OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 <stdint.h> | 5 #include <stdint.h> |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/files/file_path.h" | 10 #include "base/files/file_path.h" |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
47 storage::GetOriginFromIdentifier(origin_identifier)); | 47 storage::GetOriginFromIdentifier(origin_identifier)); |
48 if (found == mock_origin_infos_.end()) | 48 if (found == mock_origin_infos_.end()) |
49 return false; | 49 return false; |
50 *info = OriginInfo(found->second); | 50 *info = OriginInfo(found->second); |
51 return true; | 51 return true; |
52 } | 52 } |
53 | 53 |
54 bool GetAllOriginIdentifiers( | 54 bool GetAllOriginIdentifiers( |
55 std::vector<std::string>* origins_identifiers) override { | 55 std::vector<std::string>* origins_identifiers) override { |
56 std::map<GURL, MockOriginInfo>::const_iterator iter; | 56 std::map<GURL, MockOriginInfo>::const_iterator iter; |
57 for (iter = mock_origin_infos_.begin(); | 57 for (iter = mock_origin_infos_.begin(); iter != mock_origin_infos_.end(); |
58 iter != mock_origin_infos_.end(); | |
59 ++iter) { | 58 ++iter) { |
60 origins_identifiers->push_back(iter->second.GetOriginIdentifier()); | 59 origins_identifiers->push_back(iter->second.GetOriginIdentifier()); |
61 } | 60 } |
62 return true; | 61 return true; |
63 } | 62 } |
64 | 63 |
65 bool GetAllOriginsInfo(std::vector<OriginInfo>* origins_info) override { | 64 bool GetAllOriginsInfo(std::vector<OriginInfo>* origins_info) override { |
66 std::map<GURL, MockOriginInfo>::const_iterator iter; | 65 std::map<GURL, MockOriginInfo>::const_iterator iter; |
67 for (iter = mock_origin_infos_.begin(); | 66 for (iter = mock_origin_infos_.begin(); iter != mock_origin_infos_.end(); |
68 iter != mock_origin_infos_.end(); | |
69 ++iter) { | 67 ++iter) { |
70 origins_info->push_back(OriginInfo(iter->second)); | 68 origins_info->push_back(OriginInfo(iter->second)); |
71 } | 69 } |
72 return true; | 70 return true; |
73 } | 71 } |
74 | 72 |
75 int DeleteDataForOrigin(const std::string& origin_identifier, | 73 int DeleteDataForOrigin(const std::string& origin_identifier, |
76 const net::CompletionCallback& callback) override { | 74 const net::CompletionCallback& callback) override { |
77 ++delete_called_count_; | 75 ++delete_called_count_; |
78 if (async_delete()) { | 76 if (async_delete()) { |
79 base::ThreadTaskRunnerHandle::Get()->PostTask( | 77 base::ThreadTaskRunnerHandle::Get()->PostTask( |
80 FROM_HERE, base::Bind(&MockDatabaseTracker::AsyncDeleteDataForOrigin, | 78 FROM_HERE, base::Bind(&MockDatabaseTracker::AsyncDeleteDataForOrigin, |
81 this, callback)); | 79 this, callback)); |
82 return net::ERR_IO_PENDING; | 80 return net::ERR_IO_PENDING; |
83 } | 81 } |
84 return net::OK; | 82 return net::OK; |
85 } | 83 } |
86 | 84 |
87 void AsyncDeleteDataForOrigin(const net::CompletionCallback& callback) { | 85 void AsyncDeleteDataForOrigin(const net::CompletionCallback& callback) { |
88 callback.Run(net::OK); | 86 callback.Run(net::OK); |
89 } | 87 } |
90 | 88 |
91 void AddMockDatabase(const GURL& origin, const char* name, int size) { | 89 void AddMockDatabase(const GURL& origin, const char* name, int size) { |
92 MockOriginInfo& info = mock_origin_infos_[origin]; | 90 MockOriginInfo& info = mock_origin_infos_[origin]; |
93 info.set_origin(storage::GetIdentifierFromOrigin(origin)); | 91 info.set_origin(storage::GetIdentifierFromOrigin(origin)); |
94 info.AddMockDatabase(base::ASCIIToUTF16(name), size); | 92 info.AddMockDatabase(base::ASCIIToUTF16(name), size); |
95 } | 93 } |
96 | 94 |
97 int delete_called_count() { return delete_called_count_; } | 95 int delete_called_count() { return delete_called_count_; } |
98 bool async_delete() { return async_delete_; } | 96 bool async_delete() { return async_delete_; } |
99 void set_async_delete(bool async) { async_delete_ = async; } | 97 void set_async_delete(bool async) { async_delete_ = async; } |
100 | 98 |
101 protected: | 99 protected: |
(...skipping 11 matching lines...) Expand all Loading... |
113 database_info_[name].first = size; | 111 database_info_[name].first = size; |
114 total_size_ += size; | 112 total_size_ += size; |
115 } | 113 } |
116 }; | 114 }; |
117 | 115 |
118 int delete_called_count_; | 116 int delete_called_count_; |
119 bool async_delete_; | 117 bool async_delete_; |
120 std::map<GURL, MockOriginInfo> mock_origin_infos_; | 118 std::map<GURL, MockOriginInfo> mock_origin_infos_; |
121 }; | 119 }; |
122 | 120 |
123 | |
124 // Base class for our test fixtures. | 121 // Base class for our test fixtures. |
125 class DatabaseQuotaClientTest : public testing::Test { | 122 class DatabaseQuotaClientTest : public testing::Test { |
126 public: | 123 public: |
127 const GURL kOriginA; | 124 const GURL kOriginA; |
128 const GURL kOriginB; | 125 const GURL kOriginB; |
129 const GURL kOriginOther; | 126 const GURL kOriginOther; |
130 | 127 |
131 DatabaseQuotaClientTest() | 128 DatabaseQuotaClientTest() |
132 : kOriginA("http://host"), | 129 : kOriginA("http://host"), |
133 kOriginB("http://host:8000"), | 130 kOriginB("http://host:8000"), |
134 kOriginOther("http://other"), | 131 kOriginOther("http://other"), |
135 usage_(0), | 132 usage_(0), |
136 mock_tracker_(new MockDatabaseTracker), | 133 mock_tracker_(new MockDatabaseTracker), |
137 weak_factory_(this) { | 134 weak_factory_(this) {} |
138 } | |
139 | 135 |
140 int64_t GetOriginUsage(storage::QuotaClient* client, | 136 int64_t GetOriginUsage(storage::QuotaClient* client, |
141 const GURL& origin, | 137 const GURL& origin, |
142 storage::StorageType type) { | 138 storage::StorageType type) { |
143 usage_ = 0; | 139 usage_ = 0; |
144 client->GetOriginUsage( | 140 client->GetOriginUsage( |
145 origin, type, | 141 origin, type, |
146 base::Bind(&DatabaseQuotaClientTest::OnGetOriginUsageComplete, | 142 base::Bind(&DatabaseQuotaClientTest::OnGetOriginUsageComplete, |
147 weak_factory_.GetWeakPtr())); | 143 weak_factory_.GetWeakPtr())); |
148 base::RunLoop().RunUntilIdle(); | 144 base::RunLoop().RunUntilIdle(); |
149 return usage_; | 145 return usage_; |
150 } | 146 } |
151 | 147 |
152 const std::set<GURL>& GetOriginsForType(storage::QuotaClient* client, | 148 const std::set<GURL>& GetOriginsForType(storage::QuotaClient* client, |
153 storage::StorageType type) { | 149 storage::StorageType type) { |
154 origins_.clear(); | 150 origins_.clear(); |
155 client->GetOriginsForType( | 151 client->GetOriginsForType( |
156 type, | 152 type, base::Bind(&DatabaseQuotaClientTest::OnGetOriginsComplete, |
157 base::Bind(&DatabaseQuotaClientTest::OnGetOriginsComplete, | 153 weak_factory_.GetWeakPtr())); |
158 weak_factory_.GetWeakPtr())); | |
159 base::RunLoop().RunUntilIdle(); | 154 base::RunLoop().RunUntilIdle(); |
160 return origins_; | 155 return origins_; |
161 } | 156 } |
162 | 157 |
163 const std::set<GURL>& GetOriginsForHost(storage::QuotaClient* client, | 158 const std::set<GURL>& GetOriginsForHost(storage::QuotaClient* client, |
164 storage::StorageType type, | 159 storage::StorageType type, |
165 const std::string& host) { | 160 const std::string& host) { |
166 origins_.clear(); | 161 origins_.clear(); |
167 client->GetOriginsForHost( | 162 client->GetOriginsForHost( |
168 type, host, | 163 type, host, |
(...skipping 10 matching lines...) Expand all Loading... |
179 client->DeleteOriginData( | 174 client->DeleteOriginData( |
180 origin, type, | 175 origin, type, |
181 base::Bind(&DatabaseQuotaClientTest::OnDeleteOriginDataComplete, | 176 base::Bind(&DatabaseQuotaClientTest::OnDeleteOriginDataComplete, |
182 weak_factory_.GetWeakPtr())); | 177 weak_factory_.GetWeakPtr())); |
183 base::RunLoop().RunUntilIdle(); | 178 base::RunLoop().RunUntilIdle(); |
184 return delete_status_ == storage::kQuotaStatusOk; | 179 return delete_status_ == storage::kQuotaStatusOk; |
185 } | 180 } |
186 | 181 |
187 MockDatabaseTracker* mock_tracker() { return mock_tracker_.get(); } | 182 MockDatabaseTracker* mock_tracker() { return mock_tracker_.get(); } |
188 | 183 |
189 | |
190 private: | 184 private: |
191 void OnGetOriginUsageComplete(int64_t usage) { usage_ = usage; } | 185 void OnGetOriginUsageComplete(int64_t usage) { usage_ = usage; } |
192 | 186 |
193 void OnGetOriginsComplete(const std::set<GURL>& origins) { | 187 void OnGetOriginsComplete(const std::set<GURL>& origins) { |
194 origins_ = origins; | 188 origins_ = origins; |
195 } | 189 } |
196 | 190 |
197 void OnDeleteOriginDataComplete(storage::QuotaStatusCode status) { | 191 void OnDeleteOriginDataComplete(storage::QuotaStatusCode status) { |
198 delete_status_ = status; | 192 delete_status_ = status; |
199 } | 193 } |
200 | 194 |
201 base::MessageLoop message_loop_; | 195 base::MessageLoop message_loop_; |
202 int64_t usage_; | 196 int64_t usage_; |
203 std::set<GURL> origins_; | 197 std::set<GURL> origins_; |
204 storage::QuotaStatusCode delete_status_; | 198 storage::QuotaStatusCode delete_status_; |
205 scoped_refptr<MockDatabaseTracker> mock_tracker_; | 199 scoped_refptr<MockDatabaseTracker> mock_tracker_; |
206 base::WeakPtrFactory<DatabaseQuotaClientTest> weak_factory_; | 200 base::WeakPtrFactory<DatabaseQuotaClientTest> weak_factory_; |
207 }; | 201 }; |
208 | 202 |
209 | |
210 TEST_F(DatabaseQuotaClientTest, GetOriginUsage) { | 203 TEST_F(DatabaseQuotaClientTest, GetOriginUsage) { |
211 DatabaseQuotaClient client(base::ThreadTaskRunnerHandle::Get().get(), | 204 DatabaseQuotaClient client(base::ThreadTaskRunnerHandle::Get().get(), |
212 mock_tracker()); | 205 mock_tracker()); |
213 | 206 |
214 EXPECT_EQ(0, GetOriginUsage(&client, kOriginA, kTemp)); | 207 EXPECT_EQ(0, GetOriginUsage(&client, kOriginA, kTemp)); |
215 EXPECT_EQ(0, GetOriginUsage(&client, kOriginA, kPerm)); | 208 EXPECT_EQ(0, GetOriginUsage(&client, kOriginA, kPerm)); |
216 | 209 |
217 mock_tracker()->AddMockDatabase(kOriginA, "fooDB", 1000); | 210 mock_tracker()->AddMockDatabase(kOriginA, "fooDB", 1000); |
218 EXPECT_EQ(1000, GetOriginUsage(&client, kOriginA, kTemp)); | 211 EXPECT_EQ(1000, GetOriginUsage(&client, kOriginA, kTemp)); |
219 EXPECT_EQ(0, GetOriginUsage(&client, kOriginA, kPerm)); | 212 EXPECT_EQ(0, GetOriginUsage(&client, kOriginA, kPerm)); |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
274 mock_tracker()->set_async_delete(false); | 267 mock_tracker()->set_async_delete(false); |
275 EXPECT_TRUE(DeleteOriginData(&client, kTemp, kOriginA)); | 268 EXPECT_TRUE(DeleteOriginData(&client, kTemp, kOriginA)); |
276 EXPECT_EQ(1, mock_tracker()->delete_called_count()); | 269 EXPECT_EQ(1, mock_tracker()->delete_called_count()); |
277 | 270 |
278 mock_tracker()->set_async_delete(true); | 271 mock_tracker()->set_async_delete(true); |
279 EXPECT_TRUE(DeleteOriginData(&client, kTemp, kOriginA)); | 272 EXPECT_TRUE(DeleteOriginData(&client, kTemp, kOriginA)); |
280 EXPECT_EQ(2, mock_tracker()->delete_called_count()); | 273 EXPECT_EQ(2, mock_tracker()->delete_called_count()); |
281 } | 274 } |
282 | 275 |
283 } // namespace content | 276 } // namespace content |
OLD | NEW |