Searched refs:subscribedTotalMap (Results 1 – 2 of 2) sorted by relevance
234 SubscribedTotalMap &subscribedTotalMap) in ClearSubscribeQuery() argument241 if (subscribedTotalMap.find(queryInfo.first) != subscribedTotalMap.end()) { in ClearSubscribeQuery()262 …if (allIter == subscribedTotalMap.end() && subscribedTotalMap.size() >= MAX_SUBSCRIBE_NUM_PER_DB) { in ReserveSubscribeQuery()289 if (allIter == subscribedTotalMap.end()) { in ReserveSubscribeQuery()290 subscribedTotalMap[queryId] = {query, 1}; in ReserveSubscribeQuery()292 subscribedTotalMap[queryId].second++; in ReserveSubscribeQuery()300 if (subscribedTotalMap.find(queryId) == subscribedTotalMap.end()) { in ActiveSubscribeQuery()335 if (iter == subscribedTotalMap.end()) { in DeleteSubscribeQuery()342 subscribedTotalMap.erase(queryId); in DeleteSubscribeQuery()361 if (allIter == subscribedTotalMap.end()) { in RemoveSubscribeQuery()[all …]
92 SubscribedTotalMap &subscribedTotalMap);95 SubscribedTotalMap &subscribedTotalMap);98 SubscribedTotalMap &subscribedTotalMap);101 SubscribedTotalMap &subscribedTotalMap);104 SubscribedTotalMap &subscribedTotalMap);107 …const SubscribedTotalMap &subscribedTotalMap, std::vector<QuerySyncObject> &subscribeQueries) cons…