Home | History | Annotate | Line # | Download | only in pci
vioscsi.c revision 1.23
      1  1.23  jakllsch /*	$NetBSD: vioscsi.c,v 1.23 2020/09/18 14:55:28 jakllsch Exp $	*/
      2   1.1  christos /*	$OpenBSD: vioscsi.c,v 1.3 2015/03/14 03:38:49 jsg Exp $	*/
      3   1.1  christos 
      4   1.1  christos /*
      5   1.1  christos  * Copyright (c) 2013 Google Inc.
      6   1.1  christos  *
      7   1.1  christos  * Permission to use, copy, modify, and distribute this software for any
      8   1.1  christos  * purpose with or without fee is hereby granted, provided that the above
      9   1.1  christos  * copyright notice and this permission notice appear in all copies.
     10   1.1  christos  *
     11   1.1  christos  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
     12   1.1  christos  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
     13   1.1  christos  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
     14   1.1  christos  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
     15   1.1  christos  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
     16   1.1  christos  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
     17   1.1  christos  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
     18   1.1  christos  */
     19   1.1  christos 
     20   1.1  christos #include <sys/cdefs.h>
     21  1.23  jakllsch __KERNEL_RCSID(0, "$NetBSD: vioscsi.c,v 1.23 2020/09/18 14:55:28 jakllsch Exp $");
     22   1.1  christos 
     23   1.1  christos #include <sys/param.h>
     24   1.1  christos #include <sys/systm.h>
     25   1.1  christos #include <sys/device.h>
     26   1.1  christos #include <sys/bus.h>
     27   1.1  christos #include <sys/buf.h>
     28  1.15  jdolecek #include <sys/module.h>
     29   1.1  christos 
     30   1.1  christos #include <dev/pci/vioscsireg.h>
     31   1.1  christos #include <dev/pci/virtiovar.h>
     32   1.1  christos 
     33   1.1  christos #include <dev/scsipi/scsi_all.h>
     34   1.1  christos #include <dev/scsipi/scsiconf.h>
     35   1.1  christos 
     36   1.1  christos #ifdef VIOSCSI_DEBUG
     37   1.1  christos static int vioscsi_debug = 1;
     38   1.1  christos #define DPRINTF(f) do { if (vioscsi_debug) printf f; } while (/*CONSTCOND*/0)
     39   1.1  christos #else
     40   1.1  christos #define DPRINTF(f) ((void)0)
     41   1.1  christos #endif
     42   1.1  christos 
     43   1.1  christos struct vioscsi_req {
     44   1.1  christos 	struct virtio_scsi_req_hdr	 vr_req;
     45   1.1  christos 	struct virtio_scsi_res_hdr	 vr_res;
     46   1.1  christos 	struct scsipi_xfer		*vr_xs;
     47   1.1  christos 	bus_dmamap_t			 vr_control;
     48   1.1  christos 	bus_dmamap_t			 vr_data;
     49   1.1  christos };
     50   1.1  christos 
     51   1.1  christos struct vioscsi_softc {
     52   1.1  christos 	device_t 		 sc_dev;
     53   1.1  christos 	struct scsipi_adapter	 sc_adapter;
     54   1.1  christos 	struct scsipi_channel 	 sc_channel;
     55   1.1  christos 
     56   1.1  christos 	struct virtqueue	 sc_vqs[3];
     57  1.10  jdolecek #define VIOSCSI_VQ_CONTROL	0
     58  1.10  jdolecek #define VIOSCSI_VQ_EVENT	1
     59  1.10  jdolecek #define VIOSCSI_VQ_REQUEST	2
     60  1.10  jdolecek 
     61   1.1  christos 	struct vioscsi_req	*sc_reqs;
     62   1.9  jdolecek 	int			 sc_nreqs;
     63   1.1  christos 	bus_dma_segment_t        sc_reqs_segs[1];
     64   1.1  christos 
     65   1.1  christos 	u_int32_t		 sc_seg_max;
     66  1.15  jdolecek 
     67  1.15  jdolecek 	kmutex_t		 sc_mutex;
     68   1.1  christos };
     69   1.1  christos 
     70   1.2  christos /*
     71   1.2  christos  * Each block request uses at least two segments - one for the header
     72   1.2  christos  * and one for the status.
     73   1.2  christos */
     74   1.2  christos #define VIRTIO_SCSI_MIN_SEGMENTS 2
     75   1.2  christos 
     76   1.1  christos static int	 vioscsi_match(device_t, cfdata_t, void *);
     77   1.1  christos static void	 vioscsi_attach(device_t, device_t, void *);
     78  1.15  jdolecek static int	 vioscsi_detach(device_t, int);
     79   1.1  christos 
     80   1.1  christos static int	 vioscsi_alloc_reqs(struct vioscsi_softc *,
     81  1.15  jdolecek     struct virtio_softc *, int);
     82  1.12  jdolecek static void	 vioscsi_free_reqs(struct vioscsi_softc *,
     83  1.12  jdolecek     struct virtio_softc *);
     84   1.1  christos static void	 vioscsi_scsipi_request(struct scsipi_channel *,
     85   1.1  christos     scsipi_adapter_req_t, void *);
     86   1.1  christos static int	 vioscsi_vq_done(struct virtqueue *);
     87   1.1  christos static void	 vioscsi_req_done(struct vioscsi_softc *, struct virtio_softc *,
     88  1.19  jdolecek     struct vioscsi_req *, struct virtqueue *, int);
     89   1.1  christos static struct vioscsi_req *vioscsi_req_get(struct vioscsi_softc *);
     90  1.15  jdolecek static void	 vioscsi_bad_target(struct scsipi_xfer *);
     91   1.1  christos 
     92   1.1  christos static const char *const vioscsi_vq_names[] = {
     93   1.1  christos 	"control",
     94   1.1  christos 	"event",
     95   1.1  christos 	"request",
     96   1.1  christos };
     97   1.1  christos 
     98  1.15  jdolecek CFATTACH_DECL3_NEW(vioscsi, sizeof(struct vioscsi_softc),
     99  1.15  jdolecek     vioscsi_match, vioscsi_attach, vioscsi_detach, NULL, NULL, NULL,
    100  1.15  jdolecek     DVF_DETACH_SHUTDOWN);
    101   1.1  christos 
    102   1.1  christos static int
    103   1.1  christos vioscsi_match(device_t parent, cfdata_t match, void *aux)
    104   1.1  christos {
    105  1.12  jdolecek 	struct virtio_attach_args *va = aux;
    106   1.1  christos 
    107   1.1  christos 	if (va->sc_childdevid == PCI_PRODUCT_VIRTIO_SCSI)
    108   1.1  christos 		return 1;
    109  1.12  jdolecek 
    110   1.1  christos 	return 0;
    111   1.1  christos }
    112   1.1  christos 
    113   1.1  christos static void
    114   1.1  christos vioscsi_attach(device_t parent, device_t self, void *aux)
    115   1.1  christos {
    116   1.1  christos 	struct vioscsi_softc *sc = device_private(self);
    117   1.1  christos 	struct virtio_softc *vsc = device_private(parent);
    118   1.1  christos 	struct scsipi_adapter *adapt = &sc->sc_adapter;
    119   1.1  christos 	struct scsipi_channel *chan = &sc->sc_channel;
    120  1.12  jdolecek 	int rv, qsize = 0, i = 0;
    121  1.12  jdolecek 	int ipl = IPL_BIO;
    122   1.1  christos 
    123  1.12  jdolecek 	if (virtio_child(vsc) != NULL) {
    124   1.1  christos 		aprint_error(": parent %s already has a child\n",
    125   1.1  christos 		    device_xname(parent));
    126   1.1  christos 		return;
    127   1.1  christos 	}
    128   1.1  christos 
    129   1.1  christos 	sc->sc_dev = self;
    130   1.1  christos 
    131  1.12  jdolecek 	virtio_child_attach_start(vsc, self, ipl, sc->sc_vqs,
    132  1.15  jdolecek 	    NULL, virtio_vq_intr, VIRTIO_F_PCI_INTR_MSIX,
    133  1.12  jdolecek 	    0, VIRTIO_COMMON_FLAG_BITS);
    134   1.1  christos 
    135  1.15  jdolecek 	mutex_init(&sc->sc_mutex, MUTEX_DEFAULT, ipl);
    136  1.15  jdolecek 
    137   1.1  christos 	uint32_t cmd_per_lun = virtio_read_device_config_4(vsc,
    138   1.1  christos 	    VIRTIO_SCSI_CONFIG_CMD_PER_LUN);
    139   1.1  christos 
    140   1.1  christos 	uint32_t seg_max = virtio_read_device_config_4(vsc,
    141   1.1  christos 	    VIRTIO_SCSI_CONFIG_SEG_MAX);
    142   1.1  christos 
    143   1.1  christos 	uint16_t max_target = virtio_read_device_config_2(vsc,
    144   1.1  christos 	    VIRTIO_SCSI_CONFIG_MAX_TARGET);
    145   1.1  christos 
    146   1.1  christos 	uint32_t max_lun = virtio_read_device_config_4(vsc,
    147   1.1  christos 	    VIRTIO_SCSI_CONFIG_MAX_LUN);
    148   1.1  christos 
    149   1.1  christos 	sc->sc_seg_max = seg_max;
    150   1.1  christos 
    151  1.15  jdolecek 	for(i=0; i < __arraycount(sc->sc_vqs); i++) {
    152   1.1  christos 		rv = virtio_alloc_vq(vsc, &sc->sc_vqs[i], i, MAXPHYS,
    153  1.17  jdolecek 		    VIRTIO_SCSI_MIN_SEGMENTS + howmany(MAXPHYS, NBPG),
    154  1.15  jdolecek 		    vioscsi_vq_names[i]);
    155   1.1  christos 		if (rv) {
    156   1.1  christos 			aprint_error_dev(sc->sc_dev,
    157  1.15  jdolecek 			    "failed to allocate virtqueue %d\n", i);
    158  1.15  jdolecek 			goto err;
    159   1.1  christos 		}
    160  1.10  jdolecek 
    161  1.10  jdolecek 		if (i == VIOSCSI_VQ_REQUEST)
    162  1.10  jdolecek 			sc->sc_vqs[i].vq_done = vioscsi_vq_done;
    163   1.1  christos 	}
    164   1.1  christos 
    165  1.12  jdolecek 	qsize = sc->sc_vqs[VIOSCSI_VQ_REQUEST].vq_num;
    166  1.15  jdolecek 	if (vioscsi_alloc_reqs(sc, vsc, qsize))
    167  1.15  jdolecek 		goto err;
    168   1.1  christos 
    169  1.12  jdolecek 	aprint_normal_dev(sc->sc_dev,
    170  1.16  christos 	    "cmd_per_lun %u qsize %d seg_max %u max_target %hu"
    171  1.16  christos 	    " max_lun %u\n",
    172  1.12  jdolecek 	    cmd_per_lun, qsize, seg_max, max_target, max_lun);
    173  1.12  jdolecek 
    174  1.12  jdolecek 	if (virtio_child_attach_finish(vsc) != 0)
    175  1.12  jdolecek 		goto err;
    176  1.10  jdolecek 
    177   1.1  christos 	/*
    178   1.1  christos 	 * Fill in the scsipi_adapter.
    179   1.1  christos 	 */
    180   1.1  christos 	memset(adapt, 0, sizeof(*adapt));
    181   1.1  christos 	adapt->adapt_dev = sc->sc_dev;
    182  1.14  jdolecek 	adapt->adapt_nchannels = 1;
    183  1.13  jdolecek 	adapt->adapt_openings = MIN(qsize, cmd_per_lun);
    184   1.1  christos 	adapt->adapt_max_periph = adapt->adapt_openings;
    185   1.1  christos 	adapt->adapt_request = vioscsi_scsipi_request;
    186   1.1  christos 	adapt->adapt_minphys = minphys;
    187   1.1  christos 
    188   1.1  christos 	/*
    189   1.1  christos 	 * Fill in the scsipi_channel.
    190   1.1  christos 	 */
    191   1.1  christos 	memset(chan, 0, sizeof(*chan));
    192   1.1  christos 	chan->chan_adapter = adapt;
    193   1.1  christos 	chan->chan_bustype = &scsi_bustype;
    194   1.1  christos 	chan->chan_channel = 0;
    195  1.13  jdolecek 	chan->chan_ntargets = MIN(max_target, 16);	/* cap reasonably */
    196  1.15  jdolecek 	chan->chan_nluns = MIN(max_lun, 1024);		/* cap reasonably */
    197  1.22       kim 	chan->chan_id = max_target;
    198   1.6     pooka 	chan->chan_flags = SCSIPI_CHAN_NOSETTLE;
    199  1.23  jakllsch 	/*
    200  1.23  jakllsch 	 * XXX Remove this when scsipi is REPORT LUNS-aware.
    201  1.23  jakllsch 	 * scsipi(4) insists that LUNs must be contiguous starting from 0.
    202  1.23  jakllsch 	 * This is not true on Linode (circa 2020) and Proxmox 6 hosts
    203  1.23  jakllsch 	 * with more than one disk exported to guest.
    204  1.23  jakllsch 	 */
    205  1.23  jakllsch 	chan->chan_defquirks = PQUIRK_FORCELUNS;
    206   1.1  christos 
    207  1.12  jdolecek 	config_found(self, &sc->sc_channel, scsiprint);
    208  1.12  jdolecek 	return;
    209  1.12  jdolecek 
    210  1.12  jdolecek err:
    211  1.12  jdolecek 	if (qsize > 0)
    212  1.12  jdolecek 		vioscsi_free_reqs(sc, vsc);
    213  1.12  jdolecek 
    214  1.12  jdolecek 	for (i=0; i < __arraycount(sc->sc_vqs); i++) {
    215  1.12  jdolecek 		if (sc->sc_vqs[i].vq_num > 0)
    216  1.12  jdolecek 			virtio_free_vq(vsc, &sc->sc_vqs[i]);
    217  1.12  jdolecek 	}
    218  1.12  jdolecek 
    219  1.12  jdolecek 	virtio_child_attach_failed(vsc);
    220  1.15  jdolecek }
    221  1.15  jdolecek 
    222  1.15  jdolecek static int
    223  1.15  jdolecek vioscsi_detach(device_t self, int flags)
    224  1.15  jdolecek {
    225  1.15  jdolecek 	struct vioscsi_softc *sc = device_private(self);
    226  1.15  jdolecek 	struct virtio_softc *vsc = device_private(device_parent(sc->sc_dev));
    227  1.15  jdolecek 	int rc, i;
    228  1.15  jdolecek 
    229  1.15  jdolecek 	/*
    230  1.15  jdolecek 	 * Dequeue all pending finished requests. Must be done
    231  1.15  jdolecek 	 * before we try to detach children so that we process
    232  1.15  jdolecek 	 * their pending requests while they still exist.
    233  1.15  jdolecek 	 */
    234  1.15  jdolecek 	if (sc->sc_vqs[VIOSCSI_VQ_REQUEST].vq_num > 0)
    235  1.15  jdolecek 		vioscsi_vq_done(&sc->sc_vqs[VIOSCSI_VQ_REQUEST]);
    236  1.12  jdolecek 
    237  1.15  jdolecek 	if ((rc = config_detach_children(self, flags)) != 0)
    238  1.15  jdolecek 		return rc;
    239  1.15  jdolecek 
    240  1.15  jdolecek 	virtio_reset(vsc);
    241  1.15  jdolecek 
    242  1.15  jdolecek 	for (i = 0; i < __arraycount(sc->sc_vqs); i++) {
    243  1.15  jdolecek 		if (sc->sc_vqs[i].vq_num > 0)
    244  1.15  jdolecek 			virtio_free_vq(vsc, &sc->sc_vqs[i]);
    245  1.15  jdolecek 	}
    246  1.15  jdolecek 
    247  1.15  jdolecek 	vioscsi_free_reqs(sc, vsc);
    248  1.15  jdolecek 
    249  1.15  jdolecek 	virtio_child_detach(vsc);
    250  1.15  jdolecek 
    251  1.15  jdolecek 	mutex_destroy(&sc->sc_mutex);
    252  1.15  jdolecek 
    253  1.15  jdolecek 	return 0;
    254   1.1  christos }
    255   1.1  christos 
    256   1.1  christos #define XS2DMA(xs) \
    257   1.1  christos     ((((xs)->xs_control & XS_CTL_DATA_IN) ? BUS_DMA_READ : BUS_DMA_WRITE) | \
    258   1.1  christos     (((xs)->xs_control & XS_CTL_NOSLEEP) ? BUS_DMA_NOWAIT : BUS_DMA_WAITOK) | \
    259   1.1  christos     BUS_DMA_STREAMING)
    260   1.1  christos 
    261   1.1  christos #define XS2DMAPRE(xs) (((xs)->xs_control & XS_CTL_DATA_IN) ? \
    262   1.1  christos     BUS_DMASYNC_PREREAD : BUS_DMASYNC_PREWRITE)
    263   1.1  christos 
    264   1.1  christos #define XS2DMAPOST(xs) (((xs)->xs_control & XS_CTL_DATA_IN) ? \
    265   1.1  christos     BUS_DMASYNC_POSTREAD : BUS_DMASYNC_POSTWRITE)
    266   1.1  christos 
    267   1.1  christos static void
    268   1.1  christos vioscsi_scsipi_request(struct scsipi_channel *chan, scsipi_adapter_req_t
    269   1.1  christos     request, void *arg)
    270   1.1  christos {
    271   1.1  christos 	struct vioscsi_softc *sc =
    272   1.1  christos 	    device_private(chan->chan_adapter->adapt_dev);
    273   1.1  christos 	struct virtio_softc *vsc = device_private(device_parent(sc->sc_dev));
    274   1.1  christos 	struct scsipi_xfer *xs;
    275   1.1  christos 	struct scsipi_periph *periph;
    276   1.1  christos 	struct vioscsi_req *vr;
    277   1.1  christos 	struct virtio_scsi_req_hdr *req;
    278  1.11  jdolecek 	struct virtqueue *vq = &sc->sc_vqs[VIOSCSI_VQ_REQUEST];
    279   1.1  christos 	int slot, error;
    280  1.21      maxv 	bool dopoll;
    281   1.1  christos 
    282   1.1  christos 	DPRINTF(("%s: enter\n", __func__));
    283   1.1  christos 
    284   1.8  jdolecek 	switch (request) {
    285   1.8  jdolecek 	case ADAPTER_REQ_RUN_XFER:
    286   1.8  jdolecek 		break;
    287   1.8  jdolecek 	case ADAPTER_REQ_SET_XFER_MODE:
    288   1.8  jdolecek 	{
    289   1.8  jdolecek 		struct scsipi_xfer_mode *xm = arg;
    290   1.8  jdolecek 		xm->xm_mode = PERIPH_CAP_TQING;
    291   1.8  jdolecek 		xm->xm_period = 0;
    292   1.8  jdolecek 		xm->xm_offset = 0;
    293   1.8  jdolecek 		scsipi_async_event(chan, ASYNC_EVENT_XFER_MODE, xm);
    294   1.8  jdolecek 		return;
    295   1.8  jdolecek 	}
    296   1.8  jdolecek 	default:
    297   1.1  christos 		DPRINTF(("%s: unhandled %d\n", __func__, request));
    298   1.1  christos 		return;
    299   1.1  christos 	}
    300   1.1  christos 
    301   1.1  christos 	xs = arg;
    302   1.1  christos 	periph = xs->xs_periph;
    303   1.1  christos 
    304   1.1  christos 	/*
    305   1.7  jdolecek 	 * This can happen when we run out of queue slots.
    306   1.1  christos 	 */
    307  1.10  jdolecek 	vr = vioscsi_req_get(sc);
    308   1.1  christos 	if (vr == NULL) {
    309   1.7  jdolecek 		xs->error = XS_RESOURCE_SHORTAGE;
    310   1.7  jdolecek 		scsipi_done(xs);
    311   1.7  jdolecek 		return;
    312   1.1  christos 	}
    313   1.7  jdolecek 
    314   1.1  christos 	req = &vr->vr_req;
    315   1.1  christos 	slot = vr - sc->sc_reqs;
    316   1.1  christos 
    317   1.1  christos 	/*
    318   1.1  christos 	 * "The only supported format for the LUN field is: first byte set to
    319   1.1  christos 	 * 1, second byte set to target, third and fourth byte representing a
    320   1.1  christos 	 * single level LUN structure, followed by four zero bytes."
    321   1.1  christos 	 */
    322  1.15  jdolecek 	if (periph->periph_target >= 256 || periph->periph_lun >= 16384
    323  1.15  jdolecek 	    || periph->periph_target < 0 || periph->periph_lun < 0) {
    324   1.1  christos 		goto stuffup;
    325   1.1  christos 	}
    326  1.15  jdolecek 
    327   1.1  christos 	req->lun[0] = 1;
    328  1.22       kim 	req->lun[1] = periph->periph_target;
    329  1.10  jdolecek 	req->lun[2] = 0x40 | ((periph->periph_lun >> 8) & 0x3F);
    330  1.10  jdolecek 	req->lun[3] = periph->periph_lun & 0xFF;
    331   1.1  christos 	memset(req->lun + 4, 0, 4);
    332  1.15  jdolecek 	DPRINTF(("%s: command %p for %d:%d at slot %d\n", __func__,
    333  1.15  jdolecek 	    xs, periph->periph_target, periph->periph_lun, slot));
    334   1.1  christos 
    335   1.8  jdolecek 	/* tag */
    336   1.8  jdolecek 	switch (XS_CTL_TAGTYPE(xs)) {
    337   1.8  jdolecek 	case XS_CTL_HEAD_TAG:
    338   1.8  jdolecek 		req->task_attr = VIRTIO_SCSI_S_HEAD;
    339   1.8  jdolecek 		break;
    340   1.8  jdolecek 
    341   1.8  jdolecek #if 0	/* XXX */
    342   1.8  jdolecek 	case XS_CTL_ACA_TAG:
    343   1.8  jdolecek 		req->task_attr = VIRTIO_SCSI_S_ACA;
    344   1.8  jdolecek 		break;
    345   1.8  jdolecek #endif
    346   1.8  jdolecek 
    347   1.8  jdolecek 	case XS_CTL_ORDERED_TAG:
    348   1.8  jdolecek 		req->task_attr = VIRTIO_SCSI_S_ORDERED;
    349   1.8  jdolecek 		break;
    350   1.8  jdolecek 
    351   1.8  jdolecek 	case XS_CTL_SIMPLE_TAG:
    352   1.8  jdolecek 	default:
    353   1.8  jdolecek 		req->task_attr = VIRTIO_SCSI_S_SIMPLE;
    354   1.8  jdolecek 		break;
    355   1.8  jdolecek 	}
    356  1.10  jdolecek 	req->id = slot;
    357   1.8  jdolecek 
    358   1.2  christos 	if ((size_t)xs->cmdlen > sizeof(req->cdb)) {
    359   1.2  christos 		DPRINTF(("%s: bad cmdlen %zu > %zu\n", __func__,
    360   1.2  christos 		    (size_t)xs->cmdlen, sizeof(req->cdb)));
    361   1.1  christos 		goto stuffup;
    362   1.2  christos 	}
    363   1.2  christos 
    364   1.1  christos 	memset(req->cdb, 0, sizeof(req->cdb));
    365   1.1  christos 	memcpy(req->cdb, xs->cmd, xs->cmdlen);
    366   1.1  christos 
    367  1.12  jdolecek 	error = bus_dmamap_load(virtio_dmat(vsc), vr->vr_data,
    368   1.1  christos 	    xs->data, xs->datalen, NULL, XS2DMA(xs));
    369  1.18  jdolecek 	if (error) {
    370  1.18  jdolecek 		aprint_error_dev(sc->sc_dev, "%s: error %d loading DMA map\n",
    371  1.18  jdolecek 		    __func__, error);
    372  1.18  jdolecek 
    373  1.18  jdolecek 		if (error == ENOMEM || error == EAGAIN) {
    374  1.18  jdolecek 			/*
    375  1.18  jdolecek 			 * Map is allocated with ALLOCNOW, so this should
    376  1.18  jdolecek 			 * actually never ever happen.
    377  1.18  jdolecek 			 */
    378  1.18  jdolecek 			xs->error = XS_RESOURCE_SHORTAGE;
    379  1.18  jdolecek 		} else {
    380  1.11  jdolecek stuffup:
    381  1.18  jdolecek 			/* not a temporary condition */
    382  1.18  jdolecek 			xs->error = XS_DRIVER_STUFFUP;
    383  1.18  jdolecek 		}
    384  1.18  jdolecek 
    385  1.18  jdolecek 		virtio_enqueue_abort(vsc, vq, slot);
    386   1.1  christos 		scsipi_done(xs);
    387   1.1  christos 		return;
    388   1.1  christos 	}
    389   1.1  christos 
    390   1.2  christos 	int nsegs = VIRTIO_SCSI_MIN_SEGMENTS;
    391   1.2  christos 	if ((xs->xs_control & (XS_CTL_DATA_IN|XS_CTL_DATA_OUT)) != 0)
    392   1.2  christos 		nsegs += vr->vr_data->dm_nsegs;
    393   1.2  christos 
    394   1.2  christos 	error = virtio_enqueue_reserve(vsc, vq, slot, nsegs);
    395   1.1  christos 	if (error) {
    396  1.18  jdolecek 		aprint_error_dev(sc->sc_dev, "error reserving %d (nsegs %d)\n",
    397  1.18  jdolecek 		    error, nsegs);
    398  1.12  jdolecek 		bus_dmamap_unload(virtio_dmat(vsc), vr->vr_data);
    399  1.18  jdolecek 		/* slot already freed by virtio_enqueue_reserve() */
    400  1.11  jdolecek 		xs->error = XS_RESOURCE_SHORTAGE;
    401  1.18  jdolecek 		scsipi_done(xs);
    402  1.18  jdolecek 		return;
    403   1.1  christos 	}
    404   1.1  christos 
    405  1.15  jdolecek 	vr->vr_xs = xs;
    406  1.15  jdolecek 
    407  1.12  jdolecek 	bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
    408   1.1  christos 	    offsetof(struct vioscsi_req, vr_req),
    409   1.1  christos 	    sizeof(struct virtio_scsi_req_hdr),
    410   1.1  christos 	    BUS_DMASYNC_PREWRITE);
    411  1.12  jdolecek 	bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
    412   1.1  christos 	    offsetof(struct vioscsi_req, vr_res),
    413   1.1  christos             sizeof(struct virtio_scsi_res_hdr),
    414   1.1  christos 	    BUS_DMASYNC_PREREAD);
    415   1.2  christos 	if ((xs->xs_control & (XS_CTL_DATA_IN|XS_CTL_DATA_OUT)) != 0)
    416  1.12  jdolecek 		bus_dmamap_sync(virtio_dmat(vsc), vr->vr_data, 0, xs->datalen,
    417   1.2  christos 		    XS2DMAPRE(xs));
    418   1.1  christos 
    419   1.1  christos 	virtio_enqueue_p(vsc, vq, slot, vr->vr_control,
    420   1.1  christos 	    offsetof(struct vioscsi_req, vr_req),
    421   1.1  christos             sizeof(struct virtio_scsi_req_hdr), 1);
    422   1.1  christos 	if (xs->xs_control & XS_CTL_DATA_OUT)
    423   1.1  christos 		virtio_enqueue(vsc, vq, slot, vr->vr_data, 1);
    424   1.1  christos 	virtio_enqueue_p(vsc, vq, slot, vr->vr_control,
    425   1.1  christos 	    offsetof(struct vioscsi_req, vr_res),
    426   1.1  christos             sizeof(struct virtio_scsi_res_hdr), 0);
    427   1.1  christos 	if (xs->xs_control & XS_CTL_DATA_IN)
    428   1.1  christos 		virtio_enqueue(vsc, vq, slot, vr->vr_data, 0);
    429  1.21      maxv 	dopoll = (xs->xs_control & XS_CTL_POLL) != 0;
    430   1.1  christos 	virtio_enqueue_commit(vsc, vq, slot, 1);
    431   1.1  christos 
    432  1.21      maxv 	if (!dopoll)
    433   1.1  christos 		return;
    434   1.1  christos 
    435   1.1  christos 	DPRINTF(("%s: polling...\n", __func__));
    436   1.1  christos 	// XXX: do this better.
    437   1.1  christos 	int timeout = 1000;
    438   1.1  christos 	do {
    439  1.12  jdolecek 		virtio_intrhand(vsc);
    440   1.1  christos 		if (vr->vr_xs != xs)
    441   1.1  christos 			break;
    442   1.1  christos 		delay(1000);
    443   1.1  christos 	} while (--timeout > 0);
    444   1.1  christos 
    445   1.1  christos 	if (vr->vr_xs == xs) {
    446   1.1  christos 		// XXX: Abort!
    447   1.1  christos 		xs->error = XS_TIMEOUT;
    448   1.1  christos 		xs->resid = xs->datalen;
    449   1.1  christos 		DPRINTF(("%s: polling timeout\n", __func__));
    450   1.1  christos 		scsipi_done(xs);
    451   1.1  christos 	}
    452  1.15  jdolecek 	DPRINTF(("%s: command %p done (timeout=%d)\n", __func__,
    453  1.15  jdolecek 	    xs, timeout));
    454   1.1  christos }
    455   1.1  christos 
    456   1.1  christos static void
    457   1.1  christos vioscsi_req_done(struct vioscsi_softc *sc, struct virtio_softc *vsc,
    458  1.19  jdolecek     struct vioscsi_req *vr, struct virtqueue *vq, int slot)
    459   1.1  christos {
    460   1.1  christos 	struct scsipi_xfer *xs = vr->vr_xs;
    461   1.4  christos 	size_t sense_len;
    462   1.1  christos 
    463   1.1  christos 	DPRINTF(("%s: enter\n", __func__));
    464   1.1  christos 
    465  1.12  jdolecek 	bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
    466   1.1  christos 	    offsetof(struct vioscsi_req, vr_req),
    467   1.1  christos 	    sizeof(struct virtio_scsi_req_hdr),
    468   1.1  christos 	    BUS_DMASYNC_POSTWRITE);
    469  1.12  jdolecek 	bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
    470   1.1  christos 	    offsetof(struct vioscsi_req, vr_res),
    471   1.1  christos 	    sizeof(struct virtio_scsi_res_hdr),
    472   1.1  christos 	    BUS_DMASYNC_POSTREAD);
    473  1.12  jdolecek 	bus_dmamap_sync(virtio_dmat(vsc), vr->vr_data, 0, xs->datalen,
    474   1.1  christos 	    XS2DMAPOST(xs));
    475   1.1  christos 
    476  1.11  jdolecek 	xs->status = vr->vr_res.status;
    477  1.11  jdolecek 	xs->resid = vr->vr_res.residual;
    478  1.11  jdolecek 
    479   1.4  christos 	switch (vr->vr_res.response) {
    480   1.4  christos 	case VIRTIO_SCSI_S_OK:
    481   1.4  christos 		sense_len = MIN(sizeof(xs->sense), vr->vr_res.sense_len);
    482   1.4  christos 		memcpy(&xs->sense, vr->vr_res.sense, sense_len);
    483   1.4  christos 		xs->error = (sense_len == 0) ? XS_NOERROR : XS_SENSE;
    484   1.4  christos 		break;
    485   1.4  christos 	case VIRTIO_SCSI_S_BAD_TARGET:
    486  1.15  jdolecek 		vioscsi_bad_target(xs);
    487   1.4  christos 		break;
    488   1.4  christos 	default:
    489   1.4  christos 		DPRINTF(("%s: stuffup: %d\n", __func__, vr->vr_res.response));
    490   1.1  christos 		xs->error = XS_DRIVER_STUFFUP;
    491   1.1  christos 		xs->resid = xs->datalen;
    492   1.4  christos 		break;
    493   1.1  christos 	}
    494   1.1  christos 
    495  1.15  jdolecek 	DPRINTF(("%s: command %p done %d, %d, %d\n", __func__,
    496  1.15  jdolecek 	    xs, xs->error, xs->status, xs->resid));
    497   1.1  christos 
    498  1.12  jdolecek 	bus_dmamap_unload(virtio_dmat(vsc), vr->vr_data);
    499   1.1  christos 	vr->vr_xs = NULL;
    500  1.11  jdolecek 
    501  1.19  jdolecek 	virtio_dequeue_commit(vsc, vq, slot);
    502  1.19  jdolecek 
    503  1.15  jdolecek 	mutex_exit(&sc->sc_mutex);
    504   1.1  christos 	scsipi_done(xs);
    505  1.15  jdolecek 	mutex_enter(&sc->sc_mutex);
    506  1.15  jdolecek }
    507  1.15  jdolecek 
    508  1.15  jdolecek static void
    509  1.15  jdolecek vioscsi_bad_target(struct scsipi_xfer *xs)
    510  1.15  jdolecek {
    511  1.15  jdolecek 	struct scsi_sense_data *sense = &xs->sense.scsi_sense;
    512  1.15  jdolecek 
    513  1.15  jdolecek 	DPRINTF(("%s: bad target %d:%d\n", __func__,
    514  1.15  jdolecek 	    xs->xs_periph->periph_target, xs->xs_periph->periph_lun));
    515  1.15  jdolecek 
    516  1.15  jdolecek 	memset(sense, 0, sizeof(*sense));
    517  1.15  jdolecek 	sense->response_code = 0x70;
    518  1.15  jdolecek 	sense->flags = SKEY_ILLEGAL_REQUEST;
    519  1.15  jdolecek 	xs->error = XS_SENSE;
    520  1.15  jdolecek 	xs->status = 0;
    521  1.15  jdolecek 	xs->resid = 0;
    522   1.1  christos }
    523   1.1  christos 
    524   1.1  christos static int
    525   1.1  christos vioscsi_vq_done(struct virtqueue *vq)
    526   1.1  christos {
    527   1.1  christos 	struct virtio_softc *vsc = vq->vq_owner;
    528  1.12  jdolecek 	struct vioscsi_softc *sc = device_private(virtio_child(vsc));
    529   1.1  christos 	int ret = 0;
    530   1.1  christos 
    531  1.15  jdolecek 	DPRINTF(("%s: enter %d\n", __func__, vq->vq_index));
    532  1.15  jdolecek 
    533  1.15  jdolecek 	mutex_enter(&sc->sc_mutex);
    534   1.1  christos 
    535   1.1  christos 	for (;;) {
    536   1.1  christos 		int r, slot;
    537  1.15  jdolecek 
    538   1.1  christos 		r = virtio_dequeue(vsc, vq, &slot, NULL);
    539   1.1  christos 		if (r != 0)
    540   1.1  christos 			break;
    541   1.1  christos 
    542   1.1  christos 		DPRINTF(("%s: slot=%d\n", __func__, slot));
    543  1.11  jdolecek 
    544  1.19  jdolecek 		vioscsi_req_done(sc, vsc, &sc->sc_reqs[slot], vq, slot);
    545  1.11  jdolecek 
    546   1.1  christos 		ret = 1;
    547   1.1  christos 	}
    548   1.1  christos 
    549  1.15  jdolecek 	mutex_exit(&sc->sc_mutex);
    550  1.15  jdolecek 
    551  1.15  jdolecek 	DPRINTF(("%s: exit %d: %d\n", __func__, vq->vq_index, ret));
    552   1.1  christos 
    553   1.1  christos 	return ret;
    554   1.1  christos }
    555   1.1  christos 
    556   1.1  christos static struct vioscsi_req *
    557   1.1  christos vioscsi_req_get(struct vioscsi_softc *sc)
    558   1.1  christos {
    559   1.1  christos 	struct virtio_softc *vsc = device_private(device_parent(sc->sc_dev));
    560  1.10  jdolecek 	struct virtqueue *vq = &sc->sc_vqs[VIOSCSI_VQ_REQUEST];
    561  1.15  jdolecek 	struct vioscsi_req *vr = NULL;
    562   1.1  christos 	int r, slot;
    563   1.1  christos 
    564  1.15  jdolecek 	mutex_enter(&sc->sc_mutex);
    565  1.15  jdolecek 
    566   1.1  christos 	if ((r = virtio_enqueue_prep(vsc, vq, &slot)) != 0) {
    567   1.1  christos 		DPRINTF(("%s: virtio_enqueue_get error %d\n", __func__, r));
    568  1.15  jdolecek 		goto out;
    569   1.1  christos 	}
    570   1.9  jdolecek 	KASSERT(slot < sc->sc_nreqs);
    571   1.1  christos 	vr = &sc->sc_reqs[slot];
    572   1.1  christos 
    573   1.1  christos 	DPRINTF(("%s: %p, %d\n", __func__, vr, slot));
    574   1.1  christos 
    575  1.15  jdolecek out:
    576  1.15  jdolecek 	mutex_exit(&sc->sc_mutex);
    577  1.15  jdolecek 
    578   1.1  christos 	return vr;
    579   1.1  christos }
    580   1.1  christos 
    581  1.15  jdolecek static int
    582   1.1  christos vioscsi_alloc_reqs(struct vioscsi_softc *sc, struct virtio_softc *vsc,
    583  1.15  jdolecek     int qsize)
    584   1.1  christos {
    585   1.1  christos 	size_t allocsize;
    586   1.9  jdolecek 	int r, rsegs, slot;
    587   1.1  christos 	void *vaddr;
    588   1.9  jdolecek 	struct vioscsi_req *vr;
    589   1.1  christos 
    590   1.1  christos 	allocsize = qsize * sizeof(struct vioscsi_req);
    591  1.12  jdolecek 	r = bus_dmamem_alloc(virtio_dmat(vsc), allocsize, 0, 0,
    592   1.1  christos 	    &sc->sc_reqs_segs[0], 1, &rsegs, BUS_DMA_NOWAIT);
    593   1.1  christos 	if (r != 0) {
    594   1.1  christos 		aprint_error_dev(sc->sc_dev,
    595   1.1  christos 		    "%s: bus_dmamem_alloc, size %zu, error %d\n", __func__,
    596   1.1  christos 		    allocsize, r);
    597   1.9  jdolecek 		return r;
    598   1.1  christos 	}
    599  1.12  jdolecek 	r = bus_dmamem_map(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1,
    600   1.1  christos 	    allocsize, &vaddr, BUS_DMA_NOWAIT);
    601   1.1  christos 	if (r != 0) {
    602   1.1  christos 		aprint_error_dev(sc->sc_dev,
    603   1.1  christos 		    "%s: bus_dmamem_map failed, error %d\n", __func__, r);
    604  1.12  jdolecek 		bus_dmamem_free(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1);
    605   1.9  jdolecek 		return r;
    606   1.1  christos 	}
    607   1.9  jdolecek 	memset(vaddr, 0, allocsize);
    608   1.9  jdolecek 
    609   1.1  christos 	sc->sc_reqs = vaddr;
    610   1.9  jdolecek 	sc->sc_nreqs = qsize;
    611   1.9  jdolecek 
    612   1.9  jdolecek 	/* Prepare maps for the requests */
    613   1.9  jdolecek 	for (slot=0; slot < qsize; slot++) {
    614   1.9  jdolecek 		vr = &sc->sc_reqs[slot];
    615   1.9  jdolecek 
    616  1.12  jdolecek 		r = bus_dmamap_create(virtio_dmat(vsc),
    617   1.9  jdolecek 		    offsetof(struct vioscsi_req, vr_xs), 1,
    618   1.9  jdolecek 		    offsetof(struct vioscsi_req, vr_xs), 0,
    619   1.9  jdolecek 		    BUS_DMA_NOWAIT|BUS_DMA_ALLOCNOW, &vr->vr_control);
    620   1.9  jdolecek 		if (r != 0) {
    621   1.9  jdolecek 			aprint_error_dev(sc->sc_dev,
    622  1.15  jdolecek 		    	    "%s: bus_dmamem_create ctrl failed, error %d\n",
    623   1.9  jdolecek 			    __func__, r);
    624   1.9  jdolecek 			goto cleanup;
    625   1.9  jdolecek 		}
    626   1.9  jdolecek 
    627  1.12  jdolecek 		r = bus_dmamap_create(virtio_dmat(vsc), MAXPHYS, sc->sc_seg_max,
    628   1.9  jdolecek 		    MAXPHYS, 0, BUS_DMA_NOWAIT|BUS_DMA_ALLOCNOW, &vr->vr_data);
    629   1.9  jdolecek 		if (r != 0) {
    630   1.9  jdolecek 			aprint_error_dev(sc->sc_dev,
    631  1.15  jdolecek 		    	    "%s: bus_dmamem_create data failed, error %d\n",
    632   1.9  jdolecek 			    __func__, r);
    633   1.9  jdolecek 			goto cleanup;
    634   1.9  jdolecek 		}
    635   1.9  jdolecek 
    636  1.12  jdolecek 		r = bus_dmamap_load(virtio_dmat(vsc), vr->vr_control,
    637   1.9  jdolecek 		    vr, offsetof(struct vioscsi_req, vr_xs), NULL,
    638   1.9  jdolecek 		    BUS_DMA_NOWAIT);
    639   1.9  jdolecek 		if (r != 0) {
    640   1.9  jdolecek 			aprint_error_dev(sc->sc_dev,
    641  1.15  jdolecek 		    	    "%s: bus_dmamap_load ctrl error %d\n",
    642   1.9  jdolecek 			    __func__, r);
    643   1.9  jdolecek 			goto cleanup;
    644   1.9  jdolecek 		}
    645   1.9  jdolecek 	}
    646   1.9  jdolecek 
    647   1.1  christos 	return 0;
    648   1.9  jdolecek 
    649   1.9  jdolecek cleanup:
    650   1.9  jdolecek 	for (; slot > 0; slot--) {
    651   1.9  jdolecek 		vr = &sc->sc_reqs[slot];
    652   1.9  jdolecek 
    653   1.9  jdolecek 		if (vr->vr_control) {
    654   1.9  jdolecek 			/* this will also unload the mapping if loaded */
    655  1.12  jdolecek 			bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_control);
    656   1.9  jdolecek 			vr->vr_control = NULL;
    657   1.9  jdolecek 		}
    658   1.9  jdolecek 
    659   1.9  jdolecek 		if (vr->vr_data) {
    660  1.12  jdolecek 			bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_data);
    661   1.9  jdolecek 			vr->vr_data = NULL;
    662   1.9  jdolecek 		}
    663   1.9  jdolecek 	}
    664   1.9  jdolecek 
    665  1.12  jdolecek 	bus_dmamem_unmap(virtio_dmat(vsc), vaddr, allocsize);
    666  1.12  jdolecek 	bus_dmamem_free(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1);
    667   1.9  jdolecek 
    668   1.9  jdolecek 	return r;
    669   1.1  christos }
    670  1.12  jdolecek 
    671  1.12  jdolecek static void
    672  1.12  jdolecek vioscsi_free_reqs(struct vioscsi_softc *sc, struct virtio_softc *vsc)
    673  1.12  jdolecek {
    674  1.12  jdolecek 	int slot;
    675  1.12  jdolecek 	struct vioscsi_req *vr;
    676  1.12  jdolecek 
    677  1.12  jdolecek 	if (sc->sc_nreqs == 0) {
    678  1.12  jdolecek 		/* Not allocated */
    679  1.12  jdolecek 		return;
    680  1.12  jdolecek 	}
    681  1.12  jdolecek 
    682  1.12  jdolecek 	/* Free request maps */
    683  1.12  jdolecek 	for (slot=0; slot < sc->sc_nreqs; slot++) {
    684  1.12  jdolecek 		vr = &sc->sc_reqs[slot];
    685  1.12  jdolecek 
    686  1.12  jdolecek 		bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_control);
    687  1.12  jdolecek 		bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_data);
    688  1.12  jdolecek 	}
    689  1.12  jdolecek 
    690  1.12  jdolecek 	bus_dmamem_unmap(virtio_dmat(vsc), sc->sc_reqs,
    691  1.12  jdolecek 			 sc->sc_nreqs * sizeof(struct vioscsi_req));
    692  1.12  jdolecek 	bus_dmamem_free(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1);
    693  1.12  jdolecek }
    694  1.12  jdolecek 
    695  1.15  jdolecek MODULE(MODULE_CLASS_DRIVER, vioscsi, "virtio");
    696  1.15  jdolecek 
    697  1.15  jdolecek #ifdef _MODULE
    698  1.15  jdolecek #include "ioconf.c"
    699  1.15  jdolecek #endif
    700  1.15  jdolecek 
    701  1.15  jdolecek static int
    702  1.15  jdolecek vioscsi_modcmd(modcmd_t cmd, void *opaque)
    703  1.15  jdolecek {
    704  1.15  jdolecek         int error = 0;
    705  1.15  jdolecek 
    706  1.15  jdolecek #ifdef _MODULE
    707  1.15  jdolecek         switch (cmd) {
    708  1.15  jdolecek         case MODULE_CMD_INIT:
    709  1.15  jdolecek                 error = config_init_component(cfdriver_ioconf_vioscsi,
    710  1.15  jdolecek                     cfattach_ioconf_vioscsi, cfdata_ioconf_vioscsi);
    711  1.15  jdolecek                 break;
    712  1.15  jdolecek         case MODULE_CMD_FINI:
    713  1.15  jdolecek                 error = config_fini_component(cfdriver_ioconf_vioscsi,
    714  1.15  jdolecek                     cfattach_ioconf_vioscsi, cfdata_ioconf_vioscsi);
    715  1.15  jdolecek                 break;
    716  1.15  jdolecek         default:
    717  1.15  jdolecek                 error = ENOTTY;
    718  1.15  jdolecek                 break;
    719  1.15  jdolecek         }
    720  1.15  jdolecek #endif
    721  1.15  jdolecek 
    722  1.15  jdolecek         return error;
    723  1.15  jdolecek }
    724