Re-landing issue 4202006 (http://codereview.chromium.org/4202006/show) which ...

chrome/service/cloud_print/job_status_updater.cc

 // Copyright (c) 2010 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/json/json_reader.h"
 #include "base/string_util.h"
 #include "base/utf_string_conversions.h"
 #include "chrome/common/net/http_return.h"
@@ skipping 40 matching lines @@
       } else {
         // If GetJobDetails failed, the most likely case is that the job no
         // 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 = cloud_print::PRINT_JOB_STATUS_COMPLETED;
         need_update = true;
       }
     }
     if (need_update) {
-      GURL update_url = CloudPrintHelpers::GetUrlForJobStatusUpdate(
-          cloud_print_server_url_, job_id_, last_job_details_);
-      request_.reset(new URLFetcher(update_url, URLFetcher::GET, this));
-      CloudPrintHelpers::PrepCloudPrintRequest(request_.get(), auth_token_);
-      request_->Start();
+      request_ = new CloudPrintURLFetcher;
+      request_->StartGetRequest(
+          CloudPrintHelpers::GetUrlForJobStatusUpdate(
+              cloud_print_server_url_, job_id_, last_job_details_),
+          this, auth_token_, kCloudPrintAPIRetryPolicy);
     }
   }
 }
 
 void JobStatusUpdater::Stop() {
-  request_.reset();
+  request_ = NULL;
   DCHECK(delegate_);
   stopped_ = true;
   delegate_->OnJobCompleted(this);
 }
 
-// URLFetcher::Delegate implementation.
-void JobStatusUpdater::OnURLFetchComplete(const URLFetcher* source,
-                                          const GURL& url,
-                                          const URLRequestStatus& status,
-                                          int response_code,
-                                          const ResponseCookies& cookies,
-                                          const std::string& data) {
-  // If there was an auth error, we are done.
-  if (RC_FORBIDDEN == response_code) {
-    if (delegate_) {
-      delegate_->OnAuthError();
-    }
-    return;
-  }
-  int64 next_update_interval = kJobStatusUpdateInterval;
-  if (!status.is_success() || (response_code != 200)) {
-    next_update_interval *= 10;
-    MessageLoop::current()->PostDelayedTask(
-        FROM_HERE, NewRunnableMethod(this, &JobStatusUpdater::UpdateStatus),
-        next_update_interval);
-  } else if (last_job_details_.status ==
-             cloud_print::PRINT_JOB_STATUS_COMPLETED) {
+// CloudPrintURLFetcher::Delegate implementation.
+CloudPrintURLFetcher::ResponseAction JobStatusUpdater::HandleJSONData(
+      const URLFetcher* source,
+      const GURL& url,
+      DictionaryValue* json_data,
+      bool succeeded) {
+  if (last_job_details_.status == cloud_print::PRINT_JOB_STATUS_COMPLETED) {
     MessageLoop::current()->PostTask(
         FROM_HERE, NewRunnableMethod(this, &JobStatusUpdater::Stop));
   }
+  return CloudPrintURLFetcher::STOP_PROCESSING;
 }
+
+void JobStatusUpdater::OnRequestAuthError() {
+  if (delegate_)
+    delegate_->OnAuthError();
+}