nginx-quic: src/http/v3/ngx_http_v3

HTTP/3: server pushes. New directives are added: - http3_max_concurrent_pushes - http3_push - http3_push_preload

author	Roman Arutyunyan <arut@nginx.com>
date	Thu, 23 Jul 2020 13:41:24 +0300
parents	65c1fc5fae15
children	d70a38acaea0

comparison

equal deleted inserted replaced

-:c5324bb3a704
+:0596fe1aee16
 enum {
 sw_start = 0,
 sw_first_type,
 sw_type,
 sw_length,
+sw_cancel_push,
 sw_settings,
 sw_max_push_id,
 sw_skip
 };
 break;
 }
 switch (st->type) {
+case NGX_HTTP_V3_FRAME_CANCEL_PUSH:
+st->state = sw_cancel_push;
+break;
 case NGX_HTTP_V3_FRAME_SETTINGS:
 st->state = sw_settings;
 break;
 case NGX_HTTP_V3_FRAME_MAX_PUSH_ID:
 st->state = sw_skip;
 }
 break;
+case sw_cancel_push:
+rc = ngx_http_v3_parse_varlen_int(c, &st->vlint, ch);
+if (--st->length == 0 && rc == NGX_AGAIN) {
+return NGX_HTTP_V3_ERR_FRAME_ERROR;
+}
+if (rc != NGX_DONE) {
+return rc;
+}
+rc = ngx_http_v3_cancel_push(c, st->vlint.value);
+if (rc != NGX_OK) {
+return rc;
+}
+st->state = sw_type;
+break;
 case sw_settings:
 rc = ngx_http_v3_parse_settings(c, &st->settings, ch);
 if (--st->length == 0 && rc == NGX_AGAIN) {
 break;
 case sw_max_push_id:
 rc = ngx_http_v3_parse_varlen_int(c, &st->vlint, ch);
-if (rc != NGX_DONE) {
-return rc;
+if (--st->length == 0 && rc == NGX_AGAIN) {
-}
+return NGX_HTTP_V3_ERR_FRAME_ERROR;
+}
-ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
-"http3 parse MAX_PUSH_ID:%uL", st->vlint.value);
+if (rc != NGX_DONE) {
+return rc;
+}
+rc = ngx_http_v3_set_max_push_id(c, st->vlint.value);
+if (rc != NGX_OK) {
+return rc;
+}
 st->state = sw_type;
 break;
 case sw_skip:

Mercurial > hg > nginx-quic