===================================================================
RCS file: /cvsrepo/anoncvs/cvs/src/usr.bin/tcpbench/tcpbench.c,v
retrieving revision 1.29
retrieving revision 1.30
diff -u -r1.29 -r1.30
--- src/usr.bin/tcpbench/tcpbench.c	2011/12/18 02:42:53	1.29
+++ src/usr.bin/tcpbench/tcpbench.c	2012/01/26 17:53:53	1.30
@@ -176,7 +176,7 @@
 	    "usage: tcpbench -l\n"
 	    "       tcpbench [-uv] [-B buf] [-b addr] [-k kvars] [-n connections]\n"
 	    "                [-p port] [-r interval] [-S space] [-T toskeyword]\n"
-	    "                [-V rtable] hostname\n"
+	    "                [-t secs] [-V rtable] hostname\n"
 	    "       tcpbench -s [-uv] [-B buf] [-k kvars] [-p port]\n"
 	    "                [-r interval] [-S space] [-T toskeyword] [-V rtable]\n");
 	exit(1);
@@ -967,11 +967,19 @@
 	return (0);
 }
 
+static void
+quit(int sig, short event, void *arg)
+{
+	exit(0);
+}
+
 int
 main(int argc, char **argv)
 {
 	extern int optind;
 	extern char *optarg;
+	struct timeval tv;
+	unsigned int secs;
 
 	char kerr[_POSIX2_LINE_MAX], *tmp;
 	struct addrinfo *aitop, *aib, hints;
@@ -980,7 +988,7 @@
 	int ch, herr, nconn;
 	struct nlist nl[] = { { "_tcbtable" }, { "" } };
 	const char *host = NULL, *port = DEFAULT_PORT, *srcbind = NULL;
-	struct event ev_sigint, ev_sigterm, ev_sighup;
+	struct event ev_sigint, ev_sigterm, ev_sighup, ev_progtimer;
 	struct statctx *udp_sc = NULL;
 
 	/* Init world */
@@ -994,8 +1002,9 @@
 	ptb->Tflag = -1;
 	nconn = 1;
 	aib = NULL;
+	secs = 0;
 
-	while ((ch = getopt(argc, argv, "b:B:hlk:n:p:r:sS:T:uvV:")) != -1) {
+	while ((ch = getopt(argc, argv, "b:B:hlk:n:p:r:sS:t:T:uvV:")) != -1) {
 		switch (ch) {
 		case 'b':
 			srcbind = optarg;
@@ -1068,6 +1077,12 @@
 			if (ptb->Tflag == -1 || ptb->Tflag > 255 || errstr)
 				errx(1, "illegal tos value %s", optarg);
 			break;
+		case 't':
+			secs = strtonum(optarg, 1, UINT_MAX, &errstr);
+			if (errstr != NULL)
+				errx(1, "secs is %s: %s",
+				    errstr, optarg);
+			break;
 		case 'h':
 		default:
 			usage();
@@ -1171,8 +1186,15 @@
 
 	if (ptb->sflag)
 		server_init(aitop, udp_sc);
-	else
+	else {
+		if (secs > 0) {
+			timerclear(&tv);
+			tv.tv_sec = secs + 1;
+			evtimer_set(&ev_progtimer, quit, NULL);
+			evtimer_add(&ev_progtimer, &tv);
+		}
 		client_init(aitop, nconn, udp_sc, aib);
+	}
 	
 	/* libevent main loop*/
 	event_dispatch();