Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/in_process_webkit/indexed_db_context.h" | 5 #include "content/browser/in_process_webkit/indexed_db_context.h" |
| 6 | 6 |
| 7 #include "base/file_util.h" | 7 #include "base/file_util.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/message_loop_proxy.h" | 9 #include "base/message_loop_proxy.h" |
| 10 #include "base/string_util.h" | 10 #include "base/string_util.h" |
| (...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 95 FilePath IndexedDBContext::GetIndexedDBFilePath( | 95 FilePath IndexedDBContext::GetIndexedDBFilePath( |
| 96 const string16& origin_id) const { | 96 const string16& origin_id) const { |
| 97 FilePath::StringType id = | 97 FilePath::StringType id = |
| 98 webkit_glue::WebStringToFilePathString(origin_id).append( | 98 webkit_glue::WebStringToFilePathString(origin_id).append( |
| 99 FILE_PATH_LITERAL(".indexeddb")); | 99 FILE_PATH_LITERAL(".indexeddb")); |
| 100 return data_path_.Append(id.append(kIndexedDBExtension)); | 100 return data_path_.Append(id.append(kIndexedDBExtension)); |
| 101 } | 101 } |
| 102 | 102 |
| 103 void IndexedDBContext::DeleteIndexedDBFile(const FilePath& file_path) { | 103 void IndexedDBContext::DeleteIndexedDBFile(const FilePath& file_path) { |
| 104 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); | 104 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); |
| 105 // TODO(pastarmovj): Close all database connections that use that file. | 105 // TODO(pastarmovj): Close all database connections that use that file. |
|
michaeln
2011/07/27 01:31:35
I see there is a close() method on WebIDBDatabase
dgrogan
2011/07/27 22:56:01
Yes, that's how they will be closed, but more work
| |
| 106 file_util::Delete(file_path, false); | 106 file_util::Delete(file_path, true /*recursive*/); |
| 107 } | 107 } |
| 108 | 108 |
| 109 void IndexedDBContext::DeleteIndexedDBForOrigin(const string16& origin_id) { | 109 void IndexedDBContext::DeleteIndexedDBForOrigin(const string16& origin_id) { |
| 110 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); | 110 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); |
| 111 // TODO(pastarmovj): Remove this check once we are safe to delete any time. | 111 // TODO(pastarmovj): Remove this check once we are safe to delete any time. |
| 112 FilePath idb_file = GetIndexedDBFilePath(origin_id); | 112 FilePath idb_file = GetIndexedDBFilePath(origin_id); |
| 113 DCHECK_EQ(idb_file.BaseName().value().substr(0, strlen("chrome-extension")), | 113 DCHECK_EQ(idb_file.BaseName().value().substr(0, strlen("chrome-extension")), |
| 114 FILE_PATH_LITERAL("chrome-extension")); | 114 FILE_PATH_LITERAL("chrome-extension")); |
| 115 DeleteIndexedDBFile(GetIndexedDBFilePath(origin_id)); | 115 DeleteIndexedDBFile(GetIndexedDBFilePath(origin_id)); |
| 116 } | 116 } |
| 117 | 117 |
| 118 // TODO(dgrogan): Once we can delete IndexedDB directories out from underneath | |
| 119 // open webkit instances, merge this and DeleteIndexedDBForOrigin. | |
| 120 void IndexedDBContext::EvictOrigin(const string16& origin_id) { | |
|
michaeln
2011/07/27 01:31:35
This and the method above are functionally equival
dgrogan
2011/07/29 18:14:04
Correct.
| |
| 121 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); | |
| 122 FilePath idb_directory = GetIndexedDBFilePath(origin_id); | |
| 123 DeleteIndexedDBFile(idb_directory); | |
| 124 } | |
| 125 | |
| 118 bool IndexedDBContext::IsUnlimitedStorageGranted( | 126 bool IndexedDBContext::IsUnlimitedStorageGranted( |
| 119 const GURL& origin) const { | 127 const GURL& origin) const { |
| 120 return special_storage_policy_->IsStorageUnlimited(origin); | 128 return special_storage_policy_->IsStorageUnlimited(origin); |
| 121 } | 129 } |
| 122 | 130 |
| 123 // TODO(dgrogan): Merge this code with the similar loop in | 131 // TODO(dgrogan): Merge this code with the similar loop in |
| 124 // BrowsingDataIndexedDBHelperImpl::FetchIndexedDBInfoInWebKitThread. | 132 // BrowsingDataIndexedDBHelperImpl::FetchIndexedDBInfoInWebKitThread. |
| 125 void IndexedDBContext::GetAllOriginIdentifiers( | 133 void IndexedDBContext::GetAllOriginIdentifiers( |
| 126 std::vector<string16>* origin_ids) { | 134 std::vector<string16>* origin_ids) { |
| 127 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); | 135 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT)); |
| 128 file_util::FileEnumerator file_enumerator(data_path_, | 136 file_util::FileEnumerator file_enumerator(data_path_, |
| 129 false, file_util::FileEnumerator::DIRECTORIES); | 137 false, file_util::FileEnumerator::DIRECTORIES); |
| 130 for (FilePath file_path = file_enumerator.Next(); !file_path.empty(); | 138 for (FilePath file_path = file_enumerator.Next(); !file_path.empty(); |
| 131 file_path = file_enumerator.Next()) { | 139 file_path = file_enumerator.Next()) { |
| 132 if (file_path.Extension() == IndexedDBContext::kIndexedDBExtension) { | 140 if (file_path.Extension() == IndexedDBContext::kIndexedDBExtension) { |
| 133 WebKit::WebString origin_id_webstring = | 141 WebKit::WebString origin_id_webstring = |
| 134 webkit_glue::FilePathToWebString(file_path.BaseName()); | 142 webkit_glue::FilePathToWebString(file_path.BaseName()); |
| 135 origin_ids->push_back(origin_id_webstring); | 143 origin_ids->push_back(origin_id_webstring); |
| 136 } | 144 } |
| 137 } | 145 } |
| 138 } | 146 } |
| 139 | 147 |
| 140 quota::QuotaManagerProxy* IndexedDBContext::quota_manager_proxy() { | 148 quota::QuotaManagerProxy* IndexedDBContext::quota_manager_proxy() { |
| 141 return quota_manager_proxy_; | 149 return quota_manager_proxy_; |
| 142 } | 150 } |
| OLD | NEW |