Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
RepMain.cpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 3k
Category:

MySQL

Development Platform:

Visual C++

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