Merge pull request #370 from ShanyouYu-Sean/dev/sean/fix-udp

ShanyouYu-Sean · web-flow · commit 8bef815af306 · 2023-04-14T16:49:50.000+08:00
fix UdpHealthChecker
diff --git a/polaris-plugins/polaris-plugins-healthchecker/healthchecker-udp/src/main/java/com/tencent/polaris/plugins/outlier/detector/udp/UdpHealthChecker.java b/polaris-plugins/polaris-plugins-healthchecker/healthchecker-udp/src/main/java/com/tencent/polaris/plugins/outlier/detector/udp/UdpHealthChecker.java
@@ -64,7 +64,7 @@ public DetectResult detectInstance(Instance instance, FaultDetectRule faultDetec
         UdpProtocolConfig curConfig = config;
 
         int timeoutMs = DEFAULT_TIMEOUT_MILLI;
-        if (null != faultDetectRule && faultDetectRule.getProtocol() == Protocol.TCP) {
+        if (null != faultDetectRule && faultDetectRule.getProtocol() == Protocol.UDP) {
             if (faultDetectRule.getTimeout() > 0) {
                 timeoutMs = faultDetectRule.getTimeout();
             }

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ public DetectResult detectInstance(Instance instance, FaultDetectRule faultDetec`
`64`	`64`	`UdpProtocolConfig curConfig = config;`
`65`	`65`
`66`	`66`	`int timeoutMs = DEFAULT_TIMEOUT_MILLI;`
`67`		`- if (null != faultDetectRule && faultDetectRule.getProtocol() == Protocol.TCP) {`
	`67`	`+ if (null != faultDetectRule && faultDetectRule.getProtocol() == Protocol.UDP) {`
`68`	`68`	`if (faultDetectRule.getTimeout() > 0) {`
`69`	`69`	`timeoutMs = faultDetectRule.getTimeout();`
`70`	`70`	`}`