[safe browsing] Switch to independent cache lifetimes for gethash items.
[chromium-blink-merge.git] / base / file_util_posix.cc
blob9270e8a209416af2f76f8b4b4b17af2f7ac93bcf
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
3 // found in the LICENSE file.
5 #include "base/file_util.h"
7 #include <dirent.h>
8 #include <errno.h>
9 #include <fcntl.h>
10 #include <libgen.h>
11 #include <limits.h>
12 #include <stdio.h>
13 #include <stdlib.h>
14 #include <string.h>
15 #include <sys/errno.h>
16 #include <sys/mman.h>
17 #include <sys/param.h>
18 #include <sys/stat.h>
19 #include <sys/time.h>
20 #include <sys/types.h>
21 #include <time.h>
22 #include <unistd.h>
24 #if defined(OS_MACOSX)
25 #include <AvailabilityMacros.h>
26 #include "base/mac/foundation_util.h"
27 #elif !defined(OS_CHROMEOS) && defined(USE_GLIB)
28 #include <glib.h> // for g_get_home_dir()
29 #endif
31 #include <fstream>
33 #include "base/basictypes.h"
34 #include "base/files/file_enumerator.h"
35 #include "base/files/file_path.h"
36 #include "base/files/scoped_file.h"
37 #include "base/logging.h"
38 #include "base/memory/scoped_ptr.h"
39 #include "base/memory/singleton.h"
40 #include "base/path_service.h"
41 #include "base/posix/eintr_wrapper.h"
42 #include "base/stl_util.h"
43 #include "base/strings/string_util.h"
44 #include "base/strings/stringprintf.h"
45 #include "base/strings/sys_string_conversions.h"
46 #include "base/strings/utf_string_conversions.h"
47 #include "base/sys_info.h"
48 #include "base/threading/thread_restrictions.h"
49 #include "base/time/time.h"
51 #if defined(OS_ANDROID)
52 #include "base/android/content_uri_utils.h"
53 #include "base/os_compat_android.h"
54 #endif
56 #if !defined(OS_IOS)
57 #include <grp.h>
58 #endif
60 namespace base {
62 namespace {
64 #if defined(OS_BSD) || defined(OS_MACOSX) || defined(OS_NACL)
65 static int CallStat(const char *path, stat_wrapper_t *sb) {
66 ThreadRestrictions::AssertIOAllowed();
67 return stat(path, sb);
69 static int CallLstat(const char *path, stat_wrapper_t *sb) {
70 ThreadRestrictions::AssertIOAllowed();
71 return lstat(path, sb);
73 #else // defined(OS_BSD) || defined(OS_MACOSX) || defined(OS_NACL)
74 static int CallStat(const char *path, stat_wrapper_t *sb) {
75 ThreadRestrictions::AssertIOAllowed();
76 return stat64(path, sb);
78 static int CallLstat(const char *path, stat_wrapper_t *sb) {
79 ThreadRestrictions::AssertIOAllowed();
80 return lstat64(path, sb);
82 #endif // !(defined(OS_BSD) || defined(OS_MACOSX) || defined(OS_NACL))
84 // Helper for NormalizeFilePath(), defined below.
85 bool RealPath(const FilePath& path, FilePath* real_path) {
86 ThreadRestrictions::AssertIOAllowed(); // For realpath().
87 FilePath::CharType buf[PATH_MAX];
88 if (!realpath(path.value().c_str(), buf))
89 return false;
91 *real_path = FilePath(buf);
92 return true;
95 // Helper for VerifyPathControlledByUser.
96 bool VerifySpecificPathControlledByUser(const FilePath& path,
97 uid_t owner_uid,
98 const std::set<gid_t>& group_gids) {
99 stat_wrapper_t stat_info;
100 if (CallLstat(path.value().c_str(), &stat_info) != 0) {
101 DPLOG(ERROR) << "Failed to get information on path "
102 << path.value();
103 return false;
106 if (S_ISLNK(stat_info.st_mode)) {
107 DLOG(ERROR) << "Path " << path.value()
108 << " is a symbolic link.";
109 return false;
112 if (stat_info.st_uid != owner_uid) {
113 DLOG(ERROR) << "Path " << path.value()
114 << " is owned by the wrong user.";
115 return false;
118 if ((stat_info.st_mode & S_IWGRP) &&
119 !ContainsKey(group_gids, stat_info.st_gid)) {
120 DLOG(ERROR) << "Path " << path.value()
121 << " is writable by an unprivileged group.";
122 return false;
125 if (stat_info.st_mode & S_IWOTH) {
126 DLOG(ERROR) << "Path " << path.value()
127 << " is writable by any user.";
128 return false;
131 return true;
134 std::string TempFileName() {
135 #if defined(OS_MACOSX)
136 return StringPrintf(".%s.XXXXXX", base::mac::BaseBundleID());
137 #endif
139 #if defined(GOOGLE_CHROME_BUILD)
140 return std::string(".com.google.Chrome.XXXXXX");
141 #else
142 return std::string(".org.chromium.Chromium.XXXXXX");
143 #endif
146 // Creates and opens a temporary file in |directory|, returning the
147 // file descriptor. |path| is set to the temporary file path.
148 // This function does NOT unlink() the file.
149 int CreateAndOpenFdForTemporaryFile(FilePath directory, FilePath* path) {
150 ThreadRestrictions::AssertIOAllowed(); // For call to mkstemp().
151 *path = directory.Append(base::TempFileName());
152 const std::string& tmpdir_string = path->value();
153 // this should be OK since mkstemp just replaces characters in place
154 char* buffer = const_cast<char*>(tmpdir_string.c_str());
156 return HANDLE_EINTR(mkstemp(buffer));
159 #if defined(OS_LINUX)
160 // Determine if /dev/shm files can be mapped and then mprotect'd PROT_EXEC.
161 // This depends on the mount options used for /dev/shm, which vary among
162 // different Linux distributions and possibly local configuration. It also
163 // depends on details of kernel--ChromeOS uses the noexec option for /dev/shm
164 // but its kernel allows mprotect with PROT_EXEC anyway.
165 bool DetermineDevShmExecutable() {
166 bool result = false;
167 FilePath path;
169 ScopedFD fd(CreateAndOpenFdForTemporaryFile(FilePath("/dev/shm"), &path));
170 if (fd.is_valid()) {
171 DeleteFile(path, false);
172 long sysconf_result = sysconf(_SC_PAGESIZE);
173 CHECK_GE(sysconf_result, 0);
174 size_t pagesize = static_cast<size_t>(sysconf_result);
175 CHECK_GE(sizeof(pagesize), sizeof(sysconf_result));
176 void* mapping = mmap(NULL, pagesize, PROT_READ, MAP_SHARED, fd.get(), 0);
177 if (mapping != MAP_FAILED) {
178 if (mprotect(mapping, pagesize, PROT_READ | PROT_EXEC) == 0)
179 result = true;
180 munmap(mapping, pagesize);
183 return result;
185 #endif // defined(OS_LINUX)
187 } // namespace
189 FilePath MakeAbsoluteFilePath(const FilePath& input) {
190 ThreadRestrictions::AssertIOAllowed();
191 char full_path[PATH_MAX];
192 if (realpath(input.value().c_str(), full_path) == NULL)
193 return FilePath();
194 return FilePath(full_path);
197 // TODO(erikkay): The Windows version of this accepts paths like "foo/bar/*"
198 // which works both with and without the recursive flag. I'm not sure we need
199 // that functionality. If not, remove from file_util_win.cc, otherwise add it
200 // here.
201 bool DeleteFile(const FilePath& path, bool recursive) {
202 ThreadRestrictions::AssertIOAllowed();
203 const char* path_str = path.value().c_str();
204 stat_wrapper_t file_info;
205 int test = CallLstat(path_str, &file_info);
206 if (test != 0) {
207 // The Windows version defines this condition as success.
208 bool ret = (errno == ENOENT || errno == ENOTDIR);
209 return ret;
211 if (!S_ISDIR(file_info.st_mode))
212 return (unlink(path_str) == 0);
213 if (!recursive)
214 return (rmdir(path_str) == 0);
216 bool success = true;
217 std::stack<std::string> directories;
218 directories.push(path.value());
219 FileEnumerator traversal(path, true,
220 FileEnumerator::FILES | FileEnumerator::DIRECTORIES |
221 FileEnumerator::SHOW_SYM_LINKS);
222 for (FilePath current = traversal.Next(); success && !current.empty();
223 current = traversal.Next()) {
224 if (traversal.GetInfo().IsDirectory())
225 directories.push(current.value());
226 else
227 success = (unlink(current.value().c_str()) == 0);
230 while (success && !directories.empty()) {
231 FilePath dir = FilePath(directories.top());
232 directories.pop();
233 success = (rmdir(dir.value().c_str()) == 0);
235 return success;
238 bool ReplaceFile(const FilePath& from_path,
239 const FilePath& to_path,
240 File::Error* error) {
241 ThreadRestrictions::AssertIOAllowed();
242 if (rename(from_path.value().c_str(), to_path.value().c_str()) == 0)
243 return true;
244 if (error)
245 *error = File::OSErrorToFileError(errno);
246 return false;
249 bool CopyDirectory(const FilePath& from_path,
250 const FilePath& to_path,
251 bool recursive) {
252 ThreadRestrictions::AssertIOAllowed();
253 // Some old callers of CopyDirectory want it to support wildcards.
254 // After some discussion, we decided to fix those callers.
255 // Break loudly here if anyone tries to do this.
256 DCHECK(to_path.value().find('*') == std::string::npos);
257 DCHECK(from_path.value().find('*') == std::string::npos);
259 if (from_path.value().size() >= PATH_MAX) {
260 return false;
263 // This function does not properly handle destinations within the source
264 FilePath real_to_path = to_path;
265 if (PathExists(real_to_path)) {
266 real_to_path = MakeAbsoluteFilePath(real_to_path);
267 if (real_to_path.empty())
268 return false;
269 } else {
270 real_to_path = MakeAbsoluteFilePath(real_to_path.DirName());
271 if (real_to_path.empty())
272 return false;
274 FilePath real_from_path = MakeAbsoluteFilePath(from_path);
275 if (real_from_path.empty())
276 return false;
277 if (real_to_path.value().size() >= real_from_path.value().size() &&
278 real_to_path.value().compare(0, real_from_path.value().size(),
279 real_from_path.value()) == 0) {
280 return false;
283 int traverse_type = FileEnumerator::FILES | FileEnumerator::SHOW_SYM_LINKS;
284 if (recursive)
285 traverse_type |= FileEnumerator::DIRECTORIES;
286 FileEnumerator traversal(from_path, recursive, traverse_type);
288 // We have to mimic windows behavior here. |to_path| may not exist yet,
289 // start the loop with |to_path|.
290 struct stat from_stat;
291 FilePath current = from_path;
292 if (stat(from_path.value().c_str(), &from_stat) < 0) {
293 DLOG(ERROR) << "CopyDirectory() couldn't stat source directory: "
294 << from_path.value() << " errno = " << errno;
295 return false;
297 struct stat to_path_stat;
298 FilePath from_path_base = from_path;
299 if (recursive && stat(to_path.value().c_str(), &to_path_stat) == 0 &&
300 S_ISDIR(to_path_stat.st_mode)) {
301 // If the destination already exists and is a directory, then the
302 // top level of source needs to be copied.
303 from_path_base = from_path.DirName();
306 // The Windows version of this function assumes that non-recursive calls
307 // will always have a directory for from_path.
308 // TODO(maruel): This is not necessary anymore.
309 DCHECK(recursive || S_ISDIR(from_stat.st_mode));
311 bool success = true;
312 while (success && !current.empty()) {
313 // current is the source path, including from_path, so append
314 // the suffix after from_path to to_path to create the target_path.
315 FilePath target_path(to_path);
316 if (from_path_base != current) {
317 if (!from_path_base.AppendRelativePath(current, &target_path)) {
318 success = false;
319 break;
323 if (S_ISDIR(from_stat.st_mode)) {
324 if (mkdir(target_path.value().c_str(), from_stat.st_mode & 01777) != 0 &&
325 errno != EEXIST) {
326 DLOG(ERROR) << "CopyDirectory() couldn't create directory: "
327 << target_path.value() << " errno = " << errno;
328 success = false;
330 } else if (S_ISREG(from_stat.st_mode)) {
331 if (!CopyFile(current, target_path)) {
332 DLOG(ERROR) << "CopyDirectory() couldn't create file: "
333 << target_path.value();
334 success = false;
336 } else {
337 DLOG(WARNING) << "CopyDirectory() skipping non-regular file: "
338 << current.value();
341 current = traversal.Next();
342 if (!current.empty())
343 from_stat = traversal.GetInfo().stat();
346 return success;
349 bool PathExists(const FilePath& path) {
350 ThreadRestrictions::AssertIOAllowed();
351 #if defined(OS_ANDROID)
352 if (path.IsContentUri()) {
353 return ContentUriExists(path);
355 #endif
356 return access(path.value().c_str(), F_OK) == 0;
359 bool PathIsWritable(const FilePath& path) {
360 ThreadRestrictions::AssertIOAllowed();
361 return access(path.value().c_str(), W_OK) == 0;
364 bool DirectoryExists(const FilePath& path) {
365 ThreadRestrictions::AssertIOAllowed();
366 stat_wrapper_t file_info;
367 if (CallStat(path.value().c_str(), &file_info) == 0)
368 return S_ISDIR(file_info.st_mode);
369 return false;
372 bool ReadFromFD(int fd, char* buffer, size_t bytes) {
373 size_t total_read = 0;
374 while (total_read < bytes) {
375 ssize_t bytes_read =
376 HANDLE_EINTR(read(fd, buffer + total_read, bytes - total_read));
377 if (bytes_read <= 0)
378 break;
379 total_read += bytes_read;
381 return total_read == bytes;
384 bool CreateSymbolicLink(const FilePath& target_path,
385 const FilePath& symlink_path) {
386 DCHECK(!symlink_path.empty());
387 DCHECK(!target_path.empty());
388 return ::symlink(target_path.value().c_str(),
389 symlink_path.value().c_str()) != -1;
392 bool ReadSymbolicLink(const FilePath& symlink_path, FilePath* target_path) {
393 DCHECK(!symlink_path.empty());
394 DCHECK(target_path);
395 char buf[PATH_MAX];
396 ssize_t count = ::readlink(symlink_path.value().c_str(), buf, arraysize(buf));
398 if (count <= 0) {
399 target_path->clear();
400 return false;
403 *target_path = FilePath(FilePath::StringType(buf, count));
404 return true;
407 bool GetPosixFilePermissions(const FilePath& path, int* mode) {
408 ThreadRestrictions::AssertIOAllowed();
409 DCHECK(mode);
411 stat_wrapper_t file_info;
412 // Uses stat(), because on symbolic link, lstat() does not return valid
413 // permission bits in st_mode
414 if (CallStat(path.value().c_str(), &file_info) != 0)
415 return false;
417 *mode = file_info.st_mode & FILE_PERMISSION_MASK;
418 return true;
421 bool SetPosixFilePermissions(const FilePath& path,
422 int mode) {
423 ThreadRestrictions::AssertIOAllowed();
424 DCHECK((mode & ~FILE_PERMISSION_MASK) == 0);
426 // Calls stat() so that we can preserve the higher bits like S_ISGID.
427 stat_wrapper_t stat_buf;
428 if (CallStat(path.value().c_str(), &stat_buf) != 0)
429 return false;
431 // Clears the existing permission bits, and adds the new ones.
432 mode_t updated_mode_bits = stat_buf.st_mode & ~FILE_PERMISSION_MASK;
433 updated_mode_bits |= mode & FILE_PERMISSION_MASK;
435 if (HANDLE_EINTR(chmod(path.value().c_str(), updated_mode_bits)) != 0)
436 return false;
438 return true;
441 #if !defined(OS_MACOSX)
442 // This is implemented in file_util_mac.mm for Mac.
443 bool GetTempDir(FilePath* path) {
444 const char* tmp = getenv("TMPDIR");
445 if (tmp) {
446 *path = FilePath(tmp);
447 } else {
448 #if defined(OS_ANDROID)
449 return PathService::Get(base::DIR_CACHE, path);
450 #else
451 *path = FilePath("/tmp");
452 #endif
454 return true;
456 #endif // !defined(OS_MACOSX)
458 #if !defined(OS_MACOSX) // Mac implementation is in file_util_mac.mm.
459 FilePath GetHomeDir() {
460 #if defined(OS_CHROMEOS)
461 if (SysInfo::IsRunningOnChromeOS())
462 return FilePath("/home/chronos/user");
463 #endif
465 const char* home_dir = getenv("HOME");
466 if (home_dir && home_dir[0])
467 return FilePath(home_dir);
469 #if defined(OS_ANDROID)
470 DLOG(WARNING) << "OS_ANDROID: Home directory lookup not yet implemented.";
471 #elif defined(USE_GLIB) && !defined(OS_CHROMEOS)
472 // g_get_home_dir calls getpwent, which can fall through to LDAP calls so
473 // this may do I/O. However, it should be rare that $HOME is not defined and
474 // this is typically called from the path service which has no threading
475 // restrictions. The path service will cache the result which limits the
476 // badness of blocking on I/O. As a result, we don't have a thread
477 // restriction here.
478 home_dir = g_get_home_dir();
479 if (home_dir && home_dir[0])
480 return FilePath(home_dir);
481 #endif
483 FilePath rv;
484 if (GetTempDir(&rv))
485 return rv;
487 // Last resort.
488 return FilePath("/tmp");
490 #endif // !defined(OS_MACOSX)
492 bool CreateTemporaryFile(FilePath* path) {
493 ThreadRestrictions::AssertIOAllowed(); // For call to close().
494 FilePath directory;
495 if (!GetTempDir(&directory))
496 return false;
497 int fd = CreateAndOpenFdForTemporaryFile(directory, path);
498 if (fd < 0)
499 return false;
500 close(fd);
501 return true;
504 FILE* CreateAndOpenTemporaryFileInDir(const FilePath& dir, FilePath* path) {
505 int fd = CreateAndOpenFdForTemporaryFile(dir, path);
506 if (fd < 0)
507 return NULL;
509 FILE* file = fdopen(fd, "a+");
510 if (!file)
511 close(fd);
512 return file;
515 bool CreateTemporaryFileInDir(const FilePath& dir, FilePath* temp_file) {
516 ThreadRestrictions::AssertIOAllowed(); // For call to close().
517 int fd = CreateAndOpenFdForTemporaryFile(dir, temp_file);
518 return ((fd >= 0) && !IGNORE_EINTR(close(fd)));
521 static bool CreateTemporaryDirInDirImpl(const FilePath& base_dir,
522 const FilePath::StringType& name_tmpl,
523 FilePath* new_dir) {
524 ThreadRestrictions::AssertIOAllowed(); // For call to mkdtemp().
525 DCHECK(name_tmpl.find("XXXXXX") != FilePath::StringType::npos)
526 << "Directory name template must contain \"XXXXXX\".";
528 FilePath sub_dir = base_dir.Append(name_tmpl);
529 std::string sub_dir_string = sub_dir.value();
531 // this should be OK since mkdtemp just replaces characters in place
532 char* buffer = const_cast<char*>(sub_dir_string.c_str());
533 char* dtemp = mkdtemp(buffer);
534 if (!dtemp) {
535 DPLOG(ERROR) << "mkdtemp";
536 return false;
538 *new_dir = FilePath(dtemp);
539 return true;
542 bool CreateTemporaryDirInDir(const FilePath& base_dir,
543 const FilePath::StringType& prefix,
544 FilePath* new_dir) {
545 FilePath::StringType mkdtemp_template = prefix;
546 mkdtemp_template.append(FILE_PATH_LITERAL("XXXXXX"));
547 return CreateTemporaryDirInDirImpl(base_dir, mkdtemp_template, new_dir);
550 bool CreateNewTempDirectory(const FilePath::StringType& prefix,
551 FilePath* new_temp_path) {
552 FilePath tmpdir;
553 if (!GetTempDir(&tmpdir))
554 return false;
556 return CreateTemporaryDirInDirImpl(tmpdir, TempFileName(), new_temp_path);
559 bool CreateDirectoryAndGetError(const FilePath& full_path,
560 File::Error* error) {
561 ThreadRestrictions::AssertIOAllowed(); // For call to mkdir().
562 std::vector<FilePath> subpaths;
564 // Collect a list of all parent directories.
565 FilePath last_path = full_path;
566 subpaths.push_back(full_path);
567 for (FilePath path = full_path.DirName();
568 path.value() != last_path.value(); path = path.DirName()) {
569 subpaths.push_back(path);
570 last_path = path;
573 // Iterate through the parents and create the missing ones.
574 for (std::vector<FilePath>::reverse_iterator i = subpaths.rbegin();
575 i != subpaths.rend(); ++i) {
576 if (DirectoryExists(*i))
577 continue;
578 if (mkdir(i->value().c_str(), 0700) == 0)
579 continue;
580 // Mkdir failed, but it might have failed with EEXIST, or some other error
581 // due to the the directory appearing out of thin air. This can occur if
582 // two processes are trying to create the same file system tree at the same
583 // time. Check to see if it exists and make sure it is a directory.
584 int saved_errno = errno;
585 if (!DirectoryExists(*i)) {
586 if (error)
587 *error = File::OSErrorToFileError(saved_errno);
588 return false;
591 return true;
594 bool NormalizeFilePath(const FilePath& path, FilePath* normalized_path) {
595 FilePath real_path_result;
596 if (!RealPath(path, &real_path_result))
597 return false;
599 // To be consistant with windows, fail if |real_path_result| is a
600 // directory.
601 stat_wrapper_t file_info;
602 if (CallStat(real_path_result.value().c_str(), &file_info) != 0 ||
603 S_ISDIR(file_info.st_mode))
604 return false;
606 *normalized_path = real_path_result;
607 return true;
610 // TODO(rkc): Refactor GetFileInfo and FileEnumerator to handle symlinks
611 // correctly. http://code.google.com/p/chromium-os/issues/detail?id=15948
612 bool IsLink(const FilePath& file_path) {
613 stat_wrapper_t st;
614 // If we can't lstat the file, it's safe to assume that the file won't at
615 // least be a 'followable' link.
616 if (CallLstat(file_path.value().c_str(), &st) != 0)
617 return false;
619 if (S_ISLNK(st.st_mode))
620 return true;
621 else
622 return false;
625 bool GetFileInfo(const FilePath& file_path, File::Info* results) {
626 stat_wrapper_t file_info;
627 #if defined(OS_ANDROID)
628 if (file_path.IsContentUri()) {
629 File file = OpenContentUriForRead(file_path);
630 if (!file.IsValid())
631 return false;
632 return file.GetInfo(results);
633 } else {
634 #endif // defined(OS_ANDROID)
635 if (CallStat(file_path.value().c_str(), &file_info) != 0)
636 return false;
637 #if defined(OS_ANDROID)
639 #endif // defined(OS_ANDROID)
641 results->FromStat(file_info);
642 return true;
645 FILE* OpenFile(const FilePath& filename, const char* mode) {
646 ThreadRestrictions::AssertIOAllowed();
647 FILE* result = NULL;
648 do {
649 result = fopen(filename.value().c_str(), mode);
650 } while (!result && errno == EINTR);
651 return result;
654 int ReadFile(const FilePath& filename, char* data, int max_size) {
655 ThreadRestrictions::AssertIOAllowed();
656 int fd = HANDLE_EINTR(open(filename.value().c_str(), O_RDONLY));
657 if (fd < 0)
658 return -1;
660 ssize_t bytes_read = HANDLE_EINTR(read(fd, data, max_size));
661 if (IGNORE_EINTR(close(fd)) < 0)
662 return -1;
663 return bytes_read;
666 int WriteFile(const FilePath& filename, const char* data, int size) {
667 ThreadRestrictions::AssertIOAllowed();
668 int fd = HANDLE_EINTR(creat(filename.value().c_str(), 0666));
669 if (fd < 0)
670 return -1;
672 int bytes_written = WriteFileDescriptor(fd, data, size);
673 if (IGNORE_EINTR(close(fd)) < 0)
674 return -1;
675 return bytes_written;
678 int WriteFileDescriptor(const int fd, const char* data, int size) {
679 // Allow for partial writes.
680 ssize_t bytes_written_total = 0;
681 for (ssize_t bytes_written_partial = 0; bytes_written_total < size;
682 bytes_written_total += bytes_written_partial) {
683 bytes_written_partial =
684 HANDLE_EINTR(write(fd, data + bytes_written_total,
685 size - bytes_written_total));
686 if (bytes_written_partial < 0)
687 return -1;
690 return bytes_written_total;
693 int AppendToFile(const FilePath& filename, const char* data, int size) {
694 ThreadRestrictions::AssertIOAllowed();
695 int fd = HANDLE_EINTR(open(filename.value().c_str(), O_WRONLY | O_APPEND));
696 if (fd < 0)
697 return -1;
699 int bytes_written = WriteFileDescriptor(fd, data, size);
700 if (IGNORE_EINTR(close(fd)) < 0)
701 return -1;
702 return bytes_written;
705 // Gets the current working directory for the process.
706 bool GetCurrentDirectory(FilePath* dir) {
707 // getcwd can return ENOENT, which implies it checks against the disk.
708 ThreadRestrictions::AssertIOAllowed();
710 char system_buffer[PATH_MAX] = "";
711 if (!getcwd(system_buffer, sizeof(system_buffer))) {
712 NOTREACHED();
713 return false;
715 *dir = FilePath(system_buffer);
716 return true;
719 // Sets the current working directory for the process.
720 bool SetCurrentDirectory(const FilePath& path) {
721 ThreadRestrictions::AssertIOAllowed();
722 int ret = chdir(path.value().c_str());
723 return !ret;
726 bool VerifyPathControlledByUser(const FilePath& base,
727 const FilePath& path,
728 uid_t owner_uid,
729 const std::set<gid_t>& group_gids) {
730 if (base != path && !base.IsParent(path)) {
731 DLOG(ERROR) << "|base| must be a subdirectory of |path|. base = \""
732 << base.value() << "\", path = \"" << path.value() << "\"";
733 return false;
736 std::vector<FilePath::StringType> base_components;
737 std::vector<FilePath::StringType> path_components;
739 base.GetComponents(&base_components);
740 path.GetComponents(&path_components);
742 std::vector<FilePath::StringType>::const_iterator ib, ip;
743 for (ib = base_components.begin(), ip = path_components.begin();
744 ib != base_components.end(); ++ib, ++ip) {
745 // |base| must be a subpath of |path|, so all components should match.
746 // If these CHECKs fail, look at the test that base is a parent of
747 // path at the top of this function.
748 DCHECK(ip != path_components.end());
749 DCHECK(*ip == *ib);
752 FilePath current_path = base;
753 if (!VerifySpecificPathControlledByUser(current_path, owner_uid, group_gids))
754 return false;
756 for (; ip != path_components.end(); ++ip) {
757 current_path = current_path.Append(*ip);
758 if (!VerifySpecificPathControlledByUser(
759 current_path, owner_uid, group_gids))
760 return false;
762 return true;
765 #if defined(OS_MACOSX) && !defined(OS_IOS)
766 bool VerifyPathControlledByAdmin(const FilePath& path) {
767 const unsigned kRootUid = 0;
768 const FilePath kFileSystemRoot("/");
770 // The name of the administrator group on mac os.
771 const char* const kAdminGroupNames[] = {
772 "admin",
773 "wheel"
776 // Reading the groups database may touch the file system.
777 ThreadRestrictions::AssertIOAllowed();
779 std::set<gid_t> allowed_group_ids;
780 for (int i = 0, ie = arraysize(kAdminGroupNames); i < ie; ++i) {
781 struct group *group_record = getgrnam(kAdminGroupNames[i]);
782 if (!group_record) {
783 DPLOG(ERROR) << "Could not get the group ID of group \""
784 << kAdminGroupNames[i] << "\".";
785 continue;
788 allowed_group_ids.insert(group_record->gr_gid);
791 return VerifyPathControlledByUser(
792 kFileSystemRoot, path, kRootUid, allowed_group_ids);
794 #endif // defined(OS_MACOSX) && !defined(OS_IOS)
796 int GetMaximumPathComponentLength(const FilePath& path) {
797 ThreadRestrictions::AssertIOAllowed();
798 return pathconf(path.value().c_str(), _PC_NAME_MAX);
801 #if !defined(OS_ANDROID)
802 // This is implemented in file_util_android.cc for that platform.
803 bool GetShmemTempDir(bool executable, FilePath* path) {
804 #if defined(OS_LINUX)
805 bool use_dev_shm = true;
806 if (executable) {
807 static const bool s_dev_shm_executable = DetermineDevShmExecutable();
808 use_dev_shm = s_dev_shm_executable;
810 if (use_dev_shm) {
811 *path = FilePath("/dev/shm");
812 return true;
814 #endif
815 return GetTempDir(path);
817 #endif // !defined(OS_ANDROID)
819 // -----------------------------------------------------------------------------
821 namespace internal {
823 bool MoveUnsafe(const FilePath& from_path, const FilePath& to_path) {
824 ThreadRestrictions::AssertIOAllowed();
825 // Windows compatibility: if to_path exists, from_path and to_path
826 // must be the same type, either both files, or both directories.
827 stat_wrapper_t to_file_info;
828 if (CallStat(to_path.value().c_str(), &to_file_info) == 0) {
829 stat_wrapper_t from_file_info;
830 if (CallStat(from_path.value().c_str(), &from_file_info) == 0) {
831 if (S_ISDIR(to_file_info.st_mode) != S_ISDIR(from_file_info.st_mode))
832 return false;
833 } else {
834 return false;
838 if (rename(from_path.value().c_str(), to_path.value().c_str()) == 0)
839 return true;
841 if (!CopyDirectory(from_path, to_path, true))
842 return false;
844 DeleteFile(from_path, true);
845 return true;
848 #if !defined(OS_MACOSX)
849 // Mac has its own implementation, this is for all other Posix systems.
850 bool CopyFileUnsafe(const FilePath& from_path, const FilePath& to_path) {
851 ThreadRestrictions::AssertIOAllowed();
852 int infile = HANDLE_EINTR(open(from_path.value().c_str(), O_RDONLY));
853 if (infile < 0)
854 return false;
856 int outfile = HANDLE_EINTR(creat(to_path.value().c_str(), 0666));
857 if (outfile < 0) {
858 close(infile);
859 return false;
862 const size_t kBufferSize = 32768;
863 std::vector<char> buffer(kBufferSize);
864 bool result = true;
866 while (result) {
867 ssize_t bytes_read = HANDLE_EINTR(read(infile, &buffer[0], buffer.size()));
868 if (bytes_read < 0) {
869 result = false;
870 break;
872 if (bytes_read == 0)
873 break;
874 // Allow for partial writes
875 ssize_t bytes_written_per_read = 0;
876 do {
877 ssize_t bytes_written_partial = HANDLE_EINTR(write(
878 outfile,
879 &buffer[bytes_written_per_read],
880 bytes_read - bytes_written_per_read));
881 if (bytes_written_partial < 0) {
882 result = false;
883 break;
885 bytes_written_per_read += bytes_written_partial;
886 } while (bytes_written_per_read < bytes_read);
889 if (IGNORE_EINTR(close(infile)) < 0)
890 result = false;
891 if (IGNORE_EINTR(close(outfile)) < 0)
892 result = false;
894 return result;
896 #endif // !defined(OS_MACOSX)
898 } // namespace internal
899 } // namespace base