From 8d6aef37da3033a96f120ee4f5c42a5cef9e8cd6 Mon Sep 17 00:00:00 2001 From: evgeny Date: Fri, 30 Oct 2026 22:50:11 +0100 Subject: [PATCH] Keep connection construction independent from link admission policy --- tests/test_chat_sync_schedule.c | 2 +- tests/test_etcp_init_liveness.c | 4 ++-- tests/test_etcp_packet_link.c | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/test_chat_sync_schedule.c b/tests/test_chat_sync_schedule.c index 8c6536bb..ad430f35 100644 --- a/tests/test_chat_sync_schedule.c +++ b/tests/test_chat_sync_schedule.c @@ -95,7 +95,7 @@ static void setup(struct fixture* f) { assert(channels == 2); for (unsigned i = 0; i < 3; i++) { struct SC_MYKEYS keys; assert(sc_generate_keypair(&keys) == SC_OK); - struct ETCP_CONN* conn = etcp_connection_create(f->inst, "schedule peer", 0); assert(conn); + struct ETCP_CONN* conn = etcp_connection_create(f->inst, "schedule peer"); assert(conn); conn->peer_node_id = sc_derive_node_id_from_pubkey(keys.public_key); conn->initialized = 1; conn->links_up = 1; conn->state = 1; assert(sc_init_ctx(&conn->crypto_ctx, &f->inst->my_keys) == SC_OK); diff --git a/tests/test_etcp_init_liveness.c b/tests/test_etcp_init_liveness.c index 15151750..a6179d5d 100644 --- a/tests/test_etcp_init_liveness.c +++ b/tests/test_etcp_init_liveness.c @@ -92,7 +92,7 @@ static struct ETCP_LINK* first_link(unsigned side) { static void run_for(unsigned tb) { test_clock_run_for(ua, tb); } static void start_source(unsigned count) { - ep[0].conn = etcp_connection_create(ep[0].inst, "liveness", known_default); CHECK(ep[0].conn); + ep[0].conn = etcp_connection_create(ep[0].inst, "liveness"); CHECK(ep[0].conn); ep[0].conn->peer_node_id = ep[1].inst->node_id; CHECK(sc_init_ctx(&ep[0].conn->crypto_ctx, &ep[0].inst->my_keys) == SC_OK); CHECK(sc_set_peer_public_key(&ep[0].conn->crypto_ctx, ep[1].inst->my_keys.public_key, SC_PEER_PUBKEY_BIN) == SC_OK); @@ -123,7 +123,7 @@ static void setup(unsigned swapped, unsigned count) { if (!count) return; /* Отдельная проверка входящего INIT до создания транспорта. */ if (known_default) { /* Общий объект ранее мог быть создан BLE: входящий UDP обязан переиспользовать его без CHAT-проверки. */ - ep[1].conn = etcp_connection_create(ep[1].inst, "shared native", 1); CHECK(ep[1].conn); + ep[1].conn = etcp_connection_create(ep[1].inst, "shared native"); CHECK(ep[1].conn); CHECK(!etcp_connection_set_peer(ep[1].conn, ep[0].inst->my_keys.public_key)); CHECK(!etcp_conn_index_peer(ep[1].conn)); } diff --git a/tests/test_etcp_packet_link.c b/tests/test_etcp_packet_link.c index c925a097..d48d3cdb 100644 --- a/tests/test_etcp_packet_link.c +++ b/tests/test_etcp_packet_link.c @@ -50,7 +50,7 @@ int main(void) { sock.links_queue = queue_new(ua, 16, 0, LINK_ADDR_KEY_SIZE, "packet_links"); assert(sock.links_queue); sock.socket_id = uasync_add_socket_t(ua, sock.fd, NULL, etcp_link_io_socket_writable, NULL, "packet_test", &sock); assert(sock.socket_id); - struct ETCP_CONN* conn = etcp_connection_create(&inst, "packet_test", 0); assert(conn); + struct ETCP_CONN* conn = etcp_connection_create(&inst, "packet_test"); assert(conn); conn->peer_node_id = 2; etcp_conn_ready(conn); conn->links_up = 1; struct sockaddr_storage addr = {0}; struct sockaddr_in* ip = (struct sockaddr_in*)&addr; ip->sin_family = AF_INET; ip->sin_addr.s_addr = htonl(INADDR_LOOPBACK); ip->sin_port = htons(1111);