Home
last modified time | relevance | path

Searched refs:SyncTimeRange (Results 1 – 25 of 28) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_utils.h80 …static SyncTimeRange GetFullSyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark l…
83 …static SyncTimeRange GetQuerySyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark …
86 static SyncTimeRange ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataTimeRange,
89 static SyncTimeRange GetRecvDataTimeRange(SyncType syncType,
92 …static SyncTimeRange GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, WaterMark delete…
H A Dsingle_ver_data_sync.h146 SyncTimeRange GetSyncDataTimeRange(SyncType syncType, SingleVerSyncTaskContext *context,
161 DataSizeSpecInfo syncDataSizeInfo, SyncTimeRange &waterMarkInfo);
169 SyncTimeRange dataTimeRange, bool isCheckBeforUpdate = false) const;
188 …ateQueryPeerWaterMark(SyncType syncType, const std::string &queryId, const SyncTimeRange &dataTime,
228 virtual void UpdateSendInfo(SyncTimeRange dataTimeRange, SingleVerSyncTaskContext *context);
H A Dsingle_ver_data_sync_utils.cpp406 SyncTimeRange SingleVerDataSyncUtils::GetFullSyncDataTimeRange(const std::vector<SendDataItem> &inD… in GetFullSyncDataTimeRange()
427 SyncTimeRange SingleVerDataSyncUtils::GetQuerySyncDataTimeRange(const std::vector<SendDataItem> &in… in GetQuerySyncDataTimeRange()
430 SyncTimeRange dataTimeRange = {localMark, deleteLocalMark, localMark, deleteLocalMark}; in GetQuerySyncDataTimeRange()
458 SyncTimeRange SingleVerDataSyncUtils::ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataT… in ReviseLocalMark()
461 SyncTimeRange tmpDataTime = dataTimeRange; in ReviseLocalMark()
471 SyncTimeRange SingleVerDataSyncUtils::GetRecvDataTimeRange(SyncType syncType, in GetRecvDataTimeRange()
480 SyncTimeRange SingleVerDataSyncUtils::GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, … in GetSyncDataTimeRange()
H A Dsingle_ver_data_sync.cpp341 SyncTimeRange waterRange; in GetUnsyncData()
366 DataSizeSpecInfo syncDataSizeInfo, SyncTimeRange &waterMarkInfo) in GetUnsyncData()
454 SyncTimeRange SingleVerDataSync::GetSyncDataTimeRange(SyncType syncType, SingleVerSyncTaskContext *… in GetSyncDataTimeRange()
465 SyncTimeRange dataTimeRange, bool isCheckBeforUpdate) const in SaveLocalWaterMark()
638 void SingleVerDataSync::UpdateSendInfo(SyncTimeRange dataTimeRange, SingleVerSyncTaskContext *conte… in UpdateSendInfo()
740 …SyncTimeRange dataTime = GetSyncDataTimeRange(curType, context, syncData.entries, isUpdateWaterMar… in RequestStart()
812 SyncTimeRange dataTime = {localMark, deleteMark, localMark, deleteMark}; in PullRequestStart()
855 …SyncTimeRange dataTime = GetSyncDataTimeRange(curType, context, syncData.entries, isUpdateWaterMar… in PullResponseStart()
876 …const SyncTimeRange &dataTime, const SingleVerSyncTaskContext *context, UpdateWaterMark isUpdateWa… in UpdateQueryPeerWaterMark()
1001 …SyncTimeRange dataTime = SingleVerDataSyncUtils::GetRecvDataTimeRange(curType, data, isUpdateWater… in DataRequestRecv()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_query_sync_test.cpp218 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
226 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
258 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
275 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{time3, 0, time3 + 1, 0},
390 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
471 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
524 g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries);
572 g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries);
668 EXPECT_EQ(g_store->GetSyncData(queryObj2, SyncTimeRange{}, specInfo, token, entries), E_OK);
741 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
[all …]
H A Ddistributeddb_relational_get_data_test.cpp269 std::make_unique<SQLiteSingleVerRelationalContinueToken>(SyncTimeRange {}, query); in SetNextBeginTime001()
388 int errCode = store->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries);
444 EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries), E_OK);
494 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
520 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
575 int errCode = store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries);
704 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
790 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
864 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
931 SyncTimeRange timeRange;
[all …]
H A Ddistributeddb_relational_encrypted_db_test.cpp265 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
367 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
423 … EXPECT_NE(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
444 … EXPECT_EQ(store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_OK);
H A Ddistributeddb_storage_subscribe_query_test.cpp742 EXPECT_EQ(store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_continue_token.h29 …SQLiteSingleVerRelationalContinueToken(const SyncTimeRange &timeRange, const QueryObject &queryObj…
58 SyncTimeRange timeRange_;
H A Dsqlite_single_ver_relational_continue_token.cpp21 const SyncTimeRange &timeRange, const QueryObject &queryObject) in SQLiteSingleVerRelationalContinueToken()
H A Dsqlite_single_ver_relational_storage_executor.h126 …int GetSyncCloudGid(QuerySyncObject &query, const SyncTimeRange &syncTimeRange, bool isCloudForceP…
/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()
H A Dvirtual_relational_ver_sync_db_interface.h57 int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange,
H A Dvirtual_single_ver_sync_db_Interface.h86 …int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSi…
H A Dvirtual_relational_ver_sync_db_interface.cpp125 const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSizeInfo, in GetSyncData()
H A Dvirtual_single_ver_sync_db_Interface.cpp402 int VirtualSingleVerSyncDBInterface::GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_continue_token.h31 SQLiteSingleVerContinueToken(const SyncTimeRange &timeRange, const QueryObject &queryObject);
H A Dsqlite_single_ver_continue_token.cpp26 const SyncTimeRange &timeRange, const QueryObject &queryObject) in SQLiteSingleVerContinueToken()
H A Dsqlite_single_ver_natural_store.h83 …int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSi…
H A Dsqlite_cloud_kv_store.cpp182 SyncTimeRange timeRange; in GetCloudData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h48 virtual int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddb_types.h139 struct SyncTimeRange { struct
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h79 int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp441 int RelationalSyncAbleStorage::GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData()
1109 SyncTimeRange syncTimeRange = { .beginTime = beginTime }; in GetCloudData()
1165 SyncTimeRange syncTimeRange = { .beginTime = beginTime }; in GetCloudGid()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_upload_test.cpp457 SyncTimeRange syncTimeRange = { .beginTime = 1u };
1018 SyncTimeRange syncTimeRange = { .beginTime = 1u };

12