inet::tcp::TCP_NSC_ByteStreamReceiveQueue Class Reference

Receive queue that manages actual bytes. More...

#include <TCP_NSC_ByteStreamQueues.h>

Inheritance diagram for inet::tcp::TCP_NSC_ByteStreamReceiveQueue:

Public Member Functions
	TCP_NSC_ByteStreamReceiveQueue ()
	Ctor. More...
virtual	~TCP_NSC_ByteStreamReceiveQueue ()
	Virtual dtor. More...
virtual void	setConnection (TCP_NSC_Connection *connP) override
	Add a connection queue. More...
virtual void	notifyAboutIncomingSegmentProcessing (TCPSegment *tcpsegP) override
	Called when a TCP segment arrives. More...
virtual void	enqueueNscData (void *dataP, int dataLengthP) override
	The method called when data received from NSC The method should set status of the data in queue to received called after socket->read_data() successfull. More...
virtual cPacket *	extractBytesUpTo () override
	Should create a packet to be passed up to the app, up to (but NOT including) the given sequence no (usually rcv_nxt). More...
virtual uint32	getAmountOfBufferedBytes () const override
	Returns the number of bytes (out-of-order-segments) currently buffered in queue. More...
virtual uint32	getQueueLength () const override
	Returns the number of blocks currently buffered in queue. More...
virtual void	getQueueStatus () const override
	Shows current queue status. More...
virtual void	notifyAboutSending (const TCPSegment *tcpsegP) override
	notify the queue about output messages More...
Public Member Functions inherited from inet::tcp::TCP_NSC_ReceiveQueue
	TCP_NSC_ReceiveQueue ()
	Ctor. More...
virtual	~TCP_NSC_ReceiveQueue ()
	Virtual dtor. More...

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

Detailed Description

Receive queue that manages actual bytes.

Constructor & Destructor Documentation

inet::tcp::TCP_NSC_ByteStreamReceiveQueue::TCP_NSC_ByteStreamReceiveQueue

(

)

Ctor.

{
}

inet::tcp::TCP_NSC_ByteStreamReceiveQueue::~TCP_NSC_ByteStreamReceiveQueue ( )

virtual

Virtual dtor.

{
    // nothing to do here
}

Member Function Documentation

void inet::tcp::TCP_NSC_ByteStreamReceiveQueue::enqueueNscData ( void *  dataP, int  dataLengthP  )

overridevirtual

The method called when data received from NSC The method should set status of the data in queue to received called after socket->read_data() successfull.

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    byteArrayBufferM.push(dataP, dataLengthP);
}

cPacket * inet::tcp::TCP_NSC_ByteStreamReceiveQueue::extractBytesUpTo ( )

overridevirtual

Should create a packet to be passed up to the app, up to (but NOT including) the given sequence no (usually rcv_nxt).

It should return nullptr if there's no more data to be passed up – this method is called several times until it returns nullptr.

called after socket->read_data() successfull

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    ASSERT(connM);

    RawPacket *dataMsg = nullptr;
    uint64 bytesInQueue = byteArrayBufferM.getLength();

    if (bytesInQueue) {
        dataMsg = new RawPacket("DATA");
        dataMsg->setKind(TCP_I_DATA);
        unsigned int extractBytes = bytesInQueue;
        char *data = new char[extractBytes];
        unsigned int extractedBytes = byteArrayBufferM.popBytesToBuffer(data, extractBytes);
        dataMsg->setByteLength(extractedBytes);
        dataMsg->getByteArray().assignBuffer(data, extractedBytes);
    }

    return dataMsg;
}

uint32 inet::tcp::TCP_NSC_ByteStreamReceiveQueue::getAmountOfBufferedBytes ( ) const

overridevirtual

Returns the number of bytes (out-of-order-segments) currently buffered in queue.

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    return byteArrayBufferM.getLength();
}

uint32 inet::tcp::TCP_NSC_ByteStreamReceiveQueue::getQueueLength ( ) const

overridevirtual

Returns the number of blocks currently buffered in queue.

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    return byteArrayBufferM.getLength();
}

void inet::tcp::TCP_NSC_ByteStreamReceiveQueue::getQueueStatus ( ) const

overridevirtual

Shows current queue status.

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    // TODO
}

void inet::tcp::TCP_NSC_ByteStreamReceiveQueue::notifyAboutIncomingSegmentProcessing ( TCPSegment *  tcpsegP )

overridevirtual

Called when a TCP segment arrives.

The segment object should not be deleted.

For remove and store payload messages if need.

called before nsc_stack->if_receive_packet() called

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    ASSERT(tcpsegP);
}

void inet::tcp::TCP_NSC_ByteStreamReceiveQueue::notifyAboutSending ( const TCPSegment *  tcpsegP )

overridevirtual

notify the queue about output messages

called when connM send out a packet. for read AckNo, if have

Implements inet::tcp::TCP_NSC_ReceiveQueue.

{
    // nothing to do
}

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

overridevirtual

Add a connection queue.

Reimplemented from inet::tcp::TCP_NSC_ReceiveQueue.

{
    ASSERT(connP);

    byteArrayBufferM.clear();
    TCP_NSC_ReceiveQueue::setConnection(connP);
}

Member Data Documentation

ByteArrayBuffer inet::tcp::TCP_NSC_ByteStreamReceiveQueue::byteArrayBufferM

protected

---

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

• TCP_NSC_ByteStreamQueues.h
• TCP_NSC_ByteStreamQueues.cc