Revert of Update mojo sdk to rev afb4440fd5a10cba980878c326180b7ad7960480

mojo/edk/system/message_pipe.cc

Index: mojo/edk/system/message_pipe.cc
diff --git a/mojo/edk/system/message_pipe.cc b/mojo/edk/system/message_pipe.cc
index ce529ed444094c0cebcc32d9f7385108ed3dca44..e2157302cbc8e46555bc4b1c3dfdf5c6b7f25154 100644
--- a/mojo/edk/system/message_pipe.cc
+++ b/mojo/edk/system/message_pipe.cc
@@ -100,7 +100,9 @@
       GetPeerPort(port),
       make_scoped_ptr(new MessageInTransit(
           MessageInTransit::kTypeMessagePipeEndpoint,
-          MessageInTransit::kSubtypeMessagePipeEndpointData, num_bytes, bytes)),
+          MessageInTransit::kSubtypeMessagePipeEndpointData,
+          num_bytes,
+          bytes)),
       transports);
 }
 
@@ -115,8 +117,8 @@
   base::AutoLock locker(lock_);
   DCHECK(endpoints_[port]);
 
-  return endpoints_[port]->ReadMessage(bytes, num_bytes, dispatchers,
-                                       num_dispatchers, flags);
+  return endpoints_[port]->ReadMessage(
+      bytes, num_bytes, dispatchers, num_dispatchers, flags);
 }
 
 HandleSignalsState MessagePipe::GetHandleSignalsState(unsigned port) const {
@@ -163,8 +165,10 @@
   // send the already-queued messages.
   if (!endpoints_[GetPeerPort(port)]) {
     scoped_refptr<ChannelEndpoint> channel_endpoint(new ChannelEndpoint(
-        nullptr, 0, static_cast<LocalMessagePipeEndpoint*>(
-                        endpoints_[port].get())->message_queue()));
+        nullptr,
+        0,
+        static_cast<LocalMessagePipeEndpoint*>(endpoints_[port].get())
+            ->message_queue()));
     endpoints_[port]->Close();
     endpoints_[port].reset();
     return channel_endpoint;
@@ -173,15 +177,18 @@
   // TODO(vtl): Allowing this case is a temporary hack. It'll set up a
   // |MessagePipe| with two proxy endpoints, which will then act as a proxy
   // (rather than trying to connect the two ends directly).
-  DLOG_IF(WARNING, endpoints_[GetPeerPort(port)]->GetType() !=
-                       MessagePipeEndpoint::kTypeLocal)
+  DLOG_IF(WARNING,
+          endpoints_[GetPeerPort(port)]->GetType() !=
+              MessagePipeEndpoint::kTypeLocal)
       << "Direct message pipe passing across multiple channels not yet "
          "implemented; will proxy";
 
   scoped_ptr<MessagePipeEndpoint> old_endpoint(endpoints_[port].Pass());
   scoped_refptr<ChannelEndpoint> channel_endpoint(new ChannelEndpoint(
-      this, port, static_cast<LocalMessagePipeEndpoint*>(old_endpoint.get())
-                      ->message_queue()));
+      this,
+      port,
+      static_cast<LocalMessagePipeEndpoint*>(old_endpoint.get())
+          ->message_queue()));
   endpoints_[port].reset(new ProxyMessagePipeEndpoint(channel_endpoint.get()));
   old_endpoint->Close();