Changes in libcfa/src/concurrency/io.cfa [fe9468e2:8fc652e0]

File:

• libcfa/src/concurrency/io.cfa (modified) (3 diffs)

libcfa/src/concurrency/io.cfa

@@ -160 +160 @@
         static inline void process(struct io_uring_cqe & cqe ) {
                 struct io_future_t * future = (struct io_future_t *)(uintptr_t)cqe.user_data;
-                __cfadbg_print_safe( io, "Kernel I/O : Syscall completed : cqe %p, result %d for %p\n", &cqe, cqe.res, future );
+                __cfadbg_print_safe( io, "Kernel I/O : Syscall completed : cqe %p, result %d for %p\n", future, cqe.res, data->thrd );
 
                 fulfil( *future, cqe.res );
@@ -298 +298 @@
                 __u32 mask = *ring.submit_q.mask;
 
-                __u32 off = thread_rand();
+                disable_interrupts();
+                        __u32 off = __tls_rand();
+                enable_interrupts( __cfaabi_dbg_ctx );
 
                 // Loop around looking for an available spot
@@ -342 +344 @@
                 __u32 ready_mask = ring.submit_q.ready_cnt - 1;
 
-                __u32 off = thread_rand();
+                disable_interrupts();
+                        __u32 off = __tls_rand();
+                enable_interrupts( __cfaabi_dbg_ctx );
 
                 __u32 picked;