etc/netatalk/netatalk.c

   1 /*
   2    Copyright (c) 2012 Frank Lahm <franklahm@gmail.com>
   3
   4    This program is free software; you can redistribute it and/or modify
   5    it under the terms of the GNU General Public License as published by
   6    the Free Software Foundation; either version 2 of the License, or
   7    (at your option) any later version.
   8
   9    This program is distributed in the hope that it will be useful,
  10    but WITHOUT ANY WARRANTY; without even the implied warranty of
  11    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12    GNU General Public License for more details.
  13 */
  14 #ifdef HAVE_CONFIG_H
  15 #include "config.h"
  16 #endif /* HAVE_CONFIG_H */
  17
  18 #include <stdio.h>
  19 #include <stdlib.h>
  20 #include <string.h>
  21 #include <signal.h>
  22 #include <sys/param.h>
  23 #include <sys/uio.h>
  24 #include <sys/time.h>
  25 #include <sys/socket.h>
  26 #include <sys/poll.h>
  27 #include <errno.h>
  28 #include <sys/wait.h>
  29 #include <sys/resource.h>
  30
  31 #include <atalk/logger.h>
  32 #include <atalk/adouble.h>
  33 #include <atalk/compat.h>
  34 #include <atalk/dsi.h>
  35 #include <atalk/afp.h>
  36 #include <atalk/paths.h>
  37 #include <atalk/util.h>
  38 #include <atalk/server_child.h>
  39 #include <atalk/server_ipc.h>
  40 #include <atalk/errchk.h>
  41 #include <atalk/globals.h>
  42 #include <atalk/netatalk_conf.h>
  43 #include <atalk/bstrlib.h>
  44 #include <atalk/bstradd.h>
  45
  46 #include <event2/event.h>
  47
  48 /* how many seconds we wait to shutdown from SIGTERM before we send SIGKILL */
  49 #define KILL_GRACETIME 5
  50
  51 /* forward declaration */
  52 static pid_t run_process(const char *path, ...);
  53 static void kill_childs(int sig, ...);
  54
  55 /* static variables */
  56 static AFPObj obj;
  57 static pid_t afpd_pid = -1,  cnid_metad_pid = -1, dbus_pid = -1, trackerd_pid = -1;
  58 static uint afpd_restarts, cnid_metad_restarts, dbus_restarts, trackerd_restarts;
  59 static struct event_base *base;
  60 struct event *sigterm_ev, *sigquit_ev, *sigchld_ev, *timer_ev;
  61 static int in_shutdown;
  62 static const char *dbus_path;
  63 static char *trackerd_loglev;
  64
  65 /******************************************************************
  66  * Misc stuff
  67  ******************************************************************/
  68
  69 /* Set Tracker Miners to index all our volumes */
  70 static int set_sl_volumes(void)
  71 {
  72     EC_INIT;
  73     const struct vol *volumes, *vol;
  74     struct bstrList *vollist = bstrListCreate();
  75     bstring sep = bfromcstr(", ");
  76     bstring volnamelist = NULL, cmd = NULL;
  77
  78     EC_NULL_LOG( volumes = getvolumes() );
  79
  80     for (vol = volumes; vol; vol = vol->v_next) {
  81         bstring volnamequot = bformat("'%s'", vol->v_path);
  82         bstrListPush(vollist, volnamequot);
  83     }
  84
  85     volnamelist = bjoin(vollist, sep);
  86     cmd = bformat("gsettings set org.freedesktop.Tracker.Miner.Files index-recursive-directories \"[%s]\"", bdata(volnamelist));
  87     LOG(log_debug, logtype_sl, "set_sl_volumes: %s", bdata(cmd));
  88     system(bdata(cmd));
  89
  90 EC_CLEANUP:
  91     if (cmd)
  92         bdestroy(cmd);
  93     if (sep)
  94         bdestroy(sep);
  95     if (vollist)
  96         bstrListDestroy(vollist);
  97     if (volnamelist)
  98         bdestroy(volnamelist);
  99     EC_EXIT;
 100 }
 101
 102 /******************************************************************
 103  * libevent helper functions
 104  ******************************************************************/
 105
 106 /* libevent logging callback */
 107 static void libevent_logmsg_cb(int severity, const char *msg)
 108 {
 109     switch (severity) {
 110     case _EVENT_LOG_DEBUG:
 111         LOG(log_debug, logtype_default, "libevent: %s", msg);
 112         break;
 113     case _EVENT_LOG_MSG:
 114         LOG(log_info, logtype_default, "libevent: %s", msg);
 115         break;
 116     case _EVENT_LOG_WARN:
 117         LOG(log_warning, logtype_default, "libevent: %s", msg);
 118         break;
 119     case _EVENT_LOG_ERR:
 120         LOG(log_error, logtype_default, "libevent: %s", msg);
 121         break;
 122     default:
 123         LOG(log_error, logtype_default, "libevent: %s", msg);
 124         break; /* never reached */
 125     }
 126 }
 127
 128 /******************************************************************
 129  * libevent event callbacks
 130  ******************************************************************/
 131
 132 /* SIGTERM callback */
 133 static void sigterm_cb(evutil_socket_t fd, short what, void *arg)
 134 {
 135     sigset_t sigs;
 136     struct timeval tv;
 137
 138     LOG(log_info, logtype_afpd, "Exiting on SIGTERM");
 139
 140     if (in_shutdown)
 141         return;
 142     in_shutdown = 1;
 143
 144     /* block any signal but SIGCHLD */
 145     sigfillset(&sigs);
 146     sigdelset(&sigs, SIGCHLD);
 147     sigprocmask(SIG_SETMASK, &sigs, NULL);
 148
 149     /* add 10 sec timeout timer, remove all events but SIGCHLD */
 150     tv.tv_sec = KILL_GRACETIME;
 151     tv.tv_usec = 0;
 152     event_base_loopexit(base, &tv);
 153     event_del(sigterm_ev);
 154     event_del(sigquit_ev);
 155     event_del(timer_ev);
 156
 157 #ifdef HAVE_TRACKER_SPARQL
 158     system("tracker-control -t");
 159 #endif
 160     kill_childs(SIGTERM, &afpd_pid, &cnid_metad_pid, &dbus_pid, &trackerd_pid, NULL);
 161 }
 162
 163 /* SIGQUIT callback */
 164 static void sigquit_cb(evutil_socket_t fd, short what, void *arg)
 165 {
 166     LOG(log_note, logtype_afpd, "Exiting on SIGQUIT");
 167 #ifdef HAVE_TRACKER_SPARQL
 168     system("tracker-control -t");
 169 #endif
 170     kill_childs(SIGQUIT, &afpd_pid, &cnid_metad_pid, &dbus_pid, &trackerd_pid, NULL);
 171 }
 172
 173 /* SIGHUP callback */
 174 static void sighup_cb(evutil_socket_t fd, short what, void *arg)
 175 {
 176     LOG(log_note, logtype_afpd, "Received SIGHUP, sending all processes signal to reload config");
 177     kill_childs(SIGHUP, &afpd_pid, &cnid_metad_pid, &trackerd_pid, NULL);
 178 }
 179
 180 /* SIGCHLD callback */
 181 static void sigchld_cb(evutil_socket_t fd, short what, void *arg)
 182 {
 183     int status;
 184     pid_t pid;
 185
 186     while ((pid = waitpid(-1, &status, WNOHANG)) > 0) {
 187         if (WIFEXITED(status)) {
 188             if (WEXITSTATUS(status))
 189                 LOG(log_info, logtype_default, "child[%d]: exited %d", pid, WEXITSTATUS(status));
 190             else
 191                 LOG(log_info, logtype_default, "child[%d]: done", pid);
 192         } else {
 193             if (WIFSIGNALED(status))
 194                 LOG(log_info, logtype_default, "child[%d]: killed by signal %d", pid, WTERMSIG(status));
 195             else
 196                 LOG(log_info, logtype_default, "child[%d]: died", pid);
 197         }
 198
 199         if (pid == afpd_pid)
 200             afpd_pid = -1;
 201         else if (pid == cnid_metad_pid)
 202             cnid_metad_pid = -1;
 203         else if (pid == dbus_pid)
 204             dbus_pid = -1;
 205         else if (pid == trackerd_pid)
 206             trackerd_pid = -1;
 207         else
 208             LOG(log_error, logtype_afpd, "Bad pid: %d", pid);
 209     }
 210
 211     if (in_shutdown && afpd_pid == -1 && cnid_metad_pid == -1 && dbus_pid == -1 && trackerd_pid == -1)
 212         event_base_loopbreak(base);
 213 }
 214
 215 /* timer callback */
 216 static void timer_cb(evutil_socket_t fd, short what, void *arg)
 217 {
 218     if (in_shutdown)
 219         return;
 220
 221     if (afpd_pid == -1) {
 222         afpd_restarts++;
 223         LOG(log_note, logtype_afpd, "Restarting 'afpd' (restarts: %u)", afpd_restarts);
 224         if ((afpd_pid = run_process(_PATH_AFPD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 225             LOG(log_error, logtype_default, "Error starting 'afpd'");
 226         }
 227     }
 228
 229     if (cnid_metad_pid == -1) {
 230         cnid_metad_restarts++;
 231         LOG(log_note, logtype_afpd, "Restarting 'cnid_metad' (restarts: %u)", cnid_metad_restarts);
 232         if ((cnid_metad_pid = run_process(_PATH_CNID_METAD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 233             LOG(log_error, logtype_default, "Error starting 'cnid_metad'");
 234         }
 235     }
 236
 237     if (dbus_pid == -1) {
 238         dbus_restarts++;
 239         LOG(log_note, logtype_afpd, "Restarting 'dbus' (restarts: %u)", dbus_restarts);
 240         if ((dbus_pid = run_process(dbus_path, "--config-file=" _PATH_CONFDIR "dbus.session.conf", NULL)) == -1) {
 241             LOG(log_error, logtype_default, "Error starting '%s'", dbus_path);
 242         }
 243     }
 244
 245 #ifdef HAVE_TRACKER_RDF
 246     if (trackerd_pid == -1) {
 247         trackerd_restarts++;
 248         LOG(log_note, logtype_afpd, "Restarting 'trackerd' (restarts: %u)", trackerd_restarts);
 249         if ((trackerd_pid = run_process(TRACKER_RDF_PREFIX "/bin/trackerd", trackerd_loglev, NULL)) == -1) {
 250             LOG(log_error, logtype_default, "Error starting '%s'", "/usr/bin/trackerd");
 251         }
 252     }
 253 #endif
 254 }
 255
 256 /******************************************************************
 257  * helper functions
 258  ******************************************************************/
 259
 260 /* kill processes passed as varargs of type "pid_t *", terminate list with NULL */
 261 static void kill_childs(int sig, ...)
 262 {
 263     va_list args;
 264     pid_t *pid;
 265
 266     va_start(args, sig);
 267
 268     while ((pid = va_arg(args, pid_t *)) != NULL) {
 269         if (*pid == -1)
 270             continue;
 271         kill(*pid, sig);
 272     }
 273     va_end(args);
 274 }
 275
 276 /* this get called when error conditions are met that require us to exit gracefully */
 277 static void netatalk_exit(int ret)
 278 {
 279     server_unlock(PATH_NETATALK_LOCK);
 280     exit(ret);
 281 }
 282
 283 /* this forks() and exec() "path" with varags as argc[] */
 284 static pid_t run_process(const char *path, ...)
 285 {
 286     int ret, i = 0;
 287 #define MYARVSIZE 64
 288     char *myargv[MYARVSIZE];
 289     va_list args;
 290     pid_t pid;
 291
 292     if ((pid = fork()) < 0) {
 293         LOG(log_error, logtype_cnid, "error in fork: %s", strerror(errno));
 294         return -1;
 295     }
 296
 297     if (pid == 0) {
 298         myargv[i++] = (char *)path;
 299         va_start(args, path);
 300         while (i < MYARVSIZE) {
 301             if ((myargv[i++] = va_arg(args, char *)) == NULL)
 302                 break;
 303         }
 304         va_end(args);
 305
 306         ret = execv(path, myargv);
 307
 308         /* Yikes! We're still here, so exec failed... */
 309         LOG(log_error, logtype_cnid, "Fatal error in exec: %s", strerror(errno));
 310         exit(1);
 311     }
 312     return pid;
 313 }
 314
 315 static void usage(void)
 316 {
 317     printf("usage: netatalk [-F configfile] \n");
 318 }
 319
 320 int main(int argc, char **argv)
 321 {
 322     int c, ret, debug = 0;
 323     sigset_t blocksigs;
 324     struct timeval tv;
 325
 326     /* Log SIGBUS/SIGSEGV SBT */
 327     fault_setup(NULL);
 328
 329     while ((c = getopt(argc, argv, ":dF:")) != -1) {
 330         switch(c) {
 331         case 'd':
 332             debug = 1;
 333             break;
 334         case 'F':
 335             obj.cmdlineconfigfile = strdup(optarg);
 336             break;
 337         default:
 338             usage();
 339             exit(EXIT_FAILURE);
 340         }
 341     }
 342
 343     if (check_lockfile("netatalk", PATH_NETATALK_LOCK) != 0)
 344         exit(EXITERR_SYS);
 345
 346     if (!debug && daemonize(0, 0) != 0)
 347         exit(EXITERR_SYS);
 348
 349     if (create_lockfile("netatalk", PATH_NETATALK_LOCK) != 0)
 350         exit(EXITERR_SYS);
 351
 352     sigfillset(&blocksigs);
 353     sigprocmask(SIG_SETMASK, &blocksigs, NULL);
 354
 355     if (afp_config_parse(&obj, "netatalk") != 0)
 356         netatalk_exit(EXITERR_CONF);
 357
 358     load_volumes(&obj);
 359
 360     event_set_log_callback(libevent_logmsg_cb);
 361     event_set_fatal_callback(netatalk_exit);
 362
 363     LOG(log_note, logtype_default, "Netatalk AFP server starting");
 364
 365     if ((afpd_pid = run_process(_PATH_AFPD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 366         LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 367         netatalk_exit(EXITERR_CONF);
 368     }
 369
 370     if ((cnid_metad_pid = run_process(_PATH_CNID_METAD, "-d", "-F", obj.options.configfile, NULL)) == -1) {
 371         LOG(log_error, logtype_afpd, "Error starting 'cnid_metad'");
 372         netatalk_exit(EXITERR_CONF);
 373     }
 374
 375     if ((base = event_base_new()) == NULL) {
 376         LOG(log_error, logtype_afpd, "Error starting event loop");
 377         netatalk_exit(EXITERR_CONF);
 378     }
 379
 380     sigterm_ev = event_new(base, SIGTERM, EV_SIGNAL, sigterm_cb, NULL);
 381     sigquit_ev = event_new(base, SIGQUIT, EV_SIGNAL | EV_PERSIST, sigquit_cb, NULL);
 382     sigquit_ev = event_new(base, SIGHUP,  EV_SIGNAL | EV_PERSIST, sighup_cb, NULL);
 383     sigchld_ev = event_new(base, SIGCHLD, EV_SIGNAL | EV_PERSIST, sigchld_cb, NULL);
 384     timer_ev = event_new(base, -1, EV_PERSIST, timer_cb, NULL);
 385
 386     tv.tv_sec = 1;
 387     tv.tv_usec = 0;
 388
 389     event_add(sigterm_ev, NULL);
 390     event_add(sigquit_ev, NULL);
 391     event_add(sigchld_ev, NULL);
 392     event_add(timer_ev, &tv);
 393
 394     sigfillset(&blocksigs);
 395     sigdelset(&blocksigs, SIGTERM);
 396     sigdelset(&blocksigs, SIGQUIT);
 397     sigdelset(&blocksigs, SIGCHLD);
 398     sigdelset(&blocksigs, SIGHUP);
 399     sigprocmask(SIG_SETMASK, &blocksigs, NULL);
 400
 401 #ifdef HAVE_TRACKER
 402     setenv("DBUS_SESSION_BUS_ADDRESS", "unix:path=/tmp/spotlight.ipc", 1);
 403     setenv("XDG_DATA_HOME", _PATH_STATEDIR, 0);
 404     setenv("XDG_CACHE_HOME", _PATH_STATEDIR, 0);
 405     setenv("XDG_CONFIG_HOME", _PATH_CONFDIR, 0);
 406 #endif
 407
 408 #ifdef HAVE_TRACKER_RDF
 409     /* This assumes Tracker 0.6 with RDF is only used on Solaris and derived platforms */
 410     dbus_path = iniparser_getstring(obj.iniconfig, INISEC_GLOBAL, "dbus daemon path", "/usr/lib/dbus-daemon");
 411 #else
 412     dbus_path = iniparser_getstring(obj.iniconfig, INISEC_GLOBAL, "dbus daemon path", "/bin/dbus-daemon");
 413 #endif
 414     LOG(log_debug, logtype_default, "DBUS: '%s'", dbus_path);
 415     if ((dbus_pid = run_process(dbus_path, "--config-file=" _PATH_CONFDIR "dbus-session.conf", NULL)) == -1) {
 416         LOG(log_error, logtype_default, "Error starting '%s'", dbus_path);
 417         netatalk_exit(EXITERR_CONF);
 418     }
 419
 420     /* Allow dbus some time to start up */
 421     sleep(1);
 422
 423 #ifdef HAVE_TRACKER_SPARQL
 424     set_sl_volumes();
 425     system(TRACKER_PREFIX "/bin/tracker-control -s");
 426 #endif
 427 #ifdef HAVE_TRACKER_RDF
 428     if (asprintf(&trackerd_loglev, "--verbosity=%d", obj.options.tracker_loglevel) == -1)
 429         netatalk_exit(EXITERR_CONF);
 430     if ((trackerd_pid = run_process(TRACKER_RDF_PREFIX "/bin/trackerd", trackerd_loglev, NULL)) == -1) {
 431         LOG(log_error, logtype_default, "Error starting '%s'", TRACKER_RDF_PREFIX "/bin/trackerd");
 432         netatalk_exit(EXITERR_CONF);
 433     }
 434 #endif
 435
 436     /* run the event loop */
 437     ret = event_base_dispatch(base);
 438
 439     if (afpd_pid != -1 || cnid_metad_pid != -1 || dbus_pid != -1 || trackerd_pid != -1) {
 440         if (afpd_pid != -1)
 441             LOG(log_error, logtype_afpd, "AFP service did not shutdown, killing it");
 442         if (cnid_metad_pid != -1)
 443             LOG(log_error, logtype_afpd, "CNID database service did not shutdown, killing it");
 444         if (dbus_pid != -1)
 445             LOG(log_error, logtype_afpd, "DBUS session daemon still running, killing it");
 446         if (trackerd_pid != -1)
 447             LOG(log_error, logtype_afpd, "trackerd still running, killing it");
 448         kill_childs(SIGKILL, &afpd_pid, &cnid_metad_pid, &dbus_pid, &trackerd_pid, NULL);
 449     }
 450
 451     LOG(log_note, logtype_afpd, "Netatalk AFP server exiting");
 452
 453     netatalk_exit(ret);
 454 }