23 #include <ns3/pointer.h>
26 #include <ns3/simulator.h>
27 #include <ns3/lte-amc.h>
28 #include <ns3/tta-ff-mac-scheduler.h>
29 #include <ns3/lte-vendor-specific-parameters.h>
143 : m_scheduler (scheduler)
218 : m_cschedSapUser (0),
222 m_amc = CreateObject <LteAmc> ();
245 .AddConstructor<TtaFfMacScheduler> ()
246 .AddAttribute (
"CqiTimerThreshold",
247 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
250 MakeUintegerChecker<uint32_t> ())
314 std::set<uint16_t>::iterator it;
357 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
365 m_rlcBufferReq.insert (std::pair <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters> (flow, params));
369 (*it).second = params;
392 for (
int i = 0; i < 4; i++)
407 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
411 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0)
412 || ((*it).second.m_rlcRetransmissionQueueSize > 0)
413 || ((*it).second.m_rlcStatusPduSize > 0) ))
417 if ((*it).first.m_rnti > rnti)
442 std::map <uint16_t, std::vector <uint16_t> > allocationMap;
443 for (
int i = 0; i < rbgNum; i++)
445 std::set <uint16_t>::iterator it;
447 double metricMax = 0.0;
450 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
452 std::map <uint16_t,uint8_t>::iterator itWbCqi;
454 std::map <uint16_t,uint8_t>::iterator itTxMode;
461 std::vector <uint8_t> sbCqi;
464 for (uint8_t k = 0; k < nLayer; k++)
471 sbCqi = (*itCqi).second.m_higherLayerSelected.at (i).m_sbCqi;
481 wbCqi = (*itWbCqi).second;
484 uint8_t cqi1 = sbCqi.at(0);
486 if (sbCqi.size () > 1)
491 if ((cqi1 > 0)||(cqi2 > 0))
498 double achievableSbRate = 1.0;
499 double achievableWbRate = 1.0;
500 for (uint8_t k = 0; k < nLayer; k++)
502 if (sbCqi.size () > k)
516 double metric = achievableSbRate / achievableWbRate;
518 if (metric > metricMax)
534 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
535 itMap = allocationMap.find ((*itMax));
536 if (itMap == allocationMap.end ())
539 std::vector <uint16_t> tempMap;
540 tempMap.push_back (i);
541 allocationMap.insert (std::pair <uint16_t, std::vector <uint16_t> > ((*itMax), tempMap));
545 (*itMap).second.push_back (i);
554 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap = allocationMap.begin ();
555 while (itMap != allocationMap.end ())
559 newEl.
m_rnti = (*itMap).first;
562 std::vector <struct RlcPduListElement_s> newRlcPduLe;
563 newDci.
m_rnti = (*itMap).first;
566 uint16_t rbgPerRnti = (*itMap).second.size ();
567 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
569 std::map <uint16_t,uint8_t>::iterator itTxMode;
573 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*itMap).first);
576 std::vector <uint8_t> worstCqi (2, 15);
579 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
581 if ((*itCqi).second.m_higherLayerSelected.size () > (*itMap).second.at (k))
583 for (uint8_t j = 0; j < nLayer; j++)
585 if ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.size () > j)
587 if (((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j)) < worstCqi.at (j))
589 worstCqi.at (j) = ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j));
601 for (uint8_t j = 0; j < nLayer; j++)
610 for (uint8_t j = 0; j < nLayer; j++)
615 for (uint8_t j = 0; j < nLayer; j++)
624 uint32_t rbgMask = 0;
625 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
627 rbgMask = rbgMask + (0x1 << (*itMap).second.at (k));
632 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator itBufReq;
635 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
636 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0)
637 || ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0)
638 || ((*itBufReq).second.m_rlcStatusPduSize > 0) ))
640 for (uint8_t j = 0; j < nLayer; j++)
645 newRlcPduLe.push_back (newRlcEl);
649 if ((*itBufReq).first.m_rnti > (*itMap).first)
654 newDci.
m_ndi.push_back (1);
655 newDci.
m_rv.push_back (0);
657 newEl.
m_dci = newDci;
685 for (
unsigned int i = 0; i < params.
m_cqiList.size (); i++)
690 std::map <uint16_t,uint8_t>::iterator it;
691 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
696 m_p10CqiRxed.insert ( std::pair<uint16_t, uint8_t > (rnti, params.
m_cqiList.at (i).m_wbCqi.at (0)) );
703 (*it).second = params.
m_cqiList.at (i).m_wbCqi.at (0);
705 std::map <uint16_t,uint32_t>::iterator itTimers;
713 std::map <uint16_t,SbMeasResult_s>::iterator it;
714 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
719 m_a30CqiRxed.insert ( std::pair<uint16_t, SbMeasResult_s > (rnti, params.
m_cqiList.at (i).m_sbMeasResult) );
725 (*it).second = params.
m_cqiList.at (i).m_sbMeasResult;
726 std::map <uint16_t,uint32_t>::iterator itTimers;
744 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find (rnti);
758 double sinr = (*itCqi).second.at (i);
765 double estimatedSinr = sinrSum / (double)sinrNum;
767 (*itCqi).second.at (rb) = estimatedSinr;
768 return (estimatedSinr);
779 std::map <uint16_t,uint32_t>::iterator it;
785 if ((*it).second > 0)
806 std::vector <uint16_t> rbgAllocationMap;
835 uldci.
m_rnti = (*it).first;
838 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find ((*it).first);
848 double minSinr = (*itCqi).second.at (uldci.
m_rbStart);
855 double sinr = (*itCqi).second.at (i);
860 if ((*itCqi).second.at (i) < minSinr)
862 minSinr = (*itCqi).second.at (i);
867 double s = log2 ( 1 + (
868 std::pow (10, minSinr / 10 ) /
869 ( (-std::log (5.0 * 0.00005 )) / 1.5) ));
885 rbAllocated += rbPerFlow;
887 for (
int i = 0; i < rbPerFlow; i++)
889 rbgAllocationMap.push_back ((*it).first);
892 NS_LOG_DEBUG (
this <<
" UE " << (*it).first <<
" startPRB " << (uint32_t)uldci.
m_rbStart <<
" nPRB " << (uint32_t)uldci.
m_rbLen <<
" CQI " << cqi <<
" MCS " << (uint32_t)uldci.
m_mcs <<
" TBsize " << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated);
949 std::map <uint16_t,uint32_t>::iterator it;
951 for (
unsigned int i = 0; i < params.
m_macCeList.size (); i++)
963 uint8_t bsrId = params.
m_macCeList.at (i).m_macCeValue.m_bufferStatus.at (0);
965 m_ceBsrRxed.insert ( std::pair<uint16_t, uint32_t > (rnti, buffer));
1013 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
1014 std::map <uint16_t, std::vector <double> >::iterator itCqi;
1021 for (uint32_t i = 0; i < (*itMap).second.size (); i++)
1026 itCqi =
m_ueCqi.find ((*itMap).second.at (i));
1030 std::vector <double> newCqi;
1035 newCqi.push_back (sinr);
1044 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > ((*itMap).second.at (i), newCqi));
1051 (*itCqi).second.at (i) = sinr;
1053 std::map <uint16_t, uint32_t>::iterator itTimers;
1074 rnti = vsp->GetRnti ();
1077 std::map <uint16_t, std::vector <double> >::iterator itCqi;
1082 std::vector <double> newCqi;
1086 newCqi.push_back (sinr);
1087 NS_LOG_DEBUG (
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value " << sinr);
1090 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > (rnti, newCqi));
1100 (*itCqi).second.at (j) = sinr;
1101 NS_LOG_DEBUG (
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value " << sinr);
1104 std::map <uint16_t, uint32_t>::iterator itTimers;
1117 NS_FATAL_ERROR (
"TtaFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1130 std::map <uint16_t,uint32_t>::iterator itP10 =
m_p10CqiTimers.begin ();
1134 if ((*itP10).second == 0)
1137 std::map <uint16_t,uint8_t>::iterator itMap =
m_p10CqiRxed.find ((*itP10).first);
1139 NS_LOG_INFO (
this <<
" P10-CQI exired for user " << (*itP10).first);
1141 std::map <uint16_t,uint32_t>::iterator temp = itP10;
1153 std::map <uint16_t,uint32_t>::iterator itA30 =
m_a30CqiTimers.begin ();
1157 if ((*itA30).second == 0)
1160 std::map <uint16_t,SbMeasResult_s>::iterator itMap =
m_a30CqiRxed.find ((*itA30).first);
1162 NS_LOG_INFO (
this <<
" A30-CQI exired for user " << (*itA30).first);
1164 std::map <uint16_t,uint32_t>::iterator temp = itA30;
1183 std::map <uint16_t,uint32_t>::iterator itUl =
m_ueCqiTimers.begin ();
1187 if ((*itUl).second == 0)
1190 std::map <uint16_t, std::vector <double> >::iterator itMap =
m_ueCqi.find ((*itUl).first);
1191 NS_ASSERT_MSG (itMap !=
m_ueCqi.end (),
" Does not find CQI report for user " << (*itUl).first);
1192 NS_LOG_INFO (
this <<
" UL-CQI exired for user " << (*itUl).first);
1193 (*itMap).second.clear ();
1195 std::map <uint16_t,uint32_t>::iterator temp = itUl;
1213 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
1220 if ((*it).second.m_rlcStatusPduSize <= size)
1222 size -= (*it).second.m_rlcStatusPduSize;
1223 (*it).second.m_rlcStatusPduSize = 0;
1227 (*it).second.m_rlcStatusPduSize -= size;
1231 if ((*it).second.m_rlcRetransmissionQueueSize <= size)
1233 size -= (*it).second.m_rlcRetransmissionQueueSize;
1234 (*it).second.m_rlcRetransmissionQueueSize = 0;
1238 (*it).second.m_rlcRetransmissionQueueSize -= size;
1242 if ((*it).second.m_rlcTransmissionQueueSize <= size)
1244 size -= (*it).second.m_rlcTransmissionQueueSize;
1245 (*it).second.m_rlcTransmissionQueueSize = 0;
1249 (*it).second.m_rlcTransmissionQueueSize -= size;
1255 NS_LOG_ERROR (
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
1264 std::map <uint16_t,uint32_t>::iterator it =
m_ceBsrRxed.find (rnti);
1267 if ((*it).second >= size)
1269 (*it).second -= size;
1278 NS_LOG_ERROR (
this <<
" Does not find BSR report info of UE " << rnti);
1286 NS_LOG_FUNCTION (
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);