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/browser/dom_storage/dom_storage_context_wrapper.h" | 5 #include "content/browser/dom_storage/dom_storage_context_wrapper.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
73 FROM_HERE, base::Bind(&InvokeSessionStorageUsageCallbackHelper, callback, | 73 FROM_HERE, base::Bind(&InvokeSessionStorageUsageCallbackHelper, callback, |
74 base::Owned(infos))); | 74 base::Owned(infos))); |
75 } | 75 } |
76 | 76 |
77 } // namespace | 77 } // namespace |
78 | 78 |
79 // Used for mojo-based LocalStorage implementation (behind --mojo-local-storage | 79 // Used for mojo-based LocalStorage implementation (behind --mojo-local-storage |
80 // for now). | 80 // for now). |
81 class DOMStorageContextWrapper::MojoState { | 81 class DOMStorageContextWrapper::MojoState { |
82 public: | 82 public: |
83 MojoState(mojo::Connector* connector, const base::FilePath& subdirectory) | 83 MojoState(shell::Connector* connector, const base::FilePath& subdirectory) |
84 : connector_(connector), | 84 : connector_(connector), |
85 subdirectory_(subdirectory), | 85 subdirectory_(subdirectory), |
86 connection_state_(NO_CONNECTION), | 86 connection_state_(NO_CONNECTION), |
87 weak_ptr_factory_(this) {} | 87 weak_ptr_factory_(this) {} |
88 | 88 |
89 void OpenLocalStorage(const url::Origin& origin, | 89 void OpenLocalStorage(const url::Origin& origin, |
90 mojom::LevelDBObserverPtr observer, | 90 mojom::LevelDBObserverPtr observer, |
91 mojom::LevelDBWrapperRequest request); | 91 mojom::LevelDBWrapperRequest request); |
92 | 92 |
93 private: | 93 private: |
94 void OnLevelDDWrapperHasNoBindings(const url::Origin& origin) { | 94 void OnLevelDDWrapperHasNoBindings(const url::Origin& origin) { |
95 DCHECK(level_db_wrappers_.find(origin) != level_db_wrappers_.end()); | 95 DCHECK(level_db_wrappers_.find(origin) != level_db_wrappers_.end()); |
96 level_db_wrappers_.erase(origin); | 96 level_db_wrappers_.erase(origin); |
97 } | 97 } |
98 | 98 |
99 // Part of our asynchronous directory opening called from OpenLocalStorage(). | 99 // Part of our asynchronous directory opening called from OpenLocalStorage(). |
100 void OnDirectoryOpened(filesystem::FileError err); | 100 void OnDirectoryOpened(filesystem::FileError err); |
101 void OnDatabaseOpened(leveldb::DatabaseError status); | 101 void OnDatabaseOpened(leveldb::DatabaseError status); |
102 | 102 |
103 // The (possibly delayed) implementation of OpenLocalStorage(). Can be called | 103 // The (possibly delayed) implementation of OpenLocalStorage(). Can be called |
104 // directly from that function, or through |on_database_open_callbacks_|. | 104 // directly from that function, or through |on_database_open_callbacks_|. |
105 void BindLocalStorage(const url::Origin& origin, | 105 void BindLocalStorage(const url::Origin& origin, |
106 mojom::LevelDBObserverPtr observer, | 106 mojom::LevelDBObserverPtr observer, |
107 mojom::LevelDBWrapperRequest request); | 107 mojom::LevelDBWrapperRequest request); |
108 | 108 |
109 // Maps between an origin and its prefixed LevelDB view. | 109 // Maps between an origin and its prefixed LevelDB view. |
110 std::map<url::Origin, std::unique_ptr<LevelDBWrapperImpl>> level_db_wrappers_; | 110 std::map<url::Origin, std::unique_ptr<LevelDBWrapperImpl>> level_db_wrappers_; |
111 | 111 |
112 mojo::Connector* const connector_; | 112 shell::Connector* const connector_; |
113 const base::FilePath subdirectory_; | 113 const base::FilePath subdirectory_; |
114 | 114 |
115 enum ConnectionState { | 115 enum ConnectionState { |
116 NO_CONNECTION, | 116 NO_CONNECTION, |
117 CONNECTION_IN_PROGRESS, | 117 CONNECTION_IN_PROGRESS, |
118 CONNECTION_FINISHED | 118 CONNECTION_FINISHED |
119 } connection_state_; | 119 } connection_state_; |
120 | 120 |
121 std::unique_ptr<mojo::Connection> user_service_connection_; | 121 std::unique_ptr<shell::Connection> user_service_connection_; |
122 | 122 |
123 user_service::mojom::UserServicePtr user_service_; | 123 user_service::mojom::UserServicePtr user_service_; |
124 filesystem::DirectoryPtr directory_; | 124 filesystem::DirectoryPtr directory_; |
125 | 125 |
126 leveldb::LevelDBServicePtr leveldb_service_; | 126 leveldb::LevelDBServicePtr leveldb_service_; |
127 leveldb::LevelDBDatabasePtr database_; | 127 leveldb::LevelDBDatabasePtr database_; |
128 | 128 |
129 std::vector<base::Closure> on_database_opened_callbacks_; | 129 std::vector<base::Closure> on_database_opened_callbacks_; |
130 | 130 |
131 base::WeakPtrFactory<MojoState> weak_ptr_factory_; | 131 base::WeakPtrFactory<MojoState> weak_ptr_factory_; |
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
225 base::Bind(&MojoState::OnLevelDDWrapperHasNoBindings, | 225 base::Bind(&MojoState::OnLevelDDWrapperHasNoBindings, |
226 base::Unretained(this), origin))); | 226 base::Unretained(this), origin))); |
227 found = level_db_wrappers_.find(origin); | 227 found = level_db_wrappers_.find(origin); |
228 } | 228 } |
229 | 229 |
230 found->second->Bind(std::move(request)); | 230 found->second->Bind(std::move(request)); |
231 found->second->AddObserver(std::move(observer)); | 231 found->second->AddObserver(std::move(observer)); |
232 } | 232 } |
233 | 233 |
234 DOMStorageContextWrapper::DOMStorageContextWrapper( | 234 DOMStorageContextWrapper::DOMStorageContextWrapper( |
235 mojo::Connector* connector, | 235 shell::Connector* connector, |
236 const base::FilePath& profile_path, | 236 const base::FilePath& profile_path, |
237 const base::FilePath& local_partition_path, | 237 const base::FilePath& local_partition_path, |
238 storage::SpecialStoragePolicy* special_storage_policy) { | 238 storage::SpecialStoragePolicy* special_storage_policy) { |
239 base::FilePath storage_dir; | 239 base::FilePath storage_dir; |
240 if (!profile_path.empty()) | 240 if (!profile_path.empty()) |
241 storage_dir = local_partition_path.AppendASCII(kLocalStorageDirectory); | 241 storage_dir = local_partition_path.AppendASCII(kLocalStorageDirectory); |
242 mojo_state_.reset(new MojoState(connector, storage_dir)); | 242 mojo_state_.reset(new MojoState(connector, storage_dir)); |
243 | 243 |
244 base::FilePath data_path; | 244 base::FilePath data_path; |
245 if (!profile_path.empty()) | 245 if (!profile_path.empty()) |
(...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
346 | 346 |
347 void DOMStorageContextWrapper::OpenLocalStorage( | 347 void DOMStorageContextWrapper::OpenLocalStorage( |
348 const url::Origin& origin, | 348 const url::Origin& origin, |
349 mojom::LevelDBObserverPtr observer, | 349 mojom::LevelDBObserverPtr observer, |
350 mojom::LevelDBWrapperRequest request) { | 350 mojom::LevelDBWrapperRequest request) { |
351 mojo_state_->OpenLocalStorage( | 351 mojo_state_->OpenLocalStorage( |
352 origin, std::move(observer), std::move(request)); | 352 origin, std::move(observer), std::move(request)); |
353 } | 353 } |
354 | 354 |
355 } // namespace content | 355 } // namespace content |
OLD | NEW |