70#include "ns3/applications-module.h"
71#include "ns3/core-module.h"
72#include "ns3/flow-monitor-module.h"
73#include "ns3/internet-module.h"
74#include "ns3/ipv4-global-routing-helper.h"
75#include "ns3/network-module.h"
76#include "ns3/packet-sink.h"
77#include "ns3/point-to-point-module.h"
78#include "ns3/traffic-control-module.h"
98 << std::setw(12) << newval << std::endl;
105 << std::setw(12) << newval.
GetBitRate() / 1e6 << std::endl;
112 << std::setw(12) << newval << std::endl;
119 <<
" tx " << p->GetSize() << std::endl;
126 <<
" rx " << p->GetSize() << std::endl;
143main(
int argc,
char* argv[])
148 std::string transportProtocol =
"ns3::TcpCubic";
151 DataRate bottleneckBandwidth(
"10Mbps");
153 DataRate regLinkBandwidth(4 * bottleneckBandwidth.GetBitRate());
157 bool isPacingEnabled =
true;
159 bool useQueueDisc =
true;
160 bool shouldPaceInitialWindow =
true;
169 cmd.AddValue(
"tracing",
"Flag to enable/disable Ascii and Pcap tracing",
tracing);
170 cmd.AddValue(
"maxBytes",
"Total number of bytes for application to send", maxBytes);
171 cmd.AddValue(
"isPacingEnabled",
"Flag to enable/disable pacing in TCP", isPacingEnabled);
172 cmd.AddValue(
"maxPacingRate",
"Max Pacing Rate", maxPacingRate);
173 cmd.AddValue(
"useEcn",
"Flag to enable/disable ECN", useEcn);
174 cmd.AddValue(
"useQueueDisc",
"Flag to enable/disable queue disc on bottleneck", useQueueDisc);
175 cmd.AddValue(
"shouldPaceInitialWindow",
176 "Flag to enable/disable pacing of TCP initial window",
177 shouldPaceInitialWindow);
178 cmd.AddValue(
"simulationEndTime",
"Simulation end time", simulationEndTime);
179 cmd.Parse(argc, argv);
232 ipv4.SetBase(
"10.1.1.0",
"255.255.255.0");
235 ipv4.SetBase(
"10.1.2.0",
"255.255.255.0");
238 ipv4.SetBase(
"10.1.3.0",
"255.255.255.0");
241 ipv4.SetBase(
"10.1.4.0",
"255.255.255.0");
244 ipv4.SetBase(
"10.1.5.0",
"255.255.255.0");
252 uint16_t sinkPort = 8080;
263 sinkApps4.
Stop(simulationEndTime);
265 sinkApps5.
Stop(simulationEndTime);
269 uniformRv->SetStream(0);
281 sourceApps0.
Stop(simulationEndTime);
283 sourceApps1.
Stop(simulationEndTime);
292 cwndStream.open(
"tcp-dynamic-pacing-cwnd.dat", std::ios::out);
293 cwndStream <<
"#Time(s) Congestion Window (B)" << std::endl;
298 ssThreshStream.open(
"tcp-dynamic-pacing-ssthresh.dat", std::ios::out);
299 ssThreshStream <<
"#Time(s) Slow Start threshold (B)" << std::endl;
313 monitor->CheckForLostPackets();
316 for (
auto i = stats.begin(); i != stats.end(); ++i)
320 std::cout <<
"Flow " << i->first <<
" (" << t.
sourceAddress <<
" -> "
322 std::cout <<
" Tx Packets: " << i->second.txPackets <<
"\n";
323 std::cout <<
" Tx Bytes: " << i->second.txBytes <<
"\n";
324 std::cout <<
" TxOffered: "
325 << i->second.txBytes * 8.0 / simulationEndTime.
GetSeconds() / 1000 / 1000
327 std::cout <<
" Rx Packets: " << i->second.rxPackets <<
"\n";
328 std::cout <<
" Rx Bytes: " << i->second.rxBytes <<
"\n";
329 std::cout <<
" Throughput: "
330 << i->second.rxBytes * 8.0 / simulationEndTime.
GetSeconds() / 1000 / 1000
NodeContainer n2n3
Nodecontainer n2 + n3.
NodeContainer n1n2
Nodecontainer n1 + n2.
NodeContainer n3n4
Nodecontainer n3 + n4.
NodeContainer n0n2
Nodecontainer n0 + n2.
NodeContainer n3n5
Nodecontainer n3 + n5.
a polymophic address class
holds a vector of ns3::Application pointers.
void Start(Time start) const
Start all of the Applications in this container at the start time given as a parameter.
void Stop(Time stop) const
Arrange for all of the Applications in this container to Stop() at the Time given as a parameter.
void EnableAsciiAll(std::string prefix)
Enable ascii trace output on each device (which is of the appropriate type) in the set of all nodes c...
Manage ASCII trace files for device models.
Ptr< OutputStreamWrapper > CreateFileStream(std::string filename, std::ios::openmode filemode=std::ios::out)
Create and initialize an output stream object we'll use to write the traced bits.
A helper to make it easier to instantiate an ns3::BulkSendApplication on a set of nodes.
Parse command-line arguments.
Class for representing data rates.
uint64_t GetBitRate() const
Get the underlying bitrate.
Hold variables of type enum.
Helper to enable IP flow monitoring on a set of Nodes.
Ptr< FlowClassifier > GetClassifier()
Retrieve the FlowClassifier object for IPv4 created by the Install* methods.
Ptr< FlowMonitor > InstallAll()
Enable flow monitoring on all nodes.
std::map< FlowId, FlowStats > FlowStatsContainer
Container: FlowId, FlowStats.
aggregate IP/TCP/UDP functionality to existing Nodes.
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
static Ipv4Address GetAny()
static void PopulateRoutingTables()
Build a routing database and initialize the routing tables of the nodes in the simulation.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const
holds a vector of ns3::NetDevice pointers
keep track of a set of node pointers.
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
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 ...
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.
NetDeviceContainer Install(NodeContainer c)
Smart pointer class similar to boost::intrusive_ptr.
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
static Time Now()
Return the current simulation virtual time.
static void Run()
Run the simulation.
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Data structure that records the congestion state of a connection.
Simulation virtual time values and global simulation resolution.
double GetSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
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.
static TypeId LookupByName(std::string name)
Get a TypeId by name.
Hold an unsigned integer type.
void SetDefault(std::string name, const AttributeValue &value)
void ConnectWithoutContext(std::string path, const CallbackBase &cb)
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
Time MicroSeconds(uint64_t value)
Construct a Time in the indicated unit.
Time Seconds(double value)
Construct a Time in the indicated unit.
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Callback< R, Args... > MakeCallback(R(T::*memPtr)(Args...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
Ptr< T1 > DynamicCast(const Ptr< T2 > &p)
Cast a Ptr.
Structure to classify a packet.
Ipv4Address sourceAddress
Source address.
Ipv4Address destinationAddress
Destination address.
std::ofstream packetTraceStream
static void TxTracer(Ptr< const Packet > p, Ptr< Ipv4 > ipv4, uint32_t interface)
static void RxTracer(Ptr< const Packet > p, Ptr< Ipv4 > ipv4, uint32_t interface)
std::ofstream ssThreshStream
static void CwndTracer(uint32_t oldval, uint32_t newval)
std::ofstream pacingRateStream
static void SsThreshTracer(uint32_t oldval, uint32_t newval)
static void PacingRateTracer(DataRate oldval, DataRate newval)
void ConnectSocketTraces()
bool tracing
Flag to enable/disable generation of tracing files.