Home | History | Annotate | Line # | Download | only in net
if_tun.c revision 1.63
      1  1.62   darrenr /*	$NetBSD: if_tun.c,v 1.63 2003/06/29 22:31:51 fvdl Exp $	*/
      2  1.14       cgd 
      3   1.1       cgd /*
      4   1.8   deraadt  * Copyright (c) 1988, Julian Onions <jpo (at) cs.nott.ac.uk>
      5   1.8   deraadt  * Nottingham University 1987.
      6   1.1       cgd  *
      7   1.1       cgd  * This source may be freely distributed, however I would be interested
      8   1.1       cgd  * in any changes that are made.
      9   1.6   deraadt  *
     10   1.1       cgd  * This driver takes packets off the IP i/f and hands them up to a
     11  1.21    scottr  * user process to have its wicked way with. This driver has its
     12   1.1       cgd  * roots in a similar driver written by Phil Cockcroft (formerly) at
     13  1.27   mycroft  * UCL. This driver is based much more on read/write/poll mode of
     14   1.1       cgd  * operation though.
     15   1.1       cgd  */
     16  1.48     lukem 
     17  1.48     lukem #include <sys/cdefs.h>
     18  1.62   darrenr __KERNEL_RCSID(0, "$NetBSD: if_tun.c,v 1.63 2003/06/29 22:31:51 fvdl Exp $");
     19   1.1       cgd 
     20   1.8   deraadt #include "tun.h"
     21  1.33  jonathan 
     22  1.33  jonathan #include "opt_inet.h"
     23  1.34  jonathan #include "opt_ns.h"
     24   1.8   deraadt 
     25   1.6   deraadt #include <sys/param.h>
     26   1.8   deraadt #include <sys/proc.h>
     27   1.6   deraadt #include <sys/systm.h>
     28   1.6   deraadt #include <sys/mbuf.h>
     29   1.6   deraadt #include <sys/buf.h>
     30   1.6   deraadt #include <sys/protosw.h>
     31   1.6   deraadt #include <sys/socket.h>
     32   1.6   deraadt #include <sys/ioctl.h>
     33   1.6   deraadt #include <sys/errno.h>
     34   1.6   deraadt #include <sys/syslog.h>
     35   1.6   deraadt #include <sys/select.h>
     36  1.27   mycroft #include <sys/poll.h>
     37   1.8   deraadt #include <sys/file.h>
     38  1.22  christos #include <sys/signalvar.h>
     39  1.23  christos #include <sys/conf.h>
     40   1.9   deraadt 
     41   1.9   deraadt #include <machine/cpu.h>
     42   1.6   deraadt 
     43   1.6   deraadt #include <net/if.h>
     44  1.30        is #include <net/if_ether.h>
     45   1.6   deraadt #include <net/netisr.h>
     46   1.6   deraadt #include <net/route.h>
     47   1.1       cgd 
     48  1.30        is 
     49   1.1       cgd #ifdef INET
     50   1.6   deraadt #include <netinet/in.h>
     51   1.6   deraadt #include <netinet/in_systm.h>
     52   1.6   deraadt #include <netinet/in_var.h>
     53   1.6   deraadt #include <netinet/ip.h>
     54  1.30        is #include <netinet/if_inarp.h>
     55   1.1       cgd #endif
     56   1.1       cgd 
     57   1.1       cgd #ifdef NS
     58   1.6   deraadt #include <netns/ns.h>
     59   1.6   deraadt #include <netns/ns_if.h>
     60   1.1       cgd #endif
     61   1.1       cgd 
     62   1.8   deraadt #include "bpfilter.h"
     63   1.8   deraadt #if NBPFILTER > 0
     64   1.8   deraadt #include <sys/time.h>
     65   1.8   deraadt #include <net/bpf.h>
     66   1.8   deraadt #endif
     67   1.8   deraadt 
     68   1.8   deraadt #include <net/if_tun.h>
     69   1.8   deraadt 
     70  1.29  christos #define TUNDEBUG	if (tundebug) printf
     71   1.6   deraadt int	tundebug = 0;
     72   1.1       cgd 
     73   1.6   deraadt extern int ifqmaxlen;
     74  1.22  christos void	tunattach __P((int));
     75  1.46    atatat LIST_HEAD(, tun_softc) tun_softc_list;
     76  1.46    atatat static struct simplelock tun_softc_lock;
     77   1.6   deraadt 
     78  1.22  christos int	tun_ioctl __P((struct ifnet *, u_long, caddr_t));
     79  1.22  christos int	tun_output __P((struct ifnet *, struct mbuf *, struct sockaddr *,
     80  1.22  christos 		       struct rtentry *rt));
     81  1.46    atatat int	tun_clone_create __P((struct if_clone *, int));
     82  1.46    atatat void	tun_clone_destroy __P((struct ifnet *));
     83   1.6   deraadt 
     84  1.46    atatat struct if_clone tun_cloner =
     85  1.46    atatat     IF_CLONE_INITIALIZER("tun", tun_clone_create, tun_clone_destroy);
     86  1.46    atatat 
     87  1.46    atatat static void tunattach0 __P((struct tun_softc *));
     88  1.26        pk static void tuninit __P((struct tun_softc *));
     89  1.50    itojun #ifdef ALTQ
     90  1.50    itojun static void tunstart __P((struct ifnet *));
     91  1.50    itojun #endif
     92  1.46    atatat static struct tun_softc *tun_find_unit __P((dev_t));
     93  1.53   gehenna 
     94  1.53   gehenna dev_type_open(tunopen);
     95  1.53   gehenna dev_type_close(tunclose);
     96  1.53   gehenna dev_type_read(tunread);
     97  1.53   gehenna dev_type_write(tunwrite);
     98  1.53   gehenna dev_type_ioctl(tunioctl);
     99  1.53   gehenna dev_type_poll(tunpoll);
    100  1.56  jdolecek dev_type_kqfilter(tunkqfilter);
    101  1.53   gehenna 
    102  1.53   gehenna const struct cdevsw tun_cdevsw = {
    103  1.53   gehenna 	tunopen, tunclose, tunread, tunwrite, tunioctl,
    104  1.56  jdolecek 	nostop, notty, tunpoll, nommap, tunkqfilter,
    105  1.53   gehenna };
    106   1.6   deraadt 
    107   1.8   deraadt void
    108   1.8   deraadt tunattach(unused)
    109   1.8   deraadt 	int unused;
    110   1.8   deraadt {
    111  1.46    atatat 
    112  1.46    atatat 	simple_lock_init(&tun_softc_lock);
    113  1.46    atatat 	LIST_INIT(&tun_softc_list);
    114  1.46    atatat 	if_clone_attach(&tun_cloner);
    115  1.46    atatat }
    116  1.46    atatat 
    117  1.46    atatat int
    118  1.46    atatat tun_clone_create(ifc, unit)
    119  1.46    atatat 	struct if_clone *ifc;
    120  1.46    atatat 	int unit;
    121  1.46    atatat {
    122  1.46    atatat 	struct tun_softc *sc;
    123  1.46    atatat 
    124  1.46    atatat 	sc = malloc(sizeof(struct tun_softc), M_DEVBUF, M_WAITOK);
    125  1.46    atatat 	(void)memset(sc, 0, sizeof(struct tun_softc));
    126  1.46    atatat 
    127  1.46    atatat 	(void)snprintf(sc->tun_if.if_xname, sizeof(sc->tun_if.if_xname),
    128  1.46    atatat 	    "%s%d", ifc->ifc_name, unit);
    129  1.46    atatat 	sc->tun_unit = unit;
    130  1.46    atatat 	simple_lock_init(&sc->tun_lock);
    131  1.46    atatat 
    132  1.46    atatat 	tunattach0(sc);
    133  1.46    atatat 
    134  1.46    atatat 	simple_lock(&tun_softc_lock);
    135  1.46    atatat 	LIST_INSERT_HEAD(&tun_softc_list, sc, tun_list);
    136  1.46    atatat 	simple_unlock(&tun_softc_lock);
    137  1.46    atatat 
    138  1.46    atatat 	return (0);
    139  1.46    atatat }
    140  1.46    atatat 
    141  1.46    atatat void
    142  1.46    atatat tunattach0(sc)
    143  1.46    atatat 	struct tun_softc *sc;
    144  1.46    atatat {
    145  1.46    atatat 	struct ifnet *ifp = (void *)sc;
    146  1.46    atatat 
    147  1.46    atatat 	sc->tun_flags = TUN_INITED;
    148  1.46    atatat 
    149  1.46    atatat 	ifp = &sc->tun_if;
    150  1.46    atatat 	ifp->if_softc = sc;
    151  1.46    atatat 	ifp->if_mtu = TUNMTU;
    152  1.46    atatat 	ifp->if_ioctl = tun_ioctl;
    153  1.46    atatat 	ifp->if_output = tun_output;
    154  1.50    itojun #ifdef ALTQ
    155  1.50    itojun 	ifp->if_start = tunstart;
    156  1.50    itojun #endif
    157  1.46    atatat 	ifp->if_flags = IFF_POINTOPOINT;
    158  1.46    atatat 	ifp->if_snd.ifq_maxlen = ifqmaxlen;
    159  1.46    atatat 	ifp->if_collisions = 0;
    160  1.46    atatat 	ifp->if_ierrors = 0;
    161  1.46    atatat 	ifp->if_oerrors = 0;
    162  1.46    atatat 	ifp->if_ipackets = 0;
    163  1.46    atatat 	ifp->if_opackets = 0;
    164  1.58  jdolecek 	ifp->if_ibytes   = 0;
    165  1.58  jdolecek 	ifp->if_obytes   = 0;
    166  1.46    atatat 	ifp->if_dlt = DLT_NULL;
    167  1.50    itojun 	IFQ_SET_READY(&ifp->if_snd);
    168  1.46    atatat 	if_attach(ifp);
    169  1.46    atatat 	if_alloc_sadl(ifp);
    170  1.46    atatat #if NBPFILTER > 0
    171  1.46    atatat 	bpfattach(ifp, DLT_NULL, sizeof(u_int32_t));
    172  1.46    atatat #endif
    173  1.46    atatat }
    174  1.46    atatat 
    175  1.46    atatat void
    176  1.46    atatat tun_clone_destroy(ifp)
    177   1.8   deraadt 	struct ifnet *ifp;
    178  1.46    atatat {
    179  1.46    atatat 	struct tun_softc *tp = (void *)ifp;
    180  1.46    atatat 	struct proc *p;
    181   1.8   deraadt 
    182  1.46    atatat 	simple_lock(&tun_softc_lock);
    183  1.46    atatat 	simple_lock(&tp->tun_lock);
    184  1.46    atatat 	LIST_REMOVE(tp, tun_list);
    185  1.46    atatat 	simple_unlock(&tp->tun_lock);
    186  1.46    atatat 	simple_unlock(&tun_softc_lock);
    187  1.46    atatat 
    188  1.46    atatat 	if (tp->tun_flags & TUN_RWAIT) {
    189  1.46    atatat 		tp->tun_flags &= ~TUN_RWAIT;
    190  1.46    atatat 		wakeup((caddr_t)tp);
    191  1.46    atatat 	}
    192  1.46    atatat 	if (tp->tun_flags & TUN_ASYNC && tp->tun_pgrp) {
    193  1.46    atatat 		if (tp->tun_pgrp > 0)
    194  1.46    atatat 			gsignal(tp->tun_pgrp, SIGIO);
    195  1.46    atatat 		else if ((p = pfind(-tp->tun_pgrp)) != NULL)
    196  1.46    atatat 			psignal(p, SIGIO);
    197  1.46    atatat 	}
    198  1.46    atatat 	selwakeup(&tp->tun_rsel);
    199   1.8   deraadt 
    200   1.8   deraadt #if NBPFILTER > 0
    201  1.46    atatat 	bpfdetach(ifp);
    202   1.8   deraadt #endif
    203  1.46    atatat 	if_detach(ifp);
    204  1.46    atatat 
    205  1.46    atatat 	free(tp, M_DEVBUF);
    206  1.46    atatat }
    207  1.46    atatat 
    208  1.46    atatat static struct tun_softc *
    209  1.46    atatat tun_find_unit(dev)
    210  1.46    atatat 	dev_t dev;
    211  1.46    atatat {
    212  1.46    atatat 	struct tun_softc *tp;
    213  1.46    atatat 	int unit = minor(dev);
    214  1.46    atatat 
    215  1.46    atatat 	simple_lock(&tun_softc_lock);
    216  1.46    atatat 	LIST_FOREACH(tp, &tun_softc_list, tun_list)
    217  1.46    atatat 		if (unit == tp->tun_unit)
    218  1.46    atatat 			break;
    219  1.46    atatat 	if (tp)
    220  1.46    atatat 		simple_lock(&tp->tun_lock);
    221  1.46    atatat 	simple_unlock(&tun_softc_lock);
    222  1.46    atatat 
    223  1.46    atatat 	return (tp);
    224   1.8   deraadt }
    225   1.8   deraadt 
    226   1.6   deraadt /*
    227   1.6   deraadt  * tunnel open - must be superuser & the device must be
    228   1.6   deraadt  * configured in
    229   1.6   deraadt  */
    230   1.6   deraadt int
    231  1.63      fvdl tunopen(dev, flag, mode, p)
    232   1.6   deraadt 	dev_t	dev;
    233   1.6   deraadt 	int	flag, mode;
    234  1.63      fvdl 	struct proc *p;
    235   1.6   deraadt {
    236   1.6   deraadt 	struct ifnet	*ifp;
    237   1.8   deraadt 	struct tun_softc *tp;
    238  1.46    atatat 	int	error;
    239   1.1       cgd 
    240  1.22  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    241   1.5   deraadt 		return (error);
    242   1.5   deraadt 
    243  1.46    atatat 	if (NTUN < 1)
    244   1.6   deraadt 		return (ENXIO);
    245  1.46    atatat 
    246  1.46    atatat 	tp = tun_find_unit(dev);
    247  1.52    atatat 
    248  1.52    atatat 	if (!tp) {
    249  1.52    atatat 		(void)tun_clone_create(&tun_cloner, minor(dev));
    250  1.52    atatat 		tp = tun_find_unit(dev);
    251  1.52    atatat 	}
    252  1.46    atatat 
    253  1.46    atatat 	if (!tp)
    254  1.46    atatat 		return (ENXIO);
    255  1.46    atatat 
    256  1.46    atatat 	if (tp->tun_flags & TUN_OPEN) {
    257  1.46    atatat 		simple_unlock(&tp->tun_lock);
    258  1.46    atatat 		return (EBUSY);
    259  1.46    atatat 	}
    260  1.46    atatat 
    261   1.6   deraadt 	ifp = &tp->tun_if;
    262   1.6   deraadt 	tp->tun_flags |= TUN_OPEN;
    263  1.24   thorpej 	TUNDEBUG("%s: open\n", ifp->if_xname);
    264  1.46    atatat 	simple_unlock(&tp->tun_lock);
    265   1.6   deraadt 	return (0);
    266   1.1       cgd }
    267   1.1       cgd 
    268   1.6   deraadt /*
    269   1.6   deraadt  * tunclose - close the device - mark i/f down & delete
    270   1.6   deraadt  * routing info
    271   1.6   deraadt  */
    272   1.6   deraadt int
    273  1.63      fvdl tunclose(dev, flag, mode, p)
    274   1.6   deraadt 	dev_t	dev;
    275   1.6   deraadt 	int	flag;
    276  1.22  christos 	int	mode;
    277  1.63      fvdl 	struct proc *p;
    278   1.6   deraadt {
    279  1.46    atatat 	int	s;
    280  1.46    atatat 	struct tun_softc *tp;
    281  1.46    atatat 	struct ifnet	*ifp;
    282   1.6   deraadt 
    283  1.46    atatat 	tp = tun_find_unit(dev);
    284  1.46    atatat 
    285  1.46    atatat 	/* interface was "destroyed" before the close */
    286  1.46    atatat 	if (tp == NULL)
    287  1.46    atatat 		return (0);
    288  1.46    atatat 
    289  1.46    atatat 	ifp = &tp->tun_if;
    290  1.46    atatat 
    291  1.10    andrew 	tp->tun_flags &= ~TUN_OPEN;
    292   1.6   deraadt 
    293   1.6   deraadt 	/*
    294   1.6   deraadt 	 * junk all pending output
    295   1.6   deraadt 	 */
    296  1.50    itojun 	s = splnet();
    297  1.50    itojun 	IFQ_PURGE(&ifp->if_snd);
    298  1.50    itojun 	splx(s);
    299   1.6   deraadt 
    300   1.6   deraadt 	if (ifp->if_flags & IFF_UP) {
    301  1.43   thorpej 		s = splnet();
    302   1.6   deraadt 		if_down(ifp);
    303   1.8   deraadt 		if (ifp->if_flags & IFF_RUNNING) {
    304  1.17   mycroft 			/* find internet addresses and delete routes */
    305  1.39  augustss 			struct ifaddr *ifa;
    306  1.47      matt 			TAILQ_FOREACH(ifa, &ifp->if_addrlist, ifa_list) {
    307  1.38    itojun #ifdef INET
    308  1.18   mycroft 				if (ifa->ifa_addr->sa_family == AF_INET) {
    309  1.18   mycroft 					rtinit(ifa, (int)RTM_DELETE,
    310  1.26        pk 					       tp->tun_flags & TUN_DSTADDR
    311  1.26        pk 							? RTF_HOST
    312  1.26        pk 							: 0);
    313  1.18   mycroft 				}
    314  1.38    itojun #endif
    315  1.11   deraadt 			}
    316   1.8   deraadt 		}
    317   1.6   deraadt 		splx(s);
    318   1.6   deraadt 	}
    319   1.6   deraadt 	tp->tun_pgrp = 0;
    320  1.56  jdolecek 	selnotify(&tp->tun_rsel, 0);
    321   1.6   deraadt 
    322  1.24   thorpej 	TUNDEBUG ("%s: closed\n", ifp->if_xname);
    323  1.46    atatat 	simple_unlock(&tp->tun_lock);
    324   1.6   deraadt 	return (0);
    325   1.1       cgd }
    326   1.1       cgd 
    327  1.26        pk static void
    328  1.24   thorpej tuninit(tp)
    329  1.24   thorpej 	struct tun_softc *tp;
    330   1.6   deraadt {
    331   1.6   deraadt 	struct ifnet	*ifp = &tp->tun_if;
    332  1.46    atatat 	struct ifaddr	*ifa;
    333   1.8   deraadt 
    334  1.24   thorpej 	TUNDEBUG("%s: tuninit\n", ifp->if_xname);
    335   1.6   deraadt 
    336   1.6   deraadt 	ifp->if_flags |= IFF_UP | IFF_RUNNING;
    337   1.8   deraadt 
    338  1.26        pk 	tp->tun_flags &= ~(TUN_IASET|TUN_DSTADDR);
    339  1.47      matt 	TAILQ_FOREACH(ifa, &ifp->if_addrlist, ifa_list) {
    340  1.38    itojun #ifdef INET
    341  1.11   deraadt 		if (ifa->ifa_addr->sa_family == AF_INET) {
    342  1.17   mycroft 			struct sockaddr_in *sin;
    343  1.11   deraadt 
    344  1.17   mycroft 			sin = satosin(ifa->ifa_addr);
    345  1.17   mycroft 			if (sin && sin->sin_addr.s_addr)
    346  1.17   mycroft 				tp->tun_flags |= TUN_IASET;
    347  1.17   mycroft 
    348  1.26        pk 			if (ifp->if_flags & IFF_POINTOPOINT) {
    349  1.26        pk 				sin = satosin(ifa->ifa_dstaddr);
    350  1.26        pk 				if (sin && sin->sin_addr.s_addr)
    351  1.26        pk 					tp->tun_flags |= TUN_DSTADDR;
    352  1.26        pk 			}
    353  1.11   deraadt 		}
    354  1.38    itojun #endif
    355  1.18   mycroft 	}
    356   1.8   deraadt 
    357  1.26        pk 	return;
    358   1.1       cgd }
    359   1.1       cgd 
    360   1.1       cgd /*
    361   1.1       cgd  * Process an ioctl request.
    362   1.1       cgd  */
    363   1.1       cgd int
    364  1.22  christos tun_ioctl(ifp, cmd, data)
    365   1.6   deraadt 	struct ifnet *ifp;
    366  1.25   mycroft 	u_long cmd;
    367   1.6   deraadt 	caddr_t	data;
    368   1.6   deraadt {
    369   1.6   deraadt 	int		error = 0, s;
    370  1.46    atatat 	struct tun_softc *tp = (struct tun_softc *)(ifp->if_softc);
    371  1.46    atatat 
    372  1.46    atatat 	simple_lock(&tp->tun_lock);
    373   1.6   deraadt 
    374  1.43   thorpej 	s = splnet();
    375  1.61    itojun 	switch (cmd) {
    376   1.6   deraadt 	case SIOCSIFADDR:
    377  1.24   thorpej 		tuninit((struct tun_softc *)(ifp->if_softc));
    378  1.24   thorpej 		TUNDEBUG("%s: address set\n", ifp->if_xname);
    379   1.6   deraadt 		break;
    380   1.6   deraadt 	case SIOCSIFDSTADDR:
    381  1.24   thorpej 		tuninit((struct tun_softc *)(ifp->if_softc));
    382  1.24   thorpej 		TUNDEBUG("%s: destination address set\n", ifp->if_xname);
    383   1.6   deraadt 		break;
    384  1.26        pk 	case SIOCSIFBRDADDR:
    385  1.26        pk 		TUNDEBUG("%s: broadcast address set\n", ifp->if_xname);
    386  1.26        pk 		break;
    387  1.31      matt 	case SIOCSIFMTU: {
    388  1.31      matt 		struct ifreq *ifr = (struct ifreq *) data;
    389  1.31      matt 		if (ifr->ifr_mtu > TUNMTU || ifr->ifr_mtu < 576) {
    390  1.31      matt 		    error = EINVAL;
    391  1.31      matt 		    break;
    392  1.31      matt 		}
    393  1.31      matt 		TUNDEBUG("%s: interface mtu set\n", ifp->if_xname);
    394  1.31      matt 		ifp->if_mtu = ifr->ifr_mtu;
    395  1.32      matt 		break;
    396  1.32      matt 	}
    397  1.32      matt 	case SIOCADDMULTI:
    398  1.32      matt 	case SIOCDELMULTI: {
    399  1.32      matt 		struct ifreq *ifr = (struct ifreq *) data;
    400  1.32      matt 		if (ifr == 0) {
    401  1.32      matt 	        	error = EAFNOSUPPORT;           /* XXX */
    402  1.32      matt 			break;
    403  1.32      matt 		}
    404  1.32      matt 		switch (ifr->ifr_addr.sa_family) {
    405  1.32      matt 
    406  1.32      matt #ifdef INET
    407  1.32      matt 		case AF_INET:
    408  1.32      matt 			break;
    409  1.32      matt #endif
    410  1.32      matt 
    411  1.32      matt 		default:
    412  1.32      matt 			error = EAFNOSUPPORT;
    413  1.32      matt 			break;
    414  1.32      matt 		}
    415  1.31      matt 		break;
    416  1.31      matt 	}
    417  1.38    itojun 	case SIOCSIFFLAGS:
    418  1.38    itojun 		break;
    419   1.6   deraadt 	default:
    420   1.6   deraadt 		error = EINVAL;
    421   1.6   deraadt 	}
    422   1.6   deraadt 	splx(s);
    423  1.46    atatat 	simple_unlock(&tp->tun_lock);
    424   1.6   deraadt 	return (error);
    425   1.1       cgd }
    426   1.1       cgd 
    427   1.1       cgd /*
    428  1.22  christos  * tun_output - queue packets from higher level ready to put out.
    429   1.1       cgd  */
    430   1.6   deraadt int
    431  1.22  christos tun_output(ifp, m0, dst, rt)
    432   1.6   deraadt 	struct ifnet   *ifp;
    433   1.6   deraadt 	struct mbuf    *m0;
    434   1.6   deraadt 	struct sockaddr *dst;
    435  1.12   deraadt 	struct rtentry *rt;
    436   1.6   deraadt {
    437  1.24   thorpej 	struct tun_softc *tp = ifp->if_softc;
    438   1.6   deraadt 	struct proc	*p;
    439  1.38    itojun #ifdef INET
    440   1.6   deraadt 	int		s;
    441  1.51    itojun 	int		error;
    442  1.38    itojun #endif
    443  1.58  jdolecek 	int		mlen;
    444  1.50    itojun 	ALTQ_DECL(struct altq_pktattr pktattr;)
    445   1.6   deraadt 
    446  1.46    atatat 	simple_lock(&tp->tun_lock);
    447  1.24   thorpej 	TUNDEBUG ("%s: tun_output\n", ifp->if_xname);
    448   1.1       cgd 
    449   1.8   deraadt 	if ((tp->tun_flags & TUN_READY) != TUN_READY) {
    450  1.24   thorpej 		TUNDEBUG ("%s: not ready 0%o\n", ifp->if_xname,
    451  1.24   thorpej 			  tp->tun_flags);
    452   1.8   deraadt 		m_freem (m0);
    453  1.46    atatat 		simple_unlock(&tp->tun_lock);
    454  1.26        pk 		return (EHOSTDOWN);
    455   1.8   deraadt 	}
    456   1.8   deraadt 
    457  1.50    itojun 	/*
    458  1.50    itojun 	 * if the queueing discipline needs packet classification,
    459  1.50    itojun 	 * do it before prepending link headers.
    460  1.50    itojun 	 */
    461  1.50    itojun 	IFQ_CLASSIFY(&ifp->if_snd, m0, dst->sa_family, &pktattr);
    462  1.50    itojun 
    463   1.8   deraadt #if NBPFILTER > 0
    464  1.40   thorpej 	if (ifp->if_bpf) {
    465   1.8   deraadt 		/*
    466   1.8   deraadt 		 * We need to prepend the address family as
    467   1.8   deraadt 		 * a four byte field.  Cons up a dummy header
    468   1.8   deraadt 		 * to pacify bpf.  This is safe because bpf
    469   1.8   deraadt 		 * will only read from the mbuf (i.e., it won't
    470   1.8   deraadt 		 * try to free it or keep a pointer to it).
    471   1.8   deraadt 		 */
    472   1.8   deraadt 		struct mbuf m;
    473  1.16       cgd 		u_int32_t af = dst->sa_family;
    474   1.8   deraadt 
    475  1.60    itojun 		m.m_flags = 0;
    476   1.8   deraadt 		m.m_next = m0;
    477  1.16       cgd 		m.m_len = sizeof(af);
    478   1.8   deraadt 		m.m_data = (char *)&af;
    479   1.8   deraadt 
    480  1.40   thorpej 		bpf_mtap(ifp->if_bpf, &m);
    481   1.8   deraadt 	}
    482   1.8   deraadt #endif
    483   1.8   deraadt 
    484   1.6   deraadt 	switch(dst->sa_family) {
    485   1.1       cgd #ifdef INET
    486   1.6   deraadt 	case AF_INET:
    487  1.26        pk 		if (tp->tun_flags & TUN_PREPADDR) {
    488  1.26        pk 			/* Simple link-layer header */
    489  1.26        pk 			M_PREPEND(m0, dst->sa_len, M_DONTWAIT);
    490  1.26        pk 			if (m0 == NULL) {
    491  1.26        pk 				IF_DROP(&ifp->if_snd);
    492  1.46    atatat 				simple_unlock(&tp->tun_lock);
    493  1.26        pk 				return (ENOBUFS);
    494  1.26        pk 			}
    495  1.26        pk 			bcopy(dst, mtod(m0, char *), dst->sa_len);
    496  1.26        pk 		}
    497  1.36  sommerfe 		/* FALLTHROUGH */
    498  1.36  sommerfe 	case AF_UNSPEC:
    499  1.43   thorpej 		s = splnet();
    500  1.50    itojun 		IFQ_ENQUEUE(&ifp->if_snd, m0, &pktattr, error);
    501  1.50    itojun 		if (error) {
    502   1.6   deraadt 			splx(s);
    503   1.6   deraadt 			ifp->if_collisions++;
    504  1.50    itojun 			return (error);
    505   1.6   deraadt 		}
    506  1.58  jdolecek 		mlen = m0->m_pkthdr.len;
    507   1.6   deraadt 		splx(s);
    508   1.6   deraadt 		ifp->if_opackets++;
    509  1.58  jdolecek 		ifp->if_obytes += mlen;
    510   1.6   deraadt 		break;
    511   1.1       cgd #endif
    512   1.6   deraadt 	default:
    513   1.6   deraadt 		m_freem(m0);
    514  1.46    atatat 		simple_unlock(&tp->tun_lock);
    515  1.26        pk 		return (EAFNOSUPPORT);
    516   1.6   deraadt 	}
    517   1.6   deraadt 
    518   1.6   deraadt 	if (tp->tun_flags & TUN_RWAIT) {
    519   1.6   deraadt 		tp->tun_flags &= ~TUN_RWAIT;
    520   1.6   deraadt 		wakeup((caddr_t)tp);
    521   1.6   deraadt 	}
    522   1.6   deraadt 	if (tp->tun_flags & TUN_ASYNC && tp->tun_pgrp) {
    523   1.6   deraadt 		if (tp->tun_pgrp > 0)
    524   1.6   deraadt 			gsignal(tp->tun_pgrp, SIGIO);
    525  1.22  christos 		else if ((p = pfind(-tp->tun_pgrp)) != NULL)
    526   1.6   deraadt 			psignal(p, SIGIO);
    527   1.6   deraadt 	}
    528  1.56  jdolecek 	selnotify(&tp->tun_rsel, 0);
    529  1.46    atatat 	simple_unlock(&tp->tun_lock);
    530  1.26        pk 	return (0);
    531   1.1       cgd }
    532   1.1       cgd 
    533   1.1       cgd /*
    534   1.1       cgd  * the cdevsw interface is now pretty minimal.
    535   1.1       cgd  */
    536   1.6   deraadt int
    537  1.63      fvdl tunioctl(dev, cmd, data, flag, p)
    538   1.6   deraadt 	dev_t		dev;
    539  1.15       cgd 	u_long		cmd;
    540   1.6   deraadt 	caddr_t		data;
    541   1.6   deraadt 	int		flag;
    542  1.63      fvdl 	struct proc	*p;
    543   1.6   deraadt {
    544  1.46    atatat 	int		s;
    545  1.46    atatat 	struct tun_softc *tp;
    546  1.59       dsl 	pid_t pgid;
    547  1.59       dsl 	int error;
    548  1.46    atatat 
    549  1.46    atatat 	tp = tun_find_unit(dev);
    550  1.46    atatat 
    551  1.46    atatat 	/* interface was "destroyed" already */
    552  1.46    atatat 	if (tp == NULL)
    553  1.46    atatat 		return (ENXIO);
    554   1.6   deraadt 
    555   1.6   deraadt 	switch (cmd) {
    556   1.6   deraadt 	case TUNSDEBUG:
    557   1.6   deraadt 		tundebug = *(int *)data;
    558   1.6   deraadt 		break;
    559  1.26        pk 
    560   1.6   deraadt 	case TUNGDEBUG:
    561   1.6   deraadt 		*(int *)data = tundebug;
    562   1.6   deraadt 		break;
    563  1.26        pk 
    564  1.26        pk 	case TUNSIFMODE:
    565  1.31      matt 		switch (*(int *)data & (IFF_POINTOPOINT|IFF_BROADCAST)) {
    566  1.26        pk 		case IFF_POINTOPOINT:
    567  1.26        pk 		case IFF_BROADCAST:
    568  1.43   thorpej 			s = splnet();
    569  1.26        pk 			if (tp->tun_if.if_flags & IFF_UP) {
    570  1.26        pk 				splx(s);
    571  1.46    atatat 				simple_unlock(&tp->tun_lock);
    572  1.26        pk 				return (EBUSY);
    573  1.26        pk 			}
    574  1.26        pk 			tp->tun_if.if_flags &=
    575  1.31      matt 				~(IFF_BROADCAST|IFF_POINTOPOINT|IFF_MULTICAST);
    576  1.26        pk 			tp->tun_if.if_flags |= *(int *)data;
    577  1.26        pk 			splx(s);
    578  1.26        pk 			break;
    579  1.26        pk 		default:
    580  1.46    atatat 			simple_unlock(&tp->tun_lock);
    581  1.26        pk 			return (EINVAL);
    582  1.26        pk 		}
    583  1.26        pk 		break;
    584  1.26        pk 
    585  1.26        pk 	case TUNSLMODE:
    586  1.26        pk 		if (*(int *)data)
    587  1.26        pk 			tp->tun_flags |= TUN_PREPADDR;
    588  1.26        pk 		else
    589  1.26        pk 			tp->tun_flags &= ~TUN_PREPADDR;
    590  1.26        pk 		break;
    591  1.26        pk 
    592   1.6   deraadt 	case FIONBIO:
    593   1.6   deraadt 		if (*(int *)data)
    594   1.6   deraadt 			tp->tun_flags |= TUN_NBIO;
    595   1.6   deraadt 		else
    596   1.6   deraadt 			tp->tun_flags &= ~TUN_NBIO;
    597   1.6   deraadt 		break;
    598  1.26        pk 
    599   1.6   deraadt 	case FIOASYNC:
    600   1.6   deraadt 		if (*(int *)data)
    601   1.6   deraadt 			tp->tun_flags |= TUN_ASYNC;
    602   1.6   deraadt 		else
    603   1.6   deraadt 			tp->tun_flags &= ~TUN_ASYNC;
    604   1.6   deraadt 		break;
    605  1.26        pk 
    606   1.6   deraadt 	case FIONREAD:
    607  1.43   thorpej 		s = splnet();
    608   1.6   deraadt 		if (tp->tun_if.if_snd.ifq_head)
    609  1.19        pk 			*(int *)data = tp->tun_if.if_snd.ifq_head->m_pkthdr.len;
    610   1.6   deraadt 		else
    611   1.6   deraadt 			*(int *)data = 0;
    612   1.6   deraadt 		splx(s);
    613   1.6   deraadt 		break;
    614  1.26        pk 
    615   1.6   deraadt 	case TIOCSPGRP:
    616  1.59       dsl 		pgid = *(int *)data;
    617  1.59       dsl 		if (pgid != 0) {
    618  1.63      fvdl 			error = pgid_in_session(p, pgid);
    619  1.59       dsl 			if (error != 0)
    620  1.59       dsl 				return error;
    621  1.59       dsl 		}
    622  1.59       dsl 		tp->tun_pgrp = pgid;
    623   1.6   deraadt 		break;
    624  1.26        pk 
    625   1.6   deraadt 	case TIOCGPGRP:
    626   1.6   deraadt 		*(int *)data = tp->tun_pgrp;
    627   1.6   deraadt 		break;
    628  1.26        pk 
    629   1.6   deraadt 	default:
    630  1.46    atatat 		simple_unlock(&tp->tun_lock);
    631   1.6   deraadt 		return (ENOTTY);
    632   1.6   deraadt 	}
    633  1.46    atatat 	simple_unlock(&tp->tun_lock);
    634   1.6   deraadt 	return (0);
    635   1.1       cgd }
    636   1.1       cgd 
    637   1.1       cgd /*
    638   1.6   deraadt  * The cdevsw read interface - reads a packet at a time, or at
    639   1.6   deraadt  * least as much of a packet as can be read.
    640   1.1       cgd  */
    641   1.6   deraadt int
    642  1.22  christos tunread(dev, uio, ioflag)
    643   1.6   deraadt 	dev_t		dev;
    644   1.6   deraadt 	struct uio	*uio;
    645  1.22  christos 	int		ioflag;
    646   1.6   deraadt {
    647  1.46    atatat 	struct tun_softc *tp;
    648  1.46    atatat 	struct ifnet	*ifp;
    649   1.6   deraadt 	struct mbuf	*m, *m0;
    650  1.46    atatat 	int		error=0, len, s, index;
    651  1.46    atatat 
    652  1.46    atatat 	tp = tun_find_unit(dev);
    653  1.46    atatat 
    654  1.46    atatat 	/* interface was "destroyed" already */
    655  1.46    atatat 	if (tp == NULL)
    656  1.46    atatat 		return (ENXIO);
    657  1.46    atatat 
    658  1.46    atatat 	index = tp->tun_if.if_index;
    659  1.46    atatat 	ifp = &tp->tun_if;
    660   1.6   deraadt 
    661  1.24   thorpej 	TUNDEBUG ("%s: read\n", ifp->if_xname);
    662   1.8   deraadt 	if ((tp->tun_flags & TUN_READY) != TUN_READY) {
    663  1.26        pk 		TUNDEBUG ("%s: not ready 0%o\n", ifp->if_xname, tp->tun_flags);
    664  1.46    atatat 		simple_unlock(&tp->tun_lock);
    665   1.8   deraadt 		return EHOSTDOWN;
    666   1.8   deraadt 	}
    667   1.8   deraadt 
    668   1.6   deraadt 	tp->tun_flags &= ~TUN_RWAIT;
    669   1.6   deraadt 
    670  1.43   thorpej 	s = splnet();
    671   1.6   deraadt 	do {
    672  1.50    itojun 		IFQ_DEQUEUE(&ifp->if_snd, m0);
    673   1.6   deraadt 		if (m0 == 0) {
    674   1.6   deraadt 			if (tp->tun_flags & TUN_NBIO) {
    675   1.6   deraadt 				splx(s);
    676  1.46    atatat 				simple_unlock(&tp->tun_lock);
    677  1.26        pk 				return (EWOULDBLOCK);
    678   1.6   deraadt 			}
    679   1.6   deraadt 			tp->tun_flags |= TUN_RWAIT;
    680  1.46    atatat 			simple_unlock(&tp->tun_lock);
    681  1.26        pk 			if (tsleep((caddr_t)tp, PZERO|PCATCH, "tunread", 0)) {
    682  1.26        pk 				splx(s);
    683  1.26        pk 				return (EINTR);
    684  1.46    atatat 			} else {
    685  1.46    atatat 				/*
    686  1.46    atatat 				 * Maybe the interface was destroyed while
    687  1.46    atatat 				 * we were sleeping, so let's ensure that
    688  1.46    atatat 				 * we're looking at the same (valid) tun
    689  1.46    atatat 				 * interface before looping.
    690  1.46    atatat 				 */
    691  1.46    atatat 				tp = tun_find_unit(dev);
    692  1.46    atatat 				if (tp == NULL ||
    693  1.46    atatat 				    tp->tun_if.if_index != index) {
    694  1.46    atatat 					splx(s);
    695  1.46    atatat 					if (tp)
    696  1.46    atatat 						simple_unlock(&tp->tun_lock);
    697  1.46    atatat 					return (ENXIO);
    698  1.46    atatat 				}
    699  1.26        pk 			}
    700   1.6   deraadt 		}
    701   1.6   deraadt 	} while (m0 == 0);
    702   1.6   deraadt 	splx(s);
    703   1.6   deraadt 
    704   1.6   deraadt 	while (m0 && uio->uio_resid > 0 && error == 0) {
    705  1.13   deraadt 		len = min(uio->uio_resid, m0->m_len);
    706  1.45    itojun 		if (len != 0)
    707  1.45    itojun 			error = uiomove(mtod(m0, caddr_t), len, uio);
    708   1.6   deraadt 		MFREE(m0, m);
    709   1.6   deraadt 		m0 = m;
    710   1.6   deraadt 	}
    711   1.6   deraadt 
    712   1.6   deraadt 	if (m0) {
    713   1.6   deraadt 		TUNDEBUG("Dropping mbuf\n");
    714   1.6   deraadt 		m_freem(m0);
    715   1.6   deraadt 	}
    716  1.19        pk 	if (error)
    717  1.19        pk 		ifp->if_ierrors++;
    718  1.46    atatat 	simple_unlock(&tp->tun_lock);
    719  1.26        pk 	return (error);
    720   1.1       cgd }
    721   1.1       cgd 
    722   1.1       cgd /*
    723   1.1       cgd  * the cdevsw write interface - an atomic write is a packet - or else!
    724   1.1       cgd  */
    725   1.6   deraadt int
    726  1.22  christos tunwrite(dev, uio, ioflag)
    727   1.8   deraadt 	dev_t		dev;
    728   1.6   deraadt 	struct uio	*uio;
    729  1.22  christos 	int		ioflag;
    730   1.6   deraadt {
    731  1.46    atatat 	struct tun_softc *tp;
    732  1.46    atatat 	struct ifnet	*ifp;
    733   1.6   deraadt 	struct mbuf	*top, **mp, *m;
    734  1.26        pk 	struct ifqueue	*ifq;
    735  1.26        pk 	struct sockaddr	dst;
    736  1.26        pk 	int		isr, error=0, s, tlen, mlen;
    737   1.6   deraadt 
    738  1.46    atatat 	tp = tun_find_unit(dev);
    739  1.46    atatat 
    740  1.46    atatat 	/* interface was "destroyed" already */
    741  1.46    atatat 	if (tp == NULL)
    742  1.46    atatat 		return (ENXIO);
    743  1.46    atatat 
    744  1.46    atatat 	ifp = &tp->tun_if;
    745  1.46    atatat 
    746  1.24   thorpej 	TUNDEBUG("%s: tunwrite\n", ifp->if_xname);
    747   1.6   deraadt 
    748  1.26        pk 	if (tp->tun_flags & TUN_PREPADDR) {
    749  1.46    atatat 		if (uio->uio_resid < sizeof(dst)) {
    750  1.46    atatat 			simple_unlock(&tp->tun_lock);
    751  1.26        pk 			return (EIO);
    752  1.46    atatat 		}
    753  1.26        pk 		error = uiomove((caddr_t)&dst, sizeof(dst), uio);
    754  1.26        pk 		if (dst.sa_len > sizeof(dst)) {
    755  1.26        pk 			/* Duh.. */
    756  1.26        pk 			char discard;
    757  1.26        pk 			int n = dst.sa_len - sizeof(dst);
    758  1.26        pk 			while (n--)
    759  1.46    atatat 				if ((error = uiomove(&discard, 1, uio)) != 0) {
    760  1.46    atatat 					simple_unlock(&tp->tun_lock);
    761  1.26        pk 					return (error);
    762  1.46    atatat 				}
    763  1.26        pk 		}
    764  1.26        pk 	} else {
    765  1.26        pk #ifdef INET
    766  1.26        pk 		dst.sa_family = AF_INET;
    767  1.26        pk #endif
    768  1.26        pk 	}
    769  1.26        pk 
    770  1.54    simonb 	if (uio->uio_resid > TUNMTU) {
    771  1.37    mjacob 		TUNDEBUG("%s: len=%lu!\n", ifp->if_xname,
    772  1.37    mjacob 		    (unsigned long)uio->uio_resid);
    773  1.46    atatat 		simple_unlock(&tp->tun_lock);
    774  1.26        pk 		return (EIO);
    775   1.6   deraadt 	}
    776  1.26        pk 
    777  1.26        pk 	switch (dst.sa_family) {
    778  1.26        pk #ifdef INET
    779  1.26        pk 	case AF_INET:
    780  1.26        pk 		ifq = &ipintrq;
    781  1.26        pk 		isr = NETISR_IP;
    782  1.26        pk 		break;
    783  1.26        pk #endif
    784  1.26        pk 	default:
    785  1.46    atatat 		simple_unlock(&tp->tun_lock);
    786  1.26        pk 		return (EAFNOSUPPORT);
    787  1.26        pk 	}
    788  1.26        pk 
    789   1.8   deraadt 	tlen = uio->uio_resid;
    790   1.8   deraadt 
    791   1.8   deraadt 	/* get a header mbuf */
    792   1.8   deraadt 	MGETHDR(m, M_DONTWAIT, MT_DATA);
    793  1.46    atatat 	if (m == NULL) {
    794  1.46    atatat 		simple_unlock(&tp->tun_lock);
    795  1.26        pk 		return (ENOBUFS);
    796  1.46    atatat 	}
    797   1.8   deraadt 	mlen = MHLEN;
    798   1.8   deraadt 
    799   1.6   deraadt 	top = 0;
    800   1.6   deraadt 	mp = &top;
    801   1.6   deraadt 	while (error == 0 && uio->uio_resid > 0) {
    802  1.13   deraadt 		m->m_len = min(mlen, uio->uio_resid);
    803   1.8   deraadt 		error = uiomove(mtod (m, caddr_t), m->m_len, uio);
    804   1.6   deraadt 		*mp = m;
    805   1.6   deraadt 		mp = &m->m_next;
    806   1.8   deraadt 		if (uio->uio_resid > 0) {
    807   1.8   deraadt 			MGET (m, M_DONTWAIT, MT_DATA);
    808   1.8   deraadt 			if (m == 0) {
    809   1.8   deraadt 				error = ENOBUFS;
    810   1.8   deraadt 				break;
    811   1.8   deraadt 			}
    812   1.8   deraadt 			mlen = MLEN;
    813   1.8   deraadt 		}
    814   1.6   deraadt 	}
    815   1.6   deraadt 	if (error) {
    816   1.6   deraadt 		if (top)
    817   1.8   deraadt 			m_freem (top);
    818  1.19        pk 		ifp->if_ierrors++;
    819  1.46    atatat 		simple_unlock(&tp->tun_lock);
    820  1.26        pk 		return (error);
    821   1.6   deraadt 	}
    822   1.6   deraadt 
    823   1.8   deraadt 	top->m_pkthdr.len = tlen;
    824   1.8   deraadt 	top->m_pkthdr.rcvif = ifp;
    825   1.8   deraadt 
    826   1.8   deraadt #if NBPFILTER > 0
    827  1.40   thorpej 	if (ifp->if_bpf) {
    828   1.8   deraadt 		/*
    829   1.8   deraadt 		 * We need to prepend the address family as
    830   1.8   deraadt 		 * a four byte field.  Cons up a dummy header
    831   1.8   deraadt 		 * to pacify bpf.  This is safe because bpf
    832   1.8   deraadt 		 * will only read from the mbuf (i.e., it won't
    833   1.8   deraadt 		 * try to free it or keep a pointer to it).
    834   1.8   deraadt 		 */
    835   1.8   deraadt 		struct mbuf m;
    836  1.16       cgd 		u_int32_t af = AF_INET;
    837   1.8   deraadt 
    838  1.60    itojun 		m.m_flags = 0;
    839   1.8   deraadt 		m.m_next = top;
    840  1.16       cgd 		m.m_len = sizeof(af);
    841   1.8   deraadt 		m.m_data = (char *)&af;
    842   1.8   deraadt 
    843  1.40   thorpej 		bpf_mtap(ifp->if_bpf, &m);
    844   1.6   deraadt 	}
    845   1.8   deraadt #endif
    846   1.6   deraadt 
    847  1.43   thorpej 	s = splnet();
    848  1.26        pk 	if (IF_QFULL(ifq)) {
    849  1.26        pk 		IF_DROP(ifq);
    850   1.6   deraadt 		splx(s);
    851   1.6   deraadt 		ifp->if_collisions++;
    852   1.6   deraadt 		m_freem(top);
    853  1.46    atatat 		simple_unlock(&tp->tun_lock);
    854  1.26        pk 		return (ENOBUFS);
    855   1.6   deraadt 	}
    856  1.26        pk 	IF_ENQUEUE(ifq, top);
    857   1.6   deraadt 	splx(s);
    858   1.6   deraadt 	ifp->if_ipackets++;
    859  1.58  jdolecek 	ifp->if_ibytes += tlen;
    860  1.26        pk 	schednetisr(isr);
    861  1.46    atatat 	simple_unlock(&tp->tun_lock);
    862  1.26        pk 	return (error);
    863   1.1       cgd }
    864   1.1       cgd 
    865  1.50    itojun #ifdef ALTQ
    866  1.50    itojun /*
    867  1.50    itojun  * Start packet transmission on the interface.
    868  1.50    itojun  * when the interface queue is rate-limited by ALTQ or TBR,
    869  1.50    itojun  * if_start is needed to drain packets from the queue in order
    870  1.50    itojun  * to notify readers when outgoing packets become ready.
    871  1.50    itojun  */
    872  1.50    itojun static void
    873  1.50    itojun tunstart(ifp)
    874  1.50    itojun 	struct ifnet *ifp;
    875  1.50    itojun {
    876  1.50    itojun 	struct tun_softc *tp = ifp->if_softc;
    877  1.50    itojun 	struct mbuf *m;
    878  1.50    itojun 	struct proc	*p;
    879  1.50    itojun 
    880  1.50    itojun 	if (!ALTQ_IS_ENABLED(&ifp->if_snd) && !TBR_IS_ENABLED(&ifp->if_snd))
    881  1.50    itojun 		return;
    882  1.50    itojun 
    883  1.50    itojun 	IFQ_POLL(&ifp->if_snd, m);
    884  1.50    itojun 	if (m != NULL) {
    885  1.50    itojun 		if (tp->tun_flags & TUN_RWAIT) {
    886  1.50    itojun 			tp->tun_flags &= ~TUN_RWAIT;
    887  1.50    itojun 			wakeup((caddr_t)tp);
    888  1.50    itojun 		}
    889  1.50    itojun 		if (tp->tun_flags & TUN_ASYNC && tp->tun_pgrp) {
    890  1.50    itojun 			if (tp->tun_pgrp > 0)
    891  1.50    itojun 				gsignal(tp->tun_pgrp, SIGIO);
    892  1.50    itojun 			else if ((p = pfind(-tp->tun_pgrp)) != NULL)
    893  1.50    itojun 				psignal(p, SIGIO);
    894  1.50    itojun 		}
    895  1.50    itojun 		selwakeup(&tp->tun_rsel);
    896  1.50    itojun 	}
    897  1.50    itojun }
    898  1.50    itojun #endif /* ALTQ */
    899   1.1       cgd /*
    900  1.27   mycroft  * tunpoll - the poll interface, this is only useful on reads
    901   1.6   deraadt  * really. The write detect always returns true, write never blocks
    902   1.6   deraadt  * anyway, it either accepts the packet or drops it.
    903   1.6   deraadt  */
    904   1.6   deraadt int
    905  1.63      fvdl tunpoll(dev, events, p)
    906   1.6   deraadt 	dev_t		dev;
    907  1.27   mycroft 	int		events;
    908  1.63      fvdl 	struct proc	*p;
    909   1.6   deraadt {
    910  1.46    atatat 	struct tun_softc *tp;
    911  1.46    atatat 	struct ifnet	*ifp;
    912  1.46    atatat 	int		s, revents = 0;
    913  1.46    atatat 
    914  1.46    atatat 	tp = tun_find_unit(dev);
    915  1.46    atatat 
    916  1.46    atatat 	/* interface was "destroyed" already */
    917  1.46    atatat 	if (tp == NULL)
    918  1.46    atatat 		return (0);
    919  1.46    atatat 
    920  1.46    atatat 	ifp = &tp->tun_if;
    921   1.6   deraadt 
    922  1.43   thorpej 	s = splnet();
    923  1.27   mycroft 	TUNDEBUG("%s: tunpoll\n", ifp->if_xname);
    924   1.6   deraadt 
    925  1.35     veego 	if (events & (POLLIN | POLLRDNORM)) {
    926  1.50    itojun 		if (IFQ_IS_EMPTY(&ifp->if_snd) == 0) {
    927  1.27   mycroft 			TUNDEBUG("%s: tunpoll q=%d\n", ifp->if_xname,
    928  1.24   thorpej 			    ifp->if_snd.ifq_len);
    929  1.27   mycroft 			revents |= events & (POLLIN | POLLRDNORM);
    930  1.27   mycroft 		} else {
    931  1.27   mycroft 			TUNDEBUG("%s: tunpoll waiting\n", ifp->if_xname);
    932  1.63      fvdl 			selrecord(p, &tp->tun_rsel);
    933   1.6   deraadt 		}
    934  1.35     veego 	}
    935  1.27   mycroft 
    936  1.27   mycroft 	if (events & (POLLOUT | POLLWRNORM))
    937  1.27   mycroft 		revents |= events & (POLLOUT | POLLWRNORM);
    938  1.27   mycroft 
    939   1.6   deraadt 	splx(s);
    940  1.46    atatat 	simple_unlock(&tp->tun_lock);
    941  1.27   mycroft 	return (revents);
    942  1.56  jdolecek }
    943  1.56  jdolecek 
    944  1.56  jdolecek static void
    945  1.56  jdolecek filt_tunrdetach(struct knote *kn)
    946  1.56  jdolecek {
    947  1.56  jdolecek 	struct tun_softc *tp = kn->kn_hook;
    948  1.56  jdolecek 	int s;
    949  1.56  jdolecek 
    950  1.56  jdolecek 	s = splnet();
    951  1.57  christos 	SLIST_REMOVE(&tp->tun_rsel.sel_klist, kn, knote, kn_selnext);
    952  1.56  jdolecek 	splx(s);
    953  1.56  jdolecek }
    954  1.56  jdolecek 
    955  1.56  jdolecek static int
    956  1.56  jdolecek filt_tunread(struct knote *kn, long hint)
    957  1.56  jdolecek {
    958  1.56  jdolecek 	struct tun_softc *tp = kn->kn_hook;
    959  1.56  jdolecek 	struct ifnet *ifp = &tp->tun_if;
    960  1.56  jdolecek 	struct mbuf *m;
    961  1.56  jdolecek 	int s;
    962  1.56  jdolecek 
    963  1.56  jdolecek 	s = splnet();
    964  1.56  jdolecek 	IF_POLL(&ifp->if_snd, m);
    965  1.56  jdolecek 	if (m == NULL) {
    966  1.56  jdolecek 		splx(s);
    967  1.56  jdolecek 		return (0);
    968  1.56  jdolecek 	}
    969  1.56  jdolecek 
    970  1.56  jdolecek 	for (kn->kn_data = 0; m != NULL; m = m->m_next)
    971  1.56  jdolecek 		kn->kn_data += m->m_len;
    972  1.56  jdolecek 
    973  1.56  jdolecek 	splx(s);
    974  1.56  jdolecek 	return (1);
    975  1.56  jdolecek }
    976  1.56  jdolecek 
    977  1.56  jdolecek static const struct filterops tunread_filtops =
    978  1.56  jdolecek 	{ 1, NULL, filt_tunrdetach, filt_tunread };
    979  1.56  jdolecek 
    980  1.56  jdolecek static const struct filterops tun_seltrue_filtops =
    981  1.56  jdolecek 	{ 1, NULL, filt_tunrdetach, filt_seltrue };
    982  1.56  jdolecek 
    983  1.56  jdolecek int
    984  1.56  jdolecek tunkqfilter(dev_t dev, struct knote *kn)
    985  1.56  jdolecek {
    986  1.56  jdolecek 	struct tun_softc *tp = tun_find_unit(dev);
    987  1.56  jdolecek 	struct klist *klist;
    988  1.56  jdolecek 	int s;
    989  1.56  jdolecek 
    990  1.56  jdolecek 	switch (kn->kn_filter) {
    991  1.56  jdolecek 	case EVFILT_READ:
    992  1.57  christos 		klist = &tp->tun_rsel.sel_klist;
    993  1.56  jdolecek 		kn->kn_fop = &tunread_filtops;
    994  1.56  jdolecek 		break;
    995  1.56  jdolecek 
    996  1.56  jdolecek 	case EVFILT_WRITE:
    997  1.57  christos 		klist = &tp->tun_rsel.sel_klist;
    998  1.56  jdolecek 		kn->kn_fop = &tun_seltrue_filtops;
    999  1.56  jdolecek 		break;
   1000  1.56  jdolecek 
   1001  1.56  jdolecek 	default:
   1002  1.56  jdolecek 		return (1);
   1003  1.56  jdolecek 	}
   1004  1.56  jdolecek 
   1005  1.56  jdolecek 	kn->kn_hook = tp;
   1006  1.56  jdolecek 
   1007  1.56  jdolecek 	s = splnet();
   1008  1.56  jdolecek 	SLIST_INSERT_HEAD(klist, kn, kn_selnext);
   1009  1.56  jdolecek 	splx(s);
   1010  1.56  jdolecek 
   1011  1.56  jdolecek 	return (0);
   1012   1.1       cgd }
   1013