From c287166ecc4d67f83cf8ae0720657db9ac5b0ad8 Mon Sep 17 00:00:00 2001 From: Loic Guegan Date: Thu, 11 Apr 2019 13:27:39 +0200 Subject: Add old end-to-end files --- ns-3_wifi_tests/wifi-nodes-energy-consumption.cc | 334 +++++++++++++++++++++++ 1 file changed, 334 insertions(+) create mode 100644 ns-3_wifi_tests/wifi-nodes-energy-consumption.cc (limited to 'ns-3_wifi_tests/wifi-nodes-energy-consumption.cc') 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 +#include +#include +#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"< p) +{ + NS_LOG_UNCOND(Simulator::Now ().GetSeconds ()<<" Tx Packet Drop "<<++PhyTxDropCount); +} + +void +PhyRxDrop(Ptr p) +{ + NS_LOG_UNCOND(Simulator::Now ().GetSeconds ()<<" Rx Packet Drop "<<++PhyRxDropCount); +} +void ThroughputMonitor (FlowMonitorHelper *fmhelper, Ptr flowMon) + { + std::map flowStats = flowMon->GetFlowStats(); + Ptr classing = DynamicCast (fmhelper->GetClassifier()); + for (std::map::const_iterator stats = flowStats.begin (); stats != flowStats.end (); ++stats) + { + Ipv4FlowClassifier::FiveTuple fiveTuple = classing->FindFlow (stats->first); + std::cout<<"---------------------------------------------------------------------------"<first <<" ; "<< fiveTuple.sourceAddress <<" -----> "<second.timeLastRxPacket.GetSeconds()-stats->second.timeFirstTxPacket.GetSeconds()<second.timeLastRxPacket.GetSeconds()<<" Seconds"<second.rxBytes * 8.0 / (stats->second.timeLastRxPacket.GetSeconds()-stats->second.timeFirstTxPacket.GetSeconds())/1024/1024 << " Mbps"< basicSourcePtr0 = DynamicCast (wifiEdgeNodesSources.Get (0)); + + basicSourcePtr0->TraceConnectWithoutContext ("RemainingEnergy", MakeCallback (&RemainingEnergy)); + //device energy model + + Ptr 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 allMon = fmHelper.InstallAll(); + Simulator::Schedule(Seconds(1),&ThroughputMonitor,&fmHelper, allMon); + + + FlowMonitorHelper flowmon; + Ptr monitor = flowmon.InstallAll(); + Ptr classifier = DynamicCast (flowmon.GetClassifier ()); + + Simulator::Stop (Seconds (simulationTime)); + Simulator::Run (); + + std::map 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; +} -- cgit v1.2.3