Monitoring_impl.h

Go to the documentation of this file.

/***************************************
        Auteur : Thibaut Oprinsen
        Mail : thibaut.oprinsen@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
#ifndef __Monitoring_IMPL_H__
#define __Monitoring_IMPL_H__
 
#include "StatSort.h"
#include "Monitoring.h"
 
using namespace Swarm;

template<class _TBackend>
Monitoring<_TBackend>::Monitoring()
        :Daemon<_TBackend>()
{
        initializeMonitoring();
}

template<class _TBackend>
Monitoring<_TBackend>::~Monitoring(){
 
}


template<class _TBackend>
const MapDaemonStat& Monitoring<_TBackend>::getMapDaemonStat() const {
        return p_mapDaemonStat;
}


template<class _TBackend>
bool Monitoring<_TBackend>::hasReceivedStats() const {
        return !p_mapDaemonStat.empty();
}


template<class _TBackend>
size_t Monitoring<_TBackend>::getStatsCount() const { 
        return p_mapDaemonStat.size();
}


template<class _TBackend>
size_t Monitoring<_TBackend>::getStatBufferDurationSecond() const {
        return p_statBufferDuration;
}


template<class _TBackend>
size_t Monitoring<_TBackend>::getStatBinDurationSecond() const {
        return p_binDuration;
}


template<class _TBackend>
PUncastableBool Monitoring<_TBackend>::fillStatInfo(const Swarm::Stat & stat) {
        p_mapDaemonStat[stat.getName()] = stat;
        return UNCASTABLE_TRUE;
}


template<class _TBackend>
bool Monitoring<_TBackend>::extraLoad(const ConfigNode * config){
        if(config != nullptr){
                p_statBufferDuration = phoenix_get_value<size_t>(*config, "stat_buffer_duration_second", 30lu);
                p_binDuration = phoenix_get_value<size_t>(*config, "bin_duration_second", 5lu);
        }
        return true;
}

template<class _TBackend>
void Monitoring<_TBackend>::initializeMonitoring(){
        p_statBufferDuration = 0lu;
        p_binDuration = 0lu;
}


template<class _TBackend>
bool Monitoring<_TBackend>::processEvent(){
        // bool bResult = Daemon<_TBackend>::sendValue("SwarmTop", p_mapDaemonStat);
        return true;
}

template<class _TBackend>
void Monitoring<_TBackend>::addCallMethod(){
        DaemonConfig & daemonConfig = Daemon<_TBackend>::getConfig();
        BaseDaemon::getLog().getLogInfo() << "Monitoring: Adding data callable method for stat sorting with nbBin=" << daemonConfig.getStatNbBin() << ", lowerBound=" << daemonConfig.getStatHistLowerBound() << ", upperBound=" << daemonConfig.getStatHistUpperBound() << std::endl;
        Daemon<_TBackend>::addDataCallableMethod(sortFillDaemonStat<_TBackend>, *this, daemonConfig.getStatNbBin(), daemonConfig.getStatHistLowerBound(), daemonConfig.getStatHistUpperBound());
}
 
#endif