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

pulsesink: write silence on underflow

Browse source 
Start filling up the buffer with empty samples when an underflow happens. We
need to do this to keep pulseaudio reporting the right time for us.
This commit is contained in:
Wim Taymans 2009-04-09 14:16:35 +02:00
parent 2e2f1d73ca
commit 81c5fb9e48
1 changed files with 38 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
ext/pulse/pulsesink.c
View file

@ -466,12 +466,48 @@ gst_pulsering_stream_state_cb (pa_stream * s, void *userdata)
}
}
/* we need to write empty samples to pulse so that it keeps on updating
* the clock correctly, we only start doing this on underflow */
static void
gst_pulsering_underflow_cb (pa_stream * s, void *userdata)
{
GstPulseSink *psink;
GstRingBuffer *rbuf;
GstPulseRingBuffer *pbuf;
size_t avail;
rbuf = GST_RING_BUFFER_CAST (userdata);
pbuf = GST_PULSERING_BUFFER_CAST (userdata);
psink = GST_PULSESINK_CAST (GST_OBJECT_PARENT (pbuf));
GST_LOG_OBJECT (psink, "got underflow");
if ((avail = pa_stream_writable_size (pbuf->stream)) > 0) {
guint segsize, towrite;
segsize = rbuf->spec.segsize;
/* we need to write empty data into the ringbuffer to make it advance the
* clock */
GST_LOG_OBJECT (psink, "writing %" G_GSIZE_FORMAT " bytes empty data",
avail);
while (avail > 0) {
towrite = MIN (avail, segsize);
pa_stream_write (pbuf->stream, rbuf->empty_seg, towrite,
NULL, 0, PA_SEEK_RELATIVE);
avail -= towrite;
}
}
}
static void
gst_pulsering_stream_request_cb (pa_stream * s, size_t length, void *userdata)
{
GstPulseSink *psink;
GstRingBuffer *rbuf;
GstPulseRingBuffer *pbuf;
rbuf = GST_RING_BUFFER_CAST (userdata);
pbuf = GST_PULSERING_BUFFER_CAST (userdata);
psink = GST_PULSESINK_CAST (GST_OBJECT_PARENT (pbuf));
@ -542,6 +578,8 @@ gst_pulseringbuffer_acquire (GstRingBuffer * buf, GstRingBufferSpec * spec)
gst_pulsering_stream_state_cb, pbuf);
pa_stream_set_write_callback (pbuf->stream,
gst_pulsering_stream_request_cb, pbuf);
pa_stream_set_underflow_callback (pbuf->stream,
gst_pulsering_underflow_cb, pbuf);
/* buffering requirements */
memset (&buf_attr, 0, sizeof (buf_attr));