xref: /csrg-svn/sys/vax/uba/ut.c (revision 6954)
1*6954Sroot /*	ut.c	4.12	82/05/27	*/
24744Swnj 
34862Sroot #include "tj.h"
44744Swnj #if NUT > 0
54744Swnj /*
64744Swnj  * System Industries Model 9700 Tape Drive
74744Swnj  *   emulates a TU45 on the UNIBUS
84744Swnj  *
94744Swnj  * TODO:
104744Swnj  *	check out attention processing
114744Swnj  *	try reset code and dump code
124744Swnj  */
134744Swnj #include "../h/param.h"
144744Swnj #include "../h/systm.h"
154744Swnj #include "../h/buf.h"
164744Swnj #include "../h/conf.h"
174744Swnj #include "../h/dir.h"
184744Swnj #include "../h/file.h"
194744Swnj #include "../h/user.h"
204744Swnj #include "../h/map.h"
214744Swnj #include "../h/pte.h"
224744Swnj #include "../h/ubareg.h"
234744Swnj #include "../h/ubavar.h"
244744Swnj #include "../h/mtio.h"
254744Swnj #include "../h/ioctl.h"
264744Swnj #include "../h/cmap.h"
274744Swnj #include "../h/cpu.h"
284744Swnj 
294744Swnj #include "../h/utreg.h"
304744Swnj 
314744Swnj struct	buf	rutbuf[NUT];	/* bufs for raw i/o */
324744Swnj struct	buf	cutbuf[NUT];	/* bufs for control operations */
334744Swnj struct	buf	tjutab[NTJ];	/* bufs for slave queue headers */
344744Swnj 
354744Swnj struct uba_ctlr *utminfo[NUT];
364744Swnj struct uba_device *tjdinfo[NTJ];
374833Swnj int utprobe(), utslave(), utattach(), utdgo(), utintr(), uttimer();
384744Swnj u_short utstd[] = { 0772440, 0 };
394744Swnj struct uba_driver utdriver =
404744Swnj   { utprobe, utslave, utattach, utdgo, utstd, "tj", tjdinfo, "ut", utminfo, 0 };
414744Swnj 
424744Swnj /* bits in minor device */
434744Swnj #define	TJUNIT(dev)	(minor(dev)&03)
444744Swnj #define	T_NOREWIND	04
454744Swnj #define	T_1600BPI	010
464744Swnj #define	T_6250BPI	020
474744Swnj short	utdens[] = { UT_NRZI, UT_PE, UT_GCR, UT_NRZI };
484744Swnj 
494744Swnj /* slave to controller mapping table */
504744Swnj short	tjtout[NTJ];
514744Swnj #define UTUNIT(dev)	(tjtout[TJUNIT(dev)])
524744Swnj 
534744Swnj #define	INF	(daddr_t)1000000L	/* a block number that wont exist */
544744Swnj 
554744Swnj struct	tj_softc {
564744Swnj 	char	sc_openf;	/* exclusive open */
574744Swnj 	char	sc_lastiow;	/* last I/O operation was a write */
584744Swnj 	daddr_t	sc_blkno;	/* next block to transfer */
594744Swnj 	daddr_t	sc_nxrec;	/* next record on tape */
604744Swnj 	u_short	sc_erreg;	/* image of uter */
614744Swnj 	u_short	sc_dsreg;	/* image of utds */
624746Ssam 	u_short	sc_resid;	/* residual from transfer */
634744Swnj 	u_short	sc_dens;	/* sticky selected density */
644833Swnj 	daddr_t	sc_timo;	/* time until timeout expires */
654833Swnj 	short	sc_tact;	/* timeout is active flag */
664744Swnj } tj_softc[NTJ];
674744Swnj 
684744Swnj /*
694744Swnj  * Internal per/slave states found in sc_state
704744Swnj  */
714744Swnj #define	SSEEK		1	/* seeking */
724744Swnj #define	SIO		2	/* doing sequential I/O */
734744Swnj #define	SCOM		3	/* sending a control command */
744744Swnj #define	SREW		4	/* doing a rewind op */
754746Ssam #define	SERASE		5	/* erase inter-record gap */
764746Ssam #define	SERASED		6	/* erased inter-record gap */
774744Swnj 
784941Swnj /*ARGSUSED*/
794744Swnj utprobe(reg)
804744Swnj 	caddr_t reg;
814744Swnj {
824744Swnj 	register int br, cvec;
834744Swnj #ifdef lint
844744Swnj 	br=0; cvec=br; br=cvec;
854941Swnj 	utintr(0);
864744Swnj #endif
874746Ssam 	/*
88*6954Sroot 	 * The SI documentation says you must set the RDY bit
89*6954Sroot 	 * (even though it's read-only) to force an interrupt.
904746Ssam 	 */
91*6954Sroot 	((struct utdevice *) reg)->utcs1 = UT_IE|UT_NOP|UT_RDY;
924744Swnj 	DELAY(10000);
934744Swnj }
944744Swnj 
954744Swnj /*ARGSUSED*/
964744Swnj utslave(ui, reg)
974744Swnj 	struct uba_device *ui;
984744Swnj 	caddr_t reg;
994744Swnj {
1004744Swnj 	/*
1014744Swnj 	 * A real TU45 would support the slave present bit
1024744Swnj 	 * int the drive type register, but this thing doesn't,
1034744Swnj 	 * so there's no way to determine if a slave is present or not.
1044744Swnj 	 */
1054744Swnj 	 return(1);
1064744Swnj }
1074744Swnj 
1084744Swnj utattach(ui)
1094744Swnj 	struct uba_device *ui;
1104744Swnj {
1114744Swnj 	tjtout[ui->ui_unit] = ui->ui_mi->um_ctlr;
1124744Swnj }
1134744Swnj 
1144744Swnj /*
1154744Swnj  * Open the device with exclusive access.
1164744Swnj  */
1174744Swnj utopen(dev, flag)
1184744Swnj 	dev_t dev;
1194744Swnj 	int flag;
1204744Swnj {
1214744Swnj 	register int tjunit = TJUNIT(dev);
1224744Swnj 	register struct uba_device *ui;
1234744Swnj 	register struct tj_softc *sc;
1244744Swnj 	int olddens, dens;
1255439Sroot 	register int s;
1264744Swnj 
1274744Swnj 	if (tjunit >= NTJ || (sc = &tj_softc[tjunit])->sc_openf ||
1284744Swnj 	    (ui = tjdinfo[tjunit]) == 0 || ui->ui_alive == 0) {
1294744Swnj 		u.u_error = ENXIO;
1304744Swnj 		return;
1314744Swnj 	}
1324744Swnj 	olddens = sc->sc_dens;
1334744Swnj 	dens = sc->sc_dens = utdens[(minor(dev)&(T_1600BPI|T_6250BPI))>>3]|
1344744Swnj 				PDP11FMT|(ui->ui_slave&07);
1354744Swnj get:
1364744Swnj 	utcommand(dev, UT_SENSE, 1);
1374744Swnj 	if (sc->sc_dsreg&UTDS_PIP) {
1384744Swnj 		sleep((caddr_t) &lbolt, PZERO+1);
1394744Swnj 		goto get;
1404744Swnj 	}
1414744Swnj 	sc->sc_dens = olddens;
1424744Swnj 	if ((sc->sc_dsreg&UTDS_MOL) == 0) {
1434744Swnj 		uprintf("tj%d: not online\n", tjunit);
1444744Swnj 		u.u_error = EIO;
1454744Swnj 		return;
1464744Swnj 	}
1474744Swnj 	if ((flag&FWRITE) && (sc->sc_dsreg&UTDS_WRL)) {
1484744Swnj 		uprintf("tj%d: no write ring\n", tjunit);
1494744Swnj 		u.u_error = EIO;
1504744Swnj 		return;
1514744Swnj 	}
1524744Swnj 	if ((sc->sc_dsreg&UTDS_BOT) == 0 && (flag&FWRITE) &&
1534744Swnj 	    dens != sc->sc_dens) {
1544744Swnj 		uprintf("tj%d: can't change density in mid-tape\n", tjunit);
1554744Swnj 		u.u_error = EIO;
1564744Swnj 		return;
1574744Swnj 	}
1584744Swnj 	sc->sc_openf = 1;
1594744Swnj 	sc->sc_blkno = (daddr_t)0;
1604744Swnj 	sc->sc_nxrec = INF;
1614744Swnj 	sc->sc_lastiow = 0;
1624744Swnj 	sc->sc_dens = dens;
1634746Ssam 	/*
1644746Ssam 	 * For 6250 bpi take exclusive use of the UNIBUS.
1654746Ssam 	 */
1664746Ssam 	ui->ui_driver->ud_xclu = (dens&(T_1600BPI|T_6250BPI)) == T_6250BPI;
1675439Sroot 	s = spl6();
1684833Swnj 	if (sc->sc_tact == 0) {
1694833Swnj 		sc->sc_timo = INF;
1704833Swnj 		sc->sc_tact = 1;
1714833Swnj 		timeout(uttimer, (caddr_t)dev, 5*hz);
1724833Swnj 	}
1735439Sroot 	splx(s);
1744744Swnj }
1754744Swnj 
1764744Swnj utclose(dev, flag)
1774744Swnj 	register dev_t dev;
1784744Swnj 	register flag;
1794744Swnj {
1804744Swnj 	register struct tj_softc *sc = &tj_softc[TJUNIT(dev)];
1814744Swnj 
1824744Swnj 	if (flag == FWRITE || ((flag&FWRITE) && sc->sc_lastiow)) {
1834744Swnj 		utcommand(dev, UT_WEOF, 1);
1844744Swnj 		utcommand(dev, UT_WEOF, 1);
1854744Swnj 		utcommand(dev, UT_SREV, 1);
1864744Swnj 	}
1874744Swnj 	if ((minor(dev)&T_NOREWIND) == 0)
1884744Swnj 		utcommand(dev, UT_REW, 0);
1894744Swnj 	sc->sc_openf = 0;
1904744Swnj }
1914744Swnj 
1924744Swnj utcommand(dev, com, count)
1934744Swnj 	dev_t dev;
1944744Swnj 	int com, count;
1954744Swnj {
1964744Swnj 	register struct buf *bp;
1975439Sroot 	register int s;
1984744Swnj 
1994744Swnj 	bp = &cutbuf[UTUNIT(dev)];
2005439Sroot 	s = spl5();
2014744Swnj 	while (bp->b_flags&B_BUSY) {
2024744Swnj 		if(bp->b_repcnt == 0 && (bp->b_flags&B_DONE))
2034744Swnj 			break;
2044744Swnj 		bp->b_flags |= B_WANTED;
2054744Swnj 		sleep((caddr_t)bp, PRIBIO);
2064744Swnj 	}
2074744Swnj 	bp->b_flags = B_BUSY|B_READ;
2085439Sroot 	splx(s);
2094744Swnj 	bp->b_dev = dev;
2104744Swnj 	bp->b_command = com;
2114744Swnj 	bp->b_repcnt = count;
2124744Swnj 	bp->b_blkno = 0;
2134744Swnj 	utstrategy(bp);
2144744Swnj 	if (count == 0)
2154744Swnj 		return;
2164744Swnj 	iowait(bp);
2174744Swnj 	if (bp->b_flags&B_WANTED)
2184744Swnj 		wakeup((caddr_t)bp);
2194744Swnj 	bp->b_flags &= B_ERROR;
2204744Swnj }
2214744Swnj 
2224744Swnj /*
2234744Swnj  * Queue a tape operation.
2244744Swnj  */
2254744Swnj utstrategy(bp)
2264744Swnj 	register struct buf *bp;
2274744Swnj {
2284744Swnj 	int tjunit = TJUNIT(bp->b_dev);
2294744Swnj 	register struct uba_ctlr *um;
2304744Swnj 	register struct buf *dp;
2314744Swnj 
2324744Swnj 	/*
2334744Swnj 	 * Put transfer at end of unit queue
2344744Swnj 	 */
2354744Swnj 	dp = &tjutab[tjunit];
2364744Swnj 	bp->av_forw = NULL;
2374744Swnj 	(void) spl5();
2384744Swnj 	if (dp->b_actf == NULL) {
2394744Swnj 		dp->b_actf = bp;
2404744Swnj 		/*
2414744Swnj 		 * Transport not active, so...
2424744Swnj 		 * put at end of controller queue
2434744Swnj 		 */
2444744Swnj 		dp->b_forw = NULL;
2454744Swnj 		um = tjdinfo[tjunit]->ui_mi;
2464744Swnj 		if (um->um_tab.b_actf == NULL)
2474744Swnj 			um->um_tab.b_actf = dp;
2484744Swnj 		else
2494744Swnj 			um->um_tab.b_actl->b_forw = dp;
2504744Swnj 		um->um_tab.b_actl = dp;
2514744Swnj 	} else
2524744Swnj 		dp->b_actl->av_forw = bp;
2534744Swnj 	dp->b_actl = bp;
2544744Swnj 	/*
2554744Swnj 	 * If the controller is not busy, set it going.
2564744Swnj 	 */
2574746Ssam 	if (um->um_tab.b_state == 0)
2584744Swnj 		utstart(um);
2594744Swnj 	(void) spl0();
2604744Swnj }
2614744Swnj 
2624744Swnj utstart(um)
2634744Swnj 	register struct uba_ctlr *um;
2644744Swnj {
2654746Ssam 	register struct utdevice *addr;
2664744Swnj 	register struct buf *bp, *dp;
2674744Swnj 	register struct tj_softc *sc;
2684744Swnj 	struct uba_device *ui;
2694744Swnj 	int tjunit;
2704744Swnj 	daddr_t blkno;
2714744Swnj 
2724744Swnj loop:
2734744Swnj 	/*
2744744Swnj 	 * Scan controller queue looking for units with
2754744Swnj 	 * transaction queues to dispatch
2764744Swnj 	 */
2774744Swnj 	if ((dp = um->um_tab.b_actf) == NULL)
2784744Swnj 		return;
2794744Swnj 	if ((bp = dp->b_actf) == NULL) {
2804744Swnj 		um->um_tab.b_actf = dp->b_forw;
2814744Swnj 		goto loop;
2824744Swnj 	}
2834746Ssam 	addr = (struct utdevice *)um->um_addr;
2844744Swnj 	tjunit = TJUNIT(bp->b_dev);
2854744Swnj 	ui = tjdinfo[tjunit];
2864744Swnj 	sc = &tj_softc[tjunit];
2874744Swnj 	/* note slave select, density, and format were merged on open */
2884746Ssam 	addr->uttc = sc->sc_dens;
2894746Ssam 	sc->sc_dsreg = addr->utds;
2904746Ssam 	sc->sc_erreg = addr->uter;
2914746Ssam 	/* watch this, sports fans */
2924746Ssam 	sc->sc_resid = bp->b_flags&B_READ ?
2934746Ssam 		bp->b_bcount - ((-addr->utfc)&0xffff) : -addr->utwc<<1;
2944744Swnj 	/*
2954744Swnj 	 * Default is that last command was NOT a write command;
2964744Swnj 	 * if we do a write command we will notice this in utintr().
2974744Swnj 	 */
2984744Swnj 	sc->sc_lastiow = 0;
2994746Ssam 	if (sc->sc_openf < 0 || (addr->utds&UTDS_MOL) == 0) {
3004744Swnj 		/*
3014744Swnj 		 * Have had a hard error on a non-raw tape
3024744Swnj 		 * or the tape unit is now unavailable
3034744Swnj 		 * (e.g. taken off line).
3044744Swnj 		 */
3054744Swnj 		bp->b_flags |= B_ERROR;
3064744Swnj 		goto next;
3074744Swnj 	}
3084744Swnj 	if (bp == &cutbuf[UTUNIT(bp->b_dev)]) {
3094744Swnj 		/*
3104744Swnj 		 * Execute a control operation with the specified
3114744Swnj 		 * count.
3124744Swnj 		 */
3134744Swnj 		if (bp->b_command == UT_SENSE)
3144744Swnj 			goto next;
3154744Swnj 		/*
3164744Swnj 		 * Set next state; handle timeouts
3174744Swnj 		 */
3184833Swnj 		if (bp->b_command == UT_REW) {
3194746Ssam 			um->um_tab.b_state = SREW;
3204833Swnj 			sc->sc_timo = 5*60;
3214833Swnj 		} else {
3224746Ssam 			um->um_tab.b_state = SCOM;
3234833Swnj 			sc->sc_timo = imin(imax(10*(int)-bp->b_repcnt,60),5*60);
3244833Swnj 		}
3254744Swnj 		/* NOTE: this depends on the ut command values */
3264744Swnj 		if (bp->b_command >= UT_SFORW && bp->b_command <= UT_SREVF)
3274746Ssam 			addr->utfc = -bp->b_repcnt;
3284744Swnj 		goto dobpcmd;
3294744Swnj 	}
3304744Swnj 	/*
3314744Swnj 	 * The following checks boundary conditions for operations
3324744Swnj 	 * on non-raw tapes.  On raw tapes the initialization of
3334744Swnj 	 * sc->sc_nxrec by utphys causes them to be skipped normally
3344744Swnj 	 * (except in the case of retries).
3354744Swnj 	 */
3364744Swnj 	if (dbtofsb(bp->b_blkno) > sc->sc_nxrec) {
3374744Swnj 		/* can't read past end of file */
3384744Swnj 		bp->b_flags |= B_ERROR;
3394744Swnj 		bp->b_error = ENXIO;
3404744Swnj 		goto next;
3414744Swnj 	}
3424744Swnj 	if (dbtofsb(bp->b_blkno) == sc->sc_nxrec && (bp->b_flags&B_READ)) {
3434744Swnj 		/* read at eof returns 0 count */
3444744Swnj 		bp->b_resid = bp->b_bcount;
3454744Swnj 		clrbuf(bp);
3464744Swnj 		goto next;
3474744Swnj 	}
3484744Swnj 	if ((bp->b_flags&B_READ) == 0)
3494744Swnj 		sc->sc_nxrec = dbtofsb(bp->b_blkno)+1;
3504744Swnj 	/*
3514744Swnj 	 * If the tape is correctly positioned, set up all the
3524744Swnj 	 * registers but the csr, and give control over to the
3534744Swnj 	 * UNIBUS adaptor routines, to wait for resources to
3544744Swnj 	 * start I/O.
3554744Swnj 	 */
3564744Swnj 	if ((blkno = sc->sc_blkno) == dbtofsb(bp->b_blkno)) {
3574746Ssam 		addr->utwc = -(((bp->b_bcount)+1)>>1);
3584746Ssam 		addr->utfc = -bp->b_bcount;
3594744Swnj 		if ((bp->b_flags&B_READ) == 0) {
3604744Swnj 			/*
3614744Swnj 			 * On write error retries erase the
3624746Ssam 			 * inter-record gap before rewriting.
3634744Swnj 			 */
3644746Ssam 			if (um->um_tab.b_errcnt) {
3654746Ssam 				if (um->um_tab.b_state != SERASED) {
3664759Swnj 					um->um_tab.b_state = SERASE;
3674833Swnj 					sc->sc_timo = 60;
3684746Ssam 					addr->utcs1 = UT_ERASE|UT_IE|UT_GO;
3694746Ssam 					return;
3704746Ssam 				}
3714746Ssam 			}
3724746Ssam 			um->um_cmd = UT_WCOM;
3734744Swnj 		} else
3744744Swnj 			um->um_cmd = UT_RCOM;
3754833Swnj 		sc->sc_timo = 60;
3764746Ssam 		um->um_tab.b_state = SIO;
3774744Swnj 		(void) ubago(ui);
3784744Swnj 		return;
3794744Swnj 	}
3804744Swnj 	/*
3814744Swnj 	 * Tape positioned incorrectly; seek forwards or
3824744Swnj 	 * backwards to the correct spot.  This happens for
3834744Swnj 	 * raw tapes only on error retries.
3844744Swnj 	 */
3854746Ssam 	um->um_tab.b_state = SSEEK;
3864744Swnj 	if (blkno < dbtofsb(bp->b_blkno)) {
3874746Ssam 		addr->utfc = blkno - dbtofsb(bp->b_blkno);
3884744Swnj 		bp->b_command = UT_SFORW;
3894744Swnj 	} else {
3904746Ssam 		addr->utfc = dbtofsb(bp->b_blkno) - blkno;
3914744Swnj 		bp->b_command = UT_SREV;
3924744Swnj 	}
3934833Swnj 	sc->sc_timo = imin(imax(10 * -addr->utfc, 60), 5*60);
3944744Swnj 
3954744Swnj dobpcmd:
3964744Swnj 	/*
3974744Swnj 	 * Perform the command setup in bp.
3984744Swnj 	 */
3994746Ssam 	addr->utcs1 = bp->b_command|UT_IE|UT_GO;
4004744Swnj 	return;
4014744Swnj next:
4024744Swnj 	/*
4034744Swnj 	 * Advance to the next command in the slave queue,
4044744Swnj 	 * posting notice and releasing resources as needed.
4054744Swnj 	 */
4064744Swnj 	if (um->um_ubinfo)
4074744Swnj 		ubadone(um);
4084744Swnj 	um->um_tab.b_errcnt = 0;
4094744Swnj 	dp->b_actf = bp->av_forw;
4104744Swnj 	iodone(bp);
4114744Swnj 	goto loop;
4124744Swnj }
4134744Swnj 
4144744Swnj /*
4154744Swnj  * Start operation on controller --
4164744Swnj  * UNIBUS resources have been allocated.
4174744Swnj  */
4184744Swnj utdgo(um)
4194744Swnj 	register struct uba_ctlr *um;
4204744Swnj {
4214744Swnj 	register struct utdevice *addr = (struct utdevice *)um->um_addr;
4224744Swnj 
4234744Swnj 	addr->utba = (u_short) um->um_ubinfo;
4244744Swnj 	addr->utcs1 = um->um_cmd|((um->um_ubinfo>>8)&0x30)|UT_IE|UT_GO;
4254744Swnj }
4264744Swnj 
4274744Swnj /*
4284744Swnj  * Ut interrupt handler
4294744Swnj  */
4304744Swnj /*ARGSUSED*/
4314744Swnj utintr(ut11)
4324744Swnj 	int ut11;
4334744Swnj {
4344744Swnj 	struct buf *dp;
4354744Swnj 	register struct buf *bp;
4364744Swnj 	register struct uba_ctlr *um = utminfo[ut11];
4374744Swnj 	register struct utdevice *addr;
4384744Swnj 	register struct tj_softc *sc;
4394746Ssam 	u_short tjunit, cs2, cs1;
4404744Swnj 	register state;
4414744Swnj 
4424744Swnj 	if ((dp = um->um_tab.b_actf) == NULL)
4434744Swnj 		return;
4444744Swnj 	bp = dp->b_actf;
4454744Swnj 	tjunit = TJUNIT(bp->b_dev);
4464744Swnj 	addr = (struct utdevice *)tjdinfo[tjunit]->ui_addr;
4474744Swnj 	sc = &tj_softc[tjunit];
4484744Swnj 	/*
4494744Swnj 	 * Record status...
4504744Swnj 	 */
4514877Ssam 	sc->sc_timo = INF;
4524744Swnj 	sc->sc_dsreg = addr->utds;
4534744Swnj 	sc->sc_erreg = addr->uter;
4544746Ssam 	sc->sc_resid = bp->b_flags&B_READ ?
4554746Ssam 		bp->b_bcount - (-addr->utfc)&0xffff : -addr->utwc<<1;
4564746Ssam 	if ((bp->b_flags&B_READ) == 0)
4574744Swnj 		sc->sc_lastiow = 1;
4584746Ssam 	state = um->um_tab.b_state;
4594746Ssam 	um->um_tab.b_state = 0;
4604744Swnj 	/*
4614744Swnj 	 * Check for errors...
4624744Swnj 	 */
4634744Swnj 	if ((addr->utds&UTDS_ERR) || (addr->utcs1&UT_TRE)) {
4644744Swnj 		/*
4654759Swnj 		 * To clear the ERR bit, we must issue a drive clear
4664759Swnj 		 * command, and to clear the TRE bit we must set the
4674759Swnj 		 * controller clear bit.
4684759Swnj 		 */
4694759Swnj 		cs2 = addr->utcs2;
4704759Swnj 		if ((cs1 = addr->utcs1)&UT_TRE)
4714759Swnj 			addr->utcs2 |= UTCS2_CLR;
4724759Swnj 		/* is this dangerous ?? */
4734759Swnj 		while ((addr->utcs1&UT_RDY) == 0)
4744759Swnj 			;
4754759Swnj 		addr->utcs1 = UT_CLEAR|UT_GO;
4764759Swnj 		/*
4774746Ssam 		 * If we hit a tape mark or EOT update our position.
4784744Swnj 		 */
4794759Swnj 		if (sc->sc_dsreg&(UTDS_TM|UTDS_EOT)) {
4804744Swnj 			/*
4814759Swnj 			 * Set blkno and nxrec
4824744Swnj 			 */
4834744Swnj 			if (bp == &cutbuf[UTUNIT(bp->b_dev)]) {
4844744Swnj 				if (sc->sc_blkno > dbtofsb(bp->b_blkno)) {
4854744Swnj 					sc->sc_nxrec =
4864744Swnj 					      dbtofsb(bp->b_blkno) - addr->utfc;
4874744Swnj 					sc->sc_blkno = sc->sc_nxrec;
4884744Swnj 				} else {
4894744Swnj 					sc->sc_blkno =
4904744Swnj 					      dbtofsb(bp->b_blkno) + addr->utfc;
4914744Swnj 					sc->sc_nxrec = sc->sc_blkno-1;
4924744Swnj 				}
4934746Ssam 			} else
4944744Swnj 				sc->sc_nxrec = dbtofsb(bp->b_blkno);
4954744Swnj 			state = SCOM;		/* force completion */
4964744Swnj 			/*
4974746Ssam 			 * Stuff so we can unstuff later
4984746Ssam 			 * to get the residual.
4994744Swnj 			 */
5004746Ssam 			addr->utwc = (-bp->b_bcount)>>1;
5014744Swnj 			addr->utfc = -bp->b_bcount;
5024746Ssam 			if (sc->sc_dsreg&UTDS_EOT)
5034746Ssam 				goto harderror;
5044744Swnj 			goto opdone;
5054744Swnj 		}
5064744Swnj 		/*
5074744Swnj 		 * If we were reading from a raw tape and the only error
5084744Swnj 		 * was that the record was too long, then we don't consider
5094744Swnj 		 * this an error.
5104744Swnj 		 */
5114744Swnj 		if (bp == &rutbuf[UTUNIT(bp->b_dev)] && (bp->b_flags&B_READ) &&
5124744Swnj 		    (sc->sc_erreg&UTER_FCE))
5134744Swnj 			goto ignoreerr;
5144744Swnj 		/*
5154746Ssam 		 * Fix up errors which occur due to backspacing "over" the
5164746Ssam 		 * front of the tape.
5174746Ssam 		 */
5184746Ssam 		if ((sc->sc_dsreg&UTDS_BOT) &&
5194746Ssam 		    (bp->b_command == UT_SREV || bp->b_command == UT_SREV) &&
5204746Ssam 		    ((sc->sc_erreg &= ~(UTER_NEF|UTER_FCE)) == 0))
5214746Ssam 			goto opdone;
5224746Ssam 		/*
5234744Swnj 		 * Retry soft errors up to 8 times
5244744Swnj 		 */
5254744Swnj 		if ((sc->sc_erreg&UTER_HARD) == 0 && state == SIO) {
5264744Swnj 			if (++um->um_tab.b_errcnt < 7) {
5274744Swnj 				sc->sc_blkno++;
5284744Swnj 				ubadone(um);
5294744Swnj 				goto opcont;
5304744Swnj 			}
5314744Swnj 		} else
5324746Ssam harderror:
5334744Swnj 			/*
5344744Swnj 			 * Hard or non-I/O errors on non-raw tape
5354746Ssam 			 * cause it to close; also, reading off the
5364746Ssam 			 * end of the tape.
5374744Swnj 			 */
5384746Ssam 			if (sc->sc_openf > 0 &&
5394746Ssam 			    bp != &rutbuf[UTUNIT(bp->b_dev)] ||
5404746Ssam 			    sc->sc_dsreg&UTDS_EOT)
5414744Swnj 				sc->sc_openf = -1;
5424744Swnj 		/*
5434744Swnj 		 * Couldn't recover error.
5444744Swnj 		 */
5454746Ssam 		printf("ut%d: hard error bn%d cs1=%b er=%b cs2=%b ds=%b\n",
5464746Ssam 			tjunit, bp->b_blkno, cs1, UT_BITS, sc->sc_erreg,
5474746Ssam 			UTER_BITS, cs2, UTCS2_BITS, sc->sc_dsreg, UTDS_BITS);
5484744Swnj 		bp->b_flags |= B_ERROR;
5494744Swnj 		goto opdone;
5504744Swnj 	}
5514744Swnj ignoreerr:
5524744Swnj 	/*
5534744Swnj 	 * Advance tape control FSM.
5544744Swnj 	 */
5554744Swnj 	switch (state) {
5564744Swnj 
5574744Swnj 	case SIO:		/* read/write increments tape block # */
5584744Swnj 		sc->sc_blkno++;
5594746Ssam 		break;
5604744Swnj 
5614744Swnj 	case SCOM:		/* forw/rev space updates current position */
5624744Swnj 		if (bp == &cutbuf[UTUNIT(bp->b_dev)])
5634744Swnj 		switch (bp->b_command) {
5644744Swnj 
5654744Swnj 		case UT_SFORW:
5664744Swnj 			sc->sc_blkno -= bp->b_repcnt;
5674744Swnj 			break;
5684744Swnj 
5694744Swnj 		case UT_SREV:
5704744Swnj 			sc->sc_blkno += bp->b_repcnt;
5714744Swnj 			break;
5724744Swnj 		}
5734746Ssam 		break;
5744744Swnj 
5754744Swnj 	case SSEEK:
5764744Swnj 		sc->sc_blkno = dbtofsb(bp->b_blkno);
5774744Swnj 		goto opcont;
5784744Swnj 
5794746Ssam 	case SERASE:
5804746Ssam 		/*
5814746Ssam 		 * Completed erase of the inter-record gap due to a
5824746Ssam 		 * write error; now retry the write operation.
5834746Ssam 		 */
5844746Ssam 		um->um_tab.b_state = SERASED;
5854746Ssam 		goto opcont;
5864746Ssam 
5874746Ssam 	case SREW:			/* clear attention bit */
5884746Ssam 		addr->utcs1 = UT_CLEAR|UT_GO;
5894746Ssam 		break;
5904746Ssam 
5914744Swnj 	default:
5924746Ssam 		printf("bad state %d\n", state);
5934744Swnj 		panic("utintr");
5944744Swnj 	}
5954744Swnj 
5964744Swnj opdone:
5974744Swnj 	/*
5984744Swnj 	 * Reset error count and remove
5994744Swnj 	 * from device queue
6004744Swnj 	 */
6014744Swnj 	um->um_tab.b_errcnt = 0;
6024746Ssam 	dp->b_actf = bp->av_forw;
6034746Ssam 	bp->b_resid = bp->b_command&B_READ ?
6044746Ssam 		bp->b_bcount - ((-addr->utfc)&0xffff) : -addr->utwc<<1;
6054744Swnj 	ubadone(um);
6064744Swnj 	iodone(bp);
6074744Swnj 	/*
6084744Swnj 	 * Circulate slave to end of controller queue
6094744Swnj 	 * to give other slaves a chance
6104744Swnj 	 */
6114744Swnj 	um->um_tab.b_actf = dp->b_forw;
6124744Swnj 	if (dp->b_actf) {
6134744Swnj 		dp->b_forw = NULL;
6144744Swnj 		if (um->um_tab.b_actf == NULL)
6154744Swnj 			um->um_tab.b_actf = dp;
6164744Swnj 		else
6174744Swnj 			um->um_tab.b_actl->b_forw = dp;
6184744Swnj 		um->um_tab.b_actl = dp;
6194744Swnj 	}
6204744Swnj 	if (um->um_tab.b_actf == 0)
6214744Swnj 		return;
6224744Swnj opcont:
6234744Swnj 	utstart(um);
6244744Swnj }
6254744Swnj 
6264744Swnj /*
6274833Swnj  * Watchdog timer routine.
6284833Swnj  */
6294833Swnj uttimer(dev)
6304833Swnj 	int dev;
6314833Swnj {
6324833Swnj 	register struct tj_softc *sc = &tj_softc[TJUNIT(dev)];
6334846Sroot 	register short x;
6344833Swnj 
6354833Swnj 	if (sc->sc_timo != INF && (sc->sc_timo -= 5) < 0) {
6364859Ssam 		printf("tj%d: lost interrupt\n", TJUNIT(dev));
6374833Swnj 		sc->sc_timo = INF;
6384846Sroot 		x = spl5();
6394833Swnj 		utintr(UTUNIT(dev));
6404846Sroot 		(void) splx(x);
6414833Swnj 	}
6424833Swnj 	timeout(uttimer, (caddr_t)dev, 5*hz);
6434833Swnj }
6444833Swnj 
6454833Swnj /*
6464744Swnj  * Raw interface for a read
6474744Swnj  */
6484744Swnj utread(dev)
6494744Swnj 	dev_t dev;
6504744Swnj {
6514744Swnj 	utphys(dev);
6524744Swnj 	if (u.u_error)
6534744Swnj 		return;
6544744Swnj 	physio(utstrategy, &rutbuf[UTUNIT(dev)], dev, B_READ, minphys);
6554744Swnj }
6564744Swnj 
6574744Swnj /*
6584744Swnj  * Raw interface for a write
6594744Swnj  */
6604744Swnj utwrite(dev)
6614744Swnj {
6624744Swnj 	utphys(dev);
6634744Swnj 	if (u.u_error)
6644744Swnj 		return;
6654744Swnj 	physio(utstrategy, &rutbuf[UTUNIT(dev)], dev, B_WRITE, minphys);
6664744Swnj }
6674744Swnj 
6684744Swnj /*
6694744Swnj  * Check for valid device number dev and update our notion
6704744Swnj  * of where we are on the tape
6714744Swnj  */
6724744Swnj utphys(dev)
6734744Swnj 	dev_t dev;
6744744Swnj {
6754744Swnj 	register int tjunit = TJUNIT(dev);
6764744Swnj 	register struct tj_softc *sc;
6774744Swnj 	register struct uba_device *ui;
6784744Swnj 
6794744Swnj 	if (tjunit >= NTJ || (ui=tjdinfo[tjunit]) == 0 || ui->ui_alive == 0) {
6804744Swnj 		u.u_error = ENXIO;
6814744Swnj 		return;
6824744Swnj 	}
6834744Swnj 	sc = &tj_softc[tjunit];
6844746Ssam 	sc->sc_blkno = dbtofsb(u.u_offset>>9);
6854746Ssam 	sc->sc_nxrec = sc->sc_blkno+1;
6864744Swnj }
6874744Swnj 
6884744Swnj /*ARGSUSED*/
6894744Swnj utioctl(dev, cmd, addr, flag)
6904744Swnj 	dev_t dev;
6914744Swnj 	caddr_t addr;
6924744Swnj {
6934744Swnj 	register struct tj_softc *sc = &tj_softc[TJUNIT(dev)];
6944744Swnj 	register struct buf *bp = &cutbuf[UTUNIT(dev)];
6954744Swnj 	register callcount;
6964744Swnj 	int fcount;
6974744Swnj 	struct mtop mtop;
6984744Swnj 	struct mtget mtget;
6994744Swnj 	/* we depend of the values and order of the MT codes here */
7004744Swnj 	static utops[] =
7014744Swnj       {UT_WEOF,UT_SFORWF,UT_SREVF,UT_SFORW,UT_SREV,UT_REW,UT_REWOFFL,UT_SENSE};
7024744Swnj 
7034744Swnj 	switch (cmd) {
7044744Swnj 
7054744Swnj 	case MTIOCTOP:
7064744Swnj 		if (copyin((caddr_t)addr, (caddr_t)&mtop, sizeof(mtop))) {
7074744Swnj 			u.u_error = EFAULT;
7084744Swnj 			return;
7094744Swnj 		}
7104744Swnj 		switch(mtop.mt_op) {
7114744Swnj 
7124744Swnj 		case MTWEOF:
7134744Swnj 			callcount = mtop.mt_count;
7144744Swnj 			fcount = 1;
7154744Swnj 			break;
7164744Swnj 
7174744Swnj 		case MTFSF: case MTBSF:
7184744Swnj 		case MTFSR: case MTBSR:
7194744Swnj 			callcount = 1;
7204744Swnj 			fcount = mtop.mt_count;
7214744Swnj 			break;
7224744Swnj 
7234744Swnj 		case MTREW: case MTOFFL: case MTNOP:
7244744Swnj 			callcount = 1;
7254744Swnj 			fcount = 1;
7264744Swnj 			break;
7274744Swnj 
7284744Swnj 		default:
7294744Swnj 			u.u_error = ENXIO;
7304744Swnj 			return;
7314744Swnj 		}
7324744Swnj 		if (callcount <= 0 || fcount <= 0) {
7334744Swnj 			u.u_error = ENXIO;
7344744Swnj 			return;
7354744Swnj 		}
7364744Swnj 		while (--callcount >= 0) {
7374744Swnj 			utcommand(dev, utops[mtop.mt_op], fcount);
7384746Ssam 			/* note this depends on the mtop values */
7394746Ssam 			if ((mtop.mt_op >= MTFSF || mtop.mt_op <= MTBSR) &&
7404744Swnj 			    bp->b_resid) {
7414744Swnj 				u.u_error = EIO;
7424744Swnj 				break;
7434744Swnj 			}
7444744Swnj 			if ((bp->b_flags&B_ERROR) || (sc->sc_dsreg&UTDS_BOT))
7454744Swnj 				break;
7464744Swnj 		}
7474744Swnj 		geterror(bp);
7484744Swnj 		return;
7494744Swnj 
7504744Swnj 	case MTIOCGET:
7514744Swnj 		mtget.mt_dsreg = sc->sc_dsreg;
7524744Swnj 		mtget.mt_erreg = sc->sc_erreg;
7534744Swnj 		mtget.mt_resid = sc->sc_resid;
7544744Swnj 		mtget.mt_type = MT_ISUT;
7554744Swnj 		if (copyout((caddr_t)&mtget, addr, sizeof(mtget)))
7564744Swnj 			u.u_error = EFAULT;
7574744Swnj 		return;
7584744Swnj 
7594744Swnj 	default:
7604744Swnj 		u.u_error = ENXIO;
7614744Swnj 	}
7624744Swnj }
7634744Swnj 
7644744Swnj utreset(uban)
7654744Swnj 	int uban;
7664744Swnj {
7674744Swnj 	register struct uba_ctlr *um;
7684744Swnj 	register ut11, tjunit;
7694744Swnj 	register struct uba_device *ui;
7704744Swnj 	register struct buf *dp;
7714744Swnj 
7724744Swnj 	for (ut11 = 0; ut11 < NUT; ut11++) {
7734744Swnj 		if ((um = utminfo[ut11]) == 0 || um->um_alive == 0 ||
7744744Swnj 		   um->um_ubanum != uban)
7754744Swnj 			continue;
7764744Swnj 		printf(" ut%d", ut11);
7774746Ssam 		um->um_tab.b_state = 0;
7784744Swnj 		um->um_tab.b_actf = um->um_tab.b_actl = 0;
7794744Swnj 		if (um->um_ubinfo) {
7804744Swnj 			printf("<%d>", (um->um_ubinfo>>28)&0xf);
7814744Swnj 			ubadone(um);
7824744Swnj 		}
7834744Swnj 		((struct utdevice *)(um->um_addr))->utcs1 = UT_CLEAR|UT_GO;
7844746Ssam 		((struct utdevice *)(um->um_addr))->utcs2 |= UTCS2_CLR;
7854744Swnj 		for (tjunit = 0; tjunit < NTJ; tjunit++) {
7864744Swnj 			if ((ui = tjdinfo[tjunit]) == 0 || ui->ui_mi != um ||
7874744Swnj 			    ui->ui_alive == 0)
7884744Swnj 				continue;
7894744Swnj 			dp = &tjutab[tjunit];
7904746Ssam 			dp->b_state = 0;
7914744Swnj 			dp->b_forw = 0;
7924744Swnj 			if (um->um_tab.b_actf == NULL)
7934744Swnj 				um->um_tab.b_actf = dp;
7944744Swnj 			else
7954744Swnj 				um->um_tab.b_actl->b_forw = dp;
7964744Swnj 			um->um_tab.b_actl = dp;
7974744Swnj 			if (tj_softc[tjunit].sc_openf > 0)
7984744Swnj 				tj_softc[tjunit].sc_openf = -1;
7994744Swnj 		}
8004744Swnj 		utstart(um);
8014744Swnj 	}
8024744Swnj }
8034744Swnj 
8044744Swnj /*
8054744Swnj  * Do a stand-alone core dump to tape --
8064744Swnj  * from here down, routines are used only in dump context
8074744Swnj  */
8084744Swnj #define	DBSIZE	20
8094744Swnj 
8104744Swnj utdump()
8114744Swnj {
8124744Swnj 	register struct uba_device *ui;
8134744Swnj 	register struct uba_regs *up;
8144746Ssam 	register struct utdevice *addr;
8154744Swnj 	int blk, num = maxfree;
8164744Swnj 	int start = 0;
8174744Swnj 
8184744Swnj #define	phys(a,b)		((b)((int)(a)&0x7fffffff))
8194744Swnj 	if (tjdinfo[0] == 0)
8204744Swnj 		return (ENXIO);
8214744Swnj 	ui = phys(tjdinfo[0], struct uba_device *);
8224744Swnj 	up = phys(ui->ui_hd, struct uba_hd *)->uh_physuba;
8234941Swnj 	ubainit(up);
8244744Swnj 	DELAY(1000000);
8254941Swnj 	addr = (struct utdevice *)ui->ui_physaddr;
8264746Ssam 	utwait(addr);
8274746Ssam 	/*
8284746Ssam 	 * Be sure to set the appropriate density here.  We use
8294746Ssam 	 * 6250, but maybe it should be done at 1600 to insure the
8304746Ssam 	 * tape can be read by most any other tape drive available.
8314746Ssam 	 */
8324746Ssam 	addr->uttc = UT_GCR|PDP11FMT;	/* implicit slave 0 or-ed in */
8334746Ssam 	addr->utcs1 = UT_CLEAR|UT_GO;
8344744Swnj 	while (num > 0) {
8354744Swnj 		blk = num > DBSIZE ? DBSIZE : num;
8364746Ssam 		utdwrite(start, blk, addr, up);
8374746Ssam 		if ((addr->utds&UTDS_ERR) || (addr->utcs1&UT_TRE))
8384746Ssam 			return(EIO);
8394744Swnj 		start += blk;
8404744Swnj 		num -= blk;
8414744Swnj 	}
8424746Ssam 	uteof(addr);
8434746Ssam 	uteof(addr);
8444746Ssam 	utwait(addr);
8454746Ssam 	if ((addr->utds&UTDS_ERR) || (addr->utcs1&UT_TRE))
8464744Swnj 		return(EIO);
8474746Ssam 	addr->utcs1 = UT_REW|UT_GO;
8484744Swnj 	return (0);
8494744Swnj }
8504744Swnj 
8514746Ssam utdwrite(dbuf, num, addr, up)
8524744Swnj 	register dbuf, num;
8534746Ssam 	register struct utdevice *addr;
8544744Swnj 	struct uba_regs *up;
8554744Swnj {
8564744Swnj 	register struct pte *io;
8574744Swnj 	register int npf;
8584744Swnj 
8594746Ssam 	utwait(addr);
8604744Swnj 	io = up->uba_map;
8614744Swnj 	npf = num + 1;
8624744Swnj 	while (--npf != 0)
8634744Swnj 		*(int *)io++ = (dbuf++ | (1<<UBAMR_DPSHIFT) | UBAMR_MRV);
8644744Swnj 	*(int *)io = 0;
8654746Ssam 	addr->utwc = -((num*NBPG)>>1);
8664746Ssam 	addr->utfc = -(num*NBPG);
8674746Ssam 	addr->utba = 0;
8684746Ssam 	addr->utcs1 = UT_WCOM|UT_GO;
8694744Swnj }
8704744Swnj 
8714746Ssam utwait(addr)
8724746Ssam 	struct utdevice *addr;
8734744Swnj {
8744744Swnj 	register s;
8754744Swnj 
8764744Swnj 	do
8774746Ssam 		s = addr->utds;
8784744Swnj 	while ((s&UTDS_DRY) == 0);
8794744Swnj }
8804744Swnj 
8814746Ssam uteof(addr)
8824746Ssam 	struct utdevice *addr;
8834744Swnj {
8844744Swnj 
8854746Ssam 	utwait(addr);
8864746Ssam 	addr->utcs1 = UT_WEOF|UT_GO;
8874744Swnj }
8884744Swnj #endif
889