26#include <ns3/boolean.h>
29#include <ns3/pointer.h>
30#include <ns3/simulator.h>
51 : m_cschedSapUser(nullptr),
52 m_schedSapUser(nullptr),
56 m_amc = CreateObject<LteAmc>();
85 TypeId(
"ns3::FdBetFfMacScheduler")
89 .AddAttribute(
"CqiTimerThreshold",
90 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
93 MakeUintegerChecker<uint32_t>())
94 .AddAttribute(
"HarqEnabled",
95 "Activate/Deactivate the HARQ [by default is active].",
99 .AddAttribute(
"UlGrantMcs",
100 "The MCS of the UL grant, must be [0..15] (default 0)",
103 MakeUintegerChecker<uint8_t>());
161 << (uint16_t)params.m_transmissionMode);
165 m_uesTxMode.insert(std::pair<uint16_t, double>(params.m_rnti, params.m_transmissionMode));
169 dlHarqPrcStatus.resize(8, 0);
171 std::pair<uint16_t, DlHarqProcessesStatus_t>(params.m_rnti, dlHarqPrcStatus));
173 dlHarqProcessesTimer.resize(8, 0);
175 std::pair<uint16_t, DlHarqProcessesTimer_t>(params.m_rnti, dlHarqProcessesTimer));
179 std::pair<uint16_t, DlHarqProcessesDciBuffer_t>(params.m_rnti, dlHarqdci));
181 dlHarqRlcPdu.resize(2);
182 dlHarqRlcPdu.at(0).resize(8);
183 dlHarqRlcPdu.at(1).resize(8);
185 std::pair<uint16_t, DlHarqRlcPduListBuffer_t>(params.m_rnti, dlHarqRlcPdu));
188 ulHarqPrcStatus.resize(8, 0);
190 std::pair<uint16_t, UlHarqProcessesStatus_t>(params.m_rnti, ulHarqPrcStatus));
194 std::pair<uint16_t, UlHarqProcessesDciBuffer_t>(params.m_rnti, ulHarqdci));
198 (*it).second = params.m_transmissionMode;
208 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
219 m_flowStatsDl.insert(std::pair<uint16_t, fdbetsFlowPerf_t>(params.m_rnti, flowStatsDl));
225 m_flowStatsUl.insert(std::pair<uint16_t, fdbetsFlowPerf_t>(params.m_rnti, flowStatsUl));
235 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
240 if (((*it).first.m_rnti == params.m_rnti) &&
241 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
276 if ((*it).first.m_rnti == params.m_rnti)
300 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
307 std::pair<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>(flow,
312 (*it).second = params;
335 for (
int i = 0; i < 4; i++)
349 unsigned int lcActive = 0;
352 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
353 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
354 ((*it).second.m_rlcStatusPduSize > 0)))
358 if ((*it).first.m_rnti > rnti)
379 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
381 uint8_t i = (*it).second;
385 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
387 return (*itStat).second.at(i) == 0;
408 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
410 uint8_t i = (*it).second;
414 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
415 if ((*itStat).second.at(i) == 0)
418 (*itStat).second.at(i) = 1;
423 << rnti <<
" check before update with HarqProcessAvailability");
426 return ((*it).second);
443 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
448 << (*itTimers).first);
450 (*itStat).second.at(i) = 0;
451 (*itTimers).second.at(i) = 0;
455 (*itTimers).second.at(i)++;
465 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
466 << (0xF & params.m_sfnSf));
477 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
478 std::vector<bool> rbgMap;
479 uint16_t rbgAllocatedNum = 0;
480 std::set<uint16_t> rntiAllocated;
489 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
494 uint16_t rbStart = 0;
498 (*itRach).m_estimatedSize,
499 " Default UL Grant MCS does not allow to send RACH messages");
501 newRar.
m_rnti = (*itRach).m_rnti;
508 uint16_t tbSizeBits = 0;
510 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
516 if (tbSizeBits < (*itRach).m_estimatedSize)
528 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
529 << rbStart <<
" rbLen " << rbLen <<
" MCS " <<
m_ulGrantMcs <<
" tbSize "
531 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
564 harqId = (*itProcId).second;
568 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
571 (*itDci).second.at(harqId) = uldci;
574 rbStart = rbStart + rbLen;
584 if (!params.m_dlInfoList.empty())
588 params.m_dlInfoList.begin(),
589 params.m_dlInfoList.end());
594 if (!params.m_dlInfoList.empty())
604 std::vector<DlInfoListElement_s> dlInfoListUntxed;
608 if (itRnti != rntiAllocated.end())
614 std::vector<bool> retx;
615 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
620 retx.push_back(
false);
629 if (retx.at(0) || retx.at(1))
634 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
643 if (dci.
m_rv.size() == 1)
655 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
659 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
662 (*it).second.at(harqId) = 0;
666 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
669 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
671 (*itRlcPdu).second.at(k).at(harqId).clear();
677 std::vector<int> dciRbg;
680 for (
int j = 0; j < 32; j++)
690 for (std::size_t j = 0; j < dciRbg.size(); j++)
692 if (rbgMap.at(dciRbg.at(j)))
702 for (std::size_t j = 0; j < dciRbg.size(); j++)
704 rbgMap.at(dciRbg.at(j)) =
true;
705 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
709 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
715 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
716 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
717 std::vector<bool> rbgMapCopy = rbgMap;
718 while ((j < dciRbg.size()) && (startRbg != rbgId))
720 if (!rbgMapCopy.at(rbgId))
722 rbgMapCopy.at(rbgId) =
true;
723 dciRbg.at(j) = rbgId;
726 rbgId = (rbgId + 1) % rbgNum;
728 if (j == dciRbg.size())
732 for (std::size_t k = 0; k < dciRbg.size(); k++)
734 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
739 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
745 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
753 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
755 for (std::size_t j = 0; j < nLayers; j++)
759 if (j >= dci.
m_ndi.size())
762 dci.
m_ndi.push_back(0);
763 dci.
m_rv.push_back(0);
764 dci.
m_mcs.push_back(0);
767 <<
" no txed (MIMO transition)");
773 (*itHarq).second.at(harqId).m_rv.at(j)++;
774 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
775 << (uint16_t)dci.
m_rv.at(j));
785 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
788 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
790 std::vector<RlcPduListElement_s> rlcPduListPerLc;
791 for (std::size_t j = 0; j < nLayers; j++)
795 if (j < dci.
m_ndi.size())
797 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
799 rlcPduListPerLc.push_back(
812 .m_logicalChannelIdentity;
814 rlcPduListPerLc.push_back(emptyElement);
818 if (!rlcPduListPerLc.empty())
825 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
830 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
832 (*itHarqTimer).second.at(harqId) = 0;
834 rntiAllocated.insert(rnti);
851 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
854 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
863 if (rbgAllocatedNum == rbgNum)
873 std::map<uint16_t, double> estAveThr;
874 auto itMax = estAveThr.end();
875 std::map<uint16_t, int> rbgPerRntiLog;
876 double metricMax = 0.0;
879 auto itRnti = rntiAllocated.find((*itFlow).first);
883 if (itRnti != rntiAllocated.end())
885 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ tx" << (uint16_t)(*itFlow).first);
889 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ id" << (uint16_t)(*itFlow).first);
899 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itFlow).first);
904 for (uint8_t j = 0; j < nLayer; j++)
912 cqiSum = (*itCqi).second;
917 estAveThr.insert(std::pair<uint16_t, double>((*itFlow).first,
918 (*itFlow).second.lastAveragedThroughput));
922 NS_LOG_INFO(
"Skip this flow, CQI==0, rnti:" << (*itFlow).first);
926 if (!estAveThr.empty())
929 for (
auto it = estAveThr.begin(); it != estAveThr.end(); it++)
931 double metric = 1 / (*it).second;
932 if (metric > metricMax)
937 rbgPerRntiLog.insert(std::pair<uint16_t, int>((*it).first, 1));
944 NS_LOG_INFO(
this <<
" ALLOCATION for RBG " << i <<
" of " << rbgNum);
948 std::vector<uint16_t> tempMap;
949 auto itMap = allocationMap.find((*itMax).first);
950 if (itMap == allocationMap.end())
952 tempMap.push_back(i);
953 allocationMap.insert(
954 std::pair<uint16_t, std::vector<uint16_t>>((*itMax).first, tempMap));
958 (*itMap).second.push_back(i);
966 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMax).first);
969 std::vector<uint8_t> mcs;
970 for (uint8_t j = 0; j < nLayer; j++)
978 mcs.push_back(
m_amc->GetMcsFromCqi((*itCqi).second));
982 auto itRbgPerRntiLog = rbgPerRntiLog.find((*itMax).first);
985 for (uint8_t j = 0; j < nLayer; j++)
988 (
m_amc->GetDlTbSizeFromMcs(mcs.at(0), (*itRbgPerRntiLog).second * rbgSize) /
992 double expectedAveThr =
993 ((1.0 - (1.0 /
m_timeWindow)) * (*itPastAveThr).second.lastAveragedThroughput) +
996 int rbgPerRnti = (*itRbgPerRntiLog).second;
998 rbgPerRntiLog[(*itMax).first] = rbgPerRnti;
999 estAveThr[(*itMax).first] = expectedAveThr;
1003 for (
auto it = estAveThr.begin(); it != estAveThr.end(); it++)
1005 double metric = 1 / (*it).second;
1006 if (metric > metricMax)
1013 rbgMap.at(i) =
true;
1019 }
while (i < rbgNum);
1026 (*itStats).second.lastTtiBytesTrasmitted = 0;
1031 auto itMap = allocationMap.begin();
1032 while (itMap != allocationMap.end())
1036 newEl.
m_rnti = (*itMap).first;
1039 newDci.
m_rnti = (*itMap).first;
1047 lcActives = (uint16_t)65535;
1049 uint16_t RgbPerRnti = (*itMap).second.size();
1054 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
1059 for (uint8_t j = 0; j < nLayer; j++)
1063 newDci.
m_mcs.push_back(0);
1067 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi((*itCqi).second));
1070 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RgbPerRnti * rbgSize) /
1073 bytesTxed += tbSize;
1079 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1081 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
1082 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
1089 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
1090 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
1091 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
1092 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
1094 std::vector<RlcPduListElement_s> newRlcPduLe;
1095 for (uint8_t j = 0; j < nLayer; j++)
1101 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1102 newRlcPduLe.push_back(newRlcEl);
1112 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1115 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1120 if ((*itBufReq).first.m_rnti > (*itMap).first)
1125 for (uint8_t j = 0; j < nLayer; j++)
1127 newDci.
m_ndi.push_back(1);
1128 newDci.
m_rv.push_back(0);
1133 newEl.
m_dci = newDci;
1141 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1161 (*it).second.lastTtiBytesTrasmitted = bytesTxed;
1162 NS_LOG_INFO(
this <<
" UE total bytes txed " << (*it).second.lastTtiBytesTrasmitted);
1177 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTrasmitted;
1180 (*itStats).second.lastAveragedThroughput =
1181 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1183 NS_LOG_INFO(
this <<
" UE total bytes " << (*itStats).second.totalBytesTransmitted);
1184 NS_LOG_INFO(
this <<
" UE average throughput " << (*itStats).second.lastAveragedThroughput);
1185 (*itStats).second.lastTtiBytesTrasmitted = 0;
1206 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1212 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1219 params.m_cqiList.at(i).m_wbCqi.at(0)));
1226 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1235 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1241 std::pair<uint16_t, SbMeasResult_s>(rnti,
1242 params.m_cqiList.at(i).m_sbMeasResult));
1248 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1263 auto itCqi =
m_ueCqi.find(rnti);
1273 unsigned int sinrNum = 0;
1276 double sinr = (*itCqi).second.at(i);
1283 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1285 (*itCqi).second.at(rb) = estimatedSinr;
1286 return (estimatedSinr);
1294 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1295 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1301 std::vector<bool> rbMap;
1302 std::set<uint16_t> rntiAllocated;
1303 std::vector<uint16_t> rbgAllocationMap;
1314 if (rbgAllocationMap.at(i) != 0)
1324 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1329 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1333 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1336 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1337 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1341 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1348 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1350 if ((*itStat).second.at(harqId) >= 3)
1352 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1370 rbgAllocationMap.at(j) = dci.
m_rnti;
1375 << (*itStat).second.at(harqId) + 1);
1379 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1384 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1385 (*itStat).second.at(harqId) = 0;
1386 (*itHarq).second.at((*itProcId).second) = dci;
1388 rntiAllocated.insert(dci.
m_rnti);
1392 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1393 << params.m_ulInfoList.at(i).m_rnti);
1398 std::map<uint16_t, uint32_t>::iterator it;
1403 auto itRnti = rntiAllocated.find((*it).first);
1405 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1416 std::pair<uint16_t, std::vector<uint16_t>>(params.m_sfnSf, rbgAllocationMap));
1431 int rbAllocated = 0;
1454 auto itRnti = rntiAllocated.find((*it).first);
1455 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1458 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1481 uldci.
m_rnti = (*it).first;
1483 bool allocated =
false;
1484 NS_LOG_INFO(
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow
1485 <<
" flows " << nflows);
1491 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1503 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1507 rbgAllocationMap.at(j) = (*it).first;
1509 rbAllocated += rbPerFlow;
1535 std::pair<uint16_t, std::vector<uint16_t>>(params.m_sfnSf, rbgAllocationMap));
1539 auto itCqi =
m_ueCqi.find((*it).first);
1550 "CQI of RNTI = " << (*it).first <<
" has expired");
1551 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1558 double sinr = (*itCqi).second.at(i);
1570 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1571 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1584 rbgAllocationMap.at(i) = 0;
1615 harqId = (*itProcId).second;
1619 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
1622 (*itDci).second.at(harqId) = uldci;
1627 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
1630 (*itStat).second.at(harqId) = 0;
1633 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
1635 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
1636 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
1637 << (uint16_t)harqId);
1643 (*itStats).second.lastTtiBytesTrasmitted = uldci.
m_tbSize;
1647 NS_LOG_DEBUG(
this <<
" No Stats for this allocated UE");
1662 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
1668 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTrasmitted;
1671 (*itStats).second.lastAveragedThroughput =
1672 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1674 NS_LOG_INFO(
this <<
" UE total bytes " << (*itStats).second.totalBytesTransmitted);
1675 NS_LOG_INFO(
this <<
" UE average throughput " << (*itStats).second.lastAveragedThroughput);
1676 (*itStats).second.lastTtiBytesTrasmitted = 0;
1679 std::pair<uint16_t, std::vector<uint16_t>>(params.m_sfnSf, rbgAllocationMap));
1703 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
1715 for (uint8_t lcg = 0; lcg < 4; ++lcg)
1717 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
1721 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
1722 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
1727 m_ceBsrRxed.insert(std::pair<uint16_t, uint32_t>(rnti, buffer));
1732 (*it).second = buffer;
1766 switch (params.m_ulCqi.m_type)
1769 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
1770 <<
" subframe no. " << (0xF & params.m_sfnSf));
1776 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
1780 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
1784 std::vector<double> newCqi;
1789 newCqi.push_back(sinr);
1798 std::pair<uint16_t, std::vector<double>>((*itMap).second.at(i), newCqi));
1806 (*itCqi).second.at(i) = sinr;
1807 NS_LOG_DEBUG(
this <<
" RNTI " << (*itMap).second.at(i) <<
" RB " << i <<
" SINR "
1821 NS_ASSERT(!params.m_vendorSpecificList.empty());
1822 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
1827 DynamicCast<SrsCqiRntiVsp>(params.m_vendorSpecificList.at(i).m_value);
1828 rnti = vsp->GetRnti();
1831 auto itCqi =
m_ueCqi.find(rnti);
1835 std::vector<double> newCqi;
1839 newCqi.push_back(sinr);
1840 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
1843 m_ueCqi.insert(std::pair<uint16_t, std::vector<double>>(rnti, newCqi));
1853 (*itCqi).second.at(j) = sinr;
1854 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
1866 NS_FATAL_ERROR(
"FdBetFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1881 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
1883 if ((*itP10).second == 0)
1888 " Does not find CQI report for user " << (*itP10).first);
1889 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
1906 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
1908 if ((*itA30).second == 0)
1913 " Does not find CQI report for user " << (*itA30).first);
1914 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
1935 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
1937 if ((*itUl).second == 0)
1940 auto itMap =
m_ueCqi.find((*itUl).first);
1942 " Does not find CQI report for user " << (*itUl).first);
1943 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
1944 (*itMap).second.clear();
1965 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
1966 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
1967 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
1968 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
1971 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
1973 (*it).second.m_rlcStatusPduSize = 0;
1975 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
1976 (size >= (*it).second.m_rlcRetransmissionQueueSize))
1978 (*it).second.m_rlcRetransmissionQueueSize = 0;
1980 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
1997 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
1999 (*it).second.m_rlcTransmissionQueueSize = 0;
2003 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
2009 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
2020 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
2021 if ((*it).second >= size)
2023 (*it).second -= size;
2032 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
2039 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
2041 params.m_rnti = rnti;
2042 params.m_transmissionMode = txMode;
AttributeValue implementation for Boolean.
static uint32_t BsrId2BufferSize(uint8_t val)
Convert BSR ID to buffer size.
Implements the SCHED SAP and CSCHED SAP for a Frequency Domain Blind Equal Throughput scheduler.
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
std::vector< RachListElement_s > m_rachList
rach list
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RLC buffer info.
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request function.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request function.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
unsigned int LcActivePerFlow(uint16_t rnti)
LC active per flow function.
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
CSched cell config request function.
void DoDispose() override
Destructor implementation.
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
Csched LC config request function.
~FdBetFfMacScheduler() override
Destructor.
FdBetFfMacScheduler()
Constructor.
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request function.
FfMacSchedSapProvider * m_schedSapProvider
sched sap provider
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
LteFfrSapUser * m_ffrSapUser
ffr sap user
std::map< uint16_t, fdbetsFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request function.
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
csched cell config
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set the Provider part of the LteFfrSap that this Scheduler will interact with.
LteFfrSapUser * GetLteFfrSapUser() override
void RefreshUlCqiMaps()
Refresh UL CQI maps.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request function.
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CGI info request function.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
friend class MemberSchedSapProvider< FdBetFfMacScheduler >
allow MemberSchedSapProvider<FdBetFfMacScheduler> class friend access
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current process ID.
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmission mode configuration update function.
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CGI info request function.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI Buffer.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
Csched UE config request function.
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
void SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
set the user part of the FfMacSchedSap that this Scheduler will interact with.
FfMacCschedSapUser * m_cschedSapUser
csched sap user
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request function.
std::map< uint16_t, fdbetsFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
LteFfrSapProvider * m_ffrSapProvider
ffr sap provider
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SNR.
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
std::vector< uint16_t > m_rachAllocationMap
rach allocation map
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer 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)
double m_timeWindow
time window
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU List.
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request function.
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request function.
void RefreshDlCqiMaps()
Refresh DL CQI maps.
FfMacCschedSapProvider * m_cschedSapProvider
csched sap provider
uint32_t m_cqiTimersThreshold
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
set the user part of the FfMacCschedSap that this Scheduler will interact with.
static TypeId GetTypeId()
Get the type ID.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info.
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
DL HARQ retx buffered.
int GetRbgSize(int dlbandwidth)
Get RBG size function.
FfMacSchedSapUser * m_schedSapUser
sched sap user
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request function.
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
friend class MemberCschedSapProvider< FdBetFfMacScheduler >
allow MemberCschedSapProvider<FdBetFfMacScheduler> class friend access
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request function.
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 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...
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
Ptr< const AttributeChecker > MakeBooleanChecker()
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
#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.
#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.
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...
std::vector< UlDciListElement_s > UlHarqProcessesDciBuffer_t
UL HARQ process DCI buffer vector.
std::vector< RlcPduList_t > DlHarqRlcPduListBuffer_t
Vector of the 8 HARQ processes per UE.
constexpr uint32_t HARQ_DL_TIMEOUT
HARQ DL timeout.
constexpr uint32_t HARQ_PROC_NUM
Number of HARQ processes.
std::vector< DlDciListElement_s > DlHarqProcessesDciBuffer_t
DL HARQ process DCI buffer vector.
std::vector< uint8_t > UlHarqProcessesStatus_t
UL HARQ process status vector.
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector.
std::vector< uint8_t > DlHarqProcessesStatus_t
DL HARQ process status vector.
static const int FdBetType0AllocationRbg[4]
FdBetType0AllocationRbg array.
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?
fdbetsFlowPerf_t structure
unsigned int lastTtiBytesTrasmitted
last total bytes transmitted
double lastAveragedThroughput
last averaged throughput
unsigned long totalBytesTransmitted
total bytes transmitted
Time flowStart
flow start time