mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-06-11 10:39:42 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtpxqtdepay: Enabled header extension aggregation

Browse source 
Because this depayloader may build several output buffers within one
process run we push them all into a GstBufferList and push them out at
once to make sure that each buffer gets notified about each header
extension.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/5378>
This commit is contained in:
Jochen Henneberg 2023-09-17 18:48:13 +02:00 committed by GStreamer Marge Bot
parent 4788a3da0d
commit 6608b89977
1 changed files with 13 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
subprojects/gst-plugins-good/gst/isomp4/gstrtpxqtdepay.c
View file

@ -146,6 +146,9 @@ gst_rtp_xqt_depay_class_init (GstRtpXQTDepayClass * klass)
static void
gst_rtp_xqt_depay_init (GstRtpXQTDepay * rtpxqtdepay)
{
gst_rtp_base_depayload_set_aggregate_hdrext_enabled (GST_RTP_BASE_DEPAYLOAD
(rtpxqtdepay), TRUE);
rtpxqtdepay->adapter = gst_adapter_new ();
}
@ -551,6 +554,7 @@ gst_rtp_xqt_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
case 2:
{
guint slen;
GstBufferList *outbufs = NULL;
/* multiple samples per packet.
* 1 2 3
@ -571,6 +575,7 @@ gst_rtp_xqt_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
* . ...... .
* +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
*/
outbufs = gst_buffer_list_new ();
while (payload_len > 8) {
s = (payload[0] & 0x80) != 0; /* contains sync sample */
slen = (payload[2] << 8) | payload[3];
@ -590,7 +595,7 @@ gst_rtp_xqt_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
if (!s)
GST_BUFFER_FLAG_SET (outbuf, GST_BUFFER_FLAG_DELTA_UNIT);
gst_rtp_base_depayload_push (depayload, outbuf);
gst_buffer_list_add (outbufs, outbuf);
/* aligned on 32 bit boundary */
slen = GST_ROUND_UP_4 (slen);
@ -598,6 +603,8 @@ gst_rtp_xqt_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
payload += slen;
payload_len -= slen;
}
gst_rtp_base_depayload_push_list (depayload, outbufs);
outbuf = NULL;
break;
}
case 3:
@ -630,30 +637,35 @@ done:
need_resync:
{
GST_DEBUG_OBJECT (rtpxqtdepay, "waiting for marker");
gst_rtp_base_depayload_dropped (depayload);
goto done;
}
wrong_version:
{
GST_ELEMENT_WARNING (rtpxqtdepay, STREAM, DECODE,
("Unknown payload version."), (NULL));
gst_rtp_base_depayload_dropped (depayload);
goto done;
}
pck_reserved:
{
GST_ELEMENT_WARNING (rtpxqtdepay, STREAM, DECODE,
("PCK reserved 0."), (NULL));
gst_rtp_base_depayload_dropped (depayload);
goto done;
}
wrong_length:
{
GST_ELEMENT_WARNING (rtpxqtdepay, STREAM, DECODE,
("Wrong payload length."), (NULL));
gst_rtp_base_depayload_dropped (depayload);
goto done;
}
unknown_format:
{
GST_ELEMENT_WARNING (rtpxqtdepay, STREAM, DECODE,
("Unknown payload format."), (NULL));
gst_rtp_base_depayload_dropped (depayload);
goto done;
}
}