Create Ukm ReportingService implementation.

components/metrics/reporting_service.cc

 // Copyright 2017 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.
 
 // ReportingService handles uploading serialized logs to a server.
 
 #include "components/metrics/reporting_service.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
@@ skipping 103 matching lines @@
   }
   if (!log_store()->has_staged_log())
     log_store()->StageNextLog();
 
   // Proceed to stage the log for upload if log size satisfies cellular log
   // upload constrains.
   bool upload_canceled = false;
   bool is_cellular_logic = client_->IsUMACellularUploadLogicEnabled();
   if (is_cellular_logic && data_use_tracker_ &&
       !data_use_tracker_->ShouldUploadLogOnCellular(
-          log_store()->staged_log_hash().size())) {
+          log_store()->staged_log_hash().size(), service_type())) {
     upload_scheduler_->UploadOverDataUsageCap();
     upload_canceled = true;
   } else {
     SendStagedLog();
   }
   if (is_cellular_logic) {
     LogCellularConstraint(upload_canceled);
   }
 }
 
@@ skipping 23 matching lines @@
   DVLOG(1) << "OnLogUploadComplete:" << response_code;
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(log_upload_in_progress_);
   log_upload_in_progress_ = false;
 
   // Log a histogram to track response success vs. failure rates.
   LogResponseCode(response_code);
 
   bool upload_succeeded = response_code == 200;
 
-  // Provide boolean for error recovery (allow us to ignore response_code).
-  bool discard_log = false;
-  const size_t log_size = log_store()->staged_log().length();
-  if (upload_succeeded) {
-    LogSuccess(log_size);
-  } else if (log_size > max_retransmit_size_) {
-    LogLargeRejection(log_size);
-    discard_log = true;
-  } else if (response_code == 400) {
-    // Bad syntax.  Retransmission won't work.
-    discard_log = true;
-  }
+  // Staged log could have been removed already (such as by Purge() in some
+  // implementations), otherwise we may remove it here.
+  if (log_store()->has_staged_log()) {
+    // Provide boolean for error recovery (allow us to ignore response_code).
+    bool discard_log = false;
+    const size_t log_size = log_store()->staged_log().length();
+    if (upload_succeeded) {
+      LogSuccess(log_size);
+    } else if (log_size > max_retransmit_size_) {
+      LogLargeRejection(log_size);
+      discard_log = true;
+    } else if (response_code == 400) {
+      // Bad syntax.  Retransmission won't work.
+      discard_log = true;
+    }
 
-  if (upload_succeeded || discard_log) {
-    log_store()->DiscardStagedLog();
-    // Store the updated list to disk now that the removed log is uploaded.
-    log_store()->PersistUnsentLogs();
+    if (upload_succeeded || discard_log) {
+      log_store()->DiscardStagedLog();
+      // Store the updated list to disk now that the removed log is uploaded.
+      log_store()->PersistUnsentLogs();
+    }
   }
 
   // Error 400 indicates a problem with the log, not with the server, so
   // don't consider that a sign that the server is in trouble.
   bool server_is_healthy = upload_succeeded || response_code == 400;
   if (!log_store()->has_unsent_logs()) {
     DVLOG(1) << "Stopping upload_scheduler_.";
     upload_scheduler_->Stop();
   }
   upload_scheduler_->UploadFinished(server_is_healthy);
 }
 
 }  // namespace metrics