Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 25 of 56) sorted by relevance

123

/qemu/tests/
H A Dvhost-user-bridge.c71 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 Dnbd-fault-injector.py79 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 D083.out113 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 D302.out3 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 Dchar-socket.c1284 !(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 Dqemu-sockets.c362 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 Dnetdev-socket.c41 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 Dlibqtest.c110 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 Dsocket.c694 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 Dvde.c78 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 Dstream.c429 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 Dvirtfs-proxy-helper.c750 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 Dprotocol.py138 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 Dqtest.py56 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 Dvnc.py23 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 Dvhost-user-scsi.c317 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 Dutil.py141 sock = transport.get_extra_info('socket')
143 if sock is None:
148 while sock.fileno() != -1:
H A Dqmp_client.py641 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 Dnbd-reconnect-on-open.out5 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 Dtest-char.c557 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 Dvhost-user-blk.c470 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 Dqemu-storage-daemon.rst74 --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 Dvhost-user-rng.rst28 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 Dvhost-user-input.rst30 host# vhost-user-input --socket-path=input.sock \
40 -chardev socket,path=/tmp/input.sock,id=mouse0 \
/qemu/scripts/
H A Dcpu-x86-uarch-abi.py68 sock = sys.argv[1] variable
69 shell = QEMUMonitorProtocol(sock)

123