| /kernel/linux/linux-5.10/net/tipc/ |
| H A D | name_distr.c | 323 static struct sk_buff *tipc_named_dequeue(struct sk_buff_head *namedq, in tipc_named_dequeue() argument
330 spin_lock_bh(&namedq->lock); in tipc_named_dequeue()
331 skb_queue_walk_safe(namedq, skb, tmp) { in tipc_named_dequeue()
333 __skb_unlink(skb, namedq); in tipc_named_dequeue()
345 __skb_unlink(skb, namedq); in tipc_named_dequeue()
346 spin_unlock_bh(&namedq->lock); in tipc_named_dequeue()
352 __skb_unlink(skb, namedq); in tipc_named_dequeue()
353 spin_unlock_bh(&namedq->lock); in tipc_named_dequeue()
358 __skb_unlink(skb, namedq); in tipc_named_dequeue()
363 spin_unlock_bh(&namedq in tipc_named_dequeue()
370 tipc_named_rcv(struct net *net, struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) tipc_named_rcv() argument
[all...] |
| H A D | name_distr.h | 74 void tipc_named_rcv(struct net *net, struct sk_buff_head *namedq,
|
| H A D | link.h | 81 struct sk_buff_head *namedq,
86 struct sk_buff_head *namedq,
|
| H A D | node.c | 77 struct sk_buff_head namedq; member
90 * @namedq: pointer to name table input queue with name table messages
478 &n->bc_entry.namedq, snd_l, &n->bc_entry.link)) { in tipc_node_create()
553 skb_queue_head_init(&n->bc_entry.namedq); in tipc_node_create()
568 &n->bc_entry.namedq, snd_l, &n->bc_entry.link)) { in tipc_node_create()
1261 &n->bc_entry.namedq, &l)) { in tipc_node_check_dest()
1506 skb_queue_purge(&n->bc_entry.namedq); in node_lost_contact()
1883 if (!skb_queue_empty(&n->bc_entry.namedq)) in tipc_node_bc_rcv()
1884 tipc_named_rcv(net, &n->bc_entry.namedq, in tipc_node_bc_rcv()
2155 if (unlikely(!skb_queue_empty(&n->bc_entry.namedq))) in tipc_rcv()
[all...] |
| H A D | link.c | 116 * @namedq: buffer queue for name table messages to be delivered upwards
173 struct sk_buff_head *namedq; member
464 * @namedq: queue to put binding table update messages ready for delivery
476 struct sk_buff_head *namedq, in tipc_link_create()
520 l->namedq = namedq; in tipc_link_create()
538 * @namedq: queue to put binding table update messages ready for delivery
546 struct sk_buff_head *namedq, in tipc_link_bc_create()
554 bc_sndlink, NULL, inputq, namedq, link)) in tipc_link_bc_create()
1257 skb_queue_tail(l->namedq, sk in tipc_data_input()
469 tipc_link_create(struct net *net, char *if_name, int bearer_id, int tolerance, char net_plane, u32 mtu, int priority, u32 min_win, u32 max_win, u32 session, u32 self, u32 peer, u8 *peer_id, u16 peer_caps, struct tipc_link *bc_sndlink, struct tipc_link *bc_rcvlink, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link **link) tipc_link_create() argument
543 tipc_link_bc_create(struct net *net, u32 ownnode, u32 peer, u8 *peer_id, int mtu, u32 min_win, u32 max_win, u16 peer_caps, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link *bc_sndlink, struct tipc_link **link) tipc_link_bc_create() argument
[all...] |
| /kernel/linux/linux-6.6/net/tipc/ |
| H A D | name_distr.c | 313 static struct sk_buff *tipc_named_dequeue(struct sk_buff_head *namedq, in tipc_named_dequeue() argument
320 spin_lock_bh(&namedq->lock); in tipc_named_dequeue()
321 skb_queue_walk_safe(namedq, skb, tmp) { in tipc_named_dequeue()
323 __skb_unlink(skb, namedq); in tipc_named_dequeue()
335 __skb_unlink(skb, namedq); in tipc_named_dequeue()
336 spin_unlock_bh(&namedq->lock); in tipc_named_dequeue()
342 __skb_unlink(skb, namedq); in tipc_named_dequeue()
343 spin_unlock_bh(&namedq->lock); in tipc_named_dequeue()
348 __skb_unlink(skb, namedq); in tipc_named_dequeue()
353 spin_unlock_bh(&namedq in tipc_named_dequeue()
364 tipc_named_rcv(struct net *net, struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) tipc_named_rcv() argument
[all...] |
| H A D | link.h | 81 struct sk_buff_head *namedq,
86 struct sk_buff_head *namedq,
|
| H A D | name_distr.h | 73 void tipc_named_rcv(struct net *net, struct sk_buff_head *namedq,
|
| H A D | node.c | 77 struct sk_buff_head namedq; member
90 * @namedq: pointer to name table input queue with name table messages
494 &n->bc_entry.namedq, snd_l, &n->bc_entry.link)) { in tipc_node_create()
569 skb_queue_head_init(&n->bc_entry.namedq); in tipc_node_create()
584 &n->bc_entry.namedq, snd_l, &n->bc_entry.link)) { in tipc_node_create()
1288 &n->bc_entry.namedq, &l)) { in tipc_node_check_dest()
1533 skb_queue_purge(&n->bc_entry.namedq); in node_lost_contact()
1912 if (!skb_queue_empty(&n->bc_entry.namedq)) in tipc_node_bc_rcv()
1913 tipc_named_rcv(net, &n->bc_entry.namedq, in tipc_node_bc_rcv()
2186 if (unlikely(!skb_queue_empty(&n->bc_entry.namedq))) in tipc_rcv()
[all...] |
| H A D | link.c | 116 * @namedq: buffer queue for name table messages to be delivered upwards
201 struct sk_buff_head *namedq; member
491 * @namedq: queue to put binding table update messages ready for delivery
505 struct sk_buff_head *namedq, in tipc_link_create()
549 l->namedq = namedq; in tipc_link_create()
567 * @namedq: queue to put binding table update messages ready for delivery
580 struct sk_buff_head *namedq, in tipc_link_bc_create()
588 bc_sndlink, NULL, inputq, namedq, link)) in tipc_link_bc_create()
1292 skb_queue_tail(l->namedq, sk in tipc_data_input()
498 tipc_link_create(struct net *net, char *if_name, int bearer_id, int tolerance, char net_plane, u32 mtu, int priority, u32 min_win, u32 max_win, u32 session, u32 self, u32 peer, u8 *peer_id, u16 peer_caps, struct tipc_link *bc_sndlink, struct tipc_link *bc_rcvlink, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link **link) tipc_link_create() argument
577 tipc_link_bc_create(struct net *net, u32 ownnode, u32 peer, u8 *peer_id, int mtu, u32 min_win, u32 max_win, u16 peer_caps, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link *bc_sndlink, struct tipc_link **link) tipc_link_bc_create() argument
[all...] |