Home
last modified time | relevance | path

Searched refs:lcore (Results 1 – 25 of 74) sorted by relevance

123

/dpdk/lib/dispatcher/
H A Drte_dispatcher.c64 evd_lookup_handler_idx(struct rte_dispatcher_lcore *lcore, in evd_lookup_handler_idx() argument
69 for (i = 0; i < lcore->num_handlers; i++) { in evd_lookup_handler_idx()
71 &lcore->handlers[i]; in evd_lookup_handler_idx()
81 evd_prioritize_handler(struct rte_dispatcher_lcore *lcore, in evd_prioritize_handler() argument
91 tmp = lcore->handlers[handler_idx - 1]; in evd_prioritize_handler()
92 lcore->handlers[handler_idx - 1] = lcore->handlers[handler_idx]; in evd_prioritize_handler()
93 lcore->handlers[handler_idx] = tmp; in evd_prioritize_handler()
97 evd_consider_prioritize_handler(struct rte_dispatcher_lcore *lcore, in evd_consider_prioritize_handler() argument
100 lcore->prio_count -= handler_events; in evd_consider_prioritize_handler()
102 if (unlikely(lcore->prio_count <= 0)) { in evd_consider_prioritize_handler()
[all …]
/dpdk/lib/eal/common/
H A Drte_service.c369 /* The lcore service worker thread is the only writer, and in rte_service_runstate_get()
525 * lcore thread really is done in service cores code. in service_runner_func()
532 rte_service_lcore_may_be_active(uint32_t lcore)
534 struct core_state *cs = RTE_LCORE_VAR_LCORE(lcore, lcore_states); in rte_service_lcore_may_be_active() argument
536 if (lcore >= RTE_MAX_LCORE || !cs->is_service_core) in rte_service_lcore_may_be_active()
584 rte_service_lcore_count_services(uint32_t lcore) in rte_service_lcore_count_services()
586 if (lcore >= RTE_MAX_LCORE) in rte_service_lcore_count_services()
589 struct core_state *cs = RTE_LCORE_VAR_LCORE(lcore, lcore_states); in rte_service_lcore_count_services()
639 service_update(uint32_t sid, uint32_t lcore, uint32_t *set, uint32_t *enabled) in service_update()
641 struct core_state *cs = RTE_LCORE_VAR_LCORE(lcore, lcore_state in service_update()
489 const int lcore = rte_lcore_id(); service_runner_func() local
580 rte_service_lcore_count_services(uint32_t lcore) rte_service_lcore_count_services() argument
635 service_update(uint32_t sid,uint32_t lcore,uint32_t * set,uint32_t * enabled) service_update() argument
666 rte_service_map_lcore_set(uint32_t id,uint32_t lcore,uint32_t enabled) rte_service_map_lcore_set() argument
674 rte_service_map_lcore_get(uint32_t id,uint32_t lcore) rte_service_map_lcore_get() argument
684 set_lcore_state(uint32_t lcore,int32_t state) set_lcore_state() argument
724 rte_service_lcore_add(uint32_t lcore) rte_service_lcore_add() argument
745 rte_service_lcore_del(uint32_t lcore) rte_service_lcore_del() argument
769 rte_service_lcore_start(uint32_t lcore) rte_service_lcore_start() argument
802 rte_service_lcore_stop(uint32_t lcore) rte_service_lcore_stop() argument
846 lcore_attr_get_loops(unsigned int lcore) lcore_attr_get_loops() argument
854 lcore_attr_get_cycles(unsigned int lcore) lcore_attr_get_cycles() argument
862 lcore_attr_get_service_calls(uint32_t service_id,unsigned int lcore) lcore_attr_get_service_calls() argument
871 lcore_attr_get_service_cycles(uint32_t service_id,unsigned int lcore) lcore_attr_get_service_cycles() argument
885 unsigned int lcore; attr_get() local
930 rte_service_lcore_attr_get(uint32_t lcore,uint32_t attr_id,uint64_t * attr_value) rte_service_lcore_attr_get() argument
957 unsigned int lcore; rte_service_attr_reset_all() local
972 rte_service_lcore_attr_reset_all(uint32_t lcore) rte_service_lcore_attr_reset_all() argument
1011 service_dump_calls_per_lcore(FILE * f,uint32_t lcore) service_dump_calls_per_lcore() argument
[all...]
H A Deal_common_trace_points.c72 lib.eal.thread.lcore.ready)
74 lib.eal.thread.lcore.running)
76 lib.eal.thread.lcore.stopped)
79 lib.eal.service.map.lcore)
81 lib.eal.service.lcore.state.change)
83 lib.eal.service.lcore.start)
85 lib.eal.service.lcore.stop)
/dpdk/dts/framework/testbed_model/
H A Dcpu.py43 lcore: int
50 return self.lcore
82 for lcore in lcore_list:
83 if isinstance(lcore, str):
84 self._lcore_list.extend(expand_range(lcore))
86 self._lcore_list.append(int(lcore))
244 for lcore in lcores_to_filter:
250 allowed_sockets.add(lcore.socket)
251 if lcore.socket in allowed_sockets:
253 if lcore.socket in filtered_lcores:
[all …]
/dpdk/app/test-pipeline/
H A Dmain.c57 uint32_t lcore; in main() local
84 RTE_LCORE_FOREACH_WORKER(lcore) { in main()
85 if (rte_eal_wait_lcore(lcore) < 0) in main()
113 unsigned lcore; in app_lcore_main_loop() local
115 lcore = rte_lcore_id(); in app_lcore_main_loop()
117 if (lcore == app.core_rx) { in app_lcore_main_loop()
129 if (lcore == app.core_worker) { in app_lcore_main_loop()
183 if (lcore == app.core_tx) { in app_lcore_main_loop()
/dpdk/lib/power/
H A Drte_power_pmd_mgmt.c61 /**< List of queues associated with this lcore */
203 * no need change the lcore sleep target counter because this lcore will in queue_reset()
274 /* can this lcore sleep? */ in clb_multiwait()
335 /* can this lcore sleep? */ in clb_pause()
375 /* can this lcore sleep? */ in clb_scale_freq()
416 check_scale(unsigned int lcore)
429 if (rte_power_init(lcore)) in check_scale()
654 /* disable power library on this lcore if this was last queue */ in rte_power_ethdev_pmgmt_queue_disable()
703 rte_power_pmd_mgmt_set_scaling_freq_min(unsigned int lcore, unsigne
255 const unsigned int lcore = rte_lcore_id(); clb_multiwait() local
320 const unsigned int lcore = rte_lcore_id(); clb_pause() local
361 const unsigned int lcore = rte_lcore_id(); clb_scale_freq() local
418 check_scale(unsigned int lcore) check_scale() argument
704 rte_power_pmd_mgmt_set_scaling_freq_min(unsigned int lcore,unsigned int min) rte_power_pmd_mgmt_set_scaling_freq_min() argument
721 rte_power_pmd_mgmt_set_scaling_freq_max(unsigned int lcore,unsigned int max) rte_power_pmd_mgmt_set_scaling_freq_max() argument
742 rte_power_pmd_mgmt_get_scaling_freq_min(unsigned int lcore) rte_power_pmd_mgmt_get_scaling_freq_min() argument
756 rte_power_pmd_mgmt_get_scaling_freq_max(unsigned int lcore) rte_power_pmd_mgmt_get_scaling_freq_max() argument
[all...]
H A Drte_power_pmd_mgmt.h35 * Enable power management on a specified Ethernet device Rx queue and lcore.
43 * The lcore the Rx queue will be polled from.
60 * Disable power management on a specified Ethernet device Rx queue and lcore.
68 * The lcore the Rx queue is polled from.
128 * @param lcore
129 * The ID of the lcore to set the min frequency for.
137 rte_power_pmd_mgmt_set_scaling_freq_min(unsigned int lcore, unsigned int min);
144 * @param lcore
145 * The ID of the lcore to set the max frequency for.
154 rte_power_pmd_mgmt_set_scaling_freq_max(unsigned int lcore, unsigne
[all...]
/dpdk/usertools/telemetry-endpoints/
H A Dcpu.py18 lcore = sock.cmd("/eal/lcore/info", lcore_id)
19 cpu = ",".join(str(c) for c in lcore.get("cpuset", []))
20 total = lcore.get("total_cycles")
21 busy = lcore.get("busy_cycles", 0)
24 labels = {"cpu": cpu, "numa": lcore.get("socket", 0)}
/dpdk/lib/eal/include/
H A Drte_service.h98 * Map or unmap a lcore to a service.
101 * function enables or disables *lcore* to run *service_id*.
109 * If the service is known to be mapped to a single lcore, setting the
113 * @param service_id the service to apply the lcore to
114 * @param lcore The lcore that will be mapped to service
117 * @retval 0 lcore map updated successfully
118 * @retval -EINVAL An invalid service or lcore was provided.
120 int32_t rte_service_map_lcore_set(uint32_t service_id, uint32_t lcore,
124 * Retrieve the mapping of an lcore t
[all...]
/dpdk/app/test/
H A Dtest_pflock.c68 const unsigned int lcore = rte_lcore_id(); in load_loop_fn() local
71 if (lcore != rte_get_main_lcore()) in load_loop_fn()
90 time_count[lcore] = time_diff * 1000000 / hz; in load_loop_fn()
100 const unsigned int lcore = rte_lcore_id(); in test_pflock_perf() local
106 lcore, time_count[lcore]); in test_pflock_perf()
114 lcore, time_count[lcore]); in test_pflock_perf()
H A Dtest_ticketlock.c110 const unsigned int lcore = rte_lcore_id(); in load_loop_fn() local
113 if (lcore != rte_get_main_lcore()) in load_loop_fn()
118 while (lcore_count[lcore] < MAX_LOOP) { in load_loop_fn()
121 lcore_count[lcore]++; in load_loop_fn()
127 time_cost[lcore] = time_diff * 1000000 / hz; in load_loop_fn()
138 const unsigned int lcore = rte_lcore_id(); in test_ticketlock_perf() local
142 printf("Core [%u] cost time = %"PRIu64" us\n", lcore, time_cost[lcore]); in test_ticketlock_perf()
149 printf("Core [%u] cost time = %"PRIu64" us\n", lcore, time_cost[lcore]); in test_ticketlock_perf()
H A Dtest_mcslock.c72 const unsigned int lcore = rte_lcore_id(); in load_loop_fn() local
90 time_count[lcore] = time_diff * 1000000 / hz; in load_loop_fn()
100 const unsigned int lcore = rte_lcore_id(); in test_mcslock_perf() local
106 lcore, time_count[lcore]); in test_mcslock_perf()
114 lcore, time_count[lcore]); in test_mcslock_perf()
H A Dtest_spinlock.c109 const unsigned lcore = rte_lcore_id(); in load_loop_fn() local
112 if (lcore != rte_get_main_lcore()) in load_loop_fn()
125 time_count[lcore] = time_diff * 1000000 / hz; in load_loop_fn()
135 const unsigned lcore = rte_lcore_id(); in test_spinlock_perf() local
139 printf("Core [%u] Cost Time = %"PRIu64" us\n", lcore, in test_spinlock_perf()
140 time_count[lcore]); in test_spinlock_perf()
146 printf("Core [%u] Cost Time = %"PRIu64" us\n", lcore, in test_spinlock_perf()
147 time_count[lcore]); in test_spinlock_perf()
/dpdk/examples/l3fwd-power/
H A Dperf_core.c34 is_hp_core(unsigned int lcore) in is_hp_core() argument
44 ret = rte_power_get_capabilities(lcore, &caps); in is_hp_core()
84 /* update the lcore config */ in update_lcore_params()
86 int lcore = -1; in update_lcore_params() local
89 lcore = hp_lcores[prf_lc_prms[i].lcore_idx]; in update_lcore_params()
92 lcore = in update_lcore_params()
96 if (lcore < 0) { in update_lcore_params()
101 lcore_params_array[i].lcore_id = lcore; in update_lcore_params()
166 printf("exceeded max number of lcore params: %hu\n", in parse_perf_config()
/dpdk/doc/guides/sample_app_ug/
H A Dvhost_crypto.rst32 --config (lcore,cdev-id,queue-id)[,(lcore,cdev-id,queue-id)]
33 --socket-file lcore,PATH
39 * config (lcore,cdev-id,queue-id): build the lcore-cryptodev id-queue id
40 connection. Once specified, the specified lcore will only work with
43 * socket-file lcore,PATH: the path of UNIX socket file to be created and
44 the lcore id that will deal with the all workloads of the socket. Multiple
45 instances of this config item is supported and one lcore supports processing
H A Dtimer.rst46 executed on each worker lcore using the well-known
51 :start-after: Call lcore_mainloop() on every worker lcore. 8<
52 :end-before: >8 End of call lcore_mainloop() on every worker lcore.
63 As explained in the comment, it is better to use the TSC register (as it is a per-lcore register) t…
81 * The first timer (timer0) is loaded on the main lcore and expires every second.
85 * The second timer (timer1) is loaded on the next available lcore every 333 ms.
91 :start-after: Load timer0, every second, on main lcore, reloaded automatically. 8<
103 …for the second timer (timer1) displays a message and reloads the timer on the next lcore, using the
H A Dbbdev_app.rst64 using the allow option for pci device running on 1 encoding lcore and 1 decoding lcore
81 - core 4 is the encoding lcore performing Rx and Turbo Encode operations
83 - core 5 is the downlink lcore performing Turbo Decode, validation and Tx
/dpdk/doc/guides/prog_guide/
H A Dglossary.rst102 lcore
124 main lcore
128 master lcore
129 Deprecated name for *main lcore*. No longer used.
190 Slave lcore
191 Deprecated name for *worker lcore*. No longer used.
243 Worker lcore
244 Any *lcore* that is not the *main lcore*.
H A Dservice_cores.rst19 PMD requires an lcore to perform the scheduling operations, while the hardware
39 service cores. Enabling a service on a particular core means that the lcore in
41 lcore in question from running the service.
45 lcore loops over the services that are enabled for that core, and invokes the
H A Dpacket_distrib_lib.rst9 …s library, the logical cores in use are to be considered in two roles: firstly a distributor lcore,
29 #. Packets are passed to the distributor component by having the distributor lcore thread call the…
48 Other functions which are available to the distributor lcore are:
57 which should only be called on the lcore which also calls the process API.
64 Once a worker lcore requests a new packet, the distributor assumes that it has completely finished …
/dpdk/lib/eal/windows/
H A Deal_lcore.c116 struct lcore_map *lcore; in eal_create_lcore_map() local
145 lcore = &cpu_map.lcores[cpu_map.lcore_count]; in eal_create_lcore_map()
146 lcore->socket_id = socket_id; in eal_create_lcore_map()
147 lcore->core_id = cores->Group * EAL_PROCESSOR_GROUP_SIZE + i; in eal_create_lcore_map()
/dpdk/app/test-flow-perf/
H A Dmain.c1810 int lcore = rte_lcore_id(); in start_forwarding() local
1813 struct lcore_info *li = &lcore_infos[lcore]; in start_forwarding()
1819 printf(":: started stats on lcore %u\n", lcore); in start_forwarding()
1844 unsigned int lcore; in init_lcore_info() local
1855 lcore = rte_get_next_lcore(-1, 0, 0); in init_lcore_info()
1856 lcore_infos[lcore].mode = LCORE_MODE_STATS; in init_lcore_info()
1882 lcore = rte_get_next_lcore(lcore, 0, 0); in init_lcore_info()
1883 lcore_infos[lcore].streams_nb = 1; in init_lcore_info()
1889 lcore = rte_get_next_lcore(lcore, 0, 0); in init_lcore_info()
1890 lcore_infos[lcore].streams_nb = streams_per_core; in init_lcore_info()
[all …]
/dpdk/examples/l3fwd-graph/
H A Dmain.c190 printf("Exceeded max number of lcore params for remote model: %hu\n",
203 uint32_t lcore; in check_worker_model_params()
211 lcore = lcore_params[i].lcore_id; in check_lcore_params()
212 if (!rte_lcore_is_enabled(lcore)) { in check_lcore_params()
213 printf("Error: lcore %u is not enabled in lcore mask\n", in check_lcore_params()
214 lcore); in check_lcore_params()
218 if (lcore == rte_get_main_lcore()) { in check_lcore_params()
219 printf("Error: lcore %u is main lcore\ in check_lcore_params()
208 uint8_t queue, lcore; check_lcore_params() local
285 uint8_t lcore; init_lcore_rx_queues() local
[all...]
/dpdk/examples/ip_reassembly/
H A Dmain.c440 RTE_LOG(INFO, IP_RSMBL, "lcore %u has nothing to do\n", lcore_id); in main_loop()
444 RTE_LOG(INFO, IP_RSMBL, "entering main loop on lcore %u\n", lcore_id); in main_loop()
518 " -q NQ: number of RX queues per lcore\n" in print_usage()
822 setup_port_tbl(struct lcore_queue_conf *qconf, uint32_t lcore, int socket,
834 RTE_LOG(ERR, IP_RSMBL, "%s() for lcore: %u, port: %u " in setup_port_tbl()
836 __func__, lcore, port, sz); in setup_port_tbl()
847 setup_queue_tbl(struct rx_queue *rxq, uint32_t lcore, uint32_t queue)
854 socket = rte_lcore_to_socket_id(lcore); in setup_queue_tbl()
866 "lcore: %u for queue: %u failed\n", in setup_queue_tbl()
867 max_flow_num, lcore, queu in setup_queue_tbl()
823 setup_port_tbl(struct lcore_queue_conf * qconf,uint32_t lcore,int socket,uint32_t port) setup_port_tbl() argument
848 setup_queue_tbl(struct rx_queue * rxq,uint32_t lcore,uint32_t queue) setup_queue_tbl() argument
959 uint32_t i, lcore; queue_dump_stat() local
[all...]
/dpdk/examples/l3fwd/
H A Dmain.c300 uint32_t lcore; in check_lcore_params()
309 lcore = lcore_params[i].lcore_id; in check_lcore_params()
310 if (!rte_lcore_is_enabled(lcore)) { in check_lcore_params()
311 printf("error: lcore %u is not enabled in lcore mask\n", lcore); in check_lcore_params()
314 if ((socketid = rte_lcore_to_socket_id(lcore) != 0) && in check_lcore_params()
316 printf("warning: lcore %u is on socket %d with numa off\n", in check_lcore_params()
317 lcore, socketid); in check_lcore_params()
366 uint32_t lcore; in init_lcore_rx_queues()
295 uint8_t queue, lcore; check_lcore_params() local
362 uint8_t lcore; init_lcore_rx_queues() local
[all...]

123