提交 bc3bd3f4 编写于 作者: D David S. Miller

Merge branch 'enic-next'

Govindarajulu Varadarajan says:

====================
enic: Display classifier filters using ethtool

This series adds ethtool support to show classifier filters added by driver.

v2:
The patch 1/2 removes the $ifdef's around the filter structure. Making it
available always. So that .get_rxnfc() can be implimented without any #ifdefs
====================
Signed-off-by: NDavid S. Miller <davem@davemloft.net>
...@@ -99,7 +99,6 @@ struct enic_port_profile { ...@@ -99,7 +99,6 @@ struct enic_port_profile {
u8 mac_addr[ETH_ALEN]; u8 mac_addr[ETH_ALEN];
}; };
#ifdef CONFIG_RFS_ACCEL
/* enic_rfs_fltr_node - rfs filter node in hash table /* enic_rfs_fltr_node - rfs filter node in hash table
* @@keys: IPv4 5 tuple * @@keys: IPv4 5 tuple
* @flow_id: flow_id of clsf filter provided by kernel * @flow_id: flow_id of clsf filter provided by kernel
...@@ -135,8 +134,6 @@ struct enic_rfs_flw_tbl { ...@@ -135,8 +134,6 @@ struct enic_rfs_flw_tbl {
struct timer_list rfs_may_expire; struct timer_list rfs_may_expire;
}; };
#endif /* CONFIG_RFS_ACCEL */
/* Per-instance private data structure */ /* Per-instance private data structure */
struct enic { struct enic {
struct net_device *netdev; struct net_device *netdev;
...@@ -188,9 +185,7 @@ struct enic { ...@@ -188,9 +185,7 @@ struct enic {
/* completion queue cache line section */ /* completion queue cache line section */
____cacheline_aligned struct vnic_cq cq[ENIC_CQ_MAX]; ____cacheline_aligned struct vnic_cq cq[ENIC_CQ_MAX];
unsigned int cq_count; unsigned int cq_count;
#ifdef CONFIG_RFS_ACCEL
struct enic_rfs_flw_tbl rfs_h; struct enic_rfs_flw_tbl rfs_h;
#endif
}; };
static inline struct device *enic_get_dev(struct enic *enic) static inline struct device *enic_get_dev(struct enic *enic)
......
...@@ -65,37 +65,6 @@ int enic_delfltr(struct enic *enic, u16 filter_id) ...@@ -65,37 +65,6 @@ int enic_delfltr(struct enic *enic, u16 filter_id)
return ret; return ret;
} }
#ifdef CONFIG_RFS_ACCEL
void enic_flow_may_expire(unsigned long data)
{
struct enic *enic = (struct enic *)data;
bool res;
int j;
spin_lock(&enic->rfs_h.lock);
for (j = 0; j < ENIC_CLSF_EXPIRE_COUNT; j++) {
struct hlist_head *hhead;
struct hlist_node *tmp;
struct enic_rfs_fltr_node *n;
hhead = &enic->rfs_h.ht_head[enic->rfs_h.toclean++];
hlist_for_each_entry_safe(n, tmp, hhead, node) {
res = rps_may_expire_flow(enic->netdev, n->rq_id,
n->flow_id, n->fltr_id);
if (res) {
res = enic_delfltr(enic, n->fltr_id);
if (unlikely(res))
continue;
hlist_del(&n->node);
kfree(n);
enic->rfs_h.free++;
}
}
}
spin_unlock(&enic->rfs_h.lock);
mod_timer(&enic->rfs_h.rfs_may_expire, jiffies + HZ/4);
}
/* enic_rfs_flw_tbl_init - initialize enic->rfs_h members /* enic_rfs_flw_tbl_init - initialize enic->rfs_h members
* @enic: enic data * @enic: enic data
*/ */
...@@ -109,17 +78,14 @@ void enic_rfs_flw_tbl_init(struct enic *enic) ...@@ -109,17 +78,14 @@ void enic_rfs_flw_tbl_init(struct enic *enic)
enic->rfs_h.max = enic->config.num_arfs; enic->rfs_h.max = enic->config.num_arfs;
enic->rfs_h.free = enic->rfs_h.max; enic->rfs_h.free = enic->rfs_h.max;
enic->rfs_h.toclean = 0; enic->rfs_h.toclean = 0;
init_timer(&enic->rfs_h.rfs_may_expire); enic_rfs_timer_start(enic);
enic->rfs_h.rfs_may_expire.function = enic_flow_may_expire;
enic->rfs_h.rfs_may_expire.data = (unsigned long)enic;
mod_timer(&enic->rfs_h.rfs_may_expire, jiffies + HZ/4);
} }
void enic_rfs_flw_tbl_free(struct enic *enic) void enic_rfs_flw_tbl_free(struct enic *enic)
{ {
int i; int i;
del_timer_sync(&enic->rfs_h.rfs_may_expire); enic_rfs_timer_stop(enic);
spin_lock(&enic->rfs_h.lock); spin_lock(&enic->rfs_h.lock);
enic->rfs_h.free = 0; enic->rfs_h.free = 0;
for (i = 0; i < (1 << ENIC_RFS_FLW_BITSHIFT); i++) { for (i = 0; i < (1 << ENIC_RFS_FLW_BITSHIFT); i++) {
...@@ -137,6 +103,55 @@ void enic_rfs_flw_tbl_free(struct enic *enic) ...@@ -137,6 +103,55 @@ void enic_rfs_flw_tbl_free(struct enic *enic)
spin_unlock(&enic->rfs_h.lock); spin_unlock(&enic->rfs_h.lock);
} }
struct enic_rfs_fltr_node *htbl_fltr_search(struct enic *enic, u16 fltr_id)
{
int i;
for (i = 0; i < (1 << ENIC_RFS_FLW_BITSHIFT); i++) {
struct hlist_head *hhead;
struct hlist_node *tmp;
struct enic_rfs_fltr_node *n;
hhead = &enic->rfs_h.ht_head[i];
hlist_for_each_entry_safe(n, tmp, hhead, node)
if (n->fltr_id == fltr_id)
return n;
}
return NULL;
}
#ifdef CONFIG_RFS_ACCEL
void enic_flow_may_expire(unsigned long data)
{
struct enic *enic = (struct enic *)data;
bool res;
int j;
spin_lock(&enic->rfs_h.lock);
for (j = 0; j < ENIC_CLSF_EXPIRE_COUNT; j++) {
struct hlist_head *hhead;
struct hlist_node *tmp;
struct enic_rfs_fltr_node *n;
hhead = &enic->rfs_h.ht_head[enic->rfs_h.toclean++];
hlist_for_each_entry_safe(n, tmp, hhead, node) {
res = rps_may_expire_flow(enic->netdev, n->rq_id,
n->flow_id, n->fltr_id);
if (res) {
res = enic_delfltr(enic, n->fltr_id);
if (unlikely(res))
continue;
hlist_del(&n->node);
kfree(n);
enic->rfs_h.free++;
}
}
}
spin_unlock(&enic->rfs_h.lock);
mod_timer(&enic->rfs_h.rfs_may_expire, jiffies + HZ/4);
}
static struct enic_rfs_fltr_node *htbl_key_search(struct hlist_head *h, static struct enic_rfs_fltr_node *htbl_key_search(struct hlist_head *h,
struct flow_keys *k) struct flow_keys *k)
{ {
......
...@@ -8,15 +8,30 @@ ...@@ -8,15 +8,30 @@
int enic_addfltr_5t(struct enic *enic, struct flow_keys *keys, u16 rq); int enic_addfltr_5t(struct enic *enic, struct flow_keys *keys, u16 rq);
int enic_delfltr(struct enic *enic, u16 filter_id); int enic_delfltr(struct enic *enic, u16 filter_id);
#ifdef CONFIG_RFS_ACCEL
void enic_rfs_flw_tbl_init(struct enic *enic); void enic_rfs_flw_tbl_init(struct enic *enic);
void enic_rfs_flw_tbl_free(struct enic *enic); void enic_rfs_flw_tbl_free(struct enic *enic);
struct enic_rfs_fltr_node *htbl_fltr_search(struct enic *enic, u16 fltr_id);
#ifdef CONFIG_RFS_ACCEL
int enic_rx_flow_steer(struct net_device *dev, const struct sk_buff *skb, int enic_rx_flow_steer(struct net_device *dev, const struct sk_buff *skb,
u16 rxq_index, u32 flow_id); u16 rxq_index, u32 flow_id);
void enic_flow_may_expire(unsigned long data);
static inline void enic_rfs_timer_start(struct enic *enic)
{
init_timer(&enic->rfs_h.rfs_may_expire);
enic->rfs_h.rfs_may_expire.function = enic_flow_may_expire;
enic->rfs_h.rfs_may_expire.data = (unsigned long)enic;
mod_timer(&enic->rfs_h.rfs_may_expire, jiffies + HZ/4);
}
static inline void enic_rfs_timer_stop(struct enic *enic)
{
del_timer_sync(&enic->rfs_h.rfs_may_expire);
}
#else #else
static inline void enic_rfs_flw_tbl_init(struct enic *enic) {} static inline void enic_rfs_timer_start(struct enic *enic) {}
static inline void enic_rfs_flw_tbl_free(struct enic *enic) {} static inline void enic_rfs_timer_stop(struct enic *enic) {}
#endif /* CONFIG_RFS_ACCEL */ #endif /* CONFIG_RFS_ACCEL */
#endif /* _ENIC_CLSF_H_ */ #endif /* _ENIC_CLSF_H_ */
...@@ -22,6 +22,7 @@ ...@@ -22,6 +22,7 @@
#include "enic_res.h" #include "enic_res.h"
#include "enic.h" #include "enic.h"
#include "enic_dev.h" #include "enic_dev.h"
#include "enic_clsf.h"
struct enic_stat { struct enic_stat {
char name[ETH_GSTRING_LEN]; char name[ETH_GSTRING_LEN];
...@@ -282,6 +283,102 @@ static int enic_set_coalesce(struct net_device *netdev, ...@@ -282,6 +283,102 @@ static int enic_set_coalesce(struct net_device *netdev,
return 0; return 0;
} }
static int enic_grxclsrlall(struct enic *enic, struct ethtool_rxnfc *cmd,
u32 *rule_locs)
{
int j, ret = 0, cnt = 0;
cmd->data = enic->rfs_h.max - enic->rfs_h.free;
for (j = 0; j < (1 << ENIC_RFS_FLW_BITSHIFT); j++) {
struct hlist_head *hhead;
struct hlist_node *tmp;
struct enic_rfs_fltr_node *n;
hhead = &enic->rfs_h.ht_head[j];
hlist_for_each_entry_safe(n, tmp, hhead, node) {
if (cnt == cmd->rule_cnt)
return -EMSGSIZE;
rule_locs[cnt] = n->fltr_id;
cnt++;
}
}
cmd->rule_cnt = cnt;
return ret;
}
static int enic_grxclsrule(struct enic *enic, struct ethtool_rxnfc *cmd)
{
struct ethtool_rx_flow_spec *fsp =
(struct ethtool_rx_flow_spec *)&cmd->fs;
struct enic_rfs_fltr_node *n;
n = htbl_fltr_search(enic, (u16)fsp->location);
if (!n)
return -EINVAL;
switch (n->keys.ip_proto) {
case IPPROTO_TCP:
fsp->flow_type = TCP_V4_FLOW;
break;
case IPPROTO_UDP:
fsp->flow_type = UDP_V4_FLOW;
break;
default:
return -EINVAL;
break;
}
fsp->h_u.tcp_ip4_spec.ip4src = n->keys.src;
fsp->m_u.tcp_ip4_spec.ip4src = (__u32)~0;
fsp->h_u.tcp_ip4_spec.ip4dst = n->keys.dst;
fsp->m_u.tcp_ip4_spec.ip4dst = (__u32)~0;
fsp->h_u.tcp_ip4_spec.psrc = n->keys.port16[0];
fsp->m_u.tcp_ip4_spec.psrc = (__u16)~0;
fsp->h_u.tcp_ip4_spec.pdst = n->keys.port16[1];
fsp->m_u.tcp_ip4_spec.pdst = (__u16)~0;
fsp->ring_cookie = n->rq_id;
return 0;
}
static int enic_get_rxnfc(struct net_device *dev, struct ethtool_rxnfc *cmd,
u32 *rule_locs)
{
struct enic *enic = netdev_priv(dev);
int ret = 0;
switch (cmd->cmd) {
case ETHTOOL_GRXRINGS:
cmd->data = enic->rq_count;
break;
case ETHTOOL_GRXCLSRLCNT:
spin_lock_bh(&enic->rfs_h.lock);
cmd->rule_cnt = enic->rfs_h.max - enic->rfs_h.free;
cmd->data = enic->rfs_h.max;
spin_unlock_bh(&enic->rfs_h.lock);
break;
case ETHTOOL_GRXCLSRLALL:
spin_lock_bh(&enic->rfs_h.lock);
ret = enic_grxclsrlall(enic, cmd, rule_locs);
spin_unlock_bh(&enic->rfs_h.lock);
break;
case ETHTOOL_GRXCLSRULE:
spin_lock_bh(&enic->rfs_h.lock);
ret = enic_grxclsrule(enic, cmd);
spin_unlock_bh(&enic->rfs_h.lock);
break;
default:
ret = -EOPNOTSUPP;
break;
}
return ret;
}
static const struct ethtool_ops enic_ethtool_ops = { static const struct ethtool_ops enic_ethtool_ops = {
.get_settings = enic_get_settings, .get_settings = enic_get_settings,
.get_drvinfo = enic_get_drvinfo, .get_drvinfo = enic_get_drvinfo,
...@@ -293,6 +390,7 @@ static const struct ethtool_ops enic_ethtool_ops = { ...@@ -293,6 +390,7 @@ static const struct ethtool_ops enic_ethtool_ops = {
.get_ethtool_stats = enic_get_ethtool_stats, .get_ethtool_stats = enic_get_ethtool_stats,
.get_coalesce = enic_get_coalesce, .get_coalesce = enic_get_coalesce,
.set_coalesce = enic_set_coalesce, .set_coalesce = enic_set_coalesce,
.get_rxnfc = enic_get_rxnfc,
}; };
void enic_set_ethtool_ops(struct net_device *netdev) void enic_set_ethtool_ops(struct net_device *netdev)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册