22 #include "ns3/abort.h"
24 #include "ns3/pcap-file.h"
25 #include "ns3/config.h"
26 #include "ns3/string.h"
27 #include "ns3/uinteger.h"
28 #include "ns3/data-rate.h"
29 #include "ns3/inet-socket-address.h"
30 #include "ns3/point-to-point-helper.h"
31 #include "ns3/internet-stack-helper.h"
32 #include "ns3/ipv4-global-routing-helper.h"
33 #include "ns3/ipv4-address-helper.h"
34 #include "ns3/packet-sink-helper.h"
35 #include "ns3/tcp-socket-factory.h"
36 #include "ns3/node-container.h"
37 #include "ns3/simulator.h"
38 #include "ns3/error-model.h"
39 #include "ns3/pointer.h"
41 #include "ns3/tcp-westwood.h"
75 virtual void DoSetup (
void);
76 virtual void DoRun (
void);
77 virtual void DoTeardown (
void);
92 void CwndTracer (uint32_t oldval, uint32_t newval);
101 :
TestCase (
"Check the operation of the TCP state machine for several cases"),
103 m_totalTxBytes (200000),
104 m_currentTxBytes (0),
108 m_needToClose (true),
109 m_tcpModel (
"ns3::TcpWestwood")
114 :
TestCase (
"Check the behaviour of TCP upon packet losses"),
115 m_testCase (testCase),
116 m_totalTxBytes (200000),
117 m_currentTxBytes (0),
121 m_needToClose (true),
122 m_tcpModel (tcpModel)
133 std::ostringstream oss;
146 "Wrong response vectors in directory: opening " <<
183 uint32_t (tMicroSeconds % 1000000),
194 uint32_t tsSec, tsUsec, inclLen, origLen, readLen;
195 m_pcapFile.
Read (expected,
sizeof(expected), tsSec, tsUsec, inclLen, origLen, readLen);
199 uint8_t *actual =
new uint8_t[readLen];
202 int result = memcmp (actual, expected, readLen);
221 *(
m_osw->
GetStream ()) <<
"Moving cwnd from " << oldval <<
" to " << newval
223 <<
" seconds" << std::endl;
235 uint32_t dataOffset = m_currentTxBytes % 1040;
236 uint32_t toWrite = 1040 - dataOffset;
239 toWrite =
std::min (toWrite, txAvail);
246 std::clog <<
"Submitting " << toWrite
247 <<
" bytes to TCP socket" << std::endl;
249 int amountSent = localSocket->
Send (0, toWrite, 0);
251 m_currentTxBytes += amountSent;
257 std::clog <<
"Close socket at "
260 localSocket->
Close ();
272 std::clog <<
"Starting flow at time "
296 std::ostringstream tcpModel;
298 if (m_tcpModel.compare(
"WestwoodPlus") == 0)
352 ipv4.
SetBase (
"10.1.3.0",
"255.255.255.0");
354 ipv4.
SetBase (
"10.1.2.0",
"255.255.255.0");
358 Ipv4GlobalRoutingHelper::PopulateRoutingTables ();
365 uint16_t servPort = 50000;
375 Ptr<Socket> localSocket = Socket::CreateSocket (s1r1.
Get (0), TcpSocketFactory::GetTypeId ());
376 localSocket->
Bind ();
387 (
"/NodeList/0/$ns3::TcpL4Protocol/SocketList/0/CongestionWindow",
393 std::list<uint32_t> sampleList;
401 sampleList.push_back (16);
404 sampleList.push_back (16);
405 sampleList.push_back (17);
408 sampleList.push_back (16);
409 sampleList.push_back (17);
410 sampleList.push_back (18);
413 sampleList.push_back (16);
414 sampleList.push_back (17);
415 sampleList.push_back (18);
416 sampleList.push_back (19);
432 std::ostringstream oss;
433 oss <<
"tcp-loss-" << m_tcpModel <<
m_testCase <<
"-test-case";
440 std::ostringstream oss2;
441 oss2 <<
"src/test/ns3tcp/Tcp" << m_tcpModel <<
"." << m_testCase <<
".log";
452 Simulator::Stop (
Seconds (1000));
454 Simulator::Destroy ();
467 SetDataDir (
"src/test/ns3tcp/response-vectors");
468 Packet::EnablePrinting ();
uint32_t RemoveHeader(Header &header)
Deserialize and remove the header from the internal buffer.
holds a vector of ns3::Application pointers.
Simulation virtual time values and global simulation resolution.
Manage ASCII trace files for device models.
AttributeValue implementation for Boolean.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
void Ipv4L3Tx(std::string context, Ptr< const Packet > packet, Ptr< Ipv4 > ipv4, uint32_t interface)
Hold variables of type string.
Ptr< NetDevice > Get(uint32_t i) const
Get the Ptr<NetDevice> stored in this container at a given index.
NetDeviceContainer Install(NodeContainer c)
void StartFlow(Ptr< Socket > localSocket, Ipv4Address servAddress, uint16_t servPort)
void Init(uint32_t dataLinkType, uint32_t snapLen=SNAPLEN_DEFAULT, int32_t timeZoneCorrection=ZONE_DEFAULT, bool swapMode=false, bool nanosecMode=false)
Initialize the pcap file associated with this object.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
virtual void DoTeardown(void)
Implementation to do any local setup required for this TestCase.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
aggregate IP/TCP/UDP functionality to existing Nodes.
#define NS_TEST_EXPECT_MSG_EQ(actual, limit, msg)
Test that an actual and expected (limit) value are equal and report if not.
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes...
Ptr< OutputStreamWrapper > CreateFileStream(std::string filename, std::ios::openmode filemode=std::ios::out)
Create and initialize an output stream object we'll use to write the traced bits. ...
Build a set of PointToPointNetDevice objects.
void SetDeviceAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each NetDevice created by the helper.
void StartFlow(Ptr< Socket >, Ipv4Address, uint16_t)
Class for representing data rates.
double GetSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
virtual void DoRun(void)
Implementation to actually run this TestCase.
void LogComponentEnable(char const *name, enum LogLevel level)
Enable the logging output associated with that log component.
void EnablePcapAll(std::string prefix, bool promiscuous=false)
Enable pcap output on each device (which is of the appropriate type) in the set of all nodes created ...
Hold variables of type enum.
static void CwndTracer(uint32_t oldval, uint32_t newval)
void CwndTracer(uint32_t oldval, uint32_t newval)
int64_t GetMicroSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
void InstallAll(void) const
Aggregate IPv4, IPv6, UDP, and TCP stacks to all nodes in the simulation.
void AddTestCase(TestCase *testCase, enum TestDuration duration)
Add an individual child TestCase to this test suite.
AttributeValue implementation for Time.
A class representing a pcap file.
void Read(uint8_t *const data, uint32_t maxBytes, uint32_t &tsSec, uint32_t &tsUsec, uint32_t &inclLen, uint32_t &origLen, uint32_t &readLen)
Read next packet from file.
Hold an unsigned integer type.
Ptr< OutputStreamWrapper > m_osw
static Ns3TcpLossTestSuite ns3TcpLossTestSuite
holds a vector of ns3::NetDevice pointers
AttributeValue implementation for TypeId.
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
void ConnectWithoutContext(std::string path, const CallbackBase &cb)
void Start(Time start)
Arrange for all of the Applications in this container to Start() at the Time given as a parameter...
void Connect(std::string path, const CallbackBase &cb)
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
const uint32_t PCAP_LINK_TYPE
Ptr< Packet > Copy(void) const
performs a COW copy of the packet.
void LogComponentEnableAll(enum LogLevel level)
Enable the logging output for all registered log components.
virtual void DoSetup(void)
Implementation to do any local setup required for this TestCase.
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
void WriteUntilBufferFull(Ptr< Socket > localSocket, uint32_t txSpace)
keep track of a set of node pointers.
Hold objects of type Ptr<T>.
std::string CreateDataDirFilename(std::string filename)
Construct the full path to a file in the data directory.
void WriteUntilBufferFull(Ptr< Socket >, uint32_t)
virtual ~Ns3TcpLossTestCase()
void SetList(const std::list< uint32_t > &packetlist)
uint32_t m_currentTxBytes
void Close(void)
Close the underlying file.
void SetSendCallback(Callback< void, Ptr< Socket >, uint32_t > sendCb)
Notify application when space in transmit buffer is added.
bool IsStatusSuccess(void) const
Check if all tests passed.
void Open(std::string const &filename, std::ios::openmode mode)
Create a new pcap file or open an existing pcap file.
void SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
Ipv4 addresses are stored in host order in this class.
void Stop(Time stop)
Arrange for all of the Applications in this container to Stop() at the Time given as a parameter...
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
void Add(NodeContainer other)
Append the contents of another NodeContainer to the end of this container.
#define NS_ABORT_MSG_UNLESS(cond, msg)
Abnormal program termination if a condition is false, with a message.
AttributeValue implementation for DataRate.
Prefix all trace prints with function.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
Time Seconds(double value)
Construct a Time in the indicated unit.
void SetDefault(std::string name, const AttributeValue &value)
void SetDataDir(std::string directory)
Set the data directory where reference trace files can be found.
uint32_t CopyData(uint8_t *buffer, uint32_t size) const
Copy the packet contents to a byte buffer.
ApplicationContainer Install(NodeContainer c) const
Install an ns3::PacketSinkApplication on each node of the input container configured with all the att...
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
Time Now(void)
create an ns3::Time instance which contains the current simulation time.
void EnableAsciiAll(std::string prefix)
Enable ascii trace output on each device (which is of the appropriate type) in the set of all nodes c...
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
uint32_t GetDataLinkType(void)
Returns the data link type field of the pcap file as defined by the network field in the pcap global ...
void Write(uint32_t tsSec, uint32_t tsUsec, uint8_t const *const data, uint32_t totalLen)
Write next packet to file.
virtual int Send(Ptr< Packet > p, uint32_t flags)=0
Send data (or dummy data) to the remote host.
virtual int Close(void)=0
Close a socket.
const uint32_t PCAP_SNAPLEN
virtual uint32_t GetTxAvailable(void) const =0
Returns the number of bytes which can be sent in a single call to Send.
std::ostream * GetStream(void)
Return a pointer to an ostream previously set in the wrapper.
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
std::string m_pcapFilename
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const