/* * Copyright (c) 2021-2022, Andreas Kling * Copyright (c) 2021-2022, Kenneth Myhra * Copyright (c) 2021-2022, Sam Atkins * Copyright (c) 2022, Matthias Zimmerman * * SPDX-License-Identifier: BSD-2-Clause */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef AK_OS_SERENITY # include # include # include # include # include #endif #if defined(AK_OS_LINUX) && !defined(MFD_CLOEXEC) # include # include static int memfd_create(char const* name, unsigned int flags) { return syscall(SYS_memfd_create, name, flags); } #endif #if defined(AK_OS_MACOS) # include #endif #define HANDLE_SYSCALL_RETURN_VALUE(syscall_name, rc, success_value) \ if ((rc) < 0) { \ return Error::from_syscall(syscall_name##sv, rc); \ } \ return success_value; // clang-format off template concept SupportsReentrantGetpwent = requires(T passwd, T* ptr) { getpwent_r(&passwd, nullptr, 0, &ptr); }; // clang-format on // Note: This has to be in the global namespace for the extern declaration to trick the compiler // into finding a declaration of getpwent_r when it doesn't actually exist. static ErrorOr> getpwent_impl(Span buffer) { if constexpr (SupportsReentrantGetpwent) { struct passwd passwd; struct passwd* ptr = nullptr; extern int getpwent_r(struct passwd*, char*, size_t, struct passwd**); auto result = getpwent_r(&passwd, buffer.data(), buffer.size(), &ptr); if (result == 0 && ptr) return passwd; if (result != 0 && result != ENOENT) return Error::from_errno(result); } else { errno = 0; if (auto const* passwd = ::getpwent()) return *passwd; if (errno) return Error::from_errno(errno); } return Optional {}; } // clang-format off template concept SupportsReentrantGetgrent = requires(T group, T* ptr) { getgrent_r(&group, nullptr, 0, &ptr); }; // clang-format on // Note: This has to be in the global namespace for the extern declaration to trick the compiler // into finding a declaration of getgrent_r when it doesn't actually exist. static ErrorOr> getgrent_impl(Span buffer) { if constexpr (SupportsReentrantGetgrent) { struct group group; struct group* ptr = nullptr; extern int getgrent_r(struct group*, char*, size_t, struct group**); auto result = getgrent_r(&group, buffer.data(), buffer.size(), &ptr); if (result == 0 && ptr) return group; if (result != 0 && result != ENOENT) return Error::from_errno(result); } else { errno = 0; if (auto const* group = ::getgrent()) return *group; if (errno) return Error::from_errno(errno); } return Optional {}; } namespace Core::System { #ifndef HOST_NAME_MAX # ifdef AK_OS_MACOS # define HOST_NAME_MAX 255 # else # define HOST_NAME_MAX 64 # endif #endif #ifdef AK_OS_SERENITY ErrorOr beep() { auto rc = ::sysbeep(); if (rc < 0) return Error::from_syscall("beep"sv, -errno); return {}; } ErrorOr pledge(StringView promises, StringView execpromises) { Syscall::SC_pledge_params params { { promises.characters_without_null_termination(), promises.length() }, { execpromises.characters_without_null_termination(), execpromises.length() }, }; int rc = syscall(SC_pledge, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("pledge", rc, {}); } static ErrorOr unveil_dynamic_loader() { static bool dynamic_loader_unveiled { false }; if (dynamic_loader_unveiled) return {}; // FIXME: Try to find a way to not hardcode the dynamic loader path. constexpr auto dynamic_loader_path = "/usr/lib/Loader.so"sv; constexpr auto dynamic_loader_permissions = "x"sv; Syscall::SC_unveil_params params { static_cast(UnveilFlags::CurrentProgram), { dynamic_loader_path.characters_without_null_termination(), dynamic_loader_path.length() }, { dynamic_loader_permissions.characters_without_null_termination(), dynamic_loader_permissions.length() }, }; int rc = syscall(SC_unveil, ¶ms); if (rc < 0) { return Error::from_syscall("unveil (DynamicLoader @ /usr/lib/Loader.so)"sv, rc); } dynamic_loader_unveiled = true; return {}; } ErrorOr unveil(StringView path, StringView permissions) { auto const parsed_path = TRY(Core::SessionManagement::parse_path_with_sid(path)); if (permissions.contains('x')) TRY(unveil_dynamic_loader()); Syscall::SC_unveil_params params { static_cast(UnveilFlags::CurrentProgram), { parsed_path.characters(), parsed_path.length() }, { permissions.characters_without_null_termination(), permissions.length() }, }; int rc = syscall(SC_unveil, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("unveil", rc, {}); } ErrorOr unveil_after_exec(StringView path, StringView permissions) { auto const parsed_path = TRY(Core::SessionManagement::parse_path_with_sid(path)); Syscall::SC_unveil_params params { static_cast(UnveilFlags::AfterExec), { parsed_path.characters(), parsed_path.length() }, { permissions.characters_without_null_termination(), permissions.length() }, }; int rc = syscall(SC_unveil, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("unveil", rc, {}); } ErrorOr sendfd(int sockfd, int fd) { if (::sendfd(sockfd, fd) < 0) return Error::from_syscall("sendfd"sv, -errno); return {}; } ErrorOr recvfd(int sockfd, int options) { auto fd = ::recvfd(sockfd, options); if (fd < 0) return Error::from_syscall("recvfd"sv, -errno); return fd; } ErrorOr ptrace_peekbuf(pid_t tid, void const* tracee_addr, Bytes destination_buf) { Syscall::SC_ptrace_buf_params buf_params { { destination_buf.data(), destination_buf.size() } }; Syscall::SC_ptrace_params params { PT_PEEKBUF, tid, const_cast(tracee_addr), (FlatPtr)&buf_params, }; int rc = syscall(SC_ptrace, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("ptrace_peekbuf", rc, {}); } ErrorOr mount(int source_fd, StringView target, StringView fs_type, int flags) { if (target.is_null() || fs_type.is_null()) return Error::from_errno(EFAULT); Syscall::SC_mount_params params { { target.characters_without_null_termination(), target.length() }, { fs_type.characters_without_null_termination(), fs_type.length() }, source_fd, flags }; int rc = syscall(SC_mount, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("mount", rc, {}); } ErrorOr umount(StringView mount_point) { if (mount_point.is_null()) return Error::from_errno(EFAULT); int rc = syscall(SC_umount, mount_point.characters_without_null_termination(), mount_point.length()); HANDLE_SYSCALL_RETURN_VALUE("umount", rc, {}); } ErrorOr ptrace(int request, pid_t tid, void* address, void* data) { auto rc = ::ptrace(request, tid, address, data); if (rc < 0) return Error::from_syscall("ptrace"sv, -errno); return rc; } ErrorOr disown(pid_t pid) { int rc = ::disown(pid); HANDLE_SYSCALL_RETURN_VALUE("disown", rc, {}); } ErrorOr profiling_enable(pid_t pid, u64 event_mask) { int rc = ::profiling_enable(pid, event_mask); HANDLE_SYSCALL_RETURN_VALUE("profiling_enable", rc, {}); } ErrorOr profiling_disable(pid_t pid) { int rc = ::profiling_disable(pid); HANDLE_SYSCALL_RETURN_VALUE("profiling_disable", rc, {}); } ErrorOr profiling_free_buffer(pid_t pid) { int rc = ::profiling_free_buffer(pid); HANDLE_SYSCALL_RETURN_VALUE("profiling_free_buffer", rc, {}); } #endif #if !defined(AK_OS_BSD_GENERIC) && !defined(AK_OS_ANDROID) ErrorOr> getspent() { errno = 0; if (auto* spwd = ::getspent()) return *spwd; if (errno) return Error::from_syscall("getspent"sv, -errno); return Optional {}; } ErrorOr> getspnam(StringView name) { errno = 0; ::setspent(); while (auto* spwd = ::getspent()) { if (spwd->sp_namp == name) return *spwd; } if (errno) return Error::from_syscall("getspnam"sv, -errno); return Optional {}; } #endif #ifndef AK_OS_MACOS ErrorOr accept4(int sockfd, sockaddr* address, socklen_t* address_length, int flags) { auto fd = ::accept4(sockfd, address, address_length, flags); if (fd < 0) return Error::from_syscall("accept4"sv, -errno); return fd; } #endif ErrorOr sigaction(int signal, struct sigaction const* action, struct sigaction* old_action) { if (::sigaction(signal, action, old_action) < 0) return Error::from_syscall("sigaction"sv, -errno); return {}; } #if defined(AK_OS_MACOS) || defined(AK_OS_OPENBSD) || defined(AK_OS_FREEBSD) ErrorOr signal(int signal, sig_t handler) #else ErrorOr signal(int signal, sighandler_t handler) #endif { auto old_handler = ::signal(signal, handler); if (old_handler == SIG_ERR) return Error::from_syscall("signal"sv, -errno); return old_handler; } ErrorOr fstat(int fd) { struct stat st = {}; if (::fstat(fd, &st) < 0) return Error::from_syscall("fstat"sv, -errno); return st; } ErrorOr fcntl(int fd, int command, ...) { va_list ap; va_start(ap, command); uintptr_t extra_arg = va_arg(ap, uintptr_t); int rc = ::fcntl(fd, command, extra_arg); va_end(ap); if (rc < 0) return Error::from_syscall("fcntl"sv, -errno); return rc; } ErrorOr mmap(void* address, size_t size, int protection, int flags, int fd, off_t offset, [[maybe_unused]] size_t alignment, [[maybe_unused]] StringView name) { #ifdef AK_OS_SERENITY Syscall::SC_mmap_params params { address, size, alignment, protection, flags, fd, offset, { name.characters_without_null_termination(), name.length() } }; ptrdiff_t rc = syscall(SC_mmap, ¶ms); if (rc < 0 && rc > -EMAXERRNO) return Error::from_syscall("mmap"sv, rc); return reinterpret_cast(rc); #else // NOTE: Regular POSIX mmap() doesn't support custom alignment requests. VERIFY(!alignment); auto* ptr = ::mmap(address, size, protection, flags, fd, offset); if (ptr == MAP_FAILED) return Error::from_syscall("mmap"sv, -errno); return ptr; #endif } ErrorOr munmap(void* address, size_t size) { if (::munmap(address, size) < 0) return Error::from_syscall("munmap"sv, -errno); return {}; } ErrorOr anon_create([[maybe_unused]] size_t size, [[maybe_unused]] int options) { int fd = -1; #if defined(AK_OS_SERENITY) fd = ::anon_create(round_up_to_power_of_two(size, PAGE_SIZE), options); #elif defined(AK_OS_LINUX) || defined(AK_OS_FREEBSD) // FIXME: Support more options on Linux. auto linux_options = ((options & O_CLOEXEC) > 0) ? MFD_CLOEXEC : 0; fd = memfd_create("", linux_options); if (fd < 0) return Error::from_errno(errno); if (::ftruncate(fd, size) < 0) { auto saved_errno = errno; TRY(close(fd)); return Error::from_errno(saved_errno); } #elif defined(AK_OS_MACOS) || defined(AK_OS_EMSCRIPTEN) || defined(AK_OS_OPENBSD) struct timespec time; clock_gettime(CLOCK_REALTIME, &time); auto name = DeprecatedString::formatted("/shm-{}{}", (unsigned long)time.tv_sec, (unsigned long)time.tv_nsec); fd = shm_open(name.characters(), O_RDWR | O_CREAT | options, 0600); if (shm_unlink(name.characters()) == -1) { auto saved_errno = errno; TRY(close(fd)); return Error::from_errno(saved_errno); } if (fd < 0) return Error::from_errno(errno); if (::ftruncate(fd, size) < 0) { auto saved_errno = errno; TRY(close(fd)); return Error::from_errno(saved_errno); } void* addr = ::mmap(NULL, size, PROT_WRITE, MAP_SHARED, fd, 0); if (addr == MAP_FAILED) { auto saved_errno = errno; TRY(close(fd)); return Error::from_errno(saved_errno); } #endif if (fd < 0) return Error::from_errno(errno); return fd; } ErrorOr open(StringView path, int options, mode_t mode) { return openat(AT_FDCWD, path, options, mode); } ErrorOr openat(int fd, StringView path, int options, mode_t mode) { if (!path.characters_without_null_termination()) return Error::from_syscall("open"sv, -EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_open_params params { fd, { path.characters_without_null_termination(), path.length() }, options, mode }; int rc = syscall(SC_open, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("open", rc, rc); #else // NOTE: We have to ensure that the path is null-terminated. DeprecatedString path_string = path; int rc = ::openat(fd, path_string.characters(), options, mode); if (rc < 0) return Error::from_syscall("open"sv, -errno); return rc; #endif } ErrorOr close(int fd) { if (::close(fd) < 0) return Error::from_syscall("close"sv, -errno); return {}; } ErrorOr ftruncate(int fd, off_t length) { if (::ftruncate(fd, length) < 0) return Error::from_syscall("ftruncate"sv, -errno); return {}; } ErrorOr stat(StringView path) { if (!path.characters_without_null_termination()) return Error::from_syscall("stat"sv, -EFAULT); struct stat st = {}; #ifdef AK_OS_SERENITY Syscall::SC_stat_params params { { path.characters_without_null_termination(), path.length() }, &st, AT_FDCWD, true }; int rc = syscall(SC_stat, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("stat", rc, st); #else DeprecatedString path_string = path; if (::stat(path_string.characters(), &st) < 0) return Error::from_syscall("stat"sv, -errno); return st; #endif } ErrorOr lstat(StringView path) { if (!path.characters_without_null_termination()) return Error::from_syscall("lstat"sv, -EFAULT); struct stat st = {}; #ifdef AK_OS_SERENITY Syscall::SC_stat_params params { { path.characters_without_null_termination(), path.length() }, &st, AT_FDCWD, false }; int rc = syscall(SC_stat, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("lstat", rc, st); #else DeprecatedString path_string = path; if (::stat(path_string.characters(), &st) < 0) return Error::from_syscall("lstat"sv, -errno); return st; #endif } ErrorOr read(int fd, Bytes buffer) { ssize_t rc = ::read(fd, buffer.data(), buffer.size()); if (rc < 0) return Error::from_syscall("read"sv, -errno); return rc; } ErrorOr write(int fd, ReadonlyBytes buffer) { ssize_t rc = ::write(fd, buffer.data(), buffer.size()); if (rc < 0) return Error::from_syscall("write"sv, -errno); return rc; } ErrorOr kill(pid_t pid, int signal) { if (::kill(pid, signal) < 0) return Error::from_syscall("kill"sv, -errno); return {}; } ErrorOr killpg(int pgrp, int signal) { if (::killpg(pgrp, signal) < 0) return Error::from_syscall("killpg"sv, -errno); return {}; } ErrorOr dup(int source_fd) { int fd = ::dup(source_fd); if (fd < 0) return Error::from_syscall("dup"sv, -errno); return fd; } ErrorOr dup2(int source_fd, int destination_fd) { int fd = ::dup2(source_fd, destination_fd); if (fd < 0) return Error::from_syscall("dup2"sv, -errno); return fd; } ErrorOr ptsname(int fd) { auto* name = ::ptsname(fd); if (!name) return Error::from_syscall("ptsname"sv, -errno); return DeprecatedString(name); } ErrorOr gethostname() { char hostname[HOST_NAME_MAX]; int rc = ::gethostname(hostname, sizeof(hostname)); if (rc < 0) return Error::from_syscall("gethostname"sv, -errno); return DeprecatedString(&hostname[0]); } ErrorOr sethostname(StringView hostname) { int rc = ::sethostname(hostname.characters_without_null_termination(), hostname.length()); if (rc < 0) return Error::from_syscall("sethostname"sv, -errno); return {}; } ErrorOr getcwd() { auto* cwd = ::getcwd(nullptr, 0); if (!cwd) return Error::from_syscall("getcwd"sv, -errno); DeprecatedString string_cwd(cwd); free(cwd); return string_cwd; } ErrorOr ioctl(int fd, unsigned request, ...) { va_list ap; va_start(ap, request); FlatPtr arg = va_arg(ap, FlatPtr); va_end(ap); if (::ioctl(fd, request, arg) < 0) return Error::from_syscall("ioctl"sv, -errno); return {}; } ErrorOr tcgetattr(int fd) { struct termios ios = {}; if (::tcgetattr(fd, &ios) < 0) return Error::from_syscall("tcgetattr"sv, -errno); return ios; } ErrorOr tcsetattr(int fd, int optional_actions, struct termios const& ios) { if (::tcsetattr(fd, optional_actions, &ios) < 0) return Error::from_syscall("tcsetattr"sv, -errno); return {}; } ErrorOr tcsetpgrp(int fd, pid_t pgrp) { int rc = ::tcsetpgrp(fd, pgrp); if (rc < 0) return Error::from_syscall("tcsetpgrp"sv, -errno); return { rc }; } ErrorOr chmod(StringView pathname, mode_t mode) { if (!pathname.characters_without_null_termination()) return Error::from_syscall("chmod"sv, -EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_chmod_params params { AT_FDCWD, { pathname.characters_without_null_termination(), pathname.length() }, mode, true }; int rc = syscall(SC_chmod, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("chmod", rc, {}); #else DeprecatedString path = pathname; if (::chmod(path.characters(), mode) < 0) return Error::from_syscall("chmod"sv, -errno); return {}; #endif } ErrorOr fchmod(int fd, mode_t mode) { if (::fchmod(fd, mode) < 0) return Error::from_syscall("fchmod"sv, -errno); return {}; } ErrorOr fchown(int fd, uid_t uid, gid_t gid) { if (::fchown(fd, uid, gid) < 0) return Error::from_syscall("fchown"sv, -errno); return {}; } ErrorOr lchown(StringView pathname, uid_t uid, gid_t gid) { if (!pathname.characters_without_null_termination()) return Error::from_syscall("chown"sv, -EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_chown_params params = { { pathname.characters_without_null_termination(), pathname.length() }, uid, gid, AT_FDCWD, false }; int rc = syscall(SC_chown, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("chown", rc, {}); #else DeprecatedString path = pathname; if (::chown(path.characters(), uid, gid) < 0) return Error::from_syscall("chown"sv, -errno); return {}; #endif } ErrorOr chown(StringView pathname, uid_t uid, gid_t gid) { if (!pathname.characters_without_null_termination()) return Error::from_syscall("chown"sv, -EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_chown_params params = { { pathname.characters_without_null_termination(), pathname.length() }, uid, gid, AT_FDCWD, true }; int rc = syscall(SC_chown, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("chown", rc, {}); #else DeprecatedString path = pathname; if (::lchown(path.characters(), uid, gid) < 0) return Error::from_syscall("lchown"sv, -errno); return {}; #endif } ErrorOr> getpwent(Span buffer) { return getpwent_impl(buffer); } ErrorOr> getpwuid(uid_t uid) { errno = 0; if (auto* pwd = ::getpwuid(uid)) return *pwd; if (errno) return Error::from_syscall("getpwuid"sv, -errno); return Optional {}; } ErrorOr> getgrent(Span buffer) { return getgrent_impl(buffer); } ErrorOr> getgrgid(gid_t gid) { errno = 0; if (auto* grp = ::getgrgid(gid)) return *grp; if (errno) return Error::from_syscall("getgrgid"sv, -errno); return Optional {}; } ErrorOr> getpwnam(StringView name) { errno = 0; ::setpwent(); if (errno) return Error::from_syscall("getpwnam"sv, -errno); while (auto* pw = ::getpwent()) { if (errno) return Error::from_syscall("getpwnam"sv, -errno); if (pw->pw_name == name) return *pw; } if (errno) return Error::from_syscall("getpwnam"sv, -errno); else return Optional {}; } ErrorOr> getgrnam(StringView name) { errno = 0; ::setgrent(); if (errno) return Error::from_syscall("getgrnam"sv, -errno); while (auto* gr = ::getgrent()) { if (errno) return Error::from_syscall("getgrnam"sv, -errno); if (gr->gr_name == name) return *gr; } if (errno) return Error::from_syscall("getgrnam"sv, -errno); else return Optional {}; } ErrorOr clock_settime(clockid_t clock_id, struct timespec* ts) { #ifdef AK_OS_SERENITY int rc = syscall(SC_clock_settime, clock_id, ts); HANDLE_SYSCALL_RETURN_VALUE("clocksettime", rc, {}); #else if (::clock_settime(clock_id, ts) < 0) return Error::from_syscall("clocksettime"sv, -errno); return {}; #endif } static ALWAYS_INLINE ErrorOr posix_spawn_wrapper(StringView path, posix_spawn_file_actions_t const* file_actions, posix_spawnattr_t const* attr, char* const arguments[], char* const envp[], StringView function_name, decltype(::posix_spawn) spawn_function) { pid_t child_pid; if ((errno = spawn_function(&child_pid, path.to_deprecated_string().characters(), file_actions, attr, arguments, envp))) return Error::from_syscall(function_name, -errno); return child_pid; } ErrorOr posix_spawn(StringView path, posix_spawn_file_actions_t const* file_actions, posix_spawnattr_t const* attr, char* const arguments[], char* const envp[]) { return posix_spawn_wrapper(path, file_actions, attr, arguments, envp, "posix_spawn"sv, ::posix_spawn); } ErrorOr posix_spawnp(StringView path, posix_spawn_file_actions_t* const file_actions, posix_spawnattr_t* const attr, char* const arguments[], char* const envp[]) { return posix_spawn_wrapper(path, file_actions, attr, arguments, envp, "posix_spawnp"sv, ::posix_spawnp); } ErrorOr lseek(int fd, off_t offset, int whence) { off_t rc = ::lseek(fd, offset, whence); if (rc < 0) return Error::from_syscall("lseek"sv, -errno); return rc; } ErrorOr endgrent() { int old_errno = 0; swap(old_errno, errno); ::endgrent(); if (errno != 0) return Error::from_syscall("endgrent"sv, -errno); errno = old_errno; return {}; } ErrorOr waitpid(pid_t waitee, int options) { int wstatus; pid_t pid = ::waitpid(waitee, &wstatus, options); if (pid < 0) return Error::from_syscall("waitpid"sv, -errno); return WaitPidResult { pid, wstatus }; } ErrorOr setuid(uid_t uid) { if (::setuid(uid) < 0) return Error::from_syscall("setuid"sv, -errno); return {}; } ErrorOr seteuid(uid_t uid) { if (::seteuid(uid) < 0) return Error::from_syscall("seteuid"sv, -errno); return {}; } ErrorOr setgid(gid_t gid) { if (::setgid(gid) < 0) return Error::from_syscall("setgid"sv, -errno); return {}; } ErrorOr setegid(gid_t gid) { if (::setegid(gid) < 0) return Error::from_syscall("setegid"sv, -errno); return {}; } ErrorOr setpgid(pid_t pid, pid_t pgid) { if (::setpgid(pid, pgid) < 0) return Error::from_syscall("setpgid"sv, -errno); return {}; } ErrorOr setsid() { int rc = ::setsid(); if (rc < 0) return Error::from_syscall("setsid"sv, -errno); return rc; } ErrorOr getsid(pid_t pid) { int rc = ::getsid(pid); if (rc < 0) return Error::from_syscall("getsid"sv, -errno); return rc; } ErrorOr drop_privileges() { auto gid_result = setgid(getgid()); auto uid_result = setuid(getuid()); if (gid_result.is_error() || uid_result.is_error()) return Error::from_string_literal("Failed to drop privileges"); return {}; } ErrorOr isatty(int fd) { int rc = ::isatty(fd); if (rc < 0) return Error::from_syscall("isatty"sv, -errno); return rc == 1; } ErrorOr link(StringView old_path, StringView new_path) { #ifdef AK_OS_SERENITY Syscall::SC_link_params params { .old_path = { old_path.characters_without_null_termination(), old_path.length() }, .new_path = { new_path.characters_without_null_termination(), new_path.length() }, }; int rc = syscall(SC_link, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("link", rc, {}); #else DeprecatedString old_path_string = old_path; DeprecatedString new_path_string = new_path; if (::link(old_path_string.characters(), new_path_string.characters()) < 0) return Error::from_syscall("link"sv, -errno); return {}; #endif } ErrorOr symlink(StringView target, StringView link_path) { #ifdef AK_OS_SERENITY Syscall::SC_symlink_params params { .target = { target.characters_without_null_termination(), target.length() }, .linkpath = { link_path.characters_without_null_termination(), link_path.length() }, .dirfd = AT_FDCWD, }; int rc = syscall(SC_symlink, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("symlink", rc, {}); #else DeprecatedString target_string = target; DeprecatedString link_path_string = link_path; if (::symlink(target_string.characters(), link_path_string.characters()) < 0) return Error::from_syscall("symlink"sv, -errno); return {}; #endif } ErrorOr mkdir(StringView path, mode_t mode) { if (path.is_null()) return Error::from_errno(EFAULT); #ifdef AK_OS_SERENITY int rc = syscall(SC_mkdir, AT_FDCWD, path.characters_without_null_termination(), path.length(), mode); HANDLE_SYSCALL_RETURN_VALUE("mkdir", rc, {}); #else DeprecatedString path_string = path; if (::mkdir(path_string.characters(), mode) < 0) return Error::from_syscall("mkdir"sv, -errno); return {}; #endif } ErrorOr chdir(StringView path) { if (path.is_null()) return Error::from_errno(EFAULT); #ifdef AK_OS_SERENITY int rc = syscall(SC_chdir, path.characters_without_null_termination(), path.length()); HANDLE_SYSCALL_RETURN_VALUE("chdir", rc, {}); #else DeprecatedString path_string = path; if (::chdir(path_string.characters()) < 0) return Error::from_syscall("chdir"sv, -errno); return {}; #endif } ErrorOr rmdir(StringView path) { if (path.is_null()) return Error::from_errno(EFAULT); #ifdef AK_OS_SERENITY int rc = syscall(SC_rmdir, path.characters_without_null_termination(), path.length()); HANDLE_SYSCALL_RETURN_VALUE("rmdir", rc, {}); #else DeprecatedString path_string = path; if (::rmdir(path_string.characters()) < 0) return Error::from_syscall("rmdir"sv, -errno); return {}; #endif } ErrorOr fork() { pid_t pid = ::fork(); if (pid < 0) return Error::from_syscall("fork"sv, -errno); return pid; } ErrorOr mkstemp(Span pattern) { int fd = ::mkstemp(pattern.data()); if (fd < 0) return Error::from_syscall("mkstemp"sv, -errno); return fd; } ErrorOr rename(StringView old_path, StringView new_path) { if (old_path.is_null() || new_path.is_null()) return Error::from_errno(EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_rename_params params { .olddirfd = AT_FDCWD, .old_path = { old_path.characters_without_null_termination(), old_path.length() }, .newdirfd = AT_FDCWD, .new_path = { new_path.characters_without_null_termination(), new_path.length() }, }; int rc = syscall(SC_rename, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("rename", rc, {}); #else DeprecatedString old_path_string = old_path; DeprecatedString new_path_string = new_path; if (::rename(old_path_string.characters(), new_path_string.characters()) < 0) return Error::from_syscall("rename"sv, -errno); return {}; #endif } ErrorOr unlink(StringView path) { if (path.is_null()) return Error::from_errno(EFAULT); #ifdef AK_OS_SERENITY int rc = syscall(SC_unlink, AT_FDCWD, path.characters_without_null_termination(), path.length(), 0); HANDLE_SYSCALL_RETURN_VALUE("unlink", rc, {}); #else DeprecatedString path_string = path; if (::unlink(path_string.characters()) < 0) return Error::from_syscall("unlink"sv, -errno); return {}; #endif } ErrorOr utime(StringView path, Optional maybe_buf) { if (path.is_null()) return Error::from_errno(EFAULT); struct utimbuf* buf = nullptr; if (maybe_buf.has_value()) buf = &maybe_buf.value(); #ifdef AK_OS_SERENITY int rc = syscall(SC_utime, path.characters_without_null_termination(), path.length(), buf); HANDLE_SYSCALL_RETURN_VALUE("utime", rc, {}); #else DeprecatedString path_string = path; if (::utime(path_string.characters(), buf) < 0) return Error::from_syscall("utime"sv, -errno); return {}; #endif } ErrorOr uname() { utsname uts; #ifdef AK_OS_SERENITY int rc = syscall(SC_uname, &uts); HANDLE_SYSCALL_RETURN_VALUE("uname", rc, uts); #else if (::uname(&uts) < 0) return Error::from_syscall("uname"sv, -errno); #endif return uts; } #ifndef AK_OS_ANDROID ErrorOr adjtime(const struct timeval* delta, struct timeval* old_delta) { # ifdef AK_OS_SERENITY int rc = syscall(SC_adjtime, delta, old_delta); HANDLE_SYSCALL_RETURN_VALUE("adjtime", rc, {}); # else if (::adjtime(delta, old_delta) < 0) return Error::from_syscall("adjtime"sv, -errno); return {}; # endif } #endif #ifdef AK_OS_SERENITY ErrorOr exec_command(Vector& command, bool preserve_env) { Vector exec_environment; for (size_t i = 0; environ[i]; ++i) { StringView env_view { environ[i], strlen(environ[i]) }; auto maybe_needle = env_view.find('='); if (!maybe_needle.has_value()) continue; // FIXME: Allow a custom selection of variables once ArgsParser supports options with optional parameters. if (!preserve_env && env_view.substring_view(0, maybe_needle.value()) != "TERM"sv) continue; exec_environment.append(env_view); } TRY(Core::System::exec(command.at(0), command, Core::System::SearchInPath::Yes, exec_environment)); return {}; } ErrorOr join_jail(u64 jail_index) { Syscall::SC_jail_attach_params params { jail_index }; int rc = syscall(SC_jail_attach, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("jail_attach", rc, {}); } ErrorOr create_jail(StringView jail_name) { Syscall::SC_jail_create_params params { 0, { jail_name.characters_without_null_termination(), jail_name.length() } }; int rc = syscall(SC_jail_create, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("jail_create", rc, static_cast(params.index)); } #endif ErrorOr exec(StringView filename, Span arguments, SearchInPath search_in_path, Optional> environment) { #ifdef AK_OS_SERENITY Syscall::SC_execve_params params; auto argument_strings = TRY(FixedArray::try_create(arguments.size())); for (size_t i = 0; i < arguments.size(); ++i) { argument_strings[i] = { arguments[i].characters_without_null_termination(), arguments[i].length() }; } params.arguments.strings = argument_strings.data(); params.arguments.length = argument_strings.size(); size_t env_count = 0; if (environment.has_value()) { env_count = environment->size(); } else { for (size_t i = 0; environ[i]; ++i) ++env_count; } auto environment_strings = TRY(FixedArray::try_create(env_count)); if (environment.has_value()) { for (size_t i = 0; i < env_count; ++i) { environment_strings[i] = { environment->at(i).characters_without_null_termination(), environment->at(i).length() }; } } else { for (size_t i = 0; i < env_count; ++i) { environment_strings[i] = { environ[i], strlen(environ[i]) }; } } params.environment.strings = environment_strings.data(); params.environment.length = environment_strings.size(); auto run_exec = [](Syscall::SC_execve_params& params) -> ErrorOr { int rc = syscall(Syscall::SC_execve, ¶ms); if (rc < 0) return Error::from_syscall("exec"sv, rc); return {}; }; DeprecatedString exec_filename; if (search_in_path == SearchInPath::Yes) { auto maybe_executable = Core::File::resolve_executable_from_environment(filename); if (!maybe_executable.has_value()) return ENOENT; exec_filename = maybe_executable.release_value(); } else { exec_filename = filename.to_deprecated_string(); } params.path = { exec_filename.characters(), exec_filename.length() }; TRY(run_exec(params)); VERIFY_NOT_REACHED(); #else DeprecatedString filename_string { filename }; auto argument_strings = TRY(FixedArray::try_create(arguments.size())); auto argv = TRY(FixedArray::try_create(arguments.size() + 1)); for (size_t i = 0; i < arguments.size(); ++i) { argument_strings[i] = arguments[i].to_deprecated_string(); argv[i] = const_cast(argument_strings[i].characters()); } argv[arguments.size()] = nullptr; int rc = 0; if (environment.has_value()) { auto environment_strings = TRY(FixedArray::try_create(environment->size())); auto envp = TRY(FixedArray::try_create(environment->size() + 1)); for (size_t i = 0; i < environment->size(); ++i) { environment_strings[i] = environment->at(i).to_deprecated_string(); envp[i] = const_cast(environment_strings[i].characters()); } envp[environment->size()] = nullptr; if (search_in_path == SearchInPath::Yes && !filename.contains('/')) { # if defined(AK_OS_MACOS) || defined(AK_OS_FREEBSD) // These BSDs don't support execvpe(), so we'll have to manually search the PATH. ScopedValueRollback errno_rollback(errno); auto maybe_executable = Core::File::resolve_executable_from_environment(filename_string); if (!maybe_executable.has_value()) { errno_rollback.set_override_rollback_value(ENOENT); return Error::from_errno(ENOENT); } rc = ::execve(maybe_executable.release_value().characters(), argv.data(), envp.data()); # else rc = ::execvpe(filename_string.characters(), argv.data(), envp.data()); # endif } else { rc = ::execve(filename_string.characters(), argv.data(), envp.data()); } } else { if (search_in_path == SearchInPath::Yes) rc = ::execvp(filename_string.characters(), argv.data()); else rc = ::execv(filename_string.characters(), argv.data()); } if (rc < 0) return Error::from_syscall("exec"sv, rc); VERIFY_NOT_REACHED(); #endif } ErrorOr socket(int domain, int type, int protocol) { auto fd = ::socket(domain, type, protocol); if (fd < 0) return Error::from_syscall("socket"sv, -errno); return fd; } ErrorOr bind(int sockfd, struct sockaddr const* address, socklen_t address_length) { if (::bind(sockfd, address, address_length) < 0) return Error::from_syscall("bind"sv, -errno); return {}; } ErrorOr listen(int sockfd, int backlog) { if (::listen(sockfd, backlog) < 0) return Error::from_syscall("listen"sv, -errno); return {}; } ErrorOr accept(int sockfd, struct sockaddr* address, socklen_t* address_length) { auto fd = ::accept(sockfd, address, address_length); if (fd < 0) return Error::from_syscall("accept"sv, -errno); return fd; } ErrorOr connect(int sockfd, struct sockaddr const* address, socklen_t address_length) { if (::connect(sockfd, address, address_length) < 0) return Error::from_syscall("connect"sv, -errno); return {}; } ErrorOr shutdown(int sockfd, int how) { if (::shutdown(sockfd, how) < 0) return Error::from_syscall("shutdown"sv, -errno); return {}; } ErrorOr send(int sockfd, void const* buffer, size_t buffer_length, int flags) { auto sent = ::send(sockfd, buffer, buffer_length, flags); if (sent < 0) return Error::from_syscall("send"sv, -errno); return sent; } ErrorOr sendmsg(int sockfd, const struct msghdr* message, int flags) { auto sent = ::sendmsg(sockfd, message, flags); if (sent < 0) return Error::from_syscall("sendmsg"sv, -errno); return sent; } ErrorOr sendto(int sockfd, void const* source, size_t source_length, int flags, struct sockaddr const* destination, socklen_t destination_length) { auto sent = ::sendto(sockfd, source, source_length, flags, destination, destination_length); if (sent < 0) return Error::from_syscall("sendto"sv, -errno); return sent; } ErrorOr recv(int sockfd, void* buffer, size_t length, int flags) { auto received = ::recv(sockfd, buffer, length, flags); if (received < 0) return Error::from_syscall("recv"sv, -errno); return received; } ErrorOr recvmsg(int sockfd, struct msghdr* message, int flags) { auto received = ::recvmsg(sockfd, message, flags); if (received < 0) return Error::from_syscall("recvmsg"sv, -errno); return received; } ErrorOr recvfrom(int sockfd, void* buffer, size_t buffer_length, int flags, struct sockaddr* address, socklen_t* address_length) { auto received = ::recvfrom(sockfd, buffer, buffer_length, flags, address, address_length); if (received < 0) return Error::from_syscall("recvfrom"sv, -errno); return received; } ErrorOr getaddrinfo(char const* nodename, char const* servname, struct addrinfo const& hints) { struct addrinfo* results = nullptr; int const rc = ::getaddrinfo(nodename, servname, &hints, &results); if (rc != 0) { if (rc == EAI_SYSTEM) { return Error::from_syscall("getaddrinfo"sv, -errno); } auto const* error_string = gai_strerror(rc); return Error::from_string_view({ error_string, strlen(error_string) }); } Vector addresses; for (auto* result = results; result != nullptr; result = result->ai_next) TRY(addresses.try_append(*result)); return AddressInfoVector { move(addresses), results }; } ErrorOr getsockopt(int sockfd, int level, int option, void* value, socklen_t* value_size) { if (::getsockopt(sockfd, level, option, value, value_size) < 0) return Error::from_syscall("getsockopt"sv, -errno); return {}; } ErrorOr setsockopt(int sockfd, int level, int option, void const* value, socklen_t value_size) { if (::setsockopt(sockfd, level, option, value, value_size) < 0) return Error::from_syscall("setsockopt"sv, -errno); return {}; } ErrorOr getsockname(int sockfd, struct sockaddr* address, socklen_t* address_length) { if (::getsockname(sockfd, address, address_length) < 0) return Error::from_syscall("getsockname"sv, -errno); return {}; } ErrorOr getpeername(int sockfd, struct sockaddr* address, socklen_t* address_length) { if (::getpeername(sockfd, address, address_length) < 0) return Error::from_syscall("getpeername"sv, -errno); return {}; } ErrorOr socketpair(int domain, int type, int protocol, int sv[2]) { if (::socketpair(domain, type, protocol, sv) < 0) return Error::from_syscall("socketpair"sv, -errno); return {}; } ErrorOr> pipe2([[maybe_unused]] int flags) { Array fds; #if defined(__unix__) if (::pipe2(fds.data(), flags) < 0) return Error::from_syscall("pipe2"sv, -errno); #else if (::pipe(fds.data()) < 0) return Error::from_syscall("pipe2"sv, -errno); #endif return fds; } ErrorOr> getgroups() { int count = ::getgroups(0, nullptr); if (count < 0) return Error::from_syscall("getgroups"sv, -errno); if (count == 0) return Vector {}; Vector groups; TRY(groups.try_resize(count)); if (::getgroups(count, groups.data()) < 0) return Error::from_syscall("getgroups"sv, -errno); return groups; } ErrorOr setgroups(Span gids) { if (::setgroups(gids.size(), gids.data()) < 0) return Error::from_syscall("setgroups"sv, -errno); return {}; } ErrorOr mknod(StringView pathname, mode_t mode, dev_t dev) { if (pathname.is_null()) return Error::from_syscall("mknod"sv, -EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_mknod_params params { { pathname.characters_without_null_termination(), pathname.length() }, mode, dev }; int rc = syscall(SC_mknod, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("mknod", rc, {}); #else DeprecatedString path_string = pathname; if (::mknod(path_string.characters(), mode, dev) < 0) return Error::from_syscall("mknod"sv, -errno); return {}; #endif } ErrorOr mkfifo(StringView pathname, mode_t mode) { return mknod(pathname, mode | S_IFIFO, 0); } ErrorOr setenv(StringView name, StringView value, bool overwrite) { #ifdef AK_OS_SERENITY auto const rc = ::serenity_setenv(name.characters_without_null_termination(), name.length(), value.characters_without_null_termination(), value.length(), overwrite); #else DeprecatedString name_string = name; DeprecatedString value_string = value; auto const rc = ::setenv(name_string.characters(), value_string.characters(), overwrite); #endif if (rc < 0) return Error::from_syscall("setenv"sv, -errno); return {}; } ErrorOr posix_openpt(int flags) { int const rc = ::posix_openpt(flags); if (rc < 0) return Error::from_syscall("posix_openpt"sv, -errno); return rc; } ErrorOr grantpt(int fildes) { auto const rc = ::grantpt(fildes); if (rc < 0) return Error::from_syscall("grantpt"sv, -errno); return {}; } ErrorOr unlockpt(int fildes) { auto const rc = ::unlockpt(fildes); if (rc < 0) return Error::from_syscall("unlockpt"sv, -errno); return {}; } ErrorOr access(StringView pathname, int mode) { if (pathname.is_null()) return Error::from_syscall("access"sv, -EFAULT); #ifdef AK_OS_SERENITY Syscall::SC_faccessat_params params { .dirfd = AT_FDCWD, .pathname = { pathname.characters_without_null_termination(), pathname.length() }, .mode = mode, .flags = 0, }; int rc = ::syscall(Syscall::SC_faccessat, ¶ms); HANDLE_SYSCALL_RETURN_VALUE("access", rc, {}); #else DeprecatedString path_string = pathname; if (::access(path_string.characters(), mode) < 0) return Error::from_syscall("access"sv, -errno); return {}; #endif } ErrorOr readlink(StringView pathname) { // FIXME: Try again with a larger buffer. char data[PATH_MAX]; #ifdef AK_OS_SERENITY Syscall::SC_readlink_params small_params { .path = { pathname.characters_without_null_termination(), pathname.length() }, .buffer = { data, sizeof(data) }, .dirfd = AT_FDCWD, }; int rc = syscall(SC_readlink, &small_params); HANDLE_SYSCALL_RETURN_VALUE("readlink", rc, DeprecatedString(data, rc)); #else DeprecatedString path_string = pathname; int rc = ::readlink(path_string.characters(), data, sizeof(data)); if (rc == -1) return Error::from_syscall("readlink"sv, -errno); return DeprecatedString(data, rc); #endif } ErrorOr poll(Span poll_fds, int timeout) { auto const rc = ::poll(poll_fds.data(), poll_fds.size(), timeout); if (rc < 0) return Error::from_syscall("poll"sv, -errno); return { rc }; } #ifdef AK_OS_SERENITY ErrorOr posix_fallocate(int fd, off_t offset, off_t length) { int rc = ::posix_fallocate(fd, offset, length); if (rc != 0) return Error::from_syscall("posix_fallocate"sv, -rc); return {}; } #endif }