| /qemu/io/ |
| H A D | channel-command.c | 214 if (!cioc->blocking && !win32_fd_poll(cioc->readfd, G_IO_IN)) { in qio_channel_command_readv()
249 if (!cioc->blocking && !win32_fd_poll(cioc->writefd, G_IO_OUT)) { in qio_channel_command_writev()
277 cioc->blocking = enabled; in qio_channel_command_set_blocking()
280 if ((cioc->writefd >= 0 && !g_unix_set_fd_nonblocking(cioc->writefd, !enabled, NULL)) || in qio_channel_command_set_blocking()
281 (cioc->readfd >= 0 && !g_unix_set_fd_nonblocking(cioc->readfd, !enabled, NULL))) { in qio_channel_command_set_blocking()
302 if (cioc->readfd != -1 && in qio_channel_command_close()
303 close(cioc->readfd) < 0) { in qio_channel_command_close()
306 if (cioc->writefd != -1 && in qio_channel_command_close()
307 cioc->writefd != cioc->readfd && in qio_channel_command_close()
308 close(cioc->writefd) < 0) { in qio_channel_command_close()
[all …]
|
| H A D | channel-socket.c | 380 QIOChannelSocket *cioc; in qio_channel_socket_accept() local
382 cioc = qio_channel_socket_new(); in qio_channel_socket_accept()
388 cioc->fd = qemu_accept(ioc->fd, (struct sockaddr *)&cioc->remoteAddr, in qio_channel_socket_accept()
390 if (cioc->fd < 0) { in qio_channel_socket_accept()
399 if (getsockname(cioc->fd, (struct sockaddr *)&cioc->localAddr, in qio_channel_socket_accept()
400 &cioc->localAddrLen) < 0) { in qio_channel_socket_accept()
407 if (cioc->localAddr.ss_family == AF_UNIX) { in qio_channel_socket_accept()
413 qio_channel_set_feature(QIO_CHANNEL(cioc), in qio_channel_socket_accept()
416 trace_qio_channel_socket_accept_complete(ioc, cioc, cioc->fd); in qio_channel_socket_accept()
417 return cioc; in qio_channel_socket_accept()
[all …]
|
| H A D | trace-events | 33 qio_channel_socket_accept_complete(void *ioc, void *cioc, int fd) "Socket accept complete ioc=%p ci…
|
| /qemu/net/ |
| H A D | stream.c | 60 QIOChannelSocket *cioc,
238 QIOChannelSocket *cioc, in net_stream_listen() argument
245 object_ref(OBJECT(cioc)); in net_stream_listen()
249 s->ioc = QIO_CHANNEL(cioc); in net_stream_listen()
256 if (cioc->localAddr.ss_family == AF_UNIX) { in net_stream_listen()
257 addr = qio_channel_socket_get_local_address(cioc, NULL); in net_stream_listen()
259 addr = qio_channel_socket_get_remote_address(cioc, NULL); in net_stream_listen()
|
| /qemu/migration/ |
| H A D | socket.c | 138 QIOChannelSocket *cioc, in socket_accept_incoming_migration() argument
149 qio_channel_set_name(QIO_CHANNEL(cioc), "migration-socket-incoming"); in socket_accept_incoming_migration()
150 migration_channel_process_incoming(QIO_CHANNEL(cioc)); in socket_accept_incoming_migration()
|
| /qemu/tests/unit/ |
| H A D | test-yank.c | 55 QIOChannelSocket *cioc; in accept_thread() local
57 cioc = qio_channel_socket_accept(ioc, &error_abort); in accept_thread()
58 object_unref(OBJECT(cioc)); in accept_thread()
|
| H A D | test-char.c | 884 QIOChannelSocket *cioc; in char_socket_client_server_thread() local
887 cioc = qio_channel_socket_accept(ioc, &error_abort); in char_socket_client_server_thread()
888 g_assert_nonnull(cioc); in char_socket_client_server_thread()
890 if (char_socket_ping_pong(QIO_CHANNEL(cioc), NULL) != 0) { in char_socket_client_server_thread()
|
| /qemu/ |
| H A D | blockdev-nbd.c | 60 static void nbd_accept(QIONetListener *listener, QIOChannelSocket *cioc, in nbd_accept() argument
66 qio_channel_set_name(QIO_CHANNEL(cioc), "nbd-server"); in nbd_accept()
67 nbd_client_new(cioc, nbd_server->tlscreds, nbd_server->tlsauthz, in nbd_accept()
|
| H A D | qemu-nbd.c | 384 static void nbd_accept(QIONetListener *listener, QIOChannelSocket *cioc, in nbd_accept() argument
393 nbd_client_new(cioc, tlscreds, tlsauthz, nbd_client_closed); in nbd_accept()
|
| /qemu/scsi/ |
| H A D | qemu-pr-helper.c | 804 QIOChannelSocket *cioc; in accept_client() local
807 cioc = qio_channel_socket_accept(QIO_CHANNEL_SOCKET(ioc), in accept_client()
809 if (!cioc) { in accept_client()
814 prh->ioc = cioc; in accept_client()
|
| /qemu/chardev/ |
| H A D | char-socket.c | 100 QIOChannelSocket *cioc,
938 QIOChannelSocket *cioc, in tcp_chr_accept() argument
945 tcp_chr_set_client_ioc_name(chr, cioc); in tcp_chr_accept()
949 QIO_CHANNEL(cioc)); in tcp_chr_accept()
951 tcp_chr_new_client(chr, cioc); in tcp_chr_accept()
|
| /qemu/ui/ |
| H A D | vnc.c | 3367 QIOChannelSocket *cioc, in vnc_listen_io() argument
3373 qio_channel_set_name(QIO_CHANNEL(cioc), in vnc_listen_io()
3375 qio_channel_set_delay(QIO_CHANNEL(cioc), false); in vnc_listen_io()
3376 vnc_connect(vd, cioc, false, isWebsock); in vnc_listen_io()
|