CanStatistics.h

Go to the documentation of this file.

#ifndef CANINTERFACE_SOCKCAN_CANSTATISTICS_H_
#define CANINTERFACE_SOCKCAN_CANSTATISTICS_H_


#ifdef _WIN32
#       include <atomic>
#       include <time.h>
#       ifndef timeval
#               include "Winsock2.h"
#       endif
#else
#       define GCC_VERSION (__GNUC__ * 10000 + __GNUC_MINOR__ * 100 + __GNUC_PATCHLEVEL__)
#       if GCC_VERSION > 40800
#               include <atomic>
#       else // GCC_VERSION
#               include <stdatomic.h>
#       endif // GCC_VERSION
#       include <sys/time.h>
#endif
#include "ExportDefinition.h"

#include <chrono>
using namespace std;
using namespace std::chrono;

namespace CanModule
{
        class CanStatistics
        {

        public:

        SHARED_LIB_EXPORT_DEFN CanStatistics();

                void beginNewRun();
                void computeDerived(unsigned int baudRate);

                void onTransmit(unsigned int dataLength);

                void onReceive(unsigned int dataLength);

                unsigned int totalTransmitted() { return m_totalTransmitted.load(); }
                unsigned int totalReceived() { return m_totalReceived.load(); }
                float txRate() { return m_internals.m_transmittedPerSec; }
                float rxRate() { return m_internals.m_receivedPerSec; }
                float busLoad() { return m_internals.m_busLoad; }

                void operator=(const CanStatistics & other);  // not default, because of atomic data

        private:

                /* Fields below may be accessed by many threads at once */
                std::atomic_uint_least32_t m_totalTransmitted;
                std::atomic_uint_least32_t m_totalReceived;
                std::atomic_uint_least32_t m_transmitted;
                std::atomic_uint_least32_t m_received;


                std::atomic_uint_least32_t m_transmittedOctets;
                std::atomic_uint_least32_t m_receivedOctets;

                class Internals
                {
                public:
                        float m_transmittedPerSec;
                        float m_receivedPerSec;
                        float m_busLoad;
                        system_clock::time_point m_observationStart;
                };
                Internals m_internals;

        };

}
#endif /* CANINTERFACE_SOCKCAN_CANSTATISTICS_H_ */