|
|
1.1 ! root 1: /* ts.c 4.22 81/12/14 */ ! 2: ! 3: #include "ts.h" ! 4: #if NTS > 0 ! 5: /* ! 6: * TS11 tape driver ! 7: * ! 8: * TODO: ! 9: * write dump code ! 10: */ ! 11: #include "../h/param.h" ! 12: #include "../h/systm.h" ! 13: #include "../h/buf.h" ! 14: #include "../h/dir.h" ! 15: #include "../h/conf.h" ! 16: #include "../h/user.h" ! 17: #include "../h/file.h" ! 18: #include "../h/map.h" ! 19: #include "../h/pte.h" ! 20: #include "../h/vm.h" ! 21: #include "../h/ubareg.h" ! 22: #include "../h/ubavar.h" ! 23: #include "../h/mtio.h" ! 24: #include "../h/ioctl.h" ! 25: #include "../h/cmap.h" ! 26: #include "../h/cpu.h" ! 27: ! 28: #include "../h/tsreg.h" ! 29: ! 30: /* ! 31: * There is a ctsbuf per tape controller. ! 32: * It is used as the token to pass to the internal routines ! 33: * to execute tape ioctls. ! 34: * In particular, when the tape is rewinding on close we release ! 35: * the user process but any further attempts to use the tape drive ! 36: * before the rewind completes will hang waiting for ctsbuf. ! 37: */ ! 38: struct buf ctsbuf[NTS]; ! 39: ! 40: /* ! 41: * Raw tape operations use rtsbuf. The driver ! 42: * notices when rtsbuf is being used and allows the user ! 43: * program to continue after errors and read records ! 44: * not of the standard length (BSIZE). ! 45: */ ! 46: struct buf rtsbuf[NTS]; ! 47: ! 48: /* ! 49: * Driver unibus interface routines and variables. ! 50: */ ! 51: int tsprobe(), tsslave(), tsattach(), tsdgo(), tsintr(); ! 52: struct uba_ctlr *tsminfo[NTS]; ! 53: struct uba_device *tsdinfo[NTS]; ! 54: struct buf tsutab[NTS]; ! 55: u_short tsstd[] = { 0772520, 0 }; ! 56: /*** PROBABLY DON'T NEED ALL THESE SINCE CONTROLLER == DRIVE ***/ ! 57: struct uba_driver zsdriver = ! 58: { tsprobe, tsslave, tsattach, tsdgo, tsstd, "ts", tsdinfo, "zs", tsminfo, 0 }; ! 59: ! 60: /* bits in minor device */ ! 61: #define TSUNIT(dev) (minor(dev)&03) ! 62: #define T_NOREWIND 04 ! 63: ! 64: #define INF (daddr_t)1000000L ! 65: ! 66: /* ! 67: * Software state per tape transport. ! 68: * Also contains hardware state in message packets. ! 69: * ! 70: * 1. A tape drive is a unique-open device; we refuse opens when it is already. ! 71: * 2. We keep track of the current position on a block tape and seek ! 72: * before operations by forward/back spacing if necessary. ! 73: * 3. We remember if the last operation was a write on a tape, so if a tape ! 74: * is open read write and the last thing done is a write we can ! 75: * write a standard end of tape mark (two eofs). ! 76: * 4. We remember the status registers after the last command, using ! 77: * then internally and returning them to the SENSE ioctl. ! 78: */ ! 79: struct ts_softc { ! 80: char sc_openf; /* lock against multiple opens */ ! 81: char sc_lastiow; /* last op was a write */ ! 82: short sc_resid; /* copy of last bc */ ! 83: daddr_t sc_blkno; /* block number, for block device tape */ ! 84: daddr_t sc_nxrec; /* position of end of tape, if known */ ! 85: struct ts_cmd sc_cmd; /* the command packet */ ! 86: struct ts_sts sc_sts; /* status packet, for returned status */ ! 87: struct ts_char sc_char; /* characteristics packet */ ! 88: struct ts_softc *sc_ubaddr; /* Unibus address of ts_softc structure */ ! 89: u_short sc_uba; /* Unibus addr of cmd pkt for tsdb */ ! 90: short sc_mapped; /* is ts_sfotc mapped in Unibus space? */ ! 91: } ts_softc[NTS]; ! 92: ! 93: /* ! 94: * States for um->um_tab.b_active, the per controller state flag. ! 95: * This is used to sequence control in the driver. ! 96: */ ! 97: #define SSEEK 1 /* seeking */ ! 98: #define SIO 2 /* doing seq i/o */ ! 99: #define SCOM 3 /* sending control command */ ! 100: #define SREW 4 /* sending a drive rewind */ ! 101: ! 102: /* ! 103: * Determine if there is a controller for ! 104: * a ts at address reg. Our goal is to make the ! 105: * device interrupt. ! 106: */ ! 107: /*ARGSUSED*/ ! 108: tsprobe(reg) ! 109: caddr_t reg; ! 110: { ! 111: register int br, cvec; /* must be r11,r10; value-result */ ! 112: ! 113: #ifdef lint ! 114: br = 0; cvec = br; br = cvec; ! 115: #endif ! 116: ((struct tsdevice *)reg)->tssr = 0; ! 117: DELAY(100); ! 118: if ((((struct tsdevice *)reg)->tssr & TS_NBA) == 0) ! 119: return(0); ! 120: /* IT'S TOO HARD TO MAKE THIS THING INTERRUPT JUST TO FIND ITS VECTOR */ ! 121: cvec = ((unsigned)reg) & 07 ? 0260 : 0224; ! 122: br = 0x15; ! 123: return (1); ! 124: } ! 125: ! 126: /* ! 127: * TS11 only supports one drive per controller; ! 128: * check for ui_slave == 0. ! 129: * ! 130: * DO WE REALLY NEED THIS ROUTINE??? ! 131: */ ! 132: /*ARGSUSED*/ ! 133: tsslave(ui, reg) ! 134: struct uba_device *ui; ! 135: caddr_t reg; ! 136: { ! 137: ! 138: if (ui->ui_slave) /* non-zero slave not allowed */ ! 139: return(0); ! 140: return (1); ! 141: } ! 142: ! 143: /* ! 144: * Record attachment of the unit to the controller. ! 145: * ! 146: * SHOULD THIS ROUTINE DO ANYTHING??? ! 147: */ ! 148: /*ARGSUSED*/ ! 149: tsattach(ui) ! 150: struct uba_device *ui; ! 151: { ! 152: ! 153: } ! 154: ! 155: /* ! 156: * Open the device. Tapes are unique open ! 157: * devices, so we refuse if it is already open. ! 158: * We also check that a tape is available, and ! 159: * don't block waiting here; if you want to wait ! 160: * for a tape you should timeout in user code. ! 161: */ ! 162: tsopen(dev, flag) ! 163: dev_t dev; ! 164: int flag; ! 165: { ! 166: register int tsunit; ! 167: register struct uba_device *ui; ! 168: register struct ts_softc *sc; ! 169: ! 170: tsunit = TSUNIT(dev); ! 171: if (tsunit>=NTS || (sc = &ts_softc[tsunit])->sc_openf || ! 172: (ui = tsdinfo[tsunit]) == 0 || ui->ui_alive == 0) { ! 173: u.u_error = ENXIO; ! 174: return; ! 175: } ! 176: if (tsinit(tsunit)) { ! 177: u.u_error = ENXIO; ! 178: return; ! 179: } ! 180: tscommand(dev, TS_SENSE, 1); ! 181: if ((sc->sc_sts.s_xs0&TS_ONL) == 0) { ! 182: uprintf("ts%d: not online\n", tsunit); ! 183: u.u_error = EIO; ! 184: return; ! 185: } ! 186: if ((flag&(FREAD|FWRITE)) == FWRITE && (sc->sc_sts.s_xs0&TS_WLK)) { ! 187: uprintf("ts%d: no write ring\n", tsunit); ! 188: u.u_error = EIO; ! 189: return; ! 190: } ! 191: sc->sc_openf = 1; ! 192: sc->sc_blkno = (daddr_t)0; ! 193: sc->sc_nxrec = INF; ! 194: sc->sc_lastiow = 0; ! 195: } ! 196: ! 197: /* ! 198: * Close tape device. ! 199: * ! 200: * If tape was open for writing or last operation was ! 201: * a write, then write two EOF's and backspace over the last one. ! 202: * Unless this is a non-rewinding special file, rewind the tape. ! 203: * Make the tape available to others. ! 204: */ ! 205: tsclose(dev, flag) ! 206: register dev_t dev; ! 207: register flag; ! 208: { ! 209: register struct ts_softc *sc = &ts_softc[TSUNIT(dev)]; ! 210: ! 211: if (flag == FWRITE || (flag&FWRITE) && sc->sc_lastiow) { ! 212: tscommand(dev, TS_WEOF, 1); ! 213: tscommand(dev, TS_WEOF, 1); ! 214: tscommand(dev, TS_SREV, 1); ! 215: } ! 216: if ((minor(dev)&T_NOREWIND) == 0) ! 217: /* ! 218: * 0 count means don't hang waiting for rewind complete ! 219: * rather ctsbuf stays busy until the operation completes ! 220: * preventing further opens from completing by ! 221: * preventing a TS_SENSE from completing. ! 222: */ ! 223: tscommand(dev, TS_REW, 0); ! 224: sc->sc_openf = 0; ! 225: } ! 226: ! 227: /* ! 228: * Initialize the TS11. Set up Unibus mapping for command ! 229: * packets and set device characteristics. ! 230: */ ! 231: tsinit(unit) ! 232: register int unit; ! 233: { ! 234: register struct ts_softc *sc = &ts_softc[unit]; ! 235: register struct uba_ctlr *um = tsminfo[unit]; ! 236: register struct tsdevice *addr = (struct tsdevice *)um->um_addr; ! 237: register int i; ! 238: ! 239: /* ! 240: * Map the command and message packets into Unibus ! 241: * address space. We do all the command and message ! 242: * packets at once to minimize the amount of Unibus ! 243: * mapping necessary. ! 244: */ ! 245: if (sc->sc_mapped == 0) { ! 246: ctsbuf[unit].b_un.b_addr = (caddr_t)sc; ! 247: ctsbuf[unit].b_bcount = sizeof(*sc); ! 248: i = ubasetup(um->um_ubanum, &ctsbuf[unit], 0); ! 249: i &= 0777777; ! 250: sc->sc_ubaddr = (struct ts_softc *)i; ! 251: sc->sc_mapped++; ! 252: } ! 253: /* ! 254: * Now initialize the TS11 controller. ! 255: * Set the characteristics. ! 256: */ ! 257: if (addr->tssr & (TS_NBA|TS_OFL)) { ! 258: addr->tssr = 0; /* subsystem initialize */ ! 259: tswait(addr); ! 260: i = (int)&sc->sc_ubaddr->sc_cmd; /* Unibus addr of cmd */ ! 261: sc->sc_uba = (u_short)(i + ((i>>16)&3)); ! 262: sc->sc_char.char_addr = (int)&sc->sc_ubaddr->sc_sts; ! 263: sc->sc_char.char_size = sizeof(struct ts_sts); ! 264: sc->sc_char.char_mode = TS_ESS; ! 265: sc->sc_cmd.c_cmd = TS_ACK | TS_SETCHR; ! 266: i = (int)&sc->sc_ubaddr->sc_char; ! 267: sc->sc_cmd.c_loba = i; ! 268: sc->sc_cmd.c_hiba = (i>>16)&3; ! 269: sc->sc_cmd.c_size = sizeof(struct ts_char); ! 270: addr->tsdb = sc->sc_uba; ! 271: tswait(addr); ! 272: if (addr->tssr & TS_NBA) ! 273: return(1); ! 274: } ! 275: return(0); ! 276: } ! 277: ! 278: /* ! 279: * Execute a command on the tape drive ! 280: * a specified number of times. ! 281: */ ! 282: tscommand(dev, com, count) ! 283: dev_t dev; ! 284: int com, count; ! 285: { ! 286: register struct buf *bp; ! 287: ! 288: bp = &ctsbuf[TSUNIT(dev)]; ! 289: (void) spl5(); ! 290: while (bp->b_flags&B_BUSY) { ! 291: /* ! 292: * This special check is because B_BUSY never ! 293: * gets cleared in the non-waiting rewind case. ! 294: */ ! 295: if (bp->b_repcnt == 0 && (bp->b_flags&B_DONE)) ! 296: break; ! 297: bp->b_flags |= B_WANTED; ! 298: sleep((caddr_t)bp, PRIBIO); ! 299: } ! 300: bp->b_flags = B_BUSY|B_READ; ! 301: (void) spl0(); ! 302: bp->b_dev = dev; ! 303: bp->b_repcnt = count; ! 304: bp->b_command = com; ! 305: bp->b_blkno = 0; ! 306: tsstrategy(bp); ! 307: /* ! 308: * In case of rewind from close, don't wait. ! 309: * This is the only case where count can be 0. ! 310: */ ! 311: if (count == 0) ! 312: return; ! 313: iowait(bp); ! 314: if (bp->b_flags&B_WANTED) ! 315: wakeup((caddr_t)bp); ! 316: bp->b_flags &= B_ERROR; ! 317: } ! 318: ! 319: /* ! 320: * Queue a tape operation. ! 321: */ ! 322: tsstrategy(bp) ! 323: register struct buf *bp; ! 324: { ! 325: int tsunit = TSUNIT(bp->b_dev); ! 326: register struct uba_ctlr *um; ! 327: register struct buf *dp; ! 328: ! 329: /* ! 330: * Put transfer at end of controller queue ! 331: */ ! 332: bp->av_forw = NULL; ! 333: um = tsdinfo[tsunit]->ui_mi; ! 334: dp = &tsutab[tsunit]; ! 335: (void) spl5(); ! 336: if (dp->b_actf == NULL) ! 337: dp->b_actf = bp; ! 338: else ! 339: dp->b_actl->av_forw = bp; ! 340: dp->b_actl = bp; ! 341: um->um_tab.b_actf = um->um_tab.b_actl = dp; ! 342: /* ! 343: * If the controller is not busy, get ! 344: * it going. ! 345: */ ! 346: if (um->um_tab.b_active == 0) ! 347: tsstart(um); ! 348: (void) spl0(); ! 349: } ! 350: ! 351: /* ! 352: * Start activity on a ts controller. ! 353: */ ! 354: tsstart(um) ! 355: register struct uba_ctlr *um; ! 356: { ! 357: register struct buf *bp; ! 358: register struct tsdevice *addr = (struct tsdevice *)um->um_addr; ! 359: register struct ts_softc *sc; ! 360: register struct ts_cmd *tc; ! 361: register struct uba_device *ui; ! 362: int tsunit, cmd; ! 363: daddr_t blkno; ! 364: ! 365: /* ! 366: * Start the controller if there is something for it to do. ! 367: */ ! 368: loop: ! 369: if ((bp = um->um_tab.b_actf->b_actf) == NULL) ! 370: return; ! 371: tsunit = TSUNIT(bp->b_dev); ! 372: ui = tsdinfo[tsunit]; ! 373: sc = &ts_softc[tsunit]; ! 374: tc = &sc->sc_cmd; ! 375: /* ! 376: * Default is that last command was NOT a write command; ! 377: * if we do a write command we will notice this in tsintr(). ! 378: */ ! 379: sc->sc_lastiow = 0; ! 380: if (sc->sc_openf < 0 || (addr->tssr&TS_OFL)) { ! 381: /* ! 382: * Have had a hard error on a non-raw tape ! 383: * or the tape unit is now unavailable ! 384: * (e.g. taken off line). ! 385: */ ! 386: bp->b_flags |= B_ERROR; ! 387: goto next; ! 388: } ! 389: if (bp == &ctsbuf[TSUNIT(bp->b_dev)]) { ! 390: /* ! 391: * Execute control operation with the specified count. ! 392: */ ! 393: um->um_tab.b_active = ! 394: bp->b_command == TS_REW ? SREW : SCOM; ! 395: tc->c_repcnt = bp->b_repcnt; ! 396: goto dobpcmd; ! 397: } ! 398: /* ! 399: * The following checks handle boundary cases for operation ! 400: * on non-raw tapes. On raw tapes the initialization of ! 401: * sc->sc_nxrec by tsphys causes them to be skipped normally ! 402: * (except in the case of retries). ! 403: */ ! 404: if (dbtofsb(bp->b_blkno) > sc->sc_nxrec) { ! 405: /* ! 406: * Can't read past known end-of-file. ! 407: */ ! 408: bp->b_flags |= B_ERROR; ! 409: bp->b_error = ENXIO; ! 410: goto next; ! 411: } ! 412: if (dbtofsb(bp->b_blkno) == sc->sc_nxrec && ! 413: bp->b_flags&B_READ) { ! 414: /* ! 415: * Reading at end of file returns 0 bytes. ! 416: */ ! 417: bp->b_resid = bp->b_bcount; ! 418: clrbuf(bp); ! 419: goto next; ! 420: } ! 421: if ((bp->b_flags&B_READ) == 0) ! 422: /* ! 423: * Writing sets EOF ! 424: */ ! 425: sc->sc_nxrec = dbtofsb(bp->b_blkno) + 1; ! 426: /* ! 427: * If the data transfer command is in the correct place, ! 428: * set up all the registers except the csr, and give ! 429: * control over to the UNIBUS adapter routines, to ! 430: * wait for resources to start the i/o. ! 431: */ ! 432: if ((blkno = sc->sc_blkno) == dbtofsb(bp->b_blkno)) { ! 433: tc->c_size = bp->b_bcount; ! 434: if ((bp->b_flags&B_READ) == 0) ! 435: cmd = TS_WCOM; ! 436: else ! 437: cmd = TS_RCOM; ! 438: if (um->um_tab.b_errcnt) ! 439: cmd |= TS_RETRY; ! 440: um->um_tab.b_active = SIO; ! 441: tc->c_cmd = TS_ACK | TS_CVC | TS_IE | cmd; ! 442: (void) ubago(ui); ! 443: return; ! 444: } ! 445: /* ! 446: * Tape positioned incorrectly; ! 447: * set to seek forwards or backwards to the correct spot. ! 448: * This happens for raw tapes only on error retries. ! 449: */ ! 450: um->um_tab.b_active = SSEEK; ! 451: if (blkno < dbtofsb(bp->b_blkno)) { ! 452: bp->b_command = TS_SFORW; ! 453: tc->c_repcnt = dbtofsb(bp->b_blkno) - blkno; ! 454: } else { ! 455: bp->b_command = TS_SREV; ! 456: tc->c_repcnt = blkno - dbtofsb(bp->b_blkno); ! 457: } ! 458: dobpcmd: ! 459: /* ! 460: * Do the command in bp. ! 461: */ ! 462: tc->c_cmd = TS_ACK | TS_CVC | TS_IE | bp->b_command; ! 463: addr->tsdb = sc->sc_uba; ! 464: return; ! 465: ! 466: next: ! 467: /* ! 468: * Done with this operation due to error or ! 469: * the fact that it doesn't do anything. ! 470: * Release UBA resources (if any), dequeue ! 471: * the transfer and continue processing this slave. ! 472: */ ! 473: if (um->um_ubinfo) ! 474: ubadone(um); ! 475: um->um_tab.b_errcnt = 0; ! 476: um->um_tab.b_actf->b_actf = bp->av_forw; ! 477: iodone(bp); ! 478: goto loop; ! 479: } ! 480: ! 481: /* ! 482: * The UNIBUS resources we needed have been ! 483: * allocated to us; start the device. ! 484: */ ! 485: tsdgo(um) ! 486: register struct uba_ctlr *um; ! 487: { ! 488: register struct tsdevice *addr = (struct tsdevice *)um->um_addr; ! 489: register struct ts_softc *sc = &ts_softc[um->um_ctlr]; ! 490: register int i; ! 491: ! 492: i = um->um_ubinfo & 0777777; ! 493: sc->sc_cmd.c_loba = i; ! 494: sc->sc_cmd.c_hiba = (i>>16)&3; ! 495: addr->tsdb = sc->sc_uba; ! 496: } ! 497: ! 498: /* ! 499: * Ts interrupt routine. ! 500: */ ! 501: /*ARGSUSED*/ ! 502: tsintr(ts11) ! 503: int ts11; ! 504: { ! 505: register struct buf *bp; ! 506: register struct uba_ctlr *um = tsminfo[ts11]; ! 507: register struct tsdevice *addr; ! 508: register struct ts_softc *sc; ! 509: int tsunit; ! 510: register state; ! 511: ! 512: if ((bp = um->um_tab.b_actf->b_actf) == NULL) ! 513: return; ! 514: tsunit = TSUNIT(bp->b_dev); ! 515: addr = (struct tsdevice *)tsdinfo[tsunit]->ui_addr; ! 516: /* ! 517: * If last command was a rewind, and tape is still ! 518: * rewinding, wait for the rewind complete interrupt. ! 519: * ! 520: * SHOULD NEVER GET AN INTERRUPT IN THIS STATE. ! 521: */ ! 522: if (um->um_tab.b_active == SREW) { ! 523: um->um_tab.b_active = SCOM; ! 524: if ((addr->tssr&TS_SSR) == 0) ! 525: return; ! 526: } ! 527: /* ! 528: * An operation completed... record status ! 529: */ ! 530: sc = &ts_softc[tsunit]; ! 531: if ((bp->b_flags & B_READ) == 0) ! 532: sc->sc_lastiow = 1; ! 533: state = um->um_tab.b_active; ! 534: um->um_tab.b_active = 0; ! 535: /* ! 536: * Check for errors. ! 537: */ ! 538: if (addr->tssr&TS_SC) { ! 539: switch (addr->tssr & TS_TC) { ! 540: case TS_UNREC: /* unrecoverable */ ! 541: case TS_FATAL: /* fatal error */ ! 542: case TS_ATTN: /* attention (shouldn't happen) */ ! 543: case TS_RECNM: /* recoverable, no motion */ ! 544: break; ! 545: ! 546: case TS_SUCC: /* success termination */ ! 547: printf("ts%d: success\n", TSUNIT(minor(bp->b_dev))); ! 548: goto ignoreerr; ! 549: ! 550: case TS_ALERT: /* tape status alert */ ! 551: /* ! 552: * If we hit the end of the tape file, ! 553: * update our position. ! 554: */ ! 555: if (sc->sc_sts.s_xs0 & (TS_TMK|TS_EOT)) { ! 556: tsseteof(bp); /* set blkno and nxrec */ ! 557: state = SCOM; /* force completion */ ! 558: /* ! 559: * Stuff bc so it will be unstuffed correctly ! 560: * later to get resid. ! 561: */ ! 562: sc->sc_sts.s_rbpcr = bp->b_bcount; ! 563: goto opdone; ! 564: } ! 565: /* ! 566: * If we were reading raw tape and the record was too long ! 567: * or too short, then we don't consider this an error. ! 568: */ ! 569: if (bp == &rtsbuf[TSUNIT(bp->b_dev)] && (bp->b_flags&B_READ) && ! 570: sc->sc_sts.s_xs0&(TS_RLS|TS_RLL)) ! 571: goto ignoreerr; ! 572: case TS_RECOV: /* recoverable, tape moved */ ! 573: /* ! 574: * If this was an i/o operation retry up to 8 times. ! 575: */ ! 576: if (state==SIO) { ! 577: if (++um->um_tab.b_errcnt < 7) { ! 578: ubadone(um); ! 579: goto opcont; ! 580: } else ! 581: sc->sc_blkno++; ! 582: } else { ! 583: /* ! 584: * Non-i/o errors on non-raw tape ! 585: * cause it to close. ! 586: */ ! 587: if (sc->sc_openf>0 && bp != &rtsbuf[TSUNIT(bp->b_dev)]) ! 588: sc->sc_openf = -1; ! 589: } ! 590: break; ! 591: ! 592: case TS_REJECT: /* function reject */ ! 593: if (state == SIO && sc->sc_sts.s_xs0 & TS_WLE) ! 594: printf("ts%d: write locked\n", TSUNIT(bp->b_dev)); ! 595: if ((sc->sc_sts.s_xs0 & TS_ONL) == 0) ! 596: printf("ts%d: offline\n", TSUNIT(bp->b_dev)); ! 597: break; ! 598: } ! 599: /* ! 600: * Couldn't recover error ! 601: */ ! 602: printf("ts%d: hard error bn%d xs0=%b", TSUNIT(bp->b_dev), ! 603: bp->b_blkno, sc->sc_sts.s_xs0, TSXS0_BITS); ! 604: if (sc->sc_sts.s_xs1) ! 605: printf(" xs1=%b", sc->sc_sts.s_xs1, TSXS1_BITS); ! 606: if (sc->sc_sts.s_xs2) ! 607: printf(" xs2=%b", sc->sc_sts.s_xs2, TSXS2_BITS); ! 608: if (sc->sc_sts.s_xs3) ! 609: printf(" xs3=%b", sc->sc_sts.s_xs3, TSXS3_BITS); ! 610: printf("\n"); ! 611: bp->b_flags |= B_ERROR; ! 612: goto opdone; ! 613: } ! 614: /* ! 615: * Advance tape control FSM. ! 616: */ ! 617: ignoreerr: ! 618: switch (state) { ! 619: ! 620: case SIO: ! 621: /* ! 622: * Read/write increments tape block number ! 623: */ ! 624: sc->sc_blkno++; ! 625: goto opdone; ! 626: ! 627: case SCOM: ! 628: /* ! 629: * For forward/backward space record update current position. ! 630: */ ! 631: if (bp == &ctsbuf[TSUNIT(bp->b_dev)]) ! 632: switch (bp->b_command) { ! 633: ! 634: case TS_SFORW: ! 635: sc->sc_blkno += bp->b_repcnt; ! 636: break; ! 637: ! 638: case TS_SREV: ! 639: sc->sc_blkno -= bp->b_repcnt; ! 640: break; ! 641: } ! 642: goto opdone; ! 643: ! 644: case SSEEK: ! 645: sc->sc_blkno = dbtofsb(bp->b_blkno); ! 646: goto opcont; ! 647: ! 648: default: ! 649: panic("tsintr"); ! 650: } ! 651: opdone: ! 652: /* ! 653: * Reset error count and remove ! 654: * from device queue. ! 655: */ ! 656: um->um_tab.b_errcnt = 0; ! 657: um->um_tab.b_actf->b_actf = bp->av_forw; ! 658: bp->b_resid = sc->sc_sts.s_rbpcr; ! 659: ubadone(um); ! 660: iodone(bp); ! 661: if (um->um_tab.b_actf->b_actf == 0) ! 662: return; ! 663: opcont: ! 664: tsstart(um); ! 665: } ! 666: ! 667: tsseteof(bp) ! 668: register struct buf *bp; ! 669: { ! 670: register int tsunit = TSUNIT(bp->b_dev); ! 671: register struct ts_softc *sc = &ts_softc[tsunit]; ! 672: ! 673: if (bp == &ctsbuf[TSUNIT(bp->b_dev)]) { ! 674: if (sc->sc_blkno > dbtofsb(bp->b_blkno)) { ! 675: /* reversing */ ! 676: sc->sc_nxrec = dbtofsb(bp->b_blkno) - sc->sc_sts.s_rbpcr; ! 677: sc->sc_blkno = sc->sc_nxrec; ! 678: } else { ! 679: /* spacing forward */ ! 680: sc->sc_blkno = dbtofsb(bp->b_blkno) + sc->sc_sts.s_rbpcr; ! 681: sc->sc_nxrec = sc->sc_blkno - 1; ! 682: } ! 683: return; ! 684: } ! 685: /* eof on read */ ! 686: sc->sc_nxrec = dbtofsb(bp->b_blkno); ! 687: } ! 688: ! 689: tsread(dev) ! 690: dev_t dev; ! 691: { ! 692: ! 693: tsphys(dev); ! 694: if (u.u_error) ! 695: return; ! 696: physio(tsstrategy, &rtsbuf[TSUNIT(dev)], dev, B_READ, minphys); ! 697: } ! 698: ! 699: tswrite(dev) ! 700: dev_t dev; ! 701: { ! 702: ! 703: tsphys(dev); ! 704: if (u.u_error) ! 705: return; ! 706: physio(tsstrategy, &rtsbuf[TSUNIT(dev)], dev, B_WRITE, minphys); ! 707: } ! 708: ! 709: /* ! 710: * Check that a raw device exists. ! 711: * If it does, set up sc_blkno and sc_nxrec ! 712: * so that the tape will appear positioned correctly. ! 713: */ ! 714: tsphys(dev) ! 715: dev_t dev; ! 716: { ! 717: register int tsunit = TSUNIT(dev); ! 718: register daddr_t a; ! 719: register struct ts_softc *sc; ! 720: register struct uba_device *ui; ! 721: ! 722: if (tsunit >= NTS || (ui=tsdinfo[tsunit]) == 0 || ui->ui_alive == 0) { ! 723: u.u_error = ENXIO; ! 724: return; ! 725: } ! 726: sc = &ts_softc[tsunit]; ! 727: a = dbtofsb(u.u_offset >> 9); ! 728: sc->sc_blkno = a; ! 729: sc->sc_nxrec = a + 1; ! 730: } ! 731: ! 732: tsreset(uban) ! 733: int uban; ! 734: { ! 735: register struct uba_ctlr *um; ! 736: register struct uba_device *ui; ! 737: register struct buf *dp; ! 738: register ts11; ! 739: ! 740: for (ts11 = 0; ts11 < NTS; ts11++) { ! 741: if ((um = tsminfo[ts11]) == 0 || um->um_alive == 0 || ! 742: um->um_ubanum != uban) ! 743: continue; ! 744: printf(" ts%d", ts11); ! 745: um->um_tab.b_active = 0; ! 746: um->um_tab.b_actf = um->um_tab.b_actl = 0; ! 747: if (ts_softc[ts11].sc_openf > 0) ! 748: ts_softc[ts11].sc_openf = -1; ! 749: if (um->um_ubinfo) { ! 750: printf("<%d>", (um->um_ubinfo>>28)&0xf); ! 751: ubadone(um); ! 752: } ! 753: if ((ui = tsdinfo[ts11]) && ui->ui_mi == um && ui->ui_alive) { ! 754: dp = &tsutab[ts11]; ! 755: dp->b_active = 0; ! 756: dp->b_forw = 0; ! 757: if (um->um_tab.b_actf == NULL) ! 758: um->um_tab.b_actf = dp; ! 759: else ! 760: um->um_tab.b_actl->b_forw = dp; ! 761: um->um_tab.b_actl = dp; ! 762: } ! 763: (void) tsinit(ts11); ! 764: tsstart(um); ! 765: } ! 766: } ! 767: ! 768: /*ARGSUSED*/ ! 769: tsioctl(dev, cmd, addr, flag) ! 770: caddr_t addr; ! 771: dev_t dev; ! 772: { ! 773: int tsunit = TSUNIT(dev); ! 774: register struct ts_softc *sc = &ts_softc[tsunit]; ! 775: register struct buf *bp = &ctsbuf[TSUNIT(dev)]; ! 776: register callcount; ! 777: int fcount; ! 778: struct mtop mtop; ! 779: struct mtget mtget; ! 780: /* we depend of the values and order of the MT codes here */ ! 781: static tsops[] = ! 782: {TS_WEOF,TS_SFORWF,TS_SREVF,TS_SFORW,TS_SREV,TS_REW,TS_OFFL,TS_SENSE}; ! 783: ! 784: switch (cmd) { ! 785: case MTIOCTOP: /* tape operation */ ! 786: if (copyin((caddr_t)addr, (caddr_t)&mtop, sizeof(mtop))) { ! 787: u.u_error = EFAULT; ! 788: return; ! 789: } ! 790: switch(mtop.mt_op) { ! 791: case MTWEOF: ! 792: callcount = mtop.mt_count; ! 793: fcount = 1; ! 794: break; ! 795: case MTFSF: case MTBSF: ! 796: case MTFSR: case MTBSR: ! 797: callcount = 1; ! 798: fcount = mtop.mt_count; ! 799: break; ! 800: case MTREW: case MTOFFL: case MTNOP: ! 801: callcount = 1; ! 802: fcount = 1; ! 803: break; ! 804: default: ! 805: u.u_error = ENXIO; ! 806: return; ! 807: } ! 808: if (callcount <= 0 || fcount <= 0) { ! 809: u.u_error = ENXIO; ! 810: return; ! 811: } ! 812: while (--callcount >= 0) { ! 813: tscommand(dev, tsops[mtop.mt_op], fcount); ! 814: if ((mtop.mt_op == MTFSR || mtop.mt_op == MTBSR) && ! 815: bp->b_resid) { ! 816: u.u_error = EIO; ! 817: break; ! 818: } ! 819: if ((bp->b_flags&B_ERROR) || sc->sc_sts.s_xs0&TS_BOT) ! 820: break; ! 821: } ! 822: geterror(bp); ! 823: return; ! 824: case MTIOCGET: ! 825: mtget.mt_dsreg = 0; ! 826: mtget.mt_erreg = sc->sc_sts.s_xs0; ! 827: mtget.mt_resid = sc->sc_resid; ! 828: mtget.mt_type = MT_ISTS; ! 829: if (copyout((caddr_t)&mtget, addr, sizeof(mtget))) ! 830: u.u_error = EFAULT; ! 831: return; ! 832: default: ! 833: u.u_error = ENXIO; ! 834: } ! 835: } ! 836: ! 837: #define DBSIZE 20 ! 838: ! 839: tsdump() ! 840: { ! 841: register struct uba_device *ui; ! 842: register struct uba_regs *up; ! 843: register struct tsdevice *addr; ! 844: int blk, num; ! 845: int start; ! 846: ! 847: start = 0; ! 848: num = maxfree; ! 849: #define phys(a,b) ((b)((int)(a)&0x7fffffff)) ! 850: if (tsdinfo[0] == 0) ! 851: return (ENXIO); ! 852: ui = phys(tsdinfo[0], struct uba_device *); ! 853: up = phys(ui->ui_hd, struct uba_hd *)->uh_physuba; ! 854: ubainit(up); ! 855: DELAY(1000000); ! 856: addr = (struct tsdevice *)ui->ui_physaddr; ! 857: addr->tssr = 0; ! 858: tswait(addr); ! 859: while (num > 0) { ! 860: blk = num > DBSIZE ? DBSIZE : num; ! 861: tsdwrite(start, blk, addr, up); ! 862: start += blk; ! 863: num -= blk; ! 864: } ! 865: tseof(addr); ! 866: tseof(addr); ! 867: tswait(addr); ! 868: if (addr->tssr&TS_SC) ! 869: return (EIO); ! 870: addr->tssr = 0; ! 871: tswait(addr); ! 872: return (0); ! 873: } ! 874: ! 875: tsdwrite(dbuf, num, addr, up) ! 876: register dbuf, num; ! 877: register struct tsdevice *addr; ! 878: struct uba_regs *up; ! 879: { ! 880: register struct pte *io; ! 881: register int npf; ! 882: ! 883: tswait(addr); ! 884: io = up->uba_map; ! 885: npf = num+1; ! 886: while (--npf != 0) ! 887: *(int *)io++ = (dbuf++ | (1<<UBAMR_DPSHIFT) | UBAMR_MRV); ! 888: *(int *)io = 0; ! 889: #ifdef notyet ! 890: addr->tsbc = -(num*NBPG); ! 891: addr->tsba = 0; ! 892: addr->tscs = TS_WCOM | TM_GO; ! 893: #endif ! 894: } ! 895: ! 896: tswait(addr) ! 897: register struct tsdevice *addr; ! 898: { ! 899: register s; ! 900: ! 901: do ! 902: s = addr->tssr; ! 903: while ((s & TS_SSR) == 0); ! 904: } ! 905: ! 906: tseof(addr) ! 907: struct tsdevice *addr; ! 908: { ! 909: ! 910: tswait(addr); ! 911: #ifdef notyet ! 912: addr->tscs = TS_WEOF | TM_GO; ! 913: #endif ! 914: } ! 915: #endif
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.