Replace most of the occurrence of OperationRegistry with OperationRunner.

chrome/browser/google_apis/gdata_wapi_operations.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/browser/google_apis/gdata_wapi_operations.h"
 
 #include "base/stringprintf.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/task_runner_util.h"
 #include "base/threading/sequenced_worker_pool.h"
@@ skipping 143 matching lines @@
     error = GDATA_OTHER_ERROR;
 
   callback.Run(error, open_link);
 }
 
 }  // namespace
 
 //============================ GetResourceListOperation ========================
 
 GetResourceListOperation::GetResourceListOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const GURL& override_url,
     int64 start_changestamp,
     const std::string& search_string,
     const std::string& directory_resource_id,
     const GetResourceListCallback& callback)
-    : GetDataOperation(registry, url_request_context_getter,
+    : GetDataOperation(runner, url_request_context_getter,
                        base::Bind(&ParseResourceListAndRun, callback)),
       url_generator_(url_generator),
       override_url_(override_url),
       start_changestamp_(start_changestamp),
       search_string_(search_string),
       directory_resource_id_(directory_resource_id) {
   DCHECK(!callback.is_null());
 }
 
 GetResourceListOperation::~GetResourceListOperation() {}
 
 GURL GetResourceListOperation::GetURL() const {
   return url_generator_.GenerateResourceListUrl(override_url_,
                                                 start_changestamp_,
                                                 search_string_,
                                                 directory_resource_id_);
 }
 
 //============================ SearchByTitleOperation ==========================
 
 SearchByTitleOperation::SearchByTitleOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const std::string& title,
     const std::string& directory_resource_id,
     const GetResourceListCallback& callback)
-    : GetDataOperation(registry, url_request_context_getter,
+    : GetDataOperation(runner, url_request_context_getter,
                        base::Bind(&ParseResourceListAndRun, callback)),
       url_generator_(url_generator),
       title_(title),
       directory_resource_id_(directory_resource_id) {
   DCHECK(!callback.is_null());
 }
 
 SearchByTitleOperation::~SearchByTitleOperation() {}
 
 GURL SearchByTitleOperation::GetURL() const {
   return url_generator_.GenerateSearchByTitleUrl(
       title_, directory_resource_id_);
 }
 
 //============================ GetResourceEntryOperation =======================
 
 GetResourceEntryOperation::GetResourceEntryOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const std::string& resource_id,
     const GetDataCallback& callback)
-    : GetDataOperation(registry, url_request_context_getter, callback),
+    : GetDataOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       resource_id_(resource_id) {
   DCHECK(!callback.is_null());
 }
 
 GetResourceEntryOperation::~GetResourceEntryOperation() {}
 
 GURL GetResourceEntryOperation::GetURL() const {
   return url_generator_.GenerateEditUrl(resource_id_);
 }
 
 //========================= GetAccountMetadataOperation ========================
 
 GetAccountMetadataOperation::GetAccountMetadataOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const GetAccountMetadataCallback& callback,
     bool include_installed_apps)
-    : GetDataOperation(registry, url_request_context_getter,
+    : GetDataOperation(runner, url_request_context_getter,
                        base::Bind(&ParseAccounetMetadataAndRun, callback)),
       url_generator_(url_generator),
       include_installed_apps_(include_installed_apps) {
   DCHECK(!callback.is_null());
 }
 
 GetAccountMetadataOperation::~GetAccountMetadataOperation() {}
 
 GURL GetAccountMetadataOperation::GetURL() const {
   return url_generator_.GenerateAccountMetadataUrl(include_installed_apps_);
 }
 
 //=========================== DeleteResourceOperation ==========================
 
 DeleteResourceOperation::DeleteResourceOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const EntryActionCallback& callback,
     const std::string& resource_id,
     const std::string& etag)
-    : EntryActionOperation(registry, url_request_context_getter, callback),
+    : EntryActionOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       resource_id_(resource_id),
       etag_(etag) {
   DCHECK(!callback.is_null());
 }
 
 DeleteResourceOperation::~DeleteResourceOperation() {}
 
 GURL DeleteResourceOperation::GetURL() const {
   return url_generator_.GenerateEditUrl(resource_id_);
 }
 
 URLFetcher::RequestType DeleteResourceOperation::GetRequestType() const {
   return URLFetcher::DELETE_REQUEST;
 }
 
 std::vector<std::string>
 DeleteResourceOperation::GetExtraRequestHeaders() const {
   std::vector<std::string> headers;
   headers.push_back(util::GenerateIfMatchHeader(etag_));
   return headers;
 }
 
 //========================== CreateDirectoryOperation ==========================
 
 CreateDirectoryOperation::CreateDirectoryOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const GetDataCallback& callback,
     const std::string& parent_resource_id,
     const std::string& directory_name)
-    : GetDataOperation(registry, url_request_context_getter, callback),
+    : GetDataOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       parent_resource_id_(parent_resource_id),
       directory_name_(directory_name) {
   DCHECK(!callback.is_null());
 }
 
 CreateDirectoryOperation::~CreateDirectoryOperation() {}
 
 GURL CreateDirectoryOperation::GetURL() const {
   return url_generator_.GenerateContentUrl(parent_resource_id_);
@@ skipping 25 matching lines @@
   xml_writer.StopWriting();
   upload_content->assign(xml_writer.GetWrittenString());
   DVLOG(1) << "CreateDirectory data: " << *upload_content_type << ", ["
            << *upload_content << "]";
   return true;
 }
 
 //============================ CopyHostedDocumentOperation =====================
 
 CopyHostedDocumentOperation::CopyHostedDocumentOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const GetDataCallback& callback,
     const std::string& resource_id,
     const std::string& new_name)
-    : GetDataOperation(registry, url_request_context_getter, callback),
+    : GetDataOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       resource_id_(resource_id),
       new_name_(new_name) {
   DCHECK(!callback.is_null());
 }
 
 CopyHostedDocumentOperation::~CopyHostedDocumentOperation() {}
 
 URLFetcher::RequestType CopyHostedDocumentOperation::GetRequestType() const {
   return URLFetcher::POST;
@@ skipping 19 matching lines @@
   xml_writer.StopWriting();
   upload_content->assign(xml_writer.GetWrittenString());
   DVLOG(1) << "CopyHostedDocumentOperation data: " << *upload_content_type
            << ", [" << *upload_content << "]";
   return true;
 }
 
 //=========================== RenameResourceOperation ==========================
 
 RenameResourceOperation::RenameResourceOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const EntryActionCallback& callback,
     const std::string& resource_id,
     const std::string& new_name)
-    : EntryActionOperation(registry, url_request_context_getter, callback),
+    : EntryActionOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       resource_id_(resource_id),
       new_name_(new_name) {
   DCHECK(!callback.is_null());
 }
 
 RenameResourceOperation::~RenameResourceOperation() {}
 
 URLFetcher::RequestType RenameResourceOperation::GetRequestType() const {
   return URLFetcher::PUT;
@@ skipping 24 matching lines @@
   xml_writer.StopWriting();
   upload_content->assign(xml_writer.GetWrittenString());
   DVLOG(1) << "RenameResourceOperation data: " << *upload_content_type << ", ["
            << *upload_content << "]";
   return true;
 }
 
 //=========================== AuthorizeAppOperation ==========================
 
 AuthorizeAppOperation::AuthorizeAppOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const AuthorizeAppCallback& callback,
     const std::string& resource_id,
     const std::string& app_id)
-    : GetDataOperation(registry, url_request_context_getter,
+    : GetDataOperation(runner, url_request_context_getter,
                        base::Bind(&ParseOpenLinkAndRun, app_id, callback)),
       url_generator_(url_generator),
       resource_id_(resource_id),
       app_id_(app_id) {
   DCHECK(!callback.is_null());
 }
 
 AuthorizeAppOperation::~AuthorizeAppOperation() {}
 
 URLFetcher::RequestType AuthorizeAppOperation::GetRequestType() const {
@@ skipping 25 matching lines @@
   return true;
 }
 
 GURL AuthorizeAppOperation::GetURL() const {
   return url_generator_.GenerateEditUrl(resource_id_);
 }
 
 //======================= AddResourceToDirectoryOperation ======================
 
 AddResourceToDirectoryOperation::AddResourceToDirectoryOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const EntryActionCallback& callback,
     const std::string& parent_resource_id,
     const std::string& resource_id)
-    : EntryActionOperation(registry, url_request_context_getter, callback),
+    : EntryActionOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       parent_resource_id_(parent_resource_id),
       resource_id_(resource_id) {
   DCHECK(!callback.is_null());
 }
 
 AddResourceToDirectoryOperation::~AddResourceToDirectoryOperation() {}
 
 GURL AddResourceToDirectoryOperation::GetURL() const {
   return url_generator_.GenerateContentUrl(parent_resource_id_);
@@ skipping 19 matching lines @@
   xml_writer.StopWriting();
   upload_content->assign(xml_writer.GetWrittenString());
   DVLOG(1) << "AddResourceToDirectoryOperation data: " << *upload_content_type
            << ", [" << *upload_content << "]";
   return true;
 }
 
 //==================== RemoveResourceFromDirectoryOperation ====================
 
 RemoveResourceFromDirectoryOperation::RemoveResourceFromDirectoryOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const EntryActionCallback& callback,
     const std::string& parent_resource_id,
     const std::string& document_resource_id)
-    : EntryActionOperation(registry, url_request_context_getter, callback),
+    : EntryActionOperation(runner, url_request_context_getter, callback),
       url_generator_(url_generator),
       resource_id_(document_resource_id),
       parent_resource_id_(parent_resource_id) {
   DCHECK(!callback.is_null());
 }
 
 RemoveResourceFromDirectoryOperation::~RemoveResourceFromDirectoryOperation() {
 }
 
 GURL RemoveResourceFromDirectoryOperation::GetURL() const {
   return url_generator_.GenerateResourceUrlForRemoval(
       parent_resource_id_, resource_id_);
 }
 
 URLFetcher::RequestType
 RemoveResourceFromDirectoryOperation::GetRequestType() const {
   return URLFetcher::DELETE_REQUEST;
 }
 
 std::vector<std::string>
 RemoveResourceFromDirectoryOperation::GetExtraRequestHeaders() const {
   std::vector<std::string> headers;
   headers.push_back(util::kIfMatchAllHeader);
   return headers;
 }
 
 //======================= InitiateUploadNewFileOperation =======================
 
 InitiateUploadNewFileOperation::InitiateUploadNewFileOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const InitiateUploadCallback& callback,
     const base::FilePath& drive_file_path,
     const std::string& content_type,
     int64 content_length,
     const std::string& parent_resource_id,
     const std::string& title)
-    : InitiateUploadOperationBase(registry,
+    : InitiateUploadOperationBase(runner,
                                   url_request_context_getter,
                                   callback,
                                   drive_file_path,
                                   content_type,
                                   content_length),
       url_generator_(url_generator),
       parent_resource_id_(parent_resource_id),
       title_(title) {
 }
 
@@ skipping 23 matching lines @@
   xml_writer.StopWriting();
   upload_content->assign(xml_writer.GetWrittenString());
   DVLOG(1) << "InitiateUploadNewFile: " << *upload_content_type << ", ["
            << *upload_content << "]";
   return true;
 }
 
 //===================== InitiateUploadExistingFileOperation ====================
 
 InitiateUploadExistingFileOperation::InitiateUploadExistingFileOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GDataWapiUrlGenerator& url_generator,
     const InitiateUploadCallback& callback,
     const base::FilePath& drive_file_path,
     const std::string& content_type,
     int64 content_length,
     const std::string& resource_id,
     const std::string& etag)
-    : InitiateUploadOperationBase(registry,
+    : InitiateUploadOperationBase(runner,
                                   url_request_context_getter,
                                   callback,
                                   drive_file_path,
                                   content_type,
                                   content_length),
       url_generator_(url_generator),
       resource_id_(resource_id),
       etag_(etag) {
 }
 
@@ skipping 24 matching lines @@
 InitiateUploadExistingFileOperation::GetExtraRequestHeaders() const {
   std::vector<std::string> headers(
       InitiateUploadOperationBase::GetExtraRequestHeaders());
   headers.push_back(util::GenerateIfMatchHeader(etag_));
   return headers;
 }
 
 //============================ ResumeUploadOperation ===========================
 
 ResumeUploadOperation::ResumeUploadOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const UploadRangeCallback& callback,
     const ProgressCallback& progress_callback,
     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)
-    : ResumeUploadOperationBase(registry,
+    : ResumeUploadOperationBase(runner,
                                 url_request_context_getter,
                                 drive_file_path,
                                 upload_location,
                                 start_position,
                                 end_position,
                                 content_length,
                                 content_type,
                                 local_file_path),
       callback_(callback),
       progress_callback_(progress_callback) {
   DCHECK(!callback_.is_null());
 }
 
 ResumeUploadOperation::~ResumeUploadOperation() {}
 
 void ResumeUploadOperation::OnRangeOperationComplete(
     const UploadRangeResponse& response, scoped_ptr<base::Value> value) {
   callback_.Run(response, ParseResourceEntry(value.Pass()));
 }
 
 void ResumeUploadOperation::OnURLFetchUploadProgress(
     const URLFetcher* source, int64 current, int64 total) {
   if (!progress_callback_.is_null())
     progress_callback_.Run(current, total);
 }
 
 //========================== GetUploadStatusOperation ==========================
 
 GetUploadStatusOperation::GetUploadStatusOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const UploadRangeCallback& callback,
     const base::FilePath& drive_file_path,
     const GURL& upload_url,
     int64 content_length)
-  : GetUploadStatusOperationBase(registry,
+  : GetUploadStatusOperationBase(runner,
                                  url_request_context_getter,
                                  drive_file_path,
                                  upload_url,
                                  content_length),
     callback_(callback) {
   DCHECK(!callback.is_null());
 }
 
 GetUploadStatusOperation::~GetUploadStatusOperation() {}
 
 void GetUploadStatusOperation::OnRangeOperationComplete(
     const UploadRangeResponse& response, scoped_ptr<base::Value> value) {
   callback_.Run(response, ParseResourceEntry(value.Pass()));
 }
 
 }  // namespace google_apis