mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-24 01:00:37 +00:00
Code Issues 1 Projects Releases Wiki Activity

audiorate: also fill up segments if possible

Browse source
This commit is contained in:
Mark Nauwelaerts 2009-12-14 18:47:27 +01:00
parent a11a1858ed
commit 56d4534554
1 changed files with 27 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
gst/audiorate/gstaudiorate.c
View file

@ -294,6 +294,26 @@ gst_audio_rate_init (GstAudioRate * audiorate)
audiorate->silent = DEFAULT_SILENT; audiorate->silent = DEFAULT_SILENT;
} }
static void
gst_audio_rate_fill_to_time (GstAudioRate * audiorate, GstClockTime time)
{
GstBuffer *buf;
GST_DEBUG_OBJECT (audiorate, "next_ts: %" GST_TIME_FORMAT
", filling to %" GST_TIME_FORMAT, GST_TIME_ARGS (audiorate->next_ts),
GST_TIME_ARGS (time));
if (!GST_CLOCK_TIME_IS_VALID (time) ||
!GST_CLOCK_TIME_IS_VALID (audiorate->next_ts))
return;
/* feed an empty buffer to chain with the given timestamp,
* it will take care of filling */
buf = gst_buffer_new ();
GST_BUFFER_TIMESTAMP (buf) = time;
gst_audio_rate_chain (audiorate->sinkpad, buf);
}
static gboolean static gboolean
gst_audio_rate_sink_event (GstPad * pad, GstEvent * event) gst_audio_rate_sink_event (GstPad * pad, GstEvent * event)
{ {
@ -319,21 +339,16 @@ gst_audio_rate_sink_event (GstPad * pad, GstEvent * event)
&start, &stop, &time); &start, &stop, &time);
GST_DEBUG_OBJECT (audiorate, "handle NEWSEGMENT"); GST_DEBUG_OBJECT (audiorate, "handle NEWSEGMENT");
/* FIXME: /* FIXME: bad things will likely happen if rate < 0 ... */
* - sparse stream support. For this, the update flag is TRUE and the
* start/time positions are updated, meaning that time progressed by
* time - old_time amount and we need to fill that gap with empty
* samples.
* - fill the current segment if it has a valid stop position. This
* happens when the update flag is FALSE. With the segment helper we can
* calculate the accumulated time and compare this to the next_offset.
*/
if (!update) { if (!update) {
/* a new segment starts. We need to figure out what will be the next /* a new segment starts. We need to figure out what will be the next
* sample offset. We mark the offsets as invalid so that the _chain * sample offset. We mark the offsets as invalid so that the _chain
* function will perform this calculation. */ * function will perform this calculation. */
gst_audio_rate_fill_to_time (audiorate, audiorate->src_segment.stop);
audiorate->next_offset = -1; audiorate->next_offset = -1;
audiorate->next_ts = -1; audiorate->next_ts = -1;
} else {
gst_audio_rate_fill_to_time (audiorate, audiorate->src_segment.start);
} }
/* we accept all formats */ /* we accept all formats */
@ -633,6 +648,9 @@ gst_audio_rate_chain (GstPad * pad, GstBuffer * buf)
} }
} }
if (GST_BUFFER_SIZE (buf) == 0)
goto beach;
/* Now calculate parameters for whichever buffer (either the original /* Now calculate parameters for whichever buffer (either the original
* or truncated one) we're pushing. */ * or truncated one) we're pushing. */
GST_BUFFER_OFFSET (buf) = audiorate->next_offset; GST_BUFFER_OFFSET (buf) = audiorate->next_offset;