public/browser
1
0
Fork 0
mirror of https://github.com/lightpanda-io/browser.git synced 2025-10-29 15:13:28 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

server: move to TCP conn

Browse Source 
Signed-off-by: Francis Bouvier <francis@lightpanda.io>
This commit is contained in:
Francis Bouvier
2024-10-08 23:44:47 +02:00
parent c35c09db60
commit b0ff325125
1 changed files with 5 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main.zig
View File

@@ -30,7 +30,9 @@ const apiweb = @import("apiweb.zig");
pub const Types = jsruntime.reflect(apiweb.Interfaces); pub const Types = jsruntime.reflect(apiweb.Interfaces);
pub const UserContext = apiweb.UserContext; pub const UserContext = apiweb.UserContext;
const socket_path = "/tmp/browsercore-server.sock"; // TODO: move to cli options
const host = "127.0.0.1";
const port = 3245;
// Inspired by std.net.StreamServer in Zig < 0.12 // Inspired by std.net.StreamServer in Zig < 0.12
pub const StreamServer = struct { pub const StreamServer = struct {
@@ -138,18 +140,8 @@ pub fn main() !void {
var arena = std.heap.ArenaAllocator.init(std.heap.page_allocator); var arena = std.heap.ArenaAllocator.init(std.heap.page_allocator);
defer arena.deinit(); defer arena.deinit();
// remove socket file of internal server
// reuse_address (SO_REUSEADDR flag) does not seems to work on unix socket
// see: https://gavv.net/articles/unix-socket-reuse/
// TODO: use a lock file instead
std.posix.unlink(socket_path) catch |err| {
if (err != error.FileNotFound) {
return err;
}
};
// server // server
const addr = try std.net.Address.initUnix(socket_path); const addr = try std.net.Address.parseIp4(host, port);
var srv = StreamServer.init(.{ var srv = StreamServer.init(.{
.reuse_address = true, .reuse_address = true,
.reuse_port = true, .reuse_port = true,
@@ -159,7 +151,7 @@ pub fn main() !void {
try srv.listen(addr); try srv.listen(addr);
defer srv.close(); defer srv.close();
std.debug.print("Listening on: {s}...\n", .{socket_path}); std.log.info("Listening on: {s}:{d}...", .{ host, port });
var loop = try jsruntime.Loop.init(arena.allocator()); var loop = try jsruntime.Loop.init(arena.allocator());
defer loop.deinit(); defer loop.deinit();