mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2026-03-26 07:58:03 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

sendspin: cleanup receive sync and logging

Browse source 
don't check the same thing twice.

Make sure values are set before we log them.
This commit is contained in:
Wim Taymans 2026-03-01 12:49:24 +01:00
parent 06f336a581
commit d206b06c70
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/modules/module-sendspin-recv.c
View file

@ -267,7 +267,7 @@ static void on_capture_stream_process(void *d)
avail = spa_ringbuffer_get_read_index(&client->ring, &index); avail = spa_ringbuffer_get_read_index(&client->ring, &index);
if (client->timeout_count > 4 && client->timeout_count > 4) { if (client->timeout_count > 4) {
pw_stream_get_time_n(client->stream, &ts, sizeof(ts)); pw_stream_get_time_n(client->stream, &ts, sizeof(ts));
/* index to server time */ /* index to server time */
@ -298,6 +298,12 @@ static void on_capture_stream_process(void *d)
avail = 0; avail = 0;
} }
} }
corr = spa_dll_update(&client->dll, SPA_CLAMPD(err, -1000, 1000));
pw_stream_set_rate(client->stream, 1.0 / corr);
pw_log_trace("%u %f %f %f %f", index, current_time, target, err, corr);
} else { } else {
avail = 0; avail = 0;
} }
@ -313,12 +319,6 @@ static void on_capture_stream_process(void *d)
if (avail > 0) { if (avail > 0) {
n_bytes = SPA_MIN(n_bytes, (uint32_t)avail); n_bytes = SPA_MIN(n_bytes, (uint32_t)avail);
corr = spa_dll_update(&client->dll, SPA_CLAMPD(err, -1000, 1000));
pw_log_trace("%u %f %f %f %f", index, current_time, target, err, corr);
pw_stream_set_rate(client->stream, 1.0 / corr);
spa_ringbuffer_read_data(&client->ring, spa_ringbuffer_read_data(&client->ring,
client->buffer, client->buffer_size, client->buffer, client->buffer_size,
index % client->buffer_size, index % client->buffer_size,