165e7ae7bSOr Gerlitz /*
265e7ae7bSOr Gerlitz  * iSCSI Initiator over iSER Data-Path
365e7ae7bSOr Gerlitz  *
465e7ae7bSOr Gerlitz  * Copyright (C) 2004 Dmitry Yusupov
565e7ae7bSOr Gerlitz  * Copyright (C) 2004 Alex Aizman
665e7ae7bSOr Gerlitz  * Copyright (C) 2005 Mike Christie
765e7ae7bSOr Gerlitz  * Copyright (c) 2005, 2006 Voltaire, Inc. All rights reserved.
865e7ae7bSOr Gerlitz  * maintained by openib-general@openib.org
965e7ae7bSOr Gerlitz  *
1065e7ae7bSOr Gerlitz  * This software is available to you under a choice of one of two
1165e7ae7bSOr Gerlitz  * licenses.  You may choose to be licensed under the terms of the GNU
1265e7ae7bSOr Gerlitz  * General Public License (GPL) Version 2, available from the file
1365e7ae7bSOr Gerlitz  * COPYING in the main directory of this source tree, or the
1465e7ae7bSOr Gerlitz  * OpenIB.org BSD license below:
1565e7ae7bSOr Gerlitz  *
1665e7ae7bSOr Gerlitz  *     Redistribution and use in source and binary forms, with or
1765e7ae7bSOr Gerlitz  *     without modification, are permitted provided that the following
1865e7ae7bSOr Gerlitz  *     conditions are met:
1965e7ae7bSOr Gerlitz  *
2065e7ae7bSOr Gerlitz  *	- Redistributions of source code must retain the above
2165e7ae7bSOr Gerlitz  *	  copyright notice, this list of conditions and the following
2265e7ae7bSOr Gerlitz  *	  disclaimer.
2365e7ae7bSOr Gerlitz  *
2465e7ae7bSOr Gerlitz  *	- Redistributions in binary form must reproduce the above
2565e7ae7bSOr Gerlitz  *	  copyright notice, this list of conditions and the following
2665e7ae7bSOr Gerlitz  *	  disclaimer in the documentation and/or other materials
2765e7ae7bSOr Gerlitz  *	  provided with the distribution.
2865e7ae7bSOr Gerlitz  *
2965e7ae7bSOr Gerlitz  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
3065e7ae7bSOr Gerlitz  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
3165e7ae7bSOr Gerlitz  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
3265e7ae7bSOr Gerlitz  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
3365e7ae7bSOr Gerlitz  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
3465e7ae7bSOr Gerlitz  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
3565e7ae7bSOr Gerlitz  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
3665e7ae7bSOr Gerlitz  * SOFTWARE.
3765e7ae7bSOr Gerlitz  *
3865e7ae7bSOr Gerlitz  * Credits:
3965e7ae7bSOr Gerlitz  *	Christoph Hellwig
4065e7ae7bSOr Gerlitz  *	FUJITA Tomonori
4165e7ae7bSOr Gerlitz  *	Arne Redlich
4265e7ae7bSOr Gerlitz  *	Zhenyu Wang
4365e7ae7bSOr Gerlitz  * Modified by:
4465e7ae7bSOr Gerlitz  *      Erez Zilber
4565e7ae7bSOr Gerlitz  */
4665e7ae7bSOr Gerlitz 
4765e7ae7bSOr Gerlitz #include <linux/types.h>
4865e7ae7bSOr Gerlitz #include <linux/list.h>
4965e7ae7bSOr Gerlitz #include <linux/hardirq.h>
5065e7ae7bSOr Gerlitz #include <linux/kfifo.h>
5165e7ae7bSOr Gerlitz #include <linux/blkdev.h>
5265e7ae7bSOr Gerlitz #include <linux/init.h>
5365e7ae7bSOr Gerlitz #include <linux/ioctl.h>
5465e7ae7bSOr Gerlitz #include <linux/cdev.h>
5565e7ae7bSOr Gerlitz #include <linux/in.h>
5665e7ae7bSOr Gerlitz #include <linux/net.h>
5765e7ae7bSOr Gerlitz #include <linux/scatterlist.h>
5865e7ae7bSOr Gerlitz #include <linux/delay.h>
5965e7ae7bSOr Gerlitz 
6065e7ae7bSOr Gerlitz #include <net/sock.h>
6165e7ae7bSOr Gerlitz 
6265e7ae7bSOr Gerlitz #include <asm/uaccess.h>
6365e7ae7bSOr Gerlitz 
6465e7ae7bSOr Gerlitz #include <scsi/scsi_cmnd.h>
6565e7ae7bSOr Gerlitz #include <scsi/scsi_device.h>
6665e7ae7bSOr Gerlitz #include <scsi/scsi_eh.h>
6765e7ae7bSOr Gerlitz #include <scsi/scsi_tcq.h>
6865e7ae7bSOr Gerlitz #include <scsi/scsi_host.h>
6965e7ae7bSOr Gerlitz #include <scsi/scsi.h>
7065e7ae7bSOr Gerlitz #include <scsi/scsi_transport_iscsi.h>
7165e7ae7bSOr Gerlitz 
7265e7ae7bSOr Gerlitz #include "iscsi_iser.h"
7365e7ae7bSOr Gerlitz 
7475613521SMike Christie static struct scsi_host_template iscsi_iser_sht;
7575613521SMike Christie static struct iscsi_transport iscsi_iser_transport;
7675613521SMike Christie static struct scsi_transport_template *iscsi_iser_scsi_transport;
7775613521SMike Christie 
7865e7ae7bSOr Gerlitz static unsigned int iscsi_max_lun = 512;
7965e7ae7bSOr Gerlitz module_param_named(max_lun, iscsi_max_lun, uint, S_IRUGO);
8065e7ae7bSOr Gerlitz 
8165e7ae7bSOr Gerlitz int iser_debug_level = 0;
8265e7ae7bSOr Gerlitz 
8365e7ae7bSOr Gerlitz MODULE_DESCRIPTION("iSER (iSCSI Extensions for RDMA) Datamover "
8465e7ae7bSOr Gerlitz 		   "v" DRV_VER " (" DRV_DATE ")");
8565e7ae7bSOr Gerlitz MODULE_LICENSE("Dual BSD/GPL");
8665e7ae7bSOr Gerlitz MODULE_AUTHOR("Alex Nezhinsky, Dan Bar Dov, Or Gerlitz");
8765e7ae7bSOr Gerlitz 
8865e7ae7bSOr Gerlitz module_param_named(debug_level, iser_debug_level, int, 0644);
8965e7ae7bSOr Gerlitz MODULE_PARM_DESC(debug_level, "Enable debug tracing if > 0 (default:disabled)");
9065e7ae7bSOr Gerlitz 
9165e7ae7bSOr Gerlitz struct iser_global ig;
9265e7ae7bSOr Gerlitz 
9365e7ae7bSOr Gerlitz void
9465e7ae7bSOr Gerlitz iscsi_iser_recv(struct iscsi_conn *conn,
9565e7ae7bSOr Gerlitz 		struct iscsi_hdr *hdr, char *rx_data, int rx_data_len)
9665e7ae7bSOr Gerlitz {
9765e7ae7bSOr Gerlitz 	int rc = 0;
9865e7ae7bSOr Gerlitz 	int datalen;
9965e7ae7bSOr Gerlitz 	int ahslen;
10065e7ae7bSOr Gerlitz 
10165e7ae7bSOr Gerlitz 	/* verify PDU length */
10265e7ae7bSOr Gerlitz 	datalen = ntoh24(hdr->dlength);
10365e7ae7bSOr Gerlitz 	if (datalen != rx_data_len) {
10465e7ae7bSOr Gerlitz 		printk(KERN_ERR "iscsi_iser: datalen %d (hdr) != %d (IB) \n",
10565e7ae7bSOr Gerlitz 		       datalen, rx_data_len);
10665e7ae7bSOr Gerlitz 		rc = ISCSI_ERR_DATALEN;
10765e7ae7bSOr Gerlitz 		goto error;
10865e7ae7bSOr Gerlitz 	}
10965e7ae7bSOr Gerlitz 
11065e7ae7bSOr Gerlitz 	/* read AHS */
11165e7ae7bSOr Gerlitz 	ahslen = hdr->hlength * 4;
11265e7ae7bSOr Gerlitz 
11365e7ae7bSOr Gerlitz 	rc = iscsi_complete_pdu(conn, hdr, rx_data, rx_data_len);
11465e7ae7bSOr Gerlitz 	if (rc && rc != ISCSI_ERR_NO_SCSI_CMD)
11565e7ae7bSOr Gerlitz 		goto error;
11665e7ae7bSOr Gerlitz 
11765e7ae7bSOr Gerlitz 	return;
11865e7ae7bSOr Gerlitz error:
11965e7ae7bSOr Gerlitz 	iscsi_conn_failure(conn, rc);
12065e7ae7bSOr Gerlitz }
12165e7ae7bSOr Gerlitz 
1222ff79d52SMike Christie static int iscsi_iser_pdu_alloc(struct iscsi_task *task, uint8_t opcode)
1230f9c7449SMike Christie {
1240f9c7449SMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
1250f9c7449SMike Christie 
1260f9c7449SMike Christie 	task->hdr = (struct iscsi_hdr *)&iser_task->desc.iscsi_header;
1270f9c7449SMike Christie 	task->hdr_max = sizeof(iser_task->desc.iscsi_header);
1280f9c7449SMike Christie 	return 0;
1290f9c7449SMike Christie }
13065e7ae7bSOr Gerlitz 
13165e7ae7bSOr Gerlitz /**
1322261ec3dSMike Christie  * iscsi_iser_task_init - Initialize task
1332261ec3dSMike Christie  * @task: iscsi task
13465e7ae7bSOr Gerlitz  *
1352261ec3dSMike Christie  * Initialize the task for the scsi command or mgmt command.
1362747fdb2SMike Christie  */
137a8ac6311SOlaf Kirch static int
1382261ec3dSMike Christie iscsi_iser_task_init(struct iscsi_task *task)
13965e7ae7bSOr Gerlitz {
1402261ec3dSMike Christie 	struct iscsi_iser_conn *iser_conn  = task->conn->dd_data;
1412261ec3dSMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
14265e7ae7bSOr Gerlitz 
1432261ec3dSMike Christie 	/* mgmt task */
1442261ec3dSMike Christie 	if (!task->sc) {
1452261ec3dSMike Christie 		iser_task->desc.data = task->data;
1462747fdb2SMike Christie 		return 0;
1472747fdb2SMike Christie 	}
1482747fdb2SMike Christie 
1492261ec3dSMike Christie 	iser_task->command_sent = 0;
1502261ec3dSMike Christie 	iser_task->iser_conn    = iser_conn;
1512261ec3dSMike Christie 	iser_task_rdma_init(iser_task);
152a8ac6311SOlaf Kirch 	return 0;
15365e7ae7bSOr Gerlitz }
15465e7ae7bSOr Gerlitz 
15565e7ae7bSOr Gerlitz /**
1562261ec3dSMike Christie  * iscsi_iser_mtask_xmit - xmit management(immediate) task
15765e7ae7bSOr Gerlitz  * @conn: iscsi connection
1582261ec3dSMike Christie  * @task: task management task
15965e7ae7bSOr Gerlitz  *
16065e7ae7bSOr Gerlitz  * Notes:
16165e7ae7bSOr Gerlitz  *	The function can return -EAGAIN in which case caller must
16265e7ae7bSOr Gerlitz  *	call it again later, or recover. '0' return code means successful
16365e7ae7bSOr Gerlitz  *	xmit.
16465e7ae7bSOr Gerlitz  *
16565e7ae7bSOr Gerlitz  **/
16665e7ae7bSOr Gerlitz static int
1672261ec3dSMike Christie iscsi_iser_mtask_xmit(struct iscsi_conn *conn, struct iscsi_task *task)
16865e7ae7bSOr Gerlitz {
16965e7ae7bSOr Gerlitz 	int error = 0;
17065e7ae7bSOr Gerlitz 
17148a237a2SMike Christie 	iser_dbg("task deq [cid %d itt 0x%x]\n", conn->id, task->itt);
17265e7ae7bSOr Gerlitz 
1732261ec3dSMike Christie 	error = iser_send_control(conn, task);
17465e7ae7bSOr Gerlitz 
1752261ec3dSMike Christie 	/* since iser xmits control with zero copy, tasks can not be recycled
17665e7ae7bSOr Gerlitz 	 * right after sending them.
17765e7ae7bSOr Gerlitz 	 * The recycling scheme is based on whether a response is expected
1782261ec3dSMike Christie 	 * - if yes, the task is recycled at iscsi_complete_pdu
1792261ec3dSMike Christie 	 * - if no,  the task is recycled at iser_snd_completion
18065e7ae7bSOr Gerlitz 	 */
181f0938401SErez Zilber 	if (error && error != -ENOBUFS)
18265e7ae7bSOr Gerlitz 		iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED);
18365e7ae7bSOr Gerlitz 
18465e7ae7bSOr Gerlitz 	return error;
18565e7ae7bSOr Gerlitz }
18665e7ae7bSOr Gerlitz 
18765e7ae7bSOr Gerlitz static int
1882747fdb2SMike Christie iscsi_iser_task_xmit_unsol_data(struct iscsi_conn *conn,
1892261ec3dSMike Christie 				 struct iscsi_task *task)
19065e7ae7bSOr Gerlitz {
1910f9c7449SMike Christie 	struct iscsi_r2t_info *r2t = &task->unsol_r2t;
19265e7ae7bSOr Gerlitz 	struct iscsi_data hdr;
19365e7ae7bSOr Gerlitz 	int error = 0;
19465e7ae7bSOr Gerlitz 
19565e7ae7bSOr Gerlitz 	/* Send data-out PDUs while there's still unsolicited data to send */
1960f9c7449SMike Christie 	while (iscsi_task_has_unsol_data(task)) {
1970f9c7449SMike Christie 		iscsi_prep_data_out_pdu(task, r2t, &hdr);
19848a237a2SMike Christie 		iser_dbg("Sending data-out: itt 0x%x, data count %d\n",
1990f9c7449SMike Christie 			   hdr.itt, r2t->data_count);
20065e7ae7bSOr Gerlitz 
20165e7ae7bSOr Gerlitz 		/* the buffer description has been passed with the command */
20265e7ae7bSOr Gerlitz 		/* Send the command */
2032261ec3dSMike Christie 		error = iser_send_data_out(conn, task, &hdr);
20465e7ae7bSOr Gerlitz 		if (error) {
2050f9c7449SMike Christie 			r2t->datasn--;
2062747fdb2SMike Christie 			goto iscsi_iser_task_xmit_unsol_data_exit;
20765e7ae7bSOr Gerlitz 		}
2080f9c7449SMike Christie 		r2t->sent += r2t->data_count;
20948a237a2SMike Christie 		iser_dbg("Need to send %d more as data-out PDUs\n",
2100f9c7449SMike Christie 			   r2t->data_length - r2t->sent);
21165e7ae7bSOr Gerlitz 	}
21265e7ae7bSOr Gerlitz 
2132747fdb2SMike Christie iscsi_iser_task_xmit_unsol_data_exit:
21465e7ae7bSOr Gerlitz 	return error;
21565e7ae7bSOr Gerlitz }
21665e7ae7bSOr Gerlitz 
21765e7ae7bSOr Gerlitz static int
2182261ec3dSMike Christie iscsi_iser_task_xmit(struct iscsi_task *task)
21965e7ae7bSOr Gerlitz {
2202261ec3dSMike Christie 	struct iscsi_conn *conn = task->conn;
2212261ec3dSMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
22265e7ae7bSOr Gerlitz 	int error = 0;
22365e7ae7bSOr Gerlitz 
2242261ec3dSMike Christie 	if (!task->sc)
2252261ec3dSMike Christie 		return iscsi_iser_mtask_xmit(conn, task);
2262747fdb2SMike Christie 
2272261ec3dSMike Christie 	if (task->sc->sc_data_direction == DMA_TO_DEVICE) {
2282261ec3dSMike Christie 		BUG_ON(scsi_bufflen(task->sc) == 0);
22977a23c21SMike Christie 
23048a237a2SMike Christie 		iser_dbg("cmd [itt %x total %d imm %d unsol_data %d\n",
2312261ec3dSMike Christie 			   task->itt, scsi_bufflen(task->sc),
2320f9c7449SMike Christie 			   task->imm_count, task->unsol_r2t.data_length);
23377a23c21SMike Christie 	}
23477a23c21SMike Christie 
23548a237a2SMike Christie 	iser_dbg("task deq [cid %d itt 0x%x]\n",
2362261ec3dSMike Christie 		   conn->id, task->itt);
23765e7ae7bSOr Gerlitz 
23865e7ae7bSOr Gerlitz 	/* Send the cmd PDU */
2392261ec3dSMike Christie 	if (!iser_task->command_sent) {
2402261ec3dSMike Christie 		error = iser_send_command(conn, task);
24165e7ae7bSOr Gerlitz 		if (error)
2422747fdb2SMike Christie 			goto iscsi_iser_task_xmit_exit;
2432261ec3dSMike Christie 		iser_task->command_sent = 1;
24465e7ae7bSOr Gerlitz 	}
24565e7ae7bSOr Gerlitz 
24665e7ae7bSOr Gerlitz 	/* Send unsolicited data-out PDU(s) if necessary */
2470f9c7449SMike Christie 	if (iscsi_task_has_unsol_data(task))
2482261ec3dSMike Christie 		error = iscsi_iser_task_xmit_unsol_data(conn, task);
24965e7ae7bSOr Gerlitz 
2502747fdb2SMike Christie  iscsi_iser_task_xmit_exit:
251f0938401SErez Zilber 	if (error && error != -ENOBUFS)
25265e7ae7bSOr Gerlitz 		iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED);
25365e7ae7bSOr Gerlitz 	return error;
25465e7ae7bSOr Gerlitz }
25565e7ae7bSOr Gerlitz 
2560f9c7449SMike Christie static void iscsi_iser_cleanup_task(struct iscsi_task *task)
25765e7ae7bSOr Gerlitz {
2582261ec3dSMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
25965e7ae7bSOr Gerlitz 
2600f9c7449SMike Christie 	/*
2610f9c7449SMike Christie 	 * mgmt tasks do not need special cleanup and we do not
2620f9c7449SMike Christie 	 * allocate anything in the init task callout
2630f9c7449SMike Christie 	 */
2640f9c7449SMike Christie 	if (!task->sc || task->state == ISCSI_TASK_PENDING)
2652747fdb2SMike Christie 		return;
26665e7ae7bSOr Gerlitz 
2672261ec3dSMike Christie 	if (iser_task->status == ISER_TASK_STATUS_STARTED) {
2682261ec3dSMike Christie 		iser_task->status = ISER_TASK_STATUS_COMPLETED;
2692261ec3dSMike Christie 		iser_task_rdma_finalize(iser_task);
27065e7ae7bSOr Gerlitz 	}
27165e7ae7bSOr Gerlitz }
27265e7ae7bSOr Gerlitz 
27365e7ae7bSOr Gerlitz static struct iscsi_cls_conn *
27465e7ae7bSOr Gerlitz iscsi_iser_conn_create(struct iscsi_cls_session *cls_session, uint32_t conn_idx)
27565e7ae7bSOr Gerlitz {
27665e7ae7bSOr Gerlitz 	struct iscsi_conn *conn;
27765e7ae7bSOr Gerlitz 	struct iscsi_cls_conn *cls_conn;
27865e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
27965e7ae7bSOr Gerlitz 
2805d91e209SMike Christie 	cls_conn = iscsi_conn_setup(cls_session, sizeof(*iser_conn), conn_idx);
28165e7ae7bSOr Gerlitz 	if (!cls_conn)
28265e7ae7bSOr Gerlitz 		return NULL;
28365e7ae7bSOr Gerlitz 	conn = cls_conn->dd_data;
28465e7ae7bSOr Gerlitz 
28565e7ae7bSOr Gerlitz 	/*
28665e7ae7bSOr Gerlitz 	 * due to issues with the login code re iser sematics
28765e7ae7bSOr Gerlitz 	 * this not set in iscsi_conn_setup - FIXME
28865e7ae7bSOr Gerlitz 	 */
28965e7ae7bSOr Gerlitz 	conn->max_recv_dlength = 128;
29065e7ae7bSOr Gerlitz 
2915d91e209SMike Christie 	iser_conn = conn->dd_data;
29265e7ae7bSOr Gerlitz 	conn->dd_data = iser_conn;
29365e7ae7bSOr Gerlitz 	iser_conn->iscsi_conn = conn;
29465e7ae7bSOr Gerlitz 
29565e7ae7bSOr Gerlitz 	return cls_conn;
29665e7ae7bSOr Gerlitz }
29765e7ae7bSOr Gerlitz 
29865e7ae7bSOr Gerlitz static void
29965e7ae7bSOr Gerlitz iscsi_iser_conn_destroy(struct iscsi_cls_conn *cls_conn)
30065e7ae7bSOr Gerlitz {
30165e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
30265e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
303b40977d9SMike Christie 	struct iser_conn *ib_conn = iser_conn->ib_conn;
30465e7ae7bSOr Gerlitz 
30565e7ae7bSOr Gerlitz 	iscsi_conn_teardown(cls_conn);
306b40977d9SMike Christie 	/*
307b40977d9SMike Christie 	 * Userspace will normally call the stop callback and
308b40977d9SMike Christie 	 * already have freed the ib_conn, but if it goofed up then
309b40977d9SMike Christie 	 * we free it here.
310b40977d9SMike Christie 	 */
311b40977d9SMike Christie 	if (ib_conn) {
312b40977d9SMike Christie 		ib_conn->iser_conn = NULL;
313b40977d9SMike Christie 		iser_conn_put(ib_conn);
314b40977d9SMike Christie 	}
31565e7ae7bSOr Gerlitz }
31665e7ae7bSOr Gerlitz 
31765e7ae7bSOr Gerlitz static int
31865e7ae7bSOr Gerlitz iscsi_iser_conn_bind(struct iscsi_cls_session *cls_session,
31965e7ae7bSOr Gerlitz 		     struct iscsi_cls_conn *cls_conn, uint64_t transport_eph,
32065e7ae7bSOr Gerlitz 		     int is_leading)
32165e7ae7bSOr Gerlitz {
32265e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
32365e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
32465e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
325412eeafaSMike Christie 	struct iscsi_endpoint *ep;
32665e7ae7bSOr Gerlitz 	int error;
32765e7ae7bSOr Gerlitz 
32865e7ae7bSOr Gerlitz 	error = iscsi_conn_bind(cls_session, cls_conn, is_leading);
32965e7ae7bSOr Gerlitz 	if (error)
33065e7ae7bSOr Gerlitz 		return error;
33165e7ae7bSOr Gerlitz 
33265e7ae7bSOr Gerlitz 	/* the transport ep handle comes from user space so it must be
33365e7ae7bSOr Gerlitz 	 * verified against the global ib connections list */
334412eeafaSMike Christie 	ep = iscsi_lookup_endpoint(transport_eph);
335412eeafaSMike Christie 	if (!ep) {
33665e7ae7bSOr Gerlitz 		iser_err("can't bind eph %llx\n",
33765e7ae7bSOr Gerlitz 			 (unsigned long long)transport_eph);
33865e7ae7bSOr Gerlitz 		return -EINVAL;
33965e7ae7bSOr Gerlitz 	}
340412eeafaSMike Christie 	ib_conn = ep->dd_data;
341412eeafaSMike Christie 
34265e7ae7bSOr Gerlitz 	/* binds the iSER connection retrieved from the previously
34365e7ae7bSOr Gerlitz 	 * connected ep_handle to the iSCSI layer connection. exchanges
34465e7ae7bSOr Gerlitz 	 * connection pointers */
34565e7ae7bSOr Gerlitz 	iser_err("binding iscsi conn %p to iser_conn %p\n",conn,ib_conn);
34665e7ae7bSOr Gerlitz 	iser_conn = conn->dd_data;
34765e7ae7bSOr Gerlitz 	ib_conn->iser_conn = iser_conn;
34865e7ae7bSOr Gerlitz 	iser_conn->ib_conn  = ib_conn;
349b40977d9SMike Christie 	iser_conn_get(ib_conn);
35065e7ae7bSOr Gerlitz 	return 0;
35165e7ae7bSOr Gerlitz }
35265e7ae7bSOr Gerlitz 
353b40977d9SMike Christie static void
354b40977d9SMike Christie iscsi_iser_conn_stop(struct iscsi_cls_conn *cls_conn, int flag)
355b40977d9SMike Christie {
356b40977d9SMike Christie 	struct iscsi_conn *conn = cls_conn->dd_data;
357b40977d9SMike Christie 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
358b40977d9SMike Christie 	struct iser_conn *ib_conn = iser_conn->ib_conn;
359b40977d9SMike Christie 
360913e5bf4SMike Christie 	/*
361913e5bf4SMike Christie 	 * Userspace may have goofed up and not bound the connection or
362913e5bf4SMike Christie 	 * might have only partially setup the connection.
363913e5bf4SMike Christie 	 */
364913e5bf4SMike Christie 	if (ib_conn) {
365b40977d9SMike Christie 		iscsi_conn_stop(cls_conn, flag);
366b40977d9SMike Christie 		/*
367b40977d9SMike Christie 		 * There is no unbind event so the stop callback
368b40977d9SMike Christie 		 * must release the ref from the bind.
369b40977d9SMike Christie 		 */
370b40977d9SMike Christie 		iser_conn_put(ib_conn);
371913e5bf4SMike Christie 	}
372b40977d9SMike Christie 	iser_conn->ib_conn = NULL;
373b40977d9SMike Christie }
374b40977d9SMike Christie 
37565e7ae7bSOr Gerlitz static int
37665e7ae7bSOr Gerlitz iscsi_iser_conn_start(struct iscsi_cls_conn *cls_conn)
37765e7ae7bSOr Gerlitz {
37865e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
37965e7ae7bSOr Gerlitz 	int err;
38065e7ae7bSOr Gerlitz 
3812e7a7426SErez Zilber 	err = iser_conn_set_full_featured_mode(conn);
38265e7ae7bSOr Gerlitz 	if (err)
38365e7ae7bSOr Gerlitz 		return err;
38465e7ae7bSOr Gerlitz 
3852e7a7426SErez Zilber 	return iscsi_conn_start(cls_conn);
38665e7ae7bSOr Gerlitz }
38765e7ae7bSOr Gerlitz 
38875613521SMike Christie static void iscsi_iser_session_destroy(struct iscsi_cls_session *cls_session)
38975613521SMike Christie {
39075613521SMike Christie 	struct Scsi_Host *shost = iscsi_session_to_shost(cls_session);
39175613521SMike Christie 
392e5bd7b54SMike Christie 	iscsi_session_teardown(cls_session);
393a4804cd6SMike Christie 	iscsi_host_remove(shost);
394a4804cd6SMike Christie 	iscsi_host_free(shost);
39575613521SMike Christie }
39665e7ae7bSOr Gerlitz 
39765e7ae7bSOr Gerlitz static struct iscsi_cls_session *
398412eeafaSMike Christie iscsi_iser_session_create(struct iscsi_endpoint *ep,
3991548271eSMike Christie 			  uint16_t cmds_max, uint16_t qdepth,
40065e7ae7bSOr Gerlitz 			  uint32_t initial_cmdsn, uint32_t *hostno)
40165e7ae7bSOr Gerlitz {
40265e7ae7bSOr Gerlitz 	struct iscsi_cls_session *cls_session;
40365e7ae7bSOr Gerlitz 	struct iscsi_session *session;
404412eeafaSMike Christie 	struct Scsi_Host *shost;
405412eeafaSMike Christie 	struct iser_conn *ib_conn;
40675613521SMike Christie 
407a4804cd6SMike Christie 	shost = iscsi_host_alloc(&iscsi_iser_sht, 0, ISCSI_MAX_CMD_PER_LUN);
40875613521SMike Christie 	if (!shost)
40975613521SMike Christie 		return NULL;
41075613521SMike Christie 	shost->transportt = iscsi_iser_scsi_transport;
41175613521SMike Christie 	shost->max_lun = iscsi_max_lun;
41275613521SMike Christie 	shost->max_id = 0;
41375613521SMike Christie 	shost->max_channel = 0;
41475613521SMike Christie 	shost->max_cmd_len = 16;
41575613521SMike Christie 
416412eeafaSMike Christie 	/*
417412eeafaSMike Christie 	 * older userspace tools (before 2.0-870) did not pass us
418412eeafaSMike Christie 	 * the leading conn's ep so this will be NULL;
419412eeafaSMike Christie 	 */
420412eeafaSMike Christie 	if (ep)
421412eeafaSMike Christie 		ib_conn = ep->dd_data;
422412eeafaSMike Christie 
423412eeafaSMike Christie 	if (iscsi_host_add(shost,
424412eeafaSMike Christie 			   ep ? ib_conn->device->ib_device->dma_device : NULL))
42575613521SMike Christie 		goto free_host;
42675613521SMike Christie 	*hostno = shost->host_no;
42765e7ae7bSOr Gerlitz 
4281548271eSMike Christie 	/*
4291548271eSMike Christie 	 * we do not support setting can_queue cmd_per_lun from userspace yet
4301548271eSMike Christie 	 * because we preallocate so many resources
4311548271eSMike Christie 	 */
43275613521SMike Christie 	cls_session = iscsi_session_setup(&iscsi_iser_transport, shost,
4331548271eSMike Christie 					  ISCSI_DEF_XMIT_CMDS_MAX,
4342261ec3dSMike Christie 					  sizeof(struct iscsi_iser_task),
4357970634bSMike Christie 					  initial_cmdsn, 0);
43665e7ae7bSOr Gerlitz 	if (!cls_session)
43775613521SMike Christie 		goto remove_host;
43875613521SMike Christie 	session = cls_session->dd_data;
43965e7ae7bSOr Gerlitz 
4402747fdb2SMike Christie 	shost->can_queue = session->scsi_cmds_max;
44165e7ae7bSOr Gerlitz 	return cls_session;
44275613521SMike Christie 
44375613521SMike Christie remove_host:
444a4804cd6SMike Christie 	iscsi_host_remove(shost);
44575613521SMike Christie free_host:
446a4804cd6SMike Christie 	iscsi_host_free(shost);
44775613521SMike Christie 	return NULL;
44865e7ae7bSOr Gerlitz }
44965e7ae7bSOr Gerlitz 
45065e7ae7bSOr Gerlitz static int
451358ff019SMike Christie iscsi_iser_set_param(struct iscsi_cls_conn *cls_conn,
452358ff019SMike Christie 		     enum iscsi_param param, char *buf, int buflen)
45365e7ae7bSOr Gerlitz {
454358ff019SMike Christie 	int value;
45565e7ae7bSOr Gerlitz 
45665e7ae7bSOr Gerlitz 	switch (param) {
45765e7ae7bSOr Gerlitz 	case ISCSI_PARAM_MAX_RECV_DLENGTH:
45865e7ae7bSOr Gerlitz 		/* TBD */
45965e7ae7bSOr Gerlitz 		break;
46065e7ae7bSOr Gerlitz 	case ISCSI_PARAM_HDRDGST_EN:
461358ff019SMike Christie 		sscanf(buf, "%d", &value);
46265e7ae7bSOr Gerlitz 		if (value) {
46365e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
46465e7ae7bSOr Gerlitz 			return -EPROTO;
46565e7ae7bSOr Gerlitz 		}
46665e7ae7bSOr Gerlitz 		break;
46765e7ae7bSOr Gerlitz 	case ISCSI_PARAM_DATADGST_EN:
468358ff019SMike Christie 		sscanf(buf, "%d", &value);
46965e7ae7bSOr Gerlitz 		if (value) {
47065e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
47165e7ae7bSOr Gerlitz 			return -EPROTO;
47265e7ae7bSOr Gerlitz 		}
47365e7ae7bSOr Gerlitz 		break;
47465e7ae7bSOr Gerlitz 	case ISCSI_PARAM_IFMARKER_EN:
475358ff019SMike Christie 		sscanf(buf, "%d", &value);
47665e7ae7bSOr Gerlitz 		if (value) {
47765e7ae7bSOr Gerlitz 			printk(KERN_ERR "IFMarker wasn't negotiated to No");
47865e7ae7bSOr Gerlitz 			return -EPROTO;
47965e7ae7bSOr Gerlitz 		}
48065e7ae7bSOr Gerlitz 		break;
48165e7ae7bSOr Gerlitz 	case ISCSI_PARAM_OFMARKER_EN:
482358ff019SMike Christie 		sscanf(buf, "%d", &value);
48365e7ae7bSOr Gerlitz 		if (value) {
48465e7ae7bSOr Gerlitz 			printk(KERN_ERR "OFMarker wasn't negotiated to No");
48565e7ae7bSOr Gerlitz 			return -EPROTO;
48665e7ae7bSOr Gerlitz 		}
48765e7ae7bSOr Gerlitz 		break;
48865e7ae7bSOr Gerlitz 	default:
489358ff019SMike Christie 		return iscsi_set_param(cls_conn, param, buf, buflen);
49065e7ae7bSOr Gerlitz 	}
49165e7ae7bSOr Gerlitz 
49265e7ae7bSOr Gerlitz 	return 0;
49365e7ae7bSOr Gerlitz }
49465e7ae7bSOr Gerlitz 
49565e7ae7bSOr Gerlitz static void
49665e7ae7bSOr Gerlitz iscsi_iser_conn_get_stats(struct iscsi_cls_conn *cls_conn, struct iscsi_stats *stats)
49765e7ae7bSOr Gerlitz {
49865e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
49965e7ae7bSOr Gerlitz 
50065e7ae7bSOr Gerlitz 	stats->txdata_octets = conn->txdata_octets;
50165e7ae7bSOr Gerlitz 	stats->rxdata_octets = conn->rxdata_octets;
50265e7ae7bSOr Gerlitz 	stats->scsicmd_pdus = conn->scsicmd_pdus_cnt;
50365e7ae7bSOr Gerlitz 	stats->dataout_pdus = conn->dataout_pdus_cnt;
50465e7ae7bSOr Gerlitz 	stats->scsirsp_pdus = conn->scsirsp_pdus_cnt;
50565e7ae7bSOr Gerlitz 	stats->datain_pdus = conn->datain_pdus_cnt; /* always 0 */
50665e7ae7bSOr Gerlitz 	stats->r2t_pdus = conn->r2t_pdus_cnt; /* always 0 */
50765e7ae7bSOr Gerlitz 	stats->tmfcmd_pdus = conn->tmfcmd_pdus_cnt;
50865e7ae7bSOr Gerlitz 	stats->tmfrsp_pdus = conn->tmfrsp_pdus_cnt;
50987528227SEli Dorfman 	stats->custom_length = 4;
51065e7ae7bSOr Gerlitz 	strcpy(stats->custom[0].desc, "qp_tx_queue_full");
51165e7ae7bSOr Gerlitz 	stats->custom[0].value = 0; /* TB iser_conn->qp_tx_queue_full; */
51265e7ae7bSOr Gerlitz 	strcpy(stats->custom[1].desc, "fmr_map_not_avail");
51365e7ae7bSOr Gerlitz 	stats->custom[1].value = 0; /* TB iser_conn->fmr_map_not_avail */;
51465e7ae7bSOr Gerlitz 	strcpy(stats->custom[2].desc, "eh_abort_cnt");
51565e7ae7bSOr Gerlitz 	stats->custom[2].value = conn->eh_abort_cnt;
51687528227SEli Dorfman 	strcpy(stats->custom[3].desc, "fmr_unalign_cnt");
51787528227SEli Dorfman 	stats->custom[3].value = conn->fmr_unalign_cnt;
51865e7ae7bSOr Gerlitz }
51965e7ae7bSOr Gerlitz 
520412eeafaSMike Christie static struct iscsi_endpoint *
521412eeafaSMike Christie iscsi_iser_ep_connect(struct sockaddr *dst_addr, int non_blocking)
52265e7ae7bSOr Gerlitz {
52365e7ae7bSOr Gerlitz 	int err;
52465e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
525412eeafaSMike Christie 	struct iscsi_endpoint *ep;
52665e7ae7bSOr Gerlitz 
527412eeafaSMike Christie 	ep = iscsi_create_endpoint(sizeof(*ib_conn));
528412eeafaSMike Christie 	if (!ep)
529412eeafaSMike Christie 		return ERR_PTR(-ENOMEM);
53065e7ae7bSOr Gerlitz 
531412eeafaSMike Christie 	ib_conn = ep->dd_data;
532412eeafaSMike Christie 	ib_conn->ep = ep;
533412eeafaSMike Christie 	iser_conn_init(ib_conn);
53465e7ae7bSOr Gerlitz 
535412eeafaSMike Christie 	err = iser_connect(ib_conn, NULL, (struct sockaddr_in *)dst_addr,
536412eeafaSMike Christie 			   non_blocking);
537412eeafaSMike Christie 	if (err) {
538412eeafaSMike Christie 		iscsi_destroy_endpoint(ep);
539412eeafaSMike Christie 		return ERR_PTR(err);
540412eeafaSMike Christie 	}
541412eeafaSMike Christie 	return ep;
54265e7ae7bSOr Gerlitz }
54365e7ae7bSOr Gerlitz 
54465e7ae7bSOr Gerlitz static int
545412eeafaSMike Christie iscsi_iser_ep_poll(struct iscsi_endpoint *ep, int timeout_ms)
54665e7ae7bSOr Gerlitz {
547412eeafaSMike Christie 	struct iser_conn *ib_conn;
54865e7ae7bSOr Gerlitz 	int rc;
54965e7ae7bSOr Gerlitz 
550412eeafaSMike Christie 	ib_conn = ep->dd_data;
55165e7ae7bSOr Gerlitz 	rc = wait_event_interruptible_timeout(ib_conn->wait,
55265e7ae7bSOr Gerlitz 			     ib_conn->state == ISER_CONN_UP,
55365e7ae7bSOr Gerlitz 			     msecs_to_jiffies(timeout_ms));
55465e7ae7bSOr Gerlitz 
55565e7ae7bSOr Gerlitz 	/* if conn establishment failed, return error code to iscsi */
55665e7ae7bSOr Gerlitz 	if (!rc &&
55765e7ae7bSOr Gerlitz 	    (ib_conn->state == ISER_CONN_TERMINATING ||
55865e7ae7bSOr Gerlitz 	     ib_conn->state == ISER_CONN_DOWN))
55965e7ae7bSOr Gerlitz 		rc = -1;
56065e7ae7bSOr Gerlitz 
56165e7ae7bSOr Gerlitz 	iser_err("ib conn %p rc = %d\n", ib_conn, rc);
56265e7ae7bSOr Gerlitz 
56365e7ae7bSOr Gerlitz 	if (rc > 0)
56465e7ae7bSOr Gerlitz 		return 1; /* success, this is the equivalent of POLLOUT */
56565e7ae7bSOr Gerlitz 	else if (!rc)
56665e7ae7bSOr Gerlitz 		return 0; /* timeout */
56765e7ae7bSOr Gerlitz 	else
56865e7ae7bSOr Gerlitz 		return rc; /* signal */
56965e7ae7bSOr Gerlitz }
57065e7ae7bSOr Gerlitz 
57165e7ae7bSOr Gerlitz static void
572412eeafaSMike Christie iscsi_iser_ep_disconnect(struct iscsi_endpoint *ep)
57365e7ae7bSOr Gerlitz {
5741c83469dSMike Christie 	struct iser_conn *ib_conn;
57565e7ae7bSOr Gerlitz 
576412eeafaSMike Christie 	ib_conn = ep->dd_data;
577b40977d9SMike Christie 	if (ib_conn->iser_conn)
578b40977d9SMike Christie 		/*
579b40977d9SMike Christie 		 * Must suspend xmit path if the ep is bound to the
580b40977d9SMike Christie 		 * iscsi_conn, so we know we are not accessing the ib_conn
581b40977d9SMike Christie 		 * when we free it.
582b40977d9SMike Christie 		 *
583b40977d9SMike Christie 		 * This may not be bound if the ep poll failed.
584b40977d9SMike Christie 		 */
585b40977d9SMike Christie 		iscsi_suspend_tx(ib_conn->iser_conn->iscsi_conn);
586b40977d9SMike Christie 
58765e7ae7bSOr Gerlitz 
58865e7ae7bSOr Gerlitz 	iser_err("ib conn %p state %d\n",ib_conn, ib_conn->state);
58965e7ae7bSOr Gerlitz 	iser_conn_terminate(ib_conn);
59065e7ae7bSOr Gerlitz }
59165e7ae7bSOr Gerlitz 
59265e7ae7bSOr Gerlitz static struct scsi_host_template iscsi_iser_sht = {
5937974392cSMike Christie 	.module                 = THIS_MODULE,
59465e7ae7bSOr Gerlitz 	.name                   = "iSCSI Initiator over iSER, v." DRV_VER,
59565e7ae7bSOr Gerlitz 	.queuecommand           = iscsi_queuecommand,
5966410627eSErez Zilber 	.change_queue_depth	= iscsi_change_queue_depth,
59765e7ae7bSOr Gerlitz 	.sg_tablesize           = ISCSI_ISER_SG_TABLESIZE,
5988072ec2fSErez Zilber 	.max_sectors		= 1024,
59965e7ae7bSOr Gerlitz 	.cmd_per_lun            = ISCSI_MAX_CMD_PER_LUN,
60065e7ae7bSOr Gerlitz 	.eh_abort_handler       = iscsi_eh_abort,
60190c18f3cSErez Zilber 	.eh_device_reset_handler= iscsi_eh_device_reset,
6028e124525SMike Christie 	.eh_target_reset_handler= iscsi_eh_target_reset,
60365e7ae7bSOr Gerlitz 	.use_clustering         = DISABLE_CLUSTERING,
60465e7ae7bSOr Gerlitz 	.proc_name              = "iscsi_iser",
60565e7ae7bSOr Gerlitz 	.this_id                = -1,
60665e7ae7bSOr Gerlitz };
60765e7ae7bSOr Gerlitz 
60865e7ae7bSOr Gerlitz static struct iscsi_transport iscsi_iser_transport = {
60965e7ae7bSOr Gerlitz 	.owner                  = THIS_MODULE,
61065e7ae7bSOr Gerlitz 	.name                   = "iser",
61165e7ae7bSOr Gerlitz 	.caps                   = CAP_RECOVERY_L0 | CAP_MULTI_R2T,
61265e7ae7bSOr Gerlitz 	.param_mask		= ISCSI_MAX_RECV_DLENGTH |
61365e7ae7bSOr Gerlitz 				  ISCSI_MAX_XMIT_DLENGTH |
61465e7ae7bSOr Gerlitz 				  ISCSI_HDRDGST_EN |
61565e7ae7bSOr Gerlitz 				  ISCSI_DATADGST_EN |
61665e7ae7bSOr Gerlitz 				  ISCSI_INITIAL_R2T_EN |
61765e7ae7bSOr Gerlitz 				  ISCSI_MAX_R2T |
61865e7ae7bSOr Gerlitz 				  ISCSI_IMM_DATA_EN |
61965e7ae7bSOr Gerlitz 				  ISCSI_FIRST_BURST |
62065e7ae7bSOr Gerlitz 				  ISCSI_MAX_BURST |
62165e7ae7bSOr Gerlitz 				  ISCSI_PDU_INORDER_EN |
622358ff019SMike Christie 				  ISCSI_DATASEQ_INORDER_EN |
623358ff019SMike Christie 				  ISCSI_EXP_STATSN |
624358ff019SMike Christie 				  ISCSI_PERSISTENT_PORT |
625358ff019SMike Christie 				  ISCSI_PERSISTENT_ADDRESS |
626b2c64167SMike Christie 				  ISCSI_TARGET_NAME | ISCSI_TPGT |
627b2c64167SMike Christie 				  ISCSI_USERNAME | ISCSI_PASSWORD |
628f6d5180cSMike Christie 				  ISCSI_USERNAME_IN | ISCSI_PASSWORD_IN |
629f6d5180cSMike Christie 				  ISCSI_FAST_ABORT | ISCSI_ABORT_TMO |
63088dfd340SMike Christie 				  ISCSI_PING_TMO | ISCSI_RECV_TMO |
63188dfd340SMike Christie 				  ISCSI_IFACE_NAME | ISCSI_INITIATOR_NAME,
6328ad5781aSMike Christie 	.host_param_mask	= ISCSI_HOST_HWADDRESS |
633d8196ed2SMike Christie 				  ISCSI_HOST_NETDEV_NAME |
6348ad5781aSMike Christie 				  ISCSI_HOST_INITIATOR_NAME,
63565e7ae7bSOr Gerlitz 	/* session management */
63665e7ae7bSOr Gerlitz 	.create_session         = iscsi_iser_session_create,
63775613521SMike Christie 	.destroy_session        = iscsi_iser_session_destroy,
63865e7ae7bSOr Gerlitz 	/* connection management */
63965e7ae7bSOr Gerlitz 	.create_conn            = iscsi_iser_conn_create,
64065e7ae7bSOr Gerlitz 	.bind_conn              = iscsi_iser_conn_bind,
64165e7ae7bSOr Gerlitz 	.destroy_conn           = iscsi_iser_conn_destroy,
642358ff019SMike Christie 	.set_param              = iscsi_iser_set_param,
643358ff019SMike Christie 	.get_conn_param		= iscsi_conn_get_param,
644358ff019SMike Christie 	.get_session_param	= iscsi_session_get_param,
64565e7ae7bSOr Gerlitz 	.start_conn             = iscsi_iser_conn_start,
646b40977d9SMike Christie 	.stop_conn              = iscsi_iser_conn_stop,
6470801c242SMike Christie 	/* iscsi host params */
6480801c242SMike Christie 	.get_host_param		= iscsi_host_get_param,
6490801c242SMike Christie 	.set_host_param		= iscsi_host_set_param,
65065e7ae7bSOr Gerlitz 	/* IO */
65165e7ae7bSOr Gerlitz 	.send_pdu		= iscsi_conn_send_pdu,
65265e7ae7bSOr Gerlitz 	.get_stats		= iscsi_iser_conn_get_stats,
6532747fdb2SMike Christie 	.init_task		= iscsi_iser_task_init,
6542747fdb2SMike Christie 	.xmit_task		= iscsi_iser_task_xmit,
6552747fdb2SMike Christie 	.cleanup_task		= iscsi_iser_cleanup_task,
6560f9c7449SMike Christie 	.alloc_pdu		= iscsi_iser_pdu_alloc,
65765e7ae7bSOr Gerlitz 	/* recovery */
65865e7ae7bSOr Gerlitz 	.session_recovery_timedout = iscsi_session_recovery_timedout,
65965e7ae7bSOr Gerlitz 
66065e7ae7bSOr Gerlitz 	.ep_connect             = iscsi_iser_ep_connect,
66165e7ae7bSOr Gerlitz 	.ep_poll                = iscsi_iser_ep_poll,
66265e7ae7bSOr Gerlitz 	.ep_disconnect          = iscsi_iser_ep_disconnect
66365e7ae7bSOr Gerlitz };
66465e7ae7bSOr Gerlitz 
66565e7ae7bSOr Gerlitz static int __init iser_init(void)
66665e7ae7bSOr Gerlitz {
66765e7ae7bSOr Gerlitz 	int err;
66865e7ae7bSOr Gerlitz 
66965e7ae7bSOr Gerlitz 	iser_dbg("Starting iSER datamover...\n");
67065e7ae7bSOr Gerlitz 
67165e7ae7bSOr Gerlitz 	if (iscsi_max_lun < 1) {
67265e7ae7bSOr Gerlitz 		printk(KERN_ERR "Invalid max_lun value of %u\n", iscsi_max_lun);
67365e7ae7bSOr Gerlitz 		return -EINVAL;
67465e7ae7bSOr Gerlitz 	}
67565e7ae7bSOr Gerlitz 
67665e7ae7bSOr Gerlitz 	memset(&ig, 0, sizeof(struct iser_global));
67765e7ae7bSOr Gerlitz 
67865e7ae7bSOr Gerlitz 	ig.desc_cache = kmem_cache_create("iser_descriptors",
67965e7ae7bSOr Gerlitz 					  sizeof (struct iser_desc),
68065e7ae7bSOr Gerlitz 					  0, SLAB_HWCACHE_ALIGN,
68120c2df83SPaul Mundt 					  NULL);
68265e7ae7bSOr Gerlitz 	if (ig.desc_cache == NULL)
68365e7ae7bSOr Gerlitz 		return -ENOMEM;
68465e7ae7bSOr Gerlitz 
68565e7ae7bSOr Gerlitz 	/* device init is called only after the first addr resolution */
68665e7ae7bSOr Gerlitz 	mutex_init(&ig.device_list_mutex);
68765e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.device_list);
68865e7ae7bSOr Gerlitz 	mutex_init(&ig.connlist_mutex);
68965e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.connlist);
69065e7ae7bSOr Gerlitz 
69175613521SMike Christie 	iscsi_iser_scsi_transport = iscsi_register_transport(
69275613521SMike Christie 							&iscsi_iser_transport);
69375613521SMike Christie 	if (!iscsi_iser_scsi_transport) {
69465e7ae7bSOr Gerlitz 		iser_err("iscsi_register_transport failed\n");
69565e7ae7bSOr Gerlitz 		err = -EINVAL;
69665e7ae7bSOr Gerlitz 		goto register_transport_failure;
69765e7ae7bSOr Gerlitz 	}
69865e7ae7bSOr Gerlitz 
69965e7ae7bSOr Gerlitz 	return 0;
70065e7ae7bSOr Gerlitz 
70165e7ae7bSOr Gerlitz register_transport_failure:
70265e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
70365e7ae7bSOr Gerlitz 
70465e7ae7bSOr Gerlitz 	return err;
70565e7ae7bSOr Gerlitz }
70665e7ae7bSOr Gerlitz 
70765e7ae7bSOr Gerlitz static void __exit iser_exit(void)
70865e7ae7bSOr Gerlitz {
70965e7ae7bSOr Gerlitz 	iser_dbg("Removing iSER datamover...\n");
71065e7ae7bSOr Gerlitz 	iscsi_unregister_transport(&iscsi_iser_transport);
71165e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
71265e7ae7bSOr Gerlitz }
71365e7ae7bSOr Gerlitz 
71465e7ae7bSOr Gerlitz module_init(iser_init);
71565e7ae7bSOr Gerlitz module_exit(iser_exit);
716