projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
5. Only wonder down the msg queue every minute
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index c3f61038fda99ed19f746b92e58b6c99d5bb423a..8b45e2bd65d805d7fc411650b387a586199d103f 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-178,6
+178,9
@@
sub cease
};
dbg('local', "Local::finish error $@") if $@;
};
dbg('local', "Local::finish error $@") if $@;
+ # close all databases
+ DXDb::closeall;
+
# disconnect users
foreach $dxchan (DXChannel->get_all()) {
next if $dxchan->is_ak1a;
# disconnect users
foreach $dxchan (DXChannel->get_all()) {
next if $dxchan->is_ak1a;
@@
-346,6
+349,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
+382,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
};