-# If we're not running on a real cluster then we need a local copy of
-# ctdb (and other stuff) in $PATH and we will use local daemons.
-
-export CTDB_NODES_SOCKETS=""
-for i in $(seq 0 $(($TEST_LOCAL_DAEMONS - 1))) ; do
- CTDB_NODES_SOCKETS="${CTDB_NODES_SOCKETS}${CTDB_NODES_SOCKETS:+ }${TEST_VAR_DIR}/sock.${i}"
-done
-
-# Use in-tree binaries if running against local daemons.
-# Otherwise CTDB need to be installed on all nodes.
-if [ -n "$ctdb_dir" -a -d "${ctdb_dir}/bin" ] ; then
- PATH="${ctdb_dir}/bin:${PATH}"
- export CTDB_LOCK_HELPER="${ctdb_dir}/bin/ctdb_lock_helper"
- export CTDB_EVENT_HELPER="${ctdb_dir}/bin/ctdb_event_helper"
-fi
-
-export CTDB_NODES="${TEST_VAR_DIR}/nodes.txt"
+# Hey Emacs, this is a -*- shell-script -*- !!! :-)
-#######################################
-
-daemons_stop ()
-{
- echo "Attempting to politely shutdown daemons..."
- onnode 1 $CTDB shutdown -n all || true
+hdir="$CTDB_SCRIPTS_HELPER_BINDIR"
+export CTDB_EVENT_HELPER="${hdir}/ctdb-event"
- echo "Sleeping for a while..."
- sleep_for 1
+if $CTDB_TESTS_ARE_INSTALLED ; then
+ # Find it in $PATH
+ helper="ctdb_local_daemons"
+else
+ helper="${CTDB_TEST_DIR}/local_daemons.sh"
+fi
- local pat="ctdbd --socket=${TEST_VAR_DIR}/.* --nlist .* --nopublicipcheck"
- if pgrep -f "$pat" >/dev/null ; then
- echo "Killing remaining daemons..."
- pkill -f "$pat"
+ctdb_local_daemons="${helper} ${SIMPLE_TESTS_VAR_DIR}"
- if pgrep -f "$pat" >/dev/null ; then
- echo "Once more with feeling.."
- pkill -9 -f "$pat"
- fi
- fi
+# onnode will execute this, which fakes ssh against local daemons
+export ONNODE_SSH="${ctdb_local_daemons} ssh"
- rm -rf "${TEST_VAR_DIR}/test.db"
-}
+#######################################
setup_ctdb ()
{
- mkdir -p "${TEST_VAR_DIR}/test.db/persistent"
-
- local public_addresses_all="${TEST_VAR_DIR}/public_addresses_all"
- local no_public_addresses="${TEST_VAR_DIR}/no_public_addresses.txt"
- rm -f $CTDB_NODES $public_addresses_all $no_public_addresses
-
- # If there are (strictly) greater than 2 nodes then we'll randomly
- # choose a node to have no public addresses.
- local no_public_ips=-1
- [ $TEST_LOCAL_DAEMONS -gt 2 ] && no_public_ips=$(($RANDOM % $TEST_LOCAL_DAEMONS))
- echo "$no_public_ips" >$no_public_addresses
-
- # When running certain tests we add and remove eventscripts, so we
- # need to be able to modify the events.d/ directory. Therefore,
- # we use a temporary events.d/ directory under $TEST_VAR_DIR. We
- # copy the actual test eventscript(s) in there from the original
- # events.d/ directory that sits alongside $TEST_SCRIPT_DIR.
- local top=$(dirname "$TEST_SCRIPTS_DIR")
- local events_d="${top}/events.d"
- mkdir -p "${TEST_VAR_DIR}/events.d"
- cp -p "${events_d}/"* "${TEST_VAR_DIR}/events.d/"
-
- local i
- for i in $(seq 1 $TEST_LOCAL_DAEMONS) ; do
- if [ "${CTDB_USE_IPV6}x" != "x" ]; then
- echo ::$i >>"$CTDB_NODES"
- ip addr add ::$i/128 dev lo
- else
- echo 127.0.0.$i >>"$CTDB_NODES"
- # 2 public addresses on most nodes, just to make things interesting.
- if [ $(($i - 1)) -ne $no_public_ips ] ; then
- echo "192.168.234.$i/24 lo" >>"$public_addresses_all"
- echo "192.168.234.$(($i + $TEST_LOCAL_DAEMONS))/24 lo" >>"$public_addresses_all"
- fi
+ local public_addresses=""
+ local no_event_scripts=false
+ local disable_failover=""
+ local reclock_use_command=""
+ case "$1" in
+ --no-public-addresses) public_addresses="/dev/null" ;;
+ --no-event-scripts) no_event_scripts=true ;;
+ --disable-failover) disable_failover="yes" ;;
+ --reclock-use-command) reclock_use_command="yes" ;;
+ esac
+
+ $ctdb_local_daemons setup \
+ -n "$TEST_LOCAL_DAEMONS" \
+ ${disable_failover:+-F} \
+ ${public_addresses:+-P} ${public_addresses} \
+ ${CTDB_USE_IPV6:+-6} \
+ ${reclock_use_command:+-R} \
+ ${TEST_SOCKET_WRAPPER_SO_PATH:+-S ${TEST_SOCKET_WRAPPER_SO_PATH}}
+ # Burying the above in an if-statement condition reduces readability.
+ # shellcheck disable=SC2181
+ if [ $? -ne 0 ] ; then
+ exit 1
fi
- done
+
+ local pnn
+ for pnn in $(seq 0 $((TEST_LOCAL_DAEMONS - 1))) ; do
+ if $no_event_scripts ; then
+ rm -vf "${CTDB_BASE}/events/legacy/"*
+ fi
+ done
}
-daemons_start_1 ()
+start_ctdb_1 ()
{
- local pnn="$1"
- shift # "$@" gets passed to ctdbd
-
- local public_addresses_all="${TEST_VAR_DIR}/public_addresses_all"
- local public_addresses_mine="${TEST_VAR_DIR}/public_addresses.${pnn}"
- local no_public_addresses="${TEST_VAR_DIR}/no_public_addresses.txt"
-
- local no_public_ips=-1
- [ -r $no_public_addresses ] && read no_public_ips <$no_public_addresses
-
- if [ "$no_public_ips" = $pnn ] ; then
- echo "Node $no_public_ips will have no public IPs."
- fi
-
- local node_ip=$(sed -n -e "$(($pnn + 1))p" "$CTDB_NODES")
- local ctdb_options="--sloppy-start --reclock=${TEST_VAR_DIR}/rec.lock --nlist $CTDB_NODES --nopublicipcheck --listen=${node_ip} --event-script-dir=${TEST_VAR_DIR}/events.d --logfile=${TEST_VAR_DIR}/daemon.${pnn}.log -d 3 --dbdir=${TEST_VAR_DIR}/test.db --dbdir-persistent=${TEST_VAR_DIR}/test.db/persistent --dbdir-state=${TEST_VAR_DIR}/test.db/state --nosetsched"
+ local pnn="$1"
- if [ $pnn -eq $no_public_ips ] ; then
- ctdb_options="$ctdb_options --public-addresses=/dev/null"
- else
- cp "$public_addresses_all" "$public_addresses_mine"
- ctdb_options="$ctdb_options --public-addresses=$public_addresses_mine"
- fi
-
- # We'll use "pkill -f" to kill the daemons with
- # "--socket=.* --nlist .* --nopublicipcheck" as context.
- $VALGRIND ctdbd --socket="${TEST_VAR_DIR}/sock.$pnn" $ctdb_options "$@" ||return 1
+ $ctdb_local_daemons start "$pnn"
}
-daemons_start ()
+ctdb_start_all ()
{
- # "$@" gets passed to ctdbd
+ $ctdb_local_daemons start "all"
+}
- echo "Starting $TEST_LOCAL_DAEMONS ctdb daemons..."
+stop_ctdb_1 ()
+{
+ local pnn="$1"
- for i in $(seq 0 $(($TEST_LOCAL_DAEMONS - 1))) ; do
- daemons_start_1 $i "$@"
- done
+ $ctdb_local_daemons stop "$pnn"
}
-maybe_stop_ctdb ()
+ctdb_stop_all ()
{
- if $TEST_CLEANUP ; then
- daemons_stop
- fi
+ $ctdb_local_daemons stop "all"
}
-_restart_ctdb_all ()
+restart_ctdb_1 ()
{
- daemons_stop
- daemons_start "$@"
+ stop_ctdb_1 "$1"
+ start_ctdb_1 "$1"
}
+
+# onnode just needs the nodes file, so use the common one
+export CTDB_BASE="$SIMPLE_TESTS_VAR_DIR"
git.samba.org / samba.git / blobdiff