br_input.c 3.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144
  1. /*
  2. * Handle incoming frames
  3. * Linux ethernet bridge
  4. *
  5. * Authors:
  6. * Lennert Buytenhek <buytenh@gnu.org>
  7. *
  8. * $Id: br_input.c,v 1.10 2001/12/24 04:50:20 davem Exp $
  9. *
  10. * This program is free software; you can redistribute it and/or
  11. * modify it under the terms of the GNU General Public License
  12. * as published by the Free Software Foundation; either version
  13. * 2 of the License, or (at your option) any later version.
  14. */
  15. #include <linux/kernel.h>
  16. #include <linux/netdevice.h>
  17. #include <linux/etherdevice.h>
  18. #include <linux/netfilter_bridge.h>
  19. #include "br_private.h"
  20. const unsigned char bridge_ula[6] = { 0x01, 0x80, 0xc2, 0x00, 0x00, 0x00 };
  21. static int br_pass_frame_up_finish(struct sk_buff *skb)
  22. {
  23. #ifdef CONFIG_NETFILTER_DEBUG
  24. skb->nf_debug = 0;
  25. #endif
  26. netif_rx(skb);
  27. return 0;
  28. }
  29. static void br_pass_frame_up(struct net_bridge *br, struct sk_buff *skb)
  30. {
  31. struct net_device *indev;
  32. br->statistics.rx_packets++;
  33. br->statistics.rx_bytes += skb->len;
  34. indev = skb->dev;
  35. skb->dev = br->dev;
  36. NF_HOOK(PF_BRIDGE, NF_BR_LOCAL_IN, skb, indev, NULL,
  37. br_pass_frame_up_finish);
  38. }
  39. /* note: already called with rcu_read_lock (preempt_disabled) */
  40. int br_handle_frame_finish(struct sk_buff *skb)
  41. {
  42. const unsigned char *dest = eth_hdr(skb)->h_dest;
  43. struct net_bridge_port *p = skb->dev->br_port;
  44. struct net_bridge *br = p->br;
  45. struct net_bridge_fdb_entry *dst;
  46. int passedup = 0;
  47. if (br->dev->flags & IFF_PROMISC) {
  48. struct sk_buff *skb2;
  49. skb2 = skb_clone(skb, GFP_ATOMIC);
  50. if (skb2 != NULL) {
  51. passedup = 1;
  52. br_pass_frame_up(br, skb2);
  53. }
  54. }
  55. if (dest[0] & 1) {
  56. br_flood_forward(br, skb, !passedup);
  57. if (!passedup)
  58. br_pass_frame_up(br, skb);
  59. goto out;
  60. }
  61. dst = __br_fdb_get(br, dest);
  62. if (dst != NULL && dst->is_local) {
  63. if (!passedup)
  64. br_pass_frame_up(br, skb);
  65. else
  66. kfree_skb(skb);
  67. goto out;
  68. }
  69. if (dst != NULL) {
  70. br_forward(dst->dst, skb);
  71. goto out;
  72. }
  73. br_flood_forward(br, skb, 0);
  74. out:
  75. return 0;
  76. }
  77. /*
  78. * Called via br_handle_frame_hook.
  79. * Return 0 if *pskb should be processed furthur
  80. * 1 if *pskb is handled
  81. * note: already called with rcu_read_lock (preempt_disabled)
  82. */
  83. int br_handle_frame(struct net_bridge_port *p, struct sk_buff **pskb)
  84. {
  85. struct sk_buff *skb = *pskb;
  86. const unsigned char *dest = eth_hdr(skb)->h_dest;
  87. if (p->state == BR_STATE_DISABLED)
  88. goto err;
  89. if (!is_valid_ether_addr(eth_hdr(skb)->h_source))
  90. goto err;
  91. if (p->state == BR_STATE_LEARNING ||
  92. p->state == BR_STATE_FORWARDING)
  93. br_fdb_update(p->br, p, eth_hdr(skb)->h_source);
  94. if (p->br->stp_enabled &&
  95. !memcmp(dest, bridge_ula, 5) &&
  96. !(dest[5] & 0xF0)) {
  97. if (!dest[5]) {
  98. NF_HOOK(PF_BRIDGE, NF_BR_LOCAL_IN, skb, skb->dev,
  99. NULL, br_stp_handle_bpdu);
  100. return 1;
  101. }
  102. }
  103. else if (p->state == BR_STATE_FORWARDING) {
  104. if (br_should_route_hook) {
  105. if (br_should_route_hook(pskb))
  106. return 0;
  107. skb = *pskb;
  108. dest = eth_hdr(skb)->h_dest;
  109. }
  110. if (!memcmp(p->br->dev->dev_addr, dest, ETH_ALEN))
  111. skb->pkt_type = PACKET_HOST;
  112. NF_HOOK(PF_BRIDGE, NF_BR_PRE_ROUTING, skb, skb->dev, NULL,
  113. br_handle_frame_finish);
  114. return 1;
  115. }
  116. err:
  117. kfree_skb(skb);
  118. return 1;
  119. }