25 #include <ns3/pointer.h>
26 #include <ns3/packet.h>
27 #include <ns3/packet-burst.h>
28 #include <ns3/random-variable.h>
33 #include <ns3/ff-mac-common.h>
34 #include <ns3/lte-control-messages.h>
35 #include <ns3/simulator.h>
36 #include <ns3/lte-common.h>
62 virtual void RemoveLc (uint8_t lcId);
63 virtual void Reset ();
198 .AddConstructor<LteUeMac> ();
206 m_freshUlBsr (false),
209 m_rachConfigured (false),
210 m_waitingForRaResponse (false)
296 std::map <uint8_t, LteMacSapProvider::ReportBufferStatusParameters>::iterator it;
303 (*it).second = params;
307 m_ulBsrReceived.insert (std::pair<uint8_t, LteMacSapProvider::ReportBufferStatusParameters> (params.
lcid, params));
334 std::map <uint8_t, LteMacSapProvider::ReportBufferStatusParameters>::iterator it;
335 std::vector<uint32_t> queue (4, 0);
338 uint8_t lcid = it->first;
339 std::map <uint8_t, LcInfo>::iterator lcInfoMapIt;
342 NS_ASSERT_MSG ((lcid != 0) || (((*it).second.txQueueSize == 0)
343 && ((*it).second.retxQueueSize == 0)
344 && ((*it).second.statusPduSize == 0)),
345 "BSR should not be used for LCID 0");
346 uint8_t lcg = lcInfoMapIt->second.lcConfig.logicalChannelGroup;
347 queue.at (lcg) += ((*it).second.txQueueSize + (*it).second.retxQueueSize + (*it).second.statusPduSize);
371 bool contention =
true;
420 const uint8_t lc0Lcid = 0;
421 std::map <uint8_t, LcInfo>::iterator lc0InfoIt =
m_lcInfoMap.find (lc0Lcid);
423 std::map <uint8_t, LteMacSapProvider::ReportBufferStatusParameters>::iterator lc0BsrIt
426 && (lc0BsrIt->second.txQueueSize > 0))
429 "segmentation of Message 3 is not allowed");
430 lc0InfoIt->second.macSapUser->NotifyTxOpportunity (raResponse.
m_grant.
m_tbSize, 0, 0);
431 lc0BsrIt->second.txQueueSize = 0;
444 NS_LOG_INFO (
"RAR timeout, preambleTransMax reached => giving up");
485 NS_ASSERT_MSG (prachMask == 0,
"requested PRACH MASK = " << (uint32_t) prachMask <<
", but only PRACH MASK = 0 is supported");
488 bool contention =
false;
500 lcInfo.macSapUser = msu;
516 std::map <uint8_t, LcInfo>::iterator it =
m_lcInfoMap.begin ();
547 it->second.macSapUser->ReceivePdu (p);
566 std::map <uint8_t, LteMacSapProvider::ReportBufferStatusParameters>::iterator itBsr;
567 uint16_t activeLcs = 0;
568 uint32_t statusPduMinSize = 0;
571 if (((*itBsr).second.statusPduSize > 0) || ((*itBsr).second.retxQueueSize > 0) || ((*itBsr).second.txQueueSize > 0))
574 if (((*itBsr).second.statusPduSize!=0)&&((*itBsr).second.statusPduSize < statusPduMinSize))
576 statusPduMinSize = (*itBsr).second.statusPduSize;
578 if (((*itBsr).second.statusPduSize!=0)&&(statusPduMinSize == 0))
580 statusPduMinSize = (*itBsr).second.statusPduSize;
586 NS_LOG_ERROR (
this <<
" No active flows for this UL-DCI");
589 std::map <uint8_t, LcInfo>::iterator it;
590 uint32_t bytesPerActiveLc = dci.m_tbSize / activeLcs;
591 bool statusPduPriority =
false;
592 if ((statusPduMinSize != 0)&&(bytesPerActiveLc < statusPduMinSize))
595 statusPduPriority =
true;
596 NS_LOG_DEBUG (
this <<
" Reduced resource -> send only Status, b ytes " << statusPduMinSize);
597 if (dci.m_tbSize < statusPduMinSize)
599 NS_FATAL_ERROR (
"Insufficient Tx Opportunity for sending a status message");
602 NS_LOG_LOGIC (
this <<
" UE " <<
m_rnti <<
": UL-CQI notified TxOpportunity of " << dci.m_tbSize <<
" => " << bytesPerActiveLc <<
" bytes per active LC" <<
" statusPduMinSize " << statusPduMinSize);
606 NS_LOG_DEBUG (
this <<
" Processing LC " << (uint32_t)(*it).first <<
" bytesPerActiveLc " << bytesPerActiveLc);
608 ( ((*itBsr).second.statusPduSize > 0) ||
609 ((*itBsr).second.retxQueueSize > 0) ||
610 ((*itBsr).second.txQueueSize > 0)) )
612 if ((statusPduPriority) && ((*itBsr).second.statusPduSize == statusPduMinSize))
614 (*it).second.macSapUser->NotifyTxOpportunity ((*itBsr).second.statusPduSize, 0, 0);
615 NS_LOG_LOGIC (
this <<
"\t" << bytesPerActiveLc <<
" send " << (*itBsr).second.statusPduSize <<
" status bytes to LC " << (uint32_t)(*it).first <<
" statusQueue " << (*itBsr).second.statusPduSize <<
" retxQueue" << (*itBsr).second.retxQueueSize <<
" txQueue" << (*itBsr).second.txQueueSize);
616 (*itBsr).second.statusPduSize = 0;
621 uint32_t bytesForThisLc = bytesPerActiveLc;
622 NS_LOG_LOGIC (
this <<
"\t" << bytesPerActiveLc <<
" bytes to LC " << (uint32_t)(*it).first <<
" statusQueue " << (*itBsr).second.statusPduSize <<
" retxQueue" << (*itBsr).second.retxQueueSize <<
" txQueue" << (*itBsr).second.txQueueSize);
623 if (((*itBsr).second.statusPduSize > 0) && (bytesForThisLc > (*itBsr).second.statusPduSize))
625 (*it).second.macSapUser->NotifyTxOpportunity ((*itBsr).second.statusPduSize, 0, 0);
626 bytesForThisLc -= (*itBsr).second.statusPduSize;
627 NS_LOG_DEBUG (
this <<
" serve STATUS " << (*itBsr).second.statusPduSize);
628 (*itBsr).second.statusPduSize = 0;
632 if ((*itBsr).second.statusPduSize>bytesForThisLc)
634 NS_FATAL_ERROR (
"Insufficient Tx Opportunity for sending a status message");
638 if ((bytesForThisLc > 7) &&
639 (((*itBsr).second.retxQueueSize > 0) ||
640 ((*itBsr).second.txQueueSize > 0)))
642 if ((*itBsr).second.retxQueueSize > 0)
644 NS_LOG_DEBUG (
this <<
" serve retx DATA, bytes " << bytesForThisLc);
645 (*it).second.macSapUser->NotifyTxOpportunity (bytesForThisLc, 0, 0);
646 if ((*itBsr).second.retxQueueSize >= bytesForThisLc)
648 (*itBsr).second.retxQueueSize -= bytesForThisLc;
652 (*itBsr).second.retxQueueSize = 0;
655 else if ((*itBsr).second.txQueueSize > 0)
657 uint16_t lcid = (*it).first;
658 uint32_t rlcOverhead;
672 NS_LOG_DEBUG (
this <<
" serve tx DATA, bytes " << bytesForThisLc <<
", RLC overhead " << rlcOverhead);
673 (*it).second.macSapUser->NotifyTxOpportunity (bytesForThisLc, 0, 0);
674 if ((*itBsr).second.txQueueSize >= bytesForThisLc - rlcOverhead)
676 (*itBsr).second.txQueueSize -= bytesForThisLc - rlcOverhead;
680 (*itBsr).second.txQueueSize = 0;
686 if ( ((*itBsr).second.retxQueueSize > 0) || ((*itBsr).second.txQueueSize > 0))
692 NS_LOG_LOGIC (
this <<
"\t" << bytesPerActiveLc <<
"\t new queues " << (uint32_t)(*it).first <<
" statusQueue " << (*itBsr).second.statusPduSize <<
" retxQueue" << (*itBsr).second.retxQueueSize <<
" txQueue" << (*itBsr).second.txQueueSize);
717 uint16_t raRnti = rarMsg->GetRaRnti ();
718 NS_LOG_LOGIC (
this <<
"got RAR with RA-RNTI " << (uint32_t) raRnti <<
", expecting " << (uint32_t)
m_raRnti);
719 if (raRnti == m_raRnti)
721 for (std::list<RarLteControlMessage::Rar>::const_iterator it = rarMsg->RarListBegin ();
722 it != rarMsg->RarListEnd ();
738 NS_LOG_WARN (
this <<
" LteControlMessage not recognized");
754 NS_LOG_INFO (
this <<
" HARQ Proc Id " << i <<
" packets buffer expired");
uint8_t numberOfRaPreambles
virtual void AddLc(uint8_t lcId, LteUeCmacSapProvider::LogicalChannelConfig lcConfig, LteMacSapUser *msu)
add a new Logical Channel (LC)
void DoStartNonContentionBasedRandomAccessProcedure(uint16_t rnti, uint8_t rapId, uint8_t prachMask)
LteUeCmacSapProvider::LogicalChannelConfig lcConfig
uint8_t GetLcid(void) const
Simulation virtual time values and global simulation resolution.
uint8_t raResponseWindowSize
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
void SetStream(int64_t stream)
Specifies the stream number for this RNG stream.
virtual void TransmitPdu(TransmitPduParameters params)
send an RLC PDU to the MAC for transmission.
void SendRaPreamble(bool contention)
void StartWaitingForRaResponse()
void DoReceivePhyPdu(Ptr< Packet > p)
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register the class in the ns-3 factory.
Ptr< UniformRandomVariable > m_raPreambleUniformVariable
uint16_t GetRnti(void) const
LteUePhySapUser * m_uePhySapUser
void AddPacketTag(const Tag &tag) const
Add a packet tag.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
void RaResponseTimeout(bool contention)
See section 4.3.2 ulDciListElement.
virtual void ReportBufferStatus(ReportBufferStatusParameters params)
Report the RLC buffer status to the MAC.
struct MacCeValue_u m_macCeValue
virtual void DoDispose(void)
This method is called by Object::Dispose or by the object's destructor, whichever comes first...
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
#define NS_FATAL_ERROR(msg)
fatal error handling
See section 4.3.10 buildRARListElement.
void DoAddLc(uint8_t lcId, LteUeCmacSapProvider::LogicalChannelConfig lcConfig, LteMacSapUser *msu)
void SetLteUePhySapProvider(LteUePhySapProvider *s)
Set the PHY SAP Provider.
virtual void SendRachPreamble(uint32_t prachId, uint32_t raRnti)=0
send a preamble on the PRACH
static EventId Schedule(Time const &time, MEM mem_ptr, OBJ obj)
Schedule an event to expire at the relative time "time" is reached.
Service Access Point (SAP) offered by the PHY to the MAC.
uint8_t lcid
the logical channel id corresponding to the sending RLC instance
void DoStartContentionBasedRandomAccessProcedure()
void SendReportBufferStatus(void)
virtual void SubframeIndication(uint32_t frameNo, uint32_t subframeNo)
Trigger the start from a new frame (input from Phy layer)
virtual void StartContentionBasedRandomAccessProcedure()
tell the MAC to start a contention-based random access procedure, e.g., to perform RRC connection est...
void DoRemoveLc(uint8_t lcId)
Parameters for LteMacSapProvider::ReportBufferStatus.
std::vector< uint8_t > m_miUlHarqProcessesPacketTimer
friend class UeMemberLteUePhySapUser
void SetLteUeCmacSapUser(LteUeCmacSapUser *s)
void DoTransmitPdu(LteMacSapProvider::TransmitPduParameters params)
virtual void ConfigureRach(RachConfig rc)
virtual void SetTemporaryCellRnti(uint16_t rnti)=0
friend class UeMemberLteMacSapProvider
static uint8_t BufferSize2BsrId(uint32_t val)
virtual void Reset()
reset the MAC
bool m_waitingForRaResponse
void DoReportBufferStatus(LteMacSapProvider::ReportBufferStatusParameters params)
virtual void StartNonContentionBasedRandomAccessProcedure(uint16_t rnti, uint8_t preambleId, uint8_t prachMask)
tell the MAC to start a non-contention-based random access procedure, e.g., as a consequence of hando...
virtual void SendMacPdu(Ptr< Packet > p)=0
Send the MAC PDU to the channel.
LteUeCmacSapProvider * m_cmacSapProvider
uint16_t rnti
the C-RNTI identifying the UE
std::vector< Ptr< PacketBurst > > m_miUlHarqProcessesPacket
LteUeCmacSapProvider * GetLteUeCmacSapProvider(void)
Service Access Point (SAP) offered by the UE MAC to the UE RRC.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
void DoConfigureRach(LteUeCmacSapProvider::RachConfig rc)
virtual void NotifyRandomAccessSuccessful()=0
Notify the RRC that the MAC Random Access procedure completed successfully.
See section 4.3.14 macCEListElement.
void DoSubframeIndication(uint32_t frameNo, uint32_t subframeNo)
Forwarded from LteUePhySapUser: trigger the start from a new frame.
UeMemberLteUeCmacSapProvider(LteUeMac *mac)
void DoReceiveLteControlMessage(Ptr< LteControlMessage > msg)
Ptr< Packet > Copy(void) const
performs a COW copy of the packet.
std::map< uint8_t, LcInfo > m_lcInfoMap
virtual void SendLteControlMessage(Ptr< LteControlMessage > msg)=0
Send SendLteControlMessage (PDCCH map, CQI feedbacks) using the ideal control channel.
LteUePhySapUser * GetLteUePhySapUser()
Get the PHY SAP user.
LteMacSapProvider * GetLteMacSapProvider(void)
uint16_t m_backoffParameter
static TypeId GetTypeId(void)
UeMemberLteUePhySapUser(LteUeMac *mac)
LteMacSapProvider * m_macSapProvider
Service Access Point (SAP) offered by the UE MAC to the UE RRC.
uint8_t lcid
the logical channel id corresponding to the sending RLC instance
virtual void ReceivePhyPdu(Ptr< Packet > p)
Called by the Phy to notify the MAC of the reception of a new PHY-PDU.
LteUePhySapProvider * m_uePhySapProvider
static Time Now(void)
Return the "current simulation time".
virtual void RemoveLc(uint8_t lcId)
remove an existing LC
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
std::vector< uint8_t > m_bufferStatus
virtual void NotifyRandomAccessFailed()=0
Notify the RRC that the MAC Random Access procedure failed.
void RandomlySelectAndSendRaPreamble()
void RecvRaResponse(BuildRarListElement_s raResponse)
uint8_t m_preambleTransmissionCounter
Service Access Point (SAP) offered by the MAC to the RLC See Femto Forum MAC Scheduler Interface Spec...
EventId m_noRaResponseReceivedEvent
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
virtual void DoDispose(void)
This method is called by Object::Dispose or by the object's destructor, whichever comes first...
LteUeCmacSapProvider::RachConfig m_rachConfig
Service Access Point (SAP) offered by the UE-PHY to the UE-MAC.
bool RemovePacketTag(Tag &tag)
Remove a packet tag.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
Ptr< Packet > pdu
the RLC PDU
void Cancel(void)
This method is syntactic sugar for the ns3::Simulator::cancel method.
Service Access Point (SAP) offered by the MAC to the RLC See Femto Forum MAC Scheduler Interface Spec...
Tag used to define the RNTI and LC id for each MAC packet trasmitted.
enum ns3::MacCeListElement_s::MacCeType_e m_macCeType
virtual void ReceiveLteControlMessage(Ptr< LteControlMessage > msg)
Receive SendLteControlMessage (PDCCH map, CQI feedbacks) using the ideal control channel.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
std::map< uint8_t, LteMacSapProvider::ReportBufferStatusParameters > m_ulBsrReceived
a base class which provides memory management and object aggregation
friend class UeMemberLteUeCmacSapProvider
int64_t AssignStreams(int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model...
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
void RefreshHarqProcessesPacketBuffer(void)
UeMemberLteMacSapProvider(LteUeMac *mac)
LteUeCmacSapUser * m_cmacSapUser
Parameters for LteMacSapProvider::TransmitPdu.