mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-03 09:01:54 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse: always notify of available data

Browse source 
If we have some data available for capture, always report this
to get the lowest latency possible.
This commit is contained in:
Wim Taymans 2020-09-11 15:34:30 +02:00
parent 8f75056689
commit 38f8c9c6c8
1 changed files with 3 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

13
pipewire-pulseaudio/src/stream.c
View file

@ -450,13 +450,9 @@ static void stream_process(void *data)
s->write_callback(s, writable, s->write_userdata); s->write_callback(s, writable, s->write_userdata);
} }
else { else {
uint64_t required;
pull_input(s); pull_input(s);
required = SPA_MIN(s->maxblock, s->buffer_attr.fragsize); if (s->read_callback && s->ready_bytes > 0 && s->state == PA_STREAM_READY)
if (s->read_callback && s->ready_bytes > required && s->state == PA_STREAM_READY)
s->read_callback(s, s->ready_bytes, s->read_userdata); s->read_callback(s, s->ready_bytes, s->read_userdata);
} }
} }
@ -1272,7 +1268,7 @@ size_t pa_stream_writable_size(PA_CONST pa_stream *s)
SPA_EXPORT SPA_EXPORT
size_t pa_stream_readable_size(PA_CONST pa_stream *s) size_t pa_stream_readable_size(PA_CONST pa_stream *s)
{ {
uint64_t readable, required; uint64_t readable;
spa_assert(s); spa_assert(s);
spa_assert(s->refcount >= 1); spa_assert(s->refcount >= 1);
@ -1283,10 +1279,7 @@ size_t pa_stream_readable_size(PA_CONST pa_stream *s)
PA_ERR_BADSTATE, (size_t) -1); PA_ERR_BADSTATE, (size_t) -1);
readable = s->ready_bytes; readable = s->ready_bytes;
required = SPA_MIN(s->maxblock, s->buffer_attr.fragsize); pw_log_trace("stream %p: readable:%"PRIu64" fragsize:%u", s, readable, s->buffer_attr.fragsize);
pw_log_trace("stream %p: %zd %zd", s, readable, required);
if (readable < required)
readable = 0;
return readable; return readable;
} }