F5/unison
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

internet-apps: Add Ping example program

Browse Source
This commit is contained in:
Chandrakant Jena
2022-12-06 13:51:29 -08:00
committed by Tommaso Pecorella
parent 37190f5db8
commit da7bc9980f
2 changed files with 275 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/internet-apps/examples/CMakeLists.txt
View File

@@ -21,3 +21,14 @@ build_lib_example(
${libwifi}
${libinternet-apps}
)
build_lib_example(
NAME ping-example
SOURCE_FILES ping-example.cc
LIBRARIES_TO_LINK
${libcore}
${libinternet}
${libinternet-apps}
${libnix-vector-routing}
${libpoint-to-point}
)

264
src/internet-apps/examples/ping-example.cc Normal file
View File

@@ -0,0 +1,264 @@
/*
* Copyright (c) 2022 Chandrakant Jena
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 2 as
* published by the Free Software Foundation;
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* Author: Chandrakant Jena <chandrakant.barcelona@gmail.com>
*/
// Example to demonstrate the working of the Ping Application
// Network topology:
// A ------------------------------ B ------------------------------ C
// 100 Mbps 100 Mbps
// 5 ms (one way) 5 ms (one way)
// IPv4 addresses:
// 10.1.1.1 <-> 10.1.1.2 / 10.1.2.1 <-> 10.1.2.2
//
// IPv6 addresses:
// 2001:1::200:ff:fe00:1
// <-> 2001:1::200:ff:fe00:2 / 2001:1:0:1:200:ff:fe00:3
// <-> 2001:1:0:1:200:ff:fe00:4
//
// The topology has three nodes interconnected by two point-to-point links.
// Each link has 5 ms one-way delay, for a round-trip propagation delay
// of 20 ms. The transmission rate on each link is 100 Mbps. The routing
// between links is enabled by ns-3's NixVector routing.
//
// By default, this program will send 5 pings from node A to node C using IPv6.
// When using IPv6, the output will look like this:
//
// PING 2001:1:0:1:200:ff:fe00:4 - 56 bytes of data; 104 bytes including ICMP and IPv6 headers.
// 64 bytes from (2001:1:0:1:200:ff:fe00:4): icmp_seq=0 ttl=63 time=20.033 ms
// 64 bytes from (2001:1:0:1:200:ff:fe00:4): icmp_seq=1 ttl=63 time=20.033 ms
// 64 bytes from (2001:1:0:1:200:ff:fe00:4): icmp_seq=2 ttl=63 time=20.033 ms
// 64 bytes from (2001:1:0:1:200:ff:fe00:4): icmp_seq=3 ttl=63 time=20.033 ms
// 64 bytes from (2001:1:0:1:200:ff:fe00:4): icmp_seq=4 ttl=63 time=20.033 ms
//
// --- 2001:1:0:1:200:ff:fe00:4 ping statistics ---
// 5 packets transmitted, 5 received, 0% packet loss, time 4020ms
// rtt min/avg/max/mdev = 20/20/20/0 ms
//
// When using IPv4, the output will look like this:
//
// PING 10.1.2.2 - 56 bytes of data; 84 bytes including ICMP and IPv4 headers.
// 64 bytes from (10.1.2.2): icmp_seq=0 ttl=63 time=20.027 ms
// 64 bytes from (10.1.2.2): icmp_seq=1 ttl=63 time=20.027 ms
// 64 bytes from (10.1.2.2): icmp_seq=2 ttl=63 time=20.027 ms
// 64 bytes from (10.1.2.2): icmp_seq=3 ttl=63 time=20.027 ms
// 64 bytes from (10.1.2.2): icmp_seq=4 ttl=63 time=20.027 ms
// --- 10.1.2.2 ping statistics ---
// 5 packets transmitted, 5 received, 0% packet loss, time 4020ms
// rtt min/avg/max/mdev = 20/20/20/0 ms
//
// The example program will also produce four pcap traces (one for each
// NetDevice in the scenario) that can be viewed using tcpdump or Wireshark.
//
// Other program options include options to change the destination and
// source addresses, number of packets (count), packet size, interval,
// and whether to enable logging (if logging is enabled in the build).
//
// The Ping application in this example starts at simulation time 1 and will
// stop either at simulation time 50 or once 'Count' pings have been responded
// to, whichever comes first.
#include "ns3/core-module.h"
#include "ns3/internet-apps-module.h"
#include "ns3/internet-module.h"
#include "ns3/network-module.h"
#include "ns3/nix-vector-routing-module.h"
#include "ns3/point-to-point-module.h"
#include <fstream>
using namespace ns3;
NS_LOG_COMPONENT_DEFINE("PingExample");
int
main(int argc, char* argv[])
{
bool logging{false};
Time interPacketInterval{Seconds(1.0)};
uint32_t size{56};
uint32_t count{5};
std::string destinationStr;
Address destination;
std::string sourceStr;
Address source;
bool useIpv6{true};
GlobalValue::Bind("ChecksumEnabled", BooleanValue(true));
CommandLine cmd(__FILE__);
cmd.AddValue("logging", "Tell application to log if true", logging);
cmd.AddValue("interval", "The time to wait between two packets", interPacketInterval);
cmd.AddValue("size", "Data bytes to be sent, per-packet", size);
cmd.AddValue("count", "Number of packets to be sent", count);
cmd.AddValue("destination",
"Destination IPv4 or IPv6 address, e.g., \"10.1.2.2\"",
destinationStr);
cmd.AddValue("source",
"Source address, needed only for multicast or broadcast destinations",
sourceStr);
cmd.Parse(argc, argv);
if (!destinationStr.empty())
{
Ipv4Address v4Dst = Ipv4Address(destinationStr.c_str());
Ipv6Address v6Dst = Ipv6Address(destinationStr.c_str());
if (v4Dst.IsInitialized())
{
useIpv6 = false;
destination = v4Dst;
}
else if (v6Dst.IsInitialized())
{
useIpv6 = true;
destination = v6Dst;
}
}
if (!sourceStr.empty())
{
Ipv4Address v4Src = Ipv4Address(sourceStr.c_str());
Ipv6Address v6Src = Ipv6Address(sourceStr.c_str());
if (v4Src.IsInitialized())
{
source = v4Src;
}
else if (v6Src.IsInitialized())
{
source = v6Src;
}
}
if (sourceStr.empty())
{
if (useIpv6)
{
Ipv6Address v6Dst = Ipv6Address(destinationStr.c_str());
if (v6Dst.IsInitialized() && v6Dst.IsMulticast())
{
std::cout << "Specify a source address to use when pinging multicast addresses"
<< std::endl;
std::cout << "Program exiting..." << std::endl;
return 0;
}
}
else
{
Ipv4Address v4Dst = Ipv4Address(destinationStr.c_str());
if (v4Dst.IsInitialized() && (v4Dst.IsBroadcast() || v4Dst.IsMulticast()))
{
std::cout << "Specify a source address to use when pinging broadcast or multicast "
"addresses"
<< std::endl;
std::cout << "Program exiting..." << std::endl;
return 0;
}
}
}
if (logging)
{
LogComponentEnableAll(LogLevel(LOG_PREFIX_TIME | LOG_PREFIX_NODE));
LogComponentEnable("Ping", LOG_LEVEL_ALL);
}
NodeContainer nodes;
nodes.Create(3);
NodeContainer link1Nodes;
link1Nodes.Add(nodes.Get(0));
link1Nodes.Add(nodes.Get(1));
NodeContainer link2Nodes;
link2Nodes.Add(nodes.Get(1));
link2Nodes.Add(nodes.Get(2));
PointToPointHelper pointToPoint;
pointToPoint.SetDeviceAttribute("DataRate", StringValue("100Mbps"));
pointToPoint.SetChannelAttribute("Delay", StringValue("5ms"));
NetDeviceContainer link1Devices;
link1Devices = pointToPoint.Install(link1Nodes);
NetDeviceContainer link2Devices;
link2Devices = pointToPoint.Install(link2Nodes);
// The following block of code inserts an optional packet loss model
Ptr<PointToPointNetDevice> p2pSender = DynamicCast<PointToPointNetDevice>(link1Devices.Get(0));
Ptr<ReceiveListErrorModel> errorModel = CreateObject<ReceiveListErrorModel>();
std::list<uint32_t> dropList;
// Enable one or more of the below lines to force specific packet losses
// dropList.push_back (0);
// dropList.push_back (1);
// dropList.push_back (2);
// dropList.push_back (3);
// dropList.push_back (4);
// etc. (other lines may be added)
errorModel->SetList(dropList);
p2pSender->SetReceiveErrorModel(errorModel);
if (!useIpv6)
{
Ipv4NixVectorHelper nixRouting;
InternetStackHelper stack;
stack.SetRoutingHelper(nixRouting);
stack.SetIpv6StackInstall(false);
stack.Install(nodes);
Ipv4AddressHelper addressV4;
addressV4.SetBase("10.1.1.0", "255.255.255.0");
addressV4.Assign(link1Devices);
addressV4.NewNetwork();
Ipv4InterfaceContainer link2InterfacesV4 = addressV4.Assign(link2Devices);
if (destination.IsInvalid())
{
destination = link2InterfacesV4.GetAddress(1, 0);
}
}
else
{
Ipv6NixVectorHelper nixRouting;
InternetStackHelper stack;
stack.SetRoutingHelper(nixRouting);
stack.SetIpv4StackInstall(false);
stack.Install(nodes);
Ipv6AddressHelper addressV6;
addressV6.SetBase("2001:1::", 64);
addressV6.Assign(link1Devices);
addressV6.NewNetwork();
Ipv6InterfaceContainer link2InterfacesV6 = addressV6.Assign(link2Devices);
if (destination.IsInvalid())
{
destination = link2InterfacesV6.GetAddress(1, 1);
}
}
// Create Ping application and installing on node A
PingHelper pingHelper(destination, source);
pingHelper.SetAttribute("Interval", TimeValue(interPacketInterval));
pingHelper.SetAttribute("Size", UintegerValue(size));
pingHelper.SetAttribute("Count", UintegerValue(count));
ApplicationContainer apps = pingHelper.Install(nodes.Get(0));
apps.Start(Seconds(1));
apps.Stop(Seconds(50));
pointToPoint.EnablePcapAll("ping-example");
Simulator::Stop(Seconds(60.0));
Simulator::Run();
Simulator::Destroy();
return 0;
}