X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXProt.pm;h=b0e7b969edf2b07fd05100e77b8be5b658b325e6;hb=3b3b52396a19281c24481f0fcf7d216f426f94d9;hp=a7ef30c2831a5d7e76665f079ad26b6dae6b7317;hpb=5d2f2feddd2c756e43868f62f72b3c5033c3d3a7;p=spider.git diff --git a/perl/DXProt.pm b/perl/DXProt.pm index a7ef30c2..b0e7b969 100644 --- a/perl/DXProt.pm +++ b/perl/DXProt.pm @@ -565,6 +565,8 @@ sub normal # queue up any messages (look for privates only) DXMsg::queue_msg(1) if $self->state eq 'normal'; +# broadcast_route($line, $self, $field[1]); +# return; last SWITCH; } @@ -613,6 +615,8 @@ sub normal dbg('chan', "PCPROT: $field[1] not known" ); return; } +# broadcast_route($line, $self, $field[2]); +# return; last SWITCH; } @@ -731,6 +735,8 @@ sub normal dbg('chan', "PCPROT: I WILL _NOT_ be disconnected!"); return; } +# broadcast_route($line, $self, $call); +# return; last SWITCH; } @@ -1144,42 +1150,43 @@ sub process # # finish up a pc context # -sub finish + +# +# some active measures +# +sub send_route { my $self = shift; - my $call = $self->call; - my $ref = DXCluster->get_exact($call); - - # unbusy and stop and outgoing mail - 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 - foreach my $node (grep { $_->dxchan == $self } DXNode::get_all) { - next if $node->call eq $call; - next if $node->call eq $main::mycall; - broadcast_ak1a(pc21($node->call, 'Gone.'), $self) unless $self->{isolate}; - } - - # remove outstanding pings - delete $pings{$call}; + my $line = shift; + my @dxchan = DXChannel::get_all_nodes(); + my $dxchan; - # now broadcast to all other ak1a nodes that I have gone - broadcast_ak1a(pc21($call, 'Gone.'), $self) unless $self->{isolate}; - - # I was the last node visited - $self->user->node($main::mycall); - - # send info to all logged in thingies - $self->tell_login('logoutn'); + # send it if it isn't the except list and isn't isolated and still has a hop count + # taking into account filtering and so on + foreach $dxchan (@dxchan) { + my $routeit; + my ($filter, $hops); - Log('DXProt', $call . " Disconnected"); - $ref->del() if $ref; + if ($dxchan->{routefilter}) { + ($filter, $hops) = $dxchan->{routefilter}->it($self->{call}, @_); + next unless $filter; + } + next if $dxchan == $self; + if ($hops) { + $routeit = $line; + $routeit =~ s/\^H\d+\^\~$/\^H$hops\^\~/; + } else { + $routeit = adjust_hops($dxchan, $line); # adjust its hop count by node name + next unless $routeit; + } + if ($filter) { + $dxchan->send($routeit) if $routeit; + } else { + $dxchan->send($routeit) unless $dxchan->{isolate} || $self->{isolate}; + } + } } -# -# some active measures -# sub send_dx_spot { my $self = shift; @@ -1682,11 +1689,38 @@ sub disconnect { my $self = shift; my $nopc39 = shift; + my $call = $self->call; - if ($self->{conn} && !$nopc39) { + unless ($nopc39) { $self->send_now("D", DXProt::pc39($main::mycall, $self->msg('disc1', "System Op"))); } + # unbusy and stop and outgoing mail + 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 + foreach my $node (grep { $_->dxchan == $self } DXNode::get_all) { +# next if $node->call eq $call; + next if $node->call eq $main::mycall; + broadcast_ak1a(pc21($node->call, 'Gone.'), $self) unless $self->{isolate}; + $node->del; + } + + # remove outstanding pings + delete $pings{$call}; + + # now broadcast to all other ak1a nodes that I have gone + broadcast_ak1a(pc21($call, 'Gone.'), $self) unless $self->{isolate}; + + # I was the last node visited + $self->user->node($main::mycall); + + # send info to all logged in thingies + $self->tell_login('logoutn'); + + Log('DXProt', $call . " Disconnected"); + $self->SUPER::disconnect; }