Home
last modified time | relevance | path

Searched refs:io_task_runner_ (Results 1 – 7 of 7) sorted by relevance

/external/libchrome/ipc/
Dipc_sync_message_filter.cc34 if (!io_task_runner_.get()) { in Send()
39 io_task_runner_->PostTask( in Send()
59 DCHECK(base::ThreadTaskRunnerHandle::Get() != io_task_runner_); in Send()
63 if (io_task_runner_.get()) { in Send()
64 io_task_runner_->PostTask( in Send()
106 io_task_runner_ = base::ThreadTaskRunnerHandle::Get(); in OnFilterAdded()
183 DCHECK(io_task_runner_ && io_task_runner_->BelongsToCurrentThread()); in GetGenericRemoteAssociatedInterface()
Dipc_sync_message_filter.h83 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; in COMPONENT_EXPORT() local
/external/libchrome/mojo/core/
Dnode_controller.cc169 io_task_runner_ = task_runner; in SetIOTaskRunner()
171 io_task_runner_, in SetIOTaskRunner()
196 io_task_runner_->PostTask( in SendBrokerClientInvitation()
227 io_task_runner_->PostTask( in AcceptBrokerClientInvitation()
236 io_task_runner_->PostTask( in ConnectIsolated()
326 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in SendBrokerClientInvitationOnIOThread()
354 io_task_runner_, process_error_callback); in SendBrokerClientInvitationOnIOThread()
358 NodeChannel::Create(this, std::move(connection_params), io_task_runner_, in SendBrokerClientInvitationOnIOThread()
378 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in AcceptBrokerClientInvitationOnIOThread()
388 NodeChannel::Create(this, std::move(connection_params), io_task_runner_, in AcceptBrokerClientInvitationOnIOThread()
[all …]
Dchannel_posix.cc104 : Channel(delegate), self_(this), io_task_runner_(io_task_runner) { in ChannelPosix()
123 if (io_task_runner_->RunsTasksInCurrentSequence()) { in Start()
126 io_task_runner_->PostTask( in Start()
133 io_task_runner_->PostTask( in ShutDownImpl()
177 io_task_runner_->PostTask( in Write()
184 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in LeakHandle()
323 if (io_task_runner_->RunsTasksInCurrentSequence()) { in WaitForWriteOnIOThreadNoLock()
329 io_task_runner_->PostTask( in WaitForWriteOnIOThreadNoLock()
367 io_task_runner_->PostTask( in OnProcessReady()
417 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in WillDestroyCurrentMessageLoop()
[all …]
Dnode_channel.cc221 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in SetRemoteProcessHandle()
246 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in SetRemoteNodeName()
445 io_task_runner_(io_task_runner), in NodeChannel()
450 Channel::Create(this, std::move(connection_params), io_task_runner_)) in NodeChannel()
462 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnChannelMessage()
698 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnChannelError()
Dnode_controller.h66 return io_task_runner_; in io_task_runner()
255 scoped_refptr<base::TaskRunner> io_task_runner_; variable
Dnode_channel.h170 const scoped_refptr<base::TaskRunner> io_task_runner_; variable