summaryrefslogtreecommitdiffstats
path: root/src/utils
diff options
context:
space:
mode:
Diffstat (limited to 'src/utils')
-rw-r--r--src/utils/pacat.c10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/utils/pacat.c b/src/utils/pacat.c
index 3c50402f..a3c3f2c8 100644
--- a/src/utils/pacat.c
+++ b/src/utils/pacat.c
@@ -105,14 +105,19 @@ static void stream_write_callback(pa_stream *s, size_t length, void *userdata) {
}
/* This is called whenever new data may is available */
-static void stream_read_callback(pa_stream *s, const void*data, size_t length, void *userdata) {
- assert(s && data && length);
+static void stream_read_callback(pa_stream *s, size_t length, void *userdata) {
+ assert(s && length);
+ void *data;
if (stdio_event)
mainloop_api->io_enable(stdio_event, PA_IO_EVENT_OUTPUT);
+ pa_stream_peek(s, &data, &length);
+ assert(data && length);
+
if (buffer) {
fprintf(stderr, "Buffer overrun, dropping incoming data\n");
+ pa_stream_drop(s);
return;
}
@@ -120,6 +125,7 @@ static void stream_read_callback(pa_stream *s, const void*data, size_t length, v
assert(buffer);
memcpy(buffer, data, length);
buffer_index = 0;
+ pa_stream_drop(s);
}
/* This routine is called whenever the stream state changes */