A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
realtime-fd2fd-onoff.cc
Go to the documentation of this file.
1/*
2 * Copyright (c) 2012 University of Washington, 2012 INRIA
3 *
4 * SPDX-License-Identifier: GPL-2.0-only
5 *
6 * Author: Alina Quereilhac <alina.quereilhac@inria.fr>
7 *
8 */
9
10//
11// node 0 node 1
12// +----------------+ +----------------+
13// | ns-3 TCP | | ns-3 TCP |
14// +----------------+ +----------------+
15// | 10.1.1.1 | | 10.1.1.2 |
16// +----------------+ socketpair +----------------+
17// | fd-net-device |--------------| fd-net-device |
18// +----------------+ +----------------+
19//
20// This example is aimed at measuring the throughput of the FdNetDevice
21// in a pure simulation. For this purpose two FdNetDevices, attached to
22// different nodes but in a same simulation, are connected using a socket pair.
23// TCP traffic is sent at a saturating data rate. Then the throughput can
24// be obtained from the generated .pcap files.
25//
26// Steps to run the experiment:
27//
28// $ ./ns3 run "fd2fd-onoff"
29//
30
31#include "ns3/applications-module.h"
32#include "ns3/core-module.h"
33#include "ns3/fd-net-device-module.h"
34#include "ns3/internet-module.h"
35#include "ns3/network-module.h"
36
37#include <errno.h>
38#include <sys/socket.h>
39
40using namespace ns3;
41
42NS_LOG_COMPONENT_DEFINE("RealtimeFdNetDeviceSaturationExample");
43
44int
45main(int argc, char* argv[])
46{
47 CommandLine cmd(__FILE__);
48 cmd.Parse(argc, argv);
49
50 uint16_t sinkPort = 8000;
51 uint32_t packetSize = 10000; // bytes
52 std::string dataRate("1000Mb/s");
53
54 GlobalValue::Bind("SimulatorImplementationType", StringValue("ns3::RealtimeSimulatorImpl"));
55 GlobalValue::Bind("ChecksumEnabled", BooleanValue(true));
56
57 NS_LOG_INFO("Create Node");
59 nodes.Create(2);
60
61 NS_LOG_INFO("Create Device");
64
65 int sv[2];
66 if (socketpair(AF_UNIX, SOCK_DGRAM, 0, sv) < 0)
67 {
68 NS_FATAL_ERROR("Error creating pipe=" << strerror(errno));
69 }
70
71 Ptr<NetDevice> d1 = devices.Get(0);
72 Ptr<FdNetDevice> clientDevice = d1->GetObject<FdNetDevice>();
73 clientDevice->SetFileDescriptor(sv[0]);
74
75 Ptr<NetDevice> d2 = devices.Get(1);
76 Ptr<FdNetDevice> serverDevice = d2->GetObject<FdNetDevice>();
77 serverDevice->SetFileDescriptor(sv[1]);
78
79 NS_LOG_INFO("Add Internet Stack");
80 InternetStackHelper internetStackHelper;
81 internetStackHelper.SetIpv4StackInstall(true);
82 internetStackHelper.Install(nodes);
83
84 NS_LOG_INFO("Create IPv4 Interface");
85 Ipv4AddressHelper addresses;
86 addresses.SetBase("10.0.0.0", "255.255.255.0");
87 Ipv4InterfaceContainer interfaces = addresses.Assign(devices);
88
89 Ptr<Node> clientNode = nodes.Get(0);
90 Ipv4Address serverIp = interfaces.GetAddress(1);
91 Ptr<Node> serverNode = nodes.Get(1);
92
93 // server
94 Address sinkLocalAddress(InetSocketAddress(serverIp, sinkPort));
95 PacketSinkHelper sinkHelper("ns3::TcpSocketFactory", sinkLocalAddress);
96 ApplicationContainer sinkApp = sinkHelper.Install(serverNode);
97 sinkApp.Start(Seconds(0.0));
98 sinkApp.Stop(Seconds(40.0));
99 fd.EnablePcap("rt-fd2fd-onoff-server", serverDevice);
100
101 // client
102 AddressValue serverAddress(InetSocketAddress(serverIp, sinkPort));
103 OnOffHelper onoff("ns3::TcpSocketFactory", Address());
104 onoff.SetAttribute("Remote", serverAddress);
105 onoff.SetAttribute("OnTime", StringValue("ns3::ConstantRandomVariable[Constant=1]"));
106 onoff.SetAttribute("OffTime", StringValue("ns3::ConstantRandomVariable[Constant=0]"));
107 onoff.SetAttribute("DataRate", DataRateValue(dataRate));
108 onoff.SetAttribute("PacketSize", UintegerValue(packetSize));
109 ApplicationContainer clientApps = onoff.Install(clientNode);
110 clientApps.Start(Seconds(1.0));
111 clientApps.Stop(Seconds(39.0));
112 fd.EnablePcap("rt-fd2fd-onoff-client", clientDevice);
113
117
118 return 0;
119}
a polymophic address class
Definition address.h:90
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.
Parse command-line arguments.
build a set of FdNetDevice objects Normally we eschew multiple inheritance, however,...
virtual NetDeviceContainer Install(Ptr< Node > node) const
This method creates a FdNetDevice and associates it to a node.
a NetDevice to read/write network traffic from/into a file descriptor.
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...
an Inet address class
aggregate IP/TCP/UDP functionality to existing Nodes.
void SetIpv4StackInstall(bool enable)
Enable/disable IPv4 stack install.
void Install(std::string nodeName) const
Aggregate implementations of the ns3::Ipv4, ns3::Ipv6, ns3::Udp, and ns3::Tcp classes onto the provid...
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
Ipv4 addresses are stored in host order in this class.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
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::OnOffApplication on a set of nodes.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
void EnablePcap(std::string prefix, Ptr< NetDevice > nd, bool promiscuous=false, bool explicitFilename=false)
Enable pcap output the indicated net device.
Smart pointer class similar to boost::intrusive_ptr.
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
Definition simulator.cc:131
static void Run()
Run the simulation.
Definition simulator.cc:167
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Definition simulator.cc:175
Hold variables of type string.
Definition string.h:45
Hold an unsigned integer type.
Definition uinteger.h:34
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition log.h:191
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Definition log.h:264
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition nstime.h:1308
NodeContainer nodes
clientApps
Definition first.py:53
devices
Definition first.py:31
interfaces
Definition first.py:39
Every class exported by the ns3 library is enclosed in the ns3 namespace.
static const uint32_t packetSize
Packet size generated at the AP.