summaryrefslogtreecommitdiff
path: root/src/multiplex.c
diff options
context:
space:
mode:
authorAndrew Opalach <andrew@akon.city> 2026-04-13 16:11:04 -0400
committerAndrew Opalach <andrew@akon.city> 2026-04-13 16:11:04 -0400
commita389b8f2f9c55b76fe5a28c3f1fea798ed37aa98 (patch)
treeff9dcee72485443b77f03220564efa44fbe0c705 /src/multiplex.c
parentf78a30aaccffddc3e3eab07870e02157322af956 (diff)
downloadlibnaunet-a389b8f2f9c55b76fe5a28c3f1fea798ed37aa98.tar.gz
libnaunet-a389b8f2f9c55b76fe5a28c3f1fea798ed37aa98.tar.bz2
libnaunet-a389b8f2f9c55b76fe5a28c3f1fea798ed37aa98.zip
Allow packet_stream_reconnect() to cut offHEADmaster
a connecting stream. Cleanup timer. Signed-off-by: Andrew Opalach <andrew@akon.city>
Diffstat (limited to 'src/multiplex.c')
-rw-r--r--src/multiplex.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/multiplex.c b/src/multiplex.c
index 2de4621..0911540 100644
--- a/src/multiplex.c
+++ b/src/multiplex.c
@@ -108,9 +108,9 @@ static void direct_connect(struct nn_packet_stream *client, u8 id)
multiplex_direct_global.connection_callback(multiplex_direct_global.userdata, id, server);
server->direct = client;
client->direct = server;
- // Connected happens on the server first.
- nn_packet_stream_connected(server);
- nn_packet_stream_connected(client);
+ // Explicitly signal connected on the server first.
+ nn_packet_stream_set_connected(server);
+ nn_packet_stream_set_connected(client);
}
void nn_multiplex_direct_connect(struct nn_packet_stream *client, u8 id)