OLD | NEW |
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 "content/public/test/test_file_error_injector.h" | 5 #include "content/public/test/test_file_error_injector.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
(...skipping 11 matching lines...) Expand all Loading... |
22 class ByteStreamReader; | 22 class ByteStreamReader; |
23 | 23 |
24 namespace { | 24 namespace { |
25 | 25 |
26 // A class that performs file operations and injects errors. | 26 // A class that performs file operations and injects errors. |
27 class DownloadFileWithError: public DownloadFileImpl { | 27 class DownloadFileWithError: public DownloadFileImpl { |
28 public: | 28 public: |
29 DownloadFileWithError(std::unique_ptr<DownloadSaveInfo> save_info, | 29 DownloadFileWithError(std::unique_ptr<DownloadSaveInfo> save_info, |
30 const base::FilePath& default_download_directory, | 30 const base::FilePath& default_download_directory, |
31 std::unique_ptr<ByteStreamReader> byte_stream, | 31 std::unique_ptr<ByteStreamReader> byte_stream, |
32 const net::BoundNetLog& bound_net_log, | 32 const net::NetLogWithSource& net_log, |
33 base::WeakPtr<DownloadDestinationObserver> observer, | 33 base::WeakPtr<DownloadDestinationObserver> observer, |
34 const TestFileErrorInjector::FileErrorInfo& error_info, | 34 const TestFileErrorInjector::FileErrorInfo& error_info, |
35 const base::Closure& ctor_callback, | 35 const base::Closure& ctor_callback, |
36 const base::Closure& dtor_callback); | 36 const base::Closure& dtor_callback); |
37 | 37 |
38 ~DownloadFileWithError() override; | 38 ~DownloadFileWithError() override; |
39 | 39 |
40 void Initialize(const InitializeCallback& callback) override; | 40 void Initialize(const InitializeCallback& callback) override; |
41 | 41 |
42 // DownloadFile interface. | 42 // DownloadFile interface. |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
91 original_callback.Run( | 91 original_callback.Run( |
92 overwrite_error, | 92 overwrite_error, |
93 overwrite_error == DOWNLOAD_INTERRUPT_REASON_NONE ? | 93 overwrite_error == DOWNLOAD_INTERRUPT_REASON_NONE ? |
94 path_result : base::FilePath()); | 94 path_result : base::FilePath()); |
95 } | 95 } |
96 | 96 |
97 DownloadFileWithError::DownloadFileWithError( | 97 DownloadFileWithError::DownloadFileWithError( |
98 std::unique_ptr<DownloadSaveInfo> save_info, | 98 std::unique_ptr<DownloadSaveInfo> save_info, |
99 const base::FilePath& default_download_directory, | 99 const base::FilePath& default_download_directory, |
100 std::unique_ptr<ByteStreamReader> byte_stream, | 100 std::unique_ptr<ByteStreamReader> byte_stream, |
101 const net::BoundNetLog& bound_net_log, | 101 const net::NetLogWithSource& net_log, |
102 base::WeakPtr<DownloadDestinationObserver> observer, | 102 base::WeakPtr<DownloadDestinationObserver> observer, |
103 const TestFileErrorInjector::FileErrorInfo& error_info, | 103 const TestFileErrorInjector::FileErrorInfo& error_info, |
104 const base::Closure& ctor_callback, | 104 const base::Closure& ctor_callback, |
105 const base::Closure& dtor_callback) | 105 const base::Closure& dtor_callback) |
106 : DownloadFileImpl(std::move(save_info), | 106 : DownloadFileImpl(std::move(save_info), |
107 default_download_directory, | 107 default_download_directory, |
108 std::move(byte_stream), | 108 std::move(byte_stream), |
109 bound_net_log, | 109 net_log, |
110 observer), | 110 observer), |
111 error_info_(error_info), | 111 error_info_(error_info), |
112 destruction_callback_(dtor_callback) { | 112 destruction_callback_(dtor_callback) { |
113 // DownloadFiles are created on the UI thread and are destroyed on the FILE | 113 // DownloadFiles are created on the UI thread and are destroyed on the FILE |
114 // thread. Schedule the ConstructionCallback on the FILE thread so that if a | 114 // thread. Schedule the ConstructionCallback on the FILE thread so that if a |
115 // DownloadItem schedules a DownloadFile to be destroyed and creates another | 115 // DownloadItem schedules a DownloadFile to be destroyed and creates another |
116 // one (as happens during download resumption), then the DestructionCallback | 116 // one (as happens during download resumption), then the DestructionCallback |
117 // for the old DownloadFile is run before the ConstructionCallback for the | 117 // for the old DownloadFile is run before the ConstructionCallback for the |
118 // next DownloadFile. | 118 // next DownloadFile. |
119 BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE, ctor_callback); | 119 BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE, ctor_callback); |
(...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
245 public: | 245 public: |
246 DownloadFileWithErrorFactory(const base::Closure& ctor_callback, | 246 DownloadFileWithErrorFactory(const base::Closure& ctor_callback, |
247 const base::Closure& dtor_callback); | 247 const base::Closure& dtor_callback); |
248 ~DownloadFileWithErrorFactory() override; | 248 ~DownloadFileWithErrorFactory() override; |
249 | 249 |
250 // DownloadFileFactory interface. | 250 // DownloadFileFactory interface. |
251 DownloadFile* CreateFile( | 251 DownloadFile* CreateFile( |
252 std::unique_ptr<DownloadSaveInfo> save_info, | 252 std::unique_ptr<DownloadSaveInfo> save_info, |
253 const base::FilePath& default_download_directory, | 253 const base::FilePath& default_download_directory, |
254 std::unique_ptr<ByteStreamReader> byte_stream, | 254 std::unique_ptr<ByteStreamReader> byte_stream, |
255 const net::BoundNetLog& bound_net_log, | 255 const net::NetLogWithSource& net_log, |
256 base::WeakPtr<DownloadDestinationObserver> observer) override; | 256 base::WeakPtr<DownloadDestinationObserver> observer) override; |
257 | 257 |
258 bool SetError(TestFileErrorInjector::FileErrorInfo error); | 258 bool SetError(TestFileErrorInjector::FileErrorInfo error); |
259 | 259 |
260 private: | 260 private: |
261 // Our injected error. | 261 // Our injected error. |
262 TestFileErrorInjector::FileErrorInfo injected_error_; | 262 TestFileErrorInjector::FileErrorInfo injected_error_; |
263 | 263 |
264 // Callback for creation and destruction. | 264 // Callback for creation and destruction. |
265 base::Closure construction_callback_; | 265 base::Closure construction_callback_; |
266 base::Closure destruction_callback_; | 266 base::Closure destruction_callback_; |
267 }; | 267 }; |
268 | 268 |
269 DownloadFileWithErrorFactory::DownloadFileWithErrorFactory( | 269 DownloadFileWithErrorFactory::DownloadFileWithErrorFactory( |
270 const base::Closure& ctor_callback, | 270 const base::Closure& ctor_callback, |
271 const base::Closure& dtor_callback) | 271 const base::Closure& dtor_callback) |
272 : construction_callback_(ctor_callback), | 272 : construction_callback_(ctor_callback), |
273 destruction_callback_(dtor_callback) { | 273 destruction_callback_(dtor_callback) { |
274 injected_error_.code = TestFileErrorInjector::FILE_OPERATION_INITIALIZE; | 274 injected_error_.code = TestFileErrorInjector::FILE_OPERATION_INITIALIZE; |
275 injected_error_.error = DOWNLOAD_INTERRUPT_REASON_NONE; | 275 injected_error_.error = DOWNLOAD_INTERRUPT_REASON_NONE; |
276 injected_error_.operation_instance = -1; | 276 injected_error_.operation_instance = -1; |
277 } | 277 } |
278 | 278 |
279 DownloadFileWithErrorFactory::~DownloadFileWithErrorFactory() {} | 279 DownloadFileWithErrorFactory::~DownloadFileWithErrorFactory() {} |
280 | 280 |
281 DownloadFile* DownloadFileWithErrorFactory::CreateFile( | 281 DownloadFile* DownloadFileWithErrorFactory::CreateFile( |
282 std::unique_ptr<DownloadSaveInfo> save_info, | 282 std::unique_ptr<DownloadSaveInfo> save_info, |
283 const base::FilePath& default_download_directory, | 283 const base::FilePath& default_download_directory, |
284 std::unique_ptr<ByteStreamReader> byte_stream, | 284 std::unique_ptr<ByteStreamReader> byte_stream, |
285 const net::BoundNetLog& bound_net_log, | 285 const net::NetLogWithSource& net_log, |
286 base::WeakPtr<DownloadDestinationObserver> observer) { | 286 base::WeakPtr<DownloadDestinationObserver> observer) { |
287 return new DownloadFileWithError(std::move(save_info), | 287 return new DownloadFileWithError(std::move(save_info), |
288 default_download_directory, | 288 default_download_directory, |
289 std::move(byte_stream), | 289 std::move(byte_stream), |
290 bound_net_log, | 290 net_log, |
291 observer, | 291 observer, |
292 injected_error_, | 292 injected_error_, |
293 construction_callback_, | 293 construction_callback_, |
294 destruction_callback_); | 294 destruction_callback_); |
295 } | 295 } |
296 | 296 |
297 bool DownloadFileWithErrorFactory::SetError( | 297 bool DownloadFileWithErrorFactory::SetError( |
298 TestFileErrorInjector::FileErrorInfo error) { | 298 TestFileErrorInjector::FileErrorInfo error) { |
299 injected_error_ = std::move(error); | 299 injected_error_ = std::move(error); |
300 return true; | 300 return true; |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
399 case FILE_OPERATION_RENAME_ANNOTATE: | 399 case FILE_OPERATION_RENAME_ANNOTATE: |
400 return "RENAME_ANNOTATE"; | 400 return "RENAME_ANNOTATE"; |
401 default: | 401 default: |
402 break; | 402 break; |
403 } | 403 } |
404 | 404 |
405 return "Unknown"; | 405 return "Unknown"; |
406 } | 406 } |
407 | 407 |
408 } // namespace content | 408 } // namespace content |
OLD | NEW |