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

Unified Diff: chrome/renderer/indexed_db_dispatcher.cc

Issue 6703003: Move a bunch of html5 renderer code to content. (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: Created 9 years, 9 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
« no previous file with comments | « chrome/renderer/indexed_db_dispatcher.h ('k') | chrome/renderer/notification_provider.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: chrome/renderer/indexed_db_dispatcher.cc
===================================================================
--- chrome/renderer/indexed_db_dispatcher.cc (revision 78436)
+++ chrome/renderer/indexed_db_dispatcher.cc (working copy)
@@ -1,455 +0,0 @@
-// Copyright (c) 2009 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 "chrome/renderer/indexed_db_dispatcher.h"
-
-#include "chrome/renderer/render_thread.h"
-#include "chrome/renderer/render_view.h"
-#include "chrome/renderer/renderer_webidbcursor_impl.h"
-#include "chrome/renderer/renderer_webidbdatabase_impl.h"
-#include "chrome/renderer/renderer_webidbindex_impl.h"
-#include "chrome/renderer/renderer_webidbobjectstore_impl.h"
-#include "chrome/renderer/renderer_webidbtransaction_impl.h"
-#include "content/common/indexed_db_messages.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebFrame.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseCallbacks.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseError.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBKeyRange.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebSecurityOrigin.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebSerializedScriptValue.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebString.h"
-
-using WebKit::WebExceptionCode;
-using WebKit::WebFrame;
-using WebKit::WebIDBCallbacks;
-using WebKit::WebIDBKeyRange;
-using WebKit::WebIDBDatabase;
-using WebKit::WebIDBDatabaseCallbacks;
-using WebKit::WebIDBDatabaseError;
-using WebKit::WebIDBTransaction;
-using WebKit::WebIDBTransactionCallbacks;
-
-IndexedDBDispatcher::IndexedDBDispatcher() {
-}
-
-IndexedDBDispatcher::~IndexedDBDispatcher() {
-}
-
-bool IndexedDBDispatcher::OnMessageReceived(const IPC::Message& msg) {
- bool handled = true;
- IPC_BEGIN_MESSAGE_MAP(IndexedDBDispatcher, msg)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBCursor,
- OnSuccessOpenCursor)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBDatabase,
- OnSuccessIDBDatabase)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBIndex,
- OnSuccessIDBIndex)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIndexedDBKey,
- OnSuccessIndexedDBKey)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBTransaction,
- OnSuccessIDBTransaction)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValue,
- OnSuccessSerializedScriptValue)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksError, OnError)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksBlocked, OnBlocked)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksAbort, OnAbort)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksComplete, OnComplete)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksTimeout, OnTimeout)
- IPC_MESSAGE_HANDLER(IndexedDBMsg_DatabaseCallbacksVersionChange,
- OnVersionChange)
- IPC_MESSAGE_UNHANDLED(handled = false)
- IPC_END_MESSAGE_MAP()
- return handled;
-}
-
-void IndexedDBDispatcher::RequestIDBCursorUpdate(
- const SerializedScriptValue& value,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_cursor_id,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_CursorUpdate(idb_cursor_id, response_id, value, ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBCursorContinue(
- const IndexedDBKey& key,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_cursor_id,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_CursorContinue(idb_cursor_id, response_id, key, ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBCursorDelete(
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_cursor_id,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_CursorDelete(idb_cursor_id, response_id, ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBFactoryOpen(
- const string16& name,
- WebIDBCallbacks* callbacks_ptr,
- const string16& origin,
- WebFrame* web_frame,
- uint64 maximum_size) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- if (!web_frame)
- return; // We must be shutting down.
- RenderView* render_view = RenderView::FromWebView(web_frame->view());
- if (!render_view)
- return; // We must be shutting down.
-
- IndexedDBHostMsg_FactoryOpen_Params params;
- params.routing_id = render_view->routing_id();
- params.response_id = pending_callbacks_.Add(callbacks.release());
- params.origin = origin;
- params.name = name;
- params.maximum_size = maximum_size;
- RenderThread::current()->Send(new IndexedDBHostMsg_FactoryOpen(params));
-}
-
-void IndexedDBDispatcher::RequestIDBFactoryDeleteDatabase(
- const string16& name,
- WebIDBCallbacks* callbacks_ptr,
- const string16& origin,
- WebFrame* web_frame) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- if (!web_frame)
- return; // We must be shutting down.
- RenderView* render_view = RenderView::FromWebView(web_frame->view());
- if (!render_view)
- return; // We must be shutting down.
-
- IndexedDBHostMsg_FactoryDeleteDatabase_Params params;
- params.routing_id = render_view->routing_id();
- params.response_id = pending_callbacks_.Add(callbacks.release());
- params.origin = origin;
- params.name = name;
- RenderThread::current()->Send(
- new IndexedDBHostMsg_FactoryDeleteDatabase(params));
-}
-
-void IndexedDBDispatcher::RequestIDBDatabaseClose(int32 idb_database_id) {
- RenderThread::current()->Send(
- new IndexedDBHostMsg_DatabaseClose(idb_database_id));
- pending_database_callbacks_.Remove(idb_database_id);
-}
-
- void IndexedDBDispatcher::RequestIDBDatabaseOpen(
- WebIDBDatabaseCallbacks* callbacks_ptr,
- int32 idb_database_id) {
- scoped_ptr<WebIDBDatabaseCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_database_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(new IndexedDBHostMsg_DatabaseOpen(response_id,
- idb_database_id));
-}
-
-void IndexedDBDispatcher::RequestIDBDatabaseSetVersion(
- const string16& version,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_database_id,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_DatabaseSetVersion(idb_database_id, response_id,
- version, ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBIndexOpenObjectCursor(
- const WebIDBKeyRange& idb_key_range,
- unsigned short direction,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_index_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
- IndexedDBHostMsg_IndexOpenCursor_Params params;
- params.response_id = pending_callbacks_.Add(callbacks.release());
- params.lower_key.Set(idb_key_range.lower());
- params.upper_key.Set(idb_key_range.upper());
- params.lower_open = idb_key_range.lowerOpen();
- params.upper_open = idb_key_range.upperOpen();
- params.direction = direction;
- params.idb_index_id = idb_index_id;
- params.transaction_id = TransactionId(transaction);
- RenderThread::current()->Send(
- new IndexedDBHostMsg_IndexOpenObjectCursor(params, ec));
- if (*ec)
- pending_callbacks_.Remove(params.response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBIndexOpenKeyCursor(
- const WebIDBKeyRange& idb_key_range,
- unsigned short direction,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_index_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
- IndexedDBHostMsg_IndexOpenCursor_Params params;
- params.response_id = pending_callbacks_.Add(callbacks.release());
- // TODO(jorlow): We really should just create a Chromium abstraction for
- // KeyRange rather than doing it ad-hoc like this.
- params.lower_key.Set(idb_key_range.lower());
- params.upper_key.Set(idb_key_range.upper());
- params.lower_open = idb_key_range.lowerOpen();
- params.upper_open = idb_key_range.upperOpen();
- params.direction = direction;
- params.idb_index_id = idb_index_id;
- params.transaction_id = TransactionId(transaction);
- RenderThread::current()->Send(
- new IndexedDBHostMsg_IndexOpenKeyCursor(params, ec));
- if (*ec)
- pending_callbacks_.Remove(params.response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBIndexGetObject(
- const IndexedDBKey& key,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_index_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_IndexGetObject(
- idb_index_id, response_id, key,
- TransactionId(transaction), ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBIndexGetKey(
- const IndexedDBKey& key,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_index_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_IndexGetKey(
- idb_index_id, response_id, key,
- TransactionId(transaction), ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBObjectStoreGet(
- const IndexedDBKey& key,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_object_store_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_ObjectStoreGet(
- idb_object_store_id, response_id,
- key, TransactionId(transaction), ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBObjectStorePut(
- const SerializedScriptValue& value,
- const IndexedDBKey& key,
- WebKit::WebIDBObjectStore::PutMode put_mode,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_object_store_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
- IndexedDBHostMsg_ObjectStorePut_Params params;
- params.idb_object_store_id = idb_object_store_id;
- params.response_id = pending_callbacks_.Add(callbacks.release());
- params.serialized_value = value;
- params.key = key;
- params.put_mode = put_mode;
- params.transaction_id = TransactionId(transaction);
- RenderThread::current()->Send(new IndexedDBHostMsg_ObjectStorePut(
- params, ec));
- if (*ec)
- pending_callbacks_.Remove(params.response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBObjectStoreDelete(
- const IndexedDBKey& key,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_object_store_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_ObjectStoreDelete(
- idb_object_store_id, response_id,
- key, TransactionId(transaction), ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBObjectStoreClear(
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_object_store_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
-
- int32 response_id = pending_callbacks_.Add(callbacks.release());
- RenderThread::current()->Send(
- new IndexedDBHostMsg_ObjectStoreClear(
- idb_object_store_id, response_id,
- TransactionId(transaction), ec));
- if (*ec)
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::RequestIDBObjectStoreOpenCursor(
- const WebIDBKeyRange& idb_key_range,
- unsigned short direction,
- WebIDBCallbacks* callbacks_ptr,
- int32 idb_object_store_id,
- const WebIDBTransaction& transaction,
- WebExceptionCode* ec) {
- scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
- IndexedDBHostMsg_ObjectStoreOpenCursor_Params params;
- params.response_id = pending_callbacks_.Add(callbacks.release());
- params.lower_key.Set(idb_key_range.lower());
- params.upper_key.Set(idb_key_range.upper());
- params.lower_open = idb_key_range.lowerOpen();
- params.upper_open = idb_key_range.upperOpen();
- params.direction = direction;
- params.idb_object_store_id = idb_object_store_id;
- params.transaction_id = TransactionId(transaction);
- RenderThread::current()->Send(
- new IndexedDBHostMsg_ObjectStoreOpenCursor(params, ec));
- if (*ec)
- pending_callbacks_.Remove(params.response_id);
-}
-
-void IndexedDBDispatcher::RegisterWebIDBTransactionCallbacks(
- WebIDBTransactionCallbacks* callbacks,
- int32 id) {
- pending_transaction_callbacks_.AddWithID(callbacks, id);
-}
-
-int32 IndexedDBDispatcher::TransactionId(
- const WebIDBTransaction& transaction) {
- const RendererWebIDBTransactionImpl* impl =
- static_cast<const RendererWebIDBTransactionImpl*>(&transaction);
- return impl->id();
-}
-
-void IndexedDBDispatcher::OnSuccessIDBDatabase(int32 response_id,
- int32 object_id) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onSuccess(new RendererWebIDBDatabaseImpl(object_id));
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::OnSuccessIndexedDBKey(int32 response_id,
- const IndexedDBKey& key) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onSuccess(key);
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::OnSuccessIDBTransaction(int32 response_id,
- int32 object_id) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onSuccess(new RendererWebIDBTransactionImpl(object_id));
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::OnSuccessIDBIndex(int32 response_id,
- int32 object_id) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onSuccess(new RendererWebIDBIndexImpl(object_id));
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::OnSuccessSerializedScriptValue(
- int32 response_id, const SerializedScriptValue& value) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onSuccess(value);
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::OnSuccessOpenCursor(int32 repsonse_id,
- int32 object_id) {
- WebIDBCallbacks* callbacks =
- pending_callbacks_.Lookup(repsonse_id);
- callbacks->onSuccess(new RendererWebIDBCursorImpl(object_id));
- pending_callbacks_.Remove(repsonse_id);
-}
-
-void IndexedDBDispatcher::OnBlocked(int32 response_id) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onBlocked();
-}
-
-void IndexedDBDispatcher::OnError(int32 response_id, int code,
- const string16& message) {
- WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
- callbacks->onError(WebIDBDatabaseError(code, message));
- pending_callbacks_.Remove(response_id);
-}
-
-void IndexedDBDispatcher::OnAbort(int32 transaction_id) {
- WebIDBTransactionCallbacks* callbacks =
- pending_transaction_callbacks_.Lookup(transaction_id);
- callbacks->onAbort();
- pending_transaction_callbacks_.Remove(transaction_id);
-}
-
-void IndexedDBDispatcher::OnComplete(int32 transaction_id) {
- WebIDBTransactionCallbacks* callbacks =
- pending_transaction_callbacks_.Lookup(transaction_id);
- callbacks->onComplete();
- pending_transaction_callbacks_.Remove(transaction_id);
-}
-
-void IndexedDBDispatcher::OnTimeout(int32 transaction_id) {
- WebIDBTransactionCallbacks* callbacks =
- pending_transaction_callbacks_.Lookup(transaction_id);
- callbacks->onTimeout();
- pending_transaction_callbacks_.Remove(transaction_id);
-}
-
-void IndexedDBDispatcher::OnVersionChange(int32 database_id,
- const string16& newVersion) {
- WebIDBDatabaseCallbacks* callbacks =
- pending_database_callbacks_.Lookup(database_id);
- // callbacks would be NULL if a versionchange event is received after close
- // has been called.
- if (callbacks)
- callbacks->onVersionChange(newVersion);
-}
« no previous file with comments | « chrome/renderer/indexed_db_dispatcher.h ('k') | chrome/renderer/notification_provider.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698