Commit | Line | Data |
---|---|---|
460b9539 | 1 | /* |
2 | * This file is part of DisOrder. | |
5aff007d | 3 | * Copyright (C) 2004, 2005, 2007, 2008 Richard Kettlewell |
460b9539 | 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 2 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, but | |
11 | * WITHOUT ANY WARRANTY; without even the implied warranty of | |
12 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
13 | * 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, write to the Free Software | |
17 | * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 | |
18 | * USA | |
19 | */ | |
20 | ||
21 | #include <config.h> | |
22 | ||
23 | #include <stdlib.h> | |
24 | #include <string.h> | |
25 | #include <errno.h> | |
26 | #include <sys/types.h> | |
27 | #include <sys/socket.h> | |
28 | #include <sys/stat.h> | |
29 | #include <unistd.h> | |
30 | #include <locale.h> | |
31 | #include <stdio.h> | |
32 | #include <pcre.h> | |
33 | #include <netdb.h> | |
34 | #include <sys/un.h> | |
35 | #include <netinet/in.h> | |
36 | ||
37 | #include "event.h" | |
38 | #include "play.h" | |
5df73aeb | 39 | #include "rights.h" |
460b9539 | 40 | #include "trackdb.h" |
41 | #include "state.h" | |
42 | #include "configuration.h" | |
43 | #include "log.h" | |
44 | #include "queue.h" | |
f08c0859 | 45 | #include "server-queue.h" |
460b9539 | 46 | #include "server.h" |
47 | #include "printf.h" | |
48 | #include "addr.h" | |
fdca70ee | 49 | #include "schedule.h" |
460b9539 | 50 | |
51 | static const char *current_unix; | |
52 | static int current_unix_fd; | |
53 | ||
54 | static struct addrinfo *current_listen_addrinfo; | |
55 | static int current_listen_fd; | |
56 | ||
57 | void quit(ev_source *ev) { | |
4363757e | 58 | info("shutting down..."); |
460b9539 | 59 | quitting(ev); |
60 | trackdb_close(); | |
61 | trackdb_deinit(); | |
4363757e | 62 | info("exiting"); |
445a0f66 | 63 | exit(0); |
460b9539 | 64 | } |
65 | ||
66 | static void reset_socket(ev_source *ev) { | |
67 | const char *new_unix; | |
68 | struct addrinfo *res; | |
69 | struct sockaddr_un sun; | |
70 | char *name; | |
71 | ||
72 | static const struct addrinfo pref = { | |
66613034 RK |
73 | .ai_flags = AI_PASSIVE, |
74 | .ai_family = PF_INET, | |
75 | .ai_socktype = SOCK_STREAM, | |
76 | .ai_protocol = IPPROTO_TCP, | |
460b9539 | 77 | }; |
78 | ||
79 | /* unix first */ | |
80 | new_unix = config_get_file("socket"); | |
81 | if(!current_unix || strcmp(current_unix, new_unix)) { | |
82 | /* either there was no socket, or there was but a different path */ | |
83 | if(current_unix) { | |
84 | /* stop the old one and remove it from the filesystem */ | |
85 | server_stop(ev, current_unix_fd); | |
86 | if(unlink(current_unix) < 0) | |
87 | fatal(errno, "unlink %s", current_unix); | |
88 | } | |
89 | /* start the new one */ | |
90 | if(strlen(new_unix) >= sizeof sun.sun_path) | |
91 | fatal(0, "socket path %s is too long", new_unix); | |
92 | memset(&sun, 0, sizeof sun); | |
93 | sun.sun_family = AF_UNIX; | |
94 | strcpy(sun.sun_path, new_unix); | |
95 | if(unlink(new_unix) < 0 && errno != ENOENT) | |
96 | fatal(errno, "unlink %s", new_unix); | |
97 | if((current_unix_fd = server_start(ev, PF_UNIX, sizeof sun, | |
98 | (const struct sockaddr *)&sun, | |
99 | new_unix)) >= 0) { | |
100 | current_unix = new_unix; | |
101 | if(chmod(new_unix, 0777) < 0) | |
102 | fatal(errno, "error calling chmod %s", new_unix); | |
103 | } else | |
104 | current_unix = 0; | |
105 | } | |
106 | ||
107 | /* get the new listen config */ | |
108 | if(config->listen.n) | |
109 | res = get_address(&config->listen, &pref, &name); | |
110 | else | |
111 | res = 0; | |
112 | ||
113 | if((res && !current_listen_addrinfo) | |
114 | || (current_listen_addrinfo | |
115 | && (!res | |
116 | || addrinfocmp(res, current_listen_addrinfo)))) { | |
117 | /* something has to change */ | |
118 | if(current_listen_addrinfo) { | |
119 | /* delete the old listener */ | |
120 | server_stop(ev, current_listen_fd); | |
121 | freeaddrinfo(current_listen_addrinfo); | |
122 | current_listen_addrinfo = 0; | |
123 | } | |
124 | if(res) { | |
125 | /* start the new listener */ | |
126 | if((current_listen_fd = server_start(ev, res->ai_family, res->ai_addrlen, | |
127 | res->ai_addr, name)) >= 0) { | |
128 | current_listen_addrinfo = res; | |
129 | res = 0; | |
130 | } | |
131 | } | |
132 | } | |
133 | /* if res is still set it needs freeing */ | |
134 | if(res) | |
135 | freeaddrinfo(res); | |
136 | } | |
137 | ||
138 | int reconfigure(ev_source *ev, int reload) { | |
139 | int need_another_rescan = 0; | |
140 | int ret = 0; | |
141 | ||
142 | D(("reconfigure(%d)", reload)); | |
143 | if(reload) { | |
144 | need_another_rescan = trackdb_rescan_cancel(); | |
145 | trackdb_close(); | |
c00fce3a | 146 | if(config_read(1)) |
460b9539 | 147 | ret = -1; |
148 | else { | |
149 | /* Tell the speaker it needs to reload its config too. */ | |
150 | speaker_reload(); | |
151 | info("%s: installed new configuration", configfile); | |
152 | } | |
d25c4615 RK |
153 | trackdb_open(TRACKDB_NO_UPGRADE); |
154 | } else | |
155 | /* We only allow for upgrade at startup */ | |
156 | trackdb_open(TRACKDB_CAN_UPGRADE); | |
460b9539 | 157 | if(need_another_rescan) |
dd9af5cb | 158 | trackdb_rescan(ev, 1/*check*/, 0, 0); |
fdca70ee RK |
159 | /* Arrange timeouts for schedule actions */ |
160 | schedule_init(ev); | |
460b9539 | 161 | if(!ret) { |
162 | queue_read(); | |
163 | recent_read(); | |
164 | reset_socket(ev); | |
165 | } | |
166 | return ret; | |
167 | } | |
168 | ||
169 | /* | |
170 | Local Variables: | |
171 | c-basic-offset:2 | |
172 | comment-column:40 | |
173 | End: | |
174 | */ |