frame-counter-update.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2017 University of Padova
 *
 * SPDX-License-Identifier: GPL-2.0-only
 *
 * Author: Davide Magrin <magrinda@dei.unipd.it>
 */
 
/*
 * This script simulates a complex scenario with multiple gateways and end
 * devices. The metric of interest for this script is the throughput of the
 * network.
 */
 
#include "ns3/core-module.h"
#include "ns3/lorawan-module.h"
#include "ns3/mobility-helper.h"
#include "ns3/point-to-point-helper.h"
 
using namespace ns3;
using namespace lorawan;
 
NS_LOG_COMPONENT_DEFINE("FrameCounterUpdateExample");
 
// Network settings
int nGateways = 1;                   //!< Number of gateway nodes to create
double simulationTimeSeconds = 3600; //!< Scenario duration (s) in simulated time
 
/**
 * Record a packet TX start by the PHY layer of an end device
 *
 * @param packet The packet being transmitted.
 * @param index Id of end device transmitting the packet.
 */
void
OnPhySentPacket(Ptr<const Packet> packet, uint32_t index)
{
    Ptr<Packet> packetCopy = packet->Copy();
 
    LorawanMacHeader mHdr;
    packetCopy->RemoveHeader(mHdr);
    LoraFrameHeader fHdr;
    packetCopy->RemoveHeader(fHdr);
 
    NS_LOG_DEBUG("Sent a packet with Frame Counter " << fHdr.GetFCnt());
    // NS_LOG_DEBUG ("MAC Header:");
    // NS_LOG_DEBUG (mHdr);
    // NS_LOG_DEBUG ("Frame Header:");
    // NS_LOG_DEBUG (fHdr);
}
 
/**
 * Trace the outcome of MAC layer's confirmed packet retransmission and acknowledgement.
 *
 * @param txCount Number of transmissions attempted during the process.
 * @param ack Whether the retransmission process led to acknowledgement.
 * @param firstAttempt Timestamp of the initial transmission attempt.
 * @param packet The packet being retransmitted.
 */
void
OnMacPacketOutcome(uint8_t txCount, bool ack, Time firstAttempt, Ptr<Packet> packet)
{
    if (ack)
    {
        NS_LOG_INFO("Packet was successfully acknowledged");
    }
    else
    {
        NS_LOG_INFO("Giving up");
    }
}
 
/**
 * Set the position of an end device as either in range or out of range.
 *
 * @param endDevice A pointer to the Node of the end device.
 * @param inRange Whether to set the end device in range or out of range.
 */
void
ChangeEndDevicePosition(Ptr<Node> endDevice, bool inRange)
{
    if (inRange)
    {
        NS_LOG_INFO("Moving end device in range");
        endDevice->GetObject<MobilityModel>()->SetPosition(Vector(0.0, 0.0, 0.0));
    }
    else
    {
        NS_LOG_INFO("Moving end device out of range");
        endDevice->GetObject<MobilityModel>()->SetPosition(Vector(10000.0, 0.0, 0.0));
    }
}
 
int
main(int argc, char* argv[])
{
    CommandLine cmd(__FILE__);
    cmd.AddValue("simulationTime", "The time (s) for which to simulate", simulationTimeSeconds);
    cmd.AddValue("MaxTransmissions", "ns3::EndDeviceLorawanMac::MaxTransmissions");
    cmd.AddValue("FType", "ns3::EndDeviceLorawanMac::FType");
    cmd.Parse(argc, argv);
 
    // Set up logging
    LogComponentEnable("FrameCounterUpdateExample", LOG_LEVEL_ALL);
 
    /***********
     *  Setup  *
     ***********/
 
    // Mobility
    MobilityHelper mobility;
    Ptr<ListPositionAllocator> allocator = CreateObject<ListPositionAllocator>();
    // Make it so that nodes are at a certain height > 0
    allocator->Add(Vector(100000.0, 0.0, 15.0)); // End device position
    allocator->Add(Vector(0.0, 0.0, 15.0));      // Gateway position
    mobility.SetPositionAllocator(allocator);
    mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
 
    /************************
     *  Create the channel  *
     ************************/
 
    // Create the lora channel object
    Ptr<LogDistancePropagationLossModel> loss = CreateObject<LogDistancePropagationLossModel>();
    loss->SetPathLossExponent(3.76);
    loss->SetReference(1, 7.7);
 
    Ptr<PropagationDelayModel> delay = CreateObject<ConstantSpeedPropagationDelayModel>();
 
    Ptr<LoraChannel> channel = CreateObject<LoraChannel>(loss, delay);
 
    /************************
     *  Create the helpers  *
     ************************/
 
    // Create the LoraPhyHelper
    LoraPhyHelper phyHelper = LoraPhyHelper();
    phyHelper.SetChannel(channel);
 
    // Create the LorawanMacHelper
    LorawanMacHelper macHelper = LorawanMacHelper();
 
    // Create the LoraHelper
    LoraHelper helper = LoraHelper();
    helper.EnablePacketTracking(); // Output filename
 
    // Create the NetworkServerHelper
    NetworkServerHelper nsHelper = NetworkServerHelper();
 
    // Create the ForwarderHelper
    ForwarderHelper forHelper = ForwarderHelper();
 
    /************************
     *  Create End Devices  *
     ************************/
 
    // Create a set of nodes
    NodeContainer endDevices;
    endDevices.Create(1);
 
    // Assign a mobility model to each node
    mobility.Install(endDevices);
 
    // Make it so that nodes are at a certain height > 0
    for (auto j = endDevices.Begin(); j != endDevices.End(); ++j)
    {
        Ptr<MobilityModel> mobility = (*j)->GetObject<MobilityModel>();
        Vector position = mobility->GetPosition();
        position.z = 1.2;
        mobility->SetPosition(position);
    }
 
    // Create the LoraNetDevices of the end devices
    uint8_t nwkId = 54;
    uint32_t nwkAddr = 1864;
    Ptr<LoraDeviceAddressGenerator> addrGen =
        CreateObject<LoraDeviceAddressGenerator>(nwkId, nwkAddr);
 
    // Create the LoraNetDevices of the end devices
    macHelper.SetAddressGenerator(addrGen);
    phyHelper.SetDeviceType(LoraPhyHelper::ED);
    macHelper.SetDeviceType(LorawanMacHelper::ED_A);
    macHelper.Set("DataRate", UintegerValue(5));
    helper.Install(phyHelper, macHelper, endDevices);
 
    // Connect trace sources
    for (auto j = endDevices.Begin(); j != endDevices.End(); ++j)
    {
        Ptr<Node> node = *j;
        Ptr<LoraNetDevice> loraNetDevice = DynamicCast<LoraNetDevice>(node->GetDevice(0));
        Ptr<LoraPhy> phy = loraNetDevice->GetPhy();
        Ptr<EndDeviceLorawanMac> mac = DynamicCast<EndDeviceLorawanMac>(loraNetDevice->GetMac());
        phy->TraceConnectWithoutContext("StartSending", MakeCallback(&OnPhySentPacket));
        mac->TraceConnectWithoutContext("ConfirmedTransmissionOutcome",
                                        MakeCallback(&OnMacPacketOutcome));
    }
 
    // Create the gateway nodes (allocate them uniformly on the disc)
    NodeContainer gateways;
    gateways.Create(nGateways);
 
    // Make it so that nodes are at a certain height > 0
    mobility.SetPositionAllocator(allocator);
    mobility.Install(gateways);
 
    // Create a netdevice for each gateway
    phyHelper.SetDeviceType(LoraPhyHelper::GW);
    macHelper.SetDeviceType(LorawanMacHelper::GW);
    helper.Install(phyHelper, macHelper, gateways);
 
    NS_LOG_INFO("Completed configuration");
 
    /*********************************************
     *  Install applications on the end devices  *
     *********************************************/
 
    Time appStopTime = Seconds(simulationTimeSeconds);
    OneShotSenderHelper appHelper = OneShotSenderHelper();
    appHelper.SetSendTime(Time(0));
    ApplicationContainer appContainer = appHelper.Install(endDevices);
    appHelper.SetSendTime(Seconds(100));
    appContainer.Add(appHelper.Install(endDevices));
    appHelper.SetSendTime(Seconds(200));
    appContainer.Add(appHelper.Install(endDevices));
 
    appContainer.Start(Time(0));
    appContainer.Stop(appStopTime);
 
    Simulator::Schedule(Seconds(110), &ChangeEndDevicePosition, endDevices.Get(0), true);
    Simulator::Schedule(Seconds(201), &ChangeEndDevicePosition, endDevices.Get(0), false);
    Simulator::Schedule(Seconds(204), &ChangeEndDevicePosition, endDevices.Get(0), true);
 
    /**************************
     *  Create network server  *
     ***************************/
 
    // Create the network server node
    Ptr<Node> networkServer = CreateObject<Node>();
 
    // PointToPoint links between gateways and server
    PointToPointHelper p2p;
    p2p.SetDeviceAttribute("DataRate", StringValue("5Mbps"));
    p2p.SetChannelAttribute("Delay", StringValue("2ms"));
    // Store network server app registration details for later
    P2PGwRegistration_t gwRegistration;
    for (auto gw = gateways.Begin(); gw != gateways.End(); ++gw)
    {
        auto container = p2p.Install(networkServer, *gw);
        auto serverP2PNetDev = DynamicCast<PointToPointNetDevice>(container.Get(0));
        gwRegistration.emplace_back(serverP2PNetDev, *gw);
    }
 
    // Create a network server for the network
    nsHelper.SetGatewaysP2P(gwRegistration);
    nsHelper.SetEndDevices(endDevices);
    nsHelper.Install(networkServer);
 
    // Create a forwarder for each gateway
    forHelper.Install(gateways);
 
    ////////////////
    // Simulation //
    ////////////////
 
    Simulator::Stop(appStopTime + Hours(1));
 
    NS_LOG_INFO("Running simulation...");
    Simulator::Run();
 
    Simulator::Destroy();
 
    ///////////////////////////
    // Print results to file //
    ///////////////////////////
 
    LoraPacketTracker& tracker = helper.GetPacketTracker();
    NS_LOG_INFO("Printing total sent MAC-layer packets and successful MAC-layer packets");
    std::cout << tracker.CountMacPacketsGlobally(Time(0), appStopTime + Hours(1)) << std::endl;
 
    return 0;
}