aboutsummaryrefslogtreecommitdiff
path: root/crypto/openssl/ssl/quic/quic_fifd.c
diff options
context:
space:
mode:
Diffstat (limited to 'crypto/openssl/ssl/quic/quic_fifd.c')
-rw-r--r--crypto/openssl/ssl/quic/quic_fifd.c160
1 files changed, 80 insertions, 80 deletions
diff --git a/crypto/openssl/ssl/quic/quic_fifd.c b/crypto/openssl/ssl/quic/quic_fifd.c
index 1d1bcc11ce63..03b8cebd3057 100644
--- a/crypto/openssl/ssl/quic/quic_fifd.c
+++ b/crypto/openssl/ssl/quic/quic_fifd.c
@@ -14,48 +14,48 @@
DEFINE_LIST_OF(tx_history, OSSL_ACKM_TX_PKT);
int ossl_quic_fifd_init(QUIC_FIFD *fifd,
- QUIC_CFQ *cfq,
- OSSL_ACKM *ackm,
- QUIC_TXPIM *txpim,
- /* stream_id is UINT64_MAX for the crypto stream */
- QUIC_SSTREAM *(*get_sstream_by_id)(uint64_t stream_id,
- uint32_t pn_space,
- void *arg),
- void *get_sstream_by_id_arg,
- /* stream_id is UINT64_MAX if not applicable */
- void (*regen_frame)(uint64_t frame_type,
- uint64_t stream_id,
- QUIC_TXPIM_PKT *pkt,
- void *arg),
- void *regen_frame_arg,
- void (*confirm_frame)(uint64_t frame_type,
- uint64_t stream_id,
- QUIC_TXPIM_PKT *pkt,
- void *arg),
- void *confirm_frame_arg,
- void (*sstream_updated)(uint64_t stream_id,
- void *arg),
- void *sstream_updated_arg,
- QLOG *(*get_qlog_cb)(void *arg),
- void *get_qlog_cb_arg)
+ QUIC_CFQ *cfq,
+ OSSL_ACKM *ackm,
+ QUIC_TXPIM *txpim,
+ /* stream_id is UINT64_MAX for the crypto stream */
+ QUIC_SSTREAM *(*get_sstream_by_id)(uint64_t stream_id,
+ uint32_t pn_space,
+ void *arg),
+ void *get_sstream_by_id_arg,
+ /* stream_id is UINT64_MAX if not applicable */
+ void (*regen_frame)(uint64_t frame_type,
+ uint64_t stream_id,
+ QUIC_TXPIM_PKT *pkt,
+ void *arg),
+ void *regen_frame_arg,
+ void (*confirm_frame)(uint64_t frame_type,
+ uint64_t stream_id,
+ QUIC_TXPIM_PKT *pkt,
+ void *arg),
+ void *confirm_frame_arg,
+ void (*sstream_updated)(uint64_t stream_id,
+ void *arg),
+ void *sstream_updated_arg,
+ QLOG *(*get_qlog_cb)(void *arg),
+ void *get_qlog_cb_arg)
{
if (cfq == NULL || ackm == NULL || txpim == NULL
|| get_sstream_by_id == NULL || regen_frame == NULL)
return 0;
- fifd->cfq = cfq;
- fifd->ackm = ackm;
- fifd->txpim = txpim;
- fifd->get_sstream_by_id = get_sstream_by_id;
+ fifd->cfq = cfq;
+ fifd->ackm = ackm;
+ fifd->txpim = txpim;
+ fifd->get_sstream_by_id = get_sstream_by_id;
fifd->get_sstream_by_id_arg = get_sstream_by_id_arg;
- fifd->regen_frame = regen_frame;
- fifd->regen_frame_arg = regen_frame_arg;
- fifd->confirm_frame = confirm_frame;
- fifd->confirm_frame_arg = confirm_frame_arg;
- fifd->sstream_updated = sstream_updated;
- fifd->sstream_updated_arg = sstream_updated_arg;
- fifd->get_qlog_cb = get_qlog_cb;
- fifd->get_qlog_cb_arg = get_qlog_cb_arg;
+ fifd->regen_frame = regen_frame;
+ fifd->regen_frame_arg = regen_frame_arg;
+ fifd->confirm_frame = confirm_frame;
+ fifd->confirm_frame_arg = confirm_frame_arg;
+ fifd->sstream_updated = sstream_updated;
+ fifd->sstream_updated_arg = sstream_updated_arg;
+ fifd->get_qlog_cb = get_qlog_cb;
+ fifd->get_qlog_cb_arg = get_qlog_cb_arg;
return 1;
}
@@ -76,28 +76,28 @@ static void on_acked(void *arg)
/* STREAM and CRYPTO stream chunks, FINs and stream FC frames */
for (i = 0; i < num_chunks; ++i) {
sstream = fifd->get_sstream_by_id(chunks[i].stream_id,
- pkt->ackm_pkt.pkt_space,
- fifd->get_sstream_by_id_arg);
+ pkt->ackm_pkt.pkt_space,
+ fifd->get_sstream_by_id_arg);
if (sstream == NULL)
continue;
if (chunks[i].end >= chunks[i].start)
/* coverity[check_return]: Best effort - we cannot fail here. */
ossl_quic_sstream_mark_acked(sstream,
- chunks[i].start, chunks[i].end);
+ chunks[i].start, chunks[i].end);
if (chunks[i].has_fin && chunks[i].stream_id != UINT64_MAX)
ossl_quic_sstream_mark_acked_fin(sstream);
if (chunks[i].has_stop_sending && chunks[i].stream_id != UINT64_MAX)
fifd->confirm_frame(OSSL_QUIC_FRAME_TYPE_STOP_SENDING,
- chunks[i].stream_id, pkt,
- fifd->confirm_frame_arg);
+ chunks[i].stream_id, pkt,
+ fifd->confirm_frame_arg);
if (chunks[i].has_reset_stream && chunks[i].stream_id != UINT64_MAX)
fifd->confirm_frame(OSSL_QUIC_FRAME_TYPE_RESET_STREAM,
- chunks[i].stream_id, pkt,
- fifd->confirm_frame_arg);
+ chunks[i].stream_id, pkt,
+ fifd->confirm_frame_arg);
if (ossl_quic_sstream_is_totally_acked(sstream))
fifd->sstream_updated(chunks[i].stream_id, fifd->sstream_updated_arg);
@@ -135,8 +135,8 @@ static void on_lost(void *arg)
/* STREAM and CRYPTO stream chunks, FIN and stream FC frames */
for (i = 0; i < num_chunks; ++i) {
sstream = fifd->get_sstream_by_id(chunks[i].stream_id,
- pkt->ackm_pkt.pkt_space,
- fifd->get_sstream_by_id_arg);
+ pkt->ackm_pkt.pkt_space,
+ fifd->get_sstream_by_id_arg);
if (sstream == NULL)
continue;
@@ -150,7 +150,7 @@ static void on_lost(void *arg)
* and our call to get_sstream_by_id above will return NULL.
*/
ossl_quic_sstream_mark_lost(sstream,
- chunks[i].start, chunks[i].end);
+ chunks[i].start, chunks[i].end);
sstream_updated = 1;
}
@@ -161,13 +161,13 @@ static void on_lost(void *arg)
if (chunks[i].has_stop_sending && chunks[i].stream_id != UINT64_MAX)
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_STOP_SENDING,
- chunks[i].stream_id, pkt,
- fifd->regen_frame_arg);
+ chunks[i].stream_id, pkt,
+ fifd->regen_frame_arg);
if (chunks[i].has_reset_stream && chunks[i].stream_id != UINT64_MAX)
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_RESET_STREAM,
- chunks[i].stream_id, pkt,
- fifd->regen_frame_arg);
+ chunks[i].stream_id, pkt,
+ fifd->regen_frame_arg);
/*
* Inform caller that stream needs an FC frame.
@@ -180,13 +180,13 @@ static void on_lost(void *arg)
* handling loss.
*/
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_STREAM_DATA,
- chunks[i].stream_id,
- pkt,
- fifd->regen_frame_arg);
+ chunks[i].stream_id,
+ pkt,
+ fifd->regen_frame_arg);
if (sstream_updated && chunks[i].stream_id != UINT64_MAX)
fifd->sstream_updated(chunks[i].stream_id,
- fifd->sstream_updated_arg);
+ fifd->sstream_updated_arg);
}
/* GCR */
@@ -198,23 +198,23 @@ static void on_lost(void *arg)
/* Regenerate flag frames */
if (pkt->had_handshake_done_frame)
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_HANDSHAKE_DONE,
- UINT64_MAX, pkt,
- fifd->regen_frame_arg);
+ UINT64_MAX, pkt,
+ fifd->regen_frame_arg);
if (pkt->had_max_data_frame)
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_DATA,
- UINT64_MAX, pkt,
- fifd->regen_frame_arg);
+ UINT64_MAX, pkt,
+ fifd->regen_frame_arg);
if (pkt->had_max_streams_bidi_frame)
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_BIDI,
- UINT64_MAX, pkt,
- fifd->regen_frame_arg);
+ UINT64_MAX, pkt,
+ fifd->regen_frame_arg);
if (pkt->had_max_streams_uni_frame)
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_UNI,
- UINT64_MAX, pkt,
- fifd->regen_frame_arg);
+ UINT64_MAX, pkt,
+ fifd->regen_frame_arg);
if (pkt->had_ack_frame)
/*
@@ -223,8 +223,8 @@ static void on_lost(void *arg)
* whether it wants to send ECN data or not.
*/
fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_ACK_WITH_ECN,
- UINT64_MAX, pkt,
- fifd->regen_frame_arg);
+ UINT64_MAX, pkt,
+ fifd->regen_frame_arg);
ossl_quic_txpim_pkt_release(fifd->txpim, pkt);
}
@@ -256,12 +256,12 @@ int ossl_quic_fifd_pkt_commit(QUIC_FIFD *fifd, QUIC_TXPIM_PKT *pkt)
size_t i, num_chunks;
QUIC_SSTREAM *sstream;
- pkt->fifd = fifd;
+ pkt->fifd = fifd;
- pkt->ackm_pkt.on_lost = on_lost;
- pkt->ackm_pkt.on_acked = on_acked;
- pkt->ackm_pkt.on_discarded = on_discarded;
- pkt->ackm_pkt.cb_arg = pkt;
+ pkt->ackm_pkt.on_lost = on_lost;
+ pkt->ackm_pkt.on_acked = on_acked;
+ pkt->ackm_pkt.on_discarded = on_discarded;
+ pkt->ackm_pkt.cb_arg = pkt;
ossl_list_tx_history_init_elem(&pkt->ackm_pkt);
pkt->ackm_pkt.anext = pkt->ackm_pkt.lnext = NULL;
@@ -271,8 +271,8 @@ int ossl_quic_fifd_pkt_commit(QUIC_FIFD *fifd, QUIC_TXPIM_PKT *pkt)
* transmitted.
*/
for (cfq_item = pkt->retx_head;
- cfq_item != NULL;
- cfq_item = cfq_item->pkt_next)
+ cfq_item != NULL;
+ cfq_item = cfq_item->pkt_next)
ossl_quic_cfq_mark_tx(fifd->cfq, cfq_item);
/*
@@ -283,21 +283,21 @@ int ossl_quic_fifd_pkt_commit(QUIC_FIFD *fifd, QUIC_TXPIM_PKT *pkt)
num_chunks = ossl_quic_txpim_pkt_get_num_chunks(pkt);
for (i = 0; i < num_chunks; ++i) {
sstream = fifd->get_sstream_by_id(chunks[i].stream_id,
- pkt->ackm_pkt.pkt_space,
- fifd->get_sstream_by_id_arg);
+ pkt->ackm_pkt.pkt_space,
+ fifd->get_sstream_by_id_arg);
if (sstream == NULL)
continue;
if (chunks[i].end >= chunks[i].start
&& !ossl_quic_sstream_mark_transmitted(sstream,
- chunks[i].start,
- chunks[i].end))
+ chunks[i].start,
+ chunks[i].end))
return 0;
if (chunks[i].has_fin
&& !ossl_quic_sstream_mark_transmitted_fin(sstream,
- chunks[i].end + 1))
- return 0;
+ chunks[i].end + 1))
+ return 0;
}
/* Inform the ACKM. */
@@ -305,8 +305,8 @@ int ossl_quic_fifd_pkt_commit(QUIC_FIFD *fifd, QUIC_TXPIM_PKT *pkt)
}
void ossl_quic_fifd_set_qlog_cb(QUIC_FIFD *fifd, QLOG *(*get_qlog_cb)(void *arg),
- void *get_qlog_cb_arg)
+ void *get_qlog_cb_arg)
{
- fifd->get_qlog_cb = get_qlog_cb;
- fifd->get_qlog_cb_arg = get_qlog_cb_arg;
+ fifd->get_qlog_cb = get_qlog_cb;
+ fifd->get_qlog_cb_arg = get_qlog_cb_arg;
}
generated by cgit v1.2.3 (git 2.25.1) at 2026-04-29 08:45:19 +0000