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