bs-uplink-scheduler-rtps.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2007,2008 INRIA
 *               2009 TELEMATICS LAB, Politecnico di Bari
 *
 * SPDX-License-Identifier: GPL-2.0-only
 *
 * Author: Giuseppe Piro <g.piro@poliba.it>
 */
 
#include "bs-uplink-scheduler-rtps.h"
 
#include "bandwidth-manager.h"
#include "bs-link-manager.h"
#include "bs-net-device.h"
#include "burst-profile-manager.h"
#include "cid.h"
#include "service-flow-record.h"
#include "service-flow.h"
#include "ss-manager.h"
#include "ss-record.h"
 
#include "ns3/log.h"
#include "ns3/simulator.h"
#include "ns3/uinteger.h"
 
namespace ns3
{
 
NS_LOG_COMPONENT_DEFINE("UplinkSchedulerRtps");
 
NS_OBJECT_ENSURE_REGISTERED(UplinkSchedulerRtps);
 
UplinkSchedulerRtps::UplinkSchedulerRtps()
{
    SetBs(nullptr);
    SetTimeStampIrInterval(Seconds(0));
    SetNrIrOppsAllocated(0);
    SetIsIrIntrvlAllocated(false);
    SetIsInvIrIntrvlAllocated(false);
    SetDcdTimeStamp(Simulator::Now());
    SetUcdTimeStamp(Simulator::Now());
}
 
UplinkSchedulerRtps::UplinkSchedulerRtps(Ptr<BaseStationNetDevice> bs)
{
    SetBs(bs);
    SetTimeStampIrInterval(Seconds(0));
    SetNrIrOppsAllocated(0);
    SetIsIrIntrvlAllocated(false);
    SetIsInvIrIntrvlAllocated(false);
    SetDcdTimeStamp(Simulator::Now());
    SetUcdTimeStamp(Simulator::Now());
}
 
UplinkSchedulerRtps::~UplinkSchedulerRtps()
{
    SetBs(nullptr);
    m_uplinkAllocations.clear();
}
 
TypeId
UplinkSchedulerRtps::GetTypeId()
{
    static TypeId tid = TypeId("ns3::UplinkSchedulerRtps")
                            .SetParent<UplinkScheduler>()
                            .SetGroupName("Wimax")
                            .AddConstructor<UplinkSchedulerRtps>();
    return tid;
}
 
std::list<OfdmUlMapIe>
UplinkSchedulerRtps::GetUplinkAllocations() const
{
    return m_uplinkAllocations;
}
 
void
UplinkSchedulerRtps::GetChannelDescriptorsToUpdate(bool& updateDcd,
                                                   bool& updateUcd,
                                                   bool& sendDcd,
                                                   bool& sendUcd)
{
    /*DCD and UCD shall actually be updated when channel or burst profile definitions
     change. burst profiles are updated based on number of SSs, network conditions and etc.
     for now temporarily assuming DCD/UCD shall be updated every time */
 
    uint32_t randNr = rand();
    if (randNr % 5 == 0 || GetBs()->GetNrDcdSent() == 0)
    {
        sendDcd = true;
    }
 
    randNr = rand();
    if (randNr % 5 == 0 || GetBs()->GetNrUcdSent() == 0)
    {
        sendUcd = true;
    }
 
    // -------------------------------------
    // additional, just to send more frequently
    if (!sendDcd)
    {
        randNr = rand();
        if (randNr % 4 == 0)
        {
            sendDcd = true;
        }
    }
 
    if (!sendUcd)
    {
        randNr = rand();
        if (randNr % 4 == 0)
        {
            sendUcd = true;
        }
    }
    // -------------------------------------
 
    Time timeSinceLastDcd = Simulator::Now() - GetDcdTimeStamp();
    Time timeSinceLastUcd = Simulator::Now() - GetUcdTimeStamp();
 
    if (timeSinceLastDcd > GetBs()->GetDcdInterval())
    {
        sendDcd = true;
        SetDcdTimeStamp(Simulator::Now());
    }
 
    if (timeSinceLastUcd > GetBs()->GetUcdInterval())
    {
        sendUcd = true;
        SetUcdTimeStamp(Simulator::Now());
    }
}
 
uint32_t
UplinkSchedulerRtps::CalculateAllocationStartTime()
{
    return GetBs()->GetNrDlSymbols() * GetBs()->GetPhy()->GetPsPerSymbol() + GetBs()->GetTtg();
}
 
void
UplinkSchedulerRtps::AddUplinkAllocation(OfdmUlMapIe& ulMapIe,
                                         const uint32_t& allocationSize,
                                         uint32_t& symbolsToAllocation,
                                         uint32_t& availableSymbols)
{
    ulMapIe.SetDuration(allocationSize);
    ulMapIe.SetStartTime(symbolsToAllocation);
    m_uplinkAllocations.push_back(ulMapIe);
    symbolsToAllocation += allocationSize;
    availableSymbols -= allocationSize;
}
 
void
UplinkSchedulerRtps::Schedule()
{
    m_uplinkAllocations.clear();
    SetIsIrIntrvlAllocated(false);
    SetIsInvIrIntrvlAllocated(false);
    bool allocationForDsa = false;
 
    uint32_t symbolsToAllocation = 0;
    uint32_t allocationSize = 0; // size in symbols
    uint32_t availableSymbols = GetBs()->GetNrUlSymbols();
 
    WimaxPhy::ModulationType modulationType;
    Cid cid;
 
    AllocateInitialRangingInterval(symbolsToAllocation, availableSymbols);
 
    std::vector<SSRecord*>* ssRecords = GetBs()->GetSSManager()->GetSSRecords();
    NS_LOG_INFO("UL Scheduler start, availableSymbols = " << availableSymbols);
 
    for (auto iter = ssRecords->begin(); iter != ssRecords->end(); ++iter)
    {
        SSRecord* ssRecord = *iter;
        if (ssRecord->GetIsBroadcastSS())
        {
            continue;
        }
        cid = ssRecord->GetBasicCid();
        OfdmUlMapIe ulMapIe;
        ulMapIe.SetCid(cid);
 
        if (ssRecord->GetPollForRanging() &&
            ssRecord->GetRangingStatus() == WimaxNetDevice::RANGING_STATUS_CONTINUE)
        {
            // SS's ranging is not yet complete
            // allocating invited initial ranging interval
            ulMapIe.SetUiuc(OfdmUlBurstProfile::UIUC_INITIAL_RANGING);
            allocationSize = GetBs()->GetRangReqOppSize();
            SetIsInvIrIntrvlAllocated(true);
 
            if (availableSymbols >= allocationSize)
            {
                AddUplinkAllocation(ulMapIe, allocationSize, symbolsToAllocation, availableSymbols);
            }
            else
            {
                break;
            }
        }
        else
        {
            modulationType = ssRecord->GetModulationType();
 
            // need to update because modulation/FEC to UIUC mapping may vary over time
            ulMapIe.SetUiuc(GetBs()->GetBurstProfileManager()->GetBurstProfile(
                modulationType,
                WimaxNetDevice::DIRECTION_UPLINK));
 
            // establish service flows for SS
            if (ssRecord->GetRangingStatus() == WimaxNetDevice::RANGING_STATUS_SUCCESS &&
                !ssRecord->GetAreServiceFlowsAllocated())
            {
                // allocating grant (with arbitrary size) to allow SS to send DSA messages DSA-REQ
                // and DSA-ACK only one DSA allocation per frame
                if (!allocationForDsa)
                {
                    allocationSize =
                        GetBs()->GetPhy()->GetNrSymbols(sizeof(DsaReq), modulationType);
                    if (availableSymbols >= allocationSize)
                    {
                        AddUplinkAllocation(ulMapIe,
                                            allocationSize,
                                            symbolsToAllocation,
                                            availableSymbols);
                        allocationForDsa = true;
                    }
                    else
                    {
                        break;
                    }
                }
            }
            else
            {
                // all service flows associated to SS are established now
 
                /*allocating grants for data transmission for UGS flows (Data Grant Burst Type
                 IEs, 6.3.7.4.3.3) (grant has been referred by different names e.g. transmission
                 opportunity, slot, uplink allocation, etc)*/
                ServiceUnsolicitedGrants(ssRecord,
                                         ServiceFlow::SF_TYPE_UGS,
                                         ulMapIe,
                                         modulationType,
                                         symbolsToAllocation,
                                         availableSymbols);
 
                // allocate unicast polls for rtPS flows if bandwidth is available
                if (availableSymbols)
                {
                    ServiceUnsolicitedGrants(ssRecord,
                                             ServiceFlow::SF_TYPE_RTPS,
                                             ulMapIe,
                                             modulationType,
                                             symbolsToAllocation,
                                             availableSymbols);
                }
                // allocate unicast polls for nrtPS flows if bandwidth is available
                if (availableSymbols)
                {
                    ServiceUnsolicitedGrants(ssRecord,
                                             ServiceFlow::SF_TYPE_NRTPS,
                                             ulMapIe,
                                             modulationType,
                                             symbolsToAllocation,
                                             availableSymbols);
                }
                // finally allocate unicast polls for BE flows if bandwidth is available
                if (availableSymbols)
                {
                    ServiceUnsolicitedGrants(ssRecord,
                                             ServiceFlow::SF_TYPE_BE,
                                             ulMapIe,
                                             modulationType,
                                             symbolsToAllocation,
                                             availableSymbols);
                }
            }
        }
    }
 
    /*
     * Uplink Scheduler for rtPS Connection
     */
    if (availableSymbols)
    {
        ULSchedulerRTPSConnection(symbolsToAllocation, availableSymbols);
    }
 
    // UL Scheduler for nrtPS and BE flows
    if (availableSymbols)
    {
        for (auto iter = ssRecords->begin(); iter != ssRecords->end(); ++iter)
        {
            SSRecord* ssRecord = *iter;
            if (ssRecord->GetIsBroadcastSS())
            {
                continue;
            }
            if (!ssRecord->GetPollForRanging() &&
                ssRecord->GetRangingStatus() != WimaxNetDevice::RANGING_STATUS_CONTINUE &&
                ssRecord->GetAreServiceFlowsAllocated())
            {
                OfdmUlMapIe ulMapIe;
                cid = ssRecord->GetBasicCid();
                ulMapIe.SetCid(cid);
                modulationType = ssRecord->GetModulationType();
                ulMapIe.SetUiuc(GetBs()->GetBurstProfileManager()->GetBurstProfile(
                    modulationType,
                    WimaxNetDevice::DIRECTION_UPLINK));
 
                // allocate unicast polls for nrtPS flows if bandwidth is available
 
                ServiceBandwidthRequests(ssRecord,
                                         ServiceFlow::SF_TYPE_NRTPS,
                                         ulMapIe,
                                         modulationType,
                                         symbolsToAllocation,
                                         availableSymbols);
 
                // finally allocate unicast polls for BE flows if bandwidth is available
                if (availableSymbols)
                {
                    ServiceBandwidthRequests(ssRecord,
                                             ServiceFlow::SF_TYPE_BE,
                                             ulMapIe,
                                             modulationType,
                                             symbolsToAllocation,
                                             availableSymbols);
                }
            }
        }
    }
 
    OfdmUlMapIe ulMapIeEnd;
    ulMapIeEnd.SetCid(Cid::InitialRanging());
    ulMapIeEnd.SetStartTime(symbolsToAllocation);
    ulMapIeEnd.SetUiuc(OfdmUlBurstProfile::UIUC_END_OF_MAP);
    ulMapIeEnd.SetDuration(0);
    m_uplinkAllocations.push_back(ulMapIeEnd);
 
    // setting DL/UL subframe allocation for the next frame
    GetBs()->GetBandwidthManager()->SetSubframeRatio();
}
 
void
UplinkSchedulerRtps::ServiceUnsolicitedGrants(const SSRecord* ssRecord,
                                              ServiceFlow::SchedulingType schedulingType,
                                              OfdmUlMapIe& ulMapIe,
                                              const WimaxPhy::ModulationType modulationType,
                                              uint32_t& symbolsToAllocation,
                                              uint32_t& availableSymbols)
{
    uint32_t allocationSize = 0;      // size in symbols
    uint8_t uiuc = ulMapIe.GetUiuc(); // SS's burst profile
    std::vector<ServiceFlow*> serviceFlows = ssRecord->GetServiceFlows(schedulingType);
 
    for (auto iter = serviceFlows.begin(); iter != serviceFlows.end(); ++iter)
    {
        ServiceFlow* serviceFlow = *iter;
 
        /* in case of rtPS, nrtPS and BE, allocating unicast polls for bandwidth requests (Request
         IEs, 6.3.7.4.3.1). in case of UGS, allocating grants for data transmission (Data Grant
         Burst Type IEs, 6.3.7.4.3.3) (grant has been referred in this code by different names e.g.
         transmission opportunity, slot, allocation, etc) */
 
        allocationSize =
            GetBs()->GetBandwidthManager()->CalculateAllocationSize(ssRecord, serviceFlow);
 
        // verifying that minimum reserved traffic rate of nrtPS flow is maintained
        if (serviceFlow->GetSchedulingType() == ServiceFlow::SF_TYPE_NRTPS)
        {
            Time currentTime = Simulator::Now();
            ServiceFlowRecord* record = serviceFlow->GetRecord();
            if (currentTime - record->GetGrantTimeStamp() > Seconds(1))
            {
                uint32_t bps = (record->GetBwSinceLastExpiry() * 8);
                if (bps < serviceFlow->GetMinReservedTrafficRate())
                {
                    ServiceBandwidthRequests(serviceFlow,
                                             schedulingType,
                                             ulMapIe,
                                             modulationType,
                                             symbolsToAllocation,
                                             availableSymbols);
                    record->SetBwSinceLastExpiry(0);
                    record->SetGrantTimeStamp(currentTime);
                }
            }
        }
 
        if (availableSymbols < allocationSize)
        {
            break;
        }
 
        if (allocationSize > 0)
        {
            ulMapIe.SetStartTime(symbolsToAllocation);
            if (serviceFlow->GetSchedulingType() != ServiceFlow::SF_TYPE_UGS)
            {
                // special burst profile with most robust modulation type is used for unicast polls
                // (Request IEs)
                ulMapIe.SetUiuc(OfdmUlBurstProfile::UIUC_REQ_REGION_FULL);
            }
        }
        else
        {
            continue;
        }
 
        if (serviceFlow->GetSchedulingType() == ServiceFlow::SF_TYPE_UGS)
        {
            NS_LOG_DEBUG("BS uplink scheduler, UGS allocation, size: " << allocationSize
                                                                       << " symbols");
        }
        else
        {
            NS_LOG_DEBUG("BS uplink scheduler, " << serviceFlow->GetSchedulingTypeStr()
                                                 << " unicast poll, size: " << allocationSize
                                                 << " symbols"
                                                 << ", modulation: BPSK 1/2");
        }
 
        NS_LOG_DEBUG(", CID: " << serviceFlow->GetConnection()->GetCid()
                               << ", SFID: " << serviceFlow->GetSfid());
 
        AddUplinkAllocation(ulMapIe, allocationSize, symbolsToAllocation, availableSymbols);
        ulMapIe.SetUiuc(uiuc);
    }
}
 
void
UplinkSchedulerRtps::ServiceBandwidthRequests(const SSRecord* ssRecord,
                                              ServiceFlow::SchedulingType schedulingType,
                                              OfdmUlMapIe& ulMapIe,
                                              const WimaxPhy::ModulationType modulationType,
                                              uint32_t& symbolsToAllocation,
                                              uint32_t& availableSymbols)
{
    std::vector<ServiceFlow*> serviceFlows = ssRecord->GetServiceFlows(schedulingType);
 
    for (auto iter = serviceFlows.begin(); iter != serviceFlows.end(); ++iter)
    {
        if (!ServiceBandwidthRequests(*iter,
                                      schedulingType,
                                      ulMapIe,
                                      modulationType,
                                      symbolsToAllocation,
                                      availableSymbols))
        {
            break;
        }
    }
}
 
bool
UplinkSchedulerRtps::ServiceBandwidthRequests(ServiceFlow* serviceFlow,
                                              ServiceFlow::SchedulingType schedulingType,
                                              OfdmUlMapIe& ulMapIe,
                                              const WimaxPhy::ModulationType modulationType,
                                              uint32_t& symbolsToAllocation,
                                              uint32_t& availableSymbols)
{
    uint32_t allocSizeBytes = 0;
    uint32_t allocSizeSymbols = 0;
    uint16_t sduSize = 0;
 
    ServiceFlowRecord* record = serviceFlow->GetRecord();
    sduSize = serviceFlow->GetSduSize();
 
    uint32_t requiredBandwidth = record->GetRequestedBandwidth() - record->GetGrantedBandwidth();
    if (requiredBandwidth > 0)
    {
        if (sduSize > 0)
        {
            // if SDU size is mentioned, allocate grant of that size
            allocSizeBytes = sduSize;
            allocSizeSymbols = GetBs()->GetPhy()->GetNrSymbols(sduSize, modulationType);
        }
        else
        {
            allocSizeBytes = requiredBandwidth;
            allocSizeSymbols = GetBs()->GetPhy()->GetNrSymbols(requiredBandwidth, modulationType);
        }
 
        if (availableSymbols >= allocSizeSymbols)
        {
            NS_LOG_DEBUG("BS uplink scheduler, "
                         << serviceFlow->GetSchedulingTypeStr()
                         << " allocation, size: " << allocSizeSymbols << " symbols"
                         << ", CID: " << serviceFlow->GetConnection()->GetCid()
                         << ", SFID: " << serviceFlow->GetSfid()
                         << ", bw requested: " << record->GetRequestedBandwidth()
                         << ", bw granted: " << record->GetGrantedBandwidth());
 
            record->UpdateGrantedBandwidth(allocSizeBytes);
 
            if (schedulingType == ServiceFlow::SF_TYPE_NRTPS)
            {
                record->SetBwSinceLastExpiry(allocSizeBytes);
            }
 
            AddUplinkAllocation(ulMapIe, allocSizeSymbols, symbolsToAllocation, availableSymbols);
        }
        else
        {
            return false;
        }
    }
    return true;
}
 
void
UplinkSchedulerRtps::ULSchedulerRTPSConnection(uint32_t& symbolsToAllocation,
                                               uint32_t& availableSymbols)
{
    NS_LOG_INFO("\tUL Scheduler for rtPS flows");
    NS_LOG_INFO("\t\tavailableSymbols = " << availableSymbols);
    ServiceFlowRecord* record_[100];
    uint32_t allocSizeSymbols_[100]; // symbolsRequired for each SSRecord
    OfdmUlMapIe ulMapIe_[100];
    OfdmUlMapIe ulMapIe;
    WimaxPhy::ModulationType modulationType_[100];
    WimaxPhy::ModulationType modulationType;
    int nbAllocation = 0;
    uint32_t allocSizeBytes;
    uint32_t totAllocSizeSymbols = 0;
 
    Cid cid;
    std::vector<SSRecord*>* ssRecords = GetBs()->GetSSManager()->GetSSRecords();
 
    for (auto iter = ssRecords->begin(); iter != ssRecords->end(); ++iter)
    {
        SSRecord* ssRecord = *iter;
        if (ssRecord->GetIsBroadcastSS())
        {
            continue;
        }
        if (!ssRecord->GetPollForRanging() &&
            ssRecord->GetRangingStatus() != WimaxNetDevice::RANGING_STATUS_CONTINUE &&
            ssRecord->GetAreServiceFlowsAllocated())
        {
            cid = ssRecord->GetBasicCid();
            ulMapIe.SetCid(cid);
            modulationType = ssRecord->GetModulationType();
            ulMapIe.SetUiuc(GetBs()->GetBurstProfileManager()->GetBurstProfile(
                modulationType,
                WimaxNetDevice::DIRECTION_UPLINK));
 
            std::vector<ServiceFlow*> serviceFlows =
                ssRecord->GetServiceFlows(ServiceFlow::SF_TYPE_RTPS);
            for (auto iter2 = serviceFlows.begin(); iter2 != serviceFlows.end(); ++iter2)
            {
                record_[nbAllocation] = (*iter2)->GetRecord();
                uint32_t requiredBandwidth = record_[nbAllocation]->GetRequestedBandwidth() -
                                             record_[nbAllocation]->GetGrantedBandwidth();
 
                if (requiredBandwidth > 0)
                {
                    modulationType_[nbAllocation] = modulationType;
                    ulMapIe_[nbAllocation] = ulMapIe;
                    allocSizeBytes = requiredBandwidth;
                    allocSizeSymbols_[nbAllocation] =
                        GetBs()->GetPhy()->GetNrSymbols(allocSizeBytes,
                                                        modulationType_[nbAllocation]);
                    totAllocSizeSymbols += allocSizeSymbols_[nbAllocation];
 
                    NS_LOG_INFO(
                        "\t\tUL Scheduler for CID = " << (*iter2)->GetConnection()->GetCid());
                    NS_LOG_INFO("\t\t\trequiredBandwidth = "
                                << record_[nbAllocation]->GetRequestedBandwidth()
                                << ", allocSizeSymbols = " << allocSizeSymbols_[nbAllocation]
                                << ", modulationType = " << modulationType_[nbAllocation]);
 
                    nbAllocation += 1;
                }
            }
        }
    }
 
    NS_LOG_INFO("\t\ttotAllocSizeSymbols = " << totAllocSizeSymbols);
 
    // Channel Saturation
    while (totAllocSizeSymbols > availableSymbols)
    {
        NS_LOG_INFO("\tUL Channel Saturation: totAllocSizeSymbols > availableSymbols");
        double delta = double(availableSymbols) / double(totAllocSizeSymbols);
        NS_LOG_INFO("\t\tdelta = " << delta);
        totAllocSizeSymbols = 0;
        for (int i = 0; i < nbAllocation; i++)
        {
            NS_LOG_INFO("\t\tprevious allocSizeSymbols_[" << i << "] = " << allocSizeSymbols_[i]);
            allocSizeSymbols_[i] = (uint32_t)std::floor(allocSizeSymbols_[i] * delta);
            totAllocSizeSymbols += allocSizeSymbols_[i];
            NS_LOG_INFO("\t\tnew allocSizeSymbols_[" << i << "] = " << allocSizeSymbols_[i]);
        }
        NS_LOG_INFO("\t\ttotAllocSizeSymbols = " << totAllocSizeSymbols);
    }
 
    // Uplink Bandwidth Allocation
    for (int i = 0; i < nbAllocation; i++)
    {
        AddUplinkAllocation(ulMapIe_[i],
                            allocSizeSymbols_[i],
                            symbolsToAllocation,
                            availableSymbols);
        allocSizeBytes = GetBs()->GetPhy()->GetNrBytes(allocSizeSymbols_[i], modulationType_[i]);
        NS_LOG_INFO("\t\tUpdateGrantedBandwidth for " << i << " = " << allocSizeBytes);
        if (record_[i]->GetRequestedBandwidth() < allocSizeBytes)
        {
            // the flow need new poll to set the newer requiredBandwidth
            record_[i]->SetGrantedBandwidth(0);
            record_[i]->SetRequestedBandwidth(0);
        }
        else
        {
            record_[i]->UpdateGrantedBandwidth(allocSizeBytes);
        }
    }
}
 
void
UplinkSchedulerRtps::AllocateInitialRangingInterval(uint32_t& symbolsToAllocation,
                                                    uint32_t& availableSymbols)
{
    Time ssUlStartTime =
        Seconds(CalculateAllocationStartTime() * GetBs()->GetPsDuration().GetSeconds());
    SetNrIrOppsAllocated(GetBs()->GetLinkManager()->CalculateRangingOppsToAllocate());
    uint32_t allocationSize = GetNrIrOppsAllocated() * GetBs()->GetRangReqOppSize();
    Time timeSinceLastIrInterval = Simulator::Now() - GetTimeStampIrInterval();
 
    // adding one frame because may be the time has not elapsed now but will elapse before the next
    // frame is sent
    if (timeSinceLastIrInterval + GetBs()->GetPhy()->GetFrameDuration() >
            GetBs()->GetInitialRangingInterval() &&
        availableSymbols >= allocationSize)
    {
        SetIsIrIntrvlAllocated(true);
        OfdmUlMapIe ulMapIeIr;
        ulMapIeIr.SetCid(GetBs()->GetBroadcastConnection()->GetCid());
        ulMapIeIr.SetStartTime(symbolsToAllocation);
        ulMapIeIr.SetUiuc(OfdmUlBurstProfile::UIUC_INITIAL_RANGING);
 
        NS_LOG_DEBUG("BS uplink scheduler, initial ranging allocation, size: "
                     << allocationSize << " symbols"
                     << ", modulation: BPSK 1/2");
 
        // marking start and end of each TO, only for debugging
        for (uint8_t i = 0; i < GetNrIrOppsAllocated(); i++)
        {
            GetBs()->MarkRangingOppStart(
                ssUlStartTime +
                Seconds(symbolsToAllocation * GetBs()->GetSymbolDuration().GetSeconds()) +
                Seconds(i * GetBs()->GetRangReqOppSize() *
                        GetBs()->GetSymbolDuration().GetSeconds()));
        }
 
        AddUplinkAllocation(ulMapIeIr, allocationSize, symbolsToAllocation, availableSymbols);
        SetTimeStampIrInterval(Simulator::Now());
    }
}
 
void
UplinkSchedulerRtps::SetupServiceFlow(SSRecord* ssRecord, ServiceFlow* serviceFlow)
{
    uint8_t delayNrFrames = 1;
    uint32_t bitsPerSecond = serviceFlow->GetMinReservedTrafficRate();
    WimaxPhy::ModulationType modulation;
    uint32_t bytesPerFrame =
        (uint32_t((double)(bitsPerSecond)*GetBs()->GetPhy()->GetFrameDuration().GetSeconds())) / 8;
    uint32_t frameDurationMSec = GetBs()->GetPhy()->GetFrameDuration().GetMilliSeconds();
 
    switch (serviceFlow->GetSchedulingType())
    {
    case ServiceFlow::SF_TYPE_UGS: {
        if (serviceFlow->GetIsMulticast())
        {
            modulation = serviceFlow->GetModulation();
        }
        else
        {
            modulation = ssRecord->GetModulationType();
        }
        uint32_t grantSize = GetBs()->GetPhy()->GetNrSymbols(bytesPerFrame, modulation);
        serviceFlow->GetRecord()->SetGrantSize(grantSize);
 
        uint32_t toleratedJitter = serviceFlow->GetToleratedJitter();
 
        if (toleratedJitter > frameDurationMSec)
        {
            delayNrFrames = (uint8_t)(toleratedJitter / frameDurationMSec);
        }
 
        uint16_t interval = delayNrFrames * frameDurationMSec;
        serviceFlow->SetUnsolicitedGrantInterval(interval);
    }
    break;
    case ServiceFlow::SF_TYPE_RTPS: {
        if (serviceFlow->GetSduSize() > bytesPerFrame)
        {
            delayNrFrames = (uint8_t)(serviceFlow->GetSduSize() / bytesPerFrame);
        }
 
        uint16_t interval = delayNrFrames * frameDurationMSec;
        serviceFlow->SetUnsolicitedPollingInterval(interval);
    }
    break;
    case ServiceFlow::SF_TYPE_NRTPS:
        // no real-time guarantees are given to NRTPS, serviced based on available bandwidth
    case ServiceFlow::SF_TYPE_BE:
        // no real-time guarantees are given to BE, serviced based on available bandwidth
        break;
    default:
        NS_FATAL_ERROR("Invalid scheduling type");
    }
}
 
void
UplinkSchedulerRtps::InitOnce()
{
}
 
void
UplinkSchedulerRtps::ProcessBandwidthRequest(const BandwidthRequestHeader& bwRequestHdr)
{
}
 
void
UplinkSchedulerRtps::OnSetRequestedBandwidth(ServiceFlowRecord* sfr)
{
    // m_grantedBandwidth must be reset to zero
    uint32_t grantedBandwidth = 0;
    sfr->SetGrantedBandwidth(grantedBandwidth);
}
 
} // namespace ns3