Searched refs:localSubscribeTotalMap_ (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 | 39 ClearSubscribeQuery(device, localSubscribeMap_, localSubscribeTotalMap_); in ClearLocalSubscribeQuery()
63 int errCode = ReserveSubscribeQuery(device, query, localSubscribeMap_, localSubscribeTotalMap_); in ReserveLocalSubscribeQuery()
73 … int errCode = ActiveSubscribeQuery(device, queryId, localSubscribeMap_, localSubscribeTotalMap_); in ActiveLocalSubscribeQuery()
89 DeleteSubscribeQuery(device, queryId, localSubscribeMap_, localSubscribeTotalMap_); in DeleteLocalSubscribeQuery()
126 auto iterTmp = localSubscribeTotalMap_.find(queryId); in GetAllUnFinishSubQueries()
127 if (iterTmp == localSubscribeTotalMap_.end()) { in GetAllUnFinishSubQueries()
147 RemoveSubscribeQuery(device, queryId, localSubscribeMap_, localSubscribeTotalMap_); in RemoveLocalSubscribeQuery()
163 GetSubscribeQueries(device, localSubscribeMap_, localSubscribeTotalMap_, subscribeQueries); in GetLocalSubscribeQueries()
219 auto allIter = localSubscribeTotalMap_.find(queryId); in LocalSubscribeLimitCheck()
220 …if (allIter == localSubscribeTotalMap_.end() && localSubscribeTotalMap_.size() >= MAX_SUBSCRIBE_NU… in LocalSubscribeLimitCheck()
|
| H A D | subscribe_manager.h | 119 SubscribedTotalMap localSubscribeTotalMap_; variable
|