gfwleak/galaxy-tsg-olap-sip-rtp-correlation
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(error): add cond

Browse Source
This commit is contained in:
chaoc
2023-08-03 17:29:47 +08:00
parent cefc581964
commit bfd28178b0
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/zdjizhi/flink/voip/error/ErrorHandler.java
View File

@@ -101,12 +101,12 @@ class MeaninglessAddressProcessFunction extends ProcessFunction<ObjectNode, Obje
record.getServerPort() >= 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