iv-org-mirror/litespeed-quic
1
0
Fork 0
mirror of https://gitea.invidious.io/iv-org/litespeed-quic.git synced 2024-08-15 00:53:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

Release 2.4.5

Browse source 
- [OPTIMIZATION]: flush encoder stream only when necessary.
- [BUGFIX] Use ls-qpack v0.10.2 for new API -- and for a bug fix.
- [BUGFIX] Typo in IETF conn SETTINGS writer.
- Use latest BoringSSL.
This commit is contained in:
Dmitri Tikhonov 2019-10-08 15:54:01 -04:00
parent 662de5e197
commit 4947ba950d
16 changed files with 41 additions and 130 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/liblsquic/ls-qpack

@ -1 +1 @@
Subproject commit 6e2bdf46a214efa0f934d931f29058238ed32f46
Subproject commit 1d472c0a51de5b569bd6d32a77251c15e910d734

24
src/liblsquic/lsquic_enc_sess_ietf.c
View file

@ -1141,38 +1141,17 @@ static int
iquic_new_session_cb (SSL *ssl, SSL_SESSION *session)
{
struct enc_sess_iquic *enc_sess;
uint32_t max_early_data_size, num;
uint32_t num;
unsigned char *p, *buf;
uint8_t *ticket_buf;
size_t ticket_sz;
lsquic_ver_tag_t tag;
const uint8_t *trapa_buf;
SSL_CTX *ssl_ctx;
size_t trapa_sz, buf_sz;
enc_sess = SSL_get_ex_data(ssl, s_idx);
assert(enc_sess->esi_enpub->enp_stream_if->on_zero_rtt_info);
max_early_data_size = SSL_SESSION_get_max_early_data_size(session);
if (max_early_data_size && 0xFFFFFFFFu != max_early_data_size)
{
/* XXX We do not catch the case when early_data extension is present
* and max_early_data_size is set to zero, which is an invalid value.
* This is because there is no way to check this using existing
* BoringSSL APIs.
*/
/* See [draft-ietf-quic-tls-23], Section 4.5 */
LSQ_INFO("max_early_data_size=0x%X, protocol violation",
max_early_data_size);
enc_sess->esi_conn->cn_if->ci_abort_error(enc_sess->esi_conn, 0,
TEC_PROTOCOL_VIOLATION, "max_early_data_size is set to %u "
"instead of 0xFFFFFFFF as mandated by standard",
max_early_data_size);
ssl_ctx = SSL_get_SSL_CTX(ssl);
SSL_CTX_sess_set_new_cb(ssl_ctx, NULL);
return 0;
}
SSL_get_peer_quic_transport_params(enc_sess->esi_ssl, &trapa_buf,
&trapa_sz);
if (!(trapa_buf + trapa_sz))
@ -1513,7 +1492,6 @@ iquic_esfi_handshake (struct enc_sess_iquic *enc_sess)
case SSL_ERROR_WANT_WRITE:
LSQ_DEBUG("retry write");
return IHS_WANT_WRITE;
case SSL_EARLY_DATA_REJECTED: /* XXX should this be included here? */
case SSL_ERROR_EARLY_DATA_REJECTED:
LSQ_DEBUG("early data rejected");
hsk_status = LSQ_HSK_0RTT_FAIL;

2
src/liblsquic/lsquic_full_conn_ietf.c
View file

@ -3028,7 +3028,7 @@ ietf_full_conn_ci_push_stream (struct lsquic_conn *lconn, void *hset,
}
}
prefix_sz = lsqpack_enc_end_header(&conn->ifc_qeh.qeh_encoder,
discard, sizeof(discard));
discard, sizeof(discard), NULL);
if (!(prefix_sz == 2 && discard[0] == 0 && discard[1] == 0))
{
LSQ_WARN("stream push: unexpected prefix values %zd, %hhu, %hhu",

2
src/liblsquic/lsquic_hcso_writer.c
View file

@ -174,7 +174,7 @@ lsquic_hcso_write_settings (struct hcso_writer *writer,
bits = hcso_setting_type2bits(writer, HQSID_QPACK_BLOCKED_STREAMS);
vint_write(p, HQSID_QPACK_BLOCKED_STREAMS, bits, 1 << bits);
p += 1 << bits;
bits = vint_val2bits(settings->es_qpack_dec_max_size);
bits = vint_val2bits(settings->es_qpack_dec_max_blocked);
vint_write(p, settings->es_qpack_dec_max_blocked, bits, 1 << bits);
p += 1 << bits;
}

10
src/liblsquic/lsquic_qenc_hdl.c
View file

@ -322,7 +322,7 @@ static enum qwh_status
qeh_write_headers (struct qpack_enc_hdl *qeh, lsquic_stream_id_t stream_id,
unsigned seqno, const struct lsquic_http_headers *headers,
unsigned char *buf, size_t *prefix_sz, size_t *headers_sz,
uint64_t *completion_offset)
uint64_t *completion_offset, enum lsqpack_enc_header_flags *hflags)
{
unsigned char *p = buf;
unsigned char *const end = buf + *headers_sz;
@ -410,7 +410,8 @@ qeh_write_headers (struct qpack_enc_hdl *qeh, lsquic_stream_id_t stream_id,
}
}
nw = lsqpack_enc_end_header(&qeh->qeh_encoder, buf - *prefix_sz, *prefix_sz);
nw = lsqpack_enc_end_header(&qeh->qeh_encoder, buf - *prefix_sz,
*prefix_sz, hflags);
if (nw <= 0)
{
LSQ_WARN("could not end header: %zd", nw);
@ -450,11 +451,12 @@ enum qwh_status
lsquic_qeh_write_headers (struct qpack_enc_hdl *qeh,
lsquic_stream_id_t stream_id, unsigned seqno,
const struct lsquic_http_headers *headers, unsigned char *buf,
size_t *prefix_sz, size_t *headers_sz, uint64_t *completion_offset)
size_t *prefix_sz, size_t *headers_sz, uint64_t *completion_offset,
enum lsqpack_enc_header_flags *hflags)
{
if (qeh->qeh_flags & QEH_INITIALIZED)
return qeh_write_headers(qeh, stream_id, seqno, headers, buf,
prefix_sz, headers_sz, completion_offset);
prefix_sz, headers_sz, completion_offset, hflags);
else
return QWH_ERR;
}

3
src/liblsquic/lsquic_qenc_hdl.h
View file

@ -58,7 +58,8 @@ enum qwh_status {
enum qwh_status
lsquic_qeh_write_headers (struct qpack_enc_hdl *, lsquic_stream_id_t stream_id,
unsigned seqno, const struct lsquic_http_headers *, unsigned char *buf,
size_t *prefix_sz, size_t *headers_sz, uint64_t *completion_offset);
size_t *prefix_sz, size_t *headers_sz, uint64_t *completion_offset,
enum lsqpack_enc_header_flags *hflags);
uint64_t
lsquic_qeh_enc_off (struct qpack_enc_hdl *);

18
src/liblsquic/lsquic_stream.c
View file

@ -2753,13 +2753,13 @@ stream_write_to_packet_std (struct frame_gen_ctx *fg_ctx, const size_t size)
if ((stream->stream_flags & (STREAM_HEADERS_SENT|STREAM_HDRS_FLUSHED))
== STREAM_HEADERS_SENT)
{
/* Optimization idea: the QPACK encoder stream needs only be flushed
* if the headers in this stream are dependent on the buffered encoder
* stream bytes. Knowing this would require changes to ls-qpack. For
* this reason, we don't perform this check and just flush it.
*/
if (stream->sm_bflags & SMBF_IETF)
headers_stream = stream->conn_pub->u.ietf.qeh->qeh_enc_sm_out;
{
if (stream->stream_flags & STREAM_ENCODER_DEP)
headers_stream = stream->conn_pub->u.ietf.qeh->qeh_enc_sm_out;
else
headers_stream = NULL;
}
else
headers_stream =
lsquic_headers_stream_get_stream(stream->conn_pub->u.gquic.hs);
@ -3326,6 +3326,7 @@ send_headers_ietf (struct lsquic_stream *stream,
unsigned bits;
ssize_t nw;
unsigned char *header_block;
enum lsqpack_enc_header_flags hflags;
unsigned char buf[max_push_size + max_prefix_size + MAX_HEADERS_SIZE];
stream->stream_flags &= ~STREAM_PUSHING;
@ -3338,7 +3339,7 @@ send_headers_ietf (struct lsquic_stream *stream,
headers_sz = sizeof(buf) - max_prefix_size - max_push_size;
qwh = lsquic_qeh_write_headers(stream->conn_pub->u.ietf.qeh, stream->id, 0,
headers, buf + max_push_size + max_prefix_size, &prefix_sz,
&headers_sz, &stream->sm_hb_compl);
&headers_sz, &stream->sm_hb_compl, &hflags);
if (!(qwh == QWH_FULL || qwh == QWH_PARTIAL))
{
@ -3349,6 +3350,9 @@ send_headers_ietf (struct lsquic_stream *stream,
return -1;
}
if (hflags & LSQECH_REF_NEW_ENTRIES)
stream->stream_flags |= STREAM_ENCODER_DEP;
if (stream->sm_promise)
{
assert(lsquic_stream_is_pushed(stream));

2
src/liblsquic/lsquic_stream.h
View file

@ -197,7 +197,7 @@ enum stream_flags {
STREAM_UNUSED10 = 1 << 10, /* Unused */
STREAM_HEADERS_SENT = 1 << 11,
STREAM_HAVE_UH = 1 << 12, /* Have uncompressed headers */
STREAM_UNUSED13 = 1 << 13, /* Unused */
STREAM_ENCODER_DEP = 1 << 13, /* Encoder dependency: flush (IETF only) */
STREAM_HEAD_IN_FIN = 1 << 14, /* Incoming headers has FIN bit set */
STREAM_FRAMES_ELIDED= 1 << 15,
STREAM_FORCE_FINISH = 1 << 16, /* Replaces FIN sent and received */