X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXProt.pm;h=bc753c3d784e6b053a5d67d147a8807d7ef6f855;hb=64d7fcd04e89143f23455c5aae3cc4e410700870;hp=0ca491ea24c49842c18612c66fa3914579001ea2;hpb=c6552c92e3a9e3741b68305bfc43124020b57c19;p=spider.git diff --git a/perl/DXProt.pm b/perl/DXProt.pm index 0ca491ea..bc753c3d 100644 --- a/perl/DXProt.pm +++ b/perl/DXProt.pm @@ -823,13 +823,13 @@ sub send_local_config my $node; my @rawintcalls = map { $_->nodes } @localnodes if @localnodes; my @intcalls; - for $node (@rawintcalls) { - push @intcalls, $node unless grep $node eq $_, @intcalls; + foreach $node (@rawintcalls) { + push @intcalls, $node if grep $_ && $node != $_, @intcalls; } my $ref = Route::Node::get($self->{call}); my @rnodes = $ref->nodes; - for $node (@intcalls) { - push @remotenodes, Route::Node::get($node) unless grep $node eq $_, @rnodes, @remotenodes; + foreach $node (@intcalls) { + push @remotenodes, Route::Node::get($node) if grep $_ && $node != $_, @rnodes, @remotenodes; } $self->send_route($main::mycall, \&pc19, scalar(@remotenodes), @remotenodes); } @@ -893,6 +893,10 @@ sub broadcast_pc92_update dbg("ROUTE: broadcast_pc92_update $call") if isdbg('obscount'); my $nref = Route::Node::get($call); + unless ($nref) { + dbg("ERROR: broadcast_pc92_update - Route::Node $call disappeared"); + return; + } my $l = $nref->last_PC92C(gen_my_pc92_config($nref)); $main::me->broadcast_route_pc9x($main::mycall, undef, $l, 0); $self->update_pc92_next($pc92_update_period); @@ -1144,16 +1148,6 @@ sub disconnect # do routing stuff, remove me from routing table my $node = Route::Node::get($call); - my @rout; - if ($node) { - @rout = $node->del($main::routeroot); - - # and all my ephemera as well - for (@rout) { - my $c = $_->call; - eph_del_regex("^PC1[679].*$c"); - } - } RouteDB::delete_interface($call); @@ -1161,12 +1155,6 @@ sub disconnect my $mref = DXMsg::get_busy($call); $mref->stop_msg($call) if $mref; - # broadcast to all other nodes that all the nodes connected to via me are gone - unless ($pc39flag && $pc39flag == 2) { - $self->route_pc21($main::mycall, undef, @rout) if @rout; - $self->route_pc92d($main::mycall, undef, $main::routeroot, $node) if $node; - } - # remove outstanding pings delete $pings{$call}; @@ -1179,6 +1167,43 @@ sub disconnect Log('DXProt', $call . " Disconnected"); $self->SUPER::disconnect; + + # here we determine what needs to go out of the routing table + my @rout; + if ($node) { + dbg('%Route::Node::List = ' . join(',', sort keys %Route::Node::list)) if isdbg('routedisc'); + + @rout = $node->del($main::routeroot); + + dbg('@rout = ' . join(',', sort map {$_->call} @rout)) if isdbg('routedisc'); + + # now we need to see what can't be routed anymore and came + # in via this node (probably). + my $n = 0; + while ($n != @rout) { + $n = @rout; + for (Route::Node::get_all()) { + unless ($_->dxchan) { + push @rout, $_->delete; + } + } + dbg('@rout = ' . join(',', sort map {$_->call} @rout)) if isdbg('routedisc'); + } + + dbg('%Route::Node::List = ' . join(',', sort keys %Route::Node::list)) if isdbg('routedisc'); + + # and all my ephemera as well + for (@rout) { + my $c = $_->call; + eph_del_regex("^PC1[679].*$c"); + } + } + + # broadcast to all other nodes that all the nodes connected to via me are gone + unless ($pc39flag && $pc39flag == 2) { + $self->route_pc21($main::mycall, undef, @rout) if @rout; + $self->route_pc92d($main::mycall, undef, $main::routeroot, $node) if $node; + } } @@ -1213,6 +1238,12 @@ sub send_route for (; @_ && $no; $no--) { my $r = shift; + # don't send messages with $self's call in back to them + if ($r->call eq $self->{call}) { + dbg("PCPROT: trying to send $self->{call} back itself") if isdbg('chanerr'); + next; + } + if (!$self->{isolate} && $self->{routefilter}) { $filter = undef; if ($r) { @@ -1289,8 +1320,9 @@ sub broadcast_route_nopc9x next if $origin eq $dxchan->{call}; # don't route some from this call back again. next unless $dxchan->isa('DXProt'); next if $dxchan->{do_pc9x}; - next if ($generate == \&pc16 || $generate==\&pc17) && !$dxchan->user->wantsendpc16; - + if ($generate == \&pc16 || $generate==\&pc17) { + next unless $dxchan->user->wantsendpc16; + } $dxchan->send_route($origin, $generate, @_); } } @@ -1541,7 +1573,7 @@ sub import_chat Log('ann', $target, $main::mycall, $text); $main::me->normal(DXProt::pc93($target, $main::mycall, $via, $text)); } else { - $main::me->send_chats($target, $text); + DXCommandmode::send_chats($main::me, $target, $text); } } }