satellite-fwd-link-scheduler.cc

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
 * Copyright (c) 2013 Magister Solutions Ltd
 *
 * 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: Sami Rantanen <sami.rantanen@magister.fi>
 */
 
#include "satellite-fwd-link-scheduler.h"
 
#include "satellite-enums.h"
#include "satellite-mac-tag.h"
#include "satellite-scheduling-object.h"
 
#include "ns3/boolean.h"
#include "ns3/double.h"
#include "ns3/enum.h"
#include "ns3/log.h"
#include "ns3/mac48-address.h"
#include "ns3/nstime.h"
#include "ns3/pointer.h"
#include "ns3/simulator.h"
#include "ns3/trace-source-accessor.h"
#include "ns3/uinteger.h"
 
#include <algorithm>
#include <iostream>
#include <stdint.h>
#include <string>
#include <utility>
#include <vector>
 
NS_LOG_COMPONENT_DEFINE("SatFwdLinkScheduler");
 
namespace ns3
{
 
NS_OBJECT_ENSURE_REGISTERED(SatFwdLinkScheduler);
 
// #define SAT_FWD_LINK_SCHEDULER_PRINT_SORT_RESULT
 
#ifdef SAT_FWD_LINK_SCHEDULER_PRINT_SORT_RESULT
static void
PrintSoContent(std::string context, std::vector<Ptr<SatSchedulingObject>>& so)
{
    std::cout << context << std::endl;
 
    for (std::vector<Ptr<SatSchedulingObject>>::const_iterator it = so.begin(); it != so.end();
         it++)
    {
        std::cout << "So-Content (ptr, priority, load, hol): " << (*it) << ", "
                  << (*it)->GetPriority() << ", " << (*it)->GetBufferedBytes() << ", "
                  << (*it)->GetHolDelay() << std::endl;
    }
 
    std::cout << std::endl;
}
#endif
 
bool
SatFwdLinkScheduler::CompareSoFlowId(Ptr<SatSchedulingObject> obj1, Ptr<SatSchedulingObject> obj2)
{
    return (bool)(obj1->GetFlowId() < obj2->GetFlowId());
}
 
bool
SatFwdLinkScheduler::CompareSoPriorityLoad(Ptr<SatSchedulingObject> obj1,
                                           Ptr<SatSchedulingObject> obj2)
{
    bool result = CompareSoFlowId(obj1, obj2);
 
    if (obj1->GetFlowId() == obj2->GetFlowId())
    {
        result = (bool)(obj1->GetBufferedBytes() > obj2->GetBufferedBytes());
    }
 
    return result;
}
 
bool
SatFwdLinkScheduler::CompareSoPriorityHol(Ptr<SatSchedulingObject> obj1,
                                          Ptr<SatSchedulingObject> obj2)
{
    bool result = CompareSoFlowId(obj1, obj2);
 
    if (obj1->GetFlowId() == obj2->GetFlowId())
    {
        result = (bool)(obj1->GetHolDelay() > obj2->GetHolDelay());
    }
 
    return result;
}
 
TypeId
SatFwdLinkScheduler::GetTypeId(void)
{
    static TypeId tid =
        TypeId("ns3::SatFwdLinkScheduler")
            .SetParent<Object>()
            .AddAttribute("Interval",
                          "The time for periodic scheduling",
                          TimeValue(MilliSeconds(20)),
                          MakeTimeAccessor(&SatFwdLinkScheduler::m_periodicInterval),
                          MakeTimeChecker())
            .AddAttribute("BBFrameConf",
                          "BB Frame configuration for this scheduler.",
                          PointerValue(),
                          MakePointerAccessor(&SatFwdLinkScheduler::m_bbFrameConf),
                          MakePointerChecker<SatBbFrameConf>())
            .AddAttribute("DummyFrameSendingEnabled",
                          "Flag to tell, if dummy frames are sent or not.",
                          BooleanValue(false),
                          MakeBooleanAccessor(&SatFwdLinkScheduler::m_dummyFrameSendingEnabled),
                          MakeBooleanChecker())
            .AddAttribute("AdditionalSortCriteria",
                          "Sorting criteria after priority for scheduling objects from LLC.",
                          EnumValue(SatFwdLinkScheduler::NO_SORT),
                          MakeEnumAccessor<SatFwdLinkScheduler::ScheduleSortingCriteria_t>(
                              &SatFwdLinkScheduler::m_additionalSortCriteria),
                          MakeEnumChecker(SatFwdLinkScheduler::NO_SORT,
                                          "NoSorting",
                                          SatFwdLinkScheduler::BUFFERING_DELAY_SORT,
                                          "DelaySort",
                                          SatFwdLinkScheduler::BUFFERING_LOAD_SORT,
                                          "LoadSort"))
            .AddAttribute("CnoEstimationMode",
                          "Mode of the C/N0 estimator",
                          EnumValue(SatCnoEstimator::LAST),
                          MakeEnumAccessor<SatCnoEstimator::EstimationMode_t>(
                              &SatFwdLinkScheduler::m_cnoEstimatorMode),
                          MakeEnumChecker(SatCnoEstimator::LAST,
                                          "LastValueInWindow",
                                          SatCnoEstimator::MINIMUM,
                                          "MinValueInWindow",
                                          SatCnoEstimator::AVERAGE,
                                          "AverageValueInWindow"))
            .AddAttribute("CnoEstimationWindow",
                          "Time window for C/N0 estimation.",
                          TimeValue(Seconds(5000)),
                          MakeTimeAccessor(&SatFwdLinkScheduler::m_cnoEstimationWindow),
                          MakeTimeChecker())
            .AddTraceSource(
                "SymbolRate",
                "Scheduler symbol rate for a given packet",
                MakeTraceSourceAccessor(&SatFwdLinkScheduler::m_schedulingSymbolRateTrace),
                "ns3::SatTypedefs::FwdLinkSchedulerSymbolRateCallback")
 
        ;
    return tid;
}
 
SatFwdLinkScheduler::SatFwdLinkScheduler()
    : m_additionalSortCriteria(SatFwdLinkScheduler::NO_SORT),
      m_cnoEstimatorMode(SatCnoEstimator::LAST),
      m_carrierBandwidthInHz(0.0)
{
    NS_LOG_FUNCTION(this);
    NS_FATAL_ERROR("Default constructor for SatFwdLinkScheduler not supported");
}
 
SatFwdLinkScheduler::SatFwdLinkScheduler(Ptr<SatBbFrameConf> conf,
                                         Mac48Address address,
                                         double carrierBandwidthInHz)
    : m_macAddress(address),
      m_bbFrameConf(conf),
      m_additionalSortCriteria(SatFwdLinkScheduler::NO_SORT),
      m_cnoEstimatorMode(SatCnoEstimator::LAST),
      m_carrierBandwidthInHz(carrierBandwidthInHz)
{
    NS_LOG_FUNCTION(this << conf << address << carrierBandwidthInHz);
 
    // Random variable used in scheduling
    m_random = CreateObject<UniformRandomVariable>();
}
 
void
SatFwdLinkScheduler::NotifyConstructionCompleted()
{
    NS_LOG_FUNCTION(this);
 
    Object::NotifyConstructionCompleted();
 
    Simulator::Schedule(m_periodicInterval, &SatFwdLinkScheduler::PeriodicTimerExpired, this);
}
 
SatFwdLinkScheduler::~SatFwdLinkScheduler()
{
    NS_LOG_FUNCTION(this);
}
 
void
SatFwdLinkScheduler::DoDispose()
{
    NS_LOG_FUNCTION(this);
    m_schedContextCallback.Nullify();
    m_txOpportunityCallback.Nullify();
    m_sendControlMsgCallback.Nullify();
    m_cnoEstimatorContainer.clear();
}
 
void
SatFwdLinkScheduler::SetSchedContextCallback(SatFwdLinkScheduler::SchedContextCallback cb)
{
    NS_LOG_FUNCTION(this << &cb);
    m_schedContextCallback = cb;
}
 
void
SatFwdLinkScheduler::SetTxOpportunityCallback(SatFwdLinkScheduler::TxOpportunityCallback cb)
{
    NS_LOG_FUNCTION(this << &cb);
    m_txOpportunityCallback = cb;
}
 
void
SatFwdLinkScheduler::SetSendControlMsgCallback(SatFwdLinkScheduler::SendControlMsgCallback cb)
{
    NS_LOG_FUNCTION(this << &cb);
    m_sendControlMsgCallback = cb;
}
 
bool
SatFwdLinkScheduler::SendControlMsg(Ptr<SatControlMessage> message, const Address& dest) const
{
    NS_LOG_FUNCTION(this << message << dest);
    return m_sendControlMsgCallback(message, dest);
}
 
std::pair<Ptr<SatBbFrame>, const Time>
SatFwdLinkScheduler::GetNextFrame()
{
    NS_FATAL_ERROR("SatFwdLinkScheduler::GetNextFrame: should not be here");
 
    Ptr<SatBbFrame> f = nullptr;
 
    return std::make_pair(f, m_bbFrameConf->GetDummyBbFrameDuration());
}
 
void
SatFwdLinkScheduler::CnoInfoUpdated(Mac48Address utAddress, double cnoEstimate)
{
    NS_LOG_FUNCTION(this << utAddress << cnoEstimate);
 
    CnoEstimatorMap_t::const_iterator it = m_cnoEstimatorContainer.find(utAddress);
 
    if (it == m_cnoEstimatorContainer.end())
    {
        Ptr<SatCnoEstimator> estimator = CreateCnoEstimator();
 
        std::pair<CnoEstimatorMap_t::const_iterator, bool> result =
            m_cnoEstimatorContainer.insert(std::make_pair(utAddress, estimator));
        it = result.first;
 
        if (result.second == false)
        {
            NS_FATAL_ERROR("Estimator cannot be added to container!!!");
        }
    }
 
    it->second->AddSample(cnoEstimate);
}
 
Time
SatFwdLinkScheduler::GetDefaultFrameDuration() const
{
    NS_LOG_FUNCTION(this);
 
    return m_bbFrameConf->GetBbFrameDuration(m_bbFrameConf->GetDefaultModCod(),
                                             SatEnums::NORMAL_FRAME);
}
 
void
SatFwdLinkScheduler::SetDummyFrameSendingEnabled(bool dummyFrameSendingEnabled)
{
    m_dummyFrameSendingEnabled = dummyFrameSendingEnabled;
}
 
void
SatFwdLinkScheduler::ClearAllPackets()
{
    NS_LOG_FUNCTION(this);
 
    NS_FATAL_ERROR("Must use subclasses");
}
 
void
SatFwdLinkScheduler::PeriodicTimerExpired()
{
    NS_LOG_FUNCTION(this);
 
    SendAndClearSymbolsSentStat();
    ScheduleBbFrames();
 
    Simulator::Schedule(m_periodicInterval, &SatFwdLinkScheduler::PeriodicTimerExpired, this);
}
 
void
SatFwdLinkScheduler::GetSchedulingObjects(std::vector<Ptr<SatSchedulingObject>>& output)
{
    NS_FATAL_ERROR("SatFwdLinkScheduler::GetSchedulingObjects: should not be here");
}
 
void
SatFwdLinkScheduler::SortSchedulingObjects(std::vector<Ptr<SatSchedulingObject>>& so)
{
    NS_LOG_FUNCTION(this);
 
    // sort only if there is need to sort
    if ((so.empty() == false) && (so.size() > 1))
    {
#ifdef SAT_FWD_LINK_SCHEDULER_PRINT_SORT_RESULT
        PrintSoContent("Before sort", so);
#endif
 
        switch (m_additionalSortCriteria)
        {
        case SatFwdLinkScheduler::NO_SORT:
            std::sort(so.begin(), so.end(), CompareSoFlowId);
            break;
 
        case SatFwdLinkScheduler::BUFFERING_DELAY_SORT:
            std::sort(so.begin(), so.end(), CompareSoPriorityHol);
            break;
 
        case SatFwdLinkScheduler::BUFFERING_LOAD_SORT:
            std::sort(so.begin(), so.end(), CompareSoPriorityLoad);
            break;
 
        default:
            NS_FATAL_ERROR("Not supported sorting criteria!!!");
            break;
        }
 
#ifdef SAT_FWD_LINK_SCHEDULER_PRINT_SORT_RESULT
        PrintSoContent("After sort", so);
#endif
    }
}
 
bool
SatFwdLinkScheduler::CnoMatchWithFrame(double cno, Ptr<SatBbFrame> frame) const
{
    NS_LOG_FUNCTION(this << cno << frame);
 
    bool match = false;
 
    SatEnums::SatModcod_t modCod = m_bbFrameConf->GetBestModcod(cno, frame->GetFrameType());
 
    if (modCod >= frame->GetModcod())
    {
        match = true;
    }
 
    return match;
}
 
double
SatFwdLinkScheduler::GetSchedulingObjectCno(Ptr<SatSchedulingObject> ob)
{
    NS_LOG_FUNCTION(this << ob);
 
    double cno = NAN;
 
    CnoEstimatorMap_t::const_iterator it = m_cnoEstimatorContainer.find(ob->GetMacAddress());
 
    if (it != m_cnoEstimatorContainer.end())
    {
        cno = it->second->GetCnoEstimation();
    }
 
    return cno;
}
 
Ptr<SatCnoEstimator>
SatFwdLinkScheduler::CreateCnoEstimator()
{
    NS_LOG_FUNCTION(this);
 
    Ptr<SatCnoEstimator> estimator = nullptr;
 
    switch (m_cnoEstimatorMode)
    {
    case SatCnoEstimator::LAST:
    case SatCnoEstimator::MINIMUM:
    case SatCnoEstimator::AVERAGE:
        estimator = Create<SatBasicCnoEstimator>(m_cnoEstimatorMode, m_cnoEstimationWindow);
        break;
 
    default:
        NS_FATAL_ERROR("Not supported C/N0 estimation mode!!!");
        break;
    }
 
    return estimator;
}
 
} // namespace ns3