Replace most of the occurrence of OperationRegistry with OperationRunner.

chrome/browser/google_apis/base_operations.h

 // 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.
 //
 // This file provides base classes used to implement operations for Google APIs.
 
 #ifndef CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_
 #define CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_
 
 #include <string>
@@ skipping 10 matching lines @@
 namespace base {
 class Value;
 }  // namespace base
 
 namespace net {
 class URLRequestContextGetter;
 }  // namespace net
 
 namespace google_apis {
 
+class OperationRunner;
+
 // Callback used to pass parsed JSON from ParseJson(). If parsing error occurs,
 // then the passed argument is null.
 typedef base::Callback<void(scoped_ptr<base::Value> value)> ParseJsonCallback;
 
 // Callback used for DownloadOperation and ResumeUploadOperation.
 typedef base::Callback<void(int64 progress, int64 total)> ProgressCallback;
 
 // Parses JSON passed in |json| on blocking pool. Runs |callback| on the calling
 // thread when finished with either success or failure.
 // The callback must not be null.
@@ skipping 29 matching lines @@
   // Gets a weak pointer to this operation object. Since operations may be
   // deleted when it is canceled by user action, for posting asynchronous tasks
   // on the authentication operation object, weak pointers have to be used.
   // TODO(kinaba): crbug.com/134814 use more clean life time management than
   // using weak pointers, while deprecating OperationRegistry.
   virtual base::WeakPtr<AuthenticatedOperationInterface> GetWeakPtr() = 0;
 };
 
 //============================ UrlFetchOperationBase ===========================
 
-// Callback type for getting the content from URLFetcher::GetResponseAsString().
-typedef base::Callback<void(
-    GDataErrorCode error,
-    scoped_ptr<std::string> content)> GetContentCallback;
-
 // Base class for operations that are fetching URLs.
 class UrlFetchOperationBase : public AuthenticatedOperationInterface,
                               public OperationRegistry::Operation,
                               public net::URLFetcherDelegate {
  public:
   // AuthenticatedOperationInterface overrides.
   virtual void Start(const std::string& access_token,
                      const std::string& custom_user_agent,
                      const ReAuthenticateCallback& callback) OVERRIDE;
   virtual base::WeakPtr<AuthenticatedOperationInterface> GetWeakPtr() OVERRIDE;
 
  protected:
-  explicit UrlFetchOperationBase(
-      OperationRegistry* registry,
+  UrlFetchOperationBase(
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter);
   // Use this constructor when you need to implement operations that take a
   // drive file path (ex. for downloading and uploading).
   // |url_request_context_getter| is used to initialize URLFetcher.
   // TODO(satorux): Remove the drive file path hack. crbug.com/163296
   UrlFetchOperationBase(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const base::FilePath& drive_file_path);
   virtual ~UrlFetchOperationBase();
 
   // Gets URL for the request.
   virtual GURL GetURL() const = 0;
 
   // Returns the request type. A derived class should override this method
   // for a request type other than HTTP GET.
   virtual net::URLFetcher::RequestType GetRequestType() const;
@@ skipping 84 matching lines @@
 // Callback type for Delete/Move DocumentServiceInterface calls.
 typedef base::Callback<void(GDataErrorCode error)> EntryActionCallback;
 
 // This class performs a simple action over a given entry (document/file).
 // It is meant to be used for operations that return no JSON blobs.
 class EntryActionOperation : public UrlFetchOperationBase {
  public:
   // |url_request_context_getter| is used to initialize URLFetcher.
   // |callback| must not be null.
   EntryActionOperation(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const EntryActionCallback& callback);
   virtual ~EntryActionOperation();
 
  protected:
   // Overridden from UrlFetchOperationBase.
   virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE;
 
  private:
   const EntryActionCallback callback_;
 
   DISALLOW_COPY_AND_ASSIGN(EntryActionOperation);
 };
 
 //============================== GetDataOperation ==============================
 
 // Callback type for DocumentServiceInterface::GetResourceList.
 // Note: json_data argument should be passed using base::Passed(&json_data), not
 // json_data.Pass().
 typedef base::Callback<void(GDataErrorCode error,
                             scoped_ptr<base::Value> json_data)> GetDataCallback;
 
 // This class performs the operation for fetching and converting the fetched
 // content into a base::Value.
 class GetDataOperation : public UrlFetchOperationBase {
  public:
   // |callback| must not be null.
-  GetDataOperation(OperationRegistry* registry,
+  GetDataOperation(OperationRunner* runner,
                    net::URLRequestContextGetter* url_request_context_getter,
                    const GetDataCallback& callback);
   virtual ~GetDataOperation();
 
   // Parses JSON response.
   void ParseResponse(GDataErrorCode fetch_error_code, const std::string& data);
 
  protected:
   // UrlFetchOperationBase overrides.
   virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
@@ skipping 37 matching lines @@
 // 3) If there is more data to upload, go to 2).
 //
 class InitiateUploadOperationBase : public UrlFetchOperationBase {
  protected:
   // |callback| will be called with the upload URL, where upload data is
   // uploaded to with ResumeUploadOperation.
   // |callback| must not be null.
   // |content_type| and |content_length| should be the attributes of the
   // uploading file.
   InitiateUploadOperationBase(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const InitiateUploadCallback& callback,
       const base::FilePath& drive_file_path,
       const std::string& content_type,
       int64 content_length);
   virtual ~InitiateUploadOperationBase();
 
   // UrlFetchOperationBase overrides.
   virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void NotifySuccessToOperationRegistry() OVERRIDE;
@@ skipping 33 matching lines @@
 // Base class for a URL fetch request expecting the response containing the
 // current uploading range. This class processes the response containing
 // "Range" header and invoke OnRangeOperationComplete.
 class UploadRangeOperationBase : public UrlFetchOperationBase {
  protected:
   // |upload_location| is the URL of where to upload the file to.
   // |drive_file_path| is the path to the file seen in the UI. Not necessary
   // for resuming an upload, but used for adding an entry to OperationRegistry.
   // TODO(satorux): Remove the drive file path hack. crbug.com/163296
   UploadRangeOperationBase(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const base::FilePath& drive_file_path,
       const GURL& upload_url);
   virtual ~UploadRangeOperationBase();
 
   // UrlFetchOperationBase overrides.
   virtual GURL GetURL() const OVERRIDE;
   virtual net::URLFetcher::RequestType GetRequestType() const OVERRIDE;
   virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE;
   virtual void NotifySuccessToOperationRegistry() OVERRIDE;
@@ skipping 47 matching lines @@
   // |start_position| is the start of range of contents currently stored in
   // |buf|. |end_position| is the end of range of contents currently stared in
   // |buf|. This is exclusive. For instance, if you are to upload the first
   // 500 bytes of data, |start_position| is 0 and |end_position| is 500.
   // |content_length| and |content_type| are the length and type of the
   // file content to be uploaded respectively.
   // |buf| holds current content to be uploaded.
   // See also UploadRangeOperationBase's comment for remaining parameters
   // meaining.
   ResumeUploadOperationBase(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const base::FilePath& drive_file_path,
       const GURL& upload_location,
       int64 start_position,
       int64 end_position,
       int64 content_length,
       const std::string& content_type,
       const base::FilePath& local_file_path);
   virtual ~ResumeUploadOperationBase();
 
@@ skipping 25 matching lines @@
 //   if a file has been partially uploaded. |value| is not used.
 // - HTTP_SUCCESS or HTTP_CREATED (up to the upload mode) and |value|
 //   for the uploaded data, if a file has been completely uploaded.
 // See also UploadRangeOperationBase.
 class GetUploadStatusOperationBase : public UploadRangeOperationBase {
  public:
   // |content_length| is the whole data size to be uploaded.
   // See also UploadRangeOperationBase's constructor comment for other
   // parameters.
   GetUploadStatusOperationBase(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const base::FilePath& drive_file_path,
       const GURL& upload_url,
       int64 content_length);
   virtual ~GetUploadStatusOperationBase();
 
  protected:
   // UrlFetchOperationBase overrides.
   virtual std::vector<std::string> GetExtraRequestHeaders() const OVERRIDE;
 
  private:
   const int64 content_length_;
 
   DISALLOW_COPY_AND_ASSIGN(GetUploadStatusOperationBase);
 };
 
 //============================ DownloadFileOperation ===========================
 
-// Callback type for DownloadHostedDocument/DownloadFile
-// DocumentServiceInterface calls.
+// Callback type for getting the content from DownloadFileOperation.
+typedef base::Callback<void(
+    GDataErrorCode error,
+    scoped_ptr<std::string> content)> GetContentCallback;
+
+// Callback type for receiving the completion of DownloadFileOperation.
 typedef base::Callback<void(GDataErrorCode error,
                             const base::FilePath& temp_file)>
     DownloadActionCallback;
 
 // This class performs the operation for downloading of a given document/file.
 class DownloadFileOperation : public UrlFetchOperationBase {
  public:
   // download_action_callback:
   //   This callback is called when the download is complete. Must not be null.
   //
   // get_content_callback:
   //   This callback is called when some part of the content is
   //   read. Used to read the download content progressively. May be null.
   //
   // progress_callback:
   //   This callback is called for periodically reporting the number of bytes
   //   downloaded so far. May be null.
   //
   // download_url:
   //   Specifies the target file to download.
   //
   // drive_file_path:
   //   Specifies the drive path of the target file. Shown in UI.
   //   TODO(satorux): Remove the drive file path hack. crbug.com/163296
   //
   // output_file_path:
   //   Specifies the file path to save the downloaded file.
   //
   DownloadFileOperation(
-      OperationRegistry* registry,
+      OperationRunner* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       const DownloadActionCallback& download_action_callback,
       const GetContentCallback& get_content_callback,
       const ProgressCallback& progress_callback,
       const GURL& download_url,
       const base::FilePath& drive_file_path,
       const base::FilePath& output_file_path);
   virtual ~DownloadFileOperation();
 
  protected:
@@ skipping 15 matching lines @@
   const GetContentCallback get_content_callback_;
   const ProgressCallback progress_callback_;
   const GURL download_url_;
 
   DISALLOW_COPY_AND_ASSIGN(DownloadFileOperation);
 };
 
 }  // namespace google_apis
 
 #endif  // CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_