mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-12-19 08:57:14 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pinospay: error if downstream doesn't handle control-messages

Browse source 
We really need a downstream element that can handle the control-messages
or else we'll be losing the data.
This commit is contained in:
Wim Taymans 2015-12-04 12:48:03 +01:00
parent f51307f8f8
commit a25bf11c1c
1 changed files with 31 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

31
src/gst/gstpinospay.c
View file

@ -103,6 +103,33 @@ gst_pinos_pay_query (GstPad * pad, GstObject * parent, GstQuery * query)
return res; return res;
} }
static gboolean
do_allocation (GstPinosPay *pay, GstCaps *caps)
{
GstQuery *query;
GST_DEBUG_OBJECT (pay, "doing allocation query");
query = gst_query_new_allocation (caps, TRUE);
if (!gst_pad_peer_query (pay->srcpad, query)) {
/* not a problem, just debug a little */
GST_DEBUG_OBJECT (pay, "peer ALLOCATION query failed");
}
if (!gst_query_find_allocation_meta (query,
GST_NET_CONTROL_MESSAGE_META_API_TYPE, NULL))
goto no_meta;
return TRUE;
/* ERRORS */
no_meta:
{
GST_ELEMENT_ERROR (pay, STREAM, FORMAT,
("Incompatible downstream element"),
("The downstream element does not handle control-message metadata API"));
return FALSE;
}
}
static gboolean static gboolean
gst_pinos_pay_sink_event (GstPad * pad, GstObject * parent, GstEvent * event) gst_pinos_pay_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{ {
@ -123,6 +150,10 @@ gst_pinos_pay_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
caps = gst_caps_new_empty_simple ("application/x-pinos"); caps = gst_caps_new_empty_simple ("application/x-pinos");
res = gst_pad_push_event (pay->srcpad, gst_event_new_caps (caps)); res = gst_pad_push_event (pay->srcpad, gst_event_new_caps (caps));
gst_caps_unref (caps); gst_caps_unref (caps);
if (res)
/* now negotiate the allocation */
res = do_allocation (pay, caps);
break; break;
} }
default: default: