mirror of
https://git.robbyzambito.me/zits
synced 2026-02-04 03:34:48 +00:00
Return error.Canceled from concurrent group task
This commit is contained in:
@@ -126,9 +126,10 @@ fn handleConnectionInfallible(
|
||||
stream: Stream,
|
||||
r_buf_size: usize,
|
||||
w_buf_size: usize,
|
||||
) void {
|
||||
handleConnection(server, server_allocator, io, id, stream, r_buf_size, w_buf_size) catch |err| {
|
||||
log.err("Failed processing client {d}: {any}", .{ id, err });
|
||||
) !void {
|
||||
handleConnection(server, server_allocator, io, id, stream, r_buf_size, w_buf_size) catch |err| switch (err) {
|
||||
error.Canceled => return error.Canceled,
|
||||
else => log.err("Failed processing client {d}: {any}", .{ id, err }),
|
||||
};
|
||||
}
|
||||
|
||||
@@ -229,8 +230,9 @@ fn handleConnection(
|
||||
},
|
||||
}
|
||||
} else |err| switch (err) {
|
||||
error.EndOfStream => {
|
||||
error.EndOfStream, error.ReadFailed => {
|
||||
log.debug("Client {d} disconnected", .{id});
|
||||
return error.Canceled;
|
||||
},
|
||||
else => {
|
||||
return err;
|
||||
|
||||
Reference in New Issue
Block a user