zambyte/zaprus
1
0
Fork 0
mirror of https://git.robbyzambito.me/zaprus synced 2025-12-20 16:24:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Complete the handshake

Browse Source
This commit is contained in:
Robby Zambito
2025-04-05 23:27:15 -04:00
parent a2072436aa
commit ec94e85ab9
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/saprus.zig
View File

@@ -131,10 +131,13 @@ pub fn connect(payload: []const u8, allocator: Allocator) !?SaprusMessage {
try setting_up_socket.timedWait(500 * 1000 * 1000 * 1000); try setting_up_socket.timedWait(500 * 1000 * 1000 * 1000);
const msg = try sendInitialConnection(payload, initial_port, allocator); const msg = try sendInitialConnection(payload, initial_port, allocator);
_ = msg;
// Await response from the sentinel
response_thread.join(); response_thread.join();
// Complete handshake after awaiting response
try broadcastSaprusMessage(msg, allocator);
return initial_conn_res; return initial_conn_res;
} }