14#include "ns3/boolean.h"
17#include "ns3/pointer.h"
18#include "ns3/simulator.h"
76 TypeId(
"ns3::PfFfMacScheduler")
80 .AddAttribute(
"CqiTimerThreshold",
81 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
85 .AddAttribute(
"HarqEnabled",
86 "Activate/Deactivate the HARQ [by default is active].",
90 .AddAttribute(
"UlGrantMcs",
91 "The MCS of the UL grant, must be [0..15] (default 0)",
152 << (uint16_t)params.m_transmissionMode);
156 m_uesTxMode[params.m_rnti] = params.m_transmissionMode;
160 dlHarqPrcStatus.resize(8, 0);
163 dlHarqProcessesTimer.resize(8, 0);
169 dlHarqRlcPdu.resize(2);
170 dlHarqRlcPdu.at(0).resize(8);
171 dlHarqRlcPdu.at(1).resize(8);
175 ulHarqPrcStatus.resize(8, 0);
183 (*it).second = params.m_transmissionMode;
193 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
220 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
225 if (((*it).first.m_rnti == params.m_rnti) &&
226 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
261 if ((*it).first.m_rnti == params.m_rnti)
285 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
295 (*it).second = params;
318 for (
int i = 0; i < 4; i++)
332 unsigned int lcActive = 0;
335 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
336 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
337 ((*it).second.m_rlcStatusPduSize > 0)))
341 if ((*it).first.m_rnti > rnti)
362 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
364 uint8_t i = (*it).second;
368 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
370 return (*itStat).second.at(i) == 0;
391 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
393 uint8_t i = (*it).second;
397 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
398 if ((*itStat).second.at(i) == 0)
401 (*itStat).second.at(i) = 1;
406 << rnti <<
" check before update with HarqProcessAvailability");
426 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
431 << (*itTimers).first);
433 (*itStat).second.at(i) = 0;
434 (*itTimers).second.at(i) = 0;
438 (*itTimers).second.at(i)++;
448 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
449 << (0xF & params.m_sfnSf));
460 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
461 std::vector<bool> rbgMap;
462 uint16_t rbgAllocatedNum = 0;
463 std::set<uint16_t> rntiAllocated;
467 for (
auto it = rbgMap.begin(); it != rbgMap.end(); it++)
482 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
486 std::vector<bool> ulRbMap;
489 uint8_t maxContinuousUlBandwidth = 0;
490 uint8_t tmpMinBandwidth = 0;
491 uint16_t ffrRbStartOffset = 0;
492 uint16_t tmpFfrRbStartOffset = 0;
495 for (
auto it = ulRbMap.begin(); it != ulRbMap.end(); it++)
499 if (tmpMinBandwidth > maxContinuousUlBandwidth)
501 maxContinuousUlBandwidth = tmpMinBandwidth;
502 ffrRbStartOffset = tmpFfrRbStartOffset;
508 if (tmpMinBandwidth == 0)
510 tmpFfrRbStartOffset = index;
517 if (tmpMinBandwidth > maxContinuousUlBandwidth)
519 maxContinuousUlBandwidth = tmpMinBandwidth;
520 ffrRbStartOffset = tmpFfrRbStartOffset;
524 uint16_t rbStart = 0;
525 rbStart = ffrRbStartOffset;
529 (*itRach).m_estimatedSize,
530 " Default UL Grant MCS does not allow to send RACH messages");
532 newRar.
m_rnti = (*itRach).m_rnti;
539 uint16_t tbSizeBits = 0;
541 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
542 (rbStart + rbLen < (ffrRbStartOffset + maxContinuousUlBandwidth)))
547 if (tbSizeBits < (*itRach).m_estimatedSize)
559 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
560 << rbStart <<
" rbLen " << rbLen <<
" MCS " <<
m_ulGrantMcs <<
" tbSize "
562 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
595 harqId = (*itProcId).second;
599 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
602 (*itDci).second.at(harqId) = uldci;
605 rbStart = rbStart + rbLen;
615 if (!params.m_dlInfoList.empty())
619 params.m_dlInfoList.begin(),
620 params.m_dlInfoList.end());
625 if (!params.m_dlInfoList.empty())
635 std::vector<DlInfoListElement_s> dlInfoListUntxed;
639 if (itRnti != rntiAllocated.end())
645 std::vector<bool> retx;
646 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
651 retx.push_back(
false);
660 if (retx.at(0) || retx.at(1))
665 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
674 if (dci.
m_rv.size() == 1)
686 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
690 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
693 (*it).second.at(harqId) = 0;
697 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
700 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
702 (*itRlcPdu).second.at(k).at(harqId).clear();
708 std::vector<int> dciRbg;
711 for (
int j = 0; j < 32; j++)
721 for (std::size_t j = 0; j < dciRbg.size(); j++)
723 if (rbgMap.at(dciRbg.at(j)))
733 for (std::size_t j = 0; j < dciRbg.size(); j++)
735 rbgMap.at(dciRbg.at(j)) =
true;
736 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
740 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
746 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
747 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
748 std::vector<bool> rbgMapCopy = rbgMap;
749 while ((j < dciRbg.size()) && (startRbg != rbgId))
751 if (!rbgMapCopy.at(rbgId))
753 rbgMapCopy.at(rbgId) =
true;
754 dciRbg.at(j) = rbgId;
757 rbgId = (rbgId + 1) % rbgNum;
759 if (j == dciRbg.size())
763 for (std::size_t k = 0; k < dciRbg.size(); k++)
765 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
770 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
776 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
784 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
786 for (std::size_t j = 0; j < nLayers; j++)
790 if (j >= dci.
m_ndi.size())
793 dci.
m_ndi.push_back(0);
794 dci.
m_rv.push_back(0);
795 dci.
m_mcs.push_back(0);
798 <<
" no txed (MIMO transition)");
804 (*itHarq).second.at(harqId).m_rv.at(j)++;
805 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
806 << (uint16_t)dci.
m_rv.at(j));
816 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
819 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
821 std::vector<RlcPduListElement_s> rlcPduListPerLc;
822 for (std::size_t j = 0; j < nLayers; j++)
826 if (j < dci.
m_ndi.size())
828 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
830 rlcPduListPerLc.push_back(
843 .m_logicalChannelIdentity;
845 rlcPduListPerLc.push_back(emptyElement);
849 if (!rlcPduListPerLc.empty())
856 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
861 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
863 (*itHarqTimer).second.at(harqId) = 0;
865 rntiAllocated.insert(rnti);
882 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
885 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
894 if (rbgAllocatedNum == rbgNum)
904 for (
int i = 0; i < rbgNum; i++)
906 NS_LOG_INFO(
this <<
" ALLOCATION for RBG " << i <<
" of " << rbgNum);
910 double rcqiMax = 0.0;
918 auto itRnti = rntiAllocated.find((*it).first);
922 if (itRnti != rntiAllocated.end())
925 << (uint16_t)(*it).first);
930 << (uint16_t)(*it).first);
938 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
941 std::vector<uint8_t> sbCqi;
944 sbCqi = std::vector<uint8_t>(nLayer, 1);
948 sbCqi = (*itCqi).second.m_higherLayerSelected.at(i).m_sbCqi;
950 uint8_t cqi1 = sbCqi.at(0);
952 if (sbCqi.size() > 1)
963 double achievableRate = 0.0;
965 for (uint8_t k = 0; k < nLayer; k++)
967 if (sbCqi.size() > k)
969 mcs =
m_amc->GetMcsFromCqi(sbCqi.at(k));
976 achievableRate += ((
m_amc->GetDlTbSizeFromMcs(mcs, rbgSize) / 8) /
980 double rcqi = achievableRate / (*it).second.lastAveragedThroughput;
982 <<
" achievableRate " << achievableRate <<
" avgThr "
983 << (*it).second.lastAveragedThroughput <<
" RCQI "
1002 rbgMap.at(i) =
true;
1003 auto itMap = allocationMap.find((*itMax).first);
1004 if (itMap == allocationMap.end())
1007 std::vector<uint16_t> tempMap;
1008 tempMap.push_back(i);
1009 allocationMap[(*itMax).first] = tempMap;
1013 (*itMap).second.push_back(i);
1015 NS_LOG_INFO(
this <<
" UE assigned " << (*itMax).first);
1023 (*itStats).second.lastTtiBytesTransmitted = 0;
1028 auto itMap = allocationMap.begin();
1029 while (itMap != allocationMap.end())
1033 newEl.
m_rnti = (*itMap).first;
1036 newDci.
m_rnti = (*itMap).first;
1044 lcActives = (uint16_t)65535;
1046 uint16_t RbgPerRnti = (*itMap).second.size();
1051 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
1054 std::vector<uint8_t> worstCqi(2, 15);
1057 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1059 if ((*itCqi).second.m_higherLayerSelected.size() > (*itMap).second.at(k))
1061 NS_LOG_INFO(
this <<
" RBG " << (*itMap).second.at(k) <<
" CQI "
1062 << (uint16_t)((*itCqi)
1063 .second.m_higherLayerSelected
1064 .at((*itMap).second.at(k))
1066 for (uint8_t j = 0; j < nLayer; j++)
1069 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1070 .m_sbCqi.size() > j)
1073 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1074 .m_sbCqi.at(j)) < worstCqi.at(j))
1078 .second.m_higherLayerSelected.at((*itMap).second.at(k))
1091 for (uint8_t j = 0; j < nLayer; j++)
1100 for (uint8_t j = 0; j < nLayer; j++)
1105 for (uint8_t j = 0; j < nLayer; j++)
1107 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" CQI selected "
1108 << (uint16_t)worstCqi.at(j));
1111 for (uint8_t j = 0; j < nLayer; j++)
1113 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1114 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RbgPerRnti * rbgSize) /
1117 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" MCS selected"
1118 <<
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1119 bytesTxed += tbSize;
1125 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1127 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
1128 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
1135 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
1136 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
1137 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
1138 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
1140 std::vector<RlcPduListElement_s> newRlcPduLe;
1141 for (uint8_t j = 0; j < nLayer; j++)
1147 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1148 newRlcPduLe.push_back(newRlcEl);
1158 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1161 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1166 if ((*itBufReq).first.m_rnti > (*itMap).first)
1171 for (uint8_t j = 0; j < nLayer; j++)
1173 newDci.
m_ndi.push_back(1);
1174 newDci.
m_rv.push_back(0);
1179 newEl.
m_dci = newDci;
1187 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1207 (*it).second.lastTtiBytesTransmitted = bytesTxed;
1208 NS_LOG_INFO(
this <<
" UE total bytes txed " << (*it).second.lastTtiBytesTransmitted);
1223 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTransmitted;
1226 (*itStats).second.lastAveragedThroughput =
1227 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1228 ((1.0 /
m_timeWindow) * (
double)((*itStats).second.lastTtiBytesTransmitted / 0.001));
1229 NS_LOG_INFO(
this <<
" UE total bytes " << (*itStats).second.totalBytesTransmitted);
1230 NS_LOG_INFO(
this <<
" UE average throughput " << (*itStats).second.lastAveragedThroughput);
1231 (*itStats).second.lastTtiBytesTransmitted = 0;
1253 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1259 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1265 params.m_cqiList.at(i).m_wbCqi.at(0);
1272 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1281 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1286 m_a30CqiRxed[rnti] = params.m_cqiList.at(i).m_sbMeasResult;
1292 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1307 auto itCqi =
m_ueCqi.find(rnti);
1317 unsigned int sinrNum = 0;
1320 double sinr = (*itCqi).second.at(i);
1327 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1329 (*itCqi).second.at(rb) = estimatedSinr;
1330 return estimatedSinr;
1338 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1339 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1346 std::vector<bool> rbMap;
1347 uint16_t rbAllocatedNum = 0;
1348 std::set<uint16_t> rntiAllocated;
1349 std::vector<uint16_t> rbgAllocationMap;
1359 for (
auto it = rbMap.begin(); it != rbMap.end(); it++)
1367 uint8_t minContinuousUlBandwidth =
m_ffrSapProvider->GetMinContinuousUlBandwidth();
1373 if (rbgAllocationMap.at(i) != 0)
1384 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1389 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1393 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1396 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1397 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1401 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1408 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1410 if ((*itStat).second.at(harqId) >= 3)
1412 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1430 rbgAllocationMap.at(j) = dci.
m_rnti;
1436 << (*itStat).second.at(harqId) + 1);
1440 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1445 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1446 (*itStat).second.at(harqId) = 0;
1447 (*itHarq).second.at((*itProcId).second) = dci;
1449 rntiAllocated.insert(dci.
m_rnti);
1453 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1454 << params.m_ulInfoList.at(i).m_rnti);
1459 std::map<uint16_t, uint32_t>::iterator it;
1464 auto itRnti = rntiAllocated.find((*it).first);
1466 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1485 uint16_t tempRbPerFlow = (ffrUlBandwidth) / (nflows + rntiAllocated.size());
1486 uint16_t rbPerFlow =
1487 (minContinuousUlBandwidth < tempRbPerFlow) ? minContinuousUlBandwidth : tempRbPerFlow;
1495 int rbAllocated = 0;
1518 auto itRnti = rntiAllocated.find((*it).first);
1519 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1522 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1546 uldci.
m_rnti = (*it).first;
1548 bool allocated =
false;
1550 while ((!allocated) && ((rbAllocated + rbPerFlow -
m_cschedCellConfig.m_ulBandwidth) < 1) &&
1555 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1570 NS_LOG_INFO(
this <<
"RNTI: " << (*it).first <<
" RB Allocated " << rbAllocated
1571 <<
" rbPerFlow " << rbPerFlow <<
" flows " << nflows);
1574 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1578 rbgAllocationMap.at(j) = (*it).first;
1580 rbAllocated += rbPerFlow;
1609 auto itCqi =
m_ueCqi.find((*it).first);
1620 "CQI of RNTI = " << (*it).first <<
" has expired");
1621 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1628 double sinr = (*itCqi).second.at(i);
1640 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1641 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1654 rbgAllocationMap.at(i) = 0;
1685 harqId = (*itProcId).second;
1689 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
1692 (*itDci).second.at(harqId) = uldci;
1697 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
1700 (*itStat).second.at(harqId) = 0;
1703 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
1705 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
1706 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
1707 << (uint16_t)harqId);
1713 (*itStats).second.lastTtiBytesTransmitted = uldci.
m_tbSize;
1717 NS_LOG_DEBUG(
this <<
" No Stats for this allocated UE");
1732 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
1738 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTransmitted;
1741 (*itStats).second.lastAveragedThroughput =
1742 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1743 ((1.0 /
m_timeWindow) * (
double)((*itStats).second.lastTtiBytesTransmitted / 0.001));
1744 NS_LOG_INFO(
this <<
" UE total bytes " << (*itStats).second.totalBytesTransmitted);
1745 NS_LOG_INFO(
this <<
" UE average throughput " << (*itStats).second.lastAveragedThroughput);
1746 (*itStats).second.lastTtiBytesTransmitted = 0;
1772 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
1784 for (uint8_t lcg = 0; lcg < 4; ++lcg)
1786 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
1790 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
1791 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
1801 (*it).second = buffer;
1838 switch (params.m_ulCqi.m_type)
1841 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
1842 <<
" subframe no. " << (0xF & params.m_sfnSf));
1848 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
1852 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
1856 std::vector<double> newCqi;
1861 newCqi.push_back(sinr);
1869 m_ueCqi[(*itMap).second.at(i)] = newCqi;
1876 (*itCqi).second.at(i) = sinr;
1877 NS_LOG_DEBUG(
this <<
" RNTI " << (*itMap).second.at(i) <<
" RB " << i <<
" SINR "
1889 NS_LOG_DEBUG(
this <<
" Collect SRS CQIs of Frame no. " << (params.m_sfnSf >> 4)
1890 <<
" subframe no. " << (0xF & params.m_sfnSf));
1893 NS_ASSERT(!params.m_vendorSpecificList.empty());
1894 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
1900 rnti = vsp->GetRnti();
1903 auto itCqi =
m_ueCqi.find(rnti);
1907 std::vector<double> newCqi;
1911 newCqi.push_back(sinr);
1912 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
1925 (*itCqi).second.at(j) = sinr;
1926 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
1938 NS_FATAL_ERROR(
"PfFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1953 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
1955 if ((*itP10).second == 0)
1960 " Does not find CQI report for user " << (*itP10).first);
1961 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
1978 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
1980 if ((*itA30).second == 0)
1985 " Does not find CQI report for user " << (*itA30).first);
1986 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
2007 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
2009 if ((*itUl).second == 0)
2012 auto itMap =
m_ueCqi.find((*itUl).first);
2014 " Does not find CQI report for user " << (*itUl).first);
2015 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
2016 (*itMap).second.clear();
2037 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
2038 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
2039 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
2040 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
2043 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
2045 (*it).second.m_rlcStatusPduSize = 0;
2047 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
2048 (size >= (*it).second.m_rlcRetransmissionQueueSize))
2050 (*it).second.m_rlcRetransmissionQueueSize = 0;
2052 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
2069 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
2071 (*it).second.m_rlcTransmissionQueueSize = 0;
2075 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
2081 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
2092 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
2093 if ((*it).second >= size)
2095 (*it).second -= size;
2104 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
2111 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
2113 params.m_rnti = rnti;
2114 params.m_transmissionMode = txMode;
static uint32_t BsrId2BufferSize(uint8_t val)
Convert BSR ID to buffer size.
FfMacCschedSapUser class.
FfMacScheduler()
constructor
UlCqiFilter_t m_ulCqiFilter
UL CQI filter.
static double fpS11dot3toDouble(uint16_t val)
Convert from fixed point S11.3 notation to double.
Service Access Point (SAP) offered by the Frequency Reuse algorithm instance to the MAC Scheduler ins...
Service Access Point (SAP) offered by the eNodeB RRC instance to the Frequency Reuse algorithm instan...
Template for the implementation of the LteFfrSapUser as a member of an owner class of type C to which...
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current process ID.
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
CSched cell config request.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
CSched cell config.
static TypeId GetTypeId()
Get the type ID.
~PfFfMacScheduler() override
Destructor.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request.
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SINR.
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
transmission mode configuration update
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request.
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request.
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request.
LteFfrSapUser * GetLteFfrSapUser() override
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request.
void SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
set the user part of the FfMacSchedSap that this Scheduler will interact with.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
FfMacSchedSapProvider * m_schedSapProvider
Sched SAP provider.
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
friend class MemberCschedSapProvider< PfFfMacScheduler >
allow MemberCschedSapProvider<PfFfMacScheduler> class friend access
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request.
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request.
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RCL buffer info.
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU list buffer.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
void DoDispose() override
Destructor implementation.
FfMacCschedSapUser * m_cschedSapUser
CSched SAP user.
unsigned int LcActivePerFlow(uint16_t rnti)
LC active per flow.
void RefreshDlCqiMaps()
Refresh DL CQI maps.
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
friend class MemberSchedSapProvider< PfFfMacScheduler >
allow MemberSchedSapProvider<PfFfMacScheduler> class friend access
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
std::map< uint16_t, pfsFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request.
double m_timeWindow
time window
std::map< uint16_t, pfsFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request.
void RefreshUlCqiMaps()
Refresh UL CQI maps.
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
std::map< uint16_t, std::vector< uint16_t > > m_allocationMaps
Map of previous allocated UE per RBG (used to retrieve info from UL-CQI)
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
set the user part of the FfMacCschedSap that this Scheduler will interact with.
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RCL buffer info.
uint32_t m_cqiTimersThreshold
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
std::vector< RachListElement_s > m_rachList
RACH list.
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set the Provider part of the LteFfrSap that this Scheduler will interact with.
PfFfMacScheduler()
Constructor.
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request.
int GetRbgSize(int dlbandwidth)
Get RBG size.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
FfMacSchedSapUser * m_schedSapUser
Sched SAP user.
Smart pointer class similar to boost::intrusive_ptr.
static Time Now()
Return the current simulation virtual time.
static uint8_t TxMode2LayerNum(uint8_t txMode)
Transmit mode 2 layer number.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Hold an unsigned integer type.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeChecker > MakeBooleanChecker()
static const int PfType0AllocationRbg[4]
PF type 0 allocation RBG (see table 7.1.6.1-1 of 36.213)
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector.
Ptr< const AttributeChecker > MakeUintegerChecker()
constexpr double NO_SINR
Value for SINR outside the range defined by FF-API, used to indicate that there is no CQI for this el...
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
std::vector< uint8_t > UlHarqProcessesStatus_t
UL HARQ process status vector.
std::vector< uint8_t > DlHarqProcessesStatus_t
DL HARQ process status vector.
Ptr< T1 > DynamicCast(const Ptr< T2 > &p)
Cast a Ptr.
std::vector< DlDciListElement_s > DlHarqProcessesDciBuffer_t
DL HARQ process DCI buffer vector.
constexpr uint32_t HARQ_DL_TIMEOUT
HARQ DL timeout.
constexpr uint32_t HARQ_PROC_NUM
Number of HARQ processes.
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
std::vector< RlcPduList_t > DlHarqRlcPduListBuffer_t
Vector of the 8 HARQ processes per UE.
std::vector< UlDciListElement_s > UlHarqProcessesDciBuffer_t
UL HARQ process DCI buffer vector.
See section 4.3.8 buildDataListElement.
std::vector< std::vector< struct RlcPduListElement_s > > m_rlcPduList
RLC PDU list.
struct DlDciListElement_s m_dci
DCI.
See section 4.3.10 buildRARListElement.
See section 4.3.1 dlDciListElement.
std::vector< uint8_t > m_ndi
New data indicator.
uint8_t m_harqProcess
HARQ process.
uint32_t m_rbBitmap
RB bitmap.
std::vector< uint8_t > m_mcs
MCS.
uint8_t m_resAlloc
The type of resource allocation.
std::vector< uint16_t > m_tbsSize
The TBs size.
std::vector< uint8_t > m_rv
Redundancy version.
uint8_t m_tpc
Tx power control command.
Parameters of the API primitives.
Parameters of the CSCHED_LC_CONFIG_REQ primitive.
Parameters of the CSCHED_LC_RELEASE_REQ primitive.
Parameters of the CSCHED_UE_CONFIG_REQ primitive.
Parameters of the CSCHED_UE_RELEASE_REQ primitive.
Parameters of the CSCHED_UE_CONFIG_CNF primitive.
Parameters of the CSCHED_UE_CONFIG_UPDATE_IND primitive.
Parameters of the SCHED_DL_CQI_INFO_REQ primitive.
Parameters of the SCHED_DL_MAC_BUFFER_REQ primitive.
Parameters of the SCHED_DL_PAGING_BUFFER_REQ primitive.
Parameters of the SCHED_DL_RACH_INFO_REQ primitive.
Parameters of the API primitives.
Parameters of the SCHED_DL_TRIGGER_REQ primitive.
Parameters of the SCHED_UL_CQI_INFO_REQ primitive.
Parameters of the SCHED_UL_MAC_CTRL_INFO_REQ primitive.
Parameters of the SCHED_UL_NOISE_INTERFERENCE_REQ primitive.
Parameters of the SCHED_UL_SR_INFO_REQ primitive.
Parameters of the SCHED_UL_TRIGGER_REQ primitive.
Parameters of the API primitives.
std::vector< BuildDataListElement_s > m_buildDataList
build data list
std::vector< BuildRarListElement_s > m_buildRarList
build rar list
uint8_t m_nrOfPdcchOfdmSymbols
number of PDCCH OFDM symbols
Parameters of the SCHED_UL_CONFIG_IND primitive.
std::vector< UlDciListElement_s > m_dciList
DCI list.
See section 4.3.9 rlcPDU_ListElement.
uint8_t m_logicalChannelIdentity
logical channel identity
See section 4.3.2 ulDciListElement.
int8_t m_pdcchPowerOffset
CCH power offset.
int8_t m_tpc
Tx power control command.
uint8_t m_dai
DL assignment index.
uint8_t m_cceIndex
Control Channel Element index.
uint8_t m_ulIndex
UL index.
uint8_t m_ueTxAntennaSelection
UE antenna selection.
bool m_cqiRequest
CQI request.
uint8_t m_freqHopping
freq hopping
uint8_t m_aggrLevel
The aggregation level.
int8_t m_tpc
Tx power control command.
bool m_cqiRequest
CQI request?
unsigned long totalBytesTransmitted
total bytes transmitted
unsigned int lastTtiBytesTransmitted
last total bytes transmitted
Time flowStart
flow start time
double lastAveragedThroughput
last averaged throughput