OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ | 5 #ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ |
6 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ | 6 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ |
7 | 7 |
| 8 #include <stdint.h> |
| 9 |
8 #include <map> | 10 #include <map> |
9 #include <string> | 11 #include <string> |
10 #include <utility> | 12 #include <utility> |
11 #include <vector> | 13 #include <vector> |
12 | 14 |
13 #include "base/basictypes.h" | |
14 #include "base/id_map.h" | 15 #include "base/id_map.h" |
| 16 #include "base/macros.h" |
15 #include "base/memory/ref_counted.h" | 17 #include "base/memory/ref_counted.h" |
16 #include "content/browser/fileapi/chrome_blob_storage_context.h" | 18 #include "content/browser/fileapi/chrome_blob_storage_context.h" |
17 #include "content/public/browser/browser_message_filter.h" | 19 #include "content/public/browser/browser_message_filter.h" |
18 #include "net/url_request/url_request_context_getter.h" | 20 #include "net/url_request/url_request_context_getter.h" |
19 #include "storage/browser/blob/blob_data_handle.h" | 21 #include "storage/browser/blob/blob_data_handle.h" |
20 #include "url/gurl.h" | 22 #include "url/gurl.h" |
21 | 23 |
22 struct IndexedDBDatabaseMetadata; | 24 struct IndexedDBDatabaseMetadata; |
23 struct IndexedDBHostMsg_DatabaseCount_Params; | 25 struct IndexedDBHostMsg_DatabaseCount_Params; |
24 struct IndexedDBHostMsg_DatabaseCreateIndex_Params; | 26 struct IndexedDBHostMsg_DatabaseCreateIndex_Params; |
(...skipping 29 matching lines...) Expand all Loading... |
54 ChromeBlobStorageContext* blob_storage_context); | 56 ChromeBlobStorageContext* blob_storage_context); |
55 IndexedDBDispatcherHost(int ipc_process_id, | 57 IndexedDBDispatcherHost(int ipc_process_id, |
56 net::URLRequestContext* request_context, | 58 net::URLRequestContext* request_context, |
57 IndexedDBContextImpl* indexed_db_context, | 59 IndexedDBContextImpl* indexed_db_context, |
58 ChromeBlobStorageContext* blob_storage_context); | 60 ChromeBlobStorageContext* blob_storage_context); |
59 | 61 |
60 static ::IndexedDBDatabaseMetadata ConvertMetadata( | 62 static ::IndexedDBDatabaseMetadata ConvertMetadata( |
61 const content::IndexedDBDatabaseMetadata& metadata); | 63 const content::IndexedDBDatabaseMetadata& metadata); |
62 | 64 |
63 // BrowserMessageFilter implementation. | 65 // BrowserMessageFilter implementation. |
64 void OnChannelConnected(int32 peer_pid) override; | 66 void OnChannelConnected(int32_t peer_pid) override; |
65 void OnChannelClosing() override; | 67 void OnChannelClosing() override; |
66 void OnDestruct() const override; | 68 void OnDestruct() const override; |
67 base::TaskRunner* OverrideTaskRunnerForMessage( | 69 base::TaskRunner* OverrideTaskRunnerForMessage( |
68 const IPC::Message& message) override; | 70 const IPC::Message& message) override; |
69 bool OnMessageReceived(const IPC::Message& message) override; | 71 bool OnMessageReceived(const IPC::Message& message) override; |
70 | 72 |
71 void FinishTransaction(int64 host_transaction_id, bool committed); | 73 void FinishTransaction(int64_t host_transaction_id, bool committed); |
72 | 74 |
73 // A shortcut for accessing our context. | 75 // A shortcut for accessing our context. |
74 IndexedDBContextImpl* Context() { return indexed_db_context_.get(); } | 76 IndexedDBContextImpl* Context() { return indexed_db_context_.get(); } |
75 storage::BlobStorageContext* blob_storage_context() const { | 77 storage::BlobStorageContext* blob_storage_context() const { |
76 return blob_storage_context_->context(); | 78 return blob_storage_context_->context(); |
77 } | 79 } |
78 | 80 |
79 // IndexedDBCallbacks call these methods to add the results into the | 81 // IndexedDBCallbacks call these methods to add the results into the |
80 // applicable map. See below for more details. | 82 // applicable map. See below for more details. |
81 int32 Add(IndexedDBCursor* cursor); | 83 int32_t Add(IndexedDBCursor* cursor); |
82 int32 Add(IndexedDBConnection* connection, | 84 int32_t Add(IndexedDBConnection* connection, |
83 int32 ipc_thread_id, | 85 int32_t ipc_thread_id, |
84 const GURL& origin_url); | 86 const GURL& origin_url); |
85 | 87 |
86 void RegisterTransactionId(int64 host_transaction_id, const GURL& origin_url); | 88 void RegisterTransactionId(int64_t host_transaction_id, |
| 89 const GURL& origin_url); |
87 | 90 |
88 IndexedDBCursor* GetCursorFromId(int32 ipc_cursor_id); | 91 IndexedDBCursor* GetCursorFromId(int32_t ipc_cursor_id); |
89 | 92 |
90 // These are called to map a 32-bit front-end (renderer-specific) transaction | 93 // These are called to map a 32-bit front-end (renderer-specific) transaction |
91 // id to and from a back-end ("host") transaction id that encodes the process | 94 // id to and from a back-end ("host") transaction id that encodes the process |
92 // id in the high 32 bits. The mapping is host-specific and ids are validated. | 95 // id in the high 32 bits. The mapping is host-specific and ids are validated. |
93 int64 HostTransactionId(int64 transaction_id); | 96 int64_t HostTransactionId(int64_t transaction_id); |
94 int64 RendererTransactionId(int64 host_transaction_id); | 97 int64_t RendererTransactionId(int64_t host_transaction_id); |
95 | 98 |
96 // These are called to decode a host transaction ID, for diagnostic purposes. | 99 // These are called to decode a host transaction ID, for diagnostic purposes. |
97 static uint32 TransactionIdToRendererTransactionId(int64 host_transaction_id); | 100 static uint32_t TransactionIdToRendererTransactionId( |
98 static uint32 TransactionIdToProcessId(int64 host_transaction_id); | 101 int64_t host_transaction_id); |
| 102 static uint32_t TransactionIdToProcessId(int64_t host_transaction_id); |
99 | 103 |
100 std::string HoldBlobData(const IndexedDBBlobInfo& blob_info); | 104 std::string HoldBlobData(const IndexedDBBlobInfo& blob_info); |
101 | 105 |
102 private: | 106 private: |
103 // Friends to enable OnDestruct() delegation. | 107 // Friends to enable OnDestruct() delegation. |
104 friend class BrowserThread; | 108 friend class BrowserThread; |
105 friend class base::DeleteHelper<IndexedDBDispatcherHost>; | 109 friend class base::DeleteHelper<IndexedDBDispatcherHost>; |
106 | 110 |
107 // Used in nested classes. | 111 // Used in nested classes. |
108 typedef std::map<std::string, std::pair<storage::BlobDataHandle*, int>> | 112 typedef std::map<std::string, std::pair<storage::BlobDataHandle*, int>> |
109 BlobDataHandleMap; | 113 BlobDataHandleMap; |
110 typedef std::map<int64, int64> TransactionIDToDatabaseIDMap; | 114 typedef std::map<int64_t, int64_t> TransactionIDToDatabaseIDMap; |
111 typedef std::map<int64, uint64> TransactionIDToSizeMap; | 115 typedef std::map<int64_t, uint64_t> TransactionIDToSizeMap; |
112 typedef std::map<int64, GURL> TransactionIDToURLMap; | 116 typedef std::map<int64_t, GURL> TransactionIDToURLMap; |
113 typedef std::map<int32, GURL> WebIDBObjectIDToURLMap; | 117 typedef std::map<int32_t, GURL> WebIDBObjectIDToURLMap; |
114 | 118 |
115 // IDMap for RefCounted types | 119 // IDMap for RefCounted types |
116 template <typename RefCountedType> | 120 template <typename RefCountedType> |
117 class RefIDMap { | 121 class RefIDMap { |
118 public: | 122 public: |
119 typedef int32 KeyType; | 123 typedef int32_t KeyType; |
120 | 124 |
121 RefIDMap() {} | 125 RefIDMap() {} |
122 ~RefIDMap() {} | 126 ~RefIDMap() {} |
123 | 127 |
124 KeyType Add(RefCountedType* data) { | 128 KeyType Add(RefCountedType* data) { |
125 return map_.Add(new scoped_refptr<RefCountedType>(data)); | 129 return map_.Add(new scoped_refptr<RefCountedType>(data)); |
126 } | 130 } |
127 | 131 |
128 RefCountedType* Lookup(KeyType id) { | 132 RefCountedType* Lookup(KeyType id) { |
129 scoped_refptr<RefCountedType>* ptr = map_.Lookup(id); | 133 scoped_refptr<RefCountedType>* ptr = map_.Lookup(id); |
(...skipping 17 matching lines...) Expand all Loading... |
147 class DatabaseDispatcherHost { | 151 class DatabaseDispatcherHost { |
148 public: | 152 public: |
149 explicit DatabaseDispatcherHost(IndexedDBDispatcherHost* parent); | 153 explicit DatabaseDispatcherHost(IndexedDBDispatcherHost* parent); |
150 ~DatabaseDispatcherHost(); | 154 ~DatabaseDispatcherHost(); |
151 | 155 |
152 void CloseAll(); | 156 void CloseAll(); |
153 bool OnMessageReceived(const IPC::Message& message); | 157 bool OnMessageReceived(const IPC::Message& message); |
154 | 158 |
155 void OnCreateObjectStore( | 159 void OnCreateObjectStore( |
156 const IndexedDBHostMsg_DatabaseCreateObjectStore_Params& params); | 160 const IndexedDBHostMsg_DatabaseCreateObjectStore_Params& params); |
157 void OnDeleteObjectStore(int32 ipc_database_id, | 161 void OnDeleteObjectStore(int32_t ipc_database_id, |
158 int64 transaction_id, | 162 int64_t transaction_id, |
159 int64 object_store_id); | 163 int64_t object_store_id); |
160 void OnCreateTransaction( | 164 void OnCreateTransaction( |
161 const IndexedDBHostMsg_DatabaseCreateTransaction_Params&); | 165 const IndexedDBHostMsg_DatabaseCreateTransaction_Params&); |
162 void OnClose(int32 ipc_database_id); | 166 void OnClose(int32_t ipc_database_id); |
163 void OnVersionChangeIgnored(int32 ipc_database_id); | 167 void OnVersionChangeIgnored(int32_t ipc_database_id); |
164 void OnDestroyed(int32 ipc_database_id); | 168 void OnDestroyed(int32_t ipc_database_id); |
165 | 169 |
166 void OnGet(const IndexedDBHostMsg_DatabaseGet_Params& params); | 170 void OnGet(const IndexedDBHostMsg_DatabaseGet_Params& params); |
167 void OnGetAll(const IndexedDBHostMsg_DatabaseGetAll_Params& params); | 171 void OnGetAll(const IndexedDBHostMsg_DatabaseGetAll_Params& params); |
168 // OnPutWrapper starts on the IO thread so that it can grab BlobDataHandles | 172 // OnPutWrapper starts on the IO thread so that it can grab BlobDataHandles |
169 // before posting to the IDB TaskRunner for the rest of the job. | 173 // before posting to the IDB TaskRunner for the rest of the job. |
170 void OnPutWrapper(const IndexedDBHostMsg_DatabasePut_Params& params); | 174 void OnPutWrapper(const IndexedDBHostMsg_DatabasePut_Params& params); |
171 void OnPut(const IndexedDBHostMsg_DatabasePut_Params& params, | 175 void OnPut(const IndexedDBHostMsg_DatabasePut_Params& params, |
172 std::vector<storage::BlobDataHandle*> handles); | 176 std::vector<storage::BlobDataHandle*> handles); |
173 void OnSetIndexKeys( | 177 void OnSetIndexKeys( |
174 const IndexedDBHostMsg_DatabaseSetIndexKeys_Params& params); | 178 const IndexedDBHostMsg_DatabaseSetIndexKeys_Params& params); |
175 void OnSetIndexesReady(int32 ipc_database_id, | 179 void OnSetIndexesReady(int32_t ipc_database_id, |
176 int64 transaction_id, | 180 int64_t transaction_id, |
177 int64 object_store_id, | 181 int64_t object_store_id, |
178 const std::vector<int64>& ids); | 182 const std::vector<int64_t>& ids); |
179 void OnOpenCursor(const IndexedDBHostMsg_DatabaseOpenCursor_Params& params); | 183 void OnOpenCursor(const IndexedDBHostMsg_DatabaseOpenCursor_Params& params); |
180 void OnCount(const IndexedDBHostMsg_DatabaseCount_Params& params); | 184 void OnCount(const IndexedDBHostMsg_DatabaseCount_Params& params); |
181 void OnDeleteRange( | 185 void OnDeleteRange( |
182 const IndexedDBHostMsg_DatabaseDeleteRange_Params& params); | 186 const IndexedDBHostMsg_DatabaseDeleteRange_Params& params); |
183 void OnClear(int32 ipc_thread_id, | 187 void OnClear(int32_t ipc_thread_id, |
184 int32 ipc_callbacks_id, | 188 int32_t ipc_callbacks_id, |
185 int32 ipc_database_id, | 189 int32_t ipc_database_id, |
186 int64 transaction_id, | 190 int64_t transaction_id, |
187 int64 object_store_id); | 191 int64_t object_store_id); |
188 void OnCreateIndex( | 192 void OnCreateIndex( |
189 const IndexedDBHostMsg_DatabaseCreateIndex_Params& params); | 193 const IndexedDBHostMsg_DatabaseCreateIndex_Params& params); |
190 void OnDeleteIndex(int32 ipc_database_id, | 194 void OnDeleteIndex(int32_t ipc_database_id, |
191 int64 transaction_id, | 195 int64_t transaction_id, |
192 int64 object_store_id, | 196 int64_t object_store_id, |
193 int64 index_id); | 197 int64_t index_id); |
194 | 198 |
195 void OnAbort(int32 ipc_database_id, int64 transaction_id); | 199 void OnAbort(int32_t ipc_database_id, int64_t transaction_id); |
196 void OnCommit(int32 ipc_database_id, int64 transaction_id); | 200 void OnCommit(int32_t ipc_database_id, int64_t transaction_id); |
197 IndexedDBDispatcherHost* parent_; | 201 IndexedDBDispatcherHost* parent_; |
198 IDMap<IndexedDBConnection, IDMapOwnPointer> map_; | 202 IDMap<IndexedDBConnection, IDMapOwnPointer> map_; |
199 WebIDBObjectIDToURLMap database_url_map_; | 203 WebIDBObjectIDToURLMap database_url_map_; |
200 TransactionIDToSizeMap transaction_size_map_; | 204 TransactionIDToSizeMap transaction_size_map_; |
201 TransactionIDToURLMap transaction_url_map_; | 205 TransactionIDToURLMap transaction_url_map_; |
202 TransactionIDToDatabaseIDMap transaction_database_map_; | 206 TransactionIDToDatabaseIDMap transaction_database_map_; |
203 | 207 |
204 private: | 208 private: |
205 DISALLOW_COPY_AND_ASSIGN(DatabaseDispatcherHost); | 209 DISALLOW_COPY_AND_ASSIGN(DatabaseDispatcherHost); |
206 }; | 210 }; |
207 | 211 |
208 class CursorDispatcherHost { | 212 class CursorDispatcherHost { |
209 public: | 213 public: |
210 explicit CursorDispatcherHost(IndexedDBDispatcherHost* parent); | 214 explicit CursorDispatcherHost(IndexedDBDispatcherHost* parent); |
211 ~CursorDispatcherHost(); | 215 ~CursorDispatcherHost(); |
212 | 216 |
213 bool OnMessageReceived(const IPC::Message& message); | 217 bool OnMessageReceived(const IPC::Message& message); |
214 | 218 |
215 void OnAdvance(int32 ipc_object_store_id, | 219 void OnAdvance(int32_t ipc_object_store_id, |
216 int32 ipc_thread_id, | 220 int32_t ipc_thread_id, |
217 int32 ipc_callbacks_id, | 221 int32_t ipc_callbacks_id, |
218 uint32 count); | 222 uint32_t count); |
219 void OnContinue(int32 ipc_object_store_id, | 223 void OnContinue(int32_t ipc_object_store_id, |
220 int32 ipc_thread_id, | 224 int32_t ipc_thread_id, |
221 int32 ipc_callbacks_id, | 225 int32_t ipc_callbacks_id, |
222 const IndexedDBKey& key, | 226 const IndexedDBKey& key, |
223 const IndexedDBKey& primary_key); | 227 const IndexedDBKey& primary_key); |
224 void OnPrefetch(int32 ipc_cursor_id, | 228 void OnPrefetch(int32_t ipc_cursor_id, |
225 int32 ipc_thread_id, | 229 int32_t ipc_thread_id, |
226 int32 ipc_callbacks_id, | 230 int32_t ipc_callbacks_id, |
227 int n); | 231 int n); |
228 void OnPrefetchReset(int32 ipc_cursor_id, | 232 void OnPrefetchReset(int32_t ipc_cursor_id, |
229 int used_prefetches, | 233 int used_prefetches, |
230 int unused_prefetches); | 234 int unused_prefetches); |
231 void OnDestroyed(int32 ipc_cursor_id); | 235 void OnDestroyed(int32_t ipc_cursor_id); |
232 | 236 |
233 IndexedDBDispatcherHost* parent_; | 237 IndexedDBDispatcherHost* parent_; |
234 RefIDMap<IndexedDBCursor> map_; | 238 RefIDMap<IndexedDBCursor> map_; |
235 | 239 |
236 private: | 240 private: |
237 DISALLOW_COPY_AND_ASSIGN(CursorDispatcherHost); | 241 DISALLOW_COPY_AND_ASSIGN(CursorDispatcherHost); |
238 }; | 242 }; |
239 | 243 |
240 ~IndexedDBDispatcherHost() override; | 244 ~IndexedDBDispatcherHost() override; |
241 | 245 |
242 // Helper templates. | 246 // Helper templates. |
243 template <class ReturnType> | 247 template <class ReturnType> |
244 ReturnType* GetOrTerminateProcess(IDMap<ReturnType, IDMapOwnPointer>* map, | 248 ReturnType* GetOrTerminateProcess(IDMap<ReturnType, IDMapOwnPointer>* map, |
245 int32 ipc_return_object_id); | 249 int32_t ipc_return_object_id); |
246 template <class ReturnType> | 250 template <class ReturnType> |
247 ReturnType* GetOrTerminateProcess(RefIDMap<ReturnType>* map, | 251 ReturnType* GetOrTerminateProcess(RefIDMap<ReturnType>* map, |
248 int32 ipc_return_object_id); | 252 int32_t ipc_return_object_id); |
249 | 253 |
250 template <typename MapType> | 254 template <typename MapType> |
251 void DestroyObject(MapType* map, int32 ipc_object_id); | 255 void DestroyObject(MapType* map, int32_t ipc_object_id); |
252 | 256 |
253 // Message processing. Most of the work is delegated to the dispatcher hosts | 257 // Message processing. Most of the work is delegated to the dispatcher hosts |
254 // below. | 258 // below. |
255 void OnIDBFactoryGetDatabaseNames( | 259 void OnIDBFactoryGetDatabaseNames( |
256 const IndexedDBHostMsg_FactoryGetDatabaseNames_Params& p); | 260 const IndexedDBHostMsg_FactoryGetDatabaseNames_Params& p); |
257 void OnIDBFactoryOpen(const IndexedDBHostMsg_FactoryOpen_Params& p); | 261 void OnIDBFactoryOpen(const IndexedDBHostMsg_FactoryOpen_Params& p); |
258 | 262 |
259 void OnIDBFactoryDeleteDatabase( | 263 void OnIDBFactoryDeleteDatabase( |
260 const IndexedDBHostMsg_FactoryDeleteDatabase_Params& p); | 264 const IndexedDBHostMsg_FactoryDeleteDatabase_Params& p); |
261 | 265 |
(...skipping 19 matching lines...) Expand all Loading... |
281 | 285 |
282 // Used to set file permissions for blob storage. | 286 // Used to set file permissions for blob storage. |
283 int ipc_process_id_; | 287 int ipc_process_id_; |
284 | 288 |
285 DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost); | 289 DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost); |
286 }; | 290 }; |
287 | 291 |
288 } // namespace content | 292 } // namespace content |
289 | 293 |
290 #endif // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ | 294 #endif // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ |
OLD | NEW |