X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=5d6248efa296ab372364f9ddb684e3de8c3c2149;hb=502f900651a46b96008028945616a3b610d6cc7a;hp=aa44006786c5d382925d10e45cb324f0ca162766;hpb=f155969d600561b9ef151a7ce2494a0c89aed033;p=spider.git

diff --git a/perl/cluster.pl b/perl/cluster.pl
index aa440067..5d6248ef 100755
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -106,6 +106,11 @@ sub rec
 	
 	if (!defined $msg || (defined $err && $err)) {
 		if ($dxchan) {
+			if (defined $err) {
+				$conn->disconnect;
+				undef $conn;
+				$dxchan->conn(undef);
+			}
 			$dxchan->disconnect;
 		} elsif ($conn) {
 			$conn->disconnect;
@@ -375,6 +380,11 @@ dbg('err', "orft we jolly well go ...");
 
 #open(DB::OUT, "|tee /tmp/aa");
 
+$SIG{PIPE} = sub { 
+	#$DB::single = 1;  
+	dbg('err', "Broken PIPE signal received"); 
+};
+
 for (;;) {
 	my $timenow;
 #	$DB::trace = 1;