23 #include "ns3/random-variable-stream.h"
24 #include "ns3/tcp-rx-buffer.h"
74 void SetInvalidAwndCb(InvalidAwndCallback cb);
88 uint16_t AdvertisedWindowSize(
bool scale =
true)
const override;
91 uint16_t OldAdvertisedWindowSize(
bool scale =
true)
const;
107 m_inwalidAwndCb = cb;
113 static TypeId tid =
TypeId(
"ns3::TcpSocketAdvertisedWindowProxy")
115 .SetGroupName(
"Internet")
123 return CopyObject<TcpSocketAdvertisedWindowProxy>(
this);
132 uint16_t oldAwnd = OldAdvertisedWindowSize(scale);
134 if (!m_tcb->m_rxBuffer->Finished())
138 if (newAwnd != oldAwnd)
140 uint32_t available = m_tcb->m_rxBuffer->Available();
145 uint32_t newAwndKnownDifference = newAwnd;
148 newAwndKnownDifference += (available >> m_rcvWindShift);
152 newAwndKnownDifference += available;
155 if (newAwndKnownDifference > m_maxWinSize)
157 newAwndKnownDifference = m_maxWinSize;
160 if (
static_cast<uint16_t
>(newAwndKnownDifference) != oldAwnd)
162 if (!m_inwalidAwndCb.IsNull())
164 m_inwalidAwndCb(oldAwnd, newAwnd);
190 uint32_t w = m_tcb->m_rxBuffer->MaxBufferSize();
194 w >>= m_rcvWindShift;
196 if (w > m_maxWinSize)
200 << m_maxWinSize <<
"; possibly to avoid overflow of the 16-bit integer");
202 NS_LOG_DEBUG(
"Returning AdvertisedWindowSize of " <<
static_cast<uint16_t
>(w));
203 return static_cast<uint16_t
>(w);
221 static TypeId GetTypeId();
229 m_dropRatio(dropRatio)
231 m_prng = CreateObject<UniformRandomVariable>();
259 return m_prng->GetValue() < m_dropRatio;
301 void ConfigureEnvironment()
override;
310 void InvalidAwndCb(uint16_t oldAwnd, uint16_t newAwnd);
323 m_lossRatio(lossRatio)
330 TcpGeneralTest::ConfigureEnvironment();
344 DynamicCast<TcpSocketAdvertisedWindowProxy>(sock)->SetExpectedSegmentSize(500);
345 DynamicCast<TcpSocketAdvertisedWindowProxy>(sock)->SetInvalidAwndCb(
354 return CreateObject<TcpDropRatioErrorModel>(
m_lossRatio);
383 std::vector<uint32_t>& toDrop);
405 std::vector<uint32_t>& toDrop)
416 TcpGeneralTest::ConfigureEnvironment();
430 DynamicCast<TcpSocketAdvertisedWindowProxy>(sock)->SetExpectedSegmentSize(500);
431 DynamicCast<TcpSocketAdvertisedWindowProxy>(sock)->SetInvalidAwndCb(
440 auto socket = TcpGeneralTest::CreateSenderSocket(node);
510 std::vector<uint32_t> toDrop;
511 toDrop.push_back(8001);
512 toDrop.push_back(9001);
Test the TCP's advertised window size when there is a loss of specific packets.
TcpAdvWindowOnLossTest(const std::string &desc, uint32_t size, uint32_t packets, std::vector< uint32_t > &toDrop)
Constructor.
std::vector< uint32_t > m_toDrop
Sequences to drop.
void InvalidAwndCb(uint16_t oldAwnd, uint16_t newAwnd)
Callback called for the update of the awnd.
uint32_t m_pktCount
Pkt count.
uint32_t m_pktSize
Packet size.
Ptr< TcpSocketMsgBase > CreateSenderSocket(Ptr< Node > node) override
Create and install the socket to install on the sender.
void ConfigureEnvironment() override
Change the configuration of the environment.
Ptr< ErrorModel > CreateReceiverErrorModel() override
Create and return the error model to install in the receiver node.
Ptr< TcpSocketMsgBase > CreateReceiverSocket(Ptr< Node > node) override
Create and install the socket to install on the receiver.
Test the new formula for calculating TCP's advertised window size.
uint32_t m_pktSize
Packet size.
Ptr< ErrorModel > CreateReceiverErrorModel() override
Create and return the error model to install in the receiver node.
double m_lossRatio
Loss ratio.
Ptr< TcpSocketMsgBase > CreateReceiverSocket(Ptr< Node > node) override
Create and install the socket to install on the receiver.
void ConfigureEnvironment() override
Change the configuration of the environment.
TcpAdvertisedWindowTest(const std::string &desc, uint32_t size, uint32_t packets, double lossRatio)
Constructor.
void InvalidAwndCb(uint16_t oldAwnd, uint16_t newAwnd)
Callback called for the update of the awnd.
uint32_t m_pktCount
Pkt count.
Test Suite for TCP adv window.
TcpAdvertisedWindowTestSuite()
An error model that randomly drops a given rĂ¡tio of TCP segments.
static TypeId GetTypeId()
Get the type ID.
Ptr< UniformRandomVariable > m_prng
Random variable.
double m_dropRatio
Drop ratio.
void DoReset() override
Re-initialize any state.
TcpDropRatioErrorModel(double dropRatio)
Constructor.
bool ShouldDrop(const Ipv4Header &ipHeader, const TcpHeader &tcpHeader, uint32_t packetSize) override
Check if the packet should be dropped.
Socket that wraps every call to AdvertisedWindowSize ().
Ptr< TcpSocketBase > Fork() override
Call CopyObject<> to clone me.
void SetInvalidAwndCb(InvalidAwndCallback cb)
Set the invalid AdvWnd callback.
void SetExpectedSegmentSize(uint16_t seg)
Set the expected segment size.
TcpSocketAdvertisedWindowProxy()
Constructor.
uint16_t m_segmentSize
Test meta-information: size of the segments that are received.
Callback< void, uint16_t, uint16_t > InvalidAwndCallback
typedef for a cb
TcpSocketAdvertisedWindowProxy(const TcpSocketAdvertisedWindowProxy &other)
Copy-constructor.
InvalidAwndCallback m_inwalidAwndCb
Callback.
uint16_t AdvertisedWindowSize(bool scale=true) const override
The amount of Rx window announced to the peer.
static TypeId GetTypeId()
Get the type ID.
uint16_t OldAdvertisedWindowSize(bool scale=true) const
The legacy code used for calculating the advertised window.
bool IsNull() const
Check for null implementation.
Smart pointer class similar to boost::intrusive_ptr.
A general (TCP-aware) error model.
General infrastructure for TCP testing.
void SetPropagationDelay(Time propDelay)
Propagation delay of the bottleneck link.
void SetAppPktCount(uint32_t pktCount)
Set app packet count.
void SetAppPktSize(uint32_t pktSize)
Set app packet size.
virtual Ptr< TcpSocketMsgBase > CreateSocket(Ptr< Node > node, TypeId socketType, TypeId congControl)
Create a socket.
TypeId m_congControlTypeId
Congestion control.
void SetTransmitStart(Time startTime)
Set the initial time at which the application sends the first data packet.
void AddSeqToKill(const SequenceNumber32 &seq)
Add the sequence number to the list of segments to be killed.
virtual uint16_t AdvertisedWindowSize(bool scale=true) const
The amount of Rx window announced to the peer.
Class for inserting callbacks special points of the flow of TCP sockets.
void AddTestCase(TestCase *testCase, TestDuration duration=QUICK)
Add an individual child TestCase to this test suite.
@ UNIT
This test suite implements a Unit Test.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Hold an unsigned integer type.
#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.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
SequenceNumber< uint32_t, int32_t > SequenceNumber32
32 bit Sequence number.
#define NS_TEST_ASSERT_MSG_EQ(actual, limit, msg)
Test that an actual and expected (limit) value are equal and report and abort if not.
Time Seconds(double value)
Construct a Time in the indicated unit.
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Callback< R, Args... > MakeCallback(R(T::*memPtr)(Args...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
static TcpAdvertisedWindowTestSuite g_tcpAdvertisedWindowTestSuite
static const uint32_t packetSize
Packet size generated at the AP.