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