[IndexedDB] Hold referenced to IDB::put blobs in the IDBRequest

content/browser/indexed_db/indexed_db_dispatcher_host.h

 // Copyright (c) 2012 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_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_
 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_
 
 #include <stdint.h>
 
 #include <map>
@@ skipping 15 matching lines @@
 
 namespace base {
 class SequencedTaskRunner;
 }
 
 namespace url {
 class Origin;
 }
 
 namespace content {
+class BlobDispatcherHost;
 class IndexedDBBlobInfo;
 class IndexedDBContextImpl;
 
 // Handles all IndexedDB related messages from a particular renderer process.
 // Constructed on UI thread, expects all other calls (including destruction) on
 // IO thread.
 class CONTENT_EXPORT IndexedDBDispatcherHost
     : public ::indexed_db::mojom::Factory,
       public RenderProcessHostObserver {
  public:
@@ skipping 13 matching lines @@
   void AddCursorBinding(std::unique_ptr<::indexed_db::mojom::Cursor> cursor,
                         ::indexed_db::mojom::CursorAssociatedRequest request);
 
   // A shortcut for accessing our context.
   IndexedDBContextImpl* context() const { return indexed_db_context_.get(); }
   storage::BlobStorageContext* blob_storage_context() const {
     return blob_storage_context_->context();
   }
   int ipc_process_id() const { return ipc_process_id_; }
 
+  void SetBlobDispatcherHost(scoped_refptr<BlobDispatcherHost> host);
+
+  // Decrements the refcount for the given blob for this renderer.
+  void AckBlobRecievedFromIDB(const std::string& uuid);
+
   std::string HoldBlobData(const IndexedDBBlobInfo& blob_info);
   void DropBlobData(const std::string& uuid);
 
   // Must be called on the IO thread.
   base::WeakPtr<IndexedDBDispatcherHost> AsWeakPtr() {
     return weak_factory_.GetWeakPtr();
   }
 
   // Called by UI thread. Used to kill outstanding bindings and weak pointers
   // in callbacks.
@@ skipping 23 matching lines @@
   void DeleteDatabase(
       ::indexed_db::mojom::CallbacksAssociatedPtrInfo callbacks_info,
       const url::Origin& origin,
       const base::string16& name,
       bool force_close) override;
 
   void InvalidateWeakPtrsAndClearBindings();
 
   scoped_refptr<IndexedDBContextImpl> indexed_db_context_;
   scoped_refptr<ChromeBlobStorageContext> blob_storage_context_;
+  // TODO(dmurph): Remove once blobs are mojo'd.

[pwnall, 2017/04/21 01:39:22]

Would it be worth pointing to this CL in the TODO? IIUC, all the plumbing here
could go away if mojo can hang onto the Blobs.

+  scoped_refptr<BlobDispatcherHost> blob_dispatcher_host_;
   scoped_refptr<base::SequencedTaskRunner> idb_runner_;
 
   // Maps blob uuid to a pair (handle, ref count). Entry is added and/or count
   // is incremented in HoldBlobData(), and count is decremented and/or entry
   // removed in DropBlobData().
   std::map<std::string,
            std::pair<std::unique_ptr<storage::BlobDataHandle>, int>>
       blob_data_handle_map_;
 
   // Used to set file permissions for blob storage.
@@ skipping 10 matching lines @@
   IDBThreadHelper* idb_helper_;
 
   base::WeakPtrFactory<IndexedDBDispatcherHost> weak_factory_;
 
   DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_