| /f-stack/dpdk/lib/librte_eal/windows/ |
| H A D | eal_lcore.c | 22 uint8_t socket_id; member
89 unsigned int i, socket_id; in eal_create_cpu_map() local
96 for (socket_id = 0; socket_id < cpu_map.socket_count; in eal_create_cpu_map()
97 socket_id++) { in eal_create_cpu_map()
102 if (socket_id == cpu_map.socket_count) { in eal_create_cpu_map()
103 if (socket_id == RTE_DIM(cpu_map.sockets)) { in eal_create_cpu_map()
108 cpu_map.sockets[socket_id].node_id = node_id; in eal_create_cpu_map()
122 lcore->socket_id = socket_id; in eal_create_cpu_map()
153 return cpu_map.lcores[lcore_id].socket_id; in eal_cpu_socket_id()
163 eal_socket_numa_node(unsigned int socket_id) in eal_socket_numa_node() argument
[all …]
|
| H A D | eal_hugepages.c | 60 unsigned int socket_id; in hugepage_info_init() local
77 for (socket_id = 0; socket_id < rte_socket_count(); socket_id++) { in hugepage_info_init()
81 numa_node = eal_socket_numa_node(socket_id); in hugepage_info_init()
88 hpi->num_pages[socket_id] = bytes / hpi->hugepage_sz; in hugepage_info_init()
91 hpi->num_pages[socket_id], hpi->hugepage_sz, socket_id); in hugepage_info_init()
|
| H A D | eal_memalloc.c | 36 alloc_seg(struct rte_memseg *ms, void *requested_addr, int socket_id, in alloc_seg() argument
50 (ms->socket_id == socket_id) && in alloc_seg()
58 ms->len, ms->socket_id); in alloc_seg()
63 numa_node = eal_socket_numa_node(socket_id); in alloc_seg()
68 addr = eal_mem_alloc_socket(alloc_sz, socket_id); in alloc_seg()
71 "on socket %d\n", alloc_sz, socket_id); in alloc_seg()
76 addr = eal_mem_commit(requested_addr, alloc_sz, socket_id); in alloc_seg()
92 requested_addr, alloc_sz, socket_id); in alloc_seg()
130 numa_node, socket_id, page->Node); in alloc_seg()
140 ms->socket_id = socket_id; in alloc_seg()
[all …]
|
| H A D | eal_windows.h | 56 unsigned int eal_socket_numa_node(unsigned int socket_id);
94 void *eal_mem_alloc_socket(size_t size, int socket_id);
110 void *eal_mem_commit(void *requested_addr, size_t size, int socket_id);
|
| /f-stack/dpdk/lib/librte_eal/common/ |
| H A D | eal_common_memalloc.c | 30 int socket_id; member
64 if (!strcmp(r->name, name) && r->socket_id == socket_id) in find_mem_alloc_validator()
261 if (name == NULL || clb == NULL || socket_id < 0) { in eal_memalloc_mem_alloc_validator_register()
275 entry = find_mem_alloc_validator(name, socket_id); in eal_memalloc_mem_alloc_validator_register()
291 entry->socket_id = socket_id; in eal_memalloc_mem_alloc_validator_register()
299 name, socket_id, limit); in eal_memalloc_mem_alloc_validator_register()
312 if (name == NULL || socket_id < 0) { in eal_memalloc_mem_alloc_validator_unregister()
326 entry = find_mem_alloc_validator(name, socket_id); in eal_memalloc_mem_alloc_validator_unregister()
338 name, socket_id); in eal_memalloc_mem_alloc_validator_unregister()
354 if (entry->socket_id != socket_id || entry->limit > new_len) in eal_memalloc_mem_alloc_validate()
[all …]
|
| H A D | eal_common_dynmem.c | 25 int socket_id; in eal_dynmem_memseg_lists_init() member
101 memtypes[cur_type].socket_id = socket_id; in eal_dynmem_memseg_lists_init()
105 socket_id, hugepage_sz); in eal_dynmem_memseg_lists_init()
134 int socket_id; in eal_dynmem_memseg_lists_init() local
137 socket_id = type->socket_id; in eal_dynmem_memseg_lists_init()
189 socket_id, cur_seglist, true)) in eal_dynmem_memseg_lists_init()
220 RTE_SET_USED(socket_id); in limits_callback()
231 int hp_sz_idx, socket_id; in eal_dynmem_hugepage_init() local
278 for (socket_id = 0; socket_id < RTE_MAX_NUMA_NODES; in eal_dynmem_hugepage_init()
279 socket_id++) { in eal_dynmem_hugepage_init()
[all …]
|
| H A D | eal_common_memzone.c | 58 int socket_id, unsigned int flags, unsigned int align, in memzone_reserve_aligned_thread_unsafe() argument
126 if ((socket_id != SOCKET_ID_ANY) && socket_id < 0) { in memzone_reserve_aligned_thread_unsafe()
134 if (!rte_eal_has_hugepages() && socket_id < RTE_MAX_NUMA_NODES) in memzone_reserve_aligned_thread_unsafe()
135 socket_id = SOCKET_ID_ANY; in memzone_reserve_aligned_thread_unsafe()
144 mz_addr = malloc_heap_alloc_biggest(NULL, socket_id, flags, in memzone_reserve_aligned_thread_unsafe()
150 mz_addr = malloc_heap_alloc(NULL, requested_len, socket_id, in memzone_reserve_aligned_thread_unsafe()
184 mz->socket_id = elem->msl->socket_id; in memzone_reserve_aligned_thread_unsafe()
203 name, len, socket_id, flags, align, bound); in rte_memzone_reserve_thread_safe()
243 rte_memzone_reserve(const char *name, size_t len, int socket_id, in rte_memzone_reserve() argument
246 return rte_memzone_reserve_thread_safe(name, len, socket_id, in rte_memzone_reserve()
[all …]
|
| H A D | malloc_heap.h | 31 unsigned int socket_id; member
43 unsigned socket_id = rte_socket_id(); in malloc_get_numa_socket() local
45 if (socket_id == (unsigned)SOCKET_ID_ANY) in malloc_get_numa_socket()
48 return socket_id; in malloc_get_numa_socket()
68 unsigned int socket_id);
98 malloc_socket_to_heap_id(unsigned int socket_id);
|
| H A D | eal_common_thread.c | 41 int socket_id = SOCKET_ID_ANY; in eal_cpuset_socket_id() local
51 if (socket_id == SOCKET_ID_ANY) in eal_cpuset_socket_id()
52 socket_id = eal_cpu_socket_id(cpu); in eal_cpuset_socket_id()
55 if (socket_id != sid) { in eal_cpuset_socket_id()
56 socket_id = SOCKET_ID_ANY; in eal_cpuset_socket_id()
62 return socket_id; in eal_cpuset_socket_id()
80 lcore_config[lcore_id].socket_id = RTE_PER_LCORE(_socket_id); in thread_update_affinity()
|
| H A D | eal_common_lcore.c | 118 return lcore_config[lcore_id].socket_id; in rte_lcore_to_socket_id()
146 unsigned int socket_id, prev_socket_id; in rte_eal_cpu_init() local
160 socket_id = eal_cpu_socket_id(lcore_id); in rte_eal_cpu_init()
161 lcore_to_socket_id[lcore_id] = socket_id; in rte_eal_cpu_init()
176 lcore_config[lcore_id].socket_id = socket_id; in rte_eal_cpu_init()
180 lcore_config[lcore_id].socket_id); in rte_eal_cpu_init()
205 socket_id = lcore_to_socket_id[lcore_id]; in rte_eal_cpu_init()
206 if (socket_id != prev_socket_id) in rte_eal_cpu_init()
208 socket_id; in rte_eal_cpu_init()
209 prev_socket_id = socket_id; in rte_eal_cpu_init()
|
| /f-stack/dpdk/lib/librte_efd/ |
| H A D | rte_efd.c | 503 uint8_t socket_id; in rte_efd_create() local
604 for (socket_id = 0; socket_id < RTE_MAX_NUMA_NODES; socket_id++) in rte_efd_create()
605 table->chunks[socket_id] = NULL; in rte_efd_create()
615 for (socket_id = 0; socket_id < RTE_MAX_NUMA_NODES; socket_id++) { in rte_efd_create()
621 table->chunks[socket_id] = in rte_efd_create()
626 socket_id); in rte_efd_create()
631 socket_id); in rte_efd_create()
640 socket_id); in rte_efd_create()
749 uint8_t socket_id; in rte_efd_free() local
756 for (socket_id = 0; socket_id < RTE_MAX_NUMA_NODES; socket_id++) in rte_efd_free()
[all …]
|
| H A D | rte_efd.h | 200 rte_efd_update(struct rte_efd_table *table, unsigned int socket_id,
222 rte_efd_delete(struct rte_efd_table *table, unsigned int socket_id,
246 rte_efd_lookup(const struct rte_efd_table *table, unsigned int socket_id,
271 rte_efd_lookup_bulk(const struct rte_efd_table *table, unsigned int socket_id,
|
| /f-stack/dpdk/app/test-crypto-perf/ |
| H A D | main.c | 78 "priv_sess_mp_%u", socket_id); in fill_session_pool_socket()
84 NULL, socket_id, in fill_session_pool_socket()
89 mp_name, socket_id); in fill_session_pool_socket()
94 mp_name, socket_id); in fill_session_pool_socket()
101 "sess_mp_%u", socket_id); in fill_session_pool_socket()
104 nb_sessions, 0, 0, 0, socket_id); in fill_session_pool_socket()
108 mp_name, socket_id); in fill_session_pool_socket()
113 mp_name, socket_id); in fill_session_pool_socket()
199 socket_id = 0; in cperf_initialize_cryptodev()
212 .socket_id = socket_id, in cperf_initialize_cryptodev()
[all …]
|
| /f-stack/dpdk/examples/ipsec-secgw/ |
| H A D | rt.c | 124 rt_init(struct socket_ctx *ctx, int32_t socket_id) in rt_init() argument
140 "already initialized\n", socket_id); in rt_init()
144 "already initialized\n", socket_id); in rt_init()
153 snprintf(name, sizeof(name), "%s_%u", "rt_ip4", socket_id); in rt_init()
156 lpm = rte_lpm_create(name, socket_id, &conf); in rt_init()
159 "on socket %d\n", name, socket_id); in rt_init()
167 "LPM table on socket %d\n", i, name, socket_id); in rt_init()
175 snprintf(name, sizeof(name), "%s_%u", "rt_ip6", socket_id); in rt_init()
178 lpm6 = rte_lpm6_create(name, socket_id, &conf6); in rt_init()
181 "on socket %d\n", name, socket_id); in rt_init()
[all …]
|
| H A D | ipsec_worker.c | 406 int32_t socket_id; in ipsec_wrkr_non_burst_int_port_drv_mode() local
419 socket_id = rte_lcore_to_socket_id(lcore_id); in ipsec_wrkr_non_burst_int_port_drv_mode()
503 int32_t socket_id; in ipsec_wrkr_non_burst_int_port_app_mode() local
518 socket_id = rte_lcore_to_socket_id(lcore_id); in ipsec_wrkr_non_burst_int_port_app_mode()
521 lconf.rt.rt4_ctx = socket_ctx[socket_id].rt_ip4; in ipsec_wrkr_non_burst_int_port_app_mode()
522 lconf.rt.rt6_ctx = socket_ctx[socket_id].rt_ip6; in ipsec_wrkr_non_burst_int_port_app_mode()
523 lconf.inbound.sp4_ctx = socket_ctx[socket_id].sp_ip4_in; in ipsec_wrkr_non_burst_int_port_app_mode()
525 lconf.inbound.sa_ctx = socket_ctx[socket_id].sa_in; in ipsec_wrkr_non_burst_int_port_app_mode()
528 socket_ctx[socket_id].session_priv_pool; in ipsec_wrkr_non_burst_int_port_app_mode()
531 lconf.outbound.sa_ctx = socket_ctx[socket_id].sa_out; in ipsec_wrkr_non_burst_int_port_app_mode()
[all …]
|
| H A D | ipsec-secgw.c | 2246 socket_id = 0; in port_init()
2281 socket_id); in port_init()
2357 socket_id); in session_pool_init()
2393 socket_id); in session_priv_pool_init()
2396 socket_id); in session_priv_pool_init()
2423 socket_id); in pool_init()
2900 session_priv_pool_init(&socket_ctx[socket_id], socket_id, in main()
2970 sa_init(&socket_ctx[socket_id], socket_id); in main()
2971 sp4_init(&socket_ctx[socket_id], socket_id); in main()
2972 sp6_init(&socket_ctx[socket_id], socket_id); in main()
[all …]
|
| /f-stack/dpdk/drivers/crypto/nitrox/ |
| H A D | nitrox_qp.c | 17 const char *dev_name, uint8_t instr_size, int socket_id) in nitrox_setup_cmdq() argument
25 mz = rte_memzone_reserve_aligned(mz_name, cmdq_size, socket_id, in nitrox_setup_cmdq()
47 nitrox_setup_ridq(struct nitrox_qp *qp, int socket_id) in nitrox_setup_ridq() argument
53 socket_id); in nitrox_setup_ridq()
72 uint32_t nb_descriptors, uint8_t instr_size, int socket_id) in nitrox_qp_setup() argument
89 err = nitrox_setup_cmdq(qp, bar_addr, dev_name, instr_size, socket_id); in nitrox_qp_setup()
93 err = nitrox_setup_ridq(qp, socket_id); in nitrox_qp_setup()
|
| /f-stack/dpdk/examples/ip_pipeline/ |
| H A D | cryptodev.c | 57 uint32_t socket_id; in cryptodev_create() local
88 socket_id = rte_cryptodev_socket_id(dev_id); in cryptodev_create()
94 dev_conf.socket_id = socket_id; in cryptodev_create()
105 &queue_conf, socket_id); in cryptodev_create()
130 socket_id); in cryptodev_create()
145 socket_id, in cryptodev_create()
|
| /f-stack/dpdk/drivers/net/softnic/ |
| H A D | rte_eth_softnic_cryptodev.c | 65 uint32_t socket_id; in softnic_cryptodev_create() local
96 socket_id = rte_cryptodev_socket_id(dev_id); in softnic_cryptodev_create()
104 dev_conf.socket_id = socket_id; in softnic_cryptodev_create()
114 &queue_conf, socket_id); in softnic_cryptodev_create()
138 socket_id); in softnic_cryptodev_create()
152 socket_id, in softnic_cryptodev_create()
|
| /f-stack/dpdk/lib/librte_eal/include/ |
| H A D | rte_memzone.h | 64 int32_t socket_id; /**< NUMA socket ID. */ member
128 size_t len, int socket_id,
194 size_t len, int socket_id,
266 size_t len, int socket_id,
|
| /f-stack/dpdk/lib/librte_port/ |
| H A D | rte_port_ring.c | 37 rte_port_ring_reader_create_internal(void *params, int socket_id, in rte_port_ring_reader_create_internal() argument
55 RTE_CACHE_LINE_SIZE, socket_id); in rte_port_ring_reader_create_internal()
68 rte_port_ring_reader_create(void *params, int socket_id) in rte_port_ring_reader_create() argument
70 return rte_port_ring_reader_create_internal(params, socket_id, 0); in rte_port_ring_reader_create()
74 rte_port_ring_multi_reader_create(void *params, int socket_id) in rte_port_ring_multi_reader_create() argument
76 return rte_port_ring_reader_create_internal(params, socket_id, 1); in rte_port_ring_multi_reader_create()
164 rte_port_ring_writer_create_internal(void *params, int socket_id, in rte_port_ring_writer_create_internal() argument
183 RTE_CACHE_LINE_SIZE, socket_id); in rte_port_ring_writer_create_internal()
200 rte_port_ring_writer_create(void *params, int socket_id) in rte_port_ring_writer_create() argument
206 rte_port_ring_multi_writer_create(void *params, int socket_id) in rte_port_ring_multi_writer_create() argument
[all …]
|
| /f-stack/dpdk/examples/server_node_efd/server/ |
| H A D | init.c | 175 unsigned int socket_id; in init_shm_rings() local
187 socket_id = rte_socket_id(); in init_shm_rings()
190 ringsize, socket_id, in init_shm_rings()
206 uint8_t socket_id = rte_socket_id(); in create_efd_table() local
210 1 << socket_id, socket_id); in create_efd_table()
222 uint8_t socket_id = rte_socket_id(); in populate_efd_table() local
230 ret = rte_efd_update(efd_table, socket_id, in populate_efd_table()
|
| /f-stack/dpdk/drivers/compress/isal/ |
| H A D | isal_compress_pmd_ops.c | 75 config->socket_id, /* socket id */ in isal_comp_pmd_config()
189 unsigned int ring_size, int socket_id) in isal_comp_pmd_qp_create_processed_pkts_ring() argument
209 return rte_ring_create(qp->name, ring_size, socket_id, in isal_comp_pmd_qp_create_processed_pkts_ring()
231 uint32_t max_inflight_ops, int socket_id) in isal_comp_pmd_qp_setup() argument
242 RTE_CACHE_LINE_SIZE, socket_id); in isal_comp_pmd_qp_setup()
251 socket_id); in isal_comp_pmd_qp_setup()
259 socket_id); in isal_comp_pmd_qp_setup()
268 socket_id); in isal_comp_pmd_qp_setup()
285 max_inflight_ops, socket_id); in isal_comp_pmd_qp_setup()
|
| /f-stack/dpdk/lib/librte_eal/linux/ |
| H A D | eal_memory.c | 422 int socket_id; in find_numasocket() local
480 hugepg_tbl[i].socket_id = socket_id; in find_numasocket()
675 int socket_id; local
681 socket_id = hugepages[seg_start].socket_id;
695 if (msl->socket_id != socket_id)
782 ms->socket_id = hfile->socket_id;
1011 else if (cur->socket_id != prev->socket_id)
1341 int socket = tmp_hp[i].socket_id;
1681 unsigned int socket_id, i; local
1777 socket_id);
[all …]
|
| /f-stack/dpdk/app/test/ |
| H A D | virtual_pmd.c | 105 unsigned int socket_id, in virtual_ethdev_rx_queue_setup_success() argument
112 sizeof(struct virtual_ethdev_queue), 0, socket_id); in virtual_ethdev_rx_queue_setup_success()
128 unsigned int socket_id __rte_unused, in virtual_ethdev_rx_queue_setup_fail()
138 unsigned int socket_id, in virtual_ethdev_tx_queue_setup_success() argument
144 sizeof(struct virtual_ethdev_queue), 0, socket_id); in virtual_ethdev_tx_queue_setup_success()
160 unsigned int socket_id __rte_unused, in virtual_ethdev_tx_queue_setup_fail()
512 uint8_t socket_id, uint8_t isr_support) in virtual_ethdev_create() argument
526 pci_dev = rte_zmalloc_socket(name, sizeof(*pci_dev), 0, socket_id); in virtual_ethdev_create()
530 pci_drv = rte_zmalloc_socket(name, sizeof(*pci_drv), 0, socket_id); in virtual_ethdev_create()
534 id_table = rte_zmalloc_socket(name, sizeof(*id_table), 0, socket_id); in virtual_ethdev_create()
[all …]
|