mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-17 11:45:25 +00:00
Code Issues 1 Projects Releases Wiki Activity

ext/libvisual/visual.c: Improve adapter usage and comments.

Browse source 
Original commit message from CVS:
* ext/libvisual/visual.c: (gst_visual_sink_setcaps),
(gst_vis_src_negotiate), (get_buffer), (gst_visual_chain):
Improve adapter usage and comments.
This commit is contained in:
Wim Taymans 2007-03-09 16:46:35 +00:00
parent e9be846621
commit 5d5f935e38
2 changed files with 30 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2007-03-09 Wim Taymans <wim@fluendo.com>
* ext/libvisual/visual.c: (gst_visual_sink_setcaps),
(gst_vis_src_negotiate), (get_buffer), (gst_visual_chain):
Improve adapter usage and comments.
2007-03-09 Wim Taymans <wim@fluendo.com>
* ext/pango/gsttextrender.c: (gst_text_render_chain):

41
ext/libvisual/visual.c
View file

@ -370,6 +370,8 @@ gst_visual_sink_setcaps (GstPad * pad, GstCaps * caps)
gst_structure_get_int (structure, "channels", &visual->channels);
gst_structure_get_int (structure, "rate", &visual->rate);
/* this is how many samples we need to fill one frame at the requested
* framerate. */
if (visual->fps_n != 0) {
visual->spf =
gst_util_uint64_scale_int (visual->rate, visual->fps_d, visual->fps_n);
@ -401,9 +403,13 @@ gst_vis_src_negotiate (GstVisual * visual)
target = gst_caps_copy_nth (intersect, 0);
gst_caps_unref (intersect);
} else {
target = gst_caps_ref ((GstCaps *) templ);
/* need a copy, we'll be modifying it when fixating */
target = gst_caps_copy (templ);
}
/* fixate in case something is not fixed. This does nothing if the value is
* already fixed. For video we always try to fixate to something like
* 320x240x30 by convention. */
structure = gst_caps_get_structure (target, 0);
gst_structure_fixate_field_nearest_int (structure, "width", 320);
gst_structure_fixate_field_nearest_int (structure, "height", 240);
@ -541,11 +547,6 @@ get_buffer (GstVisual * visual, GstBuffer ** outbuf)
if (ret != GST_FLOW_OK)
return ret;
/* this is bad and should not happen. When the alloc function
* returns _OK, core ensures we have a valid buffer. */
if (*outbuf == NULL)
return GST_FLOW_ERROR;
return GST_FLOW_OK;
}
@ -586,15 +587,23 @@ gst_visual_chain (GstPad * pad, GstBuffer * buffer)
gst_adapter_push (visual->adapter, buffer);
avail = gst_adapter_available (visual->adapter);
GST_DEBUG_OBJECT (visual, "avail now %u", avail);
while (avail > MAX (512, visual->spf) * visual->bps) {
while (TRUE) {
gboolean need_skip;
const guint16 *data;
GST_DEBUG_OBJECT (visual, "processing buffer");
avail = gst_adapter_available (visual->adapter);
GST_DEBUG_OBJECT (visual, "avail now %u", avail);
/* we need at least 512 samples */
if (avail < 512 * visual->bps)
break;
/* we need at least enough samples to make one frame */
if (avail < visual->spf * visual->bps)
break;
if (visual->next_ts != -1) {
gint64 qostime;
@ -713,22 +722,20 @@ gst_visual_chain (GstPad * pad, GstBuffer * buffer)
ret = gst_pad_push (visual->srcpad, outbuf);
outbuf = NULL;
GST_DEBUG_OBJECT (visual, "finished frame, flushing %u samples from input",
visual->spf);
skip:
/* interpollate next timestamp */
if (visual->next_ts != -1)
visual->next_ts += visual->duration;
/* Flush out the number of samples per frame * channels * sizeof (gint16) */
gst_adapter_flush (visual->adapter, MIN (avail, visual->spf * visual->bps));
GST_DEBUG_OBJECT (visual, "finished frame, flushing %u samples from input",
visual->spf);
/* Flush out the number of samples per frame */
gst_adapter_flush (visual->adapter, visual->spf * visual->bps);
/* quit the loop if something was wrong */
if (ret != GST_FLOW_OK)
break;
/* see what we have left for next iteration */
avail = gst_adapter_available (visual->adapter);
}
if (outbuf != NULL)