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 	uint32_t ret_itt;
10265e7ae7bSOr Gerlitz 	int datalen;
10365e7ae7bSOr Gerlitz 	int ahslen;
10465e7ae7bSOr Gerlitz 
10565e7ae7bSOr Gerlitz 	/* verify PDU length */
10665e7ae7bSOr Gerlitz 	datalen = ntoh24(hdr->dlength);
10765e7ae7bSOr Gerlitz 	if (datalen != rx_data_len) {
10865e7ae7bSOr Gerlitz 		printk(KERN_ERR "iscsi_iser: datalen %d (hdr) != %d (IB) \n",
10965e7ae7bSOr Gerlitz 		       datalen, rx_data_len);
11065e7ae7bSOr Gerlitz 		rc = ISCSI_ERR_DATALEN;
11165e7ae7bSOr Gerlitz 		goto error;
11265e7ae7bSOr Gerlitz 	}
11365e7ae7bSOr Gerlitz 
11465e7ae7bSOr Gerlitz 	/* read AHS */
11565e7ae7bSOr Gerlitz 	ahslen = hdr->hlength * 4;
11665e7ae7bSOr Gerlitz 
11765e7ae7bSOr Gerlitz 	/* verify itt (itt encoding: age+cid+itt) */
11865e7ae7bSOr Gerlitz 	rc = iscsi_verify_itt(conn, hdr, &ret_itt);
11965e7ae7bSOr Gerlitz 
12065e7ae7bSOr Gerlitz 	if (!rc)
12165e7ae7bSOr Gerlitz 		rc = iscsi_complete_pdu(conn, hdr, rx_data, rx_data_len);
12265e7ae7bSOr Gerlitz 
12365e7ae7bSOr Gerlitz 	if (rc && rc != ISCSI_ERR_NO_SCSI_CMD)
12465e7ae7bSOr Gerlitz 		goto error;
12565e7ae7bSOr Gerlitz 
12665e7ae7bSOr Gerlitz 	return;
12765e7ae7bSOr Gerlitz error:
12865e7ae7bSOr Gerlitz 	iscsi_conn_failure(conn, rc);
12965e7ae7bSOr Gerlitz }
13065e7ae7bSOr Gerlitz 
13165e7ae7bSOr Gerlitz 
13265e7ae7bSOr Gerlitz /**
13365e7ae7bSOr Gerlitz  * iscsi_iser_cmd_init - Initialize iSCSI SCSI_READ or SCSI_WRITE commands
13465e7ae7bSOr Gerlitz  *
13565e7ae7bSOr Gerlitz  **/
136a8ac6311SOlaf Kirch static int
13765e7ae7bSOr Gerlitz iscsi_iser_cmd_init(struct iscsi_cmd_task *ctask)
13865e7ae7bSOr Gerlitz {
13965e7ae7bSOr Gerlitz 	struct iscsi_iser_conn     *iser_conn  = ctask->conn->dd_data;
14065e7ae7bSOr Gerlitz 	struct iscsi_iser_cmd_task *iser_ctask = ctask->dd_data;
14165e7ae7bSOr Gerlitz 
14265e7ae7bSOr Gerlitz 	iser_ctask->command_sent = 0;
14365e7ae7bSOr Gerlitz 	iser_ctask->iser_conn    = iser_conn;
14465e7ae7bSOr Gerlitz 	iser_ctask_rdma_init(iser_ctask);
145a8ac6311SOlaf Kirch 	return 0;
14665e7ae7bSOr Gerlitz }
14765e7ae7bSOr Gerlitz 
14865e7ae7bSOr Gerlitz /**
14965e7ae7bSOr Gerlitz  * iscsi_mtask_xmit - xmit management(immediate) task
15065e7ae7bSOr Gerlitz  * @conn: iscsi connection
15165e7ae7bSOr Gerlitz  * @mtask: task management task
15265e7ae7bSOr Gerlitz  *
15365e7ae7bSOr Gerlitz  * Notes:
15465e7ae7bSOr Gerlitz  *	The function can return -EAGAIN in which case caller must
15565e7ae7bSOr Gerlitz  *	call it again later, or recover. '0' return code means successful
15665e7ae7bSOr Gerlitz  *	xmit.
15765e7ae7bSOr Gerlitz  *
15865e7ae7bSOr Gerlitz  **/
15965e7ae7bSOr Gerlitz static int
16065e7ae7bSOr Gerlitz iscsi_iser_mtask_xmit(struct iscsi_conn *conn,
16165e7ae7bSOr Gerlitz 		      struct iscsi_mgmt_task *mtask)
16265e7ae7bSOr Gerlitz {
16365e7ae7bSOr Gerlitz 	int error = 0;
16465e7ae7bSOr Gerlitz 
16565e7ae7bSOr Gerlitz 	debug_scsi("mtask deq [cid %d itt 0x%x]\n", conn->id, mtask->itt);
16665e7ae7bSOr Gerlitz 
16765e7ae7bSOr Gerlitz 	error = iser_send_control(conn, mtask);
16865e7ae7bSOr Gerlitz 
16965e7ae7bSOr Gerlitz 	/* since iser xmits control with zero copy, mtasks can not be recycled
17065e7ae7bSOr Gerlitz 	 * right after sending them.
17165e7ae7bSOr Gerlitz 	 * The recycling scheme is based on whether a response is expected
17265e7ae7bSOr Gerlitz 	 * - if yes, the mtask is recycled at iscsi_complete_pdu
17365e7ae7bSOr Gerlitz 	 * - if no,  the mtask is recycled at iser_snd_completion
17465e7ae7bSOr Gerlitz 	 */
175f0938401SErez Zilber 	if (error && error != -ENOBUFS)
17665e7ae7bSOr Gerlitz 		iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED);
17765e7ae7bSOr Gerlitz 
17865e7ae7bSOr Gerlitz 	return error;
17965e7ae7bSOr Gerlitz }
18065e7ae7bSOr Gerlitz 
18165e7ae7bSOr Gerlitz static int
18265e7ae7bSOr Gerlitz iscsi_iser_ctask_xmit_unsol_data(struct iscsi_conn *conn,
18365e7ae7bSOr Gerlitz 				 struct iscsi_cmd_task *ctask)
18465e7ae7bSOr Gerlitz {
18565e7ae7bSOr Gerlitz 	struct iscsi_data  hdr;
18665e7ae7bSOr Gerlitz 	int error = 0;
18765e7ae7bSOr Gerlitz 
18865e7ae7bSOr Gerlitz 	/* Send data-out PDUs while there's still unsolicited data to send */
18965e7ae7bSOr Gerlitz 	while (ctask->unsol_count > 0) {
190ffd0436eSMike Christie 		iscsi_prep_unsolicit_data_pdu(ctask, &hdr);
19165e7ae7bSOr Gerlitz 		debug_scsi("Sending data-out: itt 0x%x, data count %d\n",
19265e7ae7bSOr Gerlitz 			   hdr.itt, ctask->data_count);
19365e7ae7bSOr Gerlitz 
19465e7ae7bSOr Gerlitz 		/* the buffer description has been passed with the command */
19565e7ae7bSOr Gerlitz 		/* Send the command */
19665e7ae7bSOr Gerlitz 		error = iser_send_data_out(conn, ctask, &hdr);
19765e7ae7bSOr Gerlitz 		if (error) {
19865e7ae7bSOr Gerlitz 			ctask->unsol_datasn--;
19965e7ae7bSOr Gerlitz 			goto iscsi_iser_ctask_xmit_unsol_data_exit;
20065e7ae7bSOr Gerlitz 		}
20165e7ae7bSOr Gerlitz 		ctask->unsol_count -= ctask->data_count;
20265e7ae7bSOr Gerlitz 		debug_scsi("Need to send %d more as data-out PDUs\n",
20365e7ae7bSOr Gerlitz 			   ctask->unsol_count);
20465e7ae7bSOr Gerlitz 	}
20565e7ae7bSOr Gerlitz 
20665e7ae7bSOr Gerlitz iscsi_iser_ctask_xmit_unsol_data_exit:
20765e7ae7bSOr Gerlitz 	return error;
20865e7ae7bSOr Gerlitz }
20965e7ae7bSOr Gerlitz 
21065e7ae7bSOr Gerlitz static int
21165e7ae7bSOr Gerlitz iscsi_iser_ctask_xmit(struct iscsi_conn *conn,
21265e7ae7bSOr Gerlitz 		      struct iscsi_cmd_task *ctask)
21365e7ae7bSOr Gerlitz {
21465e7ae7bSOr Gerlitz 	struct iscsi_iser_cmd_task *iser_ctask = ctask->dd_data;
21565e7ae7bSOr Gerlitz 	int error = 0;
21665e7ae7bSOr Gerlitz 
21777a23c21SMike Christie 	if (ctask->sc->sc_data_direction == DMA_TO_DEVICE) {
218da9c0c77SFUJITA Tomonori 		BUG_ON(scsi_bufflen(ctask->sc) == 0);
21977a23c21SMike Christie 
22077a23c21SMike Christie 		debug_scsi("cmd [itt %x total %d imm %d unsol_data %d\n",
221da9c0c77SFUJITA Tomonori 			   ctask->itt, scsi_bufflen(ctask->sc),
22277a23c21SMike Christie 			   ctask->imm_count, ctask->unsol_count);
22377a23c21SMike Christie 	}
22477a23c21SMike Christie 
22565e7ae7bSOr Gerlitz 	debug_scsi("ctask deq [cid %d itt 0x%x]\n",
22665e7ae7bSOr Gerlitz 		   conn->id, ctask->itt);
22765e7ae7bSOr Gerlitz 
22865e7ae7bSOr Gerlitz 	/* Send the cmd PDU */
22965e7ae7bSOr Gerlitz 	if (!iser_ctask->command_sent) {
23065e7ae7bSOr Gerlitz 		error = iser_send_command(conn, ctask);
23165e7ae7bSOr Gerlitz 		if (error)
23265e7ae7bSOr Gerlitz 			goto iscsi_iser_ctask_xmit_exit;
23365e7ae7bSOr Gerlitz 		iser_ctask->command_sent = 1;
23465e7ae7bSOr Gerlitz 	}
23565e7ae7bSOr Gerlitz 
23665e7ae7bSOr Gerlitz 	/* Send unsolicited data-out PDU(s) if necessary */
23765e7ae7bSOr Gerlitz 	if (ctask->unsol_count)
23865e7ae7bSOr Gerlitz 		error = iscsi_iser_ctask_xmit_unsol_data(conn, ctask);
23965e7ae7bSOr Gerlitz 
24065e7ae7bSOr Gerlitz  iscsi_iser_ctask_xmit_exit:
241f0938401SErez Zilber 	if (error && error != -ENOBUFS)
24265e7ae7bSOr Gerlitz 		iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED);
24365e7ae7bSOr Gerlitz 	return error;
24465e7ae7bSOr Gerlitz }
24565e7ae7bSOr Gerlitz 
24665e7ae7bSOr Gerlitz static void
24765e7ae7bSOr Gerlitz iscsi_iser_cleanup_ctask(struct iscsi_conn *conn, struct iscsi_cmd_task *ctask)
24865e7ae7bSOr Gerlitz {
24965e7ae7bSOr Gerlitz 	struct iscsi_iser_cmd_task *iser_ctask = ctask->dd_data;
25065e7ae7bSOr Gerlitz 
25165e7ae7bSOr Gerlitz 	if (iser_ctask->status == ISER_TASK_STATUS_STARTED) {
25265e7ae7bSOr Gerlitz 		iser_ctask->status = ISER_TASK_STATUS_COMPLETED;
25365e7ae7bSOr Gerlitz 		iser_ctask_rdma_finalize(iser_ctask);
25465e7ae7bSOr Gerlitz 	}
25565e7ae7bSOr Gerlitz }
25665e7ae7bSOr Gerlitz 
25765e7ae7bSOr Gerlitz static struct iser_conn *
25865e7ae7bSOr Gerlitz iscsi_iser_ib_conn_lookup(__u64 ep_handle)
25965e7ae7bSOr Gerlitz {
26065e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
26165e7ae7bSOr Gerlitz 	struct iser_conn *uib_conn = (struct iser_conn *)(unsigned long)ep_handle;
26265e7ae7bSOr Gerlitz 
26365e7ae7bSOr Gerlitz 	mutex_lock(&ig.connlist_mutex);
26465e7ae7bSOr Gerlitz 	list_for_each_entry(ib_conn, &ig.connlist, conn_list) {
26565e7ae7bSOr Gerlitz 		if (ib_conn == uib_conn) {
26665e7ae7bSOr Gerlitz 			mutex_unlock(&ig.connlist_mutex);
26765e7ae7bSOr Gerlitz 			return ib_conn;
26865e7ae7bSOr Gerlitz 		}
26965e7ae7bSOr Gerlitz 	}
27065e7ae7bSOr Gerlitz 	mutex_unlock(&ig.connlist_mutex);
27165e7ae7bSOr Gerlitz 	iser_err("no conn exists for eph %llx\n",(unsigned long long)ep_handle);
27265e7ae7bSOr Gerlitz 	return NULL;
27365e7ae7bSOr Gerlitz }
27465e7ae7bSOr Gerlitz 
27565e7ae7bSOr Gerlitz static struct iscsi_cls_conn *
27665e7ae7bSOr Gerlitz iscsi_iser_conn_create(struct iscsi_cls_session *cls_session, uint32_t conn_idx)
27765e7ae7bSOr Gerlitz {
27865e7ae7bSOr Gerlitz 	struct iscsi_conn *conn;
27965e7ae7bSOr Gerlitz 	struct iscsi_cls_conn *cls_conn;
28065e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn;
28165e7ae7bSOr Gerlitz 
2825d91e209SMike Christie 	cls_conn = iscsi_conn_setup(cls_session, sizeof(*iser_conn), conn_idx);
28365e7ae7bSOr Gerlitz 	if (!cls_conn)
28465e7ae7bSOr Gerlitz 		return NULL;
28565e7ae7bSOr Gerlitz 	conn = cls_conn->dd_data;
28665e7ae7bSOr Gerlitz 
28765e7ae7bSOr Gerlitz 	/*
28865e7ae7bSOr Gerlitz 	 * due to issues with the login code re iser sematics
28965e7ae7bSOr Gerlitz 	 * this not set in iscsi_conn_setup - FIXME
29065e7ae7bSOr Gerlitz 	 */
29165e7ae7bSOr Gerlitz 	conn->max_recv_dlength = 128;
29265e7ae7bSOr Gerlitz 
2935d91e209SMike Christie 	iser_conn = conn->dd_data;
29465e7ae7bSOr Gerlitz 	/* currently this is the only field which need to be initiated */
29565e7ae7bSOr Gerlitz 	rwlock_init(&iser_conn->lock);
29665e7ae7bSOr Gerlitz 
29765e7ae7bSOr Gerlitz 	conn->dd_data = iser_conn;
29865e7ae7bSOr Gerlitz 	iser_conn->iscsi_conn = conn;
29965e7ae7bSOr Gerlitz 
30065e7ae7bSOr Gerlitz 	return cls_conn;
30165e7ae7bSOr Gerlitz }
30265e7ae7bSOr Gerlitz 
30365e7ae7bSOr Gerlitz static void
30465e7ae7bSOr Gerlitz iscsi_iser_conn_destroy(struct iscsi_cls_conn *cls_conn)
30565e7ae7bSOr Gerlitz {
30665e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
30765e7ae7bSOr Gerlitz 	struct iscsi_iser_conn *iser_conn = conn->dd_data;
30865e7ae7bSOr Gerlitz 
30987e8df7aSErez Zilber 	if (iser_conn->ib_conn)
31087e8df7aSErez Zilber 		iser_conn->ib_conn->iser_conn = NULL;
3115d91e209SMike Christie 	iscsi_conn_teardown(cls_conn);
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;
32265e7ae7bSOr Gerlitz 	int error;
32365e7ae7bSOr Gerlitz 
32465e7ae7bSOr Gerlitz 	error = iscsi_conn_bind(cls_session, cls_conn, is_leading);
32565e7ae7bSOr Gerlitz 	if (error)
32665e7ae7bSOr Gerlitz 		return error;
32765e7ae7bSOr Gerlitz 
32865e7ae7bSOr Gerlitz 	/* the transport ep handle comes from user space so it must be
32965e7ae7bSOr Gerlitz 	 * verified against the global ib connections list */
33065e7ae7bSOr Gerlitz 	ib_conn = iscsi_iser_ib_conn_lookup(transport_eph);
33165e7ae7bSOr Gerlitz 	if (!ib_conn) {
33265e7ae7bSOr Gerlitz 		iser_err("can't bind eph %llx\n",
33365e7ae7bSOr Gerlitz 			 (unsigned long long)transport_eph);
33465e7ae7bSOr Gerlitz 		return -EINVAL;
33565e7ae7bSOr Gerlitz 	}
33665e7ae7bSOr Gerlitz 	/* binds the iSER connection retrieved from the previously
33765e7ae7bSOr Gerlitz 	 * connected ep_handle to the iSCSI layer connection. exchanges
33865e7ae7bSOr Gerlitz 	 * connection pointers */
33965e7ae7bSOr Gerlitz 	iser_err("binding iscsi conn %p to iser_conn %p\n",conn,ib_conn);
34065e7ae7bSOr Gerlitz 	iser_conn = conn->dd_data;
34165e7ae7bSOr Gerlitz 	ib_conn->iser_conn = iser_conn;
34265e7ae7bSOr Gerlitz 	iser_conn->ib_conn  = ib_conn;
34365e7ae7bSOr Gerlitz 
34465e7ae7bSOr Gerlitz 	conn->recv_lock = &iser_conn->lock;
34565e7ae7bSOr Gerlitz 
34665e7ae7bSOr Gerlitz 	return 0;
34765e7ae7bSOr Gerlitz }
34865e7ae7bSOr Gerlitz 
34965e7ae7bSOr Gerlitz static int
35065e7ae7bSOr Gerlitz iscsi_iser_conn_start(struct iscsi_cls_conn *cls_conn)
35165e7ae7bSOr Gerlitz {
35265e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
35365e7ae7bSOr Gerlitz 	int err;
35465e7ae7bSOr Gerlitz 
3552e7a7426SErez Zilber 	err = iser_conn_set_full_featured_mode(conn);
35665e7ae7bSOr Gerlitz 	if (err)
35765e7ae7bSOr Gerlitz 		return err;
35865e7ae7bSOr Gerlitz 
3592e7a7426SErez Zilber 	return iscsi_conn_start(cls_conn);
36065e7ae7bSOr Gerlitz }
36165e7ae7bSOr Gerlitz 
36275613521SMike Christie static void iscsi_iser_session_destroy(struct iscsi_cls_session *cls_session)
36375613521SMike Christie {
36475613521SMike Christie 	struct Scsi_Host *shost = iscsi_session_to_shost(cls_session);
36575613521SMike Christie 
366a4804cd6SMike Christie 	iscsi_host_remove(shost);
367a4804cd6SMike Christie 	iscsi_host_free(shost);
36875613521SMike Christie }
36965e7ae7bSOr Gerlitz 
37065e7ae7bSOr Gerlitz static struct iscsi_cls_session *
37175613521SMike Christie iscsi_iser_session_create(struct Scsi_Host *shost,
3721548271eSMike Christie 			  uint16_t cmds_max, uint16_t qdepth,
37365e7ae7bSOr Gerlitz 			  uint32_t initial_cmdsn, uint32_t *hostno)
37465e7ae7bSOr Gerlitz {
37565e7ae7bSOr Gerlitz 	struct iscsi_cls_session *cls_session;
37665e7ae7bSOr Gerlitz 	struct iscsi_session *session;
37765e7ae7bSOr Gerlitz 	int i;
37865e7ae7bSOr Gerlitz 	struct iscsi_cmd_task  *ctask;
37965e7ae7bSOr Gerlitz 	struct iscsi_mgmt_task *mtask;
38065e7ae7bSOr Gerlitz 	struct iscsi_iser_cmd_task *iser_ctask;
38165e7ae7bSOr Gerlitz 	struct iser_desc *desc;
38265e7ae7bSOr Gerlitz 
38375613521SMike Christie 	if (shost) {
38475613521SMike Christie 		printk(KERN_ERR "iscsi_tcp: invalid shost %d.\n",
38575613521SMike Christie 		       shost->host_no);
38675613521SMike Christie 		return NULL;
38775613521SMike Christie 	}
38875613521SMike Christie 
389a4804cd6SMike Christie 	shost = iscsi_host_alloc(&iscsi_iser_sht, 0, ISCSI_MAX_CMD_PER_LUN);
39075613521SMike Christie 	if (!shost)
39175613521SMike Christie 		return NULL;
39275613521SMike Christie 	shost->transportt = iscsi_iser_scsi_transport;
39375613521SMike Christie 	shost->max_lun = iscsi_max_lun;
39475613521SMike Christie 	shost->max_id = 0;
39575613521SMike Christie 	shost->max_channel = 0;
39675613521SMike Christie 	shost->max_cmd_len = 16;
39775613521SMike Christie 
398a4804cd6SMike Christie 	if (iscsi_host_add(shost, NULL))
39975613521SMike Christie 		goto free_host;
40075613521SMike Christie 	*hostno = shost->host_no;
40175613521SMike Christie 
4021548271eSMike Christie 	/*
4031548271eSMike Christie 	 * we do not support setting can_queue cmd_per_lun from userspace yet
4041548271eSMike Christie 	 * because we preallocate so many resources
4051548271eSMike Christie 	 */
40675613521SMike Christie 	cls_session = iscsi_session_setup(&iscsi_iser_transport, shost,
4071548271eSMike Christie 					  ISCSI_DEF_XMIT_CMDS_MAX,
40865e7ae7bSOr Gerlitz 					  sizeof(struct iscsi_iser_cmd_task),
40965e7ae7bSOr Gerlitz 					  sizeof(struct iser_desc),
41075613521SMike Christie 					  initial_cmdsn);
41165e7ae7bSOr Gerlitz 	if (!cls_session)
41275613521SMike Christie 		goto remove_host;
41375613521SMike Christie 	session = cls_session->dd_data;
41465e7ae7bSOr Gerlitz 
41575613521SMike Christie 	shost->can_queue = session->cmds_max;
41665e7ae7bSOr Gerlitz 	/* libiscsi setup itts, data and pool so just set desc fields */
41765e7ae7bSOr Gerlitz 	for (i = 0; i < session->cmds_max; i++) {
41865e7ae7bSOr Gerlitz 		ctask      = session->cmds[i];
41965e7ae7bSOr Gerlitz 		iser_ctask = ctask->dd_data;
42065e7ae7bSOr Gerlitz 		ctask->hdr = (struct iscsi_cmd *)&iser_ctask->desc.iscsi_header;
42138ad03deSBoaz Harrosh 		ctask->hdr_max = sizeof(iser_ctask->desc.iscsi_header);
42265e7ae7bSOr Gerlitz 	}
42365e7ae7bSOr Gerlitz 
42465e7ae7bSOr Gerlitz 	for (i = 0; i < session->mgmtpool_max; i++) {
42565e7ae7bSOr Gerlitz 		mtask      = session->mgmt_cmds[i];
42665e7ae7bSOr Gerlitz 		desc       = mtask->dd_data;
42765e7ae7bSOr Gerlitz 		mtask->hdr = &desc->iscsi_header;
42865e7ae7bSOr Gerlitz 		desc->data = mtask->data;
42965e7ae7bSOr Gerlitz 	}
43065e7ae7bSOr Gerlitz 
43165e7ae7bSOr Gerlitz 	return cls_session;
43275613521SMike Christie 
43375613521SMike Christie remove_host:
434a4804cd6SMike Christie 	iscsi_host_remove(shost);
43575613521SMike Christie free_host:
436a4804cd6SMike Christie 	iscsi_host_free(shost);
43775613521SMike Christie 	return NULL;
43865e7ae7bSOr Gerlitz }
43965e7ae7bSOr Gerlitz 
44065e7ae7bSOr Gerlitz static int
441358ff019SMike Christie iscsi_iser_set_param(struct iscsi_cls_conn *cls_conn,
442358ff019SMike Christie 		     enum iscsi_param param, char *buf, int buflen)
44365e7ae7bSOr Gerlitz {
444358ff019SMike Christie 	int value;
44565e7ae7bSOr Gerlitz 
44665e7ae7bSOr Gerlitz 	switch (param) {
44765e7ae7bSOr Gerlitz 	case ISCSI_PARAM_MAX_RECV_DLENGTH:
44865e7ae7bSOr Gerlitz 		/* TBD */
44965e7ae7bSOr Gerlitz 		break;
45065e7ae7bSOr Gerlitz 	case ISCSI_PARAM_HDRDGST_EN:
451358ff019SMike Christie 		sscanf(buf, "%d", &value);
45265e7ae7bSOr Gerlitz 		if (value) {
45365e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
45465e7ae7bSOr Gerlitz 			return -EPROTO;
45565e7ae7bSOr Gerlitz 		}
45665e7ae7bSOr Gerlitz 		break;
45765e7ae7bSOr Gerlitz 	case ISCSI_PARAM_DATADGST_EN:
458358ff019SMike Christie 		sscanf(buf, "%d", &value);
45965e7ae7bSOr Gerlitz 		if (value) {
46065e7ae7bSOr Gerlitz 			printk(KERN_ERR "DataDigest wasn't negotiated to None");
46165e7ae7bSOr Gerlitz 			return -EPROTO;
46265e7ae7bSOr Gerlitz 		}
46365e7ae7bSOr Gerlitz 		break;
46465e7ae7bSOr Gerlitz 	case ISCSI_PARAM_IFMARKER_EN:
465358ff019SMike Christie 		sscanf(buf, "%d", &value);
46665e7ae7bSOr Gerlitz 		if (value) {
46765e7ae7bSOr Gerlitz 			printk(KERN_ERR "IFMarker wasn't negotiated to No");
46865e7ae7bSOr Gerlitz 			return -EPROTO;
46965e7ae7bSOr Gerlitz 		}
47065e7ae7bSOr Gerlitz 		break;
47165e7ae7bSOr Gerlitz 	case ISCSI_PARAM_OFMARKER_EN:
472358ff019SMike Christie 		sscanf(buf, "%d", &value);
47365e7ae7bSOr Gerlitz 		if (value) {
47465e7ae7bSOr Gerlitz 			printk(KERN_ERR "OFMarker wasn't negotiated to No");
47565e7ae7bSOr Gerlitz 			return -EPROTO;
47665e7ae7bSOr Gerlitz 		}
47765e7ae7bSOr Gerlitz 		break;
47865e7ae7bSOr Gerlitz 	default:
479358ff019SMike Christie 		return iscsi_set_param(cls_conn, param, buf, buflen);
48065e7ae7bSOr Gerlitz 	}
48165e7ae7bSOr Gerlitz 
48265e7ae7bSOr Gerlitz 	return 0;
48365e7ae7bSOr Gerlitz }
48465e7ae7bSOr Gerlitz 
48565e7ae7bSOr Gerlitz static void
48665e7ae7bSOr Gerlitz iscsi_iser_conn_get_stats(struct iscsi_cls_conn *cls_conn, struct iscsi_stats *stats)
48765e7ae7bSOr Gerlitz {
48865e7ae7bSOr Gerlitz 	struct iscsi_conn *conn = cls_conn->dd_data;
48965e7ae7bSOr Gerlitz 
49065e7ae7bSOr Gerlitz 	stats->txdata_octets = conn->txdata_octets;
49165e7ae7bSOr Gerlitz 	stats->rxdata_octets = conn->rxdata_octets;
49265e7ae7bSOr Gerlitz 	stats->scsicmd_pdus = conn->scsicmd_pdus_cnt;
49365e7ae7bSOr Gerlitz 	stats->dataout_pdus = conn->dataout_pdus_cnt;
49465e7ae7bSOr Gerlitz 	stats->scsirsp_pdus = conn->scsirsp_pdus_cnt;
49565e7ae7bSOr Gerlitz 	stats->datain_pdus = conn->datain_pdus_cnt; /* always 0 */
49665e7ae7bSOr Gerlitz 	stats->r2t_pdus = conn->r2t_pdus_cnt; /* always 0 */
49765e7ae7bSOr Gerlitz 	stats->tmfcmd_pdus = conn->tmfcmd_pdus_cnt;
49865e7ae7bSOr Gerlitz 	stats->tmfrsp_pdus = conn->tmfrsp_pdus_cnt;
49987528227SEli Dorfman 	stats->custom_length = 4;
50065e7ae7bSOr Gerlitz 	strcpy(stats->custom[0].desc, "qp_tx_queue_full");
50165e7ae7bSOr Gerlitz 	stats->custom[0].value = 0; /* TB iser_conn->qp_tx_queue_full; */
50265e7ae7bSOr Gerlitz 	strcpy(stats->custom[1].desc, "fmr_map_not_avail");
50365e7ae7bSOr Gerlitz 	stats->custom[1].value = 0; /* TB iser_conn->fmr_map_not_avail */;
50465e7ae7bSOr Gerlitz 	strcpy(stats->custom[2].desc, "eh_abort_cnt");
50565e7ae7bSOr Gerlitz 	stats->custom[2].value = conn->eh_abort_cnt;
50687528227SEli Dorfman 	strcpy(stats->custom[3].desc, "fmr_unalign_cnt");
50787528227SEli Dorfman 	stats->custom[3].value = conn->fmr_unalign_cnt;
50865e7ae7bSOr Gerlitz }
50965e7ae7bSOr Gerlitz 
51065e7ae7bSOr Gerlitz static int
51165e7ae7bSOr Gerlitz iscsi_iser_ep_connect(struct sockaddr *dst_addr, int non_blocking,
51265e7ae7bSOr Gerlitz 		      __u64 *ep_handle)
51365e7ae7bSOr Gerlitz {
51465e7ae7bSOr Gerlitz 	int err;
51565e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn;
51665e7ae7bSOr Gerlitz 
51765e7ae7bSOr Gerlitz 	err = iser_conn_init(&ib_conn);
51865e7ae7bSOr Gerlitz 	if (err)
51965e7ae7bSOr Gerlitz 		goto out;
52065e7ae7bSOr Gerlitz 
52165e7ae7bSOr Gerlitz 	err = iser_connect(ib_conn, NULL, (struct sockaddr_in *)dst_addr, non_blocking);
52265e7ae7bSOr Gerlitz 	if (!err)
52365e7ae7bSOr Gerlitz 		*ep_handle = (__u64)(unsigned long)ib_conn;
52465e7ae7bSOr Gerlitz 
52565e7ae7bSOr Gerlitz out:
52665e7ae7bSOr Gerlitz 	return err;
52765e7ae7bSOr Gerlitz }
52865e7ae7bSOr Gerlitz 
52965e7ae7bSOr Gerlitz static int
53065e7ae7bSOr Gerlitz iscsi_iser_ep_poll(__u64 ep_handle, int timeout_ms)
53165e7ae7bSOr Gerlitz {
53265e7ae7bSOr Gerlitz 	struct iser_conn *ib_conn = iscsi_iser_ib_conn_lookup(ep_handle);
53365e7ae7bSOr Gerlitz 	int rc;
53465e7ae7bSOr Gerlitz 
53565e7ae7bSOr Gerlitz 	if (!ib_conn)
53665e7ae7bSOr Gerlitz 		return -EINVAL;
53765e7ae7bSOr Gerlitz 
53865e7ae7bSOr Gerlitz 	rc = wait_event_interruptible_timeout(ib_conn->wait,
53965e7ae7bSOr Gerlitz 			     ib_conn->state == ISER_CONN_UP,
54065e7ae7bSOr Gerlitz 			     msecs_to_jiffies(timeout_ms));
54165e7ae7bSOr Gerlitz 
54265e7ae7bSOr Gerlitz 	/* if conn establishment failed, return error code to iscsi */
54365e7ae7bSOr Gerlitz 	if (!rc &&
54465e7ae7bSOr Gerlitz 	    (ib_conn->state == ISER_CONN_TERMINATING ||
54565e7ae7bSOr Gerlitz 	     ib_conn->state == ISER_CONN_DOWN))
54665e7ae7bSOr Gerlitz 		rc = -1;
54765e7ae7bSOr Gerlitz 
54865e7ae7bSOr Gerlitz 	iser_err("ib conn %p rc = %d\n", ib_conn, rc);
54965e7ae7bSOr Gerlitz 
55065e7ae7bSOr Gerlitz 	if (rc > 0)
55165e7ae7bSOr Gerlitz 		return 1; /* success, this is the equivalent of POLLOUT */
55265e7ae7bSOr Gerlitz 	else if (!rc)
55365e7ae7bSOr Gerlitz 		return 0; /* timeout */
55465e7ae7bSOr Gerlitz 	else
55565e7ae7bSOr Gerlitz 		return rc; /* signal */
55665e7ae7bSOr Gerlitz }
55765e7ae7bSOr Gerlitz 
55865e7ae7bSOr Gerlitz static void
55965e7ae7bSOr Gerlitz iscsi_iser_ep_disconnect(__u64 ep_handle)
56065e7ae7bSOr Gerlitz {
5611c83469dSMike Christie 	struct iser_conn *ib_conn;
56265e7ae7bSOr Gerlitz 
5631c83469dSMike Christie 	ib_conn = iscsi_iser_ib_conn_lookup(ep_handle);
56465e7ae7bSOr Gerlitz 	if (!ib_conn)
56565e7ae7bSOr Gerlitz 		return;
56665e7ae7bSOr Gerlitz 
56765e7ae7bSOr Gerlitz 	iser_err("ib conn %p state %d\n",ib_conn, ib_conn->state);
56865e7ae7bSOr Gerlitz 	iser_conn_terminate(ib_conn);
56965e7ae7bSOr Gerlitz }
57065e7ae7bSOr Gerlitz 
57165e7ae7bSOr Gerlitz static struct scsi_host_template iscsi_iser_sht = {
5727974392cSMike Christie 	.module                 = THIS_MODULE,
57365e7ae7bSOr Gerlitz 	.name                   = "iSCSI Initiator over iSER, v." DRV_VER,
57465e7ae7bSOr Gerlitz 	.queuecommand           = iscsi_queuecommand,
5756410627eSErez Zilber 	.change_queue_depth	= iscsi_change_queue_depth,
5761548271eSMike Christie 	.can_queue		= ISCSI_DEF_XMIT_CMDS_MAX - 1,
57765e7ae7bSOr Gerlitz 	.sg_tablesize           = ISCSI_ISER_SG_TABLESIZE,
5788072ec2fSErez Zilber 	.max_sectors		= 1024,
57965e7ae7bSOr Gerlitz 	.cmd_per_lun            = ISCSI_MAX_CMD_PER_LUN,
58065e7ae7bSOr Gerlitz 	.eh_abort_handler       = iscsi_eh_abort,
58190c18f3cSErez Zilber 	.eh_device_reset_handler= iscsi_eh_device_reset,
58265e7ae7bSOr Gerlitz 	.eh_host_reset_handler	= iscsi_eh_host_reset,
58365e7ae7bSOr Gerlitz 	.use_clustering         = DISABLE_CLUSTERING,
58465e7ae7bSOr Gerlitz 	.proc_name              = "iscsi_iser",
58565e7ae7bSOr Gerlitz 	.this_id                = -1,
58665e7ae7bSOr Gerlitz };
58765e7ae7bSOr Gerlitz 
58865e7ae7bSOr Gerlitz static struct iscsi_transport iscsi_iser_transport = {
58965e7ae7bSOr Gerlitz 	.owner                  = THIS_MODULE,
59065e7ae7bSOr Gerlitz 	.name                   = "iser",
59165e7ae7bSOr Gerlitz 	.caps                   = CAP_RECOVERY_L0 | CAP_MULTI_R2T,
59265e7ae7bSOr Gerlitz 	.param_mask		= ISCSI_MAX_RECV_DLENGTH |
59365e7ae7bSOr Gerlitz 				  ISCSI_MAX_XMIT_DLENGTH |
59465e7ae7bSOr Gerlitz 				  ISCSI_HDRDGST_EN |
59565e7ae7bSOr Gerlitz 				  ISCSI_DATADGST_EN |
59665e7ae7bSOr Gerlitz 				  ISCSI_INITIAL_R2T_EN |
59765e7ae7bSOr Gerlitz 				  ISCSI_MAX_R2T |
59865e7ae7bSOr Gerlitz 				  ISCSI_IMM_DATA_EN |
59965e7ae7bSOr Gerlitz 				  ISCSI_FIRST_BURST |
60065e7ae7bSOr Gerlitz 				  ISCSI_MAX_BURST |
60165e7ae7bSOr Gerlitz 				  ISCSI_PDU_INORDER_EN |
602358ff019SMike Christie 				  ISCSI_DATASEQ_INORDER_EN |
603358ff019SMike Christie 				  ISCSI_EXP_STATSN |
604358ff019SMike Christie 				  ISCSI_PERSISTENT_PORT |
605358ff019SMike Christie 				  ISCSI_PERSISTENT_ADDRESS |
606b2c64167SMike Christie 				  ISCSI_TARGET_NAME | ISCSI_TPGT |
607b2c64167SMike Christie 				  ISCSI_USERNAME | ISCSI_PASSWORD |
608f6d5180cSMike Christie 				  ISCSI_USERNAME_IN | ISCSI_PASSWORD_IN |
609f6d5180cSMike Christie 				  ISCSI_FAST_ABORT | ISCSI_ABORT_TMO |
610f6d5180cSMike Christie 				  ISCSI_PING_TMO | ISCSI_RECV_TMO,
6118ad5781aSMike Christie 	.host_param_mask	= ISCSI_HOST_HWADDRESS |
612d8196ed2SMike Christie 				  ISCSI_HOST_NETDEV_NAME |
6138ad5781aSMike Christie 				  ISCSI_HOST_INITIATOR_NAME,
61465e7ae7bSOr Gerlitz 	/* session management */
61565e7ae7bSOr Gerlitz 	.create_session         = iscsi_iser_session_create,
61675613521SMike Christie 	.destroy_session        = iscsi_iser_session_destroy,
61765e7ae7bSOr Gerlitz 	/* connection management */
61865e7ae7bSOr Gerlitz 	.create_conn            = iscsi_iser_conn_create,
61965e7ae7bSOr Gerlitz 	.bind_conn              = iscsi_iser_conn_bind,
62065e7ae7bSOr Gerlitz 	.destroy_conn           = iscsi_iser_conn_destroy,
621358ff019SMike Christie 	.set_param              = iscsi_iser_set_param,
622358ff019SMike Christie 	.get_conn_param		= iscsi_conn_get_param,
623358ff019SMike Christie 	.get_session_param	= iscsi_session_get_param,
62465e7ae7bSOr Gerlitz 	.start_conn             = iscsi_iser_conn_start,
62565e7ae7bSOr Gerlitz 	.stop_conn              = iscsi_conn_stop,
6260801c242SMike Christie 	/* iscsi host params */
6270801c242SMike Christie 	.get_host_param		= iscsi_host_get_param,
6280801c242SMike Christie 	.set_host_param		= iscsi_host_set_param,
62965e7ae7bSOr Gerlitz 	/* IO */
63065e7ae7bSOr Gerlitz 	.send_pdu		= iscsi_conn_send_pdu,
63165e7ae7bSOr Gerlitz 	.get_stats		= iscsi_iser_conn_get_stats,
63265e7ae7bSOr Gerlitz 	.init_cmd_task		= iscsi_iser_cmd_init,
63365e7ae7bSOr Gerlitz 	.xmit_cmd_task		= iscsi_iser_ctask_xmit,
63465e7ae7bSOr Gerlitz 	.xmit_mgmt_task		= iscsi_iser_mtask_xmit,
63565e7ae7bSOr Gerlitz 	.cleanup_cmd_task	= iscsi_iser_cleanup_ctask,
63665e7ae7bSOr Gerlitz 	/* recovery */
63765e7ae7bSOr Gerlitz 	.session_recovery_timedout = iscsi_session_recovery_timedout,
63865e7ae7bSOr Gerlitz 
63965e7ae7bSOr Gerlitz 	.ep_connect             = iscsi_iser_ep_connect,
64065e7ae7bSOr Gerlitz 	.ep_poll                = iscsi_iser_ep_poll,
64165e7ae7bSOr Gerlitz 	.ep_disconnect          = iscsi_iser_ep_disconnect
64265e7ae7bSOr Gerlitz };
64365e7ae7bSOr Gerlitz 
64465e7ae7bSOr Gerlitz static int __init iser_init(void)
64565e7ae7bSOr Gerlitz {
64665e7ae7bSOr Gerlitz 	int err;
64765e7ae7bSOr Gerlitz 
64865e7ae7bSOr Gerlitz 	iser_dbg("Starting iSER datamover...\n");
64965e7ae7bSOr Gerlitz 
65065e7ae7bSOr Gerlitz 	if (iscsi_max_lun < 1) {
65165e7ae7bSOr Gerlitz 		printk(KERN_ERR "Invalid max_lun value of %u\n", iscsi_max_lun);
65265e7ae7bSOr Gerlitz 		return -EINVAL;
65365e7ae7bSOr Gerlitz 	}
65465e7ae7bSOr Gerlitz 
65565e7ae7bSOr Gerlitz 	memset(&ig, 0, sizeof(struct iser_global));
65665e7ae7bSOr Gerlitz 
65765e7ae7bSOr Gerlitz 	ig.desc_cache = kmem_cache_create("iser_descriptors",
65865e7ae7bSOr Gerlitz 					  sizeof (struct iser_desc),
65965e7ae7bSOr Gerlitz 					  0, SLAB_HWCACHE_ALIGN,
66020c2df83SPaul Mundt 					  NULL);
66165e7ae7bSOr Gerlitz 	if (ig.desc_cache == NULL)
66265e7ae7bSOr Gerlitz 		return -ENOMEM;
66365e7ae7bSOr Gerlitz 
66465e7ae7bSOr Gerlitz 	/* device init is called only after the first addr resolution */
66565e7ae7bSOr Gerlitz 	mutex_init(&ig.device_list_mutex);
66665e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.device_list);
66765e7ae7bSOr Gerlitz 	mutex_init(&ig.connlist_mutex);
66865e7ae7bSOr Gerlitz 	INIT_LIST_HEAD(&ig.connlist);
66965e7ae7bSOr Gerlitz 
67075613521SMike Christie 	iscsi_iser_scsi_transport = iscsi_register_transport(
67175613521SMike Christie 							&iscsi_iser_transport);
67275613521SMike Christie 	if (!iscsi_iser_scsi_transport) {
67365e7ae7bSOr Gerlitz 		iser_err("iscsi_register_transport failed\n");
67465e7ae7bSOr Gerlitz 		err = -EINVAL;
67565e7ae7bSOr Gerlitz 		goto register_transport_failure;
67665e7ae7bSOr Gerlitz 	}
67765e7ae7bSOr Gerlitz 
67865e7ae7bSOr Gerlitz 	return 0;
67965e7ae7bSOr Gerlitz 
68065e7ae7bSOr Gerlitz register_transport_failure:
68165e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
68265e7ae7bSOr Gerlitz 
68365e7ae7bSOr Gerlitz 	return err;
68465e7ae7bSOr Gerlitz }
68565e7ae7bSOr Gerlitz 
68665e7ae7bSOr Gerlitz static void __exit iser_exit(void)
68765e7ae7bSOr Gerlitz {
68865e7ae7bSOr Gerlitz 	iser_dbg("Removing iSER datamover...\n");
68965e7ae7bSOr Gerlitz 	iscsi_unregister_transport(&iscsi_iser_transport);
69065e7ae7bSOr Gerlitz 	kmem_cache_destroy(ig.desc_cache);
69165e7ae7bSOr Gerlitz }
69265e7ae7bSOr Gerlitz 
69365e7ae7bSOr Gerlitz module_init(iser_init);
69465e7ae7bSOr Gerlitz module_exit(iser_exit);
695