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

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"
 
 //=============================================================================================
@@ -74 +75 @@
         ;
 
-        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
 
@@ -199 +200 @@
                 __u32 idx;
                 struct io_uring_sqe * sqe;
-                struct $io_context * ctx = cfa_io_allocate( &sqe, &idx, 1 );
-
+                struct io_context$ * ctx = cfa_io_allocate( &sqe, &idx, 1 );
+
+                memset(sqe, 0, sizeof(*sqe));
                 sqe->opcode = IORING_OP_{op};
+                sqe->flags = sflags;
                 sqe->user_data = (uintptr_t)&future;
-                sqe->flags = sflags;
-                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}
+                {body}
 
                 asm volatile("": : :"memory");
@@ -226 +220 @@
         async_{name}( future, {args}, submit_flags );
 
-        wait( future );
+        __attribute__((unused)) bool parked;
+        parked = wait( future );
+        __STATS__(false, if(!parked) io.submit.nblk += 1; )
         if( future.result < 0 ) {{
                 errno = -future.result;