| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/browser/in_process_webkit/indexed_db_dispatcher_host.h" | 5 #include "content/browser/in_process_webkit/indexed_db_dispatcher_host.h" |
| 6 | 6 |
| 7 #include "base/command_line.h" | 7 #include "base/command_line.h" |
| 8 #include "base/utf_string_conversions.h" | 8 #include "base/utf_string_conversions.h" |
| 9 #include "content/browser/browser_thread.h" | 9 #include "content/browser/browser_thread.h" |
| 10 #include "content/browser/in_process_webkit/indexed_db_callbacks.h" | 10 #include "content/browser/in_process_webkit/indexed_db_callbacks.h" |
| (...skipping 840 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 851 | 851 |
| 852 IndexedDBDispatcherHost::CursorDispatcherHost::~CursorDispatcherHost() { | 852 IndexedDBDispatcherHost::CursorDispatcherHost::~CursorDispatcherHost() { |
| 853 } | 853 } |
| 854 | 854 |
| 855 bool IndexedDBDispatcherHost::CursorDispatcherHost::OnMessageReceived( | 855 bool IndexedDBDispatcherHost::CursorDispatcherHost::OnMessageReceived( |
| 856 const IPC::Message& message, bool* msg_is_ok) { | 856 const IPC::Message& message, bool* msg_is_ok) { |
| 857 bool handled = true; | 857 bool handled = true; |
| 858 IPC_BEGIN_MESSAGE_MAP_EX(IndexedDBDispatcherHost::CursorDispatcherHost, | 858 IPC_BEGIN_MESSAGE_MAP_EX(IndexedDBDispatcherHost::CursorDispatcherHost, |
| 859 message, *msg_is_ok) | 859 message, *msg_is_ok) |
| 860 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorDirection, OnDirection) | 860 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorDirection, OnDirection) |
| 861 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorKey, OnKey) | |
| 862 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorPrimaryKey, OnPrimaryKey) | |
| 863 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorValue, OnValue) | |
| 864 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorUpdate, OnUpdate) | 861 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorUpdate, OnUpdate) |
| 865 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorContinue, OnContinue) | 862 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorContinue, OnContinue) |
| 866 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorDelete, OnDelete) | 863 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorDelete, OnDelete) |
| 867 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorDestroyed, OnDestroyed) | 864 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_CursorDestroyed, OnDestroyed) |
| 868 IPC_MESSAGE_UNHANDLED(handled = false) | 865 IPC_MESSAGE_UNHANDLED(handled = false) |
| 869 IPC_END_MESSAGE_MAP() | 866 IPC_END_MESSAGE_MAP() |
| 870 return handled; | 867 return handled; |
| 871 } | 868 } |
| 872 | 869 |
| 873 | 870 |
| (...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1053 } | 1050 } |
| 1054 idb_transaction->didCompleteTaskEvents(); | 1051 idb_transaction->didCompleteTaskEvents(); |
| 1055 } | 1052 } |
| 1056 | 1053 |
| 1057 void IndexedDBDispatcherHost::TransactionDispatcherHost::OnDestroyed( | 1054 void IndexedDBDispatcherHost::TransactionDispatcherHost::OnDestroyed( |
| 1058 int32 object_id) { | 1055 int32 object_id) { |
| 1059 transaction_size_map_.erase(object_id); | 1056 transaction_size_map_.erase(object_id); |
| 1060 transaction_url_map_.erase(object_id); | 1057 transaction_url_map_.erase(object_id); |
| 1061 parent_->DestroyObject(&map_, object_id); | 1058 parent_->DestroyObject(&map_, object_id); |
| 1062 } | 1059 } |
| OLD | NEW |