Changeset 519f11c

Timestamp:

Jul 16, 2020, 2:59:50 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

463cb33

Parents:

79306383

Message:

Minor fixes in concurrency lib.
Remove async support for sendfile as a single call to splice

Location:

libcfa/src/concurrency

Files:

• iocall.cfa (modified) (2 diffs)
• iofwd.hfa (modified) (2 diffs)
• mutex.cfa (modified) (1 diff)

libcfa/src/concurrency/iocall.cfa

@@ -345 +345 @@
 }
 
+int cfa_statx(int dirfd, const char *pathname, int flags, unsigned int mask, struct statx *statxbuf) {
+        #if !defined(HAVE_LINUX_IO_URING_H) || !defined(IORING_OP_STATX)
+                return syscall( __NR_statx, dirfd, pathname, flags, mask, statxbuf );
+        #else
+                __submit_prelude
+
+                (*sqe){ IORING_OP_STATX, dirfd, pathname, mask, (uint64_t)statxbuf };
+                sqe->flags = flags;
+
+                __submit_wait
+        #endif
+}
+
 ssize_t cfa_read(int fd, void *buf, size_t count) {
         #if !defined(HAVE_LINUX_IO_URING_H) || !defined(IORING_OP_READ)
@@ -396 +409 @@
                 __submit_wait
         #endif
-}
-
-ssize_t cfa_sendfile(int out_fd, int in_fd, off_t *offset, size_t count) {
-        return cfa_splice(in_fd, offset, out_fd, 0p, count, 0);
 }
 

libcfa/src/concurrency/iofwd.hfa

@@ -16 +16 @@
 #pragma once
 
+#include <unistd.h>
 extern "C" {
         #include <sys/types.h>
 }
+#include "bits/defs.hfa"
+
+struct iovec;
+struct msghdr;
+struct sockaddr;
+struct statx;
 
 extern ssize_t cfa_preadv2(int fd, const struct iovec *iov, int iovcnt, off_t offset, int flags);
@@ -40 +47 @@
 extern ssize_t cfa_splice(int fd_in, loff_t *off_in, int fd_out, loff_t *off_out, size_t len, unsigned int flags);
 extern ssize_t cfa_tee(int fd_in, int fd_out, size_t len, unsigned int flags);
-extern ssize_t cfa_sendfile(int out_fd, int in_fd, off_t *offset, size_t count);
 
 //-----------------------------------------------------------------------------

libcfa/src/concurrency/mutex.cfa

@@ -30 +30 @@
         this.lock{};
         this.blocked_threads{};
+        this.is_locked = false;
 }