X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXXml%2FPing.pm;h=1e7aea6fb85d219be60ee3fceadf87313256043b;hb=17dd4968e05851f152c4bfbfae4df928c1228b2e;hp=a1b0a6a122ba6e3a8a792ef69d819c4216b9ecb0;hpb=7ed0b26aa8f65327d111e16b176316e823000e9d;p=spider.git diff --git a/perl/DXXml/Ping.pm b/perl/DXXml/Ping.pm index a1b0a6a1..1e7aea6f 100644 --- a/perl/DXXml/Ping.pm +++ b/perl/DXXml/Ping.pm @@ -30,6 +30,20 @@ sub handle_input my $self = shift; my $dxchan = shift; + if ($self->{to} eq $main::mycall) { + if ($self->{s} eq '1') { + my $rep = DXXml::Ping->new(to=>$self->{o}, + s=>'0', + oid=>$self->{id}, + ot=>$self->{t} + ); + $dxchan->send($rep->toxml); + } else { + handle_ping_reply($dxchan, $self->{o}, $self->{ot}, $self->{oid}); + } + } else { + $self->route($dxchan); + } } sub topcxx @@ -49,7 +63,7 @@ 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; @@ -68,6 +82,8 @@ sub handle_ping_reply { my $fromdxchan = shift; my $from = shift; + my $ot = shift; + my $oid = shift; my $fromxml; if (ref $from) { @@ -82,7 +98,7 @@ 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) {