Home
last modified time | relevance | path

Searched refs:io_task_runner_ (Results 1 – 9 of 9) 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_fuchsia.cc202 io_task_runner_(io_task_runner) { in ChannelFuchsia()
207 if (io_task_runner_->RunsTasksInCurrentSequence()) { in Start()
210 io_task_runner_->PostTask( in Start()
217 io_task_runner_->PostTask( in ShutDownImpl()
233 io_task_runner_->PostTask( in Write()
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()
[all …]
Dchannel_win.cc39 : Channel(delegate), self_(this), io_task_runner_(io_task_runner) { in ChannelWin()
54 io_task_runner_->PostTask( in Start()
60 io_task_runner_->PostTask( in ShutDownImpl()
90 io_task_runner_->PostTask(FROM_HERE, in Write()
97 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in LeakHandle()
199 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in WillDestroyCurrentMessageLoop()
323 DCHECK(io_task_runner_->RunsTasksInCurrentSequence()); in OnWriteError()
346 const scoped_refptr<base::TaskRunner> io_task_runner_; member in mojo::core::__anon2256fa540111::ChannelWin
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