1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
package My::Suite::Sphinx;
use My::SafeProcess;
use My::File::Path;
use mtr_report;
@ISA = qw(My::Suite);
use Carp;
$Carp::Verbose=1;
############# initialization ######################
sub locate_sphinx_binary {
my ($name)= @_;
my $res;
my @list= map "$_/$name", split /:/, $ENV{PATH};
my $env_override= $ENV{"SPHINXSEARCH_\U$name"};
@list= ($env_override) if $env_override;
for (@list) { return $_ if -x $_; }
}
# Look for Sphinx binaries.
my $exe_sphinx_indexer = &locate_sphinx_binary('indexer');
my $exe_sphinx_searchd = &locate_sphinx_binary('searchd');
return "No Sphinx" unless $exe_sphinx_indexer and $exe_sphinx_searchd;
return "No SphinxSE" unless $ENV{HA_SPHINX_SO} or
$::mysqld_variables{'sphinx'} eq "ON";
{
local $_ = `"$exe_sphinx_searchd" --help`;
mtr_verbose("tool: $exe_sphinx_searchd\n$_");
my $ver = sprintf "%04d.%04d.%04d", (/([0-9]+)\.([0-9]+)\.([0-9]+)/);
if ($ver eq "0000.0000.0000")
{
$ver = sprintf "%04d.%04d", (/([0-9]+)\.([0-9]+)-(alpha|beta|gamma|RC)/);
return "Sphinx 0.9.9 or later is needed" unless $ver ge '0001.0010';
}
else
{
return "Sphinx 0.9.9 or later is needed" unless $ver ge '0000.0009.0009';
}
}
############# action methods ######################
sub write_sphinx_conf {
my ($config) = @_; # My::Config
my $res;
foreach my $group ($config->groups()) {
my $name= $group->{name};
# Only the ones relevant to Sphinx search.
next unless ($name eq 'indexer' or $name eq 'searchd' or
$name =~ /^(source|index) \w+$/);
$res .= "$name\n{\n";
foreach my $option ($group->options()) {
$res .= $option->name();
my $value= $option->value();
if (defined $value) {
$res .= "=$value";
}
$res .= "\n";
}
$res .= "}\n\n";
}
$res;
}
sub searchd_start {
my ($sphinx, $test) = @_; # My::Config::Group, My::Test
return unless $exe_sphinx_indexer and $exe_sphinx_searchd;
# First we must run the indexer to create the data.
my $sphinx_data_dir= "$::opt_vardir/" . $sphinx->name();
mkpath($sphinx_data_dir);
my $sphinx_log= $sphinx->value('#log-error');
my $sphinx_config= "$::opt_vardir/my_sphinx.conf";
my $cmd= "\"$exe_sphinx_indexer\" --config \"$sphinx_config\" test1 > \"$sphinx_log\" 2>&1";
&::mtr_verbose("cmd: $cmd");
system $cmd;
# Then start the searchd daemon.
my $args;
&::mtr_init_args(\$args);
&::mtr_add_arg($args, "--config");
&::mtr_add_arg($args, $sphinx_config);
&::mtr_add_arg($args, "--console");
&::mtr_add_arg($args, "--pidfile");
$sphinx->{'proc'}= My::SafeProcess->new
(
name => 'sphinx-' . $sphinx->name(),
path => $exe_sphinx_searchd,
args => \$args,
output => $sphinx_log,
error => $sphinx_log,
append => 1,
nocore => 1,
);
&::mtr_verbose("Started $sphinx->{proc}");
}
sub searchd_wait {
my ($sphinx) = @_; # My::Config::Group
return not &::sleep_until_file_created($sphinx->value('pid_file'), 20,
$sphinx->{'proc'})
}
############# declaration methods ######################
sub config_files() {
( 'my_sphinx.conf' => \&write_sphinx_conf )
}
sub servers {
( qr/^searchd$/ => {
SORT => 400,
START => \&searchd_start,
WAIT => \&searchd_wait,
}
)
}
############# return an object ######################
bless { };
|
