OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "content/common/net/url_fetcher.h" | 5 #include "content/common/net/url_fetcher.h" |
6 | 6 |
7 #include <set> | 7 #include <set> |
8 | 8 |
| 9 #include "base/bind.h" |
9 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
10 #include "base/file_path.h" | 11 #include "base/file_path.h" |
11 #include "base/file_util_proxy.h" | 12 #include "base/file_util_proxy.h" |
12 #include "base/lazy_instance.h" | 13 #include "base/lazy_instance.h" |
13 #include "base/memory/scoped_callback_factory.h" | 14 #include "base/memory/scoped_callback_factory.h" |
14 #include "base/memory/scoped_ptr.h" | 15 #include "base/memory/scoped_ptr.h" |
| 16 #include "base/memory/weak_ptr.h" |
15 #include "base/message_loop_proxy.h" | 17 #include "base/message_loop_proxy.h" |
16 #include "base/platform_file.h" | 18 #include "base/platform_file.h" |
17 #include "base/stl_util.h" | 19 #include "base/stl_util.h" |
18 #include "base/string_util.h" | 20 #include "base/string_util.h" |
19 #include "base/threading/thread.h" | 21 #include "base/threading/thread.h" |
20 #include "googleurl/src/gurl.h" | 22 #include "googleurl/src/gurl.h" |
21 #include "net/base/host_port_pair.h" | 23 #include "net/base/host_port_pair.h" |
22 #include "net/base/io_buffer.h" | 24 #include "net/base/io_buffer.h" |
23 #include "net/base/load_flags.h" | 25 #include "net/base/load_flags.h" |
24 #include "net/base/net_errors.h" | 26 #include "net/base/net_errors.h" |
(...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
142 // The URLFetcher::Core which instantiated this class. | 144 // The URLFetcher::Core which instantiated this class. |
143 URLFetcher::Core* core_; | 145 URLFetcher::Core* core_; |
144 | 146 |
145 // The last error encountered on a file operation. base::PLATFORM_FILE_OK | 147 // The last error encountered on a file operation. base::PLATFORM_FILE_OK |
146 // if no error occurred. | 148 // if no error occurred. |
147 base::PlatformFileError error_code_; | 149 base::PlatformFileError error_code_; |
148 | 150 |
149 // Callbacks are created for use with base::FileUtilProxy. | 151 // Callbacks are created for use with base::FileUtilProxy. |
150 base::ScopedCallbackFactory<URLFetcher::Core::TempFileWriter> | 152 base::ScopedCallbackFactory<URLFetcher::Core::TempFileWriter> |
151 callback_factory_; | 153 callback_factory_; |
| 154 base::WeakPtrFactory<URLFetcher::Core::TempFileWriter> weak_factory_; |
152 | 155 |
153 // Message loop on which file opperations should happen. | 156 // Message loop on which file opperations should happen. |
154 scoped_refptr<base::MessageLoopProxy> file_message_loop_proxy_; | 157 scoped_refptr<base::MessageLoopProxy> file_message_loop_proxy_; |
155 | 158 |
156 // Path to the temporary file. This path is empty when there | 159 // Path to the temporary file. This path is empty when there |
157 // is no temp file. | 160 // is no temp file. |
158 FilePath temp_file_; | 161 FilePath temp_file_; |
159 | 162 |
160 // Handle to the temp file. | 163 // Handle to the temp file. |
161 base::PlatformFile temp_file_handle_; | 164 base::PlatformFile temp_file_handle_; |
(...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
314 | 317 |
315 // static | 318 // static |
316 base::LazyInstance<URLFetcher::Core::Registry> | 319 base::LazyInstance<URLFetcher::Core::Registry> |
317 URLFetcher::Core::g_registry(base::LINKER_INITIALIZED); | 320 URLFetcher::Core::g_registry(base::LINKER_INITIALIZED); |
318 | 321 |
319 URLFetcher::Core::TempFileWriter::TempFileWriter( | 322 URLFetcher::Core::TempFileWriter::TempFileWriter( |
320 URLFetcher::Core* core, | 323 URLFetcher::Core* core, |
321 scoped_refptr<base::MessageLoopProxy> file_message_loop_proxy) | 324 scoped_refptr<base::MessageLoopProxy> file_message_loop_proxy) |
322 : core_(core), | 325 : core_(core), |
323 error_code_(base::PLATFORM_FILE_OK), | 326 error_code_(base::PLATFORM_FILE_OK), |
324 callback_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)), | 327 ALLOW_THIS_IN_INITIALIZER_LIST(callback_factory_(this)), |
| 328 ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)), |
325 file_message_loop_proxy_(file_message_loop_proxy), | 329 file_message_loop_proxy_(file_message_loop_proxy), |
326 temp_file_handle_(base::kInvalidPlatformFileValue) { | 330 temp_file_handle_(base::kInvalidPlatformFileValue) { |
327 } | 331 } |
328 | 332 |
329 URLFetcher::Core::TempFileWriter::~TempFileWriter() { | 333 URLFetcher::Core::TempFileWriter::~TempFileWriter() { |
330 RemoveTempFile(); | 334 RemoveTempFile(); |
331 } | 335 } |
332 | 336 |
333 void URLFetcher::Core::TempFileWriter::CreateTempFile() { | 337 void URLFetcher::Core::TempFileWriter::CreateTempFile() { |
334 DCHECK(core_->io_message_loop_proxy_->BelongsToCurrentThread()); | 338 DCHECK(core_->io_message_loop_proxy_->BelongsToCurrentThread()); |
335 CHECK(file_message_loop_proxy_.get()); | 339 CHECK(file_message_loop_proxy_.get()); |
336 base::FileUtilProxy::CreateTemporary( | 340 base::FileUtilProxy::CreateTemporary( |
337 file_message_loop_proxy_, | 341 file_message_loop_proxy_, |
338 0, // No additional file flags. | 342 0, // No additional file flags. |
339 callback_factory_.NewCallback( | 343 base::Bind(&URLFetcher::Core::TempFileWriter::DidCreateTempFile, |
340 &URLFetcher::Core::TempFileWriter::DidCreateTempFile)); | 344 weak_factory_.GetWeakPtr())); |
341 } | 345 } |
342 | 346 |
343 void URLFetcher::Core::TempFileWriter::DidCreateTempFile( | 347 void URLFetcher::Core::TempFileWriter::DidCreateTempFile( |
344 base::PlatformFileError error_code, | 348 base::PlatformFileError error_code, |
345 base::PassPlatformFile file_handle, | 349 base::PassPlatformFile file_handle, |
346 FilePath file_path) { | 350 FilePath file_path) { |
347 DCHECK(core_->io_message_loop_proxy_->BelongsToCurrentThread()); | 351 DCHECK(core_->io_message_loop_proxy_->BelongsToCurrentThread()); |
348 | 352 |
349 if (base::PLATFORM_FILE_OK != error_code) { | 353 if (base::PLATFORM_FILE_OK != error_code) { |
350 error_code_ = error_code; | 354 error_code_ = error_code; |
(...skipping 783 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1134 } | 1138 } |
1135 | 1139 |
1136 // static | 1140 // static |
1137 int URLFetcher::GetNumFetcherCores() { | 1141 int URLFetcher::GetNumFetcherCores() { |
1138 return Core::g_registry.Get().size(); | 1142 return Core::g_registry.Get().size(); |
1139 } | 1143 } |
1140 | 1144 |
1141 URLFetcher::Delegate* URLFetcher::delegate() const { | 1145 URLFetcher::Delegate* URLFetcher::delegate() const { |
1142 return core_->delegate(); | 1146 return core_->delegate(); |
1143 } | 1147 } |
OLD | NEW |