Remove a ton of IPC from landing putWithIndexKeys

content/common/indexed_db/indexed_db_dispatcher.cc

 // 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.
 
 #include "content/common/indexed_db/indexed_db_dispatcher.h"
 
 #include "base/lazy_instance.h"
 #include "base/threading/thread_local.h"
 #include "content/common/child_thread.h"
 #include "content/common/indexed_db/indexed_db_messages.h"
@@ skipping 30 matching lines @@
     g_idb_dispatcher_tls = LAZY_INSTANCE_INITIALIZER;
 
 namespace {
 
 IndexedDBDispatcher* const kHasBeenDeleted =
     reinterpret_cast<IndexedDBDispatcher*>(0x1);
 
 int32 CurrentWorkerId() {
   return WorkerTaskRunner::Instance()->CurrentWorkerId();
 }
-
-} // unnamed namespace
+}  // unnamed namespace
 
 const size_t kMaxIDBValueSizeInBytes = 64 * 1024 * 1024;
 
 IndexedDBDispatcher::IndexedDBDispatcher() {
   g_idb_dispatcher_tls.Pointer()->Set(this);
 }
 
 IndexedDBDispatcher::~IndexedDBDispatcher() {
   g_idb_dispatcher_tls.Pointer()->Set(kHasBeenDeleted);
 }
@@ skipping 59 matching lines @@
 
 bool IndexedDBDispatcher::Send(IPC::Message* msg) {
   if (CurrentWorkerId()) {
     scoped_refptr<IPC::SyncMessageFilter> filter(
         ChildThread::current()->sync_message_filter());
     return filter->Send(msg);
   }
   return ChildThread::current()->Send(msg);
 }
 
-void IndexedDBDispatcher::RequestIDBCursorUpdate(
-    const SerializedScriptValue& value,
-    WebIDBCallbacks* callbacks_ptr,
-    int32 idb_cursor_id,
-    WebExceptionCode* ec) {
-  ResetCursorPrefetchCaches();
-  scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-  if (!value.is_null() &&
-      (value.data().length() * sizeof(char16)) > kMaxIDBValueSizeInBytes) {
-    *ec = WebKit::WebIDBDatabaseExceptionDataError;
-    return;
-  }
-  int32 response_id = pending_callbacks_.Add(callbacks.release());
-  Send(
-      new IndexedDBHostMsg_CursorUpdate(idb_cursor_id, CurrentWorkerId(),
-                                        response_id, value, ec));
-  if (*ec)
-    pending_callbacks_.Remove(response_id);
-}
-
 void IndexedDBDispatcher::RequestIDBCursorAdvance(
     unsigned long count,
     WebIDBCallbacks* callbacks_ptr,
     int32 idb_cursor_id,
     WebExceptionCode* ec) {
   // Reset all cursor prefetch caches except for this cursor.
   ResetCursorPrefetchCaches(idb_cursor_id);
 
   scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
 
@@ skipping 628 matching lines @@
 }
 
 void IndexedDBDispatcher::ResetCursorPrefetchCaches(int32 exception_cursor_id) {
   typedef std::map<int32, RendererWebIDBCursorImpl*>::iterator Iterator;
   for (Iterator i = cursors_.begin(); i != cursors_.end(); ++i) {
     if (i->first == exception_cursor_id)
       continue;
     i->second->ResetPrefetchCache();
   }
 }