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

rtpfunnel: Also write TWCC RTP header extension into buffer list buffers

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/6110>
This commit is contained in:
Sebastian Dröge 2024-02-13 18:07:52 +02:00 committed by GStreamer Marge Bot
parent d49a2ae00f
commit 17e7af7181
1 changed files with 22 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
subprojects/gst-plugins-good/gst/rtpmanager/gstrtpfunnel.c
View file

@ -259,6 +259,22 @@ map_failed:
} }
} }
typedef struct
{
GstRtpFunnel *funnel;
GstPad *pad;
} SetTwccSeqnumData;
static gboolean
set_twcc_seqnum (GstBuffer ** buf, guint idx, gpointer user_data)
{
SetTwccSeqnumData *data = user_data;
gst_rtp_funnel_set_twcc_seqnum (data->funnel, data->pad, buf);
return TRUE;
}
static GstFlowReturn static GstFlowReturn
gst_rtp_funnel_sink_chain_object (GstPad * pad, GstRtpFunnel * funnel, gst_rtp_funnel_sink_chain_object (GstPad * pad, GstRtpFunnel * funnel,
gboolean is_list, GstMiniObject * obj) gboolean is_list, GstMiniObject * obj)
@ -273,7 +289,12 @@ gst_rtp_funnel_sink_chain_object (GstPad * pad, GstRtpFunnel * funnel,
gst_rtp_funnel_forward_segment (funnel, pad); gst_rtp_funnel_forward_segment (funnel, pad);
if (is_list) { if (is_list) {
res = gst_pad_push_list (funnel->srcpad, GST_BUFFER_LIST_CAST (obj)); GstBufferList *list = GST_BUFFER_LIST_CAST (obj);
SetTwccSeqnumData data = { funnel, pad };
list = gst_buffer_list_make_writable (list);
gst_buffer_list_foreach (list, set_twcc_seqnum, &data);
res = gst_pad_push_list (funnel->srcpad, list);
} else { } else {
GstBuffer *buf = GST_BUFFER_CAST (obj); GstBuffer *buf = GST_BUFFER_CAST (obj);
gst_rtp_funnel_set_twcc_seqnum (funnel, pad, &buf); gst_rtp_funnel_set_twcc_seqnum (funnel, pad, &buf);