#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");
def_p_conf.new_event_threshold;
if (evt_rsrc->disable_implicit_release)
evt_rsrc->deq_depth = def_p_conf.dequeue_depth;
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");
if (def_q_conf.nb_atomic_order_sequences <
def_q_conf.nb_atomic_order_sequences;
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;
if (evt_rsrc->vector_enabled) {
uint32_t cap;
port_id, &cap))
"Failed to get event rx adapter capability");
eth_q_conf.vector_sz = evt_rsrc->vector_size;
eth_q_conf.vector_timeout_ns =
evt_rsrc->vector_tmo_ns;
eth_q_conf.vector_mp =
evt_rsrc->per_port_pool ?
evt_rsrc->vec_pool[port_id] :
evt_rsrc->vec_pool[0];
eth_q_conf.rx_queue_flags |=
} else {
"Rx adapter doesn't support event vector");
}
}
&evt_rsrc->def_p_conf);
if (ret)
rte_panic(
"Failed to create rx adapter[%d]\n",
adapter_id);
eth_q_conf.ev.sched_type = evt_rsrc->sched_type;
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;
}
#define RTE_ETH_FOREACH_DEV(p)
int rte_event_eth_rx_adapter_start(uint8_t id)
int rte_event_eth_rx_adapter_create(uint8_t id, uint8_t dev_id, struct rte_event_port_conf *port_config)
int rte_event_eth_rx_adapter_queue_add(uint8_t id, uint16_t eth_dev_id, int32_t rx_queue_id, const struct rte_event_eth_rx_adapter_queue_conf *conf)
#define RTE_EVENT_ETH_RX_ADAPTER_QUEUE_EVENT_VECTOR
int rte_event_eth_tx_adapter_create(uint8_t id, uint8_t dev_id, struct rte_event_port_conf *port_config)
int rte_event_eth_tx_adapter_queue_add(uint8_t id, uint16_t eth_dev_id, int32_t queue)
int rte_event_eth_tx_adapter_start(uint8_t id)
#define RTE_EVENT_DEV_PRIORITY_NORMAL
int rte_event_port_link(uint8_t dev_id, uint8_t port_id, const uint8_t queues[], const uint8_t priorities[], uint16_t nb_links)
#define RTE_EVENT_DEV_CAP_IMPLICIT_RELEASE_DISABLE
int rte_event_eth_rx_adapter_caps_get(uint8_t dev_id, uint16_t eth_port_id, uint32_t *caps)
int rte_event_queue_setup(uint8_t dev_id, uint8_t queue_id, const struct rte_event_queue_conf *queue_conf)
int rte_event_queue_default_conf_get(uint8_t dev_id, uint8_t queue_id, struct rte_event_queue_conf *queue_conf)
int rte_event_dev_info_get(uint8_t dev_id, struct rte_event_dev_info *dev_info)
#define RTE_EVENT_QUEUE_CFG_ALL_TYPES
#define RTE_EVENT_DEV_CAP_QUEUE_ALL_TYPES
#define RTE_EVENT_ETH_RX_ADAPTER_CAP_EVENT_VECTOR
int rte_event_port_default_conf_get(uint8_t dev_id, uint8_t port_id, struct rte_event_port_conf *port_conf)
int rte_event_port_setup(uint8_t dev_id, uint8_t port_id, const struct rte_event_port_conf *port_conf)
#define RTE_EVENT_DEV_CAP_BURST_MODE
int rte_event_dev_configure(uint8_t dev_id, const struct rte_event_dev_config *dev_conf)
#define RTE_EVENT_PORT_CFG_DISABLE_IMPL_REL
unsigned int rte_lcore_count(void)
static void rte_spinlock_init(rte_spinlock_t *sl)
uint32_t nb_event_port_enqueue_depth
uint32_t nb_event_queue_flows
uint32_t nb_event_port_dequeue_depth
uint32_t max_event_port_enqueue_depth
uint32_t max_event_queue_flows
uint8_t max_event_port_dequeue_depth
int32_t new_event_threshold
uint32_t nb_atomic_order_sequences