[BlobAsync] Disk support for blob storage

content/child/blob_storage/blob_message_filter.cc

 // 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.
 
 #include "content/child/blob_storage/blob_message_filter.h"
 
 #include "base/bind.h"
 #include "base/task_runner.h"
 #include "content/child/blob_storage/blob_transport_controller.h"
 #include "content/child/thread_safe_sender.h"
@@ skipping 17 matching lines @@
 
 void BlobMessageFilter::OnChannelClosing() {
   BlobTransportController::GetInstance()->CancelAllBlobTransfers();
   sender_ = nullptr;
 }
 
 bool BlobMessageFilter::OnMessageReceived(const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(BlobMessageFilter, message)
     IPC_MESSAGE_HANDLER(BlobStorageMsg_RequestMemoryItem, OnRequestMemoryItem)
-    IPC_MESSAGE_HANDLER(BlobStorageMsg_CancelBuildingBlob, OnCancelBuildingBlob)
-    IPC_MESSAGE_HANDLER(BlobStorageMsg_DoneBuildingBlob, OnDoneBuildingBlob)
+    IPC_MESSAGE_HANDLER(BlobStorageMsg_SendBlobStatus, OnBlobStatus)

[michaeln, 2016/08/15 22:44:43]

maybe call this OnBlobFinalStatus here and throughout on the client side to make
it clear that we won't see one of the pending states in here

[dmurph, 2016/08/19 00:18:32]

Done.

     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 bool BlobMessageFilter::GetSupportedMessageClasses(
     std::vector<uint32_t>* supported_message_classes) const {
   supported_message_classes->push_back(BlobMsgStart);
   return true;
 }
 
 void BlobMessageFilter::OnRequestMemoryItem(
     const std::string& uuid,
     const std::vector<storage::BlobItemBytesRequest>& requests,
     std::vector<base::SharedMemoryHandle> memory_handles,
     const std::vector<IPC::PlatformFileForTransit>& file_handles) {
   BlobTransportController::GetInstance()->OnMemoryRequest(
       uuid, requests, &memory_handles, file_handles, file_runner_.get(),
       sender_);
 }
 
-void BlobMessageFilter::OnCancelBuildingBlob(
-    const std::string& uuid,
-    storage::IPCBlobCreationCancelCode code) {
-  BlobTransportController::GetInstance()->OnCancel(uuid, code);
-}
-
-void BlobMessageFilter::OnDoneBuildingBlob(const std::string& uuid) {
-  BlobTransportController::GetInstance()->OnDone(uuid);
+void BlobMessageFilter::OnBlobStatus(const std::string& uuid,
+                                     storage::BlobStatus code) {
+  BlobTransportController::GetInstance()->OnBlobStatus(uuid, code);
 }
 
 }  // namespace content