Lines Matching full:conn
40 QUIC_LCIDM_CONN *conn; member
93 static unsigned long lcidm_conn_hash(const QUIC_LCIDM_CONN *conn) in lcidm_conn_hash() argument
95 return (unsigned long)(uintptr_t)conn->opaque; in lcidm_conn_hash()
138 static void lcidm_delete_conn(QUIC_LCIDM *lcidm, QUIC_LCIDM_CONN *conn);
140 static void lcidm_delete_conn_(QUIC_LCIDM_CONN *conn, void *arg) in lcidm_delete_conn_() argument
142 lcidm_delete_conn((QUIC_LCIDM *)arg, conn); in lcidm_delete_conn_()
200 QUIC_LCIDM_CONN *conn = lcidm_get0_conn(lcidm, opaque); in lcidm_upsert_conn() local
202 if (conn != NULL) in lcidm_upsert_conn()
203 return conn; in lcidm_upsert_conn()
205 if ((conn = OPENSSL_zalloc(sizeof(*conn))) == NULL) in lcidm_upsert_conn()
208 if ((conn->lcids = lh_QUIC_LCID_new(lcid_hash, lcid_comp)) == NULL) in lcidm_upsert_conn()
211 conn->opaque = opaque; in lcidm_upsert_conn()
213 lh_QUIC_LCIDM_CONN_insert(lcidm->conns, conn); in lcidm_upsert_conn()
217 return conn; in lcidm_upsert_conn()
220 if (conn != NULL) { in lcidm_upsert_conn()
221 lh_QUIC_LCID_free(conn->lcids); in lcidm_upsert_conn()
222 OPENSSL_free(conn); in lcidm_upsert_conn()
230 lh_QUIC_LCID_delete(lcid_obj->conn->lcids, lcid_obj); in lcidm_delete_conn_lcid()
231 assert(lcid_obj->conn->num_active_lcid > 0); in lcidm_delete_conn_lcid()
232 --lcid_obj->conn->num_active_lcid; in lcidm_delete_conn_lcid()
242 static void lcidm_delete_conn(QUIC_LCIDM *lcidm, QUIC_LCIDM_CONN *conn) in lcidm_delete_conn() argument
245 lh_QUIC_LCID_set_down_load(conn->lcids, 0); in lcidm_delete_conn()
247 lh_QUIC_LCID_doall_arg(conn->lcids, lcidm_delete_conn_lcid_, lcidm); in lcidm_delete_conn()
248 lh_QUIC_LCIDM_CONN_delete(lcidm->conns, conn); in lcidm_delete_conn()
249 lh_QUIC_LCID_free(conn->lcids); in lcidm_delete_conn()
250 OPENSSL_free(conn); in lcidm_delete_conn()
253 static QUIC_LCID *lcidm_conn_new_lcid(QUIC_LCIDM *lcidm, QUIC_LCIDM_CONN *conn, in lcidm_conn_new_lcid() argument
265 lcid_obj->conn = conn; in lcidm_conn_new_lcid()
268 lh_QUIC_LCID_insert(conn->lcids, lcid_obj); in lcidm_conn_new_lcid()
269 if (lh_QUIC_LCID_error(conn->lcids)) in lcidm_conn_new_lcid()
274 lh_QUIC_LCID_delete(conn->lcids, lcid_obj); in lcidm_conn_new_lcid()
278 ++conn->num_active_lcid; in lcidm_conn_new_lcid()
294 QUIC_LCIDM_CONN *conn; in ossl_quic_lcidm_get_num_active_lcid() local
296 conn = lcidm_get0_conn(lcidm, opaque); in ossl_quic_lcidm_get_num_active_lcid()
297 if (conn == NULL) in ossl_quic_lcidm_get_num_active_lcid()
300 return conn->num_active_lcid; in ossl_quic_lcidm_get_num_active_lcid()
328 QUIC_LCIDM_CONN *conn; in lcidm_generate() local
333 if ((conn = lcidm_upsert_conn(lcidm, opaque)) == NULL) in lcidm_generate()
336 if ((type == LCID_TYPE_INITIAL && conn->next_seq_num > 0) in lcidm_generate()
337 || conn->next_seq_num > OSSL_QUIC_VLINT_MAX) in lcidm_generate()
358 if ((lcid_obj = lcidm_conn_new_lcid(lcidm, conn, lcid_out)) == NULL) in lcidm_generate()
361 lcid_obj->seq_num = conn->next_seq_num; in lcidm_generate()
367 ++conn->next_seq_num; in lcidm_generate()
375 QUIC_LCIDM_CONN *conn; in ossl_quic_lcidm_enrol_odcid() local
382 if ((conn = lcidm_upsert_conn(lcidm, opaque)) == NULL) in ossl_quic_lcidm_enrol_odcid()
385 if (conn->done_odcid) in ossl_quic_lcidm_enrol_odcid()
393 if ((lcid_obj = lcidm_conn_new_lcid(lcidm, conn, initial_odcid)) == NULL) in ossl_quic_lcidm_enrol_odcid()
399 conn->odcid_lcid_obj = lcid_obj; in ossl_quic_lcidm_enrol_odcid()
400 conn->done_odcid = 1; in ossl_quic_lcidm_enrol_odcid()
415 QUIC_LCIDM_CONN *conn; in ossl_quic_lcidm_bind_channel() local
427 if ((conn = lcidm_upsert_conn(lcidm, opaque)) == NULL) in ossl_quic_lcidm_bind_channel()
430 if ((lcid_obj = lcidm_conn_new_lcid(lcidm, conn, lcid)) == NULL) { in ossl_quic_lcidm_bind_channel()
431 lcidm_delete_conn(lcidm, conn); in ossl_quic_lcidm_bind_channel()
435 lcid_obj->seq_num = conn->next_seq_num; in ossl_quic_lcidm_bind_channel()
437 conn->next_seq_num++; in ossl_quic_lcidm_bind_channel()
456 QUIC_LCIDM_CONN *conn; in ossl_quic_lcidm_retire_odcid() local
458 if ((conn = lcidm_upsert_conn(lcidm, opaque)) == NULL) in ossl_quic_lcidm_retire_odcid()
461 if (conn->odcid_lcid_obj == NULL) in ossl_quic_lcidm_retire_odcid()
464 lcidm_delete_conn_lcid(lcidm, conn->odcid_lcid_obj); in ossl_quic_lcidm_retire_odcid()
465 conn->odcid_lcid_obj = NULL; in ossl_quic_lcidm_retire_odcid()
497 QUIC_LCIDM_CONN key, *conn; in ossl_quic_lcidm_retire() local
506 if ((conn = lh_QUIC_LCIDM_CONN_retrieve(lcidm->conns, &key)) == NULL) in ossl_quic_lcidm_retire()
512 lh_QUIC_LCID_doall_arg(conn->lcids, retire_for_conn, &args); in ossl_quic_lcidm_retire()
533 QUIC_LCIDM_CONN key, *conn; in ossl_quic_lcidm_cull() local
537 if ((conn = lh_QUIC_LCIDM_CONN_retrieve(lcidm->conns, &key)) == NULL) in ossl_quic_lcidm_cull()
540 lcidm_delete_conn(lcidm, conn); in ossl_quic_lcidm_cull()
561 *opaque = lcid_obj->conn->opaque; in ossl_quic_lcidm_lookup()
584 QUIC_LCIDM_CONN *conn; in ossl_quic_lcidm_debug_add() local
590 if ((conn = lcidm_upsert_conn(lcidm, opaque)) == NULL) in ossl_quic_lcidm_debug_add()
598 if ((lcid_obj = lcidm_conn_new_lcid(lcidm, conn, lcid)) == NULL) in ossl_quic_lcidm_debug_add()