Lines Matching refs:encinput

491     size_t want = 4096 - ioc->encinput.offset;  in qio_channel_websock_handshake_read()
492 buffer_reserve(&ioc->encinput, want); in qio_channel_websock_handshake_read()
494 (char *)buffer_end(&ioc->encinput), want, errp); in qio_channel_websock_handshake_read()
498 ioc->encinput.offset += ret; in qio_channel_websock_handshake_read()
500 handshake_end = g_strstr_len((char *)ioc->encinput.buffer, in qio_channel_websock_handshake_read()
501 ioc->encinput.offset, in qio_channel_websock_handshake_read()
504 if (ioc->encinput.offset >= 4096) { in qio_channel_websock_handshake_read()
520 (char *)ioc->encinput.buffer, in qio_channel_websock_handshake_read()
523 buffer_advance(&ioc->encinput, in qio_channel_websock_handshake_read()
524 handshake_end - (char *)ioc->encinput.buffer + in qio_channel_websock_handshake_read()
689 (QIOChannelWebsockHeader *)ioc->encinput.buffer; in qio_channel_websock_decode_header()
700 if (ioc->encinput.offset < QIO_CHANNEL_WEBSOCK_HEADER_LEN_7_BIT) { in qio_channel_websock_decode_header()
770 ioc->encinput.offset >= QIO_CHANNEL_WEBSOCK_HEADER_LEN_16_BIT) { in qio_channel_websock_decode_header()
775 ioc->encinput.offset >= QIO_CHANNEL_WEBSOCK_HEADER_LEN_64_BIT) { in qio_channel_websock_decode_header()
786 buffer_advance(&ioc->encinput, header_size); in qio_channel_websock_decode_header()
803 if (ioc->encinput.offset < ioc->payload_remain) { in qio_channel_websock_decode_payload()
809 payload_len = ioc->encinput.offset - (ioc->encinput.offset % 4); in qio_channel_websock_decode_payload()
821 payload32 = (uint32_t *)ioc->encinput.buffer; in qio_channel_websock_decode_payload()
827 ioc->encinput.buffer[i] ^= ioc->mask.c[i % 4]; in qio_channel_websock_decode_payload()
838 buffer_append(&ioc->rawinput, ioc->encinput.buffer, payload_len); in qio_channel_websock_decode_payload()
845 struct iovec iov = { .iov_base = ioc->encinput.buffer, in qio_channel_websock_decode_payload()
846 .iov_len = ioc->encinput.offset }; in qio_channel_websock_decode_payload()
861 struct iovec iov = { .iov_base = ioc->encinput.buffer, in qio_channel_websock_decode_payload()
862 .iov_len = ioc->encinput.offset }; in qio_channel_websock_decode_payload()
870 buffer_advance(&ioc->encinput, payload_len); in qio_channel_websock_decode_payload()
922 buffer_free(&ioc->encinput); in qio_channel_websock_finalize()
940 if (ioc->encinput.offset < 4096) { in qio_channel_websock_read_wire()
941 size_t want = 4096 - ioc->encinput.offset; in qio_channel_websock_read_wire()
943 buffer_reserve(&ioc->encinput, want); in qio_channel_websock_read_wire()
945 (char *)ioc->encinput.buffer + in qio_channel_websock_read_wire()
946 ioc->encinput.offset, in qio_channel_websock_read_wire()
952 if (ret == 0 && ioc->encinput.offset == 0) { in qio_channel_websock_read_wire()
956 ioc->encinput.offset += ret; in qio_channel_websock_read_wire()
959 while (ioc->encinput.offset != 0) { in qio_channel_websock_read_wire()
1063 if (ioc->encinput.offset < QIO_CHANNEL_WEBSOCK_MAX_BUFFER && in qio_channel_websock_set_watch()