24#include "ns3/double.h"
25#include "ns3/internet-module.h"
26#include "ns3/ipv4-global-routing-helper.h"
27#include "ns3/network-module.h"
28#include "ns3/packet-sink-helper.h"
29#include "ns3/point-to-point-epc-helper.h"
30#include "ns3/point-to-point-helper.h"
31#include "ns3/radio-bearer-stats-calculator.h"
32#include "ns3/string.h"
33#include "ns3/udp-client-server-helper.h"
34#include <ns3/boolean.h>
35#include <ns3/constant-position-mobility-model.h>
37#include <ns3/eps-bearer.h>
38#include <ns3/ff-mac-scheduler.h>
40#include <ns3/lte-enb-net-device.h>
41#include <ns3/lte-enb-phy.h>
42#include <ns3/lte-helper.h>
43#include <ns3/lte-ue-net-device.h>
44#include <ns3/lte-ue-phy.h>
45#include <ns3/lte-ue-rrc.h>
46#include <ns3/mobility-helper.h>
47#include <ns3/net-device-container.h>
48#include <ns3/node-container.h>
49#include <ns3/object.h>
50#include <ns3/packet.h>
52#include <ns3/simulator.h>
53#include <ns3/spectrum-error-model.h>
54#include <ns3/spectrum-interference.h>
66 :
TestSuite(
"lte-fdtbfq-ff-mac-scheduler", SYSTEM)
68 NS_LOG_INFO(
"creating LenaTestFdTbfqFfMacSchedulerSuite");
70 bool errorModel =
false;
196 std::vector<double> dist1;
198 dist1.push_back(4800);
199 dist1.push_back(6000);
200 dist1.push_back(10000);
201 std::vector<uint16_t> packetSize1;
202 packetSize1.push_back(100);
203 packetSize1.push_back(100);
204 packetSize1.push_back(100);
205 packetSize1.push_back(100);
206 std::vector<uint32_t> estThrFdTbfqDl1;
207 estThrFdTbfqDl1.push_back(132000);
208 estThrFdTbfqDl1.push_back(132000);
209 estThrFdTbfqDl1.push_back(132000);
210 estThrFdTbfqDl1.push_back(132000);
222 std::vector<double> dist2;
224 dist2.push_back(4800);
225 dist2.push_back(6000);
226 dist2.push_back(10000);
227 std::vector<uint16_t> packetSize2;
228 packetSize2.push_back(300);
229 packetSize2.push_back(300);
230 packetSize2.push_back(300);
231 packetSize2.push_back(300);
232 std::vector<uint32_t> estThrFdTbfqDl2;
233 estThrFdTbfqDl2.push_back(302266);
234 estThrFdTbfqDl2.push_back(302266);
235 estThrFdTbfqDl2.push_back(302266);
236 estThrFdTbfqDl2.push_back(302266);
248 std::vector<double> dist3;
250 dist3.push_back(4800);
251 dist3.push_back(6000);
252 std::vector<uint16_t> packetSize3;
253 packetSize3.push_back(100);
254 packetSize3.push_back(200);
255 packetSize3.push_back(300);
256 std::vector<uint32_t> estThrFdTbfqDl3;
257 estThrFdTbfqDl3.push_back(132000);
258 estThrFdTbfqDl3.push_back(232000);
259 estThrFdTbfqDl3.push_back(332000);
276 std::ostringstream oss;
277 oss << nUser <<
" UEs, distance " << dist <<
" m";
287 bool errorModelEnabled)
288 :
TestCase(BuildNameString(nUser, dist)),
292 m_interval(interval),
293 m_thrRefDl(thrRefDl),
294 m_thrRefUl(thrRefUl),
295 m_errorModelEnabled(errorModelEnabled)
326 lteHelper->SetEpcHelper(epcHelper);
334 remoteHostContainer.
Create(1);
337 internet.Install(remoteHostContainer);
346 ipv4h.
SetBase(
"1.0.0.0",
"255.0.0.0");
354 remoteHostStaticRouting->AddNetworkRouteTo(
Ipv4Address(
"7.0.0.0"),
Ipv4Mask(
"255.0.0.0"), 1);
367 lteHelper->SetAttribute(
"PathlossModel",
StringValue(
"ns3::FriisSpectrumPropagationLossModel"));
377 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
378 mobility.Install(enbNodes);
379 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
380 mobility.Install(ueNodes);
385 lteHelper->SetSchedulerType(
"ns3::FdTbfqFfMacScheduler");
387 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
388 ueDevs = lteHelper->InstallUeDevice(ueNodes);
392 enbPhy->SetAttribute(
"TxPower",
DoubleValue(30.0));
393 enbPhy->SetAttribute(
"NoiseFigure",
DoubleValue(5.0));
396 for (
int i = 0; i <
m_nUser; i++)
400 mm->SetPosition(Vector(
m_dist, 0.0, 0.0));
404 uePhy->SetAttribute(
"NoiseFigure",
DoubleValue(9.0));
408 internet.Install(ueNodes);
419 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
423 lteHelper->Attach(ueDevs, enbDevs.
Get(0));
438 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer,
EpcTft::Default());
442 uint16_t dlPort = 1234;
443 uint16_t ulPort = 2000;
454 serverApps.Add(ulPacketSinkHelper.
Install(remoteHost));
469 clientApps.Add(dlClient.
Install(remoteHost));
470 clientApps.Add(ulClient.
Install(ueNodes.
Get(u)));
473 serverApps.Start(
Seconds(0.001));
474 clientApps.Start(
Seconds(0.04));
476 double statsStartTime = 0.04;
477 double statsDuration = 1;
478 double tolerance = 0.1;
481 lteHelper->EnableRlcTraces();
482 lteHelper->EnableMacTraces();
494 std::vector<uint64_t> dlDataRxed;
495 for (
int i = 0; i <
m_nUser; i++)
501 uint64_t
data = rlcStats->GetDlRxData(imsi, lcId);
502 dlDataRxed.push_back(
data);
503 NS_LOG_INFO(
"\tUser " << i <<
" imsi " << imsi <<
" bytes rxed " << (
double)dlDataRxed.at(i)
504 <<
" thr " << (
double)dlDataRxed.at(i) / statsDuration <<
" ref "
508 for (
int i = 0; i <
m_nUser; i++)
513 " Unfair Throughput!");
521 std::vector<uint64_t> ulDataRxed;
522 for (
int i = 0; i <
m_nUser; i++)
528 ulDataRxed.push_back(rlcStats->GetUlRxData(imsi, lcId));
529 NS_LOG_INFO(
"\tUser " << i <<
" imsi " << imsi <<
" bytes rxed " << (
double)ulDataRxed.at(i)
530 <<
" thr " << (
double)ulDataRxed.at(i) / statsDuration <<
" ref "
534 for (
int i = 0; i <
m_nUser; i++)
539 " Unfair Throughput!");
549 std::ostringstream oss;
550 oss <<
"distances (m) = [ ";
551 for (
auto it = dist.begin(); it != dist.end(); ++it)
560 std::vector<double> dist,
561 std::vector<uint32_t> estThrFdTbfqDl,
564 bool errorModelEnabled)
565 :
TestCase(BuildNameString(dist.size(), dist)),
566 m_nUser(dist.size()),
569 m_interval(interval),
570 m_estThrFdTbfqDl(estThrFdTbfqDl),
571 m_errorModelEnabled(errorModelEnabled)
600 lteHelper->SetEpcHelper(epcHelper);
606 remoteHostContainer.
Create(1);
609 internet.Install(remoteHostContainer);
618 ipv4h.
SetBase(
"1.0.0.0",
"255.0.0.0");
626 remoteHostStaticRouting->AddNetworkRouteTo(
Ipv4Address(
"7.0.0.0"),
Ipv4Mask(
"255.0.0.0"), 1);
631 lteHelper->SetAttribute(
"PathlossModel",
StringValue(
"ns3::FriisSpectrumPropagationLossModel"));
641 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
642 mobility.Install(enbNodes);
643 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
644 mobility.Install(ueNodes);
649 lteHelper->SetSchedulerType(
"ns3::FdTbfqFfMacScheduler");
651 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
652 ueDevs = lteHelper->InstallUeDevice(ueNodes);
656 enbPhy->SetAttribute(
"TxPower",
DoubleValue(30.0));
657 enbPhy->SetAttribute(
"NoiseFigure",
DoubleValue(5.0));
660 for (
int i = 0; i <
m_nUser; i++)
664 mm->SetPosition(Vector(
m_dist.at(i), 0.0, 0.0));
668 uePhy->SetAttribute(
"NoiseFigure",
DoubleValue(9.0));
672 internet.Install(ueNodes);
683 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
687 lteHelper->Attach(ueDevs, enbDevs.
Get(0));
696 mbrDl = mbrDl / ueNodes.
GetN();
710 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer,
EpcTft::Default());
714 uint16_t dlPort = 1234;
715 uint16_t ulPort = 2000;
726 serverApps.Add(ulPacketSinkHelper.
Install(remoteHost));
740 clientApps.Add(dlClient.
Install(remoteHost));
741 clientApps.Add(ulClient.
Install(ueNodes.
Get(u)));
744 serverApps.Start(
Seconds(0.001));
745 clientApps.Start(
Seconds(0.001));
747 double statsStartTime = 0.001;
748 double statsDuration = 1.0;
749 double tolerance = 0.1;
752 lteHelper->EnableRlcTraces();
764 std::vector<uint64_t> dlDataRxed;
765 for (
int i = 0; i <
m_nUser; i++)
771 dlDataRxed.push_back(rlcStats->GetDlRxData(imsi, lcId));
772 NS_LOG_INFO(
"\tUser " << i <<
" dist " <<
m_dist.at(i) <<
" imsi " << imsi <<
" bytes rxed "
773 << (
double)dlDataRxed.at(i) <<
" thr "
774 << (
double)dlDataRxed.at(i) / statsDuration <<
" ref " <<
m_nUser);
777 for (
int i = 0; i <
m_nUser; i++)
782 " Unfair Throughput!");
This system test program creates different test cases with a single eNB and several UEs,...
static std::string BuildNameString(uint16_t nUser, double dist)
Builds the test name string based on provided parameter values.
uint16_t m_nUser
number of UE nodes
double m_thrRefUl
UL throughput reference.
LenaFdTbfqFfMacSchedulerTestCase1(uint16_t nUser, double dist, double thrRefDl, double thrRefUl, uint16_t packetSize, uint16_t interval, bool errorModelEnabled)
Constructor.
void DoRun() override
Implementation to actually run this TestCase.
double m_thrRefDl
DL throughput reference.
uint16_t m_packetSize
packet size in bytes
~LenaFdTbfqFfMacSchedulerTestCase1() override
uint16_t m_interval
interval time in ms
double m_dist
distance between the nodes
bool m_errorModelEnabled
whether the error model is enabled
Test case is similar to the one defined in LenaFdTbfqFfMacSchedulerTestCase1, with the difference tha...
bool m_errorModelEnabled
error model enabled?
void DoRun() override
Implementation to actually run this TestCase.
std::vector< uint32_t > m_estThrFdTbfqDl
estimated thrpughput FDTBFQ DL
uint16_t m_interval
interval time in ms
uint16_t m_nUser
number of UE nodes
static std::string BuildNameString(uint16_t nUser, std::vector< double > dist)
Builds the test name string based on provided parameter values.
std::vector< double > m_dist
distance between the nodes
std::vector< uint16_t > m_packetSize
packet size in bytes
LenaFdTbfqFfMacSchedulerTestCase2(std::vector< double > dist, std::vector< uint32_t > estThrFdTbfqDl, std::vector< uint16_t > packetSize, uint16_t interval, bool errorModelEnabled)
Constructor.
~LenaFdTbfqFfMacSchedulerTestCase2() override
Test suit for FdTbfqFfMacScheduler test.
LenaTestFdTbfqFfMacSchedulerSuite()
holds a vector of ns3::Application pointers.
AttributeValue implementation for Boolean.
Mobility model for which the current position does not change once it has been set and until it is se...
Class for representing data rates.
AttributeValue implementation for DataRate.
This class can be used to hold variables of floating point type such as 'double' or 'float'.
Hold variables of type enum.
static Ptr< EpcTft > Default()
creates a TFT matching any traffic
This class contains the specification of EPS Bearers.
@ GBR_CONV_VOICE
GBR Conversational Voice.
aggregate IP/TCP/UDP functionality to existing Nodes.
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
Ipv4 addresses are stored in host order in this class.
static Ipv4Address GetAny()
Access to the IPv4 forwarding table, interfaces, and configuration.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const
a class to represent an Ipv4 address mask
Helper class that adds ns3::Ipv4StaticRouting objects.
Ptr< Ipv4StaticRouting > GetStaticRouting(Ptr< Ipv4 > ipv4) const
Try and find the static routing protocol as either the main routing protocol or in the list of routin...
The eNodeB device implementation.
The LteUeNetDevice class implements the UE net device.
Helper class used to assign positions and mobility models to nodes.
holds a vector of ns3::NetDevice pointers
Ptr< NetDevice > Get(uint32_t i) const
Get the Ptr<NetDevice> stored in this container at a given index.
keep track of a set of node pointers.
uint32_t GetN() const
Get the number of Ptr<Node> stored in this container.
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
Ptr< T > GetObject() const
Get a pointer to the requested aggregated Object.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
ApplicationContainer Install(NodeContainer c) const
Install an ns3::PacketSinkApplication on each node of the input container configured with all the att...
Build a set of PointToPointNetDevice objects.
void SetDeviceAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each NetDevice created by the helper.
void SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
NetDeviceContainer Install(NodeContainer c)
Smart pointer class similar to boost::intrusive_ptr.
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
static void Run()
Run the simulation.
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Hold variables of type string.
@ EXTENSIVE
Medium length test.
void AddTestCase(TestCase *testCase, TestDuration duration=QUICK)
Add an individual child TestCase to this test suite.
std::string CreateTempDirFilename(std::string filename)
Construct the full path to a file in a temporary directory.
std::string GetName() const
AttributeValue implementation for Time.
Create a client application which sends UDP packets carrying a 32bit sequence number and a 64 bit tim...
void SetAttribute(std::string name, const AttributeValue &value)
Record an attribute to be set in each Application after it is is created.
ApplicationContainer Install(NodeContainer c)
Hold an unsigned integer type.
void SetDefault(std::string name, const AttributeValue &value)
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
static LenaTestFdTbfqFfMacSchedulerSuite lenaTestFdTbfqFfMacSchedulerSuite
Static variable for test initialization.
#define NS_TEST_ASSERT_MSG_EQ_TOL(actual, limit, tol, msg)
Test that actual and expected (limit) values are equal to plus or minus some tolerance and report and...
Time Seconds(double value)
Construct a Time in the indicated unit.
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
static const uint32_t packetSize
Packet size generated at the AP.