source: src/tests/sched-int-disjoint.c @ 4c5b972

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since 4c5b972 was 4c5b972, checked in by Thierry Delisle <tdelisle@…>, 7 years ago

Minor test cleanup

  • Property mode set to 100644
File size: 2.1 KB
Line 
1#include <fstream>
2#include <kernel>
3#include <monitor>
4#include <thread>
5
6#define N 100_000
7
8enum state_t { WAIT, SIGNAL, BARGE };
9
10monitor global_t {};
11global_t mut;
12
13monitor global_data_t;
14void ?{}( global_data_t * this );
15void ^?{} ( global_data_t * this );
16
17monitor global_data_t {
18        int counter;
19        state_t state;
20} data;
21
22condition cond;
23
24volatile bool all_done;
25
26void ?{}( global_data_t * this ) {
27        this->counter == 0;
28        this->state = BARGE;
29}
30
31void ^?{} ( global_data_t * this ) {}
32
33//------------------------------------------------------------------------------
34// Barging logic
35void barge( global_data_t * mutex d ) {
36        d->state = BARGE;
37}
38
39thread Barger {};
40
41void main( Barger * this ) {
42        while( !all_done ) { 
43                barge( &data );
44                yield(); 
45        }
46}
47
48//------------------------------------------------------------------------------
49// Waiting logic
50bool wait( global_t * mutex m, global_data_t * mutex d ) {
51        wait( &cond );
52        if( d->state != SIGNAL ) {
53                sout | "ERROR barging!" | endl; 
54        }
55
56        d->counter++;
57
58        if( (d->counter % 1000) == 0 ) sout | d->counter | endl;
59
60        return d->counter < N;
61}
62
63thread Waiter {};
64
65void main( Waiter * this ) {
66        while( wait( &mut, &data ) ) { yield(); }
67}
68
69
70//------------------------------------------------------------------------------
71// Signalling logic
72void signal( condition * cond, global_t * mutex a, global_data_t * mutex b ) {
73        b->state = SIGNAL;
74        signal( cond );
75}
76
77void logic( global_t * mutex a ) {
78        signal( &cond, a, &data );
79
80        yield( (unsigned)rand48() % 10 );
81
82        //This is technically a mutual exclusion violation but the mutex monitor protects us
83        bool running = data.counter < N && data.counter > 0;
84        if( data.state != SIGNAL && running ) {
85                sout | "ERROR Eager signal" | data.state | endl; 
86        }
87}
88
89thread Signaller {};
90
91void main( Signaller * this ) {
92        while( !all_done ) { 
93                logic( &mut );
94                yield(); 
95        }
96}
97
98//------------------------------------------------------------------------------
99// Main loop
100int main(int argc, char* argv[]) {
101        all_done = false;
102        processor p;
103        {
104                Signaller s;
105                Barger b[17];
106                {
107                        Waiter w[4];
108                }
109                sout | "All waiter done" | endl;
110                all_done = true;
111        }       
112}
Note: See TracBrowser for help on using the repository browser.