/* -*- 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/uan-application-helper.h"

#include "ns3/uan-application.h"

using namespace ns3;

NS_LOG_COMPONENT_DEFINE ("UanApplicationExample");

void SetupPositions ();

void SetupEnergy ();

void SetupCommunications ();

void PrintReceivedPacket (UanAddress 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 iterator = nodeContainer.Begin ();

  while (iterator != nodeContainer.End ())

    {

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

      iterator++;

    }

  AcousticModemEnergyModelHelper acousticModemEnergyModelHelper;

  acousticModemEnergyModelHelper.Install (netDeviceContainer, energySourceContainer);

}

void

PrintReceivedPacket (UanAddress src, Buffer data)

{

  std::cout << Simulator::Now ().GetSeconds () << "|" << "Node#" << (int)(src.GetAsInt ()) << "|Energy:" << (int)((data.PeekData ())[0]) << "%" << std::endl;

}

void

SetupApplications ()

{

  UanApplicationHelper uanApplicationHelper;

  ApplicationContainer applicationContainer;

  applicationContainer = uanApplicationHelper.Install (nodeContainer);

  applicationContainer.Start (Seconds (0));

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

  while (node != nodeContainer.End ())

    {

      Ptr<UanApplication> uanApplication = (*node)->GetApplication (0)->GetObject<UanApplication> ();

      uanApplication->SetPacketReceivedCallback (MakeCallback<void, UanAddress, Buffer>(&PrintReceivedPacket));

      node++;

    }

}

void

SendPacket ()

{

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

  while (node != nodeContainer.End ())

    {

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

      Ptr<UanApplication> uanApplication = (*node)->GetApplication (0)->GetObject<UanApplication> ();

      Buffer dataBuffer;

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

      i.Write (&energy, 1);

      Simulator::Schedule (Seconds ((*node)->GetId ()), &UanApplication::Send, uanApplication, UanAddress (0), dataBuffer);

      node++;

    }

  Simulator::Schedule (Seconds (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 (Hours (24));

  Simulator::Run ();

  Simulator::Destroy ();

  return 0;

}

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

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

/* -*- 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 "uan-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/uan-application.h"

namespace ns3 {

UanApplicationHelper::UanApplicationHelper ()

{

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

}

void 

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

{

  m_factory.Set (name, value);

}

ApplicationContainer

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

{

  return ApplicationContainer (InstallPriv (node));

}

ApplicationContainer

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

{

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

  return ApplicationContainer (InstallPriv (node));

}

ApplicationContainer

UanApplicationHelper::Install (NodeContainer c) const

{

  ApplicationContainer apps;

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

    {

      apps.Add (InstallPriv (*i));

    }

  return apps;

}

Ptr<Application>

UanApplicationHelper::InstallPriv (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 UANAPPLICATION_HELPER_H

#define UANAPPLICATION_HELPER_H

#include "ns3/object-factory.h"

#include "ns3/attribute.h"

#include "ns3/node-container.h"

#include "ns3/application-container.h"

namespace ns3 {

/**

 * \ingroup uan

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

 * on a set of nodes.

 */

class UanApplicationHelper

{

public:

  /**

   * Create an UanApplicationHelper to make it easier to work with UanApplication

   */

  UanApplicationHelper ();

  /**

   * Helper function used to set the underlying application attributes.

   */

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

  /**

   * Install an ns3::UanApplication 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 an UanApplication 

   * will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (NodeContainer c) const;

  /**

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

   * attributes set with SetAttribute.

   *

   * \param node The node on which an UanApplication will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (Ptr<Node> node) const;

  /**

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

   * attributes set with SetAttribute.

   *

   * \param nodeName The node on which an UanApplication will be installed.

   * \returns Container of Ptr to the applications installed.

   */

  ApplicationContainer Install (std::string nodeName) const;

private:

  /**

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

   * attributes set with SetAttribute.

   *

   * \param node The node on which an UanApplication will be installed.

   * \returns Ptr to the application installed.

   */

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

  ObjectFactory m_factory; //!< Object factory.

};

} // namespace ns3

#endif /* UANAPPLICATION_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 "uan-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 ("UanApplication");

NS_OBJECT_ENSURE_REGISTERED (UanApplication);

TypeId 

UanApplication::GetTypeId (void)

{

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

    .SetParent<Application> ()

    .SetGroupName ("Applications")

    .AddConstructor<UanApplication> ()

  ;

  return tid;

}

UanApplication::UanApplication ()

{

  NS_LOG_FUNCTION (this);

  m_socket = NULL;

  m_packetReceivedCallback.Nullify ();

}

UanApplication::~UanApplication ()

{

  NS_LOG_FUNCTION (this);

}

void

UanApplication::DoDispose (void)

{

  NS_LOG_FUNCTION (this);

  m_socket = NULL;

  m_packetReceivedCallback.Nullify ();

  Application::DoDispose ();

}

uint32_t

UanApplication::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 

UanApplication::Send (UanAddress dst, const Buffer dataBuffer)

{

  NS_LOG_FUNCTION (this);

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

  uint8_t *address_buffer = new uint8_t[address.GetLength ()];

  address.CopyTo (address_buffer);

  UanAddress local_address = UanAddress (address_buffer[address.GetLength () -1]);

  delete [] address_buffer;

  const uint8_t * data = dataBuffer.PeekData ();

  if(dst.GetAsInt () != local_address.GetAsInt ())

    { 

      PacketSocketAddress socketAddress;

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

      socketAddress.SetPhysicalAddress (dst);

      socketAddress.SetProtocol (0);

      Ptr<Socket> socket = Socket::CreateSocket (GetNode (), TypeId::LookupByName ("ns3::PacketSocketFactory"));

      Ptr<Packet> p = Create<Packet> (data, dataBuffer.GetSize () + 1);

      NS_ASSERT (socket != NULL);

      socket->Bind ();

      socket->Connect (socketAddress);

      socket->Send (p);

      socket->Close ();

    }

}

void

UanApplication::Receive (Ptr<Socket> socket)

{

  NS_LOG_FUNCTION (this << socket);

  NS_ASSERT (m_socket != NULL);

  while (m_socket->GetRxAvailable () > 0)

    {

      Ptr<Packet> p = m_socket->Recv ();

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

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

      UanAddress src_address;

      PacketTagIterator i = p->GetPacketTagIterator ();

      while (i.HasNext ())

        {

          PacketTagIterator::Item item = i.Next ();

          if (item.GetTypeId () == TypeId::LookupByName ("ns3::SocketAddressTag"))

            {

              SocketAddressTag tag;

              item.GetTag (tag);

              Address address = tag.GetAddress ();

              uint8_t *address_buffer = new uint8_t[address.GetLength ()];

              address.CopyTo (address_buffer);

              src_address = UanAddress (address_buffer[address.GetLength () -1]);

              delete [] address_buffer;

            }

        }

      if(!m_packetReceivedCallback.IsNull ())

        {

          Buffer dataBuffer;

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

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

          m_packetReceivedCallback (src_address, dataBuffer);

        }

      delete[] buffer;

    }

} 

void 

UanApplication::StartApplication (void)

{

  NS_LOG_FUNCTION (this);

  PacketSocketAddress socketAddress;

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

  socketAddress.SetPhysicalAddress (UanAddress (UanAddress::GetBroadcast ()));

  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 (&UanApplication::Receive, this));

}

void 

UanApplication::StopApplication (void)

{

  NS_LOG_FUNCTION (this);

  if(m_socket != NULL)

    {

      m_socket->Close ();

    }

  else

    {

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

    }

}

void

UanApplication::SetPacketReceivedCallback (PacketReceivedCallback callback)

{

  NS_LOG_FUNCTION (this);

  if (callback.IsNull ())

    {

      NS_LOG_DEBUG ("AuvWaypointMobilityModel: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 UANAPPLICATION_H

#define UANAPPLICATION_H

#include "ns3/application.h"

#include "ns3/packet.h"

#include "ns3/uan-address.h"

#include "ns3/socket.h"

namespace ns3 {

/**

 * \ingroup uan

 * \brief a simple application to be used in UAN networks

 */

class UanApplication : public Application

{

public:

  typedef Callback<void, UanAddress, Buffer> PacketReceivedCallback;

  /**

   * \brief Get the type ID.

   * \return the object TypeId

   */

  static TypeId GetTypeId (void);

  /**

   * create a uan application

   */

  UanApplication ();

  virtual ~UanApplication ();

  /**

   * \brief Send a packet to the destination

   * \param dst the destination UAN address

   * \param dataBuffer the data to be sent

   */

  void Send (UanAddress 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 /* UANAPPLICATION_H */

		'model/uan-application.cc',

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

		'model/uan-application.h',

		'model/uan-mac-rc-gw.h',