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

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

MySQL数据库

开发平台：

Visual C++

keso.c：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  18. #include <ndb_global.h>
  20. #include <mgmapi.h>
  22. #ifdef VM_TRACE
  23. #include <mgmapi_debug.h>
  24. #endif
  26. #include <NdbOut.hpp>
  28. static int testConnect(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  29. static int testDisconnect(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  31. static int testStatus(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  32. static int testGetConfig(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  33. #ifdef VM_TRACE
  34. static int testLogSignals(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  35. static int testStartSignalLog(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  36. static int testStopSignalLog(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  37. static int testSetTrace(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  38. static int testInsertError(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  39. static int testDumpState(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  40. #endif
  41. static int testFilterClusterLog(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  42. static int testSetLogLevelClusterLog(NdbMgmHandle h, 
  43.      struct ndb_mgm_reply* reply);
  44. static int testSetLogLevelNode(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  45. static int testRestartNode(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  46. static int testGetStatPort(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  48. typedef int (*FUNC)(NdbMgmHandle h, struct ndb_mgm_reply* reply);
  50. struct test_case {
  51.   char name[255];
  52.   FUNC func;
  53. };
  55. struct test_case test_connect_disconnect[] = {
  56.   {"testConnect", &testConnect},
  57.   {"testDisconnect", &testDisconnect}
  58. };
  60. struct test_case tests[] = {
  61.   { "testStatus",           &testStatus           },
  62.   { "testFilterClusterLog", &testFilterClusterLog },
  63.   /*{ "testSetLogLevelClusterLog", &testSetLogLevelClusterLog },*/
  64.   /*{ "testSetLogLevelNode",  &testSetLogLevelNode  },*/
  65.   { "testRestartNode",      &testRestartNode      },
  66.   { "testGetStatPort",      &testGetStatPort      },
  67. #ifdef VM_TRACE
  68.   { "testLogSignals",       &testLogSignals       },
  69.   { "testStartSignalLog",   &testStartSignalLog   },
  70.   { "testStopSignalLog",    &testStopSignalLog    },
  71.   { "testSetTrace",         &testSetTrace         },
  72.   { "testDumpState",        &testDumpState        },
  73.   { "testInsertError",      &testInsertError      }
  74. #endif
  75. };
  77. static int no_of_tests = sizeof(tests) / sizeof(struct test_case);
  78. static int testFailed = 0;
  80. static const char * g_connect_string = "localhost:2200";
  82. int
  83. main(int argc, const char** argv){
  85.   struct ndb_mgm_reply reply;
  86.   int i = 0;
  87.   NdbMgmHandle h = NULL;
  89.   if(argc > 1)
  90.     g_connect_string = argv[1];
  92.   ndbout_c("Using connectstring: %s", g_connect_string);
  94.   for (i = 0; i < 2; i++) {
  95.     ndbout_c("-- %s --", test_connect_disconnect[i].name);
  96.     if (test_connect_disconnect[i].func(h, &reply) == 0) {
  97.       ndbout_c("-- Passed --");
  98.     } else {
  99.       testFailed++;
  100.       ndbout_c("-- Failed --");
  101.     }
  102.   }
  103.   ndbout_c("-- %d passed, %d failed --", (2 - testFailed),  testFailed);
  106.   h = ndb_mgm_create_handle();
  107.   ndb_mgm_connect(h, g_connect_string);
  108.   
  109.   for (i = 0; i < no_of_tests; i ++) {
  110.     ndbout_c("-- %s --", tests[i].name);
  111.     if (tests[i].func(h, &reply) == 0) {
  112.       ndbout_c("-- Passed --");
  113.     } else {
  114.       testFailed++;
  115.       ndbout_c("-- Failed --");
  116.       ndb_mgm_disconnect(h);
  117.       ndb_mgm_connect(h, g_connect_string);      
  118.     }
  119.   }
  120.   ndbout_c("-- %d passed, %d failed --", (no_of_tests - testFailed),  
  121.    testFailed);
  122.   
  123.   ndb_mgm_disconnect(h);
  125.   return 0;
  126. }
  128. static 
  129. int testConnect(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  130.   h = ndb_mgm_create_handle();
  131.   if (h != NULL) {
  132.     if (ndb_mgm_connect(h, g_connect_string) == -1) {
  133.       ndbout_c(g_connect_string);
  134.       /*ndbout_c("last_error: %d", h->last_error); */
  135.       return -1;
  136.     } else {
  137.       ndbout_c("Connected to localhost:37123");
  138.     }
  139.     
  140.   } else {
  141.     ndbout_c("Unable to create a NdbMgmHandle...");
  142.     return -1;
  143.   }
  145.   return 0;
  146. }
  148. static
  149. int testDisconnect(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  150.   ndb_mgm_disconnect(h); 
  151.   
  152.   return 0;
  153. }
  155. static 
  156. int testGetConfig(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  157.   int i = 0;
  158.   struct ndb_mgm_configuration * config =  ndb_mgm_get_configuration(h, 0);
  159.   if (config != NULL) {
  160.     free(config);
  161.   } else {
  162.     ndbout_c("Unable to get config");
  163.     return -1;
  164.   }
  165.   return 0;
  166. }
  168. static 
  169. int testStatus(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  170.   int i = 0;
  171.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  172.   if (cluster != NULL) {
  173.     ndbout_c("Number of nodes: %d", cluster->no_of_nodes);
  174.     for (i = 0; i < cluster->no_of_nodes; i++) {
  175.       struct ndb_mgm_node_state state = cluster->node_states[i];
  176.       ndbout_c("NodeId: %d (%s)-- %s", state.node_id,
  177.        ndb_mgm_get_node_type_string(state.node_type),
  178.        ndb_mgm_get_node_status_string(state.node_status));
  179.       
  180.     }     
  181.     free(cluster);
  182.   } else {
  183.     ndbout_c("Unable to get node status.");
  184.     return -1;
  185.   }
  186.   return 0;
  187. }
  190. #ifdef VM_TRACE
  192. static 
  193. int testLogSignals(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  194.   int rc = 0;
  195.   int nodeId = 0;
  196.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  197.   if (cluster != NULL) {
  198.     if (cluster->no_of_nodes != 0) {
  199.       nodeId = cluster->node_states[0].node_id;
  200.     }
  201.     free(cluster);
  202.   } else {
  203.     ndbout_c("Unable to get node status.");
  204.     return -1;
  205.   }
  206.       
  207.   rc = ndb_mgm_log_signals(h, nodeId, NDB_MGM_SIGNAL_LOG_MODE_INOUT, 
  208.    "CMVMI QMGR", 
  209.    reply);
  210.   if (rc != 0) {
  211.     ndbout_c("rc = %d", reply->return_code);
  212.   } 
  214.   ndbout_c("%s", reply->message); 
  216.   return rc;
  217. }
  219. static 
  220. int testStartSignalLog(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  221.   int rc = 0;
  222.   int nodeId = 0;
  223.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  224.   if (cluster != NULL) {
  225.     if (cluster->no_of_nodes != 0) {
  226.       nodeId = cluster->node_states[0].node_id;
  227.     }
  228.     free(cluster);
  229.   } else {
  230.     ndbout_c("Unable to get node status.");
  231.     return -1;
  232.   }
  234.   rc = ndb_mgm_start_signallog(h, nodeId, reply);
  235.   if (rc != 0) {
  236.     ndbout_c("rc = %d", reply->return_code);
  237.   } 
  239.   ndbout_c("%s", reply->message); 
  241.   return rc;
  242. }
  244. static 
  245. int testStopSignalLog(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  247.   int rc = 0;
  248.   int nodeId = 0;
  249.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  250.   if (cluster != NULL) {
  251.     if (cluster->no_of_nodes != 0) {
  252.       nodeId = cluster->node_states[0].node_id;
  253.     }
  254.     free(cluster);
  255.   } else {
  256.     ndbout_c("Unable to get node status.");
  257.     return -1;
  258.   }
  260.   rc = ndb_mgm_stop_signallog(h, nodeId, reply);
  261.   if (rc != 0) {
  262.     ndbout_c("rc = %d", reply->return_code);
  263.   } 
  265.   ndbout_c("%s", reply->message); 
  267.   return rc;
  269. }
  271. static 
  272. int testSetTrace(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  273.   int rc = 0;
  274.   int nodeId = 0;
  275.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  276.   if (cluster != NULL) {
  277.     if (cluster->no_of_nodes != 0) {
  278.       nodeId = cluster->node_states[0].node_id;
  279.     }
  280.     free(cluster);
  281.   } else {
  282.     ndbout_c("Unable to get node status.");
  283.     return -1;
  284.   }
  285.   
  286.   rc = ndb_mgm_set_trace(h, nodeId, 2, reply);
  287.   if (rc != 0) {
  288.     ndbout_c("rc = %d", reply->return_code);
  289.   } 
  291.   ndbout_c("%s", reply->message); 
  293.   return rc;
  295. }
  297. static 
  298. int testInsertError(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  299.   int rc = 0;
  300.   int nodeId = 0;
  301.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  302.   if (cluster != NULL) {
  303.     if (cluster->no_of_nodes != 0) {
  304.       nodeId = cluster->node_states[0].node_id;
  305.     }
  306.     free(cluster);
  307.   } else {
  308.     ndbout_c("Unable to get node status.");
  309.     return -1;
  310.   }
  311.   
  312.   rc = ndb_mgm_insert_error(h, nodeId, 9999, reply);
  313.   if (rc != 0) {
  314.     ndbout_c("rc = %d", reply->return_code);
  315.   } 
  317.   ndbout_c("%s", reply->message); 
  319.   return rc;
  321. }
  323. static 
  324. int testDumpState(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  325.   
  326.   int rc = 0;
  327.   int nodeId = 0;
  328.   int dump[3];
  330.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  331.   if (cluster != NULL) {
  332.     if (cluster->no_of_nodes != 0) {
  333.       nodeId = cluster->node_states[0].node_id;
  334.     }
  335.     free(cluster);
  336.   } else {
  337.     ndbout_c("Unable to get node status.");
  338.     return -1;
  339.   }
  340.   
  341.   dump[0] = 1;
  342.   dump[1] = 2;
  343.   dump[2] = 3;
  344.   rc = ndb_mgm_dump_state(h, nodeId, dump, 3, reply);
  346.   if (rc != 0) {
  347.     ndbout_c("rc = %d", reply->return_code);
  348.   } 
  350.   ndbout_c("%s", reply->message); 
  352.   return rc;
  353. }
  355. #endif
  357. static 
  358. int testFilterClusterLog(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  359.   int rc = 0;
  360.   
  361.   rc = ndb_mgm_filter_clusterlog(h, NDB_MGM_CLUSTERLOG_INFO, reply);
  362.   if (rc == -1) {
  363.     ndbout_c("rc = %d", reply->return_code);
  364.     ndbout_c("%s", reply->message);   
  365.     return -1;
  366.   } 
  368.   ndbout_c("%s", reply->message); 
  370.   rc = ndb_mgm_filter_clusterlog(h, NDB_MGM_CLUSTERLOG_DEBUG, reply);
  371.   if (rc == -1) {
  372.     ndbout_c("rc = %d", reply->return_code);
  373.     ndbout_c("%s", reply->message);   
  374.     return -1;
  375.   } 
  377.   ndbout_c("%s", reply->message); 
  379.   return rc;
  381. }
  383. static 
  384. int testSetLogLevelClusterLog(NdbMgmHandle h, 
  385.       struct ndb_mgm_reply* reply) {
  386.   int rc = 0;
  387.   int nodeId = 0;
  388.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  389.   if (cluster != NULL) {
  390.     if (cluster->no_of_nodes != 0) {
  391.       nodeId = cluster->node_states[0].node_id;
  392.     }
  393.     free(cluster);
  394.   } else {
  395.     ndbout_c("Unable to get node status.");
  396.     return -1;
  397.   }
  399.   rc = ndb_mgm_set_loglevel_clusterlog(h, nodeId,
  400.        NDB_MGM_EVENT_CATEGORY_CHECKPOINT,
  401.        5,
  402.        reply);
  403.   if (rc != 0) {
  404.     ndbout_c("rc = %d", reply->return_code);
  405.   } 
  407.   ndbout_c("%s", reply->message); 
  409.   return rc;
  411. }
  413. static 
  414. int testSetLogLevelNode(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  416.   int rc = 0;
  417.   int nodeId = 0;
  418.   struct ndb_mgm_cluster_state* cluster =  ndb_mgm_get_status(h);
  419.   if (cluster != NULL) {
  420.     if (cluster->no_of_nodes != 0) {
  421.       nodeId = cluster->node_states[0].node_id;
  422.     }
  423.     free(cluster);
  424.   } else {
  425.     ndbout_c("Unable to get node status.");
  426.     return -1;
  427.   }
  429.   rc = ndb_mgm_set_loglevel_node(h, nodeId,
  430.  NDB_MGM_EVENT_CATEGORY_STATISTIC,
  431.  15,
  432.  reply);
  433.   if (rc != 0) {
  434.     ndbout_c("rc = %d", reply->return_code);
  435.   } 
  437.   ndbout_c("%s", reply->message); 
  439.   return rc;
  441. }
  443. static int 
  444. testRestartNode(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  445.   int restarts = 0;
  447.   restarts = ndb_mgm_restart(h, 0, 0); /* Restart all */
  448.   if (restarts == 0) {
  449.     ndbout_c("No nodes restarted...");
  450.     return -1;
  451.   } else {
  452.     ndbout_c("%d nodes restarted...", restarts);
  453.   }
  454.   
  455.   return 0;
  456. }
  458. static 
  459. int testGetStatPort(NdbMgmHandle h, struct ndb_mgm_reply* reply) {
  461.   int rc = 0;
  462.   rc = ndb_mgm_get_stat_port(h, reply);
  463.   if (rc == 0) {
  464.     ndbout_c("stat port %s", reply->message);
  465.   } else {
  466.     ndbout_c("failed");
  467.   }
  469.   return rc;
  470. }