X-Git-Url: http://www.dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=d9827a651fc8daf635f886aae7ef1fd6dbfdf717;hb=b0dc102f62871b43134807fa254749b1720d326a;hp=64cbab11ed1d6efc69ed2adc3f6896eb85ca8dee;hpb=e6a53556f10b5d2f831dcd7b83655430c9b1a137;p=spider.git diff --git a/perl/cluster.pl b/perl/cluster.pl index 64cbab11..d9827a65 100755 --- a/perl/cluster.pl +++ b/perl/cluster.pl @@ -94,7 +94,7 @@ sub already_conn dbg('chan', "-> Z $call bye\n"); $conn->send_now("Z$call|bye"); # this will cause 'client' to disconnect sleep(1); - $conn->disconnect; + $conn->disconnect(); } # handle incoming messages @@ -105,7 +105,7 @@ sub rec if (defined $err && $err) { if ($dxchan) { - disconnect($dxchan); + $dxchan->disconnect; } return; } @@ -184,9 +184,9 @@ sub cease }; dbg('local', "Local::finish error $@") if $@; - # disconnect users + # disconnect nodes foreach $dxchan (DXChannel->get_all()) { - next if $dxchan->is_ak1a; + next unless $dxchan->is_ak1a; disconnect($dxchan) unless $dxchan == $DXProt::me; } Msg->event_loop(1, 0.05); @@ -196,9 +196,9 @@ sub cease Msg->event_loop(1, 0.05); Msg->event_loop(1, 0.05); - # disconnect nodes + # disconnect users foreach $dxchan (DXChannel->get_all()) { - next unless $dxchan->is_ak1a; + next if $dxchan->is_ak1a; disconnect($dxchan) unless $dxchan == $DXProt::me; } Msg->event_loop(1, 0.05); @@ -207,12 +207,6 @@ sub cease Msg->event_loop(1, 0.05); Msg->event_loop(1, 0.05); Msg->event_loop(1, 0.05); - Msg->event_loop(1, 0.05); - Msg->event_loop(1, 0.05); - Msg->event_loop(1, 0.05); - Msg->event_loop(1, 0.05); - Msg->event_loop(1, 0.05); - Msg->event_loop(1, 0.05); DXUser::finish(); # close all databases