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 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
122 blink::WebIDBDatabaseCallbacks* callback_state); | 122 blink::WebIDBDatabaseCallbacks* callback_state); |
123 void UnregisterMojoOwnedDatabaseCallbacks( | 123 void UnregisterMojoOwnedDatabaseCallbacks( |
124 blink::WebIDBDatabaseCallbacks* callback_state); | 124 blink::WebIDBDatabaseCallbacks* callback_state); |
125 | 125 |
126 private: | 126 private: |
127 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorReset); | 127 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorReset); |
128 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorTransactionId); | 128 FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, CursorTransactionId); |
129 | 129 |
130 static int32_t CurrentWorkerId() { return WorkerThread::GetCurrentId(); } | 130 static int32_t CurrentWorkerId() { return WorkerThread::GetCurrentId(); } |
131 | 131 |
132 template <typename T> | |
133 void init_params(T* params, blink::WebIDBCallbacks* callbacks_ptr) { | |
134 std::unique_ptr<blink::WebIDBCallbacks> callbacks(callbacks_ptr); | |
135 params->ipc_thread_id = CurrentWorkerId(); | |
136 params->ipc_callbacks_id = pending_callbacks_.Add(callbacks.release()); | |
137 } | |
138 | |
139 // IDBCallback message handlers. | 132 // IDBCallback message handlers. |
140 void OnSuccessCursorContinue( | 133 void OnSuccessCursorContinue( |
141 const IndexedDBMsg_CallbacksSuccessCursorContinue_Params& p); | 134 const IndexedDBMsg_CallbacksSuccessCursorContinue_Params& p); |
142 void OnSuccessCursorPrefetch( | 135 void OnSuccessCursorPrefetch( |
143 const IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params& p); | 136 const IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params& p); |
144 void OnSuccessValue(const IndexedDBMsg_CallbacksSuccessValue_Params& p); | 137 void OnSuccessValue(const IndexedDBMsg_CallbacksSuccessValue_Params& p); |
145 void OnSuccessInteger(int32_t ipc_thread_id, | 138 void OnSuccessInteger(int32_t ipc_thread_id, |
146 int32_t ipc_callbacks_id, | 139 int32_t ipc_callbacks_id, |
147 int64_t value); | 140 int64_t value); |
148 void OnError(int32_t ipc_thread_id, | 141 void OnError(int32_t ipc_thread_id, |
(...skipping 27 matching lines...) Expand all Loading... |
176 | 169 |
177 // Map from cursor id to WebIDBCursorImpl. | 170 // Map from cursor id to WebIDBCursorImpl. |
178 std::map<int32_t, WebIDBCursorImpl*> cursors_; | 171 std::map<int32_t, WebIDBCursorImpl*> cursors_; |
179 | 172 |
180 DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher); | 173 DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher); |
181 }; | 174 }; |
182 | 175 |
183 } // namespace content | 176 } // namespace content |
184 | 177 |
185 #endif // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ | 178 #endif // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |
OLD | NEW |