26#include "ns3/double.h"
27#include "ns3/internet-module.h"
28#include "ns3/ipv4-global-routing-helper.h"
29#include "ns3/network-module.h"
30#include "ns3/packet-sink-helper.h"
31#include "ns3/point-to-point-epc-helper.h"
32#include "ns3/point-to-point-helper.h"
33#include "ns3/radio-bearer-stats-calculator.h"
34#include "ns3/string.h"
35#include "ns3/udp-client-server-helper.h"
36#include <ns3/boolean.h>
37#include <ns3/constant-position-mobility-model.h>
39#include <ns3/eps-bearer.h>
40#include <ns3/ff-mac-scheduler.h>
42#include <ns3/lte-enb-net-device.h>
43#include <ns3/lte-enb-phy.h>
44#include <ns3/lte-helper.h>
45#include <ns3/lte-ue-net-device.h>
46#include <ns3/lte-ue-phy.h>
47#include <ns3/lte-ue-rrc.h>
48#include <ns3/mobility-helper.h>
49#include <ns3/net-device-container.h>
50#include <ns3/node-container.h>
51#include <ns3/object.h>
52#include <ns3/packet.h>
54#include <ns3/simulator.h>
55#include <ns3/spectrum-error-model.h>
56#include <ns3/spectrum-interference.h>
68 :
TestSuite(
"lte-cqa-ff-mac-scheduler", SYSTEM)
70 NS_LOG_INFO(
"creating LenaTestCqaFfMacSchedulerSuite");
72 bool errorModel =
false;
198 std::vector<double> dist1;
200 dist1.push_back(4800);
201 dist1.push_back(6000);
202 dist1.push_back(10000);
203 std::vector<uint16_t> packetSize1;
204 packetSize1.push_back(100);
205 packetSize1.push_back(100);
206 packetSize1.push_back(100);
207 packetSize1.push_back(100);
208 std::vector<uint32_t> estThrCqaDl1;
209 estThrCqaDl1.push_back(132000);
210 estThrCqaDl1.push_back(132000);
211 estThrCqaDl1.push_back(132000);
212 estThrCqaDl1.push_back(132000);
223 std::vector<double> dist2;
225 dist2.push_back(4800);
226 dist2.push_back(6000);
227 dist2.push_back(10000);
228 std::vector<uint16_t> packetSize2;
229 packetSize2.push_back(200);
230 packetSize2.push_back(200);
231 packetSize2.push_back(200);
232 packetSize2.push_back(200);
233 std::vector<uint32_t> estThrCqaDl2;
234 estThrCqaDl2.push_back(230000);
235 estThrCqaDl2.push_back(230000);
236 estThrCqaDl2.push_back(230000);
237 estThrCqaDl2.push_back(230000);
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> estThrCqaDl3;
257 estThrCqaDl3.push_back(132000);
258 estThrCqaDl3.push_back(232000);
259 estThrCqaDl3.push_back(332000);
275 std::ostringstream oss;
276 oss << nUser <<
" UEs, distance " << dist <<
" m";
286 bool errorModelEnabled)
287 :
TestCase(BuildNameString(nUser, dist)),
291 m_interval(interval),
292 m_thrRefDl(thrRefDl),
293 m_thrRefUl(thrRefUl),
294 m_errorModelEnabled(errorModelEnabled)
325 lteHelper->SetEpcHelper(epcHelper);
333 remoteHostContainer.
Create(1);
336 internet.Install(remoteHostContainer);
345 ipv4h.
SetBase(
"1.0.0.0",
"255.0.0.0");
353 remoteHostStaticRouting->AddNetworkRouteTo(
Ipv4Address(
"7.0.0.0"),
Ipv4Mask(
"255.0.0.0"), 1);
366 lteHelper->SetAttribute(
"PathlossModel",
StringValue(
"ns3::FriisSpectrumPropagationLossModel"));
376 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
377 mobility.Install(enbNodes);
378 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
379 mobility.Install(ueNodes);
384 lteHelper->SetSchedulerType(
"ns3::CqaFfMacScheduler");
386 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
387 ueDevs = lteHelper->InstallUeDevice(ueNodes);
391 enbPhy->SetAttribute(
"TxPower",
DoubleValue(30.0));
392 enbPhy->SetAttribute(
"NoiseFigure",
DoubleValue(5.0));
395 for (
int i = 0; i <
m_nUser; i++)
399 mm->SetPosition(Vector(
m_dist, 0.0, 0.0));
403 uePhy->SetAttribute(
"NoiseFigure",
DoubleValue(9.0));
407 internet.Install(ueNodes);
418 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
422 lteHelper->Attach(ueDevs, enbDevs.
Get(0));
437 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer,
EpcTft::Default());
441 uint16_t dlPort = 1234;
442 uint16_t ulPort = 2000;
453 serverApps.Add(ulPacketSinkHelper.
Install(remoteHost));
467 clientApps.Add(dlClient.
Install(remoteHost));
468 clientApps.Add(ulClient.
Install(ueNodes.
Get(u)));
471 serverApps.Start(
Seconds(0.030));
472 clientApps.Start(
Seconds(0.030));
474 double statsStartTime = 0.300;
475 double statsDuration = 0.6;
476 double tolerance = 0.1;
479 lteHelper->EnableRlcTraces();
480 lteHelper->EnableMacTraces();
488 std::vector<uint64_t> dlDataRxed;
489 for (
int i = 0; i <
m_nUser; i++)
495 uint64_t
data = rlcStats->GetDlRxData(imsi, lcId);
496 dlDataRxed.push_back(
data);
497 NS_LOG_INFO(
"\tUser " << i <<
" imsi " << imsi <<
" bytes rxed " << (
double)dlDataRxed.at(i)
498 <<
" thr " << (
double)dlDataRxed.at(i) / statsDuration <<
" ref "
502 for (
int i = 0; i <
m_nUser; i++)
507 " Unfair Throughput!");
515 std::vector<uint64_t> ulDataRxed;
516 for (
int i = 0; i <
m_nUser; i++)
522 ulDataRxed.push_back(rlcStats->GetUlRxData(imsi, lcId));
523 NS_LOG_INFO(
"\tUser " << i <<
" imsi " << imsi <<
" bytes rxed " << (
double)ulDataRxed.at(i)
524 <<
" thr " << (
double)ulDataRxed.at(i) / statsDuration <<
" ref "
528 for (
int i = 0; i <
m_nUser; i++)
533 " Unfair Throughput!");
543 std::ostringstream oss;
544 oss <<
"distances (m) = [ ";
545 for (
auto it = dist.begin(); it != dist.end(); ++it)
554 std::vector<uint32_t> estThrCqaDl,
557 bool errorModelEnabled)
558 :
TestCase(BuildNameString(dist.size(), dist)),
559 m_nUser(dist.size()),
562 m_interval(interval),
563 m_estThrCqaDl(estThrCqaDl),
564 m_errorModelEnabled(errorModelEnabled)
593 lteHelper->SetEpcHelper(epcHelper);
599 remoteHostContainer.
Create(1);
602 internet.Install(remoteHostContainer);
611 ipv4h.
SetBase(
"1.0.0.0",
"255.0.0.0");
619 remoteHostStaticRouting->AddNetworkRouteTo(
Ipv4Address(
"7.0.0.0"),
Ipv4Mask(
"255.0.0.0"), 1);
624 lteHelper->SetAttribute(
"PathlossModel",
StringValue(
"ns3::FriisSpectrumPropagationLossModel"));
634 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
635 mobility.Install(enbNodes);
636 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
637 mobility.Install(ueNodes);
642 lteHelper->SetSchedulerType(
"ns3::CqaFfMacScheduler");
644 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
645 ueDevs = lteHelper->InstallUeDevice(ueNodes);
649 enbPhy->SetAttribute(
"TxPower",
DoubleValue(30.0));
650 enbPhy->SetAttribute(
"NoiseFigure",
DoubleValue(5.0));
653 for (
int i = 0; i <
m_nUser; i++)
657 mm->SetPosition(Vector(
m_dist.at(i), 0.0, 0.0));
661 uePhy->SetAttribute(
"NoiseFigure",
DoubleValue(9.0));
665 internet.Install(ueNodes);
676 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
680 lteHelper->Attach(ueDevs, enbDevs.
Get(0));
696 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer,
EpcTft::Default());
700 uint16_t dlPort = 1234;
701 uint16_t ulPort = 2000;
712 serverApps.Add(ulPacketSinkHelper.
Install(remoteHost));
726 clientApps.Add(dlClient.
Install(remoteHost));
727 clientApps.Add(ulClient.
Install(ueNodes.
Get(u)));
730 serverApps.Start(
Seconds(0.030));
731 clientApps.Start(
Seconds(0.030));
733 double statsStartTime = 0.04;
734 double statsDuration = 0.5;
735 double tolerance = 0.1;
738 lteHelper->EnableRlcTraces();
751 std::vector<uint64_t> dlDataRxed;
752 for (
int i = 0; i <
m_nUser; i++)
758 dlDataRxed.push_back(rlcStats->GetDlRxData(imsi, lcId));
759 NS_LOG_INFO(
"\tUser " << i <<
" dist " <<
m_dist.at(i) <<
" imsi " << imsi <<
" bytes rxed "
760 << (
double)dlDataRxed.at(i) <<
" thr "
761 << (
double)dlDataRxed.at(i) / statsDuration <<
" ref "
765 for (
int i = 0; i <
m_nUser; i++)
770 " Unfair Throughput!");
This is a system test program.
double m_dist
distance between the nodes
~LenaCqaFfMacSchedulerTestCase1() override
uint16_t m_interval
interval time in ms
double m_thrRefUl
estimated uplink throughput
uint16_t m_nUser
number of UE nodes
void DoRun() override
Implementation to actually run this TestCase.
uint16_t m_packetSize
packet size in bytes
LenaCqaFfMacSchedulerTestCase1(uint16_t nUser, double dist, double thrRefDl, double thrRefUl, uint16_t packetSize, uint16_t interval, bool errorModelEnabled)
Constructor.
double m_thrRefDl
estimated downlink throughput
static std::string BuildNameString(uint16_t nUser, double dist)
Builds the test name string based on provided parameter values.
bool m_errorModelEnabled
whether error model is enabled
This is a system test program.
uint16_t m_nUser
number of UE nodes
bool m_errorModelEnabled
whether the error model is enabled
uint16_t m_interval
UDP interval time in ms.
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
~LenaCqaFfMacSchedulerTestCase2() override
LenaCqaFfMacSchedulerTestCase2(std::vector< double > dist, std::vector< uint32_t > estThrCqaDl, std::vector< uint16_t > packetSize, uint16_t interval, bool errorModelEnabled)
Constructor.
std::vector< uint16_t > m_packetSize
packet size in bytes
std::vector< uint32_t > m_estThrCqaDl
estimated throughput CQA DL
void DoRun() override
Implementation to actually run this TestCase.
The test suite for testing CQA scheduler functionality.
LenaTestCqaFfMacSchedulerSuite()
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 LenaTestCqaFfMacSchedulerSuite lenaTestCqaFfMacSchedulerSuite
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.