src/tools/csqlreplserver.cxx File Reference

#include <AbsSqlConnection.h>
#include <AbsSqlStatement.h>
#include <SqlConnection.h>
#include <SqlStatement.h>
#include <SqlFactory.h>
#include <CSql.h>
#include <Network.h>
#include <SqlLogStatement.h>
#include <SqlNetworkHandler.h>

Include dependency graph for csqlreplserver.cxx:

Go to the source code of this file.

Functions
static void	sigTermHandler (int sig)
void	printUsage ()
int	main (int argc, char **argv)
Variables
int	srvStop = 0

---

Function Documentation

int main	(	int	argc,
		char **	argv
	)

Definition at line 39 of file csqlreplserver.cxx.

References Conf::config, SqlNetworkHandler::conn, AbsSqlConnection::connect(), SqlFactory::createConnection(), CSql, AbsSqlConnection::disconnect(), ErrSysInit, fp, NetworkServer::getSocket(), NetworkServer::handleClient(), IDENTIFIER_LENGTH, OK, printError, printUsage(), os::select(), NetworkServer::setServerPort(), os::signal(), sigTermHandler(), srvStop, NetworkServer::start(), NetworkServer::stop(), and SqlNetworkHandler::type.

{
    int c = 0, opt = 0;
    while ((c = getopt(argc, argv, "?")) != EOF) 
    {
        switch (c)
        {
            case '?' : { opt = 10; break; } //print help 
            default: opt=10; 

        }
    }//while options

    if (opt == 10) {
        printUsage();
        return 0;
    }

    os::signal(SIGINT, sigTermHandler);
    os::signal(SIGTERM, sigTermHandler);

    bool end = false;
    SqlNetworkHandler::type = CSql;
    SqlNetworkHandler::conn = SqlFactory::createConnection(CSql);
    DbRetVal rv = SqlNetworkHandler::conn->connect("root", "manager");
    if (rv != OK) return 1;
    if (!Conf::config.useReplication())
    {
        printf("Replication is set to OFF in csql.conf file\n");
        SqlNetworkHandler::conn->disconnect();
        return 1;
    } 
     
    
    FILE *fp = NULL;
    int nwid =0;
    char hostname[IDENTIFIER_LENGTH];
    int port=0;
    fp = fopen(Conf::config.getReplConfigFile(),"r");
    if( fp == NULL ) {
        printError(ErrSysInit, "Invalid path/filename for REPL_CONFIG_FILE.\n");
        SqlNetworkHandler::conn->disconnect();
        return 1;
    }
    bool found =false;
    while(!feof(fp)) {
       fscanf(fp, "%d:%d:%s\n", &nwid, &port, hostname);
       printf( "%d:%d:%s\n", nwid, port, hostname);
       if (nwid == Conf::config.getNetworkID()) { found = true; break;}
    }
    fclose(fp);
    if (!found)
    {
        printf("Info not found in REPL_CONFIG_FILE for nwid %d\n", 
               Conf::config.getNetworkID());
        SqlNetworkHandler::conn->disconnect();
        return 1;
    }
    NetworkServer *nwServer;

    nwServer = new UDPServer();

    nwServer->setServerPort(port);
    rv = nwServer->start();
    if (rv != OK) {
        printf("Unable to start the server\n");
        return 1;
    }
    printf("Replication server started\n");
    fd_set fdset;
    int ret = 0;
    struct timeval timeout, tval;
    timeout.tv_sec = 5;
    timeout.tv_usec = 0;
    
    while(!srvStop)
    {
        FD_ZERO(&fdset);
        FD_SET(nwServer->getSocket(), &fdset);
        tval.tv_sec = timeout.tv_sec;
        tval.tv_usec = timeout.tv_usec;
        ret = os::select(nwServer->getSocket()+1, &fdset, 0, 0, &tval);
        if (ret > 0) {
            nwServer->handleClient();
        }
        printf("Server Waiting for clients\n");
    }
    printf("Replication Server Exiting\n");
    nwServer->stop();
    SqlNetworkHandler::conn->disconnect();
    delete SqlNetworkHandler::conn;
    return 0;
}

Here is the call graph for this function:

void printUsage

(

)

Definition at line 33 of file csqlreplserver.cxx.

{
   printf("Usage: csqlreplserver \n");
   printf("Description: Start the csql replication server.\n");
   return;
}

static void sigTermHandler

(

int

sig

)

[static]

Definition at line 27 of file csqlreplserver.cxx.

References srvStop.

{
    printf("Received signal %d\nStopping the server\n", sig);
    srvStop = 1;
}

---

Variable Documentation

int srvStop = 0

Definition at line 26 of file csqlreplserver.cxx.

---