Lines Matching refs:inputq

1195 		       struct sk_buff_head *inputq)  in tipc_sk_mcast_rcv()  argument
1211 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1212 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1227 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1230 __skb_queue_tail(inputq, skb); in tipc_sk_mcast_rcv()
1233 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1258 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1260 skb_queue_splice_tail_init(&tmpq, inputq); in tipc_sk_mcast_rcv()
1264 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1268 tipc_sk_rcv(net, inputq); in tipc_sk_mcast_rcv()
1329 struct sk_buff_head *inputq, in tipc_sk_conn_proto_rcv() argument
1357 __skb_queue_tail(inputq, skb); in tipc_sk_conn_proto_rcv()
2147 struct sk_buff_head *inputq, in tipc_sk_proto_rcv() argument
2150 struct sk_buff *skb = __skb_dequeue(inputq); in tipc_sk_proto_rcv()
2158 tipc_sk_conn_proto_rcv(tsk, skb, inputq, xmitq); in tipc_sk_proto_rcv()
2169 tipc_group_proto_rcv(grp, &wakeup, hdr, inputq, xmitq); in tipc_sk_proto_rcv()
2173 hdr, inputq, xmitq); in tipc_sk_proto_rcv()
2342 struct sk_buff_head inputq; in tipc_sk_filter_rcv() local
2348 __skb_queue_head_init(&inputq); in tipc_sk_filter_rcv()
2349 __skb_queue_tail(&inputq, skb); in tipc_sk_filter_rcv()
2352 tipc_sk_proto_rcv(sk, &inputq, xmitq); in tipc_sk_filter_rcv()
2355 tipc_group_filter_msg(grp, &inputq, xmitq); in tipc_sk_filter_rcv()
2358 tipc_mcast_filter_msg(net, &tsk->mc_method.deferredq, &inputq); in tipc_sk_filter_rcv()
2361 while ((skb = __skb_dequeue(&inputq))) { in tipc_sk_filter_rcv()
2426 static void tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk, in tipc_sk_enqueue() argument
2435 while (skb_queue_len(inputq)) { in tipc_sk_enqueue()
2439 skb = tipc_skb_dequeue(inputq, dport); in tipc_sk_enqueue()
2480 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_sk_rcv() argument
2490 while (skb_queue_len(inputq)) { in tipc_sk_rcv()
2491 dport = tipc_skb_peek_port(inputq, dport); in tipc_sk_rcv()
2497 tipc_sk_enqueue(inputq, sk, dport, &xmitq); in tipc_sk_rcv()
2506 skb = tipc_skb_dequeue(inputq, dport); in tipc_sk_rcv()