A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
bug-772.cc
Go to the documentation of this file.
1/*
2 * Copyright (c) 2009 IITP RAS
3 *
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License version 2 as
6 * published by the Free Software Foundation;
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public License
14 * along with this program; if not, write to the Free Software
15 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16 *
17 * Authors: Pavel Boyko <boyko@iitp.ru>
18 */
19
20#include "bug-772.h"
21
22#include "ns3/abort.h"
23#include "ns3/aodv-helper.h"
24#include "ns3/boolean.h"
25#include "ns3/config.h"
26#include "ns3/data-rate.h"
27#include "ns3/double.h"
28#include "ns3/inet-socket-address.h"
29#include "ns3/internet-stack-helper.h"
30#include "ns3/ipv4-address-helper.h"
31#include "ns3/mobility-helper.h"
32#include "ns3/mobility-model.h"
33#include "ns3/pcap-file.h"
34#include "ns3/pcap-test.h"
35#include "ns3/random-variable-stream.h"
36#include "ns3/rng-seed-manager.h"
37#include "ns3/simulator.h"
38#include "ns3/string.h"
39#include "ns3/uinteger.h"
40#include "ns3/yans-wifi-helper.h"
41
42#include <sstream>
43
44using namespace ns3;
45
46//-----------------------------------------------------------------------------
47// UdpChainTest
48//-----------------------------------------------------------------------------
49Bug772ChainTest::Bug772ChainTest(const char* const prefix,
50 const char* const proto,
51 Time t,
52 uint32_t size)
53 : TestCase("Bug 772 UDP and TCP chain regression test"),
54 m_nodes(nullptr),
55 m_prefix(prefix),
56 m_proto(proto),
57 m_time(t),
58 m_size(size),
59 m_step(120),
60 m_port(9),
61 m_receivedPackets(0)
62{
63}
64
66{
67 delete m_nodes;
68}
69
70void
72{
73 if (Simulator::Now() < m_time)
74 {
75 socket->Send(Create<Packet>(1000));
76 Simulator::ScheduleWithContext(socket->GetNode()->GetId(),
77 Seconds(0.25),
79 this,
80 socket);
81 }
82}
83
84void
86{
88}
89
90void
92{
95
96 // Default of 3 will cause packet loss
97 Config::SetDefault("ns3::ArpCache::PendingQueueSize", UintegerValue(10));
98
101
102 Simulator::Stop(m_time + Seconds(1)); // Allow buffered packets to clear
105
106 CheckResults();
107
108 delete m_nodes, m_nodes = nullptr;
109}
110
111void
113{
116 MobilityHelper mobility;
117 mobility.SetPositionAllocator("ns3::GridPositionAllocator",
118 "MinX",
119 DoubleValue(0.0),
120 "MinY",
121 DoubleValue(0.0),
122 "DeltaX",
124 "DeltaY",
125 DoubleValue(0),
126 "GridWidth",
128 "LayoutType",
129 StringValue("RowFirst"));
130 mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
131 mobility.Install(*m_nodes);
132}
133
134void
136{
137 int64_t streamsUsed = 0;
138 // 1. Setup WiFi
139 WifiMacHelper wifiMac;
140 wifiMac.SetType("ns3::AdhocWifiMac");
141 YansWifiPhyHelper wifiPhy;
143 // This test suite output was originally based on YansErrorRateModel
144 wifiPhy.SetErrorRateModel("ns3::YansErrorRateModel");
146 Ptr<YansWifiChannel> chan = wifiChannel.Create();
147 wifiPhy.SetChannel(chan);
148 wifiPhy.Set(
149 "TxGain",
150 DoubleValue(1.0)); // this configuration should go away in future revision to the test
151 wifiPhy.Set(
152 "RxGain",
153 DoubleValue(1.0)); // this configuration should go away in future revision to the test
154 WifiHelper wifi;
155 wifi.SetStandard(WIFI_STANDARD_80211a);
156 wifi.SetRemoteStationManager("ns3::ConstantRateWifiManager",
157 "DataMode",
158 StringValue("OfdmRate6Mbps"),
159 "RtsCtsThreshold",
160 StringValue("2200"),
161 "MaxSlrc",
162 UintegerValue(7));
163 NetDeviceContainer devices = wifi.Install(wifiPhy, wifiMac, *m_nodes);
164
165 // Assign fixed stream numbers to wifi and channel random variables
166 streamsUsed += wifi.AssignStreams(devices, streamsUsed);
167 // Assign 6 streams per device
168 NS_TEST_ASSERT_MSG_EQ(streamsUsed, (devices.GetN() * 2), "Stream assignment mismatch");
169 streamsUsed += wifiChannel.AssignStreams(chan, streamsUsed);
170 // Assign 0 streams per channel for this configuration
171 NS_TEST_ASSERT_MSG_EQ(streamsUsed, (devices.GetN() * 2), "Stream assignment mismatch");
172
173 // 2. Setup TCP/IP & AODV
174 AodvHelper aodv; // Use default parameters here
175 InternetStackHelper internetStack;
176 internetStack.SetRoutingHelper(aodv);
177 internetStack.Install(*m_nodes);
178 streamsUsed += internetStack.AssignStreams(*m_nodes, streamsUsed);
179 // Expect to use (3*m_size) more streams for internet stack random variables
180 NS_TEST_ASSERT_MSG_EQ(streamsUsed,
181 ((devices.GetN() * 3) + (3 * m_size)),
182 "Stream assignment mismatch");
183 streamsUsed += aodv.AssignStreams(*m_nodes, streamsUsed);
184 // Expect to use m_size more streams for AODV
185 NS_TEST_ASSERT_MSG_EQ(streamsUsed,
186 ((devices.GetN() * 3) + (3 * m_size) + m_size),
187 "Stream assignment mismatch");
188 Ipv4AddressHelper address;
189 address.SetBase("10.1.1.0", "255.255.255.0");
190 Ipv4InterfaceContainer interfaces = address.Assign(devices);
191
192 // 3. Setup UDP source and sink
195 m_sendSocket->Connect(InetSocketAddress(interfaces.GetAddress(m_size - 1), m_port));
198 Seconds(1.0),
200 this,
202
208}
209
210void
212{
213 // We should have sent 8 packets (every 0.25 seconds from time 1 to time 3)
214 // Check that the received packet count is 8
215 NS_TEST_EXPECT_MSG_EQ(m_receivedPackets, 8, "Did not receive expected 8 packets");
216}
const std::string m_proto
Socket factory TID.
Definition: bug-772.h:60
Bug772ChainTest(const char *const prefix, const char *const proto, Time time, uint32_t size)
Create test case.
Definition: bug-772.cc:49
void HandleRead(Ptr< Socket > socket)
Receive data function.
Definition: bug-772.cc:85
const uint16_t m_port
port number
Definition: bug-772.h:68
void DoRun() override
Go.
Definition: bug-772.cc:91
Ptr< Socket > m_recvSocket
Receiving socket.
Definition: bug-772.h:85
NodeContainer * m_nodes
Definition: bug-772.h:55
const uint32_t m_size
Chain size.
Definition: bug-772.h:64
~Bug772ChainTest() override
Definition: bug-772.cc:65
void CreateNodes()
Create test topology.
Definition: bug-772.cc:112
const double m_step
Chain step, meters.
Definition: bug-772.h:66
void CreateDevices()
Create devices, install TCP/IP stack and applications.
Definition: bug-772.cc:135
void SendData(Ptr< Socket > socket)
Send data.
Definition: bug-772.cc:71
Ptr< Socket > m_sendSocket
Transmitting socket.
Definition: bug-772.h:87
const Time m_time
Total simulation time.
Definition: bug-772.h:62
void CheckResults()
Compare traces with reference ones.
Definition: bug-772.cc:211
uint32_t m_receivedPackets
Received packet count.
Definition: bug-772.h:90
Helper class that adds AODV routing to nodes.
Definition: aodv-helper.h:36
int64_t AssignStreams(NodeContainer c, int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model.
Definition: aodv-helper.cc:58
This class can be used to hold variables of floating point type such as 'double' or 'float'.
Definition: double.h:42
an Inet address class
aggregate IP/TCP/UDP functionality to existing Nodes.
void Install(std::string nodeName) const
Aggregate implementations of the ns3::Ipv4, ns3::Ipv6, ns3::Udp, and ns3::Tcp classes onto the provid...
void SetRoutingHelper(const Ipv4RoutingHelper &routing)
int64_t AssignStreams(NodeContainer c, int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model.
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
static Ipv4Address GetAny()
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Helper class used to assign positions and mobility models to nodes.
holds a vector of ns3::NetDevice pointers
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.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
uint32_t GetId() const
Definition: node.cc:117
Smart pointer class similar to boost::intrusive_ptr.
Definition: ptr.h:77
static void SetRun(uint64_t run)
Set the run number of simulation.
static void SetSeed(uint32_t seed)
Set the seed.
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
Definition: simulator.cc:142
static void ScheduleWithContext(uint32_t context, const Time &delay, FUNC f, Ts &&... args)
Schedule an event with the given context.
Definition: simulator.h:588
static Time Now()
Return the current simulation virtual time.
Definition: simulator.cc:208
static void Run()
Run the simulation.
Definition: simulator.cc:178
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Definition: simulator.cc:186
virtual bool SetAllowBroadcast(bool allowBroadcast)=0
Configure whether broadcast datagram transmissions are allowed.
virtual int ShutdownSend()=0
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
void SetRecvCallback(Callback< void, Ptr< Socket > > receivedData)
Notify application when new data is available to be read.
Definition: socket.cc:128
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:72
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
virtual Ptr< Node > GetNode() const =0
Return the node this socket is associated with.
virtual int Listen()=0
Listen for incoming connections.
Hold variables of type string.
Definition: string.h:56
encapsulates test code
Definition: test.h:1061
Simulation virtual time values and global simulation resolution.
Definition: nstime.h:105
static TypeId LookupByName(std::string name)
Get a TypeId by name.
Definition: type-id.cc:836
Hold an unsigned integer type.
Definition: uinteger.h:45
helps to create WifiNetDevice objects
Definition: wifi-helper.h:324
create MAC layers for a ns3::WifiNetDevice.
void SetType(std::string type, Args &&... args)
void Set(std::string name, const AttributeValue &v)
Definition: wifi-helper.cc:163
void DisablePreambleDetectionModel()
Disable the preamble detection model on all links.
Definition: wifi-helper.cc:178
void SetErrorRateModel(std::string type, Args &&... args)
Helper function used to set the error rate model.
Definition: wifi-helper.h:550
manage and create wifi channel objects for the YANS model.
int64_t AssignStreams(Ptr< YansWifiChannel > c, int64_t stream)
Assign a fixed random variable stream number to the random variables used by the channel.
static YansWifiChannelHelper Default()
Create a channel helper in a default working state.
Ptr< YansWifiChannel > Create() const
Make it easy to create and manage PHY objects for the YANS model.
void SetChannel(Ptr< YansWifiChannel > channel)
void SetDefault(std::string name, const AttributeValue &value)
Definition: config.cc:894
#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.
Definition: test.h:145
#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:252
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition: nstime.h:1326
@ WIFI_STANDARD_80211a
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...
Definition: callback.h:704