Fix (now) missing dxchan error_handler

[spider.git] / perl / cluster.pl

diff --git a/perl/cluster.pl b/perl/cluster.pl
index c13d93a1df72b3238e7b23011e96b956434789df..ab6673247fcf04c899d1756eb24766493fce7641 100755 (executable)
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -138,7 +138,7 @@ $maxconnect_user = 3;                       # the maximum no of concurrent connections a user can ha
 $maxconnect_node = 0;                  # Ditto but for nodes. In either case if a new incoming connection
                                                                # takes the no of references in the routing table above these numbers
                                                                # then the connection is refused. This only affects INCOMING connections.
-$idle_interval = 0.100;                        # the wait between invocations of the main idle loop processing.
+$idle_interval = 0.500;                        # the wait between invocations of the main idle loop processing.
 our $ending;                                                              # signal that we are ending;
 
 
@@ -237,7 +237,7 @@ sub new_channel
        $conn->conns($call) if $conn->isa('IntMsg');
 
        # set callbacks
-       $conn->set_error(sub {my $err = shift; error_handler($dxchan, $err)});
+       $conn->set_error(sub {my $err = shift; LogDbg('DXCommand', "Comms error '$err' received for call $dxchan->{call}"); $dxchan->disconnect(1);});
        $conn->set_on_eof(sub {$dxchan->disconnect});
        $conn->set_rproc(sub {my ($conn,$msg) = @_; $dxchan->rec($msg);});
        $dxchan->rec($msg);
@@ -342,7 +342,7 @@ sub idle_loop
        my $timenow = time;
 
        BPQMsg::process();
-       DXChannel::process();
+#      DXChannel::process();
 
        #      $DB::trace = 0;
 
@@ -373,7 +373,7 @@ sub idle_loop
                AGWMsg::process();
                
                Timer::handler();
-
+               DXLog::flush_all();
        }
 
        if (defined &Local::process) {