X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=fb8753e24fd45782e85f351e1e233d7b457b8f8d;hb=b32570d9978c9e99a8652e52491cf92540bf876b;hp=d321cba5fcd9b971e4cb048857aa539065daa253;hpb=8cdf937edf493134e69b2df1ec689839148f2d8f;p=spider.git diff --git a/perl/cluster.pl b/perl/cluster.pl index d321cba5..fb8753e2 100755 --- a/perl/cluster.pl +++ b/perl/cluster.pl @@ -61,7 +61,6 @@ use DXProtVars; use DXProtout; use DXProt; use DXMsg; -use DXCluster; use DXCron; use DXConnect; use DXBearing; @@ -82,6 +81,9 @@ use BBS; use WCY; use BadWords; use Timer; +use Route; +use Route::Node; +use Route::User; use Data::Dumper; use IO::File; @@ -95,7 +97,7 @@ package main; use strict; use vars qw(@inqueue $systime $version $starttime $lockfn @outstanding_connects $zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr - $clusterport $mycall $decease $build $is_win + $clusterport $mycall $decease $build $is_win $routeroot ); @inqueue = (); # the main input queue, an array of hashes @@ -142,24 +144,9 @@ sub new_channel return; } - # is there one already connected elsewhere in the cluster? if ($user) { - if (($user->is_node || $call eq $myalias) && !DXCluster->get_exact($call)) { - ; - } else { - if (my $ref = DXCluster->get_exact($call)) { - my $mess = DXM::msg($lang, 'concluster', $call, $ref->mynode->dxchancall); - already_conn($conn, $call, $mess); - return; - } - } $user->{lang} = $main::lang if !$user->{lang}; # to autoupdate old systems } else { - if (my $ref = DXCluster->get_exact($call)) { - my $mess = DXM::msg($lang, 'concluster', $call, $ref->mynode->dxchancall); - already_conn($conn, $call, $mess); - return; - } $user = DXUser->new($call); } @@ -344,16 +331,20 @@ while () { push @fn, $1; } close CL; +my $subbuild; foreach my $fn (@fn) { + $fn =~ s|::|/|g; open(CL, "$main::root/perl/${fn}.pm") or next; while () { - if (/^#\s+\$Id:\s+[\w\._]+,v\s+(\d+\.\d+)/ ) { + if (/^#\s+\$Id:\s+[\w\._]+,v\s+(\d+\.\d+)\.?(\d+.\d+)?/ ) { $build += $1; + $subbuild += $2 if $2; last; } } close CL; } +$build = "$build.$subbuild" if $subbuild; Log('cluster', "DXSpider V$version, build $build started"); @@ -433,7 +424,13 @@ dbg('err', "reading in duplicate spot and WWV info ..."); DXProt->init(); # put in a DXCluster node for us here so we can add users and take them away -DXNode->new($DXProt::me, $mycall, 0, 1, $DXProt::myprot_version); +$routeroot = Route::Node->new($mycall, $version*100+5300, Route::here($DXProt::me->here)|Route::conf($DXProt::me->conf)); + +# make sure that there is a routing OUTPUT node default file +unless (Filter::read_in('route', 'node_default', 0)) { + my $dxcc = $DXProt::me->dxcc; + $Route::filterdef->cmd($DXProt::me, 'route', 'accept', "node_default call_dxcc $dxcc" ); +} # read in any existing message headers and clean out old crap dbg('err', "reading existing message headers ...");