| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_state_machine.h | 117 virtual void SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) = 0;
138 bool StartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId);
151 virtual void DoSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId);
|
| H A D | sync_state_machine.cpp | 228 …ol SyncStateMachine::StartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in StartSaveDataNotify() argument
242 [this, sessionId, sequenceId, inMsgId](TimerId timerId) { in StartSaveDataNotify()
244 … int ret = RuntimeContext::GetInstance()->ScheduleTask([this, sessionId, sequenceId, inMsgId]() { in StartSaveDataNotify()
245 DoSaveDataNotify(sessionId, sequenceId, inMsgId); in StartSaveDataNotify()
388 void SyncStateMachine::DoSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in DoSaveDataNotify() argument
397 SendNotifyPacket(sessionId, sequenceId, inMsgId); in DoSaveDataNotify()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | mock_single_ver_state_machine.h | 45 bool CallStartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in CallStartSaveDataNotify() argument
47 return SingleVerSyncStateMachine::StartSaveDataNotify(sessionId, sequenceId, inMsgId); in CallStartSaveDataNotify()
|
| H A D | distributeddb_mock_sync_module_test.cpp | 582 .WillRepeatedly([&callCount](uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) { in __anon34a84a720b02() argument
585 (void) inMsgId; in __anon34a84a720b02()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | message.h | 42 explicit Message(uint32_t inMsgId) in Message() argument
44 messageId_ = inMsgId; in Message()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.h | 75 void SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) override;
|
| H A D | multi_ver_sync_state_machine.cpp | 305 …ltiVerSyncStateMachine::SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendNotifyPacket() argument
309 (void)inMsgId; in SendNotifyPacket()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_state_machine.h | 132 void SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) override;
|
| H A D | single_ver_data_sync.h | 89 uint32_t sequenceId, uint32_t inMsgId);
|
| H A D | single_ver_data_sync.cpp | 1236 uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendSaveDataNotifyPacket() argument
1238 if (inMsgId != DATA_SYNC_MESSAGE && inMsgId != QUERY_SYNC_MESSAGE) { in SendSaveDataNotifyPacket()
1242 Message *ackMessage = new (std::nothrow) Message(inMsgId); in SendSaveDataNotifyPacket()
|
| H A D | single_ver_sync_state_machine.cpp | 298 …gleVerSyncStateMachine::SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendNotifyPacket() argument
301 …n(context_->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT), sessionId, sequenceId, inMsgId); in SendNotifyPacket()
|