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/traffic-control-module.h"
28 #include "ns3/flow-monitor-module.h"
72 std::cout <<
"TcPacketsInQueue " << oldValue <<
" to " << newValue << std::endl;
78 std::cout <<
"DevicePacketsInQueue " << oldValue <<
" to " << newValue << std::endl;
84 std::cout <<
"Sojourn time " << newValue.
ToDouble (
Time::MS) <<
"ms" << std::endl;
88 main (
int argc,
char *argv[])
90 double simulationTime = 10;
91 std::string transportProt =
"Tcp";
92 std::string socketType;
95 cmd.
AddValue (
"transportProt",
"Transport protocol to use: Tcp, Udp", transportProt);
96 cmd.
Parse (argc, argv);
98 if (transportProt.compare (
"Tcp") == 0)
100 socketType =
"ns3::TcpSocketFactory";
104 socketType =
"ns3::UdpSocketFactory";
116 devices = pointToPoint.
Install (nodes);
136 address.
SetBase (
"10.1.1.0",
"255.255.255.0");
149 uint32_t payloadSize = 1448;
153 onoff.SetAttribute (
"OnTime",
StringValue (
"ns3::ConstantRandomVariable[Constant=1]"));
154 onoff.SetAttribute (
"OffTime",
StringValue (
"ns3::ConstantRandomVariable[Constant=0]"));
155 onoff.SetAttribute (
"PacketSize",
UintegerValue (payloadSize));
156 onoff.SetAttribute (
"DataRate",
StringValue (
"50Mbps"));
162 onoff.SetAttribute (
"Remote", remoteAddress);
163 apps.
Add (onoff.Install (nodes.
Get (1)));
174 std::map<FlowId, FlowMonitor::FlowStats> stats = monitor->
GetFlowStats ();
175 std::cout << std::endl <<
"*** Flow monitor statistics ***" << std::endl;
176 std::cout <<
" Tx Packets/Bytes: " << stats[1].txPackets
177 <<
" / " << stats[1].txBytes << std::endl;
178 std::cout <<
" Offered Load: " << stats[1].txBytes * 8.0 / (stats[1].timeLastTxPacket.GetSeconds () - stats[1].timeFirstTxPacket.GetSeconds ()) / 1000000 <<
" Mbps" << std::endl;
179 std::cout <<
" Rx Packets/Bytes: " << stats[1].rxPackets
180 <<
" / " << stats[1].rxBytes << std::endl;
181 uint32_t packetsDroppedByQueueDisc = 0;
182 uint64_t bytesDroppedByQueueDisc = 0;
188 std::cout <<
" Packets/Bytes Dropped by Queue Disc: " << packetsDroppedByQueueDisc
189 <<
" / " << bytesDroppedByQueueDisc << std::endl;
190 uint32_t packetsDroppedByNetDevice = 0;
191 uint64_t bytesDroppedByNetDevice = 0;
197 std::cout <<
" Packets/Bytes Dropped by NetDevice: " << packetsDroppedByNetDevice
198 <<
" / " << bytesDroppedByNetDevice << std::endl;
199 std::cout <<
" Throughput: " << stats[1].rxBytes * 8.0 / (stats[1].timeLastRxPacket.GetSeconds () - stats[1].timeFirstRxPacket.GetSeconds ()) / 1000000 <<
" Mbps" << std::endl;
200 std::cout <<
" Mean delay: " << stats[1].delaySum.GetSeconds () / stats[1].rxPackets << std::endl;
201 std::cout <<
" Mean jitter: " << stats[1].jitterSum.GetSeconds () / (stats[1].rxPackets - 1) << std::endl;
203 for (
auto p : dscpVec)
205 std::cout <<
" DSCP value: 0x" << std::hex << static_cast<uint32_t>(p.first) << std::dec
206 <<
" count: "<< p.second << std::endl;
211 std::cout << std::endl <<
"*** Application statistics ***" << std::endl;
213 uint32_t totalPacketsThr = DynamicCast<PacketSink> (sinkApp.
Get (0))->GetTotalRx ();
214 thr = totalPacketsThr * 8 / (simulationTime * 1000000.0);
215 std::cout <<
" Rx Bytes: " << totalPacketsThr << std::endl;
216 std::cout <<
" Average Goodput: " << thr <<
" Mbit/s" << std::endl;
217 std::cout << std::endl <<
"*** TC Layer statistics ***" << std::endl;
218 std::cout << q->
GetStats () << std::endl;
holds a vector of ns3::Application pointers.
Simulation virtual time values and global simulation resolution.
const FlowStatsContainer & GetFlowStats() const
Retrieve all collected the flow statistics.
static Ipv4Address GetAny(void)
QueueDiscContainer Install(NetDeviceContainer c)
holds a vector of std::pair of Ptr and interface index.
Hold variables of type string.
Ptr< NetDevice > Get(uint32_t i) const
Get the Ptr stored in this container at a given index.
NetDeviceContainer Install(NodeContainer c)
void Add(ApplicationContainer other)
Append the contents of another ApplicationContainer to the end of this container. ...
Ptr< Queue< Packet > > GetQueue(void) const
Get a copy of the attached Queue.
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.
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.
A helper to make it easier to instantiate an ns3::OnOffApplication on a set of nodes.
a polymophic address class
Holds a vector of ns3::QueueDisc pointers.
Ptr< QueueDisc > Get(uint32_t i) const
Get the Ptr stored in this container at a given index.
Packet dropped due to queue overflow.
Hold an unsigned integer type.
double ToDouble(enum Unit unit) const
Get the Time value expressed in a particular unit.
holds a vector of ns3::NetDevice pointers
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
void ConnectWithoutContext(std::string path, const CallbackBase &cb)
Build a set of QueueDisc objects.
const Stats & GetStats(void)
Retrieve all the collected statistics.
void SojournTimeTrace(Time oldValue, Time newValue)
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().
Ptr< FlowClassifier > GetClassifier()
Retrieve the FlowClassifier object for IPv4 created by the Install* methods.
bool TraceConnectWithoutContext(std::string name, const CallbackBase &cb)
Connect a TraceSource to a Callback without a context.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
keep track of a set of node pointers.
Ptr< Application > Get(uint32_t i) const
Get the Ptr
stored in this container at a given index.
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 TcPacketsInQueueTrace(uint32_t oldValue, uint32_t newValue)
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.
void SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
std::vector< std::pair< Ipv4Header::DscpType, uint32_t > > GetDscpCounts(FlowId flowId) const
get the DSCP values of the packets belonging to the flow with the given FlowId, sorted in decreasing ...
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 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.
Ptr< Node > Get(uint32_t i) const
Get the Ptr 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)
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.
Packet dropped by the queue disc.
void DevicePacketsInQueueTrace(uint32_t oldValue, uint32_t newValue)
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