Update On Thu Jan 1 19:42:29 CET 2026

openwrt-passwall/luci-app-passwall/luasrc/passwall/util_xray.lua

@@ -628,6 +628,7 @@ function gen_config(var)
 	local dns = nil
 	local fakedns = nil
 	local routing = nil
+	local observatory = nil
 	local burstObservatory = nil
 	local strategy = nil
 	local inbounds = {}
@@ -868,18 +869,23 @@ function gen_config(var)
 				fallbackTag = fallback_node_tag,
 				strategy = strategy
 			})
-			if _node.balancingStrategy == "leastPing" or _node.balancingStrategy == "leastLoad" or fallback_node_tag then
-				if not burstObservatory then
-					burstObservatory = {
-						subjectSelector = { "blc-" },
-						pingConfig = {
-							destination = _node.useCustomProbeUrl and _node.probeUrl or nil,
-							interval = (api.format_go_time(_node.probeInterval) ~= "0s") and api.format_go_time(_node.probeInterval) or "1m",
-							sampling = 3,
-							timeout = "5s"
-						}
+			if _node.balancingStrategy == "leastPing" and not observatory then
+				observatory = {
+					subjectSelector = { "blc-" },
+					probeUrl = _node.useCustomProbeUrl and _node.probeUrl or nil,
+					probeInterval = (api.format_go_time(_node.probeInterval) ~= "0s") and api.format_go_time(_node.probeInterval) or "1m",
+					enableConcurrency = true
+				}
+			elseif _node.balancingStrategy == "leastLoad" and not burstObservatory then
+				burstObservatory = {
+					subjectSelector = { "blc-" },
+					pingConfig = {
+						destination = _node.useCustomProbeUrl and _node.probeUrl or nil,
+						interval = (api.format_go_time(_node.probeInterval) ~= "0s") and api.format_go_time(_node.probeInterval) or "1m",
+						sampling = 3,
+						timeout = "5s"
 					}
-				end
+				}
 			end
 			local inbound_tag = gen_loopback(loopback_tag, loopback_dst)
 			table.insert(rules, { inboundTag = { inbound_tag }, balancerTag = balancer_tag })
@@ -1515,6 +1521,7 @@ function gen_config(var)
 			-- 传出连接
 			outbounds = outbounds,
 			-- 连接观测
+			observatory = (not burstObservatory) and observatory or nil,
 			burstObservatory = burstObservatory,
 			-- 路由
 			routing = routing,