diff options
| author |   Andrew Opalach <andrew@akon.city>
| 2025-09-08 18:20:00 -0400 |
|---|---|---|
| committer | Andrew Opalach <andrew@akon.city>
| 2025-09-08 18:20:00 -0400 |
| commit | ac3fd1a688202375612e905da9ee63bd6cd36a6f (patch) | |
| tree | 765f200b7a18a7483698751ea5227647656a4e56 /src/liana | |
| parent | 38c371d1fa82101d59eb202d2f4aa1b2b99c0e42 (diff) | |
| download | camu-ac3fd1a688202375612e905da9ee63bd6cd36a6f.tar.gz camu-ac3fd1a688202375612e905da9ee63bd6cd36a6f.tar.bz2 camu-ac3fd1a688202375612e905da9ee63bd6cd36a6f.zip | |
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 <andrew@akon.city>
Diffstat (limited to 'src/liana')
| -rw-r--r-- | src/liana/vcr.c | 10 |
1 files changed, 5 insertions, 5 deletions
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)) { |