src/tools/csqlreplserver.cxx

   1 /***************************************************************************
   2  *   Copyright (C) 2007 by www.databasecache.com                           *
   3  *   Contact: praba_tuty@databasecache.com                                 *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU General Public License as published by  *
   7  *   the Free Software Foundation; either version 2 of the License, or     *
   8  *   (at your option) any later version.                                   *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  13  *   GNU General Public License for more details.                          *
  14  *                                                                         *
  15   ***************************************************************************/
  16 #include <AbsSqlConnection.h>
  17 #include <AbsSqlStatement.h>
  18 #include <SqlConnection.h>
  19 #include <SqlStatement.h>
  20 #include <SqlFactory.h>
  21 #include <CSql.h>
  22 #include <Network.h>
  23 #include <SqlLogStatement.h> //for BindSqlField
  24 #include <SqlNetworkHandler.h>
  25
  26 int srvStop =0;
  27 static void sigTermHandler(int sig)
  28 {
  29     printf("Received signal %d\nStopping the server\n", sig);
  30     srvStop = 1;
  31 }
  32
  33 void printUsage()
  34 {
  35    printf("Usage: csqlreplserver \n");
  36    printf("Description: Start the csql replication server.\n");
  37    return;
  38 }
  39 int main(int argc, char **argv)
  40 {
  41     int c = 0, opt = 0;
  42     while ((c = getopt(argc, argv, "?")) != EOF)
  43     {
  44         switch (c)
  45         {
  46             case '?' : { opt = 10; break; } //print help
  47             default: opt=10;
  48
  49         }
  50     }//while options
  51
  52     if (opt == 10) {
  53         printUsage();
  54         return 0;
  55     }
  56
  57     os::signal(SIGINT, sigTermHandler);
  58     os::signal(SIGTERM, sigTermHandler);
  59
  60     bool end = false;
  61     SqlNetworkHandler::type = CSql;
  62     SqlNetworkHandler::conn = SqlFactory::createConnection(CSql);
  63     DbRetVal rv = SqlNetworkHandler::conn->connect("root", "manager");
  64     if (rv != OK) return 1;
  65     //if (!Conf::config.useReplication())
  66     {
  67         printf("Replication is set to OFF in csql.conf file\n");
  68         SqlNetworkHandler::conn->disconnect();
  69         return 1;
  70     }
  71
  72
  73     FILE *fp = NULL;
  74     int nwid =0;
  75     char hostname[IDENTIFIER_LENGTH];
  76     int port=0;
  77     //fp = fopen(Conf::config.getReplConfigFile(),"r");
  78     if( fp == NULL ) {
  79         printError(ErrSysInit, "Invalid path/filename for REPL_CONFIG_FILE.\n");
  80         SqlNetworkHandler::conn->disconnect();
  81         return 1;
  82     }
  83     fclose(fp);
  84     NetworkServer *nwServer;
  85
  86     nwServer = new UDPServer();
  87
  88     nwServer->setServerPort(port);
  89     rv = nwServer->start();
  90     if (rv != OK) {
  91         printf("Unable to start the server\n");
  92         return 1;
  93     }
  94     printf("Replication server started\n");
  95     fd_set fdset;
  96     int ret = 0;
  97     struct timeval timeout, tval;
  98     timeout.tv_sec = 5;
  99     timeout.tv_usec = 0;
 100
 101     while(!srvStop)
 102     {
 103         FD_ZERO(&fdset);
 104         FD_SET(nwServer->getSocket(), &fdset);
 105         tval.tv_sec = timeout.tv_sec;
 106         tval.tv_usec = timeout.tv_usec;
 107         ret = os::select(nwServer->getSocket()+1, &fdset, 0, 0, &tval);
 108         if (ret > 0) {
 109             nwServer->handleClient();
 110         }
 111         printf("Server Waiting for clients\n");
 112     }
 113     printf("Replication Server Exiting\n");
 114     nwServer->stop();
 115     SqlNetworkHandler::conn->disconnect();
 116     delete SqlNetworkHandler::conn;
 117     return 0;
 118 }