inet::ResidenceTimeMeasurer Class Reference

#include <ResidenceTimeMeasurer.h>

Inheritance diagram for inet::ResidenceTimeMeasurer:

Public Member Functions
virtual void	receiveSignal (cComponent *source, simsignal_t signal, cObject *object, cObject *details) override

Static Public Attributes
static simsignal_t	packetStayedSignal = cComponent::registerSignal("packetStayed")

Protected Member Functions
virtual void	initialize (int stage) override

Member Function Documentation

initialize()

void inet::ResidenceTimeMeasurer::initialize ( int  stage )

overrideprotectedvirtual

{
    if (stage == INITSTAGE_LOCAL) {
        auto subscriptionModule = getModuleFromPar<cModule>(par("subscriptionModule"), this);
        auto measurementStartSignal = registerSignal(par("measurementStartSignal"));
        auto measurementEndSignal = registerSignal(par("measurementEndSignal"));
        subscriptionModule->subscribe(measurementStartSignal, this);
        subscriptionModule->subscribe(measurementEndSignal, this);
        subscriptionModule->subscribe(packetCreatedSignal, this);
        subscriptionModule->subscribe(packetDroppedSignal, this);
    }
}

receiveSignal()

void inet::ResidenceTimeMeasurer::receiveSignal ( cComponent *  source, simsignal_t  signal, cObject *  object, cObject *  details  )

overridevirtual

{
    if (signal == packetCreatedSignal) {
        auto packet = check_and_cast<Packet *>(object);
        b offset = b(0);
        b length = packet->getDataLength();
        packet->addRegionTagsWhereAbsent<ResidenceTimeTag>(offset, length);
        packet->mapAllRegionTagsForUpdate<ResidenceTimeTag>(offset, length, [&] (b o, b l, const Ptr<ResidenceTimeTag>& tag) {
            tag->setStartTime(simTime());
        });
    }
    else if (signal == packetDroppedSignal) {
        auto packet = check_and_cast<Packet *>(object);
        b offset = b(0);
        b length = packet->getDataLength();
        packet->mapAllRegionTagsForUpdate<ResidenceTimeTag>(offset, length, [&] (b o, b l, const Ptr<ResidenceTimeTag>& tag) {
            tag->setEndTime(simTime());
        });
        emit(packetStayedSignal, packet);
        packet->removeRegionTagsWherePresent<ResidenceTimeTag>(offset, length);
    }
    else {
        auto physicalSignal = check_and_cast<cPacket *>(object);
        auto packet = check_and_cast<Packet *>(physicalSignal->getEncapsulatedPacket());
        b offset = b(0);
        b length = packet->getDataLength();
        if (signal == receptionStartedSignal) {
            packet->addRegionTagsWhereAbsent<ResidenceTimeTag>(offset, length);
            packet->mapAllRegionTagsForUpdate<ResidenceTimeTag>(offset, length, [&] (b o, b l, const Ptr<ResidenceTimeTag>& tag) {
                tag->setStartTime(simTime());
            });
        }
        else if (signal == receptionEndedSignal) {
            packet->addRegionTagsWhereAbsent<ResidenceTimeTag>(offset, length);
            packet->mapAllRegionTagsForUpdate<ResidenceTimeTag>(offset, length, [&] (b o, b l, const Ptr<ResidenceTimeTag>& tag) {
                tag->setStartTime(simTime());
            });
        }
        else if (signal == transmissionStartedSignal) {
            packet->mapAllRegionTagsForUpdate<ResidenceTimeTag>(offset, length, [&] (b o, b l, const Ptr<ResidenceTimeTag>& tag) {
                tag->setEndTime(simTime());
            });
            emit(packetStayedSignal, packet);
            packet->removeRegionTagsWherePresent<ResidenceTimeTag>(offset, length);
        }
        else if (signal == transmissionEndedSignal) {
            packet->mapAllRegionTagsForUpdate<ResidenceTimeTag>(offset, length, [&] (b o, b l, const Ptr<ResidenceTimeTag>& tag) {
                tag->setEndTime(simTime());
            });
            emit(packetStayedSignal, packet);
            packet->removeRegionTagsWherePresent<ResidenceTimeTag>(offset, length);
        }
        else
            throw cRuntimeError("Unknown signal");
    }
}

Member Data Documentation

packetStayedSignal

simsignal_t inet::ResidenceTimeMeasurer::packetStayedSignal = cComponent::registerSignal("packetStayed")

static

Referenced by receiveSignal().

---

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

• ResidenceTimeMeasurer.h
• ResidenceTimeMeasurer.cc