Lines Matching refs:rtor
17 void ossl_quic_reactor_init(QUIC_REACTOR *rtor, in ossl_quic_reactor_init() argument
23 rtor->poll_r.type = BIO_POLL_DESCRIPTOR_TYPE_NONE; in ossl_quic_reactor_init()
24 rtor->poll_w.type = BIO_POLL_DESCRIPTOR_TYPE_NONE; in ossl_quic_reactor_init()
25 rtor->net_read_desired = 0; in ossl_quic_reactor_init()
26 rtor->net_write_desired = 0; in ossl_quic_reactor_init()
27 rtor->can_poll_r = 0; in ossl_quic_reactor_init()
28 rtor->can_poll_w = 0; in ossl_quic_reactor_init()
29 rtor->tick_deadline = initial_tick_deadline; in ossl_quic_reactor_init()
31 rtor->tick_cb = tick_cb; in ossl_quic_reactor_init()
32 rtor->tick_cb_arg = tick_cb_arg; in ossl_quic_reactor_init()
35 void ossl_quic_reactor_set_poll_r(QUIC_REACTOR *rtor, const BIO_POLL_DESCRIPTOR *r) in ossl_quic_reactor_set_poll_r() argument
38 rtor->poll_r.type = BIO_POLL_DESCRIPTOR_TYPE_NONE; in ossl_quic_reactor_set_poll_r()
40 rtor->poll_r = *r; in ossl_quic_reactor_set_poll_r()
42 rtor->can_poll_r in ossl_quic_reactor_set_poll_r()
43 = ossl_quic_reactor_can_support_poll_descriptor(rtor, &rtor->poll_r); in ossl_quic_reactor_set_poll_r()
46 void ossl_quic_reactor_set_poll_w(QUIC_REACTOR *rtor, const BIO_POLL_DESCRIPTOR *w) in ossl_quic_reactor_set_poll_w() argument
49 rtor->poll_w.type = BIO_POLL_DESCRIPTOR_TYPE_NONE; in ossl_quic_reactor_set_poll_w()
51 rtor->poll_w = *w; in ossl_quic_reactor_set_poll_w()
53 rtor->can_poll_w in ossl_quic_reactor_set_poll_w()
54 = ossl_quic_reactor_can_support_poll_descriptor(rtor, &rtor->poll_w); in ossl_quic_reactor_set_poll_w()
57 const BIO_POLL_DESCRIPTOR *ossl_quic_reactor_get_poll_r(const QUIC_REACTOR *rtor) in ossl_quic_reactor_get_poll_r() argument
59 return &rtor->poll_r; in ossl_quic_reactor_get_poll_r()
62 const BIO_POLL_DESCRIPTOR *ossl_quic_reactor_get_poll_w(const QUIC_REACTOR *rtor) in ossl_quic_reactor_get_poll_w() argument
64 return &rtor->poll_w; in ossl_quic_reactor_get_poll_w()
67 int ossl_quic_reactor_can_support_poll_descriptor(const QUIC_REACTOR *rtor, in ossl_quic_reactor_can_support_poll_descriptor() argument
73 int ossl_quic_reactor_can_poll_r(const QUIC_REACTOR *rtor) in ossl_quic_reactor_can_poll_r() argument
75 return rtor->can_poll_r; in ossl_quic_reactor_can_poll_r()
78 int ossl_quic_reactor_can_poll_w(const QUIC_REACTOR *rtor) in ossl_quic_reactor_can_poll_w() argument
80 return rtor->can_poll_w; in ossl_quic_reactor_can_poll_w()
83 int ossl_quic_reactor_net_read_desired(QUIC_REACTOR *rtor) in ossl_quic_reactor_net_read_desired() argument
85 return rtor->net_read_desired; in ossl_quic_reactor_net_read_desired()
88 int ossl_quic_reactor_net_write_desired(QUIC_REACTOR *rtor) in ossl_quic_reactor_net_write_desired() argument
90 return rtor->net_write_desired; in ossl_quic_reactor_net_write_desired()
93 OSSL_TIME ossl_quic_reactor_get_tick_deadline(QUIC_REACTOR *rtor) in ossl_quic_reactor_get_tick_deadline() argument
95 return rtor->tick_deadline; in ossl_quic_reactor_get_tick_deadline()
98 int ossl_quic_reactor_tick(QUIC_REACTOR *rtor, uint32_t flags) in ossl_quic_reactor_tick() argument
109 rtor->tick_cb(&res, rtor->tick_cb_arg, flags); in ossl_quic_reactor_tick()
111 rtor->net_read_desired = res.net_read_desired; in ossl_quic_reactor_tick()
112 rtor->net_write_desired = res.net_write_desired; in ossl_quic_reactor_tick()
113 rtor->tick_deadline = res.tick_deadline; in ossl_quic_reactor_tick()
346 int ossl_quic_reactor_block_until_pred(QUIC_REACTOR *rtor, in ossl_quic_reactor_block_until_pred() argument
358 ossl_quic_reactor_tick(rtor, 0); in ossl_quic_reactor_block_until_pred()
363 if (!poll_two_descriptors(ossl_quic_reactor_get_poll_r(rtor), in ossl_quic_reactor_block_until_pred()
364 ossl_quic_reactor_net_read_desired(rtor), in ossl_quic_reactor_block_until_pred()
365 ossl_quic_reactor_get_poll_w(rtor), in ossl_quic_reactor_block_until_pred()
366 ossl_quic_reactor_net_write_desired(rtor), in ossl_quic_reactor_block_until_pred()
367 ossl_quic_reactor_get_tick_deadline(rtor), in ossl_quic_reactor_block_until_pred()
