diff options
Diffstat (limited to 'net/batman-adv')
-rw-r--r-- | net/batman-adv/gateway_client.c | 80 | ||||
-rw-r--r-- | net/batman-adv/icmp_socket.c | 18 | ||||
-rw-r--r-- | net/batman-adv/originator.c | 37 | ||||
-rw-r--r-- | net/batman-adv/originator.h | 1 | ||||
-rw-r--r-- | net/batman-adv/routing.c | 194 | ||||
-rw-r--r-- | net/batman-adv/send.c | 19 | ||||
-rw-r--r-- | net/batman-adv/types.h | 4 | ||||
-rw-r--r-- | net/batman-adv/vis.c | 91 |
8 files changed, 232 insertions, 212 deletions
diff --git a/net/batman-adv/gateway_client.c b/net/batman-adv/gateway_client.c index 879ac1594869..42a8a7ba06e6 100644 --- a/net/batman-adv/gateway_client.c +++ b/net/batman-adv/gateway_client.c | |||
@@ -98,6 +98,7 @@ void gw_election(struct bat_priv *bat_priv) | |||
98 | { | 98 | { |
99 | struct hlist_node *node; | 99 | struct hlist_node *node; |
100 | struct gw_node *gw_node, *curr_gw, *curr_gw_tmp = NULL; | 100 | struct gw_node *gw_node, *curr_gw, *curr_gw_tmp = NULL; |
101 | struct neigh_node *router; | ||
101 | uint8_t max_tq = 0; | 102 | uint8_t max_tq = 0; |
102 | uint32_t max_gw_factor = 0, tmp_gw_factor = 0; | 103 | uint32_t max_gw_factor = 0, tmp_gw_factor = 0; |
103 | int down, up; | 104 | int down, up; |
@@ -133,10 +134,11 @@ void gw_election(struct bat_priv *bat_priv) | |||
133 | } | 134 | } |
134 | 135 | ||
135 | hlist_for_each_entry_rcu(gw_node, node, &bat_priv->gw_list, list) { | 136 | hlist_for_each_entry_rcu(gw_node, node, &bat_priv->gw_list, list) { |
136 | if (!gw_node->orig_node->router) | 137 | if (gw_node->deleted) |
137 | continue; | 138 | continue; |
138 | 139 | ||
139 | if (gw_node->deleted) | 140 | router = orig_node_get_router(gw_node->orig_node); |
141 | if (!router) | ||
140 | continue; | 142 | continue; |
141 | 143 | ||
142 | switch (atomic_read(&bat_priv->gw_sel_class)) { | 144 | switch (atomic_read(&bat_priv->gw_sel_class)) { |
@@ -144,15 +146,14 @@ void gw_election(struct bat_priv *bat_priv) | |||
144 | gw_bandwidth_to_kbit(gw_node->orig_node->gw_flags, | 146 | gw_bandwidth_to_kbit(gw_node->orig_node->gw_flags, |
145 | &down, &up); | 147 | &down, &up); |
146 | 148 | ||
147 | tmp_gw_factor = (gw_node->orig_node->router->tq_avg * | 149 | tmp_gw_factor = (router->tq_avg * router->tq_avg * |
148 | gw_node->orig_node->router->tq_avg * | ||
149 | down * 100 * 100) / | 150 | down * 100 * 100) / |
150 | (TQ_LOCAL_WINDOW_SIZE * | 151 | (TQ_LOCAL_WINDOW_SIZE * |
151 | TQ_LOCAL_WINDOW_SIZE * 64); | 152 | TQ_LOCAL_WINDOW_SIZE * 64); |
152 | 153 | ||
153 | if ((tmp_gw_factor > max_gw_factor) || | 154 | if ((tmp_gw_factor > max_gw_factor) || |
154 | ((tmp_gw_factor == max_gw_factor) && | 155 | ((tmp_gw_factor == max_gw_factor) && |
155 | (gw_node->orig_node->router->tq_avg > max_tq))) | 156 | (router->tq_avg > max_tq))) |
156 | curr_gw_tmp = gw_node; | 157 | curr_gw_tmp = gw_node; |
157 | break; | 158 | break; |
158 | 159 | ||
@@ -164,19 +165,25 @@ void gw_election(struct bat_priv *bat_priv) | |||
164 | * soon as a better gateway appears which has | 165 | * soon as a better gateway appears which has |
165 | * $routing_class more tq points) | 166 | * $routing_class more tq points) |
166 | **/ | 167 | **/ |
167 | if (gw_node->orig_node->router->tq_avg > max_tq) | 168 | if (router->tq_avg > max_tq) |
168 | curr_gw_tmp = gw_node; | 169 | curr_gw_tmp = gw_node; |
169 | break; | 170 | break; |
170 | } | 171 | } |
171 | 172 | ||
172 | if (gw_node->orig_node->router->tq_avg > max_tq) | 173 | if (router->tq_avg > max_tq) |
173 | max_tq = gw_node->orig_node->router->tq_avg; | 174 | max_tq = router->tq_avg; |
174 | 175 | ||
175 | if (tmp_gw_factor > max_gw_factor) | 176 | if (tmp_gw_factor > max_gw_factor) |
176 | max_gw_factor = tmp_gw_factor; | 177 | max_gw_factor = tmp_gw_factor; |
178 | |||
179 | neigh_node_free_ref(router); | ||
177 | } | 180 | } |
178 | 181 | ||
179 | if (curr_gw != curr_gw_tmp) { | 182 | if (curr_gw != curr_gw_tmp) { |
183 | router = orig_node_get_router(curr_gw_tmp->orig_node); | ||
184 | if (!router) | ||
185 | goto out; | ||
186 | |||
180 | if ((curr_gw) && (!curr_gw_tmp)) | 187 | if ((curr_gw) && (!curr_gw_tmp)) |
181 | bat_dbg(DBG_BATMAN, bat_priv, | 188 | bat_dbg(DBG_BATMAN, bat_priv, |
182 | "Removing selected gateway - " | 189 | "Removing selected gateway - " |
@@ -187,45 +194,47 @@ void gw_election(struct bat_priv *bat_priv) | |||
187 | "(gw_flags: %i, tq: %i)\n", | 194 | "(gw_flags: %i, tq: %i)\n", |
188 | curr_gw_tmp->orig_node->orig, | 195 | curr_gw_tmp->orig_node->orig, |
189 | curr_gw_tmp->orig_node->gw_flags, | 196 | curr_gw_tmp->orig_node->gw_flags, |
190 | curr_gw_tmp->orig_node->router->tq_avg); | 197 | router->tq_avg); |
191 | else | 198 | else |
192 | bat_dbg(DBG_BATMAN, bat_priv, | 199 | bat_dbg(DBG_BATMAN, bat_priv, |
193 | "Changing route to gateway %pM " | 200 | "Changing route to gateway %pM " |
194 | "(gw_flags: %i, tq: %i)\n", | 201 | "(gw_flags: %i, tq: %i)\n", |
195 | curr_gw_tmp->orig_node->orig, | 202 | curr_gw_tmp->orig_node->orig, |
196 | curr_gw_tmp->orig_node->gw_flags, | 203 | curr_gw_tmp->orig_node->gw_flags, |
197 | curr_gw_tmp->orig_node->router->tq_avg); | 204 | router->tq_avg); |
198 | 205 | ||
206 | neigh_node_free_ref(router); | ||
199 | gw_select(bat_priv, curr_gw_tmp); | 207 | gw_select(bat_priv, curr_gw_tmp); |
200 | } | 208 | } |
201 | 209 | ||
210 | out: | ||
202 | rcu_read_unlock(); | 211 | rcu_read_unlock(); |
203 | } | 212 | } |
204 | 213 | ||
205 | void gw_check_election(struct bat_priv *bat_priv, struct orig_node *orig_node) | 214 | void gw_check_election(struct bat_priv *bat_priv, struct orig_node *orig_node) |
206 | { | 215 | { |
207 | struct orig_node *curr_gw_orig; | 216 | struct orig_node *curr_gw_orig; |
217 | struct neigh_node *router_gw = NULL, *router_orig = NULL; | ||
208 | uint8_t gw_tq_avg, orig_tq_avg; | 218 | uint8_t gw_tq_avg, orig_tq_avg; |
209 | 219 | ||
210 | curr_gw_orig = gw_get_selected(bat_priv); | 220 | curr_gw_orig = gw_get_selected(bat_priv); |
211 | if (!curr_gw_orig) | 221 | if (!curr_gw_orig) |
212 | goto deselect; | 222 | goto deselect; |
213 | 223 | ||
214 | rcu_read_lock(); | 224 | router_gw = orig_node_get_router(curr_gw_orig); |
215 | if (!curr_gw_orig->router) | 225 | if (!router_gw) |
216 | goto deselect_rcu; | 226 | goto deselect; |
217 | 227 | ||
218 | /* this node already is the gateway */ | 228 | /* this node already is the gateway */ |
219 | if (curr_gw_orig == orig_node) | 229 | if (curr_gw_orig == orig_node) |
220 | goto out_rcu; | 230 | goto out; |
221 | |||
222 | if (!orig_node->router) | ||
223 | goto out_rcu; | ||
224 | 231 | ||
225 | gw_tq_avg = curr_gw_orig->router->tq_avg; | 232 | router_orig = orig_node_get_router(orig_node); |
226 | rcu_read_unlock(); | 233 | if (!router_orig) |
234 | goto out; | ||
227 | 235 | ||
228 | orig_tq_avg = orig_node->router->tq_avg; | 236 | gw_tq_avg = router_gw->tq_avg; |
237 | orig_tq_avg = router_orig->tq_avg; | ||
229 | 238 | ||
230 | /* the TQ value has to be better */ | 239 | /* the TQ value has to be better */ |
231 | if (orig_tq_avg < gw_tq_avg) | 240 | if (orig_tq_avg < gw_tq_avg) |
@@ -243,18 +252,16 @@ void gw_check_election(struct bat_priv *bat_priv, struct orig_node *orig_node) | |||
243 | "Restarting gateway selection: better gateway found (tq curr: " | 252 | "Restarting gateway selection: better gateway found (tq curr: " |
244 | "%i, tq new: %i)\n", | 253 | "%i, tq new: %i)\n", |
245 | gw_tq_avg, orig_tq_avg); | 254 | gw_tq_avg, orig_tq_avg); |
246 | goto deselect; | ||
247 | 255 | ||
248 | out_rcu: | ||
249 | rcu_read_unlock(); | ||
250 | goto out; | ||
251 | deselect_rcu: | ||
252 | rcu_read_unlock(); | ||
253 | deselect: | 256 | deselect: |
254 | gw_deselect(bat_priv); | 257 | gw_deselect(bat_priv); |
255 | out: | 258 | out: |
256 | if (curr_gw_orig) | 259 | if (curr_gw_orig) |
257 | orig_node_free_ref(curr_gw_orig); | 260 | orig_node_free_ref(curr_gw_orig); |
261 | if (router_gw) | ||
262 | neigh_node_free_ref(router_gw); | ||
263 | if (router_orig) | ||
264 | neigh_node_free_ref(router_orig); | ||
258 | 265 | ||
259 | return; | 266 | return; |
260 | } | 267 | } |
@@ -362,23 +369,30 @@ void gw_node_purge(struct bat_priv *bat_priv) | |||
362 | spin_unlock_bh(&bat_priv->gw_list_lock); | 369 | spin_unlock_bh(&bat_priv->gw_list_lock); |
363 | } | 370 | } |
364 | 371 | ||
372 | /** | ||
373 | * fails if orig_node has no router | ||
374 | */ | ||
365 | static int _write_buffer_text(struct bat_priv *bat_priv, | 375 | static int _write_buffer_text(struct bat_priv *bat_priv, |
366 | struct seq_file *seq, struct gw_node *gw_node) | 376 | struct seq_file *seq, struct gw_node *gw_node) |
367 | { | 377 | { |
368 | struct gw_node *curr_gw; | 378 | struct gw_node *curr_gw; |
369 | int down, up, ret; | 379 | struct neigh_node *router; |
380 | int down, up, ret = -1; | ||
370 | 381 | ||
371 | gw_bandwidth_to_kbit(gw_node->orig_node->gw_flags, &down, &up); | 382 | gw_bandwidth_to_kbit(gw_node->orig_node->gw_flags, &down, &up); |
372 | 383 | ||
384 | router = orig_node_get_router(gw_node->orig_node); | ||
385 | if (!router) | ||
386 | goto out; | ||
387 | |||
373 | rcu_read_lock(); | 388 | rcu_read_lock(); |
374 | curr_gw = rcu_dereference(bat_priv->curr_gw); | 389 | curr_gw = rcu_dereference(bat_priv->curr_gw); |
375 | 390 | ||
376 | ret = seq_printf(seq, "%s %pM (%3i) %pM [%10s]: %3i - %i%s/%i%s\n", | 391 | ret = seq_printf(seq, "%s %pM (%3i) %pM [%10s]: %3i - %i%s/%i%s\n", |
377 | (curr_gw == gw_node ? "=>" : " "), | 392 | (curr_gw == gw_node ? "=>" : " "), |
378 | gw_node->orig_node->orig, | 393 | gw_node->orig_node->orig, |
379 | gw_node->orig_node->router->tq_avg, | 394 | router->tq_avg, router->addr, |
380 | gw_node->orig_node->router->addr, | 395 | router->if_incoming->net_dev->name, |
381 | gw_node->orig_node->router->if_incoming->net_dev->name, | ||
382 | gw_node->orig_node->gw_flags, | 396 | gw_node->orig_node->gw_flags, |
383 | (down > 2048 ? down / 1024 : down), | 397 | (down > 2048 ? down / 1024 : down), |
384 | (down > 2048 ? "MBit" : "KBit"), | 398 | (down > 2048 ? "MBit" : "KBit"), |
@@ -386,6 +400,8 @@ static int _write_buffer_text(struct bat_priv *bat_priv, | |||
386 | (up > 2048 ? "MBit" : "KBit")); | 400 | (up > 2048 ? "MBit" : "KBit")); |
387 | 401 | ||
388 | rcu_read_unlock(); | 402 | rcu_read_unlock(); |
403 | neigh_node_free_ref(router); | ||
404 | out: | ||
389 | return ret; | 405 | return ret; |
390 | } | 406 | } |
391 | 407 | ||
@@ -423,10 +439,10 @@ int gw_client_seq_print_text(struct seq_file *seq, void *offset) | |||
423 | if (gw_node->deleted) | 439 | if (gw_node->deleted) |
424 | continue; | 440 | continue; |
425 | 441 | ||
426 | if (!gw_node->orig_node->router) | 442 | /* fails if orig_node has no router */ |
443 | if (_write_buffer_text(bat_priv, seq, gw_node) < 0) | ||
427 | continue; | 444 | continue; |
428 | 445 | ||
429 | _write_buffer_text(bat_priv, seq, gw_node); | ||
430 | gw_count++; | 446 | gw_count++; |
431 | } | 447 | } |
432 | rcu_read_unlock(); | 448 | rcu_read_unlock(); |
diff --git a/net/batman-adv/icmp_socket.c b/net/batman-adv/icmp_socket.c index 34ce56c358e5..49079c254476 100644 --- a/net/batman-adv/icmp_socket.c +++ b/net/batman-adv/icmp_socket.c | |||
@@ -218,23 +218,13 @@ static ssize_t bat_socket_write(struct file *file, const char __user *buff, | |||
218 | if (atomic_read(&bat_priv->mesh_state) != MESH_ACTIVE) | 218 | if (atomic_read(&bat_priv->mesh_state) != MESH_ACTIVE) |
219 | goto dst_unreach; | 219 | goto dst_unreach; |
220 | 220 | ||
221 | rcu_read_lock(); | ||
222 | orig_node = orig_hash_find(bat_priv, icmp_packet->dst); | 221 | orig_node = orig_hash_find(bat_priv, icmp_packet->dst); |
223 | |||
224 | if (!orig_node) | 222 | if (!orig_node) |
225 | goto unlock; | 223 | goto dst_unreach; |
226 | |||
227 | neigh_node = orig_node->router; | ||
228 | 224 | ||
225 | neigh_node = orig_node_get_router(orig_node); | ||
229 | if (!neigh_node) | 226 | if (!neigh_node) |
230 | goto unlock; | 227 | goto dst_unreach; |
231 | |||
232 | if (!atomic_inc_not_zero(&neigh_node->refcount)) { | ||
233 | neigh_node = NULL; | ||
234 | goto unlock; | ||
235 | } | ||
236 | |||
237 | rcu_read_unlock(); | ||
238 | 228 | ||
239 | if (!neigh_node->if_incoming) | 229 | if (!neigh_node->if_incoming) |
240 | goto dst_unreach; | 230 | goto dst_unreach; |
@@ -252,8 +242,6 @@ static ssize_t bat_socket_write(struct file *file, const char __user *buff, | |||
252 | send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); | 242 | send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); |
253 | goto out; | 243 | goto out; |
254 | 244 | ||
255 | unlock: | ||
256 | rcu_read_unlock(); | ||
257 | dst_unreach: | 245 | dst_unreach: |
258 | icmp_packet->msg_type = DESTINATION_UNREACHABLE; | 246 | icmp_packet->msg_type = DESTINATION_UNREACHABLE; |
259 | bat_socket_add_packet(socket_client, icmp_packet, packet_len); | 247 | bat_socket_add_packet(socket_client, icmp_packet, packet_len); |
diff --git a/net/batman-adv/originator.c b/net/batman-adv/originator.c index 0b9133022d2d..b4cfe3686155 100644 --- a/net/batman-adv/originator.c +++ b/net/batman-adv/originator.c | |||
@@ -70,6 +70,21 @@ void neigh_node_free_ref(struct neigh_node *neigh_node) | |||
70 | call_rcu(&neigh_node->rcu, neigh_node_free_rcu); | 70 | call_rcu(&neigh_node->rcu, neigh_node_free_rcu); |
71 | } | 71 | } |
72 | 72 | ||
73 | /* increases the refcounter of a found router */ | ||
74 | struct neigh_node *orig_node_get_router(struct orig_node *orig_node) | ||
75 | { | ||
76 | struct neigh_node *router; | ||
77 | |||
78 | rcu_read_lock(); | ||
79 | router = rcu_dereference(orig_node->router); | ||
80 | |||
81 | if (router && !atomic_inc_not_zero(&router->refcount)) | ||
82 | router = NULL; | ||
83 | |||
84 | rcu_read_unlock(); | ||
85 | return router; | ||
86 | } | ||
87 | |||
73 | struct neigh_node *create_neighbor(struct orig_node *orig_node, | 88 | struct neigh_node *create_neighbor(struct orig_node *orig_node, |
74 | struct orig_node *orig_neigh_node, | 89 | struct orig_node *orig_neigh_node, |
75 | uint8_t *neigh, | 90 | uint8_t *neigh, |
@@ -390,7 +405,7 @@ int orig_seq_print_text(struct seq_file *seq, void *offset) | |||
390 | struct hlist_node *node, *node_tmp; | 405 | struct hlist_node *node, *node_tmp; |
391 | struct hlist_head *head; | 406 | struct hlist_head *head; |
392 | struct orig_node *orig_node; | 407 | struct orig_node *orig_node; |
393 | struct neigh_node *neigh_node; | 408 | struct neigh_node *neigh_node, *neigh_node_tmp; |
394 | int batman_count = 0; | 409 | int batman_count = 0; |
395 | int last_seen_secs; | 410 | int last_seen_secs; |
396 | int last_seen_msecs; | 411 | int last_seen_msecs; |
@@ -421,37 +436,41 @@ int orig_seq_print_text(struct seq_file *seq, void *offset) | |||
421 | 436 | ||
422 | rcu_read_lock(); | 437 | rcu_read_lock(); |
423 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { | 438 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { |
424 | if (!orig_node->router) | 439 | neigh_node = orig_node_get_router(orig_node); |
440 | if (!neigh_node) | ||
425 | continue; | 441 | continue; |
426 | 442 | ||
427 | if (orig_node->router->tq_avg == 0) | 443 | if (neigh_node->tq_avg == 0) |
428 | continue; | 444 | goto next; |
429 | 445 | ||
430 | last_seen_secs = jiffies_to_msecs(jiffies - | 446 | last_seen_secs = jiffies_to_msecs(jiffies - |
431 | orig_node->last_valid) / 1000; | 447 | orig_node->last_valid) / 1000; |
432 | last_seen_msecs = jiffies_to_msecs(jiffies - | 448 | last_seen_msecs = jiffies_to_msecs(jiffies - |
433 | orig_node->last_valid) % 1000; | 449 | orig_node->last_valid) % 1000; |
434 | 450 | ||
435 | neigh_node = orig_node->router; | ||
436 | seq_printf(seq, "%pM %4i.%03is (%3i) %pM [%10s]:", | 451 | seq_printf(seq, "%pM %4i.%03is (%3i) %pM [%10s]:", |
437 | orig_node->orig, last_seen_secs, | 452 | orig_node->orig, last_seen_secs, |
438 | last_seen_msecs, neigh_node->tq_avg, | 453 | last_seen_msecs, neigh_node->tq_avg, |
439 | neigh_node->addr, | 454 | neigh_node->addr, |
440 | neigh_node->if_incoming->net_dev->name); | 455 | neigh_node->if_incoming->net_dev->name); |
441 | 456 | ||
442 | hlist_for_each_entry_rcu(neigh_node, node_tmp, | 457 | hlist_for_each_entry_rcu(neigh_node_tmp, node_tmp, |
443 | &orig_node->neigh_list, list) { | 458 | &orig_node->neigh_list, list) { |
444 | seq_printf(seq, " %pM (%3i)", neigh_node->addr, | 459 | seq_printf(seq, " %pM (%3i)", |
445 | neigh_node->tq_avg); | 460 | neigh_node_tmp->addr, |
461 | neigh_node_tmp->tq_avg); | ||
446 | } | 462 | } |
447 | 463 | ||
448 | seq_printf(seq, "\n"); | 464 | seq_printf(seq, "\n"); |
449 | batman_count++; | 465 | batman_count++; |
466 | |||
467 | next: | ||
468 | neigh_node_free_ref(neigh_node); | ||
450 | } | 469 | } |
451 | rcu_read_unlock(); | 470 | rcu_read_unlock(); |
452 | } | 471 | } |
453 | 472 | ||
454 | if ((batman_count == 0)) | 473 | if (batman_count == 0) |
455 | seq_printf(seq, "No batman nodes in range ...\n"); | 474 | seq_printf(seq, "No batman nodes in range ...\n"); |
456 | 475 | ||
457 | return 0; | 476 | return 0; |
diff --git a/net/batman-adv/originator.h b/net/batman-adv/originator.h index 5cc011057da1..e1d641f27aa9 100644 --- a/net/batman-adv/originator.h +++ b/net/batman-adv/originator.h | |||
@@ -34,6 +34,7 @@ struct neigh_node *create_neighbor(struct orig_node *orig_node, | |||
34 | uint8_t *neigh, | 34 | uint8_t *neigh, |
35 | struct hard_iface *if_incoming); | 35 | struct hard_iface *if_incoming); |
36 | void neigh_node_free_ref(struct neigh_node *neigh_node); | 36 | void neigh_node_free_ref(struct neigh_node *neigh_node); |
37 | struct neigh_node *orig_node_get_router(struct orig_node *orig_node); | ||
37 | int orig_seq_print_text(struct seq_file *seq, void *offset); | 38 | int orig_seq_print_text(struct seq_file *seq, void *offset); |
38 | int orig_hash_add_if(struct hard_iface *hard_iface, int max_if_num); | 39 | int orig_hash_add_if(struct hard_iface *hard_iface, int max_if_num); |
39 | int orig_hash_del_if(struct hard_iface *hard_iface, int max_if_num); | 40 | int orig_hash_del_if(struct hard_iface *hard_iface, int max_if_num); |
diff --git a/net/batman-adv/routing.c b/net/batman-adv/routing.c index f212abe745bc..b7d43caaa9c8 100644 --- a/net/batman-adv/routing.c +++ b/net/batman-adv/routing.c | |||
@@ -87,18 +87,20 @@ static void update_route(struct bat_priv *bat_priv, | |||
87 | struct neigh_node *neigh_node, | 87 | struct neigh_node *neigh_node, |
88 | unsigned char *hna_buff, int hna_buff_len) | 88 | unsigned char *hna_buff, int hna_buff_len) |
89 | { | 89 | { |
90 | struct neigh_node *neigh_node_tmp; | 90 | struct neigh_node *curr_router; |
91 | |||
92 | curr_router = orig_node_get_router(orig_node); | ||
91 | 93 | ||
92 | /* route deleted */ | 94 | /* route deleted */ |
93 | if ((orig_node->router) && (!neigh_node)) { | 95 | if ((curr_router) && (!neigh_node)) { |
94 | 96 | ||
95 | bat_dbg(DBG_ROUTES, bat_priv, "Deleting route towards: %pM\n", | 97 | bat_dbg(DBG_ROUTES, bat_priv, "Deleting route towards: %pM\n", |
96 | orig_node->orig); | 98 | orig_node->orig); |
97 | hna_global_del_orig(bat_priv, orig_node, | 99 | hna_global_del_orig(bat_priv, orig_node, |
98 | "originator timed out"); | 100 | "originator timed out"); |
99 | 101 | ||
100 | /* route added */ | 102 | /* route added */ |
101 | } else if ((!orig_node->router) && (neigh_node)) { | 103 | } else if ((!curr_router) && (neigh_node)) { |
102 | 104 | ||
103 | bat_dbg(DBG_ROUTES, bat_priv, | 105 | bat_dbg(DBG_ROUTES, bat_priv, |
104 | "Adding route towards: %pM (via %pM)\n", | 106 | "Adding route towards: %pM (via %pM)\n", |
@@ -106,21 +108,29 @@ static void update_route(struct bat_priv *bat_priv, | |||
106 | hna_global_add_orig(bat_priv, orig_node, | 108 | hna_global_add_orig(bat_priv, orig_node, |
107 | hna_buff, hna_buff_len); | 109 | hna_buff, hna_buff_len); |
108 | 110 | ||
109 | /* route changed */ | 111 | /* route changed */ |
110 | } else { | 112 | } else { |
111 | bat_dbg(DBG_ROUTES, bat_priv, | 113 | bat_dbg(DBG_ROUTES, bat_priv, |
112 | "Changing route towards: %pM " | 114 | "Changing route towards: %pM " |
113 | "(now via %pM - was via %pM)\n", | 115 | "(now via %pM - was via %pM)\n", |
114 | orig_node->orig, neigh_node->addr, | 116 | orig_node->orig, neigh_node->addr, |
115 | orig_node->router->addr); | 117 | curr_router->addr); |
116 | } | 118 | } |
117 | 119 | ||
120 | if (curr_router) | ||
121 | neigh_node_free_ref(curr_router); | ||
122 | |||
123 | /* increase refcount of new best neighbor */ | ||
118 | if (neigh_node && !atomic_inc_not_zero(&neigh_node->refcount)) | 124 | if (neigh_node && !atomic_inc_not_zero(&neigh_node->refcount)) |
119 | neigh_node = NULL; | 125 | neigh_node = NULL; |
120 | neigh_node_tmp = orig_node->router; | 126 | |
121 | orig_node->router = neigh_node; | 127 | spin_lock_bh(&orig_node->neigh_list_lock); |
122 | if (neigh_node_tmp) | 128 | rcu_assign_pointer(orig_node->router, neigh_node); |
123 | neigh_node_free_ref(neigh_node_tmp); | 129 | spin_unlock_bh(&orig_node->neigh_list_lock); |
130 | |||
131 | /* decrease refcount of previous best neighbor */ | ||
132 | if (curr_router) | ||
133 | neigh_node_free_ref(curr_router); | ||
124 | } | 134 | } |
125 | 135 | ||
126 | 136 | ||
@@ -128,16 +138,23 @@ void update_routes(struct bat_priv *bat_priv, struct orig_node *orig_node, | |||
128 | struct neigh_node *neigh_node, unsigned char *hna_buff, | 138 | struct neigh_node *neigh_node, unsigned char *hna_buff, |
129 | int hna_buff_len) | 139 | int hna_buff_len) |
130 | { | 140 | { |
141 | struct neigh_node *router = NULL; | ||
131 | 142 | ||
132 | if (!orig_node) | 143 | if (!orig_node) |
133 | return; | 144 | goto out; |
145 | |||
146 | router = orig_node_get_router(orig_node); | ||
134 | 147 | ||
135 | if (orig_node->router != neigh_node) | 148 | if (router != neigh_node) |
136 | update_route(bat_priv, orig_node, neigh_node, | 149 | update_route(bat_priv, orig_node, neigh_node, |
137 | hna_buff, hna_buff_len); | 150 | hna_buff, hna_buff_len); |
138 | /* may be just HNA changed */ | 151 | /* may be just HNA changed */ |
139 | else | 152 | else |
140 | update_HNA(bat_priv, orig_node, hna_buff, hna_buff_len); | 153 | update_HNA(bat_priv, orig_node, hna_buff, hna_buff_len); |
154 | |||
155 | out: | ||
156 | if (router) | ||
157 | neigh_node_free_ref(router); | ||
141 | } | 158 | } |
142 | 159 | ||
143 | static int is_bidirectional_neigh(struct orig_node *orig_node, | 160 | static int is_bidirectional_neigh(struct orig_node *orig_node, |
@@ -288,8 +305,8 @@ static void bonding_candidate_add(struct orig_node *orig_node, | |||
288 | struct neigh_node *neigh_node) | 305 | struct neigh_node *neigh_node) |
289 | { | 306 | { |
290 | struct hlist_node *node; | 307 | struct hlist_node *node; |
291 | struct neigh_node *tmp_neigh_node; | 308 | struct neigh_node *tmp_neigh_node, *router = NULL; |
292 | uint8_t best_tq, interference_candidate = 0; | 309 | uint8_t interference_candidate = 0; |
293 | 310 | ||
294 | spin_lock_bh(&orig_node->neigh_list_lock); | 311 | spin_lock_bh(&orig_node->neigh_list_lock); |
295 | 312 | ||
@@ -298,13 +315,12 @@ static void bonding_candidate_add(struct orig_node *orig_node, | |||
298 | neigh_node->orig_node->primary_addr)) | 315 | neigh_node->orig_node->primary_addr)) |
299 | goto candidate_del; | 316 | goto candidate_del; |
300 | 317 | ||
301 | if (!orig_node->router) | 318 | router = orig_node_get_router(orig_node); |
319 | if (!router) | ||
302 | goto candidate_del; | 320 | goto candidate_del; |
303 | 321 | ||
304 | best_tq = orig_node->router->tq_avg; | ||
305 | |||
306 | /* ... and is good enough to be considered */ | 322 | /* ... and is good enough to be considered */ |
307 | if (neigh_node->tq_avg < best_tq - BONDING_TQ_THRESHOLD) | 323 | if (neigh_node->tq_avg < router->tq_avg - BONDING_TQ_THRESHOLD) |
308 | goto candidate_del; | 324 | goto candidate_del; |
309 | 325 | ||
310 | /** | 326 | /** |
@@ -350,7 +366,9 @@ candidate_del: | |||
350 | 366 | ||
351 | out: | 367 | out: |
352 | spin_unlock_bh(&orig_node->neigh_list_lock); | 368 | spin_unlock_bh(&orig_node->neigh_list_lock); |
353 | return; | 369 | |
370 | if (router) | ||
371 | neigh_node_free_ref(router); | ||
354 | } | 372 | } |
355 | 373 | ||
356 | /* copy primary address for bonding */ | 374 | /* copy primary address for bonding */ |
@@ -373,6 +391,7 @@ static void update_orig(struct bat_priv *bat_priv, | |||
373 | char is_duplicate) | 391 | char is_duplicate) |
374 | { | 392 | { |
375 | struct neigh_node *neigh_node = NULL, *tmp_neigh_node = NULL; | 393 | struct neigh_node *neigh_node = NULL, *tmp_neigh_node = NULL; |
394 | struct neigh_node *router = NULL; | ||
376 | struct orig_node *orig_node_tmp; | 395 | struct orig_node *orig_node_tmp; |
377 | struct hlist_node *node; | 396 | struct hlist_node *node; |
378 | int tmp_hna_buff_len; | 397 | int tmp_hna_buff_len; |
@@ -441,19 +460,18 @@ static void update_orig(struct bat_priv *bat_priv, | |||
441 | 460 | ||
442 | /* if this neighbor already is our next hop there is nothing | 461 | /* if this neighbor already is our next hop there is nothing |
443 | * to change */ | 462 | * to change */ |
444 | if (orig_node->router == neigh_node) | 463 | router = orig_node_get_router(orig_node); |
464 | if (router == neigh_node) | ||
445 | goto update_hna; | 465 | goto update_hna; |
446 | 466 | ||
447 | /* if this neighbor does not offer a better TQ we won't consider it */ | 467 | /* if this neighbor does not offer a better TQ we won't consider it */ |
448 | if ((orig_node->router) && | 468 | if (router && (router->tq_avg > neigh_node->tq_avg)) |
449 | (orig_node->router->tq_avg > neigh_node->tq_avg)) | ||
450 | goto update_hna; | 469 | goto update_hna; |
451 | 470 | ||
452 | /* if the TQ is the same and the link not more symetric we | 471 | /* if the TQ is the same and the link not more symetric we |
453 | * won't consider it either */ | 472 | * won't consider it either */ |
454 | if ((orig_node->router) && | 473 | if (router && (neigh_node->tq_avg == router->tq_avg)) { |
455 | (neigh_node->tq_avg == orig_node->router->tq_avg)) { | 474 | orig_node_tmp = router->orig_node; |
456 | orig_node_tmp = orig_node->router->orig_node; | ||
457 | spin_lock_bh(&orig_node_tmp->ogm_cnt_lock); | 475 | spin_lock_bh(&orig_node_tmp->ogm_cnt_lock); |
458 | bcast_own_sum_orig = | 476 | bcast_own_sum_orig = |
459 | orig_node_tmp->bcast_own_sum[if_incoming->if_num]; | 477 | orig_node_tmp->bcast_own_sum[if_incoming->if_num]; |
@@ -474,7 +492,7 @@ static void update_orig(struct bat_priv *bat_priv, | |||
474 | goto update_gw; | 492 | goto update_gw; |
475 | 493 | ||
476 | update_hna: | 494 | update_hna: |
477 | update_routes(bat_priv, orig_node, orig_node->router, | 495 | update_routes(bat_priv, orig_node, router, |
478 | hna_buff, tmp_hna_buff_len); | 496 | hna_buff, tmp_hna_buff_len); |
479 | 497 | ||
480 | update_gw: | 498 | update_gw: |
@@ -496,6 +514,8 @@ unlock: | |||
496 | out: | 514 | out: |
497 | if (neigh_node) | 515 | if (neigh_node) |
498 | neigh_node_free_ref(neigh_node); | 516 | neigh_node_free_ref(neigh_node); |
517 | if (router) | ||
518 | neigh_node_free_ref(router); | ||
499 | } | 519 | } |
500 | 520 | ||
501 | /* checks whether the host restarted and is in the protection time. | 521 | /* checks whether the host restarted and is in the protection time. |
@@ -603,6 +623,8 @@ void receive_bat_packet(struct ethhdr *ethhdr, | |||
603 | struct bat_priv *bat_priv = netdev_priv(if_incoming->soft_iface); | 623 | struct bat_priv *bat_priv = netdev_priv(if_incoming->soft_iface); |
604 | struct hard_iface *hard_iface; | 624 | struct hard_iface *hard_iface; |
605 | struct orig_node *orig_neigh_node, *orig_node; | 625 | struct orig_node *orig_neigh_node, *orig_node; |
626 | struct neigh_node *router = NULL, *router_router = NULL; | ||
627 | struct neigh_node *orig_neigh_router = NULL; | ||
606 | char has_directlink_flag; | 628 | char has_directlink_flag; |
607 | char is_my_addr = 0, is_my_orig = 0, is_my_oldorig = 0; | 629 | char is_my_addr = 0, is_my_orig = 0, is_my_oldorig = 0; |
608 | char is_broadcast = 0, is_bidirectional, is_single_hop_neigh; | 630 | char is_broadcast = 0, is_bidirectional, is_single_hop_neigh; |
@@ -747,14 +769,15 @@ void receive_bat_packet(struct ethhdr *ethhdr, | |||
747 | goto out; | 769 | goto out; |
748 | } | 770 | } |
749 | 771 | ||
772 | router = orig_node_get_router(orig_node); | ||
773 | if (router) | ||
774 | router_router = orig_node_get_router(router->orig_node); | ||
775 | |||
750 | /* avoid temporary routing loops */ | 776 | /* avoid temporary routing loops */ |
751 | if ((orig_node->router) && | 777 | if (router && router_router && |
752 | (orig_node->router->orig_node->router) && | 778 | (compare_eth(router->addr, batman_packet->prev_sender)) && |
753 | (compare_eth(orig_node->router->addr, | ||
754 | batman_packet->prev_sender)) && | ||
755 | !(compare_eth(batman_packet->orig, batman_packet->prev_sender)) && | 779 | !(compare_eth(batman_packet->orig, batman_packet->prev_sender)) && |
756 | (compare_eth(orig_node->router->addr, | 780 | (compare_eth(router->addr, router_router->addr))) { |
757 | orig_node->router->orig_node->router->addr))) { | ||
758 | bat_dbg(DBG_BATMAN, bat_priv, | 781 | bat_dbg(DBG_BATMAN, bat_priv, |
759 | "Drop packet: ignoring all rebroadcast packets that " | 782 | "Drop packet: ignoring all rebroadcast packets that " |
760 | "may make me loop (sender: %pM)\n", ethhdr->h_source); | 783 | "may make me loop (sender: %pM)\n", ethhdr->h_source); |
@@ -769,9 +792,11 @@ void receive_bat_packet(struct ethhdr *ethhdr, | |||
769 | if (!orig_neigh_node) | 792 | if (!orig_neigh_node) |
770 | goto out; | 793 | goto out; |
771 | 794 | ||
795 | orig_neigh_router = orig_node_get_router(orig_neigh_node); | ||
796 | |||
772 | /* drop packet if sender is not a direct neighbor and if we | 797 | /* drop packet if sender is not a direct neighbor and if we |
773 | * don't route towards it */ | 798 | * don't route towards it */ |
774 | if (!is_single_hop_neigh && (!orig_neigh_node->router)) { | 799 | if (!is_single_hop_neigh && (!orig_neigh_router)) { |
775 | bat_dbg(DBG_BATMAN, bat_priv, | 800 | bat_dbg(DBG_BATMAN, bat_priv, |
776 | "Drop packet: OGM via unknown neighbor!\n"); | 801 | "Drop packet: OGM via unknown neighbor!\n"); |
777 | goto out_neigh; | 802 | goto out_neigh; |
@@ -825,6 +850,13 @@ out_neigh: | |||
825 | if ((orig_neigh_node) && (!is_single_hop_neigh)) | 850 | if ((orig_neigh_node) && (!is_single_hop_neigh)) |
826 | orig_node_free_ref(orig_neigh_node); | 851 | orig_node_free_ref(orig_neigh_node); |
827 | out: | 852 | out: |
853 | if (router) | ||
854 | neigh_node_free_ref(router); | ||
855 | if (router_router) | ||
856 | neigh_node_free_ref(router_router); | ||
857 | if (orig_neigh_router) | ||
858 | neigh_node_free_ref(orig_neigh_router); | ||
859 | |||
828 | orig_node_free_ref(orig_node); | 860 | orig_node_free_ref(orig_node); |
829 | } | 861 | } |
830 | 862 | ||
@@ -869,7 +901,7 @@ static int recv_my_icmp_packet(struct bat_priv *bat_priv, | |||
869 | struct sk_buff *skb, size_t icmp_len) | 901 | struct sk_buff *skb, size_t icmp_len) |
870 | { | 902 | { |
871 | struct orig_node *orig_node = NULL; | 903 | struct orig_node *orig_node = NULL; |
872 | struct neigh_node *neigh_node = NULL; | 904 | struct neigh_node *router = NULL; |
873 | struct icmp_packet_rr *icmp_packet; | 905 | struct icmp_packet_rr *icmp_packet; |
874 | int ret = NET_RX_DROP; | 906 | int ret = NET_RX_DROP; |
875 | 907 | ||
@@ -886,23 +918,13 @@ static int recv_my_icmp_packet(struct bat_priv *bat_priv, | |||
886 | 918 | ||
887 | /* answer echo request (ping) */ | 919 | /* answer echo request (ping) */ |
888 | /* get routing information */ | 920 | /* get routing information */ |
889 | rcu_read_lock(); | ||
890 | orig_node = orig_hash_find(bat_priv, icmp_packet->orig); | 921 | orig_node = orig_hash_find(bat_priv, icmp_packet->orig); |
891 | |||
892 | if (!orig_node) | 922 | if (!orig_node) |
893 | goto unlock; | 923 | goto out; |
894 | |||
895 | neigh_node = orig_node->router; | ||
896 | |||
897 | if (!neigh_node) | ||
898 | goto unlock; | ||
899 | |||
900 | if (!atomic_inc_not_zero(&neigh_node->refcount)) { | ||
901 | neigh_node = NULL; | ||
902 | goto unlock; | ||
903 | } | ||
904 | 924 | ||
905 | rcu_read_unlock(); | 925 | router = orig_node_get_router(orig_node); |
926 | if (!router) | ||
927 | goto out; | ||
906 | 928 | ||
907 | /* create a copy of the skb, if needed, to modify it. */ | 929 | /* create a copy of the skb, if needed, to modify it. */ |
908 | if (skb_cow(skb, sizeof(struct ethhdr)) < 0) | 930 | if (skb_cow(skb, sizeof(struct ethhdr)) < 0) |
@@ -916,15 +938,12 @@ static int recv_my_icmp_packet(struct bat_priv *bat_priv, | |||
916 | icmp_packet->msg_type = ECHO_REPLY; | 938 | icmp_packet->msg_type = ECHO_REPLY; |
917 | icmp_packet->ttl = TTL; | 939 | icmp_packet->ttl = TTL; |
918 | 940 | ||
919 | send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); | 941 | send_skb_packet(skb, router->if_incoming, router->addr); |
920 | ret = NET_RX_SUCCESS; | 942 | ret = NET_RX_SUCCESS; |
921 | goto out; | ||
922 | 943 | ||
923 | unlock: | ||
924 | rcu_read_unlock(); | ||
925 | out: | 944 | out: |
926 | if (neigh_node) | 945 | if (router) |
927 | neigh_node_free_ref(neigh_node); | 946 | neigh_node_free_ref(router); |
928 | if (orig_node) | 947 | if (orig_node) |
929 | orig_node_free_ref(orig_node); | 948 | orig_node_free_ref(orig_node); |
930 | return ret; | 949 | return ret; |
@@ -934,7 +953,7 @@ static int recv_icmp_ttl_exceeded(struct bat_priv *bat_priv, | |||
934 | struct sk_buff *skb) | 953 | struct sk_buff *skb) |
935 | { | 954 | { |
936 | struct orig_node *orig_node = NULL; | 955 | struct orig_node *orig_node = NULL; |
937 | struct neigh_node *neigh_node = NULL; | 956 | struct neigh_node *router = NULL; |
938 | struct icmp_packet *icmp_packet; | 957 | struct icmp_packet *icmp_packet; |
939 | int ret = NET_RX_DROP; | 958 | int ret = NET_RX_DROP; |
940 | 959 | ||
@@ -952,23 +971,13 @@ static int recv_icmp_ttl_exceeded(struct bat_priv *bat_priv, | |||
952 | goto out; | 971 | goto out; |
953 | 972 | ||
954 | /* get routing information */ | 973 | /* get routing information */ |
955 | rcu_read_lock(); | ||
956 | orig_node = orig_hash_find(bat_priv, icmp_packet->orig); | 974 | orig_node = orig_hash_find(bat_priv, icmp_packet->orig); |
957 | |||
958 | if (!orig_node) | 975 | if (!orig_node) |
959 | goto unlock; | 976 | goto out; |
960 | |||
961 | neigh_node = orig_node->router; | ||
962 | |||
963 | if (!neigh_node) | ||
964 | goto unlock; | ||
965 | |||
966 | if (!atomic_inc_not_zero(&neigh_node->refcount)) { | ||
967 | neigh_node = NULL; | ||
968 | goto unlock; | ||
969 | } | ||
970 | 977 | ||
971 | rcu_read_unlock(); | 978 | router = orig_node_get_router(orig_node); |
979 | if (!router) | ||
980 | goto out; | ||
972 | 981 | ||
973 | /* create a copy of the skb, if needed, to modify it. */ | 982 | /* create a copy of the skb, if needed, to modify it. */ |
974 | if (skb_cow(skb, sizeof(struct ethhdr)) < 0) | 983 | if (skb_cow(skb, sizeof(struct ethhdr)) < 0) |
@@ -982,15 +991,12 @@ static int recv_icmp_ttl_exceeded(struct bat_priv *bat_priv, | |||
982 | icmp_packet->msg_type = TTL_EXCEEDED; | 991 | icmp_packet->msg_type = TTL_EXCEEDED; |
983 | icmp_packet->ttl = TTL; | 992 | icmp_packet->ttl = TTL; |
984 | 993 | ||
985 | send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); | 994 | send_skb_packet(skb, router->if_incoming, router->addr); |
986 | ret = NET_RX_SUCCESS; | 995 | ret = NET_RX_SUCCESS; |
987 | goto out; | ||
988 | 996 | ||
989 | unlock: | ||
990 | rcu_read_unlock(); | ||
991 | out: | 997 | out: |
992 | if (neigh_node) | 998 | if (router) |
993 | neigh_node_free_ref(neigh_node); | 999 | neigh_node_free_ref(router); |
994 | if (orig_node) | 1000 | if (orig_node) |
995 | orig_node_free_ref(orig_node); | 1001 | orig_node_free_ref(orig_node); |
996 | return ret; | 1002 | return ret; |
@@ -1003,7 +1009,7 @@ int recv_icmp_packet(struct sk_buff *skb, struct hard_iface *recv_if) | |||
1003 | struct icmp_packet_rr *icmp_packet; | 1009 | struct icmp_packet_rr *icmp_packet; |
1004 | struct ethhdr *ethhdr; | 1010 | struct ethhdr *ethhdr; |
1005 | struct orig_node *orig_node = NULL; | 1011 | struct orig_node *orig_node = NULL; |
1006 | struct neigh_node *neigh_node = NULL; | 1012 | struct neigh_node *router = NULL; |
1007 | int hdr_size = sizeof(struct icmp_packet); | 1013 | int hdr_size = sizeof(struct icmp_packet); |
1008 | int ret = NET_RX_DROP; | 1014 | int ret = NET_RX_DROP; |
1009 | 1015 | ||
@@ -1050,23 +1056,13 @@ int recv_icmp_packet(struct sk_buff *skb, struct hard_iface *recv_if) | |||
1050 | return recv_icmp_ttl_exceeded(bat_priv, skb); | 1056 | return recv_icmp_ttl_exceeded(bat_priv, skb); |
1051 | 1057 | ||
1052 | /* get routing information */ | 1058 | /* get routing information */ |
1053 | rcu_read_lock(); | ||
1054 | orig_node = orig_hash_find(bat_priv, icmp_packet->dst); | 1059 | orig_node = orig_hash_find(bat_priv, icmp_packet->dst); |
1055 | |||
1056 | if (!orig_node) | 1060 | if (!orig_node) |
1057 | goto unlock; | 1061 | goto out; |
1058 | |||
1059 | neigh_node = orig_node->router; | ||
1060 | |||
1061 | if (!neigh_node) | ||
1062 | goto unlock; | ||
1063 | |||
1064 | if (!atomic_inc_not_zero(&neigh_node->refcount)) { | ||
1065 | neigh_node = NULL; | ||
1066 | goto unlock; | ||
1067 | } | ||
1068 | 1062 | ||
1069 | rcu_read_unlock(); | 1063 | router = orig_node_get_router(orig_node); |
1064 | if (!router) | ||
1065 | goto out; | ||
1070 | 1066 | ||
1071 | /* create a copy of the skb, if needed, to modify it. */ | 1067 | /* create a copy of the skb, if needed, to modify it. */ |
1072 | if (skb_cow(skb, sizeof(struct ethhdr)) < 0) | 1068 | if (skb_cow(skb, sizeof(struct ethhdr)) < 0) |
@@ -1078,15 +1074,12 @@ int recv_icmp_packet(struct sk_buff *skb, struct hard_iface *recv_if) | |||
1078 | icmp_packet->ttl--; | 1074 | icmp_packet->ttl--; |
1079 | 1075 | ||
1080 | /* route it */ | 1076 | /* route it */ |
1081 | send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); | 1077 | send_skb_packet(skb, router->if_incoming, router->addr); |
1082 | ret = NET_RX_SUCCESS; | 1078 | ret = NET_RX_SUCCESS; |
1083 | goto out; | ||
1084 | 1079 | ||
1085 | unlock: | ||
1086 | rcu_read_unlock(); | ||
1087 | out: | 1080 | out: |
1088 | if (neigh_node) | 1081 | if (router) |
1089 | neigh_node_free_ref(neigh_node); | 1082 | neigh_node_free_ref(router); |
1090 | if (orig_node) | 1083 | if (orig_node) |
1091 | orig_node_free_ref(orig_node); | 1084 | orig_node_free_ref(orig_node); |
1092 | return ret; | 1085 | return ret; |
@@ -1208,7 +1201,8 @@ struct neigh_node *find_router(struct bat_priv *bat_priv, | |||
1208 | if (!orig_node) | 1201 | if (!orig_node) |
1209 | return NULL; | 1202 | return NULL; |
1210 | 1203 | ||
1211 | if (!orig_node->router) | 1204 | router = orig_node_get_router(orig_node); |
1205 | if (!router) | ||
1212 | return NULL; | 1206 | return NULL; |
1213 | 1207 | ||
1214 | /* without bonding, the first node should | 1208 | /* without bonding, the first node should |
@@ -1217,9 +1211,8 @@ struct neigh_node *find_router(struct bat_priv *bat_priv, | |||
1217 | 1211 | ||
1218 | rcu_read_lock(); | 1212 | rcu_read_lock(); |
1219 | /* select default router to output */ | 1213 | /* select default router to output */ |
1220 | router = orig_node->router; | 1214 | router_orig = router->orig_node; |
1221 | router_orig = orig_node->router->orig_node; | 1215 | if (!router_orig) { |
1222 | if (!router_orig || !atomic_inc_not_zero(&router->refcount)) { | ||
1223 | rcu_read_unlock(); | 1216 | rcu_read_unlock(); |
1224 | return NULL; | 1217 | return NULL; |
1225 | } | 1218 | } |
@@ -1251,7 +1244,6 @@ struct neigh_node *find_router(struct bat_priv *bat_priv, | |||
1251 | if (atomic_read(&primary_orig_node->bond_candidates) < 2) | 1244 | if (atomic_read(&primary_orig_node->bond_candidates) < 2) |
1252 | goto return_router; | 1245 | goto return_router; |
1253 | 1246 | ||
1254 | |||
1255 | /* all nodes between should choose a candidate which | 1247 | /* all nodes between should choose a candidate which |
1256 | * is is not on the interface where the packet came | 1248 | * is is not on the interface where the packet came |
1257 | * in. */ | 1249 | * in. */ |
diff --git a/net/batman-adv/send.c b/net/batman-adv/send.c index d49e54d932af..e78670c3c4b7 100644 --- a/net/batman-adv/send.c +++ b/net/batman-adv/send.c | |||
@@ -308,6 +308,7 @@ void schedule_forward_packet(struct orig_node *orig_node, | |||
308 | struct hard_iface *if_incoming) | 308 | struct hard_iface *if_incoming) |
309 | { | 309 | { |
310 | struct bat_priv *bat_priv = netdev_priv(if_incoming->soft_iface); | 310 | struct bat_priv *bat_priv = netdev_priv(if_incoming->soft_iface); |
311 | struct neigh_node *router; | ||
311 | unsigned char in_tq, in_ttl, tq_avg = 0; | 312 | unsigned char in_tq, in_ttl, tq_avg = 0; |
312 | unsigned long send_time; | 313 | unsigned long send_time; |
313 | 314 | ||
@@ -316,6 +317,8 @@ void schedule_forward_packet(struct orig_node *orig_node, | |||
316 | return; | 317 | return; |
317 | } | 318 | } |
318 | 319 | ||
320 | router = orig_node_get_router(orig_node); | ||
321 | |||
319 | in_tq = batman_packet->tq; | 322 | in_tq = batman_packet->tq; |
320 | in_ttl = batman_packet->ttl; | 323 | in_ttl = batman_packet->ttl; |
321 | 324 | ||
@@ -324,20 +327,22 @@ void schedule_forward_packet(struct orig_node *orig_node, | |||
324 | 327 | ||
325 | /* rebroadcast tq of our best ranking neighbor to ensure the rebroadcast | 328 | /* rebroadcast tq of our best ranking neighbor to ensure the rebroadcast |
326 | * of our best tq value */ | 329 | * of our best tq value */ |
327 | if ((orig_node->router) && (orig_node->router->tq_avg != 0)) { | 330 | if (router && router->tq_avg != 0) { |
328 | 331 | ||
329 | /* rebroadcast ogm of best ranking neighbor as is */ | 332 | /* rebroadcast ogm of best ranking neighbor as is */ |
330 | if (!compare_eth(orig_node->router->addr, ethhdr->h_source)) { | 333 | if (!compare_eth(router->addr, ethhdr->h_source)) { |
331 | batman_packet->tq = orig_node->router->tq_avg; | 334 | batman_packet->tq = router->tq_avg; |
332 | 335 | ||
333 | if (orig_node->router->last_ttl) | 336 | if (router->last_ttl) |
334 | batman_packet->ttl = orig_node->router->last_ttl | 337 | batman_packet->ttl = router->last_ttl - 1; |
335 | - 1; | ||
336 | } | 338 | } |
337 | 339 | ||
338 | tq_avg = orig_node->router->tq_avg; | 340 | tq_avg = router->tq_avg; |
339 | } | 341 | } |
340 | 342 | ||
343 | if (router) | ||
344 | neigh_node_free_ref(router); | ||
345 | |||
341 | /* apply hop penalty */ | 346 | /* apply hop penalty */ |
342 | batman_packet->tq = hop_penalty(batman_packet->tq, bat_priv); | 347 | batman_packet->tq = hop_penalty(batman_packet->tq, bat_priv); |
343 | 348 | ||
diff --git a/net/batman-adv/types.h b/net/batman-adv/types.h index 83445cf0cc9f..1854cbb4c1b6 100644 --- a/net/batman-adv/types.h +++ b/net/batman-adv/types.h | |||
@@ -67,7 +67,7 @@ struct hard_iface { | |||
67 | struct orig_node { | 67 | struct orig_node { |
68 | uint8_t orig[ETH_ALEN]; | 68 | uint8_t orig[ETH_ALEN]; |
69 | uint8_t primary_addr[ETH_ALEN]; | 69 | uint8_t primary_addr[ETH_ALEN]; |
70 | struct neigh_node *router; | 70 | struct neigh_node __rcu *router; /* rcu protected pointer */ |
71 | unsigned long *bcast_own; | 71 | unsigned long *bcast_own; |
72 | uint8_t *bcast_own_sum; | 72 | uint8_t *bcast_own_sum; |
73 | unsigned long last_valid; | 73 | unsigned long last_valid; |
@@ -83,7 +83,7 @@ struct orig_node { | |||
83 | uint32_t last_bcast_seqno; | 83 | uint32_t last_bcast_seqno; |
84 | struct hlist_head neigh_list; | 84 | struct hlist_head neigh_list; |
85 | struct list_head frag_list; | 85 | struct list_head frag_list; |
86 | spinlock_t neigh_list_lock; /* protects neighbor list */ | 86 | spinlock_t neigh_list_lock; /* protects neigh_list and router */ |
87 | atomic_t refcount; | 87 | atomic_t refcount; |
88 | struct rcu_head rcu; | 88 | struct rcu_head rcu; |
89 | struct hlist_node hash_entry; | 89 | struct hlist_node hash_entry; |
diff --git a/net/batman-adv/vis.c b/net/batman-adv/vis.c index f90212f42082..d4cc4f5399f4 100644 --- a/net/batman-adv/vis.c +++ b/net/batman-adv/vis.c | |||
@@ -558,6 +558,7 @@ static int find_best_vis_server(struct bat_priv *bat_priv, | |||
558 | struct vis_info *info) | 558 | struct vis_info *info) |
559 | { | 559 | { |
560 | struct hashtable_t *hash = bat_priv->orig_hash; | 560 | struct hashtable_t *hash = bat_priv->orig_hash; |
561 | struct neigh_node *router; | ||
561 | struct hlist_node *node; | 562 | struct hlist_node *node; |
562 | struct hlist_head *head; | 563 | struct hlist_head *head; |
563 | struct orig_node *orig_node; | 564 | struct orig_node *orig_node; |
@@ -571,13 +572,17 @@ static int find_best_vis_server(struct bat_priv *bat_priv, | |||
571 | 572 | ||
572 | rcu_read_lock(); | 573 | rcu_read_lock(); |
573 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { | 574 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { |
574 | if ((orig_node) && (orig_node->router) && | 575 | router = orig_node_get_router(orig_node); |
575 | (orig_node->flags & VIS_SERVER) && | 576 | if (!router) |
576 | (orig_node->router->tq_avg > best_tq)) { | 577 | continue; |
577 | best_tq = orig_node->router->tq_avg; | 578 | |
579 | if ((orig_node->flags & VIS_SERVER) && | ||
580 | (router->tq_avg > best_tq)) { | ||
581 | best_tq = router->tq_avg; | ||
578 | memcpy(packet->target_orig, orig_node->orig, | 582 | memcpy(packet->target_orig, orig_node->orig, |
579 | ETH_ALEN); | 583 | ETH_ALEN); |
580 | } | 584 | } |
585 | neigh_node_free_ref(router); | ||
581 | } | 586 | } |
582 | rcu_read_unlock(); | 587 | rcu_read_unlock(); |
583 | } | 588 | } |
@@ -605,7 +610,7 @@ static int generate_vis_packet(struct bat_priv *bat_priv) | |||
605 | struct hlist_node *node; | 610 | struct hlist_node *node; |
606 | struct hlist_head *head; | 611 | struct hlist_head *head; |
607 | struct orig_node *orig_node; | 612 | struct orig_node *orig_node; |
608 | struct neigh_node *neigh_node; | 613 | struct neigh_node *router; |
609 | struct vis_info *info = (struct vis_info *)bat_priv->my_vis_info; | 614 | struct vis_info *info = (struct vis_info *)bat_priv->my_vis_info; |
610 | struct vis_packet *packet = (struct vis_packet *)info->skb_packet->data; | 615 | struct vis_packet *packet = (struct vis_packet *)info->skb_packet->data; |
611 | struct vis_info_entry *entry; | 616 | struct vis_info_entry *entry; |
@@ -633,30 +638,32 @@ static int generate_vis_packet(struct bat_priv *bat_priv) | |||
633 | 638 | ||
634 | rcu_read_lock(); | 639 | rcu_read_lock(); |
635 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { | 640 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { |
636 | neigh_node = orig_node->router; | 641 | router = orig_node_get_router(orig_node); |
637 | 642 | if (!router) | |
638 | if (!neigh_node) | ||
639 | continue; | 643 | continue; |
640 | 644 | ||
641 | if (!compare_eth(neigh_node->addr, orig_node->orig)) | 645 | if (!compare_eth(router->addr, orig_node->orig)) |
642 | continue; | 646 | goto next; |
643 | 647 | ||
644 | if (neigh_node->if_incoming->if_status != IF_ACTIVE) | 648 | if (router->if_incoming->if_status != IF_ACTIVE) |
645 | continue; | 649 | goto next; |
646 | 650 | ||
647 | if (neigh_node->tq_avg < 1) | 651 | if (router->tq_avg < 1) |
648 | continue; | 652 | goto next; |
649 | 653 | ||
650 | /* fill one entry into buffer. */ | 654 | /* fill one entry into buffer. */ |
651 | entry = (struct vis_info_entry *) | 655 | entry = (struct vis_info_entry *) |
652 | skb_put(info->skb_packet, sizeof(*entry)); | 656 | skb_put(info->skb_packet, sizeof(*entry)); |
653 | memcpy(entry->src, | 657 | memcpy(entry->src, |
654 | neigh_node->if_incoming->net_dev->dev_addr, | 658 | router->if_incoming->net_dev->dev_addr, |
655 | ETH_ALEN); | 659 | ETH_ALEN); |
656 | memcpy(entry->dest, orig_node->orig, ETH_ALEN); | 660 | memcpy(entry->dest, orig_node->orig, ETH_ALEN); |
657 | entry->quality = neigh_node->tq_avg; | 661 | entry->quality = router->tq_avg; |
658 | packet->entries++; | 662 | packet->entries++; |
659 | 663 | ||
664 | next: | ||
665 | neigh_node_free_ref(router); | ||
666 | |||
660 | if (vis_packet_full(info)) | 667 | if (vis_packet_full(info)) |
661 | goto unlock; | 668 | goto unlock; |
662 | } | 669 | } |
@@ -725,6 +732,7 @@ static void purge_vis_packets(struct bat_priv *bat_priv) | |||
725 | static void broadcast_vis_packet(struct bat_priv *bat_priv, | 732 | static void broadcast_vis_packet(struct bat_priv *bat_priv, |
726 | struct vis_info *info) | 733 | struct vis_info *info) |
727 | { | 734 | { |
735 | struct neigh_node *router; | ||
728 | struct hashtable_t *hash = bat_priv->orig_hash; | 736 | struct hashtable_t *hash = bat_priv->orig_hash; |
729 | struct hlist_node *node; | 737 | struct hlist_node *node; |
730 | struct hlist_head *head; | 738 | struct hlist_head *head; |
@@ -745,19 +753,26 @@ static void broadcast_vis_packet(struct bat_priv *bat_priv, | |||
745 | rcu_read_lock(); | 753 | rcu_read_lock(); |
746 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { | 754 | hlist_for_each_entry_rcu(orig_node, node, head, hash_entry) { |
747 | /* if it's a vis server and reachable, send it. */ | 755 | /* if it's a vis server and reachable, send it. */ |
748 | if ((!orig_node) || (!orig_node->router)) | ||
749 | continue; | ||
750 | if (!(orig_node->flags & VIS_SERVER)) | 756 | if (!(orig_node->flags & VIS_SERVER)) |
751 | continue; | 757 | continue; |
758 | |||
759 | router = orig_node_get_router(orig_node); | ||
760 | if (!router) | ||
761 | continue; | ||
762 | |||
752 | /* don't send it if we already received the packet from | 763 | /* don't send it if we already received the packet from |
753 | * this node. */ | 764 | * this node. */ |
754 | if (recv_list_is_in(bat_priv, &info->recv_list, | 765 | if (recv_list_is_in(bat_priv, &info->recv_list, |
755 | orig_node->orig)) | 766 | orig_node->orig)) { |
767 | neigh_node_free_ref(router); | ||
756 | continue; | 768 | continue; |
769 | } | ||
757 | 770 | ||
758 | memcpy(packet->target_orig, orig_node->orig, ETH_ALEN); | 771 | memcpy(packet->target_orig, orig_node->orig, ETH_ALEN); |
759 | hard_iface = orig_node->router->if_incoming; | 772 | hard_iface = router->if_incoming; |
760 | memcpy(dstaddr, orig_node->router->addr, ETH_ALEN); | 773 | memcpy(dstaddr, router->addr, ETH_ALEN); |
774 | |||
775 | neigh_node_free_ref(router); | ||
761 | 776 | ||
762 | skb = skb_clone(info->skb_packet, GFP_ATOMIC); | 777 | skb = skb_clone(info->skb_packet, GFP_ATOMIC); |
763 | if (skb) | 778 | if (skb) |
@@ -772,45 +787,29 @@ static void unicast_vis_packet(struct bat_priv *bat_priv, | |||
772 | struct vis_info *info) | 787 | struct vis_info *info) |
773 | { | 788 | { |
774 | struct orig_node *orig_node; | 789 | struct orig_node *orig_node; |
775 | struct neigh_node *neigh_node = NULL; | 790 | struct neigh_node *router = NULL; |
776 | struct sk_buff *skb; | 791 | struct sk_buff *skb; |
777 | struct vis_packet *packet; | 792 | struct vis_packet *packet; |
778 | 793 | ||
779 | packet = (struct vis_packet *)info->skb_packet->data; | 794 | packet = (struct vis_packet *)info->skb_packet->data; |
780 | 795 | ||
781 | rcu_read_lock(); | ||
782 | orig_node = orig_hash_find(bat_priv, packet->target_orig); | 796 | orig_node = orig_hash_find(bat_priv, packet->target_orig); |
783 | |||
784 | if (!orig_node) | 797 | if (!orig_node) |
785 | goto unlock; | 798 | goto out; |
786 | 799 | ||
787 | neigh_node = orig_node->router; | 800 | router = orig_node_get_router(orig_node); |
788 | 801 | if (!router) | |
789 | if (!neigh_node) | 802 | goto out; |
790 | goto unlock; | ||
791 | |||
792 | if (!atomic_inc_not_zero(&neigh_node->refcount)) { | ||
793 | neigh_node = NULL; | ||
794 | goto unlock; | ||
795 | } | ||
796 | |||
797 | rcu_read_unlock(); | ||
798 | 803 | ||
799 | skb = skb_clone(info->skb_packet, GFP_ATOMIC); | 804 | skb = skb_clone(info->skb_packet, GFP_ATOMIC); |
800 | if (skb) | 805 | if (skb) |
801 | send_skb_packet(skb, neigh_node->if_incoming, | 806 | send_skb_packet(skb, router->if_incoming, router->addr); |
802 | neigh_node->addr); | ||
803 | |||
804 | goto out; | ||
805 | 807 | ||
806 | unlock: | ||
807 | rcu_read_unlock(); | ||
808 | out: | 808 | out: |
809 | if (neigh_node) | 809 | if (router) |
810 | neigh_node_free_ref(neigh_node); | 810 | neigh_node_free_ref(router); |
811 | if (orig_node) | 811 | if (orig_node) |
812 | orig_node_free_ref(orig_node); | 812 | orig_node_free_ref(orig_node); |
813 | return; | ||
814 | } | 813 | } |
815 | 814 | ||
816 | /* only send one vis packet. called from send_vis_packets() */ | 815 | /* only send one vis packet. called from send_vis_packets() */ |