Finally!!

The much roumored replacement for our current IDE/ATA/ATAPI is
materialising in the CVS repositories around the globe.

So what does this bring us:

A new reengineered ATA/ATAPI subsystem, that tries to overcome
most of the deficiencies with the current drivers.

It supports PCI as well as ISA devices without all the hackery
in ide_pci.c to make PCI devices look like ISA counterparts.

It doesn't have the excessive wait problem on probe, in fact you
shouldn't notice any delay when your devices are getting probed.

Probing and attaching of devices are postponed until interrupts
are enabled (well almost, not finished yet for disks), making
things alot cleaner.

Improved performance, although DMA support is still WIP and not
in this pre alpha release, worldstone is faster with the new
driver compared to the old even with DMA.

So what does it take away:

There is NO support for old MFM/RLL/ESDI disks.
There is NO support for bad144, if your disk is bad, ditch it, it has
already outgrown its internal spare sectors, and is dying.

For you to try this out, you will have to modify your kernel config
file to use the "ata" controller instead of all wdc? entries.

example:

# for a PCI only system (most modern machines)
controller 	ata0
device		atadisk0	# ATA disks
device		atapicd0	# ATAPI CDROM's
device		atapist0	# ATAPI tapes

#You should add the following on ISA systems:
controller	ata1	at isa? port "IO_WD1" bio irq 14
controller	ata2	at isa? port "IO_WD2" bio irq 15

You can leave it all in there, the system knows how to manage.

For now this driver reuses the device entries from the old system
(that will probably change later), but remember that disks are
now numbered in the sequence they are found (like the SCSI system)
not as absolute positions as the old system.

Although I have tested this on all the systems I can get my hands on,
there might very well be gremlins in there, so use AT YOU OWN RISK!!
This is still WIP, so there are lots of rough edges and unfinished
things in there, and what I have in my lab might look very different
from whats in CVS at any given time. So please have all eventual
changes go through me, or chances are they just dissapears...

I would very much like to hear from you, both good and bad news
are very welcome.

Enjoy!!

-Søren

1 files changed, 567 insertions, 0 deletions

diff --git a/sys/dev/ata/atapi-tape.c b/sys/dev/ata/atapi-tape.c
new file mode 100644
index 0000000..ea21e99
--- /dev/null
+++ b/sys/dev/ata/atapi-tape.c
@@ -0,0 +1,567 @@
+/*-
+ * 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.5 1999/03/01 21:03:15 sos Exp sos $
+ */
+
+#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/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_read_t    astread;
+static	d_write_t   astwrite;
+static  d_close_t   astclose;
+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 };
+
+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
+    t->cdevs = devfs_add_devswf(&ast_cdevsw, 0, DV_CHR, UID_ROOT, GID_OPERATOR,
+				0640, "rast%d", t->lun);
+#endif /* DEVFS */
+    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");
+}
+
+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);
+}
+
+int32_t 
+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));
+}
+
+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_long 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) {
+	printf("ast_done: ");
+        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);
+}
+
+int32_t 
+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 int
+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))){
+	printf("ast_space_cmd: ");
+        atapi_error(stp->atp, error);
+        return EIO;
+    }
+    return 0;
+}
+
+static int
+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))){
+	printf("ast_write_filemark: ");
+        atapi_error(stp->atp, error);
+        return EIO;
+    }
+    return 0;
+}
+
+static int
+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))){
+	printf("ast_load_unload: ");
+        atapi_error(stp->atp, error);
+        return EIO;
+    }
+    return 0;
+}
+
+static int
+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))){
+	printf("ast_erase: ");
+        atapi_error(stp->atp, error);
+        return EIO;
+    }
+    return 0;
+}
+
+static int
+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))){
+	printf("ast_rewind: ");
+        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 */