Home
last modified time | relevance | path

Searched refs:ReserveRemoteSubscribeQuery (Results 1 – 5 of 5) 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.cpp460 ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device, querySyncObj) == E_OK);
464 ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device, querySyncObj1) != E_OK);
474 ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device, querySyncObj2) == E_OK);
567 …ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device + std::to_string(i), querySyncObj) == E_…
570 …ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device + std::to_string(33), querySyncObj) != E…
593 …ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device + std::to_string(i), querySyncObj2) == E…
597 …ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(device + std::to_string(8), querySyncObj1) != E…
718 ASSERT_TRUE(subManager.ReserveRemoteSubscribeQuery(DEVICE_A, queryCommonObj) == E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.h48 int ReserveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &query);
H A Dsubscribe_manager.cpp42 int SubscribeManager::ReserveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject … in ReserveRemoteSubscribeQuery() function in DistributedDB::SubscribeManager
H A Dsync_engine.cpp1231 errCode = subManager_->ReserveRemoteSubscribeQuery(device, query); in AddQuerySubscribe()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp2032 …errCode = subscribeManager->ReserveRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()… in SubscribeRequestRecv()