xref: /csrg-svn/sys/deprecated/netimp/if_imp.c (revision 34509)
123166Smckusick /*
233453Skarels  * Copyright (c) 1982,1986,1988 Regents of the University of California.
333453Skarels  * All rights reserved.
423166Smckusick  *
533453Skarels  * Redistribution and use in source and binary forms are permitted
633453Skarels  * provided that this notice is preserved and that due credit is given
733453Skarels  * to the University of California at Berkeley. The name of the University
833453Skarels  * may not be used to endorse or promote products derived from this
933453Skarels  * software without specific prior written permission. This software
1033453Skarels  * is provided ``as is'' without express or implied warranty.
1133453Skarels  *
12*34509Skarels  *	@(#)if_imp.c	7.7 (Berkeley) 05/26/88
1323166Smckusick  */
145640Sroot 
155640Sroot #include "imp.h"
165640Sroot #if NIMP > 0
175640Sroot /*
1833453Skarels  * ARPANET IMP (PSN) interface driver.
195640Sroot  *
2033453Skarels  * The IMP-host protocol (AHIP) is handled here, leaving
215640Sroot  * hardware specifics to the lower level interface driver.
225640Sroot  */
2317068Sbloom #include "param.h"
2417068Sbloom #include "systm.h"
2517068Sbloom #include "mbuf.h"
2617068Sbloom #include "buf.h"
2717068Sbloom #include "protosw.h"
2817068Sbloom #include "socket.h"
2917068Sbloom #include "time.h"
3017068Sbloom #include "kernel.h"
3117068Sbloom #include "errno.h"
3217068Sbloom #include "ioctl.h"
3333427Skarels #include "syslog.h"
348705Sroot 
3533453Skarels #include "../machine/mtpr.h"
3633453Skarels 
378705Sroot #include "../net/if.h"
388705Sroot #include "../net/netisr.h"
398408Swnj #include "../netinet/in.h"
408408Swnj #include "../netinet/in_systm.h"
4118412Skarels #include "../netinet/in_var.h"
428705Sroot #include "../netinet/ip.h"
438705Sroot #include "../netinet/ip_var.h"
4433427Skarels #define IMPMESSAGES
457199Ssam /* define IMPLEADERS here to get leader printing code */
4617068Sbloom #include "if_imp.h"
4717068Sbloom #include "if_imphost.h"
485640Sroot 
4933427Skarels struct	imp_softc imp_softc[NIMP];
5033453Skarels #ifndef lint
5133453Skarels int	nimp = NIMP;			/* for netstat */
5233453Skarels #endif
5328849Skarels struct	ifqueue impintrq;
5428849Skarels int	impqmaxlen = IFQ_MAXLEN;
5533453Skarels int	imphqlen = 12 + IMP_MAXHOSTMSG;	/* max packets to queue per host */
5624777Skarels 
5733427Skarels int	imppri = LOG_ERR;
5833427Skarels #ifdef IMPLEADERS
5933427Skarels int	impprintfs = 0;
6033427Skarels #endif
6133427Skarels #ifdef IMPINIT
6233427Skarels int	imptraceinit = 0;
6333427Skarels #endif
645640Sroot 
6533453Skarels 
6633427Skarels #define HOSTDEADTIMER	(30 * PR_SLOWHZ)	/* How long to wait when down */
6718132Skarels 
6833453Skarels int	impdown(), impinit(), impioctl(), impoutput(), imptimo();
695771Swnj 
705640Sroot /*
715640Sroot  * IMP attach routine.  Called from hardware device attach routine
7233427Skarels  * at configuration time with a pointer to the device structure.
735640Sroot  * Sets up local state and returns pointer to base of ifnet+impcb
745640Sroot  * structures.  This is then used by the device's attach routine
755640Sroot  * set up its back pointers.
765640Sroot  */
7733427Skarels struct imp_softc *
7834209Skarels impattach(hwname, hwunit, reset)
7934209Skarels 	char *hwname;
8034209Skarels 	int hwunit;
818815Sroot 	int (*reset)();
825640Sroot {
8324777Skarels 	struct imp_softc *sc;
8424777Skarels 	register struct ifnet *ifp;
8533427Skarels 	static int impunit;
865640Sroot 
8726397Skarels #ifdef lint
8826397Skarels 	impintr();
8926397Skarels #endif
9033427Skarels 	if (impunit >= NIMP) {
9133427Skarels 		printf("imp%d: not configured\n", impunit++);
9224777Skarels 		return (0);
9324777Skarels 	}
9433427Skarels 	sc = &imp_softc[impunit];
9524777Skarels 	ifp = &sc->imp_if;
9634209Skarels 	sc->imp_cb.ic_hwname = hwname;
9734209Skarels 	sc->imp_cb.ic_hwunit = hwunit;
9833427Skarels 	ifp->if_unit = impunit;
995640Sroot 	ifp->if_name = "imp";
1006271Sroot 	ifp->if_mtu = IMPMTU - sizeof(struct imp_leader);
1019001Sroot 	ifp->if_reset = reset;
1025771Swnj 	ifp->if_init = impinit;
10313067Ssam 	ifp->if_ioctl = impioctl;
1045771Swnj 	ifp->if_output = impoutput;
10533453Skarels 	ifp->if_watchdog = imptimo;
1065640Sroot 	if_attach(ifp);
10733427Skarels 	impunit++;
10833427Skarels 	return (sc);
1095640Sroot }
1105640Sroot 
1115640Sroot /*
1125640Sroot  * IMP initialization routine: call hardware module to
11333427Skarels  * setup resources, init state and get ready for
1145640Sroot  * NOOPs the IMP should send us, and that we want to drop.
1155640Sroot  */
1165640Sroot impinit(unit)
1175640Sroot 	int unit;
1185640Sroot {
11932570Sbostic 	int s;
1205640Sroot 	register struct imp_softc *sc = &imp_softc[unit];
1215640Sroot 
12218412Skarels 	if (sc->imp_if.if_addrlist == 0)
12313067Ssam 		return;
12432570Sbostic 	s = splimp();
12533427Skarels #ifdef IMPINIT
12633427Skarels 	if (imptraceinit)
12733427Skarels 		log(imppri, "impinit\n");
12833427Skarels #endif
12933427Skarels 	sc->imp_state = IMPS_WINIT;
13033427Skarels 	if ((*sc->imp_cb.ic_init)(sc->imp_cb.ic_hwunit) == 0)
1316336Ssam 		sc->imp_if.if_flags &= ~IFF_UP;
13233427Skarels 	impintrq.ifq_maxlen = impqmaxlen;
1336500Ssam 	splx(s);
1345640Sroot }
1355640Sroot 
1365640Sroot /*
13733453Skarels  * ARPAnet 1822/AHIP input routine.
1385640Sroot  * Called from hardware input interrupt routine to handle 1822
13933453Skarels  * IMP-host messages.  Data messages are passed to higher-level
14033453Skarels  * protocol processors on the basis of link number.
14133453Skarels  * Other type messages (control) are handled here.
1425640Sroot  */
1435771Swnj impinput(unit, m)
1445640Sroot 	int unit;
1455771Swnj 	register struct mbuf *m;
1465640Sroot {
14733427Skarels 	register struct control_leader *cp;
14833427Skarels #define	ip	((struct imp_leader *)cp)
1495640Sroot 	register struct imp_softc *sc = &imp_softc[unit];
15024777Skarels 	struct ifnet *ifp;
1515640Sroot 	register struct host *hp;
1525640Sroot 	register struct ifqueue *inq;
1536336Ssam 	struct sockaddr_in *sin;
15433453Skarels 	int s;
1555640Sroot 
15624777Skarels 	/*
15724777Skarels 	 * Pull the interface pointer out of the mbuf
15824777Skarels 	 * and save for later; adjust mbuf to look at rest of data.
15924777Skarels 	 */
16024777Skarels 	ifp = *(mtod(m, struct ifnet **));
16124777Skarels 	IF_ADJ(m);
1626257Sroot 	/* verify leader length. */
1635771Swnj 	if (m->m_len < sizeof(struct control_leader) &&
1645771Swnj 	    (m = m_pullup(m, sizeof(struct control_leader))) == 0)
1655771Swnj 		return;
1665771Swnj 	cp = mtod(m, struct control_leader *);
16733427Skarels 	if (cp->dl_mtype == IMPTYPE_DATA &&
16833427Skarels 	    m->m_len < sizeof(struct imp_leader)) {
16933427Skarels 		if ((m = m_pullup(m, sizeof(struct imp_leader))) == 0)
1705771Swnj 			return;
17133427Skarels 		cp = mtod(m, struct control_leader *);
17233427Skarels 	}
1737199Ssam #ifdef IMPLEADERS
1747170Ssam 	if (impprintfs)
1757170Ssam 		printleader("impinput", ip);
1767199Ssam #endif
17728849Skarels 	inq = &impintrq;
1785640Sroot 
1796257Sroot 	/* check leader type */
18033427Skarels 	if (cp->dl_format != IMP_NFF) {
18134209Skarels 		/*
18234209Skarels 		 * We get 1822L NOOPs and RESET
18334209Skarels 		 * at initialization.
18434209Skarels 		 */
18534209Skarels #ifdef IMPINIT
18634209Skarels 		if (imptraceinit)
18734209Skarels 			log(imppri, "input, format %x mtype %d\n",
18834209Skarels 			    cp->dl_format, cp->dl_mtype);
18934209Skarels #endif
19034209Skarels 		if (cp->dl_format != IMP_1822L_I2H ||
19134209Skarels 		    (cp->dl_mtype != IMPTYPE_NOOP &&
19234209Skarels 		    cp->dl_mtype != IMPTYPE_RESET)) {
19333453Skarels 			sc->imp_garbage++;
19433453Skarels 			sc->imp_if.if_collisions++;	/* XXX */
19533453Skarels 		}
19633427Skarels 	} else switch (cp->dl_mtype) {
1975640Sroot 
1985640Sroot 	case IMPTYPE_DATA:
19928849Skarels 		/*
20028849Skarels 		 * Data for a protocol.  Dispatch to the appropriate
20128849Skarels 		 * protocol routine (running at software interrupt).
20228849Skarels 		 * If this isn't a raw interface, advance pointer
20328849Skarels 		 * into mbuf past leader.
20428849Skarels 		 */
20533427Skarels 		switch (cp->dl_link) {
20628849Skarels 
20728849Skarels 		case IMPLINK_IP:
20828849Skarels 			m->m_len -= sizeof(struct imp_leader);
20928849Skarels 			m->m_off += sizeof(struct imp_leader);
21028849Skarels 			schednetisr(NETISR_IP);
21128849Skarels 			inq = &ipintrq;
21228849Skarels 			break;
21328849Skarels 
21428849Skarels 		default:
21528849Skarels 			break;
21628849Skarels 		}
2175640Sroot 		break;
2185640Sroot 
2195640Sroot 	/*
2205640Sroot 	 * IMP leader error.  Reset the IMP and discard the packet.
2215640Sroot 	 */
2225640Sroot 	case IMPTYPE_BADLEADER:
2235647Ssam 		/*
2245647Ssam 		 * According to 1822 document, this message
2255647Ssam 		 * will be generated in response to the
2265647Ssam 		 * first noop sent to the IMP after
2275647Ssam 		 * the host resets the IMP interface.
2285647Ssam 		 */
22933427Skarels #ifdef IMPINIT
23033427Skarels 		if (imptraceinit)
23133427Skarels 			log(imppri, "badleader\n");
23233427Skarels #endif
2335771Swnj 		if (sc->imp_state != IMPS_INIT) {
2345924Sroot 			impmsg(sc, "leader error");
23533453Skarels 			sc->imp_msgready = 0;
23633427Skarels 			hostreset(unit);
2375647Ssam 			impnoops(sc);
23833453Skarels 			sc->imp_garbage++;
2395647Ssam 		}
24028849Skarels 		break;
2415640Sroot 
2425640Sroot 	/*
2435640Sroot 	 * IMP going down.  Print message, and if not immediate,
2445640Sroot 	 * set off a timer to insure things will be reset at the
2455640Sroot 	 * appropriate time.
2465640Sroot 	 */
2475640Sroot 	case IMPTYPE_DOWN:
24833427Skarels 	    {	int type, when;
24933427Skarels 
25033427Skarels 		type = cp->dl_link & IMP_DMASK;
25133427Skarels 		when = (cp->dl_link & IMPDOWN_WHENMASK) >> IMPDOWN_WHENSHIFT;
25233427Skarels #ifdef IMPINIT
25333427Skarels 		if (imptraceinit)
25433427Skarels 			log(imppri, "input DOWN %s %d\n",
25533427Skarels 			    impmessage[type], when * IMPDOWN_WHENUNIT);
25633427Skarels #endif
25733427Skarels 		if (type != IMPDOWN_GOING && when)
25833427Skarels 			impmsg(sc, "going down %s in %d minutes",
25933427Skarels 			    (u_int)impmessage[type], when * IMPDOWN_WHENUNIT);
26033427Skarels 		else
26133427Skarels 			impmsg(sc, "going down %s", (u_int)impmessage[type]);
26233427Skarels 		if (sc->imp_state != IMPS_UP)
26328849Skarels 			break;
26433427Skarels 		if (type == IMPDOWN_GOING) {
2655640Sroot 			sc->imp_state = IMPS_GOINGDOWN;
26633427Skarels 			timeout(impdown, (caddr_t)sc, IMPTV_DOWN * hz);
26733427Skarels 		} else if (when == 0)
26833427Skarels 			sc->imp_state = IMPS_WINIT;
26933427Skarels 		sc->imp_dropcnt = 0;
27028849Skarels 		break;
27133427Skarels 	    }
2725640Sroot 
2735640Sroot 	/*
27433427Skarels 	 * A NOP, usually seen during the initialization sequence.
2755640Sroot 	 * Compare the local address with that in the message.
2765640Sroot 	 * Reset the local address notion if it doesn't match.
2775640Sroot 	 */
2786336Ssam 	case IMPTYPE_NOOP:
27933427Skarels #ifdef IMPINIT
28033427Skarels 		if (imptraceinit)
28133427Skarels 			log(imppri, "noop\n");
28233427Skarels #endif
28333427Skarels 		if (sc->imp_state == IMPS_WINIT) {
28433427Skarels 			sc->imp_dropcnt = 0;
28533427Skarels 			impnoops(sc);
2865647Ssam 			sc->imp_state = IMPS_INIT;
2875647Ssam 		}
28833427Skarels 		sc->imp_dropcnt++;
28933427Skarels 		if (sc->imp_state == IMPS_INIT && cp->dl_imp != 0) {
29018132Skarels 			struct in_addr leader_addr;
29128849Skarels 
29233427Skarels 			sin = (struct sockaddr_in *)&sc->imp_if.if_addrlist->ifa_addr;
29333427Skarels 			imp_leader_to_addr(&leader_addr, cp, &sc->imp_if);
29418412Skarels 			if (sin->sin_addr.s_addr != leader_addr.s_addr) {
29518412Skarels 				impmsg(sc, "address reset to x%x (%d/%d)",
29628849Skarels 					ntohl(leader_addr.s_addr),
29733427Skarels 					(u_int)cp->dl_host,
29833427Skarels 					ntohs(cp->dl_imp));
29918132Skarels 				sin->sin_addr.s_addr = leader_addr.s_addr;
30018132Skarels 			}
3016500Ssam 		}
30228849Skarels 		break;
3035640Sroot 
3045640Sroot 	/*
30533453Skarels 	 * RFNM or INCOMPLETE message, decrement rfnm count
30633453Skarels 	 * and prepare to send next message.
30734209Skarels 	 * If the rfnm allows another queued
30834209Skarels 	 * message to be sent, bump msgready
30934209Skarels 	 * and start IMP if idle.
31033453Skarels 	 * We could pass incomplete's up to the next level,
31133453Skarels 	 * but this currently isn't needed.
31234209Skarels 	 * Pass "bad" incompletes and rfnms to the raw socket.
3135640Sroot 	 */
31433427Skarels 	case IMPTYPE_INCOMPLETE:
31533427Skarels 		sc->imp_incomplete++;
31633427Skarels 		/* FALL THROUGH */
3175640Sroot 	case IMPTYPE_RFNM:
318*34509Skarels 		if ((hp = hostlookup((int)cp->dl_imp, (int)cp->dl_host,
319*34509Skarels 		    unit)) == 0 || hp->h_rfnm == 0) {
32034209Skarels 			sc->imp_badrfnm++;
32134209Skarels 			if (hp)
32233427Skarels 				hostfree(hp);
32334209Skarels 			break;
32434209Skarels 		}
32534209Skarels 		imprestarthost(sc, hp);
32634209Skarels 		if (cp->dl_mtype == IMPTYPE_RFNM)
32733427Skarels 			goto drop;
32833427Skarels 		break;
3295640Sroot 
3305640Sroot 	/*
3315640Sroot 	 * Host or IMP can't be reached.  Flush any packets
3325640Sroot 	 * awaiting transmission and release the host structure.
33324777Skarels 	 * Enqueue for notifying protocols at software interrupt time.
3345640Sroot 	 */
3355640Sroot 	case IMPTYPE_HOSTDEAD:
33611230Ssam 	case IMPTYPE_HOSTUNREACH:
337*34509Skarels 		if (hp = hostlookup((int)cp->dl_imp, (int)cp->dl_host, unit)) {
33833427Skarels 			hp->h_flags |= (1 << (int)cp->dl_mtype);
33933453Skarels 			sc->imp_msgready -=
34033453Skarels 			   MIN(hp->h_qcnt, IMP_MAXHOSTMSG - hp->h_rfnm);
34133427Skarels 			hp->h_rfnm = 0;
34233453Skarels 			hostflush(hp);
34324777Skarels 			hp->h_timer = HOSTDEADTIMER;
34424777Skarels 		}
34528849Skarels 		break;
3465640Sroot 
3475640Sroot 	/*
3485640Sroot 	 * Error in data.  Clear RFNM status for this host and send
3495640Sroot 	 * noops to the IMP to clear the interface.
3505640Sroot 	 */
35111230Ssam 	case IMPTYPE_BADDATA:
3525924Sroot 		impmsg(sc, "data error");
353*34509Skarels 		if (hp = hostlookup((int)cp->dl_imp, (int)cp->dl_host, unit)) {
35433453Skarels 			sc->imp_msgready -=
35533453Skarels 			   MIN(hp->h_qcnt, IMP_MAXHOSTMSG - hp->h_rfnm);
35634209Skarels 			if (hp->h_rfnm)
35734209Skarels 				hostrelease(hp);
35834209Skarels 			else
35934209Skarels 				hostfree(hp);
36033427Skarels 		}
3615640Sroot 		impnoops(sc);
36228849Skarels 		break;
3635640Sroot 
3645640Sroot 	/*
3655647Ssam 	 * Interface reset.
3665640Sroot 	 */
3675640Sroot 	case IMPTYPE_RESET:
36833427Skarels #ifdef IMPINIT
36933427Skarels 		if (imptraceinit)
37033427Skarels 			log(imppri, "reset complete\n");
37133427Skarels #endif
37233427Skarels 		if (sc->imp_state != IMPS_INIT) {
37333427Skarels 			impmsg(sc, "interface reset");
37433427Skarels 			impnoops(sc);
37533427Skarels 		}
37618412Skarels 		/* clear RFNM counts */
37733453Skarels 		sc->imp_msgready = 0;
37833427Skarels 		hostreset(unit);
37933427Skarels 		if (sc->imp_state != IMPS_DOWN) {
38033427Skarels 			sc->imp_state = IMPS_UP;
38133427Skarels 			sc->imp_if.if_flags |= IFF_UP;
38233427Skarels #ifdef IMPINIT
38333427Skarels 			if (imptraceinit)
38433427Skarels 				log(imppri, "IMP UP\n");
38533427Skarels #endif
38633427Skarels 		}
38728849Skarels 		break;
3885640Sroot 
3895640Sroot 	default:
39033427Skarels 		sc->imp_garbage++;
3915640Sroot 		sc->imp_if.if_collisions++;		/* XXX */
39228849Skarels 		break;
3935640Sroot 	}
3945640Sroot 
39528849Skarels 	if (inq == &impintrq)
39624777Skarels 		schednetisr(NETISR_IMP);
39724777Skarels 	/*
39824777Skarels 	 * Re-insert interface pointer in the mbuf chain
39924777Skarels 	 * for the next protocol up.
40024777Skarels 	 */
40128849Skarels 	if (M_HASCL(m) && (mtod(m, int) & CLOFSET) < sizeof(struct ifnet *)) {
40228849Skarels 		struct mbuf *n;
40328849Skarels 
40428849Skarels 		MGET(n, M_DONTWAIT, MT_HEADER);
40528849Skarels 		if (n == 0)
40628849Skarels 			goto drop;
40728849Skarels 		n->m_next = m;
40828849Skarels 		m = n;
40928849Skarels 		m->m_len = 0;
41028849Skarels 		m->m_off = MMINOFF + sizeof(struct ifnet  *);
41128849Skarels 	}
41224777Skarels 	m->m_off -= sizeof(struct ifnet *);
41324777Skarels 	m->m_len += sizeof(struct ifnet *);
41424777Skarels 	*(mtod(m, struct ifnet **)) = ifp;
41528849Skarels 
41633453Skarels 	s = splimp();
41733453Skarels 	if (!IF_QFULL(inq)) {
41833453Skarels 		IF_ENQUEUE(inq, m);
41933453Skarels 		splx(s);
42033453Skarels 		return;
4216208Swnj 	}
42233453Skarels 	splx(s);
42334209Skarels 	IF_DROP(inq);
4245640Sroot drop:
4255640Sroot 	m_freem(m);
42633427Skarels #undef ip
4275640Sroot }
4285640Sroot 
4295647Ssam /*
4305647Ssam  * Bring the IMP down after notification.
4315647Ssam  */
4325647Ssam impdown(sc)
4335647Ssam 	struct imp_softc *sc;
4345647Ssam {
43511230Ssam 	int s = splimp();
4366208Swnj 
43733427Skarels 	if (sc->imp_state == IMPS_GOINGDOWN) {
43833427Skarels 		sc->imp_state = IMPS_WINIT;
43933427Skarels 		impmsg(sc, "marked down");
44034209Skarels 		sc->imp_msgready = 0;
44133427Skarels 		hostreset(sc->imp_if.if_unit);
44233427Skarels 		if_down(&sc->imp_if);
44333427Skarels 	}
44433427Skarels #ifdef IMPINIT
44533427Skarels 	else if (imptraceinit)
44633427Skarels 		log(imppri, "impdown, state now %d (ignored)\n", sc->imp_state);
44733427Skarels #endif
44811230Ssam 	splx(s);
4495647Ssam }
4505647Ssam 
45126397Skarels /*VARARGS2*/
452*34509Skarels impmsg(sc, fmt, a1)
4535640Sroot 	struct imp_softc *sc;
4545640Sroot 	char *fmt;
4556160Ssam 	u_int a1;
4565640Sroot {
4576208Swnj 
45833427Skarels 	log(imppri, "imp%d: %r\n", sc->imp_if.if_unit, fmt, &a1);
4595640Sroot }
4605640Sroot 
46124777Skarels struct sockproto impproto = { PF_IMPLINK };
46224777Skarels struct sockaddr_in impdst = { AF_IMPLINK };
46324777Skarels struct sockaddr_in impsrc = { AF_IMPLINK };
46424777Skarels 
4655640Sroot /*
46624777Skarels  * Pick up the IMP "error" messages enqueued earlier,
46724777Skarels  * passing these up to the higher level protocol
46824777Skarels  * and the raw interface.
4696582Ssam  */
47024777Skarels impintr()
4716582Ssam {
47224777Skarels 	register struct mbuf *m;
47324777Skarels 	register struct control_leader *cp;
47424777Skarels 	struct ifnet *ifp;
47524777Skarels 	int s;
4766582Ssam 
47724777Skarels 	for (;;) {
47824777Skarels 		s = splimp();
47924777Skarels 		IF_DEQUEUEIF(&impintrq, m, ifp);
48024777Skarels 		splx(s);
48124777Skarels 		if (m == 0)
48224777Skarels 			return;
48318132Skarels 
48424777Skarels 		cp = mtod(m, struct control_leader *);
48533427Skarels 		imp_leader_to_addr(&impsrc.sin_addr, cp, ifp);
48624777Skarels 		impproto.sp_protocol = cp->dl_link;
48725409Skarels 		impdst.sin_addr = IA_SIN(ifp->if_addrlist)->sin_addr;
48824777Skarels 
48928849Skarels 		if (cp->dl_mtype == IMPTYPE_HOSTDEAD ||
49028849Skarels 		    cp->dl_mtype == IMPTYPE_HOSTUNREACH)
49128849Skarels 			switch (cp->dl_link) {
49224777Skarels 
49328849Skarels 			case IMPLINK_IP:
49428849Skarels 				pfctlinput((int)cp->dl_mtype,
49528849Skarels 				    (struct sockaddr *)&impsrc);
49628849Skarels 				break;
49728849Skarels 			default:
49828849Skarels 				raw_ctlinput((int)cp->dl_mtype,
49928849Skarels 				    (struct sockaddr *)&impsrc);
50028849Skarels 				break;
50128849Skarels 			}
50224777Skarels 
50324777Skarels 		raw_input(m, &impproto, (struct sockaddr *)&impsrc,
50424777Skarels 		  (struct sockaddr *)&impdst);
5056588Ssam 	}
5066582Ssam }
5076582Ssam 
5086582Ssam /*
5095640Sroot  * ARPAnet 1822 output routine.
5105640Sroot  * Called from higher level protocol routines to set up messages for
5115640Sroot  * transmission to the imp.  Sets up the header and calls impsnd to
5125640Sroot  * enqueue the message for this IMP's hardware driver.
5135640Sroot  */
5146336Ssam impoutput(ifp, m0, dst)
5155640Sroot 	register struct ifnet *ifp;
5165640Sroot 	struct mbuf *m0;
5176336Ssam 	struct sockaddr *dst;
5185640Sroot {
5195640Sroot 	register struct imp_leader *imp;
5205640Sroot 	register struct mbuf *m = m0;
52134209Skarels 	caddr_t pkt = mtod(m, caddr_t);
5226504Ssam 	int error = 0;
5235640Sroot 
5245640Sroot 	/*
5255640Sroot 	 * Don't even try if the IMP is unavailable.
5265640Sroot 	 */
52733427Skarels 	if (!IMPS_RUNNING(imp_softc[ifp->if_unit].imp_state)) {
5286504Ssam 		error = ENETDOWN;
5295647Ssam 		goto drop;
5306504Ssam 	}
5315640Sroot 
53233453Skarels 	/*
53333453Skarels 	 * If AF_IMPLINK, leader exists; just send.
53433453Skarels 	 * Otherwise, construct leader according to address family.
53533453Skarels 	 */
53633453Skarels 	if (dst->sa_family != AF_IMPLINK) {
53733453Skarels 		/*
53833453Skarels 		 * Add IMP leader.  If there's not enough space in the
53933453Skarels 		 * first mbuf, allocate another.  If that should fail, we
54033453Skarels 		 * drop this sucker.
54133453Skarels 		 */
54233453Skarels 		if (m->m_off > MMAXOFF ||
54333453Skarels 		    MMINOFF + sizeof(struct imp_leader) > m->m_off) {
54434209Skarels 			MGET(m, M_DONTWAIT, MT_HEADER);
54533453Skarels 			if (m == 0) {
54633453Skarels 				error = ENOBUFS;
54733453Skarels 				goto drop;
54833453Skarels 			}
54933453Skarels 			m->m_next = m0;
55033453Skarels 			m->m_len = sizeof(struct imp_leader);
55133453Skarels 		} else {
55233453Skarels 			m->m_off -= sizeof(struct imp_leader);
55333453Skarels 			m->m_len += sizeof(struct imp_leader);
55433453Skarels 		}
55533453Skarels 		imp = mtod(m, struct imp_leader *);
55633453Skarels 		imp->il_format = IMP_NFF;
55733453Skarels 		imp->il_mtype = IMPTYPE_DATA;
55834209Skarels 		imp->il_flags = 0;
55934209Skarels 		imp->il_htype = 0;
56034209Skarels 		imp->il_subtype = 0;
5615640Sroot 
56233453Skarels 		switch (dst->sa_family) {
5635640Sroot 
56434209Skarels 		case AF_INET:
56533453Skarels 			imp->il_link = IMPLINK_IP;
56633453Skarels 			imp_addr_to_leader((struct control_leader *)imp,
56733453Skarels 				((struct sockaddr_in *)dst)->sin_addr.s_addr);
56834209Skarels 			imp->il_length = htons(ntohs((u_short)
56934209Skarels 			    ((struct ip *)pkt)->ip_len) << 3);
57033453Skarels 			break;
5715640Sroot 
57233453Skarels 		default:
57333453Skarels 			printf("imp%d: can't handle af%d\n", ifp->if_unit,
57433453Skarels 				dst->sa_family);
57533453Skarels 			error = EAFNOSUPPORT;
57634209Skarels 			m0 = m;
5775647Ssam 			goto drop;
5786504Ssam 		}
5795640Sroot 	}
5805640Sroot 	return (impsnd(ifp, m));
5815647Ssam drop:
5825647Ssam 	m_freem(m0);
5836504Ssam 	return (error);
5845640Sroot }
5855640Sroot 
5865640Sroot /*
5875640Sroot  * Put a message on an interface's output queue.
5885640Sroot  * Perform RFNM counting: no more than 8 message may be
5895640Sroot  * in flight to any one host.
5905640Sroot  */
5915640Sroot impsnd(ifp, m)
5925640Sroot 	struct ifnet *ifp;
5935640Sroot 	struct mbuf *m;
5945640Sroot {
59533427Skarels 	register struct control_leader *imp;
5965640Sroot 	register struct host *hp;
59733453Skarels 	register struct imp_softc *sc = &imp_softc[ifp->if_unit];
59833453Skarels 	int s, error = 0;
5995640Sroot 
60033427Skarels 	imp = mtod(m, struct control_leader *);
6015640Sroot 
6025640Sroot 	/*
6035640Sroot 	 * Do RFNM counting for data messages
60433453Skarels 	 * (no more than 8 outstanding to any host).
60533453Skarels 	 * Queue data messages per host if 8 are already outstanding
60633453Skarels 	 * or if the hardware interface is already doing output.
60733453Skarels 	 * Increment imp_msgready if the message could be sent now,
60833453Skarels 	 * but must be queued because the imp output is busy.
6095640Sroot 	 */
6106588Ssam 	s = splimp();
61133427Skarels 	if (imp->dl_mtype == IMPTYPE_DATA) {
612*34509Skarels 		hp = hostenter((int)imp->dl_imp, (int)imp->dl_host,
613*34509Skarels 		    ifp->if_unit);
6145640Sroot 		if (hp) {
61534209Skarels 			if (hp->h_flags & (HF_DEAD|HF_UNREACH))
61634209Skarels 				error = hp->h_flags & HF_DEAD ?
61734209Skarels 				    EHOSTDOWN : EHOSTUNREACH;
61834209Skarels 			else if (hp->h_rfnm < IMP_MAXHOSTMSG &&
61934209Skarels 			    sc->imp_cb.ic_oactive == 0) {
62034209Skarels 				/*
62134209Skarels 				 * Send without queuing;
62234209Skarels 				 * adjust rfnm count and timer.
62334209Skarels 				 */
62434209Skarels 				if (hp->h_rfnm++ == 0)
62534209Skarels 				    hp->h_timer = RFNMTIMER;
62634209Skarels 				goto send;
62733453Skarels 			} else if (hp->h_rfnm + hp->h_qcnt < imphqlen) {
6286095Swnj 				HOST_ENQUE(hp, m);
62934209Skarels 				if (hp->h_rfnm + hp->h_qcnt <= IMP_MAXHOSTMSG)
63034209Skarels 					sc->imp_msgready++;
63134272Skarels 			} else {
63233453Skarels 				error = ENOBUFS;
63334272Skarels 				IF_DROP(&ifp->if_snd);
63434272Skarels 			}
63533453Skarels 		} else
63633453Skarels 			error = ENOBUFS;
63733453Skarels 	} else if (sc->imp_cb.ic_oactive == 0)
63833453Skarels 		goto send;
63933453Skarels 	else
64033453Skarels 		IF_ENQUEUE(&ifp->if_snd, m);
64134209Skarels 
64233453Skarels 	splx(s);
64334209Skarels 	if (error)
64434209Skarels 		m_freem(m);
64534209Skarels 	return (error);
64633453Skarels 
64733453Skarels send:
64833453Skarels 	sc->imp_if.if_timer = IMP_OTIMER;
64933453Skarels 	(*sc->imp_cb.ic_output)(sc->imp_cb.ic_hwunit, m);
65033453Skarels 	splx(s);
65133453Skarels 	return (0);
65233453Skarels }
65333453Skarels 
65433453Skarels /*
65533453Skarels  * Start another output operation on IMP; called from hardware
65633453Skarels  * transmit-complete interrupt routine at splimp or from imp routines
65734209Skarels  * when output is not in progress.  If there are any packets on shared
65834209Skarels  * output queue, send them, otherwise send the next data packet for a host.
65934209Skarels  * Host data packets are sent round-robin based on destination by walking
66034209Skarels  * the host list.
66133453Skarels  */
66233453Skarels impstart(sc)
66333453Skarels 	register struct imp_softc *sc;
66433453Skarels {
66533453Skarels 	register struct mbuf *m;
66634209Skarels 	int first = 1;				/* XXX */
66733453Skarels 	register struct host *hp;
66833453Skarels 	int index;
66933453Skarels 
67033453Skarels 	IF_DEQUEUE(&sc->imp_if.if_snd, m);
67133453Skarels 	if (m) {
67233453Skarels 		sc->imp_if.if_timer = IMP_OTIMER;
67333453Skarels 		(*sc->imp_cb.ic_output)(sc->imp_cb.ic_hwunit, m);
67433453Skarels 		return;
67533453Skarels 	}
67633453Skarels 	if (sc->imp_msgready) {
67733453Skarels 		if ((m = sc->imp_hostq) == 0 && (m = sc->imp_hosts) == 0)
67834209Skarels 			panic("imp msgready");
67934209Skarels 		index = sc->imp_hostent;
68034209Skarels 		for (hp = &mtod(m, struct hmbuf *)->hm_hosts[index]; ;
68134209Skarels 		    hp++, index++) {
68234209Skarels 			if (index >= HPMBUF) {
68334209Skarels 				if ((m = m->m_next) == 0)
68434209Skarels 					m = sc->imp_hosts;
68534209Skarels 				index = 0;
68634209Skarels 				hp = mtod(m, struct hmbuf *)->hm_hosts;
68734209Skarels 				first = 0;		/* XXX */
6886095Swnj 			}
68934209Skarels 			if (hp->h_qcnt && hp->h_rfnm < IMP_MAXHOSTMSG) {
69034209Skarels 				/*
69134209Skarels 				 * Found host entry with another message
69234209Skarels 				 * to send.  Deliver it to the IMP.
69334209Skarels 				 * Start with succeeding host next time.
69434209Skarels 				 */
69534209Skarels 				impstarthost(sc, hp);
69634209Skarels 				sc->imp_hostq = m;
69734209Skarels 				sc->imp_hostent = index + 1;
69834209Skarels 				return;
69933453Skarels 			}
70034209Skarels 			if (m == sc->imp_hostq && !first &&
70134209Skarels 			    index + 1 >= sc->imp_hostent) {	/* XXX */
70234209Skarels 				log(imppri, "imp: can't find %d msgready\n",
70334209Skarels 				    sc->imp_msgready);
70434209Skarels 				sc->imp_msgready = 0;
70534209Skarels 				break;
70634209Skarels 			}
7075640Sroot 		}
7085640Sroot 	}
70933453Skarels 	sc->imp_if.if_timer = 0;
71033453Skarels }
71133453Skarels 
71233453Skarels /*
71334209Skarels  * Restart output for a host that has received a RFNM
71434209Skarels  * or incomplete or has timed out while waiting for a RFNM.
71533453Skarels  * Must be called at splimp.
71633453Skarels  */
71734209Skarels imprestarthost(sc, hp)
71834209Skarels 	register struct imp_softc *sc;
71933453Skarels 	struct host *hp;
72033453Skarels {
72133453Skarels 
72233453Skarels 	if (--hp->h_rfnm > 0)
72333453Skarels 		hp->h_timer = RFNMTIMER;
72434209Skarels 	/*
72534209Skarels 	 * If the RFNM moved a queued message into the window,
72634209Skarels 	 * update msgready and start IMP if idle.
72734209Skarels 	 */
72834209Skarels 	if (hp->h_qcnt > IMP_MAXHOSTMSG - 1 - hp->h_rfnm) {
72934209Skarels 		sc->imp_msgready++;
73033453Skarels 		if (sc->imp_cb.ic_oactive == 0)
73133453Skarels 			impstarthost(sc, hp);
7326208Swnj 	}
73334209Skarels 	if (hp->h_rfnm == 0 && hp->h_qcnt == 0)
73434209Skarels 		hostidle(hp);
7355640Sroot }
7365640Sroot 
7375640Sroot /*
73833453Skarels  * Send the next message queued for a host
73933453Skarels  * when ready to send another message to the IMP.
74033453Skarels  * Called only when output is not in progress.
74133453Skarels  * Bump RFNM counter and start RFNM timer
74233453Skarels  * when we send the message to the IMP.
74333453Skarels  * Must be called at splimp.
74433453Skarels  */
74533453Skarels impstarthost(sc, hp)
74633453Skarels 	register struct imp_softc *sc;
74733453Skarels 	register struct host *hp;
74833453Skarels {
74933453Skarels 	struct mbuf *m;
75033453Skarels 
75133453Skarels 	if (hp->h_rfnm++ == 0)
75233453Skarels 		hp->h_timer = RFNMTIMER;
75333453Skarels 	HOST_DEQUE(hp, m);
75433453Skarels 	sc->imp_if.if_timer = IMP_OTIMER;
75533453Skarels 	(*sc->imp_cb.ic_output)(sc->imp_cb.ic_hwunit, m);
75633453Skarels 	sc->imp_msgready--;
75733453Skarels }
75833453Skarels 
75933453Skarels /*
76033453Skarels  * "Watchdog" timeout.  When the output timer expires,
76133453Skarels  * we assume we have been blocked by the imp.
76233453Skarels  * No need to restart, just collect statistics.
76333453Skarels  */
76433453Skarels imptimo(unit)
76533453Skarels 	int unit;
76633453Skarels {
76733453Skarels 
76833453Skarels 	imp_softc[unit].imp_block++;
76933453Skarels }
77033453Skarels 
77133453Skarels /*
7725640Sroot  * Put three 1822 NOOPs at the head of the output queue.
7735640Sroot  * Part of host-IMP initialization procedure.
7745640Sroot  * (Should return success/failure, but noone knows
7755640Sroot  * what to do with this, so why bother?)
7766818Ssam  * This routine is always called at splimp, so we don't
7776818Ssam  * protect the call to IF_PREPEND.
7785640Sroot  */
7795640Sroot impnoops(sc)
7805640Sroot 	register struct imp_softc *sc;
7815640Sroot {
7825640Sroot 	register i;
7835640Sroot 	register struct mbuf *m;
7845771Swnj 	register struct control_leader *cp;
7855640Sroot 
78633427Skarels #ifdef IMPINIT
78733427Skarels 	if (imptraceinit)
78833427Skarels 		log(imppri, "impnoops\n");
78933427Skarels #endif
79033427Skarels 	for (i = 0; i < IMP_NOOPCNT; i++) {
7919645Ssam 		if ((m = m_getclr(M_DONTWAIT, MT_HEADER)) == 0)
7925640Sroot 			return;
7935771Swnj 		m->m_len = sizeof(struct control_leader);
7945771Swnj 		cp = mtod(m, struct control_leader *);
7955771Swnj 		cp->dl_format = IMP_NFF;
79633427Skarels 		cp->dl_link = i;
79733427Skarels 		cp->dl_mtype = IMPTYPE_NOOP;
7985640Sroot 		IF_PREPEND(&sc->imp_if.if_snd, m);
7995640Sroot 	}
8005640Sroot 	if (sc->imp_cb.ic_oactive == 0)
80133453Skarels 		impstart(sc);
8025640Sroot }
8037170Ssam 
80413067Ssam /*
80513067Ssam  * Process an ioctl request.
80613067Ssam  */
80713067Ssam impioctl(ifp, cmd, data)
80813067Ssam 	register struct ifnet *ifp;
80913067Ssam 	int cmd;
81013067Ssam 	caddr_t data;
81113067Ssam {
81218412Skarels 	struct ifaddr *ifa = (struct ifaddr *) data;
81313067Ssam 	int s = splimp(), error = 0;
81433427Skarels #define sc	((struct imp_softc *)ifp)
81513067Ssam 
81613067Ssam 	switch (cmd) {
81713067Ssam 
81813067Ssam 	case SIOCSIFADDR:
81918412Skarels 		if (ifa->ifa_addr.sa_family != AF_INET) {
82018412Skarels 			error = EINVAL;
82118412Skarels 			break;
82218412Skarels 		}
82333427Skarels 		if ((ifp->if_flags & IFF_UP) == 0)
82413067Ssam 			impinit(ifp->if_unit);
82513067Ssam 		break;
82613067Ssam 
82733427Skarels 	case SIOCSIFFLAGS:
82833427Skarels 		if ((ifp->if_flags & IFF_UP) == 0 &&
82933427Skarels 		    sc->imp_state != IMPS_DOWN) {
83033453Skarels 			if (sc->imp_cb.ic_down &&
83134209Skarels 			    (*sc->imp_cb.ic_down)(sc->imp_cb.ic_hwunit)) {
83233427Skarels 				sc->imp_state = IMPS_DOWN;
83334209Skarels 				sc->imp_msgready = 0;
83434209Skarels 				hostreset(ifp->if_unit);
83534272Skarels 				if_down(ifp);
83634209Skarels 			}
83733427Skarels 		} else if (ifp->if_flags & IFF_UP && sc->imp_state == IMPS_DOWN)
83833427Skarels 			impinit(ifp->if_unit);
83933427Skarels 		break;
84033427Skarels 
84113067Ssam 	default:
84213067Ssam 		error = EINVAL;
84333427Skarels 		break;
84413067Ssam 	}
84513067Ssam 	splx(s);
84613067Ssam 	return (error);
84713067Ssam }
84813067Ssam 
8497170Ssam #ifdef IMPLEADERS
8507170Ssam printleader(routine, ip)
8517170Ssam 	char *routine;
8527170Ssam 	register struct imp_leader *ip;
8537170Ssam {
8547170Ssam 	printf("%s: ", routine);
8557170Ssam 	printbyte((char *)ip, 12);
8567170Ssam 	printf("<fmt=%x,net=%x,flags=%x,mtype=", ip->il_format, ip->il_network,
8577170Ssam 		ip->il_flags);
8587170Ssam 	if (ip->il_mtype <= IMPTYPE_READY)
8597170Ssam 		printf("%s,", impleaders[ip->il_mtype]);
8607170Ssam 	else
8617170Ssam 		printf("%x,", ip->il_mtype);
8627170Ssam 	printf("htype=%x,host=%x,imp=%x,link=", ip->il_htype, ip->il_host,
8637170Ssam 		ntohs(ip->il_imp));
8647170Ssam 	if (ip->il_link == IMPLINK_IP)
8657170Ssam 		printf("ip,");
8667170Ssam 	else
8677170Ssam 		printf("%x,", ip->il_link);
8687170Ssam 	printf("subtype=%x,len=%x>\n",ip->il_subtype,ntohs(ip->il_length)>>3);
8697170Ssam }
8707170Ssam 
8717170Ssam printbyte(cp, n)
8727170Ssam 	register char *cp;
8737170Ssam 	int n;
8747170Ssam {
8757170Ssam 	register i, j, c;
8767170Ssam 
8777170Ssam 	for (i=0; i<n; i++) {
8787170Ssam 		c = *cp++;
8797170Ssam 		for (j=0; j<2; j++)
88024777Skarels 			putchar("0123456789abcdef"[(c>>((1-j)*4))&0xf], 0);
88124777Skarels 		putchar(' ', 0);
8827170Ssam 	}
88324777Skarels 	putchar('\n', 0);
8847170Ssam }
8855640Sroot #endif
88618132Skarels 
88718132Skarels /*
88818132Skarels  * Routine to convert from IMP Leader to InterNet Address.
88918132Skarels  *
89018132Skarels  * This procedure is necessary because IMPs may be assigned Class A, B, or C
89118132Skarels  * network numbers, but only have 8 bits in the leader to reflect the
89218132Skarels  * IMP "network number".  The strategy is to take the network number from
89318132Skarels  * the ifnet structure, and blend in the host-on-imp and imp-on-net numbers
89418132Skarels  * from the leader.
89518132Skarels  *
89618132Skarels  * There is no support for "Logical Hosts".
89718132Skarels  *
89818132Skarels  * Class A:	Net.Host.0.Imp
89918132Skarels  * Class B:	Net.net.Host.Imp
90018132Skarels  * Class C:	Net.net.net.(Host4|Imp4)
90118132Skarels  */
90233427Skarels imp_leader_to_addr(ap, cp, ifp)
90318412Skarels 	struct in_addr *ap;
90433427Skarels 	register struct control_leader *cp;
90518412Skarels 	struct ifnet *ifp;
90618132Skarels {
90726397Skarels 	register u_long final;
90818132Skarels 	register struct sockaddr_in *sin;
90933427Skarels 	int imp = ntohs(cp->dl_imp);
91018132Skarels 
91118412Skarels 	sin = (struct sockaddr_in *)(&ifp->if_addrlist->ifa_addr);
91228849Skarels 	final = ntohl(sin->sin_addr.s_addr);
91318132Skarels 
91418412Skarels 	if (IN_CLASSA(final)) {
91518132Skarels 		final &= IN_CLASSA_NET;
91633427Skarels 		final |= (imp & 0xFF) | ((cp->dl_host & 0xFF)<<16);
91718412Skarels 	} else if (IN_CLASSB(final)) {
91818132Skarels 		final &= IN_CLASSB_NET;
91933427Skarels 		final |= (imp & 0xFF) | ((cp->dl_host & 0xFF)<<8);
92018132Skarels 	} else {
92118132Skarels 		final &= IN_CLASSC_NET;
92233427Skarels 		final |= (imp & 0x0F) | ((cp->dl_host & 0x0F)<<4);
92318132Skarels 	}
92418412Skarels 	ap->s_addr = htonl(final);
92518132Skarels }
92618132Skarels 
92718132Skarels /*
92818132Skarels  * Function to take InterNet address and fill in IMP leader fields.
92918132Skarels  */
93018412Skarels imp_addr_to_leader(imp, a)
93133427Skarels 	register struct control_leader *imp;
93226397Skarels 	u_long a;
93318132Skarels {
93428849Skarels 	register u_long addr = ntohl(a);
93518132Skarels 
93633427Skarels 	imp->dl_network = 0;	/* !! */
93718132Skarels 
93818412Skarels 	if (IN_CLASSA(addr)) {
93933427Skarels 		imp->dl_host = ((addr>>16) & 0xFF);
94033427Skarels 		imp->dl_imp = addr & 0xFF;
94118412Skarels 	} else if (IN_CLASSB(addr)) {
94233427Skarels 		imp->dl_host = ((addr>>8) & 0xFF);
94333427Skarels 		imp->dl_imp = addr & 0xFF;
94418132Skarels 	} else {
94533427Skarels 		imp->dl_host = ((addr>>4) & 0xF);
94633427Skarels 		imp->dl_imp = addr & 0xF;
94718132Skarels 	}
94833427Skarels 	imp->dl_imp = htons(imp->dl_imp);
94918132Skarels }
9507170Ssam #endif
951