X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXProt.pm;h=6bdb85cf617d08be72d155af7911c572544b3474;hb=07b08c6f048732431ae45b34463387f17d68b823;hp=42eb6b86731395c8a7f7bc108016b225f41a44d2;hpb=b0375778a3330147c3cee881856f9328a8541966;p=spider.git diff --git a/perl/DXProt.pm b/perl/DXProt.pm index 42eb6b86..6bdb85cf 100644 --- a/perl/DXProt.pm +++ b/perl/DXProt.pm @@ -236,13 +236,10 @@ sub start # send initialisation string unless ($self->{outbound}) { -# $self->send(pc38()) if DXNode->get_all(); $self->send(pc18()); $self->{lastping} = $main::systime; } else { - # remove from outstanding connects queue - @main::outstanding_connects = grep {$_->{call} ne $call} @main::outstanding_connects; - $self->{lastping} = $main::systime + $self->pingint / 2; + $self->{lastping} = $main::systime + ($self->pingint / 2); } $self->state('init'); $self->pc50_t(time); @@ -1147,42 +1144,6 @@ sub process # # finish up a pc context # -sub finish -{ - my $self = shift; - my $call = $self->call; - my $conn = shift; - 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 - my @gonenodes = map { $_->dxchan == $self ? $_ : () } DXNode::get_all(); - my $node; - - foreach $node (@gonenodes) { - next if $node->call eq $call; - 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"); - $ref->del() if $ref; -} # # some active measures @@ -1517,6 +1478,8 @@ sub broadcast_ak1a # send it if it isn't the except list and isn't isolated and still has a hop count foreach $dxchan (@dxchan) { next if grep $dxchan == $_, @except; + next if $dxchan == $me; + my $routeit = adjust_hops($dxchan, $s); # adjust its hop count by node name $dxchan->send($routeit) unless $dxchan->{isolate} || !$routeit; } @@ -1534,6 +1497,8 @@ sub broadcast_all_ak1a # send it if it isn't the except list and isn't isolated and still has a hop count foreach $dxchan (@dxchan) { next if grep $dxchan == $_, @except; + next if $dxchan == $me; + my $routeit = adjust_hops($dxchan, $s); # adjust its hop count by node name $dxchan->send($routeit); } @@ -1568,6 +1533,7 @@ sub broadcast_list foreach $dxchan (@_) { my $filter = 1; + next if $dxchan == $me; if ($sort eq 'dx') { next unless $dxchan->{dx}; @@ -1684,11 +1650,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; }