google_apis: Rename OperationRunner to RequestSender

chrome/browser/google_apis/base_requests.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_requests.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 "chrome/browser/google_apis/request_sender.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);
 }
 
 //============================ UrlFetchRequestBase ===========================
 
 UrlFetchRequestBase::UrlFetchRequestBase(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter)
     : 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));
 }
 
 UrlFetchRequestBase::UrlFetchRequestBase(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const base::FilePath& 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));
 }
@@ skipping 183 matching lines @@
 }
 
 base::WeakPtr<AuthenticatedRequestInterface>
 UrlFetchRequestBase::GetWeakPtr() {
   return weak_ptr_factory_.GetWeakPtr();
 }
 
 //============================ EntryActionRequest ============================
 
 EntryActionRequest::EntryActionRequest(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const EntryActionCallback& callback)
     : UrlFetchRequestBase(runner, url_request_context_getter),
       callback_(callback) {
   DCHECK(!callback_.is_null());
 }
 
 EntryActionRequest::~EntryActionRequest() {}
 
 void EntryActionRequest::ProcessURLFetchResults(const URLFetcher* source) {
   GDataErrorCode code = GetErrorCode(source);
   callback_.Run(code);
   const bool success = true;
   OnProcessURLFetchResultsComplete(success);
 }
 
 void EntryActionRequest::RunCallbackOnPrematureFailure(GDataErrorCode code) {
   callback_.Run(code);
 }
 
 //============================== GetDataRequest ==============================
 
 GetDataRequest::GetDataRequest(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const GetDataCallback& callback)
     : UrlFetchRequestBase(runner, url_request_context_getter),
       callback_(callback),
       weak_ptr_factory_(this) {
   DCHECK(!callback_.is_null());
 }
 
 GetDataRequest::~GetDataRequest() {}
 
@@ skipping 52 matching lines @@
 
 void GetDataRequest::RunCallbackOnSuccess(GDataErrorCode fetch_error_code,
                                           scoped_ptr<base::Value> value) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   callback_.Run(fetch_error_code, value.Pass());
 }
 
 //========================= InitiateUploadRequestBase ========================
 
 InitiateUploadRequestBase::InitiateUploadRequestBase(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const InitiateUploadCallback& callback,
     const base::FilePath& drive_file_path,
     const std::string& content_type,
     int64 content_length)
     : UrlFetchRequestBase(runner,
                           url_request_context_getter,
                           drive_file_path),
       callback_(callback),
       drive_file_path_(drive_file_path),
@@ skipping 58 matching lines @@
       start_position_received(start_position_received),
       end_position_received(end_position_received) {
 }
 
 UploadRangeResponse::~UploadRangeResponse() {
 }
 
 //========================== UploadRangeRequestBase ==========================
 
 UploadRangeRequestBase::UploadRangeRequestBase(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const base::FilePath& drive_file_path,
     const GURL& upload_url)
     : UrlFetchRequestBase(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) {
@@ skipping 90 matching lines @@
 
 void UploadRangeRequestBase::RunCallbackOnPrematureFailure(
     GDataErrorCode code) {
   OnRangeRequestComplete(
       UploadRangeResponse(code, 0, 0), scoped_ptr<base::Value>());
 }
 
 //========================== ResumeUploadRequestBase =========================
 
 ResumeUploadRequestBase::ResumeUploadRequestBase(
-    OperationRunner* runner,
+    RequestSender* 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)
     : UploadRangeRequestBase(runner,
                              url_request_context_getter,
@@ skipping 53 matching lines @@
   return true;
 }
 
 void ResumeUploadRequestBase::NotifyStartToOperationRegistry() {
   NotifyResume();
 }
 
 //======================== GetUploadStatusRequestBase ========================
 
 GetUploadStatusRequestBase::GetUploadStatusRequestBase(
-    OperationRunner* runner,
+    RequestSender* runner,
     net::URLRequestContextGetter* url_request_context_getter,
     const base::FilePath& drive_file_path,
     const GURL& upload_url,
     int64 content_length)
     : UploadRangeRequestBase(runner,
                              url_request_context_getter,
                              drive_file_path,
                              upload_url),
       content_length_(content_length) {}
 
@@ skipping 10 matching lines @@
   std::vector<std::string> headers;
   headers.push_back(
       std::string(kUploadContentRange) + "*/" +
       base::Int64ToString(content_length_));
   return headers;
 }
 
 //============================ DownloadFileRequest ===========================
 
 DownloadFileRequest::DownloadFileRequest(
-    OperationRunner* runner,
+    RequestSender* 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)
     : UrlFetchRequestBase(runner,
                           url_request_context_getter,
                           drive_file_path),
@@ skipping 49 matching lines @@
 
   download_action_callback_.Run(code, temp_file);
   OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
 }
 
 void DownloadFileRequest::RunCallbackOnPrematureFailure(GDataErrorCode code) {
   download_action_callback_.Run(code, base::FilePath());
 }
 
 }  // namespace google_apis