forked from ~ljy/RK356X_SDK_RELEASE
blame | history | patch | commit | commitdiff
hc
2024-10-09 244b2c5ca8b14627e4a17755e5922221e121c771 
 kernel/drivers/scsi/qla2xxx/tcm_qla2xxx.c
....@@ -1,3 +1,4 @@
1
+// SPDX-License-Identifier: GPL-2.0-or-later
12 /*******************************************************************************
23  * This file contains tcm implementation using v4 configfs fabric infrastructure
34  * for QLogic target mode HBAs
....@@ -11,35 +12,20 @@
1112  *
1213  * Copyright (c) 2010 Cisco Systems, Inc
1314  *
14
- * This program is free software; you can redistribute it and/or modify
15
- * it under the terms of the GNU General Public License as published by
16
- * the Free Software Foundation; either version 2 of the License, or
17
- * (at your option) any later version.
18
- *
19
- * This program is distributed in the hope that it will be useful,
20
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
21
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
22
- * GNU General Public License for more details.
2315  ****************************************************************************/
2416 
2517 
2618 #include <linux/module.h>
27
-#include <linux/moduleparam.h>
2819 #include <linux/utsname.h>
2920 #include <linux/vmalloc.h>
30
-#include <linux/init.h>
3121 #include <linux/list.h>
3222 #include <linux/slab.h>
33
-#include <linux/kthread.h>
3423 #include <linux/types.h>
3524 #include <linux/string.h>
3625 #include <linux/configfs.h>
3726 #include <linux/ctype.h>
3827 #include <asm/unaligned.h>
39
-#include <scsi/scsi.h>
4028 #include <scsi/scsi_host.h>
41
-#include <scsi/scsi_device.h>
42
-#include <scsi/scsi_cmnd.h>
4329 #include <target/target_core_base.h>
4430 #include <target/target_core_fabric.h>
4531 
....@@ -108,11 +94,6 @@
10894 		b[0], b[1], b[2], b[3], b[4], b[5], b[6], b[7]);
10995 }
11096 
111
-static char *tcm_qla2xxx_get_fabric_name(void)
112
-{
113
-	return "qla2xxx";
114
-}
115
-
11697 /*
11798  * From drivers/scsi/scsi_transport_fc.c:fc_parse_wwn
11899  */
....@@ -176,11 +157,6 @@
176157 		return rc;
177158 
178159 	return 0;
179
-}
180
-
181
-static char *tcm_qla2xxx_npiv_get_fabric_name(void)
182
-{
183
-	return "qla2xxx_npiv";
184160 }
185161 
186162 static char *tcm_qla2xxx_get_fabric_wwn(struct se_portal_group *se_tpg)
....@@ -270,6 +246,8 @@
270246  */
271247 static void tcm_qla2xxx_free_mcmd(struct qla_tgt_mgmt_cmd *mcmd)
272248 {
249
+	if (!mcmd)
250
+		return;
273251 	INIT_WORK(&mcmd->free_work, tcm_qla2xxx_complete_mcmd);
274252 	queue_work(tcm_qla2xxx_free_wq, &mcmd->free_work);
275253 }
....@@ -282,9 +260,35 @@
282260 
283261 	WARN_ON(cmd->trc_flags & TRC_CMD_FREE);
284262 
263
+	/* To do: protect all tgt_counters manipulations with proper locking. */
285264 	cmd->qpair->tgt_counters.qla_core_ret_sta_ctio++;
286265 	cmd->trc_flags |= TRC_CMD_FREE;
266
+	cmd->cmd_sent_to_fw = 0;
267
+
287268 	transport_generic_free_cmd(&cmd->se_cmd, 0);
269
+}
270
+
271
+static struct qla_tgt_cmd *tcm_qla2xxx_get_cmd(struct fc_port *sess)
272
+{
273
+	struct se_session *se_sess = sess->se_sess;
274
+	struct qla_tgt_cmd *cmd;
275
+	int tag, cpu;
276
+
277
+	tag = sbitmap_queue_get(&se_sess->sess_tag_pool, &cpu);
278
+	if (tag < 0)
279
+		return NULL;
280
+
281
+	cmd = &((struct qla_tgt_cmd *)se_sess->sess_cmd_map)[tag];
282
+	memset(cmd, 0, sizeof(struct qla_tgt_cmd));
283
+	cmd->se_cmd.map_tag = tag;
284
+	cmd->se_cmd.map_cpu = cpu;
285
+
286
+	return cmd;
287
+}
288
+
289
+static void tcm_qla2xxx_rel_cmd(struct qla_tgt_cmd *cmd)
290
+{
291
+	target_free_tag(cmd->sess->se_sess, &cmd->se_cmd);
288292 }
289293 
290294 /*
....@@ -332,8 +336,11 @@
332336 		qlt_free_mcmd(mcmd);
333337 		return;
334338 	}
335
-
336339 	cmd = container_of(se_cmd, struct qla_tgt_cmd, se_cmd);
340
+
341
+	if (WARN_ON(cmd->cmd_sent_to_fw))
342
+		return;
343
+
337344 	qlt_free_cmd(cmd);
338345 }
339346 
....@@ -366,6 +373,7 @@
366373 	target_sess_cmd_list_set_waiting(se_sess);
367374 	spin_unlock_irqrestore(&vha->hw->tgt.sess_lock, flags);
368375 
376
+	sess->explicit_logout = 1;
369377 	tcm_qla2xxx_put_sess(sess);
370378 }
371379 
....@@ -407,30 +415,10 @@
407415 	se_cmd->pi_err = 0;
408416 
409417 	/*
410
-	 * qla_target.c:qlt_rdy_to_xfer() will call pci_map_sg() to setup
418
+	 * qla_target.c:qlt_rdy_to_xfer() will call dma_map_sg() to setup
411419 	 * the SGL mappings into PCIe memory for incoming FCP WRITE data.
412420 	 */
413421 	return qlt_rdy_to_xfer(cmd);
414
-}
415
-
416
-static int tcm_qla2xxx_write_pending_status(struct se_cmd *se_cmd)
417
-{
418
-	unsigned long flags;
419
-	/*
420
-	 * Check for WRITE_PENDING status to determine if we need to wait for
421
-	 * CTIO aborts to be posted via hardware in tcm_qla2xxx_handle_data().
422
-	 */
423
-	spin_lock_irqsave(&se_cmd->t_state_lock, flags);
424
-	if (se_cmd->t_state == TRANSPORT_WRITE_PENDING ||
425
-	    se_cmd->t_state == TRANSPORT_COMPLETE_QF_WP) {
426
-		spin_unlock_irqrestore(&se_cmd->t_state_lock, flags);
427
-		wait_for_completion_timeout(&se_cmd->t_transport_stop_comp,
428
-						50);
429
-		return 0;
430
-	}
431
-	spin_unlock_irqrestore(&se_cmd->t_state_lock, flags);
432
-
433
-	return 0;
434422 }
435423 
436424 static void tcm_qla2xxx_set_default_node_attrs(struct se_node_acl *nacl)
....@@ -507,18 +495,15 @@
507495 	 * Otherwise return an exception via CHECK_CONDITION status.
508496 	 */
509497 	cmd->cmd_in_wq = 0;
498
+	cmd->cmd_sent_to_fw = 0;
499
+	if (cmd->aborted) {
500
+		transport_generic_request_failure(&cmd->se_cmd,
501
+			TCM_CHECK_CONDITION_ABORT_CMD);
502
+		return;
503
+	}
510504 
511505 	cmd->qpair->tgt_counters.qla_core_ret_ctio++;
512506 	if (!cmd->write_data_transferred) {
513
-		/*
514
-		 * Check if se_cmd has already been aborted via LUN_RESET, and
515
-		 * waiting upon completion in tcm_qla2xxx_write_pending_status()
516
-		 */
517
-		if (cmd->se_cmd.transport_state & CMD_T_ABORTED) {
518
-			complete(&cmd->se_cmd.t_transport_stop_comp);
519
-			return;
520
-		}
521
-
522507 		switch (cmd->dif_err_code) {
523508 		case DIF_ERR_GRD:
524509 			cmd->se_cmd.pi_err =
....@@ -861,7 +846,7 @@
861846 	struct tcm_qla2xxx_tpg *tpg = container_of(se_tpg,		\
862847 			struct tcm_qla2xxx_tpg, se_tpg);		\
863848 									\
864
-	return sprintf(page, "%u\n", tpg->tpg_attrib.name);	\
849
+	return sprintf(page, "%d\n", tpg->tpg_attrib.name);	\
865850 }									\
866851 									\
867852 static ssize_t tcm_qla2xxx_tpg_attrib_##name##_store(			\
....@@ -1179,9 +1164,8 @@
11791164 /*
11801165  * Expected to be called with struct qla_hw_data->tgt.sess_lock held
11811166  */
1182
-static struct fc_port *tcm_qla2xxx_find_sess_by_s_id(
1183
-	scsi_qla_host_t *vha,
1184
-	const uint8_t *s_id)
1167
+static struct fc_port *tcm_qla2xxx_find_sess_by_s_id(scsi_qla_host_t *vha,
1168
+						     const be_id_t s_id)
11851169 {
11861170 	struct tcm_qla2xxx_lport *lport;
11871171 	struct se_node_acl *se_nacl;
....@@ -1224,7 +1208,7 @@
12241208 	struct tcm_qla2xxx_nacl *nacl,
12251209 	struct se_session *se_sess,
12261210 	struct fc_port *fc_port,
1227
-	uint8_t *s_id)
1211
+	be_id_t s_id)
12281212 {
12291213 	u32 key;
12301214 	void *slot;
....@@ -1391,14 +1375,9 @@
13911375 		struct tcm_qla2xxx_nacl *nacl, struct fc_port *sess)
13921376 {
13931377 	struct se_session *se_sess = sess->se_sess;
1394
-	unsigned char be_sid[3];
1395
-
1396
-	be_sid[0] = sess->d_id.b.domain;
1397
-	be_sid[1] = sess->d_id.b.area;
1398
-	be_sid[2] = sess->d_id.b.al_pa;
13991378 
14001379 	tcm_qla2xxx_set_sess_by_s_id(lport, NULL, nacl, se_sess,
1401
-				sess, be_sid);
1380
+				     sess, port_id_to_be_id(sess->d_id));
14021381 	tcm_qla2xxx_set_sess_by_loop_id(lport, NULL, nacl, se_sess,
14031382 				sess, sess->loop_id);
14041383 }
....@@ -1444,19 +1423,14 @@
14441423 	struct fc_port *qlat_sess = p;
14451424 	uint16_t loop_id = qlat_sess->loop_id;
14461425 	unsigned long flags;
1447
-	unsigned char be_sid[3];
1448
-
1449
-	be_sid[0] = qlat_sess->d_id.b.domain;
1450
-	be_sid[1] = qlat_sess->d_id.b.area;
1451
-	be_sid[2] = qlat_sess->d_id.b.al_pa;
14521426 
14531427 	/*
14541428 	 * And now setup se_nacl and session pointers into HW lport internal
14551429 	 * mappings for fabric S_ID and LOOP_ID.
14561430 	 */
14571431 	spin_lock_irqsave(&ha->tgt.sess_lock, flags);
1458
-	tcm_qla2xxx_set_sess_by_s_id(lport, se_nacl, nacl,
1459
-				     se_sess, qlat_sess, be_sid);
1432
+	tcm_qla2xxx_set_sess_by_s_id(lport, se_nacl, nacl, se_sess, qlat_sess,
1433
+				     port_id_to_be_id(qlat_sess->d_id));
14601434 	tcm_qla2xxx_set_sess_by_loop_id(lport, se_nacl, nacl,
14611435 					se_sess, qlat_sess, loop_id);
14621436 	spin_unlock_irqrestore(&ha->tgt.sess_lock, flags);
....@@ -1492,7 +1466,7 @@
14921466 	 */
14931467 	tpg = lport->tpg_1;
14941468 	if (!tpg) {
1495
-		pr_err("Unable to lcoate struct tcm_qla2xxx_lport->tpg_1\n");
1469
+		pr_err("Unable to locate struct tcm_qla2xxx_lport->tpg_1\n");
14961470 		return -EINVAL;
14971471 	}
14981472 	/*
....@@ -1596,6 +1570,8 @@
15961570 	.handle_cmd		= tcm_qla2xxx_handle_cmd,
15971571 	.handle_data		= tcm_qla2xxx_handle_data,
15981572 	.handle_tmr		= tcm_qla2xxx_handle_tmr,
1573
+	.get_cmd		= tcm_qla2xxx_get_cmd,
1574
+	.rel_cmd		= tcm_qla2xxx_rel_cmd,
15991575 	.free_cmd		= tcm_qla2xxx_free_cmd,
16001576 	.free_mcmd		= tcm_qla2xxx_free_mcmd,
16011577 	.free_session		= tcm_qla2xxx_free_session,
....@@ -1852,14 +1828,13 @@
18521828 
18531829 static const struct target_core_fabric_ops tcm_qla2xxx_ops = {
18541830 	.module				= THIS_MODULE,
1855
-	.name				= "qla2xxx",
1831
+	.fabric_name			= "qla2xxx",
18561832 	.node_acl_size			= sizeof(struct tcm_qla2xxx_nacl),
18571833 	/*
18581834 	 * XXX: Limit assumes single page per scatter-gather-list entry.
18591835 	 * Current maximum is ~4.9 MB per se_cmd->t_data_sg with PAGE_SIZE=4096
18601836 	 */
18611837 	.max_data_sg_nents		= 1200,
1862
-	.get_fabric_name		= tcm_qla2xxx_get_fabric_name,
18631838 	.tpg_get_wwn			= tcm_qla2xxx_get_fabric_wwn,
18641839 	.tpg_get_tag			= tcm_qla2xxx_get_tag,
18651840 	.tpg_check_demo_mode		= tcm_qla2xxx_check_demo_mode,
....@@ -1877,7 +1852,6 @@
18771852 	.sess_get_index			= tcm_qla2xxx_sess_get_index,
18781853 	.sess_get_initiator_sid		= NULL,
18791854 	.write_pending			= tcm_qla2xxx_write_pending,
1880
-	.write_pending_status		= tcm_qla2xxx_write_pending_status,
18811855 	.set_default_node_attributes	= tcm_qla2xxx_set_default_node_attrs,
18821856 	.get_cmd_state			= tcm_qla2xxx_get_cmd_state,
18831857 	.queue_data_in			= tcm_qla2xxx_queue_data_in,
....@@ -1901,9 +1875,8 @@
19011875 
19021876 static const struct target_core_fabric_ops tcm_qla2xxx_npiv_ops = {
19031877 	.module				= THIS_MODULE,
1904
-	.name				= "qla2xxx_npiv",
1878
+	.fabric_name			= "qla2xxx_npiv",
19051879 	.node_acl_size			= sizeof(struct tcm_qla2xxx_nacl),
1906
-	.get_fabric_name		= tcm_qla2xxx_npiv_get_fabric_name,
19071880 	.tpg_get_wwn			= tcm_qla2xxx_get_fabric_wwn,
19081881 	.tpg_get_tag			= tcm_qla2xxx_get_tag,
19091882 	.tpg_check_demo_mode		= tcm_qla2xxx_check_demo_mode,
....@@ -1919,7 +1892,6 @@
19191892 	.sess_get_index			= tcm_qla2xxx_sess_get_index,
19201893 	.sess_get_initiator_sid		= NULL,
19211894 	.write_pending			= tcm_qla2xxx_write_pending,
1922
-	.write_pending_status		= tcm_qla2xxx_write_pending_status,
19231895 	.set_default_node_attributes	= tcm_qla2xxx_set_default_node_attrs,
19241896 	.get_cmd_state			= tcm_qla2xxx_get_cmd_state,
19251897 	.queue_data_in			= tcm_qla2xxx_queue_data_in,
....@@ -1984,6 +1956,21 @@
19841956 {
19851957 	int ret;
19861958 
1959
+	BUILD_BUG_ON(sizeof(struct abts_recv_from_24xx) != 64);
1960
+	BUILD_BUG_ON(sizeof(struct abts_resp_from_24xx_fw) != 64);
1961
+	BUILD_BUG_ON(sizeof(struct atio7_fcp_cmnd) != 32);
1962
+	BUILD_BUG_ON(sizeof(struct atio_from_isp) != 64);
1963
+	BUILD_BUG_ON(sizeof(struct ba_acc_le) != 12);
1964
+	BUILD_BUG_ON(sizeof(struct ba_rjt_le) != 4);
1965
+	BUILD_BUG_ON(sizeof(struct ctio7_from_24xx) != 64);
1966
+	BUILD_BUG_ON(sizeof(struct ctio7_to_24xx) != 64);
1967
+	BUILD_BUG_ON(sizeof(struct ctio_crc2_to_fw) != 64);
1968
+	BUILD_BUG_ON(sizeof(struct ctio_crc_from_fw) != 64);
1969
+	BUILD_BUG_ON(sizeof(struct ctio_to_2xxx) != 64);
1970
+	BUILD_BUG_ON(sizeof(struct fcp_hdr) != 24);
1971
+	BUILD_BUG_ON(sizeof(struct fcp_hdr_le) != 24);
1972
+	BUILD_BUG_ON(sizeof(struct nack_to_isp) != 64);
1973
+
19871974 	ret = tcm_qla2xxx_register_configfs();
19881975 	if (ret < 0)
19891976 		return ret;