1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24#include <linux/module.h>
25#include <linux/moduleparam.h>
26#include <generated/utsrelease.h>
27#include <linux/utsname.h>
28#include <linux/init.h>
29#include <linux/slab.h>
30#include <linux/kthread.h>
31#include <linux/types.h>
32#include <linux/string.h>
33#include <linux/configfs.h>
34#include <linux/kernel.h>
35#include <linux/ctype.h>
36#include <asm/unaligned.h>
37#include <scsi/libfc.h>
38
39#include <target/target_core_base.h>
40#include <target/target_core_fabric.h>
41
42#include "tcm_fc.h"
43
44static LIST_HEAD(ft_wwn_list);
45DEFINE_MUTEX(ft_lport_lock);
46
47unsigned int ft_debug_logging;
48module_param_named(debug_logging, ft_debug_logging, int, S_IRUGO|S_IWUSR);
49MODULE_PARM_DESC(debug_logging, "a bit mask of logging levels");
50
51
52
53
54
55
56
57static ssize_t ft_parse_wwn(const char *name, u64 *wwn, int strict)
58{
59 const char *cp;
60 char c;
61 u32 byte = 0;
62 u32 pos = 0;
63 u32 err;
64 int val;
65
66 *wwn = 0;
67 for (cp = name; cp < &name[FT_NAMELEN - 1]; cp++) {
68 c = *cp;
69 if (c == '\n' && cp[1] == '\0')
70 continue;
71 if (strict && pos++ == 2 && byte++ < 7) {
72 pos = 0;
73 if (c == ':')
74 continue;
75 err = 1;
76 goto fail;
77 }
78 if (c == '\0') {
79 err = 2;
80 if (strict && byte != 8)
81 goto fail;
82 return cp - name;
83 }
84 err = 3;
85 val = hex_to_bin(c);
86 if (val < 0 || (strict && isupper(c)))
87 goto fail;
88 *wwn = (*wwn << 4) | val;
89 }
90 err = 4;
91fail:
92 pr_debug("err %u len %zu pos %u byte %u\n",
93 err, cp - name, pos, byte);
94 return -1;
95}
96
97ssize_t ft_format_wwn(char *buf, size_t len, u64 wwn)
98{
99 u8 b[8];
100
101 put_unaligned_be64(wwn, b);
102 return snprintf(buf, len,
103 "%2.2x:%2.2x:%2.2x:%2.2x:%2.2x:%2.2x:%2.2x:%2.2x",
104 b[0], b[1], b[2], b[3], b[4], b[5], b[6], b[7]);
105}
106
107static ssize_t ft_wwn_show(void *arg, char *buf)
108{
109 u64 *wwn = arg;
110 ssize_t len;
111
112 len = ft_format_wwn(buf, PAGE_SIZE - 2, *wwn);
113 buf[len++] = '\n';
114 return len;
115}
116
117static ssize_t ft_wwn_store(void *arg, const char *buf, size_t len)
118{
119 ssize_t ret;
120 u64 wwn;
121
122 ret = ft_parse_wwn(buf, &wwn, 0);
123 if (ret > 0)
124 *(u64 *)arg = wwn;
125 return ret;
126}
127
128
129
130
131
132static ssize_t ft_nacl_port_name_show(struct config_item *item, char *page)
133{
134 struct se_node_acl *se_nacl = acl_to_nacl(item);
135 struct ft_node_acl *acl = container_of(se_nacl,
136 struct ft_node_acl, se_node_acl);
137
138 return ft_wwn_show(&acl->node_auth.port_name, page);
139}
140
141static ssize_t ft_nacl_port_name_store(struct config_item *item,
142 const char *page, size_t count)
143{
144 struct se_node_acl *se_nacl = acl_to_nacl(item);
145 struct ft_node_acl *acl = container_of(se_nacl,
146 struct ft_node_acl, se_node_acl);
147
148 return ft_wwn_store(&acl->node_auth.port_name, page, count);
149}
150
151static ssize_t ft_nacl_node_name_show(struct config_item *item,
152 char *page)
153{
154 struct se_node_acl *se_nacl = acl_to_nacl(item);
155 struct ft_node_acl *acl = container_of(se_nacl,
156 struct ft_node_acl, se_node_acl);
157
158 return ft_wwn_show(&acl->node_auth.node_name, page);
159}
160
161static ssize_t ft_nacl_node_name_store(struct config_item *item,
162 const char *page, size_t count)
163{
164 struct se_node_acl *se_nacl = acl_to_nacl(item);
165 struct ft_node_acl *acl = container_of(se_nacl,
166 struct ft_node_acl, se_node_acl);
167
168 return ft_wwn_store(&acl->node_auth.node_name, page, count);
169}
170
171CONFIGFS_ATTR(ft_nacl_, node_name);
172CONFIGFS_ATTR(ft_nacl_, port_name);
173
174static ssize_t ft_nacl_tag_show(struct config_item *item,
175 char *page)
176{
177 return snprintf(page, PAGE_SIZE, "%s", acl_to_nacl(item)->acl_tag);
178}
179
180static ssize_t ft_nacl_tag_store(struct config_item *item,
181 const char *page, size_t count)
182{
183 struct se_node_acl *se_nacl = acl_to_nacl(item);
184 int ret;
185
186 ret = core_tpg_set_initiator_node_tag(se_nacl->se_tpg, se_nacl, page);
187
188 if (ret < 0)
189 return ret;
190 return count;
191}
192
193CONFIGFS_ATTR(ft_nacl_, tag);
194
195static struct configfs_attribute *ft_nacl_base_attrs[] = {
196 &ft_nacl_attr_port_name,
197 &ft_nacl_attr_node_name,
198 &ft_nacl_attr_tag,
199 NULL,
200};
201
202
203
204
205
206
207
208
209
210static int ft_init_nodeacl(struct se_node_acl *nacl, const char *name)
211{
212 struct ft_node_acl *acl =
213 container_of(nacl, struct ft_node_acl, se_node_acl);
214 u64 wwpn;
215
216 if (ft_parse_wwn(name, &wwpn, 1) < 0)
217 return -EINVAL;
218
219 acl->node_auth.port_name = wwpn;
220 return 0;
221}
222
223
224
225
226static struct se_portal_group *ft_add_tpg(
227 struct se_wwn *wwn,
228 struct config_group *group,
229 const char *name)
230{
231 struct ft_lport_wwn *ft_wwn;
232 struct ft_tpg *tpg;
233 struct workqueue_struct *wq;
234 unsigned long index;
235 int ret;
236
237 pr_debug("tcm_fc: add tpg %s\n", name);
238
239
240
241
242 if (strstr(name, "tpgt_") != name)
243 return NULL;
244
245 ret = kstrtoul(name + 5, 10, &index);
246 if (ret)
247 return NULL;
248 if (index > UINT_MAX)
249 return NULL;
250
251 if ((index != 1)) {
252 pr_err("Error, a single TPG=1 is used for HW port mappings\n");
253 return ERR_PTR(-ENOSYS);
254 }
255
256 ft_wwn = container_of(wwn, struct ft_lport_wwn, se_wwn);
257 tpg = kzalloc(sizeof(*tpg), GFP_KERNEL);
258 if (!tpg)
259 return NULL;
260 tpg->index = index;
261 tpg->lport_wwn = ft_wwn;
262 INIT_LIST_HEAD(&tpg->lun_list);
263
264 wq = alloc_workqueue("tcm_fc", 0, 1);
265 if (!wq) {
266 kfree(tpg);
267 return NULL;
268 }
269
270 ret = core_tpg_register(wwn, &tpg->se_tpg, SCSI_PROTOCOL_FCP);
271 if (ret < 0) {
272 destroy_workqueue(wq);
273 kfree(tpg);
274 return NULL;
275 }
276 tpg->workqueue = wq;
277
278 mutex_lock(&ft_lport_lock);
279 ft_wwn->tpg = tpg;
280 mutex_unlock(&ft_lport_lock);
281
282 return &tpg->se_tpg;
283}
284
285static void ft_del_tpg(struct se_portal_group *se_tpg)
286{
287 struct ft_tpg *tpg = container_of(se_tpg, struct ft_tpg, se_tpg);
288 struct ft_lport_wwn *ft_wwn = tpg->lport_wwn;
289
290 pr_debug("del tpg %s\n",
291 config_item_name(&tpg->se_tpg.tpg_group.cg_item));
292
293 destroy_workqueue(tpg->workqueue);
294
295
296 synchronize_rcu();
297
298 mutex_lock(&ft_lport_lock);
299 ft_wwn->tpg = NULL;
300 if (tpg->tport) {
301 tpg->tport->tpg = NULL;
302 tpg->tport = NULL;
303 }
304 mutex_unlock(&ft_lport_lock);
305
306 core_tpg_deregister(se_tpg);
307 kfree(tpg);
308}
309
310
311
312
313
314
315
316struct ft_tpg *ft_lport_find_tpg(struct fc_lport *lport)
317{
318 struct ft_lport_wwn *ft_wwn;
319
320 list_for_each_entry(ft_wwn, &ft_wwn_list, ft_wwn_node) {
321 if (ft_wwn->wwpn == lport->wwpn)
322 return ft_wwn->tpg;
323 }
324 return NULL;
325}
326
327
328
329
330
331
332
333
334
335static struct se_wwn *ft_add_wwn(
336 struct target_fabric_configfs *tf,
337 struct config_group *group,
338 const char *name)
339{
340 struct ft_lport_wwn *ft_wwn;
341 struct ft_lport_wwn *old_ft_wwn;
342 u64 wwpn;
343
344 pr_debug("add wwn %s\n", name);
345 if (ft_parse_wwn(name, &wwpn, 1) < 0)
346 return NULL;
347 ft_wwn = kzalloc(sizeof(*ft_wwn), GFP_KERNEL);
348 if (!ft_wwn)
349 return NULL;
350 ft_wwn->wwpn = wwpn;
351
352 mutex_lock(&ft_lport_lock);
353 list_for_each_entry(old_ft_wwn, &ft_wwn_list, ft_wwn_node) {
354 if (old_ft_wwn->wwpn == wwpn) {
355 mutex_unlock(&ft_lport_lock);
356 kfree(ft_wwn);
357 return NULL;
358 }
359 }
360 list_add_tail(&ft_wwn->ft_wwn_node, &ft_wwn_list);
361 ft_format_wwn(ft_wwn->name, sizeof(ft_wwn->name), wwpn);
362 mutex_unlock(&ft_lport_lock);
363
364 return &ft_wwn->se_wwn;
365}
366
367static void ft_del_wwn(struct se_wwn *wwn)
368{
369 struct ft_lport_wwn *ft_wwn = container_of(wwn,
370 struct ft_lport_wwn, se_wwn);
371
372 pr_debug("del wwn %s\n", ft_wwn->name);
373 mutex_lock(&ft_lport_lock);
374 list_del(&ft_wwn->ft_wwn_node);
375 mutex_unlock(&ft_lport_lock);
376
377 kfree(ft_wwn);
378}
379
380static ssize_t ft_wwn_version_show(struct config_item *item, char *page)
381{
382 return sprintf(page, "TCM FC " FT_VERSION " on %s/%s on "
383 ""UTS_RELEASE"\n", utsname()->sysname, utsname()->machine);
384}
385
386CONFIGFS_ATTR_RO(ft_wwn_, version);
387
388static struct configfs_attribute *ft_wwn_attrs[] = {
389 &ft_wwn_attr_version,
390 NULL,
391};
392
393static inline struct ft_tpg *ft_tpg(struct se_portal_group *se_tpg)
394{
395 return container_of(se_tpg, struct ft_tpg, se_tpg);
396}
397
398static char *ft_get_fabric_name(void)
399{
400 return "fc";
401}
402
403static char *ft_get_fabric_wwn(struct se_portal_group *se_tpg)
404{
405 return ft_tpg(se_tpg)->lport_wwn->name;
406}
407
408static u16 ft_get_tag(struct se_portal_group *se_tpg)
409{
410
411
412
413
414 return ft_tpg(se_tpg)->index;
415}
416
417static int ft_check_false(struct se_portal_group *se_tpg)
418{
419 return 0;
420}
421
422static void ft_set_default_node_attr(struct se_node_acl *se_nacl)
423{
424}
425
426static u32 ft_tpg_get_inst_index(struct se_portal_group *se_tpg)
427{
428 return ft_tpg(se_tpg)->index;
429}
430
431static const struct target_core_fabric_ops ft_fabric_ops = {
432 .module = THIS_MODULE,
433 .name = "fc",
434 .node_acl_size = sizeof(struct ft_node_acl),
435 .get_fabric_name = ft_get_fabric_name,
436 .tpg_get_wwn = ft_get_fabric_wwn,
437 .tpg_get_tag = ft_get_tag,
438 .tpg_check_demo_mode = ft_check_false,
439 .tpg_check_demo_mode_cache = ft_check_false,
440 .tpg_check_demo_mode_write_protect = ft_check_false,
441 .tpg_check_prod_mode_write_protect = ft_check_false,
442 .tpg_get_inst_index = ft_tpg_get_inst_index,
443 .check_stop_free = ft_check_stop_free,
444 .release_cmd = ft_release_cmd,
445 .close_session = ft_sess_close,
446 .sess_get_index = ft_sess_get_index,
447 .sess_get_initiator_sid = NULL,
448 .write_pending = ft_write_pending,
449 .write_pending_status = ft_write_pending_status,
450 .set_default_node_attributes = ft_set_default_node_attr,
451 .get_cmd_state = ft_get_cmd_state,
452 .queue_data_in = ft_queue_data_in,
453 .queue_status = ft_queue_status,
454 .queue_tm_rsp = ft_queue_tm_resp,
455 .aborted_task = ft_aborted_task,
456
457
458
459
460 .fabric_make_wwn = &ft_add_wwn,
461 .fabric_drop_wwn = &ft_del_wwn,
462 .fabric_make_tpg = &ft_add_tpg,
463 .fabric_drop_tpg = &ft_del_tpg,
464 .fabric_init_nodeacl = &ft_init_nodeacl,
465
466 .tfc_wwn_attrs = ft_wwn_attrs,
467 .tfc_tpg_nacl_base_attrs = ft_nacl_base_attrs,
468};
469
470static struct notifier_block ft_notifier = {
471 .notifier_call = ft_lport_notify
472};
473
474static int __init ft_init(void)
475{
476 int ret;
477
478 ret = target_register_template(&ft_fabric_ops);
479 if (ret)
480 goto out;
481
482 ret = fc_fc4_register_provider(FC_TYPE_FCP, &ft_prov);
483 if (ret)
484 goto out_unregister_template;
485
486 blocking_notifier_chain_register(&fc_lport_notifier_head, &ft_notifier);
487 fc_lport_iterate(ft_lport_add, NULL);
488 return 0;
489
490out_unregister_template:
491 target_unregister_template(&ft_fabric_ops);
492out:
493 return ret;
494}
495
496static void __exit ft_exit(void)
497{
498 blocking_notifier_chain_unregister(&fc_lport_notifier_head,
499 &ft_notifier);
500 fc_fc4_deregister_provider(FC_TYPE_FCP, &ft_prov);
501 fc_lport_iterate(ft_lport_del, NULL);
502 target_unregister_template(&ft_fabric_ops);
503 synchronize_rcu();
504}
505
506MODULE_DESCRIPTION("FC TCM fabric driver " FT_VERSION);
507MODULE_LICENSE("GPL");
508module_init(ft_init);
509module_exit(ft_exit);
510
