Lines Matching refs:receivers
185 auto& receivers = mReceivers[{.atomTag = tagId, .configKey = configKey}]; in RegisterReceiver() local
186 for (auto it = receivers.begin(); it != receivers.end(); it++) { in RegisterReceiver()
188 VLOG("Receiver already registered of %d", (int)receivers.size()); in RegisterReceiver()
206 receivers.push_back(receiverInfo); in RegisterReceiver()
214 VLOG("Puller for tagId %d registered of %d", tagId, (int)receivers.size()); in RegisterReceiver()
225 std::list<ReceiverInfo>& receivers = receiversIt->second; in UnRegisterReceiver() local
226 for (auto it = receivers.begin(); it != receivers.end(); it++) { in UnRegisterReceiver()
228 receivers.erase(it); in UnRegisterReceiver()
229 VLOG("Puller for tagId %d unregistered of %d", tagId, (int)receivers.size()); in UnRegisterReceiver()
258 vector<ReceiverInfo*> receivers; in OnAlarmFired() local
262 receivers.push_back(&receiverInfo); in OnAlarmFired()
269 if (receivers.size() > 0) { in OnAlarmFired()
270 needToPull.push_back(make_pair(&pair.first, receivers)); in OnAlarmFired()