packet-socket-apps-test-suite.cc

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
 * Copyright (c) 2014 Universita' di Firenze
 * 
 * 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: Tommaso Pecorella <tommaso.pecorella@unifi.it>
 */

#include "ns3/test.h"
#include "ns3/simulator.h"
#include "ns3/uinteger.h"
#include "ns3/traced-callback.h"
#include "ns3/packet.h"
#include "ns3/packet-socket-helper.h"
#include "ns3/packet-socket-client.h"
#include "ns3/packet-socket-server.h"
#include "ns3/simple-net-device.h"
#include "ns3/simple-channel.h"

using namespace ns3;


class PacketSocketAppsTest : public TestCase
{
  uint32_t m_receivedPacketSize;    
  uint32_t m_receivedPacketNumber;  

public:
  virtual void DoRun (void);
  PacketSocketAppsTest ();

  void ReceivePkt (Ptr<const Packet> packet, const Address &from);
};

PacketSocketAppsTest::PacketSocketAppsTest ()
  : TestCase ("Packet Socket Apps test")
{
  m_receivedPacketSize = 0;
  m_receivedPacketNumber = 0;
}

void PacketSocketAppsTest::ReceivePkt (Ptr<const Packet> packet, const Address &from)
{
  if (packet)
    {
      m_receivedPacketSize = packet->GetSize ();
      m_receivedPacketNumber++;
    }
}


void
PacketSocketAppsTest::DoRun (void)
{
  // Create topology

  NodeContainer nodes;
  nodes.Create (2);

  PacketSocketHelper packetSocket;

  // give packet socket powers to nodes.
  packetSocket.Install (nodes);

  Ptr<SimpleNetDevice> txDev;
  txDev = CreateObject<SimpleNetDevice> ();
  nodes.Get (0)->AddDevice (txDev);

  Ptr<SimpleNetDevice> rxDev;
  rxDev = CreateObject<SimpleNetDevice> ();
  nodes.Get (1)->AddDevice (rxDev);

  Ptr<SimpleChannel> channel = CreateObject<SimpleChannel> ();
  txDev->SetChannel (channel);
  rxDev->SetChannel (channel);
  txDev->SetNode (nodes.Get (0));
  rxDev->SetNode (nodes.Get (1));


  PacketSocketAddress socketAddr;
  socketAddr.SetSingleDevice (txDev->GetIfIndex ());
  socketAddr.SetPhysicalAddress (rxDev->GetAddress ());
  socketAddr.SetProtocol (1);

  Ptr<PacketSocketClient> client = CreateObject<PacketSocketClient> ();
  client->SetRemote (socketAddr);
  client->SetAttribute ("PacketSize", UintegerValue (1000));
  client->SetAttribute ("MaxPackets", UintegerValue (3));
  nodes.Get (0)->AddApplication (client);

  Ptr<PacketSocketServer> server = CreateObject<PacketSocketServer> ();
  server->TraceConnectWithoutContext ("Rx", MakeCallback (&PacketSocketAppsTest::ReceivePkt, this));
  server->SetLocal (socketAddr);
  nodes.Get (1)->AddApplication (server);


  Simulator::Run ();
  Simulator::Destroy ();

  NS_TEST_EXPECT_MSG_EQ (m_receivedPacketNumber, 3, "Number of packet received");
  NS_TEST_EXPECT_MSG_EQ (m_receivedPacketSize, 1000, "Size of packet received");
}


class PacketSocketAppsTestSuite : public TestSuite
{
public:
  PacketSocketAppsTestSuite () : TestSuite ("packet-socket-apps", UNIT)
  {
    AddTestCase (new PacketSocketAppsTest, TestCase::QUICK);
  }
};

static PacketSocketAppsTestSuite g_packetSocketAppsTestSuite;