Index: mojo/system/message_pipe.cc |
diff --git a/mojo/system/message_pipe.cc b/mojo/system/message_pipe.cc |
index 70ef246113a0ec138b39024b6dd048876ec2441f..c3dd57fab1590db426dea3ac38f64bfafe3ff6c2 100644 |
--- a/mojo/system/message_pipe.cc |
+++ b/mojo/system/message_pipe.cc |
@@ -5,7 +5,6 @@ |
#include "mojo/system/message_pipe.h" |
#include "base/logging.h" |
-#include "mojo/system/channel.h" |
#include "mojo/system/local_message_pipe_endpoint.h" |
#include "mojo/system/message_in_transit.h" |
#include "mojo/system/message_pipe_dispatcher.h" |
@@ -178,10 +177,12 @@ MojoResult MessagePipe::EnqueueMessage(unsigned port, |
} |
bool MessagePipe::Attach(unsigned port, |
- scoped_refptr<Channel> channel, |
+ ChannelEndpoint* channel_endpoint, |
+ Channel* channel, |
MessageInTransit::EndpointId local_id) { |
DCHECK(port == 0 || port == 1); |
- DCHECK(channel.get()); |
+ DCHECK(channel_endpoint); |
+ DCHECK(channel); |
DCHECK_NE(local_id, MessageInTransit::kInvalidEndpointId); |
base::AutoLock locker(lock_); |
@@ -189,7 +190,7 @@ bool MessagePipe::Attach(unsigned port, |
return false; |
DCHECK_EQ(endpoints_[port]->GetType(), MessagePipeEndpoint::kTypeProxy); |
- endpoints_[port]->Attach(channel, local_id); |
+ endpoints_[port]->Attach(channel_endpoint, channel, local_id); |
return true; |
} |