Chromium Code Reviews| 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 #ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ | 5 #ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ |
| 6 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ | 6 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 97 void HoldBlobDataHandle( | 97 void HoldBlobDataHandle( |
| 98 const std::string& uuid, | 98 const std::string& uuid, |
| 99 scoped_ptr<webkit_blob::BlobDataHandle> blob_data_handle); | 99 scoped_ptr<webkit_blob::BlobDataHandle> blob_data_handle); |
| 100 void DropBlobDataHandle(const std::string& uuid); | 100 void DropBlobDataHandle(const std::string& uuid); |
| 101 | 101 |
| 102 private: | 102 private: |
| 103 // Friends to enable OnDestruct() delegation. | 103 // Friends to enable OnDestruct() delegation. |
| 104 friend class BrowserThread; | 104 friend class BrowserThread; |
| 105 friend class base::DeleteHelper<IndexedDBDispatcherHost>; | 105 friend class base::DeleteHelper<IndexedDBDispatcherHost>; |
| 106 | 106 |
| 107 virtual ~IndexedDBDispatcherHost(); | 107 // Used in nested classes. |
| 108 typedef std::map<int32, GURL> WebIDBObjectIDToURLMap; | |
| 108 | 109 |
| 109 // Message processing. Most of the work is delegated to the dispatcher hosts | 110 typedef std::map<int64, GURL> TransactionIDToURLMap; |
|
cmumford
2014/08/20 19:43:05
alphabetical?
jsbell
2014/08/22 20:50:01
Hrm... well, I went ahead and sorted these lines b
| |
| 110 // below. | 111 typedef std::map<int64, uint64> TransactionIDToSizeMap; |
| 111 void OnIDBFactoryGetDatabaseNames( | 112 typedef std::map<int64, int64> TransactionIDToDatabaseIDMap; |
| 112 const IndexedDBHostMsg_FactoryGetDatabaseNames_Params& p); | 113 typedef std::map<std::string, webkit_blob::BlobDataHandle*> BlobDataHandleMap; |
| 113 void OnIDBFactoryOpen(const IndexedDBHostMsg_FactoryOpen_Params& p); | |
| 114 | |
| 115 void OnIDBFactoryDeleteDatabase( | |
| 116 const IndexedDBHostMsg_FactoryDeleteDatabase_Params& p); | |
| 117 | |
| 118 void OnAckReceivedBlobs(const std::vector<std::string>& uuids); | |
| 119 void OnPutHelper(const IndexedDBHostMsg_DatabasePut_Params& params, | |
| 120 std::vector<webkit_blob::BlobDataHandle*> handles); | |
| 121 | |
| 122 void ResetDispatcherHosts(); | |
| 123 | 114 |
| 124 // IDMap for RefCounted types | 115 // IDMap for RefCounted types |
| 125 template <typename RefCountedType> | 116 template <typename RefCountedType> |
| 126 class RefIDMap { | 117 class RefIDMap { |
| 127 private: | 118 public: |
| 128 typedef int32 KeyType; | 119 typedef int32 KeyType; |
| 129 | 120 |
| 130 public: | |
| 131 RefIDMap() {} | 121 RefIDMap() {} |
| 132 ~RefIDMap() {} | 122 ~RefIDMap() {} |
| 133 | 123 |
| 134 KeyType Add(RefCountedType* data) { | 124 KeyType Add(RefCountedType* data) { |
| 135 return map_.Add(new scoped_refptr<RefCountedType>(data)); | 125 return map_.Add(new scoped_refptr<RefCountedType>(data)); |
| 136 } | 126 } |
| 137 | 127 |
| 138 RefCountedType* Lookup(KeyType id) { | 128 RefCountedType* Lookup(KeyType id) { |
| 139 scoped_refptr<RefCountedType>* ptr = map_.Lookup(id); | 129 scoped_refptr<RefCountedType>* ptr = map_.Lookup(id); |
| 140 if (ptr == NULL) | 130 if (ptr == NULL) |
| 141 return NULL; | 131 return NULL; |
| 142 return ptr->get(); | 132 return ptr->get(); |
| 143 } | 133 } |
| 144 | 134 |
| 145 void Remove(KeyType id) { map_.Remove(id); } | 135 void Remove(KeyType id) { map_.Remove(id); } |
| 146 | 136 |
| 147 void set_check_on_null_data(bool value) { | 137 void set_check_on_null_data(bool value) { |
| 148 map_.set_check_on_null_data(value); | 138 map_.set_check_on_null_data(value); |
| 149 } | 139 } |
| 150 | 140 |
| 151 private: | 141 private: |
| 152 IDMap<scoped_refptr<RefCountedType>, IDMapOwnPointer> map_; | 142 IDMap<scoped_refptr<RefCountedType>, IDMapOwnPointer> map_; |
| 153 | 143 |
| 154 DISALLOW_COPY_AND_ASSIGN(RefIDMap); | 144 DISALLOW_COPY_AND_ASSIGN(RefIDMap); |
| 155 }; | 145 }; |
| 156 | 146 |
| 157 // Helper templates. | |
| 158 template <class ReturnType> | |
| 159 ReturnType* GetOrTerminateProcess(IDMap<ReturnType, IDMapOwnPointer>* map, | |
| 160 int32 ipc_return_object_id); | |
| 161 template <class ReturnType> | |
| 162 ReturnType* GetOrTerminateProcess(RefIDMap<ReturnType>* map, | |
| 163 int32 ipc_return_object_id); | |
| 164 | |
| 165 template <typename MapType> | |
| 166 void DestroyObject(MapType* map, int32 ipc_object_id); | |
| 167 | |
| 168 // Used in nested classes. | |
| 169 typedef std::map<int32, GURL> WebIDBObjectIDToURLMap; | |
| 170 | |
| 171 typedef std::map<int64, GURL> TransactionIDToURLMap; | |
| 172 typedef std::map<int64, uint64> TransactionIDToSizeMap; | |
| 173 typedef std::map<int64, int64> TransactionIDToDatabaseIDMap; | |
| 174 | |
| 175 class DatabaseDispatcherHost { | 147 class DatabaseDispatcherHost { |
| 176 public: | 148 public: |
| 177 explicit DatabaseDispatcherHost(IndexedDBDispatcherHost* parent); | 149 explicit DatabaseDispatcherHost(IndexedDBDispatcherHost* parent); |
| 178 ~DatabaseDispatcherHost(); | 150 ~DatabaseDispatcherHost(); |
| 179 | 151 |
| 180 void CloseAll(); | 152 void CloseAll(); |
| 181 bool OnMessageReceived(const IPC::Message& message); | 153 bool OnMessageReceived(const IPC::Message& message); |
| 182 | 154 |
| 183 void OnCreateObjectStore( | 155 void OnCreateObjectStore( |
| 184 const IndexedDBHostMsg_DatabaseCreateObjectStore_Params& params); | 156 const IndexedDBHostMsg_DatabaseCreateObjectStore_Params& params); |
| (...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 257 int unused_prefetches); | 229 int unused_prefetches); |
| 258 void OnDestroyed(int32 ipc_cursor_id); | 230 void OnDestroyed(int32 ipc_cursor_id); |
| 259 | 231 |
| 260 IndexedDBDispatcherHost* parent_; | 232 IndexedDBDispatcherHost* parent_; |
| 261 RefIDMap<IndexedDBCursor> map_; | 233 RefIDMap<IndexedDBCursor> map_; |
| 262 | 234 |
| 263 private: | 235 private: |
| 264 DISALLOW_COPY_AND_ASSIGN(CursorDispatcherHost); | 236 DISALLOW_COPY_AND_ASSIGN(CursorDispatcherHost); |
| 265 }; | 237 }; |
| 266 | 238 |
| 239 virtual ~IndexedDBDispatcherHost(); | |
| 240 | |
| 241 // Helper templates. | |
| 242 template <class ReturnType> | |
| 243 ReturnType* GetOrTerminateProcess(IDMap<ReturnType, IDMapOwnPointer>* map, | |
| 244 int32 ipc_return_object_id); | |
| 245 template <class ReturnType> | |
| 246 ReturnType* GetOrTerminateProcess(RefIDMap<ReturnType>* map, | |
| 247 int32 ipc_return_object_id); | |
| 248 | |
| 249 template <typename MapType> | |
| 250 void DestroyObject(MapType* map, int32 ipc_object_id); | |
| 251 | |
| 252 // Message processing. Most of the work is delegated to the dispatcher hosts | |
| 253 // below. | |
| 254 void OnIDBFactoryGetDatabaseNames( | |
| 255 const IndexedDBHostMsg_FactoryGetDatabaseNames_Params& p); | |
| 256 void OnIDBFactoryOpen(const IndexedDBHostMsg_FactoryOpen_Params& p); | |
| 257 | |
| 258 void OnIDBFactoryDeleteDatabase( | |
| 259 const IndexedDBHostMsg_FactoryDeleteDatabase_Params& p); | |
| 260 | |
| 261 void OnAckReceivedBlobs(const std::vector<std::string>& uuids); | |
| 262 void OnPutHelper(const IndexedDBHostMsg_DatabasePut_Params& params, | |
| 263 std::vector<webkit_blob::BlobDataHandle*> handles); | |
| 264 | |
| 265 void ResetDispatcherHosts(); | |
| 266 | |
| 267 // The getter holds the context until OnChannelConnected() can be called from | 267 // The getter holds the context until OnChannelConnected() can be called from |
| 268 // the IO thread, which will extract the net::URLRequestContext from it. | 268 // the IO thread, which will extract the net::URLRequestContext from it. |
| 269 scoped_refptr<net::URLRequestContextGetter> request_context_getter_; | 269 scoped_refptr<net::URLRequestContextGetter> request_context_getter_; |
| 270 net::URLRequestContext* request_context_; | 270 net::URLRequestContext* request_context_; |
| 271 scoped_refptr<IndexedDBContextImpl> indexed_db_context_; | 271 scoped_refptr<IndexedDBContextImpl> indexed_db_context_; |
| 272 scoped_refptr<ChromeBlobStorageContext> blob_storage_context_; | 272 scoped_refptr<ChromeBlobStorageContext> blob_storage_context_; |
| 273 | |
| 274 typedef std::map<std::string, webkit_blob::BlobDataHandle*> BlobDataHandleMap; | |
| 275 BlobDataHandleMap blob_data_handle_map_; | 273 BlobDataHandleMap blob_data_handle_map_; |
| 276 | 274 |
| 277 // Only access on IndexedDB thread. | 275 // Only access on IndexedDB thread. |
| 278 scoped_ptr<DatabaseDispatcherHost> database_dispatcher_host_; | 276 scoped_ptr<DatabaseDispatcherHost> database_dispatcher_host_; |
| 279 scoped_ptr<CursorDispatcherHost> cursor_dispatcher_host_; | 277 scoped_ptr<CursorDispatcherHost> cursor_dispatcher_host_; |
| 280 | 278 |
| 281 // Used to set file permissions for blob storage. | 279 // Used to set file permissions for blob storage. |
| 282 int ipc_process_id_; | 280 int ipc_process_id_; |
| 283 | 281 |
| 284 DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost); | 282 DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost); |
| 285 }; | 283 }; |
| 286 | 284 |
| 287 } // namespace content | 285 } // namespace content |
| 288 | 286 |
| 289 #endif // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ | 287 #endif // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_DISPATCHER_HOST_H_ |
| OLD | NEW |