Changes in libcfa/src/concurrency/io/call.cfa.in [cefd0b9:108345a]

File:

• libcfa/src/concurrency/io/call.cfa.in (modified) (4 diffs)

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

@@ -34 +34 @@
 #include "kernel.hfa"
 #include "io/types.hfa"
-#include "stats.hfa"
 
 //=============================================================================================
@@ -75 +74 @@
         ;
 
-        extern struct io_context$ * cfa_io_allocate(struct io_uring_sqe * out_sqes[], __u32 out_idxs[], __u32 want)  __attribute__((nonnull (1,2)));
-        extern void cfa_io_submit( struct io_context$ * in_ctx, __u32 in_idxs[], __u32 have, bool lazy ) __attribute__((nonnull (1,2)));
+        extern struct $io_context * cfa_io_allocate(struct io_uring_sqe * out_sqes[], __u32 out_idxs[], __u32 want)  __attribute__((nonnull (1,2)));
+        extern void cfa_io_submit( struct $io_context * in_ctx, __u32 in_idxs[], __u32 have, bool lazy ) __attribute__((nonnull (1,2)));
 #endif
 
@@ -200 +199 @@
                 __u32 idx;
                 struct io_uring_sqe * sqe;
-                struct io_context$ * ctx = cfa_io_allocate( &sqe, &idx, 1 );
-
-                memset(sqe, 0, sizeof(*sqe));
+                struct $io_context * ctx = cfa_io_allocate( &sqe, &idx, 1 );
+
                 sqe->opcode = IORING_OP_{op};
+                sqe->user_data = (uintptr_t)&future;
                 sqe->flags = sflags;
-                sqe->user_data = (uintptr_t)&future;
-                {body}
+                sqe->ioprio = 0;
+                sqe->fd = 0;
+                sqe->off = 0;
+                sqe->addr = 0;
+                sqe->len = 0;
+                sqe->fsync_flags = 0;
+                sqe->__pad2[0] = 0;
+                sqe->__pad2[1] = 0;
+                sqe->__pad2[2] = 0;{body}
 
                 asm volatile("": : :"memory");
@@ -220 +226 @@
         async_{name}( future, {args}, submit_flags );
 
-        __attribute__((unused)) bool parked;
-        parked = wait( future );
-        __STATS__(false, if(!parked) io.submit.nblk += 1; )
+        wait( future );
         if( future.result < 0 ) {{
                 errno = -future.result;