| Index: net/ssl/default_channel_id_store.cc
|
| diff --git a/net/ssl/default_channel_id_store.cc b/net/ssl/default_channel_id_store.cc
|
| deleted file mode 100644
|
| index b71d7b3507e13dda8267e21466fdc0e3cd2b35e3..0000000000000000000000000000000000000000
|
| --- a/net/ssl/default_channel_id_store.cc
|
| +++ /dev/null
|
| @@ -1,471 +0,0 @@
|
| -// Copyright 2014 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "net/ssl/default_channel_id_store.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/metrics/histogram.h"
|
| -#include "net/base/net_errors.h"
|
| -
|
| -namespace net {
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// Task
|
| -class DefaultChannelIDStore::Task {
|
| - public:
|
| - virtual ~Task();
|
| -
|
| - // Runs the task and invokes the client callback on the thread that
|
| - // originally constructed the task.
|
| - virtual void Run(DefaultChannelIDStore* store) = 0;
|
| -
|
| - protected:
|
| - void InvokeCallback(base::Closure callback) const;
|
| -};
|
| -
|
| -DefaultChannelIDStore::Task::~Task() {
|
| -}
|
| -
|
| -void DefaultChannelIDStore::Task::InvokeCallback(
|
| - base::Closure callback) const {
|
| - if (!callback.is_null())
|
| - callback.Run();
|
| -}
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// GetChannelIDTask
|
| -class DefaultChannelIDStore::GetChannelIDTask
|
| - : public DefaultChannelIDStore::Task {
|
| - public:
|
| - GetChannelIDTask(const std::string& server_identifier,
|
| - const GetChannelIDCallback& callback);
|
| - ~GetChannelIDTask() override;
|
| - void Run(DefaultChannelIDStore* store) override;
|
| -
|
| - private:
|
| - std::string server_identifier_;
|
| - GetChannelIDCallback callback_;
|
| -};
|
| -
|
| -DefaultChannelIDStore::GetChannelIDTask::GetChannelIDTask(
|
| - const std::string& server_identifier,
|
| - const GetChannelIDCallback& callback)
|
| - : server_identifier_(server_identifier),
|
| - callback_(callback) {
|
| -}
|
| -
|
| -DefaultChannelIDStore::GetChannelIDTask::~GetChannelIDTask() {
|
| -}
|
| -
|
| -void DefaultChannelIDStore::GetChannelIDTask::Run(
|
| - DefaultChannelIDStore* store) {
|
| - base::Time expiration_time;
|
| - std::string private_key_result;
|
| - std::string cert_result;
|
| - int err = store->GetChannelID(
|
| - server_identifier_, &expiration_time, &private_key_result,
|
| - &cert_result, GetChannelIDCallback());
|
| - DCHECK(err != ERR_IO_PENDING);
|
| -
|
| - InvokeCallback(base::Bind(callback_, err, server_identifier_,
|
| - expiration_time, private_key_result, cert_result));
|
| -}
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// SetChannelIDTask
|
| -class DefaultChannelIDStore::SetChannelIDTask
|
| - : public DefaultChannelIDStore::Task {
|
| - public:
|
| - SetChannelIDTask(const std::string& server_identifier,
|
| - base::Time creation_time,
|
| - base::Time expiration_time,
|
| - const std::string& private_key,
|
| - const std::string& cert);
|
| - ~SetChannelIDTask() override;
|
| - void Run(DefaultChannelIDStore* store) override;
|
| -
|
| - private:
|
| - std::string server_identifier_;
|
| - base::Time creation_time_;
|
| - base::Time expiration_time_;
|
| - std::string private_key_;
|
| - std::string cert_;
|
| -};
|
| -
|
| -DefaultChannelIDStore::SetChannelIDTask::SetChannelIDTask(
|
| - const std::string& server_identifier,
|
| - base::Time creation_time,
|
| - base::Time expiration_time,
|
| - const std::string& private_key,
|
| - const std::string& cert)
|
| - : server_identifier_(server_identifier),
|
| - creation_time_(creation_time),
|
| - expiration_time_(expiration_time),
|
| - private_key_(private_key),
|
| - cert_(cert) {
|
| -}
|
| -
|
| -DefaultChannelIDStore::SetChannelIDTask::~SetChannelIDTask() {
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SetChannelIDTask::Run(
|
| - DefaultChannelIDStore* store) {
|
| - store->SyncSetChannelID(server_identifier_, creation_time_,
|
| - expiration_time_, private_key_, cert_);
|
| -}
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// DeleteChannelIDTask
|
| -class DefaultChannelIDStore::DeleteChannelIDTask
|
| - : public DefaultChannelIDStore::Task {
|
| - public:
|
| - DeleteChannelIDTask(const std::string& server_identifier,
|
| - const base::Closure& callback);
|
| - ~DeleteChannelIDTask() override;
|
| - void Run(DefaultChannelIDStore* store) override;
|
| -
|
| - private:
|
| - std::string server_identifier_;
|
| - base::Closure callback_;
|
| -};
|
| -
|
| -DefaultChannelIDStore::DeleteChannelIDTask::
|
| - DeleteChannelIDTask(
|
| - const std::string& server_identifier,
|
| - const base::Closure& callback)
|
| - : server_identifier_(server_identifier),
|
| - callback_(callback) {
|
| -}
|
| -
|
| -DefaultChannelIDStore::DeleteChannelIDTask::
|
| - ~DeleteChannelIDTask() {
|
| -}
|
| -
|
| -void DefaultChannelIDStore::DeleteChannelIDTask::Run(
|
| - DefaultChannelIDStore* store) {
|
| - store->SyncDeleteChannelID(server_identifier_);
|
| -
|
| - InvokeCallback(callback_);
|
| -}
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// DeleteAllCreatedBetweenTask
|
| -class DefaultChannelIDStore::DeleteAllCreatedBetweenTask
|
| - : public DefaultChannelIDStore::Task {
|
| - public:
|
| - DeleteAllCreatedBetweenTask(base::Time delete_begin,
|
| - base::Time delete_end,
|
| - const base::Closure& callback);
|
| - ~DeleteAllCreatedBetweenTask() override;
|
| - void Run(DefaultChannelIDStore* store) override;
|
| -
|
| - private:
|
| - base::Time delete_begin_;
|
| - base::Time delete_end_;
|
| - base::Closure callback_;
|
| -};
|
| -
|
| -DefaultChannelIDStore::DeleteAllCreatedBetweenTask::
|
| - DeleteAllCreatedBetweenTask(
|
| - base::Time delete_begin,
|
| - base::Time delete_end,
|
| - const base::Closure& callback)
|
| - : delete_begin_(delete_begin),
|
| - delete_end_(delete_end),
|
| - callback_(callback) {
|
| -}
|
| -
|
| -DefaultChannelIDStore::DeleteAllCreatedBetweenTask::
|
| - ~DeleteAllCreatedBetweenTask() {
|
| -}
|
| -
|
| -void DefaultChannelIDStore::DeleteAllCreatedBetweenTask::Run(
|
| - DefaultChannelIDStore* store) {
|
| - store->SyncDeleteAllCreatedBetween(delete_begin_, delete_end_);
|
| -
|
| - InvokeCallback(callback_);
|
| -}
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// GetAllChannelIDsTask
|
| -class DefaultChannelIDStore::GetAllChannelIDsTask
|
| - : public DefaultChannelIDStore::Task {
|
| - public:
|
| - explicit GetAllChannelIDsTask(const GetChannelIDListCallback& callback);
|
| - ~GetAllChannelIDsTask() override;
|
| - void Run(DefaultChannelIDStore* store) override;
|
| -
|
| - private:
|
| - std::string server_identifier_;
|
| - GetChannelIDListCallback callback_;
|
| -};
|
| -
|
| -DefaultChannelIDStore::GetAllChannelIDsTask::
|
| - GetAllChannelIDsTask(const GetChannelIDListCallback& callback)
|
| - : callback_(callback) {
|
| -}
|
| -
|
| -DefaultChannelIDStore::GetAllChannelIDsTask::
|
| - ~GetAllChannelIDsTask() {
|
| -}
|
| -
|
| -void DefaultChannelIDStore::GetAllChannelIDsTask::Run(
|
| - DefaultChannelIDStore* store) {
|
| - ChannelIDList cert_list;
|
| - store->SyncGetAllChannelIDs(&cert_list);
|
| -
|
| - InvokeCallback(base::Bind(callback_, cert_list));
|
| -}
|
| -
|
| -// --------------------------------------------------------------------------
|
| -// DefaultChannelIDStore
|
| -
|
| -DefaultChannelIDStore::DefaultChannelIDStore(
|
| - PersistentStore* store)
|
| - : initialized_(false),
|
| - loaded_(false),
|
| - store_(store),
|
| - weak_ptr_factory_(this) {}
|
| -
|
| -int DefaultChannelIDStore::GetChannelID(
|
| - const std::string& server_identifier,
|
| - base::Time* expiration_time,
|
| - std::string* private_key_result,
|
| - std::string* cert_result,
|
| - const GetChannelIDCallback& callback) {
|
| - DCHECK(CalledOnValidThread());
|
| - InitIfNecessary();
|
| -
|
| - if (!loaded_) {
|
| - EnqueueTask(scoped_ptr<Task>(
|
| - new GetChannelIDTask(server_identifier, callback)));
|
| - return ERR_IO_PENDING;
|
| - }
|
| -
|
| - ChannelIDMap::iterator it = channel_ids_.find(server_identifier);
|
| -
|
| - if (it == channel_ids_.end())
|
| - return ERR_FILE_NOT_FOUND;
|
| -
|
| - ChannelID* channel_id = it->second;
|
| - *expiration_time = channel_id->expiration_time();
|
| - *private_key_result = channel_id->private_key();
|
| - *cert_result = channel_id->cert();
|
| -
|
| - return OK;
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SetChannelID(
|
| - const std::string& server_identifier,
|
| - base::Time creation_time,
|
| - base::Time expiration_time,
|
| - const std::string& private_key,
|
| - const std::string& cert) {
|
| - RunOrEnqueueTask(scoped_ptr<Task>(new SetChannelIDTask(
|
| - server_identifier, creation_time, expiration_time, private_key,
|
| - cert)));
|
| -}
|
| -
|
| -void DefaultChannelIDStore::DeleteChannelID(
|
| - const std::string& server_identifier,
|
| - const base::Closure& callback) {
|
| - RunOrEnqueueTask(scoped_ptr<Task>(
|
| - new DeleteChannelIDTask(server_identifier, callback)));
|
| -}
|
| -
|
| -void DefaultChannelIDStore::DeleteAllCreatedBetween(
|
| - base::Time delete_begin,
|
| - base::Time delete_end,
|
| - const base::Closure& callback) {
|
| - RunOrEnqueueTask(scoped_ptr<Task>(
|
| - new DeleteAllCreatedBetweenTask(delete_begin, delete_end, callback)));
|
| -}
|
| -
|
| -void DefaultChannelIDStore::DeleteAll(
|
| - const base::Closure& callback) {
|
| - DeleteAllCreatedBetween(base::Time(), base::Time(), callback);
|
| -}
|
| -
|
| -void DefaultChannelIDStore::GetAllChannelIDs(
|
| - const GetChannelIDListCallback& callback) {
|
| - RunOrEnqueueTask(scoped_ptr<Task>(new GetAllChannelIDsTask(callback)));
|
| -}
|
| -
|
| -int DefaultChannelIDStore::GetChannelIDCount() {
|
| - DCHECK(CalledOnValidThread());
|
| -
|
| - return channel_ids_.size();
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SetForceKeepSessionState() {
|
| - DCHECK(CalledOnValidThread());
|
| - InitIfNecessary();
|
| -
|
| - if (store_.get())
|
| - store_->SetForceKeepSessionState();
|
| -}
|
| -
|
| -DefaultChannelIDStore::~DefaultChannelIDStore() {
|
| - DeleteAllInMemory();
|
| -}
|
| -
|
| -void DefaultChannelIDStore::DeleteAllInMemory() {
|
| - DCHECK(CalledOnValidThread());
|
| -
|
| - for (ChannelIDMap::iterator it = channel_ids_.begin();
|
| - it != channel_ids_.end(); ++it) {
|
| - delete it->second;
|
| - }
|
| - channel_ids_.clear();
|
| -}
|
| -
|
| -void DefaultChannelIDStore::InitStore() {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(store_.get()) << "Store must exist to initialize";
|
| - DCHECK(!loaded_);
|
| -
|
| - store_->Load(base::Bind(&DefaultChannelIDStore::OnLoaded,
|
| - weak_ptr_factory_.GetWeakPtr()));
|
| -}
|
| -
|
| -void DefaultChannelIDStore::OnLoaded(
|
| - scoped_ptr<ScopedVector<ChannelID> > channel_ids) {
|
| - DCHECK(CalledOnValidThread());
|
| -
|
| - for (std::vector<ChannelID*>::const_iterator it = channel_ids->begin();
|
| - it != channel_ids->end(); ++it) {
|
| - DCHECK(channel_ids_.find((*it)->server_identifier()) ==
|
| - channel_ids_.end());
|
| - channel_ids_[(*it)->server_identifier()] = *it;
|
| - }
|
| - channel_ids->weak_clear();
|
| -
|
| - loaded_ = true;
|
| -
|
| - base::TimeDelta wait_time;
|
| - if (!waiting_tasks_.empty())
|
| - wait_time = base::TimeTicks::Now() - waiting_tasks_start_time_;
|
| - DVLOG(1) << "Task delay " << wait_time.InMilliseconds();
|
| - UMA_HISTOGRAM_CUSTOM_TIMES("DomainBoundCerts.TaskMaxWaitTime",
|
| - wait_time,
|
| - base::TimeDelta::FromMilliseconds(1),
|
| - base::TimeDelta::FromMinutes(1),
|
| - 50);
|
| - UMA_HISTOGRAM_COUNTS_100("DomainBoundCerts.TaskWaitCount",
|
| - waiting_tasks_.size());
|
| -
|
| -
|
| - for (ScopedVector<Task>::iterator i = waiting_tasks_.begin();
|
| - i != waiting_tasks_.end(); ++i)
|
| - (*i)->Run(this);
|
| - waiting_tasks_.clear();
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SyncSetChannelID(
|
| - const std::string& server_identifier,
|
| - base::Time creation_time,
|
| - base::Time expiration_time,
|
| - const std::string& private_key,
|
| - const std::string& cert) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(loaded_);
|
| -
|
| - InternalDeleteChannelID(server_identifier);
|
| - InternalInsertChannelID(
|
| - server_identifier,
|
| - new ChannelID(
|
| - server_identifier, creation_time, expiration_time, private_key,
|
| - cert));
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SyncDeleteChannelID(
|
| - const std::string& server_identifier) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(loaded_);
|
| - InternalDeleteChannelID(server_identifier);
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SyncDeleteAllCreatedBetween(
|
| - base::Time delete_begin,
|
| - base::Time delete_end) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(loaded_);
|
| - for (ChannelIDMap::iterator it = channel_ids_.begin();
|
| - it != channel_ids_.end();) {
|
| - ChannelIDMap::iterator cur = it;
|
| - ++it;
|
| - ChannelID* channel_id = cur->second;
|
| - if ((delete_begin.is_null() ||
|
| - channel_id->creation_time() >= delete_begin) &&
|
| - (delete_end.is_null() || channel_id->creation_time() < delete_end)) {
|
| - if (store_.get())
|
| - store_->DeleteChannelID(*channel_id);
|
| - delete channel_id;
|
| - channel_ids_.erase(cur);
|
| - }
|
| - }
|
| -}
|
| -
|
| -void DefaultChannelIDStore::SyncGetAllChannelIDs(
|
| - ChannelIDList* channel_id_list) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(loaded_);
|
| - for (ChannelIDMap::iterator it = channel_ids_.begin();
|
| - it != channel_ids_.end(); ++it)
|
| - channel_id_list->push_back(*it->second);
|
| -}
|
| -
|
| -void DefaultChannelIDStore::EnqueueTask(scoped_ptr<Task> task) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(!loaded_);
|
| - if (waiting_tasks_.empty())
|
| - waiting_tasks_start_time_ = base::TimeTicks::Now();
|
| - waiting_tasks_.push_back(task.release());
|
| -}
|
| -
|
| -void DefaultChannelIDStore::RunOrEnqueueTask(scoped_ptr<Task> task) {
|
| - DCHECK(CalledOnValidThread());
|
| - InitIfNecessary();
|
| -
|
| - if (!loaded_) {
|
| - EnqueueTask(task.Pass());
|
| - return;
|
| - }
|
| -
|
| - task->Run(this);
|
| -}
|
| -
|
| -void DefaultChannelIDStore::InternalDeleteChannelID(
|
| - const std::string& server_identifier) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(loaded_);
|
| -
|
| - ChannelIDMap::iterator it = channel_ids_.find(server_identifier);
|
| - if (it == channel_ids_.end())
|
| - return; // There is nothing to delete.
|
| -
|
| - ChannelID* channel_id = it->second;
|
| - if (store_.get())
|
| - store_->DeleteChannelID(*channel_id);
|
| - channel_ids_.erase(it);
|
| - delete channel_id;
|
| -}
|
| -
|
| -void DefaultChannelIDStore::InternalInsertChannelID(
|
| - const std::string& server_identifier,
|
| - ChannelID* channel_id) {
|
| - DCHECK(CalledOnValidThread());
|
| - DCHECK(loaded_);
|
| -
|
| - if (store_.get())
|
| - store_->AddChannelID(*channel_id);
|
| - channel_ids_[server_identifier] = channel_id;
|
| -}
|
| -
|
| -DefaultChannelIDStore::PersistentStore::PersistentStore() {}
|
| -
|
| -DefaultChannelIDStore::PersistentStore::~PersistentStore() {}
|
| -
|
| -} // namespace net
|
|
|