Replacing Indexed DB Chromium IPC with Mojo

content/browser/indexed_db/indexed_db_cursor.cc

 // Copyright (c) 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/browser/indexed_db/indexed_db_cursor.h"
 
 #include <stddef.h>
 #include <utility>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/logging.h"
-#include "content/browser/indexed_db/indexed_db_callbacks.h"
 #include "content/browser/indexed_db/indexed_db_database_error.h"
 #include "content/browser/indexed_db/indexed_db_tracing.h"
 #include "content/browser/indexed_db/indexed_db_transaction.h"
 #include "content/browser/indexed_db/indexed_db_value.h"
 
 namespace content {
 
 IndexedDBCursor::IndexedDBCursor(
     std::unique_ptr<IndexedDBBackingStore::Cursor> cursor,
     indexed_db::CursorType cursor_type,
     blink::WebIDBTaskType task_type,
     IndexedDBTransaction* transaction)
     : task_type_(task_type),
       cursor_type_(cursor_type),
       transaction_(transaction),
       cursor_(std::move(cursor)),
       closed_(false) {
   transaction_->RegisterOpenCursor(this);
 }
 
 IndexedDBCursor::~IndexedDBCursor() {
   transaction_->UnregisterOpenCursor(this);
 }
 
 void IndexedDBCursor::Continue(std::unique_ptr<IndexedDBKey> key,
-                               std::unique_ptr<IndexedDBKey> primary_key,
-                               scoped_refptr<IndexedDBCallbacks> callbacks) {
+                               std::unique_ptr<IndexedDBKey> primary_key) {
   IDB_TRACE("IndexedDBCursor::Continue");
 
   transaction_->ScheduleTask(
-      task_type_,
-      base::Bind(&IndexedDBCursor::CursorIterationOperation,
-                 this,
-                 base::Passed(&key),
-                 base::Passed(&primary_key),
-                 callbacks));
+      task_type_, base::Bind(&IndexedDBCursor::CursorIterationOperation, this,
+                             base::Passed(&key), base::Passed(&primary_key)));
 }
 
-void IndexedDBCursor::Advance(uint32_t count,
-                              scoped_refptr<IndexedDBCallbacks> callbacks) {
+void IndexedDBCursor::Advance(uint32_t count) {
   IDB_TRACE("IndexedDBCursor::Advance");
 
   transaction_->ScheduleTask(
       task_type_,
-      base::Bind(
-          &IndexedDBCursor::CursorAdvanceOperation, this, count, callbacks));
+      base::Bind(&IndexedDBCursor::CursorAdvanceOperation, this, count));
 }
 
 void IndexedDBCursor::CursorAdvanceOperation(
     uint32_t count,
-    scoped_refptr<IndexedDBCallbacks> callbacks,
     IndexedDBTransaction* /*transaction*/) {
   IDB_TRACE("IndexedDBCursor::CursorAdvanceOperation");
   leveldb::Status s;
   // TODO(cmumford): Handle this error (crbug.com/363397). Although this will
   //                 properly fail, caller will not know why, and any corruption
   //                 will be ignored.
   if (!cursor_ || !cursor_->Advance(count, &s)) {
     cursor_.reset();
+#ifdef CJM_NEED_CALLBACK
     callbacks->OnSuccess(nullptr);
+#endif
     return;
   }
 
+#ifdef CJM_NEED_CALLBACK
   callbacks->OnSuccess(key(), primary_key(), Value());
+#endif
 }
 
 void IndexedDBCursor::CursorIterationOperation(
     std::unique_ptr<IndexedDBKey> key,
     std::unique_ptr<IndexedDBKey> primary_key,
-    scoped_refptr<IndexedDBCallbacks> callbacks,
     IndexedDBTransaction* /*transaction*/) {
   IDB_TRACE("IndexedDBCursor::CursorIterationOperation");
   leveldb::Status s;
   // TODO(cmumford): Handle this error (crbug.com/363397). Although this will
   //                 properly fail, caller will not know why, and any corruption
   //                 will be ignored.
   if (!cursor_ || !cursor_->Continue(key.get(),
                                      primary_key.get(),
                                      IndexedDBBackingStore::Cursor::SEEK,
                                      &s) || !s.ok()) {
     cursor_.reset();
+#ifdef CJM_NEED_CALLBACK
     callbacks->OnSuccess(nullptr);
+#endif
     return;
   }
 
+#ifdef CJM_NEED_CALLBACK
   callbacks->OnSuccess(this->key(), this->primary_key(), Value());
+#endif
 }
 
-void IndexedDBCursor::PrefetchContinue(
-    int number_to_fetch,
-    scoped_refptr<IndexedDBCallbacks> callbacks) {
+void IndexedDBCursor::PrefetchContinue(int number_to_fetch) {
   IDB_TRACE("IndexedDBCursor::PrefetchContinue");
 
   transaction_->ScheduleTask(
-      task_type_,
-      base::Bind(&IndexedDBCursor::CursorPrefetchIterationOperation,
-                 this,
-                 number_to_fetch,
-                 callbacks));
+      task_type_, base::Bind(&IndexedDBCursor::CursorPrefetchIterationOperation,
+                             this, number_to_fetch));
 }
 
 void IndexedDBCursor::CursorPrefetchIterationOperation(
     int number_to_fetch,
-    scoped_refptr<IndexedDBCallbacks> callbacks,
     IndexedDBTransaction* /*transaction*/) {
   IDB_TRACE("IndexedDBCursor::CursorPrefetchIterationOperation");
 
   std::vector<IndexedDBKey> found_keys;
   std::vector<IndexedDBKey> found_primary_keys;
   std::vector<IndexedDBValue> found_values;
 
   saved_cursor_.reset();
   // TODO(cmumford): Use IPC::Channel::kMaximumMessageSize
   const size_t max_size_estimate = 10 * 1024 * 1024;
@@ skipping 33 matching lines @@
         NOTREACHED();
     }
     size_estimate += cursor_->key().size_estimate();
     size_estimate += cursor_->primary_key().size_estimate();
 
     if (size_estimate > max_size_estimate)
       break;
   }
 
   if (found_keys.empty()) {
+#ifdef CJM_NEED_CALLBACK
     callbacks->OnSuccess(nullptr);
+#endif
     return;
   }
 
+#ifdef CJM_NEED_CALLBACK
   callbacks->OnSuccessWithPrefetch(
       found_keys, found_primary_keys, &found_values);
+#endif
 }
 
 leveldb::Status IndexedDBCursor::PrefetchReset(int used_prefetches,
                                                int /* unused_prefetches */) {
   IDB_TRACE("IndexedDBCursor::PrefetchReset");
   cursor_.swap(saved_cursor_);
   saved_cursor_.reset();
   leveldb::Status s;
 
   if (closed_)
@@ skipping 11 matching lines @@
 }
 
 void IndexedDBCursor::Close() {
   IDB_TRACE("IndexedDBCursor::Close");
   closed_ = true;
   cursor_.reset();
   saved_cursor_.reset();
 }
 
 }  // namespace content