Changeset f6afd84 for doc/theses

Timestamp:

Jul 5, 2023, 2:45:16 PM (12 months ago)

Author:

caparson <caparson@…>

Branches:

master

Children:

7c4416a

Parents:

7ce70e2

Message:

merging together benchmark run files

File:

• doc/theses/colby_parsons_MMAth/benchmarks/actors/run (modified) (14 diffs)

doc/theses/colby_parsons_MMAth/benchmarks/actors/run

@@ -85 +85 @@
 }
 
+column_headers="proc\ttime (s)"
+
 # executor config
 batch='100'
@@ -102 +104 @@
 # static config
 n_static_sends='100000000'
+n_static_sends_slow='10000000'
 
 # dynamic config
 n_dynamic_sends='20000000'
+n_dynamic_sends_slow='2000000'
 
 numtimes=5
 
-# bench_cores='1 2 4 8 16 24 32'
-# bench_cores='1 2 4 8 16 24 32 48'
-bench_cores='48'
+# bench_cores='4 8'
+bench_cores='1 2 4 8 16 24 32 48'
+# bench_cores='48'
+
+# toggle mem collection instead of time (executor only)
+# mem=${true}
+mem=${false}
 
 # toggle benchmarks
-executor=${false}
-matrix=${false}
-repeat=${false}
-balance=${false}
+executor=${true}
+matrix=${true}
+repeat=${true}
+balance=${true}
 static=${true}
 dynamic=${true}
-
-# names=('CFA-LV' 'CFA-NS' 'CFA-R')
+# executor=${false}
+# matrix=${false}
+# repeat=${false}
+# balance=${false}
+# static=${false}
+# dynamic=${false}
+
+# names=('Longest-Victim' 'No-Stealing' 'Random')
 # var_flags=('-D__STEAL=1 -DSEARCH=1' '' '-D__STEAL=1 -DRAND=1')
 
-# names=('CFA-NS')
-# var_flags=('')
-
-names=('CFA')
-var_flags=('-D__STEAL=1 -DSEARCH=1')
+# names=('CFA' 'CFA-EMPTY')
+# var_flags=('' '-DEMPTY')
+
+# names=('CFA')
+# var_flags=('-D__STEAL=1 -DSEARCH=1')
 
 # names=('CFA' 'CFA-STAT')
@@ -134 +148 @@
 # names=()
 # var_flags=()
+
+names=('CFA')
+var_flags=('')
 
 runCAF=${true}
@@ -139 +156 @@
 runPROTO=${true}
 runAKKA=${true}
-# runCAF=${false}
-# runUCPP=${false}
-# runPROTO=${false}
-# runAKKA=${false}
+runCAF=${false}
+runUCPP=${false}
+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
@@ -162 +190 @@
 print_header() {
     echo ${1}':'
-    echo -e "proc\ttime (s)"
+    if [ ${mem} -eq ${false} ] ; then
+        echo -e $column_headers
+    fi
 }
 
@@ -173 +203 @@
     affinity ${1}
     preprint="${1}\t"
-    repeat_command taskset -c ${taskset} ./a.${hostname} ${pre_args} ${1} ${post_args}
+    if [ ${mem} -eq ${true} ] ; then
+        repeat_command /usr/bin/time -f "%M" taskset -c ${taskset} ./a.${hostname} ${pre_args} ${1} ${post_args} > /dev/null
+    else
+        repeat_command taskset -c ${taskset} ./a.${hostname} ${pre_args} ${1} ${post_args}
+    fi
 }
 
@@ -232 +266 @@
 # /usr/bin/time -f "%Uu %Ss %Er %Mkb"
 if [ ${executor} -eq ${true} ] ; then
-    echo "executor"
+    if [ ${mem} -eq ${false} ] ; then
+        echo "executor"
+    else
+        echo "mem"
+    fi
     pre_args="40000 100 ${nRounds}"
     post_args="${batch}"
@@ -263 +301 @@
             set_akka_parallelism ${p}
             affinity ${p}
-            taskset -c ${taskset} sbt ${sbtflags} "run ${pre_args} ${p} ${post_args} ${numtimes}" 2>&1 | grep -v "SLF4J:" | grep -v "Slf4jLogger started" | sed -e "s/\x1b\[0J//"
+            if [ ${mem} -eq ${true} ] ; then
+                t=1
+                while [ ${t} -le ${numtimes} ] ; do
+                    /usr/bin/time -f "%M" taskset -c ${taskset} sbt ${sbtflags} "run ${pre_args} ${p} ${post_args} 1" 2>&1 | grep -v "SLF4J:" | grep -v "Slf4jLogger started" | sed -e "s/\x1b\[0J//" | grep -v "\."
+                    t=`expr ${t} + 1`
+                done
+            else
+                taskset -c ${taskset} sbt ${sbtflags} "run ${pre_args} ${p} ${post_args} ${numtimes}" 2>&1 | grep -v "SLF4J:" | grep -v "Slf4jLogger started" | sed -e "s/\x1b\[0J//"
+            fi
+            
             sbt clean > /dev/null
         done
@@ -424 +471 @@
         g++ ${prefixCAF} CAFSendStatic.cpp ${suffixCAF} -o a.${hostname} > /dev/null 2>&1
         sed -i "s/max-threads = .*/max-threads = 1/g" caf-application.conf # set CAF parallelism
-        repeat_command taskset -c ${startcore} ./a.${hostname} 'd'
+        repeat_command taskset -c ${startcore} ./a.${hostname} ${n_static_sends_slow}
         rm a.${hostname}
         cd - > /dev/null
@@ -470 +517 @@
         g++ ${prefixCAF} CAFSendDynamic.cpp ${suffixCAF} -o a.${hostname} > /dev/null 2>&1
         sed -i "s/max-threads = .*/max-threads = 1/g" caf-application.conf # set CAF parallelism
-        repeat_command taskset -c ${startcore} ./a.${hostname} 'd'
+        repeat_command taskset -c ${startcore} ./a.${hostname} ${n_dynamic_sends_slow}
         rm a.${hostname}
         cd - > /dev/null
@@ -479 +526 @@
         echo 'Akka:'
         set_akka_parallelism 1
-        taskset -c ${startcore} sbt ${sbtflags} "run d ${numtimes}" 2>&1 | grep -v "SLF4J:" | grep -v "Slf4jLogger started" | sed -e "s/\x1b\[0J//"
+        taskset -c ${startcore} sbt ${sbtflags} "run ${n_dynamic_sends_slow} ${numtimes}" 2>&1 | grep -v "SLF4J:" | grep -v "Slf4jLogger started" | sed -e "s/\x1b\[0J//"
         cd - > /dev/null
     fi # done AKKA
@@ -494 +541 @@
         echo 'ProtoActor:'
         go build -o a.${hostname} > /dev/null 2>&1
-        repeat_command taskset -c ${startcore} ./a.${hostname} 'd'
+        repeat_command taskset -c ${startcore} ./a.${hostname} ${n_dynamic_sends_slow}
         rm a.${hostname}
         cd - > /dev/null
@@ -507 +554 @@
     for i in ${!names[@]}; do
         echo ${names[$i]}':'
-        echo -e "proc\ttime (s)"
+        echo -e $column_headers
         ${cfa} ${cfa_flags} ${var_flags[$i]} balance.cfa -o a.${hostname} > /dev/null 2>&1
         for p in ${bench_cores} ; do 
@@ -520 +567 @@
     for i in ${!names[@]}; do
         echo ${names[$i]}':'
-        echo -e "proc\ttime (s)"
+        echo -e $column_headers
         ${cfa} ${cfa_flags} ${var_flags[$i]} -DMULTI balance.cfa -o a.${hostname} > /dev/null 2>&1
         for p in ${bench_cores} ; do