X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=fd23a2534ec8b4771ea1ffe2a81ccbe18147ef38;hb=febdc9bd8f6cd065d217ba089fab4361e9980f35;hp=d321cba5fcd9b971e4cb048857aa539065daa253;hpb=8cdf937edf493134e69b2df1ec689839148f2d8f;p=spider.git diff --git a/perl/cluster.pl b/perl/cluster.pl index d321cba5..fd23a253 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); } @@ -345,6 +332,7 @@ while () { } close CL; 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+)/ ) { @@ -433,7 +421,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 ...");