A Discrete-Event Network Simulator
API
hwmp-reactive-regression.cc
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2 /*
3  * Copyright (c) 2009 IITP RAS
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License version 2 as
7  * published by the Free Software Foundation;
8  *
9  * This program is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program; if not, write to the Free Software
16  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17  *
18  * Authors: Kirill Andreev <andreev@iitp.ru>
19  */
20 
21 #include "ns3/mesh-helper.h"
22 #include "ns3/simulator.h"
23 #include "ns3/random-variable-stream.h"
24 #include "ns3/rng-seed-manager.h"
25 #include "ns3/mobility-helper.h"
26 #include "ns3/double.h"
27 #include "ns3/uinteger.h"
28 #include "ns3/string.h"
29 #include "ns3/yans-wifi-helper.h"
30 #include "ns3/internet-stack-helper.h"
31 #include "ns3/ipv4-address-helper.h"
32 #include "ns3/abort.h"
33 #include "ns3/mobility-model.h"
34 #include "ns3/pcap-test.h"
35 #include <sstream>
36 
38 
40 const char * const PREFIX = "hwmp-reactive-regression-test";
41 
42 HwmpReactiveRegressionTest::HwmpReactiveRegressionTest () : TestCase ("HWMP on-demand regression test"),
43  m_nodes (0),
44  m_time (Seconds (10)),
45  m_sentPktsCounter (0)
46 {
47 }
49 {
50  delete m_nodes;
51 }
52 void
54 {
55  RngSeedManager::SetSeed (12345);
56  // This test is somewhat sensitive to seed selection, since the nodes
57  // are on the fringe of reception range from one another (to create
58  // a multi-hop topology). Some seeds may yield no data transfer because
59  // ARP resolution across the mesh may fail too many times
60  RngSeedManager::SetRun (1);
61  CreateNodes ();
62  CreateDevices ();
64 
65  Simulator::Stop (m_time);
66  Simulator::Run ();
67  Simulator::Destroy ();
68 
69  CheckResults ();
70  delete m_nodes, m_nodes = 0;
71 }
72 void
74 {
75  m_nodes = new NodeContainer;
76  m_nodes->Create (6);
78  Ptr<ListPositionAllocator> positionAlloc = CreateObject<ListPositionAllocator>();
79  positionAlloc->Add (Vector ( 0, 0, 0));
80  positionAlloc->Add (Vector ( 0, 150, 0));
81  positionAlloc->Add (Vector ( 0, 300, 0));
82  positionAlloc->Add (Vector ( 0, 450, 0));
83  positionAlloc->Add (Vector ( 0, 600, 0));
84  positionAlloc->Add (Vector ( 0, 750, 0));
85  mobility.SetPositionAllocator (positionAlloc);
86  mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel");
87  mobility.Install (*m_nodes);
88  Simulator::Schedule (Seconds (5.0), &HwmpReactiveRegressionTest::ResetPosition, this);
89 }
90 void
92 {
93  // client socket
94  m_clientSocket = Socket::CreateSocket (m_nodes->Get (5), TypeId::LookupByName ("ns3::UdpSocketFactory"));
95  m_clientSocket->Bind ();
98  Simulator::ScheduleWithContext (m_clientSocket->GetNode ()->GetId (), Seconds (2.0),
100 
101  // server socket
102  m_serverSocket = Socket::CreateSocket (m_nodes->Get (0), TypeId::LookupByName ("ns3::UdpSocketFactory"));
103  m_serverSocket->Bind (InetSocketAddress (Ipv4Address::GetAny (), 9));
104  m_serverSocket->SetRecvCallback (MakeCallback (&HwmpReactiveRegressionTest::HandleReadServer, this));
105 }
106 void
108 {
109  int64_t streamsUsed = 0;
110  // 1. setup WiFi
111  YansWifiPhyHelper wifiPhy = YansWifiPhyHelper::Default ();
112  // This test suite output was originally based on YansErrorRateModel
113  wifiPhy.SetErrorRateModel ("ns3::YansErrorRateModel");
114  YansWifiChannelHelper wifiChannel = YansWifiChannelHelper::Default ();
115  Ptr<YansWifiChannel> chan = wifiChannel.Create ();
116  wifiPhy.SetChannel (chan);
117  wifiPhy.Set ("TxGain", DoubleValue (1.0)); //this configuration should go away in future revision to the test
118  wifiPhy.Set ("RxGain", DoubleValue (1.0)); //this configuration should go away in future revision to the test
119 
120  // 2. setup mesh
121  MeshHelper mesh = MeshHelper::Default ();
122  mesh.SetStackInstaller ("ns3::Dot11sStack");
123  mesh.SetMacType ("RandomStart", TimeValue (Seconds (0.1)));
124  mesh.SetNumberOfInterfaces (1);
125  NetDeviceContainer meshDevices = mesh.Install (wifiPhy, *m_nodes);
126  // Six devices, 4 streams per device
127  streamsUsed += mesh.AssignStreams (meshDevices, streamsUsed);
128  NS_TEST_EXPECT_MSG_EQ (streamsUsed, (meshDevices.GetN () * 9), "Stream assignment mismatch");
129  streamsUsed += wifiChannel.AssignStreams (chan, streamsUsed);
130  NS_TEST_EXPECT_MSG_EQ (streamsUsed, (meshDevices.GetN () * 9), "Stream assignment mismatch");
131 
132  // 3. setup TCP/IP
133  InternetStackHelper internetStack;
134  internetStack.Install (*m_nodes);
135  streamsUsed += internetStack.AssignStreams (*m_nodes, streamsUsed);
137  address.SetBase ("10.1.1.0", "255.255.255.0");
138  m_interfaces = address.Assign (meshDevices);
139  // 4. write PCAP if needed
141 }
142 
143 void
145 {
146  for (int i = 0; i < 6; ++i)
147  {
148  NS_PCAP_TEST_EXPECT_EQ (PREFIX << "-" << i << "-1.pcap");
149  }
150 }
151 
152 void
154 {
155  Ptr<Object> object = m_nodes->Get (3);
156  Ptr<MobilityModel> model = object->GetObject<MobilityModel> ();
157  if (model == 0)
158  {
159  return;
160  }
161  model->SetPosition (Vector (9000, 0, 0));
162 }
163 
164 void
166 {
167  if ((Simulator::Now () < m_time) && (m_sentPktsCounter < 300))
168  {
169  socket->Send (Create<Packet> (20));
171  Simulator::ScheduleWithContext (socket->GetNode ()->GetId (), Seconds (0.5),
172  &HwmpReactiveRegressionTest::SendData, this, socket);
173  }
174 }
175 
176 void
178 {
179  Ptr<Packet> packet;
180  Address from;
181  while ((packet = socket->RecvFrom (from)))
182  {
183  packet->RemoveAllPacketTags ();
184  packet->RemoveAllByteTags ();
185 
186  socket->SendTo (packet, 0, from);
187  }
188 }
189 
190 void
192 {
193  Ptr<Packet> packet;
194  Address from;
195  while ((packet = socket->RecvFrom (from)))
196  {
197  }
198 }
void CreateDevices()
Create devices function.
void Set(std::string name, const AttributeValue &v)
Definition: wifi-helper.cc:132
void ResetPosition()
Reset position function.
an Inet address class
Smart pointer class similar to boost::intrusive_ptr.
Definition: ptr.h:73
Ptr< YansWifiChannel > Create(void) const
void SendData(Ptr< Socket > socket)
Send data.
Ptr< T > GetObject(void) const
Get a pointer to the requested aggregated Object.
Definition: object.h:459
Make it easy to create and manage PHY objects for the yans model.
void CreateNodes()
Create nodes function.
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.
Definition: test.h:285
encapsulates test code
Definition: test.h:1155
#define NS_PCAP_TEST_EXPECT_EQ(filename)
Test that a pair of reference/new pcap files are equal.
Definition: pcap-test.h:38
void SetNumberOfInterfaces(uint32_t nInterfaces)
Set a number of interfaces in a mesh network.
Definition: mesh-helper.cc:77
a polymophic address class
Definition: address.h:90
uint32_t GetN(void) const
Get the number of Ptr stored in this container.
Keep track of the current position and velocity of an object.
void SetChannel(Ptr< YansWifiChannel > channel)
void RemoveAllPacketTags(void)
Remove all packet tags.
Definition: packet.cc:842
void Install(Ptr< Node > node) const
"Layout" a single node according to the current position allocator type.
tuple mobility
Definition: third.py:101
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 ...
AttributeValue implementation for Time.
Definition: nstime.h:1055
void HandleReadClient(Ptr< Socket > socket)
Handle a packet reception.
holds a vector of ns3::NetDevice pointers
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
Definition: callback.h:1489
Ptr< Socket > m_serverSocket
Server-side socket.
void SetRecvCallback(Callback< void, Ptr< Socket > >)
Notify application when new data is available to be read.
Definition: socket.cc:128
void SetMacType(std::string n0="", const AttributeValue &v0=EmptyAttributeValue(), std::string n1="", const AttributeValue &v1=EmptyAttributeValue(), std::string n2="", const AttributeValue &v2=EmptyAttributeValue(), std::string n3="", const AttributeValue &v3=EmptyAttributeValue(), std::string n4="", const AttributeValue &v4=EmptyAttributeValue(), std::string n5="", const AttributeValue &v5=EmptyAttributeValue(), std::string n6="", const AttributeValue &v6=EmptyAttributeValue(), std::string n7="", const AttributeValue &v7=EmptyAttributeValue())
Definition: mesh-helper.cc:126
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
const char *const PREFIX
Unique PCAP file name prefix.
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
keep track of a set of node pointers.
void SetMobilityModel(std::string type, std::string n1="", const AttributeValue &v1=EmptyAttributeValue(), std::string n2="", const AttributeValue &v2=EmptyAttributeValue(), std::string n3="", const AttributeValue &v3=EmptyAttributeValue(), std::string n4="", const AttributeValue &v4=EmptyAttributeValue(), std::string n5="", const AttributeValue &v5=EmptyAttributeValue(), std::string n6="", const AttributeValue &v6=EmptyAttributeValue(), std::string n7="", const AttributeValue &v7=EmptyAttributeValue(), std::string n8="", const AttributeValue &v8=EmptyAttributeValue(), std::string n9="", const AttributeValue &v9=EmptyAttributeValue())
void HandleReadServer(Ptr< Socket > socket)
Handle a packet reception.
void Install(std::string nodeName) const
Aggregate implementations of the ns3::Ipv4, ns3::Ipv6, ns3::Udp, and ns3::Tcp classes onto the provid...
virtual void DoRun()
Implementation to actually run this TestCase.
manage and create wifi channel objects for the yans model.
Ptr< Socket > m_clientSocket
Client-side socket.
int64_t AssignStreams(NetDeviceContainer c, int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model...
Definition: mesh-helper.cc:215
void SetStackInstaller(std::string type, std::string n0="", const AttributeValue &v0=EmptyAttributeValue(), std::string n1="", const AttributeValue &v1=EmptyAttributeValue(), std::string n2="", const AttributeValue &v2=EmptyAttributeValue(), std::string n3="", const AttributeValue &v3=EmptyAttributeValue(), std::string n4="", const AttributeValue &v4=EmptyAttributeValue(), std::string n5="", const AttributeValue &v5=EmptyAttributeValue(), std::string n6="", const AttributeValue &v6=EmptyAttributeValue(), std::string n7="", const AttributeValue &v7=EmptyAttributeValue())
Definition: mesh-helper.cc:49
void InstallApplications()
Install application function.
void SetErrorRateModel(std::string name, std::string n0="", const AttributeValue &v0=EmptyAttributeValue(), std::string n1="", const AttributeValue &v1=EmptyAttributeValue(), std::string n2="", const AttributeValue &v2=EmptyAttributeValue(), std::string n3="", const AttributeValue &v3=EmptyAttributeValue(), std::string n4="", const AttributeValue &v4=EmptyAttributeValue(), std::string n5="", const AttributeValue &v5=EmptyAttributeValue(), std::string n6="", const AttributeValue &v6=EmptyAttributeValue(), std::string n7="", const AttributeValue &v7=EmptyAttributeValue())
Definition: wifi-helper.cc:138
void SetPosition(const Vector &position)
Helper class used to assign positions and mobility models to nodes.
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
int64_t AssignStreams(NodeContainer c, int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model...
NetDeviceContainer Install(const WifiPhyHelper &phyHelper, NodeContainer c) const
Install 802.11s mesh device & protocols on given node list.
Definition: mesh-helper.cc:82
uint32_t GetId(void) const
Definition: node.cc:107
virtual Ptr< Node > GetNode(void) const =0
Return the node this socket is associated with.
Ptr< Node > Get(uint32_t i) const
Get the Ptr stored in this container at a given index.
std::string CreateTempDirFilename(std::string filename)
Construct the full path to a file in a temporary directory.
Definition: test.cc:430
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition: nstime.h:993
void RemoveAllByteTags(void)
Remove all byte tags stored in this packet.
Definition: packet.cc:348
void Add(Vector v)
Add a position to the list of positions.
Ipv4InterfaceContainer m_interfaces
interfaces
virtual int SendTo(Ptr< Packet > p, uint32_t flags, const Address &toAddress)=0
Send data to a specified peer.
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.
Definition: simulator.cc:365
uint32_t m_sentPktsCounter
sent packets counter
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
Helper to create IEEE 802.11s mesh networks.
Definition: mesh-helper.h:38
tuple address
Definition: first.py:37
virtual Ptr< Packet > RecvFrom(uint32_t maxSize, uint32_t flags, Address &fromAddress)=0
Read a single packet from the socket and retrieve the sender address.
virtual int Send(Ptr< Packet > p, uint32_t flags)=0
Send data (or dummy data) to the remote host.
void SetPositionAllocator(Ptr< PositionAllocator > allocator)
Set the position allocator which will be used to allocate the initial position of every node initiali...
This class can be used to hold variables of floating point type such as 'double' or 'float'...
Definition: double.h:41
int64_t AssignStreams(Ptr< YansWifiChannel > c, int64_t stream)
Assign a fixed random variable stream number to the random variables used by the channel.
void CheckResults()
Check results function.
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