66 #include "ns3/core-module.h"
67 #include "ns3/network-module.h"
68 #include "ns3/internet-module.h"
69 #include "ns3/flow-monitor-helper.h"
70 #include "ns3/point-to-point-module.h"
71 #include "ns3/applications-module.h"
72 #include "ns3/traffic-control-module.h"
107 uint32_t qSize = StaticCast<RedQueueDisc> (queue)->GetQueueSize ();
115 std::ofstream fPlotQueueDisc (
filePlotQueueDisc.str ().c_str (), std::ios::out | std::ios::app);
117 fPlotQueueDisc.close ();
119 std::ofstream fPlotQueueDiscAvg (
filePlotQueueDiscAvg.str ().c_str (), std::ios::out | std::ios::app);
121 fPlotQueueDiscAvg.close ();
128 uint16_t
port = 50000;
152 if (test == 6 || test == 7 || test == 8 || test == 9 || test == 10 || test == 12)
178 main (
int argc,
char *argv[])
183 std::string aredLinkDataRate =
"1.5Mbps";
184 std::string aredLinkDelay =
"20ms";
187 bool writeForPlot =
false;
188 bool writePcap =
false;
189 bool flowMonitor =
false;
191 bool printAredStats =
true;
205 cmd.
AddValue (
"testNumber",
"Run test 1, 2, 6, 7, 8, 9, 10, 12, 13, 14 or 15", aredTest);
206 cmd.
AddValue (
"pathOut",
"Path to save results from --writeForPlot/--writePcap/--writeFlowMonitor", pathOut);
207 cmd.
AddValue (
"writeForPlot",
"<0/1> to write results for plot (gnuplot)", writeForPlot);
208 cmd.
AddValue (
"writePcap",
"<0/1> to write results in pcapfile", writePcap);
209 cmd.
AddValue (
"writeFlowMonitor",
"<0/1> to enable Flow Monitor and write their results", flowMonitor);
211 cmd.
Parse (argc, argv);
212 if ( (aredTest != 1) && (aredTest != 2) && (aredTest != 6) && (aredTest != 7) && (aredTest != 8) && (aredTest != 9) && (aredTest != 10) && (aredTest != 12) && (aredTest != 13) && (aredTest != 14) && (aredTest != 15) )
214 std::cout <<
"Invalid test number. Supported tests are 1, 2, 6, 7, 8, 9, 10, 12, 13, 14 or 15" << std::endl;
239 uint32_t meanPktSize = 1000;
256 else if (aredTest == 2)
262 else if (aredTest == 7)
266 else if (aredTest == 8)
271 else if (aredTest == 9)
276 else if (aredTest == 10)
281 else if (aredTest == 12)
287 else if (aredTest == 13)
291 else if (aredTest == 14)
297 else if (aredTest == 15)
307 NS_LOG_INFO (
"Install internet stack on all nodes.");
331 if (aredTest == 1 || aredTest == 2)
333 p2p.
SetQueue (
"ns3::DropTailQueue");
339 p2p.
SetQueue (
"ns3::DropTailQueue");
345 p2p.
SetQueue (
"ns3::DropTailQueue");
350 queueDiscs = tchRed.
Install (devn2n3);
352 p2p.
SetQueue (
"ns3::DropTailQueue");
358 p2p.
SetQueue (
"ns3::DropTailQueue");
364 else if (aredTest == 13 || aredTest == 14 || aredTest == 15)
366 p2p.
SetQueue (
"ns3::DropTailQueue");
372 p2p.
SetQueue (
"ns3::DropTailQueue");
378 p2p.
SetQueue (
"ns3::DropTailQueue");
383 queueDiscs = tchRed.
Install (devn2n3);
385 p2p.
SetQueue (
"ns3::DropTailQueue");
391 p2p.
SetQueue (
"ns3::DropTailQueue");
397 else if (aredTest == 6 || aredTest == 7 || aredTest == 8 || aredTest == 9 || aredTest == 10 || aredTest == 12)
399 p2p.
SetQueue (
"ns3::DropTailQueue");
405 p2p.
SetQueue (
"ns3::DropTailQueue");
411 p2p.
SetQueue (
"ns3::DropTailQueue");
416 queueDiscs = tchRed.
Install (devn2n3);
418 p2p.
SetQueue (
"ns3::DropTailQueue");
424 p2p.
SetQueue (
"ns3::DropTailQueue");
434 ipv4.
SetBase (
"10.1.1.0",
"255.255.255.0");
437 ipv4.
SetBase (
"10.1.2.0",
"255.255.255.0");
440 ipv4.
SetBase (
"10.1.3.0",
"255.255.255.0");
443 ipv4.
SetBase (
"10.1.4.0",
"255.255.255.0");
446 ipv4.
SetBase (
"10.1.5.0",
"255.255.255.0");
457 std::stringstream stmp;
458 stmp << pathOut <<
"/ared";
485 if (aredTest == 1 || aredTest == 2 || aredTest == 13)
489 std::cout <<
"Drops due to prob mark should be less than the drops due to hard mark" << std::endl;
495 std::cout <<
"There should be some drops due to queue full" << std::endl;
499 else if (aredTest == 6 || aredTest == 7 || aredTest == 8 || aredTest == 9 || aredTest == 10 || aredTest == 14 || aredTest ==15)
503 std::cout <<
"Drops due to prob mark should be less than the drops due to hard mark" << std::endl;
509 std::cout <<
"There should be zero drops due to queue full" << std::endl;
513 else if (aredTest == 12)
517 std::cout <<
"Drops due to prob mark should be more than the drops due to hard mark" << std::endl;
523 std::cout <<
"There should be zero drops due to queue full" << std::endl;
530 std::stringstream stmp;
531 stmp << pathOut <<
"/ared.flowmon";
538 std::cout <<
"*** ARED stats from Node 2 queue ***" << std::endl;
539 std::cout <<
"\t " << st.
unforcedDrop <<
" drops due to prob mark" << std::endl;
540 std::cout <<
"\t " << st.
forcedDrop <<
" drops due to hard mark" << std::endl;
541 std::cout <<
"\t " << st.
qLimDrop <<
" drops due to queue full" << std::endl;
holds a vector of ns3::Application pointers.
static Ipv4Address GetAny(void)
AttributeValue implementation for Boolean.
QueueDiscContainer Install(NetDeviceContainer c)
holds a vector of std::pair of Ptr<Ipv4> and interface index.
static void PopulateRoutingTables(void)
Build a routing database and initialize the routing tables of the nodes in the simulation.
Hold variables of type string.
NetDeviceContainer Install(NodeContainer c)
void Add(ApplicationContainer other)
Append the contents of another ApplicationContainer to the end of this container. ...
Ipv4InterfaceContainer i3i5
void SetQueue(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())
Each point to point net device must have a queue to pass packets through.
Ipv4InterfaceContainer i1i2
Ipv4InterfaceContainer i3i4
static void Run(void)
Run the simulation.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
aggregate IP/TCP/UDP functionality to existing Nodes.
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes...
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 AddPacketFilter(uint16_t handle, std::string type, std::string n01="", const AttributeValue &v01=EmptyAttributeValue(), std::string n02="", const AttributeValue &v02=EmptyAttributeValue(), std::string n03="", const AttributeValue &v03=EmptyAttributeValue(), std::string n04="", const AttributeValue &v04=EmptyAttributeValue(), std::string n05="", const AttributeValue &v05=EmptyAttributeValue(), std::string n06="", const AttributeValue &v06=EmptyAttributeValue(), std::string n07="", const AttributeValue &v07=EmptyAttributeValue(), std::string n08="", const AttributeValue &v08=EmptyAttributeValue())
Helper function used to add a packet filter (of the given type and with the given attributes) to the ...
A helper to make it easier to instantiate an ns3::OnOffApplication on a set of nodes.
std::stringstream filePlotQueueDiscAvg
a polymophic address class
Holds a vector of ns3::QueueDisc pointers.
static void Add(std::string name, Ptr< Object > object)
Add the association between the string "name" and the Ptr<Object> obj.
Class for representing data rates.
double GetSeconds(void) const
Get an approximation of the time stored in this instance in the indicated unit.
Ptr< QueueDisc > Get(uint32_t i) const
Get the Ptr<QueueDisc> stored in this container at a given index.
void LogComponentEnable(char const *name, enum LogLevel level)
Enable the logging output associated with that log component.
uint32_t forcedDrop
Forced drops, qavg > max threshold.
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 ...
static EventId Schedule(Time const &delay, MEM mem_ptr, OBJ obj)
Schedule an event to expire after delay.
void BuildAppsTest(uint32_t test)
AttributeValue implementation for Time.
Hold an unsigned integer type.
uint32_t qLimDrop
Drops due to queue limits.
holds a vector of ns3::NetDevice pointers
Build a set of QueueDisc objects.
static void Bind(std::string name, const AttributeValue &value)
Iterate over the set of GlobalValues until a matching name is found and then set its value with Globa...
Ptr< FlowMonitor > InstallAll()
Enable flow monitoring on all nodes.
void Start(Time start)
Arrange for all of the Applications in this container to Start() at the Time given as a parameter...
Parse command-line arguments.
static void Destroy(void)
Execute the events scheduled with ScheduleDestroy().
keep track of a set of node pointers.
uint16_t SetRootQueueDisc(std::string type, std::string n01="", const AttributeValue &v01=EmptyAttributeValue(), std::string n02="", const AttributeValue &v02=EmptyAttributeValue(), std::string n03="", const AttributeValue &v03=EmptyAttributeValue(), std::string n04="", const AttributeValue &v04=EmptyAttributeValue(), std::string n05="", const AttributeValue &v05=EmptyAttributeValue(), std::string n06="", const AttributeValue &v06=EmptyAttributeValue(), std::string n07="", const AttributeValue &v07=EmptyAttributeValue(), std::string n08="", const AttributeValue &v08=EmptyAttributeValue(), std::string n09="", const AttributeValue &v09=EmptyAttributeValue(), std::string n10="", const AttributeValue &v10=EmptyAttributeValue(), std::string n11="", const AttributeValue &v11=EmptyAttributeValue(), std::string n12="", const AttributeValue &v12=EmptyAttributeValue(), std::string n13="", const AttributeValue &v13=EmptyAttributeValue(), std::string n14="", const AttributeValue &v14=EmptyAttributeValue(), std::string n15="", const AttributeValue &v15=EmptyAttributeValue())
Helper function used to set a root queue disc of the given type and with the given attributes...
void Install(std::string nodeName) const
Aggregate implementations of the ns3::Ipv4, ns3::Ipv6, ns3::Udp, and ns3::Tcp classes onto the provid...
Helper to enable IP flow monitoring on a set of Nodes.
static EventId ScheduleNow(MEM mem_ptr, OBJ obj)
Schedule an event to expire Now.
static Time Now(void)
Return the current simulation virtual time.
Ipv4InterfaceContainer i0i2
void SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
AttributeValue implementation for Address.
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 AddInternalQueues(uint16_t handle, uint16_t count, std::string type, std::string n01="", const AttributeValue &v01=EmptyAttributeValue(), std::string n02="", const AttributeValue &v02=EmptyAttributeValue(), std::string n03="", const AttributeValue &v03=EmptyAttributeValue(), std::string n04="", const AttributeValue &v04=EmptyAttributeValue(), std::string n05="", const AttributeValue &v05=EmptyAttributeValue(), std::string n06="", const AttributeValue &v06=EmptyAttributeValue(), std::string n07="", const AttributeValue &v07=EmptyAttributeValue(), std::string n08="", const AttributeValue &v08=EmptyAttributeValue())
Helper function used to add the given number of internal queues (of the given type and with the given...
AttributeValue implementation for DataRate.
void AddValue(const std::string &name, const std::string &help, T &value)
Add a program argument, assigning to POD.
static void Stop(void)
Tell the Simulator the calling event should be the last one executed.
void SerializeToXmlFile(std::string fileName, bool enableHistograms, bool enableProbes)
Same as SerializeToXmlStream, but writes to a file instead.
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)
std::stringstream filePlotQueueDisc
ApplicationContainer Install(NodeContainer c) const
Install an ns3::PacketSinkApplication on each node of the input container configured with all the att...
void Parse(int argc, char *argv[])
Parse the program arguments.
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
This class can be used to hold variables of floating point type such as 'double' or 'float'...
ApplicationContainer Install(NodeContainer c) const
Install an ns3::OnOffApplication on each node of the input container configured with all the attribut...
void CheckQueueDiscSize(Ptr< QueueDisc > queue)
void test(void)
Example use of ns3::SystemThread.
void SetAttribute(std::string name, const AttributeValue &value)
Helper function used to set the underlying application attributes.
Ipv4InterfaceContainer i2i3
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
uint32_t unforcedDrop
Early probability drops.
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const