diff options
author | Ian Moffett <ian@osmora.org> | 2024-03-07 17:28:00 -0500 |
---|---|---|
committer | Ian Moffett <ian@osmora.org> | 2024-03-07 17:28:32 -0500 |
commit | bd5969fc876a10b18613302db7087ef3c40f18e1 (patch) | |
tree | 7c2b8619afe902abf99570df2873fbdf40a4d1a1 /lib/mlibc/sysdeps/lyre/generic | |
parent | a95b38b1b92b172e6cc4e8e56a88a30cc65907b0 (diff) |
lib: Add mlibc
Signed-off-by: Ian Moffett <ian@osmora.org>
Diffstat (limited to 'lib/mlibc/sysdeps/lyre/generic')
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/entry.cpp | 120 | ||||
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/generic.cpp | 860 | ||||
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/mntent.cpp | 97 | ||||
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/mount.cpp | 16 | ||||
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/reboot.cpp | 7 | ||||
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/thread.S | 9 | ||||
-rw-r--r-- | lib/mlibc/sysdeps/lyre/generic/thread.cpp | 58 |
7 files changed, 1167 insertions, 0 deletions
diff --git a/lib/mlibc/sysdeps/lyre/generic/entry.cpp b/lib/mlibc/sysdeps/lyre/generic/entry.cpp new file mode 100644 index 0000000..4fb0179 --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/entry.cpp @@ -0,0 +1,120 @@ +#include <stdint.h> +#include <stdlib.h> +#include <bits/ensure.h> +#include <mlibc/debug.hpp> +#include <mlibc/elf/startup.h> +#include <mlibc/all-sysdeps.hpp> +#include <bits/posix/posix_signal.h> +#include <lyre/syscall.h> + +// defined by the POSIX library +void __mlibc_initLocale(); + +extern "C" uintptr_t *__dlapi_entrystack(); + +extern char **environ; +static mlibc::exec_stack_data __mlibc_stack_data; + +struct LibraryGuard { + LibraryGuard(); +}; + +static LibraryGuard guard; + +LibraryGuard::LibraryGuard() { + __mlibc_initLocale(); + + // Parse the exec() stack. + mlibc::parse_exec_stack(__dlapi_entrystack(), &__mlibc_stack_data); + mlibc::set_startup_data(__mlibc_stack_data.argc, __mlibc_stack_data.argv, + __mlibc_stack_data.envp); +} + +struct GPRState { + uint64_t ds; + uint64_t es; + uint64_t rax; + uint64_t rbx; + uint64_t rcx; + uint64_t rdx; + uint64_t rsi; + uint64_t rdi; + uint64_t rbp; + uint64_t r8; + uint64_t r9; + uint64_t r10; + uint64_t r11; + uint64_t r12; + uint64_t r13; + uint64_t r14; + uint64_t r15; + uint64_t err; + uint64_t rip; + uint64_t cs; + uint64_t rflags; + uint64_t rsp; + uint64_t ss; +}; + +namespace mlibc { + int sys_sigentry(void *sigentry) { + __syscall_ret ret = __syscall(27, sigentry); + if (ret.errno != 0) + return ret.errno; + return 0; + } + + [[noreturn]] int sys_sigreturn(void *context, sigset_t old_mask) { + __syscall(30, context, old_mask); + __builtin_unreachable(); + } +} + +static void __mlibc_sigentry(int which, siginfo_t *siginfo, + void (*sa)(int, siginfo_t *, void *), + GPRState *ret_context, sigset_t prev_mask) { + +/* + size_t *base_ptr = (size_t *)ret_context->rbp; + + mlibc::infoLogger() << "Stacktrace:" << frg::endlog; + mlibc::infoLogger() << " [" << (void *)ret_context->rip << "]" << frg::endlog; + for (;;) { + size_t old_bp = base_ptr[0]; + size_t ret_addr = base_ptr[1]; + if (!ret_addr) + break; + size_t off; + mlibc::infoLogger() << " [" << (void *)ret_addr << "]" << frg::endlog; + if (!old_bp) + break; + base_ptr = (size_t *)old_bp; + } +*/ + + switch ((uintptr_t)sa) { + // DFL + case (uintptr_t)(-2): + mlibc::infoLogger() << "mlibc: Unhandled signal " << which << frg::endlog; + mlibc::sys_exit(128 + which); + // IGN + case (uintptr_t)(-3): + break; + default: + sa(which, siginfo, NULL); + break; + } + + mlibc::sys_sigreturn(ret_context, prev_mask); + + __builtin_unreachable(); +} + +extern "C" void __mlibc_entry(int (*main_fn)(int argc, char *argv[], char *env[])) { + //mlibc::sys_sigentry((void *)__mlibc_sigentry); + + // TODO: call __dlapi_enter, otherwise static builds will break (see Linux sysdeps) + auto result = main_fn(__mlibc_stack_data.argc, __mlibc_stack_data.argv, environ); + exit(result); +} + diff --git a/lib/mlibc/sysdeps/lyre/generic/generic.cpp b/lib/mlibc/sysdeps/lyre/generic/generic.cpp new file mode 100644 index 0000000..549e9f0 --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/generic.cpp @@ -0,0 +1,860 @@ +#include <bits/ensure.h> +#include <mlibc/allocator.hpp> +#include <mlibc/debug.hpp> +#include <mlibc/all-sysdeps.hpp> +#include <errno.h> +#include <dirent.h> +#include <fcntl.h> +#include <limits.h> +#include <asm/ioctls.h> +#include <stdlib.h> +#include <abi-bits/fcntl.h> +#include <lyre/syscall.h> +#include <frg/hash.hpp> +#include <frg/hash_map.hpp> + +#define STRINGIFY_(X) #X +#define STRINGIFY(X) STRINGIFY_(X) +#define STUB_ONLY { \ + sys_libc_log("STUB_ONLY function on line " STRINGIFY(__LINE__) " was called"); \ + sys_libc_panic(); \ +} + +namespace { + +int fcntl_helper(int fd, int request, int *result, ...) { + va_list args; + va_start(args, result); + if(!mlibc::sys_fcntl) { + return ENOSYS; + } + int ret = mlibc::sys_fcntl(fd, request, args, result); + va_end(args); + return ret; +} + +} + +namespace mlibc { + +void sys_libc_log(const char *message) { + __syscall(SYS_debug, message); +} + +void sys_libc_panic() { + sys_libc_log("\nMLIBC PANIC\n"); + sys_exit(1); + __builtin_unreachable(); +} + +void sys_exit(int status) { + __syscall(SYS_exit, status); + __builtin_unreachable(); +} + +#ifndef MLIBC_BUILDING_RTDL + +[[noreturn]] void sys_thread_exit() { + __syscall(SYS_exit_thread); + __builtin_unreachable(); +} + +extern "C" void __mlibc_thread_entry(); + +int sys_clone(void *tcb, pid_t *pid_out, void *stack) { + (void)tcb; + + __syscall_ret ret = __syscall(SYS_new_thread, (uintptr_t)__mlibc_thread_entry, (uintptr_t)stack); + int ret_value = (int)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + + *pid_out = ret_value; + return 0; +} + +int sys_kill(pid_t, int) STUB_ONLY + +int sys_tcgetattr(int fd, struct termios *attr) { + int ret; + if (int r = sys_ioctl(fd, TCGETS, attr, &ret) != 0) { + return r; + } + return 0; +} + +int sys_tcsetattr(int fd, int optional_action, const struct termios *attr) { + int ret; + switch (optional_action) { + case TCSANOW: + optional_action = TCSETS; break; + case TCSADRAIN: + optional_action = TCSETSW; break; + case TCSAFLUSH: + optional_action = TCSETSF; break; + default: + __ensure(!"Unsupported tcsetattr"); + } + + if (int r = sys_ioctl(fd, optional_action, (void *)attr, &ret) != 0) { + return r; + } + + return 0; +} + +#endif + +int sys_tcb_set(void *pointer) { + __syscall(SYS_set_fs_base, pointer); + return 0; +} + +#ifndef MLIBC_BUILDING_RTDL + +int sys_ppoll(struct pollfd *fds, int nfds, const struct timespec *timeout, const sigset_t *sigmask, int *num_events) { + __syscall_ret ret = __syscall(SYS_ppoll, fds, nfds, timeout, sigmask); + int ret_value = (int)ret.ret; + + if (ret_value == -1) + return ret.errno; + + *num_events = ret_value; + return 0; +} + +int sys_poll(struct pollfd *fds, nfds_t count, int timeout, int *num_events) { + struct timespec ts; + ts.tv_sec = timeout / 1000; + ts.tv_nsec = (timeout % 1000) * 1000000; + return sys_ppoll(fds, count, timeout < 0 ? NULL : &ts, NULL, num_events); +} + +int sys_epoll_pwait(int, struct epoll_event *, int, + int, const sigset_t *, int *) STUB_ONLY + +int sys_epoll_create(int, int *) STUB_ONLY + +int sys_epoll_ctl(int, int, int, struct epoll_event *) STUB_ONLY + +int sys_pselect(int nfds, fd_set *read_set, fd_set *write_set, + fd_set *except_set, const struct timespec *timeout, + const sigset_t *sigmask, int *num_events) { + struct pollfd *fds = (struct pollfd *)calloc(nfds, sizeof(struct pollfd)); + if (fds == NULL) { + return ENOMEM; + } + + for (int i = 0; i < nfds; i++) { + struct pollfd *fd = &fds[i]; + + if (read_set && FD_ISSET(i, read_set)) { + fd->events |= POLLIN; + } + if (write_set && FD_ISSET(i, write_set)) { + fd->events |= POLLOUT; + } + if (except_set && FD_ISSET(i, except_set)) { + fd->events |= POLLPRI; + } + + if (!fd->events) { + fd->fd = -1; + continue; + } + fd->fd = i; + } + + int ret = sys_ppoll(fds, nfds, timeout, sigmask, num_events); + if (ret != 0) { + free(fds); + return ret; + } + + fd_set res_read_set, res_write_set, res_except_set; + FD_ZERO(&res_read_set); + FD_ZERO(&res_write_set); + FD_ZERO(&res_except_set); + + for (int i = 0; i < nfds; i++) { + struct pollfd *fd = &fds[i]; + + if (read_set && FD_ISSET(i, read_set) && (fd->revents & (POLLIN | POLLERR | POLLHUP)) != 0) { + FD_SET(i, &res_read_set); + } + if (write_set && FD_ISSET(i, write_set) && (fd->revents & (POLLOUT | POLLERR | POLLHUP)) != 0) { + FD_SET(i, &res_write_set); + } + if (except_set && FD_ISSET(i, except_set) && (fd->revents & POLLPRI) != 0) { + FD_SET(i, &res_except_set); + } + } + + free(fds); + if (read_set) { + *read_set = res_read_set; + } + if (write_set) { + *write_set = res_write_set; + } + if (except_set) { + *except_set = res_except_set; + } + + return 0; +} + +#endif + +int sys_futex_wait(int *pointer, int expected, const struct timespec *time) { + __syscall_ret ret = __syscall(SYS_futex_wait, pointer, expected, time); + + if ((int)ret.ret == -1) + return ret.errno; + + return 0; +} + +int sys_futex_wake(int *pointer) { + __syscall_ret ret = __syscall(SYS_futex_wake, pointer); + + if ((int)ret.ret == -1) + return ret.errno; + + int num_woken = ret.ret; + + __ensure(num_woken >= 0 && num_woken <= 1); + return num_woken; +} + +#ifndef MLIBC_BUILDING_RTDL + +int sys_timerfd_create(int, int *) STUB_ONLY + +int sys_ioctl(int fd, unsigned long request, void *arg, int *result) { + __syscall_ret ret = __syscall(SYS_ioctl, fd, request, arg); + + if ((int)ret.ret == -1) + return ret.errno; + + *result = (int)ret.ret; + return 0; +} + +int sys_isatty(int fd) { + struct winsize ws; + int ret; + + if (!sys_ioctl(fd, TIOCGWINSZ, &ws, &ret)) + return 0; + + return ENOTTY; +} + +int sys_getcwd(char *buffer, size_t size) { + __syscall_ret ret = __syscall(SYS_getcwd, buffer, size); + + if ((int)ret.ret == -1) + return ret.errno; + + return 0; +} + +#endif + +int sys_openat(int dirfd, const char *path, int flags, mode_t mode, int *fd) { + __syscall_ret ret = __syscall(SYS_openat, dirfd, path, flags, mode); + + if ((int)ret.ret == -1) + return ret.errno; + + *fd = (int)ret.ret; + return 0; +} + +int sys_open(const char *path, int flags, mode_t mode, int *fd) { + return sys_openat(AT_FDCWD, path, flags, mode, fd); +} + +#ifndef MLIBC_BUILDING_RTDL + +int sys_open_dir(const char *path, int *handle) { + return sys_openat(AT_FDCWD, path, O_DIRECTORY, 0, handle); +} + +struct ReadDirState { + size_t offset; + size_t capacity; + void *buffer; +}; + +static frg::hash_map<int, ReadDirState *, frg::hash<int>, MemoryAllocator> open_dirs{frg::hash<int>{}, getAllocator()}; + +static ReadDirState *get_dir_state(int fdnum) { + ReadDirState *result; + if (auto value = open_dirs.get(fdnum)) { + result = *value; + } else { + result = (ReadDirState *)malloc(sizeof(ReadDirState)); + result->offset = 0; + result->capacity = 1024; + result->buffer = malloc(result->capacity); + open_dirs.insert(fdnum, result); + } + return result; +} + +int sys_read_entries(int fdnum, void *buffer, size_t max_size, size_t *bytes_read) { + ReadDirState *state = get_dir_state(fdnum); + +retry: + __syscall_ret ret = __syscall(SYS_readdir, fdnum, state->buffer, &state->capacity); + if ((int)ret.ret == -1) { + if (ret.errno == ENOBUFS) { + state->buffer = realloc(state->buffer, state->capacity); + goto retry; + } else { + return ret.errno; + } + } + + size_t offset = 0; + while (offset < max_size) { + struct dirent *ent = (struct dirent *)((char *)state->buffer + state->offset); + if (ent->d_reclen == 0) { + break; + } + + if (offset + ent->d_reclen >= max_size) { + break; + } + + memcpy((char *)buffer + offset, ent, ent->d_reclen); + offset += ent->d_reclen; + state->offset += ent->d_reclen; + } + + *bytes_read = offset; + return 0; +} + +#endif + +int sys_close(int fd) { + __syscall_ret ret = __syscall(SYS_close, fd); + if ((int)ret.ret == -1) { + return ret.errno; + } +#ifndef MLIBC_BUILDING_RTDL + open_dirs.remove(fd); +#endif + return 0; +} + +int sys_seek(int fd, off_t offset, int whence, off_t *new_offset) { + __syscall_ret ret = __syscall(SYS_seek, fd, offset, whence); + off_t ret_value = (off_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *new_offset = ret_value; + return 0; +} + +int sys_read(int fd, void *buf, size_t count, ssize_t *bytes_read) { + __syscall_ret ret = __syscall(SYS_read, fd, buf, count); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *bytes_read = ret_value; + return 0; +} + +#ifndef MLIBC_BUILDING_RTDL + +int sys_write(int fd, const void *buf, size_t count, ssize_t *bytes_written) { + __syscall_ret ret = __syscall(SYS_write, fd, buf, count); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *bytes_written = ret_value; + return 0; +} + +int sys_readlink(const char *path, void *data, size_t max_size, ssize_t *length) { + __syscall_ret ret = __syscall(SYS_readlinkat, AT_FDCWD, path, data, max_size); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *length = ret_value; + return 0; +} + +int sys_link(const char *old_path, const char *new_path) { + return sys_linkat(AT_FDCWD, old_path, AT_FDCWD, new_path, 0); +} + +int sys_linkat(int olddirfd, const char *old_path, int newdirfd, const char *new_path, int flags) { + __syscall_ret ret = __syscall(SYS_linkat, olddirfd, old_path, newdirfd, new_path, flags); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_unlinkat(int fd, const char *path, int flags) { + __syscall_ret ret = __syscall(SYS_unlinkat, fd, path, flags); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_fchmodat(int fd, const char *pathname, mode_t mode, int flags) { + __syscall_ret ret = __syscall(SYS_fchmodat, fd, pathname, mode, flags); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_fchmod(int fd, mode_t mode) { + return sys_fchmodat(fd, "", mode, AT_EMPTY_PATH); +} + +int sys_chmod(const char *pathname, mode_t mode) { + return sys_fchmodat(AT_FDCWD, pathname, mode, 0); +} + +int sys_rmdir(const char *) STUB_ONLY + +#endif + +int sys_vm_map(void *hint, size_t size, int prot, int flags, + int fd, off_t offset, void **window) { + __syscall_ret ret = __syscall(SYS_mmap, hint, size, (uint64_t)prot << 32 | flags, fd, offset); + void *ret_value = (void *)ret.ret; + if (ret_value == MAP_FAILED) { + return ret.errno; + } + *window = ret_value; + return 0; +} + +int sys_vm_unmap(void *pointer, size_t size) { + __syscall_ret ret = __syscall(SYS_unmmap, pointer, size); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +#ifndef MLIBC_BUILDING_RTDL + +int sys_vm_protect(void *pointer, size_t size, int prot) { + __syscall_ret ret = __syscall(SYS_mprotect, pointer, size, prot); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +#endif + +int sys_anon_allocate(size_t size, void **pointer) { + return sys_vm_map(NULL, size, PROT_READ | PROT_WRITE, MAP_ANONYMOUS, -1, 0, pointer); +} + +int sys_anon_free(void *pointer, size_t size) { + return sys_vm_unmap(pointer, size); +} + +#ifndef MLIBC_BUILDING_RTDL + +pid_t sys_getpid() { + __syscall_ret ret = __syscall(SYS_getpid); + return (pid_t)ret.ret; +} + +pid_t sys_getppid() { + return 0; +} + +uid_t sys_getuid() { + return 0; +} + +uid_t sys_geteuid() { + return 0; +} + +gid_t sys_getgid() { + return 0; +} + +int sys_setgid(gid_t) { + return 0; +} + +int sys_getpgid(pid_t, pid_t *) { + return 0; +} + +gid_t sys_getegid() { + return 0; +} + +int sys_setpgid(pid_t, pid_t) { + return 0; +} + +int sys_ttyname(int, char *, size_t) { + return ENOSYS; +} + +int sys_clock_get(int clock, time_t *secs, long *nanos) { + struct timespec buf; + __syscall_ret ret = __syscall(SYS_getclock, clock, &buf); + if ((int)ret.ret == -1) { + return ret.errno; + } + *secs = buf.tv_sec; + *nanos = buf.tv_nsec; + return 0; +} + +int sys_stat(fsfd_target fsfdt, int fd, const char *path, int flags, struct stat *statbuf) { + __syscall_ret ret; + switch (fsfdt) { + case fsfd_target::fd: + ret = __syscall(SYS_stat, fd, "", flags | AT_EMPTY_PATH, statbuf); + break; + case fsfd_target::path: + ret = __syscall(SYS_stat, AT_FDCWD, path, flags, statbuf); + break; + case fsfd_target::fd_path: + ret = __syscall(SYS_stat, fd, path, flags, statbuf); + break; + default: + __ensure(!"sys_stat: Invalid fsfdt"); + __builtin_unreachable(); + } + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_faccessat(int dirfd, const char *pathname, int mode, int flags) { + (void)flags; + struct stat buf; + if (int r = sys_stat(fsfd_target::fd_path, dirfd, pathname, mode & AT_SYMLINK_FOLLOW, &buf)) { + return r; + } + return 0; +} + +int sys_access(const char *path, int mode) { + return sys_faccessat(AT_FDCWD, path, mode, 0); +} + +int sys_pipe(int *fds, int flags) { + __syscall_ret ret = __syscall(SYS_pipe, fds, flags); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_chdir(const char *path) { + __syscall_ret ret = __syscall(SYS_chdir, path); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_mkdir(const char *path, mode_t mode) { + return sys_mkdirat(AT_FDCWD, path, mode); +} + +int sys_mkdirat(int dirfd, const char *path, mode_t mode) { + __syscall_ret ret = __syscall(SYS_mkdirat, dirfd, path, mode); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_socket(int domain, int type_and_flags, int proto, int *fd) { + __syscall_ret ret = __syscall(SYS_socket, domain, type_and_flags, proto); + int ret_value = (int)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *fd = ret_value; + return 0; +} + +int sys_socketpair(int domain, int type_and_flags, int proto, int *fds) { + __syscall_ret ret = __syscall(SYS_socketpair, domain, type_and_flags, proto, fds); + int ret_value = (int)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + return 0; +} + +int sys_bind(int fd, const struct sockaddr *addr_ptr, socklen_t addr_length) { + __syscall_ret ret = __syscall(SYS_bind, fd, addr_ptr, addr_length); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_connect(int fd, const struct sockaddr *addr_ptr, socklen_t addr_length) { + __syscall_ret ret = __syscall(SYS_connect, fd, addr_ptr, addr_length); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_accept(int fd, int *newfd, struct sockaddr *addr_ptr, socklen_t *addr_length, int flags) { + __syscall_ret ret = __syscall(SYS_accept, fd, addr_ptr, addr_length); + int ret_value = (int)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *newfd = ret_value; + + if(flags & SOCK_NONBLOCK) { + int fcntl_ret = 0; + fcntl_helper(*newfd, F_GETFL, &fcntl_ret); + fcntl_helper(*newfd, F_SETFL, &fcntl_ret, fcntl_ret | O_NONBLOCK); + } + + if(flags & SOCK_CLOEXEC) { + int fcntl_ret = 0; + fcntl_helper(*newfd, F_GETFD, &fcntl_ret); + fcntl_helper(*newfd, F_SETFD, &fcntl_ret, fcntl_ret | FD_CLOEXEC); + } + + return 0; +} + +int sys_getsockopt(int fd, int layer, int number, void *__restrict buffer, socklen_t *__restrict size) { + __syscall_ret ret = __syscall(SYS_getsockopt, fd, layer, number, buffer, size); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + return 0; +} + +int sys_setsockopt(int fd, int layer, int number, const void *buffer, socklen_t size) { + __syscall_ret ret = __syscall(SYS_setsockopt, fd, layer, number, buffer, size); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + return 0; +} + +int sys_msg_recv(int sockfd, struct msghdr *hdr, int flags, ssize_t *length) { + __syscall_ret ret = __syscall(SYS_recvmsg, sockfd, hdr, flags); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *length = ret_value; + return 0; +} + +int sys_msg_send(int sockfd, const struct msghdr *hdr, int flags, ssize_t *length) { + __syscall_ret ret = __syscall(SYS_sendmsg, sockfd, hdr, flags); + ssize_t ret_value = (ssize_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *length = ret_value; + return 0; +} + +int sys_peername(int fd, struct sockaddr *addr_ptr, socklen_t max_addr_length, socklen_t *actual_length) { + __syscall_ret ret = __syscall(SYS_getpeername, fd, addr_ptr, &max_addr_length); + if ((int)ret.ret == -1) { + return ret.errno; + } + *actual_length = max_addr_length; + return 0; +} + +int sys_sockname(int fd, struct sockaddr *addr_ptr, socklen_t max_addr_length, socklen_t *actual_length) { + __syscall_ret ret = __syscall(SYS_getsockname, fd, addr_ptr, &max_addr_length); + if ((int)ret.ret == -1) { + return ret.errno; + } + *actual_length = max_addr_length; + return 0; +} + +int sys_listen(int fd, int backlog) { + __syscall_ret ret = __syscall(SYS_listen, fd, backlog); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_inotify_create(int, int *) { + mlibc::infoLogger() << "mlibc: sys_inotify_create() is unimplemented" << frg::endlog; + return ENOSYS; +} + +int sys_fork(pid_t *child) { + __syscall_ret ret = __syscall(SYS_fork); + pid_t ret_value = (pid_t)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *child = ret_value; + return 0; +} + +int sys_execve(const char *path, char *const argv[], char *const envp[]) { + __syscall_ret ret = __syscall(SYS_exec, path, argv, envp); + return ret.errno; +} + +int sys_fcntl(int fd, int request, va_list args, int *result) { + __syscall_ret ret = __syscall(SYS_fcntl, fd, request, va_arg(args, uint64_t)); + int ret_value = (int)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *result = ret_value; + return 0; +} + +int sys_dup(int fd, int flags, int *newfd) { + (void)flags; + __syscall_ret ret = __syscall(SYS_fcntl, fd, F_DUPFD, 0); + int ret_value = (int)ret.ret; + if (ret_value == -1) { + return ret.errno; + } + *newfd = ret_value; + return 0; +} + +int sys_dup2(int fd, int flags, int newfd) { + __syscall_ret ret = __syscall(SYS_dup3, fd, newfd, flags); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_sigprocmask(int, const sigset_t *__restrict, sigset_t *__restrict) { + mlibc::infoLogger() << "mlibc: sys_sigprocmask() is a stub" << frg::endlog; + return 0; +} + +int sys_sigaction(int, const struct sigaction *, struct sigaction *) { + mlibc::infoLogger() << "mlibc: sys_sigaction() is a stub" << frg::endlog; + return 0; +} + +int sys_signalfd_create(sigset_t, int, int *) STUB_ONLY + +int sys_waitpid(pid_t pid, int *status, int flags, struct rusage *ru, pid_t *ret_pid) { + if (ru != NULL) { + mlibc::infoLogger() << "mlibc: struct rusage in sys_waitpid is unsupported" << frg::endlog; + return ENOSYS; + } +again: + __syscall_ret ret = __syscall(SYS_waitpid, pid, status, flags); + pid_t ret_value = (pid_t)ret.ret; + if (ret_value == -1) { + if (ret.errno == EINTR) { + goto again; + } + return ret.errno; + } + *ret_pid = ret_value; + return 0; +} + +int sys_getgroups(size_t, const gid_t *, int *) { + mlibc::infoLogger() << "mlibc: sys_getgroups() is unimplemented" << frg::endlog; + return ENOSYS; +} + +int sys_mount(const char *, const char *, const char *, unsigned long, const void *) STUB_ONLY + +int sys_umount2(const char *, int) STUB_ONLY + +int sys_gethostname(char *buffer, size_t bufsize) { + struct utsname utsname; + if (int err = sys_uname(&utsname)) { + return err; + } + if (strlen(utsname.nodename) >= bufsize) { + return ENAMETOOLONG; + } + strncpy(buffer, utsname.nodename, bufsize); + return 0; +} + +int sys_sethostname(const char *, size_t) STUB_ONLY + +int sys_sleep(time_t *secs, long *nanos) { + struct timespec time = {.tv_sec = *secs, .tv_nsec = *nanos}; + struct timespec rem = {.tv_sec = 0, .tv_nsec = 0}; + __syscall_ret ret = __syscall(SYS_sleep, &time, &rem); + if ((int)ret.ret == -1) { + return ret.errno; + } + *secs = rem.tv_sec; + *nanos = rem.tv_nsec; + return 0; +} + +int sys_getitimer(int, struct itimerval *) { + mlibc::infoLogger() << "mlibc: sys_getitimer() is unimplemented" << frg::endlog; + return ENOSYS; +} + +int sys_setitimer(int, const struct itimerval *, struct itimerval *) { + mlibc::infoLogger() << "mlibc: sys_setitimer() is unimplemented" << frg::endlog; + return ENOSYS; +} + +int sys_umask(mode_t mode, mode_t *old) { + __syscall_ret ret = __syscall(SYS_umask, mode); + *old = (mode_t)ret.ret; + return 0; +} + +int sys_uname(struct utsname *buf) { + __syscall_ret ret = __syscall(SYS_uname, buf); + if ((int)ret.ret == -1) { + return ret.errno; + } + return 0; +} + +int sys_fsync(int) { + mlibc::infoLogger() << "sys_fsync is a stub" << frg::endlog; + return 0; +} + +#endif + +} // namespace mlibc diff --git a/lib/mlibc/sysdeps/lyre/generic/mntent.cpp b/lib/mlibc/sysdeps/lyre/generic/mntent.cpp new file mode 100644 index 0000000..d064af3 --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/mntent.cpp @@ -0,0 +1,97 @@ +#include <errno.h> +#include <mntent.h> +#include <stdio.h> +#include <limits.h> +#include <string.h> +#include <bits/ensure.h> + +namespace { + +char *internal_buf; +size_t internal_bufsize; + +} + +#define SENTINEL (char *)&internal_buf + +FILE *setmntent(const char *name, const char *mode) { + return fopen(name, mode); +} + +struct mntent *getmntent(FILE *f) { + static struct mntent mnt; + return getmntent_r(f, &mnt, SENTINEL, 0); +} + +int addmntent(FILE *f, const struct mntent *mnt) { + if(fseek(f, 0, SEEK_END)) { + return 1; + } + return fprintf(f, "%s\t%s\t%s\t%s\t%d\t%d\n", + mnt->mnt_fsname, mnt->mnt_dir, mnt->mnt_type, mnt->mnt_opts, + mnt->mnt_freq, mnt->mnt_passno) < 0; +} + +int endmntent(FILE *f) { + if(f) { + fclose(f); + } + return 1; +} + +char *hasmntopt(const struct mntent *mnt, const char *opt) { + return strstr(mnt->mnt_opts, opt); +} + +/* Adapted from musl */ +struct mntent *getmntent_r(FILE *f, struct mntent *mnt, char *linebuf, int buflen) { + int n[8]; + bool use_internal = (linebuf == SENTINEL); + int len; + size_t i; + + mnt->mnt_freq = 0; + mnt->mnt_passno = 0; + + do { + if(use_internal) { + getline(&internal_buf, &internal_bufsize, f); + linebuf = internal_buf; + } else { + fgets(linebuf, buflen, f); + } + if(feof(f) || ferror(f)) { + return 0; + } + if(!strchr(linebuf, '\n')) { + fscanf(f, "%*[^\n]%*[\n]"); + errno = ERANGE; + return 0; + } + + len = strlen(linebuf); + if(len > INT_MAX) { + continue; + } + + for(i = 0; i < sizeof n / sizeof *n; i++) { + n[i] = len; + } + + sscanf(linebuf, " %n%*s%n %n%*s%n %n%*s%n %n%*s%n %d %d", + n, n + 1, n + 2, n + 3, n + 4, n + 5, n + 6, n + 7, + &mnt->mnt_freq, &mnt->mnt_passno); + } while(linebuf[n[0]] == '#' || n[1] == len); + + linebuf[n[1]] = 0; + linebuf[n[3]] = 0; + linebuf[n[5]] = 0; + linebuf[n[7]] = 0; + + mnt->mnt_fsname = linebuf + n[0]; + mnt->mnt_dir = linebuf + n[2]; + mnt->mnt_type = linebuf + n[4]; + mnt->mnt_opts = linebuf + n[6]; + + return mnt; +} diff --git a/lib/mlibc/sysdeps/lyre/generic/mount.cpp b/lib/mlibc/sysdeps/lyre/generic/mount.cpp new file mode 100644 index 0000000..f10254d --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/mount.cpp @@ -0,0 +1,16 @@ +#include <errno.h> +#include <sys/mount.h> +#include <bits/ensure.h> + +int mount(const char *source, const char *target, + const char *fstype, unsigned long flags, const void *data) { + return 0; +} + +int umount(const char *target) { + return umount2(target, 0); +} + +int umount2(const char *target, int flags) { + return 0; +} diff --git a/lib/mlibc/sysdeps/lyre/generic/reboot.cpp b/lib/mlibc/sysdeps/lyre/generic/reboot.cpp new file mode 100644 index 0000000..7c86ffd --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/reboot.cpp @@ -0,0 +1,7 @@ +#include <errno.h> +#include <sys/reboot.h> +#include <bits/ensure.h> + +int reboot(int what) { + return 0; +} diff --git a/lib/mlibc/sysdeps/lyre/generic/thread.S b/lib/mlibc/sysdeps/lyre/generic/thread.S new file mode 100644 index 0000000..47ab6a9 --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/thread.S @@ -0,0 +1,9 @@ +.section .text +.global __mlibc_thread_entry +__mlibc_thread_entry: + pop %rdi + pop %rsi + pop %rdx + call __mlibc_thread_trampoline + +.section .note.GNU-stack,"",%progbits diff --git a/lib/mlibc/sysdeps/lyre/generic/thread.cpp b/lib/mlibc/sysdeps/lyre/generic/thread.cpp new file mode 100644 index 0000000..5186e1f --- /dev/null +++ b/lib/mlibc/sysdeps/lyre/generic/thread.cpp @@ -0,0 +1,58 @@ +#include <sys/mman.h> +#include <mlibc/debug.hpp> +#include <errno.h> +#include <mlibc/all-sysdeps.hpp> +#include <bits/ensure.h> +#include <mlibc/tcb.hpp> + +extern "C" void __mlibc_thread_trampoline(void *(*fn)(void *), Tcb *tcb, void *arg) { + if (mlibc::sys_tcb_set(tcb)) { + __ensure(!"failed to set tcb for new thread"); + } + + while (__atomic_load_n(&tcb->tid, __ATOMIC_RELAXED) == 0) { + mlibc::sys_futex_wait(&tcb->tid, 0, nullptr); + } + + tcb->invokeThreadFunc(reinterpret_cast<void *>(fn), arg); + + __atomic_store_n(&tcb->didExit, 1, __ATOMIC_RELEASE); + mlibc::sys_futex_wake(&tcb->didExit); + + mlibc::sys_thread_exit(); +} + +#define DEFAULT_STACK 0x400000 + +namespace mlibc { + int sys_prepare_stack(void **stack, void *entry, void *arg, void *tcb, size_t *stack_size, size_t *guard_size, void **stack_base) { + // TODO guard + + mlibc::infoLogger() << "mlibc: sys_prepare_stack() does not setup a guard!" << frg::endlog; + + *guard_size = 0; + + *stack_size = *stack_size ? *stack_size : DEFAULT_STACK; + + if (!*stack) { + *stack_base = mmap(NULL, *stack_size, PROT_READ | PROT_WRITE, MAP_ANONYMOUS | MAP_PRIVATE, -1, 0); + if (*stack_base == MAP_FAILED) { + return errno; + } + } else { + *stack_base = *stack; + } + + *stack = (void *)((char *)*stack_base + *stack_size); + + void **stack_it = (void **)*stack; + + *--stack_it = arg; + *--stack_it = tcb; + *--stack_it = entry; + + *stack = (void *)stack_it; + + return 0; + } +} |