[DO NOT REVIEW][DO NOT COMMIT] Implement WebDataProducerHandleImpl.

content/child/blink_platform_impl.cc

 // Copyright 2014 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 "content/child/blink_platform_impl.h"
 
 #include <math.h>
 
 #include <vector>
 
@@ skipping 22 matching lines @@
 #include "content/child/bluetooth/web_bluetooth_impl.h"
 #include "content/child/child_thread.h"
 #include "content/child/content_child_helpers.h"
 #include "content/child/geofencing/web_geofencing_provider_impl.h"
 #include "content/child/navigator_connect/navigator_connect_provider.h"
 #include "content/child/notifications/notification_dispatcher.h"
 #include "content/child/notifications/notification_manager.h"
 #include "content/child/push_messaging/push_dispatcher.h"
 #include "content/child/push_messaging/push_provider.h"
 #include "content/child/thread_safe_sender.h"
+#include "content/child/web_data_consumer_handle_impl.h"
+#include "content/child/web_data_producer_handle_impl.h"
 #include "content/child/web_discardable_memory_impl.h"
 #include "content/child/web_gesture_curve_impl.h"
 #include "content/child/web_url_loader_impl.h"
 #include "content/child/websocket_bridge.h"
 #include "content/child/webthread_impl.h"
 #include "content/child/worker_task_runner.h"
 #include "content/public/common/content_client.h"
+#include "mojo/public/c/system/data_pipe.h"
+#include "mojo/public/c/system/types.h"
 #include "net/base/data_url.h"
 #include "net/base/mime_util.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_util.h"
 #include "third_party/WebKit/public/platform/WebConvertableToTraceFormat.h"
+#include "third_party/WebKit/public/platform/WebCreateDataPipeOptions.h"
 #include "third_party/WebKit/public/platform/WebData.h"
 #include "third_party/WebKit/public/platform/WebFloatPoint.h"
 #include "third_party/WebKit/public/platform/WebString.h"
 #include "third_party/WebKit/public/platform/WebURL.h"
 #include "third_party/WebKit/public/platform/WebWaitableEvent.h"
 #include "third_party/WebKit/public/web/WebSecurityOrigin.h"
 #include "ui/base/layout.h"
 
 using blink::WebData;
 using blink::WebFallbackThemeEngine;
@@ skipping 1006 matching lines @@
 
 blink::WebNavigatorConnectProvider*
 BlinkPlatformImpl::navigatorConnectProvider() {
   if (!thread_safe_sender_.get())
     return nullptr;
 
   return NavigatorConnectProvider::ThreadSpecificInstance(
       thread_safe_sender_.get(), main_thread_task_runner_);
 }
 
+bool BlinkPlatformImpl::createDataPipe(
+    const blink::WebCreateDataPipeOptions* options,
+    blink::WebDataProducerHandle** producer,
+    blink::WebDataConsumerHandle** consumer) {
+
+  MojoCreateDataPipeOptions options_entity;
+  const MojoCreateDataPipeOptions* options_to_pass = nullptr;
+  if (options) {
+    options_entity.struct_size = sizeof(MojoCreateDataPipeOptions);
+    options_entity.flags = MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE;
+    if (options->flags & options->FlagMayDiscard)
+      options_entity.flags |= MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_MAY_DISCARD;
+
+    options_entity.element_num_bytes = options->elementNumBytes;
+    options_entity.capacity_num_bytes = options->capacityNumBytes;
+    options_to_pass = &options_entity;
+  }
+
+  mojo::ScopedDataPipeProducerHandle mojo_producer;
+  mojo::ScopedDataPipeConsumerHandle mojo_consumer;
+
+  MojoResult result =
+    mojo::CreateDataPipe(options_to_pass, &mojo_producer, &mojo_consumer);
+
+  if (result != MOJO_RESULT_OK) {
+    *producer = nullptr;
+    *consumer = nullptr;
+    return false;
+  }
+
+  *producer = new WebDataProducerHandleImpl(mojo_producer.Pass());
+  *consumer = new WebDataConsumerHandleImpl(mojo_consumer.Pass());
+  return true;
+}
+
 WebThemeEngine* BlinkPlatformImpl::themeEngine() {
   return &native_theme_engine_;
 }
 
 WebFallbackThemeEngine* BlinkPlatformImpl::fallbackThemeEngine() {
   return &fallback_theme_engine_;
 }
 
 blink::Platform::FileHandle BlinkPlatformImpl::databaseOpenFile(
     const blink::WebString& vfs_file_name, int desired_flags) {
@@ skipping 144 matching lines @@
 }
 
 // static
 void BlinkPlatformImpl::DestroyCurrentThread(void* thread) {
   WebThreadImplForMessageLoop* impl =
       static_cast<WebThreadImplForMessageLoop*>(thread);
   delete impl;
 }
 
 }  // namespace content