inet::TCPSinkApp Class Reference

Accepts any number of incoming connections, and discards whatever arrives on them. More...

#include <TCPSinkApp.h>

Inheritance diagram for inet::TCPSinkApp:

Protected Member Functions
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	handleMessage (cMessage *msg) override
virtual void	finish () 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
long	bytesRcvd
TCPSocket	socket

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

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

Detailed Description

Accepts any number of incoming connections, and discards whatever arrives on them.

Member Function Documentation

void inet::TCPSinkApp::finish ( )

overrideprotectedvirtual

{
}

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

overrideprotectedvirtual

{
    if (msg->getKind() == TCP_I_PEER_CLOSED) {
        // we close too
        msg->setName("close");
        msg->setKind(TCP_C_CLOSE);
        send(msg, "tcpOut");
    }
    else if (msg->getKind() == TCP_I_DATA || msg->getKind() == TCP_I_URGENT_DATA) {
        cPacket *pk = PK(msg);
        long packetLength = pk->getByteLength();
        bytesRcvd += packetLength;
        emit(rcvdPkSignal, pk);
        delete msg;
    }
    else {
        // must be data or some kind of indication -- can be dropped
        delete msg;
    }
}

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

inlineoverrideprotectedvirtual

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(); throw cRuntimeError("Unsupported lifecycle operation '%s'", operation->getClassName()); return true; }

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

overrideprotectedvirtual

{
    cSimpleModule::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        bytesRcvd = 0;
        WATCH(bytesRcvd);
    }
    else if (stage == INITSTAGE_APPLICATION_LAYER) {
        bool isOperational;
        NodeStatus *nodeStatus = dynamic_cast<NodeStatus *>(findContainingNode(this)->getSubmodule("status"));
        isOperational = (!nodeStatus) || nodeStatus->getState() == NodeStatus::UP;
        if (!isOperational)
            throw cRuntimeError("This module doesn't support starting in node DOWN state");

        const char *localAddress = par("localAddress");
        int localPort = par("localPort");
        socket.setOutputGate(gate("tcpOut"));
        socket.readDataTransferModePar(*this);
        socket.bind(localAddress[0] ? L3AddressResolver().resolve(localAddress) : L3Address(), localPort);
        socket.listen();
    }
}

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

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

void inet::TCPSinkApp::refreshDisplay ( ) const

overrideprotectedvirtual

{
    std::ostringstream os;
    os << TCPSocket::stateName(socket.getState()) << "\nrcvd: " << bytesRcvd << " bytes";
    getDisplayString().setTagArg("t", 0, os.str().c_str());
}

Member Data Documentation

long inet::TCPSinkApp::bytesRcvd

protected

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

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

staticprotected

Referenced by handleMessage().

TCPSocket inet::TCPSinkApp::socket

protected

Referenced by initialize(), and refreshDisplay().

---

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

• TCPSinkApp.h
• TCPSinkApp.cc