/*
- * Copyright (C) 1997-2007 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 1997-2008 Andre Noll <maan@systemlinux.org>
*
* Licensed under the GPL v2. For licencing details see COPYING.
*/
* - The object storage layer: \ref osl.c,
* - Blob tables: \ref blob.c,
* - The error subssystem: \ref error.h.
+ * - Access control for paraslash senders: \ref acl.c, \ref acl.h.
*
* Low-level data structures:
*
mmd->sender_cmd_data.cmd_num = -1;
return;
err_out:
- PARA_EMERG_LOG("%s", PARA_STRERROR(-ret));
+ PARA_EMERG_LOG("%s", para_strerror(-ret));
exit(EXIT_FAILURE);
}
static void setup_signal_handling(void)
{
- int ret = 0;
-
- signal_pipe = para_signal_init();
+ signal_pipe = para_signal_init(); /* always successful */
PARA_NOTICE_LOG("setting up signal handlers\n");
- ret += para_install_sighandler(SIGINT);
- ret += para_install_sighandler(SIGTERM);
- ret += para_install_sighandler(SIGHUP);
- ret += para_install_sighandler(SIGCHLD);
- signal(SIGPIPE, SIG_IGN);
- signal(SIGUSR1, SIG_IGN);
- if (ret != 4) {
- PARA_EMERG_LOG("%s", "could not install signal handlers\n");
- exit(EXIT_FAILURE);
- }
+ if (para_install_sighandler(SIGINT) < 0)
+ goto err;
+ if (para_install_sighandler(SIGTERM) < 0)
+ goto err;
+ if (para_install_sighandler(SIGHUP) < 0)
+ goto err;
+ if (para_install_sighandler(SIGCHLD) < 0)
+ goto err;
+ if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
+ goto err;
+ if (signal(SIGUSR1, SIG_IGN) == SIG_ERR)
+ goto err;
add_close_on_fork_list(signal_pipe);
+ return;
+err:
+ PARA_EMERG_LOG("could not install signal handlers\n");
+ exit(EXIT_FAILURE);
}
static unsigned init_network(void)
add_close_on_fork_list(fd); /* child doesn't need the listener */
return fd;
err:
- PARA_EMERG_LOG("%s\n", PARA_STRERROR(-ret));
+ PARA_EMERG_LOG("%s\n", para_strerror(-ret));
exit(EXIT_FAILURE);
}
PARA_NOTICE_LOG("initializing audio format handlers\n");
afh_init();
PARA_NOTICE_LOG("initializing virtual streaming system\n");
- vss_init();
mmd->server_pid = getpid();
setup_signal_handling();
PARA_NOTICE_LOG("initializing the audio file selector\n");
init_afs();
+ vss_init();
mmd_lock();
/* init network socket */
PARA_NOTICE_LOG("initializing tcp command socket\n");
timeout = vss_preselect(&rfds, &wfds, &max_fileno);
status_refresh();
for (i = 0; senders[i].name; i++) {
- if (senders[i].status != SENDER_ON)
- continue;
if (!senders[i].pre_select)
continue;
senders[i].pre_select(&max_fileno, &rfds, &wfds);
if (ret < 0)
goto repeat;
for (i = 0; senders[i].name; i++) {
- if (senders[i].status != SENDER_ON)
- continue;
if (!senders[i].post_select)
continue;
senders[i].post_select(&rfds, &wfds);