Separate the logic of initializing vq, and subsequent patches will call
it separately.

The feature of this part is that it does not depend on the information
passed by the upper layer and can be called repeatedly.

Signed-off-by: Xuan Zhuo <[email protected]>
---
 drivers/virtio/virtio_ring.c | 65 ++++++++++++++++++++----------------
 1 file changed, 36 insertions(+), 29 deletions(-)

diff --git a/drivers/virtio/virtio_ring.c b/drivers/virtio/virtio_ring.c
index 6ed10c46d6d6..81bbfd65411e 100644
--- a/drivers/virtio/virtio_ring.c
+++ b/drivers/virtio/virtio_ring.c
@@ -2228,6 +2228,41 @@ static void __vring_virtqueue_attach_split(struct 
vring_virtqueue *vq,
        vq->split.desc_extra = desc_extra;
 }
 
+static void __vring_virtqueue_init_split(struct vring_virtqueue *vq,
+                                        struct virtio_device *vdev)
+{
+       vq->packed_ring = false;
+       vq->we_own_ring = false;
+       vq->broken = false;
+       vq->last_used_idx = 0;
+       vq->event_triggered = false;
+       vq->num_added = 0;
+       vq->use_dma_api = vring_use_dma_api(vdev);
+#ifdef DEBUG
+       vq->in_use = false;
+       vq->last_add_time_valid = false;
+#endif
+
+       vq->event = virtio_has_feature(vdev, VIRTIO_RING_F_EVENT_IDX);
+
+       if (virtio_has_feature(vdev, VIRTIO_F_ORDER_PLATFORM))
+               vq->weak_barriers = false;
+
+       vq->split.avail_flags_shadow = 0;
+       vq->split.avail_idx_shadow = 0;
+
+       /* No callback?  Tell other side not to bother us. */
+       if (!vq->vq.callback) {
+               vq->split.avail_flags_shadow |= VRING_AVAIL_F_NO_INTERRUPT;
+               if (!vq->event)
+                       vq->split.vring.avail->flags = cpu_to_virtio16(vdev,
+                                       vq->split.avail_flags_shadow);
+       }
+
+       /* Put everything in free lists. */
+       vq->free_head = 0;
+}
+
 /* Only available for split ring */
 struct virtqueue *__vring_new_virtqueue(unsigned int index,
                                        struct vring vring,
@@ -2250,41 +2285,15 @@ struct virtqueue *__vring_new_virtqueue(unsigned int 
index,
        if (!vq)
                return NULL;
 
-       vq->packed_ring = false;
        vq->vq.callback = callback;
        vq->vq.vdev = vdev;
        vq->vq.name = name;
        vq->vq.index = index;
-       vq->we_own_ring = false;
        vq->notify = notify;
        vq->weak_barriers = weak_barriers;
-       vq->broken = false;
-       vq->last_used_idx = 0;
-       vq->event_triggered = false;
-       vq->num_added = 0;
-       vq->use_dma_api = vring_use_dma_api(vdev);
-#ifdef DEBUG
-       vq->in_use = false;
-       vq->last_add_time_valid = false;
-#endif
 
        vq->indirect = virtio_has_feature(vdev, VIRTIO_RING_F_INDIRECT_DESC) &&
                !context;
-       vq->event = virtio_has_feature(vdev, VIRTIO_RING_F_EVENT_IDX);
-
-       if (virtio_has_feature(vdev, VIRTIO_F_ORDER_PLATFORM))
-               vq->weak_barriers = false;
-
-       vq->split.avail_flags_shadow = 0;
-       vq->split.avail_idx_shadow = 0;
-
-       /* No callback?  Tell other side not to bother us. */
-       if (!callback) {
-               vq->split.avail_flags_shadow |= VRING_AVAIL_F_NO_INTERRUPT;
-               if (!vq->event)
-                       vq->split.vring.avail->flags = cpu_to_virtio16(vdev,
-                                       vq->split.avail_flags_shadow);
-       }
 
        err = __vring_alloc_state_extra_split(vring.num, &state, &extra);
        if (err) {
@@ -2293,9 +2302,7 @@ struct virtqueue *__vring_new_virtqueue(unsigned int 
index,
        }
 
        __vring_virtqueue_attach_split(vq, vring, state, extra);
-
-       /* Put everything in free lists. */
-       vq->free_head = 0;
+       __vring_virtqueue_init_split(vq, vdev);
 
        spin_lock(&vdev->vqs_list_lock);
        list_add_tail(&vq->vq.list, &vdev->vqs);
-- 
2.31.0

_______________________________________________
Virtualization mailing list
[email protected]
https://lists.linuxfoundation.org/mailman/listinfo/virtualization

Reply via email to