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 #include "chrome/browser/browsing_data/browsing_data_database_helper.h" | 5 #include "chrome/browser/browsing_data/browsing_data_database_helper.h" |
6 | 6 |
| 7 #include <vector> |
| 8 |
7 #include "base/bind.h" | 9 #include "base/bind.h" |
8 #include "base/callback.h" | 10 #include "base/callback.h" |
9 #include "base/file_util.h" | 11 #include "base/file_util.h" |
10 #include "base/strings/utf_string_conversions.h" | 12 #include "base/strings/utf_string_conversions.h" |
11 #include "chrome/browser/browsing_data/browsing_data_helper.h" | 13 #include "chrome/browser/browsing_data/browsing_data_helper.h" |
12 #include "chrome/browser/profiles/profile.h" | 14 #include "chrome/browser/profiles/profile.h" |
13 #include "content/public/browser/browser_thread.h" | 15 #include "content/public/browser/browser_thread.h" |
14 #include "content/public/browser/storage_partition.h" | 16 #include "content/public/browser/storage_partition.h" |
15 #include "net/base/completion_callback.h" | 17 #include "net/base/completion_callback.h" |
16 #include "net/base/net_errors.h" | 18 #include "net/base/net_errors.h" |
(...skipping 22 matching lines...) Expand all Loading... |
39 : is_fetching_(false), | 41 : is_fetching_(false), |
40 tracker_(BrowserContext:: | 42 tracker_(BrowserContext:: |
41 GetDefaultStoragePartition(profile)->GetDatabaseTracker()) { | 43 GetDefaultStoragePartition(profile)->GetDatabaseTracker()) { |
42 } | 44 } |
43 | 45 |
44 BrowsingDataDatabaseHelper::~BrowsingDataDatabaseHelper() { | 46 BrowsingDataDatabaseHelper::~BrowsingDataDatabaseHelper() { |
45 } | 47 } |
46 | 48 |
47 void BrowsingDataDatabaseHelper::StartFetching( | 49 void BrowsingDataDatabaseHelper::StartFetching( |
48 const base::Callback<void(const std::list<DatabaseInfo>&)>& callback) { | 50 const base::Callback<void(const std::list<DatabaseInfo>&)>& callback) { |
49 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 51 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
50 DCHECK(!is_fetching_); | 52 DCHECK(!is_fetching_); |
51 DCHECK_EQ(false, callback.is_null()); | 53 DCHECK(!callback.is_null()); |
52 | 54 |
53 is_fetching_ = true; | 55 is_fetching_ = true; |
54 database_info_.clear(); | 56 database_info_.clear(); |
55 completion_callback_ = callback; | 57 completion_callback_ = callback; |
56 BrowserThread::PostTask( | 58 BrowserThread::PostTask( |
57 BrowserThread::FILE, FROM_HERE, | 59 BrowserThread::FILE, FROM_HERE, |
58 base::Bind(&BrowsingDataDatabaseHelper::FetchDatabaseInfoOnFileThread, | 60 base::Bind(&BrowsingDataDatabaseHelper::FetchDatabaseInfoOnFileThread, |
59 this)); | 61 this)); |
60 } | 62 } |
61 | 63 |
62 void BrowsingDataDatabaseHelper::DeleteDatabase(const std::string& origin, | 64 void BrowsingDataDatabaseHelper::DeleteDatabase(const std::string& origin, |
63 const std::string& name) { | 65 const std::string& name) { |
64 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 66 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
65 BrowserThread::PostTask( | 67 BrowserThread::PostTask( |
66 BrowserThread::FILE, FROM_HERE, | 68 BrowserThread::FILE, FROM_HERE, |
67 base::Bind(&BrowsingDataDatabaseHelper::DeleteDatabaseOnFileThread, this, | 69 base::Bind(&BrowsingDataDatabaseHelper::DeleteDatabaseOnFileThread, this, |
68 origin, name)); | 70 origin, name)); |
69 } | 71 } |
70 | 72 |
71 void BrowsingDataDatabaseHelper::FetchDatabaseInfoOnFileThread() { | 73 void BrowsingDataDatabaseHelper::FetchDatabaseInfoOnFileThread() { |
72 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); | 74 DCHECK_CURRENTLY_ON(BrowserThread::FILE); |
73 std::vector<webkit_database::OriginInfo> origins_info; | 75 std::vector<webkit_database::OriginInfo> origins_info; |
74 if (tracker_.get() && tracker_->GetAllOriginsInfo(&origins_info)) { | 76 if (tracker_.get() && tracker_->GetAllOriginsInfo(&origins_info)) { |
75 for (std::vector<webkit_database::OriginInfo>::const_iterator ori = | 77 for (std::vector<webkit_database::OriginInfo>::const_iterator ori = |
76 origins_info.begin(); ori != origins_info.end(); ++ori) { | 78 origins_info.begin(); ori != origins_info.end(); ++ori) { |
77 DatabaseIdentifier identifier = | 79 DatabaseIdentifier identifier = |
78 DatabaseIdentifier::Parse(ori->GetOriginIdentifier()); | 80 DatabaseIdentifier::Parse(ori->GetOriginIdentifier()); |
79 if (!BrowsingDataHelper::HasWebScheme(identifier.ToOrigin())) { | 81 if (!BrowsingDataHelper::HasWebScheme(identifier.ToOrigin())) { |
80 // Non-websafe state is not considered browsing data. | 82 // Non-websafe state is not considered browsing data. |
81 continue; | 83 continue; |
82 } | 84 } |
(...skipping 15 matching lines...) Expand all Loading... |
98 } | 100 } |
99 } | 101 } |
100 } | 102 } |
101 | 103 |
102 BrowserThread::PostTask( | 104 BrowserThread::PostTask( |
103 BrowserThread::UI, FROM_HERE, | 105 BrowserThread::UI, FROM_HERE, |
104 base::Bind(&BrowsingDataDatabaseHelper::NotifyInUIThread, this)); | 106 base::Bind(&BrowsingDataDatabaseHelper::NotifyInUIThread, this)); |
105 } | 107 } |
106 | 108 |
107 void BrowsingDataDatabaseHelper::NotifyInUIThread() { | 109 void BrowsingDataDatabaseHelper::NotifyInUIThread() { |
108 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 110 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
109 DCHECK(is_fetching_); | 111 DCHECK(is_fetching_); |
110 completion_callback_.Run(database_info_); | 112 completion_callback_.Run(database_info_); |
111 completion_callback_.Reset(); | 113 completion_callback_.Reset(); |
112 is_fetching_ = false; | 114 is_fetching_ = false; |
113 database_info_.clear(); | 115 database_info_.clear(); |
114 } | 116 } |
115 | 117 |
116 void BrowsingDataDatabaseHelper::DeleteDatabaseOnFileThread( | 118 void BrowsingDataDatabaseHelper::DeleteDatabaseOnFileThread( |
117 const std::string& origin, | 119 const std::string& origin, |
118 const std::string& name) { | 120 const std::string& name) { |
119 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); | 121 DCHECK_CURRENTLY_ON(BrowserThread::FILE); |
120 if (!tracker_.get()) | 122 if (!tracker_.get()) |
121 return; | 123 return; |
122 tracker_->DeleteDatabase(origin, base::UTF8ToUTF16(name), | 124 tracker_->DeleteDatabase(origin, base::UTF8ToUTF16(name), |
123 net::CompletionCallback()); | 125 net::CompletionCallback()); |
124 } | 126 } |
125 | 127 |
126 CannedBrowsingDataDatabaseHelper::PendingDatabaseInfo::PendingDatabaseInfo( | 128 CannedBrowsingDataDatabaseHelper::PendingDatabaseInfo::PendingDatabaseInfo( |
127 const GURL& origin, | 129 const GURL& origin, |
128 const std::string& name, | 130 const std::string& name, |
129 const std::string& description) | 131 const std::string& description) |
(...skipping 11 matching lines...) Expand all Loading... |
141 return origin < other.origin; | 143 return origin < other.origin; |
142 } | 144 } |
143 | 145 |
144 CannedBrowsingDataDatabaseHelper::CannedBrowsingDataDatabaseHelper( | 146 CannedBrowsingDataDatabaseHelper::CannedBrowsingDataDatabaseHelper( |
145 Profile* profile) | 147 Profile* profile) |
146 : BrowsingDataDatabaseHelper(profile), | 148 : BrowsingDataDatabaseHelper(profile), |
147 profile_(profile) { | 149 profile_(profile) { |
148 } | 150 } |
149 | 151 |
150 CannedBrowsingDataDatabaseHelper* CannedBrowsingDataDatabaseHelper::Clone() { | 152 CannedBrowsingDataDatabaseHelper* CannedBrowsingDataDatabaseHelper::Clone() { |
151 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 153 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
152 CannedBrowsingDataDatabaseHelper* clone = | 154 CannedBrowsingDataDatabaseHelper* clone = |
153 new CannedBrowsingDataDatabaseHelper(profile_); | 155 new CannedBrowsingDataDatabaseHelper(profile_); |
154 | 156 |
155 clone->pending_database_info_ = pending_database_info_; | 157 clone->pending_database_info_ = pending_database_info_; |
156 return clone; | 158 return clone; |
157 } | 159 } |
158 | 160 |
159 void CannedBrowsingDataDatabaseHelper::AddDatabase( | 161 void CannedBrowsingDataDatabaseHelper::AddDatabase( |
160 const GURL& origin, | 162 const GURL& origin, |
161 const std::string& name, | 163 const std::string& name, |
162 const std::string& description) { | 164 const std::string& description) { |
163 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 165 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
164 if (BrowsingDataHelper::HasWebScheme(origin)) { | 166 if (BrowsingDataHelper::HasWebScheme(origin)) { |
165 pending_database_info_.insert(PendingDatabaseInfo( | 167 pending_database_info_.insert(PendingDatabaseInfo( |
166 origin, name, description)); | 168 origin, name, description)); |
167 } | 169 } |
168 } | 170 } |
169 | 171 |
170 void CannedBrowsingDataDatabaseHelper::Reset() { | 172 void CannedBrowsingDataDatabaseHelper::Reset() { |
171 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 173 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
172 pending_database_info_.clear(); | 174 pending_database_info_.clear(); |
173 } | 175 } |
174 | 176 |
175 bool CannedBrowsingDataDatabaseHelper::empty() const { | 177 bool CannedBrowsingDataDatabaseHelper::empty() const { |
176 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 178 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
177 return pending_database_info_.empty(); | 179 return pending_database_info_.empty(); |
178 } | 180 } |
179 | 181 |
180 size_t CannedBrowsingDataDatabaseHelper::GetDatabaseCount() const { | 182 size_t CannedBrowsingDataDatabaseHelper::GetDatabaseCount() const { |
181 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 183 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
182 return pending_database_info_.size(); | 184 return pending_database_info_.size(); |
183 } | 185 } |
184 | 186 |
185 const std::set<CannedBrowsingDataDatabaseHelper::PendingDatabaseInfo>& | 187 const std::set<CannedBrowsingDataDatabaseHelper::PendingDatabaseInfo>& |
186 CannedBrowsingDataDatabaseHelper::GetPendingDatabaseInfo() { | 188 CannedBrowsingDataDatabaseHelper::GetPendingDatabaseInfo() { |
187 return pending_database_info_; | 189 return pending_database_info_; |
188 } | 190 } |
189 | 191 |
190 void CannedBrowsingDataDatabaseHelper::StartFetching( | 192 void CannedBrowsingDataDatabaseHelper::StartFetching( |
191 const base::Callback<void(const std::list<DatabaseInfo>&)>& callback) { | 193 const base::Callback<void(const std::list<DatabaseInfo>&)>& callback) { |
192 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 194 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
193 DCHECK(!callback.is_null()); | 195 DCHECK(!callback.is_null()); |
194 | 196 |
195 std::list<DatabaseInfo> result; | 197 std::list<DatabaseInfo> result; |
196 for (std::set<PendingDatabaseInfo>::const_iterator | 198 for (std::set<PendingDatabaseInfo>::const_iterator |
197 info = pending_database_info_.begin(); | 199 info = pending_database_info_.begin(); |
198 info != pending_database_info_.end(); ++info) { | 200 info != pending_database_info_.end(); ++info) { |
199 DatabaseIdentifier identifier = | 201 DatabaseIdentifier identifier = |
200 DatabaseIdentifier::CreateFromOrigin(info->origin); | 202 DatabaseIdentifier::CreateFromOrigin(info->origin); |
201 | 203 |
202 result.push_back(DatabaseInfo( | 204 result.push_back(DatabaseInfo( |
(...skipping 19 matching lines...) Expand all Loading... |
222 ++it) { | 224 ++it) { |
223 if (it->origin == origin && it->name == name) { | 225 if (it->origin == origin && it->name == name) { |
224 pending_database_info_.erase(it); | 226 pending_database_info_.erase(it); |
225 break; | 227 break; |
226 } | 228 } |
227 } | 229 } |
228 BrowsingDataDatabaseHelper::DeleteDatabase(origin_identifier, name); | 230 BrowsingDataDatabaseHelper::DeleteDatabase(origin_identifier, name); |
229 } | 231 } |
230 | 232 |
231 CannedBrowsingDataDatabaseHelper::~CannedBrowsingDataDatabaseHelper() {} | 233 CannedBrowsingDataDatabaseHelper::~CannedBrowsingDataDatabaseHelper() {} |
OLD | NEW |