15#include "ns3/boolean.h"
16#include "ns3/integer.h"
19#include "ns3/pointer.h"
20#include "ns3/simulator.h"
78 TypeId(
"ns3::TdTbfqFfMacScheduler")
82 .AddAttribute(
"CqiTimerThreshold",
83 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
87 .AddAttribute(
"DebtLimit",
88 "Flow debt limit (default -625000 bytes)",
92 .AddAttribute(
"CreditLimit",
93 "Flow credit limit (default 625000 bytes)",
97 .AddAttribute(
"TokenPoolSize",
98 "The maximum value of flow token pool (default 1 bytes)",
102 .AddAttribute(
"CreditableThreshold",
103 "Threshold of flow credit (default 0 bytes)",
108 .AddAttribute(
"HarqEnabled",
109 "Activate/Deactivate the HARQ [by default is active].",
113 .AddAttribute(
"UlGrantMcs",
114 "The MCS of the UL grant, must be [0..15] (default 0)",
175 << (uint16_t)params.m_transmissionMode);
179 m_uesTxMode[params.m_rnti] = params.m_transmissionMode;
183 dlHarqPrcStatus.resize(8, 0);
186 dlHarqProcessesTimer.resize(8, 0);
192 dlHarqRlcPdu.resize(2);
193 dlHarqRlcPdu.at(0).resize(8);
194 dlHarqRlcPdu.at(1).resize(8);
198 ulHarqPrcStatus.resize(8, 0);
206 (*it).second = params.m_transmissionMode;
216 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
222 uint64_t mbrDlInBytes =
223 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateDl / 8;
224 uint64_t mbrUlInBytes =
225 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateUl / 8;
253 uint64_t mbrDlInBytes =
254 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateDl / 8;
255 uint64_t mbrUlInBytes =
256 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateUl / 8;
257 m_flowStatsDl[(*it).first].tokenGenerationRate = mbrDlInBytes;
258 m_flowStatsUl[(*it).first].tokenGenerationRate = mbrUlInBytes;
268 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
273 if (((*it).first.m_rnti == params.m_rnti) &&
274 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
309 if ((*it).first.m_rnti == params.m_rnti)
333 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
343 (*it).second = params;
366 for (
int i = 0; i < 4; i++)
380 unsigned int lcActive = 0;
383 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
384 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
385 ((*it).second.m_rlcStatusPduSize > 0)))
389 if ((*it).first.m_rnti > rnti)
410 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
412 uint8_t i = (*it).second;
416 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
418 return (*itStat).second.at(i) == 0;
439 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
441 uint8_t i = (*it).second;
445 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
446 if ((*itStat).second.at(i) == 0)
449 (*itStat).second.at(i) = 1;
454 << rnti <<
" check before update with HarqProcessAvailability");
474 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
479 << (*itTimers).first);
481 (*itStat).second.at(i) = 0;
482 (*itTimers).second.at(i) = 0;
486 (*itTimers).second.at(i)++;
496 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
497 << (0xF & params.m_sfnSf));
508 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
509 std::vector<bool> rbgMap;
510 uint16_t rbgAllocatedNum = 0;
511 std::set<uint16_t> rntiAllocated;
515 for (
auto it = rbgMap.begin(); it != rbgMap.end(); it++)
530 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
534 std::vector<bool> ulRbMap;
537 uint8_t maxContinuousUlBandwidth = 0;
538 uint8_t tmpMinBandwidth = 0;
539 uint16_t ffrRbStartOffset = 0;
540 uint16_t tmpFfrRbStartOffset = 0;
543 for (
auto it = ulRbMap.begin(); it != ulRbMap.end(); it++)
547 if (tmpMinBandwidth > maxContinuousUlBandwidth)
549 maxContinuousUlBandwidth = tmpMinBandwidth;
550 ffrRbStartOffset = tmpFfrRbStartOffset;
556 if (tmpMinBandwidth == 0)
558 tmpFfrRbStartOffset = index;
565 if (tmpMinBandwidth > maxContinuousUlBandwidth)
567 maxContinuousUlBandwidth = tmpMinBandwidth;
568 ffrRbStartOffset = tmpFfrRbStartOffset;
572 uint16_t rbStart = 0;
573 rbStart = ffrRbStartOffset;
577 (*itRach).m_estimatedSize,
578 " Default UL Grant MCS does not allow to send RACH messages");
580 newRar.
m_rnti = (*itRach).m_rnti;
587 uint16_t tbSizeBits = 0;
589 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
590 (rbStart + rbLen < (ffrRbStartOffset + maxContinuousUlBandwidth)))
595 if (tbSizeBits < (*itRach).m_estimatedSize)
607 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
608 << rbStart <<
" rbLen " << rbLen <<
" MCS " <<
m_ulGrantMcs <<
" tbSize "
610 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
643 harqId = (*itProcId).second;
647 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
650 (*itDci).second.at(harqId) = uldci;
653 rbStart = rbStart + rbLen;
663 if (!params.m_dlInfoList.empty())
667 params.m_dlInfoList.begin(),
668 params.m_dlInfoList.end());
673 if (!params.m_dlInfoList.empty())
683 std::vector<DlInfoListElement_s> dlInfoListUntxed;
687 if (itRnti != rntiAllocated.end())
693 std::vector<bool> retx;
694 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
699 retx.emplace_back(
false);
708 if (retx.at(0) || retx.at(1))
713 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
722 if (dci.
m_rv.size() == 1)
734 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
738 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
741 (*it).second.at(harqId) = 0;
745 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
748 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
750 (*itRlcPdu).second.at(k).at(harqId).clear();
756 std::vector<int> dciRbg;
759 for (
int j = 0; j < 32; j++)
769 for (std::size_t j = 0; j < dciRbg.size(); j++)
771 if (rbgMap.at(dciRbg.at(j)))
781 for (std::size_t j = 0; j < dciRbg.size(); j++)
783 rbgMap.at(dciRbg.at(j)) =
true;
784 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
788 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
794 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
795 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
796 std::vector<bool> rbgMapCopy = rbgMap;
797 while ((j < dciRbg.size()) && (startRbg != rbgId))
799 if (!rbgMapCopy.at(rbgId))
801 rbgMapCopy.at(rbgId) =
true;
802 dciRbg.at(j) = rbgId;
805 rbgId = (rbgId + 1) % rbgNum;
807 if (j == dciRbg.size())
811 for (std::size_t k = 0; k < dciRbg.size(); k++)
813 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
818 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
824 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
832 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
834 for (std::size_t j = 0; j < nLayers; j++)
838 if (j >= dci.
m_ndi.size())
841 dci.
m_ndi.push_back(0);
842 dci.
m_rv.push_back(0);
843 dci.
m_mcs.push_back(0);
846 <<
" no txed (MIMO transition)");
852 (*itHarq).second.at(harqId).m_rv.at(j)++;
853 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
854 << (uint16_t)dci.
m_rv.at(j));
864 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
867 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
869 std::vector<RlcPduListElement_s> rlcPduListPerLc;
870 for (std::size_t j = 0; j < nLayers; j++)
874 if (j < dci.
m_ndi.size())
876 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
878 rlcPduListPerLc.push_back(
891 .m_logicalChannelIdentity;
893 rlcPduListPerLc.push_back(emptyElement);
897 if (!rlcPduListPerLc.empty())
904 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
909 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
911 (*itHarqTimer).second.at(harqId) = 0;
913 rntiAllocated.insert(rnti);
930 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
933 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
942 if (rbgAllocatedNum == rbgNum)
955 if ((*itStats).second.tokenGenerationRate / 1000 + (*itStats).second.tokenPoolSize >
956 (*itStats).second.maxTokenPoolSize)
958 (*itStats).second.counter +=
959 (*itStats).second.tokenGenerationRate / 1000 -
960 ((*itStats).second.maxTokenPoolSize - (*itStats).second.tokenPoolSize);
961 (*itStats).second.tokenPoolSize = (*itStats).second.maxTokenPoolSize;
962 bankSize += (*itStats).second.tokenGenerationRate / 1000 -
963 ((*itStats).second.maxTokenPoolSize - (*itStats).second.tokenPoolSize);
967 (*itStats).second.tokenPoolSize += (*itStats).second.tokenGenerationRate / 1000;
973 double metricMax = 0.0;
974 bool firstRnti =
true;
977 auto itRnti = rntiAllocated.find((*it).first);
981 if (itRnti != rntiAllocated.end())
983 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ tx" << (uint16_t)(*it).first);
987 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ id" << (uint16_t)(*it).first);
997 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1002 for (
int k = 0; k < rbgNum; k++)
1004 for (uint8_t j = 0; j < nLayer; j++)
1012 cqiSum += (*itCqi).second.m_higherLayerSelected.at(k).m_sbCqi.at(j);
1019 NS_LOG_INFO(
"Skip this flow, CQI==0, rnti:" << (*it).first);
1031 (((
double)(*it).second.counter) / ((
double)(*it).second.tokenGenerationRate));
1040 if (metric > metricMax)
1056 std::vector<uint16_t> tempMap;
1057 for (
int i = 0; i < rbgNum; i++)
1069 tempMap.push_back(i);
1070 rbgMap.at(i) =
true;
1072 if (!tempMap.empty())
1074 allocationMap[(*itMax).first] = tempMap;
1080 auto itMap = allocationMap.begin();
1081 while (itMap != allocationMap.end())
1085 newEl.
m_rnti = (*itMap).first;
1088 newDci.
m_rnti = (*itMap).first;
1096 lcActives = (uint16_t)65535;
1098 uint16_t RbgPerRnti = (*itMap).second.size();
1103 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
1106 std::vector<uint8_t> worstCqi(2, 15);
1109 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1111 if ((*itCqi).second.m_higherLayerSelected.size() > (*itMap).second.at(k))
1113 for (uint8_t j = 0; j < nLayer; j++)
1116 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1117 .m_sbCqi.size() > j)
1120 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1121 .m_sbCqi.at(j)) < worstCqi.at(j))
1125 .second.m_higherLayerSelected.at((*itMap).second.at(k))
1138 for (uint8_t j = 0; j < nLayer; j++)
1147 for (uint8_t j = 0; j < nLayer; j++)
1153 for (uint8_t j = 0; j < nLayer; j++)
1155 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1156 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RbgPerRnti * rbgSize) /
1159 bytesTxed += tbSize;
1165 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1167 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
1168 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
1175 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
1176 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
1177 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
1178 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
1180 std::vector<RlcPduListElement_s> newRlcPduLe;
1181 for (uint8_t j = 0; j < nLayer; j++)
1187 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1188 newRlcPduLe.push_back(newRlcEl);
1198 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1201 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1206 if ((*itBufReq).first.m_rnti > (*itMap).first)
1211 for (uint8_t j = 0; j < nLayer; j++)
1213 newDci.
m_ndi.push_back(1);
1214 newDci.
m_rv.push_back(0);
1219 newEl.
m_dci = newDci;
1227 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1241 if (bytesTxed <= (*itMax).second.tokenPoolSize)
1243 (*itMax).second.tokenPoolSize -= bytesTxed;
1247 (*itMax).second.counter =
1248 (*itMax).second.counter - (bytesTxed - (*itMax).second.tokenPoolSize);
1249 (*itMax).second.tokenPoolSize = 0;
1250 if (
bankSize <= (bytesTxed - (*itMax).second.tokenPoolSize))
1287 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1293 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1299 params.m_cqiList.at(i).m_wbCqi.at(0);
1306 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1315 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1320 m_a30CqiRxed[rnti] = params.m_cqiList.at(i).m_sbMeasResult;
1326 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1341 auto itCqi =
m_ueCqi.find(rnti);
1351 unsigned int sinrNum = 0;
1354 double sinr = (*itCqi).second.at(i);
1361 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1363 (*itCqi).second.at(rb) = estimatedSinr;
1364 return estimatedSinr;
1372 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1373 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1380 std::vector<bool> rbMap;
1381 uint16_t rbAllocatedNum = 0;
1382 std::set<uint16_t> rntiAllocated;
1383 std::vector<uint16_t> rbgAllocationMap;
1394 for (
auto it = rbMap.begin(); it != rbMap.end(); it++)
1402 uint8_t minContinuousUlBandwidth =
m_ffrSapProvider->GetMinContinuousUlBandwidth();
1408 if (rbgAllocationMap.at(i) != 0)
1418 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1423 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1427 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1430 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1431 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1435 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1442 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1444 if ((*itStat).second.at(harqId) >= 3)
1446 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1464 rbgAllocationMap.at(j) = dci.
m_rnti;
1470 << (*itStat).second.at(harqId) + 1);
1474 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1479 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1480 (*itStat).second.at(harqId) = 0;
1481 (*itHarq).second.at((*itProcId).second) = dci;
1483 rntiAllocated.insert(dci.
m_rnti);
1487 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1488 << params.m_ulInfoList.at(i).m_rnti);
1493 std::map<uint16_t, uint32_t>::iterator it;
1498 auto itRnti = rntiAllocated.find((*it).first);
1500 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1519 uint16_t tempRbPerFlow = (ffrUlBandwidth) / (nflows + rntiAllocated.size());
1520 uint16_t rbPerFlow =
1521 (minContinuousUlBandwidth < tempRbPerFlow) ? minContinuousUlBandwidth : tempRbPerFlow;
1528 int rbAllocated = 0;
1551 auto itRnti = rntiAllocated.find((*it).first);
1552 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1555 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1579 uldci.
m_rnti = (*it).first;
1581 bool allocated =
false;
1582 NS_LOG_INFO(
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow
1583 <<
" flows " << nflows);
1584 while ((!allocated) && ((rbAllocated + rbPerFlow -
m_cschedCellConfig.m_ulBandwidth) < 1) &&
1589 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1604 NS_LOG_INFO(
this <<
"RNTI: " << (*it).first <<
" RB Allocated " << rbAllocated
1605 <<
" rbPerFlow " << rbPerFlow <<
" flows " << nflows);
1608 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1612 rbgAllocationMap.at(j) = (*it).first;
1614 rbAllocated += rbPerFlow;
1643 auto itCqi =
m_ueCqi.find((*it).first);
1654 "CQI of RNTI = " << (*it).first <<
" has expired");
1655 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1662 double sinr = (*itCqi).second.at(i);
1674 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1675 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1688 rbgAllocationMap.at(i) = 0;
1719 harqId = (*itProcId).second;
1723 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
1726 (*itDci).second.at(harqId) = uldci;
1731 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
1734 (*itStat).second.at(harqId) = 0;
1737 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
1739 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
1740 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
1741 << (uint16_t)harqId);
1755 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
1781 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
1793 for (uint8_t lcg = 0; lcg < 4; ++lcg)
1795 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
1799 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
1800 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
1810 (*it).second = buffer;
1844 switch (params.m_ulCqi.m_type)
1847 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
1848 <<
" subframe no. " << (0xF & params.m_sfnSf));
1854 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
1858 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
1862 std::vector<double> newCqi;
1867 newCqi.push_back(sinr);
1875 m_ueCqi[(*itMap).second.at(i)] = newCqi;
1882 (*itCqi).second.at(i) = sinr;
1883 NS_LOG_DEBUG(
this <<
" RNTI " << (*itMap).second.at(i) <<
" RB " << i <<
" SINR "
1897 NS_ASSERT(!params.m_vendorSpecificList.empty());
1898 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
1904 rnti = vsp->GetRnti();
1907 auto itCqi =
m_ueCqi.find(rnti);
1911 std::vector<double> newCqi;
1915 newCqi.push_back(sinr);
1916 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
1929 (*itCqi).second.at(j) = sinr;
1930 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
1942 NS_FATAL_ERROR(
"TdTbfqFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1957 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
1959 if ((*itP10).second == 0)
1964 " Does not find CQI report for user " << (*itP10).first);
1965 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
1982 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
1984 if ((*itA30).second == 0)
1989 " Does not find CQI report for user " << (*itA30).first);
1990 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
2011 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
2013 if ((*itUl).second == 0)
2016 auto itMap =
m_ueCqi.find((*itUl).first);
2018 " Does not find CQI report for user " << (*itUl).first);
2019 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
2020 (*itMap).second.clear();
2041 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
2042 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
2043 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
2044 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
2047 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
2049 (*it).second.m_rlcStatusPduSize = 0;
2051 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
2052 (size >= (*it).second.m_rlcRetransmissionQueueSize))
2054 (*it).second.m_rlcRetransmissionQueueSize = 0;
2056 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
2073 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
2075 (*it).second.m_rlcTransmissionQueueSize = 0;
2079 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
2085 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
2096 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
2097 if ((*it).second >= size)
2099 (*it).second -= size;
2108 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
2115 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
2117 params.m_rnti = rnti;
2118 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.
Hold a signed integer type.
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...
Smart pointer class similar to boost::intrusive_ptr.
static Time Now()
Return the current simulation virtual time.
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set the Provider part of the LteFfrSap that this Scheduler will interact with.
static TypeId GetTypeId()
Get the type ID.
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info function.
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RLC buffer info function.
~TdTbfqFfMacScheduler() override
Destructor.
FfMacSchedSapProvider * m_schedSapProvider
Sched SAP provider.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
CSched cell config.
FfMacSchedSapUser * m_schedSapUser
A=Sched SAP user.
unsigned int LcActivePerFlow(uint16_t rnti)
LC active flow size.
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU list buffer.
uint32_t m_cqiTimersThreshold
uint32_t m_creditLimit
flow credit limit (byte)
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request.
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request.
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
int GetRbgSize(int dlbandwidth)
Get RBG size.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request.
void RefreshDlCqiMaps()
Refresh DL CQI maps function.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
uint32_t m_creditableThreshold
threshold of flow credit
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request.
std::map< uint16_t, tdtbfqsFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
LteFfrSapUser * GetLteFfrSapUser() override
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request.
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmission mde configuration update function.
friend class MemberCschedSapProvider< TdTbfqFfMacScheduler >
allow MemberCschedSapProvider<TdTbfqFfMacScheduler> class friend access
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
void RefreshUlCqiMaps()
Refresh UL CQI maps function.
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request.
void SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
set the user part of the FfMacSchedSap that this Scheduler will interact with.
int m_debtLimit
flow debt limit (byte)
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SINR function.
std::vector< RachListElement_s > m_rachList
RACH list.
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request.
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request.
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request.
friend class MemberSchedSapProvider< TdTbfqFfMacScheduler >
allow MemberSchedSapProvider<TdTbfqFfMacScheduler> class friend access
uint32_t m_tokenPoolSize
maximum size of token pool (byte)
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request.
FfMacCschedSapUser * m_cschedSapUser
CSched SAP user.
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
void DoDispose() override
Destructor implementation.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current process ID.
std::map< uint16_t, std::vector< uint16_t > > m_allocationMaps
Map of previous allocated UE per RBG (used to retrieve info from UL-CQI)
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
TdTbfqFfMacScheduler()
Constructor.
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
set the user part of the FfMacCschedSap that this Scheduler will interact with.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request.
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
CSched cell config request.
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request.
std::map< uint16_t, tdtbfqsFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
uint64_t bankSize
the number of bytes in token bank
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
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()
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector.
Ptr< const AttributeChecker > MakeIntegerChecker()
Ptr< const AttributeAccessor > MakeIntegerAccessor(T1 a1)
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...
static const int TdTbfqType0AllocationRbg[4]
TDTBFQ type 0 allocation RBG (see table 7.1.6.1-1 of 36.213)
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?
uint32_t tokenPoolSize
current size of token pool (byte)
int debtLimit
counter threshold that the flow cannot further borrow tokens from bank
uint32_t maxTokenPoolSize
maximum size of token pool (byte)
int counter
the number of token borrow or given to token bank
uint32_t creditableThreshold
the flow cannot borrow token from bank until the number of token it has deposited to bank reaches thi...
uint64_t packetArrivalRate
packet arrival rate( byte/s)
uint64_t tokenGenerationRate
token generation rate ( byte/s )
Time flowStart
flow start time
uint32_t burstCredit
the maximum number of tokens connection i can borrow from the bank each time