From ac3fd1a688202375612e905da9ee63bd6cd36a6f Mon Sep 17 00:00:00 2001 From: Andrew Opalach Date: Mon, 8 Sep 2025 18:20:00 -0400 Subject: Sink fixes - Invalidate sink entry IDs on reconnect. - Fix A/V latency calculations. - Fix reconnect_timer behavior and log reconnect attempts. Signed-off-by: Andrew Opalach --- src/liana/vcr.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/liana') diff --git a/src/liana/vcr.c b/src/liana/vcr.c index d2c6b33..d8a1fc9 100644 --- a/src/liana/vcr.c +++ b/src/liana/vcr.c @@ -5,7 +5,7 @@ #include "vcr.h" -#define VCR_BUFFER_BUFFERED MB(2) +#define VCR_BUFFER_BUFFERED MB(4) enum { VCR_EXPAND_UNTOUCHED = 0, @@ -68,7 +68,7 @@ static nn_thread_result NNWT_THREADCALL vcr_track_thread(void *userdata) struct lia_vcr_track *track = (struct lia_vcr_track *)userdata; struct lia_vcr *vcr = track->vcr; const char thread_name[16] = "\0"; // 16 = limit. - al_snprintf((char *)thread_name, sizeof(thread_name), "vcr:%hu_%hu", vcr->node_id, track->stream->index); + al_snprintf((char *)thread_name, sizeof(thread_name), "vcr:%hu_%d", vcr->node_id, track->stream->index); nn_thread_set_name(thread_name); s32 state; @@ -274,9 +274,9 @@ void lia_vcr_push_packet(struct lia_vcr *vcr, struct nn_packet *packet) case LIANA_PACKET_DATA: { u32 size = nn_packet_get_size(packet); update_metrics(vcr, size); - track = get_track_from_index(vcr, nn_packet_read_s32(packet)); - if (!track) { - log_debug("Received data from errored or unknown track."); + s32 index = nn_packet_read_s32(packet); + if (!(track = get_track_from_index(vcr, index))) { + log_debug("Received data from errored or unknown track (index: %d).", index); break; } if (VCR_TRACK_THREADED(track)) { -- cgit v1.2.3-101-g0448