1139823Simp/*-
2130407Sdfr * Copyright (c) 2004 Doug Rabson
3130407Sdfr * Copyright (c) 1982, 1989, 1993
4130407Sdfr *	The Regents of the University of California.  All rights reserved.
5130407Sdfr *
6130407Sdfr * Redistribution and use in source and binary forms, with or without
7130407Sdfr * modification, are permitted provided that the following conditions
8130407Sdfr * are met:
9130407Sdfr * 1. Redistributions of source code must retain the above copyright
10130407Sdfr *    notice, this list of conditions and the following disclaimer.
11130407Sdfr * 2. Redistributions in binary form must reproduce the above copyright
12130407Sdfr *    notice, this list of conditions and the following disclaimer in the
13130407Sdfr *    documentation and/or other materials provided with the distribution.
14130407Sdfr * 4. Neither the name of the University nor the names of its contributors
15130407Sdfr *    may be used to endorse or promote products derived from this software
16130407Sdfr *    without specific prior written permission.
17130407Sdfr *
18130407Sdfr * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
19130407Sdfr * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20130407Sdfr * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21130407Sdfr * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
22130407Sdfr * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23130407Sdfr * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24130407Sdfr * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25130407Sdfr * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26130407Sdfr * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27130407Sdfr * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28130407Sdfr * SUCH DAMAGE.
29130407Sdfr *
30130407Sdfr * $FreeBSD: stable/11/sys/net/if_fwsubr.c 369819 2021-05-17 10:01:37Z avatar $
31130407Sdfr */
32130407Sdfr
33130407Sdfr#include "opt_inet.h"
34130407Sdfr#include "opt_inet6.h"
35130407Sdfr
36130407Sdfr#include <sys/param.h>
37130407Sdfr#include <sys/systm.h>
38130407Sdfr#include <sys/kernel.h>
39130407Sdfr#include <sys/malloc.h>
40130407Sdfr#include <sys/mbuf.h>
41147256Sbrooks#include <sys/module.h>
42130407Sdfr#include <sys/socket.h>
43130407Sdfr#include <sys/sockio.h>
44130407Sdfr
45130407Sdfr#include <net/if.h>
46257176Sglebius#include <net/if_var.h>
47130407Sdfr#include <net/netisr.h>
48130407Sdfr#include <net/route.h>
49130407Sdfr#include <net/if_llc.h>
50130407Sdfr#include <net/if_dl.h>
51130407Sdfr#include <net/if_types.h>
52130407Sdfr#include <net/bpf.h>
53130407Sdfr#include <net/firewire.h>
54186119Sqingli#include <net/if_llatbl.h>
55130407Sdfr
56130407Sdfr#if defined(INET) || defined(INET6)
57130407Sdfr#include <netinet/in.h>
58130407Sdfr#include <netinet/in_var.h>
59130407Sdfr#include <netinet/if_ether.h>
60130407Sdfr#endif
61130407Sdfr#ifdef INET6
62130407Sdfr#include <netinet6/nd6.h>
63130407Sdfr#endif
64130407Sdfr
65163606Srwatson#include <security/mac/mac_framework.h>
66163606Srwatson
67227293Sedstatic MALLOC_DEFINE(M_FWCOM, "fw_com", "firewire interface internals");
68147256Sbrooks
69130407Sdfrstruct fw_hwaddr firewire_broadcastaddr = {
70130407Sdfr	0xffffffff,
71130407Sdfr	0xffffffff,
72130407Sdfr	0xff,
73130407Sdfr	0xff,
74130407Sdfr	0xffff,
75130407Sdfr	0xffffffff
76130407Sdfr};
77130407Sdfr
78130407Sdfrstatic int
79249925Sglebiusfirewire_output(struct ifnet *ifp, struct mbuf *m, const struct sockaddr *dst,
80191148Skmacy    struct route *ro)
81130407Sdfr{
82154209Sbrooks	struct fw_com *fc = IFP2FWC(ifp);
83130407Sdfr	int error, type;
84130407Sdfr	struct m_tag *mtag;
85130407Sdfr	union fw_encap *enc;
86130407Sdfr	struct fw_hwaddr *destfw;
87130407Sdfr	uint8_t speed;
88130407Sdfr	uint16_t psize, fsize, dsize;
89130407Sdfr	struct mbuf *mtail;
90130407Sdfr	int unicast, dgl, foff;
91130407Sdfr	static int next_dgl;
92287861Smelifaro#if defined(INET) || defined(INET6)
93287861Smelifaro	int is_gw = 0;
94275211Sbz#endif
95130407Sdfr
96130429Sdfr#ifdef MAC
97172930Srwatson	error = mac_ifnet_check_transmit(ifp, m);
98130429Sdfr	if (error)
99130429Sdfr		goto bad;
100130429Sdfr#endif
101130429Sdfr
102148887Srwatson	if (!((ifp->if_flags & IFF_UP) &&
103148887Srwatson	   (ifp->if_drv_flags & IFF_DRV_RUNNING))) {
104130407Sdfr		error = ENETDOWN;
105130407Sdfr		goto bad;
106130407Sdfr	}
107130407Sdfr
108287861Smelifaro#if defined(INET) || defined(INET6)
109293544Smelifaro	if (ro != NULL)
110293544Smelifaro		is_gw = (ro->ro_flags & RT_HAS_GW) != 0;
111287861Smelifaro#endif
112130407Sdfr	/*
113130407Sdfr	 * For unicast, we make a tag to store the lladdr of the
114130407Sdfr	 * destination. This might not be the first time we have seen
115130407Sdfr	 * the packet (for instance, the arp code might be trying to
116130407Sdfr	 * re-send it after receiving an arp reply) so we only
117130407Sdfr	 * allocate a tag if there isn't one there already. For
118130407Sdfr	 * multicast, we will eventually use a different tag to store
119130407Sdfr	 * the channel number.
120130407Sdfr	 */
121130407Sdfr	unicast = !(m->m_flags & (M_BCAST | M_MCAST));
122130407Sdfr	if (unicast) {
123130407Sdfr		mtag = m_tag_locate(m, MTAG_FIREWIRE, MTAG_FIREWIRE_HWADDR, NULL);
124130407Sdfr		if (!mtag) {
125130407Sdfr			mtag = m_tag_alloc(MTAG_FIREWIRE, MTAG_FIREWIRE_HWADDR,
126130407Sdfr			    sizeof (struct fw_hwaddr), M_NOWAIT);
127130407Sdfr			if (!mtag) {
128130407Sdfr				error = ENOMEM;
129130407Sdfr				goto bad;
130130407Sdfr			}
131130407Sdfr			m_tag_prepend(m, mtag);
132130407Sdfr		}
133130407Sdfr		destfw = (struct fw_hwaddr *)(mtag + 1);
134130407Sdfr	} else {
135298075Spfg		destfw = NULL;
136130407Sdfr	}
137130407Sdfr
138130407Sdfr	switch (dst->sa_family) {
139184711Sbz#ifdef INET
140130407Sdfr	case AF_INET:
141130407Sdfr		/*
142130407Sdfr		 * Only bother with arp for unicast. Allocation of
143130407Sdfr		 * channels etc. for firewire is quite different and
144130407Sdfr		 * doesn't fit into the arp model.
145130407Sdfr		 */
146130407Sdfr		if (unicast) {
147301217Sgnn			error = arpresolve(ifp, is_gw, m, dst,
148301217Sgnn			    (u_char *) destfw, NULL, NULL);
149130407Sdfr			if (error)
150130407Sdfr				return (error == EWOULDBLOCK ? 0 : error);
151130407Sdfr		}
152130407Sdfr		type = ETHERTYPE_IP;
153130407Sdfr		break;
154130407Sdfr
155130407Sdfr	case AF_ARP:
156130407Sdfr	{
157130407Sdfr		struct arphdr *ah;
158130407Sdfr		ah = mtod(m, struct arphdr *);
159130407Sdfr		ah->ar_hrd = htons(ARPHRD_IEEE1394);
160130407Sdfr		type = ETHERTYPE_ARP;
161130407Sdfr		if (unicast)
162130407Sdfr			*destfw = *(struct fw_hwaddr *) ar_tha(ah);
163130407Sdfr
164130407Sdfr		/*
165130407Sdfr		 * The standard arp code leaves a hole for the target
166130407Sdfr		 * hardware address which we need to close up.
167130407Sdfr		 */
168130407Sdfr		bcopy(ar_tpa(ah), ar_tha(ah), ah->ar_pln);
169130407Sdfr		m_adj(m, -ah->ar_hln);
170130407Sdfr		break;
171130407Sdfr	}
172130407Sdfr#endif
173130407Sdfr
174130407Sdfr#ifdef INET6
175130407Sdfr	case AF_INET6:
176130407Sdfr		if (unicast) {
177287861Smelifaro			error = nd6_resolve(fc->fc_ifp, is_gw, m, dst,
178301217Sgnn			    (u_char *) destfw, NULL, NULL);
179130407Sdfr			if (error)
180287861Smelifaro				return (error == EWOULDBLOCK ? 0 : error);
181130407Sdfr		}
182130407Sdfr		type = ETHERTYPE_IPV6;
183130407Sdfr		break;
184130407Sdfr#endif
185130407Sdfr
186130407Sdfr	default:
187130407Sdfr		if_printf(ifp, "can't handle af%d\n", dst->sa_family);
188130407Sdfr		error = EAFNOSUPPORT;
189130407Sdfr		goto bad;
190130407Sdfr	}
191130407Sdfr
192130407Sdfr	/*
193130407Sdfr	 * Let BPF tap off a copy before we encapsulate.
194130407Sdfr	 */
195159183Ssam	if (bpf_peers_present(ifp->if_bpf)) {
196130407Sdfr		struct fw_bpfhdr h;
197130407Sdfr		if (unicast)
198130407Sdfr			bcopy(destfw, h.firewire_dhost, 8);
199130407Sdfr		else
200130407Sdfr			bcopy(&firewire_broadcastaddr, h.firewire_dhost, 8);
201130407Sdfr		bcopy(&fc->fc_hwaddr, h.firewire_shost, 8);
202130407Sdfr		h.firewire_type = htons(type);
203130407Sdfr		bpf_mtap2(ifp->if_bpf, &h, sizeof(h), m);
204130407Sdfr	}
205130407Sdfr
206130407Sdfr	/*
207130407Sdfr	 * Punt on MCAP for now and send all multicast packets on the
208130407Sdfr	 * broadcast channel.
209130407Sdfr	 */
210130407Sdfr	if (m->m_flags & M_MCAST)
211130407Sdfr		m->m_flags |= M_BCAST;
212130407Sdfr
213130407Sdfr	/*
214130407Sdfr	 * Figure out what speed to use and what the largest supported
215130407Sdfr	 * packet size is. For unicast, this is the minimum of what we
216130407Sdfr	 * can speak and what they can hear. For broadcast, lets be
217130407Sdfr	 * conservative and use S100. We could possibly improve that
218130407Sdfr	 * by examining the bus manager's speed map or similar. We
219130407Sdfr	 * also reduce the packet size for broadcast to account for
220130407Sdfr	 * the GASP header.
221130407Sdfr	 */
222130407Sdfr	if (unicast) {
223130407Sdfr		speed = min(fc->fc_speed, destfw->sspd);
224130407Sdfr		psize = min(512 << speed, 2 << destfw->sender_max_rec);
225130407Sdfr	} else {
226130407Sdfr		speed = 0;
227130407Sdfr		psize = 512 - 2*sizeof(uint32_t);
228130407Sdfr	}
229130407Sdfr
230130407Sdfr	/*
231130407Sdfr	 * Next, we encapsulate, possibly fragmenting the original
232130407Sdfr	 * datagram if it won't fit into a single packet.
233130407Sdfr	 */
234130407Sdfr	if (m->m_pkthdr.len <= psize - sizeof(uint32_t)) {
235130407Sdfr		/*
236130407Sdfr		 * No fragmentation is necessary.
237130407Sdfr		 */
238243882Sglebius		M_PREPEND(m, sizeof(uint32_t), M_NOWAIT);
239130407Sdfr		if (!m) {
240130407Sdfr			error = ENOBUFS;
241130407Sdfr			goto bad;
242130407Sdfr		}
243130407Sdfr		enc = mtod(m, union fw_encap *);
244130407Sdfr		enc->unfrag.ether_type = type;
245130407Sdfr		enc->unfrag.lf = FW_ENCAP_UNFRAG;
246144114Sgallatin		enc->unfrag.reserved = 0;
247130407Sdfr
248130407Sdfr		/*
249130407Sdfr		 * Byte swap the encapsulation header manually.
250130407Sdfr		 */
251130407Sdfr		enc->ul[0] = htonl(enc->ul[0]);
252130407Sdfr
253185164Skmacy		error = (ifp->if_transmit)(ifp, m);
254130549Smlaier		return (error);
255130407Sdfr	} else {
256130407Sdfr		/*
257130407Sdfr		 * Fragment the datagram, making sure to leave enough
258130407Sdfr		 * space for the encapsulation header in each packet.
259130407Sdfr		 */
260130407Sdfr		fsize = psize - 2*sizeof(uint32_t);
261130407Sdfr		dgl = next_dgl++;
262130407Sdfr		dsize = m->m_pkthdr.len;
263130407Sdfr		foff = 0;
264130407Sdfr		while (m) {
265130407Sdfr			if (m->m_pkthdr.len > fsize) {
266130407Sdfr				/*
267130407Sdfr				 * Split off the tail segment from the
268130407Sdfr				 * datagram, copying our tags over.
269130407Sdfr				 */
270243882Sglebius				mtail = m_split(m, fsize, M_NOWAIT);
271130407Sdfr				m_tag_copy_chain(mtail, m, M_NOWAIT);
272130407Sdfr			} else {
273298075Spfg				mtail = NULL;
274130407Sdfr			}
275130407Sdfr
276130407Sdfr			/*
277130407Sdfr			 * Add our encapsulation header to this
278130407Sdfr			 * fragment and hand it off to the link.
279130407Sdfr			 */
280243882Sglebius			M_PREPEND(m, 2*sizeof(uint32_t), M_NOWAIT);
281130407Sdfr			if (!m) {
282130407Sdfr				error = ENOBUFS;
283130407Sdfr				goto bad;
284130407Sdfr			}
285130407Sdfr			enc = mtod(m, union fw_encap *);
286130407Sdfr			if (foff == 0) {
287130407Sdfr				enc->firstfrag.lf = FW_ENCAP_FIRST;
288144114Sgallatin				enc->firstfrag.reserved1 = 0;
289144114Sgallatin				enc->firstfrag.reserved2 = 0;
290130407Sdfr				enc->firstfrag.datagram_size = dsize - 1;
291130407Sdfr				enc->firstfrag.ether_type = type;
292130407Sdfr				enc->firstfrag.dgl = dgl;
293130407Sdfr			} else {
294130407Sdfr				if (mtail)
295130407Sdfr					enc->nextfrag.lf = FW_ENCAP_NEXT;
296130407Sdfr				else
297130407Sdfr					enc->nextfrag.lf = FW_ENCAP_LAST;
298144114Sgallatin				enc->nextfrag.reserved1 = 0;
299144114Sgallatin				enc->nextfrag.reserved2 = 0;
300144114Sgallatin				enc->nextfrag.reserved3 = 0;
301130407Sdfr				enc->nextfrag.datagram_size = dsize - 1;
302130407Sdfr				enc->nextfrag.fragment_offset = foff;
303130407Sdfr				enc->nextfrag.dgl = dgl;
304130407Sdfr			}
305130407Sdfr			foff += m->m_pkthdr.len - 2*sizeof(uint32_t);
306130407Sdfr
307130407Sdfr			/*
308130407Sdfr			 * Byte swap the encapsulation header manually.
309130407Sdfr			 */
310130407Sdfr			enc->ul[0] = htonl(enc->ul[0]);
311130407Sdfr			enc->ul[1] = htonl(enc->ul[1]);
312130407Sdfr
313185164Skmacy			error = (ifp->if_transmit)(ifp, m);
314130549Smlaier			if (error) {
315130407Sdfr				if (mtail)
316130407Sdfr					m_freem(mtail);
317130407Sdfr				return (ENOBUFS);
318130407Sdfr			}
319130407Sdfr
320130407Sdfr			m = mtail;
321130407Sdfr		}
322130407Sdfr
323130407Sdfr		return (0);
324130407Sdfr	}
325130407Sdfr
326130407Sdfrbad:
327130407Sdfr	if (m)
328130407Sdfr		m_freem(m);
329130407Sdfr	return (error);
330130407Sdfr}
331130407Sdfr
332130407Sdfrstatic struct mbuf *
333130407Sdfrfirewire_input_fragment(struct fw_com *fc, struct mbuf *m, int src)
334130407Sdfr{
335130407Sdfr	union fw_encap *enc;
336130407Sdfr	struct fw_reass *r;
337130407Sdfr	struct mbuf *mf, *mprev;
338130407Sdfr	int dsize;
339130407Sdfr	int fstart, fend, start, end, islast;
340130407Sdfr	uint32_t id;
341130407Sdfr
342130407Sdfr	/*
343130407Sdfr	 * Find an existing reassembly buffer or create a new one.
344130407Sdfr	 */
345130407Sdfr	enc = mtod(m, union fw_encap *);
346130407Sdfr	id = enc->firstfrag.dgl | (src << 16);
347130407Sdfr	STAILQ_FOREACH(r, &fc->fc_frags, fr_link)
348130407Sdfr		if (r->fr_id == id)
349130407Sdfr			break;
350130407Sdfr	if (!r) {
351130407Sdfr		r = malloc(sizeof(struct fw_reass), M_TEMP, M_NOWAIT);
352130407Sdfr		if (!r) {
353130407Sdfr			m_freem(m);
354130407Sdfr			return 0;
355130407Sdfr		}
356130407Sdfr		r->fr_id = id;
357130407Sdfr		r->fr_frags = 0;
358130407Sdfr		STAILQ_INSERT_HEAD(&fc->fc_frags, r, fr_link);
359130407Sdfr	}
360130407Sdfr
361130407Sdfr	/*
362130407Sdfr	 * If this fragment overlaps any other fragment, we must discard
363130407Sdfr	 * the partial reassembly and start again.
364130407Sdfr	 */
365130407Sdfr	if (enc->firstfrag.lf == FW_ENCAP_FIRST)
366130407Sdfr		fstart = 0;
367130407Sdfr	else
368130407Sdfr		fstart = enc->nextfrag.fragment_offset;
369130407Sdfr	fend = fstart + m->m_pkthdr.len - 2*sizeof(uint32_t);
370130407Sdfr	dsize = enc->nextfrag.datagram_size;
371130407Sdfr	islast = (enc->nextfrag.lf == FW_ENCAP_LAST);
372130407Sdfr
373130407Sdfr	for (mf = r->fr_frags; mf; mf = mf->m_nextpkt) {
374130407Sdfr		enc = mtod(mf, union fw_encap *);
375130407Sdfr		if (enc->nextfrag.datagram_size != dsize) {
376130407Sdfr			/*
377130407Sdfr			 * This fragment must be from a different
378130407Sdfr			 * packet.
379130407Sdfr			 */
380130407Sdfr			goto bad;
381130407Sdfr		}
382130407Sdfr		if (enc->firstfrag.lf == FW_ENCAP_FIRST)
383130407Sdfr			start = 0;
384130407Sdfr		else
385130407Sdfr			start = enc->nextfrag.fragment_offset;
386130407Sdfr		end = start + mf->m_pkthdr.len - 2*sizeof(uint32_t);
387130407Sdfr		if ((fstart < end && fend > start) ||
388130407Sdfr		    (islast && enc->nextfrag.lf == FW_ENCAP_LAST)) {
389130407Sdfr			/*
390130407Sdfr			 * Overlap - discard reassembly buffer and start
391130407Sdfr			 * again with this fragment.
392130407Sdfr			 */
393130407Sdfr			goto bad;
394130407Sdfr		}
395130407Sdfr	}
396130407Sdfr
397130407Sdfr	/*
398130407Sdfr	 * Find where to put this fragment in the list.
399130407Sdfr	 */
400130407Sdfr	for (mf = r->fr_frags, mprev = NULL; mf;
401130407Sdfr	    mprev = mf, mf = mf->m_nextpkt) {
402130407Sdfr		enc = mtod(mf, union fw_encap *);
403130407Sdfr		if (enc->firstfrag.lf == FW_ENCAP_FIRST)
404130407Sdfr			start = 0;
405130407Sdfr		else
406130407Sdfr			start = enc->nextfrag.fragment_offset;
407130407Sdfr		if (start >= fend)
408130407Sdfr			break;
409130407Sdfr	}
410130407Sdfr
411130407Sdfr	/*
412130407Sdfr	 * If this is a last fragment and we are not adding at the end
413130407Sdfr	 * of the list, discard the buffer.
414130407Sdfr	 */
415130407Sdfr	if (islast && mprev && mprev->m_nextpkt)
416130407Sdfr		goto bad;
417130407Sdfr
418130407Sdfr	if (mprev) {
419130407Sdfr		m->m_nextpkt = mprev->m_nextpkt;
420130407Sdfr		mprev->m_nextpkt = m;
421130407Sdfr
422130407Sdfr		/*
423130407Sdfr		 * Coalesce forwards and see if we can make a whole
424130407Sdfr		 * datagram.
425130407Sdfr		 */
426130407Sdfr		enc = mtod(mprev, union fw_encap *);
427130407Sdfr		if (enc->firstfrag.lf == FW_ENCAP_FIRST)
428130407Sdfr			start = 0;
429130407Sdfr		else
430130407Sdfr			start = enc->nextfrag.fragment_offset;
431130407Sdfr		end = start + mprev->m_pkthdr.len - 2*sizeof(uint32_t);
432130407Sdfr		while (end == fstart) {
433130407Sdfr			/*
434130407Sdfr			 * Strip off the encap header from m and
435130407Sdfr			 * append it to mprev, freeing m.
436130407Sdfr			 */
437130407Sdfr			m_adj(m, 2*sizeof(uint32_t));
438130407Sdfr			mprev->m_nextpkt = m->m_nextpkt;
439130407Sdfr			mprev->m_pkthdr.len += m->m_pkthdr.len;
440130407Sdfr			m_cat(mprev, m);
441130407Sdfr
442130407Sdfr			if (mprev->m_pkthdr.len == dsize + 1 + 2*sizeof(uint32_t)) {
443130407Sdfr				/*
444130407Sdfr				 * We have assembled a complete packet
445130407Sdfr				 * we must be finished. Make sure we have
446130407Sdfr				 * merged the whole chain.
447130407Sdfr				 */
448130407Sdfr				STAILQ_REMOVE(&fc->fc_frags, r, fw_reass, fr_link);
449130407Sdfr				free(r, M_TEMP);
450130407Sdfr				m = mprev->m_nextpkt;
451130407Sdfr				while (m) {
452130407Sdfr					mf = m->m_nextpkt;
453130407Sdfr					m_freem(m);
454130407Sdfr					m = mf;
455130407Sdfr				}
456130407Sdfr				mprev->m_nextpkt = NULL;
457130407Sdfr
458130407Sdfr				return (mprev);
459130407Sdfr			}
460130407Sdfr
461130407Sdfr			/*
462130407Sdfr			 * See if we can continue merging forwards.
463130407Sdfr			 */
464130407Sdfr			end = fend;
465130407Sdfr			m = mprev->m_nextpkt;
466130407Sdfr			if (m) {
467130407Sdfr				enc = mtod(m, union fw_encap *);
468130407Sdfr				if (enc->firstfrag.lf == FW_ENCAP_FIRST)
469130407Sdfr					fstart = 0;
470130407Sdfr				else
471130407Sdfr					fstart = enc->nextfrag.fragment_offset;
472130407Sdfr				fend = fstart + m->m_pkthdr.len
473130407Sdfr				    - 2*sizeof(uint32_t);
474130407Sdfr			} else {
475130407Sdfr				break;
476130407Sdfr			}
477130407Sdfr		}
478130407Sdfr	} else {
479130407Sdfr		m->m_nextpkt = 0;
480130407Sdfr		r->fr_frags = m;
481130407Sdfr	}
482130407Sdfr
483130407Sdfr	return (0);
484130407Sdfr
485130407Sdfrbad:
486130407Sdfr	while (r->fr_frags) {
487130407Sdfr		mf = r->fr_frags;
488130407Sdfr		r->fr_frags = mf->m_nextpkt;
489130407Sdfr		m_freem(mf);
490130407Sdfr	}
491130407Sdfr	m->m_nextpkt = 0;
492130407Sdfr	r->fr_frags = m;
493130407Sdfr
494130407Sdfr	return (0);
495130407Sdfr}
496130407Sdfr
497130407Sdfrvoid
498130407Sdfrfirewire_input(struct ifnet *ifp, struct mbuf *m, uint16_t src)
499130407Sdfr{
500154209Sbrooks	struct fw_com *fc = IFP2FWC(ifp);
501130407Sdfr	union fw_encap *enc;
502130407Sdfr	int type, isr;
503130407Sdfr
504130407Sdfr	/*
505130407Sdfr	 * The caller has already stripped off the packet header
506130407Sdfr	 * (stream or wreqb) and marked the mbuf's M_BCAST flag
507130407Sdfr	 * appropriately. We de-encapsulate the IP packet and pass it
508130407Sdfr	 * up the line after handling link-level fragmentation.
509130407Sdfr	 */
510130407Sdfr	if (m->m_pkthdr.len < sizeof(uint32_t)) {
511130407Sdfr		if_printf(ifp, "discarding frame without "
512130407Sdfr		    "encapsulation header (len %u pkt len %u)\n",
513130407Sdfr		    m->m_len, m->m_pkthdr.len);
514130407Sdfr	}
515130407Sdfr
516130407Sdfr	m = m_pullup(m, sizeof(uint32_t));
517169735Srwatson	if (m == NULL)
518169735Srwatson		return;
519130407Sdfr	enc = mtod(m, union fw_encap *);
520130407Sdfr
521130407Sdfr	/*
522130407Sdfr	 * Byte swap the encapsulation header manually.
523130407Sdfr	 */
524151265Simp	enc->ul[0] = ntohl(enc->ul[0]);
525130407Sdfr
526130407Sdfr	if (enc->unfrag.lf != 0) {
527130407Sdfr		m = m_pullup(m, 2*sizeof(uint32_t));
528130407Sdfr		if (!m)
529130407Sdfr			return;
530130407Sdfr		enc = mtod(m, union fw_encap *);
531151265Simp		enc->ul[1] = ntohl(enc->ul[1]);
532130407Sdfr		m = firewire_input_fragment(fc, m, src);
533130407Sdfr		if (!m)
534130407Sdfr			return;
535130407Sdfr		enc = mtod(m, union fw_encap *);
536130407Sdfr		type = enc->firstfrag.ether_type;
537130407Sdfr		m_adj(m, 2*sizeof(uint32_t));
538130407Sdfr	} else {
539130407Sdfr		type = enc->unfrag.ether_type;
540130407Sdfr		m_adj(m, sizeof(uint32_t));
541130407Sdfr	}
542130407Sdfr
543130407Sdfr	if (m->m_pkthdr.rcvif == NULL) {
544130407Sdfr		if_printf(ifp, "discard frame w/o interface pointer\n");
545271867Sglebius		if_inc_counter(ifp, IFCOUNTER_IERRORS, 1);
546130407Sdfr		m_freem(m);
547130407Sdfr		return;
548130407Sdfr	}
549130407Sdfr#ifdef DIAGNOSTIC
550130407Sdfr	if (m->m_pkthdr.rcvif != ifp) {
551130407Sdfr		if_printf(ifp, "Warning, frame marked as received on %s\n",
552130407Sdfr			m->m_pkthdr.rcvif->if_xname);
553130407Sdfr	}
554130407Sdfr#endif
555130407Sdfr
556130407Sdfr#ifdef MAC
557130407Sdfr	/*
558130407Sdfr	 * Tag the mbuf with an appropriate MAC label before any other
559130407Sdfr	 * consumers can get to it.
560130407Sdfr	 */
561172930Srwatson	mac_ifnet_create_mbuf(ifp, m);
562130407Sdfr#endif
563130407Sdfr
564130407Sdfr	/*
565130407Sdfr	 * Give bpf a chance at the packet. The link-level driver
566130407Sdfr	 * should have left us a tag with the EUID of the sender.
567130407Sdfr	 */
568159183Ssam	if (bpf_peers_present(ifp->if_bpf)) {
569130407Sdfr		struct fw_bpfhdr h;
570130407Sdfr		struct m_tag *mtag;
571130407Sdfr
572130407Sdfr		mtag = m_tag_locate(m, MTAG_FIREWIRE, MTAG_FIREWIRE_SENDER_EUID, 0);
573130407Sdfr		if (mtag)
574130407Sdfr			bcopy(mtag + 1, h.firewire_shost, 8);
575130407Sdfr		else
576130407Sdfr			bcopy(&firewire_broadcastaddr, h.firewire_dhost, 8);
577130407Sdfr		bcopy(&fc->fc_hwaddr, h.firewire_dhost, 8);
578130407Sdfr		h.firewire_type = htons(type);
579130407Sdfr		bpf_mtap2(ifp->if_bpf, &h, sizeof(h), m);
580130407Sdfr	}
581130407Sdfr
582130407Sdfr	if (ifp->if_flags & IFF_MONITOR) {
583130407Sdfr		/*
584130407Sdfr		 * Interface marked for monitoring; discard packet.
585130407Sdfr		 */
586130407Sdfr		m_freem(m);
587130407Sdfr		return;
588130407Sdfr	}
589130407Sdfr
590271867Sglebius	if_inc_counter(ifp, IFCOUNTER_IBYTES, m->m_pkthdr.len);
591130407Sdfr
592130407Sdfr	/* Discard packet if interface is not up */
593130407Sdfr	if ((ifp->if_flags & IFF_UP) == 0) {
594130407Sdfr		m_freem(m);
595130407Sdfr		return;
596130407Sdfr	}
597130407Sdfr
598130407Sdfr	if (m->m_flags & (M_BCAST|M_MCAST))
599271867Sglebius		if_inc_counter(ifp, IFCOUNTER_IMCASTS, 1);
600130407Sdfr
601130407Sdfr	switch (type) {
602130407Sdfr#ifdef INET
603130407Sdfr	case ETHERTYPE_IP:
604130407Sdfr		isr = NETISR_IP;
605130407Sdfr		break;
606130407Sdfr
607130407Sdfr	case ETHERTYPE_ARP:
608130407Sdfr	{
609130407Sdfr		struct arphdr *ah;
610130407Sdfr		ah = mtod(m, struct arphdr *);
611130407Sdfr
612130407Sdfr		/*
613130407Sdfr		 * Adjust the arp packet to insert an empty tha slot.
614130407Sdfr		 */
615130407Sdfr		m->m_len += ah->ar_hln;
616130407Sdfr		m->m_pkthdr.len += ah->ar_hln;
617130407Sdfr		bcopy(ar_tha(ah), ar_tpa(ah), ah->ar_pln);
618130407Sdfr		isr = NETISR_ARP;
619130407Sdfr		break;
620130407Sdfr	}
621130407Sdfr#endif
622130407Sdfr
623130407Sdfr#ifdef INET6
624130407Sdfr	case ETHERTYPE_IPV6:
625130407Sdfr		isr = NETISR_IPV6;
626130407Sdfr		break;
627130407Sdfr#endif
628130407Sdfr
629130407Sdfr	default:
630130407Sdfr		m_freem(m);
631130407Sdfr		return;
632130407Sdfr	}
633130407Sdfr
634223741Sbz	M_SETFIB(m, ifp->if_fib);
635369819Savatar	CURVNET_SET_QUIET(ifp->if_vnet);
636130407Sdfr	netisr_dispatch(isr, m);
637369819Savatar	CURVNET_RESTORE();
638130407Sdfr}
639130407Sdfr
640130407Sdfrint
641194581Srdivackyfirewire_ioctl(struct ifnet *ifp, u_long command, caddr_t data)
642130407Sdfr{
643130407Sdfr	struct ifaddr *ifa = (struct ifaddr *) data;
644130407Sdfr	struct ifreq *ifr = (struct ifreq *) data;
645130407Sdfr	int error = 0;
646130407Sdfr
647130407Sdfr	switch (command) {
648130407Sdfr	case SIOCSIFADDR:
649130407Sdfr		ifp->if_flags |= IFF_UP;
650130407Sdfr
651130407Sdfr		switch (ifa->ifa_addr->sa_family) {
652130407Sdfr#ifdef INET
653130407Sdfr		case AF_INET:
654130407Sdfr			ifp->if_init(ifp->if_softc);	/* before arpwhohas */
655130407Sdfr			arp_ifinit(ifp, ifa);
656130407Sdfr			break;
657130407Sdfr#endif
658130407Sdfr		default:
659130407Sdfr			ifp->if_init(ifp->if_softc);
660130407Sdfr			break;
661130407Sdfr		}
662130407Sdfr		break;
663130407Sdfr
664130407Sdfr	case SIOCGIFADDR:
665332159Sbrooks		bcopy(&IFP2FWC(ifp)->fc_hwaddr, &ifr->ifr_addr.sa_data[0],
666332159Sbrooks		    sizeof(struct fw_hwaddr));
667130407Sdfr		break;
668130407Sdfr
669130407Sdfr	case SIOCSIFMTU:
670130407Sdfr		/*
671130407Sdfr		 * Set the interface MTU.
672130407Sdfr		 */
673130407Sdfr		if (ifr->ifr_mtu > 1500) {
674130407Sdfr			error = EINVAL;
675130407Sdfr		} else {
676130407Sdfr			ifp->if_mtu = ifr->ifr_mtu;
677130407Sdfr		}
678130407Sdfr		break;
679130407Sdfr	default:
680130407Sdfr		error = EINVAL;			/* XXX netbsd has ENOTTY??? */
681130407Sdfr		break;
682130407Sdfr	}
683130407Sdfr	return (error);
684130407Sdfr}
685130407Sdfr
686130407Sdfrstatic int
687130407Sdfrfirewire_resolvemulti(struct ifnet *ifp, struct sockaddr **llsa,
688130407Sdfr    struct sockaddr *sa)
689130407Sdfr{
690130407Sdfr#ifdef INET
691130407Sdfr	struct sockaddr_in *sin;
692130407Sdfr#endif
693130407Sdfr#ifdef INET6
694130407Sdfr	struct sockaddr_in6 *sin6;
695130407Sdfr#endif
696130407Sdfr
697130407Sdfr	switch(sa->sa_family) {
698130407Sdfr	case AF_LINK:
699130407Sdfr		/*
700130407Sdfr		 * No mapping needed.
701130407Sdfr		 */
702298075Spfg		*llsa = NULL;
703130407Sdfr		return 0;
704130407Sdfr
705130407Sdfr#ifdef INET
706130407Sdfr	case AF_INET:
707130407Sdfr		sin = (struct sockaddr_in *)sa;
708130407Sdfr		if (!IN_MULTICAST(ntohl(sin->sin_addr.s_addr)))
709130407Sdfr			return EADDRNOTAVAIL;
710298075Spfg		*llsa = NULL;
711130407Sdfr		return 0;
712130407Sdfr#endif
713130407Sdfr#ifdef INET6
714130407Sdfr	case AF_INET6:
715130407Sdfr		sin6 = (struct sockaddr_in6 *)sa;
716130407Sdfr		if (IN6_IS_ADDR_UNSPECIFIED(&sin6->sin6_addr)) {
717130407Sdfr			/*
718130407Sdfr			 * An IP6 address of 0 means listen to all
719130407Sdfr			 * of the Ethernet multicast address used for IP6.
720130407Sdfr			 * (This is used for multicast routers.)
721130407Sdfr			 */
722130407Sdfr			ifp->if_flags |= IFF_ALLMULTI;
723298075Spfg			*llsa = NULL;
724130407Sdfr			return 0;
725130407Sdfr		}
726130407Sdfr		if (!IN6_IS_ADDR_MULTICAST(&sin6->sin6_addr))
727130407Sdfr			return EADDRNOTAVAIL;
728298075Spfg		*llsa = NULL;
729130407Sdfr		return 0;
730130407Sdfr#endif
731130407Sdfr
732130407Sdfr	default:
733130407Sdfr		/*
734130407Sdfr		 * Well, the text isn't quite right, but it's the name
735130407Sdfr		 * that counts...
736130407Sdfr		 */
737130407Sdfr		return EAFNOSUPPORT;
738130407Sdfr	}
739130407Sdfr}
740130407Sdfr
741130407Sdfrvoid
742130407Sdfrfirewire_ifattach(struct ifnet *ifp, struct fw_hwaddr *llc)
743130407Sdfr{
744154209Sbrooks	struct fw_com *fc = IFP2FWC(ifp);
745130407Sdfr	struct ifaddr *ifa;
746130407Sdfr	struct sockaddr_dl *sdl;
747130407Sdfr	static const char* speeds[] = {
748130407Sdfr		"S100", "S200", "S400", "S800",
749130407Sdfr		"S1600", "S3200"
750130407Sdfr	};
751130407Sdfr
752130407Sdfr	fc->fc_speed = llc->sspd;
753130407Sdfr	STAILQ_INIT(&fc->fc_frags);
754130407Sdfr
755130407Sdfr	ifp->if_addrlen = sizeof(struct fw_hwaddr);
756130407Sdfr	ifp->if_hdrlen = 0;
757130407Sdfr	if_attach(ifp);
758130407Sdfr	ifp->if_mtu = 1500;	/* XXX */
759130407Sdfr	ifp->if_output = firewire_output;
760130407Sdfr	ifp->if_resolvemulti = firewire_resolvemulti;
761130407Sdfr	ifp->if_broadcastaddr = (u_char *) &firewire_broadcastaddr;
762130407Sdfr
763152315Sru	ifa = ifp->if_addr;
764130407Sdfr	KASSERT(ifa != NULL, ("%s: no lladdr!\n", __func__));
765130407Sdfr	sdl = (struct sockaddr_dl *)ifa->ifa_addr;
766130407Sdfr	sdl->sdl_type = IFT_IEEE1394;
767130407Sdfr	sdl->sdl_alen = ifp->if_addrlen;
768130407Sdfr	bcopy(llc, LLADDR(sdl), ifp->if_addrlen);
769130407Sdfr
770130407Sdfr	bpfattach(ifp, DLT_APPLE_IP_OVER_IEEE1394,
771130407Sdfr	    sizeof(struct fw_hwaddr));
772130407Sdfr
773130407Sdfr	if_printf(ifp, "Firewire address: %8D @ 0x%04x%08x, %s, maxrec %d\n",
774130407Sdfr	    (uint8_t *) &llc->sender_unique_ID_hi, ":",
775130407Sdfr	    ntohs(llc->sender_unicast_FIFO_hi),
776130407Sdfr	    ntohl(llc->sender_unicast_FIFO_lo),
777130407Sdfr	    speeds[llc->sspd],
778130407Sdfr	    (2 << llc->sender_max_rec));
779130407Sdfr}
780130407Sdfr
781130407Sdfrvoid
782130407Sdfrfirewire_ifdetach(struct ifnet *ifp)
783130407Sdfr{
784130407Sdfr	bpfdetach(ifp);
785130407Sdfr	if_detach(ifp);
786130407Sdfr}
787130407Sdfr
788130407Sdfrvoid
789130407Sdfrfirewire_busreset(struct ifnet *ifp)
790130407Sdfr{
791154209Sbrooks	struct fw_com *fc = IFP2FWC(ifp);
792130407Sdfr	struct fw_reass *r;
793130407Sdfr	struct mbuf *m;
794130407Sdfr
795130407Sdfr	/*
796130407Sdfr	 * Discard any partial datagrams since the host ids may have changed.
797130407Sdfr	 */
798130407Sdfr	while ((r = STAILQ_FIRST(&fc->fc_frags))) {
799130407Sdfr		STAILQ_REMOVE_HEAD(&fc->fc_frags, fr_link);
800130407Sdfr		while (r->fr_frags) {
801130407Sdfr			m = r->fr_frags;
802130407Sdfr			r->fr_frags = m->m_nextpkt;
803130407Sdfr			m_freem(m);
804130407Sdfr		}
805130407Sdfr		free(r, M_TEMP);
806130407Sdfr	}
807130407Sdfr}
808147256Sbrooks
809147256Sbrooksstatic void *
810147256Sbrooksfirewire_alloc(u_char type, struct ifnet *ifp)
811147256Sbrooks{
812147256Sbrooks	struct fw_com	*fc;
813147256Sbrooks
814147256Sbrooks	fc = malloc(sizeof(struct fw_com), M_FWCOM, M_WAITOK | M_ZERO);
815147256Sbrooks	fc->fc_ifp = ifp;
816147256Sbrooks
817147256Sbrooks	return (fc);
818147256Sbrooks}
819147256Sbrooks
820147256Sbrooksstatic void
821147256Sbrooksfirewire_free(void *com, u_char type)
822147256Sbrooks{
823147256Sbrooks
824147256Sbrooks	free(com, M_FWCOM);
825147256Sbrooks}
826147256Sbrooks
827147256Sbrooksstatic int
828147256Sbrooksfirewire_modevent(module_t mod, int type, void *data)
829147256Sbrooks{
830147256Sbrooks
831147256Sbrooks	switch (type) {
832147256Sbrooks	case MOD_LOAD:
833147256Sbrooks		if_register_com_alloc(IFT_IEEE1394,
834147256Sbrooks		    firewire_alloc, firewire_free);
835147256Sbrooks		break;
836147256Sbrooks	case MOD_UNLOAD:
837147256Sbrooks		if_deregister_com_alloc(IFT_IEEE1394);
838147256Sbrooks		break;
839147256Sbrooks	default:
840147256Sbrooks		return (EOPNOTSUPP);
841147256Sbrooks	}
842147256Sbrooks
843147256Sbrooks	return (0);
844147256Sbrooks}
845147256Sbrooks
846147256Sbrooksstatic moduledata_t firewire_mod = {
847150988Savatar	"if_firewire",
848147256Sbrooks	firewire_modevent,
849241394Skevlo	0
850147256Sbrooks};
851147256Sbrooks
852150988SavatarDECLARE_MODULE(if_firewire, firewire_mod, SI_SUB_INIT_IF, SI_ORDER_ANY);
853150988SavatarMODULE_VERSION(if_firewire, 1);
854