xref: /netbsd-src/sys/net/bpf.c (revision 481fca6e59249d8ffcf24fef7cfbe7b131bfb080)
1 /*	$NetBSD: bpf.c,v 1.58 2000/07/04 18:46:49 thorpej Exp $	*/
2 
3 /*
4  * Copyright (c) 1990, 1991, 1993
5  *	The Regents of the University of California.  All rights reserved.
6  *
7  * This code is derived from the Stanford/CMU enet packet filter,
8  * (net/enet.c) distributed as part of 4.3BSD, and code contributed
9  * to Berkeley by Steven McCanne and Van Jacobson both of Lawrence
10  * Berkeley Laboratory.
11  *
12  * Redistribution and use in source and binary forms, with or without
13  * modification, are permitted provided that the following conditions
14  * are met:
15  * 1. Redistributions of source code must retain the above copyright
16  *    notice, this list of conditions and the following disclaimer.
17  * 2. Redistributions in binary form must reproduce the above copyright
18  *    notice, this list of conditions and the following disclaimer in the
19  *    documentation and/or other materials provided with the distribution.
20  * 3. All advertising materials mentioning features or use of this software
21  *    must display the following acknowledgement:
22  *	This product includes software developed by the University of
23  *	California, Berkeley and its contributors.
24  * 4. Neither the name of the University nor the names of its contributors
25  *    may be used to endorse or promote products derived from this software
26  *    without specific prior written permission.
27  *
28  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
29  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
30  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
31  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
32  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
33  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
34  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
35  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
36  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
37  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
38  * SUCH DAMAGE.
39  *
40  *	@(#)bpf.c	8.4 (Berkeley) 1/9/95
41  * static char rcsid[] =
42  * "Header: bpf.c,v 1.67 96/09/26 22:00:52 leres Exp ";
43  */
44 
45 #include "bpfilter.h"
46 
47 #include <sys/param.h>
48 #include <sys/systm.h>
49 #include <sys/mbuf.h>
50 #include <sys/buf.h>
51 #include <sys/time.h>
52 #include <sys/proc.h>
53 #include <sys/user.h>
54 #include <sys/ioctl.h>
55 #include <sys/map.h>
56 #include <sys/conf.h>
57 #include <sys/vnode.h>
58 
59 #include <sys/file.h>
60 #include <sys/tty.h>
61 #include <sys/uio.h>
62 
63 #include <sys/protosw.h>
64 #include <sys/socket.h>
65 #include <sys/errno.h>
66 #include <sys/kernel.h>
67 #include <sys/poll.h>
68 
69 #include <net/if.h>
70 
71 #include <net/bpf.h>
72 #include <net/bpfdesc.h>
73 
74 #include <net/if_arc.h>
75 #include <net/if_ether.h>
76 
77 #include <netinet/in.h>
78 #include <netinet/if_inarp.h>
79 
80 #ifndef BPF_BUFSIZE
81 # define BPF_BUFSIZE 8192		/* 4096 too small for FDDI frames */
82 #endif
83 
84 #define PRINET  26			/* interruptible */
85 
86 /*
87  * The default read buffer size is patchable.
88  */
89 int bpf_bufsize = BPF_BUFSIZE;
90 
91 /*
92  *  bpf_iflist is the list of interfaces; each corresponds to an ifnet
93  *  bpf_dtab holds the descriptors, indexed by minor device #
94  */
95 struct bpf_if	*bpf_iflist;
96 struct bpf_d	bpf_dtab[NBPFILTER];
97 
98 static int	bpf_allocbufs __P((struct bpf_d *));
99 static void	bpf_freed __P((struct bpf_d *));
100 static void	bpf_ifname __P((struct ifnet *, struct ifreq *));
101 static void	*bpf_mcpy __P((void *, const void *, size_t));
102 static int	bpf_movein __P((struct uio *, int, int,
103 			        struct mbuf **, struct sockaddr *));
104 static void	bpf_attachd __P((struct bpf_d *, struct bpf_if *));
105 static void	bpf_detachd __P((struct bpf_d *));
106 static int	bpf_setif __P((struct bpf_d *, struct ifreq *));
107 int		bpfpoll __P((dev_t, int, struct proc *));
108 static __inline void
109 		bpf_wakeup __P((struct bpf_d *));
110 static void	catchpacket __P((struct bpf_d *, u_char *, u_int, u_int,
111 				 void *(*)(void *, const void *, size_t)));
112 static void	reset_d __P((struct bpf_d *));
113 
114 static int
115 bpf_movein(uio, linktype, mtu, mp, sockp)
116 	struct uio *uio;
117 	int linktype;
118 	int mtu;
119 	struct mbuf **mp;
120 	struct sockaddr *sockp;
121 {
122 	struct mbuf *m;
123 	int error;
124 	int len;
125 	int hlen;
126 	int align;
127 
128 	/*
129 	 * Build a sockaddr based on the data link layer type.
130 	 * We do this at this level because the ethernet header
131 	 * is copied directly into the data field of the sockaddr.
132 	 * In the case of SLIP, there is no header and the packet
133 	 * is forwarded as is.
134 	 * Also, we are careful to leave room at the front of the mbuf
135 	 * for the link level header.
136 	 */
137 	switch (linktype) {
138 
139 	case DLT_SLIP:
140 		sockp->sa_family = AF_INET;
141 		hlen = 0;
142 		align = 0;
143 		break;
144 
145 	case DLT_PPP:
146 		sockp->sa_family = AF_UNSPEC;
147 		hlen = 0;
148 		align = 0;
149 		break;
150 
151 	case DLT_EN10MB:
152 		sockp->sa_family = AF_UNSPEC;
153 		/* XXX Would MAXLINKHDR be better? */
154  		/* 6(dst)+6(src)+2(type) */
155 		hlen = sizeof(struct ether_header);
156 		align = 2;
157 		break;
158 
159 	case DLT_ARCNET:
160 		sockp->sa_family = AF_UNSPEC;
161 		hlen = ARC_HDRLEN;
162 		align = 5;
163 		break;
164 
165 	case DLT_FDDI:
166 		sockp->sa_family = AF_LINK;
167 		/* XXX 4(FORMAC)+6(dst)+6(src) */
168 		hlen = 16;
169 		align = 0;
170 		break;
171 
172 	case DLT_NULL:
173 		sockp->sa_family = AF_UNSPEC;
174 		hlen = 0;
175 		align = 0;
176 		break;
177 
178 	default:
179 		return (EIO);
180 	}
181 
182 	len = uio->uio_resid;
183 	/*
184 	 * If there aren't enough bytes for a link level header or the
185 	 * packet length exceeds the interface mtu, return an error.
186 	 */
187 	if (len < hlen || len - hlen > mtu)
188 		return (EMSGSIZE);
189 
190 	/*
191 	 * XXX Avoid complicated buffer chaining ---
192 	 * bail if it won't fit in a single mbuf.
193 	 * (Take into account possible alignment bytes)
194 	 */
195 	if ((unsigned)len > MCLBYTES - align)
196 		return (EIO);
197 
198 	MGETHDR(m, M_WAIT, MT_DATA);
199 	if (m == 0)
200 		return (ENOBUFS);
201 	m->m_pkthdr.rcvif = 0;
202 	m->m_pkthdr.len = len - hlen;
203 	if (len > MHLEN - align) {
204 		MCLGET(m, M_WAIT);
205 		if ((m->m_flags & M_EXT) == 0) {
206 			error = ENOBUFS;
207 			goto bad;
208 		}
209 	}
210 
211 	/* Insure the data is properly aligned */
212 	if (align > 0) {
213 		m->m_data += align;
214 		m->m_len -= align;
215 	}
216 
217 	error = uiomove(mtod(m, caddr_t), len, uio);
218 	if (error)
219 		goto bad;
220 	if (hlen != 0) {
221 		memcpy(sockp->sa_data, mtod(m, caddr_t), hlen);
222 		m->m_data += hlen; /* XXX */
223 		len -= hlen;
224 	}
225 	m->m_len = len;
226 	*mp = m;
227 	return (0);
228 
229 bad:
230 	m_freem(m);
231 	return (error);
232 }
233 
234 /*
235  * Attach file to the bpf interface, i.e. make d listen on bp.
236  * Must be called at splimp.
237  */
238 static void
239 bpf_attachd(d, bp)
240 	struct bpf_d *d;
241 	struct bpf_if *bp;
242 {
243 	/*
244 	 * Point d at bp, and add d to the interface's list of listeners.
245 	 * Finally, point the driver's bpf cookie at the interface so
246 	 * it will divert packets to bpf.
247 	 */
248 	d->bd_bif = bp;
249 	d->bd_next = bp->bif_dlist;
250 	bp->bif_dlist = d;
251 
252 	*bp->bif_driverp = bp;
253 }
254 
255 /*
256  * Detach a file from its interface.
257  */
258 static void
259 bpf_detachd(d)
260 	struct bpf_d *d;
261 {
262 	struct bpf_d **p;
263 	struct bpf_if *bp;
264 
265 	bp = d->bd_bif;
266 	/*
267 	 * Check if this descriptor had requested promiscuous mode.
268 	 * If so, turn it off.
269 	 */
270 	if (d->bd_promisc) {
271 		int error;
272 
273 		d->bd_promisc = 0;
274 		/*
275 		 * Take device out of promiscuous mode.  Since we were
276 		 * able to enter promiscuous mode, we should be able
277 		 * to turn it off.  But we can get an error if
278 		 * the interface was configured down, so only panic
279 		 * if we don't get an unexpected error.
280 		 */
281   		error = ifpromisc(bp->bif_ifp, 0);
282 		if (error && error != EINVAL)
283 			panic("bpf: ifpromisc failed");
284 	}
285 	/* Remove d from the interface's descriptor list. */
286 	p = &bp->bif_dlist;
287 	while (*p != d) {
288 		p = &(*p)->bd_next;
289 		if (*p == 0)
290 			panic("bpf_detachd: descriptor not in list");
291 	}
292 	*p = (*p)->bd_next;
293 	if (bp->bif_dlist == 0)
294 		/*
295 		 * Let the driver know that there are no more listeners.
296 		 */
297 		*d->bd_bif->bif_driverp = 0;
298 	d->bd_bif = 0;
299 }
300 
301 
302 /*
303  * Mark a descriptor free by making it point to itself.
304  * This is probably cheaper than marking with a constant since
305  * the address should be in a register anyway.
306  */
307 #define D_ISFREE(d) ((d) == (d)->bd_next)
308 #define D_MARKFREE(d) ((d)->bd_next = (d))
309 #define D_MARKUSED(d) ((d)->bd_next = 0)
310 
311 /*
312  * bpfilterattach() is called at boot time.
313  */
314 /* ARGSUSED */
315 void
316 bpfilterattach(n)
317 	int n;
318 {
319 	int i;
320 	/*
321 	 * Mark all the descriptors free.
322 	 */
323 	for (i = 0; i < NBPFILTER; ++i)
324 		D_MARKFREE(&bpf_dtab[i]);
325 
326 }
327 
328 /*
329  * Open ethernet device.  Returns ENXIO for illegal minor device number,
330  * EBUSY if file is open by another process.
331  */
332 /* ARGSUSED */
333 int
334 bpfopen(dev, flag, mode, p)
335 	dev_t dev;
336 	int flag;
337 	int mode;
338 	struct proc *p;
339 {
340 	struct bpf_d *d;
341 
342 	if (minor(dev) >= NBPFILTER)
343 		return (ENXIO);
344 	/*
345 	 * Each minor can be opened by only one process.  If the requested
346 	 * minor is in use, return EBUSY.
347 	 */
348 	d = &bpf_dtab[minor(dev)];
349 	if (!D_ISFREE(d))
350 		return (EBUSY);
351 
352 	/* Mark "free" and do most initialization. */
353 	memset((char *)d, 0, sizeof(*d));
354 	d->bd_bufsize = bpf_bufsize;
355 
356 	return (0);
357 }
358 
359 /*
360  * Close the descriptor by detaching it from its interface,
361  * deallocating its buffers, and marking it free.
362  */
363 /* ARGSUSED */
364 int
365 bpfclose(dev, flag, mode, p)
366 	dev_t dev;
367 	int flag;
368 	int mode;
369 	struct proc *p;
370 {
371 	struct bpf_d *d = &bpf_dtab[minor(dev)];
372 	int s;
373 
374 	s = splimp();
375 	if (d->bd_bif)
376 		bpf_detachd(d);
377 	splx(s);
378 	bpf_freed(d);
379 
380 	return (0);
381 }
382 
383 /*
384  * Rotate the packet buffers in descriptor d.  Move the store buffer
385  * into the hold slot, and the free buffer into the store slot.
386  * Zero the length of the new store buffer.
387  */
388 #define ROTATE_BUFFERS(d) \
389 	(d)->bd_hbuf = (d)->bd_sbuf; \
390 	(d)->bd_hlen = (d)->bd_slen; \
391 	(d)->bd_sbuf = (d)->bd_fbuf; \
392 	(d)->bd_slen = 0; \
393 	(d)->bd_fbuf = 0;
394 /*
395  *  bpfread - read next chunk of packets from buffers
396  */
397 int
398 bpfread(dev, uio, ioflag)
399 	dev_t dev;
400 	struct uio *uio;
401 	int ioflag;
402 {
403 	struct bpf_d *d = &bpf_dtab[minor(dev)];
404 	int error;
405 	int s;
406 
407 	/*
408 	 * Restrict application to use a buffer the same size as
409 	 * as kernel buffers.
410 	 */
411 	if (uio->uio_resid != d->bd_bufsize)
412 		return (EINVAL);
413 
414 	s = splimp();
415 	/*
416 	 * If the hold buffer is empty, then do a timed sleep, which
417 	 * ends when the timeout expires or when enough packets
418 	 * have arrived to fill the store buffer.
419 	 */
420 	while (d->bd_hbuf == 0) {
421 		if (d->bd_immediate) {
422 			if (d->bd_slen == 0) {
423 				splx(s);
424 				return (EWOULDBLOCK);
425 			}
426 			/*
427 			 * A packet(s) either arrived since the previous
428 			 * read or arrived while we were asleep.
429 			 * Rotate the buffers and return what's here.
430 			 */
431 			ROTATE_BUFFERS(d);
432 			break;
433 		}
434 		if (d->bd_rtout != -1)
435 			error = tsleep((caddr_t)d, PRINET|PCATCH, "bpf",
436 					  d->bd_rtout);
437 		else
438 			error = EWOULDBLOCK; /* User requested non-blocking I/O */
439 		if (error == EINTR || error == ERESTART) {
440 			splx(s);
441 			return (error);
442 		}
443 		if (error == EWOULDBLOCK) {
444 			/*
445 			 * On a timeout, return what's in the buffer,
446 			 * which may be nothing.  If there is something
447 			 * in the store buffer, we can rotate the buffers.
448 			 */
449 			if (d->bd_hbuf)
450 				/*
451 				 * We filled up the buffer in between
452 				 * getting the timeout and arriving
453 				 * here, so we don't need to rotate.
454 				 */
455 				break;
456 
457 			if (d->bd_slen == 0) {
458 				splx(s);
459 				return (0);
460 			}
461 			ROTATE_BUFFERS(d);
462 			break;
463 		}
464 		if (error != 0)
465 			goto done;
466 	}
467 	/*
468 	 * At this point, we know we have something in the hold slot.
469 	 */
470 	splx(s);
471 
472 	/*
473 	 * Move data from hold buffer into user space.
474 	 * We know the entire buffer is transferred since
475 	 * we checked above that the read buffer is bpf_bufsize bytes.
476 	 */
477 	error = uiomove(d->bd_hbuf, d->bd_hlen, uio);
478 
479 	s = splimp();
480 	d->bd_fbuf = d->bd_hbuf;
481 	d->bd_hbuf = 0;
482 	d->bd_hlen = 0;
483 done:
484 	splx(s);
485 	return (error);
486 }
487 
488 
489 /*
490  * If there are processes sleeping on this descriptor, wake them up.
491  */
492 static __inline void
493 bpf_wakeup(d)
494 	struct bpf_d *d;
495 {
496 	struct proc *p;
497 
498 	wakeup((caddr_t)d);
499 	if (d->bd_async) {
500 		if (d->bd_pgid > 0)
501 			gsignal (d->bd_pgid, SIGIO);
502 		else if (d->bd_pgid && (p = pfind (-d->bd_pgid)) != NULL)
503 			psignal (p, SIGIO);
504 	}
505 
506 	selwakeup(&d->bd_sel);
507 	/* XXX */
508 	d->bd_sel.si_pid = 0;
509 }
510 
511 int
512 bpfwrite(dev, uio, ioflag)
513 	dev_t dev;
514 	struct uio *uio;
515 	int ioflag;
516 {
517 	struct bpf_d *d = &bpf_dtab[minor(dev)];
518 	struct ifnet *ifp;
519 	struct mbuf *m;
520 	int error, s;
521 	static struct sockaddr_storage dst;
522 
523 	if (d->bd_bif == 0)
524 		return (ENXIO);
525 
526 	ifp = d->bd_bif->bif_ifp;
527 
528 	if (uio->uio_resid == 0)
529 		return (0);
530 
531 	error = bpf_movein(uio, (int)d->bd_bif->bif_dlt, ifp->if_mtu, &m,
532 		(struct sockaddr *) &dst);
533 	if (error)
534 		return (error);
535 
536 	if (m->m_pkthdr.len > ifp->if_mtu)
537 		return (EMSGSIZE);
538 
539 	if (d->bd_hdrcmplt)
540 		dst.ss_family = pseudo_AF_HDRCMPLT;
541 
542 	s = splsoftnet();
543 	error = (*ifp->if_output)(ifp, m, (struct sockaddr *) &dst, NULL);
544 	splx(s);
545 	/*
546 	 * The driver frees the mbuf.
547 	 */
548 	return (error);
549 }
550 
551 /*
552  * Reset a descriptor by flushing its packet buffer and clearing the
553  * receive and drop counts.  Should be called at splimp.
554  */
555 static void
556 reset_d(d)
557 	struct bpf_d *d;
558 {
559 	if (d->bd_hbuf) {
560 		/* Free the hold buffer. */
561 		d->bd_fbuf = d->bd_hbuf;
562 		d->bd_hbuf = 0;
563 	}
564 	d->bd_slen = 0;
565 	d->bd_hlen = 0;
566 	d->bd_rcount = 0;
567 	d->bd_dcount = 0;
568 }
569 
570 #ifdef BPF_KERN_FILTER
571 extern struct bpf_insn *bpf_tcp_filter;
572 extern struct bpf_insn *bpf_udp_filter;
573 #endif
574 
575 /*
576  *  FIONREAD		Check for read packet available.
577  *  BIOCGBLEN		Get buffer len [for read()].
578  *  BIOCSETF		Set ethernet read filter.
579  *  BIOCFLUSH		Flush read packet buffer.
580  *  BIOCPROMISC		Put interface into promiscuous mode.
581  *  BIOCGDLT		Get link layer type.
582  *  BIOCGETIF		Get interface name.
583  *  BIOCSETIF		Set interface.
584  *  BIOCSRTIMEOUT	Set read timeout.
585  *  BIOCGRTIMEOUT	Get read timeout.
586  *  BIOCGSTATS		Get packet stats.
587  *  BIOCIMMEDIATE	Set immediate mode.
588  *  BIOCVERSION		Get filter language version.
589  *  BIOGHDRCMPLT	Get "header already complete" flag.
590  *  BIOSHDRCMPLT	Set "header already complete" flag.
591  */
592 /* ARGSUSED */
593 int
594 bpfioctl(dev, cmd, addr, flag, p)
595 	dev_t dev;
596 	u_long cmd;
597 	caddr_t addr;
598 	int flag;
599 	struct proc *p;
600 {
601 	struct bpf_d *d = &bpf_dtab[minor(dev)];
602 	int s, error = 0;
603 #ifdef BPF_KERN_FILTER
604 	struct bpf_insn **p;
605 #endif
606 
607 	switch (cmd) {
608 
609 	default:
610 		error = EINVAL;
611 		break;
612 
613 	/*
614 	 * Check for read packet available.
615 	 */
616 	case FIONREAD:
617 		{
618 			int n;
619 
620 			s = splimp();
621 			n = d->bd_slen;
622 			if (d->bd_hbuf)
623 				n += d->bd_hlen;
624 			splx(s);
625 
626 			*(int *)addr = n;
627 			break;
628 		}
629 
630 	/*
631 	 * Get buffer len [for read()].
632 	 */
633 	case BIOCGBLEN:
634 		*(u_int *)addr = d->bd_bufsize;
635 		break;
636 
637 	/*
638 	 * Set buffer length.
639 	 */
640 	case BIOCSBLEN:
641 		if (d->bd_bif != 0)
642 			error = EINVAL;
643 		else {
644 			u_int size = *(u_int *)addr;
645 
646 			if (size > BPF_MAXBUFSIZE)
647 				*(u_int *)addr = size = BPF_MAXBUFSIZE;
648 			else if (size < BPF_MINBUFSIZE)
649 				*(u_int *)addr = size = BPF_MINBUFSIZE;
650 			d->bd_bufsize = size;
651 		}
652 		break;
653 
654 	/*
655 	 * Set link layer read filter.
656 	 */
657 	case BIOCSETF:
658 		error = bpf_setf(d, (struct bpf_program *)addr);
659 		break;
660 
661 #ifdef BPF_KERN_FILTER
662 	/*
663 	 * Set TCP or UDP reject filter.
664 	 */
665 	case BIOCSTCPF:
666 	case BIOCSUDPF:
667 		if (!suser()) {
668 			error = EPERM;
669 			break;
670 		}
671 
672 		/* Validate and store filter */
673 		error = bpf_setf(d, (struct bpf_program *)addr);
674 
675 		/* Free possible old filter */
676 		if (cmd == BIOCSTCPF)
677 			p = &bpf_tcp_filter;
678 		else
679 			p = &bpf_udp_filter;
680 		if (*p != NULL)
681 			free((caddr_t)*p, M_DEVBUF);
682 
683 		/* Steal new filter (noop if error) */
684 		s = splimp();
685 		*p = d->bd_filter;
686 		d->bd_filter = NULL;
687 		splx(s);
688 		break;
689 #endif
690 
691 	/*
692 	 * Flush read packet buffer.
693 	 */
694 	case BIOCFLUSH:
695 		s = splimp();
696 		reset_d(d);
697 		splx(s);
698 		break;
699 
700 	/*
701 	 * Put interface into promiscuous mode.
702 	 */
703 	case BIOCPROMISC:
704 		if (d->bd_bif == 0) {
705 			/*
706 			 * No interface attached yet.
707 			 */
708 			error = EINVAL;
709 			break;
710 		}
711 		s = splimp();
712 		if (d->bd_promisc == 0) {
713 			error = ifpromisc(d->bd_bif->bif_ifp, 1);
714 			if (error == 0)
715 				d->bd_promisc = 1;
716 		}
717 		splx(s);
718 		break;
719 
720 	/*
721 	 * Get device parameters.
722 	 */
723 	case BIOCGDLT:
724 		if (d->bd_bif == 0)
725 			error = EINVAL;
726 		else
727 			*(u_int *)addr = d->bd_bif->bif_dlt;
728 		break;
729 
730 	/*
731 	 * Set interface name.
732 	 */
733 	case BIOCGETIF:
734 		if (d->bd_bif == 0)
735 			error = EINVAL;
736 		else
737 			bpf_ifname(d->bd_bif->bif_ifp, (struct ifreq *)addr);
738 		break;
739 
740 	/*
741 	 * Set interface.
742 	 */
743 	case BIOCSETIF:
744 		error = bpf_setif(d, (struct ifreq *)addr);
745 		break;
746 
747 	/*
748 	 * Set read timeout.
749 	 */
750 	case BIOCSRTIMEOUT:
751 		{
752 			struct timeval *tv = (struct timeval *)addr;
753 
754 			/* Compute number of ticks. */
755 			d->bd_rtout = tv->tv_sec * hz + tv->tv_usec / tick;
756 			if ((d->bd_rtout == 0) && (tv->tv_usec != 0))
757 				d->bd_rtout = 1;
758 			break;
759 		}
760 
761 	/*
762 	 * Get read timeout.
763 	 */
764 	case BIOCGRTIMEOUT:
765 		{
766 			struct timeval *tv = (struct timeval *)addr;
767 
768 			tv->tv_sec = d->bd_rtout / hz;
769 			tv->tv_usec = (d->bd_rtout % hz) * tick;
770 			break;
771 		}
772 
773 	/*
774 	 * Get packet stats.
775 	 */
776 	case BIOCGSTATS:
777 		{
778 			struct bpf_stat *bs = (struct bpf_stat *)addr;
779 
780 			bs->bs_recv = d->bd_rcount;
781 			bs->bs_drop = d->bd_dcount;
782 			break;
783 		}
784 
785 	/*
786 	 * Set immediate mode.
787 	 */
788 	case BIOCIMMEDIATE:
789 		d->bd_immediate = *(u_int *)addr;
790 		break;
791 
792 	case BIOCVERSION:
793 		{
794 			struct bpf_version *bv = (struct bpf_version *)addr;
795 
796 			bv->bv_major = BPF_MAJOR_VERSION;
797 			bv->bv_minor = BPF_MINOR_VERSION;
798 			break;
799 		}
800 
801 	case BIOCGHDRCMPLT:	/* get "header already complete" flag */
802 		*(u_int *)addr = d->bd_hdrcmplt;
803 		break;
804 
805 	case BIOCSHDRCMPLT:	/* set "header already complete" flag */
806 		d->bd_hdrcmplt = *(u_int *)addr ? 1 : 0;
807 		break;
808 
809 	case FIONBIO:		/* Non-blocking I/O */
810 		if (*(int *)addr)
811 			d->bd_rtout = -1;
812 		else
813 			d->bd_rtout = 0;
814 		break;
815 
816 	case FIOASYNC:		/* Send signal on receive packets */
817 		d->bd_async = *(int *)addr;
818 		break;
819 
820 	/*
821 	 * N.B.  ioctl (FIOSETOWN) and fcntl (F_SETOWN) both end up doing
822 	 * the equivalent of a TIOCSPGRP and hence end up here.  *However*
823 	 * TIOCSPGRP's arg is a process group if it's positive and a process
824 	 * id if it's negative.  This is exactly the opposite of what the
825 	 * other two functions want!  Therefore there is code in ioctl and
826 	 * fcntl to negate the arg before calling here.
827 	 */
828 	case TIOCSPGRP:		/* Process or group to send signals to */
829 		d->bd_pgid = *(int *)addr;
830 		break;
831 
832 	case TIOCGPGRP:
833 		*(int *)addr = d->bd_pgid;
834 		break;
835 	}
836 	return (error);
837 }
838 
839 /*
840  * Set d's packet filter program to fp.  If this file already has a filter,
841  * free it and replace it.  Returns EINVAL for bogus requests.
842  */
843 int
844 bpf_setf(d, fp)
845 	struct bpf_d *d;
846 	struct bpf_program *fp;
847 {
848 	struct bpf_insn *fcode, *old;
849 	u_int flen, size;
850 	int s;
851 
852 	old = d->bd_filter;
853 	if (fp->bf_insns == 0) {
854 		if (fp->bf_len != 0)
855 			return (EINVAL);
856 		s = splimp();
857 		d->bd_filter = 0;
858 		reset_d(d);
859 		splx(s);
860 		if (old != 0)
861 			free((caddr_t)old, M_DEVBUF);
862 		return (0);
863 	}
864 	flen = fp->bf_len;
865 	if (flen > BPF_MAXINSNS)
866 		return (EINVAL);
867 
868 	size = flen * sizeof(*fp->bf_insns);
869 	fcode = (struct bpf_insn *)malloc(size, M_DEVBUF, M_WAITOK);
870 	if (copyin((caddr_t)fp->bf_insns, (caddr_t)fcode, size) == 0 &&
871 	    bpf_validate(fcode, (int)flen)) {
872 		s = splimp();
873 		d->bd_filter = fcode;
874 		reset_d(d);
875 		splx(s);
876 		if (old != 0)
877 			free((caddr_t)old, M_DEVBUF);
878 
879 		return (0);
880 	}
881 	free((caddr_t)fcode, M_DEVBUF);
882 	return (EINVAL);
883 }
884 
885 /*
886  * Detach a file from its current interface (if attached at all) and attach
887  * to the interface indicated by the name stored in ifr.
888  * Return an errno or 0.
889  */
890 static int
891 bpf_setif(d, ifr)
892 	struct bpf_d *d;
893 	struct ifreq *ifr;
894 {
895 	struct bpf_if *bp;
896 	char *cp;
897 	int unit_seen, i, s, error;
898 
899 	/*
900 	 * Make sure the provided name has a unit number, and default
901 	 * it to '0' if not specified.
902 	 * XXX This is ugly ... do this differently?
903 	 */
904 	unit_seen = 0;
905 	cp = ifr->ifr_name;
906 	cp[sizeof(ifr->ifr_name) - 1] = '\0';	/* sanity */
907 	while (*cp++)
908 		if (*cp >= '0' && *cp <= '9')
909 			unit_seen = 1;
910 	if (!unit_seen) {
911 		/* Make sure to leave room for the '\0'. */
912 		for (i = 0; i < (IFNAMSIZ - 1); ++i) {
913 			if ((ifr->ifr_name[i] >= 'a' &&
914 			     ifr->ifr_name[i] <= 'z') ||
915 			    (ifr->ifr_name[i] >= 'A' &&
916 			     ifr->ifr_name[i] <= 'Z'))
917 				continue;
918 			ifr->ifr_name[i] = '0';
919 		}
920 	}
921 
922 	/*
923 	 * Look through attached interfaces for the named one.
924 	 */
925 	for (bp = bpf_iflist; bp != 0; bp = bp->bif_next) {
926 		struct ifnet *ifp = bp->bif_ifp;
927 
928 		if (ifp == 0 ||
929 		    strcmp(ifp->if_xname, ifr->ifr_name) != 0)
930 			continue;
931 		/*
932 		 * We found the requested interface.
933 		 * If it's not up, return an error.
934 		 * Allocate the packet buffers if we need to.
935 		 * If we're already attached to requested interface,
936 		 * just flush the buffer.
937 		 */
938 		if ((ifp->if_flags & IFF_UP) == 0)
939 			return (ENETDOWN);
940 
941 		if (d->bd_sbuf == 0) {
942 			error = bpf_allocbufs(d);
943 			if (error != 0)
944 				return (error);
945 		}
946 		s = splimp();
947 		if (bp != d->bd_bif) {
948 			if (d->bd_bif)
949 				/*
950 				 * Detach if attached to something else.
951 				 */
952 				bpf_detachd(d);
953 
954 			bpf_attachd(d, bp);
955 		}
956 		reset_d(d);
957 		splx(s);
958 		return (0);
959 	}
960 	/* Not found. */
961 	return (ENXIO);
962 }
963 
964 /*
965  * Copy the interface name to the ifreq.
966  */
967 static void
968 bpf_ifname(ifp, ifr)
969 	struct ifnet *ifp;
970 	struct ifreq *ifr;
971 {
972 
973 	memcpy(ifr->ifr_name, ifp->if_xname, IFNAMSIZ);
974 }
975 
976 /*
977  * Support for poll() system call
978  *
979  * Return true iff the specific operation will not block indefinitely.
980  * Otherwise, return false but make a note that a selwakeup() must be done.
981  */
982 int
983 bpfpoll(dev, events, p)
984 	dev_t dev;
985 	int events;
986 	struct proc *p;
987 {
988 	struct bpf_d *d = &bpf_dtab[minor(dev)];
989 	int revents = 0;
990 	int s = splimp();
991 
992 	/*
993 	 * An imitation of the FIONREAD ioctl code.
994 	 */
995 	if (events & (POLLIN | POLLRDNORM)) {
996 		if (d->bd_hlen != 0 || (d->bd_immediate && d->bd_slen != 0))
997 			revents |= events & (POLLIN | POLLRDNORM);
998 		else
999 			selrecord(p, &d->bd_sel);
1000 	}
1001 
1002 	splx(s);
1003 	return (revents);
1004 }
1005 
1006 /*
1007  * Incoming linkage from device drivers.  Process the packet pkt, of length
1008  * pktlen, which is stored in a contiguous buffer.  The packet is parsed
1009  * by each process' filter, and if accepted, stashed into the corresponding
1010  * buffer.
1011  */
1012 void
1013 bpf_tap(arg, pkt, pktlen)
1014 	caddr_t arg;
1015 	u_char *pkt;
1016 	u_int pktlen;
1017 {
1018 	struct bpf_if *bp;
1019 	struct bpf_d *d;
1020 	u_int slen;
1021 	/*
1022 	 * Note that the ipl does not have to be raised at this point.
1023 	 * The only problem that could arise here is that if two different
1024 	 * interfaces shared any data.  This is not the case.
1025 	 */
1026 	bp = (struct bpf_if *)arg;
1027 	for (d = bp->bif_dlist; d != 0; d = d->bd_next) {
1028 		++d->bd_rcount;
1029 		slen = bpf_filter(d->bd_filter, pkt, pktlen, pktlen);
1030 		if (slen != 0)
1031 			catchpacket(d, pkt, pktlen, slen, memcpy);
1032 	}
1033 }
1034 
1035 /*
1036  * Copy data from an mbuf chain into a buffer.  This code is derived
1037  * from m_copydata in sys/uipc_mbuf.c.
1038  */
1039 static void *
1040 bpf_mcpy(dst_arg, src_arg, len)
1041 	void *dst_arg;
1042 	const void *src_arg;
1043 	size_t len;
1044 {
1045 	const struct mbuf *m;
1046 	u_int count;
1047 	u_char *dst;
1048 
1049 	m = src_arg;
1050 	dst = dst_arg;
1051 	while (len > 0) {
1052 		if (m == 0)
1053 			panic("bpf_mcpy");
1054 		count = min(m->m_len, len);
1055 		memcpy((caddr_t)dst, mtod(m, caddr_t), count);
1056 		m = m->m_next;
1057 		dst += count;
1058 		len -= count;
1059 	}
1060 	return(dst_arg);
1061 }
1062 
1063 /*
1064  * Incoming linkage from device drivers, when packet is in an mbuf chain.
1065  */
1066 void
1067 bpf_mtap(arg, m)
1068 	caddr_t arg;
1069 	struct mbuf *m;
1070 {
1071 	struct bpf_if *bp = (struct bpf_if *)arg;
1072 	struct bpf_d *d;
1073 	u_int pktlen, slen;
1074 	struct mbuf *m0;
1075 
1076 	pktlen = 0;
1077 	for (m0 = m; m0 != 0; m0 = m0->m_next)
1078 		pktlen += m0->m_len;
1079 
1080 	for (d = bp->bif_dlist; d != 0; d = d->bd_next) {
1081 		++d->bd_rcount;
1082 		slen = bpf_filter(d->bd_filter, (u_char *)m, pktlen, 0);
1083 		if (slen != 0)
1084 			catchpacket(d, (u_char *)m, pktlen, slen, bpf_mcpy);
1085 	}
1086 }
1087 
1088 /*
1089  * Move the packet data from interface memory (pkt) into the
1090  * store buffer.  Return 1 if it's time to wakeup a listener (buffer full),
1091  * otherwise 0.  "copy" is the routine called to do the actual data
1092  * transfer.  memcpy is passed in to copy contiguous chunks, while
1093  * bpf_mcpy is passed in to copy mbuf chains.  In the latter case,
1094  * pkt is really an mbuf.
1095  */
1096 static void
1097 catchpacket(d, pkt, pktlen, snaplen, cpfn)
1098 	struct bpf_d *d;
1099 	u_char *pkt;
1100 	u_int pktlen, snaplen;
1101 	void *(*cpfn) __P((void *, const void *, size_t));
1102 {
1103 	struct bpf_hdr *hp;
1104 	int totlen, curlen;
1105 	int hdrlen = d->bd_bif->bif_hdrlen;
1106 	/*
1107 	 * Figure out how many bytes to move.  If the packet is
1108 	 * greater or equal to the snapshot length, transfer that
1109 	 * much.  Otherwise, transfer the whole packet (unless
1110 	 * we hit the buffer size limit).
1111 	 */
1112 	totlen = hdrlen + min(snaplen, pktlen);
1113 	if (totlen > d->bd_bufsize)
1114 		totlen = d->bd_bufsize;
1115 
1116 	/*
1117 	 * Round up the end of the previous packet to the next longword.
1118 	 */
1119 	curlen = BPF_WORDALIGN(d->bd_slen);
1120 	if (curlen + totlen > d->bd_bufsize) {
1121 		/*
1122 		 * This packet will overflow the storage buffer.
1123 		 * Rotate the buffers if we can, then wakeup any
1124 		 * pending reads.
1125 		 */
1126 		if (d->bd_fbuf == 0) {
1127 			/*
1128 			 * We haven't completed the previous read yet,
1129 			 * so drop the packet.
1130 			 */
1131 			++d->bd_dcount;
1132 			return;
1133 		}
1134 		ROTATE_BUFFERS(d);
1135 		bpf_wakeup(d);
1136 		curlen = 0;
1137 	}
1138 	else if (d->bd_immediate)
1139 		/*
1140 		 * Immediate mode is set.  A packet arrived so any
1141 		 * reads should be woken up.
1142 		 */
1143 		bpf_wakeup(d);
1144 
1145 	/*
1146 	 * Append the bpf header.
1147 	 */
1148 	hp = (struct bpf_hdr *)(d->bd_sbuf + curlen);
1149 	microtime(&hp->bh_tstamp);
1150 	hp->bh_datalen = pktlen;
1151 	hp->bh_hdrlen = hdrlen;
1152 	/*
1153 	 * Copy the packet data into the store buffer and update its length.
1154 	 */
1155 	(*cpfn)((u_char *)hp + hdrlen, pkt, (hp->bh_caplen = totlen - hdrlen));
1156 	d->bd_slen = curlen + totlen;
1157 }
1158 
1159 /*
1160  * Initialize all nonzero fields of a descriptor.
1161  */
1162 static int
1163 bpf_allocbufs(d)
1164 	struct bpf_d *d;
1165 {
1166 
1167 	d->bd_fbuf = (caddr_t)malloc(d->bd_bufsize, M_DEVBUF, M_WAITOK);
1168 	d->bd_sbuf = (caddr_t)malloc(d->bd_bufsize, M_DEVBUF, M_WAITOK);
1169 	d->bd_slen = 0;
1170 	d->bd_hlen = 0;
1171 	return (0);
1172 }
1173 
1174 /*
1175  * Free buffers currently in use by a descriptor.
1176  * Called on close.
1177  */
1178 static void
1179 bpf_freed(d)
1180 	struct bpf_d *d;
1181 {
1182 	/*
1183 	 * We don't need to lock out interrupts since this descriptor has
1184 	 * been detached from its interface and it yet hasn't been marked
1185 	 * free.
1186 	 */
1187 	if (d->bd_sbuf != 0) {
1188 		free(d->bd_sbuf, M_DEVBUF);
1189 		if (d->bd_hbuf != 0)
1190 			free(d->bd_hbuf, M_DEVBUF);
1191 		if (d->bd_fbuf != 0)
1192 			free(d->bd_fbuf, M_DEVBUF);
1193 	}
1194 	if (d->bd_filter)
1195 		free((caddr_t)d->bd_filter, M_DEVBUF);
1196 
1197 	D_MARKFREE(d);
1198 }
1199 
1200 /*
1201  * Attach an interface to bpf.  driverp is a pointer to a (struct bpf_if *)
1202  * in the driver's softc; dlt is the link layer type; hdrlen is the fixed
1203  * size of the link header (variable length headers not yet supported).
1204  */
1205 void
1206 bpfattach(driverp, ifp, dlt, hdrlen)
1207 	caddr_t *driverp;
1208 	struct ifnet *ifp;
1209 	u_int dlt, hdrlen;
1210 {
1211 	struct bpf_if *bp;
1212 	bp = (struct bpf_if *)malloc(sizeof(*bp), M_DEVBUF, M_DONTWAIT);
1213 	if (bp == 0)
1214 		panic("bpfattach");
1215 
1216 	bp->bif_dlist = 0;
1217 	bp->bif_driverp = (struct bpf_if **)driverp;
1218 	bp->bif_ifp = ifp;
1219 	bp->bif_dlt = dlt;
1220 
1221 	bp->bif_next = bpf_iflist;
1222 	bpf_iflist = bp;
1223 
1224 	*bp->bif_driverp = 0;
1225 
1226 	/*
1227 	 * Compute the length of the bpf header.  This is not necessarily
1228 	 * equal to SIZEOF_BPF_HDR because we want to insert spacing such
1229 	 * that the network layer header begins on a longword boundary (for
1230 	 * performance reasons and to alleviate alignment restrictions).
1231 	 */
1232 	bp->bif_hdrlen = BPF_WORDALIGN(hdrlen + SIZEOF_BPF_HDR) - hdrlen;
1233 
1234 #if 0
1235 	printf("bpf: %s attached\n", ifp->if_xname);
1236 #endif
1237 }
1238 
1239 /*
1240  * Remove an interface from bpf.
1241  */
1242 void
1243 bpfdetach(ifp)
1244 	struct ifnet *ifp;
1245 {
1246 	struct bpf_if *bp, **pbp;
1247 	struct bpf_d *d;
1248 	int i, s, cmaj;
1249 
1250 	/* locate the major number */
1251 	for (cmaj = 0; cmaj <= nchrdev; cmaj++)
1252 		if (cdevsw[cmaj].d_open == bpfopen)
1253 			break;
1254 
1255 	/* Nuke the vnodes for any open instances */
1256 	for (i = 0; i < NBPFILTER; ++i) {
1257 		d = &bpf_dtab[i];
1258 		if (!D_ISFREE(d) && d->bd_bif != NULL &&
1259 		    d->bd_bif->bif_ifp == ifp) {
1260 			/*
1261 			 * Detach the descriptor from an interface now.
1262 			 * It will be free'ed later by close routine.
1263 			 */
1264 			s = splimp();
1265 			d->bd_promisc = 0;	/* we can't touch device. */
1266 			bpf_detachd(d);
1267 			splx(s);
1268 			vdevgone(cmaj, i, i, VCHR);
1269 		}
1270 	}
1271 
1272 	for (bp = bpf_iflist, pbp = &bpf_iflist;
1273 	     bp != NULL; pbp = &bp->bif_next, bp = bp->bif_next) {
1274 		if (bp->bif_ifp == ifp) {
1275 			*pbp = bp->bif_next;
1276 			free(bp, M_DEVBUF);
1277 			break;
1278 		}
1279 	}
1280 }
1281 
1282 /*
1283  * Change the data link type of a BPF instance.
1284  */
1285 void
1286 bpf_change_type(driverp, dlt, hdrlen)
1287 	caddr_t *driverp;
1288 	u_int dlt, hdrlen;
1289 {
1290 	struct bpf_if *bp;
1291 
1292 	for (bp = bpf_iflist; bp != NULL; bp = bp->bif_next) {
1293 		if (bp->bif_driverp == (struct bpf_if **)driverp)
1294 			break;
1295 	}
1296 	if (bp == NULL)
1297 		panic("bpf_change_type");
1298 
1299 	bp->bif_dlt = dlt;
1300 
1301 	/*
1302 	 * Compute the length of the bpf header.  This is not necessarily
1303 	 * equal to SIZEOF_BPF_HDR because we want to insert spacing such
1304 	 * that the network layer header begins on a longword boundary (for
1305 	 * performance reasons and to alleviate alignment restrictions).
1306 	 */
1307 	bp->bif_hdrlen = BPF_WORDALIGN(hdrlen + SIZEOF_BPF_HDR) - hdrlen;
1308 }
1309