mirror of
https://gitlab.com/manzerbredes/paper-lowrate-iot.git
synced 2025-04-19 04:09:43 +00:00
Add old end-to-end files
This commit is contained in:
Loic Guegan
parent
6cadbb5316
commit
c287166ecc
2 changed files with 711 additions and 0 deletions
334
ns-3_wifi_tests/wifi-nodes-energy-consumption.cc
Normal file
334
ns-3_wifi_tests/wifi-nodes-energy-consumption.cc
Normal file
|
|
@ -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;
|
||||
}
|
||||
377
ns-3_wifi_tests/wifi-nodes-energy-consumption2.cc
Normal file
377
ns-3_wifi_tests/wifi-nodes-energy-consumption2.cc
Normal file
|
|
@ -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;
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue