X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=0de499f62a4784b9cdbbb7271977374b04ba3a50;hb=8ac487c0c3297023df07493b11fe166d4c857081;hp=8502cbaba6b3d44bc4bd8935a566fd6c042d8ce4;hpb=678715c76fa49f08acb30df0760b34407f49675c;p=spider.git

diff --git a/perl/cluster.pl b/perl/cluster.pl
index 8502cbab..0de499f6 100755
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -20,6 +20,20 @@ BEGIN {
 	
 	unshift @INC, "$root/perl";	# this IS the right way round!
 	unshift @INC, "$root/local";
+
+	# try to create and lock a lockfile (this isn't atomic but 
+	# should do for now
+	$lockfn = "$root/perl/cluster.lock";       # lock file name
+	if (-e $lockfn) {
+		open(CLLOCK, "$lockfn") or die "Can't open Lockfile ($lockfn) $!";
+		my $pid = <CLLOCK>;
+		chomp $pid;
+		die "Lockfile ($lockfn) and process $pid exist, another cluster running?" if kill 0, $pid;
+		close CLLOCK;
+	}
+	open(CLLOCK, ">$lockfn") or die "Can't open Lockfile ($lockfn) $!";
+	print CLLOCK "$$\n";
+	close CLLOCK;
 }
 
 use Msg;
@@ -42,6 +56,7 @@ use Bands;
 use Geomag;
 use CmdAlias;
 use Local;
+use Fcntl ':flock'; 
 
 use Carp;
 
@@ -49,9 +64,10 @@ package main;
 
 @inqueue = ();					# the main input queue, an array of hashes
 $systime = 0;					# the time now (in seconds)
-$version = "1.23";				# the version no of the software
+$version = "1.24";				# the version no of the software
 $starttime = 0;                 # the starting time of the cluster   
- 
+$lockfn = "cluster.lock";       # lock file name
+      
 # handle disconnections
 sub disconnect
 {
@@ -149,7 +165,12 @@ sub cease
 	foreach $dxchan (DXChannel->get_all()) {
 		disconnect($dxchan) unless $dxchan == $DXProt::me;
 	}
+	Msg->event_loop(1, 0.05);
+	Msg->event_loop(1, 0.05);
+	Msg->event_loop(1, 0.05);
+	Msg->event_loop(1, 0.05);
 	Log('cluster', "DXSpider V$version stopped");
+	unlink $lockfn;
 	exit(0);
 }
 
@@ -233,7 +254,7 @@ Bands::load();
 
 # initialise User file system
 print "loading user file system ...\n"; 
-DXUser->init($userfn);
+DXUser->init($userfn, 1);
 
 # start listening for incoming messages/connects
 print "starting listener ...\n";
@@ -281,8 +302,6 @@ eval {
 };
 dbg('local', "Local::init error $@") if $@;
 
-
-
 # print various flags
 #print "useful info - \$^D: $^D \$^W: $^W \$^S: $^S \$^P: $^P\n";