static pthread_t consolethread = AST_PTHREADT_NULL;
static int canary_pid = 0;
static char canary_filename[128];
+static int canary_pipe = -1;
static char randompool[256];
if (isroot) {
ast_set_priority(ast_opt_high_priority);
if (ast_opt_high_priority) {
+ int cpipe[2];
+
+ /* PIPE signal ensures that astcanary dies when Asterisk dies */
+ pipe(cpipe);
+ canary_pipe = cpipe[0];
+
snprintf(canary_filename, sizeof(canary_filename), "%s/alt.asterisk.canary.tweet.tweet.tweet", ast_config_AST_RUN_DIR);
+ /* Don't let the canary child kill Asterisk, if it dies immediately */
+ signal(SIGPIPE, SIG_IGN);
+
canary_pid = fork();
if (canary_pid == 0) {
char canary_binary[128], *lastslash;
/* Reset signal handler */
signal(SIGCHLD, SIG_DFL);
+ signal(SIGPIPE, SIG_DFL);
- for (fd = 0; fd < 100; fd++)
+ dup2(cpipe[1], 100);
+ close(cpipe[1]);
+
+ for (fd = 0; fd < 100; fd++) {
close(fd);
+ }
execlp("astcanary", "astcanary", canary_filename, (char *)NULL);
_exit(1);
} else if (canary_pid > 0) {
pthread_t dont_care;
+ close(cpipe[1]);
ast_pthread_create_detached(&dont_care, NULL, canary_thread, NULL);
}
int fd;
/* Run at normal priority */
setpriority(PRIO_PROCESS, 0, 0);
- for (; getppid() != 1;) {
+ for (;;) {
/* Update the modification times (checked from Asterisk) */
if (utime(argv[1], NULL)) {
/* Recreate the file if it doesn't exist */
sleep(5);
}
- /* Reached if asterisk (our parent process) dies - its chldren are inherited by the init process (pid is 1). */
+ /* Never reached */
return 0;
}