| // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | |
| // for details. All rights reserved. Use of this source code is governed by a | |
| // BSD-style license that can be found in the LICENSE file. | |
| #include "platform/globals.h" | |
| #if defined(DART_HOST_OS_FUCHSIA) | |
| #include "bin/file.h" | |
| #include <errno.h> | |
| #include <fcntl.h> | |
| #include <fuchsia/io/cpp/fidl.h> | |
| #include <lib/fdio/directory.h> | |
| #include <lib/fdio/fdio.h> | |
| #include <lib/fdio/namespace.h> | |
| #include <libgen.h> | |
| #include <sys/mman.h> | |
| #include <sys/stat.h> | |
| #include <sys/types.h> | |
| #include <unistd.h> | |
| #include <utime.h> | |
| #include "bin/builtin.h" | |
| #include "bin/fdutils.h" | |
| #include "bin/namespace.h" | |
| #include "platform/signal_blocker.h" | |
| #include "platform/syslog.h" | |
| #include "platform/utils.h" | |
| namespace dart { | |
| namespace bin { | |
| class FileHandle { | |
| public: | |
| explicit FileHandle(int fd) : fd_(fd) {} | |
| ~FileHandle() {} | |
| int fd() const { return fd_; } | |
| void set_fd(int fd) { fd_ = fd; } | |
| private: | |
| int fd_; | |
| DISALLOW_COPY_AND_ASSIGN(FileHandle); | |
| }; | |
| File::~File() { | |
| if (!IsClosed() && (handle_->fd() != STDOUT_FILENO) && | |
| (handle_->fd() != STDERR_FILENO)) { | |
| Close(); | |
| } | |
| delete handle_; | |
| } | |
| void File::Close() { | |
| ASSERT(handle_->fd() >= 0); | |
| if (handle_->fd() == STDOUT_FILENO) { | |
| // If stdout, redirect fd to Fuchsia's equivalent of /dev/null. | |
| auto* null_fdio = fdio_null_create(); | |
| ASSERT(null_fdio != nullptr); | |
| int null_fd = NO_RETRY_EXPECTED(fdio_bind_to_fd(null_fdio, -1, 0)); | |
| ASSERT(null_fd >= 0); | |
| VOID_NO_RETRY_EXPECTED(dup2(null_fd, handle_->fd())); | |
| VOID_NO_RETRY_EXPECTED(close(null_fd)); | |
| } else { | |
| int err = NO_RETRY_EXPECTED(close(handle_->fd())); | |
| if (err != 0) { | |
| const int kBufferSize = 1024; | |
| char error_buf[kBufferSize]; | |
| Syslog::PrintErr("%s\n", Utils::StrError(errno, error_buf, kBufferSize)); | |
| } | |
| } | |
| handle_->set_fd(kClosedFd); | |
| } | |
| intptr_t File::GetFD() { | |
| return handle_->fd(); | |
| } | |
| bool File::IsClosed() { | |
| return handle_->fd() == kClosedFd; | |
| } | |
| MappedMemory* File::Map(MapType type, | |
| int64_t position, | |
| int64_t length, | |
| void* start) { | |
| ASSERT(handle_->fd() >= 0); | |
| ASSERT(length > 0); | |
| void* hint = nullptr; | |
| int prot = PROT_NONE; | |
| int flags = MAP_PRIVATE; | |
| switch (type) { | |
| case kReadOnly: | |
| prot = PROT_READ; | |
| break; | |
| case kReadExecute: | |
| // Try to allocate near the VM's binary. | |
| hint = reinterpret_cast<void*>(&Dart_Initialize); | |
| prot = PROT_READ | PROT_EXEC; | |
| break; | |
| case kReadWrite: | |
| prot = PROT_READ | PROT_WRITE; | |
| break; | |
| } | |
| if (start != nullptr) { | |
| hint = start; | |
| flags |= MAP_FIXED; | |
| } | |
| void* addr = mmap(hint, length, prot, flags, handle_->fd(), position); | |
| if (addr == MAP_FAILED) { | |
| return nullptr; | |
| } | |
| return new MappedMemory(addr, length, /*should_unmap=*/start == nullptr); | |
| } | |
| void MappedMemory::Unmap() { | |
| int result = munmap(address_, size_); | |
| ASSERT(result == 0); | |
| address_ = nullptr; | |
| size_ = 0; | |
| } | |
| int64_t File::Read(void* buffer, int64_t num_bytes) { | |
| ASSERT(handle_->fd() >= 0); | |
| return NO_RETRY_EXPECTED(read(handle_->fd(), buffer, num_bytes)); | |
| } | |
| int64_t File::Write(const void* buffer, int64_t num_bytes) { | |
| ASSERT(handle_->fd() >= 0); | |
| return NO_RETRY_EXPECTED(write(handle_->fd(), buffer, num_bytes)); | |
| } | |
| bool File::VPrint(const char* format, va_list args) { | |
| // Measure. | |
| va_list measure_args; | |
| va_copy(measure_args, args); | |
| intptr_t len = Utils::VSNPrint(nullptr, 0, format, measure_args); | |
| va_end(measure_args); | |
| char* buffer = reinterpret_cast<char*>(malloc(len + 1)); | |
| // Print. | |
| va_list print_args; | |
| va_copy(print_args, args); | |
| Utils::VSNPrint(buffer, len + 1, format, print_args); | |
| va_end(print_args); | |
| bool result = WriteFully(buffer, len); | |
| free(buffer); | |
| return result; | |
| } | |
| int64_t File::Position() { | |
| ASSERT(handle_->fd() >= 0); | |
| return NO_RETRY_EXPECTED(lseek(handle_->fd(), 0, SEEK_CUR)); | |
| } | |
| bool File::SetPosition(int64_t position) { | |
| ASSERT(handle_->fd() >= 0); | |
| return NO_RETRY_EXPECTED(lseek(handle_->fd(), position, SEEK_SET)) >= 0; | |
| } | |
| bool File::Truncate(int64_t length) { | |
| ASSERT(handle_->fd() >= 0); | |
| return NO_RETRY_EXPECTED(ftruncate(handle_->fd(), length) != -1); | |
| } | |
| bool File::Flush() { | |
| ASSERT(handle_->fd() >= 0); | |
| return NO_RETRY_EXPECTED(fsync(handle_->fd())) != -1; | |
| } | |
| bool File::Lock(File::LockType lock, int64_t start, int64_t end) { | |
| ASSERT(handle_->fd() >= 0); | |
| ASSERT((end == -1) || (end > start)); | |
| struct flock fl; | |
| switch (lock) { | |
| case File::kLockUnlock: | |
| fl.l_type = F_UNLCK; | |
| break; | |
| case File::kLockShared: | |
| case File::kLockBlockingShared: | |
| fl.l_type = F_RDLCK; | |
| break; | |
| case File::kLockExclusive: | |
| case File::kLockBlockingExclusive: | |
| fl.l_type = F_WRLCK; | |
| break; | |
| default: | |
| return false; | |
| } | |
| fl.l_whence = SEEK_SET; | |
| fl.l_start = start; | |
| fl.l_len = end == -1 ? 0 : end - start; | |
| int cmd = F_SETLK; | |
| if ((lock == File::kLockBlockingShared) || | |
| (lock == File::kLockBlockingExclusive)) { | |
| cmd = F_SETLKW; | |
| } | |
| return NO_RETRY_EXPECTED(fcntl(handle_->fd(), cmd, &fl)) != -1; | |
| } | |
| int64_t File::Length() { | |
| ASSERT(handle_->fd() >= 0); | |
| struct stat st; | |
| if (NO_RETRY_EXPECTED(fstat(handle_->fd(), &st)) == 0) { | |
| return st.st_size; | |
| } | |
| return -1; | |
| } | |
| File* File::FileOpenW(const wchar_t* system_name, FileOpenMode mode) { | |
| UNREACHABLE(); | |
| return nullptr; | |
| } | |
| File* File::OpenFD(int fd) { | |
| return new File(new FileHandle(fd)); | |
| } | |
| File* File::Open(Namespace* namespc, | |
| const char* name, | |
| FileOpenMode mode, | |
| bool executable) { | |
| NamespaceScope ns(namespc, name); | |
| // Report errors for non-regular files. | |
| struct stat st; | |
| if (NO_RETRY_EXPECTED(fstatat(ns.fd(), ns.path(), &st, 0)) == 0) { | |
| if (S_ISDIR(st.st_mode)) { | |
| errno = EISDIR; | |
| return nullptr; | |
| } | |
| } | |
| int flags = O_RDONLY; | |
| if ((mode & kWrite) != 0) { | |
| ASSERT((mode & kWriteOnly) == 0); | |
| flags = (O_RDWR | O_CREAT); | |
| } | |
| if ((mode & kWriteOnly) != 0) { | |
| ASSERT((mode & kWrite) == 0); | |
| flags = (O_WRONLY | O_CREAT); | |
| } | |
| if ((mode & kTruncate) != 0) { | |
| flags = flags | O_TRUNC; | |
| } | |
| flags |= O_CLOEXEC; | |
| int fd; | |
| if (executable) { | |
| fuchsia::io::Flags flags = | |
| fuchsia::io::PERM_READABLE | fuchsia::io::PERM_EXECUTABLE; | |
| zx_status_t status = | |
| fdio_open3_fd_at(ns.fd(), ns.path(), uint64_t{flags}, &fd); | |
| if (status != ZX_OK) { | |
| return nullptr; | |
| } | |
| } else { | |
| fd = NO_RETRY_EXPECTED(openat(ns.fd(), ns.path(), flags, 0666)); | |
| } | |
| if (fd < 0) { | |
| return nullptr; | |
| } | |
| if ((((mode & kWrite) != 0) && ((mode & kTruncate) == 0)) || | |
| (((mode & kWriteOnly) != 0) && ((mode & kTruncate) == 0))) { | |
| int64_t position = lseek(fd, 0, SEEK_END); | |
| if (position < 0) { | |
| return nullptr; | |
| } | |
| } | |
| return OpenFD(fd); | |
| } | |
| CStringUniquePtr File::UriToPath(const char* uri) { | |
| const char* path = | |
| (strlen(uri) >= 8 && strncmp(uri, "file:///", 8) == 0) ? uri + 7 : uri; | |
| UriDecoder uri_decoder(path); | |
| if (uri_decoder.decoded() == nullptr) { | |
| errno = EINVAL; | |
| return CStringUniquePtr(nullptr); | |
| } | |
| return CStringUniquePtr(strdup(uri_decoder.decoded())); | |
| } | |
| File* File::OpenUri(Namespace* namespc, | |
| const char* uri, | |
| FileOpenMode mode, | |
| bool executable) { | |
| auto path = UriToPath(uri); | |
| if (path == nullptr) { | |
| return nullptr; | |
| } | |
| return File::Open(namespc, path.get(), mode, executable); | |
| } | |
| File* File::OpenStdio(int fd) { | |
| return new File(new FileHandle(fd)); | |
| } | |
| bool File::Exists(Namespace* namespc, const char* name) { | |
| NamespaceScope ns(namespc, name); | |
| struct stat st; | |
| if (NO_RETRY_EXPECTED(fstatat(ns.fd(), ns.path(), &st, 0)) == 0) { | |
| // Everything but a directory and a link is a file to Dart. | |
| return !S_ISDIR(st.st_mode) && !S_ISLNK(st.st_mode); | |
| } | |
| return false; | |
| } | |
| bool File::ExistsUri(Namespace* namespc, const char* uri) { | |
| auto path = UriToPath(uri); | |
| if (path == nullptr) { | |
| return false; | |
| } | |
| return File::Exists(namespc, path.get()); | |
| } | |
| bool File::Create(Namespace* namespc, const char* name, bool exclusive) { | |
| NamespaceScope ns(namespc, name); | |
| int flags = O_RDONLY | O_CREAT | O_CLOEXEC; | |
| if (exclusive) { | |
| flags |= O_EXCL; | |
| } | |
| const int fd = NO_RETRY_EXPECTED(openat(ns.fd(), ns.path(), flags, 0666)); | |
| if (fd < 0) { | |
| Syslog::PrintErr("File::Create() openat(%ld, %s) failed: %s\n", ns.fd(), | |
| ns.path(), strerror(errno)); | |
| return false; | |
| } | |
| // File.create returns a File, so we shouldn't be giving the illusion that the | |
| // call has created a file or that a file already exists if there is already | |
| // an entity at the same path that is a directory or a link. | |
| bool is_file = false; | |
| struct stat st; | |
| if (NO_RETRY_EXPECTED(fstat(fd, &st)) == 0) { | |
| is_file = true; | |
| if (S_ISDIR(st.st_mode)) { | |
| errno = EISDIR; | |
| is_file = false; | |
| } else if (S_ISLNK(st.st_mode)) { | |
| errno = ENOENT; | |
| is_file = false; | |
| } | |
| } | |
| FDUtils::SaveErrorAndClose(fd); | |
| return is_file; | |
| } | |
| bool File::CreateLink(Namespace* namespc, | |
| const char* name, | |
| const char* target) { | |
| NamespaceScope ns(namespc, name); | |
| return NO_RETRY_EXPECTED(symlinkat(target, ns.fd(), ns.path())) == 0; | |
| } | |
| bool File::CreatePipe(Namespace* namespc, File** readPipe, File** writePipe) { | |
| int pipe_fds[2]; | |
| int status = NO_RETRY_EXPECTED(pipe(pipe_fds)); | |
| if (status != 0) { | |
| return false; | |
| } | |
| FDUtils::SetCloseOnExec(pipe_fds[0]); | |
| FDUtils::SetCloseOnExec(pipe_fds[1]); | |
| *readPipe = OpenFD(pipe_fds[0]); | |
| *writePipe = OpenFD(pipe_fds[1]); | |
| return true; | |
| } | |
| File::Type File::GetType(Namespace* namespc, | |
| const char* name, | |
| bool follow_links) { | |
| NamespaceScope ns(namespc, name); | |
| struct stat entry_info; | |
| int stat_success; | |
| if (follow_links) { | |
| stat_success = | |
| TEMP_FAILURE_RETRY(fstatat(ns.fd(), ns.path(), &entry_info, 0)); | |
| } else { | |
| stat_success = TEMP_FAILURE_RETRY( | |
| fstatat(ns.fd(), ns.path(), &entry_info, AT_SYMLINK_NOFOLLOW)); | |
| } | |
| if (stat_success == -1) { | |
| return File::kDoesNotExist; | |
| } | |
| if (S_ISDIR(entry_info.st_mode)) { | |
| return File::kIsDirectory; | |
| } | |
| if (S_ISREG(entry_info.st_mode)) { | |
| return File::kIsFile; | |
| } | |
| if (S_ISLNK(entry_info.st_mode)) { | |
| return File::kIsLink; | |
| } | |
| if (S_ISSOCK(entry_info.st_mode)) { | |
| return File::kIsSock; | |
| } | |
| if (S_ISFIFO(entry_info.st_mode)) { | |
| return File::kIsPipe; | |
| } | |
| return File::kDoesNotExist; | |
| } | |
| static void SetErrno(File::Type type) { | |
| switch (type) { | |
| case File::kIsDirectory: | |
| errno = EISDIR; | |
| break; | |
| case File::kDoesNotExist: | |
| errno = ENOENT; | |
| break; | |
| default: | |
| errno = EINVAL; | |
| break; | |
| } | |
| } | |
| static bool CheckTypeAndSetErrno(Namespace* namespc, | |
| const char* name, | |
| File::Type expected, | |
| bool follow_links) { | |
| File::Type actual = File::GetType(namespc, name, follow_links); | |
| if (actual == expected) { | |
| return true; | |
| } | |
| SetErrno(actual); | |
| return false; | |
| } | |
| bool File::Delete(Namespace* namespc, const char* name) { | |
| File::Type type = File::GetType(namespc, name, true); | |
| if (type == kIsFile || type == kIsSock || type == kIsPipe) { | |
| NamespaceScope ns(namespc, name); | |
| return (NO_RETRY_EXPECTED(unlinkat(ns.fd(), ns.path(), 0)) == 0); | |
| } | |
| SetErrno(type); | |
| return false; | |
| } | |
| bool File::DeleteLink(Namespace* namespc, const char* name) { | |
| NamespaceScope ns(namespc, name); | |
| return CheckTypeAndSetErrno(namespc, name, kIsLink, false) && | |
| (NO_RETRY_EXPECTED(unlinkat(ns.fd(), ns.path(), 0)) == 0); | |
| } | |
| bool File::Rename(Namespace* namespc, | |
| const char* old_path, | |
| const char* new_path) { | |
| File::Type type = File::GetType(namespc, old_path, true); | |
| if (type == kIsFile || type == kIsSock || type == kIsPipe) { | |
| NamespaceScope oldns(namespc, old_path); | |
| NamespaceScope newns(namespc, new_path); | |
| return (NO_RETRY_EXPECTED(renameat(oldns.fd(), oldns.path(), newns.fd(), | |
| newns.path())) == 0); | |
| } | |
| SetErrno(type); | |
| return false; | |
| } | |
| bool File::RenameLink(Namespace* namespc, | |
| const char* old_path, | |
| const char* new_path) { | |
| NamespaceScope oldns(namespc, old_path); | |
| NamespaceScope newns(namespc, new_path); | |
| return CheckTypeAndSetErrno(namespc, old_path, kIsLink, false) && | |
| (NO_RETRY_EXPECTED(renameat(oldns.fd(), oldns.path(), newns.fd(), | |
| newns.path())) == 0); | |
| } | |
| bool File::Copy(Namespace* namespc, | |
| const char* old_path, | |
| const char* new_path) { | |
| File::Type type = File::GetType(namespc, old_path, true); | |
| if (type != kIsFile && type != kIsSock && type != kIsPipe) { | |
| SetErrno(type); | |
| return false; | |
| } | |
| NamespaceScope oldns(namespc, old_path); | |
| struct stat st; | |
| if (NO_RETRY_EXPECTED(fstatat(oldns.fd(), oldns.path(), &st, 0)) != 0) { | |
| return false; | |
| } | |
| const int old_fd = | |
| NO_RETRY_EXPECTED(openat(oldns.fd(), oldns.path(), O_RDONLY | O_CLOEXEC)); | |
| if (old_fd < 0) { | |
| return false; | |
| } | |
| NamespaceScope newns(namespc, new_path); | |
| const int new_fd = NO_RETRY_EXPECTED( | |
| openat(newns.fd(), newns.path(), O_WRONLY | O_TRUNC | O_CREAT | O_CLOEXEC, | |
| st.st_mode)); | |
| if (new_fd < 0) { | |
| close(old_fd); | |
| return false; | |
| } | |
| // TODO(ZX-429): Use sendfile/copyfile or equivalent when there is one. | |
| intptr_t result; | |
| const intptr_t kBufferSize = 8 * KB; | |
| uint8_t* buffer = reinterpret_cast<uint8_t*>(malloc(kBufferSize)); | |
| while ((result = NO_RETRY_EXPECTED(read(old_fd, buffer, kBufferSize))) > 0) { | |
| int wrote = NO_RETRY_EXPECTED(write(new_fd, buffer, result)); | |
| if (wrote != result) { | |
| result = -1; | |
| break; | |
| } | |
| } | |
| free(buffer); | |
| FDUtils::SaveErrorAndClose(old_fd); | |
| FDUtils::SaveErrorAndClose(new_fd); | |
| if (result < 0) { | |
| int e = errno; | |
| VOID_NO_RETRY_EXPECTED(unlinkat(newns.fd(), newns.path(), 0)); | |
| errno = e; | |
| return false; | |
| } | |
| return true; | |
| } | |
| static bool StatHelper(Namespace* namespc, const char* name, struct stat* st) { | |
| NamespaceScope ns(namespc, name); | |
| if (NO_RETRY_EXPECTED(fstatat(ns.fd(), ns.path(), st, 0)) != 0) { | |
| return false; | |
| } | |
| // Signal an error if it's a directory. | |
| if (S_ISDIR(st->st_mode)) { | |
| errno = EISDIR; | |
| return false; | |
| } | |
| // Otherwise assume the caller knows what it's doing. | |
| return true; | |
| } | |
| int64_t File::LengthFromPath(Namespace* namespc, const char* name) { | |
| struct stat st; | |
| if (!StatHelper(namespc, name, &st)) { | |
| return -1; | |
| } | |
| return st.st_size; | |
| } | |
| static int64_t TimespecToMicroseconds(const struct timespec& t) { | |
| return static_cast<int64_t>(t.tv_sec) * kMicrosecondsPerSecond + | |
| static_cast<int64_t>(t.tv_nsec) / 1000L; | |
| } | |
| static void MicrosecondsToTimespec(int64_t micros, struct timespec* t) { | |
| ASSERT(t != nullptr); | |
| t->tv_sec = micros / kMicrosecondsPerSecond; | |
| t->tv_nsec = (micros % kMicrosecondsPerSecond) * 1000L; | |
| } | |
| void File::Stat(Namespace* namespc, const char* name, int64_t* data) { | |
| NamespaceScope ns(namespc, name); | |
| struct stat st; | |
| if (TEMP_FAILURE_RETRY(fstatat(ns.fd(), ns.path(), &st, 0)) == 0) { | |
| if (S_ISREG(st.st_mode)) { | |
| data[kType] = kIsFile; | |
| } else if (S_ISDIR(st.st_mode)) { | |
| data[kType] = kIsDirectory; | |
| } else if (S_ISLNK(st.st_mode)) { | |
| data[kType] = kIsLink; | |
| } else if (S_ISSOCK(st.st_mode)) { | |
| data[kType] = kIsSock; | |
| } else if (S_ISFIFO(st.st_mode)) { | |
| data[kType] = kIsPipe; | |
| } else { | |
| data[kType] = kDoesNotExist; | |
| } | |
| data[kCreatedTime] = TimespecToMicroseconds(st.st_ctim); | |
| data[kModifiedTime] = TimespecToMicroseconds(st.st_mtim); | |
| data[kAccessedTime] = TimespecToMicroseconds(st.st_atim); | |
| data[kMode] = st.st_mode; | |
| data[kSize] = st.st_size; | |
| } else { | |
| data[kType] = kDoesNotExist; | |
| } | |
| } | |
| int64_t File::LastModified(Namespace* namespc, const char* name) { | |
| struct stat st; | |
| if (!StatHelper(namespc, name, &st)) { | |
| return -1; | |
| } | |
| return TimespecToMicroseconds(st.st_mtim); | |
| } | |
| int64_t File::LastAccessed(Namespace* namespc, const char* name) { | |
| struct stat st; | |
| if (!StatHelper(namespc, name, &st)) { | |
| return -1; | |
| } | |
| return TimespecToMicroseconds(st.st_atim); | |
| } | |
| bool File::SetLastAccessed(Namespace* namespc, | |
| const char* name, | |
| int64_t micros) { | |
| // First get the current times. | |
| struct stat st; | |
| if (!StatHelper(namespc, name, &st)) { | |
| return false; | |
| } | |
| // Set the new time: | |
| NamespaceScope ns(namespc, name); | |
| struct timespec times[2]; | |
| MicrosecondsToTimespec(micros, ×[0]); | |
| times[1] = st.st_mtim; | |
| return utimensat(ns.fd(), ns.path(), times, 0) == 0; | |
| } | |
| bool File::SetLastModified(Namespace* namespc, | |
| const char* name, | |
| int64_t micros) { | |
| // First get the current times. | |
| struct stat st; | |
| if (!StatHelper(namespc, name, &st)) { | |
| return false; | |
| } | |
| // Set the new time: | |
| NamespaceScope ns(namespc, name); | |
| struct timespec times[2]; | |
| times[0] = st.st_atim; | |
| MicrosecondsToTimespec(micros, ×[1]); | |
| return utimensat(ns.fd(), ns.path(), times, 0) == 0; | |
| } | |
| const char* File::LinkTarget(Namespace* namespc, | |
| const char* name, | |
| char* dest, | |
| int dest_size) { | |
| NamespaceScope ns(namespc, name); | |
| struct stat link_stats; | |
| const int status = TEMP_FAILURE_RETRY( | |
| fstatat(ns.fd(), ns.path(), &link_stats, AT_SYMLINK_NOFOLLOW)); | |
| if (status != 0) { | |
| return nullptr; | |
| } | |
| if (!S_ISLNK(link_stats.st_mode)) { | |
| errno = ENOENT; | |
| return nullptr; | |
| } | |
| // Don't rely on the link_stats.st_size for the size of the link | |
| // target. For some filesystems, e.g. procfs, this value is always | |
| // 0. Also the link might have changed before the readlink call. | |
| const int kBufferSize = PATH_MAX + 1; | |
| char target[kBufferSize]; | |
| const int target_size = | |
| TEMP_FAILURE_RETRY(readlinkat(ns.fd(), ns.path(), target, kBufferSize)); | |
| if (target_size <= 0) { | |
| return nullptr; | |
| } | |
| if (dest == nullptr) { | |
| dest = DartUtils::ScopedCString(target_size + 1); | |
| } else { | |
| ASSERT(dest_size > 0); | |
| if (dest_size <= target_size) { | |
| return nullptr; | |
| } | |
| } | |
| memmove(dest, target, target_size); | |
| dest[target_size] = '\0'; | |
| return dest; | |
| } | |
| bool File::IsAbsolutePath(const char* pathname) { | |
| return ((pathname != nullptr) && (pathname[0] == '/')); | |
| } | |
| const char* File::GetCanonicalPath(Namespace* namespc, | |
| const char* name, | |
| char* dest, | |
| int dest_size) { | |
| if (name == nullptr) { | |
| return nullptr; | |
| } | |
| if (!Namespace::IsDefault(namespc)) { | |
| // TODO(zra): There is no realpathat(). Also chasing a symlink might result | |
| // in a path to something outside of the namespace, so canonicalizing paths | |
| // would have to be done carefully. For now, don't do anything. | |
| return name; | |
| } | |
| char* abs_path; | |
| if (dest == nullptr) { | |
| dest = DartUtils::ScopedCString(PATH_MAX + 1); | |
| } else { | |
| ASSERT(dest_size >= PATH_MAX); | |
| } | |
| ASSERT(dest != nullptr); | |
| do { | |
| abs_path = realpath(name, dest); | |
| } while ((abs_path == nullptr) && (errno == EINTR)); | |
| ASSERT(abs_path == nullptr || IsAbsolutePath(abs_path)); | |
| ASSERT(abs_path == nullptr || (abs_path == dest)); | |
| return abs_path; | |
| } | |
| const char* File::PathSeparator() { | |
| return "/"; | |
| } | |
| const char* File::StringEscapedPathSeparator() { | |
| return "/"; | |
| } | |
| static int fd_is_valid(int fd) { | |
| return NO_RETRY_EXPECTED(fcntl(fd, F_GETFD)) != -1 || errno != EBADF; | |
| } | |
| File::StdioHandleType File::GetStdioHandleType(int fd) { | |
| struct stat buf; | |
| int result = TEMP_FAILURE_RETRY(fstat(fd, &buf)); | |
| if (result == -1) { | |
| // fstat() on fds 0, 1, 2 on Fuchsia return -1 with errno ENOTSUP, | |
| // but if they are opened, then we can read/write them, so pretend they | |
| // are kPipe. | |
| return ((errno == ENOTSUP) && fd_is_valid(fd)) ? kPipe : kTypeError; | |
| } | |
| if (S_ISCHR(buf.st_mode)) { | |
| return kTerminal; | |
| } | |
| if (S_ISFIFO(buf.st_mode)) { | |
| return kPipe; | |
| } | |
| if (S_ISSOCK(buf.st_mode)) { | |
| return kSocket; | |
| } | |
| if (S_ISREG(buf.st_mode)) { | |
| return kFile; | |
| } | |
| return kOther; | |
| } | |
| File::Identical File::AreIdentical(Namespace* namespc_1, | |
| const char* file_1, | |
| Namespace* namespc_2, | |
| const char* file_2) { | |
| struct stat file_1_info; | |
| struct stat file_2_info; | |
| int status; | |
| { | |
| NamespaceScope ns1(namespc_1, file_1); | |
| status = TEMP_FAILURE_RETRY( | |
| fstatat(ns1.fd(), ns1.path(), &file_1_info, AT_SYMLINK_NOFOLLOW)); | |
| if (status == -1) { | |
| return File::kError; | |
| } | |
| } | |
| { | |
| NamespaceScope ns2(namespc_2, file_2); | |
| status = TEMP_FAILURE_RETRY( | |
| fstatat(ns2.fd(), ns2.path(), &file_2_info, AT_SYMLINK_NOFOLLOW)); | |
| if (status == -1) { | |
| return File::kError; | |
| } | |
| } | |
| return ((file_1_info.st_ino == file_2_info.st_ino) && | |
| (file_1_info.st_dev == file_2_info.st_dev)) | |
| ? File::kIdentical | |
| : File::kDifferent; | |
| } | |
| } // namespace bin | |
| } // namespace dart | |
| #endif // defined(DART_HOST_OS_FUCHSIA) |