+ out=$(pgrep "$CONSUMERD_MATCH")
+ if [ -n "$dtimeleft_s" ]; then
+ if [ $dtimeleft_s -lt 0 ]; then
+ out=
+ retval=1
+ fi
+ dtimeleft_s=$((dtimeleft_s - 1))
+ fi
+ sleep 0.5
+ done
+
+ if [ "$withtap" -eq "1" ]; then
+ if [ "$retval" -eq "0" ]; then
+ pass "Wait after kill session daemon"
+ else
+ fail "Wait after kill session daemon"
+ fi
+ fi
+ fi
+ if [ "$signal" = "SIGKILL" ]; then
+ if [ "$(id -u)" -eq "0" ]; then
+ local modules=
+ modules="$(lsmod | grep ^lttng | awk '{print $1}')"
+
+ if [ -n "$modules" ]; then
+ diag "Unloading all LTTng modules"
+ modprobe -r "$modules"
+ fi
+ fi
+ fi
+
+ return $retval
+}
+
+function stop_lttng_sessiond()
+{
+ stop_lttng_sessiond_opt 1 "$@"
+}
+
+function stop_lttng_sessiond_notap()
+{
+ stop_lttng_sessiond_opt 0 "$@"
+}
+
+function sigstop_lttng_sessiond_opt()
+{
+ local withtap=$1
+ local signal=SIGSTOP
+
+ if [ -n "$TEST_NO_SESSIOND" ] && [ "$TEST_NO_SESSIOND" == "1" ]; then
+ # Env variable requested no session daemon
+ return
+ fi
+
+ PID_SESSIOND="$(pgrep "${SESSIOND_MATCH}") $(pgrep "$RUNAS_MATCH")"
+
+ if [ "$withtap" -eq "1" ]; then
+ diag "Sending SIGSTOP to lt-$SESSIOND_BIN and $SESSIOND_BIN pids: $(echo "$PID_SESSIOND" | tr '\n' ' ')"
+ fi
+
+ # shellcheck disable=SC2086
+ if ! kill -s $signal $PID_SESSIOND 1> $OUTPUT_DEST 2> $ERROR_OUTPUT_DEST; then
+ if [ "$withtap" -eq "1" ]; then
+ fail "Sending SIGSTOP to session daemon"
+ fi
+ else
+ out=1
+ while [ $out -ne 0 ]; do
+ pid="$(pgrep "$SESSIOND_MATCH")"
+
+ # Wait until state becomes stopped for session
+ # daemon(s).
+ out=0
+ for sessiond_pid in $pid; do
+ state="$(ps -p "$sessiond_pid" -o state= )"
+ if [[ -n "$state" && "$state" != "T" ]]; then
+ out=1
+ fi
+ done
+ sleep 0.5
+ done
+ if [ "$withtap" -eq "1" ]; then
+ pass "Sending SIGSTOP to session daemon"
+ fi
+ fi
+}
+
+function sigstop_lttng_sessiond()
+{
+ sigstop_lttng_sessiond_opt 1 "$@"
+}
+
+function sigstop_lttng_sessiond_notap()
+{
+ sigstop_lttng_sessiond_opt 0 "$@"
+}
+
+function stop_lttng_consumerd_opt()
+{
+ local withtap=$1
+ local signal=$2
+
+ if [ -z "$signal" ]; then
+ signal=SIGTERM
+ fi
+
+ local timeout_s=$3
+ local dtimeleft_s=
+
+ # Multiply time by 2 to simplify integer arithmetic
+ if [ -n "$timeout_s" ]; then
+ dtimeleft_s=$((timeout_s * 2))
+ fi
+
+ local retval=0
+
+ PID_CONSUMERD="$(pgrep "$CONSUMERD_MATCH")"
+
+ if [ -z "$PID_CONSUMERD" ]; then
+ if [ "$withtap" -eq "1" ]; then
+ pass "No consumer daemon to kill"
+ fi
+ return 0
+ fi
+
+ diag "Killing (signal $signal) $CONSUMERD_BIN pids: $(echo "$PID_CONSUMERD" | tr '\n' ' ')"
+
+ # shellcheck disable=SC2086
+ if ! kill -s $signal $PID_CONSUMERD 1> $OUTPUT_DEST 2> $ERROR_OUTPUT_DEST; then
+ retval=1
+ if [ "$withtap" -eq "1" ]; then
+ fail "Kill consumer daemon"
+ fi
+ else
+ out=1
+ while [ $out -ne 0 ]; do
+ pid="$(pgrep "$CONSUMERD_MATCH")"
+
+ # If consumerds are still present check their status.
+ # A zombie status qualifies the consumerd as *killed*
+ out=0
+ for consumer_pid in $pid; do
+ state="$(ps -p "$consumer_pid" -o state= )"
+ if [[ -n "$state" && "$state" != "Z" ]]; then
+ out=1
+ fi
+ done
+ if [ -n "$dtimeleft_s" ]; then
+ if [ $dtimeleft_s -lt 0 ]; then
+ out=0
+ retval=1
+ fi
+ dtimeleft_s=$((dtimeleft_s - 1))
+ fi
+ sleep 0.5
+ done
+ if [ "$withtap" -eq "1" ]; then
+ if [ "$retval" -eq "0" ]; then
+ pass "Wait after kill consumer daemon"
+ else
+ fail "Wait after kill consumer daemon"
+ fi
+ fi
+ fi
+
+ return $retval
+}
+
+function stop_lttng_consumerd()
+{
+ stop_lttng_consumerd_opt 1 "$@"
+}
+
+function stop_lttng_consumerd_notap()
+{
+ stop_lttng_consumerd_opt 0 "$@"
+}
+
+function sigstop_lttng_consumerd_opt()
+{
+ local withtap=$1
+ local signal=SIGSTOP
+
+ PID_CONSUMERD="$(pgrep "$CONSUMERD_MATCH")"
+
+ diag "Sending SIGSTOP to $CONSUMERD_BIN pids: $(echo "$PID_CONSUMERD" | tr '\n' ' ')"
+
+ # shellcheck disable=SC2086
+ kill -s $signal $PID_CONSUMERD 1> $OUTPUT_DEST 2> $ERROR_OUTPUT_DEST
+ retval=$?
+
+ if [ $retval -eq 1 ]; then
+ if [ "$withtap" -eq "1" ]; then
+ fail "Sending SIGSTOP to consumer daemon"
+ fi
+ return 1
+ else
+ out=1
+ while [ $out -ne 0 ]; do
+ pid="$(pgrep "$CONSUMERD_MATCH")"
+
+ # Wait until state becomes stopped for all
+ # consumers.
+ out=0
+ for consumer_pid in $pid; do
+ state="$(ps -p "$consumer_pid" -o state= )"
+ if [[ -n "$state" && "$state" != "T" ]]; then
+ out=1
+ fi
+ done