Changes in / [9235192c:7c4416a]

File:

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

doc/theses/colby_parsons_MMAth/benchmarks/actors/run

@@ -105 +105 @@
 # static config
 n_static_sends='100000000'
+n_static_sends_slow='10000000'
 
 # dynamic config
 n_dynamic_sends='20000000'
+n_dynamic_sends_slow='2000000'
 
 numtimes=5
@@ -115 +117 @@
 # bench_cores='48'
 
-# toggle specific experiment configs
+# toggle missed gulp tracking config (overrides specified config)
 missed_gulps=${true}
+# missed_gulps=${false}
+
+# toggle mem collection config (overrides specified config)
+# outputs mem instead of time
+mem=${true}
+mem=${false}
 
 # toggle benchmarks
@@ -122 +130 @@
 matrix=${true}
 repeat=${true}
-balance=${false}
-static=${false}
-dynamic=${false}
-
-# names=('CFA-LV' 'CFA-NS' 'CFA-R')
+balance=${true}
+static=${true}
+dynamic=${true}
+# 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')
@@ -140 +154 @@
 # names=()
 # var_flags=()
+
+names=('CFA')
+var_flags=('')
 
 runCAF=${true}
@@ -145 +162 @@
 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
@@ -159 +176 @@
     runPROTO=${false}
     runAKKA=${false}
+    executor=${true}
+    matrix=${true}
+    repeat=${true}
+fi
+
+if [ ${mem} -eq ${true} ] ; then
+    bench_cores='48'
+    column_headers="proc\tmem (kB)"
+    names=('CFA')
+    var_flags=('-D__STEAL=1 -DSEARCH=1')
+    runCAF=${true}
+    runUCPP=${true}
+    runPROTO=${true}
+    runAKKA=${true}
+    executor=${true}
+    matrix=${false}
+    repeat=${false}
+    balance=${false}
+    static=${false}
+    dynamic=${false}
 fi
 
@@ -179 +216 @@
 print_header() {
     echo ${1}':'
-    echo -e "proc\ttime (s)"
+    if [ ${mem} -eq ${false} ] ; then
+        echo -e $column_headers
+    fi
 }
 
@@ -190 +229 @@
     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
 }
 
@@ -249 +292 @@
 # /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}"
@@ -280 +327 @@
             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
@@ -441 +497 @@
         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
@@ -487 +543 @@
         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
@@ -496 +552 @@
         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
@@ -511 +567 @@
         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
@@ -524 +580 @@
     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 
@@ -537 +593 @@
     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