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   info("shutting down...");
  50   quitting(ev);
  51   trackdb_close();
  52   trackdb_deinit();
  53   info("exiting");
  54   exit(0);
  55 }
  56
  57 /** @brief Create a copy of an @c addrinfo structure */
  58 static struct sockaddr *copy_sockaddr(const struct addrinfo *addr) {
  59   struct sockaddr *sa = xmalloc_noptr(addr->ai_addrlen);
  60   memcpy(sa, addr->ai_addr, addr->ai_addrlen);
  61   return sa;
  62 }
  63
  64 /** @brief Create and destroy sockets to set current configuration */
  65 void reset_sockets(ev_source *ev) {
  66   const char *new_unix;
  67   struct addrinfo *res, *r;
  68   struct listener *l, **ll;
  69   struct sockaddr_un sun;
  70
  71   /* unix first */
  72   new_unix = config_get_file("socket");
  73   if(!current_unix || strcmp(current_unix, new_unix)) {
  74     /* either there was no socket, or there was but a different path */
  75     if(current_unix) {
  76       /* stop the old one and remove it from the filesystem */
  77       server_stop(ev, current_unix_fd);
  78       if(unlink(current_unix) < 0)
  79         fatal(errno, "unlink %s", current_unix);
  80     }
  81     /* start the new one */
  82     if(strlen(new_unix) >= sizeof sun.sun_path)
  83       fatal(0, "socket path %s is too long", new_unix);
  84     memset(&sun, 0, sizeof sun);
  85     sun.sun_family = AF_UNIX;
  86     strcpy(sun.sun_path, new_unix);
  87     if(unlink(new_unix) < 0 && errno != ENOENT)
  88       fatal(errno, "unlink %s", new_unix);
  89     if((current_unix_fd = server_start(ev, PF_UNIX, sizeof sun,
  90                                        (const struct sockaddr *)&sun,
  91                                        new_unix)) >= 0) {
  92       current_unix = new_unix;
  93       if(chmod(new_unix, 0777) < 0)
  94         fatal(errno, "error calling chmod %s", new_unix);
  95     } else
  96       current_unix = 0;
  97   }
  98
  99   /* get the new listen config */
 100   if(config->listen.af != -1)
 101     res = netaddress_resolve(&config->listen, 1, IPPROTO_TCP);
 102   else
 103     res = 0;
 104
 105   /* Close any current listeners that aren't required any more */
 106   ll = &listeners;
 107   while((l = *ll)) {
 108     for(r = res; r; r = r->ai_next)
 109       if(!sockaddrcmp(r->ai_addr, l->sa))
 110         break;
 111     if(!r) {
 112       /* Didn't find a match, remove this one */
 113       server_stop(ev, l->fd);
 114       *ll = l->next;
 115     } else {
 116       /* This address is still wanted */
 117       ll = &l->next;
 118     }
 119   }
 120
 121   /* Open any new listeners that are required */
 122   for(r = res; r; r = r->ai_next) {
 123     for(l = listeners; l; l = l->next)
 124       if(!sockaddrcmp(r->ai_addr, l->sa))
 125         break;
 126     if(!l) {
 127       /* Didn't find a match, need a new listener */
 128       int fd = server_start(ev, r->ai_family, r->ai_addrlen, r->ai_addr,
 129                             format_sockaddr(r->ai_addr));
 130       if(fd >= 0) {
 131         l = xmalloc(sizeof *l);
 132         l->next = listeners;
 133         l->sa = copy_sockaddr(r);
 134         l->fd = fd;
 135         listeners = l;
 136       }
 137       /* We ignore any failures (though server_start() will have
 138        * logged them). */
 139     }
 140   }
 141   /* if res is still set it needs freeing */
 142   if(res)
 143     freeaddrinfo(res);
 144 }
 145
 146 /** @brief Reconfigure the server
 147  * @param flags Flags
 148  * @return As config_read(); 0 on success, -1 if could not (re-)read config
 149  */
 150 int reconfigure(ev_source *ev, unsigned flags) {
 151   int need_another_rescan = 0;
 152   int ret = 0;
 153
 154   D(("reconfigure(%x)", flags));
 155   /* Deconfigure the old audio API if there is one */
 156   if(api) {
 157     if(api->close_mixer)
 158       api->close_mixer();
 159     api = NULL;
 160   }
 161   if(flags & RECONFIGURE_RELOADING) {
 162     /* If there's a rescan in progress, cancel it but remember to start a fresh
 163      * one after the reload. */
 164     need_another_rescan = trackdb_rescan_cancel();
 165     /* (Re-)read the configuration */
 166     if(config_read(1/*server*/, config))
 167       ret = -1;
 168     else {
 169       /* Tell the speaker it needs to reload its config too. */
 170       speaker_reload();
 171       info("%s: installed new configuration", configfile);
 172     }
 173   }
 174   /* New audio API */
 175   api = uaudio_find(config->api);
 176   if(api->configure)
 177     api->configure();
 178   if(api->open_mixer)
 179     api->open_mixer();
 180   /* If we interrupted a rescan of all the tracks, start a new one */
 181   if(need_another_rescan)
 182     trackdb_rescan(ev, 1/*check*/, 0, 0);
 183   if(!ret && !(flags & RECONFIGURE_FIRST)) {
 184     /* Open/close sockets */
 185     reset_sockets(ev);
 186   }
 187   return ret;
 188 }
 189
 190 /*
 191 Local Variables:
 192 c-basic-offset:2
 193 comment-column:40
 194 fill-column:79
 195 indent-tabs-mode:nil
 196 End:
 197 */