RepMain.cpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
源码类别:

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. #include <ndb_global.h>
  14. #include <NdbApiSignal.hpp>
  15. #include <getarg.h>
  16. #include <rep/RepComponents.hpp>
  17. #include "rep_version.hpp"
  18. #include <rep/RepCommandInterpreter.hpp>
  19. #include <rep/RepApiInterpreter.hpp>
  20. int
  21. main(int argc, const char **argv)
  22. {
  23.   RepComponents comps;
  24.   RepCommandInterpreter cmd(&comps);
  25.   int helpFlag = false;
  26.   int noConnectFlag = false;
  27.   int onlyPrimaryFlag = false;
  28.   int onlyStandbyFlag = false;
  29.   int port = 18000;
  30.   replogEnabled = false;
  31.   struct getargs args[] = {
  32.     { "psc", '1', arg_string, &comps.m_connectStringPS, 
  33.       "Connect string", "connectstring" },
  34.     { "ssc", '2', arg_string, &comps.m_connectStringSS, 
  35.       "Connect string", "connectstring" },
  36.     { "port", 'p', arg_integer, &port, 
  37.       "port for rep api. Default 18000", "" },
  38.     { "usage", '?', arg_flag, &helpFlag, 
  39.       "Print help", "" },
  40. /* @todo
  41.     { "noConnect", 'n', arg_flag, &noConnectFlag, 
  42.       "Do not connect adapters", "" },
  43. */
  44.     { "debug", 'd', arg_flag, &replogEnabled, 
  45.       "Enable debug printouts on console", "" },
  46.     { "onlyStandby", 's', arg_flag, &onlyStandbyFlag, 
  47.       "Let Replication Server view DBMS as standby (destination) system only", 
  48.       "" }
  49.   };
  50.   int num_args = sizeof(args) / sizeof(args[0]);
  51.   int optind = 0;
  52.   char desc[] = 
  53.     "nWhen working as a primary system node, this program receivesn"
  54.     "records from the primary NDB Cluster and forwards them ton"
  55.     "the standby system.nn"
  56.     "When working as a standby system node, this program receivesn"
  57.     "records from another replication node and inserts them inton"
  58.     "the standby NDB Cluster.nn"
  59.     "Example:  ndb_rep --psc="nodeid=3;host=localhost:10000"n";
  60.   
  61.   if(getarg(args, num_args, argc, argv, &optind) || 
  62.      //argv[optind] == NULL || 
  63.      helpFlag)
  64.   {
  65.     arg_printusage(args, num_args, argv[0], desc);
  66.     return -1; //NDBT_ProgramExit(NDBT_WRONGARGS);
  67.   }
  68.   RepApiInterpreter api(&comps,port);
  69.   api.startInterpreter();
  70.   
  71.   /**************************
  72.    * Command-line interface *
  73.    **************************/
  74.   if (!noConnectFlag && !onlyPrimaryFlag) comps.connectSS();
  75.   if (!noConnectFlag && !onlyStandbyFlag) comps.connectPS();
  76.   while (true) {
  77.     if(!cmd.readAndExecute()) {
  78.       api.stopInterpreter();
  79.       exit(1);
  80.     }
  81.   }
  82. }