15#include <ns3/boolean.h>
18#include <ns3/pointer.h>
19#include <ns3/simulator.h>
40 : m_cschedSapUser(nullptr),
41 m_schedSapUser(nullptr),
73 TypeId(
"ns3::TtaFfMacScheduler")
77 .AddAttribute(
"CqiTimerThreshold",
78 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
82 .AddAttribute(
"HarqEnabled",
83 "Activate/Deactivate the HARQ [by default is active].",
87 .AddAttribute(
"UlGrantMcs",
88 "The MCS of the UL grant, must be [0..15] (default 0)",
149 << (uint16_t)params.m_transmissionMode);
153 m_uesTxMode[params.m_rnti] = params.m_transmissionMode;
157 dlHarqPrcStatus.resize(8, 0);
160 dlHarqProcessesTimer.resize(8, 0);
166 dlHarqRlcPdu.resize(2);
167 dlHarqRlcPdu.at(0).resize(8);
168 dlHarqRlcPdu.at(1).resize(8);
172 ulHarqPrcStatus.resize(8, 0);
180 (*it).second = params.m_transmissionMode;
190 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
207 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
212 if (((*it).first.m_rnti == params.m_rnti) &&
213 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
248 if ((*it).first.m_rnti == params.m_rnti)
272 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
282 (*it).second = params;
305 for (
int i = 0; i < 4; i++)
319 unsigned int lcActive = 0;
322 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
323 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
324 ((*it).second.m_rlcStatusPduSize > 0)))
328 if ((*it).first.m_rnti > rnti)
349 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
351 uint8_t i = (*it).second;
355 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
357 return (*itStat).second.at(i) == 0;
378 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
380 uint8_t i = (*it).second;
384 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
385 if ((*itStat).second.at(i) == 0)
388 (*itStat).second.at(i) = 1;
393 << rnti <<
" check before update with HarqProcessAvailability");
413 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
418 << (*itTimers).first);
420 (*itStat).second.at(i) = 0;
421 (*itTimers).second.at(i) = 0;
425 (*itTimers).second.at(i)++;
435 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
436 << (0xF & params.m_sfnSf));
447 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
448 std::vector<bool> rbgMap;
449 uint16_t rbgAllocatedNum = 0;
450 std::set<uint16_t> rntiAllocated;
459 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
464 uint16_t rbStart = 0;
468 (*itRach).m_estimatedSize,
469 " Default UL Grant MCS does not allow to send RACH messages");
471 newRar.
m_rnti = (*itRach).m_rnti;
478 uint16_t tbSizeBits = 0;
480 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
486 if (tbSizeBits < (*itRach).m_estimatedSize)
498 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
499 << rbStart <<
" rbLen " << rbLen <<
" MCS " <<
m_ulGrantMcs <<
" tbSize "
501 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
534 harqId = (*itProcId).second;
538 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
541 (*itDci).second.at(harqId) = uldci;
544 rbStart = rbStart + rbLen;
554 if (!params.m_dlInfoList.empty())
558 params.m_dlInfoList.begin(),
559 params.m_dlInfoList.end());
564 if (!params.m_dlInfoList.empty())
574 std::vector<DlInfoListElement_s> dlInfoListUntxed;
578 if (itRnti != rntiAllocated.end())
584 std::vector<bool> retx;
585 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
590 retx.push_back(
false);
599 if (retx.at(0) || retx.at(1))
604 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
613 if (dci.
m_rv.size() == 1)
625 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
629 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
632 (*it).second.at(harqId) = 0;
636 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
639 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
641 (*itRlcPdu).second.at(k).at(harqId).clear();
647 std::vector<int> dciRbg;
650 for (
int j = 0; j < 32; j++)
660 for (std::size_t j = 0; j < dciRbg.size(); j++)
662 if (rbgMap.at(dciRbg.at(j)))
672 for (std::size_t j = 0; j < dciRbg.size(); j++)
674 rbgMap.at(dciRbg.at(j)) =
true;
675 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
679 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
685 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
686 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
687 std::vector<bool> rbgMapCopy = rbgMap;
688 while ((j < dciRbg.size()) && (startRbg != rbgId))
690 if (!rbgMapCopy.at(rbgId))
692 rbgMapCopy.at(rbgId) =
true;
693 dciRbg.at(j) = rbgId;
696 rbgId = (rbgId + 1) % rbgNum;
698 if (j == dciRbg.size())
702 for (std::size_t k = 0; k < dciRbg.size(); k++)
704 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
709 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
715 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
723 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
725 for (std::size_t j = 0; j < nLayers; j++)
729 if (j >= dci.
m_ndi.size())
732 dci.
m_ndi.push_back(0);
733 dci.
m_rv.push_back(0);
734 dci.
m_mcs.push_back(0);
737 <<
" no txed (MIMO transition)");
743 (*itHarq).second.at(harqId).m_rv.at(j)++;
744 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
745 << (uint16_t)dci.
m_rv.at(j));
755 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
758 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
760 std::vector<RlcPduListElement_s> rlcPduListPerLc;
761 for (std::size_t j = 0; j < nLayers; j++)
765 if (j < dci.
m_ndi.size())
767 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
769 rlcPduListPerLc.push_back(
782 .m_logicalChannelIdentity;
784 rlcPduListPerLc.push_back(emptyElement);
788 if (!rlcPduListPerLc.empty())
795 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
800 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
802 (*itHarqTimer).second.at(harqId) = 0;
804 rntiAllocated.insert(rnti);
821 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
824 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
833 if (rbgAllocatedNum == rbgNum)
843 for (
int i = 0; i < rbgNum; i++)
845 NS_LOG_INFO(
this <<
" ALLOCATION for RBG " << i <<
" of " << rbgNum);
849 double rcqiMax = 0.0;
852 auto itRnti = rntiAllocated.find(*it);
856 if (itRnti != rntiAllocated.end())
858 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ tx" << (uint16_t)(*it));
862 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ id" << (uint16_t)(*it));
877 std::vector<uint8_t> sbCqi;
880 sbCqi = std::vector<uint8_t>(nLayer, 1);
884 sbCqi = (*itSbCqi).second.m_higherLayerSelected.at(i).m_sbCqi;
890 wbCqi = (*itWbCqi).second;
897 uint8_t cqi1 = sbCqi.at(0);
899 if (sbCqi.size() > 1)
909 double achievableSbRate = 0.0;
910 double achievableWbRate = 0.0;
913 for (uint8_t k = 0; k < nLayer; k++)
915 if (sbCqi.size() > k)
917 sbMcs =
m_amc->GetMcsFromCqi(sbCqi.at(k));
924 achievableSbRate += ((
m_amc->GetDlTbSizeFromMcs(sbMcs, rbgSize) / 8) /
926 wbMcs =
m_amc->GetMcsFromCqi(wbCqi);
927 achievableWbRate += ((
m_amc->GetDlTbSizeFromMcs(wbMcs, rbgSize) / 8) /
931 double metric = achievableSbRate / achievableWbRate;
933 if (metric > rcqiMax)
951 auto itMap = allocationMap.find(*itMax);
952 if (itMap == allocationMap.end())
955 std::vector<uint16_t> tempMap;
956 tempMap.push_back(i);
957 allocationMap[(*itMax)] = tempMap;
961 (*itMap).second.push_back(i);
970 auto itMap = allocationMap.begin();
971 while (itMap != allocationMap.end())
975 newEl.
m_rnti = (*itMap).first;
978 newDci.
m_rnti = (*itMap).first;
986 lcActives = (uint16_t)65535;
988 uint16_t RbgPerRnti = (*itMap).second.size();
993 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
996 std::vector<uint8_t> worstCqi(2, 15);
999 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1001 if ((*itCqi).second.m_higherLayerSelected.size() > (*itMap).second.at(k))
1003 NS_LOG_INFO(
this <<
" RBG " << (*itMap).second.at(k) <<
" CQI "
1004 << (uint16_t)((*itCqi)
1005 .second.m_higherLayerSelected
1006 .at((*itMap).second.at(k))
1008 for (uint8_t j = 0; j < nLayer; j++)
1011 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1012 .m_sbCqi.size() > j)
1015 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1016 .m_sbCqi.at(j)) < worstCqi.at(j))
1020 .second.m_higherLayerSelected.at((*itMap).second.at(k))
1033 for (uint8_t j = 0; j < nLayer; j++)
1042 for (uint8_t j = 0; j < nLayer; j++)
1047 for (uint8_t j = 0; j < nLayer; j++)
1049 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" CQI selected "
1050 << (uint16_t)worstCqi.at(j));
1052 for (uint8_t j = 0; j < nLayer; j++)
1054 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1055 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RbgPerRnti * rbgSize) /
1058 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" MCS selected"
1059 <<
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1065 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1067 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
1068 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
1075 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
1076 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
1077 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
1078 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
1080 std::vector<RlcPduListElement_s> newRlcPduLe;
1081 for (uint8_t j = 0; j < nLayer; j++)
1087 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1088 newRlcPduLe.push_back(newRlcEl);
1098 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1101 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1106 if ((*itBufReq).first.m_rnti > (*itMap).first)
1111 for (uint8_t j = 0; j < nLayer; j++)
1113 newDci.
m_ndi.push_back(1);
1114 newDci.
m_rv.push_back(0);
1119 newEl.
m_dci = newDci;
1127 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1166 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1172 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1178 params.m_cqiList.at(i).m_wbCqi.at(0);
1185 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1194 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1199 m_a30CqiRxed[rnti] = params.m_cqiList.at(i).m_sbMeasResult;
1205 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1220 auto itCqi =
m_ueCqi.find(rnti);
1230 unsigned int sinrNum = 0;
1233 double sinr = (*itCqi).second.at(i);
1240 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1242 (*itCqi).second.at(rb) = estimatedSinr;
1243 return estimatedSinr;
1251 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1252 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1258 std::vector<bool> rbMap;
1259 std::set<uint16_t> rntiAllocated;
1260 std::vector<uint16_t> rbgAllocationMap;
1271 if (rbgAllocationMap.at(i) != 0)
1281 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1286 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1290 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1293 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1294 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1298 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1305 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1307 if ((*itStat).second.at(harqId) >= 3)
1309 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1327 rbgAllocationMap.at(j) = dci.
m_rnti;
1332 << (*itStat).second.at(harqId) + 1);
1336 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1341 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1342 (*itStat).second.at(harqId) = 0;
1343 (*itHarq).second.at((*itProcId).second) = dci;
1345 rntiAllocated.insert(dci.
m_rnti);
1349 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1350 << params.m_ulInfoList.at(i).m_rnti);
1355 std::map<uint16_t, uint32_t>::iterator it;
1360 auto itRnti = rntiAllocated.find((*it).first);
1362 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1387 int rbAllocated = 0;
1410 auto itRnti = rntiAllocated.find((*it).first);
1411 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1414 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1437 uldci.
m_rnti = (*it).first;
1439 bool allocated =
false;
1440 NS_LOG_INFO(
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow
1441 <<
" flows " << nflows);
1447 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1459 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1463 rbgAllocationMap.at(j) = (*it).first;
1465 rbAllocated += rbPerFlow;
1494 auto itCqi =
m_ueCqi.find((*it).first);
1505 "CQI of RNTI = " << (*it).first <<
" has expired");
1506 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1513 double sinr = (*itCqi).second.at(i);
1525 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1526 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1539 rbgAllocationMap.at(i) = 0;
1570 harqId = (*itProcId).second;
1574 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
1577 (*itDci).second.at(harqId) = uldci;
1582 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
1585 (*itStat).second.at(harqId) = 0;
1588 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
1590 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
1591 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
1592 << (uint16_t)harqId);
1606 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
1632 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
1644 for (uint8_t lcg = 0; lcg < 4; ++lcg)
1646 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
1650 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
1651 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
1661 (*it).second = buffer;
1695 switch (params.m_ulCqi.m_type)
1698 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
1699 <<
" subframe no. " << (0xF & params.m_sfnSf));
1705 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
1709 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
1713 std::vector<double> newCqi;
1718 newCqi.push_back(sinr);
1726 m_ueCqi[(*itMap).second.at(i)] = newCqi;
1733 (*itCqi).second.at(i) = sinr;
1748 NS_ASSERT(!params.m_vendorSpecificList.empty());
1749 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
1755 rnti = vsp->GetRnti();
1758 auto itCqi =
m_ueCqi.find(rnti);
1762 std::vector<double> newCqi;
1766 newCqi.push_back(sinr);
1767 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
1780 (*itCqi).second.at(j) = sinr;
1781 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
1793 NS_FATAL_ERROR(
"TtaFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1808 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
1810 if ((*itP10).second == 0)
1815 " Does not find CQI report for user " << (*itP10).first);
1816 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
1833 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
1835 if ((*itA30).second == 0)
1840 " Does not find CQI report for user " << (*itA30).first);
1841 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
1862 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
1864 if ((*itUl).second == 0)
1867 auto itMap =
m_ueCqi.find((*itUl).first);
1869 " Does not find CQI report for user " << (*itUl).first);
1870 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
1871 (*itMap).second.clear();
1892 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
1893 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
1894 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
1895 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
1898 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
1900 (*it).second.m_rlcStatusPduSize = 0;
1902 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
1903 (size >= (*it).second.m_rlcRetransmissionQueueSize))
1905 (*it).second.m_rlcRetransmissionQueueSize = 0;
1907 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
1924 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
1926 (*it).second.m_rlcTransmissionQueueSize = 0;
1930 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
1936 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
1947 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
1948 if ((*it).second >= size)
1950 (*it).second -= size;
1959 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
1966 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
1968 params.m_rnti = rnti;
1969 params.m_transmissionMode = txMode;
static uint32_t BsrId2BufferSize(uint8_t val)
Convert BSR ID to buffer size.
FfMacCschedSapUser class.
virtual void CschedUeConfigCnf(const CschedUeConfigCnfParameters ¶ms)=0
CSCHED_UE_CONFIG_CNF.
virtual void CschedUeConfigUpdateInd(const CschedUeConfigUpdateIndParameters ¶ms)=0
CSCHED_UE_UPDATE_IND.
virtual void SchedUlConfigInd(const SchedUlConfigIndParameters ¶ms)=0
SCHED_UL_CONFIG_IND.
virtual void SchedDlConfigInd(const SchedDlConfigIndParameters ¶ms)=0
SCHED_DL_CONFIG_IND.
This abstract base class identifies the interface by means of which the helper object can plug on the...
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...
Smart pointer class similar to boost::intrusive_ptr.
static uint8_t TxMode2LayerNum(uint8_t txMode)
Transmit mode 2 layer number.
Implements the SCHED SAP and CSCHED SAP for a Throughput to Average scheduler.
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
FfMacSchedSapUser * m_schedSapUser
Sched SAP user.
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request function.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request function.
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set the Provider part of the LteFfrSap that this Scheduler will interact with.
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
std::set< uint16_t > m_flowStatsDl
Set of UE statistics (per RNTI basis) in downlink.
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request function.
void DoDispose() override
Destructor implementation.
uint32_t m_cqiTimersThreshold
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request function.
int GetRbgSize(int dlbandwidth)
Get RBG size function.
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
set the user part of the FfMacCschedSap that this Scheduler will interact with.
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info function.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
void RefreshDlCqiMaps()
Refresh DL CQI maps.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SINR function.
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
friend class MemberSchedSapProvider< TtaFfMacScheduler >
allow MemberSchedSapProvider<TtaFfMacScheduler> class friend access
void RefreshUlCqiMaps()
Refresh UL CQI maps.
static TypeId GetTypeId()
Get the type ID.
~TtaFfMacScheduler() override
Destructor.
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request function.
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 SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
set the user part of the FfMacSchedSap that this Scheduler will interact with.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current process ID.
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request function.
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request function.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
LteFfrSapUser * GetLteFfrSapUser() override
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request function.
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request function.
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request function.
FfMacCschedSapUser * m_cschedSapUser
CSched SAP user.
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmission mode configuration update.
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request function.
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update DL RLC buffer info function.
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request function.
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
CSched cell config request function.
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
unsigned int LcActivePerFlow(uint16_t rnti)
LC active per flow function.
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request function.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
TtaFfMacScheduler()
Constructor.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU list buffer.
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request function.
friend class MemberCschedSapProvider< TtaFfMacScheduler >
allow MemberCschedSapProvider<TtaFfMacScheduler> class friend access
FfMacSchedSapProvider * m_schedSapProvider
Sched SAP provider.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
std::set< uint16_t > m_flowStatsUl
Set of UE statistics (per RNTI basis)
std::vector< RachListElement_s > m_rachList
RACH list.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
CSched cell config.
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request function.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
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 > 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.
static const int TtaType0AllocationRbg[4]
TTA type 0 allocation RBG.
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.
uint16_t m_dlBandwidth
DL bandwidth.
uint16_t m_ulBandwidth
UL bandwidth.
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?