Lines Matching defs:inputq

1186  * @inputq: queue with cloned messages, delivered to socket after dest lookup
1191 		       struct sk_buff_head *inputq)
1207 	skb = tipc_skb_peek(arrvq, &inputq->lock);
1208 	for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) {
1223 			spin_lock_bh(&inputq->lock);
1226 				__skb_queue_tail(inputq, skb);
1229 			spin_unlock_bh(&inputq->lock);
1253 		/* Append clones to inputq only if skb is still head of arrvq */
1254 		spin_lock_bh(&inputq->lock);
1256 			skb_queue_splice_tail_init(&tmpq, inputq);
1260 		spin_unlock_bh(&inputq->lock);
1264 	tipc_sk_rcv(net, inputq);
1321  * @inputq: buffer list containing the buffers
1325 				   struct sk_buff_head *inputq,
1353 		__skb_queue_tail(inputq, skb);
2145 			      struct sk_buff_head *inputq,
2148 	struct sk_buff *skb = __skb_dequeue(inputq);
2156 		tipc_sk_conn_proto_rcv(tsk, skb, inputq, xmitq);
2167 		tipc_group_proto_rcv(grp, &wakeup, hdr, inputq, xmitq);
2171 				      hdr, inputq, xmitq);
2340 	struct sk_buff_head inputq;
2346 	__skb_queue_head_init(&inputq);
2347 	__skb_queue_tail(&inputq, skb);
2350 		tipc_sk_proto_rcv(sk, &inputq, xmitq);
2353 		tipc_group_filter_msg(grp, &inputq, xmitq);
2356 		tipc_mcast_filter_msg(net, &tsk->mc_method.deferredq, &inputq);
2359 	while ((skb = __skb_dequeue(&inputq))) {
2416  *                   inputq and try adding them to socket or backlog queue
2417  * @inputq: list of incoming buffers with potentially different destinations
2424 static void tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk,
2433 	while (skb_queue_len(inputq)) {
2437 		skb = tipc_skb_dequeue(inputq, dport);
2474  * @inputq: buffer list containing the buffers
2475  * Consumes all buffers in list until inputq is empty
2478 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq)
2488 	while (skb_queue_len(inputq)) {
2489 		dport = tipc_skb_peek_port(inputq, dport);
2495 				tipc_sk_enqueue(inputq, sk, dport, &xmitq);
2504 		skb = tipc_skb_dequeue(inputq, dport);