Home
last modified time | relevance | path

Searched refs:dataTimeRange (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_utils.cpp430 SyncTimeRange dataTimeRange = {localMark, deleteLocalMark, localMark, deleteLocalMark}; in GetQuerySyncDataTimeRange() local
437 if (dataTimeRange.endTime < tempStamp) { in GetQuerySyncDataTimeRange()
438 dataTimeRange.endTime = tempStamp; in GetQuerySyncDataTimeRange()
440 if (dataTimeRange.beginTime > tempStamp) { in GetQuerySyncDataTimeRange()
441 dataTimeRange.beginTime = tempStamp; in GetQuerySyncDataTimeRange()
446 if (dataTimeRange.deleteEndTime < tempStamp) { in GetQuerySyncDataTimeRange()
447 dataTimeRange.deleteEndTime = tempStamp; in GetQuerySyncDataTimeRange()
449 if (dataTimeRange.deleteBeginTime > tempStamp) { in GetQuerySyncDataTimeRange()
450 dataTimeRange.deleteBeginTime = tempStamp; in GetQuerySyncDataTimeRange()
455 return dataTimeRange; in GetQuerySyncDataTimeRange()
[all …]
H A Dsingle_ver_data_sync.cpp465 SyncTimeRange dataTimeRange, bool isCheckBeforUpdate) const in SaveLocalWaterMark() argument
474 if (localMark >= dataTimeRange.endTime) { in SaveLocalWaterMark()
478 errCode = metadata_->SaveLocalWaterMark(deviceId, dataTimeRange.endTime); in SaveLocalWaterMark()
486 if (localMark >= dataTimeRange.endTime) { in SaveLocalWaterMark()
489 if (deleteDataWaterMark >= dataTimeRange.deleteEndTime) { in SaveLocalWaterMark()
495 errCode = metadata_->SetSendQueryWaterMark(queryId, deviceId, dataTimeRange.endTime); in SaveLocalWaterMark()
503 dataTimeRange.deleteEndTime); in SaveLocalWaterMark()
641 reSendInfo.start = dataTimeRange.beginTime; in UpdateSendInfo()
642 reSendInfo.end = dataTimeRange.endTime; in UpdateSendInfo()
643 reSendInfo.deleteBeginTime = dataTimeRange.deleteBeginTime; in UpdateSendInfo()
[all …]
H A Dsingle_ver_data_sync.h169 SyncTimeRange dataTimeRange, bool isCheckBeforUpdate = false) const;
228 virtual void UpdateSendInfo(SyncTimeRange dataTimeRange, SingleVerSyncTaskContext *context);
H A Dsingle_ver_data_sync_utils.h86 static SyncTimeRange ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataTimeRange,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_single_ver_data_sync.h35 void CallUpdateSendInfo(SyncTimeRange dataTimeRange, SingleVerSyncTaskContext *context) in CallUpdateSendInfo() argument
37 SingleVerDataSync::UpdateSendInfo(dataTimeRange, context); in CallUpdateSendInfo()
H A Ddistributeddb_mock_sync_module_test.cpp771 SyncTimeRange dataTimeRange = {1, 0, 1, 0}; variable
772 mockDataSync.CallUpdateSendInfo(dataTimeRange, &mockSyncTaskContext);
788 .WillOnce([&dataTimeRange](
790 EXPECT_EQ(timestamp, dataTimeRange.endTime); in __anon34a84a720c02()