asgardius/alsa-utils
1
0
Fork 0
mirror of https://github.com/alsa-project/alsa-utils synced 2024-11-10 03:35:42 +01:00
Code Issues Projects Releases Packages Wiki Activity

Added code for suspend code

Browse source
This commit is contained in:
Jaroslav Kysela 2001-10-04 15:04:44 +00:00
parent c72696ff39
commit bfa0a061ed
1 changed files with 31 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
aplay/aplay.c
View file

@ -837,9 +837,8 @@ do { \
} while (0) } while (0)
#endif #endif
/* playback write error hander */ /* I/O error handler */
static void xrun(void)
void xrun(void)
{ {
snd_pcm_status_t *status; snd_pcm_status_t *status;
int res; int res;
@ -869,6 +868,27 @@ void xrun(void)
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
/* I/O suspend handler */
static void suspend(void)
{
int res;
if (!quiet_mode)
fprintf(stderr, "Suspended... Trying resume..."); fflush(stderr);
while ((res = snd_pcm_resume(handle)) == -EBUSY)
sleep(1); /* wait until suspend flag is not released */
if (res < 0) {
if (!quiet_mode)
fprintf(stderr, " Failed... Restarting stream..."); fflush(stderr);
if ((res = snd_pcm_prepare(handle)) < 0) {
error("suspend: prepare error: %s", snd_strerror(res));
exit(EXIT_FAILURE);
}
}
if (!quiet_mode)
fprintf(stderr, "\n");
}
/* peak handler */ /* peak handler */
static void compute_max_peak(u_char *data, size_t count) static void compute_max_peak(u_char *data, size_t count)
{ {
@ -912,6 +932,8 @@ static ssize_t pcm_write(u_char *data, size_t count)
snd_pcm_wait(handle, 1000); snd_pcm_wait(handle, 1000);
} else if (r == -EPIPE) { } else if (r == -EPIPE) {
xrun(); xrun();
} else if (r == -ESTRPIPE) {
suspend();
} else if (r < 0) { } else if (r < 0) {
error("write error: %s", snd_strerror(r)); error("write error: %s", snd_strerror(r));
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
@ -952,6 +974,8 @@ static ssize_t pcm_writev(u_char **data, unsigned int channels, size_t count)
snd_pcm_wait(handle, 1000); snd_pcm_wait(handle, 1000);
} else if (r == -EPIPE) { } else if (r == -EPIPE) {
xrun(); xrun();
} else if (r == -ESTRPIPE) {
suspend();
} else if (r < 0) { } else if (r < 0) {
error("writev error: %s", snd_strerror(r)); error("writev error: %s", snd_strerror(r));
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
@ -989,6 +1013,8 @@ static ssize_t pcm_read(u_char *data, size_t rcount)
snd_pcm_wait(handle, 1000); snd_pcm_wait(handle, 1000);
} else if (r == -EPIPE) { } else if (r == -EPIPE) {
xrun(); xrun();
} else if (r == -ESTRPIPE) {
suspend();
} else if (r < 0) { } else if (r < 0) {
error("read error: %s", snd_strerror(r)); error("read error: %s", snd_strerror(r));
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
@ -1026,6 +1052,8 @@ static ssize_t pcm_readv(u_char **data, unsigned int channels, size_t rcount)
snd_pcm_wait(handle, 1000); snd_pcm_wait(handle, 1000);
} else if (r == -EPIPE) { } else if (r == -EPIPE) {
xrun(); xrun();
} else if (r == -ESTRPIPE) {
suspend();
} else if (r < 0) { } else if (r < 0) {
error("readv error: %s", snd_strerror(r)); error("readv error: %s", snd_strerror(r));
exit(EXIT_FAILURE); exit(EXIT_FAILURE);