Home
last modified time | relevance | path

Searched refs:backlog (Results 1 – 4 of 4) sorted by relevance

/dpdk/lib/distributor/
H A Drte_distributor_single.c123 if (unlikely(d->backlog[wkr].count != 0)) { in handle_worker_shutdown()
136 struct rte_distributor_backlog *bl = &d->backlog[wkr]; in handle_worker_shutdown()
173 if (d->backlog[wkr].count) in process_returns()
176 backlog_pop(&d->backlog[wkr]), in process_returns()
256 if (add_to_backlog(&d->backlog[worker], in rte_distributor_process_single()
263 (d->backlog[wkr].count || next_mb)) { in rte_distributor_process_single()
265 if (d->backlog[wkr].count) in rte_distributor_process_single()
268 backlog_pop(&d->backlog[wkr]), in rte_distributor_process_single()
295 if (d->backlog[wkr].count && in rte_distributor_process_single()
307 backlog_pop(&d->backlog[wkr]), in rte_distributor_process_single()
[all …]
H A Drte_distributor.c257 bl = &d->backlog[i]; in find_match_scalar()
316 for (i = 0; i < d->backlog[wkr].count; i++) in handle_worker_shutdown()
318 (d->backlog[wkr].pkts[i] >> RTE_DISTRIB_FLAG_BITS)); in handle_worker_shutdown()
320 d->backlog[wkr].count = 0; in handle_worker_shutdown()
325 d->backlog[wkr].tags[i] = 0; in handle_worker_shutdown()
416 for (i = 0; i < d->backlog[wkr].count; i++) { in release()
417 d->bufs[wkr].bufptr64[i] = d->backlog[wkr].pkts[i] | in release()
419 d->in_flight_tags[wkr][i] = d->backlog[wkr].tags[i]; in release()
427 d->backlog[wkr].count = 0; in release()
542 &d->backlog[matches[j]-1]; in rte_distributor_process()
[all …]
H A Ddistributor_private.h93 struct rte_distributor_backlog backlog[RTE_DISTRIB_MAX_WORKERS]; member
144 struct rte_distributor_backlog backlog[RTE_DISTRIB_MAX_WORKERS] member
H A Drte_distributor_match_sse.c41 bl = &d->backlog[i]; in find_match_vec()