Home
last modified time | relevance | path

Searched refs:task_runner_ (Results 1 – 23 of 23) sorted by relevance

/external/webrtc/webrtc/base/
Dtask_unittest.cc138 stuck_[i].task_ = new StuckTask(&task_runner_); in Start()
149 happy_[i].task_ = new HappyTask(&task_runner_); in Start()
188 task_runner_.RunTasks(); in Start()
193 for (int i = 0; !task_runner_.AllChildrenDone() && i < STUCK_TASK_COUNT; in Start()
202 task_runner_.PollTasks(); in Start()
259 EXPECT_TRUE(task_runner_.AllChildrenDone()); in check_passed()
285 MyTaskRunner task_runner_; member in rtc::TaskTest
320 Task *abort_task = new AbortTask(&task_runner_); in Start()
325 task_runner_.RunTasks(); in Start()
333 MyTaskRunner task_runner_; member in rtc::TaskAbortTest
[all …]
/external/libchrome/base/memory/
Dref_counted_delete_on_message_loop.h42 : task_runner_(std::move(task_runner)) { in RefCountedDeleteOnMessageLoop()
43 DCHECK(task_runner_); in RefCountedDeleteOnMessageLoop()
61 if (task_runner_->BelongsToCurrentThread()) in DestructOnMessageLoop()
64 task_runner_->DeleteSoon(FROM_HERE, t); in DestructOnMessageLoop()
67 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable
/external/libmojo/mojo/public/cpp/bindings/lib/
Dinterface_endpoint_client.cc45 task_runner_(std::move(runner)) {} in ResponderThunk()
53 if (task_runner_->RunsTasksOnCurrentThread()) { in ~ResponderThunk()
62 task_runner_->PostTask( in ~ResponderThunk()
71 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in Accept()
85 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in IsValid()
90 if (task_runner_->RunsTasksOnCurrentThread()) { in DCheckInvalid()
93 task_runner_->PostTask( in DCheckInvalid()
101 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in mojo::__anon43d9db350111::ResponderThunk
144 task_runner_(std::move(runner)), in InterfaceEndpointClient()
154 handle_, this, task_runner_); in InterfaceEndpointClient()
[all …]
Drouter.cc37 task_runner_(std::move(runner)) {} in ResponderThunk()
45 if (task_runner_->RunsTasksOnCurrentThread()) { in ~ResponderThunk()
53 task_runner_->PostTask(FROM_HERE, in ~ResponderThunk()
61 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in Accept()
75 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in IsValid()
80 if (task_runner_->RunsTasksOnCurrentThread()) { in DCheckInvalid()
83 task_runner_->PostTask(FROM_HERE, in DCheckInvalid()
91 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in mojo::internal::__anone1c907070111::ResponderThunk
Dmultiplex_router.cc64 return task_runner_.get(); in task_runner()
76 task_runner_ = std::move(runner); in AttachClient()
85 DCHECK(task_runner_->BelongsToCurrentThread()); in DetachClient()
88 task_runner_ = nullptr; in DetachClient()
112 DCHECK(task_runner_->BelongsToCurrentThread()); in SendMessage()
118 DCHECK(task_runner_->BelongsToCurrentThread()); in AllowWokenUpBySyncWatchOnSameThread()
125 DCHECK(task_runner_->BelongsToCurrentThread()); in SyncWatch()
144 DCHECK(task_runner_->BelongsToCurrentThread()); in OnHandleReady()
173 DCHECK(task_runner_->BelongsToCurrentThread()); in EnsureSyncWatcherExists()
231 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in mojo::internal::MultiplexRouter::InterfaceEndpoint
[all …]
Dconnector.cc51 task_runner_(std::move(runner)), in Connector()
52 handle_watcher_(task_runner_), in Connector()
244 task_runner_->PostTask( in WaitToReadMore()
/external/libchrome/base/threading/
Dthread_task_runner_handle.cc27 return current->task_runner_; in Get()
37 : task_runner_(std::move(task_runner)) { in ThreadTaskRunnerHandle()
38 DCHECK(task_runner_->BelongsToCurrentThread()); in ThreadTaskRunnerHandle()
46 DCHECK(task_runner_->BelongsToCurrentThread()); in ~ThreadTaskRunnerHandle()
Dsequenced_task_runner_handle.cc32 return handle->task_runner_; in Get()
56 : task_runner_(std::move(task_runner)) { in SequencedTaskRunnerHandle()
57 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in SequencedTaskRunnerHandle()
63 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in ~SequencedTaskRunnerHandle()
Dsequenced_task_runner_handle.h38 scoped_refptr<SequencedTaskRunner> task_runner_;
Dthread_task_runner_handle.h36 scoped_refptr<SingleThreadTaskRunner> task_runner_;
/external/libmojo/mojo/public/cpp/system/
Dwatcher.cc50 : task_runner_(std::move(runner)), in Watcher()
51 is_default_task_runner_(task_runner_ == in Watcher()
54 DCHECK(task_runner_->BelongsToCurrentThread()); in Watcher()
137 watcher->task_runner_->RunsTasksOnCurrentThread() && in CallOnHandleReady()
144 watcher->task_runner_->PostTask( in CallOnHandleReady()
Dwatcher.h98 const scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
/external/libchrome/base/files/
Dfile_path_watcher.h62 return task_runner_; in task_runner()
66 task_runner_ = std::move(runner); in set_task_runner()
79 scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
Dimportant_file_writer.cc141 task_runner_(std::move(task_runner)), in ImportantFileWriter()
146 DCHECK(task_runner_); in ImportantFileWriter()
220 task_runner_.get(), in PostWriteTask()
226 return task_runner_->PostTask( in PostWriteTask()
Dimportant_file_writer.h122 const scoped_refptr<SequencedTaskRunner> task_runner_; variable
Dfile_path_watcher_unittest.cc51 NotificationCollector() : task_runner_(base::ThreadTaskRunnerHandle::Get()) {} in NotificationCollector()
55 task_runner_->PostTask( in OnChange()
78 ASSERT_TRUE(task_runner_->BelongsToCurrentThread()); in RecordChange()
84 task_runner_->PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure()); in RecordChange()
94 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in base::__anonf96a742c0111::NotificationCollector
/external/libchrome/base/timer/
Dtimer.cc99 task_runner_.swap(task_runner); in SetTaskRunner()
173 return task_runner_.get() ? task_runner_ : ThreadTaskRunnerHandle::Get(); in GetTaskRunner()
Dtimer.h161 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable
/external/libchrome/base/message_loop/
Dmessage_loop.cc183 task_runner_ = NULL; in ~MessageLoop()
282 task_runner_->PostTask(from_here, task); in PostTask()
289 task_runner_->PostDelayedTask(from_here, task, delay); in PostDelayedTask()
399 task_runner_(unbound_task_runner_), in MessageLoop()
442 task_runner_ = std::move(task_runner); in SetTaskRunner()
451 thread_task_runner_handle_.reset(new ThreadTaskRunnerHandle(task_runner_)); in SetThreadTaskRunnerHandle()
Dmessage_loop.h301 return task_runner_; in task_runner()
542 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable
/external/libmojo/mojo/public/cpp/bindings/
Dconnector.h146 return task_runner_.get(); in task_runner()
180 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
Dinterface_endpoint_client.h144 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
/external/libchrome/base/trace_event/
Dtrace_event_system_stats_monitor.h57 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable