Home
last modified time | relevance | path

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

/freebsd/crypto/openssl/ssl/quic/
H A Dquic_reactor.c24 static void rtor_notify_other_threads(QUIC_REACTOR *rtor);
26 int ossl_quic_reactor_init(QUIC_REACTOR *rtor, in ossl_quic_reactor_init() argument
34 rtor->poll_r.type = BIO_POLL_DESCRIPTOR_TYPE_NONE; in ossl_quic_reactor_init()
35 rtor->poll_w.type = BIO_POLL_DESCRIPTOR_TYPE_NONE; in ossl_quic_reactor_init()
36 rtor->net_read_desired = 0; in ossl_quic_reactor_init()
37 rtor->net_write_desired = 0; in ossl_quic_reactor_init()
38 rtor->can_poll_r = 0; in ossl_quic_reactor_init()
39 rtor->can_poll_w = 0; in ossl_quic_reactor_init()
40 rtor->tick_deadline = initial_tick_deadline; in ossl_quic_reactor_init()
42 rtor->tick_cb = tick_cb; in ossl_quic_reactor_init()
[all …]
H A Dquic_reactor_wait_ctx.c16 QUIC_REACTOR *rtor; /* primary key */ member
30 ossl_quic_reactor_enter_blocking_section(slot->rtor); in slot_activate()
40 ossl_quic_reactor_leave_blocking_section(slot->rtor); in slot_deactivate()
44 QUIC_REACTOR *rtor) in ossl_quic_reactor_wait_ctx_enter() argument
49 if (slot->rtor == rtor) in ossl_quic_reactor_wait_ctx_enter()
56 slot->rtor = rtor; in ossl_quic_reactor_wait_ctx_enter()
65 QUIC_REACTOR *rtor) in ossl_quic_reactor_wait_ctx_leave() argument
70 if (slot->rtor == rtor) in ossl_quic_reactor_wait_ctx_leave()
H A Dquic_thread_assist.c24 QUIC_REACTOR *rtor; in assist_thread_main() local
29 rtor = ossl_quic_channel_get_reactor(qta->ch); in assist_thread_main()
37 deadline = ossl_quic_reactor_get_tick_deadline(rtor); in assist_thread_main()
59 ossl_quic_reactor_tick(rtor, QUIC_REACTOR_TICK_FLAG_CHANNEL_ONLY); in assist_thread_main()
H A Dquic_obj.c97 QUIC_REACTOR *rtor; in ossl_quic_obj_can_support_blocking() local
100 rtor = ossl_quic_obj_get0_reactor(obj); in ossl_quic_obj_can_support_blocking()
107 return ossl_quic_reactor_can_poll_r(rtor) in ossl_quic_obj_can_support_blocking()
108 || ossl_quic_reactor_can_poll_w(rtor); in ossl_quic_obj_can_support_blocking()
H A Dquic_engine.c56 return ossl_quic_reactor_init(&qeng->rtor, qeng_tick, qeng, in qeng_init()
64 ossl_quic_reactor_cleanup(&qeng->rtor); in qeng_cleanup()
69 return &qeng->rtor; in ossl_quic_engine_get0_reactor()
H A Dquic_engine_local.h48 QUIC_REACTOR rtor; member
H A Dquic_impl.c558 QUIC_REACTOR *rtor; in block_until_pred() local
569 rtor = ossl_quic_engine_get0_reactor(qeng); in block_until_pred()
570 return ossl_quic_reactor_block_until_pred(rtor, pred, pred_arg, flags); in block_until_pred()
5388 QUIC_REACTOR *rtor; in ossl_quic_get_notifier_fd() local
5396 rtor = ossl_quic_obj_get0_reactor(ctx.obj); in ossl_quic_get_notifier_fd()
5397 nfy = ossl_quic_reactor_get0_notifier(rtor); in ossl_quic_get_notifier_fd()
5411 QUIC_REACTOR *rtor; in ossl_quic_enter_blocking_section() local
5417 rtor = ossl_quic_obj_get0_reactor(ctx.obj); in ossl_quic_enter_blocking_section()
5418 ossl_quic_reactor_wait_ctx_enter(wctx, rtor); in ossl_quic_enter_blocking_section()
5426 QUIC_REACTOR *rtor; in ossl_quic_leave_blocking_section() local
[all …]
H A Dquic_port.c329 ossl_quic_reactor_set_poll_w(&port->engine->rtor, &d); in port_update_poll_desc()
331 ossl_quic_reactor_set_poll_r(&port->engine->rtor, &d); in port_update_poll_desc()
/freebsd/crypto/openssl/include/internal/
H A Dquic_reactor.h147 int ossl_quic_reactor_init(QUIC_REACTOR *rtor,
155 void ossl_quic_reactor_cleanup(QUIC_REACTOR *rtor);
157 void ossl_quic_reactor_set_poll_r(QUIC_REACTOR *rtor,
160 void ossl_quic_reactor_set_poll_w(QUIC_REACTOR *rtor,
163 const BIO_POLL_DESCRIPTOR *ossl_quic_reactor_get_poll_r(const QUIC_REACTOR *rtor);
164 const BIO_POLL_DESCRIPTOR *ossl_quic_reactor_get_poll_w(const QUIC_REACTOR *rtor);
166 int ossl_quic_reactor_can_poll_r(const QUIC_REACTOR *rtor);
167 int ossl_quic_reactor_can_poll_w(const QUIC_REACTOR *rtor);
169 int ossl_quic_reactor_can_support_poll_descriptor(const QUIC_REACTOR *rtor,
172 int ossl_quic_reactor_net_read_desired(QUIC_REACTOR *rtor);
[all …]
H A Dquic_reactor_wait_ctx.h98 QUIC_REACTOR *rtor);
102 QUIC_REACTOR *rtor);