| /qemu/io/ |
| H A D | channel.c | 46 g_free(ioc->name); in qio_channel_set_name()
47 ioc->name = g_strdup(name); in qio_channel_set_name()
388 if (ioc->name) { in qio_channel_create_watch()
624 ioc->read_ctx = ctx; in qio_channel_set_fd_handlers()
636 if (ioc->write_coroutine && ioc->write_ctx == ctx) { in qio_channel_set_fd_handlers()
645 if (ioc->read_coroutine && ioc->read_ctx == ctx) { in qio_channel_set_fd_handlers()
667 ctx = ioc->read_ctx; in qio_channel_clear_fd_handlers()
670 if (ioc->write_coroutine && ioc->write_ctx == ctx) { in qio_channel_clear_fd_handlers()
678 if (ioc->read_coroutine && ioc->read_ctx == ctx) { in qio_channel_clear_fd_handlers()
770 g_free(ioc->name); in qio_channel_finalize()
[all …]
|
| H A D | trace-events | 14 qio_channel_null_new(void *ioc) "Null new ioc=%p"
17 qio_channel_socket_new(void *ioc) "Socket new ioc=%p"
18 qio_channel_socket_new_fd(void *ioc, int fd) "Socket new ioc=%p fd=%d"
21 qio_channel_socket_connect_fail(void *ioc) "Socket connect fail ioc=%p"
25 qio_channel_socket_listen_fail(void *ioc) "Socket listen fail ioc=%p"
29 qio_channel_socket_dgram_fail(void *ioc) "Socket dgram fail ioc=%p"
31 qio_channel_socket_accept(void *ioc) "Socket accept start ioc=%p"
32 qio_channel_socket_accept_fail(void *ioc) "Socket accept fail ioc=%p"
36 qio_channel_file_new_fd(void *ioc, int fd) "File new fd ioc=%p fd=%d"
44 qio_channel_tls_handshake_fail(void *ioc) "TLS handshake fail ioc=%p"
[all …]
|
| H A D | channel-websock.c | 785 ioc, header_size, ioc->payload_remain, ioc->mask.u); in qio_channel_websock_decode_header()
803 if (ioc->encinput.offset < ioc->payload_remain) { in qio_channel_websock_decode_payload()
827 ioc->encinput.buffer[i] ^= ioc->mask.c[i % 4]; in qio_channel_websock_decode_payload()
832 ioc, ioc->opcode, ioc->payload_remain); in qio_channel_websock_decode_payload()
865 ioc->pong_remain = ioc->encoutput.offset; in qio_channel_websock_decode_payload()
880 QIOChannel *ioc; in qio_channel_websock_new_server() local
925 if (ioc->io_tag) { in qio_channel_websock_finalize()
928 if (ioc->io_err) { in qio_channel_websock_finalize()
1043 if (ioc->io_tag) { in qio_channel_websock_unset_watch()
1055 if (ioc->io_err) { in qio_channel_websock_set_watch()
[all …]
|
| H A D | channel-command.c | 59 ioc->readfd = readfd; in qio_channel_command_new_pid()
61 ioc->pid = pid; in qio_channel_command_new_pid()
70 return ioc; in qio_channel_command_new_pid()
110 trace_qio_channel_command_abort(ioc, ioc->pid); in qio_channel_command_abort()
112 trace_qio_channel_command_wait(ioc, ioc->pid, ret, status); in qio_channel_command_abort()
163 ioc->readfd = -1; in qio_channel_command_init()
164 ioc->writefd = -1; in qio_channel_command_init()
165 ioc->pid = 0; in qio_channel_command_init()
175 ioc->writefd != ioc->readfd) { in qio_channel_command_finalize()
178 ioc->writefd = ioc->readfd = -1; in qio_channel_command_finalize()
[all …]
|
| H A D | channel-file.c | 33 QIOChannelFile *ioc; in qio_channel_file_new_fd() local
37 ioc->fd = fd; in qio_channel_file_new_fd()
45 return ioc; in qio_channel_file_new_fd()
67 QIOChannelFile *ioc; in qio_channel_file_new_path() local
72 if (ioc->fd < 0) { in qio_channel_file_new_path()
83 trace_qio_channel_file_new_path(ioc, path, flags, mode, ioc->fd); in qio_channel_file_new_path()
85 return ioc; in qio_channel_file_new_path()
92 ioc->fd = -1; in qio_channel_file_init()
98 if (ioc->fd != -1) { in qio_channel_file_finalize()
99 qemu_close(ioc->fd); in qio_channel_file_finalize()
[all …]
|
| H A D | channel-socket.c | 62 QIOChannel *ioc; in qio_channel_socket_new() local
69 ioc = QIO_CHANNEL(sioc); in qio_channel_socket_new()
134 QIOChannelSocket *ioc; in qio_channel_socket_new_fd() local
136 ioc = qio_channel_socket_new(); in qio_channel_socket_new_fd()
138 object_unref(OBJECT(ioc)); in qio_channel_socket_new_fd()
144 return ioc; in qio_channel_socket_new_fd()
387 trace_qio_channel_socket_accept(ioc); in qio_channel_socket_accept()
427 ioc->fd = -1; in qio_channel_socket_init()
434 if (ioc->fd != -1) { in qio_channel_socket_finalize()
448 close(ioc->fd); in qio_channel_socket_finalize()
[all …]
|
| H A D | channel-tls.c | 72 QIOChannelTLS *ioc; in qio_channel_tls_new_server() local
76 ioc->master = master; in qio_channel_tls_new_server()
88 if (!ioc->session) { in qio_channel_tls_new_server()
93 ioc->session, in qio_channel_tls_new_server()
96 ioc); in qio_channel_tls_new_server()
99 return ioc; in qio_channel_tls_new_server()
102 object_unref(OBJECT(ioc)); in qio_channel_tls_new_server()
113 QIOChannel *ioc; in qio_channel_tls_new_client() local
116 ioc = QIO_CHANNEL(tioc); in qio_channel_tls_new_client()
201 ioc->hs_ioc_tag = in qio_channel_tls_handshake_task()
[all …]
|
| H A D | channel-null.c | 31 QIOChannel *ioc; member
39 QIOChannelNull *ioc; in qio_channel_null_new() local
43 trace_qio_channel_null_new(ioc); in qio_channel_null_new()
45 return ioc; in qio_channel_null_new()
53 ioc->closed = false; in qio_channel_null_init()
58 qio_channel_null_readv(QIOChannel *ioc, in qio_channel_null_readv() argument
79 qio_channel_null_writev(QIOChannel *ioc, in qio_channel_null_writev() argument
119 qio_channel_null_close(QIOChannel *ioc, in qio_channel_null_close() argument
165 return (*func)(ssource->ioc, in qio_channel_null_source_dispatch()
199 ssource->ioc = ioc; in qio_channel_null_create_watch()
[all …]
|
| H A D | channel-watch.c | 28 QIOChannel *ioc; member
38 QIOChannel *ioc; member
52 QIOChannel *ioc; member
84 return (*func)(ssource->ioc, in qio_channel_fd_source_dispatch()
217 return (*func)(ssource->ioc, in qio_channel_fd_pair_source_dispatch()
259 ssource->ioc = ioc; in qio_channel_create_fd_watch()
260 object_ref(OBJECT(ioc)); in qio_channel_create_fd_watch()
292 ssource->ioc = ioc; in qio_channel_create_socket_watch()
293 object_ref(OBJECT(ioc)); in qio_channel_create_socket_watch()
327 ssource->ioc = ioc; in qio_channel_create_fd_pair_watch()
[all …]
|
| H A D | channel-buffer.c | 31 QIOChannelBuffer *ioc; in qio_channel_buffer_new() local
36 ioc->data = g_new0(uint8_t, capacity); in qio_channel_buffer_new()
37 ioc->capacity = capacity; in qio_channel_buffer_new()
40 return ioc; in qio_channel_buffer_new()
46 QIOChannelBuffer *ioc = QIO_CHANNEL_BUFFER(obj); in qio_channel_buffer_finalize() local
47 g_free(ioc->data); in qio_channel_buffer_finalize()
48 ioc->capacity = ioc->usage = ioc->offset = 0; in qio_channel_buffer_finalize()
60 QIOChannelBuffer *bioc = QIO_CHANNEL_BUFFER(ioc); in qio_channel_buffer_readv()
88 QIOChannelBuffer *bioc = QIO_CHANNEL_BUFFER(ioc); in qio_channel_buffer_writev()
127 static off_t qio_channel_buffer_seek(QIOChannel *ioc, in qio_channel_buffer_seek() argument
[all …]
|
| /qemu/include/io/ |
| H A D | channel.h | 111 ssize_t (*io_writev)(QIOChannel *ioc,
118 ssize_t (*io_readv)(QIOChannel *ioc,
125 int (*io_close)(QIOChannel *ioc,
139 ssize_t (*io_preadv)(QIOChannel *ioc,
144 int (*io_shutdown)(QIOChannel *ioc,
147 void (*io_set_cork)(QIOChannel *ioc,
149 void (*io_set_delay)(QIOChannel *ioc,
151 off_t (*io_seek)(QIOChannel *ioc,
161 int (*io_flush)(QIOChannel *ioc,
539 int qio_channel_close(QIOChannel *ioc,
[all …]
|
| H A D | channel-socket.h | 94 int qio_channel_socket_connect_sync(QIOChannelSocket *ioc,
115 void qio_channel_socket_connect_async(QIOChannelSocket *ioc,
135 int qio_channel_socket_listen_sync(QIOChannelSocket *ioc,
158 void qio_channel_socket_listen_async(QIOChannelSocket *ioc,
180 int qio_channel_socket_dgram_sync(QIOChannelSocket *ioc,
205 void qio_channel_socket_dgram_async(QIOChannelSocket *ioc,
228 qio_channel_socket_get_local_address(QIOChannelSocket *ioc,
245 qio_channel_socket_get_remote_address(QIOChannelSocket *ioc,
261 qio_channel_socket_accept(QIOChannelSocket *ioc,
|
| /qemu/nbd/ |
| H A D | client.c | 119 nbd_send_opt_abort(ioc); in nbd_receive_option_reply()
133 nbd_send_opt_abort(ioc); in nbd_receive_option_reply()
140 nbd_send_opt_abort(ioc); in nbd_receive_option_reply()
237 nbd_send_opt_abort(ioc); in nbd_handle_reply_err()
280 nbd_send_opt_abort(ioc); in nbd_receive_list()
286 nbd_send_opt_abort(ioc); in nbd_receive_list()
290 nbd_send_opt_abort(ioc); in nbd_receive_list()
296 nbd_send_opt_abort(ioc); in nbd_receive_list()
967 ioc = *outioc; in nbd_start_negotiate()
1061 ioc = *outioc; in nbd_receive_negotiate()
[all …]
|
| /qemu/migration/ |
| H A D | channel.c | 33 void migration_channel_process_incoming(QIOChannel *ioc) in migration_channel_process_incoming() argument
39 ioc, object_get_typename(OBJECT(ioc))); in migration_channel_process_incoming()
41 if (migrate_channel_requires_tls_upgrade(ioc)) { in migration_channel_process_incoming()
44 migration_ioc_register_yank(ioc); in migration_channel_process_incoming()
45 migration_ioc_process_incoming(ioc, &local_err); in migration_channel_process_incoming()
63 QIOChannel *ioc, in migration_channel_connect() argument
68 ioc, object_get_typename(OBJECT(ioc)), hostname, error); in migration_channel_connect()
71 if (migrate_channel_requires_tls_upgrade(ioc)) { in migration_channel_connect()
83 QEMUFile *f = qemu_file_new_output(ioc); in migration_channel_connect()
85 migration_ioc_register_yank(ioc); in migration_channel_connect()
[all …]
|
| H A D | yank_functions.c | 18 QIOChannel *ioc = QIO_CHANNEL(opaque); in migration_yank_iochannel() local
24 static bool migration_ioc_yank_supported(QIOChannel *ioc) in migration_ioc_yank_supported() argument
29 void migration_ioc_register_yank(QIOChannel *ioc) in migration_ioc_register_yank() argument
31 if (migration_ioc_yank_supported(ioc)) { in migration_ioc_register_yank()
34 ioc); in migration_ioc_register_yank()
38 void migration_ioc_unregister_yank(QIOChannel *ioc) in migration_ioc_unregister_yank() argument
40 if (migration_ioc_yank_supported(ioc)) { in migration_ioc_unregister_yank()
43 ioc); in migration_ioc_unregister_yank()
49 QIOChannel *ioc = qemu_file_get_ioc(file); in migration_ioc_unregister_yank_from_file() local
51 if (ioc) { in migration_ioc_unregister_yank_from_file()
[all …]
|
| H A D | fd.c | 31 QIOChannel *ioc; in fd_start_outgoing_migration() local
43 ioc = qio_channel_new_fd(fd, errp); in fd_start_outgoing_migration()
44 if (!ioc) { in fd_start_outgoing_migration()
50 migration_channel_connect(s, ioc, NULL, NULL); in fd_start_outgoing_migration()
51 object_unref(OBJECT(ioc)); in fd_start_outgoing_migration()
58 migration_channel_process_incoming(ioc); in fd_accept_incoming_migration()
59 object_unref(OBJECT(ioc)); in fd_accept_incoming_migration()
65 QIOChannel *ioc; in fd_start_incoming_migration() local
78 ioc = qio_channel_new_fd(fd, errp); in fd_start_incoming_migration()
79 if (!ioc) { in fd_start_incoming_migration()
[all …]
|
| H A D | exec.c | 46 QIOChannel *ioc = NULL; in exec_start_outgoing_migration() local
53 if (!ioc) { in exec_start_outgoing_migration()
57 qio_channel_set_name(ioc, "migration-exec-outgoing"); in exec_start_outgoing_migration()
58 migration_channel_connect(s, ioc, NULL, NULL); in exec_start_outgoing_migration()
59 object_unref(OBJECT(ioc)); in exec_start_outgoing_migration()
66 migration_channel_process_incoming(ioc); in exec_accept_incoming_migration()
67 object_unref(OBJECT(ioc)); in exec_accept_incoming_migration()
73 QIOChannel *ioc; in exec_start_incoming_migration() local
80 if (!ioc) { in exec_start_incoming_migration()
84 qio_channel_set_name(ioc, "migration-exec-incoming"); in exec_start_incoming_migration()
[all …]
|
| H A D | channel-block.c | 30 QIOChannelBlock *ioc; in qio_channel_block_new() local
35 ioc->bs = bs; in qio_channel_block_new()
37 return ioc; in qio_channel_block_new()
44 QIOChannelBlock *ioc = QIO_CHANNEL_BLOCK(obj); in qio_channel_block_finalize() local
46 g_clear_pointer(&ioc->bs, bdrv_unref); in qio_channel_block_finalize()
51 qio_channel_block_readv(QIOChannel *ioc, in qio_channel_block_readv() argument
59 QIOChannelBlock *bioc = QIO_CHANNEL_BLOCK(ioc); in qio_channel_block_readv()
76 qio_channel_block_writev(QIOChannel *ioc, in qio_channel_block_writev() argument
101 qio_channel_block_set_blocking(QIOChannel *ioc, in qio_channel_block_set_blocking() argument
114 qio_channel_block_seek(QIOChannel *ioc, in qio_channel_block_seek() argument
[all …]
|
| H A D | tls.c | 61 QIOChannel *ioc = QIO_CHANNEL(qio_task_get_source(task)); in migration_tls_incoming_handshake() local
69 migration_channel_process_incoming(ioc); in migration_tls_incoming_handshake()
71 object_unref(OBJECT(ioc)); in migration_tls_incoming_handshake()
75 QIOChannel *ioc, in migration_tls_channel_process_incoming() argument
105 QIOChannel *ioc = QIO_CHANNEL(qio_task_get_source(task)); in migration_tls_outgoing_handshake() local
113 migration_channel_connect(s, ioc, NULL, err); in migration_tls_outgoing_handshake()
114 object_unref(OBJECT(ioc)); in migration_tls_outgoing_handshake()
117 QIOChannelTLS *migration_tls_client_create(QIOChannel *ioc, in migration_tls_client_create() argument
137 QIOChannel *ioc, in migration_tls_channel_connect() argument
143 tioc = migration_tls_client_create(ioc, hostname, errp); in migration_tls_channel_connect()
[all …]
|
| H A D | file.c | 55 QIOChannelFile *ioc; in file_send_channel_create() local
60 if (!ioc) { in file_send_channel_create()
65 multifd_channel_connect(opaque, QIO_CHANNEL(ioc)); in file_send_channel_create()
83 QIOChannel *ioc; in file_start_outgoing_migration() local
95 ioc = QIO_CHANNEL(fioc); in file_start_outgoing_migration()
99 qio_channel_set_name(ioc, "migration-file-outgoing"); in file_start_outgoing_migration()
100 migration_channel_connect(s, ioc, NULL, NULL); in file_start_outgoing_migration()
107 migration_channel_process_incoming(ioc); in file_accept_incoming_migration()
108 object_unref(OBJECT(ioc)); in file_accept_incoming_migration()
122 fd = QIO_CHANNEL_FILE(ioc)->fd; in file_create_incoming_channels()
[all …]
|
| /qemu/tests/qtest/ |
| H A D | tpm-emu.c | 39 static void tpm_emu_close_ioc(void *ioc) in tpm_emu_close_ioc() argument
41 qio_channel_close(ioc, NULL); in tpm_emu_close_ioc()
47 QIOChannel *ioc = s->tpm_ioc; in tpm_emu_tpm_thread() local
49 qtest_add_abrt_handler(tpm_emu_close_ioc, ioc); in tpm_emu_tpm_thread()
63 qio_channel_read(ioc, (char *)&s->tpm_msg->code, in tpm_emu_tpm_thread()
87 qtest_remove_abrt_handler(ioc); in tpm_emu_tpm_thread()
98 QIOChannel *ioc; in tpm_emu_ctrl_thread() local
109 g_assert(ioc); in tpm_emu_ctrl_thread()
110 qtest_add_abrt_handler(tpm_emu_close_ioc, ioc); in tpm_emu_ctrl_thread()
202 qtest_remove_abrt_handler(ioc); in tpm_emu_ctrl_thread()
[all …]
|
| /qemu/hw/remote/ |
| H A D | message.c | 23 static void process_config_write(QIOChannel *ioc, PCIDevice *dev,
25 static void process_config_read(QIOChannel *ioc, PCIDevice *dev,
38 assert(com->ioc); in mpqemu_remote_msg_loop_co()
44 if (!mpqemu_msg_recv(&msg, com->ioc, &local_err)) { in mpqemu_remote_msg_loop_co()
63 process_bar_write(com->ioc, &msg, &local_err); in mpqemu_remote_msg_loop_co()
66 process_bar_read(com->ioc, &msg, &local_err); in mpqemu_remote_msg_loop_co()
111 if (!mpqemu_msg_send(&ret, ioc, NULL)) { in process_config_write()
135 if (!mpqemu_msg_send(&ret, ioc, NULL)) { in process_config_read()
172 if (!mpqemu_msg_send(&ret, ioc, NULL)) { in process_bar_write()
209 if (!mpqemu_msg_send(&ret, ioc, NULL)) { in process_bar_read()
[all …]
|
| H A D | remote-obj.c | 44 QIOChannel *ioc; member
94 QIOChannel *ioc = NULL; in remote_object_machine_done() local
105 ioc = qio_channel_new_fd(o->fd, &err); in remote_object_machine_done()
106 if (!ioc) { in remote_object_machine_done()
110 qio_channel_set_blocking(ioc, false, NULL); in remote_object_machine_done()
120 .ioc = ioc, in remote_object_machine_done()
138 o->ioc = NULL; in remote_object_init()
155 if (o->ioc) { in remote_object_finalize()
156 qio_channel_shutdown(o->ioc, QIO_CHANNEL_SHUTDOWN_BOTH, NULL); in remote_object_finalize()
157 qio_channel_close(o->ioc, NULL); in remote_object_finalize()
[all …]
|
| /qemu/ui/ |
| H A D | vnc-ws.c | 43 vs->ioc_tag = qio_channel_add_watch(vs->ioc, in vncws_tls_handshake_done()
69 vs->ioc, in vncws_tls_handshake_io()
82 object_unref(OBJECT(vs->ioc)); in vncws_tls_handshake_io()
83 vs->ioc = QIO_CHANNEL(tls); in vncws_tls_handshake_io()
84 trace_vnc_client_io_wrap(vs, vs->ioc, "tls"); in vncws_tls_handshake_io()
114 vs->ioc, G_IO_IN | G_IO_HUP | G_IO_ERR, in vncws_handshake_done()
120 gboolean vncws_handshake_io(QIOChannel *ioc G_GNUC_UNUSED, in vncws_handshake_io()
137 wioc = qio_channel_websock_new_server(vs->ioc); in vncws_handshake_io()
140 object_unref(OBJECT(vs->ioc)); in vncws_handshake_io()
141 vs->ioc = QIO_CHANNEL(wioc); in vncws_handshake_io()
[all …]
|
| /qemu/net/ |
| H A D | stream.c | 49 QIOChannel *ioc; member
172 object_unref(OBJECT(s->ioc)); in net_stream_send()
173 s->ioc = NULL; in net_stream_send()
205 if (s->ioc) { in net_stream_cleanup()
216 object_unref(OBJECT(s->ioc)); in net_stream_cleanup()
217 s->ioc = NULL; in net_stream_cleanup()
249 s->ioc = QIO_CHANNEL(cioc); in net_stream_listen()
368 object_unref(OBJECT(s->ioc)); in net_stream_client_connected()
369 s->ioc = NULL; in net_stream_client_connected()
381 s->ioc = QIO_CHANNEL(sioc); in net_stream_reconnect()
[all …]
|