Home
last modified time | relevance | path

Searched refs:ActiveRemoteSubscribeQuery (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.h51 int ActiveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &query);
H A Dsubscribe_manager.cpp51 int SubscribeManager::ActiveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &… in ActiveRemoteSubscribeQuery() function in DistributedDB::SubscribeManager
H A Dsync_engine.cpp1238 subManager_->ActiveRemoteSubscribeQuery(device, query); in AddQuerySubscribe()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp461 ASSERT_TRUE(subManager.ActiveRemoteSubscribeQuery(device, querySyncObj) == E_OK);
475 ASSERT_TRUE(subManager.ActiveRemoteSubscribeQuery(device, querySyncObj2) == E_OK);
568 …ASSERT_TRUE(subManager.ActiveRemoteSubscribeQuery(device + std::to_string(i), querySyncObj) == E_O…
594 …ASSERT_TRUE(subManager.ActiveRemoteSubscribeQuery(device + std::to_string(i), querySyncObj2) == E_…
719 ASSERT_TRUE(subManager.ActiveRemoteSubscribeQuery(DEVICE_A, queryCommonObj) == E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp2048 subscribeManager->ActiveRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()