Lines Matching refs:inputq
717 struct sk_buff_head *inputq) in tipc_sk_mcast_rcv() argument
730 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
731 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
753 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
755 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
758 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
762 tipc_sk_rcv(net, inputq); in tipc_sk_mcast_rcv()
1722 static int tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk, in tipc_sk_enqueue() argument
1731 while (skb_queue_len(inputq)) { in tipc_sk_enqueue()
1734 skb = tipc_skb_dequeue(inputq, dport); in tipc_sk_enqueue()
1764 int tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_sk_rcv() argument
1773 while (skb_queue_len(inputq)) { in tipc_sk_rcv()
1776 dport = tipc_skb_peek_port(inputq, dport); in tipc_sk_rcv()
1781 err = tipc_sk_enqueue(inputq, sk, dport, &skb); in tipc_sk_rcv()
1787 skb = tipc_skb_dequeue(inputq, dport); in tipc_sk_rcv()