Index: net/reporting/reporting_delivery_agent.cc |
diff --git a/net/reporting/reporting_delivery_agent.cc b/net/reporting/reporting_delivery_agent.cc |
index b0d54dd37e4a9e4b3008a91a7ea9663d67696fd3..f39dde936ea46b4e940c8fc9e2a9aaf8c23624f6 100644 |
--- a/net/reporting/reporting_delivery_agent.cc |
+++ b/net/reporting/reporting_delivery_agent.cc |
@@ -48,16 +48,8 @@ void SerializeReports(const std::vector<const ReportingReport*>& reports, |
} // namespace |
-ReportingDeliveryAgent::ReportingDeliveryAgent( |
- base::TickClock* clock, |
- ReportingCache* cache, |
- ReportingUploader* uploader, |
- const BackoffEntry::Policy* endpoint_backoff_policy) |
- : clock_(clock), |
- cache_(cache), |
- uploader_(uploader), |
- endpoint_manager_(clock, cache, endpoint_backoff_policy), |
- weak_factory_(this) {} |
+ReportingDeliveryAgent::ReportingDeliveryAgent(ReportingContext* context) |
+ : context_(context), weak_factory_(this) {} |
ReportingDeliveryAgent::~ReportingDeliveryAgent() {} |
class ReportingDeliveryAgent::Delivery { |
@@ -74,7 +66,7 @@ class ReportingDeliveryAgent::Delivery { |
void ReportingDeliveryAgent::SendReports() { |
std::vector<const ReportingReport*> reports; |
- cache_->GetReports(&reports); |
+ cache()->GetReports(&reports); |
// Sort reports into (origin, group) buckets. |
std::map<OriginGroup, std::vector<const ReportingReport*>> |
@@ -95,7 +87,7 @@ void ReportingDeliveryAgent::SendReports() { |
continue; |
GURL endpoint_url; |
- if (!endpoint_manager_.FindEndpointForOriginAndGroup( |
+ if (!endpoint_manager()->FindEndpointForOriginAndGroup( |
origin_group.first, origin_group.second, &endpoint_url)) { |
continue; |
} |
@@ -110,13 +102,13 @@ void ReportingDeliveryAgent::SendReports() { |
const GURL& endpoint = it.first; |
const std::vector<const ReportingReport*>& reports = it.second; |
- endpoint_manager_.SetEndpointPending(endpoint); |
- cache_->SetReportsPending(reports); |
+ endpoint_manager()->SetEndpointPending(endpoint); |
+ cache()->SetReportsPending(reports); |
std::string json; |
- SerializeReports(reports, clock_->NowTicks(), &json); |
+ SerializeReports(reports, tick_clock()->NowTicks(), &json); |
- uploader_->StartUpload( |
+ uploader()->StartUpload( |
endpoint, json, |
base::Bind(&ReportingDeliveryAgent::OnUploadComplete, |
weak_factory_.GetWeakPtr(), |
@@ -128,23 +120,23 @@ void ReportingDeliveryAgent::OnUploadComplete( |
const std::unique_ptr<Delivery>& delivery, |
ReportingUploader::Outcome outcome) { |
if (outcome == ReportingUploader::Outcome::SUCCESS) { |
- cache_->RemoveReports(delivery->reports); |
- endpoint_manager_.InformOfEndpointRequest(delivery->endpoint, true); |
+ cache()->RemoveReports(delivery->reports); |
+ endpoint_manager()->InformOfEndpointRequest(delivery->endpoint, true); |
} else { |
- cache_->IncrementReportsAttempts(delivery->reports); |
- endpoint_manager_.InformOfEndpointRequest(delivery->endpoint, false); |
+ cache()->IncrementReportsAttempts(delivery->reports); |
+ endpoint_manager()->InformOfEndpointRequest(delivery->endpoint, false); |
} |
if (outcome == ReportingUploader::Outcome::REMOVE_ENDPOINT) |
- cache_->RemoveClientsForEndpoint(delivery->endpoint); |
+ cache()->RemoveClientsForEndpoint(delivery->endpoint); |
for (const ReportingReport* report : delivery->reports) { |
pending_origin_groups_.erase( |
OriginGroup(url::Origin(report->url), report->group)); |
} |
- cache_->ClearReportsPending(delivery->reports); |
- endpoint_manager_.ClearEndpointPending(delivery->endpoint); |
+ endpoint_manager()->ClearEndpointPending(delivery->endpoint); |
+ cache()->ClearReportsPending(delivery->reports); |
} |
} // namespace net |