inet::TcpSinkAppThread Class Reference

#include <TcpSinkApp.h>

Inheritance diagram for inet::TcpSinkAppThread:

Protected Member Functions
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	refreshDisplay () const override
virtual void	established () override
	Called when connection is established. More...
virtual void	dataArrived (Packet *msg, bool urgent) override
virtual void	timerExpired (cMessage *timer) override
virtual void	init (TcpServerHostApp *hostmodule, TcpSocket *socket) override
Protected Member Functions inherited from inet::TcpServerThreadBase
virtual void	socketDataArrived (TcpSocket *socket, Packet *msg, bool urgent) override
	Notifies about data arrival, packet ownership is transferred to the callee. More...
virtual void	socketAvailable (TcpSocket *socket, TcpAvailableInfo *availableInfo) override
virtual void	socketEstablished (TcpSocket *socket) override
virtual void	socketPeerClosed (TcpSocket *socket) override
virtual void	socketClosed (TcpSocket *socket) override
virtual void	socketFailure (TcpSocket *socket, int code) override
virtual void	socketStatusArrived (TcpSocket *socket, TcpStatusInfo *status) override
virtual void	socketDeleted (TcpSocket *socket) override

Protected Attributes
long	bytesRcvd
TcpSinkApp *	sinkAppModule = nullptr
Protected Attributes inherited from inet::TcpServerThreadBase
TcpServerHostApp *	hostmod
TcpSocket *	sock

Additional Inherited Members
Public Member Functions inherited from inet::TcpServerThreadBase
	TcpServerThreadBase ()
virtual	~TcpServerThreadBase ()
virtual TcpSocket *	getSocket ()
virtual TcpServerHostApp *	getHostModule ()
virtual void	peerClosed ()
virtual void	failure (int code)
virtual void	statusArrived (TcpStatusInfo *status)
Public Member Functions inherited from inet::TcpSocket::ICallback
virtual	~ICallback ()

Member Function Documentation

dataArrived()

void inet::TcpSinkAppThread::dataArrived ( Packet *  msg, bool  urgent  )

overrideprotectedvirtual

Implements inet::TcpServerThreadBase.

{
    long packetLength = pk->getByteLength();
    bytesRcvd += packetLength;
    sinkAppModule->bytesRcvd += packetLength;
 
    emit(packetReceivedSignal, pk);
    delete pk;
}

established()

void inet::TcpSinkAppThread::established ( )

overrideprotectedvirtual

Called when connection is established.

Implements inet::TcpServerThreadBase.

{
    bytesRcvd = 0;
}

init()

virtual void inet::TcpSinkAppThread::init ( TcpServerHostApp *  hostmodule, TcpSocket *  socket  )

inlineoverrideprotectedvirtual

Reimplemented from inet::TcpServerThreadBase.

{ TcpServerThreadBase::init(hostmodule, socket); sinkAppModule = check_and_cast<TcpSinkApp *>(hostmod); }

initialize()

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

overrideprotectedvirtual

{
    TcpServerThreadBase::initialize(stage);
 
    if (stage == INITSTAGE_LOCAL) {
        bytesRcvd = 0;
        WATCH(bytesRcvd);
    }
}

numInitStages()

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

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

refreshDisplay()

void inet::TcpSinkAppThread::refreshDisplay ( ) const

overrideprotectedvirtual

Reimplemented from inet::TcpServerThreadBase.

{
    std::ostringstream os;
    os << (sock ? TcpSocket::stateName(sock->getState()) : "NULL_SOCKET") << "\nrcvd: " << bytesRcvd << " bytes";
    getDisplayString().setTagArg("t", 0, os.str().c_str());
}

timerExpired()

virtual void inet::TcpSinkAppThread::timerExpired ( cMessage *  timer )

inlineoverrideprotectedvirtual

Implements inet::TcpServerThreadBase.

{ throw cRuntimeError("Model error: unknown timer message arrived"); }

Member Data Documentation

bytesRcvd

long inet::TcpSinkAppThread::bytesRcvd

protected

Referenced by dataArrived(), established(), initialize(), and refreshDisplay().

sinkAppModule

TcpSinkApp* inet::TcpSinkAppThread::sinkAppModule = nullptr

protected

Referenced by dataArrived().

---

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

• TcpSinkApp.h
• TcpSinkApp.cc