Home | History | Annotate | Download | only in quic

Lines Matching refs:fifd

16 int ossl_quic_fifd_init(QUIC_FIFD *fifd,
46 fifd->cfq = cfq;
47 fifd->ackm = ackm;
48 fifd->txpim = txpim;
49 fifd->get_sstream_by_id = get_sstream_by_id;
50 fifd->get_sstream_by_id_arg = get_sstream_by_id_arg;
51 fifd->regen_frame = regen_frame;
52 fifd->regen_frame_arg = regen_frame_arg;
53 fifd->confirm_frame = confirm_frame;
54 fifd->confirm_frame_arg = confirm_frame_arg;
55 fifd->sstream_updated = sstream_updated;
56 fifd->sstream_updated_arg = sstream_updated_arg;
57 fifd->get_qlog_cb = get_qlog_cb;
58 fifd->get_qlog_cb_arg = get_qlog_cb_arg;
62 void ossl_quic_fifd_cleanup(QUIC_FIFD *fifd)
70 QUIC_FIFD *fifd = pkt->fifd;
78 sstream = fifd->get_sstream_by_id(chunks[i].stream_id,
80 fifd->get_sstream_by_id_arg);
93 fifd->confirm_frame(OSSL_QUIC_FRAME_TYPE_STOP_SENDING,
95 fifd->confirm_frame_arg);
98 fifd->confirm_frame(OSSL_QUIC_FRAME_TYPE_RESET_STREAM,
100 fifd->confirm_frame_arg);
103 fifd->sstream_updated(chunks[i].stream_id, fifd->sstream_updated_arg);
109 ossl_quic_cfq_release(fifd->cfq, cfq_item);
112 ossl_quic_txpim_pkt_release(fifd->txpim, pkt);
115 static QLOG *fifd_get_qlog(QUIC_FIFD *fifd)
117 if (fifd->get_qlog_cb == NULL)
120 return fifd->get_qlog_cb(fifd->get_qlog_cb_arg);
126 QUIC_FIFD *fifd = pkt->fifd;
133 ossl_qlog_event_recovery_packet_lost(fifd_get_qlog(fifd), pkt);
137 sstream = fifd->get_sstream_by_id(chunks[i].stream_id,
139 fifd->get_sstream_by_id_arg);
163 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_STOP_SENDING,
165 fifd->regen_frame_arg);
168 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_RESET_STREAM,
170 fifd->regen_frame_arg);
182 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_STREAM_DATA,
185 fifd->regen_frame_arg);
188 fifd->sstream_updated(chunks[i].stream_id,
189 fifd->sstream_updated_arg);
195 ossl_quic_cfq_mark_lost(fifd->cfq, cfq_item, UINT32_MAX);
200 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_HANDSHAKE_DONE,
202 fifd->regen_frame_arg);
205 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_DATA,
207 fifd->regen_frame_arg);
210 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_BIDI,
212 fifd->regen_frame_arg);
215 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_UNI,
217 fifd->regen_frame_arg);
225 fifd->regen_frame(OSSL_QUIC_FRAME_TYPE_ACK_WITH_ECN,
227 fifd->regen_frame_arg);
229 ossl_quic_txpim_pkt_release(fifd->txpim, pkt);
235 QUIC_FIFD *fifd = pkt->fifd;
246 ossl_quic_cfq_release(fifd->cfq, cfq_item);
249 ossl_quic_txpim_pkt_release(fifd->txpim, pkt);
252 int ossl_quic_fifd_pkt_commit(QUIC_FIFD *fifd, QUIC_TXPIM_PKT *pkt)
259 pkt->fifd = fifd;
276 ossl_quic_cfq_mark_tx(fifd->cfq, cfq_item);
285 sstream = fifd->get_sstream_by_id(chunks[i].stream_id,
287 fifd->get_sstream_by_id_arg);
304 return ossl_ackm_on_tx_packet(fifd->ackm, &pkt->ackm_pkt);
307 void ossl_quic_fifd_set_qlog_cb(QUIC_FIFD *fifd, QLOG *(*get_qlog_cb)(void *arg),
310 fifd->get_qlog_cb = get_qlog_cb;
311 fifd->get_qlog_cb_arg = get_qlog_cb_arg;