2022-12-27 22:39:23 +01:00
|
|
|
const std = @import("std");
|
|
|
|
const hexdump = @import("./hexdump.zig");
|
|
|
|
const net = std.net;
|
|
|
|
const fmt = std.fmt;
|
2022-12-29 12:16:12 +01:00
|
|
|
const os = std.os;
|
2022-12-27 22:39:23 +01:00
|
|
|
|
|
|
|
const ipc = @import("./main.zig");
|
|
|
|
|
2022-12-29 12:16:12 +01:00
|
|
|
const builtin = @import("builtin");
|
|
|
|
const native_os = builtin.target.os.tag;
|
2022-12-27 22:39:23 +01:00
|
|
|
const print = std.debug.print;
|
|
|
|
const testing = std.testing;
|
|
|
|
const print_eq = @import("./util.zig").print_eq;
|
|
|
|
|
2022-12-29 10:12:40 +01:00
|
|
|
// TODO: standard library is unecessary complex regarding networking.
|
|
|
|
// Should libipc drop it and use plain old file descriptors instead?
|
2022-12-27 22:39:23 +01:00
|
|
|
|
|
|
|
// TODO: path => std.XXX.YYY, not simple [] const u8
|
|
|
|
|
|
|
|
// TODO: both Connection and pollfd store file descriptors.
|
|
|
|
// Connection stores either Stream (server) or Address (client).
|
|
|
|
|
|
|
|
// TODO: API should completely obfuscate the inner structures.
|
|
|
|
// Only structures in this file should be necessary.
|
|
|
|
|
|
|
|
fn create_service() !void {
|
|
|
|
const config = .{.safety = true};
|
|
|
|
var gpa = std.heap.GeneralPurposeAllocator(config){};
|
|
|
|
defer _ = gpa.deinit();
|
|
|
|
const allocator = gpa.allocator();
|
|
|
|
|
|
|
|
var ctx = try ipc.Context.init(allocator);
|
|
|
|
defer ctx.deinit(); // There. Can't leak. Isn't Zig wonderful?
|
|
|
|
|
|
|
|
const path = "/tmp/.TEST_USOCK";
|
|
|
|
|
|
|
|
// SERVER SIDE: creating a service.
|
|
|
|
_ = try ctx.server_init(path);
|
|
|
|
|
2022-12-29 12:16:12 +01:00
|
|
|
// signal handler, to quit when asked
|
|
|
|
const S = struct {
|
|
|
|
var should_quit: bool = false;
|
|
|
|
|
|
|
|
fn handler(sig: i32, info: *const os.siginfo_t, _: ?*const anyopaque) callconv(.C) void {
|
|
|
|
print ("A signal has been received: {}\n", .{sig});
|
|
|
|
// Check that we received the correct signal.
|
|
|
|
switch (native_os) {
|
|
|
|
.netbsd => {
|
|
|
|
if (sig != os.SIG.HUP or sig != info.info.signo)
|
|
|
|
return;
|
|
|
|
},
|
|
|
|
else => {
|
|
|
|
if (sig != os.SIG.HUP and sig != info.signo)
|
|
|
|
return;
|
|
|
|
},
|
|
|
|
}
|
|
|
|
should_quit = true;
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
var sa = os.Sigaction{
|
|
|
|
.handler = .{ .sigaction = &S.handler },
|
|
|
|
.mask = os.empty_sigset, // Do not mask any signal.
|
|
|
|
.flags = os.SA.SIGINFO,
|
|
|
|
};
|
|
|
|
|
|
|
|
// Quit on SIGHUP (kill -1).
|
|
|
|
try os.sigaction(os.SIG.HUP, &sa, null);
|
2022-12-27 22:39:23 +01:00
|
|
|
|
|
|
|
var some_event: ipc.Event = undefined;
|
2022-12-29 12:16:12 +01:00
|
|
|
ctx.timer = 10000; // 10 seconds
|
|
|
|
while(! S.should_quit) {
|
2022-12-27 22:39:23 +01:00
|
|
|
some_event = try ctx.wait_event();
|
|
|
|
switch (some_event.t) {
|
|
|
|
.TIMER => {
|
|
|
|
print("Timer!\n", .{});
|
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
|
|
|
.CONNECTION => {
|
|
|
|
print("New connection: {} so far!\n", .{ctx.pollfd.items.len});
|
|
|
|
},
|
|
|
|
|
|
|
|
.DISCONNECTION => {
|
|
|
|
print("User {} disconnected, {} remainaing.\n"
|
|
|
|
, .{some_event.origin, ctx.pollfd.items.len});
|
|
|
|
},
|
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.EXTERNAL => {
|
|
|
|
print("Message received from a non IPC socket.\n", .{});
|
|
|
|
print("NOT IMPLEMENTED, YET. It's a suicide, then.\n", .{});
|
|
|
|
break;
|
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.SWITCH => {
|
|
|
|
print("Message to send to a corresponding fd.\n", .{});
|
|
|
|
print("NOT IMPLEMENTED, YET. It's a suicide, then.\n", .{});
|
|
|
|
break;
|
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.MESSAGE => {
|
|
|
|
if (some_event.m) |m| {
|
2022-12-29 10:12:40 +01:00
|
|
|
print("New message: {}\n", .{m});
|
|
|
|
print("Let's echo it...\n", .{});
|
2022-12-27 22:39:23 +01:00
|
|
|
try ctx.schedule(m);
|
|
|
|
}
|
2022-12-29 10:12:40 +01:00
|
|
|
else {
|
|
|
|
print("Error while receiving new message.\n", .{});
|
|
|
|
print("Ignoring...\n", .{});
|
|
|
|
}
|
2022-12-27 22:39:23 +01:00
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.LOOKUP => {
|
|
|
|
print("Client asking for a service through ipcd.\n", .{});
|
|
|
|
print("NOT IMPLEMENTED, YET. It's a suicide, then.\n", .{});
|
|
|
|
break;
|
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.TX => {
|
|
|
|
print("Message sent.\n", .{});
|
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.NOT_SET => {
|
|
|
|
print("Event type not set. Something is wrong, let's suicide.\n", .{});
|
|
|
|
break;
|
|
|
|
},
|
2022-12-29 10:12:40 +01:00
|
|
|
|
2022-12-27 22:39:23 +01:00
|
|
|
.ERROR => {
|
|
|
|
print("A problem occured, event: {}, let's suicide\n", .{some_event});
|
|
|
|
break;
|
|
|
|
},
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-12-29 12:16:12 +01:00
|
|
|
print("Goodbye\n", .{});
|
2022-12-27 22:39:23 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
pub fn main() !u8 {
|
|
|
|
try create_service();
|
|
|
|
return 0;
|
|
|
|
}
|