inet::ieee80211::RecipientQoSMacDataService Class Reference

#include <RecipientQoSMacDataService.h>

Inheritance diagram for inet::ieee80211::RecipientQoSMacDataService:

Public Member Functions
virtual std::vector< Ieee80211Frame * >	dataFrameReceived (Ieee80211DataFrame *dataFrame, IRecipientBlockAckAgreementHandler *blockAckAgreementHandler) override
virtual std::vector< Ieee80211Frame * >	controlFrameReceived (Ieee80211Frame *controlFrame, IRecipientBlockAckAgreementHandler *blockAckAgreementHandler) override
virtual std::vector< Ieee80211Frame * >	managementFrameReceived (Ieee80211ManagementFrame *mgmtFrame) override

Protected Member Functions
virtual	~RecipientQoSMacDataService ()
virtual void	initialize () override
virtual Ieee80211DataFrame *	defragment (std::vector< Ieee80211DataFrame * > completeFragments)
Ieee80211ManagementFrame *	defragment (Ieee80211ManagementFrame *mgmtFragment)

Protected Attributes
BasicReassembly *	basicReassembly = nullptr
IDuplicateRemoval *	duplicateRemoval = nullptr
BlockAckReordering *	blockAckReordering = nullptr
IDefragmentation *	defragmentation = nullptr
IMsduDeaggregation *	aMsduDeaggregation = nullptr

Constructor & Destructor Documentation

inet::ieee80211::RecipientQoSMacDataService::~RecipientQoSMacDataService ( )

protectedvirtual

{
    delete duplicateRemoval;
    delete basicReassembly;
    delete aMsduDeaggregation;
    delete blockAckReordering;
}

Member Function Documentation

std::vector< Ieee80211Frame * > inet::ieee80211::RecipientQoSMacDataService::controlFrameReceived ( Ieee80211Frame *  controlFrame, IRecipientBlockAckAgreementHandler *  blockAckAgreementHandler  )

overridevirtual

Implements inet::ieee80211::IRecipientQoSMacDataService.

{
    if (auto blockAckReq = dynamic_cast<Ieee80211BasicBlockAckReq*>(controlFrame)) {
        BlockAckReordering::ReorderBuffer frames;
        if (blockAckReordering) {
            Tid tid = blockAckReq->getTidInfo();
            MACAddress originatorAddr = blockAckReq->getTransmitterAddress();
            RecipientBlockAckAgreement *agreement = blockAckAgreementHandler->getAgreement(tid, originatorAddr);
            if (agreement)
                frames = blockAckReordering->processReceivedBlockAckReq(blockAckReq);
            else
                return std::vector<Ieee80211Frame*>();
        }
        std::vector<Ieee80211Frame *> defragmentedFrames;
        if (basicReassembly) { // FIXME: defragmentation
            for (auto it : frames) {
                auto fragments = it.second;
                defragmentedFrames.push_back(defragment(fragments));
            }
        }
        else {
            for (auto it : frames) {
                auto fragments = it.second;
                if (fragments.size() == 1) {
                    defragmentedFrames.push_back(fragments.at(0));
                }
                else {
                    // TODO: drop?
                }
            }
        }
        std::vector<Ieee80211Frame *> deaggregatedFrames;
        if (aMsduDeaggregation) {
            for (auto frame : defragmentedFrames) {
                auto dataFrame = check_and_cast<Ieee80211DataFrame *>(frame);
                if (dataFrame->getAMsduPresent()) {
                    auto subframes = aMsduDeaggregation->deaggregateFrame(dataFrame);
                    for (auto subframe : *subframes)
                        deaggregatedFrames.push_back(subframe);
                    delete subframes;
                }
                else
                    deaggregatedFrames.push_back(dataFrame);
            }
        }
        // TODO: MSDU Integrity, Replay Detection, RX MSDU Rate Limiting
        return deaggregatedFrames;
    }
    return std::vector<Ieee80211Frame*>();
}

std::vector< Ieee80211Frame * > inet::ieee80211::RecipientQoSMacDataService::dataFrameReceived ( Ieee80211DataFrame *  dataFrame, IRecipientBlockAckAgreementHandler *  blockAckAgreementHandler  )

overridevirtual

Implements inet::ieee80211::IRecipientQoSMacDataService.

{
    // TODO: A-MPDU Deaggregation, MPDU Header+CRC Validation, Address1 Filtering, Duplicate Removal, MPDU Decryption
    if (duplicateRemoval && duplicateRemoval->isDuplicate(dataFrame)) {
        delete dataFrame;
        return std::vector<Ieee80211Frame*>();
    }
    BlockAckReordering::ReorderBuffer frames;
    frames[dataFrame->getSequenceNumber()].push_back(dataFrame);
    if (blockAckReordering && blockAckAgreementHandler) {
        Tid tid = dataFrame->getTid();
        MACAddress originatorAddr = dataFrame->getTransmitterAddress();
        RecipientBlockAckAgreement *agreement = blockAckAgreementHandler->getAgreement(tid, originatorAddr);
        if (agreement)
            frames = blockAckReordering->processReceivedQoSFrame(agreement, dataFrame);
    }
    std::vector<Ieee80211Frame *> defragmentedFrames;
    if (basicReassembly) { // FIXME: defragmentation
        for (auto it : frames) {
            auto fragments = it.second;
            Ieee80211DataFrame *frame = defragment(fragments);
            // TODO: revise
            if (frame)
                defragmentedFrames.push_back(frame);
        }
    }
    else {
        for (auto it : frames) {
            auto fragments = it.second;
            if (fragments.size() == 1)
                defragmentedFrames.push_back(fragments.at(0));
            else ; // TODO: drop?
        }
    }
    std::vector<Ieee80211Frame *> deaggregatedFrames;
    if (aMsduDeaggregation) {
        for (auto frame : defragmentedFrames) {
            auto dataFrame = check_and_cast<Ieee80211DataFrame *>(frame);
            if (dataFrame->getAMsduPresent()) {
                auto subframes = aMsduDeaggregation->deaggregateFrame(dataFrame);
                for (auto subframe : *subframes)
                    deaggregatedFrames.push_back(subframe);
                delete subframes;
            }
            else
                deaggregatedFrames.push_back(dataFrame);
        }
    }
    // TODO: MSDU Integrity, Replay Detection, RX MSDU Rate Limiting
    return deaggregatedFrames;
}

Ieee80211DataFrame * inet::ieee80211::RecipientQoSMacDataService::defragment ( std::vector< Ieee80211DataFrame * >  completeFragments )

protectedvirtual

Referenced by controlFrameReceived(), dataFrameReceived(), and managementFrameReceived().

{
    for (auto fragment : completeFragments)
        if (auto completeFrame = dynamic_cast<Ieee80211DataFrame*>(basicReassembly->addFragment(fragment)))
            return completeFrame;
    return nullptr;
}

Ieee80211ManagementFrame * inet::ieee80211::RecipientQoSMacDataService::defragment ( Ieee80211ManagementFrame *  mgmtFragment )

protected

{
    if (auto completeFrame = dynamic_cast<Ieee80211ManagementFrame *>(basicReassembly->addFragment(mgmtFragment)))
        return completeFrame;
    else
        return nullptr;
}

void inet::ieee80211::RecipientQoSMacDataService::initialize ( )

overrideprotectedvirtual

{
    duplicateRemoval = new QoSDuplicateRemoval();
    basicReassembly = new BasicReassembly();
    aMsduDeaggregation = new MsduDeaggregation();
    blockAckReordering = new BlockAckReordering();
}

std::vector< Ieee80211Frame * > inet::ieee80211::RecipientQoSMacDataService::managementFrameReceived ( Ieee80211ManagementFrame *  mgmtFrame )

overridevirtual

Implements inet::ieee80211::IRecipientQoSMacDataService.

{
    // TODO: MPDU Header+CRC Validation, Address1 Filtering, Duplicate Removal, MPDU Decryption
    if (duplicateRemoval && duplicateRemoval->isDuplicate(mgmtFrame))
        return std::vector<Ieee80211Frame*>();
    if (basicReassembly) { // FIXME: defragmentation
        mgmtFrame = defragment(mgmtFrame);
    }
    if (auto delba = dynamic_cast<Ieee80211Delba *>(mgmtFrame))
        blockAckReordering->processReceivedDelba(delba);
    // TODO: Defrag, MSDU Integrity, Replay Detection, RX MSDU Rate Limiting
    return std::vector<Ieee80211Frame*>({mgmtFrame});
}

Member Data Documentation

IMsduDeaggregation* inet::ieee80211::RecipientQoSMacDataService::aMsduDeaggregation = nullptr

protected

Referenced by controlFrameReceived(), dataFrameReceived(), initialize(), and ~RecipientQoSMacDataService().

BasicReassembly* inet::ieee80211::RecipientQoSMacDataService::basicReassembly = nullptr

protected

Referenced by controlFrameReceived(), dataFrameReceived(), defragment(), initialize(), managementFrameReceived(), and ~RecipientQoSMacDataService().

BlockAckReordering* inet::ieee80211::RecipientQoSMacDataService::blockAckReordering = nullptr

protected

Referenced by controlFrameReceived(), dataFrameReceived(), initialize(), managementFrameReceived(), and ~RecipientQoSMacDataService().

IDefragmentation* inet::ieee80211::RecipientQoSMacDataService::defragmentation = nullptr

protected

IDuplicateRemoval* inet::ieee80211::RecipientQoSMacDataService::duplicateRemoval = nullptr

protected

Referenced by dataFrameReceived(), initialize(), managementFrameReceived(), and ~RecipientQoSMacDataService().

---

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

• RecipientQoSMacDataService.h
• RecipientQoSMacDataService.cc