Tue Jan 24 20:24:59 2017 UTC ()

output every 5 seconds instead of 60 or every 100 packets


(christos)

diff -r1.6 -r1.7 src/usr.sbin/npf/npfd/npfd.c

--- src/usr.sbin/npf/npfd/npfd.c 2017/01/07 16:48:03	1.6
+++ src/usr.sbin/npf/npfd/npfd.c 2017/01/24 20:24:59	1.7

 @@ -1,14 +1,14 @@
-/*	$NetBSD: npfd.c,v 1.6 2017/01/07 16:48:03 christos Exp $	*/
+/*	$NetBSD: npfd.c,v 1.7 2017/01/24 20:24:59 christos Exp $	*/
 /*-
  * Copyright (c) 2015 The NetBSD Foundation, Inc.
  * All rights reserved.
+ *
  * This code is derived from software contributed to The NetBSD Foundation
  * by Mindaugas Rasiukevicius.
+ *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
 @@ -20,27 +20,27 @@
  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  * POSSIBILITY OF SUCH DAMAGE.
  */
 #include <sys/cdefs.h>
-__RCSID("$NetBSD: npfd.c,v 1.6 2017/01/07 16:48:03 christos Exp $");
+__RCSID("$NetBSD: npfd.c,v 1.7 2017/01/24 20:24:59 christos Exp $");
 #include <stdio.h>
 #include <string.h>
 #include <fcntl.h>
 #include <signal.h>
 #include <stdlib.h>
 #include <unistd.h>
 #include <stdbool.h>
 #include <poll.h>
 #include <errno.h>
 #include <err.h>
 #include <syslog.h>
 #include <util.h>
 @@ -65,54 +65,61 @@ npfd_getctl(void)
+	}
 	if (ver != NPF_VERSION) {
 		errx(EXIT_FAILURE,
 		    "Incompatible NPF interface version (%d, kernel %d)\n"
 		    "Hint: update userland?", NPF_VERSION, ver);
+	}
 	return fd;
+}
 static void
 npfd_event_loop(npfd_log_t *log, int delay)
+{
 	struct pollfd pfd;
 	size_t count = 0;
 	pfd.fd = npfd_log_getsock(log);
 	pfd.events = POLLHUP | POLLIN;
 	while  (!done) {
 		if (hup) {
 			hup = false;
 			npfd_log_reopen(log, false);
+		}
 		if (stats) {
 			stats = false;
 			npfd_log_stats(log);
+		}
 		if (flush) {
 			flush = false;
 			npfd_log_flush(log);
 			count = 0;
+		}
 		switch (poll(&pfd, 1, delay)) {
 		case -1:
 			if (errno == EINTR)
 				continue;
 			syslog(LOG_ERR, "poll failed: %m");
 			exit(EXIT_FAILURE);
 			/*NOTREACHED*/
 		case 0:
 			npfd_log_flush(log);
 			count = 0;
 			continue;
 		default:
 			if (count++ >= 100) {
 				npfd_log_flush(log);
 				count = 0;
+			}
 			npfd_log(log);
+		}
+	}
 	npfd_log_destroy(log);
+}
 static void
 sighandler(int sig)
+{
 	switch (sig) {
 	case SIGHUP:
 		hup = true;
 @@ -158,27 +165,27 @@ copyargs(int argc, char **argv)
 		memcpy(buf + p, argv[i], l);
 		p += l;
 		buf[p++] = i == argc - 1 ? '\0' : ' ';
+	}
 	return buf;
+}
 int
 main(int argc, char **argv)
+{
 	bool daemon_off = false;
 	int ch;
-	int delay = 60 * 1000;
+	int delay = 5 * 1000;
 	const char *iface = "npflog0";
 	int snaplen = 116;
 	char *pidname = NULL;
 	char *filename = NULL;
 	int fd = npfd_getctl();
 	(void)close(fd);
 	while ((ch = getopt(argc, argv, "Dd:f:i:p:s:")) != -1) {
 		switch (ch) {
 		case 'D':
 			daemon_off = true;
 			break;