benya/rmm-openwrt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Preserve reverse tunnel port during cleanup

Browse Source
This commit is contained in:
benya
2026-06-04 17:09:41 +03:00
parent 9143b43637
commit b722d09edf
1 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agent/openwrt/rmm-agent.sh
+21 -21
View File
@@ -608,39 +608,39 @@ remote_ssh_reverse_output() {
} }
remote_ssh_stop_pid() { remote_ssh_stop_pid() {
session_id="$1" stop_session_id="$1"
expected_pid="$2" stop_expected_pid="$2"
pid_file="$TUNNEL_STATE_DIR/$session_id.pid" stop_pid_file="$TUNNEL_STATE_DIR/$stop_session_id.pid"
[ -f "$pid_file" ] || return 0 [ -f "$stop_pid_file" ] || return 0
pid="$(cat "$pid_file" 2>/dev/null)" stop_pid="$(cat "$stop_pid_file" 2>/dev/null)"
[ "$pid" = "$expected_pid" ] || return 0 [ "$stop_pid" = "$stop_expected_pid" ] || return 0
case "$pid" in case "$stop_pid" in
''|*[!0-9]*) ''|*[!0-9]*)
rm -f "$pid_file" rm -f "$stop_pid_file"
return 1 return 1
;; ;;
esac esac
kill "$pid" >/dev/null 2>&1 || true kill "$stop_pid" >/dev/null 2>&1 || true
rm -f "$pid_file" rm -f "$stop_pid_file"
} }
remote_ssh_stop_session() { remote_ssh_stop_session() {
session_id="$1" stop_session_id="$1"
remote_port="${2:-}" stop_remote_port="${2:-}"
if ! safe_session_id "$session_id"; then if ! safe_session_id "$stop_session_id"; then
printf 'remote session id is invalid\n' printf 'remote session id is invalid\n'
return 2 return 2
fi fi
pid_file="$TUNNEL_STATE_DIR/$session_id.pid" stop_pid_file="$TUNNEL_STATE_DIR/$stop_session_id.pid"
if [ ! -f "$pid_file" ]; then if [ ! -f "$stop_pid_file" ]; then
if safe_port "$remote_port"; then if safe_port "$stop_remote_port"; then
for cmdline in /proc/[0-9]*/cmdline; do for cmdline in /proc/[0-9]*/cmdline; do
[ -f "$cmdline" ] || continue [ -f "$cmdline" ] || continue
command_line="$(tr '\000' ' ' < "$cmdline" 2>/dev/null)" command_line="$(tr '\000' ' ' < "$cmdline" 2>/dev/null)"
case "$command_line" in case "$command_line" in
*ssh*" -R $remote_port:"*|*dbclient*" -R $remote_port:"*) *ssh*" -R $stop_remote_port:"*|*dbclient*" -R $stop_remote_port:"*)
pid="$(printf '%s' "$cmdline" | cut -d/ -f3)" stop_pid="$(printf '%s' "$cmdline" | cut -d/ -f3)"
kill "$pid" >/dev/null 2>&1 || true kill "$stop_pid" >/dev/null 2>&1 || true
printf 'remote ssh session stopped by port\n' printf 'remote ssh session stopped by port\n'
return 0 return 0
;; ;;
@@ -650,8 +650,8 @@ remote_ssh_stop_session() {
printf 'remote ssh session is already stopped\n' printf 'remote ssh session is already stopped\n'
return 0 return 0
fi fi
pid="$(cat "$pid_file" 2>/dev/null)" stop_pid="$(cat "$stop_pid_file" 2>/dev/null)"
remote_ssh_stop_pid "$session_id" "$pid" remote_ssh_stop_pid "$stop_session_id" "$stop_pid"
printf 'remote ssh session stopped\n' printf 'remote ssh session stopped\n'
} }