Home | History | Annotate | Line # | Download | only in iscsid
iscsid_driverif.c revision 1.2
      1  1.2  christos /*	$NetBSD: iscsid_driverif.c,v 1.2 2011/10/29 16:54:49 christos Exp $	*/
      2  1.1       agc 
      3  1.1       agc /*-
      4  1.1       agc  * Copyright (c) 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 "iscsid_globals.h"
     32  1.1       agc 
     33  1.1       agc #include <sys/socket.h>
     34  1.1       agc #include <netinet/in.h>
     35  1.1       agc #include <netinet/tcp.h>
     36  1.1       agc #include <netdb.h>
     37  1.1       agc 
     38  1.1       agc 
     39  1.1       agc /* Global node name (Initiator Name and Alias) */
     40  1.1       agc iscsid_set_node_name_req_t node_name;
     41  1.1       agc 
     42  1.1       agc /* -------------------------------------------------------------------------- */
     43  1.1       agc 
     44  1.1       agc /*
     45  1.1       agc  * set_node_name:
     46  1.1       agc  *    Handle set_node_name request. Copy names into our own buffers and
     47  1.1       agc  *    set the driver's info as well.
     48  1.1       agc  *
     49  1.1       agc  *    Parameter:
     50  1.1       agc  *          par         The request parameter
     51  1.1       agc  *
     52  1.1       agc  *    Returns: Status.
     53  1.1       agc  */
     54  1.1       agc 
     55  1.1       agc uint32_t
     56  1.1       agc set_node_name(iscsid_set_node_name_req_t * par)
     57  1.1       agc {
     58  1.1       agc 	iscsi_set_node_name_parameters_t snp;
     59  1.1       agc 
     60  1.1       agc 	(void) memset(&snp, 0x0, sizeof(snp));
     61  1.1       agc 	if (!par->InitiatorName[0])
     62  1.1       agc 		return ISCSID_STATUS_NO_INITIATOR_NAME;
     63  1.1       agc 
     64  1.1       agc 	if (strlen((char *)par->InitiatorName) > ISCSI_STRING_LENGTH
     65  1.1       agc 		|| strlen((char *)par->InitiatorAlias) > ISCSI_STRING_LENGTH)
     66  1.1       agc 		return ISCSID_STATUS_PARAMETER_INVALID;
     67  1.1       agc 
     68  1.1       agc 	if (!par->InitiatorAlias[0])
     69  1.1       agc 		gethostname((char *)node_name.InitiatorAlias, sizeof(node_name.InitiatorAlias));
     70  1.1       agc 
     71  1.1       agc 	node_name = *par;
     72  1.1       agc 
     73  1.1       agc #ifdef ISCSI_DEBUG				/* DEBUG ONLY: Allow op without driver present */
     74  1.1       agc 	if (driver < 0)
     75  1.1       agc 		return ISCSID_STATUS_SUCCESS;
     76  1.1       agc #endif
     77  1.1       agc 
     78  1.1       agc 	strlcpy((char *)snp.InitiatorName, (char *)par->InitiatorName,
     79  1.1       agc 		sizeof(snp.InitiatorName));
     80  1.1       agc 	strlcpy((char *)snp.InitiatorAlias, (char *)par->InitiatorAlias,
     81  1.1       agc 		sizeof(snp.InitiatorAlias));
     82  1.1       agc 	memcpy(snp.ISID, par->ISID, 6);
     83  1.1       agc 
     84  1.1       agc 	DEB(10, ("Setting Node Name: %s (%s)\n",
     85  1.1       agc 			 snp.InitiatorName, snp.InitiatorAlias));
     86  1.2  christos 	(void)ioctl(driver, ISCSI_SET_NODE_NAME, &snp);
     87  1.1       agc 	return snp.status;
     88  1.1       agc }
     89  1.1       agc 
     90  1.1       agc 
     91  1.1       agc /*
     92  1.1       agc  * bind_socket:
     93  1.1       agc  *    Bind socket to initiator portal.
     94  1.1       agc  *
     95  1.1       agc  *    Parameter:
     96  1.1       agc  *       sock     The socket
     97  1.1       agc  *       addr     The initiator portal address
     98  1.1       agc  *
     99  1.1       agc  *    Returns:
    100  1.1       agc  *       TRUE on success, FALSE on error.
    101  1.1       agc  */
    102  1.1       agc 
    103  1.1       agc STATIC int
    104  1.1       agc bind_socket(int sock, uint8_t * addr)
    105  1.1       agc {
    106  1.1       agc 	struct sockaddr_in serverAddress;
    107  1.1       agc 	struct hostent *host;
    108  1.1       agc 
    109  1.1       agc 	DEB(8, ("Binding to <%s>\n", addr));
    110  1.1       agc 	(void) memset(&serverAddress, 0x0, sizeof(serverAddress));
    111  1.1       agc 	host = gethostbyname((char *)addr);
    112  1.1       agc 	if (host == NULL)
    113  1.1       agc 		return FALSE;
    114  1.1       agc 	if (host->h_length > (int)sizeof(serverAddress.sin_addr))
    115  1.1       agc 		return FALSE;
    116  1.1       agc 	serverAddress.sin_family = host->h_addrtype;
    117  1.1       agc 	serverAddress.sin_port = 0;
    118  1.1       agc 	serverAddress.sin_len = host->h_length;
    119  1.1       agc 	memcpy(&serverAddress.sin_addr, host->h_addr_list[0], host->h_length);
    120  1.1       agc 
    121  1.2  christos 	return bind(sock, (struct sockaddr *)(void *)&serverAddress,
    122  1.2  christos 				(socklen_t)sizeof(serverAddress)) >= 0;
    123  1.1       agc }
    124  1.1       agc 
    125  1.1       agc 
    126  1.1       agc /* -------------------------------------------------------------------------- */
    127  1.1       agc 
    128  1.1       agc /*
    129  1.1       agc  * find_free_portal:
    130  1.1       agc  *    Find the Portal with the least number of connections.
    131  1.1       agc  *
    132  1.1       agc  *    Parameter:  the portal group
    133  1.1       agc  *
    134  1.1       agc  *    Returns:    The pointer to the first free portal (or NULL if none found)
    135  1.1       agc  */
    136  1.1       agc 
    137  1.1       agc STATIC portal_t *
    138  1.1       agc find_free_portal(portal_group_t * group)
    139  1.1       agc {
    140  1.1       agc 	portal_t *curr, *m;
    141  1.1       agc 	uint32_t n;
    142  1.1       agc 
    143  1.1       agc 	if ((curr = TAILQ_FIRST(&group->portals)) == NULL)
    144  1.1       agc 		return NULL;
    145  1.1       agc 
    146  1.1       agc 	m = curr;
    147  1.1       agc 	n = curr->active_connections;
    148  1.1       agc 
    149  1.1       agc 	while ((curr = TAILQ_NEXT(curr, group_list)) != NULL)
    150  1.1       agc 		if (curr->active_connections < n) {
    151  1.1       agc 			m = curr;
    152  1.1       agc 			n = curr->active_connections;
    153  1.1       agc 		}
    154  1.1       agc 
    155  1.1       agc 	return m;
    156  1.1       agc }
    157  1.1       agc 
    158  1.1       agc 
    159  1.1       agc /*
    160  1.1       agc  * make_connection:
    161  1.1       agc  *    Common routine for login and add_connection. Creates the connection
    162  1.1       agc  *    structure, connects the socket, and executes the login.
    163  1.1       agc  *
    164  1.1       agc  *    Parameter:
    165  1.1       agc  *          sess        The associated session. NULL for a send_targets request.
    166  1.1       agc  *          req         The request parameters. NULL for send_targets.
    167  1.1       agc  *          res         The response buffer. For SendTargets, only the status
    168  1.1       agc  *                      is set. For a "real" login, the login response
    169  1.1       agc  *                      is filled in.
    170  1.1       agc  *          stid        Send target request only, else NULL. Pointer to uint32:
    171  1.1       agc  *                         On Input, contains send target ID
    172  1.1       agc  *                         On Output, receives session ID
    173  1.1       agc  *
    174  1.1       agc  *    Returns:    The connection structure on successful login, else NULL.
    175  1.1       agc  *
    176  1.1       agc  *    NOTE: Session list must be locked on entry.
    177  1.1       agc  */
    178  1.1       agc 
    179  1.1       agc STATIC connection_t *
    180  1.1       agc make_connection(session_t * sess, iscsid_login_req_t * req,
    181  1.1       agc 				iscsid_response_t * res, uint32_t * stid)
    182  1.1       agc {
    183  1.1       agc 	connection_t *conn;
    184  1.1       agc 	iscsi_login_parameters_t loginp;
    185  1.1       agc 	int sock;
    186  1.1       agc 	int ret;
    187  1.1       agc 	int yes = 1;
    188  1.1       agc 	target_t *target;
    189  1.1       agc 	portal_t *portal = NULL;
    190  1.1       agc 	iscsi_portal_address_t *addr;
    191  1.1       agc 	struct sockaddr_in serverAddress;
    192  1.1       agc 	struct hostent *host;
    193  1.1       agc 	initiator_t *init;
    194  1.1       agc 
    195  1.1       agc 	DEB(9, ("Make Connection sess=%x, req=%x, res=%x, stid=%x\n",
    196  1.1       agc 			 (int) sess, (int) req, (int) res, (int) stid));
    197  1.1       agc 	(void) memset(&loginp, 0x0, sizeof(loginp));
    198  1.1       agc 	(void) memset(&serverAddress, 0x0, sizeof(serverAddress));
    199  1.1       agc 
    200  1.1       agc 	/* find the target portal */
    201  1.1       agc 	if (stid != NULL) {
    202  1.1       agc 		send_target_t *starget;
    203  1.1       agc 
    204  1.1       agc 		if ((starget = find_send_target_id(*stid)) == NULL) {
    205  1.1       agc 			res->status = ISCSID_STATUS_INVALID_TARGET_ID;
    206  1.1       agc 			return NULL;
    207  1.1       agc 		}
    208  1.1       agc 		addr = &starget->addr;
    209  1.2  christos 		target = (target_t *)(void *)starget;
    210  1.1       agc 	} else {
    211  1.1       agc 		if (NO_ID(&req->portal_id)
    212  1.1       agc 			|| (portal = find_portal(&req->portal_id)) == NULL) {
    213  1.1       agc 			portal_group_t *group;
    214  1.1       agc 
    215  1.1       agc 			/* if no ID was specified, use target from existing session */
    216  1.1       agc 			if (NO_ID(&req->portal_id)) {
    217  1.1       agc 				if (!sess->num_connections ||
    218  1.2  christos 					((target = find_target_id(TARGET_LIST,
    219  1.2  christos 					sess->target.sid.id)) == NULL)) {
    220  1.1       agc 					res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
    221  1.1       agc 					return NULL;
    222  1.1       agc 				}
    223  1.1       agc 			}
    224  1.1       agc 			/* if a target was given instead, use it */
    225  1.1       agc 			else if ((target =
    226  1.1       agc 							  find_target(TARGET_LIST, &req->portal_id)) == NULL) {
    227  1.1       agc 				res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
    228  1.1       agc 				return NULL;
    229  1.1       agc 			}
    230  1.1       agc 			/* now get from target to portal - if this is the first connection, */
    231  1.1       agc 			/* just use the first portal group. */
    232  1.1       agc 			if (!sess->num_connections) {
    233  1.1       agc 				group = TAILQ_FIRST(&target->group_list);
    234  1.1       agc 			}
    235  1.1       agc 			/* if it's a second connection, use an available portal in the same */
    236  1.1       agc 			/* portal group */
    237  1.1       agc 			else {
    238  1.2  christos 				conn = (connection_t *)(void *)
    239  1.2  christos 				    TAILQ_FIRST(&sess->connections);
    240  1.1       agc 
    241  1.1       agc 				if (conn == NULL ||
    242  1.1       agc 					(portal = find_portal_id(conn->portal.sid.id)) == NULL) {
    243  1.1       agc 					res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
    244  1.1       agc 					return NULL;
    245  1.1       agc 				}
    246  1.1       agc 				group = portal->group;
    247  1.1       agc 			}
    248  1.1       agc 
    249  1.1       agc 			if ((portal = find_free_portal(group)) == NULL) {
    250  1.1       agc 				res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
    251  1.1       agc 				return NULL;
    252  1.1       agc 			}
    253  1.1       agc 			DEB(1, ("find_free_portal returns pid=%d\n", portal->entry.sid.id));
    254  1.1       agc 		} else
    255  1.1       agc 			target = portal->target;
    256  1.1       agc 
    257  1.1       agc 		addr = &portal->addr;
    258  1.1       agc 
    259  1.1       agc 		/* symbolic name for connection? check for duplicates */
    260  1.1       agc 		if (req->sym_name[0]) {
    261  1.1       agc 			void *p;
    262  1.1       agc 
    263  1.1       agc 			if (sess->num_connections)
    264  1.1       agc 				p = find_connection_name(sess, req->sym_name);
    265  1.1       agc 			else
    266  1.1       agc 				p = find_session_name(req->sym_name);
    267  1.1       agc 			if (p) {
    268  1.1       agc 				res->status = ISCSID_STATUS_DUPLICATE_NAME;
    269  1.1       agc 				return NULL;
    270  1.1       agc 			}
    271  1.1       agc 		}
    272  1.1       agc 	}
    273  1.1       agc 
    274  1.1       agc 	if (req != NULL && !NO_ID(&req->initiator_id)) {
    275  1.1       agc 		if ((init = find_initiator(&req->initiator_id)) == NULL) {
    276  1.1       agc 			res->status = ISCSID_STATUS_INVALID_INITIATOR_ID;
    277  1.1       agc 			return NULL;
    278  1.1       agc 		}
    279  1.1       agc 	} else
    280  1.1       agc 		init = select_initiator();
    281  1.1       agc 
    282  1.1       agc 	/* translate target address */
    283  1.1       agc 	DEB(8, ("Connecting to <%s>, port %d\n", addr->address, addr->port));
    284  1.1       agc 
    285  1.1       agc 	host = gethostbyname((char *)addr->address);
    286  1.1       agc 	if (host == NULL) {
    287  1.1       agc 		switch (h_errno) {
    288  1.1       agc 		case HOST_NOT_FOUND:
    289  1.1       agc 			res->status = ISCSID_STATUS_HOST_NOT_FOUND;
    290  1.1       agc 			break;
    291  1.1       agc 		case TRY_AGAIN:
    292  1.1       agc 			res->status = ISCSID_STATUS_HOST_TRY_AGAIN;
    293  1.1       agc 			break;
    294  1.1       agc 		default:
    295  1.1       agc 			res->status = ISCSID_STATUS_HOST_ERROR;
    296  1.1       agc 			break;
    297  1.1       agc 		}
    298  1.1       agc 		return NULL;
    299  1.1       agc 	}
    300  1.1       agc 	if (host->h_length > (int)sizeof(serverAddress.sin_addr)) {
    301  1.1       agc 		res->status = ISCSID_STATUS_HOST_ERROR;
    302  1.1       agc 		return NULL;
    303  1.1       agc 	}
    304  1.1       agc 	DEB(8, ("Gethostbyname OK, addrtype %d, len %d, addr %x\n",
    305  1.1       agc 			host->h_addrtype, host->h_length, *((int *) host->h_addr_list[0])));
    306  1.1       agc 	serverAddress.sin_family = host->h_addrtype;
    307  1.1       agc 	serverAddress.sin_port = htons((addr->port)
    308  1.1       agc 		? addr->port : ISCSI_DEFAULT_PORT);
    309  1.1       agc 	serverAddress.sin_len = host->h_length;
    310  1.1       agc 	memcpy(&serverAddress.sin_addr, host->h_addr_list[0], host->h_length);
    311  1.1       agc 
    312  1.1       agc 	/* alloc the connection structure */
    313  1.1       agc 	conn = calloc(1, sizeof(*conn));
    314  1.1       agc 	if (conn == NULL) {
    315  1.1       agc 		res->status = ISCSID_STATUS_NO_RESOURCES;
    316  1.1       agc 		return NULL;
    317  1.1       agc 	}
    318  1.1       agc 	/* create and connect the socket */
    319  1.1       agc 	sock = socket(AF_INET, SOCK_STREAM, 0);
    320  1.1       agc 	if (sock < 0) {
    321  1.1       agc 		free(conn);
    322  1.1       agc 		res->status = ISCSID_STATUS_SOCKET_ERROR;
    323  1.1       agc 		return NULL;
    324  1.1       agc 	}
    325  1.1       agc 
    326  1.1       agc 	if (init) {
    327  1.1       agc 		if (!bind_socket(sock, init->address)) {
    328  1.1       agc 			close(sock);
    329  1.1       agc 			free(conn);
    330  1.1       agc 			res->status = ISCSID_STATUS_INITIATOR_BIND_ERROR;
    331  1.1       agc 			return NULL;
    332  1.1       agc 		}
    333  1.1       agc 	}
    334  1.1       agc 
    335  1.1       agc 	DEB(8, ("Connecting socket\n"));
    336  1.2  christos 	if (connect(sock, (struct sockaddr *)(void *)&serverAddress,
    337  1.2  christos 		(socklen_t)sizeof(serverAddress)) < 0) {
    338  1.1       agc 		close(sock);
    339  1.1       agc 		free(conn);
    340  1.1       agc 		res->status = ISCSID_STATUS_CONNECT_ERROR;
    341  1.1       agc 		DEB(1, ("Connecting to socket failed (error %d), returning %d\n",
    342  1.1       agc 				errno, res->status));
    343  1.1       agc 		return NULL;
    344  1.1       agc 	}
    345  1.1       agc 	/* speed up socket processing */
    346  1.2  christos 	setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, &yes, (socklen_t)sizeof(yes));
    347  1.1       agc 
    348  1.1       agc 	/* setup login parameter structure */
    349  1.1       agc 	loginp.socket = sock;
    350  1.1       agc 	if (target->TargetName[0]) {
    351  1.1       agc 		loginp.is_present.TargetName = 1;
    352  1.1       agc 		loginp.TargetName = target->TargetName;
    353  1.1       agc 	}
    354  1.1       agc 	if (target->options.is_present.MaxConnections) {
    355  1.1       agc 		loginp.is_present.MaxConnections = 1;
    356  1.1       agc 		loginp.MaxConnections = target->options.MaxConnections;
    357  1.1       agc 	}
    358  1.1       agc 	if (target->options.is_present.DataDigest) {
    359  1.1       agc 		loginp.is_present.DataDigest = 1;
    360  1.1       agc 		loginp.DataDigest = target->options.DataDigest;
    361  1.1       agc 	}
    362  1.1       agc 	if (target->options.is_present.HeaderDigest) {
    363  1.1       agc 		loginp.is_present.HeaderDigest = 1;
    364  1.1       agc 		loginp.HeaderDigest = target->options.HeaderDigest;
    365  1.1       agc 	}
    366  1.1       agc 	if (target->options.is_present.DefaultTime2Retain) {
    367  1.1       agc 		loginp.is_present.DefaultTime2Retain = 1;
    368  1.1       agc 		loginp.DefaultTime2Retain = target->options.DefaultTime2Retain;
    369  1.1       agc 	}
    370  1.1       agc 	if (target->options.is_present.DefaultTime2Wait) {
    371  1.1       agc 		loginp.is_present.DefaultTime2Wait = 1;
    372  1.1       agc 		loginp.DefaultTime2Wait = target->options.DefaultTime2Wait;
    373  1.1       agc 	}
    374  1.1       agc 	if (target->options.is_present.ErrorRecoveryLevel) {
    375  1.1       agc 		loginp.is_present.ErrorRecoveryLevel = 1;
    376  1.1       agc 		loginp.ErrorRecoveryLevel = target->options.ErrorRecoveryLevel;
    377  1.1       agc 	}
    378  1.1       agc 	if (target->options.is_present.MaxRecvDataSegmentLength) {
    379  1.1       agc 		loginp.is_present.MaxRecvDataSegmentLength = 1;
    380  1.1       agc 		loginp.MaxRecvDataSegmentLength =
    381  1.1       agc 			target->options.MaxRecvDataSegmentLength;
    382  1.1       agc 	}
    383  1.1       agc 	if (target->auth.auth_info.auth_number) {
    384  1.1       agc 		loginp.is_present.auth_info = 1;
    385  1.1       agc 		loginp.auth_info = target->auth.auth_info;
    386  1.1       agc 		if (target->auth.password[0]) {
    387  1.1       agc 			loginp.is_present.password = 1;
    388  1.1       agc 			loginp.password = target->auth.password;
    389  1.1       agc 		}
    390  1.1       agc 		if (target->auth.target_password[0]) {
    391  1.1       agc 			loginp.is_present.target_password = 1;
    392  1.1       agc 			loginp.target_password = target->auth.target_password;
    393  1.1       agc 		}
    394  1.1       agc 		if (target->auth.user_name[0]) {
    395  1.1       agc 			loginp.is_present.user_name = 1;
    396  1.1       agc 			loginp.user_name = target->auth.user_name;
    397  1.1       agc 		}
    398  1.1       agc 	}
    399  1.1       agc 	loginp.is_present.TargetAlias = 1;
    400  1.1       agc 	loginp.TargetAlias = target->TargetAlias;
    401  1.1       agc 
    402  1.1       agc 	if (portal != NULL) {
    403  1.1       agc 		/* override general target options with portal options (if specified) */
    404  1.1       agc 		if (portal->options.is_present.DataDigest) {
    405  1.1       agc 			loginp.is_present.DataDigest = 1;
    406  1.1       agc 			loginp.DataDigest = portal->options.DataDigest;
    407  1.1       agc 		}
    408  1.1       agc 		if (portal->options.is_present.HeaderDigest) {
    409  1.1       agc 			loginp.is_present.HeaderDigest = 1;
    410  1.1       agc 			loginp.HeaderDigest = portal->options.HeaderDigest;
    411  1.1       agc 		}
    412  1.1       agc 		if (portal->options.is_present.MaxRecvDataSegmentLength) {
    413  1.1       agc 			loginp.is_present.MaxRecvDataSegmentLength = 1;
    414  1.1       agc 			loginp.MaxRecvDataSegmentLength =
    415  1.1       agc 				portal->options.MaxRecvDataSegmentLength;
    416  1.1       agc 		}
    417  1.1       agc 	}
    418  1.1       agc 
    419  1.1       agc 	if (req != NULL) {
    420  1.1       agc 		loginp.session_id = get_id(&list[SESSION_LIST].list, &req->session_id);
    421  1.1       agc 		loginp.login_type = req->login_type;
    422  1.1       agc 	} else
    423  1.1       agc 		loginp.login_type = ISCSI_LOGINTYPE_DISCOVERY;
    424  1.1       agc 
    425  1.1       agc 	DEB(5, ("Calling Login...\n"));
    426  1.1       agc 
    427  1.1       agc 	ret = ioctl(driver, (sess != NULL && sess->num_connections)
    428  1.1       agc 				? ISCSI_ADD_CONNECTION : ISCSI_LOGIN, &loginp);
    429  1.1       agc 
    430  1.1       agc 	res->status = loginp.status;
    431  1.1       agc 
    432  1.1       agc 	if (ret)
    433  1.1       agc 		close(sock);
    434  1.1       agc 
    435  1.1       agc 	if (ret || loginp.status) {
    436  1.1       agc 		free(conn);
    437  1.1       agc 		if (!res->status)
    438  1.1       agc 			res->status = ISCSID_STATUS_GENERAL_ERROR;
    439  1.1       agc 		return NULL;
    440  1.1       agc 	}
    441  1.1       agc 	/* connection established! link connection into session and return IDs */
    442  1.1       agc 
    443  1.1       agc 	conn->loginp = loginp;
    444  1.1       agc 	conn->entry.sid.id = loginp.connection_id;
    445  1.1       agc 	if (req != NULL) {
    446  1.1       agc 		strlcpy((char *)conn->entry.sid.name, (char *)req->sym_name,
    447  1.1       agc 			sizeof(conn->entry.sid.name));
    448  1.1       agc 	}
    449  1.1       agc 
    450  1.1       agc 	/*
    451  1.1       agc 	   Copy important target information
    452  1.1       agc 	 */
    453  1.1       agc 	conn->target.sid = target->entry.sid;
    454  1.1       agc 	strlcpy((char *)conn->target.TargetName, (char *)target->TargetName,
    455  1.1       agc 		sizeof(conn->target.TargetName));
    456  1.1       agc 	strlcpy((char *)conn->target.TargetAlias, (char *)target->TargetAlias,
    457  1.1       agc 		sizeof(conn->target.TargetAlias));
    458  1.1       agc 	conn->target.options = target->options;
    459  1.1       agc 	conn->target.auth = target->auth;
    460  1.1       agc 	conn->portal.addr = *addr;
    461  1.1       agc 
    462  1.1       agc 	conn->session = sess;
    463  1.1       agc 
    464  1.1       agc 	if (stid == NULL) {
    465  1.2  christos 		iscsid_login_rsp_t *rsp = (iscsid_login_rsp_t *)(void *)
    466  1.2  christos 		    res->parameter;
    467  1.1       agc 
    468  1.1       agc 		sess->entry.sid.id = loginp.session_id;
    469  1.1       agc 		TAILQ_INSERT_TAIL(&sess->connections, &conn->entry, link);
    470  1.1       agc 		sess->num_connections++;
    471  1.1       agc 
    472  1.1       agc 		res->parameter_length = sizeof(*rsp);
    473  1.1       agc 		rsp->connection_id = conn->entry.sid;
    474  1.1       agc 		rsp->session_id = sess->entry.sid;
    475  1.1       agc 
    476  1.1       agc 		if (init != NULL) {
    477  1.1       agc 			conn->initiator_id = init->entry.sid.id;
    478  1.1       agc 			init->active_connections++;
    479  1.1       agc 		}
    480  1.1       agc 	} else
    481  1.1       agc 		*stid = loginp.session_id;
    482  1.1       agc 
    483  1.1       agc 	/*
    484  1.1       agc 	   Copy important portal information
    485  1.1       agc 	 */
    486  1.1       agc 	if (portal != NULL) {
    487  1.1       agc 		conn->portal.sid = portal->entry.sid;
    488  1.1       agc 		portal->active_connections++;
    489  1.1       agc 	}
    490  1.1       agc 
    491  1.1       agc 	return conn;
    492  1.1       agc }
    493  1.1       agc 
    494  1.1       agc 
    495  1.1       agc /*
    496  1.1       agc  * event_recover_connection:
    497  1.1       agc  *    Handle RECOVER_CONNECTION event: Attempt to re-establish connection.
    498  1.1       agc  *
    499  1.1       agc  *    Parameter:
    500  1.1       agc  *          sid         Session ID
    501  1.1       agc  *          cid         Connection ID
    502  1.1       agc  */
    503  1.1       agc 
    504  1.1       agc STATIC void
    505  1.1       agc event_recover_connection(uint32_t sid, uint32_t cid)
    506  1.1       agc {
    507  1.1       agc 	int sock, ret;
    508  1.1       agc 	int yes = 1;
    509  1.1       agc 	session_t *sess;
    510  1.1       agc 	connection_t *conn;
    511  1.1       agc 	portal_t *portal;
    512  1.1       agc 	initiator_t *init;
    513  1.1       agc 	iscsi_portal_address_t *addr;
    514  1.1       agc 	struct sockaddr_in serverAddress;
    515  1.1       agc 	struct hostent *host;
    516  1.1       agc 
    517  1.1       agc 	DEB(1, ("Event_Recover_Connection sid=%d, cid=%d\n", sid, cid));
    518  1.1       agc 	(void) memset(&serverAddress, 0x0, sizeof(serverAddress));
    519  1.1       agc 
    520  1.1       agc 	LOCK_SESSIONS;
    521  1.1       agc 
    522  1.1       agc 	sess = find_session_id(sid);
    523  1.1       agc 	if (sess == NULL) {
    524  1.1       agc 		UNLOCK_SESSIONS;
    525  1.1       agc 		return;
    526  1.1       agc 	}
    527  1.1       agc 
    528  1.1       agc 	conn = find_connection_id(sess, cid);
    529  1.1       agc 	if (conn == NULL) {
    530  1.1       agc 		UNLOCK_SESSIONS;
    531  1.1       agc 		return;
    532  1.1       agc 	}
    533  1.1       agc 
    534  1.1       agc 	UNLOCK_SESSIONS;
    535  1.1       agc 
    536  1.1       agc 	conn->loginp.status = ISCSI_STATUS_CONNECTION_FAILED;
    537  1.1       agc 
    538  1.1       agc 	/* If we can't find the portal to connect to, abort. */
    539  1.1       agc 
    540  1.1       agc 	if ((portal = find_portal_id(conn->portal.sid.id)) == NULL)
    541  1.1       agc 		return;
    542  1.1       agc 
    543  1.1       agc 	init = find_initiator_id(conn->initiator_id);
    544  1.1       agc 	addr = &portal->addr;
    545  1.1       agc 	conn->portal.addr = *addr;
    546  1.1       agc 
    547  1.1       agc 	/* translate target address */
    548  1.1       agc 	DEB(1, ("Event_Recover_Connection Connecting to <%s>, port %d\n",
    549  1.1       agc 			addr->address, addr->port));
    550  1.1       agc 
    551  1.1       agc 	if ((host = gethostbyname((char *)addr->address)) == NULL) {
    552  1.1       agc 		DEB(1, ("GetHostByName failed (error %d)\n", h_errno));
    553  1.1       agc 		return;
    554  1.1       agc 	}
    555  1.1       agc 	if (host->h_length > (int)sizeof(serverAddress.sin_addr)) {
    556  1.1       agc 		DEB(1, ("Host address length invalid (%d)\n", host->h_length));
    557  1.1       agc 		return;
    558  1.1       agc 	}
    559  1.1       agc 
    560  1.1       agc 	serverAddress.sin_family = host->h_addrtype;
    561  1.1       agc 	serverAddress.sin_port = htons((addr->port)
    562  1.1       agc 									? addr->port : ISCSI_DEFAULT_PORT);
    563  1.1       agc 	serverAddress.sin_len = host->h_length;
    564  1.1       agc 	memcpy(&serverAddress.sin_addr, host->h_addr_list[0], host->h_length);
    565  1.1       agc 
    566  1.1       agc 	/* create and connect the socket */
    567  1.1       agc 	sock = socket(AF_INET, SOCK_STREAM, 0);
    568  1.1       agc 	if (sock < 0) {
    569  1.1       agc 		DEB(1, ("Creating socket failed (error %d)\n", errno));
    570  1.1       agc 		return;
    571  1.1       agc 	}
    572  1.1       agc 
    573  1.1       agc 	DEB(1, ("recover_connection: Socket = %d\n", sock));
    574  1.1       agc 
    575  1.1       agc 	if (init) {
    576  1.1       agc 		if (!bind_socket(sock, init->address)) {
    577  1.1       agc 			DEB(1, ("Binding to interface failed (error %d)\n", errno));
    578  1.1       agc 			close(sock);
    579  1.1       agc 			return;
    580  1.1       agc 		}
    581  1.1       agc 	}
    582  1.1       agc 
    583  1.2  christos 	if (connect(sock, (struct sockaddr *)(void *)&serverAddress,
    584  1.2  christos 		(socklen_t)sizeof(serverAddress)) < 0) {
    585  1.1       agc 		DEB(1, ("Connecting to socket failed (error %d)\n", errno));
    586  1.1       agc 		close(sock);
    587  1.1       agc 		return;
    588  1.1       agc 	}
    589  1.1       agc 	/* speed up socket processing */
    590  1.2  christos 	setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, &yes, (socklen_t)sizeof(yes));
    591  1.1       agc 
    592  1.1       agc 	conn->loginp.socket = sock;
    593  1.1       agc 	conn->loginp.status = 0;
    594  1.1       agc 	ret = ioctl(driver, ISCSI_RESTORE_CONNECTION, &conn->loginp);
    595  1.1       agc 
    596  1.1       agc 	if (ret)
    597  1.1       agc 		close(sock);
    598  1.1       agc }
    599  1.1       agc 
    600  1.1       agc 
    601  1.1       agc /*
    602  1.1       agc  * login:
    603  1.1       agc  *    Handle LOGIN request: Log into given portal. Create session, then
    604  1.1       agc  *    let make_connection do the rest.
    605  1.1       agc  *
    606  1.1       agc  *    Parameter:
    607  1.1       agc  *          req         The request parameters
    608  1.1       agc  *          res         The response buffer
    609  1.1       agc  */
    610  1.1       agc 
    611  1.1       agc void
    612  1.1       agc login(iscsid_login_req_t * req, iscsid_response_t * res)
    613  1.1       agc {
    614  1.1       agc 	session_t *sess;
    615  1.1       agc 	connection_t *conn;
    616  1.1       agc 
    617  1.1       agc 	sess = calloc(1, sizeof(*sess));
    618  1.1       agc 	if (sess == NULL) {
    619  1.1       agc 		res->status = ISCSID_STATUS_NO_RESOURCES;
    620  1.1       agc 		return;
    621  1.1       agc 	}
    622  1.1       agc 	TAILQ_INIT(&sess->connections);
    623  1.1       agc 	strlcpy((char *)sess->entry.sid.name, (char *)req->sym_name,
    624  1.1       agc 			sizeof(sess->entry.sid.name));
    625  1.1       agc 
    626  1.1       agc 	LOCK_SESSIONS;
    627  1.1       agc 	conn = make_connection(sess, req, res, 0);
    628  1.1       agc 
    629  1.1       agc 	if (conn == NULL)
    630  1.1       agc 		free(sess);
    631  1.1       agc 	else {
    632  1.1       agc 		sess->target = conn->target;
    633  1.1       agc 		TAILQ_INSERT_TAIL(&list[SESSION_LIST].list, &sess->entry, link);
    634  1.1       agc 		list[SESSION_LIST].num_entries++;
    635  1.1       agc 	}
    636  1.1       agc 	UNLOCK_SESSIONS;
    637  1.1       agc }
    638  1.1       agc 
    639  1.1       agc 
    640  1.1       agc /*
    641  1.1       agc  * add_connection:
    642  1.1       agc  *    Handle ADD_CONNECTION request: Log secondary connection into given portal.
    643  1.1       agc  *    Find the session, then let make_connection do the rest.
    644  1.1       agc  *
    645  1.1       agc  *    Parameter:
    646  1.1       agc  *          req         The request parameters
    647  1.1       agc  *          res         The response buffer
    648  1.1       agc  */
    649  1.1       agc 
    650  1.1       agc void
    651  1.1       agc add_connection(iscsid_login_req_t * req, iscsid_response_t * res)
    652  1.1       agc {
    653  1.1       agc 	session_t *sess;
    654  1.1       agc 
    655  1.1       agc 	LOCK_SESSIONS;
    656  1.1       agc 	sess = find_session(&req->session_id);
    657  1.1       agc 	if (sess == NULL) {
    658  1.1       agc 		UNLOCK_SESSIONS;
    659  1.1       agc 		res->status = ISCSID_STATUS_INVALID_SESSION_ID;
    660  1.1       agc 		return;
    661  1.1       agc 	}
    662  1.1       agc 
    663  1.1       agc 	make_connection(sess, req, res, 0);
    664  1.1       agc 	UNLOCK_SESSIONS;
    665  1.1       agc }
    666  1.1       agc 
    667  1.1       agc 
    668  1.1       agc /*
    669  1.1       agc  * logout:
    670  1.1       agc  *    Handle LOGOUT request: Log out the given session.
    671  1.1       agc  *
    672  1.1       agc  *    Parameter:
    673  1.1       agc  *          req         The request parameters
    674  1.1       agc  *
    675  1.1       agc  *    Returns: Response status
    676  1.1       agc  */
    677  1.1       agc 
    678  1.1       agc uint32_t
    679  1.1       agc logout(iscsid_sym_id_t * req)
    680  1.1       agc {
    681  1.1       agc 	iscsi_logout_parameters_t logoutp;
    682  1.1       agc 	session_t *sess;
    683  1.1       agc 	int ret;
    684  1.1       agc 
    685  1.1       agc 	(void) memset(&logoutp, 0x0, sizeof(logoutp));
    686  1.1       agc 	LOCK_SESSIONS;
    687  1.1       agc 	sess = find_session(req);
    688  1.1       agc 	if (sess == NULL) {
    689  1.1       agc 		UNLOCK_SESSIONS;
    690  1.1       agc 		return ISCSID_STATUS_INVALID_SESSION_ID;
    691  1.1       agc 	}
    692  1.1       agc 
    693  1.1       agc 	logoutp.session_id = sess->entry.sid.id;
    694  1.1       agc 	UNLOCK_SESSIONS;
    695  1.1       agc 
    696  1.1       agc 	ret = ioctl(driver, ISCSI_LOGOUT, &logoutp);
    697  1.1       agc 	DEB(9, ("Logout returns %d, status = %d\n", ret, logoutp.status));
    698  1.1       agc 
    699  1.1       agc 	return logoutp.status;
    700  1.1       agc }
    701  1.1       agc 
    702  1.1       agc 
    703  1.1       agc /*
    704  1.1       agc  * remove_connection:
    705  1.1       agc  *    Handle REMOVE_CONNECTION request: Log out the given connection.
    706  1.1       agc  *
    707  1.1       agc  *    Parameter:
    708  1.1       agc  *          req         The request parameters
    709  1.1       agc  *
    710  1.1       agc  *    Returns: Response status
    711  1.1       agc  */
    712  1.1       agc 
    713  1.1       agc uint32_t
    714  1.1       agc remove_connection(iscsid_remove_connection_req_t * req)
    715  1.1       agc {
    716  1.1       agc 	iscsi_remove_parameters_t removep;
    717  1.1       agc 	session_t *sess;
    718  1.1       agc 	connection_t *conn;
    719  1.1       agc 	int ret;
    720  1.1       agc 
    721  1.1       agc 	LOCK_SESSIONS;
    722  1.1       agc 	sess = find_session(&req->session_id);
    723  1.1       agc 	if (sess == NULL) {
    724  1.1       agc 		UNLOCK_SESSIONS;
    725  1.1       agc 		return ISCSID_STATUS_INVALID_SESSION_ID;
    726  1.1       agc 	}
    727  1.1       agc 	conn = find_connection(sess, &req->connection_id);
    728  1.1       agc 	if (conn == NULL) {
    729  1.1       agc 		UNLOCK_SESSIONS;
    730  1.1       agc 		return ISCSID_STATUS_INVALID_CONNECTION_ID;
    731  1.1       agc 	}
    732  1.1       agc 
    733  1.1       agc 	removep.session_id = sess->entry.sid.id;
    734  1.1       agc 	removep.connection_id = conn->entry.sid.id;
    735  1.1       agc 	UNLOCK_SESSIONS;
    736  1.1       agc 
    737  1.1       agc 	ret = ioctl(driver, ISCSI_REMOVE_CONNECTION, &removep);
    738  1.1       agc 	DEB(9, ("Remove Connection returns %d, status=%d\n", ret, removep.status));
    739  1.1       agc 
    740  1.1       agc 	return removep.status;
    741  1.1       agc }
    742  1.1       agc 
    743  1.1       agc /*
    744  1.1       agc  * send_targets:
    745  1.1       agc  *    Handle SEND_TARGETS request:
    746  1.1       agc  *       First login with type = discovery.
    747  1.1       agc  *       Then send the SendTargets iSCSI request to the target, which will
    748  1.1       agc  *       return a list of target portals.
    749  1.1       agc  *       Then logout.
    750  1.1       agc  *
    751  1.1       agc  *    Parameter:
    752  1.1       agc  *          stid              The send target ID
    753  1.1       agc  *          response_buffer   Pointer to pointer to buffer containing response
    754  1.1       agc  *                            The response contains the list of the target
    755  1.1       agc  *							  portals. The caller frees the buffer after it
    756  1.1       agc  *							  is done with it.
    757  1.1       agc  *          response_size     Pointer to variable which upon return will hold
    758  1.1       agc  *							  the size of the response buffer.
    759  1.1       agc  *
    760  1.1       agc  *    Returns: Response status
    761  1.1       agc  */
    762  1.1       agc 
    763  1.1       agc uint32_t
    764  1.1       agc send_targets(uint32_t stid, uint8_t **response_buffer, uint32_t *response_size)
    765  1.1       agc {
    766  1.1       agc 	iscsi_send_targets_parameters_t sendt;
    767  1.1       agc 	iscsi_logout_parameters_t logoutp;
    768  1.1       agc 	int ret;
    769  1.1       agc 	connection_t *conn;
    770  1.1       agc 	iscsid_response_t res;
    771  1.1       agc 	uint32_t rc = ISCSID_STATUS_SUCCESS;
    772  1.1       agc 
    773  1.1       agc 	(void) memset(&sendt, 0x0, sizeof(sendt));
    774  1.1       agc 	(void) memset(&logoutp, 0x0, sizeof(logoutp));
    775  1.1       agc 	(void) memset(&res, 0x0, sizeof(res));
    776  1.1       agc 	conn = make_connection(NULL, NULL, &res, &stid);
    777  1.1       agc 	DEB(9, ("Make connection returns, status = %d\n", res.status));
    778  1.1       agc 
    779  1.1       agc 	if (conn == NULL)
    780  1.1       agc 		return res.status;
    781  1.1       agc 
    782  1.1       agc 	sendt.session_id = stid;
    783  1.1       agc 	sendt.response_buffer = NULL;
    784  1.1       agc 	sendt.response_size = 0;
    785  1.1       agc 	sendt.response_used = sendt.response_total = 0;
    786  1.1       agc 	strlcpy((char *)sendt.key, "All", sizeof(sendt.key));
    787  1.1       agc 
    788  1.1       agc 	/*Call once to get the size of the buffer necessary */
    789  1.1       agc 	ret = ioctl(driver, ISCSI_SEND_TARGETS, &sendt);
    790  1.1       agc 
    791  1.1       agc 	if (!ret && !sendt.status) {
    792  1.1       agc 		/* Allocate buffer required and call again to retrieve data */
    793  1.1       agc 		/* We allocate one extra byte so we can place a terminating 0 */
    794  1.1       agc 		/* at the end of the buffer. */
    795  1.1       agc 
    796  1.1       agc 		sendt.response_size = sendt.response_total;
    797  1.1       agc 		sendt.response_buffer = calloc(1, sendt.response_size + 1);
    798  1.1       agc 		if (sendt.response_buffer == NULL)
    799  1.1       agc 			rc = ISCSID_STATUS_NO_RESOURCES;
    800  1.1       agc 		else {
    801  1.1       agc 			ret = ioctl(driver, ISCSI_SEND_TARGETS, &sendt);
    802  1.1       agc 			((uint8_t *)sendt.response_buffer)[sendt.response_size] = 0;
    803  1.1       agc 
    804  1.1       agc 			if (ret || sendt.status) {
    805  1.1       agc 				free(sendt.response_buffer);
    806  1.1       agc 				sendt.response_buffer = NULL;
    807  1.1       agc 				sendt.response_used = 0;
    808  1.1       agc 				if ((rc = sendt.status) == 0)
    809  1.1       agc 					rc = ISCSID_STATUS_GENERAL_ERROR;
    810  1.1       agc 			}
    811  1.1       agc 		}
    812  1.1       agc 	} else if ((rc = sendt.status) == 0)
    813  1.1       agc 		rc = ISCSID_STATUS_GENERAL_ERROR;
    814  1.1       agc 
    815  1.1       agc 	*response_buffer = sendt.response_buffer;
    816  1.1       agc 	*response_size = sendt.response_used;
    817  1.1       agc 
    818  1.1       agc 	logoutp.session_id = stid;
    819  1.1       agc 	ret = ioctl(driver, ISCSI_LOGOUT, &logoutp);
    820  1.1       agc 	/* ignore logout status */
    821  1.1       agc 
    822  1.1       agc 	free(conn);
    823  1.1       agc 
    824  1.1       agc 	return rc;
    825  1.1       agc }
    826  1.1       agc 
    827  1.1       agc 
    828  1.1       agc 
    829  1.1       agc /*
    830  1.1       agc  * get_version:
    831  1.1       agc  *    Handle GET_VERSION request.
    832  1.1       agc  *
    833  1.1       agc  *    Returns: Filled get_version_rsp structure.
    834  1.1       agc  */
    835  1.1       agc 
    836  1.1       agc void
    837  1.1       agc get_version(iscsid_response_t ** prsp, int *prsp_temp)
    838  1.1       agc {
    839  1.1       agc 	iscsid_response_t *rsp = *prsp;
    840  1.1       agc 	iscsid_get_version_rsp_t *ver;
    841  1.1       agc 	iscsi_get_version_parameters_t drv_ver;
    842  1.1       agc 
    843  1.1       agc 	rsp = make_rsp(sizeof(iscsid_get_version_rsp_t), prsp, prsp_temp);
    844  1.1       agc 	if (rsp == NULL)
    845  1.1       agc 		return;
    846  1.2  christos 	ver = (iscsid_get_version_rsp_t *)(void *)rsp->parameter;
    847  1.1       agc 
    848  1.1       agc 	ver->interface_version = INTERFACE_VERSION;
    849  1.1       agc 	ver->major = VERSION_MAJOR;
    850  1.1       agc 	ver->minor = VERSION_MINOR;
    851  1.1       agc 	strlcpy ((char *)ver->version_string, VERSION_STRING, sizeof(ver->version_string));
    852  1.1       agc 
    853  1.1       agc #ifdef ISCSI_DEBUG				/* DEBUG ONLY: Allow op without driver present */
    854  1.1       agc 	if (driver < 0)
    855  1.1       agc 		return;
    856  1.1       agc #endif
    857  1.1       agc 	ioctl(driver, ISCSI_GET_VERSION, &drv_ver);
    858  1.1       agc 	ver->driver_interface_version = drv_ver.interface_version;
    859  1.1       agc 	ver->driver_major = drv_ver.major;
    860  1.1       agc 	ver->driver_minor = drv_ver.minor;
    861  1.1       agc 	strlcpy ((char *)ver->driver_version_string, (char *)drv_ver.version_string,
    862  1.1       agc 			 sizeof (ver->driver_version_string));
    863  1.1       agc }
    864  1.1       agc 
    865  1.1       agc 
    866  1.1       agc /* -------------------------------------------------------------------------- */
    867  1.1       agc 
    868  1.1       agc iscsi_register_event_parameters_t event_reg;	/* registered event ID */
    869  1.1       agc 
    870  1.1       agc 
    871  1.1       agc /*
    872  1.1       agc  * register_event_handler:
    873  1.1       agc  *    Call driver to register the event handler.
    874  1.1       agc  *
    875  1.1       agc  *    Returns:
    876  1.1       agc  *       TRUE on success.
    877  1.1       agc  */
    878  1.1       agc 
    879  1.1       agc boolean_t
    880  1.1       agc register_event_handler(void)
    881  1.1       agc {
    882  1.1       agc 	ioctl(driver, ISCSI_REGISTER_EVENT, &event_reg);
    883  1.1       agc 	return event_reg.event_id != 0;
    884  1.1       agc }
    885  1.1       agc 
    886  1.1       agc 
    887  1.1       agc /*
    888  1.1       agc  * deregister_event_handler:
    889  1.1       agc  *    Call driver to deregister the event handler. If the event handler thread
    890  1.1       agc  *    is waiting for an event, this will wake it up and cause it to exit.
    891  1.1       agc  */
    892  1.1       agc 
    893  1.1       agc void
    894  1.1       agc deregister_event_handler(void)
    895  1.1       agc {
    896  1.1       agc 	if (event_reg.event_id) {
    897  1.1       agc 		ioctl(driver, ISCSI_DEREGISTER_EVENT, &event_reg);
    898  1.1       agc 		event_reg.event_id = 0;
    899  1.1       agc 	}
    900  1.1       agc }
    901  1.1       agc 
    902  1.1       agc 
    903  1.1       agc /*
    904  1.1       agc  * event_handler:
    905  1.1       agc  *    Event handler thread. Wait for the driver to generate an event and
    906  1.1       agc  *    process it appropriately. Exits when the driver terminates or the
    907  1.1       agc  *    handler is deregistered because the daemon is terminating.
    908  1.1       agc  *
    909  1.1       agc  *    Parameter:
    910  1.1       agc  *          par         Not used.
    911  1.1       agc  */
    912  1.1       agc 
    913  1.1       agc void *
    914  1.2  christos /*ARGSUSED*/
    915  1.1       agc event_handler(void *par)
    916  1.1       agc {
    917  1.1       agc 	iscsi_wait_event_parameters_t evtp;
    918  1.1       agc 	int rc;
    919  1.1       agc 
    920  1.1       agc 	DEB(99, ("Event handler starts\n"));
    921  1.1       agc 	(void) memset(&evtp, 0x0, sizeof(evtp));
    922  1.1       agc 
    923  1.1       agc 	evtp.event_id = event_reg.event_id;
    924  1.1       agc 
    925  1.1       agc 	do {
    926  1.1       agc #ifndef ISCSI_NOTHREAD
    927  1.1       agc 		rc = ioctl(driver, ISCSI_WAIT_EVENT, &evtp);
    928  1.1       agc #else
    929  1.1       agc 		rc = ioctl(driver, ISCSI_POLL_EVENT, &evtp);
    930  1.1       agc #endif
    931  1.1       agc 		if (rc || evtp.status)
    932  1.1       agc 			break;
    933  1.1       agc 
    934  1.1       agc 		DEB(1, ("Got Event: kind %d, status %d, sid %d, cid %d, reason %d\n",
    935  1.1       agc 				evtp.event_kind, evtp.status, evtp.session_id,
    936  1.1       agc 				evtp.connection_id, evtp.reason));
    937  1.1       agc 
    938  1.1       agc 		switch (evtp.event_kind) {
    939  1.1       agc 		case ISCSI_SESSION_TERMINATED:
    940  1.1       agc 			event_kill_session(evtp.session_id);
    941  1.1       agc 			break;
    942  1.1       agc 
    943  1.1       agc 		case ISCSI_CONNECTION_TERMINATED:
    944  1.1       agc 			event_kill_connection(evtp.session_id, evtp.connection_id);
    945  1.1       agc 			break;
    946  1.1       agc 
    947  1.1       agc 		case ISCSI_RECOVER_CONNECTION:
    948  1.1       agc 			event_recover_connection(evtp.session_id, evtp.connection_id);
    949  1.1       agc 			break;
    950  1.1       agc 
    951  1.1       agc 		default:
    952  1.1       agc 			break;
    953  1.1       agc 		}
    954  1.1       agc 	} while (evtp.event_kind != ISCSI_DRIVER_TERMINATING);
    955  1.1       agc 
    956  1.1       agc #ifdef ISCSI_NOTHREAD
    957  1.1       agc 	if (evtp.event_kind == ISCSI_DRIVER_TERMINATING)
    958  1.1       agc #endif
    959  1.1       agc 		exit_daemon();
    960  1.1       agc 
    961  1.1       agc 	return NULL;
    962  1.1       agc }
    963  1.1       agc 
    964  1.1       agc #if 0
    965  1.1       agc /*
    966  1.1       agc  * verify_connection:
    967  1.1       agc  *    Verify that a specific connection still exists, delete it if not.
    968  1.1       agc  *
    969  1.1       agc  * Parameter:  The connection pointer.
    970  1.1       agc  *
    971  1.1       agc  * Returns:    The status returned by the driver.
    972  1.1       agc  */
    973  1.1       agc 
    974  1.1       agc uint32_t
    975  1.1       agc verify_connection(connection_t * conn)
    976  1.1       agc {
    977  1.1       agc 	iscsi_conn_status_parameters_t req;
    978  1.1       agc 	session_t *sess = conn->session;
    979  1.1       agc 
    980  1.1       agc 	req.connection_id = conn->entry.sid.id;
    981  1.1       agc 	req.session_id = sess->entry.sid.id;
    982  1.1       agc 
    983  1.1       agc 	ioctl(driver, ISCSI_CONNECTION_STATUS, &req);
    984  1.1       agc 
    985  1.1       agc 	if (req.status) {
    986  1.1       agc 		TAILQ_REMOVE(&sess->connections, &conn->entry, link);
    987  1.1       agc 		sess->num_connections--;
    988  1.1       agc 		free(conn);
    989  1.1       agc 	}
    990  1.1       agc 	DEB(9, ("Verify connection returns status %d\n", req.status));
    991  1.1       agc 	return req.status;
    992  1.1       agc }
    993  1.1       agc 
    994  1.1       agc #endif
    995