Domain Reliability: Expire queued beacons after 1 hour.

components/domain_reliability/context.cc

 // 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 "components/domain_reliability/context.h"
 
 #include <algorithm>
 #include <utility>
 
 #include "base/bind.h"
@@ skipping 136 matching lines @@
     base::TimeDelta max_delay) {
   dispatcher_->ScheduleTask(
       base::Bind(
           &DomainReliabilityContext::StartUpload,
           weak_factory_.GetWeakPtr()),
       min_delay,
       max_delay);
 }
 
 void DomainReliabilityContext::StartUpload() {
+  RemoveExpiredBeacons();
+  if (beacons_.empty())
+    return;
+
   MarkUpload();
 
   size_t collector_index = scheduler_.OnUploadStart();
   const GURL& collector_url = *config().collectors[collector_index];
 
   DCHECK(upload_time_.is_null());
   upload_time_ = time_->NowTicks();
   std::string report_json = "{}";
   int max_upload_depth = -1;
   bool wrote = base::JSONWriter::Write(
@@ skipping 92 matching lines @@
           << "removing oldest beacon";
 
   beacons_.pop_front();
 
   // If that just removed a beacon counted in uploading_beacons_size_, decrement
   // that.
   if (uploading_beacons_size_ > 0)
     --uploading_beacons_size_;
 }
 
+void DomainReliabilityContext::RemoveExpiredBeacons() {
+  base::TimeTicks now = time_->NowTicks();
+  const base::TimeDelta kMaxAge = base::TimeDelta::FromHours(1);

[Randy Smith (Not in Mondays), 2016/11/04 16:06:29]

Defined constant somewhere?

+  while (!beacons_.empty() && now - beacons_.front()->start_time >= kMaxAge)
+    beacons_.pop_front();
+}
+
 }  // namespace domain_reliability