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

mojo/edk/system/data_pipe_producer_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_producer_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 DataPipeProducerDispatcher::Init(scoped_refptr<DataPipe> data_pipe) {
+void DataPipeProducerDispatcher::Init(RefPtr<DataPipe>&& data_pipe) {
   DCHECK(data_pipe);
-  data_pipe_ = data_pipe;
+  data_pipe_ = std::move(data_pipe);
 }
 
 Dispatcher::Type DataPipeProducerDispatcher::GetType() const {
   return Type::DATA_PIPE_PRODUCER;
 }
 
 // static
 scoped_refptr<DataPipeProducerDispatcher>
 DataPipeProducerDispatcher::Deserialize(Channel* channel,
                                         const void* source,
                                         size_t size) {
-  scoped_refptr<DataPipe> data_pipe;
+  RefPtr<DataPipe> data_pipe;
   if (!DataPipe::ProducerDeserialize(channel, source, size, &data_pipe))
     return nullptr;
   DCHECK(data_pipe);
 
   scoped_refptr<DataPipeProducerDispatcher> dispatcher = Create();
-  dispatcher->Init(data_pipe);
+  dispatcher->Init(std::move(data_pipe));
   return dispatcher;
 }
 
 DataPipe* DataPipeProducerDispatcher::GetDataPipeForTest() {
   MutexLocker locker(&mutex());
   return data_pipe_.get();
 }
 
 DataPipeProducerDispatcher::DataPipeProducerDispatcher() {
 }
@@ skipping 12 matching lines @@
   mutex().AssertHeld();
   data_pipe_->ProducerClose();
   data_pipe_ = nullptr;
 }
 
 scoped_refptr<Dispatcher>
 DataPipeProducerDispatcher::CreateEquivalentDispatcherAndCloseImplNoLock() {
   mutex().AssertHeld();
 
   scoped_refptr<DataPipeProducerDispatcher> rv = Create();
-  rv->Init(data_pipe_);
-  data_pipe_ = nullptr;
+  rv->Init(std::move(data_pipe_));
   return scoped_refptr<Dispatcher>(rv.get());
 }
 
 MojoResult DataPipeProducerDispatcher::WriteDataImplNoLock(
     UserPointer<const void> elements,
     UserPointer<uint32_t> num_bytes,
     MojoWriteDataFlags flags) {
   mutex().AssertHeld();
   return data_pipe_->ProducerWriteData(
       elements, num_bytes, (flags & MOJO_WRITE_DATA_FLAG_ALL_OR_NONE));
@@ skipping 63 matching lines @@
   return rv;
 }
 
 bool DataPipeProducerDispatcher::IsBusyNoLock() const {
   mutex().AssertHeld();
   return data_pipe_->ProducerIsBusy();
 }
 
 }  // namespace system
 }  // namespace mojo