Lines Matching refs:inputq
1191 * @inputq: queue with cloned messages, delivered to socket after dest lookup
1196 struct sk_buff_head *inputq)
1212 skb = tipc_skb_peek(arrvq, &inputq->lock);
1213 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) {
1228 spin_lock_bh(&inputq->lock);
1231 __skb_queue_tail(inputq, skb);
1234 spin_unlock_bh(&inputq->lock);
1258 /* Append clones to inputq only if skb is still head of arrvq */
1259 spin_lock_bh(&inputq->lock);
1261 skb_queue_splice_tail_init(&tmpq, inputq);
1265 spin_unlock_bh(&inputq->lock);
1269 tipc_sk_rcv(net, inputq);
1326 * @inputq: buffer list containing the buffers
1330 struct sk_buff_head *inputq,
1358 __skb_queue_tail(inputq, skb);
2150 struct sk_buff_head *inputq,
2153 struct sk_buff *skb = __skb_dequeue(inputq);
2161 tipc_sk_conn_proto_rcv(tsk, skb, inputq, xmitq);
2172 tipc_group_proto_rcv(grp, &wakeup, hdr, inputq, xmitq);
2176 hdr, inputq, xmitq);
2345 struct sk_buff_head inputq;
2351 __skb_queue_head_init(&inputq);
2352 __skb_queue_tail(&inputq, skb);
2355 tipc_sk_proto_rcv(sk, &inputq, xmitq);
2358 tipc_group_filter_msg(grp, &inputq, xmitq);
2361 tipc_mcast_filter_msg(net, &tsk->mc_method.deferredq, &inputq);
2364 while ((skb = __skb_dequeue(&inputq))) {
2421 * inputq and try adding them to socket or backlog queue
2422 * @inputq: list of incoming buffers with potentially different destinations
2429 static void tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk,
2438 while (skb_queue_len(inputq)) {
2442 skb = tipc_skb_dequeue(inputq, dport);
2479 * @inputq: buffer list containing the buffers
2480 * Consumes all buffers in list until inputq is empty
2483 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq)
2493 while (skb_queue_len(inputq)) {
2494 dport = tipc_skb_peek_port(inputq, dport);
2500 tipc_sk_enqueue(inputq, sk, dport, &xmitq);
2509 skb = tipc_skb_dequeue(inputq, dport);