vioscsi.c revision 1.22 1 1.22 kim /* $NetBSD: vioscsi.c,v 1.22 2020/07/12 06:40:11 kim 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.22 kim __KERNEL_RCSID(0, "$NetBSD: vioscsi.c,v 1.22 2020/07/12 06:40:11 kim 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.1 christos
200 1.12 jdolecek config_found(self, &sc->sc_channel, scsiprint);
201 1.12 jdolecek return;
202 1.12 jdolecek
203 1.12 jdolecek err:
204 1.12 jdolecek if (qsize > 0)
205 1.12 jdolecek vioscsi_free_reqs(sc, vsc);
206 1.12 jdolecek
207 1.12 jdolecek for (i=0; i < __arraycount(sc->sc_vqs); i++) {
208 1.12 jdolecek if (sc->sc_vqs[i].vq_num > 0)
209 1.12 jdolecek virtio_free_vq(vsc, &sc->sc_vqs[i]);
210 1.12 jdolecek }
211 1.12 jdolecek
212 1.12 jdolecek virtio_child_attach_failed(vsc);
213 1.15 jdolecek }
214 1.15 jdolecek
215 1.15 jdolecek static int
216 1.15 jdolecek vioscsi_detach(device_t self, int flags)
217 1.15 jdolecek {
218 1.15 jdolecek struct vioscsi_softc *sc = device_private(self);
219 1.15 jdolecek struct virtio_softc *vsc = device_private(device_parent(sc->sc_dev));
220 1.15 jdolecek int rc, i;
221 1.15 jdolecek
222 1.15 jdolecek /*
223 1.15 jdolecek * Dequeue all pending finished requests. Must be done
224 1.15 jdolecek * before we try to detach children so that we process
225 1.15 jdolecek * their pending requests while they still exist.
226 1.15 jdolecek */
227 1.15 jdolecek if (sc->sc_vqs[VIOSCSI_VQ_REQUEST].vq_num > 0)
228 1.15 jdolecek vioscsi_vq_done(&sc->sc_vqs[VIOSCSI_VQ_REQUEST]);
229 1.12 jdolecek
230 1.15 jdolecek if ((rc = config_detach_children(self, flags)) != 0)
231 1.15 jdolecek return rc;
232 1.15 jdolecek
233 1.15 jdolecek virtio_reset(vsc);
234 1.15 jdolecek
235 1.15 jdolecek for (i = 0; i < __arraycount(sc->sc_vqs); i++) {
236 1.15 jdolecek if (sc->sc_vqs[i].vq_num > 0)
237 1.15 jdolecek virtio_free_vq(vsc, &sc->sc_vqs[i]);
238 1.15 jdolecek }
239 1.15 jdolecek
240 1.15 jdolecek vioscsi_free_reqs(sc, vsc);
241 1.15 jdolecek
242 1.15 jdolecek virtio_child_detach(vsc);
243 1.15 jdolecek
244 1.15 jdolecek mutex_destroy(&sc->sc_mutex);
245 1.15 jdolecek
246 1.15 jdolecek return 0;
247 1.1 christos }
248 1.1 christos
249 1.1 christos #define XS2DMA(xs) \
250 1.1 christos ((((xs)->xs_control & XS_CTL_DATA_IN) ? BUS_DMA_READ : BUS_DMA_WRITE) | \
251 1.1 christos (((xs)->xs_control & XS_CTL_NOSLEEP) ? BUS_DMA_NOWAIT : BUS_DMA_WAITOK) | \
252 1.1 christos BUS_DMA_STREAMING)
253 1.1 christos
254 1.1 christos #define XS2DMAPRE(xs) (((xs)->xs_control & XS_CTL_DATA_IN) ? \
255 1.1 christos BUS_DMASYNC_PREREAD : BUS_DMASYNC_PREWRITE)
256 1.1 christos
257 1.1 christos #define XS2DMAPOST(xs) (((xs)->xs_control & XS_CTL_DATA_IN) ? \
258 1.1 christos BUS_DMASYNC_POSTREAD : BUS_DMASYNC_POSTWRITE)
259 1.1 christos
260 1.1 christos static void
261 1.1 christos vioscsi_scsipi_request(struct scsipi_channel *chan, scsipi_adapter_req_t
262 1.1 christos request, void *arg)
263 1.1 christos {
264 1.1 christos struct vioscsi_softc *sc =
265 1.1 christos device_private(chan->chan_adapter->adapt_dev);
266 1.1 christos struct virtio_softc *vsc = device_private(device_parent(sc->sc_dev));
267 1.1 christos struct scsipi_xfer *xs;
268 1.1 christos struct scsipi_periph *periph;
269 1.1 christos struct vioscsi_req *vr;
270 1.1 christos struct virtio_scsi_req_hdr *req;
271 1.11 jdolecek struct virtqueue *vq = &sc->sc_vqs[VIOSCSI_VQ_REQUEST];
272 1.1 christos int slot, error;
273 1.21 maxv bool dopoll;
274 1.1 christos
275 1.1 christos DPRINTF(("%s: enter\n", __func__));
276 1.1 christos
277 1.8 jdolecek switch (request) {
278 1.8 jdolecek case ADAPTER_REQ_RUN_XFER:
279 1.8 jdolecek break;
280 1.8 jdolecek case ADAPTER_REQ_SET_XFER_MODE:
281 1.8 jdolecek {
282 1.8 jdolecek struct scsipi_xfer_mode *xm = arg;
283 1.8 jdolecek xm->xm_mode = PERIPH_CAP_TQING;
284 1.8 jdolecek xm->xm_period = 0;
285 1.8 jdolecek xm->xm_offset = 0;
286 1.8 jdolecek scsipi_async_event(chan, ASYNC_EVENT_XFER_MODE, xm);
287 1.8 jdolecek return;
288 1.8 jdolecek }
289 1.8 jdolecek default:
290 1.1 christos DPRINTF(("%s: unhandled %d\n", __func__, request));
291 1.1 christos return;
292 1.1 christos }
293 1.1 christos
294 1.1 christos xs = arg;
295 1.1 christos periph = xs->xs_periph;
296 1.1 christos
297 1.1 christos /*
298 1.7 jdolecek * This can happen when we run out of queue slots.
299 1.1 christos */
300 1.10 jdolecek vr = vioscsi_req_get(sc);
301 1.1 christos if (vr == NULL) {
302 1.7 jdolecek xs->error = XS_RESOURCE_SHORTAGE;
303 1.7 jdolecek scsipi_done(xs);
304 1.7 jdolecek return;
305 1.1 christos }
306 1.7 jdolecek
307 1.1 christos req = &vr->vr_req;
308 1.1 christos slot = vr - sc->sc_reqs;
309 1.1 christos
310 1.1 christos /*
311 1.1 christos * "The only supported format for the LUN field is: first byte set to
312 1.1 christos * 1, second byte set to target, third and fourth byte representing a
313 1.1 christos * single level LUN structure, followed by four zero bytes."
314 1.1 christos */
315 1.15 jdolecek if (periph->periph_target >= 256 || periph->periph_lun >= 16384
316 1.15 jdolecek || periph->periph_target < 0 || periph->periph_lun < 0) {
317 1.1 christos goto stuffup;
318 1.1 christos }
319 1.15 jdolecek
320 1.1 christos req->lun[0] = 1;
321 1.22 kim req->lun[1] = periph->periph_target;
322 1.10 jdolecek req->lun[2] = 0x40 | ((periph->periph_lun >> 8) & 0x3F);
323 1.10 jdolecek req->lun[3] = periph->periph_lun & 0xFF;
324 1.1 christos memset(req->lun + 4, 0, 4);
325 1.15 jdolecek DPRINTF(("%s: command %p for %d:%d at slot %d\n", __func__,
326 1.15 jdolecek xs, periph->periph_target, periph->periph_lun, slot));
327 1.1 christos
328 1.8 jdolecek /* tag */
329 1.8 jdolecek switch (XS_CTL_TAGTYPE(xs)) {
330 1.8 jdolecek case XS_CTL_HEAD_TAG:
331 1.8 jdolecek req->task_attr = VIRTIO_SCSI_S_HEAD;
332 1.8 jdolecek break;
333 1.8 jdolecek
334 1.8 jdolecek #if 0 /* XXX */
335 1.8 jdolecek case XS_CTL_ACA_TAG:
336 1.8 jdolecek req->task_attr = VIRTIO_SCSI_S_ACA;
337 1.8 jdolecek break;
338 1.8 jdolecek #endif
339 1.8 jdolecek
340 1.8 jdolecek case XS_CTL_ORDERED_TAG:
341 1.8 jdolecek req->task_attr = VIRTIO_SCSI_S_ORDERED;
342 1.8 jdolecek break;
343 1.8 jdolecek
344 1.8 jdolecek case XS_CTL_SIMPLE_TAG:
345 1.8 jdolecek default:
346 1.8 jdolecek req->task_attr = VIRTIO_SCSI_S_SIMPLE;
347 1.8 jdolecek break;
348 1.8 jdolecek }
349 1.10 jdolecek req->id = slot;
350 1.8 jdolecek
351 1.2 christos if ((size_t)xs->cmdlen > sizeof(req->cdb)) {
352 1.2 christos DPRINTF(("%s: bad cmdlen %zu > %zu\n", __func__,
353 1.2 christos (size_t)xs->cmdlen, sizeof(req->cdb)));
354 1.1 christos goto stuffup;
355 1.2 christos }
356 1.2 christos
357 1.1 christos memset(req->cdb, 0, sizeof(req->cdb));
358 1.1 christos memcpy(req->cdb, xs->cmd, xs->cmdlen);
359 1.1 christos
360 1.12 jdolecek error = bus_dmamap_load(virtio_dmat(vsc), vr->vr_data,
361 1.1 christos xs->data, xs->datalen, NULL, XS2DMA(xs));
362 1.18 jdolecek if (error) {
363 1.18 jdolecek aprint_error_dev(sc->sc_dev, "%s: error %d loading DMA map\n",
364 1.18 jdolecek __func__, error);
365 1.18 jdolecek
366 1.18 jdolecek if (error == ENOMEM || error == EAGAIN) {
367 1.18 jdolecek /*
368 1.18 jdolecek * Map is allocated with ALLOCNOW, so this should
369 1.18 jdolecek * actually never ever happen.
370 1.18 jdolecek */
371 1.18 jdolecek xs->error = XS_RESOURCE_SHORTAGE;
372 1.18 jdolecek } else {
373 1.11 jdolecek stuffup:
374 1.18 jdolecek /* not a temporary condition */
375 1.18 jdolecek xs->error = XS_DRIVER_STUFFUP;
376 1.18 jdolecek }
377 1.18 jdolecek
378 1.18 jdolecek virtio_enqueue_abort(vsc, vq, slot);
379 1.1 christos scsipi_done(xs);
380 1.1 christos return;
381 1.1 christos }
382 1.1 christos
383 1.2 christos int nsegs = VIRTIO_SCSI_MIN_SEGMENTS;
384 1.2 christos if ((xs->xs_control & (XS_CTL_DATA_IN|XS_CTL_DATA_OUT)) != 0)
385 1.2 christos nsegs += vr->vr_data->dm_nsegs;
386 1.2 christos
387 1.2 christos error = virtio_enqueue_reserve(vsc, vq, slot, nsegs);
388 1.1 christos if (error) {
389 1.18 jdolecek aprint_error_dev(sc->sc_dev, "error reserving %d (nsegs %d)\n",
390 1.18 jdolecek error, nsegs);
391 1.12 jdolecek bus_dmamap_unload(virtio_dmat(vsc), vr->vr_data);
392 1.18 jdolecek /* slot already freed by virtio_enqueue_reserve() */
393 1.11 jdolecek xs->error = XS_RESOURCE_SHORTAGE;
394 1.18 jdolecek scsipi_done(xs);
395 1.18 jdolecek return;
396 1.1 christos }
397 1.1 christos
398 1.15 jdolecek vr->vr_xs = xs;
399 1.15 jdolecek
400 1.12 jdolecek bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
401 1.1 christos offsetof(struct vioscsi_req, vr_req),
402 1.1 christos sizeof(struct virtio_scsi_req_hdr),
403 1.1 christos BUS_DMASYNC_PREWRITE);
404 1.12 jdolecek bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
405 1.1 christos offsetof(struct vioscsi_req, vr_res),
406 1.1 christos sizeof(struct virtio_scsi_res_hdr),
407 1.1 christos BUS_DMASYNC_PREREAD);
408 1.2 christos if ((xs->xs_control & (XS_CTL_DATA_IN|XS_CTL_DATA_OUT)) != 0)
409 1.12 jdolecek bus_dmamap_sync(virtio_dmat(vsc), vr->vr_data, 0, xs->datalen,
410 1.2 christos XS2DMAPRE(xs));
411 1.1 christos
412 1.1 christos virtio_enqueue_p(vsc, vq, slot, vr->vr_control,
413 1.1 christos offsetof(struct vioscsi_req, vr_req),
414 1.1 christos sizeof(struct virtio_scsi_req_hdr), 1);
415 1.1 christos if (xs->xs_control & XS_CTL_DATA_OUT)
416 1.1 christos virtio_enqueue(vsc, vq, slot, vr->vr_data, 1);
417 1.1 christos virtio_enqueue_p(vsc, vq, slot, vr->vr_control,
418 1.1 christos offsetof(struct vioscsi_req, vr_res),
419 1.1 christos sizeof(struct virtio_scsi_res_hdr), 0);
420 1.1 christos if (xs->xs_control & XS_CTL_DATA_IN)
421 1.1 christos virtio_enqueue(vsc, vq, slot, vr->vr_data, 0);
422 1.21 maxv dopoll = (xs->xs_control & XS_CTL_POLL) != 0;
423 1.1 christos virtio_enqueue_commit(vsc, vq, slot, 1);
424 1.1 christos
425 1.21 maxv if (!dopoll)
426 1.1 christos return;
427 1.1 christos
428 1.1 christos DPRINTF(("%s: polling...\n", __func__));
429 1.1 christos // XXX: do this better.
430 1.1 christos int timeout = 1000;
431 1.1 christos do {
432 1.12 jdolecek virtio_intrhand(vsc);
433 1.1 christos if (vr->vr_xs != xs)
434 1.1 christos break;
435 1.1 christos delay(1000);
436 1.1 christos } while (--timeout > 0);
437 1.1 christos
438 1.1 christos if (vr->vr_xs == xs) {
439 1.1 christos // XXX: Abort!
440 1.1 christos xs->error = XS_TIMEOUT;
441 1.1 christos xs->resid = xs->datalen;
442 1.1 christos DPRINTF(("%s: polling timeout\n", __func__));
443 1.1 christos scsipi_done(xs);
444 1.1 christos }
445 1.15 jdolecek DPRINTF(("%s: command %p done (timeout=%d)\n", __func__,
446 1.15 jdolecek xs, timeout));
447 1.1 christos }
448 1.1 christos
449 1.1 christos static void
450 1.1 christos vioscsi_req_done(struct vioscsi_softc *sc, struct virtio_softc *vsc,
451 1.19 jdolecek struct vioscsi_req *vr, struct virtqueue *vq, int slot)
452 1.1 christos {
453 1.1 christos struct scsipi_xfer *xs = vr->vr_xs;
454 1.4 christos size_t sense_len;
455 1.1 christos
456 1.1 christos DPRINTF(("%s: enter\n", __func__));
457 1.1 christos
458 1.12 jdolecek bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
459 1.1 christos offsetof(struct vioscsi_req, vr_req),
460 1.1 christos sizeof(struct virtio_scsi_req_hdr),
461 1.1 christos BUS_DMASYNC_POSTWRITE);
462 1.12 jdolecek bus_dmamap_sync(virtio_dmat(vsc), vr->vr_control,
463 1.1 christos offsetof(struct vioscsi_req, vr_res),
464 1.1 christos sizeof(struct virtio_scsi_res_hdr),
465 1.1 christos BUS_DMASYNC_POSTREAD);
466 1.12 jdolecek bus_dmamap_sync(virtio_dmat(vsc), vr->vr_data, 0, xs->datalen,
467 1.1 christos XS2DMAPOST(xs));
468 1.1 christos
469 1.11 jdolecek xs->status = vr->vr_res.status;
470 1.11 jdolecek xs->resid = vr->vr_res.residual;
471 1.11 jdolecek
472 1.4 christos switch (vr->vr_res.response) {
473 1.4 christos case VIRTIO_SCSI_S_OK:
474 1.4 christos sense_len = MIN(sizeof(xs->sense), vr->vr_res.sense_len);
475 1.4 christos memcpy(&xs->sense, vr->vr_res.sense, sense_len);
476 1.4 christos xs->error = (sense_len == 0) ? XS_NOERROR : XS_SENSE;
477 1.4 christos break;
478 1.4 christos case VIRTIO_SCSI_S_BAD_TARGET:
479 1.15 jdolecek vioscsi_bad_target(xs);
480 1.4 christos break;
481 1.4 christos default:
482 1.4 christos DPRINTF(("%s: stuffup: %d\n", __func__, vr->vr_res.response));
483 1.1 christos xs->error = XS_DRIVER_STUFFUP;
484 1.1 christos xs->resid = xs->datalen;
485 1.4 christos break;
486 1.1 christos }
487 1.1 christos
488 1.15 jdolecek DPRINTF(("%s: command %p done %d, %d, %d\n", __func__,
489 1.15 jdolecek xs, xs->error, xs->status, xs->resid));
490 1.1 christos
491 1.12 jdolecek bus_dmamap_unload(virtio_dmat(vsc), vr->vr_data);
492 1.1 christos vr->vr_xs = NULL;
493 1.11 jdolecek
494 1.19 jdolecek virtio_dequeue_commit(vsc, vq, slot);
495 1.19 jdolecek
496 1.15 jdolecek mutex_exit(&sc->sc_mutex);
497 1.1 christos scsipi_done(xs);
498 1.15 jdolecek mutex_enter(&sc->sc_mutex);
499 1.15 jdolecek }
500 1.15 jdolecek
501 1.15 jdolecek static void
502 1.15 jdolecek vioscsi_bad_target(struct scsipi_xfer *xs)
503 1.15 jdolecek {
504 1.15 jdolecek struct scsi_sense_data *sense = &xs->sense.scsi_sense;
505 1.15 jdolecek
506 1.15 jdolecek DPRINTF(("%s: bad target %d:%d\n", __func__,
507 1.15 jdolecek xs->xs_periph->periph_target, xs->xs_periph->periph_lun));
508 1.15 jdolecek
509 1.15 jdolecek memset(sense, 0, sizeof(*sense));
510 1.15 jdolecek sense->response_code = 0x70;
511 1.15 jdolecek sense->flags = SKEY_ILLEGAL_REQUEST;
512 1.15 jdolecek xs->error = XS_SENSE;
513 1.15 jdolecek xs->status = 0;
514 1.15 jdolecek xs->resid = 0;
515 1.1 christos }
516 1.1 christos
517 1.1 christos static int
518 1.1 christos vioscsi_vq_done(struct virtqueue *vq)
519 1.1 christos {
520 1.1 christos struct virtio_softc *vsc = vq->vq_owner;
521 1.12 jdolecek struct vioscsi_softc *sc = device_private(virtio_child(vsc));
522 1.1 christos int ret = 0;
523 1.1 christos
524 1.15 jdolecek DPRINTF(("%s: enter %d\n", __func__, vq->vq_index));
525 1.15 jdolecek
526 1.15 jdolecek mutex_enter(&sc->sc_mutex);
527 1.1 christos
528 1.1 christos for (;;) {
529 1.1 christos int r, slot;
530 1.15 jdolecek
531 1.1 christos r = virtio_dequeue(vsc, vq, &slot, NULL);
532 1.1 christos if (r != 0)
533 1.1 christos break;
534 1.1 christos
535 1.1 christos DPRINTF(("%s: slot=%d\n", __func__, slot));
536 1.11 jdolecek
537 1.19 jdolecek vioscsi_req_done(sc, vsc, &sc->sc_reqs[slot], vq, slot);
538 1.11 jdolecek
539 1.1 christos ret = 1;
540 1.1 christos }
541 1.1 christos
542 1.15 jdolecek mutex_exit(&sc->sc_mutex);
543 1.15 jdolecek
544 1.15 jdolecek DPRINTF(("%s: exit %d: %d\n", __func__, vq->vq_index, ret));
545 1.1 christos
546 1.1 christos return ret;
547 1.1 christos }
548 1.1 christos
549 1.1 christos static struct vioscsi_req *
550 1.1 christos vioscsi_req_get(struct vioscsi_softc *sc)
551 1.1 christos {
552 1.1 christos struct virtio_softc *vsc = device_private(device_parent(sc->sc_dev));
553 1.10 jdolecek struct virtqueue *vq = &sc->sc_vqs[VIOSCSI_VQ_REQUEST];
554 1.15 jdolecek struct vioscsi_req *vr = NULL;
555 1.1 christos int r, slot;
556 1.1 christos
557 1.15 jdolecek mutex_enter(&sc->sc_mutex);
558 1.15 jdolecek
559 1.1 christos if ((r = virtio_enqueue_prep(vsc, vq, &slot)) != 0) {
560 1.1 christos DPRINTF(("%s: virtio_enqueue_get error %d\n", __func__, r));
561 1.15 jdolecek goto out;
562 1.1 christos }
563 1.9 jdolecek KASSERT(slot < sc->sc_nreqs);
564 1.1 christos vr = &sc->sc_reqs[slot];
565 1.1 christos
566 1.1 christos DPRINTF(("%s: %p, %d\n", __func__, vr, slot));
567 1.1 christos
568 1.15 jdolecek out:
569 1.15 jdolecek mutex_exit(&sc->sc_mutex);
570 1.15 jdolecek
571 1.1 christos return vr;
572 1.1 christos }
573 1.1 christos
574 1.15 jdolecek static int
575 1.1 christos vioscsi_alloc_reqs(struct vioscsi_softc *sc, struct virtio_softc *vsc,
576 1.15 jdolecek int qsize)
577 1.1 christos {
578 1.1 christos size_t allocsize;
579 1.9 jdolecek int r, rsegs, slot;
580 1.1 christos void *vaddr;
581 1.9 jdolecek struct vioscsi_req *vr;
582 1.1 christos
583 1.1 christos allocsize = qsize * sizeof(struct vioscsi_req);
584 1.12 jdolecek r = bus_dmamem_alloc(virtio_dmat(vsc), allocsize, 0, 0,
585 1.1 christos &sc->sc_reqs_segs[0], 1, &rsegs, BUS_DMA_NOWAIT);
586 1.1 christos if (r != 0) {
587 1.1 christos aprint_error_dev(sc->sc_dev,
588 1.1 christos "%s: bus_dmamem_alloc, size %zu, error %d\n", __func__,
589 1.1 christos allocsize, r);
590 1.9 jdolecek return r;
591 1.1 christos }
592 1.12 jdolecek r = bus_dmamem_map(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1,
593 1.1 christos allocsize, &vaddr, BUS_DMA_NOWAIT);
594 1.1 christos if (r != 0) {
595 1.1 christos aprint_error_dev(sc->sc_dev,
596 1.1 christos "%s: bus_dmamem_map failed, error %d\n", __func__, r);
597 1.12 jdolecek bus_dmamem_free(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1);
598 1.9 jdolecek return r;
599 1.1 christos }
600 1.9 jdolecek memset(vaddr, 0, allocsize);
601 1.9 jdolecek
602 1.1 christos sc->sc_reqs = vaddr;
603 1.9 jdolecek sc->sc_nreqs = qsize;
604 1.9 jdolecek
605 1.9 jdolecek /* Prepare maps for the requests */
606 1.9 jdolecek for (slot=0; slot < qsize; slot++) {
607 1.9 jdolecek vr = &sc->sc_reqs[slot];
608 1.9 jdolecek
609 1.12 jdolecek r = bus_dmamap_create(virtio_dmat(vsc),
610 1.9 jdolecek offsetof(struct vioscsi_req, vr_xs), 1,
611 1.9 jdolecek offsetof(struct vioscsi_req, vr_xs), 0,
612 1.9 jdolecek BUS_DMA_NOWAIT|BUS_DMA_ALLOCNOW, &vr->vr_control);
613 1.9 jdolecek if (r != 0) {
614 1.9 jdolecek aprint_error_dev(sc->sc_dev,
615 1.15 jdolecek "%s: bus_dmamem_create ctrl failed, error %d\n",
616 1.9 jdolecek __func__, r);
617 1.9 jdolecek goto cleanup;
618 1.9 jdolecek }
619 1.9 jdolecek
620 1.12 jdolecek r = bus_dmamap_create(virtio_dmat(vsc), MAXPHYS, sc->sc_seg_max,
621 1.9 jdolecek MAXPHYS, 0, BUS_DMA_NOWAIT|BUS_DMA_ALLOCNOW, &vr->vr_data);
622 1.9 jdolecek if (r != 0) {
623 1.9 jdolecek aprint_error_dev(sc->sc_dev,
624 1.15 jdolecek "%s: bus_dmamem_create data failed, error %d\n",
625 1.9 jdolecek __func__, r);
626 1.9 jdolecek goto cleanup;
627 1.9 jdolecek }
628 1.9 jdolecek
629 1.12 jdolecek r = bus_dmamap_load(virtio_dmat(vsc), vr->vr_control,
630 1.9 jdolecek vr, offsetof(struct vioscsi_req, vr_xs), NULL,
631 1.9 jdolecek BUS_DMA_NOWAIT);
632 1.9 jdolecek if (r != 0) {
633 1.9 jdolecek aprint_error_dev(sc->sc_dev,
634 1.15 jdolecek "%s: bus_dmamap_load ctrl error %d\n",
635 1.9 jdolecek __func__, r);
636 1.9 jdolecek goto cleanup;
637 1.9 jdolecek }
638 1.9 jdolecek }
639 1.9 jdolecek
640 1.1 christos return 0;
641 1.9 jdolecek
642 1.9 jdolecek cleanup:
643 1.9 jdolecek for (; slot > 0; slot--) {
644 1.9 jdolecek vr = &sc->sc_reqs[slot];
645 1.9 jdolecek
646 1.9 jdolecek if (vr->vr_control) {
647 1.9 jdolecek /* this will also unload the mapping if loaded */
648 1.12 jdolecek bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_control);
649 1.9 jdolecek vr->vr_control = NULL;
650 1.9 jdolecek }
651 1.9 jdolecek
652 1.9 jdolecek if (vr->vr_data) {
653 1.12 jdolecek bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_data);
654 1.9 jdolecek vr->vr_data = NULL;
655 1.9 jdolecek }
656 1.9 jdolecek }
657 1.9 jdolecek
658 1.12 jdolecek bus_dmamem_unmap(virtio_dmat(vsc), vaddr, allocsize);
659 1.12 jdolecek bus_dmamem_free(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1);
660 1.9 jdolecek
661 1.9 jdolecek return r;
662 1.1 christos }
663 1.12 jdolecek
664 1.12 jdolecek static void
665 1.12 jdolecek vioscsi_free_reqs(struct vioscsi_softc *sc, struct virtio_softc *vsc)
666 1.12 jdolecek {
667 1.12 jdolecek int slot;
668 1.12 jdolecek struct vioscsi_req *vr;
669 1.12 jdolecek
670 1.12 jdolecek if (sc->sc_nreqs == 0) {
671 1.12 jdolecek /* Not allocated */
672 1.12 jdolecek return;
673 1.12 jdolecek }
674 1.12 jdolecek
675 1.12 jdolecek /* Free request maps */
676 1.12 jdolecek for (slot=0; slot < sc->sc_nreqs; slot++) {
677 1.12 jdolecek vr = &sc->sc_reqs[slot];
678 1.12 jdolecek
679 1.12 jdolecek bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_control);
680 1.12 jdolecek bus_dmamap_destroy(virtio_dmat(vsc), vr->vr_data);
681 1.12 jdolecek }
682 1.12 jdolecek
683 1.12 jdolecek bus_dmamem_unmap(virtio_dmat(vsc), sc->sc_reqs,
684 1.12 jdolecek sc->sc_nreqs * sizeof(struct vioscsi_req));
685 1.12 jdolecek bus_dmamem_free(virtio_dmat(vsc), &sc->sc_reqs_segs[0], 1);
686 1.12 jdolecek }
687 1.12 jdolecek
688 1.15 jdolecek MODULE(MODULE_CLASS_DRIVER, vioscsi, "virtio");
689 1.15 jdolecek
690 1.15 jdolecek #ifdef _MODULE
691 1.15 jdolecek #include "ioconf.c"
692 1.15 jdolecek #endif
693 1.15 jdolecek
694 1.15 jdolecek static int
695 1.15 jdolecek vioscsi_modcmd(modcmd_t cmd, void *opaque)
696 1.15 jdolecek {
697 1.15 jdolecek int error = 0;
698 1.15 jdolecek
699 1.15 jdolecek #ifdef _MODULE
700 1.15 jdolecek switch (cmd) {
701 1.15 jdolecek case MODULE_CMD_INIT:
702 1.15 jdolecek error = config_init_component(cfdriver_ioconf_vioscsi,
703 1.15 jdolecek cfattach_ioconf_vioscsi, cfdata_ioconf_vioscsi);
704 1.15 jdolecek break;
705 1.15 jdolecek case MODULE_CMD_FINI:
706 1.15 jdolecek error = config_fini_component(cfdriver_ioconf_vioscsi,
707 1.15 jdolecek cfattach_ioconf_vioscsi, cfdata_ioconf_vioscsi);
708 1.15 jdolecek break;
709 1.15 jdolecek default:
710 1.15 jdolecek error = ENOTTY;
711 1.15 jdolecek break;
712 1.15 jdolecek }
713 1.15 jdolecek #endif
714 1.15 jdolecek
715 1.15 jdolecek return error;
716 1.15 jdolecek }
717