iscsi_main.c revision 1.29 1 1.29 mlelstv /* $NetBSD: iscsi_main.c,v 1.29 2019/04/21 11:26:46 mlelstv Exp $ */
2 1.1 agc
3 1.1 agc /*-
4 1.1 agc * Copyright (c) 2004,2005,2006,2011 The NetBSD Foundation, Inc.
5 1.1 agc * All rights reserved.
6 1.1 agc *
7 1.1 agc * This code is derived from software contributed to The NetBSD Foundation
8 1.1 agc * by Wasabi Systems, Inc.
9 1.1 agc *
10 1.1 agc * Redistribution and use in source and binary forms, with or without
11 1.1 agc * modification, are permitted provided that the following conditions
12 1.1 agc * are met:
13 1.1 agc * 1. Redistributions of source code must retain the above copyright
14 1.1 agc * notice, this list of conditions and the following disclaimer.
15 1.1 agc * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 agc * notice, this list of conditions and the following disclaimer in the
17 1.1 agc * documentation and/or other materials provided with the distribution.
18 1.1 agc *
19 1.1 agc * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.1 agc * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.1 agc * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.1 agc * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.1 agc * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.1 agc * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.1 agc * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.1 agc * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.1 agc * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.1 agc * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.1 agc * POSSIBILITY OF SUCH DAMAGE.
30 1.1 agc */
31 1.1 agc #include "iscsi_globals.h"
32 1.1 agc
33 1.1 agc #include <sys/systm.h>
34 1.1 agc #include <sys/buf.h>
35 1.16 joerg #include <sys/file.h>
36 1.16 joerg #include <sys/filedesc.h>
37 1.1 agc #include <sys/kmem.h>
38 1.1 agc #include <sys/socketvar.h>
39 1.18 mlelstv #include <sys/sysctl.h>
40 1.1 agc
41 1.17 christos #include "ioconf.h"
42 1.1 agc
43 1.1 agc /*------------------------- Global Variables ------------------------*/
44 1.1 agc
45 1.1 agc extern struct cfdriver iscsi_cd;
46 1.1 agc
47 1.1 agc #if defined(ISCSI_DEBUG)
48 1.4 mlelstv int iscsi_debug_level = ISCSI_DEBUG;
49 1.1 agc #endif
50 1.29 mlelstv bool iscsi_hex_bignums = false;
51 1.1 agc
52 1.18 mlelstv bool iscsi_detaching;
53 1.1 agc
54 1.1 agc /* the list of sessions */
55 1.6 mlelstv session_list_t iscsi_sessions = TAILQ_HEAD_INITIALIZER(iscsi_sessions);
56 1.1 agc
57 1.1 agc /* the number of active send threads (for cleanup thread) */
58 1.6 mlelstv uint32_t iscsi_num_send_threads = 0;
59 1.1 agc
60 1.1 agc /* Our node name, alias, and ISID */
61 1.6 mlelstv uint8_t iscsi_InitiatorName[ISCSI_STRING_LENGTH] = "";
62 1.6 mlelstv uint8_t iscsi_InitiatorAlias[ISCSI_STRING_LENGTH] = "";
63 1.6 mlelstv login_isid_t iscsi_InitiatorISID;
64 1.1 agc
65 1.1 agc /******************************************************************************/
66 1.1 agc
67 1.1 agc /*
68 1.1 agc System interface: autoconf and device structures
69 1.1 agc */
70 1.1 agc
71 1.6 mlelstv static void iscsi_attach(device_t parent, device_t self, void *aux);
72 1.6 mlelstv static int iscsi_match(device_t, cfdata_t, void *);
73 1.6 mlelstv static int iscsi_detach(device_t, int);
74 1.1 agc
75 1.18 mlelstv struct iscsi_softc {
76 1.18 mlelstv device_t dev;
77 1.18 mlelstv kmutex_t lock;
78 1.18 mlelstv TAILQ_HEAD(, iscsifd) fds;
79 1.18 mlelstv };
80 1.1 agc
81 1.1 agc CFATTACH_DECL_NEW(iscsi, sizeof(struct iscsi_softc), iscsi_match, iscsi_attach,
82 1.1 agc iscsi_detach, NULL);
83 1.1 agc
84 1.1 agc
85 1.6 mlelstv static dev_type_open(iscsiopen);
86 1.16 joerg static int iscsiclose(struct file *);
87 1.16 joerg
88 1.16 joerg static const struct fileops iscsi_fileops = {
89 1.25 christos .fo_name = "iscsi",
90 1.16 joerg .fo_ioctl = iscsiioctl,
91 1.16 joerg .fo_close = iscsiclose,
92 1.16 joerg };
93 1.1 agc
94 1.1 agc struct cdevsw iscsi_cdevsw = {
95 1.8 dholland .d_open = iscsiopen,
96 1.16 joerg .d_close = noclose,
97 1.8 dholland .d_read = noread,
98 1.8 dholland .d_write = nowrite,
99 1.16 joerg .d_ioctl = noioctl,
100 1.8 dholland .d_stop = nostop,
101 1.8 dholland .d_tty = notty,
102 1.8 dholland .d_poll = nopoll,
103 1.8 dholland .d_mmap = nommap,
104 1.8 dholland .d_kqfilter = nokqfilter,
105 1.9 dholland .d_discard = nodiscard,
106 1.8 dholland .d_flag = D_OTHER
107 1.1 agc };
108 1.1 agc
109 1.1 agc /******************************************************************************/
110 1.1 agc
111 1.1 agc STATIC void iscsi_scsipi_request(struct scsipi_channel *,
112 1.20 mlelstv scsipi_adapter_req_t, void *);
113 1.1 agc STATIC void iscsi_minphys(struct buf *);
114 1.1 agc
115 1.1 agc /******************************************************************************/
116 1.1 agc
117 1.1 agc /*******************************************************************************
118 1.1 agc * Open and Close device interfaces. We don't really need them, because we don't
119 1.1 agc * have to keep track of device opens and closes from userland. But apps can't
120 1.1 agc * call ioctl without a handle to the device, and the kernel doesn't hand out
121 1.1 agc * handles without an open routine in the driver. So here they are in all their
122 1.1 agc * glory...
123 1.1 agc *******************************************************************************/
124 1.1 agc
125 1.1 agc int
126 1.13 joerg iscsiopen(dev_t dev, int flag, int mode, struct lwp *l)
127 1.1 agc {
128 1.16 joerg struct iscsifd *d;
129 1.18 mlelstv struct iscsi_softc *sc;
130 1.16 joerg struct file *fp;
131 1.18 mlelstv int error, fd, unit;
132 1.18 mlelstv
133 1.18 mlelstv unit = minor(dev);
134 1.18 mlelstv
135 1.18 mlelstv DEB(99, ("ISCSI Open unit=%d\n",unit));
136 1.1 agc
137 1.18 mlelstv sc = device_lookup_private(&iscsi_cd, unit);
138 1.18 mlelstv if (sc == NULL)
139 1.18 mlelstv return ENXIO;
140 1.16 joerg
141 1.16 joerg if ((error = fd_allocfile(&fp, &fd)) != 0)
142 1.16 joerg return error;
143 1.16 joerg
144 1.16 joerg d = kmem_alloc(sizeof(*d), KM_SLEEP);
145 1.27 christos d->fd_dev = sc->dev;
146 1.27 christos d->fd_unit = unit;
147 1.18 mlelstv
148 1.18 mlelstv mutex_enter(&sc->lock);
149 1.18 mlelstv if (iscsi_detaching) {
150 1.18 mlelstv mutex_exit(&sc->lock);
151 1.18 mlelstv kmem_free(d, sizeof(*d));
152 1.18 mlelstv DEB(99, ("ISCSI Open aborting\n"));
153 1.18 mlelstv fd_abort(curproc, fp, fd);
154 1.18 mlelstv return ENXIO;
155 1.18 mlelstv }
156 1.27 christos TAILQ_INSERT_TAIL(&sc->fds, d, fd_link);
157 1.18 mlelstv mutex_exit(&sc->lock);
158 1.16 joerg
159 1.16 joerg return fd_clone(fp, fd, flag, &iscsi_fileops, d);
160 1.1 agc }
161 1.1 agc
162 1.16 joerg static int
163 1.16 joerg iscsiclose(struct file *fp)
164 1.1 agc {
165 1.16 joerg struct iscsifd *d = fp->f_iscsi;
166 1.18 mlelstv struct iscsi_softc *sc;
167 1.18 mlelstv
168 1.27 christos sc = device_lookup_private(&iscsi_cd, d->fd_unit);
169 1.18 mlelstv if (sc == NULL) {
170 1.18 mlelstv DEBOUT(("%s: Cannot find private data\n",__func__));
171 1.18 mlelstv return ENXIO;
172 1.18 mlelstv }
173 1.18 mlelstv
174 1.18 mlelstv mutex_enter(&sc->lock);
175 1.27 christos TAILQ_REMOVE(&sc->fds, d, fd_link);
176 1.18 mlelstv mutex_exit(&sc->lock);
177 1.16 joerg
178 1.16 joerg kmem_free(d, sizeof(*d));
179 1.16 joerg fp->f_iscsi = NULL;
180 1.1 agc
181 1.1 agc DEB(99, ("ISCSI Close\n"));
182 1.1 agc return 0;
183 1.1 agc }
184 1.1 agc
185 1.1 agc /******************************************************************************/
186 1.1 agc
187 1.1 agc /*
188 1.1 agc * The config Match routine.
189 1.1 agc * Not much to do here, either - this is a pseudo-device.
190 1.1 agc */
191 1.1 agc
192 1.6 mlelstv static int
193 1.1 agc iscsi_match(device_t self, cfdata_t cfdata, void *arg)
194 1.1 agc {
195 1.1 agc return 1;
196 1.1 agc }
197 1.1 agc
198 1.1 agc /*
199 1.1 agc * iscsiattach:
200 1.1 agc * Only called when statically configured into a kernel
201 1.1 agc */
202 1.1 agc void
203 1.1 agc iscsiattach(int n)
204 1.1 agc {
205 1.1 agc int err;
206 1.1 agc cfdata_t cf;
207 1.1 agc
208 1.1 agc err = config_cfattach_attach(iscsi_cd.cd_name, &iscsi_ca);
209 1.1 agc if (err) {
210 1.1 agc aprint_error("%s: couldn't register cfattach: %d\n",
211 1.1 agc iscsi_cd.cd_name, err);
212 1.1 agc config_cfdriver_detach(&iscsi_cd);
213 1.1 agc return;
214 1.1 agc }
215 1.1 agc
216 1.1 agc if (n > 1)
217 1.1 agc aprint_error("%s: only one device supported\n",
218 1.1 agc iscsi_cd.cd_name);
219 1.1 agc
220 1.1 agc cf = kmem_alloc(sizeof(struct cfdata), KM_NOSLEEP);
221 1.1 agc if (cf == NULL) {
222 1.1 agc aprint_error("%s: couldn't allocate cfdata\n",
223 1.1 agc iscsi_cd.cd_name);
224 1.1 agc return;
225 1.1 agc }
226 1.1 agc cf->cf_name = iscsi_cd.cd_name;
227 1.1 agc cf->cf_atname = iscsi_cd.cd_name;
228 1.1 agc cf->cf_unit = 0;
229 1.1 agc cf->cf_fstate = FSTATE_NOTFOUND;
230 1.1 agc
231 1.1 agc (void)config_attach_pseudo(cf);
232 1.1 agc return;
233 1.1 agc }
234 1.1 agc
235 1.1 agc /*
236 1.1 agc * iscsi_attach:
237 1.1 agc * One-time inits go here. Not much for now, probably even less later.
238 1.1 agc */
239 1.6 mlelstv static void
240 1.1 agc iscsi_attach(device_t parent, device_t self, void *aux)
241 1.1 agc {
242 1.18 mlelstv struct iscsi_softc *sc;
243 1.1 agc
244 1.18 mlelstv DEB(1, ("ISCSI: iscsi_attach, parent=%p, self=%p, aux=%p\n", parent,
245 1.1 agc self, aux));
246 1.18 mlelstv sc = (struct iscsi_softc *) device_private(self);
247 1.18 mlelstv sc->dev = self;
248 1.18 mlelstv
249 1.18 mlelstv TAILQ_INIT(&sc->fds);
250 1.18 mlelstv mutex_init(&sc->lock, MUTEX_DEFAULT, IPL_NONE);
251 1.18 mlelstv
252 1.18 mlelstv iscsi_detaching = false;
253 1.18 mlelstv iscsi_init_cleanup();
254 1.18 mlelstv
255 1.1 agc aprint_normal("%s: attached. major = %d\n", iscsi_cd.cd_name,
256 1.1 agc cdevsw_lookup_major(&iscsi_cdevsw));
257 1.1 agc }
258 1.1 agc
259 1.1 agc /*
260 1.1 agc * iscsi_detach:
261 1.1 agc * Cleanup.
262 1.1 agc */
263 1.6 mlelstv static int
264 1.1 agc iscsi_detach(device_t self, int flags)
265 1.1 agc {
266 1.18 mlelstv struct iscsi_softc *sc;
267 1.23 mlelstv int error;
268 1.18 mlelstv
269 1.18 mlelstv DEB(1, ("ISCSI: detach\n"));
270 1.18 mlelstv sc = (struct iscsi_softc *) device_private(self);
271 1.18 mlelstv
272 1.18 mlelstv mutex_enter(&sc->lock);
273 1.18 mlelstv if (!TAILQ_EMPTY(&sc->fds)) {
274 1.18 mlelstv mutex_exit(&sc->lock);
275 1.18 mlelstv return EBUSY;
276 1.18 mlelstv }
277 1.18 mlelstv iscsi_detaching = true;
278 1.18 mlelstv mutex_exit(&sc->lock);
279 1.1 agc
280 1.23 mlelstv error = kill_all_sessions();
281 1.23 mlelstv if (error)
282 1.23 mlelstv return error;
283 1.23 mlelstv
284 1.23 mlelstv error = iscsi_destroy_cleanup();
285 1.23 mlelstv if (error)
286 1.23 mlelstv return error;
287 1.18 mlelstv
288 1.18 mlelstv mutex_destroy(&sc->lock);
289 1.18 mlelstv
290 1.1 agc return 0;
291 1.1 agc }
292 1.1 agc
293 1.1 agc /******************************************************************************/
294 1.1 agc
295 1.1 agc typedef struct quirktab_t {
296 1.1 agc const char *tgt;
297 1.1 agc const char *iqn;
298 1.1 agc uint32_t quirks;
299 1.1 agc } quirktab_t;
300 1.1 agc
301 1.1 agc static const quirktab_t quirktab[] = {
302 1.14 joerg { "StarWind", "iqn.2008-08.com.starwindsoftware", PQUIRK_ONLYBIG },
303 1.14 joerg { "UNH", "iqn.2002-10.edu.unh.",
304 1.14 joerg PQUIRK_NOBIGMODESENSE |
305 1.14 joerg PQUIRK_NOMODESENSE |
306 1.14 joerg PQUIRK_NOSYNCCACHE },
307 1.14 joerg { "NetBSD", "iqn.1994-04.org.netbsd.", 0 },
308 1.14 joerg { "Unknown", "unknown", 0 },
309 1.14 joerg { NULL, NULL, 0 }
310 1.1 agc };
311 1.1 agc
312 1.1 agc /* loop through the quirktab looking for a match on target name */
313 1.1 agc static const quirktab_t *
314 1.1 agc getquirks(const char *iqn)
315 1.1 agc {
316 1.1 agc const quirktab_t *qp;
317 1.14 joerg size_t iqnlen, quirklen;
318 1.1 agc
319 1.14 joerg if (iqn == NULL)
320 1.1 agc iqn = "unknown";
321 1.14 joerg iqnlen = strlen(iqn);
322 1.1 agc for (qp = quirktab ; qp->iqn ; qp++) {
323 1.14 joerg quirklen = strlen(qp->iqn);
324 1.14 joerg if (quirklen > iqnlen)
325 1.14 joerg continue;
326 1.14 joerg if (memcmp(qp->iqn, iqn, quirklen) == 0)
327 1.1 agc break;
328 1.1 agc }
329 1.1 agc return qp;
330 1.1 agc }
331 1.1 agc
332 1.1 agc /******************************************************************************/
333 1.1 agc
334 1.1 agc /*
335 1.1 agc * map_session
336 1.1 agc * This (indirectly) maps the existing LUNs for a target to SCSI devices
337 1.1 agc * by going through config_found to tell any child drivers that there's
338 1.1 agc * a new adapter.
339 1.1 agc * Note that each session is equivalent to a SCSI adapter.
340 1.1 agc *
341 1.1 agc * Parameter: the session pointer
342 1.1 agc *
343 1.1 agc * Returns: 1 on success, 0 on failure
344 1.1 agc *
345 1.1 agc * ToDo: Figuring out how to handle more than one LUN. It appears that
346 1.1 agc * the NetBSD SCSI LUN discovery doesn't use "report LUNs", and instead
347 1.1 agc * goes through the LUNs sequentially, stopping somewhere on the way if it
348 1.1 agc * gets an error. We may have to do some LUN mapping in here if this is
349 1.1 agc * really how things work.
350 1.1 agc */
351 1.1 agc
352 1.1 agc int
353 1.27 christos map_session(session_t *sess, device_t dev)
354 1.1 agc {
355 1.27 christos struct scsipi_adapter *adapt = &sess->s_sc_adapter;
356 1.27 christos struct scsipi_channel *chan = &sess->s_sc_channel;
357 1.1 agc const quirktab_t *tgt;
358 1.1 agc
359 1.27 christos mutex_enter(&sess->s_lock);
360 1.27 christos sess->s_send_window = max(2, window_size(sess, CCBS_FOR_SCSIPI));
361 1.27 christos mutex_exit(&sess->s_lock);
362 1.23 mlelstv
363 1.1 agc /*
364 1.1 agc * Fill in the scsipi_adapter.
365 1.1 agc */
366 1.18 mlelstv adapt->adapt_dev = dev;
367 1.1 agc adapt->adapt_nchannels = 1;
368 1.1 agc adapt->adapt_request = iscsi_scsipi_request;
369 1.1 agc adapt->adapt_minphys = iscsi_minphys;
370 1.27 christos adapt->adapt_openings = sess->s_send_window;
371 1.23 mlelstv adapt->adapt_max_periph = CCBS_FOR_SCSIPI;
372 1.24 mlelstv adapt->adapt_flags = SCSIPI_ADAPT_MPSAFE;
373 1.1 agc
374 1.1 agc /*
375 1.1 agc * Fill in the scsipi_channel.
376 1.1 agc */
377 1.1 agc if ((tgt = getquirks(chan->chan_name)) == NULL) {
378 1.1 agc tgt = getquirks("unknown");
379 1.1 agc }
380 1.1 agc chan->chan_name = tgt->tgt;
381 1.1 agc chan->chan_defquirks = tgt->quirks;
382 1.1 agc chan->chan_adapter = adapt;
383 1.1 agc chan->chan_bustype = &scsi_bustype;
384 1.1 agc chan->chan_channel = 0;
385 1.23 mlelstv chan->chan_flags = SCSIPI_CHAN_NOSETTLE | SCSIPI_CHAN_CANGROW;
386 1.1 agc chan->chan_ntargets = 1;
387 1.29 mlelstv chan->chan_nluns = 16;
388 1.27 christos chan->chan_id = sess->s_id;
389 1.1 agc
390 1.27 christos sess->s_child_dev = config_found(dev, chan, scsiprint);
391 1.1 agc
392 1.27 christos return sess->s_child_dev != NULL;
393 1.1 agc }
394 1.1 agc
395 1.1 agc
396 1.1 agc /*
397 1.1 agc * unmap_session
398 1.1 agc * This (indirectly) unmaps the existing all LUNs for a target by
399 1.1 agc * telling the config system that the adapter has detached.
400 1.1 agc *
401 1.1 agc * Parameter: the session pointer
402 1.7 mlelstv *
403 1.7 mlelstv * Returns: 1 on success, 0 on failure
404 1.1 agc */
405 1.1 agc
406 1.7 mlelstv int
407 1.27 christos unmap_session(session_t *sess)
408 1.1 agc {
409 1.1 agc device_t dev;
410 1.7 mlelstv int rv = 1;
411 1.1 agc
412 1.27 christos if ((dev = sess->s_child_dev) != NULL) {
413 1.27 christos sess->s_child_dev = NULL;
414 1.7 mlelstv if (config_detach(dev, 0))
415 1.7 mlelstv rv = 0;
416 1.1 agc }
417 1.7 mlelstv
418 1.7 mlelstv return rv;
419 1.1 agc }
420 1.1 agc
421 1.23 mlelstv /*
422 1.23 mlelstv * grow_resources
423 1.23 mlelstv * Try to grow openings up to current window size
424 1.23 mlelstv */
425 1.23 mlelstv static void
426 1.27 christos grow_resources(session_t *sess)
427 1.23 mlelstv {
428 1.27 christos struct scsipi_adapter *adapt = &sess->s_sc_adapter;
429 1.23 mlelstv int win;
430 1.23 mlelstv
431 1.27 christos mutex_enter(&sess->s_lock);
432 1.27 christos if (sess->s_refcount < CCBS_FOR_SCSIPI &&
433 1.27 christos sess->s_send_window < CCBS_FOR_SCSIPI) {
434 1.27 christos win = window_size(sess, CCBS_FOR_SCSIPI - sess->s_refcount);
435 1.27 christos if (win > sess->s_send_window) {
436 1.27 christos sess->s_send_window++;
437 1.23 mlelstv adapt->adapt_openings++;
438 1.27 christos DEB(5, ("Grow send window to %d\n", sess->s_send_window));
439 1.23 mlelstv }
440 1.23 mlelstv }
441 1.27 christos mutex_exit(&sess->s_lock);
442 1.23 mlelstv }
443 1.23 mlelstv
444 1.1 agc /******************************************************************************/
445 1.1 agc
446 1.1 agc /*****************************************************************************
447 1.1 agc * SCSI interface routines
448 1.1 agc *****************************************************************************/
449 1.1 agc
450 1.1 agc /*
451 1.1 agc * iscsi_scsipi_request:
452 1.1 agc * Perform a request for the SCSIPI layer.
453 1.1 agc */
454 1.1 agc
455 1.1 agc void
456 1.1 agc iscsi_scsipi_request(struct scsipi_channel *chan, scsipi_adapter_req_t req,
457 1.1 agc void *arg)
458 1.1 agc {
459 1.1 agc struct scsipi_adapter *adapt = chan->chan_adapter;
460 1.1 agc struct scsipi_xfer *xs;
461 1.27 christos session_t *sess;
462 1.1 agc int flags;
463 1.7 mlelstv struct scsipi_xfer_mode *xm;
464 1.23 mlelstv int error;
465 1.1 agc
466 1.27 christos sess = (session_t *) adapt; /* adapter is first field in session */
467 1.1 agc
468 1.27 christos error = ref_session(sess);
469 1.23 mlelstv
470 1.1 agc switch (req) {
471 1.1 agc case ADAPTER_REQ_RUN_XFER:
472 1.1 agc DEB(9, ("ISCSI: scsipi_request RUN_XFER\n"));
473 1.1 agc xs = arg;
474 1.1 agc flags = xs->xs_control;
475 1.1 agc
476 1.23 mlelstv if (error) {
477 1.23 mlelstv DEB(9, ("ISCSI: refcount too high: %d, winsize %d\n",
478 1.27 christos sess->s_refcount, sess->s_send_window));
479 1.23 mlelstv xs->error = XS_BUSY;
480 1.23 mlelstv xs->status = XS_BUSY;
481 1.23 mlelstv scsipi_done(xs);
482 1.23 mlelstv return;
483 1.23 mlelstv }
484 1.23 mlelstv
485 1.1 agc if ((flags & XS_CTL_POLL) != 0) {
486 1.1 agc xs->error = XS_DRIVER_STUFFUP;
487 1.1 agc DEBOUT(("Run Xfer request with polling\n"));
488 1.1 agc scsipi_done(xs);
489 1.23 mlelstv break;
490 1.1 agc }
491 1.1 agc /*
492 1.1 agc * NOTE: It appears that XS_CTL_DATA_UIO is not actually used anywhere.
493 1.18 mlelstv * Since it really would complicate matters to handle offsets
494 1.18 mlelstv * into scatter-gather lists, and a number of other drivers don't
495 1.18 mlelstv * handle uio-based data as well, XS_CTL_DATA_UIO isn't
496 1.18 mlelstv * implemented in this driver (at least for now).
497 1.1 agc */
498 1.1 agc if (flags & XS_CTL_DATA_UIO) {
499 1.1 agc xs->error = XS_DRIVER_STUFFUP;
500 1.1 agc DEBOUT(("Run Xfer with data in UIO\n"));
501 1.1 agc scsipi_done(xs);
502 1.23 mlelstv break;
503 1.1 agc }
504 1.1 agc
505 1.27 christos send_run_xfer(sess, xs);
506 1.27 christos DEB(15, ("scsipi_req returns, refcount = %d\n", sess->s_refcount));
507 1.1 agc return;
508 1.1 agc
509 1.1 agc case ADAPTER_REQ_GROW_RESOURCES:
510 1.18 mlelstv DEB(5, ("ISCSI: scsipi_request GROW_RESOURCES\n"));
511 1.27 christos grow_resources(sess);
512 1.23 mlelstv break;
513 1.1 agc
514 1.1 agc case ADAPTER_REQ_SET_XFER_MODE:
515 1.1 agc DEB(5, ("ISCSI: scsipi_request SET_XFER_MODE\n"));
516 1.7 mlelstv xm = (struct scsipi_xfer_mode *)arg;
517 1.7 mlelstv xm->xm_mode = PERIPH_CAP_TQING;
518 1.7 mlelstv scsipi_async_event(chan, ASYNC_EVENT_XFER_MODE, xm);
519 1.23 mlelstv break;
520 1.1 agc
521 1.1 agc default:
522 1.23 mlelstv DEBOUT(("ISCSI: scsipi_request with invalid REQ code %d\n", req));
523 1.1 agc break;
524 1.1 agc }
525 1.23 mlelstv
526 1.23 mlelstv if (!error)
527 1.27 christos unref_session(sess);
528 1.1 agc }
529 1.1 agc
530 1.1 agc /* cap the transfer at 64K */
531 1.1 agc #define ISCSI_MAX_XFER 65536
532 1.1 agc
533 1.1 agc /*
534 1.1 agc * iscsi_minphys:
535 1.1 agc * Limit a transfer to our maximum transfer size.
536 1.1 agc */
537 1.1 agc
538 1.1 agc void
539 1.1 agc iscsi_minphys(struct buf *bp)
540 1.1 agc {
541 1.1 agc if (bp->b_bcount > ISCSI_MAX_XFER) {
542 1.1 agc bp->b_bcount = ISCSI_MAX_XFER;
543 1.1 agc }
544 1.1 agc }
545 1.1 agc
546 1.1 agc /*****************************************************************************
547 1.1 agc * SCSI job execution helper routines
548 1.1 agc *****************************************************************************/
549 1.1 agc
550 1.1 agc /*
551 1.1 agc * iscsi_done:
552 1.1 agc *
553 1.1 agc * A CCB has completed execution. Pass the status back to the
554 1.1 agc * upper layer.
555 1.1 agc */
556 1.1 agc void
557 1.1 agc iscsi_done(ccb_t *ccb)
558 1.1 agc {
559 1.27 christos struct scsipi_xfer *xs = ccb->ccb_xs;
560 1.18 mlelstv DEB(9, ("iscsi_done\n"));
561 1.1 agc
562 1.1 agc if (xs != NULL) {
563 1.27 christos xs->resid = ccb->ccb_residual;
564 1.27 christos ccb->ccb_xs = NULL;
565 1.27 christos xs->resid = ccb->ccb_residual;
566 1.1 agc
567 1.27 christos switch (ccb->ccb_status) {
568 1.1 agc case ISCSI_STATUS_SUCCESS:
569 1.18 mlelstv xs->error = XS_NOERROR;
570 1.18 mlelstv xs->status = SCSI_OK;
571 1.1 agc break;
572 1.1 agc
573 1.1 agc case ISCSI_STATUS_CHECK_CONDITION:
574 1.1 agc xs->error = XS_SENSE;
575 1.18 mlelstv xs->status = SCSI_CHECK;
576 1.1 agc break;
577 1.1 agc
578 1.1 agc case ISCSI_STATUS_TARGET_BUSY:
579 1.23 mlelstv case ISCSI_STATUS_NO_RESOURCES:
580 1.27 christos DEBC(ccb->ccb_connection, 5, ("target busy, ccb %p\n", ccb));
581 1.1 agc xs->error = XS_BUSY;
582 1.18 mlelstv xs->status = SCSI_BUSY;
583 1.1 agc break;
584 1.1 agc
585 1.1 agc case ISCSI_STATUS_SOCKET_ERROR:
586 1.1 agc case ISCSI_STATUS_TIMEOUT:
587 1.1 agc xs->error = XS_SELTIMEOUT;
588 1.18 mlelstv xs->status = SCSI_BUSY;
589 1.18 mlelstv break;
590 1.18 mlelstv
591 1.23 mlelstv case ISCSI_STATUS_QUEUE_FULL:
592 1.27 christos DEBC(ccb->ccb_connection, 5, ("queue full, ccb %p\n", ccb));
593 1.18 mlelstv xs->error = XS_BUSY;
594 1.18 mlelstv xs->status = SCSI_QUEUE_FULL;
595 1.1 agc break;
596 1.1 agc
597 1.1 agc default:
598 1.1 agc xs->error = XS_DRIVER_STUFFUP;
599 1.1 agc break;
600 1.1 agc }
601 1.1 agc
602 1.27 christos unref_session(ccb->ccb_session);
603 1.26 mlelstv
604 1.1 agc DEB(99, ("Calling scsipi_done (%p), err = %d\n", xs, xs->error));
605 1.1 agc scsipi_done(xs);
606 1.1 agc DEB(99, ("scsipi_done returned\n"));
607 1.18 mlelstv } else {
608 1.18 mlelstv DEBOUT(("ISCSI: iscsi_done CCB %p without XS\n", ccb));
609 1.1 agc }
610 1.1 agc }
611 1.1 agc
612 1.18 mlelstv SYSCTL_SETUP(sysctl_iscsi_setup, "ISCSI subtree setup")
613 1.18 mlelstv {
614 1.18 mlelstv const struct sysctlnode *node = NULL;
615 1.18 mlelstv
616 1.18 mlelstv sysctl_createv(clog, 0, NULL, &node,
617 1.18 mlelstv CTLFLAG_PERMANENT,
618 1.18 mlelstv CTLTYPE_NODE, "iscsi",
619 1.18 mlelstv SYSCTL_DESCR("iscsi controls"),
620 1.18 mlelstv NULL, 0, NULL, 0,
621 1.18 mlelstv CTL_HW, CTL_CREATE, CTL_EOL);
622 1.29 mlelstv sysctl_createv(clog, 0, &node, NULL,
623 1.29 mlelstv CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
624 1.29 mlelstv CTLTYPE_BOOL, "hexbignums",
625 1.29 mlelstv SYSCTL_DESCR("encode parameters in hex"),
626 1.29 mlelstv NULL, 0, &iscsi_hex_bignums, 0,
627 1.29 mlelstv CTL_CREATE, CTL_EOL);
628 1.18 mlelstv
629 1.18 mlelstv #ifdef ISCSI_DEBUG
630 1.18 mlelstv sysctl_createv(clog, 0, &node, NULL,
631 1.18 mlelstv CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
632 1.18 mlelstv CTLTYPE_INT, "debug",
633 1.18 mlelstv SYSCTL_DESCR("debug level"),
634 1.18 mlelstv NULL, 0, &iscsi_debug_level, sizeof(iscsi_debug_level),
635 1.18 mlelstv CTL_CREATE, CTL_EOL);
636 1.18 mlelstv #endif
637 1.18 mlelstv }
638 1.18 mlelstv
639 1.18 mlelstv
640 1.1 agc /* Kernel Module support */
641 1.1 agc
642 1.1 agc #include <sys/module.h>
643 1.1 agc
644 1.12 joerg MODULE(MODULE_CLASS_DRIVER, iscsi, NULL); /* Possibly a builtin module */
645 1.10 joerg
646 1.12 joerg #ifdef _MODULE
647 1.1 agc static const struct cfiattrdata ibescsi_info = { "scsi", 1,
648 1.1 agc {{"channel", "-1", -1},}
649 1.1 agc };
650 1.10 joerg
651 1.1 agc static const struct cfiattrdata *const iscsi_attrs[] = { &ibescsi_info, NULL };
652 1.1 agc
653 1.1 agc CFDRIVER_DECL(iscsi, DV_DULL, iscsi_attrs);
654 1.1 agc
655 1.1 agc static struct cfdata iscsi_cfdata[] = {
656 1.1 agc {
657 1.1 agc .cf_name = "iscsi",
658 1.1 agc .cf_atname = "iscsi",
659 1.1 agc .cf_unit = 0, /* Only unit 0 is ever used */
660 1.1 agc .cf_fstate = FSTATE_NOTFOUND,
661 1.1 agc .cf_loc = NULL,
662 1.1 agc .cf_flags = 0,
663 1.1 agc .cf_pspec = NULL,
664 1.1 agc },
665 1.1 agc { NULL, NULL, 0, 0, NULL, 0, NULL }
666 1.1 agc };
667 1.12 joerg #endif
668 1.1 agc
669 1.1 agc static int
670 1.1 agc iscsi_modcmd(modcmd_t cmd, void *arg)
671 1.1 agc {
672 1.12 joerg #ifdef _MODULE
673 1.1 agc devmajor_t cmajor = NODEVMAJOR, bmajor = NODEVMAJOR;
674 1.1 agc int error;
675 1.18 mlelstv static struct sysctllog *clog;
676 1.12 joerg #endif
677 1.1 agc
678 1.1 agc switch (cmd) {
679 1.1 agc case MODULE_CMD_INIT:
680 1.12 joerg #ifdef _MODULE
681 1.1 agc error = config_cfdriver_attach(&iscsi_cd);
682 1.1 agc if (error) {
683 1.1 agc return error;
684 1.1 agc }
685 1.1 agc
686 1.1 agc error = config_cfattach_attach(iscsi_cd.cd_name, &iscsi_ca);
687 1.1 agc if (error) {
688 1.1 agc config_cfdriver_detach(&iscsi_cd);
689 1.1 agc aprint_error("%s: unable to register cfattach\n",
690 1.1 agc iscsi_cd.cd_name);
691 1.1 agc return error;
692 1.1 agc }
693 1.1 agc
694 1.1 agc error = config_cfdata_attach(iscsi_cfdata, 1);
695 1.1 agc if (error) {
696 1.1 agc aprint_error("%s: unable to attach cfdata\n",
697 1.1 agc iscsi_cd.cd_name);
698 1.1 agc config_cfattach_detach(iscsi_cd.cd_name, &iscsi_ca);
699 1.1 agc config_cfdriver_detach(&iscsi_cd);
700 1.1 agc return error;
701 1.1 agc }
702 1.1 agc
703 1.1 agc error = devsw_attach(iscsi_cd.cd_name, NULL, &bmajor,
704 1.1 agc &iscsi_cdevsw, &cmajor);
705 1.1 agc if (error) {
706 1.1 agc aprint_error("%s: unable to register devsw\n",
707 1.1 agc iscsi_cd.cd_name);
708 1.1 agc config_cfdata_detach(iscsi_cfdata);
709 1.1 agc config_cfattach_detach(iscsi_cd.cd_name, &iscsi_ca);
710 1.1 agc config_cfdriver_detach(&iscsi_cd);
711 1.1 agc return error;
712 1.1 agc }
713 1.1 agc
714 1.1 agc if (config_attach_pseudo(iscsi_cfdata) == NULL) {
715 1.1 agc aprint_error("%s: config_attach_pseudo failed\n",
716 1.1 agc iscsi_cd.cd_name);
717 1.1 agc config_cfattach_detach(iscsi_cd.cd_name, &iscsi_ca);
718 1.1 agc config_cfdriver_detach(&iscsi_cd);
719 1.1 agc return ENXIO;
720 1.1 agc }
721 1.18 mlelstv
722 1.18 mlelstv sysctl_iscsi_setup(&clog);
723 1.12 joerg #endif
724 1.1 agc return 0;
725 1.1 agc break;
726 1.1 agc
727 1.1 agc case MODULE_CMD_FINI:
728 1.12 joerg #ifdef _MODULE
729 1.1 agc error = config_cfdata_detach(iscsi_cfdata);
730 1.1 agc if (error)
731 1.1 agc return error;
732 1.1 agc
733 1.21 mlelstv sysctl_teardown(&clog);
734 1.21 mlelstv
735 1.1 agc config_cfattach_detach(iscsi_cd.cd_name, &iscsi_ca);
736 1.1 agc config_cfdriver_detach(&iscsi_cd);
737 1.1 agc devsw_detach(NULL, &iscsi_cdevsw);
738 1.12 joerg #endif
739 1.1 agc return 0;
740 1.1 agc break;
741 1.1 agc
742 1.2 riz case MODULE_CMD_AUTOUNLOAD:
743 1.2 riz return EBUSY;
744 1.2 riz break;
745 1.2 riz
746 1.1 agc default:
747 1.1 agc return ENOTTY;
748 1.1 agc break;
749 1.1 agc }
750 1.1 agc }
751