chiark - git - mdw - disorder/blob - server/state.c

   1 /*
   2  * This file is part of DisOrder.
   3  * Copyright (C) 2004, 2005, 2007-2009 Richard Kettlewell
   4  *
   5  * This program is free software: you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation, either version 3 of the License, or
   8  * (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  * GNU General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License
  16  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17  */
  18 /** @file server/state.c
  19  * @brief Global server state
  20  */
  21 #include "disorder-server.h"
  22
  23 /** @brief Current AF_UNIX socket path */
  24 static const char *current_unix;
  25
  26 /** @brief Current AF_UNIX socket */
  27 static int current_unix_fd;
  28
  29 /** @brief TCP listener definition */
  30 struct listener {
  31   /** @brief Next listener */
  32   struct listener *next;
  33
  34   /** @brief Local socket address */
  35   struct sockaddr *sa;
  36
  37   /** @brief File descriptor */
  38   int fd;
  39 };
  40
  41 /** @brief Current listeners */
  42 static struct listener *listeners;
  43
  44 /** @brief Current audio API */
  45 const struct uaudio *api;
  46
  47 /** @brief Quit DisOrder */
  48 void quit(ev_source *ev) {
  49   disorder_info("shutting down...");
  50   quitting(ev);
  51   trackdb_close();
  52   trackdb_deinit(ev);
  53   /* Shutdown subprocesses.
  54    *
  55    * Subprocesses that use ev_child:
  56    * - the speaker
  57    * - the current rescan
  58    * - any decoders
  59    * - ...and players
  60    * - the track picker
  61    * - mail sender
  62    * - the deadlock manager
  63    *
  64    * Subprocesses that don't:
  65    * - any normalizers
  66    * These are not shut down currently.
  67    */
  68   ev_child_killall(ev);
  69   disorder_info("exiting");
  70   exit(0);
  71 }
  72
  73 /** @brief Create a copy of an @c addrinfo structure */
  74 static struct sockaddr *copy_sockaddr(const struct addrinfo *addr) {
  75   struct sockaddr *sa = xmalloc_noptr(addr->ai_addrlen);
  76   memcpy(sa, addr->ai_addr, addr->ai_addrlen);
  77   return sa;
  78 }
  79
  80 /** @brief Create and destroy sockets to set current configuration */
  81 void reset_sockets(ev_source *ev) {
  82   const char *new_unix;
  83   struct addrinfo *res, *r;
  84   struct listener *l, **ll;
  85   struct sockaddr_un sun;
  86
  87   /* unix first */
  88   new_unix = config_get_file("socket");
  89   if(!current_unix || strcmp(current_unix, new_unix)) {
  90     /* either there was no socket, or there was but a different path */
  91     if(current_unix) {
  92       /* stop the old one and remove it from the filesystem */
  93       server_stop(ev, current_unix_fd);
  94       if(unlink(current_unix) < 0)
  95         disorder_fatal(errno, "unlink %s", current_unix);
  96     }
  97     /* start the new one */
  98     if(strlen(new_unix) >= sizeof sun.sun_path)
  99       disorder_fatal(0, "socket path %s is too long", new_unix);
 100     memset(&sun, 0, sizeof sun);
 101     sun.sun_family = AF_UNIX;
 102     strcpy(sun.sun_path, new_unix);
 103     if(unlink(new_unix) < 0 && errno != ENOENT)
 104       disorder_fatal(errno, "unlink %s", new_unix);
 105     if((current_unix_fd = server_start(ev, PF_UNIX, sizeof sun,
 106                                        (const struct sockaddr *)&sun,
 107                                        new_unix)) >= 0) {
 108       current_unix = new_unix;
 109       if(chmod(new_unix, 0777) < 0)
 110         disorder_fatal(errno, "error calling chmod %s", new_unix);
 111     } else
 112       current_unix = 0;
 113   }
 114
 115   /* get the new listen config */
 116   if(config->listen.af != -1)
 117     res = netaddress_resolve(&config->listen, 1, IPPROTO_TCP);
 118   else
 119     res = 0;
 120
 121   /* Close any current listeners that aren't required any more */
 122   ll = &listeners;
 123   while((l = *ll)) {
 124     for(r = res; r; r = r->ai_next)
 125       if(!sockaddrcmp(r->ai_addr, l->sa))
 126         break;
 127     if(!r) {
 128       /* Didn't find a match, remove this one */
 129       server_stop(ev, l->fd);
 130       *ll = l->next;
 131     } else {
 132       /* This address is still wanted */
 133       ll = &l->next;
 134     }
 135   }
 136
 137   /* Open any new listeners that are required */
 138   for(r = res; r; r = r->ai_next) {
 139     for(l = listeners; l; l = l->next)
 140       if(!sockaddrcmp(r->ai_addr, l->sa))
 141         break;
 142     if(!l) {
 143       /* Didn't find a match, need a new listener */
 144       int fd = server_start(ev, r->ai_family, r->ai_addrlen, r->ai_addr,
 145                             format_sockaddr(r->ai_addr));
 146       if(fd >= 0) {
 147         l = xmalloc(sizeof *l);
 148         l->next = listeners;
 149         l->sa = copy_sockaddr(r);
 150         l->fd = fd;
 151         listeners = l;
 152       }
 153       /* We ignore any failures (though server_start() will have
 154        * logged them). */
 155     }
 156   }
 157   /* if res is still set it needs freeing */
 158   if(res)
 159     freeaddrinfo(res);
 160 }
 161
 162 /** @brief Reconfigure the server
 163  * @param ev Event loop
 164  * @param flags Flags
 165  * @return As config_read(); 0 on success, -1 if could not (re-)read config
 166  */
 167 int reconfigure(ev_source *ev, unsigned flags) {
 168   int need_another_rescan = 0;
 169   int ret = 0;
 170
 171   D(("reconfigure(%x)", flags));
 172   /* Deconfigure the old audio API if there is one */
 173   if(api) {
 174     if(api->close_mixer)
 175       api->close_mixer();
 176     api = NULL;
 177   }
 178   if(flags & RECONFIGURE_RELOADING) {
 179     /* If there's a rescan in progress, cancel it but remember to start a fresh
 180      * one after the reload. */
 181     need_another_rescan = trackdb_rescan_cancel();
 182     /* (Re-)read the configuration */
 183     if(config_read(1/*server*/, config))
 184       ret = -1;
 185     else {
 186       /* Tell the speaker it needs to reload its config too. */
 187       speaker_reload();
 188       disorder_info("%s: installed new configuration", configfile);
 189     }
 190   }
 191   /* New audio API */
 192   api = uaudio_find(config->api);
 193   if(api->configure)
 194     api->configure();
 195   if(api->open_mixer)
 196     api->open_mixer();
 197   /* If we interrupted a rescan of all the tracks, start a new one */
 198   if(need_another_rescan)
 199     trackdb_rescan(ev, 1/*check*/, 0, 0);
 200   if(!ret && !(flags & RECONFIGURE_FIRST)) {
 201     /* Open/close sockets */
 202     reset_sockets(ev);
 203   }
 204   return ret;
 205 }
 206
 207 /*
 208 Local Variables:
 209 c-basic-offset:2
 210 comment-column:40
 211 fill-column:79
 212 indent-tabs-mode:nil
 213 End:
 214 */