/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */

/*

 * Copyright (c) 2011 Centre Tecnologic de Telecomunicacions de Catalunya (CTTC)

 *

 * 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: Marco Miozzo <marco.miozzo@cttc.es>

 */

#include <ns3/log.h>

#include <ns3/pointer.h>

#include <ns3/simulator.h>

#include <ns3/lte-amc.h>

#include <ns3/pf-ff-mac-scheduler.h>

NS_LOG_COMPONENT_DEFINE ("PfFfMacScheduler");

namespace ns3 {

int PfType0AllocationRbg[4] = {

  10,       // RGB size 1

  26,       // RGB size 2

  63,       // RGB size 3

  110       // RGB size 4

};  // see table 7.1.6.1-1 of 36.213

NS_OBJECT_ENSURE_REGISTERED (PfFfMacScheduler);

class PfSchedulerMemberCschedSapProvider : public FfMacCschedSapProvider

{

public:

  PfSchedulerMemberCschedSapProvider (PfFfMacScheduler* scheduler);

  // inherited from FfMacCschedSapProvider

  virtual void CschedCellConfigReq (const struct CschedCellConfigReqParameters& params);

  virtual void CschedUeConfigReq (const struct CschedUeConfigReqParameters& params);

  virtual void CschedLcConfigReq (const struct CschedLcConfigReqParameters& params);

  virtual void CschedLcReleaseReq (const struct CschedLcReleaseReqParameters& params);

  virtual void CschedUeReleaseReq (const struct CschedUeReleaseReqParameters& params);

private:

  PfSchedulerMemberCschedSapProvider ();

  PfFfMacScheduler* m_scheduler;

};

PfSchedulerMemberCschedSapProvider::PfSchedulerMemberCschedSapProvider ()

{

}

PfSchedulerMemberCschedSapProvider::PfSchedulerMemberCschedSapProvider (PfFfMacScheduler* scheduler) : m_scheduler (scheduler)

{

}

void

PfSchedulerMemberCschedSapProvider::CschedCellConfigReq (const struct CschedCellConfigReqParameters& params)

{

  m_scheduler->DoCschedCellConfigReq (params);

}

void

PfSchedulerMemberCschedSapProvider::CschedUeConfigReq (const struct CschedUeConfigReqParameters& params)

{

  m_scheduler->DoCschedUeConfigReq (params);

}

void

PfSchedulerMemberCschedSapProvider::CschedLcConfigReq (const struct CschedLcConfigReqParameters& params)

{

  m_scheduler->DoCschedLcConfigReq (params);

}

void

PfSchedulerMemberCschedSapProvider::CschedLcReleaseReq (const struct CschedLcReleaseReqParameters& params)

{

  m_scheduler->DoCschedLcReleaseReq (params);

}

void

PfSchedulerMemberCschedSapProvider::CschedUeReleaseReq (const struct CschedUeReleaseReqParameters& params)

{

  m_scheduler->DoCschedUeReleaseReq (params);

}

class PfSchedulerMemberSchedSapProvider : public FfMacSchedSapProvider

{

public:

  PfSchedulerMemberSchedSapProvider (PfFfMacScheduler* scheduler);

  // inherited from FfMacSchedSapProvider

  virtual void SchedDlRlcBufferReq (const struct SchedDlRlcBufferReqParameters& params);

  virtual void SchedDlPagingBufferReq (const struct SchedDlPagingBufferReqParameters& params);

  virtual void SchedDlMacBufferReq (const struct SchedDlMacBufferReqParameters& params);

  virtual void SchedDlTriggerReq (const struct SchedDlTriggerReqParameters& params);

  virtual void SchedDlRachInfoReq (const struct SchedDlRachInfoReqParameters& params);

  virtual void SchedDlCqiInfoReq (const struct SchedDlCqiInfoReqParameters& params);

  virtual void SchedUlTriggerReq (const struct SchedUlTriggerReqParameters& params);

  virtual void SchedUlNoiseInterferenceReq (const struct SchedUlNoiseInterferenceReqParameters& params);

  virtual void SchedUlSrInfoReq (const struct SchedUlSrInfoReqParameters& params);

  virtual void SchedUlMacCtrlInfoReq (const struct SchedUlMacCtrlInfoReqParameters& params);

  virtual void SchedUlCqiInfoReq (const struct SchedUlCqiInfoReqParameters& params);

private:

  PfSchedulerMemberSchedSapProvider ();

  PfFfMacScheduler* m_scheduler;

};

PfSchedulerMemberSchedSapProvider::PfSchedulerMemberSchedSapProvider ()

{

}

PfSchedulerMemberSchedSapProvider::PfSchedulerMemberSchedSapProvider (PfFfMacScheduler* scheduler)

  : m_scheduler (scheduler)

{

}

void

PfSchedulerMemberSchedSapProvider::SchedDlRlcBufferReq (const struct SchedDlRlcBufferReqParameters& params)

{

  m_scheduler->DoSchedDlRlcBufferReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedDlPagingBufferReq (const struct SchedDlPagingBufferReqParameters& params)

{

  m_scheduler->DoSchedDlPagingBufferReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedDlMacBufferReq (const struct SchedDlMacBufferReqParameters& params)

{

  m_scheduler->DoSchedDlMacBufferReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedDlTriggerReq (const struct SchedDlTriggerReqParameters& params)

{

  m_scheduler->DoSchedDlTriggerReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedDlRachInfoReq (const struct SchedDlRachInfoReqParameters& params)

{

  m_scheduler->DoSchedDlRachInfoReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedDlCqiInfoReq (const struct SchedDlCqiInfoReqParameters& params)

{

  m_scheduler->DoSchedDlCqiInfoReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedUlTriggerReq (const struct SchedUlTriggerReqParameters& params)

{

  m_scheduler->DoSchedUlTriggerReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedUlNoiseInterferenceReq (const struct SchedUlNoiseInterferenceReqParameters& params)

{

  m_scheduler->DoSchedUlNoiseInterferenceReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedUlSrInfoReq (const struct SchedUlSrInfoReqParameters& params)

{

  m_scheduler->DoSchedUlSrInfoReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedUlMacCtrlInfoReq (const struct SchedUlMacCtrlInfoReqParameters& params)

{

  m_scheduler->DoSchedUlMacCtrlInfoReq (params);

}

void

PfSchedulerMemberSchedSapProvider::SchedUlCqiInfoReq (const struct SchedUlCqiInfoReqParameters& params)

{

  m_scheduler->DoSchedUlCqiInfoReq (params);

}

PfFfMacScheduler::PfFfMacScheduler ()

  :   m_cschedSapUser (0),

    m_schedSapUser (0),

    m_timeWindow (0.5),

    m_schedTtiDelay (2) // WILD ACK: based on a m_macChTtiDelay = 1 

{

  m_cschedSapProvider = new PfSchedulerMemberCschedSapProvider (this);

  m_schedSapProvider = new PfSchedulerMemberSchedSapProvider (this);

}

PfFfMacScheduler::~PfFfMacScheduler ()

{

  NS_LOG_FUNCTION (this);

}

void

PfFfMacScheduler::DoDispose ()

{

  NS_LOG_FUNCTION (this);

  delete m_cschedSapProvider;

  delete m_schedSapProvider;

}

TypeId

PfFfMacScheduler::GetTypeId (void)

{

  static TypeId tid = TypeId ("PfFfMacScheduler")

    .SetParent<FfMacScheduler> ()

    .AddConstructor<PfFfMacScheduler> ();

  return tid;

}

void

PfFfMacScheduler::SetFfMacCschedSapUser (FfMacCschedSapUser* s)

{

  m_cschedSapUser = s;

}

void

PfFfMacScheduler::SetFfMacSchedSapUser (FfMacSchedSapUser* s)

{

  m_schedSapUser = s;

}

FfMacCschedSapProvider*

PfFfMacScheduler::GetFfMacCschedSapProvider ()

{

  return m_cschedSapProvider;

}

FfMacSchedSapProvider*

PfFfMacScheduler::GetFfMacSchedSapProvider ()

{

  return m_schedSapProvider;

}

void

PfFfMacScheduler::DoCschedCellConfigReq (const struct FfMacCschedSapProvider::CschedCellConfigReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // Read the subset of parameters used

  m_cschedCellConfig = params;

  FfMacCschedSapUser::CschedUeConfigCnfParameters cnf;

  cnf.m_result = SUCCESS;

  m_cschedSapUser->CschedUeConfigCnf (cnf);

  return;

}

void

PfFfMacScheduler::DoCschedUeConfigReq (const struct FfMacCschedSapProvider::CschedUeConfigReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // Not used at this stage

  return;

}

void

PfFfMacScheduler::DoCschedLcConfigReq (const struct FfMacCschedSapProvider::CschedLcConfigReqParameters& params)

{

  NS_LOG_FUNCTION (this << " New LC, rnti: "  << params.m_rnti);

  for (uint16_t i = 0; i < params.m_logicalChannelConfigList.size (); i++)

    {

      it = m_flowStats.find (flow);

      if (it == m_flowStats.end ())

        {

          pfsFlowPerf_t flowStats;

          flowStats.flowStart = Simulator::Now ();

          flowStats.totalBytesTransmitted = 0;

          flowStats.lastTtiBytesTrasmitted = 0;

          if (params.m_logicalChannelConfigList.at (i).m_eRabGuaranteedBitrateDl != 0)

            {

              flowStats.lastAveragedThroughput = params.m_logicalChannelConfigList.at (i).m_eRabGuaranteedBitrateDl;

            }

          else

            {

              flowStats.lastAveragedThroughput = 1; // minimum bitrate -> high priority to new flows

            }

          flowStats.rlcBufferReq.m_rlcTransmissionQueueSize = 0;

          flowStats.rlcBufferReq.m_rlcRetransmissionQueueSize = 0;

          flowStats.rlcBufferReq.m_rlcStatusPduSize = 0;

        }

      else

        {

          NS_LOG_ERROR ("LC already exists");

        }

    }

  return;

}

void

PfFfMacScheduler::DoCschedLcReleaseReq (const struct FfMacCschedSapProvider::CschedLcReleaseReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // TODO: Implementation of the API

  return;

}

void

PfFfMacScheduler::DoCschedUeReleaseReq (const struct FfMacCschedSapProvider::CschedUeReleaseReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // TODO: Implementation of the API

  return;

}

void

PfFfMacScheduler::DoSchedDlRlcBufferReq (const struct FfMacSchedSapProvider::SchedDlRlcBufferReqParameters& params)

{

  NS_LOG_FUNCTION (this << params.m_rnti << (uint32_t) params.m_logicalChannelIdentity);

  // API generated by RLC for updating RLC parameters on a LC (tx and retx queues)

  it = m_flowStats.find (flow);

  if (it == m_flowStats.end ())

    {

      NS_LOG_ERROR (this << " RlcBufferReq from an unregistered LC");

    }

  else

    {

      (*it).second.rlcBufferReq = params;

    }  

  return;

}

void

PfFfMacScheduler::DoSchedDlPagingBufferReq (const struct FfMacSchedSapProvider::SchedDlPagingBufferReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // TODO: Implementation of the API

  return;

}

void

PfFfMacScheduler::DoSchedDlMacBufferReq (const struct FfMacSchedSapProvider::SchedDlMacBufferReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // TODO: Implementation of the API

  return;

}

int

PfFfMacScheduler::GetRbgSize (int dlbandwidth)

{

  for (int i = 0; i < 4; i++)

    {

      if (dlbandwidth < PfType0AllocationRbg[i])

        {

          return (i + 1);

        }

    }

  return (-1);

}

void

PfFfMacScheduler::DoSchedDlTriggerReq (const struct FfMacSchedSapProvider::SchedDlTriggerReqParameters& params)

{

  NS_LOG_FUNCTION (this);

  // API generated by RLC for triggering the scheduling of a DL subframe

  // evaluate the relative channel quality indicator for each UE per each RBG 

  // (since we are using allocation type 0 the small unit of allocation is RBG)

  // Resource allocation type 0 (see sec 7.1.6.1 of 36.213)

  int rbgSize = GetRbgSize (m_cschedCellConfig.m_dlBandwidth);

  int rbgNum = m_cschedCellConfig.m_dlBandwidth / rbgSize;

  for (int i = 0; i < rbgNum; i++)

    {

      //NS_LOG_DEBUG (this << " ALLOCATION for RBG " << i << " of " << rbgNum);

      double rcqiMax = 0.0;

      for (it = m_flowStats.begin (); it != m_flowStats.end (); it++)

        {

          std::map <uint16_t,SbMeasResult_s>::iterator itCqi;

          itCqi = m_a30CqiRxed.find ((*it).first.m_rnti);

          uint8_t cqi = 0;

          if (itCqi == m_a30CqiRxed.end ())

            {

              //NS_LOG_DEBUG (this << " No DL-CQI for this UE-LC " << (*it).first.m_rnti);

              cqi = 1;  // start with lowest value

            }

          else

            {

              cqi = (*itCqi).second.m_higherLayerSelected.at (i).m_sbCqi.at (0);

            }

          if (cqi > 0)  // CQI == 0 means "out of range" (see table 7.2.3-1 of 36.213)

            {

              if ( ((*it).second.rlcBufferReq.m_rlcTransmissionQueueSize > 0)

                || ((*it).second.rlcBufferReq.m_rlcRetransmissionQueueSize > 0)

                || ((*it).second.rlcBufferReq.m_rlcStatusPduSize > 0) )

                {

                  // this UE-LC has data to transmit

                  //NS_LOG_DEBUG (this << " ue-lc " << (*it).first.m_rnti);

                  uint8_t mcs = LteAmc::GetMcsFromCqi (cqi);

                  //NS_LOG_DEBUG (this << " MCS " << (uint32_t)mcs);

                  double achievableRate = ((LteAmc::GetTbSizeFromMcs (mcs, 1) / 8)/0.001); // = TB size / TTI

                  double rcqi = achievableRate / (*it).second.lastAveragedThroughput;

                  //NS_LOG_DEBUG (this << " achievaleRate " << achievableRate << " avg thr " << (*it).second.lastAveragedThroughput);

                  //NS_LOG_DEBUG (this << " RCQI " << rcqi);

                  if (rcqi > rcqiMax)

                    {

                      rcqiMax = rcqi;

                      itMax = it;

                    }

                }

              } // end if cqi

        } // end for m_rlcBufferReq

      if (itMax == m_flowStats.end ())

        {

          // no UE available for this RB

          //NS_LOG_DEBUG (this << " no UE found");

          nullFlow.m_rnti = 0;

          rbgAllocationMap.push_back (nullFlow);

        }

      else

        {

          rbgAllocationMap.push_back ((*itMax).first);

          //NS_LOG_DEBUG (this << " UE assigned " << (*itMax).first.m_rnti);

        }

    } // end for RBGs

    // generate the transmission opportunities by grouping the adjacent RBGs and

    // creating the correspondent DCIs

    FfMacSchedSapUser::SchedDlConfigIndParameters ret;

    int rbgAllocated = 0;

    while (flowIt != rbgAllocationMap.end ())

      {

        if ((*flowIt).m_rnti == 0)

          {

            // skip this RBG

            //NS_LOG_DEBUG (this << " RBG empty " << rbgAllocated);

            rbgAllocated++;

            flowIt++;

            continue;

          }

        int lcRbgNum = 1;

        while (((flowIt+1) != rbgAllocationMap.end ()) && ((*flowIt).m_rnti == (*(flowIt+1)).m_rnti))

          {

            lcRbgNum++;

            flowIt++;

          }

        //NS_LOG_DEBUG (this << " Tx Opp for user " << (*flowIt).m_rnti);

        //NS_LOG_DEBUG (this << " Tx Opp from " << rbgAllocated << " to " << rbgAllocated + lcRbgNum);

        // create new BuildDataListElement_s for this LC

        BuildDataListElement_s newEl;

        newEl.m_rnti = (*flowIt).m_rnti;

        // NS_LOG_DEBUG (this << "Allocate user " << newEl.m_rnti << " rbg " << rbgPerFlow);

        // create the DlDciListElement_s

        DlDciListElement_s newDci;

        std::vector <struct RlcPduListElement_s> newRlcPduLe;

        newDci.m_rnti = (*flowIt).m_rnti;

        newDci.m_resAlloc = 0;

        newDci.m_rbBitmap = 0; // TBD (32 bit bitmap see 7.1.6 of 36.213)

        uint32_t rbgMask = 0;

        uint32_t startRbg = rbgAllocated;

        for (int i = 0; i < lcRbgNum; i++)

          {

            rbgMask = rbgMask + (0x1 << rbgAllocated);

            // NS_LOG_DEBUG (this << " Allocated PRB " << rbgAllocated);

            rbgAllocated++;

          }

        uint32_t finishRbg = rbgAllocated - 1; 

        newDci.m_rbBitmap = rbgMask; // (32 bit bitmap see 7.1.6 of 36.213)

        int nbOfTbsInNewDci = 1;  // SISO -> only one TB

        int rlcPduSize = 0;

        for (int i = 0; i < nbOfTbsInNewDci; i++)

          {

            std::map <uint16_t,SbMeasResult_s>::iterator itCqi;

            itCqi = m_a30CqiRxed.find (newDci.m_rnti);