| 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 #include "content/common/indexed_db/indexed_db_dispatcher.h" | 5 #include "content/common/indexed_db/indexed_db_dispatcher.h" |
| 6 | 6 |
| 7 #include "base/lazy_instance.h" | 7 #include "base/lazy_instance.h" |
| 8 #include "base/threading/thread_local.h" | 8 #include "base/threading/thread_local.h" |
| 9 #include "content/common/child_thread.h" | 9 #include "content/common/child_thread.h" |
| 10 #include "content/common/indexed_db/indexed_db_messages.h" | 10 #include "content/common/indexed_db/indexed_db_messages.h" |
| 11 #include "content/common/indexed_db/proxy_webidbcursor_impl.h" | 11 #include "content/common/indexed_db/proxy_webidbcursor_impl.h" |
| 12 #include "content/common/indexed_db/proxy_webidbdatabase_impl.h" | 12 #include "content/common/indexed_db/proxy_webidbdatabase_impl.h" |
| 13 #include "content/common/indexed_db/proxy_webidbindex_impl.h" | |
| 14 #include "content/common/indexed_db/proxy_webidbobjectstore_impl.h" | |
| 15 #include "content/common/indexed_db/proxy_webidbtransaction_impl.h" | 13 #include "content/common/indexed_db/proxy_webidbtransaction_impl.h" |
| 16 #include "ipc/ipc_channel.h" | 14 #include "ipc/ipc_channel.h" |
| 17 #include "third_party/WebKit/Source/WebKit/chromium/public/WebFrame.h" | 15 #include "third_party/WebKit/Source/WebKit/chromium/public/WebFrame.h" |
| 18 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseCallbac
ks.h" | 16 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseCallbac
ks.h" |
| 19 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseError.h
" | 17 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseError.h
" |
| 20 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseExcepti
on.h" | 18 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabaseExcepti
on.h" |
| 21 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBKeyRange.h" | 19 #include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBKeyRange.h" |
| 22 | 20 |
| 23 using base::ThreadLocalPointer; | 21 using base::ThreadLocalPointer; |
| 24 using WebKit::WebDOMStringList; | 22 using WebKit::WebDOMStringList; |
| (...skipping 403 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 428 int64 transaction_id, | 426 int64 transaction_id, |
| 429 int64 object_store_id, | 427 int64 object_store_id, |
| 430 WebKit::WebIDBCallbacks* callbacks_ptr) { | 428 WebKit::WebIDBCallbacks* callbacks_ptr) { |
| 431 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | 429 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); |
| 432 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); | 430 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); |
| 433 Send(new IndexedDBHostMsg_DatabaseClear( | 431 Send(new IndexedDBHostMsg_DatabaseClear( |
| 434 CurrentWorkerId(), ipc_response_id, ipc_database_id, | 432 CurrentWorkerId(), ipc_response_id, ipc_database_id, |
| 435 transaction_id, object_store_id)); | 433 transaction_id, object_store_id)); |
| 436 } | 434 } |
| 437 | 435 |
| 438 void IndexedDBDispatcher::RequestIDBIndexOpenObjectCursor( | |
| 439 const WebIDBKeyRange& idb_key_range, | |
| 440 unsigned short direction, | |
| 441 WebIDBCallbacks* callbacks_ptr, | |
| 442 int32 ipc_index_id, | |
| 443 const WebIDBTransaction& transaction, | |
| 444 WebExceptionCode* ec) { | |
| 445 ResetCursorPrefetchCaches(); | |
| 446 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 447 IndexedDBHostMsg_IndexOpenCursor_Params params; | |
| 448 params.ipc_thread_id = CurrentWorkerId(); | |
| 449 params.ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 450 params.key_range = IndexedDBKeyRange(idb_key_range); | |
| 451 params.direction = direction; | |
| 452 params.ipc_index_id = ipc_index_id; | |
| 453 params.ipc_transaction_id = TransactionId(transaction); | |
| 454 Send(new IndexedDBHostMsg_IndexOpenObjectCursor(params)); | |
| 455 } | |
| 456 | |
| 457 void IndexedDBDispatcher::RequestIDBIndexOpenKeyCursor( | |
| 458 const WebIDBKeyRange& idb_key_range, | |
| 459 unsigned short direction, | |
| 460 WebIDBCallbacks* callbacks_ptr, | |
| 461 int32 ipc_index_id, | |
| 462 const WebIDBTransaction& transaction, | |
| 463 WebExceptionCode* ec) { | |
| 464 ResetCursorPrefetchCaches(); | |
| 465 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 466 IndexedDBHostMsg_IndexOpenCursor_Params params; | |
| 467 params.ipc_thread_id = CurrentWorkerId(); | |
| 468 params.ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 469 params.key_range = IndexedDBKeyRange(idb_key_range); | |
| 470 params.direction = direction; | |
| 471 params.ipc_index_id = ipc_index_id; | |
| 472 params.ipc_transaction_id = TransactionId(transaction); | |
| 473 Send(new IndexedDBHostMsg_IndexOpenKeyCursor(params)); | |
| 474 } | |
| 475 | |
| 476 void IndexedDBDispatcher::RequestIDBIndexCount( | |
| 477 const WebIDBKeyRange& idb_key_range, | |
| 478 WebIDBCallbacks* callbacks_ptr, | |
| 479 int32 ipc_index_id, | |
| 480 const WebIDBTransaction& transaction, | |
| 481 WebExceptionCode* ec) { | |
| 482 ResetCursorPrefetchCaches(); | |
| 483 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 484 IndexedDBHostMsg_IndexCount_Params params; | |
| 485 params.ipc_thread_id = CurrentWorkerId(); | |
| 486 params.ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 487 params.key_range = IndexedDBKeyRange(idb_key_range); | |
| 488 params.ipc_index_id = ipc_index_id; | |
| 489 params.ipc_transaction_id = TransactionId(transaction); | |
| 490 Send(new IndexedDBHostMsg_IndexCount(params)); | |
| 491 } | |
| 492 | |
| 493 void IndexedDBDispatcher::RequestIDBIndexGetObject( | |
| 494 const IndexedDBKeyRange& key_range, | |
| 495 WebIDBCallbacks* callbacks_ptr, | |
| 496 int32 ipc_index_id, | |
| 497 const WebIDBTransaction& transaction, | |
| 498 WebExceptionCode* ec) { | |
| 499 ResetCursorPrefetchCaches(); | |
| 500 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 501 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 502 Send(new IndexedDBHostMsg_IndexGetObject( | |
| 503 ipc_index_id, CurrentWorkerId(), | |
| 504 ipc_response_id, key_range, | |
| 505 TransactionId(transaction))); | |
| 506 } | |
| 507 | |
| 508 void IndexedDBDispatcher::RequestIDBIndexGetKey( | |
| 509 const IndexedDBKeyRange& key_range, | |
| 510 WebIDBCallbacks* callbacks_ptr, | |
| 511 int32 ipc_index_id, | |
| 512 const WebIDBTransaction& transaction, | |
| 513 WebExceptionCode* ec) { | |
| 514 ResetCursorPrefetchCaches(); | |
| 515 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 516 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 517 Send(new IndexedDBHostMsg_IndexGetKey( | |
| 518 ipc_index_id, CurrentWorkerId(), ipc_response_id, key_range, | |
| 519 TransactionId(transaction))); | |
| 520 } | |
| 521 | |
| 522 void IndexedDBDispatcher::RequestIDBObjectStoreGet( | |
| 523 const IndexedDBKeyRange& key_range, | |
| 524 WebIDBCallbacks* callbacks_ptr, | |
| 525 int32 ipc_object_store_id, | |
| 526 const WebIDBTransaction& transaction, | |
| 527 WebExceptionCode* ec) { | |
| 528 ResetCursorPrefetchCaches(); | |
| 529 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 530 | |
| 531 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 532 Send(new IndexedDBHostMsg_ObjectStoreGet( | |
| 533 ipc_object_store_id, CurrentWorkerId(), ipc_response_id, | |
| 534 key_range, TransactionId(transaction))); | |
| 535 } | |
| 536 | |
| 537 void IndexedDBDispatcher::RequestIDBObjectStorePut( | |
| 538 const SerializedScriptValue& value, | |
| 539 const IndexedDBKey& key, | |
| 540 WebKit::WebIDBObjectStore::PutMode put_mode, | |
| 541 WebIDBCallbacks* callbacks_ptr, | |
| 542 int32 ipc_object_store_id, | |
| 543 const WebIDBTransaction& transaction, | |
| 544 const WebKit::WebVector<long long>& index_ids, | |
| 545 const WebKit::WebVector<WebKit::WebVector< | |
| 546 WebKit::WebIDBKey> >& index_keys) { | |
| 547 ResetCursorPrefetchCaches(); | |
| 548 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 549 IndexedDBHostMsg_ObjectStorePut_Params params; | |
| 550 params.ipc_thread_id = CurrentWorkerId(); | |
| 551 params.ipc_object_store_id = ipc_object_store_id; | |
| 552 params.ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 553 params.serialized_value = value; | |
| 554 params.key = key; | |
| 555 params.put_mode = put_mode; | |
| 556 params.ipc_transaction_id = TransactionId(transaction); | |
| 557 params.index_ids.resize(index_ids.size()); | |
| 558 for (size_t i = 0; i < index_ids.size(); ++i) { | |
| 559 params.index_ids[i] = index_ids[i]; | |
| 560 } | |
| 561 | |
| 562 params.index_keys.resize(index_keys.size()); | |
| 563 for (size_t i = 0; i < index_keys.size(); ++i) { | |
| 564 params.index_keys[i].resize(index_keys[i].size()); | |
| 565 for (size_t j = 0; j < index_keys[i].size(); ++j) { | |
| 566 params.index_keys[i][j] = IndexedDBKey(index_keys[i][j]); | |
| 567 } | |
| 568 } | |
| 569 Send(new IndexedDBHostMsg_ObjectStorePut(params)); | |
| 570 } | |
| 571 | |
| 572 void IndexedDBDispatcher::RequestIDBObjectStoreDelete( | |
| 573 const IndexedDBKeyRange& key_range, | |
| 574 WebIDBCallbacks* callbacks_ptr, | |
| 575 int32 ipc_object_store_id, | |
| 576 const WebIDBTransaction& transaction, | |
| 577 WebExceptionCode* ec) { | |
| 578 ResetCursorPrefetchCaches(); | |
| 579 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 580 | |
| 581 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 582 Send(new IndexedDBHostMsg_ObjectStoreDelete( | |
| 583 ipc_object_store_id, CurrentWorkerId(), ipc_response_id, key_range, | |
| 584 TransactionId(transaction))); | |
| 585 } | |
| 586 | |
| 587 void IndexedDBDispatcher::RequestIDBObjectStoreClear( | |
| 588 WebIDBCallbacks* callbacks_ptr, | |
| 589 int32 ipc_object_store_id, | |
| 590 const WebIDBTransaction& transaction, | |
| 591 WebExceptionCode* ec) { | |
| 592 ResetCursorPrefetchCaches(); | |
| 593 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 594 | |
| 595 int32 ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 596 Send(new IndexedDBHostMsg_ObjectStoreClear( | |
| 597 ipc_object_store_id, CurrentWorkerId(), ipc_response_id, | |
| 598 TransactionId(transaction))); | |
| 599 } | |
| 600 | |
| 601 void IndexedDBDispatcher::RequestIDBObjectStoreOpenCursor( | |
| 602 const WebIDBKeyRange& idb_key_range, | |
| 603 WebKit::WebIDBCursor::Direction direction, | |
| 604 WebIDBCallbacks* callbacks_ptr, | |
| 605 int32 ipc_object_store_id, | |
| 606 WebKit::WebIDBTransaction::TaskType task_type, | |
| 607 const WebIDBTransaction& transaction, | |
| 608 WebExceptionCode* ec) { | |
| 609 ResetCursorPrefetchCaches(); | |
| 610 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 611 IndexedDBHostMsg_ObjectStoreOpenCursor_Params params; | |
| 612 params.ipc_thread_id = CurrentWorkerId(); | |
| 613 params.ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 614 params.key_range = IndexedDBKeyRange(idb_key_range); | |
| 615 params.direction = direction; | |
| 616 params.ipc_object_store_id = ipc_object_store_id; | |
| 617 params.task_type = task_type; | |
| 618 params.ipc_transaction_id = TransactionId(transaction); | |
| 619 Send(new IndexedDBHostMsg_ObjectStoreOpenCursor(params)); | |
| 620 } | |
| 621 | |
| 622 void IndexedDBDispatcher::RequestIDBObjectStoreCount( | |
| 623 const WebIDBKeyRange& idb_key_range, | |
| 624 WebIDBCallbacks* callbacks_ptr, | |
| 625 int32 ipc_object_store_id, | |
| 626 const WebIDBTransaction& transaction, | |
| 627 WebExceptionCode* ec) { | |
| 628 ResetCursorPrefetchCaches(); | |
| 629 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | |
| 630 IndexedDBHostMsg_ObjectStoreCount_Params params; | |
| 631 params.ipc_thread_id = CurrentWorkerId(); | |
| 632 params.ipc_response_id = pending_callbacks_.Add(callbacks.release()); | |
| 633 params.key_range = IndexedDBKeyRange(idb_key_range); | |
| 634 params.ipc_object_store_id = ipc_object_store_id; | |
| 635 params.ipc_transaction_id = TransactionId(transaction); | |
| 636 Send(new IndexedDBHostMsg_ObjectStoreCount(params)); | |
| 637 } | |
| 638 | |
| 639 void IndexedDBDispatcher::RegisterWebIDBTransactionCallbacks( | 436 void IndexedDBDispatcher::RegisterWebIDBTransactionCallbacks( |
| 640 WebIDBTransactionCallbacks* callbacks, | 437 WebIDBTransactionCallbacks* callbacks, |
| 641 int32 id) { | 438 int32 id) { |
| 642 pending_transaction_callbacks_.AddWithID(callbacks, id); | 439 pending_transaction_callbacks_.AddWithID(callbacks, id); |
| 643 } | 440 } |
| 644 | 441 |
| 645 void IndexedDBDispatcher::CursorDestroyed(int32 ipc_cursor_id) { | 442 void IndexedDBDispatcher::CursorDestroyed(int32 ipc_cursor_id) { |
| 646 cursors_.erase(ipc_cursor_id); | 443 cursors_.erase(ipc_cursor_id); |
| 647 } | 444 } |
| 648 | 445 |
| (...skipping 263 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 912 int32 ipc_exception_cursor_id) { | 709 int32 ipc_exception_cursor_id) { |
| 913 typedef std::map<int32, RendererWebIDBCursorImpl*>::iterator Iterator; | 710 typedef std::map<int32, RendererWebIDBCursorImpl*>::iterator Iterator; |
| 914 for (Iterator i = cursors_.begin(); i != cursors_.end(); ++i) { | 711 for (Iterator i = cursors_.begin(); i != cursors_.end(); ++i) { |
| 915 if (i->first == ipc_exception_cursor_id) | 712 if (i->first == ipc_exception_cursor_id) |
| 916 continue; | 713 continue; |
| 917 i->second->ResetPrefetchCache(); | 714 i->second->ResetPrefetchCache(); |
| 918 } | 715 } |
| 919 } | 716 } |
| 920 | 717 |
| 921 } // namespace content | 718 } // namespace content |
| OLD | NEW |