Branch data Line data Source code
1 : : /* SPDX-License-Identifier: BSD-3-Clause
2 : : * Copyright(c) 2018 HUAWEI TECHNOLOGIES CO., LTD.
3 : : */
4 : : #include <cryptodev_pmd.h>
5 : :
6 : : #include "virtqueue.h"
7 : : #include "virtio_cryptodev.h"
8 : : #include "virtio_crypto_algs.h"
9 : :
10 : : static void
11 : 0 : vq_ring_free_chain(struct virtqueue *vq, uint16_t desc_idx)
12 : : {
13 : : struct vring_desc *dp, *dp_tail;
14 : : struct vq_desc_extra *dxp;
15 : : uint16_t desc_idx_last = desc_idx;
16 : :
17 : 0 : dp = &vq->vq_ring.desc[desc_idx];
18 : 0 : dxp = &vq->vq_descx[desc_idx];
19 : 0 : vq->vq_free_cnt = (uint16_t)(vq->vq_free_cnt + dxp->ndescs);
20 [ # # ]: 0 : if ((dp->flags & VRING_DESC_F_INDIRECT) == 0) {
21 [ # # ]: 0 : while (dp->flags & VRING_DESC_F_NEXT) {
22 : 0 : desc_idx_last = dp->next;
23 : 0 : dp = &vq->vq_ring.desc[dp->next];
24 : : }
25 : : }
26 : 0 : dxp->ndescs = 0;
27 : :
28 : : /*
29 : : * We must append the existing free chain, if any, to the end of
30 : : * newly freed chain. If the virtqueue was completely used, then
31 : : * head would be VQ_RING_DESC_CHAIN_END (ASSERTed above).
32 : : */
33 [ # # ]: 0 : if (vq->vq_desc_tail_idx == VQ_RING_DESC_CHAIN_END) {
34 : 0 : vq->vq_desc_head_idx = desc_idx;
35 : : } else {
36 : 0 : dp_tail = &vq->vq_ring.desc[vq->vq_desc_tail_idx];
37 : 0 : dp_tail->next = desc_idx;
38 : : }
39 : :
40 : 0 : vq->vq_desc_tail_idx = desc_idx_last;
41 : 0 : dp->next = VQ_RING_DESC_CHAIN_END;
42 : 0 : }
43 : :
44 : : static uint16_t
45 : 0 : virtqueue_dequeue_burst_rx(struct virtqueue *vq,
46 : : struct rte_crypto_op **rx_pkts, uint16_t num)
47 : : {
48 : : struct vring_used_elem *uep;
49 : : struct rte_crypto_op *cop;
50 : : uint16_t used_idx, desc_idx;
51 : : uint16_t i;
52 : : struct virtio_crypto_inhdr *inhdr;
53 : : struct virtio_crypto_op_cookie *op_cookie;
54 : :
55 : : /* Caller does the check */
56 [ # # ]: 0 : for (i = 0; i < num ; i++) {
57 : 0 : used_idx = (uint16_t)(vq->vq_used_cons_idx
58 : 0 : & (vq->vq_nentries - 1));
59 : 0 : uep = &vq->vq_ring.used->ring[used_idx];
60 : 0 : desc_idx = (uint16_t)uep->id;
61 : 0 : cop = (struct rte_crypto_op *)
62 : 0 : vq->vq_descx[desc_idx].crypto_op;
63 [ # # ]: 0 : if (unlikely(cop == NULL)) {
64 : 0 : VIRTIO_CRYPTO_RX_LOG_DBG("vring descriptor with no "
65 : : "mbuf cookie at %u",
66 : : vq->vq_used_cons_idx);
67 : 0 : break;
68 : : }
69 : :
70 : 0 : op_cookie = (struct virtio_crypto_op_cookie *)
71 : : vq->vq_descx[desc_idx].cookie;
72 : : inhdr = &(op_cookie->inhdr);
73 [ # # # # : 0 : switch (inhdr->status) {
# # ]
74 : 0 : case VIRTIO_CRYPTO_OK:
75 : 0 : cop->status = RTE_CRYPTO_OP_STATUS_SUCCESS;
76 : 0 : break;
77 : 0 : case VIRTIO_CRYPTO_ERR:
78 : 0 : cop->status = RTE_CRYPTO_OP_STATUS_ERROR;
79 : 0 : vq->packets_received_failed++;
80 : 0 : break;
81 : 0 : case VIRTIO_CRYPTO_BADMSG:
82 : 0 : cop->status = RTE_CRYPTO_OP_STATUS_INVALID_ARGS;
83 : 0 : vq->packets_received_failed++;
84 : 0 : break;
85 : 0 : case VIRTIO_CRYPTO_NOTSUPP:
86 : 0 : cop->status = RTE_CRYPTO_OP_STATUS_INVALID_ARGS;
87 : 0 : vq->packets_received_failed++;
88 : 0 : break;
89 : 0 : case VIRTIO_CRYPTO_INVSESS:
90 : 0 : cop->status = RTE_CRYPTO_OP_STATUS_INVALID_SESSION;
91 : 0 : vq->packets_received_failed++;
92 : 0 : break;
93 : : default:
94 : : break;
95 : : }
96 : :
97 : 0 : vq->packets_received_total++;
98 : :
99 : 0 : rx_pkts[i] = cop;
100 [ # # ]: 0 : rte_mempool_put(vq->mpool, op_cookie);
101 : :
102 : 0 : vq->vq_used_cons_idx++;
103 : 0 : vq_ring_free_chain(vq, desc_idx);
104 : 0 : vq->vq_descx[desc_idx].crypto_op = NULL;
105 : : }
106 : :
107 : 0 : return i;
108 : : }
109 : :
110 : : static int
111 : 0 : virtqueue_crypto_sym_pkt_header_arrange(
112 : : struct rte_crypto_op *cop,
113 : : struct virtio_crypto_op_data_req *data,
114 : : struct virtio_crypto_session *session)
115 : : {
116 : : struct rte_crypto_sym_op *sym_op = cop->sym;
117 : : struct virtio_crypto_op_data_req *req_data = data;
118 : : struct virtio_crypto_op_ctrl_req *ctrl = &session->ctrl;
119 : : struct virtio_crypto_sym_create_session_req *sym_sess_req =
120 : : &ctrl->u.sym_create_session;
121 : : struct virtio_crypto_alg_chain_session_para *chain_para =
122 : : &sym_sess_req->u.chain.para;
123 : : struct virtio_crypto_cipher_session_para *cipher_para;
124 : :
125 : 0 : req_data->header.session_id = session->session_id;
126 : :
127 [ # # # ]: 0 : switch (sym_sess_req->op_type) {
128 : 0 : case VIRTIO_CRYPTO_SYM_OP_CIPHER:
129 : 0 : req_data->u.sym_req.op_type = VIRTIO_CRYPTO_SYM_OP_CIPHER;
130 : :
131 : : cipher_para = &sym_sess_req->u.cipher.para;
132 [ # # ]: 0 : if (cipher_para->op == VIRTIO_CRYPTO_OP_ENCRYPT)
133 : 0 : req_data->header.opcode = VIRTIO_CRYPTO_CIPHER_ENCRYPT;
134 : : else
135 : 0 : req_data->header.opcode = VIRTIO_CRYPTO_CIPHER_DECRYPT;
136 : :
137 : : req_data->u.sym_req.u.cipher.para.iv_len
138 : 0 : = session->iv.length;
139 : :
140 : 0 : req_data->u.sym_req.u.cipher.para.src_data_len =
141 : 0 : (sym_op->cipher.data.length +
142 : 0 : sym_op->cipher.data.offset);
143 : 0 : req_data->u.sym_req.u.cipher.para.dst_data_len =
144 : : req_data->u.sym_req.u.cipher.para.src_data_len;
145 : 0 : break;
146 : 0 : case VIRTIO_CRYPTO_SYM_OP_ALGORITHM_CHAINING:
147 : 0 : req_data->u.sym_req.op_type =
148 : : VIRTIO_CRYPTO_SYM_OP_ALGORITHM_CHAINING;
149 : :
150 : : cipher_para = &chain_para->cipher_param;
151 [ # # ]: 0 : if (cipher_para->op == VIRTIO_CRYPTO_OP_ENCRYPT)
152 : 0 : req_data->header.opcode = VIRTIO_CRYPTO_CIPHER_ENCRYPT;
153 : : else
154 : 0 : req_data->header.opcode = VIRTIO_CRYPTO_CIPHER_DECRYPT;
155 : :
156 : 0 : req_data->u.sym_req.u.chain.para.iv_len = session->iv.length;
157 : : req_data->u.sym_req.u.chain.para.aad_len = session->aad.length;
158 : :
159 : 0 : req_data->u.sym_req.u.chain.para.src_data_len =
160 : 0 : (sym_op->cipher.data.length +
161 : 0 : sym_op->cipher.data.offset);
162 : 0 : req_data->u.sym_req.u.chain.para.dst_data_len =
163 : : req_data->u.sym_req.u.chain.para.src_data_len;
164 : 0 : req_data->u.sym_req.u.chain.para.cipher_start_src_offset =
165 : : sym_op->cipher.data.offset;
166 : 0 : req_data->u.sym_req.u.chain.para.len_to_cipher =
167 : : sym_op->cipher.data.length;
168 : 0 : req_data->u.sym_req.u.chain.para.hash_start_src_offset =
169 : 0 : sym_op->auth.data.offset;
170 : 0 : req_data->u.sym_req.u.chain.para.len_to_hash =
171 : 0 : sym_op->auth.data.length;
172 : 0 : req_data->u.sym_req.u.chain.para.aad_len =
173 : 0 : chain_para->aad_len;
174 : :
175 [ # # ]: 0 : if (chain_para->hash_mode == VIRTIO_CRYPTO_SYM_HASH_MODE_PLAIN)
176 : 0 : req_data->u.sym_req.u.chain.para.hash_result_len =
177 : 0 : chain_para->u.hash_param.hash_result_len;
178 [ # # ]: 0 : if (chain_para->hash_mode ==
179 : : VIRTIO_CRYPTO_SYM_HASH_MODE_AUTH)
180 : 0 : req_data->u.sym_req.u.chain.para.hash_result_len =
181 : 0 : chain_para->u.mac_param.hash_result_len;
182 : : break;
183 : : default:
184 : : return -1;
185 : : }
186 : :
187 : : return 0;
188 : : }
189 : :
190 : : static int
191 : 0 : virtqueue_crypto_sym_enqueue_xmit(
192 : : struct virtqueue *txvq,
193 : : struct rte_crypto_op *cop)
194 : : {
195 : : uint16_t idx = 0;
196 : : uint16_t num_entry;
197 : : uint16_t needed = 1;
198 : : uint16_t head_idx;
199 : : struct vq_desc_extra *dxp;
200 : : struct vring_desc *start_dp;
201 : : struct vring_desc *desc;
202 : : uint64_t indirect_op_data_req_phys_addr;
203 : : uint16_t req_data_len = sizeof(struct virtio_crypto_op_data_req);
204 : : uint32_t indirect_vring_addr_offset = req_data_len +
205 : : sizeof(struct virtio_crypto_inhdr);
206 : : uint32_t indirect_iv_addr_offset =
207 : : offsetof(struct virtio_crypto_op_cookie, iv);
208 : : struct rte_crypto_sym_op *sym_op = cop->sym;
209 : 0 : struct virtio_crypto_session *session =
210 : 0 : CRYPTODEV_GET_SYM_SESS_PRIV(cop->sym->session);
211 : : struct virtio_crypto_op_data_req *op_data_req;
212 : : uint32_t hash_result_len = 0;
213 : : struct virtio_crypto_op_cookie *crypto_op_cookie;
214 : : struct virtio_crypto_alg_chain_session_para *para;
215 : :
216 [ # # ]: 0 : if (unlikely(sym_op->m_src->nb_segs != 1))
217 : : return -EMSGSIZE;
218 [ # # ]: 0 : if (unlikely(txvq->vq_free_cnt == 0))
219 : : return -ENOSPC;
220 : : if (unlikely(txvq->vq_free_cnt < needed))
221 : : return -EMSGSIZE;
222 : 0 : head_idx = txvq->vq_desc_head_idx;
223 [ # # ]: 0 : if (unlikely(head_idx >= txvq->vq_nentries))
224 : : return -EFAULT;
225 : : if (unlikely(session == NULL))
226 : : return -EFAULT;
227 : :
228 : 0 : dxp = &txvq->vq_descx[head_idx];
229 : :
230 [ # # # # ]: 0 : if (rte_mempool_get(txvq->mpool, &dxp->cookie)) {
231 : 0 : VIRTIO_CRYPTO_TX_LOG_ERR("can not get cookie");
232 : 0 : return -EFAULT;
233 : : }
234 : 0 : crypto_op_cookie = dxp->cookie;
235 : : indirect_op_data_req_phys_addr =
236 : : rte_mempool_virt2iova(crypto_op_cookie);
237 : : op_data_req = (struct virtio_crypto_op_data_req *)crypto_op_cookie;
238 : :
239 [ # # ]: 0 : if (virtqueue_crypto_sym_pkt_header_arrange(cop, op_data_req, session))
240 : : return -EFAULT;
241 : :
242 : : /* status is initialized to VIRTIO_CRYPTO_ERR */
243 : : ((struct virtio_crypto_inhdr *)
244 : 0 : ((uint8_t *)op_data_req + req_data_len))->status =
245 : : VIRTIO_CRYPTO_ERR;
246 : :
247 : : /* point to indirect vring entry */
248 : 0 : desc = (struct vring_desc *)
249 : : ((uint8_t *)op_data_req + indirect_vring_addr_offset);
250 [ # # ]: 0 : for (idx = 0; idx < (NUM_ENTRY_VIRTIO_CRYPTO_OP - 1); idx++)
251 : 0 : desc[idx].next = idx + 1;
252 : 0 : desc[NUM_ENTRY_VIRTIO_CRYPTO_OP - 1].next = VQ_RING_DESC_CHAIN_END;
253 : :
254 : : idx = 0;
255 : :
256 : : /* indirect vring: first part, virtio_crypto_op_data_req */
257 : 0 : desc[idx].addr = indirect_op_data_req_phys_addr;
258 : 0 : desc[idx].len = req_data_len;
259 : 0 : desc[idx++].flags = VRING_DESC_F_NEXT;
260 : :
261 : : /* indirect vring: iv of cipher */
262 [ # # ]: 0 : if (session->iv.length) {
263 [ # # ]: 0 : if (cop->phys_addr)
264 : 0 : desc[idx].addr = cop->phys_addr + session->iv.offset;
265 : : else {
266 [ # # ]: 0 : if (session->iv.length > VIRTIO_CRYPTO_MAX_IV_SIZE)
267 : : return -ENOMEM;
268 : :
269 : 0 : rte_memcpy(crypto_op_cookie->iv,
270 [ # # ]: 0 : rte_crypto_op_ctod_offset(cop,
271 : : uint8_t *, session->iv.offset),
272 : : session->iv.length);
273 : 0 : desc[idx].addr = indirect_op_data_req_phys_addr +
274 : : indirect_iv_addr_offset;
275 : : }
276 : :
277 : 0 : desc[idx].len = session->iv.length;
278 : 0 : desc[idx++].flags = VRING_DESC_F_NEXT;
279 : : }
280 : :
281 : : /* indirect vring: additional auth data */
282 [ # # ]: 0 : if (session->aad.length) {
283 : 0 : desc[idx].addr = session->aad.phys_addr;
284 : 0 : desc[idx].len = session->aad.length;
285 : 0 : desc[idx++].flags = VRING_DESC_F_NEXT;
286 : : }
287 : :
288 : : /* indirect vring: src data */
289 [ # # ]: 0 : desc[idx].addr = rte_pktmbuf_iova_offset(sym_op->m_src, 0);
290 : 0 : desc[idx].len = (sym_op->cipher.data.offset
291 : 0 : + sym_op->cipher.data.length);
292 : 0 : desc[idx++].flags = VRING_DESC_F_NEXT;
293 : :
294 : : /* indirect vring: dst data */
295 [ # # ]: 0 : if (sym_op->m_dst) {
296 : 0 : desc[idx].addr = rte_pktmbuf_iova_offset(sym_op->m_dst, 0);
297 : 0 : desc[idx].len = (sym_op->cipher.data.offset
298 : : + sym_op->cipher.data.length);
299 : : } else {
300 : 0 : desc[idx].addr = rte_pktmbuf_iova_offset(sym_op->m_src, 0);
301 : 0 : desc[idx].len = (sym_op->cipher.data.offset
302 : : + sym_op->cipher.data.length);
303 : : }
304 : 0 : desc[idx++].flags = VRING_DESC_F_WRITE | VRING_DESC_F_NEXT;
305 : :
306 : : /* indirect vring: digest result */
307 : : para = &(session->ctrl.u.sym_create_session.u.chain.para);
308 [ # # ]: 0 : if (para->hash_mode == VIRTIO_CRYPTO_SYM_HASH_MODE_PLAIN)
309 : 0 : hash_result_len = para->u.hash_param.hash_result_len;
310 [ # # ]: 0 : if (para->hash_mode == VIRTIO_CRYPTO_SYM_HASH_MODE_AUTH)
311 : 0 : hash_result_len = para->u.mac_param.hash_result_len;
312 [ # # ]: 0 : if (hash_result_len > 0) {
313 : 0 : desc[idx].addr = sym_op->auth.digest.phys_addr;
314 : 0 : desc[idx].len = hash_result_len;
315 : 0 : desc[idx++].flags = VRING_DESC_F_WRITE | VRING_DESC_F_NEXT;
316 : : }
317 : :
318 : : /* indirect vring: last part, status returned */
319 : 0 : desc[idx].addr = indirect_op_data_req_phys_addr + req_data_len;
320 : 0 : desc[idx].len = sizeof(struct virtio_crypto_inhdr);
321 : 0 : desc[idx++].flags = VRING_DESC_F_WRITE;
322 : :
323 : : num_entry = idx;
324 : :
325 : : /* save the infos to use when receiving packets */
326 : 0 : dxp->crypto_op = (void *)cop;
327 : 0 : dxp->ndescs = needed;
328 : :
329 : : /* use a single buffer */
330 : 0 : start_dp = txvq->vq_ring.desc;
331 : 0 : start_dp[head_idx].addr = indirect_op_data_req_phys_addr +
332 : : indirect_vring_addr_offset;
333 : 0 : start_dp[head_idx].len = num_entry * sizeof(struct vring_desc);
334 : 0 : start_dp[head_idx].flags = VRING_DESC_F_INDIRECT;
335 : :
336 : 0 : idx = start_dp[head_idx].next;
337 : 0 : txvq->vq_desc_head_idx = idx;
338 [ # # ]: 0 : if (txvq->vq_desc_head_idx == VQ_RING_DESC_CHAIN_END)
339 : 0 : txvq->vq_desc_tail_idx = idx;
340 [ # # ]: 0 : txvq->vq_free_cnt = (uint16_t)(txvq->vq_free_cnt - needed);
341 : : vq_update_avail_ring(txvq, head_idx);
342 : :
343 : 0 : return 0;
344 : : }
345 : :
346 : : static int
347 : 0 : virtqueue_crypto_enqueue_xmit(struct virtqueue *txvq,
348 : : struct rte_crypto_op *cop)
349 : : {
350 : : int ret;
351 : :
352 [ # # ]: 0 : switch (cop->type) {
353 : 0 : case RTE_CRYPTO_OP_TYPE_SYMMETRIC:
354 : 0 : ret = virtqueue_crypto_sym_enqueue_xmit(txvq, cop);
355 : 0 : break;
356 : 0 : default:
357 : 0 : VIRTIO_CRYPTO_TX_LOG_ERR("invalid crypto op type %u",
358 : : cop->type);
359 : : ret = -EFAULT;
360 : 0 : break;
361 : : }
362 : :
363 : 0 : return ret;
364 : : }
365 : :
366 : : static int
367 : 0 : virtio_crypto_vring_start(struct virtqueue *vq)
368 : : {
369 : 0 : struct virtio_crypto_hw *hw = vq->hw;
370 : 0 : int i, size = vq->vq_nentries;
371 : : struct vring *vr = &vq->vq_ring;
372 : 0 : uint8_t *ring_mem = vq->vq_ring_virt_mem;
373 : :
374 : 0 : PMD_INIT_FUNC_TRACE();
375 : :
376 : 0 : vring_init(vr, size, ring_mem, VIRTIO_PCI_VRING_ALIGN);
377 : 0 : vq->vq_desc_tail_idx = (uint16_t)(vq->vq_nentries - 1);
378 : 0 : vq->vq_free_cnt = vq->vq_nentries;
379 : :
380 : : /* Chain all the descriptors in the ring with an END */
381 [ # # ]: 0 : for (i = 0; i < size - 1; i++)
382 : 0 : vr->desc[i].next = (uint16_t)(i + 1);
383 : 0 : vr->desc[i].next = VQ_RING_DESC_CHAIN_END;
384 : :
385 : : /*
386 : : * Disable device(host) interrupting guest
387 : : */
388 : 0 : virtqueue_disable_intr(vq);
389 : :
390 : : /*
391 : : * Set guest physical address of the virtqueue
392 : : * in VIRTIO_PCI_QUEUE_PFN config register of device
393 : : * to share with the backend
394 : : */
395 [ # # ]: 0 : if (VTPCI_OPS(hw)->setup_queue(hw, vq) < 0) {
396 : 0 : VIRTIO_CRYPTO_INIT_LOG_ERR("setup_queue failed");
397 : 0 : return -EINVAL;
398 : : }
399 : :
400 : : return 0;
401 : : }
402 : :
403 : : void
404 : 0 : virtio_crypto_ctrlq_start(struct rte_cryptodev *dev)
405 : : {
406 : 0 : struct virtio_crypto_hw *hw = dev->data->dev_private;
407 : :
408 [ # # ]: 0 : if (hw->cvq) {
409 : 0 : virtio_crypto_vring_start(hw->cvq);
410 : 0 : VIRTQUEUE_DUMP((struct virtqueue *)hw->cvq);
411 : : }
412 : 0 : }
413 : :
414 : : void
415 : 0 : virtio_crypto_dataq_start(struct rte_cryptodev *dev)
416 : : {
417 : : /*
418 : : * Start data vrings
419 : : * - Setup vring structure for data queues
420 : : */
421 : : uint16_t i;
422 : :
423 : 0 : PMD_INIT_FUNC_TRACE();
424 : :
425 : : /* Start data vring. */
426 [ # # ]: 0 : for (i = 0; i < dev->data->nb_queue_pairs; i++) {
427 : 0 : virtio_crypto_vring_start(dev->data->queue_pairs[i]);
428 : 0 : VIRTQUEUE_DUMP((struct virtqueue *)dev->data->queue_pairs[i]);
429 : : }
430 : 0 : }
431 : :
432 : : /* vring size of data queue is 1024 */
433 : : #define VIRTIO_MBUF_BURST_SZ 1024
434 : :
435 : : uint16_t
436 : 0 : virtio_crypto_pkt_rx_burst(void *tx_queue, struct rte_crypto_op **rx_pkts,
437 : : uint16_t nb_pkts)
438 : : {
439 : : struct virtqueue *txvq = tx_queue;
440 : : uint16_t nb_used, num, nb_rx;
441 : :
442 : 0 : nb_used = VIRTQUEUE_NUSED(txvq);
443 : :
444 : 0 : virtio_rmb();
445 : :
446 [ # # ]: 0 : num = (uint16_t)(likely(nb_used <= nb_pkts) ? nb_used : nb_pkts);
447 [ # # ]: 0 : num = (uint16_t)(likely(num <= VIRTIO_MBUF_BURST_SZ)
448 : : ? num : VIRTIO_MBUF_BURST_SZ);
449 : :
450 [ # # ]: 0 : if (num == 0)
451 : : return 0;
452 : :
453 : 0 : nb_rx = virtqueue_dequeue_burst_rx(txvq, rx_pkts, num);
454 : 0 : VIRTIO_CRYPTO_RX_LOG_DBG("used:%d dequeue:%d", nb_used, num);
455 : :
456 : 0 : return nb_rx;
457 : : }
458 : :
459 : : uint16_t
460 : 0 : virtio_crypto_pkt_tx_burst(void *tx_queue, struct rte_crypto_op **tx_pkts,
461 : : uint16_t nb_pkts)
462 : : {
463 : : struct virtqueue *txvq;
464 : : uint16_t nb_tx;
465 : : int error;
466 : :
467 [ # # ]: 0 : if (unlikely(nb_pkts < 1))
468 : : return nb_pkts;
469 [ # # ]: 0 : if (unlikely(tx_queue == NULL)) {
470 : 0 : VIRTIO_CRYPTO_TX_LOG_ERR("tx_queue is NULL");
471 : 0 : return 0;
472 : : }
473 : : txvq = tx_queue;
474 : :
475 : 0 : VIRTIO_CRYPTO_TX_LOG_DBG("%d packets to xmit", nb_pkts);
476 : :
477 [ # # ]: 0 : for (nb_tx = 0; nb_tx < nb_pkts; nb_tx++) {
478 : 0 : struct rte_mbuf *txm = tx_pkts[nb_tx]->sym->m_src;
479 : : /* nb_segs is always 1 at virtio crypto situation */
480 : 0 : int need = txm->nb_segs - txvq->vq_free_cnt;
481 : :
482 : : /*
483 : : * Positive value indicates it hasn't enough space in vring
484 : : * descriptors
485 : : */
486 [ # # ]: 0 : if (unlikely(need > 0)) {
487 : : /*
488 : : * try it again because the receive process may be
489 : : * free some space
490 : : */
491 : : need = txm->nb_segs - txvq->vq_free_cnt;
492 : : if (unlikely(need > 0)) {
493 : 0 : VIRTIO_CRYPTO_TX_LOG_DBG("No free tx "
494 : : "descriptors to transmit");
495 : 0 : break;
496 : : }
497 : : }
498 : :
499 : 0 : txvq->packets_sent_total++;
500 : :
501 : : /* Enqueue Packet buffers */
502 : 0 : error = virtqueue_crypto_enqueue_xmit(txvq, tx_pkts[nb_tx]);
503 [ # # ]: 0 : if (unlikely(error)) {
504 [ # # ]: 0 : if (error == ENOSPC)
505 : 0 : VIRTIO_CRYPTO_TX_LOG_ERR(
506 : : "virtqueue_enqueue Free count = 0");
507 [ # # ]: 0 : else if (error == EMSGSIZE)
508 : 0 : VIRTIO_CRYPTO_TX_LOG_ERR(
509 : : "virtqueue_enqueue Free count < 1");
510 : : else
511 : 0 : VIRTIO_CRYPTO_TX_LOG_ERR(
512 : : "virtqueue_enqueue error: %d", error);
513 : 0 : txvq->packets_sent_failed++;
514 : 0 : break;
515 : : }
516 : : }
517 : :
518 [ # # ]: 0 : if (likely(nb_tx)) {
519 : : vq_update_avail_idx(txvq);
520 : :
521 [ # # ]: 0 : if (unlikely(virtqueue_kick_prepare(txvq))) {
522 : : virtqueue_notify(txvq);
523 : 0 : VIRTIO_CRYPTO_TX_LOG_DBG("Notified backend after xmit");
524 : : }
525 : : }
526 : :
527 : : return nb_tx;
528 : : }
|
