|
|
759f8b1 |
From 09279f76342a1f3b261c04232821c3dc225312c3 Mon Sep 17 00:00:00 2001
|
|
|
759f8b1 |
From: Lennart Poettering <lennart@poettering.net>
|
|
|
759f8b1 |
Date: Wed, 22 Oct 2008 23:55:52 +0200
|
|
|
759f8b1 |
Subject: [PATCH] warn if ALSA wakes us up and there is actually nothing to do
|
|
|
759f8b1 |
|
|
|
759f8b1 |
---
|
|
|
759f8b1 |
src/modules/alsa-util.c | 6 +++++
|
|
|
759f8b1 |
src/modules/module-alsa-sink.c | 41 +++++++++++++++++++++++++++----------
|
|
|
759f8b1 |
src/modules/module-alsa-source.c | 41 +++++++++++++++++++++++++++----------
|
|
|
759f8b1 |
3 files changed, 66 insertions(+), 22 deletions(-)
|
|
|
759f8b1 |
|
|
|
759f8b1 |
diff --git a/src/modules/alsa-util.c b/src/modules/alsa-util.c
|
|
|
759f8b1 |
index 39cea49..20dc400 100644
|
|
|
759f8b1 |
--- a/src/modules/alsa-util.c
|
|
|
759f8b1 |
+++ b/src/modules/alsa-util.c
|
|
|
759f8b1 |
@@ -1051,6 +1051,12 @@ int pa_alsa_recover_from_poll(snd_pcm_t *pcm, int revents) {
|
|
|
759f8b1 |
pa_log_warn("Got POLLNVAL from ALSA");
|
|
|
759f8b1 |
if (revents & POLLHUP)
|
|
|
759f8b1 |
pa_log_warn("Got POLLHUP from ALSA");
|
|
|
759f8b1 |
+ if (revents & POLLPRI)
|
|
|
759f8b1 |
+ pa_log_warn("Got POLLPRI from ALSA");
|
|
|
759f8b1 |
+ if (revents & POLLIN)
|
|
|
759f8b1 |
+ pa_log_warn("Got POLLIN from ALSA");
|
|
|
759f8b1 |
+ if (revents & POLLOUT)
|
|
|
759f8b1 |
+ pa_log_warn("Got POLLOUT from ALSA");
|
|
|
759f8b1 |
|
|
|
759f8b1 |
state = snd_pcm_state(pcm);
|
|
|
759f8b1 |
pa_log_warn("PCM state is %s", snd_pcm_state_name(state));
|
|
|
759f8b1 |
diff --git a/src/modules/module-alsa-sink.c b/src/modules/module-alsa-sink.c
|
|
|
759f8b1 |
index af83103..6dea172 100644
|
|
|
759f8b1 |
--- a/src/modules/module-alsa-sink.c
|
|
|
759f8b1 |
+++ b/src/modules/module-alsa-sink.c
|
|
|
759f8b1 |
@@ -241,7 +241,7 @@ static size_t check_left_to_play(struct userdata *u, snd_pcm_sframes_t n) {
|
|
|
759f8b1 |
return left_to_play;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
-static int mmap_write(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
+static int mmap_write(struct userdata *u, pa_usec_t *sleep_usec, pa_bool_t polled) {
|
|
|
759f8b1 |
int work_done = 0;
|
|
|
759f8b1 |
pa_usec_t max_sleep_usec = 0, process_usec = 0;
|
|
|
759f8b1 |
size_t left_to_play;
|
|
|
759f8b1 |
@@ -279,14 +279,23 @@ static int mmap_write(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
* need to guarantee that clients only have to keep around
|
|
|
759f8b1 |
* a single hw buffer length. */
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (pa_bytes_to_usec(left_to_play, &u->sink->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
+ if (!polled &&
|
|
|
759f8b1 |
+ pa_bytes_to_usec(left_to_play, &u->sink->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (PA_UNLIKELY(n <= u->hwbuf_unused_frames))
|
|
|
759f8b1 |
+ if (PA_UNLIKELY(n <= u->hwbuf_unused_frames)) {
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
+ if (polled)
|
|
|
759f8b1 |
+ pa_log("ALSA woke us up to write new data to the device, but there was actually nothing to write! "
|
|
|
759f8b1 |
+ "Most likely this is an ALSA driver bug. Please report this issue to the PulseAudio developers.");
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
+ }
|
|
|
759f8b1 |
|
|
|
759f8b1 |
n -= u->hwbuf_unused_frames;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
+ polled = FALSE;
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
/* pa_log_debug("Filling up"); */
|
|
|
759f8b1 |
|
|
|
759f8b1 |
for (;;) {
|
|
|
759f8b1 |
@@ -357,7 +366,7 @@ static int mmap_write(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
return work_done;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
-static int unix_write(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
+static int unix_write(struct userdata *u, pa_usec_t *sleep_usec, pa_bool_t polled) {
|
|
|
759f8b1 |
int work_done = 0;
|
|
|
759f8b1 |
pa_usec_t max_sleep_usec = 0, process_usec = 0;
|
|
|
759f8b1 |
size_t left_to_play;
|
|
|
759f8b1 |
@@ -392,14 +401,23 @@ static int unix_write(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
* need to guarantee that clients only have to keep around
|
|
|
759f8b1 |
* a single hw buffer length. */
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (pa_bytes_to_usec(left_to_play, &u->sink->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
+ if (!polled &&
|
|
|
759f8b1 |
+ pa_bytes_to_usec(left_to_play, &u->sink->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (PA_UNLIKELY(n <= u->hwbuf_unused_frames))
|
|
|
759f8b1 |
+ if (PA_UNLIKELY(n <= u->hwbuf_unused_frames)) {
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
+ if (polled)
|
|
|
759f8b1 |
+ pa_log("ALSA woke us up to write new data to the device, but there was actually nothing to write! "
|
|
|
759f8b1 |
+ "Most likely this is an ALSA driver bug. Please report this issue to the PulseAudio developers.");
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
+ }
|
|
|
759f8b1 |
|
|
|
759f8b1 |
n -= u->hwbuf_unused_frames;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
+ polled = FALSE;
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
for (;;) {
|
|
|
759f8b1 |
snd_pcm_sframes_t frames;
|
|
|
759f8b1 |
void *p;
|
|
|
759f8b1 |
@@ -1084,6 +1102,7 @@ finish:
|
|
|
759f8b1 |
|
|
|
759f8b1 |
static void thread_func(void *userdata) {
|
|
|
759f8b1 |
struct userdata *u = userdata;
|
|
|
759f8b1 |
+ unsigned short revents = 0;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
pa_assert(u);
|
|
|
759f8b1 |
|
|
|
759f8b1 |
@@ -1110,9 +1129,9 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (u->use_mmap)
|
|
|
759f8b1 |
- work_done = mmap_write(u, &sleep_usec);
|
|
|
759f8b1 |
+ work_done = mmap_write(u, &sleep_usec, revents & POLLOUT);
|
|
|
759f8b1 |
else
|
|
|
759f8b1 |
- work_done = unix_write(u, &sleep_usec);
|
|
|
759f8b1 |
+ work_done = unix_write(u, &sleep_usec, revents & POLLOUT);
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (work_done < 0)
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
@@ -1180,7 +1199,6 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
/* Tell ALSA about this and process its response */
|
|
|
759f8b1 |
if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) {
|
|
|
759f8b1 |
struct pollfd *pollfd;
|
|
|
759f8b1 |
- unsigned short revents = 0;
|
|
|
759f8b1 |
int err;
|
|
|
759f8b1 |
unsigned n;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
@@ -1191,7 +1209,7 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (revents & (POLLERR|POLLNVAL|POLLHUP|POLLPRI)) {
|
|
|
759f8b1 |
+ if (revents & (POLLIN|POLLERR|POLLNVAL|POLLHUP|POLLPRI)) {
|
|
|
759f8b1 |
if (pa_alsa_recover_from_poll(u->pcm_handle, revents) < 0)
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
@@ -1201,7 +1219,8 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (revents && u->use_tsched)
|
|
|
759f8b1 |
pa_log_debug("Wakeup from ALSA!%s%s", (revents & POLLIN) ? " INPUT" : "", (revents & POLLOUT) ? " OUTPUT" : "");
|
|
|
759f8b1 |
- }
|
|
|
759f8b1 |
+ } else
|
|
|
759f8b1 |
+ revents = 0;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
fail:
|
|
|
759f8b1 |
diff --git a/src/modules/module-alsa-source.c b/src/modules/module-alsa-source.c
|
|
|
759f8b1 |
index dd6ca97..f796ef1 100644
|
|
|
759f8b1 |
--- a/src/modules/module-alsa-source.c
|
|
|
759f8b1 |
+++ b/src/modules/module-alsa-source.c
|
|
|
759f8b1 |
@@ -238,7 +238,7 @@ static size_t check_left_to_record(struct userdata *u, snd_pcm_sframes_t n) {
|
|
|
759f8b1 |
return left_to_record;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
-static int mmap_read(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
+static int mmap_read(struct userdata *u, pa_usec_t *sleep_usec, pa_bool_t polled) {
|
|
|
759f8b1 |
int work_done = 0;
|
|
|
759f8b1 |
pa_usec_t max_sleep_usec = 0, process_usec = 0;
|
|
|
759f8b1 |
size_t left_to_record;
|
|
|
759f8b1 |
@@ -266,11 +266,20 @@ static int mmap_read(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
left_to_record = check_left_to_record(u, n);
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (u->use_tsched)
|
|
|
759f8b1 |
- if (pa_bytes_to_usec(left_to_record, &u->source->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
+ if (!polled &&
|
|
|
759f8b1 |
+ pa_bytes_to_usec(left_to_record, &u->source->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (PA_UNLIKELY(n <= 0))
|
|
|
759f8b1 |
+ if (PA_UNLIKELY(n <= 0)) {
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
+ if (polled)
|
|
|
759f8b1 |
+ pa_log("ALSA woke us up to read new data from the device, but there was actually nothing to read! "
|
|
|
759f8b1 |
+ "Most likely this is an ALSA driver bug. Please report this issue to the PulseAudio device.");
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
+ }
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
+ polled = FALSE;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
for (;;) {
|
|
|
759f8b1 |
int err;
|
|
|
759f8b1 |
@@ -336,7 +345,7 @@ static int mmap_read(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
return work_done;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
-static int unix_read(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
+static int unix_read(struct userdata *u, pa_usec_t *sleep_usec, pa_bool_t polled) {
|
|
|
759f8b1 |
int work_done = 0;
|
|
|
759f8b1 |
pa_usec_t max_sleep_usec = 0, process_usec = 0;
|
|
|
759f8b1 |
size_t left_to_record;
|
|
|
759f8b1 |
@@ -364,11 +373,20 @@ static int unix_read(struct userdata *u, pa_usec_t *sleep_usec) {
|
|
|
759f8b1 |
left_to_record = check_left_to_record(u, n);
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (u->use_tsched)
|
|
|
759f8b1 |
- if (pa_bytes_to_usec(left_to_record, &u->source->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
+ if (!polled &&
|
|
|
759f8b1 |
+ pa_bytes_to_usec(left_to_record, &u->source->sample_spec) > process_usec+max_sleep_usec/2)
|
|
|
759f8b1 |
break;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (PA_UNLIKELY(n <= 0))
|
|
|
759f8b1 |
+ if (PA_UNLIKELY(n <= 0)) {
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
+ if (polled)
|
|
|
759f8b1 |
+ pa_log("ALSA woke us up to read new data from the device, but there was actually nothing to read! "
|
|
|
759f8b1 |
+ "Most likely this is an ALSA driver bug. Please report this issue to the PulseAudio developers.");
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
return work_done;
|
|
|
759f8b1 |
+ }
|
|
|
759f8b1 |
+
|
|
|
759f8b1 |
+ polled = FALSE;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
for (;;) {
|
|
|
759f8b1 |
void *p;
|
|
|
759f8b1 |
@@ -950,6 +968,7 @@ static void source_update_requested_latency_cb(pa_source *s) {
|
|
|
759f8b1 |
|
|
|
759f8b1 |
static void thread_func(void *userdata) {
|
|
|
759f8b1 |
struct userdata *u = userdata;
|
|
|
759f8b1 |
+ unsigned short revents = 0;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
pa_assert(u);
|
|
|
759f8b1 |
|
|
|
759f8b1 |
@@ -972,9 +991,9 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
pa_usec_t sleep_usec = 0;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (u->use_mmap)
|
|
|
759f8b1 |
- work_done = mmap_read(u, &sleep_usec);
|
|
|
759f8b1 |
+ work_done = mmap_read(u, &sleep_usec, revents & POLLIN);
|
|
|
759f8b1 |
else
|
|
|
759f8b1 |
- work_done = unix_read(u, &sleep_usec);
|
|
|
759f8b1 |
+ work_done = unix_read(u, &sleep_usec, revents & POLLIN);
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (work_done < 0)
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
@@ -1016,7 +1035,6 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
/* Tell ALSA about this and process its response */
|
|
|
759f8b1 |
if (PA_SOURCE_IS_OPENED(u->source->thread_info.state)) {
|
|
|
759f8b1 |
struct pollfd *pollfd;
|
|
|
759f8b1 |
- unsigned short revents = 0;
|
|
|
759f8b1 |
int err;
|
|
|
759f8b1 |
unsigned n;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
@@ -1027,7 +1045,7 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
- if (revents & (POLLERR|POLLNVAL|POLLHUP|POLLPRI)) {
|
|
|
759f8b1 |
+ if (revents & (POLLOUT|POLLERR|POLLNVAL|POLLHUP|POLLPRI)) {
|
|
|
759f8b1 |
if (pa_alsa_recover_from_poll(u->pcm_handle, revents) < 0)
|
|
|
759f8b1 |
goto fail;
|
|
|
759f8b1 |
|
|
|
759f8b1 |
@@ -1036,7 +1054,8 @@ static void thread_func(void *userdata) {
|
|
|
759f8b1 |
|
|
|
759f8b1 |
if (revents && u->use_tsched)
|
|
|
759f8b1 |
pa_log_debug("Wakeup from ALSA!%s%s", (revents & POLLIN) ? " INPUT" : "", (revents & POLLOUT) ? " OUTPUT" : "");
|
|
|
759f8b1 |
- }
|
|
|
759f8b1 |
+ } else
|
|
|
759f8b1 |
+ revents = 0;
|
|
|
759f8b1 |
}
|
|
|
759f8b1 |
|
|
|
759f8b1 |
fail:
|
|
|
759f8b1 |
--
|
|
|
759f8b1 |
1.6.0.3
|
|
|
759f8b1 |
|