Mojo: More work towards sending message pipe handles over remote message pipes.

mojo/system/message_pipe_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/system/message_pipe_dispatcher.h"
 
 #include "base/logging.h"
 #include "mojo/system/constants.h"
 #include "mojo/system/memory.h"
 #include "mojo/system/message_pipe.h"
 
 namespace mojo {
 namespace system {
 
 const unsigned kInvalidPort = static_cast<unsigned>(-1);
 
 MessagePipeDispatcher::MessagePipeDispatcher()
     : port_(kInvalidPort) {
 }
 
 void MessagePipeDispatcher::Init(scoped_refptr<MessagePipe> message_pipe,
                                  unsigned port) {
   DCHECK(message_pipe.get());
   DCHECK(port == 0 || port == 1);
 
   message_pipe_ = message_pipe;
   port_ = port;
 }
 
+MessagePipe* MessagePipeDispatcher::GetMessagePipeNoLock() const {
+  lock().AssertAcquired();
+  return message_pipe_.get();
+}
+
+unsigned MessagePipeDispatcher::GetPortNoLock() const {
+  lock().AssertAcquired();
+  return port_;
+}
+
 Dispatcher::Type MessagePipeDispatcher::GetType() {
   return kTypeMessagePipe;
 }
 
 MessagePipeDispatcher::~MessagePipeDispatcher() {
   // |Close()|/|CloseImplNoLock()| should have taken care of the pipe.
   DCHECK(!message_pipe_.get());
 }
 
 void MessagePipeDispatcher::CancelAllWaitersNoLock() {
@@ skipping 67 matching lines @@
 
   scoped_refptr<MessagePipeDispatcher> rv = new MessagePipeDispatcher();
   rv->Init(message_pipe_, port_);
   message_pipe_ = NULL;
   port_ = kInvalidPort;
   return scoped_refptr<Dispatcher>(rv.get());
 }
 
 }  // namespace system
 }  // namespace mojo