inet::tcp::TCPSegmentTransmitInfoList Class Reference

#include <TCPSegmentTransmitInfoList.h>

Classes
class	Item

Public Types
typedef std::list< Item >	TCPSegmentTransmitInfoItems

Public Member Functions
void	set (uint32_t beg, uint32_t end, simtime_t sentTime)
const Item *	get (uint32_t seq) const
	returns pointer to Item, or nullptr if not found More...
void	clearTo (uint32_t endseg)

Public Attributes
TCPSegmentTransmitInfoItems	regions

Member Typedef Documentation

typedef std::list<Item> inet::tcp::TCPSegmentTransmitInfoList::TCPSegmentTransmitInfoItems

Member Function Documentation

void inet::tcp::TCPSegmentTransmitInfoList::clearTo

(

uint32_t

endseg

)

Referenced by inet::tcp::TCPWestwood::dataSent(), inet::tcp::TCPVegas::dataSent(), inet::tcp::TCPWestwood::receivedDataAck(), inet::tcp::TCPVegas::receivedDataAck(), and inet::tcp::TCPVegas::receivedDuplicateAck().

{
    while (!regions.empty() && seqLE(regions.front().end, endseq))
        regions.pop_front();
    if (!regions.empty() && seqLess(regions.front().beg, endseq))
        regions.front().beg = endseq;
}

const TCPSegmentTransmitInfoList::Item * inet::tcp::TCPSegmentTransmitInfoList::get

(

uint32_t

seq

)

const

returns pointer to Item, or nullptr if not found

Referenced by inet::tcp::TCPWestwood::receivedDataAck(), inet::tcp::TCPVegas::receivedDataAck(), and inet::tcp::TCPVegas::receivedDuplicateAck().

{
    for (const auto & elem : regions) {
        if (seqLess(seq, elem.beg))
            break;
        if (seqLE(elem.beg, seq) && seqLess(seq, elem.end))
            return &(elem);
    }
    return nullptr;
}

void inet::tcp::TCPSegmentTransmitInfoList::set	(	uint32_t	beg,
		uint32_t	end,
		simtime_t	sentTime
	)

Referenced by inet::tcp::TCPWestwood::dataSent(), inet::tcp::TCPVegas::dataSent(), inet::tcp::TCPWestwood::segmentRetransmitted(), and inet::tcp::TCPVegas::segmentRetransmitted().

{
    ASSERT(seqLess(beg, end));
    ASSERT(regions.empty() || (seqLE(regions.front().beg, beg) && seqLE(beg, regions.back().end)));

    if (regions.empty() || (regions.back().end == beg))
        regions.push_back(Item(beg, end, sentTime, sentTime, 1));
    else if (end == regions.front().beg)
        regions.push_front(Item(beg, end, sentTime, sentTime, 1));
    else {
        auto i = regions.begin();
        while (seqLE(i->end, beg))
            ++i;

        ASSERT(seqLE(i->beg, beg));
        if (beg != i->beg) {
            regions.insert(i, Item(i->beg, beg, i->firstSentTime, i->lastSentTime, i->transmitCount));
            i->beg = beg;
        }
        while (i != regions.end() && seqLE(i->end, end)) {
            ASSERT(beg == i->beg);
            if (i->firstSentTime > sentTime)
                i->firstSentTime = sentTime;
            if (i->lastSentTime < sentTime)
                i->lastSentTime = sentTime;
            i->transmitCount++;
            beg = i->end;
            ++i;
        }

        if (beg != end) {
            if (i != regions.end()) {
                ASSERT(beg == i->beg);
                simtime_t firstSent = std::min(i->firstSentTime, sentTime);
                simtime_t lastSent = std::max(i->lastSentTime, sentTime);
//                if (firstSent > sentTime)
//                    firstSent = sentTime;
//                if (lastSent < sentTime)
//                    lastSent = sentTime;
                regions.insert(i, Item(beg, end, firstSent, lastSent, i->transmitCount + 1));
                i->beg = end;
            }
            else
                regions.push_back(Item(beg, end, sentTime, sentTime, 1));
        }
    }
}

Member Data Documentation

TCPSegmentTransmitInfoItems inet::tcp::TCPSegmentTransmitInfoList::regions

Referenced by clearTo(), get(), and set().

---

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

• TCPSegmentTransmitInfoList.h
• TCPSegmentTransmitInfoList.cc