src/server/Server.cxx File Reference

#include <CSql.h>
#include <SessionImpl.h>
#include <Debug.h>
#include <Process.h>
#include <Database.h>
#include <Transaction.h>
#include <Lock.h>
#include <CacheTableLoader.h>

Include dependency graph for Server.cxx:

Go to the source code of this file.

Functions
static void	sigTermHandler (int sig)
bool	checkDead (pid_t pid)
DbRetVal	releaseAllResources (Database *sysdb, ThreadInfo *info)
DbRetVal	cleanupDeadProcs (Database *sysdb)
DbRetVal	logActiveProcs (Database *sysdb)
int	main ()
Variables
int	srvStop = 0

---

Function Documentation

bool checkDead

(

pid_t

pid

)

Definition at line 32 of file Server.cxx.

References os::kill().

Referenced by cleanupDeadProcs(), and main().

{
    int ret = os::kill(pid, 0);
    if (ret == -1) return true; else return false;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal cleanupDeadProcs

(

Database *

sysdb

)

Definition at line 69 of file Server.cxx.

References checkDead(), Conf::config, Config::getMaxProcs(), os::getpid(), Database::getProcessTableMutex(), Database::getThreadInfo(), os::getthrid(), OK, ThreadInfo::pid_, printError, releaseAllResources(), and Database::releaseProcessTableMutex().

Referenced by main().

{
    DbRetVal rv = sysdb->getProcessTableMutex(false);
    if (OK != rv)
    {
        printError(rv,"Unable to get process table mutex");
        return rv;
    }
    pid_t pid;
    pid = os::getpid();
    pthread_t thrid = os::getthrid();


    ThreadInfo* pInfo = sysdb->getThreadInfo(0);
    int i=0;
    ThreadInfo* freeSlot = NULL;
    for (; i < Conf::config.getMaxProcs(); i++)
    {
        //check whether it is alive
        if (pInfo->pid_ !=0 && checkDead(pInfo->pid_)) releaseAllResources(sysdb, pInfo);
        pInfo++;
    }
    sysdb->releaseProcessTableMutex(false);
    return OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal logActiveProcs

(

Database *

sysdb

)

Definition at line 96 of file Server.cxx.

References Conf::config, Config::getMaxProcs(), Database::getProcessTableMutex(), Database::getThreadInfo(), logFine, logger, OK, ThreadInfo::pid_, printError, Database::releaseProcessTableMutex(), and ThreadInfo::thrid_.

Referenced by main().

{
    DbRetVal rv = sysdb->getProcessTableMutex(false);
    if (OK != rv)
    {
        printError(rv,"Unable to get process table mutex");
        return rv;
    }
    ThreadInfo* pInfo = sysdb->getThreadInfo(0);
    int i=0;
    ThreadInfo* freeSlot = NULL;
    for (; i < Conf::config.getMaxProcs(); i++)
    {
        if (pInfo->pid_ !=0 )  logFine(logger, "Registered Procs: %d %lu\n", pInfo->pid_, pInfo->thrid_);
        pInfo++;
    }
    sysdb->releaseProcessTableMutex(false);
    return OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int main

(

)

Definition at line 118 of file Server.cxx.

References cleanupDeadProcs(), Conf::config, SessionImpl::destroySystemDatabase(), SessionImpl::getSystemDatabase(), SessionImpl::initSystemDatabase(), logActiveProcs(), logFine, logger, OK, SessionImpl::readConfigFile(), os::select(), os::signal(), sigTermHandler(), srvStop, Logger::startLogger(), and Logger::stopLogger().

{
    SessionImpl session;
    DbRetVal rv = session.readConfigFile();
    if (rv != OK)
    {
        printf("Unable to read the configuration file \n");
        return 1;
    }
    os::signal(SIGINT, sigTermHandler);
    os::signal(SIGTERM, sigTermHandler);
    rv = logger.startLogger(Conf::config.getLogFile(), true);
    if (rv != OK)
    {
        printf("Unable to start the logger\n");
        return 2;
    }

    logFine(logger, "Server Started");
    int ret  = session.initSystemDatabase();
    if (0  != ret)
    {
        printf(" System Database Initialization failed\n");
        return 3;
    }
    printf("System Database initialized\n");


    bool end = false;

    struct timeval timeout, tval;
    timeout.tv_sec = 5;
    timeout.tv_usec = 0;
    Database* sysdb = session.getSystemDatabase();
    printf("Database server recovering cached tables...\n");
   
    system("cachetable -u root -p manager -r");

    printf("Cached Tables recovered\n");

    printf("Database server started\n");

    while(!srvStop)
    {
        tval.tv_sec = timeout.tv_sec;
        tval.tv_usec = timeout.tv_usec;
        os::select(0, 0, 0, 0, &tval);
        
        //send signal to all the registered process..check they are alive
        cleanupDeadProcs(sysdb);
        
    }
   
    logFine(logger, "Server Exiting");
    logActiveProcs(sysdb);
    printf("Server Exiting\n");
    logFine(logger, "Server Ended");
    logger.stopLogger();
    session.destroySystemDatabase();
    return 0;
}

Here is the call graph for this function:

DbRetVal releaseAllResources	(	Database *	sysdb,
		ThreadInfo *	info
	)

Definition at line 38 of file Server.cxx.

References ThreadInfo::has_, logFine, logger, MAX_MUTEX_PER_THREAD, Mutex::name, ThreadInfo::pid_, srvStop, and ThreadInfo::thrid_.

Referenced by cleanupDeadProcs().

{
    printf("Releasing all the resources for process %d %lu\n", info->pid_, info->thrid_);
    //recover for all the mutexes in has_
    for (int i =0;  i < MAX_MUTEX_PER_THREAD; i++)
    {
        if (info->has_[i] != NULL) 
        {
            printf("Dead Procs: %d %lu holding mutex %x %s) \n", info->pid_, info->thrid_, info->has_[i], info->has_[i]->name);
            logFine(logger, "Dead Procs: %d %lu holding mutex %x %s) \n", info->pid_, info->thrid_, info->has_[i], info->has_[i]->name);
            //TODO::recovery of mutexes 
            //info->has_[i]->recoverMutex();
            srvStop = 1;
        }
    }
    TransactionManager *tm = new TransactionManager();
    LockManager *lm = new LockManager(sysdb);
    for (int i = 0 ;i < MAX_THREADS_PER_PROCESS; i++)
    {
        if (info->thrTrans_[i].trans_ != NULL && info->thrTrans_[i].trans_->status_ == TransRunning)
        {
            printf("Rollback Transaction %x\n", info->thrTrans_[i].trans_);
            tm->rollback(lm, info->thrTrans_[i].trans_);
        }
    }
    info->init();
    delete tm;
    delete lm;
    return OK;
}

Here is the caller graph for this function:

static void sigTermHandler

(

int

sig

)

[static]

Definition at line 26 of file Server.cxx.

References srvStop.

Referenced by main().

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

Here is the caller graph for this function:

---

Variable Documentation

int srvStop = 0

Definition at line 25 of file Server.cxx.

Referenced by main(), releaseAllResources(), and sigTermHandler().

---