masqmail
view src/listen.c @ 381:33b893124c81
Added tag 0.3.4 for changeset 35c5239ebcc1
| author | markus schnalke <meillo@marmaro.de> |
|---|---|
| date | Wed, 18 Jan 2012 09:52:40 +0100 |
| parents | b27f66555ba8 |
| children | a2909de1818b |
line source
1 /*
2 ** MasqMail
3 ** Copyright (C) 1999/2000 Oliver Kurth
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,
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, write to the Free Software
17 ** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18 */
20 #include <sys/wait.h>
21 #include <sys/types.h>
23 #include "masqmail.h"
25 static int volatile sighup_seen = 0;
27 static void
28 sighup_handler(int sig)
29 {
30 sighup_seen = 1;
31 signal(SIGHUP, sighup_handler);
32 }
34 static void
35 sigchld_handler(int sig)
36 {
37 pid_t pid;
38 int status;
40 pid = waitpid(0, &status, 0);
41 if (pid > 0) {
42 if (WEXITSTATUS(status) != 0)
43 logwrite(LOG_WARNING, "process %d exited with %d\n", pid, WEXITSTATUS(status));
44 if (WIFSIGNALED(status))
45 logwrite(LOG_WARNING, "process with pid %d got signal: %d\n", pid, WTERMSIG(status));
46 }
47 signal(SIGCHLD, sigchld_handler);
48 }
50 void
51 accept_connect(int listen_sock, int sock, struct sockaddr_in *sock_addr)
52 {
53 pid_t pid;
54 int dup_sock = dup(sock);
55 FILE *out, *in;
56 gchar *rem_host;
57 gchar *ident = NULL;
59 rem_host = g_strdup(inet_ntoa(sock_addr->sin_addr));
60 logwrite(LOG_NOTICE, "connect from host %s, port %hd\n", rem_host, ntohs(sock_addr->sin_port));
62 /* start child for connection: */
63 signal(SIGCHLD, sigchld_handler);
64 pid = fork();
65 if (pid == 0) {
66 close(listen_sock);
67 out = fdopen(sock, "w");
68 in = fdopen(dup_sock, "r");
70 smtp_in(in, out, rem_host, ident);
72 _exit(0);
73 } else if (pid < 0) {
74 logwrite(LOG_WARNING, "could not fork for incoming smtp connection: %s\n", strerror(errno));
75 }
77 close(sock);
78 close(dup_sock);
79 }
81 void
82 listen_port(GList *iface_list, gint qival, char *argv[])
83 {
84 int i;
85 fd_set active_fd_set, read_fd_set;
86 struct timeval tm;
87 time_t time_before, time_now;
88 struct sockaddr_in clientname;
89 size_t size;
90 GList *node, *node_next;
91 int sel_ret;
93 /* Create the sockets and set them up to accept connections. */
94 FD_ZERO(&active_fd_set);
95 for (node = g_list_first(iface_list); node; node = node_next) {
96 interface *iface = (interface *) (node->data);
97 int sock;
99 node_next = g_list_next(node);
100 if ((sock = make_server_socket(iface)) < 0) {
101 iface_list = g_list_remove_link(iface_list, node);
102 g_list_free_1(node);
103 continue;
104 }
105 if (listen(sock, 1) < 0) {
106 logwrite(LOG_ALERT, "listen: (terminating): %s\n", strerror(errno));
107 exit(1);
108 }
109 logwrite(LOG_NOTICE, "listening on interface %s:%d\n", iface->address, iface->port);
110 DEBUG(5) debugf("sock = %d\n", sock);
111 FD_SET(sock, &active_fd_set);
112 }
114 /* setup handler for HUP signal: */
115 signal(SIGHUP, sighup_handler);
116 signal(SIGCHLD, sigchld_handler);
118 /* now that we have our socket(s), we can give up root privileges */
119 if (!conf.run_as_user) {
120 set_euidgid(conf.mail_uid, conf.mail_gid, NULL, NULL);
121 }
123 /* sel_ret = 0; */
124 time(&time_before);
125 time_before -= qival;
126 sel_ret = -1;
128 while (1) {
130 /*
131 ** if we were interrupted by an incoming connection (or a
132 ** signal) we have to recalculate the time until the next
133 ** queue run should occur. select may put a value into tm,
134 ** but doc for select() says we should not use it.
135 */
136 if (qival > 0) {
137 time(&time_now);
138 if (sel_ret == 0) { /* we are either just starting or did a queue run */
139 tm.tv_sec = qival;
140 tm.tv_usec = 0;
141 time_before = time_now;
142 } else {
143 tm.tv_sec = qival - (time_now - time_before);
144 tm.tv_usec = 0;
146 /* race condition, very unlikely (but possible): */
147 if (tm.tv_sec < 0)
148 tm.tv_sec = 0;
149 }
150 }
151 /*
152 ** Block until input arrives on one or more active sockets,
153 ** or signal arrives, or queuing interval time elapsed
154 ** (if qival > 0)
155 */
156 read_fd_set = active_fd_set;
157 if ((sel_ret = select(FD_SETSIZE, &read_fd_set, NULL, NULL, qival > 0 ? &tm : NULL)) < 0) {
158 if (errno != EINTR) {
159 logwrite(LOG_ALERT, "select: (terminating): %s\n", strerror(errno));
160 exit(1);
161 } else {
162 if (sighup_seen) {
163 logwrite(LOG_NOTICE, "HUP signal received. Restarting daemon\n");
165 for (i = 0; i < FD_SETSIZE; i++)
166 if (FD_ISSET(i, &active_fd_set))
167 close(i);
169 execv(argv[0], &(argv[0]));
170 logwrite(LOG_ALERT, "restarting failed: %s\n", strerror(errno));
171 exit(1);
172 }
173 }
174 } else if (sel_ret > 0) {
175 for (i = 0; i < FD_SETSIZE; i++) {
176 if (FD_ISSET(i, &read_fd_set)) {
177 int sock = i;
178 int new;
179 size = sizeof(clientname);
180 new = accept(sock, (struct sockaddr *) &clientname, &size);
181 if (new < 0) {
182 logwrite(LOG_ALERT, "accept: (ignoring): %s\n", strerror(errno));
183 } else
184 accept_connect(sock, new, &clientname);
185 }
186 }
187 } else {
188 /*
189 ** If select returns 0, the interval time has elapsed.
190 ** We start a new queue runner process
191 */
192 int pid;
193 signal(SIGCHLD, sigchld_handler);
194 if ((pid = fork()) == 0) {
195 queue_run();
197 _exit(0);
198 } else if (pid < 0) {
199 logwrite(LOG_ALERT, "could not fork for queue run");
200 }
201 }
202 }
203 }