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 "net/base/file_stream_context.h" | 5 #include "net/base/file_stream_context.h" |
6 | 6 |
7 #include <windows.h> | 7 #include <windows.h> |
8 | 8 |
9 #include "base/files/file_path.h" | 9 #include "base/files/file_path.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
11 #include "base/message_loop/message_loop.h" | 11 #include "base/message_loop/message_loop.h" |
12 #include "base/message_loop/message_loop_proxy.h" | 12 #include "base/message_loop/message_loop_proxy.h" |
13 #include "base/metrics/histogram.h" | 13 #include "base/metrics/histogram.h" |
14 #include "base/profiler/scoped_tracker.h" | |
15 #include "base/task_runner.h" | 14 #include "base/task_runner.h" |
16 #include "base/threading/worker_pool.h" | 15 #include "base/threading/worker_pool.h" |
17 #include "net/base/io_buffer.h" | 16 #include "net/base/io_buffer.h" |
18 #include "net/base/net_errors.h" | 17 #include "net/base/net_errors.h" |
19 | 18 |
20 namespace net { | 19 namespace net { |
21 | 20 |
22 namespace { | 21 namespace { |
23 | 22 |
24 void SetOffset(OVERLAPPED* overlapped, const LARGE_INTEGER& offset) { | 23 void SetOffset(OVERLAPPED* overlapped, const LARGE_INTEGER& offset) { |
25 overlapped->Offset = offset.LowPart; | 24 overlapped->Offset = offset.LowPart; |
26 overlapped->OffsetHigh = offset.HighPart; | 25 overlapped->OffsetHigh = offset.HighPart; |
27 } | 26 } |
28 | 27 |
29 void IncrementOffset(OVERLAPPED* overlapped, DWORD count) { | 28 void IncrementOffset(OVERLAPPED* overlapped, DWORD count) { |
30 LARGE_INTEGER offset; | 29 LARGE_INTEGER offset; |
31 offset.LowPart = overlapped->Offset; | 30 offset.LowPart = overlapped->Offset; |
32 offset.HighPart = overlapped->OffsetHigh; | 31 offset.HighPart = overlapped->OffsetHigh; |
33 offset.QuadPart += static_cast<LONGLONG>(count); | 32 offset.QuadPart += static_cast<LONGLONG>(count); |
34 SetOffset(overlapped, offset); | 33 SetOffset(overlapped, offset); |
35 } | 34 } |
36 | 35 |
37 } // namespace | 36 } // namespace |
38 | 37 |
39 FileStream::Context::Context(const scoped_refptr<base::TaskRunner>& task_runner) | 38 FileStream::Context::Context(const scoped_refptr<base::TaskRunner>& task_runner) |
40 : io_context_(), | 39 : io_context_(), |
41 async_in_progress_(false), | 40 async_in_progress_(false), |
42 orphaned_(false), | 41 orphaned_(false), |
43 task_runner_(task_runner), | 42 task_runner_(task_runner), |
44 weak_ptr_factory_(this) { | 43 async_read_initiated_(false), |
| 44 async_read_completed_(false), |
| 45 io_complete_for_read_received_(false), |
| 46 result_(0) { |
45 io_context_.handler = this; | 47 io_context_.handler = this; |
46 memset(&io_context_.overlapped, 0, sizeof(io_context_.overlapped)); | 48 memset(&io_context_.overlapped, 0, sizeof(io_context_.overlapped)); |
47 } | 49 } |
48 | 50 |
49 FileStream::Context::Context(base::File file, | 51 FileStream::Context::Context(base::File file, |
50 const scoped_refptr<base::TaskRunner>& task_runner) | 52 const scoped_refptr<base::TaskRunner>& task_runner) |
51 : io_context_(), | 53 : io_context_(), |
52 file_(file.Pass()), | 54 file_(file.Pass()), |
53 async_in_progress_(false), | 55 async_in_progress_(false), |
54 orphaned_(false), | 56 orphaned_(false), |
55 task_runner_(task_runner), | 57 task_runner_(task_runner), |
56 weak_ptr_factory_(this) { | 58 async_read_initiated_(false), |
| 59 async_read_completed_(false), |
| 60 io_complete_for_read_received_(false), |
| 61 result_(0) { |
57 io_context_.handler = this; | 62 io_context_.handler = this; |
58 memset(&io_context_.overlapped, 0, sizeof(io_context_.overlapped)); | 63 memset(&io_context_.overlapped, 0, sizeof(io_context_.overlapped)); |
59 if (file_.IsValid()) { | 64 if (file_.IsValid()) { |
60 // TODO(hashimoto): Check that file_ is async. | 65 // TODO(hashimoto): Check that file_ is async. |
61 OnFileOpened(); | 66 OnFileOpened(); |
62 } | 67 } |
63 } | 68 } |
64 | 69 |
65 FileStream::Context::~Context() { | 70 FileStream::Context::~Context() { |
66 } | 71 } |
67 | 72 |
68 int FileStream::Context::Read(IOBuffer* buf, | 73 int FileStream::Context::Read(IOBuffer* buf, |
69 int buf_len, | 74 int buf_len, |
70 const CompletionCallback& callback) { | 75 const CompletionCallback& callback) { |
71 // TODO(vadimt): Remove ScopedTracker below once crbug.com/423948 is fixed. | 76 CHECK(!async_in_progress_); |
72 tracked_objects::ScopedTracker tracking_profile( | 77 DCHECK(!async_read_initiated_); |
73 FROM_HERE_WITH_EXPLICIT_FUNCTION("423948 FileStream::Context::Read")); | 78 DCHECK(!async_read_completed_); |
74 | 79 DCHECK(!io_complete_for_read_received_); |
75 DCHECK(!async_in_progress_); | |
76 | 80 |
77 IOCompletionIsPending(callback, buf); | 81 IOCompletionIsPending(callback, buf); |
78 | 82 |
79 base::WorkerPool::PostTask( | 83 async_read_initiated_ = true; |
| 84 result_ = 0; |
| 85 |
| 86 task_runner_->PostTask( |
80 FROM_HERE, | 87 FROM_HERE, |
81 base::Bind(&FileStream::Context::ReadAsync, | 88 base::Bind(&FileStream::Context::ReadAsync, base::Unretained(this), |
82 weak_ptr_factory_.GetWeakPtr(), file_.GetPlatformFile(), | 89 file_.GetPlatformFile(), make_scoped_refptr(buf), buf_len, |
83 make_scoped_refptr(buf), buf_len, &io_context_.overlapped, | 90 &io_context_.overlapped, |
84 base::MessageLoop::current()->message_loop_proxy()), | 91 base::MessageLoop::current()->message_loop_proxy())); |
85 false); | |
86 | |
87 return ERR_IO_PENDING; | 92 return ERR_IO_PENDING; |
88 } | 93 } |
89 | 94 |
90 int FileStream::Context::Write(IOBuffer* buf, | 95 int FileStream::Context::Write(IOBuffer* buf, |
91 int buf_len, | 96 int buf_len, |
92 const CompletionCallback& callback) { | 97 const CompletionCallback& callback) { |
| 98 CHECK(!async_in_progress_); |
| 99 |
| 100 result_ = 0; |
| 101 |
93 DWORD bytes_written = 0; | 102 DWORD bytes_written = 0; |
94 if (!WriteFile(file_.GetPlatformFile(), buf->data(), buf_len, | 103 if (!WriteFile(file_.GetPlatformFile(), buf->data(), buf_len, |
95 &bytes_written, &io_context_.overlapped)) { | 104 &bytes_written, &io_context_.overlapped)) { |
96 IOResult error = IOResult::FromOSError(GetLastError()); | 105 IOResult error = IOResult::FromOSError(GetLastError()); |
97 if (error.os_error == ERROR_IO_PENDING) | 106 if (error.os_error == ERROR_IO_PENDING) |
98 IOCompletionIsPending(callback, buf); | 107 IOCompletionIsPending(callback, buf); |
99 else | 108 else |
100 LOG(WARNING) << "WriteFile failed: " << error.os_error; | 109 LOG(WARNING) << "WriteFile failed: " << error.os_error; |
101 return static_cast<int>(error.result); | 110 return static_cast<int>(error.result); |
102 } | 111 } |
(...skipping 30 matching lines...) Expand all Loading... |
133 } | 142 } |
134 | 143 |
135 void FileStream::Context::OnIOCompleted( | 144 void FileStream::Context::OnIOCompleted( |
136 base::MessageLoopForIO::IOContext* context, | 145 base::MessageLoopForIO::IOContext* context, |
137 DWORD bytes_read, | 146 DWORD bytes_read, |
138 DWORD error) { | 147 DWORD error) { |
139 DCHECK_EQ(&io_context_, context); | 148 DCHECK_EQ(&io_context_, context); |
140 DCHECK(!callback_.is_null()); | 149 DCHECK(!callback_.is_null()); |
141 DCHECK(async_in_progress_); | 150 DCHECK(async_in_progress_); |
142 | 151 |
143 async_in_progress_ = false; | 152 if (!async_read_initiated_) |
| 153 async_in_progress_ = false; |
| 154 |
144 if (orphaned_) { | 155 if (orphaned_) { |
145 callback_.Reset(); | 156 io_complete_for_read_received_ = true; |
146 in_flight_buf_ = NULL; | 157 // If we are called due to a pending read and the asynchronous read task |
147 CloseAndDelete(); | 158 // has not completed we have to keep the context around until it completes. |
| 159 if (async_read_initiated_ && !async_read_completed_) |
| 160 return; |
| 161 DeleteOrphanedContext(); |
148 return; | 162 return; |
149 } | 163 } |
150 | 164 |
151 int result; | |
152 if (error == ERROR_HANDLE_EOF) { | 165 if (error == ERROR_HANDLE_EOF) { |
153 result = 0; | 166 result_ = 0; |
154 } else if (error) { | 167 } else if (error) { |
155 IOResult error_result = IOResult::FromOSError(error); | 168 IOResult error_result = IOResult::FromOSError(error); |
156 result = static_cast<int>(error_result.result); | 169 result_ = static_cast<int>(error_result.result); |
157 } else { | 170 } else { |
158 result = bytes_read; | 171 if (result_) |
| 172 DCHECK_EQ(result_, static_cast<int>(bytes_read)); |
| 173 result_ = bytes_read; |
159 IncrementOffset(&io_context_.overlapped, bytes_read); | 174 IncrementOffset(&io_context_.overlapped, bytes_read); |
160 } | 175 } |
161 | 176 |
| 177 if (async_read_initiated_) |
| 178 io_complete_for_read_received_ = true; |
| 179 |
| 180 InvokeUserCallback(); |
| 181 } |
| 182 |
| 183 void FileStream::Context::InvokeUserCallback() { |
| 184 // For an asynchonous Read operation don't invoke the user callback until |
| 185 // we receive the IO completion notification and the asynchronous Read |
| 186 // completion notification. |
| 187 if (async_read_initiated_) { |
| 188 if (!io_complete_for_read_received_ || !async_read_completed_) |
| 189 return; |
| 190 async_read_initiated_ = false; |
| 191 io_complete_for_read_received_ = false; |
| 192 async_read_completed_ = false; |
| 193 async_in_progress_ = false; |
| 194 } |
162 CompletionCallback temp_callback = callback_; | 195 CompletionCallback temp_callback = callback_; |
163 callback_.Reset(); | 196 callback_.Reset(); |
164 scoped_refptr<IOBuffer> temp_buf = in_flight_buf_; | 197 scoped_refptr<IOBuffer> temp_buf = in_flight_buf_; |
165 in_flight_buf_ = NULL; | 198 in_flight_buf_ = NULL; |
166 temp_callback.Run(result); | 199 temp_callback.Run(result_); |
| 200 } |
| 201 |
| 202 void FileStream::Context::DeleteOrphanedContext() { |
| 203 async_in_progress_ = false; |
| 204 callback_.Reset(); |
| 205 in_flight_buf_ = NULL; |
| 206 CloseAndDelete(); |
167 } | 207 } |
168 | 208 |
169 // static | 209 // static |
170 void FileStream::Context::ReadAsync( | 210 void FileStream::Context::ReadAsync( |
171 const base::WeakPtr<FileStream::Context>& context, | 211 FileStream::Context* context, |
172 HANDLE file, | 212 HANDLE file, |
173 scoped_refptr<net::IOBuffer> buf, | 213 scoped_refptr<net::IOBuffer> buf, |
174 int buf_len, | 214 int buf_len, |
175 OVERLAPPED* overlapped, | 215 OVERLAPPED* overlapped, |
176 scoped_refptr<base::MessageLoopProxy> origin_thread_loop) { | 216 scoped_refptr<base::MessageLoopProxy> origin_thread_loop) { |
177 DWORD bytes_read = 0; | 217 DWORD bytes_read = 0; |
178 if (!ReadFile(file, buf->data(), buf_len, &bytes_read, overlapped)) { | 218 BOOL ret = ::ReadFile(file, buf->data(), buf_len, &bytes_read, overlapped); |
179 origin_thread_loop->PostTask( | 219 origin_thread_loop->PostTask( |
180 FROM_HERE, base::Bind(&FileStream::Context::ReadAsyncResult, context, | 220 FROM_HERE, |
181 ::GetLastError())); | 221 base::Bind(&FileStream::Context::ReadAsyncResult, |
182 } | 222 base::Unretained(context), ret, bytes_read, ::GetLastError())); |
183 } | 223 } |
184 | 224 |
185 void FileStream::Context::ReadAsyncResult(DWORD os_error) { | 225 void FileStream::Context::ReadAsyncResult(BOOL read_file_ret, |
| 226 DWORD bytes_read, |
| 227 DWORD os_error) { |
| 228 // If the context is orphaned and we already received the io completion |
| 229 // notification then we should delete the context and get out. |
| 230 if (orphaned_ && io_complete_for_read_received_) { |
| 231 DeleteOrphanedContext(); |
| 232 return; |
| 233 } |
| 234 |
| 235 async_read_completed_ = true; |
| 236 if (read_file_ret) { |
| 237 result_ = bytes_read; |
| 238 InvokeUserCallback(); |
| 239 return; |
| 240 } |
| 241 |
186 IOResult error = IOResult::FromOSError(os_error); | 242 IOResult error = IOResult::FromOSError(os_error); |
187 if (error.os_error == ERROR_HANDLE_EOF) { | 243 if (error.os_error == ERROR_IO_PENDING) { |
188 // Report EOF by returning 0 bytes read. | 244 InvokeUserCallback(); |
189 OnIOCompleted(&io_context_, 0, error.os_error); | 245 } else { |
190 } else if (error.os_error != ERROR_IO_PENDING) { | |
191 // We don't need to inform the caller about ERROR_PENDING_IO as that was | |
192 // already done when the ReadFile call was queued to the worker pool. | |
193 if (error.os_error) | |
194 LOG(WARNING) << "ReadFile failed: " << error.os_error; | |
195 OnIOCompleted(&io_context_, 0, error.os_error); | 246 OnIOCompleted(&io_context_, 0, error.os_error); |
196 } | 247 } |
197 } | 248 } |
198 | 249 |
199 } // namespace net | 250 } // namespace net |
OLD | NEW |