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 ccd1152d7cc4ac929bed64d8bdf0bcdb537062f4..413ce6b35d36f76af72bd1194781e940593a41ba 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) |
@@ -527,6 +531,19 @@ void IndexedDBDispatcher::OnSuccessIDBDatabase(int32 thread_id, |
pending_callbacks_.Remove(response_id); |
} |
+void IndexedDBDispatcher::OnSuccessIDBDatabaseDeleted( |
dgrogan
2012/10/17 01:21:00
Does this guy have an IPC_MESSAGE_HANDLER line?
|
+ int32 thread_id, |
+ int32 response_id, |
+ int32 database_id) { |
+ DCHECK_EQ(thread_id, CurrentWorkerId()); |
+ WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id); |
+ if (!callbacks) |
+ return; |
+ DCHECK_EQ(databases_.count(database_id), 1u); |
+ callbacks->onSuccess(); |
+ pending_callbacks_.Remove(response_id); |
+} |
+ |
void IndexedDBDispatcher::OnSuccessIndexedDBKey( |
int32 thread_id, |
int32 response_id, |
@@ -588,6 +605,27 @@ 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()); |