From 01628fa8470f959d889bb3721abb4d7ede99c8ab Mon Sep 17 00:00:00 2001 From: Michael Olbrich Date: Mon, 6 Apr 2020 10:25:37 +0200 Subject: [PATCH] sdpdemux: don't send EOS for unknown SSRC The rtpbin sends signals for all SSRCs. Don't send an EOS when the SSRC does not match the stream SSRC. This avoids problems when an SSRC from another receiver times out. --- gst/sdp/gstsdpdemux.c | 16 +++++++++++++--- gst/sdp/gstsdpdemux.h | 1 + 2 files changed, 14 insertions(+), 3 deletions(-) diff --git a/gst/sdp/gstsdpdemux.c b/gst/sdp/gstsdpdemux.c index 98aebdf..cb3647b 100644 --- a/gst/sdp/gstsdpdemux.c +++ b/gst/sdp/gstsdpdemux.c @@ -516,6 +516,8 @@ new_session_pad (GstElement * session, GstPad * pad, GstSDPDemux * demux) if (stream == NULL) goto unknown_stream; + stream->ssrc = ssrc; + /* no need for a timeout anymore now */ g_object_set (G_OBJECT (stream->udpsrc[0]), "timeout", (guint64) 0, NULL); @@ -618,7 +620,7 @@ unknown_stream: } static void -gst_sdp_demux_do_stream_eos (GstSDPDemux * demux, guint session) +gst_sdp_demux_do_stream_eos (GstSDPDemux * demux, guint session, guint32 ssrc) { GstSDPStream *stream; @@ -634,6 +636,9 @@ gst_sdp_demux_do_stream_eos (GstSDPDemux * demux, guint session) if (stream->eos) goto was_eos; + if (stream->ssrc != ssrc) + goto wrong_ssrc; + stream->eos = TRUE; gst_sdp_demux_stream_push_event (demux, stream, gst_event_new_eos ()); return; @@ -649,6 +654,11 @@ was_eos: GST_DEBUG_OBJECT (demux, "stream for session %u was already EOS", session); return; } +wrong_ssrc: + { + GST_DEBUG_OBJECT (demux, "unkown SSRC %08x for session %u", ssrc, session); + return; + } } static void @@ -658,7 +668,7 @@ on_bye_ssrc (GstElement * manager, guint session, guint32 ssrc, GST_DEBUG_OBJECT (demux, "SSRC %08x in session %u received BYE", ssrc, session); - gst_sdp_demux_do_stream_eos (demux, session); + gst_sdp_demux_do_stream_eos (demux, session, ssrc); } static void @@ -667,7 +677,7 @@ on_timeout (GstElement * manager, guint session, guint32 ssrc, { GST_DEBUG_OBJECT (demux, "SSRC %08x in session %u timed out", ssrc, session); - gst_sdp_demux_do_stream_eos (demux, session); + gst_sdp_demux_do_stream_eos (demux, session, ssrc); } /* try to get and configure a manager */ diff --git a/gst/sdp/gstsdpdemux.h b/gst/sdp/gstsdpdemux.h index 7862b3e..908ac5b 100644 --- a/gst/sdp/gstsdpdemux.h +++ b/gst/sdp/gstsdpdemux.h @@ -50,6 +50,7 @@ typedef struct _GstSDPStream GstSDPStream; struct _GstSDPStream { gint id; + guint32 ssrc; GstSDPDemux *parent; /* parent, no extra ref to parent is taken */ -- 2.7.4