Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp795 EXPECT_EQ(meta.SetRecvQueryWaterMark("Q1", "D1", w1), E_OK);
884 EXPECT_EQ(meta.SetRecvQueryWaterMark("Q1", "D1", w2), E_OK);
994 EXPECT_EQ(meta.SetRecvQueryWaterMark("Q1", "D1", w1), E_OK);
1050 EXPECT_EQ(meta.SetRecvQueryWaterMark("Q1", "D1", w1), E_OK);
1051 EXPECT_EQ(meta.SetRecvQueryWaterMark("Q2", "D1", w1), E_OK);
1052 EXPECT_EQ(meta.SetRecvQueryWaterMark("Q1", "D2", w1), E_OK);
1397 EXPECT_EQ(meta.SetRecvQueryWaterMark(queryId, deviceId, queryWaterMark), E_OK);
1548 EXPECT_EQ(meta.SetRecvQueryWaterMark(queryId, deviceId, recvWaterMark), E_OK); in InitVerifyStorageEnvironment()
1576 EXPECT_EQ(meta.SetRecvQueryWaterMark(newQueryId, deviceId, newWaterMark), E_OK);
1584 EXPECT_EQ(meta.SetRecvQueryWaterMark(firstItemKey, deviceId, firstWaterMark), E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dquery_sync_water_mark_helper.h59 int SetRecvQueryWaterMark(const std::string &queryIdentify,
H A Dmeta_data.h101 int SetRecvQueryWaterMark(const std::string &queryIdentify,
H A Dmeta_data.cpp390 int Metadata::SetRecvQueryWaterMark(const std::string &queryIdentify, in SetRecvQueryWaterMark() function in DistributedDB::Metadata
393 return querySyncWaterMarkHelper_.SetRecvQueryWaterMark(queryIdentify, deviceId, waterMark); in SetRecvQueryWaterMark()
H A Dquery_sync_water_mark_helper.cpp129 int QuerySyncWaterMarkHelper::SetRecvQueryWaterMark(const std::string &queryIdentify, in SetRecvQueryWaterMark() function in DistributedDB::QuerySyncWaterMarkHelper
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp901 … errCode = metadata_->SetRecvQueryWaterMark(queryId, context->GetDeviceId(), peerWatermark); in UpdatePeerWaterMark()