Lines Matching refs:rx_queue
363 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_stream_do_peek()
412 if (WARN_ONCE(skb_queue_empty(&vvs->rx_queue) && vvs->rx_bytes, in virtio_transport_stream_do_dequeue()
418 while (total < len && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_stream_do_dequeue()
419 skb = skb_peek(&vvs->rx_queue); in virtio_transport_stream_do_dequeue()
443 __skb_unlink(skb, &vvs->rx_queue); in virtio_transport_stream_do_dequeue()
494 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_seqpacket_do_peek()
554 skb = __skb_dequeue(&vvs->rx_queue); in virtio_transport_seqpacket_do_dequeue()
737 skb_queue_head_init(&vvs->rx_queue); in virtio_transport_do_socket_init()
989 __skb_queue_purge(&vvs->rx_queue); in virtio_transport_remove_sock()
1165 if (len <= GOOD_COPY_LEN && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_recv_enqueue()
1169 last_skb = skb_peek_tail(&vvs->rx_queue); in virtio_transport_recv_enqueue()
1188 __skb_queue_tail(&vvs->rx_queue, skb); in virtio_transport_recv_enqueue()
1523 skb = __skb_recv_datagram(sk, &vvs->rx_queue, MSG_DONTWAIT, &off, &err); in virtio_transport_read_skb()