#!/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_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_running_ndbcluster_slave= 0; our $glob_use_embedded_server= 0; our @glob_test_mode; our $using_ndbcluster_master= 0; our $using_ndbcluster_slave= 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_slave_load_tmpdir; # What is this?! our $path_mysqltest_log; our $path_current_test_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_mysqlslap; # 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 $lib_udf_example; our $exe_libtool; 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_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_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_ndbcluster_port_slave; our $opt_ndbconnectstring_slave; our $opt_old_master; our $opt_record; our $opt_check_testcases; our $opt_result_ext; our $opt_skip; our $opt_skip_rpl; our $use_slaves; 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= 1; our $opt_user; our $opt_user_test; our $opt_valgrind= 0; our $opt_valgrind_mysqld= 0; our $opt_valgrind_mysqltest= 0; our $default_valgrind_options= "-v --show-reachable=yes"; 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= 0; our $opt_with_ndbcluster; our $opt_skip_ndbcluster_slave= 0; our $opt_with_ndbcluster_slave; our $opt_with_ndbcluster_all= 0; our $opt_with_ndbcluster_only= 0; our $opt_ndb_extra_test= 0; our $opt_skip_master_binlog= 0; our $opt_skip_slave_binlog= 0; our $exe_ndb_mgm; our $path_ndb_tools_dir; our $path_ndb_data_dir; our $path_ndb_slave_data_dir; our $file_ndb_testrun_log; our $flag_ndb_status_ok= 1; our $flag_ndb_slave_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_running_as_root(); sub check_ndbcluster_support (); sub rm_ndbcluster_tables ($); sub ndbcluster_install (); sub ndbcluster_start ($); sub ndbcluster_stop (); sub ndbcluster_install_slave (); sub ndbcluster_start_slave ($); sub ndbcluster_stop_slave (); 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_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); foreach my $test (@$tests) { $need_ndbcluster||= $test->{ndb_test}; $need_im||= $test->{component_id} eq 'im'; $use_slaves||= $test->{slave_num}; } $opt_with_ndbcluster= $opt_with_ndbcluster_slave= 0 unless $need_ndbcluster; $opt_skip_im= 1 unless $need_im; 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); # 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); # Expect mysql-bench to be located adjacent to the source tree, by default $glob_mysql_bench_dir= "$glob_basedir/../mysql-bench" unless defined $glob_mysql_bench_dir; # 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_comment; my $opt_master_myport= 9306; my $opt_slave_myport= 9308; $opt_ndbcluster_port= 9310; $opt_ndbcluster_port_slave= 9311; my $im_port= 9312; my $im_mysqld1_port= 9313; 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; $opt_ndbcluster_port_slave= $opt_master_myport + 6; $im_port= $opt_master_myport + 7; $im_mysqld1_port= $opt_master_myport + 8; $im_mysqld2_port= $opt_master_myport + 9; } 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, # 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-slave' => \$opt_with_ndbcluster_slave, 'skip-ndbcluster-slave|skip-ndb-slave' => \$opt_skip_ndbcluster_slave, 'with-ndbcluster-all' => \$opt_with_ndbcluster_all, 'with-ndbcluster-only' => \$opt_with_ndbcluster_only, 'ndb-extra-test' => \$opt_ndb_extra_test, 'skip-master-binlog' => \$opt_skip_master_binlog, 'skip-slave-binlog' => \$opt_skip_slave_binlog, 'do-test=s' => \$opt_do_test, 'start-from=s' => \$opt_start_from, 'suite=s' => \$opt_suite, 'skip-rpl' => \$opt_skip_rpl, 'skip-im' => \$opt_skip_im, 'skip-test=s' => \$opt_skip_test, 'big-test' => \$opt_big_test, # Specify ports 'master_port=i' => \$opt_master_myport, 'slave_port=i' => \$opt_slave_myport, 'ndbcluster-port|ndbcluster_port=i' => \$opt_ndbcluster_port, 'ndbcluster-port-slave=i' => \$opt_ndbcluster_port_slave, '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, # Extra options used when starting mysqld 'mysqld=s' => \@opt_extra_mysqld_opt, # Run test on running server 'extern' => \$opt_extern, 'ndb-connectstring=s' => \$opt_ndbconnectstring, 'ndb-connectstring-slave=s' => \$opt_ndbconnectstring_slave, # 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|valgrind-all' => \$opt_valgrind, 'valgrind-mysqltest' => \$opt_valgrind_mysqltest, 'valgrind-mysqld' => \$opt_valgrind_mysqld, '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, 'benchdir=s' => \$glob_mysql_bench_dir, # Misc '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, '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"); usage("") if $opt_usage; if ( $opt_comment ) { print "\n"; print '#' x 78, "\n"; print "# $opt_comment\n"; print '#' x 78, "\n\n"; } foreach my $arg ( @ARGV ) { if ( $arg =~ /^--skip-/ ) { push(@opt_extra_mysqld_opt, $arg); } elsif ( $arg =~ /^--$/ ) { # It is an effect of setting 'pass_through' in option processing # that the lone '--' separating options from arguments survives, # simply ignore it. } 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 # -------------------------------------------------------------------------- # 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 $opt_skip_ndbcluster= 1; # Avoid auto detection $opt_skip_ssl= 1; 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"); } } # Check valgrind arguments if ( $opt_valgrind or $opt_valgrind_path or defined $opt_valgrind_options) { mtr_report("Turning on valgrind for all executables"); $opt_valgrind= 1; $opt_valgrind_mysqld= 1; $opt_valgrind_mysqltest= 1; } elsif ( $opt_valgrind_mysqld ) { mtr_report("Turning on valgrind for mysqld(s) only"); $opt_valgrind= 1; } elsif ( $opt_valgrind_mysqltest ) { mtr_report("Turning on valgrind for mysqltest only"); $opt_valgrind= 1; } if ( $opt_valgrind ) { # Set valgrind_options to default unless already defined $opt_valgrind_options=$default_valgrind_options unless defined $opt_valgrind_options; mtr_report("Running valgrind with options \"$opt_valgrind_options\""); } 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, ndbcluster => 1, # ndbcluster not started }; $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_angel_pid => "$opt_vardir/run/im.angel.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", old_log_format => 1 }; $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, old_log_format => 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_current_test_log= "$opt_vardir/log/current_test"; $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'}); if ($use_slaves) { 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 () { # # Check if libtool is available in this distribution/clone # we need it when valgrinding or debugging non installed binary # Otherwise valgrind will valgrind the libtool wrapper or bash # and gdb will not find the real executable to debug # if ( -x "../libtool") { $exe_libtool= "../libtool"; if ($opt_valgrind or $glob_debugger) { mtr_report("Using \"$exe_libtool\" when running valgrind or debugger"); } } if ( $opt_source_dist ) { if ( $glob_win32 ) { $path_client_bindir= mtr_path_exists("$glob_basedir/client_release", "$glob_basedir/client_debug", "$glob_basedir/bin", # New CMake locations. "$glob_basedir/client/release", "$glob_basedir/client/debug"); $exe_mysqld= mtr_exe_exists ("$path_client_bindir/mysqld-nt", "$path_client_bindir/mysqld", "$path_client_bindir/mysqld-debug", "$path_client_bindir/mysqld-max", "$glob_basedir/sql/release/mysqld", "$glob_basedir/sql/debug/mysqld"); $path_language= mtr_path_exists("$glob_basedir/share/english/", "$glob_basedir/sql/share/english/"); $path_charsetsdir= mtr_path_exists("$glob_basedir/share/charsets", "$glob_basedir/sql/share/charsets"); $exe_my_print_defaults= mtr_exe_exists("$path_client_bindir/my_print_defaults", "$glob_basedir/extra/release/my_print_defaults", "$glob_basedir/extra/debug/my_print_defaults"); } else { $path_client_bindir= mtr_path_exists("$glob_basedir/client"); $exe_mysqld= mtr_exe_exists ("$glob_basedir/sql/mysqld"); $exe_mysqlslap= mtr_exe_exists ("$path_client_bindir/mysqlslap"); $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", "$glob_basedir/tests/release/mysql_client_test", "$glob_basedir/tests/debug/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", "/usr/bin/false"); $path_ndb_tools_dir= mtr_path_exists("$glob_basedir/storage/ndb/tools"); $exe_ndb_mgm= "$glob_basedir/storage/ndb/src/mgmclient/ndb_mgm"; $lib_udf_example= mtr_file_exists("$glob_basedir/sql/.libs/udf_example.so"); } 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", "/usr/bin/false"); $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_mysqlslap= mtr_exe_exists("$path_client_bindir/mysqlslap"); } $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", "$glob_basedir/tests/release/mysql_client_test", "$glob_basedir/tests/debug/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"; $path_ndb_slave_data_dir= "$opt_vardir/ndbcluster-$opt_ndbcluster_port_slave"; $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 () { umask(022); # -------------------------------------------------------------------------- # 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'}= ($lib_udf_example ? dirname($lib_udf_example) : "") . ($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{'NDBCLUSTER_PORT_SLAVE'}=$opt_ndbcluster_port_slave; $ENV{'NDB_STATUS_OK'}= "YES"; $ENV{'IM_EXE'}= $exe_im; $ENV{'IM_PATH_PID'}= $instance_manager->{path_pid}; $ENV{'IM_PATH_ANGEL_PID'}= $instance_manager->{path_angel_pid}; $ENV{'IM_PORT'}= $instance_manager->{port}; $ENV{'IM_DEFAULTS_PATH'}= $instance_manager->{defaults_file}; $ENV{'IM_PASSWORD_PATH'}= $instance_manager->{password_file}; $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 if (!$opt_extern) { 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 NDBCLUSTER_PORT_SLAVE = $ENV{NDBCLUSTER_PORT_SLAVE}\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; $using_ndbcluster_slave= $opt_with_ndbcluster; ndbcluster_stop_slave(); $slave->[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_running_as_root () { # Check if running as root # i.e a file can be read regardless what mode we set it to my $test_file= "$opt_vardir/test_running_as_root.txt"; mtr_tofile($test_file, "MySQL"); chmod(oct("0000"), $test_file); my $result=""; if (open(FILE,"<",$test_file)) { $result= join('', ); close FILE; } chmod(oct("0755"), $test_file); unlink($test_file); $ENV{'MYSQL_TEST_ROOT'}= "NO"; if ($result eq "MySQL") { mtr_warning("running this script as _root_ will cause some " . "tests to be skipped"); $ENV{'MYSQL_TEST_ROOT'}= "YES"; } } sub check_ssl_support () { if ($opt_skip_ssl || $opt_extern) { 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_skip_ndbcluster_slave= 1; $opt_with_ndbcluster= 0; $opt_with_ndbcluster_slave= 0; 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_skip_ndbcluster= 1; $opt_skip_ndbcluster_slave= 1; $opt_with_ndbcluster= 0; $opt_with_ndbcluster_slave= 0; return; } mtr_report("Using ndbcluster if necessary, mysqld supports it"); $opt_with_ndbcluster= 1; if ( $opt_ndbconnectstring ) { $glob_use_running_ndbcluster= 1; } else { $opt_ndbconnectstring= "host=localhost:$opt_ndbcluster_port"; } if ( $opt_skip_ndbcluster_slave ) { $opt_with_ndbcluster_slave= 0; } else { $opt_with_ndbcluster_slave= 1; if ( $opt_ndbconnectstring_slave ) { $glob_use_running_ndbcluster_slave= 1; } else { $opt_ndbconnectstring_slave= "host=localhost:$opt_ndbcluster_port_slave"; } } return; } sub ndbcluster_install () { if ( ! $opt_with_ndbcluster or $glob_use_running_ndbcluster ) { return 0; } mtr_report("Installing ndbcluster master"); my $ndbcluster_opts= $opt_bench ? "" : "--small"; if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster", ["--port=$opt_ndbcluster_port", "--data-dir=$opt_vardir", "--verbose=2", $ndbcluster_opts, "--initial", "--relative-config-data-dir", "--core"], "", "", "", "") ) { 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 #mtr_report("Starting ndbcluster master"); if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster", ["--port=$opt_ndbcluster_port", "--data-dir=$opt_vardir", "--character-sets-dir=$path_charsetsdir", "--verbose=2", "--core"], "", "/dev/null", "", "") ) { mtr_error("Error ndbcluster_start"); $using_ndbcluster_master= 0; return 1; } $using_ndbcluster_master= 1; return 0; } sub rm_ndbcluster_tables ($) { my $dir= shift; foreach my $bin ( glob("$dir/cluster/apply_status*"), glob("$dir/cluster/schema*") ) { unlink($bin); } } 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_report("Stopping ndbcluster master"); mtr_run("$glob_mysql_test_dir/ndb/ndbcluster", ["--port=$opt_ndbcluster_port", "--data-dir=$opt_vardir", "--verbose=2", "--stop"], "", "/dev/null", "", ""); rm_ndbcluster_tables ($master->[0]->{'path_myddir'}); rm_ndbcluster_tables ($master->[1]->{'path_myddir'}); $using_ndbcluster_master= 0; return; } sub ndbcluster_install_slave () { if ( ! $opt_with_ndbcluster_slave or $glob_use_running_ndbcluster_slave ) { return 0; } mtr_report("Installing ndbcluster slave"); if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster", ["--port=$opt_ndbcluster_port_slave", "--data-dir=$opt_vardir", "--verbose=2", "--small", "--ndbd-nodes=1", "--initial", "--relative-config-data-dir", "--core"], "", "", "", "") ) { return 1; } $using_ndbcluster_slave= 1; ndbcluster_stop_slave(); $slave->[0]->{'ndbcluster'}= 1; return 0; } sub ndbcluster_start_slave ($) { my $use_ndbcluster= shift; if ( ! $use_ndbcluster ) { $using_ndbcluster_slave= 0; return 0; } if ( $glob_use_running_ndbcluster_slave ) { $using_ndbcluster_slave= 1; return 0; } # FIXME, we want to _append_ output to file $file_ndb_testrun_log instead of /dev/null #mtr_report("Starting ndbcluster slave"); if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster", ["--port=$opt_ndbcluster_port_slave", "--data-dir=$opt_vardir", "--verbose=2", "--ndbd-nodes=1", "--core"], "", "/dev/null", "", "") ) { mtr_error("Error ndbcluster_start_slave"); $using_ndbcluster_slave= 0; return 1; } $using_ndbcluster_slave= 1; return 0; } sub ndbcluster_stop_slave () { if ( ! $using_ndbcluster_slave or $glob_use_running_ndbcluster_slave ) { $using_ndbcluster_slave= 0; return; } # FIXME, we want to _append_ output to file $file_ndb_testrun_log instead of /dev/null #mtr_report("Stopping ndbcluster slave"); mtr_run("$glob_mysql_test_dir/ndb/ndbcluster", ["--port=$opt_ndbcluster_port_slave", "--data-dir=$opt_vardir", "--verbose=2", "--stop"], "", "/dev/null", "", ""); rm_ndbcluster_tables ($slave->[0]->{'path_myddir'}); $using_ndbcluster_slave= 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"); } chdir($glob_mysql_bench_dir) or mtr_error("Couldn't chdir to '$glob_mysql_bench_dir': $!"); # 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(); } } check_running_as_root(); } } 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 ( $use_slaves ) { 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; $ENV{'NDB_STATUS_OK'}= "NO"; } else { print "Aborting: Failed to install ndb cluster\n"; print "To continue, re-run with '--force'.\n"; mtr_exit(1); } } if ( $use_slaves and ndbcluster_install_slave() ) { if ( $opt_force) { # failed to install, disable usage and flag that its no ok mtr_report("ndbcluster_install_slave failed, " . "continuing without slave cluster"); $opt_with_ndbcluster_slave= 0; $flag_ndb_slave_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 Database"); 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 () { 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"); mtr_add_arg($args, "--tmpdir=."); if ( ! $opt_netware ) { mtr_add_arg($args, "--language=%s", $path_language); mtr_add_arg($args, "--character-sets-dir=%s", $path_charsetsdir); } # Log bootstrap command my $path_bootstrap_log= "$opt_vardir/log/bootstrap.log"; mtr_tofile($path_bootstrap_log, "$exe_mysqld " . join(" ", @$args) . "\n"); if ( mtr_run($exe_mysqld, $args, $init_db_sql_tmp, $path_bootstrap_log, $path_bootstrap_log, "", { append_log_file => 1 }) != 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 <{path_pid} angel-pid-file = $instance_manager->{path_angel_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 <{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 "log-output=FILE\n" if $instance->{'old_log_format'}; 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'}; my $ndbcluster_opt; mtr_tonewfile($path_current_test_log,"$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"); if ( $master->[1]->{'pid'} ) { mtr_tofile($master->[1]->{'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 # First wait for first mysql server to have created ndb system tables ok if ( ! sleep_until_file_created("$master->[0]->{'path_myddir'}/cluster/apply_status.ndb", $master->[0]->{'start_timeout'}, $master->[0]->{'pid'})) { report_failure_and_restart($tinfo); return; } mtr_tofile($master->[1]->{'path_myerr'},"CURRENT_TEST: $tname\n"); $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'} ) { $ndbcluster_opt= 0; if ( $idx == 0) { if ( $slave->[0]->{'ndbcluster'} ) { $slave->[0]->{'ndbcluster'}= ndbcluster_start_slave($tinfo->{'ndb_test'}); if ( $slave->[0]->{'ndbcluster'} ) { report_failure_and_restart($tinfo); return; } } $ndbcluster_opt= $using_ndbcluster_slave; } $slave->[$idx]->{'pid'}= mysqld_start('slave',$idx, $tinfo->{'slave_opt'}, $tinfo->{'slave_mi'}, $ndbcluster_opt); if ( ! $slave->[$idx]->{'pid'} ) { report_failure_and_restart($tinfo); return; } } } } } # ---------------------------------------------------------------------- # If --start-and-exit or --start-dirty given, stop here to let user manually # run tests # ---------------------------------------------------------------------- if ( $opt_start_and_exit or $opt_start_dirty ) { 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); } } # # 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); mtr_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"); mtr_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"); if ( $opt_with_ndbcluster_slave ) { # Remove also the ndb_*_fs dirs for slave cluster rmtree("$path_ndb_slave_data_dir/ndb_1_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; if (! $opt_skip_master_binlog) { 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:10M: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); mtr_add_arg($args, "%s--ndb-extra-logging", $prefix); } } 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); if (! $opt_skip_slave_binlog) { 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); } if ( $opt_skip_ndbcluster_slave ) { mtr_add_arg($args, "%s--skip-ndbcluster", $prefix); } if ( $idx == 0 and $using_ndbcluster_slave ) { mtr_add_arg($args, "%s--ndbcluster", $prefix); mtr_add_arg($args, "%s--ndb-connectstring=%s", $prefix, $opt_ndbconnectstring_slave); mtr_add_arg($args, "%s--ndb-extra-logging", $prefix); } } # 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; } ############################################################################## # # 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 ($exe_libtool and $opt_valgrind) { # Add "libtool --mode-execute" # if running in valgrind(to avoid valgrinding bash) unshift(@$args, "--mode=execute", $exe); $exe= $exe_libtool; } 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 } } if ( ! $slave->[0]->{'ndbcluster'} ) { ndbcluster_stop_slave(); $slave->[0]->{'ndbcluster'}= 1; } 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'}); if ( $opt_debug ) { mtr_add_arg($args, "--debug=d:t:i:A,%s/log/im.trace", $opt_vardir_trace); } 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; # Obtain mysqld-process pids before we start stopping IM (it can delete pid # files). my @mysqld_pids = (); my $instances = $instance_manager->{'instances'}; push(@mysqld_pids, mtr_get_pid_from_file($instances->[0]->{'path_pid'})) if -r $instances->[0]->{'path_pid'}; push(@mysqld_pids, mtr_get_pid_from_file($instances->[1]->{'path_pid'})) if -r $instances->[1]->{'path_pid'}; # 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'}; if (-f $instance_manager->{'path_angel_pid'}) { $instance_manager->{'angel_pid'} = mtr_get_pid_from_file($instance_manager->{'path_angel_pid'}) } else { $instance_manager->{'angel_pid'} = undef; } # Inspired from mtr_stop_mysqld_servers(). start_reap_all(); # Try graceful shutdown. mtr_kill_process($instance_manager->{'pid'}, 'TERM', 10, 1); # Check that all processes died. my $clean_shutdown= 0; while (1) { last if kill (0, $instance_manager->{'pid'}); last if (defined $instance_manager->{'angel_pid'}) && kill (0, $instance_manager->{'angel_pid'}); foreach my $pid (@mysqld_pids) { last if kill (0, $pid); } $clean_shutdown= 1; last; } # Kill leftovers (the order is important). unless ($clean_shutdown) { mtr_kill_process($instance_manager->{'angel_pid'}, 'KILL', 10, 1) if defined $instance_manager->{'angel_pid'}; mtr_kill_process($instance_manager->{'pid'}, 'KILL', 10, 1); # Shutdown managed mysqld-processes. Some of them may be nonguarded, so IM # will not stop them on shutdown. So, we should firstly try to end them # legally. mtr_kill_processes(\@mysqld_pids); # Complain in error log so that a warning will be shown. my $errlog= "$opt_vardir/log/mysql-test-run.pl.err"; open (ERRLOG, ">>$errlog") || mtr_error("Can not open error log ($errlog)"); my $ts= localtime(); print ERRLOG "Warning: [$ts] Instance Manager did not shutdown gracefully.\n"; close ERRLOG; } # That's all. stop_reap_all(); $instance_manager->{'pid'} = undef; $instance_manager->{'angel_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="; my $cmdline_mysqldumpslave= "$exe_mysqldump --no-defaults -uroot " . "--socket=$slave->[0]->{'path_mysock'} --password="; if ( $opt_debug ) { $cmdline_mysqldump .= " --debug=d:t:A,$opt_vardir_trace/log/mysqldump.trace"; } my $cmdline_mysqlslap; unless ( $glob_win32 ) { $cmdline_mysqlslap= "$exe_mysqlslap -uroot " . "--port=$master->[0]->{'path_myport'} " . "--socket=$master->[0]->{'path_mysock'} --password= " . "--lock-directory=$opt_tmpdir"; if ( $opt_debug ) { $cmdline_mysqlslap .= " --debug=d:t:A,$opt_vardir_trace/log/mysqlslap.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 --no-defaults --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'}"; $ENV{'MYSQL'}= $cmdline_mysql; $ENV{'MYSQL_CHECK'}= $cmdline_mysqlcheck; $ENV{'MYSQL_DUMP'}= $cmdline_mysqldump; $ENV{'MYSQL_SLAP'}= $cmdline_mysqlslap unless $glob_win32; $ENV{'MYSQL_IMPORT'}= $cmdline_mysqlimport; $ENV{'MYSQL_DUMP_SLAVE'}= $cmdline_mysqldumpslave; $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{'UDF_EXAMPLE_LIB'}= ($lib_udf_example ? basename($lib_udf_example) : ""); $ENV{'NDB_STATUS_OK'}= $flag_ndb_status_ok ? "YES" : "NO"; $ENV{'NDB_SLAVE_STATUS_OK'}= $flag_ndb_slave_status_ok ? "YES" : "NO"; $ENV{'NDB_EXTRA_TEST'}= $opt_ndb_extra_test; $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 /mysqltest # ---------------------------------------------------------------------- $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 ($exe_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= $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 ( $exe_libtool ) { mtr_add_arg($$args, $exe_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"); } 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 ( $exe_libtool ) { $$exe= $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; # FIXME Need to change the below "eq"'s to # "case unsensitive string contains" 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"; # Add valgrind options, can be overriden by user mtr_add_arg($args, '%s', $_) for (split(' ', $opt_valgrind_options)); mtr_add_arg($args, $$exe); $$exe= $opt_valgrind_path || "valgrind"; } ############################################################################## # # Usage # ############################################################################## sub usage ($) { my $message= shift; if ( $message ) { print STDERR "$message \n"; } print STDERR <