Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(68)

Side by Side Diff: content/browser/in_process_webkit/indexed_db_dispatcher_host.cc

Issue 10179003: IndexedDB: remove proxy and IPC code for the IDBKey-based get/getKey. (Closed) Base URL: http://git.chromium.org/chromium/src.git@master
Patch Set: Updated formatting Created 8 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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/browser/in_process_webkit/indexed_db_dispatcher_host.h" 5 #include "content/browser/in_process_webkit/indexed_db_dispatcher_host.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/command_line.h" 8 #include "base/command_line.h"
9 #include "base/utf_string_conversions.h" 9 #include "base/utf_string_conversions.h"
10 #include "content/browser/in_process_webkit/indexed_db_callbacks.h" 10 #include "content/browser/in_process_webkit/indexed_db_callbacks.h"
(...skipping 488 matching lines...) Expand 10 before | Expand all | Expand 10 after
499 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexName, OnName) 499 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexName, OnName)
500 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexStoreName, OnStoreName) 500 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexStoreName, OnStoreName)
501 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexKeyPath, OnKeyPath) 501 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexKeyPath, OnKeyPath)
502 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexUnique, OnUnique) 502 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexUnique, OnUnique)
503 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexMultiEntry, OnMultiEntry) 503 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexMultiEntry, OnMultiEntry)
504 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexOpenObjectCursor, 504 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexOpenObjectCursor,
505 OnOpenObjectCursor) 505 OnOpenObjectCursor)
506 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexOpenKeyCursor, OnOpenKeyCursor) 506 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexOpenKeyCursor, OnOpenKeyCursor)
507 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexCount, OnCount) 507 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexCount, OnCount)
508 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexGetObject, OnGetObject) 508 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexGetObject, OnGetObject)
509 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexGetObjectByRange,
510 OnGetObjectByRange)
511 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexGetKey, OnGetKey) 509 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexGetKey, OnGetKey)
512 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexGetKeyByRange, OnGetKeyByRange)
513 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexDestroyed, OnDestroyed) 510 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_IndexDestroyed, OnDestroyed)
514 IPC_MESSAGE_UNHANDLED(handled = false) 511 IPC_MESSAGE_UNHANDLED(handled = false)
515 IPC_END_MESSAGE_MAP() 512 IPC_END_MESSAGE_MAP()
516 return handled; 513 return handled;
517 } 514 }
518 515
519 void IndexedDBDispatcherHost::IndexDispatcherHost::Send( 516 void IndexedDBDispatcherHost::IndexDispatcherHost::Send(
520 IPC::Message* message) { 517 IPC::Message* message) {
521 parent_->Send(message); 518 parent_->Send(message);
522 } 519 }
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
610 idb_index->count( 607 idb_index->count(
611 WebIDBKeyRange(params.lower_key, params.upper_key, params.lower_open, 608 WebIDBKeyRange(params.lower_key, params.upper_key, params.lower_open,
612 params.upper_open), 609 params.upper_open),
613 callbacks.release(), *idb_transaction, *ec); 610 callbacks.release(), *idb_transaction, *ec);
614 } 611 }
615 612
616 void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetObject( 613 void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetObject(
617 int idb_index_id, 614 int idb_index_id,
618 int32 thread_id, 615 int32 thread_id,
619 int32 response_id, 616 int32 response_id,
620 const IndexedDBKey& key,
621 int32 transaction_id,
622 WebKit::WebExceptionCode* ec) {
623 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
624 WebIDBIndex* idb_index = parent_->GetOrTerminateProcess(
625 &map_, idb_index_id);
626 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess(
627 &parent_->transaction_dispatcher_host_->map_, transaction_id);
628 if (!idb_transaction || !idb_index)
629 return;
630
631 *ec = 0;
632 scoped_ptr<WebIDBCallbacks> callbacks(
633 new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
634 response_id));
635 idb_index->getObject(key, callbacks.release(), *idb_transaction, *ec);
636 }
637
638 void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetObjectByRange(
639 int idb_index_id,
640 int32 thread_id,
641 int32 response_id,
642 const IndexedDBKeyRange& key_range, 617 const IndexedDBKeyRange& key_range,
643 int32 transaction_id, 618 int32 transaction_id,
644 WebKit::WebExceptionCode* ec) { 619 WebKit::WebExceptionCode* ec) {
645 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED)); 620 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
646 WebIDBIndex* idb_index = parent_->GetOrTerminateProcess( 621 WebIDBIndex* idb_index = parent_->GetOrTerminateProcess(
647 &map_, idb_index_id); 622 &map_, idb_index_id);
648 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess( 623 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess(
649 &parent_->transaction_dispatcher_host_->map_, transaction_id); 624 &parent_->transaction_dispatcher_host_->map_, transaction_id);
650 if (!idb_transaction || !idb_index) 625 if (!idb_transaction || !idb_index)
651 return; 626 return;
652 627
653 *ec = 0; 628 *ec = 0;
654 scoped_ptr<WebIDBCallbacks> callbacks( 629 scoped_ptr<WebIDBCallbacks> callbacks(
655 new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id, 630 new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
656 response_id)); 631 response_id));
657 idb_index->getObject(key_range, callbacks.release(), *idb_transaction, *ec); 632 idb_index->getObject(key_range, callbacks.release(), *idb_transaction, *ec);
658 } 633 }
659 634
660 void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetKey( 635 void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetKey(
661 int idb_index_id, 636 int idb_index_id,
662 int32 thread_id, 637 int32 thread_id,
663 int32 response_id, 638 int32 response_id,
664 const IndexedDBKey& key,
665 int32 transaction_id,
666 WebKit::WebExceptionCode* ec) {
667 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
668 WebIDBIndex* idb_index = parent_->GetOrTerminateProcess(
669 &map_, idb_index_id);
670 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess(
671 &parent_->transaction_dispatcher_host_->map_, transaction_id);
672 if (!idb_transaction || !idb_index)
673 return;
674
675 *ec = 0;
676 scoped_ptr<WebIDBCallbacks> callbacks(
677 new IndexedDBCallbacks<WebIDBKey>(parent_, thread_id, response_id));
678 idb_index->getKey(key, callbacks.release(), *idb_transaction, *ec);
679 }
680
681 void IndexedDBDispatcherHost::IndexDispatcherHost::OnGetKeyByRange(
682 int idb_index_id,
683 int32 thread_id,
684 int32 response_id,
685 const IndexedDBKeyRange& key_range, 639 const IndexedDBKeyRange& key_range,
686 int32 transaction_id, 640 int32 transaction_id,
687 WebKit::WebExceptionCode* ec) { 641 WebKit::WebExceptionCode* ec) {
688 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED)); 642 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
689 WebIDBIndex* idb_index = parent_->GetOrTerminateProcess( 643 WebIDBIndex* idb_index = parent_->GetOrTerminateProcess(
690 &map_, idb_index_id); 644 &map_, idb_index_id);
691 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess( 645 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess(
692 &parent_->transaction_dispatcher_host_->map_, transaction_id); 646 &parent_->transaction_dispatcher_host_->map_, transaction_id);
693 if (!idb_transaction || !idb_index) 647 if (!idb_transaction || !idb_index)
694 return; 648 return;
(...skipping 25 matching lines...) Expand all
720 674
721 bool IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnMessageReceived( 675 bool IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnMessageReceived(
722 const IPC::Message& message, bool* msg_is_ok) { 676 const IPC::Message& message, bool* msg_is_ok) {
723 bool handled = true; 677 bool handled = true;
724 IPC_BEGIN_MESSAGE_MAP_EX(IndexedDBDispatcherHost::ObjectStoreDispatcherHost, 678 IPC_BEGIN_MESSAGE_MAP_EX(IndexedDBDispatcherHost::ObjectStoreDispatcherHost,
725 message, *msg_is_ok) 679 message, *msg_is_ok)
726 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreName, OnName) 680 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreName, OnName)
727 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreKeyPath, OnKeyPath) 681 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreKeyPath, OnKeyPath)
728 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreIndexNames, OnIndexNames) 682 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreIndexNames, OnIndexNames)
729 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreGet, OnGet) 683 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreGet, OnGet)
730 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreGetByRange, OnGetByRange)
731 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStorePut, OnPut) 684 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStorePut, OnPut)
732 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDelete, OnDelete) 685 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDelete, OnDelete)
733 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDeleteRange, OnDeleteRange) 686 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDeleteRange, OnDeleteRange)
734 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreClear, OnClear) 687 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreClear, OnClear)
735 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreCreateIndex, OnCreateIndex) 688 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreCreateIndex, OnCreateIndex)
736 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreIndex, OnIndex) 689 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreIndex, OnIndex)
737 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDeleteIndex, OnDeleteIndex) 690 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDeleteIndex, OnDeleteIndex)
738 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreOpenCursor, OnOpenCursor) 691 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreOpenCursor, OnOpenCursor)
739 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreCount, OnCount) 692 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreCount, OnCount)
740 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDestroyed, OnDestroyed) 693 IPC_MESSAGE_HANDLER(IndexedDBHostMsg_ObjectStoreDestroyed, OnDestroyed)
(...skipping 29 matching lines...) Expand all
770 WebDOMStringList web_index_names = idb_object_store->indexNames(); 723 WebDOMStringList web_index_names = idb_object_store->indexNames();
771 index_names->reserve(web_index_names.length()); 724 index_names->reserve(web_index_names.length());
772 for (unsigned i = 0; i < web_index_names.length(); ++i) 725 for (unsigned i = 0; i < web_index_names.length(); ++i)
773 index_names->push_back(web_index_names.item(i)); 726 index_names->push_back(web_index_names.item(i));
774 } 727 }
775 728
776 void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnGet( 729 void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnGet(
777 int idb_object_store_id, 730 int idb_object_store_id,
778 int32 thread_id, 731 int32 thread_id,
779 int32 response_id, 732 int32 response_id,
780 const IndexedDBKey& key,
781 int32 transaction_id,
782 WebKit::WebExceptionCode* ec) {
783 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
784 WebIDBObjectStore* idb_object_store = parent_->GetOrTerminateProcess(
785 &map_, idb_object_store_id);
786 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess(
787 &parent_->transaction_dispatcher_host_->map_, transaction_id);
788 if (!idb_transaction || !idb_object_store)
789 return;
790
791 *ec = 0;
792 scoped_ptr<WebIDBCallbacks> callbacks(
793 new IndexedDBCallbacks<WebSerializedScriptValue>(parent_, thread_id,
794 response_id));
795 idb_object_store->get(key, callbacks.release(), *idb_transaction, *ec);
796 }
797
798 void IndexedDBDispatcherHost::ObjectStoreDispatcherHost::OnGetByRange(
799 int idb_object_store_id,
800 int32 thread_id,
801 int32 response_id,
802 const IndexedDBKeyRange& key_range, 733 const IndexedDBKeyRange& key_range,
803 int32 transaction_id, 734 int32 transaction_id,
804 WebKit::WebExceptionCode* ec) { 735 WebKit::WebExceptionCode* ec) {
805 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED)); 736 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
806 WebIDBObjectStore* idb_object_store = parent_->GetOrTerminateProcess( 737 WebIDBObjectStore* idb_object_store = parent_->GetOrTerminateProcess(
807 &map_, idb_object_store_id); 738 &map_, idb_object_store_id);
808 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess( 739 WebIDBTransaction* idb_transaction = parent_->GetOrTerminateProcess(
809 &parent_->transaction_dispatcher_host_->map_, transaction_id); 740 &parent_->transaction_dispatcher_host_->map_, transaction_id);
810 if (!idb_transaction || !idb_object_store) 741 if (!idb_transaction || !idb_object_store)
811 return; 742 return;
(...skipping 450 matching lines...) Expand 10 before | Expand all | Expand 10 after
1262 } 1193 }
1263 idb_transaction->didCompleteTaskEvents(); 1194 idb_transaction->didCompleteTaskEvents();
1264 } 1195 }
1265 1196
1266 void IndexedDBDispatcherHost::TransactionDispatcherHost::OnDestroyed( 1197 void IndexedDBDispatcherHost::TransactionDispatcherHost::OnDestroyed(
1267 int32 object_id) { 1198 int32 object_id) {
1268 transaction_size_map_.erase(object_id); 1199 transaction_size_map_.erase(object_id);
1269 transaction_url_map_.erase(object_id); 1200 transaction_url_map_.erase(object_id);
1270 parent_->DestroyObject(&map_, object_id); 1201 parent_->DestroyObject(&map_, object_id);
1271 } 1202 }
OLDNEW
« no previous file with comments | « content/browser/in_process_webkit/indexed_db_dispatcher_host.h ('k') | content/common/indexed_db/indexed_db_dispatcher.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698