From 6608a1ed7b97b00420d75d8f5b32e5b1cf16209d Mon Sep 17 00:00:00 2001
From: Richard Fuchs <rfuchs@sipwise.com>
Date: Tue, 4 Apr 2023 10:18:59 -0400
Subject: [PATCH] MT#56447 dequeue ICE fragments after pub/sub

Change-Id: Idda8f8cf191a162b26c908a5eb42fb9281a742f6
---
 daemon/call_interfaces.c | 4 ++++
 daemon/janus.c           | 4 ++++
 2 files changed, 8 insertions(+)

diff --git a/daemon/call_interfaces.c b/daemon/call_interfaces.c
index 8a1187a48..b2f770b05 100644
--- a/daemon/call_interfaces.c
+++ b/daemon/call_interfaces.c
@@ -3321,6 +3321,8 @@ const char *call_publish_ng(struct ng_buffer *ngbuf, bencode_item_t *input, benc
 	if (ret)
 		return "Failed to create SDP";
 
+	dequeue_sdp_fragments(ml);
+
 	call_unlock_release_update(&call);
 
 	return NULL;
@@ -3451,6 +3453,8 @@ const char *call_subscribe_request_ng(bencode_item_t *input, bencode_item_t *out
 
 	bencode_dictionary_add_str_dup(output, "to-tag", &dest_ml->tag);
 
+	dequeue_sdp_fragments(dest_ml);
+
 	call_unlock_release_update(&call);
 
 	return NULL;
diff --git a/daemon/janus.c b/daemon/janus.c
index 3982c5a71..943d66fe8 100644
--- a/daemon/janus.c
+++ b/daemon/janus.c
@@ -630,6 +630,8 @@ static const char *janus_videoroom_join(struct websocket_message *wm, struct jan
 		if (!dest_ml->janus_session)
 			dest_ml->janus_session = obj_get(session);
 
+		dequeue_sdp_fragments(dest_ml);
+
 		if (ret)
 			return "Error generating SDP";
 		*jsep_type_out = "offer";
@@ -869,6 +871,8 @@ static const char *janus_videoroom_configure(struct websocket_message *wm, struc
 		*jsep_sdp_out = sdp_out;
 		sdp_out = STR_NULL; // ownership passed to output
 
+		dequeue_sdp_fragments(ml);
+
 		*jsep_type_out = "answer";
 	}
 	else {