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

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: Add include 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/sequenced_task_runner.h"
10 #include "base/single_thread_task_runner.h" 11 #include "base/single_thread_task_runner.h"
11 #include "base/stl_util.h" 12 #include "base/stl_util.h"
12 #include "base/thread_task_runner_handle.h" 13 #include "base/thread_task_runner_handle.h"
13 #include "base/tracked_objects.h" 14 #include "base/tracked_objects.h"
14 #include "net/base/io_buffer.h" 15 #include "net/base/io_buffer.h"
15 #include "net/base/load_flags.h" 16 #include "net/base/load_flags.h"
16 #include "net/base/net_errors.h" 17 #include "net/base/net_errors.h"
17 #include "net/base/request_priority.h" 18 #include "net/base/request_priority.h"
18 #include "net/base/upload_bytes_element_reader.h" 19 #include "net/base/upload_bytes_element_reader.h"
19 #include "net/base/upload_data_stream.h" 20 #include "net/base/upload_data_stream.h"
(...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after
259 base::TimeDelta URLFetcherCore::GetBackoffDelay() const { 260 base::TimeDelta URLFetcherCore::GetBackoffDelay() const {
260 return backoff_delay_; 261 return backoff_delay_;
261 } 262 }
262 263
263 void URLFetcherCore::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { 264 void URLFetcherCore::SetAutomaticallyRetryOnNetworkChanges(int max_retries) {
264 max_retries_on_network_changes_ = max_retries; 265 max_retries_on_network_changes_ = max_retries;
265 } 266 }
266 267
267 void URLFetcherCore::SaveResponseToFileAtPath( 268 void URLFetcherCore::SaveResponseToFileAtPath(
268 const base::FilePath& file_path, 269 const base::FilePath& file_path,
269 scoped_refptr<base::TaskRunner> file_task_runner) { 270 scoped_refptr<base::SequencedTaskRunner> file_task_runner) {
270 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 271 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
271 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>( 272 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>(
272 new URLFetcherFileWriter(file_task_runner, file_path))); 273 new URLFetcherFileWriter(file_task_runner, file_path)));
273 } 274 }
274 275
275 void URLFetcherCore::SaveResponseToTemporaryFile( 276 void URLFetcherCore::SaveResponseToTemporaryFile(
276 scoped_refptr<base::TaskRunner> file_task_runner) { 277 scoped_refptr<base::SequencedTaskRunner> file_task_runner) {
277 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 278 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
278 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>( 279 SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>(
279 new URLFetcherFileWriter(file_task_runner, base::FilePath()))); 280 new URLFetcherFileWriter(file_task_runner, base::FilePath())));
280 } 281 }
281 282
282 void URLFetcherCore::SaveResponseWithWriter( 283 void URLFetcherCore::SaveResponseWithWriter(
283 scoped_ptr<URLFetcherResponseWriter> response_writer) { 284 scoped_ptr<URLFetcherResponseWriter> response_writer) {
284 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 285 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
285 response_writer_ = response_writer.Pass(); 286 response_writer_ = response_writer.Pass();
286 } 287 }
(...skipping 599 matching lines...) Expand 10 before | Expand all | Expand 10 after
886 } 887 }
887 888
888 void URLFetcherCore::InformDelegateDownloadProgressInDelegateThread( 889 void URLFetcherCore::InformDelegateDownloadProgressInDelegateThread(
889 int64 current, int64 total) { 890 int64 current, int64 total) {
890 DCHECK(delegate_task_runner_->BelongsToCurrentThread()); 891 DCHECK(delegate_task_runner_->BelongsToCurrentThread());
891 if (delegate_) 892 if (delegate_)
892 delegate_->OnURLFetchDownloadProgress(fetcher_, current, total); 893 delegate_->OnURLFetchDownloadProgress(fetcher_, current, total);
893 } 894 }
894 895
895 } // namespace net 896 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698