MT#55283 Unref ports after re-subscribe

Previously, the ports used for a monologue subscription would leak upon re-subscribe.
``__assign_stream_fds`` cleared the stream fd queue without decrementing the ref count. This
prevented ``monologue_destroy`` from releasing the ports on unsubscribe.

Closes #2125

Change-Id: Ib86290d6a35e2388e34098f2847f1e34b3db2c5d
(cherry picked from commit 250df2af5e)

daemon/call.c

@@ -906,7 +906,7 @@ static void __assign_stream_fds(struct call_media *media, sfd_intf_list_q *intf_
 		// use opaque pointer to detect changes
 		void *old_selected_sfd = ps->selected_sfd;
 
-		t_queue_clear(&ps->sfds);
+		t_queue_clear_full(&ps->sfds, stream_fd_dec);
 		bool sfd_found = false;
 		stream_fd *intf_sfd = NULL;
 
@@ -3541,10 +3541,12 @@ static void monologue_bundle_set_fds(struct call_monologue *ml) {
 			dtls_shutdown(ms);
 
 			// XXX close sockets that are not needed?
-			t_queue_clear(&ms->sfds);
+			t_queue_clear_full(&ms->sfds, stream_fd_dec);
 
-			for (__auto_type sl = bs->sfds.head; sl; sl = sl->next)
+			for (__auto_type sl = bs->sfds.head; sl; sl = sl->next) {
+				stream_fd_inc(sl->data);
 				t_queue_push_tail(&ms->sfds, sl->data);
+			}
 
 			ms->selected_sfd = bs->selected_sfd;
 

perl/NGCP/Rtpengine/AutoTest.pm

@@ -23,7 +23,7 @@ our $port;
 BEGIN {
 	require Exporter;
 	@ISA = qw(Exporter);
-	our @EXPORT = qw(autotest_start new_call new_call_nc offer answer ft tt cid snd srtp_snd rtp rcv srtp_rcv rcv_no rcv_maybe
+	our @EXPORT = qw(autotest_start new_call new_call_nc offer answer ft tt cid snd snd_no srtp_snd rtp rcv srtp_rcv rcv_no rcv_maybe
 		srtp_dec escape rtpm rtpmre reverse_tags new_ft new_tt crlf sdp_split rtpe_req offer_answer
 		autotest_init subscribe_request subscribe_answer publish create create_answer
 		use_json rtpe_raw_req);
@@ -223,6 +223,10 @@ sub snd {
 	my ($sock, $dest, $packet, $addr) = @_;
 	$sock->send($packet, 0, pack_sockaddr_in($dest, inet_aton($addr // '203.0.113.1'))) or die;
 }
+sub snd_no {
+	my ($sock, $dest, $packet, $addr) = @_;
+	ok(!$sock->send($packet, 0, pack_sockaddr_in($dest, inet_aton($addr // '203.0.113.1'))), "send to closed port fails");
+}
 sub srtp_snd {
 	my ($sock, $dest, $packet, $srtp_ctx, $addr) = @_;
 	if (!$srtp_ctx->{skey}) {

t/auto-daemon-tests-create.pl

@@ -381,7 +381,7 @@ rtpe_req('unsubscribe', 'extended connect w "all" bidirectional', {
 		flags => [],
 });
 
-snd($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
+snd_no($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
 rcv_no($sock_a);
 rcv_no($sock_b);
 rcv_no($sock_c);
@@ -766,7 +766,7 @@ rtpe_req('unsubscribe', 'extended connect w from-tags bidirectional', {
 		flags => [],
 });
 
-snd($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
+snd_no($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
 rcv_no($sock_a);
 rcv_no($sock_b);
 rcv_no($sock_c);
@@ -1144,7 +1144,7 @@ rtpe_req('unsubscribe', 'extended connect w from-tags', {
 		flags => [],
 });
 
-snd($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
+snd_no($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
 rcv_no($sock_a);
 rcv_no($sock_b);
 rcv_no($sock_c);
@@ -1703,7 +1703,7 @@ rtpe_req('unsubscribe', 'extended connect bidirectional', {
 		flags => [],
 });
 
-snd($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
+snd_no($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
 rcv_no($sock_a);
 rcv_no($sock_b);
 rcv_no($sock_c);
@@ -2249,7 +2249,7 @@ rtpe_req('unsubscribe', 'extended connect', {
 		flags => [],
 });
 
-snd($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
+snd_no($sock_a, $port_b, rtp (0, 1011, 4760, 0x1234, "\x11" x 160));
 rcv_no($sock_a);
 rcv_no($sock_b);
 rcv_no($sock_c);