Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 159) sorted by relevance

1234567

/dpdk/lib/eal/common/
H A Deal_common_dynmem.c353 get_socket_mem_size(int socket) in get_socket_mem_size() argument
362 size += hpi->hugepage_sz * hpi->num_pages[socket]; in get_socket_mem_size()
373 unsigned int socket, j, i = 0; in eal_dynmem_calc_num_pages_per_socket() local
404 for (socket = 0; socket < RTE_MAX_NUMA_NODES && total_size != 0; in eal_dynmem_calc_num_pages_per_socket()
405 socket++) { in eal_dynmem_calc_num_pages_per_socket()
409 cpu_per_socket[socket] / rte_lcore_count(); in eal_dynmem_calc_num_pages_per_socket()
413 default_size, get_socket_mem_size(socket)); in eal_dynmem_calc_num_pages_per_socket()
416 memory[socket] = default_size; in eal_dynmem_calc_num_pages_per_socket()
424 for (socket = 0; socket < RTE_MAX_NUMA_NODES && total_size != 0; in eal_dynmem_calc_num_pages_per_socket()
425 socket++) { in eal_dynmem_calc_num_pages_per_socket()
[all …]
H A Drte_malloc.c109 rte_zmalloc_socket(const char *type, size_t size, unsigned align, int socket) in rte_zmalloc_socket() argument
111 void *ptr = rte_malloc_socket(type, size, align, socket); in rte_zmalloc_socket()
130 rte_eal_trace_mem_zmalloc(type, size, align, socket, ptr); in rte_zmalloc_socket()
147 rte_calloc_socket(const char *type, size_t num, size_t size, unsigned align, int socket) in rte_calloc_socket() argument
149 return rte_zmalloc_socket(type, num * size, align, socket); in rte_calloc_socket()
165 rte_realloc_socket(void *ptr, size_t size, unsigned int align, int socket) in rte_realloc_socket() argument
170 return rte_malloc_socket(NULL, size, align, socket); in rte_realloc_socket()
185 if ((socket == SOCKET_ID_ANY || in rte_realloc_socket()
186 (unsigned int)socket == elem->heap->socket_id) && in rte_realloc_socket()
189 rte_eal_trace_mem_realloc(size, align, socket, ptr); in rte_realloc_socket()
[all …]
H A Dmalloc_heap.c294 int socket, unsigned int flags, size_t align, size_t bound, in alloc_pages_on_heap() argument
308 if (eal_memalloc_mem_alloc_validate(socket, in alloc_pages_on_heap()
315 socket, true); in alloc_pages_on_heap()
394 size_t elt_size, int socket, unsigned int flags, size_t align, in try_expand_heap_primary() argument
414 elem = alloc_pages_on_heap(heap, pg_sz, elt_size, socket, flags, align, in try_expand_heap_primary()
443 socket, alloc_sz >> 20ULL); in try_expand_heap_primary()
465 size_t elt_size, int socket, unsigned int flags, size_t align, in try_expand_heap_secondary() argument
481 req.alloc_req.socket = socket; in try_expand_heap_secondary()
497 int socket, unsigned int flags, size_t align, size_t bound, in try_expand_heap() argument
505 ret = try_expand_heap_primary(heap, pg_sz, elt_size, socket, in try_expand_heap()
[all …]
/dpdk/usertools/
H A Ddpdk-telemetry-client.py5 import socket
24 self.send_fd = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
25 self.recv_fd = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
41 self.socket = Socket()
67 self.socket.recv_fd.bind(self.file_path)
68 except socket.error as msg:
70 self.socket.recv_fd.settimeout(2)
71 self.socket.send_fd.connect(self.run_path)
73 self.socket.send_fd.sendall(JSON.encode())
75 self.socket.recv_fd.listen(1)
[all …]
H A Dcpu_layout.py77 socket = int(read_sysfs(f"{lcore_base}/topology/physical_package_id"))
81 sockets_s.add(socket)
82 key = (socket, core)
102 # track NUMA changes per socket
103 prev_numa: T.Dict[int, T.Optional[int]] = {socket: None for socket in sockets}
21 socket = int(fd.read()) global() variable
/dpdk/lib/node/
H A Dudp4_input.c61 uint8_t socket; in rte_node_udp4_dst_port_add() local
64 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in rte_node_udp4_dst_port_add()
65 if (!udp4_input_nm.hash_tbl[socket]) in rte_node_udp4_dst_port_add()
68 rc = rte_hash_add_key_data(udp4_input_nm.hash_tbl[socket], in rte_node_udp4_dst_port_add()
72 socket, rc); in rte_node_udp4_dst_port_add()
97 setup_udp4_dstprt_hash(struct udp4_input_node_main *nm, int socket) in setup_udp4_dstprt_hash() argument
103 if (nm->hash_tbl[socket]) in setup_udp4_dstprt_hash()
107 snprintf(s, sizeof(s), "UDP4_INPUT_HASH_%d", socket); in setup_udp4_dstprt_hash()
109 hash_udp4->socket_id = socket; in setup_udp4_dstprt_hash()
110 nm->hash_tbl[socket] = rte_hash_create(hash_udp4); in setup_udp4_dstprt_hash()
[all …]
H A Dip4_lookup.c6 #include <sys/socket.h>
128 uint8_t socket; in rte_node_ip4_route_add()
139 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in rte_node_ip4_route_add()
140 if (!ip4_lookup_nm.lpm_tbl[socket]) in rte_node_ip4_route_add()
143 ret = rte_lpm_add(ip4_lookup_nm.lpm_tbl[socket], in rte_node_ip4_route_add()
148 abuf, depth, val, socket, ret); in rte_node_ip4_route_add()
157 setup_lpm(struct ip4_lookup_node_main *nm, int socket) in setup_lpm()
162 /* One LPM table per socket */ in setup_lpm()
127 uint8_t socket; rte_node_ip4_route_add() local
156 setup_lpm(struct ip4_lookup_node_main * nm,int socket) setup_lpm() argument
180 uint16_t socket, lcore_id; ip4_lookup_node_init() local
[all...]
H A Dip6_lookup.c6 #include <sys/socket.h>
265 uint8_t socket; in rte_node_ip6_route_add()
275 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in rte_node_ip6_route_add()
276 if (!ip6_lookup_nm.lpm_tbl[socket]) in rte_node_ip6_route_add()
279 ret = rte_lpm6_add(ip6_lookup_nm.lpm_tbl[socket], ip, depth, val); in rte_node_ip6_route_add()
284 abuf, depth, val, socket, ret); in rte_node_ip6_route_add()
293 setup_lpm6(struct ip6_lookup_node_main *nm, int socket) in rte_node_ip6_route_add()
298 /* One LPM table per socket */ in setup_lpm6()
266 uint8_t socket; rte_node_ip6_route_add() local
296 setup_lpm6(struct ip6_lookup_node_main * nm,int socket) setup_lpm6() argument
320 uint16_t socket, lcore_id; ip6_lookup_node_init() local
[all...]
/dpdk/app/test/
H A Dtest_malloc.c33 is_mem_on_socket(int32_t socket);
270 int socket = 0; in test_multi_alloc_statistics() local
279 rte_malloc_get_socket_stats(socket, &pre_stats); in test_multi_alloc_statistics()
281 void *dummy = rte_malloc_socket(NULL, RTE_CACHE_LINE_SIZE, 0, socket); in test_multi_alloc_statistics()
285 rte_malloc_get_socket_stats(socket, &post_stats); in test_multi_alloc_statistics()
294 rte_malloc_get_socket_stats(socket, &pre_stats); in test_multi_alloc_statistics()
296 void *p1 = rte_malloc_socket("stats", size , align, socket); in test_multi_alloc_statistics()
302 rte_malloc_get_socket_stats(socket,&post_stats); in test_multi_alloc_statistics()
316 rte_malloc_get_socket_stats(socket,&pre_stats); in test_multi_alloc_statistics()
317 void *p2 = rte_malloc_socket("add", size ,align, socket); in test_multi_alloc_statistics()
[all …]
H A Dtest_stack_perf.c36 unsigned int socket[2]; in get_two_hyperthreads() local
46 socket[0] = rte_lcore_to_socket_id(id[0]); in get_two_hyperthreads()
47 socket[1] = rte_lcore_to_socket_id(id[1]); in get_two_hyperthreads()
48 if ((core[0] == core[1]) && (socket[0] == socket[1])) { in get_two_hyperthreads()
62 unsigned int socket[2]; in get_two_cores() local
72 socket[0] = rte_lcore_to_socket_id(id[0]); in get_two_cores()
73 socket[1] = rte_lcore_to_socket_id(id[1]); in get_two_cores()
74 if ((core[0] != core[1]) && (socket[0] == socket[1])) { in get_two_cores()
88 unsigned int socket[2]; in get_two_sockets() local
95 socket[0] = rte_lcore_to_socket_id(id[0]); in get_two_sockets()
[all …]
/dpdk/examples/ipsec-secgw/test/
H A Dtun_null_header_reconstruct.py146 self.assertEqual(pkt[IP].proto, socket.IPPROTO_ESP)
155 self.assertEqual(pkt[IPv6].nh, socket.IPPROTO_ESP)
164 self.assertEqual(pkt[IP].proto, socket.IPPROTO_ESP)
173 self.assertEqual(pkt[IPv6].nh, socket.IPPROTO_ESP)
183 self.assertEqual(resp[IP].proto, socket.IPPROTO_ESP)
190 self.assertEqual(resp[IP].proto, socket.IPPROTO_ESP)
197 self.assertEqual(resp[IP].proto, socket.IPPROTO_ESP)
205 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_ESP)
211 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_ESP)
218 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_ESP)
[all …]
H A Dtrs_ipv6opts.py70 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_ESP)
75 self.assertEqual(d[IPv6].nh, socket.IPPROTO_UDP)
97 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_HOPOPTS)
100 self.assertEqual(resp[IPv6ExtHdrHopByHop].nh, socket.IPPROTO_ROUTING)
101 self.assertEqual(resp[IPv6ExtHdrRouting].nh, socket.IPPROTO_DSTOPTS)
102 self.assertEqual(resp[IPv6ExtHdrDestOpt].nh, socket.IPPROTO_ESP)
109 self.assertEqual(d[IPv6].nh, socket.IPPROTO_HOPOPTS)
110 self.assertEqual(d[IPv6ExtHdrHopByHop].nh, socket.IPPROTO_ROUTING)
111 self.assertEqual(d[IPv6ExtHdrRouting].nh, socket.IPPROTO_DSTOPTS)
112 self.assertEqual(d[IPv6ExtHdrDestOpt].nh, socket.IPPROTO_UDP)
[all …]
H A Dpkttest.py6 import socket
54 self.s = socket.socket(socket.AF_PACKET, socket.SOCK_RAW, socket.htons(Interface.ETH_P_ALL))
56 self.s.bind((self.name, 0, socket.PACKET_OTHERHOST))
/dpdk/examples/ip_fragmentation/
H A Dmain.c720 int socket, ret; in init_routing_table()
723 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in init_routing_table()
724 if (socket_lpm[socket]) { in init_routing_table()
725 lpm = socket_lpm[socket]; in init_routing_table()
741 socket, in init_routing_table()
748 if (socket_lpm6[socket]) { in init_routing_table()
749 lpm6 = socket_lpm6[socket]; in init_routing_table()
765 socket, in init_routing_table()
721 int socket, ret; init_routing_table() local
784 int socket; init_mem() local
866 int socket, ret; main() local
[all...]
/dpdk/lib/eal/linux/
H A Deal_lcore.c43 unsigned socket; in eal_cpu_socket_id() local
45 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in eal_cpu_socket_id()
49 socket, lcore_id); in eal_cpu_socket_id()
51 return socket; in eal_cpu_socket_id()
/dpdk/examples/ip_reassembly/
H A Dmain.c766 int socket, ret; in init_routing_table()
769 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in init_routing_table()
770 if (socket_lpm[socket]) { in init_routing_table()
771 lpm = socket_lpm[socket]; in init_routing_table()
787 socket, in init_routing_table()
794 if (socket_lpm6[socket]) { in init_routing_table()
795 lpm6 = socket_lpm6[socket]; in init_routing_table()
811 socket, in init_routing_table()
767 int socket, ret; init_routing_table() local
823 setup_port_tbl(struct lcore_queue_conf * qconf,uint32_t lcore,int socket,uint32_t port) setup_port_tbl() argument
850 int socket; setup_queue_tbl() local
909 int socket; init_mem() local
1001 int ret, socket; main() local
[all...]
/dpdk/drivers/net/mlx4/
H A Dmlx4_utils.c54 unsigned int cnt, int zero, int socket) in mlx4_mallocv_inline() argument
84 data = rte_malloc_socket(type, size, least, socket); in mlx4_mallocv_inline()
86 data = rte_zmalloc_socket(type, size, least, socket); in mlx4_mallocv_inline()
171 unsigned int cnt, int socket) in mlx4_mallocv_socket() argument
173 return mlx4_mallocv_inline(type, vec, cnt, 0, socket); in mlx4_mallocv_socket()
185 unsigned int cnt, int socket) in mlx4_zmallocv_socket() argument
187 return mlx4_mallocv_inline(type, vec, cnt, 1, socket); in mlx4_zmallocv_socket()
/dpdk/drivers/common/mlx5/
H A Dmlx5_common_devx.c82 struct mlx5_devx_cq_attr *attr, int socket) in mlx5_devx_cq_create() argument
111 alignment, socket); in mlx5_devx_cq_create()
209 struct mlx5_devx_create_sq_attr *attr, int socket) in mlx5_devx_sq_create() argument
229 alignment, socket); in mlx5_devx_sq_create()
355 struct mlx5_devx_qp_attr *attr, int socket) in mlx5_devx_qp_create() argument
374 alignment, socket); in mlx5_devx_qp_create()
460 mlx5_devx_wq_init(void *ctx, uint32_t wqe_size, uint16_t log_wqbb_n, int socket, in mlx5_devx_wq_init() argument
480 alignment, socket); in mlx5_devx_wq_init()
539 struct mlx5_devx_create_rq_attr *attr, int socket) in mlx5_devx_rq_std_create() argument
544 ret = mlx5_devx_wq_init(ctx, wqe_size, log_wqbb_n, socket, in mlx5_devx_rq_std_create()
[all …]
H A Dmlx5_common_devx.h79 struct mlx5_devx_cq_attr *attr, int socket);
87 struct mlx5_devx_create_sq_attr *attr, int socket);
95 struct mlx5_devx_qp_attr *attr, int socket);
103 struct mlx5_devx_create_rq_attr *attr, int socket);
H A Dmlx5_malloc.c165 mlx5_malloc(uint32_t flags, size_t size, unsigned int align, int socket) in mlx5_malloc() argument
182 addr = rte_zmalloc_socket(NULL, size, align, socket); in mlx5_malloc()
184 addr = rte_malloc_socket(NULL, size, align, socket); in mlx5_malloc()
210 int socket) in mlx5_realloc() argument
217 return mlx5_malloc(flags, size, align, socket); in mlx5_realloc()
232 new_addr = rte_realloc_socket(addr, size, align, socket); in mlx5_realloc()
/dpdk/lib/eal/include/
H A Drte_malloc.h57 * NUMA socket as the core that calls this function.
85 * same NUMA socket as the core that calls this function.
111 * same NUMA socket as the core that calls this function.
164 * resides on requested NUMA socket.
176 * @param socket
177 * NUMA socket to allocate memory on.
184 rte_realloc_socket(void *ptr, size_t size, unsigned int align, int socket)
203 * @param socket
204 * NUMA socket to allocate memory on. If SOCKET_ID_ANY is used, this function
212 rte_malloc_socket(const char *type, size_t size, unsigned align, int socket)
[all...]
/dpdk/doc/guides/nics/
H A Dmemif.rst17 existing socket. It is also a producer of shared memory file and initializes
20 creates the socket and listens for any client connection requests. The socket
24 will also remove a listener socket, if it is not being used by any other
30 net_memif1, and so on. Memif uses unix domain socket to transmit control
31 messages. Each memif has a unique id per socket. This id is used to identify
33 interfaces using same socket, be sure to specify unique ids ``id=0``, ``id=1``,
34 etc. Note that if you assign a socket to a server interface it becomes a
35 listener socket. Listener socket can not be used by a client interface on same
45 "socket=/tmp/memif.sock", "Socket filename", "/tmp/memif.sock", "string len 108"
46 "socket-abstract=no", "Set usage of abstract socket address", "yes", "yes|no"
[all …]
H A Daxgbe.rst62 EAL: PCI device 0000:02:00.4 on NUMA socket 0
65 USER1: create a new mbuf pool <mbuf_pool_socket_0>: n=171456, size=2176, socket=0
66 USER1: create a new mbuf pool <mbuf_pool_socket_1>: n=171456, size=2176, socket=1
67 USER1: create a new mbuf pool <mbuf_pool_socket_2>: n=171456, size=2176, socket=2
68 USER1: create a new mbuf pool <mbuf_pool_socket_3>: n=171456, size=2176, socket=3
69 Configuring Port 0 (socket 0)
/dpdk/doc/guides/linux_gsg/
H A Dlinux_eal_parameters.rst63 * ``--socket-mem <amounts of memory per socket>``
65 Preallocate specified amounts of memory per socket. The parameter is a
68 --socket-mem 1024,2048
70 This will allocate 1 gigabyte of memory on socket 0, and 2048 megabytes of
71 memory on socket 1.
73 * ``--socket-limit <amounts of memory per socket>``
75 Place a per-socket upper limit on memory use (non-legacy memory mode only).
76 0 will disable the limit for a particular socket.
/dpdk/drivers/net/memif/
H A Dmemif_socket.c200 if (cc->socket == NULL) { in memif_msg_receive_init()
206 TAILQ_FOREACH(elt, &cc->socket->dev_queue, next) { in memif_msg_receive_init()
820 struct memif_socket *socket = arg; in memif_listener_handler() local
828 sockfd = accept(rte_intr_fd_get(socket->intr_handle), in memif_listener_handler()
833 rte_intr_fd_get(socket->intr_handle)); in memif_listener_handler()
837 MIF_LOG(DEBUG, "%s: Connection request accepted.", socket->filename); in memif_listener_handler()
858 cc->socket = socket; in memif_listener_handler()
912 sockfd = socket(AF_UNIX, SOCK_SEQPACKET, 0); in memif_socket_create()
1006 struct memif_socket *socket = NULL; in memif_socket_init() local
1024 ret = rte_hash_lookup_data(hash, key, (void **)&socket); in memif_socket_init()
[all …]

1234567