A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
ns3tcp-state-test-suite.cc
Go to the documentation of this file.
1/*
2 * Copyright (c) 2010 University of Washington
3 *
4 * SPDX-License-Identifier: GPL-2.0-only
5 */
6
8
9#include "ns3/abort.h"
10#include "ns3/boolean.h"
11#include "ns3/config.h"
12#include "ns3/data-rate.h"
13#include "ns3/error-model.h"
14#include "ns3/inet-socket-address.h"
15#include "ns3/internet-stack-helper.h"
16#include "ns3/ipv4-address-helper.h"
17#include "ns3/ipv4-global-routing-helper.h"
18#include "ns3/log.h"
19#include "ns3/node-container.h"
20#include "ns3/packet-sink-helper.h"
21#include "ns3/pcap-file.h"
22#include "ns3/point-to-point-helper.h"
23#include "ns3/pointer.h"
24#include "ns3/simulator.h"
25#include "ns3/string.h"
26#include "ns3/tcp-header.h"
27#include "ns3/tcp-socket-factory.h"
28#include "ns3/test.h"
29#include "ns3/traffic-control-helper.h"
30#include "ns3/uinteger.h"
31
32#include <iomanip>
33#include <string>
34
35using namespace ns3;
36
37NS_LOG_COMPONENT_DEFINE("Ns3TcpStateTest");
38
39// The below boolean constants should only be changed to 'true'
40// during test debugging (i.e. do not commit the value 'true')
41
42// set to 'true' to have the test suite overwrite the response vectors
43// stored in the test directory. This should only be done if you are
44// convinced through other means (e.g. pcap tracing or logging) that the
45// revised vectors are the correct ones. In other words, don't simply
46// enable this to true to clear a failing test without looking at the
47// results closely.
48const bool WRITE_VECTORS = false; //!< Set to true to write response vectors.
49const bool WRITE_PCAP = false; //!< Set to true to write out pcap.
50const bool WRITE_LOGGING = false; //!< Set to true to write logging.
52 1187373554; //!< Some large random number -- we use to verify data was written by this program.
53const uint32_t PCAP_SNAPLEN = 64; //!< Don't bother to save much data.
54
55/**
56 * \ingroup system-tests-tcp
57 *
58 * \brief Tests of TCP implementation state machine behavior
59 */
61{
62 public:
64 /**
65 * Constructor.
66 * \param testCase Testcase number.
67 */
69
71 {
72 }
73
74 private:
75 void DoSetup() override;
76 void DoRun() override;
77 void DoTeardown() override;
78
79 std::string m_pcapFilename; //!< The PCAP filename.
80 PcapFile m_pcapFile; //!< The PCAP ffile.
81 uint32_t m_testCase; //!< Testcase number.
82 uint32_t m_totalTxBytes; //!< Total number of bytes to send.
83 uint32_t m_currentTxBytes; //!< Current number of bytes sent.
84 bool m_writeVectors; //!< True if response vectors have to be written (and not read).
85 bool m_writeResults; //!< True if write PCAP files.
86 bool m_writeLogging; //!< True if write logging.
87 bool m_needToClose; //!< Check if the sending socket need to be closed.
88
89 /**
90 * Check that the transmitted packets are consistent with the trace.
91 * This callback is hooked to ns3::Ipv4L3Protocol/Tx.
92 *
93 * \param context The callback context (unused).
94 * \param packet The transmitted packet.
95 * \param ipv4 The IPv4 object that did send the packet (unused).
96 * \param interface The IPv4 interface that did send the packet (unused).
97 */
98 void Ipv4L3Tx(std::string context,
99 Ptr<const Packet> packet,
100 Ptr<Ipv4> ipv4,
101 uint32_t interface);
102 /**
103 * Check that the received packets are consistent with the trace.
104 * This callback is hooked to ns3::Ipv4L3Protocol/Tx.
105 *
106 * \param context The callback context (unused).
107 * \param packet The transmitted packet.
108 * \param ipv4 The IPv4 object that did send the packet (unused).
109 * \param interface The IPv4 interface that did send the packet (unused).
110 */
111 void Ipv4L3Rx(std::string context,
112 Ptr<const Packet> packet,
113 Ptr<Ipv4> ipv4,
114 uint32_t interface);
115 /**
116 * Write to the socket until the buffer is full.
117 *
118 * \param localSocket The output socket.
119 * \param txSpace The space left on the socket (unused).
120 */
121 void WriteUntilBufferFull(Ptr<Socket> localSocket, uint32_t txSpace);
122 /**
123 * Start transmitting a TCP flow.
124 *
125 * \param localSocket The sending socket.
126 * \param servAddress The IPv4 address of the server (i.e., the destination address).
127 * \param servPort The TCP port of the server (i.e., the destination port).
128 */
129 void StartFlow(Ptr<Socket> localSocket, Ipv4Address servAddress, uint16_t servPort);
130};
131
133 : TestCase("Check the operation of the TCP state machine for several cases"),
134 m_testCase(0),
135 m_totalTxBytes(20000),
136 m_currentTxBytes(0),
137 m_writeVectors(WRITE_VECTORS),
138 m_writeResults(WRITE_PCAP),
139 m_writeLogging(WRITE_LOGGING),
140 m_needToClose(true)
141{
142}
143
145 : TestCase("Check the operation of the TCP state machine for several cases"),
146 m_testCase(testCase),
147 m_totalTxBytes(20000),
148 m_currentTxBytes(0),
149 m_writeVectors(WRITE_VECTORS),
150 m_writeResults(WRITE_PCAP),
151 m_writeLogging(WRITE_LOGGING),
152 m_needToClose(true)
153{
154}
155
156void
158{
159 //
160 // We expect there to be a file called ns3tcp-state-response-vectors.pcap in
161 // the data directory
162 //
163 std::ostringstream oss;
164 oss << "ns3tcp-state" << m_testCase << "-response-vectors.pcap";
166 NS_LOG_INFO("m_pcapFilename=" << m_pcapFilename);
167
168 if (m_writeVectors)
169 {
170 m_pcapFile.Open(m_pcapFilename, std::ios::out | std::ios::binary);
172 }
173 else
174 {
175 m_pcapFile.Open(m_pcapFilename, std::ios::in | std::ios::binary);
177 "Wrong response vectors in directory: opening " << m_pcapFilename);
178 }
179}
180
181void
186
187void
189{
190 Ptr<Packet> received = packet->Copy();
191 Ipv4Header ipHeader;
192 TcpHeader tcpHeader;
193 received->RemoveHeader(ipHeader);
194 received->RemoveHeader(tcpHeader);
195
196 NS_LOG_DEBUG("Received: " << tcpHeader);
197}
198
199void
201{
202 //
203 // We're not testing IP so remove and toss the header. In order to do this,
204 // though, we need to copy the packet since we have a const version.
205 //
206 Ptr<Packet> received = packet->Copy();
207 Ipv4Header ipHeader;
208 received->RemoveHeader(ipHeader);
209
210 //
211 // What is left is the TCP header and any data that may be sent. We aren't
212 // sending any TCP data, so we expect what remains is only TCP header, which
213 // is a small thing to save.
214 //
215 if (m_writeVectors)
216 {
217 //
218 // Save the TCP under test response for later testing.
219 //
220 Time tNow = Simulator::Now();
221 int64_t tMicroSeconds = tNow.GetMicroSeconds();
222
223 m_pcapFile.Write(uint32_t(tMicroSeconds / 1000000),
224 uint32_t(tMicroSeconds % 1000000),
225 received);
226 }
227 else
228 {
229 //
230 // Read the TCP under test expected response from the expected vector
231 // file and see if it still does the right thing.
232 //
233 uint8_t expectedBuffer[PCAP_SNAPLEN];
234 uint32_t tsSec;
235 uint32_t tsUsec;
236 uint32_t inclLen;
237 uint32_t origLen;
238 uint32_t readLen;
240 .Read(expectedBuffer, sizeof(expectedBuffer), tsSec, tsUsec, inclLen, origLen, readLen);
241
242 NS_LOG_INFO("read " << readLen << " bytes");
243
244 auto actual = new uint8_t[readLen];
245 received->CopyData(actual, readLen);
246
247 int result = memcmp(actual, expectedBuffer, readLen);
248
249 TcpHeader expectedHeader;
250 TcpHeader receivedHeader;
251 Ptr<Packet> expected = Create<Packet>(expectedBuffer, readLen);
252
253 expected->RemoveHeader(expectedHeader);
254 received->RemoveHeader(receivedHeader);
255
256 NS_LOG_DEBUG("Expected " << expectedHeader << " received: " << receivedHeader);
257
258 delete[] actual;
259
260 //
261 // Avoid streams of errors -- only report the first.
262 //
263 if (IsStatusSuccess())
264 {
265 NS_TEST_EXPECT_MSG_EQ(result, 0, "Expected data comparison error");
266 }
267 }
268}
269
270////////////////////////////////////////////////////////////////////
271// Implementing an "application" to send bytes over a TCP connection
272void
274{
276 {
278 uint32_t dataOffset = m_currentTxBytes % 1040;
279 uint32_t toWrite = 1040 - dataOffset;
280 uint32_t txAvail = localSocket->GetTxAvailable();
281 toWrite = std::min(toWrite, left);
282 toWrite = std::min(toWrite, txAvail);
283 if (txAvail == 0)
284 {
285 return;
286 }
287 if (m_writeLogging)
288 {
289 std::clog << "Submitting " << toWrite << " bytes to TCP socket" << std::endl;
290 }
291 int amountSent = localSocket->Send(nullptr, toWrite, 0);
292 NS_ASSERT(amountSent > 0); // Given GetTxAvailable() non-zero, amountSent should not be zero
293 m_currentTxBytes += amountSent;
294 }
295 if (m_needToClose)
296 {
297 if (m_writeLogging)
298 {
299 std::clog << "Close socket at " << Simulator::Now().GetSeconds() << std::endl;
300 }
301 localSocket->Close();
302 m_needToClose = false;
303 }
304}
305
306void
307Ns3TcpStateTestCase::StartFlow(Ptr<Socket> localSocket, Ipv4Address servAddress, uint16_t servPort)
308{
309 if (m_writeLogging)
310 {
311 std::clog << "Starting flow at time " << Simulator::Now().GetSeconds() << std::endl;
312 }
313
314 localSocket->Connect(InetSocketAddress(servAddress, servPort)); // connect
315
316 // tell the tcp implementation to call WriteUntilBufferFull again
317 // if we blocked and new tx buffer space becomes available
318 localSocket->SetSendCallback(MakeCallback(&Ns3TcpStateTestCase::WriteUntilBufferFull, this));
319 WriteUntilBufferFull(localSocket, localSocket->GetTxAvailable());
320}
321
322void
324{
325 // Network topology
326 //
327 // 10Mb/s, 0.1ms 10Mb/s, 0.1ms
328 // n0-----------------n1-----------------n2
329
330 std::string tcpModel("ns3::TcpNewReno");
331
332 Config::SetDefault("ns3::TcpSocketBase::Sack", BooleanValue(false));
333 Config::SetDefault("ns3::TcpL4Protocol::SocketType", StringValue(tcpModel));
334 Config::SetDefault("ns3::TcpSocket::SegmentSize", UintegerValue(1000));
335 Config::SetDefault("ns3::TcpSocket::DelAckCount", UintegerValue(1));
336 Config::SetDefault("ns3::DropTailQueue<Packet>::MaxSize", StringValue("20p"));
337 Config::SetDefault("ns3::TcpSocketBase::Timestamp", BooleanValue(false));
338
339 if (m_writeLogging)
340 {
342 LogComponentEnable("ErrorModel", LOG_LEVEL_DEBUG);
343 LogComponentEnable("Ns3TcpStateTest", LOG_LEVEL_DEBUG);
344 LogComponentEnable("TcpCongestionOps", LOG_LEVEL_INFO);
345 LogComponentEnable("TcpSocketBase", LOG_LEVEL_INFO);
346 }
347
348 ////////////////////////////////////////////////////////
349 // Topology construction
350 //
351
352 // Create three nodes
353 NodeContainer n0n1;
354 n0n1.Create(2);
355
357 n1n2.Add(n0n1.Get(1));
358 n1n2.Create(1);
359
360 // Set up TCP/IP stack to all nodes (and create loopback device at device 0)
361 InternetStackHelper internet;
362 internet.InstallAll();
363
364 // Connect the nodes
366 p2p.SetDeviceAttribute("DataRate", DataRateValue(DataRate(1000000)));
367 p2p.SetChannelAttribute("Delay", TimeValue(Seconds(0.0001)));
368 NetDeviceContainer dev0 = p2p.Install(n0n1);
369 NetDeviceContainer dev1 = p2p.Install(n1n2);
370
371 // Use PfifoFast queue disc
373 tch.SetRootQueueDisc("ns3::PfifoFastQueueDisc");
374 tch.Install(dev0);
375 tch.Install(dev1);
376
377 // Add IP addresses to each network interfaces
379 ipv4.SetBase("10.1.3.0", "255.255.255.0");
380 ipv4.Assign(dev0);
381 ipv4.SetBase("10.1.2.0", "255.255.255.0");
382 Ipv4InterfaceContainer ipInterfs = ipv4.Assign(dev1);
383
384 // Set up routes to all nodes
386
387 ////////////////////////////////////////////////////////
388 // A flow from node n0 to node n2
389 //
390
391 // Create a packet sink to receive packets on node n2
392 uint16_t servPort = 50000; // Destination port number
393 PacketSinkHelper sink("ns3::TcpSocketFactory",
395 ApplicationContainer sinkApps = sink.Install(n1n2.Get(1));
396 sinkApps.Start(Seconds(0.0));
397 sinkApps.Stop(Seconds(100.0));
398
399 // Create a data source to send packets on node n0
400 // Instead of full application, here use the socket directly by
401 // registering callbacks in function StarFlow().
403 localSocket->Bind();
405 this,
406 localSocket,
407 ipInterfs.GetAddress(1),
408 servPort);
409
410 Config::Connect("/NodeList/0/$ns3::Ipv4L3Protocol/Tx",
412
413 Config::Connect("/NodeList/0/$ns3::Ipv4L3Protocol/Rx",
415
416 ////////////////////////////////////////////////////////
417 // Set up different test cases: Lost model at node n1, different file size
418 //
419
420 std::list<uint32_t> dropListN0;
421 std::list<uint32_t> dropListN1;
422 std::string caseDescription;
423 switch (m_testCase)
424 {
425 case 0:
426 m_totalTxBytes = 1000;
427 caseDescription = "Verify connection establishment";
428 break;
429 case 1:
430 m_totalTxBytes = 100 * 1000;
431 caseDescription = "Verify a bigger (100 pkts) transfer: Sliding window operation, etc.";
432 break;
433 case 2:
434 m_totalTxBytes = 1000;
435 caseDescription = "Survive a SYN lost";
436 dropListN0.push_back(0);
437 break;
438 case 3:
439 m_totalTxBytes = 2000;
440 caseDescription = "Survive a SYN+ACK lost";
441 dropListN1.push_back(0);
442 break;
443 case 4:
444 m_totalTxBytes = 2000;
445 caseDescription = "Survive a ACK (last packet in 3-way handshake) lost";
446 dropListN0.push_back(1);
447 break;
448 case 5:
449 m_totalTxBytes = 0;
450 caseDescription = "Immediate FIN upon SYN_RCVD";
451 m_needToClose = false;
452 dropListN0.push_back(1); // Hide the ACK in 3WHS
453 Simulator::Schedule(Seconds(0.002), &Socket::Close, localSocket);
454 break;
455 case 6:
456 m_totalTxBytes = 5000;
457 caseDescription = "Simulated simultaneous close";
458 dropListN1.push_back(5); // Hide the ACK-to-FIN from n2
459 break;
460 case 7:
461 m_totalTxBytes = 5000;
462 caseDescription = "FIN check 1: Loss of initiator's FIN. Wait until app close";
463 m_needToClose = false;
464 dropListN0.push_back(7); // Hide the FIN from n0
465 Simulator::Schedule(Seconds(0.04), &Socket::Close, localSocket);
466 break;
467 case 8:
468 m_totalTxBytes = 5000;
469 caseDescription =
470 "FIN check 2: Loss responder's FIN. FIN will be resent after last ack timeout";
471 dropListN1.push_back(6); // Hide the FIN from n2
472 break;
473 default:
474 NS_FATAL_ERROR("Program fatal error: specified test case not supported: " << m_testCase);
475 break;
476 }
477
479 errN0->SetList(dropListN0);
480 dev0.Get(1)->SetAttribute("ReceiveErrorModel", PointerValue(errN0));
481
483 errN1->SetList(dropListN1);
484 dev1.Get(0)->SetAttribute("ReceiveErrorModel", PointerValue(errN1));
485
486 std::ostringstream oss;
487 oss << "tcp-state" << m_testCase << "-test-case";
488 if (m_writeResults)
489 {
490 p2p.EnablePcapAll(oss.str());
491 p2p.EnableAsciiAll(oss.str());
492 }
493
494 if (m_writeLogging)
495 {
497 *(osw->GetStream()) << std::setprecision(9) << std::fixed;
498 p2p.EnableAsciiAll(osw);
499
500 std::clog << std::endl
501 << "Running TCP test-case " << m_testCase << ": " << caseDescription << std::endl;
502 }
503
504 // Finally, set up the simulator to run. The 1000 second hard limit is a
505 // failsafe in case some change above causes the simulation to never end
509}
510
511/**
512 * \ingroup system-tests-tcp
513 *
514 * TCP implementation state machine behavior TestSuite.
515 */
517{
518 public:
520};
521
523 : TestSuite("ns3-tcp-state", Type::SYSTEM)
524{
525 // We can't use NS_TEST_SOURCEDIR variable here because we use subdirectories
526 SetDataDir("src/test/ns3tcp/response-vectors");
527 Packet::EnablePrinting(); // Enable packet metadata for all test cases
528
529 AddTestCase(new Ns3TcpStateTestCase(0), TestCase::Duration::QUICK);
530 AddTestCase(new Ns3TcpStateTestCase(1), TestCase::Duration::QUICK);
531 AddTestCase(new Ns3TcpStateTestCase(2), TestCase::Duration::QUICK);
532 AddTestCase(new Ns3TcpStateTestCase(3), TestCase::Duration::QUICK);
533 AddTestCase(new Ns3TcpStateTestCase(4), TestCase::Duration::QUICK);
534 AddTestCase(new Ns3TcpStateTestCase(5), TestCase::Duration::QUICK);
535 AddTestCase(new Ns3TcpStateTestCase(6), TestCase::Duration::QUICK);
536 AddTestCase(new Ns3TcpStateTestCase(7), TestCase::Duration::QUICK);
537 AddTestCase(new Ns3TcpStateTestCase(8), TestCase::Duration::QUICK);
538}
539
540/// Do not forget to allocate an instance of this TestSuite.
NodeContainer n1n2
Nodecontainer n1 + n2.
Tests of TCP implementation state machine behavior.
bool m_writeVectors
True if response vectors have to be written (and not read).
void StartFlow(Ptr< Socket > localSocket, Ipv4Address servAddress, uint16_t servPort)
Start transmitting a TCP flow.
void Ipv4L3Tx(std::string context, Ptr< const Packet > packet, Ptr< Ipv4 > ipv4, uint32_t interface)
Check that the transmitted packets are consistent with the trace.
uint32_t m_totalTxBytes
Total number of bytes to send.
uint32_t m_currentTxBytes
Current number of bytes sent.
std::string m_pcapFilename
The PCAP filename.
void DoTeardown() override
Implementation to do any local setup required for this TestCase.
bool m_writeLogging
True if write logging.
void Ipv4L3Rx(std::string context, Ptr< const Packet > packet, Ptr< Ipv4 > ipv4, uint32_t interface)
Check that the received packets are consistent with the trace.
void DoSetup() override
Implementation to do any local setup required for this TestCase.
void DoRun() override
Implementation to actually run this TestCase.
void WriteUntilBufferFull(Ptr< Socket > localSocket, uint32_t txSpace)
Write to the socket until the buffer is full.
PcapFile m_pcapFile
The PCAP ffile.
bool m_needToClose
Check if the sending socket need to be closed.
bool m_writeResults
True if write PCAP files.
uint32_t m_testCase
Testcase number.
TCP implementation state machine behavior TestSuite.
holds a vector of ns3::Application pointers.
void Start(Time start) const
Start all of the Applications in this container at the start time given as a parameter.
void Stop(Time stop) const
Arrange for all of the Applications in this container to Stop() at the Time given as a parameter.
AttributeValue implementation for Boolean.
Definition boolean.h:26
Class for representing data rates.
Definition data-rate.h:78
AttributeValue implementation for DataRate.
Definition data-rate.h:285
an Inet address class
aggregate IP/TCP/UDP functionality to existing Nodes.
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
Ipv4 addresses are stored in host order in this class.
static Ipv4Address GetAny()
static void PopulateRoutingTables()
Build a routing database and initialize the routing tables of the nodes in the simulation.
Packet header for IPv4.
Definition ipv4-header.h:23
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const
holds a vector of ns3::NetDevice pointers
Ptr< NetDevice > Get(uint32_t i) const
Get the Ptr<NetDevice> stored in this container at a given index.
keep track of a set of node pointers.
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
void Add(const NodeContainer &nc)
Append the contents of another NodeContainer to the end of this container.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
static void EnablePrinting()
Enable printing packets metadata.
Definition packet.cc:585
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
A class representing a pcap file.
Definition pcap-file.h:32
void Close()
Close the underlying file.
Definition pcap-file.cc:81
void Open(const std::string &filename, std::ios::openmode mode)
Create a new pcap file or open an existing pcap file.
Definition pcap-file.cc:320
uint32_t GetDataLinkType()
Returns the data link type field of the pcap file as defined by the network field in the pcap global ...
Definition pcap-file.cc:130
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.
Definition pcap-file.cc:468
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.
Definition pcap-file.cc:340
void Write(uint32_t tsSec, uint32_t tsUsec, const uint8_t *const data, uint32_t totalLen)
Write next packet to file.
Definition pcap-file.cc:433
Build a set of PointToPointNetDevice objects.
AttributeValue implementation for Pointer.
Smart pointer class similar to boost::intrusive_ptr.
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
Definition simulator.h:560
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
Definition simulator.cc:131
static Time Now()
Return the current simulation virtual time.
Definition simulator.cc:197
static void Run()
Run the simulation.
Definition simulator.cc:167
static EventId ScheduleNow(FUNC f, Ts &&... args)
Schedule an event to expire Now.
Definition simulator.h:594
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Definition simulator.cc:175
static Ptr< Socket > CreateSocket(Ptr< Node > node, TypeId tid)
This method wraps the creation of sockets that is performed on a given node by a SocketFactory specif...
Definition socket.cc:61
virtual int Close()=0
Close a socket.
Hold variables of type string.
Definition string.h:45
Header for the Transmission Control Protocol.
Definition tcp-header.h:36
static TypeId GetTypeId()
Get the type ID.
encapsulates test code
Definition test.h:1050
std::string CreateDataDirFilename(std::string filename)
Construct the full path to a file in the data directory.
Definition test.cc:413
void AddTestCase(TestCase *testCase, Duration duration=Duration::QUICK)
Add an individual child TestCase to this test suite.
Definition test.cc:292
bool IsStatusSuccess() const
Check if all tests passed.
Definition test.cc:465
void SetDataDir(std::string directory)
Set the data directory where reference trace files can be found.
Definition test.cc:472
A suite of tests to run.
Definition test.h:1267
Type
Type of test.
Definition test.h:1274
Simulation virtual time values and global simulation resolution.
Definition nstime.h:94
double GetSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
Definition nstime.h:392
int64_t GetMicroSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
Definition nstime.h:402
AttributeValue implementation for Time.
Definition nstime.h:1395
Build a set of QueueDisc objects.
QueueDiscContainer Install(NetDeviceContainer c)
uint16_t SetRootQueueDisc(const std::string &type, Args &&... args)
Helper function used to set a root queue disc of the given type and with the given attributes.
Hold an unsigned integer type.
Definition uinteger.h:34
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
Definition assert.h:55
void SetDefault(std::string name, const AttributeValue &value)
Definition config.cc:883
void Connect(std::string path, const CallbackBase &cb)
Definition config.cc:967
#define NS_ABORT_MSG_UNLESS(cond, msg)
Abnormal program termination if a condition is false, with a message.
Definition abort.h:133
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition log.h:191
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
Definition log.h:257
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Definition log.h:264
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
Definition object.h:619
Ptr< T > Create(Ts &&... args)
Create class instances by constructors with varying numbers of arguments and return them by Ptr.
Definition ptr.h:436
#define NS_TEST_EXPECT_MSG_EQ(actual, limit, msg)
Test that an actual and expected (limit) value are equal and report if not.
Definition test.h:241
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition nstime.h:1308
Every class exported by the ns3 library is enclosed in the ns3 namespace.
void LogComponentEnable(const std::string &name, LogLevel level)
Enable the logging output associated with that log component.
Definition log.cc:291
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...
Definition callback.h:684
@ LOG_PREFIX_FUNC
Prefix all trace prints with function.
Definition log.h:107
@ LOG_LEVEL_DEBUG
LOG_DEBUG and above.
Definition log.h:102
@ LOG_LEVEL_INFO
LOG_INFO and above.
Definition log.h:93
void LogComponentEnableAll(LogLevel level)
Enable the logging output for all registered log components.
Definition log.cc:309
const uint32_t PCAP_LINK_TYPE
Some large random number – we use to verify data was written by this program.
const bool WRITE_VECTORS
Set to true to write response vectors.
static Ns3TcpStateTestSuite g_ns3TcpLossTestSuite
Do not forget to allocate an instance of this TestSuite.
const bool WRITE_PCAP
Set to true to write out pcap.
const bool WRITE_LOGGING
Set to true to write logging.
const uint32_t PCAP_SNAPLEN
Don't bother to save much data.
Ptr< PacketSink > sink
Pointer to the packet sink application.
Definition wifi-tcp.cc:44