Replace most of the occurrence of OperationRegistry with OperationRunner.

chrome/browser/google_apis/base_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/base_operations.h"
 
 #include "base/json/json_reader.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"
 #include "base/values.h"
+#include "chrome/browser/google_apis/operation_runner.h"
 #include "content/public/browser/browser_thread.h"
 #include "net/base/load_flags.h"
 #include "net/base/net_errors.h"
 #include "net/http/http_byte_range.h"
 #include "net/http/http_response_headers.h"
 #include "net/http/http_util.h"
 #include "net/url_request/url_fetcher.h"
 #include "net/url_request/url_request_status.h"
 
 using content::BrowserThread;
@@ skipping 62 matching lines @@
   base::PostTaskAndReplyWithResult(
       BrowserThread::GetBlockingPool(),
       FROM_HERE,
       base::Bind(&ParseJsonOnBlockingPool, json),
       callback);
 }
 
 //============================ UrlFetchOperationBase ===========================
 
 UrlFetchOperationBase::UrlFetchOperationBase(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter)
-    : OperationRegistry::Operation(registry),
+    : OperationRegistry::Operation(runner->operation_registry()),
       url_request_context_getter_(url_request_context_getter),
       re_authenticate_count_(0),
       started_(false),
       save_temp_file_(false),
       weak_ptr_factory_(this) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
 }
 
 UrlFetchOperationBase::UrlFetchOperationBase(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const base::FilePath& path)
-    : OperationRegistry::Operation(registry, path),
+    : OperationRegistry::Operation(runner->operation_registry(), path),
       url_request_context_getter_(url_request_context_getter),
       re_authenticate_count_(0),
       started_(false),
       save_temp_file_(false),
       weak_ptr_factory_(this) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
 }
 
 UrlFetchOperationBase::~UrlFetchOperationBase() {}
 
@@ skipping 180 matching lines @@
 }
 
 base::WeakPtr<AuthenticatedOperationInterface>
 UrlFetchOperationBase::GetWeakPtr() {
   return weak_ptr_factory_.GetWeakPtr();
 }
 
 //============================ EntryActionOperation ============================
 
 EntryActionOperation::EntryActionOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const EntryActionCallback& callback)
-    : UrlFetchOperationBase(registry, url_request_context_getter),
+    : UrlFetchOperationBase(runner, url_request_context_getter),
       callback_(callback) {
   DCHECK(!callback_.is_null());
 }
 
 EntryActionOperation::~EntryActionOperation() {}
 
 void EntryActionOperation::ProcessURLFetchResults(const URLFetcher* source) {
   GDataErrorCode code = GetErrorCode(source);
   callback_.Run(code);
   const bool success = true;
   OnProcessURLFetchResultsComplete(success);
 }
 
 void EntryActionOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
   callback_.Run(code);
 }
 
 //============================== GetDataOperation ==============================
 
 GetDataOperation::GetDataOperation(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GetDataCallback& callback)
-    : UrlFetchOperationBase(registry, url_request_context_getter),
+    : UrlFetchOperationBase(runner, url_request_context_getter),
       callback_(callback),
       weak_ptr_factory_(this) {
   DCHECK(!callback_.is_null());
 }
 
 GetDataOperation::~GetDataOperation() {}
 
 void GetDataOperation::ParseResponse(GDataErrorCode fetch_error_code,
                                      const std::string& data) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
@@ skipping 49 matching lines @@
 
 void GetDataOperation::RunCallbackOnSuccess(GDataErrorCode fetch_error_code,
                                             scoped_ptr<base::Value> value) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   callback_.Run(fetch_error_code, value.Pass());
 }
 
 //========================= InitiateUploadOperationBase ========================
 
 InitiateUploadOperationBase::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)
-    : UrlFetchOperationBase(registry,
+    : UrlFetchOperationBase(runner,
                             url_request_context_getter,
                             drive_file_path),
       callback_(callback),
       drive_file_path_(drive_file_path),
       content_type_(content_type),
       content_length_(content_length) {
   DCHECK(!callback_.is_null());
   DCHECK(!content_type_.empty());
   DCHECK_GE(content_length_, 0);
 }
@@ skipping 52 matching lines @@
       start_position_received(start_position_received),
       end_position_received(end_position_received) {
 }
 
 UploadRangeResponse::~UploadRangeResponse() {
 }
 
 //========================== UploadRangeOperationBase ==========================
 
 UploadRangeOperationBase::UploadRangeOperationBase(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const base::FilePath& drive_file_path,
     const GURL& upload_url)
-    : UrlFetchOperationBase(registry,
+    : UrlFetchOperationBase(runner,
                             url_request_context_getter,
                             drive_file_path),
       drive_file_path_(drive_file_path),
       upload_url_(upload_url),
       last_chunk_completed_(false),
       weak_ptr_factory_(this) {
 }
 
 UploadRangeOperationBase::~UploadRangeOperationBase() {}
 
@@ skipping 86 matching lines @@
 
 void UploadRangeOperationBase::RunCallbackOnPrematureFailure(
     GDataErrorCode code) {
   OnRangeOperationComplete(
       UploadRangeResponse(code, 0, 0), scoped_ptr<base::Value>());
 }
 
 //========================== ResumeUploadOperationBase =========================
 
 ResumeUploadOperationBase::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)
-    : UploadRangeOperationBase(registry,
+    : UploadRangeOperationBase(runner,
                                url_request_context_getter,
                                drive_file_path,
                                upload_location),
       start_position_(start_position),
       end_position_(end_position),
       content_length_(content_length),
       content_type_(content_type),
       local_file_path_(local_file_path) {
   DCHECK_LE(start_position_, end_position_);
 }
@@ skipping 44 matching lines @@
   return true;
 }
 
 void ResumeUploadOperationBase::NotifyStartToOperationRegistry() {
   NotifyResume();
 }
 
 //======================== GetUploadStatusOperationBase ========================
 
 GetUploadStatusOperationBase::GetUploadStatusOperationBase(
-    OperationRegistry* registry,
+    OperationRunner* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const base::FilePath& drive_file_path,
     const GURL& upload_url,
     int64 content_length)
-  : UploadRangeOperationBase(registry,
+  : UploadRangeOperationBase(runner,
                              url_request_context_getter,
                              drive_file_path,
                              upload_url),
     content_length_(content_length) {}
 
 GetUploadStatusOperationBase::~GetUploadStatusOperationBase() {}
 
 std::vector<std::string>
 GetUploadStatusOperationBase::GetExtraRequestHeaders() const {
   // The header looks like
   // Content-Range: bytes */<content_length>
   // for example:
   // Content-Range: bytes */13851821
   DCHECK_GE(content_length_, 0);
 
   std::vector<std::string> headers;
   headers.push_back(
       std::string(kUploadContentRange) + "*/" +
       base::Int64ToString(content_length_));
   return headers;
 }
 
 //============================ DownloadFileOperation ===========================
 
 DownloadFileOperation::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)
-    : UrlFetchOperationBase(registry,
+    : UrlFetchOperationBase(runner,
                             url_request_context_getter,
                             drive_file_path),
       download_action_callback_(download_action_callback),
       get_content_callback_(get_content_callback),
       progress_callback_(progress_callback),
       download_url_(download_url) {
   DCHECK(!download_action_callback_.is_null());
   // get_content_callback may be null.
 
   // Make sure we download the content into a temp file.
@@ skipping 41 matching lines @@
 
   download_action_callback_.Run(code, temp_file);
   OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
 }
 
 void DownloadFileOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
   download_action_callback_.Run(code, base::FilePath());
 }
 
 }  // namespace google_apis