#include <stdbool.h>
#include "l3fwd.h"
#include "l3fwd_event.h"
static uint32_t
l3fwd_event_device_setup_internal_port(void)
{
struct l3fwd_event_resources *evt_rsrc = l3fwd_get_eventdev_rsrc();
.nb_event_queue_flows = 1024,
.nb_event_port_dequeue_depth = 128,
.nb_event_port_enqueue_depth = 128
};
const uint8_t event_d_id = 0;
uint32_t event_queue_cfg = 0;
uint16_t ethdev_count = 0;
uint16_t num_workers = 0;
uint16_t port_id;
int ret;
if ((evt_rsrc->port_mask & (1 << port_id)) == 0)
continue;
ethdev_count++;
}
evt_rsrc->disable_implicit_release = 0;
evt_rsrc->evp.nb_ports = num_workers;
if (ret < 0)
rte_panic(
"Error in configuring event device\n");
evt_rsrc->event_d_id = event_d_id;
return event_queue_cfg;
}
static void
l3fwd_event_port_setup_internal_port(void)
{
struct l3fwd_event_resources *evt_rsrc = l3fwd_get_eventdev_rsrc();
uint8_t event_d_id = evt_rsrc->event_d_id;
.enqueue_depth = 32,
.new_event_threshold = 4096
};
uint8_t event_p_id;
int32_t ret;
evt_rsrc->evp.event_p_id = (uint8_t *)malloc(sizeof(uint8_t) *
evt_rsrc->evp.nb_ports);
if (!evt_rsrc->evp.event_p_id)
rte_panic(
"Failed to allocate memory for Event Ports\n");
if (ret < 0)
rte_panic(
"Error to get default configuration of event port\n");
if (evt_rsrc->disable_implicit_release)
for (event_p_id = 0; event_p_id < evt_rsrc->evp.nb_ports;
event_p_id++) {
&event_p_conf);
if (ret < 0)
rte_panic(
"Error in configuring event port %d\n",
event_p_id);
NULL, 0);
if (ret < 0)
rte_panic(
"Error in linking event port %d to queue\n",
event_p_id);
evt_rsrc->evp.event_p_id[event_p_id] = event_p_id;
}
evt_rsrc->def_p_conf = event_p_conf;
}
static void
l3fwd_event_queue_setup_internal_port(uint32_t event_queue_cfg)
{
struct l3fwd_event_resources *evt_rsrc = l3fwd_get_eventdev_rsrc();
uint8_t event_d_id = evt_rsrc->event_d_id;
.nb_atomic_order_sequences = 1024,
};
uint8_t event_q_id = 0;
int32_t ret;
&def_q_conf);
if (ret < 0)
rte_panic(
"Error to get default config of event queue\n");
evt_rsrc->evq.event_q_id = (uint8_t *)malloc(sizeof(uint8_t) *
evt_rsrc->evq.nb_queues);
if (!evt_rsrc->evq.event_q_id)
for (event_q_id = 0; event_q_id < evt_rsrc->evq.nb_queues;
event_q_id++) {
&event_q_conf);
if (ret < 0)
rte_panic(
"Error in configuring event queue\n");
evt_rsrc->evq.event_q_id[event_q_id] = event_q_id;
}
}
static void
l3fwd_rx_tx_adapter_setup_internal_port(void)
{
struct l3fwd_event_resources *evt_rsrc = l3fwd_get_eventdev_rsrc();
uint8_t event_d_id = evt_rsrc->event_d_id;
uint16_t adapter_id = 0;
uint16_t nb_adapter = 0;
uint16_t port_id;
uint8_t q_id = 0;
int ret;
memset(ð_q_conf, 0, sizeof(eth_q_conf));
if ((evt_rsrc->port_mask & (1 << port_id)) == 0)
continue;
nb_adapter++;
}
evt_rsrc->rx_adptr.nb_rx_adptr = nb_adapter;
evt_rsrc->rx_adptr.rx_adptr = (uint8_t *)malloc(sizeof(uint8_t) *
evt_rsrc->rx_adptr.nb_rx_adptr);
if (!evt_rsrc->rx_adptr.rx_adptr) {
free(evt_rsrc->evp.event_p_id);
free(evt_rsrc->evq.event_q_id);
rte_panic(
"Failed to allocate memory for Rx adapter\n");
}
if ((evt_rsrc->port_mask & (1 << port_id)) == 0)
continue;
&evt_rsrc->def_p_conf);
if (ret)
rte_panic(
"Failed to create rx adapter[%d]\n",
adapter_id);
eth_q_conf.
ev.
queue_id = evt_rsrc->evq.event_q_id[q_id];
-1, ð_q_conf);
if (ret)
rte_panic(
"Failed to add queues to Rx adapter\n");
if (ret)
rte_panic(
"Rx adapter[%d] start Failed\n", adapter_id);
evt_rsrc->rx_adptr.rx_adptr[adapter_id] = adapter_id;
adapter_id++;
if (q_id < evt_rsrc->evq.nb_queues)
q_id++;
}
evt_rsrc->tx_adptr.nb_tx_adptr = nb_adapter;
evt_rsrc->tx_adptr.tx_adptr = (uint8_t *)malloc(sizeof(uint8_t) *
evt_rsrc->tx_adptr.nb_tx_adptr);
if (!evt_rsrc->tx_adptr.tx_adptr) {
free(evt_rsrc->rx_adptr.rx_adptr);
free(evt_rsrc->evp.event_p_id);
free(evt_rsrc->evq.event_q_id);
rte_panic(
"Failed to allocate memory for Rx adapter\n");
}
adapter_id = 0;
if ((evt_rsrc->port_mask & (1 << port_id)) == 0)
continue;
&evt_rsrc->def_p_conf);
if (ret)
rte_panic(
"Failed to create tx adapter[%d]\n",
adapter_id);
-1);
if (ret)
rte_panic(
"Failed to add queues to Tx adapter\n");
if (ret)
rte_panic(
"Tx adapter[%d] start Failed\n", adapter_id);
evt_rsrc->tx_adptr.tx_adptr[adapter_id] = adapter_id;
adapter_id++;
}
}
void
l3fwd_event_set_internal_port_ops(struct l3fwd_event_setup_ops *ops)
{
ops->event_device_setup = l3fwd_event_device_setup_internal_port;
ops->event_queue_setup = l3fwd_event_queue_setup_internal_port;
ops->event_port_setup = l3fwd_event_port_setup_internal_port;
ops->adapter_setup = l3fwd_rx_tx_adapter_setup_internal_port;
}