run-test.hpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:2k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2003 MySQL AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. #ifndef atrt_config_hpp
  14. #define atrt_config_hpp
  15. #include <getarg.h>
  16. #include <Vector.hpp>
  17. #include <BaseString.hpp>
  18. #include <Logger.hpp>
  19. #include <mgmapi.h>
  20. #include <CpcClient.hpp>
  21. #undef MYSQL_CLIENT
  22. enum ErrorCodes {
  23.   ERR_OK = 0,
  24.   ERR_NDB_FAILED = 101,
  25.   ERR_SERVERS_FAILED = 102,
  26.   ERR_MAX_TIME_ELAPSED = 103
  27. };
  28. struct atrt_host {
  29.   size_t m_index;
  30.   BaseString m_user;
  31.   BaseString m_base_dir;
  32.   BaseString m_hostname;
  33.   SimpleCpcClient * m_cpcd;
  34. };
  35. struct atrt_process {
  36.   size_t m_index;
  37.   BaseString m_hostname;
  38.   struct atrt_host * m_host;
  39.   enum Type {
  40.     ALL = 255,
  41.     NDB_DB = 1,
  42.     NDB_API = 2,
  43.     NDB_MGM = 4,
  44.     NDB_REP = 8,
  45.     MYSQL_SERVER = 16,
  46.     MYSQL_CLIENT = 32
  47.   } m_type;
  48.   SimpleCpcClient::Process m_proc;
  49.   short m_ndb_mgm_port;
  50.   NdbMgmHandle m_ndb_mgm_handle; // if type == ndb_mgm
  51. };
  52. struct atrt_config {
  53.   BaseString m_key;
  54.   Vector<atrt_host> m_hosts;
  55.   Vector<atrt_process> m_processes;
  56. };
  57. struct atrt_testcase {
  58.   bool m_report;
  59.   bool m_run_all;
  60.   time_t m_max_time;
  61.   BaseString m_command;
  62.   BaseString m_args;
  63. };
  64. extern Logger g_logger;
  65. bool parse_args(int argc, const char** argv);
  66. bool setup_config(atrt_config&);
  67. bool connect_hosts(atrt_config&);
  68. bool connect_ndb_mgm(atrt_config&);
  69. bool wait_ndb(atrt_config&, int ndb_mgm_node_status);
  70. bool start_processes(atrt_config&, int);
  71. bool stop_processes(atrt_config&, int);
  72. bool update_status(atrt_config&, int);
  73. int is_running(atrt_config&, int);
  74. bool gather_result(atrt_config&, int * result);
  75. bool read_test_case(FILE *, atrt_testcase&, int& line);
  76. bool setup_test_case(atrt_config&, const atrt_testcase&);
  77. bool setup_hosts(atrt_config&);
  78. #endif