15#include "ns3/boolean.h"
16#include "ns3/integer.h"
19#include "ns3/pointer.h"
20#include "ns3/simulator.h"
78 TypeId(
"ns3::FdTbfqFfMacScheduler")
82 .AddAttribute(
"CqiTimerThreshold",
83 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
87 .AddAttribute(
"DebtLimit",
88 "Flow debt limit (default -625000 bytes)",
92 .AddAttribute(
"CreditLimit",
93 "Flow credit limit (default 625000 bytes)",
97 .AddAttribute(
"TokenPoolSize",
98 "The maximum value of flow token pool (default 1 bytes)",
102 .AddAttribute(
"CreditableThreshold",
103 "Threshold of flow credit (default 0 bytes)",
108 .AddAttribute(
"HarqEnabled",
109 "Activate/Deactivate the HARQ [by default is active].",
113 .AddAttribute(
"UlGrantMcs",
114 "The MCS of the UL grant, must be [0..15] (default 0)",
175 << (uint16_t)params.m_transmissionMode);
179 m_uesTxMode.insert(std::pair<uint16_t, double>(params.m_rnti, params.m_transmissionMode));
183 dlHarqPrcStatus.resize(8, 0);
186 dlHarqProcessesTimer.resize(8, 0);
192 dlHarqRlcPdu.resize(2);
193 dlHarqRlcPdu.at(0).resize(8);
194 dlHarqRlcPdu.at(1).resize(8);
198 ulHarqPrcStatus.resize(8, 0);
206 (*it).second = params.m_transmissionMode;
216 for (std::size_t i = 0; i < params.m_logicalChannelConfigList.size(); i++)
222 uint64_t mbrDlInBytes =
223 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateDl / 8;
224 uint64_t mbrUlInBytes =
225 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateUl / 8;
226 NS_LOG_DEBUG(
"mbrDlInBytes: " << mbrDlInBytes <<
" mbrUlInBytes: " << mbrUlInBytes);
239 std::pair<uint16_t, fdtbfqsFlowPerf_t>(params.m_rnti, flowStatsDl));
251 std::pair<uint16_t, fdtbfqsFlowPerf_t>(params.m_rnti, flowStatsUl));
256 uint64_t mbrDlInBytes =
257 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateDl / 8;
258 uint64_t mbrUlInBytes =
259 params.m_logicalChannelConfigList.at(i).m_eRabMaximulBitrateUl / 8;
260 NS_LOG_DEBUG(
"mbrDlInBytes: " << mbrDlInBytes <<
" mbrUlInBytes: " << mbrUlInBytes);
261 m_flowStatsDl[(*it).first].tokenGenerationRate = mbrDlInBytes;
262 m_flowStatsUl[(*it).first].tokenGenerationRate = mbrUlInBytes;
272 for (std::size_t i = 0; i < params.m_logicalChannelIdentity.size(); i++)
277 if (((*it).first.m_rnti == params.m_rnti) &&
278 ((*it).first.m_lcId == params.m_logicalChannelIdentity.at(i)))
313 if ((*it).first.m_rnti == params.m_rnti)
337 LteFlowId_t flow(params.m_rnti, params.m_logicalChannelIdentity);
347 (*it).second = params;
370 for (
int i = 0; i < 4; i++)
384 unsigned int lcActive = 0;
387 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0) ||
388 ((*it).second.m_rlcRetransmissionQueueSize > 0) ||
389 ((*it).second.m_rlcStatusPduSize > 0)))
393 if ((*it).first.m_rnti > rnti)
414 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
416 uint8_t i = (*it).second;
420 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
422 return (*itStat).second.at(i) == 0;
443 NS_FATAL_ERROR(
"No Process Id Statusfound for this RNTI " << rnti);
445 uint8_t i = (*it).second;
449 }
while (((*itStat).second.at(i) != 0) && (i != (*it).second));
450 if ((*itStat).second.at(i) == 0)
453 (*itStat).second.at(i) = 1;
458 << rnti <<
" check before update with HarqProcessAvailability");
478 NS_LOG_DEBUG(
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
483 << (*itTimers).first);
485 (*itStat).second.at(i) = 0;
486 (*itTimers).second.at(i) = 0;
490 (*itTimers).second.at(i)++;
500 NS_LOG_FUNCTION(
this <<
" Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
501 << (0xF & params.m_sfnSf));
512 std::map<uint16_t, std::vector<uint16_t>> allocationMap;
513 std::vector<bool> rbgMap;
514 uint16_t rbgAllocatedNum = 0;
515 std::set<uint16_t> rntiAllocated;
519 for (
auto it = rbgMap.begin(); it != rbgMap.end(); it++)
534 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
538 std::vector<bool> ulRbMap;
541 uint8_t maxContinuousUlBandwidth = 0;
542 uint8_t tmpMinBandwidth = 0;
543 uint16_t ffrRbStartOffset = 0;
544 uint16_t tmpFfrRbStartOffset = 0;
547 for (
auto it = ulRbMap.begin(); it != ulRbMap.end(); it++)
551 if (tmpMinBandwidth > maxContinuousUlBandwidth)
553 maxContinuousUlBandwidth = tmpMinBandwidth;
554 ffrRbStartOffset = tmpFfrRbStartOffset;
560 if (tmpMinBandwidth == 0)
562 tmpFfrRbStartOffset = index;
569 if (tmpMinBandwidth > maxContinuousUlBandwidth)
571 maxContinuousUlBandwidth = tmpMinBandwidth;
572 ffrRbStartOffset = tmpFfrRbStartOffset;
576 uint16_t rbStart = 0;
577 rbStart = ffrRbStartOffset;
581 (*itRach).m_estimatedSize,
582 " Default UL Grant MCS does not allow to send RACH messages");
584 newRar.
m_rnti = (*itRach).m_rnti;
591 uint16_t tbSizeBits = 0;
593 while ((tbSizeBits < (*itRach).m_estimatedSize) &&
594 (rbStart + rbLen < (ffrRbStartOffset + maxContinuousUlBandwidth)))
599 if (tbSizeBits < (*itRach).m_estimatedSize)
611 NS_LOG_INFO(
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart "
612 << rbStart <<
" rbLen " << rbLen <<
" MCS " << (uint16_t)
m_ulGrantMcs
614 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
647 harqId = (*itProcId).second;
651 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
654 (*itDci).second.at(harqId) = uldci;
657 rbStart = rbStart + rbLen;
667 if (!params.m_dlInfoList.empty())
671 params.m_dlInfoList.begin(),
672 params.m_dlInfoList.end());
677 if (!params.m_dlInfoList.empty())
687 std::vector<DlInfoListElement_s> dlInfoListUntxed;
691 if (itRnti != rntiAllocated.end())
697 std::vector<bool> retx;
698 NS_LOG_INFO(
this <<
" Processing DLHARQ feedback");
703 retx.push_back(
false);
712 if (retx.at(0) || retx.at(1))
717 NS_LOG_INFO(
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
726 if (dci.
m_rv.size() == 1)
738 NS_LOG_INFO(
"Maximum number of retransmissions reached -> drop process");
742 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
745 (*it).second.at(harqId) = 0;
749 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
752 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
754 (*itRlcPdu).second.at(k).at(harqId).clear();
760 std::vector<int> dciRbg;
763 for (
int j = 0; j < 32; j++)
773 for (std::size_t j = 0; j < dciRbg.size(); j++)
775 if (rbgMap.at(dciRbg.at(j)))
785 for (std::size_t j = 0; j < dciRbg.size(); j++)
787 rbgMap.at(dciRbg.at(j)) =
true;
788 NS_LOG_INFO(
"RBG " << dciRbg.at(j) <<
" assigned");
792 NS_LOG_INFO(
this <<
" Send retx in the same RBGs");
798 uint8_t rbgId = (dciRbg.at(dciRbg.size() - 1) + 1) % rbgNum;
799 uint8_t startRbg = dciRbg.at(dciRbg.size() - 1);
800 std::vector<bool> rbgMapCopy = rbgMap;
801 while ((j < dciRbg.size()) && (startRbg != rbgId))
803 if (!rbgMapCopy.at(rbgId))
805 rbgMapCopy.at(rbgId) =
true;
806 dciRbg.at(j) = rbgId;
809 rbgId = (rbgId + 1) % rbgNum;
811 if (j == dciRbg.size())
815 for (std::size_t k = 0; k < dciRbg.size(); k++)
817 rbgMask = rbgMask + (0x1 << dciRbg.at(k));
822 NS_LOG_INFO(
this <<
" Move retx in RBGs " << dciRbg.size());
828 NS_LOG_INFO(
this <<
" No resource for this retx -> buffer it");
836 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
838 for (std::size_t j = 0; j < nLayers; j++)
842 if (j >= dci.
m_ndi.size())
845 dci.
m_ndi.push_back(0);
846 dci.
m_rv.push_back(0);
847 dci.
m_mcs.push_back(0);
850 <<
" no txed (MIMO transition)");
856 (*itHarq).second.at(harqId).m_rv.at(j)++;
857 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" RV "
858 << (uint16_t)dci.
m_rv.at(j));
868 NS_LOG_INFO(
this <<
" layer " << (uint16_t)j <<
" no retx");
871 for (std::size_t k = 0; k < (*itRlcPdu).second.at(0).at(dci.
m_harqProcess).size(); k++)
873 std::vector<RlcPduListElement_s> rlcPduListPerLc;
874 for (std::size_t j = 0; j < nLayers; j++)
878 if (j < dci.
m_ndi.size())
880 NS_LOG_INFO(
" layer " << (uint16_t)j <<
" tb size "
882 rlcPduListPerLc.push_back(
895 .m_logicalChannelIdentity;
897 rlcPduListPerLc.push_back(emptyElement);
901 if (!rlcPduListPerLc.empty())
908 (*itHarq).second.at(harqId).
m_rv = dci.
m_rv;
913 NS_FATAL_ERROR(
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
915 (*itHarqTimer).second.at(harqId) = 0;
917 rntiAllocated.insert(rnti);
934 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
937 for (std::size_t k = 0; k < (*itRlcPdu).second.size(); k++)
946 if (rbgAllocatedNum == rbgNum)
959 if ((*itStats).second.tokenGenerationRate / 1000 + (*itStats).second.tokenPoolSize >
960 (*itStats).second.maxTokenPoolSize)
962 (*itStats).second.counter +=
963 (*itStats).second.tokenGenerationRate / 1000 -
964 ((*itStats).second.maxTokenPoolSize - (*itStats).second.tokenPoolSize);
965 (*itStats).second.tokenPoolSize = (*itStats).second.maxTokenPoolSize;
966 bankSize += (*itStats).second.tokenGenerationRate / 1000 -
967 ((*itStats).second.maxTokenPoolSize - (*itStats).second.tokenPoolSize);
971 (*itStats).second.tokenPoolSize += (*itStats).second.tokenGenerationRate / 1000;
975 std::set<uint16_t> allocatedRnti;
976 std::set<uint8_t> allocatedRbg;
979 while (totalRbg < rbgNum)
982 std::map<uint16_t, fdtbfqsFlowPerf_t>::iterator it;
984 double metricMax = 0.0;
985 bool firstRnti =
true;
988 auto itRnti = rntiAllocated.find((*it).first);
992 if (itRnti != rntiAllocated.end())
994 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ tx" << (uint16_t)(*it).first);
998 NS_LOG_DEBUG(
this <<
" RNTI discarded for HARQ id" << (uint16_t)(*it).first);
1007 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1012 for (
int k = 0; k < rbgNum; k++)
1014 for (uint8_t j = 0; j < nLayer; j++)
1022 cqiSum += (*itCqi).second.m_higherLayerSelected.at(k).m_sbCqi.at(j);
1029 NS_LOG_INFO(
"Skip this flow, CQI==0, rnti:" << (*it).first);
1038 auto rnti = allocatedRnti.find((*it).first);
1039 if (rnti != allocatedRnti.end())
1045 (((
double)(*it).second.counter) / ((
double)(*it).second.tokenGenerationRate));
1054 if (metric > metricMax)
1069 allocatedRnti.insert((*itMax).first);
1075 budget = (*itMax).second.counter - (*itMax).second.debtLimit;
1076 if (budget > (*itMax).second.burstCredit)
1078 budget = (*itMax).second.burstCredit;
1085 budget = budget + (*itMax).second.tokenPoolSize;
1101 if ((*itRlcBuf).first.m_rnti == (*itMax).first)
1103 lcid = (*itRlcBuf).first.m_lcId;
1110 rlcBufSize = (*itRlcBuf).second.m_rlcTransmissionQueueSize +
1111 (*itRlcBuf).second.m_rlcRetransmissionQueueSize +
1112 (*itRlcBuf).second.m_rlcStatusPduSize;
1114 if (budget > rlcBufSize)
1116 budget = rlcBufSize;
1118 <<
" RLC buffer size: " << rlcBufSize);
1126 while (bytesTxed <= budget)
1134 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*it).first);
1139 double achievableRateMax = 0.0;
1141 for (
int k = 0; k < rbgNum; k++)
1143 auto rbg = allocatedRbg.find(k);
1144 if (rbg != allocatedRbg.end())
1159 std::vector<uint8_t> sbCqi;
1162 sbCqi = std::vector<uint8_t>(nLayer, 1);
1166 sbCqi = (*itCqi).second.m_higherLayerSelected.at(k).m_sbCqi;
1168 uint8_t cqi1 = sbCqi.at(0);
1170 if (sbCqi.size() > 1)
1181 double achievableRate = 0.0;
1182 for (uint8_t j = 0; j < nLayer; j++)
1185 if (sbCqi.size() > j)
1187 mcs =
m_amc->GetMcsFromCqi(sbCqi.at(j));
1194 achievableRate += ((
m_amc->GetDlTbSizeFromMcs(mcs, rbgSize) / 8) /
1198 if (achievableRate > achievableRateMax)
1200 achievableRateMax = achievableRate;
1207 if (rbgIndex == rbgNum)
1216 allocatedRbg.insert(rbgIndex);
1220 auto itMap = allocationMap.find((*itMax).first);
1221 uint16_t RbgPerRnti;
1222 if (itMap == allocationMap.end())
1225 std::vector<uint16_t> tempMap;
1226 tempMap.push_back(rbgIndex);
1227 allocationMap[(*itMax).first] = tempMap;
1228 itMap = allocationMap.find(
1233 (*itMap).second.push_back(rbgIndex);
1235 rbgMap.at(rbgIndex) =
true;
1237 RbgPerRnti = (*itMap).second.size();
1240 std::vector<uint8_t> worstCqi(2, 15);
1243 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1245 if ((*itCqi).second.m_higherLayerSelected.size() > (*itMap).second.at(k))
1247 for (uint8_t j = 0; j < nLayer; j++)
1250 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1251 .m_sbCqi.size() > j)
1254 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1255 .m_sbCqi.at(j)) < worstCqi.at(j))
1259 .second.m_higherLayerSelected.at((*itMap).second.at(k))
1272 for (uint8_t j = 0; j < nLayer; j++)
1282 for (uint8_t j = 0; j < nLayer; j++)
1288 bytesTxedTmp = bytesTxed;
1290 for (uint8_t j = 0; j < nLayer; j++)
1292 int tbSize = (
m_amc->GetDlTbSizeFromMcs(
m_amc->GetMcsFromCqi(worstCqi.at(j)),
1293 RbgPerRnti * rbgSize) /
1295 bytesTxed += tbSize;
1300 if (bytesTxed > budget)
1302 NS_LOG_DEBUG(
"budget: " << budget <<
" bytesTxed: " << bytesTxed <<
" at "
1304 auto itMap = allocationMap.find((*itMax).first);
1305 (*itMap).second.pop_back();
1306 allocatedRbg.erase(rbgIndex);
1307 bytesTxed = bytesTxedTmp;
1309 rbgMap.at(rbgIndex) =
false;
1312 if ((*itMap).second.empty())
1314 itMap = allocationMap.erase(itMap);
1319 if (allocationMap.find((*itMax).first) != allocationMap.end())
1322 if (bytesTxed <= (*itMax).second.tokenPoolSize)
1324 (*itMax).second.tokenPoolSize -= bytesTxed;
1328 (*itMax).second.counter =
1329 (*itMax).second.counter - (bytesTxed - (*itMax).second.tokenPoolSize);
1330 (*itMax).second.tokenPoolSize = 0;
1331 if (
bankSize <= (bytesTxed - (*itMax).second.tokenPoolSize))
1345 auto itMap = allocationMap.begin();
1346 while (itMap != allocationMap.end())
1348 NS_LOG_DEBUG(
"Preparing DCI for RNTI " << (*itMap).first);
1351 newEl.
m_rnti = (*itMap).first;
1354 newDci.
m_rnti = (*itMap).first;
1362 lcActives = (uint16_t)65535;
1364 uint16_t RbgPerRnti = (*itMap).second.size();
1369 NS_FATAL_ERROR(
"No Transmission Mode info on user " << (*itMap).first);
1372 std::vector<uint8_t> worstCqi(2, 15);
1375 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1377 if ((*itCqi).second.m_higherLayerSelected.size() > (*itMap).second.at(k))
1379 NS_LOG_INFO(
this <<
" RBG " << (*itMap).second.at(k) <<
" CQI "
1380 << (uint16_t)((*itCqi)
1381 .second.m_higherLayerSelected
1382 .at((*itMap).second.at(k))
1384 for (uint8_t j = 0; j < nLayer; j++)
1387 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1388 .m_sbCqi.size() > j)
1391 .
second.m_higherLayerSelected.at((*itMap).second.at(k))
1392 .m_sbCqi.at(j)) < worstCqi.at(j))
1396 .second.m_higherLayerSelected.at((*itMap).second.at(k))
1409 for (uint8_t j = 0; j < nLayer; j++)
1418 for (uint8_t j = 0; j < nLayer; j++)
1423 for (uint8_t j = 0; j < nLayer; j++)
1425 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" CQI selected "
1426 << (uint16_t)worstCqi.at(j));
1428 for (uint8_t j = 0; j < nLayer; j++)
1430 newDci.
m_mcs.push_back(
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1431 int tbSize = (
m_amc->GetDlTbSizeFromMcs(newDci.
m_mcs.at(j), RbgPerRnti * rbgSize) /
1434 NS_LOG_INFO(
this <<
" Layer " << (uint16_t)j <<
" MCS selected"
1435 << (uint16_t)
m_amc->GetMcsFromCqi(worstCqi.at(j)));
1441 for (std::size_t k = 0; k < (*itMap).second.size(); k++)
1443 rbgMask = rbgMask + (0x1 << (*itMap).second.at(k));
1444 NS_LOG_INFO(
this <<
" Allocated RBG " << (*itMap).second.at(k));
1451 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
1452 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0) ||
1453 ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0) ||
1454 ((*itBufReq).second.m_rlcStatusPduSize > 0)))
1456 std::vector<RlcPduListElement_s> newRlcPduLe;
1457 for (uint8_t j = 0; j < nLayer; j++)
1463 <<
" size " << newRlcEl.
m_size <<
" layer " << (uint16_t)j);
1464 newRlcPduLe.push_back(newRlcEl);
1474 NS_FATAL_ERROR(
"Unable to find RlcPdcList in HARQ buffer for RNTI "
1477 (*itRlcPdu).second.at(j).at(newDci.
m_harqProcess).push_back(newRlcEl);
1482 if ((*itBufReq).first.m_rnti > (*itMap).first)
1487 for (uint8_t j = 0; j < nLayer; j++)
1489 newDci.
m_ndi.push_back(1);
1490 newDci.
m_rv.push_back(0);
1495 newEl.
m_dci = newDci;
1503 NS_FATAL_ERROR(
"Unable to find RNTI entry in DCI HARQ buffer for RNTI "
1543 for (
unsigned int i = 0; i < params.m_cqiList.size(); i++)
1549 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1555 params.m_cqiList.at(i).m_wbCqi.at(0);
1562 (*it).second = params.m_cqiList.at(i).m_wbCqi.at(0);
1571 uint16_t rnti = params.m_cqiList.at(i).m_rnti;
1576 m_a30CqiRxed[rnti] = params.m_cqiList.at(i).m_sbMeasResult;
1582 (*it).second = params.m_cqiList.at(i).m_sbMeasResult;
1597 auto itCqi =
m_ueCqi.find(rnti);
1607 unsigned int sinrNum = 0;
1610 double sinr = (*itCqi).second.at(i);
1617 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1619 (*itCqi).second.at(rb) = estimatedSinr;
1620 return estimatedSinr;
1628 NS_LOG_FUNCTION(
this <<
" UL - Frame no. " << (params.m_sfnSf >> 4) <<
" subframe no. "
1629 << (0xF & params.m_sfnSf) <<
" size " << params.m_ulInfoList.size());
1636 std::vector<bool> rbMap;
1637 uint16_t rbAllocatedNum = 0;
1638 std::set<uint16_t> rntiAllocated;
1639 std::vector<uint16_t> rbgAllocationMap;
1650 for (
auto it = rbMap.begin(); it != rbMap.end(); it++)
1658 uint8_t minContinuousUlBandwidth =
m_ffrSapProvider->GetMinContinuousUlBandwidth();
1664 if (rbgAllocationMap.at(i) != 0)
1674 for (std::size_t i = 0; i < params.m_ulInfoList.size(); i++)
1679 uint16_t rnti = params.m_ulInfoList.at(i).m_rnti;
1683 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1686 NS_LOG_INFO(
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId
1687 <<
" i " << i <<
" size " << params.m_ulInfoList.size());
1691 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1698 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1700 if ((*itStat).second.at(harqId) >= 3)
1702 NS_LOG_INFO(
"Max number of retransmissions reached (UL)-> drop process");
1720 rbgAllocationMap.at(j) = dci.
m_rnti;
1726 << (*itStat).second.at(harqId) + 1);
1730 NS_LOG_INFO(
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1735 (*itStat).second.at((*itProcId).second) = (*itStat).second.at(harqId) + 1;
1736 (*itStat).second.at(harqId) = 0;
1737 (*itHarq).second.at((*itProcId).second) = dci;
1739 rntiAllocated.insert(dci.
m_rnti);
1743 NS_LOG_INFO(
this <<
" HARQ-ACK feedback from RNTI "
1744 << params.m_ulInfoList.at(i).m_rnti);
1749 std::map<uint16_t, uint32_t>::iterator it;
1754 auto itRnti = rntiAllocated.find((*it).first);
1756 if (((*it).second > 0) && (itRnti == rntiAllocated.end()))
1775 uint16_t tempRbPerFlow = (ffrUlBandwidth) / (nflows + rntiAllocated.size());
1776 uint16_t rbPerFlow =
1777 (minContinuousUlBandwidth < tempRbPerFlow) ? minContinuousUlBandwidth : tempRbPerFlow;
1784 int rbAllocated = 0;
1807 auto itRnti = rntiAllocated.find((*it).first);
1808 if ((itRnti != rntiAllocated.end()) || ((*it).second == 0))
1811 NS_LOG_DEBUG(
this <<
" UE already allocated in HARQ -> discarded, RNTI "
1835 uldci.
m_rnti = (*it).first;
1837 bool allocated =
false;
1838 NS_LOG_INFO(
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow
1839 <<
" flows " << nflows);
1840 while ((!allocated) && ((rbAllocated + rbPerFlow -
m_cschedCellConfig.m_ulBandwidth) < 1) &&
1845 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1860 NS_LOG_INFO(
this <<
"RNTI: " << (*it).first <<
" RB Allocated " << rbAllocated
1861 <<
" rbPerFlow " << rbPerFlow <<
" flows " << nflows);
1864 for (
int j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1868 rbgAllocationMap.at(j) = (*it).first;
1870 rbAllocated += rbPerFlow;
1899 auto itCqi =
m_ueCqi.find((*it).first);
1910 "CQI of RNTI = " << (*it).first <<
" has expired");
1911 double minSinr = (*itCqi).second.at(uldci.
m_rbStart);
1918 double sinr = (*itCqi).second.at(i);
1930 double s = log2(1 + (std::pow(10, minSinr / 10) / ((-std::log(5.0 * 0.00005)) / 1.5)));
1931 cqi =
m_amc->GetCqiFromSpectralEfficiency(s);
1944 rbgAllocationMap.at(i) = 0;
1975 harqId = (*itProcId).second;
1979 NS_FATAL_ERROR(
"Unable to find RNTI entry in UL DCI HARQ buffer for RNTI "
1982 (*itDci).second.at(harqId) = uldci;
1987 NS_LOG_ERROR(
"No info find in HARQ buffer for UE (might change eNB) "
1990 (*itStat).second.at(harqId) = 0;
1993 NS_LOG_INFO(
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB "
1995 <<
" CQI " << cqi <<
" MCS " << (
uint32_t)uldci.
m_mcs <<
" TBsize "
1996 << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId "
1997 << (uint16_t)harqId);
2011 }
while (((*it).first !=
m_nextRntiUl) && (rbPerFlow != 0));
2037 for (
unsigned int i = 0; i < params.m_macCeList.size(); i++)
2049 for (uint8_t lcg = 0; lcg < 4; ++lcg)
2051 uint8_t bsrId = params.m_macCeList.at(i).m_macCeValue.m_bufferStatus.at(lcg);
2055 uint16_t rnti = params.m_macCeList.at(i).m_rnti;
2056 NS_LOG_LOGIC(
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
2061 m_ceBsrRxed.insert(std::pair<uint16_t, uint32_t>(rnti, buffer));
2066 (*it).second = buffer;
2100 switch (params.m_ulCqi.m_type)
2103 NS_LOG_DEBUG(
this <<
" Collect PUSCH CQIs of Frame no. " << (params.m_sfnSf >> 4)
2104 <<
" subframe no. " << (0xF & params.m_sfnSf));
2110 for (
uint32_t i = 0; i < (*itMap).second.size(); i++)
2114 auto itCqi =
m_ueCqi.find((*itMap).second.at(i));
2118 std::vector<double> newCqi;
2123 newCqi.push_back(sinr);
2131 m_ueCqi[(*itMap).second.at(i)] = newCqi;
2138 (*itCqi).second.at(i) = sinr;
2139 NS_LOG_DEBUG(
this <<
" RNTI " << (*itMap).second.at(i) <<
" RB " << i <<
" SINR "
2153 NS_ASSERT(!params.m_vendorSpecificList.empty());
2154 for (std::size_t i = 0; i < params.m_vendorSpecificList.size(); i++)
2160 rnti = vsp->GetRnti();
2163 auto itCqi =
m_ueCqi.find(rnti);
2167 std::vector<double> newCqi;
2171 newCqi.push_back(sinr);
2172 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value "
2175 m_ueCqi.insert(std::pair<uint16_t, std::vector<double>>(rnti, newCqi));
2185 (*itCqi).second.at(j) = sinr;
2186 NS_LOG_INFO(
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value "
2198 NS_FATAL_ERROR(
"FdTbfqFfMacScheduler supports only PUSCH and SRS UL-CQIs");
2213 NS_LOG_INFO(
this <<
" P10-CQI for user " << (*itP10).first <<
" is "
2215 if ((*itP10).second == 0)
2220 " Does not find CQI report for user " << (*itP10).first);
2221 NS_LOG_INFO(
this <<
" P10-CQI expired for user " << (*itP10).first);
2238 NS_LOG_INFO(
this <<
" A30-CQI for user " << (*itA30).first <<
" is "
2240 if ((*itA30).second == 0)
2245 " Does not find CQI report for user " << (*itA30).first);
2246 NS_LOG_INFO(
this <<
" A30-CQI expired for user " << (*itA30).first);
2267 NS_LOG_INFO(
this <<
" UL-CQI for user " << (*itUl).first <<
" is "
2269 if ((*itUl).second == 0)
2272 auto itMap =
m_ueCqi.find((*itUl).first);
2274 " Does not find CQI report for user " << (*itUl).first);
2275 NS_LOG_INFO(
this <<
" UL-CQI exired for user " << (*itUl).first);
2276 (*itMap).second.clear();
2297 NS_LOG_INFO(
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue "
2298 << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue "
2299 << (*it).second.m_rlcRetransmissionQueueSize <<
" status "
2300 << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
2303 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
2305 (*it).second.m_rlcStatusPduSize = 0;
2307 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) &&
2308 (size >= (*it).second.m_rlcRetransmissionQueueSize))
2310 (*it).second.m_rlcRetransmissionQueueSize = 0;
2312 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
2329 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
2331 (*it).second.m_rlcTransmissionQueueSize = 0;
2335 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
2341 NS_LOG_ERROR(
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
2352 NS_LOG_INFO(
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
2353 if ((*it).second >= size)
2355 (*it).second -= size;
2364 NS_LOG_ERROR(
this <<
" Does not find BSR report info of UE " << rnti);
2371 NS_LOG_FUNCTION(
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
2373 params.m_rnti = rnti;
2374 params.m_transmissionMode = txMode;
static uint32_t BsrId2BufferSize(uint8_t val)
Convert BSR ID to buffer size.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
uint32_t m_tokenPoolSize
maximum size of token pool (byte)
std::map< uint16_t, fdtbfqsFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
void DoSchedDlPagingBufferReq(const FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request function.
static TypeId GetTypeId()
Get the type ID.
bool HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
uint64_t bankSize
the number of bytes in token bank
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
void SetFfMacCschedSapUser(FfMacCschedSapUser *s) override
Set FF MAC Csched SAP user function.
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
friend class MemberSchedSapProvider< FdTbfqFfMacScheduler >
allow MemberSchedSapProvider<FdTbfqFfMacScheduler> claass friend access
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
LteFfrSapUser * GetLteFfrSapUser() override
Get FFR SAP user function.
~FdTbfqFfMacScheduler() override
Destructor.
void DoCschedLcConfigReq(const FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request function.
void DoSchedDlMacBufferReq(const FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request function.
uint32_t m_cqiTimersThreshold
uint32_t m_creditableThreshold
threshold of flow credit
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info function.
void SetFfMacSchedSapUser(FfMacSchedSapUser *s) override
Set FF MAC sched SAP user function.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current process ID.
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
Csched cell config.
void RefreshDlCqiMaps()
Refresh DL CQI maps function.
void DoDispose() override
Destructor implementation.
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SNR function.
std::vector< RachListElement_s > m_rachList
RACH list.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
void SetLteFfrSapProvider(LteFfrSapProvider *s) override
Set FFR SAP provider function.
FfMacCschedSapProvider * GetFfMacCschedSapProvider() override
Get FF MAC CSched SAP provider function.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmission mode config update function.
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
uint32_t m_creditLimit
flow credit limit (byte)
void DoSchedDlRlcBufferReq(const FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request function.
int m_debtLimit
flow debt limit (byte)
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
void DoSchedUlNoiseInterferenceReq(const FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request function.
void RefreshUlCqiMaps()
Refresh UL CQI maps function.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
void DoSchedDlRachInfoReq(const FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request function.
FfMacSchedSapProvider * m_schedSapProvider
sched SAP provider
FdTbfqFfMacScheduler()
Constructor.
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU list buffer.
void DoSchedUlMacCtrlInfoReq(const FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request function.
void DoSchedUlCqiInfoReq(const FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request function.
void DoCschedLcReleaseReq(const FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request function.
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
void DoSchedDlCqiInfoReq(const FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request function.
std::map< uint16_t, fdtbfqsFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
FfMacSchedSapProvider * GetFfMacSchedSapProvider() override
Get FF MAC sched SAP provider function.
void DoCschedUeConfigReq(const FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request function.
FfMacSchedSapUser * m_schedSapUser
sched SAP user
void DoCschedCellConfigReq(const FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
Csched cell config request function.
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
std::map< uint16_t, std::vector< uint16_t > > m_allocationMaps
Map of previous allocated UE per RBG (used to retrieve info from UL-CQI)
unsigned int LcActivePerFlow(uint16_t rnti)
LC Active per flow function.
void DoCschedUeReleaseReq(const FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request function.
void DoSchedUlSrInfoReq(const FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request function.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
FfMacCschedSapUser * m_cschedSapUser
Csched SAP user.
friend class MemberCschedSapProvider< FdTbfqFfMacScheduler >
allow MemberCschedSapProvider<FdTbfqFfMacScheduler> class friend access
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RLC buffer info function.
int GetRbgSize(int dlbandwidth)
Get RBG size function.
void DoSchedUlTriggerReq(const FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request function.
void DoSchedDlTriggerReq(const FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request function.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
FfMacCschedSapUser class.
FfMacScheduler()
constructor
UlCqiFilter_t m_ulCqiFilter
UL CQI filter.
Hold a signed integer type.
static double fpS11dot3toDouble(uint16_t val)
Convert from fixed point S11.3 notation to double.
Service Access Point (SAP) offered by the Frequency Reuse algorithm instance to the MAC Scheduler ins...
Service Access Point (SAP) offered by the eNodeB RRC instance to the Frequency Reuse algorithm instan...
Template for the implementation of the LteFfrSapUser as a member of an owner class of type C to which...
Smart pointer class similar to boost::intrusive_ptr.
static Time Now()
Return the current simulation virtual time.
static uint8_t TxMode2LayerNum(uint8_t txMode)
Transmit mode 2 layer number.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Hold an unsigned integer type.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeChecker > MakeBooleanChecker()
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector.
Ptr< const AttributeChecker > MakeIntegerChecker()
Ptr< const AttributeAccessor > MakeIntegerAccessor(T1 a1)
Ptr< const AttributeChecker > MakeUintegerChecker()
constexpr double NO_SINR
Value for SINR outside the range defined by FF-API, used to indicate that there is no CQI for this el...
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
std::vector< uint8_t > UlHarqProcessesStatus_t
UL HARQ process status vector.
std::vector< uint8_t > DlHarqProcessesStatus_t
DL HARQ process status vector.
Ptr< T1 > DynamicCast(const Ptr< T2 > &p)
Cast a Ptr.
std::vector< DlDciListElement_s > DlHarqProcessesDciBuffer_t
DL HARQ process DCI buffer vector.
constexpr uint32_t HARQ_DL_TIMEOUT
HARQ DL timeout.
constexpr uint32_t HARQ_PROC_NUM
Number of HARQ processes.
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
std::vector< RlcPduList_t > DlHarqRlcPduListBuffer_t
Vector of the 8 HARQ processes per UE.
std::vector< UlDciListElement_s > UlHarqProcessesDciBuffer_t
UL HARQ process DCI buffer vector.
static const int FdTbfqType0AllocationRbg[4]
FdTbfqType0AllocationRbg value array (see table 7.1.6.1-1 of 36.213)
See section 4.3.8 buildDataListElement.
std::vector< std::vector< struct RlcPduListElement_s > > m_rlcPduList
RLC PDU list.
struct DlDciListElement_s m_dci
DCI.
See section 4.3.10 buildRARListElement.
See section 4.3.1 dlDciListElement.
std::vector< uint8_t > m_ndi
New data indicator.
uint8_t m_harqProcess
HARQ process.
uint32_t m_rbBitmap
RB bitmap.
std::vector< uint8_t > m_mcs
MCS.
uint8_t m_resAlloc
The type of resource allocation.
std::vector< uint16_t > m_tbsSize
The TBs size.
std::vector< uint8_t > m_rv
Redundancy version.
uint8_t m_tpc
Tx power control command.
Parameters of the API primitives.
Parameters of the CSCHED_LC_CONFIG_REQ primitive.
Parameters of the CSCHED_LC_RELEASE_REQ primitive.
Parameters of the CSCHED_UE_CONFIG_REQ primitive.
Parameters of the CSCHED_UE_RELEASE_REQ primitive.
Parameters of the CSCHED_UE_CONFIG_CNF primitive.
Parameters of the CSCHED_UE_CONFIG_UPDATE_IND primitive.
Parameters of the SCHED_DL_CQI_INFO_REQ primitive.
Parameters of the SCHED_DL_MAC_BUFFER_REQ primitive.
Parameters of the SCHED_DL_PAGING_BUFFER_REQ primitive.
Parameters of the SCHED_DL_RACH_INFO_REQ primitive.
Parameters of the API primitives.
Parameters of the SCHED_DL_TRIGGER_REQ primitive.
Parameters of the SCHED_UL_CQI_INFO_REQ primitive.
Parameters of the SCHED_UL_MAC_CTRL_INFO_REQ primitive.
Parameters of the SCHED_UL_NOISE_INTERFERENCE_REQ primitive.
Parameters of the SCHED_UL_SR_INFO_REQ primitive.
Parameters of the SCHED_UL_TRIGGER_REQ primitive.
Parameters of the API primitives.
std::vector< BuildDataListElement_s > m_buildDataList
build data list
std::vector< BuildRarListElement_s > m_buildRarList
build rar list
uint8_t m_nrOfPdcchOfdmSymbols
number of PDCCH OFDM symbols
Parameters of the SCHED_UL_CONFIG_IND primitive.
std::vector< UlDciListElement_s > m_dciList
DCI list.
See section 4.3.9 rlcPDU_ListElement.
uint8_t m_logicalChannelIdentity
logical channel identity
See section 4.3.2 ulDciListElement.
int8_t m_pdcchPowerOffset
CCH power offset.
int8_t m_tpc
Tx power control command.
uint8_t m_dai
DL assignment index.
uint8_t m_cceIndex
Control Channel Element index.
uint8_t m_ulIndex
UL index.
uint8_t m_ueTxAntennaSelection
UE antenna selection.
bool m_cqiRequest
CQI request.
uint8_t m_freqHopping
freq hopping
uint8_t m_aggrLevel
The aggregation level.
int8_t m_tpc
Tx power control command.
bool m_cqiRequest
CQI request?
Time flowStart
flow start time
int counter
the number of token borrow or given to token bank
uint32_t burstCredit
the maximum number of tokens connection i can borrow from the bank each time
int debtLimit
counter threshold that the flow cannot further borrow tokens from bank
uint32_t creditableThreshold
the flow cannot borrow token from bank until the number of token it has deposited to bank reaches thi...
uint64_t packetArrivalRate
packet arrival rate( byte/s)
uint32_t tokenPoolSize
current size of token pool (byte)
uint32_t maxTokenPoolSize
maximum size of token pool (byte)
uint64_t tokenGenerationRate
token generation rate ( byte/s )