inet::tcp::TcpLwipVirtualDataSendQueue Class Reference

Send queue that manages "virtual bytes", that is, byte counts only. More...

#include <TcpLwipVirtualDataQueues.h>

Inheritance diagram for inet::tcp::TcpLwipVirtualDataSendQueue:

Public Member Functions
	TcpLwipVirtualDataSendQueue ()
	Ctor. More...
virtual	~TcpLwipVirtualDataSendQueue ()
	Virtual dtor. More...
virtual void	setConnection (TcpLwipConnection *connP) override
	set connection queue, and initialise queue variables. More...
virtual void	enqueueAppData (cPacket *msgP) override
	Called on SEND app command, it inserts in the queue the data the user wants to send. More...
virtual unsigned int	getBytesForTcpLayer (void *bufferP, unsigned int bufferLengthP) const override
	Copy data to the buffer for send to LWIP. More...
virtual void	dequeueTcpLayerMsg (unsigned int msgLengthP) override
	This function should remove msgLengthP bytes from TCP layer queue. More...
virtual unsigned long	getBytesAvailable () const override
	Utility function: returns how many bytes are available in the queue. More...
virtual TCPSegment *	createSegmentWithBytes (const void *tcpDataP, unsigned int tcpLengthP) override
	Called when the TCP wants to send or retransmit data, it constructs a TCP segment which contains the data from the requested sequence number range. More...
virtual void	discardUpTo (uint32 seqNumP)
Public Member Functions inherited from inet::tcp::TcpLwipSendQueue
	TcpLwipSendQueue ()
	Ctor. More...
virtual	~TcpLwipSendQueue ()
	Virtual dtor. More...

Protected Attributes
long int	unsentTcpLayerBytesM
Protected Attributes inherited from inet::tcp::TcpLwipSendQueue
TcpLwipConnection *	connM

Detailed Description

Send queue that manages "virtual bytes", that is, byte counts only.

Constructor & Destructor Documentation

inet::tcp::TcpLwipVirtualDataSendQueue::TcpLwipVirtualDataSendQueue

(

)

Ctor.

    :
    unsentTcpLayerBytesM(0)
{
}

inet::tcp::TcpLwipVirtualDataSendQueue::~TcpLwipVirtualDataSendQueue ( )

virtual

Virtual dtor.

{
}

Member Function Documentation

TCPSegment * inet::tcp::TcpLwipVirtualDataSendQueue::createSegmentWithBytes ( const void *  tcpDataP, unsigned int  tcpLengthP  )

overridevirtual

Called when the TCP wants to send or retransmit data, it constructs a TCP segment which contains the data from the requested sequence number range.

The actually returned segment may contain less then maxNumBytes bytes if the subclass wants to reproduce the original segment boundaries when retransmitting.

called from inside of send_callback() called before called the send() to IP layer

Implements inet::tcp::TcpLwipSendQueue.

{
    ASSERT(tcpDataP);

    TCPSegment *tcpseg = serializer::TCPSerializer().deserialize((const unsigned char *)tcpDataP, tcpLengthP, false);
    uint32 numBytes = tcpseg->getPayloadLength();

    char msgname[80];
    sprintf(msgname, "%.10s%s%s%s(l=%lu)",
            "tcpseg",
            tcpseg->getSynBit() ? " SYN" : "",
            tcpseg->getFinBit() ? " FIN" : "",
            (tcpseg->getAckBit() && 0 == numBytes) ? " ACK" : "",
            (unsigned long)numBytes);
    tcpseg->setName(msgname);

    return tcpseg;
}

void inet::tcp::TcpLwipVirtualDataSendQueue::dequeueTcpLayerMsg ( unsigned int  msgLengthP )

overridevirtual

This function should remove msgLengthP bytes from TCP layer queue.

Implements inet::tcp::TcpLwipSendQueue.

{
    ASSERT(msgLengthP <= unsentTcpLayerBytesM);

    unsentTcpLayerBytesM -= msgLengthP;
}

void inet::tcp::TcpLwipVirtualDataSendQueue::discardUpTo ( uint32  seqNumP )

virtual

{
    // nothing to do here
}

void inet::tcp::TcpLwipVirtualDataSendQueue::enqueueAppData ( cPacket *  msgP )

overridevirtual

Called on SEND app command, it inserts in the queue the data the user wants to send.

Implementations of this abstract class will decide what this means: copying actual bytes, just increasing the "last byte queued" variable, or storing cMessage object(s). The msg object should not be referenced after this point (sendQueue may delete it.)

Implements inet::tcp::TcpLwipSendQueue.

{
    ASSERT(msgP);

    int bytes = msgP->getByteLength();
    delete msgP;

    unsentTcpLayerBytesM += bytes;
}

unsigned long inet::tcp::TcpLwipVirtualDataSendQueue::getBytesAvailable ( ) const

overridevirtual

Utility function: returns how many bytes are available in the queue.

Implements inet::tcp::TcpLwipSendQueue.

{
    return unsentTcpLayerBytesM;
}

unsigned int inet::tcp::TcpLwipVirtualDataSendQueue::getBytesForTcpLayer ( void *  bufferP, unsigned int  bufferLengthP  ) const

overridevirtual

Copy data to the buffer for send to LWIP.

returns lengh of copied data. create msg for socket->send_data()

called before called socket->send_data()

Implements inet::tcp::TcpLwipSendQueue.

{
    ASSERT(bufferP);

    return (unsentTcpLayerBytesM > bufferLengthP) ? bufferLengthP : unsentTcpLayerBytesM;
}

void inet::tcp::TcpLwipVirtualDataSendQueue::setConnection ( TcpLwipConnection *  connP )

overridevirtual

set connection queue, and initialise queue variables.

Reimplemented from inet::tcp::TcpLwipSendQueue.

{
    unsentTcpLayerBytesM = 0;
    TcpLwipSendQueue::setConnection(connP);
}

Member Data Documentation

long int inet::tcp::TcpLwipVirtualDataSendQueue::unsentTcpLayerBytesM

protected

Referenced by dequeueTcpLayerMsg(), enqueueAppData(), getBytesAvailable(), getBytesForTcpLayer(), and setConnection().

---

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

• TcpLwipVirtualDataQueues.h
• TcpLwipVirtualDataQueues.cc