Changes in / [c72ea7a:44a88528]

Files:

• examples/io/client.c (added)
• examples/io/server.c (added)
• examples/io_uring.c (modified) (2 diffs)
• libcfa/src/concurrency/kernel.cfa (modified) (1 diff)

examples/io_uring.c

@@ -33 +33 @@
       io_uring_prep_readv(sqe, fd, &iov, 1, 0);
 
+      sqe->user_data = data;
+
       /* tell the kernel we have an sqe ready for consumption */
       io_uring_submit(&ring);
@@ -38 +40 @@
       /* wait for the sqe to complete */
       int ret = io_uring_wait_cqe(&ring, &cqe);
-      printf("%d\n", ret);
+      
+      /* read and process cqe event */
+      if(ret == 0) {
+            char * out = cqe->user_data;
+            signed int len = cqe->res;
+            io_uring_cqe_seen(&ring, cqe);
 
-      /* read and process cqe event */
-      printf("%s", data);
-      io_uring_cqe_seen(&ring, cqe);
+            if(len > 0) {
+                  printf("%.*s", len, out);
+            }
+      }
+      else {
+            printf("%d\n", ret);
+            io_uring_cqe_seen(&ring, cqe);
+      }
 
       io_uring_queue_exit(&ring);

libcfa/src/concurrency/kernel.cfa

@@ -344 +344 @@
 
                 __cfaabi_dbg_debug_do(
-                        thrd_dst->park_stale = true;
-                        thrd_dst->park_stale = false;
+                        thrd_dst->park_stale   = true;
+                        thrd_dst->unpark_stale = true;
                 )