Keep connection construction independent from link admission policy

This commit is contained in:
evgeny committed 2026-10-30 22:50:11 +01:00
1 parent 510dbc2e15
commit 8d6aef37da
3 files changed
+4 -4

No files matched your search

+1 -1
View File
@@ -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);
+2 -2
View File
@@ -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));
}
+1 -1
View File
@@ -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);