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