Lines Matching refs:e
99 QUIC_URXE *e, *enext; in demux_free_urxl() local
101 for (e = ossl_list_urxe_head(l); e != NULL; e = enext) { in demux_free_urxl()
102 enext = ossl_list_urxe_next(e); in demux_free_urxl()
103 ossl_list_urxe_remove(l, e); in demux_free_urxl()
104 OPENSSL_free(e); in demux_free_urxl()
157 QUIC_URXE *e; in demux_alloc_urxe() local
162 e = OPENSSL_malloc(sizeof(QUIC_URXE) + alloc_len); in demux_alloc_urxe()
163 if (e == NULL) in demux_alloc_urxe()
166 ossl_list_urxe_init_elem(e); in demux_alloc_urxe()
167 e->alloc_len = alloc_len; in demux_alloc_urxe()
168 e->data_len = 0; in demux_alloc_urxe()
169 return e; in demux_alloc_urxe()
172 static QUIC_URXE *demux_resize_urxe(QUIC_DEMUX *demux, QUIC_URXE *e, in demux_resize_urxe() argument
177 if (!ossl_assert(e->demux_state == URXE_DEMUX_STATE_FREE)) in demux_resize_urxe()
181 prev = ossl_list_urxe_prev(e); in demux_resize_urxe()
182 ossl_list_urxe_remove(&demux->urx_free, e); in demux_resize_urxe()
184 e2 = OPENSSL_realloc(e, sizeof(QUIC_URXE) + new_alloc_len); in demux_resize_urxe()
188 ossl_list_urxe_insert_head(&demux->urx_free, e); in demux_resize_urxe()
190 ossl_list_urxe_insert_after(&demux->urx_free, prev, e); in demux_resize_urxe()
204 static QUIC_URXE *demux_reserve_urxe(QUIC_DEMUX *demux, QUIC_URXE *e, in demux_reserve_urxe() argument
207 return e->alloc_len < alloc_len ? demux_resize_urxe(demux, e, alloc_len) : e; in demux_reserve_urxe()
212 QUIC_URXE *e; in demux_ensure_free_urxe() local
215 e = demux_alloc_urxe(demux->mtu); in demux_ensure_free_urxe()
216 if (e == NULL) in demux_ensure_free_urxe()
219 ossl_list_urxe_insert_tail(&demux->urx_free, e); in demux_ensure_free_urxe()
220 e->demux_state = URXE_DEMUX_STATE_FREE; in demux_ensure_free_urxe()
318 QUIC_URXE *e, in demux_identify_conn_id() argument
321 return ossl_quic_wire_get_pkt_hdr_dst_conn_id(ossl_quic_urxe_data(e), in demux_identify_conn_id()
322 e->data_len, in demux_identify_conn_id()
331 static int demux_process_pending_urxe(QUIC_DEMUX *demux, QUIC_URXE *e) in demux_process_pending_urxe() argument
337 if (!ossl_assert(e == ossl_list_urxe_head(&demux->urx_pending))) in demux_process_pending_urxe()
340 assert(e->demux_state == URXE_DEMUX_STATE_PENDING); in demux_process_pending_urxe()
343 dst_conn_id_ok = demux_identify_conn_id(demux, e, &dst_conn_id); in demux_process_pending_urxe()
345 ossl_list_urxe_remove(&demux->urx_pending, e); in demux_process_pending_urxe()
351 e->demux_state = URXE_DEMUX_STATE_ISSUED; in demux_process_pending_urxe()
352 demux->default_cb(e, demux->default_cb_arg, in demux_process_pending_urxe()
356 ossl_list_urxe_insert_tail(&demux->urx_free, e); in demux_process_pending_urxe()
357 e->demux_state = URXE_DEMUX_STATE_FREE; in demux_process_pending_urxe()
366 QUIC_URXE *e; in demux_process_pending_urxl() local
369 while ((e = ossl_list_urxe_head(&demux->urx_pending)) != NULL) in demux_process_pending_urxl()
370 if ((ret = demux_process_pending_urxe(demux, e)) <= 0) in demux_process_pending_urxl()
453 QUIC_URXE *e) in ossl_quic_demux_release_urxe() argument
455 assert(ossl_list_urxe_prev(e) == NULL && ossl_list_urxe_next(e) == NULL); in ossl_quic_demux_release_urxe()
456 assert(e->demux_state == URXE_DEMUX_STATE_ISSUED); in ossl_quic_demux_release_urxe()
457 ossl_list_urxe_insert_tail(&demux->urx_free, e); in ossl_quic_demux_release_urxe()
458 e->demux_state = URXE_DEMUX_STATE_FREE; in ossl_quic_demux_release_urxe()
462 QUIC_URXE *e) in ossl_quic_demux_reinject_urxe() argument
464 assert(ossl_list_urxe_prev(e) == NULL && ossl_list_urxe_next(e) == NULL); in ossl_quic_demux_reinject_urxe()
465 assert(e->demux_state == URXE_DEMUX_STATE_ISSUED); in ossl_quic_demux_reinject_urxe()
466 ossl_list_urxe_insert_head(&demux->urx_pending, e); in ossl_quic_demux_reinject_urxe()
467 e->demux_state = URXE_DEMUX_STATE_PENDING; in ossl_quic_demux_reinject_urxe()
