/qemu/tests/ |
H A D | vhost-user-bridge.c | 71 int sock; member 99 if (sock >= FD_SETSIZE) { in dispatcher_add() 111 dispr->max_sock = sock; in dispatcher_add() 121 if (sock >= FD_SETSIZE) { in dispatcher_remove() 157 int sock; in dispatcher_wait() local 158 for (sock = 0; sock < dispr->max_sock + 1; sock++) { in dispatcher_wait() 163 if (FD_ISSET(sock, &fdset) && FD_ISSET(sock, &dispr->fdset)) { in dispatcher_wait() 389 watch_cb(int sock, void *ctx) in watch_cb() argument 548 if (dev->sock == -1) { in vubr_new() 690 int sock; in vubr_backend_udp_setup() local [all …]
|
/qemu/tests/qemu-iotests/ |
H A D | nbd-fault-injector.py | 79 def recvall(sock, bufsize): argument 105 def __init__(self, sock, rules): argument 106 self.sock = sock 114 self.sock.close() 133 self.sock.close() 193 conn, _ = sock.accept() 237 sock = socket.socket() 239 sock.bind((host, int(port))) 245 sock.bind(path) 246 sock.listen(0) [all …]
|
H A D | 083.out | 113 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock 117 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock 121 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock 125 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock 129 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock 133 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock 198 qemu-io: can't open device nbd+unix:///?socket=SOCK_DIR/nbd.sock 202 qemu-io: can't open device nbd+unix:///?socket=SOCK_DIR/nbd.sock 206 qemu-io: can't open device nbd+unix:///?socket=SOCK_DIR/nbd.sock 210 qemu-io: can't open device nbd+unix:///?socket=SOCK_DIR/nbd.sock [all …]
|
H A D | 302.out | 3 image: nbd+unix:///exp?socket=SOCK_DIR/PID-nbd-sock 8 filename: nbd+unix:///exp?socket=SOCK_DIR/PID-nbd-sock
|
/qemu/chardev/ |
H A D | char-socket.c | 1284 !(sock->has_server && sock->server)) { in qmp_chardev_validate_socket() 1316 if (sock->tls_authz && !sock->tls_creds) { in qmp_chardev_validate_socket() 1322 if (!sock->has_server || sock->server) { in qmp_chardev_validate_socket() 1330 if (sock->has_websocket && sock->websocket) { in qmp_chardev_validate_socket() 1353 bool do_nodelay = sock->has_nodelay ? sock->nodelay : false; in qmp_chardev_open_socket() 1354 bool is_listen = sock->has_server ? sock->server : true; in qmp_chardev_open_socket() 1355 bool is_telnet = sock->has_telnet ? sock->telnet : false; in qmp_chardev_open_socket() 1356 bool is_tn3270 = sock->has_tn3270 ? sock->tn3270 : false; in qmp_chardev_open_socket() 1357 bool is_waitconnect = sock->has_wait ? sock->wait : false; in qmp_chardev_open_socket() 1359 int64_t reconnect = sock->has_reconnect ? sock->reconnect : 0; in qmp_chardev_open_socket() [all …]
|
/qemu/util/ |
H A D | qemu-sockets.c | 362 int sock, rc; in inet_connect_addr() local 387 return sock; in inet_connect_addr() 491 return sock; in inet_connect_saddr() 579 return sock; in inet_dgram_saddr() 727 return sock; in inet_connect() 784 return sock; in vsock_connect_addr() 977 return sock; in unix_listen_saddr() 981 close(sock); in unix_listen_saddr() 1041 return sock; in unix_connect_saddr() 1052 int sock; in unix_listen() local [all …]
|
/qemu/tests/qtest/ |
H A D | netdev-socket.c | 41 static int inet_get_free_port_socket_ipv4(int sock) in inet_get_free_port_socket_ipv4() argument 62 static int inet_get_free_port_socket_ipv6(int sock) in inet_get_free_port_socket_ipv6() argument 85 g_autofree int *sock = g_new(int, nb); in inet_get_free_port_multiple() local 90 if (sock[i] < 0) { in inet_get_free_port_multiple() 102 close(sock[i]); in inet_get_free_port_multiple() 339 int sock[2]; in test_stream_fd() local 342 ret = socketpair(AF_LOCAL, SOCK_STREAM, 0, sock); in test_stream_fd() 347 sock[0]); in test_stream_fd() 353 sock[1]); in test_stream_fd() 361 close(sock[0]); in test_stream_fd() [all …]
|
H A D | libqtest.c | 110 qemu_set_cloexec(sock); in init_socket() 111 return sock; in init_socket() 114 static int socket_accept(int sock) in socket_accept() argument 134 close(sock); in socket_accept() 145 close(sock); in socket_accept() 449 int sock, qmpsock, i; in qtest_init_internal() local 488 s->fd = socket_accept(sock); in qtest_init_internal() 759 int sock; in qtest_socket_server() local 763 g_assert_cmpint(sock, !=, -1); in qtest_socket_server() 770 ret = listen(sock, 1); in qtest_socket_server() [all …]
|
/qemu/net/ |
H A D | socket.c | 694 sock = &netdev->u.socket; in net_init_socket() 696 if (!!sock->fd + !!sock->listen + !!sock->connect + !!sock->mcast + in net_init_socket() 697 !!sock->udp != 1) { in net_init_socket() 703 if (sock->localaddr && !sock->mcast && !sock->udp) { in net_init_socket() 708 if (sock->fd) { in net_init_socket() 741 if (sock->listen) { in net_init_socket() 749 if (sock->connect) { in net_init_socket() 757 if (sock->mcast) { in net_init_socket() 767 assert(sock->udp); in net_init_socket() 768 if (!sock->localaddr) { in net_init_socket() [all …]
|
H A D | vde.c | 78 const char *name, const char *sock, in net_vde_init() argument 85 char *init_sock = (char *)sock; in net_vde_init() 101 qemu_set_info_str(nc, "sock=%s,fd=%d", sock, vde_datafd(vde)); in net_vde_init() 121 if (net_vde_init(peer, "vde", name, vde->sock, vde->port, vde->group, in net_init_vde()
|
H A D | stream.c | 429 const NetdevStreamOptions *sock; in net_init_stream() local 432 sock = &netdev->u.stream; in net_init_stream() 434 if (!sock->has_server || !sock->server) { in net_init_stream() 435 return net_stream_client_init(peer, "stream", name, sock->addr, in net_init_stream() 436 sock->has_reconnect ? sock->reconnect : 0, in net_init_stream() 439 if (sock->has_reconnect) { in net_init_stream() 444 return net_stream_server_init(peer, "stream", name, sock->addr, errp); in net_init_stream()
|
/qemu/fsdev/ |
H A D | virtfs-proxy-helper.c | 750 int sock, client; in proxy_socket() local 767 if (sock < 0) { in proxy_socket() 786 if (listen(sock, 1) < 0) { in proxy_socket() 797 close(sock); in proxy_socket() 801 close(sock); in proxy_socket() 1053 int sock; in main() local 1072 sock = -1; in main() 1089 sock = atoi(optarg); in main() 1115 if (sock_name && sock != -1) { in main() 1151 if (sock < 0) { in main() [all …]
|
/qemu/python/tests/ |
H A D | protocol.py | 138 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 140 sock.bind(('127.0.0.1', 0)) 141 sock.listen(1) 142 address = sock.getsockname() 144 socks.append(sock) 150 sock.connect(address) 151 socks.append(sock) 156 for sock in socks: 157 sock.close() 436 await self.proto.start_server_and_accept(sock) [all …]
|
/qemu/python/qemu/machine/ |
H A D | qtest.py | 56 sock: Optional[socket.socket] = None, 58 if address is None and sock is None: 60 if address is not None and sock is not None: 63 if sock is not None and server: 67 self._sock = sock or self._get_sock() 166 self._qtest = QEMUQtestProtocol(sock=self._qtest_sock_pair[1])
|
/qemu/tests/avocado/ |
H A D | vnc.py | 23 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock: 25 sock.bind((VNC_ADDR, port)) 33 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock: 35 sock.connect((VNC_ADDR, port))
|
/qemu/contrib/vhost-user-scsi/ |
H A D | vhost-user-scsi.c | 317 int sock; in unix_sock_new() local 323 sock = socket(AF_UNIX, SOCK_STREAM, 0); in unix_sock_new() 324 if (sock < 0) { in unix_sock_new() 334 if (bind(sock, (struct sockaddr *)&un, len) < 0) { in unix_sock_new() 339 if (listen(sock, 1) < 0) { in unix_sock_new() 344 return sock; in unix_sock_new() 347 (void)close(sock); in unix_sock_new()
|
/qemu/python/qemu/qmp/ |
H A D | util.py | 141 sock = transport.get_extra_info('socket') 143 if sock is None: 148 while sock.fileno() != -1:
|
H A D | qmp_client.py | 641 sock = self._writer.transport.get_extra_info('socket') 643 if sock.family != socket.AF_UNIX: 646 if not hasattr(sock, 'sendmsg'): 650 sock = sock._sock # pylint: disable=protected-access 652 sock.sendmsg(
|
/qemu/tests/qemu-iotests/tests/ |
H A D | nbd-reconnect-on-open.out | 5 qemu-io: can't open: Failed to connect to 'SOCK_DIR/PID-nbd-sock': No such file or directory 9 qemu-io: can't open: Failed to connect to 'SOCK_DIR/PID-nbd-sock': No such file or directory
|
/qemu/tests/unit/ |
H A D | test-char.c | 557 int ret, sock = qemu_socket(PF_INET, SOCK_DGRAM, 0); in make_udp_socket() local 559 g_assert_cmpint(sock, >=, 0); in make_udp_socket() 569 return sock; in make_udp_socket() 588 sock = make_udp_socket(&port); in char_udp_test_internal() 603 ret = recvfrom(sock, buf, sizeof(buf), 0, in char_udp_test_internal() 612 close(sock); in char_udp_test_internal() 1409 int sock = make_udp_socket(&port); in char_hotswap_test() local 1410 g_assert_cmpint(sock, >=, 0); in char_hotswap_test() 1418 char_udp_test_internal(chr, sock); in char_hotswap_test() 1429 char_udp_test_internal(chr, sock); in char_hotswap_test() [all …]
|
/qemu/contrib/vhost-user-blk/ |
H A D | vhost-user-blk.c | 470 int sock; in unix_sock_new() local 476 sock = socket(AF_UNIX, SOCK_STREAM, 0); in unix_sock_new() 477 if (sock < 0) { in unix_sock_new() 487 if (bind(sock, (struct sockaddr *)&un, len) < 0) { in unix_sock_new() 492 if (listen(sock, 1) < 0) { in unix_sock_new() 497 return sock; in unix_sock_new() 500 (void)close(sock); in unix_sock_new()
|
/qemu/docs/tools/ |
H A D | qemu-storage-daemon.rst | 74 --chardev socket,id=char1,path=/var/run/qsd-qmp.sock,server=on,wait=off 153 ``/var/run/qsd-nbd.sock``:: 155 --nbd-server addr.type=unix,addr.path=/var/run/qsd-nbd.sock 188 Launch the daemon with QMP monitor socket ``qmp.sock`` so clients can execute 192 --chardev socket,path=qmp.sock,server=on,wait=off,id=char1 \ 203 sock_path = '/var/run/qmp.sock' 231 Export raw image file ``disk.img`` over NBD UNIX domain socket ``nbd.sock``:: 235 --nbd-server addr.type=unix,addr.path=nbd.sock \ 239 domain socket ``vhost-user-blk.sock``:: 244 …--export type=vhost-user-blk,id=export,addr.type=unix,addr.path=vhost-user-blk.sock,node-name=qcow2
|
/qemu/docs/system/devices/ |
H A D | vhost-user-rng.rst | 28 host# vhost-device-rng --socket-path=rng.sock -c 1 -m 512 -p 1000 36 -chardev socket,path=$(PATH)/rng.sock,id=rng0 \
|
H A D | vhost-user-input.rst | 30 host# vhost-user-input --socket-path=input.sock \ 40 -chardev socket,path=/tmp/input.sock,id=mouse0 \
|
/qemu/scripts/ |
H A D | cpu-x86-uarch-abi.py | 68 sock = sys.argv[1] variable 69 shell = QEMUMonitorProtocol(sock)
|