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

Timestamp:

Feb 18, 2025, 12:54:23 PM (6 weeks ago)

Author:

Andrew Beach <ajbeach@…>

Branches:

master

Children:

8705a11

Parents:

3e5fea2

Message:

Clean-up the warnings of the concurrency tests. A lot of little test level fixes, the most interesting repeated one is some formally redundent fallthough statements. pthread_attr_test had to be rewritten because of library restrictions. Changed some types so they would always be pointer sized. There was a library change, there was a function that could not be implemented; I trust that it is included for a reason so I just put it in a comment. There is a change to the compiler, wait-until now uses goto. The labelled breaks were code generated as unlabelled breaks and although it worked out slipped through some checks. Finally, there is one warning that I cannot solve at this time so tests that produce it have been put in their own lax group.

File:

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

tests/concurrency/waituntil/channel_close.cfa ¶

@@ -9 +9 @@
 
 thread Producer {};
-void main( Producer & this ) {
+void main( Producer & ) {
     try {
         for( size_t i; 0~@ ) {
@@ -15 +15 @@
             and waituntil( B << i ) { inserts++; }
         }
-    } catch ( channel_closed * e ) {} 
+    } catch ( channel_closed * e ) {}
 }
 
 bool useAnd = false;
 thread Consumer {}; // ensures that the changing when states of Server1 don't result in a deadlock
-void main( Consumer & this ) {
+void main( Consumer & ) {
     ssize_t in, in2, A_removes = 0, B_removes = 0;
 
@@ -34 +34 @@
         }
     } catchResume ( channel_closed * e ) {                              // continue to remove until would block
-        } catch ( channel_closed * e ) {} 
+        } catch ( channel_closed * e ) {}
 
     try {
@@ -40 +40 @@
             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 ) {} 
+        } catch ( channel_closed * e ) {}
 
     try {
@@ -46 +46 @@
             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 ) {} 
+        } catch ( channel_closed * e ) {}
 }