Subject: serial driver patches
To: None <amiga-dev@sun-lamp.cs.berkeley.edu>
From: Ty Sarna <tsarna@endicor.com>
List: amiga-dev
Date: 04/18/1994 06:25:23
First, a patch to serreg.h.  For the normal dual-/dev-entry
dialin/dialout type serial scheme on SunOS and other BSD systems, the
dialin line is minor unit n and the dialout line is n+128.  The amiga
netbsd MAKEDEV and /etc/ttys files are also set up this way.  The
serreg.h DIALXXX macros however were backwards. Also, with my ser.c
changes below DIALIN is no longer used, so I deleted it.

*** serreg.h	Sun Apr 17 18:48:14 1994
--- serreg.h.orig	Sun Apr 17 15:32:06 1994
***************
*** 66,69 ****
     dialout:   carrier is ignored */
  
  #define SERUNIT(dev)   (minor(dev) & 0x7f)
! #define DIALOUT(dev)   ((minor(dev) & 0x80) == 0x80)
--- 66,70 ----
     dialout:   carrier is ignored */
  
  #define SERUNIT(dev)   (minor(dev) & 0x7f)
! #define DIALIN(dev)    ((minor(dev) & 0x80) == 0x80)
! #define DIALOUT(dev)   ((minor(dev) & 0x80) == 0x00)


Next, changes to ser.c: I'm including the whole file since the diffs
were nearly twice the size of the new file.

Changes:
- major style changes to make it mostly KNF compliant
- Added support for cgd's new ttyflags stuff. See ttyflags(8) and ttys(5).
- IXOFF removed from default iflags... it was XXXX'd and looked bogus.
- default cflags changed from CREAD+CS8+CLOCAL to the default flags (CREAD+
  CS7+HUPCTL+PARENB). Depending on the settings of ttyflags in /etc/ttys,
  CLOCAL and/or CRTSCTS can also be set by default on open. This is now
  consistent with cgd's changes to the i386 com driver (minus MDMBUF support)

This needs some more testing, and someone also needs to examine the
other "#if 0"'d code and either put it back or nuke it.

Here's the file:

-----snip snip-----
/*
 * Copyright (c) 1982, 1986, 1990 The Regents of the University of California.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. All advertising materials mentioning features or use of this software
 *    must display the following acknowledgement:
 *	This product includes software developed by the University of
 *	California, Berkeley and its contributors.
 * 4. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 *
 *	@(#)ser.c	7.12 (Berkeley) 6/27/91
 *	$Id: ser.c,v 1.13 1994/03/30 17:24:36 chopps Exp $
 */

#include "ser.h"

#if NSER > 0
#include <sys/param.h>
#include <sys/systm.h>
#include <sys/ioctl.h>
#include <sys/tty.h>
#include <sys/proc.h>
#include <sys/conf.h>
#include <sys/file.h>
#include <sys/malloc.h>
#include <sys/uio.h>
#include <sys/kernel.h>
#include <sys/syslog.h>
#include <sys/queue.h>

#include <amiga/dev/device.h>
#include <amiga/dev/serreg.h>
#include <machine/cpu.h>

#include <amiga/amiga/custom.h>
#include <amiga/amiga/cia.h>
#include <amiga/amiga/cc.h>

#include <dev/cons.h>

int	serprobe();
struct driver serdriver = {
	serprobe, "ser",
};

int	serstart(), serparam(), serintr();
int	ser_active;
int	ser_hasfifo;
int	nser = NSER;
#ifdef SERCONSOLE
int	serconsole = SERCONSOLE;
#else
int	serconsole = -1;
#endif
int	serconsinit;
int	serdefaultrate = TTYDEF_SPEED;
int	sermajor;
int	serswflags;
#define SWFLAGS(dev) (serswflags | (DIALOUT(dev) ? TIOCFLAG_SOFTCAR : 0))
struct	serdevice *ser_addr[NSER];
struct	vbl_node ser_vbl_node[NSER];
struct	tty ser_cons;
struct	tty *ser_tty[NSER];

struct speedtab serspeedtab[] = {
	0,	0,
	50,	SERBRD(50),
	75,	SERBRD(75),
	110,	SERBRD(110),
	134,	SERBRD(134),
	150,	SERBRD(150),
	200,	SERBRD(200),
	300,	SERBRD(300),
	600,	SERBRD(600),
	1200,	SERBRD(1200),
	1800,	SERBRD(1800),
	2400,	SERBRD(2400),
	4800,	SERBRD(4800),
	9600,	SERBRD(9600),
	19200,	SERBRD(19200),
	38400,	SERBRD(38400),
	57600,	SERBRD(57600),
	76800,	SERBRD(76800),
	-1,	-1
};


/* 
 * Since this UART is not particularly bright (to put it nicely), we'll
 * have to do parity stuff on our own.	This table contains the 8th bit
 * in 7bit character mode, for even parity.  If you want odd parity,
 * flip the bit.  (for generation of the table, see genpar.c)
 */

u_char	even_parity[] = {
	0, 1, 1, 0, 1, 0, 0, 1, 1, 0, 0, 1, 0, 1, 1, 0,
	1, 0, 0, 1, 0, 1, 1, 0, 0, 1, 1, 0, 1, 0, 0, 1,
	1, 0, 0, 1, 0, 1, 1, 0, 0, 1, 1, 0, 1, 0, 0, 1,
	0, 1, 1, 0, 1, 0, 0, 1, 1, 0, 0, 1, 0, 1, 1, 0,
	1, 0, 0, 1, 0, 1, 1, 0, 0, 1, 1, 0, 1, 0, 0, 1,
	0, 1, 1, 0, 1, 0, 0, 1, 1, 0, 0, 1, 0, 1, 1, 0,
	0, 1, 1, 0, 1, 0, 0, 1, 1, 0, 0, 1, 0, 1, 1, 0,
	1, 0, 0, 1, 0, 1, 1, 0, 0, 1, 1, 0, 1, 0, 0, 1,
};


/* 
 * Since we don't get interrupts for changes on the modem control line,
 * we'll have to fake them by comparing current settings to the settings
 * we remembered on last invocation.
 */

u_char	last_ciab_pra;

extern struct tty *constty;

#ifdef KGDB
#include <machine/remote-sl.h>

extern dev_t kgdb_dev;
extern int kgdb_rate;
extern int kgdb_debug_init;
#endif

#ifdef DEBUG
long	fifoin[17];
long	fifoout[17];
long	serintrcount[16];
long	sermintcount[16];
#endif

void	sermint __P((register int unit));

int
serprobe(ad)
	register struct amiga_device *ad;
{
	register struct serdevice *ser;
	register int unit;
	unsigned short ir = custom.intenar;

	ser = (struct serdevice *) ad->amiga_addr;
	unit = ad->amiga_unit;
	if (unit == serconsole)
		DELAY(100000);

	ad->amiga_ipl = 2;
	ser_addr[unit] = ser;
	ser_active |= 1 << unit;
	ser_vbl_node[unit].function = (void (*) (void *)) sermint;
	add_vbl_function(&ser_vbl_node[unit], SER_VBL_PRIORITY, (void *) unit);
#ifdef KGDB
	if (kgdb_dev == makedev(sermajor, unit)) {
		if (serconsole == unit)
			kgdb_dev = NODEV; /* can't debug over console port */
		else {
			(void) serinit(unit, kgdb_rate);
			serconsinit = 1;       /* don't re-init in serputc */
			if (kgdb_debug_init) {
				/*
				 * Print prefix of device name,
				 * let kgdb_connect print the rest.
				 */
				printf("ser%d: ", unit);
				kgdb_connect(1);
			} else
				printf("ser%d: kgdb enabled\n", unit);
		}
	}
#endif
	/*
	 * Need to reset baud rate, etc. of next print so reset serconsinit.
	 */
	if (unit == serconsole)
		serconsinit = 0;

	return (1);
}


/* ARGSUSED */
int
seropen(dev, flag, mode, p)
	dev_t	dev;
	int	flag, mode;
	struct proc *p;
{
	register struct tty *tp;
	register int unit;
	int	error = 0;
	int	s;

	unit = SERUNIT(dev);

	if (unit >= NSER || (ser_active & (1 << unit)) == 0)
		return (ENXIO);
	if (!ser_tty[unit]) {
		tp = ser_tty[unit] = ttymalloc();

		/*
		 * The default values are not optimal for this device,
		 * so increase the buffers
		 */

		clfree(&tp->t_rawq);
		clfree(&tp->t_canq);
		clfree(&tp->t_outq);
		clalloc(&tp->t_rawq, 8192, 1);
		clalloc(&tp->t_canq, 8192, 1);
		clalloc(&tp->t_outq, 8192, 0);
	} else
		tp = ser_tty[unit];

	tp->t_oproc = (void (*) (struct tty *)) serstart;
	tp->t_param = serparam;
	tp->t_dev = dev;

	if ((tp->t_state & TS_ISOPEN) == 0) {
		tp->t_state |= TS_WOPEN;
		ttychars(tp);
		if (tp->t_ispeed == 0) {
			tp->t_iflag = TTYDEF_IFLAG;
			tp->t_oflag = TTYDEF_OFLAG;
			tp->t_cflag = TTYDEF_CFLAG;
			if (serswflags & TIOCFLAG_CLOCAL)
				tp->t_cflag |= CLOCAL;
			if (serswflags & TIOCFLAG_CRTSCTS)
				tp->t_cflag |= CRTSCTS;
			if (serswflags & TIOCFLAG_MDMBUF)
				tp->t_cflag |= MDMBUF;
			tp->t_lflag = TTYDEF_LFLAG;
			tp->t_ispeed = tp->t_ospeed = serdefaultrate;
		}
		serparam(tp, &tp->t_termios);
		ttsetwater(tp);
	} else {
		if (tp->t_state & TS_XCLUDE && p->p_ucred->cr_uid != 0)
			return (EBUSY);
	}

	(void) sermctl(dev, TIOCM_DTR | TIOCM_RTS, DMSET);

	if ((SWFLAGS(dev) & TIOCFLAG_SOFTCAR)
	|| (sermctl(dev, 0, DMGET) & TIOCM_CD))
		tp->t_state |= TS_CARR_ON;
	else
		tp->t_state &= ~TS_CARR_ON;

	s = spltty();
	while ((flag & O_NONBLOCK) == 0
	    && (tp->t_cflag & CLOCAL) == 0
	    && (tp->t_state & TS_CARR_ON) == 0) {
		tp->t_state |= TS_WOPEN;
		if (error = ttysleep(tp, (caddr_t) & tp->t_rawq, TTIPRI | PCATCH,
			ttopen, 0))
			break;
	}
	splx(s);
	if (error == 0) {
		/*
		 * Reset the tty pointer, as there could have been a dialout
		 * use of the tty with a dialin open waiting.
		 */
		tp->t_dev = dev;
		error = (*linesw[tp->t_line].l_open) (dev, tp);
	}
	return (error);
}

/*ARGSUSED*/
int
serclose(dev, flag, mode, p)
	dev_t	dev;
	int	flag, mode;
	struct proc *p;
{
	register struct tty *tp;
	register struct serdevice *ser;
	register int unit;

	unit = SERUNIT(dev);

	ser = ser_addr[unit];
	tp = ser_tty[unit];
	(*linesw[tp->t_line].l_close) (tp, flag);
	custom.adkcon = ADKCONF_UARTBRK;	/* clear break */
#ifdef KGDB
	/* do not disable interrupts if debugging */
	if (dev != kgdb_dev)
#endif
		/* clear interrupt enable */
		custom.intena = INTF_RBF | INTF_TBE;

	custom.intreq = INTF_RBF | INTF_TBE;	/* and interrupt request */
#if 0
	/* If the device is closed, it's close, no matter whether we deal with
	 * modem control signals nor not.
	 */
	if (tp->t_cflag & HUPCL || tp->t_state & TS_WOPEN ||
	    (tp->t_state & TS_ISOPEN) == 0)
#endif
		(void) sermctl(dev, 0, DMSET);
	ttyclose(tp);
#if 0
	if (tp != &ser_cons) {
		remove_vbl_function(&ser_vbl_node[unit]);
		ttyfree(tp);
		ser_tty[unit] = (struct tty *) NULL;
	}
#endif
	return (0);
}

int
serread(dev, uio, flag)
	dev_t	dev;
	struct uio *uio;
{
	register struct tty *tp = ser_tty[SERUNIT(dev)];
	int	error;

	if (!tp)
		return ENXIO;

	error = (*linesw[tp->t_line].l_read) (tp, uio, flag);

	return error;
}

int
serwrite(dev, uio, flag)
	dev_t	dev;
	struct uio *uio;
{
	int	unit = SERUNIT(dev);
	register struct tty *tp = ser_tty[unit];

	if (!tp)
		return ENXIO;

	/*
	 * (XXX) We disallow virtual consoles if the physical console is
	 * a serial port.  This is in case there is a display attached that
	 * is not the console.	In that situation we don't need/want the X
	 * server taking over the console.
	 */
	if (constty && unit == serconsole)
		constty = NULL;

	return ((*linesw[tp->t_line].l_write) (tp, uio, flag));
}


/*
 * We don't do any processing of data here, so we store the raw code
 * obtained from the uart register.  In theory, 110kBaud gives you
 * 11kcps, so 16k buffer should be more than enough, interrupt
 * latency of 1s should never happen, or something is seriously
 * wrong..
 */

#define SERIBUF_SIZE 16384
static u_short serbuf[SERIBUF_SIZE];
static u_short *sbrpt = serbuf;
static u_short *sbwpt = serbuf;


/*
 * This is a replacement for the lack of a hardware fifo.  32k should be
 * enough (there's only one unit anyway, so this is not going to
 * accumulate).
 */
void
ser_fastint()
{
	/* 
	 * We're at RBE-level, which is higher than VBL-level which is used
	 * to periodically transmit contents of this buffer up one layer,
	 * so no spl-raising is necessary. 
	 */

	register u_short ints, code;

	ints = custom.intreqr & INTF_RBF;
	if (!ints)
		return;

	/* clear interrupt */
	custom.intreq = ints;

	/* this register contains both data and status bits! */
	code = custom.serdatr;

	/* should really not happen, but you never know.. buffer overflow. */
	if (sbwpt + 1 == sbrpt
	    || (sbwpt == serbuf + SERIBUF_SIZE - 1 && sbrpt == serbuf)) {
		log(LOG_WARNING, "ser_fastint: buffer overflow!");
		return;
	}
	*sbwpt++ = code;
	if (sbwpt == serbuf + SERIBUF_SIZE)
		sbwpt = serbuf;
}


int
serintr(unit)
	register int unit;
{
	register struct serdevice *ser;
	int	s1, s2;

	ser = ser_addr[unit];

	/*
	 * Make sure we're not interrupted by another
	 * vbl, but allow level5 ints
	 */
	s1 = spltty();

	/* ok, pass along any acumulated information .. */
	while (sbrpt != sbwpt) {
		/* no collision with ser_fastint() */
		sereint(unit, *sbrpt, ser);

		/* lock against ser_fastint() */
		s2 = spl5();
		{
			sbrpt++;
			if (sbrpt == serbuf + SERIBUF_SIZE)
				sbrpt = serbuf;
		}
		splx(s2);
	}

	splx(s1);

#if 0
/* add the code below if you really need it */
	{
/*
 * Process a received byte.  Inline for speed...
 */
#ifdef KGDB
#define	RCVBYTE() \
	    ch = code & 0xff; \
	    if ((tp->t_state & TS_ISOPEN) == 0) { \
		if (ch == FRAME_END && \
		    kgdb_dev == makedev(sermajor, unit)) \
			kgdb_connect(0); /* trap into kgdb */ \
	    }
#else
#define	RCVBYTE()
#endif
		RCVBYTE();
		/* sereint does the receive-processing */
		sereint(unit, code, ser);
	}
#endif
}

int
sereint(unit, stat, ser)
	register int unit, stat;
	register struct serdevice *ser;
{
	register struct tty *tp;
	register int c;
	register u_char ch;

	tp = ser_tty[unit];
	if ((tp->t_state & TS_ISOPEN) == 0) {
#ifdef KGDB
		/* we don't care about parity errors */
		if (kgdb_dev == makedev(sermajor, unit) && c == FRAME_END)
			kgdb_connect(0);	/* trap into kgdb */
#endif
		return;
	}
	ch = stat & 0xff;
	c = ch;

	/* all databits 0 including stop indicate break condition */
	if (!(stat & 0x1ff))
		c |= TTY_FE;

	/* if parity checking enabled, check parity */
	else
		if ((tp->t_cflag & PARENB) &&
		    (((ch >> 7) + even_parity[ch & 0x7f]
		    + !!(tp->t_cflag & PARODD)) & 1))
			c |= TTY_PE;

	if (stat & SERDATRF_OVRUN)
		log(LOG_WARNING, "ser%d: silo overflow\n", unit);

	(*linesw[tp->t_line].l_rint) (c, tp);
}

/*
 * This interrupt is periodically invoked in the vertical blank
 * interrupt.  It's used to keep track of the modem control lines
 * and (new with the fast_int code) to move accumulated data
 * up into the tty layer.
 */

void sermint(unit)
	register int unit;
{
	register struct tty *tp;
	register u_char stat, last, istat;
	register struct serdevice *ser;

	tp = ser_tty[unit];
	if (!tp)
		return;

	if ((tp->t_state & (TS_ISOPEN | TS_WOPEN)) == 0) {
		sbrpt = sbwpt = serbuf;
		return;
	}
	/* first empty buffer */
	serintr(unit);

	stat = ciab.pra;
	last = last_ciab_pra;
	last_ciab_pra = stat;

	/* check whether any interesting signal changed state */
	istat = stat ^ last;

	if ((istat & CIAB_PRA_CD) 
	&& (SWFLAGS(tp->t_dev) & TIOCFLAG_SOFTCAR) == 0) {
		if (ISDCD(stat))
			(*linesw[tp->t_line].l_modem) (tp, 1);
		else
			if ((*linesw[tp->t_line].l_modem) (tp, 0) == 0) {
				CLRDTR(stat);
				CLRRTS(stat);
				ciab.pra = stat;
				last_ciab_pra = stat;
			}
	}
	if ((istat & CIAB_PRA_CTS) && (tp->t_state & TS_ISOPEN) &&
	    (tp->t_cflag & CRTSCTS)) {
#if 0
		/* the line is up and we want to do rts/cts flow control */
		if (ISCTS(stat)) {
			tp->t_state &= ~TS_TTSTOP;
			ttstart(tp);
			/* cause tbe-int if we were stuck there */
			custom.intreq = INTF_SETCLR | INTF_TBE;
		} else
			tp->t_state |= TS_TTSTOP;
#else
		/* do this on hardware level, not with tty driver */
		if (ISCTS(stat)) {
			tp->t_state &= ~TS_TTSTOP;
			/* cause TBE interrupt */
			custom.intreq = INTF_SETCLR | INTF_TBE;
		}
#endif
	}
}

int
serioctl(dev, cmd, data, flag, p)
	dev_t	dev;
	caddr_t data;
	struct proc *p;
{
	register struct tty *tp;
	register int unit = SERUNIT(dev);
	register struct serdevice *ser;
	register int error;

	tp = ser_tty[unit];
	if (!tp)
		return ENXIO;

	error = (*linesw[tp->t_line].l_ioctl) (tp, cmd, data, flag, p);
	if (error >= 0)
		return (error);

	error = ttioctl(tp, cmd, data, flag, p);
	if (error >= 0)
		return (error);

	ser = ser_addr[unit];
	switch (cmd) {
	case TIOCSBRK:
		custom.adkcon = ADKCONF_SETCLR | ADKCONF_UARTBRK;
		break;

	case TIOCCBRK:
		custom.adkcon = ADKCONF_UARTBRK;
		break;

	case TIOCSDTR:
		(void) sermctl(dev, TIOCM_DTR | TIOCM_RTS, DMBIS);
		break;

	case TIOCCDTR:
		(void) sermctl(dev, TIOCM_DTR | TIOCM_RTS, DMBIC);
		break;

	case TIOCMSET:
		(void) sermctl(dev, *(int *) data, DMSET);
		break;

	case TIOCMBIS:
		(void) sermctl(dev, *(int *) data, DMBIS);
		break;

	case TIOCMBIC:
		(void) sermctl(dev, *(int *) data, DMBIC);
		break;

	case TIOCMGET:
		*(int *) data = sermctl(dev, 0, DMGET);
		break;
	case TIOCGFLAGS:
		*(int *)data = SWFLAGS(dev);
		break;
	case TIOCSFLAGS:
		error = suser(p->p_ucred, &p->p_acflag); 
		if (error != 0)
			return(EPERM); 

		serswflags = *(int *)data;
                serswflags &= /* only allow valid flags */
                  (TIOCFLAG_SOFTCAR | TIOCFLAG_CLOCAL | TIOCFLAG_CRTSCTS);
		break;
	default:
		return ENOTTY;
	}

	return (0);
}

int
serparam(tp, t)
	register struct tty *tp;
	register struct termios *t;
{
	register struct serdevice *ser;
	register int cfcr, cflag = t->c_cflag;
	int	unit = SERUNIT(tp->t_dev);
	int	ospeed = ttspeedtab(t->c_ospeed, serspeedtab);

	/* check requested parameters */
	if (ospeed < 0 || (t->c_ispeed && t->c_ispeed != t->c_ospeed))
		return (EINVAL);

	/* and copy to tty */
	tp->t_ispeed = t->c_ispeed;
	tp->t_ospeed = t->c_ospeed;
	tp->t_cflag = cflag;

	custom.intena = INTF_SETCLR | INTF_RBF | INTF_TBE;
	last_ciab_pra = ciab.pra;

	if (ospeed == 0) {
		(void) sermctl(tp->t_dev, 0, DMSET);	/* hang up line */
		return (0);
	} else {
		/* make sure any previous hangup is undone, ie. reenable DTR. */
		(void) sermctl(tp->t_dev, TIOCM_DTR | TIOCM_RTS, DMSET);
	}
	/* set the baud rate */
	custom.serper = (0 << 15) | ospeed;  /* select 8 (not 9) bit mode */

	return (0);
}


static void
ser_putchar(tp, c)
	struct tty *tp;
	unsigned short c;
{
	/* handle truncation of character if necessary */
	if ((tp->t_cflag & CSIZE) == CS7)
		c &= 0x7f;

	/* handle parity if necessary (forces CS7) */
	if (tp->t_cflag & PARENB) {
		c &= 0x7f;
		if (even_parity[c])
			c |= 0x80;
		if (tp->t_cflag & PARODD)
			c ^= 0x80;
	}
	/* add stop bit(s) */
	if (tp->t_cflag & CSTOPB)
		c |= 0x300;
	else
		c |= 0x100;

	custom.serdat = c;
}


#define SEROBUF_SIZE	32
static u_char ser_outbuf[SEROBUF_SIZE];
static u_char *sob_ptr = ser_outbuf, *sob_end = ser_outbuf;

void
ser_outintr()
{
	struct tty *tp = ser_tty[0];	/* hmmmmm */
	unsigned short c;
	int	s = spltty();

	if (!tp)
		goto out;

	if (!(custom.intreqr & INTF_TBE))
		goto out;

	/* clear interrupt */
	custom.intreq = INTF_TBE;

	if (sob_ptr == sob_end) {
		tp->t_state &= ~(TS_BUSY | TS_FLUSH);
		if (tp->t_line)
			(*linesw[tp->t_line].l_start) (tp);
		else
			serstart(tp);

		goto out;
	}

	/*
	 * Do hardware flow control here.  if the CTS line goes down, don't
	 * transmit anything.  That way, we'll be restarted by the periodic
	 * interrupt when CTS comes back up. 
	 */

	if (ISCTS(ciab.pra))
		ser_putchar(tp, *sob_ptr++);
out:
	splx(s);
}

int
serstart(tp)
	register struct tty *tp;
{
	register int cc, s;
	register struct serdevice *ser;
	int	unit;
	int	hiwat = 0;

	if (!(tp->t_state & TS_ISOPEN))
		return;

	unit = SERUNIT(tp->t_dev);
	ser = ser_addr[unit];

	s = spltty();
	if (tp->t_state & (TS_TIMEOUT | TS_TTSTOP))
		goto out;

	cc = tp->t_outq.c_cc;
	if (cc <= tp->t_lowat) {
		if (tp->t_state & TS_ASLEEP) {
			tp->t_state &= ~TS_ASLEEP;
			wakeup((caddr_t) & tp->t_outq);
		}
		selwakeup(&tp->t_wsel);
	}
	if (!cc || (tp->t_state & TS_BUSY))
		goto out;

	/*
	 * We only do bulk transfers if using CTSRTS flow control, not for
	 * (probably sloooow) ixon/ixoff devices.
	 */
	if (!(tp->t_cflag & CRTSCTS))
		cc = 1;

	/*
	 * Limit the amount of output we do in one burst
	 * to prevent hogging the CPU.
	 */
	if (cc > SEROBUF_SIZE) {
		hiwat++;
		cc = SEROBUF_SIZE;
	}
	cc = q_to_b(&tp->t_outq, ser_outbuf, cc);
	if (cc > 0) {
		tp->t_state |= TS_BUSY;

		sob_ptr = ser_outbuf;
		sob_end = ser_outbuf + cc;

		/*
		 * Get first character out, then have TBE-interrupts blow out
		 * further characters, until buffer is empty, and TS_BUSY gets
		 * cleared. 
		 */
		ser_putchar(tp, *sob_ptr++);
	}
out:
	splx(s);
}

/*
 * Stop output on a line.
 */
/*ARGSUSED*/
int
serstop(tp, flag)
	register struct tty *tp;
{
	register int s;

	s = spltty();
	if (tp->t_state & TS_BUSY) {
		if ((tp->t_state & TS_TTSTOP) == 0)
			tp->t_state |= TS_FLUSH;
	}
	splx(s);
}

int
sermctl(dev, bits, how)
	dev_t	dev;
	int	bits, how;
{
	register struct serdevice *ser;
	register int unit;
	u_char	ub;
	int	s;

	unit = SERUNIT(dev);
	ser = ser_addr[unit];

	/* convert TIOCM* mask into CIA mask (which is really low-active!!) */
	if (how != DMGET) {
		ub = 0;
		if (bits & TIOCM_DTR)
			ub |= CIAB_PRA_DTR;
		if (bits & TIOCM_RTS)
			ub |= CIAB_PRA_RTS;
		if (bits & TIOCM_CTS)
			ub |= CIAB_PRA_CTS;
		if (bits & TIOCM_CD)
			ub |= CIAB_PRA_CD;
		if (bits & TIOCM_RI)
			ub |= CIAB_PRA_SEL;	/* collision with /dev/par ! */
		if (bits & TIOCM_DSR)
			ub |= CIAB_PRA_DSR;
	}
	s = spltty();
	switch (how) {
	case DMSET:
		/* invert and set */
		ciab.pra = ~ub;
		break;

	case DMBIC:
		ciab.pra |= ub;
		ub = ~ciab.pra;
		break;

	case DMBIS:
		ciab.pra &= ~ub;
		ub = ~ciab.pra;
		break;

	case DMGET:
		ub = ~ciab.pra;
		break;
	}
	(void) splx(s);

	bits = 0;
	if (ub & CIAB_PRA_DTR)
		bits |= TIOCM_DTR;
	if (ub & CIAB_PRA_RTS)
		bits |= TIOCM_RTS;
	if (ub & CIAB_PRA_CTS)
		bits |= TIOCM_CTS;
	if (ub & CIAB_PRA_CD)
		bits |= TIOCM_CD;
	if (ub & CIAB_PRA_SEL)
		bits |= TIOCM_RI;
	if (ub & CIAB_PRA_DSR)
		bits |= TIOCM_DSR;

	return bits;
}

/*
 * Following are all routines needed for SER to act as console
 */
int
sercnprobe(cp)
	struct consdev *cp;
{
	int	unit = CONUNIT;
	/* locate the major number */
	for (sermajor = 0; sermajor < nchrdev; sermajor++)
		if (cdevsw[sermajor].d_open == (void *)seropen)
			break;

	/* XXX: ick */
	unit = CONUNIT;

	/* initialize required fields */
	cp->cn_dev = makedev(sermajor, unit);
	cp->cn_pri = CN_NORMAL;

	/*
	 * If serconsole is initialized, raise our priority.
	 */
	if (serconsole == unit)
		cp->cn_pri = CN_REMOTE;
#ifdef KGDB
	if (major(kgdb_dev) == 1)	/* XXX */
		kgdb_dev = makedev(sermajor, minor(kgdb_dev));
#endif
}

sercninit(cp)
	struct consdev *cp;
{
	int	unit = SERUNIT(cp->cn_dev);

	serinit(unit, serdefaultrate);
	serconsole = unit;
	serconsinit = 1;
}

serinit(unit, rate)
	int	unit, rate;
{
	int	s;

#ifdef lint
	stat = unit;
	if (stat)
		return;
#endif
	s = splhigh();
	/* might want to fiddle with the CIA later ??? */
	custom.serper = ttspeedtab(rate, serspeedtab);
	splx(s);
}

sercngetc(dev)
{
	u_short stat;
	int	c, s;

#ifdef lint
	stat = dev;
	if (stat)
		return (0);
#endif
	s = splhigh();
	while (!((stat = custom.serdatr & 0xffff) & SERDATRF_RBF));
	c = stat & 0xff;
	/* clear interrupt */
	custom.intreq = INTF_RBF;
	splx(s);
	return (c);
}

/*
 * Console kernel output character routine.
 */
sercnputc(dev, c)
	dev_t	dev;
	register int c;
{
	register int timo;
	short	stat;
	int	s = splhigh();

#ifdef lint
	stat = dev;
	if (stat)
		return;
#endif
	if (serconsinit == 0) {
		(void) serinit(SERUNIT(dev), serdefaultrate);
		serconsinit = 1;
	}
	/* wait for any pending transmission to finish */
	timo = 50000;
	while (!(custom.serdatr & SERDATRF_TBE) && --timo);

	custom.serdat = (c & 0xff) | 0x100;
	/* wait for this transmission to complete */
	timo = 1500000;
	while (!(custom.serdatr & SERDATRF_TBE) && --timo);

	/*
	 * Wait for the device (my vt100..) to process the data, since we
	 * don't do flow-control with cnputc
	 */
	for (timo = 0; timo < 30000; timo++);

	/* clear any interrupts generated by this transmission */
	custom.intreq = INTF_TBE;
	splx(s);
}


serspit(c)
	int	c;
{
	register struct Custom *cu asm("a2") = (struct Custom *) CUSTOMbase;
	register int timo asm("d2");
	extern int cold;
	int	s;

	if (c == 10)
		serspit(13);

	s = splhigh();

	/* wait for any pending transmission to finish */
	timo = 500000;
	while (!(cu->serdatr & (SERDATRF_TBE | SERDATRF_TSRE)) && --timo)
		;

	cu->serdat = (c & 0xff) | 0x100;

	/* wait for this transmission to complete */
	timo = 15000000;
	while (!(cu->serdatr & SERDATRF_TBE) && --timo)
		;

	/* clear any interrupts generated by this transmission */
	cu->intreq = INTF_TBE;

	for (timo = 0; timo < 30000; timo++)
		;

	splx(s);
}

serspits(cp)
	char   *cp;
{
	while (*cp)
		serspit(*cp++);
}

int
serselect(dev, rw, p)
	dev_t	dev;
	int	rw;
	struct proc *p;
{
	register struct tty *tp = ser_tty[SERUNIT(dev)];
	int	nread;
	int	s = spltty();
	struct proc *selp;

	switch (rw) {
	case FREAD:
		nread = ttnread(tp);
		if (nread > 0 || ((tp->t_cflag & CLOCAL) == 0
			&& (tp->t_state & TS_CARR_ON) == 0))
			goto win;
		selrecord(p, &tp->t_rsel);
		break;

	case FWRITE:
		if (tp->t_outq.c_cc <= tp->t_lowat)
			goto win;
		selrecord(p, &tp->t_wsel);
		break;
	}
	splx(s);
	return (0);

win:
	splx(s);
	return (1);
}
#endif
-----snip snip-----

------------------------------------------------------------------------------