Home
last modified time | relevance | path

Searched refs:tasks_ (Results 1 – 10 of 10) 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
/external/libmojo/mojo/public/cpp/bindings/tests/
Dbind_task_runner_unittest.cc45 tasks_.push(task); in PostDelayedTask()
62 while (!tasks_.empty()) { in Run()
63 auto task = tasks_.front(); in Run()
64 tasks_.pop(); in Run()
90 if (!tasks_.empty()) { in RunOneTask()
91 auto task = tasks_.front(); in RunOneTask()
92 tasks_.pop(); in RunOneTask()
114 std::queue<base::Closure> tasks_; member in mojo::test::__anon4c1b2fc90111::TestTaskRunner
/external/libmojo/mojo/public/cpp/bindings/lib/
Dmultiplex_router.cc314 tasks_.clear(); in ~MultiplexRouter()
422 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in AttachEndpointClient()
491 tasks_.empty() && ProcessIncomingMessage(message, client_call_behavior, in Accept()
497 tasks_.push_back(Task::CreateMessageTask(message)); in Accept()
498 Task* task = tasks_.back().get(); in Accept()
507 } else if (!tasks_.empty()) { in Accept()
535 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in OnPeerAssociatedEndpointClosed()
574 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in OnPipeConnectionError()
593 while (!tasks_.empty()) { in ProcessTasks()
594 std::unique_ptr<Task> task(std::move(tasks_.front())); in ProcessTasks()
[all …]
Dmultiplex_router.h223 std::deque<std::unique_ptr<Task>> tasks_; variable