Home
last modified time | relevance | path

Searched refs:ReserveLocalSubscribeQuery (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp239 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(DEVICE_A, queryCommonObj) == E_OK); in InitLocalSubscribeMap()
241 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(DEVICE_B, queryCommonObj) == E_OK); in InitLocalSubscribeMap()
250 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(DEVICE_A, querySyncObj) == E_OK); in InitLocalSubscribeMap()
257 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(DEVICE_B, querySyncObj) == E_OK); in InitLocalSubscribeMap()
389 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(device, querySyncObj) == E_OK);
397 int errCode = subManager.ReserveLocalSubscribeQuery(device, querySyncObj1);
404 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(device, querySyncObj2) == E_OK);
432 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(device, querySyncObj2) == E_OK);
433 ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(device, querySyncObj2) == E_OK);
520 …ASSERT_TRUE(subManager.ReserveLocalSubscribeQuery(device + std::to_string(33), querySyncObj) != E_…
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.h54 int ReserveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query);
H A Dsubscribe_manager.cpp60 int SubscribeManager::ReserveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &… in ReserveLocalSubscribeQuery() function in DistributedDB::SubscribeManager
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp1800 … errCode = subManager->ReserveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdStart()