534     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(  in qio_channel_websock_handshake_send()  local
539     ret = qio_channel_write(wioc->master,  in qio_channel_websock_handshake_send()
540                             (char *)wioc->encoutput.buffer,  in qio_channel_websock_handshake_send()
541                             wioc->encoutput.offset,  in qio_channel_websock_handshake_send()
551     buffer_advance(&wioc->encoutput, ret);  in qio_channel_websock_handshake_send()
552     if (wioc->encoutput.offset == 0) {  in qio_channel_websock_handshake_send()
553         if (wioc->io_err) {  in qio_channel_websock_handshake_send()
555                 ioc, error_get_pretty(wioc->io_err));  in qio_channel_websock_handshake_send()
556             qio_task_set_error(task, wioc->io_err);  in qio_channel_websock_handshake_send()
557             wioc->io_err = NULL;  in qio_channel_websock_handshake_send()
574     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(  in qio_channel_websock_handshake_io()  local
579     ret = qio_channel_websock_handshake_read(wioc, &err);  in qio_channel_websock_handshake_io()
597     error_propagate(&wioc->io_err, err);  in qio_channel_websock_handshake_io()
601         wioc->master,  in qio_channel_websock_handshake_io()
879     QIOChannelWebsock *wioc;  in qio_channel_websock_new_server()  local
882     wioc = QIO_CHANNEL_WEBSOCK(object_new(TYPE_QIO_CHANNEL_WEBSOCK));  in qio_channel_websock_new_server()
883     ioc = QIO_CHANNEL(wioc);  in qio_channel_websock_new_server()
885     wioc->master = master;  in qio_channel_websock_new_server()
892     trace_qio_channel_websock_new_server(wioc, master);  in qio_channel_websock_new_server()
893     return wioc;  in qio_channel_websock_new_server()
1009     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(user_data);  in qio_channel_websock_flush_free()  local
1010     object_unref(OBJECT(wioc));  in qio_channel_websock_flush_free()
1019     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(user_data);  in qio_channel_websock_flush()  local
1023         ret = qio_channel_websock_write_wire(wioc, &wioc->io_err);  in qio_channel_websock_flush()
1030         ret = qio_channel_websock_read_wire(wioc, &wioc->io_err);  in qio_channel_websock_flush()
1037     qio_channel_websock_set_watch(wioc);  in qio_channel_websock_flush()
1088     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(ioc);  in qio_channel_websock_readv()  local
1093     if (wioc->io_err) {  in qio_channel_websock_readv()
1094         error_propagate(errp, error_copy(wioc->io_err));  in qio_channel_websock_readv()
1098     if (!wioc->rawinput.offset) {  in qio_channel_websock_readv()
1107         if (want > (wioc->rawinput.offset - got)) {  in qio_channel_websock_readv()
1108             want = (wioc->rawinput.offset - got);  in qio_channel_websock_readv()
1112                wioc->rawinput.buffer + got,  in qio_channel_websock_readv()
1121     buffer_advance(&wioc->rawinput, got);  in qio_channel_websock_readv()
1122     qio_channel_websock_set_watch(wioc);  in qio_channel_websock_readv()
1135     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(ioc);  in qio_channel_websock_writev()  local
1140     if (wioc->io_err) {  in qio_channel_websock_writev()
1141         error_propagate(errp, error_copy(wioc->io_err));  in qio_channel_websock_writev()
1145     if (wioc->io_eof) {  in qio_channel_websock_writev()
1150     avail = wioc->encoutput.offset >= QIO_CHANNEL_WEBSOCK_MAX_BUFFER ?  in qio_channel_websock_writev()
1151         0 : (QIO_CHANNEL_WEBSOCK_MAX_BUFFER - wioc->encoutput.offset);  in qio_channel_websock_writev()
1157         qio_channel_websock_encode(wioc,  in qio_channel_websock_writev()
1165     ret = qio_channel_websock_write_wire(wioc, errp);  in qio_channel_websock_writev()
1168         qio_channel_websock_unset_watch(wioc);  in qio_channel_websock_writev()
1172     qio_channel_websock_set_watch(wioc);  in qio_channel_websock_writev()
1185     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(ioc);  in qio_channel_websock_set_blocking()  local
1187     qio_channel_set_blocking(wioc->master, enabled, errp);  in qio_channel_websock_set_blocking()
1219     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(ioc);  in qio_channel_websock_close()  local
1222     return qio_channel_close(wioc->master, errp);  in qio_channel_websock_close()
1228     QIOChannelWebsock *wioc;  member
1238     if (wsource->wioc->rawinput.offset) {  in qio_channel_websock_source_check()
1241     if (wsource->wioc->encoutput.offset < QIO_CHANNEL_WEBSOCK_MAX_BUFFER) {  in qio_channel_websock_source_check()
1244     if (wsource->wioc->io_eof) {  in qio_channel_websock_source_check()
1247     if (wsource->wioc->io_err) {  in qio_channel_websock_source_check()
1270     return (*func)(QIO_CHANNEL(wsource->wioc),  in qio_channel_websock_source_dispatch()
1280     object_unref(OBJECT(ssource->wioc));  in qio_channel_websock_source_finalize()
1293     QIOChannelWebsock *wioc = QIO_CHANNEL_WEBSOCK(ioc);  in qio_channel_websock_create_watch()  local
1301     ssource->wioc = wioc;  in qio_channel_websock_create_watch()
1302     object_ref(OBJECT(wioc));  in qio_channel_websock_create_watch()
1306     qio_channel_websock_set_watch(wioc);  in qio_channel_websock_create_watch()