| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_data_sync.cpp | 102 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
107 case TYPE_REQUEST: in Serialization()
123 case TYPE_REQUEST: in DeSerialization()
134 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
141 case TYPE_REQUEST: in CalculateLen()
216 if (!IsPacketValid(message, TYPE_REQUEST)) { in RequestRecvCallback()
336 message->SetMessageType(TYPE_REQUEST); in SendFinishedRequest()
361 if ((inMsg == nullptr) || !IsPacketValid(inMsg, TYPE_REQUEST)) { in RequestPacketCalculateLen()
375 if ((buffer == nullptr) || !IsPacketValid(inMsg, TYPE_REQUEST)) { in RequestPacketSerialization()
405 if ((buffer == nullptr) || !IsPacketValid(inMsg, TYPE_REQUEST)) { in RequestPacketDeSerialization()
[all …]
|
| H A D | value_slice_sync.cpp | 102 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
107 case TYPE_REQUEST: in Serialization()
118 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
123 case TYPE_REQUEST: in DeSerialization()
134 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
141 case TYPE_REQUEST: in CalculateLen()
233 if (!IsPacketValid(message, TYPE_REQUEST) || context == nullptr) { in RequestRecvCallback()
328 message->SetMessageType(TYPE_REQUEST); in SendFinishedRequest()
564 message->SetMessageType(TYPE_REQUEST); in SendRequestPacket()
|
| H A D | multi_ver_sync_state_machine.cpp | 160 …if ((errCode != -E_NOT_FOUND) && (inMsg->GetMessageType() == TYPE_REQUEST) && (errCode != -E_NOT_P… in ReceiveMessageCallback()
327 case TYPE_REQUEST: in TimeSyncPacketRecvCallback()
349 case TYPE_REQUEST: in CommitHistorySyncPktRecvCallback()
378 case TYPE_REQUEST: in MultiVerDataPktRecvCallback()
405 case TYPE_REQUEST: in ValueSlicePktRecvCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_ability_sync_test.cpp | 135 msg1.SetMessageType(TYPE_REQUEST);
152 msg2.SetMessageType(TYPE_REQUEST);
186 msg1.SetMessageType(TYPE_REQUEST);
203 msg2.SetMessageType(TYPE_REQUEST);
237 msg1.SetMessageType(TYPE_REQUEST);
254 msg2.SetMessageType(TYPE_REQUEST);
294 msg1.SetMessageType(TYPE_REQUEST);
311 msg2.SetMessageType(TYPE_REQUEST);
438 msg1.SetMessageType(TYPE_REQUEST);
|
| H A D | distributeddb_anti_dos_sync_test.cpp | 187 message->SetMessageType(TYPE_REQUEST);
239 message->SetMessageType(TYPE_REQUEST);
304 message->SetMessageType(TYPE_REQUEST);
|
| H A D | distributeddb_multi_ver_p2p_sync_test.cpp | 646 oriMsgA.SetMessageType(TYPE_REQUEST);
675 outMsgA.SetMessageType(TYPE_REQUEST);
812 oriMsgA.SetMessageType(TYPE_REQUEST);
815 oriMsgB.SetMessageType(TYPE_REQUEST);
841 outMsgA.SetMessageType(TYPE_REQUEST);
854 outMsgB.SetMessageType(TYPE_REQUEST);
1011 oriMsgA.SetMessageType(TYPE_REQUEST);
1014 oriMsgB.SetMessageType(TYPE_REQUEST);
1040 outMsgA.SetMessageType(TYPE_REQUEST);
1053 outMsgB.SetMessageType(TYPE_REQUEST);
|
| H A D | distributeddb_time_sync_test.cpp | 341 msg->SetMessageType(TYPE_REQUEST);
358 msg->SetMessageType(TYPE_REQUEST);
437 msg->SetMessageType(TYPE_REQUEST);
|
| H A D | distributeddb_single_ver_p2p_sync_check_test.cpp | 785 } else if (!invalid && inMsg->GetMessageType() == TYPE_REQUEST) { in RegOnDispatchWithOffline()
798 if (dev == DEVICE_B && !invalid && inMsg->GetMessageType() == TYPE_REQUEST) { in RegOnDispatchWithInvalidMsg()
921 if (dev != DEVICE_B || (!calResponse && msg->GetMessageType() != TYPE_REQUEST)) { in RegOnDispatchWithoutDataPacket()
1091 if (dev == DEVICE_B && inMsg->GetMessageType() == TYPE_REQUEST) { in RegOnDispatchToGetSyncCount()
1301 if (dev == DEVICE_B && !invalid && inMsg->GetMessageType() == TYPE_REQUEST) { in RegOnDispatchWithInvalidMsgAndCnt()
|
| H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 286 msg.SetMessageType(TYPE_REQUEST);
302 outMsg.SetMessageType(TYPE_REQUEST);
|
| H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 644 msg.SetMessageType(TYPE_REQUEST);
657 outMsg.SetMessageType(TYPE_REQUEST);
|
| H A D | distributeddb_relational_multi_user_test.cpp | 420 msg->GetMessageType() != TYPE_REQUEST) { in RegOnDispatchWithoutDataPacket()
|
| H A D | distributeddb_single_ver_p2p_complex_sync_test.cpp | 387 } else if (msg->GetMessageType() == TYPE_REQUEST) { in __anonb4f3bed90302()
621 …== DEVICE_B && msg->GetMessageId() == TIME_SYNC_MESSAGE && msg->GetMessageType() == TYPE_REQUEST) { in __anonb4f3bed91102()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 143 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
148 case TYPE_REQUEST: in Serialization()
159 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
164 case TYPE_REQUEST: in DeSerialization()
175 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
182 case TYPE_REQUEST: in CalculateLen()
253 if (!IsPacketValid(message, TYPE_REQUEST) || context == nullptr) { in RequestRecvCallback()
332 …Msg->GetMessageId() != COMMIT_HISTORY_SYNC_MESSAGE) || (inMsg->GetMessageType() != TYPE_REQUEST)) { in RequestPacketCalculateLen()
633 message->SetMessageType(TYPE_REQUEST); in SendRequestPacket()
|
| H A D | time_sync.cpp | 245 message->SetMessageType(TYPE_REQUEST); in SyncStart()
263 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
277 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
322 …ffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
409 if (!IsPacketValid(message, TYPE_REQUEST)) { in RequestRecv()
|
| H A D | ability_sync.cpp | 392 message->SetMessageType(TYPE_REQUEST); in SyncStart()
635 case TYPE_REQUEST: in CalculateLen()
667 case TYPE_REQUEST: in Serialization()
684 case TYPE_REQUEST: in DeSerialization()
|
| H A D | remote_executor.cpp | 484 message->SetMessageType(TYPE_REQUEST); in RequestStart()
787 case TYPE_REQUEST: in ReceiveMessageInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | message.h | 31 constexpr uint16_t TYPE_REQUEST = 1; variable
113 if (inMsgType != TYPE_REQUEST && inMsgType != TYPE_RESPONSE && inMsgType != TYPE_NOTIFY) { in SetMessageType()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 56 case TYPE_REQUEST: in DataSerialization()
69 case TYPE_REQUEST: in ControlSerialization()
102 case TYPE_REQUEST: in DataDeSerialization()
115 case TYPE_REQUEST: in ControlDeSerialization()
150 case TYPE_REQUEST: in CalculateDataLen()
175 case TYPE_REQUEST: in CalculateControlLen()
321 if (msgType != TYPE_REQUEST && msgType != TYPE_RESPONSE && msgType != TYPE_NOTIFY) { in IsPacketValid()
838 case TYPE_REQUEST: in BuildISyncPacket()
|
| H A D | single_ver_sync_state_machine.cpp | 585 if (inMsg->GetMessageType() == TYPE_REQUEST) { in AbilitySyncRecv()
766 case TYPE_REQUEST: in DataPktRecv()
827 case TYPE_REQUEST: in ControlPktRecv()
892 if (inMsg->GetMessageType() == TYPE_REQUEST) { in TimeMarkSyncRecv()
|
| H A D | single_ver_data_sync.cpp | 1060 SingleVerDataSyncUtils::SetMessageHeadInfo(*message, TYPE_REQUEST, context->GetDeviceId(), in SendDataPacket()
1105 SingleVerDataSyncUtils::SetMessageHeadInfo(*message, TYPE_REQUEST, context->GetDeviceId(), in SendPullResponseDataPkt()
1457 …SingleVerDataSyncUtils::SetMessageHeadInfo(*message, TYPE_REQUEST, context->GetDeviceId(), sequenc… in SendReSendPacket()
1915 SingleVerDataSyncUtils::SetMessageHeadInfo(*message, TYPE_REQUEST, context->GetDeviceId(), in SendControlPacket()
|
| H A D | single_ver_data_sync_utils.cpp | 356 …controlCmdType == ControlCmdType::SUBSCRIBE_QUERY_CMD && inMsg->GetMessageType() == TYPE_REQUEST) { in IsNeedTriggerQueryAutoSync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator.cpp | 241 if (oriMsg == nullptr || oriMsg->GetMessageType() != TYPE_REQUEST) { in TriggerUnknownMessageFeedback()
|
| H A D | communicator_aggregator.cpp | 832 if (oriMsg == nullptr || oriMsg->GetMessageType() != TYPE_REQUEST) { in TriggerCommunicatorNotFoundFeedback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_send_receive_test.cpp | 115 info.messageType_ = TYPE_REQUEST; in BuildAppLayerFrameMessage()
169 EXPECT_EQ(recvMsgForBA->GetMessageType(), TYPE_REQUEST);
|
| H A D | distributeddb_communicator_common.cpp | 203 outMsg->SetMessageType(TYPE_REQUEST); in BuildRegedTinyMessage()
|