mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2025-01-20 02:22:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Implemented send_alert callback, CONNECTION_CLOSE writer.

Browse Source 
The callback produces a CONNECTION_CLOSE frame, as per quic-tls-24#section-4.9.
This commit is contained in:
Sergey Kandaurov 2020-03-18 23:07:40 +03:00
parent 0561665873
commit 6aa611c314
2 changed files with 50 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/event/ngx_event_quic.c
View File

@ -251,6 +251,7 @@ ngx_quic_send_alert(ngx_ssl_conn_t *ssl_conn, enum ssl_encryption_level_t level,
uint8_t alert)
{
ngx_connection_t *c;
ngx_quic_frame_t *frame;
c = ngx_ssl_get_connection((ngx_ssl_conn_t *) ssl_conn);
@ -258,6 +259,21 @@ ngx_quic_send_alert(ngx_ssl_conn_t *ssl_conn, enum ssl_encryption_level_t level,
"ngx_quic_send_alert(), lvl=%d, alert=%d",
(int) level, (int) alert);
frame = ngx_pcalloc(c->pool, sizeof(ngx_quic_frame_t));
if (frame == NULL) {
return 0;
}
frame->level = level;
frame->type = NGX_QUIC_FT_CONNECTION_CLOSE;
frame->u.close.error_code = 0x100 + alert;
ngx_quic_queue_frame(c->quic, frame);
if (ngx_quic_output(c) != NGX_OK) {
return 0;
}
return 1;
}

34
src/event/ngx_event_quic_transport.c
View File

@ -58,6 +58,7 @@ static size_t ngx_quic_create_ack(u_char *p, ngx_quic_ack_frame_t *ack);
static size_t ngx_quic_create_crypto(u_char *p,
ngx_quic_crypto_frame_t *crypto);
static size_t ngx_quic_create_stream(u_char *p, ngx_quic_stream_frame_t *sf);
static size_t ngx_quic_create_close(u_char *p, ngx_quic_close_frame_t *cl);
/* literal errors indexed by corresponding value */
@ -464,6 +465,9 @@ ngx_quic_create_frame(u_char *p, u_char *end, ngx_quic_frame_t *f)
case NGX_QUIC_FT_STREAM7:
return ngx_quic_create_stream(p, &f->u.stream);
case NGX_QUIC_FT_CONNECTION_CLOSE:
return ngx_quic_create_close(p, &f->u.close);
default:
/* BUG: unsupported frame type generated */
return NGX_ERROR;
@ -489,6 +493,8 @@ ngx_quic_frame_len(ngx_quic_frame_t *frame)
case NGX_QUIC_FT_STREAM6:
case NGX_QUIC_FT_STREAM7:
return ngx_quic_create_stream(NULL, &frame->u.stream);
case NGX_QUIC_FT_CONNECTION_CLOSE:
return ngx_quic_create_close(NULL, &frame->u.close);
default:
/* BUG: unsupported frame type generated */
return 0;
@ -597,3 +603,31 @@ ngx_quic_create_stream(u_char *p, ngx_quic_stream_frame_t *sf)
return p - start;
}
static size_t
ngx_quic_create_close(u_char *p, ngx_quic_close_frame_t *cl)
{
size_t len;
u_char *start;
if (p == NULL) {
len = ngx_quic_varint_len(NGX_QUIC_FT_CONNECTION_CLOSE);
len += ngx_quic_varint_len(cl->error_code);
len += ngx_quic_varint_len(cl->frame_type);
len += ngx_quic_varint_len(cl->reason.len);
len += cl->reason.len;
return len;
}
start = p;
ngx_quic_build_int(&p, NGX_QUIC_FT_CONNECTION_CLOSE);
ngx_quic_build_int(&p, cl->error_code);
ngx_quic_build_int(&p, cl->frame_type);
ngx_quic_build_int(&p, cl->reason.len);
p = ngx_cpymem(p, cl->reason.data, cl->reason.len);
return p - start;
}