Mojo: Add Dispatcher::{DuplicateBufferHandle,MapBuffer} methods.

mojo/system/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/dispatcher.h"
 
 #include "base/logging.h"
 #include "mojo/system/constants.h"
 
 namespace mojo {
@@ skipping 107 matching lines @@
 }
 
 MojoResult Dispatcher::EndReadData(uint32_t num_bytes_read) {
   base::AutoLock locker(lock_);
   if (is_closed_)
     return MOJO_RESULT_INVALID_ARGUMENT;
 
   return EndReadDataImplNoLock(num_bytes_read);
 }
 
+MojoResult Dispatcher::DuplicateBufferHandle(
+    const MojoDuplicateBufferHandleOptions* options,
+    scoped_refptr<Dispatcher>* new_dispatcher) {
+  base::AutoLock locker(lock_);
+  if (is_closed_)
+    return MOJO_RESULT_INVALID_ARGUMENT;
+
+  return DuplicateBufferHandleImplNoLock(options, new_dispatcher);
+}
+
+MojoResult Dispatcher::MapBuffer(uint64_t offset,
+                                 uint64_t num_bytes,
+                                 void** buffer,
+                                 MojoMapBufferFlags flags) {
+  base::AutoLock locker(lock_);
+  if (is_closed_)
+    return MOJO_RESULT_INVALID_ARGUMENT;
+
+  return MapBufferImplNoLock(offset, num_bytes, buffer, flags);
+}
+
 MojoResult Dispatcher::AddWaiter(Waiter* waiter,
                                  MojoWaitFlags flags,
                                  MojoResult wake_result) {
   DCHECK_GE(wake_result, 0);
 
   base::AutoLock locker(lock_);
   if (is_closed_)
     return MOJO_RESULT_INVALID_ARGUMENT;
 
   return AddWaiterImplNoLock(waiter, flags, wake_result);
@@ skipping 95 matching lines @@
   return MOJO_RESULT_INVALID_ARGUMENT;
 }
 
 MojoResult Dispatcher::EndReadDataImplNoLock(uint32_t /*num_bytes_read*/) {
   lock_.AssertAcquired();
   DCHECK(!is_closed_);
   // By default, not supported. Only needed for data pipe dispatchers.
   return MOJO_RESULT_INVALID_ARGUMENT;
 }
 
+MojoResult Dispatcher::DuplicateBufferHandleImplNoLock(
+      const MojoDuplicateBufferHandleOptions* /*options*/,
+      scoped_refptr<Dispatcher>* /*new_dispatcher*/) {
+  lock_.AssertAcquired();
+  DCHECK(!is_closed_);
+  // By default, not supported. Only needed for buffer dispatchers.
+  return MOJO_RESULT_INVALID_ARGUMENT;
+}
+
+MojoResult Dispatcher::MapBufferImplNoLock(uint64_t /*offset*/,
+                                           uint64_t /*num_bytes*/,
+                                           void** /*buffer*/,
+                                           MojoMapBufferFlags /*flags*/) {
+  lock_.AssertAcquired();
+  DCHECK(!is_closed_);
+  // By default, not supported. Only needed for buffer dispatchers.
+  return MOJO_RESULT_INVALID_ARGUMENT;
+}
+
 MojoResult Dispatcher::AddWaiterImplNoLock(Waiter* /*waiter*/,
                                            MojoWaitFlags /*flags*/,
                                            MojoResult /*wake_result*/) {
   lock_.AssertAcquired();
   DCHECK(!is_closed_);
   // By default, waiting isn't supported. Only dispatchers that can be waited on
   // will do something nontrivial.
   return MOJO_RESULT_FAILED_PRECONDITION;
 }
 
@@ skipping 34 matching lines @@
 // DispatcherTransport ---------------------------------------------------------
 
 void DispatcherTransport::End() {
   DCHECK(dispatcher_);
   dispatcher_->lock_.Release();
   dispatcher_ = NULL;
 }
 
 }  // namespace system
 }  // namespace mojo