ziex-dev-mirror/ziex
1
0
Fork 0
mirror of https://github.com/ziex-dev/ziex.git synced 2026-07-20 02:29:36 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix: retry accept on transient error (#114)

Browse Source
This commit is contained in:
Mohabbat 2026-05-11 16:27:22 +06:00 committed by GitHub
parent b4653385a2
commit 6d0d80ff34
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 21 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/cli/dev/DevServer.zig
View File

@ -186,16 +186,34 @@ pub fn findFreePort() !u16 {
}
fn serve(ds: *DevServer) void {
var retry_count: u8 = 0;
while (true) {
const connection = ds.tcp_server.?.accept() catch |err| {
log.err("failed to accept connection: {s}", .{@errorName(err)});
return;
switch (err) {
error.Unexpected => {
retry_count += 1;
if (retry_count > 5) {
log.err("accept() failed {d} times, giving up: {s}", .{ retry_count - 1, @errorName(err) });
return;
}
log.warn("accept() failed (transient): {s}", .{@errorName(err)});
std.Thread.sleep(50 * std.time.ns_per_ms);
continue;
},
else => {
log.err("failed to accept connection: {s}", .{@errorName(err)});
return;
},
}
};
_ = std.Thread.spawn(.{}, handleConnection, .{ ds, connection }) catch |err| {
retry_count = 0;
const thread = std.Thread.spawn(.{}, handleConnection, .{ ds, connection }) catch |err| {
log.err("unable to spawn connection thread: {s}", .{@errorName(err)});
connection.stream.close();
continue;
};
thread.detach();
}
}