Searched refs:inputq (Results 1 – 8 of 8) sorted by relevance
| /linux-4.4.14/net/tipc/ |
| D | bcast.c | 60 struct sk_buff_head inputq; member
183 struct sk_buff_head xmitq, inputq, rcvq; in tipc_bcast_xmit() local
188 skb_queue_head_init(&inputq); in tipc_bcast_xmit()
207 tipc_sk_mcast_rcv(net, &rcvq, &inputq); in tipc_bcast_xmit()
219 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_rcv() local
240 if (!skb_queue_empty(inputq)) in tipc_bcast_rcv()
241 tipc_sk_rcv(net, inputq); in tipc_bcast_rcv()
252 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_ack_rcv() local
264 if (!skb_queue_empty(inputq)) in tipc_bcast_ack_rcv()
265 tipc_sk_rcv(net, inputq); in tipc_bcast_ack_rcv()
[all …]
|
| D | socket.h | 47 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq);
49 struct sk_buff_head *inputq);
|
| D | link.h | 202 struct sk_buff_head *inputq; member
229 struct sk_buff_head *inputq,
234 struct sk_buff_head *inputq,
|
| D | node.c | 74 static void node_lost_contact(struct tipc_node *n, struct sk_buff_head *inputq);
449 node_lost_contact(n, &le->inputq); in __tipc_node_link_down()
495 tipc_sk_rcv(n->net, &le->inputq); in tipc_node_link_down()
611 &le->inputq, in tipc_node_check_dest()
856 struct sk_buff_head *inputq) in node_lost_contact() argument
888 skb_queue_tail(inputq, skb); in node_lost_contact()
1202 tipc_skb_queue_splice_tail_init(pl->inputq, l->inputq); in tipc_node_check_state()
1247 dlv_nxt = pl->rcv_nxt - mod(skb_queue_len(pl->inputq)); in tipc_node_check_state()
1333 if (!skb_queue_empty(&le->inputq)) in tipc_rcv()
1334 tipc_sk_rcv(net, &le->inputq); in tipc_rcv()
|
| D | link.c | 263 struct sk_buff_head *inputq, in tipc_link_create() argument
301 l->inputq = inputq; in tipc_link_create()
308 skb_queue_head_init(l->inputq); in tipc_link_create()
325 struct sk_buff_head *inputq, in tipc_link_bc_create() argument
334 NULL, inputq, namedq, link)) in tipc_link_bc_create()
660 skb_queue_tail(l->inputq, skb); in link_prepare_wakeup()
678 skb_queue_splice_init(&l->wakeupq, l->inputq); in tipc_link_reset()
864 struct sk_buff_head *inputq) in tipc_data_input() argument
872 skb_queue_tail(inputq, skb); in tipc_data_input()
895 struct sk_buff_head *inputq) in tipc_link_input() argument
[all …]
|
| D | name_distr.c | 388 void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_named_rcv() argument
399 for (skb = skb_dequeue(inputq); skb; skb = skb_dequeue(inputq)) { in tipc_named_rcv()
|
| D | socket.c | 727 struct sk_buff_head *inputq) in tipc_sk_mcast_rcv() argument
740 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
741 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
763 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
765 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
768 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
772 tipc_sk_rcv(net, inputq); in tipc_sk_mcast_rcv()
1734 static void tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk, in tipc_sk_enqueue() argument
1742 while (skb_queue_len(inputq)) { in tipc_sk_enqueue()
1746 skb = tipc_skb_dequeue(inputq, dport); in tipc_sk_enqueue()
[all …]
|
| D | node.h | 73 struct sk_buff_head inputq; member
|