Home
last modified time | relevance | path

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

123456789

/dpdk/usertools/
H A Ddpdk-telemetry-client.py5 import socket
21 self.send_fd = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
22 self.recv_fd = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
36 self.socket = Socket()
55 self.socket.recv_fd.bind(self.file_path)
56 except socket.error as msg:
58 self.socket.recv_fd.settimeout(2)
61 self.socket.send_fd.sendall(JSON.encode())
63 self.socket.recv_fd.listen(1)
64 self.socket.client_fd = self.socket.recv_fd.accept()[0]
[all …]
H A Dcpu_layout.py21 socket = int(fd.read()) variable
25 if socket not in sockets:
26 sockets.append(socket)
27 key = (socket, core)
/dpdk/lib/eal/common/
H A Deal_common_dynmem.c402 for (socket = 0; socket < RTE_MAX_NUMA_NODES && total_size != 0; in eal_dynmem_calc_num_pages_per_socket()
403 socket++) { in eal_dynmem_calc_num_pages_per_socket()
422 for (socket = 0; socket < RTE_MAX_NUMA_NODES && total_size != 0; in eal_dynmem_calc_num_pages_per_socket()
423 socket++) { in eal_dynmem_calc_num_pages_per_socket()
426 get_socket_mem_size(socket) - memory[socket], in eal_dynmem_calc_num_pages_per_socket()
438 for (socket = 0; socket < RTE_MAX_NUMA_NODES && total_size != 0; in eal_dynmem_calc_num_pages_per_socket()
439 socket++) { in eal_dynmem_calc_num_pages_per_socket()
456 for (socket = 0; socket < RTE_MAX_NUMA_NODES && total_mem != 0; in eal_dynmem_calc_num_pages_per_socket()
457 socket++) { in eal_dynmem_calc_num_pages_per_socket()
475 if (memory[socket] == 0) in eal_dynmem_calc_num_pages_per_socket()
[all …]
H A Drte_malloc.c111 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()
149 return rte_zmalloc_socket(type, num * size, align, socket); in rte_calloc_socket()
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()
200 void *new_ptr = rte_malloc_socket(NULL, size, align, socket); in rte_realloc_socket()
208 rte_eal_trace_mem_realloc(size, align, socket, new_ptr); in rte_realloc_socket()
236 rte_malloc_get_socket_stats(int socket, in rte_malloc_get_socket_stats() argument
[all …]
H A Dmalloc_heap.c316 socket, true); in alloc_pages_on_heap()
444 socket, alloc_sz >> 20ULL); in try_expand_heap_primary()
482 req.alloc_req.socket = socket; in try_expand_heap_secondary()
563 if (msl->socket_id != socket) in alloc_more_mem_on_socket()
727 int socket, heap_id, i; in malloc_heap_alloc() local
738 socket = malloc_get_numa_socket(); in malloc_heap_alloc()
740 socket = socket_arg; in malloc_heap_alloc()
790 int socket, i, cur_socket, heap_id; in malloc_heap_alloc_biggest() local
801 socket = malloc_get_numa_socket(); in malloc_heap_alloc_biggest()
803 socket = socket_arg; in malloc_heap_alloc_biggest()
[all …]
/dpdk/lib/node/
H A Dip4_lookup.c127 uint8_t socket; in rte_node_ip4_route_add() local
138 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in rte_node_ip4_route_add()
139 if (!ip4_lookup_nm.lpm_tbl[socket]) in rte_node_ip4_route_add()
147 abuf, depth, val, socket, ret); in rte_node_ip4_route_add()
162 if (nm->lpm_tbl[socket]) in setup_lpm()
170 nm->lpm_tbl[socket] = rte_lpm_create(s, socket, &config_ipv4); in setup_lpm()
171 if (nm->lpm_tbl[socket] == NULL) in setup_lpm()
180 uint16_t socket, lcore_id; in ip4_lookup_node_init() local
196 socket = rte_lcore_to_socket_id(lcore_id); in ip4_lookup_node_init()
197 rc = setup_lpm(&ip4_lookup_nm, socket); in ip4_lookup_node_init()
[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
386 test_realloc_socket(int socket) in test_realloc_socket() argument
457 RTE_CACHE_LINE_SIZE, socket); in test_realloc_socket()
588 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in test_realloc_numa()
589 if (is_mem_on_socket(socket)) { in test_realloc_numa()
597 socket); in test_realloc_numa()
605 if (socket_allocated != socket) { in test_realloc_numa()
886 int32_t *socket = arg; in check_socket_mem() local
891 return *socket == msl->socket_id; in check_socket_mem()
[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)
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)
245 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_ESP)
251 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)
102 self.assertEqual(resp[IPv6ExtHdrDestOpt].nh, socket.IPPROTO_ESP)
109 self.assertEqual(d[IPv6].nh, socket.IPPROTO_HOPOPTS)
111 self.assertEqual(d[IPv6ExtHdrRouting].nh, socket.IPPROTO_DSTOPTS)
112 self.assertEqual(d[IPv6ExtHdrDestOpt].nh, socket.IPPROTO_UDP)
127 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_UDP)
153 self.assertEqual(resp[IPv6].nh, socket.IPPROTO_HOPOPTS)
156 self.assertEqual(resp[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.c722 int socket, ret; in init_routing_table() local
725 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in init_routing_table()
743 socket, in init_routing_table()
767 socket, in init_routing_table()
785 int socket; in init_mem() local
798 socket = 0; in init_mem()
802 socket); in init_mem()
816 socket); in init_mem()
820 socket); in init_mem()
867 int socket, ret; in main() local
[all …]
/dpdk/examples/ip_reassembly/
H A Dmain.c768 int socket, ret; in init_routing_table() local
771 for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) { in init_routing_table()
789 socket, in init_routing_table()
813 socket, in init_routing_table()
851 int socket; in setup_queue_tbl() local
858 socket = 0; in setup_queue_tbl()
910 int socket; in init_mem() local
923 socket = 0; in init_mem()
1002 int ret, socket; in main() local
1072 socket = 0; in main()
[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/doc/guides/linux_gsg/
H A Dbuild_sample_apps.rst48 Number of memory channels per processor socket.
58 * ``--socket-mem``:
63 * ``--socket-limit``:
74 recommended that ``--socket-mem`` be used instead of this option.
114 (assuming the platform has four memory channels per processor socket,
161 if no ``-m`` or ``--socket-mem`` parameter is passed to it when run.
166 Suppose the system has 1024 reserved 2 MB pages in socket 0 and 1024 in socket 1.
177 …is is accomplished by supplying the ``--socket-mem`` flag followed by amounts of memory requested …
178 for example, supply ``--socket-mem=0,512`` to try and reserve 512 MB for socket 1 only.
179 Similarly, on a four socket system, to allocate 1 GB memory on each of sockets 0 and 2 only, the pa…
[all …]
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/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.c80 struct mlx5_devx_cq_attr *attr, int socket) in mlx5_devx_cq_create() argument
109 alignment, socket); in mlx5_devx_cq_create()
227 alignment, socket); in mlx5_devx_sq_create()
353 struct mlx5_devx_qp_attr *attr, int socket) in mlx5_devx_qp_create() argument
372 alignment, socket); in mlx5_devx_qp_create()
478 alignment, socket); in mlx5_devx_wq_init()
547 rq = mlx5_devx_cmd_create_rq(ctx, attr, socket); in mlx5_devx_rq_std_create()
642 &attr->wq_attr, socket); in mlx5_devx_rq_shared_create()
650 rq = mlx5_devx_cmd_create_rq(ctx, attr, socket); in mlx5_devx_rq_shared_create()
703 log_wqbb_n, attr, socket); in mlx5_devx_rq_create()
[all …]
H A Dmlx5_common_devx.h77 struct mlx5_devx_cq_attr *attr, int socket);
85 struct mlx5_devx_create_sq_attr *attr, int socket);
93 struct mlx5_devx_qp_attr *attr, int socket);
101 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/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
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
46 "socket-abstract=no", "Set usage of abstract socket address", "yes", "yes|no"
65 at the same time, provided each role is assigned unique socket.
71 connected socket (control channel). Then it sends the 'hello' message
251 To see socket filename use show memif command::
[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/drivers/net/memif/
H A Dmemif_socket.c200 if (cc->socket == NULL) { in memif_msg_receive_init()
820 struct memif_socket *socket = arg; in memif_listener_handler() local
858 cc->socket = socket; in memif_listener_handler()
998 struct memif_socket *socket = NULL; in memif_socket_init() local
1018 socket = memif_socket_create(key, in memif_socket_init()
1021 if (socket == NULL) in memif_socket_init()
1055 struct memif_socket *socket = NULL; in memif_socket_remove_device() local
1086 ret = remove(socket->filename); in memif_socket_remove_device()
1089 socket->filename); in memif_socket_remove_device()
1093 rte_free(socket); in memif_socket_remove_device()
[all …]
/dpdk/lib/eal/include/
H A Drte_malloc.h161 rte_realloc_socket(void *ptr, size_t size, unsigned int align, int socket)
188 rte_malloc_socket(const char *type, size_t size, unsigned align, int socket)
217 rte_zmalloc_socket(const char *type, size_t size, unsigned align, int socket)
246 rte_calloc_socket(const char *type, size_t num, size_t size, unsigned align, int socket)
299 rte_malloc_get_socket_stats(int socket,
H A Drte_eal_trace.h200 int socket, void *ptr),
204 rte_trace_point_emit_int(socket);
211 int socket, void *ptr),
215 rte_trace_point_emit_int(socket);
221 RTE_TRACE_POINT_ARGS(size_t size, unsigned int align, int socket,
225 rte_trace_point_emit_int(socket);

123456789