}
my $tlist = $rest_env->active_workers($upid);
- $rest_env->broadcast_tasklist($tlist);
+ eval { $rest_env->broadcast_tasklist($tlist); };
+ syslog('err', $@) if $@;
my $task;
foreach my $t (@$tlist) {
$msg = $task->{status};
}
- $rest_env->log_cluster_msg($pri, $user, "end task $upid $msg")
- if $rest_env;
+ $rest_env->log_cluster_msg($pri, $user, "end task $upid $msg");
};
my $worker_reaper = sub {
}
sub get_user {
- my ($self) = @_;
+ my ($self, $noerr) = @_;
- die "user name not set\n" if !$self->{user};
+ return $self->{user} if defined($self->{user}) || $noerr;
- return $self->{user};
+ die "user name not set\n";
}
sub is_worker {
# we try to reduce the amount of data
# list all running tasks and task and a few others
# try to limit to 25 tasks
- my $ctime = time();
my $max = 25 - scalar(@$tlist);
foreach my $task (@ta) {
last if $max <= 0;
$self->log_cluster_msg('info', $user, "starting task $upid");
my $tlist = $self->active_workers($upid, $sync);
- $self->broadcast_tasklist($tlist);
+ eval { $self->broadcast_tasklist($tlist); };
+ syslog('err', $@) if $@;
my $res = 0;