Home | History | Annotate | Line # | Download | only in iscsi
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