Use shared memory for moving data over BlobChannel Mojo interface.

blimp/engine/mojo/blob_channel_service.cc

 // Copyright 2016 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 "blimp/engine/mojo/blob_channel_service.h"
 
 #include "blimp/net/blob_channel/blob_channel_sender.h"
 
 namespace blimp {
 namespace engine {
 
 BlobChannelService::BlobChannelService(BlobChannelSender* blob_channel_sender,
                                        mojom::BlobChannelRequest request)
     : binding_(this, std::move(request)),
       blob_channel_sender_(blob_channel_sender) {
   DCHECK(blob_channel_sender_);
 }
 
 BlobChannelService::~BlobChannelService() {}
 
 void BlobChannelService::PutBlob(const mojo::String& id,
-                                 const mojo::String& data) {
-  blob_channel_sender_->PutBlob(id, new BlobData(data));
+                                 mojo::ScopedSharedBufferHandle data,
+                                 uint32_t size,
+                                 const PutBlobCallback& callback) {
+  // Map |data| into memory.
+  char* blob_buf = nullptr;
+  MojoResult result =
+      mojo::MapBuffer(data.get(), 0, size, reinterpret_cast<void**>(&blob_buf),

[maniscalco, 2016/06/03 16:43:53]

#include "mojo/public/cpp/system/buffer.h" to get mojo::MapBuffer?

[Kevin M, 2016/06/03 17:14:57]

Done.

+                      MOJO_MAP_BUFFER_FLAG_NONE);
+  DCHECK_EQ(MOJO_RESULT_OK, result);
+  DCHECK(blob_buf);
+
+  scoped_refptr<BlobData> new_blob(new BlobData);
+  new_blob->data.assign(blob_buf, size);
+  blob_channel_sender_->PutBlob(id, std::move(new_blob));
+  mojo::UnmapBuffer(blob_buf);

[maniscalco, 2016/06/03 16:43:53]

Check the result of UnmapBuffer?

[Kevin M, 2016/06/03 17:14:57]

OK. I'm using DCHECK w/return so that we don't blow up the browser process if
the bug is essentially recoverable.

+
+  // Signals the renderer side that we are done with the shared memory |data|.
+  callback.Run();
 }
 
 void BlobChannelService::DeliverBlob(const mojo::String& id) {
   blob_channel_sender_->DeliverBlob(id);
 }
 
 // static
 void BlobChannelService::Create(
     BlobChannelSender* blob_channel_sender,
     mojo::InterfaceRequest<mojom::BlobChannel> request) {
   // Object lifetime is managed by BlobChannelService's StrongBinding
   // |binding_|.
   new BlobChannelService(blob_channel_sender, std::move(request));
 }
 
 }  // namespace engine
 }  // namespace blimp