virtio/console/virtio_console.c

551 	struct virtqueue *vq;
570 		vq = scport->vcsp_invq;
571 		if (vq != NULL)
572 			vtcon_port_drain_bufs(vq);
594 	struct virtqueue *vq;
597 	vq = sc->vtcon_ctrl_rxvq;
605 	return (virtqueue_enqueue(vq, control, &sg, 0, sg.sg_nseg));
642 	struct virtqueue *vq;
645 	vq = sc->vtcon_ctrl_rxvq;
648 	for (nbufs = 0; !virtqueue_full(vq); nbufs++) {
655 		virtqueue_notify(vq);
666 	struct virtqueue *vq;
669 	vq = sc->vtcon_ctrl_rxvq;
672 	if (vq == NULL)
676 	while ((control = virtqueue_drain(vq, &last)) != NULL)
842 	struct virtqueue *vq;
847 	vq = sc->vtcon_ctrl_rxvq;
852 		control = virtqueue_dequeue(vq, NULL);
863 		virtqueue_notify(vq);
864 		if (virtqueue_enable_intr(vq) != 0)
892 	struct virtqueue *vq;
895 	vq = sc->vtcon_ctrl_txvq;
910 	KASSERT(virtqueue_empty(vq),
912 	error = virtqueue_enqueue(vq, control, &sg, sg.sg_nseg, 0);
914 		virtqueue_notify(vq);
915 		virtqueue_poll(vq, NULL);
941 	struct virtqueue *vq;
944 	vq = port->vtcport_invq;
951 	error = virtqueue_enqueue(vq, buf, &sg, 0, sg.sg_nseg);
986 	struct virtqueue *vq;
989 	vq = port->vtcport_invq;
992 	for (nbufs = 0; !virtqueue_full(vq); nbufs++) {
999 		virtqueue_notify(vq);
1096 vtcon_port_drain_bufs(struct virtqueue *vq)
1103 	while ((buf = virtqueue_drain(vq, &last)) != NULL)
1199 	struct virtqueue *vq;
1206 	vq = port->vtcport_invq;
1211 	while ((buf = virtqueue_dequeue(vq, &len)) != NULL) {
1226 		virtqueue_notify(vq);
1228 	if (virtqueue_enable_intr(vq) != 0)
1260 	struct virtqueue *vq;
1263 	vq = port->vtcport_outvq;
1264 	KASSERT(virtqueue_empty(vq),
1272 	error = virtqueue_enqueue(vq, buf, &sg, sg.sg_nseg, 0);
1274 		virtqueue_notify(vq);
1275 		virtqueue_poll(vq, NULL);