| /openbmc/qemu/io/ |
| H A D | net-listener.c | 45 QIOChannelSocket *sioc; in qio_net_listener_channel_func() local
47 sioc = qio_channel_socket_accept(QIO_CHANNEL_SOCKET(ioc), in qio_net_listener_channel_func()
49 if (!sioc) { in qio_net_listener_channel_func()
54 listener->io_func(listener, sioc, listener->io_data); in qio_net_listener_channel_func()
57 object_unref(OBJECT(sioc)); in qio_net_listener_channel_func()
84 QIOChannelSocket *sioc = qio_channel_socket_new(); in qio_net_listener_open_sync() local
86 if (qio_channel_socket_listen_sync(sioc, resaddrs[i], num, in qio_net_listener_open_sync()
90 qio_net_listener_add(listener, sioc); in qio_net_listener_open_sync()
94 object_unref(OBJECT(sioc)); in qio_net_listener_open_sync()
109 QIOChannelSocket *sioc) in qio_net_listener_add() argument
[all …]
|
| H A D | channel-socket.c | 61 QIOChannelSocket *sioc; in qio_channel_socket_new() local
64 sioc = QIO_CHANNEL_SOCKET(object_new(TYPE_QIO_CHANNEL_SOCKET)); in qio_channel_socket_new()
65 sioc->fd = -1; in qio_channel_socket_new()
66 sioc->zero_copy_queued = 0; in qio_channel_socket_new()
67 sioc->zero_copy_sent = 0; in qio_channel_socket_new()
69 ioc = QIO_CHANNEL(sioc); in qio_channel_socket_new()
76 trace_qio_channel_socket_new(sioc); in qio_channel_socket_new()
78 return sioc; in qio_channel_socket_new()
83 qio_channel_socket_set_fd(QIOChannelSocket *sioc, in qio_channel_socket_set_fd() argument
87 if (sioc->fd != -1) { in qio_channel_socket_set_fd()
[all …]
|
| /openbmc/qemu/nbd/ |
| H A D | client-connection.c | 51 QIOChannelSocket *sioc; member
109 if (conn->sioc) { in nbd_client_connection_do_free()
110 qio_channel_close(QIO_CHANNEL(conn->sioc), NULL); in nbd_client_connection_do_free()
111 object_unref(OBJECT(conn->sioc)); in nbd_client_connection_do_free()
127 static int nbd_connect(QIOChannelSocket *sioc, SocketAddress *addr, in nbd_connect() argument
138 ret = qio_channel_socket_connect_sync(sioc, addr, errp); in nbd_connect()
143 qio_channel_set_delay(QIO_CHANNEL(sioc), false); in nbd_connect()
149 ret = nbd_receive_negotiate(QIO_CHANNEL(sioc), tlscreds, tlshostname, in nbd_connect()
162 qio_channel_close(QIO_CHANNEL(sioc), NULL); in nbd_connect()
183 assert(!conn->sioc); in connect_thread_func()
[all …]
|
| H A D | client.c | 1172 QIOChannel *sioc = NULL; in nbd_receive_export_list() local
1175 result = nbd_start_negotiate(ioc, tlscreds, hostname, &sioc, in nbd_receive_export_list()
1177 if (tlscreds && sioc) { in nbd_receive_export_list()
1178 ioc = sioc; in nbd_receive_export_list()
1267 object_unref(OBJECT(sioc)); in nbd_receive_export_list()
1273 int nbd_init(int fd, QIOChannelSocket *sioc, NBDExportInfo *info, in nbd_init() argument
1291 if (ioctl(fd, NBD_SET_SOCK, (unsigned long) sioc->fd) < 0) { in nbd_init()
|
| H A D | server.c | 135 QIOChannelSocket *sioc; /* The underlying data channel */ member
1236 client->ioc == (QIOChannel *)client->sioc) { in nbd_negotiate_options()
1573 object_unref(OBJECT(client->sioc)); in nbd_client_put()
3223 client->sioc); in nbd_co_client_start()
3250 void nbd_client_new(QIOChannelSocket *sioc, in nbd_client_new() argument
3269 client->sioc = sioc; in nbd_client_new()
3270 qio_channel_set_delay(QIO_CHANNEL(sioc), false); in nbd_client_new()
3271 object_ref(OBJECT(client->sioc)); in nbd_client_new()
3272 client->ioc = QIO_CHANNEL(sioc); in nbd_client_new()
|
| /openbmc/qemu/migration/ |
| H A D | socket.c | 40 QIOChannelSocket *sioc = qio_channel_socket_new(); in socket_send_channel_create() local
41 qio_channel_socket_connect_async(sioc, outgoing_args.saddr, in socket_send_channel_create()
64 QIOChannel *sioc = QIO_CHANNEL(qio_task_get_source(task)); in socket_outgoing_migration() local
75 !qio_channel_has_feature(sioc, QIO_CHANNEL_FEATURE_WRITE_ZERO_COPY)) { in socket_outgoing_migration()
80 migration_channel_connect(data->s, sioc, data->hostname, err); in socket_outgoing_migration()
81 object_unref(OBJECT(sioc)); in socket_outgoing_migration()
88 QIOChannelSocket *sioc = qio_channel_socket_new(); in socket_start_outgoing_migration() local
102 qio_channel_set_name(QIO_CHANNEL(sioc), "migration-socket-outgoing"); in socket_start_outgoing_migration()
103 qio_channel_socket_connect_async(sioc, in socket_start_outgoing_migration()
175 qio_channel_socket_get_local_address(listener->sioc[i], errp); in socket_start_incoming_migration()
|
| /openbmc/qemu/chardev/ |
| H A D | char-socket.c | 386 QIO_CHANNEL(s->sioc)); in tcp_chr_free_connection()
392 object_unref(OBJECT(s->sioc)); in tcp_chr_free_connection()
393 s->sioc = NULL; in tcp_chr_free_connection()
564 struct sockaddr_storage *ss = &s->sioc->localAddr; in qemu_chr_compute_filename()
565 struct sockaddr_storage *ps = &s->sioc->remoteAddr; in qemu_chr_compute_filename()
566 socklen_t ss_len = s->sioc->localAddrLen; in qemu_chr_compute_filename()
567 socklen_t ps_len = s->sioc->remoteAddrLen; in qemu_chr_compute_filename()
877 QIOChannelSocket *sioc) in tcp_chr_set_client_ioc_name() argument
884 qio_channel_set_name(QIO_CHANNEL(sioc), name); in tcp_chr_set_client_ioc_name()
889 static int tcp_chr_new_client(Chardev *chr, QIOChannelSocket *sioc) in tcp_chr_new_client() argument
[all …]
|
| H A D | char-udp.c | 200 QIOChannelSocket *sioc = qio_channel_socket_new(); in qmp_chardev_open_udp() local
205 ret = qio_channel_socket_dgram_sync(sioc, local_addr, remote_addr, errp); in qmp_chardev_open_udp()
209 object_unref(OBJECT(sioc)); in qmp_chardev_open_udp()
214 qio_channel_set_name(QIO_CHANNEL(sioc), name); in qmp_chardev_open_udp()
217 s->ioc = QIO_CHANNEL(sioc); in qmp_chardev_open_udp()
|
| /openbmc/qemu/target/i386/kvm/ |
| H A D | vmsr_energy.c | 69 QIOChannelSocket *sioc = qio_channel_socket_new(); in vmsr_open_socket() local
72 qio_channel_set_name(QIO_CHANNEL(sioc), "vmsr-helper"); in vmsr_open_socket()
73 qio_channel_socket_connect_sync(sioc, in vmsr_open_socket()
78 qio_channel_close(QIO_CHANNEL(sioc), NULL); in vmsr_open_socket()
79 object_unref(OBJECT(sioc)); in vmsr_open_socket()
80 sioc = NULL; in vmsr_open_socket()
84 qio_channel_set_delay(QIO_CHANNEL(sioc), false); in vmsr_open_socket()
86 return sioc; in vmsr_open_socket()
90 QIOChannelSocket *sioc) in vmsr_read_msr() argument
106 r = qio_channel_write_all(QIO_CHANNEL(sioc), in vmsr_read_msr()
[all …]
|
| H A D | vmsr_energy.h | 85 uint32_t tid, QIOChannelSocket *sioc);
|
| /openbmc/qemu/util/ |
| H A D | vhost-user-server.c | 240 object_unref(OBJECT(server->sioc)); in vu_client_trip()
241 server->sioc = NULL; in vu_client_trip()
335 static void vu_accept(QIONetListener *listener, QIOChannelSocket *sioc, in vu_accept() argument
340 if (server->sioc) { in vu_accept()
346 if (!vu_init(&server->vu_dev, server->max_queues, sioc->fd, panic_cb, in vu_accept()
360 server->sioc = sioc; in vu_accept()
365 object_ref(OBJECT(server->sioc)); in vu_accept()
366 qio_channel_set_name(QIO_CHANNEL(sioc), "vhost-user client"); in vu_accept()
367 server->ioc = QIO_CHANNEL(sioc); in vu_accept()
384 if (server->sioc) { in vhost_user_server_stop()
[all …]
|
| /openbmc/qemu/net/ |
| H A D | stream.c | 328 QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(s->ioc); in net_stream_client_connected() local
340 addr = qio_channel_socket_get_remote_address(sioc, NULL); in net_stream_client_connected()
346 ret = qemu_socket_try_set_nonblock(sioc->fd); in net_stream_client_connected()
376 QIOChannelSocket *sioc; in net_stream_reconnect() local
380 sioc = qio_channel_socket_new(); in net_stream_reconnect()
381 s->ioc = QIO_CHANNEL(sioc); in net_stream_reconnect()
382 qio_channel_socket_connect_async(sioc, s->addr, in net_stream_reconnect()
405 QIOChannelSocket *sioc = qio_channel_socket_new(); in net_stream_client_init() local
411 s->ioc = QIO_CHANNEL(sioc); in net_stream_client_init()
418 qio_channel_socket_connect_async(sioc, addr, in net_stream_client_init()
|
| /openbmc/qemu/ |
| H A D | qemu-nbd.c | 187 QIOChannelSocket *sioc; in qemu_nbd_client_list() local
191 sioc = qio_channel_socket_new(); in qemu_nbd_client_list()
192 if (qio_channel_socket_connect_sync(sioc, saddr, &err) < 0) { in qemu_nbd_client_list()
196 rc = nbd_receive_export_list(QIO_CHANNEL(sioc), tls, hostname, &list, in qemu_nbd_client_list()
254 object_unref(OBJECT(sioc)); in qemu_nbd_client_list()
306 QIOChannelSocket *sioc; in nbd_client_thread() local
312 sioc = qio_channel_socket_new(); in nbd_client_thread()
313 if (qio_channel_socket_connect_sync(sioc, in nbd_client_thread()
320 if (nbd_receive_negotiate(QIO_CHANNEL(sioc), NULL, NULL, NULL, in nbd_client_thread()
335 if (nbd_init(fd, sioc, &info, &local_error) < 0) { in nbd_client_thread()
[all …]
|
| /openbmc/qemu/include/io/ |
| H A D | net-listener.h | 33 QIOChannelSocket *sioc,
50 QIOChannelSocket **sioc; member
114 QIOChannelSocket *sioc);
|
| /openbmc/qemu/ui/ |
| H A D | input-barrier.c | 37 QIOChannelSocket *sioc; member
209 ret = qio_channel_read(QIO_CHANNEL(ib->sioc), (char *)&len, sizeof(len), in readcmd()
220 ret = qio_channel_read(QIO_CHANNEL(ib->sioc), ib->buffer, len, NULL); in readcmd()
463 ret = qio_channel_write(QIO_CHANNEL(ib->sioc), ib->buffer, in writecmd()
506 ib->sioc = qio_channel_socket_new(); in input_barrier_complete()
507 qio_channel_set_name(QIO_CHANNEL(ib->sioc), "barrier-client"); in input_barrier_complete()
509 qio_channel_socket_connect_sync(ib->sioc, &ib->saddr, &local_err); in input_barrier_complete()
515 qio_channel_set_delay(QIO_CHANNEL(ib->sioc), false); in input_barrier_complete()
517 ib->ioc_tag = qio_channel_add_watch(QIO_CHANNEL(ib->sioc), G_IO_IN, in input_barrier_complete()
530 if (ib->sioc) { in input_barrier_instance_finalize()
[all …]
|
| H A D | vnc.c | 245 vnc_init_basic_info_from_server_addr(vd->listener->sioc[0], in vnc_server_info_get()
279 vnc_init_basic_info_from_remote_addr(client->sioc, in vnc_client_cache_addr()
327 vnc_init_basic_info_from_remote_addr(client->sioc, in qmp_query_vnc_client()
391 addr = qio_channel_socket_get_local_address(vd->listener->sioc[0], in qmp_query_vnc()
566 vd->listener->sioc[i], false, vd->auth, vd->subauth, in qmp_query_vnc_servers()
571 vd->wslistener->sioc[i], true, vd->ws_auth, in qmp_query_vnc_servers()
1362 object_unref(OBJECT(vs->sioc)); in vnc_disconnect_finish()
1363 vs->sioc = NULL; in vnc_disconnect_finish()
3242 static void vnc_connect(VncDisplay *vd, QIOChannelSocket *sioc, in vnc_connect() argument
3249 trace_vnc_client_connect(vs, sioc); in vnc_connect()
[all …]
|
| H A D | vnc-auth-sasl.c | 585 if (vnc_socket_ip_addr_string(vs->sioc, true, in start_auth_sasl()
592 if (vnc_socket_ip_addr_string(vs->sioc, false, in start_auth_sasl()
645 vs->sasl.wantSSF = !vnc_socket_is_unix(vs->sioc); in start_auth_sasl()
655 if (vnc_socket_is_unix(vs->sioc) || in start_auth_sasl()
|
| H A D | vnc-jobs.c | 182 local->sioc = NULL; /* Don't do any network work on this thread */ in vnc_async_encoding_start()
|
| /openbmc/qemu/scsi/ |
| H A D | pr-manager-helper.c | 107 QIOChannelSocket *sioc = qio_channel_socket_new(); in pr_manager_helper_initialize() local
114 qio_channel_set_name(QIO_CHANNEL(sioc), "pr-manager-helper"); in pr_manager_helper_initialize()
115 qio_channel_socket_connect_sync(sioc, in pr_manager_helper_initialize()
120 object_unref(OBJECT(sioc)); in pr_manager_helper_initialize()
125 qio_channel_set_delay(QIO_CHANNEL(sioc), false); in pr_manager_helper_initialize()
126 pr_mgr->ioc = QIO_CHANNEL(sioc); in pr_manager_helper_initialize()
|
| /openbmc/linux/net/atm/ |
| H A D | ioctl.c | 203 struct atmif_sioc __user *sioc = argp; in do_vcc_ioctl() local
205 len = &sioc->length; in do_vcc_ioctl()
206 if (get_user(buf, &sioc->arg)) in do_vcc_ioctl()
208 if (get_user(number, &sioc->number)) in do_vcc_ioctl()
|
| /openbmc/qemu/include/chardev/ |
| H A D | char-socket.h | 52 QIOChannelSocket *sioc; /* Client master channel */ member
|
| /openbmc/qemu/include/qemu/ |
| H A D | vhost-user-server.h | 51 QIOChannelSocket *sioc; /* The underlying data channel with the client */ member
|
| /openbmc/qemu/include/block/ |
| H A D | nbd.h | 403 int nbd_init(int fd, QIOChannelSocket *sioc, NBDExportInfo *info,
418 void nbd_client_new(QIOChannelSocket *sioc,
|
| /openbmc/qemu/include/sysemu/ |
| H A D | kvm_int.h | 72 QIOChannelSocket *sioc; member
|
| /openbmc/qemu/block/export/ |
| H A D | vhost-user-blk-server.c | 39 QIOChannelSocket *sioc; member
|