mirrors/alsa-lib
1
0
Fork 0
mirror of https://github.com/alsa-project/alsa-lib.git synced 2025-11-06 13:29:59 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pcm: share plugin: return error if socket read or write call fails

Browse source 
Fixes: https://github.com/alsa-project/alsa-lib/pull/242
Signed-off-by: Tomohiro IKEDA <rilakkuma.san.xjapan@gmail.com>
Signed-off-by: Jaroslav Kysela <perex@perex.cz>
This commit is contained in:
Tomohiro IKEDA 2022-06-19 07:05:17 +09:00 • committed by Jaroslav Kysela
parent 917f412484
commit b97047b450
1 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/pcm/pcm_share.c
View file

@ -205,6 +205,7 @@ static snd_pcm_uframes_t _snd_pcm_share_missing(snd_pcm_t *pcm)
snd_pcm_sframes_t hw_avail;
snd_pcm_uframes_t missing = INT_MAX;
snd_pcm_sframes_t ready_missing;
ssize_t s;
// printf("state=%s hw_ptr=%ld appl_ptr=%ld slave appl_ptr=%ld safety=%ld silence=%ld\n", snd_pcm_state_name(share->state), slave->hw_ptr, share->appl_ptr, *slave->pcm->appl_ptr, slave->safety_threshold, slave->silence_frames);
switch (share->state) {
case SND_PCM_STATE_RUNNING:
@ -290,15 +291,17 @@ static snd_pcm_uframes_t _snd_pcm_share_missing(snd_pcm_t *pcm)
char buf[1];
if (pcm->stream == SND_PCM_STREAM_PLAYBACK) {
if (ready)
read(share->slave_socket, buf, 1);
s = read(share->slave_socket, buf, 1);
else
write(share->client_socket, buf, 1);
s = write(share->client_socket, buf, 1);
} else {
if (ready)
write(share->slave_socket, buf, 1);
s = write(share->slave_socket, buf, 1);
else
read(share->client_socket, buf, 1);
s = read(share->client_socket, buf, 1);
}
if (s == -1)
return INT_MAX;
share->ready = ready;
}
if (!running)