inet::TcpGenericServerThread Class Reference

Example server thread, to be used with TcpServerHostApp. More...

#include <TcpGenericServerThread.h>

Inheritance diagram for inet::TcpGenericServerThread:

Public Member Functions
	TcpGenericServerThread ()
virtual void	established () override
	Called when connection is established. More...
virtual void	dataArrived (Packet *msg, bool urgent) override
virtual void	timerExpired (cMessage *timer) override
Public Member Functions inherited from inet::TcpServerThreadBase
	TcpServerThreadBase ()
virtual	~TcpServerThreadBase ()
virtual void	init (TcpServerHostApp *hostmodule, TcpSocket *socket)
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 ()

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
Protected Attributes inherited from inet::TcpServerThreadBase
TcpServerHostApp *	hostmod
TcpSocket *	sock

Detailed Description

Example server thread, to be used with TcpServerHostApp.

Constructor & Destructor Documentation

TcpGenericServerThread()

inet::TcpGenericServerThread::TcpGenericServerThread ( )

inline

{}

Member Function Documentation

dataArrived()

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

overridevirtual

Implements inet::TcpServerThreadBase.

{
    const auto& appmsg = msg->peekData<GenericAppMsg>();
 
    if (!appmsg)
        throw cRuntimeError("Message (%s)%s is not a GenericAppMsg -- probably wrong client app",
                msg->getClassName(), msg->getName());
 
    if (appmsg->getReplyDelay() > 0)
        throw cRuntimeError("Cannot process (%s)%s: %s class doesn't support replyDelay field"
                            " of GenericAppMsg, try to use TcpGenericServerApp instead",
                msg->getClassName(), msg->getName(), getClassName());
 
    // process message: send back requested number of bytes, then close
    // connection if that was requested too
    B requestedBytes = appmsg->getExpectedReplyLength();
    bool doClose = appmsg->getServerClose();
 
    if (requestedBytes > B(0)) {
        Packet *outPacket = new Packet(msg->getName());
        const auto& payload = makeShared<ByteCountChunk>(requestedBytes);
        payload->addTag<CreationTimeTag>()->setCreationTime(simTime());
        outPacket->insertAtBack(payload);
        getSocket()->send(outPacket);
    }
 
    if (doClose)
        getSocket()->close();
    delete msg;
}

established()

void inet::TcpGenericServerThread::established ( )

overridevirtual

Called when connection is established.

To be redefined.

Implements inet::TcpServerThreadBase.

{
    // no initialization needed
}

timerExpired()

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

overridevirtual

Implements inet::TcpServerThreadBase.

{
    // no timers in this serverThread
}

---

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

• TcpGenericServerThread.h
• TcpGenericServerThread.cc