Lines Matching refs:inputq
1174 * @inputq: queue with cloned messages, delivered to socket after dest lookup
1179 struct sk_buff_head *inputq)
1194 skb = tipc_skb_peek(arrvq, &inputq->lock);
1195 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) {
1204 spin_lock_bh(&inputq->lock);
1207 __skb_queue_tail(inputq, skb);
1210 spin_unlock_bh(&inputq->lock);
1245 /* Append to inputq if not already done by other thread */
1246 spin_lock_bh(&inputq->lock);
1248 skb_queue_splice_tail_init(&tmpq, inputq);
1254 spin_unlock_bh(&inputq->lock);
1258 tipc_sk_rcv(net, inputq);
1317 struct sk_buff_head *inputq,
1345 __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
2423 static void tipc_sk_enqueue(struct sk_buff_head *inputq, struct sock *sk,
2432 while (skb_queue_len(inputq)) {
2436 skb = tipc_skb_dequeue(inputq, dport);
2472 * @inputq: buffer list containing the buffers
2473 * Consumes all buffers in list until inputq is empty
2476 void tipc_sk_rcv(struct net *net, struct sk_buff_head *inputq)
2486 while (skb_queue_len(inputq)) {
2487 dport = tipc_skb_peek_port(inputq, dport);
2493 tipc_sk_enqueue(inputq, sk, dport, &xmitq);
2502 skb = tipc_skb_dequeue(inputq, dport);