Lines Matching refs:rx_queue
545 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_stream_do_peek()
595 if (WARN_ONCE(skb_queue_empty(&vvs->rx_queue) && vvs->rx_bytes, in virtio_transport_stream_do_dequeue()
601 while (total < len && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_stream_do_dequeue()
604 skb = skb_peek(&vvs->rx_queue); in virtio_transport_stream_do_dequeue()
628 __skb_unlink(skb, &vvs->rx_queue); in virtio_transport_stream_do_dequeue()
681 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_seqpacket_do_peek()
742 skb = __skb_dequeue(&vvs->rx_queue); in virtio_transport_seqpacket_do_dequeue()
927 skb_queue_head_init(&vvs->rx_queue); in virtio_transport_do_socket_init()
1195 __skb_queue_purge(&vvs->rx_queue); in virtio_transport_remove_sock()
1362 if (len <= GOOD_COPY_LEN && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_recv_enqueue()
1366 last_skb = skb_peek_tail(&vvs->rx_queue); in virtio_transport_recv_enqueue()
1385 __skb_queue_tail(&vvs->rx_queue, skb); in virtio_transport_recv_enqueue()
1733 skb = __skb_recv_datagram(sk, &vvs->rx_queue, MSG_DONTWAIT, &off, &err); in virtio_transport_read_skb()