StatDaemonManager< _TBackend > Class Template Reference

Daemon which manages statistics of a full swarm. More...

#include <StatDaemonManager.h>

Inheritance diagram for StatDaemonManager< _TBackend >:

Collaboration diagram for StatDaemonManager< _TBackend >:

Public Member Functions
template<typename _Callable>
bool	addCallableMethod (_Callable &&function, const PString &name)
	Add a callable method of the Daemon.
virtual void	addCallMethod ()
	Method from BaseDaemon to add call methods.
template<typename _Class, typename _Data>
bool	addDataCallableMethod (PUncastableBool(&function)(_Class &, const _Data &), _Class &persistentData, size_t nbBin, float histLowerBound, float histUpperBound)
	Add a callable method of the Daemon.
template<typename _Data>
bool	addDataCallableMethod (PUncastableBool(&function)(const _Data &), size_t nbBin, float histLowerBound, float histUpperBound)
	Add a callable method of the Daemon.
void	addMessageToConfirm (const Message &message)
	Add a message to confirm.
bool	callMethod (Data &result, const PString &name, const Data &parameter)
	Call an added callable method by name.
void	checkMessageTimeout (time_t currentTime)
	Check if a message has reached the timeout.
PRecvStatus::PRecvStatus	checkRecvStatus (PRecvStatus::PRecvStatus recvStatus)
	Check the status of recv sockets.
void	checkSendStatus (PSendStatus::PSendStatus sendStatus)
	Check the status of recv sockets.
void	clearCallableMethod ()
	Clear the map of callable methods.
void	clearStat ()
	Clear all the statistics of the daemon.
StatAccumulator	createNewStat (size_t nbBin, float histLowerBound, float histUpperBound)
	Create a new clear computing statistic.
virtual void	executeOnStop ()
	Method which is called on stop of the Daemon.
virtual bool	extraLoad (const ConfigNode *config)
	Extra call on load for the current Daemon.
virtual void	extraLoopProcessing ()
	Computing Method for each event loop (when receiving message from other Daemon)
PUncastableBool	fillStatInfo (const DaemonStat &stat)
	Fill the StatInfo of the StatDaemonManager with the given DaemonStat.
DaemonConfig &	getConfig ()
	Get the configuration of the current BaseDaemon.
AbstractDataFunction *	getDataFunction (const Data &data)
	Get the data function associated with the given data.
PLog &	getLog ()
	Get the log of the current BaseDaemon.
PLog &	getLogger ()
	Get the logger of the current BaseDaemon.
DaemonMainConfig &	getMainConfig ()
	Get the main configuration of the swarm.
MapDaemonConfig &	getMapDaemonConfig ()
	Get the map of all Daemon configurations.
const MapDaemonStat &	getMapDaemonStat () const
	Get the map of DaemonStat.
const std::map< size_t, Message > &	getMapMessageToBeConfirmed () const
	Get the map of message to be confirmed.
size_t	getMessageId ()
	Get current message id.
bool	getMessageToConfirm (Message &message, size_t id) const
	Get a message to confirm by id if it exists.
OptionParser &	getOptionParser ()
	Return the OptionParser of the current BaseDaemon.
size_t	getStatsCount () const
	Get the count of stats received.
bool	hasReceivedStats () const
	Check if stats have been received.
bool	isDaemonExist (const PString &name) const
	Say if a neighbour Daemon does exist.
bool	load (const PPath &fileName, const PString &daemonName)
	Load the Toml configuration which define all BaseDaemons of the Swarm.
bool	load (const PString &configFileContent, const PString &daemonName, ConfigFormat::ConfigFormat format)
	Load the Json configuration which define all BaseDaemons of the Swarm.
void	loadConfigFromNode (const ConfigNode &dico, const PString &daemonName)
	Load configuration form a node of ConfigNode.
bool	parseArgument (int argc, char **argv)
	Parse arguments given to the BaseDaemon with command line.
void	processConfirmedMessage (size_t id, time_t currentTime)
	Process confirmed message.
bool	processData (const Data &data)
	Process given data with the proper method.
bool	processEvent ()
	Process event.
bool	run ()
	Run the Daemon.
bool	sendData (const PString &destinationName, const Data &data, bool isConfirmationNeeded)
	Send data to other Daemon (specialization for Data)
bool	sendMessage (const Message &message)
	Send message to other Daemon.
bool	sendMessage (const PString &destinationName, const Message &message)
	Send message to other Daemon.
template<typename T>
bool	sendValue (const PString &destinationName, const T &data, bool isConfirmationNeeded=true)
	Send data to other Daemon.
void	setClockMode (PClockMode::PClockMode mode)
	Set the mode of the clock.
void	setSocketMode (PSocketMode::PSocketMode mode)
	Set the mode of the sockets of the SocketManager.
	StatDaemonManager ()
	Constructor of StatDaemonManager.
void	stop ()
	Stops the BaseDaemon.
void	updateStatAccumulator (StatAccumulator &stat, float value)
	Update a computing statistic with a new value.
virtual	~StatDaemonManager ()
	Destructor of StatDaemonManager.

Protected Member Functions
void	fillDaemonStat (DaemonStat &stat, time_t startTimestamp, time_t endTimestamp)
	Fill the DaemonStat with the current statistics of the daemon.
VecStat	fillVecStat (const StatAccumulator &accumulator, time_t startTimestamp, time_t endTimestamp)
	Fill a VecStat from a StatAccumulator to send to the DamonStat.
void	processInputMessage (Message &message)
	Process an input message.

Protected Attributes
_TBackend	p_backend
	Full backend of the Daemon (for Socket and clock)
DaemonConfig	p_config
	Configuration of the curent Daemon.
bool	p_isFullMock
	True if the daemon has to be executed in mock mode for socket and clock.
bool	p_isFullMockRecord
	True if the daemon has to be executed in mock record mode for socket and clock.
bool	p_isRun
	True if the current BaseDaemon is running.
PLog	p_log
	Logger of the current Daemon.
DaemonMainConfig	p_mainConfig
	Main configuration of the Daemon.
MapDaemonConfig	p_mapDaemon
	Map of the other Daemon of the Swarm.
time_t	p_startTimestamp
	Start timestamp of the current accumulation of statistics.
PTimer	p_statTimer
	Timer to send statistics to the Stat Daemon.

Private Member Functions
std::map< PString, StatAccumulator >	createNewCommunicationStatMap (const PString &dataType, size_t nbBin, float histLowerBound, float histUpperBound)
	Create a new map of communication statistic.
void	getCommunicationStat (const PString &destName, const PString &dataType, float latency, size_t nbBin, float histLowerBound, float histUpperBound)
	Add a communication statistic.
void	initialisationBaseDaemon ()
	Initialisation function of the class BaseDaemon.
void	initialisationDaemon ()
	Initialisation function of the class Daemon.
void	initialisationDaemonSocket ()
	Initialise the Daemon Sockets.
void	initializeStatDaemonManager ()
	Initialize the StatDaemonManager.
void	sendStatToStatDaemon (time_t currentTime)
	Send the statistics of the Daemon to the Stat Daemon.

Private Attributes
std::map< PString, AbstractFunction * >	p_mapCallableMethod
	Map of callable method of the Daemon.
MapDaemonStat	p_mapDaemonStat
	Statistics about all Daemon in the swarm.
std::map< PString, AbstractDataFunction * >	p_mapDataFunction
	Map of methods which have to be called when receiving data.
std::map< size_t, Message >	p_mapMessageToBeConfirmed
	Map of messages which have to be confirmed by destination Daemon.
size_t	p_messageId
	Id counter of the message of the current Daemon.
OptionParser	p_optionParser
	Option parser of the Daemon.

Detailed Description

template<class _TBackend>
class StatDaemonManager< _TBackend >

Daemon which manages statistics of a full swarm.

Definition at line 18 of file StatDaemonManager.h.

Constructor & Destructor Documentation

StatDaemonManager()

template<class _TBackend>

StatDaemonManager< _TBackend >::StatDaemonManager

(

)

Constructor of StatDaemonManager.

Definition at line 14 of file StatDaemonManager_impl.h.

        :Daemon<_TBackend>()
{
        initializeStatDaemonManager();
}

References Daemon< _TBackend >::Daemon(), and initializeStatDaemonManager().

Here is the call graph for this function:

~StatDaemonManager()

template<class _TBackend>

StatDaemonManager< _TBackend >::~StatDaemonManager ( )

virtual

Destructor of StatDaemonManager.

Definition at line 22 of file StatDaemonManager_impl.h.

                                                {
 
}

Member Function Documentation

addCallableMethod()

template<typename _Callable>

bool BaseDaemon::addCallableMethod ( _Callable && function, const PString & name )

inlineinherited

Add a callable method of the Daemon.

Parameters

function	: method to be added
name	: name of the method which can be called

Returns

true on success, false otherwise

Definition at line 73 of file BaseDaemon.h.

                                                                                   {
                        std::map<PString, AbstractFunction*>::iterator it(p_mapCallableMethod.find(name));
                        if(it != p_mapCallableMethod.end()){
                                getLog().getLogError() << "BaseDaemon::addCallableMethod : function '"<<name<<"' already added" << std::endl;
                                return false;
                        }
                        p_mapCallableMethod[name] = new FunctionCall(function, name);
                        return true;
                }

References getLog(), and p_mapCallableMethod.

Here is the call graph for this function:

addCallMethod()

template<class _TBackend>

void StatDaemonManager< _TBackend >::addCallMethod ( )

virtual

Method from BaseDaemon to add call methods.

Reimplemented from BaseDaemon.

Definition at line 77 of file StatDaemonManager_impl.h.

                                                {
        DaemonConfig & daemonConfig = Daemon<_TBackend>::getConfig();
        BaseDaemon::getLog().getLogInfo() << "StatDaemonManager: 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());
}

References BaseDaemon::addDataCallableMethod(), BaseDaemon::getConfig(), BaseDaemon::getLog(), DaemonConfig::getStatHistLowerBound(), DaemonConfig::getStatHistUpperBound(), DaemonConfig::getStatNbBin(), and sortFillDaemonStat().

Here is the call graph for this function:

addDataCallableMethod() [1/2]

template<typename _Class, typename _Data>

bool BaseDaemon::addDataCallableMethod ( PUncastableBool(&)(_Class &, const _Data &) function, _Class & persistentData, size_t nbBin, float histLowerBound, float histUpperBound )

inlineinherited

Add a callable method of the Daemon.

Parameters

function	: method to be added
persistentData	: data used each time the method is called
nbBin	: number of bin in the histogram
histLowerBound	: lower bound of the histogram
histUpperBound	: upper bound of the histogram

Returns

true on success, false otherwise

Definition at line 128 of file BaseDaemon.h.

                                                                                                                                                                                  {
                        PString prototype(phoenix_getTypeToStr<_Data>());
                        std::cout << "BaseDaemon::addDataCallableMethod : prototype = " << prototype << std::endl;
                        std::map<PString, AbstractDataFunction*>::iterator it(p_mapDataFunction.find(prototype));
                        if(it != p_mapDataFunction.end()){
                                getLog().getLogError() << "BaseDaemon::addDataCallableMethod : function to process data '"<<prototype<<"' already added" << std::endl;
                                return false;
                        }
                        getLog().getLogDebug() << "BaseDaemon::addDataCallableMethod : add method to process data '"<<prototype<<"'" << std::endl;
                        p_mapDataFunction[prototype] = new DataFunctionClassCall(function, persistentData, prototype);
                        p_config.getDaemonStatAccumulator().getMapStatComputing()[prototype] = createNewStat(nbBin, histLowerBound, histUpperBound);
                        return true;
                }

References createNewStat(), getLog(), p_config, and p_mapDataFunction.

Here is the call graph for this function:

addDataCallableMethod() [2/2]

template<typename _Data>

bool BaseDaemon::addDataCallableMethod ( PUncastableBool(&)(const _Data &) function, size_t nbBin, float histLowerBound, float histUpperBound )

inlineinherited

Add a callable method of the Daemon.

Parameters

function	: method to be added
nbBin	: number of bin in the histogram
histLowerBound	: lower bound of the histogram
histUpperBound	: upper bound of the histogram

Returns

true on success, false otherwise

Definition at line 105 of file BaseDaemon.h.

                                                                                                                                               {
                        PString prototype(phoenix_getTypeToStr<_Data>());
                        std::cout << "BaseDaemon::addDataCallableMethod : prototype = " << prototype << std::endl;
                        std::map<PString, AbstractDataFunction*>::iterator it(p_mapDataFunction.find(prototype));
                        if(it != p_mapDataFunction.end()){
                                getLog().getLogError() << "BaseDaemon::addDataCallableMethod : function to process data '"<<prototype<<"' already added" << std::endl;
                                return false;
                        }
                        getLog().getLogDebug() << "BaseDaemon::addDataCallableMethod : add method to process data '"<<prototype<<"'" << std::endl;
                        p_mapDataFunction[prototype] = new DataFunctionCall(function, prototype);
                        p_config.getDaemonStatAccumulator().getMapStatComputing()[prototype] = createNewStat(nbBin, histLowerBound, histUpperBound);
                        return true;
                }

References createNewStat(), getLog(), p_config, and p_mapDataFunction.

Referenced by StatDaemonManager< _TBackend >::addCallMethod().

Here is the call graph for this function:

Here is the caller graph for this function:

addMessageToConfirm()

void BaseDaemon::addMessageToConfirm ( const Message & message )

inherited

Add a message to confirm.

Parameters

message

: message to be added

Definition at line 180 of file BaseDaemon.cpp.

                                                           {
        p_mapMessageToBeConfirmed[message.getId()] = message;
}

References Message::getId(), and p_mapMessageToBeConfirmed.

Referenced by Daemon< _TBackend >::sendMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

callMethod()

bool BaseDaemon::callMethod ( Data & result, const PString & name, const Data & parameter )

inherited

Call an added callable method by name.

Parameters

[out]	result	: result of the call
	name	: name of the method
	parameter	: parameters of the call

Returns

true on success, false otherwise

Definition at line 121 of file BaseDaemon.cpp.

                                                                                      {
        std::map<PString, AbstractFunction*>::iterator it(p_mapCallableMethod.find(name));
        if(it == p_mapCallableMethod.end()){
                getLog().getLogError() << "BaseDaemon::callMethod : function '"<<name<<"' not found" << std::endl;
                return false;
        }
        return p_mapCallableMethod[name]->call(p_log, result, parameter);
}

References getLog(), p_log, and p_mapCallableMethod.

Here is the call graph for this function:

checkMessageTimeout()

void BaseDaemon::checkMessageTimeout ( time_t currentTime )

inherited

Check if a message has reached the timeout.

Parameters

currentTime

: current time

Definition at line 223 of file BaseDaemon.cpp.

                                                      {
        std::vector<size_t> messagesToRemove;
        for(auto it = p_mapMessageToBeConfirmed.begin(); it != p_mapMessageToBeConfirmed.end(); ++it){
                const size_t & messageId = it->first;
                const Message & message = it->second;
                time_t elapsedTime = currentTime - message.getSendTime();
                if(message.getVecRecver().size() == 0lu){
                        getLog().getLogError() << "BaseDaemon::checkMessageTimeout() : message " << messageId << " has no receiver." << std::endl;
                        continue;
                }
                std::map<PString, time_t>::const_iterator timeoutIt = p_config.getMapTimeout().find(message.getVecRecver().front());
                if(timeoutIt == p_config.getMapTimeout().end()){
                        getLog().getLogError() << "BaseDaemon::checkMessageTimeout() : no timeout found for receiver '" << message.getVecRecver().front() << "' of message " << messageId << "." << std::endl;
                        continue;
                }
                time_t timeout = timeoutIt->second;
                phoenix_assert(message.getVecRecver().size() != 0lu);
                if (elapsedTime > timeout) {
                        messagesToRemove.push_back(messageId);
                        getLog().getLogWarning() << "BaseDaemon::checkMessageTimeout() : Timeout Reached for message " << messageId << " sent to '" << message.getVecRecver().front() << "'. Removing unconfirmed transaction" << std::endl;
                }
        }
        for(const size_t & messageId : messagesToRemove){
                p_mapMessageToBeConfirmed.erase(messageId);
        }
}

References getLog(), Message::getSendTime(), Message::getVecRecver(), p_config, and p_mapMessageToBeConfirmed.

Referenced by Daemon< _TBackend >::run().

Here is the call graph for this function:

Here is the caller graph for this function:

checkRecvStatus()

template<class _TBackend>

PRecvStatus::PRecvStatus Daemon< _TBackend >::checkRecvStatus ( PRecvStatus::PRecvStatus recvStatus )

inherited

Check the status of recv sockets.

Parameters

recvStatus

: status to be checked

Definition at line 75 of file Daemon_impl.h.

                                                                                          {
        if(recvStatus == PRecvStatus::SOCKET_NOT_AVAILABLE){
//              p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Socket not available", "Socket not available");
                p_log.getLogWarning() << "Daemon::checkRecvStatus : Socket not available" << std::endl;
        }
        if(recvStatus == PRecvStatus::SIGNAL_INTERRUPTION){
                p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Socket Backend caught a signal, aborting", "Socket Backend caught a signal, aborting");
        }
        if(recvStatus == PRecvStatus::BROKEN_BACKEND){
                p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Back-end is in invalid state", "Back-end is in invalid state");
        }
        if(recvStatus == PRecvStatus::BROKEN_SOCKET){
                p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Socket is in invalid state", "Socket is in invalid state");
        }
        if(recvStatus == PRecvStatus::CANNOT_DESERIALIZE_DATA){
                p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Cannot deserialize data", "Cannot deserialize data");
        }
        return recvStatus;
}

References BaseDaemon::p_log.

Referenced by run().

Here is the caller graph for this function:

checkSendStatus()

template<class _TBackend>

void Daemon< _TBackend >::checkSendStatus ( PSendStatus::PSendStatus sendStatus )

inherited

Check the status of recv sockets.

Parameters

sendStatus

: status to be checked

Definition at line 100 of file Daemon_impl.h.

                                                                        {
        if(sendStatus == PSendStatus::SOCKET_NOT_AVAILABLE){
                p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Socket not available", "Socket not available");
        }
        if(sendStatus == PSendStatus::NO_ROUTE_TO_RECEIVER){
                p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Receiver not reachable", "Receiver not reachable");
        }
        if(sendStatus == PSendStatus::SIGNAL_INTERRUPTION){
                p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Socket Backend caught a signal, aborting.", "Socket Backend caught a signal, aborting.");
        }
        if(sendStatus == PSendStatus::BROKEN_BACKEND){
                p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Back-end is in invalid state", "Back-end is in invalid state");
        }
        if(sendStatus == PSendStatus::BROKEN_SOCKET){
                p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Socket is in invalid state", "Socket is in invalid state");
        }
        if(sendStatus == PSendStatus::CANNOT_SERIALIZE_DATA){
                p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Cannot serialize data", "Cannot serialize data");
        }
}

References BaseDaemon::p_log.

Referenced by sendMessage().

Here is the caller graph for this function:

clearCallableMethod()

void BaseDaemon::clearCallableMethod ( )

inherited

Clear the map of callable methods.

Definition at line 131 of file BaseDaemon.cpp.

                                    {
        for(std::map<PString, AbstractFunction*>::iterator it(p_mapCallableMethod.begin()); it != p_mapCallableMethod.end(); ++it){
                delete it->second;
        }
        p_mapCallableMethod.clear();
}

References p_mapCallableMethod.

Referenced by ~BaseDaemon().

Here is the caller graph for this function:

clearStat()

void BaseDaemon::clearStat ( )

inherited

Clear all the statistics of the daemon.

Definition at line 349 of file BaseDaemon.cpp.

                          {
        for(MapStatAccumulator::iterator it = p_config.getDaemonStatAccumulator().getMapStatComputing().begin(); it != p_config.getDaemonStatAccumulator().getMapStatComputing().end(); ++it){
                it->second.setNbEvent(0lu);
                std::fill(it->second.getVecHistogram().begin(), it->second.getVecHistogram().end(), 0lu);
        }
        for(MapDaemonStatAccumulator::iterator itMap = p_config.getDaemonStatAccumulator().getMapStatCommunication().begin(); itMap != p_config.getDaemonStatAccumulator().getMapStatCommunication().end(); ++itMap){
                for(MapStatAccumulator::iterator it = itMap->second.begin(); it != itMap->second.end(); ++it){
                        it->second.setNbEvent(0lu);
                        std::fill(it->second.getVecHistogram().begin(), it->second.getVecHistogram().end(), 0lu);
                }
        }
}

References p_config.

Referenced by Daemon< _TBackend >::sendStatToStatDaemon().

Here is the caller graph for this function:

createNewCommunicationStatMap()

std::map< PString, StatAccumulator > BaseDaemon::createNewCommunicationStatMap ( const PString & dataType, size_t nbBin, float histLowerBound, float histUpperBound )

privateinherited

Create a new map of communication statistic.

Parameters

dataType	: type of data which where pushed
nbBin	: number of bin of the histogram
histLowerBound	: lower bound of the histogram
histUpperBound	: upper bound of the histogram

Returns

new map of communication statistic

Definition at line 411 of file BaseDaemon.cpp.

                                                                                                                                                            {
        std::map<PString, StatAccumulator> newStatMap;
        newStatMap[dataType] = createNewStat(nbBin, histLowerBound, histUpperBound);
        return newStatMap;
}

References createNewStat().

Referenced by getCommunicationStat().

Here is the call graph for this function:

Here is the caller graph for this function:

createNewStat()

StatAccumulator BaseDaemon::createNewStat ( size_t nbBin, float histLowerBound, float histUpperBound )

inherited

Create a new clear computing statistic.

Parameters

nbBin	: number of bin of the histogram
histLowerBound	: lower bound of the histogram
histUpperBound	: upper bound of the histogram

Returns

new clear computing statistic

Definition at line 326 of file BaseDaemon.cpp.

                                                                                                 {
        StatAccumulator newStat;
        newStat.setNbEvent(0lu);
        newStat.setMin(std::nan(""));
        newStat.setMax(std::nan(""));
        newStat.setSum(std::nan(""));
        newStat.setNbEventAboveUpperBound(0lu);
        newStat.setNbEventBelowLowerBound(0lu);
        newStat.setHistUpperBound(histUpperBound);
        newStat.setHistLowerBound(histLowerBound);
        newStat.setVecHistogram(std::vector<size_t>(nbBin, 0lu));
        return newStat;
}

References StatAccumulator::setHistLowerBound(), StatAccumulator::setHistUpperBound(), StatAccumulator::setMax(), StatAccumulator::setMin(), StatAccumulator::setNbEvent(), StatAccumulator::setNbEventAboveUpperBound(), StatAccumulator::setNbEventBelowLowerBound(), StatAccumulator::setSum(), and StatAccumulator::setVecHistogram().

Referenced by addDataCallableMethod(), addDataCallableMethod(), createNewCommunicationStatMap(), and getCommunicationStat().

Here is the call graph for this function:

Here is the caller graph for this function:

executeOnStop()

template<class _TBackend>

void Daemon< _TBackend >::executeOnStop ( )

virtualinherited

Method which is called on stop of the Daemon.

Definition at line 206 of file Daemon_impl.h.

{}

Referenced by run().

Here is the caller graph for this function:

extraLoad()

bool BaseDaemon::extraLoad ( const ConfigNode * config )

virtualinherited

Extra call on load for the current Daemon.

Parameters

config

: configuration for the current Daemon

Returns

true on success, false otherwise

Definition at line 102 of file BaseDaemon.cpp.

                                                   {
        return true;
}

extraLoopProcessing()

template<class _TBackend>

void Daemon< _TBackend >::extraLoopProcessing ( )

virtualinherited

Computing Method for each event loop (when receiving message from other Daemon)

Definition at line 202 of file Daemon_impl.h.

{}

Referenced by run().

Here is the caller graph for this function:

fillDaemonStat()

void BaseDaemon::fillDaemonStat ( DaemonStat & stat, time_t startTimestamp, time_t endTimestamp )

protectedinherited

Fill the DaemonStat with the current statistics of the daemon.

Parameters

stat	DaemonStat to be filled
startTimestamp	time at which the statistic started to be filled
endTimestamp	time at which the statistic stopped to be filled

Definition at line 476 of file BaseDaemon.cpp.

                                                                                            {
        // Fill the computing statistics
        MapStatAccumulator & mapStatComputing = p_config.getDaemonStatAccumulator().getMapStatComputing();
        for(MapStatAccumulator::iterator it = mapStatComputing.begin(); it != mapStatComputing.end(); ++it){
                StatAccumulator & accumulator = it->second;
                VecStat vecStat = fillVecStat(accumulator, startTimestamp, endTimestamp);
                stat.getMapStatComputing()[it->first] = vecStat;
        }
 
        // Fill the communication statistics
        MapDaemonStatAccumulator & mapStatCommunication = p_config.getDaemonStatAccumulator().getMapStatCommunication();
        for(MapDaemonStatAccumulator::iterator itMap = mapStatCommunication.begin(); itMap != mapStatCommunication.end(); ++itMap){
                const PString & destName = itMap->first;
                std::map<PString, VecStat> & mapVecStat = stat.getMapStatCommunication()[destName];
                for(MapStatAccumulator::iterator it = itMap->second.begin(); it != itMap->second.end(); ++it){
                        StatAccumulator & accumulator = it->second;
                        VecStat vecStat = fillVecStat(accumulator, startTimestamp, endTimestamp);
                        mapVecStat[it->first] = vecStat;
                }
        }
}

References fillVecStat(), DaemonStat::getMapStatCommunication(), DaemonStat::getMapStatComputing(), and p_config.

Referenced by Daemon< _TBackend >::sendStatToStatDaemon().

Here is the call graph for this function:

Here is the caller graph for this function:

fillStatInfo()

template<class _TBackend>

PUncastableBool StatDaemonManager< _TBackend >::fillStatInfo

(

const DaemonStat &

stat

)

Fill the StatInfo of the StatDaemonManager with the given DaemonStat.

Parameters

stat	: DaemonStat to be filled

Returns

true on success, false otherwise

Definition at line 55 of file StatDaemonManager_impl.h.

                                                                                  {
        p_mapDaemonStat[stat.getName()] = stat;
        return UNCASTABLE_TRUE;
}

References DaemonStat::getName(), and p_mapDaemonStat.

Referenced by sortFillDaemonStat().

Here is the call graph for this function:

Here is the caller graph for this function:

fillVecStat()

VecStat BaseDaemon::fillVecStat ( const StatAccumulator & accumulator, time_t startTimestamp, time_t endTimestamp )

protectedinherited

Fill a VecStat from a StatAccumulator to send to the DamonStat.

Parameters

accumulator	StatAccumulator to be converted
startTimestamp	time at which the statistic started to be filled
endTimestamp	time at which the statistic stopped to be filled

Returns

VecStat filled with the statistics from the accumulator

Definition at line 446 of file BaseDaemon.cpp.

                                                                                                              {
        VecStat vecStat;
        
        // Compute event values
        vecStat.getNbEvent().push_back(accumulator.getNbEvent());
        vecStat.getMin().push_back(accumulator.getMin());
        vecStat.getMax().push_back(accumulator.getMax());
        vecStat.getAverage().push_back(accumulator.getSum() / accumulator.getNbEvent());
 
        // Compute time values
        vecStat.getStartTimestamp().push_back(startTimestamp);
        vecStat.getEndTimestamp().push_back(endTimestamp);
        time_t rate = endTimestamp - startTimestamp;
        vecStat.getRate().push_back(accumulator.getNbEvent()*1e9 / rate);
        vecStat.getRateEventAboveUpperBound().push_back(accumulator.getNbEventAboveUpperBound()*1e9 / rate);
        vecStat.getRateEventBelowLowerBound().push_back(accumulator.getNbEventBelowLowerBound()*1e9 / rate);
        
        vecStat.getVecRateQuantile().resize(accumulator.getVecHistogram().size());
        for(size_t i = 0; i < accumulator.getVecHistogram().size(); ++i){
                vecStat.getVecRateQuantile()[i].push_back(accumulator.getVecHistogram()[i]*1e9 / rate);
        }
        return vecStat;
}

References VecStat::getAverage(), VecStat::getEndTimestamp(), StatAccumulator::getMax(), VecStat::getMax(), StatAccumulator::getMin(), VecStat::getMin(), StatAccumulator::getNbEvent(), VecStat::getNbEvent(), StatAccumulator::getNbEventAboveUpperBound(), StatAccumulator::getNbEventBelowLowerBound(), VecStat::getRate(), VecStat::getRateEventAboveUpperBound(), VecStat::getRateEventBelowLowerBound(), VecStat::getStartTimestamp(), StatAccumulator::getSum(), StatAccumulator::getVecHistogram(), and VecStat::getVecRateQuantile().

Referenced by fillDaemonStat().

Here is the call graph for this function:

Here is the caller graph for this function:

getCommunicationStat()

void BaseDaemon::getCommunicationStat ( const PString & destName, const PString & dataType, float latency, size_t nbBin, float histLowerBound, float histUpperBound )

privateinherited

Add a communication statistic.

Parameters

destName	: name of the destination Daemon from which data where pushed
dataType	: type of data which where pushed
latency	: latency between the send of the data and the receiving of the confirmation by the daemon destName
nbBin	: number of bin of the histogram
histLowerBound	: lower bound of the histogram
histUpperBound	: upper bound of the histogram

Definition at line 425 of file BaseDaemon.cpp.

                                                                                                                                                                {
        std::map<PString, std::map<PString, StatAccumulator> > & mapCommunication = p_config.getDaemonStatAccumulator().getMapStatCommunication();
        MapDaemonStatAccumulator::iterator it = mapCommunication.find(destName);
        if(it == mapCommunication.end()){
                mapCommunication[destName] = createNewCommunicationStatMap(dataType, nbBin, histLowerBound, histUpperBound);
        }
        else{
                std::map<PString, StatAccumulator>::iterator itDataType = it->second.find(dataType);
                if(itDataType == it->second.end()){
                        it->second[dataType] = createNewStat(nbBin, histLowerBound, histUpperBound);
                }
        }
        updateStatAccumulator(p_config.getDaemonStatAccumulator().getMapStatCommunication().find(destName)->second[dataType], latency);
}

References createNewCommunicationStatMap(), createNewStat(), p_config, and updateStatAccumulator().

Referenced by processConfirmedMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

getConfig()

DaemonConfig & BaseDaemon::getConfig ( )

inherited

Get the configuration of the current BaseDaemon.

Returns

configuration of the current BaseDaemon

Definition at line 365 of file BaseDaemon.cpp.

                                    {
        return p_config;
}

References p_config.

Referenced by StatDaemonManager< _TBackend >::addCallMethod().

Here is the caller graph for this function:

getDataFunction()

AbstractDataFunction * BaseDaemon::getDataFunction ( const Data & data )

inherited

Get the data function associated with the given data.

Parameters

data	The data for which to retrieve the associated function

Returns

A pointer to the associated data function, or nullptr if not found

Definition at line 262 of file BaseDaemon.cpp.

                                                                  {
        PString prototype(data.getType());
        std::map<PString, AbstractDataFunction*>::iterator it(p_mapDataFunction.find(prototype));
        if(it == p_mapDataFunction.end()){
                getLog().getLogError() << "BaseDaemon::getDataFunction : function to process data '"<<prototype<<"' not found" << std::endl;
                return nullptr;
        }
        return it->second;
}

References getLog(), Data::getType(), and p_mapDataFunction.

Referenced by processData(), and Daemon< _TBackend >::processInputMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

getLog()

PLog & BaseDaemon::getLog ( )

inherited

Get the log of the current BaseDaemon.

Returns

log of the current BaseDaemon

Definition at line 154 of file BaseDaemon.cpp.

                         {
        return p_log;
}

References p_log.

Referenced by addCallableMethod(), StatDaemonManager< _TBackend >::addCallMethod(), addDataCallableMethod(), addDataCallableMethod(), callMethod(), checkMessageTimeout(), getDataFunction(), Daemon< _TBackend >::initialisationDaemonSocket(), processConfirmedMessage(), processData(), Daemon< _TBackend >::processInputMessage(), Daemon< _TBackend >::sendStatToStatDaemon(), and updateStatAccumulator().

Here is the caller graph for this function:

getLogger()

PLog & BaseDaemon::getLogger ( )

inherited

Get the logger of the current BaseDaemon.

Returns

logger of the current BaseDaemon

Definition at line 386 of file BaseDaemon.cpp.

                            {
        return p_log;
}

References p_log.

getMainConfig()

DaemonMainConfig & BaseDaemon::getMainConfig ( )

inherited

Get the main configuration of the swarm.

Returns

main configuration of the swarm

Definition at line 379 of file BaseDaemon.cpp.

                                            {
        return p_mainConfig;
}

References p_mainConfig.

getMapDaemonConfig()

MapDaemonConfig & BaseDaemon::getMapDaemonConfig ( )

inherited

Get the map of all Daemon configurations.

Returns

map of all Daemon configurations

Definition at line 372 of file BaseDaemon.cpp.

                                                {
        return p_mapDaemon;
}

References p_mapDaemon.

getMapDaemonStat()

template<class _TBackend>

const MapDaemonStat & StatDaemonManager< _TBackend >::getMapDaemonStat

(

)

const

Get the map of DaemonStat.

Returns

map of DaemonStat

Definition at line 30 of file StatDaemonManager_impl.h.

                                                                          {
        return p_mapDaemonStat;
}

References p_mapDaemonStat.

getMapMessageToBeConfirmed()

const std::map< size_t, Message > & BaseDaemon::getMapMessageToBeConfirmed ( ) const

inherited

Get the map of message to be confirmed.

Returns

map of message to be confirmed

Definition at line 343 of file BaseDaemon.cpp.

                                                                             {
        return p_mapMessageToBeConfirmed;
}

References p_mapMessageToBeConfirmed.

getMessageId()

size_t BaseDaemon::getMessageId ( )

inherited

Get current message id.

Returns

current message id

Definition at line 253 of file BaseDaemon.cpp.

                               {
        ++p_messageId;
        return p_messageId;
}

References p_messageId.

Referenced by Daemon< _TBackend >::sendData().

Here is the caller graph for this function:

getMessageToConfirm()

bool BaseDaemon::getMessageToConfirm ( Message & message, size_t id ) const

inherited

Get a message to confirm by id if it exists.

Parameters

[out]	message	: message which has the id id
	id	: id of the message to be searched

Returns

true if the message with id id does exist, false otherwise

Definition at line 189 of file BaseDaemon.cpp.

                                                                      {
        std::map<size_t, Message>::const_iterator it(p_mapMessageToBeConfirmed.find(id));
        if(it != p_mapMessageToBeConfirmed.end()){
                message = it->second;
                return true;
        }
        return false;
}

References p_mapMessageToBeConfirmed.

getOptionParser()

OptionParser & BaseDaemon::getOptionParser ( )

inherited

Return the OptionParser of the current BaseDaemon.

Returns

OptionParser of the current BaseDaemon

Definition at line 147 of file BaseDaemon.cpp.

                                          {
        return p_optionParser;
}

References p_optionParser.

getStatsCount()

template<class _TBackend>

size_t StatDaemonManager< _TBackend >::getStatsCount

(

)

const

Get the count of stats received.

Returns

number of stats received

Definition at line 46 of file StatDaemonManager_impl.h.

                                                         { 
        return p_mapDaemonStat.size();
}

References p_mapDaemonStat.

hasReceivedStats()

template<class _TBackend>

bool StatDaemonManager< _TBackend >::hasReceivedStats

(

)

const

Check if stats have been received.

Returns

true if the stats have been received, false otherwise

Definition at line 38 of file StatDaemonManager_impl.h.

                                                          {
        return !p_mapDaemonStat.empty();
}

References p_mapDaemonStat.

initialisationBaseDaemon()

void BaseDaemon::initialisationBaseDaemon ( )

privateinherited

Initialisation function of the class BaseDaemon.

Definition at line 391 of file BaseDaemon.cpp.

                                         {
        p_optionParser.setExampleLongOption("phoenix_daemon --daemonconfig=daemon_config.toml --daemonname=main");
        p_optionParser.setExampleShortOption("phoenix_daemon -c daemon_config.toml -n main");
        p_optionParser.addOption("daemonconfig", "c", OptionType::FILENAME, true, "Toml configuration file which define all Daemons of the swarm");
        p_optionParser.addOption("daemonname", "n", OptionType::STRING, true, "Name of the current Daemon of the swarm configuration defined with --daemonconfig");
        p_optionParser.addOption("mock", "m", OptionType::NONE, false, "Activate the Daemon in mock mode for the sockets and the clock");
        p_optionParser.addOption("mockrecord", "r", OptionType::NONE, false, "Activate the Daemon in mock record mode for the sockets and the clock");
        p_isRun = false;
        p_messageId = 0lu;
        p_isFullMock = false;
        p_isFullMockRecord = false;
}

References p_isFullMock, p_isFullMockRecord, p_isRun, p_messageId, and p_optionParser.

Referenced by BaseDaemon().

Here is the caller graph for this function:

initialisationDaemon()

template<class _TBackend>

void Daemon< _TBackend >::initialisationDaemon ( )

privateinherited

Initialisation function of the class Daemon.

Definition at line 210 of file Daemon_impl.h.

                                            {
        
}

Referenced by Daemon().

Here is the caller graph for this function:

initialisationDaemonSocket()

template<class _TBackend>

void Daemon< _TBackend >::initialisationDaemonSocket ( )

privateinherited

Initialise the Daemon Sockets.

Definition at line 216 of file Daemon_impl.h.

                                                  {
        if(p_config.getName() == ""){
                getLog().criticalAndThrow<Phoenix::ConfigException>("Daemon::initialisationDaemonSocket", "daemon has no name");
        }
        if(p_isFullMockRecord){
                setSocketMode(PSocketMode::MOCK_RECORD);
                setClockMode(PClockMode::MOCK_RECORD);
        }else{
                if(p_isFullMock){
                        setSocketMode(PSocketMode::MOCK);
                        setClockMode(PClockMode::MOCK);
                }
        }
        //Let's send when we are a client and recv when we are a server
        //By doing this way, we have one server per Daemon and as many clients as other Daemon
        getLog().getLogInfo() << "Daemon<_TBackend>::initialisationDaemonSocket() : initialise pull socket for daemon '" << p_config.getName() << "'" << std::endl;
        phoenix_assert(p_backend.socketManager.addServerSocket("pull",
                        PSocketParam{p_config.getHostName(), p_config.getReceivingPort(), p_mainConfig.recvTimeoutMs, p_mainConfig.sendTimeoutMs}, p_backend.extraServerParam,
                        "./" + p_config.getName() + "_", p_backend.extraMockServerParam));
        
        //Now let's initialise connexions to other
        for(MapDaemonConfig::iterator it(p_mapDaemon.begin()); it != p_mapDaemon.end(); ++it){
                if(it->second.getName() == p_config.getName()){continue;}
                getLog().getLogInfo() << "Daemon<_TBackend>::initialisationDaemonSocket() : initialise send socket for neighbour Daemon '"<<it->second.getName()<<"'" << std::endl;
                phoenix_assert(p_backend.socketManager.addClientSocket(it->second.getName(),
                        PSocketParam{it->second.getHostName(), it->second.getReceivingPort(), p_mainConfig.recvTimeoutMs, p_mainConfig.sendTimeoutMs}, p_backend.extraClientParam,
                        "./" + p_config.getName() + "_", p_backend.extraMockClientParam));
                // p_backend.socketManager.getSocket(it->second.getName())->waitUntilConnection(500000lu, 30lu);        //0.5 s per check and 30 checks
        }
        getLog().getLogInfo() << "Daemon<_TBackend>::initialisationDaemonSocket() : all connection to neighbours Daemon initialised" << std::endl;
        p_backend.clock.setMockPrefix("./" + p_config.getName() + "_");
}

References BaseDaemon::getLog(), p_backend, BaseDaemon::p_config, BaseDaemon::p_isFullMock, BaseDaemon::p_isFullMockRecord, BaseDaemon::p_mapDaemon, setClockMode(), and setSocketMode().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

initializeStatDaemonManager()

template<class _TBackend>

void StatDaemonManager< _TBackend >::initializeStatDaemonManager ( )

private

Initialize the StatDaemonManager.

Definition at line 62 of file StatDaemonManager_impl.h.

                                                              {
        
}

Referenced by StatDaemonManager().

Here is the caller graph for this function:

isDaemonExist()

bool BaseDaemon::isDaemonExist ( const PString & name ) const

inherited

Say if a neighbour Daemon does exist.

Parameters

name	: name of the Daemon to be searched

Returns

true if the Daemon does exist, false otherwise

Definition at line 162 of file BaseDaemon.cpp.

                                                        {
        MapDaemonConfig::const_iterator it(p_mapDaemon.find(name));
        if(it == p_mapDaemon.end()){
                //Then if the stat daemon does not exist in the map, it may be the current daemon
                if(p_config.getName() == name){
                        return true;
                }
        }
        if(it != p_mapDaemon.end()){
                return true;
        }
 
        return false;
}

References p_config, and p_mapDaemon.

Referenced by loadConfigFromNode().

Here is the caller graph for this function:

load() [1/2]

bool BaseDaemon::load ( const PPath & fileName, const PString & daemonName )

inherited

Load the Toml configuration which define all BaseDaemons of the Swarm.

Parameters

fileName	: name of the configuration file of all the BaseDaemons of the Swarm in toml format
daemonName	: name of the current BaseDaemon in the given file

Returns

true on success, false otherwise

Definition at line 91 of file BaseDaemon.cpp.

                                                                       {
        ConfigNode dico;
        daemon_load_config(p_log, dico, fileName);
        loadConfigFromNode(dico, daemonName);
        return true;
}

References daemon_load_config(), loadConfigFromNode(), and p_log.

Here is the call graph for this function:

load() [2/2]

bool BaseDaemon::load ( const PString & configFileContent, const PString & daemonName, ConfigFormat::ConfigFormat format )

inherited

Load the Json configuration which define all BaseDaemons of the Swarm.

Parameters

configFileContent	: name of the configuration file of all the BaseDaemons of the Swarm in json format
daemonName	: name of the current BaseDaemon in the given file
format	: format of the configuration file

Returns

true on success, false otherwise

Definition at line 79 of file BaseDaemon.cpp.

                                                                                                                   {
        ConfigNode dico;
        daemon_load_config(p_log, dico, configFileContent, format);
        loadConfigFromNode(dico, daemonName);
        return true;
}

References daemon_load_config(), loadConfigFromNode(), and p_log.

Referenced by parseArgument().

Here is the call graph for this function:

Here is the caller graph for this function:

loadConfigFromNode()

void BaseDaemon::loadConfigFromNode ( const ConfigNode & dico, const PString & daemonName )

inherited

Load configuration form a node of ConfigNode.

Parameters

[out]	dico	: loaded configuration
	daemonName	: name of the current Daemon in the configuration

Returns

true on success, false otherwise

Definition at line 45 of file BaseDaemon.cpp.

                                                                                       {
        const ConfigNode * mapMainConfig = dico.getChild("swarm");
        if(mapMainConfig != nullptr){
                p_mainConfig.recvTimeoutMs = phoenix_get_value<int>(*mapMainConfig, "recv_timeout_ms", -1);
                p_mainConfig.sendTimeoutMs = phoenix_get_value<int>(*mapMainConfig, "send_timeout_ms", -1);
                p_mainConfig.recvFlag = daemonRecvFlagFromString(phoenix_get_string(*mapMainConfig, "recv_flag", "NON_BLOCK"));
                p_mainConfig.sendFlag = daemonSendFlagFromString(phoenix_get_string(*mapMainConfig, "send_flag", "NON_BLOCK"));
        }
        std::map<PString, time_t> mapTimeout;
        const ConfigNode * extraConfigParam = nullptr;
        daemon_read_configNode(p_config, p_mapDaemon, p_log, mapTimeout, extraConfigParam, dico, daemonName);
        
        const ConfigNode * mapStatDaemon = dico.getChild("statistics");
        if(mapStatDaemon != nullptr){
                p_config.setStatDaemonName(daemon_loadString(*mapStatDaemon, "stat_daemon_name"));
        }
        p_config.setMapTimeout(mapTimeout);
        if(p_config.getStatDaemonName() != ""){
                if(!isDaemonExist(p_config.getStatDaemonName())){
                        p_log.getLogError() << "BaseDaemon::loadConfigFromNode : stat daemon '"<<p_config.getStatDaemonName()<<"' not found in configuration" << std::endl;
                }
        }
 
        p_log.getLogInfo() << "BaseDaemon::loadConfigFromNode : loading configuration successful" << std::endl;
        p_log.getLogInfo() << "BaseDaemon::loadConfigFromNode : ready to call addCallMethod to subscribe on received data" << std::endl;
        addCallMethod();
}

References addCallMethod(), daemon_loadString(), daemon_read_configNode(), isDaemonExist(), p_config, p_log, p_mainConfig, and p_mapDaemon.

Referenced by load(), and load().

Here is the call graph for this function:

Here is the caller graph for this function:

parseArgument()

bool BaseDaemon::parseArgument ( int argc, char ** argv )

inherited

Parse arguments given to the BaseDaemon with command line.

Parameters

argc	: number of arguments given to the program
argv	: list of arguments given to the program

Returns

true on success, false otherwise

Definition at line 28 of file BaseDaemon.cpp.

                                                   {
        p_optionParser.parseArgument(argc, argv);
        const OptionMode & defaultMode = p_optionParser.getDefaultMode();
        PPath configurationFile;
        defaultMode.getValue(configurationFile, "daemonconfig");
        PString daemonName;
        defaultMode.getValue(daemonName, "daemonname");
        p_isFullMock = defaultMode.isOptionExist("mock");
        p_isFullMockRecord = defaultMode.isOptionExist("mockrecord");
        return load(configurationFile, daemonName);
}

References load(), p_isFullMock, p_isFullMockRecord, and p_optionParser.

Here is the call graph for this function:

processConfirmedMessage()

void BaseDaemon::processConfirmedMessage ( size_t id, time_t currentTime )

inherited

Process confirmed message.

Parameters

id	: id of the message to be removed
currentTime	: time when the confirmation was received

Definition at line 202 of file BaseDaemon.cpp.

                                                                     {
        std::map<size_t, Message>::const_iterator it(p_mapMessageToBeConfirmed.find(id));
        if(it != p_mapMessageToBeConfirmed.end()){
                getLog().getLogInfo() << "BaseDaemon::processConfirmedMessage : adding statistics for processed transaction " << id << std::endl;
                const Message & message = it->second;
                time_t ellapsedTime = currentTime - message.getSendTime();
                for(const PString & receiver : message.getVecRecver()){
                        getLog().getLogDebug() << "BaseDaemon::processConfirmedMessage : add statistic for receiver : " << receiver << std::endl;
                        getCommunicationStat(receiver, message.getData().getType(), ellapsedTime, p_config.getStatNbBin(), p_config.getStatHistLowerBound(), p_config.getStatHistUpperBound());
                }
                // Remove the confirmed message
                getLog().getLogInfo() << "BaseDaemon::removeConfirmedMessage : remove confirmed transaction " << id << std::endl;
                p_mapMessageToBeConfirmed.erase(it);
        }else{
                getLog().getLogError() << "BaseDaemon::processConfirmedMessage : transaction " << id << " not found in p_mapMessageToBeConfirmed" << std::endl;
        }
}

References getCommunicationStat(), Message::getData(), getLog(), Message::getSendTime(), Data::getType(), Message::getVecRecver(), p_config, and p_mapMessageToBeConfirmed.

Referenced by Daemon< _TBackend >::processInputMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

processData()

bool BaseDaemon::processData ( const Data & data )

inherited

Process given data with the proper method.

Parameters

data	: data to be processed

Returns

true on success, false otherwise

Definition at line 276 of file BaseDaemon.cpp.

                                             {
        AbstractDataFunction* function = getDataFunction(data);
        if(function == nullptr){
                return false;
        }
        getLog().getLogDebug() << "BaseDaemon::processData : process data '"<<data.getType()<<"'" << std::endl;
        bool b = function->call(p_log, data);
        return b;
}

References AbstractDataFunction::call(), getDataFunction(), getLog(), Data::getType(), and p_log.

Here is the call graph for this function:

processEvent()

template<class _TBackend>

bool StatDaemonManager< _TBackend >::processEvent

(

)

Process event.

Returns

true

Definition at line 70 of file StatDaemonManager_impl.h.

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

processInputMessage()

template<class _TBackend>

void Daemon< _TBackend >::processInputMessage ( Message & message )

protectedinherited

Process an input message.

Parameters

[out]

message

: received Message to be processed

Definition at line 253 of file Daemon_impl.h.

                                                            {
        //Check is the message needs a confirmation
        if(message.getIsConfirmationNeeded()){
                Message confirmation;
                //We do not need to change the time of the message because it has to be in the clock reference of the sender
                confirmation.setSendTime(message.getSendTime());
                confirmation.setId(message.getId());
                confirmation.setSender(p_config.getName());
                confirmation.setType(MessageType::MESSAGE_CONFIRMATION);
                confirmation.getVecRecver().push_back(message.getSender());
                sendMessage(confirmation);
        }
        
        //Let's check is we receive a stop message
        if(message.getType() == MessageType::STOP){stop();}
        else if(message.getType() == MessageType::MESSAGE_CONFIRMATION){
                processConfirmedMessage(message.getId(), p_backend.clock.now());
        }else if(message.getType() == MessageType::RESULT_DATA){
                AbstractDataFunction* function = getDataFunction(message.getData());
                if(function == NULL){
                        return;
                }
                time_t functionStartTime = p_backend.clock.now();
                if(!function->call(p_log, message.getData())){
                        getLog().getLogError() << "Daemon<_TBackend>::processInputMessage : cannot process data of type '"<<message.getData().getType()<<"' from Daemon '"<<message.getSender()<<"'" << std::endl;
                        return;
                }
                time_t functionEllapsedTime = p_backend.clock.now() - functionStartTime;
                getLog().getLogDebug() << "Daemon<_TBackend>::processInputMessage : function '"<<message.getData().getType()<<"' processed data from daemon '"<<message.getSender()<<"' in "<<functionEllapsedTime<<" nanoseconds" << std::endl;
                if(p_config.getStatDaemonName() != "" && p_config.getStatDaemonName() != p_config.getName()){
                        updateStatAccumulator(p_config.getDaemonStatAccumulator().getMapStatComputing().find(message.getData().getType())->second, functionEllapsedTime);
                }
        }
}

References AbstractDataFunction::call(), Message::getData(), BaseDaemon::getDataFunction(), Message::getId(), Message::getIsConfirmationNeeded(), BaseDaemon::getLog(), Message::getSender(), Message::getSendTime(), Data::getType(), Message::getType(), Message::getVecRecver(), MessageType::MESSAGE_CONFIRMATION, p_backend, BaseDaemon::p_config, BaseDaemon::p_log, BaseDaemon::processConfirmedMessage(), MessageType::RESULT_DATA, sendMessage(), Message::setId(), Message::setSender(), Message::setSendTime(), Message::setType(), MessageType::STOP, BaseDaemon::stop(), and BaseDaemon::updateStatAccumulator().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

run()

template<class _TBackend>

bool Daemon< _TBackend >::run ( )

inherited

Run the Daemon.

Returns

true if the run was a success, false otherwise

Definition at line 125 of file Daemon_impl.h.

                           {
        p_isRun = true;
        //Let's initialise all connexions
        initialisationDaemonSocket();
        p_startTimestamp = p_backend.clock.now();
        p_statTimer.setEllapsedTime(p_config.getStatTimerPeriodMs());
        p_statTimer.setStartTime(p_startTimestamp);
        while(p_isRun){
                //Let's get the last received message
                //If there is not message, we treat the rest of the loop
                Message message;
                PRecvStatus::PRecvStatus recvStatus = checkRecvStatus(p_backend.socketManager.recvData("pull", message, p_mainConfig.recvFlag));
                if(recvStatus == PRecvStatus::OK){
                        processInputMessage(message);
                }
                extraLoopProcessing();
 
                time_t currentTime = p_backend.clock.now();
                checkMessageTimeout(currentTime);
                if(p_statTimer.isTime(currentTime) || !p_isRun){
                        sendStatToStatDaemon(currentTime);
                }
        }
        //Let's execute a last command before stop
        executeOnStop();
        return true;
}

References BaseDaemon::checkMessageTimeout(), checkRecvStatus(), executeOnStop(), extraLoopProcessing(), initialisationDaemonSocket(), p_backend, BaseDaemon::p_config, BaseDaemon::p_isRun, BaseDaemon::p_mainConfig, p_startTimestamp, p_statTimer, processInputMessage(), and sendStatToStatDaemon().

Here is the call graph for this function:

sendData()

template<class _TBackend>

bool Daemon< _TBackend >::sendData ( const PString & destinationName, const Data & data, bool isConfirmationNeeded )

inherited

Send data to other Daemon (specialization for Data)

Parameters

destinationName	: name of the destination Daemon of the data
data	: data to be sent
isConfirmationNeeded	: true if a confirmation is needed

Returns

true on success, false otherwise (maybe received method does not exist)

Definition at line 188 of file Daemon_impl.h.

                                                                                                             {
        Message message;
        message.setSendTime(p_backend.clock.now());
        message.setData(data);
        message.setId(getMessageId());
        message.setIsConfirmationNeeded(isConfirmationNeeded);
        message.setType(MessageType::RESULT_DATA);
        message.setSender(p_config.getName());
        message.getVecRecver().push_back(destinationName);
        return sendMessage(destinationName, message);
}

References BaseDaemon::getMessageId(), Message::getVecRecver(), p_backend, BaseDaemon::p_config, MessageType::RESULT_DATA, sendMessage(), Message::setData(), Message::setId(), Message::setIsConfirmationNeeded(), Message::setSender(), Message::setSendTime(), and Message::setType().

Referenced by sendValue().

Here is the call graph for this function:

Here is the caller graph for this function:

sendMessage() [1/2]

template<class _TBackend>

bool Daemon< _TBackend >::sendMessage ( const Message & message )

inherited

Send message to other Daemon.

Parameters

message

: message to be sent

Returns

true on success, false otherwise (maybe received method does not exist)

Definition at line 158 of file Daemon_impl.h.

                                                          {
        bool b(true);
        const PVecString & vecDestination = message.getVecRecver();
        for(PVecString::const_iterator it(vecDestination.begin()); it != vecDestination.end(); ++it){
                b &= sendMessage(*it, message);
        }
        return b;
}

References Message::getVecRecver(), and sendMessage().

Referenced by processInputMessage(), sendData(), and sendMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

sendMessage() [2/2]

template<class _TBackend>

bool Daemon< _TBackend >::sendMessage ( const PString & destinationName, const Message & message )

inherited

Send message to other Daemon.

Parameters

destinationName	: name of the destination Daemon of the message
message	: message to be sent

Returns

true on success, false otherwise (maybe received method does not exist)

Definition at line 173 of file Daemon_impl.h.

                                                                                           {
        if(message.getIsConfirmationNeeded()){
                addMessageToConfirm(message);
        }
        checkSendStatus(p_backend.socketManager.sendData(destinationName, message, p_mainConfig.sendFlag));
        return true;
}

References BaseDaemon::addMessageToConfirm(), checkSendStatus(), Message::getIsConfirmationNeeded(), p_backend, and BaseDaemon::p_mainConfig.

Here is the call graph for this function:

sendStatToStatDaemon()

template<class _TBackend>

void Daemon< _TBackend >::sendStatToStatDaemon ( time_t currentTime )

privateinherited

Send the statistics of the Daemon to the Stat Daemon.

Parameters

[out]

currentTime

: current time to be used for the statistics

Definition at line 292 of file Daemon_impl.h.

                                                              {
        //Let's fill the DaemonStat
        DaemonStat stat;
        fillDaemonStat(stat, p_startTimestamp, currentTime);
        stat.setName(p_config.getName());
 
        //Let's send it to the Stat Daemon
        if(p_config.getStatDaemonName() != "" && p_config.getStatDaemonName() != p_config.getName()){
                getLog().getLogDebug() << "Daemon::sendStatToStatDaemon() : sending statistics to Stat Daemon '"<<p_config.getStatDaemonName()<<"'" << std::endl;
                sendValue(p_config.getStatDaemonName(), stat, true);
        }
 
        clearStat();
        p_startTimestamp = currentTime;
}

References BaseDaemon::clearStat(), BaseDaemon::fillDaemonStat(), BaseDaemon::getLog(), BaseDaemon::p_config, p_startTimestamp, sendValue(), and DaemonStat::setName().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

sendValue()

template<class _TBackend>

template<typename T>

bool Daemon< _TBackend >::sendValue ( const PString & destinationName, const T & data, bool isConfirmationNeeded = true )

inlineinherited

Send data to other Daemon.

Parameters

destinationName	: name of the destination Daemon of the data
data	: data to be sent
isConfirmationNeeded	: true if a confirmation is needed

Returns

true on success, false otherwise (maybe received method does not exist)

Definition at line 38 of file Daemon.h.

                                                                                                                 {
                        return sendData(destinationName, phoenix_createData(data), isConfirmationNeeded);
                }

References phoenix_createData(), and sendData().

Referenced by sendStatToStatDaemon().

Here is the call graph for this function:

Here is the caller graph for this function:

setClockMode()

template<class _TBackend>

void Daemon< _TBackend >::setClockMode ( PClockMode::PClockMode mode )

inherited

Set the mode of the clock.

Parameters

mode	: mode of the clock (NO_MOCK, MOCK, MOCK_RECORD)

Definition at line 53 of file Daemon_impl.h.

                                                             {
        p_backend.clock.setMode(mode);
        switch(mode){
                case PClockMode::MOCK:
                        p_isFullMock = true;
                        p_isFullMockRecord = false;
                        break;
                case PClockMode::MOCK_RECORD:
                        p_isFullMock = false;
                        p_isFullMockRecord = true;
                        break;
                default:
                        p_isFullMock = false;
                        p_isFullMockRecord = false;
                        break;
        }
}

References p_backend, BaseDaemon::p_isFullMock, and BaseDaemon::p_isFullMockRecord.

Referenced by initialisationDaemonSocket().

Here is the caller graph for this function:

setSocketMode()

template<class _TBackend>

void Daemon< _TBackend >::setSocketMode ( PSocketMode::PSocketMode mode )

inherited

Set the mode of the sockets of the SocketManager.

Parameters

mode	: mode of the socket manager (NO_MOCK, MOCK, MOCK_RECORD)

Definition at line 31 of file Daemon_impl.h.

                                                                {
        p_backend.socketManager.setMode(mode);
        switch(mode){
                case PSocketMode::MOCK:
                        p_isFullMock = true;
                        p_isFullMockRecord = false;
                        break;
                case PSocketMode::MOCK_RECORD:
                        p_isFullMock = false;
                        p_isFullMockRecord = true;
                        break;
                default:
                        p_isFullMock = false;
                        p_isFullMockRecord = false;
                        break;
        }
}

References p_backend, BaseDaemon::p_isFullMock, and BaseDaemon::p_isFullMockRecord.

Referenced by initialisationDaemonSocket().

Here is the caller graph for this function:

stop()

void BaseDaemon::stop ( )

inherited

Stops the BaseDaemon.

Definition at line 139 of file BaseDaemon.cpp.

                     {
        p_log.getLogInfo() << "Stopping Daemon '"<<p_config.getName()<<"' at '"<<p_config.getHostName()<<"'" << std::endl;
        p_isRun = false;
}

References p_config, p_isRun, and p_log.

Referenced by Daemon< _TBackend >::processInputMessage().

Here is the caller graph for this function:

updateStatAccumulator()

void BaseDaemon::updateStatAccumulator ( StatAccumulator & stat, float value )

inherited

Update a computing statistic with a new value.

Parameters

stat	: statistic to be updated
value	: new value to be added to the statistic

Definition at line 290 of file BaseDaemon.cpp.

                                                                         {
        stat.setNbEvent(stat.getNbEvent() + 1lu);
        getLog().getLogDebug() << "BaseDaemon::updateStatAccumulator : event nb is " << stat.getNbEvent() << std::endl;
        if(stat.getNbEvent() == 1lu){
                stat.setMin(value);
                stat.setMax(value);
                stat.setSum(value);
        }else{
                if(value < stat.getMin()){
                        stat.setMin(value);
                }
                if(value > stat.getMax()){
                        stat.setMax(value);
                }
                stat.setSum(stat.getSum() + value);
        }
        if(value > stat.getHistUpperBound()){
                stat.setNbEventAboveUpperBound(stat.getNbEventAboveUpperBound() + 1lu);
        }
        if(value < stat.getHistLowerBound()){
                stat.setNbEventBelowLowerBound(stat.getNbEventBelowLowerBound() + 1lu);
        }
        float binSize = (stat.getHistUpperBound() - stat.getHistLowerBound()) / stat.getVecHistogram().size();
        size_t bin = (value - stat.getHistLowerBound()) / binSize;
        if(bin < stat.getVecHistogram().size()){
                std::vector<size_t> & vecHistogram = stat.getVecHistogram();
                vecHistogram[bin] = vecHistogram[bin] + 1lu;
        }
}

References StatAccumulator::getHistLowerBound(), StatAccumulator::getHistUpperBound(), getLog(), StatAccumulator::getMax(), StatAccumulator::getMin(), StatAccumulator::getNbEvent(), StatAccumulator::getNbEventAboveUpperBound(), StatAccumulator::getNbEventBelowLowerBound(), StatAccumulator::getSum(), StatAccumulator::getVecHistogram(), StatAccumulator::setMax(), StatAccumulator::setMin(), StatAccumulator::setNbEvent(), StatAccumulator::setNbEventAboveUpperBound(), StatAccumulator::setNbEventBelowLowerBound(), and StatAccumulator::setSum().

Referenced by getCommunicationStat(), and Daemon< _TBackend >::processInputMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

p_backend

template<class _TBackend>

_TBackend Daemon< _TBackend >::p_backend

protectedinherited

Full backend of the Daemon (for Socket and clock)

Definition at line 49 of file Daemon.h.

Referenced by initialisationDaemonSocket(), processInputMessage(), run(), sendData(), sendMessage(), setClockMode(), and setSocketMode().

p_config

DaemonConfig BaseDaemon::p_config

protectedinherited

Configuration of the curent Daemon.

Definition at line 162 of file BaseDaemon.h.

Referenced by addDataCallableMethod(), addDataCallableMethod(), checkMessageTimeout(), clearStat(), fillDaemonStat(), getCommunicationStat(), getConfig(), Daemon< _TBackend >::initialisationDaemonSocket(), isDaemonExist(), loadConfigFromNode(), processConfirmedMessage(), Daemon< _TBackend >::processInputMessage(), Daemon< _TBackend >::run(), Daemon< _TBackend >::sendData(), Daemon< _TBackend >::sendStatToStatDaemon(), and stop().

p_isFullMock

bool BaseDaemon::p_isFullMock

protectedinherited

True if the daemon has to be executed in mock mode for socket and clock.

Definition at line 170 of file BaseDaemon.h.

Referenced by initialisationBaseDaemon(), Daemon< _TBackend >::initialisationDaemonSocket(), parseArgument(), Daemon< _TBackend >::setClockMode(), and Daemon< _TBackend >::setSocketMode().

p_isFullMockRecord

bool BaseDaemon::p_isFullMockRecord

protectedinherited

True if the daemon has to be executed in mock record mode for socket and clock.

Definition at line 172 of file BaseDaemon.h.

Referenced by initialisationBaseDaemon(), Daemon< _TBackend >::initialisationDaemonSocket(), parseArgument(), Daemon< _TBackend >::setClockMode(), and Daemon< _TBackend >::setSocketMode().

p_isRun

bool BaseDaemon::p_isRun

protectedinherited

True if the current BaseDaemon is running.

Definition at line 168 of file BaseDaemon.h.

Referenced by initialisationBaseDaemon(), Daemon< _TBackend >::run(), and stop().

p_log

PLog BaseDaemon::p_log

protectedinherited

Logger of the current Daemon.

Definition at line 166 of file BaseDaemon.h.

Referenced by addCallMethod(), callMethod(), Daemon< _TBackend >::checkRecvStatus(), Daemon< _TBackend >::checkSendStatus(), getLog(), getLogger(), load(), load(), loadConfigFromNode(), processData(), Daemon< _TBackend >::processInputMessage(), and stop().

p_mainConfig

DaemonMainConfig BaseDaemon::p_mainConfig

protectedinherited

Main configuration of the Daemon.

Definition at line 160 of file BaseDaemon.h.

Referenced by getMainConfig(), loadConfigFromNode(), Daemon< _TBackend >::run(), and Daemon< _TBackend >::sendMessage().

p_mapCallableMethod

std::map<PString, AbstractFunction*> BaseDaemon::p_mapCallableMethod

privateinherited

Map of callable method of the Daemon.

Definition at line 182 of file BaseDaemon.h.

Referenced by addCallableMethod(), callMethod(), and clearCallableMethod().

p_mapDaemon

MapDaemonConfig BaseDaemon::p_mapDaemon

protectedinherited

Map of the other Daemon of the Swarm.

Definition at line 164 of file BaseDaemon.h.

Referenced by getMapDaemonConfig(), Daemon< _TBackend >::initialisationDaemonSocket(), isDaemonExist(), and loadConfigFromNode().

p_mapDaemonStat

template<class _TBackend>

MapDaemonStat StatDaemonManager< _TBackend >::p_mapDaemonStat

private

Statistics about all Daemon in the swarm.

Definition at line 32 of file StatDaemonManager.h.

Referenced by fillStatInfo(), getMapDaemonStat(), getStatsCount(), and hasReceivedStats().

p_mapDataFunction

std::map<PString, AbstractDataFunction*> BaseDaemon::p_mapDataFunction

privateinherited

Map of methods which have to be called when receiving data.

Definition at line 189 of file BaseDaemon.h.

Referenced by addDataCallableMethod(), addDataCallableMethod(), and getDataFunction().

p_mapMessageToBeConfirmed

std::map<size_t, Message> BaseDaemon::p_mapMessageToBeConfirmed

privateinherited

Map of messages which have to be confirmed by destination Daemon.

Definition at line 184 of file BaseDaemon.h.

Referenced by addMessageToConfirm(), checkMessageTimeout(), getMapMessageToBeConfirmed(), getMessageToConfirm(), and processConfirmedMessage().

p_messageId

size_t BaseDaemon::p_messageId

privateinherited

Id counter of the message of the current Daemon.

Definition at line 186 of file BaseDaemon.h.

Referenced by getMessageId(), and initialisationBaseDaemon().

p_optionParser

OptionParser BaseDaemon::p_optionParser

privateinherited

Option parser of the Daemon.

Definition at line 180 of file BaseDaemon.h.

Referenced by BaseDaemon(), getOptionParser(), initialisationBaseDaemon(), and parseArgument().

p_startTimestamp

template<class _TBackend>

time_t Daemon< _TBackend >::p_startTimestamp

protectedinherited

Start timestamp of the current accumulation of statistics.

Definition at line 53 of file Daemon.h.

Referenced by run(), and sendStatToStatDaemon().

p_statTimer

template<class _TBackend>

PTimer Daemon< _TBackend >::p_statTimer

protectedinherited

Timer to send statistics to the Stat Daemon.

Definition at line 51 of file Daemon.h.

Referenced by run().

---

The documentation for this class was generated from the following files:

• /builds/CTA-LAPP/PHOENIX_LIBS2/network/PhoenixSwarm/src/Statistics/StatDaemonManager.h
• /builds/CTA-LAPP/PHOENIX_LIBS2/network/PhoenixSwarm/src/Statistics/StatDaemonManager_impl.h