X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FMsg.pm;h=bad84a2c4f2277d7b117999f5fbe7e55e6aa9a16;hb=28b4b03213440a9951d68da6ef1f5c17a327e002;hp=ba0e6b8eadf520d92f78ecde2219ae49bc903a1d;hpb=a16516b3420ac10f2a8d147057a26c75492e430c;p=spider.git diff --git a/perl/Msg.pm b/perl/Msg.pm index ba0e6b8e..bad84a2c 100644 --- a/perl/Msg.pm +++ b/perl/Msg.pm @@ -278,6 +278,9 @@ sub _send_stuff my $conn = shift; my $rq = $conn->{outqueue}; my $sock = $conn->{sock}; + return unless defined $sock; + return if $conn->{disconnecting}; + while (@$rq) { my $data = shift @$rq; my $lth = length $data; @@ -377,6 +380,7 @@ sub _rcv { # Complement to _send my $msg = shift; my $sock = $conn->{sock}; return unless defined($sock); + return if $conn->{disconnecting}; $total_in += length $msg;