Mojo: Have |ProxyMessagePipeEndpoint|s constructed with a |ChannelEndpoint|.

mojo/system/proxy_message_pipe_endpoint.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/system/proxy_message_pipe_endpoint.h"
 
 #include <string.h>
 
 #include "base/logging.h"
 #include "mojo/system/channel_endpoint.h"
 #include "mojo/system/local_message_pipe_endpoint.h"
 #include "mojo/system/message_pipe_dispatcher.h"
 
 namespace mojo {
 namespace system {
 
-ProxyMessagePipeEndpoint::ProxyMessagePipeEndpoint()
-    : is_running_(false), is_peer_open_(true) {
+ProxyMessagePipeEndpoint::ProxyMessagePipeEndpoint(
+    ChannelEndpoint* channel_endpoint)
+    : channel_endpoint_(channel_endpoint),
+      is_running_(false),
+      is_peer_open_(true) {
 }
 
 ProxyMessagePipeEndpoint::ProxyMessagePipeEndpoint(
+    ChannelEndpoint* channel_endpoint,
     LocalMessagePipeEndpoint* local_message_pipe_endpoint,
     bool is_peer_open)
-    : is_running_(false), is_peer_open_(is_peer_open) {
+    : channel_endpoint_(channel_endpoint),
+      is_running_(false),
+      is_peer_open_(is_peer_open) {
   paused_message_queue_.Swap(local_message_pipe_endpoint->message_queue());
   local_message_pipe_endpoint->Close();
 }
 
 ProxyMessagePipeEndpoint::~ProxyMessagePipeEndpoint() {
   DCHECK(!is_running());
   DCHECK(!is_attached());
   DCHECK(paused_message_queue_.IsEmpty());
 }
 
@@ skipping 30 matching lines @@
     scoped_ptr<MessageInTransit> message) {
   if (is_running()) {
     DCHECK(channel_endpoint_.get());
     LOG_IF(WARNING, !channel_endpoint_->EnqueueMessage(message.Pass()))
         << "Failed to write enqueue message to channel";
   } else {
     paused_message_queue_.AddMessage(message.Pass());
   }
 }
 
-void ProxyMessagePipeEndpoint::Attach(ChannelEndpoint* channel_endpoint) {
-  DCHECK(channel_endpoint);
-  DCHECK(!is_attached());
-  channel_endpoint_ = channel_endpoint;
-}
-
 bool ProxyMessagePipeEndpoint::Run() {
   // Assertions about current state:
   DCHECK(is_attached());
   DCHECK(!is_running());
 
   is_running_ = true;
 
   while (!paused_message_queue_.IsEmpty()) {
     LOG_IF(
         WARNING,
@@ skipping 17 matching lines @@
   DCHECK(is_attached());
 
   channel_endpoint_->DetachFromMessagePipe();
   channel_endpoint_ = NULL;
   is_running_ = false;
   paused_message_queue_.Clear();
 }
 
 }  // namespace system
 }  // namespace mojo