Home
last modified time | relevance | path

Searched refs:lcore_config (Results 1 – 14 of 14) sorted by relevance

/f-stack/dpdk/lib/librte_eal/windows/
H A Deal_thread.c32 if (lcore_config[worker_id].state != WAIT) in rte_eal_remote_launch()
35 lcore_config[worker_id].f = f; in rte_eal_remote_launch()
36 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
77 m2w = lcore_config[lcore_id].pipe_main2worker[0]; in eal_thread_loop()
97 lcore_config[lcore_id].state = RUNNING; in eal_thread_loop()
106 if (lcore_config[lcore_id].f == NULL) in eal_thread_loop()
110 fct_arg = lcore_config[lcore_id].arg; in eal_thread_loop()
111 ret = lcore_config[lcore_id].f(fct_arg); in eal_thread_loop()
112 lcore_config[lcore_id].ret = ret; in eal_thread_loop()
119 lcore_config[lcore_id].state = WAIT; in eal_thread_loop()
[all …]
H A Deal.c35 struct lcore_config lcore_config[RTE_MAX_LCORE]; variable
360 &lcore_config[config->main_lcore].cpuset); in rte_eal_init()
375 if (_pipe(lcore_config[i].pipe_main2worker, in rte_eal_init()
378 if (_pipe(lcore_config[i].pipe_worker2main, in rte_eal_init()
382 lcore_config[i].state = WAIT; in rte_eal_init()
385 if (eal_thread_create(&lcore_config[i].thread_id) != 0) in rte_eal_init()
/f-stack/dpdk/lib/librte_eal/linux/
H A Deal_thread.c42 if (lcore_config[worker_id].state != WAIT) in rte_eal_remote_launch()
45 lcore_config[worker_id].f = f; in rte_eal_remote_launch()
46 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
90 m2w = lcore_config[lcore_id].pipe_main2worker[0]; in eal_thread_loop()
113 lcore_config[lcore_id].state = RUNNING; in eal_thread_loop()
122 if (lcore_config[lcore_id].f == NULL) in eal_thread_loop()
126 fct_arg = lcore_config[lcore_id].arg; in eal_thread_loop()
127 ret = lcore_config[lcore_id].f(fct_arg); in eal_thread_loop()
128 lcore_config[lcore_id].ret = ret; in eal_thread_loop()
135 lcore_config[lcore_id].state = WAIT; in eal_thread_loop()
[all …]
H A Deal.c83 struct lcore_config lcore_config[RTE_MAX_LCORE]; variable
1218 &lcore_config[config->main_lcore].cpuset) != 0) { in rte_eal_init()
1224 &lcore_config[config->main_lcore].cpuset); in rte_eal_init()
1237 if (pipe(lcore_config[i].pipe_main2worker) < 0) in rte_eal_init()
1239 if (pipe(lcore_config[i].pipe_worker2main) < 0) in rte_eal_init()
1242 lcore_config[i].state = WAIT; in rte_eal_init()
1245 ret = pthread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
1253 ret = rte_thread_setname(lcore_config[i].thread_id, in rte_eal_init()
1259 ret = pthread_setaffinity_np(lcore_config[i].thread_id, in rte_eal_init()
1260 sizeof(rte_cpuset_t), &lcore_config[i].cpuset); in rte_eal_init()
/f-stack/dpdk/lib/librte_eal/freebsd/
H A Deal_thread.c42 if (lcore_config[worker_id].state != WAIT) in rte_eal_remote_launch()
45 lcore_config[worker_id].f = f; in rte_eal_remote_launch()
46 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
90 m2w = lcore_config[lcore_id].pipe_main2worker[0]; in eal_thread_loop()
91 w2m = lcore_config[lcore_id].pipe_worker2main[1]; in eal_thread_loop()
113 lcore_config[lcore_id].state = RUNNING; in eal_thread_loop()
122 if (lcore_config[lcore_id].f == NULL) in eal_thread_loop()
126 fct_arg = lcore_config[lcore_id].arg; in eal_thread_loop()
127 ret = lcore_config[lcore_id].f(fct_arg); in eal_thread_loop()
128 lcore_config[lcore_id].ret = ret; in eal_thread_loop()
[all …]
H A Deal.c70 struct lcore_config lcore_config[RTE_MAX_LCORE]; variable
854 &lcore_config[config->main_lcore].cpuset) != 0) { in rte_eal_init()
860 &lcore_config[config->main_lcore].cpuset); in rte_eal_init()
874 if (pipe(lcore_config[i].pipe_main2worker) < 0) in rte_eal_init()
876 if (pipe(lcore_config[i].pipe_worker2main) < 0) in rte_eal_init()
879 lcore_config[i].state = WAIT; in rte_eal_init()
882 ret = pthread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
890 rte_thread_setname(lcore_config[i].thread_id, thread_name); in rte_eal_init()
892 ret = pthread_setaffinity_np(lcore_config[i].thread_id, in rte_eal_init()
893 sizeof(rte_cpuset_t), &lcore_config[i].cpuset); in rte_eal_init()
/f-stack/dpdk/lib/librte_eal/common/
H A Deal_common_launch.c26 if (lcore_config[worker_id].state == WAIT) in rte_eal_wait_lcore()
29 while (lcore_config[worker_id].state != WAIT && in rte_eal_wait_lcore()
30 lcore_config[worker_id].state != FINISHED) in rte_eal_wait_lcore()
36 lcore_config[worker_id].state = WAIT; in rte_eal_wait_lcore()
37 return lcore_config[worker_id].ret; in rte_eal_wait_lcore()
54 if (lcore_config[lcore_id].state != WAIT) in rte_eal_mp_remote_launch()
64 lcore_config[main_lcore].ret = f(arg); in rte_eal_mp_remote_launch()
65 lcore_config[main_lcore].state = FINISHED; in rte_eal_mp_remote_launch()
77 return lcore_config[lcore_id].state; in rte_eal_get_lcore_state()
H A Deal_common_lcore.c43 return lcore_config[lcore_id].core_index; in rte_lcore_index()
58 return lcore_config[lcore_id].core_id; in rte_lcore_to_cpu_id()
63 return lcore_config[lcore_id].cpuset; in rte_lcore_cpuset()
118 return lcore_config[lcore_id].socket_id; in rte_lcore_to_socket_id()
154 lcore_config[lcore_id].core_index = count; in rte_eal_cpu_init()
157 CPU_ZERO(&lcore_config[lcore_id].cpuset); in rte_eal_cpu_init()
165 lcore_config[lcore_id].core_index = -1; in rte_eal_cpu_init()
174 lcore_config[lcore_id].core_role = ROLE_RTE; in rte_eal_cpu_init()
176 lcore_config[lcore_id].socket_id = socket_id; in rte_eal_cpu_init()
179 lcore_id, lcore_config[lcore_id].core_id, in rte_eal_cpu_init()
[all …]
H A Deal_private.h21 struct lcore_config { struct
39 extern struct lcore_config lcore_config[RTE_MAX_LCORE]; argument
H A Deal_common_options.c610 lcore_config[idx].core_role = ROLE_SERVICE; in eal_parse_service_coremask()
621 lcore_config[idx].core_index = -1; in eal_parse_service_coremask()
641 if (lcore_config[idx].core_role == ROLE_SERVICE) in eal_service_cores_parsed()
667 lcore_config[i].core_index = cores[i]; in update_lcore_config()
776 lcore_config[idx].core_role = in eal_parse_service_corelist()
1059 lcore_config[idx].core_index = -1; in eal_parse_lcores()
1060 CPU_ZERO(&lcore_config[idx].cpuset); in eal_parse_lcores()
1121 lcore_config[idx].core_index = count; in eal_parse_lcores()
1133 rte_memcpy(&lcore_config[idx].cpuset, &cpuset, in eal_parse_lcores()
1825 memcpy(cpuset, &lcore_config[rte_get_main_lcore()].cpuset, in compute_ctrl_threads_cpuset()
[all …]
H A Deal_common_thread.c80 lcore_config[lcore_id].socket_id = RTE_PER_LCORE(_socket_id); in thread_update_affinity()
81 memmove(&lcore_config[lcore_id].cpuset, cpusetp, in thread_update_affinity()
H A Drte_service.c109 if (lcore_config[i].core_role == ROLE_SERVICE) { in rte_service_init()
646 lcore_config[lcore].core_role = state; in set_lcore_state()
917 if (lcore_config[i].core_role != ROLE_SERVICE) in rte_service_dump()
/f-stack/dpdk/doc/guides/rel_notes/
H A Drelease_19_11.rst405 * eal: made the ``lcore_config`` struct and global symbol private.
/f-stack/dpdk/doc/guides/prog_guide/
H A Denv_abstraction_layer.rst904 will first index the ``lcore_config`` structure for the calling thread, and