From ec94e85ab90ccec073e8cbcb3d725a5ab145110e Mon Sep 17 00:00:00 2001 From: Robby Zambito Date: Sat, 5 Apr 2025 23:27:15 -0400 Subject: Complete the handshake --- src/saprus.zig | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'src/saprus.zig') diff --git a/src/saprus.zig b/src/saprus.zig index 97748be..9d676c1 100644 --- a/src/saprus.zig +++ b/src/saprus.zig @@ -131,10 +131,13 @@ pub fn connect(payload: []const u8, allocator: Allocator) !?SaprusMessage { try setting_up_socket.timedWait(500 * 1000 * 1000 * 1000); const msg = try sendInitialConnection(payload, initial_port, allocator); - _ = msg; + // Await response from the sentinel response_thread.join(); + // Complete handshake after awaiting response + try broadcastSaprusMessage(msg, allocator); + return initial_conn_res; } -- cgit