OLD | NEW |
1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/renderer/indexed_db_dispatcher.h" | 5 #include "content/renderer/indexed_db_dispatcher.h" |
6 | 6 |
7 #include "content/common/indexed_db_messages.h" | 7 #include "content/common/indexed_db_messages.h" |
8 #include "content/renderer/render_thread.h" | 8 #include "content/renderer/render_thread.h" |
9 #include "content/renderer/render_view.h" | 9 #include "content/renderer/render_view.h" |
10 #include "content/renderer/renderer_webidbcursor_impl.h" | 10 #include "content/renderer/renderer_webidbcursor_impl.h" |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
48 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIndexedDBKey, | 48 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIndexedDBKey, |
49 OnSuccessIndexedDBKey) | 49 OnSuccessIndexedDBKey) |
50 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBTransaction, | 50 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBTransaction, |
51 OnSuccessIDBTransaction) | 51 OnSuccessIDBTransaction) |
52 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValue, | 52 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessSerializedScriptValue, |
53 OnSuccessSerializedScriptValue) | 53 OnSuccessSerializedScriptValue) |
54 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksError, OnError) | 54 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksError, OnError) |
55 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksBlocked, OnBlocked) | 55 IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksBlocked, OnBlocked) |
56 IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksAbort, OnAbort) | 56 IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksAbort, OnAbort) |
57 IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksComplete, OnComplete) | 57 IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksComplete, OnComplete) |
58 IPC_MESSAGE_HANDLER(IndexedDBMsg_TransactionCallbacksTimeout, OnTimeout) | |
59 IPC_MESSAGE_HANDLER(IndexedDBMsg_DatabaseCallbacksVersionChange, | 58 IPC_MESSAGE_HANDLER(IndexedDBMsg_DatabaseCallbacksVersionChange, |
60 OnVersionChange) | 59 OnVersionChange) |
61 IPC_MESSAGE_UNHANDLED(handled = false) | 60 IPC_MESSAGE_UNHANDLED(handled = false) |
62 IPC_END_MESSAGE_MAP() | 61 IPC_END_MESSAGE_MAP() |
63 return handled; | 62 return handled; |
64 } | 63 } |
65 | 64 |
66 void IndexedDBDispatcher::RequestIDBCursorUpdate( | 65 void IndexedDBDispatcher::RequestIDBCursorUpdate( |
67 const SerializedScriptValue& value, | 66 const SerializedScriptValue& value, |
68 WebIDBCallbacks* callbacks_ptr, | 67 WebIDBCallbacks* callbacks_ptr, |
(...skipping 361 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
430 pending_transaction_callbacks_.Remove(transaction_id); | 429 pending_transaction_callbacks_.Remove(transaction_id); |
431 } | 430 } |
432 | 431 |
433 void IndexedDBDispatcher::OnComplete(int32 transaction_id) { | 432 void IndexedDBDispatcher::OnComplete(int32 transaction_id) { |
434 WebIDBTransactionCallbacks* callbacks = | 433 WebIDBTransactionCallbacks* callbacks = |
435 pending_transaction_callbacks_.Lookup(transaction_id); | 434 pending_transaction_callbacks_.Lookup(transaction_id); |
436 callbacks->onComplete(); | 435 callbacks->onComplete(); |
437 pending_transaction_callbacks_.Remove(transaction_id); | 436 pending_transaction_callbacks_.Remove(transaction_id); |
438 } | 437 } |
439 | 438 |
440 void IndexedDBDispatcher::OnTimeout(int32 transaction_id) { | |
441 WebIDBTransactionCallbacks* callbacks = | |
442 pending_transaction_callbacks_.Lookup(transaction_id); | |
443 callbacks->onTimeout(); | |
444 pending_transaction_callbacks_.Remove(transaction_id); | |
445 } | |
446 | |
447 void IndexedDBDispatcher::OnVersionChange(int32 database_id, | 439 void IndexedDBDispatcher::OnVersionChange(int32 database_id, |
448 const string16& newVersion) { | 440 const string16& newVersion) { |
449 WebIDBDatabaseCallbacks* callbacks = | 441 WebIDBDatabaseCallbacks* callbacks = |
450 pending_database_callbacks_.Lookup(database_id); | 442 pending_database_callbacks_.Lookup(database_id); |
451 // callbacks would be NULL if a versionchange event is received after close | 443 // callbacks would be NULL if a versionchange event is received after close |
452 // has been called. | 444 // has been called. |
453 if (callbacks) | 445 if (callbacks) |
454 callbacks->onVersionChange(newVersion); | 446 callbacks->onVersionChange(newVersion); |
455 } | 447 } |
OLD | NEW |