Searched refs:wkr (Results 1 – 4 of 4) sorted by relevance
119 d->in_flight_tags[wkr] = 0; in handle_worker_shutdown()160 unsigned wkr; in process_returns() local165 for (wkr = 0; wkr < d->num_workers; wkr++) { in process_returns()173 if (d->backlog[wkr].count) in process_returns()207 unsigned wkr = 0; in rte_distributor_process_single() local265 if (d->backlog[wkr].count) in rte_distributor_process_single()289 if (++wkr == d->num_workers) in rte_distributor_process_single()290 wkr = 0; in rte_distributor_process_single()294 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_process_single()295 if (d->backlog[wkr].count && in rte_distributor_process_single()[all …]
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()564 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()569 release(d, wkr); in rte_distributor_process()594 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()646 for (wkr = 0; wkr < d->num_workers; wkr++) in total_outstanding()647 total_outstanding += d->backlog[wkr].count + d->bufs[wkr].count; in total_outstanding()660 unsigned int wkr; in rte_distributor_flush() local681 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_flush()691 unsigned int wkr; in rte_distributor_clear_returns() local[all …]
19 __m128i wkr; in find_match_vec() local73 wkr = _mm_set1_epi16(i+1); in find_match_vec()74 mask1 = _mm_and_si128(mask1, wkr); in find_match_vec()
69 } wkr __rte_cache_aligned;378 app_stats.wkr.dequeue_pkts += wkr_stats[lcore_id].deq_pkts; in print_stats()379 app_stats.wkr.enqueue_pkts += wkr_stats[lcore_id].enq_pkts; in print_stats()380 app_stats.wkr.enqueue_failed_pkts += in print_stats()386 app_stats.wkr.dequeue_pkts); in print_stats()388 app_stats.wkr.enqueue_pkts); in print_stats()390 app_stats.wkr.enqueue_failed_pkts); in print_stats()