| Index: chrome/browser/google_apis/base_requests.cc
|
| diff --git a/chrome/browser/google_apis/base_operations.cc b/chrome/browser/google_apis/base_requests.cc
|
| similarity index 74%
|
| rename from chrome/browser/google_apis/base_operations.cc
|
| rename to chrome/browser/google_apis/base_requests.cc
|
| index 2469ccba584389f65c83e715adcca085182d9435..5ed4300832595619179cebac2180dac67cf15e70 100644
|
| --- a/chrome/browser/google_apis/base_operations.cc
|
| +++ b/chrome/browser/google_apis/base_requests.cc
|
| @@ -2,7 +2,7 @@
|
| // 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 "chrome/browser/google_apis/base_requests.h"
|
|
|
| #include "base/json/json_reader.h"
|
| #include "base/stringprintf.h"
|
| @@ -30,8 +30,8 @@ const char kAuthorizationHeaderFormat[] = "Authorization: Bearer %s";
|
| // Template for GData API version HTTP header.
|
| const char kGDataVersionHeader[] = "GData-Version: 3.0";
|
|
|
| -// Maximum number of attempts for re-authentication per operation.
|
| -const int kMaxReAuthenticateAttemptsPerOperation = 1;
|
| +// Maximum number of attempts for re-authentication per request.
|
| +const int kMaxReAuthenticateAttemptsPerRequest = 1;
|
|
|
| // Template for initiate upload of both GData WAPI and Drive API v2.
|
| const char kUploadContentType[] = "X-Upload-Content-Type: ";
|
| @@ -90,9 +90,9 @@ void ParseJson(const std::string& json, const ParseJsonCallback& callback) {
|
| callback);
|
| }
|
|
|
| -//============================ UrlFetchOperationBase ===========================
|
| +//============================ UrlFetchRequestBase ===========================
|
|
|
| -UrlFetchOperationBase::UrlFetchOperationBase(
|
| +UrlFetchRequestBase::UrlFetchRequestBase(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter)
|
| : OperationRegistry::Operation(runner->operation_registry()),
|
| @@ -104,7 +104,7 @@ UrlFetchOperationBase::UrlFetchOperationBase(
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| }
|
|
|
| -UrlFetchOperationBase::UrlFetchOperationBase(
|
| +UrlFetchRequestBase::UrlFetchRequestBase(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const base::FilePath& path)
|
| @@ -117,11 +117,11 @@ UrlFetchOperationBase::UrlFetchOperationBase(
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| }
|
|
|
| -UrlFetchOperationBase::~UrlFetchOperationBase() {}
|
| +UrlFetchRequestBase::~UrlFetchRequestBase() {}
|
|
|
| -void UrlFetchOperationBase::Start(const std::string& access_token,
|
| - const std::string& custom_user_agent,
|
| - const ReAuthenticateCallback& callback) {
|
| +void UrlFetchRequestBase::Start(const std::string& access_token,
|
| + const std::string& custom_user_agent,
|
| + const ReAuthenticateCallback& callback) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| DCHECK(url_request_context_getter_);
|
| DCHECK(!access_token.empty());
|
| @@ -152,7 +152,8 @@ void UrlFetchOperationBase::Start(const std::string& access_token,
|
| url_fetcher_->SaveResponseToTemporaryFile(
|
| BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE));
|
| } else if (!output_file_path_.empty()) {
|
| - url_fetcher_->SaveResponseToFileAtPath(output_file_path_,
|
| + url_fetcher_->SaveResponseToFileAtPath(
|
| + output_file_path_,
|
| BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE));
|
| }
|
|
|
| @@ -164,7 +165,7 @@ void UrlFetchOperationBase::Start(const std::string& access_token,
|
| url_fetcher_->AddExtraRequestHeader("User-Agent: " + custom_user_agent);
|
| url_fetcher_->AddExtraRequestHeader(kGDataVersionHeader);
|
| url_fetcher_->AddExtraRequestHeader(
|
| - base::StringPrintf(kAuthorizationHeaderFormat, access_token.data()));
|
| + base::StringPrintf(kAuthorizationHeaderFormat, access_token.data()));
|
| std::vector<std::string> headers = GetExtraRequestHeaders();
|
| for (size_t i = 0; i < headers.size(); ++i) {
|
| url_fetcher_->AddExtraRequestHeader(headers[i]);
|
| @@ -210,33 +211,33 @@ void UrlFetchOperationBase::Start(const std::string& access_token,
|
| started_ = true;
|
| }
|
|
|
| -URLFetcher::RequestType UrlFetchOperationBase::GetRequestType() const {
|
| +URLFetcher::RequestType UrlFetchRequestBase::GetRequestType() const {
|
| return URLFetcher::GET;
|
| }
|
|
|
| -std::vector<std::string> UrlFetchOperationBase::GetExtraRequestHeaders() const {
|
| +std::vector<std::string> UrlFetchRequestBase::GetExtraRequestHeaders() const {
|
| return std::vector<std::string>();
|
| }
|
|
|
| -bool UrlFetchOperationBase::GetContentData(std::string* upload_content_type,
|
| - std::string* upload_content) {
|
| +bool UrlFetchRequestBase::GetContentData(std::string* upload_content_type,
|
| + std::string* upload_content) {
|
| return false;
|
| }
|
|
|
| -bool UrlFetchOperationBase::GetContentFile(base::FilePath* local_file_path,
|
| - int64* range_offset,
|
| - int64* range_length,
|
| - std::string* upload_content_type) {
|
| +bool UrlFetchRequestBase::GetContentFile(base::FilePath* local_file_path,
|
| + int64* range_offset,
|
| + int64* range_length,
|
| + std::string* upload_content_type) {
|
| return false;
|
| }
|
|
|
| -void UrlFetchOperationBase::DoCancel() {
|
| +void UrlFetchRequestBase::DoCancel() {
|
| url_fetcher_.reset(NULL);
|
| RunCallbackOnPrematureFailure(GDATA_CANCELLED);
|
| }
|
|
|
| // static
|
| -GDataErrorCode UrlFetchOperationBase::GetErrorCode(const URLFetcher* source) {
|
| +GDataErrorCode UrlFetchRequestBase::GetErrorCode(const URLFetcher* source) {
|
| GDataErrorCode code = static_cast<GDataErrorCode>(source->GetResponseCode());
|
| if (!source->GetStatus().is_success()) {
|
| switch (source->GetStatus().error()) {
|
| @@ -250,19 +251,19 @@ GDataErrorCode UrlFetchOperationBase::GetErrorCode(const URLFetcher* source) {
|
| return code;
|
| }
|
|
|
| -void UrlFetchOperationBase::OnProcessURLFetchResultsComplete(bool result) {
|
| +void UrlFetchRequestBase::OnProcessURLFetchResultsComplete(bool result) {
|
| if (result)
|
| NotifySuccessToOperationRegistry();
|
| else
|
| NotifyFinish(OPERATION_FAILED);
|
| }
|
|
|
| -void UrlFetchOperationBase::OnURLFetchComplete(const URLFetcher* source) {
|
| +void UrlFetchRequestBase::OnURLFetchComplete(const URLFetcher* source) {
|
| GDataErrorCode code = GetErrorCode(source);
|
| DVLOG(1) << "Response headers:\n" << GetResponseHeadersAsString(source);
|
|
|
| if (code == HTTP_UNAUTHORIZED) {
|
| - if (++re_authenticate_count_ <= kMaxReAuthenticateAttemptsPerOperation) {
|
| + if (++re_authenticate_count_ <= kMaxReAuthenticateAttemptsPerRequest) {
|
| // Reset re_authenticate_callback_ so Start() can be called again.
|
| ReAuthenticateCallback callback = re_authenticate_callback_;
|
| re_authenticate_callback_.Reset();
|
| @@ -278,15 +279,15 @@ void UrlFetchOperationBase::OnURLFetchComplete(const URLFetcher* source) {
|
| ProcessURLFetchResults(source);
|
| }
|
|
|
| -void UrlFetchOperationBase::NotifySuccessToOperationRegistry() {
|
| +void UrlFetchRequestBase::NotifySuccessToOperationRegistry() {
|
| NotifyFinish(OPERATION_COMPLETED);
|
| }
|
|
|
| -void UrlFetchOperationBase::NotifyStartToOperationRegistry() {
|
| +void UrlFetchRequestBase::NotifyStartToOperationRegistry() {
|
| NotifyStart();
|
| }
|
|
|
| -void UrlFetchOperationBase::OnAuthFailed(GDataErrorCode code) {
|
| +void UrlFetchRequestBase::OnAuthFailed(GDataErrorCode code) {
|
| RunCallbackOnPrematureFailure(code);
|
|
|
| // Check if this failed before we even started fetching. If so, register
|
| @@ -296,67 +297,66 @@ void UrlFetchOperationBase::OnAuthFailed(GDataErrorCode code) {
|
|
|
| // Note: NotifyFinish() must be invoked at the end, after all other callbacks
|
| // and notifications. Once NotifyFinish() is called, the current instance of
|
| - // gdata operation will be deleted from the OperationRegistry and become
|
| - // invalid.
|
| + // request will be deleted from the OperationRegistry and become invalid.
|
| NotifyFinish(OPERATION_FAILED);
|
| }
|
|
|
| -base::WeakPtr<AuthenticatedOperationInterface>
|
| -UrlFetchOperationBase::GetWeakPtr() {
|
| +base::WeakPtr<AuthenticatedRequestInterface>
|
| +UrlFetchRequestBase::GetWeakPtr() {
|
| return weak_ptr_factory_.GetWeakPtr();
|
| }
|
|
|
| -//============================ EntryActionOperation ============================
|
| +//============================ EntryActionRequest ============================
|
|
|
| -EntryActionOperation::EntryActionOperation(
|
| +EntryActionRequest::EntryActionRequest(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const EntryActionCallback& callback)
|
| - : UrlFetchOperationBase(runner, url_request_context_getter),
|
| + : UrlFetchRequestBase(runner, url_request_context_getter),
|
| callback_(callback) {
|
| DCHECK(!callback_.is_null());
|
| }
|
|
|
| -EntryActionOperation::~EntryActionOperation() {}
|
| +EntryActionRequest::~EntryActionRequest() {}
|
|
|
| -void EntryActionOperation::ProcessURLFetchResults(const URLFetcher* source) {
|
| +void EntryActionRequest::ProcessURLFetchResults(const URLFetcher* source) {
|
| GDataErrorCode code = GetErrorCode(source);
|
| callback_.Run(code);
|
| const bool success = true;
|
| OnProcessURLFetchResultsComplete(success);
|
| }
|
|
|
| -void EntryActionOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
|
| +void EntryActionRequest::RunCallbackOnPrematureFailure(GDataErrorCode code) {
|
| callback_.Run(code);
|
| }
|
|
|
| -//============================== GetDataOperation ==============================
|
| +//============================== GetDataRequest ==============================
|
|
|
| -GetDataOperation::GetDataOperation(
|
| +GetDataRequest::GetDataRequest(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const GetDataCallback& callback)
|
| - : UrlFetchOperationBase(runner, url_request_context_getter),
|
| + : UrlFetchRequestBase(runner, url_request_context_getter),
|
| callback_(callback),
|
| weak_ptr_factory_(this) {
|
| DCHECK(!callback_.is_null());
|
| }
|
|
|
| -GetDataOperation::~GetDataOperation() {}
|
| +GetDataRequest::~GetDataRequest() {}
|
|
|
| -void GetDataOperation::ParseResponse(GDataErrorCode fetch_error_code,
|
| - const std::string& data) {
|
| +void GetDataRequest::ParseResponse(GDataErrorCode fetch_error_code,
|
| + const std::string& data) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
|
|
| VLOG(1) << "JSON received from " << GetURL().spec() << ": "
|
| << data.size() << " bytes";
|
| ParseJson(data,
|
| - base::Bind(&GetDataOperation::OnDataParsed,
|
| + base::Bind(&GetDataRequest::OnDataParsed,
|
| weak_ptr_factory_.GetWeakPtr(),
|
| fetch_error_code));
|
| }
|
|
|
| -void GetDataOperation::ProcessURLFetchResults(const URLFetcher* source) {
|
| +void GetDataRequest::ProcessURLFetchResults(const URLFetcher* source) {
|
| std::string data;
|
| source->GetResponseAsString(&data);
|
| scoped_ptr<base::Value> root_value;
|
| @@ -375,12 +375,12 @@ void GetDataOperation::ProcessURLFetchResults(const URLFetcher* source) {
|
| }
|
| }
|
|
|
| -void GetDataOperation::RunCallbackOnPrematureFailure(
|
| +void GetDataRequest::RunCallbackOnPrematureFailure(
|
| GDataErrorCode fetch_error_code) {
|
| callback_.Run(fetch_error_code, scoped_ptr<base::Value>());
|
| }
|
|
|
| -void GetDataOperation::OnDataParsed(
|
| +void GetDataRequest::OnDataParsed(
|
| GDataErrorCode fetch_error_code,
|
| scoped_ptr<base::Value> value) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| @@ -397,24 +397,24 @@ void GetDataOperation::OnDataParsed(
|
| OnProcessURLFetchResultsComplete(success);
|
| }
|
|
|
| -void GetDataOperation::RunCallbackOnSuccess(GDataErrorCode fetch_error_code,
|
| - scoped_ptr<base::Value> value) {
|
| +void GetDataRequest::RunCallbackOnSuccess(GDataErrorCode fetch_error_code,
|
| + scoped_ptr<base::Value> value) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| callback_.Run(fetch_error_code, value.Pass());
|
| }
|
|
|
| -//========================= InitiateUploadOperationBase ========================
|
| +//========================= InitiateUploadRequestBase ========================
|
|
|
| -InitiateUploadOperationBase::InitiateUploadOperationBase(
|
| +InitiateUploadRequestBase::InitiateUploadRequestBase(
|
| 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(runner,
|
| - url_request_context_getter,
|
| - drive_file_path),
|
| + : UrlFetchRequestBase(runner,
|
| + url_request_context_getter,
|
| + drive_file_path),
|
| callback_(callback),
|
| drive_file_path_(drive_file_path),
|
| content_type_(content_type),
|
| @@ -424,9 +424,9 @@ InitiateUploadOperationBase::InitiateUploadOperationBase(
|
| DCHECK_GE(content_length_, 0);
|
| }
|
|
|
| -InitiateUploadOperationBase::~InitiateUploadOperationBase() {}
|
| +InitiateUploadRequestBase::~InitiateUploadRequestBase() {}
|
|
|
| -void InitiateUploadOperationBase::ProcessURLFetchResults(
|
| +void InitiateUploadRequestBase::ProcessURLFetchResults(
|
| const URLFetcher* source) {
|
| GDataErrorCode code = GetErrorCode(source);
|
|
|
| @@ -445,17 +445,17 @@ void InitiateUploadOperationBase::ProcessURLFetchResults(
|
| OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
|
| }
|
|
|
| -void InitiateUploadOperationBase::NotifySuccessToOperationRegistry() {
|
| +void InitiateUploadRequestBase::NotifySuccessToOperationRegistry() {
|
| NotifySuspend();
|
| }
|
|
|
| -void InitiateUploadOperationBase::RunCallbackOnPrematureFailure(
|
| +void InitiateUploadRequestBase::RunCallbackOnPrematureFailure(
|
| GDataErrorCode code) {
|
| callback_.Run(code, GURL());
|
| }
|
|
|
| std::vector<std::string>
|
| -InitiateUploadOperationBase::GetExtraRequestHeaders() const {
|
| +InitiateUploadRequestBase::GetExtraRequestHeaders() const {
|
| std::vector<std::string> headers;
|
| headers.push_back(kUploadContentType + content_type_);
|
| headers.push_back(
|
| @@ -482,35 +482,35 @@ UploadRangeResponse::UploadRangeResponse(GDataErrorCode code,
|
| UploadRangeResponse::~UploadRangeResponse() {
|
| }
|
|
|
| -//========================== UploadRangeOperationBase ==========================
|
| +//========================== UploadRangeRequestBase ==========================
|
|
|
| -UploadRangeOperationBase::UploadRangeOperationBase(
|
| +UploadRangeRequestBase::UploadRangeRequestBase(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const base::FilePath& drive_file_path,
|
| const GURL& upload_url)
|
| - : UrlFetchOperationBase(runner,
|
| - url_request_context_getter,
|
| - drive_file_path),
|
| + : 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) {
|
| }
|
|
|
| -UploadRangeOperationBase::~UploadRangeOperationBase() {}
|
| +UploadRangeRequestBase::~UploadRangeRequestBase() {}
|
|
|
| -GURL UploadRangeOperationBase::GetURL() const {
|
| - // This is very tricky to get json from this operation. To do that, &alt=json
|
| - // has to be appended not here but in InitiateUploadOperation::GetURL().
|
| +GURL UploadRangeRequestBase::GetURL() const {
|
| + // This is very tricky to get json from this request. To do that, &alt=json
|
| + // has to be appended not here but in InitiateUploadRequestBase::GetURL().
|
| return upload_url_;
|
| }
|
|
|
| -URLFetcher::RequestType UploadRangeOperationBase::GetRequestType() const {
|
| +URLFetcher::RequestType UploadRangeRequestBase::GetRequestType() const {
|
| return URLFetcher::PUT;
|
| }
|
|
|
| -void UploadRangeOperationBase::ProcessURLFetchResults(
|
| +void UploadRangeRequestBase::ProcessURLFetchResults(
|
| const URLFetcher* source) {
|
| GDataErrorCode code = GetErrorCode(source);
|
| net::HttpResponseHeaders* hdrs = source->GetResponseHeaders();
|
| @@ -546,10 +546,10 @@ void UploadRangeOperationBase::ProcessURLFetchResults(
|
| << "], range_parsed=" << start_position_received
|
| << "," << end_position_received;
|
|
|
| - OnRangeOperationComplete(UploadRangeResponse(code,
|
| - start_position_received,
|
| - end_position_received),
|
| - scoped_ptr<base::Value>());
|
| + OnRangeRequestComplete(UploadRangeResponse(code,
|
| + start_position_received,
|
| + end_position_received),
|
| + scoped_ptr<base::Value>());
|
|
|
| OnProcessURLFetchResultsComplete(true);
|
| } else {
|
| @@ -561,14 +561,14 @@ void UploadRangeOperationBase::ProcessURLFetchResults(
|
| << ", content=[\n" << response_content << "\n]";
|
|
|
| ParseJson(response_content,
|
| - base::Bind(&UploadRangeOperationBase::OnDataParsed,
|
| + base::Bind(&UploadRangeRequestBase::OnDataParsed,
|
| weak_ptr_factory_.GetWeakPtr(),
|
| code));
|
| }
|
| }
|
|
|
| -void UploadRangeOperationBase::OnDataParsed(GDataErrorCode code,
|
| - scoped_ptr<base::Value> value) {
|
| +void UploadRangeRequestBase::OnDataParsed(GDataErrorCode code,
|
| + scoped_ptr<base::Value> value) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
|
|
| // For a new file, HTTP_CREATED is returned.
|
| @@ -576,26 +576,26 @@ void UploadRangeOperationBase::OnDataParsed(GDataErrorCode code,
|
| if (code == HTTP_CREATED || code == HTTP_SUCCESS)
|
| last_chunk_completed_ = true;
|
|
|
| - OnRangeOperationComplete(UploadRangeResponse(code, -1, -1), value.Pass());
|
| + OnRangeRequestComplete(UploadRangeResponse(code, -1, -1), value.Pass());
|
| OnProcessURLFetchResultsComplete(last_chunk_completed_);
|
| }
|
|
|
| -void UploadRangeOperationBase::NotifySuccessToOperationRegistry() {
|
| +void UploadRangeRequestBase::NotifySuccessToOperationRegistry() {
|
| if (last_chunk_completed_)
|
| NotifyFinish(OPERATION_COMPLETED);
|
| else
|
| NotifySuspend();
|
| }
|
|
|
| -void UploadRangeOperationBase::RunCallbackOnPrematureFailure(
|
| +void UploadRangeRequestBase::RunCallbackOnPrematureFailure(
|
| GDataErrorCode code) {
|
| - OnRangeOperationComplete(
|
| + OnRangeRequestComplete(
|
| UploadRangeResponse(code, 0, 0), scoped_ptr<base::Value>());
|
| }
|
|
|
| -//========================== ResumeUploadOperationBase =========================
|
| +//========================== ResumeUploadRequestBase =========================
|
|
|
| -ResumeUploadOperationBase::ResumeUploadOperationBase(
|
| +ResumeUploadRequestBase::ResumeUploadRequestBase(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const base::FilePath& drive_file_path,
|
| @@ -605,10 +605,10 @@ ResumeUploadOperationBase::ResumeUploadOperationBase(
|
| int64 content_length,
|
| const std::string& content_type,
|
| const base::FilePath& local_file_path)
|
| - : UploadRangeOperationBase(runner,
|
| - url_request_context_getter,
|
| - drive_file_path,
|
| - upload_location),
|
| + : UploadRangeRequestBase(runner,
|
| + url_request_context_getter,
|
| + drive_file_path,
|
| + upload_location),
|
| start_position_(start_position),
|
| end_position_(end_position),
|
| content_length_(content_length),
|
| @@ -617,10 +617,10 @@ ResumeUploadOperationBase::ResumeUploadOperationBase(
|
| DCHECK_LE(start_position_, end_position_);
|
| }
|
|
|
| -ResumeUploadOperationBase::~ResumeUploadOperationBase() {}
|
| +ResumeUploadRequestBase::~ResumeUploadRequestBase() {}
|
|
|
| std::vector<std::string>
|
| -ResumeUploadOperationBase::GetExtraRequestHeaders() const {
|
| +ResumeUploadRequestBase::GetExtraRequestHeaders() const {
|
| if (content_length_ == 0) {
|
| // For uploading an empty document, just PUT an empty content.
|
| DCHECK_EQ(start_position_, 0);
|
| @@ -646,7 +646,7 @@ ResumeUploadOperationBase::GetExtraRequestHeaders() const {
|
| return headers;
|
| }
|
|
|
| -bool ResumeUploadOperationBase::GetContentFile(
|
| +bool ResumeUploadRequestBase::GetContentFile(
|
| base::FilePath* local_file_path,
|
| int64* range_offset,
|
| int64* range_length,
|
| @@ -663,28 +663,28 @@ bool ResumeUploadOperationBase::GetContentFile(
|
| return true;
|
| }
|
|
|
| -void ResumeUploadOperationBase::NotifyStartToOperationRegistry() {
|
| +void ResumeUploadRequestBase::NotifyStartToOperationRegistry() {
|
| NotifyResume();
|
| }
|
|
|
| -//======================== GetUploadStatusOperationBase ========================
|
| +//======================== GetUploadStatusRequestBase ========================
|
|
|
| -GetUploadStatusOperationBase::GetUploadStatusOperationBase(
|
| +GetUploadStatusRequestBase::GetUploadStatusRequestBase(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const base::FilePath& drive_file_path,
|
| const GURL& upload_url,
|
| int64 content_length)
|
| - : UploadRangeOperationBase(runner,
|
| + : UploadRangeRequestBase(runner,
|
| url_request_context_getter,
|
| drive_file_path,
|
| upload_url),
|
| - content_length_(content_length) {}
|
| + content_length_(content_length) {}
|
|
|
| -GetUploadStatusOperationBase::~GetUploadStatusOperationBase() {}
|
| +GetUploadStatusRequestBase::~GetUploadStatusRequestBase() {}
|
|
|
| std::vector<std::string>
|
| -GetUploadStatusOperationBase::GetExtraRequestHeaders() const {
|
| +GetUploadStatusRequestBase::GetExtraRequestHeaders() const {
|
| // The header looks like
|
| // Content-Range: bytes */<content_length>
|
| // for example:
|
| @@ -698,9 +698,9 @@ GetUploadStatusOperationBase::GetExtraRequestHeaders() const {
|
| return headers;
|
| }
|
|
|
| -//============================ DownloadFileOperation ===========================
|
| +//============================ DownloadFileRequest ===========================
|
|
|
| -DownloadFileOperation::DownloadFileOperation(
|
| +DownloadFileRequest::DownloadFileRequest(
|
| OperationRunner* runner,
|
| net::URLRequestContextGetter* url_request_context_getter,
|
| const DownloadActionCallback& download_action_callback,
|
| @@ -709,9 +709,9 @@ DownloadFileOperation::DownloadFileOperation(
|
| const GURL& download_url,
|
| const base::FilePath& drive_file_path,
|
| const base::FilePath& output_file_path)
|
| - : UrlFetchOperationBase(runner,
|
| - url_request_context_getter,
|
| - drive_file_path),
|
| + : UrlFetchRequestBase(runner,
|
| + url_request_context_getter,
|
| + drive_file_path),
|
| download_action_callback_(download_action_callback),
|
| get_content_callback_(get_content_callback),
|
| progress_callback_(progress_callback),
|
| @@ -726,32 +726,32 @@ DownloadFileOperation::DownloadFileOperation(
|
| set_output_file_path(output_file_path);
|
| }
|
|
|
| -DownloadFileOperation::~DownloadFileOperation() {}
|
| +DownloadFileRequest::~DownloadFileRequest() {}
|
|
|
| -// Overridden from UrlFetchOperationBase.
|
| -GURL DownloadFileOperation::GetURL() const {
|
| +// Overridden from UrlFetchRequestBase.
|
| +GURL DownloadFileRequest::GetURL() const {
|
| return download_url_;
|
| }
|
|
|
| -void DownloadFileOperation::OnURLFetchDownloadProgress(const URLFetcher* source,
|
| - int64 current,
|
| - int64 total) {
|
| +void DownloadFileRequest::OnURLFetchDownloadProgress(const URLFetcher* source,
|
| + int64 current,
|
| + int64 total) {
|
| if (!progress_callback_.is_null())
|
| progress_callback_.Run(current, total);
|
| }
|
|
|
| -bool DownloadFileOperation::ShouldSendDownloadData() {
|
| +bool DownloadFileRequest::ShouldSendDownloadData() {
|
| return !get_content_callback_.is_null();
|
| }
|
|
|
| -void DownloadFileOperation::OnURLFetchDownloadData(
|
| +void DownloadFileRequest::OnURLFetchDownloadData(
|
| const URLFetcher* source,
|
| scoped_ptr<std::string> download_data) {
|
| if (!get_content_callback_.is_null())
|
| get_content_callback_.Run(HTTP_SUCCESS, download_data.Pass());
|
| }
|
|
|
| -void DownloadFileOperation::ProcessURLFetchResults(const URLFetcher* source) {
|
| +void DownloadFileRequest::ProcessURLFetchResults(const URLFetcher* source) {
|
| GDataErrorCode code = GetErrorCode(source);
|
|
|
| // Take over the ownership of the the downloaded temp file.
|
| @@ -766,7 +766,7 @@ void DownloadFileOperation::ProcessURLFetchResults(const URLFetcher* source) {
|
| OnProcessURLFetchResultsComplete(code == HTTP_SUCCESS);
|
| }
|
|
|
| -void DownloadFileOperation::RunCallbackOnPrematureFailure(GDataErrorCode code) {
|
| +void DownloadFileRequest::RunCallbackOnPrematureFailure(GDataErrorCode code) {
|
| download_action_callback_.Run(code, base::FilePath());
|
| }
|
|
|
|
|