projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
added new version of admin manual
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index ec1030e88096a659e1b4480c7bf78572a2ac874a..0f8ecfbba1ff4ef37b0f8889a3e2b7d82ea6062e 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-61,6
+61,8
@@
use Filter;
use DXDb;
use AnnTalk;
use WCY;
use DXDb;
use AnnTalk;
use WCY;
+use DXDupe;
+use BadWords;
use Data::Dumper;
use Fcntl ':flock';
use Data::Dumper;
use Fcntl ':flock';
@@
-219,6
+221,7
@@
sub cease
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
DXUser::finish();
Msg->event_loop(1, 0.05);
Msg->event_loop(1, 0.05);
DXUser::finish();
+ DXDupe::finish();
# close all databases
DXDb::closeall;
# close all databases
DXDb::closeall;
@@
-321,6
+324,9
@@
DXUser->init($userfn, 1);
dbg('err', "starting listener ...");
Msg->new_server("$clusteraddr", $clusterport, \&login);
dbg('err', "starting listener ...");
Msg->new_server("$clusteraddr", $clusterport, \&login);
+# load bad words
+dbg('err', "load badwords: " . (BadWords::load or "Ok"));
+
# prime some signals
$SIG{INT} = \&cease;
$SIG{TERM} = \&cease;
# prime some signals
$SIG{INT} = \&cease;
$SIG{TERM} = \&cease;
@@
-340,6
+346,9
@@
for (keys %SIG) {
}
}
}
}
+# start dupe system
+DXDupe::init();
+
# read in system messages
DXM->init();
# read in system messages
DXM->init();
@@
-410,6
+419,8
@@
for (;;) {
DXMsg::process();
DXDb::process();
DXUser::process();
DXMsg::process();
DXDb::process();
DXUser::process();
+ DXDupe::process();
+
eval {
Local::process(); # do any localised processing
};
eval {
Local::process(); # do any localised processing
};