« back to all changes in this revision
Viewing changes to lib/GenTest/Reporter.pm
- browse files at revision 0.67.771
- compare with another revision
- compare with revision 2426.3.1
- download diff
- download tarball
- view history from revision 0.67.771
- Committer: Bernt M. Johnsen
- Date: 2011-05-19 12:15:14 UTC
- mto: (2312.4.1 drizzle-randgen) (0.67.782 randgen)
- mto: This revision was merged to the branch mainline in revision 2435.
- Revision ID: bernt.johnsen@sun.com-20110519121514-f58abpjfsjhd0om7
--querytimeout added to parameterize QueryTimeout.pm reporter
added
removed
lib/GenTest/Reporter.pm
1
# Copyright (c) 2008,2011 Oracle and/or its affiliates. All rights reserved.
2
# Use is subject to license terms.
3
#
4
# This program is free software; you can redistribute it and/or modify
5
# it under the terms of the GNU General Public License as published by
6
# the Free Software Foundation; version 2 of the License.
7
#
8
# This program is distributed in the hope that it will be useful, but
9
# WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11
# General Public License for more details.
12
#
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301
16
# USA
17
18
package GenTest::Reporter;
19
20
require Exporter;
21
@ISA = qw(GenTest Exporter);
22
@EXPORT = qw(
23
REPORTER_TYPE_PERIODIC
24
REPORTER_TYPE_DEADLOCK
25
REPORTER_TYPE_CRASH
26
REPORTER_TYPE_SUCCESS
27
REPORTER_TYPE_SERVER_KILLED
28
REPORTER_TYPE_ALWAYS
29
REPORTER_TYPE_DATA
30
);
31
32
use strict;
33
use GenTest;
34
use GenTest::Result;
35
use GenTest::Random;
36
use Cwd 'abs_path';
37
use DBI;
38
39
use constant REPORTER_PRNG => 0;
40
use constant REPORTER_SERVER_DSN => 1;
41
use constant REPORTER_SERVER_VARIABLES => 2;
42
use constant REPORTER_SERVER_INFO => 3;
43
use constant REPORTER_SERVER_PLUGINS => 4;
44
use constant REPORTER_TEST_START => 5;
45
use constant REPORTER_TEST_END => 6;
46
use constant REPORTER_TEST_DURATION => 7;
47
48
use constant REPORTER_TYPE_PERIODIC => 2;
49
use constant REPORTER_TYPE_DEADLOCK => 4;
50
use constant REPORTER_TYPE_CRASH => 8;
51
use constant REPORTER_TYPE_SUCCESS => 16;
52
use constant REPORTER_TYPE_SERVER_KILLED => 32;
53
use constant REPORTER_TYPE_ALWAYS => 64;
54
use constant REPORTER_TYPE_DATA => 128;
55
56
1;
57
58
sub new {
59
my $class = shift;
60
61
my $reporter = $class->SUPER::new({
62
dsn => REPORTER_SERVER_DSN,
63
test_start => REPORTER_TEST_START,
64
test_end => REPORTER_TEST_END,
65
test_duration => REPORTER_TEST_DURATION
66
}, @_);
67
68
my $dbh = DBI->connect($reporter->dsn(), undef, undef, { RaiseError => 0 , PrintError => 1 } );
69
return undef if not defined $dbh;
70
my $sth = $dbh->prepare("SHOW VARIABLES");
71
72
$sth->execute();
73
74
while (my $array_ref = $sth->fetchrow_arrayref()) {
75
$reporter->[REPORTER_SERVER_VARIABLES]->{$array_ref->[0]} = $array_ref->[1];
76
}
77
78
$sth->finish();
79
80
my $slave_info = $dbh->selectrow_arrayref("SHOW SLAVE HOSTS");
81
$reporter->[REPORTER_SERVER_INFO]->{slave_host} = $slave_info->[1];
82
$reporter->[REPORTER_SERVER_INFO]->{slave_port} = $slave_info->[2];
83
84
if ($reporter->serverVariable('version') !~ m{^5\.0}sgio) {
85
$reporter->[REPORTER_SERVER_PLUGINS] = $dbh->selectall_arrayref("
86
SELECT PLUGIN_NAME, PLUGIN_LIBRARY
87
FROM INFORMATION_SCHEMA.PLUGINS
88
WHERE PLUGIN_LIBRARY IS NOT NULL
89
");
90
}
91
92
$dbh->disconnect();
93
94
my $pid_file = $reporter->serverVariable('pid_file');
95
96
open (PF, $pid_file);
97
read (PF, my $pid, -s $pid_file);
98
close (PF);
99
100
$pid =~ s{[\r\n]}{}sio;
101
102
$reporter->[REPORTER_SERVER_INFO]->{pid} = $pid;
103
104
foreach my $server_path (
105
'bin', 'sbin', 'sql', 'libexec',
106
'../bin', '../sbin', '../sql', '../libexec',
107
'../sql/RelWithDebInfo', '../sql/Debug',
108
) {
109
my $binary_unix = $reporter->serverVariable('basedir').'/'.$server_path."/mysqld";
110
my $binary_windows = $reporter->serverVariable('basedir').'/'.$server_path."/mysqld.exe";
111
112
if (
113
(-e $binary_unix) ||
114
(-e $binary_windows)
115
) {
116
$reporter->[REPORTER_SERVER_INFO]->{bindir} = $reporter->serverVariable('basedir').'/'.$server_path;
117
$reporter->[REPORTER_SERVER_INFO]->{binary} = $binary_unix if -e $binary_unix;
118
$reporter->[REPORTER_SERVER_INFO]->{binary} = $binary_windows if -e $binary_windows;
119
}
120
}
121
122
foreach my $client_path (
123
"client/RelWithDebInfo", "client/Debug",
124
"client", "../client", "bin", "../bin"
125
) {
126
if (-e $reporter->serverVariable('basedir').'/'.$client_path) {
127
$reporter->[REPORTER_SERVER_INFO]->{'client_bindir'} = $reporter->serverVariable('basedir').'/'.$client_path;
128
last;
129
}
130
}
131
132
# look for error log relative to datadir
133
foreach my $errorlog_path (
134
"../log/master.err", # MTRv1 regular layout
135
"../log/mysqld1.err", # MTRv2 regular layout
136
"../mysql.err" # DBServer::MySQL layout
137
) {
138
my $possible_path = abs_path($reporter->serverVariable('datadir').'/'.$errorlog_path);
139
if (-e $possible_path) {
140
$reporter->[REPORTER_SERVER_INFO]->{'errorlog'} = $possible_path;
141
}
142
}
143
144
my $prng = GenTest::Random->new( seed => 1 );
145
$reporter->[REPORTER_PRNG] = $prng;
146
147
return $reporter;
148
}
149
150
sub monitor {
151
die "Default monitor() called.";
152
}
153
154
sub report {
155
die "Default report() called.";
156
}
157
158
sub dsn {
159
return $_[0]->[REPORTER_SERVER_DSN];
160
}
161
162
sub serverVariable {
163
return $_[0]->[REPORTER_SERVER_VARIABLES]->{$_[1]};
164
}
165
166
sub serverInfo {
167
$_[0]->[REPORTER_SERVER_INFO]->{$_[1]};
168
}
169
170
sub serverPlugins {
171
return $_[0]->[REPORTER_SERVER_PLUGINS];
172
}
173
174
sub testStart {
175
return $_[0]->[REPORTER_TEST_START];
176
}
177
178
sub testEnd {
179
return $_[0]->[REPORTER_TEST_END];
180
}
181
182
sub testDuration {
183
return $_[0]->[REPORTER_TEST_DURATION];
184
}
185
186
sub prng {
187
return $_[0]->[REPORTER_PRNG];
188
}
189
190
sub configure {
191
return 1;
192
}
193
194
1;
1
# Copyright (c) 2008,2011 Oracle and/or its affiliates. All rights reserved.
2
# Use is subject to license terms.
3
#
4
# This program is free software; you can redistribute it and/or modify
5
# it under the terms of the GNU General Public License as published by
6
# the Free Software Foundation; version 2 of the License.
7
#
8
# This program is distributed in the hope that it will be useful, but
9
# WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11
# General Public License for more details.
12
#
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301
16
# USA
17
18
package GenTest::Reporter;
19
20
require Exporter;
21
@ISA = qw(GenTest Exporter);
22
@EXPORT = qw(
23
REPORTER_TYPE_PERIODIC
24
REPORTER_TYPE_DEADLOCK
25
REPORTER_TYPE_CRASH
26
REPORTER_TYPE_SUCCESS
27
REPORTER_TYPE_SERVER_KILLED
28
REPORTER_TYPE_ALWAYS
29
REPORTER_TYPE_DATA
30
);
31
32
use strict;
33
use GenTest;
34
use GenTest::Result;
35
use GenTest::Random;
36
use Cwd 'abs_path';
37
use DBI;
38
39
use constant REPORTER_PRNG => 0;
40
use constant REPORTER_SERVER_DSN => 1;
41
use constant REPORTER_SERVER_VARIABLES => 2;
42
use constant REPORTER_SERVER_INFO => 3;
43
use constant REPORTER_SERVER_PLUGINS => 4;
44
use constant REPORTER_TEST_START => 5;
45
use constant REPORTER_TEST_END => 6;
46
use constant REPORTER_TEST_DURATION => 7;
47
use constant REPORTER_PROPERTIES => 8;
48
49
use constant REPORTER_TYPE_PERIODIC => 2;
50
use constant REPORTER_TYPE_DEADLOCK => 4;
51
use constant REPORTER_TYPE_CRASH => 8;
52
use constant REPORTER_TYPE_SUCCESS => 16;
53
use constant REPORTER_TYPE_SERVER_KILLED => 32;
54
use constant REPORTER_TYPE_ALWAYS => 64;
55
use constant REPORTER_TYPE_DATA => 128;
56
57
1;
58
59
sub new {
60
my $class = shift;
61
62
my $reporter = $class->SUPER::new({
63
dsn => REPORTER_SERVER_DSN,
64
test_start => REPORTER_TEST_START,
65
test_end => REPORTER_TEST_END,
66
test_duration => REPORTER_TEST_DURATION,
67
properties => REPORTER_PROPERTIES
68
}, @_);
69
70
my $dbh = DBI->connect($reporter->dsn(), undef, undef, { RaiseError => 0 , PrintError => 1 } );
71
return undef if not defined $dbh;
72
my $sth = $dbh->prepare("SHOW VARIABLES");
73
74
$sth->execute();
75
76
while (my $array_ref = $sth->fetchrow_arrayref()) {
77
$reporter->[REPORTER_SERVER_VARIABLES]->{$array_ref->[0]} = $array_ref->[1];
78
}
79
80
$sth->finish();
81
82
my $slave_info = $dbh->selectrow_arrayref("SHOW SLAVE HOSTS");
83
$reporter->[REPORTER_SERVER_INFO]->{slave_host} = $slave_info->[1];
84
$reporter->[REPORTER_SERVER_INFO]->{slave_port} = $slave_info->[2];
85
86
if ($reporter->serverVariable('version') !~ m{^5\.0}sgio) {
87
$reporter->[REPORTER_SERVER_PLUGINS] = $dbh->selectall_arrayref("
88
SELECT PLUGIN_NAME, PLUGIN_LIBRARY
89
FROM INFORMATION_SCHEMA.PLUGINS
90
WHERE PLUGIN_LIBRARY IS NOT NULL
91
");
92
}
93
94
$dbh->disconnect();
95
96
my $pid_file = $reporter->serverVariable('pid_file');
97
98
open (PF, $pid_file);
99
read (PF, my $pid, -s $pid_file);
100
close (PF);
101
102
$pid =~ s{[\r\n]}{}sio;
103
104
$reporter->[REPORTER_SERVER_INFO]->{pid} = $pid;
105
106
foreach my $server_path (
107
'bin', 'sbin', 'sql', 'libexec',
108
'../bin', '../sbin', '../sql', '../libexec',
109
'../sql/RelWithDebInfo', '../sql/Debug',
110
) {
111
my $binary_unix = $reporter->serverVariable('basedir').'/'.$server_path."/mysqld";
112
my $binary_windows = $reporter->serverVariable('basedir').'/'.$server_path."/mysqld.exe";
113
114
if (
115
(-e $binary_unix) ||
116
(-e $binary_windows)
117
) {
118
$reporter->[REPORTER_SERVER_INFO]->{bindir} = $reporter->serverVariable('basedir').'/'.$server_path;
119
$reporter->[REPORTER_SERVER_INFO]->{binary} = $binary_unix if -e $binary_unix;
120
$reporter->[REPORTER_SERVER_INFO]->{binary} = $binary_windows if -e $binary_windows;
121
}
122
}
123
124
foreach my $client_path (
125
"client/RelWithDebInfo", "client/Debug",
126
"client", "../client", "bin", "../bin"
127
) {
128
if (-e $reporter->serverVariable('basedir').'/'.$client_path) {
129
$reporter->[REPORTER_SERVER_INFO]->{'client_bindir'} = $reporter->serverVariable('basedir').'/'.$client_path;
130
last;
131
}
132
}
133
134
# look for error log relative to datadir
135
foreach my $errorlog_path (
136
"../log/master.err", # MTRv1 regular layout
137
"../log/mysqld1.err", # MTRv2 regular layout
138
"../mysql.err" # DBServer::MySQL layout
139
) {
140
my $possible_path = abs_path($reporter->serverVariable('datadir').'/'.$errorlog_path);
141
if (-e $possible_path) {
142
$reporter->[REPORTER_SERVER_INFO]->{'errorlog'} = $possible_path;
143
}
144
}
145
146
my $prng = GenTest::Random->new( seed => 1 );
147
$reporter->[REPORTER_PRNG] = $prng;
148
149
return $reporter;
150
}
151
152
sub monitor {
153
die "Default monitor() called.";
154
}
155
156
sub report {
157
die "Default report() called.";
158
}
159
160
sub dsn {
161
return $_[0]->[REPORTER_SERVER_DSN];
162
}
163
164
sub serverVariable {
165
return $_[0]->[REPORTER_SERVER_VARIABLES]->{$_[1]};
166
}
167
168
sub serverInfo {
169
$_[0]->[REPORTER_SERVER_INFO]->{$_[1]};
170
}
171
172
sub serverPlugins {
173
return $_[0]->[REPORTER_SERVER_PLUGINS];
174
}
175
176
sub testStart {
177
return $_[0]->[REPORTER_TEST_START];
178
}
179
180
sub testEnd {
181
return $_[0]->[REPORTER_TEST_END];
182
}
183
184
sub prng {
185
return $_[0]->[REPORTER_PRNG];
186
}
187
188
sub properties {
189
return $_[0]->[REPORTER_PROPERTIES];
190
}
191
192
sub configure {
193
return 1;
194
}
195
196
1;
Loggerhead is a web-based interface for Breezy
Version: 2.0.1