test of panic handling in server
All checks were successful
AWS-Zig Build / build-zig-0.11.0-amd64-host (push) Successful in 1m34s
All checks were successful
AWS-Zig Build / build-zig-0.11.0-amd64-host (push) Successful in 1m34s
This commit is contained in:
parent
bebf1b9dfa
commit
edeed81e06
|
@ -8,7 +8,7 @@ const log = std.log.scoped(.universal_lambda);
|
||||||
const runFn = blk: {
|
const runFn = blk: {
|
||||||
switch (build_options.build_type) {
|
switch (build_options.build_type) {
|
||||||
.awslambda => break :blk @import("lambda.zig").run,
|
.awslambda => break :blk @import("lambda.zig").run,
|
||||||
.standalone_server => break :blk runStandaloneServer,
|
.standalone_server => break :blk runStandaloneServerParent,
|
||||||
.flexilib => break :blk @import("flexilib.zig").run,
|
.flexilib => break :blk @import("flexilib.zig").run,
|
||||||
.exe_run, .cloudflare => break :blk @import("console.zig").run,
|
.exe_run, .cloudflare => break :blk @import("console.zig").run,
|
||||||
}
|
}
|
||||||
|
@ -24,6 +24,39 @@ pub fn run(allocator: ?std.mem.Allocator, event_handler: interface.HandlerFn) !u
|
||||||
return try runFn(allocator, event_handler);
|
return try runFn(allocator, event_handler);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// We need to create a child process to be able to deal with panics appropriately
|
||||||
|
fn runStandaloneServerParent(allocator: ?std.mem.Allocator, event_handler: interface.HandlerFn) !u8 {
|
||||||
|
const alloc = allocator orelse std.heap.page_allocator;
|
||||||
|
|
||||||
|
var arena = std.heap.ArenaAllocator.init(alloc);
|
||||||
|
defer arena.deinit();
|
||||||
|
|
||||||
|
var aa = arena.allocator();
|
||||||
|
var al = std.ArrayList([]const u8).init(aa);
|
||||||
|
defer al.deinit();
|
||||||
|
var argi = std.process.args();
|
||||||
|
// We do this first so it shows more prominently when looking at processes
|
||||||
|
// Also it will be slightly faster for whatever that is worth
|
||||||
|
const child_arg = "--child_of_standalone_server";
|
||||||
|
try al.append(child_arg);
|
||||||
|
while (argi.next()) |a| {
|
||||||
|
if (std.mem.eql(u8, child_arg, a)) {
|
||||||
|
// This should never actually return
|
||||||
|
return try runStandaloneServer(allocator, event_handler);
|
||||||
|
}
|
||||||
|
try al.append(a);
|
||||||
|
}
|
||||||
|
// Parent
|
||||||
|
var cp = std.ChildProcess.init(al.items, aa);
|
||||||
|
cp.stdin = std.io.getStdIn();
|
||||||
|
cp.stdout = std.io.getStdOut();
|
||||||
|
cp.stderr = std.io.getStdErr();
|
||||||
|
while (true) {
|
||||||
|
_ = try cp.spawnAndWait();
|
||||||
|
try cp.stderr.?.writeAll("Caught abnormal process termination, relaunching server");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Will create a web server and marshall all requests back to our event handler
|
/// Will create a web server and marshall all requests back to our event handler
|
||||||
/// To keep things simple, we'll have this on a single thread, at least for now
|
/// To keep things simple, we'll have this on a single thread, at least for now
|
||||||
fn runStandaloneServer(allocator: ?std.mem.Allocator, event_handler: interface.HandlerFn) !u8 {
|
fn runStandaloneServer(allocator: ?std.mem.Allocator, event_handler: interface.HandlerFn) !u8 {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user