25 #include "ns3/packet.h"
26 #include "ns3/fatal-error.h"
40 .AddConstructor<TcpTxBuffer> ()
41 .AddTraceSource (
"UnackSequence",
42 "First unacknowledged sequence number (SND.UNA)",
56 : m_firstByteSeq (n), m_size (0), m_maxBuffer (32768), m_data (0)
116 NS_LOG_LOGIC (
"Rejected. Not enough room to buffer packet.");
128 ", returns " << lastSeq - seq);
129 return lastSeq - seq;
139 return Create<Packet> ();
143 return Create<Packet> (
s);
149 uint32_t pktSize = 0;
150 bool beginFound =
false;
157 pktSize = (*i)->GetSize ();
160 if (count + pktSize > offset)
162 NS_LOG_LOGIC (
"First byte found in packet #" << pktCount <<
" at buffer offset " << count
163 <<
", packet len=" << pktSize);
165 uint32_t packetOffset = offset - count;
166 uint32_t fragmentLength = count + pktSize - offset;
167 if (fragmentLength >= s)
169 return (*i)->CreateFragment (packetOffset, s);
178 else if (count + pktSize >= offset + s)
180 NS_LOG_LOGIC (
"Last byte found in packet #" << pktCount <<
" at buffer offset " << count
181 <<
", packet len=" << pktSize);
182 uint32_t fragmentLength = offset + s - count;
190 NS_LOG_LOGIC (
"Appending to output the packet #" << pktCount <<
" of offset " << count <<
" len=" << pktSize);
212 <<
", numPkts=" <<
m_data.size ());
221 while (i !=
m_data.end ())
223 if (offset > (*i)->GetSize ())
225 pktSize = (*i)->GetSize ();
230 NS_LOG_LOGIC (
"Removed one packet of size " << pktSize <<
", offset=" << offset);
234 pktSize = (*i)->GetSize () - offset;
235 *i = (*i)->CreateFragment (offset, pktSize);
238 NS_LOG_LOGIC (
"Fragmented one packet by size " << offset <<
", new size=" << pktSize);
248 <<
" numPkts="<<
m_data.size ());
uint32_t Size(void) const
#define NS_LOG_FUNCTION(parameters)
void DiscardUpTo(const SequenceNumber32 &seq)
uint32_t SizeFromSequence(const SequenceNumber32 &seq) const
SequenceNumber32 HeadSequence(void) const
#define NS_ASSERT(condition)
uint32_t MaxBufferSize(void) const
#define NS_LOG_COMPONENT_DEFINE(name)
uint32_t GetSize(void) const
SequenceNumber< uint32_t, int32_t > SequenceNumber32
Ptr< Packet > CreateFragment(uint32_t start, uint32_t length) const
void AddAtEnd(Ptr< const Packet > packet)
TracedValue< SequenceNumber32 > m_firstByteSeq
#define NS_LOG_LOGIC(msg)
void SetMaxBufferSize(uint32_t n)
uint32_t Available(void) const
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
bool Add(Ptr< Packet > p)
static TypeId GetTypeId(void)
a base class which provides memory management and object aggregation
TcpTxBuffer(uint32_t n=0)
virtual ~TcpTxBuffer(void)
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
std::list< Ptr< Packet > >::iterator BufIterator
SequenceNumber32 TailSequence(void) const
std::list< Ptr< Packet > > m_data
void SetHeadSequence(const SequenceNumber32 &seq)
Ptr< Packet > CopyFromSequence(uint32_t numBytes, const SequenceNumber32 &seq)