 @@ -1,14 +1,14 @@
-/*	$NetBSD: if_virt.c,v 1.18 2010/04/05 16:35:30 joerg Exp $	*/
+/*	$NetBSD: if_virt.c,v 1.19 2010/08/10 18:06:10 pooka Exp $	*/
 /*
  * Copyright (c) 2008 Antti Kantee.  All Rights Reserved.
+ *
  * 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.
  * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
  *    documentation and/or other materials provided with the distribution.
+ *
 @@ -16,27 +16,27 @@
  * 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 AUTHOR 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>
-__KERNEL_RCSID(0, "$NetBSD: if_virt.c,v 1.18 2010/04/05 16:35:30 joerg Exp $");
+__KERNEL_RCSID(0, "$NetBSD: if_virt.c,v 1.19 2010/08/10 18:06:10 pooka Exp $");
 #include <sys/param.h>
 #include <sys/condvar.h>
 #include <sys/fcntl.h>
 #include <sys/kmem.h>
 #include <sys/kthread.h>
 #include <sys/mutex.h>
 #include <sys/poll.h>
 #include <sys/sockio.h>
 #include <sys/socketvar.h>
 #include <net/bpf.h>
 #include <net/if.h>
 @@ -100,27 +100,28 @@ configaddr(struct ifnet *ifp, struct ifa
 int
 rump_virtif_create(int num)
+{
 	struct virtif_sc *sc;
 	struct ifnet *ifp;
 	uint8_t enaddr[ETHER_ADDR_LEN] = { 0xb2, 0x0a, 0x00, 0x0b, 0x0e, 0x01 };
 	char tapdev[16];
 	int fd, error;
 	snprintf(tapdev, sizeof(tapdev), "/dev/tap%d", num);
 	fd = rumpuser_open(tapdev, O_RDWR, &error);
 	if (fd == -1) {
-		printf("virtif_create: can't open /dev/tap %d\n", error);
+		printf("virtif_create: can't open /dev/tap%d: %d\n",
 		    num, error);
 		return error;
+	}
 	KASSERT(num < 0x100);
 	enaddr[2] = arc4random() & 0xff;
 	enaddr[5] = num;
 	sc = kmem_zalloc(sizeof(*sc), KM_SLEEP);
 	sc->sc_tapfd = fd;
 	ifp = &sc->sc_ec.ec_if;
 	sprintf(ifp->if_xname, "%s%d", VIRTIF_BASE, num);
 	ifp->if_softc = sc;
 	ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_MULTICAST;
 @@ -202,44 +203,50 @@ virtif_worker(void *arg)
 	struct virtif_sc *sc = ifp->if_softc;
 	struct mbuf *m;
 	size_t plen = ETHER_MAX_LEN_JUMBO+1;
 	ssize_t n;
 	int error;
 	for (;;) {
 		m = m_gethdr(M_WAIT, MT_DATA);
 		MEXTMALLOC(m, plen, M_WAIT);
  again:
 		n = rumpuser_read(sc->sc_tapfd, mtod(m, void *), plen, &error);
 		KASSERT(n < ETHER_MAX_LEN_JUMBO);
-		if (n <= 0) {
+		if (__predict_false(n < 0)) {
 			/*
 			 * work around tap bug: /dev/tap is opened in
 			 * non-blocking mode if it previously was
 			 * non-blocking.
 			 */
 			if (n == -1 && error == EAGAIN) {
 				struct pollfd pfd;
 				pfd.fd = sc->sc_tapfd;
 				pfd.events = POLLIN;
 				rumpuser_poll(&pfd, 1, INFTIM, &error);
 				goto again;
+			}
 			m_freem(m);
 			break;
+		}
 		/* tap sometimes returns EOF.  don't sweat it and plow on */
 		if (__predict_false(n == 0))
 			goto again;
 		m->m_len = m->m_pkthdr.len = n;
 		m->m_pkthdr.rcvif = ifp;
 		bpf_mtap(ifp, m);
 		ether_input(ifp, m);
+	}
 	panic("virtif_workin is a lazy boy %d\n", error);
+}
 /* lazy bum stetson-harrison magic value */
 #define LB_SH 32
 static void
 virtif_sender(void *arg)