Searched refs:rdbSubscribeResultMap_ (Results 1 – 3 of 3) sorted by relevance
114 auto rdbSubscribeResult = rdbSubscribeResultMap_.find(uri); in GetSubscribeFormDataProxies()115 if (rdbSubscribeResult != rdbSubscribeResultMap_.end()) { in GetSubscribeFormDataProxies()582 for (auto& result : rdbSubscribeResultMap_) { in RetryFailureSubscribes()716 isRdbType ? &rdbSubscribeResultMap_ : &publishSubscribeResultMap_; in AddSubscribeResultRecord()730 isRdbType ? &rdbSubscribeResultMap_ : &publishSubscribeResultMap_; in RemoveSubscribeResultRecord()748 isRdbType ? &rdbSubscribeResultMap_ : &publishSubscribeResultMap_; in PrintSubscribeState()839 auto resultMap = isRdbType ? rdbSubscribeResultMap_ : publishSubscribeResultMap_; in GetFormSubscribeKeys()
117 std::map<std::string, std::map<int64_t, SubscribeResultRecord>> rdbSubscribeResultMap_; variable
786 formDataProxyRecord.rdbSubscribeResultMap_.emplace(uriString, records);818 formDataProxyRecord.rdbSubscribeResultMap_.emplace(uriString, records);850 formDataProxyRecord.rdbSubscribeResultMap_.emplace(uriString, records);