Sets up a SimpleNetwork. More...

#include <SimpleUnderlayConfigurator.h>

Inheritance diagram for SimpleUnderlayConfigurator:

Public Member Functions
	~SimpleUnderlayConfigurator ()
virtual TransportAddress *	createNode (NodeType type, bool initialize=false)
	Creates an overlay node.
virtual void	preKillNode (NodeType type, TransportAddress *addr=NULL)
	Notifies and schedules overlay nodes for removal.
virtual void	migrateNode (NodeType type, TransportAddress *addr=NULL)
	Migrates overlay nodes from one access net to another.
uint32_t	getFieldSize ()
uint32_t	getFieldDimension ()
uint32_t	getSendQueueLenghth ()
IPvXAddress	migrateNode (NodeType type, IPvXAddress addr, const BaseLocation &locID)
double	getDistance (const BaseLocation &IDa, const BaseLocation &IDb)
BaseLocation *	getNearLocation (const BaseLocation &ID, double radius)
BaseLocation *	getLocation (IPvXAddress addr)
Public Member Functions inherited from UnderlayConfigurator
	UnderlayConfigurator ()
virtual	~UnderlayConfigurator ()
bool	isInInitPhase ()
	still in initialization phase?
bool	isSimulationEndingSoon ()
	Is the simulation ending soon?
simtime_t	getGracefulLeaveDelay ()
	Return the gracefulLeaveDelay.
bool	isTransitionTimeFinished ()
void	initFinished ()
ChurnGenerator *	getChurnGenerator (int typeID)
uint8_t	getChurnGeneratorNum ()
int	getOverlayTerminalCount ()

Protected Member Functions
void	initializeUnderlay (int stage)
	Enables access to the globalHashMap, sets some parameters and adds the initial number of nodes to the network.
void	handleTimerEvent (cMessage *msg)
void	finishUnderlay ()
	Saves statistics, prints simulation time.
void	setDisplayString ()
	Prints statistics.
uint32_t	parseCoordFile (const char *nodeCoordinateSource)
Protected Member Functions inherited from UnderlayConfigurator
int	numInitStages () const
	OMNeT number of init stages.
virtual void	initialize (int stage)
	OMNeT init methods.
void	finish ()
	Cleans up configurator.
void	handleMessage (cMessage *msg)
	Node mobility simulation.

Protected Attributes
uint32	nextFreeAddress
	address of the node that will be created next
std::deque< IPvXAddress >	killList
	stores nodes scheduled to be killed
std::set< int >	scheduledID
	stores nodeIds to prevent migration of prekilled nodes
uint32_t	sendQueueLength
	send queue length of overlay terminals
uint32_t	fieldSize
int	dimensions
bool	fixedNodePositions
bool	useIPv6
bool	useXmlCoords
const char *	nodeCoordinateSource
uint32_t	maxCoordinate
std::vector< std::pair < NodeRecord *, bool > >	nodeRecordPool
int	numCreated
	number of overall created overlay terminals
int	numKilled
	number of overall killed overlay terminals
Protected Attributes inherited from UnderlayConfigurator
int	overlayTerminalCount
	current number of overlay terminals
int	firstNodeId
	the Id of the overlayTerminal created first in the overlay
simtime_t	gracefulLeaveDelay
	delay until scheduled node is removed from overlay
double	gracefulLeaveProbability
	probability that node is notified befor removal
GlobalNodeList *	globalNodeList
	pointer to GlobalNodeList
GlobalStatistics *	globalStatistics
	pointer to GlobalStatistics
std::vector< ChurnGenerator * >	churnGenerator
	pointer to the ChurnGenerators
cMessage *	endSimulationTimer
	timer to signal end of simulation
cMessage *	endSimulationNotificationTimer
	timer to notify nodes that simulation ends soon
cMessage *	endTransitionTimer
	timer to signal end of transition time
struct timeval	initFinishedTime
	timestamp at end of init phase
struct timeval	initStartTime
	timestamp at begin of init phase
simtime_t	transitionTime
	time to wait before measuring after init phase is finished
simtime_t	measurementTime
	duration of the simulation after init and transition phase

Additional Inherited Members
Static Protected Attributes inherited from UnderlayConfigurator
static const int	NUM_COLORS = 8
static const char *	colorNames []

Detailed Description

Sets up a SimpleNetwork.

Adds overlay nodes to the network in init phase and adds/removes/migrates overlay nodes after init phase.

Definition at line 42 of file SimpleUnderlayConfigurator.h.

Constructor & Destructor Documentation

SimpleUnderlayConfigurator::~SimpleUnderlayConfigurator ( )

Definition at line 56 of file SimpleUnderlayConfigurator.cc.

{
    for (uint32_t i = 0; i < nodeRecordPool.size(); ++i) {
        //std::cout << (nodeRecordPool[i].second ? "+" : "_");
        delete nodeRecordPool[i].first;
    }
    nodeRecordPool.clear();
}

Member Function Documentation

TransportAddress * SimpleUnderlayConfigurator::createNode	(	NodeType	type,
		bool	initialize = `false`
	)

virtual

Creates an overlay node.

Parameters

type	NodeType of the node to create
initialize	are we in init phase?

Implements UnderlayConfigurator.

Definition at line 115 of file SimpleUnderlayConfigurator.cc.

{
    Enter_Method_Silent();
    // derive overlay node from ned
    cModuleType* moduleType = cModuleType::get(type.terminalType.c_str());
    std::string nameStr = "overlayTerminal";
    if (churnGenerator.size() > 1) {
        nameStr += "-" + convertToString<int32_t>(type.typeID);
    }
    cModule* node = moduleType->create(nameStr.c_str(), getParentModule(),
                                       numCreated + 1, numCreated);
    std::string displayString;
    if ((type.typeID > 0) && (type.typeID <= NUM_COLORS)) {
        ((displayString += "i=device/wifilaptop_l,")
                += colorNames[type.typeID - 1]) += ",40;i2=block/circle_s";
    } else {
        displayString = "i=device/wifilaptop_l;i2=block/circle_s";
    }
    node->finalizeParameters();
    node->setDisplayString(displayString.c_str());
    node->buildInside();
    node->scheduleStart(simTime());
    for (int i = 0; i < MAX_STAGE_UNDERLAY + 1; i++) {
        node->callInitialize(i);
    }
    IPvXAddress addr;
    if (useIPv6) {
        addr = IPv6Address(0, nextFreeAddress++, 0, 0);
    } else {
        addr = IPAddress(nextFreeAddress++);
    }
    int chanIndex = intuniform(0, type.channelTypesRx.size() - 1);
    cChannelType* rxChan = cChannelType::find(type.channelTypesRx[chanIndex].c_str());
    cChannelType* txChan = cChannelType::find(type.channelTypesTx[chanIndex].c_str());
    if (!txChan || !rxChan)
         opp_error("Could not find Channel Type. Most likely parameter "
            "channelTypesRx or channelTypes does not match the channels defined in "
             "channels.ned");
    SimpleNodeEntry* entry;
    if (!useXmlCoords) {
        entry = new SimpleNodeEntry(node, rxChan, txChan, sendQueueLength, fieldSize);
    } else {
        // get random unused node
        // Changed to "predictable" volunteer start value 0 by Daniel Lienert, 05/2010 to get the same coord-sequence in every run
        //uint32_t volunteer = 0;
        uint32_t volunteer = intuniform(0, nodeRecordPool.size() - 1);
        uint32_t temp = volunteer;
        while (nodeRecordPool[volunteer].second == false) {
            ++volunteer;
            if (volunteer >= nodeRecordPool.size())
                volunteer = 0;
            // stop with errormessage if no more unused nodes available
            if (temp == volunteer)
                throw cRuntimeError("No unused coordinates left -> "
                    "cannot create any more nodes. "
                    "Provide %s-file with more nodes!\n", nodeCoordinateSource);
        }
         entry = new SimpleNodeEntry(node, rxChan, txChan,
                 sendQueueLength, nodeRecordPool[volunteer].first, volunteer);
        // insert IP-address into noderecord used
        // nodeRecordPool[volunteer].first->ip = addr;
        nodeRecordPool[volunteer].second = false;
    }
    SimpleUDP* simpleUdp = check_and_cast<SimpleUDP*> (node->getSubmodule("udp"));
    simpleUdp->setNodeEntry(entry);
    SimpleTCP* simpleTcp = dynamic_cast<SimpleTCP*> (node->getSubmodule("tcp", 0));
    if (simpleTcp) {
        simpleTcp->setNodeEntry(entry);
    }
    // Add pseudo-Interface to node's interfaceTable
    if (useIPv6) {
        IPv6InterfaceData* ifdata = new IPv6InterfaceData;
        ifdata->assignAddress(addr.get6(),false, 0, 0);
        IPv6InterfaceData::AdvPrefix prefix = {addr.get6(), 64};
        ifdata->addAdvPrefix(prefix);
        InterfaceEntry* e = new InterfaceEntry;
        e->setName("dummy interface");
        e->setIPv6Data(ifdata);
        IPAddressResolver().interfaceTableOf(node)->addInterface(e, NULL);
    }
    else {
        IPv4InterfaceData* ifdata = new IPv4InterfaceData;
        ifdata->setIPAddress(addr.get4());
        ifdata->setNetmask(IPAddress("255.255.255.255"));
        InterfaceEntry* e = new InterfaceEntry;
        e->setName("dummy interface");
        e->setIPv4Data(ifdata);
        IPAddressResolver().interfaceTableOf(node)->addInterface(e, NULL);
    }
    // create meta information
    SimpleInfo* info = new SimpleInfo(type.typeID, node->getId(), type.context);
    info->setEntry(entry);
    //add node to bootstrap oracle
    globalNodeList->addPeer(addr, info);
    // if the node was not created during startup we have to
    // finish the initialization process manually
    if (!initialize) {
        for (int i = MAX_STAGE_UNDERLAY + 1; i < NUM_STAGES_ALL; i++) {
            node->callInitialize(i);
        }
    }
    //show ip...
    //TODO: migrate
    if (fixedNodePositions && ev.isGUI()) {
        node->getDisplayString().insertTag("p");
        node->getDisplayString().setTagArg("p", 0, (long int)(entry->getX() * 5));
        node->getDisplayString().setTagArg("p", 1, (long int)(entry->getY() * 5));
        node->getDisplayString().insertTag("t", 0);
        node->getDisplayString().setTagArg("t", 0, addr.str().c_str());
        node->getDisplayString().setTagArg("t", 1, "l");
    }
    overlayTerminalCount++;
    numCreated++;
    churnGenerator[type.typeID]->terminalCount++;
    TransportAddress *address = new TransportAddress(addr);
    // update display
    setDisplayString();
    return address;
}

void SimpleUnderlayConfigurator::finishUnderlay ( )

protectedvirtual

Saves statistics, prints simulation time.

Reimplemented from UnderlayConfigurator.

Definition at line 523 of file SimpleUnderlayConfigurator.cc.

{
    // statistics
    recordScalar("Terminals added", numCreated);
    recordScalar("Terminals removed", numKilled);
    if (!isInInitPhase()) {
        struct timeval now, diff;
        gettimeofday(&now, NULL);
        timersub(&now, &initFinishedTime, &diff);
        printf("Simulation time: %li.%06li\n", diff.tv_sec, diff.tv_usec);
    }
}

double SimpleUnderlayConfigurator::getDistance	(	const BaseLocation &	IDa,
		const BaseLocation &	IDb
	)

Definition at line 639 of file SimpleUnderlayConfigurator.cc.

                                                                                              {
    NodeRecord a = dynamic_cast<const NodeRecord&>(IDa);
    NodeRecord b = dynamic_cast<const NodeRecord&>(IDb);
    return sqrt( pow((a.coords[0] - b.coords[0]), 2)
                 + pow((a.coords[1] - b.coords[1]), 2) );
}

uint32_t SimpleUnderlayConfigurator::getFieldDimension ( )

inline

Definition at line 72 of file SimpleUnderlayConfigurator.h.

{ return dimensions; };

uint32_t SimpleUnderlayConfigurator::getFieldSize ( )

inline

Definition at line 71 of file SimpleUnderlayConfigurator.h.

{ return fieldSize; };

BaseLocation * SimpleUnderlayConfigurator::getLocation ( IPvXAddress addr )

Definition at line 658 of file SimpleUnderlayConfigurator.cc.

                                                                     {
    SimpleInfo* info = dynamic_cast<SimpleInfo*> (globalNodeList->getPeerInfo(addr));
    BaseLocation* ret = info->getEntry()->getNodeRecord();
    return ret;
}

BaseLocation * SimpleUnderlayConfigurator::getNearLocation	(	const BaseLocation &	ID,
		double	radius
	)

Definition at line 646 of file SimpleUnderlayConfigurator.cc.

                                                                                              {
    const NodeRecord* tempLoc = dynamic_cast<const NodeRecord*>(&ID);
    NodeRecord* ret = new NodeRecord();
    radius = uniform (0.3, 1, 0) * radius;  // scales the radius randomly
    double angle = uniform (0, 2 *M_PI, 0);  // random angle
    ret->coords[0] = cos(angle)*radius + tempLoc->coords[0];
    ret->coords[1] = sin(angle)*radius + tempLoc->coords[1];
    return ret;
}

uint32_t SimpleUnderlayConfigurator::getSendQueueLenghth ( )

inline

Definition at line 73 of file SimpleUnderlayConfigurator.h.

{ return sendQueueLength; };

void SimpleUnderlayConfigurator::handleTimerEvent ( cMessage * msg )

protectedvirtual

Reimplemented from UnderlayConfigurator.

Definition at line 475 of file SimpleUnderlayConfigurator.cc.

{
    Enter_Method_Silent();
    // get next scheduled node and remove it from the kill list
    IPvXAddress addr = killList.back();
    killList.pop_back();
    SimpleNodeEntry* entry = NULL;
    SimpleInfo* info =
            dynamic_cast<SimpleInfo*> (globalNodeList->getPeerInfo(addr));
    if (info != NULL) {
        entry = info->getEntry();
    } else {
        throw cRuntimeError("SimpleUnderlayConfigurator: Trying to kill "
                            "node with unknown TransportAddress!");
    }
    cGate* gate = entry->getUdpIPv4Gate();
    cModule* node = gate->getOwnerModule()->getParentModule();
    if (useXmlCoords) {
        nodeRecordPool[entry->getRecordIndex()].second = true;
    }
    scheduledID.erase(node->getId());
    globalNodeList->killPeer(addr);
    InterfaceEntry* ie = IPAddressResolver().interfaceTableOf(node)->
                                         getInterfaceByName("dummy interface");
    delete ie->ipv4Data();
    node->callFinish();
    node->deleteModule();
    delete msg;
}

void SimpleUnderlayConfigurator::initializeUnderlay ( int stage )

protectedvirtual

Enables access to the globalHashMap, sets some parameters and adds the initial number of nodes to the network.

Parameters

stage the phase of the initialisation

Implements UnderlayConfigurator.

Definition at line 65 of file SimpleUnderlayConfigurator.cc.

{
    if (stage != MAX_STAGE_UNDERLAY)
        return;
    // fetch some parameters
    fixedNodePositions = par("fixedNodePositions");
    useIPv6 = par("useIPv6Addresses");
    // set maximum coordinates and send queue length
    fieldSize = par("fieldSize");
    sendQueueLength = par("sendQueueLength");
    // get parameter of sourcefile's name
    nodeCoordinateSource = par("nodeCoordinateSource");
    if (std::string(nodeCoordinateSource) != "") {
        // check if exists and process xml-file containing coordinates
        std::ifstream check_for_xml_file(nodeCoordinateSource);
        if (check_for_xml_file) {
            useXmlCoords = 1;
            EV<< "[SimpleNetConfigurator::initializeUnderlay()]\n"
            << "    Using '" << nodeCoordinateSource
            << "' as coordinate source file" << endl;
            maxCoordinate = parseCoordFile(nodeCoordinateSource);
        } else {
            throw cRuntimeError("Coordinate source file not found!");
        }
        check_for_xml_file.close();
    } else {
        useXmlCoords = 0;
        dimensions = 2; //TODO do we need this variable?
        NodeRecord::setDim(dimensions);
        EV << "[SimpleNetConfigurator::initializeUnderlay()]\n"
        << "    Using conventional (random) coordinates for placing nodes!\n"
        << "    (no XML coordinate source file was specified)" << endl;
    }
    // FIXME get address from parameter
    nextFreeAddress = 0x1000001;
    // count the overlay clients
    overlayTerminalCount = 0;
    numCreated = 0;
    numKilled = 0;
}

void SimpleUnderlayConfigurator::migrateNode	(	NodeType	type,
		TransportAddress *	addr = `NULL`
	)

virtual

Migrates overlay nodes from one access net to another.

Parameters

type	NodeType of the node to migrate
addr	NULL for random node

Implements UnderlayConfigurator.

Definition at line 387 of file SimpleUnderlayConfigurator.cc.

{
    Enter_Method_Silent();
    SimpleNodeEntry* entry = NULL;
    if (addr != NULL) {
        SimpleInfo* info =
              dynamic_cast<SimpleInfo*> (globalNodeList->getPeerInfo(*addr));
        if (info != NULL) {
            entry = info->getEntry();
        } else {
            opp_error("SimpleNetConfigurator: Trying to migrate node with "
                      "nonexistant TransportAddress!");
        }
    } else {
        SimpleInfo* info = dynamic_cast<SimpleInfo*> (
                globalNodeList-> getRandomPeerInfo(type.typeID));
        entry = info->getEntry();
    }
    cGate* gate = entry->getUdpIPv4Gate();
    cModule* node = gate->getOwnerModule()->getParentModule();
    // do not migrate node that is already scheduled
    if (scheduledID.count(node->getId()))
        return;
    //std::cout << "migration @ " << tmp_ip << " --> " << address << std::endl;
    // FIXME use only IPv4?
    IPvXAddress address = IPAddress(nextFreeAddress++);
    IPvXAddress tmp_ip = IPAddressResolver().addressOf(node);
    SimpleNodeEntry* newentry;
    int chanIndex = intuniform(0, type.channelTypesRx.size() - 1);
    cChannelType* rxChan = cChannelType::find(type.channelTypesRx[chanIndex].c_str());
    cChannelType* txChan = cChannelType::find(type.channelTypesTx[chanIndex].c_str());
    if (!txChan || !rxChan)
         opp_error("Could not find Channel Type. Most likely parameter "
            "channelTypesRx or channelTypes does not match the channels defined in "
             "channels.ned");
    if (useXmlCoords) {
       newentry = new SimpleNodeEntry(node,
                                      rxChan,
                                      txChan,
                                      sendQueueLength,
                                      entry->getNodeRecord(), entry->getRecordIndex());
        //newentry->getNodeRecord()->ip = address;
    } else {
        newentry = new SimpleNodeEntry(node, rxChan, txChan, fieldSize, sendQueueLength);
    }
    node->bubble("I am migrating!");
    //remove node from bootstrap oracle
    globalNodeList->killPeer(tmp_ip);
    SimpleUDP* simple = check_and_cast<SimpleUDP*> (gate->getOwnerModule());
    simple->setNodeEntry(newentry);
    InterfaceEntry* ie = IPAddressResolver().interfaceTableOf(node)->
                                      getInterfaceByName("dummy interface");
    delete ie->ipv4Data();
    // Add pseudo-Interface to node's interfaceTable
    IPv4InterfaceData* ifdata = new IPv4InterfaceData;
    ifdata->setIPAddress(address.get4());
    ifdata->setNetmask(IPAddress("255.255.255.255"));
    ie->setIPv4Data(ifdata);
    // create meta information
    SimpleInfo* newinfo = new SimpleInfo(type.typeID, node->getId(),
                                         type.context);
    newinfo->setEntry(newentry);
    //add node to bootstrap oracle
    globalNodeList->addPeer(address, newinfo);
    // inform the notification board about the migration
    NotificationBoard* nb = check_and_cast<NotificationBoard*> (
                                      node->getSubmodule("notificationBoard"));
    nb->fireChangeNotification(NF_OVERLAY_TRANSPORTADDRESS_CHANGED);
}

IPvXAddress SimpleUnderlayConfigurator::migrateNode	(	NodeType	type,
		IPvXAddress	addr,
		const BaseLocation &	locID
	)

Definition at line 539 of file SimpleUnderlayConfigurator.cc.

{
    Enter_Method_Silent();
    SimpleNodeEntry* entry = NULL;
        SimpleInfo* info =
              dynamic_cast<SimpleInfo*> (globalNodeList->getPeerInfo(addr));
        if (info != NULL) {
            entry = info->getEntry();
        } else {
            opp_error("SimpleNetConfigurator: Trying to migrate node with "
                      "nonexistent TransportAddress!");
        }
    const NodeRecord* location = dynamic_cast<const NodeRecord*>(&locID);
    entry->setX(location->coords[0]);
    entry->setY(location->coords[1]);
    cGate* gate = entry->getUdpIPv4Gate();
    cModule* node = gate->getOwnerModule()->getParentModule();
    // do not migrate node that is already scheduled
    if (scheduledID.count(node->getId()))
        return addr;
    // FIXME use only IPv4?
    IPvXAddress address = IPAddress(nextFreeAddress++);
    EV << addr << " migrates to ";
    EV << address << "!" << endl;
    SimpleNodeEntry* newentry;
    int chanIndex = intuniform(0, type.channelTypesRx.size() - 1);
    cChannelType* rxChan = cChannelType::find(type.channelTypesRx[chanIndex].c_str());
    cChannelType* txChan = cChannelType::find(type.channelTypesTx[chanIndex].c_str());
    if (!txChan || !rxChan)
         opp_error("Could not find Channel Type. Most likely parameter "
            "channelTypesRx or channelTypes does not match the channels defined in "
             "channels.ned");
    if (useXmlCoords) {
       newentry = new SimpleNodeEntry(node,
                                      rxChan,
                                      txChan,
                                      sendQueueLength,
                                      entry->getNodeRecord(), entry->getRecordIndex());
    } else {
        newentry = new SimpleNodeEntry(node, rxChan, txChan, fieldSize, sendQueueLength);
    }
    node->bubble("I am migrating!");
    //remove node from bootstrap oracle
    NodeHandle* peer = globalNodeList->getNodeHandle(addr);
    NodeHandle registrationPeer;
    if (peer != NULL) {
        registrationPeer = *peer;
    }
    globalNodeList->killPeer(addr);
    SimpleUDP* simple = check_and_cast<SimpleUDP*> (gate->getOwnerModule());
    simple->setNodeEntry(newentry);
    InterfaceEntry* ie = IPAddressResolver().interfaceTableOf(node)->
                                      getInterfaceByName("dummy interface");
    delete ie->ipv4Data();
    // Add pseudo-Interface to node's interfaceTable
    IPv4InterfaceData* ifdata = new IPv4InterfaceData;
    ifdata->setIPAddress(address.get4());
    ifdata->setNetmask(IPAddress("255.255.255.255"));
    ie->setIPv4Data(ifdata);
    // create meta information
    SimpleInfo* newinfo = new SimpleInfo(type.typeID, node->getId(),
                                         type.context);
    newinfo->setEntry(newentry);
    //add node to bootstrap oracle
    globalNodeList->addPeer(address, newinfo);
    if (peer != NULL){
        registrationPeer.setIp(address);
        globalNodeList->registerPeer(registrationPeer);
    }
//    check_and_cast<>BaseRpc>(simulation.getModule(newinfo->getModuleID())->getSubmodule("tier1"));
    // inform the notification board about the migration
    NotificationBoard* nb = check_and_cast<NotificationBoard*> (
                                      node->getSubmodule("notificationBoard"));
    nb->fireChangeNotification(NF_OVERLAY_TRANSPORTADDRESS_CHANGED);
    return address;
}

uint32_t SimpleUnderlayConfigurator::parseCoordFile ( const char * nodeCoordinateSource )

protected

Definition at line 260 of file SimpleUnderlayConfigurator.cc.

{
    cXMLElement* rootElement = ev.getXMLDocument(nodeCoordinateSource);
    // get number of dimensions from attribute of xml rootelement
    dimensions = atoi(rootElement->getAttribute("dimensions"));
    NodeRecord::setDim(dimensions);
    EV << "[SimpleNetConfigurator::parseCoordFile()]\n"
       << "    using " << dimensions << " dimensions: ";
    double max_coord = 0;
    for (cXMLElement *tmpElement = rootElement->getFirstChild(); tmpElement;
         tmpElement = tmpElement->getNextSibling()) {
        // get "ip" and "isRoot" from Attributes (not needed yet)
      /*
       const char* str_ip = tmpElement->getAttribute("ip");
       int tmpIP = 0;
       if (str_ip) sscanf(str_ip, "%x", &tmpIP);
       bool tmpIsRoot = atoi(tmpElement->getAttribute("isroot"));
       */
        // create tmpNode to be added to vector
        NodeRecord* tmpNode = new NodeRecord;
        // get coords from childEntries and fill tmpNodes Array
        int i = 0;
        for (cXMLElement *coord = tmpElement->getFirstChild(); coord;
             coord = coord->getNextSibling()) {
            tmpNode->coords[i] = atof(coord->getNodeValue());
            double newMax = fabs(tmpNode->coords[i]);
            if (newMax > max_coord) {
               max_coord = newMax;
            }
            i++;
        }
        // add to vector
        nodeRecordPool.push_back(make_pair(tmpNode, true));
        //if (nodeRecordPool.size() >= maxSize) break; //TODO use other xml lib
    }
    EV << nodeRecordPool.size()
       << " nodes added to vector \"nodeRecordPool\"." << endl;
#if OMNETPP_VERSION>=0x0401
    // free memory used for xml document
    ev.forgetXMLDocument(nodeCoordinateSource);
#if !defined(__APPLE__) &&  !defined(_WIN32) && !defined(__ANDROID__)
    malloc_trim(0);
#endif
#endif
    return (uint32_t)ceil(max_coord);
}

void SimpleUnderlayConfigurator::preKillNode	(	NodeType	type,
		TransportAddress *	addr = `NULL`
	)

virtual

Notifies and schedules overlay nodes for removal.

Parameters

type	NodeType of the node to remove
addr	NULL for random node

Implements UnderlayConfigurator.

Definition at line 320 of file SimpleUnderlayConfigurator.cc.

{
    Enter_Method_Silent();
    SimpleNodeEntry* entry = NULL;
    SimpleInfo* info;
    if (addr == NULL) {
        addr = globalNodeList->getRandomAliveNode(type.typeID);
        if (addr == NULL) {
            // all nodes are already prekilled
            std::cout << "all nodes are already prekilled" << std::endl;
            return;
        }
    }
    info = dynamic_cast<SimpleInfo*> (globalNodeList->getPeerInfo(*addr));
    if (info != NULL) {
        entry = info->getEntry();
        globalNodeList->setPreKilled(*addr);
    } else {
        opp_error("SimpleNetConfigurator: Trying to pre kill node "
                  "with nonexistant TransportAddress!");
    }
    uint32_t effectiveType = info->getTypeID();
    cGate* gate = entry->getUdpIPv4Gate();
    cModule* node = gate->getOwnerModule()->getParentModule();
    if (scheduledID.count(node->getId())) {
        std::cout << "SchedID" << std::endl;
        return;
    }
    // remove node from bootstrap oracle
    globalNodeList->removePeer(IPAddressResolver().addressOf(node));
    // put node into the kill list and schedule a message for final removal
    // of the node
    killList.push_front(IPAddressResolver().addressOf(node));
    scheduledID.insert(node->getId());
    overlayTerminalCount--;
    numKilled++;
    churnGenerator[effectiveType]->terminalCount--;
    // update display
    setDisplayString();
    // inform the notification board about the removal
    NotificationBoard* nb = check_and_cast<NotificationBoard*> (
                             node-> getSubmodule("notificationBoard"));
    nb->fireChangeNotification(NF_OVERLAY_NODE_LEAVE);
    double random = uniform(0, 1);
    if (random < gracefulLeaveProbability) {
        nb->fireChangeNotification(NF_OVERLAY_NODE_GRACEFUL_LEAVE);
    }
    cMessage* msg = new cMessage();
    scheduleAt(simTime() + gracefulLeaveDelay, msg);
}

void SimpleUnderlayConfigurator::setDisplayString ( )

protectedvirtual

Prints statistics.

Implements UnderlayConfigurator.

Definition at line 515 of file SimpleUnderlayConfigurator.cc.

{
    // Updates the statistics display string.
    char buf[80];
    sprintf(buf, "%i overlay terminals", overlayTerminalCount);
    getDisplayString().setTagArg("t", 0, buf);
}