Searched refs:RemoveLocalSubscribeQuery (Results 1 – 4 of 4) sorted by relevance
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 413 subManager.RemoveLocalSubscribeQuery(device, querySyncObj1); 423 subManager.RemoveLocalSubscribeQuery(device, querySyncObj); 438 subManager.RemoveLocalSubscribeQuery(device, querySyncObj2); 659 subManager.RemoveLocalSubscribeQuery(DEVICE_A, querySyncObj); 661 subManager.RemoveLocalSubscribeQuery(DEVICE_A, queryCommonObj); 662 subManager.RemoveLocalSubscribeQuery(DEVICE_B, queryCommonObj); 687 subManager.RemoveLocalSubscribeQuery(DEVICE_A, queryCommonObj);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | subscribe_manager.h | 75 void RemoveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query);
|
H A D | subscribe_manager.cpp | 143 void SubscribeManager::RemoveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &… in RemoveLocalSubscribeQuery() function in DistributedDB::SubscribeManager
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
H A D | single_ver_data_sync.cpp | 1863 subManager->RemoveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
|