[BlobAsync] Fixed race between IPC messages and IO task queue

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>
@@ skipping 92 matching lines @@
   // ChildProcess::ReleaseProcess to release our previous reference.
   void ClearForTesting();
 
   enum class ResponsesStatus {
     BLOB_NOT_FOUND,
     SHARED_MEMORY_MAP_FAILED,
     SUCCESS
   };
   friend struct base::DefaultLazyInstanceTraits<BlobTransportController>;
 
-  void StoreBlobDataForRequests(
+  void StoreBlobDataAndStart(
       const std::string& uuid,
       std::unique_ptr<BlobConsolidation> consolidation,
+      scoped_refptr<ThreadSafeSender> sender,
       scoped_refptr<base::SingleThreadTaskRunner> main_runner);
 
   ResponsesStatus GetResponses(
       const std::string& uuid,
       const std::vector<storage::BlobItemBytesRequest>& requests,
       std::vector<base::SharedMemoryHandle>* memory_handles,
       const std::vector<IPC::PlatformFileForTransit>& file_handles,
       std::vector<storage::BlobItemBytesResponse>* output);
 
   // Deletes the consolidation, and if we removed the last consolidation from
   // our map, we call ChildProcess::ReleaseProcess to release our previous
   // reference.
   void ReleaseBlobConsolidation(const std::string& uuid);
 
   scoped_refptr<base::SingleThreadTaskRunner> main_thread_runner_;
   std::map<std::string, std::unique_ptr<BlobConsolidation>> blob_storage_;
 
   DISALLOW_COPY_AND_ASSIGN(BlobTransportController);
 };
 
 }  // namespace content
 #endif  // CONTENT_CHILD_BLOB_STORAGE_BLOB_TRANSPORT_CONTROLLER_H_