X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FMsg.pm;h=3a422c3a817c4c93fe32fdd1c1f2f281c5a61e0f;hb=63b5e2134b2ffba051682618f88b09d5ee5457c7;hp=f1f60edfb6f845e5e04604a41c1a49785380a33f;hpb=59e9f019432790d60afcbc96e490375e6a544dbc;p=spider.git diff --git a/perl/Msg.pm b/perl/Msg.pm index f1f60edf..3a422c3a 100644 --- a/perl/Msg.pm +++ b/perl/Msg.pm @@ -73,9 +73,9 @@ sub new csort => 'telnet', timeval => 60, blocking => 0, + cnum => ++$noconns, }; - $noconns++; dbg('connll', "Connection created ($noconns)"); return bless $conn, $class; } @@ -121,7 +121,7 @@ sub conns confess "changing $pkg->{call} to $call" if exists $pkg->{call} && $call ne $pkg->{call}; $pkg->{call} = $call; $ref = $conns{$call} = $pkg; - dbg('connll', "Connection $call stored"); + dbg('connll', "Connection $pkg->{cnum} $call stored"); } else { $ref = $conns{$call}; } @@ -134,9 +134,9 @@ sub pid_gone my ($pkg, $pid) = @_; my @pid = grep {$_->{pid} == $pid} values %conns; - for (@pid) { - &{$_->{eproc}}($_, "$pid has gorn") if exists $_->{eproc}; - $_->disconnect; + foreach my $p (@pid) { + &{$p->{eproc}}($p, "$pid has gorn") if exists $p->{eproc}; + $p->disconnect; } } @@ -194,7 +194,7 @@ sub disconnect { delete $conns{$call} if $ref && $ref == $conn; } $call ||= 'unallocated'; - dbg('connll', "Connection $call disconnected"); + dbg('connll', "Connection $conn->{cnum} $call disconnected"); unless ($main::is_win) { kill 'TERM', $conn->{pid} if exists $conn->{pid}; @@ -436,8 +436,8 @@ sub close_server # close all clients (this is for forking really) sub close_all_clients { - for (values %conns) { - $_->disconnect; + foreach my $conn (values %conns) { + $conn->disconnect; } } @@ -522,7 +522,9 @@ sub DESTROY { my $conn = shift; my $call = $conn->{call} || 'unallocated'; - dbg('connll', "Connection $call being destroyed ($noconns)"); + my $host = $conn->{peerhost} || ''; + my $port = $conn->{peerport} || ''; + dbg('connll', "Connection $conn->{cnum} $call [$host $port] being destroyed"); $noconns--; }