Convert mojo::system::Dispatcher to use our new refcounting stuff (instead of base's).

mojo/edk/system/data_pipe_consumer_dispatcher.cc

 // Copyright 2013 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/data_pipe_consumer_dispatcher.h"
 
 #include <utility>
 
 #include "base/logging.h"
 #include "mojo/edk/system/data_pipe.h"
 #include "mojo/edk/system/memory.h"
 
 namespace mojo {
 namespace system {
 
 void DataPipeConsumerDispatcher::Init(RefPtr<DataPipe>&& data_pipe) {
   DCHECK(data_pipe);
   data_pipe_ = std::move(data_pipe);
 }
 
 Dispatcher::Type DataPipeConsumerDispatcher::GetType() const {
   return Type::DATA_PIPE_CONSUMER;
 }
 
 // static
-scoped_refptr<DataPipeConsumerDispatcher>
-DataPipeConsumerDispatcher::Deserialize(Channel* channel,
-                                        const void* source,
-                                        size_t size) {
+RefPtr<DataPipeConsumerDispatcher> DataPipeConsumerDispatcher::Deserialize(
+    Channel* channel,
+    const void* source,
+    size_t size) {
   RefPtr<DataPipe> data_pipe;
   if (!DataPipe::ConsumerDeserialize(channel, source, size, &data_pipe))
     return nullptr;
   DCHECK(data_pipe);
 
-  scoped_refptr<DataPipeConsumerDispatcher> dispatcher = Create();
+  auto dispatcher = DataPipeConsumerDispatcher::Create();
   dispatcher->Init(std::move(data_pipe));
   return dispatcher;
 }
 
 DataPipe* DataPipeConsumerDispatcher::GetDataPipeForTest() {
   MutexLocker locker(&mutex());
   return data_pipe_.get();
 }
 
 DataPipeConsumerDispatcher::DataPipeConsumerDispatcher() {
 }
 
 DataPipeConsumerDispatcher::~DataPipeConsumerDispatcher() {
   // |Close()|/|CloseImplNoLock()| should have taken care of the pipe.
   DCHECK(!data_pipe_);
 }
 
 void DataPipeConsumerDispatcher::CancelAllAwakablesNoLock() {
   mutex().AssertHeld();
   data_pipe_->ConsumerCancelAllAwakables();
 }
 
 void DataPipeConsumerDispatcher::CloseImplNoLock() {
   mutex().AssertHeld();
   data_pipe_->ConsumerClose();
   data_pipe_ = nullptr;
 }
 
-scoped_refptr<Dispatcher>
+RefPtr<Dispatcher>
 DataPipeConsumerDispatcher::CreateEquivalentDispatcherAndCloseImplNoLock() {
   mutex().AssertHeld();
 
-  scoped_refptr<DataPipeConsumerDispatcher> rv = Create();
-  rv->Init(std::move(data_pipe_));
-  return scoped_refptr<Dispatcher>(rv.get());
+  auto dispatcher = DataPipeConsumerDispatcher::Create();
+  dispatcher->Init(std::move(data_pipe_));
+  return dispatcher;
 }
 
 MojoResult DataPipeConsumerDispatcher::ReadDataImplNoLock(
     UserPointer<void> elements,
     UserPointer<uint32_t> num_bytes,
     MojoReadDataFlags flags) {
   mutex().AssertHeld();
 
   if ((flags & MOJO_READ_DATA_FLAG_DISCARD)) {
     // These flags are mutally exclusive.
@@ skipping 62 matching lines @@
     Awakable* awakable,
     HandleSignalsState* signals_state) {
   mutex().AssertHeld();
   data_pipe_->ConsumerRemoveAwakable(awakable, signals_state);
 }
 
 void DataPipeConsumerDispatcher::StartSerializeImplNoLock(
     Channel* channel,
     size_t* max_size,
     size_t* max_platform_handles) {
-  DCHECK(HasOneRef());  // Only one ref => no need to take the lock.
+  AssertHasOneRef();  // Only one ref => no need to take the lock.
   data_pipe_->ConsumerStartSerialize(channel, max_size, max_platform_handles);
 }
 
 bool DataPipeConsumerDispatcher::EndSerializeAndCloseImplNoLock(
     Channel* channel,
     void* destination,
     size_t* actual_size,
     embedder::PlatformHandleVector* platform_handles) {
-  DCHECK(HasOneRef());  // Only one ref => no need to take the lock.
+  AssertHasOneRef();  // Only one ref => no need to take the lock.
 
   bool rv = data_pipe_->ConsumerEndSerialize(channel, destination, actual_size,
                                              platform_handles);
   data_pipe_ = nullptr;
   return rv;
 }
 
 bool DataPipeConsumerDispatcher::IsBusyNoLock() const {
   mutex().AssertHeld();
   return data_pipe_->ConsumerIsBusy();
 }
 
 }  // namespace system
 }  // namespace mojo