mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-13 12:51:16 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtsp-media: Only count senders when counting blocked streams

Browse source 
Only sender streams sends the GstRTSPStreamBlocking message, so only
these should be counted before setting media status to prepared.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-rtsp-server/-/merge_requests/180>
This commit is contained in:
Tobias Ronge 2020-12-17 15:27:27 +01:00
parent d1783cf381
commit 07c009dc80
1 changed files with 13 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
gst/rtsp-server/rtsp-media.c
View file

@ -3164,19 +3164,20 @@ set_target_state (GstRTSPMedia * media, GstState state, gboolean do_state)
}
static void
stream_collect_active (GstRTSPStream * stream, guint * active_streams)
stream_collect_active_sender (GstRTSPStream * stream, guint * active_streams)
{
if (gst_rtsp_stream_is_complete (stream))
if (gst_rtsp_stream_is_complete (stream)
&& gst_rtsp_stream_is_sender (stream))
(*active_streams)++;
}
static guint
nbr_active_streams (GstRTSPMedia * media)
nbr_active_sender_streams (GstRTSPMedia * media)
{
guint ret = 0;
g_ptr_array_foreach (media->priv->streams, (GFunc) stream_collect_active,
&ret);
g_ptr_array_foreach (media->priv->streams,
(GFunc) stream_collect_active_sender, &ret);
return ret;
}
@ -3289,7 +3290,7 @@ default_handle_message (GstRTSPMedia * media, GstMessage * message)
s = gst_message_get_structure (message);
if (gst_structure_has_name (s, "GstRTSPStreamBlocking")) {
gboolean is_complete = FALSE;
guint n_active_streams;
guint n_active_sender_streams;
guint expected_nbr_blocking_msg;
/* to prevent problems when some streams are complete, some are not,
@ -3297,16 +3298,16 @@ default_handle_message (GstRTSPMedia * media, GstMessage * message)
* streams (during DESCRIBE), we will listen to all streams. */
gst_structure_get_boolean (s, "is_complete", &is_complete);
n_active_streams = nbr_active_streams (media);
expected_nbr_blocking_msg = n_active_streams;
n_active_sender_streams = nbr_active_sender_streams (media);
expected_nbr_blocking_msg = n_active_sender_streams;
GST_DEBUG_OBJECT (media, "media received blocking message,"
" n_active_streams = %d, is_complete = %d",
n_active_streams, is_complete);
" n_active_sender_streams = %d, is_complete = %d",
n_active_sender_streams, is_complete);
if (n_active_streams == 0 || is_complete)
if (n_active_sender_streams == 0 || is_complete)
priv->blocking_msg_received++;
if (n_active_streams == 0)
if (n_active_sender_streams == 0)
expected_nbr_blocking_msg = priv->streams->len;
if (priv->blocked && media_streams_blocking (media) &&