Home
last modified time | relevance | path

Searched refs:demux (Results 1 – 10 of 10) sorted by relevance

/openssl/ssl/quic/
H A Dquic_demux.c76 QUIC_DEMUX *demux; in ossl_quic_demux_new() local
79 if (demux == NULL) in ossl_quic_demux_new()
94 return demux; in ossl_quic_demux_new()
110 if (demux == NULL) in ossl_quic_demux_free()
117 OPENSSL_free(demux); in ossl_quic_demux_free()
124 demux->net_bio = net_bio; in ossl_quic_demux_set_bio()
143 demux->mtu = mtu; in ossl_quic_demux_set_mtu()
266 urxe = demux_reserve_urxe(demux, urxe, demux->mtu); in demux_recv()
297 now = demux->now != NULL ? demux->now(demux->now_arg) : ossl_time_zero(); in demux_recv()
352 demux->default_cb(e, demux->default_cb_arg, in demux_process_pending_urxe()
[all …]
H A Dquic_port.c73 if ((port->demux = ossl_quic_demux_new(/*BIO=*/NULL, in port_init()
78 ossl_quic_demux_set_default_handler(port->demux, in port_init()
107 ossl_quic_demux_free(port->demux); in port_cleanup()
108 port->demux = NULL; in port_cleanup()
150 return port->demux; in ossl_quic_port_get0_demux()
261 ossl_quic_demux_set_bio(port->demux, net_rbio); in ossl_quic_port_set_net_rbio()
413 ret = ossl_quic_demux_pump(port->demux); in port_rx_pre()
581 ossl_quic_demux_release_urxe(port->demux, e); in port_default_packet_handler()
H A Dquic_port_local.h60 QUIC_DEMUX *demux; member
H A Dquic_record_rx.c99 QUIC_DEMUX *demux; member
181 if (args->demux == NULL || args->max_deferred == 0) in ossl_qrx_new()
193 qrx->demux = args->demux; in ossl_qrx_new()
218 ossl_quic_demux_release_urxe(qrx->demux, e); in qrx_cleanup_urxl()
1192 ossl_quic_demux_release_urxe(qrx->demux, e); in qrx_process_one_urxe()
H A Dquic_channel.c296 qrx_args.demux = ch->port->demux; in ch_init()
568 return ch->port->demux; in ossl_quic_channel_get0_demux()
588 return ossl_quic_demux_has_pending(ch->port->demux) in ossl_quic_channel_has_pending()
H A Dquic_impl.c2973 QUIC_DEMUX *demux; in SSL_inject_net_dgram() local
2980 demux = ossl_quic_channel_get0_demux(ctx.qc->ch); in SSL_inject_net_dgram()
2981 ret = ossl_quic_demux_inject(demux, buf, buf_len, peer, local); in SSL_inject_net_dgram()
/openssl/include/internal/
H A Dquic_demux.h207 void ossl_quic_demux_free(QUIC_DEMUX *demux);
213 void ossl_quic_demux_set_bio(QUIC_DEMUX *demux, BIO *net_bio);
218 int ossl_quic_demux_set_mtu(QUIC_DEMUX *demux, unsigned int mtu);
230 void ossl_quic_demux_set_default_handler(QUIC_DEMUX *demux,
239 void ossl_quic_demux_release_urxe(QUIC_DEMUX *demux,
253 void ossl_quic_demux_reinject_urxe(QUIC_DEMUX *demux,
280 int ossl_quic_demux_pump(QUIC_DEMUX *demux);
291 int ossl_quic_demux_inject(QUIC_DEMUX *demux,
300 int ossl_quic_demux_has_pending(const QUIC_DEMUX *demux);
H A Dquic_record_rx.h33 QUIC_DEMUX *demux; member
/openssl/test/
H A Dquic_record_test.c46 int (*new_qrx)(QUIC_DEMUX **demux, OSSL_QRX **qrx);
1716 QUIC_DEMUX *demux; member
1747 if (s->demux != NULL) { in rx_state_teardown()
1748 ossl_quic_demux_free(s->demux); in rx_state_teardown()
1749 s->demux = NULL; in rx_state_teardown()
1778 if (s->demux == NULL in rx_state_ensure()
1779 && !TEST_ptr(s->demux = ossl_quic_demux_new(NULL, in rx_state_ensure()
1785 s->args.demux = s->demux; in rx_state_ensure()
1793 ossl_quic_demux_set_default_handler(s->demux, demux_default_handler, s); in rx_state_ensure()
1852 if (!TEST_true(ossl_quic_demux_inject(s.demux, in rx_run_script()
H A Dquic_txp_test.c56 QUIC_DEMUX *demux; member
106 ossl_quic_demux_free(h->demux); in helper_cleanup()
214 if (!TEST_ptr(h->demux = ossl_quic_demux_new(h->bio2, 8, in helper_init()
218 ossl_quic_demux_set_default_handler(h->demux, demux_default_handler, h); in helper_init()
220 h->qrx_args.demux = h->demux; in helper_init()
1320 ossl_quic_demux_pump(h.demux); in run_script()
1332 ossl_quic_demux_pump(h.demux); in run_script()

Completed in 48 milliseconds