Changeset a882b68 for tests/concurrent/waituntil

Timestamp:

May 4, 2023, 2:39:52 PM (17 months ago)

Author:

caparsons <caparson@…>

Branches:

ADT, ast-experimental, master

Children:

dd7a8ce

Parents:

cb69fba

Message:

added a test change to help locate the deadlock on next test failure

File:

• tests/concurrent/waituntil/channels.cfa (modified) (5 diffs)

tests/concurrent/waituntil/channels.cfa

@@ -12 +12 @@
     long long int a, b, c, i = 0, myTotal = 0;
     for( ;;i++ ) {
-        when( i % 2 == 0 ) waituntil( (a << A) ) { myTotal += a; }
-        or when( i % 4 < 2 ) waituntil( (b << B) ) { myTotal += b; }
-        or waituntil( (c << C) ) { if ( c == -1 ) break; myTotal += c; }
+        when( i % 2 == 0 ) waituntil( a << A ) { myTotal += a; }
+        or when( i % 4 < 2 ) waituntil( b << B ) { myTotal += b; }
+        or waituntil( c << C ) { if ( c == -1 ) break; myTotal += c; }
         or when( i % 8 < 4 ) else {}
     }
@@ -22 +22 @@
 thread Drainer {}; // ensures that the changing when states of Server1 don't result in a deadlock
 void main( Drainer & this ) {
-    long long int a, b, c, i = 0, myTotal = 0;
-    for( ;;i++ ) {
-        waituntil( (a << A) ) { myTotal += a; }
-        or waituntil( (b << B) ) { myTotal += b; }
-        or waituntil( (c << C) ) { if ( c == -1 ) break; myTotal += c; }
+    long long int a, b, c, myTotal = 0;
+    for( ;; ) {
+        waituntil( a << A ) { myTotal += a; }
+        or waituntil( b << B ) { myTotal += b; }
+        or waituntil( c << C ) { if ( c == -1 ) break; myTotal += c; }
+        or else {}
     }
     __atomic_fetch_add( &globalTotal, myTotal, __ATOMIC_SEQ_CST );
@@ -39 +40 @@
         try_insert( B, 0 );
         try_insert( C, 0 );
-        [out, success] = try_remove(A);
+        [out, success] = try_remove( A );
         if ( success ) myTotal += out;
-        [out, success] = try_remove(B);
+        [out, success] = try_remove( B );
         if ( success ) myTotal += out;
-        [out, success] = try_remove(C);
+        [out, success] = try_remove( C );
         if ( success ) myTotal += out;
     }
@@ -68 +69 @@
             Churner c;
             for( long long int j = 0; j < numtimes; j++ ) {
-                when( j % 2 == 0 ) waituntil( (j >> A) ) { total += j; }
-                or when( j % 4 < 2 ) waituntil( (j >> B) ) { total += j; }
-                and when( j % 8 < 4 ) waituntil( (j >> C) ) { total += j; }
+                when( j % 2 == 0 ) waituntil( j >> A ) { total += j; }
+                or when( j % 4 < 2 ) waituntil( j >> B ) { total += j; }
+                and when( j % 8 < 4 ) waituntil( j >> C ) { total += j; }
             }
             done = true;
@@ -76 +77 @@
         }
         printf("waiting for empty channels\n");
-        while( get_count(A) > 0 || get_count(B) > 0 || get_count(C) > 0 ) { Pause(); }
+        while( get_count( A ) > 0 || get_count( B ) > 0 || get_count( C ) > 0 ) { }
         printf("sending sentinels\n");
         for ( i; numServers + 1 ) insert( C, -1 );