Changes in libcfa/src/concurrency/io/setup.cfa [11054eb:f815c46]

File:

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

libcfa/src/concurrency/io/setup.cfa

@@ -110 +110 @@
                 this.arbiter = cl.io.arbiter;
                 this.ext_sq.empty = true;
-                (this.ext_sq.queue){};
+                (this.ext_sq.blocked){};
                 __io_uring_setup( this, cl.io.params, proc->idle );
                 __cfadbg_print_safe(io_core, "Kernel I/O : Created ring for io_context %u (%p)\n", this.fd, &this);
@@ -329 +329 @@
 //=============================================================================================
         void ?{}( $io_arbiter & this ) {
-                this.pending.empty = true;
-        }
-
-        void ^?{}( $io_arbiter & this ) {}
+                this.pending.flag = false;
+        }
+
+        void ^?{}( $io_arbiter & mutex this ) {
+                // /* paranoid */ verify( empty(this.assigned) );
+                // /* paranoid */ verify( empty(this.available) );
+                /* paranoid */ verify( is_empty(this.pending.blocked) );
+        }
 
         $io_arbiter * create(void) {