X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?p=spider.git;a=blobdiff_plain;f=perl%2FDXCron.pm;h=2a02bfd36f75bb340896dbf103637ca27a6c10d1;hp=2ab02967f8d6dcdf5741af56f3d8525f1bfa1f4a;hb=309eea6bcd4a0eaf25f810168bc38dc348c2a982;hpb=2ca690592ea14e2ecd6783feed99ed7a8195162c diff --git a/perl/DXCron.pm b/perl/DXCron.pm index 2ab02967..2a02bfd3 100644 --- a/perl/DXCron.pm +++ b/perl/DXCron.pm @@ -288,14 +288,15 @@ sub spawn_cmd my $fc = DXSubprocess->new(); $fc->run( sub { - $main::me->{_nospawn} = 1; + ++$main::me->{_nospawn}; my @res = $main::me->run_cmd($line); - delete $main::me->{_nospawn}; # diffms("DXCron spawn_cmd 1", $line, $t0, scalar @res) if isdbg('chan'); return @res; }, sub { my ($fc, $err, @res) = @_; + --$main::me->{_nospawn}; + delete $main::me->{_nospawn} if exists $main::me->{_nospawn} && $main::me->{_nospawn} <= 0; if ($err) { my $s = "DXCron::spawn_cmd: error $err"; dbg($s); @@ -326,8 +327,8 @@ sub rcmd sub run_cmd { my $line = shift; - my @in = $main::me->run_cmd($line); dbg("DXCron::run_cmd: $line") if isdbg('cron'); + my @in = $main::me->run_cmd($line); for (@in) { s/\s*$//; dbg("DXCron::cmd out: $_") if isdbg('cron');