| Index: webkit/appcache/appcache_update_job.cc
|
| diff --git a/webkit/appcache/appcache_update_job.cc b/webkit/appcache/appcache_update_job.cc
|
| index d34017ae77eda305aa12aeb61c1e8f2dbbf6b78c..2578fd3938f281dc7972b1abe87958a0a375b2ef 100644
|
| --- a/webkit/appcache/appcache_update_job.cc
|
| +++ b/webkit/appcache/appcache_update_job.cc
|
| @@ -23,8 +23,8 @@ static const size_t kMaxConcurrentUrlFetches = 2;
|
| static const int kMax503Retries = 3;
|
|
|
| // Extra info associated with requests for use during response processing.
|
| -// This info is deleted when the URLRequest is deleted.
|
| -class UpdateJobInfo : public URLRequest::UserData {
|
| +// This info is deleted when the net::URLRequest is deleted.
|
| +class UpdateJobInfo : public net::URLRequest::UserData {
|
| public:
|
| enum RequestType {
|
| MANIFEST_FETCH,
|
| @@ -45,7 +45,7 @@ class UpdateJobInfo : public URLRequest::UserData {
|
|
|
| void SetUpResponseWriter(AppCacheResponseWriter* writer,
|
| AppCacheUpdateJob* update,
|
| - URLRequest* request) {
|
| + net::URLRequest* request) {
|
| DCHECK(!response_writer_.get());
|
| response_writer_.reset(writer);
|
| update_job_ = update;
|
| @@ -67,7 +67,7 @@ class UpdateJobInfo : public URLRequest::UserData {
|
| // Info needed to write responses to storage and process callbacks.
|
| scoped_ptr<AppCacheResponseWriter> response_writer_;
|
| AppCacheUpdateJob* update_job_;
|
| - URLRequest* request_;
|
| + net::URLRequest* request_;
|
| net::CompletionCallbackImpl<UpdateJobInfo> write_callback_;
|
| };
|
|
|
| @@ -174,7 +174,7 @@ AppCacheUpdateJob::~AppCacheUpdateJob() {
|
| policy_callback_->Cancel();
|
| }
|
|
|
| -UpdateJobInfo* AppCacheUpdateJob::GetUpdateJobInfo(URLRequest* request) {
|
| +UpdateJobInfo* AppCacheUpdateJob::GetUpdateJobInfo(net::URLRequest* request) {
|
| return static_cast<UpdateJobInfo*>(request->GetUserData(this));
|
| }
|
|
|
| @@ -287,7 +287,7 @@ void AppCacheUpdateJob::HandleCacheFailure(const std::string& error_message) {
|
|
|
| void AppCacheUpdateJob::FetchManifest(bool is_first_fetch) {
|
| DCHECK(!manifest_url_request_);
|
| - manifest_url_request_ = new URLRequest(manifest_url_, this);
|
| + manifest_url_request_ = new net::URLRequest(manifest_url_, this);
|
| UpdateJobInfo::RequestType fetch_type = is_first_fetch ?
|
| UpdateJobInfo::MANIFEST_FETCH : UpdateJobInfo::MANIFEST_REFETCH;
|
| manifest_url_request_->SetUserData(this, new UpdateJobInfo(fetch_type));
|
| @@ -316,7 +316,7 @@ void AppCacheUpdateJob::FetchManifest(bool is_first_fetch) {
|
| }
|
|
|
| void AppCacheUpdateJob::AddConditionalHeaders(
|
| - URLRequest* request, const net::HttpResponseInfo* info) {
|
| + net::URLRequest* request, const net::HttpResponseInfo* info) {
|
| DCHECK(request && info);
|
| net::HttpRequestHeaders extra_headers;
|
|
|
| @@ -341,7 +341,7 @@ void AppCacheUpdateJob::AddConditionalHeaders(
|
| request->SetExtraRequestHeaders(extra_headers);
|
| }
|
|
|
| -void AppCacheUpdateJob::OnResponseStarted(URLRequest *request) {
|
| +void AppCacheUpdateJob::OnResponseStarted(net::URLRequest *request) {
|
| if (request->status().is_success() &&
|
| (request->GetResponseCode() / 100) == 2) {
|
| // Write response info to storage for URL fetches. Wait for async write
|
| @@ -365,7 +365,7 @@ void AppCacheUpdateJob::OnResponseStarted(URLRequest *request) {
|
| }
|
| }
|
|
|
| -void AppCacheUpdateJob::ReadResponseData(URLRequest* request) {
|
| +void AppCacheUpdateJob::ReadResponseData(net::URLRequest* request) {
|
| if (internal_state_ == CACHE_FAILURE || internal_state_ == CANCELLED ||
|
| internal_state_ == COMPLETED) {
|
| return;
|
| @@ -377,7 +377,8 @@ void AppCacheUpdateJob::ReadResponseData(URLRequest* request) {
|
| OnReadCompleted(request, bytes_read);
|
| }
|
|
|
| -void AppCacheUpdateJob::OnReadCompleted(URLRequest* request, int bytes_read) {
|
| +void AppCacheUpdateJob::OnReadCompleted(net::URLRequest* request,
|
| + int bytes_read) {
|
| bool data_consumed = true;
|
| if (request->status().is_success() && bytes_read > 0) {
|
| UpdateJobInfo* info = GetUpdateJobInfo(request);
|
| @@ -400,7 +401,7 @@ void AppCacheUpdateJob::OnReadCompleted(URLRequest* request, int bytes_read) {
|
| OnResponseCompleted(request);
|
| }
|
|
|
| -bool AppCacheUpdateJob::ConsumeResponseData(URLRequest* request,
|
| +bool AppCacheUpdateJob::ConsumeResponseData(net::URLRequest* request,
|
| UpdateJobInfo* info,
|
| int bytes_read) {
|
| DCHECK_GT(bytes_read, 0);
|
| @@ -424,7 +425,7 @@ bool AppCacheUpdateJob::ConsumeResponseData(URLRequest* request,
|
| }
|
|
|
| void AppCacheUpdateJob::OnWriteResponseComplete(int result,
|
| - URLRequest* request,
|
| + net::URLRequest* request,
|
| UpdateJobInfo* info) {
|
| if (result < 0) {
|
| request->Cancel();
|
| @@ -435,7 +436,7 @@ void AppCacheUpdateJob::OnWriteResponseComplete(int result,
|
| ReadResponseData(request);
|
| }
|
|
|
| -void AppCacheUpdateJob::OnReceivedRedirect(URLRequest* request,
|
| +void AppCacheUpdateJob::OnReceivedRedirect(net::URLRequest* request,
|
| const GURL& new_url,
|
| bool* defer_redirect) {
|
| // Redirect is not allowed by the update process.
|
| @@ -443,7 +444,7 @@ void AppCacheUpdateJob::OnReceivedRedirect(URLRequest* request,
|
| OnResponseCompleted(request);
|
| }
|
|
|
| -void AppCacheUpdateJob::OnResponseCompleted(URLRequest* request) {
|
| +void AppCacheUpdateJob::OnResponseCompleted(net::URLRequest* request) {
|
| // Retry for 503s where retry-after is 0.
|
| if (request->status().is_success() &&
|
| request->GetResponseCode() == 503 &&
|
| @@ -472,7 +473,7 @@ void AppCacheUpdateJob::OnResponseCompleted(URLRequest* request) {
|
| delete request;
|
| }
|
|
|
| -bool AppCacheUpdateJob::RetryRequest(URLRequest* request) {
|
| +bool AppCacheUpdateJob::RetryRequest(net::URLRequest* request) {
|
| UpdateJobInfo* info = GetUpdateJobInfo(request);
|
| if (info->retry_503_attempts_ >= kMax503Retries) {
|
| return false;
|
| @@ -482,7 +483,7 @@ bool AppCacheUpdateJob::RetryRequest(URLRequest* request) {
|
| return false;
|
|
|
| const GURL& url = request->original_url();
|
| - URLRequest* retry = new URLRequest(url, this);
|
| + net::URLRequest* retry = new net::URLRequest(url, this);
|
| UpdateJobInfo* retry_info = new UpdateJobInfo(info->type_);
|
| retry_info->retry_503_attempts_ = info->retry_503_attempts_ + 1;
|
| retry_info->existing_entry_ = info->existing_entry_;
|
| @@ -514,7 +515,7 @@ bool AppCacheUpdateJob::RetryRequest(URLRequest* request) {
|
| return true;
|
| }
|
|
|
| -void AppCacheUpdateJob::HandleManifestFetchCompleted(URLRequest* request) {
|
| +void AppCacheUpdateJob::HandleManifestFetchCompleted(net::URLRequest* request) {
|
| DCHECK(internal_state_ == FETCH_MANIFEST);
|
| manifest_url_request_ = NULL;
|
|
|
| @@ -621,7 +622,7 @@ void AppCacheUpdateJob::ContinueHandleManifestFetchCompleted(bool changed) {
|
| MaybeCompleteUpdate(); // if not done, continues when async fetches complete
|
| }
|
|
|
| -void AppCacheUpdateJob::HandleUrlFetchCompleted(URLRequest* request) {
|
| +void AppCacheUpdateJob::HandleUrlFetchCompleted(net::URLRequest* request) {
|
| DCHECK(internal_state_ == DOWNLOADING);
|
| UpdateJobInfo* info = GetUpdateJobInfo(request);
|
|
|
| @@ -684,7 +685,8 @@ void AppCacheUpdateJob::HandleUrlFetchCompleted(URLRequest* request) {
|
| MaybeCompleteUpdate();
|
| }
|
|
|
| -void AppCacheUpdateJob::HandleMasterEntryFetchCompleted(URLRequest* request) {
|
| +void AppCacheUpdateJob::HandleMasterEntryFetchCompleted(
|
| + net::URLRequest* request) {
|
| DCHECK(internal_state_ == NO_UPDATE || internal_state_ == DOWNLOADING);
|
|
|
| // TODO(jennb): Handle downloads completing during cache failure when update
|
| @@ -767,7 +769,8 @@ void AppCacheUpdateJob::HandleMasterEntryFetchCompleted(URLRequest* request) {
|
| MaybeCompleteUpdate();
|
| }
|
|
|
| -void AppCacheUpdateJob::HandleManifestRefetchCompleted(URLRequest* request) {
|
| +void AppCacheUpdateJob::HandleManifestRefetchCompleted(
|
| + net::URLRequest* request) {
|
| DCHECK(internal_state_ == REFETCH_MANIFEST);
|
| manifest_url_request_ = NULL;
|
|
|
| @@ -1021,7 +1024,7 @@ void AppCacheUpdateJob::FetchUrls() {
|
| }
|
|
|
| // Send URL request for the resource.
|
| - URLRequest* request = new URLRequest(url_to_fetch.url, this);
|
| + net::URLRequest* request = new net::URLRequest(url_to_fetch.url, this);
|
| request->SetUserData(this, info);
|
| request->set_context(service_->request_context());
|
| request->set_load_flags(
|
| @@ -1136,7 +1139,7 @@ void AppCacheUpdateJob::FetchMasterEntries() {
|
| }
|
| } else {
|
| // Send URL request for the master entry.
|
| - URLRequest* request = new URLRequest(url, this);
|
| + net::URLRequest* request = new net::URLRequest(url, this);
|
| request->SetUserData(this,
|
| new UpdateJobInfo(UpdateJobInfo::MASTER_ENTRY_FETCH));
|
| request->set_context(service_->request_context());
|
|
|