Rename TaskRunner::RunsTasksOnCurrentThread() in //extensions, //headless, //mojo

mojo/edk/system/node_channel.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "mojo/edk/system/node_channel.h"
 
 #include <cstring>
 #include <limits>
 #include <sstream>
 
@@ skipping 204 matching lines @@
     channel_->LeakHandle();
   }
 }
 
 void NodeChannel::NotifyBadMessage(const std::string& error) {
   if (!process_error_callback_.is_null())
     process_error_callback_.Run("Received bad user message: " + error);
 }
 
 void NodeChannel::SetRemoteProcessHandle(base::ProcessHandle process_handle) {
-  DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(io_task_runner_->RunsTasksInCurrentSequence());
   base::AutoLock lock(remote_process_handle_lock_);
   DCHECK_EQ(base::kNullProcessHandle, remote_process_handle_);
   CHECK_NE(remote_process_handle_, base::GetCurrentProcessHandle());
   remote_process_handle_ = process_handle;
 #if defined(OS_WIN)
   DCHECK(!scoped_remote_process_handle_.is_valid());
   scoped_remote_process_handle_.reset(PlatformHandle(process_handle));
 #endif
 }
 
@@ skipping 16 matching lines @@
     DPCHECK(result);
     return handle;
   }
   return base::kNullProcessHandle;
 #else
   return remote_process_handle_;
 #endif
 }
 
 void NodeChannel::SetRemoteNodeName(const ports::NodeName& name) {
-  DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(io_task_runner_->RunsTasksInCurrentSequence());
   remote_node_name_ = name;
 }
 
 void NodeChannel::AcceptChild(const ports::NodeName& parent_name,
                               const ports::NodeName& token) {
   AcceptChildData* data;
   Channel::MessagePtr message = CreateMessage(
       MessageType::ACCEPT_CHILD, sizeof(AcceptChildData), 0, &data);
   data->parent_name = parent_name;
   data->token = token;
@@ skipping 189 matching lines @@
 {
 }
 
 NodeChannel::~NodeChannel() {
   ShutDown();
 }
 
 void NodeChannel::OnChannelMessage(const void* payload,
                                    size_t payload_size,
                                    ScopedPlatformHandleVectorPtr handles) {
-  DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(io_task_runner_->RunsTasksInCurrentSequence());
 
   RequestContext request_context(RequestContext::Source::SYSTEM);
 
   // Ensure this NodeChannel stays alive through the extent of this method. The
   // delegate may have the only other reference to this object and it may choose
   // to drop it here in response to, e.g., a malformed message.
   scoped_refptr<NodeChannel> keepalive = this;
 
 #if defined(OS_WIN)
   // If we receive handles from a known process, rewrite them to our own
@@ skipping 271 matching lines @@
 
     default:
       break;
   }
 
   DLOG(ERROR) << "Received invalid message. Closing channel.";
   delegate_->OnChannelError(remote_node_name_, this);
 }
 
 void NodeChannel::OnChannelError() {
-  DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(io_task_runner_->RunsTasksInCurrentSequence());
 
   RequestContext request_context(RequestContext::Source::SYSTEM);
 
   ShutDown();
   // |OnChannelError()| may cause |this| to be destroyed, but still need access
   // to the name name after that destruction. So may a copy of
   // |remote_node_name_| so it can be used if |this| becomes destroyed.
   ports::NodeName node_name = remote_node_name_;
   delegate_->OnChannelError(node_name, this);
 }
@@ skipping 115 matching lines @@
 
   base::AutoLock lock(channel_lock_);
   if (!channel_)
     DLOG(ERROR) << "Dropping message on closed channel.";
   else
     channel_->Write(std::move(message));
 }
 
 }  // namespace edk
 }  // namespace mojo