[WIP] Hack on Blob mojom

content/child/blob_storage/blob_transport_controller.h

 // Copyright 2015 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.
 
 #ifndef CONTENT_CHILD_BLOB_STORAGE_BLOB_TRANSPORT_CONTROLLER_H_
 #define CONTENT_CHILD_BLOB_STORAGE_BLOB_TRANSPORT_CONTROLLER_H_
 
 #include <stddef.h>
 
 #include <map>
 #include <memory>
 #include <string>
 #include <utility>
 #include <vector>
 
 #include "base/callback_forward.h"
 #include "base/gtest_prod_util.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/shared_memory_handle.h"
 #include "base/memory/weak_ptr.h"
+#include "content/common/blob.mojom.h"
 #include "content/common/content_export.h"
 #include "ipc/ipc_platform_file.h"
 #include "storage/common/blob_storage/blob_storage_constants.h"
 
 namespace base {
 template <typename T>
 struct DefaultLazyInstanceTraits;
 class SingleThreadTaskRunner;
 class TaskRunner;
 }
 
 namespace storage {
 class DataElement;
 struct BlobItemBytesRequest;
 struct BlobItemBytesResponse;
 }
 
 namespace IPC {
 class Message;
 class Sender;
+class SyncMessageFilter;
 }
 
 namespace content {
 
 class BlobConsolidation;
 class ThreadSafeSender;
 
 // This class is used to manage all the asynchronous transporation of blobs from
 // the Renderer to the Browser process, where it's handling the Renderer side.
 // The function of this class is to:
@@ skipping 29 matching lines @@
   // asynchronously. Use CancelAllBlobTransfers to stop usage of the |sender|.
   // We close the file handles once we're done writing to them.
   void OnMemoryRequest(
       const std::string& uuid,
       const std::vector<storage::BlobItemBytesRequest>& requests,
       std::vector<base::SharedMemoryHandle>* memory_handles,
       const std::vector<IPC::PlatformFileForTransit>& file_handles,
       base::TaskRunner* file_runner,
       IPC::Sender* sender);
 
-  void OnCancel(const std::string& uuid,
-                storage::IPCBlobCreationCancelCode code);
-
-  void OnDone(const std::string& uuid);
+  void OnBuildBlobComplete(const std::string& uuid,
+                           mojom::BlobAssociatedPtr blob,
+                           mojom::BlobCreationCancelCode cancel_code);
 
   bool IsTransporting(const std::string& uuid) {
     return blob_storage_.find(uuid) != blob_storage_.end();
   }
 
   // Invalidates all asynchronously running memory request handlers and clears
   // the internal state. If our map wasn't previously empty, then we call
   // ChildProcess::ReleaseProcess to release our previous reference.
   void CancelAllBlobTransfers();
 
@@ skipping 21 matching lines @@
   ~BlobTransportController();
 
   void OnFileWriteComplete(
       IPC::Sender* sender,
       const std::string& uuid,
       const std::pair<std::vector<storage::BlobItemBytesResponse>,
                       storage::IPCBlobCreationCancelCode>& result);
 
   void StoreBlobDataForRequests(
       const std::string& uuid,
+      const std::string& content_type,
       scoped_refptr<BlobConsolidation> consolidation,
+      scoped_refptr<IPC::SyncMessageFilter> sync_message_filter,
       scoped_refptr<base::SingleThreadTaskRunner> main_runner);
 
   // Deletes the consolidation and calls ChildProcess::ReleaseProcess.
   void ReleaseBlobConsolidation(const std::string& uuid);
 
   scoped_refptr<base::SingleThreadTaskRunner> main_thread_runner_;
+  mojom::BlobFactoryAssociatedPtr blob_factory_;
   std::map<std::string, scoped_refptr<BlobConsolidation>> blob_storage_;
+  std::map<std::string, mojom::BlobAssociatedPtr> blob_proxies_;
   base::WeakPtrFactory<BlobTransportController> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(BlobTransportController);
 };
 
 }  // namespace content
 #endif  // CONTENT_CHILD_BLOB_STORAGE_BLOB_TRANSPORT_CONTROLLER_H_