Searched refs:wkr (Results 1 – 4 of 4) sorted by relevance
123 d->in_flight_tags[wkr] = 0; in handle_worker_shutdown()164 unsigned wkr; in process_returns() local169 for (wkr = 0; wkr < d->num_workers; wkr++) { in process_returns()177 if (d->backlog[wkr].count) in process_returns()211 unsigned wkr = 0; in rte_distributor_process_single() local270 if (d->backlog[wkr].count) in rte_distributor_process_single()294 if (++wkr == d->num_workers) in rte_distributor_process_single()295 wkr = 0; in rte_distributor_process_single()299 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_process_single()300 if (d->backlog[wkr].count && in rte_distributor_process_single()[all …]
419 d->bufs[wkr].bufptr64[i] = d->backlog[wkr].pkts[i] | in release()421 d->in_flight_tags[wkr][i] = d->backlog[wkr].tags[i]; in release()566 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()571 release(d, wkr); in rte_distributor_process()596 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()648 for (wkr = 0; wkr < d->num_workers; wkr++) in total_outstanding()649 total_outstanding += d->backlog[wkr].count + d->bufs[wkr].count; in total_outstanding()662 unsigned int wkr; in rte_distributor_flush() local683 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_flush()693 unsigned int wkr; in rte_distributor_clear_returns() local[all …]
21 __m128i wkr; in find_match_vec() local75 wkr = _mm_set1_epi16(i+1); in find_match_vec()76 mask1 = _mm_and_si128(mask1, wkr); in find_match_vec()
62 } wkr __rte_cache_aligned;374 app_stats.wkr.dequeue_pkts += wkr_stats[lcore_id].deq_pkts; in print_stats()375 app_stats.wkr.enqueue_pkts += wkr_stats[lcore_id].enq_pkts; in print_stats()376 app_stats.wkr.enqueue_failed_pkts += in print_stats()382 app_stats.wkr.dequeue_pkts); in print_stats()384 app_stats.wkr.enqueue_pkts); in print_stats()386 app_stats.wkr.enqueue_failed_pkts); in print_stats()