5c755fe142
Pull SCSI target updates from Nicholas Bellinger:
"It's been a busy development cycle for target-core in a number of
different areas.
The fabric API usage for se_node_acl allocation is now within
target-core code, dropping the external API callers for all fabric
drivers tree-wide.
There is a new conversion to RCU hlists for se_node_acl and
se_portal_group LUN mappings, that turns fast-past LUN lookup into a
completely lockless code-path. It also removes the original
hard-coded limitation of 256 LUNs per fabric endpoint.
The configfs attributes for backends can now be shared between core
and driver code, allowing existing drivers to use common code while
still allowing flexibility for new backend provided attributes.
The highlights include:
- Merge sbc_verify_dif_* into common code (sagi)
- Remove iscsi-target support for obsolete IFMarker/OFMarker
(Christophe Vu-Brugier)
- Add bidi support in target/user backend (ilias + vangelis + agover)
- Move se_node_acl allocation into target-core code (hch)
- Add crc_t10dif_update common helper (akinobu + mkp)
- Handle target-core odd SGL mapping for data transfer memory
(akinobu)
- Move transport ID handling into target-core (hch)
- Move task tag into struct se_cmd + support 64-bit tags (bart)
- Convert se_node_acl->device_list[] to RCU hlist (nab + hch +
paulmck)
- Convert se_portal_group->tpg_lun_list[] to RCU hlist (nab + hch +
paulmck)
- Simplify target backend driver registration (hch)
- Consolidate + simplify target backend attribute implementations
(hch + nab)
- Subsume se_port + t10_alua_tg_pt_gp_member into se_lun (hch)
- Drop lun_sep_lock for se_lun->lun_se_dev RCU usage (hch + nab)
- Drop unnecessary core_tpg_register TFO parameter (nab)
- Use 64-bit LUNs tree-wide (hannes)
- Drop left-over TARGET_MAX_LUNS_PER_TRANSPORT limit (hannes)"
* 'for-next' of git://git.kernel.org/pub/scm/linux/kernel/git/nab/target-pending: (76 commits)
target: Bump core version to v5.0
target: remove target_core_configfs.h
target: remove unused TARGET_CORE_CONFIG_ROOT define
target: consolidate version defines
target: implement WRITE_SAME with UNMAP bit using ->execute_unmap
target: simplify UNMAP handling
target: replace se_cmd->execute_rw with a protocol_data field
target/user: Fix inconsistent kmap_atomic/kunmap_atomic
target: Send UA when changing LUN inventory
target: Send UA upon LUN RESET tmr completion
target: Send UA on ALUA target port group change
target: Convert se_lun->lun_deve_lock to normal spinlock
target: use 'se_dev_entry' when allocating UAs
target: Remove 'ua_nacl' pointer from se_ua structure
target_core_alua: Correct UA handling when switching states
xen-scsiback: Fix compile warning for 64-bit LUN
target: Remove TARGET_MAX_LUNS_PER_TRANSPORT
target: use 64-bit LUNs
target: Drop duplicate + unused se_dev_check_wce
target: Drop unnecessary core_tpg_register TFO parameter
...
691 lines
24 KiB
Python
Executable file
691 lines
24 KiB
Python
Executable file
#!/usr/bin/python
|
|
# The TCM v4 multi-protocol fabric module generation script for drivers/target/$NEW_MOD
|
|
#
|
|
# Copyright (c) 2010 Rising Tide Systems
|
|
# Copyright (c) 2010 Linux-iSCSI.org
|
|
#
|
|
# Author: nab@kernel.org
|
|
#
|
|
import os, sys
|
|
import subprocess as sub
|
|
import string
|
|
import re
|
|
import optparse
|
|
|
|
tcm_dir = ""
|
|
|
|
fabric_ops = []
|
|
fabric_mod_dir = ""
|
|
fabric_mod_port = ""
|
|
fabric_mod_init_port = ""
|
|
|
|
def tcm_mod_err(msg):
|
|
print msg
|
|
sys.exit(1)
|
|
|
|
def tcm_mod_create_module_subdir(fabric_mod_dir_var):
|
|
|
|
if os.path.isdir(fabric_mod_dir_var) == True:
|
|
return 1
|
|
|
|
print "Creating fabric_mod_dir: " + fabric_mod_dir_var
|
|
ret = os.mkdir(fabric_mod_dir_var)
|
|
if ret:
|
|
tcm_mod_err("Unable to mkdir " + fabric_mod_dir_var)
|
|
|
|
return
|
|
|
|
def tcm_mod_build_FC_include(fabric_mod_dir_var, fabric_mod_name):
|
|
global fabric_mod_port
|
|
global fabric_mod_init_port
|
|
buf = ""
|
|
|
|
f = fabric_mod_dir_var + "/" + fabric_mod_name + "_base.h"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w');
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
buf = "#define " + fabric_mod_name.upper() + "_VERSION \"v0.1\"\n"
|
|
buf += "#define " + fabric_mod_name.upper() + "_NAMELEN 32\n"
|
|
buf += "\n"
|
|
buf += "struct " + fabric_mod_name + "_tpg {\n"
|
|
buf += " /* FC lport target portal group tag for TCM */\n"
|
|
buf += " u16 lport_tpgt;\n"
|
|
buf += " /* Pointer back to " + fabric_mod_name + "_lport */\n"
|
|
buf += " struct " + fabric_mod_name + "_lport *lport;\n"
|
|
buf += " /* Returned by " + fabric_mod_name + "_make_tpg() */\n"
|
|
buf += " struct se_portal_group se_tpg;\n"
|
|
buf += "};\n"
|
|
buf += "\n"
|
|
buf += "struct " + fabric_mod_name + "_lport {\n"
|
|
buf += " /* Binary World Wide unique Port Name for FC Target Lport */\n"
|
|
buf += " u64 lport_wwpn;\n"
|
|
buf += " /* ASCII formatted WWPN for FC Target Lport */\n"
|
|
buf += " char lport_name[" + fabric_mod_name.upper() + "_NAMELEN];\n"
|
|
buf += " /* Returned by " + fabric_mod_name + "_make_lport() */\n"
|
|
buf += " struct se_wwn lport_wwn;\n"
|
|
buf += "};\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
|
|
fabric_mod_port = "lport"
|
|
fabric_mod_init_port = "nport"
|
|
|
|
return
|
|
|
|
def tcm_mod_build_SAS_include(fabric_mod_dir_var, fabric_mod_name):
|
|
global fabric_mod_port
|
|
global fabric_mod_init_port
|
|
buf = ""
|
|
|
|
f = fabric_mod_dir_var + "/" + fabric_mod_name + "_base.h"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w');
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
buf = "#define " + fabric_mod_name.upper() + "_VERSION \"v0.1\"\n"
|
|
buf += "#define " + fabric_mod_name.upper() + "_NAMELEN 32\n"
|
|
buf += "\n"
|
|
buf += "struct " + fabric_mod_name + "_tpg {\n"
|
|
buf += " /* SAS port target portal group tag for TCM */\n"
|
|
buf += " u16 tport_tpgt;\n"
|
|
buf += " /* Pointer back to " + fabric_mod_name + "_tport */\n"
|
|
buf += " struct " + fabric_mod_name + "_tport *tport;\n"
|
|
buf += " /* Returned by " + fabric_mod_name + "_make_tpg() */\n"
|
|
buf += " struct se_portal_group se_tpg;\n"
|
|
buf += "};\n\n"
|
|
buf += "struct " + fabric_mod_name + "_tport {\n"
|
|
buf += " /* Binary World Wide unique Port Name for SAS Target port */\n"
|
|
buf += " u64 tport_wwpn;\n"
|
|
buf += " /* ASCII formatted WWPN for SAS Target port */\n"
|
|
buf += " char tport_name[" + fabric_mod_name.upper() + "_NAMELEN];\n"
|
|
buf += " /* Returned by " + fabric_mod_name + "_make_tport() */\n"
|
|
buf += " struct se_wwn tport_wwn;\n"
|
|
buf += "};\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
|
|
fabric_mod_port = "tport"
|
|
fabric_mod_init_port = "iport"
|
|
|
|
return
|
|
|
|
def tcm_mod_build_iSCSI_include(fabric_mod_dir_var, fabric_mod_name):
|
|
global fabric_mod_port
|
|
global fabric_mod_init_port
|
|
buf = ""
|
|
|
|
f = fabric_mod_dir_var + "/" + fabric_mod_name + "_base.h"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w');
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
buf = "#define " + fabric_mod_name.upper() + "_VERSION \"v0.1\"\n"
|
|
buf += "#define " + fabric_mod_name.upper() + "_NAMELEN 32\n"
|
|
buf += "\n"
|
|
buf += "struct " + fabric_mod_name + "_tpg {\n"
|
|
buf += " /* iSCSI target portal group tag for TCM */\n"
|
|
buf += " u16 tport_tpgt;\n"
|
|
buf += " /* Pointer back to " + fabric_mod_name + "_tport */\n"
|
|
buf += " struct " + fabric_mod_name + "_tport *tport;\n"
|
|
buf += " /* Returned by " + fabric_mod_name + "_make_tpg() */\n"
|
|
buf += " struct se_portal_group se_tpg;\n"
|
|
buf += "};\n\n"
|
|
buf += "struct " + fabric_mod_name + "_tport {\n"
|
|
buf += " /* ASCII formatted TargetName for IQN */\n"
|
|
buf += " char tport_name[" + fabric_mod_name.upper() + "_NAMELEN];\n"
|
|
buf += " /* Returned by " + fabric_mod_name + "_make_tport() */\n"
|
|
buf += " struct se_wwn tport_wwn;\n"
|
|
buf += "};\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
|
|
fabric_mod_port = "tport"
|
|
fabric_mod_init_port = "iport"
|
|
|
|
return
|
|
|
|
def tcm_mod_build_base_includes(proto_ident, fabric_mod_dir_val, fabric_mod_name):
|
|
|
|
if proto_ident == "FC":
|
|
tcm_mod_build_FC_include(fabric_mod_dir_val, fabric_mod_name)
|
|
elif proto_ident == "SAS":
|
|
tcm_mod_build_SAS_include(fabric_mod_dir_val, fabric_mod_name)
|
|
elif proto_ident == "iSCSI":
|
|
tcm_mod_build_iSCSI_include(fabric_mod_dir_val, fabric_mod_name)
|
|
else:
|
|
print "Unsupported proto_ident: " + proto_ident
|
|
sys.exit(1)
|
|
|
|
return
|
|
|
|
def tcm_mod_build_configfs(proto_ident, fabric_mod_dir_var, fabric_mod_name):
|
|
buf = ""
|
|
|
|
f = fabric_mod_dir_var + "/" + fabric_mod_name + "_configfs.c"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w');
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
buf = "#include <linux/module.h>\n"
|
|
buf += "#include <linux/moduleparam.h>\n"
|
|
buf += "#include <linux/version.h>\n"
|
|
buf += "#include <generated/utsrelease.h>\n"
|
|
buf += "#include <linux/utsname.h>\n"
|
|
buf += "#include <linux/init.h>\n"
|
|
buf += "#include <linux/slab.h>\n"
|
|
buf += "#include <linux/kthread.h>\n"
|
|
buf += "#include <linux/types.h>\n"
|
|
buf += "#include <linux/string.h>\n"
|
|
buf += "#include <linux/configfs.h>\n"
|
|
buf += "#include <linux/ctype.h>\n"
|
|
buf += "#include <asm/unaligned.h>\n\n"
|
|
buf += "#include <target/target_core_base.h>\n"
|
|
buf += "#include <target/target_core_fabric.h>\n"
|
|
buf += "#include <target/target_core_fabric_configfs.h>\n"
|
|
buf += "#include <target/configfs_macros.h>\n\n"
|
|
buf += "#include \"" + fabric_mod_name + "_base.h\"\n"
|
|
buf += "#include \"" + fabric_mod_name + "_fabric.h\"\n\n"
|
|
|
|
buf += "static const struct target_core_fabric_ops " + fabric_mod_name + "_ops;\n\n"
|
|
|
|
buf += "static struct se_portal_group *" + fabric_mod_name + "_make_tpg(\n"
|
|
buf += " struct se_wwn *wwn,\n"
|
|
buf += " struct config_group *group,\n"
|
|
buf += " const char *name)\n"
|
|
buf += "{\n"
|
|
buf += " struct " + fabric_mod_name + "_" + fabric_mod_port + "*" + fabric_mod_port + " = container_of(wwn,\n"
|
|
buf += " struct " + fabric_mod_name + "_" + fabric_mod_port + ", " + fabric_mod_port + "_wwn);\n\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg *tpg;\n"
|
|
buf += " unsigned long tpgt;\n"
|
|
buf += " int ret;\n\n"
|
|
buf += " if (strstr(name, \"tpgt_\") != name)\n"
|
|
buf += " return ERR_PTR(-EINVAL);\n"
|
|
buf += " if (kstrtoul(name + 5, 10, &tpgt) || tpgt > UINT_MAX)\n"
|
|
buf += " return ERR_PTR(-EINVAL);\n\n"
|
|
buf += " tpg = kzalloc(sizeof(struct " + fabric_mod_name + "_tpg), GFP_KERNEL);\n"
|
|
buf += " if (!tpg) {\n"
|
|
buf += " printk(KERN_ERR \"Unable to allocate struct " + fabric_mod_name + "_tpg\");\n"
|
|
buf += " return ERR_PTR(-ENOMEM);\n"
|
|
buf += " }\n"
|
|
buf += " tpg->" + fabric_mod_port + " = " + fabric_mod_port + ";\n"
|
|
buf += " tpg->" + fabric_mod_port + "_tpgt = tpgt;\n\n"
|
|
buf += " ret = core_tpg_register(&" + fabric_mod_name + "_ops, wwn,\n"
|
|
buf += " &tpg->se_tpg, SCSI_PROTOCOL_SAS);\n"
|
|
buf += " if (ret < 0) {\n"
|
|
buf += " kfree(tpg);\n"
|
|
buf += " return NULL;\n"
|
|
buf += " }\n"
|
|
buf += " return &tpg->se_tpg;\n"
|
|
buf += "}\n\n"
|
|
buf += "static void " + fabric_mod_name + "_drop_tpg(struct se_portal_group *se_tpg)\n"
|
|
buf += "{\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg *tpg = container_of(se_tpg,\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg, se_tpg);\n\n"
|
|
buf += " core_tpg_deregister(se_tpg);\n"
|
|
buf += " kfree(tpg);\n"
|
|
buf += "}\n\n"
|
|
|
|
buf += "static struct se_wwn *" + fabric_mod_name + "_make_" + fabric_mod_port + "(\n"
|
|
buf += " struct target_fabric_configfs *tf,\n"
|
|
buf += " struct config_group *group,\n"
|
|
buf += " const char *name)\n"
|
|
buf += "{\n"
|
|
buf += " struct " + fabric_mod_name + "_" + fabric_mod_port + " *" + fabric_mod_port + ";\n"
|
|
|
|
if proto_ident == "FC" or proto_ident == "SAS":
|
|
buf += " u64 wwpn = 0;\n\n"
|
|
|
|
buf += " /* if (" + fabric_mod_name + "_parse_wwn(name, &wwpn, 1) < 0)\n"
|
|
buf += " return ERR_PTR(-EINVAL); */\n\n"
|
|
buf += " " + fabric_mod_port + " = kzalloc(sizeof(struct " + fabric_mod_name + "_" + fabric_mod_port + "), GFP_KERNEL);\n"
|
|
buf += " if (!" + fabric_mod_port + ") {\n"
|
|
buf += " printk(KERN_ERR \"Unable to allocate struct " + fabric_mod_name + "_" + fabric_mod_port + "\");\n"
|
|
buf += " return ERR_PTR(-ENOMEM);\n"
|
|
buf += " }\n"
|
|
|
|
if proto_ident == "FC" or proto_ident == "SAS":
|
|
buf += " " + fabric_mod_port + "->" + fabric_mod_port + "_wwpn = wwpn;\n"
|
|
|
|
buf += " /* " + fabric_mod_name + "_format_wwn(&" + fabric_mod_port + "->" + fabric_mod_port + "_name[0], " + fabric_mod_name.upper() + "_NAMELEN, wwpn); */\n\n"
|
|
buf += " return &" + fabric_mod_port + "->" + fabric_mod_port + "_wwn;\n"
|
|
buf += "}\n\n"
|
|
buf += "static void " + fabric_mod_name + "_drop_" + fabric_mod_port + "(struct se_wwn *wwn)\n"
|
|
buf += "{\n"
|
|
buf += " struct " + fabric_mod_name + "_" + fabric_mod_port + " *" + fabric_mod_port + " = container_of(wwn,\n"
|
|
buf += " struct " + fabric_mod_name + "_" + fabric_mod_port + ", " + fabric_mod_port + "_wwn);\n"
|
|
buf += " kfree(" + fabric_mod_port + ");\n"
|
|
buf += "}\n\n"
|
|
buf += "static ssize_t " + fabric_mod_name + "_wwn_show_attr_version(\n"
|
|
buf += " struct target_fabric_configfs *tf,\n"
|
|
buf += " char *page)\n"
|
|
buf += "{\n"
|
|
buf += " return sprintf(page, \"" + fabric_mod_name.upper() + " fabric module %s on %s/%s\"\n"
|
|
buf += " \"on \"UTS_RELEASE\"\\n\", " + fabric_mod_name.upper() + "_VERSION, utsname()->sysname,\n"
|
|
buf += " utsname()->machine);\n"
|
|
buf += "}\n\n"
|
|
buf += "TF_WWN_ATTR_RO(" + fabric_mod_name + ", version);\n\n"
|
|
buf += "static struct configfs_attribute *" + fabric_mod_name + "_wwn_attrs[] = {\n"
|
|
buf += " &" + fabric_mod_name + "_wwn_version.attr,\n"
|
|
buf += " NULL,\n"
|
|
buf += "};\n\n"
|
|
|
|
buf += "static const struct target_core_fabric_ops " + fabric_mod_name + "_ops = {\n"
|
|
buf += " .module = THIS_MODULE,\n"
|
|
buf += " .name = " + fabric_mod_name + ",\n"
|
|
buf += " .get_fabric_name = " + fabric_mod_name + "_get_fabric_name,\n"
|
|
buf += " .tpg_get_wwn = " + fabric_mod_name + "_get_fabric_wwn,\n"
|
|
buf += " .tpg_get_tag = " + fabric_mod_name + "_get_tag,\n"
|
|
buf += " .tpg_check_demo_mode = " + fabric_mod_name + "_check_false,\n"
|
|
buf += " .tpg_check_demo_mode_cache = " + fabric_mod_name + "_check_true,\n"
|
|
buf += " .tpg_check_demo_mode_write_protect = " + fabric_mod_name + "_check_true,\n"
|
|
buf += " .tpg_check_prod_mode_write_protect = " + fabric_mod_name + "_check_false,\n"
|
|
buf += " .tpg_get_inst_index = " + fabric_mod_name + "_tpg_get_inst_index,\n"
|
|
buf += " .release_cmd = " + fabric_mod_name + "_release_cmd,\n"
|
|
buf += " .shutdown_session = " + fabric_mod_name + "_shutdown_session,\n"
|
|
buf += " .close_session = " + fabric_mod_name + "_close_session,\n"
|
|
buf += " .sess_get_index = " + fabric_mod_name + "_sess_get_index,\n"
|
|
buf += " .sess_get_initiator_sid = NULL,\n"
|
|
buf += " .write_pending = " + fabric_mod_name + "_write_pending,\n"
|
|
buf += " .write_pending_status = " + fabric_mod_name + "_write_pending_status,\n"
|
|
buf += " .set_default_node_attributes = " + fabric_mod_name + "_set_default_node_attrs,\n"
|
|
buf += " .get_cmd_state = " + fabric_mod_name + "_get_cmd_state,\n"
|
|
buf += " .queue_data_in = " + fabric_mod_name + "_queue_data_in,\n"
|
|
buf += " .queue_status = " + fabric_mod_name + "_queue_status,\n"
|
|
buf += " .queue_tm_rsp = " + fabric_mod_name + "_queue_tm_rsp,\n"
|
|
buf += " .aborted_task = " + fabric_mod_name + "_aborted_task,\n"
|
|
buf += " /*\n"
|
|
buf += " * Setup function pointers for generic logic in target_core_fabric_configfs.c\n"
|
|
buf += " */\n"
|
|
buf += " .fabric_make_wwn = " + fabric_mod_name + "_make_" + fabric_mod_port + ",\n"
|
|
buf += " .fabric_drop_wwn = " + fabric_mod_name + "_drop_" + fabric_mod_port + ",\n"
|
|
buf += " .fabric_make_tpg = " + fabric_mod_name + "_make_tpg,\n"
|
|
buf += " .fabric_drop_tpg = " + fabric_mod_name + "_drop_tpg,\n"
|
|
buf += "\n"
|
|
buf += " .tfc_wwn_attrs = " + fabric_mod_name + "_wwn_attrs;\n"
|
|
buf += "};\n\n"
|
|
|
|
buf += "static int __init " + fabric_mod_name + "_init(void)\n"
|
|
buf += "{\n"
|
|
buf += " return target_register_template(" + fabric_mod_name + "_ops);\n"
|
|
buf += "};\n\n"
|
|
|
|
buf += "static void __exit " + fabric_mod_name + "_exit(void)\n"
|
|
buf += "{\n"
|
|
buf += " target_unregister_template(" + fabric_mod_name + "_ops);\n"
|
|
buf += "};\n\n"
|
|
|
|
buf += "MODULE_DESCRIPTION(\"" + fabric_mod_name.upper() + " series fabric driver\");\n"
|
|
buf += "MODULE_LICENSE(\"GPL\");\n"
|
|
buf += "module_init(" + fabric_mod_name + "_init);\n"
|
|
buf += "module_exit(" + fabric_mod_name + "_exit);\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
|
|
return
|
|
|
|
def tcm_mod_scan_fabric_ops(tcm_dir):
|
|
|
|
fabric_ops_api = tcm_dir + "include/target/target_core_fabric.h"
|
|
|
|
print "Using tcm_mod_scan_fabric_ops: " + fabric_ops_api
|
|
process_fo = 0;
|
|
|
|
p = open(fabric_ops_api, 'r')
|
|
|
|
line = p.readline()
|
|
while line:
|
|
if process_fo == 0 and re.search('struct target_core_fabric_ops {', line):
|
|
line = p.readline()
|
|
continue
|
|
|
|
if process_fo == 0:
|
|
process_fo = 1;
|
|
line = p.readline()
|
|
# Search for function pointer
|
|
if not re.search('\(\*', line):
|
|
continue
|
|
|
|
fabric_ops.append(line.rstrip())
|
|
continue
|
|
|
|
line = p.readline()
|
|
# Search for function pointer
|
|
if not re.search('\(\*', line):
|
|
continue
|
|
|
|
fabric_ops.append(line.rstrip())
|
|
|
|
p.close()
|
|
return
|
|
|
|
def tcm_mod_dump_fabric_ops(proto_ident, fabric_mod_dir_var, fabric_mod_name):
|
|
buf = ""
|
|
bufi = ""
|
|
|
|
f = fabric_mod_dir_var + "/" + fabric_mod_name + "_fabric.c"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w')
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
fi = fabric_mod_dir_var + "/" + fabric_mod_name + "_fabric.h"
|
|
print "Writing file: " + fi
|
|
|
|
pi = open(fi, 'w')
|
|
if not pi:
|
|
tcm_mod_err("Unable to open file: " + fi)
|
|
|
|
buf = "#include <linux/slab.h>\n"
|
|
buf += "#include <linux/kthread.h>\n"
|
|
buf += "#include <linux/types.h>\n"
|
|
buf += "#include <linux/list.h>\n"
|
|
buf += "#include <linux/types.h>\n"
|
|
buf += "#include <linux/string.h>\n"
|
|
buf += "#include <linux/ctype.h>\n"
|
|
buf += "#include <asm/unaligned.h>\n"
|
|
buf += "#include <scsi/scsi_common.h>\n"
|
|
buf += "#include <scsi/scsi_proto.h>\n"
|
|
buf += "#include <target/target_core_base.h>\n"
|
|
buf += "#include <target/target_core_fabric.h>\n"
|
|
buf += "#include \"" + fabric_mod_name + "_base.h\"\n"
|
|
buf += "#include \"" + fabric_mod_name + "_fabric.h\"\n\n"
|
|
|
|
buf += "int " + fabric_mod_name + "_check_true(struct se_portal_group *se_tpg)\n"
|
|
buf += "{\n"
|
|
buf += " return 1;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_check_true(struct se_portal_group *);\n"
|
|
|
|
buf += "int " + fabric_mod_name + "_check_false(struct se_portal_group *se_tpg)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_check_false(struct se_portal_group *);\n"
|
|
|
|
total_fabric_ops = len(fabric_ops)
|
|
i = 0
|
|
|
|
while i < total_fabric_ops:
|
|
fo = fabric_ops[i]
|
|
i += 1
|
|
# print "fabric_ops: " + fo
|
|
|
|
if re.search('get_fabric_name', fo):
|
|
buf += "char *" + fabric_mod_name + "_get_fabric_name(void)\n"
|
|
buf += "{\n"
|
|
buf += " return \"" + fabric_mod_name + "\";\n"
|
|
buf += "}\n\n"
|
|
bufi += "char *" + fabric_mod_name + "_get_fabric_name(void);\n"
|
|
continue
|
|
|
|
if re.search('get_wwn', fo):
|
|
buf += "char *" + fabric_mod_name + "_get_fabric_wwn(struct se_portal_group *se_tpg)\n"
|
|
buf += "{\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg *tpg = container_of(se_tpg,\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg, se_tpg);\n"
|
|
buf += " struct " + fabric_mod_name + "_" + fabric_mod_port + " *" + fabric_mod_port + " = tpg->" + fabric_mod_port + ";\n\n"
|
|
buf += " return &" + fabric_mod_port + "->" + fabric_mod_port + "_name[0];\n"
|
|
buf += "}\n\n"
|
|
bufi += "char *" + fabric_mod_name + "_get_fabric_wwn(struct se_portal_group *);\n"
|
|
|
|
if re.search('get_tag', fo):
|
|
buf += "u16 " + fabric_mod_name + "_get_tag(struct se_portal_group *se_tpg)\n"
|
|
buf += "{\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg *tpg = container_of(se_tpg,\n"
|
|
buf += " struct " + fabric_mod_name + "_tpg, se_tpg);\n"
|
|
buf += " return tpg->" + fabric_mod_port + "_tpgt;\n"
|
|
buf += "}\n\n"
|
|
bufi += "u16 " + fabric_mod_name + "_get_tag(struct se_portal_group *);\n"
|
|
|
|
if re.search('tpg_get_inst_index\)\(', fo):
|
|
buf += "u32 " + fabric_mod_name + "_tpg_get_inst_index(struct se_portal_group *se_tpg)\n"
|
|
buf += "{\n"
|
|
buf += " return 1;\n"
|
|
buf += "}\n\n"
|
|
bufi += "u32 " + fabric_mod_name + "_tpg_get_inst_index(struct se_portal_group *);\n"
|
|
|
|
if re.search('\*release_cmd\)\(', fo):
|
|
buf += "void " + fabric_mod_name + "_release_cmd(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return;\n"
|
|
buf += "}\n\n"
|
|
bufi += "void " + fabric_mod_name + "_release_cmd(struct se_cmd *);\n"
|
|
|
|
if re.search('shutdown_session\)\(', fo):
|
|
buf += "int " + fabric_mod_name + "_shutdown_session(struct se_session *se_sess)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_shutdown_session(struct se_session *);\n"
|
|
|
|
if re.search('close_session\)\(', fo):
|
|
buf += "void " + fabric_mod_name + "_close_session(struct se_session *se_sess)\n"
|
|
buf += "{\n"
|
|
buf += " return;\n"
|
|
buf += "}\n\n"
|
|
bufi += "void " + fabric_mod_name + "_close_session(struct se_session *);\n"
|
|
|
|
if re.search('sess_get_index\)\(', fo):
|
|
buf += "u32 " + fabric_mod_name + "_sess_get_index(struct se_session *se_sess)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "u32 " + fabric_mod_name + "_sess_get_index(struct se_session *);\n"
|
|
|
|
if re.search('write_pending\)\(', fo):
|
|
buf += "int " + fabric_mod_name + "_write_pending(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_write_pending(struct se_cmd *);\n"
|
|
|
|
if re.search('write_pending_status\)\(', fo):
|
|
buf += "int " + fabric_mod_name + "_write_pending_status(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_write_pending_status(struct se_cmd *);\n"
|
|
|
|
if re.search('set_default_node_attributes\)\(', fo):
|
|
buf += "void " + fabric_mod_name + "_set_default_node_attrs(struct se_node_acl *nacl)\n"
|
|
buf += "{\n"
|
|
buf += " return;\n"
|
|
buf += "}\n\n"
|
|
bufi += "void " + fabric_mod_name + "_set_default_node_attrs(struct se_node_acl *);\n"
|
|
|
|
if re.search('get_cmd_state\)\(', fo):
|
|
buf += "int " + fabric_mod_name + "_get_cmd_state(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_get_cmd_state(struct se_cmd *);\n"
|
|
|
|
if re.search('queue_data_in\)\(', fo):
|
|
buf += "int " + fabric_mod_name + "_queue_data_in(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_queue_data_in(struct se_cmd *);\n"
|
|
|
|
if re.search('queue_status\)\(', fo):
|
|
buf += "int " + fabric_mod_name + "_queue_status(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return 0;\n"
|
|
buf += "}\n\n"
|
|
bufi += "int " + fabric_mod_name + "_queue_status(struct se_cmd *);\n"
|
|
|
|
if re.search('queue_tm_rsp\)\(', fo):
|
|
buf += "void " + fabric_mod_name + "_queue_tm_rsp(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return;\n"
|
|
buf += "}\n\n"
|
|
bufi += "void " + fabric_mod_name + "_queue_tm_rsp(struct se_cmd *);\n"
|
|
|
|
if re.search('aborted_task\)\(', fo):
|
|
buf += "void " + fabric_mod_name + "_aborted_task(struct se_cmd *se_cmd)\n"
|
|
buf += "{\n"
|
|
buf += " return;\n"
|
|
buf += "}\n\n"
|
|
bufi += "void " + fabric_mod_name + "_aborted_task(struct se_cmd *);\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
|
|
ret = pi.write(bufi)
|
|
if ret:
|
|
tcm_mod_err("Unable to write fi: " + fi)
|
|
|
|
pi.close()
|
|
return
|
|
|
|
def tcm_mod_build_kbuild(fabric_mod_dir_var, fabric_mod_name):
|
|
|
|
buf = ""
|
|
f = fabric_mod_dir_var + "/Makefile"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w')
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
buf += fabric_mod_name + "-objs := " + fabric_mod_name + "_fabric.o \\\n"
|
|
buf += " " + fabric_mod_name + "_configfs.o\n"
|
|
buf += "obj-$(CONFIG_" + fabric_mod_name.upper() + ") += " + fabric_mod_name + ".o\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
return
|
|
|
|
def tcm_mod_build_kconfig(fabric_mod_dir_var, fabric_mod_name):
|
|
|
|
buf = ""
|
|
f = fabric_mod_dir_var + "/Kconfig"
|
|
print "Writing file: " + f
|
|
|
|
p = open(f, 'w')
|
|
if not p:
|
|
tcm_mod_err("Unable to open file: " + f)
|
|
|
|
buf = "config " + fabric_mod_name.upper() + "\n"
|
|
buf += " tristate \"" + fabric_mod_name.upper() + " fabric module\"\n"
|
|
buf += " depends on TARGET_CORE && CONFIGFS_FS\n"
|
|
buf += " default n\n"
|
|
buf += " ---help---\n"
|
|
buf += " Say Y here to enable the " + fabric_mod_name.upper() + " fabric module\n"
|
|
|
|
ret = p.write(buf)
|
|
if ret:
|
|
tcm_mod_err("Unable to write f: " + f)
|
|
|
|
p.close()
|
|
return
|
|
|
|
def tcm_mod_add_kbuild(tcm_dir, fabric_mod_name):
|
|
buf = "obj-$(CONFIG_" + fabric_mod_name.upper() + ") += " + fabric_mod_name.lower() + "/\n"
|
|
kbuild = tcm_dir + "/drivers/target/Makefile"
|
|
|
|
f = open(kbuild, 'a')
|
|
f.write(buf)
|
|
f.close()
|
|
return
|
|
|
|
def tcm_mod_add_kconfig(tcm_dir, fabric_mod_name):
|
|
buf = "source \"drivers/target/" + fabric_mod_name.lower() + "/Kconfig\"\n"
|
|
kconfig = tcm_dir + "/drivers/target/Kconfig"
|
|
|
|
f = open(kconfig, 'a')
|
|
f.write(buf)
|
|
f.close()
|
|
return
|
|
|
|
def main(modname, proto_ident):
|
|
# proto_ident = "FC"
|
|
# proto_ident = "SAS"
|
|
# proto_ident = "iSCSI"
|
|
|
|
tcm_dir = os.getcwd();
|
|
tcm_dir += "/../../"
|
|
print "tcm_dir: " + tcm_dir
|
|
fabric_mod_name = modname
|
|
fabric_mod_dir = tcm_dir + "drivers/target/" + fabric_mod_name
|
|
print "Set fabric_mod_name: " + fabric_mod_name
|
|
print "Set fabric_mod_dir: " + fabric_mod_dir
|
|
print "Using proto_ident: " + proto_ident
|
|
|
|
if proto_ident != "FC" and proto_ident != "SAS" and proto_ident != "iSCSI":
|
|
print "Unsupported proto_ident: " + proto_ident
|
|
sys.exit(1)
|
|
|
|
ret = tcm_mod_create_module_subdir(fabric_mod_dir)
|
|
if ret:
|
|
print "tcm_mod_create_module_subdir() failed because module already exists!"
|
|
sys.exit(1)
|
|
|
|
tcm_mod_build_base_includes(proto_ident, fabric_mod_dir, fabric_mod_name)
|
|
tcm_mod_scan_fabric_ops(tcm_dir)
|
|
tcm_mod_dump_fabric_ops(proto_ident, fabric_mod_dir, fabric_mod_name)
|
|
tcm_mod_build_configfs(proto_ident, fabric_mod_dir, fabric_mod_name)
|
|
tcm_mod_build_kbuild(fabric_mod_dir, fabric_mod_name)
|
|
tcm_mod_build_kconfig(fabric_mod_dir, fabric_mod_name)
|
|
|
|
input = raw_input("Would you like to add " + fabric_mod_name + " to drivers/target/Makefile..? [yes,no]: ")
|
|
if input == "yes" or input == "y":
|
|
tcm_mod_add_kbuild(tcm_dir, fabric_mod_name)
|
|
|
|
input = raw_input("Would you like to add " + fabric_mod_name + " to drivers/target/Kconfig..? [yes,no]: ")
|
|
if input == "yes" or input == "y":
|
|
tcm_mod_add_kconfig(tcm_dir, fabric_mod_name)
|
|
|
|
return
|
|
|
|
parser = optparse.OptionParser()
|
|
parser.add_option('-m', '--modulename', help='Module name', dest='modname',
|
|
action='store', nargs=1, type='string')
|
|
parser.add_option('-p', '--protoident', help='Protocol Ident', dest='protoident',
|
|
action='store', nargs=1, type='string')
|
|
|
|
(opts, args) = parser.parse_args()
|
|
|
|
mandatories = ['modname', 'protoident']
|
|
for m in mandatories:
|
|
if not opts.__dict__[m]:
|
|
print "mandatory option is missing\n"
|
|
parser.print_help()
|
|
exit(-1)
|
|
|
|
if __name__ == "__main__":
|
|
|
|
main(str(opts.modname), opts.protoident)
|