projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add DXSql module and condiational processing
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index d2392ceb0e2337417656a025838f56d6784055d4..2510c940cd5bfdc107ce2d5dac415628a1887fe3 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-116,7
+116,7
@@
use strict;
use vars qw(@inqueue $systime $version $starttime $lockfn @outstanding_connects
$zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr
$clusterport $mycall $decease $is_win $routeroot $me $reqreg $bumpexisting
use vars qw(@inqueue $systime $version $starttime $lockfn @outstanding_connects
$zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr
$clusterport $mycall $decease $is_win $routeroot $me $reqreg $bumpexisting
- $allowdxby
+ $allowdxby
$dbh $dsn $dbuser $dbpass
);
@inqueue = (); # the main input queue, an array of hashes
);
@inqueue = (); # the main input queue, an array of hashes
@@
-287,6
+287,9
@@
sub cease
Log('cluster', "DXSpider V$version, build $build ended");
dbgclose();
Logclose();
Log('cluster', "DXSpider V$version, build $build ended");
dbgclose();
Logclose();
+
+ $dbh->finish if $dbh;
+
unlink $lockfn;
# $SIG{__WARN__} = $SIG{__DIE__} = sub {my $a = shift; cluck($a); };
exit(0);
unlink $lockfn;
# $SIG{__WARN__} = $SIG{__DIE__} = sub {my $a = shift; cluck($a); };
exit(0);
@@
-351,6
+354,16
@@
$year += 1900;
dbg("Copyright (c) 1998-$year Dirk Koopman G1TLH");
dbg("DXSpider Version $version, build $build started");
dbg("Copyright (c) 1998-$year Dirk Koopman G1TLH");
dbg("DXSpider Version $version, build $build started");
+# try to load the database
+if ($dsn && -e "$root/perl/DXSql.pm") {
+ require DXSql;
+ import DXSql;
+
+ if (DXSql::init()) {
+ $dbh = DXSql->new($dsn, $dbuser, $dbpass);
+ }
+}
+
# load Prefixes
dbg("loading prefixes ...");
dbg(USDB::init());
# load Prefixes
dbg("loading prefixes ...");
dbg(USDB::init());