Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 25 of 75) sorted by relevance

123

/f-stack/dpdk/doc/guides/sample_app_ug/
H A Deventdev_pipeline.rst43 * ``-c32``: worker dequeue depth of 32
124 worker 0 thread done. RX=0 TX=0
130 worker 2 thread done. RX=0 TX=0
133 worker 0 : 12.5 % (4979876 pkts)
134 worker 1 : 12.5 % (4970497 pkts)
135 worker 2 : 12.5 % (4986359 pkts)
136 worker 3 : 12.5 % (4970517 pkts)
137 worker 4 : 12.5 % (4966566 pkts)
138 worker 5 : 12.5 % (4963297 pkts)
139 worker 6 : 12.5 % (4953598 pkts)
[all …]
H A Dpacket_ordering.rst18 * Worker (worker core) basically do some light work on the packet.
22 * TX Core (worker core) receives traffic from Worker cores through software queues,
47 [--disable-reorder] [--insight-worker]
61 The insight-worker long option enables output the packet statistics of each worker thread.
H A Ddist_app.rst66 worker threads (``lcore_worker()``), and a transmit thread(``lcore_tx()``).
78 tag. The distributor thread communicates with the worker threads using a
80 (one cache line) to each worker.
82 More than one worker thread can exist as part of the application, and these
83 worker threads do simple packet processing by requesting packets from
133 in the application, and also key statistics per worker, including how many
134 packets of each burst size (1-8) were sent to each worker thread.
/f-stack/dpdk/drivers/crypto/scheduler/
H A Dscheduler_failover.c24 failover_worker_enqueue(struct scheduler_worker *worker, in failover_worker_enqueue() argument
32 processed_ops = rte_cryptodev_enqueue_burst(worker->dev_id, in failover_worker_enqueue()
33 worker->qp_id, ops, nb_ops); in failover_worker_enqueue()
34 worker->nb_inflight_cops += processed_ops; in failover_worker_enqueue()
88 if (worker->nb_inflight_cops) { in schedule_dequeue()
90 worker->qp_id, ops, nb_ops); in schedule_dequeue()
91 worker->nb_inflight_cops -= nb_deq_ops; in schedule_dequeue()
99 worker = workers[qp_ctx->deq_idx]; in schedule_dequeue()
101 if (worker->nb_inflight_cops) { in schedule_dequeue()
103 worker->qp_id, &ops[nb_deq_ops], nb_ops - nb_deq_ops); in schedule_dequeue()
[all …]
H A Dscheduler_roundrobin.c25 struct scheduler_worker *worker = &rr_qp_ctx->workers[worker_idx]; in schedule_enqueue() local
34 processed_ops = rte_cryptodev_enqueue_burst(worker->dev_id, in schedule_enqueue()
35 worker->qp_id, ops, nb_ops); in schedule_enqueue()
37 worker->nb_inflight_cops += processed_ops; in schedule_enqueue()
67 struct scheduler_worker *worker; in schedule_dequeue() local
85 worker = &rr_qp_ctx->workers[last_worker_idx]; in schedule_dequeue()
87 nb_deq_ops = rte_cryptodev_dequeue_burst(worker->dev_id, in schedule_dequeue()
88 worker->qp_id, ops, nb_ops); in schedule_dequeue()
95 worker->nb_inflight_cops -= nb_deq_ops; in schedule_dequeue()
H A Dscheduler_pkt_size_distr.c196 struct scheduler_worker *worker = workers[qp_ctx->deq_idx]; in schedule_dequeue() local
199 if (worker->nb_inflight_cops) { in schedule_dequeue()
200 nb_deq_ops_pri = rte_cryptodev_dequeue_burst(worker->dev_id, in schedule_dequeue()
201 worker->qp_id, ops, nb_ops); in schedule_dequeue()
202 worker->nb_inflight_cops -= nb_deq_ops_pri; in schedule_dequeue()
210 worker = workers[qp_ctx->deq_idx]; in schedule_dequeue()
212 if (worker->nb_inflight_cops) { in schedule_dequeue()
213 nb_deq_ops_sec = rte_cryptodev_dequeue_burst(worker->dev_id, in schedule_dequeue()
214 worker->qp_id, &ops[nb_deq_ops_pri], in schedule_dequeue()
216 worker->nb_inflight_cops -= nb_deq_ops_sec; in schedule_dequeue()
[all …]
H A Dscheduler_multicore.c157 struct scheduler_worker *worker; in mc_scheduler_worker() local
180 worker = &sched_ctx->workers[worker_idx]; in mc_scheduler_worker()
187 rte_cryptodev_enqueue_burst(worker->dev_id, in mc_scheduler_worker()
188 worker->qp_id, in mc_scheduler_worker()
199 worker->dev_id, worker->qp_id, in mc_scheduler_worker()
214 worker->dev_id, worker->qp_id, deq_ops, in mc_scheduler_worker()
H A Drte_cryptodev_scheduler.c167 struct scheduler_worker *worker; in rte_cryptodev_scheduler_worker_attach() local
199 worker = &sched_ctx->workers[sched_ctx->nb_workers]; in rte_cryptodev_scheduler_worker_attach()
203 worker->dev_id = worker_id; in rte_cryptodev_scheduler_worker_attach()
204 worker->driver_id = dev_info.driver_id; in rte_cryptodev_scheduler_worker_attach()
208 worker->dev_id = 0; in rte_cryptodev_scheduler_worker_attach()
209 worker->driver_id = 0; in rte_cryptodev_scheduler_worker_attach()
/f-stack/dpdk/doc/guides/cryptodevs/
H A Dscheduler.rst79 …dev "crypto_aesni_mb1,name=aesni_mb_2" --vdev "crypto_scheduler,worker=aesni_mb_1,worker=aesni_mb_…
84 is set and at least one worker is attached. Also, to configure the
85 scheduler in the run-time, like attach/detach worker(s), change
115 worker and the secondary worker, and distributes the enqueued crypto
119 worker.
145 crypto operation burst to the primary worker. When one or more crypto
147 worker.
154 worker cores. The enqueued bursts are distributed among the worker cores in a
162 Each worker uses its own cryptodev. Only software cryptodevs
168 The number of worker cores should be equal to the number of worker cryptodevs.
[all …]
/f-stack/dpdk/doc/guides/prog_guide/
H A Dpacket_distrib_lib.rst11 and a set of worker lcores which are responsible for receiving the packets from the distributor and…
31 #. The worker lcores all share a single cache line with the distributor core in order to pass mess…
32 …The process API call will poll all the worker cache lines to see what workers are requesting packe…
36 and records what tags are being processed by each worker.
38 #. If the next packet in the input set has a tag which is already being processed by a worker,
39 then that packet will be queued up for processing by that worker
45 or been queued up for a worker which is processing a given tag,
58 It returns to the caller all packets which have finished processing by all worker cores.
62 If worker lcores buffer up packets internally for transmission in bulk afterwards,
91 Since it may be desirable to vary the number of worker cores, depending on the traffic load
[all …]
/f-stack/tools/libxo/tests/core/saved/
H A Dtest_11.X.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.XP.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.H.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.HP.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.T.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.J.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.JP.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.HIPx.out1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
H A Dtest_11.E.out4 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
8 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
12 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
16 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
/f-stack/doc/
H A DF-Stack_Nginx_APP_Guide.md27 last one to exit<-+ primary worker | | secondary worker | | secondary worker |
41 - spawn primary worker firstly, and then wait for primary startup, continue to spawn secondary work…
43 - a major addition to the worker process is fstack-handling：ff_init();ff_run(worker_process_cycle);…
/f-stack/dpdk/app/test-eventdev/
H A Dtest_pipeline_common.c18 total += t->worker[i].processed_pkts; in pipeline_test_result()
22 t->worker[i].processed_pkts, in pipeline_test_result()
23 (((double)t->worker[i].processed_pkts)/total) in pipeline_test_result()
49 total += t->worker[i].processed_pkts; in processed_pkts()
56 int (*worker)(void *)) in pipeline_launch_lcores()
67 ret = rte_eal_remote_launch(worker, in pipeline_launch_lcores()
68 &t->worker[port_idx], lcore_id); in pipeline_launch_lcores()
283 struct worker_data *w = &t->worker[port]; in pipeline_event_port_setup()
H A Dtest_perf_common.c17 total += t->worker[i].processed_pkts; in perf_test_result()
21 t->worker[i].processed_pkts, in perf_test_result()
22 (((double)t->worker[i].processed_pkts)/total) in perf_test_result()
229 total += t->worker[i].processed_pkts; in processed_pkts()
242 total += t->worker[i].latency; in total_latency()
250 int (*worker)(void *)) in perf_launch_lcores()
261 ret = rte_eal_remote_launch(worker, in perf_launch_lcores()
262 &t->worker[port_idx], lcore_id); in perf_launch_lcores()
473 struct worker_data *w = &t->worker[port]; in perf_event_dev_port_setup()
H A Dtest_order_common.c263 int (*worker)(void *)) in order_launch_lcores()
274 ret = rte_eal_remote_launch(worker, &t->worker[wkr_idx], in order_launch_lcores()
351 struct worker_data *w = &t->worker[port]; in order_event_dev_port_setup()
/f-stack/freebsd/contrib/zstd/lib/common/
H A Dthreading.c38 static unsigned __stdcall worker(void *arg) in worker() function
51 thread->handle = (HANDLE) _beginthreadex(NULL, 0, worker, thread, 0, NULL); in ZSTD_pthread_create()
/f-stack/dpdk/drivers/event/sw/
H A Dsw_evdev_scheduler.c102 struct rte_event_ring *worker = p->cq_worker_ring; in sw_schedule_atomic_to_cq() local
103 rte_event_ring_enqueue_burst(worker, p->cq_buf, in sw_schedule_atomic_to_cq()
344 struct rte_event_ring *worker = port->rx_worker_ring; in sw_refill_pp_buf() local
346 port->pp_buf_count = rte_event_ring_dequeue_burst(worker, port->pp_buf, in sw_refill_pp_buf()
568 struct rte_event_ring *worker = port->cq_worker_ring; in sw_event_schedule() local
575 rte_event_ring_enqueue_burst(worker, in sw_event_schedule()
583 rte_event_ring_free_count(worker) - in sw_event_schedule()

123