Commit | Line | Data |
---|---|---|
0e7623bd | 1 | // SPDX-License-Identifier: GPL-2.0 |
70ebe4a4 | 2 | /* Copyright 2011-2014 Autronica Fire and Security AS |
f421436a AB |
3 | * |
4 | * Author(s): | |
70ebe4a4 | 5 | * 2011-2014 Arvid Brodin, arvid.brodin@alten.se |
f421436a | 6 | * This file contains device methods for creating, using and destroying |
8f4c0e01 | 7 | * virtual HSR or PRP devices. |
f421436a AB |
8 | */ |
9 | ||
10 | #include <linux/netdevice.h> | |
11 | #include <linux/skbuff.h> | |
12 | #include <linux/etherdevice.h> | |
f421436a AB |
13 | #include <linux/rtnetlink.h> |
14 | #include <linux/pkt_sched.h> | |
15 | #include "hsr_device.h" | |
81ba6afd | 16 | #include "hsr_slave.h" |
f421436a AB |
17 | #include "hsr_framereg.h" |
18 | #include "hsr_main.h" | |
f266a683 | 19 | #include "hsr_forward.h" |
f421436a | 20 | |
f421436a AB |
21 | static bool is_admin_up(struct net_device *dev) |
22 | { | |
23 | return dev && (dev->flags & IFF_UP); | |
24 | } | |
25 | ||
26 | static bool is_slave_up(struct net_device *dev) | |
27 | { | |
28 | return dev && is_admin_up(dev) && netif_oper_up(dev); | |
29 | } | |
30 | ||
c5a75911 | 31 | static void hsr_set_operstate(struct hsr_port *master, bool has_carrier) |
f421436a | 32 | { |
6a2968ee ED |
33 | struct net_device *dev = master->dev; |
34 | ||
35 | if (!is_admin_up(dev)) { | |
04efcee6 | 36 | netif_set_operstate(dev, IF_OPER_DOWN); |
f421436a AB |
37 | return; |
38 | } | |
39 | ||
e9aae56e | 40 | if (has_carrier) |
04efcee6 | 41 | netif_set_operstate(dev, IF_OPER_UP); |
f421436a | 42 | else |
04efcee6 | 43 | netif_set_operstate(dev, IF_OPER_LOWERLAYERDOWN); |
f421436a AB |
44 | } |
45 | ||
c5a75911 | 46 | static bool hsr_check_carrier(struct hsr_port *master) |
f421436a | 47 | { |
c5a75911 | 48 | struct hsr_port *port; |
e9aae56e | 49 | |
81390d0c | 50 | ASSERT_RTNL(); |
c5a75911 | 51 | |
81390d0c | 52 | hsr_for_each_port(master->hsr, port) { |
5670342c | 53 | if (port->type != HSR_PT_MASTER && is_slave_up(port->dev)) { |
81390d0c TY |
54 | netif_carrier_on(master->dev); |
55 | return true; | |
c5a75911 | 56 | } |
81390d0c | 57 | } |
e9aae56e | 58 | |
81390d0c | 59 | netif_carrier_off(master->dev); |
e9aae56e | 60 | |
81390d0c | 61 | return false; |
f421436a AB |
62 | } |
63 | ||
4893b8b3 | 64 | static void hsr_check_announce(struct net_device *hsr_dev) |
f421436a | 65 | { |
70ebe4a4 | 66 | struct hsr_priv *hsr; |
f421436a | 67 | |
70ebe4a4 | 68 | hsr = netdev_priv(hsr_dev); |
4893b8b3 LM |
69 | if (netif_running(hsr_dev) && netif_oper_up(hsr_dev)) { |
70 | /* Enable announce timer and start sending supervisory frames */ | |
71 | if (!timer_pending(&hsr->announce_timer)) { | |
72 | hsr->announce_count = 0; | |
73 | mod_timer(&hsr->announce_timer, jiffies + | |
74 | msecs_to_jiffies(HSR_ANNOUNCE_INTERVAL)); | |
75 | } | |
5f703ce5 LM |
76 | |
77 | if (hsr->redbox && !timer_pending(&hsr->announce_proxy_timer)) | |
78 | mod_timer(&hsr->announce_proxy_timer, jiffies + | |
79 | msecs_to_jiffies(HSR_ANNOUNCE_INTERVAL) / 2); | |
4893b8b3 LM |
80 | } else { |
81 | /* Deactivate the announce timer */ | |
82 | timer_delete(&hsr->announce_timer); | |
5f703ce5 LM |
83 | if (hsr->redbox) |
84 | timer_delete(&hsr->announce_proxy_timer); | |
f421436a | 85 | } |
f421436a AB |
86 | } |
87 | ||
e9aae56e AB |
88 | void hsr_check_carrier_and_operstate(struct hsr_priv *hsr) |
89 | { | |
c5a75911 | 90 | struct hsr_port *master; |
e9aae56e AB |
91 | bool has_carrier; |
92 | ||
c5a75911 | 93 | master = hsr_port_get_hsr(hsr, HSR_PT_MASTER); |
e9aae56e AB |
94 | /* netif_stacked_transfer_operstate() cannot be used here since |
95 | * it doesn't set IF_OPER_LOWERLAYERDOWN (?) | |
96 | */ | |
c5a75911 AB |
97 | has_carrier = hsr_check_carrier(master); |
98 | hsr_set_operstate(master, has_carrier); | |
4893b8b3 | 99 | hsr_check_announce(master->dev); |
e9aae56e AB |
100 | } |
101 | ||
70ebe4a4 | 102 | int hsr_get_max_mtu(struct hsr_priv *hsr) |
f421436a | 103 | { |
51f3c605 | 104 | unsigned int mtu_max; |
c5a75911 | 105 | struct hsr_port *port; |
51f3c605 AB |
106 | |
107 | mtu_max = ETH_DATA_LEN; | |
c5a75911 AB |
108 | hsr_for_each_port(hsr, port) |
109 | if (port->type != HSR_PT_MASTER) | |
110 | mtu_max = min(port->dev->mtu, mtu_max); | |
51f3c605 AB |
111 | |
112 | if (mtu_max < HSR_HLEN) | |
113 | return 0; | |
70ebe4a4 | 114 | return mtu_max - HSR_HLEN; |
f421436a AB |
115 | } |
116 | ||
117 | static int hsr_dev_change_mtu(struct net_device *dev, int new_mtu) | |
118 | { | |
70ebe4a4 | 119 | struct hsr_priv *hsr; |
f421436a | 120 | |
70ebe4a4 | 121 | hsr = netdev_priv(dev); |
f421436a | 122 | |
70ebe4a4 | 123 | if (new_mtu > hsr_get_max_mtu(hsr)) { |
f30e4720 | 124 | netdev_info(dev, "A HSR master's MTU cannot be greater than the smallest MTU of its slaves minus the HSR Tag length (%d octets).\n", |
70ebe4a4 | 125 | HSR_HLEN); |
f421436a AB |
126 | return -EINVAL; |
127 | } | |
128 | ||
1eb2cded | 129 | WRITE_ONCE(dev->mtu, new_mtu); |
f421436a AB |
130 | |
131 | return 0; | |
132 | } | |
133 | ||
134 | static int hsr_dev_open(struct net_device *dev) | |
135 | { | |
70ebe4a4 | 136 | struct hsr_priv *hsr; |
c5a75911 | 137 | struct hsr_port *port; |
10e52ad5 | 138 | const char *designation = NULL; |
f421436a | 139 | |
70ebe4a4 | 140 | hsr = netdev_priv(dev); |
f421436a | 141 | |
c5a75911 AB |
142 | hsr_for_each_port(hsr, port) { |
143 | if (port->type == HSR_PT_MASTER) | |
144 | continue; | |
145 | switch (port->type) { | |
146 | case HSR_PT_SLAVE_A: | |
10e52ad5 | 147 | designation = "Slave A"; |
c5a75911 AB |
148 | break; |
149 | case HSR_PT_SLAVE_B: | |
10e52ad5 | 150 | designation = "Slave B"; |
c5a75911 | 151 | break; |
5055cccf LM |
152 | case HSR_PT_INTERLINK: |
153 | designation = "Interlink"; | |
154 | break; | |
c5a75911 | 155 | default: |
10e52ad5 | 156 | designation = "Unknown"; |
c5a75911 AB |
157 | } |
158 | if (!is_slave_up(port->dev)) | |
10e52ad5 | 159 | netdev_warn(dev, "%s (%s) is not up; please bring it up to get a fully working HSR network\n", |
c5a75911 | 160 | designation, port->dev->name); |
f421436a | 161 | } |
c5a75911 | 162 | |
10e52ad5 | 163 | if (!designation) |
c5a75911 | 164 | netdev_warn(dev, "No slave devices configured\n"); |
f421436a AB |
165 | |
166 | return 0; | |
167 | } | |
168 | ||
169 | static int hsr_dev_close(struct net_device *dev) | |
170 | { | |
36b20fcd MK |
171 | struct hsr_port *port; |
172 | struct hsr_priv *hsr; | |
173 | ||
174 | hsr = netdev_priv(dev); | |
175 | hsr_for_each_port(hsr, port) { | |
176 | if (port->type == HSR_PT_MASTER) | |
177 | continue; | |
178 | switch (port->type) { | |
179 | case HSR_PT_SLAVE_A: | |
180 | case HSR_PT_SLAVE_B: | |
181 | dev_uc_unsync(port->dev, dev); | |
182 | dev_mc_unsync(port->dev, dev); | |
183 | break; | |
184 | default: | |
185 | break; | |
186 | } | |
187 | } | |
188 | ||
f421436a AB |
189 | return 0; |
190 | } | |
191 | ||
1cc1eb52 AB |
192 | static netdev_features_t hsr_features_recompute(struct hsr_priv *hsr, |
193 | netdev_features_t features) | |
194 | { | |
195 | netdev_features_t mask; | |
196 | struct hsr_port *port; | |
197 | ||
198 | mask = features; | |
199 | ||
200 | /* Mask out all features that, if supported by one device, should be | |
201 | * enabled for all devices (see NETIF_F_ONE_FOR_ALL). | |
202 | * | |
203 | * Anything that's off in mask will not be enabled - so only things | |
204 | * that were in features originally, and also is in NETIF_F_ONE_FOR_ALL, | |
205 | * may become enabled. | |
206 | */ | |
207 | features &= ~NETIF_F_ONE_FOR_ALL; | |
208 | hsr_for_each_port(hsr, port) | |
209 | features = netdev_increment_features(features, | |
210 | port->dev->features, | |
211 | mask); | |
212 | ||
213 | return features; | |
214 | } | |
215 | ||
216 | static netdev_features_t hsr_fix_features(struct net_device *dev, | |
217 | netdev_features_t features) | |
218 | { | |
219 | struct hsr_priv *hsr = netdev_priv(dev); | |
220 | ||
221 | return hsr_features_recompute(hsr, features); | |
222 | } | |
223 | ||
42deace2 | 224 | static netdev_tx_t hsr_dev_xmit(struct sk_buff *skb, struct net_device *dev) |
f421436a | 225 | { |
f266a683 | 226 | struct hsr_priv *hsr = netdev_priv(dev); |
c5a75911 | 227 | struct hsr_port *master; |
f421436a | 228 | |
c5a75911 | 229 | master = hsr_port_get_hsr(hsr, HSR_PT_MASTER); |
df95467b TY |
230 | if (master) { |
231 | skb->dev = master->dev; | |
9d680392 | 232 | skb_reset_mac_header(skb); |
48b491a5 | 233 | skb_reset_mac_len(skb); |
06afd2c3 | 234 | spin_lock_bh(&hsr->seqnr_lock); |
df95467b | 235 | hsr_forward_skb(skb, master); |
06afd2c3 | 236 | spin_unlock_bh(&hsr->seqnr_lock); |
df95467b | 237 | } else { |
625788b5 | 238 | dev_core_stats_tx_dropped_inc(dev); |
df95467b TY |
239 | dev_kfree_skb_any(skb); |
240 | } | |
f421436a AB |
241 | return NETDEV_TX_OK; |
242 | } | |
243 | ||
f421436a | 244 | static const struct header_ops hsr_header_ops = { |
f266a683 | 245 | .create = eth_header, |
f421436a AB |
246 | .parse = eth_header_parse, |
247 | }; | |
248 | ||
af8edaed | 249 | static struct sk_buff *hsr_init_skb(struct hsr_port *master, int extra) |
f421436a | 250 | { |
121c33b0 | 251 | struct hsr_priv *hsr = master->hsr; |
f421436a AB |
252 | struct sk_buff *skb; |
253 | int hlen, tlen; | |
af8edaed | 254 | int len; |
f421436a | 255 | |
c5a75911 AB |
256 | hlen = LL_RESERVED_SPACE(master->dev); |
257 | tlen = master->dev->needed_tailroom; | |
af8edaed | 258 | len = sizeof(struct hsr_sup_tag) + sizeof(struct hsr_sup_payload); |
c643ff03 MK |
259 | /* skb size is same for PRP/HSR frames, only difference |
260 | * being, for PRP it is a trailer and for HSR it is a | |
af8edaed ED |
261 | * header. |
262 | * RedBox might use @extra more bytes. | |
c643ff03 | 263 | */ |
af8edaed | 264 | skb = dev_alloc_skb(len + extra + hlen + tlen); |
f421436a | 265 | |
05ca6e64 | 266 | if (!skb) |
121c33b0 | 267 | return skb; |
f421436a | 268 | |
f421436a | 269 | skb_reserve(skb, hlen); |
c5a75911 | 270 | skb->dev = master->dev; |
f421436a AB |
271 | skb->priority = TC_PRIO_CONTROL; |
272 | ||
9cfb5e7f ED |
273 | skb_reset_network_header(skb); |
274 | skb_reset_transport_header(skb); | |
78be9217 | 275 | if (dev_hard_header(skb, skb->dev, ETH_P_PRP, |
121c33b0 | 276 | hsr->sup_multicast_addr, |
f266a683 | 277 | skb->dev->dev_addr, skb->len) <= 0) |
f421436a | 278 | goto out; |
121c33b0 | 279 | |
f266a683 | 280 | skb_reset_mac_header(skb); |
48b491a5 | 281 | skb_reset_mac_len(skb); |
f421436a | 282 | |
121c33b0 MK |
283 | return skb; |
284 | out: | |
285 | kfree_skb(skb); | |
286 | ||
287 | return NULL; | |
288 | } | |
289 | ||
5f703ce5 LM |
290 | static void send_hsr_supervision_frame(struct hsr_port *port, |
291 | unsigned long *interval, | |
292 | const unsigned char *addr) | |
121c33b0 | 293 | { |
5f703ce5 | 294 | struct hsr_priv *hsr = port->hsr; |
28e458e0 | 295 | __u8 type = HSR_TLV_LIFE_CHECK; |
121c33b0 | 296 | struct hsr_sup_payload *hsr_sp; |
5055cccf | 297 | struct hsr_sup_tlv *hsr_stlv; |
121c33b0 | 298 | struct hsr_sup_tag *hsr_stag; |
121c33b0 | 299 | struct sk_buff *skb; |
af8edaed | 300 | int extra = 0; |
28e458e0 MK |
301 | |
302 | *interval = msecs_to_jiffies(HSR_LIFE_CHECK_INTERVAL); | |
303 | if (hsr->announce_count < 3 && hsr->prot_version == 0) { | |
304 | type = HSR_TLV_ANNOUNCE; | |
305 | *interval = msecs_to_jiffies(HSR_ANNOUNCE_INTERVAL); | |
306 | hsr->announce_count++; | |
307 | } | |
308 | ||
af8edaed ED |
309 | if (hsr->redbox) |
310 | extra = sizeof(struct hsr_sup_tlv) + | |
311 | sizeof(struct hsr_sup_payload); | |
312 | ||
313 | skb = hsr_init_skb(port, extra); | |
121c33b0 | 314 | if (!skb) { |
5f703ce5 | 315 | netdev_warn_once(port->dev, "HSR: Could not send supervision frame\n"); |
121c33b0 MK |
316 | return; |
317 | } | |
318 | ||
b952f4df | 319 | hsr_stag = skb_put(skb, sizeof(struct hsr_sup_tag)); |
28e458e0 MK |
320 | set_hsr_stag_path(hsr_stag, (hsr->prot_version ? 0x0 : 0xf)); |
321 | set_hsr_stag_HSR_ver(hsr_stag, hsr->prot_version); | |
f421436a | 322 | |
ee1c2797 | 323 | /* From HSRv1 on we have separate supervision sequence numbers. */ |
d5c7652e | 324 | spin_lock_bh(&hsr->seqnr_lock); |
28e458e0 MK |
325 | if (hsr->prot_version > 0) { |
326 | hsr_stag->sequence_nr = htons(hsr->sup_sequence_nr); | |
327 | hsr->sup_sequence_nr++; | |
ee1c2797 | 328 | } else { |
28e458e0 MK |
329 | hsr_stag->sequence_nr = htons(hsr->sequence_nr); |
330 | hsr->sequence_nr++; | |
ee1c2797 | 331 | } |
f421436a | 332 | |
eafaa88b | 333 | hsr_stag->tlv.HSR_TLV_type = type; |
ee1c2797 | 334 | /* TODO: Why 12 in HSRv0? */ |
eafaa88b | 335 | hsr_stag->tlv.HSR_TLV_length = hsr->prot_version ? |
28e458e0 | 336 | sizeof(struct hsr_sup_payload) : 12; |
f421436a | 337 | |
5f703ce5 | 338 | /* Payload: MacAddressA / SAN MAC from ProxyNodeTable */ |
b952f4df | 339 | hsr_sp = skb_put(skb, sizeof(struct hsr_sup_payload)); |
5f703ce5 | 340 | ether_addr_copy(hsr_sp->macaddress_A, addr); |
f421436a | 341 | |
5f703ce5 LM |
342 | if (hsr->redbox && |
343 | hsr_is_node_in_db(&hsr->proxy_node_db, addr)) { | |
5055cccf LM |
344 | hsr_stlv = skb_put(skb, sizeof(struct hsr_sup_tlv)); |
345 | hsr_stlv->HSR_TLV_type = PRP_TLV_REDBOX_MAC; | |
346 | hsr_stlv->HSR_TLV_length = sizeof(struct hsr_sup_payload); | |
347 | ||
348 | /* Payload: MacAddressRedBox */ | |
349 | hsr_sp = skb_put(skb, sizeof(struct hsr_sup_payload)); | |
350 | ether_addr_copy(hsr_sp->macaddress_A, hsr->macaddress_redbox); | |
351 | } | |
352 | ||
06afd2c3 SAS |
353 | if (skb_put_padto(skb, ETH_ZLEN)) { |
354 | spin_unlock_bh(&hsr->seqnr_lock); | |
414e7d76 | 355 | return; |
06afd2c3 | 356 | } |
ee1c2797 | 357 | |
5f703ce5 | 358 | hsr_forward_skb(skb, port); |
06afd2c3 | 359 | spin_unlock_bh(&hsr->seqnr_lock); |
121c33b0 | 360 | return; |
f421436a AB |
361 | } |
362 | ||
c643ff03 | 363 | static void send_prp_supervision_frame(struct hsr_port *master, |
5f703ce5 LM |
364 | unsigned long *interval, |
365 | const unsigned char *addr) | |
c643ff03 MK |
366 | { |
367 | struct hsr_priv *hsr = master->hsr; | |
368 | struct hsr_sup_payload *hsr_sp; | |
369 | struct hsr_sup_tag *hsr_stag; | |
c643ff03 | 370 | struct sk_buff *skb; |
c643ff03 | 371 | |
af8edaed | 372 | skb = hsr_init_skb(master, 0); |
c643ff03 | 373 | if (!skb) { |
37e8c97e | 374 | netdev_warn_once(master->dev, "PRP: Could not send supervision frame\n"); |
c643ff03 MK |
375 | return; |
376 | } | |
377 | ||
378 | *interval = msecs_to_jiffies(HSR_LIFE_CHECK_INTERVAL); | |
379 | hsr_stag = skb_put(skb, sizeof(struct hsr_sup_tag)); | |
380 | set_hsr_stag_path(hsr_stag, (hsr->prot_version ? 0x0 : 0xf)); | |
381 | set_hsr_stag_HSR_ver(hsr_stag, (hsr->prot_version ? 1 : 0)); | |
382 | ||
383 | /* From HSRv1 on we have separate supervision sequence numbers. */ | |
d5c7652e | 384 | spin_lock_bh(&hsr->seqnr_lock); |
c643ff03 MK |
385 | hsr_stag->sequence_nr = htons(hsr->sup_sequence_nr); |
386 | hsr->sup_sequence_nr++; | |
eafaa88b AO |
387 | hsr_stag->tlv.HSR_TLV_type = PRP_TLV_LIFE_CHECK_DD; |
388 | hsr_stag->tlv.HSR_TLV_length = sizeof(struct hsr_sup_payload); | |
c643ff03 MK |
389 | |
390 | /* Payload: MacAddressA */ | |
391 | hsr_sp = skb_put(skb, sizeof(struct hsr_sup_payload)); | |
392 | ether_addr_copy(hsr_sp->macaddress_A, master->dev->dev_addr); | |
393 | ||
78be9217 | 394 | if (skb_put_padto(skb, ETH_ZLEN)) { |
d5c7652e | 395 | spin_unlock_bh(&hsr->seqnr_lock); |
c643ff03 MK |
396 | return; |
397 | } | |
398 | ||
c643ff03 | 399 | hsr_forward_skb(skb, master); |
06afd2c3 | 400 | spin_unlock_bh(&hsr->seqnr_lock); |
c643ff03 MK |
401 | } |
402 | ||
f421436a AB |
403 | /* Announce (supervision frame) timer function |
404 | */ | |
dda436b7 | 405 | static void hsr_announce(struct timer_list *t) |
f421436a | 406 | { |
70ebe4a4 | 407 | struct hsr_priv *hsr; |
c5a75911 | 408 | struct hsr_port *master; |
1e027960 | 409 | unsigned long interval; |
f421436a | 410 | |
41cb0855 | 411 | hsr = timer_container_of(hsr, t, announce_timer); |
f266a683 AB |
412 | |
413 | rcu_read_lock(); | |
c5a75911 | 414 | master = hsr_port_get_hsr(hsr, HSR_PT_MASTER); |
5f703ce5 | 415 | hsr->proto_ops->send_sv_frame(master, &interval, master->dev->dev_addr); |
f421436a | 416 | |
c5a75911 | 417 | if (is_admin_up(master->dev)) |
1e027960 | 418 | mod_timer(&hsr->announce_timer, jiffies + interval); |
f266a683 AB |
419 | |
420 | rcu_read_unlock(); | |
f421436a AB |
421 | } |
422 | ||
5f703ce5 LM |
423 | /* Announce (supervision frame) timer function for RedBox |
424 | */ | |
425 | static void hsr_proxy_announce(struct timer_list *t) | |
426 | { | |
41cb0855 IM |
427 | struct hsr_priv *hsr = timer_container_of(hsr, t, |
428 | announce_proxy_timer); | |
5f703ce5 LM |
429 | struct hsr_port *interlink; |
430 | unsigned long interval = 0; | |
431 | struct hsr_node *node; | |
432 | ||
433 | rcu_read_lock(); | |
434 | /* RedBOX sends supervisory frames to HSR network with MAC addresses | |
435 | * of SAN nodes stored in ProxyNodeTable. | |
436 | */ | |
437 | interlink = hsr_port_get_hsr(hsr, HSR_PT_INTERLINK); | |
a7789fd4 JP |
438 | if (!interlink) |
439 | goto done; | |
440 | ||
5f703ce5 LM |
441 | list_for_each_entry_rcu(node, &hsr->proxy_node_db, mac_list) { |
442 | if (hsr_addr_is_redbox(hsr, node->macaddress_A)) | |
443 | continue; | |
444 | hsr->proto_ops->send_sv_frame(interlink, &interval, | |
445 | node->macaddress_A); | |
446 | } | |
447 | ||
448 | if (is_admin_up(interlink->dev)) { | |
449 | if (!interval) | |
450 | interval = msecs_to_jiffies(HSR_ANNOUNCE_INTERVAL); | |
451 | ||
452 | mod_timer(&hsr->announce_proxy_timer, jiffies + interval); | |
453 | } | |
454 | ||
a7789fd4 | 455 | done: |
5f703ce5 LM |
456 | rcu_read_unlock(); |
457 | } | |
458 | ||
de0083c7 | 459 | void hsr_del_ports(struct hsr_priv *hsr) |
e0a4b997 TY |
460 | { |
461 | struct hsr_port *port; | |
462 | ||
463 | port = hsr_port_get_hsr(hsr, HSR_PT_SLAVE_A); | |
464 | if (port) | |
465 | hsr_del_port(port); | |
466 | ||
467 | port = hsr_port_get_hsr(hsr, HSR_PT_SLAVE_B); | |
468 | if (port) | |
469 | hsr_del_port(port); | |
470 | ||
5055cccf LM |
471 | port = hsr_port_get_hsr(hsr, HSR_PT_INTERLINK); |
472 | if (port) | |
473 | hsr_del_port(port); | |
474 | ||
e0a4b997 TY |
475 | port = hsr_port_get_hsr(hsr, HSR_PT_MASTER); |
476 | if (port) | |
477 | hsr_del_port(port); | |
478 | } | |
479 | ||
36b20fcd MK |
480 | static void hsr_set_rx_mode(struct net_device *dev) |
481 | { | |
482 | struct hsr_port *port; | |
483 | struct hsr_priv *hsr; | |
484 | ||
485 | hsr = netdev_priv(dev); | |
486 | ||
487 | hsr_for_each_port(hsr, port) { | |
488 | if (port->type == HSR_PT_MASTER) | |
489 | continue; | |
490 | switch (port->type) { | |
491 | case HSR_PT_SLAVE_A: | |
492 | case HSR_PT_SLAVE_B: | |
493 | dev_mc_sync_multiple(port->dev, dev); | |
494 | dev_uc_sync_multiple(port->dev, dev); | |
495 | break; | |
496 | default: | |
497 | break; | |
498 | } | |
499 | } | |
500 | } | |
501 | ||
502 | static void hsr_change_rx_flags(struct net_device *dev, int change) | |
503 | { | |
504 | struct hsr_port *port; | |
505 | struct hsr_priv *hsr; | |
506 | ||
507 | hsr = netdev_priv(dev); | |
508 | ||
509 | hsr_for_each_port(hsr, port) { | |
510 | if (port->type == HSR_PT_MASTER) | |
511 | continue; | |
512 | switch (port->type) { | |
513 | case HSR_PT_SLAVE_A: | |
514 | case HSR_PT_SLAVE_B: | |
515 | if (change & IFF_ALLMULTI) | |
516 | dev_set_allmulti(port->dev, | |
517 | dev->flags & | |
518 | IFF_ALLMULTI ? 1 : -1); | |
519 | break; | |
520 | default: | |
521 | break; | |
522 | } | |
523 | } | |
524 | } | |
525 | ||
1a8a63a5 MK |
526 | static int hsr_ndo_vlan_rx_add_vid(struct net_device *dev, |
527 | __be16 proto, u16 vid) | |
528 | { | |
529 | bool is_slave_a_added = false; | |
530 | bool is_slave_b_added = false; | |
531 | struct hsr_port *port; | |
532 | struct hsr_priv *hsr; | |
533 | int ret = 0; | |
534 | ||
535 | hsr = netdev_priv(dev); | |
536 | ||
537 | hsr_for_each_port(hsr, port) { | |
538 | if (port->type == HSR_PT_MASTER || | |
539 | port->type == HSR_PT_INTERLINK) | |
540 | continue; | |
541 | ||
542 | ret = vlan_vid_add(port->dev, proto, vid); | |
543 | switch (port->type) { | |
544 | case HSR_PT_SLAVE_A: | |
545 | if (ret) { | |
546 | /* clean up Slave-B */ | |
547 | netdev_err(dev, "add vid failed for Slave-A\n"); | |
548 | if (is_slave_b_added) | |
549 | vlan_vid_del(port->dev, proto, vid); | |
550 | return ret; | |
551 | } | |
552 | ||
553 | is_slave_a_added = true; | |
554 | break; | |
555 | ||
556 | case HSR_PT_SLAVE_B: | |
557 | if (ret) { | |
558 | /* clean up Slave-A */ | |
559 | netdev_err(dev, "add vid failed for Slave-B\n"); | |
560 | if (is_slave_a_added) | |
561 | vlan_vid_del(port->dev, proto, vid); | |
562 | return ret; | |
563 | } | |
564 | ||
565 | is_slave_b_added = true; | |
566 | break; | |
567 | default: | |
568 | break; | |
569 | } | |
570 | } | |
571 | ||
572 | return 0; | |
573 | } | |
574 | ||
575 | static int hsr_ndo_vlan_rx_kill_vid(struct net_device *dev, | |
576 | __be16 proto, u16 vid) | |
577 | { | |
578 | struct hsr_port *port; | |
579 | struct hsr_priv *hsr; | |
580 | ||
581 | hsr = netdev_priv(dev); | |
582 | ||
583 | hsr_for_each_port(hsr, port) { | |
584 | switch (port->type) { | |
585 | case HSR_PT_SLAVE_A: | |
586 | case HSR_PT_SLAVE_B: | |
587 | vlan_vid_del(port->dev, proto, vid); | |
588 | break; | |
589 | default: | |
590 | break; | |
591 | } | |
592 | } | |
593 | ||
594 | return 0; | |
595 | } | |
596 | ||
f421436a AB |
597 | static const struct net_device_ops hsr_device_ops = { |
598 | .ndo_change_mtu = hsr_dev_change_mtu, | |
599 | .ndo_open = hsr_dev_open, | |
600 | .ndo_stop = hsr_dev_close, | |
601 | .ndo_start_xmit = hsr_dev_xmit, | |
36b20fcd | 602 | .ndo_change_rx_flags = hsr_change_rx_flags, |
1cc1eb52 | 603 | .ndo_fix_features = hsr_fix_features, |
36b20fcd | 604 | .ndo_set_rx_mode = hsr_set_rx_mode, |
1a8a63a5 MK |
605 | .ndo_vlan_rx_add_vid = hsr_ndo_vlan_rx_add_vid, |
606 | .ndo_vlan_rx_kill_vid = hsr_ndo_vlan_rx_kill_vid, | |
f421436a AB |
607 | }; |
608 | ||
0072b2c1 | 609 | static const struct device_type hsr_type = { |
4c3477dc AB |
610 | .name = "hsr", |
611 | }; | |
f421436a | 612 | |
28e458e0 MK |
613 | static struct hsr_proto_ops hsr_ops = { |
614 | .send_sv_frame = send_hsr_supervision_frame, | |
fa4dc895 MK |
615 | .create_tagged_frame = hsr_create_tagged_frame, |
616 | .get_untagged_frame = hsr_get_untagged_frame, | |
dcf0cd1c | 617 | .drop_frame = hsr_drop_frame, |
fa4dc895 | 618 | .fill_frame_info = hsr_fill_frame_info, |
451d8123 | 619 | .invalid_dan_ingress_frame = hsr_invalid_dan_ingress_frame, |
05fd00e5 | 620 | .register_frame_out = hsr_register_frame_out, |
28e458e0 MK |
621 | }; |
622 | ||
fa4dc895 | 623 | static struct hsr_proto_ops prp_ops = { |
c643ff03 | 624 | .send_sv_frame = send_prp_supervision_frame, |
451d8123 MK |
625 | .create_tagged_frame = prp_create_tagged_frame, |
626 | .get_untagged_frame = prp_get_untagged_frame, | |
627 | .drop_frame = prp_drop_frame, | |
628 | .fill_frame_info = prp_fill_frame_info, | |
629 | .handle_san_frame = prp_handle_san_frame, | |
630 | .update_san_info = prp_update_san_info, | |
05fd00e5 | 631 | .register_frame_out = prp_register_frame_out, |
c643ff03 MK |
632 | }; |
633 | ||
f421436a AB |
634 | void hsr_dev_setup(struct net_device *dev) |
635 | { | |
d4af4c0a | 636 | eth_hw_addr_random(dev); |
f421436a AB |
637 | |
638 | ether_setup(dev); | |
b3e3893e | 639 | dev->min_mtu = 0; |
4c3477dc AB |
640 | dev->header_ops = &hsr_header_ops; |
641 | dev->netdev_ops = &hsr_device_ops; | |
642 | SET_NETDEV_DEVTYPE(dev, &hsr_type); | |
d5c7652e | 643 | dev->priv_flags |= IFF_NO_QUEUE | IFF_DISABLE_NETPOLL; |
00d066a4 AL |
644 | /* Prevent recursive tx locking */ |
645 | dev->lltx = true; | |
05c1280a AL |
646 | /* Not sure about this. Taken from bridge code. netdevice.h says |
647 | * it means "Does not change network namespaces". | |
648 | */ | |
0c493da8 | 649 | dev->netns_immutable = true; |
f421436a | 650 | |
cf124db5 | 651 | dev->needs_free_netdev = true; |
1cc1eb52 AB |
652 | |
653 | dev->hw_features = NETIF_F_SG | NETIF_F_FRAGLIST | NETIF_F_HIGHDMA | | |
654 | NETIF_F_GSO_MASK | NETIF_F_HW_CSUM | | |
1a8a63a5 MK |
655 | NETIF_F_HW_VLAN_CTAG_TX | |
656 | NETIF_F_HW_VLAN_CTAG_FILTER; | |
1cc1eb52 AB |
657 | |
658 | dev->features = dev->hw_features; | |
f421436a AB |
659 | } |
660 | ||
f421436a AB |
661 | /* Return true if dev is a HSR master; return false otherwise. |
662 | */ | |
dcf0cd1c | 663 | bool is_hsr_master(struct net_device *dev) |
f421436a AB |
664 | { |
665 | return (dev->netdev_ops->ndo_start_xmit == hsr_dev_xmit); | |
666 | } | |
dcf0cd1c | 667 | EXPORT_SYMBOL(is_hsr_master); |
f421436a | 668 | |
9c10dd8e MDA |
669 | struct net_device *hsr_get_port_ndev(struct net_device *ndev, |
670 | enum hsr_port_type pt) | |
671 | { | |
672 | struct hsr_priv *hsr = netdev_priv(ndev); | |
673 | struct hsr_port *port; | |
674 | ||
675 | hsr_for_each_port(hsr, port) | |
676 | if (port->type == pt) | |
677 | return port->dev; | |
678 | return NULL; | |
679 | } | |
680 | EXPORT_SYMBOL(hsr_get_port_ndev); | |
681 | ||
f421436a | 682 | /* Default multicast address for HSR Supervision frames */ |
e83abe37 | 683 | static const unsigned char def_multicast_addr[ETH_ALEN] __aligned(2) = { |
f421436a AB |
684 | 0x01, 0x15, 0x4e, 0x00, 0x01, 0x00 |
685 | }; | |
686 | ||
687 | int hsr_dev_finalize(struct net_device *hsr_dev, struct net_device *slave[2], | |
5055cccf LM |
688 | struct net_device *interlink, unsigned char multicast_spec, |
689 | u8 protocol_version, struct netlink_ext_ack *extack) | |
f421436a | 690 | { |
ccfc9df1 | 691 | bool unregister = false; |
70ebe4a4 | 692 | struct hsr_priv *hsr; |
e012764c | 693 | int res; |
f421436a | 694 | |
70ebe4a4 | 695 | hsr = netdev_priv(hsr_dev); |
c5a75911 | 696 | INIT_LIST_HEAD(&hsr->ports); |
e012764c | 697 | INIT_LIST_HEAD(&hsr->node_db); |
5055cccf | 698 | INIT_LIST_HEAD(&hsr->proxy_node_db); |
92a35678 | 699 | spin_lock_init(&hsr->list_lock); |
51f3c605 | 700 | |
e35b8d7d | 701 | eth_hw_addr_set(hsr_dev, slave[0]->dev_addr); |
51f3c605 | 702 | |
c643ff03 | 703 | /* initialize protocol specific functions */ |
451d8123 MK |
704 | if (protocol_version == PRP_V1) { |
705 | /* For PRP, lan_id has most significant 3 bits holding | |
706 | * the net_id of PRP_LAN_ID | |
707 | */ | |
708 | hsr->net_id = PRP_LAN_ID << 1; | |
c643ff03 | 709 | hsr->proto_ops = &prp_ops; |
451d8123 | 710 | } else { |
c643ff03 | 711 | hsr->proto_ops = &hsr_ops; |
451d8123 | 712 | } |
c643ff03 | 713 | |
51f3c605 | 714 | /* Make sure we recognize frames from ourselves in hsr_rcv() */ |
92a35678 | 715 | res = hsr_create_self_node(hsr, hsr_dev->dev_addr, |
51f3c605 AB |
716 | slave[1]->dev_addr); |
717 | if (res < 0) | |
718 | return res; | |
719 | ||
70ebe4a4 | 720 | spin_lock_init(&hsr->seqnr_lock); |
f421436a | 721 | /* Overflow soon to find bugs easier: */ |
f266a683 | 722 | hsr->sequence_nr = HSR_SEQNR_START; |
ee1c2797 | 723 | hsr->sup_sequence_nr = HSR_SUP_SEQNR_START; |
f421436a | 724 | |
dda436b7 KC |
725 | timer_setup(&hsr->announce_timer, hsr_announce, 0); |
726 | timer_setup(&hsr->prune_timer, hsr_prune_nodes, 0); | |
3c668cef | 727 | timer_setup(&hsr->prune_proxy_timer, hsr_prune_proxy_nodes, 0); |
5f703ce5 | 728 | timer_setup(&hsr->announce_proxy_timer, hsr_proxy_announce, 0); |
abff7162 | 729 | |
70ebe4a4 AB |
730 | ether_addr_copy(hsr->sup_multicast_addr, def_multicast_addr); |
731 | hsr->sup_multicast_addr[ETH_ALEN - 1] = multicast_spec; | |
f421436a | 732 | |
b1b4aa91 | 733 | hsr->prot_version = protocol_version; |
ee1c2797 | 734 | |
f421436a AB |
735 | /* Make sure the 1st call to netif_carrier_on() gets through */ |
736 | netif_carrier_off(hsr_dev); | |
737 | ||
13eeb5fe | 738 | res = hsr_add_port(hsr, hsr_dev, HSR_PT_MASTER, extack); |
f421436a | 739 | if (res) |
1d19e2d5 | 740 | goto err_add_master; |
51f3c605 | 741 | |
e748d0fd RG |
742 | /* HSR forwarding offload supported in lower device? */ |
743 | if ((slave[0]->features & NETIF_F_HW_HSR_FWD) && | |
744 | (slave[1]->features & NETIF_F_HW_HSR_FWD)) | |
745 | hsr->fwd_offloaded = true; | |
746 | ||
1a8a63a5 MK |
747 | if ((slave[0]->features & NETIF_F_HW_VLAN_CTAG_FILTER) && |
748 | (slave[1]->features & NETIF_F_HW_VLAN_CTAG_FILTER)) | |
749 | hsr_dev->features |= NETIF_F_HW_VLAN_CTAG_FILTER; | |
750 | ||
c5a75911 | 751 | res = register_netdevice(hsr_dev); |
51f3c605 | 752 | if (res) |
1d19e2d5 | 753 | goto err_unregister; |
c5a75911 | 754 | |
ccfc9df1 TY |
755 | unregister = true; |
756 | ||
13eeb5fe | 757 | res = hsr_add_port(hsr, slave[0], HSR_PT_SLAVE_A, extack); |
c5a75911 | 758 | if (res) |
ccfc9df1 | 759 | goto err_unregister; |
1d19e2d5 | 760 | |
13eeb5fe | 761 | res = hsr_add_port(hsr, slave[1], HSR_PT_SLAVE_B, extack); |
c5a75911 | 762 | if (res) |
ccfc9df1 | 763 | goto err_unregister; |
f421436a | 764 | |
b65999e7 FFM |
765 | if (protocol_version == PRP_V1) { |
766 | eth_hw_addr_set(slave[1], slave[0]->dev_addr); | |
767 | call_netdevice_notifiers(NETDEV_CHANGEADDR, slave[1]); | |
768 | } | |
769 | ||
5055cccf LM |
770 | if (interlink) { |
771 | res = hsr_add_port(hsr, interlink, HSR_PT_INTERLINK, extack); | |
772 | if (res) | |
773 | goto err_unregister; | |
774 | ||
775 | hsr->redbox = true; | |
776 | ether_addr_copy(hsr->macaddress_redbox, interlink->dev_addr); | |
5055cccf LM |
777 | mod_timer(&hsr->prune_proxy_timer, |
778 | jiffies + msecs_to_jiffies(PRUNE_PROXY_PERIOD)); | |
779 | } | |
780 | ||
1d19e2d5 | 781 | hsr_debugfs_init(hsr, hsr_dev); |
15db6e0d | 782 | mod_timer(&hsr->prune_timer, jiffies + msecs_to_jiffies(PRUNE_PERIOD)); |
abff7162 | 783 | |
f421436a | 784 | return 0; |
c5a75911 | 785 | |
1d19e2d5 | 786 | err_unregister: |
e0a4b997 | 787 | hsr_del_ports(hsr); |
1d19e2d5 | 788 | err_add_master: |
92a35678 | 789 | hsr_del_self_node(hsr); |
c5a75911 | 790 | |
ccfc9df1 TY |
791 | if (unregister) |
792 | unregister_netdevice(hsr_dev); | |
c5a75911 | 793 | return res; |
f421436a | 794 | } |