mirror of
https://github.com/MariaDB/server.git
synced 2025-01-19 05:22:25 +01:00
639c9dbc85
Now NDB is only initialized and started when the tests that are being run will make use of it. The same thing is also done for the slave databases and the instance manager. After review from Magnus: Only take a snapshot of the data directories that are in use. mysql-test/mysql-test-run.pl: Only initialize (and start) NDB, the instance manager, and the slaves when we have tests that require them. Also, only snapshot the data directories that we are going to use. mysql-test/ndb/ndbcluster.sh: Fix text message that has always annoyed me
3476 lines
100 KiB
Perl
Executable file
3476 lines
100 KiB
Perl
Executable file
#!/usr/bin/perl
|
|
# -*- cperl -*-
|
|
|
|
# This is a transformation of the "mysql-test-run" Bourne shell script
|
|
# to Perl. There are reasons this rewrite is not the prettiest Perl
|
|
# you have seen
|
|
#
|
|
# - The original script is huge and for most part uncommented,
|
|
# not even a usage description of the flags.
|
|
#
|
|
# - There has been an attempt to write a replacement in C for the
|
|
# original Bourne shell script. It was kind of working but lacked
|
|
# lot of functionality to really be a replacement. Not to redo
|
|
# that mistake and catch all the obscure features of the original
|
|
# script, the rewrite in Perl is more close to the original script
|
|
# meaning it also share some of the ugly parts as well.
|
|
#
|
|
# - The original intention was that this script was to be a prototype
|
|
# to be the base for a new C version with full functionality. Since
|
|
# then it was decided that the Perl version should replace the
|
|
# Bourne shell version, but the Perl style still reflects the wish
|
|
# to make the Perl to C step easy.
|
|
#
|
|
# Some coding style from the original intent has been kept
|
|
#
|
|
# - To make this Perl script easy to alter even for those that not
|
|
# code Perl that often, the coding style is as close as possible to
|
|
# the C/C++ MySQL coding standard.
|
|
#
|
|
# - All lists of arguments to send to commands are Perl lists/arrays,
|
|
# not strings we append args to. Within reason, most string
|
|
# concatenation for arguments should be avoided.
|
|
#
|
|
# - Functions defined in the main program are not to be prefixed,
|
|
# functions in "library files" are to be prefixed with "mtr_" (for
|
|
# Mysql-Test-Run). There are some exceptions, code that fits best in
|
|
# the main program, but are put into separate files to avoid
|
|
# clutter, may be without prefix.
|
|
#
|
|
# - All stat/opendir/-f/ is to be kept in collect_test_cases(). It
|
|
# will create a struct that the rest of the program can use to get
|
|
# the information. This separates the "find information" from the
|
|
# "do the work" and makes the program more easy to maintain.
|
|
#
|
|
# - At the moment, there are tons of "global" variables that control
|
|
# this script, even accessed from the files in "lib/*.pl". This
|
|
# will change over time, for now global variables are used instead
|
|
# of using %opt, %path and %exe hashes, because I want more
|
|
# compile time checking, that hashes would not give me. Once this
|
|
# script is debugged, hashes will be used and passed as parameters
|
|
# to functions, to more closely mimic how it would be coded in C
|
|
# using structs.
|
|
#
|
|
# - The rule when it comes to the logic of this program is
|
|
#
|
|
# command_line_setup() - is to handle the logic between flags
|
|
# collect_test_cases() - is to do its best to select what tests
|
|
# to run, dig out options, if needs restart etc.
|
|
# run_testcase() - is to run a single testcase, and follow the
|
|
# logic set in both above. No, or rare file
|
|
# system operations. If a test seems complex,
|
|
# it should probably not be here.
|
|
#
|
|
# A nice way to trace the execution of this script while debugging
|
|
# is to use the Devel::Trace package found at
|
|
# "http://www.plover.com/~mjd/perl/Trace/" and run this script like
|
|
# "perl -d:Trace mysql-test-run.pl"
|
|
#
|
|
# FIXME Save a PID file from this code as well, to record the process
|
|
# id we think it has. In Cygwin, a fork creates one Cygwin process,
|
|
# and then the real Win32 process. Cygwin Perl can only kill Cygwin
|
|
# processes. And "mysqld --bootstrap ..." doesn't save a PID file.
|
|
|
|
$Devel::Trace::TRACE= 0; # Don't trace boring init stuff
|
|
|
|
#require 5.6.1;
|
|
use File::Path;
|
|
use File::Basename;
|
|
use File::Copy;
|
|
use Cwd;
|
|
use Getopt::Long;
|
|
use Sys::Hostname;
|
|
#use Carp;
|
|
use IO::Socket;
|
|
use IO::Socket::INET;
|
|
use Data::Dumper;
|
|
use strict;
|
|
#use diagnostics;
|
|
|
|
require "lib/mtr_cases.pl";
|
|
require "lib/mtr_process.pl";
|
|
require "lib/mtr_timer.pl";
|
|
require "lib/mtr_io.pl";
|
|
require "lib/mtr_gcov.pl";
|
|
require "lib/mtr_gprof.pl";
|
|
require "lib/mtr_report.pl";
|
|
require "lib/mtr_diff.pl";
|
|
require "lib/mtr_match.pl";
|
|
require "lib/mtr_misc.pl";
|
|
require "lib/mtr_stress.pl";
|
|
|
|
$Devel::Trace::TRACE= 1;
|
|
|
|
# Used by gcov
|
|
our @mysqld_src_dirs=
|
|
(
|
|
"strings",
|
|
"mysys",
|
|
"include",
|
|
"extra",
|
|
"regex",
|
|
"isam",
|
|
"merge",
|
|
"myisam",
|
|
"myisammrg",
|
|
"heap",
|
|
"sql",
|
|
);
|
|
|
|
##############################################################################
|
|
#
|
|
# Default settings
|
|
#
|
|
##############################################################################
|
|
|
|
# We are to use handle_options() in "mysys/my_getopt.c" for the C version
|
|
#
|
|
# In the C version we want to use structs and, in some cases, arrays of
|
|
# structs. We let each struct be a separate hash.
|
|
|
|
# Misc global variables
|
|
|
|
our $glob_win32= 0; # OS and native Win32 executables
|
|
our $glob_win32_perl= 0; # ActiveState Win32 Perl
|
|
our $glob_cygwin_perl= 0; # Cygwin Perl
|
|
our $glob_cygwin_shell= undef;
|
|
our $glob_use_libtool= 1;
|
|
our $glob_mysql_test_dir= undef;
|
|
our $glob_mysql_bench_dir= undef;
|
|
our $glob_hostname= undef;
|
|
our $glob_scriptname= undef;
|
|
our $glob_timers= undef;
|
|
our $glob_use_running_server= 0;
|
|
our $glob_use_running_ndbcluster= 0;
|
|
our $glob_use_embedded_server= 0;
|
|
our @glob_test_mode;
|
|
|
|
our $using_ndbcluster_master= 0;
|
|
|
|
our $glob_basedir;
|
|
|
|
# The total result
|
|
|
|
our $path_charsetsdir;
|
|
our $path_client_bindir;
|
|
our $path_language;
|
|
our $path_timefile;
|
|
our $path_snapshot;
|
|
our $path_manager_log; # Used by mysqldadmin
|
|
our $path_slave_load_tmpdir; # What is this?!
|
|
our $path_mysqltest_log;
|
|
our $path_my_basedir;
|
|
our $opt_vardir; # A path but set directly on cmd line
|
|
our $opt_vardir_trace; # unix formatted opt_vardir for trace files
|
|
our $opt_tmpdir; # A path but set directly on cmd line
|
|
|
|
our $opt_usage;
|
|
our $opt_suite;
|
|
|
|
our $opt_netware;
|
|
|
|
our $opt_script_debug= 0; # Script debugging, enable with --script-debug
|
|
|
|
# Options FIXME not all....
|
|
|
|
our $exe_master_mysqld;
|
|
our $exe_mysql;
|
|
our $exe_mysqladmin;
|
|
our $exe_mysqlbinlog;
|
|
our $exe_mysql_client_test;
|
|
our $exe_mysqld;
|
|
our $exe_mysqlcheck; # Called from test case
|
|
our $exe_mysqldump; # Called from test case
|
|
our $exe_mysqlimport; # Called from test case
|
|
our $exe_mysqlshow; # Called from test case
|
|
our $exe_mysql_fix_system_tables;
|
|
our $exe_mysqltest;
|
|
our $exe_slave_mysqld;
|
|
our $exe_im;
|
|
our $exe_my_print_defaults;
|
|
|
|
our $opt_bench= 0;
|
|
our $opt_small_bench= 0;
|
|
our $opt_big_test= 0; # Send --big-test to mysqltest
|
|
|
|
our @opt_extra_mysqld_opt;
|
|
|
|
our $opt_comment;
|
|
our $opt_compress;
|
|
our $opt_ssl;
|
|
our $opt_skip_ssl;
|
|
our $opt_ssl_supported;
|
|
our $opt_ps_protocol;
|
|
our $opt_sp_protocol;
|
|
our $opt_cursor_protocol;
|
|
our $opt_view_protocol;
|
|
|
|
our $opt_current_test;
|
|
our $opt_debug;
|
|
our $opt_do_test;
|
|
our @opt_cases; # The test cases names in argv
|
|
our $opt_embedded_server;
|
|
our $opt_extern;
|
|
our $opt_fast;
|
|
our $opt_force;
|
|
our $opt_reorder;
|
|
|
|
our $opt_gcov;
|
|
our $opt_gcov_err;
|
|
our $opt_gcov_msg;
|
|
|
|
our $glob_debugger= 0;
|
|
our $opt_gdb;
|
|
our $opt_client_gdb;
|
|
our $opt_ddd;
|
|
our $opt_client_ddd;
|
|
our $opt_manual_gdb;
|
|
our $opt_manual_ddd;
|
|
our $opt_manual_debug;
|
|
our $opt_debugger;
|
|
our $opt_client_debugger;
|
|
|
|
our $opt_gprof;
|
|
our $opt_gprof_dir;
|
|
our $opt_gprof_master;
|
|
our $opt_gprof_slave;
|
|
|
|
our $opt_local;
|
|
our $opt_local_master;
|
|
|
|
our $master; # Will be struct in C
|
|
our $slave;
|
|
|
|
our $instance_manager;
|
|
|
|
our $opt_ndbcluster_port;
|
|
our $opt_ndbconnectstring;
|
|
|
|
our $opt_no_manager; # Does nothing now, we never use manager
|
|
our $opt_manager_port; # Does nothing now, we never use manager
|
|
|
|
our $opt_old_master;
|
|
|
|
our $opt_record;
|
|
our $opt_check_testcases;
|
|
|
|
our $opt_result_ext;
|
|
|
|
our $opt_skip;
|
|
our $opt_skip_rpl;
|
|
our $opt_skip_test;
|
|
our $opt_skip_im;
|
|
|
|
our $opt_sleep;
|
|
|
|
our $opt_sleep_time_after_restart= 1;
|
|
our $opt_sleep_time_for_delete= 10;
|
|
our $opt_testcase_timeout;
|
|
our $opt_suite_timeout;
|
|
my $default_testcase_timeout= 15; # 15 min max
|
|
my $default_suite_timeout= 120; # 2 hours max
|
|
|
|
our $opt_socket;
|
|
|
|
our $opt_source_dist;
|
|
|
|
our $opt_start_and_exit;
|
|
our $opt_start_dirty;
|
|
our $opt_start_from;
|
|
|
|
our $opt_strace_client;
|
|
|
|
our $opt_timer;
|
|
|
|
our $opt_user;
|
|
our $opt_user_test;
|
|
|
|
our $opt_valgrind= 0;
|
|
our $opt_valgrind_mysqld= 0;
|
|
our $opt_valgrind_mysqltest= 0;
|
|
our $opt_valgrind_all= 0;
|
|
our $opt_valgrind_options;
|
|
our $opt_valgrind_path;
|
|
|
|
our $opt_stress= "";
|
|
our $opt_stress_suite= "main";
|
|
our $opt_stress_mode= "random";
|
|
our $opt_stress_threads= 5;
|
|
our $opt_stress_test_count= 0;
|
|
our $opt_stress_loop_count= 0;
|
|
our $opt_stress_test_duration= 0;
|
|
our $opt_stress_init_file= "";
|
|
our $opt_stress_test_file= "";
|
|
|
|
our $opt_wait_for_master;
|
|
our $opt_wait_for_slave;
|
|
our $opt_wait_timeout= 10;
|
|
|
|
our $opt_warnings;
|
|
|
|
our $opt_udiff;
|
|
|
|
our $opt_skip_ndbcluster;
|
|
our $opt_with_ndbcluster;
|
|
our $opt_with_ndbcluster_only= 0; # dummy, ignored
|
|
|
|
our $opt_with_openssl;
|
|
|
|
our $exe_ndb_mgm;
|
|
our $path_ndb_tools_dir;
|
|
our $path_ndb_data_dir;
|
|
our $file_ndb_testrun_log;
|
|
our $flag_ndb_status_ok= 1;
|
|
|
|
our @data_dir_lst;
|
|
|
|
######################################################################
|
|
#
|
|
# Function declarations
|
|
#
|
|
######################################################################
|
|
|
|
sub main ();
|
|
sub initial_setup ();
|
|
sub command_line_setup ();
|
|
sub snapshot_setup ();
|
|
sub executable_setup ();
|
|
sub environment_setup ();
|
|
sub kill_running_server ();
|
|
sub kill_and_cleanup ();
|
|
sub check_ssl_support ();
|
|
sub check_ndbcluster_support ();
|
|
sub ndbcluster_install ();
|
|
sub ndbcluster_start ($);
|
|
sub ndbcluster_stop ();
|
|
sub run_benchmarks ($);
|
|
sub initialize_servers ();
|
|
sub mysql_install_db ();
|
|
sub install_db ($$);
|
|
sub run_testcase ($);
|
|
sub report_failure_and_restart ($);
|
|
sub do_before_start_master ($$);
|
|
sub do_before_start_slave ($$);
|
|
sub mysqld_start ($$$$$);
|
|
sub mysqld_arguments ($$$$$$);
|
|
sub stop_masters_slaves ();
|
|
sub stop_masters ();
|
|
sub stop_slaves ();
|
|
sub im_start ($$);
|
|
sub im_stop ($);
|
|
sub run_mysqltest ($);
|
|
sub usage ($);
|
|
|
|
######################################################################
|
|
#
|
|
# Main program
|
|
#
|
|
######################################################################
|
|
|
|
main();
|
|
|
|
sub main () {
|
|
|
|
initial_setup();
|
|
command_line_setup();
|
|
executable_setup();
|
|
|
|
check_ndbcluster_support(); # We check whether to actually use it later
|
|
check_ssl_support();
|
|
|
|
environment_setup();
|
|
signal_setup();
|
|
|
|
if ( $opt_gcov )
|
|
{
|
|
gcov_prepare();
|
|
}
|
|
|
|
if ( $opt_gprof )
|
|
{
|
|
gprof_prepare();
|
|
}
|
|
|
|
if ( $opt_start_dirty )
|
|
{
|
|
if ( ndbcluster_start($opt_with_ndbcluster) )
|
|
{
|
|
mtr_error("Can't start ndbcluster");
|
|
}
|
|
if ( mysqld_start('master',0,[],[],$using_ndbcluster_master) )
|
|
{
|
|
mtr_report("Servers started, exiting");
|
|
}
|
|
else
|
|
{
|
|
mtr_error("Can't start the mysqld server");
|
|
}
|
|
}
|
|
elsif ( $opt_bench )
|
|
{
|
|
initialize_servers();
|
|
run_benchmarks(shift); # Shift what? Extra arguments?!
|
|
}
|
|
elsif ( $opt_stress )
|
|
{
|
|
initialize_servers();
|
|
run_stress_test()
|
|
}
|
|
else
|
|
{
|
|
# Figure out which tests we are going to run
|
|
my $tests= collect_test_cases($opt_suite);
|
|
|
|
# Turn off NDB and other similar options if no tests use it
|
|
my ($need_ndbcluster,$need_im,$need_slave);
|
|
foreach my $test (@$tests)
|
|
{
|
|
$need_ndbcluster||= $test->{ndb_test};
|
|
$need_im||= $test->{component_id} eq 'im';
|
|
$need_slave||= $test->{slave_num};
|
|
}
|
|
$opt_with_ndbcluster= 0 unless $need_ndbcluster;
|
|
$opt_skip_im= 1 unless $need_im;
|
|
$opt_skip_rpl= 1 unless $need_slave;
|
|
|
|
snapshot_setup();
|
|
initialize_servers();
|
|
|
|
run_suite($opt_suite, $tests);
|
|
}
|
|
|
|
mtr_exit(0);
|
|
}
|
|
|
|
##############################################################################
|
|
#
|
|
# Initial setup independent on command line arguments
|
|
#
|
|
##############################################################################
|
|
|
|
sub initial_setup () {
|
|
|
|
select(STDOUT);
|
|
$| = 1; # Make unbuffered
|
|
|
|
$glob_scriptname= basename($0);
|
|
|
|
$glob_win32_perl= ($^O eq "MSWin32");
|
|
$glob_cygwin_perl= ($^O eq "cygwin");
|
|
$glob_win32= ($glob_win32_perl or $glob_cygwin_perl);
|
|
|
|
# Use libtool on all platforms except windows
|
|
if ( $glob_win32 )
|
|
{
|
|
$glob_use_libtool= 0;
|
|
}
|
|
|
|
# We require that we are in the "mysql-test" directory
|
|
# to run mysql-test-run
|
|
|
|
if (! -f $glob_scriptname)
|
|
{
|
|
mtr_error("Can't find the location for the mysql-test-run script\n" .
|
|
"Go to to the mysql-test directory and execute the script " .
|
|
"as follows:\n./$glob_scriptname");
|
|
}
|
|
|
|
if ( -d "../sql" )
|
|
{
|
|
$opt_source_dist= 1;
|
|
}
|
|
|
|
$glob_hostname= mtr_short_hostname();
|
|
|
|
# 'basedir' is always parent of "mysql-test" directory
|
|
$glob_mysql_test_dir= cwd();
|
|
if ( $glob_cygwin_perl )
|
|
{
|
|
# Windows programs like 'mysqld' needs Windows paths
|
|
$glob_mysql_test_dir= `cygpath -m "$glob_mysql_test_dir"`;
|
|
my $shell= $ENV{'SHELL'} || "/bin/bash";
|
|
$glob_cygwin_shell= `cygpath -w "$shell"`; # The Windows path c:\...
|
|
chomp($glob_mysql_test_dir);
|
|
chomp($glob_cygwin_shell);
|
|
}
|
|
$glob_basedir= dirname($glob_mysql_test_dir);
|
|
$glob_mysql_bench_dir= "$glob_basedir/mysql-bench"; # FIXME make configurable
|
|
|
|
# needs to be same length to test logging (FIXME what???)
|
|
$path_slave_load_tmpdir= "../../var/tmp";
|
|
|
|
$path_my_basedir=
|
|
$opt_source_dist ? $glob_mysql_test_dir : $glob_basedir;
|
|
|
|
$glob_timers= mtr_init_timers();
|
|
}
|
|
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Default settings
|
|
#
|
|
##############################################################################
|
|
|
|
sub command_line_setup () {
|
|
|
|
# These are defaults for things that are set on the command line
|
|
|
|
$opt_suite= "main"; # Special default suite
|
|
my $opt_master_myport= 9306;
|
|
my $opt_slave_myport= 9308;
|
|
$opt_ndbcluster_port= 9350;
|
|
my $im_port= 9310;
|
|
my $im_mysqld1_port= 9312;
|
|
my $im_mysqld2_port= 9314;
|
|
|
|
#
|
|
# To make it easier for different devs to work on the same host,
|
|
# an environment variable can be used to control all ports. A small
|
|
# number is to be used, 0 - 16 or similar.
|
|
#
|
|
# Note the MASTER_MYPORT has to be set the same in all 4.x and 5.x
|
|
# versions of this script, else a 4.0 test run might conflict with a
|
|
# 5.1 test run, even if different MTR_BUILD_THREAD is used. This means
|
|
# all port numbers might not be used in this version of the script.
|
|
#
|
|
# Also note the limiteation of ports we are allowed to hand out. This
|
|
# differs between operating systems and configuration, see
|
|
# http://www.ncftp.com/ncftpd/doc/misc/ephemeral_ports.html
|
|
# But a fairly safe range seems to be 5001 - 32767
|
|
if ( $ENV{'MTR_BUILD_THREAD'} )
|
|
{
|
|
# Up to two masters, up to three slaves
|
|
$opt_master_myport= $ENV{'MTR_BUILD_THREAD'} * 10 + 10000; # and 1
|
|
$opt_slave_myport= $opt_master_myport + 2; # and 3 4
|
|
$opt_ndbcluster_port= $opt_master_myport + 5;
|
|
$im_port= $opt_master_myport + 6;
|
|
$im_mysqld1_port= $opt_master_myport + 7;
|
|
$im_mysqld2_port= $opt_master_myport + 8;
|
|
}
|
|
|
|
if ( $opt_master_myport < 5001 or $opt_master_myport + 10 >= 32767 )
|
|
{
|
|
mtr_error("MTR_BUILD_THREAD number results in a port",
|
|
"outside 5001 - 32767",
|
|
"($opt_master_myport - $opt_master_myport + 10)");
|
|
}
|
|
|
|
# Read the command line
|
|
# Note: Keep list, and the order, in sync with usage at end of this file
|
|
|
|
Getopt::Long::Configure("pass_through");
|
|
GetOptions(
|
|
# Control what engine/variation to run
|
|
'embedded-server' => \$opt_embedded_server,
|
|
'ps-protocol' => \$opt_ps_protocol,
|
|
'sp-protocol' => \$opt_sp_protocol,
|
|
'view-protocol' => \$opt_view_protocol,
|
|
'cursor-protocol' => \$opt_cursor_protocol,
|
|
'ssl|with-openssl' => \$opt_ssl,
|
|
'skip-ssl' => \$opt_skip_ssl,
|
|
'compress' => \$opt_compress,
|
|
'bench' => \$opt_bench,
|
|
'small-bench' => \$opt_small_bench,
|
|
'no-manager' => \$opt_no_manager, # Currently not used
|
|
|
|
# Control what test suites or cases to run
|
|
'force' => \$opt_force,
|
|
'with-ndbcluster' => \$opt_with_ndbcluster,
|
|
'skip-ndbcluster|skip-ndb' => \$opt_skip_ndbcluster,
|
|
'with-ndbcluster-only' => \$opt_with_ndbcluster_only,
|
|
'do-test=s' => \$opt_do_test,
|
|
'suite=s' => \$opt_suite,
|
|
'skip-rpl' => \$opt_skip_rpl,
|
|
'skip-im' => \$opt_skip_im,
|
|
'skip-test=s' => \$opt_skip_test,
|
|
|
|
# Specify ports
|
|
'master_port=i' => \$opt_master_myport,
|
|
'slave_port=i' => \$opt_slave_myport,
|
|
'ndbcluster_port=i' => \$opt_ndbcluster_port,
|
|
'manager-port=i' => \$opt_manager_port, # Currently not used
|
|
'im-port=i' => \$im_port, # Instance Manager port.
|
|
'im-mysqld1-port=i' => \$im_mysqld1_port, # Port of mysqld, controlled by IM
|
|
'im-mysqld2-port=i' => \$im_mysqld2_port, # Port of mysqld, controlled by IM
|
|
|
|
# Test case authoring
|
|
'record' => \$opt_record,
|
|
'check-testcases' => \$opt_check_testcases,
|
|
|
|
# ???
|
|
'mysqld=s' => \@opt_extra_mysqld_opt,
|
|
|
|
# Run test on running server
|
|
'extern' => \$opt_extern,
|
|
'ndbconnectstring=s' => \$opt_ndbconnectstring,
|
|
|
|
# Debugging
|
|
'gdb' => \$opt_gdb,
|
|
'client-gdb' => \$opt_client_gdb,
|
|
'manual-gdb' => \$opt_manual_gdb,
|
|
'manual-debug' => \$opt_manual_debug,
|
|
'ddd' => \$opt_ddd,
|
|
'client-ddd' => \$opt_client_ddd,
|
|
'debugger=s' => \$opt_debugger,
|
|
'client-debugger=s' => \$opt_client_debugger,
|
|
'strace-client' => \$opt_strace_client,
|
|
'master-binary=s' => \$exe_master_mysqld,
|
|
'slave-binary=s' => \$exe_slave_mysqld,
|
|
|
|
# Coverage, profiling etc
|
|
'gcov' => \$opt_gcov,
|
|
'gprof' => \$opt_gprof,
|
|
'valgrind' => \$opt_valgrind,
|
|
'valgrind-mysqltest' => \$opt_valgrind_mysqltest,
|
|
'valgrind-mysqld' => \$opt_valgrind_mysqld,
|
|
'valgrind-all' => \$opt_valgrind_all,
|
|
'valgrind-options=s' => \$opt_valgrind_options,
|
|
'valgrind-path=s' => \$opt_valgrind_path,
|
|
|
|
# Stress testing
|
|
'stress' => \$opt_stress,
|
|
'stress-suite=s' => \$opt_stress_suite,
|
|
'stress-threads=i' => \$opt_stress_threads,
|
|
'stress-test-file=s' => \$opt_stress_test_file,
|
|
'stress-init-file=s' => \$opt_stress_init_file,
|
|
'stress-mode=s' => \$opt_stress_mode,
|
|
'stress-loop-count=i' => \$opt_stress_loop_count,
|
|
'stress-test-count=i' => \$opt_stress_test_count,
|
|
'stress-test-duration=i' => \$opt_stress_test_duration,
|
|
|
|
# Directories
|
|
'tmpdir=s' => \$opt_tmpdir,
|
|
'vardir=s' => \$opt_vardir,
|
|
|
|
# Misc
|
|
'big-test' => \$opt_big_test,
|
|
'comment=s' => \$opt_comment,
|
|
'debug' => \$opt_debug,
|
|
'fast' => \$opt_fast,
|
|
'local' => \$opt_local,
|
|
'local-master' => \$opt_local_master,
|
|
'netware' => \$opt_netware,
|
|
'old-master' => \$opt_old_master,
|
|
'reorder' => \$opt_reorder,
|
|
'script-debug' => \$opt_script_debug,
|
|
'sleep=i' => \$opt_sleep,
|
|
'socket=s' => \$opt_socket,
|
|
'start-dirty' => \$opt_start_dirty,
|
|
'start-and-exit' => \$opt_start_and_exit,
|
|
'start-from=s' => \$opt_start_from,
|
|
'timer' => \$opt_timer,
|
|
'unified-diff|udiff' => \$opt_udiff,
|
|
'user-test=s' => \$opt_user_test,
|
|
'user=s' => \$opt_user,
|
|
'wait-timeout=i' => \$opt_wait_timeout,
|
|
'testcase-timeout=i' => \$opt_testcase_timeout,
|
|
'suite-timeout=i' => \$opt_suite_timeout,
|
|
'warnings|log-warnings' => \$opt_warnings,
|
|
|
|
'help|h' => \$opt_usage,
|
|
) or usage("Can't read options");
|
|
|
|
if ( $opt_usage )
|
|
{
|
|
usage("");
|
|
}
|
|
|
|
if ( $opt_comment )
|
|
{
|
|
print "\n";
|
|
print '#' x 78, "\n";
|
|
print "# $opt_comment\n";
|
|
print '#' x 78, "\n\n";
|
|
}
|
|
|
|
if ( $opt_with_ndbcluster_only )
|
|
{
|
|
print "# Option '--with-ndbcluster-only' is ignored in this release.\n";
|
|
}
|
|
|
|
foreach my $arg ( @ARGV )
|
|
{
|
|
if ( $arg =~ /^--skip-/ )
|
|
{
|
|
push(@opt_extra_mysqld_opt, $arg);
|
|
}
|
|
elsif ( $arg =~ /^-/ )
|
|
{
|
|
usage("Invalid option \"$arg\"");
|
|
}
|
|
else
|
|
{
|
|
push(@opt_cases, $arg);
|
|
}
|
|
}
|
|
|
|
# --------------------------------------------------------------------------
|
|
# Set the "var/" directory, as it is the base for everything else
|
|
# --------------------------------------------------------------------------
|
|
|
|
if ( ! $opt_vardir )
|
|
{
|
|
$opt_vardir= "$glob_mysql_test_dir/var";
|
|
}
|
|
$opt_vardir_trace= $opt_vardir;
|
|
# Chop off any "c:", DBUG likes a unix path ex: c:/src/... => /src/...
|
|
$opt_vardir_trace=~ s/^\w://;
|
|
|
|
# We make the path absolute, as the server will do a chdir() before usage
|
|
unless ( $opt_vardir =~ m,^/, or
|
|
($glob_win32 and $opt_vardir =~ m,^[a-z]:/,i) )
|
|
{
|
|
# Make absolute path, relative test dir
|
|
$opt_vardir= "$glob_mysql_test_dir/$opt_vardir";
|
|
}
|
|
|
|
# --------------------------------------------------------------------------
|
|
# If not set, set these to defaults
|
|
# --------------------------------------------------------------------------
|
|
|
|
$opt_tmpdir= "$opt_vardir/tmp" unless $opt_tmpdir;
|
|
$opt_tmpdir =~ s,/+$,,; # Remove ending slash if any
|
|
# FIXME maybe not needed?
|
|
$path_manager_log= "$opt_vardir/log/manager.log"
|
|
unless $path_manager_log;
|
|
$opt_current_test= "$opt_vardir/log/current_test"
|
|
unless $opt_current_test;
|
|
|
|
# --------------------------------------------------------------------------
|
|
# Do sanity checks of command line arguments
|
|
# --------------------------------------------------------------------------
|
|
|
|
if ( $opt_extern and $opt_local )
|
|
{
|
|
mtr_error("Can't use --extern and --local at the same time");
|
|
}
|
|
|
|
if ( ! $opt_socket )
|
|
{ # FIXME set default before reading options?
|
|
# $opt_socket= '@MYSQL_UNIX_ADDR@';
|
|
$opt_socket= "/tmp/mysql.sock"; # FIXME
|
|
}
|
|
|
|
# --------------------------------------------------------------------------
|
|
# Look at the command line options and set script flags
|
|
# --------------------------------------------------------------------------
|
|
|
|
if ( $opt_record and ! @opt_cases )
|
|
{
|
|
mtr_error("Will not run in record mode without a specific test case");
|
|
}
|
|
|
|
if ( $opt_embedded_server )
|
|
{
|
|
$glob_use_embedded_server= 1;
|
|
push(@glob_test_mode, "embedded");
|
|
$opt_skip_rpl= 1; # We never run replication with embedded
|
|
|
|
if ( $opt_extern )
|
|
{
|
|
mtr_error("Can't use --extern with --embedded-server");
|
|
}
|
|
}
|
|
|
|
if ( $opt_ps_protocol )
|
|
{
|
|
push(@glob_test_mode, "ps-protocol");
|
|
}
|
|
|
|
# FIXME don't understand what this is
|
|
# if ( $opt_local_master )
|
|
# {
|
|
# $opt_master_myport= 3306;
|
|
# }
|
|
|
|
if ( $opt_small_bench )
|
|
{
|
|
$opt_bench= 1;
|
|
}
|
|
|
|
if ( $opt_sleep )
|
|
{
|
|
$opt_sleep_time_after_restart= $opt_sleep;
|
|
}
|
|
|
|
if ( $opt_gcov and ! $opt_source_dist )
|
|
{
|
|
mtr_error("Coverage test needs the source - please use source dist");
|
|
}
|
|
|
|
# Check debug related options
|
|
if ( $opt_gdb || $opt_client_gdb || $opt_ddd || $opt_client_ddd ||
|
|
$opt_manual_gdb || $opt_manual_ddd || $opt_manual_debug ||
|
|
$opt_debugger || $opt_client_debugger )
|
|
{
|
|
# Indicate that we are using debugger
|
|
$glob_debugger= 1;
|
|
# Increase timeouts
|
|
$opt_wait_timeout= 300;
|
|
if ( $opt_extern )
|
|
{
|
|
mtr_error("Can't use --extern when using debugger");
|
|
}
|
|
}
|
|
|
|
if ( $opt_ndbconnectstring )
|
|
{
|
|
$glob_use_running_ndbcluster= 1;
|
|
$opt_with_ndbcluster= 1;
|
|
}
|
|
else
|
|
{
|
|
$opt_ndbconnectstring= "host=localhost:$opt_ndbcluster_port";
|
|
}
|
|
|
|
if ( $opt_skip_ndbcluster )
|
|
{
|
|
$opt_with_ndbcluster= 0;
|
|
}
|
|
|
|
# Turn on valgrinding of all executables if "valgrind" or "valgrind-all"
|
|
if ( $opt_valgrind or $opt_valgrind_all )
|
|
{
|
|
mtr_report("Turning on valgrind for all executables");
|
|
$opt_valgrind= 1;
|
|
$opt_valgrind_mysqld= 1;
|
|
$opt_valgrind_mysqltest= 1;
|
|
}
|
|
elsif ( $opt_valgrind_mysqld or $opt_valgrind_mysqltest )
|
|
{
|
|
# If test's are run for a specific executable, turn on
|
|
# verbose and show-reachable
|
|
$opt_valgrind= 1;
|
|
$opt_valgrind_all= 1;
|
|
}
|
|
|
|
if ( ! $opt_testcase_timeout )
|
|
{
|
|
$opt_testcase_timeout= $default_testcase_timeout;
|
|
$opt_testcase_timeout*= 10 if defined $opt_valgrind;
|
|
}
|
|
|
|
if ( ! $opt_suite_timeout )
|
|
{
|
|
$opt_suite_timeout= $default_suite_timeout;
|
|
$opt_suite_timeout*= 4 if defined $opt_valgrind;
|
|
}
|
|
|
|
# Increase times to wait for executables to start if using valgrind
|
|
if ( $opt_valgrind )
|
|
{
|
|
$opt_sleep_time_after_restart= 10;
|
|
$opt_sleep_time_for_delete= 60;
|
|
}
|
|
|
|
if ( ! $opt_user )
|
|
{
|
|
if ( $glob_use_running_server )
|
|
{
|
|
$opt_user= "test";
|
|
}
|
|
else
|
|
{
|
|
$opt_user= "root"; # We want to do FLUSH xxx commands
|
|
}
|
|
}
|
|
|
|
# On QNX, /tmp/dir/master.sock and /tmp/dir//master.sock seem to be
|
|
# considered different, so avoid the extra slash (/) in the socket
|
|
# paths.
|
|
my $sockdir = $opt_tmpdir;
|
|
$sockdir =~ s|/+$||;
|
|
|
|
# Put this into a hash, will be a C struct
|
|
|
|
$master->[0]=
|
|
{
|
|
path_myddir => "$opt_vardir/master-data",
|
|
path_myerr => "$opt_vardir/log/master.err",
|
|
path_mylog => "$opt_vardir/log/master.log",
|
|
path_mypid => "$opt_vardir/run/master.pid",
|
|
path_mysock => "$sockdir/master.sock",
|
|
path_myport => $opt_master_myport,
|
|
start_timeout => 400, # enough time create innodb tables
|
|
|
|
ndbcluster => 1, # ndbcluster not started
|
|
};
|
|
|
|
$master->[1]=
|
|
{
|
|
path_myddir => "$opt_vardir/master1-data",
|
|
path_myerr => "$opt_vardir/log/master1.err",
|
|
path_mylog => "$opt_vardir/log/master1.log",
|
|
path_mypid => "$opt_vardir/run/master1.pid",
|
|
path_mysock => "$sockdir/master1.sock",
|
|
path_myport => $opt_master_myport + 1,
|
|
start_timeout => 400, # enough time create innodb tables
|
|
};
|
|
|
|
$slave->[0]=
|
|
{
|
|
path_myddir => "$opt_vardir/slave-data",
|
|
path_myerr => "$opt_vardir/log/slave.err",
|
|
path_mylog => "$opt_vardir/log/slave.log",
|
|
path_mypid => "$opt_vardir/run/slave.pid",
|
|
path_mysock => "$sockdir/slave.sock",
|
|
path_myport => $opt_slave_myport,
|
|
start_timeout => 400,
|
|
};
|
|
|
|
$slave->[1]=
|
|
{
|
|
path_myddir => "$opt_vardir/slave1-data",
|
|
path_myerr => "$opt_vardir/log/slave1.err",
|
|
path_mylog => "$opt_vardir/log/slave1.log",
|
|
path_mypid => "$opt_vardir/run/slave1.pid",
|
|
path_mysock => "$sockdir/slave1.sock",
|
|
path_myport => $opt_slave_myport + 1,
|
|
start_timeout => 300,
|
|
};
|
|
|
|
$slave->[2]=
|
|
{
|
|
path_myddir => "$opt_vardir/slave2-data",
|
|
path_myerr => "$opt_vardir/log/slave2.err",
|
|
path_mylog => "$opt_vardir/log/slave2.log",
|
|
path_mypid => "$opt_vardir/run/slave2.pid",
|
|
path_mysock => "$sockdir/slave2.sock",
|
|
path_myport => $opt_slave_myport + 2,
|
|
start_timeout => 300,
|
|
};
|
|
|
|
$instance_manager=
|
|
{
|
|
path_err => "$opt_vardir/log/im.err",
|
|
path_log => "$opt_vardir/log/im.log",
|
|
path_pid => "$opt_vardir/run/im.pid",
|
|
path_sock => "$sockdir/im.sock",
|
|
port => $im_port,
|
|
start_timeout => $master->[0]->{'start_timeout'},
|
|
admin_login => 'im_admin',
|
|
admin_password => 'im_admin_secret',
|
|
admin_sha1 => '*598D51AD2DFF7792045D6DF3DDF9AA1AF737B295',
|
|
password_file => "$opt_vardir/im.passwd",
|
|
defaults_file => "$opt_vardir/im.cnf",
|
|
};
|
|
|
|
$instance_manager->{'instances'}->[0]=
|
|
{
|
|
server_id => 1,
|
|
port => $im_mysqld1_port,
|
|
path_datadir => "$opt_vardir/im_mysqld_1.data",
|
|
path_sock => "$sockdir/mysqld_1.sock",
|
|
path_pid => "$opt_vardir/run/mysqld_1.pid",
|
|
};
|
|
|
|
$instance_manager->{'instances'}->[1]=
|
|
{
|
|
server_id => 2,
|
|
port => $im_mysqld2_port,
|
|
path_datadir => "$opt_vardir/im_mysqld_2.data",
|
|
path_sock => "$sockdir/mysqld_2.sock",
|
|
path_pid => "$opt_vardir/run/mysqld_2.pid",
|
|
nonguarded => 1,
|
|
};
|
|
|
|
if ( $opt_extern )
|
|
{
|
|
$glob_use_running_server= 1;
|
|
$opt_skip_rpl= 1; # We don't run rpl test cases
|
|
$master->[0]->{'path_mysock'}= $opt_socket;
|
|
}
|
|
|
|
$path_timefile= "$opt_vardir/log/mysqltest-time";
|
|
$path_mysqltest_log= "$opt_vardir/log/mysqltest.log";
|
|
|
|
$path_snapshot= "$opt_tmpdir/snapshot_$opt_master_myport/";
|
|
}
|
|
|
|
sub snapshot_setup () {
|
|
|
|
# Make a list of all data_dirs
|
|
@data_dir_lst = (
|
|
$master->[0]->{'path_myddir'},
|
|
$master->[1]->{'path_myddir'});
|
|
|
|
unless ($opt_skip_rpl)
|
|
{
|
|
push @data_dir_lst, ($slave->[0]->{'path_myddir'},
|
|
$slave->[1]->{'path_myddir'},
|
|
$slave->[2]->{'path_myddir'});
|
|
}
|
|
|
|
unless ($opt_skip_im)
|
|
{
|
|
foreach my $instance (@{$instance_manager->{'instances'}})
|
|
{
|
|
push(@data_dir_lst, $instance->{'path_datadir'});
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Set paths to various executable programs
|
|
#
|
|
##############################################################################
|
|
|
|
sub executable_setup () {
|
|
|
|
if ( $opt_source_dist )
|
|
{
|
|
if ( $glob_win32 )
|
|
{
|
|
$path_client_bindir= mtr_path_exists("$glob_basedir/client_release",
|
|
"$glob_basedir/client_debug",
|
|
"$glob_basedir/bin",);
|
|
$exe_mysqld= mtr_exe_exists ("$path_client_bindir/mysqld-max",
|
|
"$path_client_bindir/mysqld-nt",
|
|
"$path_client_bindir/mysqld",
|
|
"$path_client_bindir/mysqld-debug",
|
|
"$path_client_bindir/mysqld-max");
|
|
$path_language= mtr_path_exists("$glob_basedir/share/english/");
|
|
$path_charsetsdir= mtr_path_exists("$glob_basedir/share/charsets");
|
|
$exe_my_print_defaults=
|
|
mtr_exe_exists("$path_client_bindir/my_print_defaults");
|
|
}
|
|
else
|
|
{
|
|
$path_client_bindir= mtr_path_exists("$glob_basedir/client");
|
|
$exe_mysqld= mtr_exe_exists ("$glob_basedir/sql/mysqld");
|
|
$path_language= mtr_path_exists("$glob_basedir/sql/share/english/");
|
|
$path_charsetsdir= mtr_path_exists("$glob_basedir/sql/share/charsets");
|
|
|
|
$exe_im= mtr_exe_exists(
|
|
"$glob_basedir/server-tools/instance-manager/mysqlmanager");
|
|
$exe_my_print_defaults=
|
|
mtr_exe_exists("$glob_basedir/extra/my_print_defaults");
|
|
}
|
|
|
|
if ( $glob_use_embedded_server )
|
|
{
|
|
my $path_examples= "$glob_basedir/libmysqld/examples";
|
|
$exe_mysqltest= mtr_exe_exists("$path_examples/mysqltest_embedded");
|
|
$exe_mysql_client_test=
|
|
mtr_exe_exists("$path_examples/mysql_client_test_embedded",
|
|
"/usr/bin/false");
|
|
}
|
|
else
|
|
{
|
|
$exe_mysqltest= mtr_exe_exists("$path_client_bindir/mysqltest");
|
|
$exe_mysql_client_test=
|
|
mtr_exe_exists("$glob_basedir/tests/mysql_client_test",
|
|
"$path_client_bindir/mysql_client_test",
|
|
"/usr/bin/false");
|
|
}
|
|
$exe_mysqlcheck= mtr_exe_exists("$path_client_bindir/mysqlcheck");
|
|
$exe_mysqldump= mtr_exe_exists("$path_client_bindir/mysqldump");
|
|
$exe_mysqlimport= mtr_exe_exists("$path_client_bindir/mysqlimport");
|
|
$exe_mysqlshow= mtr_exe_exists("$path_client_bindir/mysqlshow");
|
|
$exe_mysqlbinlog= mtr_exe_exists("$path_client_bindir/mysqlbinlog");
|
|
$exe_mysqladmin= mtr_exe_exists("$path_client_bindir/mysqladmin");
|
|
$exe_mysql= mtr_exe_exists("$path_client_bindir/mysql");
|
|
$exe_mysql_fix_system_tables=
|
|
mtr_script_exists("$glob_basedir/scripts/mysql_fix_privilege_tables");
|
|
$path_ndb_tools_dir= mtr_path_exists("$glob_basedir/ndb/tools");
|
|
$exe_ndb_mgm= "$glob_basedir/ndb/src/mgmclient/ndb_mgm";
|
|
}
|
|
else
|
|
{
|
|
$path_client_bindir= mtr_path_exists("$glob_basedir/bin");
|
|
$exe_mysqlcheck= mtr_exe_exists("$path_client_bindir/mysqlcheck");
|
|
$exe_mysqldump= mtr_exe_exists("$path_client_bindir/mysqldump");
|
|
$exe_mysqlimport= mtr_exe_exists("$path_client_bindir/mysqlimport");
|
|
$exe_mysqlshow= mtr_exe_exists("$path_client_bindir/mysqlshow");
|
|
$exe_mysqlbinlog= mtr_exe_exists("$path_client_bindir/mysqlbinlog");
|
|
$exe_mysqladmin= mtr_exe_exists("$path_client_bindir/mysqladmin");
|
|
$exe_mysql= mtr_exe_exists("$path_client_bindir/mysql");
|
|
$exe_mysql_fix_system_tables=
|
|
mtr_script_exists("$path_client_bindir/mysql_fix_privilege_tables",
|
|
"$glob_basedir/scripts/mysql_fix_privilege_tables");
|
|
$exe_my_print_defaults=
|
|
mtr_exe_exists("$path_client_bindir/my_print_defaults");
|
|
|
|
$path_language= mtr_path_exists("$glob_basedir/share/mysql/english/",
|
|
"$glob_basedir/share/english/");
|
|
$path_charsetsdir= mtr_path_exists("$glob_basedir/share/mysql/charsets",
|
|
"$glob_basedir/share/charsets");
|
|
|
|
if ( $glob_win32 )
|
|
{
|
|
$exe_mysqld= mtr_exe_exists ("$glob_basedir/bin/mysqld-nt",
|
|
"$glob_basedir/bin/mysqld",
|
|
"$glob_basedir/bin/mysqld-debug",);
|
|
}
|
|
else
|
|
{
|
|
$exe_mysqld= mtr_exe_exists ("$glob_basedir/libexec/mysqld",
|
|
"$glob_basedir/bin/mysqld");
|
|
}
|
|
$exe_im= mtr_exe_exists("$glob_basedir/libexec/mysqlmanager",
|
|
"$glob_basedir/bin/mysqlmanager");
|
|
if ( $glob_use_embedded_server )
|
|
{
|
|
$exe_mysqltest= mtr_exe_exists("$path_client_bindir/mysqltest_embedded");
|
|
$exe_mysql_client_test=
|
|
mtr_exe_exists("$glob_basedir/tests/mysql_client_test_embedded",
|
|
"$path_client_bindir/mysql_client_test_embedded",
|
|
"/usr/bin/false");
|
|
}
|
|
else
|
|
{
|
|
$exe_mysqltest= mtr_exe_exists("$path_client_bindir/mysqltest");
|
|
$exe_mysql_client_test=
|
|
mtr_exe_exists("$path_client_bindir/mysql_client_test",
|
|
"/usr/bin/false"); # FIXME temporary
|
|
}
|
|
|
|
$path_ndb_tools_dir= "$glob_basedir/bin";
|
|
$exe_ndb_mgm= "$glob_basedir/bin/ndb_mgm";
|
|
}
|
|
|
|
$exe_master_mysqld= $exe_master_mysqld || $exe_mysqld;
|
|
$exe_slave_mysqld= $exe_slave_mysqld || $exe_mysqld;
|
|
|
|
$path_ndb_data_dir= "$opt_vardir/ndbcluster-$opt_ndbcluster_port";
|
|
$file_ndb_testrun_log= "$opt_vardir/log/ndb_testrun.log";
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Set environment to be used by childs of this process
|
|
#
|
|
##############################################################################
|
|
|
|
# Note that some env is setup in spawn/run, in "mtr_process.pl"
|
|
|
|
sub environment_setup () {
|
|
|
|
# --------------------------------------------------------------------------
|
|
# We might not use a standard installation directory, like /usr/lib.
|
|
# Set LD_LIBRARY_PATH to make sure we find our installed libraries.
|
|
# --------------------------------------------------------------------------
|
|
|
|
unless ( $opt_source_dist )
|
|
{
|
|
$ENV{'LD_LIBRARY_PATH'}=
|
|
"$glob_basedir/lib" .
|
|
($ENV{'LD_LIBRARY_PATH'} ? ":$ENV{'LD_LIBRARY_PATH'}" : "");
|
|
$ENV{'DYLD_LIBRARY_PATH'}=
|
|
"$glob_basedir/lib" .
|
|
($ENV{'DYLD_LIBRARY_PATH'} ? ":$ENV{'DYLD_LIBRARY_PATH'}" : "");
|
|
}
|
|
|
|
# --------------------------------------------------------------------------
|
|
# Add the path where mysqld will find udf_example.so
|
|
# --------------------------------------------------------------------------
|
|
$ENV{'LD_LIBRARY_PATH'}=
|
|
"$glob_basedir/sql/.libs" .
|
|
($ENV{'LD_LIBRARY_PATH'} ? ":$ENV{'LD_LIBRARY_PATH'}" : "");
|
|
|
|
|
|
# --------------------------------------------------------------------------
|
|
# Also command lines in .opt files may contain env vars
|
|
# --------------------------------------------------------------------------
|
|
|
|
$ENV{'UMASK'}= "0660"; # The octal *string*
|
|
$ENV{'UMASK_DIR'}= "0770"; # The octal *string*
|
|
$ENV{'LC_COLLATE'}= "C";
|
|
$ENV{'USE_RUNNING_SERVER'}= $glob_use_running_server;
|
|
$ENV{'MYSQL_TEST_DIR'}= $glob_mysql_test_dir;
|
|
$ENV{'MYSQLTEST_VARDIR'}= $opt_vardir;
|
|
$ENV{'MYSQL_TMP_DIR'}= $opt_tmpdir;
|
|
$ENV{'MASTER_MYSOCK'}= $master->[0]->{'path_mysock'};
|
|
$ENV{'MASTER_MYSOCK1'}= $master->[1]->{'path_mysock'};
|
|
$ENV{'MASTER_MYPORT'}= $master->[0]->{'path_myport'};
|
|
$ENV{'MASTER_MYPORT1'}= $master->[1]->{'path_myport'};
|
|
$ENV{'SLAVE_MYPORT'}= $slave->[0]->{'path_myport'};
|
|
$ENV{'SLAVE_MYPORT1'}= $slave->[1]->{'path_myport'};
|
|
$ENV{'SLAVE_MYPORT2'}= $slave->[2]->{'path_myport'};
|
|
# $ENV{'MYSQL_TCP_PORT'}= '@MYSQL_TCP_PORT@'; # FIXME
|
|
$ENV{'MYSQL_TCP_PORT'}= 3306;
|
|
|
|
$ENV{'NDBCLUSTER_PORT'}= $opt_ndbcluster_port;
|
|
|
|
$ENV{'IM_PATH_PID'}= $instance_manager->{path_pid};
|
|
$ENV{'IM_PORT'}= $instance_manager->{port};
|
|
|
|
$ENV{'IM_MYSQLD1_SOCK'}= $instance_manager->{instances}->[0]->{path_sock};
|
|
$ENV{'IM_MYSQLD1_PORT'}= $instance_manager->{instances}->[0]->{port};
|
|
$ENV{'IM_MYSQLD1_PATH_PID'}=$instance_manager->{instances}->[0]->{path_pid};
|
|
$ENV{'IM_MYSQLD2_SOCK'}= $instance_manager->{instances}->[1]->{path_sock};
|
|
$ENV{'IM_MYSQLD2_PORT'}= $instance_manager->{instances}->[1]->{port};
|
|
$ENV{'IM_MYSQLD2_PATH_PID'}=$instance_manager->{instances}->[1]->{path_pid};
|
|
|
|
$ENV{MTR_BUILD_THREAD}= 0 unless $ENV{MTR_BUILD_THREAD}; # Set if not set
|
|
|
|
# We are nice and report a bit about our settings
|
|
print "Using MTR_BUILD_THREAD = $ENV{MTR_BUILD_THREAD}\n";
|
|
print "Using MASTER_MYPORT = $ENV{MASTER_MYPORT}\n";
|
|
print "Using MASTER_MYPORT1 = $ENV{MASTER_MYPORT1}\n";
|
|
print "Using SLAVE_MYPORT = $ENV{SLAVE_MYPORT}\n";
|
|
print "Using SLAVE_MYPORT1 = $ENV{SLAVE_MYPORT1}\n";
|
|
print "Using SLAVE_MYPORT2 = $ENV{SLAVE_MYPORT2}\n";
|
|
print "Using NDBCLUSTER_PORT = $ENV{NDBCLUSTER_PORT}\n";
|
|
print "Using IM_PORT = $ENV{IM_PORT}\n";
|
|
print "Using IM_MYSQLD1_PORT = $ENV{IM_MYSQLD1_PORT}\n";
|
|
print "Using IM_MYSQLD2_PORT = $ENV{IM_MYSQLD2_PORT}\n";
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# If we get a ^C, we try to clean up before termination
|
|
#
|
|
##############################################################################
|
|
# FIXME check restrictions what to do in a signal handler
|
|
|
|
sub signal_setup () {
|
|
$SIG{INT}= \&handle_int_signal;
|
|
}
|
|
|
|
sub handle_int_signal () {
|
|
$SIG{INT}= 'DEFAULT'; # If we get a ^C again, we die...
|
|
mtr_warning("got INT signal, cleaning up.....");
|
|
stop_masters_slaves();
|
|
mtr_error("We die from ^C signal from user");
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Handle left overs from previous runs
|
|
#
|
|
##############################################################################
|
|
|
|
sub kill_running_server () {
|
|
|
|
if ( $opt_fast or $glob_use_embedded_server )
|
|
{
|
|
# FIXME is embedded server really using PID files?!
|
|
unlink($master->[0]->{'path_mypid'});
|
|
unlink($master->[1]->{'path_mypid'});
|
|
unlink($slave->[0]->{'path_mypid'});
|
|
unlink($slave->[1]->{'path_mypid'});
|
|
unlink($slave->[2]->{'path_mypid'});
|
|
}
|
|
else
|
|
{
|
|
# Ensure that no old mysqld test servers are running
|
|
# This is different from terminating processes we have
|
|
# started from ths run of the script, this is terminating
|
|
# leftovers from previous runs.
|
|
|
|
mtr_report("Killing Possible Leftover Processes");
|
|
mkpath("$opt_vardir/log"); # Needed for mysqladmin log
|
|
mtr_kill_leftovers();
|
|
|
|
$using_ndbcluster_master= $opt_with_ndbcluster;
|
|
ndbcluster_stop();
|
|
$master->[0]->{'ndbcluster'}= 1;
|
|
}
|
|
}
|
|
|
|
sub kill_and_cleanup () {
|
|
|
|
kill_running_server ();
|
|
|
|
mtr_report("Removing Stale Files");
|
|
|
|
if ( $opt_vardir eq "$glob_mysql_test_dir/var" )
|
|
{
|
|
#
|
|
# Running with "var" in mysql-test dir
|
|
#
|
|
if ( -l "$glob_mysql_test_dir/var" )
|
|
{
|
|
# Some users creates a soft link in mysql-test/var to another area
|
|
# - allow it
|
|
mtr_report("WARNING: Using the 'mysql-test/var' symlink");
|
|
rmtree("$opt_vardir/log");
|
|
rmtree("$opt_vardir/ndbcluster-$opt_ndbcluster_port");
|
|
rmtree("$opt_vardir/run");
|
|
rmtree("$opt_vardir/tmp");
|
|
}
|
|
else
|
|
{
|
|
# Remove the entire "var" dir
|
|
rmtree("$opt_vardir/");
|
|
}
|
|
}
|
|
else
|
|
{
|
|
#
|
|
# Running with "var" in some other place
|
|
#
|
|
|
|
# Remove the var/ dir in mysql-test dir if any
|
|
# this could be an old symlink that shouldn't be there
|
|
rmtree("$glob_mysql_test_dir/var");
|
|
|
|
# Remove the "var" dir
|
|
rmtree("$opt_vardir/");
|
|
}
|
|
|
|
mkpath("$opt_vardir/log");
|
|
mkpath("$opt_vardir/run");
|
|
mkpath("$opt_vardir/tmp");
|
|
mkpath($opt_tmpdir) if $opt_tmpdir ne "$opt_vardir/tmp";
|
|
|
|
# Remove old and create new data dirs
|
|
foreach my $data_dir (@data_dir_lst)
|
|
{
|
|
rmtree("$data_dir");
|
|
mkpath("$data_dir/mysql");
|
|
mkpath("$data_dir/test");
|
|
}
|
|
|
|
# Make a link std_data_ln in var/ that points to std_data
|
|
if ( ! $glob_win32 )
|
|
{
|
|
symlink("$glob_mysql_test_dir/std_data", "$opt_vardir/std_data_ln");
|
|
}
|
|
else
|
|
{
|
|
# on windows, copy all files from std_data into var/std_data_ln
|
|
mkpath("$opt_vardir/std_data_ln");
|
|
opendir(DIR, "$glob_mysql_test_dir/std_data")
|
|
or mtr_error("Can't find the std_data directory: $!");
|
|
for(readdir(DIR)) {
|
|
next if -d "$glob_mysql_test_dir/std_data/$_";
|
|
copy("$glob_mysql_test_dir/std_data/$_", "$opt_vardir/std_data_ln/$_");
|
|
}
|
|
closedir(DIR);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
sub check_ssl_support () {
|
|
|
|
if ($opt_skip_ssl)
|
|
{
|
|
mtr_report("Skipping SSL");
|
|
$opt_ssl_supported= 0;
|
|
$opt_ssl= 0;
|
|
return;
|
|
}
|
|
|
|
# check ssl support by testing using a switch
|
|
# that is only available in that case
|
|
if ( mtr_run($exe_mysqld,
|
|
["--no-defaults",
|
|
"--ssl",
|
|
"--help"],
|
|
"", "/dev/null", "/dev/null", "") != 0 )
|
|
{
|
|
if ( $opt_ssl)
|
|
{
|
|
mtr_error("Couldn't find support for SSL");
|
|
return;
|
|
}
|
|
mtr_report("Skipping SSL, mysqld not compiled with SSL");
|
|
$opt_ssl_supported= 0;
|
|
$opt_ssl= 0;
|
|
return;
|
|
}
|
|
mtr_report("Setting mysqld to support SSL connections");
|
|
$opt_ssl_supported= 1;
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Start the ndb cluster
|
|
#
|
|
##############################################################################
|
|
|
|
sub check_ndbcluster_support () {
|
|
|
|
if ($opt_skip_ndbcluster)
|
|
{
|
|
mtr_report("Skipping ndbcluster");
|
|
$opt_with_ndbcluster= 0;
|
|
return;
|
|
}
|
|
|
|
if ($opt_with_ndbcluster)
|
|
{
|
|
mtr_report("Using ndbcluster if necessary");
|
|
return;
|
|
}
|
|
|
|
# check ndbcluster support by testing using a switch
|
|
# that is only available in that case
|
|
if ( mtr_run($exe_mysqld,
|
|
["--no-defaults",
|
|
"--ndb-use-exact-count",
|
|
"--help"],
|
|
"", "/dev/null", "/dev/null", "") != 0 )
|
|
{
|
|
mtr_report("Skipping ndbcluster, mysqld not compiled with ndbcluster");
|
|
$opt_with_ndbcluster= 0;
|
|
return;
|
|
}
|
|
mtr_report("Using ndbcluster if necessary, mysqld supports it");
|
|
$opt_with_ndbcluster= 1;
|
|
return;
|
|
}
|
|
|
|
# FIXME why is there a different start below?!
|
|
|
|
sub ndbcluster_install () {
|
|
|
|
if ( ! $opt_with_ndbcluster or $glob_use_running_ndbcluster )
|
|
{
|
|
return 0;
|
|
}
|
|
mtr_report("Install ndbcluster");
|
|
my $ndbcluster_opts= $opt_bench ? "" : "--small";
|
|
if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster",
|
|
["--port=$opt_ndbcluster_port",
|
|
"--data-dir=$opt_vardir",
|
|
$ndbcluster_opts,
|
|
"--initial"],
|
|
"", "", "", "") )
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
$using_ndbcluster_master= 1;
|
|
ndbcluster_stop();
|
|
$master->[0]->{'ndbcluster'}= 1;
|
|
|
|
return 0;
|
|
}
|
|
|
|
sub ndbcluster_start ($) {
|
|
my $use_ndbcluster= shift;
|
|
|
|
if ( ! $use_ndbcluster )
|
|
{
|
|
$using_ndbcluster_master= 0;
|
|
return 0;
|
|
}
|
|
if ( $glob_use_running_ndbcluster )
|
|
{
|
|
$using_ndbcluster_master= 1;
|
|
return 0;
|
|
}
|
|
if ( $using_ndbcluster_master )
|
|
{
|
|
# Master already started
|
|
return 0;
|
|
}
|
|
# FIXME, we want to _append_ output to file $file_ndb_testrun_log instead of /dev/null
|
|
if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster",
|
|
["--port=$opt_ndbcluster_port",
|
|
"--data-dir=$opt_vardir"],
|
|
"", "/dev/null", "", "") )
|
|
{
|
|
mtr_error("Error ndbcluster_start");
|
|
return 1;
|
|
}
|
|
|
|
$using_ndbcluster_master= 1;
|
|
return 0;
|
|
}
|
|
|
|
sub ndbcluster_stop () {
|
|
if ( ! $using_ndbcluster_master or $glob_use_running_ndbcluster )
|
|
{
|
|
$using_ndbcluster_master= 0;
|
|
return;
|
|
}
|
|
# FIXME, we want to _append_ output to file $file_ndb_testrun_log instead of /dev/null
|
|
mtr_run("$glob_mysql_test_dir/ndb/ndbcluster",
|
|
["--port=$opt_ndbcluster_port",
|
|
"--data-dir=$opt_vardir",
|
|
"--stop"],
|
|
"", "/dev/null", "", "");
|
|
|
|
$using_ndbcluster_master= 0;
|
|
return;
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Run the benchmark suite
|
|
#
|
|
##############################################################################
|
|
|
|
sub run_benchmarks ($) {
|
|
my $benchmark= shift;
|
|
|
|
my $args;
|
|
|
|
if ( ! $glob_use_embedded_server and ! $opt_local_master )
|
|
{
|
|
$master->[0]->{'pid'}= mysqld_start('master',0,[],[],
|
|
$using_ndbcluster_master);
|
|
if ( ! $master->[0]->{'pid'} )
|
|
{
|
|
mtr_error("Can't start the mysqld server");
|
|
}
|
|
}
|
|
|
|
mtr_init_args(\$args);
|
|
|
|
mtr_add_arg($args, "--socket=%s", $master->[0]->{'path_mysock'});
|
|
mtr_add_arg($args, "--user=%s", $opt_user);
|
|
|
|
if ( $opt_small_bench )
|
|
{
|
|
mtr_add_arg($args, "--small-test");
|
|
mtr_add_arg($args, "--small-tables");
|
|
}
|
|
|
|
if ( $opt_with_ndbcluster )
|
|
{
|
|
mtr_add_arg($args, "--create-options=TYPE=ndb");
|
|
}
|
|
|
|
my $benchdir= "$glob_basedir/sql-bench";
|
|
chdir($benchdir); # FIXME check error
|
|
|
|
# FIXME write shorter....
|
|
|
|
if ( ! $benchmark )
|
|
{
|
|
mtr_add_arg($args, "--log");
|
|
mtr_run("$glob_mysql_bench_dir/run-all-tests", $args, "", "", "", "");
|
|
# FIXME check result code?!
|
|
}
|
|
elsif ( -x $benchmark )
|
|
{
|
|
mtr_run("$glob_mysql_bench_dir/$benchmark", $args, "", "", "", "");
|
|
# FIXME check result code?!
|
|
}
|
|
else
|
|
{
|
|
mtr_error("Benchmark $benchmark not found");
|
|
}
|
|
|
|
chdir($glob_mysql_test_dir); # Go back
|
|
|
|
if ( ! $glob_use_embedded_server )
|
|
{
|
|
stop_masters();
|
|
}
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Run the test suite
|
|
#
|
|
##############################################################################
|
|
|
|
# FIXME how to specify several suites to run? Comma separated list?
|
|
|
|
|
|
sub run_suite () {
|
|
my ($suite, $tests)= @_;
|
|
|
|
mtr_print_thick_line();
|
|
|
|
mtr_report("Finding Tests in the '$suite' suite");
|
|
|
|
mtr_timer_start($glob_timers,"suite", 60 * $opt_suite_timeout);
|
|
|
|
mtr_report("Starting Tests in the '$suite' suite");
|
|
|
|
mtr_print_header();
|
|
|
|
foreach my $tinfo ( @$tests )
|
|
{
|
|
mtr_timer_start($glob_timers,"testcase", 60 * $opt_testcase_timeout);
|
|
run_testcase($tinfo);
|
|
mtr_timer_stop($glob_timers,"testcase");
|
|
}
|
|
|
|
mtr_print_line();
|
|
|
|
if ( ! $glob_debugger and
|
|
! $glob_use_running_server and
|
|
! $glob_use_embedded_server )
|
|
{
|
|
stop_masters_slaves();
|
|
}
|
|
|
|
if ( $opt_gcov )
|
|
{
|
|
gcov_collect(); # collect coverage information
|
|
}
|
|
if ( $opt_gprof )
|
|
{
|
|
gprof_collect(); # collect coverage information
|
|
}
|
|
|
|
mtr_report_stats($tests);
|
|
|
|
mtr_timer_stop($glob_timers,"suite");
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Initiate the test databases
|
|
#
|
|
##############################################################################
|
|
|
|
sub initialize_servers () {
|
|
if ( ! $glob_use_running_server )
|
|
{
|
|
if ( $opt_start_dirty )
|
|
{
|
|
kill_running_server();
|
|
}
|
|
else
|
|
{
|
|
kill_and_cleanup();
|
|
mysql_install_db();
|
|
if ( $opt_force )
|
|
{
|
|
save_installed_db();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
sub mysql_install_db () {
|
|
|
|
# FIXME not exactly true I think, needs improvements
|
|
install_db('master', $master->[0]->{'path_myddir'});
|
|
install_db('master', $master->[1]->{'path_myddir'});
|
|
|
|
if ( ! $opt_skip_rpl )
|
|
{
|
|
install_db('slave', $slave->[0]->{'path_myddir'});
|
|
install_db('slave', $slave->[1]->{'path_myddir'});
|
|
install_db('slave', $slave->[2]->{'path_myddir'});
|
|
}
|
|
|
|
if ( ! $opt_skip_im )
|
|
{
|
|
im_prepare_env($instance_manager);
|
|
}
|
|
|
|
if ( ndbcluster_install() )
|
|
{
|
|
if ( $opt_force)
|
|
{
|
|
# failed to install, disable usage and flag that its no ok
|
|
mtr_report("ndbcluster_install failed, continuing without cluster");
|
|
$opt_with_ndbcluster= 0;
|
|
$flag_ndb_status_ok= 0;
|
|
}
|
|
else
|
|
{
|
|
print "Aborting: Failed to install ndb cluster\n";
|
|
print "To continue, re-run with '--force'.\n";
|
|
mtr_exit(1);
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
sub install_db ($$) {
|
|
my $type= shift;
|
|
my $data_dir= shift;
|
|
|
|
my $init_db_sql= "lib/init_db.sql";
|
|
my $init_db_sql_tmp= "/tmp/init_db.sql$$";
|
|
my $args;
|
|
|
|
mtr_report("Installing \u$type Databases");
|
|
|
|
open(IN, $init_db_sql)
|
|
or mtr_error("Can't open $init_db_sql: $!");
|
|
open(OUT, ">", $init_db_sql_tmp)
|
|
or mtr_error("Can't write to $init_db_sql_tmp: $!");
|
|
while (<IN>)
|
|
{
|
|
chomp;
|
|
s/\@HOSTNAME\@/$glob_hostname/;
|
|
if ( /^\s*$/ )
|
|
{
|
|
print OUT "\n";
|
|
}
|
|
elsif (/;$/)
|
|
{
|
|
print OUT "$_\n";
|
|
}
|
|
else
|
|
{
|
|
print OUT "$_ ";
|
|
}
|
|
}
|
|
close OUT;
|
|
close IN;
|
|
|
|
mtr_init_args(\$args);
|
|
|
|
mtr_add_arg($args, "--no-defaults");
|
|
mtr_add_arg($args, "--bootstrap");
|
|
mtr_add_arg($args, "--console");
|
|
mtr_add_arg($args, "--skip-grant-tables");
|
|
mtr_add_arg($args, "--basedir=%s", $path_my_basedir);
|
|
mtr_add_arg($args, "--datadir=%s", $data_dir);
|
|
mtr_add_arg($args, "--skip-innodb");
|
|
mtr_add_arg($args, "--skip-ndbcluster");
|
|
mtr_add_arg($args, "--skip-bdb");
|
|
|
|
if ( ! $opt_netware )
|
|
{
|
|
mtr_add_arg($args, "--language=%s", $path_language);
|
|
mtr_add_arg($args, "--character-sets-dir=%s", $path_charsetsdir);
|
|
}
|
|
|
|
if ( mtr_run($exe_mysqld, $args, $init_db_sql_tmp,
|
|
$path_manager_log, $path_manager_log, "") != 0 )
|
|
{
|
|
unlink($init_db_sql_tmp);
|
|
mtr_error("Error executing mysqld --bootstrap\n" .
|
|
"Could not install $type test DBs");
|
|
}
|
|
unlink($init_db_sql_tmp);
|
|
}
|
|
|
|
|
|
sub im_prepare_env($) {
|
|
my $instance_manager = shift;
|
|
|
|
im_create_passwd_file($instance_manager);
|
|
im_prepare_data_dir($instance_manager);
|
|
}
|
|
|
|
|
|
sub im_create_passwd_file($) {
|
|
my $instance_manager = shift;
|
|
|
|
my $pwd_file_path = $instance_manager->{'password_file'};
|
|
|
|
mtr_report("Creating IM password file ($pwd_file_path)");
|
|
|
|
open(OUT, ">", $pwd_file_path)
|
|
or mtr_error("Can't write to $pwd_file_path: $!");
|
|
|
|
print OUT $instance_manager->{'admin_login'}, ":",
|
|
$instance_manager->{'admin_sha1'}, "\n";
|
|
|
|
close(OUT);
|
|
}
|
|
|
|
|
|
sub im_create_defaults_file($) {
|
|
my $instance_manager = shift;
|
|
|
|
my $defaults_file = $instance_manager->{'defaults_file'};
|
|
|
|
open(OUT, ">", $defaults_file)
|
|
or mtr_error("Can't write to $defaults_file: $!");
|
|
|
|
print OUT <<EOF
|
|
[mysql]
|
|
|
|
[manager]
|
|
pid-file = $instance_manager->{path_pid}
|
|
socket = $instance_manager->{path_sock}
|
|
port = $instance_manager->{port}
|
|
password-file = $instance_manager->{password_file}
|
|
default-mysqld-path = $exe_mysqld
|
|
|
|
EOF
|
|
;
|
|
|
|
foreach my $instance (@{$instance_manager->{'instances'}})
|
|
{
|
|
my $server_id = $instance->{'server_id'};
|
|
|
|
print OUT <<EOF
|
|
[mysqld$server_id]
|
|
socket = $instance->{path_sock}
|
|
pid-file = $instance->{path_pid}
|
|
port = $instance->{port}
|
|
datadir = $instance->{path_datadir}
|
|
log = $instance->{path_datadir}/mysqld$server_id.log
|
|
log-error = $instance->{path_datadir}/mysqld$server_id.err.log
|
|
log-slow-queries = $instance->{path_datadir}/mysqld$server_id.slow.log
|
|
language = $path_language
|
|
character-sets-dir = $path_charsetsdir
|
|
basedir = $path_my_basedir
|
|
server_id =$server_id
|
|
skip-stack-trace
|
|
skip-innodb
|
|
skip-bdb
|
|
skip-ndbcluster
|
|
EOF
|
|
;
|
|
|
|
print OUT "nonguarded\n" if $instance->{'nonguarded'};
|
|
print OUT "\n";
|
|
}
|
|
|
|
close(OUT);
|
|
}
|
|
|
|
|
|
sub im_prepare_data_dir($) {
|
|
my $instance_manager = shift;
|
|
|
|
foreach my $instance (@{$instance_manager->{'instances'}})
|
|
{
|
|
install_db(
|
|
'im_mysqld_' . $instance->{'server_id'},
|
|
$instance->{'path_datadir'});
|
|
}
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Run a single test case
|
|
#
|
|
##############################################################################
|
|
|
|
# When we get here, we have already filtered out test cases that doesn't
|
|
# apply to the current setup, for example if we use a running server, test
|
|
# cases that restart the server are dropped. So this function should mostly
|
|
# be about doing things, not a lot of logic.
|
|
|
|
# We don't start and kill the servers for each testcase. But some
|
|
# testcases needs a restart, because they specify options to start
|
|
# mysqld with. After that testcase, we need to restart again, to set
|
|
# back the normal options.
|
|
|
|
sub run_testcase ($) {
|
|
my $tinfo= shift;
|
|
|
|
my $tname= $tinfo->{'name'};
|
|
|
|
mtr_tonewfile($opt_current_test,"$tname\n"); # Always tell where we are
|
|
|
|
# output current test to ndbcluster log file to enable diagnostics
|
|
mtr_tofile($file_ndb_testrun_log,"CURRENT TEST $tname\n");
|
|
|
|
# ----------------------------------------------------------------------
|
|
# If marked to skip, just print out and return.
|
|
# Note that a test case not marked as 'skip' can still be
|
|
# skipped later, because of the test case itself in cooperation
|
|
# with the mysqltest program tells us so.
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( $tinfo->{'skip'} )
|
|
{
|
|
mtr_report_test_name($tinfo);
|
|
mtr_report_test_skipped($tinfo);
|
|
return;
|
|
}
|
|
|
|
if ( $tinfo->{'ndb_test'} and ! $flag_ndb_status_ok )
|
|
{
|
|
mtr_report_test_name($tinfo);
|
|
mtr_report_test_failed($tinfo);
|
|
return;
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# If not using a running servers we may need to stop and restart.
|
|
# We restart in the case we have initiation scripts, server options
|
|
# etc to run. But we also restart again after the test first restart
|
|
# and test is run, to get back to normal server settings.
|
|
#
|
|
# To make the code a bit more clean, we actually only stop servers
|
|
# here, and mark this to be done. Then a generic "start" part will
|
|
# start up the needed servers again.
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( ! $glob_use_running_server and ! $glob_use_embedded_server )
|
|
{
|
|
# We try to find out if we are to restart the server
|
|
my $do_restart= 0; # Assumes we don't have to
|
|
|
|
if ( $tinfo->{'master_sh'} )
|
|
{
|
|
$do_restart= 1; # Always restart if script to run
|
|
}
|
|
elsif ( $opt_with_ndbcluster and $tinfo->{'ndb_test'} != $using_ndbcluster_master )
|
|
{
|
|
$do_restart= 1; # Restart without cluster
|
|
}
|
|
elsif ( $master->[0]->{'running_master_is_special'} and
|
|
$master->[0]->{'running_master_is_special'}->{'timezone'} eq
|
|
$tinfo->{'timezone'} and
|
|
mtr_same_opts($master->[0]->{'running_master_is_special'}->{'master_opt'},
|
|
$tinfo->{'master_opt'}) )
|
|
{
|
|
# If running master was started with special settings, but
|
|
# the current test requuires the same ones, we *don't* restart.
|
|
$do_restart= 0;
|
|
}
|
|
elsif ( $tinfo->{'master_restart'} or
|
|
$master->[0]->{'running_master_is_special'} )
|
|
{
|
|
$do_restart= 1;
|
|
}
|
|
|
|
if ( $do_restart )
|
|
{
|
|
stop_masters();
|
|
delete $master->[0]->{'running_master_is_special'}; # Forget history
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Always terminate all slaves, if any. Else we may have useless
|
|
# reconnection attempts and error messages in case the slave and
|
|
# master servers restart.
|
|
# ----------------------------------------------------------------------
|
|
|
|
stop_slaves();
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Prepare to start masters. Even if we use embedded, we want to run
|
|
# the preparation.
|
|
# ----------------------------------------------------------------------
|
|
|
|
$ENV{'TZ'}= $tinfo->{'timezone'};
|
|
|
|
mtr_report_test_name($tinfo);
|
|
|
|
mtr_tofile($master->[0]->{'path_myerr'},"CURRENT_TEST: $tname\n");
|
|
|
|
# FIXME test cases that depend on each other, prevent this from
|
|
# being at this location.
|
|
# do_before_start_master($tname,$tinfo->{'master_sh'});
|
|
|
|
# ----------------------------------------------------------------------
|
|
# If any mysqld servers running died, we have to know
|
|
# ----------------------------------------------------------------------
|
|
|
|
mtr_record_dead_children();
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Start masters
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( ! $glob_use_running_server and ! $glob_use_embedded_server )
|
|
{
|
|
# FIXME give the args to the embedded server?!
|
|
# FIXME what does $opt_local_master mean?!
|
|
# FIXME split up start and check that started so that can do
|
|
# starts in parallel, masters and slaves at the same time.
|
|
|
|
if ( $tinfo->{'component_id'} eq 'mysqld' and ! $opt_local_master )
|
|
{
|
|
if ( $opt_with_ndbcluster and $master->[0]->{'ndbcluster'} )
|
|
{
|
|
# Cluster is not started
|
|
|
|
# Call ndbcluster_start to check if test case needs cluster
|
|
# Start it if not already started
|
|
$master->[0]->{'ndbcluster'}= ndbcluster_start($tinfo->{'ndb_test'});
|
|
if ( $master->[0]->{'ndbcluster'} )
|
|
{
|
|
report_failure_and_restart($tinfo);
|
|
return;
|
|
}
|
|
}
|
|
if ( ! $master->[0]->{'pid'} )
|
|
{
|
|
# FIXME not correct location for do_before_start_master()
|
|
do_before_start_master($tname,$tinfo->{'master_sh'});
|
|
$master->[0]->{'pid'}=
|
|
mysqld_start('master',0,$tinfo->{'master_opt'},[],
|
|
$using_ndbcluster_master);
|
|
if ( ! $master->[0]->{'pid'} )
|
|
{
|
|
report_failure_and_restart($tinfo);
|
|
return;
|
|
}
|
|
}
|
|
if ( $using_ndbcluster_master and ! $master->[1]->{'pid'} )
|
|
{
|
|
# Test needs cluster, start an extra mysqld connected to cluster
|
|
$master->[1]->{'pid'}=
|
|
mysqld_start('master',1,$tinfo->{'master_opt'},[],
|
|
$using_ndbcluster_master);
|
|
if ( ! $master->[1]->{'pid'} )
|
|
{
|
|
report_failure_and_restart($tinfo);
|
|
return;
|
|
}
|
|
}
|
|
|
|
if ( $tinfo->{'master_restart'} )
|
|
{
|
|
# Save this test case information, so next can examine it
|
|
$master->[0]->{'running_master_is_special'}= $tinfo;
|
|
}
|
|
}
|
|
elsif ( ! $opt_skip_im and $tinfo->{'component_id'} eq 'im' )
|
|
{
|
|
# We have to create defaults file every time, in order to ensure that it
|
|
# will be the same for each test. The problem is that test can change the
|
|
# file (by SET/UNSET commands), so w/o recreating the file, execution of
|
|
# one test can affect the other.
|
|
|
|
im_create_defaults_file($instance_manager);
|
|
|
|
im_start($instance_manager, $tinfo->{im_opts});
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Start slaves - if needed
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( $tinfo->{'slave_num'} )
|
|
{
|
|
mtr_tofile($slave->[0]->{'path_myerr'},"CURRENT_TEST: $tname\n");
|
|
|
|
do_before_start_slave($tname,$tinfo->{'slave_sh'});
|
|
|
|
for ( my $idx= 0; $idx < $tinfo->{'slave_num'}; $idx++ )
|
|
{
|
|
if ( ! $slave->[$idx]->{'pid'} )
|
|
{
|
|
$slave->[$idx]->{'pid'}=
|
|
mysqld_start('slave',$idx,
|
|
$tinfo->{'slave_opt'}, $tinfo->{'slave_mi'},
|
|
0);
|
|
if ( ! $slave->[$idx]->{'pid'} )
|
|
{
|
|
report_failure_and_restart($tinfo);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# If --start-and-exit given, stop here to let user manually run tests
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( $opt_start_and_exit )
|
|
{
|
|
mtr_report("\nServers started, exiting");
|
|
exit(0);
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Run the test case
|
|
# ----------------------------------------------------------------------
|
|
|
|
{
|
|
# remove the old reject file
|
|
if ( $opt_suite eq "main" )
|
|
{
|
|
unlink("r/$tname.reject");
|
|
}
|
|
else
|
|
{
|
|
unlink("suite/$opt_suite/r/$tname.reject");
|
|
}
|
|
unlink($path_timefile);
|
|
|
|
my $res= run_mysqltest($tinfo);
|
|
|
|
if ( $res == 0 )
|
|
{
|
|
mtr_report_test_passed($tinfo);
|
|
}
|
|
elsif ( $res == 62 )
|
|
{
|
|
# Testcase itself tell us to skip this one
|
|
mtr_report_test_skipped($tinfo);
|
|
}
|
|
elsif ( $res == 63 )
|
|
{
|
|
$tinfo->{'timeout'}= 1; # Mark as timeout
|
|
report_failure_and_restart($tinfo);
|
|
}
|
|
else
|
|
{
|
|
# Test case failed, if in control mysqltest returns 1
|
|
if ( $res != 1 )
|
|
{
|
|
mtr_tofile($path_timefile,
|
|
"mysqltest returned unexpected code $res, " .
|
|
"it has probably crashed");
|
|
}
|
|
report_failure_and_restart($tinfo);
|
|
}
|
|
# Save info from this testcase run to mysqltest.log
|
|
my $testcase_log= mtr_fromfile($path_timefile) if -f $path_timefile;
|
|
mtr_tofile($path_mysqltest_log,"CURRENT TEST $tname\n");
|
|
mtr_tofile($path_mysqltest_log, $testcase_log);
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Stop Instance Manager if we are processing an IM-test case.
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( ! $glob_use_running_server and $tinfo->{'component_id'} eq 'im' and
|
|
$instance_manager->{'pid'} )
|
|
{
|
|
im_stop($instance_manager);
|
|
}
|
|
}
|
|
|
|
sub copy_dir($$) {
|
|
my $from_dir= shift;
|
|
my $to_dir= shift;
|
|
|
|
mkpath("$to_dir");
|
|
opendir(DIR, "$from_dir")
|
|
or mtr_error("Can't find $from_dir$!");
|
|
for(readdir(DIR)) {
|
|
next if "$_" eq "." or "$_" eq "..";
|
|
if ( -d "$from_dir/$_" )
|
|
{
|
|
copy_dir("$from_dir/$_", "$to_dir/$_");
|
|
next;
|
|
}
|
|
copy("$from_dir/$_", "$to_dir/$_");
|
|
}
|
|
closedir(DIR);
|
|
|
|
}
|
|
|
|
#
|
|
# Save a snapshot of the installed test db(s)
|
|
# I.e take a snapshot of the var/ dir
|
|
#
|
|
sub save_installed_db () {
|
|
|
|
mtr_report("Saving snapshot of installed databases");
|
|
rmtree($path_snapshot);
|
|
|
|
foreach my $data_dir (@data_dir_lst)
|
|
{
|
|
my $name= basename($data_dir);
|
|
copy_dir("$data_dir", "$path_snapshot/$name");
|
|
}
|
|
}
|
|
|
|
|
|
#
|
|
# Save any interesting files in the data_dir
|
|
# before the data dir is removed.
|
|
#
|
|
sub save_files_before_restore($$) {
|
|
my $test_name= shift;
|
|
my $data_dir= shift;
|
|
my $save_name= "$opt_vardir/log/$test_name";
|
|
|
|
# Look for core files
|
|
foreach my $core_file ( glob("$data_dir/core*") )
|
|
{
|
|
my $core_name= basename($core_file);
|
|
mtr_report("Saving $core_name");
|
|
mkdir($save_name) if ! -d $save_name;
|
|
rename("$core_file", "$save_name/$core_name");
|
|
}
|
|
}
|
|
|
|
#
|
|
# Restore snapshot of the installed test db(s)
|
|
# if the snapshot exists
|
|
#
|
|
sub restore_installed_db ($) {
|
|
my $test_name= shift;
|
|
|
|
if ( -d $path_snapshot)
|
|
{
|
|
kill_running_server ();
|
|
|
|
mtr_report("Restoring snapshot of databases");
|
|
|
|
foreach my $data_dir (@data_dir_lst)
|
|
{
|
|
my $name= basename($data_dir);
|
|
save_files_before_restore($test_name, $data_dir);
|
|
rmtree("$data_dir");
|
|
copy_dir("$path_snapshot/$name", "$data_dir");
|
|
}
|
|
if ($opt_with_ndbcluster)
|
|
{
|
|
# Remove the ndb_*_fs dirs, forcing a clean start of ndb
|
|
rmtree("$path_ndb_data_dir/ndb_1_fs");
|
|
rmtree("$path_ndb_data_dir/ndb_2_fs");
|
|
}
|
|
}
|
|
else
|
|
{
|
|
# No snapshot existed, just stop all processes
|
|
stop_masters_slaves();
|
|
}
|
|
}
|
|
|
|
|
|
sub report_failure_and_restart ($) {
|
|
my $tinfo= shift;
|
|
|
|
mtr_report_test_failed($tinfo);
|
|
mtr_show_failed_diff($tinfo->{'name'});
|
|
print "\n";
|
|
if ( $opt_force )
|
|
{
|
|
# Restore the snapshot of the installed test db
|
|
restore_installed_db($tinfo->{'name'});
|
|
print "Resuming Tests\n\n";
|
|
return;
|
|
}
|
|
|
|
my $test_mode= join(" ", @::glob_test_mode) || "default";
|
|
print "Aborting: $tinfo->{'name'} failed in $test_mode mode. ";
|
|
print "To continue, re-run with '--force'.\n";
|
|
if ( ! $glob_debugger and
|
|
! $glob_use_running_server and
|
|
! $glob_use_embedded_server )
|
|
{
|
|
stop_masters_slaves();
|
|
}
|
|
mtr_exit(1);
|
|
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Start and stop servers
|
|
#
|
|
##############################################################################
|
|
|
|
# The embedded server needs the cleanup so we do some of the start work
|
|
# but stop before actually running mysqld or anything.
|
|
|
|
sub do_before_start_master ($$) {
|
|
my $tname= shift;
|
|
my $init_script= shift;
|
|
|
|
# FIXME what about second master.....
|
|
|
|
# Remove stale binary logs except for 2 tests which need them FIXME here????
|
|
if ( $tname ne "rpl_crash_binlog_ib_1b" and
|
|
$tname ne "rpl_crash_binlog_ib_2b" and
|
|
$tname ne "rpl_crash_binlog_ib_3b")
|
|
{
|
|
# FIXME we really want separate dir for binlogs
|
|
foreach my $bin ( glob("$opt_vardir/log/master*-bin*") )
|
|
{
|
|
unlink($bin);
|
|
}
|
|
}
|
|
|
|
# FIXME only remove the ones that are tied to this master
|
|
# Remove old master.info and relay-log.info files
|
|
unlink("$master->[0]->{'path_myddir'}/master.info");
|
|
unlink("$master->[0]->{'path_myddir'}/relay-log.info");
|
|
unlink("$master->[1]->{'path_myddir'}/master.info");
|
|
unlink("$master->[1]->{'path_myddir'}/relay-log.info");
|
|
|
|
# Run master initialization shell script if one exists
|
|
if ( $init_script )
|
|
{
|
|
my $ret= mtr_run("/bin/sh", [$init_script], "", "", "", "");
|
|
if ( $ret != 0 )
|
|
{
|
|
# FIXME rewrite those scripts to return 0 if successful
|
|
# mtr_warning("$init_script exited with code $ret");
|
|
}
|
|
}
|
|
# for gcov FIXME needed? If so we need more absolute paths
|
|
# chdir($glob_basedir);
|
|
}
|
|
|
|
sub do_before_start_slave ($$) {
|
|
my $tname= shift;
|
|
my $init_script= shift;
|
|
|
|
# Remove stale binary logs and old master.info files
|
|
# except for too tests which need them
|
|
if ( $tname ne "rpl_crash_binlog_ib_1b" and
|
|
$tname ne "rpl_crash_binlog_ib_2b" and
|
|
$tname ne "rpl_crash_binlog_ib_3b" )
|
|
{
|
|
# FIXME we really want separate dir for binlogs
|
|
foreach my $bin ( glob("$opt_vardir/log/slave*-bin*") )
|
|
{
|
|
unlink($bin);
|
|
}
|
|
# FIXME really master?!
|
|
unlink("$slave->[0]->{'path_myddir'}/master.info");
|
|
unlink("$slave->[0]->{'path_myddir'}/relay-log.info");
|
|
}
|
|
|
|
# Run slave initialization shell script if one exists
|
|
if ( $init_script )
|
|
{
|
|
my $ret= mtr_run("/bin/sh", [$init_script], "", "", "", "");
|
|
if ( $ret != 0 )
|
|
{
|
|
# FIXME rewrite those scripts to return 0 if successful
|
|
# mtr_warning("$init_script exited with code $ret");
|
|
}
|
|
}
|
|
|
|
foreach my $bin ( glob("$slave->[0]->{'path_myddir'}/log.*") )
|
|
{
|
|
unlink($bin);
|
|
}
|
|
}
|
|
|
|
sub mysqld_arguments ($$$$$$) {
|
|
my $args= shift;
|
|
my $type= shift; # master/slave/bootstrap
|
|
my $idx= shift;
|
|
my $extra_opt= shift;
|
|
my $slave_master_info= shift;
|
|
my $using_ndbcluster= shift;
|
|
|
|
my $sidx= ""; # Index as string, 0 is empty string
|
|
if ( $idx > 0 )
|
|
{
|
|
$sidx= sprintf("%d", $idx); # sprintf not needed in Perl for this
|
|
}
|
|
|
|
my $prefix= ""; # If mysqltest server arg
|
|
|
|
if ( $glob_use_embedded_server )
|
|
{
|
|
$prefix= "--server-arg=";
|
|
} else {
|
|
# We can't pass embedded server --no-defaults
|
|
mtr_add_arg($args, "%s--no-defaults", $prefix);
|
|
}
|
|
|
|
mtr_add_arg($args, "%s--console", $prefix);
|
|
mtr_add_arg($args, "%s--basedir=%s", $prefix, $path_my_basedir);
|
|
mtr_add_arg($args, "%s--character-sets-dir=%s", $prefix, $path_charsetsdir);
|
|
mtr_add_arg($args, "%s--core", $prefix);
|
|
mtr_add_arg($args, "%s--log-bin-trust-function-creators", $prefix);
|
|
mtr_add_arg($args, "%s--default-character-set=latin1", $prefix);
|
|
mtr_add_arg($args, "%s--language=%s", $prefix, $path_language);
|
|
mtr_add_arg($args, "%s--tmpdir=$opt_tmpdir", $prefix);
|
|
|
|
if ( $opt_valgrind_mysqld )
|
|
{
|
|
mtr_add_arg($args, "%s--skip-safemalloc", $prefix);
|
|
mtr_add_arg($args, "%s--skip-bdb", $prefix);
|
|
}
|
|
|
|
my $pidfile;
|
|
|
|
if ( $type eq 'master' )
|
|
{
|
|
my $id= $idx > 0 ? $idx + 101 : 1;
|
|
|
|
mtr_add_arg($args, "%s--log-bin=%s/log/master-bin%s", $prefix,
|
|
$opt_vardir, $sidx);
|
|
mtr_add_arg($args, "%s--pid-file=%s", $prefix,
|
|
$master->[$idx]->{'path_mypid'});
|
|
mtr_add_arg($args, "%s--port=%d", $prefix,
|
|
$master->[$idx]->{'path_myport'});
|
|
mtr_add_arg($args, "%s--server-id=%d", $prefix, $id);
|
|
mtr_add_arg($args, "%s--socket=%s", $prefix,
|
|
$master->[$idx]->{'path_mysock'});
|
|
mtr_add_arg($args, "%s--innodb_data_file_path=ibdata1:128M:autoextend", $prefix);
|
|
mtr_add_arg($args, "%s--local-infile", $prefix);
|
|
mtr_add_arg($args, "%s--datadir=%s", $prefix,
|
|
$master->[$idx]->{'path_myddir'});
|
|
|
|
if ( $idx > 0 )
|
|
{
|
|
mtr_add_arg($args, "%s--skip-innodb", $prefix);
|
|
}
|
|
|
|
if ( $opt_skip_ndbcluster || !$using_ndbcluster)
|
|
{
|
|
mtr_add_arg($args, "%s--skip-ndbcluster", $prefix);
|
|
}
|
|
else
|
|
{
|
|
mtr_add_arg($args, "%s--ndbcluster", $prefix);
|
|
mtr_add_arg($args, "%s--ndb-connectstring=%s", $prefix,
|
|
$opt_ndbconnectstring);
|
|
}
|
|
}
|
|
|
|
if ( $type eq 'slave' )
|
|
{
|
|
my $slave_server_id= 2 + $idx;
|
|
my $slave_rpl_rank= $slave_server_id;
|
|
|
|
mtr_add_arg($args, "%s--datadir=%s", $prefix,
|
|
$slave->[$idx]->{'path_myddir'});
|
|
# FIXME slave get this option twice?!
|
|
mtr_add_arg($args, "%s--exit-info=256", $prefix);
|
|
mtr_add_arg($args, "%s--init-rpl-role=slave", $prefix);
|
|
mtr_add_arg($args, "%s--log-bin=%s/log/slave%s-bin", $prefix,
|
|
$opt_vardir, $sidx); # FIXME use own dir for binlogs
|
|
mtr_add_arg($args, "%s--log-slave-updates", $prefix);
|
|
# FIXME option duplicated for slave
|
|
mtr_add_arg($args, "%s--log=%s", $prefix,
|
|
$slave->[$idx]->{'path_mylog'});
|
|
mtr_add_arg($args, "%s--master-retry-count=10", $prefix);
|
|
mtr_add_arg($args, "%s--pid-file=%s", $prefix,
|
|
$slave->[$idx]->{'path_mypid'});
|
|
mtr_add_arg($args, "%s--port=%d", $prefix,
|
|
$slave->[$idx]->{'path_myport'});
|
|
mtr_add_arg($args, "%s--relay-log=%s/log/slave%s-relay-bin", $prefix,
|
|
$opt_vardir, $sidx);
|
|
mtr_add_arg($args, "%s--report-host=127.0.0.1", $prefix);
|
|
mtr_add_arg($args, "%s--report-port=%d", $prefix,
|
|
$slave->[$idx]->{'path_myport'});
|
|
mtr_add_arg($args, "%s--report-user=root", $prefix);
|
|
mtr_add_arg($args, "%s--skip-innodb", $prefix);
|
|
mtr_add_arg($args, "%s--skip-ndbcluster", $prefix);
|
|
mtr_add_arg($args, "%s--skip-slave-start", $prefix);
|
|
|
|
# Directory where slaves find the dumps generated by "load data"
|
|
# on the server. The path need to have constant length otherwise
|
|
# test results will vary, thus a relative path is used.
|
|
mtr_add_arg($args, "%s--slave-load-tmpdir=%s", $prefix,
|
|
"../tmp");
|
|
mtr_add_arg($args, "%s--socket=%s", $prefix,
|
|
$slave->[$idx]->{'path_mysock'});
|
|
mtr_add_arg($args, "%s--set-variable=slave_net_timeout=10", $prefix);
|
|
|
|
if ( @$slave_master_info )
|
|
{
|
|
foreach my $arg ( @$slave_master_info )
|
|
{
|
|
mtr_add_arg($args, "%s%s", $prefix, $arg);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
mtr_add_arg($args, "%s--master-user=root", $prefix);
|
|
mtr_add_arg($args, "%s--master-connect-retry=1", $prefix);
|
|
mtr_add_arg($args, "%s--master-host=127.0.0.1", $prefix);
|
|
mtr_add_arg($args, "%s--master-password=", $prefix);
|
|
mtr_add_arg($args, "%s--master-port=%d", $prefix,
|
|
$master->[0]->{'path_myport'}); # First master
|
|
mtr_add_arg($args, "%s--server-id=%d", $prefix, $slave_server_id);
|
|
mtr_add_arg($args, "%s--rpl-recovery-rank=%d", $prefix, $slave_rpl_rank);
|
|
}
|
|
} # end slave
|
|
|
|
if ( $opt_debug )
|
|
{
|
|
if ( $type eq 'master' )
|
|
{
|
|
mtr_add_arg($args, "%s--debug=d:t:i:A,%s/log/master%s.trace",
|
|
$prefix, $opt_vardir_trace, $sidx);
|
|
}
|
|
if ( $type eq 'slave' )
|
|
{
|
|
mtr_add_arg($args, "%s--debug=d:t:i:A,%s/log/slave%s.trace",
|
|
$prefix, $opt_vardir_trace, $sidx);
|
|
}
|
|
}
|
|
|
|
# FIXME always set nowdays??? SMALL_SERVER
|
|
mtr_add_arg($args, "%s--key_buffer_size=1M", $prefix);
|
|
mtr_add_arg($args, "%s--sort_buffer=256K", $prefix);
|
|
mtr_add_arg($args, "%s--max_heap_table_size=1M", $prefix);
|
|
mtr_add_arg($args, "%s--log-bin-trust-function-creators", $prefix);
|
|
|
|
if ( $opt_ssl_supported )
|
|
{
|
|
mtr_add_arg($args, "%s--ssl-ca=%s/std_data/cacert.pem", $prefix,
|
|
$glob_mysql_test_dir);
|
|
mtr_add_arg($args, "%s--ssl-cert=%s/std_data/server-cert.pem", $prefix,
|
|
$glob_mysql_test_dir);
|
|
mtr_add_arg($args, "%s--ssl-key=%s/std_data/server-key.pem", $prefix,
|
|
$glob_mysql_test_dir);
|
|
}
|
|
|
|
if ( $opt_warnings )
|
|
{
|
|
mtr_add_arg($args, "%s--log-warnings", $prefix);
|
|
}
|
|
|
|
# Indicate to "mysqld" it will be debugged in debugger
|
|
if ( $glob_debugger )
|
|
{
|
|
mtr_add_arg($args, "%s--gdb", $prefix);
|
|
}
|
|
|
|
# If we should run all tests cases, we will use a local server for that
|
|
|
|
if ( -w "/" )
|
|
{
|
|
# We are running as root; We need to add the --root argument
|
|
mtr_add_arg($args, "%s--user=root", $prefix);
|
|
}
|
|
|
|
if ( $type eq 'master' )
|
|
{
|
|
|
|
if ( ! $opt_old_master )
|
|
{
|
|
mtr_add_arg($args, "%s--rpl-recovery-rank=1", $prefix);
|
|
mtr_add_arg($args, "%s--init-rpl-role=master", $prefix);
|
|
}
|
|
|
|
# FIXME strange,.....
|
|
# FIXME MYSQL_MYPORT is not set anythere?!
|
|
if ( $opt_local_master )
|
|
{
|
|
mtr_add_arg($args, "%s--host=127.0.0.1", $prefix);
|
|
mtr_add_arg($args, "%s--port=%s", $prefix, $ENV{'MYSQL_MYPORT'});
|
|
}
|
|
}
|
|
|
|
foreach my $arg ( @opt_extra_mysqld_opt, @$extra_opt )
|
|
{
|
|
mtr_add_arg($args, "%s%s", $prefix, $arg);
|
|
}
|
|
|
|
if ( $opt_bench )
|
|
{
|
|
mtr_add_arg($args, "%s--rpl-recovery-rank=1", $prefix);
|
|
mtr_add_arg($args, "%s--init-rpl-role=master", $prefix);
|
|
}
|
|
elsif ( $type eq 'master' )
|
|
{
|
|
mtr_add_arg($args, "%s--exit-info=256", $prefix);
|
|
mtr_add_arg($args, "%s--open-files-limit=1024", $prefix);
|
|
mtr_add_arg($args, "%s--log=%s", $prefix, $master->[0]->{'path_mylog'});
|
|
}
|
|
|
|
return $args;
|
|
}
|
|
|
|
# FIXME
|
|
# if ( $type eq 'master' and $glob_use_embedded_server )
|
|
# {
|
|
# # Add a -A to each argument to pass it to embedded server
|
|
# my @mysqltest_opt= map {("-A",$_)} @args;
|
|
# $opt_extra_mysqltest_opt= \@mysqltest_opt;
|
|
# return;
|
|
# }
|
|
|
|
##############################################################################
|
|
#
|
|
# Start mysqld and return the PID
|
|
#
|
|
##############################################################################
|
|
|
|
sub mysqld_start ($$$$$) {
|
|
my $type= shift; # master/slave/bootstrap
|
|
my $idx= shift;
|
|
my $extra_opt= shift;
|
|
my $slave_master_info= shift;
|
|
my $using_ndbcluster= shift;
|
|
|
|
|
|
my $args; # Arg vector
|
|
my $exe;
|
|
my $pid= -1;
|
|
|
|
if ( $type eq 'master' )
|
|
{
|
|
$exe= $exe_master_mysqld;
|
|
}
|
|
elsif ( $type eq 'slave' )
|
|
{
|
|
$exe= $exe_slave_mysqld;
|
|
}
|
|
else
|
|
{
|
|
$exe= $exe_mysqld;
|
|
}
|
|
|
|
mtr_init_args(\$args);
|
|
|
|
if ( $opt_valgrind_mysqld )
|
|
{
|
|
valgrind_arguments($args, \$exe);
|
|
}
|
|
|
|
mysqld_arguments($args,$type,$idx,$extra_opt,$slave_master_info,
|
|
$using_ndbcluster);
|
|
|
|
if ( $opt_gdb || $opt_manual_gdb)
|
|
{
|
|
gdb_arguments(\$args, \$exe, "$type"."_$idx");
|
|
}
|
|
elsif ( $opt_ddd || $opt_manual_ddd )
|
|
{
|
|
ddd_arguments(\$args, \$exe, "$type"."_$idx");
|
|
}
|
|
elsif ( $opt_debugger )
|
|
{
|
|
debugger_arguments(\$args, \$exe, "$type"."_$idx");
|
|
}
|
|
elsif ( $opt_manual_debug )
|
|
{
|
|
print "\nStart $type in your debugger\n" .
|
|
"dir: $glob_mysql_test_dir\n" .
|
|
"exe: $exe\n" .
|
|
"args: " . join(" ", @$args) . "\n\n" .
|
|
"Waiting ....\n";
|
|
|
|
# Indicate the exe should not be started
|
|
$exe= undef;
|
|
}
|
|
|
|
if ( $type eq 'master' )
|
|
{
|
|
if ( ! defined $exe or
|
|
$pid= mtr_spawn($exe, $args, "",
|
|
$master->[$idx]->{'path_myerr'},
|
|
$master->[$idx]->{'path_myerr'},
|
|
"",
|
|
{ append_log_file => 1 }) )
|
|
{
|
|
return sleep_until_file_created($master->[$idx]->{'path_mypid'},
|
|
$master->[$idx]->{'start_timeout'},
|
|
$pid);
|
|
}
|
|
}
|
|
|
|
if ( $type eq 'slave' )
|
|
{
|
|
if ( ! defined $exe or
|
|
$pid= mtr_spawn($exe, $args, "",
|
|
$slave->[$idx]->{'path_myerr'},
|
|
$slave->[$idx]->{'path_myerr'},
|
|
"",
|
|
{ append_log_file => 1 }) )
|
|
{
|
|
return sleep_until_file_created($slave->[$idx]->{'path_mypid'},
|
|
$master->[$idx]->{'start_timeout'},
|
|
$pid);
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
sub stop_masters_slaves () {
|
|
|
|
print "Ending Tests\n";
|
|
|
|
if ( $instance_manager->{'pid'} )
|
|
{
|
|
print "Shutting-down Instance Manager\n";
|
|
im_stop($instance_manager);
|
|
}
|
|
|
|
print "Shutting-down MySQL daemon\n\n";
|
|
stop_masters();
|
|
print "Master(s) shutdown finished\n";
|
|
stop_slaves();
|
|
print "Slave(s) shutdown finished\n";
|
|
}
|
|
|
|
sub stop_masters () {
|
|
|
|
my @args;
|
|
|
|
for ( my $idx; $idx < 2; $idx++ )
|
|
{
|
|
# FIXME if we hit ^C before fully started, this test will prevent
|
|
# the mysqld process from being killed
|
|
if ( $master->[$idx]->{'pid'} )
|
|
{
|
|
push(@args,{
|
|
pid => $master->[$idx]->{'pid'},
|
|
pidfile => $master->[$idx]->{'path_mypid'},
|
|
sockfile => $master->[$idx]->{'path_mysock'},
|
|
port => $master->[$idx]->{'path_myport'},
|
|
});
|
|
$master->[$idx]->{'pid'}= 0; # Assume we are done with it
|
|
}
|
|
}
|
|
|
|
if ( ! $master->[0]->{'ndbcluster'} )
|
|
{
|
|
ndbcluster_stop();
|
|
$master->[0]->{'ndbcluster'}= 1;
|
|
}
|
|
|
|
mtr_stop_mysqld_servers(\@args);
|
|
}
|
|
|
|
sub stop_slaves () {
|
|
my $force= shift;
|
|
|
|
my @args;
|
|
|
|
for ( my $idx; $idx < 3; $idx++ )
|
|
{
|
|
if ( $slave->[$idx]->{'pid'} )
|
|
{
|
|
push(@args,{
|
|
pid => $slave->[$idx]->{'pid'},
|
|
pidfile => $slave->[$idx]->{'path_mypid'},
|
|
sockfile => $slave->[$idx]->{'path_mysock'},
|
|
port => $slave->[$idx]->{'path_myport'},
|
|
});
|
|
$slave->[$idx]->{'pid'}= 0; # Assume we are done with it
|
|
}
|
|
}
|
|
|
|
mtr_stop_mysqld_servers(\@args);
|
|
}
|
|
|
|
##############################################################################
|
|
#
|
|
# Instance Manager management routines.
|
|
#
|
|
##############################################################################
|
|
|
|
sub im_start($$) {
|
|
my $instance_manager = shift;
|
|
my $opts = shift;
|
|
|
|
my $args;
|
|
mtr_init_args(\$args);
|
|
mtr_add_arg($args, "--defaults-file=%s",
|
|
$instance_manager->{'defaults_file'});
|
|
|
|
foreach my $opt (@{$opts})
|
|
{
|
|
mtr_add_arg($args, $opt);
|
|
}
|
|
|
|
$instance_manager->{'pid'} =
|
|
mtr_spawn(
|
|
$exe_im, # path to the executable
|
|
$args, # cmd-line args
|
|
'', # stdin
|
|
$instance_manager->{'path_log'}, # stdout
|
|
$instance_manager->{'path_err'}, # stderr
|
|
'', # pid file path (not used)
|
|
{ append_log_file => 1 } # append log files
|
|
);
|
|
|
|
if ( ! $instance_manager->{'pid'} )
|
|
{
|
|
mtr_report('Could not start Instance Manager');
|
|
return;
|
|
}
|
|
|
|
# Instance Manager can be run in daemon mode. In this case, it creates
|
|
# several processes and the parent process, created by mtr_spawn(), exits just
|
|
# after start. So, we have to obtain Instance Manager PID from the PID file.
|
|
|
|
if ( ! sleep_until_file_created(
|
|
$instance_manager->{'path_pid'},
|
|
$instance_manager->{'start_timeout'},
|
|
-1)) # real PID is still unknown
|
|
{
|
|
mtr_report("Instance Manager PID file is missing");
|
|
return;
|
|
}
|
|
|
|
$instance_manager->{'pid'} =
|
|
mtr_get_pid_from_file($instance_manager->{'path_pid'});
|
|
}
|
|
|
|
sub im_stop($) {
|
|
my $instance_manager = shift;
|
|
|
|
# Re-read pid from the file, since during tests Instance Manager could have
|
|
# been restarted, so its pid could have been changed.
|
|
|
|
$instance_manager->{'pid'} =
|
|
mtr_get_pid_from_file($instance_manager->{'path_pid'})
|
|
if -f $instance_manager->{'path_pid'};
|
|
|
|
# Inspired from mtr_stop_mysqld_servers().
|
|
|
|
start_reap_all();
|
|
|
|
# Create list of pids. We should stop Instance Manager and all started
|
|
# mysqld-instances. Some of them may be nonguarded, so IM will not stop them
|
|
# on shutdown.
|
|
|
|
my @pids = ( $instance_manager->{'pid'} );
|
|
my $instances = $instance_manager->{'instances'};
|
|
|
|
if ( -r $instances->[0]->{'path_pid'} )
|
|
{
|
|
push(@pids, mtr_get_pid_from_file($instances->[0]->{'path_pid'}));
|
|
}
|
|
|
|
if ( -r $instances->[1]->{'path_pid'} )
|
|
{
|
|
push(@pids, mtr_get_pid_from_file($instances->[1]->{'path_pid'}));
|
|
}
|
|
|
|
# Kill processes.
|
|
|
|
mtr_kill_processes(\@pids);
|
|
|
|
stop_reap_all();
|
|
|
|
$instance_manager->{'pid'} = undef;
|
|
}
|
|
|
|
#
|
|
# Run include/check-testcase.test
|
|
# Before a testcase, run in record mode, save result file to var
|
|
# After testcase, run and compare with the recorded file, they should be equal!
|
|
#
|
|
sub run_check_testcase ($) {
|
|
|
|
my $mode= shift;
|
|
|
|
my $args;
|
|
mtr_init_args(\$args);
|
|
|
|
mtr_add_arg($args, "--no-defaults");
|
|
mtr_add_arg($args, "--silent");
|
|
mtr_add_arg($args, "-v");
|
|
mtr_add_arg($args, "--skip-safemalloc");
|
|
mtr_add_arg($args, "--tmpdir=%s", $opt_tmpdir);
|
|
|
|
mtr_add_arg($args, "--socket=%s", $master->[0]->{'path_mysock'});
|
|
mtr_add_arg($args, "--port=%d", $master->[0]->{'path_myport'});
|
|
mtr_add_arg($args, "--database=test");
|
|
mtr_add_arg($args, "--user=%s", $opt_user);
|
|
mtr_add_arg($args, "--password=");
|
|
|
|
mtr_add_arg($args, "-R");
|
|
mtr_add_arg($args, "$opt_vardir/tmp/check-testcase.result");
|
|
|
|
if ( $mode eq "before" )
|
|
{
|
|
mtr_add_arg($args, "--record");
|
|
}
|
|
|
|
my $res = mtr_run_test($exe_mysqltest,$args,
|
|
"include/check-testcase.test", "", "", "");
|
|
|
|
if ( $res == 1 and $mode = "after")
|
|
{
|
|
mtr_run("diff",["-u",
|
|
"$opt_vardir/tmp/check-testcase.result",
|
|
"$opt_vardir/tmp/check-testcase.reject"],
|
|
"", "", "", "");
|
|
}
|
|
elsif ( $res )
|
|
{
|
|
mtr_error("Could not execute 'check-testcase' $mode testcase");
|
|
}
|
|
}
|
|
|
|
sub run_mysqltest ($) {
|
|
my $tinfo= shift;
|
|
|
|
my $cmdline_mysqlcheck= "$exe_mysqlcheck --no-defaults -uroot " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'} --password=";
|
|
if ( $opt_debug )
|
|
{
|
|
$cmdline_mysqlcheck .=
|
|
" --debug=d:t:A,$opt_vardir_trace/log/mysqlcheck.trace";
|
|
}
|
|
|
|
my $cmdline_mysqldump= "$exe_mysqldump --no-defaults -uroot " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'} --password=";
|
|
if ( $opt_debug )
|
|
{
|
|
$cmdline_mysqldump .=
|
|
" --debug=d:t:A,$opt_vardir_trace/log/mysqldump.trace";
|
|
}
|
|
my $cmdline_mysqlimport= "$exe_mysqlimport -uroot " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'} --password=";
|
|
if ( $opt_debug )
|
|
{
|
|
$cmdline_mysqlimport .=
|
|
" --debug=d:t:A,$opt_vardir_trace/log/mysqlimport.trace";
|
|
}
|
|
|
|
my $cmdline_mysqlshow= "$exe_mysqlshow -uroot " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'} --password=";
|
|
if ( $opt_debug )
|
|
{
|
|
$cmdline_mysqlshow .=
|
|
" --debug=d:t:A,$opt_vardir_trace/log/mysqlshow.trace";
|
|
}
|
|
|
|
my $cmdline_mysqlbinlog=
|
|
"$exe_mysqlbinlog" .
|
|
" --no-defaults --local-load=$opt_tmpdir" .
|
|
" --character-sets-dir=$path_charsetsdir";
|
|
|
|
if ( $opt_debug )
|
|
{
|
|
$cmdline_mysqlbinlog .=
|
|
" --debug=d:t:A,$opt_vardir_trace/log/mysqlbinlog.trace";
|
|
}
|
|
|
|
my $cmdline_mysql=
|
|
"$exe_mysql --host=localhost --user=root --password= " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'}";
|
|
|
|
my $cmdline_mysql_client_test=
|
|
"$exe_mysql_client_test --no-defaults --testcase --user=root --silent " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'}";
|
|
|
|
if ( $glob_use_embedded_server )
|
|
{
|
|
$cmdline_mysql_client_test.=
|
|
" -A --language=$path_language" .
|
|
" -A --datadir=$slave->[0]->{'path_myddir'}" .
|
|
" -A --character-sets-dir=$path_charsetsdir";
|
|
}
|
|
|
|
my $cmdline_mysql_fix_system_tables=
|
|
"$exe_mysql_fix_system_tables --no-defaults --host=localhost --user=root --password= " .
|
|
"--basedir=$glob_basedir --bindir=$path_client_bindir --verbose " .
|
|
"--port=$master->[0]->{'path_myport'} " .
|
|
"--socket=$master->[0]->{'path_mysock'}";
|
|
|
|
|
|
|
|
# FIXME really needing a PATH???
|
|
# $ENV{'PATH'}= "/bin:/usr/bin:/usr/local/bin:/usr/bsd:/usr/X11R6/bin:/usr/openwin/bin:/usr/bin/X11:$ENV{'PATH'}";
|
|
|
|
$ENV{'MYSQL'}= $cmdline_mysql;
|
|
$ENV{'MYSQL_CHECK'}= $cmdline_mysqlcheck;
|
|
$ENV{'MYSQL_DUMP'}= $cmdline_mysqldump;
|
|
$ENV{'MYSQL_IMPORT'}= $cmdline_mysqlimport;
|
|
$ENV{'MYSQL_SHOW'}= $cmdline_mysqlshow;
|
|
$ENV{'MYSQL_BINLOG'}= $cmdline_mysqlbinlog;
|
|
$ENV{'MYSQL_FIX_SYSTEM_TABLES'}= $cmdline_mysql_fix_system_tables;
|
|
$ENV{'MYSQL_CLIENT_TEST'}= $cmdline_mysql_client_test;
|
|
$ENV{'CHARSETSDIR'}= $path_charsetsdir;
|
|
$ENV{'MYSQL_MY_PRINT_DEFAULTS'}= $exe_my_print_defaults;
|
|
|
|
$ENV{'NDB_STATUS_OK'}= $flag_ndb_status_ok;
|
|
$ENV{'NDB_MGM'}= $exe_ndb_mgm;
|
|
$ENV{'NDB_BACKUP_DIR'}= $path_ndb_data_dir;
|
|
$ENV{'NDB_DATA_DIR'}= $path_ndb_data_dir;
|
|
$ENV{'NDB_TOOLS_DIR'}= $path_ndb_tools_dir;
|
|
$ENV{'NDB_TOOLS_OUTPUT'}= $file_ndb_testrun_log;
|
|
$ENV{'NDB_CONNECTSTRING'}= $opt_ndbconnectstring;
|
|
|
|
my $exe= $exe_mysqltest;
|
|
my $args;
|
|
|
|
mtr_init_args(\$args);
|
|
|
|
mtr_add_arg($args, "--no-defaults");
|
|
mtr_add_arg($args, "--silent");
|
|
mtr_add_arg($args, "-v");
|
|
mtr_add_arg($args, "--skip-safemalloc");
|
|
mtr_add_arg($args, "--tmpdir=%s", $opt_tmpdir);
|
|
|
|
if ($tinfo->{'component_id'} eq 'im')
|
|
{
|
|
mtr_add_arg($args, "--socket=%s", $instance_manager->{'path_sock'});
|
|
mtr_add_arg($args, "--port=%d", $instance_manager->{'port'});
|
|
mtr_add_arg($args, "--user=%s", $instance_manager->{'admin_login'});
|
|
mtr_add_arg($args, "--password=%s", $instance_manager->{'admin_password'});
|
|
}
|
|
else # component_id == mysqld
|
|
{
|
|
mtr_add_arg($args, "--socket=%s", $master->[0]->{'path_mysock'});
|
|
mtr_add_arg($args, "--port=%d", $master->[0]->{'path_myport'});
|
|
mtr_add_arg($args, "--database=test");
|
|
mtr_add_arg($args, "--user=%s", $opt_user);
|
|
mtr_add_arg($args, "--password=");
|
|
}
|
|
|
|
if ( $opt_ps_protocol )
|
|
{
|
|
mtr_add_arg($args, "--ps-protocol");
|
|
}
|
|
|
|
if ( $opt_sp_protocol )
|
|
{
|
|
mtr_add_arg($args, "--sp-protocol");
|
|
}
|
|
|
|
if ( $opt_view_protocol )
|
|
{
|
|
mtr_add_arg($args, "--view-protocol");
|
|
}
|
|
|
|
if ( $opt_cursor_protocol )
|
|
{
|
|
mtr_add_arg($args, "--cursor-protocol");
|
|
}
|
|
|
|
if ( $opt_strace_client )
|
|
{
|
|
$exe= "strace"; # FIXME there are ktrace, ....
|
|
mtr_add_arg($args, "-o");
|
|
mtr_add_arg($args, "%s/log/mysqltest.strace", $opt_vardir);
|
|
mtr_add_arg($args, "$exe_mysqltest");
|
|
}
|
|
|
|
if ( $opt_timer )
|
|
{
|
|
mtr_add_arg($args, "--timer-file=%s/log/timer", $opt_vardir);
|
|
}
|
|
|
|
if ( $opt_big_test )
|
|
{
|
|
mtr_add_arg($args, "--big-test");
|
|
}
|
|
|
|
if ( $opt_compress )
|
|
{
|
|
mtr_add_arg($args, "--compress");
|
|
}
|
|
|
|
if ( $opt_sleep )
|
|
{
|
|
mtr_add_arg($args, "--sleep=%d", $opt_sleep);
|
|
}
|
|
|
|
if ( $opt_debug )
|
|
{
|
|
mtr_add_arg($args, "--debug=d:t:A,%s/log/mysqltest.trace", $opt_vardir_trace);
|
|
}
|
|
|
|
if ( $opt_ssl_supported )
|
|
{
|
|
mtr_add_arg($args, "--ssl-ca=%s/std_data/cacert.pem",
|
|
$glob_mysql_test_dir);
|
|
mtr_add_arg($args, "--ssl-cert=%s/std_data/client-cert.pem",
|
|
$glob_mysql_test_dir);
|
|
mtr_add_arg($args, "--ssl-key=%s/std_data/client-key.pem",
|
|
$glob_mysql_test_dir);
|
|
}
|
|
|
|
# Turn on SSL for all test cases
|
|
if ( $opt_ssl )
|
|
{
|
|
mtr_add_arg($args, "--ssl",
|
|
$glob_mysql_test_dir);
|
|
}
|
|
elsif ( $opt_ssl_supported )
|
|
{
|
|
mtr_add_arg($args, "--skip-ssl",
|
|
$glob_mysql_test_dir);
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# If embedded server, we create server args to give mysqltest to pass on
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( $glob_use_embedded_server )
|
|
{
|
|
mysqld_arguments($args,'master',0,$tinfo->{'master_opt'},[],0);
|
|
}
|
|
|
|
# ----------------------------------------------------------------------
|
|
# export MYSQL_TEST variable containing <path>/mysqltest <args>
|
|
# ----------------------------------------------------------------------
|
|
$ENV{'MYSQL_TEST'}= "$exe_mysqltest " . join(" ", @$args);
|
|
|
|
# ----------------------------------------------------------------------
|
|
# Add arguments that should not go into the MYSQL_TEST env var
|
|
# ----------------------------------------------------------------------
|
|
|
|
if ( $opt_valgrind_mysqltest )
|
|
{
|
|
# Prefix the Valgrind options to the argument list.
|
|
# We do this here, since we do not want to Valgrind the nested invocations
|
|
# of mysqltest; that would mess up the stderr output causing test failure.
|
|
my @args_saved = @$args;
|
|
mtr_init_args(\$args);
|
|
valgrind_arguments($args, \$exe);
|
|
mtr_add_arg($args, "%s", $_) for @args_saved;
|
|
}
|
|
|
|
mtr_add_arg($args, "--test-file");
|
|
mtr_add_arg($args, $tinfo->{'path'});
|
|
|
|
mtr_add_arg($args, "--result-file");
|
|
mtr_add_arg($args, $tinfo->{'result_file'});
|
|
|
|
if ( $opt_record )
|
|
{
|
|
mtr_add_arg($args, "--record");
|
|
}
|
|
|
|
if ( $opt_client_gdb )
|
|
{
|
|
gdb_arguments(\$args, \$exe, "client");
|
|
}
|
|
elsif ( $opt_client_ddd )
|
|
{
|
|
ddd_arguments(\$args, \$exe, "client");
|
|
}
|
|
elsif ( $opt_client_debugger )
|
|
{
|
|
debugger_arguments(\$args, \$exe, "client");
|
|
}
|
|
|
|
if ($glob_use_libtool and $opt_valgrind)
|
|
{
|
|
# Add "libtool --mode-execute" before the test to execute
|
|
# if running in valgrind(to avoid valgrinding bash)
|
|
unshift(@$args, "--mode=execute", $exe);
|
|
$exe= "libtool";
|
|
}
|
|
|
|
if ( $opt_check_testcases )
|
|
{
|
|
run_check_testcase("before");
|
|
}
|
|
|
|
my $res = mtr_run_test($exe,$args,"","",$path_timefile,"");
|
|
|
|
if ( $opt_check_testcases )
|
|
{
|
|
run_check_testcase("after");
|
|
}
|
|
|
|
return $res;
|
|
|
|
}
|
|
|
|
|
|
#
|
|
# Modify the exe and args so that program is run in gdb in xterm
|
|
#
|
|
sub gdb_arguments {
|
|
my $args= shift;
|
|
my $exe= shift;
|
|
my $type= shift;
|
|
|
|
# Write $args to gdb init file
|
|
my $str= join(" ", @$$args);
|
|
my $gdb_init_file= "$opt_tmpdir/gdbinit.$type";
|
|
|
|
# Remove the old gdbinit file
|
|
unlink($gdb_init_file);
|
|
|
|
if ( $type eq "client" )
|
|
{
|
|
# write init file for client
|
|
mtr_tofile($gdb_init_file,
|
|
"set args $str\n" .
|
|
"break main\n");
|
|
}
|
|
else
|
|
{
|
|
# write init file for mysqld
|
|
mtr_tofile($gdb_init_file,
|
|
"set args $str\n" .
|
|
"break mysql_parse\n" .
|
|
"commands 1\n" .
|
|
"disable 1\n" .
|
|
"end\n" .
|
|
"run");
|
|
}
|
|
|
|
if ( $opt_manual_gdb )
|
|
{
|
|
print "\nTo start gdb for $type, type in another window:\n";
|
|
print "cd $glob_mysql_test_dir;\n";
|
|
print "gdb -x $gdb_init_file $$exe\n";
|
|
|
|
# Indicate the exe should not be started
|
|
$$exe= undef;
|
|
return;
|
|
}
|
|
|
|
$$args= [];
|
|
mtr_add_arg($$args, "-title");
|
|
mtr_add_arg($$args, "$type");
|
|
mtr_add_arg($$args, "-e");
|
|
|
|
if ( $glob_use_libtool )
|
|
{
|
|
mtr_add_arg($$args, "libtool");
|
|
mtr_add_arg($$args, "--mode=execute");
|
|
}
|
|
|
|
mtr_add_arg($$args, "gdb");
|
|
mtr_add_arg($$args, "-x");
|
|
mtr_add_arg($$args, "$gdb_init_file");
|
|
mtr_add_arg($$args, "$$exe");
|
|
|
|
$$exe= "xterm";
|
|
}
|
|
|
|
#
|
|
# Modify the exe and args so that program is run in ddd
|
|
#
|
|
sub ddd_arguments {
|
|
my $args= shift;
|
|
my $exe= shift;
|
|
my $type= shift;
|
|
|
|
# Write $args to ddd init file
|
|
my $str= join(" ", @$$args);
|
|
my $gdb_init_file= "$opt_tmpdir/gdbinit.$type";
|
|
|
|
# Remove the old gdbinit file
|
|
unlink($gdb_init_file);
|
|
|
|
if ( $type eq "client" )
|
|
{
|
|
# write init file for client
|
|
mtr_tofile($gdb_init_file,
|
|
"set args $str\n" .
|
|
"break main\n");
|
|
}
|
|
else
|
|
{
|
|
# write init file for mysqld
|
|
mtr_tofile($gdb_init_file,
|
|
"file $$exe\n" .
|
|
"set args $str\n" .
|
|
"break mysql_parse\n" .
|
|
"commands 1\n" .
|
|
"disable 1\n" .
|
|
"end\n" .
|
|
"run");
|
|
}
|
|
|
|
if ( $opt_manual_ddd )
|
|
{
|
|
print "\nTo start ddd for $type, type in another window:\n";
|
|
print "cd $glob_mysql_test_dir;\n";
|
|
print "ddd -x $gdb_init_file $$exe\n";
|
|
|
|
# Indicate the exe should not be started
|
|
$$exe= undef;
|
|
return;
|
|
}
|
|
|
|
my $save_exe= $$exe;
|
|
$$args= [];
|
|
if ( $glob_use_libtool )
|
|
{
|
|
$$exe= "libtool";
|
|
mtr_add_arg($$args, "--mode=execute");
|
|
mtr_add_arg($$args, "ddd");
|
|
}
|
|
else
|
|
{
|
|
$$exe= "ddd";
|
|
}
|
|
mtr_add_arg($$args, "--command=$gdb_init_file");
|
|
mtr_add_arg($$args, "$save_exe");
|
|
}
|
|
|
|
|
|
#
|
|
# Modify the exe and args so that program is run in the selected debugger
|
|
#
|
|
sub debugger_arguments {
|
|
my $args= shift;
|
|
my $exe= shift;
|
|
my $debugger= $opt_debugger || $opt_client_debugger;
|
|
|
|
if ( $debugger eq "vcexpress" or $debugger eq "vc")
|
|
{
|
|
# vc[express] /debugexe exe arg1 .. argn
|
|
|
|
# Add /debugexe and name of the exe before args
|
|
unshift(@$$args, "/debugexe");
|
|
unshift(@$$args, "$$exe");
|
|
|
|
}
|
|
elsif ( $debugger eq "windbg" )
|
|
{
|
|
# windbg exe arg1 .. argn
|
|
|
|
# Add name of the exe before args
|
|
unshift(@$$args, "$$exe");
|
|
|
|
}
|
|
else
|
|
{
|
|
mtr_error("Unknown argument \"$debugger\" passed to --debugger");
|
|
}
|
|
|
|
# Set exe to debuggername
|
|
$$exe= $debugger;
|
|
}
|
|
|
|
|
|
#
|
|
# Modify the exe and args so that program is run in valgrind
|
|
#
|
|
sub valgrind_arguments {
|
|
my $args= shift;
|
|
my $exe= shift;
|
|
|
|
mtr_add_arg($args, "--tool=memcheck"); # From >= 2.1.2 needs this option
|
|
mtr_add_arg($args, "--alignment=8");
|
|
mtr_add_arg($args, "--leak-check=yes");
|
|
mtr_add_arg($args, "--num-callers=16");
|
|
mtr_add_arg($args, "--suppressions=%s/valgrind.supp", $glob_mysql_test_dir)
|
|
if -f "$glob_mysql_test_dir/valgrind.supp";
|
|
|
|
if ( $opt_valgrind_all )
|
|
{
|
|
mtr_add_arg($args, "-v");
|
|
mtr_add_arg($args, "--show-reachable=yes");
|
|
}
|
|
|
|
if ( $opt_valgrind_options )
|
|
{
|
|
mtr_add_arg($args, split(' ', $opt_valgrind_options));
|
|
}
|
|
|
|
|
|
mtr_add_arg($args, $$exe);
|
|
|
|
$$exe= $opt_valgrind_path || "valgrind";
|
|
}
|
|
|
|
|
|
##############################################################################
|
|
#
|
|
# Usage
|
|
#
|
|
##############################################################################
|
|
|
|
sub usage ($) {
|
|
print STDERR <<HERE;
|
|
|
|
mysql-test-run [ OPTIONS ] [ TESTCASE ]
|
|
|
|
FIXME when is TESTCASE arg used or not?!
|
|
|
|
Options to control what engine/variation to run
|
|
|
|
embedded-server Use the embedded server, i.e. no mysqld daemons
|
|
ps-protocol Use the binary protocol between client and server
|
|
cursor-protocol Use the cursor protocol between client and server
|
|
(implies --ps-protocol)
|
|
view-protocol Create a view to execute all non updating queries
|
|
sp-protocol Create a stored procedure to execute all queries
|
|
compress Use the compressed protocol between client and server
|
|
ssl Use ssl protocol between client and server
|
|
skip-ssl Dont start server with support for ssl connections
|
|
bench Run the benchmark suite FIXME
|
|
small-bench FIXME
|
|
|
|
Options to control directories to use
|
|
vardir=DIR The directory where files generated from the test run
|
|
is stored(default: ./var). Specifying a ramdisk or tmpfs
|
|
will speed up tests.
|
|
tmpdir=DIR The directory where temporary files are stored
|
|
(default: ./var/tmp).
|
|
|
|
Options to control what test suites or cases to run
|
|
|
|
force Continue to run the suite after failure
|
|
with-ndbcluster Use cluster, and enable test cases that requres it
|
|
skip-ndb[cluster] Skip the ndb test cases, don't start cluster
|
|
do-test=PREFIX Run test cases which name are prefixed with PREFIX
|
|
start-from=PREFIX Run test cases starting from test prefixed with PREFIX
|
|
suite=NAME Run the test suite named NAME. The default is "main"
|
|
skip-rpl Skip the replication test cases.
|
|
skip-im Don't start IM, and skip the IM test cases
|
|
skip-test=PREFIX Skip test cases which name are prefixed with PREFIX
|
|
|
|
Options that specify ports
|
|
|
|
master_port=PORT Specify the port number used by the first master
|
|
slave_port=PORT Specify the port number used by the first slave
|
|
ndbcluster_port=PORT Specify the port number used by cluster
|
|
|
|
Options for test case authoring
|
|
|
|
record TESTNAME (Re)genereate the result file for TESTNAME
|
|
check-testcases Check testcases for sideeffects
|
|
|
|
Options that pass on options
|
|
|
|
mysqld=ARGS Specify additional arguments to "mysqld"
|
|
|
|
Options to run test on running server
|
|
|
|
extern Use running server for tests FIXME DANGEROUS
|
|
ndbconnectstring=STR Use running cluster, and connect using STR
|
|
user=USER User for connect to server
|
|
|
|
Options for debugging the product
|
|
|
|
gdb Start the mysqld(s) in gdb
|
|
manual-gdb Let user manually start mysqld in gdb, before running test(s)
|
|
manual-debug Let user manually start mysqld in debugger, before running test(s)
|
|
client-gdb Start mysqltest client in gdb
|
|
ddd Start mysqld in ddd
|
|
client-ddd Start mysqltest client in ddd
|
|
debugger=NAME Start mysqld in the selected debugger
|
|
client-debugger=NAME Start mysqltest in the selected debugger
|
|
strace-client FIXME
|
|
master-binary=PATH Specify the master "mysqld" to use
|
|
slave-binary=PATH Specify the slave "mysqld" to use
|
|
|
|
Options for coverage, profiling etc
|
|
|
|
gcov FIXME
|
|
gprof FIXME
|
|
valgrind Run the "mysqltest" and "mysqld" executables using valgrind
|
|
valgrind-all Same as "valgrind" but will also add "verbose" and "--show-reachable"
|
|
flags to valgrind
|
|
valgrind-mysqltest Run the "mysqltest" executable with valgrind
|
|
valgrind-mysqld Run the "mysqld" executable with valgrind
|
|
valgrind-options=ARGS Extra options to give valgrind
|
|
valgrind-path=[EXE] Path to the valgrind executable
|
|
|
|
Misc options
|
|
|
|
comment=STR Write STR to the output
|
|
script-debug Debug this script itself
|
|
timer Show test case execution time
|
|
start-and-exit Only initiate and start the "mysqld" servers, use the startup
|
|
settings for the specified test case if any
|
|
start-dirty Only start the "mysqld" servers without initiation
|
|
fast Don't try to cleanup from earlier runs
|
|
reorder Reorder tests to get less server restarts
|
|
help Get this help text
|
|
unified-diff | udiff When presenting differences, use unified diff
|
|
|
|
testcase-timeout=MINUTES Max test case run time (default 5)
|
|
suite-timeout=MINUTES Max test suite run time (default 120)
|
|
|
|
Deprecated options
|
|
with-openssl Deprecated option for ssl
|
|
|
|
|
|
Options not yet described, or that I want to look into more
|
|
|
|
big-test
|
|
debug
|
|
local
|
|
local-master
|
|
netware
|
|
old-master
|
|
sleep=SECONDS
|
|
socket=PATH
|
|
user-test=s
|
|
wait-timeout=SECONDS
|
|
warnings
|
|
log-warnings
|
|
|
|
HERE
|
|
mtr_exit(1);
|
|
|
|
}
|