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  * $Id: iscsi_iser.c 6965 2006-05-07 11:36:20Z ogerlitz $
4865e7ae7bSOr Gerlitz  */
4965e7ae7bSOr Gerlitz 
5065e7ae7bSOr Gerlitz #include <linux/types.h>
5165e7ae7bSOr Gerlitz #include <linux/list.h>
5265e7ae7bSOr Gerlitz #include <linux/hardirq.h>
5365e7ae7bSOr Gerlitz #include <linux/kfifo.h>
5465e7ae7bSOr Gerlitz #include <linux/blkdev.h>
5565e7ae7bSOr Gerlitz #include <linux/init.h>
5665e7ae7bSOr Gerlitz #include <linux/ioctl.h>
5765e7ae7bSOr Gerlitz #include <linux/cdev.h>
5865e7ae7bSOr Gerlitz #include <linux/in.h>
5965e7ae7bSOr Gerlitz #include <linux/net.h>
6065e7ae7bSOr Gerlitz #include <linux/scatterlist.h>
6165e7ae7bSOr Gerlitz #include <linux/delay.h>
6265e7ae7bSOr Gerlitz 
6365e7ae7bSOr Gerlitz #include <net/sock.h>
6465e7ae7bSOr Gerlitz 
6565e7ae7bSOr Gerlitz #include <asm/uaccess.h>
6665e7ae7bSOr Gerlitz 
6765e7ae7bSOr Gerlitz #include <scsi/scsi_cmnd.h>
6865e7ae7bSOr Gerlitz #include <scsi/scsi_device.h>
6965e7ae7bSOr Gerlitz #include <scsi/scsi_eh.h>
7065e7ae7bSOr Gerlitz #include <scsi/scsi_tcq.h>
7165e7ae7bSOr Gerlitz #include <scsi/scsi_host.h>
7265e7ae7bSOr Gerlitz #include <scsi/scsi.h>
7365e7ae7bSOr Gerlitz #include <scsi/scsi_transport_iscsi.h>
7465e7ae7bSOr Gerlitz 
7565e7ae7bSOr Gerlitz #include "iscsi_iser.h"
7665e7ae7bSOr Gerlitz 
7775613521SMike Christie static struct scsi_host_template iscsi_iser_sht;
7875613521SMike Christie static struct iscsi_transport iscsi_iser_transport;
7975613521SMike Christie static struct scsi_transport_template *iscsi_iser_scsi_transport;
8075613521SMike Christie 
8165e7ae7bSOr Gerlitz static unsigned int iscsi_max_lun = 512;
8265e7ae7bSOr Gerlitz module_param_named(max_lun, iscsi_max_lun, uint, S_IRUGO);
8365e7ae7bSOr Gerlitz 
8465e7ae7bSOr Gerlitz int iser_debug_level = 0;
8565e7ae7bSOr Gerlitz 
8665e7ae7bSOr Gerlitz MODULE_DESCRIPTION("iSER (iSCSI Extensions for RDMA) Datamover "
8765e7ae7bSOr Gerlitz 		   "v" DRV_VER " (" DRV_DATE ")");
8865e7ae7bSOr Gerlitz MODULE_LICENSE("Dual BSD/GPL");
8965e7ae7bSOr Gerlitz MODULE_AUTHOR("Alex Nezhinsky, Dan Bar Dov, Or Gerlitz");
9065e7ae7bSOr Gerlitz 
9165e7ae7bSOr Gerlitz module_param_named(debug_level, iser_debug_level, int, 0644);
9265e7ae7bSOr Gerlitz MODULE_PARM_DESC(debug_level, "Enable debug tracing if > 0 (default:disabled)");
9365e7ae7bSOr Gerlitz 
9465e7ae7bSOr Gerlitz struct iser_global ig;
9565e7ae7bSOr Gerlitz 
9665e7ae7bSOr Gerlitz void
9765e7ae7bSOr Gerlitz iscsi_iser_recv(struct iscsi_conn *conn,
9865e7ae7bSOr Gerlitz 		struct iscsi_hdr *hdr, char *rx_data, int rx_data_len)
9965e7ae7bSOr Gerlitz {
10065e7ae7bSOr Gerlitz 	int rc = 0;
10165e7ae7bSOr Gerlitz 	int datalen;
10265e7ae7bSOr Gerlitz 	int ahslen;
10365e7ae7bSOr Gerlitz 
10465e7ae7bSOr Gerlitz 	/* verify PDU length */
10565e7ae7bSOr Gerlitz 	datalen = ntoh24(hdr->dlength);
10665e7ae7bSOr Gerlitz 	if (datalen != rx_data_len) {
10765e7ae7bSOr Gerlitz 		printk(KERN_ERR "iscsi_iser: datalen %d (hdr) != %d (IB) \n",
10865e7ae7bSOr Gerlitz 		       datalen, rx_data_len);
10965e7ae7bSOr Gerlitz 		rc = ISCSI_ERR_DATALEN;
11065e7ae7bSOr Gerlitz 		goto error;
11165e7ae7bSOr Gerlitz 	}
11265e7ae7bSOr Gerlitz 
11365e7ae7bSOr Gerlitz 	/* read AHS */
11465e7ae7bSOr Gerlitz 	ahslen = hdr->hlength * 4;
11565e7ae7bSOr Gerlitz 
11665e7ae7bSOr Gerlitz 	rc = iscsi_complete_pdu(conn, hdr, rx_data, rx_data_len);
11765e7ae7bSOr Gerlitz 	if (rc && rc != ISCSI_ERR_NO_SCSI_CMD)
11865e7ae7bSOr Gerlitz 		goto error;
11965e7ae7bSOr Gerlitz 
12065e7ae7bSOr Gerlitz 	return;
12165e7ae7bSOr Gerlitz error:
12265e7ae7bSOr Gerlitz 	iscsi_conn_failure(conn, rc);
12365e7ae7bSOr Gerlitz }
12465e7ae7bSOr Gerlitz 
12565e7ae7bSOr Gerlitz 
12665e7ae7bSOr Gerlitz /**
1272261ec3dSMike Christie  * iscsi_iser_task_init - Initialize task
1282261ec3dSMike Christie  * @task: iscsi task
12965e7ae7bSOr Gerlitz  *
1302261ec3dSMike Christie  * Initialize the task for the scsi command or mgmt command.
1312747fdb2SMike Christie  */
132a8ac6311SOlaf Kirch static int
1332261ec3dSMike Christie iscsi_iser_task_init(struct iscsi_task *task)
13465e7ae7bSOr Gerlitz {
1352261ec3dSMike Christie 	struct iscsi_iser_conn *iser_conn  = task->conn->dd_data;
1362261ec3dSMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
13765e7ae7bSOr Gerlitz 
1382261ec3dSMike Christie 	/* mgmt task */
1392261ec3dSMike Christie 	if (!task->sc) {
1402261ec3dSMike Christie 		iser_task->desc.data = task->data;
1412747fdb2SMike Christie 		return 0;
1422747fdb2SMike Christie 	}
1432747fdb2SMike Christie 
1442261ec3dSMike Christie 	iser_task->command_sent = 0;
1452261ec3dSMike Christie 	iser_task->iser_conn    = iser_conn;
1462261ec3dSMike Christie 	iser_task_rdma_init(iser_task);
147a8ac6311SOlaf Kirch 	return 0;
14865e7ae7bSOr Gerlitz }
14965e7ae7bSOr Gerlitz 
15065e7ae7bSOr Gerlitz /**
1512261ec3dSMike Christie  * iscsi_iser_mtask_xmit - xmit management(immediate) task
15265e7ae7bSOr Gerlitz  * @conn: iscsi connection
1532261ec3dSMike Christie  * @task: task management task
15465e7ae7bSOr Gerlitz  *
15565e7ae7bSOr Gerlitz  * Notes:
15665e7ae7bSOr Gerlitz  *	The function can return -EAGAIN in which case caller must
15765e7ae7bSOr Gerlitz  *	call it again later, or recover. '0' return code means successful
15865e7ae7bSOr Gerlitz  *	xmit.
15965e7ae7bSOr Gerlitz  *
16065e7ae7bSOr Gerlitz  **/
16165e7ae7bSOr Gerlitz static int
1622261ec3dSMike Christie iscsi_iser_mtask_xmit(struct iscsi_conn *conn, struct iscsi_task *task)
16365e7ae7bSOr Gerlitz {
16465e7ae7bSOr Gerlitz 	int error = 0;
16565e7ae7bSOr Gerlitz 
1662261ec3dSMike Christie 	debug_scsi("task deq [cid %d itt 0x%x]\n", conn->id, task->itt);
16765e7ae7bSOr Gerlitz 
1682261ec3dSMike Christie 	error = iser_send_control(conn, task);
16965e7ae7bSOr Gerlitz 
1702261ec3dSMike Christie 	/* since iser xmits control with zero copy, tasks can not be recycled
17165e7ae7bSOr Gerlitz 	 * right after sending them.
17265e7ae7bSOr Gerlitz 	 * The recycling scheme is based on whether a response is expected
1732261ec3dSMike Christie 	 * - if yes, the task is recycled at iscsi_complete_pdu
1742261ec3dSMike Christie 	 * - if no,  the task is recycled at iser_snd_completion
17565e7ae7bSOr Gerlitz 	 */
176f0938401SErez Zilber 	if (error && error != -ENOBUFS)
17765e7ae7bSOr Gerlitz 		iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED);
17865e7ae7bSOr Gerlitz 
17965e7ae7bSOr Gerlitz 	return error;
18065e7ae7bSOr Gerlitz }
18165e7ae7bSOr Gerlitz 
18265e7ae7bSOr Gerlitz static int
1832747fdb2SMike Christie iscsi_iser_task_xmit_unsol_data(struct iscsi_conn *conn,
1842261ec3dSMike Christie 				 struct iscsi_task *task)
18565e7ae7bSOr Gerlitz {
18665e7ae7bSOr Gerlitz 	struct iscsi_data  hdr;
18765e7ae7bSOr Gerlitz 	int error = 0;
18865e7ae7bSOr Gerlitz 
18965e7ae7bSOr Gerlitz 	/* Send data-out PDUs while there's still unsolicited data to send */
1902261ec3dSMike Christie 	while (task->unsol_count > 0) {
1912261ec3dSMike Christie 		iscsi_prep_unsolicit_data_pdu(task, &hdr);
19265e7ae7bSOr Gerlitz 		debug_scsi("Sending data-out: itt 0x%x, data count %d\n",
1932261ec3dSMike Christie 			   hdr.itt, task->data_count);
19465e7ae7bSOr Gerlitz 
19565e7ae7bSOr Gerlitz 		/* the buffer description has been passed with the command */
19665e7ae7bSOr Gerlitz 		/* Send the command */
1972261ec3dSMike Christie 		error = iser_send_data_out(conn, task, &hdr);
19865e7ae7bSOr Gerlitz 		if (error) {
1992261ec3dSMike Christie 			task->unsol_datasn--;
2002747fdb2SMike Christie 			goto iscsi_iser_task_xmit_unsol_data_exit;
20165e7ae7bSOr Gerlitz 		}
2022261ec3dSMike Christie 		task->unsol_count -= task->data_count;
20365e7ae7bSOr Gerlitz 		debug_scsi("Need to send %d more as data-out PDUs\n",
2042261ec3dSMike Christie 			   task->unsol_count);
20565e7ae7bSOr Gerlitz 	}
20665e7ae7bSOr Gerlitz 
2072747fdb2SMike Christie iscsi_iser_task_xmit_unsol_data_exit:
20865e7ae7bSOr Gerlitz 	return error;
20965e7ae7bSOr Gerlitz }
21065e7ae7bSOr Gerlitz 
21165e7ae7bSOr Gerlitz static int
2122261ec3dSMike Christie iscsi_iser_task_xmit(struct iscsi_task *task)
21365e7ae7bSOr Gerlitz {
2142261ec3dSMike Christie 	struct iscsi_conn *conn = task->conn;
2152261ec3dSMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
21665e7ae7bSOr Gerlitz 	int error = 0;
21765e7ae7bSOr Gerlitz 
2182261ec3dSMike Christie 	if (!task->sc)
2192261ec3dSMike Christie 		return iscsi_iser_mtask_xmit(conn, task);
2202747fdb2SMike Christie 
2212261ec3dSMike Christie 	if (task->sc->sc_data_direction == DMA_TO_DEVICE) {
2222261ec3dSMike Christie 		BUG_ON(scsi_bufflen(task->sc) == 0);
22377a23c21SMike Christie 
22477a23c21SMike Christie 		debug_scsi("cmd [itt %x total %d imm %d unsol_data %d\n",
2252261ec3dSMike Christie 			   task->itt, scsi_bufflen(task->sc),
2262261ec3dSMike Christie 			   task->imm_count, task->unsol_count);
22777a23c21SMike Christie 	}
22877a23c21SMike Christie 
2292261ec3dSMike Christie 	debug_scsi("task deq [cid %d itt 0x%x]\n",
2302261ec3dSMike Christie 		   conn->id, task->itt);
23165e7ae7bSOr Gerlitz 
23265e7ae7bSOr Gerlitz 	/* Send the cmd PDU */
2332261ec3dSMike Christie 	if (!iser_task->command_sent) {
2342261ec3dSMike Christie 		error = iser_send_command(conn, task);
23565e7ae7bSOr Gerlitz 		if (error)
2362747fdb2SMike Christie 			goto iscsi_iser_task_xmit_exit;
2372261ec3dSMike Christie 		iser_task->command_sent = 1;
23865e7ae7bSOr Gerlitz 	}
23965e7ae7bSOr Gerlitz 
24065e7ae7bSOr Gerlitz 	/* Send unsolicited data-out PDU(s) if necessary */
2412261ec3dSMike Christie 	if (task->unsol_count)
2422261ec3dSMike Christie 		error = iscsi_iser_task_xmit_unsol_data(conn, task);
24365e7ae7bSOr Gerlitz 
2442747fdb2SMike Christie  iscsi_iser_task_xmit_exit:
245f0938401SErez Zilber 	if (error && error != -ENOBUFS)
24665e7ae7bSOr Gerlitz 		iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED);
24765e7ae7bSOr Gerlitz 	return error;
24865e7ae7bSOr Gerlitz }
24965e7ae7bSOr Gerlitz 
25065e7ae7bSOr Gerlitz static void
2512261ec3dSMike Christie iscsi_iser_cleanup_task(struct iscsi_conn *conn, struct iscsi_task *task)
25265e7ae7bSOr Gerlitz {
2532261ec3dSMike Christie 	struct iscsi_iser_task *iser_task = task->dd_data;
25465e7ae7bSOr Gerlitz 
2552747fdb2SMike Christie 	/* mgmt tasks do not need special cleanup */
2562261ec3dSMike Christie 	if (!task->sc)
2572747fdb2SMike Christie 		return;
2582747fdb2SMike Christie 
2592261ec3dSMike Christie 	if (iser_task->status == ISER_TASK_STATUS_STARTED) {
2602261ec3dSMike Christie 		iser_task->status = ISER_TASK_STATUS_COMPLETED;
2612261ec3dSMike Christie 		iser_task_rdma_finalize(iser_task);
26265e7ae7bSOr Gerlitz 	}
26365e7ae7bSOr Gerlitz }
26465e7ae7bSOr Gerlitz 
26565e7ae7bSOr Gerlitz static struct iscsi_cls_conn *
26665e7ae7bSOr Gerlitz iscsi_iser_conn_create(struct iscsi_cls_session *cls_session, uint32_t conn_idx)
26765e7ae7bSOr Gerlitz {
26865e7ae7bSOr Gerlitz 	struct iscsi_conn *conn;
26965e7ae7bSOr Gerlitz 	struct iscsi_cls_conn *cls_conn;
27065e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
27165e7ae7bSOr Gerlitz 
2725d91e209SMike Christie 	cls_conn = iscsi_conn_setup(cls_session, sizeof(*iser_conn), conn_idx);
27365e7ae7bSOr Gerlitz 	if (!cls_conn)
27465e7ae7bSOr Gerlitz 		return NULL;
27565e7ae7bSOr Gerlitz 	conn = cls_conn->dd_data;
27665e7ae7bSOr Gerlitz 
27765e7ae7bSOr Gerlitz 	/*
27865e7ae7bSOr Gerlitz 	 * due to issues with the login code re iser sematics
27965e7ae7bSOr Gerlitz 	 * this not set in iscsi_conn_setup - FIXME
28065e7ae7bSOr Gerlitz 	 */
28165e7ae7bSOr Gerlitz 	conn->max_recv_dlength = 128;
28265e7ae7bSOr Gerlitz 
2835d91e209SMike Christie 	iser_conn = conn->dd_data;
28465e7ae7bSOr Gerlitz 	/* currently this is the only field which need to be initiated */
28565e7ae7bSOr Gerlitz 	rwlock_init(&iser_conn->lock);
28665e7ae7bSOr Gerlitz 
28765e7ae7bSOr Gerlitz 	conn->dd_data = iser_conn;
28865e7ae7bSOr Gerlitz 	iser_conn->iscsi_conn = conn;
28965e7ae7bSOr Gerlitz 
29065e7ae7bSOr Gerlitz 	return cls_conn;
29165e7ae7bSOr Gerlitz }
29265e7ae7bSOr Gerlitz 
29365e7ae7bSOr Gerlitz static void
29465e7ae7bSOr Gerlitz iscsi_iser_conn_destroy(struct iscsi_cls_conn *cls_conn)
29565e7ae7bSOr Gerlitz {
29665e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
29765e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
298b40977d9SMike Christie 	struct iser_conn *ib_conn = iser_conn->ib_conn;
29965e7ae7bSOr Gerlitz 
3005d91e209SMike Christie 	iscsi_conn_teardown(cls_conn);
301b40977d9SMike Christie 	/*
302b40977d9SMike Christie 	 * Userspace will normally call the stop callback and
303b40977d9SMike Christie 	 * already have freed the ib_conn, but if it goofed up then
304b40977d9SMike Christie 	 * we free it here.
305b40977d9SMike Christie 	 */
306b40977d9SMike Christie 	if (ib_conn) {
307b40977d9SMike Christie 		ib_conn->iser_conn = NULL;
308b40977d9SMike Christie 		iser_conn_put(ib_conn);
309b40977d9SMike Christie 	}
31065e7ae7bSOr Gerlitz }
31165e7ae7bSOr Gerlitz 
31265e7ae7bSOr Gerlitz static int
31365e7ae7bSOr Gerlitz iscsi_iser_conn_bind(struct iscsi_cls_session *cls_session,
31465e7ae7bSOr Gerlitz 		     struct iscsi_cls_conn *cls_conn, uint64_t transport_eph,
31565e7ae7bSOr Gerlitz 		     int is_leading)
31665e7ae7bSOr Gerlitz {
31765e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
31865e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
31965e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
320412eeafaSMike Christie 	struct iscsi_endpoint *ep;
32165e7ae7bSOr Gerlitz 	int error;
32265e7ae7bSOr Gerlitz 
32365e7ae7bSOr Gerlitz 	error = iscsi_conn_bind(cls_session, cls_conn, is_leading);
32465e7ae7bSOr Gerlitz 	if (error)
32565e7ae7bSOr Gerlitz 		return error;
32665e7ae7bSOr Gerlitz 
32765e7ae7bSOr Gerlitz 	/* the transport ep handle comes from user space so it must be
32865e7ae7bSOr Gerlitz 	 * verified against the global ib connections list */
329412eeafaSMike Christie 	ep = iscsi_lookup_endpoint(transport_eph);
330412eeafaSMike Christie 	if (!ep) {
33165e7ae7bSOr Gerlitz 		iser_err("can't bind eph %llx\n",
33265e7ae7bSOr Gerlitz 			 (unsigned long long)transport_eph);
33365e7ae7bSOr Gerlitz 		return -EINVAL;
33465e7ae7bSOr Gerlitz 	}
335412eeafaSMike Christie 	ib_conn = ep->dd_data;
336412eeafaSMike Christie 
33765e7ae7bSOr Gerlitz 	/* binds the iSER connection retrieved from the previously
33865e7ae7bSOr Gerlitz 	 * connected ep_handle to the iSCSI layer connection. exchanges
33965e7ae7bSOr Gerlitz 	 * connection pointers */
34065e7ae7bSOr Gerlitz 	iser_err("binding iscsi conn %p to iser_conn %p\n",conn,ib_conn);
34165e7ae7bSOr Gerlitz 	iser_conn = conn->dd_data;
34265e7ae7bSOr Gerlitz 	ib_conn->iser_conn = iser_conn;
34365e7ae7bSOr Gerlitz 	iser_conn->ib_conn  = ib_conn;
344b40977d9SMike Christie 	iser_conn_get(ib_conn);
34565e7ae7bSOr Gerlitz 
34665e7ae7bSOr Gerlitz 	conn->recv_lock = &iser_conn->lock;
34765e7ae7bSOr Gerlitz 
34865e7ae7bSOr Gerlitz 	return 0;
34965e7ae7bSOr Gerlitz }
35065e7ae7bSOr Gerlitz 
351b40977d9SMike Christie static void
352b40977d9SMike Christie iscsi_iser_conn_stop(struct iscsi_cls_conn *cls_conn, int flag)
353b40977d9SMike Christie {
354b40977d9SMike Christie 	struct iscsi_conn *conn = cls_conn->dd_data;
355b40977d9SMike Christie 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
356b40977d9SMike Christie 	struct iser_conn *ib_conn = iser_conn->ib_conn;
357b40977d9SMike Christie 
358b40977d9SMike Christie 	iscsi_conn_stop(cls_conn, flag);
359b40977d9SMike Christie 	/*
360b40977d9SMike Christie 	 * There is no unbind event so the stop callback
361b40977d9SMike Christie 	 * must release the ref from the bind.
362b40977d9SMike Christie 	 */
363b40977d9SMike Christie 	iser_conn_put(ib_conn);
364b40977d9SMike Christie 	iser_conn->ib_conn = NULL;
365b40977d9SMike Christie }
366b40977d9SMike Christie 
36765e7ae7bSOr Gerlitz static int
36865e7ae7bSOr Gerlitz iscsi_iser_conn_start(struct iscsi_cls_conn *cls_conn)
36965e7ae7bSOr Gerlitz {
37065e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
37165e7ae7bSOr Gerlitz 	int err;
37265e7ae7bSOr Gerlitz 
3732e7a7426SErez Zilber 	err = iser_conn_set_full_featured_mode(conn);
37465e7ae7bSOr Gerlitz 	if (err)
37565e7ae7bSOr Gerlitz 		return err;
37665e7ae7bSOr Gerlitz 
3772e7a7426SErez Zilber 	return iscsi_conn_start(cls_conn);
37865e7ae7bSOr Gerlitz }
37965e7ae7bSOr Gerlitz 
38075613521SMike Christie static void iscsi_iser_session_destroy(struct iscsi_cls_session *cls_session)
38175613521SMike Christie {
38275613521SMike Christie 	struct Scsi_Host *shost = iscsi_session_to_shost(cls_session);
38375613521SMike Christie 
384a4804cd6SMike Christie 	iscsi_host_remove(shost);
385a4804cd6SMike Christie 	iscsi_host_free(shost);
38675613521SMike Christie }
38765e7ae7bSOr Gerlitz 
38865e7ae7bSOr Gerlitz static struct iscsi_cls_session *
389412eeafaSMike Christie iscsi_iser_session_create(struct iscsi_endpoint *ep,
3901548271eSMike Christie 			  uint16_t cmds_max, uint16_t qdepth,
39165e7ae7bSOr Gerlitz 			  uint32_t initial_cmdsn, uint32_t *hostno)
39265e7ae7bSOr Gerlitz {
39365e7ae7bSOr Gerlitz 	struct iscsi_cls_session *cls_session;
39465e7ae7bSOr Gerlitz 	struct iscsi_session *session;
395412eeafaSMike Christie 	struct Scsi_Host *shost;
39665e7ae7bSOr Gerlitz 	int i;
3972261ec3dSMike Christie 	struct iscsi_task *task;
3982261ec3dSMike Christie 	struct iscsi_iser_task *iser_task;
399412eeafaSMike Christie 	struct iser_conn *ib_conn;
40075613521SMike Christie 
401a4804cd6SMike Christie 	shost = iscsi_host_alloc(&iscsi_iser_sht, 0, ISCSI_MAX_CMD_PER_LUN);
40275613521SMike Christie 	if (!shost)
40375613521SMike Christie 		return NULL;
40475613521SMike Christie 	shost->transportt = iscsi_iser_scsi_transport;
40575613521SMike Christie 	shost->max_lun = iscsi_max_lun;
40675613521SMike Christie 	shost->max_id = 0;
40775613521SMike Christie 	shost->max_channel = 0;
40875613521SMike Christie 	shost->max_cmd_len = 16;
40975613521SMike Christie 
410412eeafaSMike Christie 	/*
411412eeafaSMike Christie 	 * older userspace tools (before 2.0-870) did not pass us
412412eeafaSMike Christie 	 * the leading conn's ep so this will be NULL;
413412eeafaSMike Christie 	 */
414412eeafaSMike Christie 	if (ep)
415412eeafaSMike Christie 		ib_conn = ep->dd_data;
416412eeafaSMike Christie 
417412eeafaSMike Christie 	if (iscsi_host_add(shost,
418412eeafaSMike Christie 			   ep ? ib_conn->device->ib_device->dma_device : NULL))
41975613521SMike Christie 		goto free_host;
42075613521SMike Christie 	*hostno = shost->host_no;
42175613521SMike Christie 
4221548271eSMike Christie 	/*
4231548271eSMike Christie 	 * we do not support setting can_queue cmd_per_lun from userspace yet
4241548271eSMike Christie 	 * because we preallocate so many resources
4251548271eSMike Christie 	 */
42675613521SMike Christie 	cls_session = iscsi_session_setup(&iscsi_iser_transport, shost,
4271548271eSMike Christie 					  ISCSI_DEF_XMIT_CMDS_MAX,
4282261ec3dSMike Christie 					  sizeof(struct iscsi_iser_task),
4297970634bSMike Christie 					  initial_cmdsn, 0);
43065e7ae7bSOr Gerlitz 	if (!cls_session)
43175613521SMike Christie 		goto remove_host;
43275613521SMike Christie 	session = cls_session->dd_data;
43365e7ae7bSOr Gerlitz 
4342747fdb2SMike Christie 	shost->can_queue = session->scsi_cmds_max;
43565e7ae7bSOr Gerlitz 	/* libiscsi setup itts, data and pool so just set desc fields */
43665e7ae7bSOr Gerlitz 	for (i = 0; i < session->cmds_max; i++) {
4372261ec3dSMike Christie 		task = session->cmds[i];
4382261ec3dSMike Christie 		iser_task = task->dd_data;
4392261ec3dSMike Christie 		task->hdr = (struct iscsi_cmd *)&iser_task->desc.iscsi_header;
4402261ec3dSMike Christie 		task->hdr_max = sizeof(iser_task->desc.iscsi_header);
44165e7ae7bSOr Gerlitz 	}
44265e7ae7bSOr Gerlitz 	return cls_session;
44375613521SMike Christie 
44475613521SMike Christie remove_host:
445a4804cd6SMike Christie 	iscsi_host_remove(shost);
44675613521SMike Christie free_host:
447a4804cd6SMike Christie 	iscsi_host_free(shost);
44875613521SMike Christie 	return NULL;
44965e7ae7bSOr Gerlitz }
45065e7ae7bSOr Gerlitz 
45165e7ae7bSOr Gerlitz static int
452358ff019SMike Christie iscsi_iser_set_param(struct iscsi_cls_conn *cls_conn,
453358ff019SMike Christie 		     enum iscsi_param param, char *buf, int buflen)
45465e7ae7bSOr Gerlitz {
455358ff019SMike Christie 	int value;
45665e7ae7bSOr Gerlitz 
45765e7ae7bSOr Gerlitz 	switch (param) {
45865e7ae7bSOr Gerlitz 	case ISCSI_PARAM_MAX_RECV_DLENGTH:
45965e7ae7bSOr Gerlitz 		/* TBD */
46065e7ae7bSOr Gerlitz 		break;
46165e7ae7bSOr Gerlitz 	case ISCSI_PARAM_HDRDGST_EN:
462358ff019SMike Christie 		sscanf(buf, "%d", &value);
46365e7ae7bSOr Gerlitz 		if (value) {
46465e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
46565e7ae7bSOr Gerlitz 			return -EPROTO;
46665e7ae7bSOr Gerlitz 		}
46765e7ae7bSOr Gerlitz 		break;
46865e7ae7bSOr Gerlitz 	case ISCSI_PARAM_DATADGST_EN:
469358ff019SMike Christie 		sscanf(buf, "%d", &value);
47065e7ae7bSOr Gerlitz 		if (value) {
47165e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
47265e7ae7bSOr Gerlitz 			return -EPROTO;
47365e7ae7bSOr Gerlitz 		}
47465e7ae7bSOr Gerlitz 		break;
47565e7ae7bSOr Gerlitz 	case ISCSI_PARAM_IFMARKER_EN:
476358ff019SMike Christie 		sscanf(buf, "%d", &value);
47765e7ae7bSOr Gerlitz 		if (value) {
47865e7ae7bSOr Gerlitz 			printk(KERN_ERR "IFMarker wasn't negotiated to No");
47965e7ae7bSOr Gerlitz 			return -EPROTO;
48065e7ae7bSOr Gerlitz 		}
48165e7ae7bSOr Gerlitz 		break;
48265e7ae7bSOr Gerlitz 	case ISCSI_PARAM_OFMARKER_EN:
483358ff019SMike Christie 		sscanf(buf, "%d", &value);
48465e7ae7bSOr Gerlitz 		if (value) {
48565e7ae7bSOr Gerlitz 			printk(KERN_ERR "OFMarker wasn't negotiated to No");
48665e7ae7bSOr Gerlitz 			return -EPROTO;
48765e7ae7bSOr Gerlitz 		}
48865e7ae7bSOr Gerlitz 		break;
48965e7ae7bSOr Gerlitz 	default:
490358ff019SMike Christie 		return iscsi_set_param(cls_conn, param, buf, buflen);
49165e7ae7bSOr Gerlitz 	}
49265e7ae7bSOr Gerlitz 
49365e7ae7bSOr Gerlitz 	return 0;
49465e7ae7bSOr Gerlitz }
49565e7ae7bSOr Gerlitz 
49665e7ae7bSOr Gerlitz static void
49765e7ae7bSOr Gerlitz iscsi_iser_conn_get_stats(struct iscsi_cls_conn *cls_conn, struct iscsi_stats *stats)
49865e7ae7bSOr Gerlitz {
49965e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
50065e7ae7bSOr Gerlitz 
50165e7ae7bSOr Gerlitz 	stats->txdata_octets = conn->txdata_octets;
50265e7ae7bSOr Gerlitz 	stats->rxdata_octets = conn->rxdata_octets;
50365e7ae7bSOr Gerlitz 	stats->scsicmd_pdus = conn->scsicmd_pdus_cnt;
50465e7ae7bSOr Gerlitz 	stats->dataout_pdus = conn->dataout_pdus_cnt;
50565e7ae7bSOr Gerlitz 	stats->scsirsp_pdus = conn->scsirsp_pdus_cnt;
50665e7ae7bSOr Gerlitz 	stats->datain_pdus = conn->datain_pdus_cnt; /* always 0 */
50765e7ae7bSOr Gerlitz 	stats->r2t_pdus = conn->r2t_pdus_cnt; /* always 0 */
50865e7ae7bSOr Gerlitz 	stats->tmfcmd_pdus = conn->tmfcmd_pdus_cnt;
50965e7ae7bSOr Gerlitz 	stats->tmfrsp_pdus = conn->tmfrsp_pdus_cnt;
51087528227SEli Dorfman 	stats->custom_length = 4;
51165e7ae7bSOr Gerlitz 	strcpy(stats->custom[0].desc, "qp_tx_queue_full");
51265e7ae7bSOr Gerlitz 	stats->custom[0].value = 0; /* TB iser_conn->qp_tx_queue_full; */
51365e7ae7bSOr Gerlitz 	strcpy(stats->custom[1].desc, "fmr_map_not_avail");
51465e7ae7bSOr Gerlitz 	stats->custom[1].value = 0; /* TB iser_conn->fmr_map_not_avail */;
51565e7ae7bSOr Gerlitz 	strcpy(stats->custom[2].desc, "eh_abort_cnt");
51665e7ae7bSOr Gerlitz 	stats->custom[2].value = conn->eh_abort_cnt;
51787528227SEli Dorfman 	strcpy(stats->custom[3].desc, "fmr_unalign_cnt");
51887528227SEli Dorfman 	stats->custom[3].value = conn->fmr_unalign_cnt;
51965e7ae7bSOr Gerlitz }
52065e7ae7bSOr Gerlitz 
521412eeafaSMike Christie static struct iscsi_endpoint *
522412eeafaSMike Christie iscsi_iser_ep_connect(struct sockaddr *dst_addr, int non_blocking)
52365e7ae7bSOr Gerlitz {
52465e7ae7bSOr Gerlitz 	int err;
52565e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
526412eeafaSMike Christie 	struct iscsi_endpoint *ep;
52765e7ae7bSOr Gerlitz 
528412eeafaSMike Christie 	ep = iscsi_create_endpoint(sizeof(*ib_conn));
529412eeafaSMike Christie 	if (!ep)
530412eeafaSMike Christie 		return ERR_PTR(-ENOMEM);
53165e7ae7bSOr Gerlitz 
532412eeafaSMike Christie 	ib_conn = ep->dd_data;
533412eeafaSMike Christie 	ib_conn->ep = ep;
534412eeafaSMike Christie 	iser_conn_init(ib_conn);
53565e7ae7bSOr Gerlitz 
536412eeafaSMike Christie 	err = iser_connect(ib_conn, NULL, (struct sockaddr_in *)dst_addr,
537412eeafaSMike Christie 			   non_blocking);
538412eeafaSMike Christie 	if (err) {
539412eeafaSMike Christie 		iscsi_destroy_endpoint(ep);
540412eeafaSMike Christie 		return ERR_PTR(err);
541412eeafaSMike Christie 	}
542412eeafaSMike Christie 	return ep;
54365e7ae7bSOr Gerlitz }
54465e7ae7bSOr Gerlitz 
54565e7ae7bSOr Gerlitz static int
546412eeafaSMike Christie iscsi_iser_ep_poll(struct iscsi_endpoint *ep, int timeout_ms)
54765e7ae7bSOr Gerlitz {
548412eeafaSMike Christie 	struct iser_conn *ib_conn;
54965e7ae7bSOr Gerlitz 	int rc;
55065e7ae7bSOr Gerlitz 
551412eeafaSMike Christie 	ib_conn = ep->dd_data;
55265e7ae7bSOr Gerlitz 	rc = wait_event_interruptible_timeout(ib_conn->wait,
55365e7ae7bSOr Gerlitz 			     ib_conn->state == ISER_CONN_UP,
55465e7ae7bSOr Gerlitz 			     msecs_to_jiffies(timeout_ms));
55565e7ae7bSOr Gerlitz 
55665e7ae7bSOr Gerlitz 	/* if conn establishment failed, return error code to iscsi */
55765e7ae7bSOr Gerlitz 	if (!rc &&
55865e7ae7bSOr Gerlitz 	    (ib_conn->state == ISER_CONN_TERMINATING ||
55965e7ae7bSOr Gerlitz 	     ib_conn->state == ISER_CONN_DOWN))
56065e7ae7bSOr Gerlitz 		rc = -1;
56165e7ae7bSOr Gerlitz 
56265e7ae7bSOr Gerlitz 	iser_err("ib conn %p rc = %d\n", ib_conn, rc);
56365e7ae7bSOr Gerlitz 
56465e7ae7bSOr Gerlitz 	if (rc > 0)
56565e7ae7bSOr Gerlitz 		return 1; /* success, this is the equivalent of POLLOUT */
56665e7ae7bSOr Gerlitz 	else if (!rc)
56765e7ae7bSOr Gerlitz 		return 0; /* timeout */
56865e7ae7bSOr Gerlitz 	else
56965e7ae7bSOr Gerlitz 		return rc; /* signal */
57065e7ae7bSOr Gerlitz }
57165e7ae7bSOr Gerlitz 
57265e7ae7bSOr Gerlitz static void
573412eeafaSMike Christie iscsi_iser_ep_disconnect(struct iscsi_endpoint *ep)
57465e7ae7bSOr Gerlitz {
5751c83469dSMike Christie 	struct iser_conn *ib_conn;
57665e7ae7bSOr Gerlitz 
577412eeafaSMike Christie 	ib_conn = ep->dd_data;
578b40977d9SMike Christie 	if (ib_conn->iser_conn)
579b40977d9SMike Christie 		/*
580b40977d9SMike Christie 		 * Must suspend xmit path if the ep is bound to the
581b40977d9SMike Christie 		 * iscsi_conn, so we know we are not accessing the ib_conn
582b40977d9SMike Christie 		 * when we free it.
583b40977d9SMike Christie 		 *
584b40977d9SMike Christie 		 * This may not be bound if the ep poll failed.
585b40977d9SMike Christie 		 */
586b40977d9SMike Christie 		iscsi_suspend_tx(ib_conn->iser_conn->iscsi_conn);
587b40977d9SMike Christie 
588b40977d9SMike Christie 
58965e7ae7bSOr Gerlitz 	iser_err("ib conn %p state %d\n",ib_conn, ib_conn->state);
59065e7ae7bSOr Gerlitz 	iser_conn_terminate(ib_conn);
59165e7ae7bSOr Gerlitz }
59265e7ae7bSOr Gerlitz 
59365e7ae7bSOr Gerlitz static struct scsi_host_template iscsi_iser_sht = {
5947974392cSMike Christie 	.module                 = THIS_MODULE,
59565e7ae7bSOr Gerlitz 	.name                   = "iSCSI Initiator over iSER, v." DRV_VER,
59665e7ae7bSOr Gerlitz 	.queuecommand           = iscsi_queuecommand,
5976410627eSErez Zilber 	.change_queue_depth	= iscsi_change_queue_depth,
5981548271eSMike Christie 	.can_queue		= ISCSI_DEF_XMIT_CMDS_MAX - 1,
59965e7ae7bSOr Gerlitz 	.sg_tablesize           = ISCSI_ISER_SG_TABLESIZE,
6008072ec2fSErez Zilber 	.max_sectors		= 1024,
60165e7ae7bSOr Gerlitz 	.cmd_per_lun            = ISCSI_MAX_CMD_PER_LUN,
60265e7ae7bSOr Gerlitz 	.eh_abort_handler       = iscsi_eh_abort,
60390c18f3cSErez Zilber 	.eh_device_reset_handler= iscsi_eh_device_reset,
60465e7ae7bSOr Gerlitz 	.eh_host_reset_handler	= iscsi_eh_host_reset,
60565e7ae7bSOr Gerlitz 	.use_clustering         = DISABLE_CLUSTERING,
60665e7ae7bSOr Gerlitz 	.proc_name              = "iscsi_iser",
60765e7ae7bSOr Gerlitz 	.this_id                = -1,
60865e7ae7bSOr Gerlitz };
60965e7ae7bSOr Gerlitz 
61065e7ae7bSOr Gerlitz static struct iscsi_transport iscsi_iser_transport = {
61165e7ae7bSOr Gerlitz 	.owner                  = THIS_MODULE,
61265e7ae7bSOr Gerlitz 	.name                   = "iser",
61365e7ae7bSOr Gerlitz 	.caps                   = CAP_RECOVERY_L0 | CAP_MULTI_R2T,
61465e7ae7bSOr Gerlitz 	.param_mask		= ISCSI_MAX_RECV_DLENGTH |
61565e7ae7bSOr Gerlitz 				  ISCSI_MAX_XMIT_DLENGTH |
61665e7ae7bSOr Gerlitz 				  ISCSI_HDRDGST_EN |
61765e7ae7bSOr Gerlitz 				  ISCSI_DATADGST_EN |
61865e7ae7bSOr Gerlitz 				  ISCSI_INITIAL_R2T_EN |
61965e7ae7bSOr Gerlitz 				  ISCSI_MAX_R2T |
62065e7ae7bSOr Gerlitz 				  ISCSI_IMM_DATA_EN |
62165e7ae7bSOr Gerlitz 				  ISCSI_FIRST_BURST |
62265e7ae7bSOr Gerlitz 				  ISCSI_MAX_BURST |
62365e7ae7bSOr Gerlitz 				  ISCSI_PDU_INORDER_EN |
624358ff019SMike Christie 				  ISCSI_DATASEQ_INORDER_EN |
625358ff019SMike Christie 				  ISCSI_EXP_STATSN |
626358ff019SMike Christie 				  ISCSI_PERSISTENT_PORT |
627358ff019SMike Christie 				  ISCSI_PERSISTENT_ADDRESS |
628b2c64167SMike Christie 				  ISCSI_TARGET_NAME | ISCSI_TPGT |
629b2c64167SMike Christie 				  ISCSI_USERNAME | ISCSI_PASSWORD |
630f6d5180cSMike Christie 				  ISCSI_USERNAME_IN | ISCSI_PASSWORD_IN |
631f6d5180cSMike Christie 				  ISCSI_FAST_ABORT | ISCSI_ABORT_TMO |
63288dfd340SMike Christie 				  ISCSI_PING_TMO | ISCSI_RECV_TMO |
63388dfd340SMike Christie 				  ISCSI_IFACE_NAME | ISCSI_INITIATOR_NAME,
6348ad5781aSMike Christie 	.host_param_mask	= ISCSI_HOST_HWADDRESS |
635d8196ed2SMike Christie 				  ISCSI_HOST_NETDEV_NAME |
6368ad5781aSMike Christie 				  ISCSI_HOST_INITIATOR_NAME,
63765e7ae7bSOr Gerlitz 	/* session management */
63865e7ae7bSOr Gerlitz 	.create_session         = iscsi_iser_session_create,
63975613521SMike Christie 	.destroy_session        = iscsi_iser_session_destroy,
64065e7ae7bSOr Gerlitz 	/* connection management */
64165e7ae7bSOr Gerlitz 	.create_conn            = iscsi_iser_conn_create,
64265e7ae7bSOr Gerlitz 	.bind_conn              = iscsi_iser_conn_bind,
64365e7ae7bSOr Gerlitz 	.destroy_conn           = iscsi_iser_conn_destroy,
644358ff019SMike Christie 	.set_param              = iscsi_iser_set_param,
645358ff019SMike Christie 	.get_conn_param		= iscsi_conn_get_param,
646358ff019SMike Christie 	.get_session_param	= iscsi_session_get_param,
64765e7ae7bSOr Gerlitz 	.start_conn             = iscsi_iser_conn_start,
648b40977d9SMike Christie 	.stop_conn              = iscsi_iser_conn_stop,
6490801c242SMike Christie 	/* iscsi host params */
6500801c242SMike Christie 	.get_host_param		= iscsi_host_get_param,
6510801c242SMike Christie 	.set_host_param		= iscsi_host_set_param,
65265e7ae7bSOr Gerlitz 	/* IO */
65365e7ae7bSOr Gerlitz 	.send_pdu		= iscsi_conn_send_pdu,
65465e7ae7bSOr Gerlitz 	.get_stats		= iscsi_iser_conn_get_stats,
6552747fdb2SMike Christie 	.init_task		= iscsi_iser_task_init,
6562747fdb2SMike Christie 	.xmit_task		= iscsi_iser_task_xmit,
6572747fdb2SMike Christie 	.cleanup_task		= iscsi_iser_cleanup_task,
65865e7ae7bSOr Gerlitz 	/* recovery */
65965e7ae7bSOr Gerlitz 	.session_recovery_timedout = iscsi_session_recovery_timedout,
66065e7ae7bSOr Gerlitz 
66165e7ae7bSOr Gerlitz 	.ep_connect             = iscsi_iser_ep_connect,
66265e7ae7bSOr Gerlitz 	.ep_poll                = iscsi_iser_ep_poll,
66365e7ae7bSOr Gerlitz 	.ep_disconnect          = iscsi_iser_ep_disconnect
66465e7ae7bSOr Gerlitz };
66565e7ae7bSOr Gerlitz 
66665e7ae7bSOr Gerlitz static int __init iser_init(void)
66765e7ae7bSOr Gerlitz {
66865e7ae7bSOr Gerlitz 	int err;
66965e7ae7bSOr Gerlitz 
67065e7ae7bSOr Gerlitz 	iser_dbg("Starting iSER datamover...\n");
67165e7ae7bSOr Gerlitz 
67265e7ae7bSOr Gerlitz 	if (iscsi_max_lun < 1) {
67365e7ae7bSOr Gerlitz 		printk(KERN_ERR "Invalid max_lun value of %u\n", iscsi_max_lun);
67465e7ae7bSOr Gerlitz 		return -EINVAL;
67565e7ae7bSOr Gerlitz 	}
67665e7ae7bSOr Gerlitz 
67765e7ae7bSOr Gerlitz 	memset(&ig, 0, sizeof(struct iser_global));
67865e7ae7bSOr Gerlitz 
67965e7ae7bSOr Gerlitz 	ig.desc_cache = kmem_cache_create("iser_descriptors",
68065e7ae7bSOr Gerlitz 					  sizeof (struct iser_desc),
68165e7ae7bSOr Gerlitz 					  0, SLAB_HWCACHE_ALIGN,
68220c2df83SPaul Mundt 					  NULL);
68365e7ae7bSOr Gerlitz 	if (ig.desc_cache == NULL)
68465e7ae7bSOr Gerlitz 		return -ENOMEM;
68565e7ae7bSOr Gerlitz 
68665e7ae7bSOr Gerlitz 	/* device init is called only after the first addr resolution */
68765e7ae7bSOr Gerlitz 	mutex_init(&ig.device_list_mutex);
68865e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.device_list);
68965e7ae7bSOr Gerlitz 	mutex_init(&ig.connlist_mutex);
69065e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.connlist);
69165e7ae7bSOr Gerlitz 
69275613521SMike Christie 	iscsi_iser_scsi_transport = iscsi_register_transport(
69375613521SMike Christie 							&iscsi_iser_transport);
69475613521SMike Christie 	if (!iscsi_iser_scsi_transport) {
69565e7ae7bSOr Gerlitz 		iser_err("iscsi_register_transport failed\n");
69665e7ae7bSOr Gerlitz 		err = -EINVAL;
69765e7ae7bSOr Gerlitz 		goto register_transport_failure;
69865e7ae7bSOr Gerlitz 	}
69965e7ae7bSOr Gerlitz 
70065e7ae7bSOr Gerlitz 	return 0;
70165e7ae7bSOr Gerlitz 
70265e7ae7bSOr Gerlitz register_transport_failure:
70365e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
70465e7ae7bSOr Gerlitz 
70565e7ae7bSOr Gerlitz 	return err;
70665e7ae7bSOr Gerlitz }
70765e7ae7bSOr Gerlitz 
70865e7ae7bSOr Gerlitz static void __exit iser_exit(void)
70965e7ae7bSOr Gerlitz {
71065e7ae7bSOr Gerlitz 	iser_dbg("Removing iSER datamover...\n");
71165e7ae7bSOr Gerlitz 	iscsi_unregister_transport(&iscsi_iser_transport);
71265e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
71365e7ae7bSOr Gerlitz }
71465e7ae7bSOr Gerlitz 
71565e7ae7bSOr Gerlitz module_init(iser_init);
71665e7ae7bSOr Gerlitz module_exit(iser_exit);
717