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