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

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

MySQL数据库

开发平台：

Visual C++

mysql_test_run_new.c：源码内容
  1. /*
  2.   Copyright (c) 2002, 2003 Novell, Inc. All Rights Reserved. 
  4.   This program is free software; you can redistribute it and/or modify 
  5.   it under the terms of the GNU General Public License as published by 
  6.   the Free Software Foundation; either version 2 of the License, or 
  7.   (at your option) any later version. 
  9.   This program is distributed in the hope that it will be useful, 
  10.   but WITHOUT ANY WARRANTY; without even the implied warranty of
  11.   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 
  12.   GNU General Public License for more details. 
  14.   You should have received a copy of the GNU General Public License 
  15.   along with this program; if not, write to the Free Software 
  16.   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  17. */ 
  19. #include <stdlib.h>
  20. #include <stdio.h>
  21. #include <errno.h>
  22. #ifndef __WIN__
  23. #include <dirent.h>
  24. #endif
  25. #include <string.h>
  26. #ifdef __NETWARE__
  27. #include <screen.h>
  28. #include <nks/vm.h>
  29. #endif
  30. #include <ctype.h>
  31. #include <sys/stat.h>
  32. #ifndef __WIN__
  33. #include <unistd.h>
  34. #endif
  35. #include <fcntl.h>
  36. #ifdef __NETWARE__
  37. #include <sys/mode.h>
  38. #endif
  39. #ifdef __WIN__
  40. #include <windows.h>
  41. #include <shlwapi.h>
  42. #include <direct.h>
  43. #endif
  45. #include "my_manage.h"
  47. /******************************************************************************
  49.   macros
  51. ******************************************************************************/
  53. #define HEADER  "TEST                                           RESULT  n"
  54. #define DASH    "-------------------------------------------------------n"
  56. #define NW_TEST_SUFFIX   ".nw-test"
  57. #define NW_RESULT_SUFFIX ".nw-result"
  58. #define TEST_SUFFIX      ".test"
  59. #define RESULT_SUFFIX     ".result"
  60. #define REJECT_SUFFIX    ".reject"
  61. #define OUT_SUFFIX       ".out"
  62. #define ERR_SUFFIX       ".err"
  64. const char *TEST_PASS=   "[ pass ]";
  65. const char *TEST_SKIP=   "[ skip ]";
  66. const char *TEST_FAIL=   "[ fail ]";
  67. const char *TEST_BAD=    "[ bad  ]";
  68. const char *TEST_IGNORE= "[ignore]";
  70. /******************************************************************************
  72.   global variables
  74. ******************************************************************************/
  76. #ifdef __NETWARE__
  77. static char base_dir[FN_REFLEN]= "sys:/mysql";
  78. #else
  79. static char base_dir[FN_REFLEN]= "..";
  80. #endif
  81. static char db[FN_LEN]=       "test";
  82. static char user[FN_LEN]=     "root";
  83. static char password[FN_LEN]= "";
  85. int master_port= 9306;
  86. int slave_port=  9307;
  88. #if !defined(__NETWARE__) && !defined(__WIN__)
  89. static char master_socket[FN_REFLEN]= "./var/tmp/master.sock";
  90. static char slave_socket[FN_REFLEN]=  "./var/tmp/slave.sock";
  91. #endif
  93. #define MAX_COUNT_TESTES 1024
  95. #ifdef __WIN__
  96. #  define sting_compare_func _stricmp
  97. #else
  98. #  ifdef HAVE_STRCASECMP
  99. #    define sting_compare_func strcasecmp
  100. #  else
  101. #    define sting_compare_func strcmp
  102. #  endif
  103. #endif
  105. /* comma delimited list of tests to skip or empty string */
  106. #ifndef __WIN__
  107. static char skip_test[FN_REFLEN]= " lowercase_table3 , system_mysql_db_fix ";
  108. #else
  109. /*
  110.   The most ignore testes contain the calls of system command
  112.   lowercase_table3 is disabled by Gerg
  113.   system_mysql_db_fix  is disabled by Gerg
  114.   sp contains a command system
  115.   rpl_EE_error contains a command system
  116.   rpl_loaddatalocal contains a command system
  117.   ndb_autodiscover contains a command system
  118.   rpl_rotate_logs contains a command system
  119.   repair contains a command system
  120.   rpl_trunc_binlog contains a command system
  121.   mysqldump contains a command system
  122.   rpl000001 makes non-exit loop...temporary skiped
  123. */
  124. static char skip_test[FN_REFLEN]=
  125. " lowercase_table3 ,"
  126. " system_mysql_db_fix ,"
  127. " sp ,"
  128. " rpl_EE_error ,"
  129. " rpl_loaddatalocal ,"
  130. " ndb_autodiscover ,"
  131. " rpl_rotate_logs ,"
  132. " repair ,"
  133. " rpl_trunc_binlog ,"
  134. " mysqldump ,"
  135. " rpl000001 ,"
  137. " derived ,"
  138. " group_by ,"
  139. " select ,"
  140. " rpl000015 ,"
  141. " subselect ";
  142. #endif
  143. static char ignore_test[FN_REFLEN]= "";
  145. static char bin_dir[FN_REFLEN];
  146. static char mysql_test_dir[FN_REFLEN];
  147. static char test_dir[FN_REFLEN];
  148. static char mysql_tmp_dir[FN_REFLEN];
  149. static char result_dir[FN_REFLEN];
  150. static char master_dir[FN_REFLEN];
  151. static char slave_dir[FN_REFLEN];
  152. static char slave1_dir[FN_REFLEN];
  153. static char slave2_dir[FN_REFLEN];
  154. static char lang_dir[FN_REFLEN];
  155. static char char_dir[FN_REFLEN];
  157. static char mysqladmin_file[FN_REFLEN];
  158. static char mysqld_file[FN_REFLEN];
  159. static char mysqltest_file[FN_REFLEN];
  160. #ifndef __WIN__
  161. static char master_pid[FN_REFLEN];
  162. static char slave_pid[FN_REFLEN];
  163. static char sh_file[FN_REFLEN]= "/bin/sh";
  164. #else
  165. static HANDLE master_pid;
  166. static HANDLE slave_pid;
  167. #endif
  169. static char master_opt[FN_REFLEN]= "";
  170. static char slave_opt[FN_REFLEN]= "";
  172. static char slave_master_info[FN_REFLEN]= "";
  174. static char master_init_script[FN_REFLEN]= "";
  175. static char slave_init_script[FN_REFLEN]= "";
  177. /* OpenSSL */
  178. static char ca_cert[FN_REFLEN];
  179. static char server_cert[FN_REFLEN];
  180. static char server_key[FN_REFLEN];
  181. static char client_cert[FN_REFLEN];
  182. static char client_key[FN_REFLEN];
  184. int total_skip= 0;
  185. int total_pass= 0;
  186. int total_fail= 0;
  187. int total_test= 0;
  189. int total_ignore= 0;
  191. int use_openssl=    FALSE;
  192. int master_running= FALSE;
  193. int slave_running=  FALSE;
  194. int skip_slave=     TRUE;
  195. int single_test=    TRUE;
  197. int restarts= 0;
  199. FILE *log_fd= NULL;
  201. static char argument[FN_REFLEN];
  203. /******************************************************************************
  205.   functions
  207. ******************************************************************************/
  209. /******************************************************************************
  211.   prototypes
  213. ******************************************************************************/
  215. void report_stats();
  216. void install_db(char *);
  217. void mysql_install_db();
  218. void start_master();
  219. void start_slave();
  220. void mysql_start();
  221. void stop_slave();
  222. void stop_master();
  223. void mysql_stop();
  224. void mysql_restart();
  225. int read_option(char *, char *);
  226. void run_test(char *);
  227. void setup(char *);
  228. void vlog(const char *, va_list);
  229. void mlog(const char *, ...);
  230. void log_info(const char *, ...);
  231. void log_error(const char *, ...);
  232. void log_errno(const char *, ...);
  233. void die(const char *);
  234. char *str_tok(char* dest, char *string, const char *delim);
  235. #ifndef __WIN__
  236. void run_init_script(const char *script_name);
  237. #endif
  238. /******************************************************************************
  240.   report_stats()
  242.   Report the gathered statistics.
  244. ******************************************************************************/
  246. void report_stats()
  247. {
  248.   if (total_fail == 0)
  249.   {
  250.     mlog("nAll %d test(s) were successful.n", total_test);
  251.   }
  252.   else
  253.   {
  254.     double percent= ((double)total_pass / total_test) * 100;
  256.     mlog("nFailed %u/%u test(s), %.02f%% successful.n",
  257.          total_fail, total_test, percent);
  258.     mlog("nThe .out and .err files in %s may give you somen", result_dir);
  259.     mlog("hint of what when wrong.n");
  260.     mlog("nIf you want to report this error, please first read "
  261.          "the documentationn");
  262.     mlog("at: http://www.mysql.com/doc/M/y/MySQL_test_suite.htmln");
  263.   }
  264. }
  266. /******************************************************************************
  268.   install_db()
  270.   Install the a database.
  272. ******************************************************************************/
  274. void install_db(char *datadir)
  275. {
  276.   arg_list_t al;
  277.   int err;
  278.   char input[FN_REFLEN];
  279.   char output[FN_REFLEN];
  280.   char error[FN_REFLEN];
  282.   /* input file */
  283. #ifdef __NETWARE__
  284.   snprintf(input, FN_REFLEN, "%s/bin/init_db.sql", base_dir);
  285. #else
  286.   snprintf(input, FN_REFLEN, "%s/mysql-test/init_db.sql", base_dir);
  287. #endif
  288.   snprintf(output, FN_REFLEN, "%s/install.out", datadir);
  289.   snprintf(error, FN_REFLEN, "%s/install.err", datadir);
  291.   if (create_system_files(datadir,input, TRUE))
  292.     die("Unable to create init_db.sql.");
  293.   /* args */
  294.   init_args(&al);
  295.   add_arg(&al, mysqld_file);
  296.   add_arg(&al, "--no-defaults");
  297.   add_arg(&al, "--bootstrap");
  298.   add_arg(&al, "--skip-grant-tables");
  299.   add_arg(&al, "--basedir=%s", base_dir);
  300.   add_arg(&al, "--datadir=%s", datadir);
  301.   add_arg(&al, "--skip-innodb");
  302.   add_arg(&al, "--skip-ndbcluster");
  303.   add_arg(&al, "--skip-bdb");
  304. #ifndef __NETWARE__
  305.   add_arg(&al, "--character-sets-dir=%s", char_dir);
  306.   add_arg(&al, "--language=%s", lang_dir);
  307. #endif
  308. // added 
  309.   add_arg(&al, "--default-character-set=latin1");
  310.   add_arg(&al, "--innodb_data_file_path=ibdata1:50M");
  312.   /* spawn */
  313.   if ((err= spawn(mysqld_file, &al, TRUE, input, output, error, NULL)) != 0)
  314.   {
  315.     die("Unable to create database.");
  316.   }
  318.   /* free args */
  319.   free_args(&al);
  320. }
  322. /******************************************************************************
  324.   mysql_install_db()
  326.   Install the test databases.
  328. ******************************************************************************/
  330. void mysql_install_db()
  331. {
  332.   char temp[FN_REFLEN];
  334.   /* var directory */
  335.   snprintf(temp, FN_REFLEN, "%s/var", mysql_test_dir);
  337.   /* create var directory */
  338. #ifndef __WIN__
  339.   mkdir(temp, S_IRWXU);
  340.   /* create subdirectories */
  341.   mlog("Creating test-suite folders...n");
  342.   snprintf(temp, FN_REFLEN, "%s/var/run", mysql_test_dir);
  343.   mkdir(temp, S_IRWXU);
  344.   snprintf(temp, FN_REFLEN, "%s/var/tmp", mysql_test_dir);
  345.   mkdir(temp, S_IRWXU);
  346.   snprintf(temp, FN_REFLEN, "%s/var/master-data", mysql_test_dir);
  347.   mkdir(temp, S_IRWXU);
  348.   snprintf(temp, FN_REFLEN, "%s/var/master-data/mysql", mysql_test_dir);
  349.   mkdir(temp, S_IRWXU);
  350.   snprintf(temp, FN_REFLEN, "%s/var/master-data/test", mysql_test_dir);
  351.   mkdir(temp, S_IRWXU);
  352.   
  353.   snprintf(temp, FN_REFLEN, "%s/var/slave-data", mysql_test_dir);
  354.   mkdir(temp, S_IRWXU);
  355.   snprintf(temp, FN_REFLEN, "%s/var/slave-data/mysql", mysql_test_dir);
  356.   mkdir(temp, S_IRWXU);
  357.   snprintf(temp, FN_REFLEN, "%s/var/slave-data/test", mysql_test_dir);
  358.   mkdir(temp, S_IRWXU);
  359.   
  360.   snprintf(temp, FN_REFLEN, "%s/var/slave1-data", mysql_test_dir);
  361.   mkdir(temp, S_IRWXU);
  362.   snprintf(temp, FN_REFLEN, "%s/var/slave1-data/mysql", mysql_test_dir);
  363.   mkdir(temp, S_IRWXU);
  364.   snprintf(temp, FN_REFLEN, "%s/var/slave1-data/test", mysql_test_dir);
  365.   mkdir(temp, S_IRWXU);
  366.   
  367.   snprintf(temp, FN_REFLEN, "%s/var/slave2-data", mysql_test_dir);
  368.   mkdir(temp, S_IRWXU);
  369.   snprintf(temp, FN_REFLEN, "%s/var/slave2-data/mysql", mysql_test_dir);
  370.   mkdir(temp, S_IRWXU);
  371.   snprintf(temp, FN_REFLEN, "%s/var/slave2-data/test", mysql_test_dir);
  372.   mkdir(temp, S_IRWXU);
  373. #else
  374.   mkdir(temp);
  375.   /* create subdirectories */
  376.   mlog("Creating test-suite folders...n");
  377.   snprintf(temp, FN_REFLEN, "%s/var/run", mysql_test_dir);
  378.   mkdir(temp);
  379.   snprintf(temp, FN_REFLEN, "%s/var/tmp", mysql_test_dir);
  380.   mkdir(temp);
  381.   snprintf(temp, FN_REFLEN, "%s/var/master-data", mysql_test_dir);
  382.   mkdir(temp);
  383.   snprintf(temp, FN_REFLEN, "%s/var/master-data/mysql", mysql_test_dir);
  384.   mkdir(temp);
  385.   snprintf(temp, FN_REFLEN, "%s/var/master-data/test", mysql_test_dir);
  386.   mkdir(temp);
  387.   snprintf(temp, FN_REFLEN, "%s/var/slave-data", mysql_test_dir);
  388.   mkdir(temp);
  389.   snprintf(temp, FN_REFLEN, "%s/var/slave-data/mysql", mysql_test_dir);
  390.   mkdir(temp);
  391.   snprintf(temp, FN_REFLEN, "%s/var/slave-data/test", mysql_test_dir);
  392.   mkdir(temp);
  393. #endif
  395.   /* install databases */
  396.   mlog("Creating test databases for master... n");
  397.   install_db(master_dir);
  398.   mlog("Creating test databases for slave... n");
  399.   install_db(slave_dir);
  400.   install_db(slave1_dir);
  401.   install_db(slave2_dir);
  402. }
  404. /******************************************************************************
  406.   start_master()
  408.   Start the master server.
  410. ******************************************************************************/
  412. void start_master()
  413. {
  414.   arg_list_t al;
  415.   int err;
  416.   char master_out[FN_REFLEN];
  417.   char master_err[FN_REFLEN];
  418.   char temp2[FN_REFLEN];
  420.   /* remove old berkeley db log files that can confuse the server */
  421.   removef("%s/log.*", master_dir);
  423.   /* remove stale binary logs */
  424.   removef("%s/var/log/*-bin.*", mysql_test_dir);
  426.   /* remove stale binary logs */
  427.   removef("%s/var/log/*.index", mysql_test_dir);
  429.   /* remove master.info file */
  430.   removef("%s/master.info", master_dir);
  432.   /* remove relay files */
  433.   removef("%s/var/log/*relay*", mysql_test_dir);
  435.   /* remove relay-log.info file */
  436.   removef("%s/relay-log.info", master_dir);
  438.   /* init script */
  439.   if (master_init_script[0] != 0)
  440.   {
  441. #ifdef __NETWARE__
  442.     /* TODO: use the scripts */
  443.     if (strinstr(master_init_script, "repair_part2-master.sh") != 0)
  444.     {
  445.       FILE *fp;
  447.       /* create an empty index file */
  448.       snprintf(temp, FN_REFLEN, "%s/test/t1.MYI", master_dir);
  449.       fp= fopen(temp, "wb+");
  451.       fputs("1", fp);
  453.       fclose(fp);
  454.     }
  455. #elif !defined(__WIN__)
  456.     run_init_script(master_init_script);
  457. #endif
  458.   }
  460.   /* redirection files */
  461.   snprintf(master_out, FN_REFLEN, "%s/var/run/master%u.out",
  462.            mysql_test_dir, restarts);
  463.   snprintf(master_err, FN_REFLEN, "%s/var/run/master%u.err",
  464.            mysql_test_dir, restarts);
  465. #ifndef __WIN__
  466.   snprintf(temp2,FN_REFLEN,"%s/var",mysql_test_dir);
  467.   mkdir(temp2,S_IRWXU);
  468.   snprintf(temp2,FN_REFLEN,"%s/var/log",mysql_test_dir);
  469.   mkdir(temp2,S_IRWXU);
  470. #else
  471.   snprintf(temp2,FN_REFLEN,"%s/var",mysql_test_dir);
  472.   mkdir(temp2);
  473.   snprintf(temp2,FN_REFLEN,"%s/var/log",mysql_test_dir);
  474.   mkdir(temp2);
  475. #endif
  476.   /* args */
  477.   init_args(&al);
  478.   add_arg(&al, "%s", mysqld_file);
  479.   add_arg(&al, "--no-defaults");
  480.   add_arg(&al, "--log-bin=%s/var/log/master-bin",mysql_test_dir);
  481.   add_arg(&al, "--server-id=1");
  482.   add_arg(&al, "--basedir=%s", base_dir);
  483.   add_arg(&al, "--port=%u", master_port);
  484. #if !defined(__NETWARE__) && !defined(__WIN__)
  485.   add_arg(&al, "--socket=%s",master_socket);
  486. #endif
  487.   add_arg(&al, "--local-infile");
  488.   add_arg(&al, "--core");
  489.   add_arg(&al, "--datadir=%s", master_dir);
  490. #ifndef __WIN__
  491.   add_arg(&al, "--pid-file=%s", master_pid);
  492. #endif
  493.   add_arg(&al, "--character-sets-dir=%s", char_dir);
  494.   add_arg(&al, "--tmpdir=%s", mysql_tmp_dir);
  495.   add_arg(&al, "--language=%s", lang_dir);
  496.  
  497.   add_arg(&al, "--rpl-recovery-rank=1");
  498.   add_arg(&al, "--init-rpl-role=master");
  499.   add_arg(&al, "--default-character-set=latin1");
  500. //  add_arg(&al, "--innodb_data_file_path=ibdata1:50M");
  501. #ifdef DEBUG /* only for debug builds */
  502.   add_arg(&al, "--debug");
  503. #endif
  505.   if (use_openssl)
  506.   {
  507.     add_arg(&al, "--ssl-ca=%s", ca_cert);
  508.     add_arg(&al, "--ssl-cert=%s", server_cert);
  509.     add_arg(&al, "--ssl-key=%s", server_key);
  510.   }
  512.   /* $MASTER_40_ARGS */
  513.   add_arg(&al, "--rpl-recovery-rank=1");
  514.   add_arg(&al, "--init-rpl-role=master");
  516.   /* $SMALL_SERVER */
  517.   add_arg(&al, "-O");
  518.   add_arg(&al, "key_buffer_size=1M");
  519.   add_arg(&al, "-O");
  520.   add_arg(&al, "sort_buffer=256K");
  521.   add_arg(&al, "-O");
  522.   add_arg(&al, "max_heap_table_size=1M");
  524.   /* $EXTRA_MASTER_OPT */
  525.   if (master_opt[0] != 0)
  526.   {
  527.     char *p;
  529.     p= (char *)str_tok(argument, master_opt, " t");
  530.     if (!strstr(master_opt, "timezone"))
  531.     {
  532.       while (p)
  533.       {
  534.         add_arg(&al, "%s", p);
  535.         p= (char *)str_tok(argument, NULL, " t");
  536.       }
  537.     }
  538.   }
  540.   /* remove the pid file if it exists */
  541. #ifndef __WIN__
  542.   remove(master_pid);
  543. #endif
  545.   /* spawn */
  546. #ifdef __WIN__
  547.   if ((err= spawn(mysqld_file, &al, FALSE, NULL,
  548.                   master_out, master_err, &master_pid)) == 0)
  549. #else
  550.   if ((err= spawn(mysqld_file, &al, FALSE, NULL,
  551.                   master_out, master_err, master_pid)) == 0)
  552. #endif
  553.   {
  554.     sleep_until_file_exists(master_pid);
  556.     if ((err= wait_for_server_start(bin_dir, mysqladmin_file, user, password,
  557.                                     master_port, mysql_tmp_dir)) == 0)
  558.     {
  559.       master_running= TRUE;
  560.     }
  561.     else
  562.     {
  563.       log_error("The master server went down early.");
  564.     }
  565.   }
  566.   else
  567.   {
  568.     log_error("Unable to start master server.");
  569.   }
  571.   /* free_args */
  572.   free_args(&al);
  573. }
  575. /******************************************************************************
  577.   start_slave()
  579.   Start the slave server.
  581. ******************************************************************************/
  583. void start_slave()
  584. {
  585.   arg_list_t al;
  586.   int err;
  587.   char slave_out[FN_REFLEN];
  588.   char slave_err[FN_REFLEN];
  590.   /* skip? */
  591.   if (skip_slave) return;
  593.   /* remove stale binary logs */
  594.   removef("%s/*-bin.*", slave_dir);
  596.   /* remove stale binary logs */
  597.   removef("%s/*.index", slave_dir);
  599.   /* remove master.info file */
  600.   removef("%s/master.info", slave_dir);
  602.   /* remove relay files */
  603.   removef("%s/var/log/*relay*", mysql_test_dir);
  605.   /* remove relay-log.info file */
  606.   removef("%s/relay-log.info", slave_dir);
  608.   /* init script */
  609.   if (slave_init_script[0] != 0)
  610.   {
  611. #ifdef __NETWARE__
  612.     /* TODO: use the scripts */
  613.     if (strinstr(slave_init_script, "rpl000016-slave.sh") != 0)
  614.     {
  615.       /* create empty master.info file */
  616.       snprintf(temp, FN_REFLEN, "%s/master.info", slave_dir);
  617.       close(open(temp, O_WRONLY | O_CREAT,S_IRWXU|S_IRWXG|S_IRWXO));
  618.     }
  619.     else if (strinstr(slave_init_script, "rpl000017-slave.sh") != 0)
  620.     {
  621.       FILE *fp;
  623.       /* create a master.info file */
  624.       snprintf(temp, FN_REFLEN, "%s/master.info", slave_dir);
  625.       fp= fopen(temp, "wb+");
  627.       fputs("master-bin.000001n", fp);
  628.       fputs("4n", fp);
  629.       fputs("127.0.0.1n", fp);
  630.       fputs("replicaten", fp);
  631.       fputs("aaaaaaaaaaaaaaabn", fp);
  632.       fputs("9306n", fp);
  633.       fputs("1n", fp);
  634.       fputs("0n", fp);
  636.       fclose(fp);
  637.     }
  638.     else if (strinstr(slave_init_script, "rpl_rotate_logs-slave.sh") != 0)
  639.     {
  640.       /* create empty master.info file */
  641.       snprintf(temp, FN_REFLEN, "%s/master.info", slave_dir);
  642.       close(open(temp, O_WRONLY | O_CREAT,S_IRWXU|S_IRWXG|S_IRWXO));
  643.     }
  644. #elif !defined(__WIN__)
  645.     run_init_script(slave_init_script);
  646. #endif
  647.   }
  649.   /* redirection files */
  650.   snprintf(slave_out, FN_REFLEN, "%s/var/run/slave%u.out",
  651.            mysql_test_dir, restarts);
  652.   snprintf(slave_err, FN_REFLEN, "%s/var/run/slave%u.err",
  653.            mysql_test_dir, restarts);
  655.   /* args */
  656.   init_args(&al);
  657.   add_arg(&al, "%s", mysqld_file);
  658.   add_arg(&al, "--no-defaults");
  659.   add_arg(&al, "--log-bin=slave-bin");
  660.   add_arg(&al, "--relay_log=slave-relay-bin");
  661.   add_arg(&al, "--basedir=%s", base_dir);
  662. #if !defined(__NETWARE__) && !defined(__WIN__)
  663.   add_arg(&al, "--socket=%s",slave_socket);
  664. #endif
  665.   add_arg(&al, "--port=%u", slave_port);
  666.   add_arg(&al, "--datadir=%s", slave_dir);
  667. #ifndef __WIN__
  668.   add_arg(&al, "--pid-file=%s", slave_pid);
  669. #endif
  670.   add_arg(&al, "--character-sets-dir=%s", char_dir);
  671.   add_arg(&al, "--core");
  672.   add_arg(&al, "--tmpdir=%s", mysql_tmp_dir);
  673.   add_arg(&al, "--language=%s", lang_dir);
  675.   add_arg(&al, "--exit-info=256");
  676.   add_arg(&al, "--log-slave-updates");
  677.   add_arg(&al, "--init-rpl-role=slave");
  678.   add_arg(&al, "--skip-innodb");
  679.   add_arg(&al, "--skip-slave-start");
  680.   add_arg(&al, "--slave-load-tmpdir=../../var/tmp");
  682.   add_arg(&al, "--report-user=%s", user);
  683.   add_arg(&al, "--report-host=127.0.0.1");
  684.   add_arg(&al, "--report-port=%u", slave_port);
  686.   add_arg(&al, "--master-retry-count=10");
  687.   add_arg(&al, "-O");
  688.   add_arg(&al, "slave_net_timeout=10");
  689.   add_arg(&al, "--log-slave-updates");
  690.   add_arg(&al, "--log=%s/var/log/slave.log", mysql_test_dir);
  691.   add_arg(&al, "--default-character-set=latin1");
  692.   add_arg(&al, "--skip-ndbcluster");
  693.   
  694. #ifdef DEBUG /* only for debug builds */
  695.   add_arg(&al, "--debug");
  696. #endif      
  697.            
  698.   if (use_openssl)
  699.   {
  700.     add_arg(&al, "--ssl-ca=%s", ca_cert);
  701.     add_arg(&al, "--ssl-cert=%s", server_cert);
  702.     add_arg(&al, "--ssl-key=%s", server_key);
  703.   }
  705.   /* slave master info */
  706.   if (slave_master_info[0] != 0)
  707.   {
  708.     char *p;
  710.     p= (char *)str_tok(argument, slave_master_info, " t");
  712.     while (p)
  713.     {
  714.       add_arg(&al, "%s", p);
  715.       p= (char *)str_tok(argument, NULL, " t");
  716.     }
  717.   }
  718.   else
  719.   {
  720.     add_arg(&al, "--master-user=%s", user);
  721.     add_arg(&al, "--master-password=%s", password);
  722.     add_arg(&al, "--master-host=127.0.0.1");
  723.     add_arg(&al, "--master-port=%u", master_port);
  724.     add_arg(&al, "--master-connect-retry=1");
  725.     add_arg(&al, "--server-id=2");
  726.     add_arg(&al, "--rpl-recovery-rank=2");
  727.   }
  729.   /* small server */
  730.   add_arg(&al, "-O");
  731.   add_arg(&al, "key_buffer_size=1M");
  732.   add_arg(&al, "-O");
  733.   add_arg(&al, "sort_buffer=256K");
  734.   add_arg(&al, "-O");
  735.   add_arg(&al, "max_heap_table_size=1M");
  738.   /* opt args */
  739.   if (slave_opt[0] != 0)
  740.   {
  741.     char *p;
  743.     p= (char *)str_tok(argument, slave_opt, " t");
  745.     while (p)
  746.     {
  747.       add_arg(&al, "%s", p);
  748.       p= (char *)str_tok(argument, NULL, " t");
  749.     } 
  750.   }
  752.   /* remove the pid file if it exists */
  753. #ifndef __WIN__
  754.   remove(slave_pid);
  755. #endif
  756.   /* spawn */
  757. #ifdef __WIN__
  758.   if ((err= spawn(mysqld_file, &al, FALSE, NULL,
  759.                   slave_out, slave_err, &slave_pid)) == 0)
  760. #else
  761.   if ((err= spawn(mysqld_file, &al, FALSE, NULL,
  762.                   slave_out, slave_err, slave_pid)) == 0)
  763. #endif
  764.   {
  765.     sleep_until_file_exists(slave_pid);
  767.     if ((err= wait_for_server_start(bin_dir, mysqladmin_file, user, password,
  768.                                     slave_port, mysql_tmp_dir)) == 0)
  769.     {
  770.       slave_running= TRUE;
  771.     }
  772.     else
  773.     {
  774.       log_error("The slave server went down early.");
  775.     }
  776.   }
  777.   else
  778.   {
  779.     log_error("Unable to start slave server.");
  780.   }
  782.   /* free args */
  783.   free_args(&al);
  784. }
  786. /******************************************************************************
  788.   mysql_start()
  790.   Start the mysql servers.
  792. ******************************************************************************/
  794. void mysql_start()
  795. {
  798.   printf("loading master...r");
  799.   start_master();
  801.   printf("loading slave...r");
  802.   start_slave();
  804.   /* activate the test screen */
  805. #ifdef __NETWARE__
  806.   ActivateScreen(getscreenhandle());
  807. #endif
  808. }
  810. /******************************************************************************
  812.   stop_slave()
  814.   Stop the slave server.
  816. ******************************************************************************/
  818. void stop_slave()
  819. {
  820.   int err;
  822.   /* running? */
  823.   if (!slave_running) return;
  825.   /* stop */
  826.   if ((err= stop_server(bin_dir, mysqladmin_file, user, password,
  827.                         slave_port, slave_pid, mysql_tmp_dir)) == 0)
  828.   {
  829.     slave_running= FALSE;
  830.   }
  831.   else
  832.   {
  833.     log_error("Unable to stop slave server.");
  834.   }
  835. }
  837. /******************************************************************************
  839.   stop_master()
  841.   Stop the master server.
  843. ******************************************************************************/
  845. void stop_master()
  846. {
  847.   int err;
  849.   /* running? */
  850.   if (!master_running) return;
  852.   if ((err= stop_server(bin_dir, mysqladmin_file, user, password,
  853.                         master_port, master_pid, mysql_tmp_dir)) == 0)
  854.   {
  855.     master_running= FALSE;
  856.   }
  857.   else
  858.   {
  859.     log_error("Unable to stop master server.");
  860.   }
  861. }
  863. /******************************************************************************
  865.   mysql_stop()
  867.   Stop the mysql servers.
  869. ******************************************************************************/
  871. void mysql_stop()
  872. {
  874.   stop_master();
  876.   stop_slave();
  878.   /* activate the test screen */
  879. #ifdef __NETWARE__
  880.   ActivateScreen(getscreenhandle());
  881. #endif
  882. }
  884. /******************************************************************************
  886.   mysql_restart()
  888.   Restart the mysql servers.
  890. ******************************************************************************/
  892. void mysql_restart()
  893. {
  894. /*  log_info("Restarting the MySQL server(s): %u", ++restarts); */
  896.   mysql_stop();
  898.   mlog(DASH);
  899.   sleep(1);
  901.   mysql_start();
  902. }
  904. /******************************************************************************
  906.   read_option()
  908.   Read the option file.
  910. ******************************************************************************/
  912. int read_option(char *opt_file, char *opt)
  913. {
  914.   int fd, err;
  915.   char *p;
  916.   char buf[FN_REFLEN];
  918.   /* copy current option */
  919.   strncpy(buf, opt, FN_REFLEN);
  921.   /* open options file */
  922.   fd= open(opt_file, O_RDONLY);
  923.   err= read(fd, opt, FN_REFLEN);
  924.   close(fd);
  926.   if (err > 0)
  927.   {
  928.     /* terminate string */
  929.     if ((p= strchr(opt, 'n')) != NULL)
  930.     {
  931.       *p= 0;
  933.       /* check for a 'r' */
  934.       if ((p= strchr(opt, 'r')) != NULL)
  935.       {
  936.         *p= 0;
  937.       }
  938.     }
  939.     else
  940.     {
  941.       opt[err]= 0;
  942.     }
  944.     /* check for $MYSQL_TEST_DIR */
  945.     if ((p= strstr(opt, "$MYSQL_TEST_DIR")) != NULL)
  946.     {
  947.       char temp[FN_REFLEN];
  949.       *p= 0;
  951.       strcpy(temp, p + strlen("$MYSQL_TEST_DIR"));
  952.       strcat(opt, mysql_test_dir);
  953.       strcat(opt, temp);
  954.     }
  955.     /* Check for double backslash and replace it with single bakslash */
  956.     if ((p= strstr(opt, "\\")) != NULL)
  957.     {
  958.       /* bmove is guranteed to work byte by byte */
  959.       bmove(p, p+1, strlen(p)+1);
  960.     }
  961.   }
  962.   else
  963.   {
  964.     /* clear option */
  965.     *opt= 0;
  966.   }
  968.   /* compare current option with previous */
  969.   return strcmp(opt, buf);
  970. }
  972. /******************************************************************************
  974.   run_test()
  976.   Run the given test case.
  978. ******************************************************************************/
  980. void run_test(char *test)
  981. {
  982.   char temp[FN_REFLEN];
  983.   const char *rstr;
  984.   int skip= FALSE, ignore=FALSE;
  985.   int restart= FALSE;
  986.   int flag= FALSE;
  987.   struct stat info;
  989.   /* skip tests in the skip list */
  990.   snprintf(temp, FN_REFLEN, " %s ", test);
  991.   skip= (strinstr(skip_test, temp) != 0);
  992.   if (skip == FALSE)
  993.     ignore= (strinstr(ignore_test, temp) != 0);
  995.   snprintf(master_init_script, FN_REFLEN, "%s/%s-master.sh", test_dir, test);
  996.   snprintf(slave_init_script, FN_REFLEN, "%s/%s-slave.sh", test_dir, test);
  997. #ifdef __WIN__
  998.   if (! stat(master_init_script, &info))
  999.       skip= TRUE;
  1000.   if (!stat(slave_init_script, &info))
  1001.       skip= TRUE;
  1002. #endif
  1003.   if (ignore)
  1004.   {
  1005.     /* show test */
  1006.     mlog("%-46s ", test);
  1008.     /* ignore */
  1009.     rstr= TEST_IGNORE;
  1010.     ++total_ignore;
  1011.   }
  1012.   else if (!skip)     /* skip test? */
  1013.   {
  1014.     char test_file[FN_REFLEN];
  1015.     char master_opt_file[FN_REFLEN];
  1016.     char slave_opt_file[FN_REFLEN];
  1017.     char slave_master_info_file[FN_REFLEN];
  1018.     char result_file[FN_REFLEN];
  1019.     char reject_file[FN_REFLEN];
  1020.     char out_file[FN_REFLEN];
  1021.     char err_file[FN_REFLEN];
  1022.     int err;
  1023.     arg_list_t al;
  1024.     /* skip slave? */
  1025.     flag= skip_slave;
  1026.     skip_slave= (strncmp(test, "rpl", 3) != 0);
  1027.     if (flag != skip_slave) restart= TRUE;
  1029.     /* create files */
  1030.     snprintf(master_opt_file, FN_REFLEN, "%s/%s-master.opt", test_dir, test);
  1031.     snprintf(slave_opt_file, FN_REFLEN, "%s/%s-slave.opt", test_dir, test);
  1032.     snprintf(slave_master_info_file, FN_REFLEN, "%s/%s.slave-mi",
  1033.              test_dir, test);
  1034.     snprintf(reject_file, FN_REFLEN, "%s/%s%s",
  1035.              result_dir, test, REJECT_SUFFIX);
  1036.     snprintf(out_file, FN_REFLEN, "%s/%s%s", result_dir, test, OUT_SUFFIX);
  1037.     snprintf(err_file, FN_REFLEN, "%s/%s%s", result_dir, test, ERR_SUFFIX);
  1039.     /* netware specific files */
  1040.     snprintf(test_file, FN_REFLEN, "%s/%s%s", test_dir, test, NW_TEST_SUFFIX);
  1041.     if (stat(test_file, &info))
  1042.     {
  1043.       snprintf(test_file, FN_REFLEN, "%s/%s%s", test_dir, test, TEST_SUFFIX);
  1044.       if (access(test_file,0))
  1045.       {
  1046.         printf("Invalid test name %s, %s file not foundn",test,test_file);
  1047.         return;
  1048.       }
  1049.     }
  1051.     snprintf(result_file, FN_REFLEN, "%s/%s%s",
  1052.              result_dir, test, NW_RESULT_SUFFIX);
  1053.     if (stat(result_file, &info))
  1054.     {
  1055.       snprintf(result_file, FN_REFLEN, "%s/%s%s",
  1056.                result_dir, test, RESULT_SUFFIX);
  1057.     }
  1059.     /* init scripts */
  1060.     if (stat(master_init_script, &info))
  1061.       master_init_script[0]= 0;
  1062.     else
  1063.       restart= TRUE;
  1065.     if (stat(slave_init_script, &info))
  1066.       slave_init_script[0]= 0;
  1067.     else
  1068.       restart= TRUE;
  1070.     /* read options */
  1071.     if (read_option(master_opt_file, master_opt)) restart= TRUE;
  1072.     if (read_option(slave_opt_file, slave_opt)) restart= TRUE;
  1073.     if (read_option(slave_master_info_file, slave_master_info)) restart= TRUE;
  1075.     /* cleanup previous run */
  1076.     remove(reject_file);
  1077.     remove(out_file);
  1078.     remove(err_file);
  1080.     /* start or restart? */
  1081.     if (!master_running) mysql_start();
  1082.       else if (restart) mysql_restart();
  1084.     /* show test */
  1085.     mlog("%-46s ", test);
  1087.     /* args */
  1088.     init_args(&al);
  1089.     add_arg(&al, "%s", mysqltest_file);
  1090.     add_arg(&al, "--no-defaults");
  1091.     add_arg(&al, "--port=%u", master_port);
  1092. #if !defined(__NETWARE__) && !defined(__WIN__)
  1093.     add_arg(&al, "--socket=%s", master_socket);
  1094.     add_arg(&al, "--tmpdir=%s", mysql_tmp_dir);
  1095. #endif
  1096.     add_arg(&al, "--database=%s", db);
  1097.     add_arg(&al, "--user=%s", user);
  1098.     add_arg(&al, "--password=%s", password);
  1099.     add_arg(&al, "--silent");
  1100.     add_arg(&al, "--basedir=%s/", mysql_test_dir);
  1101.     add_arg(&al, "--host=127.0.0.1");
  1102.     add_arg(&al, "--skip-safemalloc");
  1103.     add_arg(&al, "-v");
  1104.     add_arg(&al, "-R");
  1105.     add_arg(&al, "%s", result_file);
  1106.     
  1107.     
  1108.     if (use_openssl)
  1109.     {
  1110.       add_arg(&al, "--ssl-ca=%s", ca_cert);
  1111.       add_arg(&al, "--ssl-cert=%s", client_cert);
  1112.       add_arg(&al, "--ssl-key=%s", client_key);
  1113.     }
  1115.     /* spawn */
  1116.     err= spawn(mysqltest_file, &al, TRUE, test_file, out_file, err_file, NULL);
  1117.     /* free args */
  1118.     free_args(&al);
  1120.     remove_empty_file(out_file);
  1121.     remove_empty_file(err_file);
  1123.     if (err == 0)
  1124.     {
  1125.       /* pass */
  1126.       rstr= TEST_PASS;
  1127.       ++total_pass;
  1129.       /* increment total */
  1130.       ++total_test;
  1131.     }
  1132.     else if (err == 2)
  1133.     {
  1134.       /* skip */
  1135.       rstr= TEST_SKIP;
  1136.       ++total_skip;
  1137.     }
  1138.     else if (err == 1)
  1139.     {
  1140.       /* fail */
  1141.       rstr= TEST_FAIL;
  1142.       ++total_fail;
  1144.       /* increment total */
  1145.       ++total_test;
  1146.     }
  1147.     else
  1148.     {
  1149.       rstr= TEST_BAD;
  1150.     }
  1151.   }
  1152.   else /* early skips */
  1153.   {
  1154.     /* show test */
  1155.     mlog("%-46s ", test);
  1157.     /* skip */
  1158.     rstr= TEST_SKIP;
  1159.     ++total_skip;
  1160.   }
  1162.   /* result */
  1163.   mlog("%-14sn", rstr);
  1164. }
  1166. /******************************************************************************
  1168.   vlog()
  1170.   Log the message.
  1172. ******************************************************************************/
  1174. void vlog(const char *format, va_list ap)
  1175. {
  1176.   vfprintf(stdout, format, ap);
  1177.   fflush(stdout);
  1179.   if (log_fd)
  1180.   {
  1181.     vfprintf(log_fd, format, ap);
  1182.     fflush(log_fd);
  1183.   }
  1184. }
  1186. /******************************************************************************
  1188.   log()
  1190.   Log the message.
  1192. ******************************************************************************/
  1194. void mlog(const char *format, ...)
  1195. {
  1196.   va_list ap;
  1198.   va_start(ap, format);
  1200.   vlog(format, ap);
  1202.   va_end(ap);
  1203. }
  1205. /******************************************************************************
  1207.   log_info()
  1209.   Log the given information.
  1211. ******************************************************************************/
  1213. void log_info(const char *format, ...)
  1214. {
  1215.   va_list ap;
  1217.   va_start(ap, format);
  1219.   mlog("-- INFO : ");
  1220.   vlog(format, ap);
  1221.   mlog("n");
  1223.   va_end(ap);
  1224. }
  1226. /******************************************************************************
  1228.   log_error()
  1230.   Log the given error.
  1232. ******************************************************************************/
  1234. void log_error(const char *format, ...)
  1235. {
  1236.   va_list ap;
  1238.   va_start(ap, format);
  1240.   mlog("-- ERROR: ");
  1241.   vlog(format, ap);
  1242.   mlog("n");
  1244.   va_end(ap);
  1245. }
  1247. /******************************************************************************
  1249.   log_errno()
  1251.   Log the given error and errno.
  1253. ******************************************************************************/
  1255. void log_errno(const char *format, ...)
  1256. {
  1257.   va_list ap;
  1259.   va_start(ap, format);
  1261.   mlog("-- ERROR: (%003u) ", errno);
  1262.   vlog(format, ap);
  1263.   mlog("n");
  1265.   va_end(ap);
  1266. }
  1268. /******************************************************************************
  1270.   die()
  1272.   Exit the application.
  1274. ******************************************************************************/
  1276. void die(const char *msg)
  1277. {
  1278.   log_error(msg);
  1279. #ifdef __NETWARE__
  1280.   pressanykey();
  1281. #endif
  1282.   exit(-1);
  1283. }
  1285. /******************************************************************************
  1287.   setup()
  1289.   Setup the mysql test enviornment.
  1291. ******************************************************************************/
  1293. void setup(char *file __attribute__((unused)))
  1294. {
  1295.   char temp[FN_REFLEN];
  1296. #if defined(__WIN__) || defined(__NETWARE__)  
  1297.   char file_path[FN_REFLEN*2];
  1298. #endif  
  1299.   char *p;
  1300.   int position;
  1302.   /* set the timezone for the timestamp test */
  1303. #ifdef __WIN__
  1304.   _putenv( "TZ=GMT-3" );
  1305. #else
  1306.   putenv((char *)"TZ=GMT-3");
  1307. #endif
  1308.   /* find base dir */
  1309. #ifdef __NETWARE__
  1310.   strcpy(temp, strlwr(file));
  1311.   while ((p= strchr(temp, '\')) != NULL) *p= '/';
  1312. #else
  1313.   getcwd(temp, FN_REFLEN);
  1314.   position= strlen(temp);
  1315.   temp[position]= '/';
  1316.   temp[position+1]= 0;
  1317. #ifdef __WIN__
  1318.   while ((p= strchr(temp, '\')) != NULL) *p= '/';
  1319. #endif
  1320. #endif
  1322.   if ((position= strinstr(temp, "/mysql-test/")) != 0)
  1323.   {
  1324.     p= temp + position - 1;
  1325.     *p= 0;
  1326.     strcpy(base_dir, temp);
  1327.   }
  1329.   log_info("Currect directory: %s",base_dir);
  1331. #ifdef __NETWARE__
  1332.   /* setup paths */
  1333.   snprintf(bin_dir, FN_REFLEN, "%s/bin", base_dir);
  1334.   snprintf(mysql_test_dir, FN_REFLEN, "%s/mysql-test", base_dir);
  1335.   snprintf(test_dir, FN_REFLEN, "%s/t", mysql_test_dir);
  1336.   snprintf(mysql_tmp_dir, FN_REFLEN, "%s/var/tmp", mysql_test_dir);
  1337.   snprintf(result_dir, FN_REFLEN, "%s/r", mysql_test_dir);
  1338.   snprintf(master_dir, FN_REFLEN, "%s/var/master-data", mysql_test_dir);
  1339.   snprintf(slave_dir, FN_REFLEN, "%s/var/slave-data", mysql_test_dir);
  1340.   snprintf(lang_dir, FN_REFLEN, "%s/share/english", base_dir);
  1341.   snprintf(char_dir, FN_REFLEN, "%s/share/charsets", base_dir);
  1343. #ifdef HAVE_OPENSSL
  1344.   use_openssl= TRUE;
  1345. #endif /* HAVE_OPENSSL */
  1347.   /* OpenSSL paths */
  1348.   snprintf(ca_cert, FN_REFLEN, "%s/SSL/cacert.pem", base_dir);
  1349.   snprintf(server_cert, FN_REFLEN, "%s/SSL/server-cert.pem", base_dir);
  1350.   snprintf(server_key, FN_REFLEN, "%s/SSL/server-key.pem", base_dir);
  1351.   snprintf(client_cert, FN_REFLEN, "%s/SSL/client-cert.pem", base_dir);
  1352.   snprintf(client_key, FN_REFLEN, "%s/SSL/client-key.pem", base_dir);
  1354.   /* setup files */
  1355.   snprintf(mysqld_file, FN_REFLEN, "%s/mysqld", bin_dir);
  1356.   snprintf(mysqltest_file, FN_REFLEN, "%s/mysqltest", bin_dir);
  1357.   snprintf(mysqladmin_file, FN_REFLEN, "%s/mysqladmin", bin_dir);
  1358.   snprintf(master_pid, FN_REFLEN, "%s/var/run/master.pid", mysql_test_dir);
  1359.   snprintf(slave_pid, FN_REFLEN, "%s/var/run/slave.pid", mysql_test_dir);
  1360. #elif __WIN__
  1361.   /* setup paths */
  1362. #ifdef _DEBUG
  1363.   snprintf(bin_dir, FN_REFLEN, "%s/client_debug", base_dir);
  1364. #else
  1365.   snprintf(bin_dir, FN_REFLEN, "%s/client_release", base_dir);
  1366. #endif
  1367.   snprintf(mysql_test_dir, FN_REFLEN, "%s/mysql-test", base_dir);
  1368.   snprintf(test_dir, FN_REFLEN, "%s/t", mysql_test_dir);
  1369.   snprintf(mysql_tmp_dir, FN_REFLEN, "%s/var/tmp", mysql_test_dir);
  1370.   snprintf(result_dir, FN_REFLEN, "%s/r", mysql_test_dir);
  1371.   snprintf(master_dir, FN_REFLEN, "%s/var/master-data", mysql_test_dir);
  1372.   snprintf(slave_dir, FN_REFLEN, "%s/var/slave-data", mysql_test_dir);
  1373.   snprintf(lang_dir, FN_REFLEN, "%s/share/english", base_dir);
  1374.   snprintf(char_dir, FN_REFLEN, "%s/share/charsets", base_dir);
  1376. #ifdef HAVE_OPENSSL
  1377.   use_openssl= TRUE;
  1378. #endif /* HAVE_OPENSSL */
  1380.   /* OpenSSL paths */
  1381.   snprintf(ca_cert, FN_REFLEN, "%s/SSL/cacert.pem", base_dir);
  1382.   snprintf(server_cert, FN_REFLEN, "%s/SSL/server-cert.pem", base_dir);
  1383.   snprintf(server_key, FN_REFLEN, "%s/SSL/server-key.pem", base_dir);
  1384.   snprintf(client_cert, FN_REFLEN, "%s/SSL/client-cert.pem", base_dir);
  1385.   snprintf(client_key, FN_REFLEN, "%s/SSL/client-key.pem", base_dir);
  1387.   /* setup files */
  1388. #ifdef _DEBUG 
  1389.   snprintf(mysqld_file, FN_REFLEN, "%s/mysqld-debug.exe", bin_dir);
  1390. #else
  1391.   snprintf(mysqld_file, FN_REFLEN, "%s/mysqld.exe", bin_dir);
  1392. #endif
  1393.   snprintf(mysqltest_file, FN_REFLEN, "%s/mysqltest.exe", bin_dir);
  1394.   snprintf(mysqladmin_file, FN_REFLEN, "%s/mysqladmin.exe", bin_dir);
  1395. #else
  1396.   /* setup paths */
  1397.   snprintf(bin_dir, FN_REFLEN, "%s/client", base_dir);
  1398.   snprintf(mysql_test_dir, FN_REFLEN, "%s/mysql-test", base_dir);
  1399.   snprintf(test_dir, FN_REFLEN, "%s/t", mysql_test_dir);
  1400.   snprintf(mysql_tmp_dir, FN_REFLEN, "%s/var/tmp", mysql_test_dir);
  1401.   snprintf(result_dir, FN_REFLEN, "%s/r", mysql_test_dir);
  1402.   snprintf(master_dir, FN_REFLEN, "%s/var/master-data", mysql_test_dir);
  1403.   snprintf(slave_dir, FN_REFLEN, "%s/var/slave-data", mysql_test_dir);
  1404.   snprintf(slave1_dir, FN_REFLEN, "%s/var/slave1-data", mysql_test_dir);
  1405.   snprintf(slave2_dir, FN_REFLEN, "%s/var/slave2-data", mysql_test_dir);
  1406.   snprintf(lang_dir, FN_REFLEN, "%s/sql/share/english", base_dir);
  1407.   snprintf(char_dir, FN_REFLEN, "%s/sql/share/charsets", base_dir);
  1409. #ifdef HAVE_OPENSSL
  1410.   use_openssl= TRUE;
  1411. #endif /* HAVE_OPENSSL */
  1413.   /* OpenSSL paths */
  1414.   snprintf(ca_cert, FN_REFLEN, "%s/SSL/cacert.pem", base_dir);
  1415.   snprintf(server_cert, FN_REFLEN, "%s/SSL/server-cert.pem", base_dir);
  1416.   snprintf(server_key, FN_REFLEN, "%s/SSL/server-key.pem", base_dir);
  1417.   snprintf(client_cert, FN_REFLEN, "%s/SSL/client-cert.pem", base_dir);
  1418.   snprintf(client_key, FN_REFLEN, "%s/SSL/client-key.pem", base_dir);
  1420.   /* setup files */
  1421.   snprintf(mysqld_file, FN_REFLEN, "%s/sql/mysqld", base_dir);
  1422.   snprintf(mysqltest_file, FN_REFLEN, "%s/mysqltest", bin_dir);
  1423.   snprintf(mysqladmin_file, FN_REFLEN, "%s/mysqladmin", bin_dir);
  1424.   snprintf(master_pid, FN_REFLEN, "%s/var/run/master.pid", mysql_test_dir);
  1425.   snprintf(slave_pid, FN_REFLEN, "%s/var/run/slave.pid", mysql_test_dir);
  1427.   snprintf(master_socket,FN_REFLEN, "%s/var/tmp/master.sock", mysql_test_dir);
  1428.   snprintf(slave_socket,FN_REFLEN, "%s/var/tmp/slave.sock", mysql_test_dir);
  1430. #endif
  1431.   /* create log file */
  1432.   snprintf(temp, FN_REFLEN, "%s/mysql-test-run.log", mysql_test_dir);
  1433.   if ((log_fd= fopen(temp, "w+")) == NULL)
  1434.   {
  1435.     log_errno("Unable to create log file.");
  1436.   }
  1438.   /* prepare skip test list */
  1439.   while ((p= strchr(skip_test, ',')) != NULL) *p= ' ';
  1440.   strcpy(temp, strlwr(skip_test));
  1441.   snprintf(skip_test, FN_REFLEN, " %s ", temp);
  1443.   /* environment */
  1444. #ifdef __NETWARE__
  1445.   setenv("MYSQL_TEST_DIR", mysql_test_dir, 1);
  1446.   snprintf(file_path, FN_REFLEN*2,
  1447.            "%s/client/mysqldump --no-defaults -u root --port=%u",
  1448.            bin_dir, master_port);
  1449.   setenv("MYSQL_DUMP", file_path, 1);
  1450.   snprintf(file_path, FN_REFLEN*2,
  1451.            "%s/client/mysqlbinlog --no-defaults --local-load=%s",
  1452.            bin_dir, mysql_tmp_dir);
  1453.   setenv("MYSQL_BINLOG", file_path, 1);
  1454. #elif __WIN__
  1455.   snprintf(file_path,FN_REFLEN,"MYSQL_TEST_DIR=%s",mysql_test_dir);
  1456.   _putenv(file_path);
  1457.   snprintf(file_path, FN_REFLEN*2,
  1458.            "MYSQL_DUMP=%s/mysqldump.exe --no-defaults -uroot --port=%u",
  1459.            bin_dir, master_port);
  1460.   _putenv(file_path);
  1461.   snprintf(file_path, FN_REFLEN*2,
  1462.           "MYSQL_BINLOG=%s/mysqlbinlog.exe --no-defaults --local-load=%s",
  1463.            bin_dir, mysql_tmp_dir);
  1464.   _putenv(file_path);
  1465.     
  1466.   snprintf(file_path, FN_REFLEN*2,
  1467.           "TESTS_BINDIR=%s/tests", base_dir);
  1468.   _putenv(file_path);
  1470.   snprintf(file_path, FN_REFLEN*2,
  1471.            "CHARSETSDIR=%s/sql/share/charsets", base_dir);
  1472.   _putenv(file_path);
  1474.   snprintf(file_path, FN_REFLEN*2,
  1475.            "MYSQL=%s/mysql --port=%u ", 
  1476.            bin_dir, master_port);
  1477.   _putenv(file_path);
  1478.     
  1479.   snprintf(file_path, FN_REFLEN*2,
  1480.            "MYSQL_FIX_SYSTEM_TABLES=%s/scripts/mysql_fix_privilege_tables --no-defaults "
  1481.            "--host=localhost --port=%u "
  1482.            "--basedir=%s --bindir=%s --verbose",
  1483.            base_dir,master_port, base_dir, bin_dir);
  1484.   _putenv(file_path);
  1485.      
  1486.   snprintf(file_path, FN_REFLEN*2,
  1487.            "NDB_TOOLS_DIR=%s/ndb/tools", base_dir);
  1488.   _putenv(file_path);
  1489.     
  1490.   snprintf(file_path, FN_REFLEN*2,
  1491.            "CLIENT_BINDIR=%s", bin_dir);
  1492.   _putenv(file_path);
  1494.   snprintf(file_path, FN_REFLEN*2,
  1495.              "MYSQL_CLIENT_TEST=%s/tests/mysql_client_test --no-defaults --testcase "
  1496.      "--user=root --port=%u --silent", 
  1497.      base_dir, master_port);
  1498.   _putenv(file_path);
  1500. #else
  1501.   {
  1502.     static char env_MYSQL_TEST_DIR[FN_REFLEN*2];
  1503.     static char env_MYSQL_DUMP[FN_REFLEN*2];
  1504.     static char env_MYSQL_BINLOG[FN_REFLEN*2];
  1505.     static char env_MASTER_MYSOCK[FN_REFLEN*2];
  1506.     static char env_TESTS_BINDIR[FN_REFLEN*2];
  1507.     static char env_CHARSETSDIR[FN_REFLEN*2];
  1508.     static char env_MYSQL[FN_REFLEN*2];
  1509.     static char env_MYSQL_FIX_SYSTEM_TABLES[FN_REFLEN*2];
  1510.     static char env_NDB_TOOLS_DIR[FN_REFLEN*2];
  1511.     static char env_CLIENT_BINDIR[FN_REFLEN*2];
  1512.     static char env_MYSQL_CLIENT_TEST[FN_REFLEN*2];
  1513.     
  1514.     snprintf(env_MYSQL_TEST_DIR,FN_REFLEN*2,
  1515.              "MYSQL_TEST_DIR=%s",mysql_test_dir);
  1516.     putenv(env_MYSQL_TEST_DIR);
  1517.     
  1518.     snprintf(env_MYSQL_DUMP, FN_REFLEN*2,"MYSQL_DUMP=%s/mysqldump --no-defaults "
  1519.              "-uroot --port=%u --socket=%s ", 
  1520.              bin_dir, master_port, master_socket);    
  1521.     putenv(env_MYSQL_DUMP);
  1522.     
  1523.     snprintf(env_MYSQL_BINLOG, FN_REFLEN*2,
  1524.              "MYSQL_BINLOG=%s/mysqlbinlog --no-defaults --local-load=%s -uroot ",
  1525.              bin_dir, mysql_tmp_dir);
  1526.     putenv(env_MYSQL_BINLOG);
  1527.     
  1528.     snprintf(env_MASTER_MYSOCK, FN_REFLEN*2,
  1529.              "MASTER_MYSOCK=%s", master_socket);
  1530.     putenv(env_MASTER_MYSOCK);
  1532.     snprintf(env_TESTS_BINDIR, FN_REFLEN*2,
  1533.              "TESTS_BINDIR=%s/tests", base_dir);
  1534.     putenv(env_TESTS_BINDIR);
  1536.     snprintf(env_CHARSETSDIR, FN_REFLEN*2,
  1537.              "CHARSETSDIR=%s/sql/share/charsets", base_dir);
  1538.     putenv(env_CHARSETSDIR);
  1540.     snprintf(env_MYSQL, FN_REFLEN*2,
  1541.              "MYSQL=%s/mysql --port=%u --socket=%s -uroot ", 
  1542.      bin_dir, master_port, master_socket);
  1543.     putenv(env_MYSQL);
  1544.     
  1545.     snprintf(env_MYSQL_FIX_SYSTEM_TABLES, FN_REFLEN*2,
  1546.              "MYSQL_FIX_SYSTEM_TABLES=%s/scripts/mysql_fix_privilege_tables --no-defaults "
  1547.      "--host=localhost --port=%u --socket=%s "
  1548.      "--basedir=%s --bindir=%s --verbose -uroot ",
  1549.      base_dir,master_port, master_socket, base_dir, bin_dir);
  1550.     putenv(env_MYSQL_FIX_SYSTEM_TABLES);
  1551.      
  1552.     snprintf(env_NDB_TOOLS_DIR, FN_REFLEN*2,
  1553.              "NDB_TOOLS_DIR=%s/ndb/tools", base_dir);
  1554.     putenv(env_NDB_TOOLS_DIR);
  1555.     
  1556.     snprintf(env_CLIENT_BINDIR, FN_REFLEN*2,
  1557.              "CLIENT_BINDIR=%s", bin_dir);
  1558.     putenv(env_CLIENT_BINDIR);
  1560.     snprintf(env_MYSQL_CLIENT_TEST, FN_REFLEN*2,
  1561.              "MYSQL_CLIENT_TEST=%s/tests/mysql_client_test --no-defaults --testcase "
  1562.      "--user=root --socket=%s --port=%u --silent", 
  1563.      base_dir, master_socket, master_port);
  1564.     putenv(env_MYSQL_CLIENT_TEST);
  1565.     
  1566.   }
  1567.   
  1568. #endif
  1570. #ifndef __WIN__
  1571.   putenv((char *)"MASTER_MYPORT=9306");
  1572.   putenv((char *)"SLAVE_MYPORT=9307");
  1573.   putenv((char *)"MYSQL_TCP_PORT=3306");
  1575. #else
  1576.   _putenv("MASTER_MYPORT=9306");
  1577.   _putenv("SLAVE_MYPORT=9307");
  1578.   _putenv("MYSQL_TCP_PORT=3306");
  1579. #endif
  1581. }
  1583. /*
  1584.   Compare names of testes for right order
  1585. */
  1586. int compare( const void *arg1, const void *arg2 )
  1587. {
  1588.   return sting_compare_func( * ( char** ) arg1, * ( char** ) arg2 );
  1589. }
  1593. /******************************************************************************
  1595.   main()
  1597. ******************************************************************************/
  1599. int main(int argc, char **argv)
  1600. {
  1601.   int is_ignore_list= 0;
  1602.   char **names= 0;
  1603.   char **testes= 0;
  1604.   int name_index;
  1605.   int index;
  1606.   char var_dir[FN_REFLEN];
  1607.   /* setup */
  1608.   setup(argv[0]);
  1609.   
  1610.   /* delete all file in var */
  1611.   snprintf(var_dir,FN_REFLEN,"%s/var",mysql_test_dir);
  1612.   del_tree(var_dir);
  1614.   /*
  1615.     The --ignore option is comma saperated list of test cases to skip and
  1616.     should be very first command line option to the test suite.
  1618.     The usage is now:
  1619.     mysql_test_run --ignore=test1,test2 test3 test4
  1620.     where test1 and test2 are test cases to ignore
  1621.     and test3 and test4 are test cases to run.
  1622.   */
  1623.   if (argc >= 2 && !strnicmp(argv[1], "--ignore=", sizeof("--ignore=")-1))
  1624.   {
  1625.     char *temp, *token;
  1626.     temp= strdup(strchr(argv[1],'=') + 1);
  1627.     for (token=str_tok(argument, temp, ","); token != NULL; 
  1628.          token=str_tok(argument, NULL, ","))
  1629.     {
  1630.       if (strlen(ignore_test) + strlen(token) + 2 <= FN_REFLEN-1)
  1631.         sprintf(ignore_test+strlen(ignore_test), " %s ", token);
  1632.       else
  1633.       {
  1634.         free(temp);
  1635.         die("ignore list too long.");
  1636.       }
  1637.     }
  1638.     free(temp);
  1639.     is_ignore_list= 1;
  1640.   }
  1641.   /* header */
  1642. #ifndef __WIN__
  1643.   mlog("MySQL Server %s, for %s (%s)nn", VERSION, SYSTEM_TYPE, MACHINE_TYPE);
  1644. #else
  1645.   mlog("MySQL Server ---, for %s (%s)nn", SYSTEM_TYPE, MACHINE_TYPE);
  1646. #endif
  1648.   mlog("Initializing Tests...n");
  1650.   /* install test databases */
  1651.   mysql_install_db();
  1652.   
  1653.   mlog("Starting Tests...n");
  1655.   mlog("n");
  1656.   mlog(HEADER);
  1657.   mlog(DASH);
  1659.   if ( argc > 1 + is_ignore_list )
  1660.   {
  1661.     int i;
  1663.     /* single test */
  1664.     single_test= TRUE;
  1666.     for (i= 1 + is_ignore_list; i < argc; i++)
  1667.     {
  1668.       /* run given test */
  1669.       run_test(argv[i]);
  1670.     }
  1671.   }
  1672.   else
  1673.   {
  1674.     /* run all tests */
  1675.     testes= malloc(MAX_COUNT_TESTES*sizeof(void*));
  1676.     if (!testes)
  1677.       die("can not allcate memory for sorting");
  1678.     names= testes;
  1679.     name_index= 0;
  1680. #ifndef __WIN__
  1681.     struct dirent *entry;
  1682.     DIR *parent;
  1683.     char test[FN_LEN];
  1684.     int position;
  1686.     /* FIXME are we sure the list is sorted if using readdir()? */
  1687.     if ((parent= opendir(test_dir)) == NULL)    /* Not thread safe */
  1688.       die("Unable to open tests directory.");
  1689.     else
  1690.     {
  1691.       while ((entry= readdir(parent)) != NULL)  /* Not thread safe */
  1692.       {
  1693.         strcpy(test, strlwr(entry->d_name));
  1694.         /* find the test suffix */
  1695.         if ((position= strinstr(test, TEST_SUFFIX)) != 0)
  1696.         {
  1697.   if (name_index < MAX_COUNT_TESTES)
  1698.   {
  1699.             /* null terminate at the suffix */
  1700.             *(test + position - 1)= '';
  1701.             /* insert test */
  1702.             *names= malloc(FN_REFLEN);
  1703.             strcpy(*names,test);
  1704.             names++;
  1705.             name_index++;
  1706.           }
  1707.   else
  1708.     die("can not sort files, array is overloaded");
  1709.         }
  1710.       }
  1711.       closedir(parent);
  1712.     }
  1713. #else
  1714.     {
  1715.       struct _finddata_t dir;
  1716.       int* handle;
  1717.       char test[FN_LEN];
  1718.       char mask[FN_REFLEN];
  1719.       int position;
  1721.       /* single test */
  1722.       single_test= FALSE;
  1724.       snprintf(mask,FN_REFLEN,"%s/*.test",test_dir);
  1726.       if ((handle=_findfirst(mask,&dir)) == -1L)
  1727.       {
  1728.         die("Unable to open tests directory.");
  1729.       }
  1732.       do
  1733.       {
  1734.         if (!(dir.attrib & _A_SUBDIR))
  1735.         {
  1736.           strcpy(test, strlwr(dir.name));
  1738.           /* find the test suffix */
  1739.           if ((position= strinstr(test, TEST_SUFFIX)) != 0)
  1740.           {
  1741.             if (name_index < MAX_COUNT_TESTES)
  1742.     {
  1743.               /* null terminate at the suffix */
  1744.               *(test + position - 1)= '';
  1745.               /* insert test */
  1746.               *names= malloc(FN_REFLEN);
  1747.               strcpy(*names,test);
  1748.               names++;
  1749.               name_index++;
  1750.     }
  1751.     else
  1752.       die("can not sort files, array is overloaded");
  1753.           }
  1754.         }
  1755.       }while (_findnext(handle,&dir) == 0);
  1757.       _findclose(handle);
  1758.     }
  1759. #endif
  1760.     qsort( (void *)testes, name_index, sizeof( char * ), compare );
  1762.     for (index= 0; index < name_index; index++)
  1763.     {
  1764.       run_test(testes[index]);
  1765.       free(testes[index]);
  1766.     }
  1768.     free(testes);
  1769.   }
  1771.   /* stop server */
  1772.   mysql_stop();
  1774.   mlog(DASH);
  1775.   mlog("n");
  1777.   mlog("Ending Tests...n");
  1779.   /* report stats */
  1780.   report_stats();
  1782.   /* close log */
  1783.   if (log_fd) fclose(log_fd);
  1785.   /* keep results up */
  1786. #ifdef __NETWARE__
  1787.   pressanykey();
  1788. #endif
  1789.   return 0;
  1790. }
  1793. /*
  1794.  Synopsis:
  1795.   This function breaks the string into a sequence of tokens. The difference
  1796.   between this function and strtok is that it respects the quoted string i.e.
  1797.   it skips  any delimiter character within the quoted part of the string.
  1798.   It return tokens by eliminating quote character. It modifies the input string
  1799.   passed. It will work with whitespace delimeter but may not work properly with
  1800.   other delimeter. If the delimeter will contain any quote character, then
  1801.   function will not tokenize and will return null string.
  1802.   e.g. if input string is
  1803.      --init-slave="set global max_connections=500" --skip-external-locking
  1804.   then the output will two string i.e.
  1805.      --init-slave=set global max_connections=500
  1806.      --skip-external-locking
  1808. Arguments:
  1809.   string:  input string
  1810.   delim:   set of delimiter character
  1811. Output:
  1812.   return the null terminated token of NULL.
  1813. */
  1814. char *str_tok(char* dest, char *string, const char *delim)
  1815. {
  1816.   char *token;            
  1817.   char *ptr_end_token= NULL;
  1818.   char *ptr_quote= NULL;
  1819.   char *ptr_token= NULL;
  1820.   int count_quotes= 0;
  1822.   *dest = '';
  1823.   if (strchr(delim,''') || strchr(delim,'"'))
  1824.     return NULL;
  1826.   token= (char*)strtok(string, delim);
  1827.   if (token) 
  1828.   {
  1829.     /* double quote is found */
  1830.     if (strchr(token,'"'))
  1831.     {
  1832.       do
  1833.       {
  1834.         if (count_quotes & 1)
  1835.         {
  1836.   if (*dest == '')
  1837.             sprintf(dest,"%s", ptr_token);
  1838.   else
  1839.             sprintf(dest,"%s %s", dest, ptr_token);
  1840.           ptr_token= (char*)strtok(NULL, delim);
  1841.           if (!ptr_token)
  1842.             break;
  1843.         }
  1844.         else
  1845.         {
  1846.           ptr_token= token;
  1847.         }
  1848.         if (ptr_quote = strchr(ptr_token,'"'))
  1849.         {
  1850.           ptr_end_token= ptr_token + strlen(ptr_token);
  1851.           do
  1852.           {
  1853. #ifndef __WIN__
  1854.             bmove(ptr_quote, ptr_quote+1, ptr_end_token - ptr_quote);
  1855. #endif
  1856.             count_quotes++;
  1857.           } while (ptr_quote != NULL && (ptr_quote = strchr(ptr_quote+1,'"')));
  1858.         }
  1859.       /* there are unpair quotes we have to search next quote*/
  1860.       } while (count_quotes & 1);
  1861.       if (ptr_token != NULL)
  1862.       {
  1863.         if (*dest == '')
  1864.           sprintf(dest,"%s", ptr_token);
  1865. else
  1866.           sprintf(dest,"%s %s",dest,ptr_token);
  1867.       }
  1868.     }
  1869.     else
  1870.     {
  1871.       sprintf(dest,"%s",token);
  1872.     }
  1873.   }
  1874.   return token ? dest : NULL;
  1875. }
  1877. #ifndef __WIN__
  1878. /*
  1879.  Synopsis:
  1880.   This function run scripts files on Linux and Netware
  1882. Arguments:
  1883.   script_name:  name of script file
  1885. Output:
  1886.   nothing
  1887. */
  1889. void run_init_script(const char *script_name)
  1890. {
  1891.   arg_list_t al;
  1892.   int err;
  1894.   /* args */
  1895.   init_args(&al);
  1896.   add_arg(&al, sh_file);
  1897.   add_arg(&al, script_name);
  1899.   /* spawn */
  1900.   if ((err= spawn(sh_file, &al, TRUE, NULL, NULL, NULL, NULL)) != 0)
  1901.   {
  1902.     die("Unable to run script.");
  1903.   }
  1905.   /* free args */
  1906.   free_args(&al);
  1907. }
  1908. #endif