summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLoic Guegan <manzerberdes@gmx.com>2019-04-11 13:27:39 +0200
committerLoic Guegan <manzerberdes@gmx.com>2019-04-11 13:27:39 +0200
commitc287166ecc4d67f83cf8ae0720657db9ac5b0ad8 (patch)
tree170fcfc08bf65a981b4c3c41efb4fcbdb6244651
parent6cadbb531626d7b54a640c682013055752b15b55 (diff)
Add old end-to-end files
-rw-r--r--ns-3_wifi_tests/wifi-nodes-energy-consumption.cc334
-rw-r--r--ns-3_wifi_tests/wifi-nodes-energy-consumption2.cc377
2 files changed, 711 insertions, 0 deletions
diff --git a/ns-3_wifi_tests/wifi-nodes-energy-consumption.cc b/ns-3_wifi_tests/wifi-nodes-energy-consumption.cc
new file mode 100644
index 0000000..fe89256
--- /dev/null
+++ b/ns-3_wifi_tests/wifi-nodes-energy-consumption.cc
@@ -0,0 +1,334 @@
+/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
+/*
+ * 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
+ */
+
+#include <fstream>
+#include <iostream>
+#include <string>
+#include "ns3/core-module.h"
+#include "ns3/point-to-point-module.h"
+#include "ns3/network-module.h"
+#include "ns3/config-store-module.h"
+#include "ns3/energy-module.h"
+#include "ns3/applications-module.h"
+#include "ns3/wifi-module.h"
+#include "ns3/mobility-module.h"
+#include "ns3/internet-module.h"
+#include "ns3/ipv4-global-routing-helper.h"
+#include "ns3/flow-monitor-module.h"
+
+// Default Network Topology
+//
+// Number of wifi Sta or Edge nodes can be increased up to 250
+// |
+// Rank 0 | Rank 1
+// -------------------------|----------------------------
+// Wifi Sta 10.1.3.0
+// AP
+// * * * *
+// | | | | 10.1.1.0
+// n3 n4 n5 n0 -------------- n1 n2
+// point-to-point | |
+// * *
+// Ap
+// WiFi Edge 10.1.2.0
+
+using namespace ns3;
+
+NS_LOG_COMPONENT_DEFINE ("WifiEnergyExample");
+
+uint32_t PhyTxDropCount =0;
+uint32_t PhyRxDropCount =0;
+double offeredLoad = 0.0;
+double throughput = 0.0;
+double lastPacketTime = 0.0;
+
+//FlowMonitorHelper flowmon;
+
+/// Trace function for remaining energy at node.
+void
+RemainingEnergy (double oldValue, double remainingEnergy)
+{
+ NS_LOG_UNCOND (Simulator::Now ().GetSeconds ()
+ << "s Current remaining energy = " << remainingEnergy << "J");
+}
+
+/// Trace function for total energy consumption at node.
+void
+TotalEnergy (double oldValue, double newValue)
+{
+ NS_LOG_UNCOND (Simulator::Now ().GetSeconds ()
+ << "AIE\t"<< newValue-oldValue<<"\t"<<newValue);
+}
+
+void
+PhyTxDrop(Ptr<const Packet> p)
+{
+ NS_LOG_UNCOND(Simulator::Now ().GetSeconds ()<<" Tx Packet Drop "<<++PhyTxDropCount);
+}
+
+void
+PhyRxDrop(Ptr<const Packet> p)
+{
+ NS_LOG_UNCOND(Simulator::Now ().GetSeconds ()<<" Rx Packet Drop "<<++PhyRxDropCount);
+}
+void ThroughputMonitor (FlowMonitorHelper *fmhelper, Ptr<FlowMonitor> flowMon)
+ {
+ std::map<FlowId, FlowMonitor::FlowStats> flowStats = flowMon->GetFlowStats();
+ Ptr<Ipv4FlowClassifier> classing = DynamicCast<Ipv4FlowClassifier> (fmhelper->GetClassifier());
+ for (std::map<FlowId, FlowMonitor::FlowStats>::const_iterator stats = flowStats.begin (); stats != flowStats.end (); ++stats)
+ {
+ Ipv4FlowClassifier::FiveTuple fiveTuple = classing->FindFlow (stats->first);
+ std::cout<<"---------------------------------------------------------------------------"<<std::endl;
+ std::cout<<"Flow ID : " << stats->first <<" ; "<< fiveTuple.sourceAddress <<" -----> "<<fiveTuple.destinationAddress<<std::endl;
+ std::cout<<"Tx Packets = " << stats->second.txPackets<<std::endl;
+ std::cout<<"Rx Packets = " << stats->second.rxPackets<<std::endl;
+ std::cout<<"Duration : "<<stats->second.timeLastRxPacket.GetSeconds()-stats->second.timeFirstTxPacket.GetSeconds()<<std::endl;
+ std::cout<<"Last Received Packet : "<< stats->second.timeLastRxPacket.GetSeconds()<<" Seconds"<<std::endl;
+ std::cout<<"Throughput: " << stats->second.rxBytes * 8.0 / (stats->second.timeLastRxPacket.GetSeconds()-stats->second.timeFirstTxPacket.GetSeconds())/1024/1024 << " Mbps"<<std::endl;
+ std::cout<<"---------------------------------------------------------------------------"<<std::endl;
+ }
+ Simulator::Schedule(Seconds(0.1),&ThroughputMonitor, fmhelper, flowMon);
+
+ }
+
+int
+main (int argc, char *argv[])
+{
+ bool verbose = true;
+ uint32_t nWifiEdge = 1;
+ bool tracing = false;
+ double interval = 0.01; // ms
+ uint32_t maxPackets = 100000;
+ double simulationTime = 2.1;
+
+ CommandLine cmd;
+ cmd.AddValue ("nWifiEdge", "Number of wifi edge nodes/devices", nWifiEdge);
+ cmd.AddValue ("verbose", "Tell echo applications to log if true", verbose);
+ cmd.AddValue ("tracing", "Enable pcap tracing", tracing);
+ cmd.AddValue ("interval", "Interval between packets", interval);
+ cmd.AddValue ("maxPackets", "Maximum number of packets", maxPackets);
+
+
+ cmd.Parse (argc,argv);
+
+ // turn off RTS/CTS for frames below 2200 bytes
+ //Config::SetDefault ("ns3::WifiRemoteStationManager::RtsCtsThreshold", StringValue ("2200"));
+
+ NodeContainer edgeApNode;
+ edgeApNode.Create (1);
+ NodeContainer wifiEdgeNodes;
+ wifiEdgeNodes.Create (nWifiEdge);
+
+ YansWifiChannelHelper channel = YansWifiChannelHelper::Default ();
+ YansWifiPhyHelper phyEdge = YansWifiPhyHelper::Default ();
+ phyEdge.SetChannel (channel.Create ());
+ phyEdge.Set ("TxAntennas", UintegerValue (4));
+ phyEdge.Set ("RxAntennas", UintegerValue (4));
+
+
+ WifiHelper wifi;
+ wifi.SetStandard (WIFI_PHY_STANDARD_80211n_5GHZ);
+ wifi.SetRemoteStationManager ("ns3::ConstantRateWifiManager","DataMode", StringValue("HtMcs31"),"ControlMode",StringValue("HtMcs31"));
+
+
+
+ WifiMacHelper macEdge;
+ Ssid ssid = Ssid ("ns-3-ssid-edge");
+ macEdge.SetType ("ns3::StaWifiMac",
+ "Ssid", SsidValue (ssid),
+ "ActiveProbing", BooleanValue (false));
+
+ NetDeviceContainer edgeDevices;
+ edgeDevices = wifi.Install (phyEdge, macEdge, wifiEdgeNodes);
+
+ macEdge.SetType ("ns3::ApWifiMac",
+ "Ssid", SsidValue (ssid));
+
+ NetDeviceContainer edgeApDevices;
+ edgeApDevices = wifi.Install (phyEdge, macEdge, edgeApNode);
+
+ MobilityHelper mobility;
+
+ mobility.SetPositionAllocator ("ns3::GridPositionAllocator",
+ "MinX", DoubleValue (0.0),
+ "MinY", DoubleValue (0.0),
+ "DeltaX", DoubleValue (0.5),
+ "DeltaY", DoubleValue (0.5),
+ "GridWidth", UintegerValue (3),
+ "LayoutType", StringValue ("RowFirst"));
+
+ mobility.SetMobilityModel ("ns3::RandomWalk2dMobilityModel",
+ "Bounds", RectangleValue (Rectangle (-50, 50, -50, 50)));
+
+ mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel");
+ mobility.Install (edgeApNode);
+ mobility.Install (wifiEdgeNodes);
+
+ InternetStackHelper stack;
+ stack.Install (edgeApNode);
+ stack.Install (wifiEdgeNodes);
+
+ Ipv4AddressHelper address;
+
+ address.SetBase ("10.1.2.0", "255.255.255.0");
+ Ipv4InterfaceContainer edgeInterfaces;
+ Ipv4InterfaceContainer edgeApInterfaces;
+ edgeInterfaces = address.Assign (edgeDevices);
+ edgeApInterfaces = address.Assign(edgeApDevices);
+
+
+ /** Energy Model **/
+ /***************************************************************************/
+ /* energy source */
+ BasicEnergySourceHelper edgeBasicSourceHelper;
+ // configure energy source
+
+ edgeBasicSourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (2.9009));
+ edgeBasicSourceHelper.Set ("BasicEnergySupplyVoltageV", DoubleValue (3.3));
+ // install source
+ EnergySourceContainer wifiEdgeNodesSources = edgeBasicSourceHelper.Install (wifiEdgeNodes);
+ EnergySourceContainer apEdgeNodesSources = edgeBasicSourceHelper.Install (edgeApNode);
+
+ /* device energy model */
+ WifiRadioEnergyModelHelper radioEnergyHelper;
+ // configure radio energy model
+ radioEnergyHelper.Set ("TxCurrentA", DoubleValue (0.38));
+ radioEnergyHelper.Set ("RxCurrentA", DoubleValue (0.313));
+ radioEnergyHelper.Set ("IdleCurrentA", DoubleValue (0.273));
+ // install device model
+ DeviceEnergyModelContainer edgeDeviceModels = radioEnergyHelper.Install (edgeDevices, wifiEdgeNodesSources);
+ DeviceEnergyModelContainer edgeApDeviceModels = radioEnergyHelper.Install (edgeApDevices, apEdgeNodesSources);
+
+ /***************************************************************************/
+ //Setting applications
+ UdpServerHelper myServer (9);
+
+ ApplicationContainer serverApps = myServer.Install (edgeApNode.Get (0));
+ serverApps.Start (Seconds (0));
+ serverApps.Stop (Seconds (simulationTime));
+
+ //UdpEchoClientHelper client (serverAddress, port);
+ UdpClientHelper myClient (edgeApInterfaces.GetAddress (0), 9);
+ myClient.SetAttribute ("MaxPackets", UintegerValue (maxPackets));
+ myClient.SetAttribute ("Interval", TimeValue (Seconds ((interval/1000.0))));
+ myClient.SetAttribute ("PacketSize", UintegerValue (1472)); // in Bytes
+
+ ApplicationContainer clientApps = myClient.Install (wifiEdgeNodes.Get (0));
+ clientApps.Start (Seconds (1.0));
+ clientApps.Stop (Seconds (simulationTime));
+
+ Ipv4GlobalRoutingHelper::PopulateRoutingTables ();
+
+ /** connect trace sources **/
+ /***************************************************************************/
+ // all sources are connected to node 1
+ // energy source
+
+ Ptr<BasicEnergySource> basicSourcePtr0 = DynamicCast<BasicEnergySource> (wifiEdgeNodesSources.Get (0));
+
+ basicSourcePtr0->TraceConnectWithoutContext ("RemainingEnergy", MakeCallback (&RemainingEnergy));
+ //device energy model
+
+ Ptr<DeviceEnergyModel> basicRadioModelPtr0 =
+ basicSourcePtr0->FindDeviceEnergyModels ("ns3::WifiRadioEnergyModel").Get (0);
+
+ NS_ASSERT (basicRadioModelPtr0 != NULL);
+ basicRadioModelPtr0->TraceConnectWithoutContext ("TotalEnergyConsumption", MakeCallback (&TotalEnergy));
+
+
+ if (tracing == true)
+ {
+ //AsciiTraceHelper ascii;
+ //pointToPoint.EnableAsciiAll(ascii.CreateFileStream ("energy-wifi.tr"));
+ //pointToPoint.EnablePcapAll ("wifiEnergy");
+ // phySta.EnablePcapAll ("wifiEnergy");
+ phyEdge.EnablePcapAll ("wifiEnergy");
+
+ }
+
+ //Set simulation time and launch simulation
+ Config::ConnectWithoutContext("/NodeList/*/DeviceList/*/$ns3::WifiNetDevice/Phy/PhyRxDrop", MakeCallback(&PhyRxDrop));
+ Config::ConnectWithoutContext("/NodeList/*/DeviceList/*/$ns3::WifiNetDevice/Phy/PhyTxDrop", MakeCallback(&PhyTxDrop));
+
+
+// edgeDevices.Get(0)->TraceConnectWithoutContext("PhyTxDrop",MakeCallback(&PhyTxDrop));
+
+
+///
+// FlowMonitor
+///
+ FlowMonitorHelper fmHelper;
+ Ptr<FlowMonitor> allMon = fmHelper.InstallAll();
+ Simulator::Schedule(Seconds(1),&ThroughputMonitor,&fmHelper, allMon);
+
+
+ FlowMonitorHelper flowmon;
+ Ptr<FlowMonitor> monitor = flowmon.InstallAll();
+ Ptr<Ipv4FlowClassifier> classifier = DynamicCast<Ipv4FlowClassifier> (flowmon.GetClassifier ());
+
+ Simulator::Stop (Seconds (simulationTime));
+ Simulator::Run ();
+
+ std::map<FlowId, FlowMonitor::FlowStats> stats = monitor->GetFlowStats ();
+
+ double totalThroughput = 0.0;
+ double totalLostPackets = 0.0;
+ for (std::map< FlowId, FlowMonitor::FlowStats>::iterator flow=stats.begin(); flow!=stats.end(); flow++)
+ {
+ Ipv4FlowClassifier::FiveTuple t = classifier->FindFlow(flow->first);
+ NS_LOG_UNCOND( "\nFlowID: " << flow->first << " ("
+ << t.sourceAddress << " / " << t.sourcePort << " --> "
+ << t.destinationAddress << " / " << t.destinationPort << ")" );
+ NS_LOG_UNCOND( " Tx Packets: " << flow->second.txPackets );
+ NS_LOG_UNCOND( " Tx Bytes: " << flow->second.txBytes );
+
+ offeredLoad = flow->second.txBytes * 8.0 / (flow->second.timeLastTxPacket.GetSeconds () - flow->second.timeFirstTxPacket.GetSeconds ()) / 1000000 ;
+ NS_LOG_UNCOND( " Offered Load: " << offeredLoad << " Mbps");
+
+ NS_LOG_UNCOND( " Rx Packets: " << flow->second.rxPackets );
+ NS_LOG_UNCOND( " Rx Bytes: " << flow->second.rxBytes );
+
+ throughput = flow->second.rxBytes * 8.0 / (flow->second.timeLastRxPacket.GetSeconds () - flow->second.timeFirstRxPacket.GetSeconds ()) / 1000000;
+ NS_LOG_UNCOND( " Throughput: " << throughput << " Mbps");
+
+ NS_LOG_UNCOND( " Lost Packets: " << flow->second.lostPackets );
+ NS_LOG_UNCOND( " Time last packet Transmited: " << flow->second.timeLastTxPacket.GetSeconds() );
+ NS_LOG_UNCOND( " Time last packet Received: " << flow->second.timeLastRxPacket.GetSeconds() );
+
+ if(t.destinationPort == 9){
+
+ totalThroughput = totalThroughput + throughput;
+ totalLostPackets = totalLostPackets + flow->second.lostPackets;
+
+ }
+ if(t.destinationPort == 9 && (lastPacketTime < flow->second.timeLastRxPacket.GetSeconds ())){
+
+ lastPacketTime = flow->second.timeLastRxPacket.GetSeconds ();
+ }
+
+}
+ double averageThroughput = totalThroughput/nWifiEdge;
+ double averageLostPackets = totalLostPackets/nWifiEdge;
+
+ NS_LOG_UNCOND( "\nLast Packet Time: " << lastPacketTime);
+ NS_LOG_UNCOND( "Average Throughput: " << averageThroughput << " Mbps");
+ NS_LOG_UNCOND( "Average Lost Packet : " << averageLostPackets);
+
+
+ Simulator::Destroy ();
+
+ return 0;
+}
diff --git a/ns-3_wifi_tests/wifi-nodes-energy-consumption2.cc b/ns-3_wifi_tests/wifi-nodes-energy-consumption2.cc
new file mode 100644
index 0000000..e778e11
--- /dev/null
+++ b/ns-3_wifi_tests/wifi-nodes-energy-consumption2.cc
@@ -0,0 +1,377 @@
+/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
+/*
+ * 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
+ */
+
+#include <fstream>
+#include <iostream>
+#include <string>
+#include "ns3/core-module.h"
+#include "ns3/point-to-point-module.h"
+#include "ns3/network-module.h"
+#include "ns3/config-store-module.h"
+#include "ns3/energy-module.h"
+#include "ns3/applications-module.h"
+#include "ns3/wifi-module.h"
+#include "ns3/mobility-module.h"
+#include "ns3/internet-module.h"
+#include "ns3/ipv4-global-routing-helper.h"
+#include "ns3/flow-monitor-module.h"
+
+// Default Network Topology
+//
+// Number of wifi Sta or Edge nodes can be increased up to 250
+// |
+// Rank 0 | Rank 1
+// -------------------------|----------------------------
+// Wifi Sta 10.1.3.0
+// AP
+// * * * *
+// | | | | 10.1.1.0
+// n3 n4 n5 n0 -------------- n1 n2
+// point-to-point | |
+// * *
+// Ap
+// WiFi Edge 10.1.2.0
+
+using namespace ns3;
+
+NS_LOG_COMPONENT_DEFINE ("WifiEnergyExample");
+
+uint32_t PhyTxDropCount =0;
+uint32_t PhyRxDropCount =0;
+double offeredLoad = 0.0;
+double throughput = 0.0;
+double lastPacketTime = 0.0;
+
+//FlowMonitorHelper flowmon;
+
+/// Trace function for remaining energy at node.
+void
+RemainingEnergy (double oldValue, double remainingEnergy)
+{
+ NS_LOG_UNCOND (Simulator::Now ().GetSeconds ()
+ << "s Current remaining energy = " << remainingEnergy << "J");
+}
+
+/// Trace function for total energy consumption at node.
+void
+TotalEnergy (double oldValue, double newValue)
+{
+ NS_LOG_UNCOND (Simulator::Now ().GetSeconds ()
+ << "\t"<< newValue-oldValue<<"\t"<<newValue);
+}
+
+void
+PhyTxDrop(Ptr<const Packet> p)
+{
+ NS_LOG_UNCOND(Simulator::Now ().GetSeconds ()<<" Tx Packet Drop "<<++PhyTxDropCount);
+}
+
+void
+PhyRxDrop(Ptr<const Packet> p)
+{
+ NS_LOG_UNCOND(Simulator::Now ().GetSeconds ()<<" Rx Packet Drop "<<++PhyRxDropCount);
+}
+int
+main (int argc, char *argv[])
+{
+ bool verbose = false;
+ uint32_t nWifiSta = 1;
+ uint32_t nWifiEdge = 1;
+ bool tracing = false;
+ double interval = 1.0;
+ uint32_t maxPackets = 10;
+ double simulationTime = 20.0;
+
+ CommandLine cmd;
+ cmd.AddValue ("nWifiEdge", "Number of wifi edge nodes/devices", nWifiEdge);
+ cmd.AddValue ("nWifiSta", "Number of wifi STA devices", nWifiSta);
+ cmd.AddValue ("verbose", "Tell echo applications to log if true", verbose);
+ cmd.AddValue ("tracing", "Enable pcap tracing", tracing);
+ cmd.AddValue ("interval", "Interval between packets", interval);
+ cmd.AddValue ("maxPackets", "Maximum number of packets", maxPackets);
+
+
+ cmd.Parse (argc,argv);
+
+ // Check for valid number of csma or wifi nodes
+ // 250 should be enough, otherwise IP addresses
+ // soon become an issue
+ if (nWifiEdge > 250 || nWifiSta > 250)
+ {
+ std::cout << "Too many wifi station/edge nodes, no more than 250 each." << std::endl;
+ return 1;
+ }
+
+ if (verbose)
+ {
+ LogComponentEnable ("UdpEchoClientApplication", LOG_LEVEL_INFO);
+ LogComponentEnable ("UdpEchoServerApplication", LOG_LEVEL_INFO);
+ //LogComponentEnable("YansWifiPhy",LOG_LEVEL_INFO);
+ }
+
+ NodeContainer p2pNodes;
+ p2pNodes.Create (2);
+
+ PointToPointHelper pointToPoint;
+ pointToPoint.SetDeviceAttribute ("DataRate", StringValue ("250Mbps"));
+ pointToPoint.SetChannelAttribute ("Delay", StringValue ("1ns"));
+
+ NetDeviceContainer p2pDevices;
+ p2pDevices = pointToPoint.Install (p2pNodes);
+
+ NodeContainer wifiStaNodes;
+ wifiStaNodes.Create (nWifiSta);
+ NodeContainer staApNode = p2pNodes.Get (0);
+
+ NodeContainer wifiEdgeNodes;
+ wifiEdgeNodes.Create (nWifiEdge);
+ NodeContainer edgeApNode = p2pNodes.Get (1);
+
+ YansWifiChannelHelper channel = YansWifiChannelHelper::Default ();
+ YansWifiPhyHelper phySta = YansWifiPhyHelper::Default ();
+ phySta.SetChannel (channel.Create ());
+ phySta.Set ("TxAntennas", UintegerValue (4));
+ phySta.Set ("RxAntennas", UintegerValue (4));
+
+ YansWifiPhyHelper phyEdge = YansWifiPhyHelper::Default ();
+ phyEdge.SetChannel (channel.Create ());
+ phyEdge.Set ("TxAntennas", UintegerValue (4));
+ phyEdge.Set ("RxAntennas", UintegerValue (4));
+
+
+ WifiHelper wifi;
+ wifi.SetStandard (WIFI_PHY_STANDARD_80211n_5GHZ);
+ wifi.SetRemoteStationManager ("ns3::ConstantRateWifiManager","DataMode", StringValue("HtMcs31"),"ControlMode",StringValue("HtMcs31"));
+
+ WifiMacHelper macSta;
+ Ssid ssid = Ssid ("ns-3-ssid-sta");
+ macSta.SetType ("ns3::StaWifiMac",
+ "Ssid", SsidValue (ssid),
+ "ActiveProbing", BooleanValue (false));
+
+ NetDeviceContainer staDevices;
+ staDevices = wifi.Install (phySta, macSta, wifiStaNodes);
+
+ macSta.SetType ("ns3::ApWifiMac",
+ "Ssid", SsidValue (ssid));
+
+ NetDeviceContainer staApDevices;
+ staApDevices = wifi.Install (phySta, macSta, staApNode);
+
+ WifiMacHelper macEdge;
+ ssid = Ssid ("ns-3-ssid-edge");
+ macEdge.SetType ("ns3::StaWifiMac",
+ "Ssid", SsidValue (ssid),
+ "ActiveProbing", BooleanValue (false));
+
+ NetDeviceContainer edgeDevices;
+ edgeDevices = wifi.Install (phyEdge, macEdge, wifiEdgeNodes);
+
+ macEdge.SetType ("ns3::ApWifiMac",
+ "Ssid", SsidValue (ssid));
+
+ NetDeviceContainer edgeApDevices;
+ edgeApDevices = wifi.Install (phyEdge, macEdge, edgeApNode);
+
+ MobilityHelper mobility;
+
+ mobility.SetPositionAllocator ("ns3::GridPositionAllocator",
+ "MinX", DoubleValue (0.0),
+ "MinY", DoubleValue (0.0),
+ "DeltaX", DoubleValue (0.5),
+ "DeltaY", DoubleValue (0.5),
+ "GridWidth", UintegerValue (3),
+ "LayoutType", StringValue ("RowFirst"));
+
+ mobility.SetMobilityModel ("ns3::RandomWalk2dMobilityModel",
+ "Bounds", RectangleValue (Rectangle (-50, 50, -50, 50)));
+ mobility.Install (wifiStaNodes);
+
+ mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel");
+ mobility.Install (staApNode);
+ mobility.Install (edgeApNode);
+ mobility.Install (wifiEdgeNodes);
+
+ InternetStackHelper stack;
+ stack.Install (staApNode);
+ stack.Install (edgeApNode);
+ stack.Install (wifiStaNodes);
+ stack.Install (wifiEdgeNodes);
+
+ Ipv4AddressHelper address;
+
+ address.SetBase ("10.1.1.0", "255.255.255.0");
+ Ipv4InterfaceContainer p2pInterfaces;
+ p2pInterfaces = address.Assign (p2pDevices);
+
+ address.SetBase ("10.1.2.0", "255.255.255.0");
+ Ipv4InterfaceContainer edgeInterfaces;
+ edgeInterfaces = address.Assign (edgeDevices);
+ address.Assign(edgeApDevices);
+
+ address.SetBase ("10.1.3.0", "255.255.255.0");
+ address.Assign (staDevices);
+ address.Assign (staApDevices);
+
+ /** Energy Model **/
+ /***************************************************************************/
+ /* energy source */
+ BasicEnergySourceHelper staBasicSourceHelper;
+ BasicEnergySourceHelper edgeBasicSourceHelper;
+ // configure energy source
+
+ staBasicSourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (100));
+ edgeBasicSourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (100));
+// edgeBasicSourceHelper.Set ("BasicEnergySupplyVoltageV", DoubleValue (220));
+ // install source
+ EnergySourceContainer wifiStaNodesSources = staBasicSourceHelper.Install (wifiStaNodes);
+ EnergySourceContainer wifiEdgeNodesSources = edgeBasicSourceHelper.Install (wifiEdgeNodes);
+
+ /* device energy model */
+ WifiRadioEnergyModelHelper radioEnergyHelper;
+ // configure radio energy model
+/*
+ radioEnergyHelper.Set ("TxCurrentA", DoubleValue (0.0857));
+ radioEnergyHelper.Set ("RxCurrentA", DoubleValue (0.0528));
+ radioEnergyHelper.Set ("IdleCurrentA", DoubleValue (0.0188));
+*/
+ // install device model
+ DeviceEnergyModelContainer staDeviceModels = radioEnergyHelper.Install (staDevices, wifiStaNodesSources);
+ DeviceEnergyModelContainer edgeDeviceModels = radioEnergyHelper.Install (edgeDevices, wifiEdgeNodesSources);
+
+ /***************************************************************************/
+ UdpEchoServerHelper echoServer (9);
+
+ ApplicationContainer serverApps = echoServer.Install (wifiEdgeNodes.Get (0));
+ serverApps.Start (Seconds (0));
+ serverApps.Stop (Seconds (simulationTime));
+
+ UdpEchoClientHelper echoClient (edgeInterfaces.GetAddress (0), 9);
+ echoClient.SetAttribute ("MaxPackets", UintegerValue (maxPackets));
+ echoClient.SetAttribute ("Interval", TimeValue (Seconds ((interval/1000.0))));
+ echoClient.SetAttribute ("PacketSize", UintegerValue (1472));
+
+ ApplicationContainer clientApps =
+ echoClient.Install (wifiStaNodes);
+ clientApps.Start (Seconds (0.5));
+ clientApps.Stop (Seconds (simulationTime));
+
+ Ipv4GlobalRoutingHelper::PopulateRoutingTables ();
+
+ /** connect trace sources **/
+ /***************************************************************************/
+ // all sources are connected to node 1
+ // energy source
+
+ Ptr<BasicEnergySource> basicSourcePtr0 = DynamicCast<BasicEnergySource> (wifiEdgeNodesSources.Get (0));
+
+ //basicSourcePtr0->TraceConnectWithoutContext ("RemainingEnergy", MakeCallback (&RemainingEnergy));
+ //device energy model
+
+ Ptr<DeviceEnergyModel> basicRadioModelPtr0 =
+ basicSourcePtr0->FindDeviceEnergyModels ("ns3::WifiRadioEnergyModel").Get (0);
+
+ NS_ASSERT (basicRadioModelPtr0 != NULL);
+ basicRadioModelPtr0->TraceConnectWithoutContext ("TotalEnergyConsumption", MakeCallback (&TotalEnergy));
+
+/*
+
+ Ptr<BasicEnergySource> basicSourcePtr1 = DynamicCast<BasicEnergySource> (wifiStaNodesSources.Get (0));
+
+ Ptr<DeviceEnergyModel> basicRadioModelPtr1 =
+ basicSourcePtr1->FindDeviceEnergyModels ("ns3::WifiRadioEnergyModel").Get (0);
+
+ NS_ASSERT (basicRadioModelPtr1 != NULL);
+ basicRadioModelPtr1->TraceConnectWithoutContext ("TotalEnergyConsumption", MakeCallback (&TotalEnergy));
+*/
+
+
+
+ if (tracing == true)
+ {
+ //AsciiTraceHelper ascii;
+ //pointToPoint.EnableAsciiAll(ascii.CreateFileStream ("energy-wifi.tr"));
+ pointToPoint.EnablePcapAll ("wifiEnergy");
+ // phySta.EnablePcapAll ("wifiEnergy");
+ // phyEdge.EnablePcapAll ("wifiEnergy");
+
+ }
+
+ //Set simulation time and launch simulation
+ Config::ConnectWithoutContext("/NodeList/*/DeviceList/*/$ns3::WifiNetDevice/Phy/PhyRxDrop", MakeCallback(&PhyRxDrop));
+ Config::ConnectWithoutContext("/NodeList/*/DeviceList/*/$ns3::WifiNetDevice/Phy/PhyTxDrop", MakeCallback(&PhyTxDrop));
+
+
+// edgeDevices.Get(0)->TraceConnectWithoutContext("PhyTxDrop",MakeCallback(&PhyTxDrop));
+
+
+
+ FlowMonitorHelper flowmon;
+ Ptr<FlowMonitor> monitor = flowmon.InstallAll();
+ Ptr<Ipv4FlowClassifier> classifier = DynamicCast<Ipv4FlowClassifier> (flowmon.GetClassifier ());
+
+ Simulator::Stop (Seconds (simulationTime));
+ Simulator::Run ();
+
+ std::map<FlowId, FlowMonitor::FlowStats> stats = monitor->GetFlowStats ();
+
+ double totalThroughput = 0.0;
+ double totalLostPackets = 0.0;
+ for (std::map< FlowId, FlowMonitor::FlowStats>::iterator flow=stats.begin(); flow!=stats.end(); flow++)
+ {
+ Ipv4FlowClassifier::FiveTuple t = classifier->FindFlow(flow->first);
+ NS_LOG_UNCOND( "\nFlowID: " << flow->first << " ("
+ << t.sourceAddress << " / " << t.sourcePort << " --> "
+ << t.destinationAddress << " / " << t.destinationPort << ")" );
+ NS_LOG_UNCOND( " Tx Packets: " << flow->second.txPackets );
+ NS_LOG_UNCOND( " Tx Bytes: " << flow->second.txBytes );
+
+ offeredLoad = flow->second.txBytes * 8.0 / (flow->second.timeLastTxPacket.GetSeconds () - flow->second.timeFirstTxPacket.GetSeconds ()) / 1000000 ;
+ NS_LOG_UNCOND( " Offered Load: " << offeredLoad << " Mbps");
+
+ NS_LOG_UNCOND( " Rx Packets: " << flow->second.rxPackets );
+ NS_LOG_UNCOND( " Rx Bytes: " << flow->second.rxBytes );
+
+ throughput = flow->second.rxBytes * 8.0 / (flow->second.timeLastRxPacket.GetSeconds () - flow->second.timeFirstRxPacket.GetSeconds ()) / 1000000;
+ NS_LOG_UNCOND( " Throughput: " << throughput << " Mbps");
+
+ NS_LOG_UNCOND( " Lost Packets: " << flow->second.lostPackets );
+ NS_LOG_UNCOND( " Time last packet Transmited: " << flow->second.timeLastTxPacket.GetSeconds() );
+ NS_LOG_UNCOND( " Time last packet Received: " << flow->second.timeLastRxPacket.GetSeconds() );
+
+ if(t.destinationPort == 9){
+
+ totalThroughput = totalThroughput + throughput;
+ totalLostPackets = totalLostPackets + flow->second.lostPackets;
+
+ }
+ if(t.destinationPort == 9 && (lastPacketTime < flow->second.timeLastRxPacket.GetSeconds ())){
+
+ lastPacketTime = flow->second.timeLastRxPacket.GetSeconds ();
+ }
+
+}
+ double averageThroughput = totalThroughput/nWifiSta;
+ double averageLostPackets = totalLostPackets/nWifiSta;
+
+ NS_LOG_UNCOND( "\nLast Packet Time: " << lastPacketTime);
+ NS_LOG_UNCOND( "Average Throughput: " << averageThroughput << " Mbps");
+ NS_LOG_UNCOND( "Average Lost Packet : " << averageLostPackets);
+
+ Simulator::Destroy ();
+
+ return 0;
+}