33 #define NS_LOG_APPEND_CONTEXT \
34 if (m_node) { std::clog << Simulator::Now ().GetSeconds () << " [node " << m_node->GetId () << "] "; }
38 #include "ns3/trace-source-accessor.h"
39 #include "ns3/simulator.h"
40 #include "ns3/abort.h"
42 #include "ns3/sequence-number.h"
56 .AddConstructor<TcpWestwood>()
57 .AddTraceSource(
"CongestionWindow",
"The TCP connection's congestion window",
59 .AddAttribute(
"FilterType",
"Use this to choose no filter or Tustin's approximation filter",
62 .AddAttribute(
"ProtocolType",
"Use this to let the code run as Westwood or WestwoodPlus",
66 .AddTraceSource(
"EstimatedBW",
"The estimated bandwidth",
89 m_ssThresh(sock.m_ssThresh),
90 m_initialCWnd(sock.m_initialCWnd),
92 m_currentBW(sock.m_currentBW),
93 m_lastSampleBW(sock.m_lastSampleBW),
94 m_lastBW(sock.m_lastBW),
95 m_minRtt(sock.m_minRtt),
96 m_lastAck(sock.m_lastAck),
97 m_prevAckNo(sock.m_prevAckNo),
98 m_accountedFor(sock.m_accountedFor),
99 m_pType(sock.m_pType),
100 m_fType(sock.m_fType),
101 m_IsCount(sock.m_IsCount)
139 return CopyObject<TcpWestwood>(
this);
146 NS_LOG_LOGIC (
"TcpWestwood receieved ACK for seq " << seq <<
167 adder = std::max(1.0, adder);
168 m_cWnd +=
static_cast<uint32_t
>(adder);
316 m_rtt->IncreaseMultiplier();
void InitializeCwnd(void)
EventId m_bwEstimateEvent
int CountAck(const TcpHeader &tcpHeader)
keep track of time values and allow control of global simulation resolution
smart pointer class similar to boost::intrusive_ptr
virtual void EstimateRtt(const TcpHeader &)
#define NS_LOG_FUNCTION(parameters)
Ptr< const AttributeChecker > MakeEnumChecker(int v1, std::string n1, int v2, std::string n2, int v3, std::string n3, int v4, std::string n4, int v5, std::string n5, int v6, std::string n6, int v7, std::string n7, int v8, std::string n8, int v9, std::string n9, int v10, std::string n10, int v11, std::string n11, int v12, std::string n12, int v13, std::string n13, int v14, std::string n14, int v15, std::string n15, int v16, std::string n16, int v17, std::string n17, int v18, std::string n18, int v19, std::string n19, int v20, std::string n20, int v21, std::string n21, int v22, std::string n22)
virtual void ReceivedAck(Ptr< Packet >, const TcpHeader &)
TracedValue< Time > m_lastRtt
SequenceNumber32 HeadSequence(void) const
virtual void NewAck(SequenceNumber32 const &seq)
#define NS_LOG_COMPONENT_DEFINE(name)
#define NS_LOG_FUNCTION_NOARGS()
TracedValue< SequenceNumber32 > m_nextTxSequence
static EventId Schedule(Time const &time, MEM mem_ptr, OBJ obj)
TracedValue< TcpStates_t > m_state
virtual uint32_t Window(void)
#define NS_ABORT_MSG_UNLESS(cond, msg)
Abnormal program termination if cond is false.
virtual void Retransmit(void)
a polymophic address class
double GetSeconds(void) const
TracedValue< uint32_t > m_cWnd
hold variables of type 'enum'
virtual uint32_t GetInitialCwnd(void) const
virtual void SetSSThresh(uint32_t threshold)
NS_OBJECT_ENSURE_REGISTERED(AntennaModel)
virtual void DupAck(const TcpHeader &header, uint32_t count)
A base class for implementation of a stream socket using TCP.
Ptr< RttEstimator > m_rtt
#define NS_LOG_LOGIC(msg)
void UpdateAckedSegments(int acked)
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
SequenceNumber32 m_prevAckNo
virtual int Connect(const Address &address)
static TypeId GetTypeId(void)
virtual void SetSegSize(uint32_t size)
Ptr< const AttributeAccessor > MakeEnumAccessor(T1 a1)
virtual ~TcpWestwood(void)
virtual void NewAck(SequenceNumber32 const &seq)
virtual void ReceivedAck(Ptr< Packet > packet, const TcpHeader &tcpHeader)
virtual void SetInitialCwnd(uint32_t cwnd)
virtual Ptr< TcpSocketBase > Fork(void)
TracedValue< double > m_currentBW
void EstimateBW(int acked, const TcpHeader &tcpHeader, Time rtt)
virtual uint32_t GetSSThresh(void) const
virtual int Connect(const Address &address)
a unique identifier for an interface.
virtual void EstimateRtt(const TcpHeader &header)
TypeId SetParent(TypeId tid)
bool SendPendingData(bool withAck=false)
TracedValue< uint32_t > m_rWnd
virtual void DoRetransmit(void)
An implementation of a stream socket using TCP.
enum ProtocolType m_pType