Mojo: Implement local passing of MessagePipes.

mojo/system/core_test_base.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/core_test_base.h"
 
 #include <vector>
 
 #include "base/compiler_specific.h"
 #include "base/logging.h"
@@ skipping 46 matching lines @@
       return MOJO_RESULT_RESOURCE_EXHAUSTED;
 
     if (dispatchers)
       return MOJO_RESULT_UNIMPLEMENTED;
 
     return MOJO_RESULT_OK;
   }
 
   virtual MojoResult ReadMessageImplNoLock(
       void* bytes, uint32_t* num_bytes,
-      uint32_t /*max_num_dispatchers*/,
       std::vector<scoped_refptr<Dispatcher> >* /*dispatchers*/,
+      uint32_t* /*num_dispatchers*/,
       MojoReadMessageFlags /*flags*/) OVERRIDE {
     info_->IncrementReadMessageCallCount();
     lock().AssertAcquired();
 
     if (num_bytes && !VerifyUserPointer<void>(bytes, *num_bytes))
       return MOJO_RESULT_INVALID_ARGUMENT;
 
     return MOJO_RESULT_OK;
   }
 
   virtual MojoResult AddWaiterImplNoLock(Waiter* /*waiter*/,
                                          MojoWaitFlags /*flags*/,
                                          MojoResult /*wake_result*/) OVERRIDE {
     info_->IncrementAddWaiterCallCount();
     lock().AssertAcquired();
     return MOJO_RESULT_FAILED_PRECONDITION;
   }
 
   virtual void RemoveWaiterImplNoLock(Waiter* /*waiter*/) OVERRIDE {
     info_->IncrementRemoveWaiterCallCount();
     lock().AssertAcquired();
   }
 
   virtual void CancelAllWaitersNoLock() OVERRIDE {
     info_->IncrementCancelAllWaitersCallCount();
     lock().AssertAcquired();
   }
 
+  virtual scoped_refptr<Dispatcher>
+      CreateEquivalentDispatcherAndCloseImplNoLock() OVERRIDE {
+    return scoped_refptr<Dispatcher>(new MockDispatcher(info_));
+  }
+
   CoreTestBase::MockHandleInfo* const info_;
 
   DISALLOW_COPY_AND_ASSIGN(MockDispatcher);
 };
 
 }  // namespace
 
 // CoreTestBase ----------------------------------------------------------------
 
 CoreTestBase::CoreTestBase() {
@@ skipping 110 matching lines @@
 }
 
 void CoreTestBase_MockHandleInfo::IncrementCancelAllWaitersCallCount() {
   base::AutoLock locker(lock_);
   cancel_all_waiters_call_count_++;
 }
 
 }  // namespace test
 }  // namespace system
 }  // namespace mojo