1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2010-2015 Intel Corporation
9 #include "virtio_logs.h"
10 #include "virtio_pci.h"
11 #include "virtio_rxtx_simple.h"
14 * Two types of mbuf to be cleaned:
15 * 1) mbuf that has been consumed by backend but not used by virtio.
16 * 2) mbuf that hasn't been consued by backend.
19 virtqueue_detach_unused(struct virtqueue *vq)
21 struct rte_mbuf *cookie;
30 type = virtio_get_queue_type(hw, vq->vq_queue_index);
31 start = vq->vq_avail_idx & (vq->vq_nentries - 1);
32 end = (vq->vq_avail_idx + vq->vq_free_cnt) & (vq->vq_nentries - 1);
34 for (idx = 0; idx < vq->vq_nentries; idx++) {
35 if (hw->use_simple_rx && type == VTNET_RQ) {
36 if (start <= end && idx >= start && idx < end)
38 if (start > end && (idx >= start || idx < end))
40 cookie = vq->sw_ring[idx];
42 vq->sw_ring[idx] = NULL;
46 cookie = vq->vq_descx[idx].cookie;
48 vq->vq_descx[idx].cookie = NULL;
57 /* Flush used descs */
59 virtqueue_rxvq_flush_packed(struct virtqueue *vq)
61 struct vq_desc_extra *dxp;
64 struct vring_packed_desc *descs = vq->vq_packed.ring.desc;
67 i = vq->vq_used_cons_idx;
68 while (desc_is_used(&descs[i], vq) && cnt++ < vq->vq_nentries) {
69 dxp = &vq->vq_descx[descs[i].id];
70 if (dxp->cookie != NULL) {
71 rte_pktmbuf_free(dxp->cookie);
75 vq->vq_used_cons_idx++;
76 if (vq->vq_used_cons_idx >= vq->vq_nentries) {
77 vq->vq_used_cons_idx -= vq->vq_nentries;
78 vq->vq_packed.used_wrap_counter ^= 1;
80 i = vq->vq_used_cons_idx;
84 /* Flush the elements in the used ring. */
86 virtqueue_rxvq_flush_split(struct virtqueue *vq)
88 struct virtnet_rx *rxq = &vq->rxq;
89 struct virtio_hw *hw = vq->hw;
90 struct vring_used_elem *uep;
91 struct vq_desc_extra *dxp;
92 uint16_t used_idx, desc_idx;
95 nb_used = VIRTQUEUE_NUSED(vq);
97 for (i = 0; i < nb_used; i++) {
98 used_idx = vq->vq_used_cons_idx & (vq->vq_nentries - 1);
99 uep = &vq->vq_split.ring.used->ring[used_idx];
100 if (hw->use_simple_rx) {
102 rte_pktmbuf_free(vq->sw_ring[desc_idx]);
104 } else if (hw->use_inorder_rx) {
105 desc_idx = (uint16_t)uep->id;
106 dxp = &vq->vq_descx[desc_idx];
107 if (dxp->cookie != NULL) {
108 rte_pktmbuf_free(dxp->cookie);
111 vq_ring_free_inorder(vq, desc_idx, 1);
113 desc_idx = (uint16_t)uep->id;
114 dxp = &vq->vq_descx[desc_idx];
115 if (dxp->cookie != NULL) {
116 rte_pktmbuf_free(dxp->cookie);
119 vq_ring_free_chain(vq, desc_idx);
121 vq->vq_used_cons_idx++;
124 if (hw->use_simple_rx) {
125 while (vq->vq_free_cnt >= RTE_VIRTIO_VPMD_RX_REARM_THRESH) {
126 virtio_rxq_rearm_vec(rxq);
127 if (virtqueue_kick_prepare(vq))
128 virtqueue_notify(vq);
133 /* Flush the elements in the used ring. */
135 virtqueue_rxvq_flush(struct virtqueue *vq)
137 struct virtio_hw *hw = vq->hw;
139 if (vtpci_packed_queue(hw))
140 virtqueue_rxvq_flush_packed(vq);
142 virtqueue_rxvq_flush_split(vq);
146 virtqueue_rxvq_reset_packed(struct virtqueue *vq)
148 int size = vq->vq_nentries;
149 struct vq_desc_extra *dxp;
150 struct virtnet_rx *rxvq;
153 vq->vq_used_cons_idx = 0;
154 vq->vq_desc_head_idx = 0;
155 vq->vq_avail_idx = 0;
156 vq->vq_desc_tail_idx = (uint16_t)(vq->vq_nentries - 1);
157 vq->vq_free_cnt = vq->vq_nentries;
159 vq->vq_packed.used_wrap_counter = 1;
160 vq->vq_packed.cached_flags = VRING_PACKED_DESC_F_AVAIL;
161 vq->vq_packed.event_flags_shadow = 0;
162 vq->vq_packed.cached_flags |= VRING_DESC_F_WRITE;
165 memset(rxvq->mz->addr, 0, rxvq->mz->len);
167 for (desc_idx = 0; desc_idx < vq->vq_nentries; desc_idx++) {
168 dxp = &vq->vq_descx[desc_idx];
169 if (dxp->cookie != NULL) {
170 rte_pktmbuf_free(dxp->cookie);
175 vring_desc_init_packed(vq, size);
181 virtqueue_txvq_reset_packed(struct virtqueue *vq)
183 int size = vq->vq_nentries;
184 struct vq_desc_extra *dxp;
185 struct virtnet_tx *txvq;
188 vq->vq_used_cons_idx = 0;
189 vq->vq_desc_head_idx = 0;
190 vq->vq_avail_idx = 0;
191 vq->vq_desc_tail_idx = (uint16_t)(vq->vq_nentries - 1);
192 vq->vq_free_cnt = vq->vq_nentries;
194 vq->vq_packed.used_wrap_counter = 1;
195 vq->vq_packed.cached_flags = VRING_PACKED_DESC_F_AVAIL;
196 vq->vq_packed.event_flags_shadow = 0;
199 memset(txvq->mz->addr, 0, txvq->mz->len);
200 memset(txvq->virtio_net_hdr_mz->addr, 0,
201 txvq->virtio_net_hdr_mz->len);
203 for (desc_idx = 0; desc_idx < vq->vq_nentries; desc_idx++) {
204 dxp = &vq->vq_descx[desc_idx];
205 if (dxp->cookie != NULL) {
206 rte_pktmbuf_free(dxp->cookie);
211 vring_desc_init_packed(vq, size);