15#include <ns3/boolean.h>
18#include <ns3/pointer.h>
19#include <ns3/simulator.h>
20#include <ns3/string.h>
42 : m_cschedSapUser(nullptr),
43 m_schedSapUser(nullptr),
79 TypeId(
"ns3::PssFfMacScheduler")
83 .AddAttribute(
"CqiTimerThreshold",
84 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
88 .AddAttribute(
"PssFdSchedulerType",
89 "FD scheduler in PSS (default value is PFsch)",
94 "The number of UE selected by TD scheduler (default value is 0)",
98 .AddAttribute(
"HarqEnabled",
99 "Activate/Deactivate the HARQ [by default is active].",
103 .AddAttribute(
"UlGrantMcs",
104 "The MCS of the UL grant, must be [0..15] (default 0)",
165 << (uint16_t)params.m_transmissionMode);
169 m_uesTxMode[params.m_rnti] = params.m_transmissionMode;
173 dlHarqPrcStatus.resize(8, 0);
176 dlHarqProcessesTimer.resize(8, 0);
182 dlHarqRlcPdu.resize(2);
183 dlHarqRlcPdu.at(0).resize(8);
184 dlHarqRlcPdu.at(1).resize(8);
188 ulHarqPrcStatus.resize(8, 0);
196 (*it).second = params.m_transmissionMode;
206 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
212 double tbrDlInBytes =
213 params.m_logicalChannelConfigList.at(i).m_eRabGuaranteedBitrateDl / 8;
214 double tbrUlInBytes =
215 params.m_logicalChannelConfigList.at(i).m_eRabGuaranteedBitrateUl / 8;
237 double tbrDlInBytes =
238 params.m_logicalChannelConfigList.at(i).m_eRabGuaranteedBitrateDl / 8;
239 double tbrUlInBytes =
240 params.m_logicalChannelConfigList.at(i).m_eRabGuaranteedBitrateUl / 8;
252 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
257 if (((*it).first.m_rnti == params.m_rnti) &&
258 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
293 if ((*it).first.m_rnti == params.m_rnti)
317 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
327 (*it).second = params;
350 for (
int i = 0; i < 4; i++)
364 unsigned int lcActive = 0;
367 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
368 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
369 ((*it).second.m_rlcStatusPduSize > 0)))
373 if ((*it).first.m_rnti > rnti)
394 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
396 uint8_t i = (*it).second;
400 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
402 return (*itStat).second.at(i) == 0;
423 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
425 uint8_t i = (*it).second;
429 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
430 if ((*itStat).second.at(i) == 0)
433 (*itStat).second.at(i) = 1;
438 << rnti <<
" check before update with HarqProcessAvailability");
458 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
463 << (*itTimers).first);
465 (*itStat).second.at(i) = 0;
466 (*itTimers).second.at(i) = 0;
470 (*itTimers).second.at(i)++;
480 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
481 << (0xF & params.m_sfnSf));
492 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
493 std::vector<bool> rbgMap;
494 uint16_t rbgAllocatedNum = 0;
495 std::set<uint16_t> rntiAllocated;
499 for (
auto it = rbgMap.begin(); it != rbgMap.end(); it++)
514 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
518 std::vector<bool> ulRbMap;
521 uint8_t maxContinuousUlBandwidth = 0;
522 uint8_t tmpMinBandwidth = 0;
523 uint16_t ffrRbStartOffset = 0;
524 uint16_t tmpFfrRbStartOffset = 0;
527 for (
auto it = ulRbMap.begin(); it != ulRbMap.end(); it++)
531 if (tmpMinBandwidth > maxContinuousUlBandwidth)
533 maxContinuousUlBandwidth = tmpMinBandwidth;
534 ffrRbStartOffset = tmpFfrRbStartOffset;
540 if (tmpMinBandwidth == 0)
542 tmpFfrRbStartOffset = index;
549 if (tmpMinBandwidth > maxContinuousUlBandwidth)
551 maxContinuousUlBandwidth = tmpMinBandwidth;
552 ffrRbStartOffset = tmpFfrRbStartOffset;
556 uint16_t rbStart = 0;
557 rbStart = ffrRbStartOffset;
561 (*itRach).m_estimatedSize,
562 " Default UL Grant MCS does not allow to send RACH messages");
564 newRar.
m_rnti = (*itRach).m_rnti;
571 uint16_t tbSizeBits = 0;
573 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
574 (rbStart + rbLen < (ffrRbStartOffset + maxContinuousUlBandwidth)))
579 if (tbSizeBits < (*itRach).m_estimatedSize)
591 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
592 << rbStart <<
" rbLen " << rbLen <<
" MCS " << (uint16_t)
m_ulGrantMcs
594 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
627 harqId = (*itProcId).second;
631 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
634 (*itDci).second.at(harqId) = uldci;
637 rbStart = rbStart + rbLen;
647 if (!params.m_dlInfoList.empty())
651 params.m_dlInfoList.begin(),
652 params.m_dlInfoList.end());
657 if (!params.m_dlInfoList.empty())
667 std::vector<DlInfoListElement_s> dlInfoListUntxed;
671 if (itRnti != rntiAllocated.end())
677 std::vector<bool> retx;
678 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
683 retx.push_back(
false);
692 if (retx.at(0) || retx.at(1))
697 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
706 if (dci.
m_rv.size() == 1)
718 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
722 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
725 it->second.at(harqId) = 0;
729 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
732 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
734 (*itRlcPdu).second.at(k).at(harqId).clear();
740 std::vector<int> dciRbg;
743 for (
int j = 0; j < 32; j++)
753 for (std::size_t j = 0; j < dciRbg.size(); j++)
755 if (rbgMap.at(dciRbg.at(j)))
765 for (std::size_t j = 0; j < dciRbg.size(); j++)
767 rbgMap.at(dciRbg.at(j)) =
true;
768 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
772 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
778 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
779 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
780 std::vector<bool> rbgMapCopy = rbgMap;
781 while ((j < dciRbg.size()) && (startRbg != rbgId))
783 if (!rbgMapCopy.at(rbgId))
785 rbgMapCopy.at(rbgId) =
true;
786 dciRbg.at(j) = rbgId;
789 rbgId = (rbgId + 1) % rbgNum;
791 if (j == dciRbg.size())
795 for (std::size_t k = 0; k < dciRbg.size(); k++)
797 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
802 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
808 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
816 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
818 for (std::size_t j = 0; j < nLayers; j++)
822 if (j >= dci.
m_ndi.size())
825 dci.
m_ndi.push_back(0);
826 dci.
m_rv.push_back(0);
827 dci.
m_mcs.push_back(0);
830 <<
" no txed (MIMO transition)");
836 (*itHarq).second.at(harqId).m_rv.at(j)++;
837 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
838 << (uint16_t)dci.
m_rv.at(j));
848 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
851 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
853 std::vector<RlcPduListElement_s> rlcPduListPerLc;
854 for (std::size_t j = 0; j < nLayers; j++)
858 if (j < dci.
m_ndi.size())
860 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
862 rlcPduListPerLc.push_back(
875 .m_logicalChannelIdentity;
877 rlcPduListPerLc.push_back(emptyElement);
881 if (!rlcPduListPerLc.empty())
888 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
893 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
895 (*itHarqTimer).second.at(harqId) = 0;
897 rntiAllocated.insert(rnti);
914 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
917 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
926 if (rbgAllocatedNum == rbgNum)
936 std::map<uint16_t, pssFlowPerf_t> tdUeSet;
939 std::map<uint16_t, pssFlowPerf_t> ueSet;
944 ueSet[(*it).first] = (*it).second;
952 std::vector<std::pair<double, uint16_t>> ueSet1;
953 std::vector<std::pair<double, uint16_t>> ueSet2;
954 for (
auto it = ueSet.begin(); it != ueSet.end(); it++)
956 auto itRnti = rntiAllocated.find((*it).first);
960 if (itRnti != rntiAllocated.end())
962 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ tx" << (uint16_t)(*it).first);
966 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ id" << (uint16_t)(*it).first);
972 if ((*it).second.lastAveragedThroughput < (*it).second.targetThroughput)
975 metric = 1 / (*it).second.lastAveragedThroughput;
982 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
987 for (uint8_t j = 0; j < nLayer; j++)
995 cqiSum = (*itCqi).second;
1000 ueSet1.emplace_back(metric, (*it).first);
1010 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1020 wbCqi = (*itCqi).second;
1028 double achievableRate = 0.0;
1029 for (uint8_t k = 0; k < nLayer; k++)
1032 mcs =
m_amc->GetMcsFromCqi(wbCqi);
1033 achievableRate += ((
m_amc->GetDlTbSizeFromMcs(mcs, rbgSize) / 8) /
1037 metric = achievableRate / (*it).second.lastAveragedThroughput;
1039 ueSet2.emplace_back(metric, (*it).first);
1044 if (!ueSet1.empty() || !ueSet2.empty())
1047 std::sort(ueSet1.rbegin(), ueSet1.rend());
1048 std::sort(ueSet2.rbegin(), ueSet2.rend());
1059 if (ueSet1.size() + ueSet2.size() <= 2)
1066 nMux = (int)((ueSet1.size() + ueSet2.size()) / 2);
1070 for (
auto itSet = ueSet1.begin(); itSet != ueSet1.end() && nMux != 0; itSet++)
1073 tdUeSet[(*itUe).first] = (*itUe).second;
1077 for (
auto itSet = ueSet2.begin(); itSet != ueSet2.end() && nMux != 0; itSet++)
1080 tdUeSet[(*itUe).first] = (*itUe).second;
1087 std::map<uint16_t, uint8_t> sbCqiSum;
1088 for (
auto it = tdUeSet.begin(); it != tdUeSet.end(); it++)
1091 for (
int i = 0; i < rbgNum; i++)
1097 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1100 std::vector<uint8_t> sbCqis;
1103 sbCqis = std::vector<uint8_t>(nLayer, 1);
1107 sbCqis = (*itCqi).second.m_higherLayerSelected.at(i).m_sbCqi;
1110 uint8_t cqi1 = sbCqis.at(0);
1112 if (sbCqis.size() > 1)
1114 cqi2 = sbCqis.at(1);
1122 for (uint8_t k = 0; k < nLayer; k++)
1124 if (sbCqis.size() > k)
1126 sbCqi = sbCqis.at(k);
1138 sbCqiSum[(*it).first] = sum;
1141 for (
int i = 0; i < rbgNum; i++)
1148 auto itMax = tdUeSet.end();
1149 double metricMax = 0.0;
1150 for (
auto it = tdUeSet.begin(); it != tdUeSet.end(); it++)
1159 (*it).second.targetThroughput / (*it).second.lastAveragedThroughput;
1165 auto itSbCqiSum = sbCqiSum.find((*it).first);
1171 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1174 std::vector<uint8_t> sbCqis;
1177 sbCqis = std::vector<uint8_t>(nLayer, 1);
1181 sbCqis = (*itCqi).second.m_higherLayerSelected.at(i).m_sbCqi;
1184 uint8_t cqi1 = sbCqis.at(0);
1186 if (sbCqis.size() > 1)
1188 cqi2 = sbCqis.at(1);
1192 double colMetric = 0.0;
1197 for (uint8_t k = 0; k < nLayer; k++)
1199 if (sbCqis.size() > k)
1201 sbCqi = sbCqis.at(k);
1208 colMetric += (
double)sbCqi / (
double)(*itSbCqiSum).second;
1212 double metric = 0.0;
1215 metric = weight * colMetric;
1222 if (metric > metricMax)
1229 if (itMax == tdUeSet.end())
1235 allocationMap[(*itMax).first].push_back(i);
1236 rbgMap.at(i) =
true;
1245 for (
int i = 0; i < rbgNum; i++)
1252 auto itMax = tdUeSet.end();
1253 double metricMax = 0.0;
1254 for (
auto it = tdUeSet.begin(); it != tdUeSet.end(); it++)
1262 (*it).second.targetThroughput / (*it).second.lastAveragedThroughput;
1272 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1275 std::vector<uint8_t> sbCqis;
1278 sbCqis = std::vector<uint8_t>(nLayer, 1);
1282 sbCqis = (*itCqi).second.m_higherLayerSelected.at(i).m_sbCqi;
1285 uint8_t cqi1 = sbCqis.at(0);
1287 if (sbCqis.size() > 1)
1289 cqi2 = sbCqis.at(1);
1292 double schMetric = 0.0;
1297 double achievableRate = 0.0;
1298 for (uint8_t k = 0; k < nLayer; k++)
1301 if (sbCqis.size() > k)
1303 mcs =
m_amc->GetMcsFromCqi(sbCqis.at(k));
1310 achievableRate += ((
m_amc->GetDlTbSizeFromMcs(mcs, rbgSize) / 8) /
1313 schMetric = achievableRate / (*it).second.secondLastAveragedThroughput;
1316 double metric = 0.0;
1317 metric = weight * schMetric;
1319 if (metric > metricMax)
1326 if (itMax == tdUeSet.end())
1332 allocationMap[(*itMax).first].push_back(i);
1333 rbgMap.at(i) =
true;
1347 (*itStats).second.lastTtiBytesTransmitted = 0;
1352 auto itMap = allocationMap.begin();
1353 while (itMap != allocationMap.end())
1357 newEl.
m_rnti = (*itMap).first;
1360 newDci.
m_rnti = (*itMap).first;
1368 lcActives = (uint16_t)65535;
1370 uint16_t RbgPerRnti = (*itMap).second.size();
1375 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
1378 std::vector<uint8_t> worstCqi(2, 15);
1381 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1383 if ((*itCqi).second.m_higherLayerSelected.size() > (*itMap).second.at(k))
1385 NS_LOG_INFO(
this <<
" RBG " << (*itMap).second.at(k) <<
" CQI "
1386 << (uint16_t)((*itCqi)
1387 .second.m_higherLayerSelected
1388 .at((*itMap).second.at(k))
1390 for (uint8_t j = 0; j < nLayer; j++)
1393 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1394 .m_sbCqi.size() > j)
1397 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1398 .m_sbCqi.at(j)) < worstCqi.at(j))
1402 .second.m_higherLayerSelected.at((*itMap).second.at(k))
1415 for (uint8_t j = 0; j < nLayer; j++)
1424 for (uint8_t j = 0; j < nLayer; j++)
1429 for (uint8_t j = 0; j < nLayer; j++)
1431 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" CQI selected "
1432 << (uint16_t)worstCqi.at(j));
1435 for (uint8_t j = 0; j < nLayer; j++)
1437 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1438 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RbgPerRnti * rbgSize) /
1441 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" MCS selected"
1442 <<
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1443 bytesTxed += tbSize;
1449 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1451 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
1452 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
1459 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
1460 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
1461 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
1462 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
1464 std::vector<RlcPduListElement_s> newRlcPduLe;
1465 for (uint8_t j = 0; j < nLayer; j++)
1471 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1472 newRlcPduLe.push_back(newRlcEl);
1482 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1485 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1490 if ((*itBufReq).first.m_rnti > (*itMap).first)
1495 for (uint8_t j = 0; j < nLayer; j++)
1497 newDci.
m_ndi.push_back(1);
1498 newDci.
m_rv.push_back(0);
1503 newEl.
m_dci = newDci;
1511 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1531 (*it).second.lastTtiBytesTransmitted = bytesTxed;
1532 NS_LOG_INFO(
this <<
" UE total bytes txed " << (*it).second.lastTtiBytesTransmitted);
1547 auto itUeScheduleted = tdUeSet.end();
1548 itUeScheduleted = tdUeSet.find((*itStats).first);
1549 if (itUeScheduleted != tdUeSet.end())
1551 (*itStats).second.secondLastAveragedThroughput =
1552 ((1.0 - (1 /
m_timeWindow)) * (*itStats).second.secondLastAveragedThroughput) +
1556 (*itStats).second.totalBytesTransmitted += (*itStats).second.lastTtiBytesTransmitted;
1559 (*itStats).second.lastAveragedThroughput =
1560 ((1.0 - (1.0 /
m_timeWindow)) * (*itStats).second.lastAveragedThroughput) +
1561 ((1.0 /
m_timeWindow) * (
double)((*itStats).second.lastTtiBytesTransmitted / 0.001));
1562 (*itStats).second.lastTtiBytesTransmitted = 0;
1584 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1590 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1596 params.m_cqiList.at(i).m_wbCqi.at(0);
1603 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1612 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1617 m_a30CqiRxed[rnti] = params.m_cqiList.at(i).m_sbMeasResult;
1623 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1638 auto itCqi =
m_ueCqi.find(rnti);
1648 unsigned int sinrNum = 0;
1651 double sinr = (*itCqi).second.at(i);
1658 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1660 (*itCqi).second.at(rb) = estimatedSinr;
1661 return estimatedSinr;
1669 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1670 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1677 std::vector<bool> rbMap;
1678 uint16_t rbAllocatedNum = 0;
1679 std::set<uint16_t> rntiAllocated;
1680 std::vector<uint16_t> rbgAllocationMap;
1691 for (
auto it = rbMap.begin(); it != rbMap.end(); it++)
1705 if (rbgAllocationMap.at(i) != 0)
1715 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1720 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1724 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1727 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1728 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1732 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1739 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1741 if ((*itStat).second.at(harqId) >= 3)
1743 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1761 rbgAllocationMap.at(j) = dci.
m_rnti;
1767 << (*itStat).second.at(harqId) + 1);
1771 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1776 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1777 (*itStat).second.at(harqId) = 0;
1778 (*itHarq).second.at((*itProcId).second) = dci;
1780 rntiAllocated.insert(dci.
m_rnti);
1784 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1785 << params.m_ulInfoList.at(i).m_rnti);
1790 std::map<uint16_t, uint32_t>::iterator it;
1795 auto itRnti = rntiAllocated.find((*it).first);
1797 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1816 uint16_t tempRbPerFlow = (ffrUlBandwidth) / (nflows + rntiAllocated.size());
1817 uint16_t rbPerFlow =
1818 (minContinuousUlBandwidth < tempRbPerFlow) ? minContinuousUlBandwidth : tempRbPerFlow;
1825 int rbAllocated = 0;
1848 auto itRnti = rntiAllocated.find((*it).first);
1849 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1852 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1876 uldci.
m_rnti = (*it).first;
1878 bool allocated =
false;
1879 NS_LOG_INFO(
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow
1880 <<
" flows " << nflows);
1886 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1901 NS_LOG_INFO(
this <<
"RNTI: " << (*it).first <<
" RB Allocated " << rbAllocated
1902 <<
" rbPerFlow " << rbPerFlow <<
" flows " << nflows);
1905 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1909 rbgAllocationMap.at(j) = (*it).first;
1911 rbAllocated += rbPerFlow;
1940 auto itCqi =
m_ueCqi.find((*it).first);
1951 "CQI of RNTI = " << (*it).first <<
" has expired");
1952 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1959 double sinr = (*itCqi).second.at(i);
1971 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1972 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1985 rbgAllocationMap.at(i) = 0;
2016 harqId = (*itProcId).second;
2020 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
2023 (*itDci).second.at(harqId) = uldci;
2028 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
2031 (*itStat).second.at(harqId) = 0;
2034 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
2036 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
2037 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
2038 << (uint16_t)harqId);
2052 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
2078 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
2090 for (uint8_t lcg = 0; lcg < 4; ++lcg)
2092 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
2096 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
2097 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
2107 (*it).second = buffer;
2141 switch (params.m_ulCqi.m_type)
2144 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
2145 <<
" subframe no. " << (0xF & params.m_sfnSf));
2151 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
2155 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
2159 std::vector<double> newCqi;
2164 newCqi.push_back(sinr);
2172 m_ueCqi[(*itMap).second.at(i)] = newCqi;
2179 (*itCqi).second.at(i) = sinr;
2180 NS_LOG_DEBUG(
this <<
" RNTI " << (*itMap).second.at(i) <<
" RB " << i <<
" SINR "
2194 NS_ASSERT(!params.m_vendorSpecificList.empty());
2195 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
2201 rnti = vsp->GetRnti();
2204 auto itCqi =
m_ueCqi.find(rnti);
2208 std::vector<double> newCqi;
2212 newCqi.push_back(sinr);
2213 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
2226 (*itCqi).second.at(j) = sinr;
2227 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
2239 NS_FATAL_ERROR(
"PssFfMacScheduler supports only PUSCH and SRS UL-CQIs");
2254 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
2256 if ((*itP10).second == 0)
2261 " Does not find CQI report for user " << (*itP10).first);
2262 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
2279 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
2281 if ((*itA30).second == 0)
2286 " Does not find CQI report for user " << (*itA30).first);
2287 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
2308 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
2310 if ((*itUl).second == 0)
2313 auto itMap =
m_ueCqi.find((*itUl).first);
2315 " Does not find CQI report for user " << (*itUl).first);
2316 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
2317 (*itMap).second.clear();
2338 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
2339 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
2340 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
2341 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
2344 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
2346 (*it).second.m_rlcStatusPduSize = 0;
2348 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
2349 (size >= (*it).second.m_rlcRetransmissionQueueSize))
2351 (*it).second.m_rlcRetransmissionQueueSize = 0;
2353 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
2370 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
2372 (*it).second.m_rlcTransmissionQueueSize = 0;
2376 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
2382 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
2393 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
2394 if ((*it).second >= size)
2396 (*it).second -= size;
2405 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
2412 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
2414 params.m_rnti = rnti;
2415 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...
virtual uint8_t GetTpc(uint16_t rnti)=0
GetTpc.
virtual std::vector< bool > GetAvailableUlRbg()=0
Get vector of available RB in UL for this Cell.
virtual void ReportUlCqiInfo(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)=0
ReportUlCqiInfo.
virtual bool IsUlRbgAvailableForUe(int i, uint16_t rnti)=0
Check if UE can be served on i-th RB in UL.
virtual void ReportDlCqiInfo(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)=0
ReportDlCqiInfo.
virtual std::vector< bool > GetAvailableDlRbg()=0
Get vector of available RBG in DL for this Cell.
virtual uint16_t GetMinContinuousUlBandwidth()=0
Get the minimum continuous Ul bandwidth.
virtual bool IsDlRbgAvailableForUe(int i, uint16_t rnti)=0
Check if UE can be served on i-th RB in DL.
Service Access Point (SAP) offered by the eNodeB RRC instance to the Frequency Reuse algorithm instan...
Template for the implementation of the LteFfrSapUser as a member of an owner class of type C to which...
Implements the SCHED SAP and CSCHED SAP for a Priority Set scheduler.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
void DoDispose() override
Destructor implementation.
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request function.
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SINR function.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
std::vector< RachListElement_s > m_rachList
RACH list.
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request function.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
LteFfrSapUser * GetLteFfrSapUser() override
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request function.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request function.
friend class MemberSchedSapProvider< PssFfMacScheduler >
allow MemberSchedSapProvider<PssFfMacScheduler> class friend access
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request function.
unsigned int LcActivePerFlow(uint16_t rnti)
Get LC active flow function.
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request function.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
static TypeId GetTypeId()
Get the type ID.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request function.
uint32_t m_cqiTimersThreshold
void RefreshDlCqiMaps()
Refresh DL CQI maps function.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
CSched cell config 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)
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
uint32_t m_nMux
TD scheduler selects nMux UEs and transfer them to FD scheduler.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
set the user part of the FfMacCschedSap that this Scheduler will interact with.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
CSched cell config.
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request function.
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request function.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
~PssFfMacScheduler() override
Destructor.
std::string m_fdSchedulerType
FD scheduler type.
void RefreshUlCqiMaps()
Refresh UL CQI maps function.
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RLC buffer info function.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info function.
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmission mode configuration update function.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
int GetRbgSize(int dlbandwidth)
Get RBG size function.
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current proess ID.
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ process ID.
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request function.
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
FfMacSchedSapUser * m_schedSapUser
Sched SAP user.
FfMacCschedSapUser * m_cschedSapUser
CSched SAP user.
PssFfMacScheduler()
Constructor.
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request function.
FfMacSchedSapProvider * m_schedSapProvider
Sched SAP provider.
friend class MemberCschedSapProvider< PssFfMacScheduler >
allow MemberCschedSapProvider<PssFfMacScheduler> class friend access
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request function.
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
std::map< uint16_t, pssFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request function.
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request function.
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ ELC PDU list buffer.
double m_timeWindow
time window
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request function.
std::map< uint16_t, pssFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
void SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
set the user part of the FfMacSchedSap that this Scheduler will interact with.
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set the Provider part of the LteFfrSap that this Scheduler will interact with.
Smart pointer class similar to boost::intrusive_ptr.
static Time Now()
Return the current simulation virtual time.
Hold variables of type string.
static uint8_t TxMode2LayerNum(uint8_t txMode)
Transmit mode 2 layer number.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Hold an unsigned integer type.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeChecker > MakeBooleanChecker()
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector.
Ptr< const AttributeChecker > 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 AttributeChecker > MakeStringChecker()
Ptr< const AttributeAccessor > MakeStringAccessor(T1 a1)
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
std::vector< RlcPduList_t > DlHarqRlcPduListBuffer_t
Vector of the 8 HARQ processes per UE.
static const int PssType0AllocationRbg[4]
PSS 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?
double secondLastAveragedThroughput
Second last average throughput.
double lastAveragedThroughput
Past average throughput.
double targetThroughput
Target throughput.
Time flowStart
flow start time
unsigned int lastTtiBytesTransmitted
Total bytes send by eNB in last tti for this UE.
unsigned long totalBytesTransmitted
Total bytes send by eNb for this UE.