DPDK 25.07.0-rc1
rte_eventdev.h
Go to the documentation of this file.
1/* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2016 Cavium, Inc.
3 * Copyright(c) 2016-2018 Intel Corporation.
4 * Copyright 2016 NXP
5 * All rights reserved.
6 */
7
8#ifndef _RTE_EVENTDEV_H_
9#define _RTE_EVENTDEV_H_
10
240#include <rte_compat.h>
241#include <rte_common.h>
242#include <rte_errno.h>
243#include <rte_mbuf_pool_ops.h>
244#include <rte_mempool.h>
245
247
248struct rte_mbuf; /* we just use mbuf pointers; no need to include rte_mbuf.h */
249struct rte_event;
250
251/* Event device capability bitmap flags */
252#define RTE_EVENT_DEV_CAP_QUEUE_QOS (1ULL << 0)
270#define RTE_EVENT_DEV_CAP_EVENT_QOS (1ULL << 1)
284#define RTE_EVENT_DEV_CAP_DISTRIBUTED_SCHED (1ULL << 2)
294#define RTE_EVENT_DEV_CAP_QUEUE_ALL_TYPES (1ULL << 3)
318#define RTE_EVENT_DEV_CAP_BURST_MODE (1ULL << 4)
329#define RTE_EVENT_DEV_CAP_IMPLICIT_RELEASE_DISABLE (1ULL << 5)
342#define RTE_EVENT_DEV_CAP_NONSEQ_MODE (1ULL << 6)
354#define RTE_EVENT_DEV_CAP_RUNTIME_PORT_LINK (1ULL << 7)
365#define RTE_EVENT_DEV_CAP_MULTIPLE_QUEUE_PORT (1ULL << 8)
375#define RTE_EVENT_DEV_CAP_CARRY_FLOW_ID (1ULL << 9)
384#define RTE_EVENT_DEV_CAP_MAINTENANCE_FREE (1ULL << 10)
397#define RTE_EVENT_DEV_CAP_RUNTIME_QUEUE_ATTR (1ULL << 11)
407#define RTE_EVENT_DEV_CAP_PROFILE_LINK (1ULL << 12)
421#define RTE_EVENT_DEV_CAP_ATOMIC (1ULL << 13)
429#define RTE_EVENT_DEV_CAP_ORDERED (1ULL << 14)
437#define RTE_EVENT_DEV_CAP_PARALLEL (1ULL << 15)
445#define RTE_EVENT_DEV_CAP_INDEPENDENT_ENQ (1ULL << 16)
464#define RTE_EVENT_DEV_CAP_EVENT_PRESCHEDULE (1ULL << 17)
476#define RTE_EVENT_DEV_CAP_EVENT_PRESCHEDULE_ADAPTIVE (1ULL << 18)
488#define RTE_EVENT_DEV_CAP_PER_PORT_PRESCHEDULE (1ULL << 19)
498#define RTE_EVENT_DEV_CAP_PRESCHEDULE_EXPLICIT (1ULL << 20)
507/* Event device priority levels */
508#define RTE_EVENT_DEV_PRIORITY_HIGHEST 0
515#define RTE_EVENT_DEV_PRIORITY_NORMAL 128
522#define RTE_EVENT_DEV_PRIORITY_LOWEST 255
530/* Event queue scheduling weights */
531#define RTE_EVENT_QUEUE_WEIGHT_HIGHEST 255
537#define RTE_EVENT_QUEUE_WEIGHT_LOWEST 0
544/* Event queue scheduling affinity */
545#define RTE_EVENT_QUEUE_AFFINITY_HIGHEST 255
551#define RTE_EVENT_QUEUE_AFFINITY_LOWEST 0
564uint8_t
566
579int
580rte_event_dev_get_dev_id(const char *name);
581
593int
595
600 const char *driver_name;
601 struct rte_device *dev;
684};
685
702int
703rte_event_dev_info_get(uint8_t dev_id, struct rte_event_dev_info *dev_info);
704
708#define RTE_EVENT_DEV_ATTR_PORT_COUNT 0
712#define RTE_EVENT_DEV_ATTR_QUEUE_COUNT 1
716#define RTE_EVENT_DEV_ATTR_STARTED 2
717
730int
731rte_event_dev_attr_get(uint8_t dev_id, uint32_t attr_id,
732 uint32_t *attr_value);
733
734
735/* Event device configuration bitmap flags */
736#define RTE_EVENT_DEV_CFG_PER_DEQUEUE_TIMEOUT (1ULL << 0)
764};
765
843};
844
869int
871 const struct rte_event_dev_config *dev_conf);
872
873/* Event queue specific APIs */
874
875/* Event queue configuration bitmap flags */
876#define RTE_EVENT_QUEUE_CFG_ALL_TYPES (1ULL << 0)
890#define RTE_EVENT_QUEUE_CFG_SINGLE_LINK (1ULL << 1)
954 uint8_t priority;
965 uint8_t weight;
976 uint8_t affinity;
987};
988
1010int
1011rte_event_queue_default_conf_get(uint8_t dev_id, uint8_t queue_id,
1012 struct rte_event_queue_conf *queue_conf);
1013
1033int
1034rte_event_queue_setup(uint8_t dev_id, uint8_t queue_id,
1035 const struct rte_event_queue_conf *queue_conf);
1036
1040#define RTE_EVENT_QUEUE_ATTR_PRIORITY 0
1044#define RTE_EVENT_QUEUE_ATTR_NB_ATOMIC_FLOWS 1
1048#define RTE_EVENT_QUEUE_ATTR_NB_ATOMIC_ORDER_SEQUENCES 2
1052#define RTE_EVENT_QUEUE_ATTR_EVENT_QUEUE_CFG 3
1056#define RTE_EVENT_QUEUE_ATTR_SCHEDULE_TYPE 4
1060#define RTE_EVENT_QUEUE_ATTR_WEIGHT 5
1064#define RTE_EVENT_QUEUE_ATTR_AFFINITY 6
1065
1086int
1087rte_event_queue_attr_get(uint8_t dev_id, uint8_t queue_id, uint32_t attr_id,
1088 uint32_t *attr_value);
1089
1109int
1110rte_event_queue_attr_set(uint8_t dev_id, uint8_t queue_id, uint32_t attr_id,
1111 uint64_t attr_value);
1112
1113/* Event port specific APIs */
1114
1115/* Event port configuration bitmap flags */
1116#define RTE_EVENT_PORT_CFG_DISABLE_IMPL_REL (1ULL << 0)
1123#define RTE_EVENT_PORT_CFG_SINGLE_LINK (1ULL << 1)
1131#define RTE_EVENT_PORT_CFG_HINT_PRODUCER (1ULL << 2)
1141#define RTE_EVENT_PORT_CFG_HINT_CONSUMER (1ULL << 3)
1152#define RTE_EVENT_PORT_CFG_HINT_WORKER (1ULL << 4)
1163#define RTE_EVENT_PORT_CFG_INDEPENDENT_ENQ (1ULL << 5)
1209};
1210
1234int
1235rte_event_port_default_conf_get(uint8_t dev_id, uint8_t port_id,
1236 struct rte_event_port_conf *port_conf);
1237
1264int
1265rte_event_port_setup(uint8_t dev_id, uint8_t port_id,
1266 const struct rte_event_port_conf *port_conf);
1267
1268typedef void (*rte_eventdev_port_flush_t)(uint8_t dev_id,
1269 struct rte_event event, void *arg);
1299void
1300rte_event_port_quiesce(uint8_t dev_id, uint8_t port_id,
1301 rte_eventdev_port_flush_t release_cb, void *args);
1302
1306#define RTE_EVENT_PORT_ATTR_ENQ_DEPTH 0
1310#define RTE_EVENT_PORT_ATTR_DEQ_DEPTH 1
1316#define RTE_EVENT_PORT_ATTR_NEW_EVENT_THRESHOLD 2
1320#define RTE_EVENT_PORT_ATTR_IMPLICIT_RELEASE_DISABLE 3
1324#define RTE_EVENT_PORT_ATTR_INDEPENDENT_ENQ 4
1325
1343int
1344rte_event_port_attr_get(uint8_t dev_id, uint8_t port_id, uint32_t attr_id,
1345 uint32_t *attr_value);
1346
1365int
1366rte_event_dev_start(uint8_t dev_id);
1367
1386void
1387rte_event_dev_stop(uint8_t dev_id);
1388
1389typedef void (*rte_eventdev_stop_flush_t)(uint8_t dev_id,
1390 struct rte_event event, void *arg);
1424 rte_eventdev_stop_flush_t callback, void *userdata);
1425
1439int
1440rte_event_dev_close(uint8_t dev_id);
1441
1445struct __rte_aligned(16) rte_event_vector {
1446 uint16_t nb_elem;
1448 uint16_t elem_offset : 12;
1450 uint16_t rsvd : 3;
1452 uint16_t attr_valid : 1;
1455 union {
1456 /* Used by Rx/Tx adapter.
1457 * Indicates that all the elements in this vector belong to the
1458 * same port and queue pair when originating from Rx adapter,
1459 * valid only when event type is ETHDEV_VECTOR or
1460 * ETH_RX_ADAPTER_VECTOR.
1461 * Can also be used to indicate the Tx adapter the destination
1462 * port and queue of the mbufs in the vector
1463 */
1464 struct {
1465 uint16_t port;
1466 uint16_t queue;
1467 };
1468 };
1470 uint64_t impl_opaque;
1471
1472/* empty structures do not have zero size in C++ leading to compilation errors
1473 * with clang about structure having different sizes in C and C++.
1474 * Since these are all zero-sized arrays, we can omit the "union" wrapper for
1475 * C++ builds, removing the warning.
1476 */
1477#ifndef __cplusplus
1483 union __rte_aligned(16) {
1484#endif
1485 struct rte_mbuf *mbufs[0];
1486 void *ptrs[0];
1487 uint64_t u64s[0];
1488#ifndef __cplusplus
1489 };
1490#endif
1495};
1496
1497/* Scheduler type definitions */
1498#define RTE_SCHED_TYPE_ORDERED 0
1536#define RTE_SCHED_TYPE_ATOMIC 1
1563#define RTE_SCHED_TYPE_PARALLEL 2
1576/* Event types to classify the event source */
1577#define RTE_EVENT_TYPE_ETHDEV 0x0
1579#define RTE_EVENT_TYPE_CRYPTODEV 0x1
1581#define RTE_EVENT_TYPE_TIMER 0x2
1583#define RTE_EVENT_TYPE_CPU 0x3
1587#define RTE_EVENT_TYPE_ETH_RX_ADAPTER 0x4
1589#define RTE_EVENT_TYPE_DMADEV 0x5
1591#define RTE_EVENT_TYPE_VECTOR 0x8
1603#define RTE_EVENT_TYPE_ETHDEV_VECTOR \
1604 (RTE_EVENT_TYPE_VECTOR | RTE_EVENT_TYPE_ETHDEV)
1606#define RTE_EVENT_TYPE_CPU_VECTOR (RTE_EVENT_TYPE_VECTOR | RTE_EVENT_TYPE_CPU)
1608#define RTE_EVENT_TYPE_ETH_RX_ADAPTER_VECTOR \
1609 (RTE_EVENT_TYPE_VECTOR | RTE_EVENT_TYPE_ETH_RX_ADAPTER)
1611#define RTE_EVENT_TYPE_CRYPTODEV_VECTOR \
1612 (RTE_EVENT_TYPE_VECTOR | RTE_EVENT_TYPE_CRYPTODEV)
1615#define RTE_EVENT_TYPE_MAX 0x10
1618/* Event enqueue operations */
1619#define RTE_EVENT_OP_NEW 0
1624#define RTE_EVENT_OP_FORWARD 1
1636#define RTE_EVENT_OP_RELEASE 2
1676 /* WORD0 */
1677 union {
1678 uint64_t event;
1680 struct {
1681 uint32_t flow_id:20;
1693 uint32_t sub_event_type:8;
1700 uint32_t event_type:4;
1705 uint8_t op:2;
1715 uint8_t rsvd:4;
1723 uint8_t sched_type:2;
1740 uint8_t queue_id;
1748 uint8_t priority;
1786 };
1787 };
1788 /* WORD1 */
1789 union {
1790 uint64_t u64;
1796 struct rte_event_vector *vec;
1798 };
1799};
1800
1801/* Ethdev Rx adapter capability bitmap flags */
1802#define RTE_EVENT_ETH_RX_ADAPTER_CAP_INTERNAL_PORT 0x1
1806#define RTE_EVENT_ETH_RX_ADAPTER_CAP_MULTI_EVENTQ 0x2
1810#define RTE_EVENT_ETH_RX_ADAPTER_CAP_OVERRIDE_FLOW_ID 0x4
1817#define RTE_EVENT_ETH_RX_ADAPTER_CAP_EVENT_VECTOR 0x8
1838int
1839rte_event_eth_rx_adapter_caps_get(uint8_t dev_id, uint16_t eth_port_id,
1840 uint32_t *caps);
1841
1842#define RTE_EVENT_TIMER_ADAPTER_CAP_INTERNAL_PORT (1ULL << 0)
1845#define RTE_EVENT_TIMER_ADAPTER_CAP_PERIODIC (1ULL << 1)
1861int
1862rte_event_timer_adapter_caps_get(uint8_t dev_id, uint32_t *caps);
1863
1864/* Crypto adapter capability bitmap flag */
1865#define RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_NEW 0x1
1872#define RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_FWD 0x2
1879#define RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_QP_EV_BIND 0x4
1884#define RTE_EVENT_CRYPTO_ADAPTER_CAP_SESSION_PRIVATE_DATA 0x8
1889#define RTE_EVENT_CRYPTO_ADAPTER_CAP_EVENT_VECTOR 0x10
1913int
1914rte_event_crypto_adapter_caps_get(uint8_t dev_id, uint8_t cdev_id,
1915 uint32_t *caps);
1916
1917/* DMA adapter capability bitmap flag */
1918#define RTE_EVENT_DMA_ADAPTER_CAP_INTERNAL_PORT_OP_NEW 0x1
1925#define RTE_EVENT_DMA_ADAPTER_CAP_INTERNAL_PORT_OP_FWD 0x2
1932#define RTE_EVENT_DMA_ADAPTER_CAP_INTERNAL_PORT_VCHAN_EV_BIND 0x4
1955__rte_experimental
1956int
1957rte_event_dma_adapter_caps_get(uint8_t dev_id, uint8_t dmadev_id, uint32_t *caps);
1958
1959/* Ethdev Tx adapter capability bitmap flags */
1960#define RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT 0x1
1963#define RTE_EVENT_ETH_TX_ADAPTER_CAP_EVENT_VECTOR 0x2
1984int
1985rte_event_eth_tx_adapter_caps_get(uint8_t dev_id, uint16_t eth_port_id,
1986 uint32_t *caps);
1987
1988/* Vector adapter capability bitmap flags */
1989#define RTE_EVENT_VECTOR_ADAPTER_CAP_INTERNAL_PORT 0x1
1994__rte_experimental
1995int
1996rte_event_vector_adapter_caps_get(uint8_t dev_id, uint32_t *caps);
1997
2022int
2023rte_event_dequeue_timeout_ticks(uint8_t dev_id, uint64_t ns,
2024 uint64_t *timeout_ticks);
2025
2089int
2090rte_event_port_link(uint8_t dev_id, uint8_t port_id,
2091 const uint8_t queues[], const uint8_t priorities[],
2092 uint16_t nb_links);
2093
2137int
2138rte_event_port_unlink(uint8_t dev_id, uint8_t port_id,
2139 uint8_t queues[], uint16_t nb_unlinks);
2140
2213__rte_experimental
2214int
2215rte_event_port_profile_links_set(uint8_t dev_id, uint8_t port_id, const uint8_t queues[],
2216 const uint8_t priorities[], uint16_t nb_links, uint8_t profile_id);
2217
2266__rte_experimental
2267int
2268rte_event_port_profile_unlink(uint8_t dev_id, uint8_t port_id, uint8_t queues[],
2269 uint16_t nb_unlinks, uint8_t profile_id);
2270
2292int
2293rte_event_port_unlinks_in_progress(uint8_t dev_id, uint8_t port_id);
2294
2321int
2322rte_event_port_links_get(uint8_t dev_id, uint8_t port_id,
2323 uint8_t queues[], uint8_t priorities[]);
2324
2356__rte_experimental
2357int
2358rte_event_port_profile_links_get(uint8_t dev_id, uint8_t port_id, uint8_t queues[],
2359 uint8_t priorities[], uint8_t profile_id);
2360
2376int
2377rte_event_dev_service_id_get(uint8_t dev_id, uint32_t *service_id);
2378
2392int
2393rte_event_dev_dump(uint8_t dev_id, FILE *f);
2394
2396#define RTE_EVENT_DEV_XSTATS_NAME_SIZE 64
2397
2402 RTE_EVENT_DEV_XSTATS_DEVICE,
2403 RTE_EVENT_DEV_XSTATS_PORT,
2404 RTE_EVENT_DEV_XSTATS_QUEUE,
2405};
2406
2415};
2416
2449int
2451 enum rte_event_dev_xstats_mode mode,
2452 uint8_t queue_port_id,
2453 struct rte_event_dev_xstats_name *xstats_names,
2454 uint64_t *ids,
2455 unsigned int size);
2456
2483int
2485 enum rte_event_dev_xstats_mode mode,
2486 uint8_t queue_port_id,
2487 const uint64_t ids[],
2488 uint64_t values[], unsigned int n);
2489
2506uint64_t
2507rte_event_dev_xstats_by_name_get(uint8_t dev_id, const char *name,
2508 uint64_t *id);
2509
2530int
2532 enum rte_event_dev_xstats_mode mode,
2533 int16_t queue_port_id,
2534 const uint64_t ids[],
2535 uint32_t nb_ids);
2536
2547int rte_event_dev_selftest(uint8_t dev_id);
2548
2579struct rte_mempool *
2580rte_event_vector_pool_create(const char *name, unsigned int n,
2581 unsigned int cache_size, uint16_t nb_elem,
2582 int socket_id);
2583
2584#include <rte_eventdev_core.h>
2585
2586#ifdef __cplusplus
2587extern "C" {
2588#endif
2589
2590static __rte_always_inline uint16_t
2591__rte_event_enqueue_burst(uint8_t dev_id, uint8_t port_id,
2592 const struct rte_event ev[], uint16_t nb_events,
2593 const event_enqueue_burst_t fn)
2594{
2595 const struct rte_event_fp_ops *fp_ops;
2596 void *port;
2597
2598 fp_ops = &rte_event_fp_ops[dev_id];
2599 port = fp_ops->data[port_id];
2600#ifdef RTE_LIBRTE_EVENTDEV_DEBUG
2601 if (dev_id >= RTE_EVENT_MAX_DEVS ||
2602 port_id >= RTE_EVENT_MAX_PORTS_PER_DEV) {
2603 rte_errno = EINVAL;
2604 return 0;
2605 }
2606
2607 if (port == NULL) {
2608 rte_errno = EINVAL;
2609 return 0;
2610 }
2611#endif
2612 rte_eventdev_trace_enq_burst(dev_id, port_id, ev, nb_events, (void *)fn);
2613
2614 return fn(port, ev, nb_events);
2615}
2616
2660static inline uint16_t
2661rte_event_enqueue_burst(uint8_t dev_id, uint8_t port_id,
2662 const struct rte_event ev[], uint16_t nb_events)
2663{
2664 const struct rte_event_fp_ops *fp_ops;
2665
2666 fp_ops = &rte_event_fp_ops[dev_id];
2667 return __rte_event_enqueue_burst(dev_id, port_id, ev, nb_events,
2668 fp_ops->enqueue_burst);
2669}
2670
2712static inline uint16_t
2713rte_event_enqueue_new_burst(uint8_t dev_id, uint8_t port_id,
2714 const struct rte_event ev[], uint16_t nb_events)
2715{
2716 const struct rte_event_fp_ops *fp_ops;
2717
2718 fp_ops = &rte_event_fp_ops[dev_id];
2719 return __rte_event_enqueue_burst(dev_id, port_id, ev, nb_events,
2720 fp_ops->enqueue_new_burst);
2721}
2722
2764static inline uint16_t
2765rte_event_enqueue_forward_burst(uint8_t dev_id, uint8_t port_id,
2766 const struct rte_event ev[], uint16_t nb_events)
2767{
2768 const struct rte_event_fp_ops *fp_ops;
2769
2770 fp_ops = &rte_event_fp_ops[dev_id];
2771 return __rte_event_enqueue_burst(dev_id, port_id, ev, nb_events,
2772 fp_ops->enqueue_forward_burst);
2773}
2774
2841static inline uint16_t
2842rte_event_dequeue_burst(uint8_t dev_id, uint8_t port_id, struct rte_event ev[],
2843 uint16_t nb_events, uint64_t timeout_ticks)
2844{
2845 const struct rte_event_fp_ops *fp_ops;
2846 void *port;
2847
2848 fp_ops = &rte_event_fp_ops[dev_id];
2849 port = fp_ops->data[port_id];
2850#ifdef RTE_LIBRTE_EVENTDEV_DEBUG
2851 if (dev_id >= RTE_EVENT_MAX_DEVS ||
2852 port_id >= RTE_EVENT_MAX_PORTS_PER_DEV) {
2853 rte_errno = EINVAL;
2854 return 0;
2855 }
2856
2857 if (port == NULL) {
2858 rte_errno = EINVAL;
2859 return 0;
2860 }
2861#endif
2862 rte_eventdev_trace_deq_burst(dev_id, port_id, ev, nb_events);
2863
2864 return (fp_ops->dequeue_burst)(port, ev, nb_events, timeout_ticks);
2865}
2866
2867#define RTE_EVENT_DEV_MAINT_OP_FLUSH (1 << 0)
2909static inline int
2910rte_event_maintain(uint8_t dev_id, uint8_t port_id, int op)
2911{
2912 const struct rte_event_fp_ops *fp_ops;
2913 void *port;
2914
2915 fp_ops = &rte_event_fp_ops[dev_id];
2916 port = fp_ops->data[port_id];
2917#ifdef RTE_LIBRTE_EVENTDEV_DEBUG
2918 if (dev_id >= RTE_EVENT_MAX_DEVS ||
2919 port_id >= RTE_EVENT_MAX_PORTS_PER_DEV)
2920 return -EINVAL;
2921
2922 if (port == NULL)
2923 return -EINVAL;
2924
2925 if (op & (~RTE_EVENT_DEV_MAINT_OP_FLUSH))
2926 return -EINVAL;
2927#endif
2928 rte_eventdev_trace_maintain(dev_id, port_id, op);
2929
2930 if (fp_ops->maintain != NULL)
2931 fp_ops->maintain(port, op);
2932
2933 return 0;
2934}
2935
2957static inline uint8_t
2958rte_event_port_profile_switch(uint8_t dev_id, uint8_t port_id, uint8_t profile_id)
2959{
2960 const struct rte_event_fp_ops *fp_ops;
2961 void *port;
2962
2963 fp_ops = &rte_event_fp_ops[dev_id];
2964 port = fp_ops->data[port_id];
2965
2966#ifdef RTE_LIBRTE_EVENTDEV_DEBUG
2967 if (dev_id >= RTE_EVENT_MAX_DEVS ||
2968 port_id >= RTE_EVENT_MAX_PORTS_PER_DEV)
2969 return -EINVAL;
2970
2971 if (port == NULL)
2972 return -EINVAL;
2973
2974 if (profile_id >= RTE_EVENT_MAX_PROFILES_PER_PORT)
2975 return -EINVAL;
2976#endif
2977 rte_eventdev_trace_port_profile_switch(dev_id, port_id, profile_id);
2978
2979 return fp_ops->profile_switch(port, profile_id);
2980}
2981
3005__rte_experimental
3006static inline int
3007rte_event_port_preschedule_modify(uint8_t dev_id, uint8_t port_id,
3009{
3010 const struct rte_event_fp_ops *fp_ops;
3011 void *port;
3012
3013 fp_ops = &rte_event_fp_ops[dev_id];
3014 port = fp_ops->data[port_id];
3015
3016#ifdef RTE_LIBRTE_EVENTDEV_DEBUG
3017 if (dev_id >= RTE_EVENT_MAX_DEVS || port_id >= RTE_EVENT_MAX_PORTS_PER_DEV)
3018 return -EINVAL;
3019
3020 if (port == NULL)
3021 return -EINVAL;
3022#endif
3023 rte_eventdev_trace_port_preschedule_modify(dev_id, port_id, type);
3024
3025 return fp_ops->preschedule_modify(port, type);
3026}
3027
3049__rte_experimental
3050static inline void
3051rte_event_port_preschedule(uint8_t dev_id, uint8_t port_id,
3053{
3054 const struct rte_event_fp_ops *fp_ops;
3055 void *port;
3056
3057 fp_ops = &rte_event_fp_ops[dev_id];
3058 port = fp_ops->data[port_id];
3059
3060#ifdef RTE_LIBRTE_EVENTDEV_DEBUG
3061 if (dev_id >= RTE_EVENT_MAX_DEVS || port_id >= RTE_EVENT_MAX_PORTS_PER_DEV)
3062 return;
3063 if (port == NULL)
3064 return;
3065#endif
3066 rte_eventdev_trace_port_preschedule(dev_id, port_id, type);
3067
3068 fp_ops->preschedule(port, type);
3069}
3070#ifdef __cplusplus
3071}
3072#endif
3073
3074#endif /* _RTE_EVENTDEV_H_ */
#define __rte_always_inline
Definition: rte_common.h:490
#define rte_errno
Definition: rte_errno.h:29
struct __rte_aligned(16) rte_event_vector
int rte_event_port_links_get(uint8_t dev_id, uint8_t port_id, uint8_t queues[], uint8_t priorities[])
int rte_event_port_unlinks_in_progress(uint8_t dev_id, uint8_t port_id)
int rte_event_queue_attr_set(uint8_t dev_id, uint8_t queue_id, uint32_t attr_id, uint64_t attr_value)
static __rte_experimental int rte_event_port_preschedule_modify(uint8_t dev_id, uint8_t port_id, enum rte_event_dev_preschedule_type type)
void(* rte_eventdev_port_flush_t)(uint8_t dev_id, struct rte_event event, void *arg)
int rte_event_dequeue_timeout_ticks(uint8_t dev_id, uint64_t ns, uint64_t *timeout_ticks)
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)
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)
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_service_id_get(uint8_t dev_id, uint32_t *service_id)
static uint8_t rte_event_port_profile_switch(uint8_t dev_id, uint8_t port_id, uint8_t profile_id)
rte_event_dev_xstats_mode
__rte_experimental int rte_event_port_profile_links_set(uint8_t dev_id, uint8_t port_id, const uint8_t queues[], const uint8_t priorities[], uint16_t nb_links, uint8_t profile_id)
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_selftest(uint8_t dev_id)
int rte_event_dev_info_get(uint8_t dev_id, struct rte_event_dev_info *dev_info)
int rte_event_dev_stop_flush_callback_register(uint8_t dev_id, rte_eventdev_stop_flush_t callback, void *userdata)
void rte_event_dev_stop(uint8_t dev_id)
uint8_t rte_event_dev_count(void)
rte_event_dev_preschedule_type
Definition: rte_eventdev.h:742
@ RTE_EVENT_PRESCHEDULE
Definition: rte_eventdev.h:748
@ RTE_EVENT_PRESCHEDULE_ADAPTIVE
Definition: rte_eventdev.h:755
@ RTE_EVENT_PRESCHEDULE_NONE
Definition: rte_eventdev.h:743
struct rte_mempool * rte_event_vector_pool_create(const char *name, unsigned int n, unsigned int cache_size, uint16_t nb_elem, int socket_id)
int rte_event_crypto_adapter_caps_get(uint8_t dev_id, uint8_t cdev_id, uint32_t *caps)
void rte_event_port_quiesce(uint8_t dev_id, uint8_t port_id, rte_eventdev_port_flush_t release_cb, void *args)
int rte_event_dev_xstats_reset(uint8_t dev_id, enum rte_event_dev_xstats_mode mode, int16_t queue_port_id, const uint64_t ids[], uint32_t nb_ids)
int rte_event_dev_dump(uint8_t dev_id, FILE *f)
int rte_event_timer_adapter_caps_get(uint8_t dev_id, uint32_t *caps)
int rte_event_dev_attr_get(uint8_t dev_id, uint32_t attr_id, uint32_t *attr_value)
int rte_event_dev_get_dev_id(const char *name)
uint64_t rte_event_dev_xstats_by_name_get(uint8_t dev_id, const char *name, uint64_t *id)
int rte_event_dev_xstats_get(uint8_t dev_id, enum rte_event_dev_xstats_mode mode, uint8_t queue_port_id, const uint64_t ids[], uint64_t values[], unsigned int n)
#define RTE_EVENT_DEV_MAINT_OP_FLUSH
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)
void(* rte_eventdev_stop_flush_t)(uint8_t dev_id, struct rte_event event, void *arg)
int rte_event_queue_attr_get(uint8_t dev_id, uint8_t queue_id, uint32_t attr_id, uint32_t *attr_value)
__rte_experimental int rte_event_port_profile_links_get(uint8_t dev_id, uint8_t port_id, uint8_t queues[], uint8_t priorities[], uint8_t profile_id)
static int rte_event_maintain(uint8_t dev_id, uint8_t port_id, int op)
int rte_event_port_attr_get(uint8_t dev_id, uint8_t port_id, uint32_t attr_id, uint32_t *attr_value)
int rte_event_dev_start(uint8_t dev_id)
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_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, uint64_t *ids, unsigned int size)
int rte_event_port_setup(uint8_t dev_id, uint8_t port_id, const struct rte_event_port_conf *port_conf)
__rte_experimental int rte_event_dma_adapter_caps_get(uint8_t dev_id, uint8_t dmadev_id, uint32_t *caps)
int rte_event_eth_tx_adapter_caps_get(uint8_t dev_id, uint16_t eth_port_id, uint32_t *caps)
int rte_event_port_unlink(uint8_t dev_id, uint8_t port_id, uint8_t queues[], uint16_t nb_unlinks)
__rte_experimental int rte_event_port_profile_unlink(uint8_t dev_id, uint8_t port_id, uint8_t queues[], uint16_t nb_unlinks, uint8_t profile_id)
#define RTE_EVENT_DEV_XSTATS_NAME_SIZE
int rte_event_dev_socket_id(uint8_t dev_id)
int rte_event_dev_configure(uint8_t dev_id, const struct rte_event_dev_config *dev_conf)
int rte_event_dev_close(uint8_t dev_id)
static __rte_experimental void rte_event_port_preschedule(uint8_t dev_id, uint8_t port_id, enum rte_event_dev_preschedule_type type)
static uint16_t rte_event_enqueue_burst(uint8_t dev_id, uint8_t port_id, const struct rte_event ev[], uint16_t nb_events)
uint32_t dequeue_timeout_ns
Definition: rte_eventdev.h:768
enum rte_event_dev_preschedule_type preschedule_type
Definition: rte_eventdev.h:838
uint8_t nb_single_link_event_port_queues
Definition: rte_eventdev.h:830
uint32_t nb_event_port_enqueue_depth
Definition: rte_eventdev.h:821
uint32_t nb_event_queue_flows
Definition: rte_eventdev.h:809
uint32_t nb_event_port_dequeue_depth
Definition: rte_eventdev.h:814
uint8_t max_event_port_links
Definition: rte_eventdev.h:662
uint32_t max_event_port_enqueue_depth
Definition: rte_eventdev.h:655
uint32_t dequeue_timeout_ns
Definition: rte_eventdev.h:606
uint32_t min_dequeue_timeout_ns
Definition: rte_eventdev.h:602
uint8_t max_event_queues
Definition: rte_eventdev.h:608
uint32_t max_event_queue_flows
Definition: rte_eventdev.h:613
uint8_t max_event_port_dequeue_depth
Definition: rte_eventdev.h:648
uint8_t max_event_queue_priority_levels
Definition: rte_eventdev.h:615
uint8_t max_profiles_per_port
Definition: rte_eventdev.h:680
uint8_t max_event_priority_levels
Definition: rte_eventdev.h:629
uint32_t event_dev_cap
Definition: rte_eventdev.h:672
const char * driver_name
Definition: rte_eventdev.h:600
uint32_t max_dequeue_timeout_ns
Definition: rte_eventdev.h:604
struct rte_device * dev
Definition: rte_eventdev.h:601
uint8_t max_single_link_event_port_queue_pairs
Definition: rte_eventdev.h:674
uint32_t nb_atomic_order_sequences
Definition: rte_eventdev.h:924
uint8_t priority
uint32_t flow_id
uint8_t rsvd
uint8_t op
uint32_t event_type
struct rte_mbuf * mbuf
uint8_t queue_id
uint8_t sched_type
uint64_t u64
struct rte_event_vector * vec
uint8_t impl_opaque
uint32_t sub_event_type
void * event_ptr
char name[RTE_MEMPOOL_NAMESIZE]
Definition: rte_mempool.h:231
uint32_t cache_size
Definition: rte_mempool.h:241