diff options
Diffstat (limited to 'net')
| -rw-r--r-- | net/ipv6/ip6mr.c | 226 | ||||
| -rw-r--r-- | net/ipv6/route.c | 2 |
2 files changed, 127 insertions, 101 deletions
diff --git a/net/ipv6/ip6mr.c b/net/ipv6/ip6mr.c index d619faf68d98..9eed2422b3e3 100644 --- a/net/ipv6/ip6mr.c +++ b/net/ipv6/ip6mr.c | |||
| @@ -77,8 +77,10 @@ static DEFINE_SPINLOCK(mfc_unres_lock); | |||
| 77 | static struct kmem_cache *mrt_cachep __read_mostly; | 77 | static struct kmem_cache *mrt_cachep __read_mostly; |
| 78 | 78 | ||
| 79 | static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache); | 79 | static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache); |
| 80 | static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert); | 80 | static int ip6mr_cache_report(struct net *net, struct sk_buff *pkt, |
| 81 | mifi_t mifi, int assert); | ||
| 81 | static int ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm); | 82 | static int ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm); |
| 83 | static void mroute_clean_tables(struct net *net); | ||
| 82 | 84 | ||
| 83 | #ifdef CONFIG_IPV6_PIMSM_V2 | 85 | #ifdef CONFIG_IPV6_PIMSM_V2 |
| 84 | static struct inet6_protocol pim6_protocol; | 86 | static struct inet6_protocol pim6_protocol; |
| @@ -354,7 +356,8 @@ static int pim6_rcv(struct sk_buff *skb) | |||
| 354 | struct pimreghdr *pim; | 356 | struct pimreghdr *pim; |
| 355 | struct ipv6hdr *encap; | 357 | struct ipv6hdr *encap; |
| 356 | struct net_device *reg_dev = NULL; | 358 | struct net_device *reg_dev = NULL; |
| 357 | int reg_vif_num = init_net.ipv6.mroute_reg_vif_num; | 359 | struct net *net = dev_net(skb->dev); |
| 360 | int reg_vif_num = net->ipv6.mroute_reg_vif_num; | ||
| 358 | 361 | ||
| 359 | if (!pskb_may_pull(skb, sizeof(*pim) + sizeof(*encap))) | 362 | if (!pskb_may_pull(skb, sizeof(*pim) + sizeof(*encap))) |
| 360 | goto drop; | 363 | goto drop; |
| @@ -377,7 +380,7 @@ static int pim6_rcv(struct sk_buff *skb) | |||
| 377 | 380 | ||
| 378 | read_lock(&mrt_lock); | 381 | read_lock(&mrt_lock); |
| 379 | if (reg_vif_num >= 0) | 382 | if (reg_vif_num >= 0) |
| 380 | reg_dev = init_net.ipv6.vif6_table[reg_vif_num].dev; | 383 | reg_dev = net->ipv6.vif6_table[reg_vif_num].dev; |
| 381 | if (reg_dev) | 384 | if (reg_dev) |
| 382 | dev_hold(reg_dev); | 385 | dev_hold(reg_dev); |
| 383 | read_unlock(&mrt_lock); | 386 | read_unlock(&mrt_lock); |
| @@ -413,10 +416,13 @@ static struct inet6_protocol pim6_protocol = { | |||
| 413 | 416 | ||
| 414 | static int reg_vif_xmit(struct sk_buff *skb, struct net_device *dev) | 417 | static int reg_vif_xmit(struct sk_buff *skb, struct net_device *dev) |
| 415 | { | 418 | { |
| 419 | struct net *net = dev_net(dev); | ||
| 420 | |||
| 416 | read_lock(&mrt_lock); | 421 | read_lock(&mrt_lock); |
| 417 | dev->stats.tx_bytes += skb->len; | 422 | dev->stats.tx_bytes += skb->len; |
| 418 | dev->stats.tx_packets++; | 423 | dev->stats.tx_packets++; |
| 419 | ip6mr_cache_report(skb, init_net.ipv6.mroute_reg_vif_num, MRT6MSG_WHOLEPKT); | 424 | ip6mr_cache_report(net, skb, net->ipv6.mroute_reg_vif_num, |
| 425 | MRT6MSG_WHOLEPKT); | ||
| 420 | read_unlock(&mrt_lock); | 426 | read_unlock(&mrt_lock); |
| 421 | kfree_skb(skb); | 427 | kfree_skb(skb); |
| 422 | return 0; | 428 | return 0; |
| @@ -435,7 +441,7 @@ static void reg_vif_setup(struct net_device *dev) | |||
| 435 | dev->destructor = free_netdev; | 441 | dev->destructor = free_netdev; |
| 436 | } | 442 | } |
| 437 | 443 | ||
| 438 | static struct net_device *ip6mr_reg_vif(void) | 444 | static struct net_device *ip6mr_reg_vif(struct net *net) |
| 439 | { | 445 | { |
| 440 | struct net_device *dev; | 446 | struct net_device *dev; |
| 441 | 447 | ||
| @@ -443,6 +449,8 @@ static struct net_device *ip6mr_reg_vif(void) | |||
| 443 | if (dev == NULL) | 449 | if (dev == NULL) |
| 444 | return NULL; | 450 | return NULL; |
| 445 | 451 | ||
| 452 | dev_net_set(dev, net); | ||
| 453 | |||
| 446 | if (register_netdevice(dev)) { | 454 | if (register_netdevice(dev)) { |
| 447 | free_netdev(dev); | 455 | free_netdev(dev); |
| 448 | return NULL; | 456 | return NULL; |
| @@ -469,14 +477,14 @@ failure: | |||
| 469 | * Delete a VIF entry | 477 | * Delete a VIF entry |
| 470 | */ | 478 | */ |
| 471 | 479 | ||
| 472 | static int mif6_delete(int vifi) | 480 | static int mif6_delete(struct net *net, int vifi) |
| 473 | { | 481 | { |
| 474 | struct mif_device *v; | 482 | struct mif_device *v; |
| 475 | struct net_device *dev; | 483 | struct net_device *dev; |
| 476 | if (vifi < 0 || vifi >= init_net.ipv6.maxvif) | 484 | if (vifi < 0 || vifi >= net->ipv6.maxvif) |
| 477 | return -EADDRNOTAVAIL; | 485 | return -EADDRNOTAVAIL; |
| 478 | 486 | ||
| 479 | v = &init_net.ipv6.vif6_table[vifi]; | 487 | v = &net->ipv6.vif6_table[vifi]; |
| 480 | 488 | ||
| 481 | write_lock_bh(&mrt_lock); | 489 | write_lock_bh(&mrt_lock); |
| 482 | dev = v->dev; | 490 | dev = v->dev; |
| @@ -488,17 +496,17 @@ static int mif6_delete(int vifi) | |||
| 488 | } | 496 | } |
| 489 | 497 | ||
| 490 | #ifdef CONFIG_IPV6_PIMSM_V2 | 498 | #ifdef CONFIG_IPV6_PIMSM_V2 |
| 491 | if (vifi == init_net.ipv6.mroute_reg_vif_num) | 499 | if (vifi == net->ipv6.mroute_reg_vif_num) |
| 492 | init_net.ipv6.mroute_reg_vif_num = -1; | 500 | net->ipv6.mroute_reg_vif_num = -1; |
| 493 | #endif | 501 | #endif |
| 494 | 502 | ||
| 495 | if (vifi + 1 == init_net.ipv6.maxvif) { | 503 | if (vifi + 1 == net->ipv6.maxvif) { |
| 496 | int tmp; | 504 | int tmp; |
| 497 | for (tmp = vifi - 1; tmp >= 0; tmp--) { | 505 | for (tmp = vifi - 1; tmp >= 0; tmp--) { |
| 498 | if (MIF_EXISTS(&init_net, tmp)) | 506 | if (MIF_EXISTS(net, tmp)) |
| 499 | break; | 507 | break; |
| 500 | } | 508 | } |
| 501 | init_net.ipv6.maxvif = tmp + 1; | 509 | net->ipv6.maxvif = tmp + 1; |
| 502 | } | 510 | } |
| 503 | 511 | ||
| 504 | write_unlock_bh(&mrt_lock); | 512 | write_unlock_bh(&mrt_lock); |
| @@ -525,8 +533,9 @@ static inline void ip6mr_cache_free(struct mfc6_cache *c) | |||
| 525 | static void ip6mr_destroy_unres(struct mfc6_cache *c) | 533 | static void ip6mr_destroy_unres(struct mfc6_cache *c) |
| 526 | { | 534 | { |
| 527 | struct sk_buff *skb; | 535 | struct sk_buff *skb; |
| 536 | struct net *net = mfc6_net(c); | ||
| 528 | 537 | ||
| 529 | atomic_dec(&init_net.ipv6.cache_resolve_queue_len); | 538 | atomic_dec(&net->ipv6.cache_resolve_queue_len); |
| 530 | 539 | ||
| 531 | while((skb = skb_dequeue(&c->mfc_un.unres.unresolved)) != NULL) { | 540 | while((skb = skb_dequeue(&c->mfc_un.unres.unresolved)) != NULL) { |
| 532 | if (ipv6_hdr(skb)->version == 0) { | 541 | if (ipv6_hdr(skb)->version == 0) { |
| @@ -535,7 +544,7 @@ static void ip6mr_destroy_unres(struct mfc6_cache *c) | |||
| 535 | nlh->nlmsg_len = NLMSG_LENGTH(sizeof(struct nlmsgerr)); | 544 | nlh->nlmsg_len = NLMSG_LENGTH(sizeof(struct nlmsgerr)); |
| 536 | skb_trim(skb, nlh->nlmsg_len); | 545 | skb_trim(skb, nlh->nlmsg_len); |
| 537 | ((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -ETIMEDOUT; | 546 | ((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -ETIMEDOUT; |
| 538 | rtnl_unicast(skb, &init_net, NETLINK_CB(skb).pid); | 547 | rtnl_unicast(skb, net, NETLINK_CB(skb).pid); |
| 539 | } else | 548 | } else |
| 540 | kfree_skb(skb); | 549 | kfree_skb(skb); |
| 541 | } | 550 | } |
| @@ -590,13 +599,14 @@ static void ipmr_expire_process(unsigned long dummy) | |||
| 590 | static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttls) | 599 | static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttls) |
| 591 | { | 600 | { |
| 592 | int vifi; | 601 | int vifi; |
| 602 | struct net *net = mfc6_net(cache); | ||
| 593 | 603 | ||
| 594 | cache->mfc_un.res.minvif = MAXMIFS; | 604 | cache->mfc_un.res.minvif = MAXMIFS; |
| 595 | cache->mfc_un.res.maxvif = 0; | 605 | cache->mfc_un.res.maxvif = 0; |
| 596 | memset(cache->mfc_un.res.ttls, 255, MAXMIFS); | 606 | memset(cache->mfc_un.res.ttls, 255, MAXMIFS); |
| 597 | 607 | ||
| 598 | for (vifi = 0; vifi < init_net.ipv6.maxvif; vifi++) { | 608 | for (vifi = 0; vifi < net->ipv6.maxvif; vifi++) { |
| 599 | if (MIF_EXISTS(&init_net, vifi) && | 609 | if (MIF_EXISTS(net, vifi) && |
| 600 | ttls[vifi] && ttls[vifi] < 255) { | 610 | ttls[vifi] && ttls[vifi] < 255) { |
| 601 | cache->mfc_un.res.ttls[vifi] = ttls[vifi]; | 611 | cache->mfc_un.res.ttls[vifi] = ttls[vifi]; |
| 602 | if (cache->mfc_un.res.minvif > vifi) | 612 | if (cache->mfc_un.res.minvif > vifi) |
| @@ -607,15 +617,15 @@ static void ip6mr_update_thresholds(struct mfc6_cache *cache, unsigned char *ttl | |||
| 607 | } | 617 | } |
| 608 | } | 618 | } |
| 609 | 619 | ||
| 610 | static int mif6_add(struct mif6ctl *vifc, int mrtsock) | 620 | static int mif6_add(struct net *net, struct mif6ctl *vifc, int mrtsock) |
| 611 | { | 621 | { |
| 612 | int vifi = vifc->mif6c_mifi; | 622 | int vifi = vifc->mif6c_mifi; |
| 613 | struct mif_device *v = &init_net.ipv6.vif6_table[vifi]; | 623 | struct mif_device *v = &net->ipv6.vif6_table[vifi]; |
| 614 | struct net_device *dev; | 624 | struct net_device *dev; |
| 615 | int err; | 625 | int err; |
| 616 | 626 | ||
| 617 | /* Is vif busy ? */ | 627 | /* Is vif busy ? */ |
| 618 | if (MIF_EXISTS(&init_net, vifi)) | 628 | if (MIF_EXISTS(net, vifi)) |
| 619 | return -EADDRINUSE; | 629 | return -EADDRINUSE; |
| 620 | 630 | ||
| 621 | switch (vifc->mif6c_flags) { | 631 | switch (vifc->mif6c_flags) { |
| @@ -625,9 +635,9 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock) | |||
| 625 | * Special Purpose VIF in PIM | 635 | * Special Purpose VIF in PIM |
| 626 | * All the packets will be sent to the daemon | 636 | * All the packets will be sent to the daemon |
| 627 | */ | 637 | */ |
| 628 | if (init_net.ipv6.mroute_reg_vif_num >= 0) | 638 | if (net->ipv6.mroute_reg_vif_num >= 0) |
| 629 | return -EADDRINUSE; | 639 | return -EADDRINUSE; |
| 630 | dev = ip6mr_reg_vif(); | 640 | dev = ip6mr_reg_vif(net); |
| 631 | if (!dev) | 641 | if (!dev) |
| 632 | return -ENOBUFS; | 642 | return -ENOBUFS; |
| 633 | err = dev_set_allmulti(dev, 1); | 643 | err = dev_set_allmulti(dev, 1); |
| @@ -639,7 +649,7 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock) | |||
| 639 | break; | 649 | break; |
| 640 | #endif | 650 | #endif |
| 641 | case 0: | 651 | case 0: |
| 642 | dev = dev_get_by_index(&init_net, vifc->mif6c_pifi); | 652 | dev = dev_get_by_index(net, vifc->mif6c_pifi); |
| 643 | if (!dev) | 653 | if (!dev) |
| 644 | return -EADDRNOTAVAIL; | 654 | return -EADDRNOTAVAIL; |
| 645 | err = dev_set_allmulti(dev, 1); | 655 | err = dev_set_allmulti(dev, 1); |
| @@ -673,20 +683,22 @@ static int mif6_add(struct mif6ctl *vifc, int mrtsock) | |||
| 673 | v->dev = dev; | 683 | v->dev = dev; |
| 674 | #ifdef CONFIG_IPV6_PIMSM_V2 | 684 | #ifdef CONFIG_IPV6_PIMSM_V2 |
| 675 | if (v->flags & MIFF_REGISTER) | 685 | if (v->flags & MIFF_REGISTER) |
| 676 | init_net.ipv6.mroute_reg_vif_num = vifi; | 686 | net->ipv6.mroute_reg_vif_num = vifi; |
| 677 | #endif | 687 | #endif |
| 678 | if (vifi + 1 > init_net.ipv6.maxvif) | 688 | if (vifi + 1 > net->ipv6.maxvif) |
| 679 | init_net.ipv6.maxvif = vifi + 1; | 689 | net->ipv6.maxvif = vifi + 1; |
| 680 | write_unlock_bh(&mrt_lock); | 690 | write_unlock_bh(&mrt_lock); |
| 681 | return 0; | 691 | return 0; |
| 682 | } | 692 | } |
| 683 | 693 | ||
| 684 | static struct mfc6_cache *ip6mr_cache_find(struct in6_addr *origin, struct in6_addr *mcastgrp) | 694 | static struct mfc6_cache *ip6mr_cache_find(struct net *net, |
| 695 | struct in6_addr *origin, | ||
| 696 | struct in6_addr *mcastgrp) | ||
| 685 | { | 697 | { |
| 686 | int line = MFC6_HASH(mcastgrp, origin); | 698 | int line = MFC6_HASH(mcastgrp, origin); |
| 687 | struct mfc6_cache *c; | 699 | struct mfc6_cache *c; |
| 688 | 700 | ||
| 689 | for (c = init_net.ipv6.mfc6_cache_array[line]; c; c = c->next) { | 701 | for (c = net->ipv6.mfc6_cache_array[line]; c; c = c->next) { |
| 690 | if (ipv6_addr_equal(&c->mf6c_origin, origin) && | 702 | if (ipv6_addr_equal(&c->mf6c_origin, origin) && |
| 691 | ipv6_addr_equal(&c->mf6c_mcastgrp, mcastgrp)) | 703 | ipv6_addr_equal(&c->mf6c_mcastgrp, mcastgrp)) |
| 692 | break; | 704 | break; |
| @@ -743,7 +755,7 @@ static void ip6mr_cache_resolve(struct mfc6_cache *uc, struct mfc6_cache *c) | |||
| 743 | skb_trim(skb, nlh->nlmsg_len); | 755 | skb_trim(skb, nlh->nlmsg_len); |
| 744 | ((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -EMSGSIZE; | 756 | ((struct nlmsgerr *)NLMSG_DATA(nlh))->error = -EMSGSIZE; |
| 745 | } | 757 | } |
| 746 | err = rtnl_unicast(skb, &init_net, NETLINK_CB(skb).pid); | 758 | err = rtnl_unicast(skb, mfc6_net(uc), NETLINK_CB(skb).pid); |
| 747 | } else | 759 | } else |
| 748 | ip6_mr_forward(skb, c); | 760 | ip6_mr_forward(skb, c); |
| 749 | } | 761 | } |
| @@ -756,7 +768,8 @@ static void ip6mr_cache_resolve(struct mfc6_cache *uc, struct mfc6_cache *c) | |||
| 756 | * Called under mrt_lock. | 768 | * Called under mrt_lock. |
| 757 | */ | 769 | */ |
| 758 | 770 | ||
| 759 | static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) | 771 | static int ip6mr_cache_report(struct net *net, struct sk_buff *pkt, mifi_t mifi, |
| 772 | int assert) | ||
| 760 | { | 773 | { |
| 761 | struct sk_buff *skb; | 774 | struct sk_buff *skb; |
| 762 | struct mrt6msg *msg; | 775 | struct mrt6msg *msg; |
| @@ -792,7 +805,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) | |||
| 792 | msg = (struct mrt6msg *)skb_transport_header(skb); | 805 | msg = (struct mrt6msg *)skb_transport_header(skb); |
| 793 | msg->im6_mbz = 0; | 806 | msg->im6_mbz = 0; |
| 794 | msg->im6_msgtype = MRT6MSG_WHOLEPKT; | 807 | msg->im6_msgtype = MRT6MSG_WHOLEPKT; |
| 795 | msg->im6_mif = init_net.ipv6.mroute_reg_vif_num; | 808 | msg->im6_mif = net->ipv6.mroute_reg_vif_num; |
| 796 | msg->im6_pad = 0; | 809 | msg->im6_pad = 0; |
| 797 | ipv6_addr_copy(&msg->im6_src, &ipv6_hdr(pkt)->saddr); | 810 | ipv6_addr_copy(&msg->im6_src, &ipv6_hdr(pkt)->saddr); |
| 798 | ipv6_addr_copy(&msg->im6_dst, &ipv6_hdr(pkt)->daddr); | 811 | 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 | skb_pull(skb, sizeof(struct ipv6hdr)); | 842 | skb_pull(skb, sizeof(struct ipv6hdr)); |
| 830 | } | 843 | } |
| 831 | 844 | ||
| 832 | if (init_net.ipv6.mroute6_sk == NULL) { | 845 | if (net->ipv6.mroute6_sk == NULL) { |
| 833 | kfree_skb(skb); | 846 | kfree_skb(skb); |
| 834 | return -EINVAL; | 847 | return -EINVAL; |
| 835 | } | 848 | } |
| @@ -837,7 +850,7 @@ static int ip6mr_cache_report(struct sk_buff *pkt, mifi_t mifi, int assert) | |||
| 837 | /* | 850 | /* |
| 838 | * Deliver to user space multicast routing algorithms | 851 | * Deliver to user space multicast routing algorithms |
| 839 | */ | 852 | */ |
| 840 | ret = sock_queue_rcv_skb(init_net.ipv6.mroute6_sk, skb); | 853 | ret = sock_queue_rcv_skb(net->ipv6.mroute6_sk, skb); |
| 841 | if (ret < 0) { | 854 | if (ret < 0) { |
| 842 | if (net_ratelimit()) | 855 | if (net_ratelimit()) |
| 843 | printk(KERN_WARNING "mroute6: pending queue full, dropping entries.\n"); | 856 | 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 | */ | 865 | */ |
| 853 | 866 | ||
| 854 | static int | 867 | static int |
| 855 | ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) | 868 | ip6mr_cache_unresolved(struct net *net, mifi_t mifi, struct sk_buff *skb) |
| 856 | { | 869 | { |
| 857 | int err; | 870 | int err; |
| 858 | struct mfc6_cache *c; | 871 | struct mfc6_cache *c; |
| 859 | 872 | ||
| 860 | spin_lock_bh(&mfc_unres_lock); | 873 | spin_lock_bh(&mfc_unres_lock); |
| 861 | for (c = mfc_unres_queue; c; c = c->next) { | 874 | for (c = mfc_unres_queue; c; c = c->next) { |
| 862 | if (net_eq(mfc6_net(c), &init_net) && | 875 | if (net_eq(mfc6_net(c), net) && |
| 863 | ipv6_addr_equal(&c->mf6c_mcastgrp, &ipv6_hdr(skb)->daddr) && | 876 | ipv6_addr_equal(&c->mf6c_mcastgrp, &ipv6_hdr(skb)->daddr) && |
| 864 | ipv6_addr_equal(&c->mf6c_origin, &ipv6_hdr(skb)->saddr)) | 877 | ipv6_addr_equal(&c->mf6c_origin, &ipv6_hdr(skb)->saddr)) |
| 865 | break; | 878 | break; |
| @@ -870,8 +883,8 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) | |||
| 870 | * Create a new entry if allowable | 883 | * Create a new entry if allowable |
| 871 | */ | 884 | */ |
| 872 | 885 | ||
| 873 | if (atomic_read(&init_net.ipv6.cache_resolve_queue_len) >= 10 || | 886 | if (atomic_read(&net->ipv6.cache_resolve_queue_len) >= 10 || |
| 874 | (c = ip6mr_cache_alloc_unres(&init_net)) == NULL) { | 887 | (c = ip6mr_cache_alloc_unres(net)) == NULL) { |
| 875 | spin_unlock_bh(&mfc_unres_lock); | 888 | spin_unlock_bh(&mfc_unres_lock); |
| 876 | 889 | ||
| 877 | kfree_skb(skb); | 890 | kfree_skb(skb); |
| @@ -888,7 +901,8 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) | |||
| 888 | /* | 901 | /* |
| 889 | * Reflect first query at pim6sd | 902 | * Reflect first query at pim6sd |
| 890 | */ | 903 | */ |
| 891 | if ((err = ip6mr_cache_report(skb, mifi, MRT6MSG_NOCACHE)) < 0) { | 904 | err = ip6mr_cache_report(net, skb, mifi, MRT6MSG_NOCACHE); |
| 905 | if (err < 0) { | ||
| 892 | /* If the report failed throw the cache entry | 906 | /* If the report failed throw the cache entry |
| 893 | out - Brad Parker | 907 | out - Brad Parker |
| 894 | */ | 908 | */ |
| @@ -899,7 +913,7 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) | |||
| 899 | return err; | 913 | return err; |
| 900 | } | 914 | } |
| 901 | 915 | ||
| 902 | atomic_inc(&init_net.ipv6.cache_resolve_queue_len); | 916 | atomic_inc(&net->ipv6.cache_resolve_queue_len); |
| 903 | c->next = mfc_unres_queue; | 917 | c->next = mfc_unres_queue; |
| 904 | mfc_unres_queue = c; | 918 | mfc_unres_queue = c; |
| 905 | 919 | ||
| @@ -925,14 +939,14 @@ ip6mr_cache_unresolved(mifi_t mifi, struct sk_buff *skb) | |||
| 925 | * MFC6 cache manipulation by user space | 939 | * MFC6 cache manipulation by user space |
| 926 | */ | 940 | */ |
| 927 | 941 | ||
| 928 | static int ip6mr_mfc_delete(struct mf6cctl *mfc) | 942 | static int ip6mr_mfc_delete(struct net *net, struct mf6cctl *mfc) |
| 929 | { | 943 | { |
| 930 | int line; | 944 | int line; |
| 931 | struct mfc6_cache *c, **cp; | 945 | struct mfc6_cache *c, **cp; |
| 932 | 946 | ||
| 933 | line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr); | 947 | line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr); |
| 934 | 948 | ||
| 935 | for (cp = &init_net.ipv6.mfc6_cache_array[line]; | 949 | for (cp = &net->ipv6.mfc6_cache_array[line]; |
| 936 | (c = *cp) != NULL; cp = &c->next) { | 950 | (c = *cp) != NULL; cp = &c->next) { |
| 937 | if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) && | 951 | if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) && |
| 938 | ipv6_addr_equal(&c->mf6c_mcastgrp, &mfc->mf6cc_mcastgrp.sin6_addr)) { | 952 | 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 | unsigned long event, void *ptr) | 965 | unsigned long event, void *ptr) |
| 952 | { | 966 | { |
| 953 | struct net_device *dev = ptr; | 967 | struct net_device *dev = ptr; |
| 968 | struct net *net = dev_net(dev); | ||
| 954 | struct mif_device *v; | 969 | struct mif_device *v; |
| 955 | int ct; | 970 | int ct; |
| 956 | 971 | ||
| 957 | if (!net_eq(dev_net(dev), &init_net)) | ||
| 958 | return NOTIFY_DONE; | ||
| 959 | |||
| 960 | if (event != NETDEV_UNREGISTER) | 972 | if (event != NETDEV_UNREGISTER) |
| 961 | return NOTIFY_DONE; | 973 | return NOTIFY_DONE; |
| 962 | 974 | ||
| 963 | v = &init_net.ipv6.vif6_table[0]; | 975 | v = &net->ipv6.vif6_table[0]; |
| 964 | for (ct = 0; ct < init_net.ipv6.maxvif; ct++, v++) { | 976 | for (ct = 0; ct < net->ipv6.maxvif; ct++, v++) { |
| 965 | if (v->dev == dev) | 977 | if (v->dev == dev) |
| 966 | mif6_delete(ct); | 978 | mif6_delete(net, ct); |
| 967 | } | 979 | } |
| 968 | return NOTIFY_DONE; | 980 | return NOTIFY_DONE; |
| 969 | } | 981 | } |
| @@ -1026,6 +1038,7 @@ static void __net_exit ip6mr_net_exit(struct net *net) | |||
| 1026 | proc_net_remove(net, "ip6_mr_cache"); | 1038 | proc_net_remove(net, "ip6_mr_cache"); |
| 1027 | proc_net_remove(net, "ip6_mr_vif"); | 1039 | proc_net_remove(net, "ip6_mr_vif"); |
| 1028 | #endif | 1040 | #endif |
| 1041 | mroute_clean_tables(net); | ||
| 1029 | kfree(net->ipv6.mfc6_cache_array); | 1042 | kfree(net->ipv6.mfc6_cache_array); |
| 1030 | kfree(net->ipv6.vif6_table); | 1043 | kfree(net->ipv6.vif6_table); |
| 1031 | } | 1044 | } |
| @@ -1071,7 +1084,7 @@ void ip6_mr_cleanup(void) | |||
| 1071 | kmem_cache_destroy(mrt_cachep); | 1084 | kmem_cache_destroy(mrt_cachep); |
| 1072 | } | 1085 | } |
| 1073 | 1086 | ||
| 1074 | static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) | 1087 | static int ip6mr_mfc_add(struct net *net, struct mf6cctl *mfc, int mrtsock) |
| 1075 | { | 1088 | { |
| 1076 | int line; | 1089 | int line; |
| 1077 | struct mfc6_cache *uc, *c, **cp; | 1090 | struct mfc6_cache *uc, *c, **cp; |
| @@ -1087,7 +1100,7 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) | |||
| 1087 | 1100 | ||
| 1088 | line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr); | 1101 | line = MFC6_HASH(&mfc->mf6cc_mcastgrp.sin6_addr, &mfc->mf6cc_origin.sin6_addr); |
| 1089 | 1102 | ||
| 1090 | for (cp = &init_net.ipv6.mfc6_cache_array[line]; | 1103 | for (cp = &net->ipv6.mfc6_cache_array[line]; |
| 1091 | (c = *cp) != NULL; cp = &c->next) { | 1104 | (c = *cp) != NULL; cp = &c->next) { |
| 1092 | if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) && | 1105 | if (ipv6_addr_equal(&c->mf6c_origin, &mfc->mf6cc_origin.sin6_addr) && |
| 1093 | ipv6_addr_equal(&c->mf6c_mcastgrp, &mfc->mf6cc_mcastgrp.sin6_addr)) | 1106 | 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 | if (!ipv6_addr_is_multicast(&mfc->mf6cc_mcastgrp.sin6_addr)) | 1120 | if (!ipv6_addr_is_multicast(&mfc->mf6cc_mcastgrp.sin6_addr)) |
| 1108 | return -EINVAL; | 1121 | return -EINVAL; |
| 1109 | 1122 | ||
| 1110 | c = ip6mr_cache_alloc(&init_net); | 1123 | c = ip6mr_cache_alloc(net); |
| 1111 | if (c == NULL) | 1124 | if (c == NULL) |
| 1112 | return -ENOMEM; | 1125 | return -ENOMEM; |
| 1113 | 1126 | ||
| @@ -1119,8 +1132,8 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) | |||
| 1119 | c->mfc_flags |= MFC_STATIC; | 1132 | c->mfc_flags |= MFC_STATIC; |
| 1120 | 1133 | ||
| 1121 | write_lock_bh(&mrt_lock); | 1134 | write_lock_bh(&mrt_lock); |
| 1122 | c->next = init_net.ipv6.mfc6_cache_array[line]; | 1135 | c->next = net->ipv6.mfc6_cache_array[line]; |
| 1123 | init_net.ipv6.mfc6_cache_array[line] = c; | 1136 | net->ipv6.mfc6_cache_array[line] = c; |
| 1124 | write_unlock_bh(&mrt_lock); | 1137 | write_unlock_bh(&mrt_lock); |
| 1125 | 1138 | ||
| 1126 | /* | 1139 | /* |
| @@ -1130,11 +1143,11 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) | |||
| 1130 | spin_lock_bh(&mfc_unres_lock); | 1143 | spin_lock_bh(&mfc_unres_lock); |
| 1131 | for (cp = &mfc_unres_queue; (uc = *cp) != NULL; | 1144 | for (cp = &mfc_unres_queue; (uc = *cp) != NULL; |
| 1132 | cp = &uc->next) { | 1145 | cp = &uc->next) { |
| 1133 | if (net_eq(mfc6_net(uc), &init_net) && | 1146 | if (net_eq(mfc6_net(uc), net) && |
| 1134 | ipv6_addr_equal(&uc->mf6c_origin, &c->mf6c_origin) && | 1147 | ipv6_addr_equal(&uc->mf6c_origin, &c->mf6c_origin) && |
| 1135 | ipv6_addr_equal(&uc->mf6c_mcastgrp, &c->mf6c_mcastgrp)) { | 1148 | ipv6_addr_equal(&uc->mf6c_mcastgrp, &c->mf6c_mcastgrp)) { |
| 1136 | *cp = uc->next; | 1149 | *cp = uc->next; |
| 1137 | atomic_dec(&init_net.ipv6.cache_resolve_queue_len); | 1150 | atomic_dec(&net->ipv6.cache_resolve_queue_len); |
| 1138 | break; | 1151 | break; |
| 1139 | } | 1152 | } |
| 1140 | } | 1153 | } |
| @@ -1153,16 +1166,16 @@ static int ip6mr_mfc_add(struct mf6cctl *mfc, int mrtsock) | |||
| 1153 | * Close the multicast socket, and clear the vif tables etc | 1166 | * Close the multicast socket, and clear the vif tables etc |
| 1154 | */ | 1167 | */ |
| 1155 | 1168 | ||
| 1156 | static void mroute_clean_tables(struct sock *sk) | 1169 | static void mroute_clean_tables(struct net *net) |
| 1157 | { | 1170 | { |
| 1158 | int i; | 1171 | int i; |
| 1159 | 1172 | ||
| 1160 | /* | 1173 | /* |
| 1161 | * Shut down all active vif entries | 1174 | * Shut down all active vif entries |
| 1162 | */ | 1175 | */ |
| 1163 | for (i = 0; i < init_net.ipv6.maxvif; i++) { | 1176 | for (i = 0; i < net->ipv6.maxvif; i++) { |
| 1164 | if (!(init_net.ipv6.vif6_table[i].flags & VIFF_STATIC)) | 1177 | if (!(net->ipv6.vif6_table[i].flags & VIFF_STATIC)) |
| 1165 | mif6_delete(i); | 1178 | mif6_delete(net, i); |
| 1166 | } | 1179 | } |
| 1167 | 1180 | ||
| 1168 | /* | 1181 | /* |
| @@ -1171,7 +1184,7 @@ static void mroute_clean_tables(struct sock *sk) | |||
| 1171 | for (i = 0; i < MFC6_LINES; i++) { | 1184 | for (i = 0; i < MFC6_LINES; i++) { |
| 1172 | struct mfc6_cache *c, **cp; | 1185 | struct mfc6_cache *c, **cp; |
| 1173 | 1186 | ||
| 1174 | cp = &init_net.ipv6.mfc6_cache_array[i]; | 1187 | cp = &net->ipv6.mfc6_cache_array[i]; |
| 1175 | while ((c = *cp) != NULL) { | 1188 | while ((c = *cp) != NULL) { |
| 1176 | if (c->mfc_flags & MFC_STATIC) { | 1189 | if (c->mfc_flags & MFC_STATIC) { |
| 1177 | cp = &c->next; | 1190 | cp = &c->next; |
| @@ -1185,13 +1198,13 @@ static void mroute_clean_tables(struct sock *sk) | |||
| 1185 | } | 1198 | } |
| 1186 | } | 1199 | } |
| 1187 | 1200 | ||
| 1188 | if (atomic_read(&init_net.ipv6.cache_resolve_queue_len) != 0) { | 1201 | if (atomic_read(&net->ipv6.cache_resolve_queue_len) != 0) { |
| 1189 | struct mfc6_cache *c, **cp; | 1202 | struct mfc6_cache *c, **cp; |
| 1190 | 1203 | ||
| 1191 | spin_lock_bh(&mfc_unres_lock); | 1204 | spin_lock_bh(&mfc_unres_lock); |
| 1192 | cp = &mfc_unres_queue; | 1205 | cp = &mfc_unres_queue; |
| 1193 | while ((c = *cp) != NULL) { | 1206 | while ((c = *cp) != NULL) { |
| 1194 | if (!net_eq(mfc6_net(c), &init_net)) { | 1207 | if (!net_eq(mfc6_net(c), net)) { |
| 1195 | cp = &c->next; | 1208 | cp = &c->next; |
| 1196 | continue; | 1209 | continue; |
| 1197 | } | 1210 | } |
| @@ -1205,11 +1218,12 @@ static void mroute_clean_tables(struct sock *sk) | |||
| 1205 | static int ip6mr_sk_init(struct sock *sk) | 1218 | static int ip6mr_sk_init(struct sock *sk) |
| 1206 | { | 1219 | { |
| 1207 | int err = 0; | 1220 | int err = 0; |
| 1221 | struct net *net = sock_net(sk); | ||
| 1208 | 1222 | ||
| 1209 | rtnl_lock(); | 1223 | rtnl_lock(); |
| 1210 | write_lock_bh(&mrt_lock); | 1224 | write_lock_bh(&mrt_lock); |
| 1211 | if (likely(init_net.ipv6.mroute6_sk == NULL)) | 1225 | if (likely(net->ipv6.mroute6_sk == NULL)) |
| 1212 | init_net.ipv6.mroute6_sk = sk; | 1226 | net->ipv6.mroute6_sk = sk; |
| 1213 | else | 1227 | else |
| 1214 | err = -EADDRINUSE; | 1228 | err = -EADDRINUSE; |
| 1215 | write_unlock_bh(&mrt_lock); | 1229 | write_unlock_bh(&mrt_lock); |
| @@ -1222,14 +1236,15 @@ static int ip6mr_sk_init(struct sock *sk) | |||
| 1222 | int ip6mr_sk_done(struct sock *sk) | 1236 | int ip6mr_sk_done(struct sock *sk) |
| 1223 | { | 1237 | { |
| 1224 | int err = 0; | 1238 | int err = 0; |
| 1239 | struct net *net = sock_net(sk); | ||
| 1225 | 1240 | ||
| 1226 | rtnl_lock(); | 1241 | rtnl_lock(); |
| 1227 | if (sk == init_net.ipv6.mroute6_sk) { | 1242 | if (sk == net->ipv6.mroute6_sk) { |
| 1228 | write_lock_bh(&mrt_lock); | 1243 | write_lock_bh(&mrt_lock); |
| 1229 | init_net.ipv6.mroute6_sk = NULL; | 1244 | net->ipv6.mroute6_sk = NULL; |
| 1230 | write_unlock_bh(&mrt_lock); | 1245 | write_unlock_bh(&mrt_lock); |
| 1231 | 1246 | ||
| 1232 | mroute_clean_tables(sk); | 1247 | mroute_clean_tables(net); |
| 1233 | } else | 1248 | } else |
| 1234 | err = -EACCES; | 1249 | err = -EACCES; |
| 1235 | rtnl_unlock(); | 1250 | rtnl_unlock(); |
| @@ -1250,9 +1265,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int | |||
| 1250 | struct mif6ctl vif; | 1265 | struct mif6ctl vif; |
| 1251 | struct mf6cctl mfc; | 1266 | struct mf6cctl mfc; |
| 1252 | mifi_t mifi; | 1267 | mifi_t mifi; |
| 1268 | struct net *net = sock_net(sk); | ||
| 1253 | 1269 | ||
| 1254 | if (optname != MRT6_INIT) { | 1270 | if (optname != MRT6_INIT) { |
| 1255 | if (sk != init_net.ipv6.mroute6_sk && !capable(CAP_NET_ADMIN)) | 1271 | if (sk != net->ipv6.mroute6_sk && !capable(CAP_NET_ADMIN)) |
| 1256 | return -EACCES; | 1272 | return -EACCES; |
| 1257 | } | 1273 | } |
| 1258 | 1274 | ||
| @@ -1277,7 +1293,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int | |||
| 1277 | if (vif.mif6c_mifi >= MAXMIFS) | 1293 | if (vif.mif6c_mifi >= MAXMIFS) |
| 1278 | return -ENFILE; | 1294 | return -ENFILE; |
| 1279 | rtnl_lock(); | 1295 | rtnl_lock(); |
| 1280 | ret = mif6_add(&vif, sk == init_net.ipv6.mroute6_sk); | 1296 | ret = mif6_add(net, &vif, sk == net->ipv6.mroute6_sk); |
| 1281 | rtnl_unlock(); | 1297 | rtnl_unlock(); |
| 1282 | return ret; | 1298 | return ret; |
| 1283 | 1299 | ||
| @@ -1287,7 +1303,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int | |||
| 1287 | if (copy_from_user(&mifi, optval, sizeof(mifi_t))) | 1303 | if (copy_from_user(&mifi, optval, sizeof(mifi_t))) |
| 1288 | return -EFAULT; | 1304 | return -EFAULT; |
| 1289 | rtnl_lock(); | 1305 | rtnl_lock(); |
| 1290 | ret = mif6_delete(mifi); | 1306 | ret = mif6_delete(net, mifi); |
| 1291 | rtnl_unlock(); | 1307 | rtnl_unlock(); |
| 1292 | return ret; | 1308 | return ret; |
| 1293 | 1309 | ||
| @@ -1303,9 +1319,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int | |||
| 1303 | return -EFAULT; | 1319 | return -EFAULT; |
| 1304 | rtnl_lock(); | 1320 | rtnl_lock(); |
| 1305 | if (optname == MRT6_DEL_MFC) | 1321 | if (optname == MRT6_DEL_MFC) |
| 1306 | ret = ip6mr_mfc_delete(&mfc); | 1322 | ret = ip6mr_mfc_delete(net, &mfc); |
| 1307 | else | 1323 | else |
| 1308 | ret = ip6mr_mfc_add(&mfc, sk == init_net.ipv6.mroute6_sk); | 1324 | ret = ip6mr_mfc_add(net, &mfc, |
| 1325 | sk == net->ipv6.mroute6_sk); | ||
| 1309 | rtnl_unlock(); | 1326 | rtnl_unlock(); |
| 1310 | return ret; | 1327 | return ret; |
| 1311 | 1328 | ||
| @@ -1317,7 +1334,7 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int | |||
| 1317 | int v; | 1334 | int v; |
| 1318 | if (get_user(v, (int __user *)optval)) | 1335 | if (get_user(v, (int __user *)optval)) |
| 1319 | return -EFAULT; | 1336 | return -EFAULT; |
| 1320 | init_net.ipv6.mroute_do_assert = !!v; | 1337 | net->ipv6.mroute_do_assert = !!v; |
| 1321 | return 0; | 1338 | return 0; |
| 1322 | } | 1339 | } |
| 1323 | 1340 | ||
| @@ -1330,10 +1347,10 @@ int ip6_mroute_setsockopt(struct sock *sk, int optname, char __user *optval, int | |||
| 1330 | v = !!v; | 1347 | v = !!v; |
| 1331 | rtnl_lock(); | 1348 | rtnl_lock(); |
| 1332 | ret = 0; | 1349 | ret = 0; |
| 1333 | if (v != init_net.ipv6.mroute_do_pim) { | 1350 | if (v != net->ipv6.mroute_do_pim) { |
| 1334 | init_net.ipv6.mroute_do_pim = v; | 1351 | net->ipv6.mroute_do_pim = v; |
| 1335 | init_net.ipv6.mroute_do_assert = v; | 1352 | net->ipv6.mroute_do_assert = v; |
| 1336 | if (init_net.ipv6.mroute_do_pim) | 1353 | if (net->ipv6.mroute_do_pim) |
| 1337 | ret = inet6_add_protocol(&pim6_protocol, | 1354 | ret = inet6_add_protocol(&pim6_protocol, |
| 1338 | IPPROTO_PIM); | 1355 | IPPROTO_PIM); |
| 1339 | else | 1356 | else |
| @@ -1365,6 +1382,7 @@ int ip6_mroute_getsockopt(struct sock *sk, int optname, char __user *optval, | |||
| 1365 | { | 1382 | { |
| 1366 | int olr; | 1383 | int olr; |
| 1367 | int val; | 1384 | int val; |
| 1385 | struct net *net = sock_net(sk); | ||
| 1368 | 1386 | ||
| 1369 | switch (optname) { | 1387 | switch (optname) { |
| 1370 | case MRT6_VERSION: | 1388 | case MRT6_VERSION: |
| @@ -1372,11 +1390,11 @@ int ip6_mroute_getsockopt(struct sock *sk, int optname, char __user *optval, | |||
| 1372 | break; | 1390 | break; |
| 1373 | #ifdef CONFIG_IPV6_PIMSM_V2 | 1391 | #ifdef CONFIG_IPV6_PIMSM_V2 |
| 1374 | case MRT6_PIM: | 1392 | case MRT6_PIM: |
| 1375 | val = init_net.ipv6.mroute_do_pim; | 1393 | val = net->ipv6.mroute_do_pim; |
| 1376 | break; | 1394 | break; |
| 1377 | #endif | 1395 | #endif |
| 1378 | case MRT6_ASSERT: | 1396 | case MRT6_ASSERT: |
| 1379 | val = init_net.ipv6.mroute_do_assert; | 1397 | val = net->ipv6.mroute_do_assert; |
| 1380 | break; | 1398 | break; |
| 1381 | default: | 1399 | default: |
| 1382 | return -ENOPROTOOPT; | 1400 | return -ENOPROTOOPT; |
| @@ -1406,16 +1424,17 @@ int ip6mr_ioctl(struct sock *sk, int cmd, void __user *arg) | |||
| 1406 | struct sioc_mif_req6 vr; | 1424 | struct sioc_mif_req6 vr; |
| 1407 | struct mif_device *vif; | 1425 | struct mif_device *vif; |
| 1408 | struct mfc6_cache *c; | 1426 | struct mfc6_cache *c; |
| 1427 | struct net *net = sock_net(sk); | ||
| 1409 | 1428 | ||
| 1410 | switch (cmd) { | 1429 | switch (cmd) { |
| 1411 | case SIOCGETMIFCNT_IN6: | 1430 | case SIOCGETMIFCNT_IN6: |
| 1412 | if (copy_from_user(&vr, arg, sizeof(vr))) | 1431 | if (copy_from_user(&vr, arg, sizeof(vr))) |
| 1413 | return -EFAULT; | 1432 | return -EFAULT; |
| 1414 | if (vr.mifi >= init_net.ipv6.maxvif) | 1433 | if (vr.mifi >= net->ipv6.maxvif) |
| 1415 | return -EINVAL; | 1434 | return -EINVAL; |
| 1416 | read_lock(&mrt_lock); | 1435 | read_lock(&mrt_lock); |
| 1417 | vif = &init_net.ipv6.vif6_table[vr.mifi]; | 1436 | vif = &net->ipv6.vif6_table[vr.mifi]; |
| 1418 | if (MIF_EXISTS(&init_net, vr.mifi)) { | 1437 | if (MIF_EXISTS(net, vr.mifi)) { |
| 1419 | vr.icount = vif->pkt_in; | 1438 | vr.icount = vif->pkt_in; |
| 1420 | vr.ocount = vif->pkt_out; | 1439 | vr.ocount = vif->pkt_out; |
| 1421 | vr.ibytes = vif->bytes_in; | 1440 | vr.ibytes = vif->bytes_in; |
| @@ -1433,7 +1452,7 @@ int ip6mr_ioctl(struct sock *sk, int cmd, void __user *arg) | |||
| 1433 | return -EFAULT; | 1452 | return -EFAULT; |
| 1434 | 1453 | ||
| 1435 | read_lock(&mrt_lock); | 1454 | read_lock(&mrt_lock); |
| 1436 | c = ip6mr_cache_find(&sr.src.sin6_addr, &sr.grp.sin6_addr); | 1455 | c = ip6mr_cache_find(net, &sr.src.sin6_addr, &sr.grp.sin6_addr); |
| 1437 | if (c) { | 1456 | if (c) { |
| 1438 | sr.pktcnt = c->mfc_un.res.pkt; | 1457 | sr.pktcnt = c->mfc_un.res.pkt; |
| 1439 | sr.bytecnt = c->mfc_un.res.bytes; | 1458 | sr.bytecnt = c->mfc_un.res.bytes; |
| @@ -1466,7 +1485,8 @@ static inline int ip6mr_forward2_finish(struct sk_buff *skb) | |||
| 1466 | static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) | 1485 | static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) |
| 1467 | { | 1486 | { |
| 1468 | struct ipv6hdr *ipv6h; | 1487 | struct ipv6hdr *ipv6h; |
| 1469 | struct mif_device *vif = &init_net.ipv6.vif6_table[vifi]; | 1488 | struct net *net = mfc6_net(c); |
| 1489 | struct mif_device *vif = &net->ipv6.vif6_table[vifi]; | ||
| 1470 | struct net_device *dev; | 1490 | struct net_device *dev; |
| 1471 | struct dst_entry *dst; | 1491 | struct dst_entry *dst; |
| 1472 | struct flowi fl; | 1492 | struct flowi fl; |
| @@ -1480,7 +1500,7 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) | |||
| 1480 | vif->bytes_out += skb->len; | 1500 | vif->bytes_out += skb->len; |
| 1481 | vif->dev->stats.tx_bytes += skb->len; | 1501 | vif->dev->stats.tx_bytes += skb->len; |
| 1482 | vif->dev->stats.tx_packets++; | 1502 | vif->dev->stats.tx_packets++; |
| 1483 | ip6mr_cache_report(skb, vifi, MRT6MSG_WHOLEPKT); | 1503 | ip6mr_cache_report(net, skb, vifi, MRT6MSG_WHOLEPKT); |
| 1484 | kfree_skb(skb); | 1504 | kfree_skb(skb); |
| 1485 | return 0; | 1505 | return 0; |
| 1486 | } | 1506 | } |
| @@ -1495,7 +1515,7 @@ static int ip6mr_forward2(struct sk_buff *skb, struct mfc6_cache *c, int vifi) | |||
| 1495 | } | 1515 | } |
| 1496 | }; | 1516 | }; |
| 1497 | 1517 | ||
| 1498 | dst = ip6_route_output(&init_net, NULL, &fl); | 1518 | dst = ip6_route_output(net, NULL, &fl); |
| 1499 | if (!dst) | 1519 | if (!dst) |
| 1500 | goto out_free; | 1520 | goto out_free; |
| 1501 | 1521 | ||
| @@ -1538,9 +1558,10 @@ out_free: | |||
| 1538 | 1558 | ||
| 1539 | static int ip6mr_find_vif(struct net_device *dev) | 1559 | static int ip6mr_find_vif(struct net_device *dev) |
| 1540 | { | 1560 | { |
| 1561 | struct net *net = dev_net(dev); | ||
| 1541 | int ct; | 1562 | int ct; |
| 1542 | for (ct = init_net.ipv6.maxvif - 1; ct >= 0; ct--) { | 1563 | for (ct = net->ipv6.maxvif - 1; ct >= 0; ct--) { |
| 1543 | if (init_net.ipv6.vif6_table[ct].dev == dev) | 1564 | if (net->ipv6.vif6_table[ct].dev == dev) |
| 1544 | break; | 1565 | break; |
| 1545 | } | 1566 | } |
| 1546 | return ct; | 1567 | return ct; |
| @@ -1550,6 +1571,7 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache) | |||
| 1550 | { | 1571 | { |
| 1551 | int psend = -1; | 1572 | int psend = -1; |
| 1552 | int vif, ct; | 1573 | int vif, ct; |
| 1574 | struct net *net = mfc6_net(cache); | ||
| 1553 | 1575 | ||
| 1554 | vif = cache->mf6c_parent; | 1576 | vif = cache->mf6c_parent; |
| 1555 | cache->mfc_un.res.pkt++; | 1577 | cache->mfc_un.res.pkt++; |
| @@ -1558,30 +1580,30 @@ static int ip6_mr_forward(struct sk_buff *skb, struct mfc6_cache *cache) | |||
| 1558 | /* | 1580 | /* |
| 1559 | * Wrong interface: drop packet and (maybe) send PIM assert. | 1581 | * Wrong interface: drop packet and (maybe) send PIM assert. |
| 1560 | */ | 1582 | */ |
| 1561 | if (init_net.ipv6.vif6_table[vif].dev != skb->dev) { | 1583 | if (net->ipv6.vif6_table[vif].dev != skb->dev) { |
| 1562 | int true_vifi; | 1584 | int true_vifi; |
| 1563 | 1585 | ||
| 1564 | cache->mfc_un.res.wrong_if++; | 1586 | cache->mfc_un.res.wrong_if++; |
| 1565 | true_vifi = ip6mr_find_vif(skb->dev); | 1587 | true_vifi = ip6mr_find_vif(skb->dev); |
| 1566 | 1588 | ||
| 1567 | if (true_vifi >= 0 && init_net.ipv6.mroute_do_assert && | 1589 | if (true_vifi >= 0 && net->ipv6.mroute_do_assert && |
| 1568 | /* pimsm uses asserts, when switching from RPT to SPT, | 1590 | /* pimsm uses asserts, when switching from RPT to SPT, |
| 1569 | so that we cannot check that packet arrived on an oif. | 1591 | so that we cannot check that packet arrived on an oif. |
| 1570 | It is bad, but otherwise we would need to move pretty | 1592 | It is bad, but otherwise we would need to move pretty |
| 1571 | large chunk of pimd to kernel. Ough... --ANK | 1593 | large chunk of pimd to kernel. Ough... --ANK |
| 1572 | */ | 1594 | */ |
| 1573 | (init_net.ipv6.mroute_do_pim || | 1595 | (net->ipv6.mroute_do_pim || |
| 1574 | cache->mfc_un.res.ttls[true_vifi] < 255) && | 1596 | cache->mfc_un.res.ttls[true_vifi] < 255) && |
| 1575 | time_after(jiffies, | 1597 | time_after(jiffies, |
| 1576 | cache->mfc_un.res.last_assert + MFC_ASSERT_THRESH)) { | 1598 | cache->mfc_un.res.last_assert + MFC_ASSERT_THRESH)) { |
| 1577 | cache->mfc_un.res.last_assert = jiffies; | 1599 | cache->mfc_un.res.last_assert = jiffies; |
| 1578 | ip6mr_cache_report(skb, true_vifi, MRT6MSG_WRONGMIF); | 1600 | ip6mr_cache_report(net, skb, true_vifi, MRT6MSG_WRONGMIF); |
| 1579 | } | 1601 | } |
| 1580 | goto dont_forward; | 1602 | goto dont_forward; |
| 1581 | } | 1603 | } |
| 1582 | 1604 | ||
| 1583 | init_net.ipv6.vif6_table[vif].pkt_in++; | 1605 | net->ipv6.vif6_table[vif].pkt_in++; |
| 1584 | init_net.ipv6.vif6_table[vif].bytes_in += skb->len; | 1606 | net->ipv6.vif6_table[vif].bytes_in += skb->len; |
| 1585 | 1607 | ||
| 1586 | /* | 1608 | /* |
| 1587 | * Forward the frame | 1609 | * Forward the frame |
| @@ -1614,9 +1636,11 @@ dont_forward: | |||
| 1614 | int ip6_mr_input(struct sk_buff *skb) | 1636 | int ip6_mr_input(struct sk_buff *skb) |
| 1615 | { | 1637 | { |
| 1616 | struct mfc6_cache *cache; | 1638 | struct mfc6_cache *cache; |
| 1639 | struct net *net = dev_net(skb->dev); | ||
| 1617 | 1640 | ||
| 1618 | read_lock(&mrt_lock); | 1641 | read_lock(&mrt_lock); |
| 1619 | cache = ip6mr_cache_find(&ipv6_hdr(skb)->saddr, &ipv6_hdr(skb)->daddr); | 1642 | cache = ip6mr_cache_find(net, |
| 1643 | &ipv6_hdr(skb)->saddr, &ipv6_hdr(skb)->daddr); | ||
| 1620 | 1644 | ||
| 1621 | /* | 1645 | /* |
| 1622 | * No usable cache entry | 1646 | * No usable cache entry |
| @@ -1626,7 +1650,7 @@ int ip6_mr_input(struct sk_buff *skb) | |||
| 1626 | 1650 | ||
| 1627 | vif = ip6mr_find_vif(skb->dev); | 1651 | vif = ip6mr_find_vif(skb->dev); |
| 1628 | if (vif >= 0) { | 1652 | if (vif >= 0) { |
| 1629 | int err = ip6mr_cache_unresolved(vif, skb); | 1653 | int err = ip6mr_cache_unresolved(net, vif, skb); |
| 1630 | read_unlock(&mrt_lock); | 1654 | read_unlock(&mrt_lock); |
| 1631 | 1655 | ||
| 1632 | return err; | 1656 | return err; |
| @@ -1649,7 +1673,8 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm) | |||
| 1649 | { | 1673 | { |
| 1650 | int ct; | 1674 | int ct; |
| 1651 | struct rtnexthop *nhp; | 1675 | struct rtnexthop *nhp; |
| 1652 | struct net_device *dev = init_net.ipv6.vif6_table[c->mf6c_parent].dev; | 1676 | struct net *net = mfc6_net(c); |
| 1677 | struct net_device *dev = net->ipv6.vif6_table[c->mf6c_parent].dev; | ||
| 1653 | u8 *b = skb_tail_pointer(skb); | 1678 | u8 *b = skb_tail_pointer(skb); |
| 1654 | struct rtattr *mp_head; | 1679 | struct rtattr *mp_head; |
| 1655 | 1680 | ||
| @@ -1665,7 +1690,7 @@ ip6mr_fill_mroute(struct sk_buff *skb, struct mfc6_cache *c, struct rtmsg *rtm) | |||
| 1665 | nhp = (struct rtnexthop *)skb_put(skb, RTA_ALIGN(sizeof(*nhp))); | 1690 | nhp = (struct rtnexthop *)skb_put(skb, RTA_ALIGN(sizeof(*nhp))); |
| 1666 | nhp->rtnh_flags = 0; | 1691 | nhp->rtnh_flags = 0; |
| 1667 | nhp->rtnh_hops = c->mfc_un.res.ttls[ct]; | 1692 | nhp->rtnh_hops = c->mfc_un.res.ttls[ct]; |
| 1668 | nhp->rtnh_ifindex = init_net.ipv6.vif6_table[ct].dev->ifindex; | 1693 | nhp->rtnh_ifindex = net->ipv6.vif6_table[ct].dev->ifindex; |
| 1669 | nhp->rtnh_len = sizeof(*nhp); | 1694 | nhp->rtnh_len = sizeof(*nhp); |
| 1670 | } | 1695 | } |
| 1671 | } | 1696 | } |
| @@ -1679,14 +1704,15 @@ rtattr_failure: | |||
| 1679 | return -EMSGSIZE; | 1704 | return -EMSGSIZE; |
| 1680 | } | 1705 | } |
| 1681 | 1706 | ||
| 1682 | int ip6mr_get_route(struct sk_buff *skb, struct rtmsg *rtm, int nowait) | 1707 | int ip6mr_get_route(struct net *net, |
| 1708 | struct sk_buff *skb, struct rtmsg *rtm, int nowait) | ||
| 1683 | { | 1709 | { |
| 1684 | int err; | 1710 | int err; |
| 1685 | struct mfc6_cache *cache; | 1711 | struct mfc6_cache *cache; |
| 1686 | struct rt6_info *rt = (struct rt6_info *)skb->dst; | 1712 | struct rt6_info *rt = (struct rt6_info *)skb->dst; |
| 1687 | 1713 | ||
| 1688 | read_lock(&mrt_lock); | 1714 | read_lock(&mrt_lock); |
| 1689 | cache = ip6mr_cache_find(&rt->rt6i_src.addr, &rt->rt6i_dst.addr); | 1715 | cache = ip6mr_cache_find(net, &rt->rt6i_src.addr, &rt->rt6i_dst.addr); |
| 1690 | 1716 | ||
| 1691 | if (!cache) { | 1717 | if (!cache) { |
| 1692 | struct sk_buff *skb2; | 1718 | struct sk_buff *skb2; |
| @@ -1729,7 +1755,7 @@ int ip6mr_get_route(struct sk_buff *skb, struct rtmsg *rtm, int nowait) | |||
| 1729 | ipv6_addr_copy(&iph->saddr, &rt->rt6i_src.addr); | 1755 | ipv6_addr_copy(&iph->saddr, &rt->rt6i_src.addr); |
| 1730 | ipv6_addr_copy(&iph->daddr, &rt->rt6i_dst.addr); | 1756 | ipv6_addr_copy(&iph->daddr, &rt->rt6i_dst.addr); |
| 1731 | 1757 | ||
| 1732 | err = ip6mr_cache_unresolved(vif, skb2); | 1758 | err = ip6mr_cache_unresolved(net, vif, skb2); |
| 1733 | read_unlock(&mrt_lock); | 1759 | read_unlock(&mrt_lock); |
| 1734 | 1760 | ||
| 1735 | return err; | 1761 | return err; |
diff --git a/net/ipv6/route.c b/net/ipv6/route.c index 9da1ece466a2..18c486cf4987 100644 --- a/net/ipv6/route.c +++ b/net/ipv6/route.c | |||
| @@ -2194,7 +2194,7 @@ static int rt6_fill_node(struct net *net, | |||
| 2194 | if (iif) { | 2194 | if (iif) { |
| 2195 | #ifdef CONFIG_IPV6_MROUTE | 2195 | #ifdef CONFIG_IPV6_MROUTE |
| 2196 | if (ipv6_addr_is_multicast(&rt->rt6i_dst.addr)) { | 2196 | if (ipv6_addr_is_multicast(&rt->rt6i_dst.addr)) { |
| 2197 | int err = ip6mr_get_route(skb, rtm, nowait); | 2197 | int err = ip6mr_get_route(net, skb, rtm, nowait); |
| 2198 | if (err <= 0) { | 2198 | if (err <= 0) { |
| 2199 | if (!nowait) { | 2199 | if (!nowait) { |
| 2200 | if (err == 0) | 2200 | if (err == 0) |
