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

Unified Diff: webkit/common/database/database_connections.cc

Issue 524983002: Move fileapi-related files from webkit/common/ to storage/common/ and set up redirect headers (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fix presubmit Created 6 years, 3 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « webkit/common/database/database_connections.h ('k') | webkit/common/database/database_identifier.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webkit/common/database/database_connections.cc
diff --git a/webkit/common/database/database_connections.cc b/webkit/common/database/database_connections.cc
deleted file mode 100644
index bb2eaee0fe7108c77b9174958d1d2ed7139b79da..0000000000000000000000000000000000000000
--- a/webkit/common/database/database_connections.cc
+++ /dev/null
@@ -1,175 +0,0 @@
-// Copyright (c) 2012 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "webkit/common/database/database_connections.h"
-
-#include "base/auto_reset.h"
-#include "base/bind.h"
-#include "base/logging.h"
-#include "base/message_loop/message_loop.h"
-#include "base/message_loop/message_loop_proxy.h"
-
-namespace storage {
-
-DatabaseConnections::DatabaseConnections() {
-}
-
-DatabaseConnections::~DatabaseConnections() {
- DCHECK(connections_.empty());
-}
-
-bool DatabaseConnections::IsEmpty() const {
- return connections_.empty();
-}
-
-bool DatabaseConnections::IsDatabaseOpened(
- const std::string& origin_identifier,
- const base::string16& database_name) const {
- OriginConnections::const_iterator origin_it =
- connections_.find(origin_identifier);
- if (origin_it == connections_.end())
- return false;
- const DBConnections& origin_connections = origin_it->second;
- return (origin_connections.find(database_name) != origin_connections.end());
-}
-
-bool DatabaseConnections::IsOriginUsed(
- const std::string& origin_identifier) const {
- return (connections_.find(origin_identifier) != connections_.end());
-}
-
-bool DatabaseConnections::AddConnection(
- const std::string& origin_identifier,
- const base::string16& database_name) {
- int& count = connections_[origin_identifier][database_name].first;
- return ++count == 1;
-}
-
-bool DatabaseConnections::RemoveConnection(
- const std::string& origin_identifier,
- const base::string16& database_name) {
- return RemoveConnectionsHelper(origin_identifier, database_name, 1);
-}
-
-void DatabaseConnections::RemoveAllConnections() {
- connections_.clear();
-}
-
-void DatabaseConnections::RemoveConnections(
- const DatabaseConnections& connections,
- std::vector<std::pair<std::string, base::string16> >* closed_dbs) {
- for (OriginConnections::const_iterator origin_it =
- connections.connections_.begin();
- origin_it != connections.connections_.end();
- origin_it++) {
- const DBConnections& db_connections = origin_it->second;
- for (DBConnections::const_iterator db_it = db_connections.begin();
- db_it != db_connections.end(); db_it++) {
- if (RemoveConnectionsHelper(origin_it->first, db_it->first,
- db_it->second.first))
- closed_dbs->push_back(std::make_pair(origin_it->first, db_it->first));
- }
- }
-}
-
-int64 DatabaseConnections::GetOpenDatabaseSize(
- const std::string& origin_identifier,
- const base::string16& database_name) const {
- DCHECK(IsDatabaseOpened(origin_identifier, database_name));
- return connections_[origin_identifier][database_name].second;
-}
-
-void DatabaseConnections::SetOpenDatabaseSize(
- const std::string& origin_identifier,
- const base::string16& database_name,
- int64 size) {
- DCHECK(IsDatabaseOpened(origin_identifier, database_name));
- connections_[origin_identifier][database_name].second = size;
-}
-
-void DatabaseConnections::ListConnections(
- std::vector<std::pair<std::string, base::string16> > *list) const {
- for (OriginConnections::const_iterator origin_it =
- connections_.begin();
- origin_it != connections_.end();
- origin_it++) {
- const DBConnections& db_connections = origin_it->second;
- for (DBConnections::const_iterator db_it = db_connections.begin();
- db_it != db_connections.end(); db_it++) {
- list->push_back(std::make_pair(origin_it->first, db_it->first));
- }
- }
-}
-
-bool DatabaseConnections::RemoveConnectionsHelper(
- const std::string& origin_identifier,
- const base::string16& database_name,
- int num_connections) {
- OriginConnections::iterator origin_iterator =
- connections_.find(origin_identifier);
- DCHECK(origin_iterator != connections_.end());
- DBConnections& db_connections = origin_iterator->second;
- int& count = db_connections[database_name].first;
- DCHECK(count >= num_connections);
- count -= num_connections;
- if (count)
- return false;
- db_connections.erase(database_name);
- if (db_connections.empty())
- connections_.erase(origin_iterator);
- return true;
-}
-
-DatabaseConnectionsWrapper::DatabaseConnectionsWrapper()
- : waiting_for_dbs_to_close_(false),
- main_thread_(base::MessageLoopProxy::current()) {
-}
-
-DatabaseConnectionsWrapper::~DatabaseConnectionsWrapper() {
-}
-
-void DatabaseConnectionsWrapper::WaitForAllDatabasesToClose() {
- // We assume that new databases won't be open while we're waiting.
- DCHECK(main_thread_->BelongsToCurrentThread());
- if (HasOpenConnections()) {
- base::AutoReset<bool> auto_reset(&waiting_for_dbs_to_close_, true);
- base::MessageLoop::ScopedNestableTaskAllower allow(
- base::MessageLoop::current());
- base::MessageLoop::current()->Run();
- }
-}
-
-bool DatabaseConnectionsWrapper::HasOpenConnections() {
- DCHECK(main_thread_->BelongsToCurrentThread());
- base::AutoLock auto_lock(open_connections_lock_);
- return !open_connections_.IsEmpty();
-}
-
-void DatabaseConnectionsWrapper::AddOpenConnection(
- const std::string& origin_identifier,
- const base::string16& database_name) {
- // We add to the collection immediately on any thread.
- base::AutoLock auto_lock(open_connections_lock_);
- open_connections_.AddConnection(origin_identifier, database_name);
-}
-
-void DatabaseConnectionsWrapper::RemoveOpenConnection(
- const std::string& origin_identifier,
- const base::string16& database_name) {
- // But only remove from the collection on the main thread
- // so we can handle the waiting_for_dbs_to_close_ case.
- if (!main_thread_->BelongsToCurrentThread()) {
- main_thread_->PostTask(
- FROM_HERE,
- base::Bind(&DatabaseConnectionsWrapper::RemoveOpenConnection, this,
- origin_identifier, database_name));
- return;
- }
- base::AutoLock auto_lock(open_connections_lock_);
- open_connections_.RemoveConnection(origin_identifier, database_name);
- if (waiting_for_dbs_to_close_ && open_connections_.IsEmpty())
- base::MessageLoop::current()->Quit();
-}
-
-} // namespace storage
« no previous file with comments | « webkit/common/database/database_connections.h ('k') | webkit/common/database/database_identifier.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698