提交 8229efda 编写于 作者: B Benjamin Thery 提交者: David S. Miller

netns: ip6mr: enable namespace support in ipv6 multicast forwarding code

This last patch makes the appropriate changes to use and propagate the
network namespace where needed in IPv6 multicast forwarding code.

This consists mainly in replacing all the remaining init_net occurences
with current netns pointer retrieved from sockets, net devices or 
mfc6_caches depending on the routines' contexts.

Some routines receive a new 'struct net' parameter to propagate the current
netns:
* ip6mr_get_route
* ip6mr_cache_report
* ip6mr_cache_find
* ip6mr_cache_unresolved
* mif6_add/mif6_delete
* ip6mr_mfc_add/ip6mr_mfc_delete
* ip6mr_reg_vif

All the IPv6 multicast forwarding variables moved to struct netns_ipv6 by
the previous patches are now referenced in the correct namespace.

Changelog:
==========
* Take into account the net associated to mfc6_cache when matching entries in
  mfc_unres_queue list.
* Call mroute_clean_tables() in ip6mr_net_exit() to free memory allocated
  per-namespace.
* Call dev_net_set() in ip6mr_reg_vif() to initialize dev->nd_net 
  correctly.
Signed-off-by: NBenjamin Thery <benjamin.thery@bull.net>
Signed-off-by: NDavid S. Miller <davem@davemloft.net>
上级 8b90fc7e
...@@ -245,7 +245,8 @@ void mfc6_net_set(struct mfc6_cache *mfc, struct net *net) ...@@ -245,7 +245,8 @@ void mfc6_net_set(struct mfc6_cache *mfc, struct net *net)
#ifdef __KERNEL__ #ifdef __KERNEL__
struct rtmsg; struct rtmsg;
extern int ip6mr_get_route(struct sk_buff *skb, struct rtmsg *rtm, int nowait); extern int ip6mr_get_route(struct net *net, struct sk_buff *skb,
struct rtmsg *rtm, int nowait);
#ifdef CONFIG_IPV6_MROUTE #ifdef CONFIG_IPV6_MROUTE
static inline struct sock *mroute6_socket(struct net *net) static inline struct sock *mroute6_socket(struct net *net)
......
...@@ -77,8 +77,10 @@ static DEFINE_SPINLOCK(mfc_unres_lock); ...@@ -77,8 +77,10 @@ static DEFINE_SPINLOCK(mfc_unres_lock);
static struct kmem_cache *mrt_cachep __read_mostly; static struct kmem_cache *mrt_cachep __read_mostly;
static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache); static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache);
static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert); static int ip6mr_cache_report(struct net *net, struct sk_buff *pkt,
mifi_t mifi, int assert);
static int ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm); static int ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm);
static void mroute_clean_tables(struct net *net);
#ifdef CONFIG_IPV6_PIMSM_V2 #ifdef CONFIG_IPV6_PIMSM_V2
static struct inet6_protocol pim6_protocol; static struct inet6_protocol pim6_protocol;
...@@ -354,7 +356,8 @@ static int pim6_rcv(struct sk_buff *skb) ...@@ -354,7 +356,8 @@ static int pim6_rcv(struct sk_buff *skb)
struct pimreghdr *pim; struct pimreghdr *pim;
struct ipv6hdr *encap; struct ipv6hdr *encap;
struct net_device *reg_dev = NULL; struct net_device *reg_dev = NULL;
int reg_vif_num = init_net.ipv6.mroute_reg_vif_num; struct net *net = dev_net(skb->dev);
int reg_vif_num = net->ipv6.mroute_reg_vif_num;
if (!pskb_may_pull(skb, sizeof(*pim) + sizeof(*encap))) if (!pskb_may_pull(skb, sizeof(*pim) + sizeof(*encap)))
goto drop; goto drop;
...@@ -377,7 +380,7 @@ static int pim6_rcv(struct sk_buff *skb) ...@@ -377,7 +380,7 @@ static int pim6_rcv(struct sk_buff *skb)
read_lock(&mrt_lock); read_lock(&mrt_lock);
if (reg_vif_num >= 0) if (reg_vif_num >= 0)
reg_dev = init_net.ipv6.vif6_table[reg_vif_num].dev; reg_dev = net->ipv6.vif6_table[reg_vif_num].dev;
if (reg_dev) if (reg_dev)
dev_hold(reg_dev); dev_hold(reg_dev);
read_unlock(&mrt_lock); read_unlock(&mrt_lock);
...@@ -413,10 +416,13 @@ static struct inet6_protocol pim6_protocol = { ...@@ -413,10 +416,13 @@ static struct inet6_protocol pim6_protocol = {
static int reg_vif_xmit(struct sk_buff *skb, struct net_device *dev) static int reg_vif_xmit(struct sk_buff *skb, struct net_device *dev)
{ {
struct net *net = dev_net(dev);
read_lock(&mrt_lock); read_lock(&mrt_lock);
dev->stats.tx_bytes += skb->len; dev->stats.tx_bytes += skb->len;
dev->stats.tx_packets++; dev->stats.tx_packets++;
ip6mr_cache_report(skb, init_net.ipv6.mroute_reg_vif_num, MRT6MSG_WHOLEPKT); ip6mr_cache_report(net, skb, net->ipv6.mroute_reg_vif_num,
MRT6MSG_WHOLEPKT);
read_unlock(&mrt_lock); read_unlock(&mrt_lock);
kfree_skb(skb); kfree_skb(skb);
return 0; return 0;
...@@ -435,7 +441,7 @@ static void reg_vif_setup(struct net_device *dev) ...@@ -435,7 +441,7 @@ static void reg_vif_setup(struct net_device *dev)
dev->destructor = free_netdev; dev->destructor = free_netdev;
} }
static struct net_device *ip6mr_reg_vif(void) static struct net_device *ip6mr_reg_vif(struct net *net)
{ {
struct net_device *dev; struct net_device *dev;
...@@ -443,6 +449,8 @@ static struct net_device *ip6mr_reg_vif(void) ...@@ -443,6 +449,8 @@ static struct net_device *ip6mr_reg_vif(void)
if (dev == NULL) if (dev == NULL)
return NULL; return NULL;
dev_net_set(dev, net);
if (register_netdevice(dev)) { if (register_netdevice(dev)) {
free_netdev(dev); free_netdev(dev);
return NULL; return NULL;
...@@ -469,14 +477,14 @@ static struct net_device *ip6mr_reg_vif(void) ...@@ -469,14 +477,14 @@ static struct net_device *ip6mr_reg_vif(void)
* Delete a VIF entry * Delete a VIF entry
*/ */
static int mif6_delete(int vifi) static int mif6_delete(struct net *net, int vifi)
{ {
struct mif_device *v; struct mif_device *v;
struct net_device *dev; struct net_device *dev;
if (vifi < 0 || vifi >= init_net.ipv6.maxvif) if (vifi < 0 || vifi >= net->ipv6.maxvif)
return -EADDRNOTAVAIL; return -EADDRNOTAVAIL;
v = &init_net.ipv6.vif6_table[vifi]; v = &net->ipv6.vif6_table[vifi];
write_lock_bh(&mrt_lock); write_lock_bh(&mrt_lock);
dev = v->dev; dev = v->dev;
...@@ -488,17 +496,17 @@ static int mif6_delete(int vifi) ...@@ -488,17 +496,17 @@ static int mif6_delete(int vifi)
} }
#ifdef CONFIG_IPV6_PIMSM_V2 #ifdef CONFIG_IPV6_PIMSM_V2
if (vifi == init_net.ipv6.mroute_reg_vif_num) if (vifi == net->ipv6.mroute_reg_vif_num)
init_net.ipv6.mroute_reg_vif_num = -1; net->ipv6.mroute_reg_vif_num = -1;
#endif #endif
if (vifi + 1 == init_net.ipv6.maxvif) { if (vifi + 1 == net->ipv6.maxvif) {
int tmp; int tmp;
for (tmp = vifi - 1; tmp >= 0; tmp--) { for (tmp = vifi - 1; tmp >= 0; tmp--) {
if (MIF_EXISTS(&init_net, tmp)) if (MIF_EXISTS(net, tmp))
break; break;
} }
init_net.ipv6.maxvif = tmp + 1; net->ipv6.maxvif = tmp + 1;
} }
write_unlock_bh(&mrt_lock); write_unlock_bh(&mrt_lock);
...@@ -525,8 +533,9 @@ static inline void ip6mr_cache_free(struct mfc6_cache *c) ...@@ -525,8 +533,9 @@ static inline void ip6mr_cache_free(struct mfc6_cache *c)
static void ip6mr_destroy_unres(struct mfc6_cache *c) static void ip6mr_destroy_unres(struct mfc6_cache *c)
{ {
struct sk_buff *skb; struct sk_buff *skb;
struct net *net = mfc6_net(c);
atomic_dec(&init_net.ipv6.cache_resolve_queue_len); atomic_dec(&net->ipv6.cache_resolve_queue_len);
while((skb = skb_dequeue(&c->mfc_un.unres.unresolved)) != NULL) { while((skb = skb_dequeue(&c->mfc_un.unres.unresolved)) != NULL) {
if (ipv6_hdr(skb)->version == 0) { if (ipv6_hdr(skb)->version == 0) {
...@@ -535,7 +544,7 @@ static void ip6mr_destroy_unres(struct mfc6_cache *c) ...@@ -535,7 +544,7 @@ static void ip6mr_destroy_unres(struct mfc6_cache *c)
nlh->nlmsg_len = NLMSG_LENGTH(sizeof(struct nlmsgerr)); nlh->nlmsg_len = NLMSG_LENGTH(sizeof(struct nlmsgerr));
skb_trim(skb, nlh->nlmsg_len); skb_trim(skb, nlh->nlmsg_len);
((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -ETIMEDOUT; ((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -ETIMEDOUT;
rtnl_unicast(skb, &init_net, NETLINK_CB(skb).pid); rtnl_unicast(skb, net, NETLINK_CB(skb).pid);
} else } else
kfree_skb(skb); kfree_skb(skb);
} }
...@@ -590,13 +599,14 @@ static void ipmr_expire_process(unsigned long dummy) ...@@ -590,13 +599,14 @@ static void ipmr_expire_process(unsigned long dummy)
static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttls) static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttls)
{ {
int vifi; int vifi;
struct net *net = mfc6_net(cache);
cache->mfc_un.res.minvif = MAXMIFS; cache->mfc_un.res.minvif = MAXMIFS;
cache->mfc_un.res.maxvif = 0; cache->mfc_un.res.maxvif = 0;
memset(cache->mfc_un.res.ttls, 255, MAXMIFS); memset(cache->mfc_un.res.ttls, 255, MAXMIFS);
for (vifi = 0; vifi < init_net.ipv6.maxvif; vifi++) { for (vifi = 0; vifi < net->ipv6.maxvif; vifi++) {
if (MIF_EXISTS(&init_net, vifi) && if (MIF_EXISTS(net, vifi) &&
ttls[vifi] && ttls[vifi] < 255) { ttls[vifi] && ttls[vifi] < 255) {
cache->mfc_un.res.ttls[vifi] = ttls[vifi]; cache->mfc_un.res.ttls[vifi] = ttls[vifi];
if (cache->mfc_un.res.minvif > vifi) if (cache->mfc_un.res.minvif > vifi)
...@@ -607,15 +617,15 @@ static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttl ...@@ -607,15 +617,15 @@ static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttl
} }
} }
static int mif6_add(struct mif6ctl *vifc, int mrtsock) static int mif6_add(struct net *net, struct mif6ctl *vifc, int mrtsock)
{ {
int vifi = vifc->mif6c_mifi; int vifi = vifc->mif6c_mifi;
struct mif_device *v = &init_net.ipv6.vif6_table[vifi]; struct mif_device *v = &net->ipv6.vif6_table[vifi];
struct net_device *dev; struct net_device *dev;
int err; int err;
/* Is vif busy ? */ /* Is vif busy ? */
if (MIF_EXISTS(&init_net, vifi)) if (MIF_EXISTS(net, vifi))
return -EADDRINUSE; return -EADDRINUSE;
switch (vifc->mif6c_flags) { switch (vifc->mif6c_flags) {
...@@ -625,9 +635,9 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock) ...@@ -625,9 +635,9 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock)
* Special Purpose VIF in PIM * Special Purpose VIF in PIM
* All the packets will be sent to the daemon * All the packets will be sent to the daemon
*/ */
if (init_net.ipv6.mroute_reg_vif_num >= 0) if (net->ipv6.mroute_reg_vif_num >= 0)
return -EADDRINUSE; return -EADDRINUSE;
dev = ip6mr_reg_vif(); dev = ip6mr_reg_vif(net);
if (!dev) if (!dev)
return -ENOBUFS; return -ENOBUFS;
err = dev_set_allmulti(dev, 1); err = dev_set_allmulti(dev, 1);
...@@ -639,7 +649,7 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock) ...@@ -639,7 +649,7 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock)
break; break;
#endif #endif
case 0: case 0:
dev = dev_get_by_index(&init_net, vifc->mif6c_pifi); dev = dev_get_by_index(net, vifc->mif6c_pifi);
if (!dev) if (!dev)
return -EADDRNOTAVAIL; return -EADDRNOTAVAIL;
err = dev_set_allmulti(dev, 1); err = dev_set_allmulti(dev, 1);
...@@ -673,20 +683,22 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock) ...@@ -673,20 +683,22 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock)
v->dev = dev; v->dev = dev;
#ifdef CONFIG_IPV6_PIMSM_V2 #ifdef CONFIG_IPV6_PIMSM_V2
if (v->flags & MIFF_REGISTER) if (v->flags & MIFF_REGISTER)
init_net.ipv6.mroute_reg_vif_num = vifi; net->ipv6.mroute_reg_vif_num = vifi;
#endif #endif
if (vifi + 1 > init_net.ipv6.maxvif) if (vifi + 1 > net->ipv6.maxvif)
init_net.ipv6.maxvif = vifi + 1; net->ipv6.maxvif = vifi + 1;
write_unlock_bh(&mrt_lock); write_unlock_bh(&mrt_lock);
return 0; return 0;
} }
static struct mfc6_cache *ip6mr_cache_find(struct in6_addr *origin, struct in6_addr *mcastgrp) static struct mfc6_cache *ip6mr_cache_find(struct net *net,
struct in6_addr *origin,
struct in6_addr *mcastgrp)
{ {
int line = MFC6_HASH(mcastgrp, origin); int line = MFC6_HASH(mcastgrp, origin);
struct mfc6_cache *c; struct mfc6_cache *c;
for (c = init_net.ipv6.mfc6_cache_array[line]; c; c = c->next) { for (c = net->ipv6.mfc6_cache_array[line]; c; c = c->next) {
if (ipv6_addr_equal(&c->mf6c_origin, origin) && if (ipv6_addr_equal(&c->mf6c_origin, origin) &&
ipv6_addr_equal(&c->mf6c_mcastgrp, mcastgrp)) ipv6_addr_equal(&c->mf6c_mcastgrp, mcastgrp))
break; break;
...@@ -743,7 +755,7 @@ static void ip6mr_cache_resolve(struct mfc6_cache *uc, struct mfc6_cache *c) ...@@ -743,7 +755,7 @@ static void ip6mr_cache_resolve(struct mfc6_cache *uc, struct mfc6_cache *c)
skb_trim(skb, nlh->nlmsg_len); skb_trim(skb, nlh->nlmsg_len);
((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -EMSGSIZE; ((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -EMSGSIZE;
} }
err = rtnl_unicast(skb, &init_net, NETLINK_CB(skb).pid); err = rtnl_unicast(skb, mfc6_net(uc), NETLINK_CB(skb).pid);
} else } else
ip6_mr_forward(skb, c); ip6_mr_forward(skb, c);
} }
...@@ -756,7 +768,8 @@ static void ip6mr_cache_resolve(struct mfc6_cache *uc, struct mfc6_cache *c) ...@@ -756,7 +768,8 @@ static void ip6mr_cache_resolve(struct mfc6_cache *uc, struct mfc6_cache *c)
* Called under mrt_lock. * Called under mrt_lock.
*/ */
static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) static int ip6mr_cache_report(struct net *net, struct sk_buff *pkt, mifi_t mifi,
int assert)
{ {
struct sk_buff *skb; struct sk_buff *skb;
struct mrt6msg *msg; struct mrt6msg *msg;
...@@ -792,7 +805,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) ...@@ -792,7 +805,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert)
msg = (struct mrt6msg *)skb_transport_header(skb); msg = (struct mrt6msg *)skb_transport_header(skb);
msg->im6_mbz = 0; msg->im6_mbz = 0;
msg->im6_msgtype = MRT6MSG_WHOLEPKT; msg->im6_msgtype = MRT6MSG_WHOLEPKT;
msg->im6_mif = init_net.ipv6.mroute_reg_vif_num; msg->im6_mif = net->ipv6.mroute_reg_vif_num;
msg->im6_pad = 0; msg->im6_pad = 0;
ipv6_addr_copy(&msg->im6_src, &ipv6_hdr(pkt)->saddr); ipv6_addr_copy(&msg->im6_src, &ipv6_hdr(pkt)->saddr);
ipv6_addr_copy(&msg->im6_dst, &ipv6_hdr(pkt)->daddr); ipv6_addr_copy(&msg->im6_dst, &ipv6_hdr(pkt)->daddr);
...@@ -829,7 +842,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) ...@@ -829,7 +842,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert)
skb_pull(skb, sizeof(struct ipv6hdr)); skb_pull(skb, sizeof(struct ipv6hdr));
} }
if (init_net.ipv6.mroute6_sk == NULL) { if (net->ipv6.mroute6_sk == NULL) {
kfree_skb(skb); kfree_skb(skb);
return -EINVAL; return -EINVAL;
} }
...@@ -837,7 +850,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) ...@@ -837,7 +850,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert)
/* /*
* Deliver to user space multicast routing algorithms * Deliver to user space multicast routing algorithms
*/ */
ret = sock_queue_rcv_skb(init_net.ipv6.mroute6_sk, skb); ret = sock_queue_rcv_skb(net->ipv6.mroute6_sk, skb);
if (ret < 0) { if (ret < 0) {
if (net_ratelimit()) if (net_ratelimit())
printk(KERN_WARNING "mroute6: pending queue full, dropping entries.\n"); printk(KERN_WARNING "mroute6: pending queue full, dropping entries.\n");
...@@ -852,14 +865,14 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) ...@@ -852,14 +865,14 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert)
*/ */
static int static int
ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) ip6mr_cache_unresolved(struct net *net, mifi_t mifi, struct sk_buff *skb)
{ {
int err; int err;
struct mfc6_cache *c; struct mfc6_cache *c;
spin_lock_bh(&mfc_unres_lock); spin_lock_bh(&mfc_unres_lock);
for (c = mfc_unres_queue; c; c = c->next) { for (c = mfc_unres_queue; c; c = c->next) {
if (net_eq(mfc6_net(c), &init_net) && if (net_eq(mfc6_net(c), net) &&
ipv6_addr_equal(&c->mf6c_mcastgrp, &ipv6_hdr(skb)->daddr) && ipv6_addr_equal(&c->mf6c_mcastgrp, &ipv6_hdr(skb)->daddr) &&
ipv6_addr_equal(&c->mf6c_origin, &ipv6_hdr(skb)->saddr)) ipv6_addr_equal(&c->mf6c_origin, &ipv6_hdr(skb)->saddr))
break; break;
...@@ -870,8 +883,8 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) ...@@ -870,8 +883,8 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb)
* Create a new entry if allowable * Create a new entry if allowable
*/ */
if (atomic_read(&init_net.ipv6.cache_resolve_queue_len) >= 10 || if (atomic_read(&net->ipv6.cache_resolve_queue_len) >= 10 ||
(c = ip6mr_cache_alloc_unres(&init_net)) == NULL) { (c = ip6mr_cache_alloc_unres(net)) == NULL) {
spin_unlock_bh(&mfc_unres_lock); spin_unlock_bh(&mfc_unres_lock);
kfree_skb(skb); kfree_skb(skb);
...@@ -888,7 +901,8 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) ...@@ -888,7 +901,8 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb)
/* /*
* Reflect first query at pim6sd * Reflect first query at pim6sd
*/ */
if ((err = ip6mr_cache_report(skb, mifi, MRT6MSG_NOCACHE)) < 0) { err = ip6mr_cache_report(net, skb, mifi, MRT6MSG_NOCACHE);
if (err < 0) {
/* If the report failed throw the cache entry /* If the report failed throw the cache entry
out - Brad Parker out - Brad Parker
*/ */
...@@ -899,7 +913,7 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) ...@@ -899,7 +913,7 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb)
return err; return err;
} }
atomic_inc(&init_net.ipv6.cache_resolve_queue_len); atomic_inc(&net->ipv6.cache_resolve_queue_len);
c->next = mfc_unres_queue; c->next = mfc_unres_queue;
mfc_unres_queue = c; mfc_unres_queue = c;
...@@ -925,14 +939,14 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) ...@@ -925,14 +939,14 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb)
* MFC6 cache manipulation by user space * MFC6 cache manipulation by user space
*/ */
static int ip6mr_mfc_delete(struct mf6cctl *mfc) static int ip6mr_mfc_delete(struct net *net, struct mf6cctl *mfc)
{ {
int line; int line;
struct mfc6_cache *c, **cp; struct mfc6_cache *c, **cp;
line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr); line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr);
for (cp = &init_net.ipv6.mfc6_cache_array[line]; for (cp = &net->ipv6.mfc6_cache_array[line];
(c = *cp) != NULL; cp = &c->next) { (c = *cp) != NULL; cp = &c->next) {
if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) && if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) &&
ipv6_addr_equal(&c->mf6c_mcastgrp, &mfc->mf6cc_mcastgrp.sin6_addr)) { ipv6_addr_equal(&c->mf6c_mcastgrp, &mfc->mf6cc_mcastgrp.sin6_addr)) {
...@@ -951,19 +965,17 @@ static int ip6mr_device_event(struct notifier_block *this, ...@@ -951,19 +965,17 @@ static int ip6mr_device_event(struct notifier_block *this,
unsigned long event, void *ptr) unsigned long event, void *ptr)
{ {
struct net_device *dev = ptr; struct net_device *dev = ptr;
struct net *net = dev_net(dev);
struct mif_device *v; struct mif_device *v;
int ct; int ct;
if (!net_eq(dev_net(dev), &init_net))
return NOTIFY_DONE;
if (event != NETDEV_UNREGISTER) if (event != NETDEV_UNREGISTER)
return NOTIFY_DONE; return NOTIFY_DONE;
v = &init_net.ipv6.vif6_table[0]; v = &net->ipv6.vif6_table[0];
for (ct = 0; ct < init_net.ipv6.maxvif; ct++, v++) { for (ct = 0; ct < net->ipv6.maxvif; ct++, v++) {
if (v->dev == dev) if (v->dev == dev)
mif6_delete(ct); mif6_delete(net, ct);
} }
return NOTIFY_DONE; return NOTIFY_DONE;
} }
...@@ -1026,6 +1038,7 @@ static void __net_exit ip6mr_net_exit(struct net *net) ...@@ -1026,6 +1038,7 @@ static void __net_exit ip6mr_net_exit(struct net *net)
proc_net_remove(net, "ip6_mr_cache"); proc_net_remove(net, "ip6_mr_cache");
proc_net_remove(net, "ip6_mr_vif"); proc_net_remove(net, "ip6_mr_vif");
#endif #endif
mroute_clean_tables(net);
kfree(net->ipv6.mfc6_cache_array); kfree(net->ipv6.mfc6_cache_array);
kfree(net->ipv6.vif6_table); kfree(net->ipv6.vif6_table);
} }
...@@ -1071,7 +1084,7 @@ void ip6_mr_cleanup(void) ...@@ -1071,7 +1084,7 @@ void ip6_mr_cleanup(void)
kmem_cache_destroy(mrt_cachep); kmem_cache_destroy(mrt_cachep);
} }
static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) static int ip6mr_mfc_add(struct net *net, struct mf6cctl *mfc, int mrtsock)
{ {
int line; int line;
struct mfc6_cache *uc, *c, **cp; struct mfc6_cache *uc, *c, **cp;
...@@ -1087,7 +1100,7 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) ...@@ -1087,7 +1100,7 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock)
line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr); line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr);
for (cp = &init_net.ipv6.mfc6_cache_array[line]; for (cp = &net->ipv6.mfc6_cache_array[line];
(c = *cp) != NULL; cp = &c->next) { (c = *cp) != NULL; cp = &c->next) {
if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) && if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) &&
ipv6_addr_equal(&c->mf6c_mcastgrp, &mfc->mf6cc_mcastgrp.sin6_addr)) ipv6_addr_equal(&c->mf6c_mcastgrp, &mfc->mf6cc_mcastgrp.sin6_addr))
...@@ -1107,7 +1120,7 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) ...@@ -1107,7 +1120,7 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock)
if (!ipv6_addr_is_multicast(&mfc->mf6cc_mcastgrp.sin6_addr)) if (!ipv6_addr_is_multicast(&mfc->mf6cc_mcastgrp.sin6_addr))
return -EINVAL; return -EINVAL;
c = ip6mr_cache_alloc(&init_net); c = ip6mr_cache_alloc(net);
if (c == NULL) if (c == NULL)
return -ENOMEM; return -ENOMEM;
...@@ -1119,8 +1132,8 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) ...@@ -1119,8 +1132,8 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock)
c->mfc_flags |= MFC_STATIC; c->mfc_flags |= MFC_STATIC;
write_lock_bh(&mrt_lock); write_lock_bh(&mrt_lock);
c->next = init_net.ipv6.mfc6_cache_array[line]; c->next = net->ipv6.mfc6_cache_array[line];
init_net.ipv6.mfc6_cache_array[line] = c; net->ipv6.mfc6_cache_array[line] = c;
write_unlock_bh(&mrt_lock); write_unlock_bh(&mrt_lock);
/* /*
...@@ -1130,11 +1143,11 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) ...@@ -1130,11 +1143,11 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock)
spin_lock_bh(&mfc_unres_lock); spin_lock_bh(&mfc_unres_lock);
for (cp = &mfc_unres_queue; (uc = *cp) != NULL; for (cp = &mfc_unres_queue; (uc = *cp) != NULL;
cp = &uc->next) { cp = &uc->next) {
if (net_eq(mfc6_net(uc), &init_net) && if (net_eq(mfc6_net(uc), net) &&
ipv6_addr_equal(&uc->mf6c_origin, &c->mf6c_origin) && ipv6_addr_equal(&uc->mf6c_origin, &c->mf6c_origin) &&
ipv6_addr_equal(&uc->mf6c_mcastgrp, &c->mf6c_mcastgrp)) { ipv6_addr_equal(&uc->mf6c_mcastgrp, &c->mf6c_mcastgrp)) {
*cp = uc->next; *cp = uc->next;
atomic_dec(&init_net.ipv6.cache_resolve_queue_len); atomic_dec(&net->ipv6.cache_resolve_queue_len);
break; break;
} }
} }
...@@ -1153,16 +1166,16 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) ...@@ -1153,16 +1166,16 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock)
* Close the multicast socket, and clear the vif tables etc * Close the multicast socket, and clear the vif tables etc
*/ */
static void mroute_clean_tables(struct sock *sk) static void mroute_clean_tables(struct net *net)
{ {
int i; int i;
/* /*
* Shut down all active vif entries * Shut down all active vif entries
*/ */
for (i = 0; i < init_net.ipv6.maxvif; i++) { for (i = 0; i < net->ipv6.maxvif; i++) {
if (!(init_net.ipv6.vif6_table[i].flags & VIFF_STATIC)) if (!(net->ipv6.vif6_table[i].flags & VIFF_STATIC))
mif6_delete(i); mif6_delete(net, i);
} }
/* /*
...@@ -1171,7 +1184,7 @@ static void mroute_clean_tables(struct sock *sk) ...@@ -1171,7 +1184,7 @@ static void mroute_clean_tables(struct sock *sk)
for (i = 0; i < MFC6_LINES; i++) { for (i = 0; i < MFC6_LINES; i++) {
struct mfc6_cache *c, **cp; struct mfc6_cache *c, **cp;
cp = &init_net.ipv6.mfc6_cache_array[i]; cp = &net->ipv6.mfc6_cache_array[i];
while ((c = *cp) != NULL) { while ((c = *cp) != NULL) {
if (c->mfc_flags & MFC_STATIC) { if (c->mfc_flags & MFC_STATIC) {
cp = &c->next; cp = &c->next;
...@@ -1185,13 +1198,13 @@ static void mroute_clean_tables(struct sock *sk) ...@@ -1185,13 +1198,13 @@ static void mroute_clean_tables(struct sock *sk)
} }
} }
if (atomic_read(&init_net.ipv6.cache_resolve_queue_len) != 0) { if (atomic_read(&net->ipv6.cache_resolve_queue_len) != 0) {
struct mfc6_cache *c, **cp; struct mfc6_cache *c, **cp;
spin_lock_bh(&mfc_unres_lock); spin_lock_bh(&mfc_unres_lock);
cp = &mfc_unres_queue; cp = &mfc_unres_queue;
while ((c = *cp) != NULL) { while ((c = *cp) != NULL) {
if (!net_eq(mfc6_net(c), &init_net)) { if (!net_eq(mfc6_net(c), net)) {
cp = &c->next; cp = &c->next;
continue; continue;
} }
...@@ -1205,11 +1218,12 @@ static void mroute_clean_tables(struct sock *sk) ...@@ -1205,11 +1218,12 @@ static void mroute_clean_tables(struct sock *sk)
static int ip6mr_sk_init(struct sock *sk) static int ip6mr_sk_init(struct sock *sk)
{ {
int err = 0; int err = 0;
struct net *net = sock_net(sk);
rtnl_lock(); rtnl_lock();
write_lock_bh(&mrt_lock); write_lock_bh(&mrt_lock);
if (likely(init_net.ipv6.mroute6_sk == NULL)) if (likely(net->ipv6.mroute6_sk == NULL))
init_net.ipv6.mroute6_sk = sk; net->ipv6.mroute6_sk = sk;
else else
err = -EADDRINUSE; err = -EADDRINUSE;
write_unlock_bh(&mrt_lock); write_unlock_bh(&mrt_lock);
...@@ -1222,14 +1236,15 @@ static int ip6mr_sk_init(struct sock *sk) ...@@ -1222,14 +1236,15 @@ static int ip6mr_sk_init(struct sock *sk)
int ip6mr_sk_done(struct sock *sk) int ip6mr_sk_done(struct sock *sk)
{ {
int err = 0; int err = 0;
struct net *net = sock_net(sk);
rtnl_lock(); rtnl_lock();
if (sk == init_net.ipv6.mroute6_sk) { if (sk == net->ipv6.mroute6_sk) {
write_lock_bh(&mrt_lock); write_lock_bh(&mrt_lock);
init_net.ipv6.mroute6_sk = NULL; net->ipv6.mroute6_sk = NULL;
write_unlock_bh(&mrt_lock); write_unlock_bh(&mrt_lock);
mroute_clean_tables(sk); mroute_clean_tables(net);
} else } else
err = -EACCES; err = -EACCES;
rtnl_unlock(); rtnl_unlock();
...@@ -1250,9 +1265,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int ...@@ -1250,9 +1265,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int
struct mif6ctl vif; struct mif6ctl vif;
struct mf6cctl mfc; struct mf6cctl mfc;
mifi_t mifi; mifi_t mifi;
struct net *net = sock_net(sk);
if (optname != MRT6_INIT) { if (optname != MRT6_INIT) {
if (sk != init_net.ipv6.mroute6_sk && !capable(CAP_NET_ADMIN)) if (sk != net->ipv6.mroute6_sk && !capable(CAP_NET_ADMIN))
return -EACCES; return -EACCES;
} }
...@@ -1277,7 +1293,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int ...@@ -1277,7 +1293,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int
if (vif.mif6c_mifi >= MAXMIFS) if (vif.mif6c_mifi >= MAXMIFS)
return -ENFILE; return -ENFILE;
rtnl_lock(); rtnl_lock();
ret = mif6_add(&vif, sk == init_net.ipv6.mroute6_sk); ret = mif6_add(net, &vif, sk == net->ipv6.mroute6_sk);
rtnl_unlock(); rtnl_unlock();
return ret; return ret;
...@@ -1287,7 +1303,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int ...@@ -1287,7 +1303,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int
if (copy_from_user(&mifi, optval, sizeof(mifi_t))) if (copy_from_user(&mifi, optval, sizeof(mifi_t)))
return -EFAULT; return -EFAULT;
rtnl_lock(); rtnl_lock();
ret = mif6_delete(mifi); ret = mif6_delete(net, mifi);
rtnl_unlock(); rtnl_unlock();
return ret; return ret;
...@@ -1303,9 +1319,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int ...@@ -1303,9 +1319,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int
return -EFAULT; return -EFAULT;
rtnl_lock(); rtnl_lock();
if (optname == MRT6_DEL_MFC) if (optname == MRT6_DEL_MFC)
ret = ip6mr_mfc_delete(&mfc); ret = ip6mr_mfc_delete(net, &mfc);
else else
ret = ip6mr_mfc_add(&mfc, sk == init_net.ipv6.mroute6_sk); ret = ip6mr_mfc_add(net, &mfc,
sk == net->ipv6.mroute6_sk);
rtnl_unlock(); rtnl_unlock();
return ret; return ret;
...@@ -1317,7 +1334,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int ...@@ -1317,7 +1334,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int
int v; int v;
if (get_user(v, (int __user *)optval)) if (get_user(v, (int __user *)optval))
return -EFAULT; return -EFAULT;
init_net.ipv6.mroute_do_assert = !!v; net->ipv6.mroute_do_assert = !!v;
return 0; return 0;
} }
...@@ -1330,10 +1347,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int ...@@ -1330,10 +1347,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int
v = !!v; v = !!v;
rtnl_lock(); rtnl_lock();
ret = 0; ret = 0;
if (v != init_net.ipv6.mroute_do_pim) { if (v != net->ipv6.mroute_do_pim) {
init_net.ipv6.mroute_do_pim = v; net->ipv6.mroute_do_pim = v;
init_net.ipv6.mroute_do_assert = v; net->ipv6.mroute_do_assert = v;
if (init_net.ipv6.mroute_do_pim) if (net->ipv6.mroute_do_pim)
ret = inet6_add_protocol(&pim6_protocol, ret = inet6_add_protocol(&pim6_protocol,
IPPROTO_PIM); IPPROTO_PIM);
else else
...@@ -1365,6 +1382,7 @@ int ip6_mroute_getsockopt(struct sock *sk, int optname, char __user *optval, ...@@ -1365,6 +1382,7 @@ int ip6_mroute_getsockopt(struct sock *sk, int optname, char __user *optval,
{ {
int olr; int olr;
int val; int val;
struct net *net = sock_net(sk);
switch (optname) { switch (optname) {
case MRT6_VERSION: case MRT6_VERSION:
...@@ -1372,11 +1390,11 @@ int ip6_mroute_getsockopt(struct sock *sk, int optname, char __user *optval, ...@@ -1372,11 +1390,11 @@ int ip6_mroute_getsockopt(struct sock *sk, int optname, char __user *optval,
break; break;
#ifdef CONFIG_IPV6_PIMSM_V2 #ifdef CONFIG_IPV6_PIMSM_V2
case MRT6_PIM: case MRT6_PIM:
val = init_net.ipv6.mroute_do_pim; val = net->ipv6.mroute_do_pim;
break; break;
#endif #endif
case MRT6_ASSERT: case MRT6_ASSERT:
val = init_net.ipv6.mroute_do_assert; val = net->ipv6.mroute_do_assert;
break; break;
default: default:
return -ENOPROTOOPT; return -ENOPROTOOPT;
...@@ -1406,16 +1424,17 @@ int ip6mr_ioctl(struct sock *sk, int cmd, void __user *arg) ...@@ -1406,16 +1424,17 @@ int ip6mr_ioctl(struct sock *sk, int cmd, void __user *arg)
struct sioc_mif_req6 vr; struct sioc_mif_req6 vr;
struct mif_device *vif; struct mif_device *vif;
struct mfc6_cache *c; struct mfc6_cache *c;
struct net *net = sock_net(sk);
switch (cmd) { switch (cmd) {
case SIOCGETMIFCNT_IN6: case SIOCGETMIFCNT_IN6:
if (copy_from_user(&vr, arg, sizeof(vr))) if (copy_from_user(&vr, arg, sizeof(vr)))
return -EFAULT; return -EFAULT;
if (vr.mifi >= init_net.ipv6.maxvif) if (vr.mifi >= net->ipv6.maxvif)
return -EINVAL; return -EINVAL;
read_lock(&mrt_lock); read_lock(&mrt_lock);
vif = &init_net.ipv6.vif6_table[vr.mifi]; vif = &net->ipv6.vif6_table[vr.mifi];
if (MIF_EXISTS(&init_net, vr.mifi)) { if (MIF_EXISTS(net, vr.mifi)) {
vr.icount = vif->pkt_in; vr.icount = vif->pkt_in;
vr.ocount = vif->pkt_out; vr.ocount = vif->pkt_out;
vr.ibytes = vif->bytes_in; vr.ibytes = vif->bytes_in;
...@@ -1433,7 +1452,7 @@ int ip6mr_ioctl(struct sock *sk, int cmd, void __user *arg) ...@@ -1433,7 +1452,7 @@ int ip6mr_ioctl(struct sock *sk, int cmd, void __user *arg)
return -EFAULT; return -EFAULT;
read_lock(&mrt_lock); read_lock(&mrt_lock);
c = ip6mr_cache_find(&sr.src.sin6_addr, &sr.grp.sin6_addr); c = ip6mr_cache_find(net, &sr.src.sin6_addr, &sr.grp.sin6_addr);
if (c) { if (c) {
sr.pktcnt = c->mfc_un.res.pkt; sr.pktcnt = c->mfc_un.res.pkt;
sr.bytecnt = c->mfc_un.res.bytes; sr.bytecnt = c->mfc_un.res.bytes;
...@@ -1466,7 +1485,8 @@ static inline int ip6mr_forward2_finish(struct sk_buff *skb) ...@@ -1466,7 +1485,8 @@ static inline int ip6mr_forward2_finish(struct sk_buff *skb)
static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi)
{ {
struct ipv6hdr *ipv6h; struct ipv6hdr *ipv6h;
struct mif_device *vif = &init_net.ipv6.vif6_table[vifi]; struct net *net = mfc6_net(c);
struct mif_device *vif = &net->ipv6.vif6_table[vifi];
struct net_device *dev; struct net_device *dev;
struct dst_entry *dst; struct dst_entry *dst;
struct flowi fl; struct flowi fl;
...@@ -1480,7 +1500,7 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) ...@@ -1480,7 +1500,7 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi)
vif->bytes_out += skb->len; vif->bytes_out += skb->len;
vif->dev->stats.tx_bytes += skb->len; vif->dev->stats.tx_bytes += skb->len;
vif->dev->stats.tx_packets++; vif->dev->stats.tx_packets++;
ip6mr_cache_report(skb, vifi, MRT6MSG_WHOLEPKT); ip6mr_cache_report(net, skb, vifi, MRT6MSG_WHOLEPKT);
kfree_skb(skb); kfree_skb(skb);
return 0; return 0;
} }
...@@ -1495,7 +1515,7 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) ...@@ -1495,7 +1515,7 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi)
} }
}; };
dst = ip6_route_output(&init_net, NULL, &fl); dst = ip6_route_output(net, NULL, &fl);
if (!dst) if (!dst)
goto out_free; goto out_free;
...@@ -1538,9 +1558,10 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) ...@@ -1538,9 +1558,10 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi)
static int ip6mr_find_vif(struct net_device *dev) static int ip6mr_find_vif(struct net_device *dev)
{ {
struct net *net = dev_net(dev);
int ct; int ct;
for (ct = init_net.ipv6.maxvif - 1; ct >= 0; ct--) { for (ct = net->ipv6.maxvif - 1; ct >= 0; ct--) {
if (init_net.ipv6.vif6_table[ct].dev == dev) if (net->ipv6.vif6_table[ct].dev == dev)
break; break;
} }
return ct; return ct;
...@@ -1550,6 +1571,7 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache) ...@@ -1550,6 +1571,7 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache)
{ {
int psend = -1; int psend = -1;
int vif, ct; int vif, ct;
struct net *net = mfc6_net(cache);
vif = cache->mf6c_parent; vif = cache->mf6c_parent;
cache->mfc_un.res.pkt++; cache->mfc_un.res.pkt++;
...@@ -1558,30 +1580,30 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache) ...@@ -1558,30 +1580,30 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache)
/* /*
* Wrong interface: drop packet and (maybe) send PIM assert. * Wrong interface: drop packet and (maybe) send PIM assert.
*/ */
if (init_net.ipv6.vif6_table[vif].dev != skb->dev) { if (net->ipv6.vif6_table[vif].dev != skb->dev) {
int true_vifi; int true_vifi;
cache->mfc_un.res.wrong_if++; cache->mfc_un.res.wrong_if++;
true_vifi = ip6mr_find_vif(skb->dev); true_vifi = ip6mr_find_vif(skb->dev);
if (true_vifi >= 0 && init_net.ipv6.mroute_do_assert && if (true_vifi >= 0 && net->ipv6.mroute_do_assert &&
/* pimsm uses asserts, when switching from RPT to SPT, /* pimsm uses asserts, when switching from RPT to SPT,
so that we cannot check that packet arrived on an oif. so that we cannot check that packet arrived on an oif.
It is bad, but otherwise we would need to move pretty It is bad, but otherwise we would need to move pretty
large chunk of pimd to kernel. Ough... --ANK large chunk of pimd to kernel. Ough... --ANK
*/ */
(init_net.ipv6.mroute_do_pim || (net->ipv6.mroute_do_pim ||
cache->mfc_un.res.ttls[true_vifi] < 255) && cache->mfc_un.res.ttls[true_vifi] < 255) &&
time_after(jiffies, time_after(jiffies,
cache->mfc_un.res.last_assert + MFC_ASSERT_THRESH)) { cache->mfc_un.res.last_assert + MFC_ASSERT_THRESH)) {
cache->mfc_un.res.last_assert = jiffies; cache->mfc_un.res.last_assert = jiffies;
ip6mr_cache_report(skb, true_vifi, MRT6MSG_WRONGMIF); ip6mr_cache_report(net, skb, true_vifi, MRT6MSG_WRONGMIF);
} }
goto dont_forward; goto dont_forward;
} }
init_net.ipv6.vif6_table[vif].pkt_in++; net->ipv6.vif6_table[vif].pkt_in++;
init_net.ipv6.vif6_table[vif].bytes_in += skb->len; net->ipv6.vif6_table[vif].bytes_in += skb->len;
/* /*
* Forward the frame * Forward the frame
...@@ -1614,9 +1636,11 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache) ...@@ -1614,9 +1636,11 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache)
int ip6_mr_input(struct sk_buff *skb) int ip6_mr_input(struct sk_buff *skb)
{ {
struct mfc6_cache *cache; struct mfc6_cache *cache;
struct net *net = dev_net(skb->dev);
read_lock(&mrt_lock); read_lock(&mrt_lock);
cache = ip6mr_cache_find(&ipv6_hdr(skb)->saddr, &ipv6_hdr(skb)->daddr); cache = ip6mr_cache_find(net,
&ipv6_hdr(skb)->saddr, &ipv6_hdr(skb)->daddr);
/* /*
* No usable cache entry * No usable cache entry
...@@ -1626,7 +1650,7 @@ int ip6_mr_input(struct sk_buff *skb) ...@@ -1626,7 +1650,7 @@ int ip6_mr_input(struct sk_buff *skb)
vif = ip6mr_find_vif(skb->dev); vif = ip6mr_find_vif(skb->dev);
if (vif >= 0) { if (vif >= 0) {
int err = ip6mr_cache_unresolved(vif, skb); int err = ip6mr_cache_unresolved(net, vif, skb);
read_unlock(&mrt_lock); read_unlock(&mrt_lock);
return err; return err;
...@@ -1649,7 +1673,8 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm) ...@@ -1649,7 +1673,8 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm)
{ {
int ct; int ct;
struct rtnexthop *nhp; struct rtnexthop *nhp;
struct net_device *dev = init_net.ipv6.vif6_table[c->mf6c_parent].dev; struct net *net = mfc6_net(c);
struct net_device *dev = net->ipv6.vif6_table[c->mf6c_parent].dev;
u8 *b = skb_tail_pointer(skb); u8 *b = skb_tail_pointer(skb);
struct rtattr *mp_head; struct rtattr *mp_head;
...@@ -1665,7 +1690,7 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm) ...@@ -1665,7 +1690,7 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm)
nhp = (struct rtnexthop *)skb_put(skb, RTA_ALIGN(sizeof(*nhp))); nhp = (struct rtnexthop *)skb_put(skb, RTA_ALIGN(sizeof(*nhp)));
nhp->rtnh_flags = 0; nhp->rtnh_flags = 0;
nhp->rtnh_hops = c->mfc_un.res.ttls[ct]; nhp->rtnh_hops = c->mfc_un.res.ttls[ct];
nhp->rtnh_ifindex = init_net.ipv6.vif6_table[ct].dev->ifindex; nhp->rtnh_ifindex = net->ipv6.vif6_table[ct].dev->ifindex;
nhp->rtnh_len = sizeof(*nhp); nhp->rtnh_len = sizeof(*nhp);
} }
} }
...@@ -1679,14 +1704,15 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm) ...@@ -1679,14 +1704,15 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm)
return -EMSGSIZE; return -EMSGSIZE;
} }
int ip6mr_get_route(struct sk_buff *skb, struct rtmsg *rtm, int nowait) int ip6mr_get_route(struct net *net,
struct sk_buff *skb, struct rtmsg *rtm, int nowait)
{ {
int err; int err;
struct mfc6_cache *cache; struct mfc6_cache *cache;
struct rt6_info *rt = (struct rt6_info *)skb->dst; struct rt6_info *rt = (struct rt6_info *)skb->dst;
read_lock(&mrt_lock); read_lock(&mrt_lock);
cache = ip6mr_cache_find(&rt->rt6i_src.addr, &rt->rt6i_dst.addr); cache = ip6mr_cache_find(net, &rt->rt6i_src.addr, &rt->rt6i_dst.addr);
if (!cache) { if (!cache) {
struct sk_buff *skb2; struct sk_buff *skb2;
...@@ -1729,7 +1755,7 @@ int ip6mr_get_route(struct sk_buff *skb, struct rtmsg *rtm, int nowait) ...@@ -1729,7 +1755,7 @@ int ip6mr_get_route(struct sk_buff *skb, struct rtmsg *rtm, int nowait)
ipv6_addr_copy(&iph->saddr, &rt->rt6i_src.addr); ipv6_addr_copy(&iph->saddr, &rt->rt6i_src.addr);
ipv6_addr_copy(&iph->daddr, &rt->rt6i_dst.addr); ipv6_addr_copy(&iph->daddr, &rt->rt6i_dst.addr);
err = ip6mr_cache_unresolved(vif, skb2); err = ip6mr_cache_unresolved(net, vif, skb2);
read_unlock(&mrt_lock); read_unlock(&mrt_lock);
return err; return err;
......
...@@ -2194,7 +2194,7 @@ static int rt6_fill_node(struct net *net, ...@@ -2194,7 +2194,7 @@ static int rt6_fill_node(struct net *net,
if (iif) { if (iif) {
#ifdef CONFIG_IPV6_MROUTE #ifdef CONFIG_IPV6_MROUTE
if (ipv6_addr_is_multicast(&rt->rt6i_dst.addr)) { if (ipv6_addr_is_multicast(&rt->rt6i_dst.addr)) {
int err = ip6mr_get_route(skb, rtm, nowait); int err = ip6mr_get_route(net, skb, rtm, nowait);
if (err <= 0) { if (err <= 0) {
if (!nowait) { if (!nowait) {
if (err == 0) if (err == 0)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册