[160] | 1 | #include "stdio.h" |
---|
| 2 | #include "srl.h" |
---|
| 3 | |
---|
| 4 | #define NMAX 200 |
---|
| 5 | |
---|
| 6 | ///////////////////////////////////////////// |
---|
| 7 | __attribute__ ((constructor)) void producer() |
---|
| 8 | { |
---|
| 9 | |
---|
| 10 | unsigned int n; |
---|
| 11 | unsigned int buf; |
---|
| 12 | srl_mwmr_t mwmr; |
---|
| 13 | |
---|
| 14 | srl_log_printf( TRACE, "*** Starting task producer on processor %d", procid() ); |
---|
| 15 | srl_log_printf( TRACE, " at cycle %d ***\n\n", proctime() ); |
---|
| 16 | |
---|
| 17 | if( vobj_get_vbase( "router" , "mwmr_in", MWMR, (unsigned int*)&mwmr ) ) |
---|
| 18 | { |
---|
| 19 | srl_log_printf( NONE, "\n[ERROR] in producer task :\n"); |
---|
| 20 | srl_log_printf( NONE, " undefined <mwmr_in> channel: %d\n", mwmr); |
---|
| 21 | srl_log_printf( TRACE, "*** &mwmr_in = %x\n\n", (unsigned int)mwmr ); |
---|
| 22 | exit(); |
---|
| 23 | } |
---|
| 24 | else |
---|
| 25 | { |
---|
| 26 | srl_log_printf( TRACE, "*** &mwmr_in = %x\n\n", (unsigned int)mwmr ); |
---|
| 27 | } |
---|
| 28 | |
---|
| 29 | // main loop : token value = departure index |
---|
| 30 | for(n = 0 ; n < NMAX ; n++) |
---|
| 31 | { |
---|
| 32 | buf = n; |
---|
| 33 | srl_mwmr_write( mwmr, &buf , 1 ); |
---|
| 34 | srl_log_printf( TRACE, "transmitted value : %d\n", buf); |
---|
| 35 | } |
---|
| 36 | |
---|
| 37 | srl_log_printf( TRACE, "\n*** Completing producer task at cycle %d ***\n", proctime()); |
---|
| 38 | exit(); |
---|
| 39 | |
---|
| 40 | } // end producer() |
---|
| 41 | |
---|
| 42 | ///////////////////////////////////////////// |
---|
| 43 | __attribute__ ((constructor)) void consumer() |
---|
| 44 | { |
---|
| 45 | unsigned int n; |
---|
| 46 | unsigned int buf[5]; |
---|
| 47 | srl_mwmr_t mwmr; |
---|
| 48 | |
---|
| 49 | srl_log_printf( TRACE, "*** Starting task consumer on processor %d", procid() ); |
---|
| 50 | srl_log_printf( TRACE, " at cycle %d ***\n\n", proctime() ); |
---|
| 51 | |
---|
| 52 | if ( vobj_get_vbase( "router" , "mwmr_out", MWMR, (unsigned int*)&mwmr ) ) |
---|
| 53 | { |
---|
| 54 | srl_log_printf( NONE, "\n[ERROR] in consumer task :\n"); |
---|
| 55 | srl_log_printf( NONE, " undefined <mwmr_out> channel\n"); |
---|
| 56 | exit(); |
---|
| 57 | } |
---|
| 58 | else |
---|
| 59 | { |
---|
| 60 | srl_log_printf( TRACE, "*** &mwmr_out = %x\n\n", (unsigned int)mwmr ); |
---|
| 61 | } |
---|
| 62 | |
---|
| 63 | // main loop : display token arrival index and value |
---|
| 64 | for(n = 0 ; n < NMAX ; n = n+5 ) |
---|
| 65 | { |
---|
| 66 | srl_mwmr_read( mwmr, buf , 5 ); |
---|
| 67 | srl_log_printf( TRACE, "received token %d / value = %d\n", n , buf[0]); |
---|
| 68 | srl_log_printf( TRACE, "received token %d / value = %d\n", n+1, buf[1]); |
---|
| 69 | srl_log_printf( TRACE, "received token %d / value = %d\n", n+2, buf[2]); |
---|
| 70 | srl_log_printf( TRACE, "received token %d / value = %d\n", n+3, buf[3]); |
---|
| 71 | srl_log_printf( TRACE, "received token %d / value = %d\n", n+4, buf[4]); |
---|
| 72 | } |
---|
| 73 | |
---|
| 74 | srl_log_printf( TRACE, "\n*** Completing consumer task at cycle %d ***\n", proctime()); |
---|
| 75 | exit(); |
---|
| 76 | |
---|
| 77 | } // end consumer() |
---|
| 78 | |
---|
| 79 | /////////////////////////////////////////// |
---|
| 80 | __attribute__ ((constructor)) void router() |
---|
| 81 | { |
---|
| 82 | unsigned int buf[2]; |
---|
| 83 | unsigned int x; |
---|
| 84 | unsigned int tempo; |
---|
| 85 | srl_mwmr_t mwmr_in ; |
---|
| 86 | srl_mwmr_t mwmr_out ; |
---|
| 87 | |
---|
| 88 | |
---|
| 89 | srl_log_printf( TRACE, "*** Starting task router on processor %d at cycle %d ***\n\n", |
---|
| 90 | procid(), proctime() ); |
---|
| 91 | |
---|
| 92 | if ( vobj_get_vbase( "router" , "mwmr_out", MWMR, (unsigned int*)&mwmr_out ) ) |
---|
| 93 | { |
---|
| 94 | srl_log( NONE, "\n[ERROR] in router task :\n"); |
---|
| 95 | srl_log( NONE, " undefined <mwmr_in> channel\n"); |
---|
| 96 | exit(); |
---|
| 97 | } |
---|
| 98 | else |
---|
| 99 | { |
---|
| 100 | srl_log_printf( TRACE, "*** &mwmr_out = %x\n\n", (unsigned int)mwmr_out ); |
---|
| 101 | } |
---|
| 102 | |
---|
| 103 | if ( vobj_get_vbase( "router" , "mwmr_in", MWMR, (unsigned int*)&mwmr_in ) ) |
---|
| 104 | { |
---|
| 105 | srl_log( NONE, "\n[ERROR] in router task :\n"); |
---|
| 106 | srl_log( NONE, " undefined <mwmr_out> channel\n"); |
---|
| 107 | exit(); |
---|
| 108 | } |
---|
| 109 | else |
---|
| 110 | { |
---|
| 111 | srl_log_printf( TRACE, "*** &mwmr_in = %x\n\n", (unsigned int)mwmr_out ); |
---|
| 112 | } |
---|
| 113 | |
---|
| 114 | // main loop |
---|
| 115 | while(1) |
---|
| 116 | { |
---|
| 117 | srl_mwmr_read( mwmr_in , buf , 2 ); |
---|
| 118 | tempo = rand() >> 6; |
---|
| 119 | for ( x = 0 ; x < tempo ; x++ ) asm volatile (""); |
---|
| 120 | srl_log_printf( TRACE, "token value : %d / temporisation = %d\n", buf[0], tempo); |
---|
| 121 | srl_log_printf( TRACE, "token value : %d / temporisation = %d\n", buf[1], tempo); |
---|
| 122 | srl_mwmr_write( mwmr_out, buf , 2 ); |
---|
| 123 | } |
---|
| 124 | } |
---|