Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1321)

Unified Diff: content/browser/in_process_webkit/indexed_db_callbacks.cc

Issue 17840006: Move IndexedDB files out of in_process_webkit (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: content/browser/in_process_webkit/indexed_db_callbacks.cc
diff --git a/content/browser/in_process_webkit/indexed_db_callbacks.cc b/content/browser/in_process_webkit/indexed_db_callbacks.cc
deleted file mode 100644
index f6eda3b2d8c303691ccf8d7062da276e8c1d5eeb..0000000000000000000000000000000000000000
--- a/content/browser/in_process_webkit/indexed_db_callbacks.cc
+++ /dev/null
@@ -1,296 +0,0 @@
-// 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/browser/in_process_webkit/indexed_db_callbacks.h"
-
-#include <algorithm>
-#include <vector>
-
-#include "content/browser/indexed_db/indexed_db_metadata.h"
-#include "content/browser/indexed_db/webidbdatabase_impl.h"
-#include "content/common/indexed_db/indexed_db_messages.h"
-#include "webkit/browser/quota/quota_manager.h"
-
-using WebKit::WebData;
-using WebKit::WebIDBCallbacks;
-using WebKit::WebString;
-
-namespace content {
-
-namespace {
-const int32 kDatabaseNotAdded = -1;
-}
-
-IndexedDBCallbacksBase::IndexedDBCallbacksBase(
- IndexedDBDispatcherHost* dispatcher_host,
- int32 ipc_thread_id,
- int32 ipc_callbacks_id)
- : dispatcher_host_(dispatcher_host),
- ipc_callbacks_id_(ipc_callbacks_id),
- ipc_thread_id_(ipc_thread_id) {}
-
-IndexedDBCallbacksBase::~IndexedDBCallbacksBase() {}
-
-void IndexedDBCallbacksBase::onError(const WebKit::WebIDBDatabaseError& error) {
- dispatcher_host_->Send(new IndexedDBMsg_CallbacksError(
- ipc_thread_id_, ipc_callbacks_id_, error.code(), error.message()));
-}
-
-void IndexedDBCallbacksBase::onBlocked(long long old_version) {
- dispatcher_host_->Send(new IndexedDBMsg_CallbacksIntBlocked(
- ipc_thread_id_, ipc_callbacks_id_, old_version));
-}
-
-void IndexedDBCallbacksBase::onSuccess(const std::vector<string16>& value) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(
- WebIDBDatabaseImpl* idb_object,
- const IndexedDBDatabaseMetadata& metadata) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onUpgradeNeeded(
- long long old_version,
- WebIDBDatabaseImpl* database,
- const IndexedDBDatabaseMetadata& /*metadata*/,
- WebKit::WebIDBCallbacks::DataLoss data_loss) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(WebIDBCursorImpl* idb_object,
- const IndexedDBKey& key,
- const IndexedDBKey& primaryKey,
- std::vector<char>* value) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(const IndexedDBKey& key,
- const IndexedDBKey& primaryKey,
- std::vector<char>* value) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(std::vector<char>* value) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccessWithPrefetch(
- const std::vector<IndexedDBKey>& keys,
- const std::vector<IndexedDBKey>& primaryKeys,
- const std::vector<std::vector<char> >& values) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(const IndexedDBKey& value) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(std::vector<char>* value,
- const IndexedDBKey& key,
- const IndexedDBKeyPath& keyPath) {
- NOTREACHED();
-}
-
-void IndexedDBCallbacksBase::onSuccess(long long value) { NOTREACHED(); }
-
-void IndexedDBCallbacksBase::onSuccess() { NOTREACHED(); }
-
-IndexedDBCallbacksDatabase::IndexedDBCallbacksDatabase(
- IndexedDBDispatcherHost* dispatcher_host,
- int32 ipc_thread_id,
- int32 ipc_callbacks_id,
- int32 ipc_database_callbacks_id,
- int64 host_transaction_id,
- const GURL& origin_url)
- : IndexedDBCallbacksBase(dispatcher_host, ipc_thread_id, ipc_callbacks_id),
- host_transaction_id_(host_transaction_id),
- origin_url_(origin_url),
- ipc_database_id_(kDatabaseNotAdded),
- ipc_database_callbacks_id_(ipc_database_callbacks_id) {}
-
-void IndexedDBCallbacksDatabase::onSuccess(
- WebIDBDatabaseImpl* idb_object,
- const IndexedDBDatabaseMetadata& metadata) {
- int32 ipc_object_id = ipc_database_id_;
- if (ipc_object_id == kDatabaseNotAdded) {
- ipc_object_id =
- dispatcher_host()->Add(idb_object, ipc_thread_id(), origin_url_);
- } else {
- // We already have this database and don't need a new copy of it.
- delete idb_object;
- }
- const ::IndexedDBDatabaseMetadata idb_metadata =
- IndexedDBDispatcherHost::ConvertMetadata(metadata);
-
- dispatcher_host()->Send(
- new IndexedDBMsg_CallbacksSuccessIDBDatabase(ipc_thread_id(),
- ipc_callbacks_id(),
- ipc_database_callbacks_id_,
- ipc_object_id,
- idb_metadata));
-}
-
-void IndexedDBCallbacksDatabase::onUpgradeNeeded(
- long long old_version,
- WebIDBDatabaseImpl* database,
- const IndexedDBDatabaseMetadata& metadata,
- WebIDBCallbacks::DataLoss data_loss) {
- dispatcher_host()->RegisterTransactionId(host_transaction_id_, origin_url_);
- int32 ipc_database_id =
- dispatcher_host()->Add(database, ipc_thread_id(), origin_url_);
- ipc_database_id_ = ipc_database_id;
- IndexedDBMsg_CallbacksUpgradeNeeded_Params params;
- params.ipc_thread_id = ipc_thread_id();
- params.ipc_callbacks_id = ipc_callbacks_id();
- params.ipc_database_id = ipc_database_id;
- params.ipc_database_callbacks_id = ipc_database_callbacks_id_;
- params.old_version = old_version;
- params.idb_metadata = IndexedDBDispatcherHost::ConvertMetadata(metadata);
- params.data_loss = data_loss;
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksUpgradeNeeded(params));
-}
-
-void IndexedDBCallbacks<WebIDBCursorImpl>::onSuccess(
- WebIDBCursorImpl* idb_cursor,
- const IndexedDBKey& key,
- const IndexedDBKey& primaryKey,
- std::vector<char>* value) {
- int32 ipc_object_id = dispatcher_host()->Add(idb_cursor);
- IndexedDBMsg_CallbacksSuccessIDBCursor_Params params;
- params.ipc_thread_id = ipc_thread_id();
- params.ipc_callbacks_id = ipc_callbacks_id();
- params.ipc_cursor_id = ipc_object_id;
- params.key = key;
- params.primary_key = primaryKey;
- if (value && !value->empty())
- std::swap(params.value, *value);
- // TODO(alecflett): Avoid a copy here: the whole params object is
- // being copied into the message.
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessIDBCursor(params));
-}
-
-void IndexedDBCallbacks<WebIDBCursorImpl>::onSuccess(std::vector<char>* value) {
- std::vector<char> value_copy;
- if (value && !value->empty())
- std::swap(value_copy, *value);
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessValue(
- ipc_thread_id(),
- ipc_callbacks_id(),
- // TODO(alecflett): avoid a copy here.
- value_copy));
-}
-
-void IndexedDBCallbacks<WebIDBCursorImpl>::onSuccess(
- const IndexedDBKey& key,
- const IndexedDBKey& primaryKey,
- std::vector<char>* value) {
- DCHECK_NE(ipc_cursor_id_, -1);
- WebIDBCursorImpl* idb_cursor =
- dispatcher_host()->GetCursorFromId(ipc_cursor_id_);
-
- DCHECK(idb_cursor);
- if (!idb_cursor)
- return;
- IndexedDBMsg_CallbacksSuccessCursorContinue_Params params;
- params.ipc_thread_id = ipc_thread_id();
- params.ipc_callbacks_id = ipc_callbacks_id();
- params.ipc_cursor_id = ipc_cursor_id_;
- params.key = key;
- params.primary_key = primaryKey;
- if (value && !value->empty())
- std::swap(params.value, *value);
- // TODO(alecflett): Avoid a copy here: the whole params object is
- // being copied into the message.
- dispatcher_host()->Send(
- new IndexedDBMsg_CallbacksSuccessCursorContinue(params));
-}
-
-void IndexedDBCallbacks<WebIDBCursorImpl>::onSuccessWithPrefetch(
- const std::vector<IndexedDBKey>& keys,
- const std::vector<IndexedDBKey>& primaryKeys,
- const std::vector<std::vector<char> >& values) {
- DCHECK_NE(ipc_cursor_id_, -1);
-
- std::vector<IndexedDBKey> msgKeys;
- std::vector<IndexedDBKey> msgPrimaryKeys;
-
- for (size_t i = 0; i < keys.size(); ++i) {
- msgKeys.push_back(keys[i]);
- msgPrimaryKeys.push_back(primaryKeys[i]);
- }
-
- IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params params;
- params.ipc_thread_id = ipc_thread_id();
- params.ipc_callbacks_id = ipc_callbacks_id();
- params.ipc_cursor_id = ipc_cursor_id_;
- params.keys = msgKeys;
- params.primary_keys = msgPrimaryKeys;
- params.values = values;
- dispatcher_host()->Send(
- new IndexedDBMsg_CallbacksSuccessCursorPrefetch(params));
-}
-
-void IndexedDBCallbacks<IndexedDBKey>::onSuccess(const IndexedDBKey& value) {
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessIndexedDBKey(
- ipc_thread_id(), ipc_callbacks_id(), IndexedDBKey(value)));
-}
-
-void IndexedDBCallbacks<std::vector<string16> >::onSuccess(
- const std::vector<string16>& value) {
-
- std::vector<string16> list;
- for (unsigned i = 0; i < value.size(); ++i)
- list.push_back(value[i]);
-
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessStringList(
- ipc_thread_id(), ipc_callbacks_id(), list));
-}
-
-void IndexedDBCallbacks<std::vector<char> >::onSuccess(
- std::vector<char>* value) {
- std::vector<char> value_copy;
- if (value && !value->empty())
- std::swap(value_copy, *value);
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessValue(
- ipc_thread_id(),
- ipc_callbacks_id(),
- // TODO(alecflett): avoid a copy here
- value_copy));
-}
-
-void IndexedDBCallbacks<std::vector<char> >::onSuccess(
- std::vector<char>* value,
- const IndexedDBKey& primaryKey,
- const IndexedDBKeyPath& keyPath) {
- std::vector<char> value_copy;
- if (value && !value->empty())
- std::swap(value_copy, *value);
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessValueWithKey(
- ipc_thread_id(),
- ipc_callbacks_id(),
- // TODO(alecflett): Avoid a copy here.
- value_copy,
- IndexedDBKey(primaryKey),
- IndexedDBKeyPath(keyPath)));
-}
-
-void IndexedDBCallbacks<std::vector<char> >::onSuccess(long long value) {
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessInteger(
- ipc_thread_id(), ipc_callbacks_id(), value));
-}
-
-void IndexedDBCallbacks<std::vector<char> >::onSuccess() {
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessUndefined(
- ipc_thread_id(), ipc_callbacks_id()));
-}
-
-void IndexedDBCallbacks<std::vector<char> >::onSuccess(
- const IndexedDBKey& value) {
- dispatcher_host()->Send(new IndexedDBMsg_CallbacksSuccessIndexedDBKey(
- ipc_thread_id(), ipc_callbacks_id(), value));
-}
-
-} // namespace content

Powered by Google App Engine
This is Rietveld 408576698