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:

Public Member Functions
	TcpSinkApp ()
	~TcpSinkApp ()
Public Member Functions inherited from inet::TcpServerHostApp
virtual	~TcpServerHostApp ()
virtual void	removeThread (TcpServerThreadBase *thread)
virtual void	threadClosed (TcpServerThreadBase *thread)
Public Member Functions inherited from inet::ApplicationBase
	ApplicationBase ()
Public Member Functions inherited from inet::OperationalMixin< cSimpleModule >
virtual	~OperationalMixin ()
	}@ More...
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()
Public Member Functions inherited from inet::TcpSocket::ICallback
virtual	~ICallback ()

Protected Member Functions
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	finish () override
virtual void	refreshDisplay () const override
Protected Member Functions inherited from inet::TcpServerHostApp
virtual void	handleMessageWhenUp (cMessage *msg) override
virtual void	socketDataArrived (TcpSocket *socket, Packet *packet, 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
virtual void	handleStartOperation (LifecycleOperation *operation) override
virtual void	handleStopOperation (LifecycleOperation *operation) override
virtual void	handleCrashOperation (LifecycleOperation *operation) override
Protected Member Functions inherited from inet::ApplicationBase
virtual bool	isInitializeStage (int stage) const override
virtual bool	isModuleStartStage (int stage) const override
virtual bool	isModuleStopStage (int stage) const override
Protected Member Functions inherited from inet::OperationalMixin< cSimpleModule >
virtual int	numInitStages () const override
virtual void	refreshDisplay () const override
virtual void	handleMessage (cMessage *msg) override
virtual void	handleMessageWhenDown (cMessage *msg)
virtual bool	handleOperationStage (LifecycleOperation *operation, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...
virtual State	getInitialOperationalState () const
	Returns initial operational state: OPERATING or NOT_OPERATING. More...
virtual void	handleActiveOperationTimeout (cMessage *message)
virtual bool	isUp () const
	utility functions More...
virtual bool	isDown () const
virtual void	setOperationalState (State newState)
virtual void	scheduleOperationTimeout (simtime_t timeout)
virtual void	setupActiveOperation (LifecycleOperation *operation, IDoneCallback *doneCallback, State)
virtual void	delayActiveOperationFinish (simtime_t timeout)
virtual void	startActiveOperationExtraTime (simtime_t delay=SIMTIME_ZERO)
virtual void	startActiveOperationExtraTimeOrFinish (simtime_t extraTime)
virtual void	finishActiveOperation ()

Protected Attributes
long	bytesRcvd = 0
Protected Attributes inherited from inet::TcpServerHostApp
TcpSocket	serverSocket
SocketMap	socketMap
ThreadSet	threadSet
Protected Attributes inherited from inet::OperationalMixin< cSimpleModule >
State	operationalState
simtime_t	lastChange
Operation	activeOperation
cMessage *	activeOperationTimeout
cMessage *	activeOperationExtraTimer

Friends
class	TcpSinkAppThread

Additional Inherited Members
Protected Types inherited from inet::TcpServerHostApp
typedef std::set< TcpServerThreadBase * >	ThreadSet
Protected Types inherited from inet::OperationalMixin< cSimpleModule >
enum	State

Detailed Description

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

Constructor & Destructor Documentation

TcpSinkApp()

inet::TcpSinkApp::TcpSinkApp

(

)

{
}

~TcpSinkApp()

inet::TcpSinkApp::~TcpSinkApp

(

)

{
}

Member Function Documentation

finish()

void inet::TcpSinkApp::finish ( )

overrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

{
    TcpServerHostApp::finish();
 
    recordScalar("bytesRcvd", bytesRcvd);
}

initialize()

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

overrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

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

numInitStages()

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

inlineoverrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

{ return NUM_INIT_STAGES; }

refreshDisplay()

void inet::TcpSinkApp::refreshDisplay ( ) const

overrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

{
    ApplicationBase::refreshDisplay();
 
    char buf[160];
    sprintf(buf, "threads: %d\nrcvd: %ld bytes", socketMap.size(), bytesRcvd);
    getDisplayString().setTagArg("t", 0, buf);
}

Friends And Related Function Documentation

TcpSinkAppThread

friend class TcpSinkAppThread

friend

Member Data Documentation

bytesRcvd

long inet::TcpSinkApp::bytesRcvd = 0

protected

Referenced by inet::TcpSinkAppThread::dataArrived(), finish(), initialize(), and refreshDisplay().

---

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

• TcpSinkApp.h
• TcpSinkApp.cc