Lines Matching refs:rx_queue
28 struct sk_buff_head *rx_queue; in rxrpc_encap_rcv() local
46 rx_queue = &local->rx_queue; in rxrpc_encap_rcv()
51 rx_queue = &local->rx_delay_queue; in rxrpc_encap_rcv()
55 skb_queue_tail(rx_queue, skb); in rxrpc_encap_rcv()
78 skb_queue_tail(&local->rx_queue, skb); in rxrpc_error_report()
433 struct sk_buff_head rx_queue; in rxrpc_io_thread() local
444 skb_queue_head_init(&rx_queue); in rxrpc_io_thread()
487 if ((skb = __skb_dequeue(&rx_queue))) { in rxrpc_io_thread()
521 skb_queue_tail(&local->rx_queue, skb); in rxrpc_io_thread()
525 if (!skb_queue_empty(&local->rx_queue)) { in rxrpc_io_thread()
526 spin_lock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
527 skb_queue_splice_tail_init(&local->rx_queue, &rx_queue); in rxrpc_io_thread()
528 spin_unlock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
534 if (!skb_queue_empty(&local->rx_queue) || in rxrpc_io_thread()