Home
last modified time | relevance | path

Searched refs:DeleteLocalSubscribeQuery (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.h60 void DeleteLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query);
H A Dsubscribe_manager.cpp85 void SubscribeManager::DeleteLocalSubscribeQuery(const std::string &device, const QuerySyncObject &… in DeleteLocalSubscribeQuery() function in DistributedDB::SubscribeManager
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp686 subManager.DeleteLocalSubscribeQuery(DEVICE_A, queryCommonObj);
714 subManager.DeleteLocalSubscribeQuery(DEVICE_A, queryObj);
717 subManager.DeleteLocalSubscribeQuery(DEVICE_A, queryCommonObj);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp554 subManager->DeleteLocalSubscribeQuery(context_->GetDeviceId(), context_->GetQuery()); in DoTimeout()
570 … subManager->DeleteLocalSubscribeQuery(context_->GetDeviceId(), context_->GetQuery()); in DoInnerErr()
H A Dsingle_ver_data_sync_utils.cpp373 subManager->DeleteLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlAckErrorHandle()
H A Dsingle_ver_data_sync.cpp1811 subManager->DeleteLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdStart()