mirrors/zaprus
1
0
Fork 0
mirror of https://git.robbyzambito.me/zaprus/ synced 2026-02-04 03:34:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Retry timing

Browse Source 
Wait 2 minutes if trying for initial connect. Wait 10 minutes if
connection to sentinel has timed out
This commit is contained in:
Robby Zambito
2026-01-24 18:50:22 -05:00
parent 16fd65e281
commit cf365673b5
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/main.zig
View File

@@ -126,6 +126,8 @@ pub fn main(init: std.process.Init) !void {
return; return;
} }
var retry_seconds: u16 = 120;
if (flags.connect != null) { if (flags.connect != null) {
reconnect: while (true) { reconnect: while (true) {
log.debug("Starting connection", .{}); log.debug("Starting connection", .{});
@@ -133,14 +135,22 @@ pub fn main(init: std.process.Init) !void {
var init_con_buf: [SaprusClient.max_payload_len]u8 = undefined; var init_con_buf: [SaprusClient.max_payload_len]u8 = undefined;
var w: Writer = .fixed(&init_con_buf); var w: Writer = .fixed(&init_con_buf);
try w.print("{b64}", .{flags.connect.?}); try w.print("{b64}", .{flags.connect.?});
var connection = try client.connect(init.io, w.buffered()); var connection = client.connect(init.io, w.buffered()) catch {
try init.io.sleep(.fromSeconds(retry_seconds), .boot);
continue;
};
defer connection.deinit(); defer connection.deinit();
retry_seconds = 600;
log.debug("Connection started", .{}); log.debug("Connection started", .{});
while (true) { while (true) {
var res_buf: [2048]u8 = undefined; var res_buf: [2048]u8 = undefined;
const next = connection.next(init.io, &res_buf) catch continue :reconnect; const next = connection.next(init.io, &res_buf) catch {
try init.io.sleep(.fromSeconds(retry_seconds), .boot);
continue :reconnect;
};
const b64d = std.base64.standard.Decoder; const b64d = std.base64.standard.Decoder;
var connection_payload_buf: [2048]u8 = undefined; var connection_payload_buf: [2048]u8 = undefined;