summaryrefslogtreecommitdiff
path: root/usr.sbin/rebound/rebound.c
diff options
context:
space:
mode:
authorTed Unangst <tedu@cvs.openbsd.org>2015-10-29 13:54:44 +0000
committerTed Unangst <tedu@cvs.openbsd.org>2015-10-29 13:54:44 +0000
commit80fa3320c1d6972d06697159b526ddfb52357240 (patch)
treeb4f657f0157a710f845a6f40f3fb79eaa545f783 /usr.sbin/rebound/rebound.c
parent6bf5fcb9f6d752c0ab95b8f2ff48833b5d96850d (diff)
refold a few lines
Diffstat (limited to 'usr.sbin/rebound/rebound.c')
-rw-r--r--usr.sbin/rebound/rebound.c34
1 files changed, 16 insertions, 18 deletions
diff --git a/usr.sbin/rebound/rebound.c b/usr.sbin/rebound/rebound.c
index 5ebff124900..b74edabd6a4 100644
--- a/usr.sbin/rebound/rebound.c
+++ b/usr.sbin/rebound/rebound.c
@@ -1,4 +1,4 @@
-/* $OpenBSD: rebound.c,v 1.36 2015/10/29 12:58:10 tedu Exp $ */
+/* $OpenBSD: rebound.c,v 1.37 2015/10/29 13:54:43 tedu Exp $ */
/*
* Copyright (c) 2015 Ted Unangst <tedu@openbsd.org>
*
@@ -413,7 +413,7 @@ static int
launch(const char *confname, int ud, int ld, int kq)
{
struct sockaddr_storage remoteaddr;
- struct kevent chlist[2], kev[4];
+ struct kevent ch[2], kev[4];
struct timespec ts, *timeout = NULL;
struct request reqkey, *req;
struct dnscache *ent;
@@ -432,9 +432,9 @@ launch(const char *confname, int ud, int ld, int kq)
if (!debug) {
if ((child = fork()))
return child;
+ close(kq);
}
- close(kq);
kq = kqueue();
if (!(pwd = getpwnam("_rebound")))
@@ -475,8 +475,8 @@ launch(const char *confname, int ud, int ld, int kq)
clock_gettime(CLOCK_MONOTONIC, &now);
if (stopaccepting) {
- EV_SET(&chlist[0], ld, EVFILT_READ, EV_ADD, 0, 0, NULL);
- kevent(kq, chlist, 1, NULL, 0, NULL);
+ EV_SET(&ch[0], ld, EVFILT_READ, EV_ADD, 0, 0, NULL);
+ kevent(kq, ch, 1, NULL, 0, NULL);
stopaccepting = 0;
}
@@ -499,19 +499,19 @@ launch(const char *confname, int ud, int ld, int kq)
} else if (kev[i].ident == ud) {
while ((req = newrequest(ud,
(struct sockaddr *)&remoteaddr))) {
- EV_SET(&chlist[0], req->s, EVFILT_READ,
+ EV_SET(&ch[0], req->s, EVFILT_READ,
EV_ADD, 0, 0, NULL);
- kevent(kq, chlist, 1, NULL, 0, NULL);
+ kevent(kq, ch, 1, NULL, 0, NULL);
if (conncount > connmax)
break;
}
} else if (kev[i].ident == ld) {
while ((req = newtcprequest(ld,
(struct sockaddr *)&remoteaddr))) {
- EV_SET(&chlist[0], req->s,
+ EV_SET(&ch[0], req->s,
req->tcp == 1 ? EVFILT_WRITE :
EVFILT_READ, EV_ADD, 0, 0, NULL);
- kevent(kq, chlist, 1, NULL, 0, NULL);
+ kevent(kq, ch, 1, NULL, 0, NULL);
if (conncount > connmax)
break;
}
@@ -522,11 +522,11 @@ launch(const char *confname, int ud, int ld, int kq)
logerr("lost partial tcp request");
req = tcpphasetwo(req);
if (req) {
- EV_SET(&chlist[0], req->s, EVFILT_WRITE,
+ EV_SET(&ch[0], req->s, EVFILT_WRITE,
EV_DELETE, 0, 0, NULL);
- EV_SET(&chlist[1], req->s, EVFILT_READ,
+ EV_SET(&ch[1], req->s, EVFILT_READ,
EV_ADD, 0, 0, NULL);
- kevent(kq, chlist, 2, NULL, 0, NULL);
+ kevent(kq, ch, 2, NULL, 0, NULL);
}
} else if (kev[i].filter == EVFILT_READ) {
reqkey.s = kev[i].ident;
@@ -542,8 +542,8 @@ launch(const char *confname, int ud, int ld, int kq)
}
if (stopaccepting) {
- EV_SET(&chlist[0], ld, EVFILT_READ, EV_DELETE, 0, 0, NULL);
- kevent(kq, chlist, 1, NULL, 0, NULL);
+ EV_SET(&ch[0], ld, EVFILT_READ, EV_DELETE, 0, 0, NULL);
+ kevent(kq, ch, 1, NULL, 0, NULL);
memset(&ts, 0, sizeof(ts));
/* one second added below */
timeout = &ts;
@@ -703,16 +703,14 @@ main(int argc, char **argv)
logerr("child died without HUP");
} else if (kev.filter == EVFILT_SIGNAL) {
/* signaled. kill child. */
- logmsg(LOG_INFO,
- "received HUP, restarting");
+ logmsg(LOG_INFO, "received HUP, restarting");
hupped = 1;
if (childdead)
break;
kill(child, SIGHUP);
} else if (kev.filter == EVFILT_PROC) {
/* child died. wait for our own HUP. */
- logmsg(LOG_INFO,
- "observed child exit");
+ logmsg(LOG_INFO, "observed child exit");
childdead = 1;
if (hupped)
break;