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_indexed_db_helper.h" | 5 #include "chrome/browser/browsing_data/browsing_data_indexed_db_helper.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
(...skipping 14 matching lines...) Expand all Loading... |
25 : indexed_db_context_(indexed_db_context), | 25 : indexed_db_context_(indexed_db_context), |
26 is_fetching_(false) { | 26 is_fetching_(false) { |
27 DCHECK(indexed_db_context_.get()); | 27 DCHECK(indexed_db_context_.get()); |
28 } | 28 } |
29 | 29 |
30 BrowsingDataIndexedDBHelper::~BrowsingDataIndexedDBHelper() { | 30 BrowsingDataIndexedDBHelper::~BrowsingDataIndexedDBHelper() { |
31 } | 31 } |
32 | 32 |
33 void BrowsingDataIndexedDBHelper::StartFetching( | 33 void BrowsingDataIndexedDBHelper::StartFetching( |
34 const base::Callback<void(const std::list<IndexedDBInfo>&)>& callback) { | 34 const base::Callback<void(const std::list<IndexedDBInfo>&)>& callback) { |
35 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 35 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
36 DCHECK(!is_fetching_); | 36 DCHECK(!is_fetching_); |
37 DCHECK_EQ(false, callback.is_null()); | 37 DCHECK(!callback.is_null()); |
38 | 38 |
39 is_fetching_ = true; | 39 is_fetching_ = true; |
40 completion_callback_ = callback; | 40 completion_callback_ = callback; |
41 indexed_db_context_->TaskRunner()->PostTask( | 41 indexed_db_context_->TaskRunner()->PostTask( |
42 FROM_HERE, | 42 FROM_HERE, |
43 base::Bind( | 43 base::Bind( |
44 &BrowsingDataIndexedDBHelper::FetchIndexedDBInfoInIndexedDBThread, | 44 &BrowsingDataIndexedDBHelper::FetchIndexedDBInfoInIndexedDBThread, |
45 this)); | 45 this)); |
46 } | 46 } |
47 | 47 |
48 void BrowsingDataIndexedDBHelper::DeleteIndexedDB( | 48 void BrowsingDataIndexedDBHelper::DeleteIndexedDB( |
49 const GURL& origin) { | 49 const GURL& origin) { |
50 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 50 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
51 indexed_db_context_->TaskRunner()->PostTask( | 51 indexed_db_context_->TaskRunner()->PostTask( |
52 FROM_HERE, | 52 FROM_HERE, |
53 base::Bind( | 53 base::Bind( |
54 &BrowsingDataIndexedDBHelper::DeleteIndexedDBInIndexedDBThread, | 54 &BrowsingDataIndexedDBHelper::DeleteIndexedDBInIndexedDBThread, |
55 this, | 55 this, |
56 origin)); | 56 origin)); |
57 } | 57 } |
58 | 58 |
59 void BrowsingDataIndexedDBHelper::FetchIndexedDBInfoInIndexedDBThread() { | 59 void BrowsingDataIndexedDBHelper::FetchIndexedDBInfoInIndexedDBThread() { |
60 DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); | 60 DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
61 std::vector<IndexedDBInfo> origins = indexed_db_context_->GetAllOriginsInfo(); | 61 std::vector<IndexedDBInfo> origins = indexed_db_context_->GetAllOriginsInfo(); |
62 for (std::vector<IndexedDBInfo>::const_iterator iter = origins.begin(); | 62 for (std::vector<IndexedDBInfo>::const_iterator iter = origins.begin(); |
63 iter != origins.end(); ++iter) { | 63 iter != origins.end(); ++iter) { |
64 const IndexedDBInfo& origin = *iter; | 64 const IndexedDBInfo& origin = *iter; |
65 if (!BrowsingDataHelper::HasWebScheme(origin.origin_)) | 65 if (!BrowsingDataHelper::HasWebScheme(origin.origin_)) |
66 continue; // Non-websafe state is not considered browsing data. | 66 continue; // Non-websafe state is not considered browsing data. |
67 | 67 |
68 indexed_db_info_.push_back(origin); | 68 indexed_db_info_.push_back(origin); |
69 } | 69 } |
70 | 70 |
71 BrowserThread::PostTask( | 71 BrowserThread::PostTask( |
72 BrowserThread::UI, FROM_HERE, | 72 BrowserThread::UI, FROM_HERE, |
73 base::Bind(&BrowsingDataIndexedDBHelper::NotifyInUIThread, this)); | 73 base::Bind(&BrowsingDataIndexedDBHelper::NotifyInUIThread, this)); |
74 } | 74 } |
75 | 75 |
76 void BrowsingDataIndexedDBHelper::NotifyInUIThread() { | 76 void BrowsingDataIndexedDBHelper::NotifyInUIThread() { |
77 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 77 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
78 DCHECK(is_fetching_); | 78 DCHECK(is_fetching_); |
79 completion_callback_.Run(indexed_db_info_); | 79 completion_callback_.Run(indexed_db_info_); |
80 completion_callback_.Reset(); | 80 completion_callback_.Reset(); |
81 is_fetching_ = false; | 81 is_fetching_ = false; |
82 } | 82 } |
83 | 83 |
84 void BrowsingDataIndexedDBHelper::DeleteIndexedDBInIndexedDBThread( | 84 void BrowsingDataIndexedDBHelper::DeleteIndexedDBInIndexedDBThread( |
85 const GURL& origin) { | 85 const GURL& origin) { |
86 DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); | 86 DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
87 indexed_db_context_->DeleteForOrigin(origin); | 87 indexed_db_context_->DeleteForOrigin(origin); |
(...skipping 18 matching lines...) Expand all Loading... |
106 } | 106 } |
107 | 107 |
108 CannedBrowsingDataIndexedDBHelper::CannedBrowsingDataIndexedDBHelper( | 108 CannedBrowsingDataIndexedDBHelper::CannedBrowsingDataIndexedDBHelper( |
109 content::IndexedDBContext* context) | 109 content::IndexedDBContext* context) |
110 : BrowsingDataIndexedDBHelper(context) { | 110 : BrowsingDataIndexedDBHelper(context) { |
111 } | 111 } |
112 | 112 |
113 CannedBrowsingDataIndexedDBHelper::~CannedBrowsingDataIndexedDBHelper() {} | 113 CannedBrowsingDataIndexedDBHelper::~CannedBrowsingDataIndexedDBHelper() {} |
114 | 114 |
115 CannedBrowsingDataIndexedDBHelper* CannedBrowsingDataIndexedDBHelper::Clone() { | 115 CannedBrowsingDataIndexedDBHelper* CannedBrowsingDataIndexedDBHelper::Clone() { |
116 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 116 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
117 CannedBrowsingDataIndexedDBHelper* clone = | 117 CannedBrowsingDataIndexedDBHelper* clone = |
118 new CannedBrowsingDataIndexedDBHelper(indexed_db_context_); | 118 new CannedBrowsingDataIndexedDBHelper(indexed_db_context_); |
119 | 119 |
120 clone->pending_indexed_db_info_ = pending_indexed_db_info_; | 120 clone->pending_indexed_db_info_ = pending_indexed_db_info_; |
121 clone->indexed_db_info_ = indexed_db_info_; | 121 clone->indexed_db_info_ = indexed_db_info_; |
122 return clone; | 122 return clone; |
123 } | 123 } |
124 | 124 |
125 void CannedBrowsingDataIndexedDBHelper::AddIndexedDB( | 125 void CannedBrowsingDataIndexedDBHelper::AddIndexedDB( |
126 const GURL& origin, const base::string16& name) { | 126 const GURL& origin, const base::string16& name) { |
(...skipping 16 matching lines...) Expand all Loading... |
143 return pending_indexed_db_info_.size(); | 143 return pending_indexed_db_info_.size(); |
144 } | 144 } |
145 | 145 |
146 const std::set<CannedBrowsingDataIndexedDBHelper::PendingIndexedDBInfo>& | 146 const std::set<CannedBrowsingDataIndexedDBHelper::PendingIndexedDBInfo>& |
147 CannedBrowsingDataIndexedDBHelper::GetIndexedDBInfo() const { | 147 CannedBrowsingDataIndexedDBHelper::GetIndexedDBInfo() const { |
148 return pending_indexed_db_info_; | 148 return pending_indexed_db_info_; |
149 } | 149 } |
150 | 150 |
151 void CannedBrowsingDataIndexedDBHelper::StartFetching( | 151 void CannedBrowsingDataIndexedDBHelper::StartFetching( |
152 const base::Callback<void(const std::list<IndexedDBInfo>&)>& callback) { | 152 const base::Callback<void(const std::list<IndexedDBInfo>&)>& callback) { |
153 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 153 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
154 DCHECK(!callback.is_null()); | 154 DCHECK(!callback.is_null()); |
155 | 155 |
156 std::list<IndexedDBInfo> result; | 156 std::list<IndexedDBInfo> result; |
157 for (std::set<PendingIndexedDBInfo>::const_iterator | 157 for (std::set<PendingIndexedDBInfo>::const_iterator |
158 pending_info = pending_indexed_db_info_.begin(); | 158 pending_info = pending_indexed_db_info_.begin(); |
159 pending_info != pending_indexed_db_info_.end(); ++pending_info) { | 159 pending_info != pending_indexed_db_info_.end(); ++pending_info) { |
160 IndexedDBInfo info( | 160 IndexedDBInfo info( |
161 pending_info->origin, 0, base::Time(), base::FilePath(), 0); | 161 pending_info->origin, 0, base::Time(), base::FilePath(), 0); |
162 result.push_back(info); | 162 result.push_back(info); |
163 } | 163 } |
164 | 164 |
165 BrowserThread::PostTask( | 165 BrowserThread::PostTask( |
166 BrowserThread::UI, FROM_HERE, base::Bind(callback, result)); | 166 BrowserThread::UI, FROM_HERE, base::Bind(callback, result)); |
167 } | 167 } |
168 | 168 |
169 void CannedBrowsingDataIndexedDBHelper::DeleteIndexedDB( | 169 void CannedBrowsingDataIndexedDBHelper::DeleteIndexedDB( |
170 const GURL& origin) { | 170 const GURL& origin) { |
171 for (std::set<PendingIndexedDBInfo>::iterator it = | 171 for (std::set<PendingIndexedDBInfo>::iterator it = |
172 pending_indexed_db_info_.begin(); | 172 pending_indexed_db_info_.begin(); |
173 it != pending_indexed_db_info_.end(); ) { | 173 it != pending_indexed_db_info_.end(); ) { |
174 if (it->origin == origin) | 174 if (it->origin == origin) |
175 pending_indexed_db_info_.erase(it++); | 175 pending_indexed_db_info_.erase(it++); |
176 else | 176 else |
177 ++it; | 177 ++it; |
178 } | 178 } |
179 BrowsingDataIndexedDBHelper::DeleteIndexedDB(origin); | 179 BrowsingDataIndexedDBHelper::DeleteIndexedDB(origin); |
180 } | 180 } |
OLD | NEW |