X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FMsg.pm;h=8992d3c108b85d94886bd3b2d0bf213740eeec94;hb=5835ca385fb719194163512276666aaf75e82484;hp=d0ad733048a3c0699d14695ae2263fb48ac80074;hpb=cbb522ef802d48991734a4ce803fa6ffa9774588;p=spider.git diff --git a/perl/Msg.pm b/perl/Msg.pm index d0ad7330..8992d3c1 100644 --- a/perl/Msg.pm +++ b/perl/Msg.pm @@ -18,7 +18,7 @@ use Mojo::IOLoop; use Mojo::IOLoop::Stream; use DXDebug; -use Timer; +use DXTimer; use vars qw($now %conns $noconns $cnum $total_in $total_out $total_lines_in $total_lines_out $connect_timeout $disc_waittime); @@ -291,7 +291,8 @@ sub disconnect dbg("Buffer empty, just close $call") if $dbg; _close_it($conn); } - } else { + } + else { dbg((ref $conn) . " socket missing on $conn->{call}") if $dbg; _close_it($conn); } @@ -320,7 +321,7 @@ sub _close_it if ($sock) { dbg((ref $conn) . " Connection $conn->{cnum} $call closing gracefully") if isdbg('connll'); - $sock->close_gracefully; + $sock->close_gracefully if $sock->can('close_gracefully'); } # get rid of any references @@ -570,7 +571,8 @@ sub DESTROY my $sock = $conn->{sock}; if ($sock) { - $sock->close_gracefully; + $sock->close_gracefully if $sock->can('close_gracefully'); + delete $conn->{sock}; } $noconns--;