Searched refs:remoteSubscribedTotalMap_ (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | subscribe_manager.cpp | 25 ClearSubscribeQuery(device, remoteSubscribedMap_, remoteSubscribedTotalMap_); in ClearRemoteSubscribeQuery()
32 remoteSubscribedTotalMap_.clear(); in ClearAllRemoteQuery()
45 …nt errCode = ReserveSubscribeQuery(device, query, remoteSubscribedMap_, remoteSubscribedTotalMap_); in ReserveRemoteSubscribeQuery()
55 …t errCode = ActiveSubscribeQuery(device, queryId, remoteSubscribedMap_, remoteSubscribedTotalMap_); in ActiveRemoteSubscribeQuery()
96 DeleteSubscribeQuery(device, queryId, remoteSubscribedMap_, remoteSubscribedTotalMap_); in DeleteRemoteSubscribeQuery()
140 RemoveSubscribeQuery(device, queryId, remoteSubscribedMap_, remoteSubscribedTotalMap_); in RemoveRemoteSubscribeQuery()
170 GetSubscribeQueries(device, remoteSubscribedMap_, remoteSubscribedTotalMap_, subscribeQueries); in GetRemoteSubscribeQueries()
179 auto iter = remoteSubscribedTotalMap_.find(queryId); in IsLastRemoteContainSubscribe()
180 if (iter == remoteSubscribedTotalMap_.end()) { in IsLastRemoteContainSubscribe()
196 if (remoteSubscribedTotalMap_.find(queryInfo.first) == remoteSubscribedTotalMap_.end()) { in GetRemoteSubscribeQueryIds()
[all …]
|
| H A D | subscribe_manager.h | 128 SubscribedTotalMap remoteSubscribedTotalMap_; variable
|