Commit 55bd079a authored by David S. Miller's avatar David S. Miller

Merge branch 'smc-EDID-support'

Guvenc Gulce says:

====================
net/smc: add EID support

please apply the following patch series for smc to netdev's net-next
tree. The series introduce the so called Enterprise ID support for smc
protocol. Including the generic netlink based interface.
====================
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parents f787e3cf 3c572145
...@@ -38,6 +38,9 @@ enum { /* SMC PNET Table commands */ ...@@ -38,6 +38,9 @@ enum { /* SMC PNET Table commands */
#define SMC_GENL_FAMILY_VERSION 1 #define SMC_GENL_FAMILY_VERSION 1
#define SMC_PCI_ID_STR_LEN 16 /* Max length of pci id string */ #define SMC_PCI_ID_STR_LEN 16 /* Max length of pci id string */
#define SMC_MAX_HOSTNAME_LEN 32 /* Max length of the hostname */
#define SMC_MAX_UEID 4 /* Max number of user EIDs */
#define SMC_MAX_EID_LEN 32 /* Max length of an EID */
/* SMC_GENL_FAMILY commands */ /* SMC_GENL_FAMILY commands */
enum { enum {
...@@ -49,6 +52,13 @@ enum { ...@@ -49,6 +52,13 @@ enum {
SMC_NETLINK_GET_DEV_SMCR, SMC_NETLINK_GET_DEV_SMCR,
SMC_NETLINK_GET_STATS, SMC_NETLINK_GET_STATS,
SMC_NETLINK_GET_FBACK_STATS, SMC_NETLINK_GET_FBACK_STATS,
SMC_NETLINK_DUMP_UEID,
SMC_NETLINK_ADD_UEID,
SMC_NETLINK_REMOVE_UEID,
SMC_NETLINK_FLUSH_UEID,
SMC_NETLINK_DUMP_SEID,
SMC_NETLINK_ENABLE_SEID,
SMC_NETLINK_DISABLE_SEID,
}; };
/* SMC_GENL_FAMILY top level attributes */ /* SMC_GENL_FAMILY top level attributes */
...@@ -242,4 +252,21 @@ enum { ...@@ -242,4 +252,21 @@ enum {
__SMC_NLA_FBACK_STATS_MAX, __SMC_NLA_FBACK_STATS_MAX,
SMC_NLA_FBACK_STATS_MAX = __SMC_NLA_FBACK_STATS_MAX - 1 SMC_NLA_FBACK_STATS_MAX = __SMC_NLA_FBACK_STATS_MAX - 1
}; };
/* SMC_NETLINK_UEID attributes */
enum {
SMC_NLA_EID_TABLE_UNSPEC,
SMC_NLA_EID_TABLE_ENTRY, /* string */
__SMC_NLA_EID_TABLE_MAX,
SMC_NLA_EID_TABLE_MAX = __SMC_NLA_EID_TABLE_MAX - 1
};
/* SMC_NETLINK_SEID attributes */
enum {
SMC_NLA_SEID_UNSPEC,
SMC_NLA_SEID_ENTRY, /* string */
SMC_NLA_SEID_ENABLED, /* u8 */
__SMC_NLA_SEID_TABLE_MAX,
SMC_NLA_SEID_TABLE_MAX = __SMC_NLA_SEID_TABLE_MAX - 1
};
#endif /* _UAPI_LINUX_SMC_H */ #endif /* _UAPI_LINUX_SMC_H */
...@@ -829,7 +829,7 @@ static int smc_connect_rdma(struct smc_sock *smc, ...@@ -829,7 +829,7 @@ static int smc_connect_rdma(struct smc_sock *smc,
smc_rmb_sync_sg_for_device(&smc->conn); smc_rmb_sync_sg_for_device(&smc->conn);
reason_code = smc_clc_send_confirm(smc, ini->first_contact_local, reason_code = smc_clc_send_confirm(smc, ini->first_contact_local,
SMC_V1); SMC_V1, NULL);
if (reason_code) if (reason_code)
goto connect_abort; goto connect_abort;
...@@ -883,6 +883,7 @@ static int smc_connect_ism(struct smc_sock *smc, ...@@ -883,6 +883,7 @@ static int smc_connect_ism(struct smc_sock *smc,
struct smc_clc_msg_accept_confirm *aclc, struct smc_clc_msg_accept_confirm *aclc,
struct smc_init_info *ini) struct smc_init_info *ini)
{ {
u8 *eid = NULL;
int rc = 0; int rc = 0;
ini->is_smcd = true; ini->is_smcd = true;
...@@ -918,8 +919,15 @@ static int smc_connect_ism(struct smc_sock *smc, ...@@ -918,8 +919,15 @@ static int smc_connect_ism(struct smc_sock *smc,
smc_rx_init(smc); smc_rx_init(smc);
smc_tx_init(smc); smc_tx_init(smc);
if (aclc->hdr.version > SMC_V1) {
struct smc_clc_msg_accept_confirm_v2 *clc_v2 =
(struct smc_clc_msg_accept_confirm_v2 *)aclc;
eid = clc_v2->eid;
}
rc = smc_clc_send_confirm(smc, ini->first_contact_local, rc = smc_clc_send_confirm(smc, ini->first_contact_local,
aclc->hdr.version); aclc->hdr.version, eid);
if (rc) if (rc)
goto connect_abort; goto connect_abort;
mutex_unlock(&smc_server_lgr_pending); mutex_unlock(&smc_server_lgr_pending);
...@@ -1533,9 +1541,8 @@ static void smc_find_ism_v2_device_serv(struct smc_sock *new_smc, ...@@ -1533,9 +1541,8 @@ static void smc_find_ism_v2_device_serv(struct smc_sock *new_smc,
pclc_smcd = smc_get_clc_msg_smcd(pclc); pclc_smcd = smc_get_clc_msg_smcd(pclc);
smc_v2_ext = smc_get_clc_v2_ext(pclc); smc_v2_ext = smc_get_clc_v2_ext(pclc);
smcd_v2_ext = smc_get_clc_smcd_v2_ext(smc_v2_ext); smcd_v2_ext = smc_get_clc_smcd_v2_ext(smc_v2_ext);
if (!smcd_v2_ext || if (!smcd_v2_ext) {
!smc_v2_ext->hdr.flag.seid) { /* no system EID support for SMCD */ smc_find_ism_store_rc(SMC_CLC_DECL_NOV2DEXT, ini);
smc_find_ism_store_rc(SMC_CLC_DECL_NOSEID, ini);
goto not_found; goto not_found;
} }
...@@ -1555,13 +1562,13 @@ static void smc_find_ism_v2_device_serv(struct smc_sock *new_smc, ...@@ -1555,13 +1562,13 @@ static void smc_find_ism_v2_device_serv(struct smc_sock *new_smc,
} }
mutex_unlock(&smcd_dev_list.mutex); mutex_unlock(&smcd_dev_list.mutex);
if (ini->ism_dev[0]) { if (!ini->ism_dev[0])
smc_ism_get_system_eid(ini->ism_dev[0], &eid); goto not_found;
if (memcmp(eid, smcd_v2_ext->system_eid, SMC_MAX_EID_LEN))
goto not_found; smc_ism_get_system_eid(&eid);
} else { if (!smc_clc_match_eid(ini->negotiated_eid, smc_v2_ext,
smcd_v2_ext->system_eid, eid))
goto not_found; goto not_found;
}
/* separate - outside the smcd_dev_list.lock */ /* separate - outside the smcd_dev_list.lock */
smcd_version = ini->smcd_version; smcd_version = ini->smcd_version;
...@@ -1579,6 +1586,7 @@ static void smc_find_ism_v2_device_serv(struct smc_sock *new_smc, ...@@ -1579,6 +1586,7 @@ static void smc_find_ism_v2_device_serv(struct smc_sock *new_smc,
} }
/* no V2 ISM device could be initialized */ /* no V2 ISM device could be initialized */
ini->smcd_version = smcd_version; /* restore original value */ ini->smcd_version = smcd_version; /* restore original value */
ini->negotiated_eid[0] = 0;
not_found: not_found:
ini->smcd_version &= ~SMC_V2; ini->smcd_version &= ~SMC_V2;
...@@ -1788,7 +1796,8 @@ static void smc_listen_work(struct work_struct *work) ...@@ -1788,7 +1796,8 @@ static void smc_listen_work(struct work_struct *work)
/* send SMC Accept CLC message */ /* send SMC Accept CLC message */
rc = smc_clc_send_accept(new_smc, ini->first_contact_local, rc = smc_clc_send_accept(new_smc, ini->first_contact_local,
ini->smcd_version == SMC_V2 ? SMC_V2 : SMC_V1); ini->smcd_version == SMC_V2 ? SMC_V2 : SMC_V1,
ini->negotiated_eid);
if (rc) if (rc)
goto out_unlock; goto out_unlock;
...@@ -2662,6 +2671,7 @@ static void __exit smc_exit(void) ...@@ -2662,6 +2671,7 @@ static void __exit smc_exit(void)
proto_unregister(&smc_proto); proto_unregister(&smc_proto);
smc_pnet_exit(); smc_pnet_exit();
smc_nl_exit(); smc_nl_exit();
smc_clc_exit();
unregister_pernet_subsys(&smc_net_stat_ops); unregister_pernet_subsys(&smc_net_stat_ops);
unregister_pernet_subsys(&smc_net_ops); unregister_pernet_subsys(&smc_net_ops);
rcu_barrier(); rcu_barrier();
......
...@@ -29,9 +29,6 @@ ...@@ -29,9 +29,6 @@
* devices * devices
*/ */
#define SMC_MAX_HOSTNAME_LEN 32
#define SMC_MAX_EID_LEN 32
extern struct proto smc_proto; extern struct proto smc_proto;
extern struct proto smc_proto6; extern struct proto smc_proto6;
......
This diff is collapsed.
...@@ -14,8 +14,10 @@ ...@@ -14,8 +14,10 @@
#define _SMC_CLC_H #define _SMC_CLC_H
#include <rdma/ib_verbs.h> #include <rdma/ib_verbs.h>
#include <linux/smc.h>
#include "smc.h" #include "smc.h"
#include "smc_netlink.h"
#define SMC_CLC_PROPOSAL 0x01 #define SMC_CLC_PROPOSAL 0x01
#define SMC_CLC_ACCEPT 0x02 #define SMC_CLC_ACCEPT 0x02
...@@ -158,6 +160,7 @@ struct smc_clc_msg_proposal { /* clc proposal message sent by Linux */ ...@@ -158,6 +160,7 @@ struct smc_clc_msg_proposal { /* clc proposal message sent by Linux */
} __aligned(4); } __aligned(4);
#define SMC_CLC_MAX_V6_PREFIX 8 #define SMC_CLC_MAX_V6_PREFIX 8
#define SMC_CLC_MAX_UEID 8
struct smc_clc_msg_proposal_area { struct smc_clc_msg_proposal_area {
struct smc_clc_msg_proposal pclc_base; struct smc_clc_msg_proposal pclc_base;
...@@ -165,6 +168,7 @@ struct smc_clc_msg_proposal_area { ...@@ -165,6 +168,7 @@ struct smc_clc_msg_proposal_area {
struct smc_clc_msg_proposal_prefix pclc_prfx; struct smc_clc_msg_proposal_prefix pclc_prfx;
struct smc_clc_ipv6_prefix pclc_prfx_ipv6[SMC_CLC_MAX_V6_PREFIX]; struct smc_clc_ipv6_prefix pclc_prfx_ipv6[SMC_CLC_MAX_V6_PREFIX];
struct smc_clc_v2_extension pclc_v2_ext; struct smc_clc_v2_extension pclc_v2_ext;
u8 user_eids[SMC_CLC_MAX_UEID][SMC_MAX_EID_LEN];
struct smc_clc_smcd_v2_extension pclc_smcd_v2_ext; struct smc_clc_smcd_v2_extension pclc_smcd_v2_ext;
struct smc_clc_smcd_gid_chid pclc_gidchids[SMC_MAX_ISM_DEVS]; struct smc_clc_smcd_gid_chid pclc_gidchids[SMC_MAX_ISM_DEVS];
struct smc_clc_msg_trail pclc_trl; struct smc_clc_msg_trail pclc_trl;
...@@ -330,10 +334,21 @@ int smc_clc_wait_msg(struct smc_sock *smc, void *buf, int buflen, ...@@ -330,10 +334,21 @@ int smc_clc_wait_msg(struct smc_sock *smc, void *buf, int buflen,
int smc_clc_send_decline(struct smc_sock *smc, u32 peer_diag_info, u8 version); int smc_clc_send_decline(struct smc_sock *smc, u32 peer_diag_info, u8 version);
int smc_clc_send_proposal(struct smc_sock *smc, struct smc_init_info *ini); int smc_clc_send_proposal(struct smc_sock *smc, struct smc_init_info *ini);
int smc_clc_send_confirm(struct smc_sock *smc, bool clnt_first_contact, int smc_clc_send_confirm(struct smc_sock *smc, bool clnt_first_contact,
u8 version); u8 version, u8 *eid);
int smc_clc_send_accept(struct smc_sock *smc, bool srv_first_contact, int smc_clc_send_accept(struct smc_sock *smc, bool srv_first_contact,
u8 version); u8 version, u8 *negotiated_eid);
void smc_clc_init(void) __init; void smc_clc_init(void) __init;
void smc_clc_exit(void);
void smc_clc_get_hostname(u8 **host); void smc_clc_get_hostname(u8 **host);
bool smc_clc_match_eid(u8 *negotiated_eid,
struct smc_clc_v2_extension *smc_v2_ext,
u8 *peer_eid, u8 *local_eid);
int smc_nl_dump_ueid(struct sk_buff *skb, struct netlink_callback *cb);
int smc_nl_add_ueid(struct sk_buff *skb, struct genl_info *info);
int smc_nl_remove_ueid(struct sk_buff *skb, struct genl_info *info);
int smc_nl_flush_ueid(struct sk_buff *skb, struct genl_info *info);
int smc_nl_dump_seid(struct sk_buff *skb, struct netlink_callback *cb);
int smc_nl_enable_seid(struct sk_buff *skb, struct genl_info *info);
int smc_nl_disable_seid(struct sk_buff *skb, struct genl_info *info);
#endif #endif
...@@ -223,7 +223,6 @@ int smc_nl_get_sys_info(struct sk_buff *skb, struct netlink_callback *cb) ...@@ -223,7 +223,6 @@ int smc_nl_get_sys_info(struct sk_buff *skb, struct netlink_callback *cb)
struct smc_nl_dmp_ctx *cb_ctx = smc_nl_dmp_ctx(cb); struct smc_nl_dmp_ctx *cb_ctx = smc_nl_dmp_ctx(cb);
char hostname[SMC_MAX_HOSTNAME_LEN + 1]; char hostname[SMC_MAX_HOSTNAME_LEN + 1];
char smc_seid[SMC_MAX_EID_LEN + 1]; char smc_seid[SMC_MAX_EID_LEN + 1];
struct smcd_dev *smcd_dev;
struct nlattr *attrs; struct nlattr *attrs;
u8 *seid = NULL; u8 *seid = NULL;
u8 *host = NULL; u8 *host = NULL;
...@@ -252,13 +251,8 @@ int smc_nl_get_sys_info(struct sk_buff *skb, struct netlink_callback *cb) ...@@ -252,13 +251,8 @@ int smc_nl_get_sys_info(struct sk_buff *skb, struct netlink_callback *cb)
if (nla_put_string(skb, SMC_NLA_SYS_LOCAL_HOST, hostname)) if (nla_put_string(skb, SMC_NLA_SYS_LOCAL_HOST, hostname))
goto errattr; goto errattr;
} }
mutex_lock(&smcd_dev_list.mutex); if (smc_ism_is_v2_capable()) {
smcd_dev = list_first_entry_or_null(&smcd_dev_list.list, smc_ism_get_system_eid(&seid);
struct smcd_dev, list);
if (smcd_dev)
smc_ism_get_system_eid(smcd_dev, &seid);
mutex_unlock(&smcd_dev_list.mutex);
if (seid && smc_ism_is_v2_capable()) {
memcpy(smc_seid, seid, SMC_MAX_EID_LEN); memcpy(smc_seid, seid, SMC_MAX_EID_LEN);
smc_seid[SMC_MAX_EID_LEN] = 0; smc_seid[SMC_MAX_EID_LEN] = 0;
if (nla_put_string(skb, SMC_NLA_SYS_SEID, smc_seid)) if (nla_put_string(skb, SMC_NLA_SYS_SEID, smc_seid))
......
...@@ -310,6 +310,7 @@ struct smc_init_info { ...@@ -310,6 +310,7 @@ struct smc_init_info {
u8 first_contact_local; u8 first_contact_local;
unsigned short vlan_id; unsigned short vlan_id;
u32 rc; u32 rc;
u8 negotiated_eid[SMC_MAX_EID_LEN];
/* SMC-R */ /* SMC-R */
struct smc_clc_msg_local *ib_lcl; struct smc_clc_msg_local *ib_lcl;
struct smc_ib_device *ib_dev; struct smc_ib_device *ib_dev;
......
...@@ -23,6 +23,7 @@ struct smcd_dev_list smcd_dev_list = { ...@@ -23,6 +23,7 @@ struct smcd_dev_list smcd_dev_list = {
}; };
static bool smc_ism_v2_capable; static bool smc_ism_v2_capable;
static u8 smc_ism_v2_system_eid[SMC_MAX_EID_LEN];
/* Test if an ISM communication is possible - same CPC */ /* Test if an ISM communication is possible - same CPC */
int smc_ism_cantalk(u64 peer_gid, unsigned short vlan_id, struct smcd_dev *smcd) int smc_ism_cantalk(u64 peer_gid, unsigned short vlan_id, struct smcd_dev *smcd)
...@@ -42,9 +43,12 @@ int smc_ism_write(struct smcd_dev *smcd, const struct smc_ism_position *pos, ...@@ -42,9 +43,12 @@ int smc_ism_write(struct smcd_dev *smcd, const struct smc_ism_position *pos,
return rc < 0 ? rc : 0; return rc < 0 ? rc : 0;
} }
void smc_ism_get_system_eid(struct smcd_dev *smcd, u8 **eid) void smc_ism_get_system_eid(u8 **eid)
{ {
smcd->ops->get_system_eid(smcd, eid); if (!smc_ism_v2_capable)
*eid = NULL;
else
*eid = smc_ism_v2_system_eid;
} }
u16 smc_ism_get_chid(struct smcd_dev *smcd) u16 smc_ism_get_chid(struct smcd_dev *smcd)
...@@ -435,9 +439,12 @@ int smcd_register_dev(struct smcd_dev *smcd) ...@@ -435,9 +439,12 @@ int smcd_register_dev(struct smcd_dev *smcd)
if (list_empty(&smcd_dev_list.list)) { if (list_empty(&smcd_dev_list.list)) {
u8 *system_eid = NULL; u8 *system_eid = NULL;
smc_ism_get_system_eid(smcd, &system_eid); smcd->ops->get_system_eid(smcd, &system_eid);
if (system_eid[24] != '0' || system_eid[28] != '0') if (system_eid[24] != '0' || system_eid[28] != '0') {
smc_ism_v2_capable = true; smc_ism_v2_capable = true;
memcpy(smc_ism_v2_system_eid, system_eid,
SMC_MAX_EID_LEN);
}
} }
/* sort list: devices without pnetid before devices with pnetid */ /* sort list: devices without pnetid before devices with pnetid */
if (smcd->pnetid[0]) if (smcd->pnetid[0])
...@@ -533,4 +540,5 @@ EXPORT_SYMBOL_GPL(smcd_handle_irq); ...@@ -533,4 +540,5 @@ EXPORT_SYMBOL_GPL(smcd_handle_irq);
void __init smc_ism_init(void) void __init smc_ism_init(void)
{ {
smc_ism_v2_capable = false; smc_ism_v2_capable = false;
memset(smc_ism_v2_system_eid, 0, SMC_MAX_EID_LEN);
} }
...@@ -48,7 +48,7 @@ int smc_ism_unregister_dmb(struct smcd_dev *dev, struct smc_buf_desc *dmb_desc); ...@@ -48,7 +48,7 @@ int smc_ism_unregister_dmb(struct smcd_dev *dev, struct smc_buf_desc *dmb_desc);
int smc_ism_write(struct smcd_dev *dev, const struct smc_ism_position *pos, int smc_ism_write(struct smcd_dev *dev, const struct smc_ism_position *pos,
void *data, size_t len); void *data, size_t len);
int smc_ism_signal_shutdown(struct smc_link_group *lgr); int smc_ism_signal_shutdown(struct smc_link_group *lgr);
void smc_ism_get_system_eid(struct smcd_dev *dev, u8 **eid); void smc_ism_get_system_eid(u8 **eid);
u16 smc_ism_get_chid(struct smcd_dev *dev); u16 smc_ism_get_chid(struct smcd_dev *dev);
bool smc_ism_is_v2_capable(void); bool smc_ism_is_v2_capable(void);
void smc_ism_init(void); void smc_ism_init(void);
......
...@@ -19,11 +19,19 @@ ...@@ -19,11 +19,19 @@
#include "smc_core.h" #include "smc_core.h"
#include "smc_ism.h" #include "smc_ism.h"
#include "smc_ib.h" #include "smc_ib.h"
#include "smc_clc.h"
#include "smc_stats.h" #include "smc_stats.h"
#include "smc_netlink.h" #include "smc_netlink.h"
#define SMC_CMD_MAX_ATTR 1 const struct nla_policy
smc_gen_ueid_policy[SMC_NLA_EID_TABLE_MAX + 1] = {
[SMC_NLA_EID_TABLE_UNSPEC] = { .type = NLA_UNSPEC },
[SMC_NLA_EID_TABLE_ENTRY] = { .type = NLA_STRING,
.len = SMC_MAX_EID_LEN,
},
};
#define SMC_CMD_MAX_ATTR 1
/* SMC_GENL generic netlink operation definition */ /* SMC_GENL generic netlink operation definition */
static const struct genl_ops smc_gen_nl_ops[] = { static const struct genl_ops smc_gen_nl_ops[] = {
{ {
...@@ -66,6 +74,43 @@ static const struct genl_ops smc_gen_nl_ops[] = { ...@@ -66,6 +74,43 @@ static const struct genl_ops smc_gen_nl_ops[] = {
/* can be retrieved by unprivileged users */ /* can be retrieved by unprivileged users */
.dumpit = smc_nl_get_fback_stats, .dumpit = smc_nl_get_fback_stats,
}, },
{
.cmd = SMC_NETLINK_DUMP_UEID,
/* can be retrieved by unprivileged users */
.dumpit = smc_nl_dump_ueid,
},
{
.cmd = SMC_NETLINK_ADD_UEID,
.flags = GENL_ADMIN_PERM,
.doit = smc_nl_add_ueid,
.policy = smc_gen_ueid_policy,
},
{
.cmd = SMC_NETLINK_REMOVE_UEID,
.flags = GENL_ADMIN_PERM,
.doit = smc_nl_remove_ueid,
.policy = smc_gen_ueid_policy,
},
{
.cmd = SMC_NETLINK_FLUSH_UEID,
.flags = GENL_ADMIN_PERM,
.doit = smc_nl_flush_ueid,
},
{
.cmd = SMC_NETLINK_DUMP_SEID,
/* can be retrieved by unprivileged users */
.dumpit = smc_nl_dump_seid,
},
{
.cmd = SMC_NETLINK_ENABLE_SEID,
.flags = GENL_ADMIN_PERM,
.doit = smc_nl_enable_seid,
},
{
.cmd = SMC_NETLINK_DISABLE_SEID,
.flags = GENL_ADMIN_PERM,
.doit = smc_nl_disable_seid,
},
}; };
static const struct nla_policy smc_gen_nl_policy[2] = { static const struct nla_policy smc_gen_nl_policy[2] = {
......
...@@ -17,6 +17,8 @@ ...@@ -17,6 +17,8 @@
extern struct genl_family smc_gen_nl_family; extern struct genl_family smc_gen_nl_family;
extern const struct nla_policy smc_gen_ueid_policy[];
struct smc_nl_dmp_ctx { struct smc_nl_dmp_ctx {
int pos[3]; int pos[3];
}; };
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment