23 #include "ns3/abort.h"
25 #include "ns3/pcap-file.h"
26 #include "ns3/config.h"
27 #include "ns3/string.h"
28 #include "ns3/uinteger.h"
29 #include "ns3/boolean.h"
30 #include "ns3/data-rate.h"
31 #include "ns3/inet-socket-address.h"
32 #include "ns3/point-to-point-helper.h"
33 #include "ns3/internet-stack-helper.h"
34 #include "ns3/ipv4-global-routing-helper.h"
35 #include "ns3/ipv4-address-helper.h"
36 #include "ns3/packet-sink-helper.h"
37 #include "ns3/tcp-socket-factory.h"
38 #include "ns3/node-container.h"
39 #include "ns3/simulator.h"
40 #include "ns3/error-model.h"
41 #include "ns3/pointer.h"
43 #include "ns3/tcp-header.h"
77 virtual void DoSetup (
void);
78 virtual void DoRun (
void);
79 virtual void DoTeardown (
void);
100 :
TestCase (
"Check the operation of the TCP state machine for several cases"),
102 m_totalTxBytes (20000),
103 m_currentTxBytes (0),
112 :
TestCase (
"Check the operation of the TCP state machine for several cases"),
113 m_testCase (testCase),
114 m_totalTxBytes (20000),
115 m_currentTxBytes (0),
130 std::ostringstream oss;
131 oss <<
"ns3tcp-state" <<
m_testCase <<
"-response-vectors.pcap";
144 "Wrong response vectors in directory: opening " <<
187 uint32_t (tMicroSeconds % 1000000),
197 uint32_t tsSec, tsUsec, inclLen, origLen, readLen;
198 m_pcapFile.
Read (expected,
sizeof(expected), tsSec, tsUsec, inclLen, origLen, readLen);
200 uint8_t *actual =
new uint8_t[readLen];
203 uint32_t result = memcmp (actual, expected, readLen);
225 uint32_t dataOffset = m_currentTxBytes % 1040;
226 uint32_t toWrite = 1040 - dataOffset;
229 toWrite =
std::min (toWrite, txAvail);
236 std::clog <<
"Submitting "
237 << toWrite <<
" bytes to TCP socket" << std::endl;
239 int amountSent = localSocket->
Send (0, toWrite, 0);
241 m_currentTxBytes += amountSent;
247 std::clog <<
"Close socket at "
251 localSocket->
Close ();
263 std::clog <<
"Starting flow at time "
286 std::string tcpModel (
"ns3::TcpNewReno");
328 ipv4.
SetBase (
"10.1.3.0",
"255.255.255.0");
330 ipv4.
SetBase (
"10.1.2.0",
"255.255.255.0");
334 Ipv4GlobalRoutingHelper::PopulateRoutingTables ();
341 uint16_t servPort = 50000;
351 TcpSocketFactory::GetTypeId ());
352 localSocket->
Bind ();
354 localSocket, ipInterfs.
GetAddress (1), servPort);
363 std::list<uint32_t> dropListN0;
364 std::list<uint32_t> dropListN1;
365 std::string caseDescription;
370 caseDescription =
"Verify connection establishment";
374 caseDescription =
"Verify a bigger (100 pkts) transfer: Sliding window operation, etc.";
378 caseDescription =
"Survive a SYN lost";
379 dropListN0.push_back (0);
383 caseDescription =
"Survive a SYN+ACK lost";
384 dropListN1.push_back (0);
388 caseDescription =
"Survive a ACK (last packet in 3-way handshake) lost";
389 dropListN0.push_back (1);
393 caseDescription =
"Immediate FIN upon SYN_RCVD";
395 dropListN0.push_back (1);
396 Simulator::Schedule (
Seconds (0.002), &Socket::Close, localSocket);
400 caseDescription =
"Simulated simultaneous close";
401 dropListN1.push_back (5);
405 caseDescription =
"FIN check 1: Loss of initiator's FIN. Wait until app close";
407 dropListN0.push_back (7);
408 Simulator::Schedule (
Seconds (0.04), &Socket::Close, localSocket);
412 caseDescription =
"FIN check 2: Loss responder's FIN. FIN will be resent after last ack timeout";
413 dropListN1.push_back (6);
416 NS_FATAL_ERROR (
"Program fatal error: specified test case not supported: "
423 dev0.
Get (1)->SetAttribute (
"ReceiveErrorModel",
PointerValue (errN0));
427 dev1.
Get (0)->SetAttribute (
"ReceiveErrorModel",
PointerValue (errN1));
429 std::ostringstream oss;
430 oss <<
"tcp-state" <<
m_testCase <<
"-test-case";
440 *(osw->
GetStream ()) << std::setprecision (9) << std::fixed;
443 std::clog << std::endl <<
"Running TCP test-case " << m_testCase <<
": "
444 << caseDescription << std::endl;
449 Simulator::Stop (
Seconds (1000));
451 Simulator::Destroy ();
466 SetDataDir (
"src/test/ns3tcp/response-vectors");
467 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.
AttributeValue implementation for Boolean.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
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 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...
#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...
Build a set of PointToPointNetDevice objects.
void StartFlow(Ptr< Socket > localSocket, Ipv4Address servAddress, uint16_t servPort)
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)
virtual ~Ns3TcpStateTestCase()
void WriteUntilBufferFull(Ptr< Socket > localSocket, uint32_t txSpace)
Class for representing data rates.
double GetSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
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 ...
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.
holds a vector of ns3::NetDevice pointers
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
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 void DoRun(void)
Implementation to actually run this TestCase.
virtual void DoTeardown(void)
Implementation to do any local setup required for this TestCase.
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
Ptr< Packet > Copy(void) const
performs a COW copy of the packet.
uint32_t PeekHeader(Header &header) const
Deserialize but does not remove the header from the internal buffer.
void LogComponentEnableAll(enum LogLevel level)
Enable the logging output for all registered log components.
uint32_t m_currentTxBytes
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
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)
void SetList(const std::list< uint32_t > &packetlist)
const uint32_t PCAP_LINK_TYPE
virtual void DoSetup(void)
Implementation to do any local setup required for this TestCase.
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.
static Ns3TcpStateTestSuite ns3TcpLossTestSuite
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.
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.
Rare ad-hoc debug messages.
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.
virtual uint32_t GetTxAvailable(void) const =0
Returns the number of bytes which can be sent in a single call to Send.
void Ipv4L3Tx(std::string context, Ptr< const Packet > packet, Ptr< Ipv4 > ipv4, uint32_t interface)
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.
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const
const uint32_t PCAP_SNAPLEN
std::string m_pcapFilename