5 #ifndef _RTE_EVENTDEV_PMD_H_ 6 #define _RTE_EVENTDEV_PMD_H_ 23 #include <rte_compat.h> 24 #include <rte_config.h> 35 #define RTE_EDEV_LOG_ERR(...) \ 36 RTE_LOG(ERR, EVENTDEV, \ 37 RTE_FMT("%s() line %u: " RTE_FMT_HEAD(__VA_ARGS__,) "\n", \ 38 __func__, __LINE__, RTE_FMT_TAIL(__VA_ARGS__,))) 40 #ifdef RTE_LIBRTE_EVENTDEV_DEBUG 41 #define RTE_EDEV_LOG_DEBUG(...) \ 42 RTE_LOG(DEBUG, EVENTDEV, \ 43 RTE_FMT("%s() line %u: " RTE_FMT_HEAD(__VA_ARGS__,) "\n", \ 44 __func__, __LINE__, RTE_FMT_TAIL(__VA_ARGS__,))) 46 #define RTE_EDEV_LOG_DEBUG(...) (void)0 50 #define RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(dev_id, retval) do { \ 51 if (!rte_event_pmd_is_valid_dev((dev_id))) { \ 52 RTE_EDEV_LOG_ERR("Invalid dev_id=%d\n", dev_id); \ 57 #define RTE_EVENTDEV_VALID_DEVID_OR_ERRNO_RET(dev_id, errno, retval) do { \ 58 if (!rte_event_pmd_is_valid_dev((dev_id))) { \ 59 RTE_EDEV_LOG_ERR("Invalid dev_id=%d\n", dev_id); \ 65 #define RTE_EVENTDEV_VALID_DEVID_OR_RET(dev_id) do { \ 66 if (!rte_event_pmd_is_valid_dev((dev_id))) { \ 67 RTE_EDEV_LOG_ERR("Invalid dev_id=%d\n", dev_id); \ 72 #define RTE_EVENT_ETH_RX_ADAPTER_SW_CAP \ 73 ((RTE_EVENT_ETH_RX_ADAPTER_CAP_OVERRIDE_FLOW_ID) | \ 74 (RTE_EVENT_ETH_RX_ADAPTER_CAP_MULTI_EVENTQ)) 76 #define RTE_EVENT_CRYPTO_ADAPTER_SW_CAP \ 77 RTE_EVENT_CRYPTO_ADAPTER_CAP_SESSION_PRIVATE_DATA 83 #define RTE_EVENTDEV_DETACHED (0) 84 #define RTE_EVENTDEV_ATTACHED (1) 93 extern struct rte_eventdev *rte_eventdevs;
105 static inline struct rte_eventdev *
108 struct rte_eventdev *dev;
114 for (i = 0; i < RTE_EVENT_MAX_DEVS; i++) {
115 dev = &rte_eventdevs[i];
116 if ((dev->attached == RTE_EVENTDEV_ATTACHED) &&
117 (strcmp(dev->data->name, name) == 0))
133 static inline unsigned 136 struct rte_eventdev *dev;
138 if (dev_id >= RTE_EVENT_MAX_DEVS)
141 dev = &rte_eventdevs[dev_id];
142 if (dev->attached != RTE_EVENTDEV_ATTACHED)
311 const uint8_t queues[],
const uint8_t priorities[],
331 uint8_t queues[], uint16_t nb_unlinks);
365 uint64_t ns, uint64_t *timeout_ticks);
398 const unsigned int ids[], uint64_t values[],
unsigned int n);
405 int16_t queue_port_id,
406 const uint32_t ids[],
433 unsigned int *ids,
unsigned int size);
451 const char *name,
unsigned int *id);
474 (
const struct rte_eventdev *dev,
475 const struct rte_eth_dev *eth_dev,
506 const struct rte_eventdev *dev,
509 const struct rte_event_timer_adapter_ops **ops);
534 const struct rte_eventdev *dev,
535 const struct rte_eth_dev *eth_dev,
559 (
const struct rte_eventdev *dev,
560 const struct rte_eth_dev *eth_dev,
561 int32_t rx_queue_id);
580 (
const struct rte_eventdev *dev,
581 const struct rte_eth_dev *eth_dev);
600 (
const struct rte_eventdev *dev,
601 const struct rte_eth_dev *eth_dev);
622 (
const struct rte_eventdev *dev,
623 const struct rte_eth_dev *eth_dev,
638 (
const struct rte_eventdev *dev,
639 const struct rte_eth_dev *eth_dev);
648 typedef uint32_t rte_event_pmd_selftest_seqn_t;
649 extern int rte_event_pmd_selftest_seqn_dynfield_offset;
658 static inline rte_event_pmd_selftest_seqn_t *
662 rte_event_pmd_selftest_seqn_dynfield_offset,
663 rte_event_pmd_selftest_seqn_t *);
691 (
const struct rte_eventdev *dev,
722 (
const struct rte_eventdev *dev,
724 int32_t queue_pair_id,
750 (
const struct rte_eventdev *dev,
752 int32_t queue_pair_id);
771 (
const struct rte_eventdev *dev,
791 (
const struct rte_eventdev *dev,
813 (
const struct rte_eventdev *dev,
831 (
const struct rte_eventdev *dev,
852 (
const struct rte_eventdev *dev,
853 const struct rte_eth_dev *eth_dev,
870 const struct rte_eventdev *dev);
886 const struct rte_eventdev *dev);
911 const struct rte_eventdev *dev,
912 const struct rte_eth_dev *eth_dev,
913 int32_t tx_queue_id);
939 const struct rte_eventdev *dev,
940 const struct rte_eth_dev *eth_dev,
941 int32_t tx_queue_id);
957 const struct rte_eventdev *dev);
973 const struct rte_eventdev *dev);
995 const struct rte_eventdev *dev,
1012 const struct rte_eventdev *dev);
1127 struct rte_eventdev *
eventdev_port_release_t port_release
eventdev_eth_rx_adapter_stats_reset eth_rx_adapter_stats_reset
eventdev_port_default_conf_get_t port_def_conf
eventdev_configure_t dev_configure
eventdev_selftest dev_selftest
int(* eventdev_close_t)(struct rte_eventdev *dev)
eventdev_eth_tx_adapter_queue_add_t eth_tx_adapter_queue_add
int(* eventdev_crypto_adapter_start_t)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev)
eventdev_eth_rx_adapter_caps_get_t eth_rx_adapter_caps_get
eventdev_queue_release_t queue_release
eventdev_crypto_adapter_stats_reset crypto_adapter_stats_reset
eventdev_eth_rx_adapter_start_t eth_rx_adapter_start
eventdev_port_link_t port_link
eventdev_info_get_t dev_infos_get
eventdev_port_setup_t port_setup
void(* eventdev_port_default_conf_get_t)(struct rte_eventdev *dev, uint8_t port_id, struct rte_event_port_conf *port_conf)
static unsigned rte_event_pmd_is_valid_dev(uint8_t dev_id)
int(* eventdev_timer_adapter_caps_get_t)(const struct rte_eventdev *dev, uint64_t flags, uint32_t *caps, const struct rte_event_timer_adapter_ops **ops)
int(* eventdev_xstats_reset_t)(struct rte_eventdev *dev, enum rte_event_dev_xstats_mode mode, int16_t queue_port_id, const uint32_t ids[], uint32_t nb_ids)
int(* eventdev_port_setup_t)(struct rte_eventdev *dev, uint8_t port_id, const struct rte_event_port_conf *port_conf)
int(* eventdev_configure_t)(const struct rte_eventdev *dev)
int(* eventdev_crypto_adapter_stop_t)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev)
eventdev_eth_rx_adapter_queue_add_t eth_rx_adapter_queue_add
eventdev_eth_tx_adapter_queue_del_t eth_tx_adapter_queue_del
int(* eventdev_eth_tx_adapter_queue_del_t)(uint8_t id, const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, int32_t tx_queue_id)
void(* eventdev_queue_release_t)(struct rte_eventdev *dev, uint8_t queue_id)
int(* eventdev_crypto_adapter_queue_pair_add_t)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev, int32_t queue_pair_id, const struct rte_event *event)
eventdev_eth_rx_adapter_queue_del_t eth_rx_adapter_queue_del
int(* eventdev_eth_tx_adapter_stats_get_t)(uint8_t id, const struct rte_eventdev *dev, struct rte_event_eth_tx_adapter_stats *stats)
void(* eventdev_port_release_t)(void *port)
static __rte_internal rte_event_pmd_selftest_seqn_t * rte_event_pmd_selftest_seqn(struct rte_mbuf *mbuf)
eventdev_queue_setup_t queue_setup
int(* eventdev_eth_tx_adapter_caps_get_t)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, uint32_t *caps)
void(* eventdev_stop_t)(struct rte_eventdev *dev)
int(* eventdev_crypto_adapter_stats_get)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev, struct rte_event_crypto_adapter_stats *stats)
#define RTE_MBUF_DYNFIELD(m, offset, type)
eventdev_crypto_adapter_queue_pair_add_t crypto_adapter_queue_pair_add
eventdev_xstats_get_by_name xstats_get_by_name
eventdev_queue_default_conf_get_t queue_def_conf
eventdev_eth_rx_adapter_stats_get eth_rx_adapter_stats_get
eventdev_port_unlink_t port_unlink
int(* eventdev_eth_rx_adapter_stats_reset)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev)
int(* eventdev_queue_setup_t)(struct rte_eventdev *dev, uint8_t queue_id, const struct rte_event_queue_conf *queue_conf)
int rte_event_pmd_release(struct rte_eventdev *eventdev)
rte_event_dev_xstats_mode
int(* eventdev_eth_rx_adapter_stop_t)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev)
int(* eventdev_eth_rx_adapter_queue_del_t)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, int32_t rx_queue_id)
int(* eventdev_port_unlink_t)(struct rte_eventdev *dev, void *port, uint8_t queues[], uint16_t nb_unlinks)
int(* eventdev_eth_rx_adapter_start_t)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev)
struct rte_eventdev * rte_event_pmd_allocate(const char *name, int socket_id)
static struct rte_eventdev * rte_event_pmd_get_named_dev(const char *name)
int(* eventdev_port_unlinks_in_progress_t)(struct rte_eventdev *dev, void *port)
int(* eventdev_selftest)(void)
eventdev_crypto_adapter_start_t crypto_adapter_start
eventdev_start_t dev_start
int(* eventdev_start_t)(struct rte_eventdev *dev)
eventdev_dequeue_timeout_ticks_t timeout_ticks
int(* eventdev_crypto_adapter_queue_pair_del_t)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev, int32_t queue_pair_id)
eventdev_eth_tx_adapter_stop_t eth_tx_adapter_stop
eventdev_xstats_reset_t xstats_reset
eventdev_eth_tx_adapter_stats_reset_t eth_tx_adapter_stats_reset
int(* eventdev_eth_rx_adapter_caps_get_t)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, uint32_t *caps)
eventdev_stop_flush_t dev_stop_flush
eventdev_eth_tx_adapter_caps_get_t eth_tx_adapter_caps_get
int(* eventdev_eth_tx_adapter_create_t)(uint8_t id, const struct rte_eventdev *dev)
int(* eventdev_xstats_get_names_t)(const struct rte_eventdev *dev, 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)
eventdev_eth_tx_adapter_stats_get_t eth_tx_adapter_stats_get
eventdev_eth_tx_adapter_free_t eth_tx_adapter_free
int(* eventdev_eth_tx_adapter_stop_t)(uint8_t id, const struct rte_eventdev *dev)
int(* eventdev_eth_rx_adapter_queue_add_t)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, int32_t rx_queue_id, const struct rte_event_eth_rx_adapter_queue_conf *queue_conf)
int(* eventdev_xstats_get_t)(const struct rte_eventdev *dev, enum rte_event_dev_xstats_mode mode, uint8_t queue_port_id, const unsigned int ids[], uint64_t values[], unsigned int n)
eventdev_eth_tx_adapter_create_t eth_tx_adapter_create
void(* eventdev_info_get_t)(struct rte_eventdev *dev, struct rte_event_dev_info *dev_info)
void(* eventdev_queue_default_conf_get_t)(struct rte_eventdev *dev, uint8_t queue_id, struct rte_event_queue_conf *queue_conf)
eventdev_port_unlinks_in_progress_t port_unlinks_in_progress
eventdev_crypto_adapter_queue_pair_del_t crypto_adapter_queue_pair_del
eventdev_xstats_get_names_t xstats_get_names
uint64_t(* eventdev_xstats_get_by_name)(const struct rte_eventdev *dev, const char *name, unsigned int *id)
eventdev_eth_tx_adapter_start_t eth_tx_adapter_start
eventdev_eth_rx_adapter_stop_t eth_rx_adapter_stop
eventdev_crypto_adapter_stop_t crypto_adapter_stop
eventdev_close_t dev_close
int(* eventdev_dequeue_timeout_ticks_t)(struct rte_eventdev *dev, uint64_t ns, uint64_t *timeout_ticks)
eventdev_xstats_get_t xstats_get
int(* eventdev_port_link_t)(struct rte_eventdev *dev, void *port, const uint8_t queues[], const uint8_t priorities[], uint16_t nb_links)
void(* eventdev_dump_t)(struct rte_eventdev *dev, FILE *f)
eventdev_crypto_adapter_stats_get crypto_adapter_stats_get
int(* eventdev_eth_tx_adapter_stats_reset_t)(uint8_t id, const struct rte_eventdev *dev)
int(* eventdev_eth_tx_adapter_queue_add_t)(uint8_t id, const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, int32_t tx_queue_id)
eventdev_crypto_adapter_caps_get_t crypto_adapter_caps_get
void(* eventdev_stop_flush_t)(uint8_t dev_id, struct rte_event event, void *arg)
eventdev_timer_adapter_caps_get_t timer_adapter_caps_get
int(* eventdev_eth_tx_adapter_free_t)(uint8_t id, const struct rte_eventdev *dev)
int(* eventdev_eth_tx_adapter_start_t)(uint8_t id, const struct rte_eventdev *dev)
int(* eventdev_eth_rx_adapter_stats_get)(const struct rte_eventdev *dev, const struct rte_eth_dev *eth_dev, struct rte_event_eth_rx_adapter_stats *stats)
int(* eventdev_crypto_adapter_caps_get_t)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev, uint32_t *caps)
int(* eventdev_crypto_adapter_stats_reset)(const struct rte_eventdev *dev, const struct rte_cryptodev *cdev)