Changeset ec22220 for tests/concurrency/waituntil/channel_close.cfa

Timestamp:

Dec 10, 2024, 3:07:59 PM (8 days ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

64f3b9f

Parents:

6e6e372

Message:

formatting

File:

• tests/concurrency/waituntil/channel_close.cfa (modified) (4 diffs)

tests/concurrency/waituntil/channel_close.cfa

@@ -1 @@
-#include <select.hfa>
+#include <fstream.hfa>
 #include <thread.hfa>
 #include <channel.hfa>
 #include <time.hfa>
 
-channel(long long int) A, B;
+channel(ssize_t) A, B;
 
-volatile long long int inserts = 0;
-volatile long long int removes = 0;
+volatile size_t inserts = 0, removes = 0;
 
 thread Producer {};
 void main( Producer & this ) {
     try {
-        for( long long int i = 0;;i++ ) {
+        for( size_t i; 0~@ ) {
             waituntil( A << i ) { inserts++; }
             and waituntil( B << i ) { inserts++; }
@@ -22 +21 @@
 thread Consumer {}; // ensures that the changing when states of Server1 don't result in a deadlock
 void main( Consumer & this ) {
-    long long int in, in2, A_removes = 0, B_removes = 0;
+    ssize_t in, in2, A_removes = 0, B_removes = 0;
+
     try {
-        for( ;; ) {
+        for () {
             if ( useAnd ) {
                 waituntil( (in << A) ) { __atomic_thread_fence( __ATOMIC_SEQ_CST ); assert( A_removes == in ); A_removes++; removes++; }
@@ -33 +33 @@
             or waituntil( (in << B) ) { __atomic_thread_fence( __ATOMIC_SEQ_CST ); ( B_removes == in ); B_removes++; removes++; }
         }
-    } catchResume ( channel_closed * e ) {} // continue to remove until would block
-    catch ( channel_closed * e ) {} 
+    } catchResume ( channel_closed * e ) {                              // continue to remove until would block
+        } catch ( channel_closed * e ) {} 
+
     try {
-        for( ;; )
+        for ()
             waituntil( (in << A) ) { __atomic_thread_fence( __ATOMIC_SEQ_CST ); assert( A_removes == in ); A_removes++; removes++; }
-    } catchResume ( channel_closed * e ) {} // continue to remove until would block
-    catch ( channel_closed * e ) {} 
+    } catchResume ( channel_closed * e ) {                              // continue to remove until would block
+        } catch ( channel_closed * e ) {} 
+
     try {
-        for( ;; )
+        for ()
             waituntil( (in << B) ) { __atomic_thread_fence( __ATOMIC_SEQ_CST ); assert( B_removes == in ); B_removes++; removes++; }
-    } catchResume ( channel_closed * e ) {} // continue to remove until would block
-    catch ( channel_closed * e ) {} 
+    } catchResume ( channel_closed * e ) {                              // continue to remove until would block
+        } catch ( channel_closed * e ) {} 
 }
 
+int main( int argc, char * argv[] ) {
+        size_t time = 5;
 
-size_t time = 5;
-int main( int argc, char * argv[] ) {
     if ( argc == 2 )
         time = atoi( argv[1] );
@@ -57 +59 @@
     B{5};
 
-    printf("start OR\n");
+    sout | "start OR";
     {
         Producer p;
         Consumer c;
         sleep(time`s);
-        printf("done sleep\n");
-        printf("closing A\n");
-        close(A);
-        printf("closing B\n");
-        close(B);
+        sout | "done sleep";
+        sout | "closing A";
+        close( A );
+        sout | "closing B";
+        close( B );
     }
     if ( inserts != removes ) 
-        printf("CHECKSUM MISMATCH!! Producer got: %lld, Consumer got: %lld\n", inserts, removes);
-    printf("done\n");
+        sout | "CHECKSUM MISMATCH!! Producer got:" | inserts | ", Consumer got:" | removes;
+    sout | "done";
     ^A{};
     ^B{};
 
     useAnd = true;
-
-    inserts = 0;
-    removes = 0;
+    inserts = removes = 0;
     A{5};
     B{5};
-    printf("start AND\n");
+    sout | "start AND";
     {
         Producer p;
         Consumer c;
-        sleep(time`s);
-        printf("done sleep\n");
-        printf("closing A\n");
-        close(A);
-        printf("closing B\n");
-        close(B);
+        sleep( time`s );
+        sout | "done sleep";
+        sout | "closing A";
+        close( A );
+        sout | "closing B";
+        close( B );
     }
     if ( inserts != removes ) 
-        printf("CHECKSUM MISMATCH!! Producer got: %lld, Consumer got: %lld\n", inserts, removes);
-    printf("done\n");
+        sout | "CHECKSUM MISMATCH!! Producer got:" | inserts | ", Consumer got:" | removes;
+    sout | "done";
 }