mirror of
https://github.com/casjaysdevdocker/gitea
synced 2026-06-24 08:01:03 -04:00
jason
0abc43bffc
Runners were launched in parallel subshells with only a 2-second gap between them. act_runner register is a network call; if Gitea was still warming up any registration could race past an earlier one, causing Gitea to assign IDs out of sequence (1,3,2,5,4 instead of 1,2,3,4,5). Split into two phases: register all runners sequentially first so IDs are assigned in the correct order, then launch all daemons in parallel once every runner is confirmed registered. - rootfs/usr/local/bin/start-runners: split __start_runner into __register_runner (sequential, phase 1) and __start_runner_daemon (parallel, phase 2); remove the sleep 2 workaround rootfs/usr/local/bin/start-runners
105 lines
5.0 KiB
Bash
Executable File
105 lines
5.0 KiB
Bash
Executable File
#!/usr/bin/env bash
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
set -e
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
trap 'retVal=$?; echo "❌ Fatal error occurred: Exit code $retVal at line $LINENO in command: $BASH_COMMAND"; kill -TERM 1' ERR
|
|
trap 'retVal=$?;if [ "$SERVICE_IS_RUNNING" != "yes" ] && [ -f "$SERVICE_PID_FILE" ]; then rm -Rf "$SERVICE_PID_FILE"; fi;exit $retVal' SIGINT SIGTERM SIGPWR
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Function to __log messages with timestamp
|
|
__log() { echo "[$(date '+%Y-%m-%d %H:%M:%S')] $1" >>"$RUNNERS_LOG_DIR/runners" 2>&1; }
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Function to cleanup child processes on exit
|
|
__cleanup() {
|
|
__log "Shutting down runners..."
|
|
kill $(jobs -p) 2>/dev/null || true
|
|
wait
|
|
__log "All runners stopped"
|
|
}
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Set up signal handling
|
|
trap __cleanup SIGTERM SIGINT
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Validate required environment variables
|
|
if [ -n "$SERVER_ADDRESS" ]; then
|
|
if ! echo "$SERVER_ADDRESS" | grep -q '://'; then
|
|
SERVER_ADDRESS="http://$SERVER_ADDRESS"
|
|
fi
|
|
else
|
|
SERVER_ADDRESS=http://$HOSTNAME
|
|
fi
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
if [ -z "$SERVER_TOKEN" ]; then
|
|
__log "ERROR: SERVER_TOKEN environment variable is required"
|
|
exit 1
|
|
fi
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
RUNNER_LABELS="${RUNNER_LABELS:-linux:host,node14:docker://node:14,node16:docker://node:16,node18:docker://node:18,node20:docker://node:20,node22:docker://node:22,node:docker://node:latest,perl:docker://perl:latest,ruby:docker://ruby:latest,python:docker://python:latest,python3:docker://python:latest,php7:docker://casjaysdevdocker/php:7,php8:docker://casjaysdevdocker/php:8,php:docker://casjaysdevdocker/php:latest,alpine:docker://casjaysdev/alpine:latest,debian:docker://casjaysdev/debian:latest,ubuntu:docker://casjaysdev/ubuntu:latest,rhel:docker://casjaysdev/almalinux:latest,redhat:docker://casjaysdev/almalinux:latest,almalinux:docker://casjaysdev/almalinux:latest,act_runner:docker://catthehacker/ubuntu:full-latest,ubuntu-latest:docker://catthehacker/ubuntu:full-latest}"
|
|
# Determine number of runners to start
|
|
RUNNERS_START=${RUNNERS_START:-1}
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Validate RUNNERS_START is a positive integer
|
|
if ! [[ "$RUNNERS_START" =~ ^[0-9]+$ ]] || [ "$RUNNERS_START" -lt 1 ]; then
|
|
__log "WARNING: Invalid RUNNERS_START value '$RUNNERS_START', defaulting to 1"
|
|
RUNNERS_START=1
|
|
fi
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
__log "Starting $RUNNERS_START act_runner instance(s)"
|
|
__log "Server Address: $SERVER_ADDRESS"
|
|
__log "Runner Name Prefix: ${RUNNER_NAME_PREFIX:-runner}"
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Register a single runner synchronously (no daemon start)
|
|
__register_runner() {
|
|
local runner_id=$1
|
|
local runner_name="${RUNNER_NAME_PREFIX:-runner}-${runner_id}"
|
|
local runner_dir="/config/act_runner/reg/${runner_name}"
|
|
|
|
mkdir -p "$runner_dir"
|
|
[ -d "$runner_dir" ] && cd "$runner_dir" || return 1
|
|
|
|
if [ ! -f "$runner_dir/.runner" ]; then
|
|
__log "Registering runner: $runner_name (ID: $runner_id)"
|
|
act_runner register --instance "$SERVER_ADDRESS" --token "$SERVER_TOKEN" --name "$runner_name" --labels "$RUNNER_LABELS" --no-interactive
|
|
if [ $? -ne 0 ]; then
|
|
__log "ERROR: Failed to register runner $runner_name"
|
|
return 1
|
|
fi
|
|
fi
|
|
__log "Runner $runner_name registered"
|
|
}
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Start daemon for a single runner (called in background after all are registered)
|
|
__start_runner_daemon() {
|
|
local runner_id=$1
|
|
local runner_name="${RUNNER_NAME_PREFIX:-runner}-${runner_id}"
|
|
local runner_dir="/config/act_runner/reg/${runner_name}"
|
|
|
|
[ -d "$runner_dir" ] && cd "$runner_dir" || return 1
|
|
__log "Starting daemon for runner: $runner_name"
|
|
exec act_runner daemon
|
|
}
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Phase 1: register all runners sequentially so IDs are assigned in order
|
|
for i in $(seq 1 $RUNNERS_START); do
|
|
__register_runner "$i" || { __log "Aborting: registration failed for runner-$i"; exit 1; }
|
|
done
|
|
unset i
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Phase 2: start all daemons in parallel
|
|
for i in $(seq 1 $RUNNERS_START); do
|
|
(__start_runner_daemon "$i") &
|
|
done
|
|
unset i
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
RUNNERS_ID="$(jobs -p | tr '\n' ' ')"
|
|
if [ -n "$RUNNERS_ID" ]; then
|
|
__log "All $RUNNERS_START runners started successfully"
|
|
__log "Process IDs: $RUNNERS_ID"
|
|
printf 'All %s runners started successfully: %s\n' "$RUNNERS_START" "$RUNNERS_ID"
|
|
else
|
|
__log "The runners have failed to start"
|
|
printf '%s\n' "The runners have failed to start"
|
|
fi
|
|
# - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
|
|
# Wait for all background processes
|
|
wait
|