A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
lte-test-fdtbfq-ff-mac-scheduler.cc
Go to the documentation of this file.
1/*
2 * Copyright (c) 2011 Centre Tecnologic de Telecomunicacions de Catalunya (CTTC)
3 *
4 * SPDX-License-Identifier: GPL-2.0-only
5 *
6 * Author: Marco Miozzo <marco.miozzo@cttc.es>,
7 * Nicola Baldo <nbaldo@cttc.es>
8 * Dizhi Zhou <dizhi.zhou@gmail.com>
9 */
10
12
13#include "ns3/double.h"
14#include "ns3/internet-module.h"
15#include "ns3/ipv4-global-routing-helper.h"
16#include "ns3/network-module.h"
17#include "ns3/packet-sink-helper.h"
18#include "ns3/point-to-point-epc-helper.h"
19#include "ns3/point-to-point-helper.h"
20#include "ns3/radio-bearer-stats-calculator.h"
21#include "ns3/string.h"
22#include "ns3/udp-client-server-helper.h"
23#include <ns3/boolean.h>
24#include <ns3/constant-position-mobility-model.h>
25#include <ns3/enum.h>
26#include <ns3/eps-bearer.h>
27#include <ns3/ff-mac-scheduler.h>
28#include <ns3/log.h>
29#include <ns3/lte-enb-net-device.h>
30#include <ns3/lte-enb-phy.h>
31#include <ns3/lte-helper.h>
32#include <ns3/lte-ue-net-device.h>
33#include <ns3/lte-ue-phy.h>
34#include <ns3/lte-ue-rrc.h>
35#include <ns3/mobility-helper.h>
36#include <ns3/net-device-container.h>
37#include <ns3/node-container.h>
38#include <ns3/object.h>
39#include <ns3/packet.h>
40#include <ns3/ptr.h>
41#include <ns3/simulator.h>
42#include <ns3/spectrum-error-model.h>
43#include <ns3/spectrum-interference.h>
44#include <ns3/test.h>
45
46#include <iostream>
47#include <sstream>
48#include <string>
49
50using namespace ns3;
51
52NS_LOG_COMPONENT_DEFINE("LenaTestFdTbfqFfMacScheduler");
53
55 : TestSuite("lte-fdtbfq-ff-mac-scheduler", Type::SYSTEM)
56{
57 NS_LOG_INFO("creating LenaTestFdTbfqFfMacSchedulerSuite");
58
59 bool errorModel = false;
60
61 // General config
62 // Traffic: UDP traffic with fixed rate
63 // Token generation rate = traffic rate
64 // RLC header length = 2 bytes, PDCP header = 2 bytes
65 // Simulation time = 1.0 sec
66 // Throughput in this file is calculated in RLC layer
67
68 // Test Case 1: homogeneous flow test in FDTBFQ (same distance)
69 // DOWNLINK -> DISTANCE 0 -> MCS 28 -> Itbs 26 (from table 7.1.7.2.1-1 of 36.2 13)
70 // Traffic info
71 // UDP traffic: payload size = 200 bytes, interval = 1 ms
72 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) *
73 // 1000 byte/sec -> 232000 byte/rate
74 // Total bandwidth: 24 PRB at Itbs 26 -> 2196 -> 2196000 byte/sec
75 // 1 user -> 232000 * 1 = 232000 < 2196000 -> throughput = 232000 byte/sec
76 // 3 user -> 232000 * 3 = 696000 < 2196000 -> througphut = 232000 byte/sec
77 // 6 user -> 232000 * 6 = 139200 < 2196000 -> throughput = 232000 byte/sec
78 // 12 user -> 232000 * 12 = 2784000 > 2196000 -> throughput = 2196000 / 12 = 183000 byte/sec
79 // UPLINK -> DISTANCE 0 -> MCS 28 -> Itbs 26 (from table 7.1.7.2.1-1 of 36.2 13)
80 // 1 user -> 25 PRB at Itbs 26 -> 2292 -> 2292000 > 232000 -> throughput = 232000 bytes/sec
81 // 3 users -> 8 PRB at Itbs 26 -> 749 -> 749000 > 232000 -> throughput = 232000 bytes/sec
82 // 6 users -> 4 PRB at Itbs 26 -> 373 -> 373000 > 232000 -> throughput = 232000 bytes/sec
83 // 12 users -> 2 PRB at Itbs 26 -> 185 -> 185000 < 232000 -> throughput = 185000 bytes/sec
84 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(1, 0, 232000, 232000, 200, 1, errorModel),
85 TestCase::Duration::EXTENSIVE);
86 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(3, 0, 232000, 232000, 200, 1, errorModel),
87 TestCase::Duration::EXTENSIVE);
88 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(6, 0, 232000, 232000, 200, 1, errorModel),
89 TestCase::Duration::EXTENSIVE);
90 // AddTestCase (new LenaFdTbfqFfMacSchedulerTestCase1 (12,0,183000,185000,200,1,errorModel));//
91 // simulation time = 1.5, otherwise, ul test will fail
92
93 // DOWNLINK - DISTANCE 4800 -> MCS 22 -> Itbs 20 (from table 7.1.7.2.1-1 of 36.213)
94 // Traffic info
95 // UDP traffic: payload size = 200 bytes, interval = 1 ms
96 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) * 1000
97 // byte/sec -> 232000 byte/rate
98 // Total bandwidth: 24 PRB at Itbs 20 -> 1383 -> 1383000 byte/sec
99 // 1 user -> 903000 * 1 = 232000 < 1383000 -> throughput = 232000 byte/sec
100 // 3 user -> 232000 * 3 = 696000 < 1383000 -> througphut = 232000 byte/sec
101 // 6 user -> 232000 * 6 = 139200 > 1383000 -> throughput = 1383000 / 6 = 230500 byte/sec
102 // 12 user -> 232000 * 12 = 2784000 > 1383000 -> throughput = 1383000 / 12 = 115250 byte/sec
103 // UPLINK - DISTANCE 4800 -> MCS 14 -> Itbs 13 (from table 7.1.7.2.1-1 of 36.213)
104 // 1 user -> 25 PRB at Itbs 13 -> 807 -> 807000 > 232000 -> throughput = 232000 bytes/sec
105 // 3 users -> 8 PRB at Itbs 13 -> 253 -> 253000 > 232000 -> throughput = 232000 bytes/sec
106 // 6 users -> 4 PRB at Itbs 13 -> 125 -> 125000 < 232000 -> throughput = 125000 bytes/sec
107 // after the patch enforcing min 3 PRBs per UE:
108 // 12 users -> 3 PRB at Itbs 13 -> 93 bytes * 8/12 UE/TTI -> 62000 < 232000 -> throughput =
109 // 62000 bytes/sec
110 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(1, 4800, 232000, 232000, 200, 1, errorModel),
111 TestCase::Duration::EXTENSIVE);
112 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(3, 4800, 232000, 232000, 200, 1, errorModel),
113 TestCase::Duration::EXTENSIVE);
114 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(6, 4800, 230500, 125000, 200, 1, errorModel),
115 TestCase::Duration::EXTENSIVE);
116 // AddTestCase (new LenaFdTbfqFfMacSchedulerTestCase1 (12,4800,75250,62000,200,1,errorModel));
117 // // simulation time = 1.5, otherwise, ul test will fail
118
119 // DOWNLINK - DISTANCE 6000 -> MCS 20 -> Itbs 18 (from table 7.1.7.2.1-1 of 36.213)
120 // Traffic info
121 // UDP traffic: payload size = 200 bytes, interval = 1 ms
122 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) * 1000
123 // byte/sec -> 232000 byte/rate
124 // Total bandwidth: 24 PRB at Itbs 18 -> 1191 -> 1191000 byte/sec
125 // 1 user -> 903000 * 1 = 232000 < 1191000 -> throughput = 232000 byte/sec
126 // 3 user -> 232000 * 3 = 696000 < 1191000 -> througphut = 232000 byte/sec
127 // 6 user -> 232000 * 6 = 1392000 > 1191000 -> throughput = 1191000 / 6 = 198500 byte/sec
128 // 12 user -> 232000 * 12 = 2784000 > 1191000 -> throughput = 1191000 / 12 = 99250 byte/sec
129
130 // UPLINK - DISTANCE 6000 -> MCS 12 -> Itbs 11 (from table 7.1.7.2.1-1 of 36.213)
131 // 1 user -> 25 PRB at Itbs 11 -> 621 -> 621000 > 232000 -> throughput = 232000 bytes/sec
132 // 3 users -> 8 PRB at Itbs 11 -> 201 -> 201000 < 232000 -> throughput = 201000 bytes/sec
133 // 6 users -> 4 PRB at Itbs 11 -> 97 -> 97000 < 232000 -> throughput = 97000 bytes/sec
134 // after the patch enforcing min 3 PRBs per UE:
135 // 12 users -> 3 PRB at Itbs 11 -> 73 bytes * 8/12 UE/TTI -> 48667 < 232000 -> throughput =
136 // 48667 bytes/sec
137 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(1, 6000, 232000, 232000, 200, 1, errorModel),
138 TestCase::Duration::EXTENSIVE);
139 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(3, 6000, 232000, 201000, 200, 1, errorModel),
140 TestCase::Duration::EXTENSIVE);
141 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(6, 6000, 198500, 97000, 200, 1, errorModel),
142 TestCase::Duration::EXTENSIVE);
143 // AddTestCase (new LenaFdTbfqFfMacSchedulerTestCase1 (12,6000,99250,48667,200,1, errorModel));
144 // // simulation time = 1.5, otherwise, ul test will fail
145
146 // DOWNLINK - DISTANCE 10000 -> MCS 14 -> Itbs 13 (from table 7.1.7.2.1-1 of 36.213)
147 // Traffic info
148 // UDP traffic: payload size = 200 bytes, interval = 1 ms
149 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) * 1000
150 // byte/sec -> 232000 byte/rate
151 // Total bandwidth: 24 PRB at Itbs 13 -> 775 -> 775000 byte/sec
152 // 1 user -> 903000 * 1 = 232000 < 775000 -> throughput = 232000 byte/sec
153 // 3 user -> 232000 * 3 = 696000 < 775000 -> througphut = 232000 byte/sec
154 // 6 user -> 232000 * 6 = 139200 > 775000 -> throughput = 775000 / 6 = 129166 byte/sec
155 // 12 user -> 232000 * 12 = 2784000 > 775000 -> throughput = 775000 / 12 = 64583 byte/sec
156 // UPLINK - DISTANCE 10000 -> MCS 8 -> Itbs 8 (from table 7.1.7.2.1-1 of 36.213)
157 // 1 user -> 24 PRB at Itbs 8 -> 437 -> 437000 > 232000 -> throughput = 232000 bytes/sec
158 // 3 users -> 8 PRB at Itbs 8 -> 137 -> 137000 < 232000 -> throughput = 137000 bytes/sec
159 // 6 users -> 4 PRB at Itbs 8 -> 67 -> 67000 < 232000 -> throughput = 67000 bytes/sec
160 // after the patch enforcing min 3 PRBs per UE:
161 // 12 users -> 3 PRB at Itbs 8 -> 49 bytes * 8/12 UE/TTI -> 32667 < 232000 -> throughput = 32667
162 // bytes/sec
163 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(1, 10000, 232000, 232000, 200, 1, errorModel),
164 TestCase::Duration::EXTENSIVE);
165 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(3, 10000, 232000, 137000, 200, 1, errorModel),
166 TestCase::Duration::EXTENSIVE);
167 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(6, 10000, 129166, 67000, 200, 1, errorModel),
168 TestCase::Duration::EXTENSIVE);
169 // AddTestCase (new LenaFdTbfqFfMacSchedulerTestCase1
170 // (12,10000,64583,32667,200,1,errorModel));// simulation time = 1.5, otherwise, ul test will
171 // fail
172
173 // DOWNLINK - DISTANCE 100000 -> CQI == 0 -> out of range -> 0 bytes/sec
174 // UPLINK - DISTANCE 100000 -> CQI == 0 -> out of range -> 0 bytes/sec
175 AddTestCase(new LenaFdTbfqFfMacSchedulerTestCase1(1, 100000, 0, 0, 200, 1, errorModel),
176 TestCase::Duration::QUICK);
177
178 // Test Case 2: homogeneous flow test in FDTBFQ (different distance)
179 // Traffic1 info
180 // UDP traffic: payload size = 100 bytes, interval = 1 ms
181 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) * 1000
182 // byte/sec -> 132000 byte/rate
183 // Maximum throughput = 4 / ( 1/2196000 + 1/1191000 + 1/1383000 + 1/775000 ) = 1209046 byte/s
184 // 132000 * 4 = 528000 < 1209046 -> estimated throughput in downlink = 132000 byte/sec
185 std::vector<double> dist1;
186 dist1.push_back(0); // User 0 distance --> MCS 28
187 dist1.push_back(4800); // User 1 distance --> MCS 22
188 dist1.push_back(6000); // User 2 distance --> MCS 20
189 dist1.push_back(10000); // User 3 distance --> MCS 14
190 std::vector<uint16_t> packetSize1;
191 packetSize1.push_back(100);
192 packetSize1.push_back(100);
193 packetSize1.push_back(100);
194 packetSize1.push_back(100);
195 std::vector<uint32_t> estThrFdTbfqDl1;
196 estThrFdTbfqDl1.push_back(132000); // User 0 estimated TTI throughput from FDTBFQ
197 estThrFdTbfqDl1.push_back(132000); // User 1 estimated TTI throughput from FDTBFQ
198 estThrFdTbfqDl1.push_back(132000); // User 2 estimated TTI throughput from FDTBFQ
199 estThrFdTbfqDl1.push_back(132000); // User 3 estimated TTI throughput from FDTBFQ
201 new LenaFdTbfqFfMacSchedulerTestCase2(dist1, estThrFdTbfqDl1, packetSize1, 1, errorModel),
202 TestCase::Duration::EXTENSIVE);
203
204 // Traffic2 info
205 // UDP traffic: payload size = 300 bytes, interval = 1 ms
206 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) * 1000
207 // byte/sec -> 332000 byte/rate
208 // Maximum throughput = 4 / ( 1/2196000 + 1/1191000 + 1/1383000 + 1/775000 ) = 1209046 byte/s
209 // 232000 * 4 = 1328000 > 1209046 -> estimated throughput in downlink = 1209046 / 4 = 302266
210 // byte/sec
211 std::vector<double> dist2;
212 dist2.push_back(0); // User 0 distance --> MCS 28
213 dist2.push_back(4800); // User 1 distance --> MCS 22
214 dist2.push_back(6000); // User 2 distance --> MCS 20
215 dist2.push_back(10000); // User 3 distance --> MCS 14
216 std::vector<uint16_t> packetSize2;
217 packetSize2.push_back(300);
218 packetSize2.push_back(300);
219 packetSize2.push_back(300);
220 packetSize2.push_back(300);
221 std::vector<uint32_t> estThrFdTbfqDl2;
222 estThrFdTbfqDl2.push_back(302266); // User 0 estimated TTI throughput from FDTBFQ
223 estThrFdTbfqDl2.push_back(302266); // User 1 estimated TTI throughput from FDTBFQ
224 estThrFdTbfqDl2.push_back(302266); // User 2 estimated TTI throughput from FDTBFQ
225 estThrFdTbfqDl2.push_back(302266); // User 3 estimated TTI throughput from FDTBFQ
227 new LenaFdTbfqFfMacSchedulerTestCase2(dist2, estThrFdTbfqDl2, packetSize2, 1, errorModel),
228 TestCase::Duration::EXTENSIVE);
229
230 // Test Case 3: heterogeneous flow test in FDTBFQ
231 // UDP traffic: payload size = [100,200,300] bytes, interval = 1 ms
232 // UDP rate in scheduler: (payload + RLC header + PDCP header + IP header + UDP header) * 1000
233 // byte/sec -> [132000, 232000, 332000] byte/rate
234 // Maximum throughput = 3 / ( 1/2196000 + 1/1191000 + 1/1383000) = 1486569 byte/s
235 // 132000 + 232000 + 332000 = 696000 < 1486569 -> estimated throughput in downlink = [132000,
236 // 232000, 332000] byte/sec
237 std::vector<double> dist3;
238 dist3.push_back(0); // User 0 distance --> MCS 28
239 dist3.push_back(4800); // User 1 distance --> MCS 22
240 dist3.push_back(6000); // User 2 distance --> MCS 20
241 std::vector<uint16_t> packetSize3;
242 packetSize3.push_back(100);
243 packetSize3.push_back(200);
244 packetSize3.push_back(300);
245 std::vector<uint32_t> estThrFdTbfqDl3;
246 estThrFdTbfqDl3.push_back(132000); // User 0 estimated TTI throughput from FDTBFQ
247 estThrFdTbfqDl3.push_back(232000); // User 1 estimated TTI throughput from FDTBFQ
248 estThrFdTbfqDl3.push_back(332000); // User 2 estimated TTI throughput from FDTBFQ
250 new LenaFdTbfqFfMacSchedulerTestCase2(dist3, estThrFdTbfqDl3, packetSize3, 1, errorModel),
251 TestCase::Duration::QUICK);
252}
253
254/**
255 * \ingroup lte-test
256 * Static variable for test initialization
257 */
259
260// --------------- T E S T - C A S E # 1 ------------------------------
261
262std::string
264{
265 std::ostringstream oss;
266 oss << nUser << " UEs, distance " << dist << " m";
267 return oss.str();
268}
269
271 double dist,
272 double thrRefDl,
273 double thrRefUl,
274 uint16_t packetSize,
275 uint16_t interval,
276 bool errorModelEnabled)
277 : TestCase(BuildNameString(nUser, dist)),
278 m_nUser(nUser),
279 m_dist(dist),
280 m_packetSize(packetSize),
281 m_interval(interval),
282 m_thrRefDl(thrRefDl),
283 m_thrRefUl(thrRefUl),
284 m_errorModelEnabled(errorModelEnabled)
285{
286}
287
291
292void
294{
295 NS_LOG_FUNCTION(this << GetName());
296
298 {
299 Config::SetDefault("ns3::LteSpectrumPhy::CtrlErrorModelEnabled", BooleanValue(false));
300 Config::SetDefault("ns3::LteSpectrumPhy::DataErrorModelEnabled", BooleanValue(false));
301 }
302
303 Config::SetDefault("ns3::LteHelper::UseIdealRrc", BooleanValue(true));
304 Config::SetDefault("ns3::MacStatsCalculator::DlOutputFilename",
305 StringValue(CreateTempDirFilename("DlMacStats.txt")));
306 Config::SetDefault("ns3::MacStatsCalculator::UlOutputFilename",
307 StringValue(CreateTempDirFilename("UlMacStats.txt")));
308 Config::SetDefault("ns3::RadioBearerStatsCalculator::DlRlcOutputFilename",
309 StringValue(CreateTempDirFilename("DlRlcStats.txt")));
310 Config::SetDefault("ns3::RadioBearerStatsCalculator::UlRlcOutputFilename",
311 StringValue(CreateTempDirFilename("UlRlcStats.txt")));
312
315 lteHelper->SetEpcHelper(epcHelper);
316
317 // LogComponentEnable ("FdTbfqFfMacScheduler", LOG_DEBUG);
318
319 Ptr<Node> pgw = epcHelper->GetPgwNode();
320
321 // Create a single RemoteHost
322 NodeContainer remoteHostContainer;
323 remoteHostContainer.Create(1);
324 Ptr<Node> remoteHost = remoteHostContainer.Get(0);
325 InternetStackHelper internet;
326 internet.Install(remoteHostContainer);
327
328 // Create the Internet
330 p2ph.SetDeviceAttribute("DataRate", DataRateValue(DataRate("100Gb/s")));
331 p2ph.SetDeviceAttribute("Mtu", UintegerValue(1500));
332 p2ph.SetChannelAttribute("Delay", TimeValue(Seconds(0.001)));
333 NetDeviceContainer internetDevices = p2ph.Install(pgw, remoteHost);
334 Ipv4AddressHelper ipv4h;
335 ipv4h.SetBase("1.0.0.0", "255.0.0.0");
336 Ipv4InterfaceContainer internetIpIfaces = ipv4h.Assign(internetDevices);
337 // interface 0 is localhost, 1 is the p2p device
338 Ipv4Address remoteHostAddr = internetIpIfaces.GetAddress(1);
339
340 Ipv4StaticRoutingHelper ipv4RoutingHelper;
341 Ptr<Ipv4StaticRouting> remoteHostStaticRouting =
342 ipv4RoutingHelper.GetStaticRouting(remoteHost->GetObject<Ipv4>());
343 remoteHostStaticRouting->AddNetworkRouteTo(Ipv4Address("7.0.0.0"), Ipv4Mask("255.0.0.0"), 1);
344
345 // Config::SetDefault ("ns3::LteAmc::AmcModel", EnumValue (LteAmc::PiroEW2010));
346 // Config::SetDefault ("ns3::LteAmc::Ber", DoubleValue (0.00005));
347 // Config::SetDefault ("ns3::LteSpectrumPhy::CtrlErrorModelEnabled", BooleanValue (false));
348 // Config::SetDefault ("ns3::LteSpectrumPhy::DataErrorModelEnabled", BooleanValue (false));
349
350 // Config::SetDefault ("ns3::LteEnbRrc::EpsBearerToRlcMapping", EnumValue
351 // (LteHelper::RLC_UM_ALWAYS));
352
353 // LogComponentDisableAll (LOG_LEVEL_ALL);
354 // LogComponentEnable ("LenaTestFdTbfqFfMacScheduler", LOG_LEVEL_ALL);
355
356 lteHelper->SetAttribute("PathlossModel", StringValue("ns3::FriisSpectrumPropagationLossModel"));
357
358 // Create Nodes: eNodeB and UE
359 NodeContainer enbNodes;
360 NodeContainer ueNodes;
361 enbNodes.Create(1);
362 ueNodes.Create(m_nUser);
363
364 // Install Mobility Model
365 MobilityHelper mobility;
366 mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
367 mobility.Install(enbNodes);
368 mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
369 mobility.Install(ueNodes);
370
371 // Create Devices and install them in the Nodes (eNB and UE)
372 NetDeviceContainer enbDevs;
373 NetDeviceContainer ueDevs;
374 lteHelper->SetSchedulerType("ns3::FdTbfqFfMacScheduler");
375 lteHelper->SetSchedulerAttribute("UlCqiFilter", EnumValue(FfMacScheduler::SRS_UL_CQI));
376 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
377 ueDevs = lteHelper->InstallUeDevice(ueNodes);
378
379 Ptr<LteEnbNetDevice> lteEnbDev = enbDevs.Get(0)->GetObject<LteEnbNetDevice>();
380 Ptr<LteEnbPhy> enbPhy = lteEnbDev->GetPhy();
381 enbPhy->SetAttribute("TxPower", DoubleValue(30.0));
382 enbPhy->SetAttribute("NoiseFigure", DoubleValue(5.0));
383
384 // Set UEs' position and power
385 for (int i = 0; i < m_nUser; i++)
386 {
389 mm->SetPosition(Vector(m_dist, 0.0, 0.0));
390 Ptr<LteUeNetDevice> lteUeDev = ueDevs.Get(i)->GetObject<LteUeNetDevice>();
391 Ptr<LteUePhy> uePhy = lteUeDev->GetPhy();
392 uePhy->SetAttribute("TxPower", DoubleValue(23.0));
393 uePhy->SetAttribute("NoiseFigure", DoubleValue(9.0));
394 }
395
396 // Install the IP stack on the UEs
397 internet.Install(ueNodes);
398 Ipv4InterfaceContainer ueIpIface;
399 ueIpIface = epcHelper->AssignUeIpv4Address(NetDeviceContainer(ueDevs));
400
401 // Assign IP address to UEs
402 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
403 {
404 Ptr<Node> ueNode = ueNodes.Get(u);
405 // Set the default gateway for the UE
406 Ptr<Ipv4StaticRouting> ueStaticRouting =
407 ipv4RoutingHelper.GetStaticRouting(ueNode->GetObject<Ipv4>());
408 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
409 }
410
411 // Attach a UE to a eNB
412 lteHelper->Attach(ueDevs, enbDevs.Get(0));
413
414 // Activate an EPS bearer on all UEs
415 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
416 {
417 Ptr<NetDevice> ueDevice = ueDevs.Get(u);
419 qos.gbrDl = (m_packetSize + 32) * (1000 / m_interval) *
420 8; // bit/s, considering IP, UDP, RLC, PDCP header size
421 qos.gbrUl = 0;
422 qos.mbrDl = qos.gbrDl;
423 qos.mbrUl = 0;
424
426 EpsBearer bearer(q, qos);
427 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer, EpcTft::Default());
428 }
429
430 // Install downlink and uplink applications
431 uint16_t dlPort = 1234;
432 uint16_t ulPort = 2000;
433 PacketSinkHelper dlPacketSinkHelper("ns3::UdpSocketFactory",
435 ApplicationContainer clientApps;
436 ApplicationContainer serverApps;
437
438 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
439 {
440 ++ulPort;
441 PacketSinkHelper ulPacketSinkHelper("ns3::UdpSocketFactory",
443 serverApps.Add(ulPacketSinkHelper.Install(remoteHost)); // receive packets from UEs
444
445 serverApps.Add(
446 dlPacketSinkHelper.Install(ueNodes.Get(u))); // receive packets from remotehost
447
448 UdpClientHelper dlClient(ueIpIface.GetAddress(u), dlPort); // uplink packets generator
449 dlClient.SetAttribute("Interval", TimeValue(MilliSeconds(m_interval)));
450 dlClient.SetAttribute("MaxPackets", UintegerValue(1000000));
451 dlClient.SetAttribute("PacketSize", UintegerValue(m_packetSize));
452
453 UdpClientHelper ulClient(remoteHostAddr, ulPort); // downlink packets generator
454 ulClient.SetAttribute("Interval", TimeValue(MilliSeconds(m_interval)));
455 ulClient.SetAttribute("MaxPackets", UintegerValue(1000000));
456 ulClient.SetAttribute("PacketSize", UintegerValue(m_packetSize));
457
458 clientApps.Add(dlClient.Install(remoteHost));
459 clientApps.Add(ulClient.Install(ueNodes.Get(u)));
460 }
461
462 serverApps.Start(Seconds(0.001));
463 clientApps.Start(Seconds(0.04));
464
465 double statsStartTime = 0.04; // need to allow for RRC connection establishment + SRS
466 double statsDuration = 1;
467 double tolerance = 0.1;
468 Simulator::Stop(Seconds(statsStartTime + statsDuration - 0.0001));
469
470 lteHelper->EnableRlcTraces();
471 lteHelper->EnableMacTraces();
472 Ptr<RadioBearerStatsCalculator> rlcStats = lteHelper->GetRlcStats();
473 rlcStats->SetAttribute("StartTime", TimeValue(Seconds(statsStartTime)));
474 rlcStats->SetAttribute("EpochDuration", TimeValue(Seconds(statsDuration)));
475
477
478 /**
479 * Check that the downlink assignment is done in a "token bank fair queue" manner
480 */
481
482 NS_LOG_INFO("DL - Test with " << m_nUser << " user(s) at distance " << m_dist);
483 std::vector<uint64_t> dlDataRxed;
484 for (int i = 0; i < m_nUser; i++)
485 {
486 // get the imsi
487 uint64_t imsi = ueDevs.Get(i)->GetObject<LteUeNetDevice>()->GetImsi();
488 // get the lcId
489 uint8_t lcId = 4;
490 uint64_t data = rlcStats->GetDlRxData(imsi, lcId);
491 dlDataRxed.push_back(data);
492 NS_LOG_INFO("\tUser " << i << " imsi " << imsi << " bytes rxed " << (double)dlDataRxed.at(i)
493 << " thr " << (double)dlDataRxed.at(i) / statsDuration << " ref "
494 << m_thrRefDl);
495 }
496
497 for (int i = 0; i < m_nUser; i++)
498 {
499 NS_TEST_ASSERT_MSG_EQ_TOL((double)dlDataRxed.at(i) / statsDuration,
501 m_thrRefDl * tolerance,
502 " Unfair Throughput!");
503 }
504
505 /**
506 * Check that the uplink assignment is done in a "round robin" manner
507 */
508
509 NS_LOG_INFO("UL - Test with " << m_nUser << " user(s) at distance " << m_dist);
510 std::vector<uint64_t> ulDataRxed;
511 for (int i = 0; i < m_nUser; i++)
512 {
513 // get the imsi
514 uint64_t imsi = ueDevs.Get(i)->GetObject<LteUeNetDevice>()->GetImsi();
515 // get the lcId
516 uint8_t lcId = 4;
517 ulDataRxed.push_back(rlcStats->GetUlRxData(imsi, lcId));
518 NS_LOG_INFO("\tUser " << i << " imsi " << imsi << " bytes rxed " << (double)ulDataRxed.at(i)
519 << " thr " << (double)ulDataRxed.at(i) / statsDuration << " ref "
520 << m_thrRefUl);
521 }
522
523 for (int i = 0; i < m_nUser; i++)
524 {
525 NS_TEST_ASSERT_MSG_EQ_TOL((double)ulDataRxed.at(i) / statsDuration,
527 m_thrRefUl * tolerance,
528 " Unfair Throughput!");
529 }
531}
532
533// --------------- T E S T - C A S E # 2 ------------------------------
534
535std::string
536LenaFdTbfqFfMacSchedulerTestCase2::BuildNameString(uint16_t nUser, std::vector<double> dist)
537{
538 std::ostringstream oss;
539 oss << "distances (m) = [ ";
540 for (auto it = dist.begin(); it != dist.end(); ++it)
541 {
542 oss << *it << " ";
543 }
544 oss << "]";
545 return oss.str();
546}
547
549 std::vector<double> dist,
550 std::vector<uint32_t> estThrFdTbfqDl,
551 std::vector<uint16_t> packetSize,
552 uint16_t interval,
553 bool errorModelEnabled)
554 : TestCase(BuildNameString(dist.size(), dist)),
555 m_nUser(dist.size()),
556 m_dist(dist),
557 m_packetSize(packetSize),
558 m_interval(interval),
559 m_estThrFdTbfqDl(estThrFdTbfqDl),
560 m_errorModelEnabled(errorModelEnabled)
561{
562}
563
567
568void
570{
572 {
573 Config::SetDefault("ns3::LteSpectrumPhy::CtrlErrorModelEnabled", BooleanValue(false));
574 Config::SetDefault("ns3::LteSpectrumPhy::DataErrorModelEnabled", BooleanValue(false));
575 }
576
577 Config::SetDefault("ns3::LteHelper::UseIdealRrc", BooleanValue(true));
578 Config::SetDefault("ns3::MacStatsCalculator::DlOutputFilename",
579 StringValue(CreateTempDirFilename("DlMacStats.txt")));
580 Config::SetDefault("ns3::MacStatsCalculator::UlOutputFilename",
581 StringValue(CreateTempDirFilename("UlMacStats.txt")));
582 Config::SetDefault("ns3::RadioBearerStatsCalculator::DlRlcOutputFilename",
583 StringValue(CreateTempDirFilename("DlRlcStats.txt")));
584 Config::SetDefault("ns3::RadioBearerStatsCalculator::UlRlcOutputFilename",
585 StringValue(CreateTempDirFilename("UlRlcStats.txt")));
586
589 lteHelper->SetEpcHelper(epcHelper);
590
591 Ptr<Node> pgw = epcHelper->GetPgwNode();
592
593 // Create a single RemoteHost
594 NodeContainer remoteHostContainer;
595 remoteHostContainer.Create(1);
596 Ptr<Node> remoteHost = remoteHostContainer.Get(0);
597 InternetStackHelper internet;
598 internet.Install(remoteHostContainer);
599
600 // Create the Internet
602 p2ph.SetDeviceAttribute("DataRate", DataRateValue(DataRate("100Gb/s")));
603 p2ph.SetDeviceAttribute("Mtu", UintegerValue(1500));
604 p2ph.SetChannelAttribute("Delay", TimeValue(Seconds(0.001)));
605 NetDeviceContainer internetDevices = p2ph.Install(pgw, remoteHost);
606 Ipv4AddressHelper ipv4h;
607 ipv4h.SetBase("1.0.0.0", "255.0.0.0");
608 Ipv4InterfaceContainer internetIpIfaces = ipv4h.Assign(internetDevices);
609 // interface 0 is localhost, 1 is the p2p device
610 Ipv4Address remoteHostAddr = internetIpIfaces.GetAddress(1);
611
612 Ipv4StaticRoutingHelper ipv4RoutingHelper;
613 Ptr<Ipv4StaticRouting> remoteHostStaticRouting =
614 ipv4RoutingHelper.GetStaticRouting(remoteHost->GetObject<Ipv4>());
615 remoteHostStaticRouting->AddNetworkRouteTo(Ipv4Address("7.0.0.0"), Ipv4Mask("255.0.0.0"), 1);
616
617 // LogComponentDisableAll (LOG_LEVEL_ALL);
618 // LogComponentEnable ("LenaTestFdTbfqFfMacScheduler", LOG_LEVEL_ALL);
619
620 lteHelper->SetAttribute("PathlossModel", StringValue("ns3::FriisSpectrumPropagationLossModel"));
621
622 // Create Nodes: eNodeB and UE
623 NodeContainer enbNodes;
624 NodeContainer ueNodes;
625 enbNodes.Create(1);
626 ueNodes.Create(m_nUser);
627
628 // Install Mobility Model
629 MobilityHelper mobility;
630 mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
631 mobility.Install(enbNodes);
632 mobility.SetMobilityModel("ns3::ConstantPositionMobilityModel");
633 mobility.Install(ueNodes);
634
635 // Create Devices and install them in the Nodes (eNB and UE)
636 NetDeviceContainer enbDevs;
637 NetDeviceContainer ueDevs;
638 lteHelper->SetSchedulerType("ns3::FdTbfqFfMacScheduler");
639 lteHelper->SetSchedulerAttribute("UlCqiFilter", EnumValue(FfMacScheduler::SRS_UL_CQI));
640 enbDevs = lteHelper->InstallEnbDevice(enbNodes);
641 ueDevs = lteHelper->InstallUeDevice(ueNodes);
642
643 Ptr<LteEnbNetDevice> lteEnbDev = enbDevs.Get(0)->GetObject<LteEnbNetDevice>();
644 Ptr<LteEnbPhy> enbPhy = lteEnbDev->GetPhy();
645 enbPhy->SetAttribute("TxPower", DoubleValue(30.0));
646 enbPhy->SetAttribute("NoiseFigure", DoubleValue(5.0));
647
648 // Set UEs' position and power
649 for (int i = 0; i < m_nUser; i++)
650 {
653 mm->SetPosition(Vector(m_dist.at(i), 0.0, 0.0));
654 Ptr<LteUeNetDevice> lteUeDev = ueDevs.Get(i)->GetObject<LteUeNetDevice>();
655 Ptr<LteUePhy> uePhy = lteUeDev->GetPhy();
656 uePhy->SetAttribute("TxPower", DoubleValue(23.0));
657 uePhy->SetAttribute("NoiseFigure", DoubleValue(9.0));
658 }
659
660 // Install the IP stack on the UEs
661 internet.Install(ueNodes);
662 Ipv4InterfaceContainer ueIpIface;
663 ueIpIface = epcHelper->AssignUeIpv4Address(NetDeviceContainer(ueDevs));
664
665 // Assign IP address to UEs
666 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
667 {
668 Ptr<Node> ueNode = ueNodes.Get(u);
669 // Set the default gateway for the UE
670 Ptr<Ipv4StaticRouting> ueStaticRouting =
671 ipv4RoutingHelper.GetStaticRouting(ueNode->GetObject<Ipv4>());
672 ueStaticRouting->SetDefaultRoute(epcHelper->GetUeDefaultGatewayAddress(), 1);
673 }
674
675 // Attach a UE to a eNB
676 lteHelper->Attach(ueDevs, enbDevs.Get(0));
677
678 // Activate an EPS bearer on all UEs
679
680 uint16_t mbrDl = 0;
681 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
682 {
683 mbrDl = mbrDl + m_packetSize.at(u);
684 }
685 mbrDl = mbrDl / ueNodes.GetN();
686
687 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
688 {
689 Ptr<NetDevice> ueDevice = ueDevs.Get(u);
691 qos.gbrDl = (mbrDl + 32) * (1000 / m_interval) *
692 8; // bit/s, considering IP, UDP, RLC, PDCP header size
693 qos.gbrUl = 0;
694 qos.mbrDl = qos.gbrDl;
695 qos.mbrUl = 0;
696
698 EpsBearer bearer(q, qos);
699 lteHelper->ActivateDedicatedEpsBearer(ueDevice, bearer, EpcTft::Default());
700 }
701
702 // Install downlink and uplink applications
703 uint16_t dlPort = 1234;
704 uint16_t ulPort = 2000;
705 PacketSinkHelper dlPacketSinkHelper("ns3::UdpSocketFactory",
707 ApplicationContainer clientApps;
708 ApplicationContainer serverApps;
709
710 for (uint32_t u = 0; u < ueNodes.GetN(); ++u)
711 {
712 ++ulPort;
713 PacketSinkHelper ulPacketSinkHelper("ns3::UdpSocketFactory",
715 serverApps.Add(ulPacketSinkHelper.Install(remoteHost)); // receive packets from UEs
716 serverApps.Add(
717 dlPacketSinkHelper.Install(ueNodes.Get(u))); // receive packets from remotehost
718
719 UdpClientHelper dlClient(ueIpIface.GetAddress(u), dlPort); // uplink packets generator
720 dlClient.SetAttribute("Interval", TimeValue(MilliSeconds(m_interval)));
721 dlClient.SetAttribute("MaxPackets", UintegerValue(1000000));
722 dlClient.SetAttribute("PacketSize", UintegerValue(m_packetSize.at(u)));
723
724 UdpClientHelper ulClient(remoteHostAddr, ulPort); // downlink packets generator
725 ulClient.SetAttribute("Interval", TimeValue(MilliSeconds(m_interval)));
726 ulClient.SetAttribute("MaxPackets", UintegerValue(1000000));
727 ulClient.SetAttribute("PacketSize", UintegerValue(m_packetSize.at(u)));
728
729 clientApps.Add(dlClient.Install(remoteHost));
730 clientApps.Add(ulClient.Install(ueNodes.Get(u)));
731 }
732
733 serverApps.Start(Seconds(0.001));
734 clientApps.Start(Seconds(0.001));
735
736 double statsStartTime = 0.001; // need to allow for RRC connection establishment + SRS
737 double statsDuration = 1.0;
738 double tolerance = 0.1;
739 Simulator::Stop(Seconds(statsStartTime + statsDuration - 0.0001));
740
741 lteHelper->EnableRlcTraces();
742 Ptr<RadioBearerStatsCalculator> rlcStats = lteHelper->GetRlcStats();
743 rlcStats->SetAttribute("StartTime", TimeValue(Seconds(statsStartTime)));
744 rlcStats->SetAttribute("EpochDuration", TimeValue(Seconds(statsDuration)));
745
747
748 /**
749 * Check that the downlink assignment is done in a "token bank fair queue" manner
750 */
751
752 NS_LOG_INFO("DL - Test with " << m_nUser << " user(s)");
753 std::vector<uint64_t> dlDataRxed;
754 for (int i = 0; i < m_nUser; i++)
755 {
756 // get the imsi
757 uint64_t imsi = ueDevs.Get(i)->GetObject<LteUeNetDevice>()->GetImsi();
758 // get the lcId
759 uint8_t lcId = 4;
760 dlDataRxed.push_back(rlcStats->GetDlRxData(imsi, lcId));
761 NS_LOG_INFO("\tUser " << i << " dist " << m_dist.at(i) << " imsi " << imsi << " bytes rxed "
762 << (double)dlDataRxed.at(i) << " thr "
763 << (double)dlDataRxed.at(i) / statsDuration << " ref " << m_nUser);
764 }
765
766 for (int i = 0; i < m_nUser; i++)
767 {
768 NS_TEST_ASSERT_MSG_EQ_TOL((double)dlDataRxed.at(i) / statsDuration,
769 m_estThrFdTbfqDl.at(i),
770 m_estThrFdTbfqDl.at(i) * tolerance,
771 " Unfair Throughput!");
772 }
773
775}
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.
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.
bool m_errorModelEnabled
whether the error model is enabled
Test case is similar to the one defined in LenaFdTbfqFfMacSchedulerTestCase1, with the difference tha...
void DoRun() override
Implementation to actually run this TestCase.
std::vector< uint32_t > m_estThrFdTbfqDl
estimated thrpughput FDTBFQ DL
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.
Test suit for FdTbfqFfMacScheduler test.
holds a vector of ns3::Application pointers.
ApplicationContainer Install(NodeContainer c)
Install an application on each node of the input container configured with all the attributes set wit...
void SetAttribute(const std::string &name, const AttributeValue &value)
Helper function used to set the underlying application attributes.
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.
Definition data-rate.h:78
This class can be used to hold variables of floating point type such as 'double' or 'float'.
Definition double.h:31
Hold variables of type enum.
Definition enum.h:52
static Ptr< EpcTft > Default()
creates a TFT matching any traffic
Definition epc-tft.cc:218
This class contains the specification of EPS Bearers.
Definition eps-bearer.h:80
Qci
QoS Class Indicator.
Definition eps-bearer.h:95
@ GBR_CONV_VOICE
GBR Conversational Voice.
Definition eps-bearer.h:96
an Inet address class
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.
Definition ipv4.h:69
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.
Definition object.h:511
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
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().
Definition simulator.cc:131
static void Run()
Run the simulation.
Definition simulator.cc:167
static void Stop()
Tell the Simulator the calling event should be the last one executed.
Definition simulator.cc:175
Hold variables of type string.
Definition string.h:45
encapsulates test code
Definition test.h:1050
void AddTestCase(TestCase *testCase, Duration duration=Duration::QUICK)
Add an individual child TestCase to this test suite.
Definition test.cc:292
std::string CreateTempDirFilename(std::string filename)
Construct the full path to a file in a temporary directory.
Definition test.cc:432
std::string GetName() const
Definition test.cc:367
A suite of tests to run.
Definition test.h:1267
Type
Type of test.
Definition test.h:1274
Create a client application which sends UDP packets carrying a 32bit sequence number and a 64 bit tim...
Hold an unsigned integer type.
Definition uinteger.h:34
void SetDefault(std::string name, const AttributeValue &value)
Definition config.cc:883
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition log.h:191
#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.
Definition log.h:264
static LenaTestFdTbfqFfMacSchedulerSuite lenaTestFdTbfqFfMacSchedulerSuite
Static variable for test initialization.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
Definition object.h:619
#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...
Definition test.h:327
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition nstime.h:1308
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
Definition nstime.h:1320
Every class exported by the ns3 library is enclosed in the ns3 namespace.
uint8_t data[writeSize]
3GPP TS 36.413 9.2.1.18 GBR QoS Information
Definition eps-bearer.h:25
uint64_t gbrDl
Guaranteed Bit Rate (bit/s) in downlink.
Definition eps-bearer.h:31
uint64_t gbrUl
Guaranteed Bit Rate (bit/s) in uplink.
Definition eps-bearer.h:32
uint64_t mbrDl
Maximum Bit Rate (bit/s) in downlink.
Definition eps-bearer.h:33
uint64_t mbrUl
Maximum Bit Rate (bit/s) in uplink.
Definition eps-bearer.h:34
static const uint32_t packetSize
Packet size generated at the AP.