989fb3947c
reports on those most welcome!
Fixed problems:
Hang on probe on "fantom" devices.
The probe now use a timeout to avoid hangs if no interrupt
is recevied.
There has also been more general code clenaups, and some reorgs.
564 lines
16 KiB
C
564 lines
16 KiB
C
/*-
|
|
* Copyright (c) 1998,1999 Søren Schmidt
|
|
* All rights reserved.
|
|
*
|
|
* 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,
|
|
* without modification, immediately at the beginning of the file.
|
|
* 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. The name of the author may not be used to endorse or promote products
|
|
* derived from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``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 AUTHOR 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.
|
|
*
|
|
* $Id: atapi-tape.c,v 1.3 1999/03/05 09:43:30 sos Exp $
|
|
*/
|
|
|
|
#include "ata.h"
|
|
#include "atapist.h"
|
|
#include "opt_devfs.h"
|
|
|
|
#if NATA > 0 && NATAPIST > 0
|
|
|
|
#include <sys/param.h>
|
|
#include <sys/systm.h>
|
|
#include <sys/kernel.h>
|
|
#include <sys/conf.h>
|
|
#include <sys/malloc.h>
|
|
#include <sys/buf.h>
|
|
#include <sys/mtio.h>
|
|
#include <sys/disklabel.h>
|
|
#include <sys/devicestat.h>
|
|
#ifdef DEVFS
|
|
#include <sys/devfsext.h>
|
|
#endif
|
|
#include <machine/clock.h>
|
|
#include <dev/ata/ata-all.h>
|
|
#include <dev/ata/atapi-all.h>
|
|
#include <dev/ata/atapi-tape.h>
|
|
|
|
static d_open_t astopen;
|
|
static d_close_t astclose;
|
|
static d_read_t astread;
|
|
static d_write_t astwrite;
|
|
static d_ioctl_t astioctl;
|
|
static d_strategy_t aststrategy;
|
|
|
|
#define CDEV_MAJOR 90
|
|
#define BDEV_MAJOR 24
|
|
|
|
static struct cdevsw ast_cdevsw = {
|
|
astopen, astclose, astread, astwrite,
|
|
astioctl, nostop, nullreset, nodevtotty,
|
|
seltrue, nommap, aststrategy, "ast",
|
|
NULL, -1, nodump, nopsize,
|
|
D_TAPE, 0, -1
|
|
};
|
|
|
|
static u_int32_t ast_total = 0;
|
|
|
|
#define NUNIT 8
|
|
#define UNIT(d) ((minor(d) >> 3) & 3)
|
|
|
|
#define F_OPEN 0x0001 /* The device is opened */
|
|
#define F_MEDIA_CHANGED 0x0002 /* The media have changed */
|
|
#define F_DATA_WRITTEN 0x0004 /* Data has been written */
|
|
#define F_FM_WRITTEN 0x0008 /* Filemark has been written */
|
|
#define F_CTL_WARN 0x0010 /* Have we warned about CTL wrong? */
|
|
|
|
static struct ast_softc *asttab[NUNIT]; /* Drive info by unit number */
|
|
static int32_t astnlun = 0; /* Number of config'd drives */
|
|
|
|
int32_t astattach(struct atapi_softc *);
|
|
static int32_t ast_sense(struct ast_softc *);
|
|
static void ast_describe(struct ast_softc *);
|
|
static void ast_start(struct ast_softc *);
|
|
static void ast_done(struct atapi_request *);
|
|
static void ast_drvinit(void *);
|
|
static int32_t ast_space_cmd(struct ast_softc *, u_int8_t, u_int32_t);
|
|
static int32_t ast_write_filemark(struct ast_softc *, u_int8_t);
|
|
static int32_t ast_erase(struct ast_softc *);
|
|
static int32_t ast_load_unload(struct ast_softc *, u_int8_t);
|
|
static int32_t ast_rewind(struct ast_softc *);
|
|
|
|
int32_t
|
|
astattach(struct atapi_softc *atp)
|
|
{
|
|
struct ast_softc *stp;
|
|
|
|
if (astnlun >= NUNIT) {
|
|
printf("ast: too many units\n");
|
|
return -1;
|
|
}
|
|
stp = malloc(sizeof(struct ast_softc), M_TEMP, M_NOWAIT);
|
|
if (!stp) {
|
|
printf("ast: out of memory\n");
|
|
return -1;
|
|
}
|
|
bzero(stp, sizeof(struct ast_softc));
|
|
bufq_init(&stp->buf_queue);
|
|
stp->atp = atp;
|
|
stp->lun = astnlun;
|
|
stp->flags = F_MEDIA_CHANGED;
|
|
|
|
if (ast_sense(stp)) {
|
|
free(stp, M_TEMP);
|
|
return -1;
|
|
}
|
|
|
|
ast_describe(stp);
|
|
asttab[astnlun++] = stp;
|
|
devstat_add_entry(&stp->stats, "ast", stp->lun, DEV_BSIZE,
|
|
DEVSTAT_NO_ORDERED_TAGS,
|
|
DEVSTAT_TYPE_SEQUENTIAL | DEVSTAT_TYPE_IF_IDE,
|
|
0x178);
|
|
#ifdef DEVFS
|
|
stp->cdevs_token = devfs_add_devswf(&ast_cdevsw, dkmakeminor(stp->lun, 0,0),
|
|
DV_CHR, UID_ROOT, GID_OPERATOR, 0640,
|
|
"rast%d", stp->lun);
|
|
#endif
|
|
return 0;
|
|
}
|
|
|
|
static int32_t
|
|
ast_sense(struct ast_softc *stp)
|
|
{
|
|
int32_t error, count;
|
|
int8_t buffer[256];
|
|
int8_t ccb[16] = { ATAPI_TAPE_MODE_SENSE,
|
|
8, /* DBD = 1 no block descr */
|
|
ATAPI_TAPE_CAP_PAGE,
|
|
sizeof(buffer)>>8, sizeof(buffer) & 0xff,
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
|
|
|
|
bzero(buffer, sizeof(buffer));
|
|
/* Get drive capabilities, some drives needs this repeated */
|
|
for (count = 0 ; count < 5 ; count++) {
|
|
if (!(error = atapi_queue_cmd(stp->atp, ccb, buffer, sizeof(buffer),
|
|
A_READ, NULL, NULL, NULL)))
|
|
break;
|
|
}
|
|
#ifdef AST_DEBUG
|
|
atapi_dump("ast: sense", buffer, sizeof(buffer));
|
|
#endif
|
|
if (error)
|
|
return error;
|
|
bcopy(buffer, &stp->header, sizeof(struct ast_header));
|
|
bcopy(buffer+sizeof(struct ast_header), &stp->cap,
|
|
sizeof(struct ast_cappage));
|
|
if (stp->cap.page_code != ATAPI_TAPE_CAP_PAGE)
|
|
return 1;
|
|
stp->cap.max_speed = ntohs(stp->cap.max_speed);
|
|
stp->cap.max_defects = ntohs(stp->cap.max_defects);
|
|
stp->cap.ctl = ntohs(stp->cap.ctl);
|
|
stp->cap.speed = ntohs(stp->cap.speed);
|
|
stp->cap.buffer_size = ntohs(stp->cap.buffer_size);
|
|
stp->blksize = (stp->cap.blk512 ? 512 : (stp->cap.blk1024 ? 1024 : 0));
|
|
return 0;
|
|
}
|
|
|
|
static void
|
|
ast_describe(struct ast_softc *stp)
|
|
{
|
|
int8_t model_buf[40+1];
|
|
int8_t revision_buf[8+1];
|
|
|
|
bpack(stp->atp->atapi_parm->model, model_buf, sizeof(model_buf));
|
|
bpack(stp->atp->atapi_parm->revision, revision_buf, sizeof(revision_buf));
|
|
printf("ast%d: <%s/%s> tape drive at ata%d as %s\n",
|
|
stp->lun, model_buf, revision_buf,
|
|
stp->atp->controller->unit,
|
|
(stp->atp->unit == ATA_MASTER) ? "master" : "slave ");
|
|
printf("ast%d: ", stp->lun);
|
|
switch (stp->header.medium_type) {
|
|
case 0x00: printf("Drive empty"); break;
|
|
case 0x17: printf("Travan 1 (400 Mbyte) media"); break;
|
|
case 0xb6: printf("Travan 4 (4 Gbyte) media"); break;
|
|
default: printf("Unknown media (0x%x)", stp->header.medium_type);
|
|
}
|
|
if (stp->cap.readonly) printf(", readonly");
|
|
if (stp->cap.reverse) printf(", reverse");
|
|
if (stp->cap.eformat) printf(", eformat");
|
|
if (stp->cap.qfa) printf(", qfa");
|
|
if (stp->cap.lock) printf(", lock");
|
|
if (stp->cap.locked) printf(", locked");
|
|
if (stp->cap.prevent) printf(", prevent");
|
|
if (stp->cap.eject) printf(", eject");
|
|
if (stp->cap.disconnect) printf(", disconnect");
|
|
if (stp->cap.ecc) printf(", ecc");
|
|
if (stp->cap.compress) printf(", compress");
|
|
if (stp->cap.blk512) printf(", 512b");
|
|
if (stp->cap.blk1024) printf(", 1024b");
|
|
if (stp->cap.slowb) printf(", slowb");
|
|
printf("\nast%d: ", stp->lun);
|
|
printf("Max speed=%dKb/s, ", stp->cap.max_speed);
|
|
printf("Transfer limit=%d blocks, ", stp->cap.ctl);
|
|
printf("Buffer size=%d blocks", stp->cap.buffer_size);
|
|
printf("\n");
|
|
}
|
|
|
|
static int
|
|
astopen(dev_t dev, int32_t flags, int32_t fmt, struct proc *p)
|
|
{
|
|
int32_t lun = UNIT(dev);
|
|
struct ast_softc *stp;
|
|
|
|
if (lun >= astnlun || !(stp = asttab[lun]))
|
|
return ENXIO;
|
|
if (stp->flags == F_OPEN)
|
|
return EBUSY;
|
|
if (ast_sense(stp))
|
|
printf("ast%d: sense media type failed\n", stp->lun);
|
|
stp->flags &= ~F_MEDIA_CHANGED;
|
|
stp->flags &= ~(F_DATA_WRITTEN | F_FM_WRITTEN);
|
|
stp->flags |= F_OPEN;
|
|
ast_total = 0;
|
|
return 0;
|
|
}
|
|
|
|
static int
|
|
astclose(dev_t dev, int32_t flags, int32_t fmt, struct proc *p)
|
|
{
|
|
int32_t lun = UNIT(dev);
|
|
struct ast_softc *stp;
|
|
|
|
if (lun >= astnlun || !(stp = asttab[lun]))
|
|
return ENXIO;
|
|
|
|
/* Flush buffers, some drives fail here, but they should report ctl = 0 */
|
|
if (stp->cap.ctl && (stp->flags & F_DATA_WRITTEN))
|
|
ast_write_filemark(stp, 0);
|
|
|
|
/* Write filemark if data written to tape */
|
|
if ((stp->flags & (F_DATA_WRITTEN | F_FM_WRITTEN)) == F_DATA_WRITTEN)
|
|
ast_write_filemark(stp, WEOF_WRITE_MASK);
|
|
|
|
/* If minor is even rewind on close */
|
|
if (!(minor(dev) & 0x01))
|
|
ast_rewind(stp);
|
|
|
|
stp->flags &= ~F_OPEN;
|
|
#ifdef AST_DEBUG
|
|
printf("ast%d: %ud total bytes transferred\n", stp->lun, ast_total);
|
|
#endif
|
|
stp->flags &= ~F_CTL_WARN;
|
|
return 0;
|
|
}
|
|
|
|
static int
|
|
astread(dev_t dev, struct uio *uio, int32_t ioflag)
|
|
{
|
|
return physio(aststrategy, NULL, dev, 1, minphys, uio);
|
|
}
|
|
|
|
static int
|
|
astwrite(dev_t dev, struct uio *uio, int32_t ioflag)
|
|
{
|
|
return physio(aststrategy, NULL, dev, 0, minphys, uio);
|
|
}
|
|
|
|
static int
|
|
astioctl(dev_t dev, u_long cmd, caddr_t addr, int32_t flag, struct proc *p)
|
|
{
|
|
int32_t lun = UNIT(dev);
|
|
int32_t error = 0;
|
|
struct ast_softc *stp;
|
|
|
|
if (lun >= astnlun || !(stp = asttab[lun]))
|
|
return ENXIO;
|
|
|
|
switch (cmd) {
|
|
case MTIOCGET:
|
|
{
|
|
struct mtget *g = (struct mtget *) addr;
|
|
|
|
bzero(g, sizeof(struct mtget));
|
|
g->mt_type = 7;
|
|
g->mt_density = 1;
|
|
g->mt_blksiz = stp->blksize;
|
|
g->mt_comp = stp->cap.compress;
|
|
g->mt_density0 = 0; g->mt_density1 = 0;
|
|
g->mt_density2 = 0; g->mt_density3 = 0;
|
|
g->mt_blksiz0 = 0; g->mt_blksiz1 = 0;
|
|
g->mt_blksiz2 = 0; g->mt_blksiz3 = 0;
|
|
g->mt_comp0 = 0; g->mt_comp1 = 0;
|
|
g->mt_comp2 = 0; g->mt_comp3 = 0;
|
|
break;
|
|
}
|
|
case MTIOCTOP:
|
|
{
|
|
int32_t i;
|
|
struct mtop *mt = (struct mtop *)addr;
|
|
|
|
switch ((int16_t) (mt->mt_op)) {
|
|
case MTWEOF:
|
|
for (i=0; i < mt->mt_count && !error; i++)
|
|
error = ast_write_filemark(stp, WEOF_WRITE_MASK);
|
|
break;
|
|
case MTFSF:
|
|
if (mt->mt_count)
|
|
error = ast_space_cmd(stp, SP_FM, mt->mt_count);
|
|
break;
|
|
case MTBSF:
|
|
if (mt->mt_count)
|
|
error = ast_space_cmd(stp, SP_FM, -(mt->mt_count));
|
|
break;
|
|
case MTFSR:
|
|
error = EINVAL; break;
|
|
case MTBSR:
|
|
error = EINVAL; break;
|
|
case MTREW:
|
|
error = ast_rewind(stp);
|
|
break;
|
|
case MTOFFL:
|
|
if ((error = ast_rewind(stp)))
|
|
break;
|
|
error = ast_load_unload(stp, !LU_LOAD_MASK);
|
|
break;
|
|
case MTNOP:
|
|
error = ast_write_filemark(stp, 0);
|
|
break;
|
|
case MTCACHE:
|
|
error = EINVAL; break;
|
|
case MTNOCACHE:
|
|
error = EINVAL; break;
|
|
case MTSETBSIZ:
|
|
error = EINVAL; break;
|
|
case MTSETDNSTY:
|
|
error = EINVAL; break;
|
|
case MTERASE:
|
|
error = ast_erase(stp);
|
|
break;
|
|
case MTEOD:
|
|
error = ast_space_cmd(stp, SP_EOD, 0);
|
|
break;
|
|
case MTCOMP:
|
|
error = EINVAL; break;
|
|
case MTRETENS:
|
|
error = ast_load_unload(stp, LU_RETENSION_MASK|LU_LOAD_MASK);
|
|
break;
|
|
default:
|
|
error = EINVAL;
|
|
}
|
|
return error;
|
|
}
|
|
default:
|
|
return ENOTTY;
|
|
}
|
|
return error;
|
|
}
|
|
|
|
static void
|
|
aststrategy(struct buf *bp)
|
|
{
|
|
int32_t lun = UNIT(bp->b_dev);
|
|
struct ast_softc *stp = asttab[lun];
|
|
int32_t x;
|
|
|
|
/* If it's a null transfer, return immediatly. */
|
|
if (bp->b_bcount == 0) {
|
|
bp->b_resid = 0;
|
|
biodone(bp);
|
|
return;
|
|
}
|
|
|
|
/* Check for != blocksize requests */
|
|
if (bp->b_bcount % stp->blksize) {
|
|
printf("ast%d: bad request, must be multiple of %d\n",
|
|
lun, stp->blksize);
|
|
bp->b_error = EIO;
|
|
bp->b_flags |= B_ERROR;
|
|
biodone(bp);
|
|
return;
|
|
}
|
|
if (bp->b_bcount > stp->blksize * stp->cap.ctl) {
|
|
if ((stp->flags & F_CTL_WARN) == 0) {
|
|
printf("ast%d: WARNING: CTL exceeded %ld>%d\n",
|
|
lun, bp->b_bcount, stp->blksize * stp->cap.ctl);
|
|
stp->flags |= F_CTL_WARN;
|
|
}
|
|
}
|
|
|
|
x = splbio();
|
|
ast_total += bp->b_bcount;
|
|
bufq_insert_tail(&stp->buf_queue, bp);
|
|
ast_start(stp);
|
|
splx(x);
|
|
}
|
|
|
|
static void
|
|
ast_start(struct ast_softc *stp)
|
|
{
|
|
struct buf *bp = bufq_first(&stp->buf_queue);
|
|
u_int32_t blkcount;
|
|
int8_t ccb[16];
|
|
|
|
if (!bp)
|
|
return;
|
|
bzero(ccb, sizeof(ccb));
|
|
bufq_remove(&stp->buf_queue, bp);
|
|
blkcount = bp->b_bcount / stp->blksize;
|
|
if (bp->b_flags & B_READ) {
|
|
ccb[0] = ATAPI_TAPE_READ_CMD;
|
|
} else {
|
|
ccb[0] = ATAPI_TAPE_WRITE_CMD;
|
|
stp->flags |= F_DATA_WRITTEN;
|
|
}
|
|
ccb[1] = 1;
|
|
ccb[2] = blkcount>>16;
|
|
ccb[3] = blkcount>>8;
|
|
ccb[4] = blkcount;
|
|
|
|
devstat_start_transaction(&stp->stats);
|
|
|
|
atapi_queue_cmd(stp->atp, ccb, bp->b_data, bp->b_bcount,
|
|
(bp->b_flags & B_READ) ? A_READ : 0, ast_done, stp, bp);
|
|
}
|
|
|
|
static void
|
|
ast_done(struct atapi_request *request)
|
|
{
|
|
struct buf *bp = request->bp;
|
|
struct ast_softc *stp = request->driver;
|
|
|
|
devstat_end_transaction(&stp->stats, bp->b_bcount-request->bytecount,
|
|
DEVSTAT_TAG_NONE,
|
|
(bp->b_flags&B_READ) ? DEVSTAT_READ:DEVSTAT_WRITE);
|
|
|
|
if (request->result) {
|
|
atapi_error(request->device, request->result);
|
|
bp->b_error = EIO;
|
|
bp->b_flags |= B_ERROR;
|
|
}
|
|
else
|
|
bp->b_resid = request->bytecount;
|
|
biodone(bp);
|
|
ast_start(stp);
|
|
}
|
|
|
|
static int32_t
|
|
ast_space_cmd(struct ast_softc *stp, u_int8_t function, u_int32_t count)
|
|
{
|
|
int32_t error;
|
|
int8_t ccb[16];
|
|
|
|
bzero(ccb, sizeof(ccb));
|
|
ccb[0] = ATAPI_TAPE_SPACE_CMD;
|
|
ccb[1] = function;
|
|
ccb[2] = count>>16;
|
|
ccb[3] = count>>8;
|
|
ccb[4] = count;
|
|
|
|
if ((error = atapi_queue_cmd(stp->atp, ccb, NULL, 0, 0, NULL, NULL, NULL))){
|
|
atapi_error(stp->atp, error);
|
|
return EIO;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int32_t
|
|
ast_write_filemark(struct ast_softc *stp, u_int8_t function)
|
|
{
|
|
int32_t error;
|
|
int8_t ccb[16];
|
|
|
|
if (function) {
|
|
if (stp->flags & F_FM_WRITTEN)
|
|
stp->flags &= ~F_DATA_WRITTEN;
|
|
else
|
|
stp->flags |= F_FM_WRITTEN;
|
|
}
|
|
bzero(ccb, sizeof(ccb));
|
|
ccb[0] = ATAPI_TAPE_WEOF;
|
|
ccb[4] = function;
|
|
|
|
if ((error = atapi_queue_cmd(stp->atp, ccb, NULL, 0, 0, NULL, NULL, NULL))){
|
|
atapi_error(stp->atp, error);
|
|
return EIO;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int32_t
|
|
ast_load_unload(struct ast_softc *stp, u_int8_t function)
|
|
{
|
|
int32_t error;
|
|
int8_t ccb[16];
|
|
|
|
bzero(ccb, sizeof(ccb));
|
|
ccb[0] = ATAPI_TAPE_LOAD_UNLOAD;
|
|
ccb[4] = function;
|
|
|
|
if ((error = atapi_queue_cmd(stp->atp, ccb, NULL, 0, 0, NULL, NULL, NULL))){
|
|
atapi_error(stp->atp, error);
|
|
return EIO;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int32_t
|
|
ast_erase(struct ast_softc *stp)
|
|
{
|
|
int32_t error;
|
|
int8_t ccb[16];
|
|
|
|
if ((error = ast_rewind(stp)))
|
|
return error;
|
|
|
|
bzero(ccb, sizeof(ccb));
|
|
ccb[0] = ATAPI_TAPE_ERASE;
|
|
ccb[1] = 3;
|
|
|
|
if ((error = atapi_queue_cmd(stp->atp, ccb, NULL, 0, 0, NULL, NULL, NULL))){
|
|
atapi_error(stp->atp, error);
|
|
return EIO;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int32_t
|
|
ast_rewind(struct ast_softc *stp)
|
|
{
|
|
int32_t error;
|
|
int8_t ccb[16];
|
|
|
|
bzero(ccb, sizeof(ccb));
|
|
ccb[0] = ATAPI_TAPE_REWIND;
|
|
|
|
if ((error = atapi_queue_cmd(stp->atp, ccb, NULL, 0, 0, NULL, NULL, NULL))){
|
|
atapi_error(stp->atp, error);
|
|
return EIO;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static void
|
|
ast_drvinit(void *unused)
|
|
{
|
|
static ast_devsw_installed = 0;
|
|
|
|
if (!ast_devsw_installed) {
|
|
dev_t dev = makedev(CDEV_MAJOR, 0);
|
|
|
|
cdevsw_add(&dev, &ast_cdevsw, NULL);
|
|
ast_devsw_installed = 1;
|
|
}
|
|
}
|
|
|
|
SYSINIT(astdev, SI_SUB_DRIVERS, SI_ORDER_MIDDLE, ast_drvinit, NULL)
|
|
#endif /* NATA & NATAPIST */
|