#
# Copyright (c) 1998 Dirk Koopman G1TLH
#
-# $Id$
-#
+#
+#
package DXProt;
$investigation_int $pc19_version $myprot_version
%nodehops $baddx $badspotter $badnode $censorpc $rspfcheck
$allowzero $decode_dk0wcy $send_opernam @checklist
- $eph_pc15_restime $pc92_update_period $last_pc92_update
- %pc92_find $pc92_find_timeout
+ $eph_pc15_restime $pc92_update_period $pc92_obs_timeout
+ %pc92_find $pc92_find_timeout $pc92_short_update_period
);
$pc11_max_age = 1*3600; # the maximum age for an incoming 'real-time' pc11
$chatimportfn = "$main::root/chat_import";
$investigation_int = 12*60*60; # time between checks to see if we can see this node
$pc19_version = 5466; # the visible version no for outgoing PC19s generated from pc59
-$pc92_update_period = 30*60; # the period between PC92 C updates
-$last_pc92_update = time + int rand(180); # the last time a PC92 config update
+$pc92_update_period = 60*60; # the period between PC92 C updates
+$pc92_short_update_period = 15*60; # shorten the update period after a connection
%pc92_find = (); # outstanding pc92 find operations
$pc92_find_timeout = 30; # maximum time to wait for a reply
+$pc92_obs_timeout = $pc92_update_period; # the time between obscount countdowns
-@checklist =
+@checklist =
(
[ qw(i c c m bp bc c) ], # pc10
[ qw(i f m d t m c c h) ], # pc11
[ qw(i c bm m bm bm p h) ], # pc12
- [ qw(i c h) ], #
- [ qw(i c h) ], #
- [ qw(i c m h) ], #
+ [ qw(i c h) ], #
+ [ qw(i c h) ], #
+ [ qw(i c m h) ], #
undef , # pc16 has to be validated manually
[ qw(i c c h) ], # pc17
[ qw(i m n) ], # pc18
{
my $n = shift;
$n -= 10;
- return 0 if $n < 0 || $n > @checklist;
+ return 0 if $n < 0 || $n > @checklist;
my $ref = $checklist[$n];
return 0 unless ref $ref;
-
+
my $i;
for ($i = 1; $i < @$ref; $i++) {
my ($blank, $act) = $$ref[$i] =~ /^(b?)(\w)$/;
next if $blank && $_[$i] =~ /^[ \*]$/;
if ($act eq 'c') {
return $i unless is_callsign($_[$i]);
- } elsif ($act eq 'i') {
+ } elsif ($act eq 'i') {
; # do nothing
} elsif ($act eq 'm') {
return $i unless is_pctext($_[$i]);
return $i unless $_[$i] =~ /^\s*\d+-\w\w\w-[12][90]\d\d$/;
} elsif ($act eq 't') {
return $i unless $_[$i] =~ /^[012]\d[012345]\dZ$/;
- }
+ }
}
return 0;
}
+sub update_pc92_next
+{
+ my $self = shift;
+ my $period = shift || $pc92_update_period;
+ $self->{next_pc92_update} = $main::systime + $period - int rand($period / 4);
+}
+
sub init
{
do "$main::data/hop_table.pl" if -e "$main::data/hop_table.pl";
my $user = DXUser->get($main::mycall);
die "User $main::mycall not setup or disappeared RTFM" unless $user;
-
+
$myprot_version += $main::version*100;
- $main::me = DXProt->new($main::mycall, 0, $user);
+ $main::me = DXProt->new($main::mycall, 0, $user);
$main::me->{here} = 1;
$main::me->{state} = "indifferent";
$main::me->{sort} = 'S'; # S for spider
$main::me->{pingave} = 0;
$main::me->{registered} = 1;
$main::me->{version} = $main::version;
- $main::me->{build} = $main::build;
+ $main::me->{build} = "$main::subversion.$main::build";
$main::me->{do_pc9x} = 1;
+ $main::me->update_pc92_next($pc92_update_period);
}
#
# obtain a new connection this is derived from dxchannel
#
-sub new
+sub new
{
my $self = DXChannel::alloc(@_);
$host ||= "unknown";
Log('DXProt', "$call connected from $host");
-
+
# remember type of connection
$self->{consort} = $line;
$self->{outbound} = $sort eq 'O';
$self->{inwcyfilter} = Filter::read_in('wcy', $call, 1) || Filter::read_in('wcy', 'node_default', 1);
$self->{inannfilter} = Filter::read_in('ann', $call, 1) || Filter::read_in('ann', 'node_default', 1);
$self->{inroutefilter} = Filter::read_in('route', $call, 1) || Filter::read_in('route', 'node_default', 1) unless $self->{isolate};
-
+ # if there is no route input filter then specify a default one.
+ # obviously this can be changed later by the sysop.
+ if (!$self->{inroutefilter}) {
+ my $dxcc = $self->dxcc;
+ $Route::filterdef->cmd($self, 'route', 'accept', "input by_dxcc $dxcc" );
+ }
+
# set unbuffered and no echo
$self->send_now('B',"0");
$self->send_now('E',"0");
$self->conn->echo(0) if $self->conn->can('echo');
-
+
# ping neighbour node stuff
my $ping = $user->pingint;
$ping = $pingint unless defined $ping;
$self->{pingave} = 999;
$self->{metric} ||= 100;
$self->{lastping} = $main::systime;
-
+
# send initialisation string
unless ($self->{outbound}) {
$self->sendinit;
}
-
+
$self->state('init');
$self->{pc50_t} = $main::systime;
# run a script send the output to the debug file
my $script = new Script(lc $call) || new Script('node_default');
$script->run($self) if $script;
+
+ # set next_pc92_update time for this node sooner
+ $self->update_pc92_next($pc92_short_update_period);
}
#
sub sendinit
{
my $self = shift;
- $self->send(pc18());
+ $self->send(pc18(($self->{isolate} || !$self->user->wantpc9x) ? "" : " pc9x"));
}
#
my @field = split /\^/, $line;
return unless @field;
-
+
pop @field if $field[-1] eq '~';
-
+
# print join(',', @field), "\n";
-
-
+
+
# process PC frames, this will fail unless the frame starts PCnn
my ($pcno) = $field[0] =~ /^PC(\d\d)/; # just get the number
unless (defined $pcno && $pcno >= 10 && $pcno <= 99) {
my @dxchan = DXChannel::get_all();
my $dxchan;
my $pc50s;
-
+
# send out a pc50 on EVERY channel all at once
if ($t >= $last_pc50 + $DXProt::pc50_interval) {
$pc50s = pc50($main::me, scalar DXChannel::get_all_users);
# send the pc50
$dxchan->send($pc50s) if $pc50s;
-
+
# send a ping out on this channel
if ($dxchan->{pingint} && $t >= $dxchan->{pingint} + $dxchan->{lastping}) {
if ($dxchan->{nopings} <= 0) {
$dxchan->{lastping} += $dxchan->{pingint} / 2 unless @{$dxchan->{pingtime}};
}
}
+
}
Investigate::process();
clean_pc92_find();
# every ten seconds
- if ($t - $last10 >= 10) {
- # clean out ephemera
+ if ($t - $last10 >= 10) {
+ # clean out ephemera
eph_clean();
import_chat();
- if ($main::systime >= $last_pc92_update + $pc92_update_period) {
- dbg("ROUTE: sending pc92 update") if isdbg('route');
- send_pc92_update();
+ if ($main::systime >= $pc92_obs_timeout) {
time_out_pc92_routes();
- $last_pc92_update = $main::systime + int rand(5*60);
+ $pc92_obs_timeout = $main::systime + $pc92_update_period;
}
-
+
$last10 = $t;
+
+ # send out config broadcasts
+ foreach $dxchan (@dxchan) {
+ next unless $dxchan->is_node;
+
+ # send out a PC92 config record if required for me and
+ # all my non pc9x dependent nodes.
+ if ($main::systime >= $dxchan->{next_pc92_update}) {
+ if ($dxchan->{call} eq $main::mycall || !$dxchan->{do_pc9x}) {
+ $dxchan->broadcast_pc92_update($dxchan->{call});
+ }
+ }
+ }
}
-
+
if ($main::systime - 3600 > $last_hour) {
$last_hour = $main::systime;
}
my $line = shift;
my @dxchan = DXChannel::get_all();
my $dxchan;
-
+
# 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 $line = shift;
my $isolate = shift;
my ($filter, $hops);
-
+
if ($self->{wwvfilter}) {
($filter, $hops) = $self->{wwvfilter}->it(@_[7..$#_]);
return unless $filter;
my @dxchan = DXChannel::get_all();
my $dxchan;
my @dxcc = ((Prefix::cty_data($_[10]))[0..2], (Prefix::cty_data($_[11]))[0..2]);
-
+
# 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 $target = $_[6];
my $to = 'To ';
my $text = unpad($_[2]);
-
+ my $from = $_[0];
+
if ($_[3] eq '*') { # sysops
$target = "SYSOP";
} elsif ($_[3] gt ' ') { # speciality list handling
- my ($name) = split /\./, $_[3];
- $target = "$name"; # put the rest in later (if bothered)
- }
-
+ my ($name) = split /\./, $_[3];
+ $target = "$name"; # put the rest in later (if bothered)
+ }
+
if ($_[5] eq '1') {
- $target = "WX";
+ $target = "WX";
$to = '';
}
$target = "ALL" if !$target;
- # obtain country codes etc
- my @a = Prefix::cty_data($_[0]);
+ # obtain country codes etc
+ my @a = Prefix::cty_data($from);
my @b = Prefix::cty_data($_[4]);
if ($self->{inannfilter}) {
- my ($filter, $hops) =
- $self->{inannfilter}->it(@_, $self->{call},
+ my ($filter, $hops) =
+ $self->{inannfilter}->it(@_, $self->{call},
@a[0..2],
@b[0..2], $a[3], $b[3]);
unless ($filter) {
}
}
- if (AnnTalk::dup($_[0], $_[1], $_[2])) {
- dbg("PCPROT: Duplicate Announce ignored") if isdbg('chanerr');
- return;
+ if (AnnTalk::dup($from, $_[1], $_[2])) {
+ my $dxchan = DXChannel::get($from);
+ if ($dxchan && $dxchan->is_user) {
+ if ($dxchan->priv < 5) {
+ $dxchan->send($dxchan->msg('dup'));
+ return;
+ }
+ } else {
+ dbg("PCPROT: Duplicate Announce ignored") if isdbg('chanerr');
+ return;
+ }
}
- Log('ann', $target, $_[0], $text);
+ Log('ann', $target, $from, $text);
# 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
my $target = $_[3];
my $text = unpad($_[2]);
my $ak1a_line;
-
+ my $from = $_[0];
+
# munge the group and recast the line if required
if ($target =~ s/\.LST$//) {
$ak1a_line = $line;
}
-
- # obtain country codes etc
- my @a = Prefix::cty_data($_[0]);
+
+ # obtain country codes etc
+ my @a = Prefix::cty_data($from);
my @b = Prefix::cty_data($_[4]);
if ($self->{inannfilter}) {
- my ($filter, $hops) =
- $self->{inannfilter}->it(@_, $self->{call},
+ my ($filter, $hops) =
+ $self->{inannfilter}->it(@_, $self->{call},
@a[0..2],
@b[0..2], $a[3], $b[3]);
unless ($filter) {
}
}
- if (AnnTalk::dup($_[0], $_[1], $_[2], $chatdupeage)) {
- dbg("PCPROT: Duplicate Announce ignored") if isdbg('chanerr');
- return;
+ if (AnnTalk::dup($from, $target, $_[2], $chatdupeage)) {
+ my $dxchan = DXChannel::get($from);
+ if ($dxchan && $dxchan->is_user) {
+ if ($dxchan->priv < 5) {
+ $dxchan->send($dxchan->msg('dup'));
+ return;
+ }
+ } else {
+ dbg("PCPROT: Duplicate Announce ignored") if isdbg('chanerr');
+ return;
+ }
}
- Log('chat', $target, $_[0], $text);
+ Log('chat', $target, $from, $text);
# 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 $is_ak1a = $dxchan->is_ak1a;
-
+
if ($dxchan->is_node) {
next if $dxchan == $main::me;
next if $dxchan == $self;
$ak1a_line = pc12($_[0], $text, $_[1], "$target.LST");
}
}
-
- $dxchan->chat($is_ak1a ? $ak1a_line : $line, $self->{isolate}, $target, $_[1],
+
+ $dxchan->chat($is_ak1a ? $ak1a_line : $line, $self->{isolate}, $target, $_[1],
$text, @_, $self->{call}, @a[0..2], @b[0..2]);
}
}
dbg('DXProt::send_local_config') if isdbg('trace');
# send our nodes
- if ($self->{do_pc9x}) {
- $self->send_pc92_config;
+ my $node;
+ my @nodes;
+ my @localnodes;
+ my @remotenodes;
+
+ if ($self->{isolate}) {
+ dbg("send_local_config: isolated");
+ @localnodes = ( $main::routeroot );
+ $self->send_route($main::mycall, \&pc19, 1, $main::routeroot);
+ } elsif ($self->{do_pc9x}) {
+ dbg("send_local_config: doing pc9x");
+ my $node = Route::Node::get($self->{call});
+ $self->send_last_pc92_config($main::routeroot);
+ $self->send(pc92a($main::routeroot, $node)) unless $main::routeroot->last_PC92C =~ /$self->{call}/;
} else {
- my $node;
- my @nodes;
- my @localnodes;
- my @remotenodes;
+ # create a list of all the nodes that are not connected to this connection
+ # and are not themselves isolated, this to make sure that isolated nodes
+ # don't appear outside of this node
- if ($self->{isolate}) {
- @localnodes = ( $main::routeroot );
- $self->send_route($main::mycall, \&pc19, 1, $main::routeroot);
- } else {
- # create a list of all the nodes that are not connected to this connection
- # and are not themselves isolated, this to make sure that isolated nodes
- # don't appear outside of this node
-
- # send locally connected nodes
- my @dxchan = grep { $_->call ne $main::mycall && $_ != $self && !$_->{isolate} } DXChannel::get_all_nodes();
- @localnodes = map { my $r = Route::Node::get($_->{call}); $r ? $r : () } @dxchan if @dxchan;
- $self->send_route($main::mycall, \&pc19, scalar(@localnodes)+1, $main::routeroot, @localnodes);
-
- my $node;
- my @rawintcalls = map { $_->nodes } @localnodes if @localnodes;
- my @intcalls;
- for $node (@rawintcalls) {
- push @intcalls, $node unless grep $node eq $_, @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;
- }
- $self->send_route($main::mycall, \&pc19, scalar(@remotenodes), @remotenodes);
+ dbg("send_local_config: traditional");
+
+ # send locally connected nodes
+ my @dxchan = grep { $_->call ne $main::mycall && $_ != $self && !$_->{isolate} } DXChannel::get_all_nodes();
+ @localnodes = map { my $r = Route::Node::get($_->{call}); $r ? $r : () } @dxchan if @dxchan;
+ $self->send_route($main::mycall, \&pc19, scalar(@localnodes)+1, $main::routeroot, @localnodes);
+
+ my $node;
+ my @rawintcalls = map { $_->nodes } @localnodes if @localnodes;
+ my @intcalls;
+ for $node (@rawintcalls) {
+ push @intcalls, $node unless grep $node eq $_, @intcalls;
}
-
- # get all the users connected on the above nodes and send them out
+ 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;
+ }
+ $self->send_route($main::mycall, \&pc19, scalar(@remotenodes), @remotenodes);
+ }
+
+ # get all the users connected on the above nodes and send them out
+ unless ($self->{do_pc9x}) {
foreach $node ($main::routeroot, @localnodes, @remotenodes) {
if ($node) {
my @rout = map {my $r = Route::User::get($_); $r ? ($r) : ()} $node->users;
sub gen_my_pc92_config
{
my $node = shift;
-
+
if ($node->{call} eq $main::mycall) {
my @dxchan = grep { $_->call ne $main::mycall && !$_->{isolate} } DXChannel::get_all();
dbg("ROUTE: all dxchan: " . join(',', map{$_->{call}} @dxchan)) if isdbg('routelow');
}
}
-sub gen_pc92_update
+sub send_last_pc92_config
{
my $self = shift;
- my $with_pc92_nodes = shift;
- my $node;
- my @lines;
- my @dxchan;
- my @localnodes;
-
- dbg('ROUTE: DXProt::gen_pc92_update start') if isdbg('routelow');
-
- # send 'my' configuration for all channels
- push @lines, gen_my_pc92_config($main::routeroot);
-
- if ($with_pc92_nodes) {
- # send out the configuration of all the directly connected PC92 nodes with current configuration
- # but with the dates that the last config came in with.
- @dxchan = grep { $_->call ne $main::mycall && $_ != $self && !$_->{isolate} && $_->{do_pc9x} } DXChannel::get_all_nodes();
- dbg("ROUTE: pc92 dxchan: " . join(',', map{$_->{call}} @dxchan)) if isdbg('routelow');
- @localnodes = map { my $r = Route::Node::get($_->{call}); $r ? $r : () } @dxchan;
- dbg("ROUTE: pc92 localnodes: " . join(',', map{$_->{call}} @localnodes)) if isdbg('routelow');
- foreach $node (@localnodes) {
- if ($node && $node->lastid->{92}) {
- my @rout = map {my $r = Route::get($_); $r ? ($r) : ()} $node->nodes, $node->users;
- push @lines, gen_pc92_with_time($node->call, 'C', $node->lastid->{92}, @rout);
- }
- }
+ my $node = shift;
+ if (my $l = $node->last_PC92C) {
+ $self->send($l);
+ } else {
+ $self->send_pc92_config($node);
}
-
- # send the configuration of all the directly connected 'external' nodes that don't handle PC92
- # out with the 'external' marker on the first node.
- @dxchan = grep { $_->call ne $main::mycall && $_ != $self && !$_->{isolate} && !$_->{do_pc9x} } DXChannel::get_all_nodes();
- dbg("ROUTE: non pc92 dxchan: " . join(',', map{$_->{call}} @dxchan)) if isdbg('routelow');
- @localnodes = map { my $r = Route::Node::get($_->{call}); $r ? $r : () } @dxchan;
- dbg("ROUTE: non pc92 localnodes: " . join(',', map{$_->{call}} @localnodes)) if isdbg('routelow');
- foreach $node (@localnodes) {
- if ($node) {
- push @lines, gen_my_pc92_config($node);
- }
- }
-
- dbg('ROUTE: DXProt::gen_pc92_update end with ' . scalar @lines . ' lines') if isdbg('routelow');
- return @lines;
}
-
sub send_pc92_config
{
my $self = shift;
+ my $node = shift;
dbg('DXProt::send_pc92_config') if isdbg('trace');
- my @out = $self->gen_pc92_update(1);
-
- # send the complete config out on this interface
- for (@out) {
- $self->send($_);
- }
-}
+ $node->last_PC92C(gen_my_pc92_config($node));
+ $self->send($node->last_PC92C);
+}
-sub send_pc92_update
+sub broadcast_pc92_update
{
- my @out = $main::me->gen_pc92_update(0);
-
- # broadcast the lines to all PC92 nodes
- for (@out) {
- $main::me->broadcast_route_pc9x($main::mycall, undef, $_, 0);
- }
-}
+ my $self = shift;
+ my $call = shift;
+
+ dbg('DXProt::broadcast_pc92_update') if isdbg('trace');
+
+ my $nref = Route::Node::get($call);
+ 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);
+}
sub time_out_pc92_routes
{
my $o = $n->dec_obs;
if ($o <= 0) {
if (my $dxchan = DXChannel::get($n->call)) {
- dbg("ROUTE: disconnecting local pc92 $dxchan->{call} on obscount") if isdbg('route');
+ dbg("disconnecting local pc92 $dxchan->{call} on obscount") if isdbg('obscount');
$dxchan->disconnect;
next;
}
my @parents = map {Route::Node::get($_)} $n->parents;
for (@parents) {
if ($_) {
- dbg("ROUTE: deleting pc92 $_->{call} from $n->{call} on obscount") if isdbg('route');
+ dbg("deleting pc92 $_->{call} from $n->{call} on obscount") if isdbg('obscount');
push @rdel, $n->del($_);
}
}
} else {
- dbg("ROUTE: obscount on $n->{call} now $o") if isdbg('route');
+ dbg("ROUTE: obscount on $n->{call} now $o") if isdbg('obscount');
}
}
for (@rdel) {
}
#
-# obtain the hops from the list for this callsign and pc no
+# obtain the hops from the list for this callsign and pc no
#
sub get_hops
my $pcno = shift;
my $hops = $DXProt::hopcount{$pcno};
$hops = $DXProt::def_hopcount if !$hops;
- return "H$hops";
+ return "H$hops";
}
-#
-# adjust the hop count on a per node basis using the user loadable
+#
+# adjust the hop count on a per node basis using the user loadable
# hop table if available or else decrement an existing one
#
my $s = shift;
my $call = $self->{call};
my $hops;
-
+
if (($hops) = $s =~ /\^H(\d+)\^?~?$/o) {
my ($pcno) = $s =~ /^PC(\d\d)/o;
confess "$call called adjust_hops with '$s'" unless $pcno;
return $s;
}
-#
+#
# load hop tables
#
sub load_hops
$r->{t} = $main::systime;
$r->{cmd} = $cmd;
$rcmds{$to} = $r;
-
+
my $ref = Route::Node::get($to);
my $dxchan = $ref->dxchan;
if ($dxchan && $dxchan->is_clx) {
my $call = $self->call;
return if $self->{disconnecting}++;
-
+
unless ($pc39flag && $pc39flag == 1) {
$self->send_now("D", DXProt::pc39($main::mycall, $self->msg('disc1', "System Op")));
}
my @rout;
if ($node) {
@rout = $node->del($main::routeroot);
-
+
# and all my ephemera as well
for (@rout) {
my $c = $_->call;
}
RouteDB::delete_interface($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
unless ($pc39flag && $pc39flag == 2) {
$self->route_pc21($main::mycall, undef, @rout) if @rout;
# remove outstanding pings
delete $pings{$call};
-
+
# I was the last node visited
$self->user->node($main::mycall);
}
-#
+#
# send a talk message to this thingy
#
sub talk
{
my ($self, $from, $to, $via, $line, $origin) = @_;
-
+
if ($self->{do_pc9x}) {
$self->send(pc93($to, $from, $via, $line));
} else {
$self->send(pc10($from, $to, $via, $line, $origin));
}
- Log('talk', $to, $from, $via?$via:$self->call, $line) unless $origin && $origin ne $main::mycall;
+ Log('talk', $to, $from, '>' . ($via || $origin || $self->call), $line) unless $origin && $origin ne $main::mycall;
}
# send it if it isn't the except list and isn't isolated and still has a hop count
my $self = shift;
my $origin = shift;
my $generate = shift;
- my $no = shift; # the no of things to filter on
+ my $no = shift; # the no of things to filter on
my $routeit;
my ($filter, $hops);
my @rin;
-
+
for (; @_ && $no; $no--) {
my $r = shift;
-
+
if (!$self->{isolate} && $self->{routefilter}) {
$filter = undef;
if ($r) {
if ($filter) {
push @rin, $r;
} else {
- dbg("DXPROT: $self->{call}/" . $r->call . " rejected by output filter") if isdbg('chanerr');
+ dbg("PCPROT: $self->{call}/" . $r->call . " rejected by output filter") if isdbg('filter');
}
} else {
dbg("was sent a null value") if isdbg('chanerr');
$routeit = adjust_hops($self, $line); # adjust its hop count by node name
next unless $routeit;
}
-
+
$self->send($routeit);
}
}
}
+# broadcast everywhere
sub broadcast_route
{
my $self = shift;
}
unless ($self->{isolate}) {
foreach $dxchan (@dxchan) {
- next if $dxchan == $self;
- next if $dxchan == $main::me;
+ next if $dxchan == $self || $dxchan == $main::me;
+ next if $origin eq $dxchan->{call}; # don't route some from this call back again.
+ next unless $dxchan->isa('DXProt');
+
+ $dxchan->send_route($origin, $generate, @_);
+ }
+ }
+}
+
+# broadcast to non-pc9x nodes
+sub broadcast_route_nopc9x
+{
+ my $self = shift;
+ my $origin = shift;
+ my $generate = shift;
+ my $line = shift;
+ my @dxchan = DXChannel::get_all_nodes();
+ my $dxchan;
+
+ if ($line) {
+ $line =~ /\^H(\d+)\^?\~?$/;
+ return unless $1 > 0;
+ }
+ unless ($self->{isolate}) {
+ foreach $dxchan (@dxchan) {
+ next if $dxchan == $self || $dxchan == $main::me;
+ 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;
-
+
$dxchan->send_route($origin, $generate, @_);
}
}
my $self = shift;
return unless $self->{do_pc9x};
-
+
my $origin = shift;
my $generate = shift;
- my $no = shift; # the no of things to filter on
+ my $no = shift; # the no of things to filter on
my $line;
$line = &$generate(@_);
$self->send($line);
}
+# broadcast only to pc9x nodes
sub broadcast_route_pc9x
{
my $self = shift;
if ($origin eq $main::mycall && $generate && !$line) {
$line = &$generate(@_);
- }
+ }
$line =~ /\^H(\d+)\^\~?$/;
unless ($1 > 0 && $self->{isolate}) {
foreach $dxchan (@dxchan) {
next if $dxchan == $self || $dxchan == $main::me;
next if $origin eq $dxchan->{call}; # don't route some from this call back again.
- next unless $dxchan->{do_pc9x};
next unless $dxchan->isa('DXProt');
+ next unless $dxchan->{do_pc9x};
$dxchan->send($line);
}
return unless $self->user->wantpc16;
my $origin = shift;
my $line = shift;
- broadcast_route($self, $origin, \&pc16, $line, 1, @_);
+ broadcast_route_nopc9x($self, $origin, \&pc16, $line, 1, @_);
}
sub route_pc17
return unless $self->user->wantpc16;
my $origin = shift;
my $line = shift;
- broadcast_route($self, $origin, \&pc17, $line, 1, @_);
+ broadcast_route_nopc9x($self, $origin, \&pc17, $line, 1, @_);
}
sub route_pc19
my $self = shift;
my $origin = shift;
my $line = shift;
- broadcast_route($self, $origin, \&pc19, $line, scalar @_, @_);
+ broadcast_route_nopc9x($self, $origin, \&pc19, $line, scalar @_, @_);
}
sub route_pc21
my $self = shift;
my $origin = shift;
my $line = shift;
- broadcast_route($self, $origin, \&pc21, $line, scalar @_, @_);
+ broadcast_route_nopc9x($self, $origin, \&pc21, $line, scalar @_, @_);
}
sub route_pc24
my $self = shift;
my $r = shift;
my ($filter, $hops) = (1, 1);
-
+
if ($self->{inroutefilter}) {
($filter, $hops) = $self->{inroutefilter}->it($self->{call}, $self->{dxcc}, $self->{itu}, $self->{cq}, $r->call, $r->dxcc, $r->itu, $r->cq, $self->state, $r->state);
dbg("PCPROT: $self->{call}/" . $r->call . ' rejected by in_filter_route') if !$filter && isdbg('chanerr');
$s =~ s/\^H\d\d?\^?\~?$//;
$r = 1 if exists $eph{$s}; # pump up the dup if it keeps circulating
$eph{$s} = $main::systime + $t;
- dbg("PCPROT: emphemeral duplicate") if $r && isdbg('chanerr');
+ dbg("PCPROT: emphemeral duplicate") if $r && isdbg('chanerr');
return $r;
}
sub eph_clean
{
my ($key, $val);
-
+
while (($key, $val) = each %eph) {
if ($main::systime >= $val) {
delete $eph{$key};
# the messages are sent to the chat group which forms the
# the first part of the name (eg: solar.1243.txt would be
# sent to chat group SOLAR)
-#
+#
# Each message found is sent: one non-blank line to one chat
# message. So 4 lines = 4 chat messages.
-#
+#
# The special name LOCAL is for local users ANN
# The special name ALL is for ANN/FULL
# The special name SYSOP is for ANN/SYSOP
dbg("can\'t open $chatimportfn $!") if isdbg('msg');
Log('msg', "can\'t open $chatimportfn $!");
return;
- }
+ }
my @names = readdir(DIR);
closedir(DIR);
my $fn = "$chatimportfn/$name";
next unless -f $fn;
unless (open(MSG, $fn)) {
- dbg("can\'t open import file $fn $!") if isdbg('msg');
+ dbg("can\'t open import file $fn $!") if isdbg('msg');
Log('msg', "can\'t open import file $fn $!");
unlink($fn);
next;
my $target = shift;
my $key = "$dxchan->{call}|$target";
if ($pc92_find{$key}) {
-
+
}
}
sub handle_pc92_find_reply
{
my ($dxchan, $node, $from, $target, $flag, $ms) = @_;
-
+
$dxchan->print_pc92_find_reply($node, $target, $flag, $ms) if $dxchan->can('print_pc92_find_return');
}
}
1;
-__END__
+__END__
projects / spider.git / blobdiff