fix typo so can handle more than one transport
[unix-history] / usr / src / sys / vax / uba / tm.c
CommitLineData
04b2deaa 1/* tm.c 4.48 82/05/27 */
d75e5c3e 2
443c8066 3#include "te.h"
23e0e9b8 4#include "ts.h"
2ac8d080 5#if NTE > 0
d75e5c3e 6/*
afb907f2 7 * TM11/TE10 tape driver
7e00c42b 8 *
d565635a
BJ
9 * TODO:
10 * test driver with more than one slave
11 * test driver with more than one controller
12 * test reset code
d565635a
BJ
13 * what happens if you offline tape during rewind?
14 * test using file system on tape
d75e5c3e 15 */
d75e5c3e 16#include "../h/param.h"
27a897a2 17#include "../h/systm.h"
d75e5c3e
BJ
18#include "../h/buf.h"
19#include "../h/dir.h"
20#include "../h/conf.h"
21#include "../h/user.h"
22#include "../h/file.h"
23#include "../h/map.h"
24#include "../h/pte.h"
e4271c68 25#include "../h/vm.h"
89bd2f01
BJ
26#include "../h/ubareg.h"
27#include "../h/ubavar.h"
d75e5c3e
BJ
28#include "../h/mtio.h"
29#include "../h/ioctl.h"
7455bf3e 30#include "../h/cmap.h"
3f3a34c3 31#include "../h/cpu.h"
d75e5c3e 32
3f3a34c3 33#include "../h/tmreg.h"
d75e5c3e 34
d565635a
BJ
35/*
36 * There is a ctmbuf per tape controller.
37 * It is used as the token to pass to the internal routines
38 * to execute tape ioctls, and also acts as a lock on the slaves
39 * on the controller, since there is only one per controller.
40 * In particular, when the tape is rewinding on close we release
41 * the user process but any further attempts to use the tape drive
42 * before the rewind completes will hang waiting for ctmbuf.
43 */
44struct buf ctmbuf[NTM];
45
46/*
47 * Raw tape operations use rtmbuf. The driver
48 * notices when rtmbuf is being used and allows the user
49 * program to continue after errors and read records
50 * not of the standard length (BSIZE).
51 */
52struct buf rtmbuf[NTM];
d75e5c3e 53
d565635a
BJ
54/*
55 * Driver unibus interface routines and variables.
56 */
71236e46 57int tmprobe(), tmslave(), tmattach(), tmdgo(), tmintr();
89bd2f01 58struct uba_ctlr *tmminfo[NTM];
d565635a
BJ
59struct uba_device *tedinfo[NTE];
60struct buf teutab[NTE];
61short tetotm[NTE];
d763a2b7 62u_short tmstd[] = { 0772520, 0 };
3f3a34c3 63struct uba_driver tmdriver =
d565635a 64 { tmprobe, tmslave, tmattach, tmdgo, tmstd, "te", tedinfo, "tm", tmminfo, 0 };
d75e5c3e
BJ
65
66/* bits in minor device */
d565635a
BJ
67#define TEUNIT(dev) (minor(dev)&03)
68#define TMUNIT(dev) (tetotm[TEUNIT(dev)])
d75e5c3e
BJ
69#define T_NOREWIND 04
70#define T_1600BPI 08
71
72#define INF (daddr_t)1000000L
73
71236e46
BJ
74/*
75 * Software state per tape transport.
d565635a
BJ
76 *
77 * 1. A tape drive is a unique-open device; we refuse opens when it is already.
78 * 2. We keep track of the current position on a block tape and seek
79 * before operations by forward/back spacing if necessary.
80 * 3. We remember if the last operation was a write on a tape, so if a tape
81 * is open read write and the last thing done is a write we can
82 * write a standard end of tape mark (two eofs).
83 * 4. We remember the status registers after the last command, using
84 * then internally and returning them to the SENSE ioctl.
85 * 5. We remember the last density the tape was used at. If it is
86 * not a BOT when we start using it and we are writing, we don't
87 * let the density be changed.
71236e46 88 */
d565635a 89struct te_softc {
71236e46
BJ
90 char sc_openf; /* lock against multiple opens */
91 char sc_lastiow; /* last op was a write */
92 daddr_t sc_blkno; /* block number, for block device tape */
d565635a 93 daddr_t sc_nxrec; /* position of end of tape, if known */
71236e46
BJ
94 u_short sc_erreg; /* copy of last erreg */
95 u_short sc_dsreg; /* copy of last dsreg */
96 short sc_resid; /* copy of last bc */
a0eab615 97#ifdef unneeded
d1330646 98 short sc_lastcmd; /* last command to handle direction changes */
80905075 99#endif
d565635a 100 u_short sc_dens; /* prototype command with density info */
a752fee0
BJ
101 daddr_t sc_timo; /* time until timeout expires */
102 short sc_tact; /* timeout is active */
04b2deaa 103} te_softc[NTE];
a0eab615
BJ
104#ifdef unneeded
105int tmgapsdcnt; /* DEBUG */
106#endif
d75e5c3e 107
71236e46 108/*
d565635a
BJ
109 * States for um->um_tab.b_active, the per controller state flag.
110 * This is used to sequence control in the driver.
71236e46 111 */
d75e5c3e
BJ
112#define SSEEK 1 /* seeking */
113#define SIO 2 /* doing seq i/o */
114#define SCOM 3 /* sending control command */
71236e46 115#define SREW 4 /* sending a drive rewind */
d75e5c3e 116
5aa9d5ea
RE
117/*
118 * Determine if there is a controller for
119 * a tm at address reg. Our goal is to make the
120 * device interrupt.
5aa9d5ea 121 */
71236e46 122tmprobe(reg)
3f3a34c3
BJ
123 caddr_t reg;
124{
d565635a 125 register int br, cvec; /* must be r11,r10; value-result */
5aa9d5ea 126
71236e46 127#ifdef lint
a0eab615 128 br = 0; cvec = br; br = cvec;
89b8a44c 129 tmintr(0);
71236e46 130#endif
a870f835 131 ((struct tmdevice *)reg)->tmcs = TM_IE;
3f3a34c3 132 /*
afb907f2 133 * If this is a tm11, it ought to have interrupted
3f3a34c3 134 * by now, if it isn't (ie: it is a ts04) then we just
d763a2b7
BJ
135 * hope that it didn't interrupt, so autoconf will ignore it.
136 * Just in case, we will reference one
3f3a34c3 137 * of the more distant registers, and hope for a machine
d763a2b7 138 * check, or similar disaster if this is a ts.
7e00c42b
BJ
139 *
140 * Note: on an 11/780, badaddr will just generate
141 * a uba error for a ts; but our caller will notice that
142 * so we won't check for it.
3f3a34c3 143 */
a870f835 144 if (badaddr((caddr_t)&((struct tmdevice *)reg)->tmrd, 2))
d763a2b7
BJ
145 return (0);
146 return (1);
3f3a34c3
BJ
147}
148
71236e46
BJ
149/*
150 * Due to a design flaw, we cannot ascertain if the tape
151 * exists or not unless it is on line - ie: unless a tape is
152 * mounted. This is too servere a restriction to bear,
153 * so all units are assumed to exist.
154 */
155/*ARGSUSED*/
e4271c68 156tmslave(ui, reg)
89bd2f01 157 struct uba_device *ui;
3f3a34c3
BJ
158 caddr_t reg;
159{
d763a2b7 160
d763a2b7 161 return (1);
3f3a34c3
BJ
162}
163
71236e46 164/*
d565635a 165 * Record attachment of the unit to the controller.
71236e46
BJ
166 */
167/*ARGSUSED*/
168tmattach(ui)
89bd2f01 169 struct uba_device *ui;
71236e46 170{
d565635a
BJ
171 /*
172 * Tetotm is used in TMUNIT to index the ctmbuf and rtmbuf
173 * arrays given a te unit number.
174 */
175 tetotm[ui->ui_unit] = ui->ui_mi->um_ctlr;
71236e46
BJ
176}
177
a752fee0 178int tmtimer();
71236e46
BJ
179/*
180 * Open the device. Tapes are unique open
181 * devices, so we refuse if it is already open.
182 * We also check that a tape is available, and
d565635a
BJ
183 * don't block waiting here; if you want to wait
184 * for a tape you should timeout in user code.
71236e46 185 */
d75e5c3e
BJ
186tmopen(dev, flag)
187 dev_t dev;
188 int flag;
189{
d565635a 190 register int teunit;
89bd2f01 191 register struct uba_device *ui;
d565635a 192 register struct te_softc *sc;
971424d9 193 int olddens, dens;
2311123d 194 int s;
d75e5c3e 195
d565635a
BJ
196 teunit = TEUNIT(dev);
197 if (teunit>=NTE || (sc = &te_softc[teunit])->sc_openf ||
198 (ui = tedinfo[teunit]) == 0 || ui->ui_alive == 0) {
71236e46 199 u.u_error = ENXIO;
d75e5c3e
BJ
200 return;
201 }
971424d9
BJ
202 olddens = sc->sc_dens;
203 dens = TM_IE | TM_GO | (ui->ui_slave << 8);
204 if ((minor(dev) & T_1600BPI) == 0)
205 dens |= TM_D800;
206 sc->sc_dens = dens;
27a897a2 207get:
71236e46 208 tmcommand(dev, TM_SENSE, 1);
27a897a2
BJ
209 if (sc->sc_erreg&TMER_SDWN) {
210 sleep((caddr_t)&lbolt, PZERO+1);
211 goto get;
212 }
971424d9 213 sc->sc_dens = olddens;
a1706887
BJ
214 if ((sc->sc_erreg&(TMER_SELR|TMER_TUR)) != (TMER_SELR|TMER_TUR)) {
215 uprintf("te%d: not online\n", teunit);
216 u.u_error = EIO;
217 return;
218 }
219 if ((flag&FWRITE) && (sc->sc_erreg&TMER_WRL)) {
220 uprintf("te%d: no write ring\n", teunit);
221 u.u_error = EIO;
222 return;
223 }
224 if ((sc->sc_erreg&TMER_BOT) == 0 && (flag&FWRITE) &&
225 dens != sc->sc_dens) {
226 uprintf("te%d: can't change density in mid-tape\n", teunit);
71236e46 227 u.u_error = EIO;
d75e5c3e
BJ
228 return;
229 }
71236e46 230 sc->sc_openf = 1;
7e00c42b
BJ
231 sc->sc_blkno = (daddr_t)0;
232 sc->sc_nxrec = INF;
71236e46 233 sc->sc_lastiow = 0;
d565635a 234 sc->sc_dens = dens;
2311123d 235 s = spl6();
a752fee0
BJ
236 if (sc->sc_tact == 0) {
237 sc->sc_timo = INF;
238 sc->sc_tact = 1;
c27ba986 239 timeout(tmtimer, (caddr_t)dev, 5*hz);
a752fee0 240 }
2311123d 241 splx(s);
d75e5c3e
BJ
242}
243
71236e46
BJ
244/*
245 * Close tape device.
246 *
247 * If tape was open for writing or last operation was
248 * a write, then write two EOF's and backspace over the last one.
249 * Unless this is a non-rewinding special file, rewind the tape.
250 * Make the tape available to others.
251 */
d75e5c3e
BJ
252tmclose(dev, flag)
253 register dev_t dev;
254 register flag;
255{
d565635a 256 register struct te_softc *sc = &te_softc[TEUNIT(dev)];
d75e5c3e 257
71236e46
BJ
258 if (flag == FWRITE || (flag&FWRITE) && sc->sc_lastiow) {
259 tmcommand(dev, TM_WEOF, 1);
260 tmcommand(dev, TM_WEOF, 1);
261 tmcommand(dev, TM_SREV, 1);
d75e5c3e
BJ
262 }
263 if ((minor(dev)&T_NOREWIND) == 0)
d565635a
BJ
264 /*
265 * 0 count means don't hang waiting for rewind complete
266 * rather ctmbuf stays busy until the operation completes
267 * preventing further opens from completing by
268 * preventing a TM_SENSE from completing.
269 */
270 tmcommand(dev, TM_REW, 0);
7e00c42b 271 sc->sc_openf = 0;
d75e5c3e
BJ
272}
273
71236e46
BJ
274/*
275 * Execute a command on the tape drive
276 * a specified number of times.
277 */
e4271c68 278tmcommand(dev, com, count)
d75e5c3e
BJ
279 dev_t dev;
280 int com, count;
281{
282 register struct buf *bp;
2311123d 283 register int s;
d75e5c3e 284
71236e46 285 bp = &ctmbuf[TMUNIT(dev)];
2311123d 286 s = spl5();
d75e5c3e 287 while (bp->b_flags&B_BUSY) {
d565635a
BJ
288 /*
289 * This special check is because B_BUSY never
290 * gets cleared in the non-waiting rewind case.
291 */
27a897a2 292 if (bp->b_repcnt == 0 && (bp->b_flags&B_DONE))
d565635a 293 break;
d75e5c3e
BJ
294 bp->b_flags |= B_WANTED;
295 sleep((caddr_t)bp, PRIBIO);
296 }
297 bp->b_flags = B_BUSY|B_READ;
2311123d 298 splx(s);
d75e5c3e
BJ
299 bp->b_dev = dev;
300 bp->b_repcnt = -count;
301 bp->b_command = com;
302 bp->b_blkno = 0;
303 tmstrategy(bp);
d565635a
BJ
304 /*
305 * In case of rewind from close, don't wait.
306 * This is the only case where count can be 0.
307 */
308 if (count == 0)
309 return;
d75e5c3e
BJ
310 iowait(bp);
311 if (bp->b_flags&B_WANTED)
312 wakeup((caddr_t)bp);
313 bp->b_flags &= B_ERROR;
314}
315
71236e46 316/*
d565635a 317 * Queue a tape operation.
71236e46 318 */
d75e5c3e
BJ
319tmstrategy(bp)
320 register struct buf *bp;
321{
d565635a 322 int teunit = TEUNIT(bp->b_dev);
89bd2f01 323 register struct uba_ctlr *um;
71236e46 324 register struct buf *dp;
2311123d 325 int s;
d75e5c3e 326
71236e46
BJ
327 /*
328 * Put transfer at end of unit queue
329 */
d565635a 330 dp = &teutab[teunit];
d75e5c3e 331 bp->av_forw = NULL;
2311123d 332 s = spl5();
06e2c4fb 333 um = tedinfo[teunit]->ui_mi;
71236e46
BJ
334 if (dp->b_actf == NULL) {
335 dp->b_actf = bp;
336 /*
337 * Transport not already active...
338 * put at end of controller queue.
339 */
340 dp->b_forw = NULL;
71236e46
BJ
341 if (um->um_tab.b_actf == NULL)
342 um->um_tab.b_actf = dp;
343 else
344 um->um_tab.b_actl->b_forw = dp;
345 um->um_tab.b_actl = dp;
346 } else
347 dp->b_actl->av_forw = bp;
348 dp->b_actl = bp;
349 /*
350 * If the controller is not busy, get
351 * it going.
352 */
353 if (um->um_tab.b_active == 0)
354 tmstart(um);
2311123d 355 splx(s);
d75e5c3e
BJ
356}
357
71236e46
BJ
358/*
359 * Start activity on a tm controller.
360 */
361tmstart(um)
89bd2f01 362 register struct uba_ctlr *um;
d75e5c3e 363{
71236e46 364 register struct buf *bp, *dp;
a870f835 365 register struct tmdevice *addr = (struct tmdevice *)um->um_addr;
d565635a 366 register struct te_softc *sc;
89bd2f01 367 register struct uba_device *ui;
d565635a 368 int teunit, cmd;
7e00c42b 369 daddr_t blkno;
d75e5c3e 370
71236e46
BJ
371 /*
372 * Look for an idle transport on the controller.
373 */
d75e5c3e 374loop:
71236e46 375 if ((dp = um->um_tab.b_actf) == NULL)
d75e5c3e 376 return;
71236e46
BJ
377 if ((bp = dp->b_actf) == NULL) {
378 um->um_tab.b_actf = dp->b_forw;
379 goto loop;
380 }
d565635a
BJ
381 teunit = TEUNIT(bp->b_dev);
382 ui = tedinfo[teunit];
71236e46
BJ
383 /*
384 * Record pre-transfer status (e.g. for TM_SENSE)
385 */
d565635a 386 sc = &te_softc[teunit];
a870f835 387 addr = (struct tmdevice *)um->um_addr;
71236e46 388 addr->tmcs = (ui->ui_slave << 8);
7e00c42b
BJ
389 sc->sc_dsreg = addr->tmcs;
390 sc->sc_erreg = addr->tmer;
391 sc->sc_resid = addr->tmbc;
71236e46
BJ
392 /*
393 * Default is that last command was NOT a write command;
394 * if we do a write command we will notice this in tmintr().
395 */
bc9da2ca 396 sc->sc_lastiow = 0;
71236e46
BJ
397 if (sc->sc_openf < 0 || (addr->tmcs&TM_CUR) == 0) {
398 /*
d565635a
BJ
399 * Have had a hard error on a non-raw tape
400 * or the tape unit is now unavailable
401 * (e.g. taken off line).
71236e46
BJ
402 */
403 bp->b_flags |= B_ERROR;
d75e5c3e
BJ
404 goto next;
405 }
d565635a
BJ
406 if (bp == &ctmbuf[TMUNIT(bp->b_dev)]) {
407 /*
408 * Execute control operation with the specified count.
409 */
71236e46
BJ
410 if (bp->b_command == TM_SENSE)
411 goto next;
a752fee0
BJ
412 /*
413 * Set next state; give 5 minutes to complete
414 * rewind, or 10 seconds per iteration (minimum 60
c27ba986 415 * seconds and max 5 minutes) to complete other ops.
a752fee0
BJ
416 */
417 if (bp->b_command == TM_REW) {
418 um->um_tab.b_active = SREW;
419 sc->sc_timo = 5 * 60;
420 } else {
421 um->um_tab.b_active = SCOM;
0218811c
BJ
422 sc->sc_timo =
423 imin(imax(10*(int)-bp->b_repcnt,60),5*60);
a752fee0 424 }
71236e46
BJ
425 if (bp->b_command == TM_SFORW || bp->b_command == TM_SREV)
426 addr->tmbc = bp->b_repcnt;
d1330646 427 goto dobpcmd;
71236e46 428 }
d565635a
BJ
429 /*
430 * The following checks handle boundary cases for operation
431 * on non-raw tapes. On raw tapes the initialization of
432 * sc->sc_nxrec by tmphys causes them to be skipped normally
433 * (except in the case of retries).
434 */
435 if (dbtofsb(bp->b_blkno) > sc->sc_nxrec) {
436 /*
437 * Can't read past known end-of-file.
438 */
439 bp->b_flags |= B_ERROR;
440 bp->b_error = ENXIO;
441 goto next;
442 }
443 if (dbtofsb(bp->b_blkno) == sc->sc_nxrec &&
444 bp->b_flags&B_READ) {
445 /*
446 * Reading at end of file returns 0 bytes.
447 */
448 bp->b_resid = bp->b_bcount;
449 clrbuf(bp);
450 goto next;
451 }
452 if ((bp->b_flags&B_READ) == 0)
453 /*
454 * Writing sets EOF
455 */
456 sc->sc_nxrec = dbtofsb(bp->b_blkno) + 1;
71236e46
BJ
457 /*
458 * If the data transfer command is in the correct place,
459 * set up all the registers except the csr, and give
460 * control over to the UNIBUS adapter routines, to
461 * wait for resources to start the i/o.
462 */
7e00c42b 463 if ((blkno = sc->sc_blkno) == dbtofsb(bp->b_blkno)) {
3f3a34c3 464 addr->tmbc = -bp->b_bcount;
d75e5c3e 465 if ((bp->b_flags&B_READ) == 0) {
7e00c42b 466 if (um->um_tab.b_errcnt)
d565635a 467 cmd = TM_WIRG;
d75e5c3e 468 else
d565635a 469 cmd = TM_WCOM;
d75e5c3e 470 } else
d565635a 471 cmd = TM_RCOM;
7e00c42b 472 um->um_tab.b_active = SIO;
d565635a 473 um->um_cmd = sc->sc_dens|cmd;
80905075 474#ifdef notdef
d1330646 475 if (tmreverseop(sc->sc_lastcmd))
d565635a 476 while (addr->tmer & TMER_SDWN)
d1330646 477 tmgapsdcnt++;
d1330646 478 sc->sc_lastcmd = TM_RCOM; /* will serve */
80905075 479#endif
a752fee0 480 sc->sc_timo = 60; /* premature, but should serve */
a0eab615 481 (void) ubago(ui);
d75e5c3e
BJ
482 return;
483 }
71236e46 484 /*
d565635a
BJ
485 * Tape positioned incorrectly;
486 * set to seek forwards or backwards to the correct spot.
487 * This happens for raw tapes only on error retries.
71236e46 488 */
7e00c42b 489 um->um_tab.b_active = SSEEK;
d75e5c3e 490 if (blkno < dbtofsb(bp->b_blkno)) {
d1330646 491 bp->b_command = TM_SFORW;
3f3a34c3 492 addr->tmbc = blkno - dbtofsb(bp->b_blkno);
d75e5c3e 493 } else {
d1330646 494 bp->b_command = TM_SREV;
3f3a34c3 495 addr->tmbc = dbtofsb(bp->b_blkno) - blkno;
d75e5c3e 496 }
c27ba986 497 sc->sc_timo = imin(imax(10 * -addr->tmbc, 60), 5 * 60);
d1330646 498dobpcmd:
80905075 499#ifdef notdef
d565635a
BJ
500 /*
501 * It is strictly necessary to wait for the tape
502 * to stop before changing directions, but the TC11
503 * handles this for us.
504 */
d1330646
BJ
505 if (tmreverseop(sc->sc_lastcmd) != tmreverseop(bp->b_command))
506 while (addr->tmer & TM_SDWN)
507 tmgapsdcnt++;
d1330646 508 sc->sc_lastcmd = bp->b_command;
80905075 509#endif
d565635a
BJ
510 /*
511 * Do the command in bp.
512 */
513 addr->tmcs = (sc->sc_dens | bp->b_command);
d75e5c3e
BJ
514 return;
515
516next:
71236e46
BJ
517 /*
518 * Done with this operation due to error or
519 * the fact that it doesn't do anything.
520 * Release UBA resources (if any), dequeue
521 * the transfer and continue processing this slave.
522 */
523 if (um->um_ubinfo)
0801d37f 524 ubadone(um);
71236e46
BJ
525 um->um_tab.b_errcnt = 0;
526 dp->b_actf = bp->av_forw;
d75e5c3e
BJ
527 iodone(bp);
528 goto loop;
529}
530
71236e46
BJ
531/*
532 * The UNIBUS resources we needed have been
533 * allocated to us; start the device.
534 */
e4271c68 535tmdgo(um)
89bd2f01 536 register struct uba_ctlr *um;
3f3a34c3 537{
a870f835 538 register struct tmdevice *addr = (struct tmdevice *)um->um_addr;
7e00c42b 539
e4271c68
BJ
540 addr->tmba = um->um_ubinfo;
541 addr->tmcs = um->um_cmd | ((um->um_ubinfo >> 12) & 0x30);
3f3a34c3
BJ
542}
543
71236e46
BJ
544/*
545 * Tm interrupt routine.
546 */
7e00c42b 547/*ARGSUSED*/
afb907f2
BJ
548tmintr(tm11)
549 int tm11;
d75e5c3e 550{
71236e46 551 struct buf *dp;
d75e5c3e 552 register struct buf *bp;
89bd2f01 553 register struct uba_ctlr *um = tmminfo[tm11];
a870f835 554 register struct tmdevice *addr;
d565635a
BJ
555 register struct te_softc *sc;
556 int teunit;
d75e5c3e
BJ
557 register state;
558
d565635a
BJ
559 if ((dp = um->um_tab.b_actf) == NULL)
560 return;
561 bp = dp->b_actf;
562 teunit = TEUNIT(bp->b_dev);
a870f835 563 addr = (struct tmdevice *)tedinfo[teunit]->ui_addr;
6a476a42 564 sc = &te_softc[teunit];
71236e46
BJ
565 /*
566 * If last command was a rewind, and tape is still
567 * rewinding, wait for the rewind complete interrupt.
568 */
569 if (um->um_tab.b_active == SREW) {
570 um->um_tab.b_active = SCOM;
6a476a42
BJ
571 if (addr->tmer&TMER_RWS) {
572 sc->sc_timo = 5*60; /* 5 minutes */
71236e46 573 return;
6a476a42 574 }
d75e5c3e 575 }
71236e46
BJ
576 /*
577 * An operation completed... record status
578 */
a752fee0 579 sc->sc_timo = INF;
7e00c42b
BJ
580 sc->sc_dsreg = addr->tmcs;
581 sc->sc_erreg = addr->tmer;
582 sc->sc_resid = addr->tmbc;
d75e5c3e 583 if ((bp->b_flags & B_READ) == 0)
71236e46 584 sc->sc_lastiow = 1;
7e00c42b
BJ
585 state = um->um_tab.b_active;
586 um->um_tab.b_active = 0;
71236e46
BJ
587 /*
588 * Check for errors.
589 */
590 if (addr->tmcs&TM_ERR) {
d565635a 591 while (addr->tmer & TMER_SDWN)
d75e5c3e 592 ; /* await settle down */
71236e46 593 /*
d565635a 594 * If we hit the end of the tape file, update our position.
71236e46 595 */
d565635a 596 if (addr->tmer&TMER_EOF) {
71236e46
BJ
597 tmseteof(bp); /* set blkno and nxrec */
598 state = SCOM; /* force completion */
599 /*
600 * Stuff bc so it will be unstuffed correctly
601 * later to get resid.
602 */
3f3a34c3 603 addr->tmbc = -bp->b_bcount;
71236e46 604 goto opdone;
d75e5c3e 605 }
71236e46 606 /*
d565635a
BJ
607 * If we were reading raw tape and the only error was that the
608 * record was too long, then we don't consider this an error.
71236e46 609 */
d565635a
BJ
610 if (bp == &rtmbuf[TMUNIT(bp->b_dev)] && (bp->b_flags&B_READ) &&
611 (addr->tmer&(TMER_HARD|TMER_SOFT)) == TMER_RLE)
71236e46
BJ
612 goto ignoreerr;
613 /*
614 * If error is not hard, and this was an i/o operation
615 * retry up to 8 times.
616 */
d565635a 617 if ((addr->tmer&TMER_HARD)==0 && state==SIO) {
7e00c42b 618 if (++um->um_tab.b_errcnt < 7) {
7e00c42b 619 sc->sc_blkno++;
0801d37f 620 ubadone(um);
71236e46 621 goto opcont;
d75e5c3e 622 }
71236e46
BJ
623 } else
624 /*
625 * Hard or non-i/o errors on non-raw tape
626 * cause it to close.
627 */
d565635a 628 if (sc->sc_openf>0 && bp != &rtmbuf[TMUNIT(bp->b_dev)])
71236e46
BJ
629 sc->sc_openf = -1;
630 /*
631 * Couldn't recover error
632 */
80905075 633 printf("te%d: hard error bn%d er=%b\n", minor(bp->b_dev)&03,
d565635a 634 bp->b_blkno, sc->sc_erreg, TMER_BITS);
d75e5c3e 635 bp->b_flags |= B_ERROR;
71236e46 636 goto opdone;
d75e5c3e 637 }
71236e46
BJ
638 /*
639 * Advance tape control FSM.
640 */
641ignoreerr:
d75e5c3e
BJ
642 switch (state) {
643
644 case SIO:
71236e46
BJ
645 /*
646 * Read/write increments tape block number
647 */
7e00c42b 648 sc->sc_blkno++;
71236e46 649 goto opdone;
d75e5c3e
BJ
650
651 case SCOM:
71236e46 652 /*
d565635a 653 * For forward/backward space record update current position.
71236e46 654 */
d565635a 655 if (bp == &ctmbuf[TMUNIT(bp->b_dev)])
71236e46
BJ
656 switch (bp->b_command) {
657
658 case TM_SFORW:
659 sc->sc_blkno -= bp->b_repcnt;
d565635a 660 break;
71236e46
BJ
661
662 case TM_SREV:
663 sc->sc_blkno += bp->b_repcnt;
d565635a 664 break;
d75e5c3e 665 }
d565635a 666 goto opdone;
d75e5c3e
BJ
667
668 case SSEEK:
7e00c42b 669 sc->sc_blkno = dbtofsb(bp->b_blkno);
71236e46 670 goto opcont;
d75e5c3e
BJ
671
672 default:
71236e46 673 panic("tmintr");
d75e5c3e 674 }
71236e46
BJ
675opdone:
676 /*
677 * Reset error count and remove
678 * from device queue.
679 */
680 um->um_tab.b_errcnt = 0;
681 dp->b_actf = bp->av_forw;
682 bp->b_resid = -addr->tmbc;
0801d37f 683 ubadone(um);
71236e46
BJ
684 iodone(bp);
685 /*
686 * Circulate slave to end of controller
687 * queue to give other slaves a chance.
688 */
689 um->um_tab.b_actf = dp->b_forw;
690 if (dp->b_actf) {
691 dp->b_forw = NULL;
692 if (um->um_tab.b_actf == NULL)
693 um->um_tab.b_actf = dp;
694 else
695 um->um_tab.b_actl->b_forw = dp;
696 um->um_tab.b_actl = dp;
697 }
698 if (um->um_tab.b_actf == 0)
699 return;
700opcont:
701 tmstart(um);
d75e5c3e
BJ
702}
703
a752fee0
BJ
704tmtimer(dev)
705 int dev;
706{
707 register struct te_softc *sc = &te_softc[TEUNIT(dev)];
afa0df56 708 register short x;
a752fee0
BJ
709
710 if (sc->sc_timo != INF && (sc->sc_timo -= 5) < 0) {
aa4e15a3 711 printf("te%d: lost interrupt\n", TEUNIT(dev));
a752fee0 712 sc->sc_timo = INF;
afa0df56 713 x = spl5();
a752fee0 714 tmintr(TMUNIT(dev));
afa0df56 715 (void) splx(x);
a752fee0 716 }
c27ba986 717 timeout(tmtimer, (caddr_t)dev, 5*hz);
a752fee0
BJ
718}
719
d75e5c3e
BJ
720tmseteof(bp)
721 register struct buf *bp;
722{
d565635a 723 register int teunit = TEUNIT(bp->b_dev);
a870f835
BJ
724 register struct tmdevice *addr =
725 (struct tmdevice *)tedinfo[teunit]->ui_addr;
d565635a 726 register struct te_softc *sc = &te_softc[teunit];
d75e5c3e 727
d565635a 728 if (bp == &ctmbuf[TMUNIT(bp->b_dev)]) {
7e00c42b 729 if (sc->sc_blkno > dbtofsb(bp->b_blkno)) {
d75e5c3e 730 /* reversing */
7e00c42b
BJ
731 sc->sc_nxrec = dbtofsb(bp->b_blkno) - addr->tmbc;
732 sc->sc_blkno = sc->sc_nxrec;
d75e5c3e
BJ
733 } else {
734 /* spacing forward */
7e00c42b
BJ
735 sc->sc_blkno = dbtofsb(bp->b_blkno) + addr->tmbc;
736 sc->sc_nxrec = sc->sc_blkno - 1;
d75e5c3e
BJ
737 }
738 return;
739 }
740 /* eof on read */
7e00c42b 741 sc->sc_nxrec = dbtofsb(bp->b_blkno);
d75e5c3e
BJ
742}
743
744tmread(dev)
71236e46 745 dev_t dev;
d75e5c3e
BJ
746{
747
748 tmphys(dev);
89bd2f01
BJ
749 if (u.u_error)
750 return;
71236e46 751 physio(tmstrategy, &rtmbuf[TMUNIT(dev)], dev, B_READ, minphys);
d75e5c3e
BJ
752}
753
754tmwrite(dev)
71236e46 755 dev_t dev;
d75e5c3e
BJ
756{
757
758 tmphys(dev);
89bd2f01
BJ
759 if (u.u_error)
760 return;
71236e46 761 physio(tmstrategy, &rtmbuf[TMUNIT(dev)], dev, B_WRITE, minphys);
d75e5c3e
BJ
762}
763
d565635a
BJ
764/*
765 * Check that a raw device exists.
766 * If it does, set up sc_blkno and sc_nxrec
767 * so that the tape will appear positioned correctly.
768 */
d75e5c3e 769tmphys(dev)
71236e46 770 dev_t dev;
d75e5c3e 771{
d565635a 772 register int teunit = TEUNIT(dev);
d75e5c3e 773 register daddr_t a;
d565635a
BJ
774 register struct te_softc *sc;
775 register struct uba_device *ui;
d75e5c3e 776
d565635a 777 if (teunit >= NTE || (ui=tedinfo[teunit]) == 0 || ui->ui_alive == 0) {
89bd2f01
BJ
778 u.u_error = ENXIO;
779 return;
780 }
d565635a 781 sc = &te_softc[teunit];
d75e5c3e 782 a = dbtofsb(u.u_offset >> 9);
7e00c42b
BJ
783 sc->sc_blkno = a;
784 sc->sc_nxrec = a + 1;
d75e5c3e
BJ
785}
786
71236e46
BJ
787tmreset(uban)
788 int uban;
789{
89bd2f01 790 register struct uba_ctlr *um;
d565635a 791 register tm11, teunit;
89bd2f01 792 register struct uba_device *ui;
71236e46
BJ
793 register struct buf *dp;
794
afb907f2
BJ
795 for (tm11 = 0; tm11 < NTM; tm11++) {
796 if ((um = tmminfo[tm11]) == 0 || um->um_alive == 0 ||
71236e46
BJ
797 um->um_ubanum != uban)
798 continue;
80905075 799 printf(" tm%d", tm11);
71236e46
BJ
800 um->um_tab.b_active = 0;
801 um->um_tab.b_actf = um->um_tab.b_actl = 0;
802 if (um->um_ubinfo) {
803 printf("<%d>", (um->um_ubinfo>>28)&0xf);
0801d37f 804 ubadone(um);
71236e46 805 }
a870f835 806 ((struct tmdevice *)(um->um_addr))->tmcs = TM_DCLR;
d565635a
BJ
807 for (teunit = 0; teunit < NTE; teunit++) {
808 if ((ui = tedinfo[teunit]) == 0 || ui->ui_mi != um ||
809 ui->ui_alive == 0)
71236e46 810 continue;
d565635a 811 dp = &teutab[teunit];
71236e46
BJ
812 dp->b_active = 0;
813 dp->b_forw = 0;
814 if (um->um_tab.b_actf == NULL)
815 um->um_tab.b_actf = dp;
816 else
817 um->um_tab.b_actl->b_forw = dp;
818 um->um_tab.b_actl = dp;
a752fee0
BJ
819 if (te_softc[teunit].sc_openf > 0)
820 te_softc[teunit].sc_openf = -1;
71236e46
BJ
821 }
822 tmstart(um);
823 }
824}
825
d75e5c3e
BJ
826/*ARGSUSED*/
827tmioctl(dev, cmd, addr, flag)
828 caddr_t addr;
829 dev_t dev;
830{
d565635a
BJ
831 int teunit = TEUNIT(dev);
832 register struct te_softc *sc = &te_softc[teunit];
833 register struct buf *bp = &ctmbuf[TMUNIT(dev)];
d75e5c3e
BJ
834 register callcount;
835 int fcount;
836 struct mtop mtop;
837 struct mtget mtget;
838 /* we depend of the values and order of the MT codes here */
71236e46
BJ
839 static tmops[] =
840 {TM_WEOF,TM_SFORW,TM_SREV,TM_SFORW,TM_SREV,TM_REW,TM_OFFL,TM_SENSE};
d75e5c3e 841
71236e46 842 switch (cmd) {
d75e5c3e
BJ
843 case MTIOCTOP: /* tape operation */
844 if (copyin((caddr_t)addr, (caddr_t)&mtop, sizeof(mtop))) {
845 u.u_error = EFAULT;
846 return;
847 }
848 switch(mtop.mt_op) {
71236e46
BJ
849 case MTWEOF:
850 callcount = mtop.mt_count;
851 fcount = 1;
852 break;
853 case MTFSF: case MTBSF:
d75e5c3e
BJ
854 callcount = mtop.mt_count;
855 fcount = INF;
856 break;
857 case MTFSR: case MTBSR:
858 callcount = 1;
859 fcount = mtop.mt_count;
860 break;
77115c00 861 case MTREW: case MTOFFL: case MTNOP:
d75e5c3e
BJ
862 callcount = 1;
863 fcount = 1;
864 break;
865 default:
866 u.u_error = ENXIO;
867 return;
868 }
71236e46 869 if (callcount <= 0 || fcount <= 0) {
d75e5c3e 870 u.u_error = ENXIO;
71236e46
BJ
871 return;
872 }
873 while (--callcount >= 0) {
e4271c68 874 tmcommand(dev, tmops[mtop.mt_op], fcount);
d75e5c3e 875 if ((mtop.mt_op == MTFSR || mtop.mt_op == MTBSR) &&
71236e46 876 bp->b_resid) {
d75e5c3e
BJ
877 u.u_error = EIO;
878 break;
879 }
d565635a 880 if ((bp->b_flags&B_ERROR) || sc->sc_erreg&TMER_BOT)
d75e5c3e
BJ
881 break;
882 }
71236e46 883 geterror(bp);
d75e5c3e
BJ
884 return;
885 case MTIOCGET:
7e00c42b
BJ
886 mtget.mt_dsreg = sc->sc_dsreg;
887 mtget.mt_erreg = sc->sc_erreg;
888 mtget.mt_resid = sc->sc_resid;
65e74b33 889 mtget.mt_type = MT_ISTM;
d75e5c3e
BJ
890 if (copyout((caddr_t)&mtget, addr, sizeof(mtget)))
891 u.u_error = EFAULT;
892 return;
893 default:
894 u.u_error = ENXIO;
895 }
896}
897
898#define DBSIZE 20
899
7455bf3e 900tmdump()
d75e5c3e 901{
89bd2f01 902 register struct uba_device *ui;
3f3a34c3 903 register struct uba_regs *up;
a870f835 904 register struct tmdevice *addr;
5aa9d5ea
RE
905 int blk, num;
906 int start;
d75e5c3e 907
5aa9d5ea
RE
908 start = 0;
909 num = maxfree;
910#define phys(a,b) ((b)((int)(a)&0x7fffffff))
d565635a 911 if (tedinfo[0] == 0)
2536c16c 912 return (ENXIO);
d565635a 913 ui = phys(tedinfo[0], struct uba_device *);
3f3a34c3 914 up = phys(ui->ui_hd, struct uba_hd *)->uh_physuba;
57229699 915 ubainit(up);
77115c00 916 DELAY(1000000);
a870f835 917 addr = (struct tmdevice *)ui->ui_physaddr;
3f3a34c3 918 tmwait(addr);
71236e46 919 addr->tmcs = TM_DCLR | TM_GO;
d75e5c3e
BJ
920 while (num > 0) {
921 blk = num > DBSIZE ? DBSIZE : num;
3f3a34c3 922 tmdwrite(start, blk, addr, up);
d75e5c3e
BJ
923 start += blk;
924 num -= blk;
925 }
5aa9d5ea
RE
926 tmeof(addr);
927 tmeof(addr);
7e00c42b 928 tmwait(addr);
2536c16c
BJ
929 if (addr->tmcs&TM_ERR)
930 return (EIO);
71236e46 931 addr->tmcs = TM_REW | TM_GO;
5aa9d5ea 932 tmwait(addr);
7455bf3e 933 return (0);
d75e5c3e
BJ
934}
935
71236e46
BJ
936tmdwrite(dbuf, num, addr, up)
937 register dbuf, num;
a870f835 938 register struct tmdevice *addr;
3f3a34c3 939 struct uba_regs *up;
d75e5c3e 940{
3f3a34c3
BJ
941 register struct pte *io;
942 register int npf;
0a51498e 943
3f3a34c3 944 tmwait(addr);
3f3a34c3 945 io = up->uba_map;
d75e5c3e 946 npf = num+1;
0a51498e 947 while (--npf != 0)
89bd2f01 948 *(int *)io++ = (dbuf++ | (1<<UBAMR_DPSHIFT) | UBAMR_MRV);
3f3a34c3
BJ
949 *(int *)io = 0;
950 addr->tmbc = -(num*NBPG);
951 addr->tmba = 0;
71236e46 952 addr->tmcs = TM_WCOM | TM_GO;
d75e5c3e
BJ
953}
954
3f3a34c3 955tmwait(addr)
a870f835 956 register struct tmdevice *addr;
d75e5c3e 957{
0a51498e 958 register s;
d75e5c3e
BJ
959
960 do
3f3a34c3 961 s = addr->tmcs;
71236e46 962 while ((s & TM_CUR) == 0);
d75e5c3e
BJ
963}
964
3f3a34c3 965tmeof(addr)
a870f835 966 struct tmdevice *addr;
d75e5c3e
BJ
967{
968
3f3a34c3 969 tmwait(addr);
71236e46 970 addr->tmcs = TM_WEOF | TM_GO;
d75e5c3e
BJ
971}
972#endif