23 #include <ns3/pointer.h> 26 #include <ns3/simulator.h> 27 #include <ns3/lte-amc.h> 28 #include <ns3/fdtbfq-ff-mac-scheduler.h> 29 #include <ns3/lte-vendor-specific-parameters.h> 30 #include <ns3/boolean.h> 31 #include <ns3/integer.h> 53 : m_cschedSapUser (0),
58 m_amc = CreateObject <LteAmc> ();
93 .AddAttribute (
"CqiTimerThreshold",
94 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
97 MakeUintegerChecker<uint32_t> ())
98 .AddAttribute (
"DebtLimit",
99 "Flow debt limit (default -625000 bytes)",
102 MakeIntegerChecker<int> ())
103 .AddAttribute (
"CreditLimit",
104 "Flow credit limit (default 625000 bytes)",
107 MakeUintegerChecker<uint32_t> ())
108 .AddAttribute (
"TokenPoolSize",
109 "The maximum value of flow token pool (default 1 bytes)",
112 MakeUintegerChecker<uint32_t> ())
113 .AddAttribute (
"CreditableThreshold",
114 "Threshold of flow credit (default 0 bytes)",
117 MakeUintegerChecker<uint32_t> ())
119 .AddAttribute (
"HarqEnabled",
120 "Activate/Deactivate the HARQ [by default is active].",
124 .AddAttribute (
"UlGrantMcs",
125 "The MCS of the UL grant, must be [0..15] (default 0)",
128 MakeUintegerChecker<uint8_t> ())
195 dlHarqPrcStatus.resize (8,0);
198 dlHarqProcessesTimer.resize (8,0);
201 dlHarqdci.resize (8);
204 dlHarqRlcPdu.resize (2);
205 dlHarqRlcPdu.at (0).resize (8);
206 dlHarqRlcPdu.at (1).resize (8);
210 ulHarqPrcStatus.resize (8,0);
213 ulHarqdci.resize (8);
228 std::map <uint16_t, fdtbfqsFlowPerf_t>::iterator it;
237 NS_LOG_DEBUG (
"mbrDlInBytes: " << mbrDlInBytes <<
" mbrUlInBytes: " << mbrUlInBytes);
249 m_flowStatsDl.insert (std::pair<uint16_t, fdtbfqsFlowPerf_t> (params.
m_rnti, flowStatsDl));
260 m_flowStatsUl.insert (std::pair<uint16_t, fdtbfqsFlowPerf_t> (params.
m_rnti, flowStatsUl));
267 NS_LOG_DEBUG (
"mbrDlInBytes: " << mbrDlInBytes <<
" mbrUlInBytes: " << mbrUlInBytes);
268 m_flowStatsDl[(*it).first].tokenGenerationRate = mbrDlInBytes;
269 m_flowStatsUl[(*it).first].tokenGenerationRate = mbrUlInBytes;
283 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it =
m_rlcBufferReq.begin ();
284 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator temp;
319 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it =
m_rlcBufferReq.begin ();
320 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator temp;
323 if ((*it).first.m_rnti == params.
m_rnti)
349 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
357 m_rlcBufferReq.insert (std::pair <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters> (flow, params));
361 (*it).second = params;
386 for (
int i = 0; i < 4; i++)
401 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
402 unsigned int lcActive = 0;
405 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0)
406 || ((*it).second.m_rlcRetransmissionQueueSize > 0)
407 || ((*it).second.m_rlcStatusPduSize > 0) ))
411 if ((*it).first.m_rnti > rnti)
434 NS_FATAL_ERROR (
"No Process Id Statusfound for this RNTI " << rnti);
436 uint8_t i = (*it).second;
441 while ( ((*itStat).second.at (i) != 0)&&(i != (*it).second));
442 if ((*itStat).second.at (i) == 0)
473 NS_FATAL_ERROR (
"No Process Id Statusfound for this RNTI " << rnti);
475 uint8_t i = (*it).second;
480 while ( ((*itStat).second.at (i) != 0)&&(i != (*it).second));
481 if ((*itStat).second.at (i) == 0)
484 (*itStat).second.at (i) = 1;
488 NS_FATAL_ERROR (
"No HARQ process available for RNTI " << rnti <<
" check before update with HarqProcessAvailability");
491 return ((*it).second);
500 std::map <uint16_t, DlHarqProcessesTimer_t>::iterator itTimers;
509 NS_LOG_DEBUG (
this <<
" Reset HARQ proc " << i <<
" for RNTI " << (*itTimers).first);
510 std::map <uint16_t, DlHarqProcessesStatus_t>::iterator itStat =
m_dlHarqProcessesStatus.find ((*itTimers).first);
513 NS_FATAL_ERROR (
"No Process Id Status found for this RNTI " << (*itTimers).first);
515 (*itStat).second.at (i) = 0;
516 (*itTimers).second.at (i) = 0;
520 (*itTimers).second.at (i)++;
543 std::map <uint16_t, std::vector <uint16_t> > allocationMap;
544 std::vector <bool> rbgMap;
545 uint16_t rbgAllocatedNum = 0;
546 std::set <uint16_t> rntiAllocated;
550 for (std::vector<bool>::iterator it = rbgMap.begin (); it != rbgMap.end (); it++)
561 std::map <uint16_t, uint8_t>::iterator itProcId;
564 (*itProcId).second = ((*itProcId).second + 1) %
HARQ_PROC_NUM;
568 uint16_t rbAllocatedNum = 0;
569 std::vector <bool> ulRbMap;
572 uint8_t maxContinuousUlBandwidth = 0;
573 uint8_t tmpMinBandwidth = 0;
574 uint16_t ffrRbStartOffset = 0;
575 uint16_t tmpFfrRbStartOffset = 0;
578 for (std::vector<bool>::iterator it = ulRbMap.begin (); it != ulRbMap.end (); it++)
583 if (tmpMinBandwidth > maxContinuousUlBandwidth)
585 maxContinuousUlBandwidth = tmpMinBandwidth;
586 ffrRbStartOffset = tmpFfrRbStartOffset;
592 if (tmpMinBandwidth == 0)
594 tmpFfrRbStartOffset = index;
601 if (tmpMinBandwidth > maxContinuousUlBandwidth)
603 maxContinuousUlBandwidth = tmpMinBandwidth;
604 ffrRbStartOffset = tmpFfrRbStartOffset;
608 uint16_t rbStart = 0;
609 rbStart = ffrRbStartOffset;
610 std::vector <struct RachListElement_s>::iterator itRach;
615 newRar.
m_rnti = (*itRach).m_rnti;
619 newRar.m_grant.m_rnti = newRar.m_rnti;
622 uint16_t tbSizeBits = 0;
624 while ((tbSizeBits < (*itRach).m_estimatedSize) && (rbStart + rbLen < (ffrRbStartOffset + maxContinuousUlBandwidth)))
629 if (tbSizeBits < (*itRach).m_estimatedSize)
634 newRar.m_grant.m_rbStart = rbStart;
635 newRar.m_grant.m_rbLen = rbLen;
636 newRar.m_grant.m_tbSize = tbSizeBits / 8;
637 newRar.m_grant.m_hopping =
false;
638 newRar.m_grant.m_tpc = 0;
639 newRar.m_grant.m_cqiRequest =
false;
640 newRar.m_grant.m_ulDelay =
false;
641 NS_LOG_INFO (
this <<
" UL grant allocated to RNTI " << (*itRach).m_rnti <<
" rbStart " << rbStart <<
" rbLen " << rbLen <<
" MCS " << (uint16_t)
m_ulGrantMcs <<
" tbSize " << newRar.m_grant.m_tbSize);
642 for (uint16_t i = rbStart; i < rbStart + rbLen; i++)
651 uldci.
m_rnti = newRar.m_rnti;
670 std::map <uint16_t, uint8_t>::iterator itProcId;
676 harqId = (*itProcId).second;
682 (*itDci).second.at (harqId) = uldci;
685 rbStart = rbStart + rbLen;
698 NS_LOG_INFO (
this <<
" Received DL-HARQ feedback");
714 std::vector <struct DlInfoListElement_s> dlInfoListUntxed;
718 if (itRnti != rntiAllocated.end ())
724 std::vector <bool> retx;
725 NS_LOG_INFO (
this <<
" Processing DLHARQ feedback");
729 retx.push_back (
false);
736 if (retx.at (0) || retx.at (1))
741 NS_LOG_INFO (
this <<
" HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId);
750 if (dci.
m_rv.size () == 1)
752 rv = dci.
m_rv.at (0);
756 rv = (dci.
m_rv.at (0) > dci.
m_rv.at (1) ? dci.
m_rv.at (0) : dci.
m_rv.at (1));
762 NS_LOG_INFO (
"Maximum number of retransmissions reached -> drop process");
768 (*it).second.at (harqId) = 0;
774 for (uint16_t k = 0; k < (*itRlcPdu).second.size (); k++)
776 (*itRlcPdu).second.at (k).at (harqId).clear ();
782 std::vector <int> dciRbg;
785 for (
int j = 0; j < 32; j++)
789 dciRbg.push_back (j);
795 for (uint8_t j = 0; j < dciRbg.size (); j++)
797 if (rbgMap.at (dciRbg.at (j)) ==
true)
807 for (uint8_t j = 0; j < dciRbg.size (); j++)
809 rbgMap.at (dciRbg.at (j)) =
true;
810 NS_LOG_INFO (
"RBG " << dciRbg.at (j) <<
" assigned");
814 NS_LOG_INFO (
this <<
" Send retx in the same RBGs");
820 uint8_t rbgId = (dciRbg.at (dciRbg.size () - 1) + 1) % rbgNum;
821 uint8_t startRbg = dciRbg.at (dciRbg.size () - 1);
822 std::vector <bool> rbgMapCopy = rbgMap;
823 while ((j < dciRbg.size ())&&(startRbg != rbgId))
825 if (rbgMapCopy.at (rbgId) ==
false)
827 rbgMapCopy.at (rbgId) =
true;
828 dciRbg.at (j) = rbgId;
831 rbgId = (rbgId + 1) % rbgNum;
833 if (j == dciRbg.size ())
836 uint32_t rbgMask = 0;
837 for (uint16_t k = 0; k < dciRbg.size (); k++)
839 rbgMask = rbgMask + (0x1 << dciRbg.at (k));
844 NS_LOG_INFO (
this <<
" Move retx in RBGs " << dciRbg.size ());
850 NS_LOG_INFO (
this <<
" No resource for this retx -> buffer it");
858 NS_FATAL_ERROR (
"Unable to find RlcPdcList in HARQ buffer for RNTI " << rnti);
860 for (uint8_t j = 0; j < nLayers; j++)
864 if (j >= dci.
m_ndi.size ())
867 dci.
m_ndi.push_back (0);
868 dci.
m_rv.push_back (0);
869 dci.
m_mcs.push_back (0);
871 NS_LOG_INFO (
this <<
" layer " << (uint16_t)j <<
" no txed (MIMO transition)");
875 dci.
m_ndi.at (j) = 0;
877 (*itHarq).second.at (harqId).m_rv.at (j)++;
878 NS_LOG_INFO (
this <<
" layer " << (uint16_t)j <<
" RV " << (uint16_t)dci.
m_rv.at (j));
884 dci.
m_ndi.at (j) = 0;
886 dci.
m_mcs.at (j) = 0;
888 NS_LOG_INFO (
this <<
" layer " << (uint16_t)j <<
" no retx");
891 for (uint16_t k = 0; k < (*itRlcPdu).second.at (0).at (dci.
m_harqProcess).size (); k++)
893 std::vector <struct RlcPduListElement_s> rlcPduListPerLc;
894 for (uint8_t j = 0; j < nLayers; j++)
898 if (j < dci.
m_ndi.size ())
901 rlcPduListPerLc.push_back ((*itRlcPdu).second.at (j).at (dci.
m_harqProcess).at (k));
909 emptyElement.m_size = 0;
910 rlcPduListPerLc.push_back (emptyElement);
914 if (rlcPduListPerLc.size () > 0)
921 (*itHarq).second.at (harqId).
m_rv = dci.
m_rv;
926 NS_FATAL_ERROR (
"Unable to find HARQ timer for RNTI " << (uint16_t)rnti);
928 (*itHarqTimer).second.at (harqId) = 0;
930 rntiAllocated.insert (rnti);
947 for (uint16_t k = 0; k < (*itRlcPdu).second.size (); k++)
956 if (rbgAllocatedNum == rbgNum)
967 std::map <uint16_t, fdtbfqsFlowPerf_t>::iterator itStats;
970 if ( (*itStats).second.tokenGenerationRate / 1000 + (*itStats).second.tokenPoolSize > (*itStats).second.maxTokenPoolSize )
972 (*itStats).second.counter += (*itStats).second.tokenGenerationRate / 1000 - ( (*itStats).second.maxTokenPoolSize - (*itStats).second.tokenPoolSize );
973 (*itStats).second.tokenPoolSize = (*itStats).second.maxTokenPoolSize;
974 bankSize += (*itStats).second.tokenGenerationRate / 1000 - ( (*itStats).second.maxTokenPoolSize - (*itStats).second.tokenPoolSize );
978 (*itStats).second.tokenPoolSize += (*itStats).second.tokenGenerationRate / 1000;
982 std::set <uint16_t> allocatedRnti;
983 std::set <uint8_t> allocatedRbg;
986 while (totalRbg < rbgNum)
989 std::map <uint16_t, fdtbfqsFlowPerf_t>::iterator it;
990 std::map <uint16_t, fdtbfqsFlowPerf_t>::iterator itMax =
m_flowStatsDl.end ();
991 double metricMax = 0.0;
992 bool firstRnti =
true;
995 std::set <uint16_t>::iterator itRnti = rntiAllocated.find ((*it).first);
999 if (itRnti != rntiAllocated.end ())
1001 NS_LOG_DEBUG (
this <<
" RNTI discared for HARQ tx" << (uint16_t)(*it).first);
1005 NS_LOG_DEBUG (
this <<
" RNTI discared for HARQ id" << (uint16_t)(*it).first);
1010 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
1012 std::map <uint16_t,uint8_t>::iterator itTxMode;
1016 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*it).first);
1021 for (
int k = 0; k < rbgNum; k++)
1023 for (uint8_t j = 0; j < nLayer; j++)
1031 cqiSum += (*itCqi).second.m_higherLayerSelected.at (k).m_sbCqi.at(j);
1038 NS_LOG_INFO (
"Skip this flow, CQI==0, rnti:"<<(*it).first);
1047 std::set <uint16_t>::iterator rnti;
1048 rnti = allocatedRnti.find((*it).first);
1049 if (rnti != allocatedRnti.end ())
1054 double metric = ( ( (double)(*it).second.counter ) / ( (double)(*it).second.tokenGenerationRate ) );
1056 if (firstRnti ==
true)
1063 if (metric > metricMax)
1077 allocatedRnti.insert((*itMax).first);
1080 uint32_t budget = 0;
1083 budget = (*itMax).second.counter - (*itMax).second.debtLimit;
1084 if ( budget > (*itMax).second.burstCredit )
1085 budget = (*itMax).second.burstCredit;
1089 budget = budget + (*itMax).second.tokenPoolSize;
1100 uint32_t rlcBufSize = 0;
1102 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator itRlcBuf;
1105 if ( (*itRlcBuf).first.m_rnti == (*itMax).first )
1106 lcid = (*itRlcBuf).first.m_lcId;
1112 rlcBufSize = (*itRlcBuf).second.m_rlcTransmissionQueueSize + (*itRlcBuf).second.m_rlcRetransmissionQueueSize + (*itRlcBuf).second.m_rlcStatusPduSize;
1114 if (budget > rlcBufSize)
1116 budget = rlcBufSize;
1117 NS_LOG_DEBUG (
"budget > rlcBufSize. budget: " << budget <<
" RLC buffer size: " << rlcBufSize);
1122 uint32_t bytesTxed = 0;
1123 uint32_t bytesTxedTmp = 0;
1125 while ( bytesTxed <= budget )
1129 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
1131 std::map <uint16_t,uint8_t>::iterator itTxMode;
1135 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*it).first);
1140 double achievableRateMax = 0.0;
1142 for (
int k = 0; k < rbgNum; k++)
1144 std::set <uint8_t>::iterator rbg;
1145 rbg = allocatedRbg.find (k);
1146 if (rbg != allocatedRbg.end ())
1149 if ( rbgMap.at (k) ==
true)
1155 std::vector <uint8_t> sbCqi;
1158 for (uint8_t k = 0; k < nLayer; k++)
1160 sbCqi.push_back (1);
1165 sbCqi = (*itCqi).second.m_higherLayerSelected.at (k).m_sbCqi;
1167 uint8_t cqi1 = sbCqi.at (0);
1169 if (sbCqi.size () > 1)
1171 cqi2 = sbCqi.at (1);
1174 if ((cqi1 > 0)||(cqi2 > 0))
1179 double achievableRate = 0.0;
1180 for (uint8_t j = 0; j < nLayer; j++)
1183 if (sbCqi.size () > j)
1185 mcs =
m_amc->GetMcsFromCqi (sbCqi.at (j));
1192 achievableRate += ((
m_amc->GetDlTbSizeFromMcs (mcs, rbgSize) / 8) / 0.001);
1195 if ( achievableRate > achievableRateMax )
1197 achievableRateMax = achievableRate;
1204 if ( rbgIndex == rbgNum)
1213 allocatedRbg.insert (rbgIndex);
1217 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
1218 itMap = allocationMap.find ((*itMax).first);
1219 uint16_t RbgPerRnti;
1220 if (itMap == allocationMap.end ())
1223 std::vector <uint16_t> tempMap;
1224 tempMap.push_back (rbgIndex);
1225 allocationMap.insert (std::pair <uint16_t, std::vector <uint16_t> > ((*itMax).first, tempMap));
1226 itMap = allocationMap.find ((*itMax).first);
1230 (*itMap).second.push_back (rbgIndex);
1232 rbgMap.at (rbgIndex) =
true;
1234 RbgPerRnti = (*itMap).second.size();
1237 std::vector <uint8_t> worstCqi (2, 15);
1240 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
1242 if ((*itCqi).second.m_higherLayerSelected.size () > (*itMap).second.at (k))
1244 for (uint8_t j = 0; j < nLayer; j++)
1246 if ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.size () > j)
1248 if (((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j)) < worstCqi.at (j))
1250 worstCqi.at (j) = ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j));
1256 worstCqi.at (j) = 1;
1262 for (uint8_t j = 0; j < nLayer; j++)
1264 worstCqi.at (j) = 1;
1271 for (uint8_t j = 0; j < nLayer; j++)
1273 worstCqi.at (j) = 1;
1277 bytesTxedTmp = bytesTxed;
1279 for (uint8_t j = 0; j < nLayer; j++)
1281 int tbSize = (
m_amc->GetDlTbSizeFromMcs (
m_amc->GetMcsFromCqi (worstCqi.at (j)), RbgPerRnti * rbgSize) / 8);
1282 bytesTxed += tbSize;
1288 if ( bytesTxed > budget )
1290 NS_LOG_DEBUG (
"budget: " << budget <<
" bytesTxed: " << bytesTxed <<
" at " <<
Simulator::Now().GetMilliSeconds () <<
" ms");
1291 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
1292 itMap = allocationMap.find ((*itMax).first);
1293 (*itMap).second.pop_back ();
1294 allocatedRbg.erase (rbgIndex);
1295 bytesTxed = bytesTxedTmp;
1297 rbgMap.at (rbgIndex) =
false;
1300 if ((*itMap).second.size () == 0)
1302 itMap = allocationMap.erase (itMap);
1307 if (allocationMap.find ((*itMax).first) != allocationMap.end ())
1310 if ( bytesTxed <= (*itMax).second.tokenPoolSize )
1312 (*itMax).second.tokenPoolSize -= bytesTxed;
1316 (*itMax).second.counter = (*itMax).second.counter - ( bytesTxed - (*itMax).second.tokenPoolSize );
1317 (*itMax).second.tokenPoolSize = 0;
1318 if (
bankSize <= ( bytesTxed - (*itMax).second.tokenPoolSize ))
1328 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap = allocationMap.begin ();
1329 while (itMap != allocationMap.end ())
1331 NS_LOG_DEBUG (
"Preparing DCI for RNTI " << (*itMap).first);
1334 newEl.
m_rnti = (*itMap).first;
1337 newDci.
m_rnti = (*itMap).first;
1345 lcActives = (uint16_t)65535;
1347 uint16_t RgbPerRnti = (*itMap).second.size ();
1348 std::map <uint16_t,SbMeasResult_s>::iterator itCqi;
1350 std::map <uint16_t,uint8_t>::iterator itTxMode;
1354 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*itMap).first);
1357 std::vector <uint8_t> worstCqi (2, 15);
1360 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
1362 if ((*itCqi).second.m_higherLayerSelected.size () > (*itMap).second.at (k))
1364 NS_LOG_INFO (
this <<
" RBG " << (*itMap).second.at (k) <<
" CQI " << (uint16_t)((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (0)) );
1365 for (uint8_t j = 0; j < nLayer; j++)
1367 if ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.size () > j)
1369 if (((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j)) < worstCqi.at (j))
1371 worstCqi.at (j) = ((*itCqi).second.m_higherLayerSelected.at ((*itMap).second.at (k)).m_sbCqi.at (j));
1377 worstCqi.at (j) = 1;
1383 for (uint8_t j = 0; j < nLayer; j++)
1385 worstCqi.at (j) = 1;
1392 for (uint8_t j = 0; j < nLayer; j++)
1394 worstCqi.at (j) = 1;
1397 for (uint8_t j = 0; j < nLayer; j++)
1399 NS_LOG_INFO (
this <<
" Layer " << (uint16_t)j <<
" CQI selected " << (uint16_t)worstCqi.at (j));
1401 uint32_t bytesTxed = 0;
1402 for (uint8_t j = 0; j < nLayer; j++)
1404 newDci.
m_mcs.push_back (
m_amc->GetMcsFromCqi (worstCqi.at (j)));
1405 int tbSize = (
m_amc->GetDlTbSizeFromMcs (newDci.
m_mcs.at (j), RgbPerRnti * rbgSize) / 8);
1407 NS_LOG_INFO (
this <<
" Layer " << (uint16_t)j <<
" MCS selected" << (uint16_t)
m_amc->GetMcsFromCqi (worstCqi.at (j)));
1408 bytesTxed += tbSize;
1413 uint32_t rbgMask = 0;
1414 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
1416 rbgMask = rbgMask + (0x1 << (*itMap).second.at (k));
1417 NS_LOG_INFO (
this <<
" Allocated RBG " << (*itMap).second.at (k));
1422 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator itBufReq;
1425 if (((*itBufReq).first.m_rnti == (*itMap).first)
1426 && (((*itBufReq).second.m_rlcTransmissionQueueSize > 0)
1427 || ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0)
1428 || ((*itBufReq).second.m_rlcStatusPduSize > 0) ))
1430 std::vector <struct RlcPduListElement_s> newRlcPduLe;
1431 for (uint8_t j = 0; j < nLayer; j++)
1437 newRlcPduLe.push_back (newRlcEl);
1445 NS_FATAL_ERROR (
"Unable to find RlcPdcList in HARQ buffer for RNTI " << (*itMap).first);
1447 (*itRlcPdu).second.at (j).at (newDci.
m_harqProcess).push_back (newRlcEl);
1452 if ((*itBufReq).first.m_rnti > (*itMap).first)
1457 for (uint8_t j = 0; j < nLayer; j++)
1459 newDci.
m_ndi.push_back (1);
1460 newDci.
m_rv.push_back (0);
1465 newEl.
m_dci = newDci;
1515 for (
unsigned int i = 0; i < params.
m_cqiList.size (); i++)
1520 std::map <uint16_t,uint8_t>::iterator it;
1521 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
1526 m_p10CqiRxed.insert ( std::pair<uint16_t, uint8_t > (rnti, params.
m_cqiList.at (i).m_wbCqi.at (0)) );
1533 (*it).second = params.
m_cqiList.at (i).m_wbCqi.at (0);
1535 std::map <uint16_t,uint32_t>::iterator itTimers;
1543 std::map <uint16_t,SbMeasResult_s>::iterator it;
1544 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
1549 m_a30CqiRxed.insert ( std::pair<uint16_t, SbMeasResult_s > (rnti, params.
m_cqiList.at (i).m_sbMeasResult) );
1555 (*it).second = params.
m_cqiList.at (i).m_sbMeasResult;
1556 std::map <uint16_t,uint32_t>::iterator itTimers;
1574 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find (rnti);
1585 unsigned int sinrNum = 0;
1588 double sinr = (*itCqi).second.at (i);
1595 double estimatedSinr = (sinrNum > 0) ? (sinrSum / sinrNum) : DBL_MAX;
1597 (*itCqi).second.at (rb) = estimatedSinr;
1598 return (estimatedSinr);
1612 std::vector <bool> rbMap;
1613 uint16_t rbAllocatedNum = 0;
1614 std::set <uint16_t> rntiAllocated;
1615 std::vector <uint16_t> rbgAllocationMap;
1626 for (std::vector<bool>::iterator it = rbMap.begin (); it != rbMap.end (); it++)
1640 if (rbgAllocationMap.at (i) != 0)
1642 rbMap.at (i) =
true;
1651 for (uint16_t i = 0; i < params.
m_ulInfoList.size (); i++)
1660 NS_LOG_ERROR (
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1663 NS_LOG_INFO (
this <<
" UL-HARQ retx RNTI " << rnti <<
" harqId " << (uint16_t)harqId <<
" i " << i <<
" size " << params.
m_ulInfoList.size ());
1667 NS_LOG_ERROR (
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1674 NS_LOG_ERROR (
"No info find in HARQ buffer for UE (might change eNB) " << rnti);
1676 if ((*itStat).second.at (harqId) >= 3)
1678 NS_LOG_INFO (
"Max number of retransmissions reached (UL)-> drop process");
1684 if (rbMap.at (j) ==
true)
1695 rbMap.at (j) =
true;
1696 rbgAllocationMap.at (j) = dci.
m_rnti;
1704 NS_LOG_INFO (
"Cannot allocate retx due to RACH allocations for UE " << rnti);
1709 (*itStat).second.at ((*itProcId).second) = (*itStat).second.at (harqId) + 1;
1710 (*itStat).second.at (harqId) = 0;
1711 (*itHarq).second.at ((*itProcId).second) = dci;
1713 rntiAllocated.insert (dci.
m_rnti);
1722 std::map <uint16_t,uint32_t>::iterator it;
1727 std::set <uint16_t>::iterator itRnti = rntiAllocated.find ((*it).first);
1729 if (((*it).second > 0)&&(itRnti == rntiAllocated.end ()))
1748 uint16_t tempRbPerFlow = (ffrUlBandwidth) / (nflows + rntiAllocated.size ());
1749 uint16_t rbPerFlow = (minContinuousUlBandwidth < tempRbPerFlow) ? minContinuousUlBandwidth : tempRbPerFlow;
1755 int rbAllocated = 0;
1757 std::map <uint16_t, fdtbfqsFlowPerf_t>::iterator itStats;
1779 std::set <uint16_t>::iterator itRnti = rntiAllocated.find ((*it).first);
1780 if ((itRnti != rntiAllocated.end ())||((*it).second == 0))
1783 NS_LOG_DEBUG (
this <<
" UE already allocated in HARQ -> discared, RNTI " << (*it).first);
1806 uldci.
m_rnti = (*it).first;
1808 bool allocated =
false;
1809 NS_LOG_INFO (
this <<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow <<
" flows " << nflows);
1814 for (uint16_t j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1816 if (rbMap.at (j) ==
true)
1829 NS_LOG_INFO (
this <<
"RNTI: "<< (*it).first<<
" RB Allocated " << rbAllocated <<
" rbPerFlow " << rbPerFlow <<
" flows " << nflows);
1832 for (uint16_t j = rbAllocated; j < rbAllocated + rbPerFlow; j++)
1834 rbMap.at (j) =
true;
1836 rbgAllocationMap.at (j) = (*it).first;
1838 rbAllocated += rbPerFlow;
1870 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find ((*it).first);
1880 NS_ABORT_MSG_IF ((*itCqi).second.size() == 0,
"CQI of RNTI = " << (*it).first <<
" has expired");
1881 double minSinr = (*itCqi).second.at (uldci.
m_rbStart);
1888 double sinr = (*itCqi).second.at (i);
1900 double s = log2 ( 1 + (
1901 std::pow (10, minSinr / 10 ) /
1902 ( (-std::log (5.0 * 0.00005 )) / 1.5) ));
1903 cqi =
m_amc->GetCqiFromSpectralEfficiency (s);
1916 rbgAllocationMap.at (i) = 0;
1942 std::map <uint16_t, uint8_t>::iterator itProcId;
1948 harqId = (*itProcId).second;
1954 (*itDci).second.at (harqId) = uldci;
1959 NS_LOG_ERROR (
"No info find in HARQ buffer for UE (might change eNB) " << uldci.
m_rnti);
1961 (*itStat).second.at (harqId) = 0;
1964 NS_LOG_INFO (
this <<
" UE Allocation RNTI " << (*it).first <<
" startPRB " << (uint32_t)uldci.
m_rbStart <<
" nPRB " << (uint32_t)uldci.
m_rbLen <<
" CQI " << cqi <<
" MCS " << (uint32_t)uldci.
m_mcs <<
" TBsize " << uldci.
m_tbSize <<
" RbAlloc " << rbAllocated <<
" harqId " << (uint16_t)harqId);
2007 std::map <uint16_t,uint32_t>::iterator it;
2009 for (
unsigned int i = 0; i < params.
m_macCeList.size (); i++)
2020 uint32_t buffer = 0;
2021 for (uint8_t lcg = 0; lcg < 4; ++lcg)
2023 uint8_t bsrId = params.
m_macCeList.at (i).m_macCeValue.m_bufferStatus.at (lcg);
2028 NS_LOG_LOGIC (
this <<
"RNTI=" << rnti <<
" buffer=" << buffer);
2033 m_ceBsrRxed.insert ( std::pair<uint16_t, uint32_t > (rnti, buffer));
2038 (*it).second = buffer;
2079 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
2080 std::map <uint16_t, std::vector <double> >::iterator itCqi;
2081 NS_LOG_DEBUG (
this <<
" Collect PUSCH CQIs of Frame no. " << (params.
m_sfnSf >> 4) <<
" subframe no. " << (0xF & params.
m_sfnSf));
2087 for (uint32_t i = 0; i < (*itMap).second.size (); i++)
2091 itCqi =
m_ueCqi.find ((*itMap).second.at (i));
2095 std::vector <double> newCqi;
2100 newCqi.push_back (sinr);
2109 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > ((*itMap).second.at (i), newCqi));
2116 (*itCqi).second.at (i) = sinr;
2117 NS_LOG_DEBUG (
this <<
" RNTI " << (*itMap).second.at (i) <<
" RB " << i <<
" SINR " << sinr);
2119 std::map <uint16_t, uint32_t>::iterator itTimers;
2140 rnti = vsp->GetRnti ();
2143 std::map <uint16_t, std::vector <double> >::iterator itCqi;
2148 std::vector <double> newCqi;
2152 newCqi.push_back (sinr);
2153 NS_LOG_INFO (
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value " << sinr);
2156 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > (rnti, newCqi));
2166 (*itCqi).second.at (j) = sinr;
2167 NS_LOG_INFO (
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value " << sinr);
2170 std::map <uint16_t, uint32_t>::iterator itTimers;
2183 NS_FATAL_ERROR (
"FdTbfqFfMacScheduler supports only PUSCH and SRS UL-CQIs");
2196 std::map <uint16_t,uint32_t>::iterator itP10 =
m_p10CqiTimers.begin ();
2200 if ((*itP10).second == 0)
2203 std::map <uint16_t,uint8_t>::iterator itMap =
m_p10CqiRxed.find ((*itP10).first);
2205 NS_LOG_INFO (
this <<
" P10-CQI expired for user " << (*itP10).first);
2207 std::map <uint16_t,uint32_t>::iterator temp = itP10;
2219 std::map <uint16_t,uint32_t>::iterator itA30 =
m_a30CqiTimers.begin ();
2223 if ((*itA30).second == 0)
2226 std::map <uint16_t,SbMeasResult_s>::iterator itMap =
m_a30CqiRxed.find ((*itA30).first);
2228 NS_LOG_INFO (
this <<
" A30-CQI expired for user " << (*itA30).first);
2230 std::map <uint16_t,uint32_t>::iterator temp = itA30;
2249 std::map <uint16_t,uint32_t>::iterator itUl =
m_ueCqiTimers.begin ();
2253 if ((*itUl).second == 0)
2256 std::map <uint16_t, std::vector <double> >::iterator itMap =
m_ueCqi.find ((*itUl).first);
2257 NS_ASSERT_MSG (itMap !=
m_ueCqi.end (),
" Does not find CQI report for user " << (*itUl).first);
2258 NS_LOG_INFO (
this <<
" UL-CQI exired for user " << (*itUl).first);
2259 (*itMap).second.clear ();
2261 std::map <uint16_t,uint32_t>::iterator temp = itUl;
2278 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
2283 NS_LOG_INFO (
this <<
" UE " << rnti <<
" LC " << (uint16_t)lcid <<
" txqueue " << (*it).second.m_rlcTransmissionQueueSize <<
" retxqueue " << (*it).second.m_rlcRetransmissionQueueSize <<
" status " << (*it).second.m_rlcStatusPduSize <<
" decrease " << size);
2286 if (((*it).second.m_rlcStatusPduSize > 0) && (size >= (*it).second.m_rlcStatusPduSize))
2288 (*it).second.m_rlcStatusPduSize = 0;
2290 else if (((*it).second.m_rlcRetransmissionQueueSize > 0) && (size >= (*it).second.m_rlcRetransmissionQueueSize))
2292 (*it).second.m_rlcRetransmissionQueueSize = 0;
2294 else if ((*it).second.m_rlcTransmissionQueueSize > 0)
2296 uint32_t rlcOverhead;
2311 if ((*it).second.m_rlcTransmissionQueueSize <= size - rlcOverhead)
2313 (*it).second.m_rlcTransmissionQueueSize = 0;
2317 (*it).second.m_rlcTransmissionQueueSize -= size - rlcOverhead;
2323 NS_LOG_ERROR (
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
2332 std::map <uint16_t,uint32_t>::iterator it =
m_ceBsrRxed.find (rnti);
2335 NS_LOG_INFO (
this <<
" UE " << rnti <<
" size " << size <<
" BSR " << (*it).second);
2336 if ((*it).second >= size)
2338 (*it).second -= size;
2347 NS_LOG_ERROR (
this <<
" Does not find BSR report info of UE " << rnti);
2355 NS_LOG_FUNCTION (
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);
std::vector< struct UlInfoListElement_s > m_ulInfoList
UL info list.
See section 4.3.1 dlDciListElement.
std::map< uint16_t, uint32_t > m_a30CqiTimers
Map of UE's timers on DL CQI A30 received.
virtual void SetFfMacCschedSapUser(FfMacCschedSapUser *s)
Set FF MAC Csched SAP user function.
void DoCschedCellConfigReq(const struct FfMacCschedSapProvider::CschedCellConfigReqParameters ¶ms)
Csched cell config request function.
uint32_t creditableThreshold
the flow cannot borrow token from bank until the number of token it has deposited to bank reaches thi...
Smart pointer class similar to boost::intrusive_ptr.
Service Access Point (SAP) offered by the eNodeB RRC instance to the Frequency Reuse algorithm instan...
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
std::map< uint16_t, uint8_t > m_uesTxMode
txMode of the UEs
std::map< uint16_t, std::vector< double > > m_ueCqi
Map of UEs' UL-CQI per RBG.
Time flowStart
flow start time
AttributeValue implementation for Boolean.
std::map< LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters > m_rlcBufferReq
Vectors of UE's LC info.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
virtual void ReportUlCqiInfo(const struct FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)=0
ReportUlCqiInfo.
std::map< uint16_t, SbMeasResult_s > m_a30CqiRxed
Map of UE's DL CQI A30 received.
NS_ASSERT_MSG(false, "Ipv4AddressGenerator::MaskToIndex(): Impossible")
Parameters of the CSCHED_UE_CONFIG_CNF primitive.
Parameters of the CSCHED_UE_RELEASE_REQ primitive.
void DoSchedUlNoiseInterferenceReq(const struct FfMacSchedSapProvider::SchedUlNoiseInterferenceReqParameters ¶ms)
Sched UL noise interference request function.
void DoCschedLcConfigReq(const struct FfMacCschedSapProvider::CschedLcConfigReqParameters ¶ms)
CSched LC config request function.
virtual bool IsDlRbgAvailableForUe(int i, uint16_t rnti)=0
Check if UE can be served on i-th RB in DL.
virtual bool IsUlRbgAvailableForUe(int i, uint16_t rnti)=0
Check if UE can be served on i-th RB in UL.
std::map< uint16_t, UlHarqProcessesDciBuffer_t > m_ulHarqProcessesDciBuffer
UL HARQ process DCI buffer.
enum ns3::UlCqi_s::Type_e m_type
type
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
void DoSchedUlSrInfoReq(const struct FfMacSchedSapProvider::SchedUlSrInfoReqParameters ¶ms)
Sched UL SR info request function.
std::vector< UlDciListElement_s > UlHarqProcessesDciBuffer_t
UL HARQ process DCI buffer vector.
std::vector< struct LogicalChannelConfigListElement_s > m_logicalChannelConfigList
logicalChannelConfigList
std::vector< uint16_t > m_sinr
SINR.
void DoSchedDlPagingBufferReq(const struct FfMacSchedSapProvider::SchedDlPagingBufferReqParameters ¶ms)
Sched DL paging buffer request function.
std::vector< uint8_t > DlHarqProcessesTimer_t
DL HARQ process timer vector typedef.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
Hold a signed integer type.
int debtLimit
counter threshold that the flow cannot further borrow tokens from bank
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
std::vector< uint8_t > m_mcs
MCS.
void DoSchedDlCqiInfoReq(const struct FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)
Sched DL CQI info request function.
See section 4.3.2 ulDciListElement.
bool m_harqOn
m_harqOn when false inhibit the HARQ mechanisms (by default active)
uint32_t tokenPoolSize
current size of token pool (byte)
std::vector< struct UlDciListElement_s > m_dciList
DCI list.
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
See section 4.3.10 buildRARListElement.
Parameters of the CSCHED_UE_CONFIG_UPDATE_IND primitive.
uint8_t m_ulBandwidth
UL bandwidth.
std::map< uint16_t, fdtbfqsFlowPerf_t > m_flowStatsUl
Map of UE statistics (per RNTI basis)
void DoSchedDlRachInfoReq(const struct FfMacSchedSapProvider::SchedDlRachInfoReqParameters ¶ms)
Sched DL RACH info request function.
Parameters of the CSCHED_LC_RELEASE_REQ primitive.
uint16_t m_nextRntiUl
RNTI of the next user to be served next scheduling in UL.
virtual uint8_t GetTpc(uint16_t rnti)=0
GetTpc.
virtual void SetLteFfrSapProvider(LteFfrSapProvider *s)
Set FFR SAP provider function.
std::vector< std::vector< struct RlcPduListElement_s > > m_rlcPduList
RLC PDU list.
uint8_t m_transmissionMode
transmission mode
uint32_t m_cqiTimersThreshold
of TTIs for which a CQI can be considered valid
Parameters of the SCHED_DL_TRIGGER_REQ primitive.
uint8_t m_logicalChannelIdentity
logical channel identity
virtual ~FdTbfqFfMacScheduler()
Destructor.
uint8_t m_harqProcess
HARQ process.
Ptr< const AttributeAccessor > MakeIntegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
std::vector< RlcPduList_t > DlHarqRlcPduListBuffer_t
vector of the 8 HARQ processes per UE
Parameters of the SCHED_DL_MAC_BUFFER_REQ primitive.
uint8_t m_dlBandwidth
DL badnwidth.
Parameters of the SCHED_DL_PAGING_BUFFER_REQ primitive.
virtual void CschedUeConfigUpdateInd(const struct CschedUeConfigUpdateIndParameters ¶ms)=0
CSCHED_UE_UPDATE_IND.
virtual void SetFfMacSchedSapUser(FfMacSchedSapUser *s)
Set FF MAC sched SAP user function.
std::vector< struct RachListElement_s > m_rachList
RACH list.
std::vector< struct VendorSpecificListElement_s > m_vendorSpecificList
vendor specific list
uint8_t m_aggrLevel
The aggregation level.
FfMacSchedSapUser * m_schedSapUser
sched SAP user
std::map< uint16_t, std::vector< uint16_t > > m_allocationMaps
Map of previous allocated UE per RBG (used to retrieve info from UL-CQI)
std::map< uint16_t, DlHarqProcessesDciBuffer_t > m_dlHarqProcessesDciBuffer
DL HARQ process DCI buffer.
uint8_t HarqProcessAvailability(uint16_t rnti)
Return the availability of free process for the RNTI specified.
static TypeId GetTypeId(void)
Get the type ID.
std::map< uint16_t, DlHarqProcessesTimer_t > m_dlHarqProcessesTimer
DL HARQ process timer.
uint64_t packetArrivalRate
packet arrival rate( byte/s)
void DoCschedLcReleaseReq(const struct FfMacCschedSapProvider::CschedLcReleaseReqParameters ¶ms)
CSched LC release request function.
std::map< uint16_t, fdtbfqsFlowPerf_t > m_flowStatsDl
Map of UE statistics (per RNTI basis) in downlink.
Service Access Point (SAP) offered by the Frequency Reuse algorithm instance to the MAC Scheduler ins...
Parameters of the SCHED_UL_TRIGGER_REQ primitive.
uint32_t m_rbBitmap
RB bitmap.
Hold an unsigned integer type.
static uint8_t TxMode2LayerNum(uint8_t txMode)
Transmit mode 2 layer number.
bool m_cqiRequest
CQI request.
uint64_t bankSize
the number of bytes in token bank
std::vector< uint8_t > m_ndi
New data indicator.
uint8_t m_cceIndex
Control Channel Element index.
FfMacCschedSapProvider::CschedCellConfigReqParameters m_cschedCellConfig
Csched cell config.
LteFfrSapProvider * m_ffrSapProvider
FFR SAP provider.
virtual FfMacCschedSapProvider * GetFfMacCschedSapProvider()
Get FF MAC CSched SAP provider function.
int8_t m_tpc
Tx power control command.
virtual void CschedUeConfigCnf(const struct CschedUeConfigCnfParameters ¶ms)=0
CSCHED_UE_CONFIG_CNF.
struct UlCqi_s m_ulCqi
UL CQI.
std::vector< uint16_t > m_rachAllocationMap
RACH allocation map.
uint32_t m_tokenPoolSize
maximum size of token pool (byte)
std::map< uint16_t, uint32_t > m_p10CqiTimers
Map of UE's timers on DL CQI P01 received.
std::vector< uint8_t > m_logicalChannelIdentity
logical channel identity
Parameters of the SCHED_UL_NOISE_INTERFERENCE_REQ primitive.
uint8_t m_logicalChannelIdentity
logical channel identity
std::vector< struct CqiListElement_s > m_cqiList
CQI list.
uint8_t m_ulGrantMcs
MCS for UL grant (default 0)
std::vector< struct DlInfoListElement_s > m_dlInfoList
DL info list.
void DoSchedDlRlcBufferReq(const struct FfMacSchedSapProvider::SchedDlRlcBufferReqParameters ¶ms)
Sched DL RLC buffer request function.
std::map< uint16_t, uint32_t > m_ueCqiTimers
Map of UEs' timers on UL-CQI per RBG.
virtual void ReportDlCqiInfo(const struct FfMacSchedSapProvider::SchedDlCqiInfoReqParameters ¶ms)=0
ReportDlCqiInfo.
Implements the SCHED SAP and CSCHED SAP for a Frequency Domain Token Bank Fair Queue scheduler...
virtual void SchedDlConfigInd(const struct SchedDlConfigIndParameters ¶ms)=0
SCHED_DL_CONFIG_IND.
uint8_t m_tpc
Tx power control command.
Parameters of the API primitives.
int8_t m_pdcchPowerOffset
CCH power offset.
std::vector< uint16_t > m_tbsSize
The TBs size.
uint32_t m_creditableThreshold
threshold of flow credit
See section 4.3.9 rlcPDU_ListElement.
void DoSchedUlMacCtrlInfoReq(const struct FfMacSchedSapProvider::SchedUlMacCtrlInfoReqParameters ¶ms)
Sched UL MAC control info request function.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeChecker > MakeBooleanChecker(void)
LteFfrSapUser * m_ffrSapUser
FFR SAP user.
uint8_t m_freqHopping
freq hopping
std::vector< DlDciListElement_s > DlHarqProcessesDciBuffer_t
DL HARQ process DCI buffer vector typedef.
Parameters of the CSCHED_LC_CONFIG_REQ primitive.
std::vector< uint8_t > m_rv
Redundancy version.
FdTbfqFfMacScheduler()
Constructor.
unsigned int LcActivePerFlow(uint16_t rnti)
LC Active per flow function.
void RefreshHarqProcesses()
Refresh HARQ processes according to the timers.
std::map< uint16_t, uint8_t > m_dlHarqCurrentProcessId
DL HARQ current process ID.
MemberCschedSapProvider class.
virtual std::vector< bool > GetAvailableUlRbg()=0
Get vector of available RB in UL for this Cell.
FfMacCschedSapProvider * m_cschedSapProvider
CSched SAP provider.
virtual uint8_t GetMinContinuousUlBandwidth()=0
Get the minimum continuous Ul bandwidth.
uint64_t tokenGenerationRate
token generation rate ( byte/s )
virtual void SchedUlConfigInd(const struct SchedUlConfigIndParameters ¶ms)=0
SCHED_UL_CONFIG_IND.
uint8_t m_ulIndex
UL index.
static Time Now(void)
Return the current simulation virtual time.
double EstimateUlSinr(uint16_t rnti, uint16_t rb)
Estimate UL SNR function.
std::map< uint16_t, DlHarqRlcPduListBuffer_t > m_dlHarqProcessesRlcPduListBuffer
DL HARQ process RLC PDU list buffer.
NS_LOG_LOGIC("Net device "<< nd<< " is not bridged")
UlCqiFilter_t m_ulCqiFilter
UL CQI filter.
int GetRbgSize(int dlbandwidth)
Get RBG size function.
This abstract base class identifies the interface by means of which the helper object can plug on the...
FfMacCschedSapUser class.
enum Result_e m_result
result
uint8_t m_nrOfPdcchOfdmSymbols
number of PDCCH OFDM symbols
Parameters of the SCHED_DL_CQI_INFO_REQ primitive.
std::vector< struct MacCeListElement_s > m_macCeList
MAC CE list.
Parameters of the API primitives.
uint32_t burstCredit
the maximum number of tokens connection i can borrow from the bank each time
virtual LteFfrSapUser * GetLteFfrSapUser()
Get FFR SAP user function.
std::vector< struct RachListElement_s > m_rachList
RACH list.
static double fpS11dot3toDouble(uint16_t val)
Convert from fixed point S11.3 notation to double.
int counter
the number of token borrow or given to token bank
std::vector< uint8_t > UlHarqProcessesStatus_t
UL HARQ process status vector.
void DoSchedUlCqiInfoReq(const struct FfMacSchedSapProvider::SchedUlCqiInfoReqParameters ¶ms)
Sched UL CQI info request function.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
std::vector< uint8_t > DlHarqProcessesStatus_t
DL HARQ process status vector typedef.
Parameters of the SCHED_UL_CQI_INFO_REQ primitive.
virtual void DoDispose(void)
Destructor implementation.
static uint32_t BsrId2BufferSize(uint8_t val)
Convert BSR ID to buffer size.
uint8_t m_transmissionMode
transmission mode
Template for the implementation of the LteFfrSapUser as a member of an owner class of type C to which...
void DoSchedDlTriggerReq(const struct FfMacSchedSapProvider::SchedDlTriggerReqParameters ¶ms)
Sched DL trigger request function.
FfMacSchedSapProvider * m_schedSapProvider
sched SAP provider
void RefreshDlCqiMaps(void)
Refresh DL CQI maps function.
Parameters of the API primitives.
Parameters of the SCHED_UL_MAC_CTRL_INFO_REQ primitive.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
std::map< uint16_t, UlHarqProcessesStatus_t > m_ulHarqProcessesStatus
UL HARQ process status.
virtual std::vector< bool > GetAvailableDlRbg()=0
Get vector of available RBG in DL for this Cell.
void DoSchedDlMacBufferReq(const struct FfMacSchedSapProvider::SchedDlMacBufferReqParameters ¶ms)
Sched DL MAC buffer request function.
FfMacCschedSapUser * m_cschedSapUser
Csched SAP user.
void DoSchedUlTriggerReq(const struct FfMacSchedSapProvider::SchedUlTriggerReqParameters ¶ms)
Sched UL trigger request function.
std::vector< DlInfoListElement_s > m_dlInfoListBuffered
HARQ retx buffered.
Parameters of the SCHED_UL_SR_INFO_REQ primitive.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
Parameters of the SCHED_DL_RACH_INFO_REQ primitive.
Parameters of the SCHED_UL_CONFIG_IND primitive.
std::map< uint16_t, DlHarqProcessesStatus_t > m_dlHarqProcessesStatus
DL HARQ process status.
uint32_t m_creditLimit
flow credit limit (byte)
MemberSchedSapProvider class.
Parameters of the CSCHED_UE_CONFIG_REQ primitive.
uint8_t m_dai
DL assignment index.
std::map< uint16_t, uint8_t > m_ulHarqCurrentProcessId
UL HARQ current process ID.
virtual FfMacSchedSapProvider * GetFfMacSchedSapProvider()
Get FF MAC sched SAP provider function.
uint32_t maxTokenPoolSize
maximum size of token pool (byte)
struct DlDciListElement_s m_dci
DCI.
std::vector< struct BuildRarListElement_s > m_buildRarList
build rar list
std::map< uint16_t, uint8_t > m_p10CqiRxed
Map of UE's DL CQI P01 received.
void RefreshUlCqiMaps(void)
Refresh UL CQI maps function.
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
a unique identifier for an interface.
uint8_t m_resAlloc
The type of resource allocation.
static const int FdTbfqType0AllocationRbg[4]
FdTbfqType0AllocationRbg value array.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
void DoCschedUeReleaseReq(const struct FfMacCschedSapProvider::CschedUeReleaseReqParameters ¶ms)
CSched UE release request function.
void UpdateUlRlcBufferInfo(uint16_t rnti, uint16_t size)
Update UL RLC buffer info function.
void DoCschedUeConfigReq(const struct FfMacCschedSapProvider::CschedUeConfigReqParameters ¶ms)
CSched UE config request function.
uint8_t UpdateHarqProcessId(uint16_t rnti)
Update and return a new process Id for the RNTI specified.
int m_debtLimit
flow debt limit (byte)
std::map< uint16_t, uint32_t > m_ceBsrRxed
Map of UE's buffer status reports received.
void UpdateDlRlcBufferInfo(uint16_t rnti, uint8_t lcid, uint16_t size)
Update DL RLC buffer info function.
void TransmissionModeConfigurationUpdate(uint16_t rnti, uint8_t txMode)
Transmisson mode config update function.
std::vector< struct BuildDataListElement_s > m_buildDataList
build data list
uint8_t m_ueTxAntennaSelection
UE antenna selection.
See section 4.3.8 builDataListElement.