aleesa-bot/aleesa-craniac
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Implement async signal trap via Mojo::IOLoop::Signal for more robust app stop and restart

Browse Source
This commit is contained in:
eleksir
2022-01-01 17:34:07 +03:00
parent 637e5f8261
commit 0f58c30603
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
lib/Craniac.pm
View File

@@ -20,6 +20,7 @@ use English qw ( -no_match_vars );
use Digest::SHA qw (sha1_base64); use Digest::SHA qw (sha1_base64);
use Hailo; use Hailo;
use Mojo::IOLoop; use Mojo::IOLoop;
use Mojo::IOLoop::Signal;
use Mojo::Log; use Mojo::Log;
# Чтобы "уж точно" использовать hiredis-биндинги, загрузим этот модуль перед Mojo::Redis # Чтобы "уж точно" использовать hiredis-биндинги, загрузим этот модуль перед Mojo::Redis
use Protocol::Redis::XS; use Protocol::Redis::XS;
@@ -351,6 +352,18 @@ my $parse_message = sub {
return; return;
}; };
my $__signal_handler = sub {
my ($self, $name) = @_;
$log->info ("[INFO] Caught a signal $name");
if (defined $main::pidfile && -f $main::pidfile) {
unlink $main::pidfile;
}
exit 0;
};
# Main loop, он же event loop # Main loop, он же event loop
sub RunCraniac () { sub RunCraniac () {
$log->info ("[INFO] Connecting to $c->{server}, $c->{port}"); $log->info ("[INFO] Connecting to $c->{server}, $c->{port}");
@@ -392,6 +405,11 @@ sub RunCraniac () {
); );
} }
Mojo::IOLoop::Signal->on (
TERM => $__signal_handler,
INT => $__signal_handler
);
do { Mojo::IOLoop->start } until Mojo::IOLoop->is_running; do { Mojo::IOLoop->start } until Mojo::IOLoop->is_running;
return; return;
} }