From: Andre Date: Sat, 1 Apr 2006 22:21:46 +0000 (+0200) Subject: Minor audiod mainloop cleanup X-Git-Tag: v0.2.12~118 X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=commitdiff_plain;h=ea8b1e10bc7b8b1cc01e0908a2e404d1b5409604 Minor audiod mainloop cleanup --- diff --git a/audiod.c b/audiod.c index 56d022fa..695a6cfd 100644 --- a/audiod.c +++ b/audiod.c @@ -1520,7 +1520,7 @@ static int open_stat_pipe(void) return ret; } -static int pre_select(fd_set *rfds, fd_set *wfds, struct timeval *tv) +static int audiod_pre_select(fd_set *rfds, fd_set *wfds, struct timeval *tv) { int i, ret, max = -1; @@ -1571,15 +1571,21 @@ static void __noreturn audiod_mainloop(void) char status_buf[STRINGSIZE] = ""; struct timeval tv; repeat: - FD_ZERO(&rfds); FD_ZERO(&wfds); - max_fileno = 0; + FD_ZERO(&rfds); + /* always check signal pipe and the local socket */ + FD_SET(signal_pipe, &rfds); + max_fileno = signal_pipe; + FD_SET(audiod_socket, &rfds); + max_fileno = MAX(max_fileno, audiod_socket); + if (audiod_status != AUDIOD_ON) kill_all_decoders(); else if (playing) start_current_receiver(); - max_fileno = set_stream_fds(&wfds); - /* stat pipe (read) */ + + max_fileno = MAX(max_fileno, set_stream_fds(&wfds)); + /* status pipe */ if (stat_pipe >= 0 && audiod_status == AUDIOD_OFF) close_stat_pipe(); if (stat_pipe < 0 && audiod_status != AUDIOD_OFF) { @@ -1591,18 +1597,12 @@ repeat: FD_SET(stat_pipe, &rfds); max_fileno = MAX(max_fileno, stat_pipe); } - /* always check signal pipe */ - FD_SET(signal_pipe, &rfds); - max_fileno = MAX(max_fileno, signal_pipe); /* local socket */ - if (audiod_socket < 0) - audiod_get_socket(); /* doesn't return on errors */ - FD_SET(audiod_socket, &rfds); - max_fileno = MAX(max_fileno, audiod_socket); tv.tv_sec = 0; tv.tv_usec = 200 * 1000; - ret = pre_select(&rfds, &wfds, &tv); + ret = audiod_pre_select(&rfds, &wfds, &tv); max_fileno = MAX(max_fileno, ret); + ret = select(max_fileno + 1, &rfds, &wfds, NULL, &tv); if (ret < 0 && errno != EINTR) PARA_ERROR_LOG("select returned %d (%s)\n", ret, @@ -1690,5 +1690,6 @@ int __noreturn main(int argc, char *argv[]) setup_signal_handling(); if (conf.daemon_given) daemon_init(); + audiod_get_socket(); /* doesn't return on errors */ audiod_mainloop(); }