projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
alias 'w' to 'who'
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index 8798392b8541152633ce50445d3a97666de3cff3..b7ac117773e9f398f8a777e6d21abd56cd0d4e7e 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-100,7
+100,7
@@
package main;
use strict;
use vars qw(@inqueue $systime $version $starttime $lockfn @outstanding_connects
$zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr
use strict;
use vars qw(@inqueue $systime $version $starttime $lockfn @outstanding_connects
$zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr
- $clusterport $mycall $decease $is_win $routeroot $me
+ $clusterport $mycall $decease $is_win $routeroot $me
$reqreg
);
@inqueue = (); # the main input queue, an array of hashes
);
@inqueue = (); # the main input queue, an array of hashes
@@
-109,6
+109,7
@@
$version = "1.49"; # the version no of the software
$starttime = 0; # the starting time of the cluster
#@outstanding_connects = (); # list of outstanding connects
@listeners = (); # list of listeners
$starttime = 0; # the starting time of the cluster
#@outstanding_connects = (); # list of outstanding connects
@listeners = (); # list of listeners
+$reqreg = 0; # 1 = registration required, 2 = deregister people
use vars qw($VERSION $BRANCH $build $branch);
$VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
use vars qw($VERSION $BRANCH $build $branch);
$VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
@@
-310,7
+311,6
@@
sub process_inqueue
die "\$user not defined for $call" if !defined $user;
# normal input
$dxchan->normal($line);
die "\$user not defined for $call" if !defined $user;
# normal input
$dxchan->normal($line);
- $dxchan->disconnect if ($dxchan->{state} eq 'bye');
} elsif ($sort eq 'Z') {
$dxchan->disconnect;
} elsif ($sort eq 'D') {
} elsif ($sort eq 'Z') {
$dxchan->disconnect;
} elsif ($sort eq 'D') {
@@
-466,12
+466,6
@@
eval {
};
dbg("Local::init error $@") if $@;
};
dbg("Local::init error $@") if $@;
-dbg("cleaning out old debug files");
-DXDebug::dbgclean();
-
-# print various flags
-#dbg("seful info - \$^D: $^D \$^W: $^W \$^S: $^S \$^P: $^P");
-
# this, such as it is, is the main loop!
dbg("orft we jolly well go ...");
my $script = new Script "startup";
# this, such as it is, is the main loop!
dbg("orft we jolly well go ...");
my $script = new Script "startup";