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

rtpsrc: re-use the same src pad for streams that have the same payload type

Browse source 
Also use payload type when naming pads, this will make it easier to identify
pads and simplify the code.

Fixes #1395

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-bad/-/merge_requests/1575>
This commit is contained in:
George Kiagiadakis 2020-09-04 14:18:13 +03:00 committed by GStreamer Merge Bot
parent 6e30cbb3fc
commit 2fcbb4386b
1 changed files with 18 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
gst/rtp/gstrtpsrc.c
View file

@ -426,7 +426,9 @@ gst_rtp_src_rtpbin_pad_added_cb (GstElement * element, GstPad * pad,
{
GstRtpSrc *self = GST_RTP_SRC (data);
GstCaps *caps = gst_pad_query_caps (pad, NULL);
GstPad *upad;
const GstStructure *s;
GstPad *upad = NULL;
gint pt = -1;
gchar name[48];
/* Expose RTP data pad only */
@ -458,15 +460,26 @@ gst_rtp_src_rtpbin_pad_added_cb (GstElement * element, GstPad * pad,
return;
}
s = gst_caps_get_structure (caps, 0);
gst_structure_get_int (s, "payload", &pt);
gst_caps_unref (caps);
GST_RTP_SRC_LOCK (self);
g_snprintf (name, 48, "src_%u", GST_ELEMENT (self)->numpads);
upad = gst_ghost_pad_new (name, pad);
g_snprintf (name, 48, "src_%u", pt);
upad = gst_element_get_static_pad (GST_ELEMENT (self), name);
if (!upad) {
GST_DEBUG_OBJECT (self, "Adding new pad: %s", name);
upad = gst_ghost_pad_new (name, pad);
gst_pad_set_active (upad, TRUE);
gst_element_add_pad (GST_ELEMENT (self), upad);
} else {
GST_DEBUG_OBJECT (self, "Re-using existing pad: %s", GST_PAD_NAME (upad));
gst_ghost_pad_set_target (GST_GHOST_PAD (upad), pad);
gst_object_unref (upad);
}
GST_RTP_SRC_UNLOCK (self);
}