inet::TcpClientSocketIo Class Reference

#include <TcpClientSocketIo.h>

Inheritance diagram for inet::TcpClientSocketIo:

Public Member Functions
virtual	~TcpClientSocketIo ()
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
Public Member Functions inherited from inet::TcpSocket::ICallback
virtual	~ICallback ()

Protected Member Functions
virtual void	handleMessage (cMessage *message) override
virtual void	open ()

Protected Attributes
TcpSocket *	socket = nullptr

Constructor & Destructor Documentation

~TcpClientSocketIo()

virtual inet::TcpClientSocketIo::~TcpClientSocketIo ( )

inlinevirtual

{ delete socket; }

Member Function Documentation

handleMessage()

void inet::TcpClientSocketIo::handleMessage ( cMessage *  message )

overrideprotectedvirtual

{
    if (message->arrivedOn("socketIn")) {
        ASSERT(socket && socket->belongsToSocket(message));
        socket->processMessage(message);
    }
    else if (message->arrivedOn("trafficIn")) {
        if (socket == nullptr)
            open();
        socket->send(check_and_cast<Packet *>(message));
    }
    else
        throw cRuntimeError("Unknown message");
}

open()

void inet::TcpClientSocketIo::open ( )

protectedvirtual

{
    socket = new TcpSocket();
    socket->setOutputGate(gate("socketOut"));
    socket->setCallback(this);
    const char *localAddress = par("localAddress");
    int localPort = par("localPort");
    socket->bind(*localAddress ? L3AddressResolver().resolve(localAddress) : L3Address(), localPort);
    const char *connectAddress = par("connectAddress");
    int connectPort = par("connectPort");
    L3Address destination;
    L3AddressResolver().tryResolve(connectAddress, destination);
    socket->connect(destination, connectPort);
}

Referenced by handleMessage().

socketAvailable()

virtual void inet::TcpClientSocketIo::socketAvailable ( TcpSocket *  socket, TcpAvailableInfo *  availableInfo  )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

socketClosed()

virtual void inet::TcpClientSocketIo::socketClosed ( TcpSocket *  socket )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

socketDataArrived()

void inet::TcpClientSocketIo::socketDataArrived ( TcpSocket *  socket, Packet *  packet, bool  urgent  )

overridevirtual

Notifies about data arrival, packet ownership is transferred to the callee.

Implements inet::TcpSocket::ICallback.

{
    packet->removeTag<SocketInd>();
    send(packet, "trafficOut");
}

socketDeleted()

virtual void inet::TcpClientSocketIo::socketDeleted ( TcpSocket *  socket )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

socketEstablished()

virtual void inet::TcpClientSocketIo::socketEstablished ( TcpSocket *  socket )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

socketFailure()

virtual void inet::TcpClientSocketIo::socketFailure ( TcpSocket *  socket, int  code  )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

socketPeerClosed()

virtual void inet::TcpClientSocketIo::socketPeerClosed ( TcpSocket *  socket )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

socketStatusArrived()

virtual void inet::TcpClientSocketIo::socketStatusArrived ( TcpSocket *  socket, TcpStatusInfo *  status  )

inlineoverridevirtual

Implements inet::TcpSocket::ICallback.

{}

Member Data Documentation

socket

TcpSocket* inet::TcpClientSocketIo::socket = nullptr

protected

Referenced by handleMessage(), and open().

---

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

• TcpClientSocketIo.h
• TcpClientSocketIo.cc