From 20003fd25404ee5fc4cd068fbc4fae1ad6f6ae99 Mon Sep 17 00:00:00 2001 From: Andrew Opalach Date: Fri, 27 Dec 2024 15:24:00 -0500 Subject: Finish server reuse connection, move loop to list Signed-off-by: Andrew Opalach --- src/buffer/audio.c | 4 ++-- src/buffer/video.c | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'src/buffer') diff --git a/src/buffer/audio.c b/src/buffer/audio.c index c0556e2..7bb2c4c 100644 --- a/src/buffer/audio.c +++ b/src/buffer/audio.c @@ -343,11 +343,11 @@ size_t camu_audio_buffer_read(struct camu_audio_buffer *buf, u8 *data, size_t re // Only signal EOF if what, if any, data from the peak buffer // still isn't enough for this request. if (have < req) { + signal = have; + al_log_debug("audio_buffer", "Flushed (signal: %zu).", signal); buf->callback(buf->userdata, CAMU_BUFFER_EOF); flow = SIGNALED; al_atomic_store(u8)(&buf->flow, SIGNALED, AL_ATOMIC_RELEASE); - signal = have; - al_log_debug("audio_buffer", "Flushed (signal: %zu).", signal); } } else { // Silence remainder of the request. diff --git a/src/buffer/video.c b/src/buffer/video.c index 245f3d2..fefb307 100644 --- a/src/buffer/video.c +++ b/src/buffer/video.c @@ -242,9 +242,9 @@ bool camu_video_buffer_read(struct camu_video_buffer *buf, void *out) return false; } if (flow == FLUSHED && (ret == CAMU_QUEUE_EOF || (buf->single_frame && ret == CAMU_QUEUE_OK))) { + al_log_debug("video_buffer", "Flushed."); buf->callback(buf->userdata, CAMU_BUFFER_EOF); al_atomic_store(u8)(&buf->flow, SIGNALED, AL_ATOMIC_RELEASE); - al_log_debug("video_buffer", "Flushed."); } else if (flow == FLOWING) { f64 have = buf->queue->count(buf->queue) * buf->avg_frame_duration; if (have <= BUFFER_MARK_LOW) { -- cgit v1.2.3-101-g0448