Lines Matching refs:RunsTasksInCurrentSequence
417 if (!task_runner_->RunsTasksInCurrentSequence()) { in NotifyLocalEndpointOfPeerClosure()
665 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SendMessage()
671 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in AllowWokenUpBySyncWatchOnSameThread()
678 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SyncWatch()
746 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in OnSyncMessageEventReady()
788 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in EnsureSyncWatcherExists()
970 if (endpoint->task_runner()->RunsTasksInCurrentSequence() && !force_async) { in NotifyEndpointOfError()
999 DCHECK(endpoint->task_runner()->RunsTasksInCurrentSequence()); in NotifyEndpointOfErrorOnEndpointThread()
1071 if (!client || !endpoint->task_runner()->RunsTasksInCurrentSequence()) { in Accept()
1171 if (!endpoint->task_runner()->RunsTasksInCurrentSequence() && in AcceptOnEndpointThread()
1172 !proxy_task_runner_->RunsTasksInCurrentSequence()) { in AcceptOnEndpointThread()
1223 if (!endpoint->task_runner()->RunsTasksInCurrentSequence() && in AcceptSyncMessage()
1224 !proxy_task_runner_->RunsTasksInCurrentSequence()) { in AcceptSyncMessage()