blob: 346ac95405b82cbd5e51e980c212981cea073ab6 [file] [log] [blame]
// Copyright 2018 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 "services/network/crl_set_distributor.h"
#include <string>
#include "base/bind.h"
#include "base/containers/span.h"
#include "base/location.h"
#include "base/strings/string_piece.h"
#include "base/task/post_task.h"
namespace network {
namespace {
// Attempts to parse |crl_set|, returning nullptr on error or the parsed
// CRLSet.
scoped_refptr<net::CRLSet> ParseCRLSet(std::string crl_set) {
scoped_refptr<net::CRLSet> result;
if (!net::CRLSet::Parse(crl_set, &result))
return nullptr;
return result;
}
} // namespace
CRLSetDistributor::CRLSetDistributor() {}
CRLSetDistributor::~CRLSetDistributor() = default;
void CRLSetDistributor::AddObserver(Observer* observer) {
observers_.AddObserver(observer);
}
void CRLSetDistributor::RemoveObserver(Observer* observer) {
observers_.RemoveObserver(observer);
}
void CRLSetDistributor::OnNewCRLSet(base::span<const uint8_t> crl_set) {
// Make a copy for the background task, since the underlying storage for
// the span will go away.
std::string crl_set_string(reinterpret_cast<const char*>(crl_set.data()),
crl_set.size());
base::PostTaskWithTraitsAndReplyWithResult(
FROM_HERE, {base::TaskPriority::BEST_EFFORT},
base::BindOnce(&ParseCRLSet, std::move(crl_set_string)),
base::BindOnce(&CRLSetDistributor::OnCRLSetParsed,
weak_factory_.GetWeakPtr()));
}
void CRLSetDistributor::OnCRLSetParsed(scoped_refptr<net::CRLSet> crl_set) {
if (!crl_set)
return; // Error parsing
if (crl_set_ && crl_set_->sequence() >= crl_set->sequence()) {
// Don't allow downgrades, and don't refresh CRLSets that are identical
// (the sequence is globally unique for all CRLSets).
return;
}
crl_set_ = std::move(crl_set);
for (auto& observer : observers_) {
observer.OnNewCRLSet(crl_set_);
}
}
} // namespace network