| 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 |