ocb-wifi-mac.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2008 INRIA
 * Copyright (c) 2013 Dalian University of Technology
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation;
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 * Author: Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
 *         Junling Bu <linlinjavaer@gmail.com>
 */
 
#include "ocb-wifi-mac.h"
 
#include "higher-tx-tag.h"
#include "vendor-specific-action.h"
#include "wave-frame-exchange-manager.h"
 
#include "ns3/channel-access-manager.h"
#include "ns3/event-id.h"
#include "ns3/ht-capabilities.h"
#include "ns3/log.h"
#include "ns3/mac-rx-middle.h"
#include "ns3/pointer.h"
#include "ns3/string.h"
#include "ns3/vht-capabilities.h"
 
namespace ns3
{
 
NS_LOG_COMPONENT_DEFINE("OcbWifiMac");
 
NS_OBJECT_ENSURE_REGISTERED(OcbWifiMac);
 
const static Mac48Address WILDCARD_BSSID = Mac48Address::GetBroadcast();
 
TypeId
OcbWifiMac::GetTypeId()
{
    static TypeId tid = TypeId("ns3::OcbWifiMac")
                            .SetParent<WifiMac>()
                            .SetGroupName("Wave")
                            .AddConstructor<OcbWifiMac>();
    return tid;
}
 
OcbWifiMac::OcbWifiMac()
{
    NS_LOG_FUNCTION(this);
    // Let the lower layers know that we are acting as an OCB node
    SetTypeOfStation(OCB);
}
 
OcbWifiMac::~OcbWifiMac()
{
    NS_LOG_FUNCTION(this);
}
 
void
OcbWifiMac::SendVsc(Ptr<Packet> vsc, Mac48Address peer, OrganizationIdentifier oi)
{
    NS_LOG_FUNCTION(this << vsc << peer << oi);
    WifiMacHeader hdr;
    hdr.SetType(WIFI_MAC_MGT_ACTION);
    hdr.SetAddr1(peer);
    hdr.SetAddr2(GetAddress());
    hdr.SetAddr3(WILDCARD_BSSID);
    hdr.SetDsNotFrom();
    hdr.SetDsNotTo();
    VendorSpecificActionHeader vsa;
    vsa.SetOrganizationIdentifier(oi);
    vsc->AddHeader(vsa);
 
    if (GetQosSupported())
    {
        uint8_t tid = QosUtilsGetTidForPacket(vsc);
        tid = tid > 7 ? 0 : tid;
        GetQosTxop(tid)->Queue(vsc, hdr);
    }
    else
    {
        GetTxop()->Queue(vsc, hdr);
    }
}
 
void
OcbWifiMac::AddReceiveVscCallback(OrganizationIdentifier oi, VscCallback cb)
{
    NS_LOG_FUNCTION(this << oi << &cb);
    m_vscManager.RegisterVscCallback(oi, cb);
}
 
void
OcbWifiMac::RemoveReceiveVscCallback(OrganizationIdentifier oi)
{
    NS_LOG_FUNCTION(this << oi);
    m_vscManager.DeregisterVscCallback(oi);
}
 
void
OcbWifiMac::SetSsid(Ssid ssid)
{
    NS_LOG_WARN("in OCB mode we should not call SetSsid");
}
 
Ssid
OcbWifiMac::GetSsid() const
{
    NS_LOG_WARN("in OCB mode we should not call GetSsid");
    // we really do not want to return ssid, however we have to provide
    return WifiMac::GetSsid();
}
 
void
OcbWifiMac::SetBssid(Mac48Address bssid)
{
    NS_LOG_WARN("in OCB mode we should not call SetBsid");
}
 
Mac48Address
OcbWifiMac::GetBssid(uint8_t /* linkId */) const
{
    NS_LOG_WARN("in OCB mode we should not call GetBssid");
    return WILDCARD_BSSID;
}
 
void
OcbWifiMac::SetLinkUpCallback(Callback<void> linkUp)
{
    NS_LOG_FUNCTION(this << &linkUp);
    WifiMac::SetLinkUpCallback(linkUp);
 
    // The approach taken here is that, from the point of view of a STA
    // in OCB mode, the link is always up, so we immediately invoke the
    // callback if one is set
    linkUp();
}
 
void
OcbWifiMac::SetLinkDownCallback(Callback<void> linkDown)
{
    NS_LOG_FUNCTION(this << &linkDown);
    WifiMac::SetLinkDownCallback(linkDown);
    NS_LOG_WARN("in OCB mode the like will never down, so linkDown will never be called");
}
 
bool
OcbWifiMac::CanForwardPacketsTo(Mac48Address to) const
{
    return true;
}
 
void
OcbWifiMac::Enqueue(Ptr<Packet> packet, Mac48Address to)
{
    NS_LOG_FUNCTION(this << packet << to);
    if (GetWifiRemoteStationManager()->IsBrandNew(to))
    {
        // In ad hoc mode, we assume that every destination supports all
        // the rates we support.
        if (GetHtSupported() || GetVhtSupported(SINGLE_LINK_OP_ID))
        {
            GetWifiRemoteStationManager()->AddAllSupportedMcs(to);
            GetWifiRemoteStationManager()->AddStationHtCapabilities(
                to,
                GetHtCapabilities(SINGLE_LINK_OP_ID));
        }
        if (GetVhtSupported(SINGLE_LINK_OP_ID))
        {
            GetWifiRemoteStationManager()->AddStationVhtCapabilities(
                to,
                GetVhtCapabilities(SINGLE_LINK_OP_ID));
        }
        GetWifiRemoteStationManager()->AddAllSupportedModes(to);
        GetWifiRemoteStationManager()->RecordDisassociated(to);
    }
 
    WifiMacHeader hdr;
 
    // If we are not a QoS STA then we definitely want to use AC_BE to
    // transmit the packet. A TID of zero will map to AC_BE (through \c
    // QosUtilsMapTidToAc()), so we use that as our default here.
    uint8_t tid = 0;
 
    if (GetQosSupported())
    {
        hdr.SetType(WIFI_MAC_QOSDATA);
        hdr.SetQosAckPolicy(WifiMacHeader::NORMAL_ACK);
        hdr.SetQosNoEosp();
        hdr.SetQosNoAmsdu();
        // About transmission of multiple frames,
        // in Ad-hoc mode TXOP is not supported for now, so TxopLimit=0;
        // however in OCB mode, 802.11p do not allow transmit multiple frames
        // so TxopLimit must equal 0
        hdr.SetQosTxopLimit(0);
 
        // Fill in the QoS control field in the MAC header
        tid = QosUtilsGetTidForPacket(packet);
        // Any value greater than 7 is invalid and likely indicates that
        // the packet had no QoS tag, so we revert to zero, which'll
        // mean that AC_BE is used.
        if (tid > 7)
        {
            tid = 0;
        }
        hdr.SetQosTid(tid);
    }
    else
    {
        hdr.SetType(WIFI_MAC_DATA);
    }
 
    if (GetHtSupported() || GetVhtSupported(SINGLE_LINK_OP_ID))
    {
        hdr.SetNoOrder(); // explicitly set to 0 for the time being since HT/VHT/HE control field is
                          // not yet implemented (set it to 1 when implemented)
    }
    hdr.SetAddr1(to);
    hdr.SetAddr2(GetAddress());
    hdr.SetAddr3(WILDCARD_BSSID);
    hdr.SetDsNotFrom();
    hdr.SetDsNotTo();
 
    if (GetQosSupported())
    {
        // Sanity check that the TID is valid
        NS_ASSERT(tid < 8);
        GetQosTxop(tid)->Queue(packet, hdr);
    }
    else
    {
        GetTxop()->Queue(packet, hdr);
    }
}
 
/*
 * see 802.11p-2010 chapter 11.19
 * here we only care about data packet and vsa management frame
 */
void
OcbWifiMac::Receive(Ptr<const WifiMpdu> mpdu, uint8_t linkId)
{
    NS_LOG_FUNCTION(this << *mpdu << +linkId);
    const WifiMacHeader* hdr = &mpdu->GetHeader();
    // Create a copy of the MPDU payload because non-const operations like RemovePacketTag
    // and RemoveHeader may need to be performed.
    Ptr<Packet> packet = mpdu->GetPacket()->Copy();
    NS_ASSERT(!hdr->IsCtl());
    NS_ASSERT(hdr->GetAddr3() == WILDCARD_BSSID);
 
    Mac48Address from = hdr->GetAddr2();
    Mac48Address to = hdr->GetAddr1();
 
    if (GetWifiRemoteStationManager()->IsBrandNew(from))
    {
        // In ad hoc mode, we assume that every destination supports all
        // the rates we support.
        if (GetHtSupported() || GetVhtSupported(SINGLE_LINK_OP_ID))
        {
            GetWifiRemoteStationManager()->AddAllSupportedMcs(from);
            GetWifiRemoteStationManager()->AddStationHtCapabilities(
                from,
                GetHtCapabilities(SINGLE_LINK_OP_ID));
        }
        if (GetVhtSupported(SINGLE_LINK_OP_ID))
        {
            GetWifiRemoteStationManager()->AddStationVhtCapabilities(
                from,
                GetVhtCapabilities(SINGLE_LINK_OP_ID));
        }
        GetWifiRemoteStationManager()->AddAllSupportedModes(from);
        GetWifiRemoteStationManager()->RecordDisassociated(from);
    }
 
    if (hdr->IsData())
    {
        if (hdr->IsQosData() && hdr->IsQosAmsdu())
        {
            NS_LOG_DEBUG("Received A-MSDU from" << from);
            DeaggregateAmsduAndForward(mpdu);
        }
        else
        {
            ForwardUp(packet, from, to);
        }
        return;
    }
 
    // why put check here, not before "if (hdr->IsData ())" ?
    // because WifiNetDevice::ForwardUp needs to m_promiscRx data packet
    // and will filter data packet for itself
    // so we need to filter management frame
    if (to != GetAddress() && !to.IsGroup())
    {
        NS_LOG_LOGIC("the management frame is not for us");
        NotifyRxDrop(packet);
        return;
    }
 
    if (hdr->IsMgt() && hdr->IsAction())
    {
        // yes, we only care about VendorSpecificAction frame in OCB mode
        // other management frames will be handled by WifiMac::Receive
        VendorSpecificActionHeader vsaHdr;
        packet->PeekHeader(vsaHdr);
        if (vsaHdr.GetCategory() == CATEGORY_OF_VSA)
        {
            VendorSpecificActionHeader vsa;
            packet->RemoveHeader(vsa);
            OrganizationIdentifier oi = vsa.GetOrganizationIdentifier();
            VscCallback cb = m_vscManager.FindVscCallback(oi);
 
            if (cb.IsNull())
            {
                NS_LOG_DEBUG("cannot find VscCallback for OrganizationIdentifier=" << oi);
                return;
            }
            bool succeed = cb(this, oi, packet, from);
 
            if (!succeed)
            {
                NS_LOG_DEBUG("vsc callback could not handle the packet successfully");
            }
 
            return;
        }
    }
    // Invoke the receive handler of our parent class to deal with any
    // other frames. Specifically, this will handle Block Ack-related
    // Management Action frames.
    WifiMac::Receive(Create<WifiMpdu>(packet, *hdr), linkId);
}
 
void
OcbWifiMac::ConfigureEdca(uint32_t cwmin, uint32_t cwmax, uint32_t aifsn, AcIndex ac)
{
    NS_LOG_FUNCTION(this << cwmin << cwmax << aifsn << ac);
    Ptr<Txop> dcf;
    switch (ac)
    {
    case AC_VO:
        dcf = WifiMac::GetVOQueue();
        dcf->SetWifiMac(this);
        dcf->SetMinCw((cwmin + 1) / 4 - 1);
        dcf->SetMaxCw((cwmin + 1) / 2 - 1);
        dcf->SetAifsn(aifsn);
        break;
    case AC_VI:
        dcf = WifiMac::GetVIQueue();
        dcf->SetWifiMac(this);
        dcf->SetMinCw((cwmin + 1) / 2 - 1);
        dcf->SetMaxCw(cwmin);
        dcf->SetAifsn(aifsn);
        break;
    case AC_BE:
        dcf = WifiMac::GetBEQueue();
        dcf->SetWifiMac(this);
        dcf->SetMinCw(cwmin);
        dcf->SetMaxCw(cwmax);
        dcf->SetAifsn(aifsn);
        break;
    case AC_BK:
        dcf = WifiMac::GetBKQueue();
        dcf->SetWifiMac(this);
        dcf->SetMinCw(cwmin);
        dcf->SetMaxCw(cwmax);
        dcf->SetAifsn(aifsn);
        break;
    case AC_BE_NQOS:
        dcf = WifiMac::GetTxop();
        dcf->SetWifiMac(this);
        dcf->SetMinCw(cwmin);
        dcf->SetMaxCw(cwmax);
        dcf->SetAifsn(aifsn);
        break;
    case AC_BEACON:
        // done by ApWifiMac
        break;
    case AC_UNDEF:
        NS_FATAL_ERROR("I don't know what to do with this");
        break;
    }
 
    GetLink(SINGLE_LINK_OP_ID).channelAccessManager->Add(dcf);
}
 
void
OcbWifiMac::SetWifiPhy(Ptr<WifiPhy> phy)
{
    NS_LOG_FUNCTION(this << phy);
    WifiMac::SetWifiPhys({phy});
    NS_ABORT_MSG_IF(!phy->GetOperatingChannel().IsSet(),
                    "PHY operating channel must have been set");
    auto& link = GetLink(SINGLE_LINK_OP_ID);
    if (link.channelAccessManager != nullptr)
    {
        link.channelAccessManager->SetupPhyListener(phy);
    }
    if (link.feManager != nullptr)
    {
        link.feManager->SetWifiPhy(phy);
    }
}
 
void
OcbWifiMac::ConfigureStandard(WifiStandard standard)
{
    NS_LOG_FUNCTION(this << standard);
    NS_ASSERT(standard == WIFI_STANDARD_80211p);
 
    if (GetNLinks() == 0)
    {
        WifiMac::SetWifiPhys({nullptr}); // for the purpose of adding a link
    }
 
    auto& link = GetLink(SINGLE_LINK_OP_ID);
 
    // Setup ChannelAccessManager
    link.channelAccessManager = CreateObject<ChannelAccessManager>();
 
    uint32_t cwmin = 15;
    uint32_t cwmax = 1023;
 
    if (!GetQosSupported())
    {
        // The special value of AC_BE_NQOS which exists in the Access
        // Category enumeration allows us to configure plain old DCF.
        ConfigureEdca(cwmin, cwmax, 2, AC_BE_NQOS);
    }
    else
    {
        // Now we configure the EDCA functions
        // see IEEE802.11p-2010 section 7.3.2.29
        // Wave CCH and SCHs set default 802.11p EDCA
        ConfigureEdca(cwmin, cwmax, 2, AC_VO);
        ConfigureEdca(cwmin, cwmax, 3, AC_VI);
        ConfigureEdca(cwmin, cwmax, 6, AC_BE);
        ConfigureEdca(cwmin, cwmax, 9, AC_BK);
    }
 
    // Setup FrameExchangeManager
    auto feManager = CreateObject<WaveFrameExchangeManager>();
    feManager->SetWifiMac(this);
    feManager->SetMacTxMiddle(m_txMiddle);
    feManager->SetMacRxMiddle(m_rxMiddle);
    feManager->SetAddress(GetAddress());
    link.channelAccessManager->SetupFrameExchangeManager(feManager);
    if (auto phy = GetWifiPhy(); phy != nullptr)
    {
        feManager->SetWifiPhy(phy);
        link.channelAccessManager->SetupPhyListener(phy);
    }
    link.feManager = feManager;
}
 
void
OcbWifiMac::Suspend()
{
    NS_LOG_FUNCTION(this);
    GetLink(SINGLE_LINK_OP_ID).channelAccessManager->NotifySleepNow();
    GetLink(SINGLE_LINK_OP_ID).feManager->NotifySleepNow();
}
 
void
OcbWifiMac::Resume()
{
    NS_LOG_FUNCTION(this);
    // wake-up operation is not required in m_low object
    GetLink(SINGLE_LINK_OP_ID).channelAccessManager->NotifyWakeupNow();
}
 
void
OcbWifiMac::MakeVirtualBusy(Time duration)
{
    NS_LOG_FUNCTION(this << duration);
    GetLink(SINGLE_LINK_OP_ID)
        .channelAccessManager->NotifyCcaBusyStartNow(duration, WIFI_CHANLIST_PRIMARY, {});
}
 
void
OcbWifiMac::CancleTx(AcIndex ac)
{
    NS_LOG_FUNCTION(this << ac);
    Ptr<QosTxop> queue = GetQosTxop(ac);
    NS_ASSERT(queue);
    // reset and flush queue
    queue->GetWifiMacQueue()->Flush();
}
 
void
OcbWifiMac::Reset()
{
    NS_LOG_FUNCTION(this);
    // The switching event is used to notify MAC entity reset its operation.
    GetLink(SINGLE_LINK_OP_ID).channelAccessManager->NotifySwitchingStartNow(Time(0));
    GetLink(SINGLE_LINK_OP_ID).feManager->NotifySwitchingStartNow(Time(0));
}
 
void
OcbWifiMac::EnableForWave(Ptr<WaveNetDevice> device)
{
    NS_LOG_FUNCTION(this << device);
    // To extend current OcbWifiMac for WAVE 1609.4, we shall use WaveFrameExchangeManager
    StaticCast<WaveFrameExchangeManager>(GetLink(SINGLE_LINK_OP_ID).feManager)
        ->SetWaveNetDevice(device);
}
 
std::optional<uint8_t>
OcbWifiMac::GetLinkIdByAddress(const Mac48Address& address) const
{
    return 0;
}
 
void
OcbWifiMac::DoDispose()
{
    NS_LOG_FUNCTION(this);
    WifiMac::DoDispose();
}
 
} // namespace ns3