inet::ieee80211::OriginatorQosAckPolicy Class Reference

#include <OriginatorQosAckPolicy.h>

Inheritance diagram for inet::ieee80211::OriginatorQosAckPolicy:

Public Member Functions
virtual bool	isAckNeeded (const Ptr< const Ieee80211MgmtHeader > &header) const override
virtual AckPolicy	computeAckPolicy (Packet *packet, const Ptr< const Ieee80211DataHeader > &header, OriginatorBlockAckAgreement *agreement) const override
virtual bool	isBlockAckPolicyEligibleFrame (Packet *packet, const Ptr< const Ieee80211DataHeader > &header) const override
virtual bool	isBlockAckReqNeeded (InProgressFrames *inProgressFrames, TxopProcedure *txopProcedure) const override
virtual std::tuple< MacAddress, SequenceNumberCyclic, Tid >	computeBlockAckReqParameters (InProgressFrames *inProgressFrames, TxopProcedure *txopProcedure) const override
virtual simtime_t	getAckTimeout (Packet *packet, const Ptr< const Ieee80211DataOrMgmtHeader > &dataOrMgmtHeader) const override
virtual simtime_t	getBlockAckTimeout (Packet *packet, const Ptr< const Ieee80211BlockAckReq > &blockAckReq) const override
Public Member Functions inherited from inet::ieee80211::IOriginatorQoSAckPolicy
virtual	~IOriginatorQoSAckPolicy ()

Protected Member Functions
virtual int	numInitStages () const override
virtual void	initialize (int stage) override
virtual bool	checkAgreementPolicy (const Ptr< const Ieee80211DataHeader > &header, OriginatorBlockAckAgreement *agreement) const
virtual std::map< MacAddress, std::vector< Packet * > >	getOutstandingFramesPerReceiver (InProgressFrames *inProgressFrames) const
virtual SequenceNumberCyclic	computeStartingSequenceNumber (const std::vector< Packet * > &outstandingFrames) const
virtual bool	isCompressedBlockAckReq (const std::vector< Packet * > &outstandingFrames, int startingSequenceNumber) const
Protected Member Functions inherited from inet::ieee80211::ModeSetListener
virtual void	receiveSignal (cComponent *source, simsignal_t signalID, cObject *obj, cObject *details) override

Protected Attributes
IQosRateSelection *	rateSelection = nullptr
int	maxBlockAckPolicyFrameLength = -1
int	blockAckReqThreshold = -1
simtime_t	blockAckTimeout = -1
simtime_t	ackTimeout = -1
Protected Attributes inherited from inet::ieee80211::ModeSetListener
physicallayer::Ieee80211ModeSet *	modeSet = nullptr

Member Function Documentation

checkAgreementPolicy()

bool inet::ieee80211::OriginatorQosAckPolicy::checkAgreementPolicy ( const Ptr< const Ieee80211DataHeader > &  header, OriginatorBlockAckAgreement *  agreement  ) const

protectedvirtual

{
    bool bufferFull = agreement->getBufferSize() == agreement->getNumSentBaPolicyFrames();
    bool aMsduOk = agreement->getIsAMsduSupported() || !header->getAMsduPresent();
    // TODO bool baPolicy = agreement->getIsDelayedBlockAckPolicySupported() || !frame->getAckPolicy();
    return !bufferFull && aMsduOk && (header->getSequenceNumber() >= agreement->getStartingSequenceNumber()); // TODO && baPolicy
}

Referenced by computeAckPolicy().

computeAckPolicy()

AckPolicy inet::ieee80211::OriginatorQosAckPolicy::computeAckPolicy ( Packet *  packet, const Ptr< const Ieee80211DataHeader > &  header, OriginatorBlockAckAgreement *  agreement  ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    if (agreement == nullptr)
        return AckPolicy::NORMAL_ACK;
    if (agreement->getIsAddbaResponseReceived() && isBlockAckPolicyEligibleFrame(packet, header)) {
        if (checkAgreementPolicy(header, agreement))
            return AckPolicy::BLOCK_ACK;
        else
            return AckPolicy::NORMAL_ACK;
    }
    else
        return AckPolicy::NORMAL_ACK;
}

computeBlockAckReqParameters()

std::tuple< MacAddress, SequenceNumberCyclic, Tid > inet::ieee80211::OriginatorQosAckPolicy::computeBlockAckReqParameters ( InProgressFrames *  inProgressFrames, TxopProcedure *  txopProcedure  ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    auto outstandingFramesPerReceiver = getOutstandingFramesPerReceiver(inProgressFrames);
    for (auto outstandingFrames : outstandingFramesPerReceiver) {
        if ((int)outstandingFrames.second.size() >= blockAckReqThreshold) {
            auto largestOutstandingFrames = outstandingFramesPerReceiver.begin();
            for (auto it = outstandingFramesPerReceiver.begin(); it != outstandingFramesPerReceiver.end(); it++) {
                if (it->second.size() > largestOutstandingFrames->second.size())
                    largestOutstandingFrames = it;
            }
            MacAddress receiverAddress = largestOutstandingFrames->first;
            SequenceNumberCyclic startingSequenceNumber = computeStartingSequenceNumber(largestOutstandingFrames->second);
            Tid tid = largestOutstandingFrames->second.at(0)->peekAtFront<Ieee80211DataHeader>()->getTid();
            return std::make_tuple(receiverAddress, startingSequenceNumber, tid);
        }
    }
    return std::make_tuple(MacAddress::UNSPECIFIED_ADDRESS, SequenceNumberCyclic(), -1);
}

computeStartingSequenceNumber()

SequenceNumberCyclic inet::ieee80211::OriginatorQosAckPolicy::computeStartingSequenceNumber ( const std::vector< Packet * > &  outstandingFrames ) const

protectedvirtual

{
    ASSERT(outstandingFrames.size() > 0);
    auto startingSequenceNumber = outstandingFrames[0]->peekAtFront<Ieee80211DataHeader>()->getSequenceNumber();
    for (size_t i = 1; i < outstandingFrames.size(); i++) {
        auto seqNum = outstandingFrames[i]->peekAtFront<Ieee80211DataHeader>()->getSequenceNumber();
        if (seqNum < startingSequenceNumber)
            startingSequenceNumber = seqNum;
    }
    return startingSequenceNumber;
}

Referenced by computeBlockAckReqParameters().

getAckTimeout()

simtime_t inet::ieee80211::OriginatorQosAckPolicy::getAckTimeout ( Packet *  packet, const Ptr< const Ieee80211DataOrMgmtHeader > &  dataOrMgmtHeader  ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    return ackTimeout == -1 ? modeSet->getSifsTime() + modeSet->getSlotTime() + rateSelection->computeResponseAckFrameMode(packet, dataOrMgmtHeader)->getPhyRxStartDelay() : ackTimeout;
}

getBlockAckTimeout()

simtime_t inet::ieee80211::OriginatorQosAckPolicy::getBlockAckTimeout ( Packet *  packet, const Ptr< const Ieee80211BlockAckReq > &  blockAckReq  ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    return blockAckTimeout == -1 ? modeSet->getSifsTime() + modeSet->getSlotTime() + rateSelection->computeResponseBlockAckFrameMode(packet, blockAckReq)->getPhyRxStartDelay() : blockAckTimeout;
}

getOutstandingFramesPerReceiver()

std::map< MacAddress, std::vector< Packet * > > inet::ieee80211::OriginatorQosAckPolicy::getOutstandingFramesPerReceiver ( InProgressFrames *  inProgressFrames ) const

protectedvirtual

{
    auto outstandingFrames = inProgressFrames->getOutstandingFrames();
    std::map<MacAddress, std::vector<Packet *>> outstandingFramesPerReceiver;
    for (auto frame : outstandingFrames)
        outstandingFramesPerReceiver[frame->peekAtFront<Ieee80211MacHeader>()->getReceiverAddress()].push_back(frame);
    return outstandingFramesPerReceiver;
}

Referenced by computeBlockAckReqParameters(), and isBlockAckReqNeeded().

initialize()

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

overrideprotectedvirtual

Reimplemented from inet::ieee80211::ModeSetListener.

{
    ModeSetListener::initialize(stage);
    if (stage == INITSTAGE_LOCAL) {
        rateSelection = check_and_cast<IQosRateSelection *>(getModuleByPath(par("rateSelectionModule")));
        maxBlockAckPolicyFrameLength = par("maxBlockAckPolicyFrameLength");
        blockAckReqThreshold = par("blockAckReqThreshold");
        blockAckTimeout = par("blockAckTimeout");
        ackTimeout = par("ackTimeout");
    }
}

isAckNeeded()

bool inet::ieee80211::OriginatorQosAckPolicy::isAckNeeded ( const Ptr< const Ieee80211MgmtHeader > &  header ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    return !header->getReceiverAddress().isMulticast();
}

isBlockAckPolicyEligibleFrame()

bool inet::ieee80211::OriginatorQosAckPolicy::isBlockAckPolicyEligibleFrame ( Packet *  packet, const Ptr< const Ieee80211DataHeader > &  header  ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    return header->getType() == ST_DATA_WITH_QOS && packet->getByteLength() < maxBlockAckPolicyFrameLength;
}

Referenced by computeAckPolicy().

isBlockAckReqNeeded()

bool inet::ieee80211::OriginatorQosAckPolicy::isBlockAckReqNeeded ( InProgressFrames *  inProgressFrames, TxopProcedure *  txopProcedure  ) const

overridevirtual

Implements inet::ieee80211::IOriginatorQoSAckPolicy.

{
    auto outstandingFramesPerReceiver = getOutstandingFramesPerReceiver(inProgressFrames);
    for (auto outstandingFrames : outstandingFramesPerReceiver) {
        if ((int)outstandingFrames.second.size() >= blockAckReqThreshold)
            return true;
    }
    return false;
}

isCompressedBlockAckReq()

bool inet::ieee80211::OriginatorQosAckPolicy::isCompressedBlockAckReq ( const std::vector< Packet * > &  outstandingFrames, int  startingSequenceNumber  ) const

protectedvirtual

{
    // The Compressed Bitmap subfield of the BA Control field or BAR Control field shall be set to 1 in all
    // BlockAck and BlockAckReq frames sent from one HT STA to another HT STA and shall be set to 0 otherwise.
    return false; // non-HT STA
//    for (auto frame : outstandingFrames)
//        if (frame->getSequenceNumber() >= startingSequenceNumber && frame->getFragmentNumber() > 0)
//            return false;
//    return true;
}

numInitStages()

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

inlineoverrideprotectedvirtual

Reimplemented from inet::ieee80211::ModeSetListener.

{ return NUM_INIT_STAGES; }

Member Data Documentation

ackTimeout

simtime_t inet::ieee80211::OriginatorQosAckPolicy::ackTimeout = -1

protected

Referenced by getAckTimeout(), and initialize().

blockAckReqThreshold

int inet::ieee80211::OriginatorQosAckPolicy::blockAckReqThreshold = -1

protected

Referenced by computeBlockAckReqParameters(), initialize(), and isBlockAckReqNeeded().

blockAckTimeout

simtime_t inet::ieee80211::OriginatorQosAckPolicy::blockAckTimeout = -1

protected

Referenced by getBlockAckTimeout(), and initialize().

maxBlockAckPolicyFrameLength

int inet::ieee80211::OriginatorQosAckPolicy::maxBlockAckPolicyFrameLength = -1

protected

Referenced by initialize(), and isBlockAckPolicyEligibleFrame().

rateSelection

IQosRateSelection* inet::ieee80211::OriginatorQosAckPolicy::rateSelection = nullptr

protected

Referenced by getAckTimeout(), getBlockAckTimeout(), and initialize().

---

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

• OriginatorQosAckPolicy.h
• OriginatorQosAckPolicy.cc