Network traffic annotation added to CloudPrintUrlFetcher.

chrome/service/cloud_print/job_status_updater.cc

 // Copyright (c) 2012 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 "chrome/service/cloud_print/job_status_updater.h"
 
 #include "base/bind.h"
 #include "base/json/json_reader.h"
 #include "base/location.h"
 #include "base/metrics/histogram_macros.h"
@@ skipping 10 matching lines @@
 
 namespace {
 
 bool IsTerminalJobState(PrintJobStatus status) {
   return status == PRINT_JOB_STATUS_ERROR ||
          status == PRINT_JOB_STATUS_COMPLETED;
 }
 
 }  // namespace
 
-JobStatusUpdater::JobStatusUpdater(const std::string& printer_name,
-                                   const std::string& job_id,
-                                   PlatformJobId local_job_id,
-                                   const GURL& cloud_print_server_url,
-                                   PrintSystem* print_system,
-                                   Delegate* delegate)
+JobStatusUpdater::JobStatusUpdater(
+    const std::string& printer_name,
+    const std::string& job_id,
+    PlatformJobId local_job_id,
+    const GURL& cloud_print_server_url,
+    PrintSystem* print_system,
+    Delegate* delegate,
+    const net::PartialNetworkTrafficAnnotationTag& partial_traffic_annotation)
     : start_time_(base::Time::Now()),
       printer_name_(printer_name),
       job_id_(job_id),
       local_job_id_(local_job_id),
       cloud_print_server_url_(cloud_print_server_url),
       print_system_(print_system),
       delegate_(delegate),
-      stopped_(false) {
+      stopped_(false),
+      partial_traffic_annotation_(partial_traffic_annotation) {
   DCHECK(delegate_);
 }
 
 // Start checking the status of the local print job.
 void JobStatusUpdater::UpdateStatus() {
   // It does not matter if we had already sent out an update and are waiting for
   // a response. This is a new update and we will simply cancel the old request
   // and send a new one.
   if (!stopped_) {
     bool need_update = false;
@@ skipping 15 matching lines @@
         // longer exists in the OS queue. We are going to assume it is done in
         // this case.
         last_job_details_.Clear();
         last_job_details_.status = PRINT_JOB_STATUS_COMPLETED;
         need_update = true;
       }
       UMA_HISTOGRAM_ENUMERATION("CloudPrint.NativeJobStatus",
                                 last_job_details_.status, PRINT_JOB_STATUS_MAX);
     }
     if (need_update) {
-      request_ = CloudPrintURLFetcher::Create();
+      request_ = CloudPrintURLFetcher::Create(partial_traffic_annotation_);
       request_->StartGetRequest(
           CloudPrintURLFetcher::REQUEST_UPDATE_JOB,
           GetUrlForJobStatusUpdate(
               cloud_print_server_url_, job_id_, last_job_details_),
           this,
           kCloudPrintAPIMaxRetryCount,
           std::string());
     }
   }
 }
@@ skipping 28 matching lines @@
   return CloudPrintURLFetcher::STOP_PROCESSING;
 }
 
 std::string JobStatusUpdater::GetAuthHeader() {
   return GetCloudPrintAuthHeaderFromStore();
 }
 
 JobStatusUpdater::~JobStatusUpdater() {}
 
 }  // namespace cloud_print