projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add do command
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index 4816916c37c85a79f75ce21b582ad36ac567ffa6..0a66c1db5732a6a2448526ee77d237a734a96026 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-36,6
+36,9
@@
BEGIN {
open(CLLOCK, ">$lockfn") or die "Can't open Lockfile ($lockfn) $!";
print CLLOCK "$$\n";
close CLLOCK;
open(CLLOCK, ">$lockfn") or die "Can't open Lockfile ($lockfn) $!";
print CLLOCK "$$\n";
close CLLOCK;
+
+ $is_win = ($^O =~ /^MS/ || $^O =~ /^OS-2/) ? 1 : 0; # is it Windows?
+ $systime = time;
}
use Msg;
}
use Msg;
@@
-79,7
+82,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 $build
+ $clusterport $mycall $decease $build
$is_win
);
@inqueue = (); # the main input queue, an array of hashes
);
@inqueue = (); # the main input queue, an array of hashes
@@
-301,6
+304,12
@@
sub uptime
my $mins = int $t / 60;
return sprintf "%d %02d:%02d", $days, $hours, $mins;
}
my $mins = int $t / 60;
return sprintf "%d %02d:%02d", $days, $hours, $mins;
}
+
+sub AGWrestart
+{
+ AGWMsg::init(\&new_channel);
+}
+
#############################################################
#
# The start of the main line of code
#############################################################
#
# The start of the main line of code
@@
-368,13
+377,13
@@
for (@main::listen) {
push @listeners, $conn;
dbg('err', "External Port: $_->[0] $_->[1]");
}
push @listeners, $conn;
dbg('err', "External Port: $_->[0] $_->[1]");
}
-AGW
Msg::init(\&new_channel
);
+AGW
restart(
);
# load bad words
dbg('err', "load badwords: " . (BadWords::load or "Ok"));
# prime some signals
# load bad words
dbg('err', "load badwords: " . (BadWords::load or "Ok"));
# prime some signals
-unless ($
^O =~ /^MS/
) {
+unless ($
is_win
) {
unless ($DB::VERSION) {
$SIG{INT} = \&cease;
$SIG{TERM} = \&cease;
unless ($DB::VERSION) {
$SIG{INT} = \&cease;
$SIG{TERM} = \&cease;