Line data Source code
1 : #include "fd_quic_svc_q.h"
2 : #include "fd_quic_private.h"
3 : #include "fd_quic_conn.h"
4 :
5 : /* PRIVATE ************************************************/
6 :
7 : #define PRQ_NAME fd_quic_svc_queue_prq
8 25530347 : #define PRQ_T fd_quic_svc_event_t
9 25229840 : #define PRQ_TMP_ST(p,t) do { \
10 25229840 : (p)[0] = (t); \
11 25229840 : t.conn->svc_meta.private.prq_idx = (ulong)((p)-heap); \
12 25229840 : } while( 0 )
13 25529807 : #define PRQ_TIMEOUT_T long
14 : #include "../../util/tmpl/fd_prq.c"
15 : typedef fd_quic_svc_event_t fd_quic_svc_queue_prq_t;
16 :
17 :
18 : /* SETUP FUNCTIONS *************************************************/
19 :
20 : ulong
21 11142 : fd_quic_svc_timers_footprint( ulong max_conn ) {
22 11142 : ulong l = FD_LAYOUT_INIT;
23 11142 : l = FD_LAYOUT_APPEND( l, alignof(fd_quic_svc_timers_t), sizeof(fd_quic_svc_timers_t) );
24 11142 : l = FD_LAYOUT_APPEND( l, fd_quic_svc_queue_prq_align(), fd_quic_svc_queue_prq_footprint( max_conn ) );
25 11142 : l = FD_LAYOUT_FINI( l, fd_quic_svc_timers_align() );
26 11142 : return l;
27 11142 : }
28 :
29 : ulong
30 36882 : fd_quic_svc_timers_align( void ) {
31 36882 : return fd_ulong_max( alignof( fd_quic_svc_timers_t ),
32 36882 : fd_quic_svc_queue_prq_align() );
33 36882 : }
34 :
35 : fd_quic_svc_timers_t *
36 : fd_quic_svc_timers_init( void * mem,
37 : ulong max_conn,
38 3456 : fd_quic_state_t * state ) {
39 3456 : if( FD_UNLIKELY( !mem ) ) {
40 0 : FD_LOG_ERR(( "fd_quic_svc_timers_init called with NULL mem" ));
41 0 : return NULL;
42 0 : }
43 :
44 3456 : if( FD_UNLIKELY( !fd_ulong_is_aligned( (ulong)mem, fd_quic_svc_timers_align() ) ) ) {
45 0 : FD_LOG_ERR(( "fd_quic_svc_timers_init called with misaligned mem" ));
46 0 : return NULL;
47 0 : }
48 :
49 3456 : FD_SCRATCH_ALLOC_INIT( l, mem );
50 3456 : fd_quic_svc_timers_t * timers = FD_SCRATCH_ALLOC_APPEND( l,
51 3456 : alignof(fd_quic_svc_timers_t),
52 3456 : sizeof(fd_quic_svc_timers_t) );
53 3456 : uchar * prq_mem = FD_SCRATCH_ALLOC_APPEND( l,
54 3456 : fd_quic_svc_queue_prq_align(),
55 3456 : fd_quic_svc_queue_prq_footprint( max_conn ) );
56 :
57 :
58 0 : timers->prq = fd_quic_svc_queue_prq_join( fd_quic_svc_queue_prq_new( prq_mem, max_conn ) );
59 3456 : if( FD_UNLIKELY( !timers->prq ) ) FD_LOG_ERR(( "fd_quic_svc_timers_init failed to join prq" ));
60 :
61 3456 : timers->instant.cnt = 0U;
62 3456 : timers->instant.head = FD_QUIC_SVC_DLIST_IDX_INVAL;
63 3456 : timers->instant.tail = FD_QUIC_SVC_DLIST_IDX_INVAL;
64 :
65 3456 : timers->state = state;
66 :
67 3456 : return timers;
68 3456 : }
69 :
70 : void
71 25209055 : fd_quic_svc_timers_init_conn( fd_quic_conn_t * conn ) {
72 25209055 : conn->svc_meta.next_timeout = LONG_MAX;
73 25209055 : conn->svc_meta.private.prq_idx = FD_QUIC_SVC_PRQ_IDX_INVAL;
74 25209055 : conn->svc_meta.private.svc_type = FD_QUIC_SVC_CNT;
75 25209055 : }
76 :
77 : /* END SETUP FUNCTIONS *********************************************/
78 :
79 : /* DLIST HELPER FUNCTIONS *******************************************/
80 :
81 : static inline void
82 : fd_quic_svc_dlist_insert_tail( fd_quic_svc_queue_t * queue,
83 : fd_quic_state_t * state,
84 24560785 : fd_quic_conn_t * conn ) {
85 :
86 24560785 : uint conn_idx = conn->conn_idx;
87 24560785 : fd_quic_conn_t * tail_conn = fd_quic_conn_at_idx( state, queue->tail );
88 :
89 24560785 : *fd_ptr_if( !!queue->cnt, &tail_conn->svc_meta.private.dlist.next , &queue->head) = conn_idx ;
90 24560785 : conn->svc_meta.private.dlist.prev = queue->tail;
91 24560785 : conn->svc_meta.private.dlist.next = FD_QUIC_SVC_DLIST_IDX_INVAL;
92 24560785 : queue->tail = conn_idx;
93 24560785 : queue->cnt++;
94 24560785 : }
95 :
96 : static inline void
97 : fd_quic_svc_dlist_remove( fd_quic_svc_queue_t * queue,
98 : fd_quic_state_t * state,
99 24560740 : fd_quic_conn_t * conn ) {
100 24560740 : uint conn_idx = conn->conn_idx;
101 24560740 : uint qhead = queue->head;
102 24560740 : uint qtail = queue->tail;
103 :
104 24560740 : fd_quic_conn_t * prev_conn = fd_quic_conn_at_idx( state, conn->svc_meta.private.dlist.prev );
105 24560740 : fd_quic_conn_t * next_conn = fd_quic_conn_at_idx( state, conn->svc_meta.private.dlist.next );
106 :
107 24560740 : *fd_ptr_if( conn_idx == qhead, &queue->head , &prev_conn->svc_meta.private.dlist.next) = conn->svc_meta.private.dlist.next;
108 24560740 : *fd_ptr_if( conn_idx == qtail, &queue->tail , &next_conn->svc_meta.private.dlist.prev) = conn->svc_meta.private.dlist.prev;
109 :
110 24560740 : conn->svc_meta.private.dlist.next = FD_QUIC_SVC_DLIST_IDX_INVAL;
111 24560740 : conn->svc_meta.private.dlist.prev = FD_QUIC_SVC_DLIST_IDX_INVAL;
112 24560740 : queue->cnt--;
113 24560740 : }
114 :
115 : /* TASK FUNCTIONS *************************************************/
116 :
117 : void
118 : fd_quic_svc_timers_cancel( fd_quic_svc_timers_t * timers,
119 14346 : fd_quic_conn_t * conn ) {
120 :
121 14346 : uint svc_type = conn->svc_meta.private.svc_type;
122 14346 : fd_quic_state_t * state = timers->state;
123 :
124 14346 : if( svc_type == FD_QUIC_SVC_INSTANT ) {
125 45 : fd_quic_svc_dlist_remove( &timers->instant, state, conn );
126 14301 : } else if( svc_type == FD_QUIC_SVC_DYNAMIC ) {
127 87 : fd_quic_svc_queue_prq_remove( timers->prq, conn->svc_meta.private.prq_idx );
128 87 : }
129 14346 : fd_quic_svc_timers_init_conn( conn );
130 14346 : }
131 :
132 : void
133 : fd_quic_svc_timers_schedule( fd_quic_svc_timers_t * timers,
134 : fd_quic_conn_t * conn,
135 98208543 : long now ) {
136 :
137 : /* if conn null or invalid, do not schedule */
138 98208543 : if( FD_UNLIKELY( !conn || conn->state == FD_QUIC_CONN_STATE_INVALID ) ) {
139 : /* cleaner/safer to check in here for now. If function call overhead
140 : becomes a constraint, move check to caller */
141 13212 : return;
142 13212 : }
143 :
144 98195331 : fd_quic_state_t * state = timers->state;
145 98195331 : long const expiry = conn->svc_meta.next_timeout;
146 98195331 : uint const old_svc_type = conn->svc_meta.private.svc_type;
147 :
148 98195331 : uint const new_svc_type = expiry == now ? FD_QUIC_SVC_INSTANT : FD_QUIC_SVC_DYNAMIC;
149 98195331 : int const old_dynamic = old_svc_type==FD_QUIC_SVC_DYNAMIC;
150 98195331 : int const both_dynamic = old_dynamic & (new_svc_type==FD_QUIC_SVC_DYNAMIC);
151 :
152 : /* Speculative is_increase is invalid when !both_dynamic, but safe bc prq_idx==0 */
153 98195331 : ulong const prq_idx = fd_ulong_if( both_dynamic, conn->svc_meta.private.prq_idx, 0 );
154 98195331 : int const is_increase = timers->prq[prq_idx].timeout <= expiry;
155 :
156 : /* No-op if already INSTANT, or if trying to increase/preserve DYNAMIC expiry */
157 98195331 : int noop = (old_svc_type==FD_QUIC_SVC_INSTANT) | (both_dynamic & is_increase);
158 98195331 : if( noop ) return;
159 :
160 : /* Cancel existing DYNAMIC timer if it exists */
161 49790355 : if( old_dynamic ) {
162 24926966 : fd_quic_svc_queue_prq_remove( timers->prq, conn->svc_meta.private.prq_idx );
163 24926966 : }
164 :
165 : /* Schedule in appropriate queue */
166 49790355 : conn->svc_meta.private.svc_type = new_svc_type;
167 :
168 49790355 : if( new_svc_type==FD_QUIC_SVC_INSTANT ) {
169 24560785 : fd_quic_svc_dlist_insert_tail( &timers->instant, state, conn );
170 25229570 : } else {
171 : /* FD_QUIC_SVC_DYNAMIC - use heap */
172 25229570 : fd_quic_svc_event_t e = {
173 25229570 : .conn = conn,
174 25229570 : .timeout = expiry
175 25229570 : };
176 25229570 : fd_quic_svc_queue_prq_insert( timers->prq, &e );
177 25229570 : }
178 49790355 : }
179 :
180 : int
181 : fd_quic_svc_timers_validate( fd_quic_svc_timers_t * timers,
182 126 : fd_quic_t * quic ) {
183 126 : fd_quic_state_t * state = fd_quic_get_state( quic );
184 :
185 : /* Validate DYNAMIC queue (heap) */
186 126 : ulong prq_cnt = fd_quic_svc_queue_prq_cnt( timers->prq );
187 300192 : for( ulong i=0; i<prq_cnt; i++ ) {
188 300066 : fd_quic_svc_event_t * event = timers->prq + i;
189 300066 : fd_quic_conn_t * conn = event->conn;
190 :
191 : /* conn and idx match for dynamic queue */
192 300066 : if( FD_UNLIKELY( conn->svc_meta.private.prq_idx != i ) ) return 0;
193 300066 : if( FD_UNLIKELY( conn->svc_meta.private.svc_type != FD_QUIC_SVC_DYNAMIC ) ) return 0;
194 :
195 : /* conn in prq at most once */
196 300066 : if( FD_UNLIKELY( conn->visited ) ) return 0;
197 300066 : conn->visited = 1U;
198 300066 : }
199 :
200 : /* Validate dlist */
201 126 : ulong instant_cnt = 0U;
202 126 : uint curr = timers->instant.head;
203 180 : while( curr != FD_QUIC_SVC_DLIST_IDX_INVAL ) {
204 54 : fd_quic_conn_t * conn = fd_quic_conn_at_idx( state, curr );
205 54 : if( FD_UNLIKELY( conn->svc_meta.private.svc_type != FD_QUIC_SVC_INSTANT ) ) return 0;
206 54 : if( FD_UNLIKELY( conn->visited ) ) return 0;
207 54 : conn->visited = 1U;
208 54 : curr = conn->svc_meta.private.dlist.next;
209 54 : instant_cnt++;
210 54 : }
211 126 : if( instant_cnt != timers->instant.cnt ) return 0;
212 :
213 : /* connections not in any queue should have INVALID idx */
214 126 : ulong const conn_cnt = quic->limits.conn_cnt;
215 300888 : for( ulong i=0; i<conn_cnt; i++ ) {
216 300762 : fd_quic_conn_t * conn = fd_quic_conn_at_idx( state, i );
217 300762 : if( !conn->visited && conn->svc_meta.private.prq_idx != FD_QUIC_SVC_PRQ_IDX_INVAL ) return 0;
218 300762 : }
219 :
220 126 : return 1;
221 126 : }
222 :
223 : fd_quic_svc_event_t
224 : fd_quic_svc_timers_next( fd_quic_svc_timers_t * timers,
225 : long now,
226 146982283 : int pop ) {
227 146982283 : fd_quic_svc_event_t next = { .timeout = LONG_MAX, .conn = NULL };
228 :
229 : /* Priority: INSTANT > DYNAMIC */
230 :
231 : /* Check INSTANT queue first */
232 146982283 : if( FD_LIKELY( timers->instant.cnt ) ) {
233 24609133 : fd_quic_conn_t * conn = fd_quic_conn_at_idx( timers->state, timers->instant.head );
234 24609133 : next = (fd_quic_svc_event_t){.conn = conn, .timeout = fd_long_min( now, conn->svc_meta.next_timeout )};
235 :
236 24609133 : if( FD_LIKELY( pop ) ) {
237 24560695 : fd_quic_svc_dlist_remove( &timers->instant, timers->state, conn );
238 24560695 : fd_quic_svc_timers_init_conn( conn );
239 24560695 : }
240 :
241 24609133 : return next;
242 24609133 : }
243 :
244 : /* Check DYNAMIC queue (heap) */
245 122373150 : if( !fd_quic_svc_queue_prq_cnt( timers->prq ) ) return next;
246 122367795 : else if( pop && now < timers->prq[0].timeout ) return next;
247 105273 : else {
248 105273 : next = timers->prq[0];
249 105273 : if( FD_LIKELY( pop ) ) {
250 2460 : fd_quic_svc_queue_prq_remove_min( timers->prq );
251 2460 : fd_quic_svc_timers_init_conn( next.conn );
252 2460 : }
253 105273 : return next;
254 105273 : }
255 122373150 : }
256 :
257 : fd_quic_svc_event_t
258 : fd_quic_svc_timers_get_event( fd_quic_svc_timers_t * timers,
259 : fd_quic_conn_t * conn,
260 2091 : long now ) {
261 2091 : uint svc_type = conn->svc_meta.private.svc_type;
262 :
263 2091 : if( svc_type == FD_QUIC_SVC_INSTANT ) {
264 0 : return (fd_quic_svc_event_t){ .timeout = now, .conn = conn };
265 2091 : } else if (svc_type == FD_QUIC_SVC_DYNAMIC) {
266 2088 : ulong idx = conn->svc_meta.private.prq_idx;
267 2088 : return *(timers->prq + idx);
268 2088 : }
269 3 : return (fd_quic_svc_event_t){ .timeout = LONG_MAX, .conn = NULL };
270 2091 : }
271 :
272 : ulong
273 171436100 : fd_quic_svc_timers_cnt_events( fd_quic_svc_timers_t * timers ) {
274 171436100 : return timers->instant.cnt +
275 171436100 : fd_quic_svc_queue_prq_cnt( timers->prq );
276 171436100 : }
|
