DTApp Class Reference

#include <DTApp.h>

List of all members.

Protected Types
typedef std::map< int, std::vector< int > >	SourceSequence
Protected Member Functions
virtual void	finish ()
	the finish function of the module
virtual void	processPacket (cPacket *msg)
	processes the received packets
Protected Attributes
SourceSequence	sourceSequence
	To be used for recording the received packets.

---

Member Typedef Documentation

typedef std::map<int,std::vector<int> > DTApp::SourceSequence [protected]

---

Member Function Documentation

void DTApp::finish

(

)

[protected, virtual]

the finish function of the module

{


    simtime_t t = simTime();
    if (t==0) return;

    recordScalar("Total send", numSent);
    recordScalar("Total received", numReceived);
    recordScalar("Total deleted", numDeleted);
//    recordScalar("Mean delay", meanDelay/numReceived);
    recordScalar("Mean delay", pktDelay->getMean());
    recordScalar("Min delay", pktDelay->getMin());
    recordScalar("Max delay", pktDelay->getMax());
    recordScalar("Deviation delay", pktDelay->getStddev());
    if(numSent!=0)
        recordScalar("AvgDelivery", (numReceived*100)/numSent);
    else
        recordScalar("AvgDelivery", 0);
    delete pktDelay;
        pktDelay = NULL;
}

void DTApp::processPacket

(

cPacket *

msg

)

[protected, virtual]

processes the received packets

{

    if (msg->getKind()== UDP_I_ERROR)
    {
        delete msg;
        return;
    }

    if (msg->hasPar("sourceId"))
    {
        // duplicate control
        int moduleId = (int) msg->par("sourceId");
        int msgId = msg->par("msgId");
        SourceSequence::iterator i;
        i = sourceSequence.find(moduleId);
        //If we have received before from this node
        if (i!=sourceSequence.end())
        {
            if (std::find(i->second.begin(),i->second.end(), msgId)!=i->second.end())
            {
                EV << "Duplicated packet: ";
                printPacket(msg);
                delete msg;
                numDeleted++;
                return;
            }
            else
                i->second.push_back(msgId);
        }
        //Else create new record
        else {
            std::vector<int> tmp_vector;
            tmp_vector.push_back(msgId);
            sourceSequence[moduleId] = tmp_vector;
        }

    }
    if (limitDelay>=0)
        if (simTime()-msg->getTimestamp()>limitDelay)
        {
            EV << "Old packet: ";
            printPacket(msg);
            delete msg;
            numDeleted++;
            return;
        }

    EV << "Received packet: ";
    printPacket(msg);
    pktDelay->collect(simTime()-msg->getTimestamp());
    //meanDelay += (msg->getTimestamp()-simTime());
    delete msg;

    numReceived++;
    if (numShare)
        numShare[1]++;
}

---

Member Data Documentation

SourceSequence DTApp::sourceSequence [protected]

To be used for recording the received packets.

---

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

• DTApp.h
• DTApp.cc