OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 "webkit/fileapi/file_writer_delegate.h" | 5 #include "webkit/fileapi/file_writer_delegate.h" |
6 | 6 |
7 #include "base/message_loop.h" | 7 #include "base/message_loop.h" |
8 #include "net/base/net_errors.h" | 8 #include "net/base/net_errors.h" |
9 #include "webkit/fileapi/file_system_operation.h" | 9 #include "webkit/fileapi/file_system_operation.h" |
10 | 10 |
(...skipping 11 matching lines...) Expand all Loading... |
22 bytes_written_(0), | 22 bytes_written_(0), |
23 bytes_read_(0), | 23 bytes_read_(0), |
24 io_buffer_(new net::IOBufferWithSize(kReadBufSize)), | 24 io_buffer_(new net::IOBufferWithSize(kReadBufSize)), |
25 callback_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)), | 25 callback_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)), |
26 method_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { | 26 method_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { |
27 } | 27 } |
28 | 28 |
29 FileWriterDelegate::~FileWriterDelegate() { | 29 FileWriterDelegate::~FileWriterDelegate() { |
30 } | 30 } |
31 | 31 |
32 void FileWriterDelegate::Start(base::PlatformFile file, URLRequest* request) { | 32 void FileWriterDelegate::Start(base::PlatformFile file, |
| 33 net::URLRequest* request) { |
33 file_ = file; | 34 file_ = file; |
34 request_ = request; | 35 request_ = request; |
35 file_stream_.reset( | 36 file_stream_.reset( |
36 new net::FileStream( | 37 new net::FileStream( |
37 file, | 38 file, |
38 base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_WRITE | | 39 base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_WRITE | |
39 base::PLATFORM_FILE_ASYNC)); | 40 base::PLATFORM_FILE_ASYNC)); |
40 request_->Start(); | 41 request_->Start(); |
41 } | 42 } |
42 | 43 |
43 void FileWriterDelegate::OnReceivedRedirect( | 44 void FileWriterDelegate::OnReceivedRedirect( |
44 URLRequest* request, const GURL& new_url, bool* defer_redirect) { | 45 net::URLRequest* request, const GURL& new_url, bool* defer_redirect) { |
45 NOTREACHED(); | 46 NOTREACHED(); |
46 OnError(base::PLATFORM_FILE_ERROR_SECURITY); | 47 OnError(base::PLATFORM_FILE_ERROR_SECURITY); |
47 } | 48 } |
48 | 49 |
49 void FileWriterDelegate::OnAuthRequired( | 50 void FileWriterDelegate::OnAuthRequired( |
50 URLRequest* request, net::AuthChallengeInfo* auth_info) { | 51 net::URLRequest* request, net::AuthChallengeInfo* auth_info) { |
51 NOTREACHED(); | 52 NOTREACHED(); |
52 OnError(base::PLATFORM_FILE_ERROR_SECURITY); | 53 OnError(base::PLATFORM_FILE_ERROR_SECURITY); |
53 } | 54 } |
54 | 55 |
55 void FileWriterDelegate::OnCertificateRequested( | 56 void FileWriterDelegate::OnCertificateRequested( |
56 URLRequest* request, net::SSLCertRequestInfo* cert_request_info) { | 57 net::URLRequest* request, net::SSLCertRequestInfo* cert_request_info) { |
57 NOTREACHED(); | 58 NOTREACHED(); |
58 OnError(base::PLATFORM_FILE_ERROR_SECURITY); | 59 OnError(base::PLATFORM_FILE_ERROR_SECURITY); |
59 } | 60 } |
60 | 61 |
61 void FileWriterDelegate::OnSSLCertificateError( | 62 void FileWriterDelegate::OnSSLCertificateError( |
62 URLRequest* request, int cert_error, net::X509Certificate* cert) { | 63 net::URLRequest* request, int cert_error, net::X509Certificate* cert) { |
63 NOTREACHED(); | 64 NOTREACHED(); |
64 OnError(base::PLATFORM_FILE_ERROR_SECURITY); | 65 OnError(base::PLATFORM_FILE_ERROR_SECURITY); |
65 } | 66 } |
66 | 67 |
67 void FileWriterDelegate::OnResponseStarted(URLRequest* request) { | 68 void FileWriterDelegate::OnResponseStarted(net::URLRequest* request) { |
68 DCHECK_EQ(request_, request); | 69 DCHECK_EQ(request_, request); |
69 if (!request->status().is_success()) { | 70 if (!request->status().is_success()) { |
70 OnError(base::PLATFORM_FILE_ERROR_FAILED); | 71 OnError(base::PLATFORM_FILE_ERROR_FAILED); |
71 return; | 72 return; |
72 } | 73 } |
73 int64 error = file_stream_->Seek(net::FROM_BEGIN, offset_); | 74 int64 error = file_stream_->Seek(net::FROM_BEGIN, offset_); |
74 if (error != offset_) { | 75 if (error != offset_) { |
75 OnError(base::PLATFORM_FILE_ERROR_FAILED); | 76 OnError(base::PLATFORM_FILE_ERROR_FAILED); |
76 return; | 77 return; |
77 } | 78 } |
78 Read(); | 79 Read(); |
79 } | 80 } |
80 | 81 |
81 void FileWriterDelegate::OnReadCompleted(URLRequest* request, int bytes_read) { | 82 void FileWriterDelegate::OnReadCompleted(net::URLRequest* request, |
| 83 int bytes_read) { |
82 DCHECK_EQ(request_, request); | 84 DCHECK_EQ(request_, request); |
83 if (!request->status().is_success()) { | 85 if (!request->status().is_success()) { |
84 OnError(base::PLATFORM_FILE_ERROR_FAILED); | 86 OnError(base::PLATFORM_FILE_ERROR_FAILED); |
85 return; | 87 return; |
86 } | 88 } |
87 OnDataReceived(bytes_read); | 89 OnDataReceived(bytes_read); |
88 } | 90 } |
89 | 91 |
90 void FileWriterDelegate::Read() { | 92 void FileWriterDelegate::Read() { |
91 bytes_written_ = 0; | 93 bytes_written_ = 0; |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
156 bytes_read_backlog_ = 0; | 158 bytes_read_backlog_ = 0; |
157 file_system_operation_->DidWrite( | 159 file_system_operation_->DidWrite( |
158 base::PLATFORM_FILE_OK, bytes_read, done); | 160 base::PLATFORM_FILE_OK, bytes_read, done); |
159 return; | 161 return; |
160 } | 162 } |
161 bytes_read_backlog_ += bytes_read; | 163 bytes_read_backlog_ += bytes_read; |
162 } | 164 } |
163 | 165 |
164 } // namespace fileapi | 166 } // namespace fileapi |
165 | 167 |
OLD | NEW |