projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
added some extra cases for IOTA and QSL detection on sh/dx
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index c3f61038fda99ed19f746b92e58b6c99d5bb423a..1f011c55584971360363523d3c332d3e8c6f5766 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-208,6
+208,10
@@
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();
+
+ # close all databases
+ DXDb::closeall;
+
dbg('chan', "DXSpider version $version ended");
Log('cluster', "DXSpider V$version stopped");
dbgclose();
dbg('chan', "DXSpider version $version ended");
Log('cluster', "DXSpider V$version stopped");
dbgclose();
@@
-346,6
+350,10
@@
DXMsg::clean_old();
print "reading cron jobs ...\n";
DXCron->init();
print "reading cron jobs ...\n";
DXCron->init();
+# read in database descriptors
+print "reading database descriptors ...\n";
+DXDb::load();
+
# starting local stuff
print "doing local initialisation ...\n";
eval {
# starting local stuff
print "doing local initialisation ...\n";
eval {
@@
-375,6
+383,7
@@
for (;;) {
DXProt::process(); # process ongoing ak1a pcxx stuff
DXConnect::process();
DXMsg::process();
DXProt::process(); # process ongoing ak1a pcxx stuff
DXConnect::process();
DXMsg::process();
+ DXDb::process();
eval {
Local::process(); # do any localised processing
};
eval {
Local::process(); # do any localised processing
};