Ordinal Based Dropper module. More...

#include <OrdinalBasedDropper.h>

Inheritance diagram for inet::OrdinalBasedDropper:

Protected Member Functions
virtual void	initialize () override

virtual void	handleMessage (cMessage *msg) override

virtual void	parseVector (const char *vector)

virtual void	finish () override

Protected Attributes
unsigned int	numPackets

unsigned int	numDropped

bool	generateFurtherDrops

std::vector< unsigned int >	dropsVector

Static Protected Attributes
static simsignal_t	rcvdPkSignal = registerSignal("rcvdPk")

static simsignal_t	sentPkSignal = registerSignal("sentPk")

static simsignal_t	dropPkSignal = registerSignal("dropPk")

Detailed Description

Ordinal Based Dropper module.

Member Function Documentation

void inet::OrdinalBasedDropper::finish ( )

overrideprotectedvirtual

105 {

106 }

void inet::OrdinalBasedDropper::handleMessage ( cMessage * msg )

overrideprotectedvirtual

 {
     numPackets++;
     emit(rcvdPkSignal, msg);
 
     if (generateFurtherDrops) {
         if (numPackets == dropsVector[0]) {
             EV << "DropsGenerator: Dropping packet number " << numPackets << " " << msg << endl;
             emit(dropPkSignal, msg);
             delete msg;
             numDropped++;
             dropsVector.erase(dropsVector.begin());
             if (dropsVector.size() == 0) {
                 EV << "DropsGenerator: End of dropsVector reached." << endl;
                 generateFurtherDrops = false;
             }
             return;    // drop message
         }
     }
     emit(sentPkSignal, msg);
     send(msg, "out");
 }

void inet::OrdinalBasedDropper::initialize ( )

overrideprotectedvirtual

 {
     numPackets = 0;
     numDropped = 0;
     generateFurtherDrops = false;
 
     WATCH(numPackets);
     WATCH(numDropped);
     WATCH(generateFurtherDrops);
 
     const char *vector = par("dropsVector");
     parseVector(vector);
 
     if (dropsVector.size() == 0) {
         EV << "DropsGenerator: Empty dropsVector" << endl;
     }
     else {
         EV << "DropsGenerator: dropsVector=" << vector << endl;
         generateFurtherDrops = true;
     }
 }

void inet::OrdinalBasedDropper::parseVector ( const char * vector )

protectedvirtual

Referenced by initialize().

 {
     const char *v = vector;
     while (*v) {
         // parse packet numbers
         while (isspace(*v))
             v++;
         if (!*v || *v == ';')
             break;
         if (!isdigit(*v))
             throw cRuntimeError("Syntax error in dropsVector: packet number expected");
         if (dropsVector.size() > 0 && dropsVector.back() >= (unsigned int)atoi(v))
             throw cRuntimeError("Syntax error in dropsVector: packet numbers in ascending order expected");
 
         dropsVector.push_back(atoi(v));
         while (isdigit(*v))
             v++;
 
         // skip delimiter
         while (isspace(*v))
             v++;
         if (!*v)
             break;
         if (*v != ';')
             throw cRuntimeError("Syntax error in dropsVector: separator ';' missing");
         v++;
         while (isspace(*v))
             v++;
     }
 }