40 #include "ns3/core-module.h"
41 #include "ns3/network-module.h"
42 #include "ns3/internet-module.h"
43 #include "ns3/point-to-point-module.h"
44 #include "ns3/applications-module.h"
45 #include "ns3/error-model.h"
46 #include "ns3/tcp-header.h"
47 #include "ns3/udp-header.h"
49 #include "ns3/event-id.h"
50 #include "ns3/flow-monitor-helper.h"
51 #include "ns3/ipv4-global-routing-helper.h"
76 *stream->
GetStream() << new_time <<
" " << mycurrent <<
" " << newval << std::endl;
84 *stream->
GetStream() << new_time <<
" " << newval << std::endl;
98 *stream->
GetStream() << new_time <<
" " << mycurrent <<
" " << newval << std::endl;
106 *stream->
GetStream() << new_time <<
" " << newval << std::endl;
117 if (cwnd_tr_file_name.compare(
"") == 0)
133 if (ssthresh_tr_file_name.compare(
"") == 0)
145 int main (
int argc,
char *argv[])
147 std::string transport_prot =
"TcpWestwood";
148 double error_p = 0.0;
149 std::string bandwidth =
"2Mbps";
150 std::string access_bandwidth =
"10Mbps";
151 std::string access_delay =
"45ms";
152 bool tracing =
false;
153 std::string tr_file_name =
"";
154 std::string cwnd_tr_file_name =
"";
155 std::string ssthresh_tr_file_name =
"";
156 double data_mbytes = 0;
157 uint32_t mtu_bytes = 400;
158 uint16_t num_flows = 1;
159 float duration = 100;
161 bool flow_monitor =
true;
165 cmd.
AddValue(
"transport_prot",
"Transport protocol to use: TcpTahoe, TcpReno, TcpNewReno, TcpWestwood, TcpWestwoodPlus ", transport_prot);
166 cmd.
AddValue(
"error_p",
"Packet error rate", error_p);
167 cmd.
AddValue(
"bandwidth",
"Bottleneck bandwidth", bandwidth);
168 cmd.
AddValue(
"access_bandwidth",
"Access link bandwidth", access_bandwidth);
169 cmd.
AddValue(
"delay",
"Access link delay", access_delay);
170 cmd.
AddValue(
"tracing",
"Flag to enable/disable tracing", tracing);
171 cmd.
AddValue(
"tr_name",
"Name of output trace file", tr_file_name);
172 cmd.
AddValue(
"cwnd_tr_name",
"Name of output trace file", cwnd_tr_file_name);
173 cmd.
AddValue(
"ssthresh_tr_name",
"Name of output trace file", ssthresh_tr_file_name);
174 cmd.
AddValue(
"data",
"Number of Megabytes of data to transmit", data_mbytes);
175 cmd.
AddValue(
"mtu",
"Size of IP packets to send in bytes", mtu_bytes);
176 cmd.
AddValue(
"num_flows",
"Number of flows", num_flows);
177 cmd.
AddValue(
"duration",
"Time to allow flows to run in seconds", duration);
178 cmd.
AddValue(
"run",
"Run index (for setting repeatable seeds)", run);
179 cmd.
AddValue(
"flow_monitor",
"Enable flow monitor", flow_monitor);
180 cmd.
Parse (argc, argv);
199 uint32_t tcp_adu_size = mtu_bytes - (ip_header + tcp_header);
203 float start_time = 0.1;
204 float stop_time = start_time + duration;
207 if (transport_prot.compare(
"TcpTahoe") == 0)
209 else if (transport_prot.compare(
"TcpReno") == 0)
211 else if (transport_prot.compare(
"TcpNewReno") == 0)
213 else if (transport_prot.compare(
"TcpWestwood") == 0)
218 else if (transport_prot.compare(
"TcpWestwoodPlus") == 0)
234 sources.
Create(num_flows);
257 address.
SetBase (
"10.0.0.0",
"255.255.255.0");
265 for (
int i=0; i<num_flows; i++)
268 devices = LocalLink.
Install(sources.
Get(i), gateways.
Get(0));
273 interfaces = address.
Assign (devices);
274 sink_interfaces.
Add(interfaces.
Get(1));
280 uint16_t
port = 50000;
284 for(uint16_t i=0; i<sources.
GetN(); i++)
288 if (transport_prot.compare(
"TcpTahoe") == 0
289 || transport_prot.compare(
"TcpReno") == 0
290 || transport_prot.compare(
"TcpNewReno") == 0
291 || transport_prot.compare(
"TcpWestwood") == 0
292 || transport_prot.compare(
"TcpWestwoodPlus") == 0)
301 sourceApp.
Start (Seconds (start_time*i));
302 sourceApp.
Stop (Seconds (stop_time - 3));
306 sinkApp.
Start (Seconds (start_time*i));
307 sinkApp.
Stop (Seconds (stop_time));
311 NS_LOG_DEBUG (
"Invalid transport protocol " << transport_prot <<
" specified");
321 if (tr_file_name.compare(
"") == 0)
328 ascii.open (tr_file_name.c_str());
holds a vector of ns3::Application pointers.
keep track of time values and allow control of global simulation resolution
Manage ASCII trace files for device models.
static Ipv4Address GetAny(void)
void SetStream(int64_t stream)
Specifies the stream number for this RNG stream.
std::pair< Ptr< Ipv4 >, uint32_t > Get(uint32_t i) const
A helper to make it easier to instantiate an ns3::BulkSendApplication on a set of nodes...
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. Makes all nodes in the simulation into routers.
hold variables of type string
NetDeviceContainer Install(NodeContainer c)
Callback< R > MakeBoundCallback(R(*fnPtr)(TX), ARG a1)
aggregate IP/TCP/UDP functionality to existing Nodes.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes...
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. ...
Build a set of PointToPointNetDevice objects.
static EventId Schedule(Time const &time, MEM mem_ptr, OBJ obj)
void SetDeviceAttribute(std::string name, const AttributeValue &value)
static void SetRun(uint64_t run)
Set the run number of simulation.
a polymophic address class
uint32_t GetN(void) const
Get the number of Ptr<Node> stored in this container.
double GetSeconds(void) const
ApplicationContainer Install(NodeContainer c) const
static TypeId GetTypeId(void)
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 ...
hold variables of type 'enum'
void InstallAll(void) const
Hold an unsigned integer type.
void SetRate(double rate)
holds a vector of ns3::NetDevice pointers
static TypeId GetTypeId(void)
hold objects of type ns3::TypeId
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.
#define NS_LOG_LOGIC(msg)
void EnableAsciiIpv4All(std::string prefix)
Enable ascii trace output on all Ipv4 and interface pairs existing in the set of all nodes created in...
static void Destroy(void)
static TypeId GetTypeId(void)
void SetDefault(std::string name, const AttributeValue &value)
static void OutputTrace()
keep track of a set of node pointers.
hold objects of type Ptr<T>
static void TraceSsThresh(std::string ssthresh_tr_file_name)
static TypeId GetTypeId(void)
static TypeId GetTypeId(void)
Helper to enable IPv4 flow monitoring on a set of Nodes.
static void SsThreshTracer(Ptr< OutputStreamWrapper >stream, uint32_t oldval, uint32_t newval)
void SetChannelAttribute(std::string name, const AttributeValue &value)
static void SetSeed(uint32_t seed)
set the seed it will duplicate the seed value 6 times
void SetUnit(enum ErrorUnit error_unit)
static Time FromInteger(uint64_t value, enum Unit timeUnit)
hold objects of type ns3::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...
NS_LOG_COMPONENT_DEFINE("PacketLossCounter")
int main(int argc, char *argv[])
an identifier for simulation events.
void AddValue(const std::string &name, const std::string &help, T &value)
void SerializeToXmlFile(std::string fileName, bool enableHistograms, bool enableProbes)
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
#define NS_LOG_DEBUG(msg)
void SetRandomVariable(Ptr< RandomVariableStream >)
static void CwndTracer(Ptr< OutputStreamWrapper >stream, uint32_t oldval, uint32_t newval)
Ipv4Address NewNetwork(void)
Increment the network number and reset the IP address counter to the base value provided in the SetBa...
ApplicationContainer Install(NodeContainer c) const
void Parse(int argc, char *argv[])
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.
void Add(Ipv4InterfaceContainer other)
void SetAttribute(std::string name, const AttributeValue &value)
Determine which packets are errored corresponding to an underlying distribution, rate, and unit.
bool IsExpired(void) const
static void TraceCwnd(std::string cwnd_tr_file_name)
void ConnectWithoutContext(std::string path, const CallbackBase &cb)
std::ostream * GetStream(void)
void SetAttribute(std::string name, const AttributeValue &value)
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