Searched refs:SetSendQueryWaterMark (Results 1 – 6 of 6) sorted by relevance
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | query_sync_water_mark_helper.h | 56 int SetSendQueryWaterMark(const std::string &queryIdentify,
|
H A D | meta_data.h | 93 int SetSendQueryWaterMark(const std::string &queryIdentify,
|
H A D | meta_data.cpp | 414 int Metadata::SetSendQueryWaterMark(const std::string &queryIdentify, in SetSendQueryWaterMark() function in DistributedDB::Metadata 417 return querySyncWaterMarkHelper_.SetSendQueryWaterMark(queryIdentify, deviceId, waterMark); in SetSendQueryWaterMark()
|
H A D | query_sync_water_mark_helper.cpp | 163 int QuerySyncWaterMarkHelper::SetSendQueryWaterMark(const std::string &queryIdentify, in SetSendQueryWaterMark() function in DistributedDB::QuerySyncWaterMarkHelper
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 796 EXPECT_EQ(meta.SetSendQueryWaterMark("Q1", "D1", w1), E_OK); 885 EXPECT_EQ(meta.SetSendQueryWaterMark("Q1", "D1", w2), E_OK); 1398 EXPECT_EQ(meta.SetSendQueryWaterMark(queryId, deviceId, queryWaterMark), E_OK);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
H A D | single_ver_data_sync.cpp | 495 errCode = metadata_->SetSendQueryWaterMark(queryId, deviceId, dataTimeRange.endTime); in SaveLocalWaterMark()
|