A Discrete-Event Network Simulator
API
pfifo-vs-red.cc
Go to the documentation of this file.
1/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/*
3 * This program is free software; you can redistribute it and/or modify
4 * it under the terms of the GNU General Public License version 2 as
5 * published by the Free Software Foundation;
6 *
7 * This program is distributed in the hope that it will be useful,
8 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 * GNU General Public License for more details.
11 *
12 * You should have received a copy of the GNU General Public License
13 * along with this program; if not, write to the Free Software
14 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
15 *
16 * Author: John Abraham <john.abraham@gatech.edu>
17 * Modified by: Pasquale Imputato <p.imputato@gmail.com>
18 *
19 */
20
21
22#include "ns3/core-module.h"
23#include "ns3/network-module.h"
24#include "ns3/internet-module.h"
25#include "ns3/point-to-point-module.h"
26#include "ns3/applications-module.h"
27#include "ns3/point-to-point-layout-module.h"
28#include "ns3/traffic-control-module.h"
29
30#include <iostream>
31#include <iomanip>
32#include <map>
33
34using namespace ns3;
35
36
37int main (int argc, char *argv[])
38{
39 uint32_t nLeaf = 5;
40 uint32_t maxPackets = 100;
41 uint32_t modeBytes = 0;
42 uint32_t queueDiscLimitPackets = 1000;
43 double minTh = 50;
44 double maxTh = 80;
45 uint32_t pktSize = 512;
46 std::string appDataRate = "10Mbps";
47 std::string queueDiscType = "PfifoFast";
48 uint16_t port = 5001;
49 std::string bottleNeckLinkBw = "1Mbps";
50 std::string bottleNeckLinkDelay = "50ms";
51
52 CommandLine cmd (__FILE__);
53 cmd.AddValue ("nLeaf", "Number of left and right side leaf nodes", nLeaf);
54 cmd.AddValue ("maxPackets","Max Packets allowed in the device queue", maxPackets);
55 cmd.AddValue ("queueDiscLimitPackets","Max Packets allowed in the queue disc", queueDiscLimitPackets);
56 cmd.AddValue ("queueDiscType", "Set QueueDisc type to PfifoFast or RED", queueDiscType);
57 cmd.AddValue ("appPktSize", "Set OnOff App Packet Size", pktSize);
58 cmd.AddValue ("appDataRate", "Set OnOff App DataRate", appDataRate);
59 cmd.AddValue ("modeBytes", "Set QueueDisc mode to Packets <0> or bytes <1>", modeBytes);
60
61 cmd.AddValue ("redMinTh", "RED queue minimum threshold", minTh);
62 cmd.AddValue ("redMaxTh", "RED queue maximum threshold", maxTh);
63 cmd.Parse (argc,argv);
64
65 if ((queueDiscType != "RED") && (queueDiscType != "PfifoFast"))
66 {
67 NS_ABORT_MSG ("Invalid queue disc type: Use --queueDiscType=RED or --queueDiscType=PfifoFast");
68 }
69
70 Config::SetDefault ("ns3::OnOffApplication::PacketSize", UintegerValue (pktSize));
71 Config::SetDefault ("ns3::OnOffApplication::DataRate", StringValue (appDataRate));
72
73 Config::SetDefault ("ns3::DropTailQueue<Packet>::MaxSize",
75
76 if (!modeBytes)
77 {
78 Config::SetDefault ("ns3::RedQueueDisc::MaxSize",
79 QueueSizeValue (QueueSize (QueueSizeUnit::PACKETS, queueDiscLimitPackets)));
80 Config::SetDefault ("ns3::PfifoFastQueueDisc::MaxSize",
81 QueueSizeValue (QueueSize (QueueSizeUnit::PACKETS, queueDiscLimitPackets)));
82 }
83 else
84 {
85 Config::SetDefault ("ns3::RedQueueDisc::MaxSize",
86 QueueSizeValue (QueueSize (QueueSizeUnit::BYTES, queueDiscLimitPackets * pktSize)));
87 minTh *= pktSize;
88 maxTh *= pktSize;
89 }
90
91 Config::SetDefault ("ns3::RedQueueDisc::MinTh", DoubleValue (minTh));
92 Config::SetDefault ("ns3::RedQueueDisc::MaxTh", DoubleValue (maxTh));
93 Config::SetDefault ("ns3::RedQueueDisc::LinkBandwidth", StringValue (bottleNeckLinkBw));
94 Config::SetDefault ("ns3::RedQueueDisc::LinkDelay", StringValue (bottleNeckLinkDelay));
95
96 // Create the point-to-point link helpers
97 PointToPointHelper bottleNeckLink;
98 bottleNeckLink.SetDeviceAttribute ("DataRate", StringValue (bottleNeckLinkBw));
99 bottleNeckLink.SetChannelAttribute ("Delay", StringValue (bottleNeckLinkDelay));
100
101 PointToPointHelper pointToPointLeaf;
102 pointToPointLeaf.SetDeviceAttribute ("DataRate", StringValue ("10Mbps"));
103 pointToPointLeaf.SetChannelAttribute ("Delay", StringValue ("1ms"));
104
105 PointToPointDumbbellHelper d (nLeaf, pointToPointLeaf,
106 nLeaf, pointToPointLeaf,
107 bottleNeckLink);
108
109 // Install Stack
111 for (uint32_t i = 0; i < d.LeftCount (); ++i)
112 {
113 stack.Install (d.GetLeft (i));
114 }
115 for (uint32_t i = 0; i < d.RightCount (); ++i)
116 {
117 stack.Install (d.GetRight (i));
118 }
119
120 if (queueDiscType == "PfifoFast")
121 {
122 stack.Install (d.GetLeft ());
123 stack.Install (d.GetRight ());
124 }
125 else if (queueDiscType == "RED")
126 {
127 stack.Install (d.GetLeft ());
128 stack.Install (d.GetRight ());
129 TrafficControlHelper tchBottleneck;
130 tchBottleneck.SetRootQueueDisc ("ns3::RedQueueDisc");
131 tchBottleneck.Install (d.GetLeft ()->GetDevice (0));
132 tchBottleneck.Install (d.GetRight ()->GetDevice (0));
133 }
134
135 // Assign IP Addresses
136 d.AssignIpv4Addresses (Ipv4AddressHelper ("10.1.1.0", "255.255.255.0"),
137 Ipv4AddressHelper ("10.2.1.0", "255.255.255.0"),
138 Ipv4AddressHelper ("10.3.1.0", "255.255.255.0"));
139
140 // Install on/off app on all right side nodes
141 OnOffHelper clientHelper ("ns3::TcpSocketFactory", Address ());
142 clientHelper.SetAttribute ("OnTime", StringValue ("ns3::UniformRandomVariable[Min=0.|Max=1.]"));
143 clientHelper.SetAttribute ("OffTime", StringValue ("ns3::UniformRandomVariable[Min=0.|Max=1.]"));
144 Address sinkLocalAddress (InetSocketAddress (Ipv4Address::GetAny (), port));
145 PacketSinkHelper packetSinkHelper ("ns3::TcpSocketFactory", sinkLocalAddress);
146 ApplicationContainer sinkApps;
147 for (uint32_t i = 0; i < d.LeftCount (); ++i)
148 {
149 sinkApps.Add (packetSinkHelper.Install (d.GetLeft (i)));
150 }
151 sinkApps.Start (Seconds (0.0));
152 sinkApps.Stop (Seconds (30.0));
153
155 for (uint32_t i = 0; i < d.RightCount (); ++i)
156 {
157 // Create an on/off app sending packets to the left side
158 AddressValue remoteAddress (InetSocketAddress (d.GetLeftIpv4Address (i), port));
159 clientHelper.SetAttribute ("Remote", remoteAddress);
160 clientApps.Add (clientHelper.Install (d.GetRight (i)));
161 }
162 clientApps.Start (Seconds (1.0)); // Start 1 second after sink
163 clientApps.Stop (Seconds (15.0)); // Stop before the sink
164
165 Ipv4GlobalRoutingHelper::PopulateRoutingTables ();
166
167 std::cout << "Running the simulation" << std::endl;
168 Simulator::Run ();
169
170 uint64_t totalRxBytesCounter = 0;
171 for (uint32_t i = 0; i < sinkApps.GetN (); i++)
172 {
173 Ptr <Application> app = sinkApps.Get (i);
174 Ptr <PacketSink> pktSink = DynamicCast <PacketSink> (app);
175 totalRxBytesCounter += pktSink->GetTotalRx ();
176 }
177 NS_LOG_UNCOND ("----------------------------\nQueueDisc Type:"
178 << queueDiscType
179 << "\nGoodput Bytes/sec:"
180 << totalRxBytesCounter/Simulator::Now ().GetSeconds ());
181 NS_LOG_UNCOND ("----------------------------");
182
183
184 std::cout << "Destroying the simulation" << std::endl;
185 Simulator::Destroy ();
186 return 0;
187}
a polymophic address class
Definition: address.h:91
AttributeValue implementation for Address.
holds a vector of ns3::Application pointers.
Ptr< Application > Get(uint32_t i) const
Get the Ptr<Application> stored in this container at a given index.
void Start(Time start)
Arrange for all of the Applications in this container to Start() at the Time given as a parameter.
void Add(ApplicationContainer other)
Append the contents of another ApplicationContainer to the end of this container.
void Stop(Time stop)
Arrange for all of the Applications in this container to Stop() at the Time given as a parameter.
uint32_t GetN(void) const
Get the number of Ptr<Application> stored in this container.
Parse command-line arguments.
Definition: command-line.h:229
This class can be used to hold variables of floating point type such as 'double' or 'float'.
Definition: double.h:41
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.
A helper to make it easier to instantiate an ns3::OnOffApplication on a set of nodes.
Definition: on-off-helper.h:43
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
uint64_t GetTotalRx() const
Definition: packet-sink.cc:93
A helper to make it easier to create a dumbbell topology with p2p links.
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 SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
Class for representing queue sizes.
Definition: queue-size.h:95
AttributeValue implementation for QueueSize.
Hold variables of type string.
Definition: string.h:41
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:44
uint16_t port
Definition: dsdv-manet.cc:45
void SetDefault(std::string name, const AttributeValue &value)
Definition: config.cc:849
#define NS_ABORT_MSG(msg)
Unconditional abnormal program termination with a message.
Definition: abort.h:50
#define NS_LOG_UNCOND(msg)
Output the requested message unconditionally.
@ BYTES
Use number of bytes for queue size.
Definition: queue-size.h:45
@ PACKETS
Use number of packets for queue size.
Definition: queue-size.h:44
Time Now(void)
create an ns3::Time instance which contains the current simulation time.
Definition: simulator.cc:287
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition: nstime.h:1244
clientApps
Definition: first.py:61
stack
Definition: first.py:41
Every class exported by the ns3 library is enclosed in the ns3 namespace.
cmd
Definition: second.py:35
uint32_t pktSize
packet size used for the simulation (in bytes)
Definition: wifi-bianchi.cc:89