X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=alsa_write.c;h=34a71f9bd34b503fafdbb192d5479c1815846b49;hp=047eeaa348f9017431fc42e5c121ba08f331d3b0;hb=53306876b029205c4dfcce0c39551b115dd18130;hpb=4434989abcd113f73ca5217c3a9ecc74ce2eb1db

diff --git a/alsa_write.c b/alsa_write.c
index 047eeaa3..34a71f9b 100644
--- a/alsa_write.c
+++ b/alsa_write.c
@@ -150,8 +150,14 @@ static void alsa_write_pre_select(struct sched *s, struct task *t)
 
 	if (ret == 0)
 		return;
-	if (ret < 0 || !pad)
-		return sched_min_delay(s);
+	if (!pad) {
+		sched_min_delay(s);
+		return;
+	}
+	if (ret < 0) {
+		sched_request_barrier_or_min_delay(&pad->drain_barrier, s);
+		return;
+	}
 	/*
 	 * Data is available to be written to the alsa handle.  Compute number
 	 * of milliseconds until next buffer underrun would occur.
@@ -251,7 +257,9 @@ again:
 	}
 	frames = bytes / pad->bytes_per_frame;
 	frames = snd_pcm_writei(pad->handle, data, frames);
-	if (frames >= 0) {
+	if (frames == 0 || frames == -EAGAIN)
+		return;
+	if (frames > 0) {
 		btr_consume(btrn, frames * pad->bytes_per_frame);
 		goto again;
 	}
@@ -260,8 +268,6 @@ again:
 		snd_pcm_prepare(pad->handle);
 		return;
 	}
-	if (frames == -EAGAIN)
-		return;
 	PARA_WARNING_LOG("%s\n", snd_strerror(-frames));
 	ret = -E_ALSA_WRITE;
 err: