diff options
author | hashimoto@chromium.org <hashimoto@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-11-12 01:09:56 +0000 |
---|---|---|
committer | hashimoto@chromium.org <hashimoto@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-11-12 01:09:56 +0000 |
commit | 0b5ab509aa9324709b11a61f293920fc22a680e0 (patch) | |
tree | 06782fb5a14eb427d750b98ace9757739ace1ddc /net | |
parent | 0181a7d0055f4b77c494917bc49ab8cb93f5602c (diff) | |
download | chromium_src-0b5ab509aa9324709b11a61f293920fc22a680e0.zip chromium_src-0b5ab509aa9324709b11a61f293920fc22a680e0.tar.gz chromium_src-0b5ab509aa9324709b11a61f293920fc22a680e0.tar.bz2 |
net: Use SequencedTaskRunner for URLFetcherResponseWriter
TBR=scottbyer@chromium.org for chrome/service/cloud_print/cloud_print_url_fetcher.h
BUG=316065
TEST=build
Review URL: https://codereview.chromium.org/63923002
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@234357 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net')
-rw-r--r-- | net/url_request/test_url_fetcher_factory.cc | 4 | ||||
-rw-r--r-- | net/url_request/test_url_fetcher_factory.h | 4 | ||||
-rw-r--r-- | net/url_request/url_fetcher.h | 7 | ||||
-rw-r--r-- | net/url_request/url_fetcher_core.cc | 5 | ||||
-rw-r--r-- | net/url_request/url_fetcher_core.h | 4 | ||||
-rw-r--r-- | net/url_request/url_fetcher_impl.cc | 5 | ||||
-rw-r--r-- | net/url_request/url_fetcher_impl.h | 4 | ||||
-rw-r--r-- | net/url_request/url_fetcher_response_writer.cc | 4 | ||||
-rw-r--r-- | net/url_request/url_fetcher_response_writer.h | 9 |
9 files changed, 25 insertions, 21 deletions
diff --git a/net/url_request/test_url_fetcher_factory.cc b/net/url_request/test_url_fetcher_factory.cc index c95e07d..5a72d71 100644 --- a/net/url_request/test_url_fetcher_factory.cc +++ b/net/url_request/test_url_fetcher_factory.cc @@ -142,11 +142,11 @@ void TestURLFetcher::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { void TestURLFetcher::SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner) { + scoped_refptr<base::SequencedTaskRunner> file_task_runner) { } void TestURLFetcher::SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner) { + scoped_refptr<base::SequencedTaskRunner> file_task_runner) { } void TestURLFetcher::SaveResponseWithWriter( diff --git a/net/url_request/test_url_fetcher_factory.h b/net/url_request/test_url_fetcher_factory.h index ff46dba..75ffcad 100644 --- a/net/url_request/test_url_fetcher_factory.h +++ b/net/url_request/test_url_fetcher_factory.h @@ -124,9 +124,9 @@ class TestURLFetcher : public URLFetcher { virtual void SetAutomaticallyRetryOnNetworkChanges(int max_retries) OVERRIDE; virtual void SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner) OVERRIDE; + scoped_refptr<base::SequencedTaskRunner> file_task_runner) OVERRIDE; virtual void SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner) OVERRIDE; + scoped_refptr<base::SequencedTaskRunner> file_task_runner) OVERRIDE; virtual void SaveResponseWithWriter( scoped_ptr<URLFetcherResponseWriter> response_writer) OVERRIDE; virtual HttpResponseHeaders* GetResponseHeaders() const OVERRIDE; diff --git a/net/url_request/url_fetcher.h b/net/url_request/url_fetcher.h index 1de8bad..4cc6f5f 100644 --- a/net/url_request/url_fetcher.h +++ b/net/url_request/url_fetcher.h @@ -12,7 +12,6 @@ #include "base/memory/ref_counted.h" #include "base/memory/scoped_ptr.h" #include "base/supports_user_data.h" -#include "base/task_runner.h" #include "net/base/net_export.h" class GURL; @@ -20,6 +19,8 @@ class GURL; namespace base { class FilePath; class MessageLoopProxy; +class SequencedTaskRunner; +class TaskRunner; class TimeDelta; } @@ -231,7 +232,7 @@ class NET_EXPORT URLFetcher { // take ownership by calling GetResponseAsFilePath(). virtual void SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner) = 0; + scoped_refptr<base::SequencedTaskRunner> file_task_runner) = 0; // By default, the response is saved in a string. Call this method to save the // response to a temporary file instead. Must be called before Start(). @@ -239,7 +240,7 @@ class NET_EXPORT URLFetcher { // The created file is removed when the URLFetcher is deleted unless you // take ownership by calling GetResponseAsFilePath(). virtual void SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner) = 0; + scoped_refptr<base::SequencedTaskRunner> file_task_runner) = 0; // By default, the response is saved in a string. Call this method to use the // specified writer to save the response. Must be called before Start(). diff --git a/net/url_request/url_fetcher_core.cc b/net/url_request/url_fetcher_core.cc index f4e1113..708429f 100644 --- a/net/url_request/url_fetcher_core.cc +++ b/net/url_request/url_fetcher_core.cc @@ -7,6 +7,7 @@ #include "base/bind.h" #include "base/logging.h" #include "base/metrics/histogram.h" +#include "base/sequenced_task_runner.h" #include "base/single_thread_task_runner.h" #include "base/stl_util.h" #include "base/thread_task_runner_handle.h" @@ -266,14 +267,14 @@ void URLFetcherCore::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { void URLFetcherCore::SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner) { + scoped_refptr<base::SequencedTaskRunner> file_task_runner) { DCHECK(delegate_task_runner_->BelongsToCurrentThread()); SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>( new URLFetcherFileWriter(file_task_runner, file_path))); } void URLFetcherCore::SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner) { + scoped_refptr<base::SequencedTaskRunner> file_task_runner) { DCHECK(delegate_task_runner_->BelongsToCurrentThread()); SaveResponseWithWriter(scoped_ptr<URLFetcherResponseWriter>( new URLFetcherFileWriter(file_task_runner, base::FilePath()))); diff --git a/net/url_request/url_fetcher_core.h b/net/url_request/url_fetcher_core.h index 9ee58b6..c8864d4 100644 --- a/net/url_request/url_fetcher_core.h +++ b/net/url_request/url_fetcher_core.h @@ -97,9 +97,9 @@ class URLFetcherCore void SetAutomaticallyRetryOnNetworkChanges(int max_retries); void SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner); + scoped_refptr<base::SequencedTaskRunner> file_task_runner); void SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner); + scoped_refptr<base::SequencedTaskRunner> file_task_runner); void SaveResponseWithWriter( scoped_ptr<URLFetcherResponseWriter> response_writer); HttpResponseHeaders* GetResponseHeaders() const; diff --git a/net/url_request/url_fetcher_impl.cc b/net/url_request/url_fetcher_impl.cc index c3fc646..32253c9 100644 --- a/net/url_request/url_fetcher_impl.cc +++ b/net/url_request/url_fetcher_impl.cc @@ -6,6 +6,7 @@ #include "base/bind.h" #include "base/message_loop/message_loop_proxy.h" +#include "base/sequenced_task_runner.h" #include "net/url_request/url_fetcher_core.h" #include "net/url_request/url_fetcher_factory.h" #include "net/url_request/url_fetcher_response_writer.h" @@ -121,12 +122,12 @@ void URLFetcherImpl::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { void URLFetcherImpl::SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner) { + scoped_refptr<base::SequencedTaskRunner> file_task_runner) { core_->SaveResponseToFileAtPath(file_path, file_task_runner); } void URLFetcherImpl::SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner) { + scoped_refptr<base::SequencedTaskRunner> file_task_runner) { core_->SaveResponseToTemporaryFile(file_task_runner); } diff --git a/net/url_request/url_fetcher_impl.h b/net/url_request/url_fetcher_impl.h index ec72d1a..fe0362b 100644 --- a/net/url_request/url_fetcher_impl.h +++ b/net/url_request/url_fetcher_impl.h @@ -70,9 +70,9 @@ class NET_EXPORT_PRIVATE URLFetcherImpl : public URLFetcher { virtual void SetAutomaticallyRetryOnNetworkChanges(int max_retries) OVERRIDE; virtual void SaveResponseToFileAtPath( const base::FilePath& file_path, - scoped_refptr<base::TaskRunner> file_task_runner) OVERRIDE; + scoped_refptr<base::SequencedTaskRunner> file_task_runner) OVERRIDE; virtual void SaveResponseToTemporaryFile( - scoped_refptr<base::TaskRunner> file_task_runner) OVERRIDE; + scoped_refptr<base::SequencedTaskRunner> file_task_runner) OVERRIDE; virtual void SaveResponseWithWriter( scoped_ptr<URLFetcherResponseWriter> response_writer) OVERRIDE; virtual HttpResponseHeaders* GetResponseHeaders() const OVERRIDE; diff --git a/net/url_request/url_fetcher_response_writer.cc b/net/url_request/url_fetcher_response_writer.cc index ee52578..fd08a8d 100644 --- a/net/url_request/url_fetcher_response_writer.cc +++ b/net/url_request/url_fetcher_response_writer.cc @@ -6,7 +6,7 @@ #include "base/file_util.h" #include "base/location.h" -#include "base/task_runner.h" +#include "base/sequenced_task_runner.h" #include "base/task_runner_util.h" #include "net/base/file_stream.h" #include "net/base/io_buffer.h" @@ -50,7 +50,7 @@ URLFetcherStringWriter* URLFetcherStringWriter::AsStringWriter() { } URLFetcherFileWriter::URLFetcherFileWriter( - scoped_refptr<base::TaskRunner> file_task_runner, + scoped_refptr<base::SequencedTaskRunner> file_task_runner, const base::FilePath& file_path) : weak_factory_(this), file_task_runner_(file_task_runner), diff --git a/net/url_request/url_fetcher_response_writer.h b/net/url_request/url_fetcher_response_writer.h index 0032a4a..422a8a4 100644 --- a/net/url_request/url_fetcher_response_writer.h +++ b/net/url_request/url_fetcher_response_writer.h @@ -14,7 +14,7 @@ #include "net/base/net_export.h" namespace base { -class TaskRunner; +class SequencedTaskRunner; } // namespace base namespace net { @@ -81,8 +81,9 @@ class NET_EXPORT URLFetcherFileWriter : public URLFetcherResponseWriter { public: // |file_path| is used as the destination path. If |file_path| is empty, // Initialize() will create a temporary file. - URLFetcherFileWriter(scoped_refptr<base::TaskRunner> file_task_runner, - const base::FilePath& file_path); + URLFetcherFileWriter( + scoped_refptr<base::SequencedTaskRunner> file_task_runner, + const base::FilePath& file_path); virtual ~URLFetcherFileWriter(); const base::FilePath& file_path() const { return file_path_; } @@ -122,7 +123,7 @@ class NET_EXPORT URLFetcherFileWriter : public URLFetcherResponseWriter { base::WeakPtrFactory<URLFetcherFileWriter> weak_factory_; // Task runner on which file operations should happen. - scoped_refptr<base::TaskRunner> file_task_runner_; + scoped_refptr<base::SequencedTaskRunner> file_task_runner_; // Destination file path. // Initialize() creates a temporary file if this variable is empty. |