| /dpdk/drivers/net/sfc/ |
| H A D | sfc_service.c | 30 sfc_find_service_lcore(int *socket_id) in sfc_find_service_lcore() argument
53 if (*socket_id == SOCKET_ID_ANY) { in sfc_find_service_lcore()
54 *socket_id = rte_lcore_to_socket_id(lcore_id); in sfc_find_service_lcore()
57 (unsigned int)*socket_id) { in sfc_find_service_lcore()
64 "No service cores reserved at socket %d", *socket_id); in sfc_find_service_lcore()
72 sfc_get_service_lcore(int socket_id) in sfc_get_service_lcore() argument
78 if (socket_id != SOCKET_ID_ANY) { in sfc_get_service_lcore()
79 lcore_id = sfc_service_lcore[socket_id]; in sfc_get_service_lcore()
92 lcore_id = sfc_find_service_lcore(&socket_id); in sfc_get_service_lcore()
94 sfc_service_lcore[socket_id] = lcore_id; in sfc_get_service_lcore()
|
| /dpdk/lib/eal/common/ |
| H A D | eal_common_memalloc.c | 27 int socket_id; member
61 if (!strcmp(r->name, name) && r->socket_id == socket_id) in find_mem_alloc_validator()
258 if (name == NULL || clb == NULL || socket_id < 0) { in eal_memalloc_mem_alloc_validator_register()
272 entry = find_mem_alloc_validator(name, socket_id); in eal_memalloc_mem_alloc_validator_register()
288 entry->socket_id = socket_id; in eal_memalloc_mem_alloc_validator_register()
296 name, socket_id, limit); in eal_memalloc_mem_alloc_validator_register()
309 if (name == NULL || socket_id < 0) { in eal_memalloc_mem_alloc_validator_unregister()
323 entry = find_mem_alloc_validator(name, socket_id); in eal_memalloc_mem_alloc_validator_unregister()
335 name, socket_id); in eal_memalloc_mem_alloc_validator_unregister()
351 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 | 66 int socket_id, unsigned int flags, unsigned int align, in memzone_reserve_aligned_thread_unsafe() argument
134 if ((socket_id != SOCKET_ID_ANY) && socket_id < 0) { in memzone_reserve_aligned_thread_unsafe()
147 if (!rte_eal_has_hugepages() && socket_id < RTE_MAX_NUMA_NODES) in memzone_reserve_aligned_thread_unsafe()
148 socket_id = SOCKET_ID_ANY; in memzone_reserve_aligned_thread_unsafe()
157 mz_addr = malloc_heap_alloc_biggest(NULL, socket_id, flags, in memzone_reserve_aligned_thread_unsafe()
163 mz_addr = malloc_heap_alloc(NULL, requested_len, socket_id, in memzone_reserve_aligned_thread_unsafe()
197 mz->socket_id = elem->msl->socket_id; in memzone_reserve_aligned_thread_unsafe()
216 name, len, socket_id, flags, align, bound); in rte_memzone_reserve_thread_safe()
256 rte_memzone_reserve(const char *name, size_t len, int socket_id, in rte_memzone_reserve() argument
259 return rte_memzone_reserve_thread_safe(name, len, socket_id, in rte_memzone_reserve()
[all …]
|
| H A D | eal_common_lcore.c | 113 return lcore_config[lcore_id].socket_id; in rte_lcore_to_socket_id()
141 unsigned int socket_id, prev_socket_id; in rte_eal_cpu_init() local
155 socket_id = eal_cpu_socket_id(lcore_id); in rte_eal_cpu_init()
156 lcore_to_socket_id[lcore_id] = socket_id; in rte_eal_cpu_init()
171 lcore_config[lcore_id].socket_id = socket_id; in rte_eal_cpu_init()
175 lcore_config[lcore_id].socket_id); in rte_eal_cpu_init()
200 socket_id = lcore_to_socket_id[lcore_id]; in rte_eal_cpu_init()
201 if (socket_id != prev_socket_id) in rte_eal_cpu_init()
203 socket_id; in rte_eal_cpu_init()
204 prev_socket_id = socket_id; in rte_eal_cpu_init()
|
| H A D | malloc_heap.c | 80 if (heap->socket_id == socket_id) in malloc_socket_to_heap_id()
139 msl->socket_id); in malloc_add_seg()
650 int socket_id; in malloc_heap_alloc_on_heap_id() local
679 if (socket_id < 0) in malloc_heap_alloc_on_heap_id()
687 if (socket_id < 0) in malloc_heap_alloc_on_heap_id()
711 return socket_id; in malloc_get_numa_socket()
717 return socket_id; in malloc_get_numa_socket()
1175 unsigned int socket_id) in malloc_heap_create_external_seg() argument
1221 ms->socket_id = socket_id; in malloc_heap_create_external_seg()
1227 msl->socket_id = socket_id; in malloc_heap_create_external_seg()
[all …]
|
| /dpdk/lib/eal/windows/ |
| H A D | eal_lcore.c | 21 uint8_t socket_id; member
116 unsigned int socket_id; in eal_create_lcore_map() local
125 for (socket_id = 0; socket_id < cpu_map.socket_count; socket_id++) in eal_create_lcore_map()
126 if (cpu_map.sockets[socket_id].node_id == node_id) in eal_create_lcore_map()
129 if (socket_id == cpu_map.socket_count) { in eal_create_lcore_map()
130 if (socket_id == RTE_DIM(cpu_map.sockets)) in eal_create_lcore_map()
133 cpu_map.sockets[socket_id].node_id = node_id; in eal_create_lcore_map()
145 lcore->socket_id = socket_id; in eal_create_lcore_map()
232 return cpu_map.lcores[lcore_id].socket_id; in eal_cpu_socket_id()
242 eal_socket_numa_node(unsigned int socket_id) in eal_socket_numa_node() argument
[all …]
|
| H A D | eal_hugepages.c | 63 unsigned int socket_id; in hugepage_info_init() local
80 for (socket_id = 0; socket_id < rte_socket_count(); socket_id++) { in hugepage_info_init()
84 numa_node = eal_socket_numa_node(socket_id); in hugepage_info_init()
91 hpi->num_pages[socket_id] = bytes / hpi->hugepage_sz; in hugepage_info_init()
94 hpi->num_pages[socket_id], hpi->hugepage_sz, socket_id); in hugepage_info_init()
|
| H A D | eal_memalloc.c | 35 alloc_seg(struct rte_memseg *ms, void *requested_addr, int socket_id, in alloc_seg() argument
49 (ms->socket_id == socket_id) && in alloc_seg()
57 ms->len, ms->socket_id); in alloc_seg()
62 numa_node = eal_socket_numa_node(socket_id); in alloc_seg()
67 addr = eal_mem_alloc_socket(alloc_sz, socket_id); in alloc_seg()
70 "on socket %d\n", alloc_sz, socket_id); in alloc_seg()
75 addr = eal_mem_commit(requested_addr, alloc_sz, socket_id); in alloc_seg()
91 requested_addr, alloc_sz, socket_id); in alloc_seg()
124 numa_node, socket_id, page->Node); in alloc_seg()
134 ms->socket_id = socket_id; in alloc_seg()
[all …]
|
| /dpdk/app/test-crypto-perf/ |
| H A D | main.c | 79 socket_id); in create_asym_op_pool_socket()
84 mp_name, socket_id); in create_asym_op_pool_socket()
107 NULL, socket_id, in fill_session_pool_socket()
112 mp_name, socket_id); in fill_session_pool_socket()
117 mp_name, socket_id); in fill_session_pool_socket()
124 "sess_mp_%u", socket_id); in fill_session_pool_socket()
131 mp_name, socket_id); in fill_session_pool_socket()
136 mp_name, socket_id); in fill_session_pool_socket()
222 socket_id = 0; in cperf_initialize_cryptodev()
242 .socket_id = socket_id, in cperf_initialize_cryptodev()
[all …]
|
| /dpdk/lib/efd/ |
| H A D | rte_efd.c | 500 uint8_t socket_id; in rte_efd_create() local
601 for (socket_id = 0; socket_id < RTE_MAX_NUMA_NODES; socket_id++) in rte_efd_create()
602 table->chunks[socket_id] = NULL; in rte_efd_create()
612 for (socket_id = 0; socket_id < RTE_MAX_NUMA_NODES; socket_id++) { in rte_efd_create()
618 table->chunks[socket_id] = in rte_efd_create()
623 socket_id); in rte_efd_create()
628 socket_id); in rte_efd_create()
637 socket_id); in rte_efd_create()
746 uint8_t socket_id; in rte_efd_free() local
753 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,
|
| /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-secgw.c | 2489 socket_id); in session_pool_init()
2525 socket_id); in session_priv_pool_init()
2528 socket_id); in session_priv_pool_init()
2564 socket_id); in pool_init()
3383 pool_init(&socket_ctx[socket_id], socket_id, in main()
3387 pool_init(&socket_ctx[socket_id], socket_id, 0, in main()
3395 session_priv_pool_init(&socket_ctx[socket_id], socket_id, in main()
3469 sa_init(&socket_ctx[socket_id], socket_id); in main()
3470 sp4_init(&socket_ctx[socket_id], socket_id); in main()
3471 sp6_init(&socket_ctx[socket_id], socket_id); in main()
[all …]
|
| /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()
|
| /dpdk/examples/ip_pipeline/ |
| H A D | cryptodev.c | 56 uint32_t socket_id; in cryptodev_create() local
87 socket_id = rte_cryptodev_socket_id(dev_id); in cryptodev_create()
93 dev_conf.socket_id = socket_id; in cryptodev_create()
104 &queue_conf, socket_id); in cryptodev_create()
129 socket_id); in cryptodev_create()
144 socket_id, in cryptodev_create()
|
| /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()
|
| /dpdk/lib/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 …]
|
| H A D | rte_port_source_sink.c | 54 int socket_id) in pcap_source_load() argument
89 (sizeof(*port->pkt_len) * n_pkts), 0, socket_id); in pcap_source_load()
103 (sizeof(*port->pkts) * n_pkts), 0, socket_id); in pcap_source_load()
129 total_buff_len, 0, socket_id); in pcap_source_load()
173 #define PCAP_SOURCE_LOAD(port, file_name, n_bytes, socket_id) \ argument
174 pcap_source_load(port, file_name, n_bytes, socket_id)
194 rte_port_source_create(void *params, int socket_id) in rte_port_source_create() argument
208 RTE_CACHE_LINE_SIZE, socket_id); in rte_port_source_create()
219 p->n_bytes_per_pkt, socket_id); in rte_port_source_create()
453 rte_port_sink_create(void *params, int socket_id) in rte_port_sink_create() argument
[all …]
|
| /dpdk/lib/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,
|
| /dpdk/examples/server_node_efd/server/ |
| H A D | init.c | 174 unsigned int socket_id; in init_shm_rings() local
186 socket_id = rte_socket_id(); in init_shm_rings()
189 ringsize, socket_id, in init_shm_rings()
207 uint8_t socket_id = rte_socket_id(); in create_efd_table() local
211 1 << socket_id, socket_id); in create_efd_table()
223 uint8_t socket_id = rte_socket_id(); in populate_efd_table() local
231 ret = rte_efd_update(efd_table, socket_id, in populate_efd_table()
|
| /dpdk/drivers/compress/qat/ |
| H A D | qat_comp_pmd.c | 16 int socket_id; member
99 uint32_t max_inflight_ops, int socket_id) in qat_comp_qp_setup() argument
131 qat_qp_conf.socket_id = socket_id; in qat_comp_qp_setup()
156 64, dev->data->socket_id); in qat_comp_qp_setup()
162 64, dev->data->socket_id); in qat_comp_qp_setup()
181 cookie->socket_id = dev->data->socket_id; in qat_comp_qp_setup()
236 comp_dev->compressdev->data->socket_id, in qat_comp_setup_inter_buffers()
382 info->socket_id, in qat_comp_stream_init()
424 int socket_id, in qat_comp_create_stream_pool() argument
450 .socket_id = socket_id, in qat_comp_create_stream_pool()
[all …]
|
| /dpdk/drivers/compress/isal/ |
| H A D | isal_compress_pmd_ops.c | 76 config->socket_id, /* socket id */ in isal_comp_pmd_config()
195 unsigned int ring_size, int socket_id) in isal_comp_pmd_qp_create_processed_pkts_ring() argument
215 return rte_ring_create(qp->name, ring_size, socket_id, in isal_comp_pmd_qp_create_processed_pkts_ring()
237 uint32_t max_inflight_ops, int socket_id) in isal_comp_pmd_qp_setup() argument
248 RTE_CACHE_LINE_SIZE, socket_id); in isal_comp_pmd_qp_setup()
257 socket_id); in isal_comp_pmd_qp_setup()
265 socket_id); in isal_comp_pmd_qp_setup()
274 socket_id); in isal_comp_pmd_qp_setup()
291 max_inflight_ops, socket_id); in isal_comp_pmd_qp_setup()
|
| /dpdk/lib/eal/linux/ |
| H A D | eal_memory.c | 413 int socket_id; in find_numasocket() local
471 hugepg_tbl[i].socket_id = socket_id; in find_numasocket()
666 int socket_id; local
672 socket_id = hugepages[seg_start].socket_id;
686 if (msl->socket_id != socket_id)
773 ms->socket_id = hfile->socket_id;
1002 else if (cur->socket_id != prev->socket_id)
1332 int socket = tmp_hp[i].socket_id;
1672 unsigned int socket_id, i; local
1768 socket_id);
[all …]
|
| /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()
504 uint8_t socket_id, uint8_t isr_support) in virtual_ethdev_create() argument
518 pci_dev = rte_zmalloc_socket(name, sizeof(*pci_dev), 0, socket_id); in virtual_ethdev_create()
522 pci_drv = rte_zmalloc_socket(name, sizeof(*pci_drv), 0, socket_id); in virtual_ethdev_create()
526 id_table = rte_zmalloc_socket(name, sizeof(*id_table), 0, socket_id); in virtual_ethdev_create()
[all …]
|