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 /* how many seconds we wait to shutdown from SIGTERM before we send SIGKILL */
  39 #define KILL_GRACETIME 5
  40
  41 /* forward declaration */
  42 static pid_t run_process(const char *path, ...);
  43 static void kill_childs(int sig, ...);
  44
  45 /* static variables */
  46 static AFPObj obj;
  47 static sig_atomic_t got_chldsig;
  48 static pid_t afpd_pid = -1,  cnid_metad_pid = -1, dbus_pid = -1;
  49 static uint afpd_restarts, cnid_metad_restarts, dbus_restarts;
  50 static struct event_base *base;
  51 struct event *sigterm_ev, *sigquit_ev, *sigchld_ev, *timer_ev;
  52 static int in_shutdown;
  53 static const char *dbus_path;
  54
  55 /******************************************************************
  56  * libevent helper functions
  57  ******************************************************************/
  58
  59 /* libevent logging callback */
  60 static void libevent_logmsg_cb(int severity, const char *msg)
  61 {
  62     switch (severity) {
  63     case _EVENT_LOG_DEBUG:
  64         LOG(log_debug, logtype_default, "libevent: %s", msg);
  65         break;
  66     case _EVENT_LOG_MSG:
  67         LOG(log_info, logtype_default, "libevent: %s", msg);
  68         break;
  69     case _EVENT_LOG_WARN:
  70         LOG(log_warning, logtype_default, "libevent: %s", msg);
  71         break;
  72     case _EVENT_LOG_ERR:
  73         LOG(log_error, logtype_default, "libevent: %s", msg);
  74         break;
  75     default:
  76         LOG(log_error, logtype_default, "libevent: %s", msg);
  77         break; /* never reached */
  78     }
  79 }
  80
  81 /******************************************************************
  82  * libevent event callbacks
  83  ******************************************************************/
  84
  85 /* SIGTERM callback */
  86 static void sigterm_cb(evutil_socket_t fd, short what, void *arg)
  87 {
  88     sigset_t sigs;
  89     struct timeval tv;
  90
  91     LOG(log_info, logtype_afpd, "Exiting on SIGTERM");
  92
  93     if (in_shutdown)
  94         return;
  95     in_shutdown = 1;
  96
  97     /* block any signal but SIGCHLD */
  98     sigfillset(&sigs);
  99     sigdelset(&sigs, SIGCHLD);
 100     sigprocmask(SIG_SETMASK, &sigs, NULL);
 101
 102     /* add 10 sec timeout timer, remove all events but SIGCHLD */
 103     tv.tv_sec = KILL_GRACETIME;
 104     tv.tv_usec = 0;
 105     event_base_loopexit(base, &tv);
 106     event_del(sigterm_ev);
 107     event_del(sigquit_ev);
 108     event_del(timer_ev);
 109
 110     system("tracker-control -t");
 111     kill_childs(SIGTERM, &afpd_pid, &cnid_metad_pid, &dbus_pid, NULL);
 112 }
 113
 114 /* SIGQUIT callback */
 115 static void sigquit_cb(evutil_socket_t fd, short what, void *arg)
 116 {
 117     LOG(log_note, logtype_afpd, "Exiting on SIGQUIT");
 118     system("tracker-control -t");
 119     kill_childs(SIGQUIT, &afpd_pid, &cnid_metad_pid, &dbus_pid, NULL);
 120 }
 121
 122 /* SIGCHLD callback */
 123 static void sigchld_cb(evutil_socket_t fd, short what, void *arg)
 124 {
 125     int status, i;
 126     pid_t pid;
 127
 128     while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
 129         if (WIFEXITED(status)) {
 130             if (WEXITSTATUS(status))
 131                 LOG(log_info, logtype_default, "child[%d]: exited %d", pid, WEXITSTATUS(status));
 132             else
 133                 LOG(log_info, logtype_default, "child[%d]: done", pid);
 134         } else {
 135             if (WIFSIGNALED(status))
 136                 LOG(log_info, logtype_default, "child[%d]: killed by signal %d", pid, WTERMSIG(status));
 137             else
 138                 LOG(log_info, logtype_default, "child[%d]: died", pid);
 139         }
 140
 141         if (pid == afpd_pid)
 142             afpd_pid = -1;
 143         else if (pid == cnid_metad_pid)
 144             cnid_metad_pid = -1;
 145         else if (pid == dbus_pid)
 146             dbus_pid = -1;
 147         else
 148             LOG(log_error, logtype_afpd, "Bad pid: %d", pid);
 149     }
 150
 151     if (in_shutdown && afpd_pid == -1 && cnid_metad_pid == -1 && dbus_pid == -1)
 152         event_base_loopbreak(base);
 153 }
 154
 155 /* timer callback */
 156 static void timer_cb(evutil_socket_t fd, short what, void *arg)
 157 {
 158     static int i = 0;
 159
 160     if (in_shutdown)
 161         return;
 162
 163     if (afpd_pid == -1) {
 164         afpd_restarts++;
 165         LOG(log_note, logtype_afpd, "Restarting 'afpd' (restarts: %u)", afpd_restarts);
 166         if ((afpd_pid = run_process(_PATH_AFPD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 167             LOG(log_error, logtype_default, "Error starting 'afpd'");
 168         }
 169     }
 170
 171     if (cnid_metad_pid == -1) {
 172         cnid_metad_restarts++;
 173         LOG(log_note, logtype_afpd, "Restarting 'cnid_metad' (restarts: %u)", cnid_metad_restarts);
 174         if ((cnid_metad_pid = run_process(_PATH_CNID_METAD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 175             LOG(log_error, logtype_default, "Error starting 'cnid_metad'");
 176         }
 177     }
 178
 179     if (dbus_pid == -1) {
 180         dbus_restarts++;
 181         LOG(log_note, logtype_afpd, "Restarting 'dbus' (restarts: %u)", dbus_restarts);
 182         if ((dbus_pid = run_process(dbus_path, "--config-file=" _PATH_CONFDIR "dbus.session.conf", NULL)) == -1) {
 183             LOG(log_error, logtype_default, "Error starting '%s'", dbus_path);
 184         }
 185     }
 186 }
 187
 188 /******************************************************************
 189  * helper functions
 190  ******************************************************************/
 191
 192 /* kill processes passed as varargs of type "pid_t *", terminate list with NULL */
 193 static void kill_childs(int sig, ...)
 194 {
 195     va_list args;
 196     pid_t *pid;
 197
 198     va_start(args, sig);
 199
 200     while ((pid = va_arg(args, pid_t *)) != NULL) {
 201         if (*pid == -1)
 202             continue;
 203         kill(*pid, sig);
 204     }
 205     va_end(args);
 206 }
 207
 208 /* this get called when error conditions are met that require us to exit gracefully */
 209 static void netatalk_exit(int ret)
 210 {
 211     server_unlock(_PATH_NETATALK_LOCK);
 212     exit(ret);
 213 }
 214
 215 /* this forks() and exec() "path" with varags as argc[] */
 216 static pid_t run_process(const char *path, ...)
 217 {
 218     int ret, i = 0;
 219     char *myargv[10];
 220     va_list args;
 221     pid_t pid;
 222
 223     if ((pid = fork()) < 0) {
 224         LOG(log_error, logtype_cnid, "error in fork: %s", strerror(errno));
 225         return -1;
 226     }
 227
 228     if (pid == 0) {
 229         myargv[i++] = (char *)path;
 230         va_start(args, path);
 231         while ((myargv[i++] = va_arg(args, char *)) != NULL)
 232             ;
 233         va_end(args);
 234
 235         ret = execv(path, myargv);
 236
 237         /* Yikes! We're still here, so exec failed... */
 238         LOG(log_error, logtype_cnid, "Fatal error in exec: %s", strerror(errno));
 239         exit(1);
 240     }
 241     return pid;
 242 }
 243
 244 static void usage(void)
 245 {
 246     printf("usage: netatalk [-F configfile] \n");
 247 }
 248
 249 int main(int argc, char **argv)
 250 {
 251     const char *configfile = NULL;
 252     int c, ret, debug = 0;
 253     sigset_t blocksigs;
 254     struct timeval tv;
 255
 256     /* Log SIGBUS/SIGSEGV SBT */
 257     fault_setup(NULL);
 258
 259     while ((c = getopt(argc, argv, ":dF:")) != -1) {
 260         switch(c) {
 261         case 'd':
 262             debug = 1;
 263             break;
 264         case 'F':
 265             obj.cmdlineconfigfile = strdup(optarg);
 266             break;
 267         default:
 268             usage();
 269             exit(EXIT_FAILURE);
 270         }
 271     }
 272
 273     if (check_lockfile("netatalk", _PATH_NETATALK_LOCK) != 0)
 274         exit(EXITERR_SYS);
 275
 276     if (!debug && daemonize(0, 0) != 0)
 277         exit(EXITERR_SYS);
 278
 279     if (create_lockfile("netatalk", _PATH_NETATALK_LOCK) != 0)
 280         exit(EXITERR_SYS);
 281
 282     sigfillset(&blocksigs);
 283     sigprocmask(SIG_SETMASK, &blocksigs, NULL);
 284
 285     if (afp_config_parse(&obj, "netatalk") != 0)
 286         netatalk_exit(EXITERR_CONF);
 287
 288     event_set_log_callback(libevent_logmsg_cb);
 289     event_set_fatal_callback(netatalk_exit);
 290
 291     LOG(log_note, logtype_default, "Netatalk AFP server starting");
 292
 293     if ((afpd_pid = run_process(_PATH_AFPD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 294         LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 295         netatalk_exit(EXITERR_CONF);
 296     }
 297
 298     if ((cnid_metad_pid = run_process(_PATH_CNID_METAD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 299         LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 300         netatalk_exit(EXITERR_CONF);
 301     }
 302
 303     if ((base = event_base_new()) == NULL) {
 304         LOG(log_error, logtype_afpd, "Error starting event loop");
 305         netatalk_exit(EXITERR_CONF);
 306     }
 307
 308     sigterm_ev = event_new(base, SIGTERM, EV_SIGNAL, sigterm_cb, NULL);
 309     sigquit_ev = event_new(base, SIGQUIT, EV_SIGNAL | EV_PERSIST, sigquit_cb, NULL);
 310     sigchld_ev = event_new(base, SIGCHLD, EV_SIGNAL | EV_PERSIST, sigchld_cb, NULL);
 311     timer_ev = event_new(base, -1, EV_PERSIST, timer_cb, NULL);
 312
 313     tv.tv_sec = 1;
 314     tv.tv_usec = 0;
 315
 316     event_add(sigterm_ev, NULL);
 317     event_add(sigquit_ev, NULL);
 318     event_add(sigchld_ev, NULL);
 319     event_add(timer_ev, &tv);
 320
 321     sigfillset(&blocksigs);
 322     sigdelset(&blocksigs, SIGTERM);
 323     sigdelset(&blocksigs, SIGQUIT);
 324     sigdelset(&blocksigs, SIGCHLD);
 325     sigprocmask(SIG_SETMASK, &blocksigs, NULL);
 326
 327     dbus_path = iniparser_getstring(obj.iniconfig, INISEC_GLOBAL, "dbus daemon path", "/bin/dbus-daemon");
 328     LOG(log_debug, logtype_default, "DBUS: '%s'", dbus_path);
 329     if ((dbus_pid = run_process(dbus_path, "--config-file=" _PATH_CONFDIR "dbus-session.conf", NULL)) == -1) {
 330         LOG(log_error, logtype_default, "Error starting '%s'", dbus_path);
 331         netatalk_exit(EXITERR_CONF);
 332     }
 333
 334     sleep(1);
 335
 336     setenv("DBUS_SESSION_BUS_ADDRESS", "unix:path=/tmp/spotlight.ipc", 1);
 337     system(TRACKER_PREFIX "/bin/tracker-control -s");
 338
 339     /* run the event loop */
 340     ret = event_base_dispatch(base);
 341
 342     if (afpd_pid != -1 || cnid_metad_pid != -1 || dbus_pid != -1) {
 343         if (afpd_pid != -1)
 344             LOG(log_error, logtype_afpd, "AFP service did not shutdown, killing it");
 345         if (cnid_metad_pid != -1)
 346             LOG(log_error, logtype_afpd, "CNID database service did not shutdown, killing it");
 347         if (dbus_pid != -1)
 348             LOG(log_error, logtype_afpd, "DBUS session daemon still running, killing it");
 349         kill_childs(SIGKILL, &afpd_pid, &cnid_metad_pid, &dbus_pid, NULL);
 350     }
 351
 352     LOG(log_note, logtype_afpd, "Netatalk AFP server exiting");
 353
 354     netatalk_exit(ret);
 355 }