Domain Reliability: Don't upload when metrics reporting is off.

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"
 #include "base/task_runner.h"
 #include "base/threading/thread_checker.h"
 #include "base/time/time.h"
 #include "components/domain_reliability/baked_in_configs.h"
 #include "net/base/load_flags.h"
 #include "net/http/http_response_headers.h"
 #include "net/url_request/url_request.h"
 #include "net/url_request/url_request_context.h"
 #include "net/url_request/url_request_context_getter.h"
 
 namespace domain_reliability {
 
 DomainReliabilityMonitor::DomainReliabilityMonitor(
     const std::string& upload_reporter_string)
     : time_(new ActualTime()),
       upload_reporter_string_(upload_reporter_string),
       scheduler_params_(
           DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()),
       dispatcher_(time_.get()),
+      reporting_pref_initialized_(false),
       weak_factory_(this) {}
 
 DomainReliabilityMonitor::DomainReliabilityMonitor(
     const std::string& upload_reporter_string,
     scoped_ptr<MockableTime> time)
     : time_(time.Pass()),
       upload_reporter_string_(upload_reporter_string),
       scheduler_params_(
           DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()),
       dispatcher_(time_.get()),
+      reporting_pref_initialized_(false),
       weak_factory_(this) {}
 
 DomainReliabilityMonitor::~DomainReliabilityMonitor() {
   ClearContexts();
 }
 
-void DomainReliabilityMonitor::Init(
+void DomainReliabilityMonitor::InitReportingPref(

[davidben, 2014/08/20 21:49:02]

Is this called anywhere outside of test code yet?

[Deprecated (see juliatuttle), 2014/08/21 18:35:28]

It is now!

+    PrefService* local_state_pref_service,
+    const char* reporting_pref_name,
+    const scoped_refptr<base::SingleThreadTaskRunner>&
+        network_message_loop_proxy) {
+  DCHECK(!reporting_pref_initialized_);
+
+  reporting_pref_.Init(
+      reporting_pref_name,
+      local_state_pref_service,
+      base::Bind(&DomainReliabilityMonitor::OnReportingPrefChanged,
+                 base::Unretained(this)));
+  reporting_pref_.MoveToThread(network_message_loop_proxy);
+
+  reporting_pref_initialized_ = true;
+
+  OnReportingPrefChanged();

[davidben, 2014/08/20 21:49:03]

Doesn't this require that |uploader_| be initialized? But |uploader_| is only
initialized in InitURLRequestContext which is called later. (Indeed the tests
seem to segfault.)

It's also strange that OnReportingPrefChanged is usually called on the IO
thread, but here, if I understand correctly, will be called on the UI thread.

Should this line be moved to InitURLRequestContext?

[Deprecated (see juliatuttle), 2014/08/21 18:35:28]

Well-spotted.

+}
+
+void DomainReliabilityMonitor::InitURLRequestContext(
     net::URLRequestContext* url_request_context,
     const scoped_refptr<base::SingleThreadTaskRunner>& task_runner) {
+  DCHECK(reporting_pref_initialized_);
   DCHECK(!thread_checker_);
 
   scoped_refptr<net::URLRequestContextGetter> url_request_context_getter =
       new net::TrivialURLRequestContextGetter(url_request_context,
                                               task_runner);
-  Init(url_request_context_getter);
+  InitURLRequestContext(url_request_context_getter);
 }
 
-void DomainReliabilityMonitor::Init(
+void DomainReliabilityMonitor::InitURLRequestContext(
     scoped_refptr<net::URLRequestContextGetter> url_request_context_getter) {
+  DCHECK(reporting_pref_initialized_);
   DCHECK(!thread_checker_);
 
   DCHECK(url_request_context_getter->GetNetworkTaskRunner()->
          RunsTasksOnCurrentThread());
 
   uploader_ = DomainReliabilityUploader::Create(url_request_context_getter);
   thread_checker_.reset(new base::ThreadChecker());
 }
 
 void DomainReliabilityMonitor::AddBakedInConfigs() {
@@ skipping 161 matching lines @@
     beacon.server_ip.clear();
   beacon.protocol = GetDomainReliabilityProtocol(
       request.response_info.connection_info,
       request.response_info.ssl_info.is_valid());
   beacon.http_response_code = response_code;
   beacon.start_time = request.load_timing_info.request_start;
   beacon.elapsed = time_->NowTicks() - beacon.start_time;
   context->OnBeacon(request.url, beacon);
 }
 
+void DomainReliabilityMonitor::OnReportingPrefChanged() {
+  // When metrics reporting is disabled, discard Domain Reliability uploads.
+  uploader_->set_discard_uploads(!*reporting_pref_);
+}
+
 // TODO(ttuttle): Keep a separate wildcard_contexts_ map to avoid having to
 // prepend '*.' to domains.
 DomainReliabilityContext* DomainReliabilityMonitor::GetContextForHost(
     const std::string& host) const {
   ContextMap::const_iterator context_it;
 
   context_it = contexts_.find(host);
   if (context_it != contexts_.end())
     return context_it->second;
 
@@ skipping 15 matching lines @@
 
   return NULL;
 }
 
 base::WeakPtr<DomainReliabilityMonitor>
 DomainReliabilityMonitor::MakeWeakPtr() {
   return weak_factory_.GetWeakPtr();
 }
 
 }  // namespace domain_reliability