inet::ieee80211::QoSRecoveryProcedure Class Reference

#include <QoSRecoveryProcedure.h>

Inheritance diagram for inet::ieee80211::QoSRecoveryProcedure:

Public Member Functions
virtual void	multicastFrameTransmitted ()
virtual void	ctsFrameReceived ()
virtual void	ackFrameReceived (Ieee80211DataFrame *ackedFrame)
virtual void	blockAckFrameReceived ()
virtual void	rtsFrameTransmissionFailed (Ieee80211DataFrame *protectedFrame)
virtual void	dataFrameTransmissionFailed (Ieee80211DataFrame *failedFrame)
virtual bool	isRetryLimitReached (Ieee80211DataFrame *failedFrame)
virtual int	getRetryCount (Ieee80211DataFrame *frame)
virtual bool	isRtsFrameRetryLimitReached (Ieee80211DataFrame *protectedFrame)
virtual void	retryLimitReached (Ieee80211DataFrame *frame)
virtual int	getLongRetryLimit ()
virtual int	getShortRetryLimit ()
Public Member Functions inherited from inet::ieee80211::IRecoveryProcedure
virtual	~IRecoveryProcedure ()

Protected Member Functions
virtual int	numInitStages () const override
virtual void	initialize (int stage) override
void	incrementCounter (Ieee80211DataFrame *frame, std::map< std::pair< Tid, SequenceControlField >, int > &retryCounter)
void	incrementStationSrc ()
void	incrementStationLrc ()
void	resetStationSrc ()
void	resetStationLrc ()
void	resetContentionWindow ()
int	doubleCw (int cw)
int	getRc (Ieee80211DataFrame *frame, std::map< std::pair< Tid, SequenceControlField >, int > &retryCounter)
bool	isMulticastFrame (Ieee80211Frame *frame)

Protected Attributes
ICwCalculator *	cwCalculator = nullptr
std::map< std::pair< Tid, SequenceControlField >, int >	shortRetryCounter
std::map< std::pair< Tid, SequenceControlField >, int >	longRetryCounter
int	stationLongRetryCounter = 0
int	stationShortRetryCounter = 0
int	shortRetryLimit = -1
int	longRetryLimit = -1
int	rtsThreshold = -1

Member Function Documentation

void inet::ieee80211::QoSRecoveryProcedure::ackFrameReceived ( Ieee80211DataFrame *  ackedFrame )

virtual

{
    auto id = std::make_pair(ackedFrame->getTid(), SequenceControlField(ackedFrame->getSequenceNumber(), ackedFrame->getFragmentNumber()));
    if (ackedFrame->getByteLength() >= rtsThreshold) {
        resetStationLrc();
        auto it = longRetryCounter.find(id);
        if (it != longRetryCounter.end())
            longRetryCounter.erase(it);
    }
    else {
        auto it = shortRetryCounter.find(id);
        resetStationSrc();
        if (it != shortRetryCounter.end())
            shortRetryCounter.erase(it);
    }
//
// The CW shall be reset to aCWmin after every successful attempt to transmit a frame containing
// all or part of an MSDU or MMPDU
//
    resetContentionWindow();
}

void inet::ieee80211::QoSRecoveryProcedure::blockAckFrameReceived ( )

virtual

{
    resetStationSrc();
}

void inet::ieee80211::QoSRecoveryProcedure::ctsFrameReceived ( )

virtual

{
    resetStationSrc();
}

void inet::ieee80211::QoSRecoveryProcedure::dataFrameTransmissionFailed ( Ieee80211DataFrame *  failedFrame )

virtual

{
    if (failedFrame->getByteLength() >= rtsThreshold) {
        incrementStationLrc();
        incrementCounter(failedFrame, longRetryCounter);
    }
    else {
        incrementStationSrc();
        incrementCounter(failedFrame, shortRetryCounter);
    }
}

int inet::ieee80211::QoSRecoveryProcedure::doubleCw ( int  cw )

protected

virtual int inet::ieee80211::QoSRecoveryProcedure::getLongRetryLimit ( )

inlinevirtual

{ return longRetryLimit; }

int inet::ieee80211::QoSRecoveryProcedure::getRc ( Ieee80211DataFrame *  frame, std::map< std::pair< Tid, SequenceControlField >, int > &  retryCounter  )

protected

Referenced by getRetryCount(), isRetryLimitReached(), and isRtsFrameRetryLimitReached().

{
    auto id = std::make_pair(frame->getTid(), SequenceControlField(frame->getSequenceNumber(), frame->getFragmentNumber()));
    auto it = retryCounter.find(id);
    if (it != retryCounter.end())
        return it->second;
    else
        throw cRuntimeError("The retry counter entry doesn't exist for message id: %d", frame->getId());
}

int inet::ieee80211::QoSRecoveryProcedure::getRetryCount ( Ieee80211DataFrame *  frame )

virtual

{
    if (frame->getByteLength() >= rtsThreshold)
        return getRc(frame, longRetryCounter);
    else
        return getRc(frame, shortRetryCounter);
}

virtual int inet::ieee80211::QoSRecoveryProcedure::getShortRetryLimit ( )

inlinevirtual

{ return shortRetryLimit; }

void inet::ieee80211::QoSRecoveryProcedure::incrementCounter ( Ieee80211DataFrame *  frame, std::map< std::pair< Tid, SequenceControlField >, int > &  retryCounter  )

protected

Referenced by dataFrameTransmissionFailed(), and rtsFrameTransmissionFailed().

{
    auto id = std::make_pair(frame->getTid(), SequenceControlField(frame->getSequenceNumber(), frame->getFragmentNumber()));
    if (retryCounter.find(id) != retryCounter.end())
        retryCounter[id]++;
    else
        retryCounter[id] = 1;
}

void inet::ieee80211::QoSRecoveryProcedure::incrementStationLrc ( )

protected

Referenced by dataFrameTransmissionFailed().

{
    stationLongRetryCounter++;
    if (stationLongRetryCounter == longRetryLimit) // 9.3.3 Random backoff time
        resetContentionWindow();
    else
        cwCalculator->incrementCw();
}

void inet::ieee80211::QoSRecoveryProcedure::incrementStationSrc ( )

protected

Referenced by dataFrameTransmissionFailed(), and rtsFrameTransmissionFailed().

{
    stationShortRetryCounter++;
    if (stationShortRetryCounter == shortRetryLimit) // 9.3.3 Random backoff time
        resetContentionWindow();
    else
        cwCalculator->incrementCw();
}

void inet::ieee80211::QoSRecoveryProcedure::initialize ( int  stage )

overrideprotectedvirtual

{
    if (stage == INITSTAGE_LAST) {
        auto rtsPolicy = check_and_cast<IRtsPolicy *>(getModuleByPath(par("rtsPolicyModule")));
        cwCalculator = check_and_cast<ICwCalculator *>(getModuleByPath(par("cwCalculatorModule")));
        rtsThreshold = rtsPolicy->getRtsThreshold();
        shortRetryLimit = par("shortRetryLimit");
        longRetryLimit = par("longRetryLimit");
    }
}

bool inet::ieee80211::QoSRecoveryProcedure::isMulticastFrame ( Ieee80211Frame *  frame )

protected

{
    if (Ieee80211OneAddressFrame *oneAddressFrame = dynamic_cast<Ieee80211OneAddressFrame*>(frame)) {
        return oneAddressFrame->getReceiverAddress().isMulticast();
    }
    return false;
}

bool inet::ieee80211::QoSRecoveryProcedure::isRetryLimitReached ( Ieee80211DataFrame *  failedFrame )

virtual

{
    if (failedFrame->getByteLength() >= rtsThreshold)
        return getRc(failedFrame, longRetryCounter) >= longRetryLimit;
    else
        return getRc(failedFrame, shortRetryCounter) >= shortRetryLimit;
}

bool inet::ieee80211::QoSRecoveryProcedure::isRtsFrameRetryLimitReached ( Ieee80211DataFrame *  protectedFrame )

virtual

{
    return getRc(protectedFrame, shortRetryCounter) >= shortRetryLimit;
}

void inet::ieee80211::QoSRecoveryProcedure::multicastFrameTransmitted ( )

virtual

{
    resetStationLrc();
    resetStationSrc();
}

virtual int inet::ieee80211::QoSRecoveryProcedure::numInitStages ( ) const

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

void inet::ieee80211::QoSRecoveryProcedure::resetContentionWindow ( )

protected

Referenced by ackFrameReceived(), incrementStationLrc(), and incrementStationSrc().

{
    cwCalculator->resetCw();
}

void inet::ieee80211::QoSRecoveryProcedure::resetStationLrc ( )

inlineprotected

Referenced by ackFrameReceived(), and multicastFrameTransmitted().

{ stationLongRetryCounter = 0; }

void inet::ieee80211::QoSRecoveryProcedure::resetStationSrc ( )

inlineprotected

Referenced by ackFrameReceived(), blockAckFrameReceived(), ctsFrameReceived(), and multicastFrameTransmitted().

{ stationShortRetryCounter = 0; }

void inet::ieee80211::QoSRecoveryProcedure::retryLimitReached ( Ieee80211DataFrame *  frame )

virtual

{
    auto id = std::make_pair(frame->getTid(), SequenceControlField(frame->getSequenceNumber(), frame->getFragmentNumber()));
    if (frame->getByteLength() >= rtsThreshold) {
        auto it = longRetryCounter.find(id);
        if (it != longRetryCounter.end())
            longRetryCounter.erase(it);
    }
    else {
        auto it = shortRetryCounter.find(id);
        if (it != shortRetryCounter.end())
            shortRetryCounter.erase(it);
    }
}

void inet::ieee80211::QoSRecoveryProcedure::rtsFrameTransmissionFailed ( Ieee80211DataFrame *  protectedFrame )

virtual

{
    incrementStationSrc();
    incrementCounter(protectedFrame, shortRetryCounter);
}

Member Data Documentation

ICwCalculator* inet::ieee80211::QoSRecoveryProcedure::cwCalculator = nullptr

protected

Referenced by incrementStationLrc(), incrementStationSrc(), initialize(), and resetContentionWindow().

std::map<std::pair<Tid, SequenceControlField>, int> inet::ieee80211::QoSRecoveryProcedure::longRetryCounter

protected

Referenced by ackFrameReceived(), dataFrameTransmissionFailed(), getRetryCount(), isRetryLimitReached(), and retryLimitReached().

int inet::ieee80211::QoSRecoveryProcedure::longRetryLimit = -1

protected

Referenced by incrementStationLrc(), initialize(), and isRetryLimitReached().

int inet::ieee80211::QoSRecoveryProcedure::rtsThreshold = -1

protected

Referenced by ackFrameReceived(), dataFrameTransmissionFailed(), getRetryCount(), initialize(), isRetryLimitReached(), and retryLimitReached().

std::map<std::pair<Tid, SequenceControlField>, int> inet::ieee80211::QoSRecoveryProcedure::shortRetryCounter

protected

Referenced by ackFrameReceived(), dataFrameTransmissionFailed(), getRetryCount(), isRetryLimitReached(), isRtsFrameRetryLimitReached(), retryLimitReached(), and rtsFrameTransmissionFailed().

int inet::ieee80211::QoSRecoveryProcedure::shortRetryLimit = -1

protected

Referenced by incrementStationSrc(), initialize(), isRetryLimitReached(), and isRtsFrameRetryLimitReached().

int inet::ieee80211::QoSRecoveryProcedure::stationLongRetryCounter = 0

protected

Referenced by incrementStationLrc().

int inet::ieee80211::QoSRecoveryProcedure::stationShortRetryCounter = 0

protected

Referenced by incrementStationSrc().

---

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

• QoSRecoveryProcedure.h
• QoSRecoveryProcedure.cc