Lines Matching refs:neigh
56 static void neigh_update_notify(struct neighbour *neigh);
91 static int neigh_blackhole(struct neighbour *neigh, struct sk_buff *skb) in neigh_blackhole() argument
97 static void neigh_cleanup_and_release(struct neighbour *neigh) in neigh_cleanup_and_release() argument
99 if (neigh->parms->neigh_cleanup) in neigh_cleanup_and_release()
100 neigh->parms->neigh_cleanup(neigh); in neigh_cleanup_and_release()
102 __neigh_notify(neigh, RTM_DELNEIGH, 0); in neigh_cleanup_and_release()
103 neigh_release(neigh); in neigh_cleanup_and_release()
679 void neigh_destroy(struct neighbour *neigh) in neigh_destroy() argument
681 struct net_device *dev = neigh->dev; in neigh_destroy()
683 NEIGH_CACHE_STAT_INC(neigh->tbl, destroys); in neigh_destroy()
685 if (!neigh->dead) { in neigh_destroy()
686 pr_warn("Destroying alive neighbour %p\n", neigh); in neigh_destroy()
691 if (neigh_del_timer(neigh)) in neigh_destroy()
694 write_lock_bh(&neigh->lock); in neigh_destroy()
695 __skb_queue_purge(&neigh->arp_queue); in neigh_destroy()
696 write_unlock_bh(&neigh->lock); in neigh_destroy()
697 neigh->arp_queue_len_bytes = 0; in neigh_destroy()
700 dev->netdev_ops->ndo_neigh_destroy(neigh); in neigh_destroy()
703 neigh_parms_put(neigh->parms); in neigh_destroy()
705 neigh_dbg(2, "neigh %p is destroyed\n", neigh); in neigh_destroy()
707 atomic_dec(&neigh->tbl->entries); in neigh_destroy()
708 kfree_rcu(neigh, rcu); in neigh_destroy()
717 static void neigh_suspect(struct neighbour *neigh) in neigh_suspect() argument
719 neigh_dbg(2, "neigh %p is suspected\n", neigh); in neigh_suspect()
721 neigh->output = neigh->ops->output; in neigh_suspect()
729 static void neigh_connect(struct neighbour *neigh) in neigh_connect() argument
731 neigh_dbg(2, "neigh %p is connected\n", neigh); in neigh_connect()
733 neigh->output = neigh->ops->connected_output; in neigh_connect()
825 static void neigh_invalidate(struct neighbour *neigh) in neigh_invalidate() argument
826 __releases(neigh->lock) in neigh_invalidate()
827 __acquires(neigh->lock) in neigh_invalidate()
831 NEIGH_CACHE_STAT_INC(neigh->tbl, res_failed); in neigh_invalidate()
832 neigh_dbg(2, "neigh %p is failed\n", neigh); in neigh_invalidate()
833 neigh->updated = jiffies; in neigh_invalidate()
840 while (neigh->nud_state == NUD_FAILED && in neigh_invalidate()
841 (skb = __skb_dequeue(&neigh->arp_queue)) != NULL) { in neigh_invalidate()
842 write_unlock(&neigh->lock); in neigh_invalidate()
843 neigh->ops->error_report(neigh, skb); in neigh_invalidate()
844 write_lock(&neigh->lock); in neigh_invalidate()
846 __skb_queue_purge(&neigh->arp_queue); in neigh_invalidate()
847 neigh->arp_queue_len_bytes = 0; in neigh_invalidate()
850 static void neigh_probe(struct neighbour *neigh) in neigh_probe() argument
851 __releases(neigh->lock) in neigh_probe()
853 struct sk_buff *skb = skb_peek_tail(&neigh->arp_queue); in neigh_probe()
857 write_unlock(&neigh->lock); in neigh_probe()
858 neigh->ops->solicit(neigh, skb); in neigh_probe()
859 atomic_inc(&neigh->probes); in neigh_probe()
868 struct neighbour *neigh = (struct neighbour *)arg; in neigh_timer_handler() local
872 write_lock(&neigh->lock); in neigh_timer_handler()
874 state = neigh->nud_state; in neigh_timer_handler()
883 neigh->confirmed + neigh->parms->reachable_time)) { in neigh_timer_handler()
884 neigh_dbg(2, "neigh %p is still alive\n", neigh); in neigh_timer_handler()
885 next = neigh->confirmed + neigh->parms->reachable_time; in neigh_timer_handler()
887 neigh->used + in neigh_timer_handler()
888 NEIGH_VAR(neigh->parms, DELAY_PROBE_TIME))) { in neigh_timer_handler()
889 neigh_dbg(2, "neigh %p is delayed\n", neigh); in neigh_timer_handler()
890 neigh->nud_state = NUD_DELAY; in neigh_timer_handler()
891 neigh->updated = jiffies; in neigh_timer_handler()
892 neigh_suspect(neigh); in neigh_timer_handler()
893 next = now + NEIGH_VAR(neigh->parms, DELAY_PROBE_TIME); in neigh_timer_handler()
895 neigh_dbg(2, "neigh %p is suspected\n", neigh); in neigh_timer_handler()
896 neigh->nud_state = NUD_STALE; in neigh_timer_handler()
897 neigh->updated = jiffies; in neigh_timer_handler()
898 neigh_suspect(neigh); in neigh_timer_handler()
903 neigh->confirmed + in neigh_timer_handler()
904 NEIGH_VAR(neigh->parms, DELAY_PROBE_TIME))) { in neigh_timer_handler()
905 neigh_dbg(2, "neigh %p is now reachable\n", neigh); in neigh_timer_handler()
906 neigh->nud_state = NUD_REACHABLE; in neigh_timer_handler()
907 neigh->updated = jiffies; in neigh_timer_handler()
908 neigh_connect(neigh); in neigh_timer_handler()
910 next = neigh->confirmed + neigh->parms->reachable_time; in neigh_timer_handler()
912 neigh_dbg(2, "neigh %p is probed\n", neigh); in neigh_timer_handler()
913 neigh->nud_state = NUD_PROBE; in neigh_timer_handler()
914 neigh->updated = jiffies; in neigh_timer_handler()
915 atomic_set(&neigh->probes, 0); in neigh_timer_handler()
916 next = now + NEIGH_VAR(neigh->parms, RETRANS_TIME); in neigh_timer_handler()
920 next = now + NEIGH_VAR(neigh->parms, RETRANS_TIME); in neigh_timer_handler()
923 if ((neigh->nud_state & (NUD_INCOMPLETE | NUD_PROBE)) && in neigh_timer_handler()
924 atomic_read(&neigh->probes) >= neigh_max_probes(neigh)) { in neigh_timer_handler()
925 neigh->nud_state = NUD_FAILED; in neigh_timer_handler()
927 neigh_invalidate(neigh); in neigh_timer_handler()
931 if (neigh->nud_state & NUD_IN_TIMER) { in neigh_timer_handler()
934 if (!mod_timer(&neigh->timer, next)) in neigh_timer_handler()
935 neigh_hold(neigh); in neigh_timer_handler()
937 if (neigh->nud_state & (NUD_INCOMPLETE | NUD_PROBE)) { in neigh_timer_handler()
938 neigh_probe(neigh); in neigh_timer_handler()
941 write_unlock(&neigh->lock); in neigh_timer_handler()
945 neigh_update_notify(neigh); in neigh_timer_handler()
947 neigh_release(neigh); in neigh_timer_handler()
950 int __neigh_event_send(struct neighbour *neigh, struct sk_buff *skb) in __neigh_event_send() argument
955 write_lock_bh(&neigh->lock); in __neigh_event_send()
958 if (neigh->nud_state & (NUD_CONNECTED | NUD_DELAY | NUD_PROBE)) in __neigh_event_send()
960 if (neigh->dead) in __neigh_event_send()
963 if (!(neigh->nud_state & (NUD_STALE | NUD_INCOMPLETE))) { in __neigh_event_send()
964 if (NEIGH_VAR(neigh->parms, MCAST_PROBES) + in __neigh_event_send()
965 NEIGH_VAR(neigh->parms, APP_PROBES)) { in __neigh_event_send()
968 atomic_set(&neigh->probes, in __neigh_event_send()
969 NEIGH_VAR(neigh->parms, UCAST_PROBES)); in __neigh_event_send()
970 neigh->nud_state = NUD_INCOMPLETE; in __neigh_event_send()
971 neigh->updated = now; in __neigh_event_send()
972 next = now + max(NEIGH_VAR(neigh->parms, RETRANS_TIME), in __neigh_event_send()
974 neigh_add_timer(neigh, next); in __neigh_event_send()
977 neigh->nud_state = NUD_FAILED; in __neigh_event_send()
978 neigh->updated = jiffies; in __neigh_event_send()
979 write_unlock_bh(&neigh->lock); in __neigh_event_send()
984 } else if (neigh->nud_state & NUD_STALE) { in __neigh_event_send()
985 neigh_dbg(2, "neigh %p is delayed\n", neigh); in __neigh_event_send()
986 neigh->nud_state = NUD_DELAY; in __neigh_event_send()
987 neigh->updated = jiffies; in __neigh_event_send()
988 neigh_add_timer(neigh, jiffies + in __neigh_event_send()
989 NEIGH_VAR(neigh->parms, DELAY_PROBE_TIME)); in __neigh_event_send()
992 if (neigh->nud_state == NUD_INCOMPLETE) { in __neigh_event_send()
994 while (neigh->arp_queue_len_bytes + skb->truesize > in __neigh_event_send()
995 NEIGH_VAR(neigh->parms, QUEUE_LEN_BYTES)) { in __neigh_event_send()
998 buff = __skb_dequeue(&neigh->arp_queue); in __neigh_event_send()
1001 neigh->arp_queue_len_bytes -= buff->truesize; in __neigh_event_send()
1003 NEIGH_CACHE_STAT_INC(neigh->tbl, unres_discards); in __neigh_event_send()
1006 __skb_queue_tail(&neigh->arp_queue, skb); in __neigh_event_send()
1007 neigh->arp_queue_len_bytes += skb->truesize; in __neigh_event_send()
1013 neigh_probe(neigh); in __neigh_event_send()
1015 write_unlock(&neigh->lock); in __neigh_event_send()
1020 if (neigh->nud_state & NUD_STALE) in __neigh_event_send()
1022 write_unlock_bh(&neigh->lock); in __neigh_event_send()
1028 static void neigh_update_hhs(struct neighbour *neigh) in neigh_update_hhs() argument
1034 if (neigh->dev->header_ops) in neigh_update_hhs()
1035 update = neigh->dev->header_ops->cache_update; in neigh_update_hhs()
1038 hh = &neigh->hh; in neigh_update_hhs()
1041 update(hh, neigh->dev, neigh->ha); in neigh_update_hhs()
1070 int neigh_update(struct neighbour *neigh, const u8 *lladdr, u8 new, in neigh_update() argument
1079 write_lock_bh(&neigh->lock); in neigh_update()
1081 dev = neigh->dev; in neigh_update()
1082 old = neigh->nud_state; in neigh_update()
1088 if (neigh->dead) in neigh_update()
1092 neigh_del_timer(neigh); in neigh_update()
1094 neigh_suspect(neigh); in neigh_update()
1095 neigh->nud_state = new; in neigh_update()
1100 neigh_invalidate(neigh); in neigh_update()
1109 lladdr = neigh->ha; in neigh_update()
1117 !memcmp(lladdr, neigh->ha, dev->addr_len)) in neigh_update()
1118 lladdr = neigh->ha; in neigh_update()
1126 lladdr = neigh->ha; in neigh_update()
1130 neigh->confirmed = jiffies; in neigh_update()
1131 neigh->updated = jiffies; in neigh_update()
1139 if (lladdr != neigh->ha && !(flags & NEIGH_UPDATE_F_OVERRIDE)) { in neigh_update()
1143 lladdr = neigh->ha; in neigh_update()
1148 if (lladdr == neigh->ha && new == NUD_STALE && in neigh_update()
1157 neigh_del_timer(neigh); in neigh_update()
1159 neigh_add_timer(neigh, (jiffies + in neigh_update()
1161 neigh->parms->reachable_time : in neigh_update()
1163 neigh->nud_state = new; in neigh_update()
1167 if (lladdr != neigh->ha) { in neigh_update()
1168 write_seqlock(&neigh->ha_lock); in neigh_update()
1169 memcpy(&neigh->ha, lladdr, dev->addr_len); in neigh_update()
1170 write_sequnlock(&neigh->ha_lock); in neigh_update()
1171 neigh_update_hhs(neigh); in neigh_update()
1173 neigh->confirmed = jiffies - in neigh_update()
1174 (NEIGH_VAR(neigh->parms, BASE_REACHABLE_TIME) << 1); in neigh_update()
1180 neigh_connect(neigh); in neigh_update()
1182 neigh_suspect(neigh); in neigh_update()
1188 while (neigh->nud_state & NUD_VALID && in neigh_update()
1189 (skb = __skb_dequeue(&neigh->arp_queue)) != NULL) { in neigh_update()
1191 struct neighbour *n2, *n1 = neigh; in neigh_update()
1192 write_unlock_bh(&neigh->lock); in neigh_update()
1214 write_lock_bh(&neigh->lock); in neigh_update()
1216 __skb_queue_purge(&neigh->arp_queue); in neigh_update()
1217 neigh->arp_queue_len_bytes = 0; in neigh_update()
1221 neigh->flags = (flags & NEIGH_UPDATE_F_ISROUTER) ? in neigh_update()
1222 (neigh->flags | NTF_ROUTER) : in neigh_update()
1223 (neigh->flags & ~NTF_ROUTER); in neigh_update()
1225 write_unlock_bh(&neigh->lock); in neigh_update()
1228 neigh_update_notify(neigh); in neigh_update()
1237 void __neigh_set_probe_once(struct neighbour *neigh) in __neigh_set_probe_once() argument
1239 if (neigh->dead) in __neigh_set_probe_once()
1241 neigh->updated = jiffies; in __neigh_set_probe_once()
1242 if (!(neigh->nud_state & NUD_FAILED)) in __neigh_set_probe_once()
1244 neigh->nud_state = NUD_INCOMPLETE; in __neigh_set_probe_once()
1245 atomic_set(&neigh->probes, neigh_max_probes(neigh)); in __neigh_set_probe_once()
1246 neigh_add_timer(neigh, in __neigh_set_probe_once()
1247 jiffies + NEIGH_VAR(neigh->parms, RETRANS_TIME)); in __neigh_set_probe_once()
1255 struct neighbour *neigh = __neigh_lookup(tbl, saddr, dev, in neigh_event_ns() local
1257 if (neigh) in neigh_event_ns()
1258 neigh_update(neigh, lladdr, NUD_STALE, in neigh_event_ns()
1260 return neigh; in neigh_event_ns()
1284 int neigh_resolve_output(struct neighbour *neigh, struct sk_buff *skb) in neigh_resolve_output() argument
1288 if (!neigh_event_send(neigh, skb)) { in neigh_resolve_output()
1290 struct net_device *dev = neigh->dev; in neigh_resolve_output()
1293 if (dev->header_ops->cache && !neigh->hh.hh_len) in neigh_resolve_output()
1294 neigh_hh_init(neigh); in neigh_resolve_output()
1298 seq = read_seqbegin(&neigh->ha_lock); in neigh_resolve_output()
1300 neigh->ha, NULL, skb->len); in neigh_resolve_output()
1301 } while (read_seqretry(&neigh->ha_lock, seq)); in neigh_resolve_output()
1319 int neigh_connected_output(struct neighbour *neigh, struct sk_buff *skb) in neigh_connected_output() argument
1321 struct net_device *dev = neigh->dev; in neigh_connected_output()
1327 seq = read_seqbegin(&neigh->ha_lock); in neigh_connected_output()
1329 neigh->ha, NULL, skb->len); in neigh_connected_output()
1330 } while (read_seqretry(&neigh->ha_lock, seq)); in neigh_connected_output()
1342 int neigh_direct_output(struct neighbour *neigh, struct sk_buff *skb) in neigh_direct_output() argument
1593 struct neighbour *neigh; in neigh_delete() local
1629 neigh = neigh_lookup(tbl, nla_data(dst_attr), dev); in neigh_delete()
1630 if (neigh == NULL) { in neigh_delete()
1635 err = neigh_update(neigh, NULL, NUD_FAILED, in neigh_delete()
1638 neigh_release(neigh); in neigh_delete()
1652 struct neighbour *neigh; in neigh_add() local
1701 neigh = neigh_lookup(tbl, dst, dev); in neigh_add()
1702 if (neigh == NULL) { in neigh_add()
1708 neigh = __neigh_lookup_errno(tbl, dst, dev); in neigh_add()
1709 if (IS_ERR(neigh)) { in neigh_add()
1710 err = PTR_ERR(neigh); in neigh_add()
1716 neigh_release(neigh); in neigh_add()
1725 neigh_event_send(neigh, NULL); in neigh_add()
1728 err = neigh_update(neigh, lladdr, ndm->ndm_state, flags); in neigh_add()
1729 neigh_release(neigh); in neigh_add()
2140 static int neigh_fill_info(struct sk_buff *skb, struct neighbour *neigh, in neigh_fill_info() argument
2153 ndm->ndm_family = neigh->ops->family; in neigh_fill_info()
2156 ndm->ndm_flags = neigh->flags; in neigh_fill_info()
2157 ndm->ndm_type = neigh->type; in neigh_fill_info()
2158 ndm->ndm_ifindex = neigh->dev->ifindex; in neigh_fill_info()
2160 if (nla_put(skb, NDA_DST, neigh->tbl->key_len, neigh->primary_key)) in neigh_fill_info()
2163 read_lock_bh(&neigh->lock); in neigh_fill_info()
2164 ndm->ndm_state = neigh->nud_state; in neigh_fill_info()
2165 if (neigh->nud_state & NUD_VALID) { in neigh_fill_info()
2168 neigh_ha_snapshot(haddr, neigh, neigh->dev); in neigh_fill_info()
2169 if (nla_put(skb, NDA_LLADDR, neigh->dev->addr_len, haddr) < 0) { in neigh_fill_info()
2170 read_unlock_bh(&neigh->lock); in neigh_fill_info()
2175 ci.ndm_used = jiffies_to_clock_t(now - neigh->used); in neigh_fill_info()
2176 ci.ndm_confirmed = jiffies_to_clock_t(now - neigh->confirmed); in neigh_fill_info()
2177 ci.ndm_updated = jiffies_to_clock_t(now - neigh->updated); in neigh_fill_info()
2178 ci.ndm_refcnt = atomic_read(&neigh->refcnt) - 1; in neigh_fill_info()
2179 read_unlock_bh(&neigh->lock); in neigh_fill_info()
2181 if (nla_put_u32(skb, NDA_PROBES, atomic_read(&neigh->probes)) || in neigh_fill_info()
2224 static void neigh_update_notify(struct neighbour *neigh) in neigh_update_notify() argument
2226 call_netevent_notifiers(NETEVENT_NEIGH_UPDATE, neigh); in neigh_update_notify()
2227 __neigh_notify(neigh, RTM_NEWNEIGH, 0); in neigh_update_notify()
2414 struct neighbour *neigh; in neigh_xmit() local
2419 neigh = __neigh_lookup_noref(tbl, addr, dev); in neigh_xmit()
2420 if (!neigh) in neigh_xmit()
2421 neigh = __neigh_create(tbl, addr, dev, false); in neigh_xmit()
2422 err = PTR_ERR(neigh); in neigh_xmit()
2423 if (IS_ERR(neigh)) in neigh_xmit()
2425 err = neigh->output(neigh, skb); in neigh_xmit()