mirror of
https://gitlab.com/prpl-foundation/prplmesh/prplMesh.git
synced 2025-12-20 01:21:22 +08:00
prplmesh_utils: simplify script and unify entrypoint
Rework prplmesh_utils.sh to serve as a unified entrypoint for prplMesh start/stop/restart and mode selection, to be used until the prplMesh ProcessManager is released. Closes: PPM-3589 Signed-off-by: Igor Plesser <i.plesser@inango-systems.com>
This commit is contained in:
Igor Plesser
@@ -1,196 +1,52 @@
|
||||
#!/bin/sh
|
||||
###############################################################
|
||||
# SPDX-License-Identifier: BSD-2-Clause-Patent
|
||||
# SPDX-FileCopyrightText: 2019-2020 the prplMesh contributors (see AUTHORS.md)
|
||||
# SPDX-FileCopyrightText: 2019-2025 the prplMesh contributors (see AUTHORS.md)
|
||||
# This code is subject to the terms of the BSD+Patent license.
|
||||
# See LICENSE file for more details.
|
||||
###############################################################
|
||||
|
||||
scriptdir="$(dirname "$(readlink -f "${0}")")"
|
||||
PRPLMESH_DIR="$(cd "${scriptdir}/.." && pwd)"
|
||||
SCRIPTDIR="$(dirname "$(readlink -f "${0}")")"
|
||||
PRPLMESH_DIR="$(cd "${SCRIPTDIR}/.." && pwd)"
|
||||
TARGET_PLATFORM=@TARGET_PLATFORM@
|
||||
ODL_FILES="
|
||||
${PRPLMESH_DIR}/share/agent/odl/agent.odl
|
||||
${PRPLMESH_DIR}/config/agent/odl/defaults.d/00_slave_configuration.odl
|
||||
"
|
||||
|
||||
# Explicitely ignore SIGPIPE to make sure the processes we start in
|
||||
# the background do not stop in case stdout/stderr gets closed early
|
||||
# (because the SSH connection calling the script is closed as soon as
|
||||
# the utils script exits for example). Similarly, ignore SIGHUP to
|
||||
# make sure the processes do not stop when the session leader
|
||||
# terminates:
|
||||
trap '' HUP PIPE
|
||||
|
||||
dbg() {
|
||||
[ "$VERBOSE" = "true" ] && echo "$@"
|
||||
}
|
||||
|
||||
err() {
|
||||
printf '\033[1;31m%s\n\033[0m' "$*"
|
||||
}
|
||||
|
||||
success() {
|
||||
printf '\033[1;32m%s\n\033[0m' "$*"
|
||||
}
|
||||
|
||||
run() {
|
||||
dbg "$*"
|
||||
"$@" || exit $?
|
||||
}
|
||||
|
||||
killall_program() {
|
||||
send_signal_to_prplmesh_process() {
|
||||
PROGRAM_NAME=$1
|
||||
SIG=${2:-TERM}
|
||||
|
||||
echo "sending signal to ${PROGRAM_NAME} (${SIG})"
|
||||
start-stop-daemon -K -s "${SIG}" -x "${PRPLMESH_DIR}/bin/${PROGRAM_NAME}" > /dev/null 2>&1
|
||||
}
|
||||
|
||||
start_prplmesh_process() {
|
||||
PROGRAM_NAME=$1
|
||||
|
||||
echo "starting ${PROGRAM_NAME}"
|
||||
start-stop-daemon -S -b -x "${PRPLMESH_DIR}/bin/${PROGRAM_NAME}" > /dev/null 2>&1
|
||||
}
|
||||
|
||||
stop_prplmesh_process() {
|
||||
PROGRAM_NAME=$1
|
||||
TERM_SIG=${2:-TERM}
|
||||
TIMEOUT=10
|
||||
echo "terminating $PROGRAM_NAME ($TERM_SIG)"
|
||||
start-stop-daemon -K -s "$TERM_SIG" -x "$PRPLMESH_DIR/bin/$PROGRAM_NAME" > /dev/null 2>&1
|
||||
|
||||
# If an explicit signal was provided, we don't do a SIGKILL
|
||||
if [ -n "$2" ]; then return; fi
|
||||
echo "stop ${PROGRAM_NAME} via signals"
|
||||
send_signal_to_prplmesh_process "${PROGRAM_NAME}"
|
||||
|
||||
# `-R` option is not always available for `start-stop-daemon`, we need to imitate it
|
||||
for _ in $(seq 1 "$TIMEOUT"); do
|
||||
if ! pgrep -f "$PROGRAM_NAME" > /dev/null; then
|
||||
return
|
||||
for _ in $(seq 1 "${TIMEOUT}"); do
|
||||
if ! pgrep -f "${PROGRAM_NAME}" > /dev/null; then
|
||||
return 0
|
||||
fi
|
||||
sleep 1
|
||||
done
|
||||
|
||||
echo "killing $PROGRAM_NAME (KILL)"
|
||||
start-stop-daemon -K -s "KILL" -x "$PRPLMESH_DIR/bin/$PROGRAM_NAME" > /dev/null 2>&1
|
||||
send_signal_to_prplmesh_process "${PROGRAM_NAME}" "KILL"
|
||||
}
|
||||
|
||||
platform_init() {
|
||||
echo "platform init..."
|
||||
[ -z "$DATA_IFACE" ] && err "DATA_IFACE not set, abort" && exit 1
|
||||
[ -z "$CONTROL_IFACE" ] && err "CONTROL_IFACE not set, abort" && exit 1
|
||||
base_mac=46:55:66:77
|
||||
bridge_ip=192.168.100.140
|
||||
control_ip=192.168.250.140
|
||||
|
||||
ip link add @BEEROCKS_BRIDGE_IFACE@ address "${base_mac}:00:00" type bridge
|
||||
ip link add @BEEROCKS_WLAN1_IFACE@ address "${base_mac}:00:10" type dummy
|
||||
ip link add @BEEROCKS_WLAN2_IFACE@ address "${base_mac}:00:20" type dummy
|
||||
ip link set dev @BEEROCKS_WLAN1_IFACE@ up
|
||||
ip link set dev @BEEROCKS_WLAN2_IFACE@ up
|
||||
for iface in @BEEROCKS_WLAN1_IFACE@ @BEEROCKS_WLAN2_IFACE@ $DATA_IFACE
|
||||
do
|
||||
echo "add $iface to @BEEROCKS_BRIDGE_IFACE@"
|
||||
nmcli d set "$iface" managed no
|
||||
ip link set dev "$iface" master @BEEROCKS_BRIDGE_IFACE@
|
||||
ip addr flush "$iface"
|
||||
done
|
||||
ip addr add "$control_ip"/24 dev "$CONTROL_IFACE"
|
||||
ip addr add "$bridge_ip"/24 dev @BEEROCKS_BRIDGE_IFACE@
|
||||
ip link set @BEEROCKS_BRIDGE_IFACE@ up
|
||||
}
|
||||
|
||||
platform_deinit() {
|
||||
echo "platform deinit"
|
||||
[ -z "$DATA_IFACE" ] && err "DATA_IFACE not set, abort" && exit 1
|
||||
[ -z "$CONTROL_IFACE" ] && err "CONTROL_IFACE not set, abort" && exit 1
|
||||
for iface in @BEEROCKS_WLAN1_IFACE@ @BEEROCKS_WLAN2_IFACE@ $DATA_IFACE
|
||||
do
|
||||
echo "remove $iface from @BEEROCKS_BRIDGE_IFACE@"
|
||||
ip link set dev "$iface" nomaster
|
||||
nmcli d set "$iface" managed yes
|
||||
done
|
||||
ip link del @BEEROCKS_WLAN1_IFACE@
|
||||
ip link del @BEEROCKS_WLAN2_IFACE@
|
||||
ip link del @BEEROCKS_BRIDGE_IFACE@
|
||||
}
|
||||
|
||||
prplmesh_platform_db_init() {
|
||||
management_mode=${1-Multi-AP-Controller-and-Agent}
|
||||
operating_mode=${2-Gateway}
|
||||
|
||||
mkdir -p @TMP_PATH@
|
||||
|
||||
# Put generated prplmesh_platform_db file to the temporary directory
|
||||
cp "${PRPLMESH_DIR}/share/prplmesh_platform_db" @TMP_PATH@/prplmesh_platform_db
|
||||
|
||||
# Modify generated parameters to current
|
||||
sed -i "s/management_mode=.*/management_mode=${management_mode}/g" @TMP_PATH@/prplmesh_platform_db
|
||||
sed -i "s/operating_mode=.*/operating_mode=${operating_mode}/g" @TMP_PATH@/prplmesh_platform_db
|
||||
}
|
||||
|
||||
prplmesh_framework_init() {
|
||||
# This is required for solveing issue which causing meesges not geeting to their destination.
|
||||
# For more information see: https://github.com/prplfoundation/prplMesh/pull/1029#issuecomment-608353274
|
||||
ebtables -A FORWARD -d 01:80:c2:00:00:13 -j DROP || {
|
||||
printf "Failed to add the required ebtables rule.\n" >&2
|
||||
printf "Please make sure the 'ebtables' kernel module is loaded and try again.\n" >&2
|
||||
exit 1
|
||||
}
|
||||
|
||||
echo "prplmesh_framework_init - starting ieee1905_transport process..."
|
||||
"$PRPLMESH_DIR/bin/ieee1905_transport" &
|
||||
}
|
||||
|
||||
prplmesh_framework_deinit() {
|
||||
echo "prplmesh_framework_deinit - killing ieee1905_transport process..."
|
||||
killall_program ieee1905_transport
|
||||
ebtables -D FORWARD -d 01:80:c2:00:00:13 -j DROP
|
||||
}
|
||||
|
||||
prplmesh_controller_start() {
|
||||
echo "prplmesh_controller_start - start beerocks_controller process..."
|
||||
"$PRPLMESH_DIR/bin/beerocks_controller" &
|
||||
}
|
||||
|
||||
prplmesh_controller_stop() {
|
||||
echo "prplmesh_controller_stop - stopping beerocks_controller process..."
|
||||
killall_program beerocks_controller
|
||||
}
|
||||
|
||||
prplmesh_agent_start() {
|
||||
echo "prplmesh_agent_start - start beerocks_agent process..."
|
||||
"$PRPLMESH_DIR/bin/beerocks_agent" &
|
||||
}
|
||||
|
||||
prplmesh_agent_stop() {
|
||||
echo "prplmesh_agent_stop - stopping beerocks_agent process..."
|
||||
killall_program beerocks_fronthaul
|
||||
killall_program beerocks_agent
|
||||
}
|
||||
|
||||
prplmesh_vendor_message_start() {
|
||||
echo "prplmesh_vendor_message_start - start beerocks_vendor_message process..."
|
||||
"$PRPLMESH_DIR/bin/beerocks_vendor_message" &
|
||||
}
|
||||
|
||||
prplmesh_vendor_message_stop() {
|
||||
echo "prplmesh_vendor_message_stop - stopping beerocks_vendor_message process..."
|
||||
killall_program beerocks_vendor_message
|
||||
}
|
||||
|
||||
prplmesh_delete_logs() {
|
||||
echo "deleting logs"
|
||||
rm -rf @BEEROCKS_LOG_FILES_PATH@
|
||||
|
||||
# Relevant only for Linux environment
|
||||
rm -rf "/tmp/beerocks/logs"
|
||||
}
|
||||
|
||||
prplmesh_watchdog() {
|
||||
# Store PIDs of the Controller and Agents
|
||||
CURR_PIDS="$(pgrep -f 'beerocks_(agent|controller|vendor_message)' | wc -l)"
|
||||
PREV_PIDS="$CURR_PIDS"
|
||||
|
||||
# Make sure there's at least one PID to monitor
|
||||
if [ -z "$CURR_PIDS" ]; then
|
||||
echo "No controller or agent processes found."
|
||||
return
|
||||
fi
|
||||
|
||||
# Monitor the number of running processes
|
||||
while [ "$CURR_PIDS" -ge "$PREV_PIDS" ]; do
|
||||
sleep 5
|
||||
CURR_PIDS="$(pgrep -f 'beerocks_(agent|controller|vendor_message)' | wc -l)"
|
||||
if [ "$CURR_PIDS" -gt "$PREV_PIDS" ]; then
|
||||
PREV_PIDS=$CURR_PIDS
|
||||
fi
|
||||
done
|
||||
}
|
||||
|
||||
roll_logs_function()
|
||||
{
|
||||
roll_logs_function() {
|
||||
ROLL_PROGRESS_DIR="roll_in_progress.lock"
|
||||
|
||||
# Switch into the beerocks logs folder
|
||||
@@ -212,308 +68,198 @@ roll_logs_function()
|
||||
done
|
||||
|
||||
# Send USR1 signals to the beerocks processes to trigger log rolling
|
||||
killall_program beerocks_controller USR1
|
||||
killall_program beerocks_agent USR1
|
||||
killall_program beerocks_fronthaul USR1
|
||||
killall_program beerocks_vendor_message USR1
|
||||
send_signal_to_prplmesh_process beerocks_controller USR1
|
||||
send_signal_to_prplmesh_process beerocks_agent USR1
|
||||
send_signal_to_prplmesh_process beerocks_fronthaul USR1
|
||||
send_signal_to_prplmesh_process beerocks_vendor_message USR1
|
||||
|
||||
# Cleanup
|
||||
rm -r $ROLL_PROGRESS_DIR
|
||||
}
|
||||
|
||||
start_function() {
|
||||
echo "$0: start"
|
||||
[ "$(id -u)" -ne 0 ] && echo "$0: warning - this commands needs root privileges. It might not work without them (are you root?)"
|
||||
|
||||
# shellcheck disable=SC2050
|
||||
[ "@BWL_TYPE@" = "DUMMY" ] && [ "$PLATFORM_INIT" = "true" ] && platform_init
|
||||
prplmesh_framework_init
|
||||
case "$PRPLMESH_MODE" in
|
||||
CA | ca)
|
||||
prplmesh_platform_db_init "Multi-AP-Controller-and-Agent"
|
||||
prplmesh_controller_start
|
||||
prplmesh_agent_start
|
||||
prplmesh_vendor_message_start
|
||||
;;
|
||||
NA | na)
|
||||
prplmesh_platform_db_init "Non-Prpl-Controller-and-Agent"
|
||||
prplmesh_agent_start
|
||||
prplmesh_vendor_message_start
|
||||
;;
|
||||
C | c)
|
||||
prplmesh_platform_db_init "Multi-AP-Controller"
|
||||
prplmesh_controller_start
|
||||
# Dummy agent configures transport layer
|
||||
prplmesh_agent_start
|
||||
;;
|
||||
A | a)
|
||||
prplmesh_platform_db_init "Multi-AP-Agent" "WDS-Repeater"
|
||||
prplmesh_agent_start
|
||||
prplmesh_vendor_message_start
|
||||
;;
|
||||
* ) err "unsupported mode: $PRPLMESH_MODE"; usage; exit 1 ;;
|
||||
esac
|
||||
}
|
||||
|
||||
stop_function() {
|
||||
echo "$0: stop"
|
||||
[ "$(id -u)" -ne 0 ] && echo "$0: warning - this commands needs root privileges. It might not work without them (are you root?)"
|
||||
|
||||
# shellcheck disable=SC2050
|
||||
[ "@BWL_TYPE@" = "DUMMY" ] && [ "$PLATFORM_INIT" = "true" ] && platform_deinit
|
||||
prplmesh_agent_stop
|
||||
prplmesh_controller_stop
|
||||
prplmesh_framework_deinit
|
||||
prplmesh_vendor_message_stop
|
||||
[ "$DELETE_LOGS" = "true" ] && prplmesh_delete_logs
|
||||
}
|
||||
|
||||
execute_beerocks_command() {
|
||||
dbg "Executing beerocks cli command: $*"
|
||||
if [ -e "$PRPLMESH_DIR/bin/beerocks_cli" ]; then
|
||||
output="$("${PRPLMESH_DIR}/bin/beerocks_cli" -c "$@")"
|
||||
return $?
|
||||
else
|
||||
err "BML CLI not found"
|
||||
output=""
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
# Note: Apparently on some Linux version space is added to the process name.
|
||||
# Therefore added "($|[[:blank:]])" to the end of the regex expression which means the end of the
|
||||
# line ($) or blank character ([[:blank:]])
|
||||
main_agent_operational() {
|
||||
pgrep -fx "$PRPLMESH_DIR/bin/beerocks_agent($|[[:blank:]])" > /dev/null 2>&1 || return 1
|
||||
grep -q ' --> OPERATIONAL' "$1/beerocks_backhaul@BEEROCKS_LOG_FILES_SUFFIX@"
|
||||
}
|
||||
|
||||
radio_agent_operational() {
|
||||
grep -q "$2 FSM: .* --> CONFIGURED" "$1/beerocks_agent@BEEROCKS_LOG_FILES_SUFFIX@"
|
||||
}
|
||||
|
||||
report() {
|
||||
msg="$1"; shift
|
||||
if "$@"; then
|
||||
success "OK $msg"
|
||||
else
|
||||
err "FAIL $msg"
|
||||
error=1
|
||||
fi
|
||||
}
|
||||
|
||||
status_function() {
|
||||
echo "$0: status"
|
||||
|
||||
pgrep -l beerocks
|
||||
pgrep -f -l 'ieee1905_transport'
|
||||
|
||||
# Use the given argument as birdge mac if it filled with something, otherwise get the bridge mac
|
||||
# of the local platform.
|
||||
ARGUMENT_LEN=${#1}
|
||||
if [ "$ARGUMENT_LEN" -ne "0" ]; then
|
||||
BRIDGE_MAC=$1
|
||||
else
|
||||
BRIDGE_MAC="$(ip link show dev @BEEROCKS_BRIDGE_IFACE@ | awk '/^ *link\/ether / {print $2}')"
|
||||
fi
|
||||
|
||||
bml_cmd="bml_get_device_operational_radios $BRIDGE_MAC"
|
||||
|
||||
if pgrep beerocks_cont >/dev/null ; then
|
||||
echo "executing operational test using bml"
|
||||
if ! execute_beerocks_command "$bml_cmd" ; then
|
||||
err "Beerocks command failed to execute!"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
OUTPUT=$(echo "$output" | grep -E '(FAIL|OK).*?operational')
|
||||
Count=$(echo "$OUTPUT" | grep -c 'radio agent operational')
|
||||
OK_Count=$(echo "$OUTPUT" | grep -c -e "OK.*operational")
|
||||
if [ "$OK_Count" -eq "$Count" ]; then
|
||||
success "operational test success!"
|
||||
success "$OUTPUT"
|
||||
exit 0
|
||||
fi
|
||||
|
||||
err "operational test failed!"
|
||||
echo "$OUTPUT" |
|
||||
while read -r line ; do
|
||||
case $line in
|
||||
"OK "*) success "$line" ;;
|
||||
"FAIL "*) err "$line" ;;
|
||||
esac
|
||||
done
|
||||
exit 1
|
||||
else
|
||||
echo "executing operational test using grep on log files"
|
||||
# check for operational status
|
||||
LOGS_PATH=@BEEROCKS_LOG_FILES_PATH@
|
||||
|
||||
error=0
|
||||
report "Main agent operational" main_agent_operational $LOGS_PATH
|
||||
# For each existing slave log file, check if they are OPERATIONAL:
|
||||
main_agent_log="$LOGS_PATH/beerocks_agent@BEEROCKS_LOG_FILES_SUFFIX@"
|
||||
# skip files that aren't symlinks (and skip the literal glob if there is no matching file):
|
||||
[ -L "$main_agent_log" ] || return
|
||||
|
||||
grep -q "[^[:print:]]" "$main_agent_log" && err "$main_agent_log contains non-printable characters!"
|
||||
radios=$(grep -a 'fronthaul_iface=' "$main_agent_log" | cut -d "=" -f2)
|
||||
for radio in $radios ; do
|
||||
report "$radio radio agent operational" radio_agent_operational "$LOGS_PATH" "$radio"
|
||||
done
|
||||
|
||||
exit $error
|
||||
fi
|
||||
rm -r "$ROLL_PROGRESS_DIR"
|
||||
}
|
||||
|
||||
usage() {
|
||||
echo "usage: $(basename "$0") {start|stop|restart|status|roll_logs} [-hvpmdCD]"
|
||||
echo "usage: $(basename "$0") {start|stop|restart|status|roll_logs} [-h] [-m MODE] [-c CERT_MODE]"
|
||||
}
|
||||
|
||||
check_processmonitor_entry() {
|
||||
ba-cli "ProcessMonitor.Test.[Subject=='/tmp/beerocks/pid/beerocks_$1'].?" | grep -Eq "No data found|ERROR"
|
||||
odl_get_str_param() {
|
||||
key=$1
|
||||
default=$2
|
||||
value=""
|
||||
|
||||
for file in $ODL_FILES; do
|
||||
[ -e "${file}" ] || continue
|
||||
value=$(sed -n -E "s/^[[:space:]]*parameter[[:space:]]*['\"]?${key}['\"]?[[:space:]]*=[[:space:]]*\"([^\"]*)\".*/\1/p" "${file}")
|
||||
[ -n "${value}" ] && break
|
||||
done
|
||||
|
||||
[ -z "${value}" ] && value=$default
|
||||
|
||||
echo "${value}"
|
||||
}
|
||||
|
||||
add_processmonitor_entry() {
|
||||
echo "Adding ProcessMonitor entry for prplMesh $1" &&
|
||||
ba-cli -l "ProcessMonitor.Test.+(
|
||||
Name='prplmesh',
|
||||
Type='Process',
|
||||
Subject='/tmp/beerocks/pid/beerocks_$1',
|
||||
MaxFailNum=2,
|
||||
MaxFailDuration=-1,
|
||||
FailAction='RESTART',
|
||||
TestInterval=30,
|
||||
TestIntervalMultiplier=1,
|
||||
ProcessMonitoringEnabled=0,
|
||||
TestResetInterval=300
|
||||
)" > /dev/null
|
||||
}
|
||||
odl_set_param() {
|
||||
name=$1
|
||||
value=$2
|
||||
type=$3
|
||||
|
||||
remove_processmonitor_entry() {
|
||||
echo "Removing ProcessMonitor entry for prplMesh $1" &&
|
||||
(ba-cli -l "ProcessMonitor.Test.[Subject=='/tmp/beerocks/pid/beerocks_$1'].-" > /dev/null || true)
|
||||
check_processmonitor_entry "$1"
|
||||
statusCode=$?
|
||||
if [ $statusCode -eq 0 ]; then
|
||||
echo "ProcessMonitor entry has been removed successfully"
|
||||
else
|
||||
echo "Failed to remove the ProcessMonitor entry"
|
||||
fi
|
||||
}
|
||||
for file in $ODL_FILES; do
|
||||
[ -e "${file}" ] || continue
|
||||
|
||||
remove_processmonitor_entries() {
|
||||
(check_processmonitor_entry "agent") ||
|
||||
remove_processmonitor_entry "agent"
|
||||
|
||||
(check_processmonitor_entry "vendor_message") ||
|
||||
remove_processmonitor_entry "vendor_message"
|
||||
|
||||
(check_processmonitor_entry "controller") ||
|
||||
remove_processmonitor_entry "controller"
|
||||
}
|
||||
|
||||
add_processmonitor() {
|
||||
retries=10
|
||||
statusCode=0
|
||||
|
||||
echo "Checking if ProcessMonitor entry for '$1' exists..."
|
||||
if ! check_processmonitor_entry "$1"; then
|
||||
echo "ProcessMonitor entry for '$1' already exists. Skipping..."
|
||||
else
|
||||
while [ $retries -gt 0 ] && [ $statusCode -ne 1 ]; do
|
||||
echo "Trying to add ProcessMonitor entry for '$1'..."
|
||||
add_processmonitor_entry "$1"
|
||||
sleep 1
|
||||
check_processmonitor_entry "$1"
|
||||
statusCode=$?
|
||||
if [ $statusCode -eq 1 ]; then
|
||||
echo "ProcessMonitor entry has been added successfully"
|
||||
else
|
||||
echo "Failed to add the ProcessMonitor entry"
|
||||
fi
|
||||
retries=$((retries - 1))
|
||||
done
|
||||
fi
|
||||
}
|
||||
|
||||
main() {
|
||||
if ! OPTS=$(getopt -o 'hvm:pdC:D:' -n 'parse-options' \
|
||||
--long 'verbose,help,mode:,platform-init,delete-logs,iface-ctrl,iface-data' \
|
||||
-- "$@") ; then
|
||||
err "Failed parsing options." >&2
|
||||
usage
|
||||
exit 1
|
||||
fi
|
||||
|
||||
eval set -- "$OPTS"
|
||||
|
||||
while true; do
|
||||
case "$1" in
|
||||
-v | --verbose) VERBOSE=true; shift ;;
|
||||
-h | --help) usage; exit 0; shift ;;
|
||||
-m | --mode) PRPLMESH_MODE="$2"; shift; shift ;;
|
||||
-p | --platform-init) PLATFORM_INIT=true; shift ;;
|
||||
-d | --delete-logs) DELETE_LOGS=true; shift ;;
|
||||
-C | --iface-ctrl) CONTROL_IFACE="$2"; shift; shift ;;
|
||||
-D | --iface-data) DATA_IFACE="$2"; shift; shift ;;
|
||||
-- ) shift; break ;;
|
||||
* ) err "unsupported argument $1"; usage; exit 1 ;;
|
||||
case "$type" in
|
||||
string)
|
||||
sed -i "s/\(parameter[[:space:]]\+${name}[[:space:]]*=[[:space:]]*\"\)[^\"]*\";/\1${value}\";/" "${file}"
|
||||
sed -i "s/\(parameter[[:space:]]\+'${name}'[[:space:]]*=[[:space:]]*\"\)[^\"]*\";/\1${value}\";/" "${file}"
|
||||
;;
|
||||
bool)
|
||||
sed -i "s/\(parameter[[:space:]]\+${name}[[:space:]]*=[[:space:]]*\)[^;]*;/\1${value};/" "${file}"
|
||||
sed -i "s/\(parameter[[:space:]]\+'${name}'[[:space:]]*=[[:space:]]*\)[^;]*;/\1${value};/" "${file}"
|
||||
;;
|
||||
*)
|
||||
echo "Unsupported param_type: ${type}" >&2
|
||||
return 1
|
||||
;;
|
||||
esac
|
||||
done
|
||||
|
||||
dbg VERBOSE=$VERBOSE
|
||||
dbg PLATFORM_INIT=$PLATFORM_INIT
|
||||
dbg DELETE_LOGS=$DELETE_LOGS
|
||||
return 0
|
||||
}
|
||||
|
||||
case $1 in
|
||||
"start")
|
||||
start_function
|
||||
if [ "$PRPLMESH_MODE" = "CA" ] || [ "$PRPLMESH_MODE" = "C" ]; then
|
||||
add_processmonitor "controller"
|
||||
fi
|
||||
ensure_platform_db() {
|
||||
mkdir -p "@TMP_PATH@"
|
||||
if [ ! -e "@TMP_PATH@/prplmesh_platform_db" ]; then
|
||||
cp "${PRPLMESH_DIR}/share/prplmesh_platform_db" "@TMP_PATH@/prplmesh_platform_db"
|
||||
fi
|
||||
}
|
||||
|
||||
if [ "$PRPLMESH_MODE" = "CA" ] || [ "$PRPLMESH_MODE" = "A" ]; then
|
||||
add_processmonitor "agent"
|
||||
add_processmonitor "vendor_message"
|
||||
fi
|
||||
certification_mode_to_num() {
|
||||
case "$1" in
|
||||
1|true|TRUE|yes|on) echo 1 ;;
|
||||
0|false|FALSE|no|off) echo 0 ;;
|
||||
*)
|
||||
echo "Unsupported certification_mode: \"$1\" (use 0/1/true/false)" >&2
|
||||
return 1
|
||||
;;
|
||||
"start_wait")
|
||||
start_function
|
||||
prplmesh_watchdog
|
||||
stop_function
|
||||
esac
|
||||
}
|
||||
|
||||
set_management_and_certification_mode() {
|
||||
management_mode=$1
|
||||
certification_mode=$2
|
||||
|
||||
if [ -n "${management_mode}" ]; then
|
||||
case "${management_mode}" in
|
||||
Not-Multi-AP|Multi-AP-Agent|Multi-AP-Controller|Multi-AP-Controller-and-Agent|Non-Prpl-Controller-and-Agent)
|
||||
;;
|
||||
*)
|
||||
echo "unsupported mode: \"${management_mode}\""
|
||||
exit 1
|
||||
;;
|
||||
esac
|
||||
|
||||
echo "Set prplMesh management_mode to ${management_mode}"
|
||||
|
||||
sed -i "s/management_mode=.*/management_mode=${management_mode}/g" @TMP_PATH@/prplmesh_platform_db
|
||||
odl_set_param "ManagementMode" "${management_mode}" "string" || return 1
|
||||
fi
|
||||
|
||||
if [ -n "${certification_mode}" ]; then
|
||||
certification_mode_num=$(certification_mode_to_num "${certification_mode}") || return 1
|
||||
echo "Set prplMesh certification_mode to ${certification_mode_num}"
|
||||
|
||||
sed -i "s/certification_mode=.*/certification_mode=${certification_mode_num}/g" @TMP_PATH@/prplmesh_platform_db
|
||||
odl_set_param "CertificationMode" "${certification_mode_num}" "bool" || return 1
|
||||
fi
|
||||
|
||||
return 0
|
||||
}
|
||||
|
||||
start_func() {
|
||||
# This is required for solveing issue which causing meesges not geeting to their destination.
|
||||
# For more information see: https://github.com/prplfoundation/prplMesh/pull/1029#issuecomment-608353274
|
||||
ebtables -A FORWARD -d 01:80:c2:00:00:13 -j DROP
|
||||
|
||||
if [ "${TARGET_PLATFORM}" = "linux" ] || [ "${TARGET_PLATFORM}" = "rdkb" ]; then
|
||||
mode=$(sed -n 's/^management_mode=\(.*\)$/\1/p' @TMP_PATH@/prplmesh_platform_db)
|
||||
[ -z "$mode" ] && mode="@BEEROCKS_MANAGEMENT_MODE@"
|
||||
else
|
||||
mode=$(odl_get_str_param "ManagementMode" "@BEEROCKS_MANAGEMENT_MODE@")
|
||||
fi
|
||||
|
||||
echo "Starting prplMesh (mode=${mode})"
|
||||
|
||||
start_prplmesh_process ieee1905_transport
|
||||
if [ "${mode}" != "Multi-AP-Agent" ] && [ "${mode}" != "Non-Prpl-Controller-and-Agent" ]; then
|
||||
start_prplmesh_process beerocks_controller
|
||||
fi
|
||||
start_prplmesh_process beerocks_agent
|
||||
start_prplmesh_process beerocks_vendor_message
|
||||
return 0
|
||||
}
|
||||
|
||||
stop_func() {
|
||||
echo "Stopping prplMesh"
|
||||
stop_prplmesh_process beerocks_vendor_message
|
||||
stop_prplmesh_process beerocks_fronthaul
|
||||
stop_prplmesh_process beerocks_agent
|
||||
stop_prplmesh_process beerocks_controller
|
||||
stop_prplmesh_process ieee1905_transport
|
||||
|
||||
ebtables -D FORWARD -d 01:80:c2:00:00:13 -j DROP
|
||||
return 0
|
||||
}
|
||||
|
||||
main() {
|
||||
if ! OPTS=$(getopt -o 'hm:c:' -l 'help,mode:,cert:' -n 'parse-options' -- "$@"); then
|
||||
echo "Failed parsing options." >&2
|
||||
usage
|
||||
exit 1
|
||||
fi
|
||||
|
||||
eval set -- "$OPTS"
|
||||
echo "OPTS=${OPTS}"
|
||||
|
||||
while true; do
|
||||
case "${1}" in
|
||||
-h | --help) usage; exit 0 ;;
|
||||
-m | --mode) PRPLMESH_MODE="${2}"; shift; shift ;;
|
||||
-c | --cert) CERTIFICATION_MODE="${2}"; shift; shift ;;
|
||||
-- ) shift; break ;;
|
||||
* ) echo "unsupported argument ${1}"; usage; exit 1 ;;
|
||||
esac
|
||||
done
|
||||
|
||||
case "${1}" in
|
||||
"start" | "restart")
|
||||
ensure_platform_db
|
||||
stop_func # Need to stop first for correctly apply modes
|
||||
sleep 1 # Wait some time for completely stop
|
||||
set_management_and_certification_mode "${PRPLMESH_MODE}" "${CERTIFICATION_MODE}" || echo "Warning: failed to set mode, starting with existing configuration"
|
||||
start_func
|
||||
;;
|
||||
"stop")
|
||||
remove_processmonitor_entries
|
||||
stop_function
|
||||
;;
|
||||
"restart")
|
||||
stop_function
|
||||
start_function
|
||||
stop_func
|
||||
;;
|
||||
"status")
|
||||
status_function "$2"
|
||||
"${PRPLMESH_DIR}/bin/prplmesh_cli" -c status -o pretty
|
||||
;;
|
||||
"roll_logs")
|
||||
roll_logs_function
|
||||
return $?
|
||||
return $?
|
||||
;;
|
||||
*)
|
||||
err "unsupported argument \"$1\""; usage; exit 1 ;;
|
||||
echo "unsupported argument \"${1}\""; usage; exit 1 ;;
|
||||
esac
|
||||
|
||||
# Give write permissions (linux only)
|
||||
# shellcheck disable=SC2050
|
||||
if [ "@TARGET_PLATFORM@" = "linux" ]; then
|
||||
if [ "${TARGET_PLATFORM}" = "linux" ]; then
|
||||
chmod -R +o+w "/tmp/beerocks" || true
|
||||
fi
|
||||
|
||||
return 0
|
||||
}
|
||||
|
||||
VERBOSE=false
|
||||
PLATFORM_INIT=@BEEROCKS_PLATFORM_INIT@
|
||||
DELETE_LOGS=false
|
||||
CONTROL_IFACE=
|
||||
DATA_IFACE=
|
||||
PRPLMESH_MODE="CA" # CA = Controller & Agent, A = Agent only, C = Controller only
|
||||
PRPLMESH_MODE=""
|
||||
CERTIFICATION_MODE=""
|
||||
|
||||
main "$@"
|
||||
|
||||
Reference in New Issue
Block a user