mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-06-27 10:20:42 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst/gstpad.c (gst_pad_get_range, gst_pad_pull_range): Set caps on the pads if necessary, as in push()/chain(). Update...

Browse source 
Original commit message from CVS:
2007-01-06  Andy Wingo  <wingo@pobox.com>

* gst/gstpad.c (gst_pad_get_range, gst_pad_pull_range): Set caps
on the pads if necessary, as in push()/chain(). Update docs.
Shouldn't affect existing pull() usage as it is currently only
being used on buffers without caps.
This commit is contained in:
Andy Wingo 2007-01-06 17:09:10 +00:00
parent 3001f88c3c
commit 77472ddbd7
2 changed files with 72 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
ChangeLog
View file

@ -1,3 +1,10 @@
2007-01-06 Andy Wingo <wingo@pobox.com>
* gst/gstpad.c (gst_pad_get_range, gst_pad_pull_range): Set caps
on the pads if necessary, as in push()/chain(). Update docs.
Shouldn't affect existing pull() usage as it is currently only
being used on buffers without caps.
2007-01-05 Tim-Philipp Müller <tim at centricular dot net>
* gst/gst.c: (gst_init_get_option_group), (gst_init_check),

65
gst/gstpad.c
View file

@ -3691,6 +3691,11 @@ not_connected:
* installed (see gst_pad_set_getrange_function()) this function returns
* #GST_FLOW_NOT_SUPPORTED.
*
* This function will call gst_pad_set_caps() on @pad if the pull is successful
* and the caps on @buffer differ from what is already set on @pad, as is done
* in gst_pad_push(). This could cause the function to return
* #GST_FLOW_NOT_NEGOTIATED if the caps could not be set.
*
* Returns: a #GstFlowReturn from the pad.
*
* MT safe.
@ -3734,6 +3739,25 @@ gst_pad_get_range (GstPad * pad, guint64 offset, guint size,
GST_PAD_STREAM_UNLOCK (pad);
if (G_LIKELY (ret == GST_FLOW_OK)) {
GstCaps *caps;
gboolean caps_changed;
GST_OBJECT_LOCK (pad);
/* Before pushing the buffer to the peer pad, ensure that caps
* are set on this pad */
caps = GST_BUFFER_CAPS (*buffer);
caps_changed = caps && caps != GST_PAD_CAPS (pad);
GST_OBJECT_UNLOCK (pad);
/* we got a new datatype from the pad, it had better handle it */
if (G_UNLIKELY (caps_changed)) {
GST_DEBUG_OBJECT (pad, "caps changed to %p %" GST_PTR_FORMAT, caps, caps);
if (G_UNLIKELY (!gst_pad_configure_src (pad, caps, TRUE)))
goto not_negotiated;
}
}
return ret;
/* ERRORS */
@ -3762,6 +3786,14 @@ dropping:
*buffer = NULL;
return GST_FLOW_UNEXPECTED;
}
not_negotiated:
{
gst_buffer_unref (*buffer);
*buffer = NULL;
GST_CAT_DEBUG_OBJECT (GST_CAT_SCHEDULING, pad,
"getrange returned buffer then refused to accept the caps");
return GST_FLOW_NOT_NEGOTIATED;
}
}
@ -3782,6 +3814,11 @@ dropping:
* See gst_pad_get_range() for a list of return values and for the
* semantics of the arguments of this function.
*
* This function will call gst_pad_set_caps() on @pad if the pull is successful
* and the caps on @buffer differ from what is already set on @pad, as is done
* in gst_pad_chain(). This could cause the function to return
* #GST_FLOW_NOT_NEGOTIATED if the caps could not be set.
*
* Returns: a #GstFlowReturn from the peer pad.
* When this function returns #GST_FLOW_OK, @buffer will contain a valid
* #GstBuffer that should be freed with gst_buffer_unref() after usage.
@ -3827,6 +3864,26 @@ gst_pad_pull_range (GstPad * pad, guint64 offset, guint size,
if (!gst_pad_emit_have_data_signal (pad, GST_MINI_OBJECT (*buffer)))
goto dropping;
}
if (G_LIKELY (ret == GST_FLOW_OK)) {
GstCaps *caps;
gboolean caps_changed;
GST_OBJECT_LOCK (pad);
/* Before pushing the buffer to the peer pad, ensure that caps
* are set on this pad */
caps = GST_BUFFER_CAPS (*buffer);
caps_changed = caps && caps != GST_PAD_CAPS (pad);
GST_OBJECT_UNLOCK (pad);
/* we got a new datatype on the pad, see if it can handle it */
if (G_UNLIKELY (caps_changed)) {
GST_DEBUG_OBJECT (pad, "caps changed to %p %" GST_PTR_FORMAT, caps, caps);
if (G_UNLIKELY (!gst_pad_configure_sink (pad, caps)))
goto not_negotiated;
}
}
return ret;
/* ERROR recovery here */
@ -3845,6 +3902,14 @@ dropping:
*buffer = NULL;
return GST_FLOW_UNEXPECTED;
}
not_negotiated:
{
gst_buffer_unref (*buffer);
*buffer = NULL;
GST_CAT_LOG_OBJECT (GST_CAT_SCHEDULING, pad,
"pulled buffer but pad did not accept the caps");
return GST_FLOW_NOT_NEGOTIATED;
}
}
/**