OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "services/files/file_impl.h" | 5 #include "services/files/file_impl.h" |
6 | 6 |
7 #include <errno.h> | 7 #include <errno.h> |
8 #include <fcntl.h> | 8 #include <fcntl.h> |
9 #include <sys/stat.h> | 9 #include <sys/stat.h> |
10 #include <sys/types.h> | 10 #include <sys/types.h> |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
64 Whence whence, | 64 Whence whence, |
65 const ReadCallback& callback) { | 65 const ReadCallback& callback) { |
66 if (!file_fd_.is_valid()) { | 66 if (!file_fd_.is_valid()) { |
67 callback.Run(ERROR_CLOSED, Array<uint8_t>()); | 67 callback.Run(ERROR_CLOSED, Array<uint8_t>()); |
68 return; | 68 return; |
69 } | 69 } |
70 if (num_bytes_to_read > kMaxReadSize) { | 70 if (num_bytes_to_read > kMaxReadSize) { |
71 callback.Run(ERROR_OUT_OF_RANGE, Array<uint8_t>()); | 71 callback.Run(ERROR_OUT_OF_RANGE, Array<uint8_t>()); |
72 return; | 72 return; |
73 } | 73 } |
74 if (Error error = IsOffsetValid(offset)) { | 74 |
| 75 Error error = IsOffsetValid(offset); |
| 76 if (error != ERROR_OK) { |
75 callback.Run(error, Array<uint8_t>()); | 77 callback.Run(error, Array<uint8_t>()); |
76 return; | 78 return; |
77 } | 79 } |
78 if (Error error = IsWhenceValid(whence)) { | 80 |
| 81 error = IsWhenceValid(whence); |
| 82 if (error != ERROR_OK) { |
79 callback.Run(error, Array<uint8_t>()); | 83 callback.Run(error, Array<uint8_t>()); |
80 return; | 84 return; |
81 } | 85 } |
82 | 86 |
83 if (offset != 0 || whence != WHENCE_FROM_CURRENT) { | 87 if (offset != 0 || whence != WHENCE_FROM_CURRENT) { |
84 // TODO(vtl): Use |pread()| below in the |WHENCE_FROM_START| case. This | 88 // TODO(vtl): Use |pread()| below in the |WHENCE_FROM_START| case. This |
85 // implementation is obviously not atomic. (If someone seeks simultaneously, | 89 // implementation is obviously not atomic. (If someone seeks simultaneously, |
86 // we'll end up writing somewhere else. Or, well, we would if we were | 90 // we'll end up writing somewhere else. Or, well, we would if we were |
87 // multithreaded.) Maybe we should do an |ftell()| and always use |pread()|. | 91 // multithreaded.) Maybe we should do an |ftell()| and always use |pread()|. |
88 // TODO(vtl): Possibly, at least sometimes we should not change the file | 92 // TODO(vtl): Possibly, at least sometimes we should not change the file |
(...skipping 29 matching lines...) Expand all Loading... |
118 callback.Run(ERROR_CLOSED, 0); | 122 callback.Run(ERROR_CLOSED, 0); |
119 return; | 123 return; |
120 } | 124 } |
121 // Who knows what |write()| would return if the size is that big (and it | 125 // Who knows what |write()| would return if the size is that big (and it |
122 // actually wrote that much). | 126 // actually wrote that much). |
123 if (bytes_to_write.size() > | 127 if (bytes_to_write.size() > |
124 static_cast<size_t>(std::numeric_limits<ssize_t>::max())) { | 128 static_cast<size_t>(std::numeric_limits<ssize_t>::max())) { |
125 callback.Run(ERROR_OUT_OF_RANGE, 0); | 129 callback.Run(ERROR_OUT_OF_RANGE, 0); |
126 return; | 130 return; |
127 } | 131 } |
128 if (Error error = IsOffsetValid(offset)) { | 132 |
| 133 Error error = IsOffsetValid(offset); |
| 134 if (error != ERROR_OK) { |
129 callback.Run(error, 0); | 135 callback.Run(error, 0); |
130 return; | 136 return; |
131 } | 137 } |
132 if (Error error = IsWhenceValid(whence)) { | 138 |
| 139 error = IsWhenceValid(whence); |
| 140 if (error != ERROR_OK) { |
133 callback.Run(error, 0); | 141 callback.Run(error, 0); |
134 return; | 142 return; |
135 } | 143 } |
136 | 144 |
137 if (offset != 0 || whence != WHENCE_FROM_CURRENT) { | 145 if (offset != 0 || whence != WHENCE_FROM_CURRENT) { |
138 // TODO(vtl): Use |pwrite()| below in the |WHENCE_FROM_START| case. This | 146 // TODO(vtl): Use |pwrite()| below in the |WHENCE_FROM_START| case. This |
139 // implementation is obviously not atomic. (If someone seeks simultaneously, | 147 // implementation is obviously not atomic. (If someone seeks simultaneously, |
140 // we'll end up writing somewhere else. Or, well, we would if we were | 148 // we'll end up writing somewhere else. Or, well, we would if we were |
141 // multithreaded.) Maybe we should do an |ftell()| and always use | 149 // multithreaded.) Maybe we should do an |ftell()| and always use |
142 // |pwrite()|. | 150 // |pwrite()|. |
(...skipping 22 matching lines...) Expand all Loading... |
165 | 173 |
166 void FileImpl::ReadToStream(ScopedDataPipeProducerHandle source, | 174 void FileImpl::ReadToStream(ScopedDataPipeProducerHandle source, |
167 int64_t offset, | 175 int64_t offset, |
168 Whence whence, | 176 Whence whence, |
169 int64_t num_bytes_to_read, | 177 int64_t num_bytes_to_read, |
170 const ReadToStreamCallback& callback) { | 178 const ReadToStreamCallback& callback) { |
171 if (!file_fd_.is_valid()) { | 179 if (!file_fd_.is_valid()) { |
172 callback.Run(ERROR_CLOSED); | 180 callback.Run(ERROR_CLOSED); |
173 return; | 181 return; |
174 } | 182 } |
175 if (Error error = IsOffsetValid(offset)) { | 183 |
| 184 Error error = IsOffsetValid(offset); |
| 185 if (error != ERROR_OK) { |
176 callback.Run(error); | 186 callback.Run(error); |
177 return; | 187 return; |
178 } | 188 } |
179 if (Error error = IsWhenceValid(whence)) { | 189 |
| 190 error = IsWhenceValid(whence); |
| 191 if (error != ERROR_OK) { |
180 callback.Run(error); | 192 callback.Run(error); |
181 return; | 193 return; |
182 } | 194 } |
183 | 195 |
184 // TODO(vtl): FIXME soon | 196 // TODO(vtl): FIXME soon |
185 NOTIMPLEMENTED(); | 197 NOTIMPLEMENTED(); |
186 callback.Run(ERROR_UNIMPLEMENTED); | 198 callback.Run(ERROR_UNIMPLEMENTED); |
187 } | 199 } |
188 | 200 |
189 void FileImpl::WriteFromStream(ScopedDataPipeConsumerHandle sink, | 201 void FileImpl::WriteFromStream(ScopedDataPipeConsumerHandle sink, |
190 int64_t offset, | 202 int64_t offset, |
191 Whence whence, | 203 Whence whence, |
192 const WriteFromStreamCallback& callback) { | 204 const WriteFromStreamCallback& callback) { |
193 if (!file_fd_.is_valid()) { | 205 if (!file_fd_.is_valid()) { |
194 callback.Run(ERROR_CLOSED); | 206 callback.Run(ERROR_CLOSED); |
195 return; | 207 return; |
196 } | 208 } |
197 if (Error error = IsOffsetValid(offset)) { | 209 |
| 210 Error error = IsOffsetValid(offset); |
| 211 if (error != ERROR_OK) { |
198 callback.Run(error); | 212 callback.Run(error); |
199 return; | 213 return; |
200 } | 214 } |
201 if (Error error = IsWhenceValid(whence)) { | 215 |
| 216 error = IsWhenceValid(whence); |
| 217 if (error != ERROR_OK) { |
202 callback.Run(error); | 218 callback.Run(error); |
203 return; | 219 return; |
204 } | 220 } |
205 | 221 |
206 // TODO(vtl): FIXME soon | 222 // TODO(vtl): FIXME soon |
207 NOTIMPLEMENTED(); | 223 NOTIMPLEMENTED(); |
208 callback.Run(ERROR_UNIMPLEMENTED); | 224 callback.Run(ERROR_UNIMPLEMENTED); |
209 } | 225 } |
210 | 226 |
211 void FileImpl::Tell(const TellCallback& callback) { | 227 void FileImpl::Tell(const TellCallback& callback) { |
212 Seek(0, WHENCE_FROM_CURRENT, callback); | 228 Seek(0, WHENCE_FROM_CURRENT, callback); |
213 } | 229 } |
214 | 230 |
215 void FileImpl::Seek(int64_t offset, | 231 void FileImpl::Seek(int64_t offset, |
216 Whence whence, | 232 Whence whence, |
217 const SeekCallback& callback) { | 233 const SeekCallback& callback) { |
218 if (!file_fd_.is_valid()) { | 234 if (!file_fd_.is_valid()) { |
219 callback.Run(ERROR_CLOSED, 0); | 235 callback.Run(ERROR_CLOSED, 0); |
220 return; | 236 return; |
221 } | 237 } |
222 if (Error error = IsOffsetValid(offset)) { | 238 |
| 239 Error error = IsOffsetValid(offset); |
| 240 if (error != ERROR_OK) { |
223 callback.Run(error, 0); | 241 callback.Run(error, 0); |
224 return; | 242 return; |
225 } | 243 } |
226 if (Error error = IsWhenceValid(whence)) { | 244 |
| 245 error = IsWhenceValid(whence); |
| 246 if (error != ERROR_OK) { |
227 callback.Run(error, 0); | 247 callback.Run(error, 0); |
228 return; | 248 return; |
229 } | 249 } |
230 | 250 |
231 off_t position = lseek(file_fd_.get(), static_cast<off_t>(offset), | 251 off_t position = lseek(file_fd_.get(), static_cast<off_t>(offset), |
232 WhenceToStandardWhence(whence)); | 252 WhenceToStandardWhence(whence)); |
233 if (position < 0) { | 253 if (position < 0) { |
234 callback.Run(ErrnoToError(errno), 0); | 254 callback.Run(ErrnoToError(errno), 0); |
235 return; | 255 return; |
236 } | 256 } |
(...skipping 11 matching lines...) Expand all Loading... |
248 | 268 |
249 void FileImpl::Truncate(int64_t size, const TruncateCallback& callback) { | 269 void FileImpl::Truncate(int64_t size, const TruncateCallback& callback) { |
250 if (!file_fd_.is_valid()) { | 270 if (!file_fd_.is_valid()) { |
251 callback.Run(ERROR_CLOSED); | 271 callback.Run(ERROR_CLOSED); |
252 return; | 272 return; |
253 } | 273 } |
254 if (size < 0) { | 274 if (size < 0) { |
255 callback.Run(ERROR_INVALID_ARGUMENT); | 275 callback.Run(ERROR_INVALID_ARGUMENT); |
256 return; | 276 return; |
257 } | 277 } |
258 if (Error error = IsOffsetValid(size)) { | 278 |
| 279 Error error = IsOffsetValid(size); |
| 280 if (error != ERROR_OK) { |
259 callback.Run(error); | 281 callback.Run(error); |
260 return; | 282 return; |
261 } | 283 } |
262 | 284 |
263 if (ftruncate(file_fd_.get(), static_cast<off_t>(size)) != 0) { | 285 if (ftruncate(file_fd_.get(), static_cast<off_t>(size)) != 0) { |
264 callback.Run(ErrnoToError(errno)); | 286 callback.Run(ErrnoToError(errno)); |
265 return; | 287 return; |
266 } | 288 } |
267 | 289 |
268 callback.Run(ERROR_OK); | 290 callback.Run(ERROR_OK); |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
326 return; | 348 return; |
327 } | 349 } |
328 | 350 |
329 // TODO(vtl): The "correct" error code should be one that can be translated to | 351 // TODO(vtl): The "correct" error code should be one that can be translated to |
330 // ENOTTY! | 352 // ENOTTY! |
331 callback.Run(ERROR_UNAVAILABLE, Array<uint32_t>()); | 353 callback.Run(ERROR_UNAVAILABLE, Array<uint32_t>()); |
332 } | 354 } |
333 | 355 |
334 } // namespace files | 356 } // namespace files |
335 } // namespace mojo | 357 } // namespace mojo |
OLD | NEW |