mirror of
https://github.com/Fishwaldo/Star64_linux.git
synced 2025-05-01 12:54:13 +00:00
ipv6: mark DST_NOGC and remove the operation of dst_free()
With the previous preparation patches, we are ready to get rid of the dst gc operation in ipv6 code and release dst based on refcnt only. So this patch adds DST_NOGC flag for all IPv6 dst and remove the calls to dst_free() and its related functions. At this point, all dst created in ipv6 code do not use the dst gc anymore and will be destroyed at the point when refcnt drops to 0. Also, as icmp6 dst route is refcounted during creation and will be freed by user during its call of dst_release(), there is no need to add this dst to the icmp6 gc list as well. Instead, we need to add it into uncached list so that when a NETDEV_DOWN/NETDEV_UNREGISRER event comes, we can properly go through these icmp6 dst as well and release the net device properly. Signed-off-by: Wei Wang <weiwan@google.com> Acked-by: Martin KaFai Lau <kafai@fb.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
parent
ad65a2f056
commit
587fea7411
2 changed files with 19 additions and 45 deletions
|
@ -153,11 +153,6 @@ static void node_free(struct fib6_node *fn)
|
||||||
kmem_cache_free(fib6_node_kmem, fn);
|
kmem_cache_free(fib6_node_kmem, fn);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void rt6_rcu_free(struct rt6_info *rt)
|
|
||||||
{
|
|
||||||
call_rcu(&rt->dst.rcu_head, dst_rcu_free);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void rt6_free_pcpu(struct rt6_info *non_pcpu_rt)
|
static void rt6_free_pcpu(struct rt6_info *non_pcpu_rt)
|
||||||
{
|
{
|
||||||
int cpu;
|
int cpu;
|
||||||
|
@ -174,7 +169,6 @@ static void rt6_free_pcpu(struct rt6_info *non_pcpu_rt)
|
||||||
if (pcpu_rt) {
|
if (pcpu_rt) {
|
||||||
dst_dev_put(&pcpu_rt->dst);
|
dst_dev_put(&pcpu_rt->dst);
|
||||||
dst_release(&pcpu_rt->dst);
|
dst_release(&pcpu_rt->dst);
|
||||||
rt6_rcu_free(pcpu_rt);
|
|
||||||
*ppcpu_rt = NULL;
|
*ppcpu_rt = NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -189,7 +183,6 @@ static void rt6_release(struct rt6_info *rt)
|
||||||
rt6_free_pcpu(rt);
|
rt6_free_pcpu(rt);
|
||||||
dst_dev_put(&rt->dst);
|
dst_dev_put(&rt->dst);
|
||||||
dst_release(&rt->dst);
|
dst_release(&rt->dst);
|
||||||
rt6_rcu_free(rt);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1108,9 +1101,7 @@ out:
|
||||||
/* Always release dst as dst->__refcnt is guaranteed
|
/* Always release dst as dst->__refcnt is guaranteed
|
||||||
* to be taken before entering this function
|
* to be taken before entering this function
|
||||||
*/
|
*/
|
||||||
dst_release(&rt->dst);
|
dst_release_immediate(&rt->dst);
|
||||||
if (!(rt->dst.flags & DST_NOCACHE))
|
|
||||||
dst_free(&rt->dst);
|
|
||||||
}
|
}
|
||||||
return err;
|
return err;
|
||||||
|
|
||||||
|
@ -1124,9 +1115,7 @@ st_failure:
|
||||||
/* Always release dst as dst->__refcnt is guaranteed
|
/* Always release dst as dst->__refcnt is guaranteed
|
||||||
* to be taken before entering this function
|
* to be taken before entering this function
|
||||||
*/
|
*/
|
||||||
dst_release(&rt->dst);
|
dst_release_immediate(&rt->dst);
|
||||||
if (!(rt->dst.flags & DST_NOCACHE))
|
|
||||||
dst_free(&rt->dst);
|
|
||||||
return err;
|
return err;
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
|
@ -354,7 +354,8 @@ static struct rt6_info *__ip6_dst_alloc(struct net *net,
|
||||||
int flags)
|
int flags)
|
||||||
{
|
{
|
||||||
struct rt6_info *rt = dst_alloc(&net->ipv6.ip6_dst_ops, dev,
|
struct rt6_info *rt = dst_alloc(&net->ipv6.ip6_dst_ops, dev,
|
||||||
1, DST_OBSOLETE_FORCE_CHK, flags);
|
1, DST_OBSOLETE_FORCE_CHK,
|
||||||
|
flags | DST_NOGC);
|
||||||
|
|
||||||
if (rt)
|
if (rt)
|
||||||
rt6_info_init(rt);
|
rt6_info_init(rt);
|
||||||
|
@ -381,9 +382,7 @@ struct rt6_info *ip6_dst_alloc(struct net *net,
|
||||||
*p = NULL;
|
*p = NULL;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
dst_release(&rt->dst);
|
dst_release_immediate(&rt->dst);
|
||||||
if (!(flags & DST_NOCACHE))
|
|
||||||
dst_destroy((struct dst_entry *)rt);
|
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1053,8 +1052,7 @@ static struct rt6_info *rt6_make_pcpu_route(struct rt6_info *rt)
|
||||||
prev = cmpxchg(p, NULL, pcpu_rt);
|
prev = cmpxchg(p, NULL, pcpu_rt);
|
||||||
if (prev) {
|
if (prev) {
|
||||||
/* If someone did it before us, return prev instead */
|
/* If someone did it before us, return prev instead */
|
||||||
dst_release(&pcpu_rt->dst);
|
dst_release_immediate(&pcpu_rt->dst);
|
||||||
dst_destroy(&pcpu_rt->dst);
|
|
||||||
pcpu_rt = prev;
|
pcpu_rt = prev;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
@ -1064,8 +1062,7 @@ static struct rt6_info *rt6_make_pcpu_route(struct rt6_info *rt)
|
||||||
* since rt is going away anyway. The next
|
* since rt is going away anyway. The next
|
||||||
* dst_check() will trigger a re-lookup.
|
* dst_check() will trigger a re-lookup.
|
||||||
*/
|
*/
|
||||||
dst_release(&pcpu_rt->dst);
|
dst_release_immediate(&pcpu_rt->dst);
|
||||||
dst_destroy(&pcpu_rt->dst);
|
|
||||||
pcpu_rt = rt;
|
pcpu_rt = rt;
|
||||||
}
|
}
|
||||||
dst_hold(&pcpu_rt->dst);
|
dst_hold(&pcpu_rt->dst);
|
||||||
|
@ -1257,9 +1254,8 @@ struct dst_entry *ip6_blackhole_route(struct net *net, struct dst_entry *dst_ori
|
||||||
struct net_device *loopback_dev = net->loopback_dev;
|
struct net_device *loopback_dev = net->loopback_dev;
|
||||||
struct dst_entry *new = NULL;
|
struct dst_entry *new = NULL;
|
||||||
|
|
||||||
|
|
||||||
rt = dst_alloc(&ip6_dst_blackhole_ops, loopback_dev, 1,
|
rt = dst_alloc(&ip6_dst_blackhole_ops, loopback_dev, 1,
|
||||||
DST_OBSOLETE_NONE, 0);
|
DST_OBSOLETE_NONE, DST_NOGC);
|
||||||
if (rt) {
|
if (rt) {
|
||||||
rt6_info_init(rt);
|
rt6_info_init(rt);
|
||||||
|
|
||||||
|
@ -1279,8 +1275,6 @@ struct dst_entry *ip6_blackhole_route(struct net *net, struct dst_entry *dst_ori
|
||||||
#ifdef CONFIG_IPV6_SUBTREES
|
#ifdef CONFIG_IPV6_SUBTREES
|
||||||
memcpy(&rt->rt6i_src, &ort->rt6i_src, sizeof(struct rt6key));
|
memcpy(&rt->rt6i_src, &ort->rt6i_src, sizeof(struct rt6key));
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
dst_free(new);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
dst_release(dst_orig);
|
dst_release(dst_orig);
|
||||||
|
@ -1692,12 +1686,10 @@ struct dst_entry *icmp6_dst_alloc(struct net_device *dev,
|
||||||
rt->rt6i_idev = idev;
|
rt->rt6i_idev = idev;
|
||||||
dst_metric_set(&rt->dst, RTAX_HOPLIMIT, 0);
|
dst_metric_set(&rt->dst, RTAX_HOPLIMIT, 0);
|
||||||
|
|
||||||
spin_lock_bh(&icmp6_dst_lock);
|
/* Add this dst into uncached_list so that rt6_ifdown() can
|
||||||
rt->dst.next = icmp6_dst_gc_list;
|
* do proper release of the net_device
|
||||||
icmp6_dst_gc_list = &rt->dst;
|
*/
|
||||||
spin_unlock_bh(&icmp6_dst_lock);
|
rt6_uncached_list_add(rt);
|
||||||
|
|
||||||
fib6_force_start_gc(net);
|
|
||||||
|
|
||||||
dst = xfrm_lookup(net, &rt->dst, flowi6_to_flowi(fl6), NULL, 0);
|
dst = xfrm_lookup(net, &rt->dst, flowi6_to_flowi(fl6), NULL, 0);
|
||||||
|
|
||||||
|
@ -2142,10 +2134,8 @@ out:
|
||||||
dev_put(dev);
|
dev_put(dev);
|
||||||
if (idev)
|
if (idev)
|
||||||
in6_dev_put(idev);
|
in6_dev_put(idev);
|
||||||
if (rt) {
|
if (rt)
|
||||||
dst_release(&rt->dst);
|
dst_release_immediate(&rt->dst);
|
||||||
dst_free(&rt->dst);
|
|
||||||
}
|
|
||||||
|
|
||||||
return ERR_PTR(err);
|
return ERR_PTR(err);
|
||||||
}
|
}
|
||||||
|
@ -2174,10 +2164,8 @@ int ip6_route_add(struct fib6_config *cfg,
|
||||||
|
|
||||||
return err;
|
return err;
|
||||||
out:
|
out:
|
||||||
if (rt) {
|
if (rt)
|
||||||
dst_release(&rt->dst);
|
dst_release_immediate(&rt->dst);
|
||||||
dst_free(&rt->dst);
|
|
||||||
}
|
|
||||||
|
|
||||||
return err;
|
return err;
|
||||||
}
|
}
|
||||||
|
@ -3206,8 +3194,7 @@ static int ip6_route_multipath_add(struct fib6_config *cfg,
|
||||||
|
|
||||||
err = ip6_route_info_append(&rt6_nh_list, rt, &r_cfg);
|
err = ip6_route_info_append(&rt6_nh_list, rt, &r_cfg);
|
||||||
if (err) {
|
if (err) {
|
||||||
dst_release(&rt->dst);
|
dst_release_immediate(&rt->dst);
|
||||||
dst_free(&rt->dst);
|
|
||||||
goto cleanup;
|
goto cleanup;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -3270,10 +3257,8 @@ add_errout:
|
||||||
|
|
||||||
cleanup:
|
cleanup:
|
||||||
list_for_each_entry_safe(nh, nh_safe, &rt6_nh_list, next) {
|
list_for_each_entry_safe(nh, nh_safe, &rt6_nh_list, next) {
|
||||||
if (nh->rt6_info) {
|
if (nh->rt6_info)
|
||||||
dst_release(&nh->rt6_info->dst);
|
dst_release_immediate(&nh->rt6_info->dst);
|
||||||
dst_free(&nh->rt6_info->dst);
|
|
||||||
}
|
|
||||||
kfree(nh->mxc.mx);
|
kfree(nh->mxc.mx);
|
||||||
list_del(&nh->next);
|
list_del(&nh->next);
|
||||||
kfree(nh);
|
kfree(nh);
|
||||||
|
|
Loading…
Add table
Reference in a new issue