mirror of
https://github.com/AuxXxilium/linux_dsm_epyc7002.git
synced 2024-11-30 02:06:49 +07:00
ipvs: Pass ipvs not net to ip_vs_proto_data_get
Signed-off-by: "Eric W. Biederman" <ebiederm@xmission.com> Acked-by: Julian Anastasov <ja@ssi.bg> Signed-off-by: Simon Horman <horms@verge.net.au>
This commit is contained in:
parent
a47b430080
commit
18d6ade63c
@ -541,7 +541,7 @@ struct ip_vs_proto_data {
|
||||
};
|
||||
|
||||
struct ip_vs_protocol *ip_vs_proto_get(unsigned short proto);
|
||||
struct ip_vs_proto_data *ip_vs_proto_data_get(struct net *net,
|
||||
struct ip_vs_proto_data *ip_vs_proto_data_get(struct netns_ipvs *ipvs,
|
||||
unsigned short proto);
|
||||
|
||||
struct ip_vs_conn_param {
|
||||
|
@ -668,7 +668,7 @@ void ip_vs_try_bind_dest(struct ip_vs_conn *cp)
|
||||
#endif
|
||||
ip_vs_bind_xmit(cp);
|
||||
|
||||
pd = ip_vs_proto_data_get(cp->ipvs->net, cp->protocol);
|
||||
pd = ip_vs_proto_data_get(cp->ipvs, cp->protocol);
|
||||
if (pd && atomic_read(&pd->appcnt))
|
||||
ip_vs_bind_app(cp, pd->pp);
|
||||
}
|
||||
@ -876,7 +876,7 @@ ip_vs_conn_new(const struct ip_vs_conn_param *p, int dest_af,
|
||||
{
|
||||
struct ip_vs_conn *cp;
|
||||
struct netns_ipvs *ipvs = p->ipvs;
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(p->ipvs->net,
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(p->ipvs,
|
||||
p->protocol);
|
||||
|
||||
cp = kmem_cache_alloc(ip_vs_conn_cachep, GFP_ATOMIC);
|
||||
|
@ -1237,7 +1237,7 @@ ip_vs_out(unsigned int hooknum, struct sk_buff *skb, int af)
|
||||
return verdict;
|
||||
}
|
||||
|
||||
pd = ip_vs_proto_data_get(net, iph.protocol);
|
||||
pd = ip_vs_proto_data_get(ipvs, iph.protocol);
|
||||
if (unlikely(!pd))
|
||||
return NF_ACCEPT;
|
||||
pp = pd->pp;
|
||||
@ -1470,7 +1470,7 @@ ip_vs_in_icmp(struct sk_buff *skb, int *related, unsigned int hooknum)
|
||||
ipip = true;
|
||||
}
|
||||
|
||||
pd = ip_vs_proto_data_get(net, cih->protocol);
|
||||
pd = ip_vs_proto_data_get(ipvs, cih->protocol);
|
||||
if (!pd)
|
||||
return NF_ACCEPT;
|
||||
pp = pd->pp;
|
||||
@ -1633,7 +1633,7 @@ static int ip_vs_in_icmp_v6(struct sk_buff *skb, int *related,
|
||||
|
||||
net = skb_net(skb);
|
||||
ipvs = net_ipvs(net);
|
||||
pd = ip_vs_proto_data_get(net, ciph.protocol);
|
||||
pd = ip_vs_proto_data_get(ipvs, ciph.protocol);
|
||||
if (!pd)
|
||||
return NF_ACCEPT;
|
||||
pp = pd->pp;
|
||||
@ -1765,7 +1765,7 @@ ip_vs_in(unsigned int hooknum, struct sk_buff *skb, int af)
|
||||
}
|
||||
|
||||
/* Protocol supported? */
|
||||
pd = ip_vs_proto_data_get(net, iph.protocol);
|
||||
pd = ip_vs_proto_data_get(ipvs, iph.protocol);
|
||||
if (unlikely(!pd)) {
|
||||
/* The only way we'll see this packet again is if it's
|
||||
* encapsulated, so mark it with ipvs_property=1 so we
|
||||
|
@ -2205,6 +2205,7 @@ static const struct file_operations ip_vs_stats_percpu_fops = {
|
||||
static int ip_vs_set_timeout(struct net *net, struct ip_vs_timeout_user *u)
|
||||
{
|
||||
#if defined(CONFIG_IP_VS_PROTO_TCP) || defined(CONFIG_IP_VS_PROTO_UDP)
|
||||
struct netns_ipvs *ipvs = net_ipvs(net);
|
||||
struct ip_vs_proto_data *pd;
|
||||
#endif
|
||||
|
||||
@ -2215,13 +2216,13 @@ static int ip_vs_set_timeout(struct net *net, struct ip_vs_timeout_user *u)
|
||||
|
||||
#ifdef CONFIG_IP_VS_PROTO_TCP
|
||||
if (u->tcp_timeout) {
|
||||
pd = ip_vs_proto_data_get(net, IPPROTO_TCP);
|
||||
pd = ip_vs_proto_data_get(ipvs, IPPROTO_TCP);
|
||||
pd->timeout_table[IP_VS_TCP_S_ESTABLISHED]
|
||||
= u->tcp_timeout * HZ;
|
||||
}
|
||||
|
||||
if (u->tcp_fin_timeout) {
|
||||
pd = ip_vs_proto_data_get(net, IPPROTO_TCP);
|
||||
pd = ip_vs_proto_data_get(ipvs, IPPROTO_TCP);
|
||||
pd->timeout_table[IP_VS_TCP_S_FIN_WAIT]
|
||||
= u->tcp_fin_timeout * HZ;
|
||||
}
|
||||
@ -2229,7 +2230,7 @@ static int ip_vs_set_timeout(struct net *net, struct ip_vs_timeout_user *u)
|
||||
|
||||
#ifdef CONFIG_IP_VS_PROTO_UDP
|
||||
if (u->udp_timeout) {
|
||||
pd = ip_vs_proto_data_get(net, IPPROTO_UDP);
|
||||
pd = ip_vs_proto_data_get(ipvs, IPPROTO_UDP);
|
||||
pd->timeout_table[IP_VS_UDP_S_NORMAL]
|
||||
= u->udp_timeout * HZ;
|
||||
}
|
||||
@ -2589,18 +2590,19 @@ static inline void
|
||||
__ip_vs_get_timeouts(struct net *net, struct ip_vs_timeout_user *u)
|
||||
{
|
||||
#if defined(CONFIG_IP_VS_PROTO_TCP) || defined(CONFIG_IP_VS_PROTO_UDP)
|
||||
struct netns_ipvs *ipvs = net_ipvs(net);
|
||||
struct ip_vs_proto_data *pd;
|
||||
#endif
|
||||
|
||||
memset(u, 0, sizeof (*u));
|
||||
|
||||
#ifdef CONFIG_IP_VS_PROTO_TCP
|
||||
pd = ip_vs_proto_data_get(net, IPPROTO_TCP);
|
||||
pd = ip_vs_proto_data_get(ipvs, IPPROTO_TCP);
|
||||
u->tcp_timeout = pd->timeout_table[IP_VS_TCP_S_ESTABLISHED] / HZ;
|
||||
u->tcp_fin_timeout = pd->timeout_table[IP_VS_TCP_S_FIN_WAIT] / HZ;
|
||||
#endif
|
||||
#ifdef CONFIG_IP_VS_PROTO_UDP
|
||||
pd = ip_vs_proto_data_get(net, IPPROTO_UDP);
|
||||
pd = ip_vs_proto_data_get(ipvs, IPPROTO_UDP);
|
||||
u->udp_timeout =
|
||||
pd->timeout_table[IP_VS_UDP_S_NORMAL] / HZ;
|
||||
#endif
|
||||
|
@ -156,8 +156,8 @@ EXPORT_SYMBOL(ip_vs_proto_get);
|
||||
/*
|
||||
* get ip_vs_protocol object data by netns and proto
|
||||
*/
|
||||
static struct ip_vs_proto_data *
|
||||
__ipvs_proto_data_get(struct netns_ipvs *ipvs, unsigned short proto)
|
||||
struct ip_vs_proto_data *
|
||||
ip_vs_proto_data_get(struct netns_ipvs *ipvs, unsigned short proto)
|
||||
{
|
||||
struct ip_vs_proto_data *pd;
|
||||
unsigned int hash = IP_VS_PROTO_HASH(proto);
|
||||
@ -169,14 +169,6 @@ __ipvs_proto_data_get(struct netns_ipvs *ipvs, unsigned short proto)
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
struct ip_vs_proto_data *
|
||||
ip_vs_proto_data_get(struct net *net, unsigned short proto)
|
||||
{
|
||||
struct netns_ipvs *ipvs = net_ipvs(net);
|
||||
|
||||
return __ipvs_proto_data_get(ipvs, proto);
|
||||
}
|
||||
EXPORT_SYMBOL(ip_vs_proto_data_get);
|
||||
|
||||
/*
|
||||
|
@ -494,7 +494,7 @@ static int sctp_register_app(struct net *net, struct ip_vs_app *inc)
|
||||
__be16 port = inc->port;
|
||||
int ret = 0;
|
||||
struct netns_ipvs *ipvs = net_ipvs(net);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_SCTP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(ipvs, IPPROTO_SCTP);
|
||||
|
||||
hash = sctp_app_hashkey(port);
|
||||
|
||||
@ -513,7 +513,7 @@ static int sctp_register_app(struct net *net, struct ip_vs_app *inc)
|
||||
|
||||
static void sctp_unregister_app(struct net *net, struct ip_vs_app *inc)
|
||||
{
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_SCTP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net_ipvs(net), IPPROTO_SCTP);
|
||||
|
||||
atomic_dec(&pd->appcnt);
|
||||
list_del_rcu(&inc->p_list);
|
||||
|
@ -602,7 +602,7 @@ static int tcp_register_app(struct net *net, struct ip_vs_app *inc)
|
||||
__be16 port = inc->port;
|
||||
int ret = 0;
|
||||
struct netns_ipvs *ipvs = net_ipvs(net);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_TCP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(ipvs, IPPROTO_TCP);
|
||||
|
||||
hash = tcp_app_hashkey(port);
|
||||
|
||||
@ -623,7 +623,7 @@ static int tcp_register_app(struct net *net, struct ip_vs_app *inc)
|
||||
static void
|
||||
tcp_unregister_app(struct net *net, struct ip_vs_app *inc)
|
||||
{
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_TCP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net_ipvs(net), IPPROTO_TCP);
|
||||
|
||||
atomic_dec(&pd->appcnt);
|
||||
list_del_rcu(&inc->p_list);
|
||||
@ -679,7 +679,7 @@ tcp_app_conn_bind(struct ip_vs_conn *cp)
|
||||
*/
|
||||
void ip_vs_tcp_conn_listen(struct net *net, struct ip_vs_conn *cp)
|
||||
{
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_TCP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net_ipvs(net), IPPROTO_TCP);
|
||||
|
||||
spin_lock_bh(&cp->lock);
|
||||
cp->state = IP_VS_TCP_S_LISTEN;
|
||||
|
@ -372,7 +372,7 @@ static int udp_register_app(struct net *net, struct ip_vs_app *inc)
|
||||
__be16 port = inc->port;
|
||||
int ret = 0;
|
||||
struct netns_ipvs *ipvs = net_ipvs(net);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_UDP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(ipvs, IPPROTO_UDP);
|
||||
|
||||
hash = udp_app_hashkey(port);
|
||||
|
||||
@ -393,7 +393,7 @@ static int udp_register_app(struct net *net, struct ip_vs_app *inc)
|
||||
static void
|
||||
udp_unregister_app(struct net *net, struct ip_vs_app *inc)
|
||||
{
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net, IPPROTO_UDP);
|
||||
struct ip_vs_proto_data *pd = ip_vs_proto_data_get(net_ipvs(net), IPPROTO_UDP);
|
||||
|
||||
atomic_dec(&pd->appcnt);
|
||||
list_del_rcu(&inc->p_list);
|
||||
|
@ -941,7 +941,7 @@ static void ip_vs_proc_conn(struct net *net, struct ip_vs_conn_param *param,
|
||||
} else {
|
||||
struct ip_vs_proto_data *pd;
|
||||
|
||||
pd = ip_vs_proto_data_get(net, protocol);
|
||||
pd = ip_vs_proto_data_get(ipvs, protocol);
|
||||
if (!(flags & IP_VS_CONN_F_TEMPLATE) && pd && pd->timeout_table)
|
||||
cp->timeout = pd->timeout_table[state];
|
||||
else
|
||||
|
Loading…
Reference in New Issue
Block a user