Skip to content

Commit 7408c05

Browse files
authored
Merge pull request karlstav#311 from Xyene/loop-bounds
Use loop exit condition in place of always true
2 parents 9ab9358 + 889860d commit 7408c05

File tree

4 files changed

+11
-26
lines changed

4 files changed

+11
-26
lines changed

input/alsa.c

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ void* input_alsa(void* data) {
116116
//const int size = frames * (audio->format / 8) * CHANNELS_COUNT;
117117
signed char* buffer = malloc(period_size);
118118

119-
while (1) {
119+
while (!audio->terminate) {
120120
switch (audio->format) {
121121
case 16:
122122
err = snd_pcm_readi(handle, buf, frames);
@@ -153,12 +153,9 @@ void* input_alsa(void* data) {
153153

154154

155155
write_to_fftw_input_buffers(buf, frames, data);
156-
157-
158-
if (audio->terminate == 1) {
159-
free(buffer);
160-
snd_pcm_close(handle);
161-
return NULL;
162-
}
163156
}
157+
158+
free(buffer);
159+
snd_pcm_close(handle);
160+
return NULL;
164161
}

input/fifo.c

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ void* input_fifo(void* data)
9191

9292
fd = open_fifo(audio->source);
9393

94-
while (1) {
94+
while (!audio->terminate) {
9595

9696
bytes = read(fd, buf, sizeof(buf));
9797

@@ -114,13 +114,8 @@ void* input_fifo(void* data)
114114

115115
write_to_fftw_input_buffers(buf, frames, audio);
116116
}
117-
118-
if (audio->terminate == 1) {
119-
close(fd);
120-
break;
121-
}
122-
123117
}
124118

119+
close(fd);
125120
return 0;
126121
}

input/pulse.c

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ void* input_pulse(void* data) {
146146
}
147147

148148

149-
while (1) {
149+
while (!audio->terminate) {
150150
if (pa_simple_read(s, buf, sizeof(buf), &error) < 0) {
151151
sprintf(audio->error_message, __FILE__": pa_simple_read() failed: %s\n",
152152
pa_strerror(error));
@@ -157,12 +157,8 @@ void* input_pulse(void* data) {
157157
//sorting out channels
158158

159159
write_to_fftw_input_buffers(buf, frames, data);
160+
}
160161

161-
if (audio->terminate == 1) {
162-
pa_simple_free(s);
163-
break;
164-
}
165-
}
166-
162+
pa_simple_free(s);
167163
return 0;
168164
}

input/shmem.c

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ void* input_shmem(void* data)
5959
// printf("bufs: %u / run: %u / rate: %u\n",mmap_area->buf_size, mmap_area->running, mmap_area->rate);
6060
audio->rate = mmap_area->rate;
6161

62-
while (1) {
62+
while (!audio->terminate) {
6363
write_to_fftw_input_buffers(mmap_area->buffer, BUFSIZE, audio);
6464
/*
6565
for (i = VB_OFFSET; i < BUFSIZE+VB_OFFSET; i += 2) {
@@ -73,9 +73,6 @@ void* input_shmem(void* data)
7373
if (n == audio->FFTbufferSize - 1) n = 0;
7474
}
7575
*/
76-
if (audio->terminate == 1) {
77-
break;
78-
}
7976
}
8077

8178
// cleanup

0 commit comments

Comments
 (0)