dadk.c revision fa9e4066f08beec538e775443c5be79dd423fcab
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
* or http://www.opensolaris.org/os/licensing.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at usr/src/OPENSOLARIS.LICENSE.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information: Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*/
/*
* Copyright 2005 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#pragma ident "%Z%%M% %I% %E% SMI"
/*
* Direct Attached Disk
*/
#include <sys/file.h>
#include <sys/scsi/scsi.h>
#include <sys/var.h>
#include <sys/proc.h>
#include <sys/dktp/cm.h>
#include <sys/vtoc.h>
#include <sys/dkio.h>
#include <sys/dktp/dadev.h>
#include <sys/dktp/fctypes.h>
#include <sys/dktp/flowctrl.h>
#include <sys/dktp/tgcom.h>
#include <sys/dktp/tgdk.h>
#include <sys/dktp/bbh.h>
#include <sys/dktp/dadkio.h>
#include <sys/dktp/dadk.h>
#include <sys/cdio.h>
/*
* Local Function Prototypes
*/
static void dadk_restart(void *pktp);
static void dadk_pktcb(struct cmpkt *pktp);
static void dadk_iodone(struct buf *bp);
static void dadk_polldone(struct buf *bp);
static void dadk_setcap(struct dadk *dadkp);
static int dadk_chkerr(struct cmpkt *pktp);
static int dadk_ioprep(struct dadk *dadkp, struct cmpkt *pktp);
static int dadk_iosetup(struct dadk *dadkp, struct cmpkt *pktp);
static int dadk_ioretry(struct cmpkt *pktp, int action);
static struct cmpkt *dadk_pktprep(struct dadk *dadkp, struct cmpkt *in_pktp,
struct buf *bp, void (*cb_func)(struct buf *), int (*func)(caddr_t),
caddr_t arg);
static int dadk_pkt(opaque_t com_data, struct buf *bp, int (*func)(caddr_t),
caddr_t arg);
static void dadk_transport(opaque_t com_data, struct buf *bp);
struct tgcom_objops dadk_com_ops = {
nodev,
nodev,
dadk_pkt,
dadk_transport,
0, 0
};
static int dadk_rmb_ioctl(struct dadk *dadkp, int cmd, intptr_t arg, int flags,
int silent);
static void dadk_rmb_iodone(struct buf *bp);
static int dadk_dk_buf_setup(struct dadk *dadkp, opaque_t *cmdp,
dev_t dev, enum uio_seg dataspace, int rw);
static void dadk_dk(struct dadk *dadkp, struct dadkio_rwcmd *scmdp,
struct buf *bp);
static void dadkmin(struct buf *bp);
static int dadk_dk_strategy(struct buf *bp);
static void dadk_recorderr(struct cmpkt *pktp, struct dadkio_rwcmd *rwcmdp);
struct tgdk_objops dadk_ops = {
dadk_init,
dadk_free,
dadk_probe,
dadk_attach,
dadk_open,
dadk_close,
dadk_ioctl,
dadk_strategy,
dadk_setgeom,
dadk_getgeom,
dadk_iob_alloc,
dadk_iob_free,
dadk_iob_htoc,
dadk_iob_xfer,
dadk_dump,
dadk_getphygeom,
dadk_set_bbhobj,
dadk_check_media,
dadk_inquiry,
dadk_cleanup,
0
};
/*
* Local static data
*/
#ifdef DADK_DEBUG
#define DENT 0x0001
#define DERR 0x0002
#define DIO 0x0004
#define DGEOM 0x0010
#define DSTATE 0x0020
static int dadk_debug = DGEOM;
#endif /* DADK_DEBUG */
static int dadk_check_media_time = 3000000; /* 3 Second State Check */
static int dadk_dk_maxphys = 0x80000;
static char *dadk_cmds[] = {
"\000Unknown", /* unknown */
"\001read sector", /* DCMD_READ 1 */
"\002write sector", /* DCMD_WRITE 2 */
"\003format track", /* DCMD_FMTTRK 3 */
"\004format whole drive", /* DCMD_FMTDRV 4 */
"\005recalibrate", /* DCMD_RECAL 5 */
"\006seek sector", /* DCMD_SEEK 6 */
"\007read verify", /* DCMD_RDVER 7 */
"\010read defect list", /* DCMD_GETDEF 8 */
"\011lock door", /* DCMD_LOCK 9 */
"\012unlock door", /* DCMD_UNLOCK 10 */
"\013start motor", /* DCMD_START_MOTOR 11 */
"\014stop motor", /* DCMD_STOP_MOTOR 12 */
"\015eject", /* DCMD_EJECT 13 */
"\016update geometry", /* DCMD_UPDATE_GEOM 14 */
"\017get state", /* DCMD_GET_STATE 15 */
"\020cdrom pause", /* DCMD_PAUSE 16 */
"\021cdrom resume", /* DCMD_RESUME 17 */
"\022cdrom play track index", /* DCMD_PLAYTRKIND 18 */
"\023cdrom play msf", /* DCMD_PLAYMSF 19 */
"\024cdrom sub channel", /* DCMD_SUBCHNL 20 */
"\025cdrom read mode 1", /* DCMD_READMODE1 21 */
"\026cdrom read toc header", /* DCMD_READTOCHDR 22 */
"\027cdrom read toc entry", /* DCMD_READTOCENT 23 */
"\030cdrom read offset", /* DCMD_READOFFSET 24 */
"\031cdrom read mode 2", /* DCMD_READMODE2 25 */
"\032cdrom volume control", /* DCMD_VOLCTRL 26 */
"\033flush cache", /* DCMD_FLUSH_CACHE 27 */
NULL
};
static char *dadk_sense[] = {
"\000Success", /* DERR_SUCCESS */
"\001address mark not found", /* DERR_AMNF */
"\002track 0 not found", /* DERR_TKONF */
"\003aborted command", /* DERR_ABORT */
"\004write fault", /* DERR_DWF */
"\005ID not found", /* DERR_IDNF */
"\006drive busy", /* DERR_BUSY */
"\007uncorrectable data error", /* DERR_UNC */
"\010bad block detected", /* DERR_BBK */
"\011invalid command", /* DERR_INVCDB */
"\012device hard error", /* DERR_HARD */
"\013illegal length indicated", /* DERR_ILI */
"\014end of media", /* DERR_EOM */
"\015media change requested", /* DERR_MCR */
"\016recovered from error", /* DERR_RECOVER */
"\017device not ready", /* DERR_NOTREADY */
"\020medium error", /* DERR_MEDIUM */
"\021hardware error", /* DERR_HW */
"\022illegal request", /* DERR_ILL */
"\023unit attention", /* DERR_UNIT_ATTN */
"\024data protection", /* DERR_DATA_PROT */
"\025miscompare", /* DERR_MISCOMPARE */
"\026reserved", /* DERR_RESV */
NULL
};
static char *dadk_name = "Disk";
/*
* This is the loadable module wrapper
*/
#include <sys/modctl.h>
extern struct mod_ops mod_miscops;
static struct modlmisc modlmisc = {
&mod_miscops, /* Type of module */
"Direct Attached Disk %I%"
};
static struct modlinkage modlinkage = {
MODREV_1, (void *)&modlmisc, NULL
};
int
_init(void)
{
#ifdef DADK_DEBUG
if (dadk_debug & DENT)
PRF("dadk_init: call\n");
#endif
return (mod_install(&modlinkage));
}
int
_fini(void)
{
#ifdef DADK_DEBUG
if (dadk_debug & DENT)
PRF("dadk_fini: call\n");
#endif
return (mod_remove(&modlinkage));
}
int
_info(struct modinfo *modinfop)
{
return (mod_info(&modlinkage, modinfop));
}
struct tgdk_obj *
dadk_create()
{
struct tgdk_obj *dkobjp;
struct dadk *dadkp;
dkobjp = kmem_zalloc((sizeof (*dkobjp) + sizeof (*dadkp)), KM_NOSLEEP);
if (!dkobjp)
return (NULL);
dadkp = (struct dadk *)(dkobjp+1);
dkobjp->tg_ops = (struct tgdk_objops *)&dadk_ops;
dkobjp->tg_data = (opaque_t)dadkp;
dkobjp->tg_ext = &(dkobjp->tg_extblk);
dadkp->dad_extp = &(dkobjp->tg_extblk);
#ifdef DADK_DEBUG
if (dadk_debug & DENT)
PRF("dadk_create: tgdkobjp= 0x%x dadkp= 0x%x\n", dkobjp, dadkp);
#endif
return (dkobjp);
}
int
dadk_init(opaque_t objp, opaque_t devp, opaque_t flcobjp, opaque_t queobjp,
opaque_t bbhobjp, void *lkarg)
{
struct dadk *dadkp = (struct dadk *)objp;
struct scsi_device *sdevp = (struct scsi_device *)devp;
dadkp->dad_sd = devp;
dadkp->dad_ctlobjp = (opaque_t)sdevp->sd_address.a_hba_tran;
sdevp->sd_private = (caddr_t)dadkp;
/* initialize the communication object */
dadkp->dad_com.com_data = (opaque_t)dadkp;
dadkp->dad_com.com_ops = &dadk_com_ops;
dadkp->dad_bbhobjp = bbhobjp;
BBH_INIT(bbhobjp);
dadkp->dad_flcobjp = flcobjp;
return (FLC_INIT(flcobjp, &(dadkp->dad_com), queobjp, lkarg));
}
int
dadk_free(struct tgdk_obj *dkobjp)
{
TGDK_CLEANUP(dkobjp);
kmem_free(dkobjp, (sizeof (*dkobjp) + sizeof (struct dadk)));
return (DDI_SUCCESS);
}
void
dadk_cleanup(struct tgdk_obj *dkobjp)
{
struct dadk *dadkp;
dadkp = (struct dadk *)(dkobjp->tg_data);
if (dadkp->dad_sd)
dadkp->dad_sd->sd_private = NULL;
if (dadkp->dad_bbhobjp) {
BBH_FREE(dadkp->dad_bbhobjp);
dadkp->dad_bbhobjp = NULL;
}
if (dadkp->dad_flcobjp) {
FLC_FREE(dadkp->dad_flcobjp);
dadkp->dad_flcobjp = NULL;
}
}
/* ARGSUSED */
int
dadk_probe(opaque_t objp, int kmsflg)
{
struct dadk *dadkp = (struct dadk *)objp;
struct scsi_device *devp;
char name[80];
devp = dadkp->dad_sd;
if (!devp->sd_inq || (devp->sd_inq->inq_dtype == DTYPE_NOTPRESENT) ||
(devp->sd_inq->inq_dtype == DTYPE_UNKNOWN)) {
return (DDI_PROBE_FAILURE);
}
switch (devp->sd_inq->inq_dtype) {
case DTYPE_DIRECT:
dadkp->dad_ctype = DKC_DIRECT;
dadkp->dad_extp->tg_nodetype = DDI_NT_BLOCK;
dadkp->dad_extp->tg_ctype = DKC_DIRECT;
break;
case DTYPE_RODIRECT: /* eg cdrom */
dadkp->dad_ctype = DKC_CDROM;
dadkp->dad_extp->tg_rdonly = 1;
dadkp->dad_rdonly = 1;
dadkp->dad_cdrom = 1;
dadkp->dad_extp->tg_nodetype = DDI_NT_CD;
dadkp->dad_extp->tg_ctype = DKC_CDROM;
break;
case DTYPE_WORM:
case DTYPE_OPTICAL:
default:
return (DDI_PROBE_FAILURE);
}
dadkp->dad_extp->tg_rmb = dadkp->dad_rmb = devp->sd_inq->inq_rmb;
dadkp->dad_secshf = SCTRSHFT;
dadkp->dad_blkshf = 0;
/* display the device name */
(void) strcpy(name, "Vendor '");
gda_inqfill((caddr_t)devp->sd_inq->inq_vid, 8, &name[strlen(name)]);
(void) strcat(name, "' Product '");
gda_inqfill((caddr_t)devp->sd_inq->inq_pid, 16, &name[strlen(name)]);
(void) strcat(name, "'");
gda_log(devp->sd_dev, dadk_name, CE_NOTE, "!<%s>\n", name);
return (DDI_PROBE_SUCCESS);
}
/* ARGSUSED */
int
dadk_attach(opaque_t objp)
{
return (DDI_SUCCESS);
}
int
dadk_set_bbhobj(opaque_t objp, opaque_t bbhobjp)
{
struct dadk *dadkp = (struct dadk *)objp;
/* free the old bbh object */
if (dadkp->dad_bbhobjp)
BBH_FREE(dadkp->dad_bbhobjp);
/* initialize the new bbh object */
dadkp->dad_bbhobjp = bbhobjp;
BBH_INIT(bbhobjp);
return (DDI_SUCCESS);
}
/* ARGSUSED */
int
dadk_open(opaque_t objp, int flag)
{
struct dadk *dadkp = (struct dadk *)objp;
int error;
int wce;
if (!dadkp->dad_rmb) {
if (dadkp->dad_phyg.g_cap) {
FLC_START_KSTAT(dadkp->dad_flcobjp, "disk",
ddi_get_instance(CTL_DIP_DEV(dadkp->dad_ctlobjp)));
return (DDI_SUCCESS);
}
} else {
mutex_enter(&dadkp->dad_mutex);
dadkp->dad_iostate = DKIO_NONE;
cv_broadcast(&dadkp->dad_state_cv);
mutex_exit(&dadkp->dad_mutex);
if (dadk_rmb_ioctl(dadkp, DCMD_START_MOTOR, 0, 0, DADK_SILENT) ||
dadk_rmb_ioctl(dadkp, DCMD_LOCK, 0, 0, DADK_SILENT) ||
dadk_rmb_ioctl(dadkp, DCMD_UPDATE_GEOM, 0, 0, DADK_SILENT)) {
return (DDI_FAILURE);
}
mutex_enter(&dadkp->dad_mutex);
dadkp->dad_iostate = DKIO_INSERTED;
cv_broadcast(&dadkp->dad_state_cv);
mutex_exit(&dadkp->dad_mutex);
}
/*
* get write cache enable state
* If there is an error, must assume that write cache
* is enabled.
* NOTE: Since there is currently no Solaris mechanism to
* change the state of the Write Cache Enable feature,
* this code just checks the value of the WCE bit
* obtained at device init time. If a mechanism
* is added to the driver to change WCE, dad_wce
* must be updated appropriately.
*/
error = CTL_IOCTL(dadkp->dad_ctlobjp, DIOCTL_GETWCE,
(uintptr_t)&wce, 0);
mutex_enter(&dadkp->dad_mutex);
dadkp->dad_wce = (error != 0) || (wce != 0);
mutex_exit(&dadkp->dad_mutex);
/* logical disk geometry */
CTL_IOCTL(dadkp->dad_ctlobjp, DIOCTL_GETGEOM,
(uintptr_t)&dadkp->dad_logg, 0);
if (dadkp->dad_logg.g_cap == 0)
return (DDI_FAILURE);
/* get physical disk geometry */
CTL_IOCTL(dadkp->dad_ctlobjp, DIOCTL_GETPHYGEOM,
(uintptr_t)&dadkp->dad_phyg, 0);
if (dadkp->dad_phyg.g_cap == 0)
return (DDI_FAILURE);
dadk_setcap(dadkp);
/* start profiling */
FLC_START_KSTAT(dadkp->dad_flcobjp, "disk",
ddi_get_instance(CTL_DIP_DEV(dadkp->dad_ctlobjp)));
return (DDI_SUCCESS);
}
static void
dadk_setcap(struct dadk *dadkp)
{
int totsize;
int i;
totsize = dadkp->dad_phyg.g_secsiz;
if (totsize == 0) {
if (dadkp->dad_cdrom) {
totsize = 2048;
} else {
totsize = NBPSCTR;
}
} else {
/* Round down sector size to multiple of 512B */
totsize &= ~(NBPSCTR-1);
}
dadkp->dad_phyg.g_secsiz = totsize;
/* set sec,block shift factor - (512->0, 1024->1, 2048->2, etc.) */
totsize >>= SCTRSHFT;
for (i = 0; totsize != 1; i++, totsize >>= 1);
dadkp->dad_blkshf = i;
dadkp->dad_secshf = i + SCTRSHFT;
}
int
dadk_close(opaque_t objp)
{
struct dadk *dadkp = (struct dadk *)objp;
if (dadkp->dad_rmb) {
(void) dadk_rmb_ioctl(dadkp, DCMD_STOP_MOTOR, 0, 0,
DADK_SILENT);
(void) dadk_rmb_ioctl(dadkp, DCMD_UNLOCK, 0, 0, DADK_SILENT);
}
FLC_STOP_KSTAT(dadkp->dad_flcobjp);
return (DDI_SUCCESS);
}
int
dadk_strategy(opaque_t objp, struct buf *bp)
{
struct dadk *dadkp = (struct dadk *)objp;
if (dadkp->dad_rdonly && !(bp->b_flags & B_READ)) {
bioerror(bp, EROFS);
return (DDI_FAILURE);
}
if (bp->b_bcount & (dadkp->DAD_SECSIZ-1)) {
bioerror(bp, ENXIO);
return (DDI_FAILURE);
}
SET_BP_SEC(bp, (LBLK2SEC(GET_BP_SEC(bp), dadkp->dad_blkshf)));
FLC_ENQUE(dadkp->dad_flcobjp, bp);
return (DDI_SUCCESS);
}
int
dadk_dump(opaque_t objp, struct buf *bp)
{
struct dadk *dadkp = (struct dadk *)objp;
struct cmpkt *pktp;
if (dadkp->dad_rdonly) {
bioerror(bp, EROFS);
return (DDI_FAILURE);
}
if (bp->b_bcount & (dadkp->DAD_SECSIZ-1)) {
bioerror(bp, ENXIO);
return (DDI_FAILURE);
}
SET_BP_SEC(bp, (LBLK2SEC(GET_BP_SEC(bp), dadkp->dad_blkshf)));
pktp = dadk_pktprep(dadkp, NULL, bp, dadk_polldone, NULL, NULL);
if (!pktp) {
cmn_err(CE_WARN, "no resources for dumping");
bioerror(bp, EIO);
return (DDI_FAILURE);
}
pktp->cp_flags |= CPF_NOINTR;
(void) dadk_ioprep(dadkp, pktp);
dadk_transport(dadkp, bp);
pktp->cp_byteleft -= pktp->cp_bytexfer;
while (geterror(bp) == 0 && pktp->cp_byteleft != 0) {
(void) dadk_iosetup(dadkp, pktp);
dadk_transport(dadkp, bp);
pktp->cp_byteleft -= pktp->cp_bytexfer;
}
if (pktp->cp_private)
BBH_FREEHANDLE(dadkp->dad_bbhobjp, pktp->cp_private);
gda_free(dadkp->dad_ctlobjp, pktp, NULL);
return (DDI_SUCCESS);
}
/* ARGSUSED */
int
dadk_ioctl(opaque_t objp, dev_t dev, int cmd, intptr_t arg, int flag,
cred_t *cred_p, int *rval_p)
{
struct dadk *dadkp = (struct dadk *)objp;
switch (cmd) {
case DKIOCGETDEF:
{
struct buf *bp;
int err, head;
unsigned char *secbuf;
STRUCT_DECL(defect_header, adh);
STRUCT_INIT(adh, flag & FMODELS);
/*
* copyin header ....
* yields head number and buffer address
*/
if (ddi_copyin((caddr_t)arg, STRUCT_BUF(adh), STRUCT_SIZE(adh),
flag))
return (EFAULT);
head = STRUCT_FGET(adh, head);
if (head < 0 || head >= dadkp->dad_phyg.g_head)
return (ENXIO);
secbuf = kmem_zalloc(NBPSCTR, KM_SLEEP);
if (!secbuf)
return (ENOMEM);
bp = getrbuf(KM_SLEEP);
if (!bp) {
kmem_free(secbuf, NBPSCTR);
return (ENOMEM);
}
bp->b_edev = dev;
bp->b_dev = cmpdev(dev);
bp->b_flags = B_BUSY;
bp->b_resid = 0;
bp->b_bcount = NBPSCTR;
bp->b_un.b_addr = (caddr_t)secbuf;
bp->b_blkno = head; /* I had to put it somwhere! */
bp->b_forw = (struct buf *)dadkp;
bp->b_back = (struct buf *)DCMD_GETDEF;
FLC_ENQUE(dadkp->dad_flcobjp, bp);
err = biowait(bp);
if (!err) {
if (ddi_copyout((caddr_t)secbuf,
STRUCT_FGETP(adh, buffer), NBPSCTR, flag))
err = ENXIO;
}
kmem_free(secbuf, NBPSCTR);
freerbuf(bp);
return (err);
}
case DIOCTL_RWCMD:
{
struct dadkio_rwcmd *rwcmdp;
int status, rw;
/*
* copied in by cmdk and, if necessary, converted to the
* correct datamodel
*/
rwcmdp = (struct dadkio_rwcmd *)(intptr_t)arg;
/*
* handle the complex cases here; we pass these
* through to the driver, which will queue them and
* handle the requests asynchronously. The simpler
* cases ,which can return immediately, fail here, and
* the request reverts to the dadk_ioctl routine, while
* will reroute them directly to the ata driver.
*/
switch (rwcmdp->cmd) {
case DADKIO_RWCMD_READ :
/*FALLTHROUGH*/
case DADKIO_RWCMD_WRITE:
rw = ((rwcmdp->cmd == DADKIO_RWCMD_WRITE) ?
B_WRITE : B_READ);
status = dadk_dk_buf_setup(dadkp,
(opaque_t)rwcmdp, dev, ((flag &FKIOCTL) ?
UIO_SYSSPACE : UIO_USERSPACE), rw);
return (status);
default:
return (EINVAL);
}
}
case DKIOCFLUSHWRITECACHE:
{
struct buf *bp;
int err = 0;
struct dk_callback *dkc = (struct dk_callback *)arg;
struct cmpkt *pktp;
int is_sync = 1;
mutex_enter(&dadkp->dad_mutex);
if (dadkp->dad_noflush || ! dadkp->dad_wce) {
err = dadkp->dad_noflush ? ENOTSUP : 0;
mutex_exit(&dadkp->dad_mutex);
/*
* If a callback was requested: a
* callback will always be done if the
* caller saw the DKIOCFLUSHWRITECACHE
* ioctl return 0, and never done if the
* caller saw the ioctl return an error.
*/
if ((flag & FKIOCTL) && dkc != NULL &&
dkc->dkc_callback != NULL) {
(*dkc->dkc_callback)(dkc->dkc_cookie,
err);
/*
* Did callback and reported error.
* Since we did a callback, ioctl
* should return 0.
*/
err = 0;
}
return (err);
}
mutex_exit(&dadkp->dad_mutex);
bp = getrbuf(KM_SLEEP);
bp->b_edev = dev;
bp->b_dev = cmpdev(dev);
bp->b_flags = B_BUSY;
bp->b_resid = 0;
bp->b_bcount = 0;
SET_BP_SEC(bp, 0);
if ((flag & FKIOCTL) && dkc != NULL &&
dkc->dkc_callback != NULL) {
struct dk_callback *dkc2 =
(struct dk_callback *)kmem_zalloc(
sizeof (struct dk_callback), KM_SLEEP);
bcopy(dkc, dkc2, sizeof (*dkc2));
/*
* Borrow b_list to carry private data
* to the b_iodone func.
*/
bp->b_list = (struct buf *)dkc2;
bp->b_iodone = dadk_flushdone;
is_sync = 0;
}
/*
* Setup command pkt
* dadk_pktprep() can't fail since DDI_DMA_SLEEP set
*/
pktp = dadk_pktprep(dadkp, NULL, bp,
dadk_iodone, DDI_DMA_SLEEP, NULL);
pktp->cp_time = DADK_FLUSH_CACHE_TIME;
*((char *)(pktp->cp_cdbp)) = DCMD_FLUSH_CACHE;
pktp->cp_byteleft = 0;
pktp->cp_private = NULL;
pktp->cp_secleft = 0;
pktp->cp_srtsec = -1;
pktp->cp_bytexfer = 0;
CTL_IOSETUP(dadkp->dad_ctlobjp, pktp);
FLC_ENQUE(dadkp->dad_flcobjp, bp);
if (is_sync) {
err = biowait(bp);
freerbuf(bp);
}
return (err);
}
default:
if (!dadkp->dad_rmb)
return (CTL_IOCTL(dadkp->dad_ctlobjp, cmd, arg, flag));
}
switch (cmd) {
case CDROMSTOP:
return (dadk_rmb_ioctl(dadkp, DCMD_STOP_MOTOR, 0,
0, DADK_SILENT));
case CDROMSTART:
return (dadk_rmb_ioctl(dadkp, DCMD_START_MOTOR, 0,
0, DADK_SILENT));
case DKIOCLOCK:
return (dadk_rmb_ioctl(dadkp, DCMD_LOCK, 0, 0, DADK_SILENT));
case DKIOCUNLOCK:
return (dadk_rmb_ioctl(dadkp, DCMD_UNLOCK, 0, 0, DADK_SILENT));
case DKIOCEJECT:
case CDROMEJECT:
{
int ret;
if (ret = dadk_rmb_ioctl(dadkp, DCMD_UNLOCK, 0, 0,
DADK_SILENT)) {
return (ret);
}
if (ret = dadk_rmb_ioctl(dadkp, DCMD_EJECT, 0, 0,
DADK_SILENT)) {
return (ret);
}
mutex_enter(&dadkp->dad_mutex);
dadkp->dad_iostate = DKIO_EJECTED;
cv_broadcast(&dadkp->dad_state_cv);
mutex_exit(&dadkp->dad_mutex);
return (0);
}
default:
return (ENOTTY);
/*
* cdrom audio commands
*/
case CDROMPAUSE:
cmd = DCMD_PAUSE;
break;
case CDROMRESUME:
cmd = DCMD_RESUME;
break;
case CDROMPLAYMSF:
cmd = DCMD_PLAYMSF;
break;
case CDROMPLAYTRKIND:
cmd = DCMD_PLAYTRKIND;
break;
case CDROMREADTOCHDR:
cmd = DCMD_READTOCHDR;
break;
case CDROMREADTOCENTRY:
cmd = DCMD_READTOCENT;
break;
case CDROMVOLCTRL:
cmd = DCMD_VOLCTRL;
break;
case CDROMSUBCHNL:
cmd = DCMD_SUBCHNL;
break;
case CDROMREADMODE2:
cmd = DCMD_READMODE2;
break;
case CDROMREADMODE1:
cmd = DCMD_READMODE1;
break;
case CDROMREADOFFSET:
cmd = DCMD_READOFFSET;
break;
}
return (dadk_rmb_ioctl(dadkp, cmd, arg, flag, 0));
}
int
dadk_flushdone(struct buf *bp)
{
struct dk_callback *dkc = (struct dk_callback *)bp->b_list;
ASSERT(dkc != NULL && dkc->dkc_callback != NULL);
(*dkc->dkc_callback)(dkc->dkc_cookie, geterror(bp));
kmem_free(dkc, sizeof (*dkc));
freerbuf(bp);
return (0);
}
int
dadk_getphygeom(opaque_t objp, struct tgdk_geom *dkgeom_p)
{
struct dadk *dadkp = (struct dadk *)objp;
bcopy((caddr_t)&dadkp->dad_phyg, (caddr_t)dkgeom_p,
sizeof (struct tgdk_geom));
return (DDI_SUCCESS);
}
int
dadk_getgeom(opaque_t objp, struct tgdk_geom *dkgeom_p)
{
struct dadk *dadkp = (struct dadk *)objp;
bcopy((caddr_t)&dadkp->dad_logg, (caddr_t)dkgeom_p,
sizeof (struct tgdk_geom));
return (DDI_SUCCESS);
}
int
dadk_setgeom(opaque_t objp, struct tgdk_geom *dkgeom_p)
{
struct dadk *dadkp = (struct dadk *)objp;
dadkp->dad_logg.g_cyl = dkgeom_p->g_cyl;
dadkp->dad_logg.g_head = dkgeom_p->g_head;
dadkp->dad_logg.g_sec = dkgeom_p->g_sec;
dadkp->dad_logg.g_cap = dkgeom_p->g_cap;
return (DDI_SUCCESS);
}
tgdk_iob_handle
dadk_iob_alloc(opaque_t objp, daddr_t blkno, ssize_t xfer, int kmsflg)
{
struct dadk *dadkp = (struct dadk *)objp;
struct buf *bp;
struct tgdk_iob *iobp;
iobp = kmem_zalloc(sizeof (*iobp), kmsflg);
if (iobp == NULL)
return (NULL);
if ((bp = getrbuf(kmsflg)) == NULL) {
kmem_free(iobp, sizeof (*iobp));
return (NULL);
}
iobp->b_psec = LBLK2SEC(blkno, dadkp->dad_blkshf);
iobp->b_pbyteoff = (blkno & ((1<<dadkp->dad_blkshf) - 1)) << SCTRSHFT;
iobp->b_pbytecnt = ((iobp->b_pbyteoff + xfer + dadkp->DAD_SECSIZ - 1)
>> dadkp->dad_secshf) << dadkp->dad_secshf;
bp->b_un.b_addr = 0;
if (ddi_iopb_alloc((dadkp->dad_sd)->sd_dev, (ddi_dma_lim_t *)0,
(uint_t)iobp->b_pbytecnt, &bp->b_un.b_addr)) {
freerbuf(bp);
kmem_free(iobp, sizeof (*iobp));
return (NULL);
}
iobp->b_flag |= IOB_BPALLOC | IOB_BPBUFALLOC;
iobp->b_bp = bp;
iobp->b_lblk = blkno;
iobp->b_xfer = xfer;
iobp->b_lblk = blkno;
iobp->b_xfer = xfer;
return (iobp);
}
/* ARGSUSED */
int
dadk_iob_free(opaque_t objp, struct tgdk_iob *iobp)
{
struct buf *bp;
if (iobp) {
if (iobp->b_bp && (iobp->b_flag & IOB_BPALLOC)) {
bp = iobp->b_bp;
if (bp->b_un.b_addr && (iobp->b_flag & IOB_BPBUFALLOC))
ddi_iopb_free((caddr_t)bp->b_un.b_addr);
freerbuf(bp);
}
kmem_free(iobp, sizeof (*iobp));
}
return (DDI_SUCCESS);
}
/* ARGSUSED */
caddr_t
dadk_iob_htoc(opaque_t objp, struct tgdk_iob *iobp)
{
return (iobp->b_bp->b_un.b_addr+iobp->b_pbyteoff);
}
caddr_t
dadk_iob_xfer(opaque_t objp, struct tgdk_iob *iobp, int rw)
{
struct dadk *dadkp = (struct dadk *)objp;
struct buf *bp;
int err;
bp = iobp->b_bp;
if (dadkp->dad_rdonly && !(rw & B_READ)) {
bioerror(bp, EROFS);
return (NULL);
}
bp->b_flags |= (B_BUSY | rw);
bp->b_bcount = iobp->b_pbytecnt;
SET_BP_SEC(bp, iobp->b_psec);
bp->av_back = (struct buf *)0;
bp->b_resid = 0;
/* call flow control */
FLC_ENQUE(dadkp->dad_flcobjp, bp);
err = biowait(bp);
bp->b_bcount = iobp->b_xfer;
bp->b_flags &= ~(B_DONE|B_BUSY);
if (err)
return (NULL);
return (bp->b_un.b_addr+iobp->b_pbyteoff);
}
static void
dadk_transport(opaque_t com_data, struct buf *bp)
{
struct dadk *dadkp = (struct dadk *)com_data;
if (CTL_TRANSPORT(dadkp->dad_ctlobjp, GDA_BP_PKT(bp)) ==
CTL_SEND_SUCCESS)
return;
dadk_restart((void*)GDA_BP_PKT(bp));
}
static int
dadk_pkt(opaque_t com_data, struct buf *bp, int (*func)(caddr_t), caddr_t arg)
{
struct cmpkt *pktp;
struct dadk *dadkp = (struct dadk *)com_data;
if (GDA_BP_PKT(bp))
return (DDI_SUCCESS);
pktp = dadk_pktprep(dadkp, NULL, bp, dadk_iodone, func, arg);
if (!pktp)
return (DDI_FAILURE);
return (dadk_ioprep(dadkp, pktp));
}
/*
* Read, Write preparation
*/
static int
dadk_ioprep(struct dadk *dadkp, struct cmpkt *pktp)
{
struct buf *bp;
bp = pktp->cp_bp;
if (bp->b_forw == (struct buf *)dadkp)
*((char *)(pktp->cp_cdbp)) = (char)(intptr_t)bp->b_back;
else if (bp->b_flags & B_READ)
*((char *)(pktp->cp_cdbp)) = DCMD_READ;
else
*((char *)(pktp->cp_cdbp)) = DCMD_WRITE;
pktp->cp_byteleft = bp->b_bcount;
/* setup the bad block list handle */
pktp->cp_private = BBH_GETHANDLE(dadkp->dad_bbhobjp, bp);
return (dadk_iosetup(dadkp, pktp));
}
static int
dadk_iosetup(struct dadk *dadkp, struct cmpkt *pktp)
{
struct buf *bp;
bbh_cookie_t bbhckp;
int seccnt;
seccnt = pktp->cp_bytexfer >> dadkp->dad_secshf;
pktp->cp_secleft -= seccnt;
if (pktp->cp_secleft) {
pktp->cp_srtsec += seccnt;
} else {
/* get the first cookie from the bad block list */
if (!pktp->cp_private) {
bp = pktp->cp_bp;
pktp->cp_srtsec = GET_BP_SEC(bp);
pktp->cp_secleft = (bp->b_bcount >> dadkp->dad_secshf);
} else {
bbhckp = BBH_HTOC(dadkp->dad_bbhobjp,
pktp->cp_private);
pktp->cp_srtsec = BBH_GETCK_SECTOR(dadkp->dad_bbhobjp,
bbhckp);
pktp->cp_secleft = BBH_GETCK_SECLEN(dadkp->dad_bbhobjp,
bbhckp);
}
}
pktp->cp_bytexfer = pktp->cp_secleft << dadkp->dad_secshf;
if (CTL_IOSETUP(dadkp->dad_ctlobjp, pktp)) {
return (DDI_SUCCESS);
} else {
return (DDI_FAILURE);
}
}
static struct cmpkt *
dadk_pktprep(struct dadk *dadkp, struct cmpkt *in_pktp, struct buf *bp,
void (*cb_func)(struct buf *), int (*func)(caddr_t), caddr_t arg)
{
struct cmpkt *pktp;
pktp = gda_pktprep(dadkp->dad_ctlobjp, in_pktp, (opaque_t)bp, func,
arg);
if (pktp) {
pktp->cp_callback = dadk_pktcb;
pktp->cp_time = DADK_IO_TIME;
pktp->cp_flags = 0;
pktp->cp_iodone = cb_func;
pktp->cp_dev_private = (opaque_t)dadkp;
}
return (pktp);
}
static void
dadk_restart(void *vpktp)
{
struct cmpkt *pktp = (struct cmpkt *)vpktp;
if (dadk_ioretry(pktp, QUE_COMMAND) == JUST_RETURN)
return;
pktp->cp_iodone(pktp->cp_bp);
}
static int
dadk_ioretry(struct cmpkt *pktp, int action)
{
struct buf *bp;
struct dadk *dadkp = PKT2DADK(pktp);
switch (action) {
case QUE_COMMAND:
if (pktp->cp_retry++ < DADK_RETRY_COUNT) {
CTL_IOSETUP(dadkp->dad_ctlobjp, pktp);
if (CTL_TRANSPORT(dadkp->dad_ctlobjp, pktp) ==
CTL_SEND_SUCCESS) {
return (JUST_RETURN);
}
gda_log(dadkp->dad_sd->sd_dev, dadk_name,
CE_WARN,
"transport of command fails\n");
} else
gda_log(dadkp->dad_sd->sd_dev,
dadk_name, CE_WARN,
"exceeds maximum number of retries\n");
bioerror(pktp->cp_bp, ENXIO);
/*FALLTHROUGH*/
case COMMAND_DONE_ERROR:
bp = pktp->cp_bp;
bp->b_resid += pktp->cp_byteleft - pktp->cp_bytexfer +
pktp->cp_resid;
if (geterror(bp) == 0) {
if ((*((char *)(pktp->cp_cdbp)) == DCMD_FLUSH_CACHE) &&
(pktp->cp_dev_private == (opaque_t)dadkp) &&
((int)(*(char *)pktp->cp_scbp) == DERR_ABORT)) {
/*
* Flag "unimplemented" responses for
* DCMD_FLUSH_CACHE as ENOTSUP
*/
bioerror(bp, ENOTSUP);
mutex_enter(&dadkp->dad_mutex);
dadkp->dad_noflush = 1;
mutex_exit(&dadkp->dad_mutex);
} else {
bioerror(bp, EIO);
}
}
/*FALLTHROUGH*/
case COMMAND_DONE:
default:
return (COMMAND_DONE);
}
}
static void
dadk_pktcb(struct cmpkt *pktp)
{
int action;
struct dadkio_rwcmd *rwcmdp;
rwcmdp = (struct dadkio_rwcmd *)pktp->cp_passthru; /* ioctl packet */
if (pktp->cp_reason == CPS_SUCCESS) {
if (rwcmdp && (rwcmdp != (opaque_t)DADK_SILENT))
rwcmdp->status.status = DADKIO_STAT_NO_ERROR;
pktp->cp_iodone(pktp->cp_bp);
return;
}
if (rwcmdp && (rwcmdp != (opaque_t)DADK_SILENT)) {
if (pktp->cp_reason == CPS_CHKERR)
dadk_recorderr(pktp, rwcmdp);
dadk_iodone(pktp->cp_bp);
return;
}
if (pktp->cp_reason == CPS_CHKERR)
action = dadk_chkerr(pktp);
else
action = COMMAND_DONE_ERROR;
if (action == JUST_RETURN)
return;
if (action != COMMAND_DONE) {
if ((dadk_ioretry(pktp, action)) == JUST_RETURN)
return;
}
pktp->cp_iodone(pktp->cp_bp);
}
static struct dadkio_derr dadk_errtab[] = {
{COMMAND_DONE, GDA_INFORMATIONAL}, /* 0 DERR_SUCCESS */
{QUE_COMMAND, GDA_FATAL}, /* 1 DERR_AMNF */
{QUE_COMMAND, GDA_FATAL}, /* 2 DERR_TKONF */
{COMMAND_DONE_ERROR, GDA_INFORMATIONAL}, /* 3 DERR_ABORT */
{QUE_COMMAND, GDA_RETRYABLE}, /* 4 DERR_DWF */
{QUE_COMMAND, GDA_FATAL}, /* 5 DERR_IDNF */
{JUST_RETURN, GDA_INFORMATIONAL}, /* 6 DERR_BUSY */
{QUE_COMMAND, GDA_FATAL}, /* 7 DERR_UNC */
{QUE_COMMAND, GDA_RETRYABLE}, /* 8 DERR_BBK */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 9 DERR_INVCDB */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 10 DERR_HARD */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 11 DERR_ILI */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 12 DERR_EOM */
{COMMAND_DONE, GDA_INFORMATIONAL}, /* 13 DERR_MCR */
{COMMAND_DONE, GDA_INFORMATIONAL}, /* 14 DERR_RECOVER */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 15 DERR_NOTREADY */
{QUE_COMMAND, GDA_RETRYABLE}, /* 16 DERR_MEDIUM */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 17 DERR_HW */
{COMMAND_DONE, GDA_FATAL}, /* 18 DERR_ILL */
{COMMAND_DONE, GDA_FATAL}, /* 19 DERR_UNIT_ATTN */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 20 DERR_DATA_PROT */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 21 DERR_MISCOMPARE */
{COMMAND_DONE_ERROR, GDA_FATAL}, /* 22 DERR_RESV */
};
static int
dadk_chkerr(struct cmpkt *pktp)
{
int err_blkno;
struct dadk *dadkp;
int scb;
if (*(char *)pktp->cp_scbp == DERR_SUCCESS)
return (COMMAND_DONE);
/* check error code table */
dadkp = PKT2DADK(pktp);
scb = (int)(*(char *)pktp->cp_scbp);
if (pktp->cp_retry) {
err_blkno = pktp->cp_srtsec + ((pktp->cp_bytexfer -
pktp->cp_resid) >> dadkp->dad_secshf);
} else
err_blkno = -1;
/* if attempting to read a sector from a cdrom audio disk */
if ((dadkp->dad_cdrom) &&
(*((char *)(pktp->cp_cdbp)) == DCMD_READ) &&
(scb == DERR_ILL)) {
return (COMMAND_DONE);
}
if (pktp->cp_passthru == NULL) {
gda_errmsg(dadkp->dad_sd, pktp, dadk_name,
dadk_errtab[scb].d_severity, pktp->cp_srtsec,
err_blkno, dadk_cmds, dadk_sense);
}
if (scb == DERR_BUSY) {
(void) timeout(dadk_restart, (void *)pktp, DADK_BSY_TIMEOUT);
}
return (dadk_errtab[scb].d_action);
}
static void
dadk_recorderr(struct cmpkt *pktp, struct dadkio_rwcmd *rwcmdp)
{
struct dadk *dadkp;
int scb;
dadkp = PKT2DADK(pktp);
scb = (int)(*(char *)pktp->cp_scbp);
rwcmdp->status.failed_blk = rwcmdp->blkaddr +
((pktp->cp_bytexfer -
pktp->cp_resid) >> dadkp->dad_secshf);
rwcmdp->status.resid = pktp->cp_bp->b_resid +
pktp->cp_byteleft - pktp->cp_bytexfer + pktp->cp_resid;
switch ((int)(* (char *)pktp->cp_scbp)) {
case DERR_AMNF:
case DERR_ABORT:
rwcmdp->status.status = DADKIO_STAT_ILLEGAL_REQUEST;
break;
case DERR_DWF:
case DERR_IDNF:
rwcmdp->status.status = DADKIO_STAT_ILLEGAL_ADDRESS;
break;
case DERR_TKONF:
case DERR_UNC:
case DERR_BBK:
rwcmdp->status.status = DADKIO_STAT_MEDIUM_ERROR;
rwcmdp->status.failed_blk_is_valid = 1;
rwcmdp->status.resid = 0;
break;
case DERR_BUSY:
rwcmdp->status.status = DADKIO_STAT_NOT_READY;
break;
case DERR_INVCDB:
case DERR_HARD:
rwcmdp->status.status = DADKIO_STAT_HARDWARE_ERROR;
break;
default:
rwcmdp->status.status = DADKIO_STAT_NOT_SUPPORTED;
}
if (rwcmdp->flags & DADKIO_FLAG_SILENT)
return;
gda_errmsg(dadkp->dad_sd, pktp, dadk_name, dadk_errtab[scb].d_severity,
rwcmdp->blkaddr, rwcmdp->status.failed_blk,
dadk_cmds, dadk_sense);
}
/*ARGSUSED*/
static void
dadk_polldone(struct buf *bp)
{
}
static void
dadk_iodone(struct buf *bp)
{
struct cmpkt *pktp;
struct dadk *dadkp;
pktp = GDA_BP_PKT(bp);
dadkp = PKT2DADK(pktp);
/* check for all iodone */
pktp->cp_byteleft -= pktp->cp_bytexfer;
if (geterror(bp) == 0 && pktp->cp_byteleft != 0) {
pktp->cp_retry = 0;
(void) dadk_iosetup(dadkp, pktp);
/* transport the next one */
if (CTL_TRANSPORT(dadkp->dad_ctlobjp, pktp) == CTL_SEND_SUCCESS)
return;
if ((dadk_ioretry(pktp, QUE_COMMAND)) == JUST_RETURN)
return;
}
/* start next one */
FLC_DEQUE(dadkp->dad_flcobjp, bp);
/* free pkt */
if (pktp->cp_private)
BBH_FREEHANDLE(dadkp->dad_bbhobjp, pktp->cp_private);
gda_free(dadkp->dad_ctlobjp, pktp, NULL);
biodone(bp);
}
int
dadk_check_media(opaque_t objp, int *state)
{
struct dadk *dadkp = (struct dadk *)objp;
if (!dadkp->dad_rmb) {
return (ENXIO);
}
#ifdef DADK_DEBUG
if (dadk_debug & DSTATE)
PRF("dadk_check_media: user state %x disk state %x\n",
*state, dadkp->dad_iostate);
#endif
/*
* If state already changed just return
*/
if (*state != dadkp->dad_iostate) {
*state = dadkp->dad_iostate;
return (0);
}
/*
* Startup polling on thread state
*/
mutex_enter(&dadkp->dad_mutex);
if (dadkp->dad_thread_cnt == 0) {
/*
* One thread per removable dadk device
*/
(void) thread_create(NULL, 0, dadk_watch_thread, dadkp, 0, &p0,
TS_RUN, v.v_maxsyspri - 2);
}
dadkp->dad_thread_cnt++;
/*
* Wait for state to change
*/
do {
if (cv_wait_sig(&dadkp->dad_state_cv, &dadkp->dad_mutex) == 0) {
dadkp->dad_thread_cnt--;
mutex_exit(&dadkp->dad_mutex);
return (EINTR);
}
} while (*state == dadkp->dad_iostate);
*state = dadkp->dad_iostate;
dadkp->dad_thread_cnt--;
mutex_exit(&dadkp->dad_mutex);
return (0);
}
#define MEDIA_ACCESS_DELAY 2000000
static void
dadk_watch_thread(struct dadk *dadkp)
{
enum dkio_state state;
int interval;
interval = drv_usectohz(dadk_check_media_time);
do {
if (dadk_rmb_ioctl(dadkp, DCMD_GET_STATE, (intptr_t)&state, 0,
DADK_SILENT)) {
/*
* Assume state remained the same
*/
state = dadkp->dad_iostate;
}
/*
* now signal the waiting thread if this is *not* the
* specified state;
* delay the signal if the state is DKIO_INSERTED
* to allow the target to recover
*/
if (state != dadkp->dad_iostate) {
dadkp->dad_iostate = state;
if (state == DKIO_INSERTED) {
/*
* delay the signal to give the drive a chance
* to do what it apparently needs to do
*/
(void) timeout((void(*)(void *))cv_broadcast,
(void *)&dadkp->dad_state_cv,
drv_usectohz((clock_t)MEDIA_ACCESS_DELAY));
} else {
cv_broadcast(&dadkp->dad_state_cv);
}
}
delay(interval);
} while (dadkp->dad_thread_cnt);
}
int
dadk_inquiry(opaque_t objp, opaque_t *inqpp)
{
struct dadk *dadkp = (struct dadk *)objp;
struct scsi_inquiry **sinqpp = (struct scsi_inquiry **)inqpp;
if (dadkp && dadkp->dad_sd && dadkp->dad_sd->sd_inq) {
*sinqpp = dadkp->dad_sd->sd_inq;
return (DDI_SUCCESS);
}
return (DDI_FAILURE);
}
static int
dadk_rmb_ioctl(struct dadk *dadkp, int cmd, intptr_t arg, int flags, int silent)
{
struct buf *bp;
int err;
struct cmpkt *pktp;
if ((bp = getrbuf(KM_SLEEP)) == NULL) {
return (ENOMEM);
}
pktp = dadk_pktprep(dadkp, NULL, bp, dadk_rmb_iodone, NULL, NULL);
if (!pktp) {
freerbuf(bp);
return (ENOMEM);
}
bp->b_back = (struct buf *)arg;
bp->b_forw = (struct buf *)dadkp->dad_flcobjp;
pktp->cp_passthru = (opaque_t)(intptr_t)silent;
err = CTL_IOCTL(dadkp->dad_ctlobjp, cmd, (uintptr_t)pktp, flags);
freerbuf(bp);
gda_free(dadkp->dad_ctlobjp, pktp, NULL);
return (err);
}
static void
dadk_rmb_iodone(struct buf *bp)
{
struct cmpkt *pktp;
struct dadk *dadkp;
pktp = GDA_BP_PKT(bp);
dadkp = PKT2DADK(pktp);
bp->b_flags &= ~(B_DONE|B_BUSY);
/* Start next one */
FLC_DEQUE(dadkp->dad_flcobjp, bp);
biodone(bp);
}
static int
dadk_dk_buf_setup(struct dadk *dadkp, opaque_t *cmdp, dev_t dev,
enum uio_seg dataspace, int rw)
{
struct dadkio_rwcmd *rwcmdp = (struct dadkio_rwcmd *)cmdp;
struct buf *bp;
struct iovec aiov;
struct uio auio;
struct uio *uio = &auio;
int status;
bp = getrbuf(KM_SLEEP);
bp->av_forw = bp->b_forw = (struct buf *)dadkp;
bp->b_back = (struct buf *)rwcmdp; /* ioctl packet */
bzero((caddr_t)&auio, sizeof (struct uio));
bzero((caddr_t)&aiov, sizeof (struct iovec));
aiov.iov_base = rwcmdp->bufaddr;
aiov.iov_len = rwcmdp->buflen;
uio->uio_iov = &aiov;
uio->uio_iovcnt = 1;
uio->uio_resid = rwcmdp->buflen;
uio->uio_segflg = dataspace;
/* Let physio do the rest... */
status = physio(dadk_dk_strategy, bp, dev, rw, dadkmin, uio);
freerbuf(bp);
return (status);
}
/* Do not let a user gendisk request get too big or */
/* else we could use to many resources. */
static void
dadkmin(struct buf *bp)
{
if (bp->b_bcount > dadk_dk_maxphys)
bp->b_bcount = dadk_dk_maxphys;
}
static int
dadk_dk_strategy(struct buf *bp)
{
dadk_dk((struct dadk *)bp->av_forw, (struct dadkio_rwcmd *)bp->b_back,
bp);
return (0);
}
static void
dadk_dk(struct dadk *dadkp, struct dadkio_rwcmd *rwcmdp, struct buf *bp)
{
struct cmpkt *pktp;
pktp = dadk_pktprep(dadkp, NULL, bp, dadk_iodone, NULL, NULL);
if (!pktp) {
bioerror(bp, ENOMEM);
biodone(bp);
return;
}
pktp->cp_passthru = rwcmdp;
(void) dadk_ioprep(dadkp, pktp);
FLC_ENQUE(dadkp->dad_flcobjp, bp);
}