LinkMon Class Reference

#include <LinkMon.h>

Inheritance diagram for LinkMon:

List of all members.

Protected Member Functions
virtual void	initialize (int stage)
virtual int	numInitStages () const
virtual void	handleMessage (cMessage *msg)
virtual void	report ()
Protected Attributes
double	pollInt
	Interval between polling for statistics.
double	reportInt
	The interval of sending report to the Topology Manager.
LinkTable	links
	All the monitored links.
FwTable *	fwt
	Pointer to the Forwarding Table of the Router.
TMInterface *	tm
	Pointer to the Topology Manager for sending messages.

---

Detailed Description

The Link Monitor application. Reports in random intervals to the Topology Manager information about the link status.

---

Member Function Documentation

void LinkMon::handleMessage

(

cMessage *

msg

)

[protected, virtual]

This module is not supposed to receive any messages. It also deal with self messages for internal functions.

Reimplemented from cSimpleModule.

{
        if (msg->isSelfMessage())
        {
                //Self message to create or delete a new publication
                if(strcmp(msg->getFullName(),"LinkUpdate")==0) {

                        // For each link... update...
                        for (unsigned int i=0; i<links.size(); i++){
                                // Finally do the job
                                links[i].update();
                        }

                        //Reschedule message
                        scheduleAt(simTime()+pollInt, msg);
                }
                else if(strcmp(msg->getFullName(),"LSReport")==0) {

                        //Report to the TM
                        report();

                        //Reschedule reporting
                        scheduleAt(simTime()+reportInt, msg);
                }
        }
}

void LinkMon::initialize

(

int

stage

)

[protected, virtual]

Initialized the parameters of the class.

Reimplemented from cComponent.

{
        if(stage==1) {
                reportInt=this->par("reportInt").doubleValue();

                //Access Interface and Forwarding Table
                fwt = FwTableAccess().get();

                //For all interface in Forwarding Table, initialize Link Table
                for (int i=0; i<fwt->getNumRoutes(); i++) {
                        Link l;
                        l.lid=fwt->getLID(i);

                        //l.cap = this->getParentModule()->getParentModule()->par("Datarate").doubleValue();
                        l.nettype = NT_ETH;

                        //Get Interface Name
                        string name=fwt->getInterfaceName(i);

                        //Look for the position of the first number in the string
                        size_t pos=name.find_first_of("0123456789");

                        //If the interface has indeed an index number
                        if(pos!=string::npos){

                                //Create interface name
                                stringstream fullname;
                                fullname << name.substr(0,pos) << "[" << name.substr(pos,name.size()) << "]";

                                // Find the gate according to the interface number and get the channel datarate!
                                for (cModule::GateIterator i(this->getParentModule()); !i.end(); i++) {
                                        cGate *gate = i();
                                        //If this is an output gate
                                        if( strcmp(cGate::getTypeName(gate->getType()),"output")==0 ) {
                                                //If the gate index is the same as the interface index
                                                if(atoi(name.substr(pos,name.size()).c_str()) == gate->getIndex()) {
                                                        cDatarateChannel *mychannel = check_and_cast<cDatarateChannel *>(gate->getTransmissionChannel());
                                                        //Set the capacity in Mbps
                                                        l.cap = mychannel->getDatarate()/pow(10,6);
                                                }
                                        }
                                }

                                //Find correct interface
                                cModule *m = findModuleWhereverInNode(fullname.str().c_str(), this->getParentModule());

                                //Access the throughput meter and submodules of the network interface
                                l.thr = check_and_cast<ThrPutMeter *>(m->getSubmodule("thruputMeter"));
                                //If the is a problem with the throughput meter
                                if(!l.thr) {
                                        ev << "Interface " << name << " of module " << this->getParentModule()->getFullName() << " doesn't have a throughput meter!" << endl;
                                }

                                //Access the queue submodule of the network interface
                                l.queue = check_and_cast<ReportDTQueue *>(m->getSubmodule("queue"));
                                //If the is a problem with the throughput meter
                                if(!l.queue) {
                                        ev << "Interface " << name << " of module " << this->getParentModule()->getFullName() << " doesn't have a readable queue!" << endl;
                                }

                                //Access the forwarding entry of the network interface
                                l.FwEntry = fwt->getFwRoute(l.lid);
                                //If the is a problem with the throughput meter
                                if(!l.FwEntry) {
                                        ev << "FwTable of module " << this->getParentModule()->getFullName() << " doesn't have the requested entry!" << endl;
                                }

                                //Adding link to the link monitoring table
                                links.push_back(l);
                        }
                        //Otherwise print an error
                        else
                                opp_error("Erroneous interface given to Link Monitor module as input.");
                }
                WATCH_VECTOR(links);

                //Generate self message for updating the link status
                pollInt = par("pollInt").doubleValue();
                cMessage *linkUpdate = new cMessage("LinkUpdate");
                scheduleAt(simTime()+pollInt, linkUpdate);

                //Generate self message for reporting to the TM
                reportInt = par("reportInt").doubleValue();
                cMessage *linkReport = new cMessage("LSReport");
                scheduleAt(simTime()+reportInt, linkReport);
        }
        if(stage==2) {
                //Set pointer to the topology manager module
                tm = check_and_cast<TMInterface *>(simulation.getModuleByPath("tm"));
        }
}

virtual int LinkMon::numInitStages

(

)

const [inline, protected, virtual]

Returns the number of initialization stages.

Reimplemented from cComponent.

{return 4;}

void LinkMon::report

(

)

[protected, virtual]

Reports the acquired QoS statistics from each link to the Topology Manager. It's being call by the handleMessage() function, whenever the correct self messages arives.

                     {

        //If there are no link to report, do nothing
        if (links.size()==0){
                ev << "LinkMon: No Links on this router!!!" << endl;
                return;
        }

        //Create report message
        LSMPacket *lsmPacket = new LSMPacket("LSMPacket");

        //Set data
        lsmPacket->setType(QoS_REPORT);
        lsmPacket->setNodeID(this->getParentModule()->getName());

        //Set the report length
        lsmPacket->setRepLen(links.size());

        //Fix the array sizes
        lsmPacket->setLinkStatusArraySize(links.size());
        lsmPacket->setLidArraySize(links.size());

        // For each link append status and LID
        for (unsigned int i=0; i<links.size(); i++){
                lsmPacket->setLid(i,links[i].lid.c_str());
            lsmPacket->setLinkStatus(i,links[i].status);
        }

        this->sendDirect(lsmPacket, tm, tm->findGate("TMin"));
}

---

Member Data Documentation

FwTable* LinkMon::fwt [protected]

Pointer to the Forwarding Table of the Router.

LinkTable LinkMon::links [protected]

All the monitored links.

double LinkMon::pollInt [protected]

Interval between polling for statistics.

double LinkMon::reportInt [protected]

The interval of sending report to the Topology Manager.

TMInterface* LinkMon::tm [protected]

Pointer to the Topology Manager for sending messages.

---

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

• LinkMon.h
• LinkMon.cc