开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
mysql-test-run.pl
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：71k
源码类别：

MySQL数据库

开发平台：

Visual C++

mysql-test-run.pl：源码内容
  1. #!/usr/bin/perl
  2. # -*- cperl -*-
  4. # This is a transformation of the "mysql-test-run" Bourne shell script
  5. # to Perl. There are reasons this rewrite is not the prettiest Perl
  6. # you have seen
  7. #
  8. #   - The original script is huge and for most part uncommented,
  9. #     not even a usage description of the flags.
  10. #
  11. #   - There has been an attempt to write a replacement in C for the
  12. #     original Bourne shell script. It was kind of working but lacked
  13. #     lot of functionality to really be a replacement. Not to redo
  14. #     that mistake and catch all the obscure features of the original
  15. #     script, the rewrite in Perl is more close to the original script
  16. #     meaning it also share some of the ugly parts as well.
  17. #
  18. #   - The original intention was that this script was to be a prototype
  19. #     to be the base for a new C version with full functionality. Since
  20. #     then it was decided that the Perl version should replace the
  21. #     Bourne shell version, but the Perl style still reflects the wish
  22. #     to make the Perl to C step easy.
  23. #
  24. # Some coding style from the original intent has been kept
  25. #
  26. #   - To make this Perl script easy to alter even for those that not
  27. #     code Perl that often, the coding style is as close as possible to
  28. #     the C/C++ MySQL coding standard.
  29. #
  30. #   - All lists of arguments to send to commands are Perl lists/arrays,
  31. #     not strings we append args to. Within reason, most string
  32. #     concatenation for arguments should be avoided.
  33. #
  34. #   - Functions defined in the main program are not to be prefixed,
  35. #     functions in "library files" are to be prefixed with "mtr_" (for
  36. #     Mysql-Test-Run). There are some exceptions, code that fits best in
  37. #     the main program, but are put into separate files to avoid
  38. #     clutter, may be without prefix.
  39. #
  40. #   - All stat/opendir/-f/ is to be kept in collect_test_cases(). It
  41. #     will create a struct that the rest of the program can use to get
  42. #     the information. This separates the "find information" from the
  43. #     "do the work" and makes the program more easy to maintain.
  44. #
  45. #   - At the moment, there are tons of "global" variables that control
  46. #     this script, even accessed from the files in "lib/*.pl". This
  47. #     will change over time, for now global variables are used instead
  48. #     of using %opt, %path and %exe hashes, because I want more
  49. #     compile time checking, that hashes would not give me. Once this
  50. #     script is debugged, hashes will be used and passed as parameters
  51. #     to functions, to more closely mimic how it would be coded in C
  52. #     using structs.
  53. #
  54. #   - The rule when it comes to the logic of this program is
  55. #
  56. #       command_line_setup() - is to handle the logic between flags
  57. #       collect_test_cases() - is to do its best to select what tests
  58. #                              to run, dig out options, if needs restart etc.
  59. #       run_testcase()       - is to run a single testcase, and follow the
  60. #                              logic set in both above. No, or rare file
  61. #                              system operations. If a test seems complex,
  62. #                              it should probably not be here.
  63. #
  64. # A nice way to trace the execution of this script while debugging
  65. # is to use the Devel::Trace package found at
  66. # "http://www.plover.com/~mjd/perl/Trace/" and run this script like
  67. # "perl -d:Trace mysql-test-run.pl"
  68. #
  69. # FIXME Save a PID file from this code as well, to record the process
  70. #       id we think it has. In Cygwin, a fork creates one Cygwin process,
  71. #       and then the real Win32 process. Cygwin Perl can only kill Cygwin
  72. #       processes. And "mysqld --bootstrap ..." doesn't save a PID file.
  74. $Devel::Trace::TRACE= 0;       # Don't trace boring init stuff
  76. #require 5.6.1;
  77. use File::Path;
  78. use File::Basename;
  79. use Cwd;
  80. use Getopt::Long;
  81. use Sys::Hostname;
  82. #use Carp;
  83. use IO::Socket;
  84. use IO::Socket::INET;
  85. use Data::Dumper;
  86. use strict;
  87. #use diagnostics;
  89. require "lib/mtr_cases.pl";
  90. require "lib/mtr_process.pl";
  91. require "lib/mtr_timer.pl";
  92. require "lib/mtr_io.pl";
  93. require "lib/mtr_gcov.pl";
  94. require "lib/mtr_gprof.pl";
  95. require "lib/mtr_report.pl";
  96. require "lib/mtr_diff.pl";
  97. require "lib/mtr_match.pl";
  98. require "lib/mtr_misc.pl";
  100. $Devel::Trace::TRACE= 1;
  102. # Used by gcov
  103. our @mysqld_src_dirs=
  104.   (
  105.    "strings",
  106.    "mysys",
  107.    "include",
  108.    "extra",
  109.    "regex",
  110.    "isam",
  111.    "merge",
  112.    "myisam",
  113.    "myisammrg",
  114.    "heap",
  115.    "sql",
  116.   );
  118. ##############################################################################
  119. #
  120. #  Default settings
  121. #
  122. ##############################################################################
  124. # We are to use handle_options() in "mysys/my_getopt.c" for the C version
  125. #
  126. # In the C version we want to use structs and, in some cases, arrays of
  127. # structs. We let each struct be a separate hash.
  129. # Misc global variables
  131. our $glob_win32=                  0; # OS and native Win32 executables
  132. our $glob_win32_perl=             0; # ActiveState Win32 Perl
  133. our $glob_cygwin_perl=            0; # Cygwin Perl
  134. our $glob_cygwin_shell=           undef;
  135. our $glob_mysql_test_dir=         undef;
  136. our $glob_mysql_bench_dir=        undef;
  137. our $glob_hostname=               undef;
  138. our $glob_scriptname=             undef;
  139. our $glob_timers=                 undef;
  140. our $glob_use_running_server=     0;
  141. our $glob_use_running_ndbcluster= 0;
  142. our $glob_use_embedded_server=    0;
  143. our @glob_test_mode;
  145. our $glob_basedir;
  147. # The total result
  149. our $path_charsetsdir;
  150. our $path_client_bindir;
  151. our $path_language;
  152. our $path_timefile;
  153. our $path_manager_log;           # Used by mysqldadmin
  154. our $path_slave_load_tmpdir;     # What is this?!
  155. our $path_my_basedir;
  156. our $opt_vardir;                 # A path but set directly on cmd line
  157. our $opt_tmpdir;                 # A path but set directly on cmd line
  159. our $opt_usage;
  160. our $opt_suite;
  162. our $opt_netware;
  164. our $opt_script_debug= 0;  # Script debugging, enable with --script-debug
  166. # Options FIXME not all....
  168. our $exe_master_mysqld;
  169. our $exe_mysql;
  170. our $exe_mysqladmin;
  171. our $exe_mysqlbinlog;
  172. our $exe_mysql_client_test;
  173. our $exe_mysqld;
  174. our $exe_mysqldump;              # Called from test case
  175. our $exe_mysqlimport;              # Called from test case
  176. our $exe_mysqlshow;              # Called from test case
  177. our $exe_mysql_fix_system_tables;
  178. our $exe_mysqltest;
  179. our $exe_slave_mysqld;
  181. our $opt_bench= 0;
  182. our $opt_small_bench= 0;
  183. our $opt_big_test= 0;            # Send --big-test to mysqltest
  185. our @opt_extra_mysqld_opt;
  187. our $opt_compress;
  188. our $opt_current_test;
  189. our $opt_ddd;
  190. our $opt_debug;
  191. our $opt_do_test;
  192. our @opt_cases;                  # The test cases names in argv
  193. our $opt_embedded_server;
  194. our $opt_extern;
  195. our $opt_fast;
  196. our $opt_force;
  197. our $opt_reorder;
  199. our $opt_gcov;
  200. our $opt_gcov_err;
  201. our $opt_gcov_msg;
  203. our $opt_gdb;
  204. our $opt_client_gdb;
  205. our $opt_manual_gdb;
  207. our $opt_gprof;
  208. our $opt_gprof_dir;
  209. our $opt_gprof_master;
  210. our $opt_gprof_slave;
  212. our $opt_local;
  213. our $opt_local_master;
  215. our $master;                    # Will be struct in C
  216. our $slave;
  218. our $opt_ndbcluster_port;
  219. our $opt_ndbconnectstring;
  221. our $opt_no_manager;            # Does nothing now, we never use manager
  222. our $opt_manager_port;          # Does nothing now, we never use manager
  224. our $opt_old_master;
  226. our $opt_record;
  228. our $opt_result_ext;
  230. our $opt_skip;
  231. our $opt_skip_rpl;
  232. our $opt_skip_test;
  234. our $opt_sleep;
  235. our $opt_ps_protocol;
  237. our $opt_sleep_time_after_restart=  1;
  238. our $opt_sleep_time_for_delete=    10;
  239. our $opt_testcase_timeout;
  240. our $opt_suite_timeout;
  241. my  $default_testcase_timeout=     10; # 10 min max
  242. my  $default_suite_timeout=       120; # 2 hours max
  244. our $opt_socket;
  246. our $opt_source_dist;
  248. our $opt_start_and_exit;
  249. our $opt_start_dirty;
  250. our $opt_start_from;
  252. our $opt_strace_client;
  254. our $opt_timer;
  256. our $opt_user;
  257. our $opt_user_test;
  259. our $opt_valgrind;
  260. our $opt_valgrind_mysqltest;
  261. our $opt_valgrind_all;
  262. our $opt_valgrind_options;
  264. our $opt_verbose;
  266. our $opt_wait_for_master;
  267. our $opt_wait_for_slave;
  268. our $opt_wait_timeout=  10;
  270. our $opt_warnings;
  272. our $opt_udiff;
  274. our $opt_skip_ndbcluster;
  275. our $opt_with_ndbcluster;
  276. our $opt_with_openssl;
  278. our $exe_ndb_mgm;
  279. our $path_ndb_tools_dir;
  280. our $path_ndb_backup_dir;
  281. our $file_ndb_testrun_log;
  282. our $flag_ndb_status_ok= 1;
  284. ######################################################################
  285. #
  286. #  Function declarations
  287. #
  288. ######################################################################
  290. sub main ();
  291. sub initial_setup ();
  292. sub command_line_setup ();
  293. sub executable_setup ();
  294. sub environment_setup ();
  295. sub kill_running_server ();
  296. sub kill_and_cleanup ();
  297. sub ndbcluster_support ();
  298. sub ndbcluster_install ();
  299. sub ndbcluster_start ();
  300. sub ndbcluster_stop ();
  301. sub run_benchmarks ($);
  302. sub run_tests ();
  303. sub mysql_install_db ();
  304. sub install_db ($$);
  305. sub run_testcase ($);
  306. sub report_failure_and_restart ($);
  307. sub do_before_start_master ($$);
  308. sub do_before_start_slave ($$);
  309. sub mysqld_start ($$$$);
  310. sub mysqld_arguments ($$$$$);
  311. sub stop_masters_slaves ();
  312. sub stop_masters ();
  313. sub stop_slaves ();
  314. sub run_mysqltest ($);
  315. sub usage ($);
  317. ######################################################################
  318. #
  319. #  Main program
  320. #
  321. ######################################################################
  323. main();
  325. sub main () {
  327.   initial_setup();
  328.   command_line_setup();
  329.   executable_setup();
  330.   
  331.   if (! $opt_skip_ndbcluster and ! $opt_with_ndbcluster)
  332.   {
  333.     $opt_with_ndbcluster= ndbcluster_support();
  334.   }
  336.   environment_setup();
  337.   signal_setup();
  339.   if ( $opt_gcov )
  340.   {
  341.     gcov_prepare();
  342.   }
  344.   if ( $opt_gprof )
  345.   {
  346.     gprof_prepare();
  347.   }
  349.   if ( ! $glob_use_running_server )
  350.   {
  351.     if ( $opt_start_dirty )
  352.     {
  353.       kill_running_server();
  354.     }
  355.     else
  356.     {
  357.       kill_and_cleanup();
  358.       mysql_install_db();
  360. #    mysql_loadstd();  FIXME copying from "std_data" .frm and
  361. #                      .MGR but there are none?!
  362.     }
  363.   }
  365.   if ( $opt_start_dirty )
  366.   {
  367.     if ( ndbcluster_start() )
  368.     {
  369.       mtr_error("Can't start ndbcluster");
  370.     }
  371.     if ( mysqld_start('master',0,[],[]) )
  372.     {
  373.       mtr_report("Servers started, exiting");
  374.     }
  375.     else
  376.     {
  377.       mtr_error("Can't start the mysqld server");
  378.     }
  379.   }
  380.   elsif ( $opt_bench )
  381.   {
  382.     run_benchmarks(shift);      # Shift what? Extra arguments?!
  383.   }
  384.   else
  385.   {
  386.     run_tests();
  387.   }
  389.   mtr_exit(0);
  390. }
  392. ##############################################################################
  393. #
  394. #  Initial setup independent on command line arguments
  395. #
  396. ##############################################################################
  398. sub initial_setup () {
  400.   select(STDOUT);
  401.   $| = 1;                       # Make unbuffered
  403.   $glob_scriptname=  basename($0);
  405.   $glob_win32_perl=  ($^O eq "MSWin32");
  406.   $glob_cygwin_perl= ($^O eq "cygwin");
  407.   $glob_win32=       ($glob_win32_perl or $glob_cygwin_perl);
  409.   # We require that we are in the "mysql-test" directory
  410.   # to run mysql-test-run
  412.   if (! -f $glob_scriptname)
  413.   {
  414.     mtr_error("Can't find the location for the mysql-test-run scriptn" .
  415.               "Go to to the mysql-test directory and execute the script " .
  416.               "as follows:n./$glob_scriptname");
  417.   }
  419.   if ( -d "../sql" )
  420.   {
  421.     $opt_source_dist=  1;
  422.   }
  424.   $glob_hostname=  mtr_short_hostname();
  426.   # 'basedir' is always parent of "mysql-test" directory
  427.   $glob_mysql_test_dir=  cwd();
  428.   if ( $glob_cygwin_perl )
  429.   {
  430.     # Windows programs like 'mysqld' needs Windows paths
  431.     $glob_mysql_test_dir= `cygpath -m $glob_mysql_test_dir`;
  432.     my $shell= $ENV{'SHELL'} || "/bin/bash";
  433.     $glob_cygwin_shell=   `cygpath -w $shell`; # The Windows path c:...
  434.     chomp($glob_mysql_test_dir);
  435.     chomp($glob_cygwin_shell);
  436.   }
  437.   $glob_basedir=         dirname($glob_mysql_test_dir);
  438.   $glob_mysql_bench_dir= "$glob_basedir/mysql-bench"; # FIXME make configurable
  440.   # needs to be same length to test logging (FIXME what???)
  441.   $path_slave_load_tmpdir=  "../../var/tmp";
  443.   $path_my_basedir=
  444.     $opt_source_dist ? $glob_mysql_test_dir : $glob_basedir;
  446.   $glob_timers= mtr_init_timers();
  447. }
  451. ##############################################################################
  452. #
  453. #  Default settings
  454. #
  455. ##############################################################################
  457. sub command_line_setup () {
  459.   # These are defaults for things that are set on the command line
  461.   $opt_suite=        "main";    # Special default suite
  462.   my $opt_master_myport= 9306;
  463.   my $opt_slave_myport=  9308;
  464.   $opt_ndbcluster_port=  9350;
  466.   if ( $ENV{'MTR_BUILD_THREAD'} )
  467.   {
  468.     $opt_master_myport=   $ENV{'MTR_BUILD_THREAD'} * 40 + 8120;
  469.     $opt_slave_myport=    $opt_master_myport + 16;
  470.     $opt_ndbcluster_port= $opt_master_myport + 24;
  471.   }
  473.   # Read the command line
  474.   # Note: Keep list, and the order, in sync with usage at end of this file
  476.   Getopt::Long::Configure("pass_through");
  477.   GetOptions(
  478.              # Control what engine/variation to run
  479.              'embedded-server'          => $opt_embedded_server,
  480.              'ps-protocol'              => $opt_ps_protocol,
  481.              'bench'                    => $opt_bench,
  482.              'small-bench'              => $opt_small_bench,
  483.              'no-manager'               => $opt_no_manager, # Currently not used
  485.              # Control what test suites or cases to run
  486.              'force'                    => $opt_force,
  487.              'with-ndbcluster'          => $opt_with_ndbcluster,
  488.              'skip-ndbcluster|skip-ndb' => $opt_skip_ndbcluster,
  489.              'do-test=s'                => $opt_do_test,
  490.              'suite=s'                  => $opt_suite,
  491.              'skip-rpl'                 => $opt_skip_rpl,
  492.              'skip-test=s'              => $opt_skip_test,
  494.              # Specify ports
  495.              'master_port=i'            => $opt_master_myport,
  496.              'slave_port=i'             => $opt_slave_myport,
  497.              'ndbcluster_port=i'        => $opt_ndbcluster_port,
  498.              'manager-port=i'           => $opt_manager_port, # Currently not used
  500.              # Test case authoring
  501.              'record'                   => $opt_record,
  503.              # ???
  504.              'mysqld=s'                 => @opt_extra_mysqld_opt,
  506.              # Run test on running server
  507.              'extern'                   => $opt_extern,
  508.              'ndbconnectstring=s'       => $opt_ndbconnectstring,
  510.              # Debugging
  511.              'gdb'                      => $opt_gdb,
  512.              'manual-gdb'               => $opt_manual_gdb,
  513.              'client-gdb'               => $opt_client_gdb,
  514.              'ddd'                      => $opt_ddd,
  515.              'strace-client'            => $opt_strace_client,
  516.              'master-binary=s'          => $exe_master_mysqld,
  517.              'slave-binary=s'           => $exe_slave_mysqld,
  519.              # Coverage, profiling etc
  520.              'gcov'                     => $opt_gcov,
  521.              'gprof'                    => $opt_gprof,
  522.              'valgrind:s'               => $opt_valgrind,
  523.              'valgrind-mysqltest:s'     => $opt_valgrind_mysqltest,
  524.              'valgrind-all:s'           => $opt_valgrind_all,
  525.              'valgrind-options=s'       => $opt_valgrind_options,
  527.              # Misc
  528.              'big-test'                 => $opt_big_test,
  529.              'compress'                 => $opt_compress,
  530.              'debug'                    => $opt_debug,
  531.              'fast'                     => $opt_fast,
  532.              'local'                    => $opt_local,
  533.              'local-master'             => $opt_local_master,
  534.              'netware'                  => $opt_netware,
  535.              'old-master'               => $opt_old_master,
  536.              'reorder'                  => $opt_reorder,
  537.              'script-debug'             => $opt_script_debug,
  538.              'sleep=i'                  => $opt_sleep,
  539.              'socket=s'                 => $opt_socket,
  540.              'start-dirty'              => $opt_start_dirty,
  541.              'start-and-exit'           => $opt_start_and_exit,
  542.              'start-from=s'             => $opt_start_from,
  543.              'timer'                    => $opt_timer,
  544.              'tmpdir=s'                 => $opt_tmpdir,
  545.              'unified-diff|udiff'       => $opt_udiff,
  546.              'user-test=s'              => $opt_user_test,
  547.              'user=s'                   => $opt_user,
  548.              'vardir=s'                 => $opt_vardir,
  549.              'verbose'                  => $opt_verbose,
  550.              'wait-timeout=i'           => $opt_wait_timeout,
  551.              'testcase-timeout=i'       => $opt_testcase_timeout,
  552.              'suite-timeout=i'          => $opt_suite_timeout,
  553.              'warnings|log-warnings'    => $opt_warnings,
  554.              'with-openssl'             => $opt_with_openssl,
  556.              'help|h'                   => $opt_usage,
  557.             ) or usage("Can't read options");
  559.   if ( $opt_usage )
  560.   {
  561.     usage("");
  562.   }
  564.   foreach my $arg ( @ARGV )
  565.   {
  566.     if ( $arg =~ /^--skip-/ )
  567.     {
  568.       push(@opt_extra_mysqld_opt, $arg);
  569.     }
  570.     elsif ( $arg =~ /^-/ )
  571.     {
  572.       usage("Invalid option "$arg"");
  573.     }
  574.     else
  575.     {
  576.       push(@opt_cases, $arg);
  577.     }
  578.   }
  580.   # --------------------------------------------------------------------------
  581.   # Set the "var/" directory, as it is the base for everything else
  582.   # --------------------------------------------------------------------------
  584.   if ( ! $opt_vardir )
  585.   {
  586.     $opt_vardir= "$glob_mysql_test_dir/var";
  587.   }
  589.   # We make the path absolute, as the server will do a chdir() before usage
  590.   unless ( $opt_vardir =~ m,^/, or
  591.            ($glob_win32 and $opt_vardir =~ m,^[a-z]:/,i) )
  592.   {
  593.     # Make absolute path, relative test dir
  594.     $opt_vardir= "$glob_mysql_test_dir/$opt_vardir";
  595.   }
  597.   # --------------------------------------------------------------------------
  598.   # If not set, set these to defaults
  599.   # --------------------------------------------------------------------------
  601.   $opt_tmpdir=       "$opt_vardir/tmp" unless $opt_tmpdir;
  602.   # FIXME maybe not needed?
  603.   $path_manager_log= "$opt_vardir/log/manager.log"
  604.     unless $path_manager_log;
  605.   $opt_current_test= "$opt_vardir/log/current_test"
  606.     unless $opt_current_test;
  608.   # --------------------------------------------------------------------------
  609.   # Do sanity checks of command line arguments
  610.   # --------------------------------------------------------------------------
  612.   if ( $opt_extern and $opt_local )
  613.   {
  614.     mtr_error("Can't use --extern and --local at the same time");
  615.   }
  617.   if ( ! $opt_socket )
  618.   {     # FIXME set default before reading options?
  619. #    $opt_socket=  '@MYSQL_UNIX_ADDR@';
  620.     $opt_socket=  "/tmp/mysql.sock"; # FIXME
  621.   }
  623.   # --------------------------------------------------------------------------
  624.   # Look at the command line options and set script flags
  625.   # --------------------------------------------------------------------------
  627.   if ( $opt_record and ! @opt_cases )
  628.   {
  629.     mtr_error("Will not run in record mode without a specific test case");
  630.   }
  632.   if ( $opt_embedded_server )
  633.   {
  634.     $glob_use_embedded_server= 1;
  635.     push(@glob_test_mode, "embedded");
  636.     $opt_skip_rpl= 1;              # We never run replication with embedded
  638.     if ( $opt_extern )
  639.     {
  640.       mtr_error("Can't use --extern with --embedded-server");
  641.     }
  642.   }
  644.   if ( $opt_ps_protocol )
  645.   {
  646.     push(@glob_test_mode, "ps-protocol");
  647.   }
  649.   # FIXME don't understand what this is
  650. #  if ( $opt_local_master )
  651. #  {
  652. #    $opt_master_myport=  3306;
  653. #  }
  655.   if ( $opt_small_bench )
  656.   {
  657.     $opt_bench=  1;
  658.   }
  660.   if ( $opt_sleep )
  661.   {
  662.     $opt_sleep_time_after_restart= $opt_sleep;
  663.   }
  665.   if ( $opt_gcov and ! $opt_source_dist )
  666.   {
  667.     mtr_error("Coverage test needs the source - please use source dist");
  668.   }
  670.   if ( $opt_gdb )
  671.   {
  672.     $opt_wait_timeout=  300;
  673.     if ( $opt_extern )
  674.     {
  675.       mtr_error("Can't use --extern with --gdb");
  676.     }
  677.   }
  679.   if ( $opt_manual_gdb )
  680.   {
  681.     $opt_gdb=  1;
  682.     if ( $opt_extern )
  683.     {
  684.       mtr_error("Can't use --extern with --manual-gdb");
  685.     }
  686.   }
  688.   if ( $opt_ddd )
  689.   {
  690.     if ( $opt_extern )
  691.     {
  692.       mtr_error("Can't use --extern with --ddd");
  693.     }
  694.   }
  696.   if ( $opt_ndbconnectstring )
  697.   {
  698.     $glob_use_running_ndbcluster= 1;
  699.     $opt_with_ndbcluster= 1;
  700.   }
  701.   else
  702.   {
  703.     $opt_ndbconnectstring= "host=localhost:$opt_ndbcluster_port";
  704.   }
  706.   if ( $opt_skip_ndbcluster )
  707.   {
  708.     $opt_with_ndbcluster= 0;
  709.   }
  711.   # The ":s" in the argument spec, means we have three different cases
  712.   #
  713.   #   undefined    option not set
  714.   #   ""           option set with no argument
  715.   #   "somestring" option is name/path of valgrind executable
  717.   # Take executable path from any of them, if any
  718.   $opt_valgrind= $opt_valgrind_mysqltest if $opt_valgrind_mysqltest;
  719.   $opt_valgrind= $opt_valgrind_all       if $opt_valgrind_all;
  721.   # If valgrind flag not defined, define if other valgrind flags are
  722.   unless ( defined $opt_valgrind )
  723.   {
  724.     $opt_valgrind= ""
  725.       if defined $opt_valgrind_mysqltest or defined $opt_valgrind_all;
  726.   }
  728.   if ( ! $opt_testcase_timeout )
  729.   {
  730.     $opt_testcase_timeout= $default_testcase_timeout;
  731.     $opt_testcase_timeout*= 10 if defined $opt_valgrind;
  732.   }
  734.   if ( ! $opt_suite_timeout )
  735.   {
  736.     $opt_suite_timeout= $default_suite_timeout;
  737.     $opt_suite_timeout*= 4 if defined $opt_valgrind;
  738.   }
  740.   if ( defined $opt_valgrind )
  741.   {
  742.     $opt_sleep_time_after_restart= 10;
  743.     $opt_sleep_time_for_delete= 60;
  744.     # >=2.1.2 requires the --tool option, some versions write to stdout, some to stderr
  745.     #  valgrind --help 2>&1 | grep "--tool" > /dev/null && VALGRIND="$VALGRIND --tool=memcheck"
  746.   }
  748.   if ( ! $opt_user )
  749.   {
  750.     if ( $glob_use_running_server )
  751.     {
  752.       $opt_user= "test";
  753.     }
  754.     else
  755.     {
  756.       $opt_user= "root"; # We want to do FLUSH xxx commands
  757.     }
  758.   }
  760.   # Put this into a hash, will be a C struct
  762.   $master->[0]=
  763.   {
  764.    path_myddir   => "$opt_vardir/master-data",
  765.    path_myerr    => "$opt_vardir/log/master.err",
  766.    path_mylog    => "$opt_vardir/log/master.log",
  767.    path_mypid    => "$opt_vardir/run/master.pid",
  768.    path_mysock   => "$opt_tmpdir/master.sock",
  769.    path_myport   =>  $opt_master_myport,
  770.    start_timeout =>  400, # enough time create innodb tables
  772.    ndbcluster    =>  1, # ndbcluster not started
  773.   };
  775.   $master->[1]=
  776.   {
  777.    path_myddir   => "$opt_vardir/master1-data",
  778.    path_myerr    => "$opt_vardir/log/master1.err",
  779.    path_mylog    => "$opt_vardir/log/master1.log",
  780.    path_mypid    => "$opt_vardir/run/master1.pid",
  781.    path_mysock   => "$opt_tmpdir/master1.sock",
  782.    path_myport   => $opt_master_myport + 1,
  783.    start_timeout => 400, # enough time create innodb tables
  784.   };
  786.   $slave->[0]=
  787.   {
  788.    path_myddir   => "$opt_vardir/slave-data",
  789.    path_myerr    => "$opt_vardir/log/slave.err",
  790.    path_mylog    => "$opt_vardir/log/slave.log",
  791.    path_mypid    => "$opt_vardir/run/slave.pid",
  792.    path_mysock   => "$opt_tmpdir/slave.sock",
  793.    path_myport   => $opt_slave_myport,
  794.    start_timeout => 400,
  795.   };
  797.   $slave->[1]=
  798.   {
  799.    path_myddir   => "$opt_vardir/slave1-data",
  800.    path_myerr    => "$opt_vardir/log/slave1.err",
  801.    path_mylog    => "$opt_vardir/log/slave1.log",
  802.    path_mypid    => "$opt_vardir/run/slave1.pid",
  803.    path_mysock   => "$opt_tmpdir/slave1.sock",
  804.    path_myport   => $opt_slave_myport + 1,
  805.    start_timeout => 300,
  806.   };
  808.   $slave->[2]=
  809.   {
  810.    path_myddir   => "$opt_vardir/slave2-data",
  811.    path_myerr    => "$opt_vardir/log/slave2.err",
  812.    path_mylog    => "$opt_vardir/log/slave2.log",
  813.    path_mypid    => "$opt_vardir/run/slave2.pid",
  814.    path_mysock   => "$opt_tmpdir/slave2.sock",
  815.    path_myport   => $opt_slave_myport + 2,
  816.    start_timeout => 300,
  817.   };
  819.   if ( $opt_extern )
  820.   {
  821.     $glob_use_running_server=  1;
  822.     $opt_skip_rpl= 1;                   # We don't run rpl test cases
  823.     $master->[0]->{'path_mysock'}=  $opt_socket;
  824.   }
  826.   $path_timefile=  "$opt_vardir/log/mysqltest-time";
  827. }
  830. ##############################################################################
  831. #
  832. #  Set paths to various executable programs
  833. #
  834. ##############################################################################
  836. sub executable_setup () {
  838.   if ( $opt_source_dist )
  839.   {
  840.     if ( $glob_win32 )
  841.     {
  842.       $path_client_bindir= mtr_path_exists("$glob_basedir/client_release",
  843.                                            "$glob_basedir/bin");
  844.       $exe_mysqld=         mtr_exe_exists ("$path_client_bindir/mysqld-nt",
  845.                                            "$path_client_bindir/mysqld",
  846.                                            "$path_client_bindir/mysqld-debug",);
  847.       $path_language=      mtr_path_exists("$glob_basedir/share/english/");
  848.       $path_charsetsdir=   mtr_path_exists("$glob_basedir/share/charsets");
  849.     }
  850.     else
  851.     {
  852.       $path_client_bindir= mtr_path_exists("$glob_basedir/client");
  853.       $exe_mysqld=         mtr_exe_exists ("$glob_basedir/sql/mysqld");
  854.       $path_language=      mtr_path_exists("$glob_basedir/sql/share/english/");
  855.       $path_charsetsdir=   mtr_path_exists("$glob_basedir/sql/share/charsets");
  856.     }
  858.     if ( $glob_use_embedded_server )
  859.     {
  860.       my $path_examples= "$glob_basedir/libmysqld/examples";
  861.       $exe_mysqltest=    mtr_exe_exists("$path_examples/mysqltest_embedded");
  862.       $exe_mysql_client_test=
  863.         mtr_exe_exists("$path_examples/mysql_client_test_embedded",
  864.        "/usr/bin/false");
  865.     }
  866.     else
  867.     {
  868.       $exe_mysqltest=  mtr_exe_exists("$path_client_bindir/mysqltest");
  869.       $exe_mysql_client_test=
  870.         mtr_exe_exists("$glob_basedir/tests/mysql_client_test",
  871.        "/usr/bin/false");
  872.     }
  873.     $exe_mysqldump=      mtr_exe_exists("$path_client_bindir/mysqldump");
  874.     $exe_mysqlimport=    mtr_exe_exists("$path_client_bindir/mysqlimport");
  875.     $exe_mysqlshow=      mtr_exe_exists("$path_client_bindir/mysqlshow");
  876.     $exe_mysqlbinlog=    mtr_exe_exists("$path_client_bindir/mysqlbinlog");
  877.     $exe_mysqladmin=     mtr_exe_exists("$path_client_bindir/mysqladmin");
  878.     $exe_mysql=          mtr_exe_exists("$path_client_bindir/mysql");
  879.     $exe_mysql_fix_system_tables=
  880.       mtr_script_exists("$glob_basedir/scripts/mysql_fix_privilege_tables");
  881.     $path_ndb_tools_dir= mtr_path_exists("$glob_basedir/ndb/tools");
  882.     $exe_ndb_mgm=        "$glob_basedir/ndb/src/mgmclient/ndb_mgm";
  883.   }
  884.   else
  885.   {
  886.     $path_client_bindir= mtr_path_exists("$glob_basedir/bin");
  887.     $exe_mysqldump=      mtr_exe_exists("$path_client_bindir/mysqldump");
  888.     $exe_mysqlimport=    mtr_exe_exists("$path_client_bindir/mysqlimport");
  889.     $exe_mysqlshow=      mtr_exe_exists("$path_client_bindir/mysqlshow");
  890.     $exe_mysqlbinlog=    mtr_exe_exists("$path_client_bindir/mysqlbinlog");
  891.     $exe_mysqladmin=     mtr_exe_exists("$path_client_bindir/mysqladmin");
  892.     $exe_mysql=          mtr_exe_exists("$path_client_bindir/mysql");
  893.     $exe_mysql_fix_system_tables=
  894.       mtr_script_exists("$path_client_bindir/mysql_fix_privilege_tables",
  895. "$glob_basedir/scripts/mysql_fix_privilege_tables");
  897.     $path_language=      mtr_path_exists("$glob_basedir/share/mysql/english/",
  898.                                          "$glob_basedir/share/english/");
  899.     $path_charsetsdir=   mtr_path_exists("$glob_basedir/share/mysql/charsets",
  900.                                          "$glob_basedir/share/charsets");
  902.     if ( $glob_win32 )
  903.     {
  904.       $exe_mysqld=         mtr_exe_exists ("$glob_basedir/bin/mysqld-nt",
  905.                                            "$glob_basedir/bin/mysqld",
  906.                                            "$glob_basedir/bin/mysqld-debug",);
  907.     }
  908.     else
  909.     {
  910.       $exe_mysqld=         mtr_exe_exists ("$glob_basedir/libexec/mysqld",
  911.                                            "$glob_basedir/bin/mysqld");
  912.     }
  914.     if ( $glob_use_embedded_server )
  915.     {
  916.       $exe_mysqltest= mtr_exe_exists("$path_client_bindir/mysqltest_embedded");
  917.       $exe_mysql_client_test=
  918.         mtr_exe_exists("$glob_basedir/tests/mysql_client_test_embedded",
  919.                        "$path_client_bindir/mysql_client_test_embedded",
  920.        "/usr/bin/false");
  921.     }
  922.     else
  923.     {
  924.       $exe_mysqltest= mtr_exe_exists("$path_client_bindir/mysqltest");
  925.       $exe_mysql_client_test=
  926.         mtr_exe_exists("$path_client_bindir/mysql_client_test",
  927.        "/usr/bin/false"); # FIXME temporary
  928.     }
  930.     $path_ndb_tools_dir=  "$glob_basedir/bin";
  931.     $exe_ndb_mgm=         "$glob_basedir/bin/ndb_mgm";
  932.   }
  934.   $exe_master_mysqld= $exe_master_mysqld || $exe_mysqld;
  935.   $exe_slave_mysqld=  $exe_slave_mysqld  || $exe_mysqld;
  937.   $path_ndb_backup_dir=
  938.     "$opt_vardir/ndbcluster-$opt_ndbcluster_port";
  939.   $file_ndb_testrun_log= "$opt_vardir/log/ndb_testrun.log";
  940. }
  943. ##############################################################################
  944. #
  945. #  Set environment to be used by childs of this process
  946. #
  947. ##############################################################################
  949. # Note that some env is setup in spawn/run, in "mtr_process.pl"
  951. sub environment_setup () {
  953.   # --------------------------------------------------------------------------
  954.   # We might not use a standard installation directory, like /usr/lib.
  955.   # Set LD_LIBRARY_PATH to make sure we find our installed libraries.
  956.   # --------------------------------------------------------------------------
  958.   unless ( $opt_source_dist )
  959.   {
  960.     $ENV{'LD_LIBRARY_PATH'}=
  961.       "$glob_basedir/lib" .
  962.         ($ENV{'LD_LIBRARY_PATH'} ? ":$ENV{'LD_LIBRARY_PATH'}" : "");
  963.     $ENV{'DYLD_LIBRARY_PATH'}=
  964.       "$glob_basedir/lib" .
  965.         ($ENV{'DYLD_LIBRARY_PATH'} ? ":$ENV{'DYLD_LIBRARY_PATH'}" : "");
  966.   }
  968.   # --------------------------------------------------------------------------
  969.   # Also command lines in .opt files may contain env vars
  970.   # --------------------------------------------------------------------------
  972.   $ENV{'UMASK'}=              "0660"; # The octal *string*
  973.   $ENV{'UMASK_DIR'}=          "0770"; # The octal *string*
  974.   $ENV{'LC_COLLATE'}=         "C";
  975.   $ENV{'USE_RUNNING_SERVER'}= $glob_use_running_server;
  976.   $ENV{'MYSQL_TEST_DIR'}=     $glob_mysql_test_dir;
  977.   $ENV{'MYSQL_TEST_WINDIR'}=  $glob_mysql_test_dir;
  978.   $ENV{'MASTER_MYSOCK'}=      $master->[0]->{'path_mysock'};
  979.   $ENV{'MASTER_WINMYSOCK'}=   $master->[0]->{'path_mysock'};
  980.   $ENV{'MASTER_MYSOCK1'}=     $master->[1]->{'path_mysock'};
  981.   $ENV{'MASTER_MYPORT'}=      $master->[0]->{'path_myport'};
  982.   $ENV{'MASTER_MYPORT1'}=     $master->[1]->{'path_myport'};
  983.   $ENV{'SLAVE_MYPORT'}=       $slave->[0]->{'path_myport'};
  984. # $ENV{'MYSQL_TCP_PORT'}=     '@MYSQL_TCP_PORT@'; # FIXME
  985.   $ENV{'MYSQL_TCP_PORT'}=     3306;
  987.   if ( $glob_cygwin_perl )
  988.   {
  989.     foreach my $key ('MYSQL_TEST_WINDIR','MASTER_MYSOCK')
  990.     {
  991.       $ENV{$key}= `cygpath -w $ENV{$key}`;
  992.       $ENV{$key} =~ s,\,\\,g;
  993.       chomp($ENV{$key});
  994.     }
  995.   }
  997.   # We are nice and report a bit about our settings
  998.   print "Using MTR_BUILD_THREAD = ",$ENV{MTR_BUILD_THREAD} || 0,"n";
  999.   print "Using MASTER_MYPORT    = $ENV{MASTER_MYPORT}n";
  1000.   print "Using MASTER_MYPORT1   = $ENV{MASTER_MYPORT1}n";
  1001.   print "Using SLAVE_MYPORT     = $ENV{SLAVE_MYPORT}n";
  1002.   print "Using NDBCLUSTER_PORT  = $opt_ndbcluster_portn";
  1003. }
  1006. ##############################################################################
  1007. #
  1008. #  If we get a ^C, we try to clean up before termination
  1009. #
  1010. ##############################################################################
  1011. # FIXME check restrictions what to do in a signal handler
  1013. sub signal_setup () {
  1014.   $SIG{INT}= &handle_int_signal;
  1015. }
  1017. sub handle_int_signal () {
  1018.   $SIG{INT}= 'DEFAULT';         # If we get a ^C again, we die...
  1019.   mtr_warning("got INT signal, cleaning up.....");
  1020.   stop_masters_slaves();
  1021.   mtr_error("We die from ^C signal from user");
  1022. }
  1025. ##############################################################################
  1026. #
  1027. #  Handle left overs from previous runs
  1028. #
  1029. ##############################################################################
  1031. sub kill_running_server () {
  1033.   if ( $opt_fast or $glob_use_embedded_server )
  1034.   {
  1035.     # FIXME is embedded server really using PID files?!
  1036.     unlink($master->[0]->{'path_mypid'});
  1037.     unlink($master->[1]->{'path_mypid'});
  1038.     unlink($slave->[0]->{'path_mypid'});
  1039.     unlink($slave->[1]->{'path_mypid'});
  1040.     unlink($slave->[2]->{'path_mypid'});
  1041.   }
  1042.   else
  1043.   {
  1044.     # Ensure that no old mysqld test servers are running
  1045.     # This is different from terminating processes we have
  1046.     # started from ths run of the script, this is terminating
  1047.     # leftovers from previous runs.
  1049.     mtr_report("Killing Possible Leftover Processes");
  1050.     mkpath("$opt_vardir/log"); # Needed for mysqladmin log
  1051.     mtr_kill_leftovers();
  1053.     ndbcluster_stop();
  1054.     $master->[0]->{'ndbcluster'}= 1;
  1055.   }
  1056. }
  1058. sub kill_and_cleanup () {
  1060.   kill_running_server ();
  1062.   mtr_report("Removing Stale Files");
  1064.   rmtree("$opt_vardir/log");
  1065.   rmtree("$opt_vardir/ndbcluster-$opt_ndbcluster_port");
  1066.   rmtree("$opt_vardir/run");
  1067.   rmtree("$opt_vardir/tmp");
  1069.   mkpath("$opt_vardir/log");
  1070.   mkpath("$opt_vardir/run");
  1071.   mkpath("$opt_vardir/tmp");
  1072.   mkpath($opt_tmpdir) if $opt_tmpdir ne "$opt_vardir/tmp";
  1074.   # FIXME do we really need to create these all, or are they
  1075.   # created for us when tables are created?
  1077.   my @data_dir_lst = (
  1078.     $master->[0]->{'path_myddir'},
  1079.     $master->[1]->{'path_myddir'},
  1080.     $slave->[0]->{'path_myddir'},
  1081.     $slave->[1]->{'path_myddir'},
  1082.     $slave->[2]->{'path_myddir'});
  1083.   
  1084.   foreach my $data_dir (@data_dir_lst)
  1085.   {
  1086.     rmtree("$data_dir");
  1087.     mkpath("$data_dir/mysql");
  1088.     mkpath("$data_dir/test");
  1089.   }
  1091.   # To make some old test cases work, we create a soft
  1092.   # link from the old "var" location to the new one
  1094.   if ( ! $glob_win32 and $opt_vardir ne "$glob_mysql_test_dir/var" )
  1095.   {
  1096.     # FIXME why bother with the above, why not always remove all of var?!
  1097.     rmtree("$glob_mysql_test_dir/var"); # Clean old var, FIXME or rename it?!
  1098.     symlink($opt_vardir, "$glob_mysql_test_dir/var");
  1099.   }
  1100. }
  1103. ##############################################################################
  1104. #
  1105. #  Start the ndb cluster
  1106. #
  1107. ##############################################################################
  1109. sub ndbcluster_support () {
  1111.   # check ndbcluster support by testing using a switch
  1112.   # that is only available in that case
  1113.   if ( mtr_run($exe_mysqld,
  1114.        ["--no-defaults",
  1115.         "--ndb-use-exact-count",
  1116.         "--help"],
  1117.        "", "/dev/null", "/dev/null", "") != 0 )
  1118.   {
  1119.     mtr_report("No ndbcluster support");
  1120.     return 0;
  1121.   }
  1122.   mtr_report("Has ndbcluster support");
  1123.   return 1;
  1124. }
  1126. # FIXME why is there a different start below?!
  1128. sub ndbcluster_install () {
  1130.   if ( ! $opt_with_ndbcluster or $glob_use_running_ndbcluster )
  1131.   {
  1132.     return 0;
  1133.   }
  1134.   mtr_report("Install ndbcluster");
  1135.   my $ndbcluster_opts=  $opt_bench ? "" : "--small";
  1136.   my $ndbcluster_port_base= $opt_ndbcluster_port + 2;
  1137.   if (  mtr_run("$glob_mysql_test_dir/ndb/ndbcluster",
  1138. ["--port=$opt_ndbcluster_port",
  1139.  "--port-base=$ndbcluster_port_base",
  1140.  "--data-dir=$opt_vardir",
  1141.  $ndbcluster_opts,
  1142.  "--initial"],
  1143. "", "", "", "") )
  1144.   {
  1145.     mtr_error("Error ndbcluster_install");
  1146.     return 1;
  1147.   }
  1149.   ndbcluster_stop();
  1150.   $master->[0]->{'ndbcluster'}= 1;
  1152.   return 0;
  1153. }
  1155. sub ndbcluster_start () {
  1157.   if ( ! $opt_with_ndbcluster or $glob_use_running_ndbcluster )
  1158.   {
  1159.     return 0;
  1160.   }
  1161.   # FIXME, we want to _append_ output to file $file_ndb_testrun_log instead of /dev/null
  1162.   if ( mtr_run("$glob_mysql_test_dir/ndb/ndbcluster",
  1163.        ["--port=$opt_ndbcluster_port",
  1164. "--data-dir=$opt_vardir"],
  1165.        "", "/dev/null", "", "") )
  1166.   {
  1167.     mtr_error("Error ndbcluster_start");
  1168.     return 1;
  1169.   }
  1171.   return 0;
  1172. }
  1174. sub ndbcluster_stop () {
  1176.   if ( ! $opt_with_ndbcluster or $glob_use_running_ndbcluster )
  1177.   {
  1178.     return;
  1179.   }
  1180.   my $ndbcluster_port_base= $opt_ndbcluster_port + 2;
  1181.   # FIXME, we want to _append_ output to file $file_ndb_testrun_log instead of /dev/null
  1182.   mtr_run("$glob_mysql_test_dir/ndb/ndbcluster",
  1183.           ["--port=$opt_ndbcluster_port",
  1184.            "--data-dir=$opt_vardir",
  1185.            "--stop"],
  1186.           "", "/dev/null", "", "");
  1188.   return;
  1189. }
  1192. ##############################################################################
  1193. #
  1194. #  Run the benchmark suite
  1195. #
  1196. ##############################################################################
  1198. sub run_benchmarks ($) {
  1199.   my $benchmark=  shift;
  1201.   my $args;
  1203.   if ( ! $glob_use_embedded_server and ! $opt_local_master )
  1204.   {
  1205.     $master->[0]->{'pid'}= mysqld_start('master',0,[],[]);
  1206.     if ( ! $master->[0]->{'pid'} )
  1207.     {
  1208.       mtr_error("Can't start the mysqld server");
  1209.     }
  1210.   }
  1212.   mtr_init_args($args);
  1214.   mtr_add_arg($args, "--socket=%s", $master->[0]->{'path_mysock'});
  1215.   mtr_add_arg($args, "--user=%s", $opt_user);
  1217.   if ( $opt_small_bench )
  1218.   {
  1219.     mtr_add_arg($args, "--small-test");
  1220.     mtr_add_arg($args, "--small-tables");
  1221.   }
  1223.   if ( $opt_with_ndbcluster )
  1224.   {
  1225.     mtr_add_arg($args, "--create-options=TYPE=ndb");
  1226.   }
  1228.   my $benchdir=  "$glob_basedir/sql-bench";
  1229.   chdir($benchdir);             # FIXME check error
  1231.   # FIXME write shorter....
  1233.   if ( ! $benchmark )
  1234.   {
  1235.     mtr_add_arg($args, "--log");
  1236.     mtr_run("$glob_mysql_bench_dir/run-all-tests", $args, "", "", "", "");
  1237.     # FIXME check result code?!
  1238.   }
  1239.   elsif ( -x $benchmark )
  1240.   {
  1241.     mtr_run("$glob_mysql_bench_dir/$benchmark", $args, "", "", "", "");
  1242.     # FIXME check result code?!
  1243.   }
  1244.   else
  1245.   {
  1246.     mtr_error("Benchmark $benchmark not found");
  1247.   }
  1249.   chdir($glob_mysql_test_dir);          # Go back
  1251.   if ( ! $glob_use_embedded_server )
  1252.   {
  1253.     stop_masters();
  1254.   }
  1255. }
  1258. ##############################################################################
  1259. #
  1260. #  Run the test suite
  1261. #
  1262. ##############################################################################
  1264. # FIXME how to specify several suites to run? Comma separated list?
  1266. sub run_tests () {
  1267.   run_suite($opt_suite);
  1268. }
  1270. sub run_suite () {
  1271.   my $suite= shift;
  1273.   mtr_print_thick_line();
  1275.   mtr_report("Finding  Tests in the '$suite' suite");
  1277.   mtr_timer_start($glob_timers,"suite", 60 * $opt_suite_timeout);
  1279.   my $tests= collect_test_cases($suite);
  1281.   mtr_report("Starting Tests in the '$suite' suite");
  1283.   mtr_print_header();
  1285.   foreach my $tinfo ( @$tests )
  1286.   {
  1287.     mtr_timer_start($glob_timers,"testcase", 60 * $opt_testcase_timeout);
  1288.     run_testcase($tinfo);
  1289.     mtr_timer_stop($glob_timers,"testcase");
  1290.   }
  1292.   mtr_print_line();
  1294.   if ( ! $opt_gdb and ! $glob_use_running_server and
  1295.        ! $opt_ddd and ! $glob_use_embedded_server )
  1296.   {
  1297.     stop_masters_slaves();
  1298.   }
  1300.   if ( $opt_gcov )
  1301.   {
  1302.     gcov_collect(); # collect coverage information
  1303.   }
  1304.   if ( $opt_gprof )
  1305.   {
  1306.     gprof_collect(); # collect coverage information
  1307.   }
  1309.   mtr_report_stats($tests);
  1311.   mtr_timer_stop($glob_timers,"suite");
  1312. }
  1315. ##############################################################################
  1316. #
  1317. #  Initiate the test databases
  1318. #
  1319. ##############################################################################
  1321. sub mysql_install_db () {
  1323.   # FIXME not exactly true I think, needs improvements
  1324.   install_db('master', $master->[0]->{'path_myddir'});
  1325.   install_db('master', $master->[1]->{'path_myddir'});
  1326.   install_db('slave',  $slave->[0]->{'path_myddir'});
  1327.   install_db('slave',  $slave->[1]->{'path_myddir'});
  1328.   install_db('slave',  $slave->[2]->{'path_myddir'});
  1330.   if ( ndbcluster_install() )
  1331.   {
  1332.     # failed to install, disable usage but flag that its no ok
  1333.     $opt_with_ndbcluster= 0;
  1334.     $flag_ndb_status_ok= 0;
  1335.   }
  1337.   return 0;
  1338. }
  1341. sub install_db ($$) {
  1342.   my $type=      shift;
  1343.   my $data_dir=  shift;
  1345.   my $init_db_sql=     "lib/init_db.sql";
  1346.   my $init_db_sql_tmp= "/tmp/init_db.sql$$";
  1347.   my $args;
  1349.   mtr_report("Installing u$type Databases");
  1351.   open(IN, $init_db_sql)
  1352.     or mtr_error("Can't open $init_db_sql: $!");
  1353.   open(OUT, ">", $init_db_sql_tmp)
  1354.     or mtr_error("Can't write to $init_db_sql_tmp: $!");
  1355.   while (<IN>)
  1356.   {
  1357.     chomp;
  1358.     s/@HOSTNAME@/$glob_hostname/;
  1359.     if ( /^s*$/ )
  1360.     {
  1361.       print OUT "n";
  1362.     }
  1363.     elsif (/;$/)
  1364.     {
  1365.       print OUT "$_n";
  1366.     }
  1367.     else
  1368.     {
  1369.       print OUT "$_ ";
  1370.     }
  1371.   }
  1372.   close OUT;
  1373.   close IN;
  1375.   mtr_init_args($args);
  1377.   mtr_add_arg($args, "--no-defaults");
  1378.   mtr_add_arg($args, "--bootstrap");
  1379.   mtr_add_arg($args, "--console");
  1380.   mtr_add_arg($args, "--skip-grant-tables");
  1381.   mtr_add_arg($args, "--basedir=%s", $path_my_basedir);
  1382.   mtr_add_arg($args, "--datadir=%s", $data_dir);
  1383.   mtr_add_arg($args, "--skip-innodb");
  1384.   mtr_add_arg($args, "--skip-ndbcluster");
  1385.   mtr_add_arg($args, "--skip-bdb");
  1387.   if ( ! $opt_netware )
  1388.   {
  1389.     mtr_add_arg($args, "--language=%s", $path_language);
  1390.     mtr_add_arg($args, "--character-sets-dir=%s", $path_charsetsdir);
  1391.   }
  1393.   if ( mtr_run($exe_mysqld, $args, $init_db_sql_tmp,
  1394.                $path_manager_log, $path_manager_log, "") != 0 )
  1395.   {
  1396.     unlink($init_db_sql_tmp);
  1397.     mtr_error("Error executing mysqld --bootstrapn" .
  1398.               "Could not install $type test DBs");
  1399.   }
  1400.   unlink($init_db_sql_tmp);
  1401. }
  1404. ##############################################################################
  1405. #
  1406. #  Run a single test case
  1407. #
  1408. ##############################################################################
  1410. # When we get here, we have already filtered out test cases that doesn't
  1411. # apply to the current setup, for example if we use a running server, test
  1412. # cases that restart the server are dropped. So this function should mostly
  1413. # be about doing things, not a lot of logic.
  1415. # We don't start and kill the servers for each testcase. But some
  1416. # testcases needs a restart, because they specify options to start
  1417. # mysqld with. After that testcase, we need to restart again, to set
  1418. # back the normal options.
  1420. sub run_testcase ($) {
  1421.   my $tinfo=  shift;
  1423.   my $tname= $tinfo->{'name'};
  1425.   mtr_tonewfile($opt_current_test,"$tnamen"); # Always tell where we are
  1427.   # output current test to ndbcluster log file to enable diagnostics
  1428.   mtr_tofile($file_ndb_testrun_log,"CURRENT TEST $tnamen");
  1430.   # ----------------------------------------------------------------------
  1431.   # If marked to skip, just print out and return.
  1432.   # Note that a test case not marked as 'skip' can still be
  1433.   # skipped later, because of the test case itself in cooperation
  1434.   # with the mysqltest program tells us so.
  1435.   # ----------------------------------------------------------------------
  1437.   if ( $tinfo->{'skip'} )
  1438.   {
  1439.     mtr_report_test_name($tinfo);
  1440.     mtr_report_test_skipped($tinfo);
  1441.     return;
  1442.   }
  1444.   # ----------------------------------------------------------------------
  1445.   # If not using a running servers we may need to stop and restart.
  1446.   # We restart in the case we have initiation scripts, server options
  1447.   # etc to run. But we also restart again after the test first restart
  1448.   # and test is run, to get back to normal server settings.
  1449.   #
  1450.   # To make the code a bit more clean, we actually only stop servers
  1451.   # here, and mark this to be done. Then a generic "start" part will
  1452.   # start up the needed servers again.
  1453.   # ----------------------------------------------------------------------
  1455.   if ( ! $glob_use_running_server and ! $glob_use_embedded_server )
  1456.   {
  1457.     if ( $tinfo->{'master_restart'} or
  1458.          $master->[0]->{'running_master_is_special'} )
  1459.     {
  1460.       stop_masters();
  1461.       $master->[0]->{'running_master_is_special'}= 0; # Forget why we stopped
  1462.     }
  1464.     # ----------------------------------------------------------------------
  1465.     # Always terminate all slaves, if any. Else we may have useless
  1466.     # reconnection attempts and error messages in case the slave and
  1467.     # master servers restart.
  1468.     # ----------------------------------------------------------------------
  1470.     stop_slaves();
  1471.   }    
  1473.   # ----------------------------------------------------------------------
  1474.   # Prepare to start masters. Even if we use embedded, we want to run
  1475.   # the preparation.
  1476.   # ----------------------------------------------------------------------
  1478.   $ENV{'TZ'}= $tinfo->{'timezone'};
  1480.   mtr_report_test_name($tinfo);
  1482.   mtr_tofile($master->[0]->{'path_myerr'},"CURRENT_TEST: $tnamen");
  1484. # FIXME test cases that depend on each other, prevent this from
  1485. # being at this location.
  1486. #  do_before_start_master($tname,$tinfo->{'master_sh'});
  1488.   # ----------------------------------------------------------------------
  1489.   # If any mysqld servers running died, we have to know
  1490.   # ----------------------------------------------------------------------
  1492.   mtr_record_dead_children();
  1494.   # ----------------------------------------------------------------------
  1495.   # Start masters
  1496.   # ----------------------------------------------------------------------
  1498.   if ( ! $glob_use_running_server and ! $glob_use_embedded_server )
  1499.   {
  1500.     # FIXME give the args to the embedded server?!
  1501.     # FIXME what does $opt_local_master mean?!
  1502.     # FIXME split up start and check that started so that can do
  1503.     #       starts in parallel, masters and slaves at the same time.
  1505.     if ( ! $opt_local_master )
  1506.     {
  1507.       if ( $master->[0]->{'ndbcluster'} )
  1508.       {
  1509. $master->[0]->{'ndbcluster'}= ndbcluster_start();
  1510.         if ( $master->[0]->{'ndbcluster'} )
  1511.         {
  1512.           report_failure_and_restart($tinfo);
  1513.           return;
  1514.         }
  1515.       }
  1516.       if ( ! $master->[0]->{'pid'} )
  1517.       {
  1518.         # FIXME not correct location for do_before_start_master()
  1519.         do_before_start_master($tname,$tinfo->{'master_sh'});
  1520.         $master->[0]->{'pid'}=
  1521.           mysqld_start('master',0,$tinfo->{'master_opt'},[]);
  1522.         if ( ! $master->[0]->{'pid'} )
  1523.         {
  1524.           report_failure_and_restart($tinfo);
  1525.           return;
  1526.         }
  1527.       }
  1528.       if ( $opt_with_ndbcluster and ! $master->[1]->{'pid'} )
  1529.       {
  1530.         $master->[1]->{'pid'}=
  1531.           mysqld_start('master',1,$tinfo->{'master_opt'},[]);
  1532.         if ( ! $master->[1]->{'pid'} )
  1533.         {
  1534.           report_failure_and_restart($tinfo);
  1535.           return;
  1536.         }
  1537.       }
  1539.       if ( $tinfo->{'master_restart'} )
  1540.       {
  1541.         $master->[0]->{'running_master_is_special'}= 1;
  1542.       }
  1543.     }
  1545.     # ----------------------------------------------------------------------
  1546.     # Start slaves - if needed
  1547.     # ----------------------------------------------------------------------
  1549.     if ( $tinfo->{'slave_num'} )
  1550.     {
  1551.       mtr_tofile($slave->[0]->{'path_myerr'},"CURRENT_TEST: $tnamen");
  1553.       do_before_start_slave($tname,$tinfo->{'slave_sh'});
  1555.       for ( my $idx= 0; $idx <  $tinfo->{'slave_num'}; $idx++ )
  1556.       {
  1557.         if ( ! $slave->[$idx]->{'pid'} )
  1558.         {
  1559.           $slave->[$idx]->{'pid'}=
  1560.             mysqld_start('slave',$idx,
  1561.                          $tinfo->{'slave_opt'}, $tinfo->{'slave_mi'});
  1562.           if ( ! $slave->[$idx]->{'pid'} )
  1563.           {
  1564.             report_failure_and_restart($tinfo);
  1565.             return;
  1566.           }
  1567.         }
  1568.       }
  1569.     }
  1570.   }
  1572.   # ----------------------------------------------------------------------
  1573.   # If --start-and-exit given, stop here to let user manually run tests
  1574.   # ----------------------------------------------------------------------
  1576.   if ( $opt_start_and_exit )
  1577.   {
  1578.     mtr_report("nServers started, exiting");
  1579.     exit(0);
  1580.   }
  1582.   # ----------------------------------------------------------------------
  1583.   # Run the test case
  1584.   # ----------------------------------------------------------------------
  1586.   {
  1587.     # remove the old reject file
  1588.     if ( $opt_suite eq "main" )
  1589.     {
  1590.       unlink("r/$tname.reject");
  1591.     }
  1592.     else
  1593.     {
  1594.       unlink("suite/$opt_suite/r/$tname.reject");
  1595.     }
  1596.     unlink($path_timefile);
  1598.     my $res= run_mysqltest($tinfo);
  1600.     if ( $res == 0 )
  1601.     {
  1602.       mtr_report_test_passed($tinfo);
  1603.     }
  1604.     elsif ( $res == 62 )
  1605.     {
  1606.       # Testcase itself tell us to skip this one
  1607.       mtr_report_test_skipped($tinfo);
  1608.     }
  1609.     elsif ( $res == 63 )
  1610.     {
  1611.       $tinfo->{'timeout'}= 1;           # Mark as timeout
  1612.       report_failure_and_restart($tinfo);
  1613.     }
  1614.     else
  1615.     {
  1616.       # Test case failed, if in control mysqltest returns 1
  1617.       if ( $res != 1 )
  1618.       {
  1619.         mtr_tofile($path_timefile,
  1620.                    "mysqltest returned unexpected code $res, " .
  1621.                    "it has probably crashed");
  1622.       }
  1623.       report_failure_and_restart($tinfo);
  1624.     }
  1625.   }
  1626. }
  1629. sub report_failure_and_restart ($) {
  1630.   my $tinfo= shift;
  1632.   mtr_report_test_failed($tinfo);
  1633.   mtr_show_failed_diff($tinfo->{'name'});
  1634.   print "n";
  1635.   if ( ! $opt_force )
  1636.   {
  1637.     my $test_mode= join(" ", @::glob_test_mode) || "default";
  1638.     print "Aborting: $tinfo->{'name'} failed in $test_mode mode. ";
  1639.     print "To continue, re-run with '--force'.n";
  1640.     if ( ! $opt_gdb and ! $glob_use_running_server and
  1641.          ! $opt_ddd and ! $glob_use_embedded_server )
  1642.     {
  1643.       stop_masters_slaves();
  1644.     }
  1645.     mtr_exit(1);
  1646.   }
  1648.   # FIXME always terminate on failure?!
  1649.   if ( ! $opt_gdb and ! $glob_use_running_server and
  1650.        ! $opt_ddd and ! $glob_use_embedded_server )
  1651.   {
  1652.     stop_masters_slaves();
  1653.   }
  1654.   print "Resuming Testsnn";
  1655. }
  1658. ##############################################################################
  1659. #
  1660. #  Start and stop servers
  1661. #
  1662. ##############################################################################
  1664. # The embedded server needs the cleanup so we do some of the start work
  1665. # but stop before actually running mysqld or anything.
  1667. sub do_before_start_master ($$) {
  1668.   my $tname=       shift;
  1669.   my $init_script= shift;
  1671.   # FIXME what about second master.....
  1673.   # Remove stale binary logs except for 2 tests which need them FIXME here????
  1674.   if ( $tname ne "rpl_crash_binlog_ib_1b" and
  1675.        $tname ne "rpl_crash_binlog_ib_2b" and
  1676.        $tname ne "rpl_crash_binlog_ib_3b")
  1677.   {
  1678.     # FIXME we really want separate dir for binlogs
  1679.     foreach my $bin ( glob("$opt_vardir/log/master*-bin*") )
  1680.     {
  1681.       unlink($bin);
  1682.     }
  1683.   }
  1685.   # FIXME only remove the ones that are tied to this master
  1686.   # Remove old master.info and relay-log.info files
  1687.   unlink("$master->[0]->{'path_myddir'}/master.info");
  1688.   unlink("$master->[0]->{'path_myddir'}/relay-log.info");
  1689.   unlink("$master->[1]->{'path_myddir'}/master.info");
  1690.   unlink("$master->[1]->{'path_myddir'}/relay-log.info");
  1692.   # Run master initialization shell script if one exists
  1693.   if ( $init_script )
  1694.   {
  1695.     my $ret= mtr_run("/bin/sh", [$init_script], "", "", "", "");
  1696.     if ( $ret != 0 )
  1697.     {
  1698.       # FIXME rewrite those scripts to return 0 if successful
  1699. #      mtr_warning("$init_script exited with code $ret");
  1700.     }
  1701.   }
  1702.   # for gcov  FIXME needed? If so we need more absolute paths
  1703. # chdir($glob_basedir);
  1704. }
  1706. sub do_before_start_slave ($$) {
  1707.   my $tname=       shift;
  1708.   my $init_script= shift;
  1710.   # Remove stale binary logs and old master.info files
  1711.   # except for too tests which need them
  1712.   if ( $tname ne "rpl_crash_binlog_ib_1b" and
  1713.        $tname ne "rpl_crash_binlog_ib_2b" and
  1714.        $tname ne "rpl_crash_binlog_ib_3b" )
  1715.   {
  1716.     # FIXME we really want separate dir for binlogs
  1717.     foreach my $bin ( glob("$opt_vardir/log/slave*-bin*") )
  1718.     {
  1719.       unlink($bin);
  1720.     }
  1721.     # FIXME really master?!
  1722.     unlink("$slave->[0]->{'path_myddir'}/master.info");
  1723.     unlink("$slave->[0]->{'path_myddir'}/relay-log.info");
  1724.   }
  1726.   # Run slave initialization shell script if one exists
  1727.   if ( $init_script )
  1728.   {
  1729.     my $ret= mtr_run("/bin/sh", [$init_script], "", "", "", "");
  1730.     if ( $ret != 0 )
  1731.     {
  1732.       # FIXME rewrite those scripts to return 0 if successful
  1733. #      mtr_warning("$init_script exited with code $ret");
  1734.     }
  1735.   }
  1737.   foreach my $bin ( glob("$slave->[0]->{'path_myddir'}/log.*") )
  1738.   {
  1739.     unlink($bin);
  1740.   }
  1741. }
  1743. sub mysqld_arguments ($$$$$) {
  1744.   my $args=              shift;
  1745.   my $type=              shift;        # master/slave/bootstrap
  1746.   my $idx=               shift;
  1747.   my $extra_opt=         shift;
  1748.   my $slave_master_info= shift;
  1750.   my $sidx= "";                 # Index as string, 0 is empty string
  1751.   if ( $idx > 0 )
  1752.   {
  1753.     $sidx= sprintf("%d", $idx); # sprintf not needed in Perl for this
  1754.   }
  1756.   my $prefix= "";               # If mysqltest server arg
  1758.   if ( $glob_use_embedded_server )
  1759.   {
  1760.     $prefix= "--server-arg=";
  1761.   } else {
  1762.     # We can't pass embedded server --no-defaults
  1763.     mtr_add_arg($args, "%s--no-defaults", $prefix);
  1764.   }
  1766.   mtr_add_arg($args, "%s--console", $prefix);
  1767.   mtr_add_arg($args, "%s--basedir=%s", $prefix, $path_my_basedir);
  1768.   mtr_add_arg($args, "%s--character-sets-dir=%s", $prefix, $path_charsetsdir);
  1769.   mtr_add_arg($args, "%s--core", $prefix);
  1770.   mtr_add_arg($args, "%s--default-character-set=latin1", $prefix);
  1771.   mtr_add_arg($args, "%s--language=%s", $prefix, $path_language);
  1772.   mtr_add_arg($args, "%s--tmpdir=$opt_tmpdir", $prefix);
  1774.   if ( defined $opt_valgrind )
  1775.   {
  1776.     mtr_add_arg($args, "%s--skip-safemalloc", $prefix);
  1777.     mtr_add_arg($args, "%s--skip-bdb", $prefix);
  1778.   }
  1780.   my $pidfile;
  1782.   if ( $type eq 'master' )
  1783.   {
  1784.     my $id= $idx > 0 ? $idx + 101 : 1;
  1786.     mtr_add_arg($args, "%s--log-bin=%s/log/master-bin%s", $prefix,
  1787.                 $opt_vardir, $sidx);
  1788.     mtr_add_arg($args, "%s--pid-file=%s", $prefix,
  1789.                 $master->[$idx]->{'path_mypid'});
  1790.     mtr_add_arg($args, "%s--port=%d", $prefix,
  1791.                 $master->[$idx]->{'path_myport'});
  1792.     mtr_add_arg($args, "%s--server-id=%d", $prefix, $id);
  1793.     mtr_add_arg($args, "%s--socket=%s", $prefix,
  1794.                 $master->[$idx]->{'path_mysock'});
  1795.     mtr_add_arg($args, "%s--innodb_data_file_path=ibdata1:50M", $prefix);
  1796.     mtr_add_arg($args, "%s--local-infile", $prefix);
  1797.     mtr_add_arg($args, "%s--datadir=%s", $prefix,
  1798.                 $master->[$idx]->{'path_myddir'});
  1800.     if ( $idx > 0 )
  1801.     {
  1802.       mtr_add_arg($args, "%s--skip-innodb", $prefix);
  1803.     }
  1805.     if ( $opt_skip_ndbcluster )
  1806.     {
  1807.       mtr_add_arg($args, "%s--skip-ndbcluster", $prefix);
  1808.     }
  1809.   }
  1811.   if ( $type eq 'slave' )
  1812.   {
  1813.     my $slave_server_id=  2 + $idx;
  1814.     my $slave_rpl_rank= $slave_server_id;
  1816.     mtr_add_arg($args, "%s--datadir=%s", $prefix,
  1817.                 $slave->[$idx]->{'path_myddir'});
  1818.     # FIXME slave get this option twice?!
  1819.     mtr_add_arg($args, "%s--exit-info=256", $prefix);
  1820.     mtr_add_arg($args, "%s--init-rpl-role=slave", $prefix);
  1821.     mtr_add_arg($args, "%s--log-bin=%s/log/slave%s-bin", $prefix,
  1822.                 $opt_vardir, $sidx); # FIXME use own dir for binlogs
  1823.     mtr_add_arg($args, "%s--log-slave-updates", $prefix);
  1824.     # FIXME option duplicated for slave
  1825.     mtr_add_arg($args, "%s--log=%s", $prefix,
  1826.                 $slave->[$idx]->{'path_mylog'});
  1827.     mtr_add_arg($args, "%s--master-retry-count=10", $prefix);
  1828.     mtr_add_arg($args, "%s--pid-file=%s", $prefix,
  1829.                 $slave->[$idx]->{'path_mypid'});
  1830.     mtr_add_arg($args, "%s--port=%d", $prefix,
  1831.                 $slave->[$idx]->{'path_myport'});
  1832.     mtr_add_arg($args, "%s--relay-log=%s/log/slave%s-relay-bin", $prefix,
  1833.                 $opt_vardir, $sidx);
  1834.     mtr_add_arg($args, "%s--report-host=127.0.0.1", $prefix);
  1835.     mtr_add_arg($args, "%s--report-port=%d", $prefix,
  1836.                 $slave->[$idx]->{'path_myport'});
  1837.     mtr_add_arg($args, "%s--report-user=root", $prefix);
  1838.     mtr_add_arg($args, "%s--skip-innodb", $prefix);
  1839.     mtr_add_arg($args, "%s--skip-ndbcluster", $prefix);
  1840.     mtr_add_arg($args, "%s--skip-slave-start", $prefix);
  1841.     mtr_add_arg($args, "%s--slave-load-tmpdir=%s", $prefix,
  1842.                 $path_slave_load_tmpdir);
  1843.     mtr_add_arg($args, "%s--socket=%s", $prefix,
  1844.                 $slave->[$idx]->{'path_mysock'});
  1845.     mtr_add_arg($args, "%s--set-variable=slave_net_timeout=10", $prefix);
  1847.     if ( @$slave_master_info )
  1848.     {
  1849.       foreach my $arg ( @$slave_master_info )
  1850.       {
  1851.         mtr_add_arg($args, "%s%s", $prefix, $arg);
  1852.       }
  1853.     }
  1854.     else
  1855.     {
  1856.       mtr_add_arg($args, "%s--master-user=root", $prefix);
  1857.       mtr_add_arg($args, "%s--master-connect-retry=1", $prefix);
  1858.       mtr_add_arg($args, "%s--master-host=127.0.0.1", $prefix);
  1859.       mtr_add_arg($args, "%s--master-password=", $prefix);
  1860.       mtr_add_arg($args, "%s--master-port=%d", $prefix,
  1861.                   $master->[0]->{'path_myport'}); # First master
  1862.       mtr_add_arg($args, "%s--server-id=%d", $prefix, $slave_server_id);
  1863.       mtr_add_arg($args, "%s--rpl-recovery-rank=%d", $prefix, $slave_rpl_rank);
  1864.     }
  1865.   } # end slave
  1867.   if ( $opt_debug )
  1868.   {
  1869.     if ( $type eq 'master' )
  1870.     {
  1871.       mtr_add_arg($args, "%s--debug=d:t:i:A,%s/log/master%s.trace",
  1872.                   $prefix, $opt_vardir, $sidx);
  1873.     }
  1874.     if ( $type eq 'slave' )
  1875.     {
  1876.       mtr_add_arg($args, "%s--debug=d:t:i:A,%s/log/slave%s.trace",
  1877.                   $prefix, $opt_vardir, $sidx);
  1878.     }
  1879.   }
  1881.   if ( $opt_with_ndbcluster )
  1882.   {
  1883.     mtr_add_arg($args, "%s--ndbcluster", $prefix);
  1884.     mtr_add_arg($args, "%s--ndb-connectstring=%s", $prefix,
  1885.                 $opt_ndbconnectstring);
  1886.   }
  1888.   # FIXME always set nowdays??? SMALL_SERVER
  1889.   mtr_add_arg($args, "%s--key_buffer_size=1M", $prefix);
  1890.   mtr_add_arg($args, "%s--sort_buffer=256K", $prefix);
  1891.   mtr_add_arg($args, "%s--max_heap_table_size=1M", $prefix);
  1893.   if ( $opt_with_openssl )
  1894.   {
  1895.     mtr_add_arg($args, "%s--ssl-ca=%s/std_data/cacert.pem", $prefix,
  1896.                 $glob_mysql_test_dir);
  1897.     mtr_add_arg($args, "%s--ssl-cert=%s/std_data/server-cert.pem", $prefix,
  1898.                 $glob_mysql_test_dir);
  1899.     mtr_add_arg($args, "%s--ssl-key=%s/std_data/server-key.pem", $prefix,
  1900.                 $glob_mysql_test_dir);
  1901.   }
  1903.   if ( $opt_warnings )
  1904.   {
  1905.     mtr_add_arg($args, "%s--log-warnings", $prefix);
  1906.   }
  1908.   if ( $opt_gdb or $opt_client_gdb or $opt_manual_gdb or $opt_ddd)
  1909.   {
  1910.     mtr_add_arg($args, "%s--gdb", $prefix);
  1911.   }
  1913.   # If we should run all tests cases, we will use a local server for that
  1915.   if ( -w "/" )
  1916.   {
  1917.     # We are running as root;  We need to add the --root argument
  1918.     mtr_add_arg($args, "%s--user=root", $prefix);
  1919.   }
  1921.   if ( $type eq 'master' )
  1922.   {
  1924.     if ( ! $opt_old_master )
  1925.     {
  1926.       mtr_add_arg($args, "%s--rpl-recovery-rank=1", $prefix);
  1927.       mtr_add_arg($args, "%s--init-rpl-role=master", $prefix);
  1928.     }
  1930.     # FIXME strange,.....
  1931.     # FIXME MYSQL_MYPORT is not set anythere?!
  1932.     if ( $opt_local_master )
  1933.     {
  1934.       mtr_add_arg($args, "%s--host=127.0.0.1", $prefix);
  1935.       mtr_add_arg($args, "%s--port=%s", $prefix, $ENV{'MYSQL_MYPORT'});
  1936.     }
  1937.   }
  1939.   foreach my $arg ( @opt_extra_mysqld_opt, @$extra_opt )
  1940.   {
  1941.     mtr_add_arg($args, "%s%s", $prefix, $arg);
  1942.   }
  1944.   if ( $opt_bench )
  1945.   {
  1946.     mtr_add_arg($args, "%s--rpl-recovery-rank=1", $prefix);
  1947.     mtr_add_arg($args, "%s--init-rpl-role=master", $prefix);
  1948.   }
  1949.   elsif ( $type eq 'master' )
  1950.   {
  1951.     mtr_add_arg($args, "%s--exit-info=256", $prefix);
  1952.     mtr_add_arg($args, "%s--open-files-limit=1024", $prefix);
  1953.     mtr_add_arg($args, "%s--log=%s", $prefix, $master->[0]->{'path_mylog'});
  1954.   }
  1956.   return $args;
  1957. }
  1959. # FIXME
  1960. #  if ( $type eq 'master' and $glob_use_embedded_server )
  1961. #  {
  1962. #    # Add a -A to each argument to pass it to embedded server
  1963. #    my @mysqltest_opt=  map {("-A",$_)} @args;
  1964. #    $opt_extra_mysqltest_opt=  @mysqltest_opt;
  1965. #    return;
  1966. #  }
  1968. ##############################################################################
  1969. #
  1970. #  Start mysqld and return the PID
  1971. #
  1972. ##############################################################################
  1974. sub mysqld_start ($$$$) {
  1975.   my $type=              shift;        # master/slave/bootstrap
  1976.   my $idx=               shift;
  1977.   my $extra_opt=         shift;
  1978.   my $slave_master_info= shift;
  1980.   my $args;                             # Arg vector
  1981.   my $exe;
  1982.   my $pid;
  1984.   if ( $type eq 'master' )
  1985.   {
  1986.     $exe= $exe_master_mysqld;
  1987.   }
  1988.   elsif ( $type eq 'slave' )
  1989.   {
  1990.     $exe= $exe_slave_mysqld;
  1991.   }
  1992.   else
  1993.   {
  1994.     $exe= $exe_mysqld;
  1995.   }
  1997.   mtr_init_args($args);
  1999.   if ( defined $opt_valgrind )
  2000.   {
  2001.     valgrind_arguments($args, $exe);
  2002.   }
  2004.   mysqld_arguments($args,$type,$idx,$extra_opt,$slave_master_info);
  2006.   if ( $type eq 'master' )
  2007.   {
  2008.     if ( $pid= mtr_spawn($exe, $args, "",
  2009.                          $master->[$idx]->{'path_myerr'},
  2010.                          $master->[$idx]->{'path_myerr'},
  2011.                          "",
  2012.                          { append_log_file => 1 }) )
  2013.     {
  2014.       return sleep_until_file_created($master->[$idx]->{'path_mypid'},
  2015.                                       $master->[$idx]->{'start_timeout'}, $pid);
  2016.     }
  2017.   }
  2019.   if ( $type eq 'slave' )
  2020.   {
  2021.     if ( $pid= mtr_spawn($exe, $args, "",
  2022.                          $slave->[$idx]->{'path_myerr'},
  2023.                          $slave->[$idx]->{'path_myerr'},
  2024.                          "",
  2025.                          { append_log_file => 1 }) )
  2026.     {
  2027.       return sleep_until_file_created($slave->[$idx]->{'path_mypid'},
  2028.                                       $master->[$idx]->{'start_timeout'}, $pid);
  2029.     }
  2030.   }
  2032.   return 0;
  2033. }
  2035. sub stop_masters_slaves () {
  2037.   print  "Ending Testsn";
  2038.   print  "Shutting-down MySQL daemonnn";
  2039.   stop_masters();
  2040.   print "Master(s) shutdown finishedn";
  2041.   stop_slaves();
  2042.   print "Slave(s) shutdown finishedn";
  2043. }
  2045. sub stop_masters () {
  2047.   my @args;
  2049.   for ( my $idx; $idx < 2; $idx++ )
  2050.   {
  2051.     # FIXME if we hit ^C before fully started, this test will prevent
  2052.     # the mysqld process from being killed
  2053.     if ( $master->[$idx]->{'pid'} )
  2054.     {
  2055.       push(@args,{
  2056.                   pid      => $master->[$idx]->{'pid'},
  2057.                   pidfile  => $master->[$idx]->{'path_mypid'},
  2058.                   sockfile => $master->[$idx]->{'path_mysock'},
  2059.                   port     => $master->[$idx]->{'path_myport'},
  2060.                  });
  2061.       $master->[$idx]->{'pid'}= 0; # Assume we are done with it
  2062.     }
  2063.   }
  2065.   if ( ! $master->[0]->{'ndbcluster'} )
  2066.   {
  2067.     ndbcluster_stop();
  2068.     $master->[0]->{'ndbcluster'}= 1;
  2069.   }
  2071.   mtr_stop_mysqld_servers(@args);
  2072. }
  2074. sub stop_slaves () {
  2075.   my $force= shift;
  2077.   my @args;
  2079.   for ( my $idx; $idx < 3; $idx++ )
  2080.   {
  2081.     if ( $slave->[$idx]->{'pid'} )
  2082.     {
  2083.       push(@args,{
  2084.                   pid      => $slave->[$idx]->{'pid'},
  2085.                   pidfile  => $slave->[$idx]->{'path_mypid'},
  2086.                   sockfile => $slave->[$idx]->{'path_mysock'},
  2087.                   port     => $slave->[$idx]->{'path_myport'},
  2088.                  });
  2089.       $slave->[$idx]->{'pid'}= 0; # Assume we are done with it
  2090.     }
  2091.   }
  2093.   mtr_stop_mysqld_servers(@args);
  2094. }
  2097. sub run_mysqltest ($) {
  2098.   my $tinfo=       shift;
  2100.   my $cmdline_mysqldump= "$exe_mysqldump --no-defaults -uroot " .
  2101.                          "--port=$master->[0]->{'path_myport'} " .
  2102.                          "--socket=$master->[0]->{'path_mysock'} --password=";
  2103.   if ( $opt_debug )
  2104.   {
  2105.     $cmdline_mysqldump .=
  2106.       " --debug=d:t:A,$opt_vardir/log/mysqldump.trace";
  2107.   }
  2108.   my $cmdline_mysqlimport= "$exe_mysqlimport -uroot " .
  2109.                          "--port=$master->[0]->{'path_myport'} " .
  2110.                          "--socket=$master->[0]->{'path_mysock'} --password=";
  2111.   if ( $opt_debug )
  2112.   {
  2113.     $cmdline_mysqlimport .=
  2114.       " --debug=d:t:A,$opt_vardir/log/mysqlimport.trace";
  2115.   }
  2117.   my $cmdline_mysqlshow= "$exe_mysqlshow -uroot " .
  2118.                          "--port=$master->[0]->{'path_myport'} " .
  2119.                          "--socket=$master->[0]->{'path_mysock'} --password=";
  2120.   if ( $opt_debug )
  2121.   {
  2122.     $cmdline_mysqlshow .=
  2123.       " --debug=d:t:A,$opt_vardir/log/mysqlshow.trace";
  2124.   }
  2126.   my $cmdline_mysqlbinlog=
  2127.     "$exe_mysqlbinlog --no-defaults --local-load=$opt_tmpdir";
  2129.   if ( $opt_debug )
  2130.   {
  2131.     $cmdline_mysqlbinlog .=
  2132.       " --debug=d:t:A,$opt_vardir/log/mysqlbinlog.trace";
  2133.   }
  2135.   my $cmdline_mysql=
  2136.     "$exe_mysql --host=localhost  --user=root --password= " .
  2137.     "--port=$master->[0]->{'path_myport'} " .
  2138.     "--socket=$master->[0]->{'path_mysock'}";
  2140.   my $cmdline_mysql_client_test=
  2141.     "$exe_mysql_client_test --no-defaults --testcase --user=root --silent " .
  2142.     "--port=$master->[0]->{'path_myport'} " .
  2143.     "--socket=$master->[0]->{'path_mysock'}";
  2145.   if ( $glob_use_embedded_server )
  2146.   {
  2147.     $cmdline_mysql_client_test.=
  2148.       " -A --language=$path_language" .
  2149.       " -A --datadir=$slave->[0]->{'path_myddir'}" .
  2150.       " -A --character-sets-dir=$path_charsetsdir";
  2151.   }
  2153.   my $cmdline_mysql_fix_system_tables=
  2154.     "$exe_mysql_fix_system_tables --no-defaults --host=localhost --user=root --password= " .
  2155.     "--basedir=$glob_basedir --bindir=$path_client_bindir --verbose " .
  2156.     "--port=$master->[0]->{'path_myport'} " .
  2157.     "--socket=$master->[0]->{'path_mysock'}";
  2161.   # FIXME really needing a PATH???
  2162.   # $ENV{'PATH'}= "/bin:/usr/bin:/usr/local/bin:/usr/bsd:/usr/X11R6/bin:/usr/openwin/bin:/usr/bin/X11:$ENV{'PATH'}";
  2164.   $ENV{'MYSQL'}=                    $cmdline_mysql;
  2165.   $ENV{'MYSQL_DUMP'}=               $cmdline_mysqldump;
  2166.   $ENV{'MYSQL_IMPORT'}=             $cmdline_mysqlimport;
  2167.   $ENV{'MYSQL_SHOW'}=               $cmdline_mysqlshow;
  2168.   $ENV{'MYSQL_BINLOG'}=             $cmdline_mysqlbinlog;
  2169.   $ENV{'MYSQL_FIX_SYSTEM_TABLES'}=  $cmdline_mysql_fix_system_tables;
  2170.   $ENV{'MYSQL_CLIENT_TEST'}=        $cmdline_mysql_client_test;
  2171.   $ENV{'CHARSETSDIR'}=              $path_charsetsdir;
  2173.   $ENV{'NDB_STATUS_OK'}=            $flag_ndb_status_ok;
  2174.   $ENV{'NDB_MGM'}=                  $exe_ndb_mgm;
  2175.   $ENV{'NDB_BACKUP_DIR'}=           $path_ndb_backup_dir;
  2176.   $ENV{'NDB_TOOLS_DIR'}=            $path_ndb_tools_dir;
  2177.   $ENV{'NDB_TOOLS_OUTPUT'}=         $file_ndb_testrun_log;
  2178.   $ENV{'NDB_CONNECTSTRING'}=        $opt_ndbconnectstring;
  2180.   my $exe= $exe_mysqltest;
  2181.   my $args;
  2183.   mtr_init_args($args);
  2185.   if ( defined $opt_valgrind_mysqltest )
  2186.   {
  2187.     valgrind_arguments($args, $exe);
  2188.   }
  2190.   mtr_add_arg($args, "--no-defaults");
  2191.   mtr_add_arg($args, "--socket=%s", $master->[0]->{'path_mysock'});
  2192.   mtr_add_arg($args, "--database=test");
  2193.   mtr_add_arg($args, "--user=%s", $opt_user);
  2194.   mtr_add_arg($args, "--password=");
  2195.   mtr_add_arg($args, "--silent");
  2196.   mtr_add_arg($args, "-v");
  2197.   mtr_add_arg($args, "--skip-safemalloc");
  2198.   mtr_add_arg($args, "--tmpdir=%s", $opt_tmpdir);
  2199.   mtr_add_arg($args, "--port=%d", $master->[0]->{'path_myport'});
  2201.   if ( $opt_ps_protocol )
  2202.   {
  2203.     mtr_add_arg($args, "--ps-protocol");
  2204.   }
  2206.   if ( $opt_strace_client )
  2207.   {
  2208.     $exe=  "strace";            # FIXME there are ktrace, ....
  2209.     mtr_add_arg($args, "-o");
  2210.     mtr_add_arg($args, "%s/log/mysqltest.strace", $opt_vardir);
  2211.     mtr_add_arg($args, "$exe_mysqltest");
  2212.   }
  2214.   if ( $opt_timer )
  2215.   {
  2216.     mtr_add_arg($args, "--timer-file=%s/log/timer", $opt_vardir);
  2217.   }
  2219.   if ( $opt_big_test )
  2220.   {
  2221.     mtr_add_arg($args, "--big-test");
  2222.   }
  2224.   if ( $opt_compress )
  2225.   {
  2226.     mtr_add_arg($args, "--compress");
  2227.   }
  2229.   if ( $opt_sleep )
  2230.   {
  2231.     mtr_add_arg($args, "--sleep=%d", $opt_sleep);
  2232.   }
  2234.   if ( $opt_debug )
  2235.   {
  2236.     mtr_add_arg($args, "--debug=d:t:A,%s/log/mysqltest.trace", $opt_vardir);
  2237.   }
  2239.   if ( $opt_with_openssl )
  2240.   {
  2241.     mtr_add_arg($args, "--ssl-ca=%s/std_data/cacert.pem",
  2242.                 $glob_mysql_test_dir);
  2243.     mtr_add_arg($args, "--ssl-cert=%s/std_data/client-cert.pem",
  2244.                 $glob_mysql_test_dir);
  2245.     mtr_add_arg($args, "--ssl-key=%s/std_data/client-key.pem",
  2246.                 $glob_mysql_test_dir);
  2247.   }
  2249.   # ----------------------------------------------------------------------
  2250.   # If embedded server, we create server args to give mysqltest to pass on
  2251.   # ----------------------------------------------------------------------
  2253.   if ( $glob_use_embedded_server )
  2254.   {
  2255.     mysqld_arguments($args,'master',0,$tinfo->{'master_opt'},[]);
  2256.   }
  2258.   # ----------------------------------------------------------------------
  2259.   # export MYSQL_TEST variable containing <path>/mysqltest <args>
  2260.   # ----------------------------------------------------------------------
  2261.   $ENV{'MYSQL_TEST'}= "$exe_mysqltest " . join(" ", @$args);
  2263.   # ----------------------------------------------------------------------
  2264.   # Add arguments that should not go into the MYSQL_TEST env var
  2265.   # ----------------------------------------------------------------------
  2267.   mtr_add_arg($args, "-R");
  2268.   mtr_add_arg($args, $tinfo->{'result_file'});
  2270.   if ( $opt_record )
  2271.   {
  2272.     mtr_add_arg($args, "--record");
  2273.   }
  2275.   return mtr_run_test($exe,$args,$tinfo->{'path'},"",$path_timefile,"");
  2276. }
  2279. sub valgrind_arguments {
  2280.   my $args= shift;
  2281.   my $exe=  shift;
  2283.   mtr_add_arg($args, "--tool=memcheck"); # From >= 2.1.2 needs this option
  2284.   mtr_add_arg($args, "--alignment=8");
  2285.   mtr_add_arg($args, "--leak-check=yes");
  2286.   mtr_add_arg($args, "--num-callers=16");
  2287.   mtr_add_arg($args, "--suppressions=%s/valgrind.supp", $glob_mysql_test_dir)
  2288.     if -f "$glob_mysql_test_dir/valgrind.supp";
  2290.   if ( defined $opt_valgrind_all )
  2291.   {
  2292.     mtr_add_arg($args, "-v");
  2293.     mtr_add_arg($args, "--show-reachable=yes");
  2294.   }
  2296.   if ( $opt_valgrind_options )
  2297.   {
  2298.     # FIXME split earlier and put into @glob_valgrind_*
  2299.     mtr_add_arg($args, split(' ', $opt_valgrind_options));
  2300.   }
  2302.   mtr_add_arg($args, $$exe);
  2304.   $$exe= $opt_valgrind || "valgrind";
  2305. }
  2308. ##############################################################################
  2309. #
  2310. #  Usage
  2311. #
  2312. ##############################################################################
  2314. sub usage ($) {
  2315.   print STDERR <<HERE;
  2317. mysql-test-run [ OPTIONS ] [ TESTCASE ]
  2319. FIXME when is TESTCASE arg used or not?!
  2321. Options to control what engine/variation to run
  2323.   embedded-server       Use the embedded server, i.e. no mysqld daemons
  2324.   ps-protocol           Use the binary protocol between client and server
  2325.   bench                 Run the benchmark suite FIXME
  2326.   small-bench           FIXME
  2327.   no-manager            Use the istanse manager (currently disabled)
  2329. Options to control what test suites or cases to run
  2331.   force                 Continue to run the suite after failure
  2332.   with-ndbcluster       Use cluster, and enable test cases that requres it
  2333.   do-test=PREFIX        Run test cases which name are prefixed with PREFIX
  2334.   start-from=PREFIX     Run test cases starting from test prefixed with PREFIX
  2335.   suite=NAME            Run the test suite named NAME. The default is "main"
  2336.   skip-rpl              Skip the replication test cases.
  2337.   skip-test=PREFIX      Skip test cases which name are prefixed with PREFIX
  2339. Options that specify ports
  2341.   master_port=PORT      Specify the port number used by the first master
  2342.   slave_port=PORT       Specify the port number used by the first slave
  2343.   ndbcluster_port=PORT  Specify the port number used by cluster
  2344.   manager-port=PORT     Specify the port number used by manager (currently not used)
  2346. Options for test case authoring
  2348.   record TESTNAME       (Re)genereate the result file for TESTNAME
  2350. Options that pass on options
  2352.   mysqld=ARGS           Specify additional arguments to "mysqld"
  2354. Options to run test on running server
  2356.   extern                Use running server for tests FIXME DANGEROUS
  2357.   ndbconnectstring=STR  Use running cluster, and connect using STR      
  2358.   user=USER             User for connect to server
  2360. Options for debugging the product
  2362.   gdb                   FIXME
  2363.   manual-gdb            FIXME
  2364.   client-gdb            FIXME
  2365.   ddd                   FIXME
  2366.   strace-client         FIXME
  2367.   master-binary=PATH    Specify the master "mysqld" to use
  2368.   slave-binary=PATH     Specify the slave "mysqld" to use
  2370. Options for coverage, profiling etc
  2372.   gcov                  FIXME
  2373.   gprof                 FIXME
  2374.   valgrind[=EXE]        Run the "mysqltest" executable as well as the "mysqld"
  2375.                         server using valgrind, optionally specifying the
  2376.                         executable path/name
  2377.   valgrind-mysqltest[=EXE] In addition, run the "mysqltest" executable with valgrind
  2378.   valgrind-all[=EXE]    Adds verbose flag, and --show-reachable to valgrind
  2379.   valgrind-options=ARGS Extra options to give valgrind
  2381. Misc options
  2383.   verbose               Verbose output from this script
  2384.   script-debug          Debug this script itself
  2385.   compress              Use the compressed protocol between client and server
  2386.   timer                 Show test case execution time
  2387.   start-and-exit        Only initiate and start the "mysqld" servers, use the startup
  2388.                         settings for the specified test case if any
  2389.   start-dirty           Only start the "mysqld" servers without initiation
  2390.   fast                  Don't try to cleanup from earlier runs
  2391.   reorder               Reorder tests to get less server restarts
  2392.   help                  Get this help text
  2393.   unified-diff | udiff  When presenting differences, use unified diff
  2395.   testcase-timeout=MINUTES Max test case run time (default 5)
  2396.   suite-timeout=MINUTES    Max test suite run time (default 120)
  2399. Options not yet described, or that I want to look into more
  2401.   big-test              
  2402.   debug                 
  2403.   local                 
  2404.   local-master          
  2405.   netware               
  2406.   old-master            
  2407.   sleep=SECONDS         
  2408.   socket=PATH           
  2409.   tmpdir=DIR            
  2410.   user-test=s           
  2411.   wait-timeout=SECONDS  
  2412.   warnings              
  2413.   log-warnings          
  2414.   with-openssl          
  2416. HERE
  2417.   mtr_exit(1);
  2419. }