Changeset 9235192c

Timestamp:

Jul 5, 2023, 2:10:59 PM (10 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

7c4416a

Parents:

7ce70e2

Message:

added support for missed gulps benchmark

Files:

• doc/theses/colby_parsons_MMAth/benchmarks/actors/run (modified) (4 diffs)
• libcfa/src/concurrency/actor.hfa (modified) (4 diffs)

doc/theses/colby_parsons_MMAth/benchmarks/actors/run

@@ -85 +85 @@
 }
 
+#used for output formatting
+column_headers="proc\ttime (s)"
+
 # executor config
 batch='100'
@@ -109 +112 @@
 
 # bench_cores='1 2 4 8 16 24 32'
-# bench_cores='1 2 4 8 16 24 32 48'
-bench_cores='48'
+bench_cores='1 2 4 8 16 24 32 48'
+# bench_cores='48'
+
+# toggle specific experiment configs
+missed_gulps=${true}
 
 # toggle benchmarks
-executor=${false}
-matrix=${false}
-repeat=${false}
+executor=${true}
+matrix=${true}
+repeat=${true}
 balance=${false}
-static=${true}
-dynamic=${true}
+static=${false}
+dynamic=${false}
 
 # names=('CFA-LV' 'CFA-NS' 'CFA-R')
@@ -143 +149 @@
 # runPROTO=${false}
 # runAKKA=${false}
+
+if [ ${missed_gulps} -eq ${true} ] ; then
+    bench_cores='2 4 8 16 24 32 48'
+    column_headers="proc\tmissed\ttime (s)"
+    names=('CFA')
+    var_flags=('-D__STEAL=1 -DSEARCH=1 -DACTOR_STATS_QUEUE_MISSED')
+    runCAF=${false}
+    runUCPP=${false}
+    runPROTO=${false}
+    runAKKA=${false}
+fi
 
 cfa=~/cfa-cc/driver/cfa
@@ -196 +213 @@
 
 for i in ${!names[@]}; do
-        echo -n ${names[$i]}" "
+    echo -n ${names[$i]}" "
 done
 if [ ${runCAF} -eq ${true} ] ; then

libcfa/src/concurrency/actor.hfa

@@ -38 +38 @@
 // show stats
 // #define ACTOR_STATS
+
+// used to run and only track missed queue gulps
+#ifdef ACTOR_STATS
+#define ACTOR_STATS_QUEUE_MISSED
+#endif
 
 // forward decls
@@ -129 +134 @@
         #ifdef ACTOR_STATS
         unsigned int id;
+    #endif
+    #ifdef ACTOR_STATS_QUEUE_MISSED
         size_t missed;                                                                          // transfers skipped due to being_processed flag being up
         #endif
@@ -338 +345 @@
         } // for
 
-        #ifdef ACTOR_STATS
+        #ifdef ACTOR_STATS_QUEUE_MISSED
         size_t misses = 0;
         for ( i; nrqueues ) {
@@ -365 +372 @@
         printf("\tMessages stolen:\t\t\t%lu\n\tAverage steal size:\t\t\t%lu\n", __all_msgs_stolen, avg_steal);
         #endif
+
+    #ifndef ACTOR_STATS
+    #ifdef ACTOR_STATS_QUEUE_MISSED
+    printf("\t%lu", misses);
+    #endif
+    #endif
                 
 }