From 7de03e4e519705301265c0415b3c0af85263a7ac Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Wed, 17 Apr 2024 09:52:36 +0200 Subject: Adding upstream version 1:4.13.0. Signed-off-by: Daniel Baumann --- tools/ocft/ocft.in | 893 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 893 insertions(+) create mode 100644 tools/ocft/ocft.in (limited to 'tools/ocft/ocft.in') diff --git a/tools/ocft/ocft.in b/tools/ocft/ocft.in new file mode 100644 index 0000000..0d7f645 --- /dev/null +++ b/tools/ocft/ocft.in @@ -0,0 +1,893 @@ +#!@BASH_SHELL@ + +# Copyright (c) 2010-2013 Novell Inc, John Shi +# All Rights Reserved. +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of version 2 of the GNU General Public License as +# published by the Free Software Foundation. +# +# This program is distributed in the hope that it would be useful, but +# WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. +# +# Further, this software is distributed without any warranty that it is +# free of the rightful claim of any third person regarding infringement +# or the like. Any license provided herein, whether implied or +# otherwise, applies only to this software file. Patent licenses, if +# any, provided herein do not apply to combinations of this program with +# other software, or any other product whatsoever. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write the Free Software Foundation, +# Inc., 59 Temple Place - Suite 330, Boston MA 02111-1307, USA. + +die() +{ + local str + str="$1" + + echo "ERROR: $str" >&2 + exit 1 +} + +warn() +{ + local str + str="$1" + + echo "WARNING: $str" >&2 +} + +parse_die() +{ + local str + str="$1" + + agent_parse_finish + die "${agent}: line ${line_num}: ${str}" +} + +# add quotes to string for Here Documents +add_quotes() +{ + local typ str a b + typ="$1" + str="$2" + + case "$typ" in + 1) a=\'; b=\";; + 2) a=\"; b=\';; + esac + + echo "$str" | sed "s/$a/$a$b$a$b$a/g; 1 s/^/$a/; $ s/$/$a/" +} + +# split strings +explode() +{ + local str + str="$1" + + echo "$str" | awk -F'"' '{ + if (NF > 0 && NF%2 == 0) + exit(1); + for (i=1; i<=NF; i++) { + if (i%2 == 0) + print $i; + else { + len = split($i, str, /[ \t]+/); + for (j=1; j<=len; j++) { + sb = sub(/#.*/, "", str[j]); + if (str[j] != "") + print str[j]; + if (sb) + exit(0); + } + } + } + }' +} + +# phase 1: parse the string to 'command' and 'argument collection'. +line2trunk() +{ + trunk[0]="${line%%[[:blank:]]*}" + trunk[1]="${line#*[[:blank:]]}" +} + +# phase 2: split the argument collection. +trunk2branch() +{ + local IFS + + # Some of statements need one parameter at least. + if [ "$line" = "${trunk[0]}" ]; then + parse_die "missing parameter." + fi + + IFS=$'\n' + branch=($(explode "${trunk[1]}")) + if [ $? -ne 0 ]; then + parse_die "missing '\"'." + fi +} + +preparse_cfg() +{ + local agent line trunk branch macro num host + agent="$1" + + if [ ! -r "$opt_cfgsdir/$agent" ]; then + die "${agent}: configuration file not found." + fi + + line_num=0 + while read -r line; do + let line_num++ + num=" $line_num" + + case "$line" in + ""|\#*) continue;; + esac + + line2trunk + case "${trunk[0]}" in + CASE-BLOCK) + trunk2branch + macro="$CASES_DIR/${agent}_macro.${branch[0]}" + continue + ;; + Include|Include@*) + host=$(echo "${trunk[0]}" | awk -F@ '{print $2}') + trunk2branch + if [ ! -r "$CASES_DIR/${agent}_macro.${branch[0]}" ]; then + parse_die "Macro '${branch[0]}' not found." + fi + if [ -n "$host" ]; then + line="$(sed -e 's/^\([^[:blank:]]*\)@[^[:blank:]]*/\1/' -e "s/^[^[:blank:]]*/&@$host/" "$CASES_DIR/${agent}_macro.${branch[0]}")" + else + line="$(<"$CASES_DIR/${agent}_macro.${branch[0]}")" + fi + num= + ;; + *[!A-Z-]*) + : + ;; + *) + macro= + ;; + esac + + if [ -n "$macro" ]; then + echo "$line$num" >>"$macro" + else + echo "$line$num" >>"$CASES_DIR/${agent}_preparse" + fi + done <"$opt_cfgsdir/$agent" +} + +case_parse_finish() +{ + local host + + if [ -n "$sh" ]; then + cat >>$sh <>$sh + done + echo "quit 0" >>$sh + fi + + atexit_num=0 + hosts= + sh= +} + +init_cfg_vars() +{ + cfg_agent= + cfg_agent_root= + cfg_install_package=() + cfg_hang_timeout=20 +} + +agent_parse_finish() +{ + local suf + + for suf in preparse setup cleanup var hosts; do + rm -f $CASES_DIR/${agent}_$suf + done + rm -f $CASES_DIR/${agent}_macro.* + init_cfg_vars +} + +need_make() +{ + local src_time obj_time + + if [ ! -f "$CASES_DIR/0_${agent}.sh" ]; then + return 0 + fi + + src_time=$(stat -c '%Y' "$opt_cfgsdir/$agent") + obj_time=$(stat -c '%Y' "$CASES_DIR/0_${agent}.sh") + + test $src_time -ge $obj_time +} + +parse_cfg() +{ + local agents i line stat sh trunk branch atexit_num host hosts + + if [ $# -eq 0 ]; then + agents=($opt_cfgsdir/*) + else + agents=("$@") + fi + + for agent in "${agents[@]}"; do + agent="$(basename "$agent")" + + if ! need_make; then + continue + fi + + agent_obj_clean $agent + agent_parse_finish + + i=0 + + echo "Making '$agent': " + preparse_cfg "$agent" + while read -r line; do + line_num="${line##* }" + line="${line% *}" + line2trunk + + # state switch + case "${trunk[0]}" in + CONFIG) + case_parse_finish + stat=1 + continue + ;; + VARIABLE) + case_parse_finish + stat=2 + continue + ;; + SETUP-AGENT) + case_parse_finish + stat=3 + continue + ;; + CLEANUP-AGENT) + case_parse_finish + stat=4 + continue + ;; + CASE) + case_parse_finish + trunk2branch + echo " - case ${i}: ${branch[0]}" + sh="$CASES_DIR/${i}_${agent}.sh" + cat >$sh <>$CASES_DIR/${agent}_var + ;; + 3) + echo "$line" >>$CASES_DIR/${agent}_setup + ;; + 4) + echo "$line" >>$CASES_DIR/${agent}_cleanup + ;; + 5) + host=$(echo ${trunk[0]} | awk -F@ '{print $2}') + if [ -n "$host" ]; then + if ! echo "$hosts" | grep -q "$host"; then + echo "$host" >>$CASES_DIR/${agent}_hosts + hosts=$hosts$'\n'$host + cat >>$sh <>$sh + + if [ -n "$host" ]; then + echo "backbash $host <<'CMD'" >>$sh + fi + + case "${trunk[0]}" in + Env|Env@*) + cat >>$sh <>$sh <>$sh <>$sh <>$sh <>$sh <>$sh <>$sh <>$sh <>$sh + fi + ;; + *) + parse_die "unimplemented statement: ${trunk[0]}" + ;; + esac + done <$CASES_DIR/${agent}_preparse + + if [ -r "$CASES_DIR/${agent}_setup" ]; then + cat >$CASES_DIR/setup_${agent}.sh <>$CASES_DIR/setup_${agent}.sh <>$CASES_DIR/setup_${agent}.sh <$CASES_DIR/cleanup_${agent}.sh <>$CASES_DIR/cleanup_${agent}.sh <>$CASES_DIR/cleanup_${agent}.sh </dev/null 2>&1; then + die "cases directory not found." + fi + + if [ ! -d logs ]; then + mkdir logs + fi + + export __OCFT__VERBOSE=$opt_verbose + + if [ $# -eq 0 ]; then + agents=($(ls -1 *.sh 2>/dev/null | sed 's/.*_\([^_]*\)\.sh$/\1/' | sort | uniq)) + else + agents=("$@") + fi + + for shs in "${agents[@]}"; do + if [ -z "$opt_incremental" ]; then + testsh="setup_${shs}.sh + $(ls -1 [0-9]*_${shs}.sh 2>/dev/null | sort -n) + cleanup_${shs}.sh" + else + testsh="setup_${shs}.sh + $(ls -1 [0-9]*_${shs}.retest 2>/dev/null | sed 's/retest$/sh/' | sort -n) + cleanup_${shs}.sh" + fi + + if [ -n "$opt_trace_ra" ]; then + varlib=${HA_VARLIB:="/var/lib/heartbeat"} + export OCF_RESKEY_trace_ra=1 + echo "RA trace on, output in $varlib/trace_ra" + fi + + rc_f=`mktemp` + (for sh in $testsh; do + if [ -r "$sh" ]; then + if [ -n "$opt_trace_ra" ]; then + export OCF_RESOURCE_INSTANCE="`echo $sh | sed 's/_.*//'`" + fi + ./$sh + ret=$? + + case "$sh" in + setup*) + rc=$((rc|ret)) + if [ $ret -ne 0 ]; then + warn "SETUP failed, break all tests of '$shs'." + break + fi + ;; + cleanup*) + if [ $ret -ne 0 ]; then + warn "CLEANUP failed." + fi + ;; + [0-9]*) + case $ret in + 3) die "core function failed, break all tests." ;; + 2) warn "core function failed, break all tests of '$shs'."; break ;; + 1) touch ${sh%.*}.retest ;; + 0) rm -f ${sh%.*}.retest ;; + esac + rc=$((rc|ret)) + ;; + esac + fi + done 2>&1; echo $rc > $rc_f) | while read -r line; do + echo "$line" + echo "$(date '+%F %T'): $line" | cat -A | + sed -r 's/\^\[\[[0-9]+m|\^I|.$//g' >>logs/$shs.log + done + done + rc=`cat $rc_f` + rm -f $rc_f + return $rc +} + +agent_clean() +{ + local typ ra + typ=$1 + + shift + + if [ $# -eq 0 ]; then + rm -f $CASES_DIR/*.$typ + else + for ra in "$@"; do + rm -f $CASES_DIR/*_${ra}.$typ + done + fi +} + +agent_retest_clean() +{ + agent_clean retest "$@" +} + +agent_obj_clean() +{ + agent_clean sh "$@" +} + +usage() +{ + cat <