CLEANUP: assorted typo fixes in the code and comments
This is 31st iteration of typo fixes
This commit is contained in:
parent
4c785f0a1f
commit
3b64a28e15
@ -227,7 +227,7 @@ da_status_t da_atlas_open(da_atlas_t *atlas, da_property_decl_t *extra_props, co
|
|||||||
* @brief read from a mapped data which then replace da_atlas_compile call
|
* @brief read from a mapped data which then replace da_atlas_compile call
|
||||||
*
|
*
|
||||||
* @param dumppath, anonymous if NULL
|
* @param dumppath, anonymous if NULL
|
||||||
* @param map for anonymous, it is the responsability of the caller to unmap it, ignored otherwise
|
* @param map for anonymous, it is the responsibility of the caller to unmap it, ignored otherwise
|
||||||
* @param maplen for anonymous, it is the size of the mapped data, ignored otherwise
|
* @param maplen for anonymous, it is the size of the mapped data, ignored otherwise
|
||||||
* @param ptr Pointer dynamically allocated if the mapping happened normally
|
* @param ptr Pointer dynamically allocated if the mapping happened normally
|
||||||
* @param len size of the atlas image
|
* @param len size of the atlas image
|
||||||
|
@ -23091,7 +23091,7 @@ filter bwlim-out <name> limit <size> key <pattern> [table <table>] [min-size <sz
|
|||||||
be specified for shared bandwidth limitation filters only.
|
be specified for shared bandwidth limitation filters only.
|
||||||
|
|
||||||
<time> is the default time period used to evaluate the bandwidth
|
<time> is the default time period used to evaluate the bandwidth
|
||||||
limitation rate. It can be speficied for per-stream bandwidth
|
limitation rate. It can be specified for per-stream bandwidth
|
||||||
limitation filters only. It follows the HAProxy time format and
|
limitation filters only. It follows the HAProxy time format and
|
||||||
is expressed in milliseconds.
|
is expressed in milliseconds.
|
||||||
|
|
||||||
@ -23166,7 +23166,7 @@ some experimentations.
|
|||||||
# of 10m/s with all other streams with the same source address.
|
# of 10m/s with all other streams with the same source address.
|
||||||
filter bwlim-out limit-by-src key src table limit-by-src limit 10m
|
filter bwlim-out limit-by-src key src table limit-by-src limit 10m
|
||||||
|
|
||||||
# If this filter is enalbed, the stream will be limited to download at 1m/s,
|
# If this filter is enabled, the stream will be limited to download at 1m/s,
|
||||||
# independently of all other streams.
|
# independently of all other streams.
|
||||||
filter bwlim-out limit-by-strm default-limit 1m default-period 1s
|
filter bwlim-out limit-by-strm default-limit 1m default-period 1s
|
||||||
|
|
||||||
|
@ -319,7 +319,7 @@ thread mask due to takeover ?), the same FD may appear at the same time:
|
|||||||
|
|
||||||
- in the global update_list. In this case, fd_rm_from_fd_list() already
|
- in the global update_list. In this case, fd_rm_from_fd_list() already
|
||||||
performs an attachment check, so it's safe to always call it before closing
|
performs an attachment check, so it's safe to always call it before closing
|
||||||
(since noone else may be in the process of changing anything).
|
(since no one else may be in the process of changing anything).
|
||||||
|
|
||||||
|
|
||||||
###########################################################
|
###########################################################
|
||||||
@ -481,7 +481,7 @@ the FD, and all those with a bit in it ought to do it.
|
|||||||
- thread_mask (in bind_conf->rx_settings) should become an array of
|
- thread_mask (in bind_conf->rx_settings) should become an array of
|
||||||
MAX_TGROUP longs.
|
MAX_TGROUP longs.
|
||||||
- when parsing "thread 123" or "thread 2/37", the proper bit is set,
|
- when parsing "thread 123" or "thread 2/37", the proper bit is set,
|
||||||
assuming the array is either a contigous bitfield or a tgroup array.
|
assuming the array is either a contiguous bitfield or a tgroup array.
|
||||||
An option RX_O_THR_PER_GRP or RX_O_THR_PER_PROC is set depending on
|
An option RX_O_THR_PER_GRP or RX_O_THR_PER_PROC is set depending on
|
||||||
how the thread num was parsed, so that we reject mixes.
|
how the thread num was parsed, so that we reject mixes.
|
||||||
- end of parsing: entries translated to the cleanest form (to be determined)
|
- end of parsing: entries translated to the cleanest form (to be determined)
|
||||||
|
@ -20,7 +20,7 @@ context that was allowed to use extra fields of various types. Other applets
|
|||||||
preferred to use their own context definition.
|
preferred to use their own context definition.
|
||||||
|
|
||||||
All this resulted in the appctx->ctx to contain a myriad of definitions of
|
All this resulted in the appctx->ctx to contain a myriad of definitions of
|
||||||
vairous service contexts, and in some services abusing other services'
|
various service contexts, and in some services abusing other services'
|
||||||
definitions by laziness, and others being extended to use their own definition
|
definitions by laziness, and others being extended to use their own definition
|
||||||
after having run for a long time on the generic types, some of which were not
|
after having run for a long time on the generic types, some of which were not
|
||||||
noticed and mistakenly used the same storage locations by accident. A massive
|
noticed and mistakenly used the same storage locations by accident. A massive
|
||||||
@ -44,7 +44,7 @@ purposed function is provided: "applet_reserve_svcctx()". This function will
|
|||||||
require the caller to indicate how large an area it needs, and will return a
|
require the caller to indicate how large an area it needs, and will return a
|
||||||
pointer to this area after checking that it fits. If it does not, haproxy will
|
pointer to this area after checking that it fits. If it does not, haproxy will
|
||||||
crash. This is purposely done so that it's known during development that if a
|
crash. This is purposely done so that it's known during development that if a
|
||||||
small structure doesn't fit, a differnet approach is required.
|
small structure doesn't fit, a different approach is required.
|
||||||
|
|
||||||
As such, for the vast majority of commands, the process is the following one:
|
As such, for the vast majority of commands, the process is the following one:
|
||||||
|
|
||||||
|
@ -573,5 +573,5 @@ CONFIG_HAP_POOL_CLUSTER_SIZE
|
|||||||
This allows one to define the maximum number of objects that will be
|
This allows one to define the maximum number of objects that will be
|
||||||
groupped together in an allocation from the shared pool. Values 4 to 8
|
groupped together in an allocation from the shared pool. Values 4 to 8
|
||||||
have experimentally shown good results with 16 threads. On systems with
|
have experimentally shown good results with 16 threads. On systems with
|
||||||
more cores or losely coupled caches exhibiting slow atomic operations,
|
more cores or loosely coupled caches exhibiting slow atomic operations,
|
||||||
it could possibly make sense to slightly increase this value.
|
it could possibly make sense to slightly increase this value.
|
||||||
|
@ -7,7 +7,7 @@
|
|||||||
* store data in a non-linear way with gaps between them. The buffer is
|
* store data in a non-linear way with gaps between them. The buffer is
|
||||||
* circular and so data may wrapped.
|
* circular and so data may wrapped.
|
||||||
*
|
*
|
||||||
* The API of <ncbuf> is splitted in two parts. Please refer to the public API
|
* The API of <ncbuf> is split in two parts. Please refer to the public API
|
||||||
* declared in this header file which should cover all the needs.
|
* declared in this header file which should cover all the needs.
|
||||||
*
|
*
|
||||||
* To minimize the memory footprint, size of data and gaps are inserted in the
|
* To minimize the memory footprint, size of data and gaps are inserted in the
|
||||||
|
@ -144,9 +144,9 @@ enum PR_SRV_STATE_FILE {
|
|||||||
|
|
||||||
#define PR_O2_FAKE_KA 0x00200000 /* pretend we do keep-alive with server even though we close */
|
#define PR_O2_FAKE_KA 0x00200000 /* pretend we do keep-alive with server even though we close */
|
||||||
|
|
||||||
#define PR_O2_RSTRICT_REQ_HDR_NAMES_BLK 0x00400000 /* reject request with header names containing chars ouside of [0-9a-zA-Z-] charset */
|
#define PR_O2_RSTRICT_REQ_HDR_NAMES_BLK 0x00400000 /* reject request with header names containing chars outside of [0-9a-zA-Z-] charset */
|
||||||
#define PR_O2_RSTRICT_REQ_HDR_NAMES_DEL 0x00800000 /* remove request header names containing chars outside of [0-9a-zA-Z-] charset */
|
#define PR_O2_RSTRICT_REQ_HDR_NAMES_DEL 0x00800000 /* remove request header names containing chars outside of [0-9a-zA-Z-] charset */
|
||||||
#define PR_O2_RSTRICT_REQ_HDR_NAMES_NOOP 0x01000000 /* preserve request header names containing chars ouside of [0-9a-zA-Z-] charset */
|
#define PR_O2_RSTRICT_REQ_HDR_NAMES_NOOP 0x01000000 /* preserve request header names containing chars outside of [0-9a-zA-Z-] charset */
|
||||||
#define PR_O2_RSTRICT_REQ_HDR_NAMES_MASK 0x01c00000 /* mask for restrict-http-header-names option */
|
#define PR_O2_RSTRICT_REQ_HDR_NAMES_MASK 0x01c00000 /* mask for restrict-http-header-names option */
|
||||||
/* unused : 0x0000000..0x80000000 */
|
/* unused : 0x0000000..0x80000000 */
|
||||||
|
|
||||||
|
@ -209,7 +209,7 @@ static inline void _task_wakeup(struct task *t, unsigned int f, const char *file
|
|||||||
* happened since the flag was set will result in the task being queued (if
|
* happened since the flag was set will result in the task being queued (if
|
||||||
* it wasn't already). This is used to safely drop the flag from within the
|
* it wasn't already). This is used to safely drop the flag from within the
|
||||||
* scheduler. The flag <f> is combined with existing flags before the test so
|
* scheduler. The flag <f> is combined with existing flags before the test so
|
||||||
* that it's possible to inconditionally wakeup the task and drop the RUNNING
|
* that it's possible to unconditionally wakeup the task and drop the RUNNING
|
||||||
* flag if needed.
|
* flag if needed.
|
||||||
*/
|
*/
|
||||||
#define task_drop_running(t, f) _task_drop_running(t, f, __FILE__, __LINE__)
|
#define task_drop_running(t, f) _task_drop_running(t, f, __FILE__, __LINE__)
|
||||||
|
@ -440,9 +440,9 @@ struct quic_rx_crypto_frm {
|
|||||||
#define QUIC_FL_TX_PACKET_PADDING (1UL << 1)
|
#define QUIC_FL_TX_PACKET_PADDING (1UL << 1)
|
||||||
/* Flag a sent packet as being in flight. */
|
/* Flag a sent packet as being in flight. */
|
||||||
#define QUIC_FL_TX_PACKET_IN_FLIGHT (QUIC_FL_TX_PACKET_ACK_ELICITING | QUIC_FL_TX_PACKET_PADDING)
|
#define QUIC_FL_TX_PACKET_IN_FLIGHT (QUIC_FL_TX_PACKET_ACK_ELICITING | QUIC_FL_TX_PACKET_PADDING)
|
||||||
/* Flag a sent packet as containg a CONNECTION_CLOSE frame */
|
/* Flag a sent packet as containing a CONNECTION_CLOSE frame */
|
||||||
#define QUIC_FL_TX_PACKET_CC (1UL << 2)
|
#define QUIC_FL_TX_PACKET_CC (1UL << 2)
|
||||||
/* Flag a sent packet as containg an ACK frame */
|
/* Flag a sent packet as containing an ACK frame */
|
||||||
#define QUIC_FL_TX_PACKET_ACK (1UL << 3)
|
#define QUIC_FL_TX_PACKET_ACK (1UL << 3)
|
||||||
/* Flag a sent packet as being coalesced to another one in the same datagram */
|
/* Flag a sent packet as being coalesced to another one in the same datagram */
|
||||||
#define QUIC_FL_TX_PACKET_COALESCED (1UL << 4)
|
#define QUIC_FL_TX_PACKET_COALESCED (1UL << 4)
|
||||||
|
@ -90,7 +90,7 @@ static inline void quic_cid_cpy(struct quic_cid *dst, const struct quic_cid *src
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Copy <saddr> socket address data into <buf> buffer.
|
/* Copy <saddr> socket address data into <buf> buffer.
|
||||||
* This is the responsability of the caller to check the output buffer is big
|
* This is the responsibility of the caller to check the output buffer is big
|
||||||
* enough to contain these socket address data.
|
* enough to contain these socket address data.
|
||||||
* Return the number of bytes copied.
|
* Return the number of bytes copied.
|
||||||
*/
|
*/
|
||||||
|
@ -3790,7 +3790,7 @@ out_uri_auth_compat:
|
|||||||
if (!bind_conf->mux_proto) {
|
if (!bind_conf->mux_proto) {
|
||||||
/* No protocol was specified. If we're using QUIC at the transport
|
/* No protocol was specified. If we're using QUIC at the transport
|
||||||
* layer, we'll instantiate it as a mux as well. If QUIC is not
|
* layer, we'll instantiate it as a mux as well. If QUIC is not
|
||||||
* compiled in, this wil remain NULL.
|
* compiled in, this will remain NULL.
|
||||||
*/
|
*/
|
||||||
if (bind_conf->xprt && bind_conf->xprt == xprt_get(XPRT_QUIC))
|
if (bind_conf->xprt && bind_conf->xprt == xprt_get(XPRT_QUIC))
|
||||||
bind_conf->mux_proto = get_mux_proto(ist("quic"));
|
bind_conf->mux_proto = get_mux_proto(ist("quic"));
|
||||||
|
@ -1574,7 +1574,7 @@ int init_srv_check(struct server *srv)
|
|||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
/* For dynamic servers, check-ssl and check-send-proxy must be
|
/* For dynamic servers, check-ssl and check-send-proxy must be
|
||||||
* explicitely defined even if the check port was not
|
* explicitly defined even if the check port was not
|
||||||
* overridden.
|
* overridden.
|
||||||
*/
|
*/
|
||||||
if (srv->check.use_ssl == 1)
|
if (srv->check.use_ssl == 1)
|
||||||
|
@ -106,7 +106,7 @@ static int bwlim_apply_limit(struct filter *filter, struct channel *chn, unsigne
|
|||||||
else {
|
else {
|
||||||
/* On per-stream mode, the freq-counter is private to the
|
/* On per-stream mode, the freq-counter is private to the
|
||||||
* stream. Get it from the filter state. Rely on the custom
|
* stream. Get it from the filter state. Rely on the custom
|
||||||
* limit/period if defined or use the defaut ones. In this mode,
|
* limit/period if defined or use the default ones. In this mode,
|
||||||
* there is only one user.
|
* there is only one user.
|
||||||
*/
|
*/
|
||||||
bytes_rate = &st->bytes_rate;
|
bytes_rate = &st->bytes_rate;
|
||||||
@ -141,7 +141,7 @@ static int bwlim_apply_limit(struct filter *filter, struct channel *chn, unsigne
|
|||||||
if (tokens < len) {
|
if (tokens < len) {
|
||||||
/* The stream cannot forward all its data. But we will check if
|
/* The stream cannot forward all its data. But we will check if
|
||||||
* it can perform a small burst if the global quota is large
|
* it can perform a small burst if the global quota is large
|
||||||
* enought. But, in this case, its waiting time will be
|
* enough. But, in this case, its waiting time will be
|
||||||
* increased accordingly.
|
* increased accordingly.
|
||||||
*/
|
*/
|
||||||
ret = tokens;
|
ret = tokens;
|
||||||
@ -505,7 +505,7 @@ static void release_bwlim_action(struct act_rule *rule)
|
|||||||
*
|
*
|
||||||
* arg.act.p[0] will be the filter name (mandatory)
|
* arg.act.p[0] will be the filter name (mandatory)
|
||||||
* arg.act.p[1] will be an expression for the custom limit (optional, may be NULL)
|
* arg.act.p[1] will be an expression for the custom limit (optional, may be NULL)
|
||||||
* arg.act.p[2] will be an expression for the custom period (optiona, may be NULLl)
|
* arg.act.p[2] will be an expression for the custom period (optional, may be NULL)
|
||||||
*
|
*
|
||||||
* It returns ACT_RET_PRS_OK on success, ACT_RET_PRS_ERR on error.
|
* It returns ACT_RET_PRS_OK on success, ACT_RET_PRS_ERR on error.
|
||||||
*/
|
*/
|
||||||
|
@ -468,7 +468,7 @@ int httpclient_set_dst(struct httpclient *hc, const char *dst)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Return a splitted URL in <scheme>, <host>, <port>
|
* Return a split URL in <scheme>, <host>, <port>
|
||||||
*/
|
*/
|
||||||
static void httpclient_spliturl(struct ist url, enum http_scheme *scheme,
|
static void httpclient_spliturl(struct ist url, enum http_scheme *scheme,
|
||||||
struct ist *host, int *port)
|
struct ist *host, int *port)
|
||||||
@ -877,7 +877,7 @@ static void httpclient_applet_io_handler(struct appctx *appctx)
|
|||||||
if (hc->ops.res_payload)
|
if (hc->ops.res_payload)
|
||||||
hc->ops.res_payload(hc);
|
hc->ops.res_payload(hc);
|
||||||
|
|
||||||
/* cannot copy everything, need to processs */
|
/* cannot copy everything, need to process */
|
||||||
if (vlen != blksz)
|
if (vlen != blksz)
|
||||||
goto process_data;
|
goto process_data;
|
||||||
} else {
|
} else {
|
||||||
|
@ -3858,7 +3858,7 @@ struct task *fcgi_deferred_shut(struct task *t, void *ctx, unsigned int state)
|
|||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* shutr() called by the stream conector (mux_ops.shutr) */
|
/* shutr() called by the stream connector (mux_ops.shutr) */
|
||||||
static void fcgi_shutr(struct stconn *sc, enum co_shr_mode mode)
|
static void fcgi_shutr(struct stconn *sc, enum co_shr_mode mode)
|
||||||
{
|
{
|
||||||
struct fcgi_strm *fstrm = __sc_mux_strm(sc);
|
struct fcgi_strm *fstrm = __sc_mux_strm(sc);
|
||||||
|
@ -451,7 +451,7 @@ static struct ncbuf *qc_get_ncbuf(struct qcs *qcs, struct ncbuf *ncbuf)
|
|||||||
return ncbuf;
|
return ncbuf;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Notify an eventual subscriber on <qcs> or else wakup up the stconn layer if
|
/* Notify an eventual subscriber on <qcs> or else wakeup up the stconn layer if
|
||||||
* initialized.
|
* initialized.
|
||||||
*/
|
*/
|
||||||
static void qcs_alert(struct qcs *qcs)
|
static void qcs_alert(struct qcs *qcs)
|
||||||
@ -678,7 +678,7 @@ int qcc_get_qcs(struct qcc *qcc, uint64_t id, int receive_only, int send_only,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Create the stream. This is valid only for remote initiated one. A
|
/* Create the stream. This is valid only for remote initiated one. A
|
||||||
* local stream must have already been explicitely created by the
|
* local stream must have already been explicitly created by the
|
||||||
* application protocol layer.
|
* application protocol layer.
|
||||||
*/
|
*/
|
||||||
if (quic_stream_is_local(qcc, id)) {
|
if (quic_stream_is_local(qcc, id)) {
|
||||||
@ -1280,7 +1280,7 @@ static int qcs_build_stream_frm(struct qcs *qcs, struct buffer *out, char fin,
|
|||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Check after transfering data from qcs.tx.buf if FIN must be set on the next
|
/* Check after transferring data from qcs.tx.buf if FIN must be set on the next
|
||||||
* STREAM frame for <qcs>.
|
* STREAM frame for <qcs>.
|
||||||
*
|
*
|
||||||
* Returns true if FIN must be set else false.
|
* Returns true if FIN must be set else false.
|
||||||
@ -1502,7 +1502,7 @@ static int _qc_send_qcs(struct qcs *qcs, struct list *frms)
|
|||||||
/* out buffer cannot be emptied if qcs offsets differ. */
|
/* out buffer cannot be emptied if qcs offsets differ. */
|
||||||
BUG_ON(!b_data(out) && qcs->tx.sent_offset != qcs->tx.offset);
|
BUG_ON(!b_data(out) && qcs->tx.sent_offset != qcs->tx.offset);
|
||||||
|
|
||||||
/* FIN is set if all incoming data were transfered. */
|
/* FIN is set if all incoming data were transferred. */
|
||||||
fin = qcs_stream_fin(qcs);
|
fin = qcs_stream_fin(qcs);
|
||||||
|
|
||||||
/* Build a new STREAM frame with <out> buffer. */
|
/* Build a new STREAM frame with <out> buffer. */
|
||||||
|
@ -506,7 +506,7 @@ int ncb_is_fragmented(const struct ncbuf *buf)
|
|||||||
return !ncb_blk_is_last(buf, gap);
|
return !ncb_blk_is_last(buf, gap);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Returns the number of bytes of data avaiable in <buf> starting at offset
|
/* Returns the number of bytes of data available in <buf> starting at offset
|
||||||
* <off> until the next gap or the buffer end. The counted data may wrapped if
|
* <off> until the next gap or the buffer end. The counted data may wrapped if
|
||||||
* the buffer storage is not aligned.
|
* the buffer storage is not aligned.
|
||||||
*/
|
*/
|
||||||
@ -589,7 +589,7 @@ enum ncb_ret ncb_add(struct ncbuf *buf, ncb_sz_t off,
|
|||||||
ncb_sz_t done;
|
ncb_sz_t done;
|
||||||
|
|
||||||
/* retrieve the next block. This is necessary to do this
|
/* retrieve the next block. This is necessary to do this
|
||||||
* before overwritting a gap.
|
* before overwriting a gap.
|
||||||
*/
|
*/
|
||||||
next = ncb_blk_next(buf, blk);
|
next = ncb_blk_next(buf, blk);
|
||||||
|
|
||||||
|
@ -295,7 +295,7 @@ void quic_sock_fd_iocb(int fd)
|
|||||||
|
|
||||||
max_dgrams = global.tune.maxpollevents;
|
max_dgrams = global.tune.maxpollevents;
|
||||||
start:
|
start:
|
||||||
/* Try to reuse an existing dgram. Note that there is alway at
|
/* Try to reuse an existing dgram. Note that there is always at
|
||||||
* least one datagram to pick, except the first time we enter
|
* least one datagram to pick, except the first time we enter
|
||||||
* this function for this <rxbuf> buffer.
|
* this function for this <rxbuf> buffer.
|
||||||
*/
|
*/
|
||||||
@ -397,7 +397,7 @@ int qc_snd_buf(struct quic_conn *qc, const struct buffer *buf, size_t sz,
|
|||||||
HA_ATOMIC_INC(&prx_counters->sendto_err);
|
HA_ATOMIC_INC(&prx_counters->sendto_err);
|
||||||
}
|
}
|
||||||
else if (errno) {
|
else if (errno) {
|
||||||
/* TODO unlisted errno : handle it explicitely. */
|
/* TODO unlisted errno : handle it explicitly. */
|
||||||
ABORT_NOW();
|
ABORT_NOW();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -244,7 +244,7 @@ static void sc_free_cond(struct stconn **scp)
|
|||||||
|
|
||||||
|
|
||||||
/* Attaches a stconn to a mux endpoint and sets the endpoint ctx. Returns
|
/* Attaches a stconn to a mux endpoint and sets the endpoint ctx. Returns
|
||||||
* -1 on error and 0 on sucess. SE_FL_DETACHED flag is removed. This function is
|
* -1 on error and 0 on success. SE_FL_DETACHED flag is removed. This function is
|
||||||
* called from a mux when it is attached to a stream or a health-check.
|
* called from a mux when it is attached to a stream or a health-check.
|
||||||
*/
|
*/
|
||||||
int sc_attach_mux(struct stconn *sc, void *sd, void *ctx)
|
int sc_attach_mux(struct stconn *sc, void *sd, void *ctx)
|
||||||
@ -286,7 +286,7 @@ int sc_attach_mux(struct stconn *sc, void *sd, void *ctx)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Attaches a stconn to an applet endpoint and sets the endpoint
|
/* Attaches a stconn to an applet endpoint and sets the endpoint
|
||||||
* ctx. Returns -1 on error and 0 on sucess. SE_FL_DETACHED flag is
|
* ctx. Returns -1 on error and 0 on success. SE_FL_DETACHED flag is
|
||||||
* removed. This function is called by a stream when a backend applet is
|
* removed. This function is called by a stream when a backend applet is
|
||||||
* registered.
|
* registered.
|
||||||
*/
|
*/
|
||||||
@ -427,7 +427,7 @@ void sc_destroy(struct stconn *sc)
|
|||||||
|
|
||||||
/* Resets the stream connector endpoint. It happens when the app layer want to renew
|
/* Resets the stream connector endpoint. It happens when the app layer want to renew
|
||||||
* its endpoint. For a connection retry for instance. If a mux or an applet is
|
* its endpoint. For a connection retry for instance. If a mux or an applet is
|
||||||
* attached, a new endpoint is created. Returns -1 on error and 0 on sucess.
|
* attached, a new endpoint is created. Returns -1 on error and 0 on success.
|
||||||
*
|
*
|
||||||
* Only SE_FL_ERROR flag is removed on the endpoint. Orther flags are preserved.
|
* Only SE_FL_ERROR flag is removed on the endpoint. Orther flags are preserved.
|
||||||
* It is the caller responsibility to remove other flags if needed.
|
* It is the caller responsibility to remove other flags if needed.
|
||||||
@ -1960,7 +1960,7 @@ void sc_conn_prepare_endp_upgrade(struct stconn *sc)
|
|||||||
sc_ep_set(sc, SE_FL_DETACHED);
|
sc_ep_set(sc, SE_FL_DETACHED);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Endpoint upgrade failed. Retore the stconn state. */
|
/* Endpoint upgrade failed. Restore the stconn state. */
|
||||||
void sc_conn_abort_endp_upgrade(struct stconn *sc)
|
void sc_conn_abort_endp_upgrade(struct stconn *sc)
|
||||||
{
|
{
|
||||||
sc_ep_set(sc, SE_FL_T_MUX);
|
sc_ep_set(sc, SE_FL_T_MUX);
|
||||||
|
@ -1710,7 +1710,7 @@ static inline void qc_requeue_nacked_pkt_tx_frms(struct quic_conn *qc,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Free <pkt> TX packet and its attached frames.
|
/* Free <pkt> TX packet and its attached frames.
|
||||||
* This is the responsability of the caller to remove this packet of
|
* This is the responsibility of the caller to remove this packet of
|
||||||
* any data structure it was possibly attached to.
|
* any data structure it was possibly attached to.
|
||||||
*/
|
*/
|
||||||
static inline void free_quic_tx_packet(struct quic_tx_packet *pkt)
|
static inline void free_quic_tx_packet(struct quic_tx_packet *pkt)
|
||||||
@ -2642,7 +2642,7 @@ static int qc_parse_pkt_frms(struct quic_rx_packet *pkt, struct ssl_sock_ctx *ct
|
|||||||
/* Must be called only by a <cbuf> writer (packet builder).
|
/* Must be called only by a <cbuf> writer (packet builder).
|
||||||
* Return 1 if <cbuf> may be reused to build packets, depending on its <rd> and
|
* Return 1 if <cbuf> may be reused to build packets, depending on its <rd> and
|
||||||
* <wr> internal indexes, 0 if not. When this is the case, reset <wr> writer
|
* <wr> internal indexes, 0 if not. When this is the case, reset <wr> writer
|
||||||
* index after having marked the end of written data. This the responsability
|
* index after having marked the end of written data. This the responsibility
|
||||||
* of the caller to ensure there is enough room in <cbuf> to write the end of
|
* of the caller to ensure there is enough room in <cbuf> to write the end of
|
||||||
* data made of a uint16_t null field.
|
* data made of a uint16_t null field.
|
||||||
*
|
*
|
||||||
@ -4832,7 +4832,7 @@ static int send_stateless_reset(struct listener *l, struct sockaddr_storage *dst
|
|||||||
|
|
||||||
/* QUIC server only function.
|
/* QUIC server only function.
|
||||||
* Add AAD to <add> buffer from <cid> connection ID and <addr> socket address.
|
* Add AAD to <add> buffer from <cid> connection ID and <addr> socket address.
|
||||||
* This is the responsability of the caller to check <aad> size is big enough
|
* This is the responsibility of the caller to check <aad> size is big enough
|
||||||
* to contain these data.
|
* to contain these data.
|
||||||
* Return the number of bytes copied to <aad>.
|
* Return the number of bytes copied to <aad>.
|
||||||
*/
|
*/
|
||||||
@ -5253,7 +5253,7 @@ static int qc_conn_alloc_ssl_ctx(struct quic_conn *qc)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Check that all the bytes between <buf> included and <end> address
|
/* Check that all the bytes between <buf> included and <end> address
|
||||||
* excluded are null. This is the responsability of the caller to
|
* excluded are null. This is the responsibility of the caller to
|
||||||
* check that there is at least one byte between <buf> end <end>.
|
* check that there is at least one byte between <buf> end <end>.
|
||||||
* Return 1 if this all the bytes are null, 0 if not.
|
* Return 1 if this all the bytes are null, 0 if not.
|
||||||
*/
|
*/
|
||||||
@ -5271,7 +5271,7 @@ static inline int quic_padding_check(const unsigned char *buf,
|
|||||||
* with the information collected from the packet.
|
* with the information collected from the packet.
|
||||||
* This function sets ->len <pkt> field value to the end of the packet past one
|
* This function sets ->len <pkt> field value to the end of the packet past one
|
||||||
* byte to enable the caller to run this function again to continue to parse
|
* byte to enable the caller to run this function again to continue to parse
|
||||||
* the remaing QUIC packets carried by the datagram.
|
* the remaining QUIC packets carried by the datagram.
|
||||||
* Note that this function always sets this ->len value. If a paquet could
|
* Note that this function always sets this ->len value. If a paquet could
|
||||||
* not be correctly found, ->len value will be set to the remaining number
|
* not be correctly found, ->len value will be set to the remaining number
|
||||||
* bytes in the datagram to entirely consume this latter.
|
* bytes in the datagram to entirely consume this latter.
|
||||||
@ -6623,7 +6623,7 @@ struct task *quic_lstnr_dghdlr(struct task *t, void *ctx, unsigned int state)
|
|||||||
return t;
|
return t;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Retreive the DCID from a QUIC datagram or packet with <buf> as first octet.
|
/* Retrieve the DCID from a QUIC datagram or packet with <buf> as first octet.
|
||||||
* Returns 1 if succeeded, 0 if not.
|
* Returns 1 if succeeded, 0 if not.
|
||||||
*/
|
*/
|
||||||
int quic_get_dgram_dcid(unsigned char *buf, const unsigned char *end,
|
int quic_get_dgram_dcid(unsigned char *buf, const unsigned char *end,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user