Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(13)

Side by Side Diff: net/url_request/url_fetcher_core.cc

Issue 63923002: net: Use SequencedTaskRunner for URLFetcherResponseWriter (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "net/url_request/url_fetcher_core.h" 5 #include "net/url_request/url_fetcher_core.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/logging.h" 8 #include "base/logging.h"
9 #include "base/metrics/histogram.h" 9 #include "base/metrics/histogram.h"
10 #include "base/single_thread_task_runner.h" 10 #include "base/single_thread_task_runner.h"
(...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after
259 base::TimeDelta URLFetcherCore::GetBackoffDelay() const { 259 base::TimeDelta URLFetcherCore::GetBackoffDelay() const {
260 return backoff_delay_; 260 return backoff_delay_;
261 } 261 }
262 262
263 void URLFetcherCore::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { 263 void URLFetcherCore::SetAutomaticallyRetryOnNetworkChanges(int max_retries) {
264 max_retries_on_network_changes_ = max_retries; 264 max_retries_on_network_changes_ = max_retries;
265 } 265 }
266 266
267 void URLFetcherCore::SaveResponseToFileAtPath( 267 void URLFetcherCore::SaveResponseToFileAtPath(
268 const base::FilePath& file_path, 268 const base::FilePath& file_path,
269 scoped_refptr<base::TaskRunner> file_task_runner) { 269 scoped_refptr<base::SequencedTaskRunner> file_task_runner) {
mmenke 2013/11/07 17:02:36 Shouldn't we include sequenced_task_runner.h for t
hashimoto 2013/11/08 04:08:17 Done.
270 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 270 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
271 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>( 271 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>(
272 new URLFetcherFileWriter(file_task_runner, file_path))); 272 new URLFetcherFileWriter(file_task_runner, file_path)));
273 } 273 }
274 274
275 void URLFetcherCore::SaveResponseToTemporaryFile( 275 void URLFetcherCore::SaveResponseToTemporaryFile(
276 scoped_refptr<base::TaskRunner> file_task_runner) { 276 scoped_refptr<base::SequencedTaskRunner> file_task_runner) {
277 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 277 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
278 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>( 278 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>(
279 new URLFetcherFileWriter(file_task_runner, base::FilePath()))); 279 new URLFetcherFileWriter(file_task_runner, base::FilePath())));
280 } 280 }
281 281
282 void URLFetcherCore::SaveResponseWithWriter( 282 void URLFetcherCore::SaveResponseWithWriter(
283 scoped_ptr<URLFetcherResponseWriter> response_writer) { 283 scoped_ptr<URLFetcherResponseWriter> response_writer) {
284 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 284 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
285 response_writer_ = response_writer.Pass(); 285 response_writer_ = response_writer.Pass();
286 } 286 }
(...skipping 599 matching lines...) Expand 10 before | Expand all | Expand 10 after
886 } 886 }
887 887
888 void URLFetcherCore::InformDelegateDownloadProgressInDelegateThread( 888 void URLFetcherCore::InformDelegateDownloadProgressInDelegateThread(
889 int64 current, int64 total) { 889 int64 current, int64 total) {
890 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 890 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
891 if (delegate_) 891 if (delegate_)
892 delegate_->OnURLFetchDownloadProgress(fetcher_, current, total); 892 delegate_->OnURLFetchDownloadProgress(fetcher_, current, total);
893 } 893 }
894 894
895 } // namespace net 895 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698