Home
last modified time | relevance | path

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

/external/libmojo/mojo/edk/system/
Dnode_controller.cc158 io_task_runner_ = task_runner; in SetIOTaskRunner()
160 io_task_runner_, in SetIOTaskRunner()
196 io_task_runner_->PostTask( in ConnectToChild()
250 io_task_runner_->PostTask( in ConnectToParent()
382 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ConnectToChildOnIOThread()
390 this, node_channel.PassServerHandle(), io_task_runner_, in ConnectToChildOnIOThread()
394 NodeChannel::Create(this, std::move(platform_handle), io_task_runner_, in ConnectToChildOnIOThread()
415 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ConnectToParentOnIOThread()
425 NodeChannel::Create(this, std::move(platform_handle), io_task_runner_, in ConnectToParentOnIOThread()
467 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in AddPeer()
[all …]
Dchannel_posix.cc96 io_task_runner_(io_task_runner) in ChannelPosix()
105 if (io_task_runner_->RunsTasksOnCurrentThread()) { in Start()
108 io_task_runner_->PostTask( in Start()
115 io_task_runner_->PostTask( in ShutDownImpl()
135 io_task_runner_->PostTask(FROM_HERE, in Write()
141 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in LeakHandle()
231 if (io_task_runner_->RunsTasksOnCurrentThread()) { in WaitForWriteOnIOThreadNoLock()
237 io_task_runner_->PostTask( in WaitForWriteOnIOThreadNoLock()
260 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in WillDestroyCurrentMessageLoop()
485 scoped_refptr<base::TaskRunner> io_task_runner_; member in mojo::edk::__anon24f20da50111::ChannelPosix
Dchannel_win.cc81 io_task_runner_(io_task_runner) { in ChannelWin()
88 io_task_runner_->PostTask( in Start()
94 io_task_runner_->PostTask( in ShutDownImpl()
114 io_task_runner_->PostTask(FROM_HERE, in Write()
120 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in LeakHandle()
209 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in WillDestroyCurrentMessageLoop()
326 scoped_refptr<base::TaskRunner> io_task_runner_; member in mojo::edk::__anonc30da2c00111::ChannelWin
Dnode_channel.cc224 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in SetRemoteProcessHandle()
261 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in SetRemoteNodeName()
442 io_task_runner_(io_task_runner), in NodeChannel()
446 Channel::Create(this, std::move(platform_handle), io_task_runner_)) in NodeChannel()
458 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnChannelMessage()
740 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnChannelError()
754 io_task_runner_->PostTask(FROM_HERE, base::Bind( in OnProcessReady()
Dnode_controller.h62 return io_task_runner_; in io_task_runner()
229 scoped_refptr<base::TaskRunner> io_task_runner_; variable
Dnode_channel.h185 const scoped_refptr<base::TaskRunner> io_task_runner_; variable
/external/libchrome/base/files/
Dfile_path_watcher_kqueue.cc332 io_task_runner_ = ThreadTaskRunnerHandle::Get(); in Watch()
361 SingleThreadTaskRunner* task_runner = io_task_runner_.get(); in Cancel()
385 io_task_runner_ = NULL; in CancelOnMessageLoopThread()
Dfile_path_watcher_kqueue.h122 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; variable