42 lines
1.3 KiB
Zig
42 lines
1.3 KiB
Zig
const std = @import("std");
|
|
const Session = @import("Session.zig");
|
|
|
|
const Allocator = std.mem.Allocator;
|
|
|
|
pub fn listen() !void {
|
|
const addr = std.net.Address.parseIp4("0.0.0.0", 23301) catch unreachable;
|
|
var listener = try addr.listen(.{
|
|
.kernel_backlog = 100,
|
|
.reuse_address = true,
|
|
});
|
|
|
|
std.log.info("server is listening at {}", .{listener.listen_address});
|
|
|
|
while (true) {
|
|
const conn = listener.accept() catch continue;
|
|
errdefer conn.stream.close();
|
|
|
|
const thread = try std.Thread.spawn(.{}, runSession, .{ conn.address, conn.stream });
|
|
thread.detach();
|
|
}
|
|
}
|
|
|
|
fn runSession(address: std.net.Address, stream: std.net.Stream) !void {
|
|
std.log.info("new connection from {}", .{address});
|
|
|
|
var gpa = std.heap.GeneralPurposeAllocator(.{}){};
|
|
defer if (gpa.deinit() == .leak) std.log.err("memory leaks were detected for session at {}", .{address});
|
|
|
|
const allocator = gpa.allocator();
|
|
|
|
const session = try allocator.create(Session);
|
|
session.* = Session.init(address, stream, allocator);
|
|
|
|
if (session.*.run()) |_| {
|
|
std.log.info("client from {} disconnected", .{address});
|
|
} else |err| {
|
|
std.log.err("session disconnected with an error: {}", .{err});
|
|
}
|
|
|
|
allocator.destroy(session);
|
|
}
|