Plumb through the rest of OnSuccessWithKey

BUG=129471
TEST=


Review URL: https://chromiumcodereview.appspot.com/10834039

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@148653 0039d316-1c4b-4281-b951-d872f2087c98
parent 36df8e31
...@@ -22,6 +22,7 @@ ...@@ -22,6 +22,7 @@
using base::ThreadLocalPointer; using base::ThreadLocalPointer;
using content::IndexedDBKey; using content::IndexedDBKey;
using content::IndexedDBKeyPath;
using content::IndexedDBKeyRange; using content::IndexedDBKeyRange;
using content::SerializedScriptValue; using content::SerializedScriptValue;
using WebKit::WebDOMStringList; using WebKit::WebDOMStringList;
...@@ -99,6 +100,8 @@ void IndexedDBDispatcher::OnMessageReceived(const IPC::Message& msg) { ...@@ -99,6 +100,8 @@ void IndexedDBDispatcher::OnMessageReceived(const IPC::Message& msg) {
OnSuccessStringList) OnSuccessStringList)
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValue, IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValue,
OnSuccessSerializedScriptValue) OnSuccessSerializedScriptValue)
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValueWithKey,
OnSuccessSerializedScriptValueWithKey)
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksError, OnError) IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksError, OnError)
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksBlocked, OnBlocked) IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksBlocked, OnBlocked)
IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksAbort, OnAbort) IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksAbort, OnAbort)
...@@ -605,6 +608,19 @@ void IndexedDBDispatcher::OnSuccessSerializedScriptValue( ...@@ -605,6 +608,19 @@ void IndexedDBDispatcher::OnSuccessSerializedScriptValue(
pending_callbacks_.Remove(response_id); pending_callbacks_.Remove(response_id);
} }
void IndexedDBDispatcher::OnSuccessSerializedScriptValueWithKey(
int32 thread_id, int32 response_id,
const SerializedScriptValue& value,
const IndexedDBKey& primary_key,
const IndexedDBKeyPath& key_path) {
DCHECK_EQ(thread_id, CurrentWorkerId());
WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
if (!callbacks)
return;
callbacks->onSuccess(value, primary_key, key_path);
pending_callbacks_.Remove(response_id);
}
void IndexedDBDispatcher::OnSuccessOpenCursor( void IndexedDBDispatcher::OnSuccessOpenCursor(
const IndexedDBMsg_CallbacksSuccessIDBCursor_Params& p) { const IndexedDBMsg_CallbacksSuccessIDBCursor_Params& p) {
DCHECK_EQ(p.thread_id, CurrentWorkerId()); DCHECK_EQ(p.thread_id, CurrentWorkerId());
......
...@@ -37,6 +37,7 @@ class WebIDBTransaction; ...@@ -37,6 +37,7 @@ class WebIDBTransaction;
namespace content { namespace content {
class IndexedDBKey; class IndexedDBKey;
class IndexedDBKeyPath;
class IndexedDBKeyRange; class IndexedDBKeyRange;
class SerializedScriptValue; class SerializedScriptValue;
} }
...@@ -242,6 +243,12 @@ class CONTENT_EXPORT IndexedDBDispatcher ...@@ -242,6 +243,12 @@ class CONTENT_EXPORT IndexedDBDispatcher
int32 thread_id, int32 thread_id,
int32 response_id, int32 response_id,
const content::SerializedScriptValue& value); const content::SerializedScriptValue& value);
void OnSuccessSerializedScriptValueWithKey(
int32 thread_id,
int32 response_id,
const content::SerializedScriptValue& value,
const content::IndexedDBKey& primary_key,
const content::IndexedDBKeyPath& key_path);
void OnError(int32 thread_id, void OnError(int32 thread_id,
int32 response_id, int32 response_id,
int code, int code,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment