11 |
use Time::HiRes qw/time/; |
use Time::HiRes qw/time/; |
12 |
use File::Pid; |
use File::Pid; |
13 |
use POSIX qw/strftime/; |
use POSIX qw/strftime/; |
14 |
|
use BackupPC::SearchLib; |
15 |
|
|
16 |
use constant BPC_FTYPE_DIR => 5; |
use constant BPC_FTYPE_DIR => 5; |
17 |
use constant EST_CHUNK => 100000; |
use constant EST_CHUNK => 100000; |
44 |
my $user = $Conf{SearchUser} || ''; |
my $user = $Conf{SearchUser} || ''; |
45 |
|
|
46 |
my $use_hest = $Conf{HyperEstraierIndex}; |
my $use_hest = $Conf{HyperEstraierIndex}; |
47 |
my ($index_path, $index_node_url); |
my ($index_path, $index_node_url) = BackupPC::SearchLib::getHyperEstraier_url($use_hest); |
|
if ($use_hest) { |
|
|
use HyperEstraier; |
|
|
if ($use_hest =~ m#^http://#) { |
|
|
$index_node_url = $use_hest; |
|
|
} else { |
|
|
$index_path = $TopDir . '/' . $index_path; |
|
|
$index_path =~ s#//#/#g; |
|
|
} |
|
|
} |
|
|
print "-- $use_hest : $index_path OR $index_node_url --\n"; |
|
|
|
|
48 |
|
|
49 |
my $dbh = DBI->connect($dsn, $user, "", { RaiseError => 1, AutoCommit => 0 }); |
my $dbh = DBI->connect($dsn, $user, "", { RaiseError => 1, AutoCommit => 0 }); |
50 |
|
|
119 |
print " opening index $use_hest"; |
print " opening index $use_hest"; |
120 |
if ($index_path) { |
if ($index_path) { |
121 |
$hest_db = HyperEstraier::Database->new(); |
$hest_db = HyperEstraier::Database->new(); |
122 |
$hest_db->open($index_path, $HyperEstraier::Database::DBWRITER | $HyperEstraier::Database::DBCREAT); |
$hest_db->open($TopDir . $index_path, $HyperEstraier::Database::DBWRITER | $HyperEstraier::Database::DBCREAT); |
123 |
print " directly"; |
print " directly"; |
124 |
} elsif ($index_node_url) { |
} elsif ($index_node_url) { |
125 |
$hest_node ||= HyperEstraier::Node->new($index_node_url); |
$hest_node ||= HyperEstraier::Node->new($index_node_url); |