/external/libchrome/components/timers/ |
D | alarm_timer_chromeos.cc | 27 DCHECK(origin_task_runner_->RunsTasksInCurrentSequence()); in ~SimpleAlarmTimer() 32 DCHECK(origin_task_runner_->RunsTasksInCurrentSequence()); in Stop() 51 DCHECK(origin_task_runner_->RunsTasksInCurrentSequence()); in Reset() 107 DCHECK(origin_task_runner_->RunsTasksInCurrentSequence()); in OnAlarmFdReadableWithoutBlocking() 119 DCHECK(origin_task_runner_->RunsTasksInCurrentSequence()); in OnTimerFired()
|
/external/libchrome/mojo/public/cpp/bindings/lib/ |
D | multiplex_router.cc | 87 DCHECK(runner->RunsTasksInCurrentSequence()); in AttachClient() 98 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in DetachClient() 130 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SendMessage() 136 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in AllowWokenUpBySyncWatchOnSameThread() 143 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SyncWatch() 159 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in OnSyncEventSignaled() 181 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in EnsureSyncWatcherExists() 327 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in MultiplexRouter() 490 if (task_runner_->RunsTasksInCurrentSequence()) { in RaiseError() 758 current_task_runner->RunsTasksInCurrentSequence()); in ProcessNotifyErrorTask() [all …]
|
D | interface_endpoint_client.cc | 54 if (task_runner_->RunsTasksInCurrentSequence()) { in ~ResponderThunk() 76 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in Accept() 90 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in IsConnected() 95 if (task_runner_->RunsTasksInCurrentSequence()) { in IsConnectedAsync()
|
D | task_runner_helper.cc | 17 DCHECK(runner->RunsTasksInCurrentSequence()); in GetTaskRunnerToUseFromUserProvidedTaskRunner()
|
/external/libchrome/mojo/core/ |
D | node_controller.cc | 118 if (task_runner->RunsTasksInCurrentSequence()) { in Create() 326 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in SendBrokerClientInvitationOnIOThread() 378 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in AcceptBrokerClientInvitationOnIOThread() 402 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in ConnectIsolatedOnIOThread() 470 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in AddPeer() 512 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in DropPeer() 652 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in DropAllPeers() 726 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnAcceptInvitee() 758 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnAcceptInvitation() 964 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnEventMessage() [all …]
|
D | channel_fuchsia.cc | 207 if (io_task_runner_->RunsTasksInCurrentSequence()) { in Start() 240 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in LeakHandle() 251 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in GetReadPlatformHandles() 315 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in WillDestroyCurrentMessageLoop() 322 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnZxHandleSignalled() 420 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnWriteError()
|
D | channel_win.cc | 97 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in LeakHandle() 199 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in WillDestroyCurrentMessageLoop() 323 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnWriteError()
|
D | channel_posix.cc | 123 if (io_task_runner_->RunsTasksInCurrentSequence()) { in Start() 184 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in LeakHandle() 323 if (io_task_runner_->RunsTasksInCurrentSequence()) { in WaitForWriteOnIOThreadNoLock() 417 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in WillDestroyCurrentMessageLoop() 685 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnWriteError()
|
/external/libchrome/ipc/ |
D | ipc_mojo_bootstrap.cc | 457 DCHECK(runner->RunsTasksInCurrentSequence()); in AttachClient() 466 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in DetachClient() 500 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SendMessage() 506 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in AllowWokenUpBySyncWatchOnSameThread() 513 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SyncWatch() 536 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in OnSyncMessageEventReady() 575 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in EnsureSyncWatcherExists() 717 if (endpoint->task_runner()->RunsTasksInCurrentSequence() && !force_async) { in NotifyEndpointOfError() 742 DCHECK(endpoint->task_runner()->RunsTasksInCurrentSequence()); in NotifyEndpointOfErrorOnEndpointThread() 800 if (!client || !endpoint->task_runner()->RunsTasksInCurrentSequence()) { in Accept() [all …]
|
D | ipc_channel_mojo.cc | 129 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in ForwardMessageFromThreadSafePtr() 139 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in ForwardMessageWithResponderFromThreadSafePtr() 147 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in ~ChannelMojo() 152 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in Connect() 194 if (task_runner_->RunsTasksInCurrentSequence()) { in OnPipeError()
|
/external/libchrome/base/threading/ |
D | sequenced_task_runner_handle.cc | 48 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SequencedTaskRunnerHandle() 54 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in ~SequencedTaskRunnerHandle()
|
/external/libchrome/base/task/sequence_manager/test/ |
D | lazy_thread_controller_for_test.cc | 27 DCHECK(RunsTasksInCurrentSequence()); in EnsureMessageLoop() 92 bool LazyThreadControllerForTest::RunsTasksInCurrentSequence() { in RunsTasksInCurrentSequence() function in base::sequence_manager::LazyThreadControllerForTest
|
D | lazy_thread_controller_for_test.h | 31 bool RunsTasksInCurrentSequence() override;
|
/external/libchrome/base/ |
D | run_loop.cc | 27 if (task_runner->RunsTasksInCurrentSequence()) { in ProxyToTaskRunner() 124 if (!origin_task_runner_->RunsTasksInCurrentSequence()) { in Quit() 143 if (!origin_task_runner_->RunsTasksInCurrentSequence()) { in QuitWhenIdle()
|
D | single_thread_task_runner.h | 28 bool BelongsToCurrentThread() const { return RunsTasksInCurrentSequence(); } in BelongsToCurrentThread()
|
D | task_runner.h | 89 virtual bool RunsTasksInCurrentSequence() const = 0;
|
/external/libchrome/base/test/ |
D | test_simple_task_runner.cc | 42 bool TestSimpleTaskRunner::RunsTasksInCurrentSequence() const { in RunsTasksInCurrentSequence() function in base::TestSimpleTaskRunner 77 DCHECK(RunsTasksInCurrentSequence()); in RunPendingTasks()
|
D | test_mock_time_task_runner.cc | 84 bool RunsTasksInCurrentSequence() const override { in RunsTasksInCurrentSequence() function in base::TestMockTimeTaskRunner::NonOwningProxyTaskRunner 87 return target_->RunsTasksInCurrentSequence(); in RunsTasksInCurrentSequence() 350 bool TestMockTimeTaskRunner::RunsTasksInCurrentSequence() const { in RunsTasksInCurrentSequence() function in base::TestMockTimeTaskRunner
|
/external/libchrome/mojo/public/cpp/bindings/tests/ |
D | bind_task_runner_unittest.cc | 52 bool RunsTasksInCurrentSequence() const override { in RunsTasksInCurrentSequence() function in mojo::test::__anona2eee2bc0111::TestTaskRunner 58 DCHECK(RunsTasksInCurrentSequence()); in Run() 81 DCHECK(RunsTasksInCurrentSequence()); in Quit() 87 DCHECK(RunsTasksInCurrentSequence()); in RunOneTask()
|
/external/libchrome/base/files/ |
D | file_path_watcher_linux.cc | 350 DCHECK(!task_runner() || task_runner()->RunsTasksInCurrentSequence()); in ~FilePathWatcherImpl() 358 DCHECK(!task_runner()->RunsTasksInCurrentSequence()); in OnFilePathChanged() 375 DCHECK(task_runner()->RunsTasksInCurrentSequence()); in OnFilePathChangedOnOriginSequence() 484 DCHECK(task_runner()->RunsTasksInCurrentSequence()); in Cancel() 500 DCHECK(task_runner()->RunsTasksInCurrentSequence()); in UpdateWatches()
|
/external/libchrome/base/task/sequence_manager/ |
D | thread_controller_with_message_pump_impl.cc | 54 if (RunsTasksInCurrentSequence() && is_doing_work()) in ScheduleWork() 83 bool ThreadControllerWithMessagePumpImpl::RunsTasksInCurrentSequence() { in RunsTasksInCurrentSequence() function in base::sequence_manager::internal::ThreadControllerWithMessagePumpImpl
|
D | thread_controller_impl.cc | 120 bool ThreadControllerImpl::RunsTasksInCurrentSequence() { in RunsTasksInCurrentSequence() function in base::sequence_manager::internal::ThreadControllerImpl 121 return task_runner_->RunsTasksInCurrentSequence(); in RunsTasksInCurrentSequence()
|
/external/libchrome/base/task_scheduler/ |
D | scheduler_worker_pool.cc | 69 bool RunsTasksInCurrentSequence() const override { in RunsTasksInCurrentSequence() function in base::internal::SchedulerParallelTaskRunner 115 bool RunsTasksInCurrentSequence() const override { in RunsTasksInCurrentSequence() function in base::internal::SchedulerSequencedTaskRunner
|
/external/libchrome/mojo/public/cpp/bindings/ |
D | thread_safe_interface_ptr.h | 128 if (task_runner_->RunsTasksInCurrentSequence()) { in AcceptWithResponder() 350 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in Bind() 365 if (!task_runner_->RunsTasksInCurrentSequence()) { in DeleteOnCorrectThread()
|
/external/libchrome/base/message_loop/ |
D | message_loop_task_runner.h | 40 bool RunsTasksInCurrentSequence() const override;
|