A Discrete-Event Network Simulator
API
energy-model-with-harvesting-example.cc
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2014 Wireless Communications and Networking Group (WCNG),
3  * University of Rochester, Rochester, NY, USA.
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License version 2 as
7  * published by the Free Software Foundation;
8  *
9  * This program is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program; if not, write to the Free Software
16  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17  *
18  * Author: Cristiano Tapparello <cristiano.tapparello@rochester.edu>
19  */
20 
49 #include "ns3/config-store-module.h"
50 #include "ns3/core-module.h"
51 #include "ns3/energy-module.h"
52 #include "ns3/internet-module.h"
53 #include "ns3/mobility-module.h"
54 #include "ns3/network-module.h"
55 #include "ns3/wifi-radio-energy-model-helper.h"
56 #include "ns3/yans-wifi-helper.h"
57 
58 #include <fstream>
59 #include <iostream>
60 #include <string>
61 #include <vector>
62 
63 using namespace ns3;
64 
65 NS_LOG_COMPONENT_DEFINE("EnergyWithHarvestingExample");
66 
73 static inline std::string
75 {
77 
78  std::ostringstream oss;
79  oss << "--\nReceived one packet! Socket: " << iaddr.GetIpv4() << " port: " << iaddr.GetPort()
80  << " at time = " << Simulator::Now().GetSeconds() << "\n--";
81 
82  return oss.str();
83 }
84 
90 void
92 {
93  Ptr<Packet> packet;
94  Address from;
95  while ((packet = socket->RecvFrom(from)))
96  {
97  if (packet->GetSize() > 0)
98  {
100  }
101  }
102 }
103 
113 static void
115  uint32_t pktSize,
116  Ptr<Node> n,
117  uint32_t pktCount,
118  Time pktInterval)
119 {
120  if (pktCount > 0)
121  {
122  socket->Send(Create<Packet>(pktSize));
123  Simulator::Schedule(pktInterval,
125  socket,
126  pktSize,
127  n,
128  pktCount - 1,
129  pktInterval);
130  }
131  else
132  {
133  socket->Close();
134  }
135 }
136 
143 void
144 RemainingEnergy(double oldValue, double remainingEnergy)
145 {
146  NS_LOG_UNCOND(Simulator::Now().GetSeconds()
147  << "s Current remaining energy = " << remainingEnergy << "J");
148 }
149 
156 void
157 TotalEnergy(double oldValue, double totalEnergy)
158 {
159  NS_LOG_UNCOND(Simulator::Now().GetSeconds()
160  << "s Total energy consumed by radio = " << totalEnergy << "J");
161 }
162 
169 void
170 HarvestedPower(double oldValue, double harvestedPower)
171 {
172  NS_LOG_UNCOND(Simulator::Now().GetSeconds()
173  << "s Current harvested power = " << harvestedPower << " W");
174 }
175 
182 void
183 TotalEnergyHarvested(double oldValue, double totalEnergyHarvested)
184 {
185  NS_LOG_UNCOND(Simulator::Now().GetSeconds()
186  << "s Total energy harvested by harvester = " << totalEnergyHarvested << " J");
187 }
188 
189 int
190 main(int argc, char* argv[])
191 {
192  std::string phyMode("DsssRate1Mbps");
193  double Prss = -80; // dBm
194  uint32_t PacketSize = 200; // bytes
195  bool verbose = false;
196 
197  // simulation parameters
198  uint32_t numPackets = 10000; // number of packets to send
199  double interval = 1; // seconds
200  double startTime = 0.0; // seconds
201  double distanceToRx = 100.0; // meters
202 
203  // Energy Harvester variables
204  double harvestingUpdateInterval = 1; // seconds
205 
206  CommandLine cmd(__FILE__);
207  cmd.AddValue("phyMode", "Wifi Phy mode", phyMode);
208  cmd.AddValue("Prss", "Intended primary RSS (dBm)", Prss);
209  cmd.AddValue("PacketSize", "size of application packet sent", PacketSize);
210  cmd.AddValue("numPackets", "Total number of packets to send", numPackets);
211  cmd.AddValue("startTime", "Simulation start time", startTime);
212  cmd.AddValue("distanceToRx", "X-Axis distance between nodes", distanceToRx);
213  cmd.AddValue("verbose", "Turn on all device log components", verbose);
214  cmd.Parse(argc, argv);
215 
216  // Convert to time object
217  Time interPacketInterval = Seconds(interval);
218 
219  // disable fragmentation for frames below 2200 bytes
220  Config::SetDefault("ns3::WifiRemoteStationManager::FragmentationThreshold",
221  StringValue("2200"));
222  // turn off RTS/CTS for frames below 2200 bytes
223  Config::SetDefault("ns3::WifiRemoteStationManager::RtsCtsThreshold", StringValue("2200"));
224  // Fix non-unicast data rate to be the same as that of unicast
225  Config::SetDefault("ns3::WifiRemoteStationManager::NonUnicastMode", StringValue(phyMode));
226 
227  NodeContainer c;
228  c.Create(2); // create 2 nodes
229  NodeContainer networkNodes;
230  networkNodes.Add(c.Get(0));
231  networkNodes.Add(c.Get(1));
232 
233  // The below set of helpers will help us to put together the wifi NICs we want
235  if (verbose)
236  {
238  }
239  wifi.SetStandard(WIFI_STANDARD_80211b);
240 
242  /***************************************************************************/
243  YansWifiPhyHelper wifiPhy;
244 
246  YansWifiChannelHelper wifiChannel;
247  wifiChannel.SetPropagationDelay("ns3::ConstantSpeedPropagationDelayModel");
248  wifiChannel.AddPropagationLoss("ns3::FriisPropagationLossModel");
249 
250  // create wifi channel
251  Ptr<YansWifiChannel> wifiChannelPtr = wifiChannel.Create();
252  wifiPhy.SetChannel(wifiChannelPtr);
253 
255  // Add a MAC and disable rate control
256  WifiMacHelper wifiMac;
257  wifi.SetRemoteStationManager("ns3::ConstantRateWifiManager",
258  "DataMode",
259  StringValue(phyMode),
260  "ControlMode",
261  StringValue(phyMode));
262  // Set it to ad-hoc mode
263  wifiMac.SetType("ns3::AdhocWifiMac");
264 
266  NetDeviceContainer devices = wifi.Install(wifiPhy, wifiMac, networkNodes);
267 
270  Ptr<ListPositionAllocator> positionAlloc = CreateObject<ListPositionAllocator>();
271  positionAlloc->Add(Vector(0.0, 0.0, 0.0));
272  positionAlloc->Add(Vector(2 * distanceToRx, 0.0, 0.0));
273  mobility.SetPositionAllocator(positionAlloc);
274  mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
275  mobility.Install(c);
276 
278  /***************************************************************************/
279  /* energy source */
280  BasicEnergySourceHelper basicSourceHelper;
281  // configure energy source
282  basicSourceHelper.Set("BasicEnergySourceInitialEnergyJ", DoubleValue(1.0));
283  // install source
284  EnergySourceContainer sources = basicSourceHelper.Install(c);
285  /* device energy model */
286  WifiRadioEnergyModelHelper radioEnergyHelper;
287  // configure radio energy model
288  radioEnergyHelper.Set("TxCurrentA", DoubleValue(0.0174));
289  radioEnergyHelper.Set("RxCurrentA", DoubleValue(0.0197));
290  // install device model
291  DeviceEnergyModelContainer deviceModels = radioEnergyHelper.Install(devices, sources);
292 
293  /* energy harvester */
294  BasicEnergyHarvesterHelper basicHarvesterHelper;
295  // configure energy harvester
296  basicHarvesterHelper.Set("PeriodicHarvestedPowerUpdateInterval",
297  TimeValue(Seconds(harvestingUpdateInterval)));
298  basicHarvesterHelper.Set("HarvestablePower",
299  StringValue("ns3::UniformRandomVariable[Min=0.0|Max=0.1]"));
300  // install harvester on all energy sources
301  EnergyHarvesterContainer harvesters = basicHarvesterHelper.Install(sources);
302  /***************************************************************************/
303 
305  InternetStackHelper internet;
306  internet.Install(networkNodes);
307 
308  Ipv4AddressHelper ipv4;
309  NS_LOG_INFO("Assign IP Addresses.");
310  ipv4.SetBase("10.1.1.0", "255.255.255.0");
312 
313  TypeId tid = TypeId::LookupByName("ns3::UdpSocketFactory");
314  Ptr<Socket> recvSink = Socket::CreateSocket(networkNodes.Get(1), tid); // node 1, Destination
316  recvSink->Bind(local);
318 
319  Ptr<Socket> source = Socket::CreateSocket(networkNodes.Get(0), tid); // node 0, Source
321  source->SetAllowBroadcast(true);
322  source->Connect(remote);
323 
325  /***************************************************************************/
326  // all traces are connected to node 1 (Destination)
327  // energy source
328  Ptr<BasicEnergySource> basicSourcePtr = DynamicCast<BasicEnergySource>(sources.Get(1));
329  basicSourcePtr->TraceConnectWithoutContext("RemainingEnergy", MakeCallback(&RemainingEnergy));
330  // device energy model
331  Ptr<DeviceEnergyModel> basicRadioModelPtr =
332  basicSourcePtr->FindDeviceEnergyModels("ns3::WifiRadioEnergyModel").Get(0);
333  NS_ASSERT(basicRadioModelPtr);
334  basicRadioModelPtr->TraceConnectWithoutContext("TotalEnergyConsumption",
336  // energy harvester
337  Ptr<BasicEnergyHarvester> basicHarvesterPtr =
338  DynamicCast<BasicEnergyHarvester>(harvesters.Get(1));
339  basicHarvesterPtr->TraceConnectWithoutContext("HarvestedPower", MakeCallback(&HarvestedPower));
340  basicHarvesterPtr->TraceConnectWithoutContext("TotalEnergyHarvested",
342  /***************************************************************************/
343 
345  // start traffic
346  Simulator::Schedule(Seconds(startTime),
348  source,
349  PacketSize,
350  networkNodes.Get(0),
351  numPackets,
352  interPacketInterval);
353 
354  Simulator::Stop(Seconds(10.0));
355  Simulator::Run();
356 
357  for (DeviceEnergyModelContainer::Iterator iter = deviceModels.Begin();
358  iter != deviceModels.End();
359  iter++)
360  {
361  double energyConsumed = (*iter)->GetTotalEnergyConsumption();
362  NS_LOG_UNCOND("End of simulation ("
363  << Simulator::Now().GetSeconds()
364  << "s) Total energy consumed by radio = " << energyConsumed << "J");
365  NS_ASSERT(energyConsumed <= 1.0);
366  }
367 
369 
370  return 0;
371 }
a polymophic address class
Definition: address.h:100
Creates a BasicEnergyHarvester object.
void Set(std::string name, const AttributeValue &v) override
Creates a BasicEnergySource object.
void Set(std::string name, const AttributeValue &v) override
Parse command-line arguments.
Definition: command-line.h:232
Holds a vector of ns3::DeviceEnergyModel pointers.
std::vector< Ptr< DeviceEnergyModel > >::const_iterator Iterator
Const iterator of DeviceEnergyModel container.
Iterator Begin() const
Get an iterator which refers to the first DeviceEnergyModel pointer in the container.
Iterator End() const
Get an iterator which refers to the last DeviceEnergyModel pointer in the container.
Ptr< DeviceEnergyModel > Get(uint32_t i) const
Get the i-th Ptr<DeviceEnergyModel> stored in this container.
DeviceEnergyModelContainer Install(Ptr< NetDevice > device, Ptr< EnergySource > source) const
This class can be used to hold variables of floating point type such as 'double' or 'float'.
Definition: double.h:42
Holds a vector of ns3::EnergyHarvester pointers.
Ptr< EnergyHarvester > Get(uint32_t i) const
Get the i-th Ptr<EnergyHarvester> stored in this container.
EnergyHarvesterContainer Install(Ptr< EnergySource > source) const
Holds a vector of ns3::EnergySource pointers.
Ptr< EnergySource > Get(uint32_t i) const
Get the i-th Ptr<EnergySource> stored in this container.
EnergySourceContainer Install(Ptr< Node > node) const
DeviceEnergyModelContainer FindDeviceEnergyModels(TypeId tid)
an Inet address class
Ipv4Address GetIpv4() const
static InetSocketAddress ConvertFrom(const Address &address)
Returns an InetSocketAddress which corresponds to the input Address.
aggregate IP/TCP/UDP functionality to existing Nodes.
void Install(std::string nodeName) const
Aggregate implementations of the ns3::Ipv4, ns3::Ipv6, ns3::Udp, and ns3::Tcp classes onto the provid...
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
static Ipv4Address GetBroadcast()
static Ipv4Address GetAny()
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Helper class used to assign positions and mobility models to nodes.
holds a vector of ns3::NetDevice pointers
keep track of a set of node pointers.
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
void Add(const NodeContainer &nc)
Append the contents of another NodeContainer to the end of this container.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
bool TraceConnectWithoutContext(std::string name, const CallbackBase &cb)
Connect a TraceSource to a Callback without a context.
Definition: object-base.cc:311
uint32_t GetSize() const
Returns the the size in bytes of the packet (including the zero-filled initial payload).
Definition: packet.h:863
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
Definition: simulator.h:568
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
Definition: simulator.cc:140
static Time Now()
Return the current simulation virtual time.
Definition: simulator.cc:199
static void Run()
Run the simulation.
Definition: simulator.cc:176
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Definition: simulator.cc:184
virtual int Send(Ptr< Packet > p, uint32_t flags)=0
Send data (or dummy data) to the remote host.
virtual bool SetAllowBroadcast(bool allowBroadcast)=0
Configure whether broadcast datagram transmissions are allowed.
void SetRecvCallback(Callback< void, Ptr< Socket >> receivedData)
Notify application when new data is available to be read.
Definition: socket.cc:126
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
static Ptr< Socket > CreateSocket(Ptr< Node > node, TypeId tid)
This method wraps the creation of sockets that is performed on a given node by a SocketFactory specif...
Definition: socket.cc:72
virtual int Close()=0
Close a socket.
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
virtual Ptr< Packet > RecvFrom(uint32_t maxSize, uint32_t flags, Address &fromAddress)=0
Read a single packet from the socket and retrieve the sender address.
Hold variables of type string.
Definition: string.h:56
Simulation virtual time values and global simulation resolution.
Definition: nstime.h:105
double GetSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
Definition: nstime.h:402
AttributeValue implementation for Time.
Definition: nstime.h:1423
a unique identifier for an interface.
Definition: type-id.h:60
static TypeId LookupByName(std::string name)
Get a TypeId by name.
Definition: type-id.cc:839
helps to create WifiNetDevice objects
Definition: wifi-helper.h:325
static void EnableLogComponents()
Helper to enable all WifiNetDevice log components with one statement.
Definition: wifi-helper.cc:880
create MAC layers for a ns3::WifiNetDevice.
void SetType(std::string type, Args &&... args)
Assign WifiRadioEnergyModel to wifi devices.
void Set(std::string name, const AttributeValue &v) override
manage and create wifi channel objects for the YANS model.
void SetPropagationDelay(std::string name, Ts &&... args)
void AddPropagationLoss(std::string name, Ts &&... args)
Ptr< YansWifiChannel > Create() const
Make it easy to create and manage PHY objects for the YANS model.
void SetChannel(Ptr< YansWifiChannel > channel)
void HarvestedPower(double oldValue, double harvestedPower)
Trace function for the power harvested by the energy harvester.
void TotalEnergy(double oldValue, double totalEnergy)
Trace function for total energy consumption at node.
void ReceivePacket(Ptr< Socket > socket)
void TotalEnergyHarvested(double oldValue, double totalEnergyHarvested)
Trace function for the total energy harvested by the node.
void RemainingEnergy(double oldValue, double remainingEnergy)
Trace function for remaining energy at node.
static void GenerateTraffic(Ptr< Socket > socket, uint32_t pktSize, Ptr< Node > n, uint32_t pktCount, Time pktInterval)
static std::string PrintReceivedPacket(Address &from)
Print a received packet.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
Definition: assert.h:66
void SetDefault(std::string name, const AttributeValue &value)
Definition: config.cc:891
#define NS_LOG_UNCOND(msg)
Output the requested message unconditionally.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition: log.h:202
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Definition: log.h:275
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition: nstime.h:1336
@ WIFI_STANDARD_80211b
devices
Definition: first.py:35
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Callback< R, Args... > MakeCallback(R(T::*memPtr)(Args...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
Definition: callback.h:707
cmd
Definition: second.py:33
wifi
Definition: third.py:88
mobility
Definition: third.py:96
bool verbose
uint32_t pktSize
packet size used for the simulation (in bytes)