imbajin commented on code in PR #2945:
URL: https://github.com/apache/hugegraph/pull/2945#discussion_r4301036267


##########
hugegraph-store/Dockerfile:
##########
@@ -35,7 +35,8 @@ RUN 
--mount=type=cache,id=hugegraph-maven-${SOURCE_REVISION},target=/root/.m2,sh
 
 # 2nd stage: runtime env
 # Note: ZGC (The Z Garbage Collector) is only supported on ARM-Mac with java > 
13
-FROM eclipse-temurin:17-jre-jammy
+# Local Arthas attach requires the JDK attach and compiler modules.

Review Comment:
   Moved the JDK explanation below the runtime FROM in all three affected 
Dockerfiles. The shared build-stage content is unchanged, and the exact 
awk/diff contract from the Docker workflow passes locally. The JDK 17 runtime 
bases are retained.



##########
hugegraph-server/hugegraph-dist/src/assembly/static/bin/arthas.sh:
##########
@@ -0,0 +1,115 @@
+#!/bin/bash
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# Offline attachment to a running Server or Store using the bundled agent.
+set -euo pipefail
+
+fail() { echo "Error: $*" >&2; exit 1; }
+usage() {
+    echo "Usage: $0 [--pid PID] [--telnet-port PORT] [--command COMMAND]"
+    echo "Run as the service OS user; defaults to bin/pid and loopback port 
3658."
+    echo "New agents disable HTTP/MCP; use the existing telnet port for an 
active agent."
+    echo "Exiting this helper stops Arthas, including after --command or quit; 
the JVM keeps running."
+}
+
+BIN=$(cd -P "$(dirname "${BASH_SOURCE[0]}")" && pwd)
+TOP=$(cd -P "$BIN/.." && pwd)
+pid=""
+port=3658
+boot_args=()
+while [ "$#" -gt 0 ]; do
+    case "$1" in
+        --pid|--telnet-port|--command)
+            [ "$#" -ge 2 ] || fail "Missing value for $1"
+            case "$1" in
+                --pid) pid=$2 ;;
+                --telnet-port) port=$2 ;;
+                --command) boot_args=(--command "$2") ;;
+            esac
+            shift 2 ;;
+        -h|--help) usage; exit 0 ;;
+        *) usage >&2; fail "Unknown option: $1" ;;
+    esac
+done
+if [ -z "$pid" ]; then
+    [ -r "$BIN/pid" ] || fail "No bin/pid; start the service or supply --pid 
PID"
+    pid=$(cat "$BIN/pid")
+fi
+[[ "$pid" =~ ^[1-9][0-9]{0,9}$ ]] || fail "PID must be a positive integer"
+[[ "$port" =~ ^[1-9][0-9]{0,4}$ ]] && [ "$port" -le 65535 ] || fail "Invalid 
telnet port"
+JAVA=${JAVA_HOME:+$JAVA_HOME/bin/}java
+ARTHAS="$TOP/lib/arthas"
+[ -f "$ARTHAS/arthas-boot.jar" ] || fail "Bundled Arthas files are missing 
from lib/arthas"
+boot_args+=(--arthas-home "$ARTHAS" --target-ip 127.0.0.1 --telnet-port 
"$port" --http-port -1 "$pid")
+# Keep the listener within this diagnosis session. Verify its PID before 
stopping
+# it, since an occupied port must never stop a different application's agent.
+state_dir=$(mktemp -d)
+client_pid=""
+attaching=true
+# The native client's -t option does not bound its final response wait.
+bounded_client() {
+    "$JAVA" -jar "$ARTHAS/arthas-client.jar" -t 5000 -c "$1" 127.0.0.1 "$port" 
&
+    local command_pid=$!
+    (sleep 10; kill -KILL "$command_pid" 2>/dev/null) >/dev/null 2>&1 &
+    local timer_pid=$!
+    local status=0
+    wait "$command_pid" || status=$?
+    kill "$timer_pid" 2>/dev/null || true
+    wait "$timer_pid" 2>/dev/null || true
+    return "$status"
+}
+stop_agent() {
+    local session
+    if ! session=$(bounded_client session 2>&1); then
+        if [[ "$session" != *"Connection refused"* ]]; then
+            echo "Warning: could not verify Arthas cleanup; check port $port 
and stop it manually" >&2
+        fi
+        return 0
+    fi
+    if [[ "$session" =~ JAVA_PID[[:space:]]+$pid([[:space:]]|$) ]]; then
+        bounded_client stop >/dev/null 2>&1 ||
+            echo "Warning: could not stop Arthas; run the helper with 
--command stop" >&2
+    fi
+}
+cleanup() {
+    trap - EXIT INT TERM HUP

Review Comment:
   Confirmed the repeated-signal failure with the unchanged native helper: a 
second signal interrupted cleanup and left the agent listening while the 
application JVM survived. Exit traps now ignore further INT/TERM/HUP before 
exiting; cleanup keeps those signals ignored and resets only EXIT. The watchdog 
is killed with KILL so its inherited signal disposition cannot delay cleanup. 
Native regressions pass for interactive Bash terminal hangup and repeated mixed 
signals on Server/Store, with the listener closed and application JVM alive.



##########
hugegraph-server/hugegraph-dist/src/assembly/static/bin/arthas.sh:
##########
@@ -0,0 +1,115 @@
+#!/bin/bash
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# Offline attachment to a running Server or Store using the bundled agent.
+set -euo pipefail
+
+fail() { echo "Error: $*" >&2; exit 1; }
+usage() {
+    echo "Usage: $0 [--pid PID] [--telnet-port PORT] [--command COMMAND]"
+    echo "Run as the service OS user; defaults to bin/pid and loopback port 
3658."
+    echo "New agents disable HTTP/MCP; use the existing telnet port for an 
active agent."
+    echo "Exiting this helper stops Arthas, including after --command or quit; 
the JVM keeps running."
+}
+
+BIN=$(cd -P "$(dirname "${BASH_SOURCE[0]}")" && pwd)
+TOP=$(cd -P "$BIN/.." && pwd)
+pid=""
+port=3658
+boot_args=()
+while [ "$#" -gt 0 ]; do
+    case "$1" in
+        --pid|--telnet-port|--command)
+            [ "$#" -ge 2 ] || fail "Missing value for $1"
+            case "$1" in
+                --pid) pid=$2 ;;
+                --telnet-port) port=$2 ;;
+                --command) boot_args=(--command "$2") ;;
+            esac
+            shift 2 ;;
+        -h|--help) usage; exit 0 ;;
+        *) usage >&2; fail "Unknown option: $1" ;;
+    esac
+done
+if [ -z "$pid" ]; then
+    [ -r "$BIN/pid" ] || fail "No bin/pid; start the service or supply --pid 
PID"
+    pid=$(cat "$BIN/pid")
+fi
+[[ "$pid" =~ ^[1-9][0-9]{0,9}$ ]] || fail "PID must be a positive integer"
+[[ "$port" =~ ^[1-9][0-9]{0,4}$ ]] && [ "$port" -le 65535 ] || fail "Invalid 
telnet port"
+JAVA=${JAVA_HOME:+$JAVA_HOME/bin/}java
+ARTHAS="$TOP/lib/arthas"
+[ -f "$ARTHAS/arthas-boot.jar" ] || fail "Bundled Arthas files are missing 
from lib/arthas"
+boot_args+=(--arthas-home "$ARTHAS" --target-ip 127.0.0.1 --telnet-port 
"$port" --http-port -1 "$pid")
+# Keep the listener within this diagnosis session. Verify its PID before 
stopping
+# it, since an occupied port must never stop a different application's agent.
+state_dir=$(mktemp -d)
+client_pid=""
+attaching=true
+# The native client's -t option does not bound its final response wait.
+bounded_client() {
+    "$JAVA" -jar "$ARTHAS/arthas-client.jar" -t 5000 -c "$1" 127.0.0.1 "$port" 
&
+    local command_pid=$!
+    (sleep 10; kill -KILL "$command_pid" 2>/dev/null) >/dev/null 2>&1 &
+    local timer_pid=$!
+    local status=0
+    wait "$command_pid" || status=$?
+    kill "$timer_pid" 2>/dev/null || true
+    wait "$timer_pid" 2>/dev/null || true
+    return "$status"
+}
+stop_agent() {
+    local session
+    if ! session=$(bounded_client session 2>&1); then
+        if [[ "$session" != *"Connection refused"* ]]; then
+            echo "Warning: could not verify Arthas cleanup; check port $port 
and stop it manually" >&2
+        fi
+        return 0
+    fi
+    if [[ "$session" =~ JAVA_PID[[:space:]]+$pid([[:space:]]|$) ]]; then
+        bounded_client stop >/dev/null 2>&1 ||
+            echo "Warning: could not stop Arthas; run the helper with 
--command stop" >&2
+    fi
+}
+cleanup() {
+    trap - EXIT INT TERM HUP
+    if [ -n "$client_pid" ]; then
+        # Let an in-flight loadAgent finish before checking/closing its 
listener.
+        if [ "$attaching" = false ]; then
+            kill "$client_pid" 2>/dev/null || true
+        fi
+        wait "$client_pid" 2>/dev/null || true
+    fi
+    if [ -f "$state_dir/validated" ]; then
+        stop_agent
+    fi
+    rm -f "$state_dir/validated"
+    rmdir "$state_dir"
+}
+trap cleanup EXIT
+trap 'exit 130' INT
+trap 'exit 143' TERM
+trap 'exit 129' HUP
+"$JAVA" --add-modules jdk.attach --class-path "$ARTHAS/arthas-core.jar" \
+    "$BIN/ArthasAttach.java" "$pid" "$ARTHAS" "$port" "$TOP" 
"$state_dir/validated" <&0 &
+client_pid=$!
+wait "$client_pid"
+attaching=false
+"$JAVA" -jar "$ARTHAS/arthas-boot.jar" "${boot_args[@]}" <&0 &

Review Comment:
   Interactive mode now refuses non-terminal stdin before attachment and 
instructs batch callers to use --command. The regression checks both immediate 
EOF and piped version input, verifies that no listener is created, and retains 
successful one-time command coverage. Repository and bilingual website 
documentation explain the supported use.



##########
hugegraph-store/Dockerfile:
##########
@@ -35,7 +35,8 @@ RUN 
--mount=type=cache,id=hugegraph-maven-${SOURCE_REVISION},target=/root/.m2,sh
 
 # 2nd stage: runtime env
 # Note: ZGC (The Z Garbage Collector) is only supported on ARM-Mac with java > 
13
-FROM eclipse-temurin:17-jre-jammy
+# Local Arthas attach requires the JDK attach and compiler modules.

Review Comment:
   Moved this comment below the runtime FROM in Store and both Server 
Dockerfiles, preserving the JDK runtime base and the existing shared-stage 
check. Replayed the workflow’s exact stage extractor and all comparisons pass.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to