videoroom: Always destroy forwarders on hash map removal.

meetecho · Apr 23, 2024 · 508e84d · 508e84d
1 parent 0200270
commit 508e84d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/plugins/janus_videoroom.c b/src/plugins/janus_videoroom.c
@@ -2817,7 +2817,7 @@ static void janus_videoroom_create_dummy_publisher(janus_videoroom *room, GHashT
 	janus_mutex_init(&publisher->rtp_forwarders_mutex);
 	publisher->remote_recipients = g_hash_table_new_full(g_str_hash, g_str_equal,
 		(GDestroyNotify)g_free, (GDestroyNotify)janus_videoroom_remote_recipient_free);
-	publisher->rtp_forwarders = g_hash_table_new(NULL, NULL);
+	publisher->rtp_forwarders = g_hash_table_new_full(NULL, NULL, NULL, (GDestroyNotify)janus_rtp_forwarder_destroy);
 	publisher->udp_sock = -1;
 	g_atomic_int_set(&publisher->destroyed, 0);
 	janus_refcount_init(&publisher->ref, janus_videoroom_publisher_free);
@@ -7407,7 +7407,7 @@ static json_t *janus_videoroom_process_synchronous_request(janus_videoroom_sessi
 		janus_mutex_init(&publisher->rtp_forwarders_mutex);
 		publisher->remote_recipients = g_hash_table_new_full(g_str_hash, g_str_equal,
 			(GDestroyNotify)g_free, (GDestroyNotify)janus_videoroom_remote_recipient_free);
-		publisher->rtp_forwarders = g_hash_table_new(NULL, NULL);
+		publisher->rtp_forwarders = g_hash_table_new_full(NULL, NULL, NULL, (GDestroyNotify)janus_rtp_forwarder_destroy);
 		publisher->udp_sock = -1;
 		g_atomic_int_set(&publisher->destroyed, 0);
 		janus_refcount_init(&publisher->ref, janus_videoroom_publisher_free);
@@ -9179,7 +9179,7 @@ static void *janus_videoroom_handler(void *data) {
 				janus_mutex_init(&publisher->rtp_forwarders_mutex);
 				publisher->remote_recipients = g_hash_table_new_full(g_str_hash, g_str_equal,
 					(GDestroyNotify)g_free, (GDestroyNotify)janus_videoroom_remote_recipient_free);
-				publisher->rtp_forwarders = g_hash_table_new(NULL, NULL);
+				publisher->rtp_forwarders = g_hash_table_new_full(NULL, NULL, NULL, (GDestroyNotify)janus_rtp_forwarder_destroy);
 				publisher->udp_sock = -1;
 				/* Finally, generate a private ID: this is only needed in case the participant
 				 * wants to allow the plugin to know which subscriptions belong to them */