Home
last modified time | relevance | path

Searched refs:worker_idx (Results 1 – 6 of 6) sorted by relevance

/f-stack/dpdk/drivers/crypto/scheduler/
H A Dscheduler_multicore.c58 if (++worker_idx == mc_ctx->num_workers) in schedule_enqueue()
59 worker_idx = 0; in schedule_enqueue()
61 mc_qp_ctx->last_enq_worker_idx = worker_idx; in schedule_enqueue()
99 if (++worker_idx == mc_ctx->num_workers) in schedule_dequeue()
100 worker_idx = 0; in schedule_dequeue()
103 mc_qp_ctx->last_deq_worker_idx = worker_idx; in schedule_dequeue()
156 int i, worker_idx = -1; in mc_scheduler_worker() local
170 worker_idx = i; in mc_scheduler_worker()
174 if (worker_idx == -1) { in mc_scheduler_worker()
180 worker = &sched_ctx->workers[worker_idx]; in mc_scheduler_worker()
[all …]
H A Dscheduler_pkt_size_distr.c32 uint8_t worker_idx; member
83 if (p_enq_op->pos + in_flight_ops[p_enq_op->worker_idx] == in schedule_enqueue()
89 sched_ops[p_enq_op->worker_idx][p_enq_op->pos] = ops[i]; in schedule_enqueue()
97 if (p_enq_op->pos + in_flight_ops[p_enq_op->worker_idx] == in schedule_enqueue()
103 sched_ops[p_enq_op->worker_idx][p_enq_op->pos] = ops[i+1]; in schedule_enqueue()
111 if (p_enq_op->pos + in_flight_ops[p_enq_op->worker_idx] == in schedule_enqueue()
117 sched_ops[p_enq_op->worker_idx][p_enq_op->pos] = ops[i+2]; in schedule_enqueue()
125 if (p_enq_op->pos + in_flight_ops[p_enq_op->worker_idx] == in schedule_enqueue()
131 sched_ops[p_enq_op->worker_idx][p_enq_op->pos] = ops[i+3]; in schedule_enqueue()
141 if (p_enq_op->pos + in_flight_ops[p_enq_op->worker_idx] == in schedule_enqueue()
[all …]
H A Dscheduler_roundrobin.c24 uint32_t worker_idx = rr_qp_ctx->last_enq_worker_idx; in schedule_enqueue() local
25 struct scheduler_worker *worker = &rr_qp_ctx->workers[worker_idx]; in schedule_enqueue()
/f-stack/dpdk/app/test/
H A Dtest_distributor_perf.c23 static volatile unsigned worker_idx; variable
91 for (i = 0; i < worker_idx; i++) in total_packet_count()
114 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_work()
200 worker_idx = 0; in quit_workers()
H A Dtest_distributor.c41 static volatile unsigned worker_idx; variable
56 for (i = 0; i < worker_idx; i++) in total_packet_count()
82 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_work()
300 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_work_with_free_mbufs()
370 const unsigned int id = __atomic_fetch_add(&worker_idx, 1, in handle_work_for_shutdown_test()
585 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_and_mark_work()
803 worker_idx = 0; in quit_workers()
/f-stack/dpdk/examples/eventdev_pipeline/
H A Dmain.c398 int worker_idx = 0; in main() local
427 worker_data[worker_idx].port_id); in main()
430 &worker_data[worker_idx], lcore_id); in main()
437 worker_idx++; in main()
443 fdata->cap.worker(&worker_data[worker_idx++]); in main()