inet::TcpEchoApp Class Reference

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

#include <TcpEchoApp.h>

Inheritance diagram for inet::TcpEchoApp:

Public Member Functions
	TcpEchoApp ()
	~TcpEchoApp ()
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	sendDown (Packet *packet)
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
simtime_t	delay
double	echoFactor = NaN
long	bytesRcvd = 0
long	bytesSent = 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	TcpEchoAppThread

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 sends back whatever arrives on them.

Constructor & Destructor Documentation

TcpEchoApp()

inet::TcpEchoApp::TcpEchoApp

(

)

{
}

~TcpEchoApp()

inet::TcpEchoApp::~TcpEchoApp

(

)

{
}

Member Function Documentation

finish()

void inet::TcpEchoApp::finish ( )

overrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

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

initialize()

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

overrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

{
    TcpServerHostApp::initialize(stage);
 
    if (stage == INITSTAGE_LOCAL) {
        delay = par("echoDelay");
        echoFactor = par("echoFactor");
 
        bytesRcvd = bytesSent = 0;
        WATCH(bytesRcvd);
        WATCH(bytesSent);
    }
}

numInitStages()

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

inlineoverrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

{ return NUM_INIT_STAGES; }

refreshDisplay()

void inet::TcpEchoApp::refreshDisplay ( ) const

overrideprotectedvirtual

Reimplemented from inet::TcpServerHostApp.

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

sendDown()

void inet::TcpEchoApp::sendDown ( Packet *  packet )

protectedvirtual

{
    if (msg->isPacket()) {
        Packet *pk = static_cast<Packet *>(msg);
        bytesSent += pk->getByteLength();
        emit(packetSentSignal, pk);
    }
 
    msg->addTagIfAbsent<DispatchProtocolReq>()->setProtocol(&Protocol::tcp);
    msg->getTag<SocketReq>();
    send(msg, "socketOut");
}

Referenced by inet::TcpEchoAppThread::dataArrived(), and inet::TcpEchoAppThread::timerExpired().

Friends And Related Function Documentation

TcpEchoAppThread

friend class TcpEchoAppThread

friend

Member Data Documentation

bytesRcvd

long inet::TcpEchoApp::bytesRcvd = 0

protected

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

bytesSent

long inet::TcpEchoApp::bytesSent = 0

protected

Referenced by finish(), initialize(), refreshDisplay(), and sendDown().

delay

simtime_t inet::TcpEchoApp::delay

protected

Referenced by inet::TcpEchoAppThread::dataArrived(), and initialize().

echoFactor

double inet::TcpEchoApp::echoFactor = NaN

protected

Referenced by inet::TcpEchoAppThread::dataArrived(), and initialize().

---

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

• TcpEchoApp.h
• TcpEchoApp.cc