asgardius/alsa-utils
1
0
Fork 0
mirror of https://github.com/alsa-project/alsa-utils synced 2024-11-09 17:55:43 +01:00
Code Issues Projects Releases Packages Wiki Activity

aplay: avoid any further PCM writing if in abort

Browse source 
Terminating stream with CTRL-C will set in_aborting flag which is used to leave any
write/read loop on the ALSA device.
After ending the read/write loop aplay tries to drain the stream which is not required and can also lead to malfunctions:
-If user interrupts a blocked/non responsive PCM (e.g. usb uac2 gadget which does not consume data
due to stream stopped by host) it will successfully terminate the write loop but will hang again in drain call.
This would require to hit CTRL-C again to unblock which should be avoided.
Aplay currently anyhow allows signal handler to get invoked only once.

Signed-off-by: Andreas Pape <apape@de.adit-jv.com>
Signed-off-by: Jaroslav Kysela <perex@perex.cz>
This commit is contained in:
Andreas Pape 2021-03-19 11:57:13 +01:00 committed by Jaroslav Kysela
parent 00be486131
commit c9e9a79c6c
1 changed files with 13 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
aplay/aplay.c
View file

@ -2570,7 +2570,9 @@ static void voc_play(int fd, int ofs, char *name)
} }
} /* while(1) */ } /* while(1) */
__end: __end:
voc_pcm_flush(); if (!in_aborting) {
voc_pcm_flush();
}
free(buf); free(buf);
} }
/* that was a big one, perhaps somebody split it :-) */ /* that was a big one, perhaps somebody split it :-) */
@ -2885,9 +2887,11 @@ static void playback_go(int fd, size_t loaded, off64_t count, int rtype, char *n
written += r; written += r;
l = 0; l = 0;
} }
snd_pcm_nonblock(handle, 0); if (!in_aborting) {
snd_pcm_drain(handle); snd_pcm_nonblock(handle, 0);
snd_pcm_nonblock(handle, nonblock); snd_pcm_drain(handle);
snd_pcm_nonblock(handle, nonblock);
}
} }
static int read_header(int *loaded, int header_size) static int read_header(int *loaded, int header_size)
@ -3363,9 +3367,11 @@ static void playbackv_go(int* fds, unsigned int channels, size_t loaded, off64_t
r = r * bits_per_frame / 8; r = r * bits_per_frame / 8;
count -= r; count -= r;
} }
snd_pcm_nonblock(handle, 0); if (!in_aborting) {
snd_pcm_drain(handle); snd_pcm_nonblock(handle, 0);
snd_pcm_nonblock(handle, nonblock); snd_pcm_drain(handle);
snd_pcm_nonblock(handle, nonblock);
}
} }
static void capturev_go(int* fds, unsigned int channels, off64_t count, int rtype, char **names) static void capturev_go(int* fds, unsigned int channels, off64_t count, int rtype, char **names)