The chromium-side backchannel plumbing for blobs in IDB.

content/child/indexed_db/webidbcursor_impl.cc

 // Copyright 2013 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/indexed_db/webidbcursor_impl.h"
 
 #include <vector>
 
 #include "content/child/indexed_db/indexed_db_dispatcher.h"
 #include "content/child/indexed_db/indexed_db_key_builders.h"
@@ skipping 104 matching lines @@
   // callback did something else, or nothing at all, in which case we need to
   // reset the cache.
 
   if (pending_onsuccess_callbacks_ == 0)
     ResetPrefetchCache();
 }
 
 void WebIDBCursorImpl::SetPrefetchData(
     const std::vector<IndexedDBKey>& keys,
     const std::vector<IndexedDBKey>& primary_keys,
-    const std::vector<WebData>& values) {
+    const std::vector<WebData>& values,
+    const std::vector<blink::WebVector<blink::WebBlobInfo> >& blob_info) {
   prefetch_keys_.assign(keys.begin(), keys.end());
   prefetch_primary_keys_.assign(primary_keys.begin(), primary_keys.end());
   prefetch_values_.assign(values.begin(), values.end());
+  prefetch_blob_info_.assign(blob_info.begin(), blob_info.end());
 
   used_prefetches_ = 0;
   pending_onsuccess_callbacks_ = 0;
 }
 
 void WebIDBCursorImpl::CachedAdvance(unsigned long count,
                                      WebIDBCallbacks* callbacks) {
   DCHECK_GE(prefetch_keys_.size(), count);
   DCHECK_EQ(prefetch_primary_keys_.size(), prefetch_keys_.size());
   DCHECK_EQ(prefetch_values_.size(), prefetch_keys_.size());
+  DCHECK_EQ(prefetch_blob_info_.size(), prefetch_keys_.size());
 
   while (count > 1) {
     prefetch_keys_.pop_front();
     prefetch_primary_keys_.pop_front();
     prefetch_values_.pop_front();
+    prefetch_blob_info_.pop_front();
     ++used_prefetches_;
     --count;
   }
 
   CachedContinue(callbacks);
 }
 
 void WebIDBCursorImpl::CachedContinue(WebIDBCallbacks* callbacks) {
   DCHECK_GT(prefetch_keys_.size(), 0ul);
   DCHECK_EQ(prefetch_primary_keys_.size(), prefetch_keys_.size());
   DCHECK_EQ(prefetch_values_.size(), prefetch_keys_.size());
+  DCHECK_EQ(prefetch_blob_info_.size(), prefetch_keys_.size());
 
   IndexedDBKey key = prefetch_keys_.front();
   IndexedDBKey primary_key = prefetch_primary_keys_.front();
   WebData value = prefetch_values_.front();
+  blink::WebVector<blink::WebBlobInfo> blob_info = prefetch_blob_info_.front();
 
   prefetch_keys_.pop_front();
   prefetch_primary_keys_.pop_front();
   prefetch_values_.pop_front();
+  prefetch_blob_info_.pop_front();
   ++used_prefetches_;
 
   ++pending_onsuccess_callbacks_;
 
   if (!continue_count_) {
     // The cache was invalidated by a call to ResetPrefetchCache()
     // after the RequestIDBCursorPrefetch() was made. Now that the
     // initiating continue() call has been satisfied, discard
     // the rest of the cache.
     ResetPrefetchCache();
   }
 
   callbacks->onSuccess(WebIDBKeyBuilder::Build(key),
                        WebIDBKeyBuilder::Build(primary_key),
-                       value);
+                       value,
+                       blob_info);
 }
 
 void WebIDBCursorImpl::ResetPrefetchCache() {
   continue_count_ = 0;
   prefetch_amount_ = kMinPrefetchAmount;
 
   if (!prefetch_keys_.size()) {
     // No prefetch cache, so no need to reset the cursor in the back-end.
     return;
   }
 
   IndexedDBDispatcher* dispatcher =
       IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get());
   dispatcher->RequestIDBCursorPrefetchReset(
       used_prefetches_, prefetch_keys_.size(), ipc_cursor_id_);
   prefetch_keys_.clear();
   prefetch_primary_keys_.clear();
   prefetch_values_.clear();
+  prefetch_blob_info_.clear();
 
   pending_onsuccess_callbacks_ = 0;
 }
 
 }  // namespace content