-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathpingmessage.cc
127 lines (101 loc) · 4.23 KB
/
pingmessage.cc
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
/* Simulate a transmission of ping message over a network topology consisting of 6 nodes and find the number of packets dropped due to congestion. */
// Network topology
//
// n0 n1 n2 n3 n4 n5
// | | | | | |
// =====================================
//
// node n0,n1,n3,n4,n5 pings to node n2
// node n0 generates protocol 2 (IGMP) to node n3
#include <iostream>
#include <fstream>
#include <string>
#include <cassert>
#include "ns3/core-module.h"
#include "ns3/network-module.h"
#include "ns3/csma-module.h"
#include "ns3/applications-module.h"
#include "ns3/internet-apps-module.h"
#include "ns3/internet-module.h"
#include "ns3/flow-monitor-module.h"
//#include "ns3/netanim-module.h"
using namespace ns3;
NS_LOG_COMPONENT_DEFINE ("CsmaPingExample");
int
main (int argc, char *argv[])
{
CommandLine cmd;
cmd.Parse (argc, argv);
Time interPacketInterval = Seconds (1.);
// Here, we will explicitly create four nodes.
NS_LOG_UNCOND ("Create nodes.");
NodeContainer c;
c.Create (6);
// connect all our nodes to a shared channel.
NS_LOG_UNCOND ("Build Topology.");
CsmaHelper csma;
csma.SetChannelAttribute ("DataRate", DataRateValue (DataRate (5000000)));
csma.SetChannelAttribute ("Delay", TimeValue (MilliSeconds (2)));
csma.SetDeviceAttribute ("EncapsulationMode", StringValue ("Llc"));
NetDeviceContainer devs = csma.Install (c);
// add an ip stack to all nodes.
NS_LOG_UNCOND ("Add ip stack.");
InternetStackHelper ipStack;
ipStack.Install (c);
// assign ip addresses
NS_LOG_UNCOND ("Assign ip addresses.");
Ipv4AddressHelper ip;
ip.SetBase ("192.168.1.0", "255.255.255.0");
Ipv4InterfaceContainer addresses = ip.Assign (devs);
NS_LOG_UNCOND ("Create Source");
InetSocketAddress dst = InetSocketAddress (addresses.GetAddress (3));
OnOffHelper onoff = OnOffHelper ("ns3::UdpSocketFactory", dst);
onoff.SetAttribute ("OnTime", StringValue ("ns3::ConstantRandomVariable[Constant=1]"));
onoff.SetAttribute ("OffTime", StringValue ("ns3::ConstantRandomVariable[Constant=0]"));
onoff.SetAttribute ("PacketSize", UintegerValue (1100));
onoff.SetAttribute ("DataRate", StringValue ("50Mbps"));
ApplicationContainer apps = onoff.Install (c.Get (0));
apps.Start (Seconds (1.0));
apps.Stop (Seconds (10.0));
NS_LOG_UNCOND ("Create Sink.");
PacketSinkHelper sink = PacketSinkHelper ("ns3::UdpSocketFactory", dst);
apps = sink.Install (c.Get (3));
apps.Start (Seconds (0.0));
apps.Stop (Seconds (11.0));
NS_LOG_UNCOND ("Create pinger");
V4PingHelper ping = V4PingHelper (addresses.GetAddress (0));
// ping.SetAttribute ("Interval", TimeValue (interPacketInterval));
ping.SetAttribute ("Interval", TimeValue (interPacketInterval));
NodeContainer pingers;
pingers.Add (c.Get (3));
pingers.Add (c.Get (1));
pingers.Add (c.Get (2));
pingers.Add (c.Get (4));
pingers.Add (c.Get (5));
apps = ping.Install (pingers);
apps.Start (Seconds (2.0));
apps.Stop (Seconds (10.0));
//Enable Tracing using flowmonitor
FlowMonitorHelper flowmon;
Ptr<FlowMonitor> monitor = flowmon.InstallAll();
Simulator::Stop (Seconds (10.0));
//Add visualization using Netanim
// AnimationInterface anim ("ex5.xml");
NS_LOG_UNCOND ("Run Simulation.");
Simulator::Run ();
// Print per flow statistics
monitor->CheckForLostPackets ();
Ptr<Ipv4FlowClassifier> classifier = DynamicCast<Ipv4FlowClassifier> (flowmon.GetClassifier ());
std::map<FlowId, FlowMonitor::FlowStats> stats = monitor->GetFlowStats ();
for (std::map<FlowId, FlowMonitor::FlowStats>::const_iterator iter = stats.begin (); iter != stats.end (); ++iter)
{
Ipv4FlowClassifier::FiveTuple t = classifier->FindFlow (iter->first);
NS_LOG_UNCOND("Flow ID: " << iter->first << " Src Addr " << t.sourceAddress << " Dst Addr " << t.destinationAddress);
NS_LOG_UNCOND("Tx Packets = " << iter->second.txPackets);
NS_LOG_UNCOND("Rx Packets = " << iter->second.rxPackets);
std::cout << "Lost Packets = " << iter->second.lostPackets<< std::endl;
NS_LOG_UNCOND("Throughput: " << iter->second.rxBytes * 8.0 / (iter->second.timeLastRxPacket.GetSeconds()-iter->second.timeFirstTxPacket.GetSeconds()) / 1024 << " Kbps");
}
Simulator::Destroy ();
NS_LOG_UNCOND ("Done.");
}