+KEEP COPYRIGHT_SERVICE_LABEL 3782c9399af9718cb85783105b7784ae

+BELONGS ya.make

+ License text:

+ Copyright (C) 1994-1996, 1999-2002, 2004-2017, 2020-2021 Free

+ Software Foundation, Inc.

+ Scancode info:

+ Original SPDX id: COPYRIGHT_SERVICE_LABEL

+ Score : 100.00

+ Match type : COPYRIGHT

+ Files with this license:

+ INSTALL [4:5]

+

+KEEP COPYRIGHT_SERVICE_LABEL bc9503ec48dfbffaed72fd039643c15f

+BELONGS ya.make

+ License text:

+ * Copyright (c) 2022 nghttp3 contributors

+ * Copyright (c) 2022 nghttp2 contributors

+ Scancode info:

+ Original SPDX id: COPYRIGHT_SERVICE_LABEL

+ Score : 100.00

+ Match type : COPYRIGHT

+ Files with this license:

+ lib/nghttp2_extpri.c [4:5]

+ lib/nghttp2_extpri.h [4:5]

+

+

+KEEP COPYRIGHT_SERVICE_LABEL d89f9db9c9889910b44184610d7947e1

+BELONGS ya.make

+ License text:

+ * Copyright (c) 2022 nghttp3 contributors

+ * Copyright (c) 2022 nghttp2 contributors

+ Scancode info:

+ Original SPDX id: COPYRIGHT_SERVICE_LABEL

+ Score : 100.00

+ Match type : COPYRIGHT

+ Files with this license:

+ lib/nghttp2_extpri.c [4:5]

+ lib/nghttp2_extpri.h [4:5]

+FILE_INCLUDE AUTHORS found in files: lib/includes/nghttp2/nghttp2.h at line 20, lib/includes/nghttp2/nghttp2ver.h at line 20, lib/nghttp2_buf.c at line 20, lib/nghttp2_buf.h at line 20, lib/nghttp2_callbacks.c at line 20, lib/nghttp2_callbacks.h at line 20, lib/nghttp2_debug.c at line 20, lib/nghttp2_debug.h at line 20, lib/nghttp2_extpri.c at line 21, lib/nghttp2_extpri.h at line 21, lib/nghttp2_frame.c at line 20, lib/nghttp2_frame.h at line 20, lib/nghttp2_hd.c at line 20, lib/nghttp2_hd.h at line 20, lib/nghttp2_hd_huffman.c at line 20, lib/nghttp2_hd_huffman.h at line 20, lib/nghttp2_hd_huffman_data.c at line 20, lib/nghttp2_helper.c at line 20, lib/nghttp2_helper.h at line 20, lib/nghttp2_http.c at line 20, lib/nghttp2_http.h at line 20, lib/nghttp2_int.h at line 20, lib/nghttp2_map.c at line 21, lib/nghttp2_map.h at line 21, lib/nghttp2_mem.c at line 20, lib/nghttp2_mem.h at line 20, lib/nghttp2_net.h at line 20, lib/nghttp2_npn.c at line 20, lib/nghttp2_npn.h at line 20, lib/nghttp2_option.c at line 20, lib/nghttp2_option.h at line 20, lib/nghttp2_outbound_item.c at line 20, lib/nghttp2_outbound_item.h at line 20, lib/nghttp2_pq.c at line 20, lib/nghttp2_pq.h at line 20, lib/nghttp2_priority_spec.c at line 20, lib/nghttp2_priority_spec.h at line 20, lib/nghttp2_queue.c at line 20, lib/nghttp2_queue.h at line 20, lib/nghttp2_rcbuf.c at line 20, lib/nghttp2_rcbuf.h at line 20, lib/nghttp2_session.c at line 20, lib/nghttp2_session.h at line 20, lib/nghttp2_stream.c at line 20, lib/nghttp2_stream.h at line 20, lib/nghttp2_submit.c at line 20, lib/nghttp2_submit.h at line 20, lib/nghttp2_version.c at line 20

+ lib/nghttp2_extpri.c [7:24]

+ lib/nghttp2_extpri.h [7:24]

+ Copyright (C) 1994-1996, 1999-2002, 2004-2017, 2020-2021 Free

+Software Foundation, Inc.

+ * Copyright (c) 2022 nghttp3 contributors

+ * Copyright (c) 2022 nghttp2 contributors

+

+

+====================COPYRIGHT====================

+ ${CMAKE_SOURCE_DIR}/contrib/libs/nghttp2/lib/nghttp2_extpri.c

+ Copyright (C) 1994-1996, 1999-2002, 2004-2017, 2020-2021 Free

+Software Foundation, Inc.

+ HP-UX 'make' updates targets which have the same timestamps as their

+ <https://github.com/quictls/openssl/tree/OpenSSL_1_1_1p+quic>`_; or

+ 27ffcc6e19bbafddf1b59ec0bc6df2904de7eb2c)

+* `ngtcp2 <https://github.com/ngtcp2/ngtcp2>`_ >= 0.6.0

+* `nghttp3 <https://github.com/ngtcp2/nghttp3>`_ >= 0.4.0

+<https://github.com/libbpf/libbpf/releases/tag/v0.8.0>`_. nghttpx

+ $ git clone --depth 1 -b OpenSSL_1_1_1p+quic https://github.com/quictls/openssl

+ $ git clone --depth 1 -b v0.5.0 https://github.com/ngtcp2/nghttp3

+ $ git clone --depth 1 -b v0.6.0 https://github.com/ngtcp2/ngtcp2

+ $ git clone --depth 1 -b v0.8.0 https://github.com/libbpf/libbpf

+#define PACKAGE_STRING "nghttp2 1.48.0"

+#define PACKAGE_VERSION "1.48.0"

+#define VERSION "1.48.0"

+ NGHTTP2_ORIGIN = 0x0c,

+ /**

+ * The PRIORITY_UPDATE frame, which is defined by :rfc:`9218`.

+ */

+ NGHTTP2_PRIORITY_UPDATE = 0x10

+ NGHTTP2_SETTINGS_ENABLE_CONNECT_PROTOCOL = 0x08,

+ /**

+ * SETTINGS_NO_RFC7540_PRIORITIES (:rfc:`9218`)

+ */

+ NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES = 0x09

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is submitted via `nghttp2_submit_settings()`, any

+ * closed streams are not retained regardless of this option.

+ * This option, if set to nonzero, allows server to fallback to

+ * :rfc:`7540` priorities if SETTINGS_NO_RFC7540_PRIORITIES was not

+ * received from client, and server submitted

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * = 1 via `nghttp2_submit_settings()`. Most of the advanced

+ * functionality for RFC 7540 priorities are still disabled. This

+ * fallback only enables the minimal feature set of RFC 7540

+ * priorities to deal with priority signaling from client.

+ *

+ * Client session ignores this option.

+ */

+NGHTTP2_EXTERN void

+nghttp2_option_set_server_fallback_rfc7540_priorities(nghttp2_option *option,

+ int val);

+

+/**

+ * @function

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is submitted via `nghttp2_submit_settings()`, this

+ * function does nothing and returns 0.

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is submitted via `nghttp2_submit_settings()`, this

+ * function does nothing and returns 0.

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is received by a remote endpoint, |pri_spec| is

+ * ignored, and treated as if ``NULL`` is specified.

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is received by a remote endpoint, |pri_spec| is

+ * ignored, and treated as if ``NULL`` is specified.

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is received by a remote endpoint, this function does

+ * nothing and returns 0.

+ *

+ * @macro

+ *

+ * :macro:`NGHTTP2_EXTPRI_DEFAULT_URGENCY` is the default urgency

+ * level for :rfc:`9218` extensible priorities.

+ */

+#define NGHTTP2_EXTPRI_DEFAULT_URGENCY 3

+

+/**

+ * @macro

+ *

+ * :macro:`NGHTTP2_EXTPRI_URGENCY_HIGH` is the highest urgency level

+ * for :rfc:`9218` extensible priorities.

+ */

+#define NGHTTP2_EXTPRI_URGENCY_HIGH 0

+

+/**

+ * @macro

+ *

+ * :macro:`NGHTTP2_EXTPRI_URGENCY_LOW` is the lowest urgency level for

+ * :rfc:`9218` extensible priorities.

+ */

+#define NGHTTP2_EXTPRI_URGENCY_LOW 7

+

+/**

+ * @macro

+ *

+ * :macro:`NGHTTP2_EXTPRI_URGENCY_LEVELS` is the number of urgency

+ * levels for :rfc:`9218` extensible priorities.

+ */

+#define NGHTTP2_EXTPRI_URGENCY_LEVELS (NGHTTP2_EXTPRI_URGENCY_LOW + 1)

+

+/**

+ * @struct

+ *

+ * :type:`nghttp2_extpri` is :rfc:`9218` extensible priorities

+ * specification for a stream.

+ */

+typedef struct nghttp2_extpri {

+ /**

+ * :member:`urgency` is the urgency of a stream, it must be in

+ * [:macro:`NGHTTP2_EXTPRI_URGENCY_HIGH`,

+ * :macro:`NGHTTP2_EXTPRI_URGENCY_LOW`], inclusive, and 0 is the

+ * highest urgency.

+ */

+ uint32_t urgency;

+ /**

+ * :member:`inc` indicates that a content can be processed

+ * incrementally or not. If inc is 0, it cannot be processed

+ * incrementally. If inc is 1, it can be processed incrementally.

+ * Other value is not permitted.

+ */

+ int inc;

+} nghttp2_extpri;

+

+/**

+ * @struct

+ *

+ * The payload of PRIORITY_UPDATE frame. PRIORITY_UPDATE frame is a

+ * non-critical extension to HTTP/2. If this frame is received, and

+ * `nghttp2_option_set_user_recv_extension_type()` is not set, and

+ * `nghttp2_option_set_builtin_recv_extension_type()` is set for

+ * :enum:`nghttp2_frame_type.NGHTTP2_PRIORITY_UPDATE`,

+ * ``nghttp2_extension.payload`` will point to this struct.

+ *

+ * It has the following members:

+ */

+typedef struct {

+ /**

+ * The stream ID of the stream whose priority is updated.

+ */

+ int32_t stream_id;

+ /**

+ * The pointer to Priority field value. It is not necessarily

+ * NULL-terminated.

+ */

+ uint8_t *field_value;

+ /**

+ * The length of the :member:`field_value`.

+ */

+ size_t field_value_len;

+} nghttp2_ext_priority_update;

+

+/**

+ * @function

+ *

+ * Submits PRIORITY_UPDATE frame.

+ *

+ * PRIORITY_UPDATE frame is a non-critical extension to HTTP/2, and

+ * defined in :rfc:`9218#section-7.1`.

+ *

+ * The |flags| is currently ignored and should be

+ * :enum:`nghttp2_flag.NGHTTP2_FLAG_NONE`.

+ *

+ * The |stream_id| is the ID of stream which is prioritized. The

+ * |field_value| points to the Priority field value. The

+ * |field_value_len| is the length of the Priority field value.

+ *

+ * If this function is called by server,

+ * :enum:`nghttp2_error.NGHTTP2_ERR_INVALID_STATE` is returned.

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 0 is received by a remote endpoint (or it is omitted),

+ * this function does nothing and returns 0.

+ *

+ * This function returns 0 if it succeeds, or one of the following

+ * negative error codes:

+ *

+ * :enum:`nghttp2_error.NGHTTP2_ERR_NOMEM`

+ * Out of memory

+ * :enum:`nghttp2_error.NGHTTP2_ERR_INVALID_STATE`

+ * The function is called from server side session

+ * :enum:`nghttp2_error.NGHTTP2_ERR_INVALID_ARGUMENT`

+ * The |field_value_len| is larger than 16380; or |stream_id| is

+ * 0.

+ */

+NGHTTP2_EXTERN int nghttp2_submit_priority_update(nghttp2_session *session,

+ uint8_t flags,

+ int32_t stream_id,

+ const uint8_t *field_value,

+ size_t field_value_len);

+

+/**

+ * @function

+ *

+ * Changes the priority of the existing stream denoted by |stream_id|.

+ * The new priority is |extpri|. This function is meant to be used by

+ * server for :rfc:`9218` extensible prioritization scheme.

+ *

+ * If |session| is initialized as client, this function returns

+ * :enum:`nghttp2_error.NGHTTP2_ERR_INVALID_STATE`. For client, use

+ * `nghttp2_submit_priority_update()` instead.

+ *

+ * If :member:`extpri->urgency <nghttp2_extpri.urgency>` is out of

+ * bound, it is set to :macro:`NGHTTP2_EXTPRI_URGENCY_LOW`.

+ *

+ * If |ignore_client_signal| is nonzero, server starts to ignore

+ * client priority signals for this stream.

+ *

+ * If

+ * :enum:`nghttp2_settings_id.NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES`

+ * of value of 1 is not submitted via `nghttp2_submit_settings()`,

+ * this function does nothing and returns 0.

+ *

+ * :enum:`nghttp2_error.NGHTTP2_ERR_NOMEM`

+ * Out of memory.

+ * :enum:`nghttp2_error.NGHTTP2_ERR_INVALID_STATE`

+ * The |session| is initialized as client.

+ * :enum:`nghttp2_error.NGHTTP2_ERR_INVALID_ARGUMENT`

+ * |stream_id| is zero; or a stream denoted by |stream_id| is not

+ * found.

+ */

+NGHTTP2_EXTERN int nghttp2_session_change_extpri_stream_priority(

+ nghttp2_session *session, int32_t stream_id, const nghttp2_extpri *extpri,

+ int ignore_client_signal);

+

+/**

+#define NGHTTP2_VERSION "1.48.0"

+#define NGHTTP2_VERSION_NUM 0x013000

+/*

+ * nghttp2 - HTTP/2 C Library

+ *

+ * Copyright (c) 2022 nghttp3 contributors

+ * Copyright (c) 2022 nghttp2 contributors

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining

+ * a copy of this software and associated documentation files (the

+ * "Software"), to deal in the Software without restriction, including

+ * without limitation the rights to use, copy, modify, merge, publish,

+ * distribute, sublicense, and/or sell copies of the Software, and to

+ * permit persons to whom the Software is furnished to do so, subject to

+ * the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be

+ * included in all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,

+ * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND

+ * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE

+ * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION

+ * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION

+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

+ */

+#include "nghttp2_extpri.h"

+

+uint8_t nghttp2_extpri_to_uint8(const nghttp2_extpri *extpri) {

+ return (uint8_t)((uint32_t)extpri->inc << 7 | extpri->urgency);

+}

+

+void nghttp2_extpri_from_uint8(nghttp2_extpri *extpri, uint8_t u8extpri) {

+ extpri->urgency = nghttp2_extpri_uint8_urgency(u8extpri);

+ extpri->inc = nghttp2_extpri_uint8_inc(u8extpri);

+}

+/*

+ * nghttp2 - HTTP/2 C Library

+ *

+ * Copyright (c) 2022 nghttp3 contributors

+ * Copyright (c) 2022 nghttp2 contributors

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining

+ * a copy of this software and associated documentation files (the

+ * "Software"), to deal in the Software without restriction, including

+ * without limitation the rights to use, copy, modify, merge, publish,

+ * distribute, sublicense, and/or sell copies of the Software, and to

+ * permit persons to whom the Software is furnished to do so, subject to

+ * the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be

+ * included in all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,

+ * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND

+ * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE

+ * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION

+ * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION

+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

+ */

+#ifndef NGHTTP2_EXTPRI_H

+#define NGHTTP2_EXTPRI_H

+

+#ifdef HAVE_CONFIG_H

+# include <config.h>

+#endif /* HAVE_CONFIG_H */

+

+#include <nghttp2/nghttp2.h>

+

+/*

+ * NGHTTP2_EXTPRI_INC_MASK is a bit mask to retrieve incremental bit

+ * from a value produced by nghttp2_extpri_to_uint8.

+ */

+#define NGHTTP2_EXTPRI_INC_MASK (1 << 7)

+

+/*

+ * nghttp2_extpri_to_uint8 encodes |pri| into uint8_t variable.

+ */

+uint8_t nghttp2_extpri_to_uint8(const nghttp2_extpri *extpri);

+

+/*

+ * nghttp2_extpri_from_uint8 decodes |u8extpri|, which is produced by

+ * nghttp2_extpri_to_uint8, intto |extpri|.

+ */

+void nghttp2_extpri_from_uint8(nghttp2_extpri *extpri, uint8_t u8extpri);

+

+/*

+ * nghttp2_extpri_uint8_urgency extracts urgency from |PRI| which is

+ * supposed to be constructed by nghttp2_extpri_to_uint8.

+ */

+#define nghttp2_extpri_uint8_urgency(PRI) \

+ ((uint32_t)((PRI) & ~NGHTTP2_EXTPRI_INC_MASK))

+

+/*

+ * nghttp2_extpri_uint8_inc extracts inc from |PRI| which is supposed to

+ * be constructed by nghttp2_extpri_to_uint8.

+ */

+#define nghttp2_extpri_uint8_inc(PRI) (((PRI)&NGHTTP2_EXTPRI_INC_MASK) != 0)

+

+#endif /* NGHTTP2_EXTPRI_H */

+void nghttp2_frame_priority_update_init(nghttp2_extension *frame,

+ int32_t stream_id, uint8_t *field_value,

+ size_t field_value_len) {

+ nghttp2_ext_priority_update *priority_update;

+

+ nghttp2_frame_hd_init(&frame->hd, 4 + field_value_len,

+ NGHTTP2_PRIORITY_UPDATE, NGHTTP2_FLAG_NONE, 0);

+

+ priority_update = frame->payload;

+ priority_update->stream_id = stream_id;

+ priority_update->field_value = field_value;

+ priority_update->field_value_len = field_value_len;

+}

+

+void nghttp2_frame_priority_update_free(nghttp2_extension *frame,

+ nghttp2_mem *mem) {

+ nghttp2_ext_priority_update *priority_update;

+

+ priority_update = frame->payload;

+ if (priority_update == NULL) {

+ return;

+ }

+ nghttp2_mem_free(mem, priority_update->field_value);

+}

+

+int nghttp2_frame_pack_priority_update(nghttp2_bufs *bufs,

+ nghttp2_extension *frame) {

+ int rv;

+ nghttp2_buf *buf;

+ nghttp2_ext_priority_update *priority_update;

+

+ /* This is required with --disable-assert. */

+ (void)rv;

+

+ priority_update = frame->payload;

+

+ buf = &bufs->head->buf;

+

+ assert(nghttp2_buf_avail(buf) >= 4 + priority_update->field_value_len);

+

+ buf->pos -= NGHTTP2_FRAME_HDLEN;

+

+ nghttp2_frame_pack_frame_hd(buf->pos, &frame->hd);

+

+ nghttp2_put_uint32be(buf->last, (uint32_t)priority_update->stream_id);

+ buf->last += 4;

+

+ rv = nghttp2_bufs_add(bufs, priority_update->field_value,

+ priority_update->field_value_len);

+

+ assert(rv == 0);

+

+ return 0;

+}

+

+void nghttp2_frame_unpack_priority_update_payload(nghttp2_extension *frame,

+ uint8_t *payload,

+ size_t payloadlen) {

+ nghttp2_ext_priority_update *priority_update;

+

+ assert(payloadlen >= 4);

+

+ priority_update = frame->payload;

+

+ priority_update->stream_id =

+ nghttp2_get_uint32(payload) & NGHTTP2_STREAM_ID_MASK;

+

+ if (payloadlen > 4) {

+ priority_update->field_value = payload + 4;

+ priority_update->field_value_len = payloadlen - 4;

+ } else {

+ priority_update->field_value = NULL;

+ priority_update->field_value_len = 0;

+ }

+}

+

+ case NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES:

+ if (iv[i].value != 0 && iv[i].value != 1) {

+ return 0;

+ }

+ break;

+ nghttp2_ext_priority_update priority_update;

+

+/*

+ * Packs PRIORITY_UPDATE frame |frame| in wire frame format and store

+ * it in |bufs|.

+ *

+ * The caller must make sure that nghttp2_bufs_reset(bufs) is called

+ * before calling this function.

+ *

+ * This function always succeeds and returns 0.

+ */

+int nghttp2_frame_pack_priority_update(nghttp2_bufs *bufs,

+ nghttp2_extension *ext);

+

+/*

+ * Unpacks PRIORITY_UPDATE wire format into |frame|. The |payload| of

+ * |payloadlen| bytes contains frame payload. This function assumes

+ * that frame->payload points to the nghttp2_ext_priority_update

+ * object.

+ *

+ * This function always succeeds and returns 0.

+ */

+void nghttp2_frame_unpack_priority_update_payload(nghttp2_extension *frame,

+ uint8_t *payload,

+ size_t payloadlen);

+

+ * Initializes PRIORITY_UPDATE frame |frame| with given values. This

+ * function assumes that frame->payload points to

+ * nghttp2_ext_priority_update object. On success, this function

+ * takes ownership of |field_value|, so caller must not free it.

+ */

+void nghttp2_frame_priority_update_init(nghttp2_extension *frame,

+ int32_t stream_id, uint8_t *field_value,

+ size_t field_value_len);

+

+/*

+ * Frees up resources under |frame|. This function does not free

+ * nghttp2_ext_priority_update object pointed by frame->payload. This

+ * function only frees field_value pointed by

+ * nghttp2_ext_priority_update.field_value.

+ */

+void nghttp2_frame_priority_update_free(nghttp2_extension *frame,

+ nghttp2_mem *mem);

+

+/*

+ case 'y':

+ if (memeq("priorit", name, 7)) {

+ return NGHTTP2_TOKEN_PRIORITY;

+ }

+ break;

+ NGHTTP2_TOKEN_PRIORITY,

+#include "nghttp2_extpri.h"

+ uint32_t flag) {

+ stream->http_flags = stream->http_flags | flag;

+ nghttp2_extpri extpri;

+

+ case NGHTTP2_TOKEN_PRIORITY:

+ if (!trailer &&

+ /* Do not parse the header field in PUSH_PROMISE. */

+ (stream->stream_id & 1) &&

+ (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) &&

+ !(stream->http_flags & NGHTTP2_HTTP_FLAG_BAD_PRIORITY)) {

+ nghttp2_extpri_from_uint8(&extpri, stream->http_extpri);

+ if (nghttp2_http_parse_priority(&extpri, nv->value->base,

+ nv->value->len) == 0) {

+ stream->http_extpri = nghttp2_extpri_to_uint8(&extpri);

+ stream->http_flags |= NGHTTP2_HTTP_FLAG_PRIORITY;

+ } else {

+ stream->http_flags &= (uint32_t)~NGHTTP2_HTTP_FLAG_PRIORITY;

+ stream->http_flags |= NGHTTP2_HTTP_FLAG_BAD_PRIORITY;

+ }

+ }

+ break;

+ if (session->server || frame->hd.type == NGHTTP2_PUSH_PROMISE) {

+ rv = nghttp2_check_authority(nv->value->base, nv->value->len);

+ } else {

+ rv = nghttp2_check_header_value(nv->value->base, nv->value->len);

+ }

+ stream->http_flags = (stream->http_flags & NGHTTP2_HTTP_FLAG_METH_ALL) |

+ NGHTTP2_HTTP_FLAG_EXPECT_FINAL_RESPONSE;

+ stream->http_flags & (uint32_t)~NGHTTP2_HTTP_FLAG_EXPECT_FINAL_RESPONSE;

+

+/* Generated by genchartbl.py */

+static const int SF_KEY_CHARS[] = {

+ 0 /* NUL */, 0 /* SOH */, 0 /* STX */, 0 /* ETX */, 0 /* EOT */,

+ 0 /* ENQ */, 0 /* ACK */, 0 /* BEL */, 0 /* BS */, 0 /* HT */,

+ 0 /* LF */, 0 /* VT */, 0 /* FF */, 0 /* CR */, 0 /* SO */,

+ 0 /* SI */, 0 /* DLE */, 0 /* DC1 */, 0 /* DC2 */, 0 /* DC3 */,

+ 0 /* DC4 */, 0 /* NAK */, 0 /* SYN */, 0 /* ETB */, 0 /* CAN */,

+ 0 /* EM */, 0 /* SUB */, 0 /* ESC */, 0 /* FS */, 0 /* GS */,

+ 0 /* RS */, 0 /* US */, 0 /* SPC */, 0 /* ! */, 0 /* " */,

+ 0 /* # */, 0 /* $ */, 0 /* % */, 0 /* & */, 0 /* ' */,

+ 0 /* ( */, 0 /* ) */, 1 /* * */, 0 /* + */, 0 /* , */,

+ 1 /* - */, 1 /* . */, 0 /* / */, 1 /* 0 */, 1 /* 1 */,

+ 1 /* 2 */, 1 /* 3 */, 1 /* 4 */, 1 /* 5 */, 1 /* 6 */,

+ 1 /* 7 */, 1 /* 8 */, 1 /* 9 */, 0 /* : */, 0 /* ; */,

+ 0 /* < */, 0 /* = */, 0 /* > */, 0 /* ? */, 0 /* @ */,

+ 0 /* A */, 0 /* B */, 0 /* C */, 0 /* D */, 0 /* E */,

+ 0 /* F */, 0 /* G */, 0 /* H */, 0 /* I */, 0 /* J */,

+ 0 /* K */, 0 /* L */, 0 /* M */, 0 /* N */, 0 /* O */,

+ 0 /* P */, 0 /* Q */, 0 /* R */, 0 /* S */, 0 /* T */,

+ 0 /* U */, 0 /* V */, 0 /* W */, 0 /* X */, 0 /* Y */,

+ 0 /* Z */, 0 /* [ */, 0 /* \ */, 0 /* ] */, 0 /* ^ */,

+ 1 /* _ */, 0 /* ` */, 1 /* a */, 1 /* b */, 1 /* c */,

+ 1 /* d */, 1 /* e */, 1 /* f */, 1 /* g */, 1 /* h */,

+ 1 /* i */, 1 /* j */, 1 /* k */, 1 /* l */, 1 /* m */,

+ 1 /* n */, 1 /* o */, 1 /* p */, 1 /* q */, 1 /* r */,

+ 1 /* s */, 1 /* t */, 1 /* u */, 1 /* v */, 1 /* w */,

+ 1 /* x */, 1 /* y */, 1 /* z */, 0 /* { */, 0 /* | */,

+ 0 /* } */, 0 /* ~ */, 0 /* DEL */, 0 /* 0x80 */, 0 /* 0x81 */,

+ 0 /* 0x82 */, 0 /* 0x83 */, 0 /* 0x84 */, 0 /* 0x85 */, 0 /* 0x86 */,

+ 0 /* 0x87 */, 0 /* 0x88 */, 0 /* 0x89 */, 0 /* 0x8a */, 0 /* 0x8b */,

+ 0 /* 0x8c */, 0 /* 0x8d */, 0 /* 0x8e */, 0 /* 0x8f */, 0 /* 0x90 */,

+ 0 /* 0x91 */, 0 /* 0x92 */, 0 /* 0x93 */, 0 /* 0x94 */, 0 /* 0x95 */,

+ 0 /* 0x96 */, 0 /* 0x97 */, 0 /* 0x98 */, 0 /* 0x99 */, 0 /* 0x9a */,

+ 0 /* 0x9b */, 0 /* 0x9c */, 0 /* 0x9d */, 0 /* 0x9e */, 0 /* 0x9f */,

+ 0 /* 0xa0 */, 0 /* 0xa1 */, 0 /* 0xa2 */, 0 /* 0xa3 */, 0 /* 0xa4 */,

+ 0 /* 0xa5 */, 0 /* 0xa6 */, 0 /* 0xa7 */, 0 /* 0xa8 */, 0 /* 0xa9 */,

+ 0 /* 0xaa */, 0 /* 0xab */, 0 /* 0xac */, 0 /* 0xad */, 0 /* 0xae */,

+ 0 /* 0xaf */, 0 /* 0xb0 */, 0 /* 0xb1 */, 0 /* 0xb2 */, 0 /* 0xb3 */,

+ 0 /* 0xb4 */, 0 /* 0xb5 */, 0 /* 0xb6 */, 0 /* 0xb7 */, 0 /* 0xb8 */,

+ 0 /* 0xb9 */, 0 /* 0xba */, 0 /* 0xbb */, 0 /* 0xbc */, 0 /* 0xbd */,

+ 0 /* 0xbe */, 0 /* 0xbf */, 0 /* 0xc0 */, 0 /* 0xc1 */, 0 /* 0xc2 */,

+ 0 /* 0xc3 */, 0 /* 0xc4 */, 0 /* 0xc5 */, 0 /* 0xc6 */, 0 /* 0xc7 */,

+ 0 /* 0xc8 */, 0 /* 0xc9 */, 0 /* 0xca */, 0 /* 0xcb */, 0 /* 0xcc */,

+ 0 /* 0xcd */, 0 /* 0xce */, 0 /* 0xcf */, 0 /* 0xd0 */, 0 /* 0xd1 */,

+ 0 /* 0xd2 */, 0 /* 0xd3 */, 0 /* 0xd4 */, 0 /* 0xd5 */, 0 /* 0xd6 */,

+ 0 /* 0xd7 */, 0 /* 0xd8 */, 0 /* 0xd9 */, 0 /* 0xda */, 0 /* 0xdb */,

+ 0 /* 0xdc */, 0 /* 0xdd */, 0 /* 0xde */, 0 /* 0xdf */, 0 /* 0xe0 */,

+ 0 /* 0xe1 */, 0 /* 0xe2 */, 0 /* 0xe3 */, 0 /* 0xe4 */, 0 /* 0xe5 */,

+ 0 /* 0xe6 */, 0 /* 0xe7 */, 0 /* 0xe8 */, 0 /* 0xe9 */, 0 /* 0xea */,

+ 0 /* 0xeb */, 0 /* 0xec */, 0 /* 0xed */, 0 /* 0xee */, 0 /* 0xef */,

+ 0 /* 0xf0 */, 0 /* 0xf1 */, 0 /* 0xf2 */, 0 /* 0xf3 */, 0 /* 0xf4 */,

+ 0 /* 0xf5 */, 0 /* 0xf6 */, 0 /* 0xf7 */, 0 /* 0xf8 */, 0 /* 0xf9 */,

+ 0 /* 0xfa */, 0 /* 0xfb */, 0 /* 0xfc */, 0 /* 0xfd */, 0 /* 0xfe */,

+ 0 /* 0xff */,

+};

+

+static ssize_t sf_parse_key(const uint8_t *begin, const uint8_t *end) {

+ const uint8_t *p = begin;

+

+ if ((*p < 'a' || 'z' < *p) && *p != '*') {

+ return -1;

+ }

+

+ for (; p != end && SF_KEY_CHARS[*p]; ++p)

+ ;

+

+ return p - begin;

+}

+

+static ssize_t sf_parse_integer_or_decimal(nghttp2_sf_value *dest,

+ const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+ int sign = 1;

+ int64_t value = 0;

+ int type = NGHTTP2_SF_VALUE_TYPE_INTEGER;

+ size_t len = 0;

+ size_t fpos = 0;

+ size_t i;

+

+ if (*p == '-') {

+ if (++p == end) {

+ return -1;

+ }

+

+ sign = -1;

+ }

+

+ if (*p < '0' || '9' < *p) {

+ return -1;

+ }

+

+ for (; p != end; ++p) {

+ switch (*p) {

+ case '0':

+ case '1':

+ case '2':

+ case '3':

+ case '4':

+ case '5':

+ case '6':

+ case '7':

+ case '8':

+ case '9':

+ value *= 10;

+ value += *p - '0';

+

+ if (++len > 15) {

+ return -1;

+ }

+

+ break;

+ case '.':

+ if (type != NGHTTP2_SF_VALUE_TYPE_INTEGER) {

+ goto fin;

+ }

+

+ if (len > 12) {

+ return -1;

+ }

+ fpos = len;

+ type = NGHTTP2_SF_VALUE_TYPE_DECIMAL;

+

+ break;

+ default:

+ goto fin;

+ };

+ }

+

+fin:

+ switch (type) {

+ case NGHTTP2_SF_VALUE_TYPE_INTEGER:

+ if (dest) {

+ dest->type = (uint8_t)type;

+ dest->i = value * sign;

+ }

+

+ return p - begin;

+ case NGHTTP2_SF_VALUE_TYPE_DECIMAL:

+ if (fpos == len || len - fpos > 3) {

+ return -1;

+ }

+

+ if (dest) {

+ dest->type = (uint8_t)type;

+ dest->d = (double)value;

+ for (i = len - fpos; i > 0; --i) {

+ dest->d /= (double)10;

+ }

+ dest->d *= sign;

+ }

+

+ return p - begin;

+ default:

+ assert(0);

+ abort();

+ }

+}

+

+/* Generated by genchartbl.py */

+static const int SF_DQUOTE_CHARS[] = {

+ 0 /* NUL */, 0 /* SOH */, 0 /* STX */, 0 /* ETX */, 0 /* EOT */,

+ 0 /* ENQ */, 0 /* ACK */, 0 /* BEL */, 0 /* BS */, 0 /* HT */,

+ 0 /* LF */, 0 /* VT */, 0 /* FF */, 0 /* CR */, 0 /* SO */,

+ 0 /* SI */, 0 /* DLE */, 0 /* DC1 */, 0 /* DC2 */, 0 /* DC3 */,

+ 0 /* DC4 */, 0 /* NAK */, 0 /* SYN */, 0 /* ETB */, 0 /* CAN */,

+ 0 /* EM */, 0 /* SUB */, 0 /* ESC */, 0 /* FS */, 0 /* GS */,

+ 0 /* RS */, 0 /* US */, 1 /* SPC */, 1 /* ! */, 0 /* " */,

+ 1 /* # */, 1 /* $ */, 1 /* % */, 1 /* & */, 1 /* ' */,

+ 1 /* ( */, 1 /* ) */, 1 /* * */, 1 /* + */, 1 /* , */,

+ 1 /* - */, 1 /* . */, 1 /* / */, 1 /* 0 */, 1 /* 1 */,

+ 1 /* 2 */, 1 /* 3 */, 1 /* 4 */, 1 /* 5 */, 1 /* 6 */,

+ 1 /* 7 */, 1 /* 8 */, 1 /* 9 */, 1 /* : */, 1 /* ; */,

+ 1 /* < */, 1 /* = */, 1 /* > */, 1 /* ? */, 1 /* @ */,

+ 1 /* A */, 1 /* B */, 1 /* C */, 1 /* D */, 1 /* E */,

+ 1 /* F */, 1 /* G */, 1 /* H */, 1 /* I */, 1 /* J */,

+ 1 /* K */, 1 /* L */, 1 /* M */, 1 /* N */, 1 /* O */,

+ 1 /* P */, 1 /* Q */, 1 /* R */, 1 /* S */, 1 /* T */,

+ 1 /* U */, 1 /* V */, 1 /* W */, 1 /* X */, 1 /* Y */,

+ 1 /* Z */, 1 /* [ */, 0 /* \ */, 1 /* ] */, 1 /* ^ */,

+ 1 /* _ */, 1 /* ` */, 1 /* a */, 1 /* b */, 1 /* c */,

+ 1 /* d */, 1 /* e */, 1 /* f */, 1 /* g */, 1 /* h */,

+ 1 /* i */, 1 /* j */, 1 /* k */, 1 /* l */, 1 /* m */,

+ 1 /* n */, 1 /* o */, 1 /* p */, 1 /* q */, 1 /* r */,

+ 1 /* s */, 1 /* t */, 1 /* u */, 1 /* v */, 1 /* w */,

+ 1 /* x */, 1 /* y */, 1 /* z */, 1 /* { */, 1 /* | */,

+ 1 /* } */, 1 /* ~ */, 0 /* DEL */, 0 /* 0x80 */, 0 /* 0x81 */,

+ 0 /* 0x82 */, 0 /* 0x83 */, 0 /* 0x84 */, 0 /* 0x85 */, 0 /* 0x86 */,

+ 0 /* 0x87 */, 0 /* 0x88 */, 0 /* 0x89 */, 0 /* 0x8a */, 0 /* 0x8b */,

+ 0 /* 0x8c */, 0 /* 0x8d */, 0 /* 0x8e */, 0 /* 0x8f */, 0 /* 0x90 */,

+ 0 /* 0x91 */, 0 /* 0x92 */, 0 /* 0x93 */, 0 /* 0x94 */, 0 /* 0x95 */,

+ 0 /* 0x96 */, 0 /* 0x97 */, 0 /* 0x98 */, 0 /* 0x99 */, 0 /* 0x9a */,

+ 0 /* 0x9b */, 0 /* 0x9c */, 0 /* 0x9d */, 0 /* 0x9e */, 0 /* 0x9f */,

+ 0 /* 0xa0 */, 0 /* 0xa1 */, 0 /* 0xa2 */, 0 /* 0xa3 */, 0 /* 0xa4 */,

+ 0 /* 0xa5 */, 0 /* 0xa6 */, 0 /* 0xa7 */, 0 /* 0xa8 */, 0 /* 0xa9 */,

+ 0 /* 0xaa */, 0 /* 0xab */, 0 /* 0xac */, 0 /* 0xad */, 0 /* 0xae */,

+ 0 /* 0xaf */, 0 /* 0xb0 */, 0 /* 0xb1 */, 0 /* 0xb2 */, 0 /* 0xb3 */,

+ 0 /* 0xb4 */, 0 /* 0xb5 */, 0 /* 0xb6 */, 0 /* 0xb7 */, 0 /* 0xb8 */,

+ 0 /* 0xb9 */, 0 /* 0xba */, 0 /* 0xbb */, 0 /* 0xbc */, 0 /* 0xbd */,

+ 0 /* 0xbe */, 0 /* 0xbf */, 0 /* 0xc0 */, 0 /* 0xc1 */, 0 /* 0xc2 */,

+ 0 /* 0xc3 */, 0 /* 0xc4 */, 0 /* 0xc5 */, 0 /* 0xc6 */, 0 /* 0xc7 */,

+ 0 /* 0xc8 */, 0 /* 0xc9 */, 0 /* 0xca */, 0 /* 0xcb */, 0 /* 0xcc */,

+ 0 /* 0xcd */, 0 /* 0xce */, 0 /* 0xcf */, 0 /* 0xd0 */, 0 /* 0xd1 */,

+ 0 /* 0xd2 */, 0 /* 0xd3 */, 0 /* 0xd4 */, 0 /* 0xd5 */, 0 /* 0xd6 */,

+ 0 /* 0xd7 */, 0 /* 0xd8 */, 0 /* 0xd9 */, 0 /* 0xda */, 0 /* 0xdb */,

+ 0 /* 0xdc */, 0 /* 0xdd */, 0 /* 0xde */, 0 /* 0xdf */, 0 /* 0xe0 */,

+ 0 /* 0xe1 */, 0 /* 0xe2 */, 0 /* 0xe3 */, 0 /* 0xe4 */, 0 /* 0xe5 */,

+ 0 /* 0xe6 */, 0 /* 0xe7 */, 0 /* 0xe8 */, 0 /* 0xe9 */, 0 /* 0xea */,

+ 0 /* 0xeb */, 0 /* 0xec */, 0 /* 0xed */, 0 /* 0xee */, 0 /* 0xef */,

+ 0 /* 0xf0 */, 0 /* 0xf1 */, 0 /* 0xf2 */, 0 /* 0xf3 */, 0 /* 0xf4 */,

+ 0 /* 0xf5 */, 0 /* 0xf6 */, 0 /* 0xf7 */, 0 /* 0xf8 */, 0 /* 0xf9 */,

+ 0 /* 0xfa */, 0 /* 0xfb */, 0 /* 0xfc */, 0 /* 0xfd */, 0 /* 0xfe */,

+ 0 /* 0xff */,

+};

+

+static ssize_t sf_parse_string(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+

+ if (*p++ != '"') {

+ return -1;

+ }

+

+ for (; p != end; ++p) {

+ switch (*p) {

+ case '\\':

+ if (++p == end) {

+ return -1;

+ }

+

+ switch (*p) {

+ case '"':

+ case '\\':

+ break;

+ default:

+ return -1;

+ }

+

+ break;

+ case '"':

+ if (dest) {

+ dest->type = NGHTTP2_SF_VALUE_TYPE_STRING;

+ dest->s.base = begin + 1;

+ dest->s.len = (size_t)(p - dest->s.base);

+ }

+

+ ++p;

+

+ return p - begin;

+ default:

+ if (!SF_DQUOTE_CHARS[*p]) {

+ return -1;

+ }

+ }

+ }

+

+ return -1;

+}

+

+/* Generated by genchartbl.py */

+static const int SF_TOKEN_CHARS[] = {

+ 0 /* NUL */, 0 /* SOH */, 0 /* STX */, 0 /* ETX */, 0 /* EOT */,

+ 0 /* ENQ */, 0 /* ACK */, 0 /* BEL */, 0 /* BS */, 0 /* HT */,

+ 0 /* LF */, 0 /* VT */, 0 /* FF */, 0 /* CR */, 0 /* SO */,

+ 0 /* SI */, 0 /* DLE */, 0 /* DC1 */, 0 /* DC2 */, 0 /* DC3 */,

+ 0 /* DC4 */, 0 /* NAK */, 0 /* SYN */, 0 /* ETB */, 0 /* CAN */,

+ 0 /* EM */, 0 /* SUB */, 0 /* ESC */, 0 /* FS */, 0 /* GS */,

+ 0 /* RS */, 0 /* US */, 0 /* SPC */, 1 /* ! */, 0 /* " */,

+ 1 /* # */, 1 /* $ */, 1 /* % */, 1 /* & */, 1 /* ' */,

+ 0 /* ( */, 0 /* ) */, 1 /* * */, 1 /* + */, 0 /* , */,

+ 1 /* - */, 1 /* . */, 1 /* / */, 1 /* 0 */, 1 /* 1 */,

+ 1 /* 2 */, 1 /* 3 */, 1 /* 4 */, 1 /* 5 */, 1 /* 6 */,

+ 1 /* 7 */, 1 /* 8 */, 1 /* 9 */, 1 /* : */, 0 /* ; */,

+ 0 /* < */, 0 /* = */, 0 /* > */, 0 /* ? */, 0 /* @ */,

+ 1 /* A */, 1 /* B */, 1 /* C */, 1 /* D */, 1 /* E */,

+ 1 /* F */, 1 /* G */, 1 /* H */, 1 /* I */, 1 /* J */,

+ 1 /* K */, 1 /* L */, 1 /* M */, 1 /* N */, 1 /* O */,

+ 1 /* P */, 1 /* Q */, 1 /* R */, 1 /* S */, 1 /* T */,

+ 1 /* U */, 1 /* V */, 1 /* W */, 1 /* X */, 1 /* Y */,

+ 1 /* Z */, 0 /* [ */, 0 /* \ */, 0 /* ] */, 1 /* ^ */,

+ 1 /* _ */, 1 /* ` */, 1 /* a */, 1 /* b */, 1 /* c */,

+ 1 /* d */, 1 /* e */, 1 /* f */, 1 /* g */, 1 /* h */,

+ 1 /* i */, 1 /* j */, 1 /* k */, 1 /* l */, 1 /* m */,

+ 1 /* n */, 1 /* o */, 1 /* p */, 1 /* q */, 1 /* r */,

+ 1 /* s */, 1 /* t */, 1 /* u */, 1 /* v */, 1 /* w */,

+ 1 /* x */, 1 /* y */, 1 /* z */, 0 /* { */, 1 /* | */,

+ 0 /* } */, 1 /* ~ */, 0 /* DEL */, 0 /* 0x80 */, 0 /* 0x81 */,

+ 0 /* 0x82 */, 0 /* 0x83 */, 0 /* 0x84 */, 0 /* 0x85 */, 0 /* 0x86 */,

+ 0 /* 0x87 */, 0 /* 0x88 */, 0 /* 0x89 */, 0 /* 0x8a */, 0 /* 0x8b */,

+ 0 /* 0x8c */, 0 /* 0x8d */, 0 /* 0x8e */, 0 /* 0x8f */, 0 /* 0x90 */,

+ 0 /* 0x91 */, 0 /* 0x92 */, 0 /* 0x93 */, 0 /* 0x94 */, 0 /* 0x95 */,

+ 0 /* 0x96 */, 0 /* 0x97 */, 0 /* 0x98 */, 0 /* 0x99 */, 0 /* 0x9a */,

+ 0 /* 0x9b */, 0 /* 0x9c */, 0 /* 0x9d */, 0 /* 0x9e */, 0 /* 0x9f */,

+ 0 /* 0xa0 */, 0 /* 0xa1 */, 0 /* 0xa2 */, 0 /* 0xa3 */, 0 /* 0xa4 */,

+ 0 /* 0xa5 */, 0 /* 0xa6 */, 0 /* 0xa7 */, 0 /* 0xa8 */, 0 /* 0xa9 */,

+ 0 /* 0xaa */, 0 /* 0xab */, 0 /* 0xac */, 0 /* 0xad */, 0 /* 0xae */,

+ 0 /* 0xaf */, 0 /* 0xb0 */, 0 /* 0xb1 */, 0 /* 0xb2 */, 0 /* 0xb3 */,

+ 0 /* 0xb4 */, 0 /* 0xb5 */, 0 /* 0xb6 */, 0 /* 0xb7 */, 0 /* 0xb8 */,

+ 0 /* 0xb9 */, 0 /* 0xba */, 0 /* 0xbb */, 0 /* 0xbc */, 0 /* 0xbd */,

+ 0 /* 0xbe */, 0 /* 0xbf */, 0 /* 0xc0 */, 0 /* 0xc1 */, 0 /* 0xc2 */,

+ 0 /* 0xc3 */, 0 /* 0xc4 */, 0 /* 0xc5 */, 0 /* 0xc6 */, 0 /* 0xc7 */,

+ 0 /* 0xc8 */, 0 /* 0xc9 */, 0 /* 0xca */, 0 /* 0xcb */, 0 /* 0xcc */,

+ 0 /* 0xcd */, 0 /* 0xce */, 0 /* 0xcf */, 0 /* 0xd0 */, 0 /* 0xd1 */,

+ 0 /* 0xd2 */, 0 /* 0xd3 */, 0 /* 0xd4 */, 0 /* 0xd5 */, 0 /* 0xd6 */,

+ 0 /* 0xd7 */, 0 /* 0xd8 */, 0 /* 0xd9 */, 0 /* 0xda */, 0 /* 0xdb */,

+ 0 /* 0xdc */, 0 /* 0xdd */, 0 /* 0xde */, 0 /* 0xdf */, 0 /* 0xe0 */,

+ 0 /* 0xe1 */, 0 /* 0xe2 */, 0 /* 0xe3 */, 0 /* 0xe4 */, 0 /* 0xe5 */,

+ 0 /* 0xe6 */, 0 /* 0xe7 */, 0 /* 0xe8 */, 0 /* 0xe9 */, 0 /* 0xea */,

+ 0 /* 0xeb */, 0 /* 0xec */, 0 /* 0xed */, 0 /* 0xee */, 0 /* 0xef */,

+ 0 /* 0xf0 */, 0 /* 0xf1 */, 0 /* 0xf2 */, 0 /* 0xf3 */, 0 /* 0xf4 */,

+ 0 /* 0xf5 */, 0 /* 0xf6 */, 0 /* 0xf7 */, 0 /* 0xf8 */, 0 /* 0xf9 */,

+ 0 /* 0xfa */, 0 /* 0xfb */, 0 /* 0xfc */, 0 /* 0xfd */, 0 /* 0xfe */,

+ 0 /* 0xff */,

+};

+

+static ssize_t sf_parse_token(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+

+ if ((*p < 'A' || 'Z' < *p) && (*p < 'a' || 'z' < *p) && *p != '*') {

+ return -1;

+ }

+

+ for (; p != end && SF_TOKEN_CHARS[*p]; ++p)

+ ;

+

+ if (dest) {

+ dest->type = NGHTTP2_SF_VALUE_TYPE_TOKEN;

+ dest->s.base = begin;

+ dest->s.len = (size_t)(p - begin);

+ }

+

+ return p - begin;

+}

+

+/* Generated by genchartbl.py */

+static const int SF_BYTESEQ_CHARS[] = {

+ 0 /* NUL */, 0 /* SOH */, 0 /* STX */, 0 /* ETX */, 0 /* EOT */,

+ 0 /* ENQ */, 0 /* ACK */, 0 /* BEL */, 0 /* BS */, 0 /* HT */,

+ 0 /* LF */, 0 /* VT */, 0 /* FF */, 0 /* CR */, 0 /* SO */,

+ 0 /* SI */, 0 /* DLE */, 0 /* DC1 */, 0 /* DC2 */, 0 /* DC3 */,

+ 0 /* DC4 */, 0 /* NAK */, 0 /* SYN */, 0 /* ETB */, 0 /* CAN */,

+ 0 /* EM */, 0 /* SUB */, 0 /* ESC */, 0 /* FS */, 0 /* GS */,

+ 0 /* RS */, 0 /* US */, 0 /* SPC */, 0 /* ! */, 0 /* " */,

+ 0 /* # */, 0 /* $ */, 0 /* % */, 0 /* & */, 0 /* ' */,

+ 0 /* ( */, 0 /* ) */, 0 /* * */, 1 /* + */, 0 /* , */,

+ 0 /* - */, 0 /* . */, 1 /* / */, 1 /* 0 */, 1 /* 1 */,

+ 1 /* 2 */, 1 /* 3 */, 1 /* 4 */, 1 /* 5 */, 1 /* 6 */,

+ 1 /* 7 */, 1 /* 8 */, 1 /* 9 */, 0 /* : */, 0 /* ; */,

+ 0 /* < */, 1 /* = */, 0 /* > */, 0 /* ? */, 0 /* @ */,

+ 1 /* A */, 1 /* B */, 1 /* C */, 1 /* D */, 1 /* E */,

+ 1 /* F */, 1 /* G */, 1 /* H */, 1 /* I */, 1 /* J */,

+ 1 /* K */, 1 /* L */, 1 /* M */, 1 /* N */, 1 /* O */,

+ 1 /* P */, 1 /* Q */, 1 /* R */, 1 /* S */, 1 /* T */,

+ 1 /* U */, 1 /* V */, 1 /* W */, 1 /* X */, 1 /* Y */,

+ 1 /* Z */, 0 /* [ */, 0 /* \ */, 0 /* ] */, 0 /* ^ */,

+ 0 /* _ */, 0 /* ` */, 1 /* a */, 1 /* b */, 1 /* c */,

+ 1 /* d */, 1 /* e */, 1 /* f */, 1 /* g */, 1 /* h */,

+ 1 /* i */, 1 /* j */, 1 /* k */, 1 /* l */, 1 /* m */,

+ 1 /* n */, 1 /* o */, 1 /* p */, 1 /* q */, 1 /* r */,

+ 1 /* s */, 1 /* t */, 1 /* u */, 1 /* v */, 1 /* w */,

+ 1 /* x */, 1 /* y */, 1 /* z */, 0 /* { */, 0 /* | */,

+ 0 /* } */, 0 /* ~ */, 0 /* DEL */, 0 /* 0x80 */, 0 /* 0x81 */,

+ 0 /* 0x82 */, 0 /* 0x83 */, 0 /* 0x84 */, 0 /* 0x85 */, 0 /* 0x86 */,

+ 0 /* 0x87 */, 0 /* 0x88 */, 0 /* 0x89 */, 0 /* 0x8a */, 0 /* 0x8b */,

+ 0 /* 0x8c */, 0 /* 0x8d */, 0 /* 0x8e */, 0 /* 0x8f */, 0 /* 0x90 */,

+ 0 /* 0x91 */, 0 /* 0x92 */, 0 /* 0x93 */, 0 /* 0x94 */, 0 /* 0x95 */,

+ 0 /* 0x96 */, 0 /* 0x97 */, 0 /* 0x98 */, 0 /* 0x99 */, 0 /* 0x9a */,

+ 0 /* 0x9b */, 0 /* 0x9c */, 0 /* 0x9d */, 0 /* 0x9e */, 0 /* 0x9f */,

+ 0 /* 0xa0 */, 0 /* 0xa1 */, 0 /* 0xa2 */, 0 /* 0xa3 */, 0 /* 0xa4 */,

+ 0 /* 0xa5 */, 0 /* 0xa6 */, 0 /* 0xa7 */, 0 /* 0xa8 */, 0 /* 0xa9 */,

+ 0 /* 0xaa */, 0 /* 0xab */, 0 /* 0xac */, 0 /* 0xad */, 0 /* 0xae */,

+ 0 /* 0xaf */, 0 /* 0xb0 */, 0 /* 0xb1 */, 0 /* 0xb2 */, 0 /* 0xb3 */,

+ 0 /* 0xb4 */, 0 /* 0xb5 */, 0 /* 0xb6 */, 0 /* 0xb7 */, 0 /* 0xb8 */,

+ 0 /* 0xb9 */, 0 /* 0xba */, 0 /* 0xbb */, 0 /* 0xbc */, 0 /* 0xbd */,

+ 0 /* 0xbe */, 0 /* 0xbf */, 0 /* 0xc0 */, 0 /* 0xc1 */, 0 /* 0xc2 */,

+ 0 /* 0xc3 */, 0 /* 0xc4 */, 0 /* 0xc5 */, 0 /* 0xc6 */, 0 /* 0xc7 */,

+ 0 /* 0xc8 */, 0 /* 0xc9 */, 0 /* 0xca */, 0 /* 0xcb */, 0 /* 0xcc */,

+ 0 /* 0xcd */, 0 /* 0xce */, 0 /* 0xcf */, 0 /* 0xd0 */, 0 /* 0xd1 */,

+ 0 /* 0xd2 */, 0 /* 0xd3 */, 0 /* 0xd4 */, 0 /* 0xd5 */, 0 /* 0xd6 */,

+ 0 /* 0xd7 */, 0 /* 0xd8 */, 0 /* 0xd9 */, 0 /* 0xda */, 0 /* 0xdb */,

+ 0 /* 0xdc */, 0 /* 0xdd */, 0 /* 0xde */, 0 /* 0xdf */, 0 /* 0xe0 */,

+ 0 /* 0xe1 */, 0 /* 0xe2 */, 0 /* 0xe3 */, 0 /* 0xe4 */, 0 /* 0xe5 */,

+ 0 /* 0xe6 */, 0 /* 0xe7 */, 0 /* 0xe8 */, 0 /* 0xe9 */, 0 /* 0xea */,

+ 0 /* 0xeb */, 0 /* 0xec */, 0 /* 0xed */, 0 /* 0xee */, 0 /* 0xef */,

+ 0 /* 0xf0 */, 0 /* 0xf1 */, 0 /* 0xf2 */, 0 /* 0xf3 */, 0 /* 0xf4 */,

+ 0 /* 0xf5 */, 0 /* 0xf6 */, 0 /* 0xf7 */, 0 /* 0xf8 */, 0 /* 0xf9 */,

+ 0 /* 0xfa */, 0 /* 0xfb */, 0 /* 0xfc */, 0 /* 0xfd */, 0 /* 0xfe */,

+ 0 /* 0xff */,

+};

+

+static ssize_t sf_parse_byteseq(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+

+ if (*p++ != ':') {

+ return -1;

+ }

+

+ for (; p != end; ++p) {

+ switch (*p) {

+ case ':':

+ if (dest) {

+ dest->type = NGHTTP2_SF_VALUE_TYPE_BYTESEQ;

+ dest->s.base = begin + 1;

+ dest->s.len = (size_t)(p - dest->s.base);

+ }

+

+ ++p;

+

+ return p - begin;

+ default:

+ if (!SF_BYTESEQ_CHARS[*p]) {

+ return -1;

+ }

+ }

+ }

+

+ return -1;

+}

+

+static ssize_t sf_parse_boolean(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+ int b;

+

+ if (*p++ != '?') {

+ return -1;

+ }

+

+ if (p == end) {

+ return -1;

+ }

+

+ switch (*p++) {

+ case '0':

+ b = 0;

+ break;

+ case '1':

+ b = 1;

+ break;

+ default:

+ return -1;

+ }

+

+ if (dest) {

+ dest->type = NGHTTP2_SF_VALUE_TYPE_BOOLEAN;

+ dest->b = b;

+ }

+

+ return p - begin;

+}

+

+static ssize_t sf_parse_bare_item(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ switch (*begin) {

+ case '-':

+ case '0':

+ case '1':

+ case '2':

+ case '3':

+ case '4':

+ case '5':

+ case '6':

+ case '7':

+ case '8':

+ case '9':

+ return sf_parse_integer_or_decimal(dest, begin, end);

+ case '"':

+ return sf_parse_string(dest, begin, end);

+ case '*':

+ return sf_parse_token(dest, begin, end);

+ case ':':

+ return sf_parse_byteseq(dest, begin, end);

+ case '?':

+ return sf_parse_boolean(dest, begin, end);

+ default:

+ if (('A' <= *begin && *begin <= 'Z') || ('a' <= *begin && *begin <= 'z')) {

+ return sf_parse_token(dest, begin, end);

+ }

+ return -1;

+ }

+}

+

+#define sf_discard_sp_end_err(BEGIN, END, ERR) \

+ for (;; ++(BEGIN)) { \

+ if ((BEGIN) == (END)) { \

+ return (ERR); \

+ } \

+ if (*(BEGIN) != ' ') { \

+ break; \

+ } \

+ }

+

+static ssize_t sf_parse_params(const uint8_t *begin, const uint8_t *end) {

+ const uint8_t *p = begin;

+ ssize_t slen;

+

+ for (; p != end && *p == ';';) {

+ ++p;

+

+ sf_discard_sp_end_err(p, end, -1);

+

+ slen = sf_parse_key(p, end);

+ if (slen < 0) {

+ return -1;

+ }

+

+ p += slen;

+

+ if (p == end || *p != '=') {

+ /* Boolean true */

+ } else if (++p == end) {

+ return -1;

+ } else {

+ slen = sf_parse_bare_item(NULL, p, end);

+ if (slen < 0) {

+ return -1;

+ }

+

+ p += slen;

+ }

+ }

+

+ return p - begin;

+}

+

+static ssize_t sf_parse_item(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+ ssize_t slen;

+

+ slen = sf_parse_bare_item(dest, p, end);

+ if (slen < 0) {

+ return -1;

+ }

+

+ p += slen;

+

+ slen = sf_parse_params(p, end);

+ if (slen < 0) {

+ return -1;

+ }

+

+ p += slen;

+

+ return p - begin;

+}

+

+ssize_t nghttp2_sf_parse_item(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ return sf_parse_item(dest, begin, end);

+}

+

+static ssize_t sf_parse_inner_list(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end) {

+ const uint8_t *p = begin;

+ ssize_t slen;

+

+ if (*p++ != '(') {

+ return -1;

+ }

+

+ for (;;) {

+ sf_discard_sp_end_err(p, end, -1);

+

+ if (*p == ')') {

+ ++p;

+

+ slen = sf_parse_params(p, end);

+ if (slen < 0) {

+ return -1;

+ }

+

+ p += slen;

+

+ if (dest) {

+ dest->type = NGHTTP2_SF_VALUE_TYPE_INNER_LIST;

+ }

+

+ return p - begin;

+ }

+

+ slen = sf_parse_item(NULL, p, end);

+ if (slen < 0) {

+ return -1;

+ }

+

+ p += slen;

+

+ if (p == end || (*p != ' ' && *p != ')')) {

+ return -1;

+ }

+ }

+}

+

+ssize_t nghttp2_sf_parse_inner_list(nghttp2_sf_value *dest,

+ const uint8_t *begin, const uint8_t *end) {

+ return sf_parse_inner_list(dest, begin, end);

+}

+

+static ssize_t sf_parse_item_or_inner_list(nghttp2_sf_value *dest,

+ const uint8_t *begin,

+ const uint8_t *end) {

+ if (*begin == '(') {

+ return sf_parse_inner_list(dest, begin, end);

+ }

+

+ return sf_parse_item(dest, begin, end);

+}

+

+#define sf_discard_ows(BEGIN, END) \

+ for (;; ++(BEGIN)) { \

+ if ((BEGIN) == (END)) { \

+ goto fin; \

+ } \

+ if (*(BEGIN) != ' ' && *(BEGIN) != '\t') { \

+ break; \

+ } \

+ }

+

+#define sf_discard_ows_end_err(BEGIN, END, ERR) \

+ for (;; ++(BEGIN)) { \

+ if ((BEGIN) == (END)) { \

+ return (ERR); \

+ } \

+ if (*(BEGIN) != ' ' && *(BEGIN) != '\t') { \

+ break; \

+ } \

+ }

+

+int nghttp2_http_parse_priority(nghttp2_extpri *dest, const uint8_t *value,

+ size_t valuelen) {

+ const uint8_t *p = value, *end = value + valuelen;

+ ssize_t slen;

+ nghttp2_sf_value val;

+ nghttp2_extpri pri = *dest;

+ const uint8_t *key;

+ size_t keylen;

+

+ for (; p != end && *p == ' '; ++p)

+ ;

+

+ for (; p != end;) {

+ slen = sf_parse_key(p, end);

+ if (slen < 0) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ key = p;

+ keylen = (size_t)slen;

+

+ p += slen;

+

+ if (p == end || *p != '=') {

+ /* Boolean true */

+ val.type = NGHTTP2_SF_VALUE_TYPE_BOOLEAN;

+ val.b = 1;

+

+ slen = sf_parse_params(p, end);

+ if (slen < 0) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+ } else if (++p == end) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ } else {

+ slen = sf_parse_item_or_inner_list(&val, p, end);

+ if (slen < 0) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+ }

+

+ p += slen;

+

+ if (keylen == 1) {

+ switch (key[0]) {

+ case 'i':

+ if (val.type != NGHTTP2_SF_VALUE_TYPE_BOOLEAN) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ pri.inc = val.b;

+

+ break;

+ case 'u':

+ if (val.type != NGHTTP2_SF_VALUE_TYPE_INTEGER ||

+ val.i < NGHTTP2_EXTPRI_URGENCY_HIGH ||

+ NGHTTP2_EXTPRI_URGENCY_LOW < val.i) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ pri.urgency = (uint32_t)val.i;

+

+ break;

+ }

+ }

+

+ sf_discard_ows(p, end);

+

+ if (*p++ != ',') {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ sf_discard_ows_end_err(p, end, NGHTTP2_ERR_INVALID_ARGUMENT);

+ }

+

+fin:

+ *dest = pri;

+

+ return 0;

+}

+/*

+ * RFC 8941 Structured Field Values.

+ */

+typedef enum nghttp2_sf_value_type {

+ NGHTTP2_SF_VALUE_TYPE_BOOLEAN,

+ NGHTTP2_SF_VALUE_TYPE_INTEGER,

+ NGHTTP2_SF_VALUE_TYPE_DECIMAL,

+ NGHTTP2_SF_VALUE_TYPE_STRING,

+ NGHTTP2_SF_VALUE_TYPE_TOKEN,

+ NGHTTP2_SF_VALUE_TYPE_BYTESEQ,

+ NGHTTP2_SF_VALUE_TYPE_INNER_LIST,

+} nghttp2_sf_value_type;

+

+/*

+ * nghttp2_sf_value stores Structured Field Values item. For Inner

+ * List, only type is set to NGHTTP2_SF_VALUE_TYPE_INNER_LIST.

+ */

+typedef struct nghttp2_sf_value {

+ uint8_t type;

+ union {

+ int b;

+ int64_t i;

+ double d;

+ struct {

+ const uint8_t *base;

+ size_t len;

+ } s;

+ };

+} nghttp2_sf_value;

+

+/*

+ * nghttp2_sf_parse_item parses the input sequence [|begin|, |end|)

+ * and stores the parsed an Item in |dest|. It returns the number of

+ * bytes consumed if it succeeds, or -1. This function is declared

+ * here for unit tests.

+ */

+ssize_t nghttp2_sf_parse_item(nghttp2_sf_value *dest, const uint8_t *begin,

+ const uint8_t *end);

+

+/*

+ * nghttp2_sf_parse_inner_list parses the input sequence [|begin|, |end|)

+ * and stores the parsed an Inner List in |dest|. It returns the number of

+ * bytes consumed if it succeeds, or -1. This function is declared

+ * here for unit tests.

+ */

+ssize_t nghttp2_sf_parse_inner_list(nghttp2_sf_value *dest,

+ const uint8_t *begin, const uint8_t *end);

+

+int nghttp2_http_parse_priority(nghttp2_extpri *dest, const uint8_t *value,

+ size_t valuelen);

+

+ case NGHTTP2_PRIORITY_UPDATE:

+ option->opt_set_mask |= NGHTTP2_OPT_BUILTIN_RECV_EXT_TYPES;

+ option->builtin_recv_ext_types |= NGHTTP2_TYPEMASK_PRIORITY_UPDATE;

+ return;

+

+void nghttp2_option_set_server_fallback_rfc7540_priorities(

+ nghttp2_option *option, int val) {

+ option->opt_set_mask |= NGHTTP2_OPT_SERVER_FALLBACK_RFC7540_PRIORITIES;

+ option->server_fallback_rfc7540_priorities = val;

+}

+ NGHTTP2_OPT_SERVER_FALLBACK_RFC7540_PRIORITIES = 1 << 13,

+ * NGHTTP2_OPT_SERVER_FALLBACK_RFC7540_PRIORITIES

+ */

+ int server_fallback_rfc7540_priorities;

+ /**

+ case NGHTTP2_PRIORITY_UPDATE:

+ nghttp2_frame_priority_update_free(&frame->ext, mem);

+ break;

+void nghttp2_pq_init(nghttp2_pq *pq, nghttp2_less less, nghttp2_mem *mem) {

+void nghttp2_pq_init(nghttp2_pq *pq, nghttp2_less less, nghttp2_mem *mem);

+#include "nghttp2_extpri.h"

+static int session_no_rfc7540_pri_no_fallback(nghttp2_session *session) {

+ return session->pending_no_rfc7540_priorities == 1 &&

+ !session->fallback_rfc7540_priorities;

+}

+

+ case NGHTTP2_PRIORITY_UPDATE:

+ if ((session->builtin_recv_ext_types &

+ NGHTTP2_TYPEMASK_PRIORITY_UPDATE) == 0) {

+ break;

+ }

+ /* Do not call nghttp2_frame_priority_update_free, because all

+ fields point to sbuf. */

+ break;

+ settings->no_rfc7540_priorities = UINT32_MAX;

+#define NGHTTP2_STREAM_MAX_CYCLE_GAP ((uint64_t)NGHTTP2_MAX_FRAME_SIZE_MAX)

+

+static int stream_less(const void *lhsx, const void *rhsx) {

+ const nghttp2_stream *lhs, *rhs;

+

+ lhs = nghttp2_struct_of(lhsx, nghttp2_stream, pq_entry);

+ rhs = nghttp2_struct_of(rhsx, nghttp2_stream, pq_entry);

+

+ if (lhs->cycle == rhs->cycle) {

+ return lhs->seq < rhs->seq;

+ }

+

+ return rhs->cycle - lhs->cycle <= NGHTTP2_STREAM_MAX_CYCLE_GAP;

+}

+

+ size_t i;

+ (*session_ptr)->pending_no_rfc7540_priorities = UINT8_MAX;

+

+ if ((option->opt_set_mask &

+ NGHTTP2_OPT_SERVER_FALLBACK_RFC7540_PRIORITIES) &&

+ option->server_fallback_rfc7540_priorities) {

+ (*session_ptr)->opt_flags |=

+ NGHTTP2_OPTMASK_SERVER_FALLBACK_RFC7540_PRIORITIES;

+ }

+ for (i = 0; i < NGHTTP2_EXTPRI_URGENCY_LEVELS; ++i) {

+ nghttp2_pq_init(&(*session_ptr)->sched[i].ob_data, stream_less, mem);

+ }

+

+ size_t i;

+ for (i = 0; i < NGHTTP2_EXTPRI_URGENCY_LEVELS; ++i) {

+ nghttp2_pq_free(&session->sched[i].ob_data);

+ }

+ assert((!session->server && session->pending_no_rfc7540_priorities != 1) ||

+ (session->server && !session_no_rfc7540_pri_no_fallback(session)));

+static uint64_t pq_get_first_cycle(nghttp2_pq *pq) {

+ nghttp2_stream *stream;

+

+ if (nghttp2_pq_empty(pq)) {

+ return 0;

+ }

+

+ stream = nghttp2_struct_of(nghttp2_pq_top(pq), nghttp2_stream, pq_entry);

+ return stream->cycle;

+}

+

+static int session_ob_data_push(nghttp2_session *session,

+ nghttp2_stream *stream) {

+ int rv;

+ uint32_t urgency;

+ int inc;

+ nghttp2_pq *pq;

+

+ assert(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES);

+ assert(stream->queued == 0);

+

+ urgency = nghttp2_extpri_uint8_urgency(stream->extpri);

+ inc = nghttp2_extpri_uint8_inc(stream->extpri);

+

+ assert(urgency < NGHTTP2_EXTPRI_URGENCY_LEVELS);

+

+ pq = &session->sched[urgency].ob_data;

+

+ stream->cycle = pq_get_first_cycle(pq);

+ if (inc) {

+ stream->cycle += stream->last_writelen;

+ }

+

+ rv = nghttp2_pq_push(pq, &stream->pq_entry);

+ if (rv != 0) {

+ return rv;

+ }

+

+ stream->queued = 1;

+

+ return 0;

+}

+

+static int session_ob_data_remove(nghttp2_session *session,

+ nghttp2_stream *stream) {

+ uint32_t urgency;

+

+ assert(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES);

+ assert(stream->queued == 1);

+

+ urgency = nghttp2_extpri_uint8_urgency(stream->extpri);

+

+ assert(urgency < NGHTTP2_EXTPRI_URGENCY_LEVELS);

+

+ nghttp2_pq_remove(&session->sched[urgency].ob_data, &stream->pq_entry);

+

+ stream->queued = 0;

+

+ return 0;

+}

+

+static int session_attach_stream_item(nghttp2_session *session,

+ nghttp2_stream *stream,

+ nghttp2_outbound_item *item) {

+ int rv;

+

+ rv = nghttp2_stream_attach_item(stream, item);

+ if (rv != 0) {

+ return rv;

+ }

+

+ if (!(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES)) {

+ return 0;

+ }

+

+ return session_ob_data_push(session, stream);

+}

+

+static int session_detach_stream_item(nghttp2_session *session,

+ nghttp2_stream *stream) {

+ int rv;

+

+ rv = nghttp2_stream_detach_item(stream);

+ if (rv != 0) {

+ return rv;

+ }

+

+ if (!(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) ||

+ !stream->queued) {

+ return 0;

+ }

+

+ return session_ob_data_remove(session, stream);

+}

+

+static int session_defer_stream_item(nghttp2_session *session,

+ nghttp2_stream *stream, uint8_t flags) {

+ int rv;

+

+ rv = nghttp2_stream_defer_item(stream, flags);

+ if (rv != 0) {

+ return rv;

+ }

+

+ if (!(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) ||

+ !stream->queued) {

+ return 0;

+ }

+

+ return session_ob_data_remove(session, stream);

+}

+

+static int session_resume_deferred_stream_item(nghttp2_session *session,

+ nghttp2_stream *stream,

+ uint8_t flags) {

+ int rv;

+

+ rv = nghttp2_stream_resume_deferred_item(stream, flags);

+ if (rv != 0) {

+ return rv;

+ }

+

+ if (!(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) ||

+ (stream->flags & NGHTTP2_STREAM_FLAG_DEFERRED_ALL)) {

+ return 0;

+ }

+

+ return session_ob_data_push(session, stream);

+}

+

+static nghttp2_outbound_item *

+session_sched_get_next_outbound_item(nghttp2_session *session) {

+ size_t i;

+ nghttp2_pq_entry *ent;

+ nghttp2_stream *stream;

+

+ for (i = 0; i < NGHTTP2_EXTPRI_URGENCY_LEVELS; ++i) {

+ ent = nghttp2_pq_top(&session->sched[i].ob_data);

+ if (!ent) {

+ continue;

+ }

+

+ stream = nghttp2_struct_of(ent, nghttp2_stream, pq_entry);

+ return stream->item;

+ }

+

+ return NULL;

+}

+

+static int session_sched_empty(nghttp2_session *session) {

+ size_t i;

+

+ for (i = 0; i < NGHTTP2_EXTPRI_URGENCY_LEVELS; ++i) {

+ if (!nghttp2_pq_empty(&session->sched[i].ob_data)) {

+ return 0;

+ }

+ }

+

+ return 1;

+}

+

+static void session_sched_reschedule_stream(nghttp2_session *session,

+ nghttp2_stream *stream) {

+ nghttp2_pq *pq;

+ uint32_t urgency = nghttp2_extpri_uint8_urgency(stream->extpri);

+ int inc = nghttp2_extpri_uint8_inc(stream->extpri);

+ uint64_t penalty = (uint64_t)stream->last_writelen;

+ int rv;

+

+ (void)rv;

+

+ assert(urgency < NGHTTP2_EXTPRI_URGENCY_LEVELS);

+

+ pq = &session->sched[urgency].ob_data;

+

+ if (!inc || nghttp2_pq_size(pq) == 1) {

+ return;

+ }

+

+ nghttp2_pq_remove(pq, &stream->pq_entry);

+

+ stream->cycle += penalty;

+

+ rv = nghttp2_pq_push(pq, &stream->pq_entry);

+

+ assert(0 == rv);

+}

+

+static int session_update_stream_priority(nghttp2_session *session,

+ nghttp2_stream *stream,

+ uint8_t u8extpri) {

+ if (stream->extpri == u8extpri) {

+ return 0;

+ }

+

+ if (stream->queued) {

+ session_ob_data_remove(session, stream);

+

+ stream->extpri = u8extpri;

+

+ return session_ob_data_push(session, stream);

+ }

+

+ stream->extpri = u8extpri;

+

+ return 0;

+}

+

+ rv = session_attach_stream_item(session, stream, item);

+ assert((stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) ||

+ nghttp2_stream_in_dep_tree(stream));

+

+ if (nghttp2_stream_in_dep_tree(stream)) {

+ assert(!(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES));

+ nghttp2_session_detach_idle_stream(session, stream);

+ rv = nghttp2_stream_dep_remove(stream);

+ if (rv != 0) {

+ return NULL;

+ }

+

+ if (session_no_rfc7540_pri_no_fallback(session)) {

+ stream->flags |= NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES;

+ }

+ if (session_no_rfc7540_pri_no_fallback(session) ||

+ session->remote_settings.no_rfc7540_priorities == 1) {

+ /* For client which has not received server

+ SETTINGS_NO_RFC7540_PRIORITIES = 1, send a priority signal

+ opportunistically. */

+ if (session->server ||

+ session->remote_settings.no_rfc7540_priorities == 1) {

+ nghttp2_priority_spec_default_init(&pri_spec_default);

+ pri_spec = &pri_spec_default;

+ }

+

+ if (session->pending_no_rfc7540_priorities == 1) {

+ flags |= NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES;

+ }

+ } else if (pri_spec->stream_id != 0) {

+ if (session_no_rfc7540_pri_no_fallback(session)) {

+ stream->seq = session->stream_seq++;

+ }

+

+ if (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) {

+ return stream;

+ }

+

+ rv = session_detach_stream_item(session, stream);

+ if (session->pending_no_rfc7540_priorities == 1) {

+ return nghttp2_session_destroy_stream(session, stream);

+ }

+

+static int session_predicate_priority_update_send(nghttp2_session *session,

+ int32_t stream_id) {

+ nghttp2_stream *stream;

+

+ if (session_is_closing(session)) {

+ return NGHTTP2_ERR_SESSION_CLOSING;

+ }

+

+ stream = nghttp2_session_get_stream(session, stream_id);

+ if (stream == NULL) {

+ return 0;

+ }

+ if (stream->state == NGHTTP2_STREAM_CLOSING) {

+ return NGHTTP2_ERR_STREAM_CLOSING;

+ }

+ if (stream->shut_flags & NGHTTP2_SHUT_RD) {

+ return NGHTTP2_ERR_INVALID_STREAM_STATE;

+ }

+

+ return 0;

+}

+

+ rv2 = session_detach_stream_item(session, stream);

+ rv = session_defer_stream_item(session, stream,

+ rv = session_defer_stream_item(session, stream,

+ NGHTTP2_STREAM_FLAG_DEFERRED_USER);

+ rv = session_detach_stream_item(session, stream);

+ rv2 = session_detach_stream_item(session, stream);

+ case NGHTTP2_PRIORITY_UPDATE: {

+ nghttp2_ext_priority_update *priority_update = frame->ext.payload;

+ rv = session_predicate_priority_update_send(session,

+ priority_update->stream_id);

+ if (rv != 0) {

+ return rv;

+ }

+

+ nghttp2_frame_pack_priority_update(&session->aob.framebufs, &frame->ext);

+

+ return 0;

+ }

+ nghttp2_outbound_item *item;

+

+ item = nghttp2_stream_next_outbound_item(&session->root);

+ if (item) {

+ return item;

+ }

+

+ return session_sched_get_next_outbound_item(session);

+ item = nghttp2_stream_next_outbound_item(&session->root);

+ if (item) {

+ return item;

+ }

+

+ return session_sched_get_next_outbound_item(session);

+static void session_reschedule_stream(nghttp2_session *session,

+ nghttp2_stream *stream) {

+ if (!(stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES)) {

+ nghttp2_stream_reschedule(stream);

+ return;

+ }

+

+ if (!session->server) {

+ return;

+ }

+

+ session_sched_reschedule_stream(session, stream);

+ rv = session_detach_stream_item(session, stream);

+ if (session->server || session->pending_no_rfc7540_priorities == 1) {

+ rv = session_detach_stream_item(session, stream);

+ rv = session_detach_stream_item(session, stream);

+

+ assert(frame->hd.type == NGHTTP2_HEADERS);

+

+ if (session->server && session_enforce_http_messaging(session) &&

+ frame->headers.cat == NGHTTP2_HCAT_REQUEST &&

+ (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) &&

+ !(stream->flags & NGHTTP2_STREAM_FLAG_IGNORE_CLIENT_PRIORITIES) &&

+ (stream->http_flags & NGHTTP2_HTTP_FLAG_PRIORITY)) {

+ rv = session_update_stream_priority(session, stream, stream->http_extpri);

+ if (rv != 0) {

+ assert(nghttp2_is_fatal(rv));

+ return rv;

+ }

+ }

+

+ assert(!session_no_rfc7540_pri_no_fallback(session));

+

+ assert(!session_no_rfc7540_pri_no_fallback(session));

+

+ rv = session_resume_deferred_stream_item(

+ arg->session, stream, NGHTTP2_STREAM_FLAG_DEFERRED_FLOW_CONTROL);

+

+ if (stream->window_update_queued) {

+ return 0;

+ }

+

+ if (arg->session->opt_flags & NGHTTP2_OPTMASK_NO_AUTO_WINDOW_UPDATE) {

+ return session_update_stream_consumed_size(arg->session, stream, 0);

+ }

+

+ if (nghttp2_should_send_window_update(stream->local_window_size,

+ case NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES:

+ session->local_settings.no_rfc7540_priorities = iv[i].value;

+ break;

+ case NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES:

+

+ if (entry->value != 0 && entry->value != 1) {

+ return session_handle_invalid_connection(

+ session, frame, NGHTTP2_ERR_PROTO,

+ "SETTINGS: invalid SETTINGS_NO_RFC7540_PRIORITIES");

+ }

+

+ if (session->remote_settings.no_rfc7540_priorities != UINT32_MAX &&

+ session->remote_settings.no_rfc7540_priorities != entry->value) {

+ return session_handle_invalid_connection(

+ session, frame, NGHTTP2_ERR_PROTO,

+ "SETTINGS: SETTINGS_NO_RFC7540_PRIORITIES cannot be changed");

+ }

+

+ session->remote_settings.no_rfc7540_priorities = entry->value;

+

+ break;

+ }

+ }

+

+ if (session->remote_settings.no_rfc7540_priorities == UINT32_MAX) {

+ session->remote_settings.no_rfc7540_priorities = 0;

+

+ if (session->server && session->pending_no_rfc7540_priorities &&

+ (session->opt_flags &

+ NGHTTP2_OPTMASK_SERVER_FALLBACK_RFC7540_PRIORITIES)) {

+ session->fallback_rfc7540_priorities = 1;

+ rv = session_resume_deferred_stream_item(

+ session, stream, NGHTTP2_STREAM_FLAG_DEFERRED_FLOW_CONTROL);

+int nghttp2_session_on_priority_update_received(nghttp2_session *session,

+ nghttp2_frame *frame) {

+ nghttp2_ext_priority_update *priority_update;

+ nghttp2_stream *stream;

+ nghttp2_priority_spec pri_spec;

+ nghttp2_extpri extpri;

+ int rv;

+

+ assert(session->server);

+

+ priority_update = frame->ext.payload;

+

+ if (frame->hd.stream_id != 0) {

+ return session_handle_invalid_connection(session, frame, NGHTTP2_ERR_PROTO,

+ "PRIORITY_UPDATE: stream_id == 0");

+ }

+

+ if (nghttp2_session_is_my_stream_id(session, priority_update->stream_id)) {

+ if (session_detect_idle_stream(session, priority_update->stream_id)) {

+ return session_handle_invalid_connection(

+ session, frame, NGHTTP2_ERR_PROTO,

+ "PRIORITY_UPDATE: prioritizing idle push is not allowed");

+ }

+

+ /* TODO Ignore priority signal to a push stream for now */

+ return session_call_on_frame_received(session, frame);

+ }

+

+ stream = nghttp2_session_get_stream_raw(session, priority_update->stream_id);

+ if (stream) {

+ /* Stream already exists. */

+ if (stream->flags & NGHTTP2_STREAM_FLAG_IGNORE_CLIENT_PRIORITIES) {

+ return session_call_on_frame_received(session, frame);

+ }

+ } else if (session_detect_idle_stream(session, priority_update->stream_id)) {

+ if (session->num_idle_streams + session->num_incoming_streams >=

+ session->local_settings.max_concurrent_streams) {

+ return session_handle_invalid_connection(

+ session, frame, NGHTTP2_ERR_PROTO,

+ "PRIORITY_UPDATE: max concurrent streams exceeded");

+ }

+

+ nghttp2_priority_spec_default_init(&pri_spec);

+ stream = nghttp2_session_open_stream(session, priority_update->stream_id,

+ NGHTTP2_FLAG_NONE, &pri_spec,

+ NGHTTP2_STREAM_IDLE, NULL);

+ if (!stream) {

+ return NGHTTP2_ERR_NOMEM;

+ }

+ } else {

+ return session_call_on_frame_received(session, frame);

+ }

+

+ extpri.urgency = NGHTTP2_EXTPRI_DEFAULT_URGENCY;

+ extpri.inc = 0;

+

+ rv = nghttp2_http_parse_priority(&extpri, priority_update->field_value,

+ priority_update->field_value_len);

+ if (rv != 0) {

+ /* Just ignore field_value if it cannot be parsed. */

+ return session_call_on_frame_received(session, frame);

+ }

+

+ rv = session_update_stream_priority(session, stream,

+ nghttp2_extpri_to_uint8(&extpri));

+ if (rv != 0) {

+ if (nghttp2_is_fatal(rv)) {

+ return rv;

+ }

+ }

+

+ return session_call_on_frame_received(session, frame);

+}

+

+static int session_process_priority_update_frame(nghttp2_session *session) {

+ nghttp2_inbound_frame *iframe = &session->iframe;

+ nghttp2_frame *frame = &iframe->frame;

+

+ nghttp2_frame_unpack_priority_update_payload(&frame->ext, iframe->sbuf.pos,

+ nghttp2_buf_len(&iframe->sbuf));

+

+ return nghttp2_session_on_priority_update_received(session, frame);

+}

+

+ case NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES:

+ case NGHTTP2_PRIORITY_UPDATE:

+ if ((session->builtin_recv_ext_types &

+ NGHTTP2_TYPEMASK_PRIORITY_UPDATE) == 0) {

+ busy = 1;

+ iframe->state = NGHTTP2_IB_IGN_PAYLOAD;

+ break;

+ }

+

+ DEBUGF("recv: PRIORITY_UPDATE\n");

+

+ iframe->frame.hd.flags = NGHTTP2_FLAG_NONE;

+ iframe->frame.ext.payload =

+ &iframe->ext_frame_payload.priority_update;

+

+ if (!session->server) {

+ rv = nghttp2_session_terminate_session_with_reason(

+ session, NGHTTP2_PROTOCOL_ERROR,

+ "PRIORITY_UPDATE is received from server");

+ if (nghttp2_is_fatal(rv)) {

+ return rv;

+ }

+ return (ssize_t)inlen;

+ }

+

+ if (iframe->payloadleft < 4) {

+ busy = 1;

+ iframe->state = NGHTTP2_IB_FRAME_SIZE_ERROR;

+ break;

+ }

+

+ if (!session_no_rfc7540_pri_no_fallback(session) ||

+ iframe->payloadleft > sizeof(iframe->raw_sbuf)) {

+ busy = 1;

+ iframe->state = NGHTTP2_IB_IGN_PAYLOAD;

+ break;

+ }

+

+ busy = 1;

+

+ iframe->state = NGHTTP2_IB_READ_NBYTE;

+ inbound_frame_set_mark(iframe, iframe->payloadleft);

+

+ break;

+ if (!session_no_rfc7540_pri_no_fallback(session) &&

+ session->remote_settings.no_rfc7540_priorities != 1) {

+ rv = session_process_priority_frame(session);

+ if (nghttp2_is_fatal(rv)) {

+ return rv;

+ }

+ if (iframe->state == NGHTTP2_IB_IGN_ALL) {

+ return (ssize_t)inlen;

+ }

+ case NGHTTP2_PRIORITY_UPDATE:

+ DEBUGF("recv: prioritized_stream_id=%d\n",

+ nghttp2_get_uint32(iframe->sbuf.pos) & NGHTTP2_STREAM_ID_MASK);

+

+ rv = session_process_priority_update_frame(session);

+ if (nghttp2_is_fatal(rv)) {

+ return rv;

+ }

+

+ session_inbound_frame_reset(session);

+

+ break;

+ ((!nghttp2_pq_empty(&session->root.obq) ||

+ !session_sched_empty(session)) &&

+ uint8_t no_rfc7540_pri = session->pending_no_rfc7540_priorities;

+ for (i = 0; i < niv; ++i) {

+ if (iv[i].settings_id != NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES) {

+ continue;

+ }

+

+ if (no_rfc7540_pri == UINT8_MAX) {

+ no_rfc7540_pri = (uint8_t)iv[i].value;

+ continue;

+ }

+

+ if (iv[i].value != (uint32_t)no_rfc7540_pri) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+ }

+

+ if (no_rfc7540_pri == UINT8_MAX) {

+ session->pending_no_rfc7540_priorities = 0;

+ } else {

+ session->pending_no_rfc7540_priorities = no_rfc7540_pri;

+ }

+

+ session_reschedule_stream(session, stream);

+ rv = session_resume_deferred_stream_item(session, stream,

+ case NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES:

+ return session->remote_settings.no_rfc7540_priorities;

+ case NGHTTP2_SETTINGS_NO_RFC7540_PRIORITIES:

+ return session->local_settings.no_rfc7540_priorities;

+ if (session->pending_no_rfc7540_priorities == 1) {

+ return 0;

+ }

+

+ if (session->pending_no_rfc7540_priorities == 1) {

+ return 0;

+ }

+

+

+int nghttp2_session_change_extpri_stream_priority(

+ nghttp2_session *session, int32_t stream_id,

+ const nghttp2_extpri *extpri_in, int ignore_client_signal) {

+ nghttp2_stream *stream;

+ nghttp2_extpri extpri = *extpri_in;

+

+ if (!session->server) {

+ return NGHTTP2_ERR_INVALID_STATE;

+ }

+

+ if (session->pending_no_rfc7540_priorities != 1) {

+ return 0;

+ }

+

+ if (stream_id == 0) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ stream = nghttp2_session_get_stream_raw(session, stream_id);

+ if (!stream) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ if (extpri.urgency > NGHTTP2_EXTPRI_URGENCY_LOW) {

+ extpri.urgency = NGHTTP2_EXTPRI_URGENCY_LOW;

+ }

+

+ if (ignore_client_signal) {

+ stream->flags |= NGHTTP2_STREAM_FLAG_IGNORE_CLIENT_PRIORITIES;

+ }

+

+ return session_update_stream_priority(session, stream,

+ nghttp2_extpri_to_uint8(&extpri));

+}

+ NGHTTP2_OPTMASK_NO_CLOSED_STREAMS = 1 << 4,

+ NGHTTP2_OPTMASK_SERVER_FALLBACK_RFC7540_PRIORITIES = 1 << 5

+ NGHTTP2_TYPEMASK_ORIGIN = 1 << 1,

+ NGHTTP2_TYPEMASK_PRIORITY_UPDATE = 1 << 2

+ /* Small fixed sized buffer. */

+ uint8_t raw_sbuf[32];

+ uint32_t no_rfc7540_priorities;

+ /* Queues for DATA frames which is used when

+ SETTINGS_NO_RFC7540_PRIORITIES is enabled. This implements RFC

+ 9218 extensible prioritization scheme. */

+ struct {

+ nghttp2_pq ob_data;

+ } sched[NGHTTP2_EXTPRI_URGENCY_LEVELS];

+ /* Sequential number across all streams to process streams in

+ FIFO. */

+ uint64_t stream_seq;

+ /* Unacked local SETTINGS_NO_RFC7540_PRIORITIES value, which is

+ effective before it is acknowledged. */

+ uint8_t pending_no_rfc7540_priorities;

+ /* Turn on fallback to RFC 7540 priorities; for server use only. */

+ uint8_t fallback_rfc7540_priorities;

+ * Called when PRIORITY_UPDATE is received, assuming |frame| is

+ * properly initialized.

+ *

+ * This function returns 0 if it succeeds, or one of the following

+ * negative error codes:

+ *

+ * NGHTTP2_ERR_CALLBACK_FAILURE

+ * The callback function failed.

+ */

+int nghttp2_session_on_priority_update_received(nghttp2_session *session,

+ nghttp2_frame *frame);

+

+/*

+

+ stream->extpri = stream->http_extpri = NGHTTP2_EXTPRI_DEFAULT_URGENCY;

+ if (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) {

+ return 0;

+ }

+

+ if (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) {

+ return 0;

+ }

+

+ if (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) {

+ return 0;

+ }

+

+ if (stream->flags & NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES) {

+ return 0;

+ }

+

+ NGHTTP2_STREAM_FLAG_DEFERRED_ALL = 0x0c,

+ /* Indicates that this stream is not subject to RFC7540

+ priorities scheme. */

+ NGHTTP2_STREAM_FLAG_NO_RFC7540_PRIORITIES = 0x10,

+ /* Ignore client RFC 9218 priority signal. */

+ NGHTTP2_STREAM_FLAG_IGNORE_CLIENT_PRIORITIES = 0x20,

+ /* set if priority header field is received */

+ NGHTTP2_HTTP_FLAG_PRIORITY = 1 << 16,

+ /* set if an error is encountered while parsing priority header

+ field */

+ NGHTTP2_HTTP_FLAG_BAD_PRIORITY = 1 << 17,

+ uint32_t http_flags;

+ /* extpri is a stream priority produced by nghttp2_extpri_to_uint8

+ used by RFC 9218 extensible priorities. */

+ uint8_t extpri;

+ /* http_extpri is a stream priority received in HTTP request header

+ fields and produced by nghttp2_extpri_to_uint8. */

+ uint8_t http_extpri;

+ if (pri_spec && !nghttp2_priority_spec_check_default(pri_spec) &&

+ session->remote_settings.no_rfc7540_priorities != 1) {

+ if (session->remote_settings.no_rfc7540_priorities == 1) {

+ return 0;

+ }

+

+int nghttp2_submit_priority_update(nghttp2_session *session, uint8_t flags,

+ int32_t stream_id,

+ const uint8_t *field_value,

+ size_t field_value_len) {

+ nghttp2_mem *mem;

+ uint8_t *buf, *p;

+ nghttp2_outbound_item *item;

+ nghttp2_frame *frame;

+ nghttp2_ext_priority_update *priority_update;

+ int rv;

+ (void)flags;

+

+ mem = &session->mem;

+

+ if (session->server) {

+ return NGHTTP2_ERR_INVALID_STATE;

+ }

+

+ if (session->remote_settings.no_rfc7540_priorities == 0) {

+ return 0;

+ }

+

+ if (stream_id == 0 || 4 + field_value_len > NGHTTP2_MAX_PAYLOADLEN) {

+ return NGHTTP2_ERR_INVALID_ARGUMENT;

+ }

+

+ if (field_value_len) {

+ buf = nghttp2_mem_malloc(mem, field_value_len + 1);

+ if (buf == NULL) {

+ return NGHTTP2_ERR_NOMEM;

+ }

+

+ p = nghttp2_cpymem(buf, field_value, field_value_len);

+ *p = '\0';

+ } else {

+ buf = NULL;

+ }

+

+ item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));

+ if (item == NULL) {

+ rv = NGHTTP2_ERR_NOMEM;

+ goto fail_item_malloc;

+ }

+

+ nghttp2_outbound_item_init(item);

+

+ item->aux_data.ext.builtin = 1;

+

+ priority_update = &item->ext_frame_payload.priority_update;

+

+ frame = &item->frame;

+ frame->ext.payload = priority_update;

+

+ nghttp2_frame_priority_update_init(&frame->ext, stream_id, buf,

+ field_value_len);

+

+ rv = nghttp2_session_add_item(session, item);

+ if (rv != 0) {

+ nghttp2_frame_priority_update_free(&frame->ext, mem);

+ nghttp2_mem_free(mem, item);

+

+ return rv;

+ }

+

+ return 0;

+

+fail_item_malloc:

+ free(buf);

+

+ return rv;

+}

+

+ if (pri_spec && !nghttp2_priority_spec_check_default(pri_spec) &&

+ session->remote_settings.no_rfc7540_priorities != 1) {