inet::ieee80211::ReceiveBuffer Class Reference

#include <ReceiveBuffer.h>

Public Types
typedef std::vector< Ieee80211DataFrame * >	Fragments
typedef std::map< SequenceNumber, Fragments >	ReorderBuffer

Public Member Functions
	ReceiveBuffer (int bufferSize, int nextExpectedSequenceNumber)
virtual	~ReceiveBuffer ()
bool	insertFrame (Ieee80211DataFrame *dataFrame)
void	remove (int sequenceNumber)
const ReorderBuffer &	getBuffer ()
int	getLength ()
int	getBufferSize ()
SequenceNumber	getNextExpectedSequenceNumber ()
void	setNextExpectedSequenceNumber (SequenceNumber nextExpectedSequenceNumber)
bool	isFull ()

Protected Attributes
ReorderBuffer	buffer
int	bufferSize = -1
int	length = 0
SequenceNumber	nextExpectedSequenceNumber = -1

Member Typedef Documentation

typedef std::vector<Ieee80211DataFrame *> inet::ieee80211::ReceiveBuffer::Fragments

typedef std::map<SequenceNumber, Fragments> inet::ieee80211::ReceiveBuffer::ReorderBuffer

Constructor & Destructor Documentation

inet::ieee80211::ReceiveBuffer::ReceiveBuffer	(	int	bufferSize,
		int	nextExpectedSequenceNumber
	)

                                                                           :
        bufferSize(bufferSize),
        nextExpectedSequenceNumber(nextExpectedSequenceNumber)
{
}

inet::ieee80211::ReceiveBuffer::~ReceiveBuffer ( )

virtual

{
    for (auto fragments : buffer) {
        for (auto fragment : fragments.second)
            delete fragment;
    }
}

Member Function Documentation

const ReorderBuffer& inet::ieee80211::ReceiveBuffer::getBuffer ( )

inline

Referenced by inet::ieee80211::BlockAckReordering::addMsduIfComplete(), inet::ieee80211::BlockAckReordering::collectCompletePrecedingMpdus(), and inet::ieee80211::BlockAckReordering::getEarliestCompleteMsduOrAMsduIfExists().

{ return buffer; }

int inet::ieee80211::ReceiveBuffer::getBufferSize ( )

inline

Referenced by inet::ieee80211::BlockAckReordering::collectCompletePrecedingMpdus(), inet::ieee80211::BlockAckReordering::collectConsecutiveCompleteFollowingMpdus(), inet::ieee80211::BlockAckReordering::getEarliestCompleteMsduOrAMsduIfExists(), and inet::ieee80211::BlockAckReordering::processReceivedBlockAckReq().

{ return bufferSize; }

int inet::ieee80211::ReceiveBuffer::getLength ( )

inline

{ return length; }

SequenceNumber inet::ieee80211::ReceiveBuffer::getNextExpectedSequenceNumber ( )

inline

Referenced by inet::ieee80211::BlockAckReordering::collectCompletePrecedingMpdus(), inet::ieee80211::BlockAckReordering::getEarliestCompleteMsduOrAMsduIfExists(), inet::ieee80211::BlockAckReordering::processReceivedBlockAckReq(), and inet::ieee80211::BlockAckReordering::processReceivedQoSFrame().

{ return nextExpectedSequenceNumber; }

bool inet::ieee80211::ReceiveBuffer::insertFrame

(

Ieee80211DataFrame *

dataFrame

)

Referenced by inet::ieee80211::BlockAckReordering::processReceivedQoSFrame().

{
    int sequenceNumber = dataFrame->getSequenceNumber();
    // The total number of MPDUs in these MSDUs may not
    // exceed the reorder buffer size in the receiver.
    if (length < bufferSize && !isSequenceNumberTooOld(sequenceNumber, nextExpectedSequenceNumber, bufferSize)) {
        auto it = buffer.find(sequenceNumber);
        if (it != buffer.end()) {
            auto &fragments = it->second;
            fragments.push_back(dataFrame);
        }
        else {
            buffer[sequenceNumber].push_back(dataFrame);
        }
        // The total number of frames that can be sent depends on the total
        // number of MPDUs in all the outstanding MSDUs.
        length++;
        return true;
    }
    return false;
}

bool inet::ieee80211::ReceiveBuffer::isFull ( )

inline

Referenced by inet::ieee80211::BlockAckReordering::processReceivedQoSFrame().

{ ASSERT(length <= bufferSize); return length == bufferSize; }

void inet::ieee80211::ReceiveBuffer::remove

(

int

sequenceNumber

)

Referenced by inet::ieee80211::BlockAckReordering::passedUp().

{
    auto it = buffer.find(sequenceNumber);
    if (it != buffer.end()) {
        length -= it->second.size();
        buffer.erase(sequenceNumber);
    }
    else
        throw cRuntimeError("Unknown sequence number = %d", sequenceNumber);
}

void inet::ieee80211::ReceiveBuffer::setNextExpectedSequenceNumber ( SequenceNumber  nextExpectedSequenceNumber )

inline

Referenced by inet::ieee80211::BlockAckReordering::passedUp(), and inet::ieee80211::BlockAckReordering::processReceivedBlockAckReq().

{ this->nextExpectedSequenceNumber = nextExpectedSequenceNumber; }

Member Data Documentation

ReorderBuffer inet::ieee80211::ReceiveBuffer::buffer

protected

Referenced by insertFrame(), remove(), and ~ReceiveBuffer().

int inet::ieee80211::ReceiveBuffer::bufferSize = -1

protected

Referenced by insertFrame().

int inet::ieee80211::ReceiveBuffer::length = 0

protected

Referenced by insertFrame(), and remove().

SequenceNumber inet::ieee80211::ReceiveBuffer::nextExpectedSequenceNumber = -1

protected

Referenced by insertFrame().

---

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

• ReceiveBuffer.h
• ReceiveBuffer.cc