Something went wrong. Try again.
🐑 a fluffy Gleam web server
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174#!/usr/bin/env bash
ROOT="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
CORES="$(nproc)"if [ "$CORES" -ge 4 ]; then SERVER_CPUS="0-$((CORES / 2 - 1))" LOAD_CPUS="$((CORES / 2))-$((CORES - 1))" PIN_SERVER=(taskset -c "$SERVER_CPUS") PIN_LOAD=(taskset -c "$LOAD_CPUS")else SERVER_CPUS="unpinned" LOAD_CPUS="unpinned" PIN_SERVER=() PIN_LOAD=()fi
fixture() { local name="$1" size="$2" [ -f "$ROOT/priv/$name" ] || head -c "$size" /dev/urandom > "$ROOT/priv/$name"}
ensure_fixtures() { mkdir -p "$ROOT/priv" fixture file_1kb.bin 1K fixture file_100kb.bin 100K fixture file_5mb.bin 5M fixture body_1kb.bin 1K fixture body_10kb.bin 10K}
body_file() { case "$1" in -) echo "" ;; *) echo "$ROOT/priv/body_$1.bin" ;; esac}
package_version() { local dir="$1" package="$2"
[ "$package" = "-" ] && return 0 if [ -f "$ROOT/$dir/manifest.toml" ]; then grep -oP "name = \"$package\", version = \"\K[^\"]+" "$ROOT/$dir/manifest.toml" elif [ -f "$ROOT/$dir/mix.lock" ]; then grep -oP "\"$package\": \{:hex, :$package, \"\K[^\"]+" "$ROOT/$dir/mix.lock" elif [ -f "$ROOT/$dir/rebar.lock" ]; then grep -oP "<<\"$package\">>,\{pkg,<<\"[^\"]+\">>,<<\"\K[^\"]+" "$ROOT/$dir/rebar.lock" fi}
record_versions() { local entry server dir version
printf 'toolchain gleam %s, OTP %s, elixir %s\n' \ "$(gleam --version 2>/dev/null | awk '{print $2}')" \ "$(erl -noshell -eval 'io:format("~s",[erlang:system_info(otp_release)]),halt().' 2>/dev/null)" \ "$(elixir --version 2>/dev/null | awk '/^Elixir/ { print $2 }')" printf 'tools %s, wrk2 %s\n' \ "$(h2load --version 2>/dev/null | tr '/' ' ' | awk '{print $2 " " $3}')" \ "$(git -C "$ROOT/.wrk2/src" rev-parse --short HEAD 2>/dev/null)"
local label="packages" for entry in "${SERVERS[@]}"; do IFS='|' read -r server dir _cmd _h1_port _h2_port <<< "$entry" version="$(package_version "$dir" "$(server_package "$server")")" [ -z "$version" ] && continue printf '%-12s%-12s%s\n' "$label" "$server" "$version" label="" done}
new_results_dir() { RESULTS_DIR="$ROOT/results/$(date +%Y%m%d-%H%M%S)-$1" mkdir -p "$RESULTS_DIR"}
render_report() { local csv="$1" echo "Results: $csv" command -v deno > /dev/null || return 0 echo "$ROOT/report.js" "$csv" | tee "$RESULTS_DIR/report.txt" echo "Report: $RESULTS_DIR/report.txt"}
port_pid() { ss -tlnp 2>/dev/null | awk -v p=":$1\$" '$4 ~ p' | grep -oP 'pid=\K[0-9]+' | head -1}
pgid_of() { ps -o pgid= -p "$1" 2>/dev/null | tr -d ' '}
free_port() { local port="$1" pid attempts=5
[ "$port" = "-" ] && return 0 while pid="$(port_pid "$port")" && [ -n "$pid" ]; do if [ "$attempts" -eq 0 ]; then echo " port $port still held by pid $pid, giving up" >&2 return 1 fi echo " port $port held by pid $pid, killing" >&2 kill -9 "$pid" 2>/dev/null attempts=$((attempts - 1)) sleep 1 done}
port_answered_by_group() { local port="$1" pgid="$2" pid pid="$(port_pid "$port")" [ -z "$pid" ] && return 0 [ "$(pgid_of "$pid")" = "$pgid" ]}
startup_port() { if [ "$1" != "-" ]; then echo "$1"; else echo "$2"; fi}
wait_for_port() { local port="$1" attempts=60 while [ "$attempts" -gt 0 ]; do (exec 3<>"/dev/tcp/127.0.0.1/$port") 2>/dev/null && { exec 3<&- 3>&-; return 0; } sleep 0.5 attempts=$((attempts - 1)) done return 1}
CURRENT_PGID=""
start_server() { local dir="$1" cmd="$2" port="$3" log="$4"
free_port "$port" || return 1
( cd "$ROOT/$dir" && exec setsid "${PIN_SERVER[@]}" $cmd > "$log" 2>&1 < /dev/null ) & CURRENT_PGID=$!
if ! wait_for_port "$port"; then echo " failed to start, see $log" >&2 stop_server return 1 fi
if ! port_answered_by_group "$port" "$CURRENT_PGID"; then echo " port $port is answered by another process, see $log" >&2 stop_server return 1 fi}
stop_server() { [ -z "$CURRENT_PGID" ] && return 0 kill -TERM -- -"$CURRENT_PGID" 2>/dev/null sleep 1 kill -KILL -- -"$CURRENT_PGID" 2>/dev/null wait "$CURRENT_PGID" 2>/dev/null CURRENT_PGID=""}
trap stop_server EXIT INT TERM HUP PIPE
selected() { local name="$1" allowed="$2" [ -z "$allowed" ] && return 0 case ",$allowed," in *",$name,"*) return 0 ;; *) return 1 ;; esac}