Home
last modified time | relevance | path

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

123

/qemu/tests/
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/
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 …]
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 …]
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/
A Dchar-socket.c1299 !(sock->has_server && sock->server)) { in qmp_chardev_validate_socket()
1331 if (sock->tls_authz && !sock->tls_creds) { in qmp_chardev_validate_socket()
1337 if (!sock->has_server || sock->server) { in qmp_chardev_validate_socket()
1345 if (sock->has_websocket && sock->websocket) { in qmp_chardev_validate_socket()
1357 if (sock->has_reconnect_ms && sock->has_reconnect) { in qmp_chardev_validate_socket()
1374 bool do_nodelay = sock->has_nodelay ? sock->nodelay : false; in qmp_chardev_open_socket()
1375 bool is_listen = sock->has_server ? sock->server : true; in qmp_chardev_open_socket()
1376 bool is_telnet = sock->has_telnet ? sock->telnet : false; in qmp_chardev_open_socket()
1377 bool is_tn3270 = sock->has_tn3270 ? sock->tn3270 : false; in qmp_chardev_open_socket()
1378 bool is_waitconnect = sock->has_wait ? sock->wait : false; in qmp_chardev_open_socket()
[all …]
/qemu/util/
A Dqemu-sockets.c362 int sock, rc; in inet_connect_addr() local
386 return sock; in inet_connect_addr()
490 return sock; in inet_connect_saddr()
578 return sock; in inet_dgram_saddr()
763 return sock; in vsock_connect_addr()
956 return sock; in unix_listen_saddr()
960 close(sock); in unix_listen_saddr()
1020 return sock; in unix_connect_saddr()
1023 close(sock); in unix_connect_saddr()
1031 int sock; in unix_listen() local
[all …]
/qemu/tests/qtest/
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 …]
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()
761 int sock; in qtest_socket_server() local
765 g_assert_cmpint(sock, !=, -1); in qtest_socket_server()
772 ret = listen(sock, 1); in qtest_socket_server()
[all …]
/qemu/net/
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 …]
A Dstream.c428 const NetdevStreamOptions *sock; in net_init_stream() local
431 sock = &netdev->u.stream; in net_init_stream()
433 if (!sock->has_server || !sock->server) { in net_init_stream()
436 if (sock->has_reconnect && sock->has_reconnect_ms) { in net_init_stream()
440 } else if (sock->has_reconnect_ms) { in net_init_stream()
441 reconnect_ms = sock->reconnect_ms; in net_init_stream()
442 } else if (sock->has_reconnect) { in net_init_stream()
443 reconnect_ms = sock->reconnect * 1000u; in net_init_stream()
446 return net_stream_client_init(peer, "stream", name, sock->addr, in net_init_stream()
449 if (sock->has_reconnect || sock->has_reconnect_ms) { in net_init_stream()
[all …]
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()
/qemu/python/tests/
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/
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/
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/
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/
A Dutil.py141 sock = transport.get_extra_info('socket')
143 if sock is None:
148 while sock.fileno() != -1:
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/
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/
A Dtest-char.c579 int ret, sock = qemu_socket(PF_INET, SOCK_DGRAM, 0); in make_udp_socket() local
581 g_assert_cmpint(sock, >=, 0); in make_udp_socket()
591 return sock; in make_udp_socket()
610 sock = make_udp_socket(&port); in char_udp_test_internal()
625 ret = recvfrom(sock, buf, sizeof(buf), 0, in char_udp_test_internal()
634 close(sock); in char_udp_test_internal()
1431 int sock = make_udp_socket(&port); in char_hotswap_test() local
1432 g_assert_cmpint(sock, >=, 0); in char_hotswap_test()
1440 char_udp_test_internal(chr, sock); in char_hotswap_test()
1451 char_udp_test_internal(chr, sock); in char_hotswap_test()
[all …]
A Dtest-io-channel-socket.c509 int sock, ret = 0; in test_io_channel_unix_listen_cleanup() local
517 sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0); in test_io_channel_unix_listen_cleanup()
522 ret = bind(sock, (struct sockaddr *)&un, sizeof(un)); in test_io_channel_unix_listen_cleanup()
525 ioc->fd = sock; in test_io_channel_unix_listen_cleanup()
527 getsockname(sock, (struct sockaddr *)&ioc->localAddr, in test_io_channel_unix_listen_cleanup()
/qemu/contrib/vhost-user-blk/
A Dvhost-user-blk.c471 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()
486 if (bind(sock, (struct sockaddr *)&un, sizeof(un)) < 0) { in unix_sock_new()
491 if (listen(sock, 1) < 0) { in unix_sock_new()
496 return sock; in unix_sock_new()
499 (void)close(sock); in unix_sock_new()
/qemu/docs/tools/
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/
A Dvhost-user-input.rst30 host# vhost-user-input --socket-path=input.sock \
40 -chardev socket,path=/tmp/input.sock,id=mouse0 \
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 \
/qemu/scripts/
A Dcpu-x86-uarch-abi.py68 sock = sys.argv[1] variable
69 shell = QEMUMonitorProtocol(sock)

Completed in 63 milliseconds

123