X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=5b65717e705ebee2634f3c87f3cc6b2e3555d55b;hb=7a395060c59baffc5d2a57c2dbcbed89aa85dd1e;hp=a33e6da5f1a8e76b2907cf8547791702a146cdd9;hpb=537a4a109f291c206d754ec2067d49f9964cca08;p=spider.git diff --git a/perl/cluster.pl b/perl/cluster.pl index a33e6da5..5b65717e 100755 --- a/perl/cluster.pl +++ b/perl/cluster.pl @@ -34,11 +34,14 @@ BEGIN { # try to create and lock a lockfile (this isn't atomic but # should do for now $lockfn = "$root/local/cluster.lck"; # lock file name - if (-e $lockfn) { + if (-w $lockfn) { open(CLLOCK, "$lockfn") or die "Can't open Lockfile ($lockfn) $!"; my $pid = ; - chomp $pid; - die "Lockfile ($lockfn) and process $pid exist, another cluster running?" if kill 0, $pid; + if ($pid) { + chomp $pid; + die "Lockfile ($lockfn) and process $pid exist, another cluster running?" if kill 0, $pid; + } + unlink $lockfn; close CLLOCK; } open(CLLOCK, ">$lockfn") or die "Can't open Lockfile ($lockfn) $!"; @@ -564,6 +567,8 @@ for (;;) { AGWMsg::process(); BPQMsg::process(); + DXLog::flushall(); + if (defined &Local::process) { eval { Local::process(); # do any localised processing