From 3c5830783f40f8c29f2901a0a563bd9c3ddead3b Mon Sep 17 00:00:00 2001
From: Richard Fuchs <rfuchs@sipwise.com>
Date: Fri, 2 May 2025 07:23:40 -0400
Subject: [PATCH] MT#62735 add tests for heuristic learning mode

Change-Id: I0c3d67f4ee3f3350fcf0b350c39e475db948c6c8
(cherry picked from commit ee32e5ba5fade0cb9e3620f8abc05fcc9054387b)
---
 t/Makefile                       |  13 +-
 t/auto-daemon-tests-heuristic.pl | 584 +++++++++++++++++++++++++++++++
 2 files changed, 595 insertions(+), 2 deletions(-)
 create mode 100755 t/auto-daemon-tests-heuristic.pl

diff --git a/t/Makefile b/t/Makefile
index 4189a2164..7d8607f0d 100644
--- a/t/Makefile
+++ b/t/Makefile
@@ -88,7 +88,8 @@ include ../lib/common.Makefile
 
 .PHONY:		all-tests unit-tests daemon-tests daemon-tests \
 	daemon-tests-main daemon-tests-jb daemon-tests-dtx daemon-tests-dtx-cn daemon-tests-pubsub \
-	daemon-tests-intfs daemon-tests-stats daemon-tests-delay-buffer daemon-tests-delay-timing
+	daemon-tests-intfs daemon-tests-stats daemon-tests-delay-buffer daemon-tests-delay-timing \
+	daemon-tests-heuristic
 
 TESTS=		test-bitstr aes-crypt aead-aes-crypt test-const_str_hash.strhash
 ifeq ($(with_transcoding),yes)
@@ -123,7 +124,7 @@ unit-tests:	$(TESTS)
 	fi
 
 daemon-tests: daemon-tests-main daemon-tests-jb daemon-tests-pubsub daemon-tests-websocket \
-	daemon-tests-intfs daemon-tests-stats # daemon-tests-delay-buffer daemon-tests-delay-timing
+	daemon-tests-intfs daemon-tests-stats daemon-tests-heuristic
 
 daemon-test-deps:	tests-preload.so
 	$(MAKE) -C ../daemon
@@ -144,6 +145,14 @@ daemon-tests-jb:	daemon-test-deps
 	test "$$(ls fake-$@-sockets)" = ""
 	rmdir fake-$@-sockets
 
+daemon-tests-heuristic:	daemon-test-deps
+	rm -rf fake-$@-sockets
+	mkdir fake-$@-sockets
+	LD_PRELOAD=../t/tests-preload.so RTPE_BIN=../daemon/rtpengine TEST_SOCKET_PATH=./fake-$@-sockets \
+		   perl -I../perl auto-daemon-tests-heuristic.pl
+	test "$$(ls fake-$@-sockets)" = ""
+	rmdir fake-$@-sockets
+
 daemon-tests-dtx:	daemon-test-deps
 	rm -rf fake-$@-sockets
 	mkdir fake-$@-sockets
diff --git a/t/auto-daemon-tests-heuristic.pl b/t/auto-daemon-tests-heuristic.pl
new file mode 100755
index 000000000..facb612b6
--- /dev/null
+++ b/t/auto-daemon-tests-heuristic.pl
@@ -0,0 +1,584 @@
+#!/usr/bin/perl
+
+use strict;
+use warnings;
+use NGCP::Rtpengine::Test;
+use NGCP::Rtpclient::SRTP;
+use NGCP::Rtpengine::AutoTest;
+use Test::More;
+
+
+autotest_start(qw(--config-file=none -t -1 -i 203.0.113.1
+			-n 2223 -f -L 7 -E --endpoint-learning=heuristic))
+		or die;
+
+
+my ($sock_a, $sock_b, $sock_c, $sock_d, $sock_e, $port_a, $port_b);
+
+
+
+
+($sock_a, $sock_b, $sock_c, $sock_d, $sock_e) = new_call(
+	[qw(198.51.100.1 2010)], # caller
+	[qw(198.51.100.3 2012)], # callee - from SDP
+	[qw(198.51.100.3 2032)], # callee - different port
+	[qw(198.51.100.6 2012)], # callee - different address
+	[qw(198.51.100.6 2032)], # callee - all different
+);
+
+($port_a) = offer('basic, forward', { }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 2010 RTP/AVP 0 8
+c=IN IP4 198.51.100.1
+a=sendrecv
+----------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+($port_b) = answer('basic, forward', { }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 2012 RTP/AVP 0 8
+c=IN IP4 198.51.100.3
+a=sendrecv
+--------------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1000, 3000, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1000, 3000, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2000, 4000, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2000, 4000, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1001, 3160, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1001, 3160, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2001, 4160, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2001, 4160, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1002, 3320, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1002, 3320, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2002, 4320, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2002, 4320, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1003, 3480, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1003, 3480, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2003, 4480, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2003, 4480, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1004, 3640, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1004, 3640, 0x1234, "\x00" x 160));
+
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2004, 4640, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2004, 4640, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1005, 3800, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1005, 3800, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2005, 4800, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2005, 4800, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1006, 3960, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1006, 3960, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2006, 4960, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2006, 4960, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1007, 4120, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1007, 4120, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2007, 5120, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2007, 5120, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1008, 4280, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1008, 4280, 0x1234, "\x00" x 160));
+
+# wait for fix
+sleep(4);
+
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2008, 5280, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2008, 5280, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1009, 4440, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1009, 4440, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2009, 5440, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2009, 5440, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1010, 4600, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1010, 4600, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2010, 5600, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2010, 5600, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1011, 4760, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1011, 4760, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2011, 5760, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2011, 5760, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1012, 4920, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1012, 4920, 0x1234, "\x00" x 160));
+
+rcv_no($sock_a);
+rcv_no($sock_b);
+rcv_no($sock_c);
+rcv_no($sock_d);
+rcv_no($sock_e);
+
+
+($sock_a, $sock_b, $sock_c, $sock_d, $sock_e) = new_call(
+	[qw(198.51.100.1 2050)], # caller
+	[qw(198.51.100.3 2052)], # callee - from SDP
+	[qw(198.51.100.3 2072)], # callee - different port
+	[qw(198.51.100.6 2052)], # callee - different address
+	[qw(198.51.100.6 2072)], # callee - all different
+);
+
+($port_a) = offer('basic, reverse', { }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 2050 RTP/AVP 0 8
+c=IN IP4 198.51.100.1
+a=sendrecv
+----------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+($port_b) = answer('basic, reverse', { }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 2052 RTP/AVP 0 8
+c=IN IP4 198.51.100.3
+a=sendrecv
+--------------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1000, 3000, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1000, 3000, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2000, 4000, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2000, 4000, 0x1234, "\x00" x 160));
+# caller send, forward to worst candidate
+snd($sock_a, $port_b, rtp(0, 1001, 3160, 0x1234, "\x00" x 160));
+rcv($sock_e, $port_a, rtpm(0, 1001, 3160, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2001, 4160, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2001, 4160, 0x1234, "\x00" x 160));
+# caller send, forward to almost good candidate
+snd($sock_a, $port_b, rtp(0, 1002, 3320, 0x1234, "\x00" x 160));
+rcv($sock_c, $port_a, rtpm(0, 1002, 3320, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2002, 4320, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2002, 4320, 0x1234, "\x00" x 160));
+# caller send, forward to almost good candidate (different address ignored)
+snd($sock_a, $port_b, rtp(0, 1003, 3480, 0x1234, "\x00" x 160));
+rcv($sock_c, $port_a, rtpm(0, 1003, 3480, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2003, 4480, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2003, 4480, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1004, 3640, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1004, 3640, 0x1234, "\x00" x 160));
+
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2004, 4640, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2004, 4640, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1005, 3800, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1005, 3800, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2005, 4800, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2005, 4800, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1006, 3960, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1006, 3960, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2006, 4960, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2006, 4960, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1007, 4120, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1007, 4120, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2007, 5120, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2007, 5120, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1008, 4280, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1008, 4280, 0x1234, "\x00" x 160));
+
+# wait for fix
+sleep(4);
+
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2008, 5280, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2008, 5280, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1009, 4440, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1009, 4440, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2009, 5440, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2009, 5440, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1010, 4600, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1010, 4600, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2010, 5600, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2010, 5600, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1011, 4760, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1011, 4760, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2011, 5760, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2011, 5760, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1012, 4920, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1012, 4920, 0x1234, "\x00" x 160));
+
+rcv_no($sock_a);
+rcv_no($sock_b);
+rcv_no($sock_c);
+rcv_no($sock_d);
+rcv_no($sock_e);
+
+
+
+
+
+
+($sock_a, $sock_b, $sock_c, $sock_d, $sock_e) = new_call(
+	[qw(198.51.100.1 2080)], # caller
+	[qw(198.51.100.3 2082)], # callee - from SDP
+	[qw(198.51.100.3 2102)], # callee - different port
+	[qw(198.51.100.6 2082)], # callee - different address
+	[qw(198.51.100.6 2102)], # callee - all different
+);
+
+($port_a) = offer('strict source, forward', { flags => ['strict source'] }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 2080 RTP/AVP 0 8
+c=IN IP4 198.51.100.1
+a=sendrecv
+----------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+($port_b) = answer('strict source, forward', { flags => ['strict source'] }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 2082 RTP/AVP 0 8
+c=IN IP4 198.51.100.3
+a=sendrecv
+--------------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1000, 3000, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1000, 3000, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2000, 4000, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2000, 4000, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1001, 3160, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1001, 3160, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2001, 4160, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2001, 4160, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1002, 3320, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1002, 3320, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2002, 4320, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2002, 4320, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1003, 3480, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1003, 3480, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2003, 4480, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2003, 4480, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1004, 3640, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1004, 3640, 0x1234, "\x00" x 160));
+
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2004, 4640, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2004, 4640, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1005, 3800, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1005, 3800, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2005, 4800, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2005, 4800, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1006, 3960, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1006, 3960, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2006, 4960, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2006, 4960, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1007, 4120, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1007, 4120, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2007, 5120, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2007, 5120, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1008, 4280, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1008, 4280, 0x1234, "\x00" x 160));
+
+# wait for fix
+sleep(4);
+
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2008, 5280, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2008, 5280, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1009, 4440, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1009, 4440, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2009, 5440, 0x1234, "\x00" x 160));
+rcv_no($sock_a); # dropped
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1010, 4600, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1010, 4600, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2010, 5600, 0x1234, "\x00" x 160));
+rcv_no($sock_a); # dropped
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1011, 4760, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1011, 4760, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2011, 5760, 0x1234, "\x00" x 160));
+rcv_no($sock_a); # dropped
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1012, 4920, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1012, 4920, 0x1234, "\x00" x 160));
+
+rcv_no($sock_a);
+rcv_no($sock_b);
+rcv_no($sock_c);
+rcv_no($sock_d);
+rcv_no($sock_e);
+
+
+
+
+
+($sock_a, $sock_b, $sock_c, $sock_d, $sock_e) = new_call(
+	[qw(198.51.100.1 2140)], # caller
+	[qw(198.51.100.3 2142)], # callee - from SDP
+	[qw(198.51.100.3 2162)], # callee - different port
+	[qw(198.51.100.6 2142)], # callee - different address
+	[qw(198.51.100.6 2162)], # callee - all different
+);
+
+($port_a) = offer('strict source, reverse', { flags => ['strict source'] }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 2140 RTP/AVP 0 8
+c=IN IP4 198.51.100.1
+a=sendrecv
+----------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+($port_b) = answer('strict source, reverse', { flags => ['strict source'] }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 2142 RTP/AVP 0 8
+c=IN IP4 198.51.100.3
+a=sendrecv
+--------------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 0 8
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1000, 3000, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1000, 3000, 0x1234, "\x00" x 160));
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2000, 4000, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2000, 4000, 0x1234, "\x00" x 160));
+# caller send, forward to worst candidate
+snd($sock_a, $port_b, rtp(0, 1001, 3160, 0x1234, "\x00" x 160));
+rcv($sock_e, $port_a, rtpm(0, 1001, 3160, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2001, 4160, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2001, 4160, 0x1234, "\x00" x 160));
+# caller send, forward to almost good candidate
+snd($sock_a, $port_b, rtp(0, 1002, 3320, 0x1234, "\x00" x 160));
+rcv($sock_c, $port_a, rtpm(0, 1002, 3320, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2002, 4320, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2002, 4320, 0x1234, "\x00" x 160));
+# caller send, forward to almost good candidate (different address ignored)
+snd($sock_a, $port_b, rtp(0, 1003, 3480, 0x1234, "\x00" x 160));
+rcv($sock_c, $port_a, rtpm(0, 1003, 3480, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2003, 4480, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2003, 4480, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1004, 3640, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1004, 3640, 0x1234, "\x00" x 160));
+
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2004, 4640, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2004, 4640, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1005, 3800, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1005, 3800, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2005, 4800, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2005, 4800, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1006, 3960, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1006, 3960, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2006, 4960, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2006, 4960, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1007, 4120, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1007, 4120, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2007, 5120, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2007, 5120, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1008, 4280, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1008, 4280, 0x1234, "\x00" x 160));
+
+# wait for fix
+sleep(4);
+
+# callee send from different everything
+snd($sock_e, $port_a, rtp(0, 2008, 5280, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2008, 5280, 0x1234, "\x00" x 160)); # first packet that confirms the address still gets through
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1009, 4440, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1009, 4440, 0x1234, "\x00" x 160));
+# callee send from different port
+snd($sock_c, $port_a, rtp(0, 2009, 5440, 0x1234, "\x00" x 160));
+rcv_no($sock_a); # dropped
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1010, 4600, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1010, 4600, 0x1234, "\x00" x 160));
+# callee send from different address
+snd($sock_d, $port_a, rtp(0, 2010, 5600, 0x1234, "\x00" x 160));
+rcv_no($sock_a); # dropped
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1011, 4760, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1011, 4760, 0x1234, "\x00" x 160));
+# callee send from expected
+snd($sock_b, $port_a, rtp(0, 2011, 5760, 0x1234, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2011, 5760, 0x1234, "\x00" x 160));
+# caller send, forward to expected
+snd($sock_a, $port_b, rtp(0, 1012, 4920, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1012, 4920, 0x1234, "\x00" x 160));
+
+rcv_no($sock_a);
+rcv_no($sock_b);
+rcv_no($sock_c);
+rcv_no($sock_d);
+rcv_no($sock_e);
+
+
+
+
+
+#done_testing;NGCP::Rtpengine::AutoTest::terminate('f00');exit;
+done_testing();