diff options
author | Wim Taymans <wtaymans@redhat.com> | 2020-09-29 09:56:14 +0200 |
---|---|---|
committer | Wim Taymans <wtaymans@redhat.com> | 2020-09-29 09:57:16 +0200 |
commit | 62ef0145c3bffdca23c6087117d7cf7830b13a28 (patch) | |
tree | feaabc4c7ecede7318813a7c4a4310dcfbe8e538 | |
parent | 81ca70af9bb6c60e2998b4aaf939b82eba257472 (diff) |
pulse: limit get_writable_size()
Try to limit the amount of data we can write. Fixes chrome playback.
-rw-r--r-- | pipewire-pulseaudio/src/stream.c | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/pipewire-pulseaudio/src/stream.c b/pipewire-pulseaudio/src/stream.c index c30cd00e..0a398c66 100644 --- a/pipewire-pulseaudio/src/stream.c +++ b/pipewire-pulseaudio/src/stream.c @@ -493,8 +493,7 @@ static void stream_process(void *data) s, queued, target, wanted, required); if (s->write_callback && s->state == PA_STREAM_READY && - queued < wanted && - wanted >= required) + queued < wanted && wanted >= required) s->write_callback(s, wanted, s->write_userdata); } else { @@ -1283,7 +1282,7 @@ SPA_EXPORT size_t pa_stream_writable_size(PA_CONST pa_stream *s) { const pa_timing_info *i; - uint64_t now, then, queued, writable, elapsed, required; + uint64_t now, then, queued, target, wanted, elapsed, required; struct timespec ts; spa_assert(s); @@ -1306,16 +1305,18 @@ size_t pa_stream_writable_size(PA_CONST pa_stream *s) } queued = queued_size(s, elapsed); - writable = writable_size(s, queued); + target = target_queue(s); + wanted = wanted_size(s, queued, target); required = required_size(s); - pw_log_debug("stream %p: writable:%"PRIu64" queued:%"PRIu64" required:%"PRIu64, s, - writable, queued, required); + pw_log_debug("stream %p: queued:%"PRIu64" target:%"PRIu64 + " wanted:%"PRIu64" required:%"PRIu64, s, + queued, target, wanted, required); - if (writable < required) - writable = 0; + if (queued >= wanted || wanted < required) + wanted = 0; - return writable; + return wanted; } SPA_EXPORT |