Index: content/common/indexed_db/indexed_db_dispatcher.cc |
diff --git a/content/common/indexed_db/indexed_db_dispatcher.cc b/content/common/indexed_db/indexed_db_dispatcher.cc |
index 64284d1364b5dc5a8be8160bda15e94b37dcba61..ae1e157929a53ecd34fd4038ec7a709193b88b74 100644 |
--- a/content/common/indexed_db/indexed_db_dispatcher.cc |
+++ b/content/common/indexed_db/indexed_db_dispatcher.cc |
@@ -101,6 +101,10 @@ void IndexedDBDispatcher::OnMessageReceived(const IPC::Message& msg) { |
OnSuccessSerializedScriptValue) |
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValueWithKey, |
OnSuccessSerializedScriptValueWithKey) |
+ IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessInteger, |
+ OnSuccessInteger) |
+ IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessUndefined, |
+ OnSuccessUndefined) |
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksError, OnError) |
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksBlocked, OnBlocked) |
IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksIntBlocked, OnIntBlocked) |
@@ -586,6 +590,26 @@ void IndexedDBDispatcher::OnSuccessSerializedScriptValueWithKey( |
pending_callbacks_.Remove(response_id); |
} |
+void IndexedDBDispatcher::OnSuccessInteger( |
+ int32 thread_id, int32 response_id, int64 value) { |
+ DCHECK_EQ(thread_id, CurrentWorkerId()); |
+ WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id); |
+ if (!callbacks) |
+ return; |
+ callbacks->onSuccess(value); |
+ pending_callbacks_.Remove(response_id); |
+} |
+ |
+void IndexedDBDispatcher::OnSuccessUndefined( |
+ int32 thread_id, int32 response_id) { |
+ DCHECK_EQ(thread_id, CurrentWorkerId()); |
+ WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id); |
+ if (!callbacks) |
+ return; |
+ callbacks->onSuccess(); |
+ pending_callbacks_.Remove(response_id); |
+} |
+ |
void IndexedDBDispatcher::OnSuccessOpenCursor( |
const IndexedDBMsg_CallbacksSuccessIDBCursor_Params& p) { |
DCHECK_EQ(p.thread_id, CurrentWorkerId()); |