Changeset b93bf85 for src/Concurrency

Timestamp:

Jul 11, 2023, 2:27:58 PM (20 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

bbecdd4

Parents:

4c8ce47

Message:

fixed spurious channel close waituntil error case. Was caused by a race condition causing an exception to be thrown while another was in flight

File:

• src/Concurrency/Waituntil.cpp (modified) (2 diffs)

src/Concurrency/Waituntil.cpp

@@ -1290 +1290 @@
     // Collection of unregister calls on resources to be put in finally clause
     // for each clause: 
-    // when_cond_i = (!__CFA_has_clause_run( clause_statuses[i] )) && unregister_select( ... , clausei );
+    // if ( !__CFA_has_clause_run( clause_statuses[i] )) && unregister_select( ... , clausei ) ) { ... clausei stmt ... }
     // OR if when( ... ) defined on resource
-    // if ( when_cond_i ) 
-    //   when_cond_i =  (!__CFA_has_clause_run( clause_statuses[i] )) && unregister_select( ... , clausei );
+    // if ( when_cond_i && (!__CFA_has_clause_run( clause_statuses[i] )) && unregister_select( ... , clausei ) ) { ... clausei stmt ... }
     CompoundStmt * unregisters = new CompoundStmt( loc );
-
 
     Expr * statusExpr; // !__CFA_has_clause_run( clause_statuses[i] )
@@ -1348 +1346 @@
             new IfStmt( cLoc,
                 statusExpr,
-                genStmtBlock( stmt->clauses.at(i), clauseData.at(i) )
-            )
-        );
+                new CompoundStmt( cLoc,
+                    {
+                        new IfStmt( cLoc,
+                            genSelectTraitCall( stmt->clauses.at(i), clauseData.at(i), "on_selected" ),
+                            ast::deepCopy( stmt->clauses.at(i)->stmt )
+                        )
+                    }
+                )
+            )
+        );
+
+        // // generates:
+        // // if ( statusExpr ) { ... clausei stmt ... }
+        // unregisters->push_back( 
+        //     new IfStmt( cLoc,
+        //         statusExpr,
+        //         genStmtBlock( stmt->clauses.at(i), clauseData.at(i) )
+        //     )
+        // );
     }