Searched refs:sync_message_tasks_ (Results 1 – 2 of 2) sorted by relevance
181 auto iter = router_->sync_message_tasks_.find(id_); in EnsureSyncWatcherExists()182 if (iter != router_->sync_message_tasks_.end() && !iter->second.empty()) in EnsureSyncWatcherExists()313 sync_message_tasks_.clear(); in ~MultiplexRouter()502 sync_message_tasks_[id].push_back(task); in Accept()602 auto& sync_message_queue = sync_message_tasks_[id]; in ProcessTasks()616 auto& sync_message_queue = sync_message_tasks_[id]; in ProcessTasks()623 auto iter = sync_message_tasks_.find(id); in ProcessTasks()624 if (iter != sync_message_tasks_.end() && iter->second.empty()) in ProcessTasks()625 sync_message_tasks_.erase(iter); in ProcessTasks()634 auto iter = sync_message_tasks_.find(id); in ProcessFirstSyncMessageForEndpoint()[all …]
225 std::map<InterfaceId, std::deque<Task*>> sync_message_tasks_; variable