From 6f0b7078ece146a7daf3450383fed115a83c858b Mon Sep 17 00:00:00 2001 From: Alessandro Toppi Date: Fri, 25 Feb 2022 12:58:54 +0100 Subject: [PATCH] Add missing mountpoint mutex unlock and unref, remove double lock (fixes #2902) --- src/plugins/janus_streaming.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/plugins/janus_streaming.c b/src/plugins/janus_streaming.c index 8bf6092b8e..baf72ff2c4 100644 --- a/src/plugins/janus_streaming.c +++ b/src/plugins/janus_streaming.c @@ -4679,6 +4679,8 @@ static json_t *janus_streaming_process_synchronous_request(janus_streaming_sessi } } janus_mutex_unlock(&source->rec_mutex); + janus_refcount_decrease(&mp->ref); + janus_mutex_unlock(&mountpoints_mutex); /* Send a success response back */ response = json_object(); json_object_set_new(response, "streaming", json_string("ok")); @@ -4782,7 +4784,6 @@ static json_t *janus_streaming_process_synchronous_request(janus_streaming_sessi janus_mutex_lock(&source->rec_mutex); if(media) { /* Iterate on all media to stop */ - janus_mutex_lock(&source->rec_mutex); if(json_array_size(media) > 0) { size_t i = 0; for(i=0; irec_mutex); + janus_refcount_decrease(&mp->ref); + janus_mutex_unlock(&mountpoints_mutex); /* Send a success response back */ response = json_object(); json_object_set_new(response, "streaming", json_string("ok"));