X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fconsole.pl;h=4ba23d43502e7aefe0de3fe0abb65b3fa9d0aa60;hb=6e858487b4db7054748d3d82830249bb134265b4;hp=a25e1533a806469186e7d5d450eaac756efc2170;hpb=bbc51ffb416a39a421b6054d1cb57af330ab68f1;p=spider.git

diff --git a/perl/console.pl b/perl/console.pl
index a25e1533..4ba23d43 100755
--- a/perl/console.pl
+++ b/perl/console.pl
@@ -71,6 +71,7 @@ my @time = ();
 my $lastmin = 0;
 my $sigint;
 my $sigterm;
+my $decease;
 
 #$SIG{WINCH} = sub {@time = gettimeofday};
 
@@ -140,13 +141,23 @@ sub do_resize
 	show_screen();
 }
 
+my $ceasing = 0;
+
 # cease communications
 sub cease
 {
 	my $sendz = shift;
+
+	print "ceasing ($ceasing)\r\n";
+
+	return if $ceasing;
+	++$ceasing;
+
 	$conn->disconnect if $conn;
-	endwin();
 	dbgclose();
+	endwin();
+	$decease->send;
+
 	print @_ if @_;
 	exit(0);	
 }
@@ -505,6 +516,9 @@ if ($call eq $main::mycall) {
 	exit(0);
 }
 
+# create end condvar
+$decease = AnyEvent->condvar;
+
 dbginit();
 
 $conn = IntMsg->connect("$main::clusteraddr", $main::clusterport, \&rec_socket);
@@ -521,22 +535,22 @@ if (! $conn) {
 	exit(0);
 }
 
-# create end condvar
-my $decease = AnyEvent->condvar;
-
-$conn->set_error(sub{cease(0)});
 
 unless ($DB::VERSION) {
 	$sigint = AnyEvent->signal(signal=>'INT', cb=> sub{$decease->send});
 	$sigterm = AnyEvent->signal(signal=>'TERM', cb=> sub{$decease->send});
 }
 
-$SIG{'HUP'} = \&sig_term;
+#$SIG{'HUP'} = \&sig_term;
+my $sighup = AnyEvent->signal(signal=>'HUP', cb=> sub{$decease->send});
+$conn->{sock}->on_eof(sub{$decease->send});
+$conn->{sock}->on_error(sub{$decease->send});
 
 # start up
 do_resize();
 
-$SIG{__DIE__} = \&sig_term;
+#$SIG{__DIE__} = \&sig_term;
+#my $sigdie = AnyEvent->signal(signal=>'__DIE__', cb=> sub{$decease->send});
 
 $conn->send_later("A$call|$connsort width=$cols");
 $conn->send_later("I$call|set/page $maxshist");
@@ -551,4 +565,3 @@ my $event_loop =  AnyEvent->timer(after => 0, interval => 0.010, cb => sub{idle_
 $decease->recv;
 
 cease(0);
-exit(0);