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

#include <TCP_NSC_VirtualDataQueues.h>

Inheritance diagram for inet::tcp::TCP_NSC_VirtualDataReceiveQueue:

Public Member Functions
	TCP_NSC_VirtualDataReceiveQueue ()
	Ctor. More...

virtual	~TCP_NSC_VirtualDataReceiveQueue ()
	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
long int	bytesInQueueM

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

Detailed Description

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

Constructor & Destructor Documentation

inet::tcp::TCP_NSC_VirtualDataReceiveQueue::TCP_NSC_VirtualDataReceiveQueue ( )

Ctor.

     :
     bytesInQueueM(0)
 {
 }

inet::tcp::TCP_NSC_VirtualDataReceiveQueue::~TCP_NSC_VirtualDataReceiveQueue ( )

virtual

Virtual dtor.

 {
     // nothing to do here
 }

Member Function Documentation

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

 {
     bytesInQueueM += dataLengthP;
 }

cPacket * inet::tcp::TCP_NSC_VirtualDataReceiveQueue::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);
 
     cPacket *dataMsg = nullptr;
 
     if (bytesInQueueM) {
         dataMsg = new cPacket("DATA");
         dataMsg->setKind(TCP_I_DATA);
         dataMsg->setByteLength(bytesInQueueM);
         bytesInQueueM -= dataMsg->getByteLength();
     }
 
     return dataMsg;
 }

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

overridevirtual

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

Implements inet::tcp::TCP_NSC_ReceiveQueue.

 {
     return bytesInQueueM;
 }

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

overridevirtual

Returns the number of blocks currently buffered in queue.

Implements inet::tcp::TCP_NSC_ReceiveQueue.

 {
     return bytesInQueueM ? 1 : 0;
 }

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

overridevirtual

Shows current queue status.

Implements inet::tcp::TCP_NSC_ReceiveQueue.

 {
     // TODO
 }

void inet::tcp::TCP_NSC_VirtualDataReceiveQueue::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_VirtualDataReceiveQueue::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_VirtualDataReceiveQueue::setConnection ( TCP_NSC_Connection * connP )

overridevirtual

Add a connection queue.

Reimplemented from inet::tcp::TCP_NSC_ReceiveQueue.

 {
     ASSERT(connP);
 
     bytesInQueueM = 0;
     TCP_NSC_ReceiveQueue::setConnection(connP);
 }

Member Data Documentation

long int inet::tcp::TCP_NSC_VirtualDataReceiveQueue::bytesInQueueM

protected

Referenced by enqueueNscData(), extractBytesUpTo(), getAmountOfBufferedBytes(), getQueueLength(), and setConnection().

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

Public Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation