| 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 "base/platform_file.h" | 5 #include "base/platform_file.h" |
| 6 | 6 |
| 7 #include <fcntl.h> | 7 #include <fcntl.h> |
| 8 #include <errno.h> | 8 #include <errno.h> |
| 9 #include <sys/stat.h> | 9 #include <sys/stat.h> |
| 10 #include <unistd.h> | 10 #include <unistd.h> |
| 11 | 11 |
| 12 #include "base/files/file_path.h" | 12 #include "base/files/file_path.h" |
| 13 #include "base/logging.h" | 13 #include "base/logging.h" |
| 14 #include "base/metrics/sparse_histogram.h" | 14 #include "base/metrics/sparse_histogram.h" |
| 15 #include "base/posix/eintr_wrapper.h" | 15 #include "base/posix/eintr_wrapper.h" |
| 16 #include "base/strings/utf_string_conversions.h" | 16 #include "base/strings/utf_string_conversions.h" |
| 17 #include "base/threading/thread_restrictions.h" | 17 #include "base/threading/thread_restrictions.h" |
| 18 | 18 |
| 19 #if defined(OS_ANDROID) | 19 #if defined(OS_ANDROID) |
| 20 #include "base/os_compat_android.h" | 20 #include "base/os_compat_android.h" |
| 21 #endif | 21 #endif |
| 22 | 22 |
| 23 namespace base { | 23 namespace base { |
| 24 | 24 |
| 25 // Make sure our Whence mappings match the system headers. | 25 // Make sure our Whence mappings match the system headers. |
| 26 COMPILE_ASSERT(PLATFORM_FILE_FROM_BEGIN == SEEK_SET && | 26 COMPILE_ASSERT(PLATFORM_FILE_FROM_BEGIN == SEEK_SET && |
| 27 PLATFORM_FILE_FROM_CURRENT == SEEK_CUR && | 27 PLATFORM_FILE_FROM_CURRENT == SEEK_CUR && |
| 28 PLATFORM_FILE_FROM_END == SEEK_END, whence_matches_system); | 28 PLATFORM_FILE_FROM_END == SEEK_END, whence_matches_system); |
| 29 | 29 |
| 30 #if defined(OS_BSD) || defined(OS_MACOSX) | 30 #if defined(OS_BSD) || defined(OS_MACOSX) || defined(OS_NACL) |
| 31 typedef struct stat stat_wrapper_t; | 31 typedef struct stat stat_wrapper_t; |
| 32 static int CallFstat(int fd, stat_wrapper_t *sb) { | 32 static int CallFstat(int fd, stat_wrapper_t *sb) { |
| 33 base::ThreadRestrictions::AssertIOAllowed(); | 33 base::ThreadRestrictions::AssertIOAllowed(); |
| 34 return fstat(fd, sb); | 34 return fstat(fd, sb); |
| 35 } | 35 } |
| 36 #else | 36 #else |
| 37 typedef struct stat64 stat_wrapper_t; | 37 typedef struct stat64 stat_wrapper_t; |
| 38 static int CallFstat(int fd, stat_wrapper_t *sb) { | 38 static int CallFstat(int fd, stat_wrapper_t *sb) { |
| 39 base::ThreadRestrictions::AssertIOAllowed(); | 39 base::ThreadRestrictions::AssertIOAllowed(); |
| 40 return fstat64(fd, sb); | 40 return fstat64(fd, sb); |
| 41 } | 41 } |
| 42 #endif | 42 #endif |
| 43 | 43 |
| 44 // NaCl lacks many file handling system calls, so exclude any platform file |
| 45 // functions that can't be implemented there. |
| 46 #if !defined(OS_NACL) |
| 44 // TODO(erikkay): does it make sense to support PLATFORM_FILE_EXCLUSIVE_* here? | 47 // TODO(erikkay): does it make sense to support PLATFORM_FILE_EXCLUSIVE_* here? |
| 45 PlatformFile CreatePlatformFileUnsafe(const FilePath& name, | 48 PlatformFile CreatePlatformFileUnsafe(const FilePath& name, |
| 46 int flags, | 49 int flags, |
| 47 bool* created, | 50 bool* created, |
| 48 PlatformFileError* error) { | 51 PlatformFileError* error) { |
| 49 base::ThreadRestrictions::AssertIOAllowed(); | 52 base::ThreadRestrictions::AssertIOAllowed(); |
| 50 | 53 |
| 51 int open_flags = 0; | 54 int open_flags = 0; |
| 52 if (flags & PLATFORM_FILE_CREATE) | 55 if (flags & PLATFORM_FILE_CREATE) |
| 53 open_flags = O_CREAT | O_EXCL; | 56 open_flags = O_CREAT | O_EXCL; |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 132 else | 135 else |
| 133 *error = ErrnoToPlatformFileError(errno); | 136 *error = ErrnoToPlatformFileError(errno); |
| 134 } | 137 } |
| 135 | 138 |
| 136 return descriptor; | 139 return descriptor; |
| 137 } | 140 } |
| 138 | 141 |
| 139 FILE* FdopenPlatformFile(PlatformFile file, const char* mode) { | 142 FILE* FdopenPlatformFile(PlatformFile file, const char* mode) { |
| 140 return fdopen(file, mode); | 143 return fdopen(file, mode); |
| 141 } | 144 } |
| 145 #endif // !defined(OS_NACL) |
| 142 | 146 |
| 143 bool ClosePlatformFile(PlatformFile file) { | 147 bool ClosePlatformFile(PlatformFile file) { |
| 144 base::ThreadRestrictions::AssertIOAllowed(); | 148 base::ThreadRestrictions::AssertIOAllowed(); |
| 145 return !HANDLE_EINTR(close(file)); | 149 return !HANDLE_EINTR(close(file)); |
| 146 } | 150 } |
| 147 | 151 |
| 148 int64 SeekPlatformFile(PlatformFile file, | 152 int64 SeekPlatformFile(PlatformFile file, |
| 149 PlatformFileWhence whence, | 153 PlatformFileWhence whence, |
| 150 int64 offset) { | 154 int64 offset) { |
| 151 base::ThreadRestrictions::AssertIOAllowed(); | 155 base::ThreadRestrictions::AssertIOAllowed(); |
| 152 if (file < 0 || offset < 0) | 156 if (file < 0 || offset < 0) |
| 153 return -1; | 157 return -1; |
| 154 | 158 |
| 155 return lseek(file, static_cast<off_t>(offset), static_cast<int>(whence)); | 159 return lseek(file, static_cast<off_t>(offset), static_cast<int>(whence)); |
| 156 } | 160 } |
| 157 | 161 |
| 162 #if !defined(OS_NACL) // NaCl has no pread. |
| 158 int ReadPlatformFile(PlatformFile file, int64 offset, char* data, int size) { | 163 int ReadPlatformFile(PlatformFile file, int64 offset, char* data, int size) { |
| 159 base::ThreadRestrictions::AssertIOAllowed(); | 164 base::ThreadRestrictions::AssertIOAllowed(); |
| 160 if (file < 0 || size < 0) | 165 if (file < 0 || size < 0) |
| 161 return -1; | 166 return -1; |
| 162 | 167 |
| 163 int bytes_read = 0; | 168 int bytes_read = 0; |
| 164 int rv; | 169 int rv; |
| 165 do { | 170 do { |
| 166 rv = HANDLE_EINTR(pread(file, data + bytes_read, | 171 rv = HANDLE_EINTR(pread(file, data + bytes_read, |
| 167 size - bytes_read, offset + bytes_read)); | 172 size - bytes_read, offset + bytes_read)); |
| 168 if (rv <= 0) | 173 if (rv <= 0) |
| 169 break; | 174 break; |
| 170 | 175 |
| 171 bytes_read += rv; | 176 bytes_read += rv; |
| 172 } while (bytes_read < size); | 177 } while (bytes_read < size); |
| 173 | 178 |
| 174 return bytes_read ? bytes_read : rv; | 179 return bytes_read ? bytes_read : rv; |
| 175 } | 180 } |
| 181 #endif // !defined(OS_NACL) |
| 176 | 182 |
| 177 int ReadPlatformFileAtCurrentPos(PlatformFile file, char* data, int size) { | 183 int ReadPlatformFileAtCurrentPos(PlatformFile file, char* data, int size) { |
| 178 base::ThreadRestrictions::AssertIOAllowed(); | 184 base::ThreadRestrictions::AssertIOAllowed(); |
| 179 if (file < 0 || size < 0) | 185 if (file < 0 || size < 0) |
| 180 return -1; | 186 return -1; |
| 181 | 187 |
| 182 int bytes_read = 0; | 188 int bytes_read = 0; |
| 183 int rv; | 189 int rv; |
| 184 do { | 190 do { |
| 185 rv = HANDLE_EINTR(read(file, data, size)); | 191 rv = HANDLE_EINTR(read(file, data, size)); |
| 186 if (rv <= 0) | 192 if (rv <= 0) |
| 187 break; | 193 break; |
| 188 | 194 |
| 189 bytes_read += rv; | 195 bytes_read += rv; |
| 190 } while (bytes_read < size); | 196 } while (bytes_read < size); |
| 191 | 197 |
| 192 return bytes_read ? bytes_read : rv; | 198 return bytes_read ? bytes_read : rv; |
| 193 } | 199 } |
| 194 | 200 |
| 201 #if !defined(OS_NACL) // NaCl has no pread. |
| 195 int ReadPlatformFileNoBestEffort(PlatformFile file, int64 offset, | 202 int ReadPlatformFileNoBestEffort(PlatformFile file, int64 offset, |
| 196 char* data, int size) { | 203 char* data, int size) { |
| 197 base::ThreadRestrictions::AssertIOAllowed(); | 204 base::ThreadRestrictions::AssertIOAllowed(); |
| 198 if (file < 0) | 205 if (file < 0) |
| 199 return -1; | 206 return -1; |
| 200 | 207 |
| 201 return HANDLE_EINTR(pread(file, data, size, offset)); | 208 return HANDLE_EINTR(pread(file, data, size, offset)); |
| 202 } | 209 } |
| 210 #endif // !defined(OS_NACL) |
| 203 | 211 |
| 204 int ReadPlatformFileCurPosNoBestEffort(PlatformFile file, | 212 int ReadPlatformFileCurPosNoBestEffort(PlatformFile file, |
| 205 char* data, int size) { | 213 char* data, int size) { |
| 206 base::ThreadRestrictions::AssertIOAllowed(); | 214 base::ThreadRestrictions::AssertIOAllowed(); |
| 207 if (file < 0 || size < 0) | 215 if (file < 0 || size < 0) |
| 208 return -1; | 216 return -1; |
| 209 | 217 |
| 210 return HANDLE_EINTR(read(file, data, size)); | 218 return HANDLE_EINTR(read(file, data, size)); |
| 211 } | 219 } |
| 212 | 220 |
| 221 #if !defined(OS_NACL) // NaCl has no fcntl or pwrite. |
| 213 int WritePlatformFile(PlatformFile file, int64 offset, | 222 int WritePlatformFile(PlatformFile file, int64 offset, |
| 214 const char* data, int size) { | 223 const char* data, int size) { |
| 215 base::ThreadRestrictions::AssertIOAllowed(); | 224 base::ThreadRestrictions::AssertIOAllowed(); |
| 216 | 225 |
| 217 if (fcntl(file, F_GETFL) & O_APPEND) | 226 if (fcntl(file, F_GETFL) & O_APPEND) |
| 218 return WritePlatformFileAtCurrentPos(file, data, size); | 227 return WritePlatformFileAtCurrentPos(file, data, size); |
| 219 | 228 |
| 220 if (file < 0 || size < 0) | 229 if (file < 0 || size < 0) |
| 221 return -1; | 230 return -1; |
| 222 | 231 |
| 223 int bytes_written = 0; | 232 int bytes_written = 0; |
| 224 int rv; | 233 int rv; |
| 225 do { | 234 do { |
| 226 rv = HANDLE_EINTR(pwrite(file, data + bytes_written, | 235 rv = HANDLE_EINTR(pwrite(file, data + bytes_written, |
| 227 size - bytes_written, offset + bytes_written)); | 236 size - bytes_written, offset + bytes_written)); |
| 228 if (rv <= 0) | 237 if (rv <= 0) |
| 229 break; | 238 break; |
| 230 | 239 |
| 231 bytes_written += rv; | 240 bytes_written += rv; |
| 232 } while (bytes_written < size); | 241 } while (bytes_written < size); |
| 233 | 242 |
| 234 return bytes_written ? bytes_written : rv; | 243 return bytes_written ? bytes_written : rv; |
| 235 } | 244 } |
| 245 #endif // !defined(OS_NACL) |
| 236 | 246 |
| 237 int WritePlatformFileAtCurrentPos(PlatformFile file, | 247 int WritePlatformFileAtCurrentPos(PlatformFile file, |
| 238 const char* data, int size) { | 248 const char* data, int size) { |
| 239 base::ThreadRestrictions::AssertIOAllowed(); | 249 base::ThreadRestrictions::AssertIOAllowed(); |
| 240 if (file < 0 || size < 0) | 250 if (file < 0 || size < 0) |
| 241 return -1; | 251 return -1; |
| 242 | 252 |
| 243 int bytes_written = 0; | 253 int bytes_written = 0; |
| 244 int rv; | 254 int rv; |
| 245 do { | 255 do { |
| 246 rv = HANDLE_EINTR(write(file, data, size)); | 256 rv = HANDLE_EINTR(write(file, data, size)); |
| 247 if (rv <= 0) | 257 if (rv <= 0) |
| 248 break; | 258 break; |
| 249 | 259 |
| 250 bytes_written += rv; | 260 bytes_written += rv; |
| 251 } while (bytes_written < size); | 261 } while (bytes_written < size); |
| 252 | 262 |
| 253 return bytes_written ? bytes_written : rv; | 263 return bytes_written ? bytes_written : rv; |
| 254 } | 264 } |
| 255 | 265 |
| 256 int WritePlatformFileCurPosNoBestEffort(PlatformFile file, | 266 int WritePlatformFileCurPosNoBestEffort(PlatformFile file, |
| 257 const char* data, int size) { | 267 const char* data, int size) { |
| 258 base::ThreadRestrictions::AssertIOAllowed(); | 268 base::ThreadRestrictions::AssertIOAllowed(); |
| 259 if (file < 0 || size < 0) | 269 if (file < 0 || size < 0) |
| 260 return -1; | 270 return -1; |
| 261 | 271 |
| 262 return HANDLE_EINTR(write(file, data, size)); | 272 return HANDLE_EINTR(write(file, data, size)); |
| 263 } | 273 } |
| 264 | 274 |
| 275 #if !defined(OS_NACL) // NaCl has no ftruncate or fsync. |
| 265 bool TruncatePlatformFile(PlatformFile file, int64 length) { | 276 bool TruncatePlatformFile(PlatformFile file, int64 length) { |
| 266 base::ThreadRestrictions::AssertIOAllowed(); | 277 base::ThreadRestrictions::AssertIOAllowed(); |
| 267 return ((file >= 0) && !HANDLE_EINTR(ftruncate(file, length))); | 278 return ((file >= 0) && !HANDLE_EINTR(ftruncate(file, length))); |
| 268 } | 279 } |
| 269 | 280 |
| 270 bool FlushPlatformFile(PlatformFile file) { | 281 bool FlushPlatformFile(PlatformFile file) { |
| 271 base::ThreadRestrictions::AssertIOAllowed(); | 282 base::ThreadRestrictions::AssertIOAllowed(); |
| 272 return !HANDLE_EINTR(fsync(file)); | 283 return !HANDLE_EINTR(fsync(file)); |
| 273 } | 284 } |
| 285 #endif // !defined(OS_NACL) |
| 274 | 286 |
| 287 #if !defined(OS_NACL) |
| 275 bool TouchPlatformFile(PlatformFile file, const base::Time& last_access_time, | 288 bool TouchPlatformFile(PlatformFile file, const base::Time& last_access_time, |
| 276 const base::Time& last_modified_time) { | 289 const base::Time& last_modified_time) { |
| 277 base::ThreadRestrictions::AssertIOAllowed(); | 290 base::ThreadRestrictions::AssertIOAllowed(); |
| 278 if (file < 0) | 291 if (file < 0) |
| 279 return false; | 292 return false; |
| 280 | 293 |
| 281 timeval times[2]; | 294 timeval times[2]; |
| 282 times[0] = last_access_time.ToTimeVal(); | 295 times[0] = last_access_time.ToTimeVal(); |
| 283 times[1] = last_modified_time.ToTimeVal(); | 296 times[1] = last_modified_time.ToTimeVal(); |
| 284 | 297 |
| 285 #ifdef __USE_XOPEN2K8 | 298 #ifdef __USE_XOPEN2K8 |
| 286 // futimens should be available, but futimes might not be | 299 // futimens should be available, but futimes might not be |
| 287 // http://pubs.opengroup.org/onlinepubs/9699919799/ | 300 // http://pubs.opengroup.org/onlinepubs/9699919799/ |
| 288 | 301 |
| 289 timespec ts_times[2]; | 302 timespec ts_times[2]; |
| 290 ts_times[0].tv_sec = times[0].tv_sec; | 303 ts_times[0].tv_sec = times[0].tv_sec; |
| 291 ts_times[0].tv_nsec = times[0].tv_usec * 1000; | 304 ts_times[0].tv_nsec = times[0].tv_usec * 1000; |
| 292 ts_times[1].tv_sec = times[1].tv_sec; | 305 ts_times[1].tv_sec = times[1].tv_sec; |
| 293 ts_times[1].tv_nsec = times[1].tv_usec * 1000; | 306 ts_times[1].tv_nsec = times[1].tv_usec * 1000; |
| 294 | 307 |
| 295 return !futimens(file, ts_times); | 308 return !futimens(file, ts_times); |
| 296 #else | 309 #else |
| 297 return !futimes(file, times); | 310 return !futimes(file, times); |
| 298 #endif | 311 #endif |
| 299 } | 312 } |
| 313 #endif // !defined(OS_NACL) |
| 300 | 314 |
| 301 bool GetPlatformFileInfo(PlatformFile file, PlatformFileInfo* info) { | 315 bool GetPlatformFileInfo(PlatformFile file, PlatformFileInfo* info) { |
| 302 if (!info) | 316 if (!info) |
| 303 return false; | 317 return false; |
| 304 | 318 |
| 305 stat_wrapper_t file_info; | 319 stat_wrapper_t file_info; |
| 306 if (CallFstat(file, &file_info)) | 320 if (CallFstat(file, &file_info)) |
| 307 return false; | 321 return false; |
| 308 | 322 |
| 309 info->is_directory = S_ISDIR(file_info.st_mode); | 323 info->is_directory = S_ISDIR(file_info.st_mode); |
| 310 info->is_symbolic_link = S_ISLNK(file_info.st_mode); | 324 info->is_symbolic_link = S_ISLNK(file_info.st_mode); |
| 311 info->size = file_info.st_size; | 325 info->size = file_info.st_size; |
| 312 info->last_modified = base::Time::FromTimeT(file_info.st_mtime); | 326 info->last_modified = base::Time::FromTimeT(file_info.st_mtime); |
| 313 info->last_accessed = base::Time::FromTimeT(file_info.st_atime); | 327 info->last_accessed = base::Time::FromTimeT(file_info.st_atime); |
| 314 info->creation_time = base::Time::FromTimeT(file_info.st_ctime); | 328 info->creation_time = base::Time::FromTimeT(file_info.st_ctime); |
| 315 return true; | 329 return true; |
| 316 } | 330 } |
| 317 | 331 |
| 318 PlatformFileError ErrnoToPlatformFileError(int saved_errno) { | 332 PlatformFileError ErrnoToPlatformFileError(int saved_errno) { |
| 319 switch (saved_errno) { | 333 switch (saved_errno) { |
| 320 case EACCES: | 334 case EACCES: |
| 321 case EISDIR: | 335 case EISDIR: |
| 322 case EROFS: | 336 case EROFS: |
| 323 case EPERM: | 337 case EPERM: |
| 324 return PLATFORM_FILE_ERROR_ACCESS_DENIED; | 338 return PLATFORM_FILE_ERROR_ACCESS_DENIED; |
| 339 #if !defined(OS_NACL) // ETXTBSY not defined by NaCl. |
| 325 case ETXTBSY: | 340 case ETXTBSY: |
| 326 return PLATFORM_FILE_ERROR_IN_USE; | 341 return PLATFORM_FILE_ERROR_IN_USE; |
| 342 #endif |
| 327 case EEXIST: | 343 case EEXIST: |
| 328 return PLATFORM_FILE_ERROR_EXISTS; | 344 return PLATFORM_FILE_ERROR_EXISTS; |
| 329 case ENOENT: | 345 case ENOENT: |
| 330 return PLATFORM_FILE_ERROR_NOT_FOUND; | 346 return PLATFORM_FILE_ERROR_NOT_FOUND; |
| 331 case EMFILE: | 347 case EMFILE: |
| 332 return PLATFORM_FILE_ERROR_TOO_MANY_OPENED; | 348 return PLATFORM_FILE_ERROR_TOO_MANY_OPENED; |
| 333 case ENOMEM: | 349 case ENOMEM: |
| 334 return PLATFORM_FILE_ERROR_NO_MEMORY; | 350 return PLATFORM_FILE_ERROR_NO_MEMORY; |
| 335 case ENOSPC: | 351 case ENOSPC: |
| 336 return PLATFORM_FILE_ERROR_NO_SPACE; | 352 return PLATFORM_FILE_ERROR_NO_SPACE; |
| 337 case ENOTDIR: | 353 case ENOTDIR: |
| 338 return PLATFORM_FILE_ERROR_NOT_A_DIRECTORY; | 354 return PLATFORM_FILE_ERROR_NOT_A_DIRECTORY; |
| 339 default: | 355 default: |
| 340 #if !defined(OS_NACL) // NaCl build has no metrics code. | 356 #if !defined(OS_NACL) // NaCl build has no metrics code. |
| 341 UMA_HISTOGRAM_SPARSE_SLOWLY("PlatformFile.UnknownErrors.Posix", | 357 UMA_HISTOGRAM_SPARSE_SLOWLY("PlatformFile.UnknownErrors.Posix", |
| 342 saved_errno); | 358 saved_errno); |
| 343 #endif | 359 #endif |
| 344 return PLATFORM_FILE_ERROR_FAILED; | 360 return PLATFORM_FILE_ERROR_FAILED; |
| 345 } | 361 } |
| 346 } | 362 } |
| 347 | 363 |
| 348 } // namespace base | 364 } // namespace base |
| OLD | NEW |