OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ | 5 #ifndef CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |
6 #define CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ | 6 #define CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |
7 | 7 |
8 #include <stddef.h> | 8 #include <stddef.h> |
9 #include <stdint.h> | 9 #include <stdint.h> |
10 | 10 |
(...skipping 11 matching lines...) Expand all Loading... |
22 #include "content/public/child/worker_thread.h" | 22 #include "content/public/child/worker_thread.h" |
23 #include "ipc/ipc_sync_message_filter.h" | 23 #include "ipc/ipc_sync_message_filter.h" |
24 #include "third_party/WebKit/public/platform/WebBlobInfo.h" | 24 #include "third_party/WebKit/public/platform/WebBlobInfo.h" |
25 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBCallbacks.h
" | 25 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBCallbacks.h
" |
26 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseCal
lbacks.h" | 26 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseCal
lbacks.h" |
27 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBObserver.h" | 27 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBObserver.h" |
28 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBTypes.h" | 28 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBTypes.h" |
29 #include "url/origin.h" | 29 #include "url/origin.h" |
30 | 30 |
31 struct IndexedDBDatabaseMetadata; | 31 struct IndexedDBDatabaseMetadata; |
| 32 struct IndexedDBObservation; |
| 33 struct IndexedDBObserverChanges; |
32 struct IndexedDBMsg_CallbacksSuccessCursorContinue_Params; | 34 struct IndexedDBMsg_CallbacksSuccessCursorContinue_Params; |
33 struct IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params; | 35 struct IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params; |
34 struct IndexedDBMsg_CallbacksSuccessIDBCursor_Params; | 36 struct IndexedDBMsg_CallbacksSuccessIDBCursor_Params; |
35 struct IndexedDBMsg_CallbacksSuccessArray_Params; | 37 struct IndexedDBMsg_CallbacksSuccessArray_Params; |
36 struct IndexedDBMsg_CallbacksSuccessValue_Params; | 38 struct IndexedDBMsg_CallbacksSuccessValue_Params; |
37 struct IndexedDBMsg_CallbacksUpgradeNeeded_Params; | 39 struct IndexedDBMsg_CallbacksUpgradeNeeded_Params; |
38 | 40 |
39 namespace blink { | 41 namespace blink { |
40 class WebData; | 42 class WebData; |
41 } | 43 } |
(...skipping 208 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
250 int64_t existing_version); | 252 int64_t existing_version); |
251 void OnUpgradeNeeded(const IndexedDBMsg_CallbacksUpgradeNeeded_Params& p); | 253 void OnUpgradeNeeded(const IndexedDBMsg_CallbacksUpgradeNeeded_Params& p); |
252 void OnAbort(int32_t ipc_thread_id, | 254 void OnAbort(int32_t ipc_thread_id, |
253 int32_t ipc_database_id, | 255 int32_t ipc_database_id, |
254 int64_t transaction_id, | 256 int64_t transaction_id, |
255 int code, | 257 int code, |
256 const base::string16& message); | 258 const base::string16& message); |
257 void OnComplete(int32_t ipc_thread_id, | 259 void OnComplete(int32_t ipc_thread_id, |
258 int32_t ipc_database_id, | 260 int32_t ipc_database_id, |
259 int64_t transaction_id); | 261 int64_t transaction_id); |
| 262 void OnDatabaseChange(int32_t ipc_thread_id, |
| 263 int32_t ipc_database_callbacks_id, |
| 264 const IndexedDBObserverChanges&); |
| 265 |
260 void OnForcedClose(int32_t ipc_thread_id, int32_t ipc_database_id); | 266 void OnForcedClose(int32_t ipc_thread_id, int32_t ipc_database_id); |
261 void OnVersionChange(int32_t ipc_thread_id, | 267 void OnVersionChange(int32_t ipc_thread_id, |
262 int32_t ipc_database_id, | 268 int32_t ipc_database_id, |
263 int64_t old_version, | 269 int64_t old_version, |
264 int64_t new_version); | 270 int64_t new_version); |
265 | 271 |
266 // Reset cursor prefetch caches for all cursors except exception_cursor_id. | 272 // Reset cursor prefetch caches for all cursors except exception_cursor_id. |
267 void ResetCursorPrefetchCaches(int64_t transaction_id, | 273 void ResetCursorPrefetchCaches(int64_t transaction_id, |
268 int32_t ipc_exception_cursor_id); | 274 int32_t ipc_exception_cursor_id); |
269 | 275 |
(...skipping 21 matching lines...) Expand all Loading... |
291 std::map<int32_t, WebIDBCursorImpl*> cursors_; | 297 std::map<int32_t, WebIDBCursorImpl*> cursors_; |
292 | 298 |
293 std::map<int32_t, WebIDBDatabaseImpl*> databases_; | 299 std::map<int32_t, WebIDBDatabaseImpl*> databases_; |
294 | 300 |
295 DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher); | 301 DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher); |
296 }; | 302 }; |
297 | 303 |
298 } // namespace content | 304 } // namespace content |
299 | 305 |
300 #endif // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ | 306 #endif // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |
OLD | NEW |