15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ 6eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <map> 9f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)#include <string> 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <vector> 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/basictypes.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/id_map.h" 14eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "base/memory/ref_counted.h" 15a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch#include "content/browser/fileapi/chrome_blob_storage_context.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "content/public/browser/browser_message_filter.h" 17a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch#include "net/url_request/url_request_context_getter.h" 181320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "storage/browser/blob/blob_data_handle.h" 19424c4d7b64af9d0d8fd9624f381f469654d5e3d2Torne (Richard Coles)#include "url/gurl.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct IndexedDBDatabaseMetadata; 222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseCount_Params; 232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseCreateIndex_Params; 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct IndexedDBHostMsg_DatabaseCreateObjectStore_Params; 252a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseCreateTransaction_Params; 262a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseDeleteRange_Params; 272a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseGet_Params; 282a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseOpenCursor_Params; 292a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabasePut_Params; 302a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)struct IndexedDBHostMsg_DatabaseSetIndexKeys_Params; 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct IndexedDBHostMsg_FactoryDeleteDatabase_Params; 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct IndexedDBHostMsg_FactoryGetDatabaseNames_Params; 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct IndexedDBHostMsg_FactoryOpen_Params; 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace content { 36eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdochclass IndexedDBConnection; 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IndexedDBContextImpl; 38eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdochclass IndexedDBCursor; 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IndexedDBKey; 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IndexedDBKeyPath; 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IndexedDBKeyRange; 425e3f23d412006dc4db4e659864679f29341e113fTorne (Richard Coles)struct IndexedDBDatabaseMetadata; 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Handles all IndexedDB related messages from a particular renderer process. 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IndexedDBDispatcherHost : public BrowserMessageFilter { 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Only call the constructor from the UI thread. 48a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch IndexedDBDispatcherHost(int ipc_process_id, 49a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch net::URLRequestContextGetter* request_context_getter, 50a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch IndexedDBContextImpl* indexed_db_context, 51a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch ChromeBlobStorageContext* blob_storage_context); 52a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch IndexedDBDispatcherHost(int ipc_process_id, 53a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch net::URLRequestContext* request_context, 54a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch IndexedDBContextImpl* indexed_db_context, 55a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch ChromeBlobStorageContext* blob_storage_context); 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 575e3f23d412006dc4db4e659864679f29341e113fTorne (Richard Coles) static ::IndexedDBDatabaseMetadata ConvertMetadata( 585e3f23d412006dc4db4e659864679f29341e113fTorne (Richard Coles) const content::IndexedDBDatabaseMetadata& metadata); 592a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // BrowserMessageFilter implementation. 61a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch virtual void OnChannelConnected(int32 peer_pid) OVERRIDE; 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual void OnChannelClosing() OVERRIDE; 63eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch virtual void OnDestruct() const OVERRIDE; 64eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch virtual base::TaskRunner* OverrideTaskRunnerForMessage( 65eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch const IPC::Message& message) OVERRIDE; 66cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void FinishTransaction(int64 host_transaction_id, bool committed); 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // A shortcut for accessing our context. 711320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci IndexedDBContextImpl* Context() { return indexed_db_context_.get(); } 7203b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles) storage::BlobStorageContext* blob_storage_context() const { 73a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch return blob_storage_context_->context(); 74a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch } 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 76eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // IndexedDBCallbacks call these methods to add the results into the 77eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // applicable map. See below for more details. 78eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch int32 Add(IndexedDBCursor* cursor); 79eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch int32 Add(IndexedDBConnection* connection, 802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_thread_id, 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const GURL& origin_url); 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void RegisterTransactionId(int64 host_transaction_id, const GURL& origin_url); 842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 85eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch IndexedDBCursor* GetCursorFromId(int32 ipc_cursor_id); 862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 87d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // These are called to map a 32-bit front-end (renderer-specific) transaction 88d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // id to and from a back-end ("host") transaction id that encodes the process 89d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // id in the high 32 bits. The mapping is host-specific and ids are validated. 902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 HostTransactionId(int64 transaction_id); 912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 RendererTransactionId(int64 host_transaction_id); 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 93d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // These are called to decode a host transaction ID, for diagnostic purposes. 94d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) static uint32 TransactionIdToRendererTransactionId(int64 host_transaction_id); 95d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) static uint32 TransactionIdToProcessId(int64 host_transaction_id); 96d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 9703b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles) void HoldBlobDataHandle(const std::string& uuid, 9803b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles) scoped_ptr<storage::BlobDataHandle> blob_data_handle); 99a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) void DropBlobDataHandle(const std::string& uuid); 100a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 102eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Friends to enable OnDestruct() delegation. 103eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch friend class BrowserThread; 104eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch friend class base::DeleteHelper<IndexedDBDispatcherHost>; 105eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 1061320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // Used in nested classes. 1071320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci typedef std::map<std::string, storage::BlobDataHandle*> BlobDataHandleMap; 1081320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci typedef std::map<int64, int64> TransactionIDToDatabaseIDMap; 1091320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci typedef std::map<int64, uint64> TransactionIDToSizeMap; 1101320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci typedef std::map<int64, GURL> TransactionIDToURLMap; 1111320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci typedef std::map<int32, GURL> WebIDBObjectIDToURLMap; 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 113eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // IDMap for RefCounted types 114eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch template <typename RefCountedType> 115eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch class RefIDMap { 1161320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci public: 117eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch typedef int32 KeyType; 118eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 119eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch RefIDMap() {} 120eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch ~RefIDMap() {} 121eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 122eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch KeyType Add(RefCountedType* data) { 123eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return map_.Add(new scoped_refptr<RefCountedType>(data)); 124eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 125eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 126eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch RefCountedType* Lookup(KeyType id) { 127eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch scoped_refptr<RefCountedType>* ptr = map_.Lookup(id); 128eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (ptr == NULL) 129eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return NULL; 130eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return ptr->get(); 131eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 132eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 133eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch void Remove(KeyType id) { map_.Remove(id); } 134eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 135eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch void set_check_on_null_data(bool value) { 136eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch map_.set_check_on_null_data(value); 137eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 138eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 139eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch private: 140eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch IDMap<scoped_refptr<RefCountedType>, IDMapOwnPointer> map_; 141f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 142f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(RefIDMap); 143eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch }; 144eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) class DatabaseDispatcherHost { 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) explicit DatabaseDispatcherHost(IndexedDBDispatcherHost* parent); 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ~DatabaseDispatcherHost(); 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void CloseAll(); 151cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) bool OnMessageReceived(const IPC::Message& message); 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnCreateObjectStore( 1542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const IndexedDBHostMsg_DatabaseCreateObjectStore_Params& params); 1552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnDeleteObjectStore(int32 ipc_database_id, 1562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 transaction_id, 1572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 object_store_id); 1582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnCreateTransaction( 1592a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const IndexedDBHostMsg_DatabaseCreateTransaction_Params&); 1602a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnClose(int32 ipc_database_id); 161116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch void OnVersionChangeIgnored(int32 ipc_database_id); 1622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnDestroyed(int32 ipc_database_id); 1632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnGet(const IndexedDBHostMsg_DatabaseGet_Params& params); 1650529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch // OnPutWrapper starts on the IO thread so that it can grab BlobDataHandles 1660529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch // before posting to the IDB TaskRunner for the rest of the job. 1670529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch void OnPutWrapper(const IndexedDBHostMsg_DatabasePut_Params& params); 1680529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch void OnPut(const IndexedDBHostMsg_DatabasePut_Params& params, 16903b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles) std::vector<storage::BlobDataHandle*> handles); 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnSetIndexKeys( 1712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const IndexedDBHostMsg_DatabaseSetIndexKeys_Params& params); 172868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) void OnSetIndexesReady(int32 ipc_database_id, 173868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) int64 transaction_id, 174868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) int64 object_store_id, 175868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) const std::vector<int64>& ids); 176868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) void OnOpenCursor(const IndexedDBHostMsg_DatabaseOpenCursor_Params& params); 1772a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnCount(const IndexedDBHostMsg_DatabaseCount_Params& params); 1782a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnDeleteRange( 1792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const IndexedDBHostMsg_DatabaseDeleteRange_Params& params); 1802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnClear(int32 ipc_thread_id, 1812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_callbacks_id, 1822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_database_id, 1832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 transaction_id, 1842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 object_store_id); 1852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnCreateIndex( 1862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const IndexedDBHostMsg_DatabaseCreateIndex_Params& params); 1872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnDeleteIndex(int32 ipc_database_id, 1882a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 transaction_id, 1892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 object_store_id, 1902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int64 index_id); 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1922a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnAbort(int32 ipc_database_id, int64 transaction_id); 1932a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnCommit(int32 ipc_database_id, int64 transaction_id); 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) IndexedDBDispatcherHost* parent_; 195eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch IDMap<IndexedDBConnection, IDMapOwnPointer> map_; 1962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) WebIDBObjectIDToURLMap database_url_map_; 1972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) TransactionIDToSizeMap transaction_size_map_; 1982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) TransactionIDToURLMap transaction_url_map_; 1992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) TransactionIDToDatabaseIDMap transaction_database_map_; 200f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 201f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) private: 202f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(DatabaseDispatcherHost); 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) class CursorDispatcherHost { 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) explicit CursorDispatcherHost(IndexedDBDispatcherHost* parent); 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ~CursorDispatcherHost(); 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 210cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) bool OnMessageReceived(const IPC::Message& message); 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2122a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnAdvance(int32 ipc_object_store_id, 2132a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_thread_id, 2142a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_callbacks_id, 215f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) uint32 count); 2162a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnContinue(int32 ipc_object_store_id, 2172a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_thread_id, 2182a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_callbacks_id, 219f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) const IndexedDBKey& key, 220f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) const IndexedDBKey& primary_key); 2212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnPrefetch(int32 ipc_cursor_id, 2222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_thread_id, 2232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int32 ipc_callbacks_id, 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int n); 225868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) void OnPrefetchReset(int32 ipc_cursor_id, 226868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) int used_prefetches, 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int unused_prefetches); 2282a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void OnDestroyed(int32 ipc_cursor_id); 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) IndexedDBDispatcherHost* parent_; 231eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch RefIDMap<IndexedDBCursor> map_; 232f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 233f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) private: 234f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(CursorDispatcherHost); 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2371320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci virtual ~IndexedDBDispatcherHost(); 2381320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 2391320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // Helper templates. 2401320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci template <class ReturnType> 2411320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci ReturnType* GetOrTerminateProcess(IDMap<ReturnType, IDMapOwnPointer>* map, 2421320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci int32 ipc_return_object_id); 2431320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci template <class ReturnType> 2441320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci ReturnType* GetOrTerminateProcess(RefIDMap<ReturnType>* map, 2451320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci int32 ipc_return_object_id); 2461320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 2471320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci template <typename MapType> 2481320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void DestroyObject(MapType* map, int32 ipc_object_id); 2491320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 2501320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // Message processing. Most of the work is delegated to the dispatcher hosts 2511320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // below. 2521320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void OnIDBFactoryGetDatabaseNames( 2531320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci const IndexedDBHostMsg_FactoryGetDatabaseNames_Params& p); 2541320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void OnIDBFactoryOpen(const IndexedDBHostMsg_FactoryOpen_Params& p); 2551320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 2561320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void OnIDBFactoryDeleteDatabase( 2571320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci const IndexedDBHostMsg_FactoryDeleteDatabase_Params& p); 2581320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 2591320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void OnAckReceivedBlobs(const std::vector<std::string>& uuids); 2601320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void OnPutHelper(const IndexedDBHostMsg_DatabasePut_Params& params, 2611320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci std::vector<storage::BlobDataHandle*> handles); 2621320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 2631320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void ResetDispatcherHosts(); 2641320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 265a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch // The getter holds the context until OnChannelConnected() can be called from 266a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch // the IO thread, which will extract the net::URLRequestContext from it. 267a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch scoped_refptr<net::URLRequestContextGetter> request_context_getter_; 268a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch net::URLRequestContext* request_context_; 2695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<IndexedDBContextImpl> indexed_db_context_; 270a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch scoped_refptr<ChromeBlobStorageContext> blob_storage_context_; 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 272a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) BlobDataHandleMap blob_data_handle_map_; 273a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 274eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Only access on IndexedDB thread. 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_ptr<DatabaseDispatcherHost> database_dispatcher_host_; 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_ptr<CursorDispatcherHost> cursor_dispatcher_host_; 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 278a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch // Used to set file permissions for blob storage. 279a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch int ipc_process_id_; 280a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost); 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace content 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 286eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#endif // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ 287