Home
last modified time | relevance | path

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

/external/libmojo/mojo/edk/system/
Dnode_controller.cc160 io_task_runner_ = task_runner; in SetIOTaskRunner()
162 io_task_runner_, in SetIOTaskRunner()
198 io_task_runner_->PostTask( in ConnectToChild()
230 io_task_runner_->PostTask( in ClosePeerConnection()
256 io_task_runner_->PostTask( in ConnectToParent()
267 io_task_runner_->PostTask( in ConnectToPeer()
398 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ConnectToChildOnIOThread()
422 io_task_runner_, process_error_callback); in ConnectToChildOnIOThread()
426 NodeChannel::Create(this, std::move(connection_params), io_task_runner_, in ConnectToChildOnIOThread()
447 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ConnectToParentOnIOThread()
[all …]
Dchannel_posix.cc96 io_task_runner_(io_task_runner) in ChannelPosix()
106 if (io_task_runner_->RunsTasksOnCurrentThread()) { in Start()
109 io_task_runner_->PostTask( in Start()
116 io_task_runner_->PostTask( in ShutDownImpl()
136 io_task_runner_->PostTask(FROM_HERE, in Write()
142 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in LeakHandle()
242 if (io_task_runner_->RunsTasksOnCurrentThread()) { in WaitForWriteOnIOThreadNoLock()
248 io_task_runner_->PostTask( in WaitForWriteOnIOThreadNoLock()
271 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in WillDestroyCurrentMessageLoop()
536 scoped_refptr<base::TaskRunner> io_task_runner_; member in mojo::edk::__anona552ed230111::ChannelPosix
Dchannel_win.cc82 io_task_runner_(io_task_runner) { in ChannelWin()
89 io_task_runner_->PostTask( in Start()
95 io_task_runner_->PostTask( in ShutDownImpl()
115 io_task_runner_->PostTask(FROM_HERE, in Write()
121 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in LeakHandle()
210 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in WillDestroyCurrentMessageLoop()
327 scoped_refptr<base::TaskRunner> io_task_runner_; member in mojo::edk::__anon66148abe0111::ChannelWin
Dnode_channel.cc231 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in SetRemoteProcessHandle()
268 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in SetRemoteNodeName()
461 io_task_runner_(io_task_runner), in NodeChannel()
466 Channel::Create(this, std::move(connection_params), io_task_runner_)) in NodeChannel()
478 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnChannelMessage()
770 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnChannelError()
784 io_task_runner_->PostTask(FROM_HERE, base::Bind( in OnProcessReady()
Dnode_controller.h62 return io_task_runner_; in io_task_runner()
271 scoped_refptr<base::TaskRunner> io_task_runner_; variable
Dnode_channel.h192 const scoped_refptr<base::TaskRunner> io_task_runner_; variable