X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FMsg.pm;h=aa9993e7ff966bf2b15ae5d3dc9782e96a421271;hb=f47c97d80722ed7d1881afa7caa0e8d24b6b0a75;hp=f3642d59b79dfabd3bbe0b7f00e7d514421981ba;hpb=422e8587b6408c8d2b712e3319169ef412c6a509;p=spider.git diff --git a/perl/Msg.pm b/perl/Msg.pm index f3642d59..aa9993e7 100644 --- a/perl/Msg.pm +++ b/perl/Msg.pm @@ -283,24 +283,7 @@ sub disconnect my $ref = $conns{$call}; delete $conns{$call} if $ref && $ref == $conn; } - - $conn->{delay} = Mojo::IOLoop->delay ( -# Mojo::IOLoop->delay ( - sub { - my $delay = shift; - dbg("before drain $call") if $dbg; - $sock->on(drain => $delay->begin); - 1; - }, - sub { - my $delay = shift; - dbg("before _close_it $call") if $dbg; - _close_it($conn); - 1; - } - ); - $conn->{delay}->wait; - + _close_it($conn); } else { dbg((ref $conn) . " socket missing on $conn->{call}") if $dbg; _close_it($conn);