X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXXml%2FPing.pm;h=21662dae5a7a009a885c466d46e4c3dc2e19025f;hb=6d1745603b0d1bb463194999129713c978f4244f;hp=a9d72083c213df926ef80157c83453973ac9c7fe;hpb=7574ad49911d0cbe7711257025a13b9b273b7b93;p=spider.git diff --git a/perl/DXXml/Ping.pm b/perl/DXXml/Ping.pm index a9d72083..21662dae 100644 --- a/perl/DXXml/Ping.pm +++ b/perl/DXXml/Ping.pm @@ -37,6 +37,7 @@ sub handle_input oid=>$self->{id}, ot=>$self->{t} ); + $dxchan->send($rep->toxml); } else { handle_ping_reply($dxchan, $self->{o}, $self->{ot}, $self->{oid}); } @@ -62,10 +63,9 @@ sub add my $ref = $pings{$to} || []; my $r = {}; my $self = DXXml::Ping->new(to=>$to, '-hirestime'=>[ gettimeofday ], s=>'1'); - $self->{u} = $from unless $from eq $main::mycall; + $self->{u} = $from; $self->{'-via'} = $via if $via && DXChannel::get($via); $self->{o} = $main::mycall; - $self->{id} = $self->nextid; $self->route($dxchan); push @$ref, $self; @@ -97,14 +97,10 @@ sub handle_ping_reply my $tochan = DXChannel::get($from); while (@$ref) { my $r = shift @$ref; - my $dxchan = DXChannel::get($r->{to}); + my $dxchan = DXChannel::get($r->{u}); next unless $dxchan; my $t = tv_interval($r->{'-hirestime'}, [ gettimeofday ]); - if ($dxchan->is_user) { - my $s = sprintf "%.2f", $t; - my $ave = sprintf "%.2f", $tochan ? ($tochan->{pingave} || $t) : $t; - $dxchan->send($dxchan->msg('pingi', $from, $s, $ave)) - } elsif ($dxchan->is_node) { + if ($dxchan->is_node) { if ($tochan) { my $nopings = $tochan->user->nopings || $DXProt::obscount; push @{$tochan->{pingtime}}, $t; @@ -126,11 +122,16 @@ sub handle_ping_reply $ivp->handle_ping; } } elsif (my $rref = Route::Node::get($r->{to})) { - if (my $ivp = Investigate::get($from, $fromdxchan->{to})) { + if (my $ivp = Investigate::get($from, $fromdxchan->{call})) { $ivp->handle_ping; } } - } + } + if ($dxchan->is_user) { + my $s = sprintf "%.2f", $t; + my $ave = sprintf "%.2f", $tochan ? ($tochan->{pingave} || $t) : $t; + $dxchan->send($dxchan->msg('pingi', $from, $s, $ave)) + } } }