Home
last modified time | relevance | path

Searched refs:tasks_ (Results 1 – 7 of 7) sorted by relevance

/external/webrtc/webrtc/base/
Dtaskrunner.cc40 tasks_.push_back(task); in StartTask()
73 for (size_t i = 0; i < tasks_.size(); ++i) { in InternalRunTasks()
74 while (!tasks_[i]->Blocked()) { in InternalRunTasks()
75 tasks_[i]->Step(); in InternalRunTasks()
82 for (size_t i = 0; i < tasks_.size(); ++i) { in InternalRunTasks()
83 if (tasks_[i]->IsDone()) { in InternalRunTasks()
84 Task* task = tasks_[i]; in InternalRunTasks()
98 tasks_[i] = NULL; in InternalRunTasks()
103 it = std::remove(tasks_.begin(), in InternalRunTasks()
104 tasks_.end(), in InternalRunTasks()
[all …]
Dtaskrunner.h87 std::vector<Task *> tasks_; variable
/external/libbrillo/brillo/message_loops/
Dfake_message_loop.cc28 tasks_.emplace(current_id, ScheduledTask{from_here, false, task}); in PostDelayedTask()
45 tasks_.emplace(current_id, ScheduledTask{from_here, persistent, task}); in WatchFileDescriptor()
53 bool ret = tasks_.erase(task_id) > 0; in CancelTask()
68 const auto& scheduled_task_ref = tasks_.find(fd_watched->second); in RunOnce()
69 if (scheduled_task_ref == tasks_.end()) { in RunOnce()
84 tasks_.erase(scheduled_task_ref); in RunOnce()
99 const auto scheduled_task_ref = tasks_.find(task_ref.second); in RunOnce()
100 if (scheduled_task_ref == tasks_.end()) in RunOnce()
115 tasks_.erase(scheduled_task_ref); in RunOnce()
133 for (const auto& task : tasks_) { in PendingTasks()
[all …]
Dglib_message_loop.cc22 for (const auto& task : tasks_) { in ~GlibMessageLoop()
49 tasks_[task_id] = scheduled_task; in PostDelayedTask()
120 tasks_[task_id] = scheduled_task; in WatchFileDescriptor()
127 const auto task = tasks_.find(task_id); in CancelTask()
129 if (task == tasks_.end()) in CancelTask()
136 tasks_.erase(task); in CancelTask()
157 } while (!res || tasks_.find(res) != tasks_.end()); in NextTaskId()
168 scheduled_task->loop->tasks_.erase(scheduled_task->task_id); in OnRanPostedTask()
184 scheduled_task->loop->tasks_.erase(scheduled_task->task_id); in OnWatchedFdReady()
Dglib_message_loop.h74 std::map<MessageLoop::TaskId, ScheduledTask*> tasks_; variable
Dfake_message_loop.h72 std::map<MessageLoop::TaskId, ScheduledTask> tasks_; variable
/external/webrtc/webrtc/libjingle/xmpp/
Dfakexmppclient.h74 tasks_.push_back(task); in AddXmppTask()
78 std::remove(tasks_.begin(), tasks_.end(), task); in RemoveXmppTask()
88 for (std::vector<XmppTask*>::iterator task = tasks_.begin(); in HandleStanza()
89 task != tasks_.end(); ++task) { in HandleStanza()
100 std::vector<XmppTask*> tasks_; variable