xref: /netbsd/sys/dev/ppbus/if_plip.c (revision 6550d01e)
1 /* $NetBSD: if_plip.c,v 1.24 2010/04/05 07:21:47 joerg Exp $ */
2 
3 /*-
4  * Copyright (c) 1997 Poul-Henning Kamp
5  * Copyright (c) 2003, 2004 Gary Thorpe <gathorpe@users.sourceforge.net>
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted provided that the following conditions
10  * are met:
11  * 1. Redistributions of source code must retain the above copyright
12  *    notice, this list of conditions and the following disclaimer.
13  * 2. Redistributions in binary form must reproduce the above copyright
14  *    notice, this list of conditions and the following disclaimer in the
15  *    documentation and/or other materials provided with the distribution.
16  *
17  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
21  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27  * SUCH DAMAGE.
28  *
29  *	From Id: lpt.c,v 1.55.2.1 1996/11/12 09:08:38 phk Exp
30  * FreeBSD: src/sys/dev/ppbus/if_plip.c,v 1.19.2.1 2000/05/24 00:20:57 n_hibma Exp
31  */
32 
33 #include <sys/cdefs.h>
34 __KERNEL_RCSID(0, "$NetBSD: if_plip.c,v 1.24 2010/04/05 07:21:47 joerg Exp $");
35 
36 /*
37  * Parallel port TCP/IP interfaces added.  I looked at the driver from
38  * MACH but this is a complete rewrite, and btw. incompatible, and it
39  * should perform better too.  I have never run the MACH driver though.
40  *
41  * This driver sends two bytes (0x08, 0x00) in front of each packet,
42  * to allow us to distinguish another format later.
43  *
44  * Now added an Linux/Crynwr compatibility mode which is enabled using
45  * IF_LINK0 - Tim Wilkinson.
46  *
47  * TODO:
48  *    Make HDLC/PPP mode, use IF_LLC1 to enable.
49  *
50  * Connect the two computers using a Laplink parallel cable to use this
51  * feature:
52  *
53  *      +----------------------------------------+
54  * 	|A-name	A-End	B-End	Descr.	Port/Bit |
55  *      +----------------------------------------+
56  *	|DATA0	2	15	Data	0/0x01   |
57  *	|-ERROR	15	2	   	1/0x08   |
58  *      +----------------------------------------+
59  *	|DATA1	3	13	Data	0/0x02	 |
60  *	|+SLCT	13	3	   	1/0x10   |
61  *      +----------------------------------------+
62  *	|DATA2	4	12	Data	0/0x04   |
63  *	|+PE	12	4	   	1/0x20   |
64  *      +----------------------------------------+
65  *	|DATA3	5	10	Strobe	0/0x08   |
66  *	|-ACK	10	5	   	1/0x40   |
67  *      +----------------------------------------+
68  *	|DATA4	6	11	Data	0/0x10   |
69  *	|BUSY	11	6	   	1/~0x80  |
70  *      +----------------------------------------+
71  *	|GND	18-25	18-25	GND	-        |
72  *      +----------------------------------------+
73  *
74  * Expect transfer-rates up to 75 kbyte/sec.
75  *
76  * If GCC could correctly grok
77  *	register int port __asm("edx")
78  * the code would be cleaner
79  *
80  * Poul-Henning Kamp <phk@freebsd.org>
81  */
82 
83 /*
84  * Update for ppbus, PLIP support only - Nicolas Souchu
85  */
86 
87 #include "opt_inet.h"
88 #include "opt_plip.h"
89 
90 #include <sys/systm.h>
91 #include <sys/param.h>
92 #include <sys/proc.h>
93 #include <sys/types.h>
94 #include <sys/device.h>
95 #include <sys/ioctl.h>
96 #include <sys/malloc.h>
97 #include <sys/mbuf.h>
98 
99 #include <net/if.h>
100 #include <net/if_types.h>
101 #include <net/netisr.h>
102 
103 #include <sys/time.h>
104 #include <net/bpf.h>
105 
106 #ifdef INET
107 #include <netinet/in_var.h>
108 /* #include <netinet/in.h> */
109 #else
110 #error Cannot config lp/plip without inet
111 #endif
112 
113 #include <dev/ppbus/ppbus_base.h>
114 #include <dev/ppbus/ppbus_device.h>
115 #include <dev/ppbus/ppbus_io.h>
116 #include <dev/ppbus/ppbus_var.h>
117 
118 #include <machine/types.h>
119 #include <sys/intr.h>
120 
121 #ifndef LPMTU			/* MTU for the lp# interfaces */
122 #define	LPMTU		1500
123 #endif
124 
125 #ifndef LPMAXSPIN1		/* DELAY factor for the lp# interfaces */
126 #define	LPMAXSPIN1	8000	/* Spinning for remote intr to happen */
127 #endif
128 
129 #ifndef LPMAXSPIN2		/* DELAY factor for the lp# interfaces */
130 #define	LPMAXSPIN2	500	/* Spinning for remote handshake to happen */
131 #endif
132 
133 #ifndef LPMAXERRS		/* Max errors before !RUNNING */
134 #define	LPMAXERRS	100
135 #endif
136 
137 #ifndef LPMAXRTRY
138 #define LPMAXRTRY	100	/* If channel busy, retry LPMAXRTRY
139 					consecutive times */
140 #endif
141 
142 #define CLPIPHDRLEN	14	/* We send dummy ethernet addresses (two) + packet type in front of packet */
143 #define	CLPIP_SHAKE	0x80	/* This bit toggles between nibble reception */
144 #define MLPIPHDRLEN	CLPIPHDRLEN
145 
146 #define LPIPHDRLEN	2	/* We send 0x08, 0x00 in front of packet */
147 #define	LPIP_SHAKE	0x40	/* This bit toggles between nibble reception */
148 #if !defined(MLPIPHDRLEN) || LPIPHDRLEN > MLPIPHDRLEN
149 #define MLPIPHDRLEN	LPIPHDRLEN
150 #endif
151 
152 #define	LPIPTBLSIZE	256	/* Size of octet translation table */
153 
154 #define LP_PRINTF	if (lpflag) printf
155 
156 #ifdef PLIP_DEBUG
157 static int volatile lpflag = 1;
158 #else
159 static int volatile lpflag = 0;
160 #endif
161 
162 /* Tx/Rsv tables for the lp interface */
163 static u_char *txmith;
164 #define txmitl (txmith+(1*LPIPTBLSIZE))
165 #define trecvh (txmith+(2*LPIPTBLSIZE))
166 #define trecvl (txmith+(3*LPIPTBLSIZE))
167 static u_char *ctxmith;
168 #define ctxmitl (ctxmith+(1*LPIPTBLSIZE))
169 #define ctrecvh (ctxmith+(2*LPIPTBLSIZE))
170 #define ctrecvl (ctxmith+(3*LPIPTBLSIZE))
171 static uint16_t lp_count = 0;
172 
173 /* Autoconf functions */
174 static int lp_probe(device_t, cfdata_t, void *);
175 static void lp_attach(device_t, device_t, void *);
176 static int lp_detach(device_t, int);
177 
178 /* Soft config data */
179 struct lp_softc {
180 	struct ppbus_device_softc ppbus_dev;
181 	struct ifnet sc_if;
182 	u_char *sc_ifbuf;
183 	unsigned short sc_iferrs;
184 	unsigned short sc_xmit_rtry;
185 	u_int8_t sc_dev_ok; /* Zero means ok */
186 };
187 
188 /* Autoconf structure */
189 CFATTACH_DECL_NEW(plip, sizeof(struct lp_softc), lp_probe, lp_attach, lp_detach,
190 	NULL);
191 
192 /* Functions for the lp interface */
193 static void lpinittables(void);
194 static void lpfreetables(void);
195 static int lpioctl(struct ifnet *, u_long, void *);
196 static int lpoutput(struct ifnet *, struct mbuf *, const struct sockaddr *,
197 	struct rtentry *);
198 static void lpstart(struct ifnet *);
199 static void lp_intr(void *);
200 
201 
202 static int
203 lp_probe(device_t parent, cfdata_t match, void *aux)
204 {
205 	struct ppbus_attach_args * args = aux;
206 
207 	/* Fail if ppbus is not interrupt capable */
208 	if(args->capabilities & PPBUS_HAS_INTR)
209 		return 1;
210 
211 	printf("%s(%s): not an interrupt-driven port.\n", __func__,
212 		device_xname(parent));
213 	return 0;
214 }
215 
216 static void
217 lp_attach(device_t parent, device_t self, void *aux)
218 {
219 	struct lp_softc * lp = device_private(self);
220 	struct ifnet * ifp = &lp->sc_if;
221 
222 	lp->ppbus_dev.sc_dev = self;
223 	lp->sc_dev_ok = 0;
224 	lp->sc_ifbuf = NULL;
225 	lp->sc_iferrs = 0;
226 	lp->sc_xmit_rtry = 0;
227 
228 	ifp->if_softc = lp;
229 	strlcpy(ifp->if_xname, device_xname(self), IFNAMSIZ);
230 	ifp->if_mtu = LPMTU;
231 	ifp->if_flags = IFF_SIMPLEX | IFF_POINTOPOINT | IFF_MULTICAST;
232 	ifp->if_ioctl = lpioctl;
233 	ifp->if_output = lpoutput;
234 	ifp->if_start = lpstart;
235 	ifp->if_type = IFT_PARA;
236 	ifp->if_hdrlen = 0;
237 	ifp->if_addrlen = 0;
238 	ifp->if_dlt = DLT_NULL;
239 	IFQ_SET_MAXLEN(&ifp->if_snd, IFQ_MAXLEN);
240 	IFQ_SET_READY(&ifp->if_snd);
241 	if_attach(ifp);
242 	if_alloc_sadl(ifp);
243 
244 	bpf_attach(ifp, DLT_NULL, sizeof(u_int32_t));
245 
246 	if(lp_count++ == 0)
247 		lpinittables();
248 	printf("\n");
249 }
250 
251 static int
252 lp_detach(device_t self, int flags)
253 {
254 	int error = 0;
255 	struct lp_softc * lp = device_private(self);
256 	device_t ppbus = device_parent(self);
257 
258 	if(lp->sc_dev_ok) {
259 		if(!(flags & DETACH_QUIET))
260 			LP_PRINTF("%s(%s): device not properly attached! "
261 				"Skipping detach....\n", __func__,
262 				device_xname(self));
263 		return error;
264 	}
265 
266 	/* If interface is up, bring it down and release ppbus */
267 	if(lp->sc_if.if_flags & IFF_RUNNING) {
268 		ppbus_wctr(ppbus, 0x00);
269 		if_detach(&lp->sc_if);
270 		error = ppbus_remove_handler(ppbus, lp_intr);
271 		if(error) {
272 			if(!(flags & DETACH_QUIET))
273 				LP_PRINTF("%s(%s): unable to remove interrupt "
274 					"callback.\n", __func__,
275 					device_xname(self));
276 			if(!(flags & DETACH_FORCE))
277 				return error;
278 		}
279 		error = ppbus_release_bus(ppbus, self, 0, 0);
280 		if(error) {
281 			if(!(flags & DETACH_QUIET))
282 				LP_PRINTF("%s(%s): error releasing bus %s.\n",
283 					__func__, device_xname(self),
284 					device_xname(ppbus));
285 			if(!(flags & DETACH_FORCE))
286 				return error;
287 		}
288 	}
289 
290 	if(lp->sc_ifbuf)
291 		free(lp->sc_ifbuf, M_DEVBUF);
292 
293 	if(--lp_count == 0)
294 		lpfreetables();
295 	return error;
296 }
297 
298 /*
299  * Build the translation tables for the LPIP (BSD unix) protocol.
300  * We don't want to calculate these nasties in our tight loop, so we
301  * precalculate them when we initialize.
302  */
303 static void
304 lpinittables (void)
305 {
306 	int i;
307 
308 	if (!txmith)
309 		txmith = malloc(4*LPIPTBLSIZE, M_DEVBUF, M_WAITOK);
310 
311 	if (!ctxmith)
312 		ctxmith = malloc(4*LPIPTBLSIZE, M_DEVBUF, M_WAITOK);
313 
314 	for(i = 0; i < LPIPTBLSIZE; i++) {
315 		ctxmith[i] = (i & 0xF0) >> 4;
316 		ctxmitl[i] = 0x10 | (i & 0x0F);
317 		ctrecvh[i] = (i & 0x78) << 1;
318 		ctrecvl[i] = (i & 0x78) >> 3;
319 	}
320 
321 	for(i = 0; i < LPIPTBLSIZE; i++) {
322 		txmith[i] = ((i & 0x80) >> 3) | ((i & 0x70) >> 4) | 0x08;
323 		txmitl[i] = ((i & 0x08) << 1) | (i & 0x07);
324 		trecvh[i] = ((~i) & 0x80) | ((i & 0x38) << 1);
325 		trecvl[i] = (((~i) & 0x80) >> 4) | ((i & 0x38) >> 3);
326 	}
327 }
328 
329 /* Free translation tables */
330 static void
331 lpfreetables (void)
332 {
333 	if (txmith)
334 		free(txmith, M_DEVBUF);
335 	if (ctxmith)
336 		free(ctxmith, M_DEVBUF);
337 	txmith = ctxmith = NULL;
338 }
339 
340 
341 /* Process an ioctl request. */
342 static int
343 lpioctl(struct ifnet *ifp, u_long cmd, void *data)
344 {
345 	struct lp_softc * sc = ifp->if_softc;
346 	device_t dev = sc->ppbus_dev.sc_dev;
347 	device_t ppbus = device_parent(dev);
348 	struct ifaddr * ifa = (struct ifaddr *)data;
349 	struct ifreq * ifr = (struct ifreq *)data;
350 	u_char * ptr;
351 	int error, s;
352 
353 	error = 0;
354 	s = splnet();
355 
356 	if(sc->sc_dev_ok) {
357 		LP_PRINTF("%s(%s): device not properly attached!", __func__,
358 			device_xname(dev));
359 		error = ENODEV;
360 		goto end;
361 	}
362 
363 	switch (cmd) {
364 
365 	case SIOCSIFDSTADDR:
366 		if (ifa->ifa_addr->sa_family != AF_INET)
367 			error = EAFNOSUPPORT;
368 		break;
369 
370 	case SIOCINITIFADDR:
371 		if (ifa->ifa_addr->sa_family != AF_INET) {
372 			error = EAFNOSUPPORT;
373 			break;
374 		}
375 		ifp->if_flags |= IFF_UP;
376 	/* FALLTHROUGH */
377 	case SIOCSIFFLAGS:
378 		if ((error = ifioctl_common(ifp, cmd, data)) != 0)
379 			break;
380 		if((ifp->if_flags & (IFF_UP|IFF_RUNNING)) == IFF_UP) {
381 			if((error = ppbus_request_bus(ppbus, dev, 0, 0)))
382 				break;
383 			error = ppbus_set_mode(ppbus, PPBUS_COMPATIBLE, 0);
384 			if(error)
385 				break;
386 
387 			error = ppbus_add_handler(ppbus, lp_intr, dev);
388 			if(error) {
389 				LP_PRINTF("%s(%s): unable to register interrupt"
390 					" callback.\n", __func__,
391 					device_xname(dev));
392 				ppbus_release_bus(ppbus, dev, 0, 0);
393 				break;
394 			}
395 
396 			/* Allocate a buffer if necessary */
397 			if(sc->sc_ifbuf == NULL) {
398 				sc->sc_ifbuf = malloc(sc->sc_if.if_mtu +
399 					MLPIPHDRLEN, M_DEVBUF, M_NOWAIT);
400 				if (!sc->sc_ifbuf) {
401 					error = ENOBUFS;
402 					ppbus_release_bus(ppbus, dev, 0, 0);
403 					break;
404 				}
405 			}
406 
407 			ppbus_wctr(ppbus, IRQENABLE);
408 			ifp->if_flags |= IFF_RUNNING;
409 		}
410 		if((ifp->if_flags & (IFF_UP|IFF_RUNNING)) == IFF_RUNNING) {
411 			ppbus_remove_handler(ppbus, lp_intr);
412 			error = ppbus_release_bus(ppbus, dev, 0, 0);
413 			ifp->if_flags &= ~IFF_RUNNING;
414 		}
415 		/* Go quiescent */
416 		ppbus_wdtr(ppbus, 0);
417 		break;
418 
419 	case SIOCSIFMTU:
420 		if(sc->sc_if.if_mtu == ifr->ifr_mtu)
421 			break;
422 		ptr = sc->sc_ifbuf;
423 		sc->sc_ifbuf = malloc(ifr->ifr_mtu+MLPIPHDRLEN, M_DEVBUF,
424 			M_NOWAIT);
425 		if (!sc->sc_ifbuf) {
426 			sc->sc_ifbuf = ptr;
427 			error = ENOBUFS;
428 			break;
429 		}
430 		if(ptr)
431 			free(ptr,M_DEVBUF);
432 		/*FALLTHROUGH*/
433 	case SIOCGIFMTU:
434 		if ((error = ifioctl_common(ifp, cmd, data)) == ENETRESET)
435 			error = 0;
436 		break;
437 
438 	case SIOCADDMULTI:
439 	case SIOCDELMULTI:
440 		if (ifr == NULL) {
441 			error = EAFNOSUPPORT;		/* XXX */
442 			break;
443 		}
444 		switch (ifreq_getaddr(cmd, ifr)->sa_family) {
445 		case AF_INET:
446 			break;
447 		default:
448 			return EAFNOSUPPORT;
449 		}
450 		break;
451 
452 	case SIOCGIFMEDIA:
453 		/*
454 		 * No ifmedia support at this stage; maybe use it
455 		 * in future for eg. protocol selection.
456 		 */
457 	default:
458 		LP_PRINTF("LP:ioctl(0x%lx)\n", cmd);
459 		error = ifioctl_common(ifp, cmd, data);
460 	}
461 
462 end:
463 	splx(s);
464 	return error;
465 }
466 
467 static inline int
468 clpoutbyte (u_char byte, int spin, device_t ppbus)
469 {
470 	int s = spin;
471 	ppbus_wdtr(ppbus, ctxmitl[byte]);
472 	while (ppbus_rstr(ppbus) & CLPIP_SHAKE) {
473 		if (--s == 0) {
474 			return 1;
475 		}
476 	}
477 	s = spin;
478 	ppbus_wdtr(ppbus, ctxmith[byte]);
479 	while (!(ppbus_rstr(ppbus) & CLPIP_SHAKE)) {
480 		if (--s == 0) {
481 			return 1;
482 		}
483 	}
484 	return 0;
485 }
486 
487 static inline int
488 clpinbyte (int spin, device_t ppbus)
489 {
490 	u_char c, cl;
491 	int s = spin;
492 
493 	while(ppbus_rstr(ppbus) & CLPIP_SHAKE) {
494 		if(!--s) {
495 			return -1;
496 		}
497 	}
498 	cl = ppbus_rstr(ppbus);
499 	ppbus_wdtr(ppbus, 0x10);
500 
501 	s = spin;
502 	while(!(ppbus_rstr(ppbus) & CLPIP_SHAKE)) {
503 		if(!--s) {
504 			return -1;
505 		}
506 	}
507 	c = ppbus_rstr(ppbus);
508 	ppbus_wdtr(ppbus, 0x00);
509 
510 	return (ctrecvl[cl] | ctrecvh[c]);
511 }
512 
513 static void
514 lptap(struct ifnet *ifp, struct mbuf *m)
515 {
516 	/*
517 	 * Send a packet through bpf. We need to prepend the address family
518 	 * as a four byte field. Cons up a dummy header to pacify bpf. This
519 	 * is safe because bpf will only read from the mbuf (i.e., it won't
520 	 * try to free it or keep a pointer to it).
521 	 */
522 	u_int32_t af = AF_INET;
523 	struct mbuf m0;
524 
525 	m0.m_next = m;
526 	m0.m_len = sizeof(u_int32_t);
527 	m0.m_data = (char *)&af;
528 	bpf_mtap(ifp, &m0);
529 }
530 
531 /* Soft interrupt handler called by hardware interrupt handler */
532 static void
533 lp_intr (void *arg)
534 {
535 	device_t dev = (device_t)arg;
536         device_t ppbus = device_parent(dev);
537 	struct lp_softc * sc = device_private(dev);
538 	struct ifnet * ifp = &sc->sc_if;
539 	struct mbuf *top;
540 	int len, s, j;
541 	u_char *bp;
542 	u_char c, cl;
543 
544 	s = splnet();
545 
546 	/* Do nothing if device not properly attached */
547 	if(sc->sc_dev_ok) {
548 		LP_PRINTF("%s(%s): device not properly attached!", __func__,
549 			device_xname(dev));
550 		goto done;
551 	}
552 
553 	/* Do nothing if interface is not up */
554 	if((ifp->if_flags & (IFF_UP|IFF_RUNNING)) != (IFF_UP|IFF_RUNNING))
555 		goto done;
556 
557 	/* If other side is no longer transmitting, do nothing */
558 	if(!(ppbus_rstr(ppbus) & LPIP_SHAKE))
559 		goto done;
560 
561 	/* Disable interrupts until we finish */
562 	ppbus_wctr(ppbus, ~IRQENABLE);
563 
564 	top = NULL;
565 	bp = sc->sc_ifbuf;
566 	/* Linux/crynwyr protocol receiving */
567 	if(ifp->if_flags & IFF_LINK0) {
568 		/* Ack. the request */
569 		ppbus_wdtr(ppbus, 0x01);
570 
571 		/* Get the packet length */
572 		j = clpinbyte(LPMAXSPIN2, ppbus);
573 		if(j == -1)
574 			goto err;
575 		len = j;
576 		j = clpinbyte(LPMAXSPIN2, ppbus);
577 		if(j == -1)
578 			goto err;
579 		len = len + (j << 8);
580 		if(len > ifp->if_mtu + MLPIPHDRLEN)
581 			goto err;
582 
583 		while(len--) {
584 			j = clpinbyte(LPMAXSPIN2, ppbus);
585 			if (j == -1) {
586 				goto err;
587 			}
588 			*bp++ = j;
589 		}
590 		/* Get and ignore checksum */
591 		j = clpinbyte(LPMAXSPIN2, ppbus);
592 		if(j == -1) {
593 			goto err;
594 		}
595 
596 		/* Return to idle state */
597 		ppbus_wdtr(ppbus, 0);
598 		len = bp - sc->sc_ifbuf;
599 		if (len <= CLPIPHDRLEN)
600 			goto err;
601 		len -= CLPIPHDRLEN;
602 		top = m_devget(sc->sc_ifbuf + CLPIPHDRLEN, len, 0, ifp, NULL);
603 	}
604 	/* FreeBSD protocol receiving */
605 	else {
606 		len = ifp->if_mtu + LPIPHDRLEN;
607 		while(len--) {
608 			cl = ppbus_rstr(ppbus);
609 			ppbus_wdtr(ppbus, 0x08);
610 
611 			j = LPMAXSPIN2;
612 			while((ppbus_rstr(ppbus) & LPIP_SHAKE)) {
613 				if(!--j) goto err;
614 			}
615 
616 			c = ppbus_rstr(ppbus);
617 			ppbus_wdtr(ppbus, 0);
618 
619 			*bp++= trecvh[cl] | trecvl[c];
620 
621 			j = LPMAXSPIN2;
622 			while(!((cl=ppbus_rstr(ppbus)) & LPIP_SHAKE)) {
623 				if(cl != c &&
624 					(((cl = ppbus_rstr(ppbus)) ^ 0xb8) &
625 					0xf8) == (c & 0xf8))
626 					goto end;
627 				if(!--j) goto err;
628 			}
629 		}
630 
631 end:
632 		len = bp - sc->sc_ifbuf;
633 		if(len <= LPIPHDRLEN)
634 			goto err;
635 		len -= LPIPHDRLEN;
636 		top = m_devget(sc->sc_ifbuf + LPIPHDRLEN, len, 0, ifp, NULL);
637 	}
638 
639 	/* Do nothing if mbuf was not created or the queue is full */
640 	if((top == NULL) || (IF_QFULL(&ipintrq))) {
641 		IF_DROP(&ipintrq);
642 		ifp->if_iqdrops++;
643 		LP_PRINTF("DROP");
644 		goto err;
645 	}
646 	if(ifp->if_bpf)
647 		lptap(ifp, top);
648 	IF_ENQUEUE(&ipintrq, top);
649 	schednetisr(NETISR_IP);
650 	ifp->if_ipackets++;
651 	ifp->if_ibytes += len;
652 	sc->sc_iferrs = 0;
653 
654 	goto done;
655 
656 err:
657 	/* Return to idle state */
658 	ppbus_wdtr(ppbus, 0);
659 	ifp->if_ierrors++;
660 	sc->sc_iferrs++;
661 	LP_PRINTF("R");
662 	/* Disable interface if there are too many errors */
663 	if(sc->sc_iferrs > LPMAXERRS) {
664 		aprint_error_dev(dev, "Too many consecutive errors, going off-line.\n");
665 		ppbus_wctr(ppbus, ~IRQENABLE);
666 		if_down(ifp);
667 		sc->sc_iferrs = 0;
668 	}
669 
670 done:
671 	/* Re-enable interrupts */
672 	ppbus_wctr(ppbus, IRQENABLE);
673 	/* If interface is not active, send some packets */
674 	if((ifp->if_flags & IFF_OACTIVE) == 0)
675 		lpstart(ifp);
676 	splx(s);
677 	return;
678 }
679 
680 static inline int
681 lpoutbyte(u_char byte, int spin, device_t ppbus)
682 {
683 	int s = spin;
684 	ppbus_wdtr(ppbus, txmith[byte]);
685 	while(!(ppbus_rstr(ppbus) & LPIP_SHAKE)) {
686 		if(--s == 0)
687 			return 1;
688 	}
689 	s = spin;
690 	ppbus_wdtr(ppbus, txmitl[byte]);
691 	while(ppbus_rstr(ppbus) & LPIP_SHAKE) {
692 		if(--s == 0)
693 			return 1;
694 	}
695 	return 0;
696 }
697 
698 /* Queue a packet for delivery */
699 static int
700 lpoutput(struct ifnet *ifp, struct mbuf *m, const struct sockaddr *dst,
701 	struct rtentry *rt)
702 {
703 	struct lp_softc * sc = ifp->if_softc;
704 	device_t dev = sc->ppbus_dev.sc_dev;
705 	device_t ppbus = device_parent(dev);
706 	ALTQ_DECL(struct altq_pktattr pktattr;)
707 	int err;
708 	int s;
709 
710 	s = splnet();
711 
712 	if(sc->sc_dev_ok) {
713 		LP_PRINTF("%s(%s): device not properly attached!", __func__,
714 			device_xname(dev));
715 		err = ENODEV;
716 		goto endoutput;
717 	}
718 
719 	if((ifp->if_flags & (IFF_UP|IFF_RUNNING)) != (IFF_UP|IFF_RUNNING)) {
720 		err = ENETDOWN;
721 		goto endoutput;
722 	}
723 
724 	/* Only support INET */
725 	if(dst->sa_family != AF_INET) {
726 		LP_PRINTF("%s: af%d not supported\n", ifp->if_xname,
727 		    dst->sa_family);
728 		ifp->if_noproto++;
729 		err = EAFNOSUPPORT;
730 		goto endoutput;
731 	}
732 
733 	IFQ_CLASSIFY(&ifp->if_snd, m, dst->sa_family, &pktattr);
734 	IFQ_ENQUEUE(&ifp->if_snd, m, NULL, err);
735 	if(err == 0) {
736 		if((ifp->if_flags & IFF_OACTIVE) == 0)
737 			lpstart(ifp);
738 	}
739 	else {
740 		ifp->if_oerrors++;
741 		sc->sc_iferrs++;
742 		LP_PRINTF("Q");
743 
744 		/* Disable interface if there are too many errors */
745 		if(sc->sc_iferrs > LPMAXERRS) {
746 			aprint_error_dev(dev, "Too many errors, going off-line.\n");
747 			ppbus_wctr(ppbus, ~IRQENABLE);
748 			if_down(ifp);
749 			sc->sc_iferrs = 0;
750 		}
751 	}
752 
753 endoutput:
754 	if((err != 0) && (err != ENOBUFS))
755 		m_freem(m);
756 	splx(s);
757 	return err;
758 }
759 
760 /* Send routine: send packets over PLIP cable. Call at splnet(). */
761 void
762 lpstart(struct ifnet * ifp)
763 {
764 	struct lp_softc * lp = ifp->if_softc;
765 	device_t dev = lp->ppbus_dev.sc_dev;
766 	device_t ppbus = device_parent(dev);
767 	struct mbuf * mm;
768 	struct mbuf * m;
769 	u_char * cp;
770 	int err, i, len, spin, count;
771 	u_char str, chksum;
772 
773 	if(lp->sc_dev_ok) {
774 		LP_PRINTF("%s(%s): device not properly attached!", __func__,
775 			device_xname(dev));
776 		return;
777 	}
778 
779 	if((ifp->if_flags & (IFF_UP|IFF_RUNNING)) != (IFF_UP|IFF_RUNNING)) {
780 		return;
781 	}
782 
783 	ifp->if_flags |= IFF_OACTIVE;
784 
785 	/* Go quiescent */
786 	ppbus_wdtr(ppbus, 0);
787 
788 	/* Output loop */
789 	for(;;) {
790 		/* Check if there are packets to send */
791 		if(IFQ_IS_EMPTY(&ifp->if_snd)) {
792 			goto final;
793 		}
794 		/* Try to send a packet, dequeue it later if successful */
795 		IFQ_POLL(&ifp->if_snd, m);
796 		if(m == NULL)
797 			goto final;
798 
799 		str = ppbus_rstr(ppbus);
800 		/* Wait until other side is not transmitting */
801 		if((str & LPIP_SHAKE) ||
802 			((ifp->if_flags & IFF_LINK0) && !(str & CLPIP_SHAKE))) {
803 			LP_PRINTF("&");
804 			if(++lp->sc_xmit_rtry > LPMAXRTRY) {
805 				aprint_error_dev(dev, "Too many retries while channel "
806 					"busy, going off-line.\n");
807 				ppbus_wctr(ppbus, ~IRQENABLE);
808 				if_down(ifp);
809 				lp->sc_xmit_rtry = 0;
810 			}
811 			goto final;
812 		}
813 		lp->sc_xmit_rtry = 0;
814 
815 		/* Disable interrupt generation */
816 		ppbus_wctr(ppbus, ~IRQENABLE);
817 
818 		err = 1;
819 
820 		/* Output packet for Linux/crynwyr compatible protocol */
821 		if(ifp->if_flags & IFF_LINK0) {
822 			/* Calculate packet length */
823 			count = 14;		/* Ethernet header len */
824 			for(mm = m; mm; mm = mm->m_next) {
825 				count += mm->m_len;
826 			}
827 
828 			/* Alert other end to pending packet */
829 			spin = LPMAXSPIN1;
830 			ppbus_wdtr(ppbus, 0x08);
831 			while((ppbus_rstr(ppbus) & 0x08) == 0) {
832 				if (--spin == 0) {
833 					goto nend;
834 				}
835 			}
836 
837 			if(clpoutbyte(count & 0xFF, LPMAXSPIN1, ppbus))
838 				goto nend;
839 			if(clpoutbyte((count >> 8) & 0xFF, LPMAXSPIN1, ppbus))
840 				goto nend;
841 
842 			/* Send dummy ethernet header */
843 			chksum = 0;
844 			for(i = 0; i < 12; i++) {
845 				if(clpoutbyte(i, LPMAXSPIN1, ppbus))
846 					goto nend;
847 				chksum += i;
848 			}
849 
850 			if(clpoutbyte(0x08, LPMAXSPIN1, ppbus))
851 				goto nend;
852 			if(clpoutbyte(0x00, LPMAXSPIN1, ppbus))
853 				goto nend;
854 			chksum += 0x08 + 0x00;		/* Add into checksum */
855 
856 			mm = m;
857 			do {
858 				cp = mtod(mm, u_char *);
859 				len = mm->m_len;
860 				while(len--) {
861 					if(clpoutbyte(*cp, LPMAXSPIN2, ppbus))
862 						goto nend;
863 					chksum += *cp++;
864 				}
865 			} while ((mm = mm->m_next));
866 
867 			/* Send checksum */
868 			if(clpoutbyte(chksum, LPMAXSPIN2, ppbus))
869 				goto nend;
870 
871 			/* No errors */
872 			err = 0;
873 			/* Go quiescent */
874 			ppbus_wdtr(ppbus, 0);
875 		}
876 		/* Output packet for FreeBSD compatible protocol */
877 		else {
878 			/* We need a sensible value if we abort */
879 			cp = NULL;
880 
881 			if(lpoutbyte(0x08, LPMAXSPIN1, ppbus))
882 				goto end;
883 			if(lpoutbyte(0x00, LPMAXSPIN2, ppbus))
884 				goto end;
885 
886 			mm = m;
887 			do {
888 				cp = mtod(mm,u_char *);
889 				len = mm->m_len;
890 				while(len--)
891 					if(lpoutbyte(*cp++, LPMAXSPIN2, ppbus))
892 						goto end;
893 			} while ((mm = mm->m_next));
894 
895 			/* no errors were encountered */
896 			err = 0;
897 
898 end:
899 			if(cp)
900 				ppbus_wdtr(ppbus, txmitl[*(--cp)] ^ 0x17);
901 			else
902 				ppbus_wdtr(ppbus, txmitl['\0'] ^ 0x17);
903 		}
904 
905 nend:
906 		/* Re-enable interrupt generation */
907 		ppbus_wctr(ppbus, IRQENABLE);
908 
909 		if(err) {
910 			/* Go quiescent */
911 			ppbus_wdtr(ppbus, 0);
912 
913 			ifp->if_oerrors++;
914 			lp->sc_iferrs++;
915 			LP_PRINTF("X");
916 
917 			/* Disable interface if there are too many errors */
918 			if(lp->sc_iferrs > LPMAXERRS) {
919 				aprint_error_dev(dev, "Too many errors, going off-line.\n");
920 				ppbus_wctr(ppbus, ~IRQENABLE);
921 				if_down(ifp);
922 				lp->sc_iferrs = 0;
923 				goto final;
924 			}
925 		}
926 		else {
927 			/* Dequeue packet on success */
928 			IFQ_DEQUEUE(&ifp->if_snd, m);
929 			if(ifp->if_bpf)
930 				lptap(ifp, m);
931 			ifp->if_opackets++;
932 			ifp->if_obytes += m->m_pkthdr.len;
933 			m_freem(m);
934 		}
935 	}
936 
937 final:
938 	ifp->if_flags &= ~IFF_OACTIVE;
939 	return;
940 }
941