Home
last modified time | relevance | path

Searched refs:timeHelper_ (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.cpp139 timeHelper_(nullptr), in TimeSync()
160 timeHelper_ = nullptr; in ~TimeSync()
194 timeHelper_ = std::make_unique<TimeHelper>(); in Initialize()
196 int errCode = timeHelper_->Initialize(storage, metadata_); in Initialize()
198 timeHelper_ = nullptr; in Initialize()
232 Timestamp startTime = timeHelper_->GetTime(); in SyncStart()
387 Timestamp sourceTimeEnd = timeHelper_->GetTime(); in AckRecv()
655 Timestamp targetTimeBegin = timeHelper_->GetTime(); in BuildAckPacket()
657 Timestamp targetTimeEnd = timeHelper_->GetTime(); in BuildAckPacket()
746 info.recordTime = timeHelper_->GetSysCurrentTime(); in SaveOffsetWithAck()
[all …]
H A Dgeneric_syncer.cpp47 timeHelper_(nullptr), in GenericSyncer()
293 timeHelper = timeHelper_; in GetTimestamp()
400 if (timeHelper_ != nullptr) { in InitTimeHelper()
404 timeHelper_ = std::make_shared<TimeHelper>(); in InitTimeHelper()
405 if (timeHelper_ == nullptr) { in InitTimeHelper()
408 int errCode = timeHelper_->Initialize(syncInterface, metadata_); in InitTimeHelper()
411 timeHelper_ = nullptr; in InitTimeHelper()
966 timeHelper_ = nullptr; in ReleaseInnerResource()
H A Dsync_task_context.cpp52 timeHelper_(nullptr), in SyncTaskContext()
475 if (timeHelper_ == nullptr) { in GetCurrentLocalTime()
478 return timeHelper_->GetTime(); in GetCurrentLocalTime()
H A Dtime_sync.h154 std::unique_ptr<TimeHelper> timeHelper_; variable
H A Dsync_task_context.h284 std::unique_ptr<TimeHelper> timeHelper_; variable
H A Dgeneric_syncer.h223 std::shared_ptr<TimeHelper> timeHelper_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_task_context.cpp42 timeHelper_ = std::make_unique<TimeHelper>(); in Initialize()
43 int errCode = timeHelper_->Initialize(syncInterface, metadata); in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.cpp65 timeHelper_ = std::make_unique<TimeHelper>(); in Initialize()
66 errCode = timeHelper_->Initialize(syncInterface, metadata); in Initialize()
116 static_cast<SingleVerSyncTarget *>(*iter)->SetEndWaterMark(timeHelper_->GetTime()); in AddSyncOperation()
127 Timestamp timstamp = timeHelper_->GetTime(); in AddSyncOperation()