Implements JS bindings for mojo shared buffer.

third_party/WebKit/Source/core/mojo/MojoHandle.cpp

 // Copyright 2017 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 "core/mojo/MojoHandle.h"
 
 #include "bindings/core/v8/ArrayBufferOrArrayBufferView.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMArrayBufferView.h"
+#include "core/mojo/MojoCreateSharedBufferResult.h"
+#include "core/mojo/MojoDuplicateBufferHandleOptions.h"
+#include "core/mojo/MojoMapBufferResult.h"
 #include "core/mojo/MojoReadMessageFlags.h"
 #include "core/mojo/MojoReadMessageResult.h"
 #include "core/mojo/MojoWatcher.h"
 
 // Mojo messages typically do not contain many handles. In fact most
 // messages do not contain any handle. An inline capacity of 4 should avoid
 // heap allocation in vast majority of cases.
 static const size_t kHandleVectorInlineCapacity = 4;
 
 namespace blink {
@@ skipping 64 matching lines @@
   for (size_t i = 0; i < numHandles; ++i) {
     handles[i] =
         MojoHandle::create(mojo::MakeScopedHandle(mojo::Handle(rawHandles[i])));
   }
 
   resultDict.setResult(result);
   resultDict.setBuffer(buffer);
   resultDict.setHandles(handles);
 }
 
+void MojoHandle::mapBuffer(unsigned offset,
+                           unsigned numBytes,
+                           MojoMapBufferResult& resultDict) {
+  void* data = nullptr;
+  MojoResult result = MojoMapBuffer(m_handle->value(), offset, numBytes, &data,
+                                    MOJO_MAP_BUFFER_FLAG_NONE);
+  resultDict.setResult(result);
+  if (result == MOJO_RESULT_OK) {
+    WTF::ArrayBufferContents::DataHandle dataHandle(data, [](void* buffer) {
+      MojoResult result = MojoUnmapBuffer(buffer);
+      DCHECK_EQ(result, MOJO_RESULT_OK);
+    });
+    WTF::ArrayBufferContents contents(std::move(dataHandle), numBytes,
+                                      WTF::ArrayBufferContents::NotShared);
+    resultDict.setBuffer(DOMArrayBuffer::create(contents));
+  }
+}
+
+void MojoHandle::duplicateBufferHandle(
+    const MojoDuplicateBufferHandleOptions& optionsDict,
+    MojoCreateSharedBufferResult& resultDict) {
+  ::MojoDuplicateBufferHandleOptions options = {
+      sizeof(options), MOJO_DUPLICATE_BUFFER_HANDLE_OPTIONS_FLAG_NONE};
+  if (optionsDict.readOnly())
+    options.flags |= MOJO_DUPLICATE_BUFFER_HANDLE_OPTIONS_FLAG_READ_ONLY;
+
+  mojo::Handle handle;
+  MojoResult result = MojoDuplicateBufferHandle(m_handle->value(), &options,
+                                                handle.mutable_value());
+  resultDict.setResult(result);
+  if (result == MOJO_RESULT_OK) {
+    resultDict.setHandle(MojoHandle::create(mojo::MakeScopedHandle(handle)));
+  }
+}
+
 }  // namespace blink