Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • src/benchmark/csv-data.c

    r43426d4 rbd951f7  
    100100}
    101101
    102 //-----------------------------------------------------------------------------
    103 // single internal sched entry
    104 mon_t mon1;
    105 
    106 condition cond1a;
    107 condition cond1b;
    108 
    109 thread thrd1a { long long int * out; };
    110 thread thrd1b {};
    111 
    112 void ?{}( thrd1a * this, long long int * out ) {
    113         this->out = out;
    114 }
    115 
    116 void side1A( mon_t * mutex a, long long int * out ) {
    117         long long int StartTime, EndTime;
    118 
    119         StartTime = Time();
    120         for( int i = 0;; i++ ) {
    121                 signal(&cond1a);
    122                 if( i > N ) break;
    123                 wait(&cond1b);
    124         }
    125         EndTime = Time();
    126 
    127         *out = ( EndTime - StartTime ) / N;
    128 }
    129 
    130 void side1B( mon_t * mutex a ) {
    131         for( int i = 0;; i++ ) {
    132                 signal(&cond1b);
    133                 if( i > N ) break;
    134                 wait(&cond1a);
    135         }
    136 }
    137 
    138 void main( thrd1a * this ) { side1A( &mon1, this->out ); }
    139 void main( thrd1b * this ) { side1B( &mon1 ); }
    140 
    141 long long int measure_1_sched_int() {
    142         long long int t;
    143         {
    144                 thrd1a a = { &t };
    145                 thrd1b b;
    146         }
    147         return t;
    148 }
    149 
    150 //-----------------------------------------------------------------------------
    151 // multi internal sched entry
    152 mon_t mon2;
    153 
    154 condition cond2a;
    155 condition cond2b;
    156 
    157 thread thrd2a { long long int * out; };
    158 thread thrd2b {};
    159 
    160 void ?{}( thrd2a * this, long long int * out ) {
    161         this->out = out;
    162 }
    163 
    164 void side2A( mon_t * mutex a, mon_t * mutex b, long long int * out ) {
    165         long long int StartTime, EndTime;
    166 
    167         StartTime = Time();
    168         for( int i = 0;; i++ ) {
    169                 signal(&cond2a);
    170                 if( i > N ) break;
    171                 wait(&cond2b);
    172         }
    173         EndTime = Time();
    174 
    175         *out = ( EndTime - StartTime ) / N;
    176 }
    177 
    178 void side2B( mon_t * mutex a, mon_t * mutex b ) {
    179         for( int i = 0;; i++ ) {
    180                 signal(&cond2b);
    181                 if( i > N ) break;
    182                 wait(&cond2a);
    183         }
    184 }
    185 
    186 void main( thrd2a * this ) { side2A( &mon1, &mon2, this->out ); }
    187 void main( thrd2b * this ) { side2B( &mon1, &mon2 ); }
    188 
    189 long long int measure_2_sched_int() {
    190         long long int t;
    191         {
    192                 thrd2a a = { &t };
    193                 thrd2b b;
    194         }
    195         return t;
    196 }
    197 
    198 //-----------------------------------------------------------------------------
    199 // main loop
    200102int main()
    201103{
     
    204106        sout | measure_thread() | ',';
    205107        sout | measure_1_monitor_entry() | ',';
    206         sout | measure_2_monitor_entry() | ',';
    207         sout | measure_1_sched_int() | ',';
    208         sout | measure_2_sched_int() | endl;
     108        sout | measure_2_monitor_entry() | endl;
    209109}
Note: See TracChangeset for help on using the changeset viewer.