21 #include "ns3/simulator.h" 24 #include "ns3/lte-rlc-header.h" 25 #include "ns3/lte-rlc-um.h" 26 #include "ns3/lte-rlc-sdu-status-tag.h" 27 #include "ns3/lte-rlc-tag.h" 36 : m_maxTxBufferSize (10 * 1024),
43 m_expectedSeqNumber (0)
61 .AddAttribute (
"MaxTxBufferSize",
62 "Maximum Size of the Transmission Buffer (in Bytes)",
65 MakeUintegerChecker<uint32_t> ())
126 if (txOpParams.
bytes <= 2)
137 uint32_t nextSegmentSize = txOpParams.
bytes - 2;
138 uint32_t nextSegmentId = 1;
139 uint32_t dataFieldTotalSize = 0;
140 uint32_t dataFieldAddedSize = 0;
141 std::vector < Ptr<Packet> > dataField;
157 NS_LOG_LOGIC (
"Next segment size = " << nextSegmentSize);
163 while ( firstSegment && (firstSegment->
GetSize () > 0) && (nextSegmentSize > 0) )
165 NS_LOG_LOGIC (
"WHILE ( firstSegment && firstSegment->GetSize > 0 && nextSegmentSize > 0 )");
167 NS_LOG_LOGIC (
" nextSegmentSize = " << nextSegmentSize);
168 if ( (firstSegment->
GetSize () > nextSegmentSize) ||
170 (firstSegment->
GetSize () > 2047)
175 uint32_t currSegmentSize =
std::min (firstSegment->
GetSize (), nextSegmentSize);
177 NS_LOG_LOGIC (
" IF ( firstSegment > nextSegmentSize ||");
205 if (firstSegment->
GetSize () > 0)
212 NS_LOG_LOGIC (
" TX buffer: Give back the remaining segment");
237 dataFieldAddedSize = newSegment->
GetSize ();
238 dataFieldTotalSize += dataFieldAddedSize;
239 dataField.push_back (newSegment);
247 nextSegmentSize -= dataFieldAddedSize;
255 else if ( (nextSegmentSize - firstSegment->
GetSize () <= 2) || (
m_txBuffer.size () == 0) )
257 NS_LOG_LOGIC (
" IF nextSegmentSize - firstSegment->GetSize () <= 2 || txBuffer.size == 0");
259 dataFieldAddedSize = firstSegment->
GetSize ();
260 dataFieldTotalSize += dataFieldAddedSize;
261 dataField.push_back (firstSegment);
269 nextSegmentSize -= dataFieldAddedSize;
278 NS_LOG_LOGIC (
" Next segment size = " << nextSegmentSize);
287 NS_LOG_LOGIC (
" IF firstSegment < NextSegmentSize && txBuffer.size > 0");
289 dataFieldAddedSize = firstSegment->
GetSize ();
290 dataFieldTotalSize += dataFieldAddedSize;
291 dataField.push_back (firstSegment);
297 rlcHeader.PushLengthIndicator (firstSegment->
GetSize ());
299 nextSegmentSize -= ((nextSegmentId % 2) ? (2) : (1)) + dataFieldAddedSize;
308 NS_LOG_LOGIC (
" Next segment size = " << nextSegmentSize);
312 firstSegment =
m_txBuffer.begin ()->m_pdu->Copy ();
313 firstSegmentTime =
m_txBuffer.begin ()->m_waitingSince;
325 std::vector< Ptr<Packet> >::iterator it;
326 it = dataField.begin ();
328 uint8_t framingInfo = 0;
332 NS_ASSERT_MSG ((*it)->PeekPacketTag (tag),
"LteRlcSduStatusTag is missing");
333 (*it)->PeekPacketTag (tag);
344 while (it < dataField.end ())
346 NS_LOG_LOGIC (
"Adding SDU/segment to packet, length = " << (*it)->GetSize ());
348 NS_ASSERT_MSG ((*it)->PeekPacketTag (tag),
"LteRlcSduStatusTag is missing");
349 (*it)->RemovePacketTag (tag);
373 rlcHeader.SetFramingInfo (framingInfo);
388 params.layer = txOpParams.
layer;
389 params.harqProcessId = txOpParams.
harqId;
496 NS_LOG_LOGIC (
"VR(UR) is outside the reordering window");
511 std::map <uint16_t, Ptr<Packet> >::iterator it;
516 newVrUr = (it->first) + 1;
583 NS_LOG_LOGIC (seqNumber <<
" is INSIDE the reordering window");
588 NS_LOG_LOGIC (seqNumber <<
" is OUTSIDE the reordering window");
605 expectedSnLost =
true;
611 expectedSnLost =
false;
617 uint8_t extensionBit;
618 uint16_t lengthIndicator;
624 if ( extensionBit == 0 )
634 if ( lengthIndicator >= packet->
GetSize () )
636 NS_LOG_LOGIC (
"INTERNAL ERROR: Not enough data in the packet (" << packet->
GetSize () <<
"). Needed LI=" << lengthIndicator);
646 while ( extensionBit == 1 );
648 std::list < Ptr<Packet> >::iterator it;
653 else NS_LOG_LOGIC (
"Reassembling State = Unknown state");
656 NS_LOG_LOGIC (
"Framing Info = " << (uint16_t)framingInfo);
754 NS_LOG_LOGIC (
"INTERNAL ERROR: Transition not possible. FI = " << (uint32_t) framingInfo);
825 NS_LOG_LOGIC (
"INTERNAL ERROR: Transition not possible. FI = " << (uint32_t) framingInfo);
930 NS_LOG_LOGIC (
"INTERNAL ERROR: Transition not possible. FI = " << (uint32_t) framingInfo);
1047 NS_LOG_LOGIC (
"INTERNAL ERROR: Transition not possible. FI = " << (uint32_t) framingInfo);
1066 std::map <uint16_t, Ptr<Packet> >::iterator it;
1076 std::map <uint16_t, Ptr<Packet> >::iterator it_tmp = it;
1083 NS_LOG_LOGIC (
"(SN = " << it->first <<
") is inside the reordering window");
1090 NS_LOG_LOGIC (
"Reassemble SN between " << lowSeqNumber <<
" and " << highSeqNumber);
1092 std::map <uint16_t, Ptr<Packet> >::iterator it;
1097 while (reassembleSn < highSeqNumber)
1122 uint32_t queueSize = 0;
1160 std::map <uint16_t, Ptr<Packet> >::iterator it;
uint32_t m_maxTxBufferSize
maximum transmit buffer status
bool FindFirstMatchingByteTag(Tag &tag) const
Finds the first tag matching the parameter Tag type.
uint32_t RemoveHeader(Header &header)
Deserialize and remove the header from the internal buffer.
TracedCallback< uint16_t, uint8_t, uint32_t > m_txPdu
Used to inform of a PDU delivery to the MAC SAP provider.
virtual uint32_t GetSerializedSize() const
Simulation virtual time values and global simulation resolution.
Store an incoming (from layer above us) PDU, waiting to transmit it.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
Parameters for LteMacSapUser::NotifyTxOpportunity.
LTE RLC Unacknowledged Mode (UM), see 3GPP TS 36.322.
uint16_t GetValue() const
Extracts the numeric value of the sequence number.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
uint32_t GetSize(void) const
Returns the the size in bytes of the packet (including the zero-filled initial payload).
NS_ASSERT_MSG(false, "Ipv4AddressGenerator::MaskToIndex(): Impossible")
void ReassembleAndDeliver(Ptr< Packet > packet)
Reassemble and deliver function.
void DoReportBufferStatus()
Report buffer status.
Tag to calculate the per-PDU delay from eNb RLC to UE RLC.
Ptr< Packet > CreateFragment(uint32_t start, uint32_t length) const
Create a new packet which contains a fragment of the original packet.
#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.
uint32_t retxQueueSize
the current size of the RLC retransmission queue in bytes
virtual void DoTransmitPdcpPdu(Ptr< Packet > p)
RLC SAP.
std::vector< TxPdu > m_txBuffer
Transmission buffer.
virtual void DoNotifyHarqDeliveryFailure()
Notify HARQ delivery failure.
SequenceNumber10 m_vrUr
VR(UR)
uint16_t rnti
the C-RNTI identifying the UE
uint8_t harqId
the HARQ ID
SequenceNumber10 m_sequenceNumber
State variables.
void ReassembleSnInterval(SequenceNumber10 lowSeqNumber, SequenceNumber10 highSeqNumber)
Reassemble SN interval function.
void SetModulusBase(SequenceNumber10 modulusBase)
Set modulus base.
Parameters for LteMacSapProvider::ReportBufferStatus.
virtual void DoNotifyTxOpportunity(LteMacSapUser::TxOpportunityParameters txOpParams)
MAC SAP.
SequenceNumber10 m_vrUh
VR(UH)
uint16_t txQueueHolDelay
the Head Of Line delay of the transmission queue
void AddAtEnd(Ptr< const Packet > packet)
Concatenate the input packet at the end of the current packet.
uint8_t GetStatus(void) const
Get status function.
LteRlcSapUser * m_rlcSapUser
RLC SAP user.
SequenceNumber10 m_expectedSeqNumber
Expected Sequence Number.
void RemoveAtStart(uint32_t size)
Remove size bytes from the start of the current packet.
static EventId Schedule(Time const &delay, MEM mem_ptr, OBJ obj)
Schedule an event to expire after delay.
static TypeId GetTypeId(void)
Get the type ID.
Hold an unsigned integer type.
ReassemblingState_t m_reassemblingState
reassembling state
uint8_t componentCarrierId
the component carrier id
virtual void ReceivePdcpPdu(Ptr< Packet > p)=0
Called by the RLC entity to notify the PDCP entity of the reception of a new PDCP PDU...
virtual void DoDispose()
Destructor implementation.
uint32_t PeekHeader(Header &header) const
Deserialize but does not remove the header from the internal buffer.
LteMacSapProvider * m_macSapProvider
MAC SAP provider.
Ptr< Packet > m_keepS0
keep S0
Every class exported by the ns3 library is enclosed in the ns3 namespace.
int64_t GetNanoSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
SequenceNumber10 m_vrUx
VR(UX)
uint16_t m_windowSize
Constants.
void ExpireReorderingTimer(void)
Expire reordering timer.
uint8_t lcid
the logical channel id corresponding to the sending RLC instance
uint32_t txQueueSize
the current size of the RLC transmission queue
static Time Now(void)
Return the current simulation virtual time.
std::map< uint16_t, Ptr< Packet > > m_rxBuffer
Reception buffer.
NS_LOG_LOGIC("Net device "<< nd<< " is not bridged")
EventId m_reorderingTimer
Timers.
uint32_t bytes
the number of bytes to transmit
uint16_t statusPduSize
the current size of the pending STATUS RLC PDU message in bytes
std::list< Ptr< Packet > > m_sdusBuffer
List of SDUs in a packet.
uint8_t layer
the layer of transmission (MIMO)
void AddPacketTag(const Tag &tag) const
Add a packet tag.
This class implements a tag that carries the status of a RLC SDU for the fragmentation process Status...
int64_t GetMilliSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
bool RemovePacketTag(Tag &tag)
Remove a packet tag.
void ReassembleOutsideWindow(void)
Reassemble outside window.
bool IsInsideReorderingWindow(SequenceNumber10 seqNumber)
Is inside reordering window function.
bool IsRunning(void) const
This method is syntactic sugar for !IsExpired().
void SetStatus(uint8_t status)
Set status function.
virtual void DoDispose()
Destructor implementation.
uint16_t retxQueueHolDelay
the Head Of Line delay of the retransmission queue
Ptr< Packet > pdu
the RLC PDU
void Cancel(void)
This method is syntactic sugar for the ns3::Simulator::Cancel method.
virtual void ReportBufferStatus(ReportBufferStatusParameters params)=0
Report the RLC buffer status to the MAC.
uint32_t m_txBufferSize
transmit buffer size
Parameters for LteMacSapUser::ReceivePdu.
virtual void DoReceivePdu(LteMacSapUser::ReceivePduParameters rxPduParams)
Receive PDU function.
void ExpireRbsTimer(void)
Expire RBS timer.
TracedCallback< uint16_t, uint8_t, uint32_t, uint64_t > m_rxPdu
Used to inform of a PDU reception from the MAC SAP user.
EventId m_rbsTimer
RBS timer.
virtual void TransmitPdu(TransmitPduParameters params)=0
send an RLC PDU to the MAC for transmission.
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
This abstract base class defines the API to interact with the Radio Link Control (LTE_RLC) in LTE...
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
void AddByteTag(const Tag &tag) const
Tag each byte included in this packet with a new byte tag.
void AddHeader(const Header &header)
Add header to this packet.
Ptr< Packet > p
the RLC PDU to be received
Parameters for LteMacSapProvider::TransmitPdu.