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