projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix always 'telnet' in a connect script with a client line
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index b3b4c5a64595547862a84b244d7d0ab14850b0eb..4816916c37c85a79f75ce21b582ad36ac567ffa6 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-41,6
+41,7
@@
BEGIN {
use Msg;
use IntMsg;
use ExtMsg;
use Msg;
use IntMsg;
use ExtMsg;
+use AGWMsg;
use DXVars;
use DXDebug;
use DXLog;
use DXVars;
use DXDebug;
use DXLog;
@@
-97,7
+98,7
@@
sub already_conn
dbg('chan', "-> D $call $mess\n");
$conn->send_now("D$call|$mess");
dbg('chan', "-> D $call $mess\n");
$conn->send_now("D$call|$mess");
- sleep(2);
+
Msg->
sleep(2);
$conn->disconnect;
}
$conn->disconnect;
}
@@
-214,6
+215,10
@@
sub cease
next if $dxchan->is_node;
$dxchan->disconnect unless $dxchan == $DXProt::me;
}
next if $dxchan->is_node;
$dxchan->disconnect unless $dxchan == $DXProt::me;
}
+
+ # disconnect AGW
+ AGWMsg::finish();
+
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
@@
-363,6
+368,7
@@
for (@main::listen) {
push @listeners, $conn;
dbg('err', "External Port: $_->[0] $_->[1]");
}
push @listeners, $conn;
dbg('err', "External Port: $_->[0] $_->[1]");
}
+AGWMsg::init(\&new_channel);
# load bad words
dbg('err', "load badwords: " . (BadWords::load or "Ok"));
# load bad words
dbg('err', "load badwords: " . (BadWords::load or "Ok"));
@@
-461,7
+467,8
@@
for (;;) {
DXDb::process();
DXUser::process();
DXDupe::process();
DXDb::process();
DXUser::process();
DXDupe::process();
-
+ AGWMsg::process();
+
eval {
Local::process(); # do any localised processing
};
eval {
Local::process(); # do any localised processing
};