signal.re

type signal_msg = {
	sig_val : int
};

let rec signal_listener_thread = (signal_events : Event.channel(signal_msg)) => {
	Log.info("Waiting for signal");
	let msg = Event.sync(Event.receive(signal_events));
	Log.info("Received signal: %d", msg.sig_val);
	signal_listener_thread(signal_events);
};

let parent(pid : int) = {
	let chan = Event.new_channel();
	let _ = Thread.create(signal_listener_thread, chan);
	/* Setup the signal listener here */
	let handler = Signal_handle((my_sig) => {
		Log.info("Signal sent: %d", my_sig);
		let _ = Event.send(chan, {sig_val: my_sig});
		Log.info("Signal completed sending: %d", my_sig);
	});
	Sys.set_signal(Sys.sigint, handler);
	Sys.set_signal(Sys.sigterm, handler);
	let _ = Unix.sigprocmask(SIG_UNBLOCK, [Sys.sigint, Sys.sigterm]);
	waitpid_loop(pid);
};