X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FMsg.pm;h=9e7a03a1da59af184231ff4d675f46aab5c641ef;hb=dd01a8824f3896015e031cf301181760a6496bbd;hp=4400fe8d76482050f5d8974b599a6fcdeed55559;hpb=9e8b70da52136e061fee9f8a219c713cc1d7df4d;p=spider.git diff --git a/perl/Msg.pm b/perl/Msg.pm index 4400fe8d..9e7a03a1 100644 --- a/perl/Msg.pm +++ b/perl/Msg.pm @@ -146,7 +146,7 @@ sub _on_connect $sock->timeout(0); $sock->start; $conn->{peerhost} = eval { $handle->peerhost; }; - dbg((ref $conn) . " connected $conn->{cnum} to $conn->{peerhost}:$conn->{peerport}") if isdbg('connll'); + dbg((ref $conn) . " connected $conn->{cnum} to $conn->{peerhost}:$conn->{peerport}") if isdbg('conn') || isdbg ('connect'); if ($conn->{on_connect}) { &{$conn->{on_connect}}($conn, $handle); } @@ -279,7 +279,7 @@ sub disconnect if ($sock->{buffer}) { my $lth = length $sock->{buffer}; Mojo::IOLoop->timer($disc_waittime, sub { - dbg("Buffer contained $lth data , coordinated for $disc_waittime secs, now disconnecting $call") if $dbg; + dbg("Buffer contained $lth characters, coordinated for $disc_waittime secs, now disconnecting $call") if $dbg; _close_it($conn); }); } else { @@ -484,8 +484,8 @@ sub new_client { $sock->start; $conn->{peerhost} = $handle->peerhost; $conn->{peerhost} =~ s|^::ffff:||; # chop off leading pseudo IPV6 stuff on dual stack listeners - $conn->{peerport} = $handle->peerport; - dbg((ref $conn) . " accept $conn->{cnum} from $conn->{peerhost}:$conn->{peerport}") if isdbg('connll'); + $conn->{peerport} = $handle->peerport || 0; + dbg((ref $conn) . " accept $conn->{cnum} from $conn->{peerhost}:$conn->{peerport}") if isdbg('conn') || isdbg('connect'); my ($rproc, $eproc) = &{$server_conn->{rproc}} ($conn, $conn->{peerhost}, $conn->{peerport}); $conn->{sort} = 'Incoming'; if ($eproc) {