• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*******************************************************************************
2  * Filename:  target_core_device.c (based on iscsi_target_device.c)
3  *
4  * This file contains the TCM Virtual Device and Disk Transport
5  * agnostic related functions.
6  *
7  * (c) Copyright 2003-2013 Datera, Inc.
8  *
9  * 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.
24  *
25  ******************************************************************************/
26 
27 #include <linux/net.h>
28 #include <linux/string.h>
29 #include <linux/delay.h>
30 #include <linux/timer.h>
31 #include <linux/slab.h>
32 #include <linux/spinlock.h>
33 #include <linux/kthread.h>
34 #include <linux/in.h>
35 #include <linux/export.h>
36 #include <net/sock.h>
37 #include <net/tcp.h>
38 #include <scsi/scsi.h>
39 #include <scsi/scsi_device.h>
40 
41 #include <target/target_core_base.h>
42 #include <target/target_core_backend.h>
43 #include <target/target_core_fabric.h>
44 
45 #include "target_core_internal.h"
46 #include "target_core_alua.h"
47 #include "target_core_pr.h"
48 #include "target_core_ua.h"
49 
50 DEFINE_MUTEX(g_device_mutex);
51 LIST_HEAD(g_device_list);
52 
53 static struct se_hba *lun0_hba;
54 /* not static, needed by tpg.c */
55 struct se_device *g_lun0_dev;
56 
57 sense_reason_t
transport_lookup_cmd_lun(struct se_cmd * se_cmd,u32 unpacked_lun)58 transport_lookup_cmd_lun(struct se_cmd *se_cmd, u32 unpacked_lun)
59 {
60 	struct se_lun *se_lun = NULL;
61 	struct se_session *se_sess = se_cmd->se_sess;
62 	struct se_device *dev;
63 	unsigned long flags;
64 
65 	if (unpacked_lun >= TRANSPORT_MAX_LUNS_PER_TPG)
66 		return TCM_NON_EXISTENT_LUN;
67 
68 	spin_lock_irqsave(&se_sess->se_node_acl->device_list_lock, flags);
69 	se_cmd->se_deve = se_sess->se_node_acl->device_list[unpacked_lun];
70 	if (se_cmd->se_deve->lun_flags & TRANSPORT_LUNFLAGS_INITIATOR_ACCESS) {
71 		struct se_dev_entry *deve = se_cmd->se_deve;
72 
73 		deve->total_cmds++;
74 
75 		if ((se_cmd->data_direction == DMA_TO_DEVICE) &&
76 		    (deve->lun_flags & TRANSPORT_LUNFLAGS_READ_ONLY)) {
77 			pr_err("TARGET_CORE[%s]: Detected WRITE_PROTECTED LUN"
78 				" Access for 0x%08x\n",
79 				se_cmd->se_tfo->get_fabric_name(),
80 				unpacked_lun);
81 			spin_unlock_irqrestore(&se_sess->se_node_acl->device_list_lock, flags);
82 			return TCM_WRITE_PROTECTED;
83 		}
84 
85 		if (se_cmd->data_direction == DMA_TO_DEVICE)
86 			deve->write_bytes += se_cmd->data_length;
87 		else if (se_cmd->data_direction == DMA_FROM_DEVICE)
88 			deve->read_bytes += se_cmd->data_length;
89 
90 		se_lun = deve->se_lun;
91 		se_cmd->se_lun = deve->se_lun;
92 		se_cmd->pr_res_key = deve->pr_res_key;
93 		se_cmd->orig_fe_lun = unpacked_lun;
94 		se_cmd->se_cmd_flags |= SCF_SE_LUN_CMD;
95 
96 		percpu_ref_get(&se_lun->lun_ref);
97 		se_cmd->lun_ref_active = true;
98 	}
99 	spin_unlock_irqrestore(&se_sess->se_node_acl->device_list_lock, flags);
100 
101 	if (!se_lun) {
102 		/*
103 		 * Use the se_portal_group->tpg_virt_lun0 to allow for
104 		 * REPORT_LUNS, et al to be returned when no active
105 		 * MappedLUN=0 exists for this Initiator Port.
106 		 */
107 		if (unpacked_lun != 0) {
108 			pr_err("TARGET_CORE[%s]: Detected NON_EXISTENT_LUN"
109 				" Access for 0x%08x\n",
110 				se_cmd->se_tfo->get_fabric_name(),
111 				unpacked_lun);
112 			return TCM_NON_EXISTENT_LUN;
113 		}
114 		/*
115 		 * Force WRITE PROTECT for virtual LUN 0
116 		 */
117 		if ((se_cmd->data_direction != DMA_FROM_DEVICE) &&
118 		    (se_cmd->data_direction != DMA_NONE))
119 			return TCM_WRITE_PROTECTED;
120 
121 		se_lun = &se_sess->se_tpg->tpg_virt_lun0;
122 		se_cmd->se_lun = &se_sess->se_tpg->tpg_virt_lun0;
123 		se_cmd->orig_fe_lun = 0;
124 		se_cmd->se_cmd_flags |= SCF_SE_LUN_CMD;
125 
126 		percpu_ref_get(&se_lun->lun_ref);
127 		se_cmd->lun_ref_active = true;
128 	}
129 
130 	/* Directly associate cmd with se_dev */
131 	se_cmd->se_dev = se_lun->lun_se_dev;
132 
133 	dev = se_lun->lun_se_dev;
134 	atomic_long_inc(&dev->num_cmds);
135 	if (se_cmd->data_direction == DMA_TO_DEVICE)
136 		atomic_long_add(se_cmd->data_length, &dev->write_bytes);
137 	else if (se_cmd->data_direction == DMA_FROM_DEVICE)
138 		atomic_long_add(se_cmd->data_length, &dev->read_bytes);
139 
140 	return 0;
141 }
142 EXPORT_SYMBOL(transport_lookup_cmd_lun);
143 
transport_lookup_tmr_lun(struct se_cmd * se_cmd,u32 unpacked_lun)144 int transport_lookup_tmr_lun(struct se_cmd *se_cmd, u32 unpacked_lun)
145 {
146 	struct se_dev_entry *deve;
147 	struct se_lun *se_lun = NULL;
148 	struct se_session *se_sess = se_cmd->se_sess;
149 	struct se_tmr_req *se_tmr = se_cmd->se_tmr_req;
150 	unsigned long flags;
151 
152 	if (unpacked_lun >= TRANSPORT_MAX_LUNS_PER_TPG)
153 		return -ENODEV;
154 
155 	spin_lock_irqsave(&se_sess->se_node_acl->device_list_lock, flags);
156 	se_cmd->se_deve = se_sess->se_node_acl->device_list[unpacked_lun];
157 	deve = se_cmd->se_deve;
158 
159 	if (deve->lun_flags & TRANSPORT_LUNFLAGS_INITIATOR_ACCESS) {
160 		se_tmr->tmr_lun = deve->se_lun;
161 		se_cmd->se_lun = deve->se_lun;
162 		se_lun = deve->se_lun;
163 		se_cmd->pr_res_key = deve->pr_res_key;
164 		se_cmd->orig_fe_lun = unpacked_lun;
165 	}
166 	spin_unlock_irqrestore(&se_sess->se_node_acl->device_list_lock, flags);
167 
168 	if (!se_lun) {
169 		pr_debug("TARGET_CORE[%s]: Detected NON_EXISTENT_LUN"
170 			" Access for 0x%08x\n",
171 			se_cmd->se_tfo->get_fabric_name(),
172 			unpacked_lun);
173 		return -ENODEV;
174 	}
175 
176 	/* Directly associate cmd with se_dev */
177 	se_cmd->se_dev = se_lun->lun_se_dev;
178 	se_tmr->tmr_dev = se_lun->lun_se_dev;
179 
180 	spin_lock_irqsave(&se_tmr->tmr_dev->se_tmr_lock, flags);
181 	list_add_tail(&se_tmr->tmr_list, &se_tmr->tmr_dev->dev_tmr_list);
182 	spin_unlock_irqrestore(&se_tmr->tmr_dev->se_tmr_lock, flags);
183 
184 	return 0;
185 }
186 EXPORT_SYMBOL(transport_lookup_tmr_lun);
187 
188 /*
189  * This function is called from core_scsi3_emulate_pro_register_and_move()
190  * and core_scsi3_decode_spec_i_port(), and will increment &deve->pr_ref_count
191  * when a matching rtpi is found.
192  */
core_get_se_deve_from_rtpi(struct se_node_acl * nacl,u16 rtpi)193 struct se_dev_entry *core_get_se_deve_from_rtpi(
194 	struct se_node_acl *nacl,
195 	u16 rtpi)
196 {
197 	struct se_dev_entry *deve;
198 	struct se_lun *lun;
199 	struct se_port *port;
200 	struct se_portal_group *tpg = nacl->se_tpg;
201 	u32 i;
202 
203 	spin_lock_irq(&nacl->device_list_lock);
204 	for (i = 0; i < TRANSPORT_MAX_LUNS_PER_TPG; i++) {
205 		deve = nacl->device_list[i];
206 
207 		if (!(deve->lun_flags & TRANSPORT_LUNFLAGS_INITIATOR_ACCESS))
208 			continue;
209 
210 		lun = deve->se_lun;
211 		if (!lun) {
212 			pr_err("%s device entries device pointer is"
213 				" NULL, but Initiator has access.\n",
214 				tpg->se_tpg_tfo->get_fabric_name());
215 			continue;
216 		}
217 		port = lun->lun_sep;
218 		if (!port) {
219 			pr_err("%s device entries device pointer is"
220 				" NULL, but Initiator has access.\n",
221 				tpg->se_tpg_tfo->get_fabric_name());
222 			continue;
223 		}
224 		if (port->sep_rtpi != rtpi)
225 			continue;
226 
227 		atomic_inc_mb(&deve->pr_ref_count);
228 		spin_unlock_irq(&nacl->device_list_lock);
229 
230 		return deve;
231 	}
232 	spin_unlock_irq(&nacl->device_list_lock);
233 
234 	return NULL;
235 }
236 
core_free_device_list_for_node(struct se_node_acl * nacl,struct se_portal_group * tpg)237 int core_free_device_list_for_node(
238 	struct se_node_acl *nacl,
239 	struct se_portal_group *tpg)
240 {
241 	struct se_dev_entry *deve;
242 	struct se_lun *lun;
243 	u32 i;
244 
245 	if (!nacl->device_list)
246 		return 0;
247 
248 	spin_lock_irq(&nacl->device_list_lock);
249 	for (i = 0; i < TRANSPORT_MAX_LUNS_PER_TPG; i++) {
250 		deve = nacl->device_list[i];
251 
252 		if (!(deve->lun_flags & TRANSPORT_LUNFLAGS_INITIATOR_ACCESS))
253 			continue;
254 
255 		if (!deve->se_lun) {
256 			pr_err("%s device entries device pointer is"
257 				" NULL, but Initiator has access.\n",
258 				tpg->se_tpg_tfo->get_fabric_name());
259 			continue;
260 		}
261 		lun = deve->se_lun;
262 
263 		spin_unlock_irq(&nacl->device_list_lock);
264 		core_disable_device_list_for_node(lun, NULL, deve->mapped_lun,
265 			TRANSPORT_LUNFLAGS_NO_ACCESS, nacl, tpg);
266 		spin_lock_irq(&nacl->device_list_lock);
267 	}
268 	spin_unlock_irq(&nacl->device_list_lock);
269 
270 	array_free(nacl->device_list, TRANSPORT_MAX_LUNS_PER_TPG);
271 	nacl->device_list = NULL;
272 
273 	return 0;
274 }
275 
core_update_device_list_access(u32 mapped_lun,u32 lun_access,struct se_node_acl * nacl)276 void core_update_device_list_access(
277 	u32 mapped_lun,
278 	u32 lun_access,
279 	struct se_node_acl *nacl)
280 {
281 	struct se_dev_entry *deve;
282 
283 	spin_lock_irq(&nacl->device_list_lock);
284 	deve = nacl->device_list[mapped_lun];
285 	if (lun_access & TRANSPORT_LUNFLAGS_READ_WRITE) {
286 		deve->lun_flags &= ~TRANSPORT_LUNFLAGS_READ_ONLY;
287 		deve->lun_flags |= TRANSPORT_LUNFLAGS_READ_WRITE;
288 	} else {
289 		deve->lun_flags &= ~TRANSPORT_LUNFLAGS_READ_WRITE;
290 		deve->lun_flags |= TRANSPORT_LUNFLAGS_READ_ONLY;
291 	}
292 	spin_unlock_irq(&nacl->device_list_lock);
293 }
294 
295 /*      core_enable_device_list_for_node():
296  *
297  *
298  */
core_enable_device_list_for_node(struct se_lun * lun,struct se_lun_acl * lun_acl,u32 mapped_lun,u32 lun_access,struct se_node_acl * nacl,struct se_portal_group * tpg)299 int core_enable_device_list_for_node(
300 	struct se_lun *lun,
301 	struct se_lun_acl *lun_acl,
302 	u32 mapped_lun,
303 	u32 lun_access,
304 	struct se_node_acl *nacl,
305 	struct se_portal_group *tpg)
306 {
307 	struct se_port *port = lun->lun_sep;
308 	struct se_dev_entry *deve;
309 
310 	spin_lock_irq(&nacl->device_list_lock);
311 
312 	deve = nacl->device_list[mapped_lun];
313 
314 	/*
315 	 * Check if the call is handling demo mode -> explicit LUN ACL
316 	 * transition.  This transition must be for the same struct se_lun
317 	 * + mapped_lun that was setup in demo mode..
318 	 */
319 	if (deve->lun_flags & TRANSPORT_LUNFLAGS_INITIATOR_ACCESS) {
320 		if (deve->se_lun_acl != NULL) {
321 			pr_err("struct se_dev_entry->se_lun_acl"
322 			       " already set for demo mode -> explicit"
323 			       " LUN ACL transition\n");
324 			spin_unlock_irq(&nacl->device_list_lock);
325 			return -EINVAL;
326 		}
327 		if (deve->se_lun != lun) {
328 			pr_err("struct se_dev_entry->se_lun does"
329 			       " match passed struct se_lun for demo mode"
330 			       " -> explicit LUN ACL transition\n");
331 			spin_unlock_irq(&nacl->device_list_lock);
332 			return -EINVAL;
333 		}
334 		deve->se_lun_acl = lun_acl;
335 
336 		if (lun_access & TRANSPORT_LUNFLAGS_READ_WRITE) {
337 			deve->lun_flags &= ~TRANSPORT_LUNFLAGS_READ_ONLY;
338 			deve->lun_flags |= TRANSPORT_LUNFLAGS_READ_WRITE;
339 		} else {
340 			deve->lun_flags &= ~TRANSPORT_LUNFLAGS_READ_WRITE;
341 			deve->lun_flags |= TRANSPORT_LUNFLAGS_READ_ONLY;
342 		}
343 
344 		spin_unlock_irq(&nacl->device_list_lock);
345 		return 0;
346 	}
347 
348 	deve->se_lun = lun;
349 	deve->se_lun_acl = lun_acl;
350 	deve->mapped_lun = mapped_lun;
351 	deve->lun_flags |= TRANSPORT_LUNFLAGS_INITIATOR_ACCESS;
352 
353 	if (lun_access & TRANSPORT_LUNFLAGS_READ_WRITE) {
354 		deve->lun_flags &= ~TRANSPORT_LUNFLAGS_READ_ONLY;
355 		deve->lun_flags |= TRANSPORT_LUNFLAGS_READ_WRITE;
356 	} else {
357 		deve->lun_flags &= ~TRANSPORT_LUNFLAGS_READ_WRITE;
358 		deve->lun_flags |= TRANSPORT_LUNFLAGS_READ_ONLY;
359 	}
360 
361 	deve->creation_time = get_jiffies_64();
362 	deve->attach_count++;
363 	spin_unlock_irq(&nacl->device_list_lock);
364 
365 	spin_lock_bh(&port->sep_alua_lock);
366 	list_add_tail(&deve->alua_port_list, &port->sep_alua_list);
367 	spin_unlock_bh(&port->sep_alua_lock);
368 
369 	return 0;
370 }
371 
372 /*      core_disable_device_list_for_node():
373  *
374  *
375  */
core_disable_device_list_for_node(struct se_lun * lun,struct se_lun_acl * lun_acl,u32 mapped_lun,u32 lun_access,struct se_node_acl * nacl,struct se_portal_group * tpg)376 int core_disable_device_list_for_node(
377 	struct se_lun *lun,
378 	struct se_lun_acl *lun_acl,
379 	u32 mapped_lun,
380 	u32 lun_access,
381 	struct se_node_acl *nacl,
382 	struct se_portal_group *tpg)
383 {
384 	struct se_port *port = lun->lun_sep;
385 	struct se_dev_entry *deve = nacl->device_list[mapped_lun];
386 
387 	/*
388 	 * If the MappedLUN entry is being disabled, the entry in
389 	 * port->sep_alua_list must be removed now before clearing the
390 	 * struct se_dev_entry pointers below as logic in
391 	 * core_alua_do_transition_tg_pt() depends on these being present.
392 	 *
393 	 * deve->se_lun_acl will be NULL for demo-mode created LUNs
394 	 * that have not been explicitly converted to MappedLUNs ->
395 	 * struct se_lun_acl, but we remove deve->alua_port_list from
396 	 * port->sep_alua_list. This also means that active UAs and
397 	 * NodeACL context specific PR metadata for demo-mode
398 	 * MappedLUN *deve will be released below..
399 	 */
400 	spin_lock_bh(&port->sep_alua_lock);
401 	list_del(&deve->alua_port_list);
402 	spin_unlock_bh(&port->sep_alua_lock);
403 	/*
404 	 * Wait for any in process SPEC_I_PT=1 or REGISTER_AND_MOVE
405 	 * PR operation to complete.
406 	 */
407 	while (atomic_read(&deve->pr_ref_count) != 0)
408 		cpu_relax();
409 
410 	spin_lock_irq(&nacl->device_list_lock);
411 	/*
412 	 * Disable struct se_dev_entry LUN ACL mapping
413 	 */
414 	core_scsi3_ua_release_all(deve);
415 	deve->se_lun = NULL;
416 	deve->se_lun_acl = NULL;
417 	deve->lun_flags = 0;
418 	deve->creation_time = 0;
419 	deve->attach_count--;
420 	spin_unlock_irq(&nacl->device_list_lock);
421 
422 	core_scsi3_free_pr_reg_from_nacl(lun->lun_se_dev, nacl);
423 	return 0;
424 }
425 
426 /*      core_clear_lun_from_tpg():
427  *
428  *
429  */
core_clear_lun_from_tpg(struct se_lun * lun,struct se_portal_group * tpg)430 void core_clear_lun_from_tpg(struct se_lun *lun, struct se_portal_group *tpg)
431 {
432 	struct se_node_acl *nacl;
433 	struct se_dev_entry *deve;
434 	u32 i;
435 
436 	spin_lock_irq(&tpg->acl_node_lock);
437 	list_for_each_entry(nacl, &tpg->acl_node_list, acl_list) {
438 		spin_unlock_irq(&tpg->acl_node_lock);
439 
440 		spin_lock_irq(&nacl->device_list_lock);
441 		for (i = 0; i < TRANSPORT_MAX_LUNS_PER_TPG; i++) {
442 			deve = nacl->device_list[i];
443 			if (lun != deve->se_lun)
444 				continue;
445 			spin_unlock_irq(&nacl->device_list_lock);
446 
447 			core_disable_device_list_for_node(lun, NULL,
448 				deve->mapped_lun, TRANSPORT_LUNFLAGS_NO_ACCESS,
449 				nacl, tpg);
450 
451 			spin_lock_irq(&nacl->device_list_lock);
452 		}
453 		spin_unlock_irq(&nacl->device_list_lock);
454 
455 		spin_lock_irq(&tpg->acl_node_lock);
456 	}
457 	spin_unlock_irq(&tpg->acl_node_lock);
458 }
459 
core_alloc_port(struct se_device * dev)460 static struct se_port *core_alloc_port(struct se_device *dev)
461 {
462 	struct se_port *port, *port_tmp;
463 
464 	port = kzalloc(sizeof(struct se_port), GFP_KERNEL);
465 	if (!port) {
466 		pr_err("Unable to allocate struct se_port\n");
467 		return ERR_PTR(-ENOMEM);
468 	}
469 	INIT_LIST_HEAD(&port->sep_alua_list);
470 	INIT_LIST_HEAD(&port->sep_list);
471 	atomic_set(&port->sep_tg_pt_secondary_offline, 0);
472 	spin_lock_init(&port->sep_alua_lock);
473 	mutex_init(&port->sep_tg_pt_md_mutex);
474 
475 	spin_lock(&dev->se_port_lock);
476 	if (dev->dev_port_count == 0x0000ffff) {
477 		pr_warn("Reached dev->dev_port_count =="
478 				" 0x0000ffff\n");
479 		spin_unlock(&dev->se_port_lock);
480 		return ERR_PTR(-ENOSPC);
481 	}
482 again:
483 	/*
484 	 * Allocate the next RELATIVE TARGET PORT IDENTIFIER for this struct se_device
485 	 * Here is the table from spc4r17 section 7.7.3.8.
486 	 *
487 	 *    Table 473 -- RELATIVE TARGET PORT IDENTIFIER field
488 	 *
489 	 * Code      Description
490 	 * 0h        Reserved
491 	 * 1h        Relative port 1, historically known as port A
492 	 * 2h        Relative port 2, historically known as port B
493 	 * 3h to FFFFh    Relative port 3 through 65 535
494 	 */
495 	port->sep_rtpi = dev->dev_rpti_counter++;
496 	if (!port->sep_rtpi)
497 		goto again;
498 
499 	list_for_each_entry(port_tmp, &dev->dev_sep_list, sep_list) {
500 		/*
501 		 * Make sure RELATIVE TARGET PORT IDENTIFIER is unique
502 		 * for 16-bit wrap..
503 		 */
504 		if (port->sep_rtpi == port_tmp->sep_rtpi)
505 			goto again;
506 	}
507 	spin_unlock(&dev->se_port_lock);
508 
509 	return port;
510 }
511 
core_export_port(struct se_device * dev,struct se_portal_group * tpg,struct se_port * port,struct se_lun * lun)512 static void core_export_port(
513 	struct se_device *dev,
514 	struct se_portal_group *tpg,
515 	struct se_port *port,
516 	struct se_lun *lun)
517 {
518 	struct t10_alua_tg_pt_gp_member *tg_pt_gp_mem = NULL;
519 
520 	spin_lock(&dev->se_port_lock);
521 	spin_lock(&lun->lun_sep_lock);
522 	port->sep_tpg = tpg;
523 	port->sep_lun = lun;
524 	lun->lun_sep = port;
525 	spin_unlock(&lun->lun_sep_lock);
526 
527 	list_add_tail(&port->sep_list, &dev->dev_sep_list);
528 	spin_unlock(&dev->se_port_lock);
529 
530 	if (dev->transport->transport_type != TRANSPORT_PLUGIN_PHBA_PDEV &&
531 	    !(dev->se_hba->hba_flags & HBA_FLAGS_INTERNAL_USE)) {
532 		tg_pt_gp_mem = core_alua_allocate_tg_pt_gp_mem(port);
533 		if (IS_ERR(tg_pt_gp_mem) || !tg_pt_gp_mem) {
534 			pr_err("Unable to allocate t10_alua_tg_pt"
535 					"_gp_member_t\n");
536 			return;
537 		}
538 		spin_lock(&tg_pt_gp_mem->tg_pt_gp_mem_lock);
539 		__core_alua_attach_tg_pt_gp_mem(tg_pt_gp_mem,
540 			dev->t10_alua.default_tg_pt_gp);
541 		spin_unlock(&tg_pt_gp_mem->tg_pt_gp_mem_lock);
542 		pr_debug("%s/%s: Adding to default ALUA Target Port"
543 			" Group: alua/default_tg_pt_gp\n",
544 			dev->transport->name, tpg->se_tpg_tfo->get_fabric_name());
545 	}
546 
547 	dev->dev_port_count++;
548 	port->sep_index = port->sep_rtpi; /* RELATIVE TARGET PORT IDENTIFIER */
549 }
550 
551 /*
552  *	Called with struct se_device->se_port_lock spinlock held.
553  */
core_release_port(struct se_device * dev,struct se_port * port)554 static void core_release_port(struct se_device *dev, struct se_port *port)
555 	__releases(&dev->se_port_lock) __acquires(&dev->se_port_lock)
556 {
557 	/*
558 	 * Wait for any port reference for PR ALL_TG_PT=1 operation
559 	 * to complete in __core_scsi3_alloc_registration()
560 	 */
561 	spin_unlock(&dev->se_port_lock);
562 	if (atomic_read(&port->sep_tg_pt_ref_cnt))
563 		cpu_relax();
564 	spin_lock(&dev->se_port_lock);
565 
566 	core_alua_free_tg_pt_gp_mem(port);
567 
568 	list_del(&port->sep_list);
569 	dev->dev_port_count--;
570 	kfree(port);
571 }
572 
core_dev_export(struct se_device * dev,struct se_portal_group * tpg,struct se_lun * lun)573 int core_dev_export(
574 	struct se_device *dev,
575 	struct se_portal_group *tpg,
576 	struct se_lun *lun)
577 {
578 	struct se_hba *hba = dev->se_hba;
579 	struct se_port *port;
580 
581 	port = core_alloc_port(dev);
582 	if (IS_ERR(port))
583 		return PTR_ERR(port);
584 
585 	lun->lun_se_dev = dev;
586 
587 	spin_lock(&hba->device_lock);
588 	dev->export_count++;
589 	spin_unlock(&hba->device_lock);
590 
591 	core_export_port(dev, tpg, port, lun);
592 	return 0;
593 }
594 
core_dev_unexport(struct se_device * dev,struct se_portal_group * tpg,struct se_lun * lun)595 void core_dev_unexport(
596 	struct se_device *dev,
597 	struct se_portal_group *tpg,
598 	struct se_lun *lun)
599 {
600 	struct se_hba *hba = dev->se_hba;
601 	struct se_port *port = lun->lun_sep;
602 
603 	spin_lock(&lun->lun_sep_lock);
604 	if (lun->lun_se_dev == NULL) {
605 		spin_unlock(&lun->lun_sep_lock);
606 		return;
607 	}
608 	spin_unlock(&lun->lun_sep_lock);
609 
610 	spin_lock(&dev->se_port_lock);
611 	core_release_port(dev, port);
612 	spin_unlock(&dev->se_port_lock);
613 
614 	spin_lock(&hba->device_lock);
615 	dev->export_count--;
616 	spin_unlock(&hba->device_lock);
617 
618 	lun->lun_sep = NULL;
619 	lun->lun_se_dev = NULL;
620 }
621 
se_release_vpd_for_dev(struct se_device * dev)622 static void se_release_vpd_for_dev(struct se_device *dev)
623 {
624 	struct t10_vpd *vpd, *vpd_tmp;
625 
626 	spin_lock(&dev->t10_wwn.t10_vpd_lock);
627 	list_for_each_entry_safe(vpd, vpd_tmp,
628 			&dev->t10_wwn.t10_vpd_list, vpd_list) {
629 		list_del(&vpd->vpd_list);
630 		kfree(vpd);
631 	}
632 	spin_unlock(&dev->t10_wwn.t10_vpd_lock);
633 }
634 
se_dev_align_max_sectors(u32 max_sectors,u32 block_size)635 static u32 se_dev_align_max_sectors(u32 max_sectors, u32 block_size)
636 {
637 	u32 aligned_max_sectors;
638 	u32 alignment;
639 	/*
640 	 * Limit max_sectors to a PAGE_SIZE aligned value for modern
641 	 * transport_allocate_data_tasks() operation.
642 	 */
643 	alignment = max(1ul, PAGE_SIZE / block_size);
644 	aligned_max_sectors = rounddown(max_sectors, alignment);
645 
646 	if (max_sectors != aligned_max_sectors)
647 		pr_info("Rounding down aligned max_sectors from %u to %u\n",
648 			max_sectors, aligned_max_sectors);
649 
650 	return aligned_max_sectors;
651 }
652 
se_dev_set_max_unmap_lba_count(struct se_device * dev,u32 max_unmap_lba_count)653 int se_dev_set_max_unmap_lba_count(
654 	struct se_device *dev,
655 	u32 max_unmap_lba_count)
656 {
657 	dev->dev_attrib.max_unmap_lba_count = max_unmap_lba_count;
658 	pr_debug("dev[%p]: Set max_unmap_lba_count: %u\n",
659 			dev, dev->dev_attrib.max_unmap_lba_count);
660 	return 0;
661 }
662 
se_dev_set_max_unmap_block_desc_count(struct se_device * dev,u32 max_unmap_block_desc_count)663 int se_dev_set_max_unmap_block_desc_count(
664 	struct se_device *dev,
665 	u32 max_unmap_block_desc_count)
666 {
667 	dev->dev_attrib.max_unmap_block_desc_count =
668 		max_unmap_block_desc_count;
669 	pr_debug("dev[%p]: Set max_unmap_block_desc_count: %u\n",
670 			dev, dev->dev_attrib.max_unmap_block_desc_count);
671 	return 0;
672 }
673 
se_dev_set_unmap_granularity(struct se_device * dev,u32 unmap_granularity)674 int se_dev_set_unmap_granularity(
675 	struct se_device *dev,
676 	u32 unmap_granularity)
677 {
678 	dev->dev_attrib.unmap_granularity = unmap_granularity;
679 	pr_debug("dev[%p]: Set unmap_granularity: %u\n",
680 			dev, dev->dev_attrib.unmap_granularity);
681 	return 0;
682 }
683 
se_dev_set_unmap_granularity_alignment(struct se_device * dev,u32 unmap_granularity_alignment)684 int se_dev_set_unmap_granularity_alignment(
685 	struct se_device *dev,
686 	u32 unmap_granularity_alignment)
687 {
688 	dev->dev_attrib.unmap_granularity_alignment = unmap_granularity_alignment;
689 	pr_debug("dev[%p]: Set unmap_granularity_alignment: %u\n",
690 			dev, dev->dev_attrib.unmap_granularity_alignment);
691 	return 0;
692 }
693 
se_dev_set_max_write_same_len(struct se_device * dev,u32 max_write_same_len)694 int se_dev_set_max_write_same_len(
695 	struct se_device *dev,
696 	u32 max_write_same_len)
697 {
698 	dev->dev_attrib.max_write_same_len = max_write_same_len;
699 	pr_debug("dev[%p]: Set max_write_same_len: %u\n",
700 			dev, dev->dev_attrib.max_write_same_len);
701 	return 0;
702 }
703 
dev_set_t10_wwn_model_alias(struct se_device * dev)704 static void dev_set_t10_wwn_model_alias(struct se_device *dev)
705 {
706 	const char *configname;
707 
708 	configname = config_item_name(&dev->dev_group.cg_item);
709 	if (strlen(configname) >= 16) {
710 		pr_warn("dev[%p]: Backstore name '%s' is too long for "
711 			"INQUIRY_MODEL, truncating to 16 bytes\n", dev,
712 			configname);
713 	}
714 	snprintf(&dev->t10_wwn.model[0], 16, "%s", configname);
715 }
716 
se_dev_set_emulate_model_alias(struct se_device * dev,int flag)717 int se_dev_set_emulate_model_alias(struct se_device *dev, int flag)
718 {
719 	if (dev->export_count) {
720 		pr_err("dev[%p]: Unable to change model alias"
721 			" while export_count is %d\n",
722 			dev, dev->export_count);
723 			return -EINVAL;
724 	}
725 
726 	if (flag != 0 && flag != 1) {
727 		pr_err("Illegal value %d\n", flag);
728 		return -EINVAL;
729 	}
730 
731 	if (flag) {
732 		dev_set_t10_wwn_model_alias(dev);
733 	} else {
734 		strncpy(&dev->t10_wwn.model[0],
735 			dev->transport->inquiry_prod, 16);
736 	}
737 	dev->dev_attrib.emulate_model_alias = flag;
738 
739 	return 0;
740 }
741 
se_dev_set_emulate_dpo(struct se_device * dev,int flag)742 int se_dev_set_emulate_dpo(struct se_device *dev, int flag)
743 {
744 	if (flag != 0 && flag != 1) {
745 		pr_err("Illegal value %d\n", flag);
746 		return -EINVAL;
747 	}
748 
749 	if (flag) {
750 		pr_err("dpo_emulated not supported\n");
751 		return -EINVAL;
752 	}
753 
754 	return 0;
755 }
756 
se_dev_set_emulate_fua_write(struct se_device * dev,int flag)757 int se_dev_set_emulate_fua_write(struct se_device *dev, int flag)
758 {
759 	if (flag != 0 && flag != 1) {
760 		pr_err("Illegal value %d\n", flag);
761 		return -EINVAL;
762 	}
763 
764 	if (flag &&
765 	    dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) {
766 		pr_err("emulate_fua_write not supported for pSCSI\n");
767 		return -EINVAL;
768 	}
769 	dev->dev_attrib.emulate_fua_write = flag;
770 	pr_debug("dev[%p]: SE Device Forced Unit Access WRITEs: %d\n",
771 			dev, dev->dev_attrib.emulate_fua_write);
772 	return 0;
773 }
774 
se_dev_set_emulate_fua_read(struct se_device * dev,int flag)775 int se_dev_set_emulate_fua_read(struct se_device *dev, int flag)
776 {
777 	if (flag != 0 && flag != 1) {
778 		pr_err("Illegal value %d\n", flag);
779 		return -EINVAL;
780 	}
781 
782 	if (flag) {
783 		pr_err("ua read emulated not supported\n");
784 		return -EINVAL;
785 	}
786 
787 	return 0;
788 }
789 
se_dev_set_emulate_write_cache(struct se_device * dev,int flag)790 int se_dev_set_emulate_write_cache(struct se_device *dev, int flag)
791 {
792 	if (flag != 0 && flag != 1) {
793 		pr_err("Illegal value %d\n", flag);
794 		return -EINVAL;
795 	}
796 	if (flag &&
797 	    dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) {
798 		pr_err("emulate_write_cache not supported for pSCSI\n");
799 		return -EINVAL;
800 	}
801 	if (flag &&
802 	    dev->transport->get_write_cache) {
803 		pr_err("emulate_write_cache not supported for this device\n");
804 		return -EINVAL;
805 	}
806 
807 	dev->dev_attrib.emulate_write_cache = flag;
808 	pr_debug("dev[%p]: SE Device WRITE_CACHE_EMULATION flag: %d\n",
809 			dev, dev->dev_attrib.emulate_write_cache);
810 	return 0;
811 }
812 
se_dev_set_emulate_ua_intlck_ctrl(struct se_device * dev,int flag)813 int se_dev_set_emulate_ua_intlck_ctrl(struct se_device *dev, int flag)
814 {
815 	if ((flag != 0) && (flag != 1) && (flag != 2)) {
816 		pr_err("Illegal value %d\n", flag);
817 		return -EINVAL;
818 	}
819 
820 	if (dev->export_count) {
821 		pr_err("dev[%p]: Unable to change SE Device"
822 			" UA_INTRLCK_CTRL while export_count is %d\n",
823 			dev, dev->export_count);
824 		return -EINVAL;
825 	}
826 	dev->dev_attrib.emulate_ua_intlck_ctrl = flag;
827 	pr_debug("dev[%p]: SE Device UA_INTRLCK_CTRL flag: %d\n",
828 		dev, dev->dev_attrib.emulate_ua_intlck_ctrl);
829 
830 	return 0;
831 }
832 
se_dev_set_emulate_tas(struct se_device * dev,int flag)833 int se_dev_set_emulate_tas(struct se_device *dev, int flag)
834 {
835 	if ((flag != 0) && (flag != 1)) {
836 		pr_err("Illegal value %d\n", flag);
837 		return -EINVAL;
838 	}
839 
840 	if (dev->export_count) {
841 		pr_err("dev[%p]: Unable to change SE Device TAS while"
842 			" export_count is %d\n",
843 			dev, dev->export_count);
844 		return -EINVAL;
845 	}
846 	dev->dev_attrib.emulate_tas = flag;
847 	pr_debug("dev[%p]: SE Device TASK_ABORTED status bit: %s\n",
848 		dev, (dev->dev_attrib.emulate_tas) ? "Enabled" : "Disabled");
849 
850 	return 0;
851 }
852 
se_dev_set_emulate_tpu(struct se_device * dev,int flag)853 int se_dev_set_emulate_tpu(struct se_device *dev, int flag)
854 {
855 	if ((flag != 0) && (flag != 1)) {
856 		pr_err("Illegal value %d\n", flag);
857 		return -EINVAL;
858 	}
859 	/*
860 	 * We expect this value to be non-zero when generic Block Layer
861 	 * Discard supported is detected iblock_create_virtdevice().
862 	 */
863 	if (flag && !dev->dev_attrib.max_unmap_block_desc_count) {
864 		pr_err("Generic Block Discard not supported\n");
865 		return -ENOSYS;
866 	}
867 
868 	dev->dev_attrib.emulate_tpu = flag;
869 	pr_debug("dev[%p]: SE Device Thin Provisioning UNMAP bit: %d\n",
870 				dev, flag);
871 	return 0;
872 }
873 
se_dev_set_emulate_tpws(struct se_device * dev,int flag)874 int se_dev_set_emulate_tpws(struct se_device *dev, int flag)
875 {
876 	if ((flag != 0) && (flag != 1)) {
877 		pr_err("Illegal value %d\n", flag);
878 		return -EINVAL;
879 	}
880 	/*
881 	 * We expect this value to be non-zero when generic Block Layer
882 	 * Discard supported is detected iblock_create_virtdevice().
883 	 */
884 	if (flag && !dev->dev_attrib.max_unmap_block_desc_count) {
885 		pr_err("Generic Block Discard not supported\n");
886 		return -ENOSYS;
887 	}
888 
889 	dev->dev_attrib.emulate_tpws = flag;
890 	pr_debug("dev[%p]: SE Device Thin Provisioning WRITE_SAME: %d\n",
891 				dev, flag);
892 	return 0;
893 }
894 
se_dev_set_emulate_caw(struct se_device * dev,int flag)895 int se_dev_set_emulate_caw(struct se_device *dev, int flag)
896 {
897 	if (flag != 0 && flag != 1) {
898 		pr_err("Illegal value %d\n", flag);
899 		return -EINVAL;
900 	}
901 	dev->dev_attrib.emulate_caw = flag;
902 	pr_debug("dev[%p]: SE Device CompareAndWrite (AtomicTestandSet): %d\n",
903 		 dev, flag);
904 
905 	return 0;
906 }
907 
se_dev_set_emulate_3pc(struct se_device * dev,int flag)908 int se_dev_set_emulate_3pc(struct se_device *dev, int flag)
909 {
910 	if (flag != 0 && flag != 1) {
911 		pr_err("Illegal value %d\n", flag);
912 		return -EINVAL;
913 	}
914 	dev->dev_attrib.emulate_3pc = flag;
915 	pr_debug("dev[%p]: SE Device 3rd Party Copy (EXTENDED_COPY): %d\n",
916 		dev, flag);
917 
918 	return 0;
919 }
920 
se_dev_set_pi_prot_type(struct se_device * dev,int flag)921 int se_dev_set_pi_prot_type(struct se_device *dev, int flag)
922 {
923 	int rc, old_prot = dev->dev_attrib.pi_prot_type;
924 
925 	if (flag != 0 && flag != 1 && flag != 2 && flag != 3) {
926 		pr_err("Illegal value %d for pi_prot_type\n", flag);
927 		return -EINVAL;
928 	}
929 	if (flag == 2) {
930 		pr_err("DIF TYPE2 protection currently not supported\n");
931 		return -ENOSYS;
932 	}
933 	if (dev->dev_attrib.hw_pi_prot_type) {
934 		pr_warn("DIF protection enabled on underlying hardware,"
935 			" ignoring\n");
936 		return 0;
937 	}
938 	if (!dev->transport->init_prot || !dev->transport->free_prot) {
939 		/* 0 is only allowed value for non-supporting backends */
940 		if (flag == 0)
941 			return 0;
942 
943 		pr_err("DIF protection not supported by backend: %s\n",
944 		       dev->transport->name);
945 		return -ENOSYS;
946 	}
947 	if (!(dev->dev_flags & DF_CONFIGURED)) {
948 		pr_err("DIF protection requires device to be configured\n");
949 		return -ENODEV;
950 	}
951 	if (dev->export_count) {
952 		pr_err("dev[%p]: Unable to change SE Device PROT type while"
953 		       " export_count is %d\n", dev, dev->export_count);
954 		return -EINVAL;
955 	}
956 
957 	dev->dev_attrib.pi_prot_type = flag;
958 
959 	if (flag && !old_prot) {
960 		rc = dev->transport->init_prot(dev);
961 		if (rc) {
962 			dev->dev_attrib.pi_prot_type = old_prot;
963 			return rc;
964 		}
965 
966 	} else if (!flag && old_prot) {
967 		dev->transport->free_prot(dev);
968 	}
969 	pr_debug("dev[%p]: SE Device Protection Type: %d\n", dev, flag);
970 
971 	return 0;
972 }
973 
se_dev_set_pi_prot_format(struct se_device * dev,int flag)974 int se_dev_set_pi_prot_format(struct se_device *dev, int flag)
975 {
976 	int rc;
977 
978 	if (!flag)
979 		return 0;
980 
981 	if (flag != 1) {
982 		pr_err("Illegal value %d for pi_prot_format\n", flag);
983 		return -EINVAL;
984 	}
985 	if (!dev->transport->format_prot) {
986 		pr_err("DIF protection format not supported by backend %s\n",
987 		       dev->transport->name);
988 		return -ENOSYS;
989 	}
990 	if (!(dev->dev_flags & DF_CONFIGURED)) {
991 		pr_err("DIF protection format requires device to be configured\n");
992 		return -ENODEV;
993 	}
994 	if (dev->export_count) {
995 		pr_err("dev[%p]: Unable to format SE Device PROT type while"
996 		       " export_count is %d\n", dev, dev->export_count);
997 		return -EINVAL;
998 	}
999 
1000 	rc = dev->transport->format_prot(dev);
1001 	if (rc)
1002 		return rc;
1003 
1004 	pr_debug("dev[%p]: SE Device Protection Format complete\n", dev);
1005 
1006 	return 0;
1007 }
1008 
se_dev_set_enforce_pr_isids(struct se_device * dev,int flag)1009 int se_dev_set_enforce_pr_isids(struct se_device *dev, int flag)
1010 {
1011 	if ((flag != 0) && (flag != 1)) {
1012 		pr_err("Illegal value %d\n", flag);
1013 		return -EINVAL;
1014 	}
1015 	dev->dev_attrib.enforce_pr_isids = flag;
1016 	pr_debug("dev[%p]: SE Device enforce_pr_isids bit: %s\n", dev,
1017 		(dev->dev_attrib.enforce_pr_isids) ? "Enabled" : "Disabled");
1018 	return 0;
1019 }
1020 
se_dev_set_force_pr_aptpl(struct se_device * dev,int flag)1021 int se_dev_set_force_pr_aptpl(struct se_device *dev, int flag)
1022 {
1023 	if ((flag != 0) && (flag != 1)) {
1024 		printk(KERN_ERR "Illegal value %d\n", flag);
1025 		return -EINVAL;
1026 	}
1027 	if (dev->export_count) {
1028 		pr_err("dev[%p]: Unable to set force_pr_aptpl while"
1029 		       " export_count is %d\n", dev, dev->export_count);
1030 		return -EINVAL;
1031 	}
1032 
1033 	dev->dev_attrib.force_pr_aptpl = flag;
1034 	pr_debug("dev[%p]: SE Device force_pr_aptpl: %d\n", dev, flag);
1035 	return 0;
1036 }
1037 
se_dev_set_is_nonrot(struct se_device * dev,int flag)1038 int se_dev_set_is_nonrot(struct se_device *dev, int flag)
1039 {
1040 	if ((flag != 0) && (flag != 1)) {
1041 		printk(KERN_ERR "Illegal value %d\n", flag);
1042 		return -EINVAL;
1043 	}
1044 	dev->dev_attrib.is_nonrot = flag;
1045 	pr_debug("dev[%p]: SE Device is_nonrot bit: %d\n",
1046 	       dev, flag);
1047 	return 0;
1048 }
1049 
se_dev_set_emulate_rest_reord(struct se_device * dev,int flag)1050 int se_dev_set_emulate_rest_reord(struct se_device *dev, int flag)
1051 {
1052 	if (flag != 0) {
1053 		printk(KERN_ERR "dev[%p]: SE Device emulatation of restricted"
1054 			" reordering not implemented\n", dev);
1055 		return -ENOSYS;
1056 	}
1057 	dev->dev_attrib.emulate_rest_reord = flag;
1058 	pr_debug("dev[%p]: SE Device emulate_rest_reord: %d\n", dev, flag);
1059 	return 0;
1060 }
1061 
1062 /*
1063  * Note, this can only be called on unexported SE Device Object.
1064  */
se_dev_set_queue_depth(struct se_device * dev,u32 queue_depth)1065 int se_dev_set_queue_depth(struct se_device *dev, u32 queue_depth)
1066 {
1067 	if (dev->export_count) {
1068 		pr_err("dev[%p]: Unable to change SE Device TCQ while"
1069 			" export_count is %d\n",
1070 			dev, dev->export_count);
1071 		return -EINVAL;
1072 	}
1073 	if (!queue_depth) {
1074 		pr_err("dev[%p]: Illegal ZERO value for queue"
1075 			"_depth\n", dev);
1076 		return -EINVAL;
1077 	}
1078 
1079 	if (dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) {
1080 		if (queue_depth > dev->dev_attrib.hw_queue_depth) {
1081 			pr_err("dev[%p]: Passed queue_depth: %u"
1082 				" exceeds TCM/SE_Device TCQ: %u\n",
1083 				dev, queue_depth,
1084 				dev->dev_attrib.hw_queue_depth);
1085 			return -EINVAL;
1086 		}
1087 	} else {
1088 		if (queue_depth > dev->dev_attrib.queue_depth) {
1089 			if (queue_depth > dev->dev_attrib.hw_queue_depth) {
1090 				pr_err("dev[%p]: Passed queue_depth:"
1091 					" %u exceeds TCM/SE_Device MAX"
1092 					" TCQ: %u\n", dev, queue_depth,
1093 					dev->dev_attrib.hw_queue_depth);
1094 				return -EINVAL;
1095 			}
1096 		}
1097 	}
1098 
1099 	dev->dev_attrib.queue_depth = dev->queue_depth = queue_depth;
1100 	pr_debug("dev[%p]: SE Device TCQ Depth changed to: %u\n",
1101 			dev, queue_depth);
1102 	return 0;
1103 }
1104 
se_dev_set_fabric_max_sectors(struct se_device * dev,u32 fabric_max_sectors)1105 int se_dev_set_fabric_max_sectors(struct se_device *dev, u32 fabric_max_sectors)
1106 {
1107 	int block_size = dev->dev_attrib.block_size;
1108 
1109 	if (dev->export_count) {
1110 		pr_err("dev[%p]: Unable to change SE Device"
1111 			" fabric_max_sectors while export_count is %d\n",
1112 			dev, dev->export_count);
1113 		return -EINVAL;
1114 	}
1115 	if (!fabric_max_sectors) {
1116 		pr_err("dev[%p]: Illegal ZERO value for"
1117 			" fabric_max_sectors\n", dev);
1118 		return -EINVAL;
1119 	}
1120 	if (fabric_max_sectors < DA_STATUS_MAX_SECTORS_MIN) {
1121 		pr_err("dev[%p]: Passed fabric_max_sectors: %u less than"
1122 			" DA_STATUS_MAX_SECTORS_MIN: %u\n", dev, fabric_max_sectors,
1123 				DA_STATUS_MAX_SECTORS_MIN);
1124 		return -EINVAL;
1125 	}
1126 	if (dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) {
1127 		if (fabric_max_sectors > dev->dev_attrib.hw_max_sectors) {
1128 			pr_err("dev[%p]: Passed fabric_max_sectors: %u"
1129 				" greater than TCM/SE_Device max_sectors:"
1130 				" %u\n", dev, fabric_max_sectors,
1131 				dev->dev_attrib.hw_max_sectors);
1132 			 return -EINVAL;
1133 		}
1134 	} else {
1135 		if (fabric_max_sectors > DA_STATUS_MAX_SECTORS_MAX) {
1136 			pr_err("dev[%p]: Passed fabric_max_sectors: %u"
1137 				" greater than DA_STATUS_MAX_SECTORS_MAX:"
1138 				" %u\n", dev, fabric_max_sectors,
1139 				DA_STATUS_MAX_SECTORS_MAX);
1140 			return -EINVAL;
1141 		}
1142 	}
1143 	/*
1144 	 * Align max_sectors down to PAGE_SIZE to follow transport_allocate_data_tasks()
1145 	 */
1146 	if (!block_size) {
1147 		block_size = 512;
1148 		pr_warn("Defaulting to 512 for zero block_size\n");
1149 	}
1150 	fabric_max_sectors = se_dev_align_max_sectors(fabric_max_sectors,
1151 						      block_size);
1152 
1153 	dev->dev_attrib.fabric_max_sectors = fabric_max_sectors;
1154 	pr_debug("dev[%p]: SE Device max_sectors changed to %u\n",
1155 			dev, fabric_max_sectors);
1156 	return 0;
1157 }
1158 
se_dev_set_optimal_sectors(struct se_device * dev,u32 optimal_sectors)1159 int se_dev_set_optimal_sectors(struct se_device *dev, u32 optimal_sectors)
1160 {
1161 	if (dev->export_count) {
1162 		pr_err("dev[%p]: Unable to change SE Device"
1163 			" optimal_sectors while export_count is %d\n",
1164 			dev, dev->export_count);
1165 		return -EINVAL;
1166 	}
1167 	if (dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) {
1168 		pr_err("dev[%p]: Passed optimal_sectors cannot be"
1169 				" changed for TCM/pSCSI\n", dev);
1170 		return -EINVAL;
1171 	}
1172 	if (optimal_sectors > dev->dev_attrib.hw_max_sectors) {
1173 		pr_err("dev[%p]: Passed optimal_sectors %u cannot be"
1174 			" greater than hw_max_sectors: %u\n", dev,
1175 			optimal_sectors, dev->dev_attrib.hw_max_sectors);
1176 		return -EINVAL;
1177 	}
1178 
1179 	dev->dev_attrib.optimal_sectors = optimal_sectors;
1180 	pr_debug("dev[%p]: SE Device optimal_sectors changed to %u\n",
1181 			dev, optimal_sectors);
1182 	return 0;
1183 }
1184 
se_dev_set_block_size(struct se_device * dev,u32 block_size)1185 int se_dev_set_block_size(struct se_device *dev, u32 block_size)
1186 {
1187 	if (dev->export_count) {
1188 		pr_err("dev[%p]: Unable to change SE Device block_size"
1189 			" while export_count is %d\n",
1190 			dev, dev->export_count);
1191 		return -EINVAL;
1192 	}
1193 
1194 	if ((block_size != 512) &&
1195 	    (block_size != 1024) &&
1196 	    (block_size != 2048) &&
1197 	    (block_size != 4096)) {
1198 		pr_err("dev[%p]: Illegal value for block_device: %u"
1199 			" for SE device, must be 512, 1024, 2048 or 4096\n",
1200 			dev, block_size);
1201 		return -EINVAL;
1202 	}
1203 
1204 	if (dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) {
1205 		pr_err("dev[%p]: Not allowed to change block_size for"
1206 			" Physical Device, use for Linux/SCSI to change"
1207 			" block_size for underlying hardware\n", dev);
1208 		return -EINVAL;
1209 	}
1210 
1211 	dev->dev_attrib.block_size = block_size;
1212 	pr_debug("dev[%p]: SE Device block_size changed to %u\n",
1213 			dev, block_size);
1214 
1215 	if (dev->dev_attrib.max_bytes_per_io)
1216 		dev->dev_attrib.hw_max_sectors =
1217 			dev->dev_attrib.max_bytes_per_io / block_size;
1218 
1219 	return 0;
1220 }
1221 
core_dev_add_lun(struct se_portal_group * tpg,struct se_device * dev,u32 unpacked_lun)1222 struct se_lun *core_dev_add_lun(
1223 	struct se_portal_group *tpg,
1224 	struct se_device *dev,
1225 	u32 unpacked_lun)
1226 {
1227 	struct se_lun *lun;
1228 	int rc;
1229 
1230 	lun = core_tpg_alloc_lun(tpg, unpacked_lun);
1231 	if (IS_ERR(lun))
1232 		return lun;
1233 
1234 	rc = core_tpg_add_lun(tpg, lun,
1235 				TRANSPORT_LUNFLAGS_READ_WRITE, dev);
1236 	if (rc < 0)
1237 		return ERR_PTR(rc);
1238 
1239 	pr_debug("%s_TPG[%u]_LUN[%u] - Activated %s Logical Unit from"
1240 		" CORE HBA: %u\n", tpg->se_tpg_tfo->get_fabric_name(),
1241 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun,
1242 		tpg->se_tpg_tfo->get_fabric_name(), dev->se_hba->hba_id);
1243 	/*
1244 	 * Update LUN maps for dynamically added initiators when
1245 	 * generate_node_acl is enabled.
1246 	 */
1247 	if (tpg->se_tpg_tfo->tpg_check_demo_mode(tpg)) {
1248 		struct se_node_acl *acl;
1249 		spin_lock_irq(&tpg->acl_node_lock);
1250 		list_for_each_entry(acl, &tpg->acl_node_list, acl_list) {
1251 			if (acl->dynamic_node_acl &&
1252 			    (!tpg->se_tpg_tfo->tpg_check_demo_mode_login_only ||
1253 			     !tpg->se_tpg_tfo->tpg_check_demo_mode_login_only(tpg))) {
1254 				spin_unlock_irq(&tpg->acl_node_lock);
1255 				core_tpg_add_node_to_devs(acl, tpg);
1256 				spin_lock_irq(&tpg->acl_node_lock);
1257 			}
1258 		}
1259 		spin_unlock_irq(&tpg->acl_node_lock);
1260 	}
1261 
1262 	return lun;
1263 }
1264 
1265 /*      core_dev_del_lun():
1266  *
1267  *
1268  */
core_dev_del_lun(struct se_portal_group * tpg,struct se_lun * lun)1269 void core_dev_del_lun(
1270 	struct se_portal_group *tpg,
1271 	struct se_lun *lun)
1272 {
1273 	pr_debug("%s_TPG[%u]_LUN[%u] - Deactivating %s Logical Unit from"
1274 		" device object\n", tpg->se_tpg_tfo->get_fabric_name(),
1275 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun,
1276 		tpg->se_tpg_tfo->get_fabric_name());
1277 
1278 	core_tpg_remove_lun(tpg, lun);
1279 }
1280 
core_get_lun_from_tpg(struct se_portal_group * tpg,u32 unpacked_lun)1281 struct se_lun *core_get_lun_from_tpg(struct se_portal_group *tpg, u32 unpacked_lun)
1282 {
1283 	struct se_lun *lun;
1284 
1285 	spin_lock(&tpg->tpg_lun_lock);
1286 	if (unpacked_lun > (TRANSPORT_MAX_LUNS_PER_TPG-1)) {
1287 		pr_err("%s LUN: %u exceeds TRANSPORT_MAX_LUNS"
1288 			"_PER_TPG-1: %u for Target Portal Group: %hu\n",
1289 			tpg->se_tpg_tfo->get_fabric_name(), unpacked_lun,
1290 			TRANSPORT_MAX_LUNS_PER_TPG-1,
1291 			tpg->se_tpg_tfo->tpg_get_tag(tpg));
1292 		spin_unlock(&tpg->tpg_lun_lock);
1293 		return NULL;
1294 	}
1295 	lun = tpg->tpg_lun_list[unpacked_lun];
1296 
1297 	if (lun->lun_status != TRANSPORT_LUN_STATUS_FREE) {
1298 		pr_err("%s Logical Unit Number: %u is not free on"
1299 			" Target Portal Group: %hu, ignoring request.\n",
1300 			tpg->se_tpg_tfo->get_fabric_name(), unpacked_lun,
1301 			tpg->se_tpg_tfo->tpg_get_tag(tpg));
1302 		spin_unlock(&tpg->tpg_lun_lock);
1303 		return NULL;
1304 	}
1305 	spin_unlock(&tpg->tpg_lun_lock);
1306 
1307 	return lun;
1308 }
1309 
1310 /*      core_dev_get_lun():
1311  *
1312  *
1313  */
core_dev_get_lun(struct se_portal_group * tpg,u32 unpacked_lun)1314 static struct se_lun *core_dev_get_lun(struct se_portal_group *tpg, u32 unpacked_lun)
1315 {
1316 	struct se_lun *lun;
1317 
1318 	spin_lock(&tpg->tpg_lun_lock);
1319 	if (unpacked_lun > (TRANSPORT_MAX_LUNS_PER_TPG-1)) {
1320 		pr_err("%s LUN: %u exceeds TRANSPORT_MAX_LUNS_PER"
1321 			"_TPG-1: %u for Target Portal Group: %hu\n",
1322 			tpg->se_tpg_tfo->get_fabric_name(), unpacked_lun,
1323 			TRANSPORT_MAX_LUNS_PER_TPG-1,
1324 			tpg->se_tpg_tfo->tpg_get_tag(tpg));
1325 		spin_unlock(&tpg->tpg_lun_lock);
1326 		return NULL;
1327 	}
1328 	lun = tpg->tpg_lun_list[unpacked_lun];
1329 
1330 	if (lun->lun_status != TRANSPORT_LUN_STATUS_ACTIVE) {
1331 		pr_err("%s Logical Unit Number: %u is not active on"
1332 			" Target Portal Group: %hu, ignoring request.\n",
1333 			tpg->se_tpg_tfo->get_fabric_name(), unpacked_lun,
1334 			tpg->se_tpg_tfo->tpg_get_tag(tpg));
1335 		spin_unlock(&tpg->tpg_lun_lock);
1336 		return NULL;
1337 	}
1338 	spin_unlock(&tpg->tpg_lun_lock);
1339 
1340 	return lun;
1341 }
1342 
core_dev_init_initiator_node_lun_acl(struct se_portal_group * tpg,struct se_node_acl * nacl,u32 mapped_lun,int * ret)1343 struct se_lun_acl *core_dev_init_initiator_node_lun_acl(
1344 	struct se_portal_group *tpg,
1345 	struct se_node_acl *nacl,
1346 	u32 mapped_lun,
1347 	int *ret)
1348 {
1349 	struct se_lun_acl *lacl;
1350 
1351 	if (strlen(nacl->initiatorname) >= TRANSPORT_IQN_LEN) {
1352 		pr_err("%s InitiatorName exceeds maximum size.\n",
1353 			tpg->se_tpg_tfo->get_fabric_name());
1354 		*ret = -EOVERFLOW;
1355 		return NULL;
1356 	}
1357 	lacl = kzalloc(sizeof(struct se_lun_acl), GFP_KERNEL);
1358 	if (!lacl) {
1359 		pr_err("Unable to allocate memory for struct se_lun_acl.\n");
1360 		*ret = -ENOMEM;
1361 		return NULL;
1362 	}
1363 
1364 	INIT_LIST_HEAD(&lacl->lacl_list);
1365 	lacl->mapped_lun = mapped_lun;
1366 	lacl->se_lun_nacl = nacl;
1367 	snprintf(lacl->initiatorname, TRANSPORT_IQN_LEN, "%s",
1368 		 nacl->initiatorname);
1369 
1370 	return lacl;
1371 }
1372 
core_dev_add_initiator_node_lun_acl(struct se_portal_group * tpg,struct se_lun_acl * lacl,u32 unpacked_lun,u32 lun_access)1373 int core_dev_add_initiator_node_lun_acl(
1374 	struct se_portal_group *tpg,
1375 	struct se_lun_acl *lacl,
1376 	u32 unpacked_lun,
1377 	u32 lun_access)
1378 {
1379 	struct se_lun *lun;
1380 	struct se_node_acl *nacl;
1381 
1382 	lun = core_dev_get_lun(tpg, unpacked_lun);
1383 	if (!lun) {
1384 		pr_err("%s Logical Unit Number: %u is not active on"
1385 			" Target Portal Group: %hu, ignoring request.\n",
1386 			tpg->se_tpg_tfo->get_fabric_name(), unpacked_lun,
1387 			tpg->se_tpg_tfo->tpg_get_tag(tpg));
1388 		return -EINVAL;
1389 	}
1390 
1391 	nacl = lacl->se_lun_nacl;
1392 	if (!nacl)
1393 		return -EINVAL;
1394 
1395 	if ((lun->lun_access & TRANSPORT_LUNFLAGS_READ_ONLY) &&
1396 	    (lun_access & TRANSPORT_LUNFLAGS_READ_WRITE))
1397 		lun_access = TRANSPORT_LUNFLAGS_READ_ONLY;
1398 
1399 	lacl->se_lun = lun;
1400 
1401 	if (core_enable_device_list_for_node(lun, lacl, lacl->mapped_lun,
1402 			lun_access, nacl, tpg) < 0)
1403 		return -EINVAL;
1404 
1405 	spin_lock(&lun->lun_acl_lock);
1406 	list_add_tail(&lacl->lacl_list, &lun->lun_acl_list);
1407 	atomic_inc_mb(&lun->lun_acl_count);
1408 	spin_unlock(&lun->lun_acl_lock);
1409 
1410 	pr_debug("%s_TPG[%hu]_LUN[%u->%u] - Added %s ACL for "
1411 		" InitiatorNode: %s\n", tpg->se_tpg_tfo->get_fabric_name(),
1412 		tpg->se_tpg_tfo->tpg_get_tag(tpg), unpacked_lun, lacl->mapped_lun,
1413 		(lun_access & TRANSPORT_LUNFLAGS_READ_WRITE) ? "RW" : "RO",
1414 		lacl->initiatorname);
1415 	/*
1416 	 * Check to see if there are any existing persistent reservation APTPL
1417 	 * pre-registrations that need to be enabled for this LUN ACL..
1418 	 */
1419 	core_scsi3_check_aptpl_registration(lun->lun_se_dev, tpg, lun, nacl,
1420 					    lacl->mapped_lun);
1421 	return 0;
1422 }
1423 
1424 /*      core_dev_del_initiator_node_lun_acl():
1425  *
1426  *
1427  */
core_dev_del_initiator_node_lun_acl(struct se_portal_group * tpg,struct se_lun * lun,struct se_lun_acl * lacl)1428 int core_dev_del_initiator_node_lun_acl(
1429 	struct se_portal_group *tpg,
1430 	struct se_lun *lun,
1431 	struct se_lun_acl *lacl)
1432 {
1433 	struct se_node_acl *nacl;
1434 
1435 	nacl = lacl->se_lun_nacl;
1436 	if (!nacl)
1437 		return -EINVAL;
1438 
1439 	spin_lock(&lun->lun_acl_lock);
1440 	list_del(&lacl->lacl_list);
1441 	atomic_dec_mb(&lun->lun_acl_count);
1442 	spin_unlock(&lun->lun_acl_lock);
1443 
1444 	core_disable_device_list_for_node(lun, NULL, lacl->mapped_lun,
1445 		TRANSPORT_LUNFLAGS_NO_ACCESS, nacl, tpg);
1446 
1447 	lacl->se_lun = NULL;
1448 
1449 	pr_debug("%s_TPG[%hu]_LUN[%u] - Removed ACL for"
1450 		" InitiatorNode: %s Mapped LUN: %u\n",
1451 		tpg->se_tpg_tfo->get_fabric_name(),
1452 		tpg->se_tpg_tfo->tpg_get_tag(tpg), lun->unpacked_lun,
1453 		lacl->initiatorname, lacl->mapped_lun);
1454 
1455 	return 0;
1456 }
1457 
core_dev_free_initiator_node_lun_acl(struct se_portal_group * tpg,struct se_lun_acl * lacl)1458 void core_dev_free_initiator_node_lun_acl(
1459 	struct se_portal_group *tpg,
1460 	struct se_lun_acl *lacl)
1461 {
1462 	pr_debug("%s_TPG[%hu] - Freeing ACL for %s InitiatorNode: %s"
1463 		" Mapped LUN: %u\n", tpg->se_tpg_tfo->get_fabric_name(),
1464 		tpg->se_tpg_tfo->tpg_get_tag(tpg),
1465 		tpg->se_tpg_tfo->get_fabric_name(),
1466 		lacl->initiatorname, lacl->mapped_lun);
1467 
1468 	kfree(lacl);
1469 }
1470 
scsi_dump_inquiry(struct se_device * dev)1471 static void scsi_dump_inquiry(struct se_device *dev)
1472 {
1473 	struct t10_wwn *wwn = &dev->t10_wwn;
1474 	char buf[17];
1475 	int i, device_type;
1476 	/*
1477 	 * Print Linux/SCSI style INQUIRY formatting to the kernel ring buffer
1478 	 */
1479 	for (i = 0; i < 8; i++)
1480 		if (wwn->vendor[i] >= 0x20)
1481 			buf[i] = wwn->vendor[i];
1482 		else
1483 			buf[i] = ' ';
1484 	buf[i] = '\0';
1485 	pr_debug("  Vendor: %s\n", buf);
1486 
1487 	for (i = 0; i < 16; i++)
1488 		if (wwn->model[i] >= 0x20)
1489 			buf[i] = wwn->model[i];
1490 		else
1491 			buf[i] = ' ';
1492 	buf[i] = '\0';
1493 	pr_debug("  Model: %s\n", buf);
1494 
1495 	for (i = 0; i < 4; i++)
1496 		if (wwn->revision[i] >= 0x20)
1497 			buf[i] = wwn->revision[i];
1498 		else
1499 			buf[i] = ' ';
1500 	buf[i] = '\0';
1501 	pr_debug("  Revision: %s\n", buf);
1502 
1503 	device_type = dev->transport->get_device_type(dev);
1504 	pr_debug("  Type:   %s ", scsi_device_type(device_type));
1505 }
1506 
target_alloc_device(struct se_hba * hba,const char * name)1507 struct se_device *target_alloc_device(struct se_hba *hba, const char *name)
1508 {
1509 	struct se_device *dev;
1510 	struct se_lun *xcopy_lun;
1511 
1512 	dev = hba->transport->alloc_device(hba, name);
1513 	if (!dev)
1514 		return NULL;
1515 
1516 	dev->dev_link_magic = SE_DEV_LINK_MAGIC;
1517 	dev->se_hba = hba;
1518 	dev->transport = hba->transport;
1519 	dev->prot_length = sizeof(struct se_dif_v1_tuple);
1520 
1521 	INIT_LIST_HEAD(&dev->dev_list);
1522 	INIT_LIST_HEAD(&dev->dev_sep_list);
1523 	INIT_LIST_HEAD(&dev->dev_tmr_list);
1524 	INIT_LIST_HEAD(&dev->delayed_cmd_list);
1525 	INIT_LIST_HEAD(&dev->state_list);
1526 	INIT_LIST_HEAD(&dev->qf_cmd_list);
1527 	INIT_LIST_HEAD(&dev->g_dev_node);
1528 	spin_lock_init(&dev->execute_task_lock);
1529 	spin_lock_init(&dev->delayed_cmd_lock);
1530 	spin_lock_init(&dev->dev_reservation_lock);
1531 	spin_lock_init(&dev->se_port_lock);
1532 	spin_lock_init(&dev->se_tmr_lock);
1533 	spin_lock_init(&dev->qf_cmd_lock);
1534 	sema_init(&dev->caw_sem, 1);
1535 	atomic_set(&dev->dev_ordered_id, 0);
1536 	INIT_LIST_HEAD(&dev->t10_wwn.t10_vpd_list);
1537 	spin_lock_init(&dev->t10_wwn.t10_vpd_lock);
1538 	INIT_LIST_HEAD(&dev->t10_pr.registration_list);
1539 	INIT_LIST_HEAD(&dev->t10_pr.aptpl_reg_list);
1540 	spin_lock_init(&dev->t10_pr.registration_lock);
1541 	spin_lock_init(&dev->t10_pr.aptpl_reg_lock);
1542 	INIT_LIST_HEAD(&dev->t10_alua.tg_pt_gps_list);
1543 	spin_lock_init(&dev->t10_alua.tg_pt_gps_lock);
1544 	INIT_LIST_HEAD(&dev->t10_alua.lba_map_list);
1545 	spin_lock_init(&dev->t10_alua.lba_map_lock);
1546 
1547 	dev->t10_wwn.t10_dev = dev;
1548 	dev->t10_alua.t10_dev = dev;
1549 
1550 	dev->dev_attrib.da_dev = dev;
1551 	dev->dev_attrib.emulate_model_alias = DA_EMULATE_MODEL_ALIAS;
1552 	dev->dev_attrib.emulate_dpo = DA_EMULATE_DPO;
1553 	dev->dev_attrib.emulate_fua_write = DA_EMULATE_FUA_WRITE;
1554 	dev->dev_attrib.emulate_fua_read = DA_EMULATE_FUA_READ;
1555 	dev->dev_attrib.emulate_write_cache = DA_EMULATE_WRITE_CACHE;
1556 	dev->dev_attrib.emulate_ua_intlck_ctrl = DA_EMULATE_UA_INTLLCK_CTRL;
1557 	dev->dev_attrib.emulate_tas = DA_EMULATE_TAS;
1558 	dev->dev_attrib.emulate_tpu = DA_EMULATE_TPU;
1559 	dev->dev_attrib.emulate_tpws = DA_EMULATE_TPWS;
1560 	dev->dev_attrib.emulate_caw = DA_EMULATE_CAW;
1561 	dev->dev_attrib.emulate_3pc = DA_EMULATE_3PC;
1562 	dev->dev_attrib.pi_prot_type = TARGET_DIF_TYPE0_PROT;
1563 	dev->dev_attrib.enforce_pr_isids = DA_ENFORCE_PR_ISIDS;
1564 	dev->dev_attrib.force_pr_aptpl = DA_FORCE_PR_APTPL;
1565 	dev->dev_attrib.is_nonrot = DA_IS_NONROT;
1566 	dev->dev_attrib.emulate_rest_reord = DA_EMULATE_REST_REORD;
1567 	dev->dev_attrib.max_unmap_lba_count = DA_MAX_UNMAP_LBA_COUNT;
1568 	dev->dev_attrib.max_unmap_block_desc_count =
1569 		DA_MAX_UNMAP_BLOCK_DESC_COUNT;
1570 	dev->dev_attrib.unmap_granularity = DA_UNMAP_GRANULARITY_DEFAULT;
1571 	dev->dev_attrib.unmap_granularity_alignment =
1572 				DA_UNMAP_GRANULARITY_ALIGNMENT_DEFAULT;
1573 	dev->dev_attrib.max_write_same_len = DA_MAX_WRITE_SAME_LEN;
1574 	dev->dev_attrib.fabric_max_sectors = DA_FABRIC_MAX_SECTORS;
1575 
1576 	xcopy_lun = &dev->xcopy_lun;
1577 	xcopy_lun->lun_se_dev = dev;
1578 	init_completion(&xcopy_lun->lun_shutdown_comp);
1579 	INIT_LIST_HEAD(&xcopy_lun->lun_acl_list);
1580 	spin_lock_init(&xcopy_lun->lun_acl_lock);
1581 	spin_lock_init(&xcopy_lun->lun_sep_lock);
1582 	init_completion(&xcopy_lun->lun_ref_comp);
1583 
1584 	return dev;
1585 }
1586 
target_configure_device(struct se_device * dev)1587 int target_configure_device(struct se_device *dev)
1588 {
1589 	struct se_hba *hba = dev->se_hba;
1590 	int ret;
1591 
1592 	if (dev->dev_flags & DF_CONFIGURED) {
1593 		pr_err("se_dev->se_dev_ptr already set for storage"
1594 				" object\n");
1595 		return -EEXIST;
1596 	}
1597 
1598 	ret = dev->transport->configure_device(dev);
1599 	if (ret)
1600 		goto out;
1601 	/*
1602 	 * XXX: there is not much point to have two different values here..
1603 	 */
1604 	dev->dev_attrib.block_size = dev->dev_attrib.hw_block_size;
1605 	dev->dev_attrib.queue_depth = dev->dev_attrib.hw_queue_depth;
1606 
1607 	/*
1608 	 * Align max_hw_sectors down to PAGE_SIZE I/O transfers
1609 	 */
1610 	dev->dev_attrib.hw_max_sectors =
1611 		se_dev_align_max_sectors(dev->dev_attrib.hw_max_sectors,
1612 					 dev->dev_attrib.hw_block_size);
1613 	dev->dev_attrib.optimal_sectors = dev->dev_attrib.hw_max_sectors;
1614 
1615 	dev->dev_index = scsi_get_new_index(SCSI_DEVICE_INDEX);
1616 	dev->creation_time = get_jiffies_64();
1617 
1618 	ret = core_setup_alua(dev);
1619 	if (ret)
1620 		goto out;
1621 
1622 	/*
1623 	 * Startup the struct se_device processing thread
1624 	 */
1625 	dev->tmr_wq = alloc_workqueue("tmr-%s", WQ_MEM_RECLAIM | WQ_UNBOUND, 1,
1626 				      dev->transport->name);
1627 	if (!dev->tmr_wq) {
1628 		pr_err("Unable to create tmr workqueue for %s\n",
1629 			dev->transport->name);
1630 		ret = -ENOMEM;
1631 		goto out_free_alua;
1632 	}
1633 
1634 	/*
1635 	 * Setup work_queue for QUEUE_FULL
1636 	 */
1637 	INIT_WORK(&dev->qf_work_queue, target_qf_do_work);
1638 
1639 	/*
1640 	 * Preload the initial INQUIRY const values if we are doing
1641 	 * anything virtual (IBLOCK, FILEIO, RAMDISK), but not for TCM/pSCSI
1642 	 * passthrough because this is being provided by the backend LLD.
1643 	 */
1644 	if (dev->transport->transport_type != TRANSPORT_PLUGIN_PHBA_PDEV) {
1645 		strncpy(&dev->t10_wwn.vendor[0], "LIO-ORG", 8);
1646 		strncpy(&dev->t10_wwn.model[0],
1647 			dev->transport->inquiry_prod, 16);
1648 		strncpy(&dev->t10_wwn.revision[0],
1649 			dev->transport->inquiry_rev, 4);
1650 	}
1651 
1652 	scsi_dump_inquiry(dev);
1653 
1654 	spin_lock(&hba->device_lock);
1655 	hba->dev_count++;
1656 	spin_unlock(&hba->device_lock);
1657 
1658 	mutex_lock(&g_device_mutex);
1659 	list_add_tail(&dev->g_dev_node, &g_device_list);
1660 	mutex_unlock(&g_device_mutex);
1661 
1662 	dev->dev_flags |= DF_CONFIGURED;
1663 
1664 	return 0;
1665 
1666 out_free_alua:
1667 	core_alua_free_lu_gp_mem(dev);
1668 out:
1669 	se_release_vpd_for_dev(dev);
1670 	return ret;
1671 }
1672 
target_free_device(struct se_device * dev)1673 void target_free_device(struct se_device *dev)
1674 {
1675 	struct se_hba *hba = dev->se_hba;
1676 
1677 	WARN_ON(!list_empty(&dev->dev_sep_list));
1678 
1679 	if (dev->dev_flags & DF_CONFIGURED) {
1680 		destroy_workqueue(dev->tmr_wq);
1681 
1682 		mutex_lock(&g_device_mutex);
1683 		list_del(&dev->g_dev_node);
1684 		mutex_unlock(&g_device_mutex);
1685 
1686 		spin_lock(&hba->device_lock);
1687 		hba->dev_count--;
1688 		spin_unlock(&hba->device_lock);
1689 	}
1690 
1691 	core_alua_free_lu_gp_mem(dev);
1692 	core_alua_set_lba_map(dev, NULL, 0, 0);
1693 	core_scsi3_free_all_registrations(dev);
1694 	se_release_vpd_for_dev(dev);
1695 
1696 	if (dev->transport->free_prot)
1697 		dev->transport->free_prot(dev);
1698 
1699 	dev->transport->free_device(dev);
1700 }
1701 
core_dev_setup_virtual_lun0(void)1702 int core_dev_setup_virtual_lun0(void)
1703 {
1704 	struct se_hba *hba;
1705 	struct se_device *dev;
1706 	char buf[] = "rd_pages=8,rd_nullio=1";
1707 	int ret;
1708 
1709 	hba = core_alloc_hba("rd_mcp", 0, HBA_FLAGS_INTERNAL_USE);
1710 	if (IS_ERR(hba))
1711 		return PTR_ERR(hba);
1712 
1713 	dev = target_alloc_device(hba, "virt_lun0");
1714 	if (!dev) {
1715 		ret = -ENOMEM;
1716 		goto out_free_hba;
1717 	}
1718 
1719 	hba->transport->set_configfs_dev_params(dev, buf, sizeof(buf));
1720 
1721 	ret = target_configure_device(dev);
1722 	if (ret)
1723 		goto out_free_se_dev;
1724 
1725 	lun0_hba = hba;
1726 	g_lun0_dev = dev;
1727 	return 0;
1728 
1729 out_free_se_dev:
1730 	target_free_device(dev);
1731 out_free_hba:
1732 	core_delete_hba(hba);
1733 	return ret;
1734 }
1735 
1736 
core_dev_release_virtual_lun0(void)1737 void core_dev_release_virtual_lun0(void)
1738 {
1739 	struct se_hba *hba = lun0_hba;
1740 
1741 	if (!hba)
1742 		return;
1743 
1744 	if (g_lun0_dev)
1745 		target_free_device(g_lun0_dev);
1746 	core_delete_hba(hba);
1747 }
1748