Lines Matching refs:e
63 static inline unsigned int vlan_prio(const struct l2t_entry *e) in vlan_prio() argument
65 return e->vlan >> 13; in vlan_prio()
74 static inline void neigh_replace(struct l2t_entry *e, struct neighbour *n) in neigh_replace() argument
77 if (e->neigh) in neigh_replace()
78 neigh_release(e->neigh); in neigh_replace()
79 e->neigh = n; in neigh_replace()
88 struct l2t_entry *e) in setup_l2e_send_pending() argument
101 OPCODE_TID(req) = htonl(MK_OPCODE_TID(CPL_L2T_WRITE_REQ, e->idx)); in setup_l2e_send_pending()
102 req->params = htonl(V_L2T_W_IDX(e->idx) | V_L2T_W_IFF(e->smt_idx) | in setup_l2e_send_pending()
103 V_L2T_W_VLAN(e->vlan & VLAN_VID_MASK) | in setup_l2e_send_pending()
104 V_L2T_W_PRIO(vlan_prio(e))); in setup_l2e_send_pending()
105 memcpy(e->dmac, e->neigh->ha, sizeof(e->dmac)); in setup_l2e_send_pending()
106 memcpy(req->dst_mac, e->dmac, sizeof(req->dst_mac)); in setup_l2e_send_pending()
110 skb_queue_walk_safe(&e->arpq, skb, tmp) { in setup_l2e_send_pending()
111 __skb_unlink(skb, &e->arpq); in setup_l2e_send_pending()
114 e->state = L2T_STATE_VALID; in setup_l2e_send_pending()
123 static inline void arpq_enqueue(struct l2t_entry *e, struct sk_buff *skb) in arpq_enqueue() argument
125 __skb_queue_tail(&e->arpq, skb); in arpq_enqueue()
129 struct l2t_entry *e) in t3_l2t_send_slow() argument
132 switch (e->state) { in t3_l2t_send_slow()
134 neigh_event_send(e->neigh, NULL); in t3_l2t_send_slow()
135 spin_lock_bh(&e->lock); in t3_l2t_send_slow()
136 if (e->state == L2T_STATE_STALE) in t3_l2t_send_slow()
137 e->state = L2T_STATE_VALID; in t3_l2t_send_slow()
138 spin_unlock_bh(&e->lock); in t3_l2t_send_slow()
142 spin_lock_bh(&e->lock); in t3_l2t_send_slow()
143 if (e->state != L2T_STATE_RESOLVING) { in t3_l2t_send_slow()
145 spin_unlock_bh(&e->lock); in t3_l2t_send_slow()
148 arpq_enqueue(e, skb); in t3_l2t_send_slow()
149 spin_unlock_bh(&e->lock); in t3_l2t_send_slow()
159 if (!neigh_event_send(e->neigh, NULL)) { in t3_l2t_send_slow()
165 spin_lock_bh(&e->lock); in t3_l2t_send_slow()
166 if (!skb_queue_empty(&e->arpq)) in t3_l2t_send_slow()
167 setup_l2e_send_pending(dev, skb, e); in t3_l2t_send_slow()
170 spin_unlock_bh(&e->lock); in t3_l2t_send_slow()
178 void t3_l2t_send_event(struct t3cdev *dev, struct l2t_entry *e) in t3_l2t_send_event() argument
181 switch (e->state) { in t3_l2t_send_event()
183 neigh_event_send(e->neigh, NULL); in t3_l2t_send_event()
184 spin_lock_bh(&e->lock); in t3_l2t_send_event()
185 if (e->state == L2T_STATE_STALE) { in t3_l2t_send_event()
186 e->state = L2T_STATE_VALID; in t3_l2t_send_event()
188 spin_unlock_bh(&e->lock); in t3_l2t_send_event()
193 spin_lock_bh(&e->lock); in t3_l2t_send_event()
194 if (e->state != L2T_STATE_RESOLVING) { in t3_l2t_send_event()
196 spin_unlock_bh(&e->lock); in t3_l2t_send_event()
199 spin_unlock_bh(&e->lock); in t3_l2t_send_event()
209 neigh_event_send(e->neigh, NULL); in t3_l2t_send_event()
220 struct l2t_entry *end, *e, **p; in alloc_l2e() local
226 for (e = d->rover, end = &d->l2tab[d->nentries]; e != end; ++e) in alloc_l2e()
227 if (atomic_read(&e->refcnt) == 0) in alloc_l2e()
230 for (e = &d->l2tab[1]; atomic_read(&e->refcnt); ++e) ; in alloc_l2e()
232 d->rover = e + 1; in alloc_l2e()
239 if (e->state != L2T_STATE_UNUSED) { in alloc_l2e()
240 int hash = arp_hash(e->addr, e->ifindex, d); in alloc_l2e()
243 if (*p == e) { in alloc_l2e()
244 *p = e->next; in alloc_l2e()
247 e->state = L2T_STATE_UNUSED; in alloc_l2e()
249 return e; in alloc_l2e()
263 void t3_l2e_free(struct l2t_data *d, struct l2t_entry *e) in t3_l2e_free() argument
265 spin_lock_bh(&e->lock); in t3_l2e_free()
266 if (atomic_read(&e->refcnt) == 0) { /* hasn't been recycled */ in t3_l2e_free()
267 if (e->neigh) { in t3_l2e_free()
268 neigh_release(e->neigh); in t3_l2e_free()
269 e->neigh = NULL; in t3_l2e_free()
272 spin_unlock_bh(&e->lock); in t3_l2e_free()
282 static inline void reuse_entry(struct l2t_entry *e, struct neighbour *neigh) in reuse_entry() argument
286 spin_lock(&e->lock); /* avoid race with t3_l2t_free */ in reuse_entry()
288 if (neigh != e->neigh) in reuse_entry()
289 neigh_replace(e, neigh); in reuse_entry()
291 if (memcmp(e->dmac, neigh->ha, sizeof(e->dmac)) || in reuse_entry()
293 e->state = L2T_STATE_RESOLVING; in reuse_entry()
295 e->state = L2T_STATE_VALID; in reuse_entry()
297 e->state = L2T_STATE_STALE; in reuse_entry()
298 spin_unlock(&e->lock); in reuse_entry()
304 struct l2t_entry *e = NULL; in t3_l2t_get() local
333 for (e = d->l2tab[hash].first; e; e = e->next) in t3_l2t_get()
334 if (e->addr == addr && e->ifindex == ifidx && in t3_l2t_get()
335 e->smt_idx == smt_idx) { in t3_l2t_get()
336 l2t_hold(d, e); in t3_l2t_get()
337 if (atomic_read(&e->refcnt) == 1) in t3_l2t_get()
338 reuse_entry(e, neigh); in t3_l2t_get()
343 e = alloc_l2e(d); in t3_l2t_get()
344 if (e) { in t3_l2t_get()
345 spin_lock(&e->lock); /* avoid race with t3_l2t_free */ in t3_l2t_get()
346 e->next = d->l2tab[hash].first; in t3_l2t_get()
347 d->l2tab[hash].first = e; in t3_l2t_get()
348 e->state = L2T_STATE_RESOLVING; in t3_l2t_get()
349 e->addr = addr; in t3_l2t_get()
350 e->ifindex = ifidx; in t3_l2t_get()
351 e->smt_idx = smt_idx; in t3_l2t_get()
352 atomic_set(&e->refcnt, 1); in t3_l2t_get()
353 neigh_replace(e, neigh); in t3_l2t_get()
355 e->vlan = vlan_dev_vlan_id(neigh->dev); in t3_l2t_get()
357 e->vlan = VLAN_NONE; in t3_l2t_get()
358 spin_unlock(&e->lock); in t3_l2t_get()
366 return e; in t3_l2t_get()
401 struct l2t_entry *e; in t3_l2t_update() local
408 for (e = d->l2tab[hash].first; e; e = e->next) in t3_l2t_update()
409 if (e->addr == addr && e->ifindex == ifidx) { in t3_l2t_update()
410 spin_lock(&e->lock); in t3_l2t_update()
420 if (atomic_read(&e->refcnt)) { in t3_l2t_update()
421 if (neigh != e->neigh) in t3_l2t_update()
422 neigh_replace(e, neigh); in t3_l2t_update()
424 if (e->state == L2T_STATE_RESOLVING) { in t3_l2t_update()
426 skb_queue_splice_init(&e->arpq, &arpq); in t3_l2t_update()
428 setup_l2e_send_pending(dev, NULL, e); in t3_l2t_update()
430 e->state = neigh->nud_state & NUD_CONNECTED ? in t3_l2t_update()
432 if (!ether_addr_equal(e->dmac, neigh->ha)) in t3_l2t_update()
433 setup_l2e_send_pending(dev, NULL, e); in t3_l2t_update()
436 spin_unlock_bh(&e->lock); in t3_l2t_update()