summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
Diffstat (limited to 'src/server')
-rw-r--r--src/server/main.zig14
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;