22 #define log2(x) (log(x) / M_LN2)
26 #include <ns3/pointer.h>
28 #include <ns3/simulator.h>
29 #include <ns3/lte-amc.h>
30 #include <ns3/pf-ff-mac-scheduler.h>
140 : m_scheduler (scheduler)
215 : m_cschedSapUser (0),
220 m_amc = CreateObject <LteAmc> ();
243 .AddConstructor<PfFfMacScheduler> ()
244 .AddAttribute (
"CqiTimerThreshold",
245 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
248 MakeUintegerChecker<uint32_t> ())
313 std::map <uint16_t, pfsFlowPerf_t>::iterator it;
365 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
373 m_rlcBufferReq.insert (std::pair <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters> (flow, params));
377 (*it).second = params;
402 for (
int i = 0; i < 4; i++)
417 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
421 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0)
422 || ((*it).second.m_rlcRetransmissionQueueSize > 0)
423 || ((*it).second.m_rlcStatusPduSize > 0) ))
427 if ((*it).first.m_rnti > rnti)
452 std::map <uint16_t, std::vector <uint16_t> > allocationMap;
453 for (
int i = 0; i < rbgNum; i++)
456 std::map <uint16_t, pfsFlowPerf_t>::iterator it;
457 std::map <uint16_t, pfsFlowPerf_t>::iterator itMax =
m_flowStatsDl.end ();
458 double rcqiMax = 0.0;
461 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
463 std::map <uint16_t,uint8_t>::iterator itTxMode;
467 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*it).first);
470 std::vector <uint8_t> sbCqi;
474 for (uint8_t k = 0; k < nLayer; k++)
481 sbCqi = (*itCqi).second.m_higherLayerSelected.at (i).m_sbCqi;
484 uint8_t cqi1 = sbCqi.at(0);
486 if (sbCqi.size () > 1)
491 if ((cqi1 > 0)||(cqi2 > 0))
497 double achievableRate = 0.0;
498 for (uint8_t k = 0; k < nLayer; k++)
501 if (sbCqi.size () > k)
513 double rcqi = achievableRate / (*it).second.lastAveragedThroughput;
532 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
533 itMap = allocationMap.find ((*itMax).first);
534 if (itMap == allocationMap.end ())
537 std::vector <uint16_t> tempMap;
538 tempMap.push_back (i);
539 allocationMap.insert (std::pair <uint16_t, std::vector <uint16_t> > ((*itMax).first, tempMap));
543 (*itMap).second.push_back (i);
550 std::map <uint16_t, pfsFlowPerf_t>::iterator itStats;
553 (*itStats).second.lastTtiBytesTrasmitted = 0;
559 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap = allocationMap.begin ();
560 while (itMap != allocationMap.end ())
564 newEl.
m_rnti = (*itMap).first;
567 std::vector <struct RlcPduListElement_s> newRlcPduLe;
568 newDci.
m_rnti = (*itMap).first;
572 uint16_t RgbPerRnti = (*itMap).second.size ();
573 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
575 std::map <uint16_t,uint8_t>::iterator itTxMode;
579 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*itMap).first);
582 std::vector <uint8_t> worstCqi (2, 15);
585 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
587 if ((*itCqi).second.m_higherLayerSelected.size () > (*itMap).second.at (k))
590 for (uint8_t j = 0; j < nLayer; j++)
592 if ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.size ()> j)
594 if (((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j)) < worstCqi.at (j))
596 worstCqi.at (j) = ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j));
608 for (uint8_t j = 0; j < nLayer; j++)
617 for (uint8_t j = 0; j < nLayer; j++)
623 uint32_t bytesTxed = 0;
624 for (uint8_t j = 0; j < nLayer; j++)
635 uint32_t rbgMask = 0;
636 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
638 rbgMask = rbgMask + (0x1 << (*itMap).second.at (k));
644 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator itBufReq;
647 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
648 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0)
649 || ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0)
650 || ((*itBufReq).second.m_rlcStatusPduSize > 0) ))
652 for (uint8_t j = 0; j < nLayer; j++)
658 newRlcPduLe.push_back (newRlcEl);
662 if ((*itBufReq).first.m_rnti > (*itMap).first)
667 newDci.
m_ndi.push_back (1);
668 newDci.
m_rv.push_back (0);
670 newEl.
m_dci = newDci;
677 std::map <uint16_t, pfsFlowPerf_t>::iterator it;
681 (*it).second.lastTtiBytesTrasmitted = bytesTxed;
688 NS_LOG_DEBUG (
this <<
" No Stats for this allocated UE");
699 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTrasmitted;
701 (*itStats).second.lastAveragedThroughput = ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) + ((1.0 /
m_timeWindow) * (double)((*itStats).second.lastTtiBytesTrasmitted / 0.001));
704 (*itStats).second.lastTtiBytesTrasmitted = 0;
726 for (
unsigned int i = 0; i < params.
m_cqiList.size (); i++)
731 std::map <uint16_t,uint8_t>::iterator it;
732 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
737 m_p10CqiRxed.insert ( std::pair<uint16_t, uint8_t > (rnti, params.
m_cqiList.at (i).m_wbCqi.at (0)) );
744 (*it).second = params.
m_cqiList.at (i).m_wbCqi.at (0);
746 std::map <uint16_t,uint32_t>::iterator itTimers;
754 std::map <uint16_t,SbMeasResult_s>::iterator it;
755 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
760 m_a30CqiRxed.insert ( std::pair<uint16_t, SbMeasResult_s > (rnti, params.
m_cqiList.at (i).m_sbMeasResult) );
766 (*it).second = params.
m_cqiList.at (i).m_sbMeasResult;
767 std::map <uint16_t,uint32_t>::iterator itTimers;
785 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find (rnti);
799 double sinr = (*itCqi).second.at (i);
806 double estimatedSinr = sinrSum / (double)sinrNum;
808 (*itCqi).second.at (rb) = estimatedSinr;
809 return (estimatedSinr);
820 std::map <uint16_t,uint32_t>::iterator it;
826 if ((*it).second > 0)
847 std::vector <uint16_t> rbgAllocationMap;
848 std::map <uint16_t, pfsFlowPerf_t>::iterator itStats;
877 uldci.
m_rnti = (*it).first;
880 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find ((*it).first);
891 double minSinr = (*itCqi).second.at (uldci.
m_rbStart);
899 double sinr = (*itCqi).second.at (i);
904 if ((*itCqi).second.at (i) < minSinr)
906 minSinr = (*itCqi).second.at (i);
911 double s = log2 ( 1 + (
912 pow (10, minSinr / 10 ) /
913 ( (-log (5.0 * 0.00005 )) / 1.5) ));
930 rbAllocated += rbPerFlow;
932 for (
int i = 0; i < rbPerFlow; i++)
934 rbgAllocationMap.push_back ((*it).first);
957 (*itStats).second.lastTtiBytesTrasmitted = uldci.
m_tbSize;
964 NS_LOG_DEBUG (
this <<
" No Stats for this allocated UE");
988 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTrasmitted;
990 (*itStats).second.lastAveragedThroughput = ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) + ((1.0 /
m_timeWindow) * (double)((*itStats).second.lastTtiBytesTrasmitted / 0.001));
993 (*itStats).second.lastTtiBytesTrasmitted = 0;
1021 std::map <uint16_t,uint32_t>::iterator it;
1023 for (
unsigned int i = 0; i < params.
m_macCeList.size (); i++)
1035 uint8_t bsrId = params.
m_macCeList.at (i).m_macCeValue.m_bufferStatus.at (0);
1037 m_ceBsrRxed.insert ( std::pair<uint16_t, uint32_t > (rnti, buffer));
1056 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
1057 std::map <uint16_t, std::vector <double> >::iterator itCqi;
1064 for (uint32_t i = 0; i < (*itMap).second.size (); i++)
1070 itCqi =
m_ueCqi.find ((*itMap).second.at (i));
1074 std::vector <double> newCqi;
1079 newCqi.push_back (sinr);
1088 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > ((*itMap).second.at (i), newCqi));
1095 (*itCqi).second.at (i) = sinr;
1097 std::map <uint16_t, uint32_t>::iterator itTimers;
1114 std::map <uint16_t,uint32_t>::iterator itP10 =
m_p10CqiTimers.begin ();
1118 if ((*itP10).second == 0)
1121 std::map <uint16_t,uint8_t>::iterator itMap =
m_p10CqiRxed.find ((*itP10).first);
1123 NS_LOG_INFO (
this <<
" P10-CQI exired for user " << (*itP10).first);
1125 std::map <uint16_t,uint32_t>::iterator temp = itP10;
1137 std::map <uint16_t,uint32_t>::iterator itA30 =
m_a30CqiTimers.begin ();
1141 if ((*itA30).second == 0)
1144 std::map <uint16_t,SbMeasResult_s>::iterator itMap =
m_a30CqiRxed.find ((*itA30).first);
1146 NS_LOG_INFO (
this <<
" A30-CQI exired for user " << (*itA30).first);
1148 std::map <uint16_t,uint32_t>::iterator temp = itA30;
1167 std::map <uint16_t,uint32_t>::iterator itUl =
m_ueCqiTimers.begin ();
1171 if ((*itUl).second == 0)
1174 std::map <uint16_t, std::vector <double> >::iterator itMap =
m_ueCqi.find ((*itUl).first);
1175 NS_ASSERT_MSG (itMap !=
m_ueCqi.end (),
" Does not find CQI report for user " << (*itUl).first);
1176 NS_LOG_INFO (
this <<
" UL-CQI exired for user " << (*itUl).first);
1177 (*itMap).second.clear ();
1179 std::map <uint16_t,uint32_t>::iterator temp = itUl;
1197 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
1205 if ((*it).second.m_rlcStatusPduSize <= size)
1207 size -= (*it).second.m_rlcStatusPduSize;
1208 (*it).second.m_rlcStatusPduSize = 0;
1212 (*it).second.m_rlcStatusPduSize -= size;
1216 if ((*it).second.m_rlcRetransmissionQueueSize <= size)
1218 size -= (*it).second.m_rlcRetransmissionQueueSize;
1219 (*it).second.m_rlcRetransmissionQueueSize = 0;
1223 (*it).second.m_rlcRetransmissionQueueSize -= size;
1227 if ((*it).second.m_rlcTransmissionQueueSize <= size)
1229 size -= (*it).second.m_rlcTransmissionQueueSize;
1230 (*it).second.m_rlcTransmissionQueueSize = 0;
1234 (*it).second.m_rlcTransmissionQueueSize -= size;
1240 NS_LOG_ERROR (
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
1249 std::map <uint16_t,uint32_t>::iterator it =
m_ceBsrRxed.find (rnti);
1253 if ((*it).second >= size)
1255 (*it).second -= size;
1264 NS_LOG_ERROR (
this <<
" Does not find BSR report info of UE " << rnti);
1272 NS_LOG_FUNCTION (
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);