Home
last modified time | relevance | path

Searched refs:timeSync_ (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp106 timeSync_(nullptr), in SingleVerSyncStateMachine()
131 timeSync_ = std::make_shared<TimeSync>(); in Initialize()
135 timeSync_ = nullptr; in Initialize()
475 timeSync_->SetTimeSyncFinishIfNeed(); in DoTimeSync()
476 if (timeSync_->IsNeedSync()) { in DoTimeSync()
893 return timeSync_->RequestRecv(inMsg); in TimeMarkSyncRecv()
915 timeSync_ = nullptr; in Clear()
1277 if (timeSync_ != nullptr) { in NotifyClosing()
1278 timeSync_->Close(); in NotifyClosing()
1319 if (timeSync_ == nullptr) { in TimeChange()
[all …]
H A Dsingle_ver_sync_state_machine.h230 std::shared_ptr<TimeSync> timeSync_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.cpp49 timeSync_(nullptr), in MultiVerSyncStateMachine()
72 timeSync_ = std::make_unique<TimeSync>(); in Initialize()
77 errCode = timeSync_->Initialize(communicator, metadata, syncInterface, context->GetDeviceId()); in Initialize()
92 (void)timeSync_->SyncStart(); in Initialize()
328 errCode = timeSync_->RequestRecv(inMsg); in TimeSyncPacketRecvCallback()
331 errCode = timeSync_->AckRecv(inMsg); in TimeSyncPacketRecvCallback()
466 errCode = timeSync_->GetTimeOffset(outOffset, TIME_SYNC_WAIT_TIME); in OneCommitSyncFinish()
529 timeSync_ = nullptr; in Clear()
H A Dmulti_ver_sync_state_machine.h132 std::unique_ptr<TimeSync> timeSync_; variable