| Index: content/renderer/indexed_db_dispatcher.cc
|
| ===================================================================
|
| --- content/renderer/indexed_db_dispatcher.cc (revision 104358)
|
| +++ content/renderer/indexed_db_dispatcher.cc (working copy)
|
| @@ -5,7 +5,7 @@
|
| #include "content/renderer/indexed_db_dispatcher.h"
|
|
|
| #include "content/common/indexed_db_messages.h"
|
| -#include "content/renderer/render_thread.h"
|
| +#include "content/renderer/render_thread_impl.h"
|
| #include "content/renderer/render_view.h"
|
| #include "content/renderer/renderer_webidbcursor_impl.h"
|
| #include "content/renderer/renderer_webidbdatabase_impl.h"
|
| @@ -71,7 +71,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_CursorUpdate(idb_cursor_id, response_id, value, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(response_id);
|
| @@ -85,7 +85,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_CursorContinue(idb_cursor_id, response_id, key, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(response_id);
|
| @@ -98,7 +98,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_CursorDelete(idb_cursor_id, response_id, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(response_id);
|
| @@ -122,7 +122,7 @@
|
| params.response_id = pending_callbacks_.Add(callbacks.release());
|
| params.origin = origin;
|
| params.name = name;
|
| - RenderThread::current()->Send(new IndexedDBHostMsg_FactoryOpen(params));
|
| + RenderThreadImpl::current()->Send(new IndexedDBHostMsg_FactoryOpen(params));
|
| }
|
|
|
| void IndexedDBDispatcher::RequestIDBFactoryGetDatabaseNames(
|
| @@ -141,7 +141,7 @@
|
| params.routing_id = render_view->routing_id();
|
| params.response_id = pending_callbacks_.Add(callbacks.release());
|
| params.origin = origin;
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_FactoryGetDatabaseNames(params));
|
| }
|
|
|
| @@ -163,12 +163,12 @@
|
| params.response_id = pending_callbacks_.Add(callbacks.release());
|
| params.origin = origin;
|
| params.name = name;
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_FactoryDeleteDatabase(params));
|
| }
|
|
|
| void IndexedDBDispatcher::RequestIDBDatabaseClose(int32 idb_database_id) {
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_DatabaseClose(idb_database_id));
|
| pending_database_callbacks_.Remove(idb_database_id);
|
| }
|
| @@ -179,8 +179,8 @@
|
| 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));
|
| + RenderThreadImpl::current()->Send(new IndexedDBHostMsg_DatabaseOpen(
|
| + response_id, idb_database_id));
|
| }
|
|
|
| void IndexedDBDispatcher::RequestIDBDatabaseSetVersion(
|
| @@ -191,7 +191,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_DatabaseSetVersion(idb_database_id, response_id,
|
| version, ec));
|
| if (*ec)
|
| @@ -215,7 +215,7 @@
|
| params.direction = direction;
|
| params.idb_index_id = idb_index_id;
|
| params.transaction_id = TransactionId(transaction);
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_IndexOpenObjectCursor(params, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(params.response_id);
|
| @@ -240,7 +240,7 @@
|
| params.direction = direction;
|
| params.idb_index_id = idb_index_id;
|
| params.transaction_id = TransactionId(transaction);
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_IndexOpenKeyCursor(params, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(params.response_id);
|
| @@ -254,7 +254,7 @@
|
| WebExceptionCode* ec) {
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_IndexGetObject(
|
| idb_index_id, response_id, key,
|
| TransactionId(transaction), ec));
|
| @@ -270,7 +270,7 @@
|
| WebExceptionCode* ec) {
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_IndexGetKey(
|
| idb_index_id, response_id, key,
|
| TransactionId(transaction), ec));
|
| @@ -287,7 +287,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_ObjectStoreGet(
|
| idb_object_store_id, response_id,
|
| key, TransactionId(transaction), ec));
|
| @@ -311,7 +311,7 @@
|
| params.key = key;
|
| params.put_mode = put_mode;
|
| params.transaction_id = TransactionId(transaction);
|
| - RenderThread::current()->Send(new IndexedDBHostMsg_ObjectStorePut(
|
| + RenderThreadImpl::current()->Send(new IndexedDBHostMsg_ObjectStorePut(
|
| params, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(params.response_id);
|
| @@ -326,7 +326,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_ObjectStoreDelete(
|
| idb_object_store_id, response_id,
|
| key, TransactionId(transaction), ec));
|
| @@ -342,7 +342,7 @@
|
| scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
|
|
|
| int32 response_id = pending_callbacks_.Add(callbacks.release());
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_ObjectStoreClear(
|
| idb_object_store_id, response_id,
|
| TransactionId(transaction), ec));
|
| @@ -367,7 +367,7 @@
|
| params.direction = direction;
|
| params.idb_object_store_id = idb_object_store_id;
|
| params.transaction_id = TransactionId(transaction);
|
| - RenderThread::current()->Send(
|
| + RenderThreadImpl::current()->Send(
|
| new IndexedDBHostMsg_ObjectStoreOpenCursor(params, ec));
|
| if (*ec)
|
| pending_callbacks_.Remove(params.response_id);
|
|
|