| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | time_helper.cpp | 23 std::mutex TimeHelper::systemTimeLock_;
24 Timestamp TimeHelper::lastSystemTimeUs_ = 0;
25 Timestamp TimeHelper::currentIncCount_ = 0;
28 Timestamp TimeHelper::GetSysCurrentTime() in GetSysCurrentTime()
50 int TimeHelper::GetSysCurrentRawTime(uint64_t &curTime) in GetSysCurrentRawTime()
64 TimeHelper::TimeHelper() in TimeHelper() function in DistributedDB::TimeHelper
70 TimeHelper::~TimeHelper() in ~TimeHelper()
103 Timestamp TimeHelper::GetTime() in GetTime()
125 Timestamp TimeHelper::GetMaxDataItemTime() in GetMaxDataItemTime()
132 TimeOffset TimeHelper::GetLocalTimeOffset() const in GetLocalTimeOffset()
[all …]
|
| H A D | time_helper.h | 26 class TimeHelper {
44 TimeHelper();
45 ~TimeHelper();
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_register_conflict_test.cpp | 277 Timestamp timeEnd = TimeHelper::GetSysCurrentTime(); in SyncPutConflictData()
311 Timestamp time = TimeHelper::GetSysCurrentTime(); in SyncDeleteConflictData()
335 Timestamp time = TimeHelper::GetSysCurrentTime(); in SyncPutFromDiffDevConflictData()
356 Timestamp time = TimeHelper::GetSysCurrentTime(); in SyncDeleteFromDiffDevConflictData()
466 Timestamp time = TimeHelper::GetSysCurrentTime();
499 Timestamp time = TimeHelper::GetSysCurrentTime();
536 Timestamp time = TimeHelper::GetSysCurrentTime();
728 Timestamp timeEnd = TimeHelper::GetSysCurrentTime();
757 Timestamp timeEnd = TimeHelper::GetSysCurrentTime();
826 Timestamp timeEnd = TimeHelper::GetSysCurrentTime();
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | generic_syncer.cpp | 289 std::shared_ptr<TimeHelper> timeHelper = nullptr; in GetTimestamp()
300 return TimeHelper::GetSysCurrentTime(); in GetTimestamp()
304 return TimeHelper::GetSysCurrentTime(); in GetTimestamp()
404 timeHelper_ = std::make_shared<TimeHelper>(); in InitTimeHelper()
995 static_cast<TimeOffset>(TimeHelper::TO_100_NS); in RecordTimeChangeOffset()
997 TimeOffset currentSysTime = static_cast<TimeOffset>(TimeHelper::GetSysCurrentTime()); in RecordTimeChangeOffset()
1000 if ((orgOffset + currentSysTime) > TimeHelper::BUFFER_VALID_TIME) { in RecordTimeChangeOffset()
1001 orgOffset = TimeHelper::BUFFER_VALID_TIME - in RecordTimeChangeOffset()
1002 currentSysTime + static_cast<TimeOffset>(TimeHelper::MS_TO_100_NS); in RecordTimeChangeOffset()
1006 static_cast<TimeOffset>(TimeHelper::MS_TO_100_NS); // 1ms in RecordTimeChangeOffset()
|
| H A D | time_sync.cpp | 194 timeHelper_ = std::make_unique<TimeHelper>(); in Initialize()
392 packetData.GetSourceTimeEnd() > TimeHelper::MAX_VALID_TIME || in AckRecv()
393 packetData.GetTargetTimeEnd() > TimeHelper::MAX_VALID_TIME) { in AckRecv()
420 if (ackPacket.GetSourceTimeBegin() > TimeHelper::MAX_VALID_TIME) { in RequestRecv()
529 TimeHelper::GetSysCurrentTime(), errCode, timeout); in GetTimeOffset()
|
| H A D | time_sync.h | 154 std::unique_ptr<TimeHelper> timeHelper_;
|
| H A D | sync_task_context.h | 284 std::unique_ptr<TimeHelper> timeHelper_;
|
| H A D | generic_syncer.h | 223 std::shared_ptr<TimeHelper> timeHelper_;
|
| H A D | sync_task_context.cpp | 476 return TimeHelper::INVALID_TIMESTAMP; in GetCurrentLocalTime()
824 std::to_string(TimeHelper::GetSysCurrentTime())); in GenerateRequestSessionId()
|
| H A D | meta_data.cpp | 59 int err = SaveLocalTimeOffset(TimeHelper::BASE_OFFSET); in Initialize()
84 metadata.lastUpdateTime = TimeHelper::GetSysCurrentTime(); in SaveTimeOffset()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_time_sync_test.cpp | 148 TimeHelper::GetSysCurrentTime() + TimeHelper::BASE_OFFSET + offsetA, 0);
158 TimeHelper::GetSysCurrentTime() + TimeHelper::BASE_OFFSET + offsetB, 0);
|
| H A D | distributeddb_single_ver_p2p_simple_sync_test.cpp | 436 TimeHelper::GetSysCurrentTime() + g_deviceB->GetLocalTimeOffset() + TIME_OFFSET, 0);
444 TimeHelper::GetSysCurrentTime() + g_deviceC->GetLocalTimeOffset() - TIME_OFFSET, 0);
498 TimeHelper::GetSysCurrentTime() + g_deviceB->GetLocalTimeOffset() + TIME_OFFSET, 1);
506 TimeHelper::GetSysCurrentTime() + g_deviceC->GetLocalTimeOffset() - TIME_OFFSET, 0);
642 TimeHelper::GetSysCurrentTime() + g_deviceB->GetLocalTimeOffset() + TIME_OFFSET, 0);
649 TimeHelper::GetSysCurrentTime() + g_deviceC->GetLocalTimeOffset() - TIME_OFFSET, 0);
720 TimeHelper::GetSysCurrentTime() + g_deviceB->GetLocalTimeOffset() + TIME_OFFSET, 1);
728 TimeHelper::GetSysCurrentTime() + g_deviceC->GetLocalTimeOffset() - TIME_OFFSET, 1);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_sqlite_ext.cpp | 131 class TimeHelper { class
299 Timestamp localTimeOffset_ = TimeHelper::BASE_OFFSET;
321 TimeHelper timeHelper; in AddStore()
340 return TimeHelper::INVALID_TIMESTAMP; in GetLastTime()
362 return TimeHelper::INVALID_TIMESTAMP; in GetTime()
369 std::map<std::string, TimeHelper> metaData_;
372 std::mutex TimeHelper::systemTimeLock_;
373 Timestamp TimeHelper::lastSystemTimeUs_ = 0;
374 Timestamp TimeHelper::currentIncCount_ = 0;
563 TimeOffset localTimeOffset = TimeHelper::BASE_OFFSET; in GetSysTime()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_task_context.cpp | 42 timeHelper_ = std::make_unique<TimeHelper>(); in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 225 Timestamp now = TimeHelper::GetSysCurrentTime(); in GenerateDataRecords()
289 Timestamp now = TimeHelper::GetSysCurrentTime(); in DeleteCloudDBData()
420 Timestamp now = TimeHelper::GetSysCurrentTime(); in UpdateCloudAssets()
|
| H A D | cloud_db_sync_utils_test.cpp | 85 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertCloudTableRecord()
116 Timestamp now = TimeHelper::GetSysCurrentTime(); in UpdateCloudTableRecord()
|
| H A D | virtual_cloud_db.cpp | 252 tableData.extend[g_modifiedField] = (int64_t)TimeHelper::GetSysCurrentTime() / in DeleteByGid()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 224 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertRecordWithoutPk2LocalAndCloud()
257 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertCloudTableRecord()
395 Timestamp now = TimeHelper::GetSysCurrentTime(); in UpdateDiffType()
950 Timestamp now = TimeHelper::GetSysCurrentTime(); in UpdateCloudAssetForDownloadAssetTest003()
1021 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertCloudForCloudProcessNotify001()
1568 Timestamp now = TimeHelper::GetSysCurrentTime();
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 256 Timestamp now = TimeHelper::GetSysCurrentTime(); in UpdateCloudTableRecord()
636 Timestamp now = DistributedDB::TimeHelper::GetSysCurrentTime(); in InsertCloudAssetData()
|
| H A D | distributeddb_cloud_reference_sync_test.cpp | 270 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertCloudSharedTableRecord()
308 Timestamp now = TimeHelper::GetSysCurrentTime(); in UpdateCloudSharedTableRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 65 timeHelper_ = std::make_unique<TimeHelper>(); in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 215 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertCloudTableRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_utils.cpp | 1405 sqlite3_result_int64(ctx, (sqlite3_int64)TimeHelper::GetSysCurrentTime()); in GetSysTime()
1416 int errCode = TimeHelper::GetSysCurrentRawTime(curTime); in GetRawSysTime()
1431 sqlite3_result_int64(ctx, (sqlite3_int64)TimeHelper::GetSysCurrentTime()); in GetLastTime()
|
| H A D | sqlite_single_ver_natural_store.cpp | 1320 int64_t localTimeOffset = TimeHelper::BASE_OFFSET; in GetTimestampFromDB()
1332 uint64_t currentSysTime = TimeHelper::GetSysCurrentTime(); in GetTimestampFromDB()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 280 Timestamp now = TimeHelper::GetSysCurrentTime(); in InsertCloudTableRecord()
389 Timestamp now = TimeHelper::GetSysCurrentTime(); in DeleteCloudTableRecord()
|