5 #ifndef _RTE_DIST_PRIV_H_
6 #define _RTE_DIST_PRIV_H_
21 #define RTE_DISTRIB_PREFIX "DT_"
29 #define RTE_DISTRIB_FLAG_BITS 4
30 #define RTE_DISTRIB_FLAGS_MASK (0x0F)
31 #define RTE_DISTRIB_NO_BUF 0
32 #define RTE_DISTRIB_GET_BUF (1)
33 #define RTE_DISTRIB_RETURN_BUF (2)
34 #define RTE_DISTRIB_VALID_BUF (4)
36 #define RTE_DISTRIB_BACKLOG_SIZE 8
37 #define RTE_DISTRIB_BACKLOG_MASK (RTE_DISTRIB_BACKLOG_SIZE - 1)
39 #define RTE_DISTRIB_MAX_RETURNS 128
40 #define RTE_DISTRIB_RETURNS_MASK (RTE_DISTRIB_MAX_RETURNS - 1)
47 #define RTE_DISTRIB_MAX_WORKERS 64
49 #define RTE_DISTRIBUTOR_NAMESIZE 32
58 union rte_distributor_buffer_v20 {
59 volatile int64_t bufptr64;
60 char pad[RTE_CACHE_LINE_SIZE*3];
67 #define RTE_DIST_BURST_SIZE 8
69 struct rte_distributor_backlog {
80 struct rte_mbuf *mbufs[RTE_DISTRIB_MAX_RETURNS];
83 struct rte_distributor_v20 {
84 TAILQ_ENTRY(rte_distributor_v20) next;
87 unsigned int num_workers;
91 uint64_t in_flight_bitmask;
97 struct rte_distributor_backlog backlog[RTE_DISTRIB_MAX_WORKERS];
105 enum rte_distributor_match_function {
106 RTE_DIST_MATCH_SCALAR = 0,
107 RTE_DIST_MATCH_VECTOR,
108 RTE_DIST_NUM_MATCH_FNS
120 volatile int64_t bufptr64[RTE_DIST_BURST_SIZE]
125 volatile int64_t retptr64[RTE_DIST_BURST_SIZE]
133 struct rte_distributor {
134 TAILQ_ENTRY(rte_distributor) next;
137 unsigned int num_workers;
138 unsigned int alg_type;
155 enum rte_distributor_match_function dist_match_fn;
157 struct rte_distributor_v20 *d_v20;
161 find_match_scalar(struct rte_distributor *d,
163 uint16_t *output_ptr);
166 find_match_vec(struct rte_distributor *d,
168 uint16_t *output_ptr);
int rte_distributor_returned_pkts(struct rte_distributor *d, struct rte_mbuf **mbufs, unsigned int max_mbufs)
#define RTE_DISTRIBUTOR_NAMESIZE
#define RTE_DISTRIB_MAX_WORKERS
#define __rte_cache_aligned