X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FMsg.pm;h=df4edd3606f0d90ae1faaf3bf07415e2ed50d558;hb=f6fd9522ef2db78203d2de675d46ec8f722eb071;hp=bad84a2c4f2277d7b117999f5fbe7e55e6aa9a16;hpb=28b4b03213440a9951d68da6ef1f5c17a327e002;p=spider.git

diff --git a/perl/Msg.pm b/perl/Msg.pm
index bad84a2c..df4edd36 100644
--- a/perl/Msg.pm
+++ b/perl/Msg.pm
@@ -136,8 +136,8 @@ sub _on_connect
 	undef $conn->{sock};
 	my $sock = $conn->{sock} = Mojo::IOLoop::Stream->new($handle);
 	$sock->on(read => sub {$conn->_rcv($_[1]);} );
-	$sock->on(error => sub {$conn->disconnect;});
-	$sock->on(close => sub {$conn->disconnect;});
+	$sock->on(error => sub {delete $conn->{sock}; $conn->disconnect;});
+	$sock->on(close => sub {delete $conn->{sock}; $conn->disconnect;});
 	$sock->timeout(0);
 	$sock->start;
 	$conn->{peerhost} = eval { $handle->peerhost; };