inet::ieee80211::Ieee80211MgmtSTA Class Reference

Used in 802.11 infrastructure mode: handles management frames for a station (STA). More...

#include <Ieee80211MgmtSTA.h>

Inheritance diagram for inet::ieee80211::Ieee80211MgmtSTA:

Classes
struct	APInfo
struct	AssociatedAPInfo
struct	ScanningInfo

Public Member Functions
	Ieee80211MgmtSTA ()
Public Member Functions inherited from inet::ieee80211::Ieee80211MgmtBase
virtual bool	handleOperationStage (LifecycleOperation *operation, int stage, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()

Protected Types
typedef std::list< APInfo >	AccessPointList

Protected Member Functions
virtual int	numInitStages () const override
virtual void	initialize (int stage) override
virtual void	handleTimer (cMessage *msg) override
	Implements abstract Ieee80211MgmtBase method. More...
virtual void	handleUpperMessage (cPacket *msg) override
	Implements abstract Ieee80211MgmtBase method. More...
virtual void	handleCommand (int msgkind, cObject *ctrl) override
	Implements abstract Ieee80211MgmtBase method. More...
virtual Ieee80211DataFrame *	encapsulate (cPacket *msg)
	Utility function for handleUpperMessage() More...
virtual cPacket *	decapsulate (Ieee80211DataFrame *frame)
	Utility method to decapsulate a data frame. More...
virtual void	startAuthentication (APInfo *ap, simtime_t timeout)
	Utility function: sends authentication request. More...
virtual void	startAssociation (APInfo *ap, simtime_t timeout)
	Utility function: sends association request. More...
virtual APInfo *	lookupAP (const MACAddress &address)
	Utility function: looks up AP in our AP list. More...
virtual void	clearAPList ()
	Utility function: clear the AP list, and cancel any pending authentications. More...
virtual void	changeChannel (int channelNum)
	Utility function: switches to the given radio channel. More...
virtual void	storeAPInfo (const MACAddress &address, const Ieee80211BeaconFrameBody &body)
	Stores AP info received in a beacon or probe response. More...
virtual bool	scanNextChannel ()
	Switches to the next channel to scan; returns true if done (there wasn't any more channel to scan). More...
virtual void	sendProbeRequest ()
	Broadcasts a Probe Request. More...
virtual void	beaconLost ()
	Missed a few consecutive beacons. More...
virtual void	sendScanConfirm ()
	Sends back result of scanning to the agent. More...
virtual void	sendAuthenticationConfirm (APInfo *ap, int resultCode)
	Sends back result of authentication to the agent. More...
virtual void	sendAssociationConfirm (APInfo *ap, int resultCode)
	Sends back result of association to the agent. More...
virtual void	disassociate ()
	Utility function: Cancel the existing association. More...
virtual void	sendConfirm (Ieee80211PrimConfirm *confirm, int resultCode)
	Utility function: sends a confirmation to the agent. More...
virtual void	sendManagementFrame (Ieee80211ManagementFrame *frame, const MACAddress &address)
	Utility function: sends a management frame. More...
virtual void	receiveSignal (cComponent *source, simsignal_t signalID, long value, cObject *details) override
	Called by the signal handler whenever a change occurs we're interested in. More...
virtual void	receiveSignal (cComponent *source, simsignal_t signalID, cObject *obj, cObject *details) override
virtual int	statusCodeToPrimResultCode (int statusCode)
	Utility function: converts Ieee80211StatusCode (->frame) to Ieee80211PrimResultCode (->primitive) More...
Processing of different frame types
virtual void	handleDataFrame (Ieee80211DataFrame *frame) override
virtual void	handleAuthenticationFrame (Ieee80211AuthenticationFrame *frame) override
virtual void	handleDeauthenticationFrame (Ieee80211DeauthenticationFrame *frame) override
virtual void	handleAssociationRequestFrame (Ieee80211AssociationRequestFrame *frame) override
virtual void	handleAssociationResponseFrame (Ieee80211AssociationResponseFrame *frame) override
virtual void	handleReassociationRequestFrame (Ieee80211ReassociationRequestFrame *frame) override
virtual void	handleReassociationResponseFrame (Ieee80211ReassociationResponseFrame *frame) override
virtual void	handleDisassociationFrame (Ieee80211DisassociationFrame *frame) override
virtual void	handleBeaconFrame (Ieee80211BeaconFrame *frame) override
virtual void	handleProbeRequestFrame (Ieee80211ProbeRequestFrame *frame) override
virtual void	handleProbeResponseFrame (Ieee80211ProbeResponseFrame *frame) override
Processing of different agent commands
virtual void	processScanCommand (Ieee80211Prim_ScanRequest *ctrl)
virtual void	processAuthenticateCommand (Ieee80211Prim_AuthenticateRequest *ctrl)
virtual void	processDeauthenticateCommand (Ieee80211Prim_DeauthenticateRequest *ctrl)
virtual void	processAssociateCommand (Ieee80211Prim_AssociateRequest *ctrl)
virtual void	processReassociateCommand (Ieee80211Prim_ReassociateRequest *ctrl)
virtual void	processDisassociateCommand (Ieee80211Prim_DisassociateRequest *ctrl)
Protected Member Functions inherited from inet::ieee80211::Ieee80211MgmtBase
virtual void	handleMessage (cMessage *msg) override
	Dispatches incoming messages to handleTimer(), handleUpperMessage() or processFrame(). More...
virtual void	sendDown (cPacket *frame)
	Utility method for implementing handleUpperMessage(): send message to MAC. More...
virtual void	dropManagementFrame (Ieee80211ManagementFrame *frame)
	Utility method to dispose of an unhandled frame. More...
virtual void	sendUp (cMessage *msg)
	Utility method: sends the packet to the upper layer. More...
virtual void	processFrame (Ieee80211DataOrMgmtFrame *frame)
	Dispatch to frame processing methods according to frame type. More...
virtual void	start ()
	lifecycle support More...
virtual void	stop ()

Protected Attributes
cModule *	host
IInterfaceTable *	interfaceTable
InterfaceEntry *	myIface
int	numChannels
bool	isScanning
ScanningInfo	scanning
AccessPointList	apList
bool	isAssociated
cMessage *	assocTimeoutMsg
AssociatedAPInfo	assocAP
Protected Attributes inherited from inet::ieee80211::Ieee80211MgmtBase
MACAddress	myAddress
bool	isOperational
long	numDataFramesReceived
long	numMgmtFramesReceived
long	numMgmtFramesDropped

Detailed Description

Used in 802.11 infrastructure mode: handles management frames for a station (STA).

See corresponding NED file for a detailed description.

Author

Andras Varga

Member Typedef Documentation

typedef std::list<APInfo> inet::ieee80211::Ieee80211MgmtSTA::AccessPointList

protected

Constructor & Destructor Documentation

inet::ieee80211::Ieee80211MgmtSTA::Ieee80211MgmtSTA ( )

inline

: host(nullptr), interfaceTable(nullptr), myIface(nullptr), numChannels(-1), isScanning(false), isAssociated(false), assocTimeoutMsg(nullptr) {}

Member Function Documentation

void inet::ieee80211::Ieee80211MgmtSTA::beaconLost ( )

protectedvirtual

Missed a few consecutive beacons.

{
    EV << "Missed a few consecutive beacons -- AP is considered lost\n";
    emit(NF_L2_BEACON_LOST, myIface);
}

void inet::ieee80211::Ieee80211MgmtSTA::changeChannel ( int  channelNum )

protectedvirtual

Utility function: switches to the given radio channel.

{
    EV << "Tuning to channel #" << channelNum << "\n";

    Ieee80211ConfigureRadioCommand *configureCommand = new Ieee80211ConfigureRadioCommand();
    configureCommand->setChannelNumber(channelNum);
    cMessage *msg = new cMessage("changeChannel", RADIO_C_CONFIGURE);
    msg->setControlInfo(configureCommand);
    send(msg, "macOut");
}

void inet::ieee80211::Ieee80211MgmtSTA::clearAPList ( )

protectedvirtual

Utility function: clear the AP list, and cancel any pending authentications.

{
    for (auto & elem : apList)
        if (elem.authTimeoutMsg)
            delete cancelEvent(elem.authTimeoutMsg);

    apList.clear();
}

cPacket * inet::ieee80211::Ieee80211MgmtSTA::decapsulate ( Ieee80211DataFrame *  frame )

protectedvirtual

Utility method to decapsulate a data frame.

{
    cPacket *payload = frame->decapsulate();

    Ieee802Ctrl *ctrl = new Ieee802Ctrl();
    ctrl->setSrc(frame->getAddress3());
    ctrl->setDest(frame->getReceiverAddress());
    if (frame->getType() == ST_DATA_WITH_QOS) {
        int tid = frame->getTid();
        if (tid < 8)
            ctrl->setUserPriority(tid); // TID values 0..7 are UP
    }
    Ieee80211DataFrameWithSNAP *frameWithSNAP = dynamic_cast<Ieee80211DataFrameWithSNAP *>(frame);
    if (frameWithSNAP)
        ctrl->setEtherType(frameWithSNAP->getEtherType());
    payload->setControlInfo(ctrl);

    delete frame;
    return payload;
}

void inet::ieee80211::Ieee80211MgmtSTA::disassociate ( )

protectedvirtual

Utility function: Cancel the existing association.

{
    EV << "Disassociating from AP address=" << assocAP.address << "\n";
    ASSERT(isAssociated);
    isAssociated = false;
    delete cancelEvent(assocAP.beaconTimeoutMsg);
    assocAP.beaconTimeoutMsg = nullptr;
    assocAP = AssociatedAPInfo();    // clear it
}

Ieee80211DataFrame * inet::ieee80211::Ieee80211MgmtSTA::encapsulate ( cPacket *  msg )

protectedvirtual

Utility function for handleUpperMessage()

{
    Ieee80211DataFrameWithSNAP *frame = new Ieee80211DataFrameWithSNAP(msg->getName());

    // frame goes to the AP
    frame->setToDS(true);

    // receiver is the AP
    frame->setReceiverAddress(assocAP.address);

    // destination address is in address3
    Ieee802Ctrl *ctrl = check_and_cast<Ieee802Ctrl *>(msg->removeControlInfo());
    frame->setAddress3(ctrl->getDest());
    frame->setEtherType(ctrl->getEtherType());
    int up = ctrl->getUserPriority();
    if (up >= 0) {
        // make it a QoS frame, and set TID
        frame->setType(ST_DATA_WITH_QOS);
        frame->addBitLength(QOSCONTROL_BITS);
        frame->setTid(up);
    }
    delete ctrl;

    frame->encapsulate(msg);
    return frame;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleAssociationRequestFrame ( Ieee80211AssociationRequestFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    dropManagementFrame(frame);
}

void inet::ieee80211::Ieee80211MgmtSTA::handleAssociationResponseFrame ( Ieee80211AssociationResponseFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    EV << "Received Association Response frame\n";

    if (!assocTimeoutMsg) {
        EV << "No association in progress, ignoring frame\n";
        delete frame;
        return;
    }

    // extract frame contents
    MACAddress address = frame->getTransmitterAddress();
    int statusCode = frame->getBody().getStatusCode();
    //XXX short aid;
    //XXX Ieee80211SupportedRatesElement supportedRates;
    delete frame;

    // look up AP data structure
    APInfo *ap = lookupAP(address);
    if (!ap)
        throw cRuntimeError("handleAssociationResponseFrame: AP not known: address=%s", address.str().c_str());

    if (isAssociated) {
        EV << "Breaking existing association with AP address=" << assocAP.address << "\n";
        isAssociated = false;
        delete cancelEvent(assocAP.beaconTimeoutMsg);
        assocAP.beaconTimeoutMsg = nullptr;
        assocAP = AssociatedAPInfo();
    }

    delete cancelEvent(assocTimeoutMsg);
    assocTimeoutMsg = nullptr;

    if (statusCode != SC_SUCCESSFUL) {
        EV << "Association failed with AP address=" << ap->address << "\n";
    }
    else {
        EV << "Association successful, AP address=" << ap->address << "\n";

        // change our state to "associated"
        isAssociated = true;
        (APInfo&)assocAP = (*ap);

        emit(NF_L2_ASSOCIATED, myIface, ap);

        assocAP.beaconTimeoutMsg = new cMessage("beaconTimeout", MK_BEACON_TIMEOUT);
        scheduleAt(simTime() + MAX_BEACONS_MISSED * assocAP.beaconInterval, assocAP.beaconTimeoutMsg);
    }

    // report back to agent
    sendAssociationConfirm(ap, statusCodeToPrimResultCode(statusCode));
}

void inet::ieee80211::Ieee80211MgmtSTA::handleAuthenticationFrame ( Ieee80211AuthenticationFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    MACAddress address = frame->getTransmitterAddress();
    int frameAuthSeq = frame->getBody().getSequenceNumber();
    EV << "Received Authentication frame from address=" << address << ", seqNum=" << frameAuthSeq << "\n";

    APInfo *ap = lookupAP(address);
    if (!ap) {
        EV << "AP not known, discarding authentication frame\n";
        delete frame;
        return;
    }

    // what if already authenticated with AP
    if (ap->isAuthenticated) {
        EV << "AP already authenticated, ignoring frame\n";
        delete frame;
        return;
    }

    // is authentication is in progress with this AP?
    if (!ap->authTimeoutMsg) {
        EV << "No authentication in progress with AP, ignoring frame\n";
        delete frame;
        return;
    }

    // check authentication sequence number is OK
    if (frameAuthSeq != ap->authSeqExpected) {
        // wrong sequence number: send error and return
        EV << "Wrong sequence number, " << ap->authSeqExpected << " expected\n";
        Ieee80211AuthenticationFrame *resp = new Ieee80211AuthenticationFrame("Auth-ERROR");
        resp->getBody().setStatusCode(SC_AUTH_OUT_OF_SEQ);
        sendManagementFrame(resp, frame->getTransmitterAddress());
        delete frame;

        // cancel timeout, send error to agent
        delete cancelEvent(ap->authTimeoutMsg);
        ap->authTimeoutMsg = nullptr;
        sendAuthenticationConfirm(ap, PRC_REFUSED);    //XXX or what resultCode?
        return;
    }

    // check if more exchanges are needed for auth to be complete
    int statusCode = frame->getBody().getStatusCode();

    if (statusCode == SC_SUCCESSFUL && !frame->getBody().getIsLast()) {
        EV << "More steps required, sending another Authentication frame\n";

        // more steps required, send another Authentication frame
        Ieee80211AuthenticationFrame *resp = new Ieee80211AuthenticationFrame("Auth");
        resp->getBody().setSequenceNumber(frameAuthSeq + 1);
        resp->getBody().setStatusCode(SC_SUCCESSFUL);
        // XXX frame length could be increased to account for challenge text length etc.
        sendManagementFrame(resp, address);
        ap->authSeqExpected += 2;
    }
    else {
        if (statusCode == SC_SUCCESSFUL)
            EV << "Authentication successful\n";
        else
            EV << "Authentication failed\n";

        // authentication completed
        ap->isAuthenticated = (statusCode == SC_SUCCESSFUL);
        delete cancelEvent(ap->authTimeoutMsg);
        ap->authTimeoutMsg = nullptr;
        sendAuthenticationConfirm(ap, statusCodeToPrimResultCode(statusCode));
    }

    delete frame;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleBeaconFrame ( Ieee80211BeaconFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    EV << "Received Beacon frame\n";
    storeAPInfo(frame->getTransmitterAddress(), frame->getBody());

    // if it is out associate AP, restart beacon timeout
    if (isAssociated && frame->getTransmitterAddress() == assocAP.address) {
        EV << "Beacon is from associated AP, restarting beacon timeout timer\n";
        ASSERT(assocAP.beaconTimeoutMsg != nullptr);
        cancelEvent(assocAP.beaconTimeoutMsg);
        scheduleAt(simTime() + MAX_BEACONS_MISSED * assocAP.beaconInterval, assocAP.beaconTimeoutMsg);

        //APInfo *ap = lookupAP(frame->getTransmitterAddress());
        //ASSERT(ap!=nullptr);
    }

    delete frame;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleCommand ( int  msgkind, cObject *  ctrl  )

overrideprotectedvirtual

Implements abstract Ieee80211MgmtBase method.

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    if (dynamic_cast<Ieee80211Prim_ScanRequest *>(ctrl))
        processScanCommand((Ieee80211Prim_ScanRequest *)ctrl);
    else if (dynamic_cast<Ieee80211Prim_AuthenticateRequest *>(ctrl))
        processAuthenticateCommand((Ieee80211Prim_AuthenticateRequest *)ctrl);
    else if (dynamic_cast<Ieee80211Prim_DeauthenticateRequest *>(ctrl))
        processDeauthenticateCommand((Ieee80211Prim_DeauthenticateRequest *)ctrl);
    else if (dynamic_cast<Ieee80211Prim_AssociateRequest *>(ctrl))
        processAssociateCommand((Ieee80211Prim_AssociateRequest *)ctrl);
    else if (dynamic_cast<Ieee80211Prim_ReassociateRequest *>(ctrl))
        processReassociateCommand((Ieee80211Prim_ReassociateRequest *)ctrl);
    else if (dynamic_cast<Ieee80211Prim_DisassociateRequest *>(ctrl))
        processDisassociateCommand((Ieee80211Prim_DisassociateRequest *)ctrl);
    else if (ctrl)
        throw cRuntimeError("handleCommand(): unrecognized control info class `%s'", ctrl->getClassName());
    else
        throw cRuntimeError("handleCommand(): control info is nullptr");
    delete ctrl;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleDataFrame ( Ieee80211DataFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    // Only send the Data frame up to the higher layer if the STA is associated with an AP,
    // else delete the frame
    if (isAssociated)
        sendUp(decapsulate(frame));
    else {
        EV << "Rejecting data frame as STA is not associated with an AP" << endl;
        delete frame;
    }
}

void inet::ieee80211::Ieee80211MgmtSTA::handleDeauthenticationFrame ( Ieee80211DeauthenticationFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    EV << "Received Deauthentication frame\n";
    const MACAddress& address = frame->getAddress3();    // source address
    APInfo *ap = lookupAP(address);
    if (!ap || !ap->isAuthenticated) {
        EV << "Unknown AP, or not authenticated with that AP -- ignoring frame\n";
        delete frame;
        return;
    }
    if (ap->authTimeoutMsg) {
        delete cancelEvent(ap->authTimeoutMsg);
        ap->authTimeoutMsg = nullptr;
        EV << "Cancelling pending authentication\n";
        delete frame;
        return;
    }

    EV << "Setting isAuthenticated flag for that AP to false\n";
    ap->isAuthenticated = false;
    delete frame;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleDisassociationFrame ( Ieee80211DisassociationFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    EV << "Received Disassociation frame\n";
    const MACAddress& address = frame->getAddress3();    // source address

    if (assocTimeoutMsg) {
        // pending association
        delete cancelEvent(assocTimeoutMsg);
        assocTimeoutMsg = nullptr;
    }
    if (!isAssociated || address != assocAP.address) {
        EV << "Not associated with that AP -- ignoring frame\n";
        delete frame;
        return;
    }

    EV << "Setting isAssociated flag to false\n";
    isAssociated = false;
    delete cancelEvent(assocAP.beaconTimeoutMsg);
    assocAP.beaconTimeoutMsg = nullptr;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleProbeRequestFrame ( Ieee80211ProbeRequestFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    dropManagementFrame(frame);
}

void inet::ieee80211::Ieee80211MgmtSTA::handleProbeResponseFrame ( Ieee80211ProbeResponseFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    EV << "Received Probe Response frame\n";
    storeAPInfo(frame->getTransmitterAddress(), frame->getBody());
    delete frame;
}

void inet::ieee80211::Ieee80211MgmtSTA::handleReassociationRequestFrame ( Ieee80211ReassociationRequestFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    dropManagementFrame(frame);
}

void inet::ieee80211::Ieee80211MgmtSTA::handleReassociationResponseFrame ( Ieee80211ReassociationResponseFrame *  frame )

overrideprotectedvirtual

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    EV << "Received Reassociation Response frame\n";
    //TBD handle with the same code as Association Response?
}

void inet::ieee80211::Ieee80211MgmtSTA::handleTimer ( cMessage *  msg )

overrideprotectedvirtual

Implements abstract Ieee80211MgmtBase method.

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    if (msg->getKind() == MK_AUTH_TIMEOUT) {
        // authentication timed out
        APInfo *ap = (APInfo *)msg->getContextPointer();
        EV << "Authentication timed out, AP address = " << ap->address << "\n";

        // send back failure report to agent
        sendAuthenticationConfirm(ap, PRC_TIMEOUT);
    }
    else if (msg->getKind() == MK_ASSOC_TIMEOUT) {
        // association timed out
        APInfo *ap = (APInfo *)msg->getContextPointer();
        EV << "Association timed out, AP address = " << ap->address << "\n";

        // send back failure report to agent
        sendAssociationConfirm(ap, PRC_TIMEOUT);
    }
    else if (msg->getKind() == MK_SCAN_MAXCHANNELTIME) {
        // go to next channel during scanning
        bool done = scanNextChannel();
        if (done)
            sendScanConfirm(); // send back response to agents' "scan" command
        delete msg;
    }
    else if (msg->getKind() == MK_SCAN_SENDPROBE) {
        // Active Scan: send a probe request, then wait for minChannelTime (11.1.3.2.2)
        delete msg;
        sendProbeRequest();
        cMessage *timerMsg = new cMessage("minChannelTime", MK_SCAN_MINCHANNELTIME);
        scheduleAt(simTime() + scanning.minChannelTime, timerMsg);    //XXX actually, we should start waiting after ProbeReq actually got transmitted
    }
    else if (msg->getKind() == MK_SCAN_MINCHANNELTIME) {
        // Active Scan: after minChannelTime, possibly listen for the remaining time until maxChannelTime
        delete msg;
        if (scanning.busyChannelDetected) {
            EV << "Busy channel detected during minChannelTime, continuing listening until maxChannelTime elapses\n";
            cMessage *timerMsg = new cMessage("maxChannelTime", MK_SCAN_MAXCHANNELTIME);
            scheduleAt(simTime() + scanning.maxChannelTime - scanning.minChannelTime, timerMsg);
        }
        else {
            EV << "Channel was empty during minChannelTime, going to next channel\n";
            bool done = scanNextChannel();
            if (done)
                sendScanConfirm(); // send back response to agents' "scan" command
        }
    }
    else if (msg->getKind() == MK_BEACON_TIMEOUT) {
        // missed a few consecutive beacons
        beaconLost();
    }
    else {
        throw cRuntimeError("internal error: unrecognized timer '%s'", msg->getName());
    }
}

void inet::ieee80211::Ieee80211MgmtSTA::handleUpperMessage ( cPacket *  msg )

overrideprotectedvirtual

Implements abstract Ieee80211MgmtBase method.

Implements inet::ieee80211::Ieee80211MgmtBase.

{
    if (!isAssociated || assocAP.address.isUnspecified()) {
        EV << "STA is not associated with an access point, discarding packet" << msg << "\n";
        delete msg;
        return;
    }

    Ieee80211DataFrame *frame = encapsulate(msg);
    sendDown(frame);
}

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

overrideprotectedvirtual

Reimplemented from inet::ieee80211::Ieee80211MgmtBase.

{
    Ieee80211MgmtBase::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        isScanning = false;
        isAssociated = false;
        assocTimeoutMsg = nullptr;
        myIface = nullptr;
        numChannels = par("numChannels");

        host = getContainingNode(this);
        host->subscribe(NF_LINK_FULL_PROMISCUOUS, this);

        WATCH(isScanning);
        WATCH(isAssociated);

        WATCH(scanning);
        WATCH(assocAP);
        WATCH_LIST(apList);
    }
    else if (stage == INITSTAGE_LINK_LAYER_2) {
        IInterfaceTable *ift = findModuleFromPar<IInterfaceTable>(par("interfaceTableModule"), this);
        if (ift) {
            myIface = ift->getInterfaceByName(utils::stripnonalnum(findModuleUnderContainingNode(this)->getFullName()).c_str());
        }
    }
}

Ieee80211MgmtSTA::APInfo * inet::ieee80211::Ieee80211MgmtSTA::lookupAP ( const MACAddress &  address )

protectedvirtual

Utility function: looks up AP in our AP list.

Returns nullptr if not found.

{
    for (auto & elem : apList)
        if (elem.address == address)
            return &(elem);

    return nullptr;
}

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

inlineoverrideprotectedvirtual

Reimplemented from inet::ieee80211::Ieee80211MgmtBase.

{ return NUM_INIT_STAGES; }

void inet::ieee80211::Ieee80211MgmtSTA::processAssociateCommand ( Ieee80211Prim_AssociateRequest *  ctrl )

protectedvirtual

{
    const MACAddress& address = ctrl->getAddress();
    APInfo *ap = lookupAP(address);
    if (!ap)
        throw cRuntimeError("processAssociateCommand: AP not known: address = %s", address.str().c_str());
    startAssociation(ap, ctrl->getTimeout());
}

void inet::ieee80211::Ieee80211MgmtSTA::processAuthenticateCommand ( Ieee80211Prim_AuthenticateRequest *  ctrl )

protectedvirtual

{
    const MACAddress& address = ctrl->getAddress();
    APInfo *ap = lookupAP(address);
    if (!ap)
        throw cRuntimeError("processAuthenticateCommand: AP not known: address = %s", address.str().c_str());
    startAuthentication(ap, ctrl->getTimeout());
}

void inet::ieee80211::Ieee80211MgmtSTA::processDeauthenticateCommand ( Ieee80211Prim_DeauthenticateRequest *  ctrl )

protectedvirtual

{
    const MACAddress& address = ctrl->getAddress();
    APInfo *ap = lookupAP(address);
    if (!ap)
        throw cRuntimeError("processDeauthenticateCommand: AP not known: address = %s", address.str().c_str());

    if (isAssociated && assocAP.address == address)
        disassociate();

    if (ap->isAuthenticated)
        ap->isAuthenticated = false;

    // cancel possible pending authentication timer
    if (ap->authTimeoutMsg) {
        delete cancelEvent(ap->authTimeoutMsg);
        ap->authTimeoutMsg = nullptr;
    }

    // create and send deauthentication request
    Ieee80211DeauthenticationFrame *frame = new Ieee80211DeauthenticationFrame("Deauth");
    frame->getBody().setReasonCode(ctrl->getReasonCode());
    sendManagementFrame(frame, address);
}

void inet::ieee80211::Ieee80211MgmtSTA::processDisassociateCommand ( Ieee80211Prim_DisassociateRequest *  ctrl )

protectedvirtual

{
    const MACAddress& address = ctrl->getAddress();

    if (isAssociated && address == assocAP.address) {
        disassociate();
    }
    else if (assocTimeoutMsg) {
        // pending association
        delete cancelEvent(assocTimeoutMsg);
        assocTimeoutMsg = nullptr;
    }

    // create and send disassociation request
    Ieee80211DisassociationFrame *frame = new Ieee80211DisassociationFrame("Disass");
    frame->getBody().setReasonCode(ctrl->getReasonCode());
    sendManagementFrame(frame, address);
}

void inet::ieee80211::Ieee80211MgmtSTA::processReassociateCommand ( Ieee80211Prim_ReassociateRequest *  ctrl )

protectedvirtual

{
    // treat the same way as association
    //XXX refine
    processAssociateCommand(ctrl);
}

void inet::ieee80211::Ieee80211MgmtSTA::processScanCommand ( Ieee80211Prim_ScanRequest *  ctrl )

protectedvirtual

{
    EV << "Received Scan Request from agent, clearing AP list and starting scanning...\n";

    if (isScanning)
        throw cRuntimeError("processScanCommand: scanning already in progress");
    if (isAssociated) {
        disassociate();
    }
    else if (assocTimeoutMsg) {
        EV << "Cancelling ongoing association process\n";
        delete cancelEvent(assocTimeoutMsg);
        assocTimeoutMsg = nullptr;
    }

    // clear existing AP list (and cancel any pending authentications) -- we want to start with a clean page
    clearAPList();

    // fill in scanning state
    ASSERT(ctrl->getBSSType() == BSSTYPE_INFRASTRUCTURE);
    scanning.bssid = ctrl->getBSSID().isUnspecified() ? MACAddress::BROADCAST_ADDRESS : ctrl->getBSSID();
    scanning.ssid = ctrl->getSSID();
    scanning.activeScan = ctrl->getActiveScan();
    scanning.probeDelay = ctrl->getProbeDelay();
    scanning.channelList.clear();
    scanning.minChannelTime = ctrl->getMinChannelTime();
    scanning.maxChannelTime = ctrl->getMaxChannelTime();
    ASSERT(scanning.minChannelTime <= scanning.maxChannelTime);

    // channel list to scan (default: all channels)
    for (int i = 0; i < (int)ctrl->getChannelListArraySize(); i++)
        scanning.channelList.push_back(ctrl->getChannelList(i));
    if (scanning.channelList.empty())
        for (int i = 0; i < numChannels; i++)
            scanning.channelList.push_back(i);


    // start scanning
    if (scanning.activeScan)
        host->subscribe(IRadio::receptionStateChangedSignal, this);
    scanning.currentChannelIndex = -1;    // so we'll start with index==0
    isScanning = true;
    scanNextChannel();
}

void inet::ieee80211::Ieee80211MgmtSTA::receiveSignal ( cComponent *  source, simsignal_t  signalID, long  value, cObject *  details  )

overrideprotectedvirtual

Called by the signal handler whenever a change occurs we're interested in.

{
    Enter_Method_Silent();
    // Note that we are only subscribed during scanning!
    if (signalID == IRadio::receptionStateChangedSignal) {
        IRadio::ReceptionState newReceptionState = (IRadio::ReceptionState)value;
        if (newReceptionState != IRadio::RECEPTION_STATE_UNDEFINED && newReceptionState != IRadio::RECEPTION_STATE_IDLE) {
            EV << "busy radio channel detected during scanning\n";
            scanning.busyChannelDetected = true;
        }
    }
}

void inet::ieee80211::Ieee80211MgmtSTA::receiveSignal ( cComponent *  source, simsignal_t  signalID, cObject *  obj, cObject *  details  )

overrideprotectedvirtual

{
    Enter_Method_Silent();
    printNotificationBanner(signalID, obj);

    // Note that we are only subscribed during scanning!
    if (signalID == NF_LINK_FULL_PROMISCUOUS) {
        Ieee80211DataOrMgmtFrame *frame = dynamic_cast<Ieee80211DataOrMgmtFrame *>(obj);
        if (!frame || frame->getControlInfo() == nullptr)
            return;
        if (frame->getType() != ST_BEACON)
            return;
        Ieee80211ReceptionIndication *ctl = dynamic_cast<Ieee80211ReceptionIndication *>(frame->getControlInfo());
        if (ctl == nullptr)
            return;
        Ieee80211BeaconFrame *beacon = (check_and_cast<Ieee80211BeaconFrame *>(frame));
        APInfo *ap = lookupAP(beacon->getTransmitterAddress());
        if (ap)
            ap->rxPower = ctl->getRecPow();
    }
}

bool inet::ieee80211::Ieee80211MgmtSTA::scanNextChannel ( )

protectedvirtual

Switches to the next channel to scan; returns true if done (there wasn't any more channel to scan).

{
    // if we're already at the last channel, we're through
    if (scanning.currentChannelIndex == (int)scanning.channelList.size() - 1) {
        EV << "Finished scanning last channel\n";
        if (scanning.activeScan)
            host->unsubscribe(IRadio::receptionStateChangedSignal, this);
        isScanning = false;
        return true;    // we're done
    }

    // tune to next channel
    int newChannel = scanning.channelList[++scanning.currentChannelIndex];
    changeChannel(newChannel);
    scanning.busyChannelDetected = false;

    if (scanning.activeScan) {
        // Active Scan: first wait probeDelay, then send a probe. Listening
        // for minChannelTime or maxChannelTime takes place after that. (11.1.3.2)
        scheduleAt(simTime() + scanning.probeDelay, new cMessage("sendProbe", MK_SCAN_SENDPROBE));
    }
    else {
        // Passive Scan: spend maxChannelTime on the channel (11.1.3.1)
        cMessage *timerMsg = new cMessage("maxChannelTime", MK_SCAN_MAXCHANNELTIME);
        scheduleAt(simTime() + scanning.maxChannelTime, timerMsg);
    }

    return false;
}

void inet::ieee80211::Ieee80211MgmtSTA::sendAssociationConfirm ( APInfo *  ap, int  resultCode  )

protectedvirtual

Sends back result of association to the agent.

{
    sendConfirm(new Ieee80211Prim_AssociateConfirm(), resultCode);
}

void inet::ieee80211::Ieee80211MgmtSTA::sendAuthenticationConfirm ( APInfo *  ap, int  resultCode  )

protectedvirtual

Sends back result of authentication to the agent.

{
    Ieee80211Prim_AuthenticateConfirm *confirm = new Ieee80211Prim_AuthenticateConfirm();
    confirm->setAddress(ap->address);
    sendConfirm(confirm, resultCode);
}

void inet::ieee80211::Ieee80211MgmtSTA::sendConfirm ( Ieee80211PrimConfirm *  confirm, int  resultCode  )

protectedvirtual

Utility function: sends a confirmation to the agent.

{
    confirm->setResultCode(resultCode);
    cMessage *msg = new cMessage(confirm->getClassName());
    msg->setControlInfo(confirm);
    send(msg, "agentOut");
}

void inet::ieee80211::Ieee80211MgmtSTA::sendManagementFrame ( Ieee80211ManagementFrame *  frame, const MACAddress &  address  )

protectedvirtual

Utility function: sends a management frame.

{
    // frame goes to the specified AP
    frame->setToDS(true);
    frame->setReceiverAddress(address);
    //XXX set sequenceNumber?

    sendDown(frame);
}

void inet::ieee80211::Ieee80211MgmtSTA::sendProbeRequest ( )

protectedvirtual

Broadcasts a Probe Request.

{
    EV << "Sending Probe Request, BSSID=" << scanning.bssid << ", SSID=\"" << scanning.ssid << "\"\n";
    Ieee80211ProbeRequestFrame *frame = new Ieee80211ProbeRequestFrame("ProbeReq");
    frame->getBody().setSSID(scanning.ssid.c_str());
    sendManagementFrame(frame, scanning.bssid);
}

void inet::ieee80211::Ieee80211MgmtSTA::sendScanConfirm ( )

protectedvirtual

Sends back result of scanning to the agent.

{
    EV << "Scanning complete, found " << apList.size() << " APs, sending confirmation to agent\n";

    // copy apList contents into a ScanConfirm primitive and send it back
    int n = apList.size();
    Ieee80211Prim_ScanConfirm *confirm = new Ieee80211Prim_ScanConfirm();
    confirm->setBssListArraySize(n);
    auto it = apList.begin();
    //XXX filter for req'd bssid and ssid
    for (int i = 0; i < n; i++, it++) {
        APInfo *ap = &(*it);
        Ieee80211Prim_BSSDescription& bss = confirm->getBssList(i);
        bss.setChannelNumber(ap->channel);
        bss.setBSSID(ap->address);
        bss.setSSID(ap->ssid.c_str());
        bss.setSupportedRates(ap->supportedRates);
        bss.setBeaconInterval(ap->beaconInterval);
        bss.setRxPower(ap->rxPower);
    }
    sendConfirm(confirm, PRC_SUCCESS);
}

void inet::ieee80211::Ieee80211MgmtSTA::startAssociation ( APInfo *  ap, simtime_t  timeout  )

protectedvirtual

Utility function: sends association request.

{
    if (isAssociated || assocTimeoutMsg)
        throw cRuntimeError("startAssociation: already associated or association currently in progress");
    if (!ap->isAuthenticated)
        throw cRuntimeError("startAssociation: not yet authenticated with AP address=", ap->address.str().c_str());

    // switch to that channel
    changeChannel(ap->channel);

    // create and send association request
    Ieee80211AssociationRequestFrame *frame = new Ieee80211AssociationRequestFrame("Assoc");

    //XXX set the following too?
    // string SSID
    // Ieee80211SupportedRatesElement supportedRates;

    sendManagementFrame(frame, ap->address);

    // schedule timeout
    ASSERT(assocTimeoutMsg == nullptr);
    assocTimeoutMsg = new cMessage("assocTimeout", MK_ASSOC_TIMEOUT);
    assocTimeoutMsg->setContextPointer(ap);
    scheduleAt(simTime() + timeout, assocTimeoutMsg);
}

void inet::ieee80211::Ieee80211MgmtSTA::startAuthentication ( APInfo *  ap, simtime_t  timeout  )

protectedvirtual

Utility function: sends authentication request.

{
    if (ap->authTimeoutMsg)
        throw cRuntimeError("startAuthentication: authentication currently in progress with AP address=", ap->address.str().c_str());
    if (ap->isAuthenticated)
        throw cRuntimeError("startAuthentication: already authenticated with AP address=", ap->address.str().c_str());

    changeChannel(ap->channel);

    EV << "Sending initial Authentication frame with seqNum=1\n";

    // create and send first authentication frame
    Ieee80211AuthenticationFrame *frame = new Ieee80211AuthenticationFrame("Auth");
    frame->getBody().setSequenceNumber(1);
    //XXX frame length could be increased to account for challenge text length etc.
    sendManagementFrame(frame, ap->address);

    ap->authSeqExpected = 2;

    // schedule timeout
    ASSERT(ap->authTimeoutMsg == nullptr);
    ap->authTimeoutMsg = new cMessage("authTimeout", MK_AUTH_TIMEOUT);
    ap->authTimeoutMsg->setContextPointer(ap);
    scheduleAt(simTime() + timeout, ap->authTimeoutMsg);
}

int inet::ieee80211::Ieee80211MgmtSTA::statusCodeToPrimResultCode ( int  statusCode )

protectedvirtual

Utility function: converts Ieee80211StatusCode (->frame) to Ieee80211PrimResultCode (->primitive)

{
    return statusCode == SC_SUCCESSFUL ? PRC_SUCCESS : PRC_REFUSED;
}

void inet::ieee80211::Ieee80211MgmtSTA::storeAPInfo ( const MACAddress &  address, const Ieee80211BeaconFrameBody &  body  )

protectedvirtual

Stores AP info received in a beacon or probe response.

{
    APInfo *ap = lookupAP(address);
    if (ap) {
        EV << "AP address=" << address << ", SSID=" << body.getSSID() << " already in our AP list, refreshing the info\n";
    }
    else {
        EV << "Inserting AP address=" << address << ", SSID=" << body.getSSID() << " into our AP list\n";
        apList.push_back(APInfo());
        ap = &apList.back();
    }

    ap->channel = body.getChannelNumber();
    ap->address = address;
    ap->ssid = body.getSSID();
    ap->supportedRates = body.getSupportedRates();
    ap->beaconInterval = body.getBeaconInterval();

    //XXX where to get this from?
    //ap->rxPower = ...
}

Member Data Documentation

AccessPointList inet::ieee80211::Ieee80211MgmtSTA::apList

protected

AssociatedAPInfo inet::ieee80211::Ieee80211MgmtSTA::assocAP

protected

cMessage* inet::ieee80211::Ieee80211MgmtSTA::assocTimeoutMsg

protected

cModule* inet::ieee80211::Ieee80211MgmtSTA::host

protected

IInterfaceTable* inet::ieee80211::Ieee80211MgmtSTA::interfaceTable

protected

bool inet::ieee80211::Ieee80211MgmtSTA::isAssociated

protected

bool inet::ieee80211::Ieee80211MgmtSTA::isScanning

protected

InterfaceEntry* inet::ieee80211::Ieee80211MgmtSTA::myIface

protected

int inet::ieee80211::Ieee80211MgmtSTA::numChannels

protected

ScanningInfo inet::ieee80211::Ieee80211MgmtSTA::scanning

protected

---

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

• Ieee80211MgmtSTA.h
• Ieee80211MgmtSTA.cc