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

Issues Search
    My Issues | Starred     Open | Closed | All

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

Issue 8747002: Dispatch IndexedDB IPC messages to worker threads (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: remove some includes Created 9 years 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 | « content/browser/in_process_webkit/indexed_db_dispatcher_host.h ('k') | content/browser/in_process_webkit/indexed_db_transaction_callbacks.h » ('j') | content/common/child_thread.cc » ('J')
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: content/browser/in_process_webkit/indexed_db_dispatcher_host.cc
diff --git a/content/browser/in_process_webkit/indexed_db_dispatcher_host.cc b/content/browser/in_process_webkit/indexed_db_dispatcher_host.cc
index 1fbfbedc3f0f7aaf9862cf5b6201679a81e09a0a..b04c25a78fbb88b189a455608c4502fa4be6babf 100644
--- a/content/browser/in_process_webkit/indexed_db_dispatcher_host.cc
+++ b/content/browser/in_process_webkit/indexed_db_dispatcher_host.cc
@@ -148,6 +148,7 @@ int32 IndexedDBDispatcherHost::Add(WebIDBCursor* idb_cursor) {
}
int32 IndexedDBDispatcherHost::Add(WebIDBDatabase* idb_database,
+ int32 thread_id,
const GURL& origin_url) {
if (!database_dispatcher_host_.get()) {
delete idb_database;
@@ -180,13 +181,15 @@ int32 IndexedDBDispatcherHost::Add(WebIDBObjectStore* idb_object_store) {
}
int32 IndexedDBDispatcherHost::Add(WebIDBTransaction* idb_transaction,
+ int32 thread_id,
const GURL& url) {
if (!transaction_dispatcher_host_.get()) {
delete idb_transaction;
return 0;
}
int32 id = transaction_dispatcher_host_->map_.Add(idb_transaction);
- idb_transaction->setCallbacks(new IndexedDBTransactionCallbacks(this, id));
+ idb_transaction->setCallbacks(
+ new IndexedDBTransactionCallbacks(this, thread_id, id));
transaction_dispatcher_host_->transaction_url_map_[id] = url;
return id;
}
@@ -217,8 +220,9 @@ void IndexedDBDispatcherHost::OnIDBFactoryGetDatabaseNames(
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT));
Context()->GetIDBFactory()->getDatabaseNames(
- new IndexedDBCallbacks<WebDOMStringList>(this, params.response_id),
- origin, NULL, webkit_glue::FilePathToWebString(indexed_db_path));
+ new IndexedDBCallbacks<WebDOMStringList>(this, params.thread_id,
+ params.response_id), origin, NULL,
+ webkit_glue::FilePathToWebString(indexed_db_path));
}
void IndexedDBDispatcherHost::OnIDBFactoryOpen(
@@ -245,8 +249,8 @@ void IndexedDBDispatcherHost::OnIDBFactoryOpen(
// created) if this origin is already over quota.
Context()->GetIDBFactory()->open(
params.name,
- new IndexedDBCallbacks<WebIDBDatabase>(this, params.response_id,
- origin_url),
+ new IndexedDBCallbacks<WebIDBDatabase>(this, params.thread_id,
+ params.response_id, origin_url),
origin, NULL, webkit_glue::FilePathToWebString(indexed_db_path));
}
@@ -263,6 +267,7 @@ void IndexedDBDispatcherHost::OnIDBFactoryDeleteDatabase(
Context()->GetIDBFactory()->deleteDatabase(
params.name,
new IndexedDBCallbacks<WebSerializedScriptValue>(this,
+ params.thread_id,
params.response_id),
WebSecurityOrigin::createFromDatabaseIdentifier(params.origin), NULL,
webkit_glue::FilePathToWebString(indexed_db_path));
@@ -418,6 +423,7 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnDeleteObjectStore(
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnSetVersion(
int32 idb_database_id,
+ int32 thread_id,
int32 response_id,
const string16& version,
WebKit::WebExceptionCode* ec) {
@@ -430,12 +436,13 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnSetVersion(
*ec = 0;
idb_database->setVersion(
version,
- new IndexedDBCallbacks<WebIDBTransaction>(parent_, response_id,
+ new IndexedDBCallbacks<WebIDBTransaction>(parent_, thread_id, response_id,
database_url_map_[idb_database_id]),
*ec);
}
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnTransaction(
+ int32 thread_id,
int32 idb_database_id,
const std::vector<string16>& names,
int32 mode,
@@ -457,16 +464,18 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnTransaction(
object_stores, mode, *ec);
DCHECK(!transaction != !*ec);
*idb_transaction_id =
- *ec ? 0 : parent_->Add(transaction, database_url_map_[idb_database_id]);
+ *ec ? 0 : parent_->Add(transaction, thread_id,
+ database_url_map_[idb_database_id]);
}
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnOpen(
- int32 idb_database_id, int32 response_id) {
+ int32 idb_database_id, int32 thread_id, int32 response_id) {
WebIDBDatabase* database = parent_->GetOrTerminateProcess(
&map_, idb_database_id);
if (!database)
return;
- database->open(new IndexedDBDatabaseCallbacks(parent_, response_id));
+ database->open(new IndexedDBDatabaseCallbacks(parent_, thread_id,
+ response_id));
}
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnClose(
@@ -559,7 +568,8 @@ void IndexedDBDispatcherHost::IndexDispatcherHost::OnOpenObjectCursor(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebIDBCursor>(parent_, params.response_id, -1));
+ new IndexedDBCallbacks<WebIDBCursor>(parent_, params.thread_id,
+ params.response_id, -1));
idb_index->openObjectCursor(
WebIDBKeyRange(params.lower_key, params.upper_key, params.lower_open,
params.upper_open),
@@ -579,7 +589,8 @@ void IndexedDBDispatcherHost::IndexDispatcherHost::OnOpenKeyCursor(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebIDBCursor>(parent_, params.response_id, -1));
+ new IndexedDBCallbacks<WebIDBCursor>(parent_, params.thread_id,
+ params.response_id, -1));
idb_index->openKeyCursor(
WebIDBKeyRange(params.lower_key, params.upper_key, params.lower_open,
params.upper_open),
@@ -588,6 +599,7 @@ void IndexedDBDispatcherHost::IndexDispatcherHost::OnOpenKeyCursor(
void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetObject(
int idb_index_id,
+ int32 thread_id,
int32 response_id,
const IndexedDBKey& key,
int32 transaction_id,
@@ -602,12 +614,14 @@ void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetObject(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, response_id));
+ new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
+ response_id));
idb_index->getObject(key, callbacks.release(), *idb_transaction, *ec);
}
void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetKey(
int idb_index_id,
+ int32 thread_id,
int32 response_id,
const IndexedDBKey& key,
int32 transaction_id,
@@ -622,7 +636,7 @@ void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetKey(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebIDBKey>(parent_, response_id));
+ new IndexedDBCallbacks<WebIDBKey>(parent_, thread_id, response_id));
idb_index->getKey(key, callbacks.release(), *idb_transaction, *ec);
}
@@ -699,6 +713,7 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnIndexNames(
void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnGet(
int idb_object_store_id,
+ int32 thread_id,
int32 response_id,
const IndexedDBKey& key,
int32 transaction_id,
@@ -713,7 +728,8 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnGet(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, response_id));
+ new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
+ response_id));
idb_object_store->get(key, callbacks.release(), *idb_transaction, *ec);
}
@@ -730,7 +746,8 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnPut(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebIDBKey>(parent_, params.response_id));
+ new IndexedDBCallbacks<WebIDBKey>(parent_, params.thread_id,
+ params.response_id));
idb_object_store->put(params.serialized_value, params.key, params.put_mode,
callbacks.release(), *idb_transaction, *ec);
if (*ec)
@@ -743,6 +760,7 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnPut(
void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnDelete(
int idb_object_store_id,
+ int32 thread_id,
int32 response_id,
const IndexedDBKey& key,
int32 transaction_id,
@@ -757,13 +775,15 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnDelete(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, response_id));
+ new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
+ response_id));
idb_object_store->deleteFunction(
key, callbacks.release(), *idb_transaction, *ec);
}
void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnClear(
int idb_object_store_id,
+ int32 thread_id,
int32 response_id,
int32 transaction_id,
WebKit::WebExceptionCode* ec) {
@@ -777,7 +797,8 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnClear(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, response_id));
+ new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
+ response_id));
idb_object_store->clear(callbacks.release(), *idb_transaction, *ec);
}
@@ -851,7 +872,8 @@ void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnOpenCursor(
*ec = 0;
scoped_ptr<WebIDBCallbacks> callbacks(
- new IndexedDBCallbacks<WebIDBCursor>(parent_, params.response_id, -1));
+ new IndexedDBCallbacks<WebIDBCursor>(parent_, params.thread_id,
+ params.response_id, -1));
idb_object_store->openCursor(
WebIDBKeyRange(params.lower_key, params.upper_key, params.lower_open,
params.upper_open),
@@ -938,6 +960,7 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnValue(
void IndexedDBDispatcherHost::CursorDispatcherHost::OnUpdate(
int32 cursor_id,
+ int32 thread_id,
int32 response_id,
const content::SerializedScriptValue& value,
WebKit::WebExceptionCode* ec) {
@@ -948,11 +971,13 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnUpdate(
*ec = 0;
idb_cursor->update(
- value, new IndexedDBCallbacks<WebIDBKey>(parent_, response_id), *ec);
+ value, new IndexedDBCallbacks<WebIDBKey>(parent_, thread_id, response_id),
+ *ec);
}
void IndexedDBDispatcherHost::CursorDispatcherHost::OnContinue(
int32 cursor_id,
+ int32 thread_id,
int32 response_id,
const IndexedDBKey& key,
WebKit::WebExceptionCode* ec) {
@@ -963,12 +988,13 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnContinue(
*ec = 0;
idb_cursor->continueFunction(
- key, new IndexedDBCallbacks<WebIDBCursor>(parent_, response_id,
+ key, new IndexedDBCallbacks<WebIDBCursor>(parent_, thread_id, response_id,
cursor_id), *ec);
}
void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetch(
int32 cursor_id,
+ int32 thread_id,
int32 response_id,
int n,
WebKit::WebExceptionCode* ec) {
@@ -979,7 +1005,7 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetch(
*ec = 0;
idb_cursor->prefetchContinue(
- n, new IndexedDBCallbacks<WebIDBCursor>(parent_, response_id,
+ n, new IndexedDBCallbacks<WebIDBCursor>(parent_, thread_id, response_id,
cursor_id), *ec);
}
@@ -995,6 +1021,7 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetchReset(
void IndexedDBDispatcherHost::CursorDispatcherHost::OnDelete(
int32 cursor_id,
+ int32 thread_id,
int32 response_id,
WebKit::WebExceptionCode* ec) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT));
@@ -1004,7 +1031,8 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnDelete(
*ec = 0;
idb_cursor->deleteFunction(
- new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, response_id), *ec);
+ new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
+ response_id), *ec);
}
void IndexedDBDispatcherHost::CursorDispatcherHost::OnDestroyed(
« no previous file with comments | « content/browser/in_process_webkit/indexed_db_dispatcher_host.h ('k') | content/browser/in_process_webkit/indexed_db_transaction_callbacks.h » ('j') | content/common/child_thread.cc » ('J')

Powered by Google App Engine
This is Rietveld 408576698