inet::tcp::TCPByteStreamRcvQueue::Region Class Reference

#include <TCPByteStreamRcvQueue.h>

Inheritance diagram for inet::tcp::TCPByteStreamRcvQueue::Region:

Public Member Functions
	Region (uint32 _begin, uint32 _end)
	Region (uint32 _begin, uint32 _end, ByteArray _data)
virtual	~Region ()
virtual bool	merge (const TCPVirtualDataRcvQueue::Region *other) override
	Merge other to self. More...
virtual void	copyTo (cPacket *msg) const override
	Copy self to msg. More...
virtual TCPByteStreamRcvQueue::Region *	split (uint32 seq) override
	Returns an allocated new Region object with filled with begin..seq and set self to seq..end. More...
Public Member Functions inherited from inet::tcp::TCPVirtualDataRcvQueue::Region
	Region (uint32 _begin, uint32 _end)
uint32	getBegin () const
uint32	getEnd () const
unsigned long	getLength () const
unsigned long	getLengthTo (uint32 seq) const
CompareStatus	compare (const TCPVirtualDataRcvQueue::Region &other) const
	Compare self and other. More...

Protected Attributes
ByteArray	data
Protected Attributes inherited from inet::tcp::TCPVirtualDataRcvQueue::Region
uint32	begin
uint32	end

Additional Inherited Members
Public Types inherited from inet::tcp::TCPVirtualDataRcvQueue::Region
enum	CompareStatus {   BEFORE = 1, BEFORE_TOUCH, OVERLAP, AFTER_TOUCH,   AFTER }

Constructor & Destructor Documentation

inet::tcp::TCPByteStreamRcvQueue::Region::Region ( uint32  _begin, uint32  _end  )

inline

Referenced by inet::tcp::TCPByteStreamRcvQueue::createRegionFromSegment(), and split().

: TCPVirtualDataRcvQueue::Region(_begin, _end) {};

inet::tcp::TCPByteStreamRcvQueue::Region::Region ( uint32  _begin, uint32  _end, ByteArray  _data  )

inline

            : TCPVirtualDataRcvQueue::Region(_begin, _end), data(_data) {};

virtual inet::tcp::TCPByteStreamRcvQueue::Region::~Region ( )

inlinevirtual

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue::Region.

{};

Member Function Documentation

void inet::tcp::TCPByteStreamRcvQueue::Region::copyTo ( cPacket *  msg ) const

overridevirtual

Copy self to msg.

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue::Region.

{
    ASSERT(getLength() == data.getDataArraySize());

    RawPacket *msg = check_and_cast<RawPacket *>(msg_);
    TCPVirtualDataRcvQueue::Region::copyTo(msg);
    msg->setByteArray(data);
}

bool inet::tcp::TCPByteStreamRcvQueue::Region::merge ( const TCPVirtualDataRcvQueue::Region *  other )

overridevirtual

Merge other to self.

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue::Region.

{
    const Region *other = dynamic_cast<const Region *>(_other);

    if (!other)
        throw cRuntimeError("merge(): cannot cast (TCPVirtualDataRcvQueue::Region *) to type 'TCPDataStreamRcvQueue::Region *'");

    if (seqLess(end, other->begin) || seqLess(other->end, begin))
        return false;

    uint32 nbegin = seqMin(begin, other->begin);
    uint32 nend = seqMax(end, other->end);

    if (nbegin != begin || nend != end) {
        char *buff = new char[nend - nbegin];

        if (nbegin != begin)
            other->data.copyDataToBuffer(buff, begin - nbegin);

        data.copyDataToBuffer(buff + begin - nbegin, end - begin);

        if (nend != end)
            other->data.copyDataToBuffer(buff + end - nbegin, nend - end);

        begin = nbegin;
        end = nend;
        data.assignBuffer(buff, end - begin);
    }

    return true;
}

TCPByteStreamRcvQueue::Region * inet::tcp::TCPByteStreamRcvQueue::Region::split ( uint32  seq )

overridevirtual

Returns an allocated new Region object with filled with begin..seq and set self to seq..end.

Reimplemented from inet::tcp::TCPVirtualDataRcvQueue::Region.

{
    ASSERT(seqGreater(seq, begin) && seqLess(seq, end));

    Region *reg = new Region(begin, seq);
    reg->data.setDataFromByteArray(data, 0, seq - begin);
    data.truncateData(seq - begin, 0);
    begin = seq;
    return reg;
}

Member Data Documentation

ByteArray inet::tcp::TCPByteStreamRcvQueue::Region::data

protected

Referenced by copyTo(), merge(), and split().

---

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

• TCPByteStreamRcvQueue.h
• TCPByteStreamRcvQueue.cc