23 #include <ns3/pointer.h>
26 #include <ns3/simulator.h>
27 #include <ns3/lte-amc.h>
28 #include <ns3/tdmt-ff-mac-scheduler.h>
29 #include <ns3/lte-vendor-specific-parameters.h>
143 : m_scheduler (scheduler)
218 : m_cschedSapUser (0),
222 m_amc = CreateObject <LteAmc> ();
245 .AddConstructor<TdMtFfMacScheduler> ()
246 .AddAttribute (
"CqiTimerThreshold",
247 "The number of TTIs a CQI is valid (default 1000 - 1 sec.)",
250 MakeUintegerChecker<uint32_t> ())
314 std::set<uint16_t>::iterator it;
357 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
365 m_rlcBufferReq.insert (std::pair <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters> (flow, params));
369 (*it).second = params;
392 for (
int i = 0; i < 4; i++)
407 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
411 if (((*it).first.m_rnti == rnti) && (((*it).second.m_rlcTransmissionQueueSize > 0)
412 || ((*it).second.m_rlcRetransmissionQueueSize > 0)
413 || ((*it).second.m_rlcStatusPduSize > 0) ))
417 if ((*it).first.m_rnti > rnti)
442 std::map <uint16_t, std::vector <uint16_t> > allocationMap;
443 std::set <uint16_t>::iterator it;
445 double metricMax = 0.0;
448 std::map <uint16_t,uint8_t>::iterator itCqi;
450 std::map <uint16_t,uint8_t>::iterator itTxMode;
464 wbCqi = (*itCqi).second;
472 double achievableRate = 0.0;
473 for (uint8_t k = 0; k < nLayer; k++)
480 double metric = achievableRate;
482 if (metric > metricMax)
499 std::vector <uint16_t> tempMap;
500 for (
int i = 0; i < rbgNum; i++)
502 tempMap.push_back (i);
504 allocationMap.insert (std::pair <uint16_t, std::vector <uint16_t> > ((*itMax), tempMap));
510 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap = allocationMap.begin ();
511 while (itMap != allocationMap.end ())
515 newEl.
m_rnti = (*itMap).first;
518 std::vector <struct RlcPduListElement_s> newRlcPduLe;
519 newDci.
m_rnti = (*itMap).first;
522 std::map <uint16_t,uint8_t>::iterator itCqi;
524 std::map <uint16_t,uint8_t>::iterator itTxMode;
528 NS_FATAL_ERROR (
"No Transmission Mode info on user " << (*itMap).first);
531 for (uint8_t j = 0; j < nLayer; j++)
535 newDci.
m_mcs.push_back (0);
548 uint32_t rbgMask = 0;
549 for (uint16_t k = 0; k < (*itMap).second.size (); k++)
551 rbgMask = rbgMask + (0x1 << (*itMap).second.at (k));
556 std::map <LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator itBufReq;
559 if (((*itBufReq).first.m_rnti == (*itMap).first) &&
560 (((*itBufReq).second.m_rlcTransmissionQueueSize > 0)
561 || ((*itBufReq).second.m_rlcRetransmissionQueueSize > 0)
562 || ((*itBufReq).second.m_rlcStatusPduSize > 0) ))
564 for (uint8_t j = 0; j < nLayer; j++)
569 newRlcPduLe.push_back (newRlcEl);
573 if ((*itBufReq).first.m_rnti > (*itMap).first)
578 newDci.
m_ndi.push_back (1);
579 newDci.
m_rv.push_back (0);
581 newEl.
m_dci = newDci;
609 for (
unsigned int i = 0; i < params.
m_cqiList.size (); i++)
614 std::map <uint16_t,uint8_t>::iterator it;
615 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
620 m_p10CqiRxed.insert ( std::pair<uint16_t, uint8_t > (rnti, params.
m_cqiList.at (i).m_wbCqi.at (0)) );
627 (*it).second = params.
m_cqiList.at (i).m_wbCqi.at (0);
629 std::map <uint16_t,uint32_t>::iterator itTimers;
637 std::map <uint16_t,SbMeasResult_s>::iterator it;
638 uint16_t rnti = params.
m_cqiList.at (i).m_rnti;
643 m_a30CqiRxed.insert ( std::pair<uint16_t, SbMeasResult_s > (rnti, params.
m_cqiList.at (i).m_sbMeasResult) );
649 (*it).second = params.
m_cqiList.at (i).m_sbMeasResult;
650 std::map <uint16_t,uint32_t>::iterator itTimers;
668 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find (rnti);
682 double sinr = (*itCqi).second.at (i);
689 double estimatedSinr = sinrSum / (double)sinrNum;
691 (*itCqi).second.at (rb) = estimatedSinr;
692 return (estimatedSinr);
703 std::map <uint16_t,uint32_t>::iterator it;
709 if ((*it).second > 0)
730 std::vector <uint16_t> rbgAllocationMap;
759 uldci.
m_rnti = (*it).first;
762 std::map <uint16_t, std::vector <double> >::iterator itCqi =
m_ueCqi.find ((*it).first);
772 double minSinr = (*itCqi).second.at (uldci.
m_rbStart);
779 double sinr = (*itCqi).second.at (i);
784 if ((*itCqi).second.at (i) < minSinr)
786 minSinr = (*itCqi).second.at (i);
791 double s = log2 ( 1 + (
792 std::pow (10, minSinr / 10 ) /
793 ( (-std::log (5.0 * 0.00005 )) / 1.5) ));
809 rbAllocated += rbPerFlow;
811 for (
int i = 0; i < rbPerFlow; i++)
813 rbgAllocationMap.push_back ((*it).first);
816 NS_LOG_DEBUG (
this <<
" UE " << (*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);
873 std::map <uint16_t,uint32_t>::iterator it;
875 for (
unsigned int i = 0; i < params.
m_macCeList.size (); i++)
887 uint8_t bsrId = params.
m_macCeList.at (i).m_macCeValue.m_bufferStatus.at (0);
889 m_ceBsrRxed.insert ( std::pair<uint16_t, uint32_t > (rnti, buffer));
937 std::map <uint16_t, std::vector <uint16_t> >::iterator itMap;
938 std::map <uint16_t, std::vector <double> >::iterator itCqi;
945 for (uint32_t i = 0; i < (*itMap).second.size (); i++)
950 itCqi =
m_ueCqi.find ((*itMap).second.at (i));
954 std::vector <double> newCqi;
959 newCqi.push_back (sinr);
968 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > ((*itMap).second.at (i), newCqi));
975 (*itCqi).second.at (i) = sinr;
977 std::map <uint16_t, uint32_t>::iterator itTimers;
998 rnti = vsp->GetRnti ();
1001 std::map <uint16_t, std::vector <double> >::iterator itCqi;
1006 std::vector <double> newCqi;
1010 newCqi.push_back (sinr);
1011 NS_LOG_DEBUG (
this <<
" RNTI " << rnti <<
" new SRS-CQI for RB " << j <<
" value " << sinr);
1014 m_ueCqi.insert (std::pair <uint16_t, std::vector <double> > (rnti, newCqi));
1024 (*itCqi).second.at (j) = sinr;
1025 NS_LOG_DEBUG (
this <<
" RNTI " << rnti <<
" update SRS-CQI for RB " << j <<
" value " << sinr);
1028 std::map <uint16_t, uint32_t>::iterator itTimers;
1041 NS_FATAL_ERROR (
"TdMtFfMacScheduler supports only PUSCH and SRS UL-CQIs");
1054 std::map <uint16_t,uint32_t>::iterator itP10 =
m_p10CqiTimers.begin ();
1058 if ((*itP10).second == 0)
1061 std::map <uint16_t,uint8_t>::iterator itMap =
m_p10CqiRxed.find ((*itP10).first);
1063 NS_LOG_INFO (
this <<
" P10-CQI exired for user " << (*itP10).first);
1065 std::map <uint16_t,uint32_t>::iterator temp = itP10;
1077 std::map <uint16_t,uint32_t>::iterator itA30 =
m_a30CqiTimers.begin ();
1081 if ((*itA30).second == 0)
1084 std::map <uint16_t,SbMeasResult_s>::iterator itMap =
m_a30CqiRxed.find ((*itA30).first);
1086 NS_LOG_INFO (
this <<
" A30-CQI exired for user " << (*itA30).first);
1088 std::map <uint16_t,uint32_t>::iterator temp = itA30;
1107 std::map <uint16_t,uint32_t>::iterator itUl =
m_ueCqiTimers.begin ();
1111 if ((*itUl).second == 0)
1114 std::map <uint16_t, std::vector <double> >::iterator itMap =
m_ueCqi.find ((*itUl).first);
1115 NS_ASSERT_MSG (itMap !=
m_ueCqi.end (),
" Does not find CQI report for user " << (*itUl).first);
1116 NS_LOG_INFO (
this <<
" UL-CQI exired for user " << (*itUl).first);
1117 (*itMap).second.clear ();
1119 std::map <uint16_t,uint32_t>::iterator temp = itUl;
1137 std::map<LteFlowId_t, FfMacSchedSapProvider::SchedDlRlcBufferReqParameters>::iterator it;
1144 if ((*it).second.m_rlcStatusPduSize <= size)
1146 size -= (*it).second.m_rlcStatusPduSize;
1147 (*it).second.m_rlcStatusPduSize = 0;
1151 (*it).second.m_rlcStatusPduSize -= size;
1155 if ((*it).second.m_rlcRetransmissionQueueSize <= size)
1157 size -= (*it).second.m_rlcRetransmissionQueueSize;
1158 (*it).second.m_rlcRetransmissionQueueSize = 0;
1162 (*it).second.m_rlcRetransmissionQueueSize -= size;
1166 if ((*it).second.m_rlcTransmissionQueueSize <= size)
1168 size -= (*it).second.m_rlcTransmissionQueueSize;
1169 (*it).second.m_rlcTransmissionQueueSize = 0;
1173 (*it).second.m_rlcTransmissionQueueSize -= size;
1179 NS_LOG_ERROR (
this <<
" Does not find DL RLC Buffer Report of UE " << rnti);
1188 std::map <uint16_t,uint32_t>::iterator it =
m_ceBsrRxed.find (rnti);
1191 if ((*it).second >= size)
1193 (*it).second -= size;
1202 NS_LOG_ERROR (
this <<
" Does not find BSR report info of UE " << rnti);
1210 NS_LOG_FUNCTION (
this <<
" RNTI " << rnti <<
" txMode " << (uint16_t)txMode);