[RFC,v2,3/3] eventdev: have adapters support device maintenance
Checks
Commit Message
Introduce support for event devices requiring calls to
rte_event_maintain() in the Ethernet RX, Timer and Crypto Eventdev
adapters.
RFC v2:
- For simplicity, the timer adapter now unconditionally calls
rte_event_maintain().
- The RX adapter now only calls rte_event_maintain() when it has not
enqueued any events.
Signed-off-by: Mattias Rönnblom <mattias.ronnblom@ericsson.com>
Tested-by: Richard Eklycke <richard.eklycke@ericsson.com>
---
lib/eventdev/rte_event_crypto_adapter.c | 16 +++++++++++-----
lib/eventdev/rte_event_eth_rx_adapter.c | 9 +++++++--
lib/eventdev/rte_event_timer_adapter.c | 3 +++
3 files changed, 21 insertions(+), 7 deletions(-)
@@ -630,19 +630,25 @@ static void
eca_crypto_adapter_run(struct rte_event_crypto_adapter *adapter,
unsigned int max_ops)
{
- while (max_ops) {
+ unsigned int ops_left = max_ops;
+
+ while (ops_left > 0) {
unsigned int e_cnt, d_cnt;
- e_cnt = eca_crypto_adapter_deq_run(adapter, max_ops);
- max_ops -= RTE_MIN(max_ops, e_cnt);
+ e_cnt = eca_crypto_adapter_deq_run(adapter, ops_left);
+ ops_left -= RTE_MIN(ops_left, e_cnt);
- d_cnt = eca_crypto_adapter_enq_run(adapter, max_ops);
- max_ops -= RTE_MIN(max_ops, d_cnt);
+ d_cnt = eca_crypto_adapter_enq_run(adapter, ops_left);
+ ops_left -= RTE_MIN(ops_left, d_cnt);
if (e_cnt == 0 && d_cnt == 0)
break;
}
+
+ if (ops_left == max_ops)
+ rte_event_maintain(adapter->eventdev_id,
+ adapter->event_port_id);
}
static int
@@ -923,6 +923,7 @@ rxa_eth_rx(struct rte_event_eth_rx_adapter *rx_adapter,
&rx_adapter->stats;
uint16_t n;
uint32_t nb_rx = 0;
+ uint32_t nb_flushed = 0;
if (rxq_empty)
*rxq_empty = 0;
@@ -931,7 +932,7 @@ rxa_eth_rx(struct rte_event_eth_rx_adapter *rx_adapter,
*/
while (BATCH_SIZE <= (RTE_DIM(buf->events) - buf->count)) {
if (buf->count >= BATCH_SIZE)
- rxa_flush_event_buffer(rx_adapter);
+ nb_flushed += rxa_flush_event_buffer(rx_adapter);
stats->rx_poll_count++;
n = rte_eth_rx_burst(port_id, queue_id, mbufs, BATCH_SIZE);
@@ -947,7 +948,11 @@ rxa_eth_rx(struct rte_event_eth_rx_adapter *rx_adapter,
}
if (buf->count > 0)
- rxa_flush_event_buffer(rx_adapter);
+ nb_flushed += rxa_flush_event_buffer(rx_adapter);
+
+ if (nb_flushed == 0)
+ rte_event_maintain(rx_adapter->eventdev_id,
+ rx_adapter->event_port_id);
return nb_rx;
}
@@ -754,6 +754,9 @@ swtim_service_func(void *arg)
sw->stats.adapter_tick_count++;
}
+ rte_event_maintain(adapter->data->event_dev_id,
+ adapter->data->event_port_id);
+
return 0;
}