inet::tcp::TCP_NSC_ByteStreamSendQueue Class Reference

Send queue that manages actual bytes. More...

#include <TCP_NSC_ByteStreamQueues.h>

Inheritance diagram for inet::tcp::TCP_NSC_ByteStreamSendQueue:

Public Member Functions
	TCP_NSC_ByteStreamSendQueue ()
	Ctor. More...
virtual	~TCP_NSC_ByteStreamSendQueue ()
	Virtual dtor. More...
virtual void	setConnection (TCP_NSC_Connection *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 int	getBytesForTcpLayer (void *bufferP, int bufferLengthP) const override
	Copy data to the buffer for send to NSC. More...
virtual void	dequeueTcpLayerMsg (int msgLengthP) override
	The function should remove msgLengthP bytes from NSCqueue. 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, 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) override
	Tells the queue that bytes up to (but NOT including) seqNum have been transmitted and ACKed, so they can be removed from the queue. More...
Public Member Functions inherited from inet::tcp::TCP_NSC_SendQueue
	TCP_NSC_SendQueue ()
	Ctor. More...
virtual	~TCP_NSC_SendQueue ()
	Virtual dtor. More...

Protected Attributes
ByteArrayBuffer	byteArrayBufferM
Protected Attributes inherited from inet::tcp::TCP_NSC_SendQueue
TCP_NSC_Connection *	connM

Detailed Description

Send queue that manages actual bytes.

Constructor & Destructor Documentation

inet::tcp::TCP_NSC_ByteStreamSendQueue::TCP_NSC_ByteStreamSendQueue

(

)

Ctor.

{
}

inet::tcp::TCP_NSC_ByteStreamSendQueue::~TCP_NSC_ByteStreamSendQueue ( )

virtual

Virtual dtor.

{
}

Member Function Documentation

TCPSegment * inet::tcp::TCP_NSC_ByteStreamSendQueue::createSegmentWithBytes ( const void *  tcpDataP, 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::TCP_NSC_SendQueue.

{
    ASSERT(tcpDataP);

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

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

    return tcpseg;
}

void inet::tcp::TCP_NSC_ByteStreamSendQueue::dequeueTcpLayerMsg ( int  msgLengthP )

overridevirtual

The function should remove msgLengthP bytes from NSCqueue.

But the NSC sometimes reread from this datapart (when data destroyed in IP Layer) inside of createSegmentWithBytes() function.

called with return value of socket->send_data() if larger than 0

Implements inet::tcp::TCP_NSC_SendQueue.

{
    byteArrayBufferM.drop(msgLengthP);
}

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

overridevirtual

Tells the queue that bytes up to (but NOT including) seqNum have been transmitted and ACKed, so they can be removed from the queue.

Implements inet::tcp::TCP_NSC_SendQueue.

{
    // nothing to do here
}

void inet::tcp::TCP_NSC_ByteStreamSendQueue::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::TCP_NSC_SendQueue.

{
    ASSERT(msgP);

    RawPacket *msg = check_and_cast<RawPacket *>(msgP);
    int64 bytes = msg->getByteLength();
    ASSERT(bytes == msg->getByteArray().getDataArraySize());
    byteArrayBufferM.push(msg->getByteArray());
    delete msgP;
}

ulong inet::tcp::TCP_NSC_ByteStreamSendQueue::getBytesAvailable ( ) const

overridevirtual

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

Implements inet::tcp::TCP_NSC_SendQueue.

{
    return byteArrayBufferM.getLength();
}

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

overridevirtual

Copy data to the buffer for send to NSC.

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

called before called socket->send_data()

Implements inet::tcp::TCP_NSC_SendQueue.

{
    ASSERT(bufferP);
    return byteArrayBufferM.getBytesToBuffer(bufferP, bufferLengthP);
}

void inet::tcp::TCP_NSC_ByteStreamSendQueue::setConnection ( TCP_NSC_Connection *  connP )

overridevirtual

set connection queue, and initialise queue variables.

Reimplemented from inet::tcp::TCP_NSC_SendQueue.

{
    byteArrayBufferM.clear();
    TCP_NSC_SendQueue::setConnection(connP);
}

Member Data Documentation

ByteArrayBuffer inet::tcp::TCP_NSC_ByteStreamSendQueue::byteArrayBufferM

protected

Referenced by dequeueTcpLayerMsg(), enqueueAppData(), inet::tcp::TCP_NSC_ByteStreamReceiveQueue::enqueueNscData(), inet::tcp::TCP_NSC_ByteStreamReceiveQueue::extractBytesUpTo(), inet::tcp::TCP_NSC_ByteStreamReceiveQueue::getAmountOfBufferedBytes(), getBytesAvailable(), getBytesForTcpLayer(), inet::tcp::TCP_NSC_ByteStreamReceiveQueue::getQueueLength(), setConnection(), and inet::tcp::TCP_NSC_ByteStreamReceiveQueue::setConnection().

---

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

• TCP_NSC_ByteStreamQueues.h
• TCP_NSC_ByteStreamQueues.cc