72 lines
1.4 KiB
Bash
72 lines
1.4 KiB
Bash
|
#!/bin/bash
|
||
|
|
|
||
|
|
RED='\033[1;31m'
|
||
|
|
GRN='\033[1;32m'
|
||
|
|
YEL='\033[1;33m'
|
||
|
|
BLU='\033[1;34m'
|
||
|
|
WHT='\033[1;37m'
|
||
|
|
MGT='\033[1;95m'
|
||
|
|
CYA='\033[1;96m'
|
||
|
|
END='\033[0m'
|
||
|
|
|
||
|
|
function section() {
|
||
|
|
echo ""
|
||
|
|
log "***** Section: ${MGT}$1${END} *****";
|
||
|
|
echo ""
|
||
|
|
}
|
||
|
|
|
||
|
|
function log() { >&2 printf "${WHT}#${END} $1\n"; }
|
||
|
|
|
||
|
|
function error() { >&2 printf "${WHT}#${END} ${RED}$1${END}\n"; }
|
||
|
|
|
||
|
|
# takes a function and many inputs, runs function on each input in parallel
|
||
|
|
# inputs should be stored deliniated by newlines in $2
|
||
|
|
# if $3 exists it will be a stub for logging filename
|
||
|
|
function parallel_invoke_and_wait() {
|
||
|
|
local procedure=$1
|
||
|
|
local pids=()
|
||
|
|
local rets=()
|
||
|
|
|
||
|
|
if [[ ! $1 ]]; then
|
||
|
|
log "failed to invoke null procedure"
|
||
|
|
return 1
|
||
|
|
fi
|
||
|
|
|
||
|
|
if [[ ! $2 ]]; then
|
||
|
|
log "failed to invoke procedure on 0 inputs"
|
||
|
|
return 1
|
||
|
|
fi
|
||
|
|
|
||
|
|
IFS=$'\n'
|
||
|
|
for input in $2; do
|
||
|
|
log "invoking procedure with input $input"
|
||
|
|
if [[ $3 ]]; then
|
||
|
|
$procedure $input &>${3}${input}.log &
|
||
|
|
else
|
||
|
|
$procedure $input &
|
||
|
|
fi
|
||
|
|
pids+=("$input/$!")
|
||
|
|
done
|
||
|
|
|
||
|
|
cf="true"
|
||
|
|
for pid in ${pids[*]}; do
|
||
|
|
local p=$(basename $pid)
|
||
|
|
local input=$(dirname $pid)
|
||
|
|
wait $p
|
||
|
|
local code=$?
|
||
|
|
log "procedure with input $input returned $code"
|
||
|
|
if [[ $3 && ! $code == 0 ]]; then # needs to catch code==2, etc
|
||
|
|
log "tail of related logs..."
|
||
|
|
tail ${3}${input}.log
|
||
|
|
log "see more in ${3}${input}.log"
|
||
|
|
cf="false"
|
||
|
|
fi
|
||
|
|
done
|
||
|
|
|
||
|
|
if [[ $cf == "false" ]]; then
|
||
|
|
return 1
|
||
|
|
else
|
||
|
|
return 0
|
||
|
|
fi
|
||
|
|
}
|