inet::tcp::TCPByteStreamRcvQueue Class Reference

TCP send queue that stores actual bytes. More...

#include <TCPByteStreamRcvQueue.h>

Inheritance diagram for inet::tcp::TCPByteStreamRcvQueue:

Classes
class	Region

Public Member Functions
	TCPByteStreamRcvQueue ()
	Ctor. More...
virtual	~TCPByteStreamRcvQueue ()
	Virtual dtor. More...
virtual std::string	info () const override
	Returns a string with region stored. More...
cPacket *	extractBytesUpTo (uint32 seq) override
	Method inherited from TCPReceiveQueue. More...
virtual TCPVirtualDataRcvQueue::Region *	createRegionFromSegment (TCPSegment *tcpseg) override
	Create a new Region from tcpseg. More...
Public Member Functions inherited from inet::tcp::TCPVirtualDataRcvQueue
	TCPVirtualDataRcvQueue ()
	Ctor. More...
virtual	~TCPVirtualDataRcvQueue ()
	Virtual dtor. More...
virtual void	init (uint32 startSeq) override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	insertBytesFromSegment (TCPSegment *tcpseg) override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	getAmountOfBufferedBytes () override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	getAmountOfFreeBytes (uint32 maxRcvBuffer) override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	getQueueLength () override
	Method inherited from TCPReceiveQueue. More...
virtual void	getQueueStatus () override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	getLE (uint32 fromSeqNum) override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	getRE (uint32 toSeqNum) override
	Method inherited from TCPReceiveQueue. More...
virtual uint32	getFirstSeqNo () override
	Returns the minimum of first byte seq.no. More...
Public Member Functions inherited from inet::tcp::TCPReceiveQueue
	TCPReceiveQueue ()
	Ctor. More...
virtual	~TCPReceiveQueue ()
	Virtual dtor. More...
virtual void	setConnection (TCPConnection *_conn)
	Set the connection that owns this queue. More...

Additional Inherited Members
Protected Types inherited from inet::tcp::TCPVirtualDataRcvQueue
typedef std::list< Region * >	RegionList
Protected Member Functions inherited from inet::tcp::TCPVirtualDataRcvQueue
void	merge (TCPVirtualDataRcvQueue::Region *region)
	Merge segment byte range into regionList, the parameter region must created by 'new' operator. More...
TCPVirtualDataRcvQueue::Region *	extractTo (uint32 toSeq)
Protected Attributes inherited from inet::tcp::TCPVirtualDataRcvQueue
uint32	rcv_nxt = 0
RegionList	regionList
Protected Attributes inherited from inet::tcp::TCPReceiveQueue
TCPConnection *	conn

Detailed Description

TCP send queue that stores actual bytes.

See also

TCPSendQueue

Constructor & Destructor Documentation

inet::tcp::TCPByteStreamRcvQueue::TCPByteStreamRcvQueue ( )

inline

Ctor.

: TCPVirtualDataRcvQueue() {};

inet::tcp::TCPByteStreamRcvQueue::~TCPByteStreamRcvQueue ( )

virtual

Virtual dtor.

{
}

Member Function Documentation

TCPVirtualDataRcvQueue::Region * inet::tcp::TCPByteStreamRcvQueue::createRegionFromSegment ( TCPSegment *  tcpseg )

overridevirtual

Create a new Region from tcpseg.

Called from insertBytesFromSegment()

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue.

{
    ASSERT(tcpseg->getPayloadLength() == tcpseg->getByteArray().getDataArraySize());

    Region *region = new Region(tcpseg->getSequenceNo(),
                tcpseg->getSequenceNo() + tcpseg->getPayloadLength(), tcpseg->getByteArray());

    return region;
}

cPacket * inet::tcp::TCPByteStreamRcvQueue::extractBytesUpTo ( uint32  seq )

overridevirtual

Method inherited from TCPReceiveQueue.

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue.

{
    cPacket *msg = nullptr;
    TCPVirtualDataRcvQueue::Region *reg = extractTo(seq);
    if (reg) {
        msg = new RawPacket("data");
        reg->copyTo(msg);
        delete reg;
    }
    return msg;
}

std::string inet::tcp::TCPByteStreamRcvQueue::info ( ) const

overridevirtual

Returns a string with region stored.

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue.

{
    std::stringstream os;

    os << "rcv_nxt=" << rcv_nxt;

    for (const auto & elem : regionList) {
        os << " [" << (elem)->getBegin() << ".." << (elem)->getEnd() << ")";
    }

    os << " " << regionList.size() << "msgs";

    return os.str();
}

---

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

• TCPByteStreamRcvQueue.h
• TCPByteStreamRcvQueue.cc