- uint16_t nb_deq_ops = rte_ring_dequeue_burst(enq_ring,
- (void *)enq_ops, MC_SCHED_BUFFER_SIZE, NULL);
- if (nb_deq_ops) {
- uint16_t i;
-
- for (i = 0; i < nb_deq_ops && i < 4; i++)
- rte_prefetch0(enq_ops[i]->sym->session);
-
- for (i = 0; (i < (nb_deq_ops - 8))
- && (nb_deq_ops > 8); i += 4) {
- sess0 = (struct scheduler_session *)
- enq_ops[i]->sym->session->_private;
- sess1 = (struct scheduler_session *)
- enq_ops[i+1]->sym->session->_private;
- sess2 = (struct scheduler_session *)
- enq_ops[i+2]->sym->session->_private;
- sess3 = (struct scheduler_session *)
- enq_ops[i+3]->sym->session->_private;
-
- enq_ops[i]->sym->session =
- sess0->sessions[worker_idx];
- enq_ops[i + 1]->sym->session =
- sess1->sessions[worker_idx];
- enq_ops[i + 2]->sym->session =
- sess2->sessions[worker_idx];
- enq_ops[i + 3]->sym->session =
- sess3->sessions[worker_idx];
-
- rte_prefetch0(enq_ops[i + 4]->sym->session);
- rte_prefetch0(enq_ops[i + 5]->sym->session);
- rte_prefetch0(enq_ops[i + 6]->sym->session);
- rte_prefetch0(enq_ops[i + 7]->sym->session);
- }
-
- for (; i < nb_deq_ops; i++) {
- sess0 = (struct scheduler_session *)
- enq_ops[i]->sym->session->_private;
- enq_ops[i]->sym->session =
- sess0->sessions[worker_idx];
- }
-
- processed_ops = rte_cryptodev_enqueue_burst(slave->dev_id,
- slave->qp_id, enq_ops, nb_deq_ops);
-
- if (unlikely(processed_ops < nb_deq_ops)) {
- left_op = nb_deq_ops - processed_ops;
- left_op_idx = processed_ops;
- }
-
- inflight_ops += processed_ops;
+ processed_ops = rte_ring_dequeue_burst(enq_ring, (void *)enq_ops,
+ MC_SCHED_BUFFER_SIZE, NULL);
+ if (processed_ops) {
+ pending_enq_ops_idx = rte_cryptodev_enqueue_burst(
+ slave->dev_id, slave->qp_id,
+ enq_ops, processed_ops);
+ pending_enq_ops = processed_ops - pending_enq_ops_idx;
+ inflight_ops += pending_enq_ops_idx;