X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXXml%2FPing.pm;h=6088a4628b92756d946bfe4eac2c8398e2592974;hb=b33cb7a3d3842fabb787105b89aa1094bf5372e0;hp=04f830d1b534a8d701a32289a0b5d19c2db2ba29;hpb=9f4c467f60ec71c0bbb2b27f91ca7d86a40b4597;p=spider.git diff --git a/perl/DXXml/Ping.pm b/perl/DXXml/Ping.pm index 04f830d1..6088a462 100644 --- a/perl/DXXml/Ping.pm +++ b/perl/DXXml/Ping.pm @@ -14,6 +14,7 @@ use DXDebug; use DXProt; use IsoTime; use Time::HiRes qw(gettimeofday tv_interval); +use Route::Node; use vars qw(@ISA %pings); @ISA = qw(DXXml); @@ -67,10 +68,10 @@ sub add push @$ref, $self; $pings{$to} = $ref; - my $u = DXUser->get_current($to); + my $u = DXUser::get_current($to); if ($u) { $u->lastping(($via || $from), $main::systime); - $u->put; + $u->put unless $dxchan->{_nospawn}; } } @@ -115,6 +116,12 @@ sub handle_ping_reply $tochan->{pingave} = $tochan->{pingave} + (($t - $tochan->{pingave}) / 6); } $tochan->{nopings} = $nopings; # pump up the timer + dbg("ROUTE: $tochan->{call} ping obscount reset to $tochan->{nopings}") if isdbg('obscount'); + my $nref = Route::Node::get($tochan->{call}); + if ($nref) { + my $n = $nref->reset_obs; + dbg("ROUTE: reset obscount on $tochan->{call} to $n (ping)") if isdbg('obscount'); + } } _handle_believe($from, $fromdxchan->{call}); } @@ -129,11 +136,12 @@ sub handle_ping_reply sub _handle_believe { my ($from, $via) = @_; - - my $user = DXUser->get_current($from); + + my $dxchan = DXChannel::get($from); + my $user = $dxchan->user || DXUser::get($from); if ($user) { $user->set_believe($via); - $user->put; + $user->put unless $dxchan->{_nospawn}; } } 1;