Index: ipc/ipc_channel_mojo.cc |
diff --git a/ipc/ipc_channel_mojo.cc b/ipc/ipc_channel_mojo.cc |
index ab376f4bdc46a697d939694e7fcfe81993bcbfa5..ba6b8edfe9ea76138b5fa3bd5733582047ccf832 100644 |
--- a/ipc/ipc_channel_mojo.cc |
+++ b/ipc/ipc_channel_mojo.cc |
@@ -282,7 +282,7 @@ ChannelMojo::ChannelMojo( |
} |
void ChannelMojo::ForwardMessageFromThreadSafePtr(mojo::Message message) { |
- DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
+ DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
if (!message_reader_ || !message_reader_->sender().is_bound()) |
return; |
message_reader_->sender().internal_state()->ForwardMessage( |
@@ -292,7 +292,7 @@ void ChannelMojo::ForwardMessageFromThreadSafePtr(mojo::Message message) { |
void ChannelMojo::ForwardMessageWithResponderFromThreadSafePtr( |
mojo::Message message, |
std::unique_ptr<mojo::MessageReceiver> responder) { |
- DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
+ DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
if (!message_reader_ || !message_reader_->sender().is_bound()) |
return; |
message_reader_->sender().internal_state()->ForwardMessageWithResponder( |
@@ -300,12 +300,12 @@ void ChannelMojo::ForwardMessageWithResponderFromThreadSafePtr( |
} |
ChannelMojo::~ChannelMojo() { |
- DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
+ DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
Close(); |
} |
bool ChannelMojo::Connect() { |
- DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
+ DCHECK(task_runner_->RunsTasksInCurrentSequence()); |
WillConnect(); |
@@ -347,7 +347,7 @@ void ChannelMojo::Close() { |
void ChannelMojo::OnPipeError() { |
DCHECK(task_runner_); |
- if (task_runner_->RunsTasksOnCurrentThread()) { |
+ if (task_runner_->RunsTasksInCurrentSequence()) { |
listener_->OnChannelError(); |
} else { |
task_runner_->PostTask( |