mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-03 09:01:54 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

module-jack: improve xrun reporting

Browse source
This commit is contained in:
Wim Taymans 2023-04-27 18:10:41 +02:00
parent 381aa90b54
commit 9e7921b37d
1 changed files with 19 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

20
src/modules/module-jack-tunnel.c
View file

@ -158,9 +158,14 @@ struct impl {
jack_nframes_t frames; jack_nframes_t frames;
uint32_t pw_xrun;
uint32_t jack_xrun;
unsigned int do_disconnect:1; unsigned int do_disconnect:1;
unsigned int source_running:1; unsigned int source_running:1;
unsigned int sink_running:1; unsigned int sink_running:1;
unsigned int done:1;
unsigned int new_xrun:1;
}; };
static void source_stream_destroy(void *d) static void source_stream_destroy(void *d)
@ -225,6 +230,7 @@ static void sink_stream_process(void *d)
pw_stream_queue_buffer(impl->sink, buf); pw_stream_queue_buffer(impl->sink, buf);
done: done:
pw_log_trace_fp("done %u", impl->frames); pw_log_trace_fp("done %u", impl->frames);
impl->done = true;
sem_post(&impl->sem); sem_post(&impl->sem);
} }
@ -458,9 +464,18 @@ static int jack_process(jack_nframes_t nframes, void *arg)
while (sem_trywait(&impl->sem) == 0); while (sem_trywait(&impl->sem) == 0);
impl->done = false;
pw_stream_trigger_process(impl->sink); pw_stream_trigger_process(impl->sink);
sem_wait(&impl->sem); sem_wait(&impl->sem);
if (!impl->done) {
impl->pw_xrun++;
impl->new_xrun = true;
}
if (impl->new_xrun) {
pw_log_warn("Xrun JACK:%u PipeWire:%u", impl->jack_xrun, impl->pw_xrun);
impl->new_xrun = false;
}
} }
pw_log_trace_fp("done %u", impl->frames); pw_log_trace_fp("done %u", impl->frames);
@ -470,7 +485,10 @@ static int jack_process(jack_nframes_t nframes, void *arg)
static int jack_xrun(void *arg) static int jack_xrun(void *arg)
{ {
struct impl *impl = arg; struct impl *impl = arg;
pw_log_warn("xrun"); if (impl->done) {
impl->jack_xrun++;
impl->new_xrun = true;
}
sem_post(&impl->sem); sem_post(&impl->sem);
return 0; return 0;
} }