Wrap large IndexedDB values into Blobs before writing to LevelDB.

third_party/WebKit/Source/modules/indexeddb/IDBTransaction.cpp

 /*
  * Copyright (C) 2010 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
  * 2.  Redistributions in binary form must reproduce the above copyright
@@ skipping 18 matching lines @@
 #include "core/dom/DOMException.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/events/EventQueue.h"
 #include "modules/IndexedDBNames.h"
 #include "modules/indexeddb/IDBDatabase.h"
 #include "modules/indexeddb/IDBEventDispatcher.h"
 #include "modules/indexeddb/IDBIndex.h"
 #include "modules/indexeddb/IDBObjectStore.h"
 #include "modules/indexeddb/IDBOpenDBRequest.h"
+#include "modules/indexeddb/IDBRequestQueueItem.h"
 #include "modules/indexeddb/IDBTracing.h"
 #include "platform/bindings/ScriptState.h"
 #include "platform/bindings/V8PerIsolateData.h"
 #include "platform/wtf/PtrUtil.h"
 
 #include <memory>
 
 using blink::WebIDBDatabase;
 
 namespace blink {
@@ skipping 323 matching lines @@
 }
 
 void IDBTransaction::RegisterRequest(IDBRequest* request) {
   DCHECK(request);
   DCHECK_EQ(state_, kActive);
   request_list_.insert(request);
 }
 
 void IDBTransaction::UnregisterRequest(IDBRequest* request) {
   DCHECK(request);
+  DCHECK_EQ(request->QueueItem(), nullptr);
   // If we aborted the request, it will already have been removed.
   request_list_.erase(request);
 }
 
+void IDBTransaction::EnqueueResult(
+    std::unique_ptr<IDBRequestQueueItem> result) {
+  DCHECK(result);
+  DCHECK(HasQueuedResults() || !result->IsReady());
+
+  result_queue_.push_back(std::move(result));
+  // StartLoading() may complete post-processing synchronously, so the result
+  // needs to be in the queue before StartLoading() is called.
+  result_queue_.back()->StartLoading();
+}
+
+void IDBTransaction::OnResultReady() {
+  while (!result_queue_.empty()) {
+    IDBRequestQueueItem* result = result_queue_.front().get();
+    if (!result->IsReady())
+      break;
+
+    result->FireCallback();
+    result_queue_.pop_front();
+  }
+}
+
 void IDBTransaction::OnAbort(DOMException* error) {
   IDB_TRACE("IDBTransaction::onAbort");
   if (!GetExecutionContext()) {
     Finished();
     return;
   }
 
   DCHECK_NE(state_, kFinished);
   if (state_ != kFinishing) {
     // Abort was not triggered by front-end.
@@ skipping 218 matching lines @@
     IDBObjectStore* object_store = it.key;
     object_store->ClearIndexCache();
   }
   old_store_metadata_.clear();
 
   deleted_indexes_.clear();
   deleted_object_stores_.clear();
 }
 
 }  // namespace blink