X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=a40a5aa5c51c274f2690984526a0de43fd5cecc8;hb=38aa5af305ed46fcf56f4624eb6bac29afaccda5;hp=2cf7173f9c5cea358c8267670f27d029c07f0cf4;hpb=d17f05b19fac36a0a8a2f828912a1a7ebefae79f;p=spider.git

diff --git a/perl/cluster.pl b/perl/cluster.pl
index 2cf7173f..a40a5aa5 100755
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -144,10 +144,9 @@ sub already_conn
 {
 	my ($conn, $call, $mess) = @_;
 
-	$conn->disable_read(1);
 	dbg("-> D $call $mess\n") if isdbg('chan');
+	$conn->disable_read(1);
 	$conn->send_now("D$call|$mess");
-	sleep(2);
 	$conn->disconnect;
 }
 
@@ -372,6 +371,8 @@ sub idle_loop
 		AGWMsg::process();
 		BPQMsg::process();
 
+		Timer::handler();
+
 		if (defined &Local::process) {
 			eval {
 				Local::process();       # do any localised processing
@@ -579,8 +580,7 @@ $script->run($main::me) if $script;
 
 #open(DB::OUT, "|tee /tmp/aa");
 
-my $idle_loop = AnyEvent->idle(cb => &idle_loop);
-
+my $per_sec = AnyEvent->timer(after => 0, interval => 0.010, cb => sub{idle_loop()});
 
 # main loop
 $decease->recv;