CanStatistics.cpp

Go to the documentation of this file.

#include <CanModuleUtils.h>
#include "CanStatistics.h"

#include <iostream>


namespace CanModule
{
        CanStatistics::CanStatistics() :
                m_totalTransmitted(0),
                m_totalReceived(0),
                m_transmitted(0),
                m_received(0),
                m_transmittedOctets(0),
                m_receivedOctets(0)
        {}

        void CanStatistics::beginNewRun()
        {
                m_internals.m_observationStart = std::chrono::system_clock::now();
                m_transmitted = 0;
                m_received = 0;
                m_transmittedOctets = 0;
                m_receivedOctets = 0;
        }

        void CanStatistics::computeDerived(unsigned int baudRate)
        {
                system_clock::time_point tnom = system_clock::now(); 

                auto nDiff = tnom - m_internals.m_observationStart;
                auto period = duration_cast<seconds>(nDiff).count();

                m_internals.m_transmittedPerSec = (period != 0 ? float(m_transmitted / period) : 0);
                m_internals.m_receivedPerSec = (period != 0 ? float(m_received / period) : 0);

                if (baudRate > 0)
                { // baud rate is known
                        unsigned int octets = m_transmittedOctets.load() + m_receivedOctets.load();
                        float maxOctetsInSecond = float(baudRate / 8.0);
                        m_internals.m_busLoad = float(octets / maxOctetsInSecond);
                } else {
                        m_internals.m_busLoad = 0;
                }
        }

        void CanStatistics::onTransmit(unsigned int dataLength)
        {
                m_totalTransmitted++;
                m_transmitted++;
                m_transmittedOctets += 2 + 1 + dataLength + 2; /* ID, DLC, USER DATA, CRC */
        }

        void CanStatistics::onReceive(unsigned int dataLength)
        {
                m_totalReceived++;
                m_received++;
                m_receivedOctets += 2 + 1 + dataLength + 2; /* ID, DLC, USER DATA, CRC */
        }

        void CanStatistics::operator=(const CanStatistics & other)
        {
                this->m_received = other.m_received.load();
                this->m_totalReceived = other.m_totalReceived.load();
                this->m_transmitted = other.m_transmitted.load();
                this->m_totalTransmitted = other.m_totalTransmitted.load();
                this->m_transmittedOctets = other.m_transmittedOctets.load();
                this->m_receivedOctets = other.m_receivedOctets.load();
                this->m_internals = other.m_internals;
        }
}