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 
260b3cd5050SMike Christie 	/* mgmt tasks do not need special cleanup */
261b3cd5050SMike Christie 	if (!task->sc)
2622747fdb2SMike Christie 		return;
26365e7ae7bSOr Gerlitz 
2642261ec3dSMike Christie 	if (iser_task->status == ISER_TASK_STATUS_STARTED) {
2652261ec3dSMike Christie 		iser_task->status = ISER_TASK_STATUS_COMPLETED;
2662261ec3dSMike Christie 		iser_task_rdma_finalize(iser_task);
26765e7ae7bSOr Gerlitz 	}
26865e7ae7bSOr Gerlitz }
26965e7ae7bSOr Gerlitz 
27065e7ae7bSOr Gerlitz static struct iscsi_cls_conn *
27165e7ae7bSOr Gerlitz iscsi_iser_conn_create(struct iscsi_cls_session *cls_session, uint32_t conn_idx)
27265e7ae7bSOr Gerlitz {
27365e7ae7bSOr Gerlitz 	struct iscsi_conn *conn;
27465e7ae7bSOr Gerlitz 	struct iscsi_cls_conn *cls_conn;
27565e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
27665e7ae7bSOr Gerlitz 
2775d91e209SMike Christie 	cls_conn = iscsi_conn_setup(cls_session, sizeof(*iser_conn), conn_idx);
27865e7ae7bSOr Gerlitz 	if (!cls_conn)
27965e7ae7bSOr Gerlitz 		return NULL;
28065e7ae7bSOr Gerlitz 	conn = cls_conn->dd_data;
28165e7ae7bSOr Gerlitz 
28265e7ae7bSOr Gerlitz 	/*
28365e7ae7bSOr Gerlitz 	 * due to issues with the login code re iser sematics
28465e7ae7bSOr Gerlitz 	 * this not set in iscsi_conn_setup - FIXME
28565e7ae7bSOr Gerlitz 	 */
28665e7ae7bSOr Gerlitz 	conn->max_recv_dlength = 128;
28765e7ae7bSOr Gerlitz 
2885d91e209SMike Christie 	iser_conn = conn->dd_data;
28965e7ae7bSOr Gerlitz 	conn->dd_data = iser_conn;
29065e7ae7bSOr Gerlitz 	iser_conn->iscsi_conn = conn;
29165e7ae7bSOr Gerlitz 
29265e7ae7bSOr Gerlitz 	return cls_conn;
29365e7ae7bSOr Gerlitz }
29465e7ae7bSOr Gerlitz 
29565e7ae7bSOr Gerlitz static void
29665e7ae7bSOr Gerlitz iscsi_iser_conn_destroy(struct iscsi_cls_conn *cls_conn)
29765e7ae7bSOr Gerlitz {
29865e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
29965e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
300b40977d9SMike Christie 	struct iser_conn *ib_conn = iser_conn->ib_conn;
30165e7ae7bSOr Gerlitz 
30265e7ae7bSOr Gerlitz 	iscsi_conn_teardown(cls_conn);
303b40977d9SMike Christie 	/*
304b40977d9SMike Christie 	 * Userspace will normally call the stop callback and
305b40977d9SMike Christie 	 * already have freed the ib_conn, but if it goofed up then
306b40977d9SMike Christie 	 * we free it here.
307b40977d9SMike Christie 	 */
308b40977d9SMike Christie 	if (ib_conn) {
309b40977d9SMike Christie 		ib_conn->iser_conn = NULL;
310b40977d9SMike Christie 		iser_conn_put(ib_conn);
311b40977d9SMike Christie 	}
31265e7ae7bSOr Gerlitz }
31365e7ae7bSOr Gerlitz 
31465e7ae7bSOr Gerlitz static int
31565e7ae7bSOr Gerlitz iscsi_iser_conn_bind(struct iscsi_cls_session *cls_session,
31665e7ae7bSOr Gerlitz 		     struct iscsi_cls_conn *cls_conn, uint64_t transport_eph,
31765e7ae7bSOr Gerlitz 		     int is_leading)
31865e7ae7bSOr Gerlitz {
31965e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
32065e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
32165e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
322412eeafaSMike Christie 	struct iscsi_endpoint *ep;
32365e7ae7bSOr Gerlitz 	int error;
32465e7ae7bSOr Gerlitz 
32565e7ae7bSOr Gerlitz 	error = iscsi_conn_bind(cls_session, cls_conn, is_leading);
32665e7ae7bSOr Gerlitz 	if (error)
32765e7ae7bSOr Gerlitz 		return error;
32865e7ae7bSOr Gerlitz 
32965e7ae7bSOr Gerlitz 	/* the transport ep handle comes from user space so it must be
33065e7ae7bSOr Gerlitz 	 * verified against the global ib connections list */
331412eeafaSMike Christie 	ep = iscsi_lookup_endpoint(transport_eph);
332412eeafaSMike Christie 	if (!ep) {
33365e7ae7bSOr Gerlitz 		iser_err("can't bind eph %llx\n",
33465e7ae7bSOr Gerlitz 			 (unsigned long long)transport_eph);
33565e7ae7bSOr Gerlitz 		return -EINVAL;
33665e7ae7bSOr Gerlitz 	}
337412eeafaSMike Christie 	ib_conn = ep->dd_data;
338412eeafaSMike Christie 
33965e7ae7bSOr Gerlitz 	/* binds the iSER connection retrieved from the previously
34065e7ae7bSOr Gerlitz 	 * connected ep_handle to the iSCSI layer connection. exchanges
34165e7ae7bSOr Gerlitz 	 * connection pointers */
34265e7ae7bSOr Gerlitz 	iser_err("binding iscsi conn %p to iser_conn %p\n",conn,ib_conn);
34365e7ae7bSOr Gerlitz 	iser_conn = conn->dd_data;
34465e7ae7bSOr Gerlitz 	ib_conn->iser_conn = iser_conn;
34565e7ae7bSOr Gerlitz 	iser_conn->ib_conn  = ib_conn;
346b40977d9SMike Christie 	iser_conn_get(ib_conn);
34765e7ae7bSOr Gerlitz 	return 0;
34865e7ae7bSOr Gerlitz }
34965e7ae7bSOr Gerlitz 
350b40977d9SMike Christie static void
351b40977d9SMike Christie iscsi_iser_conn_stop(struct iscsi_cls_conn *cls_conn, int flag)
352b40977d9SMike Christie {
353b40977d9SMike Christie 	struct iscsi_conn *conn = cls_conn->dd_data;
354b40977d9SMike Christie 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
355b40977d9SMike Christie 	struct iser_conn *ib_conn = iser_conn->ib_conn;
356b40977d9SMike Christie 
357913e5bf4SMike Christie 	/*
358913e5bf4SMike Christie 	 * Userspace may have goofed up and not bound the connection or
359913e5bf4SMike Christie 	 * might have only partially setup the connection.
360913e5bf4SMike Christie 	 */
361913e5bf4SMike Christie 	if (ib_conn) {
362b40977d9SMike Christie 		iscsi_conn_stop(cls_conn, flag);
363b40977d9SMike Christie 		/*
364b40977d9SMike Christie 		 * There is no unbind event so the stop callback
365b40977d9SMike Christie 		 * must release the ref from the bind.
366b40977d9SMike Christie 		 */
367b40977d9SMike Christie 		iser_conn_put(ib_conn);
368913e5bf4SMike Christie 	}
369b40977d9SMike Christie 	iser_conn->ib_conn = NULL;
370b40977d9SMike Christie }
371b40977d9SMike Christie 
37265e7ae7bSOr Gerlitz static int
37365e7ae7bSOr Gerlitz iscsi_iser_conn_start(struct iscsi_cls_conn *cls_conn)
37465e7ae7bSOr Gerlitz {
37565e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
37665e7ae7bSOr Gerlitz 	int err;
37765e7ae7bSOr Gerlitz 
3782e7a7426SErez Zilber 	err = iser_conn_set_full_featured_mode(conn);
37965e7ae7bSOr Gerlitz 	if (err)
38065e7ae7bSOr Gerlitz 		return err;
38165e7ae7bSOr Gerlitz 
3822e7a7426SErez Zilber 	return iscsi_conn_start(cls_conn);
38365e7ae7bSOr Gerlitz }
38465e7ae7bSOr Gerlitz 
38575613521SMike Christie static void iscsi_iser_session_destroy(struct iscsi_cls_session *cls_session)
38675613521SMike Christie {
38775613521SMike Christie 	struct Scsi_Host *shost = iscsi_session_to_shost(cls_session);
38875613521SMike Christie 
389e5bd7b54SMike Christie 	iscsi_session_teardown(cls_session);
390a4804cd6SMike Christie 	iscsi_host_remove(shost);
391a4804cd6SMike Christie 	iscsi_host_free(shost);
39275613521SMike Christie }
39365e7ae7bSOr Gerlitz 
39465e7ae7bSOr Gerlitz static struct iscsi_cls_session *
395412eeafaSMike Christie iscsi_iser_session_create(struct iscsi_endpoint *ep,
3961548271eSMike Christie 			  uint16_t cmds_max, uint16_t qdepth,
3975e7facb7SMike Christie 			  uint32_t initial_cmdsn)
39865e7ae7bSOr Gerlitz {
39965e7ae7bSOr Gerlitz 	struct iscsi_cls_session *cls_session;
40065e7ae7bSOr Gerlitz 	struct iscsi_session *session;
401412eeafaSMike Christie 	struct Scsi_Host *shost;
402412eeafaSMike Christie 	struct iser_conn *ib_conn;
40375613521SMike Christie 
4044d108350SMike Christie 	shost = iscsi_host_alloc(&iscsi_iser_sht, 0, 1);
40575613521SMike Christie 	if (!shost)
40675613521SMike Christie 		return NULL;
40775613521SMike Christie 	shost->transportt = iscsi_iser_scsi_transport;
40875613521SMike Christie 	shost->max_lun = iscsi_max_lun;
40975613521SMike Christie 	shost->max_id = 0;
41075613521SMike Christie 	shost->max_channel = 0;
41175613521SMike Christie 	shost->max_cmd_len = 16;
41275613521SMike Christie 
413412eeafaSMike Christie 	/*
414412eeafaSMike Christie 	 * older userspace tools (before 2.0-870) did not pass us
415412eeafaSMike Christie 	 * the leading conn's ep so this will be NULL;
416412eeafaSMike Christie 	 */
417412eeafaSMike Christie 	if (ep)
418412eeafaSMike Christie 		ib_conn = ep->dd_data;
419412eeafaSMike Christie 
420412eeafaSMike Christie 	if (iscsi_host_add(shost,
421412eeafaSMike Christie 			   ep ? ib_conn->device->ib_device->dma_device : NULL))
42275613521SMike Christie 		goto free_host;
42365e7ae7bSOr Gerlitz 
4241548271eSMike Christie 	/*
4251548271eSMike Christie 	 * we do not support setting can_queue cmd_per_lun from userspace yet
4261548271eSMike Christie 	 * because we preallocate so many resources
4271548271eSMike Christie 	 */
42875613521SMike Christie 	cls_session = iscsi_session_setup(&iscsi_iser_transport, shost,
429b8b9e1b8SJayamohan Kallickal 					  ISCSI_DEF_XMIT_CMDS_MAX, 0,
4302261ec3dSMike Christie 					  sizeof(struct iscsi_iser_task),
4317970634bSMike Christie 					  initial_cmdsn, 0);
43265e7ae7bSOr Gerlitz 	if (!cls_session)
43375613521SMike Christie 		goto remove_host;
43475613521SMike Christie 	session = cls_session->dd_data;
43565e7ae7bSOr Gerlitz 
4362747fdb2SMike Christie 	shost->can_queue = session->scsi_cmds_max;
43765e7ae7bSOr Gerlitz 	return cls_session;
43875613521SMike Christie 
43975613521SMike Christie remove_host:
440a4804cd6SMike Christie 	iscsi_host_remove(shost);
44175613521SMike Christie free_host:
442a4804cd6SMike Christie 	iscsi_host_free(shost);
44375613521SMike Christie 	return NULL;
44465e7ae7bSOr Gerlitz }
44565e7ae7bSOr Gerlitz 
44665e7ae7bSOr Gerlitz static int
447358ff019SMike Christie iscsi_iser_set_param(struct iscsi_cls_conn *cls_conn,
448358ff019SMike Christie 		     enum iscsi_param param, char *buf, int buflen)
44965e7ae7bSOr Gerlitz {
450358ff019SMike Christie 	int value;
45165e7ae7bSOr Gerlitz 
45265e7ae7bSOr Gerlitz 	switch (param) {
45365e7ae7bSOr Gerlitz 	case ISCSI_PARAM_MAX_RECV_DLENGTH:
45465e7ae7bSOr Gerlitz 		/* TBD */
45565e7ae7bSOr Gerlitz 		break;
45665e7ae7bSOr Gerlitz 	case ISCSI_PARAM_HDRDGST_EN:
457358ff019SMike Christie 		sscanf(buf, "%d", &value);
45865e7ae7bSOr Gerlitz 		if (value) {
45965e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
46065e7ae7bSOr Gerlitz 			return -EPROTO;
46165e7ae7bSOr Gerlitz 		}
46265e7ae7bSOr Gerlitz 		break;
46365e7ae7bSOr Gerlitz 	case ISCSI_PARAM_DATADGST_EN:
464358ff019SMike Christie 		sscanf(buf, "%d", &value);
46565e7ae7bSOr Gerlitz 		if (value) {
46665e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
46765e7ae7bSOr Gerlitz 			return -EPROTO;
46865e7ae7bSOr Gerlitz 		}
46965e7ae7bSOr Gerlitz 		break;
47065e7ae7bSOr Gerlitz 	case ISCSI_PARAM_IFMARKER_EN:
471358ff019SMike Christie 		sscanf(buf, "%d", &value);
47265e7ae7bSOr Gerlitz 		if (value) {
47365e7ae7bSOr Gerlitz 			printk(KERN_ERR "IFMarker wasn't negotiated to No");
47465e7ae7bSOr Gerlitz 			return -EPROTO;
47565e7ae7bSOr Gerlitz 		}
47665e7ae7bSOr Gerlitz 		break;
47765e7ae7bSOr Gerlitz 	case ISCSI_PARAM_OFMARKER_EN:
478358ff019SMike Christie 		sscanf(buf, "%d", &value);
47965e7ae7bSOr Gerlitz 		if (value) {
48065e7ae7bSOr Gerlitz 			printk(KERN_ERR "OFMarker wasn't negotiated to No");
48165e7ae7bSOr Gerlitz 			return -EPROTO;
48265e7ae7bSOr Gerlitz 		}
48365e7ae7bSOr Gerlitz 		break;
48465e7ae7bSOr Gerlitz 	default:
485358ff019SMike Christie 		return iscsi_set_param(cls_conn, param, buf, buflen);
48665e7ae7bSOr Gerlitz 	}
48765e7ae7bSOr Gerlitz 
48865e7ae7bSOr Gerlitz 	return 0;
48965e7ae7bSOr Gerlitz }
49065e7ae7bSOr Gerlitz 
49165e7ae7bSOr Gerlitz static void
49265e7ae7bSOr Gerlitz iscsi_iser_conn_get_stats(struct iscsi_cls_conn *cls_conn, struct iscsi_stats *stats)
49365e7ae7bSOr Gerlitz {
49465e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
49565e7ae7bSOr Gerlitz 
49665e7ae7bSOr Gerlitz 	stats->txdata_octets = conn->txdata_octets;
49765e7ae7bSOr Gerlitz 	stats->rxdata_octets = conn->rxdata_octets;
49865e7ae7bSOr Gerlitz 	stats->scsicmd_pdus = conn->scsicmd_pdus_cnt;
49965e7ae7bSOr Gerlitz 	stats->dataout_pdus = conn->dataout_pdus_cnt;
50065e7ae7bSOr Gerlitz 	stats->scsirsp_pdus = conn->scsirsp_pdus_cnt;
50165e7ae7bSOr Gerlitz 	stats->datain_pdus = conn->datain_pdus_cnt; /* always 0 */
50265e7ae7bSOr Gerlitz 	stats->r2t_pdus = conn->r2t_pdus_cnt; /* always 0 */
50365e7ae7bSOr Gerlitz 	stats->tmfcmd_pdus = conn->tmfcmd_pdus_cnt;
50465e7ae7bSOr Gerlitz 	stats->tmfrsp_pdus = conn->tmfrsp_pdus_cnt;
50587528227SEli Dorfman 	stats->custom_length = 4;
50665e7ae7bSOr Gerlitz 	strcpy(stats->custom[0].desc, "qp_tx_queue_full");
50765e7ae7bSOr Gerlitz 	stats->custom[0].value = 0; /* TB iser_conn->qp_tx_queue_full; */
50865e7ae7bSOr Gerlitz 	strcpy(stats->custom[1].desc, "fmr_map_not_avail");
50965e7ae7bSOr Gerlitz 	stats->custom[1].value = 0; /* TB iser_conn->fmr_map_not_avail */;
51065e7ae7bSOr Gerlitz 	strcpy(stats->custom[2].desc, "eh_abort_cnt");
51165e7ae7bSOr Gerlitz 	stats->custom[2].value = conn->eh_abort_cnt;
51287528227SEli Dorfman 	strcpy(stats->custom[3].desc, "fmr_unalign_cnt");
51387528227SEli Dorfman 	stats->custom[3].value = conn->fmr_unalign_cnt;
51465e7ae7bSOr Gerlitz }
51565e7ae7bSOr Gerlitz 
516412eeafaSMike Christie static struct iscsi_endpoint *
51710eb0f01SMike Christie iscsi_iser_ep_connect(struct Scsi_Host *shost, struct sockaddr *dst_addr,
51810eb0f01SMike Christie 		      int non_blocking)
51965e7ae7bSOr Gerlitz {
52065e7ae7bSOr Gerlitz 	int err;
52165e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
522412eeafaSMike Christie 	struct iscsi_endpoint *ep;
52365e7ae7bSOr Gerlitz 
524412eeafaSMike Christie 	ep = iscsi_create_endpoint(sizeof(*ib_conn));
525412eeafaSMike Christie 	if (!ep)
526412eeafaSMike Christie 		return ERR_PTR(-ENOMEM);
52765e7ae7bSOr Gerlitz 
528412eeafaSMike Christie 	ib_conn = ep->dd_data;
529412eeafaSMike Christie 	ib_conn->ep = ep;
530412eeafaSMike Christie 	iser_conn_init(ib_conn);
53165e7ae7bSOr Gerlitz 
532412eeafaSMike Christie 	err = iser_connect(ib_conn, NULL, (struct sockaddr_in *)dst_addr,
533412eeafaSMike Christie 			   non_blocking);
534412eeafaSMike Christie 	if (err) {
535412eeafaSMike Christie 		iscsi_destroy_endpoint(ep);
536412eeafaSMike Christie 		return ERR_PTR(err);
537412eeafaSMike Christie 	}
538412eeafaSMike Christie 	return ep;
53965e7ae7bSOr Gerlitz }
54065e7ae7bSOr Gerlitz 
54165e7ae7bSOr Gerlitz static int
542412eeafaSMike Christie iscsi_iser_ep_poll(struct iscsi_endpoint *ep, int timeout_ms)
54365e7ae7bSOr Gerlitz {
544412eeafaSMike Christie 	struct iser_conn *ib_conn;
54565e7ae7bSOr Gerlitz 	int rc;
54665e7ae7bSOr Gerlitz 
547412eeafaSMike Christie 	ib_conn = ep->dd_data;
54865e7ae7bSOr Gerlitz 	rc = wait_event_interruptible_timeout(ib_conn->wait,
54965e7ae7bSOr Gerlitz 			     ib_conn->state == ISER_CONN_UP,
55065e7ae7bSOr Gerlitz 			     msecs_to_jiffies(timeout_ms));
55165e7ae7bSOr Gerlitz 
55265e7ae7bSOr Gerlitz 	/* if conn establishment failed, return error code to iscsi */
55365e7ae7bSOr Gerlitz 	if (!rc &&
55465e7ae7bSOr Gerlitz 	    (ib_conn->state == ISER_CONN_TERMINATING ||
55565e7ae7bSOr Gerlitz 	     ib_conn->state == ISER_CONN_DOWN))
55665e7ae7bSOr Gerlitz 		rc = -1;
55765e7ae7bSOr Gerlitz 
55865e7ae7bSOr Gerlitz 	iser_err("ib conn %p rc = %d\n", ib_conn, rc);
55965e7ae7bSOr Gerlitz 
56065e7ae7bSOr Gerlitz 	if (rc > 0)
56165e7ae7bSOr Gerlitz 		return 1; /* success, this is the equivalent of POLLOUT */
56265e7ae7bSOr Gerlitz 	else if (!rc)
56365e7ae7bSOr Gerlitz 		return 0; /* timeout */
56465e7ae7bSOr Gerlitz 	else
56565e7ae7bSOr Gerlitz 		return rc; /* signal */
56665e7ae7bSOr Gerlitz }
56765e7ae7bSOr Gerlitz 
56865e7ae7bSOr Gerlitz static void
569412eeafaSMike Christie iscsi_iser_ep_disconnect(struct iscsi_endpoint *ep)
57065e7ae7bSOr Gerlitz {
5711c83469dSMike Christie 	struct iser_conn *ib_conn;
57265e7ae7bSOr Gerlitz 
573412eeafaSMike Christie 	ib_conn = ep->dd_data;
574b40977d9SMike Christie 	if (ib_conn->iser_conn)
575b40977d9SMike Christie 		/*
576b40977d9SMike Christie 		 * Must suspend xmit path if the ep is bound to the
577b40977d9SMike Christie 		 * iscsi_conn, so we know we are not accessing the ib_conn
578b40977d9SMike Christie 		 * when we free it.
579b40977d9SMike Christie 		 *
580b40977d9SMike Christie 		 * This may not be bound if the ep poll failed.
581b40977d9SMike Christie 		 */
582b40977d9SMike Christie 		iscsi_suspend_tx(ib_conn->iser_conn->iscsi_conn);
583b40977d9SMike Christie 
58465e7ae7bSOr Gerlitz 
58565e7ae7bSOr Gerlitz 	iser_err("ib conn %p state %d\n",ib_conn, ib_conn->state);
58665e7ae7bSOr Gerlitz 	iser_conn_terminate(ib_conn);
58765e7ae7bSOr Gerlitz }
58865e7ae7bSOr Gerlitz 
58965e7ae7bSOr Gerlitz static struct scsi_host_template iscsi_iser_sht = {
5907974392cSMike Christie 	.module                 = THIS_MODULE,
59165e7ae7bSOr Gerlitz 	.name                   = "iSCSI Initiator over iSER, v." DRV_VER,
59265e7ae7bSOr Gerlitz 	.queuecommand           = iscsi_queuecommand,
5936410627eSErez Zilber 	.change_queue_depth	= iscsi_change_queue_depth,
59465e7ae7bSOr Gerlitz 	.sg_tablesize           = ISCSI_ISER_SG_TABLESIZE,
5958072ec2fSErez Zilber 	.max_sectors		= 1024,
596e28f3d5bSMike Christie 	.cmd_per_lun            = ISER_DEF_CMD_PER_LUN,
59765e7ae7bSOr Gerlitz 	.eh_abort_handler       = iscsi_eh_abort,
59890c18f3cSErez Zilber 	.eh_device_reset_handler= iscsi_eh_device_reset,
5998e124525SMike Christie 	.eh_target_reset_handler= iscsi_eh_target_reset,
6006b5d6c44SMike Christie 	.target_alloc		= iscsi_target_alloc,
60165e7ae7bSOr Gerlitz 	.use_clustering         = DISABLE_CLUSTERING,
60265e7ae7bSOr Gerlitz 	.proc_name              = "iscsi_iser",
60365e7ae7bSOr Gerlitz 	.this_id                = -1,
60465e7ae7bSOr Gerlitz };
60565e7ae7bSOr Gerlitz 
60665e7ae7bSOr Gerlitz static struct iscsi_transport iscsi_iser_transport = {
60765e7ae7bSOr Gerlitz 	.owner                  = THIS_MODULE,
60865e7ae7bSOr Gerlitz 	.name                   = "iser",
60965e7ae7bSOr Gerlitz 	.caps                   = CAP_RECOVERY_L0 | CAP_MULTI_R2T,
61065e7ae7bSOr Gerlitz 	.param_mask		= ISCSI_MAX_RECV_DLENGTH |
61165e7ae7bSOr Gerlitz 				  ISCSI_MAX_XMIT_DLENGTH |
61265e7ae7bSOr Gerlitz 				  ISCSI_HDRDGST_EN |
61365e7ae7bSOr Gerlitz 				  ISCSI_DATADGST_EN |
61465e7ae7bSOr Gerlitz 				  ISCSI_INITIAL_R2T_EN |
61565e7ae7bSOr Gerlitz 				  ISCSI_MAX_R2T |
61665e7ae7bSOr Gerlitz 				  ISCSI_IMM_DATA_EN |
61765e7ae7bSOr Gerlitz 				  ISCSI_FIRST_BURST |
61865e7ae7bSOr Gerlitz 				  ISCSI_MAX_BURST |
61965e7ae7bSOr Gerlitz 				  ISCSI_PDU_INORDER_EN |
620358ff019SMike Christie 				  ISCSI_DATASEQ_INORDER_EN |
621358ff019SMike Christie 				  ISCSI_EXP_STATSN |
622358ff019SMike Christie 				  ISCSI_PERSISTENT_PORT |
623358ff019SMike Christie 				  ISCSI_PERSISTENT_ADDRESS |
624b2c64167SMike Christie 				  ISCSI_TARGET_NAME | ISCSI_TPGT |
625b2c64167SMike Christie 				  ISCSI_USERNAME | ISCSI_PASSWORD |
626f6d5180cSMike Christie 				  ISCSI_USERNAME_IN | ISCSI_PASSWORD_IN |
627f6d5180cSMike Christie 				  ISCSI_FAST_ABORT | ISCSI_ABORT_TMO |
628b20d038dSMike Christie 				  ISCSI_LU_RESET_TMO | ISCSI_TGT_RESET_TMO |
62988dfd340SMike Christie 				  ISCSI_PING_TMO | ISCSI_RECV_TMO |
63088dfd340SMike Christie 				  ISCSI_IFACE_NAME | ISCSI_INITIATOR_NAME,
6318ad5781aSMike Christie 	.host_param_mask	= ISCSI_HOST_HWADDRESS |
632d8196ed2SMike Christie 				  ISCSI_HOST_NETDEV_NAME |
6338ad5781aSMike Christie 				  ISCSI_HOST_INITIATOR_NAME,
63465e7ae7bSOr Gerlitz 	/* session management */
63565e7ae7bSOr Gerlitz 	.create_session         = iscsi_iser_session_create,
63675613521SMike Christie 	.destroy_session        = iscsi_iser_session_destroy,
63765e7ae7bSOr Gerlitz 	/* connection management */
63865e7ae7bSOr Gerlitz 	.create_conn            = iscsi_iser_conn_create,
63965e7ae7bSOr Gerlitz 	.bind_conn              = iscsi_iser_conn_bind,
64065e7ae7bSOr Gerlitz 	.destroy_conn           = iscsi_iser_conn_destroy,
641358ff019SMike Christie 	.set_param              = iscsi_iser_set_param,
642358ff019SMike Christie 	.get_conn_param		= iscsi_conn_get_param,
643358ff019SMike Christie 	.get_session_param	= iscsi_session_get_param,
64465e7ae7bSOr Gerlitz 	.start_conn             = iscsi_iser_conn_start,
645b40977d9SMike Christie 	.stop_conn              = iscsi_iser_conn_stop,
6460801c242SMike Christie 	/* iscsi host params */
6470801c242SMike Christie 	.get_host_param		= iscsi_host_get_param,
6480801c242SMike Christie 	.set_host_param		= iscsi_host_set_param,
64965e7ae7bSOr Gerlitz 	/* IO */
65065e7ae7bSOr Gerlitz 	.send_pdu		= iscsi_conn_send_pdu,
65165e7ae7bSOr Gerlitz 	.get_stats		= iscsi_iser_conn_get_stats,
6522747fdb2SMike Christie 	.init_task		= iscsi_iser_task_init,
6532747fdb2SMike Christie 	.xmit_task		= iscsi_iser_task_xmit,
6542747fdb2SMike Christie 	.cleanup_task		= iscsi_iser_cleanup_task,
6550f9c7449SMike Christie 	.alloc_pdu		= iscsi_iser_pdu_alloc,
65665e7ae7bSOr Gerlitz 	/* recovery */
65765e7ae7bSOr Gerlitz 	.session_recovery_timedout = iscsi_session_recovery_timedout,
65865e7ae7bSOr Gerlitz 
65965e7ae7bSOr Gerlitz 	.ep_connect             = iscsi_iser_ep_connect,
66065e7ae7bSOr Gerlitz 	.ep_poll                = iscsi_iser_ep_poll,
66165e7ae7bSOr Gerlitz 	.ep_disconnect          = iscsi_iser_ep_disconnect
66265e7ae7bSOr Gerlitz };
66365e7ae7bSOr Gerlitz 
66465e7ae7bSOr Gerlitz static int __init iser_init(void)
66565e7ae7bSOr Gerlitz {
66665e7ae7bSOr Gerlitz 	int err;
66765e7ae7bSOr Gerlitz 
66865e7ae7bSOr Gerlitz 	iser_dbg("Starting iSER datamover...\n");
66965e7ae7bSOr Gerlitz 
67065e7ae7bSOr Gerlitz 	if (iscsi_max_lun < 1) {
67165e7ae7bSOr Gerlitz 		printk(KERN_ERR "Invalid max_lun value of %u\n", iscsi_max_lun);
67265e7ae7bSOr Gerlitz 		return -EINVAL;
67365e7ae7bSOr Gerlitz 	}
67465e7ae7bSOr Gerlitz 
67565e7ae7bSOr Gerlitz 	memset(&ig, 0, sizeof(struct iser_global));
67665e7ae7bSOr Gerlitz 
67765e7ae7bSOr Gerlitz 	ig.desc_cache = kmem_cache_create("iser_descriptors",
67865e7ae7bSOr Gerlitz 					  sizeof (struct iser_desc),
67965e7ae7bSOr Gerlitz 					  0, SLAB_HWCACHE_ALIGN,
68020c2df83SPaul Mundt 					  NULL);
68165e7ae7bSOr Gerlitz 	if (ig.desc_cache == NULL)
68265e7ae7bSOr Gerlitz 		return -ENOMEM;
68365e7ae7bSOr Gerlitz 
68465e7ae7bSOr Gerlitz 	/* device init is called only after the first addr resolution */
68565e7ae7bSOr Gerlitz 	mutex_init(&ig.device_list_mutex);
68665e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.device_list);
68765e7ae7bSOr Gerlitz 	mutex_init(&ig.connlist_mutex);
68865e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.connlist);
68965e7ae7bSOr Gerlitz 
69075613521SMike Christie 	iscsi_iser_scsi_transport = iscsi_register_transport(
69175613521SMike Christie 							&iscsi_iser_transport);
69275613521SMike Christie 	if (!iscsi_iser_scsi_transport) {
69365e7ae7bSOr Gerlitz 		iser_err("iscsi_register_transport failed\n");
69465e7ae7bSOr Gerlitz 		err = -EINVAL;
69565e7ae7bSOr Gerlitz 		goto register_transport_failure;
69665e7ae7bSOr Gerlitz 	}
69765e7ae7bSOr Gerlitz 
69865e7ae7bSOr Gerlitz 	return 0;
69965e7ae7bSOr Gerlitz 
70065e7ae7bSOr Gerlitz register_transport_failure:
70165e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
70265e7ae7bSOr Gerlitz 
70365e7ae7bSOr Gerlitz 	return err;
70465e7ae7bSOr Gerlitz }
70565e7ae7bSOr Gerlitz 
70665e7ae7bSOr Gerlitz static void __exit iser_exit(void)
70765e7ae7bSOr Gerlitz {
70865e7ae7bSOr Gerlitz 	iser_dbg("Removing iSER datamover...\n");
70965e7ae7bSOr Gerlitz 	iscsi_unregister_transport(&iscsi_iser_transport);
71065e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
71165e7ae7bSOr Gerlitz }
71265e7ae7bSOr Gerlitz 
71365e7ae7bSOr Gerlitz module_init(iser_init);
71465e7ae7bSOr Gerlitz module_exit(iser_exit);
715