Implement exponential back-off mechanism and enforce it at the URLRequestHttpJob level.

chrome/service/cloud_print/cloud_print_url_fetcher.h

 // 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.
 
 #ifndef CHROME_SERVICE_CLOUD_PRINT_CLOUD_PRINT_URL_FETCHER_H_
 #define CHROME_SERVICE_CLOUD_PRINT_CLOUD_PRINT_URL_FETCHER_H_
 #pragma once
 
 #include <string>
 
 #include "chrome/common/net/url_fetcher.h"
 
 class DictionaryValue;
 class GURL;
-class URLFetcherProtectEntry;
+class RequestThrottlerManager;
 class URLRequestStatus;
 
 // A wrapper around URLFetcher for CloudPrint. URLFetcher applies retry logic
 // only on HTTP response codes >= 500. In the cloud print case, we want to
 // retry on all network errors. In addition, we want to treat non-JSON responses
 // (for all CloudPrint APIs that expect JSON responses) as errors and they
-// must also be retried. Also URLFetcher uses the host name of the URL as the
-// key for applying the retry policy. In our case, we want to apply one global
-// policy for many requests (not necessarily scoped by hostname).
+// must also be retried.
 class CloudPrintURLFetcher
     : public base::RefCountedThreadSafe<CloudPrintURLFetcher>,
       public URLFetcher::Delegate {
  public:
   enum ResponseAction {
     CONTINUE_PROCESSING,
     STOP_PROCESSING,
     RETRY_REQUEST,
   };
   class Delegate {
@@ skipping 37 matching lines @@
     virtual void OnRequestGiveUp() { }
     // Invoked when the request returns a 403 error (applicable only when
     // HandleRawResponse returns CONTINUE_PROCESSING)
     virtual void OnRequestAuthError() = 0;
   };
   CloudPrintURLFetcher();
 
   void StartGetRequest(const GURL& url,
                        Delegate* delegate,
                        const std::string& auth_token,
-                       const std::string& retry_policy);
+                       int max_retries);
   void StartPostRequest(const GURL& url,
                         Delegate* delegate,
                         const std::string& auth_token,
-                        const std::string& retry_policy,
+                        int max_retries,
                         const std::string& post_data_mime_type,
                         const std::string& post_data);
 
   // URLFetcher::Delegate implementation.
   virtual void OnURLFetchComplete(const URLFetcher* source, const GURL& url,
                                   const URLRequestStatus& status,
                                   int response_code,
                                   const ResponseCookies& cookies,
                                   const std::string& data);
  protected:
   // Virtual for testing.
   virtual URLRequestContextGetter* GetRequestContextGetter();
 
  private:
   void StartRequestHelper(const GURL& url,
                           URLFetcher::RequestType request_type,
                           Delegate* delegate,
                           const std::string& auth_token,
-                          const std::string& retry_policy,
+                          int max_retries,
                           const std::string& post_data_mime_type,
                           const std::string& post_data);
   void StartRequestNow();
 
   scoped_ptr<URLFetcher> request_;
   Delegate* delegate_;
-  URLFetcherProtectEntry* protect_entry_;
+  RequestThrottlerManager* request_throttler_manager_;

[willchan no longer on Chromium, 2010/11/17 20:32:34]

Why are we caching the singleton into a pointer?

[yzshen, 2010/11/19 23:51:36]

I thought it was right since I read this in singleton.h: "Every call to get(),
operator->() and operator*() incurs some overhead... You may wish to cache the
result of get(); it will not change."

I've changed it.

   int num_retries_;
 };
 
 typedef CloudPrintURLFetcher::Delegate CloudPrintURLFetcherDelegate;
 
 #endif  // CHROME_SERVICE_CLOUD_PRINT_CLOUD_PRINT_URL_FETCHER_H_