12#include "ns3/nstime.h"
13#include "ns3/string.h"
28 m_pendingOutput(false),
36 m_pendingOutput(false)
51 TypeId(
"ns3::RadioBearerStatsCalculator")
53 .AddConstructor<RadioBearerStatsCalculator>()
55 .AddAttribute(
"StartTime",
56 "Start time of the on going epoch.",
61 .AddAttribute(
"EpochDuration",
67 .AddAttribute(
"DlRlcOutputFilename",
68 "Name of the file where the downlink results will be saved.",
72 .AddAttribute(
"UlRlcOutputFilename",
73 "Name of the file where the uplink results will be saved.",
77 .AddAttribute(
"DlPdcpOutputFilename",
78 "Name of the file where the downlink results will be saved.",
82 .AddAttribute(
"UlPdcpOutputFilename",
83 "Name of the file where the uplink results will be saved.",
233 std::ofstream ulOutFile;
234 std::ofstream dlOutFile;
239 if (!ulOutFile.is_open())
246 if (!dlOutFile.is_open())
252 ulOutFile <<
"% start\tend\tCellId\tIMSI\tRNTI\tLCID\tnTxPDUs\tTxBytes\tnRxPDUs\tRxBytes\t";
253 ulOutFile <<
"delay\tstdDev\tmin\tmax\t";
254 ulOutFile <<
"PduSize\tstdDev\tmin\tmax";
255 ulOutFile << std::endl;
256 dlOutFile <<
"% start\tend\tCellId\tIMSI\tRNTI\tLCID\tnTxPDUs\tTxBytes\tnRxPDUs\tRxBytes\t";
257 dlOutFile <<
"delay\tstdDev\tmin\tmax\t";
258 dlOutFile <<
"PduSize\tstdDev\tmin\tmax";
259 dlOutFile << std::endl;
264 if (!ulOutFile.is_open())
271 if (!dlOutFile.is_open())
289 std::vector<ImsiLcidPair_t> pairVector;
292 if (find(pairVector.begin(), pairVector.end(), (*it).first) == pairVector.end())
294 pairVector.push_back((*it).first);
300 if (find(pairVector.begin(), pairVector.end(), (*it).first) == pairVector.end())
302 pairVector.push_back((*it).first);
307 for (
auto it = pairVector.begin(); it != pairVector.end(); ++it)
320 outFile << p.
m_imsi <<
"\t";
321 outFile << flowId.
m_rnti <<
"\t";
328 for (
auto it = stats.begin(); it != stats.end(); ++it)
330 outFile << (*it) * 1e-9 <<
"\t";
333 for (
auto it = stats.begin(); it != stats.end(); ++it)
335 outFile << (*it) <<
"\t";
337 outFile << std::endl;
349 std::vector<ImsiLcidPair_t> pairVector;
352 if (find(pairVector.begin(), pairVector.end(), (*it).first) == pairVector.end())
354 pairVector.push_back((*it).first);
360 if (find(pairVector.begin(), pairVector.end(), (*it).first) == pairVector.end())
362 pairVector.push_back((*it).first);
367 for (
auto pair = pairVector.begin(); pair != pairVector.end(); ++pair)
380 outFile << p.
m_imsi <<
"\t";
381 outFile << flowId.
m_rnti <<
"\t";
388 for (
auto it = stats.begin(); it != stats.end(); ++it)
390 outFile << (*it) * 1e-9 <<
"\t";
393 for (
auto it = stats.begin(); it != stats.end(); ++it)
395 outFile << (*it) <<
"\t";
397 outFile << std::endl;
485 NS_LOG_ERROR(
"UL delay for " << imsi <<
" - " << (uint16_t)lcid <<
" not found");
496 std::vector<double> stats;
500 stats.push_back(0.0);
501 stats.push_back(0.0);
502 stats.push_back(0.0);
503 stats.push_back(0.0);
506 stats.push_back(
m_ulDelay[p]->getMean());
507 stats.push_back(
m_ulDelay[p]->getStddev());
518 std::vector<double> stats;
522 stats.push_back(0.0);
523 stats.push_back(0.0);
524 stats.push_back(0.0);
525 stats.push_back(0.0);
602 std::vector<double> stats;
606 stats.push_back(0.0);
607 stats.push_back(0.0);
608 stats.push_back(0.0);
609 stats.push_back(0.0);
612 stats.push_back(
m_dlDelay[p]->getMean());
613 stats.push_back(
m_dlDelay[p]->getStddev());
624 std::vector<double> stats;
628 stats.push_back(0.0);
629 stats.push_back(0.0);
630 stats.push_back(0.0);
631 stats.push_back(0.0);
void Cancel()
This method is syntactic sugar for the ns3::Simulator::Cancel method.
Base class for ***StatsCalculator classes.
std::string GetUlOutputFilename()
Get the name of the file where the uplink statistics will be stored.
void SetDlOutputFilename(std::string outputFilename)
Set the name of the file where the downlink statistics will be stored.
void SetUlOutputFilename(std::string outputFilename)
Set the name of the file where the uplink statistics will be stored.
std::string GetDlOutputFilename()
Get the name of the file where the downlink statistics will be stored.
Uint32Map m_ulTxPackets
Number of UL TX Packets by (IMSI, LCID) pair.
Uint64StatsMap m_dlDelay
DL delay by (IMSI, LCID) pair.
std::vector< double > GetDlDelayStats(uint64_t imsi, uint8_t lcid)
Gets the downlink RLC to RLC statistics: average, min, max and standard deviation.
std::string m_protocolType
Protocol type, by default RLC.
RadioBearerStatsCalculator()
Class constructor.
Uint64Map m_dlRxData
Amount of DL RX Data by (IMSI, LCID) pair.
uint64_t GetDlTxData(uint64_t imsi, uint8_t lcid)
Gets the number of transmitted downlink data bytes.
uint32_t GetUlRxPackets(uint64_t imsi, uint8_t lcid)
Gets the number of received uplink packets.
~RadioBearerStatsCalculator() override
Class destructor.
uint32_t GetDlRxPackets(uint64_t imsi, uint8_t lcid)
Gets the number of received downlink data bytes.
std::vector< double > GetDlPduSizeStats(uint64_t imsi, uint8_t lcid)
Gets the downlink PDU size statistics: average, min, max and standard deviation.
void RescheduleEndEpoch()
Reschedules EndEpoch event.
Uint64StatsMap m_ulDelay
UL delay by (IMSI, LCID) pair.
uint32_t GetUlCellId(uint64_t imsi, uint8_t lcid)
Gets the attached Enb cellId.
Uint64Map m_ulRxData
Amount of UL RX Data by (IMSI, LCID) pair.
void EndEpoch()
Function called in every endEpochEvent.
Time m_startTime
Start time of the on going epoch.
std::vector< double > GetUlPduSizeStats(uint64_t imsi, uint8_t lcid)
Gets the uplink PDU size statistics: average, min, max and standard deviation.
Uint64Map m_ulTxData
Amount of UL TX Data by (IMSI, LCID) pair.
std::string GetUlPdcpOutputFilename()
Get the name of the file where the uplink PDCP statistics will be stored.
void ShowResults()
Called after each epoch to write collected statistics to output files.
uint32_t GetDlTxPackets(uint64_t imsi, uint8_t lcid)
Gets the number of transmitted downlink data bytes.
Uint32StatsMap m_ulPduSize
UL PDU Size by (IMSI, LCID) pair.
EventId m_endEpochEvent
Event id for next end epoch event.
void DoDispose() override
Destructor implementation.
void UlRxPdu(uint16_t cellId, uint64_t imsi, uint16_t rnti, uint8_t lcid, uint32_t packetSize, uint64_t delay)
Notifies the stats calculator that an uplink reception has occurred.
uint64_t GetUlRxData(uint64_t imsi, uint8_t lcid)
Gets the number of received uplink data bytes.
std::string m_dlPdcpOutputFilename
Name of the file where the downlink PDCP statistics will be saved.
void UlTxPdu(uint16_t cellId, uint64_t imsi, uint16_t rnti, uint8_t lcid, uint32_t packetSize)
Notifies the stats calculator that an uplink transmission has occurred.
uint64_t GetDlRxData(uint64_t imsi, uint8_t lcid)
Gets the number of received downlink data bytes.
Uint32Map m_dlRxPackets
Number of DL RX Packets by (IMSI, LCID) pair.
std::string GetUlOutputFilename()
Get the name of the file where the uplink statistics will be stored.
void DlTxPdu(uint16_t cellId, uint64_t imsi, uint16_t rnti, uint8_t lcid, uint32_t packetSize)
Notifies the stats calculator that an downlink transmission has occurred.
uint64_t GetUlTxData(uint64_t imsi, uint8_t lcid)
Gets the number of transmitted uplink data bytes.
std::string GetDlOutputFilename()
Get the name of the file where the downlink statistics will be stored.
std::string m_ulPdcpOutputFilename
Name of the file where the uplink PDCP statistics will be saved.
void DlRxPdu(uint16_t cellId, uint64_t imsi, uint16_t rnti, uint8_t lcid, uint32_t packetSize, uint64_t delay)
Notifies the stats calculator that an downlink reception has occurred.
void ResetResults()
Erases collected statistics.
void WriteDlResults(std::ofstream &outFile)
Writes collected statistics to DL output file and closes DL output file.
Uint32StatsMap m_dlPduSize
DL PDU Size by (IMSI, LCID) pair.
Uint32Map m_ulRxPackets
Number of UL RX Packets by (IMSI, LCID) pair.
void SetStartTime(Time t)
bool m_firstWrite
true if output files have not been opened yet
FlowIdMap m_flowId
List of FlowIds, ie.
std::string GetDlPdcpOutputFilename()
Get the name of the file where the downlink PDCP statistics will be stored.
uint32_t GetDlCellId(uint64_t imsi, uint8_t lcid)
Gets the attached Enb cellId.
double GetDlDelay(uint64_t imsi, uint8_t lcid)
Gets the downlink RLC to RLC delay.
void WriteUlResults(std::ofstream &outFile)
Writes collected statistics to UL output file and closes UL output file.
double GetUlDelay(uint64_t imsi, uint8_t lcid)
Gets the uplink RLC to RLC delay.
Time GetStartTime() const
void SetUlPdcpOutputFilename(std::string outputFilename)
Set the name of the file where the uplink PDCP statistics will be stored.
Time m_epochDuration
Epoch duration.
Uint32Map m_ulCellId
List of UL CellIds by (IMSI, LCID) pair.
uint32_t GetUlTxPackets(uint64_t imsi, uint8_t lcid)
Gets the number of transmitted uplink packets.
Uint32Map m_dlCellId
List of DL CellIds by (IMSI, LCID) pair.
std::vector< double > GetUlDelayStats(uint64_t imsi, uint8_t lcid)
Gets the uplink RLC to RLC statistics: average, min, max and standard deviation.
Uint32Map m_dlTxPackets
Number of DL TX Packets by (IMSI, LCID) pair.
bool m_pendingOutput
true if any output is pending
static TypeId GetTypeId()
Register this type.
Uint64Map m_dlTxData
Amount of DL TX Data by (IMSI, LCID) pair.
void SetDlPdcpOutputFilename(std::string outputFilename)
Set the name of the file where the downlink PDCP statistics will be stored.
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
static Time Now()
Return the current simulation virtual time.
Hold variables of type string.
Simulation virtual time values and global simulation resolution.
double GetSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#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.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Time Seconds(double value)
Construct a Time in the indicated unit.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeAccessor > MakeTimeAccessor(T1 a1)
Ptr< const AttributeChecker > MakeStringChecker()
Ptr< const AttributeAccessor > MakeStringAccessor(T1 a1)
Ptr< const AttributeChecker > MakeTimeChecker()
Helper to make an unbounded Time checker.
static const uint32_t packetSize
Packet size generated at the AP.