15#include <ns3/boolean.h>
18#include <ns3/pointer.h>
19#include <ns3/simulator.h>
40 : m_cschedSapUser(nullptr),
41 m_schedSapUser(nullptr),
74 TypeId(
"ns3::TdBetFfMacScheduler")
78 .AddAttribute(
"CqiTimerThreshold",
79 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
83 .AddAttribute(
"HarqEnabled",
84 "Activate/Deactivate the HARQ [by default is active].",
88 .AddAttribute(
"UlGrantMcs",
89 "The MCS of the UL grant, must be [0..15] (default 0)",
150 << (uint16_t)params.m_transmissionMode);
154 m_uesTxMode[params.m_rnti] = params.m_transmissionMode;
158 dlHarqPrcStatus.resize(8, 0);
161 dlHarqProcessesTimer.resize(8, 0);
167 dlHarqRlcPdu.resize(2);
168 dlHarqRlcPdu.at(0).resize(8);
169 dlHarqRlcPdu.at(1).resize(8);
173 ulHarqPrcStatus.resize(8, 0);
181 (*it).second = params.m_transmissionMode;
191 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
218 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
223 if (((*it).first.m_rnti == params.m_rnti) &&
224 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
259 if ((*it).first.m_rnti == params.m_rnti)
283 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
293 (*it).second = params;
316 for (
int i = 0; i < 4; i++)
330 unsigned int lcActive = 0;
333 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
334 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
335 ((*it).second.m_rlcStatusPduSize > 0)))
339 if ((*it).first.m_rnti > rnti)
360 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
362 uint8_t i = (*it).second;
366 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
368 return (*itStat).second.at(i) == 0;
389 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
391 uint8_t i = (*it).second;
395 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
396 if ((*itStat).second.at(i) == 0)
399 (*itStat).second.at(i) = 1;
404 << rnti <<
" check before update with HarqProcessAvailability");
424 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
429 << (*itTimers).first);
431 (*itStat).second.at(i) = 0;
432 (*itTimers).second.at(i) = 0;
436 (*itTimers).second.at(i)++;
446 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
447 << (0xF & params.m_sfnSf));
458 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
459 std::vector<bool> rbgMap;
460 uint16_t rbgAllocatedNum = 0;
461 std::set<uint16_t> rntiAllocated;
470 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
475 uint16_t rbStart = 0;
479 (*itRach).m_estimatedSize,
480 " Default UL Grant MCS does not allow to send RACH messages");
482 newRar.
m_rnti = (*itRach).m_rnti;
489 uint16_t tbSizeBits = 0;
491 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
497 if (tbSizeBits < (*itRach).m_estimatedSize)
509 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
510 << rbStart <<
" rbLen " << rbLen <<
" MCS " <<
m_ulGrantMcs <<
" tbSize "
512 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
545 harqId = (*itProcId).second;
549 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
552 (*itDci).second.at(harqId) = uldci;
555 rbStart = rbStart + rbLen;
565 if (!params.m_dlInfoList.empty())
569 params.m_dlInfoList.begin(),
570 params.m_dlInfoList.end());
575 if (!params.m_dlInfoList.empty())
585 std::vector<DlInfoListElement_s> dlInfoListUntxed;
589 if (itRnti != rntiAllocated.end())
595 std::vector<bool> retx;
596 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
601 retx.push_back(
false);
610 if (retx.at(0) || retx.at(1))
615 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
624 if (dci.
m_rv.size() == 1)
636 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
640 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
643 (*it).second.at(harqId) = 0;
647 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
650 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
652 (*itRlcPdu).second.at(k).at(harqId).clear();
658 std::vector<int> dciRbg;
661 for (
int j = 0; j < 32; j++)
671 for (std::size_t j = 0; j < dciRbg.size(); j++)
673 if (rbgMap.at(dciRbg.at(j)))
683 for (std::size_t j = 0; j < dciRbg.size(); j++)
685 rbgMap.at(dciRbg.at(j)) =
true;
686 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
690 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
696 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
697 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
698 std::vector<bool> rbgMapCopy = rbgMap;
699 while ((j < dciRbg.size()) && (startRbg != rbgId))
701 if (!rbgMapCopy.at(rbgId))
703 rbgMapCopy.at(rbgId) =
true;
704 dciRbg.at(j) = rbgId;
707 rbgId = (rbgId + 1) % rbgNum;
709 if (j == dciRbg.size())
713 for (std::size_t k = 0; k < dciRbg.size(); k++)
715 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
720 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
726 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
734 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
736 for (std::size_t j = 0; j < nLayers; j++)
740 if (j >= dci.
m_ndi.size())
743 dci.
m_ndi.push_back(0);
744 dci.
m_rv.push_back(0);
745 dci.
m_mcs.push_back(0);
748 <<
" no txed (MIMO transition)");
754 (*itHarq).second.at(harqId).m_rv.at(j)++;
755 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
756 << (uint16_t)dci.
m_rv.at(j));
766 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
769 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
771 std::vector<RlcPduListElement_s> rlcPduListPerLc;
772 for (std::size_t j = 0; j < nLayers; j++)
776 if (j < dci.
m_ndi.size())
778 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
780 rlcPduListPerLc.push_back(
793 .m_logicalChannelIdentity;
795 rlcPduListPerLc.push_back(emptyElement);
799 if (!rlcPduListPerLc.empty())
806 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
811 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
813 (*itHarqTimer).second.at(harqId) = 0;
815 rntiAllocated.insert(rnti);
832 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
835 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
844 if (rbgAllocatedNum == rbgNum)
855 double metricMax = 0.0;
863 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
868 for (uint8_t j = 0; j < nLayer; j++)
876 cqiSum = (*itCqi).second;
881 NS_LOG_INFO(
"Skip this flow, CQI==0, rnti:" << (*it).first);
885 auto itRnti = rntiAllocated.find((*it).first);
889 if (itRnti != rntiAllocated.end())
891 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ tx" << (uint16_t)(*it).first);
895 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ id" << (uint16_t)(*it).first);
900 double metric = 1 / (*it).second.lastAveragedThroughput;
902 if (metric > metricMax)
917 std::vector<uint16_t> tempMap;
918 tempMap.reserve(rbgNum);
919 for (
int i = 0; i < rbgNum; i++)
921 tempMap.push_back(i);
923 allocationMap[(*itMax).first] = tempMap;
929 (*itStats).second.lastTtiBytesTransmitted = 0;
934 auto itMap = allocationMap.begin();
935 while (itMap != allocationMap.end())
939 newEl.
m_rnti = (*itMap).first;
942 newDci.
m_rnti = (*itMap).first;
950 lcActives = (uint16_t)65535;
952 uint16_t RbgPerRnti = (*itMap).second.size();
957 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
962 for (uint8_t j = 0; j < nLayer; j++)
966 newDci.
m_mcs.push_back(0);
970 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi((*itCqi).second));
973 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RbgPerRnti * rbgSize) /
982 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
984 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
985 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
992 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
993 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
994 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
995 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
997 std::vector<RlcPduListElement_s> newRlcPduLe;
998 for (uint8_t j = 0; j < nLayer; j++)
1004 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1005 newRlcPduLe.push_back(newRlcEl);
1015 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1018 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1023 if ((*itBufReq).first.m_rnti > (*itMap).first)
1028 for (uint8_t j = 0; j < nLayer; j++)
1030 newDci.
m_ndi.push_back(1);
1031 newDci.
m_rv.push_back(0);
1036 newEl.
m_dci = newDci;
1044 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1064 (*it).second.lastTtiBytesTransmitted = bytesTxed;
1065 NS_LOG_INFO(
this <<
" UE total bytes txed " << (*it).second.lastTtiBytesTransmitted);
1080 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTransmitted;
1083 (*itStats).second.lastAveragedThroughput =
1084 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1085 ((1.0 /
m_timeWindow) * (
double)((*itStats).second.lastTtiBytesTransmitted / 0.001));
1086 NS_LOG_INFO(
this <<
" UE total bytes " << (*itStats).second.totalBytesTransmitted);
1087 NS_LOG_INFO(
this <<
" UE average throughput " << (*itStats).second.lastAveragedThroughput);
1088 (*itStats).second.lastTtiBytesTransmitted = 0;
1109 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1115 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1121 params.m_cqiList.at(i).m_wbCqi.at(0);
1128 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1137 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1142 m_a30CqiRxed[rnti] = params.m_cqiList.at(i).m_sbMeasResult;
1148 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1163 auto itCqi =
m_ueCqi.find(rnti);
1173 unsigned int sinrNum = 0;
1176 double sinr = (*itCqi).second.at(i);
1183 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1185 (*itCqi).second.at(rb) = estimatedSinr;
1186 return estimatedSinr;
1194 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1195 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1201 std::vector<bool> rbMap;
1202 std::set<uint16_t> rntiAllocated;
1203 std::vector<uint16_t> rbgAllocationMap;
1214 if (rbgAllocationMap.at(i) != 0)
1224 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1229 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1233 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1236 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1237 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1241 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1248 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1250 if ((*itStat).second.at(harqId) >= 3)
1252 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1270 rbgAllocationMap.at(j) = dci.
m_rnti;
1275 << (*itStat).second.at(harqId) + 1);
1279 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1284 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1285 (*itStat).second.at(harqId) = 0;
1286 (*itHarq).second.at((*itProcId).second) = dci;
1288 rntiAllocated.insert(dci.
m_rnti);
1292 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1293 << params.m_ulInfoList.at(i).m_rnti);
1298 std::map<uint16_t, uint32_t>::iterator it;
1303 auto itRnti = rntiAllocated.find((*it).first);
1305 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1330 int rbAllocated = 0;
1353 auto itRnti = rntiAllocated.find((*it).first);
1354 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1357 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1380 uldci.
m_rnti = (*it).first;
1382 bool allocated =
false;
1383 NS_LOG_INFO(
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow
1384 <<
" flows " << nflows);
1390 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1402 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1406 rbgAllocationMap.at(j) = (*it).first;
1408 rbAllocated += rbPerFlow;
1437 auto itCqi =
m_ueCqi.find((*it).first);
1448 "CQI of RNTI = " << (*it).first <<
" has expired");
1449 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1456 double sinr = (*itCqi).second.at(i);
1468 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1469 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1482 rbgAllocationMap.at(i) = 0;
1513 harqId = (*itProcId).second;
1517 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
1520 (*itDci).second.at(harqId) = uldci;
1525 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
1528 (*itStat).second.at(harqId) = 0;
1531 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
1533 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
1534 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
1535 << (uint16_t)harqId);
1541 (*itStats).second.lastTtiBytesTransmitted = uldci.
m_tbSize;
1545 NS_LOG_DEBUG(
this <<
" No Stats for this allocated UE");
1560 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
1566 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTransmitted;
1569 (*itStats).second.lastAveragedThroughput =
1570 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1571 ((1.0 /
m_timeWindow) * (
double)((*itStats).second.lastTtiBytesTransmitted / 0.001));
1572 NS_LOG_INFO(
this <<
" UE total bytes " << (*itStats).second.totalBytesTransmitted);
1573 NS_LOG_INFO(
this <<
" UE average throughput " << (*itStats).second.lastAveragedThroughput);
1574 (*itStats).second.lastTtiBytesTransmitted = 0;
1600 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
1612 for (uint8_t lcg = 0; lcg < 4; ++lcg)
1614 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
1618 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
1619 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
1629 (*it).second = buffer;
1663 switch (params.m_ulCqi.m_type)
1666 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
1667 <<
" subframe no. " << (0xF & params.m_sfnSf));
1673 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
1677 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
1681 std::vector<double> newCqi;
1686 newCqi.push_back(sinr);
1694 m_ueCqi[(*itMap).second.at(i)] = newCqi;
1701 (*itCqi).second.at(i) = sinr;
1702 NS_LOG_DEBUG(
this <<
" RNTI " << (*itMap).second.at(i) <<
" RB " << i <<
" SINR "
1716 NS_ASSERT(!params.m_vendorSpecificList.empty());
1717 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
1723 rnti = vsp->GetRnti();
1726 auto itCqi =
m_ueCqi.find(rnti);
1730 std::vector<double> newCqi;
1734 newCqi.push_back(sinr);
1735 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
1748 (*itCqi).second.at(j) = sinr;
1749 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
1761 NS_FATAL_ERROR(
"TdBetFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1776 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
1778 if ((*itP10).second == 0)
1783 " Does not find CQI report for user " << (*itP10).first);
1784 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
1801 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
1803 if ((*itA30).second == 0)
1808 " Does not find CQI report for user " << (*itA30).first);
1809 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
1830 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
1832 if ((*itUl).second == 0)
1835 auto itMap =
m_ueCqi.find((*itUl).first);
1837 " Does not find CQI report for user " << (*itUl).first);
1838 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
1839 (*itMap).second.clear();
1860 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
1861 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
1862 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
1863 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
1866 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
1868 (*it).second.m_rlcStatusPduSize = 0;
1870 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
1871 (size >= (*it).second.m_rlcRetransmissionQueueSize))
1873 (*it).second.m_rlcRetransmissionQueueSize = 0;
1875 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
1892 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
1894 (*it).second.m_rlcTransmissionQueueSize = 0;
1898 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
1904 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
1915 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
1916 if ((*it).second >= size)
1918 (*it).second -= size;
1927 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
1934 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
1936 params.m_rnti = rnti;
1937 params.m_transmissionMode = txMode;
AttributeValue implementation for Boolean.
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 Time Now()
Return the current simulation virtual time.
Implements the SCHED SAP and CSCHED SAP for a Time Domain Blind Equal Throughput scheduler.
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SINR function.
FfMacCschedSapUser * m_cschedSapUser
CSched SAP user.
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request.
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request.
std::map< uint16_t, tdbetsFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
int GetRbgSize(int dlbandwidth)
Get RBG size function.
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request.
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request.
void RefreshDlCqiMaps()
Refresh DL CQI maps function.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ process ID.
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
std::map< uint16_t, tdbetsFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
std::vector< RachListElement_s > m_rachList
RACH list.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
CSched cell config.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request.
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
void DoDispose() override
Destructor implementation.
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
LteFfrSapUser * GetLteFfrSapUser() override
FfMacSchedSapUser * m_schedSapUser
Sched SAP user.
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
static TypeId GetTypeId()
Get the type ID.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request.
void SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
set the user part of the FfMacSchedSap that this Scheduler will interact with.
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request.
FfMacSchedSapProvider * m_schedSapProvider
Sched SAP provider.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request.
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
friend class MemberSchedSapProvider< TdBetFfMacScheduler >
allow MemberSchedSapProvider<TdBetFfMacScheduler> class friend access
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmission mode configuration update function.
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
set the user part of the FfMacCschedSap that this Scheduler will interact with.
TdBetFfMacScheduler()
Constructor.
friend class MemberCschedSapProvider< TdBetFfMacScheduler >
allow MemberCschedSapProvider<TdBetFfMacScheduler> class friend access
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request.
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request.
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.
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set the Provider part of the LteFfrSap that this Scheduler will interact with.
void RefreshUlCqiMaps()
Refresh UL CQI maps function.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
double m_timeWindow
time window
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request.
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request.
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RLC buffer info function.
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
~TdBetFfMacScheduler() override
Destructor.
uint32_t m_cqiTimersThreshold
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
unsigned int LcActivePerFlow(uint16_t rnti)
LC active flow function.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU list buffer.
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info function.
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
CSched cell config request.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
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 AttributeChecker > MakeBooleanChecker()
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method.
Ptr< const AttributeChecker > MakeUintegerChecker()
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method.
#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.
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector.
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< 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.
static const int TdBetType0AllocationRbg[4]
TDBET type 0 allocation RBG.
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.
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.
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?
tdbetsFlowPerf_t structure
double lastAveragedThroughput
last average throughput
Time flowStart
flow start time
unsigned long totalBytesTransmitted
total bytes transmitted
unsigned int lastTtiBytesTransmitted
last total bytes transmitted