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 "net/ssl/default_channel_id_store.h" | 5 #include "net/ssl/default_channel_id_store.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "base/metrics/histogram.h" | 9 #include "base/metrics/histogram.h" |
| 10 #include "crypto/ec_private_key.h" |
10 #include "net/base/net_errors.h" | 11 #include "net/base/net_errors.h" |
11 | 12 |
12 namespace net { | 13 namespace net { |
13 | 14 |
14 // -------------------------------------------------------------------------- | 15 // -------------------------------------------------------------------------- |
15 // Task | 16 // Task |
16 class DefaultChannelIDStore::Task { | 17 class DefaultChannelIDStore::Task { |
17 public: | 18 public: |
18 virtual ~Task(); | 19 virtual ~Task(); |
19 | 20 |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
54 const GetChannelIDCallback& callback) | 55 const GetChannelIDCallback& callback) |
55 : server_identifier_(server_identifier), | 56 : server_identifier_(server_identifier), |
56 callback_(callback) { | 57 callback_(callback) { |
57 } | 58 } |
58 | 59 |
59 DefaultChannelIDStore::GetChannelIDTask::~GetChannelIDTask() { | 60 DefaultChannelIDStore::GetChannelIDTask::~GetChannelIDTask() { |
60 } | 61 } |
61 | 62 |
62 void DefaultChannelIDStore::GetChannelIDTask::Run( | 63 void DefaultChannelIDStore::GetChannelIDTask::Run( |
63 DefaultChannelIDStore* store) { | 64 DefaultChannelIDStore* store) { |
64 base::Time expiration_time; | 65 scoped_ptr<crypto::ECPrivateKey> key_result; |
65 std::string private_key_result; | 66 int err = store->GetChannelID(server_identifier_, &key_result, |
66 std::string cert_result; | 67 GetChannelIDCallback()); |
67 int err = store->GetChannelID( | |
68 server_identifier_, &expiration_time, &private_key_result, | |
69 &cert_result, GetChannelIDCallback()); | |
70 DCHECK(err != ERR_IO_PENDING); | 68 DCHECK(err != ERR_IO_PENDING); |
71 | 69 |
72 InvokeCallback(base::Bind(callback_, err, server_identifier_, | 70 InvokeCallback(base::Bind(callback_, err, server_identifier_, |
73 expiration_time, private_key_result, cert_result)); | 71 base::Passed(key_result.Pass()))); |
74 } | 72 } |
75 | 73 |
76 // -------------------------------------------------------------------------- | 74 // -------------------------------------------------------------------------- |
77 // SetChannelIDTask | 75 // SetChannelIDTask |
78 class DefaultChannelIDStore::SetChannelIDTask | 76 class DefaultChannelIDStore::SetChannelIDTask |
79 : public DefaultChannelIDStore::Task { | 77 : public DefaultChannelIDStore::Task { |
80 public: | 78 public: |
81 SetChannelIDTask(const std::string& server_identifier, | 79 SetChannelIDTask(scoped_ptr<ChannelID> channel_id); |
82 base::Time creation_time, | |
83 base::Time expiration_time, | |
84 const std::string& private_key, | |
85 const std::string& cert); | |
86 ~SetChannelIDTask() override; | 80 ~SetChannelIDTask() override; |
87 void Run(DefaultChannelIDStore* store) override; | 81 void Run(DefaultChannelIDStore* store) override; |
88 | 82 |
89 private: | 83 private: |
90 std::string server_identifier_; | 84 scoped_ptr<ChannelID> channel_id_; |
91 base::Time creation_time_; | |
92 base::Time expiration_time_; | |
93 std::string private_key_; | |
94 std::string cert_; | |
95 }; | 85 }; |
96 | 86 |
97 DefaultChannelIDStore::SetChannelIDTask::SetChannelIDTask( | 87 DefaultChannelIDStore::SetChannelIDTask::SetChannelIDTask( |
98 const std::string& server_identifier, | 88 scoped_ptr<ChannelID> channel_id) |
99 base::Time creation_time, | 89 : channel_id_(channel_id.Pass()) { |
100 base::Time expiration_time, | |
101 const std::string& private_key, | |
102 const std::string& cert) | |
103 : server_identifier_(server_identifier), | |
104 creation_time_(creation_time), | |
105 expiration_time_(expiration_time), | |
106 private_key_(private_key), | |
107 cert_(cert) { | |
108 } | 90 } |
109 | 91 |
110 DefaultChannelIDStore::SetChannelIDTask::~SetChannelIDTask() { | 92 DefaultChannelIDStore::SetChannelIDTask::~SetChannelIDTask() { |
111 } | 93 } |
112 | 94 |
113 void DefaultChannelIDStore::SetChannelIDTask::Run( | 95 void DefaultChannelIDStore::SetChannelIDTask::Run( |
114 DefaultChannelIDStore* store) { | 96 DefaultChannelIDStore* store) { |
115 store->SyncSetChannelID(server_identifier_, creation_time_, | 97 store->SyncSetChannelID(channel_id_.Pass()); |
116 expiration_time_, private_key_, cert_); | |
117 } | 98 } |
118 | 99 |
119 // -------------------------------------------------------------------------- | 100 // -------------------------------------------------------------------------- |
120 // DeleteChannelIDTask | 101 // DeleteChannelIDTask |
121 class DefaultChannelIDStore::DeleteChannelIDTask | 102 class DefaultChannelIDStore::DeleteChannelIDTask |
122 : public DefaultChannelIDStore::Task { | 103 : public DefaultChannelIDStore::Task { |
123 public: | 104 public: |
124 DeleteChannelIDTask(const std::string& server_identifier, | 105 DeleteChannelIDTask(const std::string& server_identifier, |
125 const base::Closure& callback); | 106 const base::Closure& callback); |
126 ~DeleteChannelIDTask() override; | 107 ~DeleteChannelIDTask() override; |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
206 GetAllChannelIDsTask(const GetChannelIDListCallback& callback) | 187 GetAllChannelIDsTask(const GetChannelIDListCallback& callback) |
207 : callback_(callback) { | 188 : callback_(callback) { |
208 } | 189 } |
209 | 190 |
210 DefaultChannelIDStore::GetAllChannelIDsTask:: | 191 DefaultChannelIDStore::GetAllChannelIDsTask:: |
211 ~GetAllChannelIDsTask() { | 192 ~GetAllChannelIDsTask() { |
212 } | 193 } |
213 | 194 |
214 void DefaultChannelIDStore::GetAllChannelIDsTask::Run( | 195 void DefaultChannelIDStore::GetAllChannelIDsTask::Run( |
215 DefaultChannelIDStore* store) { | 196 DefaultChannelIDStore* store) { |
216 ChannelIDList cert_list; | 197 ChannelIDList key_list; |
217 store->SyncGetAllChannelIDs(&cert_list); | 198 store->SyncGetAllChannelIDs(&key_list); |
218 | 199 |
219 InvokeCallback(base::Bind(callback_, cert_list)); | 200 InvokeCallback(base::Bind(callback_, key_list)); |
220 } | 201 } |
221 | 202 |
222 // -------------------------------------------------------------------------- | 203 // -------------------------------------------------------------------------- |
223 // DefaultChannelIDStore | 204 // DefaultChannelIDStore |
224 | 205 |
225 DefaultChannelIDStore::DefaultChannelIDStore( | 206 DefaultChannelIDStore::DefaultChannelIDStore( |
226 PersistentStore* store) | 207 PersistentStore* store) |
227 : initialized_(false), | 208 : initialized_(false), |
228 loaded_(false), | 209 loaded_(false), |
229 store_(store), | 210 store_(store), |
230 weak_ptr_factory_(this) {} | 211 weak_ptr_factory_(this) {} |
231 | 212 |
232 int DefaultChannelIDStore::GetChannelID( | 213 int DefaultChannelIDStore::GetChannelID( |
233 const std::string& server_identifier, | 214 const std::string& server_identifier, |
234 base::Time* expiration_time, | 215 scoped_ptr<crypto::ECPrivateKey>* key_result, |
235 std::string* private_key_result, | |
236 std::string* cert_result, | |
237 const GetChannelIDCallback& callback) { | 216 const GetChannelIDCallback& callback) { |
238 DCHECK(CalledOnValidThread()); | 217 DCHECK(CalledOnValidThread()); |
239 InitIfNecessary(); | 218 InitIfNecessary(); |
240 | 219 |
241 if (!loaded_) { | 220 if (!loaded_) { |
242 EnqueueTask(scoped_ptr<Task>( | 221 EnqueueTask(scoped_ptr<Task>( |
243 new GetChannelIDTask(server_identifier, callback))); | 222 new GetChannelIDTask(server_identifier, callback))); |
244 return ERR_IO_PENDING; | 223 return ERR_IO_PENDING; |
245 } | 224 } |
246 | 225 |
247 ChannelIDMap::iterator it = channel_ids_.find(server_identifier); | 226 ChannelIDMap::iterator it = channel_ids_.find(server_identifier); |
248 | 227 |
249 if (it == channel_ids_.end()) | 228 if (it == channel_ids_.end()) |
250 return ERR_FILE_NOT_FOUND; | 229 return ERR_FILE_NOT_FOUND; |
251 | 230 |
252 ChannelID* channel_id = it->second; | 231 ChannelID* channel_id = it->second; |
253 *expiration_time = channel_id->expiration_time(); | 232 key_result->reset(channel_id->key()->Copy()); |
254 *private_key_result = channel_id->private_key(); | |
255 *cert_result = channel_id->cert(); | |
256 | 233 |
257 return OK; | 234 return OK; |
258 } | 235 } |
259 | 236 |
260 void DefaultChannelIDStore::SetChannelID( | 237 void DefaultChannelIDStore::SetChannelID(scoped_ptr<ChannelID> channel_id) { |
261 const std::string& server_identifier, | 238 auto task = new SetChannelIDTask(channel_id.Pass()); |
262 base::Time creation_time, | 239 RunOrEnqueueTask(scoped_ptr<Task>(task)); |
263 base::Time expiration_time, | |
264 const std::string& private_key, | |
265 const std::string& cert) { | |
266 RunOrEnqueueTask(scoped_ptr<Task>(new SetChannelIDTask( | |
267 server_identifier, creation_time, expiration_time, private_key, | |
268 cert))); | |
269 } | 240 } |
270 | 241 |
271 void DefaultChannelIDStore::DeleteChannelID( | 242 void DefaultChannelIDStore::DeleteChannelID( |
272 const std::string& server_identifier, | 243 const std::string& server_identifier, |
273 const base::Closure& callback) { | 244 const base::Closure& callback) { |
274 RunOrEnqueueTask(scoped_ptr<Task>( | 245 RunOrEnqueueTask(scoped_ptr<Task>( |
275 new DeleteChannelIDTask(server_identifier, callback))); | 246 new DeleteChannelIDTask(server_identifier, callback))); |
276 } | 247 } |
277 | 248 |
278 void DefaultChannelIDStore::DeleteAllCreatedBetween( | 249 void DefaultChannelIDStore::DeleteAllCreatedBetween( |
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
356 UMA_HISTOGRAM_COUNTS_100("DomainBoundCerts.TaskWaitCount", | 327 UMA_HISTOGRAM_COUNTS_100("DomainBoundCerts.TaskWaitCount", |
357 waiting_tasks_.size()); | 328 waiting_tasks_.size()); |
358 | 329 |
359 | 330 |
360 for (ScopedVector<Task>::iterator i = waiting_tasks_.begin(); | 331 for (ScopedVector<Task>::iterator i = waiting_tasks_.begin(); |
361 i != waiting_tasks_.end(); ++i) | 332 i != waiting_tasks_.end(); ++i) |
362 (*i)->Run(this); | 333 (*i)->Run(this); |
363 waiting_tasks_.clear(); | 334 waiting_tasks_.clear(); |
364 } | 335 } |
365 | 336 |
366 void DefaultChannelIDStore::SyncSetChannelID( | 337 void DefaultChannelIDStore::SyncSetChannelID(scoped_ptr<ChannelID> channel_id) { |
367 const std::string& server_identifier, | |
368 base::Time creation_time, | |
369 base::Time expiration_time, | |
370 const std::string& private_key, | |
371 const std::string& cert) { | |
372 DCHECK(CalledOnValidThread()); | 338 DCHECK(CalledOnValidThread()); |
373 DCHECK(loaded_); | 339 DCHECK(loaded_); |
374 | 340 |
375 InternalDeleteChannelID(server_identifier); | 341 InternalDeleteChannelID(channel_id->server_identifier()); |
376 InternalInsertChannelID( | 342 InternalInsertChannelID(channel_id.Pass()); |
377 server_identifier, | |
378 new ChannelID( | |
379 server_identifier, creation_time, expiration_time, private_key, | |
380 cert)); | |
381 } | 343 } |
382 | 344 |
383 void DefaultChannelIDStore::SyncDeleteChannelID( | 345 void DefaultChannelIDStore::SyncDeleteChannelID( |
384 const std::string& server_identifier) { | 346 const std::string& server_identifier) { |
385 DCHECK(CalledOnValidThread()); | 347 DCHECK(CalledOnValidThread()); |
386 DCHECK(loaded_); | 348 DCHECK(loaded_); |
387 InternalDeleteChannelID(server_identifier); | 349 InternalDeleteChannelID(server_identifier); |
388 } | 350 } |
389 | 351 |
390 void DefaultChannelIDStore::SyncDeleteAllCreatedBetween( | 352 void DefaultChannelIDStore::SyncDeleteAllCreatedBetween( |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
447 return; // There is nothing to delete. | 409 return; // There is nothing to delete. |
448 | 410 |
449 ChannelID* channel_id = it->second; | 411 ChannelID* channel_id = it->second; |
450 if (store_.get()) | 412 if (store_.get()) |
451 store_->DeleteChannelID(*channel_id); | 413 store_->DeleteChannelID(*channel_id); |
452 channel_ids_.erase(it); | 414 channel_ids_.erase(it); |
453 delete channel_id; | 415 delete channel_id; |
454 } | 416 } |
455 | 417 |
456 void DefaultChannelIDStore::InternalInsertChannelID( | 418 void DefaultChannelIDStore::InternalInsertChannelID( |
457 const std::string& server_identifier, | 419 scoped_ptr<ChannelID> channel_id) { |
458 ChannelID* channel_id) { | |
459 DCHECK(CalledOnValidThread()); | 420 DCHECK(CalledOnValidThread()); |
460 DCHECK(loaded_); | 421 DCHECK(loaded_); |
461 | 422 |
462 if (store_.get()) | 423 if (store_.get()) |
463 store_->AddChannelID(*channel_id); | 424 store_->AddChannelID(*(channel_id.get())); |
464 channel_ids_[server_identifier] = channel_id; | 425 const std::string& server_identifier = channel_id->server_identifier(); |
| 426 channel_ids_[server_identifier] = channel_id.release(); |
465 } | 427 } |
466 | 428 |
467 DefaultChannelIDStore::PersistentStore::PersistentStore() {} | 429 DefaultChannelIDStore::PersistentStore::PersistentStore() {} |
468 | 430 |
469 DefaultChannelIDStore::PersistentStore::~PersistentStore() {} | 431 DefaultChannelIDStore::PersistentStore::~PersistentStore() {} |
470 | 432 |
471 } // namespace net | 433 } // namespace net |
OLD | NEW |