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 #include "content/child/indexed_db/indexed_db_dispatcher.h" | 5 #include "content/child/indexed_db/indexed_db_dispatcher.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/format_macros.h" | 9 #include "base/format_macros.h" |
10 #include "base/lazy_instance.h" | 10 #include "base/lazy_instance.h" |
(...skipping 311 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
322 params.index_id = index_id; | 322 params.index_id = index_id; |
323 params.key_range = key_range; | 323 params.key_range = key_range; |
324 params.key_only = key_only; | 324 params.key_only = key_only; |
325 Send(new IndexedDBHostMsg_DatabaseGet(params)); | 325 Send(new IndexedDBHostMsg_DatabaseGet(params)); |
326 } | 326 } |
327 | 327 |
328 void IndexedDBDispatcher::RequestIDBDatabaseGetAll( | 328 void IndexedDBDispatcher::RequestIDBDatabaseGetAll( |
329 int32 ipc_database_id, | 329 int32 ipc_database_id, |
330 int64 transaction_id, | 330 int64 transaction_id, |
331 int64 object_store_id, | 331 int64 object_store_id, |
| 332 int64 index_id, |
332 const IndexedDBKeyRange& key_range, | 333 const IndexedDBKeyRange& key_range, |
333 int64 max_count, | 334 int64 max_count, |
334 WebIDBCallbacks* callbacks) { | 335 WebIDBCallbacks* callbacks) { |
335 ResetCursorPrefetchCaches(transaction_id, kAllCursors); | 336 ResetCursorPrefetchCaches(transaction_id, kAllCursors); |
336 IndexedDBHostMsg_DatabaseGetAll_Params params; | 337 IndexedDBHostMsg_DatabaseGetAll_Params params; |
337 init_params(¶ms, callbacks); | 338 init_params(¶ms, callbacks); |
338 params.ipc_database_id = ipc_database_id; | 339 params.ipc_database_id = ipc_database_id; |
339 params.transaction_id = transaction_id; | 340 params.transaction_id = transaction_id; |
340 params.object_store_id = object_store_id; | 341 params.object_store_id = object_store_id; |
| 342 params.index_id = index_id; |
341 params.key_range = key_range; | 343 params.key_range = key_range; |
342 params.max_count = max_count; | 344 params.max_count = max_count; |
343 Send(new IndexedDBHostMsg_DatabaseGetAll(params)); | 345 Send(new IndexedDBHostMsg_DatabaseGetAll(params)); |
344 } | 346 } |
345 | 347 |
346 void IndexedDBDispatcher::RequestIDBDatabasePut( | 348 void IndexedDBDispatcher::RequestIDBDatabasePut( |
347 int32 ipc_database_id, | 349 int32 ipc_database_id, |
348 int64 transaction_id, | 350 int64 transaction_id, |
349 int64 object_store_id, | 351 int64 object_store_id, |
350 const WebData& value, | 352 const WebData& value, |
(...skipping 476 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
827 typedef std::map<int32, WebIDBCursorImpl*>::iterator Iterator; | 829 typedef std::map<int32, WebIDBCursorImpl*>::iterator Iterator; |
828 for (Iterator i = cursors_.begin(); i != cursors_.end(); ++i) { | 830 for (Iterator i = cursors_.begin(); i != cursors_.end(); ++i) { |
829 if (i->first == ipc_exception_cursor_id || | 831 if (i->first == ipc_exception_cursor_id || |
830 i->second->transaction_id() != transaction_id) | 832 i->second->transaction_id() != transaction_id) |
831 continue; | 833 continue; |
832 i->second->ResetPrefetchCache(); | 834 i->second->ResetPrefetchCache(); |
833 } | 835 } |
834 } | 836 } |
835 | 837 |
836 } // namespace content | 838 } // namespace content |
OLD | NEW |