etc/netatalk/netatalk.c

   1 /*
   2  * Copyright (c) 1990,1993 Regents of The University of Michigan.
   3  * All Rights Reserved.  See COPYRIGHT.
   4  */
   5
   6 #ifdef HAVE_CONFIG_H
   7 #include "config.h"
   8 #endif /* HAVE_CONFIG_H */
   9
  10 #include <stdio.h>
  11 #include <stdlib.h>
  12 #include <string.h>
  13 #include <signal.h>
  14 #include <sys/param.h>
  15 #include <sys/uio.h>
  16 #include <sys/time.h>
  17 #include <sys/socket.h>
  18 #include <sys/poll.h>
  19 #include <errno.h>
  20 #include <sys/wait.h>
  21 #include <sys/resource.h>
  22
  23 #include <atalk/logger.h>
  24 #include <atalk/adouble.h>
  25 #include <atalk/compat.h>
  26 #include <atalk/dsi.h>
  27 #include <atalk/afp.h>
  28 #include <atalk/paths.h>
  29 #include <atalk/util.h>
  30 #include <atalk/server_child.h>
  31 #include <atalk/server_ipc.h>
  32 #include <atalk/errchk.h>
  33 #include <atalk/globals.h>
  34 #include <atalk/netatalk_conf.h>
  35
  36 #include <event2/event.h>
  37
  38 /* forward declaration */
  39 static pid_t run_process(const char *path, ...);
  40
  41 /* static variables */
  42 static AFPObj obj;
  43 static sig_atomic_t got_chldsig;
  44 static pid_t afpd_pid = -1,  cnid_metad_pid = -1;
  45 static uint afpd_restarts, cnid_metad_restarts;
  46 static struct event_base *base;
  47
  48 /* event functions */
  49 static void libevent_logmsg_cb(int severity, const char *msg)
  50 {
  51     switch (severity) {
  52     case _EVENT_LOG_DEBUG:
  53         LOG(log_debug, logtype_default, "libevent: %s", msg);
  54         break;
  55     case _EVENT_LOG_MSG:
  56         LOG(log_info, logtype_default, "libevent: %s", msg);
  57         break;
  58     case _EVENT_LOG_WARN:
  59         LOG(log_warning, logtype_default, "libevent: %s", msg);
  60         break;
  61     case _EVENT_LOG_ERR:
  62         LOG(log_error, logtype_default, "libevent: %s", msg);
  63         break;
  64     default:
  65         LOG(log_error, logtype_default, "libevent: %s", msg);
  66         break; /* never reached */
  67     }
  68 }
  69
  70 static void sigterm_cb(evutil_socket_t fd, short what, void *arg)
  71 {
  72     LOG(log_note, logtype_afpd, "Exiting on SIGTERM");
  73     if (afpd_pid != -1)
  74         kill(afpd_pid, SIGTERM);
  75     if (cnid_metad_pid != -1)
  76         kill(cnid_metad_pid, SIGTERM);
  77     server_unlock(_PATH_NETATALK_LOCK);
  78     event_base_loopbreak(base);
  79 }
  80
  81 static void sigquit_cb(evutil_socket_t fd, short what, void *arg)
  82 {
  83     LOG(log_note, logtype_afpd, "Exiting on SIGQUIT");
  84     if (afpd_pid != -1)
  85         kill(afpd_pid, SIGTERM);
  86     if (cnid_metad_pid != -1)
  87         kill(cnid_metad_pid, SIGTERM);
  88     server_unlock(_PATH_NETATALK_LOCK);
  89     event_base_loopbreak(base);
  90 }
  91
  92 static void sigchld_cb(evutil_socket_t fd, short what, void *arg)
  93 {
  94     int status, i;
  95     pid_t pid;
  96
  97     LOG(log_debug, logtype_afpd, "Got SIGCHLD event");
  98
  99     while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
 100         if (WIFEXITED(status)) {
 101             if (WEXITSTATUS(status))
 102                 LOG(log_info, logtype_afpd, "child[%d]: exited %d", pid, WEXITSTATUS(status));
 103             else
 104                 LOG(log_info, logtype_afpd, "child[%d]: done", pid);
 105         } else {
 106             if (WIFSIGNALED(status))
 107                 LOG(log_info, logtype_afpd, "child[%d]: killed by signal %d", pid, WTERMSIG(status));
 108             else
 109                 LOG(log_info, logtype_afpd, "child[%d]: died", pid);
 110         }
 111
 112         if (pid == afpd_pid) {
 113             sleep(1);
 114             afpd_restarts++;
 115             LOG(log_note, logtype_afpd, "Restarting 'afpd' (restarts: %u)", afpd_restarts);
 116             if ((afpd_pid = run_process(_PATH_AFPD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 117                 LOG(log_error, logtype_afpd, "Error starting 'afpd'");
 118             }
 119         } else if (pid = cnid_metad_pid) {
 120             sleep(1);
 121             cnid_metad_restarts++;
 122             LOG(log_note, logtype_afpd, "Restarting 'cnid_metad' (restarts: %u)", cnid_metad_restarts);
 123             if ((cnid_metad_pid = run_process(_PATH_CNID_METAD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 124                 LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 125             }
 126         } else {
 127             LOG(log_error, logtype_afpd, "Bad pid: %d", pid);
 128         }
 129     }
 130 }
 131
 132 /* other functions */
 133
 134 static void netatalk_exit(int ret)
 135 {
 136     if (afpd_pid != -1)
 137         kill(afpd_pid, SIGTERM);
 138     if (cnid_metad_pid != -1)
 139         kill(cnid_metad_pid, SIGTERM);
 140     server_unlock(_PATH_NETATALK_LOCK);
 141     exit(ret);
 142 }
 143
 144 static pid_t run_process(const char *path, ...)
 145 {
 146     int ret, i = 0;
 147     char *myargv[10];
 148     va_list args;
 149     pid_t pid;
 150
 151     if ((pid = fork()) < 0) {
 152         LOG(log_error, logtype_cnid, "error in fork: %s", strerror(errno));
 153         return -1;
 154     }
 155
 156     if (pid == 0) {
 157         myargv[i++] = (char *)path;
 158         va_start(args, path);
 159         while ((myargv[i++] = va_arg(args, char *)) != NULL)
 160             ;
 161         va_end(args);
 162
 163         ret = execv(path, myargv);
 164
 165         /* Yikes! We're still here, so exec failed... */
 166         LOG(log_error, logtype_cnid, "Fatal error in exec: %s", strerror(errno));
 167         exit(1);
 168     }
 169     return pid;
 170 }
 171
 172 static void usage(void)
 173 {
 174     printf("usage: netatalk [-F configfile] \n");
 175 }
 176
 177 int main(int argc, char **argv)
 178 {
 179     const char *configfile = NULL;
 180     int c, ret, debug = 0;
 181     sigset_t blocksigs;
 182
 183     /* Log SIGBUS/SIGSEGV SBT */
 184     fault_setup(NULL);
 185
 186     while ((c = getopt(argc, argv, ":dF:")) != -1) {
 187         switch(c) {
 188         case 'd':
 189             debug = 1;
 190             break;
 191         case 'F':
 192             obj.cmdlineconfigfile = strdup(optarg);
 193             break;
 194         default:
 195             usage();
 196             exit(EXIT_FAILURE);
 197         }
 198     }
 199
 200     if (check_lockfile("netatalk", _PATH_NETATALK_LOCK) != 0)
 201         exit(EXITERR_SYS);
 202
 203     if (!debug && daemonize(0, 0) != 0)
 204         exit(EXITERR_SYS);
 205
 206     if (create_lockfile("netatalk", _PATH_NETATALK_LOCK) != 0)
 207         exit(EXITERR_SYS);
 208
 209     sigfillset(&blocksigs);
 210     sigprocmask(SIG_SETMASK, &blocksigs, NULL);
 211
 212     if (afp_config_parse(&obj) != 0)
 213         netatalk_exit(EXITERR_CONF);
 214
 215     set_processname("netatalk");
 216     setuplog(obj.options.logconfig, obj.options.logfile);
 217     event_set_log_callback(libevent_logmsg_cb);
 218     event_set_fatal_callback(netatalk_exit);
 219
 220     LOG(log_note, logtype_default, "Netatalk AFP server starting");
 221
 222     if ((afpd_pid = run_process(_PATH_AFPD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 223         LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 224         netatalk_exit(EXITERR_CONF);
 225     }
 226
 227     if ((cnid_metad_pid = run_process(_PATH_CNID_METAD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 228         LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 229         netatalk_exit(EXITERR_CONF);
 230     }
 231
 232     if ((base = event_base_new()) == NULL) {
 233         LOG(log_error, logtype_afpd, "Error starting event loop");
 234         netatalk_exit(EXITERR_CONF);
 235     }
 236
 237     struct event *sigterm_ev, *sigquit_ev, *sigchld_ev;
 238     sigterm_ev = event_new(base, SIGTERM, EV_SIGNAL|EV_PERSIST, sigterm_cb, NULL);
 239     sigquit_ev = event_new(base, SIGQUIT, EV_SIGNAL|EV_PERSIST, sigquit_cb, NULL);
 240     sigchld_ev = event_new(base, SIGCHLD, EV_SIGNAL|EV_PERSIST, sigchld_cb, NULL);
 241
 242     event_add(sigterm_ev, NULL);
 243     event_add(sigquit_ev, NULL);
 244     event_add(sigchld_ev, NULL);
 245
 246     sigfillset(&blocksigs);
 247     sigdelset(&blocksigs, SIGTERM);
 248     sigdelset(&blocksigs, SIGQUIT);
 249     sigdelset(&blocksigs, SIGCHLD);
 250     sigprocmask(SIG_SETMASK, &blocksigs, NULL);
 251
 252     /* run the event loop */
 253     ret = event_base_dispatch(base);
 254
 255     return ret;
 256 }