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