packet-socket-apps-test-suite.cc

Go to the documentation of this file.

/*
 * 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/packet-socket-client.h"
#include "ns3/packet-socket-helper.h"
#include "ns3/packet-socket-server.h"
#include "ns3/packet.h"
#include "ns3/simple-channel.h"
#include "ns3/simple-net-device.h"
#include "ns3/simulator.h"
#include "ns3/test.h"
#include "ns3/traced-callback.h"
#include "ns3/uinteger.h"
 
using namespace ns3;
 
class PacketSocketAppsTest : public TestCase
{
    uint32_t m_receivedPacketSize;   
    uint32_t m_receivedPacketNumber; 
 
  public:
    void DoRun() override;
    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()
{
    // 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;