source: tests/concurrent/waituntil/chan-and-no-else.cfa @ ab2b352

ADTast-experimental
Last change on this file since ab2b352 was 85e49a6, checked in by caparsons <caparson@…>, 18 months ago

added and removed some tests in pursuit of a more minimal repro of the deadlock failure case

  • Property mode set to 100644
File size: 1.8 KB
RevLine 
[85e49a6]1#include <select.hfa>
2#include <thread.hfa>
3#include <channel.hfa>
4
5channel(long long int) A, B, C;
6
7volatile bool done = false;
8long long int globalTotal = 0;
9
10thread Server1 {};
11void main( Server1 & this ) {
12    long long int a, b, c, i = 0, myTotal = 0;
13    bool isDone = false;
14    for( ; !isDone; i++ ) {
15        waituntil( a << A ) { myTotal += a; }
16        and waituntil( b << B ) { myTotal += b; }
17        and waituntil( c << C ) { if ( c == -1 ) { isDone = true; } else myTotal += c; }
18    }
19    __atomic_fetch_add( &globalTotal, myTotal, __ATOMIC_SEQ_CST );
20}
21
22size_t numtimes = 100000;
23size_t numServers = 1;
24int main( int argc, char * argv[] ) {
25    if ( argc == 2 )
26        numtimes = atoi( argv[1] );
27
28    processor p[numServers];
29    A{5};
30    B{5};
31    C{5};
32
33    long long int total = 0;
34    printf("start\n");
35    {
36        Server1 s[numServers];
37        for( long long int j = 0; j < numtimes; j++ ) {
38            waituntil( j >> A ) { total += j; }
39            and waituntil( j >> B ) { total += j; }
40            and waituntil( j >> C ) { total += j; }
41        }
42        printf("waiting for empty channels\n");
43        size_t A_count = get_count( A );
44        size_t B_count = get_count( B );
45        size_t C_count = get_count( C );
46        while( A_count > 0 || B_count > 0 || C_count > 0 ) {
47            A_count = get_count( A );
48            B_count = get_count( B );
49            C_count = get_count( C );
50        }
51        printf("sending sentinels\n");
52        for ( i; numServers ) {
53            insert( A, 0 );
54            insert( B, 0 );
55            insert( C, -1 );
56        }
57        printf("joining servers\n");
58    }
59    if ( total != globalTotal )
60        printf("CHECKSUM MISMATCH!! Main thread got %lld, server sum is %lld\n", total, globalTotal);
61    printf("done\n");
62}
Note: See TracBrowser for help on using the repository browser.