inet::ieee80211::InProgressFrames Class Reference

#include <InProgressFrames.h>

Public Member Functions
	InProgressFrames (PendingQueue *pendingQueue, IOriginatorMacDataService *dataService, IAckHandler *ackHandler)
virtual	~InProgressFrames ()
virtual Ieee80211DataOrMgmtFrame *	getFrameToTransmit ()
virtual Ieee80211DataOrMgmtFrame *	getPendingFrameFor (Ieee80211Frame *frame)
virtual void	dropFrame (Ieee80211DataOrMgmtFrame *dataOrMgmtFrame)
virtual void	dropFrames (std::set< std::pair< MACAddress, std::pair< Tid, SequenceControlField >>> seqAndFragNums)
virtual bool	hasInProgressFrames ()
virtual std::vector< Ieee80211DataFrame * >	getOutstandingFrames ()
virtual void	clearDroppedFrames ()

Protected Member Functions
void	ensureHasFrameToTransmit ()
bool	hasEligibleFrameToTransmit ()

Protected Attributes
PendingQueue *	pendingQueue = nullptr
IOriginatorMacDataService *	dataService = nullptr
IAckHandler *	ackHandler = nullptr
std::list< Ieee80211DataOrMgmtFrame * >	inProgressFrames
std::vector< Ieee80211DataOrMgmtFrame * >	droppedFrames

Constructor & Destructor Documentation

inet::ieee80211::InProgressFrames::InProgressFrames ( PendingQueue *  pendingQueue, IOriginatorMacDataService *  dataService, IAckHandler *  ackHandler  )

inline

                                                                                                                      :
            pendingQueue(pendingQueue),
            dataService(dataService),
            ackHandler(ackHandler)
        { }

inet::ieee80211::InProgressFrames::~InProgressFrames ( )

virtual

{
    for (auto frame : inProgressFrames)
        delete frame;
    for (auto frame : droppedFrames)
        delete frame;
}

Member Function Documentation

void inet::ieee80211::InProgressFrames::clearDroppedFrames ( )

virtual

Referenced by inet::ieee80211::FrameSequenceContext::~FrameSequenceContext().

{
    for (auto frame : droppedFrames)
        delete frame;
    droppedFrames.clear();
}

void inet::ieee80211::InProgressFrames::dropFrame ( Ieee80211DataOrMgmtFrame *  dataOrMgmtFrame )

virtual

Referenced by inet::ieee80211::Dcf::originatorProcessFailedFrame(), inet::ieee80211::Dcf::originatorProcessReceivedFrame(), inet::ieee80211::Dcf::originatorProcessRtsProtectionFailed(), and inet::ieee80211::Dcf::originatorProcessTransmittedFrame().

{
    inProgressFrames.remove(frame);
    droppedFrames.push_back(frame);
}

void inet::ieee80211::InProgressFrames::dropFrames ( std::set< std::pair< MACAddress, std::pair< Tid, SequenceControlField >>>  seqAndFragNums )

virtual

{
    for (auto it = inProgressFrames.begin(); it != inProgressFrames.end();) {
        auto frame = *it;
        if (frame->getType() == ST_DATA_WITH_QOS) {
            auto dataFrame = check_and_cast<const Ieee80211DataFrame*>(frame);
            if (seqAndFragNums.count(std::make_pair(dataFrame->getReceiverAddress(), std::make_pair(dataFrame->getTid(), SequenceControlField(dataFrame->getSequenceNumber(), dataFrame->getFragmentNumber())))) != 0) {
                it = inProgressFrames.erase(it);
                droppedFrames.push_back(frame);
            }
            else
                it++;
        }
        else
            it++;
    }
}

void inet::ieee80211::InProgressFrames::ensureHasFrameToTransmit ( )

protected

Referenced by getFrameToTransmit().

{
//    TODO: delete old frames from inProgressFrames
//    if (auto dataFrame = dynamic_cast<Ieee80211DataFrame*>(frame)) {
//        if (transmitLifetimeHandler->isLifetimeExpired(dataFrame))
//            return frame;
//    }
    if (!hasEligibleFrameToTransmit()) {
        auto frames = dataService->extractFramesToTransmit(pendingQueue);
        if (frames) {
            for (auto frame : *frames) {
                ackHandler->frameGotInProgress(frame);
                inProgressFrames.push_back(frame);
            }
            delete frames;
        }
    }
}

Ieee80211DataOrMgmtFrame * inet::ieee80211::InProgressFrames::getFrameToTransmit ( )

virtual

Referenced by getPendingFrameFor(), inet::ieee80211::DcfFs::hasMoreFragments(), inet::ieee80211::HcfFs::hasMoreTxOps(), inet::ieee80211::HcfFs::hasMoreTxOpsAndMulticast(), inet::ieee80211::DcfFs::isBroadcastManagementOrGroupDataSequenceNeeded(), inet::ieee80211::DcfFs::isFragFrameSequenceNeeded(), inet::ieee80211::TxOpFs::isRtsCtsNeeded(), inet::ieee80211::DcfFs::isRtsCtsNeeded(), inet::ieee80211::Dcf::originatorProcessTransmittedFrame(), inet::ieee80211::DataFs::prepareStep(), inet::ieee80211::ManagementAckFs::prepareStep(), inet::ieee80211::ManagementFs::prepareStep(), inet::ieee80211::RtsCtsFs::prepareStep(), inet::ieee80211::RtsFs::prepareStep(), inet::ieee80211::FragFrameAckFs::prepareStep(), inet::ieee80211::LastFrameAckFs::prepareStep(), inet::ieee80211::HcfFs::selectDataOrManagementSequence(), inet::ieee80211::HcfFs::selectHcfSequence(), inet::ieee80211::DcfFs::selectMulticastDataOrMgmt(), and inet::ieee80211::TxOpFs::selectTxOpSequence().

{
    ensureHasFrameToTransmit();
    for (auto frame : inProgressFrames) {
        if (ackHandler->isEligibleToTransmit(frame))
            return frame;
    }
    return nullptr;
}

std::vector< Ieee80211DataFrame * > inet::ieee80211::InProgressFrames::getOutstandingFrames ( )

virtual

Referenced by inet::ieee80211::OriginatorQoSAckPolicy::getOutstandingFramesPerReceiver().

{
    std::vector<Ieee80211DataFrame*> outstandingFrames;
    for (auto frame : inProgressFrames) {
        if (ackHandler->isOutstandingFrame(frame))
            outstandingFrames.push_back(check_and_cast<Ieee80211DataFrame*>(frame));
    }
    return outstandingFrames;
}

Ieee80211DataOrMgmtFrame * inet::ieee80211::InProgressFrames::getPendingFrameFor ( Ieee80211Frame *  frame )

virtual

Referenced by inet::ieee80211::Dcf::transmitFrame().

{
    auto frameToTransmit = getFrameToTransmit();
    if (dynamic_cast<Ieee80211RTSFrame *>(frame))
        return frameToTransmit;
    else {
        for (auto frame : inProgressFrames) {
            if (ackHandler->isEligibleToTransmit(frame) && frameToTransmit != frame)
                return frame;
        }
        auto frames = dataService->extractFramesToTransmit(pendingQueue);
        if (frames) {
            auto firstFrame = (*frames)[0];
            for (auto frame : *frames) {
                ackHandler->frameGotInProgress(frame);
                inProgressFrames.push_back(frame);
            }
            delete frames;
            // FIXME: If the next Txop sequence were a BlockAckReqBlockAckFs then this would return
            // a wrong pending frame.
            return firstFrame;
        }
        else
            return nullptr;
    }
}

bool inet::ieee80211::InProgressFrames::hasEligibleFrameToTransmit ( )

protected

Referenced by ensureHasFrameToTransmit().

{
    for (auto frame : inProgressFrames) {
        if (ackHandler->isEligibleToTransmit(frame))
            return true;
    }
    return false;
}

virtual bool inet::ieee80211::InProgressFrames::hasInProgressFrames ( )

inlinevirtual

Referenced by inet::ieee80211::Dcf::hasFrameToTransmit(), inet::ieee80211::DcfFs::hasMoreFragments(), inet::ieee80211::HcfFs::hasMoreTxOps(), inet::ieee80211::DcfFs::isBroadcastManagementOrGroupDataSequenceNeeded(), and inet::ieee80211::DcfFs::isFragFrameSequenceNeeded().

{ ensureHasFrameToTransmit(); return hasEligibleFrameToTransmit(); }

Member Data Documentation

IAckHandler* inet::ieee80211::InProgressFrames::ackHandler = nullptr

protected

Referenced by ensureHasFrameToTransmit(), getFrameToTransmit(), getOutstandingFrames(), getPendingFrameFor(), and hasEligibleFrameToTransmit().

IOriginatorMacDataService* inet::ieee80211::InProgressFrames::dataService = nullptr

protected

Referenced by ensureHasFrameToTransmit(), and getPendingFrameFor().

std::vector<Ieee80211DataOrMgmtFrame *> inet::ieee80211::InProgressFrames::droppedFrames

protected

Referenced by clearDroppedFrames(), dropFrame(), dropFrames(), and ~InProgressFrames().

std::list<Ieee80211DataOrMgmtFrame *> inet::ieee80211::InProgressFrames::inProgressFrames

protected

Referenced by dropFrame(), dropFrames(), ensureHasFrameToTransmit(), getFrameToTransmit(), getOutstandingFrames(), getPendingFrameFor(), hasEligibleFrameToTransmit(), and ~InProgressFrames().

PendingQueue* inet::ieee80211::InProgressFrames::pendingQueue = nullptr

protected

Referenced by ensureHasFrameToTransmit(), and getPendingFrameFor().

---

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

• InProgressFrames.h
• InProgressFrames.cc