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

mojo/edk/system/local_data_pipe_impl.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.
 
 // TODO(vtl): I currently potentially overflow in doing index calculations.
 // E.g., |start_index_| and |current_num_bytes_| fit into a |uint32_t|, but
 // their sum may not. This is bad and poses a security risk. (We're currently
 // saved by the limit on capacity -- the maximum size of the buffer, checked in
 // |DataPipe::ValidateOptions()|, is currently sufficiently small.)
 
@@ skipping 164 matching lines @@
     *actual_size = sizeof(SerializedDataPipeProducerDispatcher);
     return true;
   }
 
   // Case 2: The consumer isn't closed. We'll replace ourselves with a
   // |RemoteProducerDataPipeImpl|.
 
   s->consumer_num_bytes = current_num_bytes_;
   // Note: We don't use |port|.
   RefPtr<ChannelEndpoint> channel_endpoint =
-      channel->SerializeEndpointWithLocalPeer(destination_for_endpoint, nullptr,
-                                              channel_endpoint_client(), 0);
+      channel->SerializeEndpointWithLocalPeer(
+          destination_for_endpoint, nullptr,
+          RefPtr<ChannelEndpointClient>(channel_endpoint_client()), 0);
   // Note: Keep |*this| alive until the end of this method, to make things
   // slightly easier on ourselves.
   std::unique_ptr<DataPipeImpl> self(
       ReplaceImpl(util::MakeUnique<RemoteProducerDataPipeImpl>(
           std::move(channel_endpoint), std::move(buffer_), start_index_,
           current_num_bytes_)));
 
   *actual_size = sizeof(SerializedDataPipeProducerDispatcher) +
                  channel->GetSerializedEndpointSize();
   return true;
@@ skipping 156 matching lines @@
     *actual_size = sizeof(SerializedDataPipeConsumerDispatcher) +
                    channel->GetSerializedEndpointSize();
     return true;
   }
 
   // Case 2: The producer isn't closed. We'll replace ourselves with a
   // |RemoteConsumerDataPipeImpl|.
 
   // Note: We don't use |port|.
   RefPtr<ChannelEndpoint> channel_endpoint =
-      channel->SerializeEndpointWithLocalPeer(destination_for_endpoint,
-                                              &message_queue,
-                                              channel_endpoint_client(), 0);
+      channel->SerializeEndpointWithLocalPeer(
+          destination_for_endpoint, &message_queue,
+          RefPtr<ChannelEndpointClient>(channel_endpoint_client()), 0);
   // Note: Keep |*this| alive until the end of this method, to make things
   // slightly easier on ourselves.
   std::unique_ptr<DataPipeImpl> self(
       ReplaceImpl(util::MakeUnique<RemoteConsumerDataPipeImpl>(
           std::move(channel_endpoint), old_num_bytes, std::move(buffer_),
           start_index_)));
   DestroyBuffer();
 
   *actual_size = sizeof(SerializedDataPipeConsumerDispatcher) +
                  channel->GetSerializedEndpointSize();
@@ skipping 51 matching lines @@
 
 void LocalDataPipeImpl::MarkDataAsConsumed(size_t num_bytes) {
   DCHECK_LE(num_bytes, current_num_bytes_);
   start_index_ += num_bytes;
   start_index_ %= capacity_num_bytes();
   current_num_bytes_ -= num_bytes;
 }
 
 }  // namespace system
 }  // namespace mojo