Searched refs:subscribeRecords_ (Results 1 – 10 of 10) sorted by relevance
48 …auto it = std::find_if(subscribeRecords_.begin(), subscribeRecords_.end(), [&eventListener](const … in SubscribeDistributedAccountEvent()51 if (it != subscribeRecords_.end()) { in SubscribeDistributedAccountEvent()62 subscribeRecords_.emplace_back(subscribeRecordPtr); in SubscribeDistributedAccountEvent()75 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in UnsubscribeDistributedAccountEvent()85 subscribeRecords_.erase(it); in UnsubscribeDistributedAccountEvent()106 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in UnsubscribeDistributedAccountEvent()109 subscribeRecords_.erase(it); in UnsubscribeDistributedAccountEvent()135 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in Publish()
87 subscribeRecords_.emplace_back(subscribeRecordPtr); in InsertSubscribeRecord()101 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in RemoveSubscribeRecord()104 subscribeRecords_.erase(it); in RemoveSubscribeRecord()122 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in GetSubscribeRecordInfo()161 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in Publish()196 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in Publish()
203 auto iter = subscribeRecords_.find(eventCb); in SubscribeProfileEvents()204 if (iter != subscribeRecords_.end()) { in SubscribeProfileEvents()224 iter = subscribeRecords_.find(eventCb); in SubscribeProfileEvents()225 if (iter != subscribeRecords_.end()) { in SubscribeProfileEvents()230 subscribeRecords_.emplace(eventCb, std::move(record)); in SubscribeProfileEvents()257 auto iter = subscribeRecords_.find(eventCb); in UnsubscribeProfileEvents()258 if (iter == subscribeRecords_.end()) { in UnsubscribeProfileEvents()272 iter = subscribeRecords_.find(eventCb); in UnsubscribeProfileEvents()273 if (iter != subscribeRecords_.end()) { in UnsubscribeProfileEvents()280 subscribeRecords_.erase(iter); in UnsubscribeProfileEvents()
86 int size = OsAccountSubscribeManager::GetInstance().subscribeRecords_.size();92 size = OsAccountSubscribeManager::GetInstance().subscribeRecords_.size();111 int size = OsAccountSubscribeManager::GetInstance().subscribeRecords_.size();131 int size = OsAccountSubscribeManager::GetInstance().subscribeRecords_.size();
210 subscribeRecords_.emplace_back(subscribeRecordPtr); in InsertSubscribeRecord()225 for (auto it = subscribeRecords_.begin(); it != subscribeRecords_.end(); ++it) { in RemoveSubscribeRecord()229 subscribeRecords_.erase(it); in RemoveSubscribeRecord()
47 std::vector<DistributedSubscribeRecordPtr> subscribeRecords_; variable
53 std::vector<OsSubscribeRecordPtr> subscribeRecords_; variable
60 std::vector<AppAccountSubscribeRecordPtr> subscribeRecords_; variable
87 std::map<std::shared_ptr<IProfileEventCallback>, SubscribeRecord> subscribeRecords_; variable
426 DistributedDeviceProfileClient::GetInstance().subscribeRecords_[callback] = subscribeRecord;690 DistributedDeviceProfileClient::GetInstance().subscribeRecords_[eventCb] = subscribeRecord;1057 DistributedDeviceProfileClient::GetInstance().subscribeRecords_[callback] = subscribeRecord;