mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-19 06:46:38 +00:00
Code Issues 1 Projects Releases Wiki Activity

webrtcbin: Store the ssrc of the last received packet

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/1448>
This commit is contained in:
Olivier Crête 2021-12-14 11:28:13 -05:00
parent fc7e7f5ccc
commit 29befed685
2 changed files with 36 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
subprojects/gst-plugins-bad/ext/webrtc/gstwebrtcbin.c
View file

@ -439,6 +439,37 @@ gst_webrtc_bin_pad_init (GstWebRTCBinPad * pad)
{ {
} }
static GstPadProbeReturn
webrtc_bin_pad_buffer_cb (GstPad * pad, GstPadProbeInfo * info,
gpointer user_data)
{
GstWebRTCBinPad *wpad;
GstBuffer *buf;
GstRTPBuffer rtpbuf = GST_RTP_BUFFER_INIT;
if (info->type & GST_PAD_PROBE_TYPE_BUFFER) {
buf = GST_PAD_PROBE_INFO_BUFFER (info);
} else {
GstBufferList *list;
list = GST_PAD_PROBE_INFO_BUFFER_LIST (info);
buf = gst_buffer_list_get (list, 0);
}
if (buf == NULL)
return GST_PAD_PROBE_OK;
if (!gst_rtp_buffer_map (buf, GST_MAP_READ, &rtpbuf))
return GST_PAD_PROBE_OK;
wpad = GST_WEBRTC_BIN_PAD (pad);
wpad->last_ssrc = gst_rtp_buffer_get_ssrc (&rtpbuf);
gst_rtp_buffer_unmap (&rtpbuf);
return GST_PAD_PROBE_OK;
}
static GstWebRTCBinPad * static GstWebRTCBinPad *
gst_webrtc_bin_pad_new (const gchar * name, GstPadDirection direction) gst_webrtc_bin_pad_new (const gchar * name, GstPadDirection direction)
{ {
@ -460,6 +491,9 @@ gst_webrtc_bin_pad_new (const gchar * name, GstPadDirection direction)
gst_pad_set_event_function (GST_PAD (pad), gst_webrtcbin_sink_event); gst_pad_set_event_function (GST_PAD (pad), gst_webrtcbin_sink_event);
gst_pad_set_query_function (GST_PAD (pad), gst_webrtcbin_sink_query); gst_pad_set_query_function (GST_PAD (pad), gst_webrtcbin_sink_query);
gst_pad_add_probe (GST_PAD (pad), GST_PAD_PROBE_TYPE_BUFFER |
GST_PAD_PROBE_TYPE_BUFFER_LIST, webrtc_bin_pad_buffer_cb, NULL, NULL);
GST_DEBUG_OBJECT (pad, "new visible pad with direction %s", GST_DEBUG_OBJECT (pad, "new visible pad with direction %s",
direction == GST_PAD_SRC ? "src" : "sink"); direction == GST_PAD_SRC ? "src" : "sink");
return pad; return pad;

2
subprojects/gst-plugins-bad/ext/webrtc/gstwebrtcbin.h
View file

@ -46,6 +46,8 @@ struct _GstWebRTCBinPad
GstWebRTCRTPTransceiver *trans; GstWebRTCRTPTransceiver *trans;
gulong block_id; gulong block_id;
guint32 last_ssrc;
GstCaps *received_caps; GstCaps *received_caps;
}; };