Domain Reliability: Remove browsing data when requested.

components/domain_reliability/monitor.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/monitor.h"
 
 #include "base/command_line.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
 #include "base/single_thread_task_runner.h"
@@ skipping 50 matching lines @@
       url_request_context_getter_(scoped_refptr<net::URLRequestContextGetter>(
           new TrivialURLRequestContextGetter(
               url_request_context,
               content::BrowserThread::GetMessageLoopProxyForThread(
                   content::BrowserThread::IO)))),
       upload_reporter_string_(upload_reporter_string),
       scheduler_params_(
           DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()),
       dispatcher_(time_.get()),
       uploader_(
-          DomainReliabilityUploader::Create(url_request_context_getter_)) {
+          DomainReliabilityUploader::Create(url_request_context_getter_)),
+      was_cleared_(false),
+      cleared_mode_(MAX_CLEAR_MODE) {
   DCHECK(OnIOThread());
 }
 
 DomainReliabilityMonitor::DomainReliabilityMonitor(
     net::URLRequestContext* url_request_context,
     const std::string& upload_reporter_string,
     scoped_ptr<MockableTime> time)
     : time_(time.Pass()),
       url_request_context_getter_(scoped_refptr<net::URLRequestContextGetter>(
           new TrivialURLRequestContextGetter(
               url_request_context,
               content::BrowserThread::GetMessageLoopProxyForThread(
                   content::BrowserThread::IO)))),
       upload_reporter_string_(upload_reporter_string),
       scheduler_params_(
           DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()),
       dispatcher_(time_.get()),
       uploader_(
-          DomainReliabilityUploader::Create(url_request_context_getter_)) {
+          DomainReliabilityUploader::Create(url_request_context_getter_)),
+      was_cleared_(false),
+      cleared_mode_(MAX_CLEAR_MODE) {
   DCHECK(OnIOThread());
 }
 
 DomainReliabilityMonitor::~DomainReliabilityMonitor() {
   DCHECK(OnIOThread());
-  STLDeleteContainerPairSecondPointers(contexts_.begin(), contexts_.end());
+  ClearContexts();
 }
 
 void DomainReliabilityMonitor::AddBakedInConfigs() {
   base::Time now = base::Time::Now();
   for (size_t i = 0; kBakedInJsonConfigs[i]; ++i) {
     std::string json(kBakedInJsonConfigs[i]);
     scoped_ptr<const DomainReliabilityConfig> config =
         DomainReliabilityConfig::FromJSON(json);
     if (config && config->IsExpired(now)) {
       LOG(WARNING) << "Baked-in Domain Reliability config for "
@@ skipping 17 matching lines @@
     return;
   RequestInfo request_info(*request);
   if (request_info.AccessedNetwork()) {
     OnRequestLegComplete(request_info);
     // A request was just using the network, so now is a good time to run any
     // pending and eligible uploads.
     dispatcher_.RunEligibleTasks();
   }
 }
 
+void DomainReliabilityMonitor::ClearBrowsingData(
+   DomainReliabilityClearMode mode) {
+  DCHECK(OnIOThread());
+
+  was_cleared_ = true;
+  cleared_mode_ = mode;
+
+  switch (mode) {
+    case CLEAR_BEACONS: {
+      ContextMap::const_iterator it;
+      for (it = contexts_.begin(); it != contexts_.end(); ++it)
+        it->second->ClearBeacons();
+      break;
+    };
+    case CLEAR_CONTEXTS:
+      ClearContexts();
+      break;
+    case MAX_CLEAR_MODE:
+      NOTREACHED();
+  }
+}
+
 DomainReliabilityContext* DomainReliabilityMonitor::AddContextForTesting(
     scoped_ptr<const DomainReliabilityConfig> config) {
   return AddContext(config.Pass());
 }
 
 DomainReliabilityMonitor::RequestInfo::RequestInfo() {}
 
 DomainReliabilityMonitor::RequestInfo::RequestInfo(
     const net::URLRequest& request)
     : url(request.url()),
@@ skipping 28 matching lines @@
                                    config.Pass());
 
   std::pair<ContextMap::iterator, bool> map_it =
       contexts_.insert(make_pair(domain, context));
   // Make sure the domain wasn't already in the map.
   DCHECK(map_it.second);
 
   return map_it.first->second;
 }
 
+void DomainReliabilityMonitor::ClearContexts() {
+  STLDeleteContainerPairSecondPointers(
+      contexts_.begin(), contexts_.end());
+  contexts_.clear();
+}
+
 void DomainReliabilityMonitor::OnRequestLegComplete(
     const RequestInfo& request) {
   int response_code;
   if (request.response_info.headers)
     response_code = request.response_info.headers->response_code();
   else
     response_code = -1;
   ContextMap::iterator context_it;
   std::string beacon_status;
 
@@ skipping 21 matching lines @@
     beacon.server_ip = request.response_info.socket_address.host();
   else
     beacon.server_ip.clear();
   beacon.http_response_code = response_code;
   beacon.start_time = request.load_timing_info.request_start;
   beacon.elapsed = time_->NowTicks() - beacon.start_time;
   context_it->second->OnBeacon(request.url, beacon);
 }
 
 }  // namespace domain_reliability