Lines Matching full:d
21 NetStreamData *d = data; in net_stream_data_writable() local
23 d->ioc_write_tag = 0; in net_stream_data_writable()
25 qemu_flush_queued_packets(&d->nc); in net_stream_data_writable()
30 ssize_t net_stream_data_receive(NetStreamData *d, const uint8_t *buf, in net_stream_data_receive() argument
48 remaining = iov_size(iov, 2) - d->send_index; in net_stream_data_receive()
49 nlocal_iov = iov_copy(local_iov, 2, iov, 2, d->send_index, remaining); in net_stream_data_receive()
50 ret = qio_channel_writev(d->ioc, local_iov, nlocal_iov, NULL); in net_stream_data_receive()
55 d->send_index = 0; in net_stream_data_receive()
59 d->send_index += ret; in net_stream_data_receive()
60 d->ioc_write_tag = qio_channel_add_watch(d->ioc, G_IO_OUT, in net_stream_data_receive()
61 net_stream_data_writable, d, in net_stream_data_receive()
65 d->send_index = 0; in net_stream_data_receive()
71 NetStreamData *d = DO_UPCAST(NetStreamData, nc, nc); in net_stream_data_send_completed() local
73 if (!d->ioc_read_tag) { in net_stream_data_send_completed()
74 d->ioc_read_tag = qio_channel_add_watch(d->ioc, G_IO_IN, d->send, d, in net_stream_data_send_completed()
81 NetStreamData *d = container_of(rs, NetStreamData, rs); in net_stream_data_rs_finalize() local
83 if (qemu_send_packet_async(&d->nc, rs->buf, in net_stream_data_rs_finalize()
86 if (d->ioc_read_tag) { in net_stream_data_rs_finalize()
87 g_source_remove(d->ioc_read_tag); in net_stream_data_rs_finalize()
88 d->ioc_read_tag = 0; in net_stream_data_rs_finalize()
94 NetStreamData *d) in net_stream_data_send() argument
101 size = qio_channel_read(d->ioc, buf1, sizeof(buf1), NULL); in net_stream_data_send()
109 d->ioc_read_tag = 0; in net_stream_data_send()
110 if (d->ioc_write_tag) { in net_stream_data_send()
111 g_source_remove(d->ioc_write_tag); in net_stream_data_send()
112 d->ioc_write_tag = 0; in net_stream_data_send()
114 if (d->listener) { in net_stream_data_send()
115 qemu_set_info_str(&d->nc, "listening"); in net_stream_data_send()
116 qio_net_listener_set_client_func(d->listener, in net_stream_data_send()
117 d->listen, d, NULL); in net_stream_data_send()
119 object_unref(OBJECT(d->ioc)); in net_stream_data_send()
120 d->ioc = NULL; in net_stream_data_send()
122 net_socket_rs_init(&d->rs, net_stream_data_rs_finalize, false); in net_stream_data_send()
123 d->nc.link_down = true; in net_stream_data_send()
129 ret = net_fill_rstate(&d->rs, (const uint8_t *)buf, size); in net_stream_data_send()
140 NetStreamData *d) in net_stream_data_listen() argument
144 qio_net_listener_set_client_func(d->listener, NULL, d, NULL); in net_stream_data_listen()
146 d->ioc = QIO_CHANNEL(cioc); in net_stream_data_listen()
147 qio_channel_set_name(d->ioc, "stream-server"); in net_stream_data_listen()
148 d->nc.link_down = false; in net_stream_data_listen()
150 d->ioc_read_tag = qio_channel_add_watch(d->ioc, G_IO_IN, d->send, d, NULL); in net_stream_data_listen()
153 int net_stream_data_client_connected(QIOTask *task, NetStreamData *d) in net_stream_data_client_connected() argument
155 QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(d->ioc); in net_stream_data_client_connected()
161 qemu_set_info_str(&d->nc, "error: %s", error_get_pretty(err)); in net_stream_data_client_connected()
171 qemu_set_info_str(&d->nc, "can't use file descriptor %s (errno %d)", in net_stream_data_client_connected()
179 net_socket_rs_init(&d->rs, net_stream_data_rs_finalize, false); in net_stream_data_client_connected()
182 qio_channel_set_delay(d->ioc, false); in net_stream_data_client_connected()
184 d->ioc_read_tag = qio_channel_add_watch(d->ioc, G_IO_IN, d->send, d, NULL); in net_stream_data_client_connected()
185 d->nc.link_down = false; in net_stream_data_client_connected()
189 object_unref(OBJECT(d->ioc)); in net_stream_data_client_connected()
190 d->ioc = NULL; in net_stream_data_client_connected()