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()
452 struct sk_buff_head rx_queue; in rxrpc_io_thread() local
465 skb_queue_head_init(&rx_queue); in rxrpc_io_thread()
479 skb_queue_tail(&local->rx_queue, skb); in rxrpc_io_thread()
483 if (!skb_queue_empty(&local->rx_queue)) { in rxrpc_io_thread()
484 spin_lock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
485 skb_queue_splice_tail_init(&local->rx_queue, &rx_queue); in rxrpc_io_thread()
486 spin_unlock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
487 trace_rxrpc_iothread_rx(local, skb_queue_len(&rx_queue)); in rxrpc_io_thread()
491 while ((skb = __skb_dequeue(&rx_queue))) { in rxrpc_io_thread()
559 if (!skb_queue_empty(&local->rx_queue) || in rxrpc_io_thread()