Skip to content
Snippets Groups Projects
Commit 84985eb7 authored by Jarrod Pas's avatar Jarrod Pas
Browse files

Removes old runners

parent d641b22d
No related branches found
No related tags found
2 merge requests!3Version 0.2,!1Full rewrite
#!/usr/bin/env bash
set -euo pipefail
epoch=$((7*24*60*60))
ticks_per_packet=$((60*120))
time_to_live=$((3*$epoch))
buffer_size=$((3*7*24*60*60))
duty=300
run() {
local router=$1
local community=$2
local seed=$3
local shed=$4
echo 'start:' $@ >&2
python main.py \
--router "$router" \
--community "$community" \
--seed "$seed" \
--community-args \
"epoch=${epoch}" \
--trace "csv" \
--trace-args \
"path=shed/data/pp_${shed}_reduced.csv" \
--node-args \
"tick_time=${duty}" \
"buffer_size=${buffer_size}" \
--packet-args \
"ticks_per_packet=${ticks_per_packet}" \
"time_to_live=${time_to_live}" \
"start_delay=${epoch}"
echo 'done:' $@ >&2
}
nproc=$(nproc)
for shed in $@; do
for seed in {1..10}; do
for router in direct epidemic; do
[[ "$(jobs | wc -l)" -ge "$nproc" ]] && wait -n
mkdir -p "logs/${router}"
run "$router" "none" "$seed" "$shed" > "logs/${router}/${shed}_${seed}.log" &
done
for router in bubble hcbf; do
for community in kclique louvain; do
[[ "$(jobs | wc -l)" -ge "$nproc" ]] && wait -n
mkdir -p "logs/${router}_${community}"
run "$router" "$community" "$seed" "$shed" > "logs/${router}_${community}/${shed}_${seed}.log" &
done
done
done
done
wait
./util/runner_all_summary logs/*/*.log
# send slack notification if the script exists
status=$?
notify=$HOME/dev/slack-notifier/send_notification_via_slack.py
[[ -e "$notify" ]] && $notify "\`$shed done: exit($status)\`"
#!/usr/bin/env bash
router=${1:-hcbf}
shed=shed1
epoch=$((7*24*60*60))
community="louvain"
ticks_per_packet=$((60))
time_to_live=$epoch
buffer_size=$((3*7*24*60/10))
duty=300
time python main.py \
--router "${router}" \
--community "${community}" \
--community-args \
"epoch=${epoch}" \
--trace "csv" \
--trace-args \
"path=shed/data/pp_${shed}_reduced.csv" \
--node-args \
"tick_time=${duty}" \
"buffer_size=${buffer_size}" \
--packet-args \
"ticks_per_packet=${ticks_per_packet}" \
"time_to_live=${time_to_live}" \
"start_delay=${epoch}"
# send slack notification if the script exists
status=$?
notify=$HOME/dev/slack-notifier/send_notification_via_slack.py
[[ -e "$notify" ]] && $notify "\`khadija done: exit($status)\`"
#!/usr/bin/env bash
router=${1:-hcbf}
shed=shed1
epoch=$((7*24*60*60))
community="louvain"
ticks_per_packet=$((60))
time_to_live=$((3*$epoch))
buffer_size=$((3*7*24*60*60))
duty=300
time python main.py \
--router "${router}" \
--community "${community}" \
--community-args \
"epoch=${epoch}" \
--trace "csv" \
--trace-args \
"path=shed/data/pp_${shed}_reduced.csv" \
--node-args \
"tick_time=${duty}" \
"buffer_size=${buffer_size}" \
--packet-args \
"ticks_per_packet=${ticks_per_packet}" \
"time_to_live=${time_to_live}" \
"start_delay=${epoch}"
# send slack notification if the script exists
status=$?
notify=$HOME/dev/slack-notifier/send_notification_via_slack.py
[[ -e "$notify" ]] && $notify "\`khadija done: exit($status)\`"
#!/usr/bin/env bash
router=${1:-hcbf}
shed=${2:shed1}
epoch=$((7*24*60*60))
community="louvain"
ticks_per_packet=$((60*120))
time_to_live=$((3*$epoch))
buffer_size=$((3*7*24*60*60))
duty=300
time python main.py \
--router "${router}" \
--community "${community}" \
--community-args \
"epoch=${epoch}" \
--trace "csv" \
--trace-args \
"path=shed/data/pp_${shed}_reduced.csv" \
--node-args \
"tick_time=${duty}" \
"buffer_size=${buffer_size}" \
--packet-args \
"ticks_per_packet=${ticks_per_packet}" \
"time_to_live=${time_to_live}" \
"start_delay=${epoch}"
# send slack notification if the script exists
status=$?
notify=$HOME/dev/slack-notifier/send_notification_via_slack.py
[[ -e "$notify" ]] && $notify "\`khadija done: exit($status)\`"
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment