Commit | Line | Data |
---|---|---|
81ba6afd AB |
1 | /* Copyright 2011-2014 Autronica Fire and Security AS |
2 | * | |
3 | * This program is free software; you can redistribute it and/or modify it | |
4 | * under the terms of the GNU General Public License as published by the Free | |
5 | * Software Foundation; either version 2 of the License, or (at your option) | |
6 | * any later version. | |
7 | * | |
8 | * Author(s): | |
9 | * 2011-2014 Arvid Brodin, arvid.brodin@alten.se | |
10 | */ | |
11 | ||
12 | #include "hsr_slave.h" | |
13 | #include <linux/etherdevice.h> | |
51f3c605 | 14 | #include <linux/if_arp.h> |
d0d7b10b | 15 | #include <linux/if_vlan.h> |
81ba6afd | 16 | #include "hsr_main.h" |
51f3c605 | 17 | #include "hsr_device.h" |
f266a683 | 18 | #include "hsr_forward.h" |
81ba6afd AB |
19 | #include "hsr_framereg.h" |
20 | ||
21 | ||
f266a683 AB |
22 | static rx_handler_result_t hsr_handle_frame(struct sk_buff **pskb) |
23 | { | |
24 | struct sk_buff *skb = *pskb; | |
25 | struct hsr_port *port; | |
ee1c2797 | 26 | u16 protocol; |
f266a683 AB |
27 | |
28 | if (!skb_mac_header_was_set(skb)) { | |
29 | WARN_ONCE(1, "%s: skb invalid", __func__); | |
30 | return RX_HANDLER_PASS; | |
31 | } | |
32 | ||
33 | rcu_read_lock(); /* hsr->node_db, hsr->ports */ | |
34 | port = hsr_port_get_rcu(skb->dev); | |
35 | ||
36 | if (hsr_addr_is_self(port->hsr, eth_hdr(skb)->h_source)) { | |
37 | /* Directly kill frames sent by ourselves */ | |
38 | kfree_skb(skb); | |
39 | goto finish_consume; | |
40 | } | |
41 | ||
ee1c2797 PH |
42 | protocol = eth_hdr(skb)->h_proto; |
43 | if (protocol != htons(ETH_P_PRP) && protocol != htons(ETH_P_HSR)) | |
f266a683 AB |
44 | goto finish_pass; |
45 | ||
46 | skb_push(skb, ETH_HLEN); | |
47 | ||
48 | hsr_forward_skb(skb, port); | |
49 | ||
50 | finish_consume: | |
51 | rcu_read_unlock(); /* hsr->node_db, hsr->ports */ | |
52 | return RX_HANDLER_CONSUMED; | |
53 | ||
54 | finish_pass: | |
55 | rcu_read_unlock(); /* hsr->node_db, hsr->ports */ | |
56 | return RX_HANDLER_PASS; | |
57 | } | |
58 | ||
59 | bool hsr_port_exists(const struct net_device *dev) | |
60 | { | |
61 | return rcu_access_pointer(dev->rx_handler) == hsr_handle_frame; | |
62 | } | |
63 | ||
64 | ||
c5a75911 | 65 | static int hsr_check_dev_ok(struct net_device *dev) |
51f3c605 AB |
66 | { |
67 | /* Don't allow HSR on non-ethernet like devices */ | |
68 | if ((dev->flags & IFF_LOOPBACK) || (dev->type != ARPHRD_ETHER) || | |
69 | (dev->addr_len != ETH_ALEN)) { | |
70 | netdev_info(dev, "Cannot use loopback or non-ethernet device as HSR slave.\n"); | |
71 | return -EINVAL; | |
72 | } | |
73 | ||
74 | /* Don't allow enslaving hsr devices */ | |
75 | if (is_hsr_master(dev)) { | |
76 | netdev_info(dev, "Cannot create trees of HSR devices.\n"); | |
77 | return -EINVAL; | |
78 | } | |
79 | ||
c5a75911 | 80 | if (hsr_port_exists(dev)) { |
51f3c605 AB |
81 | netdev_info(dev, "This device is already a HSR slave.\n"); |
82 | return -EINVAL; | |
83 | } | |
84 | ||
d0d7b10b | 85 | if (is_vlan_dev(dev)) { |
51f3c605 AB |
86 | netdev_info(dev, "HSR on top of VLAN is not yet supported in this driver.\n"); |
87 | return -EINVAL; | |
88 | } | |
89 | ||
f266a683 AB |
90 | if (dev->priv_flags & IFF_DONT_BRIDGE) { |
91 | netdev_info(dev, "This device does not support bridging.\n"); | |
92 | return -EOPNOTSUPP; | |
93 | } | |
94 | ||
51f3c605 AB |
95 | /* HSR over bonded devices has not been tested, but I'm not sure it |
96 | * won't work... | |
97 | */ | |
98 | ||
99 | return 0; | |
100 | } | |
101 | ||
102 | ||
c5a75911 AB |
103 | /* Setup device to be added to the HSR bridge. */ |
104 | static int hsr_portdev_setup(struct net_device *dev, struct hsr_port *port) | |
51f3c605 AB |
105 | { |
106 | int res; | |
107 | ||
108 | dev_hold(dev); | |
51f3c605 AB |
109 | res = dev_set_promiscuity(dev, 1); |
110 | if (res) | |
c5a75911 | 111 | goto fail_promiscuity; |
51f3c605 | 112 | |
c5a75911 AB |
113 | /* FIXME: |
114 | * What does net device "adjacency" mean? Should we do | |
115 | * res = netdev_master_upper_dev_link(port->dev, port->hsr->dev); ? | |
116 | */ | |
51f3c605 | 117 | |
f266a683 AB |
118 | res = netdev_rx_handler_register(dev, hsr_handle_frame, port); |
119 | if (res) | |
120 | goto fail_rx_handler; | |
121 | dev_disable_lro(dev); | |
122 | ||
51f3c605 AB |
123 | return 0; |
124 | ||
125 | fail_rx_handler: | |
126 | dev_set_promiscuity(dev, -1); | |
c5a75911 | 127 | fail_promiscuity: |
51f3c605 | 128 | dev_put(dev); |
c5a75911 | 129 | |
51f3c605 AB |
130 | return res; |
131 | } | |
132 | ||
c5a75911 AB |
133 | int hsr_add_port(struct hsr_priv *hsr, struct net_device *dev, |
134 | enum hsr_port_type type) | |
51f3c605 | 135 | { |
c5a75911 AB |
136 | struct hsr_port *port, *master; |
137 | int res; | |
51f3c605 | 138 | |
c5a75911 AB |
139 | if (type != HSR_PT_MASTER) { |
140 | res = hsr_check_dev_ok(dev); | |
141 | if (res) | |
142 | return res; | |
143 | } | |
144 | ||
145 | port = hsr_port_get_hsr(hsr, type); | |
146 | if (port != NULL) | |
147 | return -EBUSY; /* This port already exists */ | |
148 | ||
149 | port = kzalloc(sizeof(*port), GFP_KERNEL); | |
150 | if (port == NULL) | |
151 | return -ENOMEM; | |
152 | ||
153 | if (type != HSR_PT_MASTER) { | |
154 | res = hsr_portdev_setup(dev, port); | |
155 | if (res) | |
156 | goto fail_dev_setup; | |
157 | } | |
158 | ||
159 | port->hsr = hsr; | |
160 | port->dev = dev; | |
161 | port->type = type; | |
162 | ||
163 | list_add_tail_rcu(&port->port_list, &hsr->ports); | |
164 | synchronize_rcu(); | |
165 | ||
166 | master = hsr_port_get_hsr(hsr, HSR_PT_MASTER); | |
1cc1eb52 | 167 | netdev_update_features(master->dev); |
c5a75911 | 168 | dev_set_mtu(master->dev, hsr_get_max_mtu(hsr)); |
51f3c605 | 169 | |
c5a75911 AB |
170 | return 0; |
171 | ||
172 | fail_dev_setup: | |
173 | kfree(port); | |
174 | return res; | |
175 | } | |
176 | ||
177 | void hsr_del_port(struct hsr_port *port) | |
178 | { | |
179 | struct hsr_priv *hsr; | |
180 | struct hsr_port *master; | |
181 | ||
182 | hsr = port->hsr; | |
183 | master = hsr_port_get_hsr(hsr, HSR_PT_MASTER); | |
184 | list_del_rcu(&port->port_list); | |
185 | ||
186 | if (port != master) { | |
56b08fdc AB |
187 | if (master != NULL) { |
188 | netdev_update_features(master->dev); | |
189 | dev_set_mtu(master->dev, hsr_get_max_mtu(hsr)); | |
190 | } | |
c5a75911 AB |
191 | netdev_rx_handler_unregister(port->dev); |
192 | dev_set_promiscuity(port->dev, -1); | |
51f3c605 AB |
193 | } |
194 | ||
c5a75911 AB |
195 | /* FIXME? |
196 | * netdev_upper_dev_unlink(port->dev, port->hsr->dev); | |
197 | */ | |
198 | ||
51f3c605 | 199 | synchronize_rcu(); |
56b08fdc AB |
200 | |
201 | if (port != master) | |
202 | dev_put(port->dev); | |
51f3c605 | 203 | } |