35 #ifndef _RTE_EVENTDEV_H_ 36 #define _RTE_EVENTDEV_H_ 242 #include <rte_config.h> 249 #define RTE_EVENT_DEV_CAP_QUEUE_QOS (1ULL << 0) 255 #define RTE_EVENT_DEV_CAP_EVENT_QOS (1ULL << 1) 262 #define RTE_EVENT_DEV_CAP_DISTRIBUTED_SCHED (1ULL << 2) 271 #define RTE_EVENT_DEV_CAP_QUEUE_ALL_TYPES (1ULL << 3) 278 #define RTE_EVENT_DEV_CAP_BURST_MODE (1ULL << 4) 286 #define RTE_EVENT_DEV_CAP_IMPLICIT_RELEASE_DISABLE (1ULL << 5) 297 #define RTE_EVENT_DEV_CAP_NONSEQ_MODE (1ULL << 6) 307 #define RTE_EVENT_DEV_CAP_RUNTIME_PORT_LINK (1ULL << 7) 313 #define RTE_EVENT_DEV_CAP_MULTIPLE_QUEUE_PORT (1ULL << 8) 320 #define RTE_EVENT_DEV_PRIORITY_HIGHEST 0 325 #define RTE_EVENT_DEV_PRIORITY_NORMAL 128 330 #define RTE_EVENT_DEV_PRIORITY_LOWEST 255 438 #define RTE_EVENT_DEV_ATTR_PORT_COUNT 0 442 #define RTE_EVENT_DEV_ATTR_QUEUE_COUNT 1 446 #define RTE_EVENT_DEV_ATTR_STARTED 2 462 uint32_t *attr_value);
466 #define RTE_EVENT_DEV_CFG_PER_DEQUEUE_TIMEOUT (1ULL << 0) 551 #define RTE_EVENT_QUEUE_CFG_ALL_TYPES (1ULL << 0) 557 #define RTE_EVENT_QUEUE_CFG_SINGLE_LINK (1ULL << 1) 655 #define RTE_EVENT_QUEUE_ATTR_PRIORITY 0 659 #define RTE_EVENT_QUEUE_ATTR_NB_ATOMIC_FLOWS 1 663 #define RTE_EVENT_QUEUE_ATTR_NB_ATOMIC_ORDER_SEQUENCES 2 667 #define RTE_EVENT_QUEUE_ATTR_EVENT_QUEUE_CFG 3 671 #define RTE_EVENT_QUEUE_ATTR_SCHEDULE_TYPE 4 695 uint32_t *attr_value);
788 #define RTE_EVENT_PORT_ATTR_ENQ_DEPTH 0 792 #define RTE_EVENT_PORT_ATTR_DEQ_DEPTH 1 796 #define RTE_EVENT_PORT_ATTR_NEW_EVENT_THRESHOLD 2 816 uint32_t *attr_value);
862 #define RTE_SCHED_TYPE_ORDERED 0 889 #define RTE_SCHED_TYPE_ATOMIC 1 908 #define RTE_SCHED_TYPE_PARALLEL 2 922 #define RTE_EVENT_TYPE_ETHDEV 0x0 924 #define RTE_EVENT_TYPE_CRYPTODEV 0x1 926 #define RTE_EVENT_TYPE_TIMERDEV 0x2 928 #define RTE_EVENT_TYPE_CPU 0x3 932 #define RTE_EVENT_TYPE_ETH_RX_ADAPTER 0x4 934 #define RTE_EVENT_TYPE_MAX 0x10 938 #define RTE_EVENT_OP_NEW 0 942 #define RTE_EVENT_OP_FORWARD 1 950 #define RTE_EVENT_OP_RELEASE 2 1060 #define RTE_EVENT_ETH_RX_ADAPTER_CAP_INTERNAL_PORT 0x1 1064 #define RTE_EVENT_ETH_RX_ADAPTER_CAP_MULTI_EVENTQ 0x2 1068 #define RTE_EVENT_ETH_RX_ADAPTER_CAP_OVERRIDE_FLOW_ID 0x4 1099 struct rte_eventdev_driver;
1101 struct rte_eventdev;
1103 typedef uint16_t (*event_enqueue_t)(
void *
port,
const struct rte_event *ev);
1106 typedef uint16_t (*event_enqueue_burst_t)(
void *
port,
1107 const struct rte_event ev[], uint16_t nb_events);
1110 typedef uint16_t (*event_dequeue_t)(
void *
port,
struct rte_event *ev,
1111 uint64_t timeout_ticks);
1114 typedef uint16_t (*event_dequeue_burst_t)(
void *
port,
struct rte_event ev[],
1115 uint16_t nb_events, uint64_t timeout_ticks);
1118 #define RTE_EVENTDEV_NAME_MAX_LEN (64) 1128 struct rte_eventdev_data {
1143 uint16_t *links_map;
1147 uint32_t event_dev_cap;
1151 uint8_t service_inited;
1153 uint32_t service_id;
1157 uint8_t dev_started : 1;
1160 char name[RTE_EVENTDEV_NAME_MAX_LEN];
1165 struct rte_eventdev {
1166 event_enqueue_t enqueue;
1168 event_enqueue_burst_t enqueue_burst;
1170 event_enqueue_burst_t enqueue_new_burst;
1172 event_enqueue_burst_t enqueue_forward_burst;
1174 event_dequeue_t dequeue;
1176 event_dequeue_burst_t dequeue_burst;
1179 struct rte_eventdev_data *data;
1187 uint8_t attached : 1;
1195 __rte_event_enqueue_burst(uint8_t dev_id, uint8_t port_id,
1196 const struct rte_event ev[], uint16_t nb_events,
1197 const event_enqueue_burst_t fn)
1201 #ifdef RTE_LIBRTE_EVENTDEV_DEBUG 1202 if (dev_id >= RTE_EVENT_MAX_DEVS || !
rte_eventdevs[dev_id].attached) {
1207 if (port_id >= dev->data->nb_ports) {
1217 return (*dev->enqueue)(dev->data->ports[port_id], ev);
1219 return fn(dev->data->ports[port_id], ev, nb_events);
1264 static inline uint16_t
1266 const struct rte_event ev[], uint16_t nb_events)
1270 return __rte_event_enqueue_burst(dev_id, port_id, ev, nb_events,
1271 dev->enqueue_burst);
1313 static inline uint16_t
1315 const struct rte_event ev[], uint16_t nb_events)
1319 return __rte_event_enqueue_burst(dev_id, port_id, ev, nb_events,
1320 dev->enqueue_new_burst);
1362 static inline uint16_t
1364 const struct rte_event ev[], uint16_t nb_events)
1368 return __rte_event_enqueue_burst(dev_id, port_id, ev, nb_events,
1369 dev->enqueue_forward_burst);
1399 uint64_t *timeout_ticks);
1467 static inline uint16_t
1469 uint16_t nb_events, uint64_t timeout_ticks)
1473 #ifdef RTE_LIBRTE_EVENTDEV_DEBUG 1474 if (dev_id >= RTE_EVENT_MAX_DEVS || !
rte_eventdevs[dev_id].attached) {
1479 if (port_id >= dev->data->nb_ports) {
1490 return (*dev->dequeue)(
1491 dev->data->ports[port_id], ev, timeout_ticks);
1493 return (*dev->dequeue_burst)(
1494 dev->data->ports[port_id], ev, nb_events,
1560 const uint8_t queues[],
const uint8_t priorities[],
1604 uint8_t queues[], uint16_t nb_unlinks);
1635 uint8_t queues[], uint8_t priorities[]);
1672 #define RTE_EVENT_DEV_XSTATS_NAME_SIZE 64 1678 RTE_EVENT_DEV_XSTATS_DEVICE,
1679 RTE_EVENT_DEV_XSTATS_PORT,
1680 RTE_EVENT_DEV_XSTATS_QUEUE,
1728 uint8_t queue_port_id,
1762 uint8_t queue_port_id,
1763 const unsigned int ids[],
1764 uint64_t values[],
unsigned int n);
1809 int16_t queue_port_id,
1810 const uint32_t ids[],
void rte_event_dev_stop(uint8_t dev_id)
uint32_t min_dequeue_timeout_ns
int rte_event_dequeue_timeout_ticks(uint8_t dev_id, uint64_t ns, uint64_t *timeout_ticks)
static uint16_t rte_event_enqueue_new_burst(uint8_t dev_id, uint8_t port_id, const struct rte_event ev[], uint16_t nb_events)
#define __rte_always_inline
#define RTE_EVENT_DEV_XSTATS_NAME_SIZE
int rte_event_eth_rx_adapter_caps_get(uint8_t dev_id, uint8_t eth_port_id, uint32_t *caps)
struct rte_eventdev * rte_eventdevs
int rte_event_dev_attr_get(uint8_t dev_id, uint32_t attr_id, uint32_t *attr_value)
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_port_default_conf_get(uint8_t dev_id, uint8_t port_id, struct rte_event_port_conf *port_conf)
uint32_t dequeue_timeout_ns
int rte_event_dev_socket_id(uint8_t dev_id)
uint32_t max_event_port_enqueue_depth
struct rte_mbuf __rte_cache_aligned
uint64_t rte_event_dev_xstats_by_name_get(uint8_t dev_id, const char *name, unsigned int *id)
int rte_event_dev_info_get(uint8_t dev_id, struct rte_event_dev_info *dev_info)
uint32_t nb_atomic_order_sequences
uint32_t nb_event_port_dequeue_depth
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)
int rte_event_queue_attr_get(uint8_t dev_id, uint8_t queue_id, uint32_t attr_id, uint32_t *attr_value)
uint8_t disable_implicit_release
rte_event_dev_xstats_mode
int rte_event_port_links_get(uint8_t dev_id, uint8_t port_id, uint8_t queues[], uint8_t priorities[])
int rte_event_dev_selftest(uint8_t dev_id)
static uint16_t rte_event_enqueue_burst(uint8_t dev_id, uint8_t port_id, const struct rte_event ev[], uint16_t nb_events)
int rte_event_dev_start(uint8_t dev_id)
int rte_event_port_setup(uint8_t dev_id, uint8_t port_id, const struct rte_event_port_conf *port_conf)
uint8_t max_event_port_dequeue_depth
int rte_event_port_attr_get(uint8_t dev_id, uint8_t port_id, uint32_t attr_id, uint32_t *attr_value)
uint32_t nb_event_port_enqueue_depth
static uint16_t rte_event_dequeue_burst(uint8_t dev_id, uint8_t port_id, struct rte_event ev[], uint16_t nb_events, uint64_t timeout_ticks)
int rte_event_dev_get_dev_id(const char *name)
uint8_t rte_event_dev_count(void)
int rte_event_dev_close(uint8_t dev_id)
int rte_event_dev_xstats_get(uint8_t dev_id, enum rte_event_dev_xstats_mode mode, uint8_t queue_port_id, const unsigned int ids[], uint64_t values[], unsigned int n)
int rte_event_dev_xstats_reset(uint8_t dev_id, enum rte_event_dev_xstats_mode mode, int16_t queue_port_id, const uint32_t ids[], uint32_t nb_ids)
uint32_t dequeue_timeout_ns
int rte_event_dev_service_id_get(uint8_t dev_id, uint32_t *service_id)
static uint16_t rte_event_enqueue_forward_burst(uint8_t dev_id, uint8_t port_id, const struct rte_event ev[], uint16_t nb_events)
int rte_event_dev_dump(uint8_t dev_id, FILE *f)
int32_t new_event_threshold
uint8_t max_event_priority_levels
uint32_t max_dequeue_timeout_ns
uint32_t max_event_queue_flows
int rte_event_dev_configure(uint8_t dev_id, const struct rte_event_dev_config *dev_conf)
uint8_t max_event_queue_priority_levels
int rte_event_port_unlink(uint8_t dev_id, uint8_t port_id, uint8_t queues[], uint16_t nb_unlinks)
int rte_event_dev_xstats_names_get(uint8_t dev_id, enum rte_event_dev_xstats_mode mode, uint8_t queue_port_id, struct rte_event_dev_xstats_name *xstats_names, unsigned int *ids, unsigned int size)
uint32_t nb_event_queue_flows