diff options
Diffstat (limited to 'src/server/main.zig')
| -rw-r--r-- | src/server/main.zig | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/src/server/main.zig b/src/server/main.zig index fca0dee..d8cf1d7 100644 --- a/src/server/main.zig +++ b/src/server/main.zig @@ -70,10 +70,11 @@ pub fn main(alloc: std.mem.Allocator, server_config: ServerInfo) !void { try io.sleep(.fromMilliseconds(1), .awake); } - std.debug.print("\nShutting down...\n", .{}); + std.debug.print("\n", .{}); + std.log.info("Shutting down...", .{}); server_task.cancel(io) catch {}; } - std.debug.print("Goodbye\n", .{}); + std.log.info("Goodbye", .{}); } pub fn start(server: *Server, io: std.Io, gpa: std.mem.Allocator) !void { @@ -82,18 +83,19 @@ pub fn start(server: *Server, io: std.Io, gpa: std.mem.Allocator) !void { server.info.port, ), io, .{ .reuse_address = true }); defer tcp_server.deinit(io); + std.log.info("Server listening on {s}:{d}", .{server.info.host, server.info.port}); var client_group: std.Io.Group = .init; defer client_group.cancel(io); var id: usize = 0; while (true) : (id +%= 1) { - std.debug.print("in server loop\n", .{}); if (server.clients.contains(id)) continue; + std.log.debug("Accepting next client", .{}); const stream = try tcp_server.accept(io); - std.debug.print("accepted connection\n", .{}); + std.log.debug("Accepted connection {d}", .{id}); _ = client_group.concurrent(io, handleConnectionInfallible, .{ server, gpa, io, id, stream }) catch { - std.debug.print("could not start concurrent handler for {d}\n", .{id}); + std.log.err("Could not start concurrent handler for {d}", .{id}); stream.close(io); }; } @@ -205,7 +207,7 @@ fn handleConnection( } } else |err| switch (err) { error.EndOfStream => { - std.debug.print("Client {d} disconnected\n", .{id}); + std.log.debug("Client {d} disconnected", .{id}); }, else => { return err; |
