mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2025-07-31 18:46:15 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Stream ID handling in MAX_STREAM_DATA and STREAM_DATA_BLOCKED.

Browse Source
This commit is contained in:
Sergey Kandaurov 2020-06-05 20:59:27 +03:00
parent d42fadcf29
commit 7d8a64a862
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/event/ngx_event_quic.c
View File

@ -2875,6 +2875,14 @@ ngx_quic_handle_stream_data_blocked_frame(ngx_connection_t *c,
ngx_quic_connection_t *qc; ngx_quic_connection_t *qc;
qc = c->quic; qc = c->quic;
if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
&& (f->id & NGX_QUIC_STREAM_SERVER_INITIATED))
{
qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
return NGX_ERROR;
}
sn = ngx_quic_find_stream(&qc->streams.tree, f->id); sn = ngx_quic_find_stream(&qc->streams.tree, f->id);
if (sn == NULL) { if (sn == NULL) {
@ -2917,10 +2925,23 @@ ngx_quic_handle_max_stream_data_frame(ngx_connection_t *c,
ngx_quic_connection_t *qc; ngx_quic_connection_t *qc;
qc = c->quic; qc = c->quic;
if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
&& (f->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0)
{
qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
return NGX_ERROR;
}
sn = ngx_quic_find_stream(&qc->streams.tree, f->id); sn = ngx_quic_find_stream(&qc->streams.tree, f->id);
if (sn == NULL) { if (sn == NULL) {
ngx_log_error(NGX_LOG_INFO, c->log, 0, "unknown stream id:%uL", f->id); ngx_log_error(NGX_LOG_INFO, c->log, 0, "unknown stream id:%uL", f->id);
if (f->id & NGX_QUIC_STREAM_SERVER_INITIATED) {
qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
}
return NGX_ERROR; return NGX_ERROR;
} }