inet::TcpEchoAppThread Class Reference

#include <TcpEchoApp.h>

Inheritance diagram for inet::TcpEchoAppThread:

Public Member Functions
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
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 ()

Protected Attributes
TcpEchoApp *	echoAppModule = nullptr
Protected Attributes inherited from inet::TcpServerThreadBase
TcpServerHostApp *	hostmod
TcpSocket *	sock

Additional Inherited Members
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
virtual void	refreshDisplay () const override

Member Function Documentation

dataArrived()

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

overridevirtual

Implements inet::TcpServerThreadBase.

{
    echoAppModule->emit(packetReceivedSignal, rcvdPkt);
    int64_t rcvdBytes = rcvdPkt->getByteLength();
    echoAppModule->bytesRcvd += rcvdBytes;
 
    if (echoAppModule->echoFactor > 0 && sock->getState() == TcpSocket::CONNECTED) {
        Packet *outPkt = new Packet(rcvdPkt->getName(), TCP_C_SEND);
        // reverse direction, modify length, and send it back
        int socketId = rcvdPkt->getTag<SocketInd>()->getSocketId();
        outPkt->addTag<SocketReq>()->setSocketId(socketId);
 
        long outByteLen = rcvdBytes * echoAppModule->echoFactor;
 
        if (outByteLen < 1)
            outByteLen = 1;
 
        int64_t len = 0;
        for (; len + rcvdBytes <= outByteLen; len += rcvdBytes) {
            outPkt->insertAtBack(rcvdPkt->peekDataAt(B(0), B(rcvdBytes)));
        }
        if (len < outByteLen)
            outPkt->insertAtBack(rcvdPkt->peekDataAt(B(0), B(outByteLen - len)));
 
        ASSERT(outPkt->getByteLength() == outByteLen);
 
        if (echoAppModule->delay == 0)
            echoAppModule->sendDown(outPkt);
        else
            scheduleAfter(echoAppModule->delay, outPkt); // send after a delay
    }
    delete rcvdPkt;
}

established()

void inet::TcpEchoAppThread::established ( )

overridevirtual

Called when connection is established.

Implements inet::TcpServerThreadBase.

{
}

init()

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

inlineoverridevirtual

Reimplemented from inet::TcpServerThreadBase.

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

timerExpired()

void inet::TcpEchoAppThread::timerExpired ( cMessage *  timer )

overridevirtual

Implements inet::TcpServerThreadBase.

{
    Packet *pkt = check_and_cast<Packet *>(timer);
    pkt->setContextPointer(nullptr);
    echoAppModule->sendDown(pkt);
}

Member Data Documentation

echoAppModule

TcpEchoApp* inet::TcpEchoAppThread::echoAppModule = nullptr

protected

Referenced by dataArrived(), and timerExpired().

---

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

• TcpEchoApp.h
• TcpEchoApp.cc