Changes in / [d800676:18ea270]

Location:

libcfa/src/concurrency

Files:

• io.cfa (modified) (1 diff)
• io/call.cfa.in (modified) (11 diffs)

libcfa/src/concurrency/io.cfa

@@ -295 +295 @@
                                 // make sure the target hasn't stopped existing since last time
                                 HELP: if(target < ctxs_count) {
-                                        // calculate it's age and how young it could be before we give up on helping
+                                        // calculate it's age and how young it could be before we give ip on helping
                                         const __readyQ_avg_t cutoff = calc_cutoff(ctsc, ctx->cq.id, ctxs_count, io.data, io.tscs, __shard_factor.io, false);
                                         const __readyQ_avg_t age = moving_average(ctsc, io.tscs[target].t.tv, io.tscs[target].t.ma, false);

libcfa/src/concurrency/io/call.cfa.in

@@ -89 +89 @@
 #if defined(CFA_HAVE_PREADV2)
         struct iovec;
-        extern ssize_t preadv2 (int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags);
+        extern ssize_t preadv2 (int fd, const struct iovec *iov, int iovcnt, off_t offset, int flags);
 #endif
 #if defined(CFA_HAVE_PWRITEV2)
         struct iovec;
-        extern ssize_t pwritev2(int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags);
+        extern ssize_t pwritev2(int fd, const struct iovec *iov, int iovcnt, off_t offset, int flags);
 #endif
 
@@ -108 +108 @@
         struct msghdr;
         struct sockaddr;
-        extern ssize_t sendmsg(int sockfd, const struct msghdr * msg, int flags);
-        extern ssize_t recvmsg(int sockfd, struct msghdr * msg, int flags);
-        extern ssize_t send(int sockfd, const void * buf, size_t len, int flags);
-        extern ssize_t recv(int sockfd, void * buf, size_t len, int flags);
+        extern ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags);
+        extern ssize_t recvmsg(int sockfd, struct msghdr *msg, int flags);
+        extern ssize_t send(int sockfd, const void *buf, size_t len, int flags);
+        extern ssize_t recv(int sockfd, void *buf, size_t len, int flags);
 
         extern int fallocate(int fd, int mode, off_t offset, off_t len);
         extern int posix_fadvise(int fd, off_t offset, off_t len, int advice);
-        extern int madvise(void * addr, size_t length, int advice);
-
-        extern int openat(int dirfd, const char * pathname, int flags, mode_t mode);
+        extern int madvise(void *addr, size_t length, int advice);
+
+        extern int openat(int dirfd, const char *pathname, int flags, mode_t mode);
         extern int close(int fd);
 
-        extern ssize_t read (int fd, void * buf, size_t count);
+        extern ssize_t read (int fd, void *buf, size_t count);
 
         struct epoll_event;
-        extern int epoll_ctl(int epfd, int op, int fd, struct epoll_event * event);
-
-        extern ssize_t splice(int fd_in, __off64_t * off_in, int fd_out, __off64_t * off_out, size_t len, unsigned int flags);
+        extern int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
+
+        extern ssize_t splice(int fd_in, __off64_t *off_in, int fd_out, __off64_t *off_out, size_t len, unsigned int flags);
         extern ssize_t tee(int fd_in, int fd_out, size_t len, unsigned int flags);
 }
@@ -224 +224 @@
 calls = [
         # CFA_HAVE_IORING_OP_READV
-        Call('READV', 'ssize_t preadv2(int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags)', {
+        Call('READV', 'ssize_t preadv2(int fd, const struct iovec *iov, int iovcnt, off_t offset, int flags)', {
                 'fd'  : 'fd',
-                'addr': '(typeof(sqe->addr))iov',
+                'off' : 'offset',
+                'addr': '(uintptr_t)iov',
                 'len' : 'iovcnt',
-                'off' : 'offset',
-                'rw_flags' : 'flags'
         }, define = 'CFA_HAVE_PREADV2'),
         # CFA_HAVE_IORING_OP_WRITEV
-        Call('WRITEV', 'ssize_t pwritev2(int fd, const struct iovec * iov, int iovcnt, off_t offset, int flags)', {
+        Call('WRITEV', 'ssize_t pwritev2(int fd, const struct iovec *iov, int iovcnt, off_t offset, int flags)', {
                 'fd'  : 'fd',
-                'addr': '(typeof(sqe->addr))iov',
-                'len' : 'iovcnt',
                 'off' : 'offset',
-                'rw_flags' : 'flags'
+                'addr': '(uintptr_t)iov',
+                'len' : 'iovcnt'
         }, define = 'CFA_HAVE_PWRITEV2'),
         # CFA_HAVE_IORING_OP_FSYNC
@@ -244 +242 @@
         }),
         # CFA_HAVE_IORING_OP_EPOLL_CTL
-        Call('EPOLL_CTL', 'int epoll_ctl(int epfd, int op, int fd, struct epoll_event * event)', {
+        Call('EPOLL_CTL', 'int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)', {
                 'fd': 'epfd',
+                'addr': 'fd',
                 'len': 'op',
-                'addr': 'fd',
-                'off': '(typeof(sqe->off))event'
+                'off': '(uintptr_t)event'
         }),
         # CFA_HAVE_IORING_OP_SYNC_FILE_RANGE
@@ -258 +256 @@
         }),
         # CFA_HAVE_IORING_OP_SENDMSG
-        Call('SENDMSG', 'ssize_t sendmsg(int sockfd, const struct msghdr * msg, int flags)', {
-                'fd': 'sockfd',
-                'addr': '(typeof(sqe->addr))(struct msghdr *)msg',
+        Call('SENDMSG', 'ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags)', {
+                'fd': 'sockfd',
+                'addr': '(uintptr_t)(struct msghdr *)msg',
                 'len': '1',
                 'msg_flags': 'flags'
         }),
         # CFA_HAVE_IORING_OP_RECVMSG
-        Call('RECVMSG', 'ssize_t recvmsg(int sockfd, struct msghdr * msg, int flags)', {
-                'fd': 'sockfd',
-                'addr': '(typeof(sqe->addr))(struct msghdr *)msg',
+        Call('RECVMSG', 'ssize_t recvmsg(int sockfd, struct msghdr *msg, int flags)', {
+                'fd': 'sockfd',
+                'addr': '(uintptr_t)(struct msghdr *)msg',
                 'len': '1',
                 'msg_flags': 'flags'
         }),
         # CFA_HAVE_IORING_OP_SEND
-        Call('SEND', 'ssize_t send(int sockfd, const void * buf, size_t len, int flags)', {
-                'fd': 'sockfd',
-                'addr': '(typeof(sqe->addr))buf',
+        Call('SEND', 'ssize_t send(int sockfd, const void *buf, size_t len, int flags)', {
+                'fd': 'sockfd',
+                'addr': '(uintptr_t)buf',
                 'len': 'len',
                 'msg_flags': 'flags'
         }),
         # CFA_HAVE_IORING_OP_RECV
-        Call('RECV', 'ssize_t recv(int sockfd, void * buf, size_t len, int flags)', {
-                'fd': 'sockfd',
-                'addr': '(typeof(sqe->addr))buf',
+        Call('RECV', 'ssize_t recv(int sockfd, void *buf, size_t len, int flags)', {
+                'fd': 'sockfd',
+                'addr': '(uintptr_t)buf',
                 'len': 'len',
                 'msg_flags': 'flags'
@@ -288 +286 @@
         Call('ACCEPT', 'int accept4(int sockfd, __SOCKADDR_ARG addr, socklen_t * restrict addrlen, int flags)', {
                 'fd': 'sockfd',
-                'addr': '(typeof(sqe->addr))&addr',
-                'addr2': '(typeof(sqe->addr2))addrlen',
+                'addr': '(uintptr_t)&addr',
+                'addr2': '(uintptr_t)addrlen',
                 'accept_flags': 'flags'
         }),
@@ -295 +293 @@
         Call('CONNECT', 'int connect(int sockfd, __CONST_SOCKADDR_ARG addr, socklen_t addrlen)', {
                 'fd': 'sockfd',
-                'addr': '(typeof(sqe->addr))&addr',
+                'addr': '(uintptr_t)&addr',
                 'off': 'addrlen'
         }),
@@ -301 +299 @@
         Call('FALLOCATE', 'int fallocate(int fd, int mode, off_t offset, off_t len)', {
                 'fd': 'fd',
+                'addr': '(uintptr_t)len',
                 'len': 'mode',
-                'off': 'offset',
-                'addr': 'len'
+                'off': 'offset'
         }),
         # CFA_HAVE_IORING_OP_FADVISE
@@ -313 +311 @@
         }),
         # CFA_HAVE_IORING_OP_MADVISE
-        Call('MADVISE', 'int madvise(void * addr, size_t length, int advice)', {
-                'addr': '(typeof(sqe->addr))addr',
+        Call('MADVISE', 'int madvise(void *addr, size_t length, int advice)', {
+                'addr': '(uintptr_t)addr',
                 'len': 'length',
                 'fadvise_advice': 'advice'
         }),
         # CFA_HAVE_IORING_OP_OPENAT
-        Call('OPENAT', 'int openat(int dirfd, const char * pathname, int flags, mode_t mode)', {
+        Call('OPENAT', 'int openat(int dirfd, const char *pathname, int flags, mode_t mode)', {
                 'fd': 'dirfd',
-                'addr': '(typeof(sqe->addr))pathname',
-                'open_flags': 'flags;',
-                'len': 'mode'
+                'addr': '(uintptr_t)pathname',
+                'len': 'mode',
+                'open_flags': 'flags;'
         }),
         # CFA_HAVE_IORING_OP_OPENAT2
-        Call('OPENAT2', 'int openat2(int dirfd, const char * pathname, struct open_how * how, size_t size)', {
+        Call('OPENAT2', 'int openat2(int dirfd, const char *pathname, struct open_how * how, size_t size)', {
                 'fd': 'dirfd',
-                'addr': '(typeof(sqe->addr))pathname',
-                'off': '(typeof(sqe->off))how',
-                'len': 'sizeof(*how)'
+                'addr': 'pathname',
+                'len': 'sizeof(*how)',
+                'off': '(uintptr_t)how',
         }, define = 'CFA_HAVE_OPENAT2'),
         # CFA_HAVE_IORING_OP_CLOSE
@@ -337 +335 @@
         }),
         # CFA_HAVE_IORING_OP_STATX
-        Call('STATX', 'int statx(int dirfd, const char * pathname, int flags, unsigned int mask, struct statx * statxbuf)', {
+        Call('STATX', 'int statx(int dirfd, const char *pathname, int flags, unsigned int mask, struct statx *statxbuf)', {
                 'fd': 'dirfd',
-                'addr': '(typeof(sqe->addr))pathname',
-                'statx_flags': 'flags',
+                'off': '(uintptr_t)statxbuf',
+                'addr': 'pathname',
                 'len': 'mask',
-                'off': '(typeof(sqe->off))statxbuf'
+                'statx_flags': 'flags'
         }, define = 'CFA_HAVE_STATX'),
         # CFA_HAVE_IORING_OP_READ
         Call('READ', 'ssize_t read(int fd, void * buf, size_t count)', {
                 'fd': 'fd',
-                'addr': '(typeof(sqe->addr))buf',
+                'addr': '(uintptr_t)buf',
                 'len': 'count'
         }),
@@ -353 +351 @@
         Call('WRITE', 'ssize_t write(int fd, void * buf, size_t count)', {
                 'fd': 'fd',
-                'addr': '(typeof(sqe->addr))buf',
+                'addr': '(uintptr_t)buf',
                 'len': 'count'
         }),
         # CFA_HAVE_IORING_OP_SPLICE
-        Call('SPLICE', 'ssize_t splice(int fd_in, __off64_t * off_in, int fd_out, __off64_t * off_out, size_t len, unsigned int flags)', {
+        Call('SPLICE', 'ssize_t splice(int fd_in, __off64_t *off_in, int fd_out, __off64_t *off_out, size_t len, unsigned int flags)', {
                 'splice_fd_in': 'fd_in',
-                'splice_off_in': 'off_in ? (typeof(sqe->splice_off_in))*off_in : (typeof(sqe->splice_off_in))-1',
+                'splice_off_in': 'off_in ? (__u64)*off_in : (__u64)-1',
                 'fd': 'fd_out',
-                'off': 'off_out ? (typeof(sqe->off))*off_out : (typeof(sqe->off))-1',
+                'off': 'off_out ? (__u64)*off_out : (__u64)-1',
                 'len': 'len',
                 'splice_flags': 'flags'