NetworkTable Class Reference

#include <Network.h>

Collaboration diagram for NetworkTable:

[legend]

Public Member Functions
	~NetworkTable ()
DbRetVal	initialize ()
void	destroy ()
DbRetVal	readNetworkConfig ()
NetworkClient *	getNetworkClient ()
DbRetVal	connect ()
DbRetVal	disconnect ()
DbRetVal	connectIfNotConnected ()

---

Detailed Description

Definition at line 102 of file Network.h.

---

Constructor & Destructor Documentation

NetworkTable::~NetworkTable

(

)

Definition at line 31 of file NetworkTable.cxx.

{
    //TODO::
}

---

Member Function Documentation

DbRetVal NetworkTable::connect

(

)

Definition at line 74 of file NetworkTable.cxx.

References NetworkClient::connect(), ErrOS, NetworkClient::getNetworkID(), OK, printError, and NetworkClient::setConnectFlag().

{
    DbRetVal rv = nwClient->connect();
    if (rv != OK) {
        printError(ErrOS, "Unable to connect to peer %d\n", nwClient->getNetworkID());
        nwClient->setConnectFlag(false);
    }
    return rv;
}

Here is the call graph for this function:

DbRetVal NetworkTable::connectIfNotConnected

(

)

Definition at line 83 of file NetworkTable.cxx.

References NetworkClient::connect(), ErrAlready, NetworkClient::isConnected(), and OK.

Referenced by SqlLogConnection::connectIfNotConnected().

{
   DbRetVal rv = OK;
   if (!nwClient->isConnected()) rv = nwClient->connect(); else rv =ErrAlready;
   return rv;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void NetworkTable::destroy

(

)

[inline]

Definition at line 108 of file Network.h.

{}

DbRetVal NetworkTable::disconnect

(

)

Definition at line 90 of file NetworkTable.cxx.

References NetworkClient::disconnect(), NetworkClient::isConnected(), and OK.

{
    if (nwClient->isConnected()) {
        nwClient->disconnect();
    }
    return OK;
}

Here is the call graph for this function:

NetworkClient* NetworkTable::getNetworkClient

(

)

[inline]

Definition at line 110 of file Network.h.

Referenced by SqlLogConnection::sendAndReceive().

{ return nwClient; }

Here is the caller graph for this function:

DbRetVal NetworkTable::initialize

(

)

Definition at line 23 of file NetworkTable.cxx.

References Conf::config, OK, and readNetworkConfig().

{
    DbRetVal rv = OK;
    if (!Conf::config.useReplication() && !Conf::config.useCache()) return OK;
    rv = readNetworkConfig();
    return rv;
    
}

Here is the call graph for this function:

DbRetVal NetworkTable::readNetworkConfig

(

)

Definition at line 35 of file NetworkTable.cxx.

References Conf::config, NetworkFactory::createClient(), DM_Network, ErrNotYet, ErrSysInit, fp, IDENTIFIER_LENGTH, OK, printDebug, printError, NetworkClient::setCacheClient(), NetworkClient::setHost(), and TCP.

Referenced by initialize().

{
    FILE *fp;
    int nwid;
    char hostname[IDENTIFIER_LENGTH];
    int port;
    fp = fopen(Conf::config.getReplConfigFile(),"r");
    if( fp == NULL ) {
        printError(ErrSysInit, "Invalid path/filename for NETWORK_CONFIG_FILE.\n");
        return ErrSysInit;
    }
    int count = 0;
    while(!feof(fp)) {
       if (count >=1) 
       {
           fclose(fp);
           printError(ErrNotYet, "Only 2 hosts are allowed in this version"); 
           return ErrNotYet;
       }
       printDebug(DM_Network, "Count is %d\n", count);
       fscanf(fp, "%d:%d:%s\n", &nwid, &port, hostname);
       printDebug(DM_Network, "%d:%d:%s\n", nwid, port, hostname);
       NetworkClient* nClient;
       if (nwid == Conf::config.getNetworkID()) continue;

       nClient = NetworkFactory::createClient(TCP);

       printDebug(DM_Network, "nwid %d getCacheNetworkID %d\n", nwid,  Conf::config.getCacheNetworkID());
       if (nwid == Conf::config.getCacheNetworkID()) nClient->setCacheClient();
       nClient->setHost(hostname, port, nwid);
       nwClient = nClient;
       count++;
    }
    fclose(fp);
    return OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• include/Network.h
• src/network/NetworkTable.cxx

---