| /spdk/python/spdk/rpc/ |
| H A D | client.py | 6 import socket 24 socket.inet_pton(socket.AF_INET, addr) 25 return socket.AF_INET 29 socket.inet_pton(socket.AF_INET6, addr) 30 return socket.AF_INET6 34 return socket.AF_UNIX 80 if addr_type == socket.AF_UNIX: 82 self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) 84 elif addr_type == socket.AF_INET6: 86 … for res in socket.getaddrinfo(addr, port, socket.AF_INET6, socket.SOCK_STREAM, socket.SOL_TCP): [all …]
|
| /spdk/test/app/fuzz/vhost_fuzz/ |
| H A D | vhost_fuzz_rpc.c | 13 char *socket; member 22 {"socket", offsetof(struct rpc_fuzz_vhost_dev_create, socket), spdk_json_decode_string}, 45 if (strlen(req.socket) > PATH_MAX) { in spdk_rpc_fuzz_vhost_create_dev() 49 free(req.socket); in spdk_rpc_fuzz_vhost_create_dev() 53 rc = fuzz_vhost_dev_init(req.socket, req.is_blk, req.use_bogus_buffer, req.use_valid_buffer, in spdk_rpc_fuzz_vhost_create_dev() 74 free(req.socket); in spdk_rpc_fuzz_vhost_create_dev()
|
| H A D | README.md | 4 malformed or invalid requests across a unix domain socket. This fuzzer
|
| /spdk/scripts/ |
| H A D | rpc_http_proxy.py | 12 import socket 39 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) 140 httpd.socket = ssl.wrap_socket(httpd.socket, certfile=args.cert, server_side=True) 145 httpd.socket.close()
|
| H A D | posix.txt | 60 <sys/socket.h>
|
| /spdk/test/spdkcli/ |
| H A D | spdkcli_job.py | 34 socket = "/var/tmp/spdk.sock" variable 37 socket = sys.argv[2] variable 43 child = pexpect.spawn(os.path.join(testdir, "../../scripts/spdkcli.py") + " -s %s" % socket) 45 … pexpect.spawn(os.path.join(testdir, "../../scripts/spdkcli.py") + " -s %s -p %s" % (socket, port))
|
| /spdk/python/spdk/sma/ |
| H A D | qmp.py | 7 import socket 8 from socket import error as SocketError 46 Exception Class for socket exceptions in QMPClient implementation 48 def __init__(self, message, code='socket'): 64 QMPBaseClass implements a low level connection to QMP socket 66 :param family is one of [socket.AF_INET, socket.AF_UNIX] 67 :param address is tuple(address, port) for socket.AF_INET 68 or a path string for socket.AF_UNIX 74 family: socket [all...] |
| /spdk/scripts/perf/pm/ |
| H A D | collect-bmc-pm | 333 local socket socket_idx _socket_idx socket_name 340 for socket in /sys/class/powercap/intel-rapl:*; do 341 [[ -e $socket ]] || continue 343 socket_idx=${socket#*:} socket_name=$(< "$socket/name") 347 package-*) _socket_idx=$socket_idx socket_name=socket ;; 352 socket_uj+=("$(< "$socket/energy_uj")")
|
| /spdk/test/app/fuzz/common/ |
| H A D | fuzz_rpc.py | 25 def _fuzz_vhost_create_dev(client, socket, is_blk, use_bogus_buffer, use_valid_buffer, test_scsi_tm… argument 40 params = {"socket": socket, 70 args.socket,
|
| /spdk/doc/ |
| H A D | vhost.md | 79 on CPU cores 0 and 1 (cpumask 0x3) with all future socket files placed in /var/tmp. 124 on NUMA systems, the cpumask should specify cores on the same CPU socket as its 152 socket as its associated VM. 192 -chardev socket,id=char0,path=/var/tmp/vhost.0 199 -chardev socket,id=char1,path=/var/tmp/vhost.1 221 reactor.c: 668:spdk_reactors_init: *NOTICE*: Occupied cpu socket mask is 0x1 222 reactor.c: 424:_spdk_reactor_run: *NOTICE*: Reactor started on core 1 on socket 0 223 reactor.c: 424:_spdk_reactor_run: *NOTICE*: Reactor started on core 0 on socket 0 228 EAL: PCI device 0000:01:00.0 on NUMA socket 0 240 VHOST_CONFIG: vhost-user server: socket created, fd: 21 [all …]
|
| H A D | virtio.md | 12 * vhost-user - Can be used to connect to a vhost socket directly on the same host.
|
| H A D | jsonrpc_proxy.md | 15 RPC listen address | Optional | string | Path to SPDK JSON RPC socket. Default: /var/tmp/…
|
| H A D | vagrant.md | 156 EAL: Multi-process socket /var/run/dpdk/spdk0/mp_socket 159 EAL: PCI device 0000:00:0e.0 on NUMA socket 0
|
| H A D | applications.md | 39 -r | --rpc-socket | string | /var/tmp/spdk.sock | RPC listen address 92 one file per hugepages per socket. This is needed for @ref virtio to be used
|
| H A D | sma.md | 126 service, as well as several other options (e.g. listen address, SPDK-RPC socket, 133 socket: '/var/tmp/spdk.sock'
|
| H A D | nvmf_multipath_howto.md | 72 Connect to the RPC socket of the bdevperf process and start the test:
|
| H A D | vhost_processing.md | 51 > same host. It uses communication over a Unix domain socket to share file 64 > server (listening) in the socket communication.
|
| /spdk/test/spdkcli/match_files/ |
| H A D | spdkcli_details_vhost_ctrl.test.match | 22 "socket": "$(S)/vhost_scsi1"
|
| /spdk/test/ftl/ |
| H A D | common.sh | 162 $spdk_ini_bin --cpumask="$spdk_ini_cpumask" --rpc-socket="$spdk_ini_rpc" & 199 …$spdk_dd_bin --cpumask="$spdk_ini_cpumask" --rpc-socket="$spdk_ini_rpc" --json="$spdk_ini_cnfg" "$…
|
| /spdk/lib/env_dpdk/ |
| H A D | pci_event.c | 34 netlink_fd = socket(PF_NETLINK, SOCK_DGRAM, NETLINK_KOBJECT_UEVENT); in spdk_pci_event_listen()
|
| /spdk/go/rpc/ |
| H A D | README.md | 7 SPDK over Unix and TCP socket in Go. In addition, this repository provides integration of a client
|
| /spdk/python/spdk/sma/device/ |
| H A D | vhost_blk.py | 8 from socket import AddressFamily
|
| /spdk/lib/jsonrpc/ |
| H A D | jsonrpc_client_tcp.c | 205 client->sockfd = socket(domain, SOCK_STREAM | SOCK_NONBLOCK, protocol); in jsonrpc_client_connect()
|
| H A D | jsonrpc_server_tcp.c | 32 server->sockfd = socket(domain, SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC, protocol); in spdk_jsonrpc_server_listen()
|
| /spdk/lib/vfio_user/host/ |
| H A D | vfio_user.c | 339 fd = socket(AF_UNIX, SOCK_STREAM, 0); in vfio_user_dev_setup()
|