diff options
author | Olivier CrĂȘte <olivier.crete@collabora.com> | 2021-04-30 16:21:14 -0400 |
---|---|---|
committer | Olivier CrĂȘte <olivier.crete@collabora.com> | 2021-05-13 15:05:00 -0400 |
commit | 70befc0b21dfd94f76d8d401df4dd6e5595550cf (patch) | |
tree | 643f7cee0552b5747ada6e3e8ef4bff02609f15a /ext | |
parent | dc6655542d49eac55232d69f7e816f7083ae5be7 (diff) | |
download | gstreamer-plugins-bad-70befc0b21dfd94f76d8d401df4dd6e5595550cf.tar.gz |
webrtcbin: Implement caps queries on sinkpad based on codec preferences
Also includes a unit test.
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-bad/-/merge_requests/2183>
Diffstat (limited to 'ext')
-rw-r--r-- | ext/webrtc/gstwebrtcbin.c | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/ext/webrtc/gstwebrtcbin.c b/ext/webrtc/gstwebrtcbin.c index 44c1f03da..0994d3543 100644 --- a/ext/webrtc/gstwebrtcbin.c +++ b/ext/webrtc/gstwebrtcbin.c @@ -310,6 +310,80 @@ gst_webrtcbin_sink_event (GstPad * pad, GstObject * parent, GstEvent * event) return gst_pad_event_default (pad, parent, event); } +static gboolean +gst_webrtcbin_sink_query (GstPad * pad, GstObject * parent, GstQuery * query) +{ + GstWebRTCBinPad *wpad = GST_WEBRTC_BIN_PAD (pad); + gboolean ret = FALSE; + + switch (GST_QUERY_TYPE (query)) { + case GST_QUERY_ACCEPT_CAPS: + GST_OBJECT_LOCK (wpad->trans); + if (wpad->trans->codec_preferences) { + GstCaps *caps; + + gst_query_parse_accept_caps (query, &caps); + + gst_query_set_accept_caps_result (query, + gst_caps_can_intersect (caps, wpad->trans->codec_preferences)); + ret = TRUE; + } + GST_OBJECT_UNLOCK (wpad->trans); + break; + + case GST_QUERY_CAPS: + { + GstCaps *codec_preferences = NULL; + + GST_OBJECT_LOCK (wpad->trans); + if (wpad->trans->codec_preferences) + codec_preferences = gst_caps_ref (wpad->trans->codec_preferences); + GST_OBJECT_UNLOCK (wpad->trans); + + if (codec_preferences) { + GstCaps *filter = NULL; + GstCaps *filter_prefs = NULL; + GstPad *target; + + gst_query_parse_caps (query, &filter); + + if (filter) { + filter_prefs = gst_caps_intersect_full (filter, codec_preferences, + GST_CAPS_INTERSECT_FIRST); + gst_caps_unref (codec_preferences); + } else { + filter_prefs = codec_preferences; + } + + target = gst_ghost_pad_get_target (GST_GHOST_PAD (pad)); + if (target) { + GstCaps *result; + + result = gst_pad_query_caps (target, filter_prefs); + gst_query_set_caps_result (query, result); + gst_caps_unref (result); + + gst_object_unref (target); + } else { + gst_query_set_caps_result (query, filter_prefs); + } + + gst_caps_unref (filter_prefs); + ret = TRUE; + } + break; + } + default: + break; + } + + if (ret) + return TRUE; + + return gst_pad_query_default (pad, parent, query); +} + + static void gst_webrtc_bin_pad_init (GstWebRTCBinPad * pad) { @@ -334,6 +408,7 @@ gst_webrtc_bin_pad_new (const gchar * name, GstPadDirection direction) gst_object_unref (template); 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_DEBUG_OBJECT (pad, "new visible pad with direction %s", direction == GST_PAD_SRC ? "src" : "sink"); |