Searched refs:arrvq (Results 1 - 6 of 6) sorted by relevance
| /kernel/linux/linux-5.10/net/tipc/ |
| H A D | socket.h | 57 void tipc_sk_mcast_rcv(struct net *net, struct sk_buff_head *arrvq,
|
| H A D | socket.c | 1173 * @arrvq: queue with arriving messages, to be cloned after destination lookup
1178 void tipc_sk_mcast_rcv(struct net *net, struct sk_buff_head *arrvq, in tipc_sk_mcast_rcv() argument
1194 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1195 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1205 if (skb_peek(arrvq) == skb) { in tipc_sk_mcast_rcv()
1206 __skb_dequeue(arrvq); in tipc_sk_mcast_rcv()
1247 if (skb_peek(arrvq) == skb) { in tipc_sk_mcast_rcv()
1252 kfree_skb(__skb_dequeue(arrvq)); in tipc_sk_mcast_rcv()
|
| H A D | node.c | 75 struct sk_buff_head arrvq; member
555 __skb_queue_head_init(&n->bc_entry.arrvq); in tipc_node_create()
1797 /* 'arrvq' is under inputq2's lock protection */ in tipc_node_mcast_rcv()
1800 skb_queue_splice_tail_init(&be->inputq1, &be->arrvq); in tipc_node_mcast_rcv()
1803 tipc_sk_mcast_rcv(n->net, &be->arrvq, &be->inputq2); in tipc_node_mcast_rcv()
|
| /kernel/linux/linux-6.6/net/tipc/ |
| H A D | socket.h | 57 void tipc_sk_mcast_rcv(struct net *net, struct sk_buff_head *arrvq,
|
| H A D | socket.c | 1190 * @arrvq: queue with arriving messages, to be cloned after destination lookup
1195 void tipc_sk_mcast_rcv(struct net *net, struct sk_buff_head *arrvq, in tipc_sk_mcast_rcv() argument
1212 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1213 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1229 if (skb_peek(arrvq) == skb) { in tipc_sk_mcast_rcv()
1230 __skb_dequeue(arrvq); in tipc_sk_mcast_rcv()
1258 /* Append clones to inputq only if skb is still head of arrvq */ in tipc_sk_mcast_rcv()
1260 if (skb_peek(arrvq) == skb) { in tipc_sk_mcast_rcv()
1263 kfree_skb(__skb_dequeue(arrvq)); in tipc_sk_mcast_rcv()
|
| H A D | node.c | 75 struct sk_buff_head arrvq; member
571 __skb_queue_head_init(&n->bc_entry.arrvq); in tipc_node_create()
1826 /* 'arrvq' is under inputq2's lock protection */ in tipc_node_mcast_rcv()
1829 skb_queue_splice_tail_init(&be->inputq1, &be->arrvq); in tipc_node_mcast_rcv()
1832 tipc_sk_mcast_rcv(n->net, &be->arrvq, &be->inputq2); in tipc_node_mcast_rcv()
|
Completed in 20 milliseconds