Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/include/iscsi_err.h open-iscsi-2.0-872-rc4-bnx2i.build/include/iscsi_err.h
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/include/iscsi_err.h	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/include/iscsi_err.h	2011-08-14 16:56:54.000000000 -0500
Mike Christie 3949e1
@@ -58,6 +58,8 @@ enum {
Mike Christie 3949e1
 	ISCSI_ERR_ISNS_QUERY		= 25,
Mike Christie 3949e1
 	/* iSNS registration/deregistration failed */
Mike Christie 3949e1
 	ISCSI_ERR_ISNS_REG_FAILED	= 26,
Mike Christie 3949e1
+	/* Operation failed, but retrying layer may succeed */
Mike Christie 3949e1
+	ISCSI_ERR_AGAIN			= 27,
Mike Christie 3949e1
 
Mike Christie 3949e1
 	/* Always last. Indicates end of error code space */
Mike Christie 3949e1
 	ISCSI_MAX_ERR_VAL,
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/libiscsi/Makefile open-iscsi-2.0-872-rc4-bnx2i.build/libiscsi/Makefile
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/libiscsi/Makefile	2011-08-14 16:55:23.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/libiscsi/Makefile	2011-08-14 16:56:54.000000000 -0500
Mike Christie 3949e1
@@ -13,7 +13,7 @@ TESTS += tests/test_set_auth tests/test_
Mike Christie 3949e1
 
Mike Christie 3949e1
 COMMON_SRCS = sysdeps.o
Mike Christie 3949e1
 # sources shared between iscsid, iscsiadm and iscsistart
Mike Christie 3949e1
-ISCSI_LIB_SRCS = netlink.o transport.o cxgbi.o be2iscsi.o iscsi_timer.o initiator_common.o iscsi_err.o session_info.o iscsi_util.o dcb_app.o io.o auth.o discovery.o login.o log.o md5.o sha1.o iface.o idbm.o sysfs.o iscsi_sysfs.o iscsi_net_util.o iscsid_req.o
Mike Christie 3949e1
+ISCSI_LIB_SRCS = netlink.o uip_mgmt_ipc.o transport.o cxgbi.o be2iscsi.o iscsi_timer.o initiator_common.o iscsi_err.o session_info.o iscsi_util.o dcb_app.o io.o auth.o discovery.o login.o log.o md5.o sha1.o iface.o idbm.o sysfs.o iscsi_sysfs.o iscsi_net_util.o iscsid_req.o
Mike Christie 3949e1
 FW_PARAM_SRCS = fw_entry.o prom_lex.o prom_parse.tab.o fwparam_ppc.o fwparam_sysfs.o
5ebdd5
 
Mike Christie 3949e1
 # sources shared with the userspace utils, note we build these separately
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/initiator.c open-iscsi-2.0-872-rc4-bnx2i.build/usr/initiator.c
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/initiator.c	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/initiator.c	2011-08-14 16:56:54.000000000 -0500
5ebdd5
@@ -45,6 +45,7 @@
5ebdd5
 #include "iscsi_sysfs.h"
5ebdd5
 #include "iscsi_settings.h"
5ebdd5
 #include "iface.h"
5ebdd5
+#include "host.h"
5ebdd5
 #include "sysdeps.h"
Mike Christie 3949e1
 #include "iscsi_err.h"
5ebdd5
 
Mike Christie 3949e1
@@ -557,6 +558,48 @@ static int iscsi_conn_connect(struct isc
5ebdd5
 	return 0;
5ebdd5
 }
5ebdd5
 
Mike Christie 3949e1
+static void iscsi_uio_poll_login_timedout(void *data)
Mike Christie 3949e1
+{
Mike Christie 3949e1
+	struct queue_task *qtask = data;
Mike Christie 3949e1
+	struct iscsi_conn *conn = qtask->conn;
Mike Christie 3949e1
+	iscsi_session_t *session = conn->session;
Mike Christie 3949e1
+
Mike Christie 3949e1
+	log_debug(3, "timeout waiting for UIO ...\n");
Mike Christie 3949e1
+	mgmt_ipc_write_rsp(qtask, ISCSI_ERR_TRANS_TIMEOUT);
Mike Christie 3949e1
+	conn_delete_timers(conn);
Mike Christie 3949e1
+	__session_destroy(session);
Mike Christie 3949e1
+}
Mike Christie 3949e1
+
Mike Christie 3949e1
+static int iscsi_sched_uio_poll(queue_task_t *qtask)
Mike Christie 3949e1
+{
Mike Christie 3949e1
+	struct iscsi_conn *conn = qtask->conn;
Mike Christie 3949e1
+	struct iscsi_session *session = conn->session;
Mike Christie 3949e1
+	struct iscsi_transport *t = session->t;
Mike Christie 3949e1
+	struct iscsi_ev_context *ev_context;
Mike Christie 3949e1
+
Mike Christie 3949e1
+	if (!t->template->set_net_config)
Mike Christie 3949e1
+		return 0;
Mike Christie 3949e1
+
Mike Christie 3949e1
+	ev_context = iscsi_ev_context_get(conn, 0);
Mike Christie 3949e1
+	if (!ev_context) {
Mike Christie 3949e1
+		/* while reopening the recv pool should be full */
Mike Christie 3949e1
+		log_error("BUG: __session_conn_reopen could "
Mike Christie 3949e1
+			  "not get conn context for recv.");
Mike Christie 3949e1
+		return ENOMEM;
Mike Christie 3949e1
+	}
Mike Christie 3949e1
+
Mike Christie 3949e1
+	ev_context->data = qtask;
Mike Christie 3949e1
+	conn->state = ISCSI_CONN_STATE_XPT_WAIT;
Mike Christie 3949e1
+
Mike Christie 3949e1
+	iscsi_sched_ev_context(ev_context, conn, 0, EV_UIO_POLL);
Mike Christie 3949e1
+
Mike Christie 3949e1
+	log_debug(3, "Setting login UIO poll timer %p timeout %d",
Mike Christie 3949e1
+		  &conn->login_timer, conn->login_timeout);
Mike Christie 3949e1
+	actor_timer(&conn->login_timer, conn->login_timeout * 1000,
Mike Christie 3949e1
+		    iscsi_uio_poll_login_timedout, qtask);
Mike Christie 3949e1
+	return EAGAIN;
Mike Christie 3949e1
+}
Mike Christie 3949e1
+
Mike Christie 3949e1
 static void
Mike Christie 3949e1
 __session_conn_reopen(iscsi_conn_t *conn, queue_task_t *qtask, int do_stop,
Mike Christie 3949e1
 		      int redirected)
Mike Christie 3949e1
@@ -598,6 +641,11 @@ __session_conn_reopen(iscsi_conn_t *conn
Mike Christie 3949e1
 	if (!redirected)
Mike Christie 3949e1
 		session->reopen_cnt++;
Mike Christie 3949e1
 
Mike Christie 3949e1
+	/* uIP will needs to be re-triggered on the connection re-open */
Mike Christie 3949e1
+	if (iscsi_set_net_config(conn->session->t, conn->session,
Mike Christie 3949e1
+				 &conn->session->nrec.iface) != 0)
Mike Christie 3949e1
+		goto queue_reopen;
Mike Christie 3949e1
+
Mike Christie 3949e1
 	if (iscsi_conn_connect(conn, qtask)) {
Mike Christie 3949e1
 		delay = ISCSI_CONN_ERR_REOPEN_DELAY;
Mike Christie 3949e1
 		goto queue_reopen;
Mike Christie 3949e1
@@ -1659,6 +1707,53 @@ failed_login:
Mike Christie 3949e1
 
Mike Christie 3949e1
 }
Mike Christie 3949e1
 
Mike Christie 3949e1
+static void session_conn_uio_poll(void *data)
Mike Christie 3949e1
+{
Mike Christie 3949e1
+	struct iscsi_ev_context *ev_context = data;
Mike Christie 3949e1
+	iscsi_conn_t *conn = ev_context->conn;
Mike Christie 3949e1
+	struct iscsi_session *session = conn->session;
Mike Christie 3949e1
+	queue_task_t *qtask = ev_context->data;
Mike Christie 3949e1
+	int rc;
Mike Christie 3949e1
+
Mike Christie 3949e1
+	log_debug(4, "retrying uio poll");
Mike Christie 3949e1
+	rc = iscsi_set_net_config(session->t, session,
Mike Christie 3949e1
+				  &conn->session->nrec.iface);
Mike Christie 3949e1
+	if (rc != 0) {
Mike Christie 3949e1
+		if (rc == ISCSI_ERR_AGAIN) {
Mike Christie 3949e1
+			ev_context->data = qtask;
Mike Christie 3949e1
+			iscsi_sched_ev_context(ev_context, conn, 2,
Mike Christie 3949e1
+					       EV_UIO_POLL);
Mike Christie 3949e1
+			return;
Mike Christie 3949e1
+		} else {
Mike Christie 3949e1
+			log_error("session_conn_uio_poll() "
Mike Christie 3949e1
+				  "connection failure [0x%x]", rc);
Mike Christie 3949e1
+			actor_delete(&conn->login_timer);
Mike Christie 3949e1
+			iscsi_login_eh(conn, qtask, ISCSI_ERR_INTERNAL);
Mike Christie 3949e1
+			iscsi_ev_context_put(ev_context);
Mike Christie 3949e1
+			return;
Mike Christie 3949e1
+		}
Mike Christie 3949e1
+	}
Mike Christie 3949e1
+
Mike Christie 3949e1
+	iscsi_ev_context_put(ev_context);
Mike Christie 3949e1
+	actor_delete(&conn->login_timer);
Mike Christie 3949e1
+	log_debug(4, "UIO ready trying connect");
Mike Christie 3949e1
+
Mike Christie 3949e1
+	/*  uIP is ready try to connect */
Mike Christie 3949e1
+	if (gettimeofday(&conn->initial_connect_time, NULL))
Mike Christie 3949e1
+		log_error("Could not get initial connect time. If "
Mike Christie 3949e1
+			  "login errors iscsid may give up the initial "
Mike Christie 3949e1
+			  "login early. You should manually login.");
Mike Christie 3949e1
+
Mike Christie 3949e1
+	conn->state = ISCSI_CONN_STATE_XPT_WAIT;
Mike Christie 3949e1
+	if (iscsi_conn_connect(conn, qtask)) {
Mike Christie 3949e1
+		int delay = ISCSI_CONN_ERR_REOPEN_DELAY;
Mike Christie 3949e1
+
Mike Christie 3949e1
+		log_debug(4, "Waiting %u seconds before trying to reconnect.\n",
Mike Christie 3949e1
+			  delay);
Mike Christie 3949e1
+		queue_delayed_reopen(qtask, delay);
Mike Christie 3949e1
+	}
Mike Christie 3949e1
+}
Mike Christie 3949e1
+
Mike Christie 3949e1
 static int iscsi_sched_ev_context(struct iscsi_ev_context *ev_context,
Mike Christie 3949e1
 				  struct iscsi_conn *conn, unsigned long tmo,
Mike Christie 3949e1
 				  int event)
Mike Christie 3949e1
@@ -1700,6 +1795,11 @@ static int iscsi_sched_ev_context(struct
Mike Christie 3949e1
 			  ev_context);
Mike Christie 3949e1
 		actor_schedule(&ev_context->actor);
Mike Christie 3949e1
 		break;
Mike Christie 3949e1
+	case EV_UIO_POLL:
Mike Christie 3949e1
+		actor_new(&ev_context->actor, session_conn_uio_poll,
Mike Christie 3949e1
+			  ev_context);
Mike Christie 3949e1
+		actor_schedule(&ev_context->actor);
Mike Christie 3949e1
+		break;
Mike Christie 3949e1
 	case EV_CONN_LOGOUT_TIMER:
Mike Christie 3949e1
 		actor_timer(&ev_context->actor, tmo * 1000,
Mike Christie 3949e1
 			    iscsi_logout_timedout, ev_context);
Mike Christie 3949e1
@@ -1833,7 +1933,17 @@ session_login_task(node_rec_t *rec, queu
Mike Christie 3949e1
 	conn = &session->conn[0];
Mike Christie 3949e1
 	qtask->conn = conn;
Mike Christie 3949e1
 
Mike Christie 3949e1
-	if (iscsi_host_set_net_params(&rec->iface, session)) {
Mike Christie 3949e1
+	rc = iscsi_host_set_net_params(&rec->iface, session);
Mike Christie 3949e1
+	if (rc == ISCSI_ERR_AGAIN) {
Mike Christie 3949e1
+		iscsi_sched_uio_poll(qtask);
Mike Christie 3949e1
+		/*
Mike Christie 3949e1
+		 * Cannot block iscsid, so caller is going to internally
Mike Christie 3949e1
+		 * retry the operation.
Mike Christie 3949e1
+		 */
Mike Christie 3949e1
+		qtask->rsp.command = MGMT_IPC_SESSION_LOGIN;
Mike Christie 3949e1
+		qtask->rsp.err = ISCSI_SUCCESS;
Mike Christie 3949e1
+		return ISCSI_SUCCESS;
Mike Christie 3949e1
+	} else if (rc) {
Mike Christie 3949e1
 		__session_destroy(session);
Mike Christie 3949e1
 		return ISCSI_ERR_LOGIN;
Mike Christie 3949e1
 	}
Mike Christie 3949e1
@@ -1990,6 +2100,7 @@ iscsi_host_send_targets(queue_task_t *qt
Mike Christie 3949e1
 			struct sockaddr_storage *ss)
Mike Christie 3949e1
 {
Mike Christie 3949e1
 	struct iscsi_transport *t;
Mike Christie 3949e1
+	int rc;
Mike Christie 3949e1
 
Mike Christie 3949e1
 	t = iscsi_sysfs_get_transport_by_hba(host_no);
Mike Christie 3949e1
 	if (!t) {
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/initiator_common.c open-iscsi-2.0-872-rc4-bnx2i.build/usr/initiator_common.c
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/initiator_common.c	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/initiator_common.c	2011-08-14 16:56:54.000000000 -0500
Mike Christie 3949e1
@@ -561,6 +561,36 @@ TODO handle this
Mike Christie 3949e1
 	return 0;
Mike Christie 3949e1
 }
Mike Christie 3949e1
 
Mike Christie 3949e1
+int iscsi_set_net_config(struct iscsi_transport *t, iscsi_session_t *session,
Mike Christie 3949e1
+			 struct iface_rec *iface)
5ebdd5
+{
5ebdd5
+	if (t->template->set_net_config) {
5ebdd5
+		/* uip needs the netdev name */
5ebdd5
+		struct host_info hinfo;
5ebdd5
+		int hostno, rc;
5ebdd5
+
5ebdd5
+		/* this assumes that the netdev or hw address is going to be
5ebdd5
+		   set */
5ebdd5
+		hostno = iscsi_sysfs_get_host_no_from_hwinfo(iface, &rc);
5ebdd5
+		if (rc) {
5ebdd5
+			log_debug(4, "Couldn't get host no.\n");
5ebdd5
+			return rc;
5ebdd5
+		}
5ebdd5
+
5ebdd5
+		/* uip needs the netdev name */
5ebdd5
+		if (!strlen(iface->netdev)) {
5ebdd5
+			memset(&hinfo, 0, sizeof(hinfo));
5ebdd5
+			hinfo.host_no = hostno;
5ebdd5
+			iscsi_sysfs_get_hostinfo_by_host_no(&hinfo);
5ebdd5
+			strcpy(iface->netdev, hinfo.iface.netdev);
5ebdd5
+		}
5ebdd5
+
5ebdd5
+		return t->template->set_net_config(t, iface, session);
5ebdd5
+	}
5ebdd5
+
5ebdd5
+	return 0;
5ebdd5
+}
5ebdd5
+
Mike Christie 3949e1
 int iscsi_host_set_net_params(struct iface_rec *iface,
Mike Christie 3949e1
 			      struct iscsi_session *session)
Mike Christie 3949e1
 {
Mike Christie 3949e1
@@ -582,6 +612,10 @@ int iscsi_host_set_net_params(struct ifa
5ebdd5
 		return EINVAL;
5ebdd5
 	}
5ebdd5
 
Mike Christie 3949e1
+	rc = iscsi_set_net_config(t, session, iface);
5ebdd5
+	if (rc != 0)
5ebdd5
+		return rc;
5ebdd5
+
Mike Christie 3949e1
 	rc = host_set_param(t, session->hostno,
Mike Christie 3949e1
 			    ISCSI_HOST_PARAM_IPADDRESS,
Mike Christie 3949e1
 			    iface->ipaddress, ISCSI_STRING);
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/initiator.h open-iscsi-2.0-872-rc4-bnx2i.build/usr/initiator.h
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/initiator.h	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/initiator.h	2011-08-14 16:58:14.000000000 -0500
Mike Christie 3949e1
@@ -83,6 +83,7 @@ typedef enum iscsi_event_e {
Mike Christie 3949e1
 	EV_CONN_LOGOUT_TIMER,
Mike Christie 3949e1
 	EV_CONN_STOP,
Mike Christie 3949e1
 	EV_CONN_LOGIN,
Mike Christie 3949e1
+	EV_UIO_POLL,
Mike Christie 3949e1
 } iscsi_event_e;
Mike Christie 3949e1
 
Mike Christie 3949e1
 struct queue_task;
Mike Christie 3949e1
@@ -353,5 +354,8 @@ extern void iscsi_copy_operational_param
Mike Christie 3949e1
 extern int iscsi_setup_authentication(struct iscsi_session *session,
Mike Christie 3949e1
 				      struct iscsi_auth_config *auth_cfg);
Mike Christie 3949e1
 extern int iscsi_setup_portal(struct iscsi_conn *conn, char *address, int port);
Mike Christie 3949e1
+extern int iscsi_set_net_config(struct iscsi_transport *t,
Mike Christie 3949e1
+				iscsi_session_t *session,
Mike Christie 3949e1
+				struct iface_rec *iface);
Mike Christie 3949e1
 
Mike Christie 3949e1
 #endif /* INITIATOR_H */
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/iscsid_req.c open-iscsi-2.0-872-rc4-bnx2i.build/usr/iscsid_req.c
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/iscsid_req.c	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/iscsid_req.c	2011-08-14 16:56:54.000000000 -0500
5ebdd5
@@ -22,6 +22,7 @@
5ebdd5
 #include <stdlib.h>
5ebdd5
 #include <string.h>
5ebdd5
 #include <errno.h>
5ebdd5
+#include <fcntl.h>
5ebdd5
 #include <sys un.h="">
5ebdd5
 #include <sys types.h="">
5ebdd5
 #include <sys socket.h="">
Mike Christie 3949e1
@@ -32,6 +33,7 @@
5ebdd5
 #include "iscsi_util.h"
5ebdd5
 #include "config.h"
Mike Christie 3949e1
 #include "iscsi_err.h"
5ebdd5
+#include "uip_mgmt_ipc.h"
5ebdd5
 
5ebdd5
 static void iscsid_startup(void)
5ebdd5
 {
Mike Christie 3949e1
@@ -54,7 +56,7 @@ static void iscsid_startup(void)
5ebdd5
 
5ebdd5
 #define MAXSLEEP 128
5ebdd5
 
Mike Christie 3949e1
-static int iscsid_connect(int *fd, int start_iscsid)
Mike Christie 3949e1
+static int ipc_connect(int *fd, char *unix_sock_name, int start_iscsid)
5ebdd5
 {
5ebdd5
 	int nsec;
5ebdd5
 	struct sockaddr_un addr;
Mike Christie 3949e1
@@ -67,8 +69,8 @@ static int iscsid_connect(int *fd, int s
5ebdd5
 
5ebdd5
 	memset(&addr, 0, sizeof(addr));
5ebdd5
 	addr.sun_family = AF_LOCAL;
5ebdd5
-	memcpy((char *) &addr.sun_path + 1, ISCSIADM_NAMESPACE,
5ebdd5
-		strlen(ISCSIADM_NAMESPACE));
5ebdd5
+	memcpy((char *) &addr.sun_path + 1, unix_sock_name,
5ebdd5
+		strlen(unix_sock_name));
5ebdd5
 	/*
5ebdd5
 	 * Trying to connect with exponential backoff
5ebdd5
 	 */
Mike Christie 3949e1
@@ -96,6 +98,11 @@ static int iscsid_connect(int *fd, int s
Mike Christie 3949e1
 	return ISCSI_ERR_ISCSID_NOTCONN;
5ebdd5
 }
5ebdd5
 
Mike Christie 3949e1
+static int iscsid_connect(int *fd, int start_iscsid)
5ebdd5
+{
Mike Christie 3949e1
+	return ipc_connect(fd, ISCSIADM_NAMESPACE, start_iscsid);
5ebdd5
+}
5ebdd5
+
Mike Christie 3949e1
 int iscsid_request(int *fd, iscsiadm_req_t *req, int start_iscsid)
5ebdd5
 {
5ebdd5
 	int err;
Mike Christie 3949e1
@@ -192,3 +199,81 @@ int iscsid_req_by_sid(iscsiadm_cmd_e cmd
Mike Christie 3949e1
 		return err;
5ebdd5
 	return iscsid_req_wait(cmd, fd);
5ebdd5
 }
Mike Christie 3949e1
+
Mike Christie 3949e1
+static int uip_connect(int *fd)
5ebdd5
+{
5ebdd5
+	return ipc_connect(fd, ISCSID_UIP_NAMESPACE, 0);
5ebdd5
+}
5ebdd5
+
5ebdd5
+int uip_broadcast(void *buf, size_t buf_len)
5ebdd5
+{
5ebdd5
+	int err;
5ebdd5
+	int fd;
5ebdd5
+	iscsid_uip_rsp_t rsp;
5ebdd5
+	int flags;
5ebdd5
+	int count;
5ebdd5
+
5ebdd5
+	err = uip_connect(&fd);
5ebdd5
+	if (err) {
5ebdd5
+		log_warning("uIP daemon is not up");
5ebdd5
+		return err;
5ebdd5
+	}
5ebdd5
+
Mike Christie 3949e1
+	log_debug(3, "connected to uIP daemon");
Mike Christie 3949e1
+
5ebdd5
+	/*  Send the data to uIP */
5ebdd5
+	if ((err = write(fd, buf, buf_len)) != buf_len) {
5ebdd5
+		log_error("got write error (%d/%d), daemon died?",
Mike Christie 3949e1
+			  err, errno);
5ebdd5
+		close(fd);
Mike Christie 3949e1
+		return ISCSI_ERR_ISCSID_COMM_ERR;
5ebdd5
+	}
5ebdd5
+
Mike Christie 3949e1
+	log_debug(3, "send iface config to uIP daemon");
Mike Christie 3949e1
+
5ebdd5
+	/*  Set the socket to a non-blocking read, this way if there are
5ebdd5
+	 *  problems waiting for uIP, iscsid can bailout early */
5ebdd5
+	flags = fcntl(fd, F_GETFL, 0);
5ebdd5
+	if (flags == -1)
Mike Christie 3949e1
+		flags = 0;
5ebdd5
+	err = fcntl(fd, F_SETFL, flags | O_NONBLOCK);
5ebdd5
+	if(err != 0) {
5ebdd5
+		log_error("could not set uip broadcast to non-blocking: %d",
5ebdd5
+			  errno);
5ebdd5
+		close(fd);
Mike Christie 3949e1
+		return ISCSI_ERR;
5ebdd5
+	}
5ebdd5
+
5ebdd5
+#define MAX_UIP_BROADCAST_READ_TRIES 3
5ebdd5
+	for(count = 0; count < MAX_UIP_BROADCAST_READ_TRIES; count++) {
5ebdd5
+		/*  Wait for the response */
5ebdd5
+		err = read(fd, &rsp, sizeof(rsp));
5ebdd5
+		if (err == sizeof(rsp)) {
Mike Christie 3949e1
+			log_debug(3, "Broadcasted to uIP with length: %ld "
Mike Christie 3949e1
+				     "cmd: 0x%x rsp: 0x%x\n", buf_len,
Mike Christie 3949e1
+				     rsp.command, rsp.err);
Mike Christie 3949e1
+			err = 0;
5ebdd5
+			break;
5ebdd5
+		} else if((err == -1) && (errno == EAGAIN)) {
5ebdd5
+			usleep(250000);
5ebdd5
+			continue;
5ebdd5
+		} else {
5ebdd5
+			log_error("Could not read response (%d/%d), daemon died?",
5ebdd5
+				  err, errno);
Mike Christie 3949e1
+			err = ISCSI_ERR;
5ebdd5
+			break;
5ebdd5
+		}
5ebdd5
+	}
5ebdd5
+
Mike Christie 3949e1
+	if (count == MAX_UIP_BROADCAST_READ_TRIES) {
Mike Christie 3949e1
+		log_error("Could not broadcast to uIP after %d tries",
Mike Christie 3949e1
+			  count);
Mike Christie 3949e1
+		err = ISCSI_ERR_AGAIN;
Mike Christie 3949e1
+	} else if (rsp.err != ISCISD_UIP_MGMT_IPC_DEVICE_UP) {
Mike Christie 3949e1
+		log_debug(3, "Device is not ready\n");
Mike Christie 3949e1
+		err = ISCSI_ERR_AGAIN;
Mike Christie 3949e1
+	}
5ebdd5
+
5ebdd5
+	close(fd);
Mike Christie 3949e1
+	return err;
5ebdd5
+}
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/iscsid_req.h open-iscsi-2.0-872-rc4-bnx2i.build/usr/iscsid_req.h
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/iscsid_req.h	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/iscsid_req.h	2011-08-14 16:56:54.000000000 -0500
Mike Christie 3949e1
@@ -33,4 +33,6 @@ extern int iscsid_req_by_rec(int cmd, st
5ebdd5
 extern int iscsid_req_by_sid_async(int cmd, int sid, int *fd);
5ebdd5
 extern int iscsid_req_by_sid(int cmd, int sid);
5ebdd5
 
5ebdd5
+extern int uip_broadcast(void *buf, size_t buf_len);
5ebdd5
+
5ebdd5
 #endif
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/iscsi_err.c open-iscsi-2.0-872-rc4-bnx2i.build/usr/iscsi_err.c
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/iscsi_err.c	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/iscsi_err.c	2011-08-14 16:56:54.000000000 -0500
Mike Christie 3949e1
@@ -49,6 +49,7 @@ static char *iscsi_err_msgs[] = {
Mike Christie 3949e1
 	/* 24 */ "iSCSI login failed due to authorization failure",
Mike Christie 3949e1
 	/* 25 */ "iSNS query failed",
Mike Christie 3949e1
 	/* 26 */ "iSNS registration failed",
Mike Christie 3949e1
+	/* 27 */ "Retryable failure",
Mike Christie 3949e1
 };
Mike Christie 3949e1
 
Mike Christie 3949e1
 char *iscsi_err_to_str(int err)
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/Makefile open-iscsi-2.0-872-rc4-bnx2i.build/usr/Makefile
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/Makefile	2011-08-14 16:55:23.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/Makefile	2011-08-14 16:58:57.000000000 -0500
Mike Christie 3949e1
@@ -42,7 +42,8 @@ SYSDEPS_SRCS = $(wildcard ../utils/sysde
Mike Christie 3949e1
 ISCSI_LIB_SRCS = iscsi_util.o io.o auth.o iscsi_timer.o login.o log.o md5.o \
Mike Christie 3949e1
 	sha1.o iface.o idbm.o sysfs.o host.o session_info.o iscsi_sysfs.o \
Mike Christie 3949e1
 	iscsi_net_util.o iscsid_req.o transport.o cxgbi.o be2iscsi.o \
Mike Christie 3949e1
-	initiator_common.o iscsi_err.o $(IPC_OBJ)  $(SYSDEPS_SRCS) $(DCB_OBJ)
Mike Christie 3949e1
+	initiator_common.o iscsi_err.o uip_mgmt_ipc.o \
Mike Christie 3949e1
+	$(IPC_OBJ)  $(SYSDEPS_SRCS) $(DCB_OBJ)
Mike Christie 3949e1
 # core initiator files
Mike Christie 3949e1
 INITIATOR_SRCS = initiator.o scsi.o actor.o event_poll.o mgmt_ipc.o
Mike Christie 3949e1
 
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/transport.c open-iscsi-2.0-872-rc4-bnx2i.build/usr/transport.c
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/transport.c	2011-08-14 16:49:44.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/transport.c	2011-08-14 16:56:54.000000000 -0500
5ebdd5
@@ -25,6 +25,7 @@
5ebdd5
 #include "log.h"
5ebdd5
 #include "iscsi_util.h"
5ebdd5
 #include "iscsi_sysfs.h"
5ebdd5
+#include "uip_mgmt_ipc.h"
Mike Christie 3949e1
 #include "cxgbi.h"
5ebdd5
 #include "be2iscsi.h"
5ebdd5
 
Mike Christie 3949e1
@@ -67,6 +68,7 @@ struct iscsi_transport_template bnx2i = 
5ebdd5
 	.ep_connect	= ktransport_ep_connect,
5ebdd5
 	.ep_poll	= ktransport_ep_poll,
5ebdd5
 	.ep_disconnect	= ktransport_ep_disconnect,
5ebdd5
+	.set_net_config = uip_broadcast_params,
5ebdd5
 };
5ebdd5
 
5ebdd5
 struct iscsi_transport_template be2iscsi = {
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/transport.h open-iscsi-2.0-872-rc4-bnx2i.build/usr/transport.h
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/transport.h	2011-08-14 16:49:34.000000000 -0500
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/transport.h	2011-08-14 16:56:54.000000000 -0500
5ebdd5
@@ -35,6 +35,9 @@ struct iscsi_transport_template {
5ebdd5
 	int (*ep_poll) (struct iscsi_conn *conn, int timeout_ms);
5ebdd5
 	void (*ep_disconnect) (struct iscsi_conn *conn);
5ebdd5
 	void (*create_conn) (struct iscsi_conn *conn);
5ebdd5
+	int (*set_net_config) (struct iscsi_transport *t,
5ebdd5
+			       struct iface_rec *iface,
5ebdd5
+			       struct iscsi_session *session);
5ebdd5
 };
5ebdd5
 
5ebdd5
 /* represents data path provider */
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/uip_mgmt_ipc.c open-iscsi-2.0-872-rc4-bnx2i.build/usr/uip_mgmt_ipc.c
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/uip_mgmt_ipc.c	1969-12-31 18:00:00.000000000 -0600
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/uip_mgmt_ipc.c	2011-08-14 16:56:54.000000000 -0500
5ebdd5
@@ -0,0 +1,41 @@
5ebdd5
+/*
5ebdd5
+ * uIP iSCSI Daemon/Admin Management IPC
5ebdd5
+ *
5ebdd5
+ * This program is free software; you can redistribute it and/or modify
5ebdd5
+ * it under the terms of the GNU General Public License as published
5ebdd5
+ * by the Free Software Foundation; either version 2 of the License, or
5ebdd5
+ * (at your option) any later version.
5ebdd5
+ *
5ebdd5
+ * This program is distributed in the hope that it will be useful, but
5ebdd5
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
5ebdd5
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
5ebdd5
+ * General Public License for more details.
5ebdd5
+ *
5ebdd5
+ * See the file COPYING included with this distribution for more details.
5ebdd5
+ */
5ebdd5
+
5ebdd5
+#include <string.h>
5ebdd5
+
5ebdd5
+#include "log.h"
5ebdd5
+#include "uip_mgmt_ipc.h"
5ebdd5
+#include "iscsid_req.h"
5ebdd5
+
5ebdd5
+int uip_broadcast_params(struct iscsi_transport *t,
5ebdd5
+			 struct iface_rec *iface,
5ebdd5
+			 struct iscsi_session *session)
5ebdd5
+{
5ebdd5
+	struct iscsid_uip_broadcast broadcast;
5ebdd5
+
5ebdd5
+        log_debug(3, "broadcasting to uip\n");
5ebdd5
+
5ebdd5
+	memset(&broadcast, 0, sizeof(broadcast));
5ebdd5
+
5ebdd5
+	broadcast.header.command = ISCSID_UIP_IPC_GET_IFACE;
5ebdd5
+	broadcast.header.payload_len = sizeof(*iface);
5ebdd5
+
5ebdd5
+	memcpy(&broadcast.u.iface_rec, iface, sizeof(*iface));
5ebdd5
+
5ebdd5
+	return uip_broadcast(&broadcast,
5ebdd5
+			     sizeof(iscsid_uip_broadcast_header_t) +
5ebdd5
+			     sizeof(*iface));
5ebdd5
+}
Mike Christie 3949e1
diff -Naurp open-iscsi-2.0-872-rc4-bnx2i.base/usr/uip_mgmt_ipc.h open-iscsi-2.0-872-rc4-bnx2i.build/usr/uip_mgmt_ipc.h
Mike Christie 3949e1
--- open-iscsi-2.0-872-rc4-bnx2i.base/usr/uip_mgmt_ipc.h	1969-12-31 18:00:00.000000000 -0600
Mike Christie 3949e1
+++ open-iscsi-2.0-872-rc4-bnx2i.build/usr/uip_mgmt_ipc.h	2011-08-14 16:56:54.000000000 -0500
Mike Christie 3949e1
@@ -0,0 +1,73 @@
5ebdd5
+/*
5ebdd5
+ * uIP iSCSI Daemon/Admin Management IPC
5ebdd5
+ *
5ebdd5
+ * This program is free software; you can redistribute it and/or modify
5ebdd5
+ * it under the terms of the GNU General Public License as published
5ebdd5
+ * by the Free Software Foundation; either version 2 of the License, or
5ebdd5
+ * (at your option) any later version.
5ebdd5
+ *
5ebdd5
+ * This program is distributed in the hope that it will be useful, but
5ebdd5
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
5ebdd5
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
5ebdd5
+ * General Public License for more details.
5ebdd5
+ *
5ebdd5
+ * See the file COPYING included with this distribution for more details.
5ebdd5
+ */
5ebdd5
+#ifndef UIP_MGMT_IPC_H
5ebdd5
+#define UIP_MGMT_IPC_H
5ebdd5
+
5ebdd5
+#include "types.h"
5ebdd5
+#include "iscsi_if.h"
5ebdd5
+#include "config.h"
5ebdd5
+#include "mgmt_ipc.h"
5ebdd5
+
5ebdd5
+#include "initiator.h"
5ebdd5
+#include "transport.h"
5ebdd5
+
5ebdd5
+#define ISCSID_UIP_NAMESPACE	"ISCSID_UIP_ABSTRACT_NAMESPACE"
5ebdd5
+
5ebdd5
+typedef enum iscsid_uip_cmd {
5ebdd5
+	ISCSID_UIP_IPC_UNKNOWN			= 0,
5ebdd5
+	ISCSID_UIP_IPC_GET_IFACE		= 1,
5ebdd5
+
5ebdd5
+        __ISCSID_UIP_IPC_MAX_COMMAND
5ebdd5
+} iscsid_uip_cmd_e;
5ebdd5
+
5ebdd5
+typedef struct iscsid_uip_broadcast_header {
5ebdd5
+	iscsid_uip_cmd_e command;
5ebdd5
+	uint32_t payload_len;
5ebdd5
+} iscsid_uip_broadcast_header_t;
5ebdd5
+
5ebdd5
+/* IPC Request */
5ebdd5
+typedef struct iscsid_uip_broadcast {
5ebdd5
+	struct iscsid_uip_broadcast_header header;
5ebdd5
+
5ebdd5
+	union {
5ebdd5
+		/* messages */
5ebdd5
+		struct ipc_broadcast_iface_rec {
5ebdd5
+			struct iface_rec rec;
5ebdd5
+		} iface_rec;
5ebdd5
+	} u;
5ebdd5
+} iscsid_uip_broadcast_t;
5ebdd5
+
5ebdd5
+typedef enum iscsid_uip_mgmt_ipc_err {
5ebdd5
+	ISCSID_UIP_MGMT_IPC_OK                     = 0,
5ebdd5
+        ISCISD_UIP_MGMT_IPC_ERR                    = 1,
5ebdd5
+        ISCISD_UIP_MGMT_IPC_ERR_NOT_FOUND          = 2,
5ebdd5
+        ISCISD_UIP_MGMT_IPC_ERR_NOMEM              = 3,
Mike Christie 3949e1
+	ISCISD_UIP_MGMT_IPC_DEVICE_UP              = 4,
Mike Christie 3949e1
+	ISCISD_UIP_MGMT_IPC_DEVICE_INITIALIZING    = 5,
5ebdd5
+} iscsid_uip_mgmt_ipc_err_e;
5ebdd5
+
5ebdd5
+/* IPC Response */
5ebdd5
+typedef struct iscsid_uip_mgmt_rsp {
5ebdd5
+	iscsid_uip_cmd_e command;
5ebdd5
+	iscsid_uip_mgmt_ipc_err_e err;
5ebdd5
+} iscsid_uip_rsp_t;
5ebdd5
+
5ebdd5
+extern int uip_broadcast_params(struct iscsi_transport *t,
5ebdd5
+				struct iface_rec *iface,
5ebdd5
+				struct iscsi_session *session);
5ebdd5
+
5ebdd5
+
5ebdd5
+#endif /* UIP_MGMT_IPC_H */