diff --git a/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm b/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm index e95fb603..80ea1fd4 100644 --- a/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm +++ b/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm @@ -35,8 +35,10 @@ sub worker_body { my $self = shift; my $wid = $self->wid; - return debug "mgr ($wid): no need for manager... quitting" - if setting('workers')->{'no_manager'}; + if (setting('workers')->{'no_manager'}) { + prctl sprintf 'netdisco-daemon: worker #%s manager: shutdown', $wid; + return debug "mgr ($wid): no need for manager... quitting" + } my $num_slots = MCE::Util::_parse_max_workers( setting('workers')->{tasks} ) diff --git a/Netdisco/lib/App/Netdisco/Daemon/Worker/Scheduler.pm b/Netdisco/lib/App/Netdisco/Daemon/Worker/Scheduler.pm index 198872b8..cd71b55e 100644 --- a/Netdisco/lib/App/Netdisco/Daemon/Worker/Scheduler.pm +++ b/Netdisco/lib/App/Netdisco/Daemon/Worker/Scheduler.pm @@ -38,8 +38,10 @@ sub worker_body { my $self = shift; my $wid = $self->wid; - return debug "sch ($wid): no need for scheduler... quitting" - unless setting('schedule'); + unless (setting('schedule')) { + prctl sprintf 'netdisco-daemon: worker #%s scheduler: shutdown', $wid; + return debug "sch ($wid): no need for scheduler... quitting" + } while (1) { # sleep until some point in the next minute