/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "raw-application-helper.h"

#include "ns3/names.h"

#include "ns3/packet-socket-factory.h"

#include "ns3/packet-socket-helper.h"

#include "ns3/net-device.h"

#include "ns3/address.h"

namespace ns3 {

RawApplicationHelper::RawApplicationHelper ()

{

  m_factory.SetTypeId ("ns3::UdpRawApplication");

}

void 

RawApplicationHelper::SetAttribute (std::string name, const AttributeValue &value)

{

  m_factory.Set (name, value);

}

ApplicationContainer

RawApplicationHelper::Install (Ptr<Node> node) const

{

  return ApplicationContainer (DoInstall (node));

}

ApplicationContainer

RawApplicationHelper::Install (std::string nodeName) const

{

  Ptr<Node> node = Names::Find<Node> (nodeName);

  return ApplicationContainer (DoInstall (node));

}

ApplicationContainer

RawApplicationHelper::Install (NodeContainer c) const

{

  ApplicationContainer apps;

  for (NodeContainer::Iterator i = c.Begin (); i != c.End (); ++i)

    {

      apps.Add (DoInstall (*i));

    }

  return apps;

}

Ptr<Application>

RawApplicationHelper::DoInstall (Ptr<Node> node) const

{

  if(node->GetObject<PacketSocketFactory> () == NULL)

    {

      PacketSocketHelper packetSocketHelper;

      packetSocketHelper.Install (node);

    }

  Ptr<Application> app = m_factory.Create<Application> ();

  node->AddApplication (app);

  return app;

}

} // namespace ns3

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#ifndef RAW_APPLICATION_HELPER_H

#define RAW_APPLICATION_HELPER_H

#include "ns3/object-factory.h"

#include "ns3/attribute.h"

#include "ns3/node-container.h"

#include "ns3/application-container.h"

namespace ns3 {

/**

 * \ingroup applications

 * \brief A helper to make it easier to instantiate an ns3::RawApplication 

 * on a set of nodes.

 */

class RawApplicationHelper

{

public:

  /**

   * Create a RawApplicationHelper to make it easier to work with RawApplication

   */

  RawApplicationHelper ();

  /**

   * Helper function used to set the underlying application attributes.

   */

  void SetAttribute (std::string name, const AttributeValue &value);

  /**

   * Install an ns3::RawApplication on each node of the input container

   * configured with all the attributes set with SetAttribute.

   *

   * \param c NodeContainer of the set of nodes on which a RawApplication 

   * will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (NodeContainer c) const;

  /**

   * Install an ns3::RawApplication on the node configured with all the 

   * attributes set with SetAttribute.

   *

   * \param node The node on which a RawApplication will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (Ptr<Node> node) const;

  /**

   * Install an ns3::RawApplication on the node configured with all the 

   * attributes set with SetAttribute.

   *

   * \param nodeName The node on which a RawApplication will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (std::string nodeName) const;

private:

  /**

   * Install an ns3::RawApplication on the node configured with all the 

   * attributes set with SetAttribute.

   *

   * \param node The node on which a RawApplication will be installed.

   * \returns Ptr to the application installed.

   */

  Ptr<Application> DoInstall (Ptr<Node> node) const;

  ObjectFactory m_factory; //!< Object factory.

};

} // namespace ns3

#endif /* RAW_APPLICATION_HELPER_H */

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "udp-application-helper.h"

#include "ns3/names.h"

#include "ns3/packet-socket-factory.h"

#include "ns3/packet-socket-helper.h"

#include "ns3/net-device.h"

#include "ns3/address.h"

#include "ns3/udp-application.h"

#include "ns3/internet-stack-helper.h"

namespace ns3 {

UdpApplicationHelper::UdpApplicationHelper ()

  : m_port (0)

{

  m_factory.SetTypeId ("ns3::UdpApplication");

}

void 

UdpApplicationHelper::SetAttribute (std::string name, const AttributeValue &value)

{

  m_factory.Set (name, value);

}

ApplicationContainer

UdpApplicationHelper::Install (Ptr<Node> node) const

{

  return ApplicationContainer (DoInstall (node));

}

ApplicationContainer

UdpApplicationHelper::Install (std::string nodeName) const

{

  Ptr<Node> node = Names::Find<Node> (nodeName);

  return ApplicationContainer (DoInstall (node));

}

ApplicationContainer

UdpApplicationHelper::Install (NodeContainer c) const

{

  ApplicationContainer apps;

  for (NodeContainer::Iterator i = c.Begin (); i != c.End (); ++i)

    {

      apps.Add (DoInstall (*i));

    }

  return apps;

}

Ptr<Application>

UdpApplicationHelper::DoInstall (Ptr<Node> node) const

{

  if(node->GetObject<Ipv4> () == NULL)

    {

      InternetStackHelper internet;

      internet.Install (node);

    }

  Ptr<Application> app = m_factory.Create<Application> ();

  node->AddApplication (app);

  app->GetObject<UdpApplication> ()->SetPort (m_port);

  return app;

}

void

UdpApplicationHelper::SetPort (uint16_t port)

{

  m_port = port;

}

} // namespace ns3

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#ifndef UDP_APPLICATION_HELPER_H

#define UDP_APPLICATION_HELPER_H

#include "ns3/object-factory.h"

#include "ns3/attribute.h"

#include "ns3/node-container.h"

#include "ns3/application-container.h"

namespace ns3 {

/**

 * \ingroup applications

 * \brief A helper to make it easier to instantiate an ns3::UdpApplication 

 * on a set of nodes.

 */

class UdpApplicationHelper

{

public:

  /**

   * Create a UdpApplicationHelper to make it easier to work with UdpApplication

   */

  UdpApplicationHelper ();

  /**

   * Helper function used to set the underlying application attributes.

   */

  void SetAttribute (std::string name, const AttributeValue &value);

  /**

   * Install an ns3::UdpApplication on each node of the input container

   * configured with all the attributes set with SetAttribute.

   *

   * \param c NodeContainer of the set of nodes on which a UdpApplication 

   * will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (NodeContainer c) const;

  /**

   * Install an ns3::UdpApplication on the node configured with all the 

   * attributes set with SetAttribute.

   *

   * \param node The node on which a UdpApplication will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (Ptr<Node> node) const;

  /**

   * Install an ns3::UdpApplication on the node configured with all the 

   * attributes set with SetAttribute.

   *

   * \param nodeName The node on which a UdpApplication will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (std::string nodeName) const;

  /**

   * Sets the UDP port number that the UdpApplication will use

   *

   * \param port The UDP port number

   */

  void SetPort (uint16_t port);

private:

  /**

   * Install an ns3::UdpApplication on the node configured with all the 

   * attributes set with SetAttribute.

   *

   * \param node The node on which a UdpApplication will be installed.

   * \returns Ptr to the application installed.

   */

  Ptr<Application> DoInstall (Ptr<Node> node) const;

  ObjectFactory m_factory; //!< Object factory.

  uint16_t m_port;

};

} // namespace ns3

#endif /* UDP_APPLICATION_HELPER_H */

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "raw-application.h"

#include "ns3/log.h"

#include "ns3/socket-factory.h"

#include "ns3/packet-socket-address.h"

#include "ns3/packet-socket.h"

namespace ns3 {

NS_LOG_COMPONENT_DEFINE ("RawApplication");

NS_OBJECT_ENSURE_REGISTERED (RawApplication);

TypeId 

RawApplication::GetTypeId (void)

{

  static TypeId tid = TypeId ("ns3::RawApplication")

    .SetParent<Application> ()

    .SetGroupName ("Applications")

    .AddConstructor<RawApplication> ()

  ;

  return tid;

}

RawApplication::RawApplication ()

{

  NS_LOG_FUNCTION (this);

  m_socket = NULL;

  m_packetReceivedCallback.Nullify ();

}

RawApplication::~RawApplication ()

{

  NS_LOG_FUNCTION (this);

}

void

RawApplication::DoDispose (void)

{

  NS_LOG_FUNCTION (this);

  m_socket = NULL;

  m_packetReceivedCallback.Nullify ();

  Application::DoDispose ();

}

uint32_t

RawApplication::GetApplicationId (void) const

{

  NS_LOG_FUNCTION (this);

  Ptr<Node> node = GetNode ();

  for (uint32_t i = 0; i < node->GetNApplications (); ++i)

    {

      if (node->GetApplication (i) == this)

        {

          return i;

        }

    }

  NS_ASSERT_MSG (false, "forgot to add application to node");

  return 0;

}

void 

RawApplication::Send (Address dst, const Buffer dataBuffer)

{

  NS_LOG_FUNCTION (this);

  const uint8_t * data = dataBuffer.PeekData ();

  Address local = GetNode ()->GetDevice (0)->GetAddress ();

  if(dst != local)

    { 

      PacketSocketAddress socketAddress;

      socketAddress.SetSingleDevice (GetNode ()->GetDevice (0)->GetIfIndex ());

      socketAddress.SetPhysicalAddress (dst);

      socketAddress.SetProtocol (0);

      Ptr<Packet> packet = Create<Packet> (data, dataBuffer.GetSize ());

      if(m_socket == NULL)

        {

          StartApplication ();

        }

      m_socket->SendTo (packet, 0, socketAddress);

    }

}

void

RawApplication::Receive (Ptr<Socket> socket)

{

  NS_LOG_FUNCTION (this << socket);

  NS_ASSERT (m_socket != NULL);

  while (m_socket->GetRxAvailable () > 0)

    {

      Address srcAddress;

      Ptr<Packet> packet = m_socket->RecvFrom (srcAddress);

      uint8_t *buffer = new uint8_t[packet->GetSize ()];

      packet->CopyData (buffer, packet->GetSize ());

      PacketSocketAddress packetSocketAddress = PacketSocketAddress::ConvertFrom (srcAddress);

      srcAddress = packetSocketAddress.GetPhysicalAddress ();

      if(!m_packetReceivedCallback.IsNull ())

        {

          Buffer dataBuffer;

          dataBuffer.AddAtEnd ( packet->GetSize ());

          Buffer::Iterator iterator = dataBuffer.Begin ();

          iterator.Write (buffer, packet->GetSize ());

          m_packetReceivedCallback (srcAddress, dataBuffer);

        }

      delete[] buffer;

    }

} 

void 

RawApplication::StartApplication (void)

{

  NS_LOG_FUNCTION (this);

  PacketSocketAddress socketAddress;

  socketAddress.SetSingleDevice (GetNode ()->GetDevice (0)->GetIfIndex ());

  socketAddress.SetProtocol (0);

  if (!m_socket)

    {

      m_socket = Socket::CreateSocket (GetNode (), TypeId::LookupByName ("ns3::PacketSocketFactory"));

    }

  m_socket->Bind ();

  m_socket->Connect (socketAddress);

  m_socket->SetRecvCallback (MakeCallback (&RawApplication::Receive, this));

}

void 

RawApplication::StopApplication (void)

{

  NS_LOG_FUNCTION (this);

  if(m_socket != NULL)

    {

      m_socket->Close ();

    }

  else

    {

      NS_LOG_WARN ("RawApplication found null socket to close in StopApplication");

    }

}

void

RawApplication::SetPacketReceivedCallback (PacketReceivedCallback callback)

{

  NS_LOG_FUNCTION (this);

  if (callback.IsNull ())

    {

      NS_LOG_DEBUG ("RawApplication:Setting NULL packet received callback!");

    }

  m_packetReceivedCallback = callback;

}

} // namespace ns3

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#ifndef RAW_APPLICATION_H

#define RAW_APPLICATION_H

#include "ns3/application.h"

#include "ns3/packet.h"

#include "ns3/socket.h"

namespace ns3 {

/**

 * \ingroup applications

 * \brief a simple Raw application.

 * 

 * The Application combines both the client-side and the server-side 

 * functionality, and provides an easy to use bidirectional communications 

 * between the nodes. It runs directly on top of the data link layer, so

 * raw data is sent in the payload of the frame.

 * 

 * The user interacts with the application mainly through two functions:

 * Send () : Used to send the data in the buffer parameter to the

 * destination layer 2 address.

 * SetPacketReceivedCallback (): Used to set a receive callback where the raw 

 * packet payload, and the source layer 2 address will be passed as

 * parameters.

 */

class RawApplication : public Application

{

public:

  typedef Callback<void, Address, Buffer> PacketReceivedCallback;

  /**

   * \brief Get the type ID.

   * \return the object TypeId

   */

  static TypeId GetTypeId (void);

  /**

   * create a raw application

   */

  RawApplication ();

  virtual ~RawApplication ();

  /**

   * \brief Send a packet to the destination

   * \param dst the destination address

   * \param dataBuffer the data to be sent

   */

  void Send (Address dst, const Buffer dataBuffer);

  /**

   * \brief Set a callback when a packet is received

   * \param callback the packet received callback

   */

  void SetPacketReceivedCallback (PacketReceivedCallback callback);

private:

  // inherited from Application base class.

  virtual void StartApplication (void);

  virtual void StopApplication (void);

  virtual void DoDispose (void);

  /**

   * \brief Return the application ID in the node.

   * \returns the application id

   */

  uint32_t GetApplicationId (void) const;

  /**

   * \brief Receive a packet

   * \param socket the receiving socket

   *

   * This function is called by lower layers through a callback.

   */

  void Receive (Ptr<Socket> socket);

  Ptr<Socket> m_socket; //!< Associated socket

  PacketReceivedCallback m_packetReceivedCallback;

};

} // namespace ns3

#endif /* RAW_APPLICATION_H */

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "udp-application.h"

#include "ns3/log.h"

#include "ns3/socket-factory.h"

#include "ns3/packet-socket-address.h"

#include "ns3/packet-socket.h"

#include "ns3/ipv4-l3-protocol.h"

#include "ns3/ipv6-l3-protocol.h"

namespace ns3 {

NS_LOG_COMPONENT_DEFINE ("UdpApplication");

NS_OBJECT_ENSURE_REGISTERED (UdpApplication);

TypeId 

UdpApplication::GetTypeId (void)

{

  static TypeId tid = TypeId ("ns3::UdpApplication")

    .SetParent<Application> ()

    .SetGroupName ("Applications")

    .AddConstructor<UdpApplication> ()

  ;

  return tid;

}

UdpApplication::UdpApplication ()

{

  NS_LOG_FUNCTION (this);

  m_socket = NULL;

  m_packetReceivedCallback.Nullify ();

}

UdpApplication::~UdpApplication ()

{

  NS_LOG_FUNCTION (this);

}

void

UdpApplication::DoDispose (void)

{

  NS_LOG_FUNCTION (this);

  m_socket = NULL;

  m_packetReceivedCallback.Nullify ();

  Application::DoDispose ();

}

uint32_t

UdpApplication::GetApplicationId (void) const

{

  NS_LOG_FUNCTION (this);

  Ptr<Node> node = GetNode ();

  for (uint32_t i = 0; i < node->GetNApplications (); ++i)

    {

      if (node->GetApplication (i) == this)

        {

          return i;

        }

    }

  NS_ASSERT_MSG (false, "forgot to add application to node");

  return 0;

}

void 

UdpApplication::Send (Address dst, const Buffer dataBuffer)

{

  NS_LOG_FUNCTION (this);

  const uint8_t * data = dataBuffer.PeekData ();

  Ptr<Packet> packet = Create<Packet> (data, dataBuffer.GetSize ());

  if(m_socket == NULL)

    {

      StartApplication ();

    }

    if(Ipv6Address::IsMatchingType (dst))

      {

        Inet6SocketAddress ipv6_destination = Inet6SocketAddress (Ipv6Address::ConvertFrom (dst), m_port);

        m_socket->SendTo (packet, 0, ipv6_destination);

      }

    else if(Ipv4Address::IsMatchingType (dst))

      {

        InetSocketAddress ipv4_destination = InetSocketAddress (Ipv4Address::ConvertFrom (dst), m_port);

        m_socket->SendTo (packet, 0, ipv4_destination);

      }

}

void

UdpApplication::Receive (Ptr<Socket> socket)

{

  NS_LOG_FUNCTION (this << socket);

  NS_ASSERT (m_socket != NULL);

  Address srcAddress;

  while (m_socket->GetRxAvailable () > 0)

    {

      Ptr<Packet> packet = m_socket->RecvFrom (srcAddress);

      uint8_t *buffer = new uint8_t[packet->GetSize ()];

      packet->CopyData (buffer, packet->GetSize ());

      if(!m_packetReceivedCallback.IsNull ())

        {

          Buffer dataBuffer;

          dataBuffer.AddAtEnd ( packet->GetSize ());

          Buffer::Iterator iterator = dataBuffer.Begin ();

          iterator.Write (buffer, packet->GetSize ());

          if(Inet6SocketAddress::IsMatchingType (srcAddress))

            {

              m_packetReceivedCallback (Inet6SocketAddress::ConvertFrom (srcAddress).GetIpv6 (), dataBuffer);

            }

          else if(InetSocketAddress::IsMatchingType (srcAddress))

            {

              m_packetReceivedCallback (InetSocketAddress::ConvertFrom (srcAddress).GetIpv4 (), dataBuffer);

            }

        }

      delete[] buffer;

    }

} 

void 

UdpApplication::StartApplication (void)

{

  NS_LOG_FUNCTION (this);

  if (!m_socket)

    {

      m_socket = Socket::CreateSocket (GetNode (), TypeId::LookupByName ("ns3::UdpSocketFactory"));

    }

  if(GetNode ()->GetObject<Ipv6> () != NULL)

    {

      Inet6SocketAddress ipv6_local = Inet6SocketAddress (Ipv6Address::GetAny (), m_port);

      m_socket->Bind (ipv6_local);

    }

  if(GetNode ()->GetObject<Ipv4> () != NULL)

    {

      InetSocketAddress ipv4_local = InetSocketAddress (Ipv4Address::GetAny (), m_port);

      m_socket->Bind (ipv4_local);

    }

  m_socket->SetRecvCallback (MakeCallback (&UdpApplication::Receive, this));

}

void 

UdpApplication::StopApplication (void)

{

  NS_LOG_FUNCTION (this);

  if(m_socket != NULL)

    {

      m_socket->Close ();

    }

  else

    {

      NS_LOG_WARN ("UdpApplication found null socket to close in StopApplication");

    }

}

void

UdpApplication::SetPacketReceivedCallback (PacketReceivedCallback callback)

{

  NS_LOG_FUNCTION (this);

  if (callback.IsNull ())

    {

      NS_LOG_DEBUG ("UdpApplication:Setting NULL packet received callback!");

    }

  m_packetReceivedCallback = callback;

}

void

UdpApplication::SetPort (uint16_t port)

{

  m_port = port;

}

uint16_t

UdpApplication::GetPort () const

{

  return m_port;

}

} // namespace ns3

/* -*- 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

 * 

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#ifndef UDP_APPLICATION_H

#define UDP_APPLICATION_H

#include "ns3/application.h"

#include "ns3/packet.h"

#include "ns3/mac8-address.h"

#include "ns3/socket.h"

namespace ns3 {

/**

 * \ingroup applications

 * \brief a simple UDP application.

 * 

 * The Application uses the NS-3 IP stack, and UDP Sockets to send and received

 * data.

 * The user interacts with the application mainly through two functions:

 * Send () : Used to send the data in the buffer parameter to the

 * destination IPv4/IPv6 address.

 * SetPacketReceivedCallback (): Used to set a receive callback where the raw 

 * packet payload, and the source IPv4/IPv6 address will be passed as

 * parameters.

 */

class UdpApplication : public Application

{

public:

  typedef Callback<void, Address, Buffer> PacketReceivedCallback;

  /**

   * \brief Get the type ID.

   * \return the object TypeId

   */

  static TypeId GetTypeId (void);

  /**

   * create a udp application

   */

  UdpApplication ();

  virtual ~UdpApplication ();

  /**

   * \brief Send a packet to the destination

   * \param dst the destination IPv4 address

   * \param dataBuffer the data to be sent

   */

  void Send (Address dst, const Buffer dataBuffer);

  /**

   * \brief Set a callback when a packet is received

   * \param callback the packet received callback

   */

  void SetPacketReceivedCallback (PacketReceivedCallback callback);

  /**

   * \brief Sets the UDP port number.

   * \param port The UDP port number

   */

  void SetPort (uint16_t port);

  /**

   * \brief Gets the UDP port number.

   * \return The UDP port number

   */

  uint16_t GetPort () const;

private:

  // inherited from Application base class.

  virtual void StartApplication (void);

  virtual void StopApplication (void);

  virtual void DoDispose (void);

  /**

   * \brief Return the application ID in the node.

   * \returns the application id

   */

  uint32_t GetApplicationId (void) const;

  /**

   * \brief Receive a packet

   * \param socket the receiving socket

   *

   * This function is called by lower layers through a callback.

   */

  void Receive (Ptr<Socket> socket);

  Ptr<Socket> m_socket; //!< Associated socket

  uint16_t m_port;      //!< Port number

  PacketReceivedCallback m_packetReceivedCallback;

};

} // namespace ns3

#endif /* UDP_APPLICATION_H */

        'model/udp-application.cc',

        'model/raw-application.cc',

        'helper/udp-application-helper.cc',

        'helper/raw-application-helper.cc',

        'model/udp-application.h',

        'model/raw-application.h',

        'helper/udp-application-helper.h',

        'helper/raw-application-helper.h',

/* -*- 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

 *

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "ns3/core-module.h"

#include "ns3/internet-module.h"

#include "ns3/node-container.h"

#include "ns3/mobility-helper.h"

#include "ns3/mobility-model.h"

#include "ns3/basic-energy-source-helper.h"

#include "ns3/energy-source-container.h"

#include "ns3/uan-helper.h"

#include "ns3/uan-channel.h"

#include "ns3/acoustic-modem-energy-model-helper.h"

#include "ns3/udp-application-helper.h"

#include "ns3/udp-application.h"

#include "ns3/sixlowpan-helper.h"

#include "ns3/sixlowpan-net-device.h"

using namespace ns3;

/**

 *

 * This example shows the usage of UdpApplication to transfer data.

 * Two nodes are sending their remaining energy percentage (1 byte)

 * to a gateway node, that prints the received data.

 * The transmissions are scheduled at random times to avoid collisions

 *

 */

NS_LOG_COMPONENT_DEFINE ("Uan6lowpanExample");

void SetupPositions ();

void SetupEnergy ();

void SetupCommunications ();

void PrintReceivedPacket (Address src, Buffer data);

void SetupApplications ();

void SendPacket ();

void Run ();

NodeContainer nodeContainer;

void

SetupPositions ()

{

  MobilityHelper mobilityHelper;

  mobilityHelper.SetMobilityModel ("ns3::ConstantPositionMobilityModel");

  mobilityHelper.Install (nodeContainer);

  nodeContainer.Get (0)->GetObject<MobilityModel> ()->SetPosition (Vector (0, 0, 0));

  nodeContainer.Get (1)->GetObject<MobilityModel> ()->SetPosition (Vector (100, 0, 0));

  nodeContainer.Get (2)->GetObject<MobilityModel> ()->SetPosition (Vector (-100, 0, 0));

}

void

SetupEnergy ()

{

  BasicEnergySourceHelper energySourceHelper;

  energySourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (900000));

  energySourceHelper.Install (nodeContainer);

}

void

SetupCommunications ()

{

  Ptr<UanChannel> channel = CreateObject<UanChannel> ();

  UanHelper uanHelper;

  NetDeviceContainer netDeviceContainer = uanHelper.Install (nodeContainer, channel);

  EnergySourceContainer energySourceContainer;

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      energySourceContainer.Add ((*node)->GetObject<EnergySourceContainer> ()->Get (0));

      node++;

    }

  AcousticModemEnergyModelHelper acousticModemEnergyModelHelper;

  acousticModemEnergyModelHelper.Install (netDeviceContainer, energySourceContainer);

  SixLowPanHelper sixLowPanHelper;

  NetDeviceContainer sixlowpanNetDevices = sixLowPanHelper.Install (netDeviceContainer);

  InternetStackHelper internetStackHelper;

  internetStackHelper.Install (nodeContainer);

  Ipv6AddressHelper ipv6AddressHelper;

  ipv6AddressHelper.SetBase (Ipv6Address ("2002::"), Ipv6Prefix (64));

  ipv6AddressHelper.Assign (sixlowpanNetDevices);

  node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      (*node)->GetObject<Icmpv6L4Protocol> ()->SetAttribute("DAD", BooleanValue(false));

      (*node)->GetObject<Icmpv6L4Protocol> ()->SetAttribute("ReachableTime", TimeValue (Seconds (3600)));

      (*node)->GetObject<Icmpv6L4Protocol> ()->SetAttribute("RetransmissionTime", TimeValue (Seconds (1000)));

      node++;

    }

}

void

PrintReceivedPacket (Address src, Buffer data)

{

  std::cout << "Time:" << Simulator::Now ().GetDays () << "|"

            << "Node:" << Ipv6Address::ConvertFrom (src)

            << "|Energy:" << (int)(data.Begin ().ReadU8 ()) << "%" << std::endl;

}

void

SetupApplications ()

{

  UdpApplicationHelper udpApplicationHelper;

  ApplicationContainer applicationContainer;

  udpApplicationHelper.SetPort (9);

  applicationContainer = udpApplicationHelper.Install (nodeContainer);

  applicationContainer.Start (Seconds (0));

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      Ptr<UdpApplication> udpApplication = (*node)->GetApplication (0)->GetObject<UdpApplication> ();

      udpApplication->SetPacketReceivedCallback (MakeCallback<void, Address, Buffer>(&PrintReceivedPacket));

      node++;

    }

}

void

SendPacket ()

{

  Ptr<UniformRandomVariable> uniformRandomVariable = CreateObject<UniformRandomVariable> ();

  NodeContainer::Iterator node = nodeContainer.Begin ();

  Ipv6Address dst = (*node)->GetObject<Ipv6L3Protocol> ()->GetInterface (1)->GetAddress (1).GetAddress ();

  node++;

  while (node != nodeContainer.End ())

    {

      uint8_t energy = ((*node)->GetObject<EnergySourceContainer> ()->Get (0)->GetEnergyFraction ()) * 100;

      Ptr<UdpApplication> udpApplication = (*node)->GetApplication (0)->GetObject<UdpApplication> ();

      Buffer dataBuffer;

      dataBuffer.AddAtEnd (sizeof (uint8_t));

      Buffer::Iterator i = dataBuffer.Begin ();

      i.WriteU8 (energy);

      double time = uniformRandomVariable->GetValue (0, 60);

      Simulator::Schedule (Seconds (time), &UdpApplication::Send, udpApplication, dst, dataBuffer);

      node++;

    }

  Simulator::Schedule (Hours (2), &SendPacket);

}

void

Run ()

{

  nodeContainer.Create (3);

  SetupPositions ();

  SetupEnergy ();

  SetupCommunications ();

  SetupApplications ();

  SendPacket ();

}

int

main (int argc, char *argv[])

{

  CommandLine cmd;

  cmd.Parse (argc, argv);

  Run ();

  Simulator::Stop (Days (50));

  Simulator::Run ();

  Simulator::Destroy ();

  return 0;

}

/* -*- 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

 *

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "ns3/core-module.h"

#include "ns3/node-container.h"

#include "ns3/mobility-helper.h"

#include "ns3/mobility-model.h"

#include "ns3/basic-energy-source-helper.h"

#include "ns3/energy-source-container.h"

#include "ns3/uan-helper.h"

#include "ns3/uan-channel.h"

#include "ns3/acoustic-modem-energy-model-helper.h"

#include "ns3/udp-application-helper.h"

#include "ns3/udp-application.h"

#include "ns3/ipv4-address-helper.h"

#include "ns3/internet-stack-helper.h"

#include "ns3/ipv4-interface.h"

#include "ns3/arp-cache.h"

using namespace ns3;

/**

 *

 * This example shows the usage of UdpApplication to transfer data.

 * Two nodes are sending their remaining energy percentage (1 byte)

 * to a gateway node, that prints the received data.

 * The transmissions are scheduled at random times to avoid collisions

 * ARP parameters should be tuned, based on the network size

 *

 */

NS_LOG_COMPONENT_DEFINE ("UanIpv4Example");

void SetupPositions ();

void SetupEnergy ();

void SetupCommunications ();

void PrintReceivedPacket (Address src, Buffer data);

void SetupApplications ();

void SendPacket ();

void Run ();

NodeContainer nodeContainer;

void

SetupPositions ()

{

  MobilityHelper mobilityHelper;

  mobilityHelper.SetMobilityModel ("ns3::ConstantPositionMobilityModel");

  mobilityHelper.Install (nodeContainer);

  nodeContainer.Get (0)->GetObject<MobilityModel> ()->SetPosition (Vector (0, 0, 0));

  nodeContainer.Get (1)->GetObject<MobilityModel> ()->SetPosition (Vector (100, 0, 0));

  nodeContainer.Get (2)->GetObject<MobilityModel> ()->SetPosition (Vector (-100, 0, 0));

}

void

SetupEnergy ()

{

  BasicEnergySourceHelper energySourceHelper;

  energySourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (900000));

  energySourceHelper.Install (nodeContainer);

}

void

SetupCommunications ()

{

  Ptr<UanChannel> channel = CreateObject<UanChannel> ();

  UanHelper uanHelper;

  NetDeviceContainer netDeviceContainer = uanHelper.Install (nodeContainer, channel);

  EnergySourceContainer energySourceContainer;

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      energySourceContainer.Add ((*node)->GetObject<EnergySourceContainer> ()->Get (0));

      node++;

    }

  AcousticModemEnergyModelHelper acousticModemEnergyModelHelper;

  acousticModemEnergyModelHelper.Install (netDeviceContainer, energySourceContainer);

  InternetStackHelper internetStackHelper;

  internetStackHelper.Install (nodeContainer);

  Ipv4AddressHelper ipv4AddressHelper;

  ipv4AddressHelper.SetBase ("10.0.0.0", "255.255.255.0");  

  ipv4AddressHelper.Assign (netDeviceContainer);

  node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      (*node)->GetObject<Ipv4L3Protocol> ()->GetInterface (1)->GetArpCache ()->SetWaitReplyTimeout (Seconds (10));

      node++;

    }

}

void

PrintReceivedPacket (Address src, Buffer data)

{

  std::cout << "Time:" << Simulator::Now ().GetDays () << "|"

            << "Node:" << Ipv4Address::ConvertFrom (src)

            << "|Energy:" << (int)(data.Begin ().ReadU8 ()) << "%" << std::endl;

}

void

SetupApplications ()

{

  UdpApplicationHelper udpApplicationHelper;

  ApplicationContainer applicationContainer;

  udpApplicationHelper.SetPort (9);

  applicationContainer = udpApplicationHelper.Install (nodeContainer);

  applicationContainer.Start (Seconds (0));

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      Ptr<UdpApplication> udpApplication = (*node)->GetApplication (0)->GetObject<UdpApplication> ();

      udpApplication->SetPacketReceivedCallback (MakeCallback<void, Address, Buffer>(&PrintReceivedPacket));

      node++;

    }

}

void

SendPacket ()

{

  Ptr<UniformRandomVariable> uniformRandomVariable = CreateObject<UniformRandomVariable> ();

  NodeContainer::Iterator node = nodeContainer.Begin ();

  Ipv4Address dst = (*node)->GetObject<Ipv4L3Protocol> ()->GetInterface (1)->GetAddress (0).GetLocal ();

  node++;

  while (node != nodeContainer.End ())

    {

      uint8_t energy = ((*node)->GetObject<EnergySourceContainer> ()->Get (0)->GetEnergyFraction ()) * 100;

      Ptr<UdpApplication> udpApplication = (*node)->GetApplication (0)->GetObject<UdpApplication> ();

      Buffer dataBuffer;

      dataBuffer.AddAtEnd (sizeof (uint8_t));

      Buffer::Iterator i = dataBuffer.Begin ();

      double time = uniformRandomVariable->GetValue (0, 15);

      i.WriteU8 (energy);

      Simulator::Schedule (Seconds (time), &UdpApplication::Send, udpApplication, dst, dataBuffer);

      node++;

    }

  Simulator::Schedule (Minutes (5), &SendPacket);

}

void

Run ()

{

  nodeContainer.Create (3);

  SetupPositions ();

  SetupEnergy ();

  SetupCommunications ();

  SetupApplications ();

  SendPacket ();

}

int

main (int argc, char *argv[])

{

  CommandLine cmd;

  cmd.Parse (argc, argv);

  Run ();

  Simulator::Stop (Days (10));

  Simulator::Run ();

  Simulator::Destroy ();

  return 0;

}

/* -*- 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

 *

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "ns3/core-module.h"

#include "ns3/internet-module.h"

#include "ns3/node-container.h"

#include "ns3/mobility-helper.h"

#include "ns3/mobility-model.h"

#include "ns3/basic-energy-source-helper.h"

#include "ns3/energy-source-container.h"

#include "ns3/uan-helper.h"

#include "ns3/uan-channel.h"

#include "ns3/acoustic-modem-energy-model-helper.h"

#include "ns3/udp-application-helper.h"

#include "ns3/udp-application.h"

using namespace ns3;

/**

 *

 * This example shows the usage of UdpApplication to transfer data.

 * Two nodes are sending their remaining energy percentage (1 byte)

 * to a gateway node, that prints the received data.

 * The transmissions are scheduled at random times to avoid collisions

 *

 */

NS_LOG_COMPONENT_DEFINE ("UanIpv6Example");

void SetupPositions ();

void SetupEnergy ();

void SetupCommunications ();

void PrintReceivedPacket (Address src, Buffer data);

void SetupApplications ();

void SendPacket ();

void Run ();

NodeContainer nodeContainer;

void

SetupPositions ()

{

  MobilityHelper mobilityHelper;

  mobilityHelper.SetMobilityModel ("ns3::ConstantPositionMobilityModel");

  mobilityHelper.Install (nodeContainer);

  nodeContainer.Get (0)->GetObject<MobilityModel> ()->SetPosition (Vector (0, 0, 0));

  nodeContainer.Get (1)->GetObject<MobilityModel> ()->SetPosition (Vector (100, 0, 0));

  nodeContainer.Get (2)->GetObject<MobilityModel> ()->SetPosition (Vector (-100, 0, 0));

}

void

SetupEnergy ()

{

  BasicEnergySourceHelper energySourceHelper;

  energySourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (900000));

  energySourceHelper.Install (nodeContainer);

}

void

SetupCommunications ()

{

  Ptr<UanChannel> channel = CreateObject<UanChannel> ();

  UanHelper uanHelper;

  NetDeviceContainer netDeviceContainer = uanHelper.Install (nodeContainer, channel);

  EnergySourceContainer energySourceContainer;

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      energySourceContainer.Add ((*node)->GetObject<EnergySourceContainer> ()->Get (0));

      node++;

    }

  AcousticModemEnergyModelHelper acousticModemEnergyModelHelper;

  acousticModemEnergyModelHelper.Install (netDeviceContainer, energySourceContainer);

  InternetStackHelper internetStackHelper;

  internetStackHelper.Install (nodeContainer);

  Ipv6AddressHelper ipv6AddressHelper;

  ipv6AddressHelper.SetBase (Ipv6Address ("2002::"), Ipv6Prefix (64));

  ipv6AddressHelper.Assign (netDeviceContainer);

  node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      (*node)->GetObject<Icmpv6L4Protocol> ()->SetAttribute("DAD", BooleanValue(false));

      (*node)->GetObject<Icmpv6L4Protocol> ()->SetAttribute("ReachableTime", TimeValue (Seconds (3600)));

      (*node)->GetObject<Icmpv6L4Protocol> ()->SetAttribute("RetransmissionTime", TimeValue (Seconds (1000)));

      node++;

    }

}

void

PrintReceivedPacket (Address src, Buffer data)

{

  std::cout << "Time:" << Simulator::Now ().GetDays () << "|"

            << "Node:" << Ipv6Address::ConvertFrom (src)

            << "|Energy:" << (int)(data.Begin ().ReadU8 ()) << "%" << std::endl;

}

void

SetupApplications ()

{

  UdpApplicationHelper udpApplicationHelper;

  ApplicationContainer applicationContainer;

  udpApplicationHelper.SetPort (9);

  applicationContainer = udpApplicationHelper.Install (nodeContainer);

  applicationContainer.Start (Seconds (0));

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      Ptr<UdpApplication> udpApplication = (*node)->GetApplication (0)->GetObject<UdpApplication> ();

      udpApplication->SetPacketReceivedCallback (MakeCallback<void, Address, Buffer>(&PrintReceivedPacket));

      node++;

    }

}

void

SendPacket ()

{

  Ptr<UniformRandomVariable> uniformRandomVariable = CreateObject<UniformRandomVariable> ();

  NodeContainer::Iterator node = nodeContainer.Begin ();

  Ipv6Address dst = (*node)->GetObject<Ipv6L3Protocol> ()->GetInterface (1)->GetAddress (1).GetAddress ();

  node++;

  while (node != nodeContainer.End ())

    {

      uint8_t energy = ((*node)->GetObject<EnergySourceContainer> ()->Get (0)->GetEnergyFraction ()) * 100;

      Ptr<UdpApplication> udpApplication = (*node)->GetApplication (0)->GetObject<UdpApplication> ();

      Buffer dataBuffer;

      dataBuffer.AddAtEnd (sizeof (uint8_t));

      Buffer::Iterator i = dataBuffer.Begin ();

      double time = uniformRandomVariable->GetValue (0, 120);

      i.WriteU8 (energy);

      Simulator::Schedule (Seconds (time), &UdpApplication::Send, udpApplication, dst, dataBuffer);

      node++;

    }

  Simulator::Schedule (Hours (2), &SendPacket);

}

void

Run ()

{

  nodeContainer.Create (3);

  SetupPositions ();

  SetupEnergy ();

  SetupCommunications ();

  SetupApplications ();

  SendPacket ();

}

int

main (int argc, char *argv[])

{

  CommandLine cmd;

  cmd.Parse (argc, argv);

  Run ();

  Simulator::Stop (Days (30));

  Simulator::Run ();

  Simulator::Destroy ();

  return 0;

}

/* -*- 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

 *

 * Author: Hossam Khader <hossamkhader@gmail.com>

 */

#include "ns3/core-module.h"

#include "ns3/node-container.h"

#include "ns3/mobility-helper.h"

#include "ns3/mobility-model.h"

#include "ns3/basic-energy-source-helper.h"

#include "ns3/energy-source-container.h"

#include "ns3/uan-helper.h"

#include "ns3/uan-channel.h"

#include "ns3/acoustic-modem-energy-model-helper.h"

#include "ns3/raw-application-helper.h"

#include "ns3/raw-application.h"

using namespace ns3;

/**

 *

 * This example shows the usage of RawApplication to transfer data.

 * Two nodes are sending their remaining energy percentage (1 byte)

 * to a gateway node, that prints the received data.

 * The transmissions are scheduled at random times to avoid collisions

 *

 */

NS_LOG_COMPONENT_DEFINE ("UanRawExample");

void SetupPositions ();

void SetupEnergy ();

void SetupCommunications ();

void PrintReceivedPacket (Address src, Buffer data);

void SetupApplications ();

void SendPacket ();

void Run ();

NodeContainer nodeContainer;

void

SetupPositions ()

{

  MobilityHelper mobilityHelper;

  mobilityHelper.SetMobilityModel ("ns3::ConstantPositionMobilityModel");

  mobilityHelper.Install (nodeContainer);

  nodeContainer.Get (0)->GetObject<MobilityModel> ()->SetPosition (Vector (0, 0, 0));

  nodeContainer.Get (1)->GetObject<MobilityModel> ()->SetPosition (Vector (100, 0, 0));

  nodeContainer.Get (2)->GetObject<MobilityModel> ()->SetPosition (Vector (-100, 0, 0));

}

void

SetupEnergy ()

{

  BasicEnergySourceHelper energySourceHelper;

  energySourceHelper.Set ("BasicEnergySourceInitialEnergyJ", DoubleValue (900000));

  energySourceHelper.Install (nodeContainer);

}

void

SetupCommunications ()

{

  Ptr<UanChannel> channel = CreateObject<UanChannel> ();

  UanHelper uanHelper;

  NetDeviceContainer netDeviceContainer = uanHelper.Install (nodeContainer, channel);

  EnergySourceContainer energySourceContainer;

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      energySourceContainer.Add ((*node)->GetObject<EnergySourceContainer> ()->Get (0));

      node++;

    }

  AcousticModemEnergyModelHelper acousticModemEnergyModelHelper;

  acousticModemEnergyModelHelper.Install (netDeviceContainer, energySourceContainer);

}

void

PrintReceivedPacket (Address src, Buffer data)

{

  std::cout << "Time:" << Simulator::Now ().GetDays () << "|"

            << "Node:" << Mac8Address::ConvertFrom (src)

            << "|Energy:" << (int)(data.Begin ().ReadU8 ()) << "%" << std::endl;

}

void

SetupApplications ()

{

  RawApplicationHelper rawApplicationHelper;

  ApplicationContainer applicationContainer;

  applicationContainer = rawApplicationHelper.Install (nodeContainer);

  applicationContainer.Start (Seconds (0));

  NodeContainer::Iterator node = nodeContainer.Begin ();

  while (node != nodeContainer.End ())

    {

      Ptr<RawApplication> rawApplication = (*node)->GetApplication (0)->GetObject<RawApplication> ();

      rawApplication->SetPacketReceivedCallback (MakeCallback<void, Address, Buffer>(&PrintReceivedPacket));

      node++;

    }

}

void

SendPacket ()

{

  Ptr<UniformRandomVariable> uniformRandomVariable = CreateObject<UniformRandomVariable> ();

  NodeContainer::Iterator node = nodeContainer.Begin ();

  node++;

  while (node != nodeContainer.End ())

    {

      uint8_t energy = ((*node)->GetObject<EnergySourceContainer> ()->Get (0)->GetEnergyFraction ()) * 100;

      Ptr<RawApplication> rawApplication = (*node)->GetApplication (0)->GetObject<RawApplication> ();

      Buffer dataBuffer;

      dataBuffer.AddAtEnd (sizeof (uint8_t));

      Buffer::Iterator i = dataBuffer.Begin ();

      double time = uniformRandomVariable->GetValue (0, 15);

      i.WriteU8 (energy);

      Simulator::Schedule (Seconds (time), &RawApplication::Send, rawApplication, Mac8Address (0), dataBuffer);

      node++;

    }

  Simulator::Schedule (Hours (2), &SendPacket);

}

void

Run ()

{

  Packet::EnablePrinting ();

  nodeContainer.Create (3);

  SetupPositions ();

  SetupEnergy ();

  SetupCommunications ();

  SetupApplications ();

  SendPacket ();

}

int

main (int argc, char *argv[])

{

  CommandLine cmd;

  cmd.Parse (argc, argv);

  Run ();

  Simulator::Stop (Days (60));

  Simulator::Run ();

  Simulator::Destroy ();

  return 0;

}

    obj = bld.create_ns3_program('uan-raw-example', ['internet', 'mobility', 'stats', 'applications', 'uan'])

    obj.source = 'uan-raw-example.cc'

    obj = bld.create_ns3_program('uan-ipv4-example', ['internet', 'mobility', 'stats', 'applications', 'uan'])

    obj.source = 'uan-ipv4-example.cc'

    obj = bld.create_ns3_program('uan-ipv6-example', ['internet', 'mobility', 'stats', 'applications', 'uan'])

    obj.source = 'uan-ipv6-example.cc'

    obj = bld.create_ns3_program('uan-6lowpan-example', ['internet', 'mobility', 'stats', 'applications', 'uan', 'sixlowpan'])

    obj.source = 'uan-6lowpan-example.cc'