| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_data_sync.cpp | 102 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
118 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
134 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
216 if (!IsPacketValid(message, TYPE_REQUEST)) { in RequestRecvCallback()
257 if (!IsPacketValid(message, TYPE_RESPONSE) || (context == nullptr)) { in AckRecvCallback()
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()
440 if (!IsPacketValid(inMsg, TYPE_RESPONSE)) { in AckPacketCalculateLen()
454 if ((buffer == nullptr) || !IsPacketValid(inMsg, TYPE_RESPONSE)) { in AckPacketSerialization()
[all …]
|
| H A D | value_slice_sync.cpp | 102 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
118 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
134 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
233 if (!IsPacketValid(message, TYPE_REQUEST) || context == nullptr) { in RequestRecvCallback()
269 if (!IsPacketValid(message, TYPE_RESPONSE) || (context == nullptr)) { in AckRecvCallback()
424 if ((buffer == nullptr) || !IsPacketValid(inMsg, TYPE_RESPONSE)) { in AckPacketSerialization()
489 bool ValueSliceSync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid() function in DistributedDB::ValueSliceSync
|
| H A D | multi_ver_sync_state_machine.h | 112 bool IsPacketValid(const Message *inMsg) const;
|
| H A D | value_slice_sync.h | 102 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
|
| H A D | multi_ver_data_sync.h | 112 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
|
| H A D | multi_ver_sync_state_machine.cpp | 127 if (!IsPacketValid(inMsg)) { in MessageCallbackCheck()
499 bool MultiVerSyncStateMachine::IsPacketValid(const Message *inMsg) const in IsPacketValid() function in DistributedDB::MultiVerSyncStateMachine
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 143 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
159 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
175 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
253 if (!IsPacketValid(message, TYPE_REQUEST) || context == nullptr) { in RequestRecvCallback()
296 if (!IsPacketValid(message, TYPE_RESPONSE) || (context == nullptr)) { in AckRecvCallback()
535 bool CommitHistorySync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid() function in DistributedDB::CommitHistorySync
|
| H A D | time_sync.cpp | 263 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
277 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
322 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
377 if (!IsPacketValid(message, TYPE_RESPONSE)) { in AckRecv()
409 if (!IsPacketValid(message, TYPE_REQUEST)) { in RequestRecv()
468 bool TimeSync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid() function in DistributedDB::TimeSync
|
| H A D | commit_history_sync.h | 122 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
|
| H A D | time_sync.h | 120 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
|
| H A D | remote_executor.h | 78 virtual bool IsPacketValid(uint32_t sessionId);
|
| H A D | remote_executor.cpp | 284 if (!IsPacketValid(sessionId)) { in ReceiveRemoteExecutorAck()
780 if (inMsg->IsFeedbackError() && IsPacketValid(inMsg->GetSessionId())) { in ReceiveMessageInner()
803 bool RemoteExecutor::IsPacketValid(uint32_t sessionId) in IsPacketValid() function in DistributedDB::RemoteExecutor
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | mock_remote_executor.h | 26 MOCK_METHOD1(IsPacketValid, bool(uint32_t));
|
| H A D | distributeddb_mock_sync_module_test.cpp | 1569 EXPECT_CALL(*executor, IsPacketValid).WillRepeatedly(Return(true));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 33 if ((buffer == nullptr) || !(IsPacketValid(inMsg))) { in Serialization()
80 if ((buffer == nullptr) || !(IsPacketValid(inMsg))) { in DeSerialization()
126 if (!(IsPacketValid(inMsg))) { in CalculateLen()
314 bool SingleVerSerializeManager::IsPacketValid(const Message *inMsg) in IsPacketValid() function in DistributedDB::SingleVerSerializeManager
|
| H A D | single_ver_serialize_manager.h | 42 static bool IsPacketValid(const Message *inMsg);
|
| H A D | single_ver_sync_state_machine.h | 195 bool IsPacketValid(const Message *inMsg) const;
|
| H A D | single_ver_sync_state_machine.cpp | 729 if (!IsPacketValid(inMsg)) { in HandleDataAckRecv()
921 bool SingleVerSyncStateMachine::IsPacketValid(const Message *inMsg) const in IsPacketValid() function in DistributedDB::SingleVerSyncStateMachine
984 if (!IsPacketValid(inMsg)) { in MessageCallbackPre()
|