inet::TCPGenericSrvThread Class Reference

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

#include <TCPGenericSrvThread.h>

Inheritance diagram for inet::TCPGenericSrvThread:

Public Member Functions
	TCPGenericSrvThread ()
virtual void	established () override
	Called when connection is established. More...
virtual void	dataArrived (cMessage *msg, bool urgent) override
virtual void	timerExpired (cMessage *timer) override
Public Member Functions inherited from inet::TCPServerThreadBase
	TCPServerThreadBase ()
virtual	~TCPServerThreadBase ()
virtual void	init (TCPSrvHostApp *hostmodule, TCPSocket *socket)
virtual TCPSocket *	getSocket ()
virtual TCPSrvHostApp *	getHostModule ()
virtual void	scheduleAt (simtime_t t, cMessage *msg)
	Schedule an event. More...
virtual void	cancelEvent (cMessage *msg)
virtual void	peerClosed ()
virtual void	closed ()
virtual void	failure (int code)
virtual void	statusArrived (TCPStatusInfo *status)
Public Member Functions inherited from inet::TCPSocket::CallbackInterface
virtual	~CallbackInterface ()
virtual void	socketDeleted (int connId, void *yourPtr)

Additional Inherited Members
Protected Member Functions inherited from inet::TCPServerThreadBase
virtual void	socketDataArrived (int, void *, cPacket *msg, bool urgent) override
virtual void	socketEstablished (int, void *) override
virtual void	socketPeerClosed (int, void *) override
virtual void	socketClosed (int, void *) override
virtual void	socketFailure (int, void *, int code) override
virtual void	socketStatusArrived (int, void *, TCPStatusInfo *status) override
Protected Attributes inherited from inet::TCPServerThreadBase
TCPSrvHostApp *	hostmod
TCPSocket *	sock

Detailed Description

Example server thread, to be used with TCPSrvHostApp.

Constructor & Destructor Documentation

inet::TCPGenericSrvThread::TCPGenericSrvThread ( )

inline

{}

Member Function Documentation

void inet::TCPGenericSrvThread::dataArrived ( cMessage *  msg, bool  urgent  )

overridevirtual

Implements inet::TCPServerThreadBase.

{
    GenericAppMsg *appmsg = dynamic_cast<GenericAppMsg *>(msg);

    if (!appmsg)
        throw cRuntimeError("Message (%s)%s is not a GenericAppMsg -- "
                            "probably wrong client app, or wrong setting of TCP's "
                            "dataTransferMode parameters "
                            "(try \"object\")",
                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 TCPGenericSrvApp instead",
                msg->getClassName(), msg->getName(), getClassName());

    // process message: send back requested number of bytes, then close
    // connection if that was requested too
    long requestedBytes = appmsg->getExpectedReplyLength();
    bool doClose = appmsg->getServerClose();

    if (requestedBytes == 0) {
        delete appmsg;
    }
    else {
        appmsg->setByteLength(requestedBytes);
        delete appmsg->removeControlInfo();
        getSocket()->send(appmsg);
    }

    if (doClose)
        getSocket()->close();
}

void inet::TCPGenericSrvThread::established ( )

overridevirtual

Called when connection is established.

To be redefined.

Implements inet::TCPServerThreadBase.

{
    // no initialization needed
}

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

overridevirtual

Implements inet::TCPServerThreadBase.

{
    // no timers in this serverThread
}

---

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

• TCPGenericSrvThread.h
• TCPGenericSrvThread.cc