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