Measures and records network thruput. More...

#include <ThruputMeter.h>

Inheritance diagram for inet::ThruputMeter:

Protected Member Functions
virtual void	updateStats (simtime_t now, unsigned long bits)

virtual void	beginNewInterval (simtime_t now)

virtual void	initialize () override

virtual void	handleMessage (cMessage *msg) override

virtual void	finish () override

Protected Attributes
simtime_t	startTime

unsigned int	batchSize

simtime_t	maxInterval

unsigned long	numPackets

unsigned long	numBits

simtime_t	intvlStartTime

simtime_t	intvlLastPkTime

unsigned long	intvlNumPackets

unsigned long	intvlNumBits

cOutVector	bitpersecVector

cOutVector	pkpersecVector

Detailed Description

Measures and records network thruput.

Member Function Documentation

void inet::ThruputMeter::beginNewInterval ( simtime_t now )

protectedvirtual

Referenced by updateStats().

 {
     simtime_t duration = now - intvlStartTime;
 
     // record measurements
     double bitpersec = intvlNumBits / duration.dbl();
     double pkpersec = intvlNumPackets / duration.dbl();
 
     bitpersecVector.recordWithTimestamp(intvlStartTime, bitpersec);
     pkpersecVector.recordWithTimestamp(intvlStartTime, pkpersec);
 
     // restart counters
     intvlStartTime = now;    // FIXME this should be *beginning* of tx of this packet, not end!
     intvlNumPackets = intvlNumBits = 0;
 }

void inet::ThruputMeter::finish ( )

overrideprotectedvirtual

 {
     simtime_t duration = simTime() - startTime;
 
     recordScalar("duration", duration);
     recordScalar("total packets", numPackets);
     recordScalar("total bits", numBits);
 
     recordScalar("avg throughput (bit/s)", numBits / duration.dbl());
     recordScalar("avg packets/s", numPackets / duration.dbl());
 }

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

overrideprotectedvirtual

 {
     updateStats(simTime(), PK(msg)->getBitLength());
     send(msg, "out");
 }

void inet::ThruputMeter::initialize ( )

overrideprotectedvirtual

 {
     startTime = par("startTime");
     long _batchSize = par("batchSize");
     if ((_batchSize < 0) || (((long)(unsigned int)_batchSize) != _batchSize))
         throw cRuntimeError("Invalid 'batchSize=%ld' parameter at '%s' module", _batchSize, getFullPath().c_str());
     batchSize = (unsigned int)_batchSize;
     maxInterval = par("maxInterval");
 
     numPackets = numBits = 0;
     intvlStartTime = intvlLastPkTime = 0;
     intvlNumPackets = intvlNumBits = 0;
 
     WATCH(numPackets);
     WATCH(numBits);
     WATCH(intvlStartTime);
     WATCH(intvlNumPackets);
     WATCH(intvlNumBits);
 
     bitpersecVector.setName("thruput (bit/sec)");
     pkpersecVector.setName("packet/sec");
 }

void inet::ThruputMeter::updateStats	(	simtime_t	now,
		unsigned long	bits
	)

protectedvirtual

Referenced by handleMessage().

 {
     numPackets++;
     numBits += bits;
 
     // packet should be counted to new interval
     if (intvlNumPackets >= batchSize || now - intvlStartTime >= maxInterval)
         beginNewInterval(now);
 
     intvlNumPackets++;
     intvlNumBits += bits;
     intvlLastPkTime = now;
 }