Lines Matching refs:rx_queue
28 struct sk_buff_head *rx_queue; in rxrpc_encap_rcv() local
40 rx_queue = &local->rx_queue; in rxrpc_encap_rcv()
45 rx_queue = &local->rx_delay_queue; in rxrpc_encap_rcv()
49 skb_queue_tail(rx_queue, skb); in rxrpc_encap_rcv()
72 skb_queue_tail(&local->rx_queue, skb); in rxrpc_error_report()
416 struct sk_buff_head rx_queue; in rxrpc_io_thread() local
427 skb_queue_head_init(&rx_queue); in rxrpc_io_thread()
470 if ((skb = __skb_dequeue(&rx_queue))) { in rxrpc_io_thread()
504 skb_queue_tail(&local->rx_queue, skb); in rxrpc_io_thread()
508 if (!skb_queue_empty(&local->rx_queue)) { in rxrpc_io_thread()
509 spin_lock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
510 skb_queue_splice_tail_init(&local->rx_queue, &rx_queue); in rxrpc_io_thread()
511 spin_unlock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
517 if (!skb_queue_empty(&local->rx_queue) || in rxrpc_io_thread()