Changeset 81ab5eb for libcfa/src/concurrency/io.cfa

Timestamp:

Mar 29, 2026, 9:52:51 PM (5 days ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

e6e250d

Parents:

00675ed4

Message:

2nd attempt at harmonizing isOp functions, e.g., isEmpty, to C/C++ form empty

File:

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

libcfa/src/concurrency/io.cfa

@@ -594 +594 @@
                 lock( queue.lock __cfaabi_dbg_ctx2 );
                 {
-                        was_empty = isEmpty( queue.queue );
+                        was_empty = empty( queue.queue );
 
                         // Add our request to the list
@@ -632 +632 @@
         // notify the arbiter that new allocations are available
         static void __ioarbiter_notify( io_arbiter$ & this, io_context$ * ctx ) {
-                /* paranoid */ verify( ! isEmpty( this.pending.queue ) );
+                /* paranoid */ verify( ! empty( this.pending.queue ) );
                 /* paranoid */ verify( __preemption_enabled() );
 
@@ -642 +642 @@
                         // as long as there are pending allocations try to satisfy them
                         // for simplicity do it in FIFO order
-                        while( ! isEmpty( this.pending.queue ) ) {
+                        while( ! empty( this.pending.queue ) ) {
                                 // get first pending allocs
                                 __u32 have = ctx->sq.free_ring.tail - ctx->sq.free_ring.head;
@@ -727 +727 @@
                         // pop each operation one at a time.
                         // There is no wait morphing because of the io sq ring
-                        while( ! isEmpty( ctx.ext_sq.queue ) ) {
+                        while( ! empty( ctx.ext_sq.queue ) ) {
                                 // drop the element from the queue
                                 __external_io & ei = (__external_io&)remove_first( ctx.ext_sq.queue );