Changes in src/benchmark/csv-data.c [bd37119:a5b7905]

File:

• src/benchmark/csv-data.c (modified) (9 diffs)

src/benchmark/csv-data.c

@@ -28 +28 @@
 // coroutine context switch
 long long int measure_coroutine() {
-        const unsigned int NoOfTimes = N;
+        const unsigned int NoOfTimes = 50000000;
         long long int StartTime, EndTime;
 
@@ -43 +43 @@
 // thread context switch
 long long int measure_thread() {
-        const unsigned int NoOfTimes = N;
+        const unsigned int NoOfTimes = 50000000;
         long long int StartTime, EndTime;
 
@@ -61 +61 @@
 
 long long int measure_1_monitor_entry() {
-        const unsigned int NoOfTimes = N;
+        const unsigned int NoOfTimes = 5000000;
         long long int StartTime, EndTime;
         mon_t mon;
@@ -79 +79 @@
 
 long long int measure_2_monitor_entry() {
-        const unsigned int NoOfTimes = N;
+        const unsigned int NoOfTimes = 5000000;
         long long int StartTime, EndTime;
         mon_t mon1, mon2;
@@ -94 +94 @@
 //-----------------------------------------------------------------------------
 // single internal sched entry
+const unsigned int NoOfTimes = 500000;
+
 mon_t mon1;
 
@@ -107 +109 @@
 
 void side1A( mon_t & mutex a, long long int * out ) {
-        long long int StartTime, EndTime;
-
-        StartTime = Time();
-        for( int i = 0;; i++ ) {
-                signal(&cond1a);
+        const unsigned int NoOfTimes = 500000;
+        long long int StartTime, EndTime;
+
+        StartTime = Time();
+        for( int i = 0;; i++ ) {
+                signal(cond1a);
+                if( i > NoOfTimes ) break;
+                wait(cond1b);
+        }
+        EndTime = Time();
+
+        *out = ( EndTime - StartTime ) / NoOfTimes;
+}
+
+void side1B( mon_t & mutex a ) {
+        for( int i = 0;; i++ ) {
+                signal(cond1b);
                 if( i > N ) break;
-                wait(&cond1b);
-        }
-        EndTime = Time();
-
-        *out = ( EndTime - StartTime ) / N;
-}
-
-void side1B( mon_t & mutex a ) {
-        for( int i = 0;; i++ ) {
-                signal(&cond1b);
-                if( i > N ) break;
-                wait(&cond1a);
+                wait(cond1a);
         }
 }
@@ -141 +144 @@
 
 //-----------------------------------------------------------------------------
-// multi internal sched entry
+// multi internal sched
 mon_t mon2;
 
@@ -155 +158 @@
 
 void side2A( mon_t & mutex a, mon_t & mutex b, long long int * out ) {
-        long long int StartTime, EndTime;
-
-        StartTime = Time();
-        for( int i = 0;; i++ ) {
-                signal(&cond2a);
+        const unsigned int NoOfTimes = 500000;
+        long long int StartTime, EndTime;
+
+        StartTime = Time();
+        for( int i = 0;; i++ ) {
+                signal(cond2a);
+                if( i > NoOfTimes ) break;
+                wait(cond2b);
+        }
+        EndTime = Time();
+
+        *out = ( EndTime - StartTime ) / NoOfTimes;
+}
+
+void side2B( mon_t & mutex a, mon_t & mutex b ) {
+        for( int i = 0;; i++ ) {
+                signal(cond2b);
                 if( i > N ) break;
-                wait(&cond2b);
-        }
-        EndTime = Time();
-
-        *out = ( EndTime - StartTime ) / N;
-}
-
-void side2B( mon_t & mutex a, mon_t & mutex b ) {
-        for( int i = 0;; i++ ) {
-                signal(&cond2b);
-                if( i > N ) break;
-                wait(&cond2a);
+                wait(cond2a);
         }
 }
@@ -189 +193 @@
 
 //-----------------------------------------------------------------------------
+// single external sched
+
+volatile int go = 0;
+
+void __attribute__((noinline)) call( mon_t & mutex m1 ) {}
+
+long long int  __attribute__((noinline)) wait( mon_t & mutex m1 ) {
+        go = 1;
+        const unsigned int NoOfTimes = 5000000;
+        long long int StartTime, EndTime;
+
+        StartTime = Time();
+        for (size_t i = 0; i < NoOfTimes; i++) {
+                waitfor(call, m1);
+        }
+
+        EndTime = Time();
+        go = 0;
+        return ( EndTime - StartTime ) / NoOfTimes;
+}
+
+thread thrd3 {};
+void ^?{}( thrd3 & mutex this ) {}
+void main( thrd3 & this ) {
+        while(go == 0) { yield(); }
+        while(go == 1) { call(mon1); }
+
+}
+
+long long int measure_1_sched_ext() {
+        go = 0;
+        thrd3 t;
+        return wait(mon1);
+}
+
+//-----------------------------------------------------------------------------
+// multi external sched
+
+void __attribute__((noinline)) call( mon_t & mutex m1, mon_t & mutex m2 ) {}
+
+long long int  __attribute__((noinline)) wait( mon_t & mutex m1, mon_t & mutex m2 ) {
+        go = 1;
+        const unsigned int NoOfTimes = 5000000;
+        long long int StartTime, EndTime;
+
+        StartTime = Time();
+        for (size_t i = 0; i < NoOfTimes; i++) {
+                waitfor(call, m1, m2);
+        }
+
+        EndTime = Time();
+        go = 0;
+        return ( EndTime - StartTime ) / NoOfTimes;
+}
+
+thread thrd4 {};
+void ^?{}( thrd4 & mutex this ) {}
+void main( thrd4 & this ) {
+        while(go == 0) { yield(); }
+        while(go == 1) { call(mon1, mon2); }
+
+}
+
+long long int measure_2_sched_ext() {
+        go = 0;
+        thrd3 t;
+        return wait(mon1, mon2);
+}
+
+//-----------------------------------------------------------------------------
 // main loop
 int main()
 {
-        sout | time(NULL) | ',';
-        sout | measure_coroutine() | ',';
-        sout | measure_thread() | ',';
-        sout | measure_1_monitor_entry() | ',';
-        sout | measure_2_monitor_entry() | ',';
-        sout | measure_1_sched_int() | ',';
-        sout | measure_2_sched_int() | endl;
-}
+        sout | "\tepoch:" | time(NULL) | ',' | endl;
+        sout | "\tctxswitch: {" | endl;
+        sout | "\t\tcoroutine: "| measure_coroutine() | ',' | endl;
+        sout | "\t\tthread:" | measure_thread() | ',' | endl;
+        sout | "\t}," | endl;
+        sout | "\tmutex: ["     | measure_1_monitor_entry()     | ',' | measure_2_monitor_entry()       | "]," | endl;
+        sout | "\tscheduling: ["| measure_1_sched_int()         | ',' | measure_2_sched_int()   | ','  |
+                                          measure_1_sched_ext()         | ',' | measure_2_sched_ext()   | "]," | endl;
+}