xref: /csrg-svn/sys/vax/uba/uda.c (revision 5434)
1*5434Sroot /*	uda.c	4.2	82/01/17	*/
24743Swnj 
34743Swnj #include "ra.h"
44743Swnj #if NUDA > 0
54743Swnj /*
64743Swnj  * UDA50/RAxx disk device driver
74743Swnj  *
84743Swnj  * Restrictions:
94743Swnj  *	Unit numbers must be less than 8.
104743Swnj  *
114743Swnj  * TO DO:
124743Swnj  *	write dump code
134743Swnj  *	test on 750
144743Swnj  */
154743Swnj 
164743Swnj #include "../h/param.h"
174743Swnj #include "../h/systm.h"
184743Swnj #include "../h/buf.h"
194743Swnj #include "../h/conf.h"
204743Swnj #include "../h/dir.h"
214743Swnj #include "../h/user.h"
224743Swnj #include "../h/pte.h"
234743Swnj #include "../h/map.h"
244743Swnj #include "../h/vm.h"
254743Swnj #include "../h/ubareg.h"
264743Swnj #include "../h/ubavar.h"
274743Swnj #include "../h/dk.h"
284743Swnj #include "../h/cpu.h"
294743Swnj #include "../h/cmap.h"
304743Swnj 
314743Swnj int udadebug;
324743Swnj #define	printd	if(udadebug&1)printf
334743Swnj 
344743Swnj /*
354743Swnj  * Parameters for the communications area
364743Swnj  */
374743Swnj 
384743Swnj #define	NRSPL2	3
394743Swnj #define	NCMDL2	3
404743Swnj #define	NRSP	(1<<NRSPL2)
414743Swnj #define	NCMD	(1<<NCMDL2)
424743Swnj 
434743Swnj #include "../h/udareg.h"
444743Swnj #include "../h/mscp.h"
454743Swnj 
464743Swnj struct uda_softc {
474743Swnj 	short	sc_state;	/* state of controller */
484743Swnj 	short	sc_mapped;	/* Unibus map allocated for uda struct? */
494743Swnj 	int	sc_ubainfo;	/* Unibus mapping info */
504743Swnj 	struct uda *sc_uda;	/* Unibus address of uda struct */
514743Swnj 	int	sc_ivec;	/* interrupt vector address */
524743Swnj 	short	sc_credits;	/* transfer credits */
534743Swnj 	short	sc_lastcmd;	/* pointer into command ring */
544743Swnj 	short	sc_lastrsp;	/* pointer into response ring */
554743Swnj } uda_softc[NUDA];
564743Swnj 
574743Swnj /*
584743Swnj  * Controller states
594743Swnj  */
604743Swnj #define	S_IDLE	0		/* hasn't been initialized */
614743Swnj #define	S_STEP1	1		/* doing step 1 init */
624743Swnj #define	S_STEP2	2		/* doing step 2 init */
634743Swnj #define	S_STEP3	3		/* doing step 3 init */
644743Swnj #define	S_SCHAR	4		/* doing "set controller characteristics" */
654743Swnj #define	S_RUN	5		/* running */
664743Swnj 
674743Swnj struct uda {
684743Swnj 	struct udaca	uda_ca;		/* communications area */
694743Swnj 	struct mscp	uda_rsp[NRSP];	/* response packets */
704743Swnj 	struct mscp	uda_cmd[NCMD];	/* command packets */
714743Swnj } uda[NUDA];
724743Swnj 
734743Swnj /* THIS SHOULD BE READ OFF THE PACK, PER DRIVE */
744743Swnj struct size {
754743Swnj 	daddr_t	nblocks;
764743Swnj 	daddr_t	blkoff;
774743Swnj } ra_sizes[8] ={
784743Swnj 	15884,	0,		/* A=blk 0 thru 15883 */
794743Swnj 	33440,	15884,		/* B=blk 15884 thru 49323 */
804743Swnj 	-1,	0,		/* C=blk 0 thru end */
814743Swnj 	0,	0,		/* D reserved for RA81 */
824743Swnj 	0,	0,		/* E reserved for RA81 */
834743Swnj 	0,	0,		/* F reserved for RA81 */
844743Swnj 	82080,	49324,		/* G=blk 49324 thru 131403 */
854743Swnj 	-1,	131404,		/* H=blk 131404 thru end */
864743Swnj };
874743Swnj /* END OF STUFF WHICH SHOULD BE READ IN PER DISK */
884743Swnj 
894743Swnj daddr_t	radsize[NRA];			/* disk size, from ONLINE end packet */
904743Swnj 
914743Swnj int	udprobe(), udslave(), udattach(), udintr();
924743Swnj struct	mscp *udgetcp();
934743Swnj struct	uba_ctlr *udminfo[NUDA];
944743Swnj struct	uba_device *uddinfo[NRA];
954743Swnj struct	uba_device *udip[NUDA][8];	/* 8 == max number of drives */
964743Swnj 
974743Swnj u_short	udstd[] = { 0777550, 0 };
984743Swnj struct	uba_driver udadriver =
994743Swnj  { udprobe, udslave, udattach, 0, udstd, "ra", uddinfo, "uda", udminfo, 0 };
1004743Swnj struct	buf rudbuf[NRA];
1014743Swnj struct	buf udutab[NRA];
1024743Swnj struct	buf udwtab[NUDA];		/* I/O wait queue, per controller */
1034743Swnj 
1044743Swnj #define	b_qsize		b_resid		/* queue size per drive, in udutab */
1054743Swnj #define	b_ubinfo	b_resid		/* Unibus mapping info, per buffer */
1064743Swnj 
1074743Swnj udprobe(reg, ctlr)
1084743Swnj 	caddr_t reg;
1094743Swnj 	int ctlr;
1104743Swnj {
1114743Swnj 	register int br, cvec;
1124743Swnj 	register struct uda_softc *sc = &uda_softc[ctlr];
1134743Swnj 
1144743Swnj #ifdef lint
1154743Swnj 	br = 0; cvec = br; br = cvec;
1164743Swnj #endif
1174743Swnj 	/* SHOULD CHECK THAT IT REALLY IS A UDA */
1184743Swnj 	br = 0x15;
1194743Swnj 	cvec = sc->sc_ivec = (uba_hd[numuba].uh_lastiv -= 4);
1204743Swnj 	return(1);
1214743Swnj }
1224743Swnj 
1234743Swnj udslave(ui, reg)
1244743Swnj 	struct uba_device *ui;
1254743Swnj 	caddr_t reg;
1264743Swnj {
1274743Swnj 	/*
1284743Swnj 	 * TOO HARD TO FIND OUT IF DISK IS THERE UNTIL
1294743Swnj 	 * INITIALIZED.  WE'LL FIND OUT WHEN WE FIRST
1304743Swnj 	 * TRY TO ACCESS IT.
1314743Swnj 	 */
1324743Swnj 	return(1);
1334743Swnj }
1344743Swnj 
1354743Swnj udattach(ui)
1364743Swnj 	register struct uba_device *ui;
1374743Swnj {
1384743Swnj 
1394743Swnj 	if (ui->ui_dk > 0)
1404743Swnj 		dk_mspw[ui->ui_dk] = 1.0 / (60 * 31 * 256);	/* approx */
1414743Swnj 	ui->ui_flags = 0;
1424743Swnj 	udip[ui->ui_ctlr][ui->ui_slave] = ui;
1434743Swnj 	radsize[ui->ui_unit] = (daddr_t)0xffffff;	/* max possible size */
1444743Swnj }
1454743Swnj 
1464743Swnj /*
1474743Swnj  * Open a UDA.  Initialize the device and
1484743Swnj  * set the unit online.
1494743Swnj  */
1504743Swnj udopen(dev, flag)
1514743Swnj 	dev_t dev;
1524743Swnj 	int flag;
1534743Swnj {
1544743Swnj 	register int unit;
1554743Swnj 	register struct uba_device *ui;
1564743Swnj 	register struct uda_softc *sc;
157*5434Sroot 	int s;
1584743Swnj 
1594743Swnj 	unit = minor(dev) >> 3;
1604743Swnj 	if (unit >= NRA || (ui = uddinfo[unit]) == 0 || ui->ui_alive == 0) {
1614743Swnj 		u.u_error = ENXIO;
1624743Swnj 		return;
1634743Swnj 	}
1644743Swnj 	sc = &uda_softc[ui->ui_ctlr];
165*5434Sroot 	s = spl5();
1664743Swnj 	if (sc->sc_state != S_RUN) {
1674743Swnj 		if (sc->sc_state == S_IDLE)
1684743Swnj 			udinit(ui->ui_ctlr);
1694743Swnj 		sleep(ui->ui_mi, 0); /* wait for initialization to complete */
1704743Swnj 		if (sc->sc_state != S_RUN) {
1714743Swnj 			u.u_error = EIO;
1724743Swnj 			return;
1734743Swnj 		}
1744743Swnj 	}
175*5434Sroot 	splx(s);
1764743Swnj 	/* SHOULD PROBABLY FORCE AN ONLINE ATTEMPT
1774743Swnj 	   TO SEE IF DISK IS REALLY THERE */
1784743Swnj }
1794743Swnj 
1804743Swnj /*
1814743Swnj  * Initialize a UDA.  Set up UBA mapping registers,
1824743Swnj  * initialize data structures, and start hardware
1834743Swnj  * initialization sequence.
1844743Swnj  */
1854743Swnj udinit(d)
1864743Swnj 	int d;
1874743Swnj {
1884743Swnj 	register struct uda_softc *sc;
1894743Swnj 	register struct uda *ud;
1904743Swnj 	struct udadevice *udaddr;
1914743Swnj 	struct uba_ctlr *um;
1924743Swnj 
1934743Swnj 	sc = &uda_softc[d];
1944743Swnj 	um = udminfo[d];
1954743Swnj 	um->um_tab.b_active++;
1964743Swnj 	ud = &uda[d];
1974743Swnj 	udaddr = (struct udadevice *)um->um_addr;
1984743Swnj 	if (sc->sc_mapped == 0) {
1994743Swnj 		/*
2004743Swnj 		 * Map the communications area and command
2014743Swnj 		 * and response packets into Unibus address
2024743Swnj 		 * space.
2034743Swnj 		 */
2044743Swnj 		sc->sc_ubainfo = uballoc(um->um_ubanum, (caddr_t)ud,
2054743Swnj 		    sizeof (struct uda), 0);
2064743Swnj 		sc->sc_uda = (struct uda *)(sc->sc_ubainfo & 0x3ffff);
2074743Swnj 		sc->sc_mapped = 1;
2084743Swnj 	}
2094743Swnj 
2104743Swnj 	/*
2114743Swnj 	 * Start the hardware initialization sequence.
2124743Swnj 	 */
2134743Swnj 	udaddr->udaip = 0;		/* start initialization */
2144743Swnj 	while ((udaddr->udasa & UDA_STEP1) == 0)
2154743Swnj 		;
2164743Swnj 	udaddr->udasa = UDA_ERR|(NCMDL2<<11)|(NRSPL2<<8)|UDA_IE|(sc->sc_ivec/4);
2174743Swnj 	/*
2184743Swnj 	 * Initialization continues in interrupt routine.
2194743Swnj 	 */
2204743Swnj 	sc->sc_state = S_STEP1;
2214743Swnj 	sc->sc_credits = 0;
2224743Swnj }
2234743Swnj 
2244743Swnj udstrategy(bp)
2254743Swnj 	register struct buf *bp;
2264743Swnj {
2274743Swnj 	register struct uba_device *ui;
2284743Swnj 	register struct uba_ctlr *um;
2294743Swnj 	register struct buf *dp;
2304743Swnj 	register int unit;
2314743Swnj 	int xunit = minor(bp->b_dev) & 07;
2324743Swnj 	daddr_t sz, maxsz;
233*5434Sroot 	int s;
2344743Swnj 
2354743Swnj 	sz = (bp->b_bcount+511) >> 9;
2364743Swnj 	unit = dkunit(bp);
2374743Swnj 	if (unit >= NRA)
2384743Swnj 		goto bad;
2394743Swnj 	ui = uddinfo[unit];
2404743Swnj 	um = ui->ui_mi;
2414743Swnj 	if (ui == 0 || ui->ui_alive == 0)
2424743Swnj 		goto bad;
2434743Swnj 	if ((maxsz = ra_sizes[xunit].nblocks) < 0)
2444743Swnj 		maxsz = radsize[unit] - ra_sizes[xunit].blkoff;
2454743Swnj 	if (bp->b_blkno < 0 || bp->b_blkno+sz > maxsz ||
2464743Swnj 	    ra_sizes[xunit].blkoff >= radsize[unit])
2474743Swnj 		goto bad;
248*5434Sroot 	s = spl5();
2494743Swnj 	/*
2504743Swnj 	 * Link the buffer onto the drive queue
2514743Swnj 	 */
2524743Swnj 	dp = &udutab[ui->ui_unit];
2534743Swnj 	if (dp->b_actf == 0)
2544743Swnj 		dp->b_actf = bp;
2554743Swnj 	else
2564743Swnj 		dp->b_actl->av_forw = bp;
2574743Swnj 	dp->b_actl = bp;
2584743Swnj 	bp->av_forw = 0;
2594743Swnj 	/*
2604743Swnj 	 * Link the drive onto the controller queue
2614743Swnj 	 */
2624743Swnj 	if (dp->b_active == 0) {
2634743Swnj 		dp->b_forw = NULL;
2644743Swnj 		if (um->um_tab.b_actf == NULL)
2654743Swnj 			um->um_tab.b_actf = dp;
2664743Swnj 		else
2674743Swnj 			um->um_tab.b_actl->b_forw = dp;
2684743Swnj 		um->um_tab.b_actl = dp;
2694743Swnj 		dp->b_active = 1;
2704743Swnj 	}
2714743Swnj 	if (um->um_tab.b_active == 0) {
2724743Swnj #if defined(VAX750)
2734743Swnj 		if (cpu == VAX_750) {
2744743Swnj 			if (um->um_ubinfo != 0)
2754743Swnj 				printf("uda: ubinfo %x\n",um->um_ubinfo);
2764743Swnj 			else
2774743Swnj 				um->um_ubinfo =
2784743Swnj 				uballoc(um->um_ubanum, 0, 0, UBA_NEEDBDP);
2794743Swnj 		}
2804743Swnj #endif
2814743Swnj 		(void) udstart(um);
2824743Swnj 	}
283*5434Sroot 	splx(s);
2844743Swnj 	return;
2854743Swnj 
2864743Swnj bad:
2874743Swnj 	bp->b_flags |= B_ERROR;
2884743Swnj 	iodone(bp);
2894743Swnj 	return;
2904743Swnj }
2914743Swnj 
2924743Swnj udstart(um)
2934743Swnj 	register struct uba_ctlr *um;
2944743Swnj {
2954743Swnj 	register struct buf *bp, *dp;
2964743Swnj 	register struct mscp *mp;
2974743Swnj 	register struct uda_softc *sc;
2984743Swnj 	register struct uba_device *ui;
2994743Swnj 	struct udadevice *udaddr;
3004743Swnj 	int i;
3014743Swnj 
3024743Swnj 	sc = &uda_softc[um->um_ctlr];
3034743Swnj 
3044743Swnj loop:
3054743Swnj 	if ((dp = um->um_tab.b_actf) == NULL) {
3064743Swnj 		/*
3074743Swnj 		 * Release uneeded UBA resources and return
3084743Swnj 		 */
3094743Swnj 		um->um_tab.b_active = 0;
3104743Swnj #if defined(VAX750)
3114743Swnj 		if (cpu == VAX_750) {
3124743Swnj 			if (um->um_ubinfo == 0)
3134743Swnj 				printf("uda: um_ubinfo == 0\n");
3144743Swnj 			else
3154743Swnj 				ubarelse(um->um_ubanum, &um->um_ubinfo);
3164743Swnj 		}
3174743Swnj #endif
3184743Swnj 		return(0);
3194743Swnj 	}
3204743Swnj 	if ((bp = dp->b_actf) == NULL) {
3214743Swnj 		/*
3224743Swnj 		 * No more requests for this drive, remove
3234743Swnj 		 * from controller queue and look at next drive.
3244743Swnj 		 * We know we're at the head of the controller queue.
3254743Swnj 		 */
3264743Swnj 		dp->b_active = 0;
3274743Swnj 		um->um_tab.b_actf = dp->b_forw;
3284743Swnj 		goto loop;
3294743Swnj 	}
3304743Swnj 	um->um_tab.b_active++;
3314743Swnj 	udaddr = (struct udadevice *)um->um_addr;
3324743Swnj 	if ((udaddr->udasa&UDA_ERR) || sc->sc_state != S_RUN) {
3334743Swnj 		harderr(bp, "ra");
3344743Swnj 		printf("udasa %o, state %d\n", udaddr->udasa&0xffff, sc->sc_state);
3354743Swnj 		udinit(um->um_ctlr);
3364743Swnj 		/* SHOULD REQUEUE OUTSTANDING REQUESTS, LIKE UDRESET */
3374743Swnj 		return;
3384743Swnj 	}
3394743Swnj 	ui = uddinfo[dkunit(bp)];
3404743Swnj 	/*
3414743Swnj 	 * If no credits, can't issue any commands
3424743Swnj 	 * until some outstanding commands complete.
3434743Swnj 	 */
3444743Swnj 	if (sc->sc_credits < 2)
3454743Swnj 		return(0);
3464743Swnj 	if ((mp = udgetcp(um)) == NULL)
3474743Swnj 		return(0);
3484743Swnj 	sc->sc_credits--;	/* committed to issuing a command */
3494743Swnj 	if (ui->ui_flags == 0) {	/* not online */
3504743Swnj 		mp->mscp_opcode = M_OP_ONLIN;
3514743Swnj 		mp->mscp_unit = ui->ui_slave;
3524743Swnj 		dp->b_active = 2;
3534743Swnj 		um->um_tab.b_actf = dp->b_forw;	/* remove from controller q */
3544743Swnj 		printd("uda: bring unit %d online\n", ui->ui_slave);
3554743Swnj 		*((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT;
3564743Swnj 		i = udaddr->udaip;
3574743Swnj 		goto loop;
3584743Swnj 	}
3594743Swnj 	switch (cpu) {
3604743Swnj 	case VAX_780:
3614743Swnj 		i = UBA_NEEDBDP|UBA_CANTWAIT;
3624743Swnj 		break;
3634743Swnj 
3644743Swnj 	case VAX_750:
3654743Swnj 		i = um->um_ubinfo|UBA_HAVEBDP|UBA_CANTWAIT;
3664743Swnj 		break;
3674743Swnj 
3684743Swnj 	case VAX_7ZZ:
3694743Swnj 		i = UBA_CANTWAIT;
3704743Swnj 		break;
3714743Swnj 	}
3724743Swnj 	if ((i = ubasetup(um->um_ubanum, bp, i)) == 0) {
3734743Swnj 		mp->mscp_opcode = M_OP_GTUNT;
3744743Swnj 		mp->mscp_unit = ui->ui_slave;
3754743Swnj 		*((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT;
3764743Swnj 		i = udaddr->udaip;	/* initiate polling */
3774743Swnj 		return(1);		/* wait for interrupt */
3784743Swnj 	}
3794743Swnj 	mp->mscp_cmdref = (long)bp;	/* pointer to get back */
3804743Swnj 	mp->mscp_opcode = bp->b_flags&B_READ ? M_OP_READ : M_OP_WRITE;
3814743Swnj 	mp->mscp_unit = ui->ui_slave;
3824743Swnj 	mp->mscp_lbn = bp->b_blkno + ra_sizes[minor(bp->b_dev)&7].blkoff;
3834743Swnj 	mp->mscp_bytecnt = bp->b_bcount;
3844743Swnj 	mp->mscp_buffer = (i & 0x3ffff) | (((i>>28)&0xf)<<24);
3854743Swnj #if defined(VAX750)
3864743Swnj 	if (cpu == VAX_750)
3874743Swnj 		i &= 0xfffffff;		/* mask off bdp */
3884743Swnj #endif
3894743Swnj 	bp->b_ubinfo = i;		/* save mapping info */
3904743Swnj 	*((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT;
3914743Swnj 	i = udaddr->udaip;		/* initiate polling */
3924743Swnj 	if (ui->ui_dk >= 0) {
3934743Swnj 		dk_busy |= 1<<ui->ui_dk;
3944743Swnj 		dp->b_qsize++;
3954743Swnj 		dk_xfer[ui->ui_dk]++;
3964743Swnj 		dk_wds[ui->ui_dk] += bp->b_bcount>>6;
3974743Swnj 	}
3984743Swnj 
3994743Swnj 	/*
4004743Swnj 	 * Move drive to the end of the controller queue
4014743Swnj 	 */
4024743Swnj 	if (dp->b_forw != NULL) {
4034743Swnj 		um->um_tab.b_actf = dp->b_forw;
4044743Swnj 		um->um_tab.b_actl->b_forw = dp;
4054743Swnj 		um->um_tab.b_actl = dp;
4064743Swnj 		dp->b_forw = NULL;
4074743Swnj 	}
4084743Swnj 	/*
4094743Swnj 	 * Move buffer to I/O wait queue
4104743Swnj 	 */
4114743Swnj 	dp->b_actf = bp->av_forw;
4124743Swnj 	dp = &udwtab[um->um_ctlr];
4134743Swnj 	bp->av_forw = dp;
4144743Swnj 	bp->av_back = dp->av_back;
4154743Swnj 	dp->av_back->av_forw = bp;
4164743Swnj 	dp->av_back = bp;
4174743Swnj 	goto loop;
4184743Swnj }
4194743Swnj 
4204743Swnj /*
4214743Swnj  * UDA interrupt routine.
4224743Swnj  */
4234743Swnj udintr(d)
4244743Swnj 	int d;
4254743Swnj {
4264743Swnj 	register struct uba_ctlr *um = udminfo[d];
4274743Swnj 	register struct udadevice *udaddr = (struct udadevice *)um->um_addr;
4284743Swnj 	struct buf *bp;
4294743Swnj 	register int i;
4304743Swnj 	register struct uda_softc *sc = &uda_softc[d];
4314743Swnj 	register struct uda *ud = &uda[d];
4324743Swnj 	struct uda *uud;
4334743Swnj 	struct mscp *mp;
4344743Swnj 
4354743Swnj 	printd("udintr: state %d, udasa %o\n", sc->sc_state, udaddr->udasa);
4364743Swnj 	switch (sc->sc_state) {
4374743Swnj 	case S_IDLE:
4384743Swnj 		printf("uda%d: random interrupt ignored\n", d);
4394743Swnj 		return;
4404743Swnj 
4414743Swnj 	case S_STEP1:
4424743Swnj #define	STEP1GOOD	(UDA_STEP2|UDA_IE|(NCMDL2<<3)|NRSPL2)
4434743Swnj 		if ((udaddr->udasa&(UDA_ERR|STEP1GOOD)) != STEP1GOOD) {
4444743Swnj 			sc->sc_state = S_IDLE;
4454743Swnj 			wakeup(um);
4464743Swnj 			return;
4474743Swnj 		}
4484743Swnj 		udaddr->udasa = ((int)&sc->sc_uda->uda_ca.ca_ringbase)|
4494743Swnj 		    (cpu == VAX_780 ? UDA_PI : 0);
4504743Swnj 		sc->sc_state = S_STEP2;
4514743Swnj 		return;
4524743Swnj 
4534743Swnj 	case S_STEP2:
4544743Swnj #define	STEP2GOOD	(UDA_STEP3|UDA_IE|(sc->sc_ivec/4))
4554743Swnj 		if ((udaddr->udasa&(UDA_ERR|STEP2GOOD)) != STEP2GOOD) {
4564743Swnj 			sc->sc_state = S_IDLE;
4574743Swnj 			wakeup(um);
4584743Swnj 			return;
4594743Swnj 		}
4604743Swnj 		udaddr->udasa = ((int)&sc->sc_uda->uda_ca.ca_ringbase)>>16;
4614743Swnj 		sc->sc_state = S_STEP3;
4624743Swnj 		return;
4634743Swnj 
4644743Swnj 	case S_STEP3:
4654743Swnj #define	STEP3GOOD	UDA_STEP4
4664743Swnj 		if ((udaddr->udasa&(UDA_ERR|STEP3GOOD)) != STEP3GOOD) {
4674743Swnj 			sc->sc_state = S_IDLE;
4684743Swnj 			wakeup(um);
4694743Swnj 			return;
4704743Swnj 		}
4714743Swnj 		udaddr->udasa = UDA_GO;
4724743Swnj 		sc->sc_state = S_SCHAR;
4734743Swnj 
4744743Swnj 		/*
4754743Swnj 		 * Initialize the data structures.
4764743Swnj 		 */
4774743Swnj 		uud = sc->sc_uda;
4784743Swnj 		for (i = 0; i < NRSP; i++) {
4794743Swnj 			ud->uda_ca.ca_rspdsc[i] = UDA_OWN|UDA_INT|
4804743Swnj 				(long)&uud->uda_rsp[i].mscp_cmdref;
4814743Swnj 			ud->uda_rsp[i].mscp_dscptr = &ud->uda_ca.ca_rspdsc[i];
4824743Swnj 			ud->uda_rsp[i].mscp_header.uda_msglen = sizeof (struct mscp);
4834743Swnj 		}
4844743Swnj 		for (i = 0; i < NCMD; i++) {
4854743Swnj 			ud->uda_ca.ca_cmddsc[i] = UDA_INT|
4864743Swnj 				(long)&uud->uda_cmd[i].mscp_cmdref;
4874743Swnj 			ud->uda_cmd[i].mscp_dscptr = &ud->uda_ca.ca_cmddsc[i];
4884743Swnj 			ud->uda_cmd[i].mscp_header.uda_msglen = sizeof (struct mscp);
4894743Swnj 		}
4904743Swnj 		bp = &udwtab[d];
4914743Swnj 		bp->av_forw = bp->av_back = bp;
4924743Swnj 		sc->sc_lastcmd = 0;
4934743Swnj 		sc->sc_lastrsp = 0;
4944743Swnj 		if ((mp = udgetcp(um)) == NULL) {
4954743Swnj 			sc->sc_state = S_IDLE;
4964743Swnj 			wakeup(um);
4974743Swnj 			return;
4984743Swnj 		}
4994743Swnj 		mp->mscp_opcode = M_OP_STCON;
5004743Swnj 		mp->mscp_cntflgs = M_CF_ATTN|M_CF_MISC|M_CF_THIS;
5014743Swnj 		*((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT;
5024743Swnj 		i = udaddr->udaip;	/* initiate polling */
5034743Swnj 		return;
5044743Swnj 
5054743Swnj 	case S_SCHAR:
5064743Swnj 	case S_RUN:
5074743Swnj 		break;
5084743Swnj 
5094743Swnj 	default:
5104743Swnj 		printf("uda%d: interrupt in unknown state %d ignored\n",
5114743Swnj 			d, sc->sc_state);
5124743Swnj 		return;
5134743Swnj 	}
5144743Swnj 
5154743Swnj 	if (udaddr->udasa&UDA_ERR) {
5164743Swnj 		printf("uda%d: fatal error (%o)\n", d, udaddr->udasa&0xffff);
5174743Swnj 		udaddr->udaip = 0;
5184743Swnj 		wakeup(um);
5194743Swnj 	}
5204743Swnj 
5214743Swnj 	/*
5224743Swnj 	 * Check for a buffer purge request.
5234743Swnj 	 */
5244743Swnj 	if (ud->uda_ca.ca_bdp) {
5254743Swnj 		/*
5264743Swnj 		 * THIS IS A KLUDGE.
5274743Swnj 		 * Maybe we should change the entire
5284743Swnj 		 * UBA interface structure.
5294743Swnj 		 */
5304743Swnj 		int s = spl7();
5314743Swnj 
5324743Swnj 		i = um->um_ubinfo;
5334743Swnj 		printd("uda: purge bdp %d\n", ud->uda_ca.ca_bdp);
5344743Swnj 		um->um_ubinfo = ud->uda_ca.ca_bdp<<28;
5354743Swnj 		ubapurge(um);
5364743Swnj 		um->um_ubinfo = i;
5374743Swnj 		(void) splx(s);
5384743Swnj 		ud->uda_ca.ca_bdp = 0;
5394743Swnj 		udaddr->udasa = 0;	/* signal purge complete */
5404743Swnj 	}
5414743Swnj 
5424743Swnj 	/*
5434743Swnj 	 * Check for response ring transition.
5444743Swnj 	 */
5454743Swnj 	if (ud->uda_ca.ca_rspint) {
5464743Swnj 		ud->uda_ca.ca_rspint = 0;
5474743Swnj 		for (i = sc->sc_lastrsp;; i++) {
5484743Swnj 			i %= NRSP;
5494743Swnj 			if (ud->uda_ca.ca_rspdsc[i]&UDA_OWN)
5504743Swnj 				break;
5514743Swnj 			udrsp(um, ud, sc, i);
5524743Swnj 			ud->uda_ca.ca_rspdsc[i] |= UDA_OWN;
5534743Swnj 		}
5544743Swnj 		sc->sc_lastrsp = i;
5554743Swnj 	}
5564743Swnj 
5574743Swnj 	/*
5584743Swnj 	 * Check for command ring transition.
5594743Swnj 	 */
5604743Swnj 	if (ud->uda_ca.ca_cmdint) {
5614743Swnj 		printd("uda: command ring transition\n");
5624743Swnj 		ud->uda_ca.ca_cmdint = 0;
5634743Swnj 	}
5644743Swnj 	udstart(um);
5654743Swnj }
5664743Swnj 
5674743Swnj /*
5684743Swnj  * Process a response packet
5694743Swnj  */
5704743Swnj udrsp(um, ud, sc, i)
5714743Swnj 	register struct uba_ctlr *um;
5724743Swnj 	register struct uda *ud;
5734743Swnj 	register struct uda_softc *sc;
5744743Swnj 	int i;
5754743Swnj {
5764743Swnj 	register struct mscp *mp;
5774743Swnj 	struct uba_device *ui;
5784743Swnj 	struct buf *dp, *bp;
5794743Swnj 	int st;
5804743Swnj 
5814743Swnj 	mp = &ud->uda_rsp[i];
5824743Swnj 	mp->mscp_header.uda_msglen = sizeof (struct mscp);
5834743Swnj 	sc->sc_credits += mp->mscp_header.uda_credits & 0xf;
5844743Swnj 	if ((mp->mscp_header.uda_credits & 0xf0) > 0x10)
5854743Swnj 		return;
5864743Swnj 	/*
5874743Swnj 	 * If it's an error log message (datagram),
5884743Swnj 	 * pass it on for more extensive processing.
5894743Swnj 	 */
5904743Swnj 	if ((mp->mscp_header.uda_credits & 0xf0) == 0x10) {
5914743Swnj 		uderror(um, (struct mslg *)mp);
5924743Swnj 		return;
5934743Swnj 	}
5944743Swnj 	if (mp->mscp_unit >= 8)
5954743Swnj 		return;
5964743Swnj 	if ((ui = udip[um->um_ctlr][mp->mscp_unit]) == 0)
5974743Swnj 		return;
5984743Swnj 	st = mp->mscp_status&M_ST_MASK;
5994743Swnj 	switch (mp->mscp_opcode) {
6004743Swnj 	case M_OP_STCON|M_OP_END:
6014743Swnj 		if (st == M_ST_SUCC)
6024743Swnj 			sc->sc_state = S_RUN;
6034743Swnj 		else
6044743Swnj 			sc->sc_state = S_IDLE;
6054743Swnj 		um->um_tab.b_active = 0;
6064743Swnj 		wakeup(um);
6074743Swnj 		break;
6084743Swnj 
6094743Swnj 	case M_OP_ONLIN|M_OP_END:
6104743Swnj 		/*
6114743Swnj 		 * Link the drive onto the controller queue
6124743Swnj 		 */
6134743Swnj 		dp = &udutab[ui->ui_unit];
6144743Swnj 		dp->b_forw = NULL;
6154743Swnj 		if (um->um_tab.b_actf == NULL)
6164743Swnj 			um->um_tab.b_actf = dp;
6174743Swnj 		else
6184743Swnj 			um->um_tab.b_actl->b_forw = dp;
6194743Swnj 		um->um_tab.b_actl = dp;
6204743Swnj 		if (st == M_ST_SUCC) {
6214743Swnj 			ui->ui_flags = 1;	/* mark it online */
6224743Swnj 			radsize[ui->ui_unit] = (daddr_t)mp->mscp_untsize;
6234743Swnj 			printd("uda: unit %d online\n", mp->mscp_unit);
6244743Swnj 		} else {
6254743Swnj 			harderr(dp->b_actf, "ra");
6264743Swnj 			printf("OFFLINE\n");
6274743Swnj 			while (bp = dp->b_actf) {
6284743Swnj 				dp->b_actf = bp->av_forw;
6294743Swnj 				bp->b_flags |= B_ERROR;
6304743Swnj 				iodone(bp);
6314743Swnj 			}
6324743Swnj 		}
6334743Swnj 		dp->b_active = 1;
6344743Swnj 		break;
6354743Swnj 
6364743Swnj 	case M_OP_AVATN:
6374743Swnj 		printd("uda: unit %d attention\n", mp->mscp_unit);
6384743Swnj 		ui->ui_flags = 0;	/* it went offline and we didn't notice */
6394743Swnj 		break;
6404743Swnj 
6414743Swnj 	case M_OP_READ|M_OP_END:
6424743Swnj 	case M_OP_WRITE|M_OP_END:
6434743Swnj 		bp = (struct buf *)mp->mscp_cmdref;
6444743Swnj 		ubarelse(um->um_ubanum, &bp->b_resid);
6454743Swnj 		/*
6464743Swnj 		 * Unlink buffer from I/O wait queue.
6474743Swnj 		 */
6484743Swnj 		bp->av_back->av_forw = bp->av_forw;
6494743Swnj 		bp->av_forw->av_back = bp->av_back;
6504743Swnj 		dp = &udutab[ui->ui_unit];
6514743Swnj 		if (ui->ui_dk >= 0)
6524743Swnj 			if (--dp->b_qsize == 0)
6534743Swnj 				dk_busy &= ~(1<<ui->ui_dk);
6544743Swnj 		if (st == M_ST_OFFLN || st == M_ST_AVLBL) {
6554743Swnj 			ui->ui_flags = 0;	/* mark unit offline */
6564743Swnj 			/*
6574743Swnj 			 * Link the buffer onto the front of the drive queue
6584743Swnj 			 */
6594743Swnj 			if ((bp->av_forw = dp->b_actf) == 0)
6604743Swnj 				dp->b_actl = bp;
6614743Swnj 			dp->b_actf = bp;
6624743Swnj 			/*
6634743Swnj 			 * Link the drive onto the controller queue
6644743Swnj 			 */
6654743Swnj 			if (dp->b_active == 0) {
6664743Swnj 				dp->b_forw = NULL;
6674743Swnj 				if (um->um_tab.b_actf == NULL)
6684743Swnj 					um->um_tab.b_actf = dp;
6694743Swnj 				else
6704743Swnj 					um->um_tab.b_actl->b_forw = dp;
6714743Swnj 				um->um_tab.b_actl = dp;
6724743Swnj 				dp->b_active = 1;
6734743Swnj 			}
6744743Swnj 			return;
6754743Swnj 		}
6764743Swnj 		if (st != M_ST_SUCC) {
6774743Swnj 			harderr(bp, "ra");
6784743Swnj 			printf("status %o\n", mp->mscp_status);
6794743Swnj 			bp->b_flags |= B_ERROR;
6804743Swnj 		}
6814743Swnj 		bp->b_resid = bp->b_bcount - mp->mscp_bytecnt;
6824743Swnj 		iodone(bp);
6834743Swnj 		break;
6844743Swnj 
6854743Swnj 	case M_OP_GTUNT|M_OP_END:
6864743Swnj 		break;
6874743Swnj 
6884743Swnj 	default:
6894743Swnj 		printf("uda: unknown packet\n");
6904743Swnj 	}
6914743Swnj }
6924743Swnj 
6934743Swnj 
6944743Swnj /*
6954743Swnj  * Process an error log message
6964743Swnj  *
6974743Swnj  * For now, just log the error on the console.
6984743Swnj  * Only minimal decoding is done, only "useful"
6994743Swnj  * information is printed.  Eventually should
7004743Swnj  * send message to an error logger.
7014743Swnj  */
7024743Swnj uderror(um, mp)
7034743Swnj 	register struct uba_ctlr *um;
7044743Swnj 	register struct mslg *mp;
7054743Swnj {
7064743Swnj 	printf("uda%d:%d: %s error, ", um->um_ctlr, mp->mslg_seqnum,
7074743Swnj 		mp->mslg_flags&M_LF_SUCC ? "soft" : "hard");
7084743Swnj 	switch (mp->mslg_format) {
7094743Swnj 	case M_FM_CNTERR:
7104743Swnj 		printf("controller error, event 0%o\n", mp->mslg_event);
7114743Swnj 		break;
7124743Swnj 
7134743Swnj 	case M_FM_BUSADDR:
7144743Swnj 		printf("host memory access error, event 0%o, addr 0%o\n",
7154743Swnj 			mp->mslg_event, *((long *)&mp->mslg_busaddr[0]));
7164743Swnj 		break;
7174743Swnj 
7184743Swnj 	case M_FM_DISKTRN:
7194743Swnj 		printf("disk transfer error, unit %d, grp %d, cyl %d, sec %d, ",
7204743Swnj 			mp->mslg_unit, mp->mslg_group, mp->mslg_cylinder,
7214743Swnj 			mp->mslg_sector);
7224743Swnj 		printf("trk %d, lbn %d, retry %d, level %d\n", mp->mslg_track,
7234743Swnj 			mp->mslg_lbn, mp->mslg_retry, mp->mslg_level);
7244743Swnj 		break;
7254743Swnj 
7264743Swnj 	case M_FM_SDI:
7274743Swnj 		printf("SDI error, unit %d, event 0%o, cyl %d\n", mp->mslg_unit,
7284743Swnj 			mp->mslg_event, mp->mslg_cylinder);
7294743Swnj 		break;
7304743Swnj 
7314743Swnj 	case M_FM_SMLDSK:
7324743Swnj 		printf("small disk error, unit %d, event 0%o, cyl %d\n",
7334743Swnj 			mp->mslg_unit, mp->mslg_event, mp->mslg_sdecyl);
7344743Swnj 		break;
7354743Swnj 
7364743Swnj 	default:
7374743Swnj 		printf("unknown error, unit %d, format 0%o, event 0%o\n",
7384743Swnj 			mp->mslg_unit, mp->mslg_format, mp->mslg_event);
7394743Swnj 	}
7404743Swnj }
7414743Swnj 
7424743Swnj 
7434743Swnj /*
7444743Swnj  * Find an unused command packet
7454743Swnj  */
7464743Swnj struct mscp *
7474743Swnj udgetcp(um)
7484743Swnj 	struct uba_ctlr *um;
7494743Swnj {
7504743Swnj 	register struct mscp *mp;
7514743Swnj 	register struct udaca *cp;
7524743Swnj 	register struct uda_softc *sc;
7534743Swnj 	register int i;
7544743Swnj 
7554743Swnj 	cp = &uda[um->um_ctlr].uda_ca;
7564743Swnj 	sc = &uda_softc[um->um_ctlr];
7574743Swnj 	i = sc->sc_lastcmd;
7584743Swnj 	if ((cp->ca_cmddsc[i] & (UDA_OWN|UDA_INT)) == UDA_INT) {
7594743Swnj 		cp->ca_cmddsc[i] &= ~UDA_INT;
7604743Swnj 		mp = &uda[um->um_ctlr].uda_cmd[i];
7614743Swnj 		mp->mscp_unit = mp->mscp_modifier = 0;
7624743Swnj 		mp->mscp_opcode = mp->mscp_flags = 0;
7634743Swnj 		mp->mscp_bytecnt = mp->mscp_buffer = 0;
7644743Swnj 		mp->mscp_errlgfl = mp->mscp_copyspd = 0;
7654743Swnj 		sc->sc_lastcmd = (i + 1) % NCMD;
7664743Swnj 		return(mp);
7674743Swnj 	}
7684743Swnj 	return(NULL);
7694743Swnj }
7704743Swnj 
7714743Swnj udread(dev)
7724743Swnj 	dev_t dev;
7734743Swnj {
7744743Swnj 	register int unit = minor(dev) >> 3;
7754743Swnj 
7764743Swnj 	if (unit >= NRA)
7774743Swnj 		u.u_error = ENXIO;
7784743Swnj 	else
7794743Swnj 		physio(udstrategy, &rudbuf[unit], dev, B_READ, minphys);
7804743Swnj }
7814743Swnj 
7824743Swnj udwrite(dev)
7834743Swnj 	dev_t dev;
7844743Swnj {
7854743Swnj 	register int unit = minor(dev) >> 3;
7864743Swnj 
7874743Swnj 	if (unit >= NRA)
7884743Swnj 		u.u_error = ENXIO;
7894743Swnj 	else
7904743Swnj 		physio(udstrategy, &rudbuf[unit], dev, B_WRITE, minphys);
7914743Swnj }
7924743Swnj 
7934743Swnj udreset(uban)
7944743Swnj 	int uban;
7954743Swnj {
7964743Swnj 	register struct uba_ctlr *um;
7974743Swnj 	register struct uba_device *ui;
7984743Swnj 	register struct buf *bp, *dp;
7994743Swnj 	register int unit;
8004743Swnj 	struct buf *nbp;
8014743Swnj 	int d;
8024743Swnj 
8034743Swnj 	for (d = 0; d < NUDA; d++) {
8044743Swnj 		if ((um = udminfo[d]) == 0 || um->um_ubanum != uban ||
8054743Swnj 		    um->um_alive == 0)
8064743Swnj 			continue;
8074743Swnj 		printf(" uda%d", d);
8084743Swnj 		um->um_tab.b_active = 0;
8094743Swnj 		um->um_tab.b_actf = um->um_tab.b_actl = 0;
8104743Swnj 		uda_softc[d].sc_state = S_IDLE;
8114743Swnj 		for (unit = 0; unit < NRA; unit++) {
8124743Swnj 			if ((ui = uddinfo[unit]) == 0)
8134743Swnj 				continue;
8144743Swnj 			if (ui->ui_alive == 0 || ui->ui_mi != um)
8154743Swnj 				continue;
8164743Swnj 			udutab[unit].b_active = 0;
8174743Swnj 			udutab[unit].b_qsize = 0;
8184743Swnj 		}
8194743Swnj 		for (bp = udwtab[d].av_forw; bp != &udwtab[d]; bp = nbp) {
8204743Swnj 			nbp = bp->av_forw;
8214743Swnj 			ubarelse(uban, &bp->b_ubinfo);
8224743Swnj 			/*
8234743Swnj 			 * Link the buffer onto the drive queue
8244743Swnj 			 */
8254743Swnj 			dp = &udutab[dkunit(bp)];
8264743Swnj 			if (dp->b_actf == 0)
8274743Swnj 				dp->b_actf = bp;
8284743Swnj 			else
8294743Swnj 				dp->b_actl->av_forw = bp;
8304743Swnj 			dp->b_actl = bp;
8314743Swnj 			bp->av_forw = 0;
8324743Swnj 			/*
8334743Swnj 			 * Link the drive onto the controller queue
8344743Swnj 			 */
8354743Swnj 			if (dp->b_active == 0) {
8364743Swnj 				dp->b_forw = NULL;
8374743Swnj 				if (um->um_tab.b_actf == NULL)
8384743Swnj 					um->um_tab.b_actf = dp;
8394743Swnj 				else
8404743Swnj 					um->um_tab.b_actl->b_forw = dp;
8414743Swnj 				um->um_tab.b_actl = dp;
8424743Swnj 				dp->b_active = 1;
8434743Swnj 			}
8444743Swnj 		}
8454743Swnj 		udinit(d);
8464743Swnj 	}
8474743Swnj }
8484743Swnj 
8494743Swnj uddump()
8504743Swnj {
8514743Swnj 	return(ENXIO);
8524743Swnj }
853