33 #ifndef _RTE_DISTRIBUTOR_H_
34 #define _RTE_DISTRIBUTOR_H_
49 enum rte_distributor_alg_type {
50 RTE_DIST_ALG_BURST = 0,
52 RTE_DIST_NUM_ALG_TYPES
55 struct rte_distributor;
78 struct rte_distributor *
80 unsigned int num_workers,
81 unsigned int alg_type);
117 struct rte_mbuf **mbufs,
unsigned int num_mbufs);
135 struct rte_mbuf **mbufs,
unsigned int max_mbufs);
195 unsigned int worker_id,
struct rte_mbuf **pkts,
196 struct rte_mbuf **oldpkt,
unsigned int retcount);
214 unsigned int worker_id,
struct rte_mbuf **oldpkt,
int num);
240 unsigned int worker_id,
struct rte_mbuf **oldpkt,
263 unsigned int worker_id,
struct rte_mbuf **mbufs);
int rte_distributor_process(struct rte_distributor *d, struct rte_mbuf **mbufs, unsigned int num_mbufs)
int rte_distributor_get_pkt(struct rte_distributor *d, unsigned int worker_id, struct rte_mbuf **pkts, struct rte_mbuf **oldpkt, unsigned int retcount)
struct rte_distributor * rte_distributor_create(const char *name, unsigned int socket_id, unsigned int num_workers, unsigned int alg_type)
int rte_distributor_returned_pkts(struct rte_distributor *d, struct rte_mbuf **mbufs, unsigned int max_mbufs)
int rte_distributor_return_pkt(struct rte_distributor *d, unsigned int worker_id, struct rte_mbuf **oldpkt, int num)
void rte_distributor_request_pkt(struct rte_distributor *d, unsigned int worker_id, struct rte_mbuf **oldpkt, unsigned int count)
int rte_distributor_flush(struct rte_distributor *d)
void rte_distributor_clear_returns(struct rte_distributor *d)
int rte_distributor_poll_pkt(struct rte_distributor *d, unsigned int worker_id, struct rte_mbuf **mbufs)