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

Side by Side Diff: content/browser/dom_storage/dom_storage_context_wrapper.cc

Issue 1745603002: Switch LevelDBWrapper::GetAll to use the new Mojo sync IPC mechanism. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: review comment Created 4 years, 9 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 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"
11 #include "base/bind_helpers.h" 11 #include "base/bind_helpers.h"
12 #include "base/files/file_path.h" 12 #include "base/files/file_path.h"
13 #include "base/location.h" 13 #include "base/location.h"
14 #include "base/single_thread_task_runner.h" 14 #include "base/single_thread_task_runner.h"
15 #include "base/thread_task_runner_handle.h" 15 #include "base/thread_task_runner_handle.h"
16 #include "content/browser/dom_storage/dom_storage_area.h" 16 #include "content/browser/dom_storage/dom_storage_area.h"
17 #include "content/browser/dom_storage/dom_storage_context_impl.h" 17 #include "content/browser/dom_storage/dom_storage_context_impl.h"
18 #include "content/browser/dom_storage/dom_storage_task_runner.h" 18 #include "content/browser/dom_storage/dom_storage_task_runner.h"
19 #include "content/browser/dom_storage/session_storage_namespace_impl.h" 19 #include "content/browser/dom_storage/session_storage_namespace_impl.h"
20 #include "content/browser/level_db_wrapper_impl.h" 20 #include "content/browser/leveldb_wrapper_impl.h"
21 #include "content/public/browser/browser_thread.h" 21 #include "content/public/browser/browser_thread.h"
22 #include "content/public/browser/local_storage_usage_info.h" 22 #include "content/public/browser/local_storage_usage_info.h"
23 #include "content/public/browser/session_storage_usage_info.h" 23 #include "content/public/browser/session_storage_usage_info.h"
24 24
25 namespace content { 25 namespace content {
26 namespace { 26 namespace {
27 27
28 const char kLocalStorageDirectory[] = "Local Storage"; 28 const char kLocalStorageDirectory[] = "Local Storage";
29 const char kSessionStorageDirectory[] = "Session Storage"; 29 const char kSessionStorageDirectory[] = "Session Storage";
30 30
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after
162 162
163 void DOMStorageContextWrapper::Flush() { 163 void DOMStorageContextWrapper::Flush() {
164 DCHECK(context_.get()); 164 DCHECK(context_.get());
165 context_->task_runner()->PostShutdownBlockingTask( 165 context_->task_runner()->PostShutdownBlockingTask(
166 FROM_HERE, DOMStorageTaskRunner::PRIMARY_SEQUENCE, 166 FROM_HERE, DOMStorageTaskRunner::PRIMARY_SEQUENCE,
167 base::Bind(&DOMStorageContextImpl::Flush, context_)); 167 base::Bind(&DOMStorageContextImpl::Flush, context_));
168 } 168 }
169 169
170 void DOMStorageContextWrapper::OpenLocalStorage( 170 void DOMStorageContextWrapper::OpenLocalStorage(
171 const mojo::String& origin, 171 const mojo::String& origin,
172 LevelDBObserverPtr observer,
173 mojo::InterfaceRequest<LevelDBWrapper> request) { 172 mojo::InterfaceRequest<LevelDBWrapper> request) {
174 if (level_db_wrappers_.find(origin) == level_db_wrappers_.end()) { 173 if (level_db_wrappers_.find(origin) == level_db_wrappers_.end()) {
175 level_db_wrappers_[origin] = make_scoped_ptr(new LevelDBWrapperImpl( 174 level_db_wrappers_[origin] = make_scoped_ptr(new LevelDBWrapperImpl(
176 origin, 175 origin,
177 base::Bind(&DOMStorageContextWrapper::LevelDBWrapperImplHasNoBindings, 176 base::Bind(&DOMStorageContextWrapper::LevelDBWrapperImplHasNoBindings,
178 base::Unretained(this), 177 base::Unretained(this),
179 origin.get()))); 178 origin.get())));
180 } 179 }
181 // TODO(jam): call LevelDB service (once per this object) to open the database 180 // TODO(jam): call LevelDB service (once per this object) to open the database
182 // for LocalStorage and keep a pointer to it in this class. Then keep a map 181 // for LocalStorage and keep a pointer to it in this class. Then keep a map
183 // from origins to LevelDBWrapper object. Each call here for the same origin 182 // from origins to LevelDBWrapper object. Each call here for the same origin
184 // should use the same LevelDBWrapper object. 183 // should use the same LevelDBWrapper object.
185 184
186 level_db_wrappers_[origin]->Bind(std::move(request), std::move(observer)); 185 level_db_wrappers_[origin]->Bind(std::move(request));
187 } 186 }
188 187
189 void DOMStorageContextWrapper::LevelDBWrapperImplHasNoBindings( 188 void DOMStorageContextWrapper::LevelDBWrapperImplHasNoBindings(
190 const std::string& origin) { 189 const std::string& origin) {
191 DCHECK(level_db_wrappers_.find(origin) != level_db_wrappers_.end()); 190 DCHECK(level_db_wrappers_.find(origin) != level_db_wrappers_.end());
192 level_db_wrappers_.erase(origin); 191 level_db_wrappers_.erase(origin);
193 } 192 }
194 193
195 } // namespace content 194 } // namespace content
OLDNEW
« no previous file with comments | « content/browser/dom_storage/dom_storage_context_wrapper.h ('k') | content/browser/level_db_wrapper_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698