update proctitle when worker not running
This commit is contained in:
		| @@ -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} ) | ||||
|   | ||||
| @@ -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 | ||||
|   | ||||
		Reference in New Issue
	
	Block a user