Lines Matching refs:vq_tx
78 * @vq_tx: tx/uplink virtqueue
82 * @tx_lock: protects vq_tx from concurrent use
105 struct virtqueue *vq_tx;
108 /* Protect access to vq_tx */
140 static void cfv_release_cb(struct virtqueue *vq_tx)
142 struct cfv_info *cfv = vq_tx->vdev->priv;
160 static void cfv_release_used_buf(struct virtqueue *vq_tx)
162 struct cfv_info *cfv = vq_tx->vdev->priv;
165 BUG_ON(vq_tx != cfv->vq_tx);
173 buf_info = virtqueue_get_buf(vq_tx, &len);
186 if (cfv->vq_tx->num_free <= cfv->watermark_tx)
198 virtqueue_get_vring_size(cfv->vq_tx);
203 virtqueue_disable_cb(cfv->vq_tx);
208 virtqueue_get_vring_size(cfv->vq_tx));
210 virtqueue_get_vring_size(cfv->vq_tx) / 4;
384 cfv->allocsz = (virtqueue_get_vring_size(cfv->vq_tx) *
430 cfv->watermark_tx = virtqueue_get_vring_size(cfv->vq_tx);
462 virtqueue_disable_cb(cfv->vq_tx);
467 cfv_release_used_buf(cfv->vq_tx);
469 while ((buf_info = virtqueue_detach_unused_buf(cfv->vq_tx)))
532 cfv_release_used_buf(cfv->vq_tx);
540 if (unlikely(cfv->vq_tx->num_free <= num_present_cpus())) {
563 cfv->watermark_tx = virtqueue_get_vring_size(cfv->vq_tx) / 4;
565 virtqueue_enable_cb(cfv->vq_tx);
575 ret = virtqueue_add_outbuf(cfv->vq_tx, &sg, 1, buf_info, GFP_ATOMIC);
589 virtqueue_kick(cfv->vq_tx);
604 cfv_release_used_buf(cfv->vq_tx);
678 err = virtio_find_vqs(vdev, 1, &cfv->vq_tx, &vq_cbs, &names, NULL);
709 virtqueue_disable_cb(cfv->vq_tx);