Home
last modified time | relevance | path

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

/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()
/dpdk/examples/eventdev_pipeline/
H A Dmain.c27 unsigned int worker_idx) in dump_core_info() argument
48 data[worker_idx].port_id); in dump_core_info()
419 int worker_idx = 0; in main() local
430 dump_core_info(lcore_id, worker_data, worker_idx); in main()
433 &worker_data[worker_idx], lcore_id); in main()
440 worker_idx++; in main()
446 dump_core_info(lcore_id, worker_data, worker_idx); in main()
447 fdata->cap.worker(&worker_data[worker_idx]); in main()
450 worker_idx++; in main()
/dpdk/app/test/
H A Dtest_distributor_perf.c34 static volatile unsigned worker_idx; variable
102 for (i = 0; i < worker_idx; i++) in total_packet_count()
124 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_work()
210 worker_idx = 0; in quit_workers()
H A Dtest_distributor.c52 static volatile unsigned worker_idx; variable
67 for (i = 0; i < worker_idx; i++) in total_packet_count()
93 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_work()
313 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_work_with_free_mbufs()
383 const unsigned int id = __atomic_fetch_add(&worker_idx, 1, in handle_work_for_shutdown_test()
598 unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); in handle_and_mark_work()
816 worker_idx = 0; in quit_workers()