[d384787] | 1 | // |
---|
| 2 | // Cforall Version 1.0.0 Copyright (C) 2020 University of Waterloo |
---|
| 3 | // |
---|
| 4 | // The contents of this file are covered under the licence agreement in the |
---|
| 5 | // file "LICENCE" distributed with Cforall. |
---|
| 6 | // |
---|
| 7 | // iofwd.hfa -- |
---|
| 8 | // |
---|
| 9 | // Author : Thierry Delisle |
---|
| 10 | // Created On : Thu Apr 23 17:31:00 2020 |
---|
[a0a949c] | 11 | // Last Modified By : Peter A. Buhr |
---|
[374cdb66] | 12 | // Last Modified On : Fri Jul 21 20:35:53 2023 |
---|
| 13 | // Update Count : 2 |
---|
[d384787] | 14 | // |
---|
| 15 | |
---|
| 16 | #pragma once |
---|
| 17 | |
---|
[519f11c] | 18 | #include <unistd.h> |
---|
[2d028003] | 19 | #include <sys/socket.h> |
---|
[f5f2768] | 20 | |
---|
[e1801fc] | 21 | extern "C" { |
---|
[44f09ea] | 22 | #include <asm/types.h> |
---|
[93829cb] | 23 | #include <sys/stat.h> // needed for mode_t |
---|
[f00b26d4] | 24 | #if CFA_HAVE_LINUX_IO_URING_H |
---|
| 25 | #include <linux/io_uring.h> |
---|
| 26 | #endif |
---|
[e1801fc] | 27 | } |
---|
[519f11c] | 28 | #include "bits/defs.hfa" |
---|
[40a606d2] | 29 | #include "kernel/fwd.hfa" |
---|
[f00b26d4] | 30 | #include "time.hfa" |
---|
| 31 | |
---|
| 32 | #if defined(CFA_HAVE_IOSQE_FIXED_FILE) |
---|
| 33 | #define CFA_IO_FIXED_FD1 IOSQE_FIXED_FILE |
---|
| 34 | #endif |
---|
| 35 | #if defined(CFA_HAVE_SPLICE_F_FD_IN_FIXED) |
---|
| 36 | #define CFA_IO_FIXED_FD2 SPLICE_F_FD_IN_FIXED |
---|
| 37 | #endif |
---|
| 38 | #if defined(CFA_HAVE_IOSQE_IO_DRAIN) |
---|
| 39 | #define CFA_IO_DRAIN IOSQE_IO_DRAIN |
---|
| 40 | #endif |
---|
| 41 | #if defined(CFA_HAVE_IOSQE_ASYNC) |
---|
| 42 | #define CFA_IO_ASYNC IOSQE_ASYNC |
---|
| 43 | #endif |
---|
| 44 | |
---|
[6d1790c] | 45 | #if __OFF_T_MATCHES_OFF64_T |
---|
| 46 | typedef __off64_t off_t; |
---|
| 47 | #else |
---|
| 48 | typedef __off_t off_t; |
---|
| 49 | #endif |
---|
| 50 | typedef __off64_t off64_t; |
---|
| 51 | |
---|
[78da4ab] | 52 | struct epoll_event; |
---|
| 53 | |
---|
[40a606d2] | 54 | //----------------------------------------------------------------------- |
---|
| 55 | // IO user data |
---|
| 56 | struct io_future_t { |
---|
| 57 | future_t self; |
---|
| 58 | __s32 result; |
---|
| 59 | }; |
---|
| 60 | |
---|
| 61 | static inline { |
---|
| 62 | thread$ * fulfil( io_future_t & this, __s32 result, bool do_unpark = true ) { |
---|
| 63 | this.result = result; |
---|
| 64 | return fulfil(this.self, do_unpark); |
---|
| 65 | } |
---|
| 66 | |
---|
| 67 | // Wait for the future to be fulfilled |
---|
| 68 | bool wait ( io_future_t & this ) { return wait (this.self); } |
---|
| 69 | void reset ( io_future_t & this ) { return reset (this.self); } |
---|
| 70 | bool available( io_future_t & this ) { return available(this.self); } |
---|
[f3da205] | 71 | bool setup ( io_future_t & this, oneshot & ctx ) { return setup (this.self, ctx); } |
---|
| 72 | bool retract ( io_future_t & this, oneshot & ctx ) { return retract(this.self, ctx); } |
---|
[40a606d2] | 73 | } |
---|
| 74 | |
---|
[78da4ab] | 75 | //---------- |
---|
| 76 | // underlying calls |
---|
[8bee858] | 77 | extern struct io_context$ * cfa_io_allocate(struct io_uring_sqe * out_sqes[], __u32 out_idxs[], __u32 want) __attribute__((nonnull (1,2))); |
---|
| 78 | extern void cfa_io_submit( struct io_context$ * in_ctx, __u32 in_idxs[], __u32 have, bool lazy ) __attribute__((nonnull (1,2))); |
---|
[e1801fc] | 79 | |
---|
[c402739f] | 80 | //---------- |
---|
| 81 | // synchronous calls |
---|
| 82 | #if defined(CFA_HAVE_PREADV2) |
---|
[a0a949c] | 83 | extern ssize_t cfa_preadv2(int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags, __u64 submit_flags); |
---|
[c402739f] | 84 | #endif |
---|
| 85 | #if defined(CFA_HAVE_PWRITEV2) |
---|
[a0a949c] | 86 | extern ssize_t cfa_pwritev2(int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags, __u64 submit_flags); |
---|
[c402739f] | 87 | #endif |
---|
[dddb3dd0] | 88 | extern int cfa_fsync(int fd, __u64 submit_flags); |
---|
[a0a949c] | 89 | extern int cfa_epoll_ctl(int epfd, int op, int fd, struct epoll_event * event, __u64 submit_flags); |
---|
[dddb3dd0] | 90 | extern int cfa_sync_file_range(int fd, off64_t offset, off64_t nbytes, unsigned int flags, __u64 submit_flags); |
---|
[a0a949c] | 91 | extern ssize_t cfa_sendmsg(int sockfd, const struct msghdr * msg, int flags, __u64 submit_flags); |
---|
| 92 | extern ssize_t cfa_recvmsg(int sockfd, struct msghdr * msg, int flags, __u64 submit_flags); |
---|
| 93 | extern ssize_t cfa_send(int sockfd, const void * buf, size_t len, int flags, __u64 submit_flags); |
---|
| 94 | extern ssize_t cfa_recv(int sockfd, void * buf, size_t len, int flags, __u64 submit_flags); |
---|
[f5f2768] | 95 | extern int cfa_accept4(int sockfd, __SOCKADDR_ARG addr, socklen_t * restrict addrlen, int flags, __u64 submit_flags); |
---|
| 96 | extern int cfa_connect(int sockfd, __CONST_SOCKADDR_ARG addr, socklen_t addrlen, __u64 submit_flags); |
---|
[dddb3dd0] | 97 | extern int cfa_fallocate(int fd, int mode, off_t offset, off_t len, __u64 submit_flags); |
---|
| 98 | extern int cfa_posix_fadvise(int fd, off_t offset, off_t len, int advice, __u64 submit_flags); |
---|
[a0a949c] | 99 | extern int cfa_madvise(void * addr, size_t length, int advice, __u64 submit_flags); |
---|
| 100 | extern int cfa_openat(int dirfd, const char * pathname, int flags, mode_t mode, __u64 submit_flags); |
---|
[c402739f] | 101 | #if defined(CFA_HAVE_OPENAT2) |
---|
[a0a949c] | 102 | extern int cfa_openat2(int dirfd, const char * pathname, struct open_how * how, size_t size, __u64 submit_flags); |
---|
[c402739f] | 103 | #endif |
---|
[dddb3dd0] | 104 | extern int cfa_close(int fd, __u64 submit_flags); |
---|
[c402739f] | 105 | #if defined(CFA_HAVE_STATX) |
---|
[a0a949c] | 106 | extern int cfa_statx(int dirfd, const char * pathname, int flags, unsigned int mask, struct statx * statxbuf, __u64 submit_flags); |
---|
[c402739f] | 107 | #endif |
---|
[dddb3dd0] | 108 | extern ssize_t cfa_read(int fd, void * buf, size_t count, __u64 submit_flags); |
---|
| 109 | extern ssize_t cfa_write(int fd, void * buf, size_t count, __u64 submit_flags); |
---|
[a0a949c] | 110 | extern ssize_t cfa_splice(int fd_in, __off64_t * off_in, int fd_out, __off64_t * off_out, size_t len, unsigned int flags, __u64 submit_flags); |
---|
[dddb3dd0] | 111 | extern ssize_t cfa_tee(int fd_in, int fd_out, size_t len, unsigned int flags, __u64 submit_flags); |
---|
[c402739f] | 112 | |
---|
| 113 | //---------- |
---|
| 114 | // asynchronous calls |
---|
| 115 | #if defined(CFA_HAVE_PREADV2) |
---|
[a0a949c] | 116 | extern void async_preadv2(io_future_t & future, int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags, __u64 submit_flags); |
---|
[c402739f] | 117 | #endif |
---|
| 118 | #if defined(CFA_HAVE_PWRITEV2) |
---|
[a0a949c] | 119 | extern void async_pwritev2(io_future_t & future, int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags, __u64 submit_flags); |
---|
[c402739f] | 120 | #endif |
---|
[dddb3dd0] | 121 | extern void async_fsync(io_future_t & future, int fd, __u64 submit_flags); |
---|
[a0a949c] | 122 | extern void async_epoll_ctl(io_future_t & future, int epfd, int op, int fd, struct epoll_event * event, __u64 submit_flags); |
---|
[dddb3dd0] | 123 | extern void async_sync_file_range(io_future_t & future, int fd, off64_t offset, off64_t nbytes, unsigned int flags, __u64 submit_flags); |
---|
[a0a949c] | 124 | extern void async_sendmsg(io_future_t & future, int sockfd, const struct msghdr * msg, int flags, __u64 submit_flags); |
---|
| 125 | extern void async_recvmsg(io_future_t & future, int sockfd, struct msghdr * msg, int flags, __u64 submit_flags); |
---|
| 126 | extern void async_send(io_future_t & future, int sockfd, const void * buf, size_t len, int flags, __u64 submit_flags); |
---|
| 127 | extern void async_recv(io_future_t & future, int sockfd, void * buf, size_t len, int flags, __u64 submit_flags); |
---|
[f5f2768] | 128 | extern void async_accept4(io_future_t & future, int sockfd, __SOCKADDR_ARG addr, socklen_t * restrict addrlen, int flags, __u64 submit_flags); |
---|
| 129 | extern void async_connect(io_future_t & future, int sockfd, __CONST_SOCKADDR_ARG addr, socklen_t addrlen, __u64 submit_flags); |
---|
[dddb3dd0] | 130 | extern void async_fallocate(io_future_t & future, int fd, int mode, off_t offset, off_t len, __u64 submit_flags); |
---|
| 131 | extern void async_posix_fadvise(io_future_t & future, int fd, off_t offset, off_t len, int advice, __u64 submit_flags); |
---|
[a0a949c] | 132 | extern void async_madvise(io_future_t & future, void * addr, size_t length, int advice, __u64 submit_flags); |
---|
| 133 | extern void async_openat(io_future_t & future, int dirfd, const char * pathname, int flags, mode_t mode, __u64 submit_flags); |
---|
[c402739f] | 134 | #if defined(CFA_HAVE_OPENAT2) |
---|
[a0a949c] | 135 | extern void async_openat2(io_future_t & future, int dirfd, const char * pathname, struct open_how * how, size_t size, __u64 submit_flags); |
---|
[c402739f] | 136 | #endif |
---|
[dddb3dd0] | 137 | extern void async_close(io_future_t & future, int fd, __u64 submit_flags); |
---|
[c402739f] | 138 | #if defined(CFA_HAVE_STATX) |
---|
[a0a949c] | 139 | extern void async_statx(io_future_t & future, int dirfd, const char * pathname, int flags, unsigned int mask, struct statx * statxbuf, __u64 submit_flags); |
---|
[c402739f] | 140 | #endif |
---|
[dddb3dd0] | 141 | void async_read(io_future_t & future, int fd, void * buf, size_t count, __u64 submit_flags); |
---|
| 142 | extern void async_write(io_future_t & future, int fd, void * buf, size_t count, __u64 submit_flags); |
---|
[a0a949c] | 143 | extern void async_splice(io_future_t & future, int fd_in, __off64_t * off_in, int fd_out, __off64_t * off_out, size_t len, unsigned int flags, __u64 submit_flags); |
---|
[dddb3dd0] | 144 | extern void async_tee(io_future_t & future, int fd_in, int fd_out, size_t len, unsigned int flags, __u64 submit_flags); |
---|
[c402739f] | 145 | |
---|
[d384787] | 146 | |
---|
| 147 | //----------------------------------------------------------------------------- |
---|
| 148 | // Check if a function is blocks a only the user thread |
---|
[93829cb] | 149 | bool has_user_level_blocking( fptr_t func ); |
---|
| 150 | |
---|
| 151 | #if CFA_HAVE_LINUX_IO_URING_H |
---|
| 152 | static inline void zero_sqe(struct io_uring_sqe * sqe) { |
---|
[374cdb66] | 153 | memset( sqe, 0, sizeof( struct io_uring_sqe ) ); |
---|
[93829cb] | 154 | } |
---|
[f5f2768] | 155 | #endif |
---|