Home
last modified time | relevance | path

Searched refs:GetSendQueryWaterMark (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.h97 int GetSendQueryWaterMark(const std::string &queryId, const DeviceID &deviceId, bool isAutoLift,
H A Dsingle_ver_kv_syncer.cpp268 errCode = metadata->GetSendQueryWaterMark(queryId, device, queryWaterMark, false); in TriggerSubQuerySync()
H A Dsingle_ver_sync_task_context.cpp517 … int errCode = static_cast<SingleVerSyncStateMachine *>(stateMachine_)->GetSendQueryWaterMark( in GetCorrectedSendWaterMarkForCurrentTask()
H A Dsingle_ver_sync_state_machine.cpp1243 int SingleVerSyncStateMachine::GetSendQueryWaterMark(const std::string &queryId, const DeviceID &d… in GetSendQueryWaterMark() function in DistributedDB::SingleVerSyncStateMachine
1246 return metadata_->GetSendQueryWaterMark(queryId, deviceId, outValue, isAutoLift); in GetSendQueryWaterMark()
H A Dsingle_ver_data_sync.cpp541 metadata_->GetSendQueryWaterMark(queryIdentify, context->GetDeviceId(), in GetLocalWaterMark()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp805 EXPECT_EQ(meta.GetSendQueryWaterMark("Q1", "D1", w), E_OK);
822 EXPECT_EQ(meta.GetSendQueryWaterMark("Q1", "D1", w), E_OK);
839 EXPECT_EQ(meta.GetSendQueryWaterMark("Q2", "D2", w), E_OK);
848 EXPECT_EQ(meta.GetSendQueryWaterMark("Q3", "D3", w), E_OK);
894 EXPECT_EQ(meta.GetSendQueryWaterMark("Q1", "D1", w), E_OK);
1423 EXPECT_EQ(anotherMeta.GetSendQueryWaterMark(queryId, deviceId, waterMark), E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dmeta_data.h98 int GetSendQueryWaterMark(const std::string &queryIdentify,
H A Dmeta_data.cpp396 int Metadata::GetSendQueryWaterMark(const std::string &queryIdentify, in GetSendQueryWaterMark() function in DistributedDB::Metadata