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