Changes in / [59f74a2:365e423]

File:

• libcfa/src/concurrency/iocall.cfa (modified) (4 diffs)

libcfa/src/concurrency/iocall.cfa

@@ -108 +108 @@
 
         extern ssize_t read (int fd, void *buf, size_t count);
+
+        extern ssize_t splice(int fd_in, loff_t *off_in, int fd_out, loff_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);
 }
 
@@ -342 +345 @@
 }
 
-
 ssize_t cfa_read(int fd, void *buf, size_t count) {
         #if !defined(HAVE_LINUX_IO_URING_H) || !defined(IORING_OP_READ)
@@ -362 +364 @@
 
                 (*sqe){ IORING_OP_WRITE, fd, buf, count, 0 };
+
+                __submit_wait
+        #endif
+}
+
+ssize_t cfa_splice(int fd_in, loff_t *off_in, int fd_out, loff_t *off_out, size_t len, unsigned int flags) {
+        #if !defined(HAVE_LINUX_IO_URING_H) || !defined(IORING_OP_SPLICE)
+                return splice( fd_in, off_in, fd_out, off_out, len, flags );
+        #else
+                __submit_prelude
+
+                (*sqe){ IORING_OP_SPLICE, fd_out, 0p, len, off_out };
+                sqe->splice_fd_in  = fd_in;
+                sqe->splice_off_in = off_in;
+                sqe->splice_flags  = flags;
+
+                __submit_wait
+        #endif
+}
+
+ssize_t cfa_tee(int fd_in, int fd_out, size_t len, unsigned int flags) {
+        #if !defined(HAVE_LINUX_IO_URING_H) || !defined(IORING_OP_TEE)
+                return tee( fd_in, fd_out, len, flags );
+        #else
+                __submit_prelude
+
+                (*sqe){ IORING_OP_TEE, fd_out, 0p, len, 0 };
+                sqe->splice_fd_in = fd_in;
+                sqe->splice_flags = flags;
 
                 __submit_wait
@@ -466 +497 @@
                         #define _CFA_IO_FEATURE_IORING_OP_WRITE ,
                         return IS_DEFINED(IORING_OP_WRITE);
+
+                if( /*func == (fptr_t)splice || */
+                        func == (fptr_t)cfa_splice )
+                        #define _CFA_IO_FEATURE_IORING_OP_SPLICE ,
+                        return IS_DEFINED(IORING_OP_SPLICE);
+
+                if( /*func == (fptr_t)tee || */
+                        func == (fptr_t)cfa_tee )
+                        #define _CFA_IO_FEATURE_IORING_OP_TEE ,
+                        return IS_DEFINED(IORING_OP_TEE);
         #endif