Lines Matching refs:encoutput
172 buffer_reserve(&ioc->encoutput, responselen); in qio_channel_websock_handshake_send_res()
173 buffer_append(&ioc->encoutput, response, responselen); in qio_channel_websock_handshake_send_res()
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()
642 buffer_reserve(&ioc->encoutput, header_size + size); in qio_channel_websock_encode()
643 buffer_append(&ioc->encoutput, header.buf, header_size); in qio_channel_websock_encode()
649 buffer_append(&ioc->encoutput, iov[i].iov_base, want); in qio_channel_websock_encode()
865 ioc->pong_remain = ioc->encoutput.offset; in qio_channel_websock_decode_payload()
923 buffer_free(&ioc->encoutput); in qio_channel_websock_finalize()
982 while (ioc->encoutput.offset > 0) { in qio_channel_websock_write_wire()
984 (char *)ioc->encoutput.buffer, in qio_channel_websock_write_wire()
985 ioc->encoutput.offset, in qio_channel_websock_write_wire()
995 buffer_advance(&ioc->encoutput, ret); in qio_channel_websock_write_wire()
1060 if (ioc->encoutput.offset) { in qio_channel_websock_set_watch()
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()
1241 if (wsource->wioc->encoutput.offset < QIO_CHANNEL_WEBSOCK_MAX_BUFFER) { in qio_channel_websock_source_check()