Home
last modified time | relevance | path

Searched refs:subscribeManager (Results 1 – 2 of 2) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp2019 std::shared_ptr<SubscribeManager> subscribeManager = context->GetSubscribeManager(); in SubscribeRequestRecv() local
2020 if (subscribeManager == nullptr) { in SubscribeRequestRecv()
2036 RemoveSubscribeIfNeed(packet->GetQuery().GetIdentify(), subscribeManager); in SubscribeRequestRecv()
2042 subscribeManager->DeleteRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()
2043 RemoveSubscribeIfNeed(packet->GetQuery().GetIdentify(), subscribeManager); in SubscribeRequestRecv()
2048 subscribeManager->ActiveRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()
2062 std::shared_ptr<SubscribeManager> subscribeManager = context->GetSubscribeManager(); in UnsubscribeRequestRecv() local
2063 if (subscribeManager == nullptr) { in UnsubscribeRequestRecv()
2085 subscribeManager->RemoveRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in UnsubscribeRequestRecv()
2137 const std::shared_ptr<SubscribeManager> &subscribeManager) in RemoveSubscribeIfNeed() argument
[all …]
H A Dsingle_ver_data_sync.h252 …cribeIfNeed(const std::string &queryId, const std::shared_ptr<SubscribeManager> &subscribeManager);