Add fping support

model/dce.cc

@@ -295,7 +295,7 @@ int dce_gettimeofday (struct timeval *tv, struct timezone *tz)
 {
   NS_LOG_FUNCTION (Current () << UtilsGetNodeId ());
   NS_ASSERT (Current () != 0);
-  NS_ASSERT (tz == 0);
+  // NS_ASSERT (tz == 0);
   *tv = UtilsTimeToTimeval (UtilsSimulationTimeToTime (Now ()));
   return 0;
 }

myscripts/ping/dce-fping.cc

@@ -0,0 +1,207 @@
+/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
+/*
+ * Copyright (c) 2018 NITK Surathkal
+ *
+ * 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: Sourabh Jain <[email protected]>
+ *         Mohit P. Tahiliani <[email protected]>
+ */
+
+// ===============================================================================
+// Steps to download and build fping:
+//
+// git clone https://github.com/direct-code-execution/ns-3-dce.git
+// ./autogen.sh
+// CC="gcc -fpic -rdynamic -pie" ./configure
+// make
+//
+// To run successfully comment: ASSERT (tz == 0) in gettimeofday function in dce.cc
+// Though fping ask for timezone value but never uses it.
+// ================================================================================
+
+
+#include <iostream>
+#include <fstream>
+#include <string>
+#include "ns3/core-module.h"
+#include "ns3/network-module.h"
+#include "ns3/internet-module.h"
+#include "ns3/point-to-point-module.h"
+#include "ns3/applications-module.h"
+#include "ns3/flow-monitor-helper.h"
+#include "ns3/ipv4-global-routing-helper.h"
+#include "ns3/dce-module.h"
+#include "ns3/point-to-point-layout-module.h"
+
+using namespace ns3;
+
+std::string intToString (int a);
+/*
+ * Helper function to extact Ipv4 address
+ * from Ipv4Address object.
+ */
+std::string Ipv4AddressToString (Ipv4Address ip);
+
+int main (int argc, char *argv[])
+{
+  bool pcap = false;
+  int simulationTime = 30;
+  unsigned int rightCout = 2;
+  unsigned int leftCount = 3;
+  double startTime = 2.0;
+
+  CommandLine cmd;
+  cmd.AddValue ("pcap", "Enable PCAP", pcap);
+  cmd.AddValue ("time", "Simulation Duration", simulationTime);
+  cmd.Parse (argc, argv);
+
+  if (simulationTime < 5)
+    {
+      std::cout << "WARNING: " << "Simluation time sholud be greater than 5 seconds" << std::endl;
+      exit (0);
+    }
+
+  /*
+   * Bottleneck and Non-Bottleneck links configuration
+   */
+  PointToPointHelper p1, p2;
+  p1.SetDeviceAttribute ("DataRate", StringValue ("100Mbps"));
+  p1.SetChannelAttribute ("Delay", StringValue ("5ms"));
+
+  p2.SetDeviceAttribute ("DataRate", StringValue ("5Mbps"));
+  p2.SetChannelAttribute ("Delay", StringValue ("100ms"));
+  PointToPointDumbbellHelper dumbbellHelper(leftCount, p1, rightCout, p1, p2);
+
+  /*
+   * Install ns-3 stack
+   */
+  InternetStackHelper stack;
+  dumbbellHelper.InstallStack (stack);
+
+  DceManagerHelper dceManager;
+  dceManager.SetTaskManagerAttribute ("FiberManagerType", StringValue ("UcontextFiberManager"));
+
+  for (int i = 0; i < dumbbellHelper.LeftCount (); i++)
+    {
+      dceManager.Install (dumbbellHelper.GetLeft (i));
+    }
+
+  for (int i = 0; i < dumbbellHelper.RightCount (); i++)
+    {
+      dceManager.Install (dumbbellHelper.GetRight (i));
+    }
+
+  dumbbellHelper.AssignIpv4Addresses (Ipv4AddressHelper ("10.1.1.0", "255.255.255.0"),
+                                      Ipv4AddressHelper ("10.2.1.0", "255.255.255.0"),
+                                      Ipv4AddressHelper ("10.3.1.0", "255.255.255.0"));
+
+  uint16_t port = 9000;
+
+  /*
+   * Application container for
+   * source and sink apps.
+   * Install source apps over
+   * right nodes of dumbbell.
+   */
+  ApplicationContainer sourceApps, sinkApps;
+  BulkSendHelper sourceBulkSend ("ns3::TcpSocketFactory",
+                         InetSocketAddress (dumbbellHelper.GetLeftIpv4Address (1), port));
+
+  OnOffHelper sourceOnOffSend ("ns3::UdpSocketFactory", Address ());
+  sourceOnOffSend.SetAttribute ("OnTime", StringValue ("ns3::UniformRandomVariable[Min=0.|Max=1.]"));
+  sourceOnOffSend.SetAttribute ("OffTime", StringValue ("ns3::UniformRandomVariable[Min=0.|Max=1.]"));
+  AddressValue remoteAddress (InetSocketAddress (dumbbellHelper.GetLeftIpv4Address (2), port));
+  sourceOnOffSend.SetAttribute ("Remote", remoteAddress);
+
+  sourceApps.Add (sourceBulkSend.Install (dumbbellHelper.GetRight (1)));
+  sourceApps.Add (sourceOnOffSend.Install (dumbbellHelper.GetRight (1)));
+  sourceApps.Start (Seconds (startTime));
+  sourceApps.Stop (Seconds (simulationTime - 2));
+
+  /*
+   * Install sink application
+   * on left side of dumbbell. 
+   */
+  PacketSinkHelper sink ("ns3::TcpSocketFactory",
+                         InetSocketAddress (Ipv4Address::GetAny (), port));
+  sinkApps.Add (sink.Install (dumbbellHelper.GetLeft (1)));
+  sinkApps.Add (sink.Install (dumbbellHelper.GetLeft (2)));
+  sinkApps.Start (Seconds (0.0));
+  sinkApps.Stop (Seconds (simulationTime));
+
+  /*
+   * Install fping over first node
+   * on the left side of dumbbell.
+   */
+  DceApplicationHelper dce;
+  ApplicationContainer dceApps;
+  dce.SetStackSize (1 << 20);
+
+  /*
+   * Install binary and reset the old arguments
+   */
+  dce.SetBinary ("fping");
+  dce.ResetArguments ();
+  dce.ResetEnvironment ();
+  /*
+   * -D: display timestamp
+   * -C: per target statistics display
+   * -p: ping frequency (200 ms)
+   * -t: target timeout (two times of simulation time)
+   */
+  dce.AddArguments ("-n", "-D", "-C");
+  dce.AddArguments (intToString (simulationTime * 5));
+  dce.AddArguments ("-p", "200", "-t");
+  dce.AddArguments (intToString(simulationTime*2*1000));
+
+  /*
+   * extract ip and add it in fping command
+   */
+  for (int i = 0; i < dumbbellHelper.RightCount (); i++)
+    {
+      dce.AddArguments (Ipv4AddressToString(dumbbellHelper.GetRightIpv4Address(i)));
+    }
+
+  dce.AddArgument (Ipv4AddressToString(dumbbellHelper.GetLeftIpv4Address (1)));
+  dceApps = dce.Install (dumbbellHelper.GetLeft (0));
+  dceApps.Start (Seconds (startTime));
+  dceApps.Stop (Seconds (simulationTime));
+
+  Ipv4GlobalRoutingHelper::PopulateRoutingTables ();
+
+  if (pcap)
+    {
+      p1.EnablePcapAll ("fping", false);
+    }
+
+  Simulator::Stop (Seconds (simulationTime));
+  Simulator::Run ();
+  Simulator::Destroy ();
+  return 0;
+}
+
+std::string Ipv4AddressToString (Ipv4Address ip)
+{
+  std::ostringstream ipStream;
+  ip.Print (ipStream);
+  return ipStream.str();
+}
+
+std::string intToString (int val)
+{
+  std::stringstream ss;
+  ss << val;
+  return ss.str ();
+}

myscripts/ping/wscript

@@ -15,4 +15,8 @@ def build(bld):
 #				  linkflags=['-L/usr/local/lib'],
 #				  lib=['foolib']
 				  )
+    bld.build_a_script('dce', needed = ['core', 'internet', 'dce', 'point-to-point', 'netanim' ],
+          target='bin/dce-fping',
+          source=['dce-fping.cc', 'misc-tools.cc'],
+          )