Searched refs:GetQuerySyncId (Results 1 – 7 of 7) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_kv_sync_task_context.h | 29 std::string GetQuerySyncId() const override;
|
| H A D | single_ver_data_sync.cpp | 345 GetLocalWaterMark(curType, context->GetQuerySyncId(), context, startMark); in GetUnsyncData()
459 GetLocalWaterMark(syncType, context->GetQuerySyncId(), context, localMark); in GetSyncDataTimeRange()
470 std::string queryId = context->GetQuerySyncId(); in SaveLocalWaterMark()
608 GetPeerWaterMark(curType, context->GetQuerySyncId(), in DealRemoveDeviceDataByAck()
672 std::string id = context->GetQuerySyncId(); in FillDataRequestPacket()
694 packet->SetQueryId(context->GetQuerySyncId()); in FillDataRequestPacket()
806 GetPeerWaterMark(syncType, context->GetQuerySyncId(), in PullRequestStart()
808 GetLocalWaterMark(syncType, context->GetQuerySyncId(), context, localMark); in PullRequestStart()
820 packet->SetQueryId(context->GetQuerySyncId()); in PullRequestStart()
1715 GetPeerWaterMark(curType, context->GetQuerySyncId(), context->GetDeviceId(), in FillRequestReSendPacket()
[all …]
|
| H A D | single_ver_kv_sync_task_context.cpp | 27 std::string SingleVerKvSyncTaskContext::GetQuerySyncId() const in GetQuerySyncId() function in DistributedDB::SingleVerKvSyncTaskContext
|
| H A D | single_ver_relational_sync_task_context.h | 31 std::string GetQuerySyncId() const override;
|
| H A D | single_ver_relational_sync_task_context.cpp | 29 std::string SingleVerRelationalSyncTaskContext::GetQuerySyncId() const in GetQuerySyncId() function in DistributedDB::SingleVerRelationalSyncTaskContext
|
| H A D | single_ver_sync_task_context.h | 132 virtual std::string GetQuerySyncId() const = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_mock_sync_module_test.cpp | 1777 (void) context->GetQuerySyncId(); in __anon34a84a721f02()
1792 EXPECT_EQ(context->GetQuerySyncId(), "");
|