/external/webrtc/webrtc/base/ |
D | task_unittest.cc | 138 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/ |
D | ref_counted_delete_on_message_loop.h | 42 : 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/ |
D | interface_endpoint_client.cc | 45 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 …]
|
D | router.cc | 37 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
|
D | multiplex_router.cc | 64 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 …]
|
D | connector.cc | 51 task_runner_(std::move(runner)), in Connector() 52 handle_watcher_(task_runner_), in Connector() 244 task_runner_->PostTask( in WaitToReadMore()
|
/external/libchrome/base/threading/ |
D | thread_task_runner_handle.cc | 27 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()
|
D | sequenced_task_runner_handle.cc | 32 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()
|
D | sequenced_task_runner_handle.h | 38 scoped_refptr<SequencedTaskRunner> task_runner_;
|
D | thread_task_runner_handle.h | 36 scoped_refptr<SingleThreadTaskRunner> task_runner_;
|
/external/libmojo/mojo/public/cpp/system/ |
D | watcher.cc | 50 : 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()
|
D | watcher.h | 98 const scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
|
/external/libchrome/base/files/ |
D | file_path_watcher.h | 62 return task_runner_; in task_runner() 66 task_runner_ = std::move(runner); in set_task_runner() 79 scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
|
D | important_file_writer.cc | 141 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()
|
D | important_file_writer.h | 122 const scoped_refptr<SequencedTaskRunner> task_runner_; variable
|
D | file_path_watcher_unittest.cc | 51 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/ |
D | timer.cc | 99 task_runner_.swap(task_runner); in SetTaskRunner() 173 return task_runner_.get() ? task_runner_ : ThreadTaskRunnerHandle::Get(); in GetTaskRunner()
|
D | timer.h | 161 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable
|
/external/libchrome/base/message_loop/ |
D | message_loop.cc | 183 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()
|
D | message_loop.h | 301 return task_runner_; in task_runner() 542 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable
|
/external/libmojo/mojo/public/cpp/bindings/ |
D | connector.h | 146 return task_runner_.get(); in task_runner() 180 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
|
D | interface_endpoint_client.h | 144 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
|
/external/libchrome/base/trace_event/ |
D | trace_event_system_stats_monitor.h | 57 scoped_refptr<SingleThreadTaskRunner> task_runner_; variable
|