@@ -2144,6 +2144,7 @@ static int srpt_cm_req_recv(struct srpt_device *const sdev,
const char *src_addr)
{
struct srpt_port *sport = &sdev->port[port_num - 1];
+ struct t10_transport_id tpid;
struct srpt_nexus *nexus;
struct srp_login_rsp *rsp = NULL;
struct srp_login_rej *rej = NULL;
@@ -2314,13 +2315,17 @@ static int srpt_cm_req_recv(struct srpt_device *const sdev,
tag_num = ch->rq_size;
tag_size = 1; /* ib_srpt does not use se_sess->sess_cmd_map */
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = SCSI_PROTOCOL_SRP;
+ tpid.name = i_port_id + 2;
+
mutex_lock(&sport->port_guid_id.mutex);
list_for_each_entry(stpg, &sport->port_guid_id.tpg_list, entry) {
if (!IS_ERR_OR_NULL(ch->sess))
break;
ch->sess = target_setup_session(&stpg->tpg, tag_num,
tag_size, TARGET_PROT_NORMAL,
- ch->sess_name, ch, NULL);
+ &tpid, ch->sess_name, ch, NULL);
}
mutex_unlock(&sport->port_guid_id.mutex);
@@ -2329,14 +2334,14 @@ static int srpt_cm_req_recv(struct srpt_device *const sdev,
if (!IS_ERR_OR_NULL(ch->sess))
break;
ch->sess = target_setup_session(&stpg->tpg, tag_num,
- tag_size, TARGET_PROT_NORMAL, i_port_id,
- ch, NULL);
+ tag_size, TARGET_PROT_NORMAL, &tpid,
+ i_port_id, ch, NULL);
if (!IS_ERR_OR_NULL(ch->sess))
break;
/* Retry without leading "0x" */
ch->sess = target_setup_session(&stpg->tpg, tag_num,
tag_size, TARGET_PROT_NORMAL,
- i_port_id + 2, ch, NULL);
+ &tpid, i_port_id + 2, ch, NULL);
}
mutex_unlock(&sport->port_gid_id.mutex);
@@ -2208,6 +2208,7 @@ static int ibmvscsis_make_nexus(struct ibmvscsis_tport *tport)
{
char *name = tport->tport_name;
struct ibmvscsis_nexus *nexus;
+ struct t10_transport_id tpid;
struct scsi_info *vscsi = container_of(tport, struct scsi_info, tport);
int rc;
@@ -2222,9 +2223,13 @@ static int ibmvscsis_make_nexus(struct ibmvscsis_tport *tport)
return -ENOMEM;
}
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = SCSI_PROTOCOL_SRP;
+ tpid.name = name;
+
nexus->se_sess = target_setup_session(&tport->se_tpg, 0, 0,
- TARGET_PROT_NORMAL, name, nexus,
- NULL);
+ TARGET_PROT_NORMAL, &tpid, name,
+ nexus, NULL);
if (IS_ERR(nexus->se_sess)) {
rc = PTR_ERR(nexus->se_sess);
goto transport_init_fail;
@@ -1428,6 +1428,7 @@ static int tcm_qla2xxx_check_initiator_node_acl(
{
struct qla_hw_data *ha = vha->hw;
struct tcm_qla2xxx_lport *lport;
+ struct t10_transport_id tpid;
struct tcm_qla2xxx_tpg *tpg;
struct se_session *se_sess;
unsigned char port_name[36];
@@ -1454,13 +1455,18 @@ static int tcm_qla2xxx_check_initiator_node_acl(
*/
memset(&port_name, 0, 36);
snprintf(port_name, sizeof(port_name), "%8phC", fc_wwpn);
+
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = SCSI_PROTOCOL_FCP;
+ tpid.name = port_name;
+
/*
* Locate our struct se_node_acl either from an explict NodeACL created
* via ConfigFS, or via running in TPG demo mode.
*/
se_sess = target_setup_session(&tpg->se_tpg, num_tags,
sizeof(struct qla_tgt_cmd),
- TARGET_PROT_ALL, port_name,
+ TARGET_PROT_ALL, &tpid, port_name,
qlat_sess, tcm_qla2xxx_session_cb);
if (IS_ERR(se_sess))
return PTR_ERR(se_sess);
@@ -725,10 +725,11 @@ static int tcm_loop_alloc_sess_cb(struct se_portal_group *se_tpg,
static int tcm_loop_make_nexus(
struct tcm_loop_tpg *tl_tpg,
- const char *name)
+ char *name)
{
struct tcm_loop_hba *tl_hba = tl_tpg->tl_hba;
struct tcm_loop_nexus *tl_nexus;
+ struct t10_transport_id tpid;
int ret;
if (tl_tpg->tl_nexus) {
@@ -736,13 +737,28 @@ static int tcm_loop_make_nexus(
return -EEXIST;
}
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = tl_hba->tl_proto_id;
+
+ if (tpid.proto == SCSI_PROTOCOL_SAS) {
+ /* Drop naa. prefix */
+ tpid.name = name + 4;
+ } else {
+ /*
+ * For iSCSI we only support format=0, so we always only set
+ * the name
+ */
+ tpid.name = name;
+ }
+
tl_nexus = kzalloc(sizeof(*tl_nexus), GFP_KERNEL);
if (!tl_nexus)
return -ENOMEM;
tl_nexus->se_sess = target_setup_session(&tl_tpg->tl_se_tpg, 0, 0,
TARGET_PROT_DIN_PASS | TARGET_PROT_DOUT_PASS,
- name, tl_nexus, tcm_loop_alloc_sess_cb);
+ &tpid, name, tl_nexus,
+ tcm_loop_alloc_sess_cb);
if (IS_ERR(tl_nexus->se_sess)) {
ret = PTR_ERR(tl_nexus->se_sess);
kfree(tl_nexus);
@@ -181,6 +181,7 @@ static struct sbp_session *sbp_session_create(
struct sbp_tpg *tpg,
u64 guid)
{
+ struct t10_transport_id tpid;
struct sbp_session *sess;
int ret;
char guid_str[17];
@@ -196,10 +197,14 @@ static struct sbp_session *sbp_session_create(
INIT_DELAYED_WORK(&sess->maint_work, session_maintenance_work);
sess->guid = guid;
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = SCSI_PROTOCOL_SBP;
+ tpid.name = guid_str;
+
sess->se_sess = target_setup_session(&tpg->se_tpg, 128,
sizeof(struct sbp_target_request),
- TARGET_PROT_NORMAL, guid_str,
- sess, NULL);
+ TARGET_PROT_NORMAL, &tpid,
+ guid_str, sess, NULL);
if (IS_ERR(sess->se_sess)) {
pr_err("failed to init se_session\n");
ret = PTR_ERR(sess->se_sess);
@@ -421,3 +421,42 @@ const char *target_parse_pr_out_transport_id(struct se_portal_group *tpg,
*out_tid_len = 24;
return buf + offset;
}
+
+struct t10_transport_id *target_cp_transport_id(struct t10_transport_id *src)
+{
+ struct t10_transport_id *dst;
+
+ dst = kzalloc(sizeof(*dst), GFP_KERNEL);
+ if (!dst)
+ return NULL;
+ dst->proto = src->proto;
+
+ dst->name = kstrdup(src->name, GFP_KERNEL);
+ if (!dst->name)
+ goto free_tpid;
+
+ if (src->session_id) {
+ dst->session_id = kstrdup(src->session_id, GFP_KERNEL);
+ if (!dst->session_id)
+ goto free_name;
+ }
+
+ return dst;
+
+free_name:
+ kfree(dst->name);
+free_tpid:
+ kfree(dst);
+ return NULL;
+}
+EXPORT_SYMBOL(target_cp_transport_id);
+
+void target_free_transport_id(struct t10_transport_id *tpid)
+{
+ if (!tpid)
+ return;
+
+ kfree(tpid->name);
+ kfree(tpid->session_id);
+ kfree(tpid);
+}
@@ -104,6 +104,7 @@ int target_get_pr_transport_id(struct se_node_acl *nacl,
unsigned char *buf);
const char *target_parse_pr_out_transport_id(struct se_portal_group *tpg,
char *buf, u32 *out_tid_len, char **port_nexus_ptr);
+void target_free_transport_id(struct t10_transport_id *tpid);
/* target_core_hba.c */
struct se_hba *core_alloc_hba(const char *, u32, u32);
@@ -416,12 +416,13 @@ void transport_register_session(
struct se_session *
target_setup_session(struct se_portal_group *tpg,
unsigned int tag_num, unsigned int tag_size,
- enum target_prot_op prot_op,
+ enum target_prot_op prot_op, struct t10_transport_id *tpid,
const char *initiatorname, void *private,
int (*callback)(struct se_portal_group *,
struct se_session *, void *))
{
struct se_session *sess;
+ int rc;
/*
* If the fabric driver is using percpu-ida based pre allocation
@@ -435,26 +436,34 @@ struct se_session *
if (IS_ERR(sess))
return sess;
+ sess->tpid = target_cp_transport_id(tpid);
+ if (!sess->tpid) {
+ rc = -ENOMEM;
+ goto free_sess;
+ }
+
sess->se_node_acl = core_tpg_check_initiator_node_acl(tpg,
(unsigned char *)initiatorname);
if (!sess->se_node_acl) {
- transport_free_session(sess);
- return ERR_PTR(-EACCES);
+ rc = -EACCES;
+ goto free_sess;
}
/*
* Go ahead and perform any remaining fabric setup that is
* required before transport_register_session().
*/
if (callback != NULL) {
- int rc = callback(tpg, sess, private);
- if (rc) {
- transport_free_session(sess);
- return ERR_PTR(rc);
- }
+ rc = callback(tpg, sess, private);
+ if (rc)
+ goto free_sess;
}
transport_register_session(tpg, sess->se_node_acl, sess, private);
return sess;
+
+free_sess:
+ transport_free_session(sess);
+ return ERR_PTR(rc);
}
EXPORT_SYMBOL(target_setup_session);
@@ -579,6 +588,7 @@ void transport_free_session(struct se_session *se_sess)
sbitmap_queue_free(&se_sess->sess_tag_pool);
kvfree(se_sess->sess_cmd_map);
}
+ target_free_transport_id(se_sess->tpid);
percpu_ref_exit(&se_sess->cmd_count);
kmem_cache_free(se_sess_cache, se_sess);
}
@@ -208,6 +208,7 @@ static struct ft_sess *ft_sess_create(struct ft_tport *tport, u32 port_id,
struct fc_rport_priv *rdata)
{
struct se_portal_group *se_tpg = &tport->tpg->se_tpg;
+ struct t10_transport_id tpid;
struct ft_sess *sess;
struct hlist_head *head;
unsigned char initiatorname[TRANSPORT_IQN_LEN];
@@ -227,10 +228,15 @@ static struct ft_sess *ft_sess_create(struct ft_tport *tport, u32 port_id,
sess->tport = tport;
sess->port_id = port_id;
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = SCSI_PROTOCOL_FCP;
+ tpid.name = &initiatorname[0];
+
sess->se_sess = target_setup_session(se_tpg, TCM_FC_DEFAULT_TAGS,
sizeof(struct ft_cmd),
- TARGET_PROT_NORMAL, &initiatorname[0],
- sess, ft_sess_alloc_cb);
+ TARGET_PROT_NORMAL, &tpid,
+ &initiatorname[0], sess,
+ ft_sess_alloc_cb);
if (IS_ERR(sess->se_sess)) {
int rc = PTR_ERR(sess->se_sess);
kfree(sess);
@@ -1564,6 +1564,7 @@ static int usbg_alloc_sess_cb(struct se_portal_group *se_tpg,
static int tcm_usbg_make_nexus(struct usbg_tpg *tpg, char *name)
{
struct tcm_usbg_nexus *tv_nexus;
+ struct t10_transport_id tpid;
int ret = 0;
mutex_lock(&tpg->tpg_mutex);
@@ -1579,11 +1580,16 @@ static int tcm_usbg_make_nexus(struct usbg_tpg *tpg, char *name)
goto out_unlock;
}
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = tpg->se_tpg.proto_id;
+ tpid.name = name;
+
tv_nexus->tvn_se_sess = target_setup_session(&tpg->se_tpg,
USB_G_DEFAULT_SESSION_TAGS,
sizeof(struct usbg_cmd),
- TARGET_PROT_NORMAL, name,
- tv_nexus, usbg_alloc_sess_cb);
+ TARGET_PROT_NORMAL, &tpid,
+ name, tv_nexus,
+ usbg_alloc_sess_cb);
if (IS_ERR(tv_nexus->tvn_se_sess)) {
#define MAKE_NEXUS_MSG "core_tpg_check_initiator_node_acl() failed for %s\n"
pr_debug(MAKE_NEXUS_MSG, name);
@@ -1937,10 +1937,10 @@ static int vhost_scsi_nexus_cb(struct se_portal_group *se_tpg,
return -ENOMEM;
}
-static int vhost_scsi_make_nexus(struct vhost_scsi_tpg *tpg,
- const char *name)
+static int vhost_scsi_make_nexus(struct vhost_scsi_tpg *tpg, char *name)
{
struct vhost_scsi_nexus *tv_nexus;
+ struct t10_transport_id tpid;
mutex_lock(&tpg->tv_tpg_mutex);
if (tpg->tpg_nexus) {
@@ -1949,6 +1949,20 @@ static int vhost_scsi_make_nexus(struct vhost_scsi_tpg *tpg,
return -EEXIST;
}
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = tpg->se_tpg.proto_id;
+
+ if (tpid.proto == SCSI_PROTOCOL_SAS) {
+ /* Drop naa. prefix */
+ tpid.name = name + 4;
+ } else {
+ /*
+ * For iSCSI we only support format=0, so we always only set
+ * the name
+ */
+ tpid.name = name;
+ }
+
tv_nexus = kzalloc(sizeof(*tv_nexus), GFP_KERNEL);
if (!tv_nexus) {
mutex_unlock(&tpg->tv_tpg_mutex);
@@ -1964,7 +1978,7 @@ static int vhost_scsi_make_nexus(struct vhost_scsi_tpg *tpg,
VHOST_SCSI_DEFAULT_TAGS,
sizeof(struct vhost_scsi_cmd),
TARGET_PROT_DIN_PASS | TARGET_PROT_DOUT_PASS,
- (unsigned char *)name, tv_nexus,
+ &tpid, (unsigned char *)name, tv_nexus,
vhost_scsi_nexus_cb);
if (IS_ERR(tv_nexus->tvn_se_sess)) {
mutex_unlock(&tpg->tv_tpg_mutex);
@@ -1507,10 +1507,10 @@ static int scsiback_alloc_sess_cb(struct se_portal_group *se_tpg,
return 0;
}
-static int scsiback_make_nexus(struct scsiback_tpg *tpg,
- const char *name)
+static int scsiback_make_nexus(struct scsiback_tpg *tpg, char *name)
{
struct scsiback_nexus *tv_nexus;
+ struct t10_transport_id tpid;
int ret = 0;
mutex_lock(&tpg->tv_tpg_mutex);
@@ -1520,6 +1520,20 @@ static int scsiback_make_nexus(struct scsiback_tpg *tpg,
goto out_unlock;
}
+ memset(&tpid, 0, sizeof(tpid));
+ tpid.proto = tpg->se_tpg.proto_id;
+
+ if (tpid.proto == SCSI_PROTOCOL_SAS) {
+ /* Drop naa. prefix */
+ tpid.name = name + 4;
+ } else {
+ /*
+ * For iSCSI we only support format=0, so we always only set
+ * the name
+ */
+ tpid.name = name;
+ }
+
tv_nexus = kzalloc(sizeof(struct scsiback_nexus), GFP_KERNEL);
if (!tv_nexus) {
ret = -ENOMEM;
@@ -1529,8 +1543,9 @@ static int scsiback_make_nexus(struct scsiback_tpg *tpg,
tv_nexus->tvn_se_sess = target_setup_session(&tpg->se_tpg,
VSCSI_DEFAULT_SESSION_TAGS,
sizeof(struct vscsibk_pend),
- TARGET_PROT_NORMAL, name,
- tv_nexus, scsiback_alloc_sess_cb);
+ TARGET_PROT_NORMAL, &tpid,
+ name, tv_nexus,
+ scsiback_alloc_sess_cb);
if (IS_ERR(tv_nexus->tvn_se_sess)) {
kfree(tv_nexus);
ret = -ENOMEM;
@@ -333,6 +333,17 @@ struct t10_wwn {
struct list_head t10_vpd_list;
};
+struct t10_transport_id {
+ /* The format=0 transport specific port id/name value. */
+ char *name;
+ /*
+ * If proto is iSCSI and it's using format=1, then this is set to the
+ * initiator session id string defined in spc4r37 table 508.
+ */
+ char *session_id;
+ u8 proto;
+};
+
struct t10_pr_registration {
/* Used for fabrics that contain WWN+ISID */
#define PR_REG_ISID_LEN 16
@@ -605,6 +616,7 @@ static inline struct se_node_acl *fabric_stat_to_nacl(struct config_item *item)
struct se_session {
unsigned sess_tearing_down:1;
u64 sess_bin_isid;
+ struct t10_transport_id *tpid;
enum target_prot_op sup_prot_ops;
enum target_prot_type sess_prot_type;
struct se_node_acl *se_node_acl;
@@ -125,9 +125,10 @@ struct target_core_fabric_ops {
int target_depend_item(struct config_item *item);
void target_undepend_item(struct config_item *item);
+struct t10_transport_id *target_cp_transport_id(struct t10_transport_id *);
struct se_session *target_setup_session(struct se_portal_group *,
unsigned int, unsigned int, enum target_prot_op prot_op,
- const char *, void *,
+ struct t10_transport_id *, const char *, void *,
int (*callback)(struct se_portal_group *,
struct se_session *, void *));
void target_remove_session(struct se_session *);
The PGR code assumes the ACL name is going to be based on the SPC4 transportID type of values. The problem is that for iSCSI we have an extra session id as part of the SCSI port id and some fabric modules support or would like to support non transportID values for the ACL name. For example, iSCSI and SRP would like to use the source address for the ACL name, but that is not a valud transportID value that you can get in a PGR request. This patch adds a new transport_id struct which maps to the SPC transportID. In the future will be used for PGR commands instead of the ACL name. In this patchset, it is used to export the initiator info in the session's sysfs dir, so tools can disply the info and daemons that execute commands like PGRs in userspace can build a session id to I_T nexus mapping. Signed-off-by: Mike Christie <mchristi@redhat.com> --- V3: - drop format drivers/infiniband/ulp/srpt/ib_srpt.c | 13 +++++++---- drivers/scsi/ibmvscsi_tgt/ibmvscsi_tgt.c | 9 ++++++-- drivers/scsi/qla2xxx/tcm_qla2xxx.c | 8 ++++++- drivers/target/loopback/tcm_loop.c | 20 ++++++++++++++-- drivers/target/sbp/sbp_target.c | 9 ++++++-- drivers/target/target_core_fabric_lib.c | 39 ++++++++++++++++++++++++++++++++ drivers/target/target_core_internal.h | 1 + drivers/target/target_core_transport.c | 26 ++++++++++++++------- drivers/target/tcm_fc/tfc_sess.c | 10 ++++++-- drivers/usb/gadget/function/f_tcm.c | 10 ++++++-- drivers/vhost/scsi.c | 20 +++++++++++++--- drivers/xen/xen-scsiback.c | 23 +++++++++++++++---- include/target/target_core_base.h | 12 ++++++++++ include/target/target_core_fabric.h | 3 ++- 14 files changed, 172 insertions(+), 31 deletions(-)