# that (also see perlipc)
my $WORKER_PIDS;
+my $WORKER_FLAG = 0;
my $log_task_result = sub {
my ($upid, $user, $status) = @_;
return $self->{user};
}
+sub is_worker {
+ return $WORKER_FLAG;
+}
+
# read/update list of active workers
# we move all finished tasks to the archive index,
# but keep aktive and most recent task in the active file.
my @arlist = ();
foreach my $task (@ta) {
if (!$task->{saved}) {
- $archive .= sprintf("$task->{upid} %08X $task->{status}\n", $task->{endtime});
+ $archive .= sprintf("%s %08X %s\n", $task->{upid}, $task->{endtime}, $task->{status});
$save = 1;
push @arlist, $task;
$task->{saved} = 1;
if (!$cpid) { # child
$0 = "task $upid";
+ $WORKER_FLAG = 1;
$SIG{INT} = $SIG{QUIT} = $SIG{TERM} = sub { die "received interrupt\n"; };