4.4BSD/usr/src/sys/tahoe/vba/cy.c
/*
* Copyright (c) 1988 Regents of the University of California.
* All rights reserved.
*
* This code is derived from software contributed to Berkeley by
* Computer Consoles Inc.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* 3. All advertising materials mentioning features or use of this software
* must display the following acknowledgement:
* This product includes software developed by the University of
* California, Berkeley and its contributors.
* 4. Neither the name of the University nor the names of its contributors
* may be used to endorse or promote products derived from this software
* without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*
*
* @(#)cy.c 7.8 (Berkeley) 5/8/91
*/
#include "yc.h"
#if NCY > 0
/*
* Cipher Tapemaster driver.
*/
#define CYDEBUG
#ifdef CYDEBUG
int cydebug = 0;
#define dlog(params) if (cydebug) log params
#else
#define dlog(params) /* */
#endif
#include "sys/param.h"
#include "sys/systm.h"
#include "sys/vm.h"
#include "sys/buf.h"
#include "sys/file.h"
#include "sys/signal.h"
#include "sys/ioctl.h"
#include "sys/mtio.h"
#include "sys/errno.h"
#include "sys/cmap.h"
#include "sys/time.h"
#include "sys/kernel.h"
#include "sys/syslog.h"
#include "sys/tprintf.h"
#include "../include/cpu.h"
#include "../include/mtpr.h"
#include "../include/pte.h"
#include "../vba/vbavar.h"
#define CYERROR
#include "../vba/cyreg.h"
/*
* There is a ccybuf per tape controller.
* It is used as the token to pass to the internal routines
* to execute tape ioctls, and also acts as a lock on the slaves
* on the controller, since there is only one per controller.
* In particular, when the tape is rewinding on close we release
* the user process but any further attempts to use the tape drive
* before the rewind completes will hang waiting for ccybuf.
*/
struct buf ccybuf[NCY];
int cyprobe(), cyslave(), cyattach();
struct buf ycutab[NYC];
short yctocy[NYC];
struct vba_ctlr *cyminfo[NCY];
struct vba_device *ycdinfo[NYC];
long cystd[] = { 0 };
struct vba_driver cydriver =
{ cyprobe, cyslave, cyattach, 0, cystd, "yc", ycdinfo, "cy", cyminfo };
/* bits in minor device */
#define YCUNIT(dev) (minor(dev)&03)
#define CYUNIT(dev) (yctocy[YCUNIT(dev)])
#define T_NOREWIND 0x04
#define T_1600BPI 0x00 /* pseudo */
#define T_3200BPI 0x08 /* unused */
#define INF 1000000L /* close to infinity */
/*
* Software state and shared command areas per controller.
*
* The i/o intermediate buffer must be allocated in startup()
* so its address will fit in 20-bits (YECH!!!!!!!!!!!!!!).
*/
struct cy_softc {
int cy_bs; /* controller's buffer size */
struct cyscp *cy_scp; /* system configuration block address */
struct cyccb cy_ccb; /* channel control block */
struct cyscb cy_scb; /* system configuration block */
struct cytpb cy_tpb; /* tape parameter block */
struct cytpb cy_nop; /* nop parameter block for cyintr */
struct vb_buf cy_rbuf; /* vba resources */
} cy_softc[NCY];
/*
* Software state per tape transport.
*/
struct yc_softc {
char yc_openf; /* lock against multiple opens */
char yc_lastiow; /* last operation was a write */
short yc_tact; /* timeout is active */
long yc_timo; /* time until timeout expires */
u_short yc_control; /* copy of last tpcb.tpcontrol */
u_short yc_status; /* copy of last tpcb.tpstatus */
u_short yc_resid; /* copy of last bc */
u_short yc_dens; /* prototype control word with density info */
tpr_t yc_tpr; /* handle for tprintf */
daddr_t yc_blkno; /* block number, for block device tape */
daddr_t yc_nxrec; /* position of end of tape, if known */
int yc_blksize; /* current tape blocksize estimate */
int yc_blks; /* number of I/O operations since open */
int yc_softerrs; /* number of soft I/O errors since open */
} yc_softc[NYC];
/*
* States for vm->um_tab.b_active, the per controller state flag.
* This is used to sequence control in the driver.
*/
#define SSEEK 1 /* seeking */
#define SIO 2 /* doing seq i/o */
#define SCOM 3 /* sending control command */
#define SREW 4 /* sending a rewind */
#define SERASE 5 /* erase inter-record gap */
#define SERASED 6 /* erased inter-record gap */
/* there's no way to figure these out dynamically? -- yech */
struct cyscp *cyscp[] =
{ (struct cyscp *)0xc0000c06, (struct cyscp *)0xc0000c16 };
#define NCYSCP (sizeof (cyscp) / sizeof (cyscp[0]))
cyprobe(reg, vm)
caddr_t reg;
struct vba_ctlr *vm;
{
register br, cvec; /* must be r12, r11 */
register struct cy_softc *cy;
int ctlr = vm->um_ctlr;
#ifdef lint
br = 0; cvec = br; br = cvec;
cyintr(0);
#endif
if (badcyaddr(reg+1))
return (0);
if (ctlr > NCYSCP || cyscp[ctlr] == 0) /* XXX */
return (0);
cy = &cy_softc[ctlr];
cy->cy_scp = cyscp[ctlr]; /* XXX */
/*
* Tapemaster controller must have interrupt handler
* disable interrupt, so we'll just kludge things
* (stupid multibus non-vectored interrupt crud).
*/
if (cyinit(ctlr, reg)) {
uncache(&cy->cy_tpb.tpcount);
cy->cy_bs = htoms(cy->cy_tpb.tpcount);
/*
* Setup nop parameter block for clearing interrupts.
*/
cy->cy_nop.tpcmd = CY_NOP;
cy->cy_nop.tpcontrol = 0;
/*
* Allocate page tables.
*/
if (cybuf == 0) {
printf("no cy buffer!!!\n");
return (0);
}
cy->cy_rbuf.vb_rawbuf = cybuf + ctlr * CYMAXIO;
if (vbainit(&cy->cy_rbuf, CYMAXIO, VB_20BIT) == 0) {
printf("cy%d: vbainit failed\n", ctlr);
return (0);
}
br = 0x13, cvec = 0x80; /* XXX */
return (sizeof (struct cyccb));
} else
return (0);
}
/*
* Check to see if a drive is attached to a controller.
* Since we can only tell that a drive is there if a tape is loaded and
* the drive is placed online, we always indicate the slave is present.
*/
cyslave(vi, addr)
struct vba_device *vi;
caddr_t addr;
{
#ifdef lint
vi = vi; addr = addr;
#endif
return (1);
}
cyattach(vi)
struct vba_device *vi;
{
register struct cy_softc *cy;
int ctlr = vi->ui_mi->um_ctlr;
yctocy[vi->ui_unit] = ctlr;
cy = &cy_softc[ctlr];
if (vi->ui_slave == 0 && cy->cy_bs)
printf("; %dkb buffer", cy->cy_bs/1024);
}
/*
* Initialize the controller after a controller reset or
* during autoconfigure. All of the system control blocks
* are initialized and the controller is asked to configure
* itself for later use.
*/
cyinit(ctlr, addr)
int ctlr;
register caddr_t addr;
{
register struct cy_softc *cy = &cy_softc[ctlr];
register int *pte;
/*
* Initialize the system configuration pointer.
*/
/* make kernel writable */
pte = (int *)&Sysmap[btop((int)cy->cy_scp &~ KERNBASE)];
*pte &= ~PG_PROT; *pte |= PG_KW;
mtpr(TBIS, cy->cy_scp);
/* load the correct values in the scp */
cy->cy_scp->csp_buswidth = CSP_16BITS;
cyldmba(cy->cy_scp->csp_scb, (caddr_t)&cy->cy_scb);
/* put it back to read-only */
*pte &= ~PG_PROT; *pte |= PG_KR;
mtpr(TBIS, cy->cy_scp);
/*
* Init system configuration block.
*/
cy->cy_scb.csb_fixed = CSB_FIXED;
/* set pointer to the channel control block */
cyldmba(cy->cy_scb.csb_ccb, (caddr_t)&cy->cy_ccb);
/*
* Initialize the chanel control block.
*/
cy->cy_ccb.cbcw = CBCW_CLRINT;
cy->cy_ccb.cbgate = GATE_OPEN;
/* set pointer to the tape parameter block */
cyldmba(cy->cy_ccb.cbtpb, (caddr_t)&cy->cy_tpb);
/*
* Issue a nop cmd and get the internal buffer size for buffered i/o.
*/
cy->cy_tpb.tpcmd = CY_NOP;
cy->cy_tpb.tpcontrol = CYCW_16BITS;
cy->cy_ccb.cbgate = GATE_CLOSED;
CY_GO(addr);
if (cywait(&cy->cy_ccb) || (cy->cy_tpb.tpstatus&CYS_ERR)) {
uncache(&cy->cy_tpb.tpstatus);
printf("cy%d: timeout or err during init, status=%b\n", ctlr,
cy->cy_tpb.tpstatus, CYS_BITS);
return (0);
}
cy->cy_tpb.tpcmd = CY_CONFIG;
cy->cy_tpb.tpcontrol = CYCW_16BITS;
cy->cy_ccb.cbgate = GATE_CLOSED;
CY_GO(addr);
if (cywait(&cy->cy_ccb) || (cy->cy_tpb.tpstatus&CYS_ERR)) {
uncache(&cy->cy_tpb.tpstatus);
printf("cy%d: configuration failure, status=%b\n", ctlr,
cy->cy_tpb.tpstatus, CYS_BITS);
return (0);
}
return (1);
}
int cytimer();
/*
* Open the device. Tapes are unique open
* devices, so we refuse if it is already open.
* We also check that a tape is available, and
* don't block waiting here; if you want to wait
* for a tape you should timeout in user code.
*/
cyopen(dev, flag)
dev_t dev;
register int flag;
{
register int ycunit;
register struct vba_device *vi;
register struct yc_softc *yc;
ycunit = YCUNIT(dev);
if (ycunit >= NYC || (vi = ycdinfo[ycunit]) == 0 || vi->ui_alive == 0)
return (ENXIO);
if ((yc = &yc_softc[ycunit])->yc_openf)
return (EBUSY);
yc->yc_openf = 1;
#define PACKUNIT(vi) \
(((vi->ui_slave&1)<<11)|((vi->ui_slave&2)<<9)|((vi->ui_slave&4)>>2))
/* no way to select density */
yc->yc_dens = PACKUNIT(vi)|CYCW_IE|CYCW_16BITS;
if (yc->yc_tact == 0) {
yc->yc_timo = INF;
yc->yc_tact = 1;
timeout(cytimer, (caddr_t)dev, 5*hz);
}
cycommand(dev, CY_SENSE, 1);
if ((yc->yc_status&CYS_OL) == 0) { /* not on-line */
uprintf("cy%d: not online\n", ycunit);
yc->yc_openf = 0;
return (EIO);
}
if ((flag&FWRITE) && (yc->yc_status&CYS_WP)) {
uprintf("cy%d: no write ring\n", ycunit);
yc->yc_openf = 0;
return (EIO);
}
yc->yc_blkno = (daddr_t)0;
yc->yc_nxrec = INF;
yc->yc_lastiow = 0;
yc->yc_blksize = CYMAXIO; /* guess > 0 */
yc->yc_blks = 0;
yc->yc_softerrs = 0;
yc->yc_tpr = tprintf_open();
return (0);
}
/*
* Close tape device.
*
* If tape was open for writing or last operation was a write,
* then write two EOF's and backspace over the last one.
* Unless this is a non-rewinding special file, rewind the tape.
* Make the tape available to others.
*/
cyclose(dev, flag)
dev_t dev;
int flag;
{
struct yc_softc *yc = &yc_softc[YCUNIT(dev)];
if (flag == FWRITE || (flag&FWRITE) && yc->yc_lastiow) {
cycommand(dev, CY_WEOF, 1); /* can't use count with WEOF */
cycommand(dev, CY_WEOF, 1);
cycommand(dev, CY_SREV, 1);
}
if ((minor(dev)&T_NOREWIND) == 0)
/*
* 0 count means don't hang waiting for rewind complete
* rather ccybuf stays busy until the operation completes
* preventing further opens from completing by preventing
* a CY_SENSE from completing.
*/
cycommand(dev, CY_REW, 0);
if (yc->yc_blks > 10 && yc->yc_softerrs > yc->yc_blks / 10)
log(LOG_INFO, "yc%d: %d soft errors in %d blocks\n",
YCUNIT(dev), yc->yc_softerrs, yc->yc_blks);
dlog((LOG_INFO, "%d soft errors in %d blocks\n",
yc->yc_softerrs, yc->yc_blks));
tprintf_close(yc->yc_tpr);
yc->yc_openf = 0;
return (0);
}
/*
* Execute a command on the tape drive a specified number of times.
*/
cycommand(dev, com, count)
dev_t dev;
int com, count;
{
register struct buf *bp;
int s;
bp = &ccybuf[CYUNIT(dev)];
s = spl3();
dlog((LOG_INFO, "cycommand(%o, %x, %d), b_flags %x\n",
dev, com, count, bp->b_flags));
while (bp->b_flags&B_BUSY) {
/*
* This special check is because B_BUSY never
* gets cleared in the non-waiting rewind case.
*/
if (bp->b_repcnt == 0 && (bp->b_flags&B_DONE))
break;
bp->b_flags |= B_WANTED;
sleep((caddr_t)bp, PRIBIO);
}
bp->b_flags = B_BUSY|B_READ;
splx(s);
bp->b_dev = dev;
bp->b_repcnt = count;
bp->b_command = com;
bp->b_blkno = 0;
cystrategy(bp);
/*
* In case of rewind from close; don't wait.
* This is the only case where count can be 0.
*/
if (count == 0)
return;
biowait(bp);
if (bp->b_flags&B_WANTED)
wakeup((caddr_t)bp);
bp->b_flags &= B_ERROR;
}
cystrategy(bp)
register struct buf *bp;
{
int ycunit = YCUNIT(bp->b_dev);
register struct vba_ctlr *vm;
register struct buf *dp;
int s;
/*
* Put transfer at end of unit queue.
*/
dlog((LOG_INFO, "cystrategy(%o, %x)\n", bp->b_dev, bp->b_command));
dp = &ycutab[ycunit];
bp->av_forw = NULL;
vm = ycdinfo[ycunit]->ui_mi;
/* BEGIN GROT */
if (bp->b_flags & B_RAW) {
if (bp->b_bcount >= CYMAXIO) {
uprintf("cy%d: i/o size too large\n", vm->um_ctlr);
bp->b_error = EINVAL;
bp->b_resid = bp->b_bcount;
bp->b_flags |= B_ERROR;
biodone(bp);
return;
}
}
/* END GROT */
s = spl3();
if (dp->b_actf == NULL) {
dp->b_actf = bp;
/*
* Transport not already active...
* put at end of controller queue.
*/
dp->b_forw = NULL;
if (vm->um_tab.b_actf == NULL)
vm->um_tab.b_actf = dp;
else
vm->um_tab.b_actl->b_forw = dp;
} else
dp->b_actl->av_forw = bp;
dp->b_actl = bp;
/*
* If the controller is not busy, get it going.
*/
if (vm->um_tab.b_active == 0)
cystart(vm);
splx(s);
}
/*
* Start activity on a cy controller.
*/
cystart(vm)
register struct vba_ctlr *vm;
{
register struct buf *bp, *dp;
register struct yc_softc *yc;
register struct cy_softc *cy;
int ycunit;
daddr_t blkno;
dlog((LOG_INFO, "cystart()\n"));
/*
* Look for an idle transport on the controller.
*/
loop:
if ((dp = vm->um_tab.b_actf) == NULL)
return;
if ((bp = dp->b_actf) == NULL) {
vm->um_tab.b_actf = dp->b_forw;
goto loop;
}
ycunit = YCUNIT(bp->b_dev);
yc = &yc_softc[ycunit];
cy = &cy_softc[CYUNIT(bp->b_dev)];
/*
* Default is that last command was NOT a write command;
* if we do a write command we will notice this in cyintr().
*/
yc->yc_lastiow = 0;
if (yc->yc_openf < 0 ||
(bp->b_command != CY_SENSE && (cy->cy_tpb.tpstatus&CYS_OL) == 0)) {
/*
* Have had a hard error on a non-raw tape
* or the tape unit is now unavailable (e.g.
* taken off line).
*/
dlog((LOG_INFO, "openf %d command %x status %b\n",
yc->yc_openf, bp->b_command, cy->cy_tpb.tpstatus, CYS_BITS));
bp->b_flags |= B_ERROR;
goto next;
}
if (bp == &ccybuf[CYUNIT(bp->b_dev)]) {
/*
* Execute control operation with the specified count.
*
* Set next state; give 5 minutes to complete
* rewind or file mark search, or 10 seconds per
* iteration (minimum 60 seconds and max 5 minutes)
* to complete other ops.
*/
if (bp->b_command == CY_REW) {
vm->um_tab.b_active = SREW;
yc->yc_timo = 5*60;
} else if (bp->b_command == CY_FSF ||
bp->b_command == CY_BSF) {
vm->um_tab.b_active = SCOM;
yc->yc_timo = 5*60;
} else {
vm->um_tab.b_active = SCOM;
yc->yc_timo = imin(imax(10*(int)bp->b_repcnt,60),5*60);
}
cy->cy_tpb.tprec = htoms(bp->b_repcnt);
dlog((LOG_INFO, "bpcmd "));
goto dobpcmd;
}
/*
* For raw I/O, save the current block
* number in case we have to retry.
*/
if (bp->b_flags & B_RAW) {
if (vm->um_tab.b_errcnt == 0) {
yc->yc_blkno = bp->b_blkno;
yc->yc_nxrec = yc->yc_blkno + 1;
}
} else {
/*
* Handle boundary cases for operation
* on non-raw tapes.
*/
if (bp->b_blkno > yc->yc_nxrec) {
/*
* Can't read past known end-of-file.
*/
bp->b_flags |= B_ERROR;
bp->b_error = ENXIO;
goto next;
}
if (bp->b_blkno == yc->yc_nxrec && bp->b_flags&B_READ) {
/*
* Reading at end of file returns 0 bytes.
*/
bp->b_resid = bp->b_bcount;
clrbuf(bp);
goto next;
}
if ((bp->b_flags&B_READ) == 0)
/*
* Writing sets EOF.
*/
yc->yc_nxrec = bp->b_blkno + 1;
}
if ((blkno = yc->yc_blkno) == bp->b_blkno) {
caddr_t addr;
int cmd;
/*
* Choose the appropriate i/o command based on the
* transfer size, the estimated block size,
* and the controller's internal buffer size.
* If the request length is longer than the tape
* block length, a buffered read will fail,
* thus, we request at most the size that we expect.
* We then check for larger records when the read completes.
* If we're retrying a read on a raw device because
* the original try was a buffer request which failed
* due to a record length error, then we force the use
* of the raw controller read (YECH!!!!).
*/
if (bp->b_flags&B_READ) {
if (yc->yc_blksize <= cy->cy_bs &&
vm->um_tab.b_errcnt == 0)
cmd = CY_BRCOM;
else
cmd = CY_RCOM;
} else {
/*
* On write error retries erase the
* inter-record gap before rewriting.
*/
if (vm->um_tab.b_errcnt &&
vm->um_tab.b_active != SERASED) {
vm->um_tab.b_active = SERASE;
bp->b_command = CY_ERASE;
yc->yc_timo = 60;
goto dobpcmd;
}
cmd = (bp->b_bcount > cy->cy_bs) ? CY_WCOM : CY_BWCOM;
}
vm->um_tab.b_active = SIO;
addr = (caddr_t)vbasetup(bp, &cy->cy_rbuf, 1);
cy->cy_tpb.tpcmd = cmd;
cy->cy_tpb.tpcontrol = yc->yc_dens;
if (cmd == CY_RCOM || cmd == CY_WCOM)
cy->cy_tpb.tpcontrol |= CYCW_LOCK;
cy->cy_tpb.tpstatus = 0;
cy->cy_tpb.tpcount = 0;
cyldmba(cy->cy_tpb.tpdata, (caddr_t)addr);
cy->cy_tpb.tprec = 0;
if (cmd == CY_BRCOM)
cy->cy_tpb.tpsize = htoms(imin(yc->yc_blksize,
(int)bp->b_bcount));
else
cy->cy_tpb.tpsize = htoms(bp->b_bcount);
cyldmba(cy->cy_tpb.tplink, (caddr_t)0);
do
uncache(&cy->cy_ccb.cbgate);
while (cy->cy_ccb.cbgate == GATE_CLOSED);
cyldmba(cy->cy_ccb.cbtpb, (caddr_t)&cy->cy_tpb);
cy->cy_ccb.cbcw = CBCW_IE;
cy->cy_ccb.cbgate = GATE_CLOSED;
dlog((LOG_INFO, "CY_GO(%x) cmd %x control %x size %d\n",
vm->um_addr, cy->cy_tpb.tpcmd, cy->cy_tpb.tpcontrol,
htoms(cy->cy_tpb.tpsize)));
CY_GO(vm->um_addr);
return;
}
/*
* Tape positioned incorrectly; set to seek forwards
* or backwards to the correct spot. This happens
* for raw tapes only on error retries.
*/
vm->um_tab.b_active = SSEEK;
if (blkno < bp->b_blkno) {
bp->b_command = CY_SFORW;
cy->cy_tpb.tprec = htoms(bp->b_blkno - blkno);
} else {
bp->b_command = CY_SREV;
cy->cy_tpb.tprec = htoms(blkno - bp->b_blkno);
}
yc->yc_timo = imin(imax((int)(10 * htoms(cy->cy_tpb.tprec)), 60), 5*60);
dobpcmd:
/*
* Do the command in bp. Reverse direction commands
* are indicated by having CYCW_REV or'd into their
* value. For these we must set the appropriate bit
* in the control field.
*/
if (bp->b_command&CYCW_REV) {
cy->cy_tpb.tpcmd = bp->b_command &~ CYCW_REV;
cy->cy_tpb.tpcontrol = yc->yc_dens | CYCW_REV;
dlog((LOG_INFO, "cmd %x control %x\n", cy->cy_tpb.tpcmd, cy->cy_tpb.tpcontrol));
} else {
cy->cy_tpb.tpcmd = bp->b_command;
cy->cy_tpb.tpcontrol = yc->yc_dens;
dlog((LOG_INFO, "cmd %x control %x\n", cy->cy_tpb.tpcmd, cy->cy_tpb.tpcontrol));
}
cy->cy_tpb.tpstatus = 0;
cy->cy_tpb.tpcount = 0;
cyldmba(cy->cy_tpb.tplink, (caddr_t)0);
do
uncache(&cy->cy_ccb.cbgate);
while (cy->cy_ccb.cbgate == GATE_CLOSED);
cyldmba(cy->cy_ccb.cbtpb, (caddr_t)&cy->cy_tpb);
cy->cy_ccb.cbcw = CBCW_IE;
cy->cy_ccb.cbgate = GATE_CLOSED;
dlog((LOG_INFO, "CY_GO(%x) cmd %x control %x rec %d\n",
vm->um_addr, cy->cy_tpb.tpcmd, cy->cy_tpb.tpcontrol,
htoms(cy->cy_tpb.tprec)));
CY_GO(vm->um_addr);
return;
next:
/*
* Done with this operation due to error or the
* fact that it doesn't do anything.
* Dequeue the transfer and continue
* processing this slave.
*/
vm->um_tab.b_errcnt = 0;
dp->b_actf = bp->av_forw;
biodone(bp);
goto loop;
}
/*
* Cy interrupt routine.
*/
cyintr(cyunit)
int cyunit;
{
struct buf *dp;
register struct buf *bp;
register struct vba_ctlr *vm = cyminfo[cyunit];
register struct cy_softc *cy;
register struct yc_softc *yc;
int err;
register state;
dlog((LOG_INFO, "cyintr(%d)\n", cyunit));
/*
* First, turn off the interrupt from the controller
* (device uses Multibus non-vectored interrupts...yech).
*/
cy = &cy_softc[vm->um_ctlr];
cy->cy_ccb.cbcw = CBCW_CLRINT;
cyldmba(cy->cy_ccb.cbtpb, (caddr_t)&cy->cy_nop);
cy->cy_ccb.cbgate = GATE_CLOSED;
CY_GO(vm->um_addr);
if ((dp = vm->um_tab.b_actf) == NULL) {
dlog((LOG_ERR, "cy%d: stray interrupt", vm->um_ctlr));
return;
}
bp = dp->b_actf;
cy = &cy_softc[cyunit];
cyuncachetpb(cy);
yc = &yc_softc[YCUNIT(bp->b_dev)];
/*
* If last command was a rewind and tape is
* still moving, wait for the operation to complete.
*/
if (vm->um_tab.b_active == SREW) {
vm->um_tab.b_active = SCOM;
if ((cy->cy_tpb.tpstatus&CYS_RDY) == 0) {
yc->yc_timo = 5*60; /* 5 minutes */
return;
}
}
/*
* An operation completed...record status.
*/
yc->yc_timo = INF;
yc->yc_control = cy->cy_tpb.tpcontrol;
yc->yc_status = cy->cy_tpb.tpstatus;
yc->yc_resid = bp->b_bcount - htoms(cy->cy_tpb.tpcount);
dlog((LOG_INFO, "cmd %x control %b status %b resid %d\n",
cy->cy_tpb.tpcmd, yc->yc_control, CYCW_BITS,
yc->yc_status, CYS_BITS, yc->yc_resid));
if ((bp->b_flags&B_READ) == 0)
yc->yc_lastiow = 1;
state = vm->um_tab.b_active;
vm->um_tab.b_active = 0;
/*
* Check for errors.
*/
if (cy->cy_tpb.tpstatus&CYS_ERR) {
err = cy->cy_tpb.tpstatus&CYS_ERR;
dlog((LOG_INFO, "error %d\n", err));
/*
* If we hit the end of tape file, update our position.
*/
if (err == CYER_FM) {
yc->yc_status |= CYS_FM;
state = SCOM; /* force completion */
cyseteof(bp); /* set blkno and nxrec */
goto opdone;
}
/*
* Fix up errors which occur due to backspacing over
* the beginning of the tape.
*/
if (err == CYER_BOT && cy->cy_tpb.tpcontrol&CYCW_REV) {
yc->yc_status |= CYS_BOT;
goto ignoreerr;
}
/*
* If we were reading raw tape and the only error was that the
* record was too long, then we don't consider this an error.
*/
if ((bp->b_flags & (B_READ|B_RAW)) == (B_READ|B_RAW) &&
err == CYER_STROBE) {
/*
* Retry reads with the command changed to
* a raw read if necessary. Setting b_errcnt
* here causes cystart (above) to force a CY_RCOM.
*/
if (cy->cy_tpb.tpcmd == CY_BRCOM &&
vm->um_tab.b_errcnt++ == 0) {
yc->yc_blkno++;
goto opcont;
} else
goto ignoreerr;
}
/*
* If error is not hard, and this was an i/o operation
* retry up to 8 times.
*/
if (state == SIO && (CYMASK(err) &
((bp->b_flags&B_READ) ? CYER_RSOFT : CYER_WSOFT))) {
if (++vm->um_tab.b_errcnt < 7) {
yc->yc_blkno++;
goto opcont;
}
} else
/*
* Hard or non-i/o errors on non-raw tape
* cause it to close.
*/
if ((bp->b_flags&B_RAW) == 0 &&
yc->yc_openf > 0)
yc->yc_openf = -1;
/*
* Couldn't recover from error.
*/
tprintf(yc->yc_tpr,
"yc%d: hard error bn%d status=%b, %s\n", YCUNIT(bp->b_dev),
bp->b_blkno, yc->yc_status, CYS_BITS,
(err < NCYERROR) ? cyerror[err] : "");
bp->b_flags |= B_ERROR;
goto opdone;
} else if (cy->cy_tpb.tpcmd == CY_BRCOM) {
int reclen = htoms(cy->cy_tpb.tprec);
/*
* If we did a buffered read, check whether the read
* was long enough. If we asked the controller for less
* than the user asked for because the previous record
* was shorter, update our notion of record size
* and retry. If the record is longer than the buffer,
* bump the errcnt so the retry will use direct read.
*/
if (reclen > yc->yc_blksize && bp->b_bcount > yc->yc_blksize) {
yc->yc_blksize = reclen;
if (reclen > cy->cy_bs)
vm->um_tab.b_errcnt++;
yc->yc_blkno++;
goto opcont;
}
}
/*
* Advance tape control FSM.
*/
ignoreerr:
/*
* If we hit a tape mark update our position.
*/
if (yc->yc_status&CYS_FM && bp->b_flags&B_READ) {
cyseteof(bp);
goto opdone;
}
switch (state) {
case SIO:
/*
* Read/write increments tape block number.
*/
yc->yc_blkno++;
yc->yc_blks++;
if (vm->um_tab.b_errcnt || yc->yc_status & CYS_CR)
yc->yc_softerrs++;
yc->yc_blksize = htoms(cy->cy_tpb.tpcount);
dlog((LOG_ERR, "blocksize %d", yc->yc_blksize));
goto opdone;
case SCOM:
/*
* For forward/backward space record update current position.
*/
if (bp == &ccybuf[CYUNIT(bp->b_dev)])
switch ((int)bp->b_command) {
case CY_SFORW:
yc->yc_blkno -= bp->b_repcnt;
break;
case CY_SREV:
yc->yc_blkno += bp->b_repcnt;
break;
}
goto opdone;
case SSEEK:
yc->yc_blkno = bp->b_blkno;
goto opcont;
case SERASE:
/*
* Completed erase of the inter-record gap due to a
* write error; now retry the write operation.
*/
vm->um_tab.b_active = SERASED;
goto opcont;
}
opdone:
/*
* Reset error count and remove from device queue.
*/
vm->um_tab.b_errcnt = 0;
dp->b_actf = bp->av_forw;
/*
* Save resid and release resources.
*/
bp->b_resid = bp->b_bcount - htoms(cy->cy_tpb.tpcount);
if (bp != &ccybuf[cyunit])
vbadone(bp, &cy->cy_rbuf);
biodone(bp);
/*
* Circulate slave to end of controller
* queue to give other slaves a chance.
*/
vm->um_tab.b_actf = dp->b_forw;
if (dp->b_actf) {
dp->b_forw = NULL;
if (vm->um_tab.b_actf == NULL)
vm->um_tab.b_actf = dp;
else
vm->um_tab.b_actl->b_forw = dp;
}
if (vm->um_tab.b_actf == 0)
return;
opcont:
cystart(vm);
}
cytimer(dev)
int dev;
{
register struct yc_softc *yc = &yc_softc[YCUNIT(dev)];
int s;
if (yc->yc_openf == 0 && yc->yc_timo == INF) {
yc->yc_tact = 0;
return;
}
if (yc->yc_timo != INF && (yc->yc_timo -= 5) < 0) {
printf("yc%d: lost interrupt\n", YCUNIT(dev));
yc->yc_timo = INF;
s = spl3();
cyintr(CYUNIT(dev));
splx(s);
}
timeout(cytimer, (caddr_t)dev, 5*hz);
}
cyseteof(bp)
register struct buf *bp;
{
register int cyunit = CYUNIT(bp->b_dev);
register struct cy_softc *cy = &cy_softc[cyunit];
register struct yc_softc *yc = &yc_softc[YCUNIT(bp->b_dev)];
if (bp == &ccybuf[cyunit]) {
if (yc->yc_blkno > bp->b_blkno) {
/* reversing */
yc->yc_nxrec = bp->b_blkno - htoms(cy->cy_tpb.tpcount);
yc->yc_blkno = yc->yc_nxrec;
} else {
yc->yc_blkno = bp->b_blkno + htoms(cy->cy_tpb.tpcount);
yc->yc_nxrec = yc->yc_blkno - 1;
}
return;
}
/* eof on read */
yc->yc_nxrec = bp->b_blkno;
}
/*ARGSUSED*/
cyioctl(dev, cmd, data, flag)
caddr_t data;
dev_t dev;
{
int ycunit = YCUNIT(dev);
register struct yc_softc *yc = &yc_softc[ycunit];
register struct buf *bp = &ccybuf[CYUNIT(dev)];
register callcount;
int fcount, op;
struct mtop *mtop;
struct mtget *mtget;
/* we depend of the values and order of the MT codes here */
static cyops[] =
{CY_WEOF,CY_FSF,CY_BSF,CY_SFORW,CY_SREV,CY_REW,CY_OFFL,CY_SENSE};
switch (cmd) {
case MTIOCTOP: /* tape operation */
mtop = (struct mtop *)data;
switch (op = mtop->mt_op) {
case MTWEOF:
callcount = mtop->mt_count;
fcount = 1;
break;
case MTFSR: case MTBSR:
callcount = 1;
fcount = mtop->mt_count;
break;
case MTFSF: case MTBSF:
callcount = mtop->mt_count;
fcount = 1;
break;
case MTREW: case MTOFFL: case MTNOP:
callcount = 1;
fcount = 1;
break;
default:
return (ENXIO);
}
if (callcount <= 0 || fcount <= 0)
return (EINVAL);
while (--callcount >= 0) {
#ifdef notdef
/*
* Gagh, this controller is the pits...
*/
if (op == MTFSF || op == MTBSF) {
do
cycommand(dev, cyops[op], 1);
while ((bp->b_flags&B_ERROR) == 0 &&
(yc->yc_status&(CYS_EOT|CYS_BOT|CYS_FM)) == 0);
} else
#endif
cycommand(dev, cyops[op], fcount);
dlog((LOG_INFO,
"cyioctl: status %x, b_flags %x, resid %d\n",
yc->yc_status, bp->b_flags, bp->b_resid));
if ((bp->b_flags&B_ERROR) ||
(yc->yc_status&(CYS_BOT|CYS_EOT)))
break;
}
bp->b_resid = callcount + 1;
/*
* Pick up the device's error number and pass it
* to the user; if there is an error but the number
* is 0 set a generalized code.
*/
if ((bp->b_flags & B_ERROR) == 0)
return (0);
if (bp->b_error)
return (bp->b_error);
return (EIO);
case MTIOCGET:
cycommand(dev, CY_SENSE, 1);
mtget = (struct mtget *)data;
mtget->mt_dsreg = yc->yc_status;
mtget->mt_erreg = yc->yc_control;
mtget->mt_resid = yc->yc_resid;
mtget->mt_type = MT_ISCY;
break;
default:
return (ENXIO);
}
return (0);
}
/*
* Poll until the controller is ready.
*/
cywait(cp)
register struct cyccb *cp;
{
register int i = 5000;
uncache(&cp->cbgate);
while (i-- > 0 && cp->cbgate == GATE_CLOSED) {
DELAY(1000);
uncache(&cp->cbgate);
}
return (i <= 0);
}
/*
* Load a 20 bit pointer into a Tapemaster pointer.
*/
cyldmba(reg, value)
register u_char *reg;
caddr_t value;
{
register int v = (int)value;
*reg++ = v;
*reg++ = v >> 8;
*reg++ = 0;
*reg = (v&0xf0000) >> 12;
}
/*
* Unconditionally reset all controllers to their initial state.
*/
cyreset(vba)
int vba;
{
register caddr_t addr;
register int ctlr;
for (ctlr = 0; ctlr < NCY; ctlr++)
if (cyminfo[ctlr] && cyminfo[ctlr]->um_vbanum == vba) {
addr = cyminfo[ctlr]->um_addr;
CY_RESET(addr);
if (!cyinit(ctlr, addr)) {
printf("cy%d: reset failed\n", ctlr);
cyminfo[ctlr] = NULL;
}
}
}
cyuncachetpb(cy)
struct cy_softc *cy;
{
register long *lp = (long *)&cy->cy_tpb;
register int i;
for (i = 0; i < howmany(sizeof (struct cytpb), sizeof (long)); i++)
uncache(lp++);
}
/*
* Dump routine.
*/
#define DUMPREC (32*1024)
cydump(dev)
dev_t dev;
{
register struct cy_softc *cy;
register int bs, num, start;
register caddr_t addr;
int unit = CYUNIT(dev), error;
if (unit >= NCY || cyminfo[unit] == 0 ||
(cy = &cy_softc[unit])->cy_bs == 0 || YCUNIT(dev) >= NYC)
return (ENXIO);
if (cywait(&cy->cy_ccb))
return (EFAULT);
#define phys(a) ((caddr_t)((int)(a)&~0xc0000000))
addr = phys(cyminfo[unit]->um_addr);
num = maxfree, start = NBPG*2;
while (num > 0) {
bs = num > btoc(DUMPREC) ? btoc(DUMPREC) : num;
error = cydwrite(cy, start, bs, addr);
if (error)
return (error);
start += bs, num -= bs;
}
cyweof(cy, addr);
cyweof(cy, addr);
uncache(&cy->cy_tpb);
if (cy->cy_tpb.tpstatus&CYS_ERR)
return (EIO);
cyrewind(cy, addr);
return (0);
}
cydwrite(cy, pf, npf, addr)
register struct cy_softc *cy;
int pf, npf;
caddr_t addr;
{
cy->cy_tpb.tpcmd = CY_WCOM;
cy->cy_tpb.tpcontrol = CYCW_LOCK|CYCW_25IPS|CYCW_16BITS;
cy->cy_tpb.tpstatus = 0;
cy->cy_tpb.tpsize = htoms(npf*NBPG);
cyldmba(cy->cy_tpb.tplink, (caddr_t)0);
cyldmba(cy->cy_tpb.tpdata, (caddr_t)(pf*NBPG));
cyldmba(cy->cy_ccb.cbtpb, (caddr_t)&cy->cy_tpb);
cy->cy_ccb.cbgate = GATE_CLOSED;
CY_GO(addr);
if (cywait(&cy->cy_ccb))
return (EFAULT);
uncache(&cy->cy_tpb);
if (cy->cy_tpb.tpstatus&CYS_ERR)
return (EIO);
return (0);
}
cyweof(cy, addr)
register struct cy_softc *cy;
caddr_t addr;
{
cy->cy_tpb.tpcmd = CY_WEOF;
cy->cy_tpb.tpcount = htoms(1);
cy->cy_ccb.cbgate = GATE_CLOSED;
CY_GO(addr);
(void) cywait(&cy->cy_ccb);
}
cyrewind(cy, addr)
register struct cy_softc *cy;
caddr_t addr;
{
cy->cy_tpb.tpcmd = CY_REW;
cy->cy_tpb.tpcount = htoms(1);
cy->cy_ccb.cbgate = GATE_CLOSED;
CY_GO(addr);
(void) cywait(&cy->cy_ccb);
}
#endif