From bfd28178b0ebb2b2c8769a256bad09ea534aedf5 Mon Sep 17 00:00:00 2001 From: chaoc Date: Thu, 3 Aug 2023 17:29:47 +0800 Subject: [PATCH] perf(error): add cond --- .../com/zdjizhi/flink/voip/error/ErrorHandler.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/zdjizhi/flink/voip/error/ErrorHandler.java b/src/main/java/com/zdjizhi/flink/voip/error/ErrorHandler.java index bc9b456..995da1e 100644 --- a/src/main/java/com/zdjizhi/flink/voip/error/ErrorHandler.java +++ b/src/main/java/com/zdjizhi/flink/voip/error/ErrorHandler.java @@ -101,12 +101,12 @@ class MeaninglessAddressProcessFunction extends ProcessFunction= 0; final SIPRecord sipRecord = new SIPRecord(obj); - boolean cond2 = IPUtil.isIPAddress(sipRecord.getOriginatorSdpConnectIp()) && - IPUtil.internalIp(sipRecord.getOriginatorSdpConnectIp()) - || IPUtil.isIPAddress(sipRecord.getResponderSdpConnectIp()) && - IPUtil.internalIp(sipRecord.getResponderSdpConnectIp()); + boolean cond2 = !IPUtil.isIPAddress(sipRecord.getOriginatorSdpConnectIp()) + || IPUtil.internalIp(sipRecord.getOriginatorSdpConnectIp()); + boolean cond3 = !IPUtil.isIPAddress(sipRecord.getResponderSdpConnectIp()) + || IPUtil.internalIp(sipRecord.getResponderSdpConnectIp()); - if (cond1 && cond2) { + if (cond1 && cond2 && cond3) { out.collect(obj); } else { // Output invalid records to the invalid output tag