inet::IPvXTrafSink Class Reference

Consumes and prints packets received from the IP module. More...

#include <IPvXTrafSink.h>

Inheritance diagram for inet::IPvXTrafSink:

Protected Member Functions
virtual void	printPacket (cPacket *msg)
virtual void	processPacket (cPacket *msg)
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	handleMessage (cMessage *msg) override
virtual void	refreshDisplay () const override
virtual bool	handleOperationStage (LifecycleOperation *operation, int stage, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...

Protected Attributes
int	numReceived
bool	isOperational

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

Additional Inherited Members
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()

Detailed Description

Consumes and prints packets received from the IP module.

See NED for more info.

Member Function Documentation

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

overrideprotectedvirtual

{
    if (!isOperational) {
        EV_ERROR << "Module is down, received " << msg->getName() << " message dropped\n";
        delete msg;
        return;
    }
    processPacket(check_and_cast<cPacket *>(msg));
}

bool inet::IPvXTrafSink::handleOperationStage ( LifecycleOperation *  operation, int  stage, IDoneCallback *  doneCallback  )

overrideprotectedvirtual

Perform one stage of a lifecycle operation.

Processing may be done entirely within this method, or may be a longer process that involves nonzero simulation time or several events, and is triggered by this method call.

Return value: true = "done"; false = "not yet done, will invoke doneCallback when done"

Implements inet::ILifecycle.

{
    Enter_Method_Silent();
    if (dynamic_cast<NodeStartOperation *>(operation))
        isOperational = true;
    else if (dynamic_cast<NodeShutdownOperation *>(operation))
        isOperational = false;
    else if (dynamic_cast<NodeCrashOperation *>(operation))
        isOperational = false;
    else
        throw cRuntimeError("Unsupported lifecycle operation '%s'", operation->getClassName());
    return true;
}

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

overrideprotectedvirtual

{
    cSimpleModule::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        numReceived = 0;
        WATCH(numReceived);
    }
    else if (stage == INITSTAGE_APPLICATION_LAYER) {
        int protocol = par("protocol");
        IPSocket ipSocket(gate("ipOut"));
        ipSocket.registerProtocol(protocol);

        NodeStatus *nodeStatus = dynamic_cast<NodeStatus *>(findContainingNode(this)->getSubmodule("status"));
        isOperational = (!nodeStatus) || nodeStatus->getState() == NodeStatus::UP;
    }
}

virtual int inet::IPvXTrafSink::numInitStages ( ) const

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

void inet::IPvXTrafSink::printPacket ( cPacket *  msg )

protectedvirtual

Referenced by processPacket().

{
    L3Address src, dest;
    int protocol = -1;

    INetworkProtocolControlInfo *ctrl = dynamic_cast<INetworkProtocolControlInfo *>(msg->getControlInfo());

    if (ctrl != nullptr) {
        src = ctrl->getSourceAddress();
        dest = ctrl->getDestinationAddress();
        protocol = ctrl->getTransportProtocol();
    }

    EV_INFO << msg << endl;
    EV_INFO << "Payload length: " << msg->getByteLength() << " bytes" << endl;

    if (ctrl != nullptr)
        EV_INFO << "src: " << src << "  dest: " << dest << "  protocol=" << protocol << endl;
}

void inet::IPvXTrafSink::processPacket ( cPacket *  msg )

protectedvirtual

Referenced by handleMessage().

{
    emit(rcvdPkSignal, msg);
    EV_INFO << "Received packet: ";
    printPacket(msg);
    delete msg;
    numReceived++;
}

void inet::IPvXTrafSink::refreshDisplay ( ) const

overrideprotectedvirtual

{
    char buf[32];
    sprintf(buf, "rcvd: %d pks", numReceived);
    getDisplayString().setTagArg("t", 0, buf);
}

Member Data Documentation

bool inet::IPvXTrafSink::isOperational

protected

Referenced by handleMessage(), handleOperationStage(), and initialize().

int inet::IPvXTrafSink::numReceived

protected

Referenced by initialize(), processPacket(), and refreshDisplay().

simsignal_t inet::IPvXTrafSink::rcvdPkSignal = registerSignal("rcvdPk")

staticprotected

Referenced by processPacket().

---

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

• IPvXTrafSink.h
• IPvXTrafSink.cc