Changeset 6502a2b for libcfa/src/concurrency/io.cfa

Timestamp:

May 4, 2020, 12:54:56 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

3c039b0

Parents:

c5c743e

Message:

Tentative fix to the deadlock in cluster shutdown

File:

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

libcfa/src/concurrency/io.cfa

@@ -89 +89 @@
                 void ?{}( __io_poller_fast & this, struct cluster & cltr ) {
                         this.ring = &cltr.io;
+                        this.waiting = true;
                         (this.thrd){ "Fast I/O Poller", cltr };
                 }
@@ -242 +243 @@
 
                 #if defined(__CFA_IO_POLLING_USER__)
+                        verify( this.io.poller.fast.waiting );
+                        verify( this.io.poller.fast.thrd.state == Blocked );
+
+                        this.io.poller.fast.thrd.curr_cluster = mainCluster;
+
                         // unpark the fast io_poller
                         unpark( &this.io.poller.fast.thrd __cfaabi_dbg_ctx2 );
@@ -409 +415 @@
                         while(!__atomic_load_n(&this.ring->done, __ATOMIC_SEQ_CST)) {
                                 // Drain the io
-                                if(0 > __drain_io( *this.ring, 0p, 0, false )) {
+                                this.waiting = false;
+                                int ret = __drain_io( *this.ring, 0p, 0, false );
+                                this.waiting = true;
+                                if(0 > ret) {
                                         // If we got something, just yield and check again
                                         yield();