26#include "ns3/applications-module.h"
27#include "ns3/double.h"
28#include "ns3/internet-module.h"
29#include "ns3/ipv4-global-routing-helper.h"
30#include "ns3/network-module.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/boolean.h>
36#include <ns3/constant-position-mobility-model.h>
38#include <ns3/eps-bearer.h>
39#include <ns3/ff-mac-scheduler.h>
41#include <ns3/lte-enb-net-device.h>
42#include <ns3/lte-enb-phy.h>
43#include <ns3/lte-helper.h>
44#include <ns3/lte-ue-net-device.h>
45#include <ns3/lte-ue-phy.h>
46#include <ns3/lte-ue-rrc.h>
47#include <ns3/mobility-helper.h>
48#include <ns3/net-device-container.h>
49#include <ns3/node-container.h>
50#include <ns3/object.h>
51#include <ns3/packet.h>
53#include <ns3/simulator.h>
54#include <ns3/spectrum-error-model.h>
55#include <ns3/spectrum-interference.h>
67 :
TestSuite(
"lte-cqa-ff-mac-scheduler", SYSTEM)
69 NS_LOG_INFO(
"creating LenaTestCqaFfMacSchedulerSuite");
71 bool errorModel =
false;
197 std::vector<double> dist1;
199 dist1.push_back(4800);
200 dist1.push_back(6000);
201 dist1.push_back(10000);
202 std::vector<uint16_t> packetSize1;
203 packetSize1.push_back(100);
204 packetSize1.push_back(100);
205 packetSize1.push_back(100);
206 packetSize1.push_back(100);
207 std::vector<uint32_t> estThrCqaDl1;
208 estThrCqaDl1.push_back(132000);
209 estThrCqaDl1.push_back(132000);
210 estThrCqaDl1.push_back(132000);
211 estThrCqaDl1.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(200);
229 packetSize2.push_back(200);
230 packetSize2.push_back(200);
231 packetSize2.push_back(200);
232 std::vector<uint32_t> estThrCqaDl2;
233 estThrCqaDl2.push_back(230000);
234 estThrCqaDl2.push_back(230000);
235 estThrCqaDl2.push_back(230000);
236 estThrCqaDl2.push_back(230000);
247 std::vector<double> dist3;
249 dist3.push_back(4800);
250 dist3.push_back(6000);
251 std::vector<uint16_t> packetSize3;
252 packetSize3.push_back(100);
253 packetSize3.push_back(200);
254 packetSize3.push_back(300);
255 std::vector<uint32_t> estThrCqaDl3;
256 estThrCqaDl3.push_back(132000);
257 estThrCqaDl3.push_back(232000);
258 estThrCqaDl3.push_back(332000);
274 std::ostringstream oss;
275 oss << nUser <<
" UEs, distance " << dist <<
" m";
285 bool errorModelEnabled)
286 :
TestCase(BuildNameString(nUser, dist)),
290 m_interval(interval),
291 m_thrRefDl(thrRefDl),
292 m_thrRefUl(thrRefUl),
293 m_errorModelEnabled(errorModelEnabled)
324 lteHelper->SetEpcHelper(epcHelper);
332 remoteHostContainer.
Create(1);
335 internet.Install(remoteHostContainer);
344 ipv4h.
SetBase(
"1.0.0.0",
"255.0.0.0");
352 remoteHostStaticRouting->AddNetworkRouteTo(
Ipv4Address(
"7.0.0.0"),
Ipv4Mask(
"255.0.0.0"), 1);
365 lteHelper->SetAttribute(
"PathlossModel",
StringValue(
"ns3::FriisSpectrumPropagationLossModel"));
375 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
376 mobility.Install(enbNodes);
377 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
378 mobility.Install(ueNodes);
383 lteHelper->SetSchedulerType(
"ns3::CqaFfMacScheduler");
385 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
386 ueDevs = lteHelper->InstallUeDevice(ueNodes);
390 enbPhy->SetAttribute(
"TxPower",
DoubleValue(30.0));
391 enbPhy->SetAttribute(
"NoiseFigure",
DoubleValue(5.0));
394 for (
int i = 0; i <
m_nUser; i++)
398 mm->SetPosition(Vector(
m_dist, 0.0, 0.0));
402 uePhy->SetAttribute(
"NoiseFigure",
DoubleValue(9.0));
406 internet.Install(ueNodes);
417 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
421 lteHelper->Attach(ueDevs, enbDevs.
Get(0));
436 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer,
EpcTft::Default());
440 uint16_t dlPort = 1234;
441 uint16_t ulPort = 2000;
452 serverApps.Add(ulPacketSinkHelper.
Install(remoteHost));
466 clientApps.Add(dlClient.
Install(remoteHost));
467 clientApps.Add(ulClient.
Install(ueNodes.
Get(u)));
470 serverApps.Start(
Seconds(0.030));
471 clientApps.Start(
Seconds(0.030));
473 double statsStartTime = 0.300;
474 double statsDuration = 0.6;
475 double tolerance = 0.1;
478 lteHelper->EnableRlcTraces();
479 lteHelper->EnableMacTraces();
487 std::vector<uint64_t> dlDataRxed;
488 for (
int i = 0; i <
m_nUser; i++)
494 uint64_t
data = rlcStats->GetDlRxData(imsi, lcId);
495 dlDataRxed.push_back(
data);
496 NS_LOG_INFO(
"\tUser " << i <<
" imsi " << imsi <<
" bytes rxed " << (
double)dlDataRxed.at(i)
497 <<
" thr " << (
double)dlDataRxed.at(i) / statsDuration <<
" ref "
501 for (
int i = 0; i <
m_nUser; i++)
506 " Unfair Throughput!");
514 std::vector<uint64_t> ulDataRxed;
515 for (
int i = 0; i <
m_nUser; i++)
521 ulDataRxed.push_back(rlcStats->GetUlRxData(imsi, lcId));
522 NS_LOG_INFO(
"\tUser " << i <<
" imsi " << imsi <<
" bytes rxed " << (
double)ulDataRxed.at(i)
523 <<
" thr " << (
double)ulDataRxed.at(i) / statsDuration <<
" ref "
527 for (
int i = 0; i <
m_nUser; i++)
532 " Unfair Throughput!");
542 std::ostringstream oss;
543 oss <<
"distances (m) = [ ";
544 for (std::vector<double>::iterator it = dist.begin(); it != dist.end(); ++it)
553 std::vector<uint32_t> estThrCqaDl,
556 bool errorModelEnabled)
557 :
TestCase(BuildNameString(dist.size(), dist)),
558 m_nUser(dist.size()),
561 m_interval(interval),
562 m_estThrCqaDl(estThrCqaDl),
563 m_errorModelEnabled(errorModelEnabled)
592 lteHelper->SetEpcHelper(epcHelper);
598 remoteHostContainer.
Create(1);
601 internet.Install(remoteHostContainer);
610 ipv4h.
SetBase(
"1.0.0.0",
"255.0.0.0");
618 remoteHostStaticRouting->AddNetworkRouteTo(
Ipv4Address(
"7.0.0.0"),
Ipv4Mask(
"255.0.0.0"), 1);
623 lteHelper->SetAttribute(
"PathlossModel",
StringValue(
"ns3::FriisSpectrumPropagationLossModel"));
633 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
634 mobility.Install(enbNodes);
635 mobility.SetMobilityModel(
"ns3::ConstantPositionMobilityModel");
636 mobility.Install(ueNodes);
641 lteHelper->SetSchedulerType(
"ns3::CqaFfMacScheduler");
643 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
644 ueDevs = lteHelper->InstallUeDevice(ueNodes);
648 enbPhy->SetAttribute(
"TxPower",
DoubleValue(30.0));
649 enbPhy->SetAttribute(
"NoiseFigure",
DoubleValue(5.0));
652 for (
int i = 0; i <
m_nUser; i++)
656 mm->SetPosition(Vector(
m_dist.at(i), 0.0, 0.0));
660 uePhy->SetAttribute(
"NoiseFigure",
DoubleValue(9.0));
664 internet.Install(ueNodes);
675 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
679 lteHelper->Attach(ueDevs, enbDevs.
Get(0));
695 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer,
EpcTft::Default());
699 uint16_t dlPort = 1234;
700 uint16_t ulPort = 2000;
711 serverApps.Add(ulPacketSinkHelper.
Install(remoteHost));
725 clientApps.Add(dlClient.
Install(remoteHost));
726 clientApps.Add(ulClient.
Install(ueNodes.
Get(u)));
729 serverApps.Start(
Seconds(0.030));
730 clientApps.Start(
Seconds(0.030));
732 double statsStartTime = 0.04;
733 double statsDuration = 0.5;
734 double tolerance = 0.1;
737 lteHelper->EnableRlcTraces();
750 std::vector<uint64_t> dlDataRxed;
751 for (
int i = 0; i <
m_nUser; i++)
757 dlDataRxed.push_back(rlcStats->GetDlRxData(imsi, lcId));
758 NS_LOG_INFO(
"\tUser " << i <<
" dist " <<
m_dist.at(i) <<
" imsi " << imsi <<
" bytes rxed "
759 << (
double)dlDataRxed.at(i) <<
" thr "
760 << (
double)dlDataRxed.at(i) / statsDuration <<
" ref "
764 for (
int i = 0; i <
m_nUser; i++)
769 " 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.