41 #include "ns3/core-module.h"
42 #include "ns3/network-module.h"
43 #include "ns3/internet-module.h"
44 #include "ns3/flow-monitor-helper.h"
45 #include "ns3/point-to-point-module.h"
46 #include "ns3/applications-module.h"
47 #include "ns3/traffic-control-module.h"
82 uint32_t qSize = StaticCast<RedQueueDisc> (queue)->GetQueueSize ();
90 std::ofstream fPlotQueue (
filePlotQueue.str ().c_str (), std::ios::out|std::ios::app);
94 std::ofstream fPlotQueueAvg (
filePlotQueueAvg.str ().c_str (), std::ios::out|std::ios::app);
96 fPlotQueueAvg.close ();
102 if ( (test == 1) || (test == 3) )
105 uint16_t
port = 50000;
153 uint16_t port1 = 50001;
160 uint16_t port2 = 50002;
167 uint16_t port3 = 50003;
174 uint16_t port4 = 50004;
256 main (
int argc,
char *argv[])
261 std::string redLinkDataRate =
"1.5Mbps";
262 std::string redLinkDelay =
"20ms";
265 bool writeForPlot =
false;
266 bool writePcap =
false;
267 bool flowMonitor =
false;
269 bool printRedStats =
true;
283 cmd.
AddValue (
"testNumber",
"Run test 1, 3, 4 or 5", redTest);
284 cmd.
AddValue (
"pathOut",
"Path to save results from --writeForPlot/--writePcap/--writeFlowMonitor", pathOut);
285 cmd.
AddValue (
"writeForPlot",
"<0/1> to write results for plot (gnuplot)", writeForPlot);
286 cmd.
AddValue (
"writePcap",
"<0/1> to write results in pcapfile", writePcap);
287 cmd.
AddValue (
"writeFlowMonitor",
"<0/1> to enable Flow Monitor and write their results", flowMonitor);
289 cmd.
Parse (argc, argv);
290 if ( (redTest != 1) && (redTest != 3) && (redTest != 4) && (redTest != 5) )
292 NS_ABORT_MSG (
"Invalid test number. Supported tests are 1, 3, 4 or 5");
316 uint32_t meanPktSize = 500;
334 else if (redTest == 5)
343 NS_LOG_INFO (
"Install internet stack on all nodes.");
359 p2p.
SetQueue (
"ns3::DropTailQueue");
365 p2p.
SetQueue (
"ns3::DropTailQueue");
371 p2p.
SetQueue (
"ns3::DropTailQueue");
378 p2p.
SetQueue (
"ns3::DropTailQueue");
384 p2p.
SetQueue (
"ns3::DropTailQueue");
393 ipv4.
SetBase (
"10.1.1.0",
"255.255.255.0");
396 ipv4.
SetBase (
"10.1.2.0",
"255.255.255.0");
399 ipv4.
SetBase (
"10.1.3.0",
"255.255.255.0");
402 ipv4.
SetBase (
"10.1.4.0",
"255.255.255.0");
405 ipv4.
SetBase (
"10.1.5.0",
"255.255.255.0");
417 StaticCast<RedQueueDisc> (queue)->SetTh (5, 15);
418 StaticCast<RedQueueDisc> (queue)->SetQueueLimit (1000);
426 std::stringstream stmp;
427 stmp << pathOut <<
"/red";
454 std::stringstream stmp;
455 stmp << pathOut <<
"/red.flowmon";
463 std::cout <<
"*** RED stats from Node 2 queue ***" << std::endl;
464 std::cout <<
"\t " << st.
unforcedDrop <<
" drops due prob mark" << std::endl;
465 std::cout <<
"\t " << st.
forcedDrop <<
" drops due hard mark" << std::endl;
466 std::cout <<
"\t " << st.
qLimDrop <<
" drops due queue full" << std::endl;
468 st = StaticCast<RedQueueDisc> (queueDiscs.
Get (1))->GetStats ();
469 std::cout <<
"*** RED stats from Node 3 queue ***" << std::endl;
470 std::cout <<
"\t " << st.
unforcedDrop <<
" drops due prob mark" << std::endl;
471 std::cout <<
"\t " << st.
forcedDrop <<
" drops due hard mark" << std::endl;
472 std::cout <<
"\t " << st.
qLimDrop <<
" drops due queue full" << std::endl;
holds a vector of ns3::Application pointers.
void BuildAppsTest(uint32_t test)
static Ipv4Address GetAny(void)
AttributeValue implementation for Boolean.
QueueDiscContainer Install(NetDeviceContainer c)
#define NS_ABORT_MSG(msg)
Unconditional abnormal program termination with a message.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Ipv4InterfaceContainer i2i3
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. ...
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.
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.
Ipv4InterfaceContainer i3i5
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.
void CheckQueueSize(Ptr< QueueDisc > queue)
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.
Hold an unsigned integer type.
uint32_t qLimDrop
Drops due to queue limits.
holds a vector of ns3::NetDevice pointers
Ipv4InterfaceContainer i3i4
Ipv4InterfaceContainer i0i2
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.
std::stringstream filePlotQueue
std::stringstream filePlotQueueAvg
void SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
Use number of packets for maximum queue size.
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.
Ipv4InterfaceContainer i1i2
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)
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 test(void)
Example use of ns3::SystemThread.
void SetAttribute(std::string name, const AttributeValue &value)
Helper function used to set the underlying application attributes.
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