forked from ~ljy/RK356X_SDK_RELEASE
blame | history | patch | commit | commitdiff
hc
2023-12-09 b22da3d8526a935aa31e086e63f60ff3246cb61c 
 kernel/drivers/target/target_core_device.c
....@@ -1,3 +1,4 @@
1
+// SPDX-License-Identifier: GPL-2.0-or-later
12 /*******************************************************************************
23  * Filename:  target_core_device.c (based on iscsi_target_device.c)
34  *
....@@ -7,20 +8,6 @@
78  * (c) Copyright 2003-2013 Datera, Inc.
89  *
910  * Nicholas A. Bellinger <nab@kernel.org>
10
- *
11
- * This program is free software; you can redistribute it and/or modify
12
- * it under the terms of the GNU General Public License as published by
13
- * the Free Software Foundation; either version 2 of the License, or
14
- * (at your option) any later version.
15
- *
16
- * This program is distributed in the hope that it will be useful,
17
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
18
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
19
- * GNU General Public License for more details.
20
- *
21
- * You should have received a copy of the GNU General Public License
22
- * along with this program; if not, write to the Free Software
23
- * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
2411  *
2512  ******************************************************************************/
2613 
....@@ -58,7 +45,7 @@
5845 struct se_device *g_lun0_dev;
5946 
6047 sense_reason_t
61
-transport_lookup_cmd_lun(struct se_cmd *se_cmd, u64 unpacked_lun)
48
+transport_lookup_cmd_lun(struct se_cmd *se_cmd)
6249 {
6350 	struct se_lun *se_lun = NULL;
6451 	struct se_session *se_sess = se_cmd->se_sess;
....@@ -67,7 +54,7 @@
6754 	sense_reason_t ret = TCM_NO_SENSE;
6855 
6956 	rcu_read_lock();
70
-	deve = target_nacl_find_deve(nacl, unpacked_lun);
57
+	deve = target_nacl_find_deve(nacl, se_cmd->orig_fe_lun);
7158 	if (deve) {
7259 		atomic_long_inc(&deve->total_cmds);
7360 
....@@ -87,7 +74,6 @@
8774 
8875 		se_cmd->se_lun = se_lun;
8976 		se_cmd->pr_res_key = deve->pr_res_key;
90
-		se_cmd->orig_fe_lun = unpacked_lun;
9177 		se_cmd->se_cmd_flags |= SCF_SE_LUN_CMD;
9278 		se_cmd->lun_ref_active = true;
9379 
....@@ -95,8 +81,8 @@
9581 		    deve->lun_access_ro) {
9682 			pr_err("TARGET_CORE[%s]: Detected WRITE_PROTECTED LUN"
9783 				" Access for 0x%08llx\n",
98
-				se_cmd->se_tfo->get_fabric_name(),
99
-				unpacked_lun);
84
+				se_cmd->se_tfo->fabric_name,
85
+				se_cmd->orig_fe_lun);
10086 			rcu_read_unlock();
10187 			ret = TCM_WRITE_PROTECTED;
10288 			goto ref_dev;
....@@ -111,17 +97,17 @@
11197 		 * REPORT_LUNS, et al to be returned when no active
11298 		 * MappedLUN=0 exists for this Initiator Port.
11399 		 */
114
-		if (unpacked_lun != 0) {
100
+		if (se_cmd->orig_fe_lun != 0) {
115101 			pr_err("TARGET_CORE[%s]: Detected NON_EXISTENT_LUN"
116
-				" Access for 0x%08llx\n",
117
-				se_cmd->se_tfo->get_fabric_name(),
118
-				unpacked_lun);
102
+				" Access for 0x%08llx from %s\n",
103
+				se_cmd->se_tfo->fabric_name,
104
+				se_cmd->orig_fe_lun,
105
+				nacl->initiatorname);
119106 			return TCM_NON_EXISTENT_LUN;
120107 		}
121108 
122109 		se_lun = se_sess->se_tpg->tpg_virt_lun0;
123110 		se_cmd->se_lun = se_sess->se_tpg->tpg_virt_lun0;
124
-		se_cmd->orig_fe_lun = 0;
125111 		se_cmd->se_cmd_flags |= SCF_SE_LUN_CMD;
126112 
127113 		percpu_ref_get(&se_lun->lun_ref);
....@@ -157,7 +143,7 @@
157143 }
158144 EXPORT_SYMBOL(transport_lookup_cmd_lun);
159145 
160
-int transport_lookup_tmr_lun(struct se_cmd *se_cmd, u64 unpacked_lun)
146
+int transport_lookup_tmr_lun(struct se_cmd *se_cmd)
161147 {
162148 	struct se_dev_entry *deve;
163149 	struct se_lun *se_lun = NULL;
....@@ -167,7 +153,7 @@
167153 	unsigned long flags;
168154 
169155 	rcu_read_lock();
170
-	deve = target_nacl_find_deve(nacl, unpacked_lun);
156
+	deve = target_nacl_find_deve(nacl, se_cmd->orig_fe_lun);
171157 	if (deve) {
172158 		se_lun = rcu_dereference(deve->se_lun);
173159 
....@@ -178,7 +164,6 @@
178164 
179165 		se_cmd->se_lun = se_lun;
180166 		se_cmd->pr_res_key = deve->pr_res_key;
181
-		se_cmd->orig_fe_lun = unpacked_lun;
182167 		se_cmd->se_cmd_flags |= SCF_SE_LUN_CMD;
183168 		se_cmd->lun_ref_active = true;
184169 	}
....@@ -187,9 +172,10 @@
187172 
188173 	if (!se_lun) {
189174 		pr_debug("TARGET_CORE[%s]: Detected NON_EXISTENT_LUN"
190
-			" Access for 0x%08llx\n",
191
-			se_cmd->se_tfo->get_fabric_name(),
192
-			unpacked_lun);
175
+			" Access for 0x%08llx for %s\n",
176
+			se_cmd->se_tfo->fabric_name,
177
+			se_cmd->orig_fe_lun,
178
+			nacl->initiatorname);
193179 		return -ENODEV;
194180 	}
195181 	se_cmd->se_dev = rcu_dereference_raw(se_lun->lun_se_dev);
....@@ -237,7 +223,7 @@
237223 		if (!lun) {
238224 			pr_err("%s device entries device pointer is"
239225 				" NULL, but Initiator has access.\n",
240
-				tpg->se_tpg_tfo->get_fabric_name());
226
+				tpg->se_tpg_tfo->fabric_name);
241227 			continue;
242228 		}
243229 		if (lun->lun_rtpi != rtpi)
....@@ -404,9 +390,6 @@
404390 	return 0;
405391 }
406392 
407
-/*
408
- *	Called with se_node_acl->lun_entry_mutex held.
409
- */
410393 void core_disable_device_list_for_node(
411394 	struct se_lun *lun,
412395 	struct se_dev_entry *orig,
....@@ -418,6 +401,9 @@
418401 	 * reference to se_device->dev_group.
419402 	 */
420403 	struct se_device *dev = rcu_dereference_raw(lun->lun_se_dev);
404
+
405
+	lockdep_assert_held(&nacl->lun_entry_mutex);
406
+
421407 	/*
422408 	 * If the MappedLUN entry is being disabled, the entry in
423409 	 * lun->lun_deve_list must be removed now before clearing the
....@@ -571,9 +557,9 @@
571557 		return rc;
572558 
573559 	pr_debug("%s_TPG[%u]_LUN[%llu] - Activated %s Logical Unit from"
574
-		" CORE HBA: %u\n", tpg->se_tpg_tfo->get_fabric_name(),
560
+		" CORE HBA: %u\n", tpg->se_tpg_tfo->fabric_name,
575561 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun,
576
-		tpg->se_tpg_tfo->get_fabric_name(), dev->se_hba->hba_id);
562
+		tpg->se_tpg_tfo->fabric_name, dev->se_hba->hba_id);
577563 	/*
578564 	 * Update LUN maps for dynamically added initiators when
579565 	 * generate_node_acl is enabled.
....@@ -604,9 +590,9 @@
604590 	struct se_lun *lun)
605591 {
606592 	pr_debug("%s_TPG[%u]_LUN[%llu] - Deactivating %s Logical Unit from"
607
-		" device object\n", tpg->se_tpg_tfo->get_fabric_name(),
593
+		" device object\n", tpg->se_tpg_tfo->fabric_name,
608594 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun,
609
-		tpg->se_tpg_tfo->get_fabric_name());
595
+		tpg->se_tpg_tfo->fabric_name);
610596 
611597 	core_tpg_remove_lun(tpg, lun);
612598 }
....@@ -621,7 +607,7 @@
621607 
622608 	if (strlen(nacl->initiatorname) >= TRANSPORT_IQN_LEN) {
623609 		pr_err("%s InitiatorName exceeds maximum size.\n",
624
-			tpg->se_tpg_tfo->get_fabric_name());
610
+			tpg->se_tpg_tfo->fabric_name);
625611 		*ret = -EOVERFLOW;
626612 		return NULL;
627613 	}
....@@ -664,7 +650,7 @@
664650 		return -EINVAL;
665651 
666652 	pr_debug("%s_TPG[%hu]_LUN[%llu->%llu] - Added %s ACL for "
667
-		" InitiatorNode: %s\n", tpg->se_tpg_tfo->get_fabric_name(),
653
+		" InitiatorNode: %s\n", tpg->se_tpg_tfo->fabric_name,
668654 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun, lacl->mapped_lun,
669655 		lun_access_ro ? "RO" : "RW",
670656 		nacl->initiatorname);
....@@ -697,7 +683,7 @@
697683 
698684 	pr_debug("%s_TPG[%hu]_LUN[%llu] - Removed ACL for"
699685 		" InitiatorNode: %s Mapped LUN: %llu\n",
700
-		tpg->se_tpg_tfo->get_fabric_name(),
686
+		tpg->se_tpg_tfo->fabric_name,
701687 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun,
702688 		nacl->initiatorname, lacl->mapped_lun);
703689 
....@@ -709,9 +695,9 @@
709695 	struct se_lun_acl *lacl)
710696 {
711697 	pr_debug("%s_TPG[%hu] - Freeing ACL for %s InitiatorNode: %s"
712
-		" Mapped LUN: %llu\n", tpg->se_tpg_tfo->get_fabric_name(),
698
+		" Mapped LUN: %llu\n", tpg->se_tpg_tfo->fabric_name,
713699 		tpg->se_tpg_tfo->tpg_get_tag(tpg),
714
-		tpg->se_tpg_tfo->get_fabric_name(),
700
+		tpg->se_tpg_tfo->fabric_name,
715701 		lacl->se_lun_nacl->initiatorname, lacl->mapped_lun);
716702 
717703 	kfree(lacl);
....@@ -720,36 +706,17 @@
720706 static void scsi_dump_inquiry(struct se_device *dev)
721707 {
722708 	struct t10_wwn *wwn = &dev->t10_wwn;
723
-	char buf[17];
724
-	int i, device_type;
709
+	int device_type = dev->transport->get_device_type(dev);
710
+
725711 	/*
726712 	 * Print Linux/SCSI style INQUIRY formatting to the kernel ring buffer
727713 	 */
728
-	for (i = 0; i < 8; i++)
729
-		if (wwn->vendor[i] >= 0x20)
730
-			buf[i] = wwn->vendor[i];
731
-		else
732
-			buf[i] = ' ';
733
-	buf[i] = '\0';
734
-	pr_debug("  Vendor: %s\n", buf);
735
-
736
-	for (i = 0; i < 16; i++)
737
-		if (wwn->model[i] >= 0x20)
738
-			buf[i] = wwn->model[i];
739
-		else
740
-			buf[i] = ' ';
741
-	buf[i] = '\0';
742
-	pr_debug("  Model: %s\n", buf);
743
-
744
-	for (i = 0; i < 4; i++)
745
-		if (wwn->revision[i] >= 0x20)
746
-			buf[i] = wwn->revision[i];
747
-		else
748
-			buf[i] = ' ';
749
-	buf[i] = '\0';
750
-	pr_debug("  Revision: %s\n", buf);
751
-
752
-	device_type = dev->transport->get_device_type(dev);
714
+	pr_debug("  Vendor: %-" __stringify(INQUIRY_VENDOR_LEN) "s\n",
715
+		wwn->vendor);
716
+	pr_debug("  Model: %-" __stringify(INQUIRY_MODEL_LEN) "s\n",
717
+		wwn->model);
718
+	pr_debug("  Revision: %-" __stringify(INQUIRY_REVISION_LEN) "s\n",
719
+		wwn->revision);
753720 	pr_debug("  Type:   %s ", scsi_device_type(device_type));
754721 }
755722 
....@@ -764,6 +731,7 @@
764731 
765732 	dev->se_hba = hba;
766733 	dev->transport = hba->backend->ops;
734
+	dev->transport_flags = dev->transport->transport_flags_default;
767735 	dev->prot_length = sizeof(struct t10_pi_tuple);
768736 	dev->hba_index = hba->hba_index;
769737 
....@@ -801,12 +769,13 @@
801769 	dev->dev_attrib.emulate_fua_write = 1;
802770 	dev->dev_attrib.emulate_fua_read = 1;
803771 	dev->dev_attrib.emulate_write_cache = DA_EMULATE_WRITE_CACHE;
804
-	dev->dev_attrib.emulate_ua_intlck_ctrl = DA_EMULATE_UA_INTLLCK_CTRL;
772
+	dev->dev_attrib.emulate_ua_intlck_ctrl = TARGET_UA_INTLCK_CTRL_CLEAR;
805773 	dev->dev_attrib.emulate_tas = DA_EMULATE_TAS;
806774 	dev->dev_attrib.emulate_tpu = DA_EMULATE_TPU;
807775 	dev->dev_attrib.emulate_tpws = DA_EMULATE_TPWS;
808776 	dev->dev_attrib.emulate_caw = DA_EMULATE_CAW;
809777 	dev->dev_attrib.emulate_3pc = DA_EMULATE_3PC;
778
+	dev->dev_attrib.emulate_pr = DA_EMULATE_PR;
810779 	dev->dev_attrib.pi_prot_type = TARGET_DIF_TYPE0_PROT;
811780 	dev->dev_attrib.enforce_pr_isids = DA_ENFORCE_PR_ISIDS;
812781 	dev->dev_attrib.force_pr_aptpl = DA_FORCE_PR_APTPL;
....@@ -824,12 +793,18 @@
824793 
825794 	xcopy_lun = &dev->xcopy_lun;
826795 	rcu_assign_pointer(xcopy_lun->lun_se_dev, dev);
827
-	init_completion(&xcopy_lun->lun_ref_comp);
828796 	init_completion(&xcopy_lun->lun_shutdown_comp);
829797 	INIT_LIST_HEAD(&xcopy_lun->lun_deve_list);
830798 	INIT_LIST_HEAD(&xcopy_lun->lun_dev_link);
831799 	mutex_init(&xcopy_lun->lun_tg_pt_md_mutex);
832800 	xcopy_lun->lun_tpg = &xcopy_pt_tpg;
801
+
802
+	/* Preload the default INQUIRY const values */
803
+	strlcpy(dev->t10_wwn.vendor, "LIO-ORG", sizeof(dev->t10_wwn.vendor));
804
+	strlcpy(dev->t10_wwn.model, dev->transport->inquiry_prod,
805
+		sizeof(dev->t10_wwn.model));
806
+	strlcpy(dev->t10_wwn.revision, dev->transport->inquiry_rev,
807
+		sizeof(dev->t10_wwn.revision));
833808 
834809 	return dev;
835810 }
....@@ -856,7 +831,6 @@
856831 	attrib->unmap_granularity = q->limits.discard_granularity / block_size;
857832 	attrib->unmap_granularity_alignment = q->limits.discard_alignment /
858833 								block_size;
859
-	attrib->unmap_zeroes_data = (q->limits.max_write_zeroes_sectors);
860834 	return true;
861835 }
862836 EXPORT_SYMBOL(target_configure_unmap_from_queue);
....@@ -989,34 +963,9 @@
989963 		goto out_destroy_device;
990964 
991965 	/*
992
-	 * Startup the struct se_device processing thread
993
-	 */
994
-	dev->tmr_wq = alloc_workqueue("tmr-%s", WQ_MEM_RECLAIM | WQ_UNBOUND, 1,
995
-				      dev->transport->name);
996
-	if (!dev->tmr_wq) {
997
-		pr_err("Unable to create tmr workqueue for %s\n",
998
-			dev->transport->name);
999
-		ret = -ENOMEM;
1000
-		goto out_free_alua;
1001
-	}
1002
-
1003
-	/*
1004966 	 * Setup work_queue for QUEUE_FULL
1005967 	 */
1006968 	INIT_WORK(&dev->qf_work_queue, target_qf_do_work);
1007
-
1008
-	/*
1009
-	 * Preload the initial INQUIRY const values if we are doing
1010
-	 * anything virtual (IBLOCK, FILEIO, RAMDISK), but not for TCM/pSCSI
1011
-	 * passthrough because this is being provided by the backend LLD.
1012
-	 */
1013
-	if (!(dev->transport->transport_flags & TRANSPORT_FLAG_PASSTHROUGH)) {
1014
-		strncpy(&dev->t10_wwn.vendor[0], "LIO-ORG", 8);
1015
-		strncpy(&dev->t10_wwn.model[0],
1016
-			dev->transport->inquiry_prod, 16);
1017
-		strncpy(&dev->t10_wwn.revision[0],
1018
-			dev->transport->inquiry_rev, 4);
1019
-	}
1020969 
1021970 	scsi_dump_inquiry(dev);
1022971 
....@@ -1028,8 +977,6 @@
1028977 
1029978 	return 0;
1030979 
1031
-out_free_alua:
1032
-	core_alua_free_lu_gp_mem(dev);
1033980 out_destroy_device:
1034981 	dev->transport->destroy_device(dev);
1035982 out_free_index:
....@@ -1048,8 +995,6 @@
1048995 	WARN_ON(!list_empty(&dev->dev_sep_list));
1049996 
1050997 	if (target_dev_configured(dev)) {
1051
-		destroy_workqueue(dev->tmr_wq);
1052
-
1053998 		dev->transport->destroy_device(dev);
1054999 
10551000 		mutex_lock(&device_mutex);
....@@ -1140,11 +1085,23 @@
11401085 	}
11411086 
11421087 	/*
1088
+	 * With emulate_pr disabled, all reservation requests should fail,
1089
+	 * regardless of whether or not TRANSPORT_FLAG_PASSTHROUGH_PGR is set.
1090
+	 */
1091
+	if (!dev->dev_attrib.emulate_pr &&
1092
+	    ((cdb[0] == PERSISTENT_RESERVE_IN) ||
1093
+	     (cdb[0] == PERSISTENT_RESERVE_OUT) ||
1094
+	     (cdb[0] == RELEASE || cdb[0] == RELEASE_10) ||
1095
+	     (cdb[0] == RESERVE || cdb[0] == RESERVE_10))) {
1096
+		return TCM_UNSUPPORTED_SCSI_OPCODE;
1097
+	}
1098
+
1099
+	/*
11431100 	 * For PERSISTENT RESERVE IN/OUT, RELEASE, and RESERVE we need to
11441101 	 * emulate the response, since tcmu does not have the information
11451102 	 * required to process these commands.
11461103 	 */
1147
-	if (!(dev->transport->transport_flags &
1104
+	if (!(dev->transport_flags &
11481105 	      TRANSPORT_FLAG_PASSTHROUGH_PGR)) {
11491106 		if (cdb[0] == PERSISTENT_RESERVE_IN) {
11501107 			cmd->execute_cmd = target_scsi3_emulate_pr_in;