PhoenixSwarm  5.1.1
Library to ease communication between daemons
Loading...
Searching...
No Matches
Public Member Functions | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes | List of all members
Swarm::Monitoring< _TBackend > Class Template Reference

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

#include <Monitoring.h>

+ Inheritance diagram for Swarm::Monitoring< _TBackend >:
+ Collaboration diagram for Swarm::Monitoring< _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 Swarm::Message &message)
 Add a message to confirm.
 
bool callMethod (Swarm::Data &result, const PString &name, const Swarm::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.
 
bool extraLoad (const ConfigNode *config)
 Override for loading extra parameters for the Monitoring.
 
virtual void extraLoopProcessing ()
 Computing Method for each event loop (when receiving message from other Daemon)
 
PUncastableBool fillStatInfo (const Swarm::Stat &stat)
 Fill the StatInfo of the Monitoring with the given Stat.
 
DaemonConfig & getConfig ()
 Get the configuration of the current BaseDaemon.
 
Swarm::AbstractDataFunction * getDataFunction (const Swarm::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 Stat.
 
const std::map< size_t, Swarm::Message > & getMapMessageToBeConfirmed () const
 Get the map of message to be confirmed.
 
size_t getMessageId ()
 Get current message id.
 
bool getMessageToConfirm (Swarm::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 getStatBinDurationSecond () const
 Get the duration of a bin in seconds for the histogram of the statistics.
 
size_t getStatBufferDurationSecond () const
 Get the buffer duration in seconds for the statistics accumulation period.
 
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.
 
 Monitoring ()
 Constructor of Monitoring.
 
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 Swarm::Data &data)
 Process given data with the proper method.
 
bool processEvent ()
 Process event.
 
bool run ()
 Run the Daemon.
 
bool sendData (const PString &destinationName, const Swarm::Data &data, bool isConfirmationNeeded)
 Send data to other Daemon (specialization for Data)
 
bool sendMessage (const PString &destinationName, const Swarm::Message &message)
 Send message to other Daemon.
 
bool sendMessage (const Swarm::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.
 
void stop ()
 Stops the BaseDaemon.
 
void updateStatAccumulator (StatAccumulator &stat, float value)
 Update a computing statistic with a new value.
 
virtual ~Monitoring ()
 Destructor of Monitoring.
 

Protected Member Functions

void fillDaemonStat (Swarm::Stat &stat, time_t startTimestamp, time_t endTimestamp)
 Fill the Stat with the current statistics of the daemon.
 
VecStat fillVecStat (const Swarm::StatAccumulator &accumulator, time_t startTimestamp, time_t endTimestamp)
 Fill a VecStat from a StatAccumulator to send to the DamonStat.
 
void processInputMessage (Swarm::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 initializeMonitoring ()
 Initialize the Monitoring.
 
void sendStatToStatDaemon (time_t currentTime)
 Send the statistics of the Daemon to the Stat Daemon.
 

Private Attributes

size_t p_binDuration
 Duration of a bin in seconds for stat accumulation.
 
std::map< PString, Swarm::AbstractFunction * > p_mapCallableMethod
 Map of callable method of the Daemon.
 
MapDaemonStat p_mapDaemonStat
 Statistics about all Daemon in the swarm.
 
std::map< PString, Swarm::AbstractDataFunction * > p_mapDataFunction
 Map of methods which have to be called when receiving data.
 
std::map< size_t, Swarm::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.
 
size_t p_statBufferDuration
 Buffer duration in seconds for the statistics accumulation period.
 

Detailed Description

template<class _TBackend>
class Swarm::Monitoring< _TBackend >

Daemon which manages statistics of a full swarm.

Definition at line 19 of file Monitoring.h.

Constructor & Destructor Documentation

◆ Monitoring()

template<class _TBackend>
Monitoring::Monitoring ( )

Constructor of Monitoring.

Definition at line 16 of file Monitoring_impl.h.

17 :Daemon<_TBackend>()
18{
19 initializeMonitoring();
20}
Swarm::Daemon::Daemon
Daemon()
Default constructor of Daemon.
Definition Daemon_impl.h:17
Swarm::Monitoring::initializeMonitoring
void initializeMonitoring()
Initialize the Monitoring.
Definition Monitoring_impl.h:93

References Swarm::Daemon< _TBackend >::Daemon(), and initializeMonitoring().

+ Here is the call graph for this function:

◆ ~Monitoring()

template<class _TBackend>
Monitoring::~Monitoring ( )
virtual

Destructor of Monitoring.

Definition at line 24 of file Monitoring_impl.h.

24 {
25
26}

Member Function Documentation

◆ addCallableMethod()

template<typename _Callable>
bool Swarm::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.

73 {
74 std::map<PString, AbstractFunction*>::iterator it(p_mapCallableMethod.find(name));
75 if(it != p_mapCallableMethod.end()){
76 getLog().getLogError() << "BaseDaemon::addCallableMethod : function '"<<name<<"' already added" << std::endl;
77 return false;
78 }
79 p_mapCallableMethod[name] = new FunctionCall(function, name);
80 return true;
81 }
Swarm::BaseDaemon::p_mapCallableMethod
std::map< PString, Swarm::AbstractFunction * > p_mapCallableMethod
Map of callable method of the Daemon.
Definition BaseDaemon.h:182
Swarm::BaseDaemon::getLog
PLog & getLog()
Get the log of the current BaseDaemon.
Definition BaseDaemon.cpp:160

References getLog(), and p_mapCallableMethod.

+ Here is the call graph for this function:

◆ addCallMethod()

template<class _TBackend>
void Monitoring::addCallMethod ( )
virtual

Method from BaseDaemon to add call methods.

Reimplemented from Swarm::BaseDaemon.

Definition at line 110 of file Monitoring_impl.h.

110 {
111 DaemonConfig & daemonConfig = Daemon<_TBackend>::getConfig();
112 BaseDaemon::getLog().getLogInfo() << "Monitoring: Adding data callable method for stat sorting with nbBin=" << daemonConfig.getStatNbBin() << ", lowerBound=" << daemonConfig.getStatHistLowerBound() << ", upperBound=" << daemonConfig.getStatHistUpperBound() << std::endl;
113 Daemon<_TBackend>::addDataCallableMethod(sortFillDaemonStat<_TBackend>, *this, daemonConfig.getStatNbBin(), daemonConfig.getStatHistLowerBound(), daemonConfig.getStatHistUpperBound());
114}
Swarm::BaseDaemon::addDataCallableMethod
bool addDataCallableMethod(PUncastableBool(&function)(const _Data &), size_t nbBin, float histLowerBound, float histUpperBound)
Add a callable method of the Daemon.
Definition BaseDaemon.h:105
Swarm::BaseDaemon::getConfig
DaemonConfig & getConfig()
Get the configuration of the current BaseDaemon.
Definition BaseDaemon.cpp:371
Swarm::Monitoring
Daemon which manages statistics of a full swarm.
Definition Monitoring.h:19

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

+ Here is the call graph for this function:

◆ addDataCallableMethod() [1/2]

template<typename _Class, typename _Data>
bool Swarm::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.

128 {
129 PString prototype(phoenix_getTypeToStr<_Data>());
130 std::cout << "BaseDaemon::addDataCallableMethod : prototype = " << prototype << std::endl;
131 std::map<PString, Swarm::AbstractDataFunction*>::iterator it(p_mapDataFunction.find(prototype));
132 if(it != p_mapDataFunction.end()){
133 getLog().getLogError() << "BaseDaemon::addDataCallableMethod : function to process data '"<<prototype<<"' already added" << std::endl;
134 return false;
135 }
136 getLog().getLogDebug() << "BaseDaemon::addDataCallableMethod : add method to process data '"<<prototype<<"'" << std::endl;
137 p_mapDataFunction[prototype] = new Swarm::DataFunctionClassCall(function, persistentData, prototype);
138 p_config.getDaemonStatAccumulator().getMapStatComputing()[prototype] = createNewStat(nbBin, histLowerBound, histUpperBound);
139 return true;
140 }
Swarm::BaseDaemon::p_mapDataFunction
std::map< PString, Swarm::AbstractDataFunction * > p_mapDataFunction
Map of methods which have to be called when receiving data.
Definition BaseDaemon.h:189
Swarm::BaseDaemon::createNewStat
StatAccumulator createNewStat(size_t nbBin, float histLowerBound, float histUpperBound)
Create a new clear computing statistic.
Definition BaseDaemon.cpp:332
Swarm::BaseDaemon::p_config
DaemonConfig p_config
Configuration of the curent Daemon.
Definition BaseDaemon.h:162

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

+ Here is the call graph for this function:

◆ addDataCallableMethod() [2/2]

template<typename _Data>
bool Swarm::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.

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

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

Referenced by Swarm::Monitoring< _TBackend >::addCallMethod().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ addMessageToConfirm()

void BaseDaemon::addMessageToConfirm ( const Swarm::Message & message)
inherited

Add a message to confirm.

Parameters
message: message to be added

Definition at line 186 of file BaseDaemon.cpp.

186 {
187 p_mapMessageToBeConfirmed[message.getId()] = message;
188}
Swarm::BaseDaemon::p_mapMessageToBeConfirmed
std::map< size_t, Swarm::Message > p_mapMessageToBeConfirmed
Map of messages which have to be confirmed by destination Daemon.
Definition BaseDaemon.h:184
Swarm::Message::getId
size_t getId() const
Gets the id of the Message.
Definition Representation.cpp:435

References Swarm::Message::getId(), and p_mapMessageToBeConfirmed.

Referenced by Swarm::Daemon< _TBackend >::sendMessage(), testBaseDaemonGetMessageToConfirm(), and testBaseDaemonProcessConfirmedMessage().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ callMethod()

bool BaseDaemon::callMethod ( Swarm::Data & result,
const PString & name,
const Swarm::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 127 of file BaseDaemon.cpp.

127 {
128 std::map<PString, AbstractFunction*>::iterator it(p_mapCallableMethod.find(name));
129 if(it == p_mapCallableMethod.end()){
130 getLog().getLogError() << "BaseDaemon::callMethod : function '"<<name<<"' not found" << std::endl;
131 return false;
132 }
133 return p_mapCallableMethod[name]->call(p_log, result, parameter);
134}
Swarm::BaseDaemon::p_log
PLog p_log
Logger of the current Daemon.
Definition BaseDaemon.h:166

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 229 of file BaseDaemon.cpp.

229 {
230 std::vector<size_t> messagesToRemove;
231 for(auto it = p_mapMessageToBeConfirmed.begin(); it != p_mapMessageToBeConfirmed.end(); ++it){
232 const size_t & messageId = it->first;
233 const Message & message = it->second;
234 time_t elapsedTime = currentTime - message.getSendTime();
235 if(message.getVecRecver().size() == 0lu){
236 getLog().getLogError() << "BaseDaemon::checkMessageTimeout() : message " << messageId << " has no receiver." << std::endl;
237 continue;
238 }
239 std::map<PString, time_t>::const_iterator timeoutIt = p_config.getMapTimeout().find(message.getVecRecver().front());
240 if(timeoutIt == p_config.getMapTimeout().end()){
241 getLog().getLogError() << "BaseDaemon::checkMessageTimeout() : no timeout found for receiver '" << message.getVecRecver().front() << "' of message " << messageId << "." << std::endl;
242 continue;
243 }
244 time_t timeout = timeoutIt->second;
245 phoenix_assert(message.getVecRecver().size() != 0lu);
246 if (elapsedTime > timeout) {
247 messagesToRemove.push_back(messageId);
248 getLog().getLogWarning() << "BaseDaemon::checkMessageTimeout() : Timeout Reached for message " << messageId << " sent to '" << message.getVecRecver().front() << "'. Removing unconfirmed transaction" << std::endl;
249 }
250 }
251 for(const size_t & messageId : messagesToRemove){
252 p_mapMessageToBeConfirmed.erase(messageId);
253 }
254}
Swarm::Message::getVecRecver
const std::vector< PString > & getVecRecver() const
Gets the vecRecver of the Message.
Definition Representation.cpp:477
Swarm::Message::getSendTime
const time_t & getSendTime() const
Gets the sendTime of the Message.
Definition Representation.cpp:421

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

Referenced by Swarm::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::checkRecvStatus ( PRecvStatus::PRecvStatus recvStatus)
inherited

Check the status of recv sockets.

Parameters
recvStatus: status to be checked

Definition at line 77 of file Daemon_impl.h.

77 {
78 if(recvStatus == PRecvStatus::SOCKET_NOT_AVAILABLE){
79// p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Socket not available", "Socket not available");
80 p_log.getLogWarning() << "Daemon::checkRecvStatus : Socket not available" << std::endl;
81 }
82 if(recvStatus == PRecvStatus::SIGNAL_INTERRUPTION){
83 p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Socket Backend caught a signal, aborting", "Socket Backend caught a signal, aborting");
84 }
85 if(recvStatus == PRecvStatus::BROKEN_BACKEND){
86 p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Back-end is in invalid state", "Back-end is in invalid state");
87 }
88 if(recvStatus == PRecvStatus::BROKEN_SOCKET){
89 p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Socket is in invalid state", "Socket is in invalid state");
90 }
91 if(recvStatus == PRecvStatus::CANNOT_DESERIALIZE_DATA){
92 p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkRecvStatus : Cannot deserialize data", "Cannot deserialize data");
93 }
94 return recvStatus;
95}
Swarm::Daemon
Class which describes a Daemon with connections to other daemons.
Definition Daemon.h:17

References Swarm::BaseDaemon::p_log.

Referenced by run().

+ Here is the caller graph for this function:

◆ checkSendStatus()

template<class _TBackend>
void Daemon::checkSendStatus ( PSendStatus::PSendStatus sendStatus)
inherited

Check the status of recv sockets.

Parameters
sendStatus: status to be checked

Definition at line 102 of file Daemon_impl.h.

102 {
103 if(sendStatus == PSendStatus::SOCKET_NOT_AVAILABLE){
104 p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Socket not available", "Socket not available");
105 }
106 if(sendStatus == PSendStatus::NO_ROUTE_TO_RECEIVER){
107 p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Receiver not reachable", "Receiver not reachable");
108 }
109 if(sendStatus == PSendStatus::SIGNAL_INTERRUPTION){
110 p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Socket Backend caught a signal, aborting.", "Socket Backend caught a signal, aborting.");
111 }
112 if(sendStatus == PSendStatus::BROKEN_BACKEND){
113 p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Back-end is in invalid state", "Back-end is in invalid state");
114 }
115 if(sendStatus == PSendStatus::BROKEN_SOCKET){
116 p_log.criticalAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Socket is in invalid state", "Socket is in invalid state");
117 }
118 if(sendStatus == PSendStatus::CANNOT_SERIALIZE_DATA){
119 p_log.errorAndThrow<Phoenix::SocketStatusException>("Daemon::checkSendStatus : Cannot serialize data", "Cannot serialize data");
120 }
121}

References Swarm::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 137 of file BaseDaemon.cpp.

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

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 355 of file BaseDaemon.cpp.

355 {
356 for(MapStatAccumulator::iterator it = p_config.getDaemonStatAccumulator().getMapStatComputing().begin(); it != p_config.getDaemonStatAccumulator().getMapStatComputing().end(); ++it){
357 it->second.setNbEvent(0lu);
358 std::fill(it->second.getVecHistogram().begin(), it->second.getVecHistogram().end(), 0lu);
359 }
360 for(MapDaemonStatAccumulator::iterator itMap = p_config.getDaemonStatAccumulator().getMapStatCommunication().begin(); itMap != p_config.getDaemonStatAccumulator().getMapStatCommunication().end(); ++itMap){
361 for(MapStatAccumulator::iterator it = itMap->second.begin(); it != itMap->second.end(); ++it){
362 it->second.setNbEvent(0lu);
363 std::fill(it->second.getVecHistogram().begin(), it->second.getVecHistogram().end(), 0lu);
364 }
365 }
366}

References p_config.

Referenced by Swarm::Daemon< _TBackend >::sendStatToStatDaemon(), and testClearStatAccumulator().

+ 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 417 of file BaseDaemon.cpp.

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

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 332 of file BaseDaemon.cpp.

332 {
333 StatAccumulator newStat;
334 newStat.setNbEvent(0lu);
335 newStat.setMin(std::nan(""));
336 newStat.setMax(std::nan(""));
337 newStat.setSum(std::nan(""));
338 newStat.setNbEventAboveUpperBound(0lu);
339 newStat.setNbEventBelowLowerBound(0lu);
340 newStat.setHistUpperBound(histUpperBound);
341 newStat.setHistLowerBound(histLowerBound);
342 newStat.setVecHistogram(std::vector<size_t>(nbBin, 0lu));
343 return newStat;
344}
Swarm::StatAccumulator::setMin
void setMin(float min)
Sets the min of the StatAccumulator.
Definition Representation.cpp:1023
Swarm::StatAccumulator::setVecHistogram
void setVecHistogram(const std::vector< size_t > &vecHistogram)
Sets the vecHistogram of the StatAccumulator.
Definition Representation.cpp:1037
Swarm::StatAccumulator::setHistUpperBound
void setHistUpperBound(float histUpperBound)
Sets the histUpperBound of the StatAccumulator.
Definition Representation.cpp:1051
Swarm::StatAccumulator::setMax
void setMax(float max)
Sets the max of the StatAccumulator.
Definition Representation.cpp:1030
Swarm::StatAccumulator::setNbEventAboveUpperBound
void setNbEventAboveUpperBound(size_t nbEventAboveUpperBound)
Sets the nbEventAboveUpperBound of the StatAccumulator.
Definition Representation.cpp:1065
Swarm::StatAccumulator::setHistLowerBound
void setHistLowerBound(float histLowerBound)
Sets the histLowerBound of the StatAccumulator.
Definition Representation.cpp:1044
Swarm::StatAccumulator::setNbEventBelowLowerBound
void setNbEventBelowLowerBound(size_t nbEventBelowLowerBound)
Sets the nbEventBelowLowerBound of the StatAccumulator.
Definition Representation.cpp:1058
Swarm::StatAccumulator::setSum
void setSum(float sum)
Sets the sum of the StatAccumulator.
Definition Representation.cpp:1016
Swarm::StatAccumulator::setNbEvent
void setNbEvent(size_t nbEvent)
Sets the nbEvent of the StatAccumulator.
Definition Representation.cpp:1009

References Swarm::StatAccumulator::setHistLowerBound(), Swarm::StatAccumulator::setHistUpperBound(), Swarm::StatAccumulator::setMax(), Swarm::StatAccumulator::setMin(), Swarm::StatAccumulator::setNbEvent(), Swarm::StatAccumulator::setNbEventAboveUpperBound(), Swarm::StatAccumulator::setNbEventBelowLowerBound(), Swarm::StatAccumulator::setSum(), and Swarm::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::executeOnStop ( )
virtualinherited

Method which is called on stop of the Daemon.

Definition at line 208 of file Daemon_impl.h.

208{}

Referenced by run().

+ Here is the caller graph for this function:

◆ extraLoad()

template<class _TBackend>
bool Monitoring::extraLoad ( const ConfigNode * config)
virtual

Override for loading extra parameters for the Monitoring.

Parameters
config: ConfigNode with the extra parameters to be loaded
Returns
true on success, false otherwise

Reimplemented from Swarm::BaseDaemon.

Definition at line 83 of file Monitoring_impl.h.

83 {
84 if(config != nullptr){
85 p_statBufferDuration = phoenix_get_value<size_t>(*config, "stat_buffer_duration_second", 30lu);
86 p_binDuration = phoenix_get_value<size_t>(*config, "bin_duration_second", 5lu);
87 }
88 return true;
89}
Swarm::Monitoring::p_statBufferDuration
size_t p_statBufferDuration
Buffer duration in seconds for the statistics accumulation period.
Definition Monitoring.h:37
Swarm::Monitoring::p_binDuration
size_t p_binDuration
Duration of a bin in seconds for stat accumulation.
Definition Monitoring.h:39

References p_binDuration, and p_statBufferDuration.

◆ extraLoopProcessing()

template<class _TBackend>
void Daemon::extraLoopProcessing ( )
virtualinherited

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

Definition at line 204 of file Daemon_impl.h.

204{}

Referenced by run().

+ Here is the caller graph for this function:

◆ fillDaemonStat()

void BaseDaemon::fillDaemonStat ( Swarm::Stat & stat,
time_t startTimestamp,
time_t endTimestamp )
protectedinherited

Fill the Stat with the current statistics of the daemon.

Parameters
statStat to be filled
startTimestamptime at which the statistic started to be filled
endTimestamptime at which the statistic stopped to be filled

Definition at line 482 of file BaseDaemon.cpp.

482 {
483 // Fill the computing statistics
484 MapStatAccumulator & mapStatComputing = p_config.getDaemonStatAccumulator().getMapStatComputing();
485 for(MapStatAccumulator::iterator it = mapStatComputing.begin(); it != mapStatComputing.end(); ++it){
486 StatAccumulator & accumulator = it->second;
487 VecStat vecStat = fillVecStat(accumulator, startTimestamp, endTimestamp);
488 stat.getMapStatComputing()[it->first] = vecStat;
489 }
490
491 // Fill the communication statistics
492 MapDaemonStatAccumulator & mapStatCommunication = p_config.getDaemonStatAccumulator().getMapStatCommunication();
493 for(MapDaemonStatAccumulator::iterator itMap = mapStatCommunication.begin(); itMap != mapStatCommunication.end(); ++itMap){
494 const PString & destName = itMap->first;
495 std::map<PString, VecStat> & mapVecStat = stat.getMapStatCommunication()[destName];
496 for(MapStatAccumulator::iterator it = itMap->second.begin(); it != itMap->second.end(); ++it){
497 StatAccumulator & accumulator = it->second;
498 VecStat vecStat = fillVecStat(accumulator, startTimestamp, endTimestamp);
499 mapVecStat[it->first] = vecStat;
500 }
501 }
502}
MapStatAccumulator
std::map< PString, Swarm::StatAccumulator > MapStatAccumulator
Definition BaseDaemon.h:39
MapDaemonStatAccumulator
std::map< PString, std::map< PString, Swarm::StatAccumulator > > MapDaemonStatAccumulator
Definition BaseDaemon.h:38
Swarm::BaseDaemon::fillVecStat
VecStat fillVecStat(const Swarm::StatAccumulator &accumulator, time_t startTimestamp, time_t endTimestamp)
Fill a VecStat from a StatAccumulator to send to the DamonStat.
Definition BaseDaemon.cpp:452
Swarm::Stat::getMapStatCommunication
const std::map< DaemonName, std::map< DataType, Swarm::VecStat > > & getMapStatCommunication() const
Gets the mapStatCommunication of the Stat.
Definition Representation.cpp:925
Swarm::Stat::getMapStatComputing
const std::map< PString, Swarm::VecStat > & getMapStatComputing() const
Gets the mapStatComputing of the Stat.
Definition Representation.cpp:911

References fillVecStat(), Swarm::Stat::getMapStatCommunication(), Swarm::Stat::getMapStatComputing(), and p_config.

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

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ fillStatInfo()

template<class _TBackend>
PUncastableBool Monitoring::fillStatInfo ( const Swarm::Stat & stat)

Fill the StatInfo of the Monitoring with the given Stat.

Parameters
stat: Stat to be filled
Returns
true on success, false otherwise

Definition at line 73 of file Monitoring_impl.h.

73 {
74 p_mapDaemonStat[stat.getName()] = stat;
75 return UNCASTABLE_TRUE;
76}
Swarm::Monitoring::p_mapDaemonStat
MapDaemonStat p_mapDaemonStat
Statistics about all Daemon in the swarm.
Definition Monitoring.h:41

References Swarm::Stat::getName(), and p_mapDaemonStat.

+ Here is the call graph for this function:

◆ fillVecStat()

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

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

Parameters
accumulatorStatAccumulator to be converted
startTimestamptime at which the statistic started to be filled
endTimestamptime at which the statistic stopped to be filled
Returns
VecStat filled with the statistics from the accumulator

Definition at line 452 of file BaseDaemon.cpp.

452 {
453 VecStat vecStat;
454
455 // Compute event values
456 vecStat.getNbEvent().push_back(accumulator.getNbEvent());
457 vecStat.getMin().push_back(accumulator.getMin());
458 vecStat.getMax().push_back(accumulator.getMax());
459 vecStat.getAverage().push_back(accumulator.getSum() / accumulator.getNbEvent());
460
461 // Compute time values
462 vecStat.getStartTimestamp().push_back(startTimestamp);
463 vecStat.getEndTimestamp().push_back(endTimestamp);
464 time_t rate = endTimestamp - startTimestamp;
465 vecStat.getRate().push_back(accumulator.getNbEvent()*1e9 / rate);
466 vecStat.getRateEventAboveUpperBound().push_back(accumulator.getNbEventAboveUpperBound()*1e9 / rate);
467 vecStat.getRateEventBelowLowerBound().push_back(accumulator.getNbEventBelowLowerBound()*1e9 / rate);
468
469 vecStat.getVecRateQuantile().resize(accumulator.getVecHistogram().size());
470 for(size_t i = 0; i < accumulator.getVecHistogram().size(); ++i){
471 vecStat.getVecRateQuantile()[i].push_back(accumulator.getVecHistogram()[i]*1e9 / rate);
472 }
473 return vecStat;
474}
Swarm::StatAccumulator::getSum
float getSum() const
Gets the sum of the StatAccumulator.
Definition Representation.cpp:1086
Swarm::StatAccumulator::getNbEvent
size_t getNbEvent() const
Gets the nbEvent of the StatAccumulator.
Definition Representation.cpp:1072
Swarm::StatAccumulator::getMax
float getMax() const
Gets the max of the StatAccumulator.
Definition Representation.cpp:1114
Swarm::StatAccumulator::getNbEventAboveUpperBound
size_t getNbEventAboveUpperBound() const
Gets the nbEventAboveUpperBound of the StatAccumulator.
Definition Representation.cpp:1184
Swarm::StatAccumulator::getMin
float getMin() const
Gets the min of the StatAccumulator.
Definition Representation.cpp:1100
Swarm::StatAccumulator::getNbEventBelowLowerBound
size_t getNbEventBelowLowerBound() const
Gets the nbEventBelowLowerBound of the StatAccumulator.
Definition Representation.cpp:1170
Swarm::StatAccumulator::getVecHistogram
const std::vector< size_t > & getVecHistogram() const
Gets the vecHistogram of the StatAccumulator.
Definition Representation.cpp:1128
Swarm::VecStat::getMax
const std::vector< float > & getMax() const
Gets the max of the VecStat.
Definition Representation.cpp:722
Swarm::VecStat::getEndTimestamp
const std::vector< time_t > & getEndTimestamp() const
Gets the endTimestamp of the VecStat.
Definition Representation.cpp:694
Swarm::VecStat::getRate
const std::vector< float > & getRate() const
Gets the rate of the VecStat.
Definition Representation.cpp:750
Swarm::VecStat::getStartTimestamp
const std::vector< time_t > & getStartTimestamp() const
Gets the startTimestamp of the VecStat.
Definition Representation.cpp:680
Swarm::VecStat::getAverage
const std::vector< float > & getAverage() const
Gets the average of the VecStat.
Definition Representation.cpp:736
Swarm::VecStat::getRateEventBelowLowerBound
const std::vector< float > & getRateEventBelowLowerBound() const
Gets the rateEventBelowLowerBound of the VecStat.
Definition Representation.cpp:778
Swarm::VecStat::getRateEventAboveUpperBound
const std::vector< float > & getRateEventAboveUpperBound() const
Gets the rateEventAboveUpperBound of the VecStat.
Definition Representation.cpp:792
Swarm::VecStat::getMin
const std::vector< float > & getMin() const
Gets the min of the VecStat.
Definition Representation.cpp:708
Swarm::VecStat::getNbEvent
const std::vector< size_t > & getNbEvent() const
Gets the nbEvent of the VecStat.
Definition Representation.cpp:666
Swarm::VecStat::getVecRateQuantile
const std::vector< std::vector< float > > & getVecRateQuantile() const
Gets the vecRateQuantile of the VecStat.
Definition Representation.cpp:764

References Swarm::VecStat::getAverage(), Swarm::VecStat::getEndTimestamp(), Swarm::StatAccumulator::getMax(), Swarm::VecStat::getMax(), Swarm::StatAccumulator::getMin(), Swarm::VecStat::getMin(), Swarm::StatAccumulator::getNbEvent(), Swarm::VecStat::getNbEvent(), Swarm::StatAccumulator::getNbEventAboveUpperBound(), Swarm::StatAccumulator::getNbEventBelowLowerBound(), Swarm::VecStat::getRate(), Swarm::VecStat::getRateEventAboveUpperBound(), Swarm::VecStat::getRateEventBelowLowerBound(), Swarm::VecStat::getStartTimestamp(), Swarm::StatAccumulator::getSum(), Swarm::StatAccumulator::getVecHistogram(), and Swarm::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 431 of file BaseDaemon.cpp.

431 {
432 std::map<PString, std::map<PString, StatAccumulator> > & mapCommunication = p_config.getDaemonStatAccumulator().getMapStatCommunication();
433 MapDaemonStatAccumulator::iterator it = mapCommunication.find(destName);
434 if(it == mapCommunication.end()){
435 mapCommunication[destName] = createNewCommunicationStatMap(dataType, nbBin, histLowerBound, histUpperBound);
436 }
437 else{
438 std::map<PString, StatAccumulator>::iterator itDataType = it->second.find(dataType);
439 if(itDataType == it->second.end()){
440 it->second[dataType] = createNewStat(nbBin, histLowerBound, histUpperBound);
441 }
442 }
443 updateStatAccumulator(p_config.getDaemonStatAccumulator().getMapStatCommunication().find(destName)->second[dataType], latency);
444}
Swarm::BaseDaemon::updateStatAccumulator
void updateStatAccumulator(StatAccumulator &stat, float value)
Update a computing statistic with a new value.
Definition BaseDaemon.cpp:296
Swarm::BaseDaemon::createNewCommunicationStatMap
std::map< PString, StatAccumulator > createNewCommunicationStatMap(const PString &dataType, size_t nbBin, float histLowerBound, float histUpperBound)
Create a new map of communication statistic.
Definition BaseDaemon.cpp:417

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 371 of file BaseDaemon.cpp.

371 {
372 return p_config;
373}

References p_config.

Referenced by Swarm::Monitoring< _TBackend >::addCallMethod(), testClearStatAccumulator(), and testFillDaemonStat().

+ Here is the caller graph for this function:

◆ getDataFunction()

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

Get the data function associated with the given data.

Parameters
dataThe data for which to retrieve the associated function
Returns
A pointer to the associated data function, or nullptr if not found

Definition at line 268 of file BaseDaemon.cpp.

268 {
269 PString prototype(data.getType());
270 std::map<PString, AbstractDataFunction*>::iterator it(p_mapDataFunction.find(prototype));
271 if(it == p_mapDataFunction.end()){
272 getLog().getLogError() << "BaseDaemon::getDataFunction : function to process data '"<<prototype<<"' not found" << std::endl;
273 return nullptr;
274 }
275 return it->second;
276}
Swarm::Data::getType
const PString & getType() const
Gets the type of the Data.
Definition Representation.cpp:122

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

Referenced by processData(), and Swarm::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 160 of file BaseDaemon.cpp.

160 {
161 return p_log;
162}

References p_log.

Referenced by addCallableMethod(), Swarm::Monitoring< _TBackend >::addCallMethod(), addDataCallableMethod(), addDataCallableMethod(), callMethod(), checkMessageTimeout(), getDataFunction(), Swarm::Daemon< _TBackend >::initialisationDaemonSocket(), processConfirmedMessage(), processData(), Swarm::Daemon< _TBackend >::processInputMessage(), Swarm::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 392 of file BaseDaemon.cpp.

392 {
393 return p_log;
394}

References p_log.

◆ getMainConfig()

DaemonMainConfig & BaseDaemon::getMainConfig ( )
inherited

Get the main configuration of the swarm.

Returns
main configuration of the swarm

Definition at line 385 of file BaseDaemon.cpp.

385 {
386 return p_mainConfig;
387}
Swarm::BaseDaemon::p_mainConfig
DaemonMainConfig p_mainConfig
Main configuration of the Daemon.
Definition BaseDaemon.h:160

References p_mainConfig.

◆ getMapDaemonConfig()

MapDaemonConfig & BaseDaemon::getMapDaemonConfig ( )
inherited

Get the map of all Daemon configurations.

Returns
map of all Daemon configurations

Definition at line 378 of file BaseDaemon.cpp.

378 {
379 return p_mapDaemon;
380}
Swarm::BaseDaemon::p_mapDaemon
MapDaemonConfig p_mapDaemon
Map of the other Daemon of the Swarm.
Definition BaseDaemon.h:164

References p_mapDaemon.

◆ getMapDaemonStat()

template<class _TBackend>
const MapDaemonStat & Monitoring::getMapDaemonStat ( ) const

Get the map of Stat.

Returns
map of Stat

Definition at line 32 of file Monitoring_impl.h.

32 {
33 return p_mapDaemonStat;
34}

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 349 of file BaseDaemon.cpp.

349 {
350 return p_mapMessageToBeConfirmed;
351}

References p_mapMessageToBeConfirmed.

◆ getMessageId()

size_t BaseDaemon::getMessageId ( )
inherited

Get current message id.

Returns
current message id

Definition at line 259 of file BaseDaemon.cpp.

259 {
260 ++p_messageId;
261 return p_messageId;
262}
Swarm::BaseDaemon::p_messageId
size_t p_messageId
Id counter of the message of the current Daemon.
Definition BaseDaemon.h:186

References p_messageId.

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

+ Here is the caller graph for this function:

◆ getMessageToConfirm()

bool BaseDaemon::getMessageToConfirm ( Swarm::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 195 of file BaseDaemon.cpp.

195 {
196 std::map<size_t, Message>::const_iterator it(p_mapMessageToBeConfirmed.find(id));
197 if(it != p_mapMessageToBeConfirmed.end()){
198 message = it->second;
199 return true;
200 }
201 return false;
202}

References p_mapMessageToBeConfirmed.

Referenced by testBaseDaemonGetMessageToConfirm(), and testBaseDaemonProcessConfirmedMessage().

+ Here is the caller graph for this function:

◆ getOptionParser()

OptionParser & BaseDaemon::getOptionParser ( )
inherited

Return the OptionParser of the current BaseDaemon.

Returns
OptionParser of the current BaseDaemon

Definition at line 153 of file BaseDaemon.cpp.

153 {
154 return p_optionParser;
155}
Swarm::BaseDaemon::p_optionParser
OptionParser p_optionParser
Option parser of the Daemon.
Definition BaseDaemon.h:180

References p_optionParser.

◆ getStatBinDurationSecond()

template<class _TBackend>
size_t Monitoring::getStatBinDurationSecond ( ) const

Get the duration of a bin in seconds for the histogram of the statistics.

Returns
duration of a bin in seconds for the histogram of the statistics

Definition at line 64 of file Monitoring_impl.h.

64 {
65 return p_binDuration;
66}

References p_binDuration.

◆ getStatBufferDurationSecond()

template<class _TBackend>
size_t Monitoring::getStatBufferDurationSecond ( ) const

Get the buffer duration in seconds for the statistics accumulation period.

Returns
buffer duration in seconds for the statistics accumulation period

Definition at line 56 of file Monitoring_impl.h.

56 {
57 return p_statBufferDuration;
58}

References p_statBufferDuration.

◆ getStatsCount()

template<class _TBackend>
size_t Monitoring::getStatsCount ( ) const

Get the count of stats received.

Returns
number of stats received

Definition at line 48 of file Monitoring_impl.h.

48 {
49 return p_mapDaemonStat.size();
50}

References p_mapDaemonStat.

◆ hasReceivedStats()

template<class _TBackend>
bool Monitoring::hasReceivedStats ( ) const

Check if stats have been received.

Returns
true if the stats have been received, false otherwise

Definition at line 40 of file Monitoring_impl.h.

40 {
41 return !p_mapDaemonStat.empty();
42}

References p_mapDaemonStat.

◆ initialisationBaseDaemon()

void BaseDaemon::initialisationBaseDaemon ( )
privateinherited

Initialisation function of the class BaseDaemon.

Definition at line 397 of file BaseDaemon.cpp.

397 {
398 p_optionParser.setExampleLongOption("phoenix_daemon --daemonconfig=daemon_config.toml --daemonname=main");
399 p_optionParser.setExampleShortOption("phoenix_daemon -c daemon_config.toml -n main");
400 p_optionParser.addOption("daemonconfig", "c", OptionType::FILENAME, true, "Toml configuration file which define all Daemons of the swarm");
401 p_optionParser.addOption("daemonname", "n", OptionType::STRING, true, "Name of the current Daemon of the swarm configuration defined with --daemonconfig");
402 p_optionParser.addOption("mock", "m", OptionType::NONE, false, "Activate the Daemon in mock mode for the sockets and the clock");
403 p_optionParser.addOption("mockrecord", "r", OptionType::NONE, false, "Activate the Daemon in mock record mode for the sockets and the clock");
404 p_isRun = false;
405 p_messageId = 0lu;
406 p_isFullMock = false;
407 p_isFullMockRecord = false;
408}
Swarm::BaseDaemon::p_isRun
bool p_isRun
True if the current BaseDaemon is running.
Definition BaseDaemon.h:168
Swarm::BaseDaemon::p_isFullMock
bool p_isFullMock
True if the daemon has to be executed in mock mode for socket and clock.
Definition BaseDaemon.h:170
Swarm::BaseDaemon::p_isFullMockRecord
bool p_isFullMockRecord
True if the daemon has to be executed in mock record mode for socket and clock.
Definition BaseDaemon.h:172

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::initialisationDaemon ( )
privateinherited

Initialisation function of the class Daemon.

Definition at line 212 of file Daemon_impl.h.

212 {
213
214}

Referenced by Daemon().

+ Here is the caller graph for this function:

◆ initialisationDaemonSocket()

template<class _TBackend>
void Daemon::initialisationDaemonSocket ( )
privateinherited

Initialise the Daemon Sockets.

Definition at line 218 of file Daemon_impl.h.

218 {
219 if(p_config.getName() == ""){
220 getLog().criticalAndThrow<Phoenix::ConfigException>("Daemon::initialisationDaemonSocket", "daemon has no name");
221 }
222 if(p_isFullMockRecord){
223 setSocketMode(PSocketMode::MOCK_RECORD);
224 setClockMode(PClockMode::MOCK_RECORD);
225 }else{
226 if(p_isFullMock){
227 setSocketMode(PSocketMode::MOCK);
228 setClockMode(PClockMode::MOCK);
229 }
230 }
231 //Let's send when we are a client and recv when we are a server
232 //By doing this way, we have one server per Daemon and as many clients as other Daemon
233 getLog().getLogInfo() << "Daemon<_TBackend>::initialisationDaemonSocket() : initialise pull socket for daemon '" << p_config.getName() << "'" << std::endl;
234 phoenix_assert(p_backend.socketManager.addServerSocket("pull",
235 PSocketParam{p_config.getHostName(), p_config.getReceivingPort(), p_mainConfig.recvTimeoutMs, p_mainConfig.sendTimeoutMs}, p_backend.extraServerParam,
236 "./" + p_config.getName() + "_", p_backend.extraMockServerParam));
237
238 //Now let's initialise connexions to other
239 for(MapDaemonConfig::iterator it(p_mapDaemon.begin()); it != p_mapDaemon.end(); ++it){
240 if(it->second.getName() == p_config.getName()){continue;}
241 getLog().getLogInfo() << "Daemon<_TBackend>::initialisationDaemonSocket() : initialise send socket for neighbour Daemon '"<<it->second.getName()<<"'" << std::endl;
242 phoenix_assert(p_backend.socketManager.addClientSocket(it->second.getName(),
243 PSocketParam{it->second.getHostName(), it->second.getReceivingPort(), p_mainConfig.recvTimeoutMs, p_mainConfig.sendTimeoutMs}, p_backend.extraClientParam,
244 "./" + p_config.getName() + "_", p_backend.extraMockClientParam));
245 // p_backend.socketManager.getSocket(it->second.getName())->waitUntilConnection(500000lu, 30lu); //0.5 s per check and 30 checks
246 }
247 getLog().getLogInfo() << "Daemon<_TBackend>::initialisationDaemonSocket() : all connection to neighbours Daemon initialised" << std::endl;
248 p_backend.clock.setMockPrefix("./" + p_config.getName() + "_");
249}
Swarm::Daemon::setClockMode
void setClockMode(PClockMode::PClockMode mode)
Set the mode of the clock.
Definition Daemon_impl.h:55
Swarm::Daemon::setSocketMode
void setSocketMode(PSocketMode::PSocketMode mode)
Set the mode of the sockets of the SocketManager.
Definition Daemon_impl.h:33
Swarm::Daemon::p_backend
_TBackend p_backend
Full backend of the Daemon (for Socket and clock)
Definition Daemon.h:49

References Swarm::BaseDaemon::getLog(), p_backend, Swarm::BaseDaemon::p_config, Swarm::BaseDaemon::p_isFullMock, Swarm::BaseDaemon::p_isFullMockRecord, Swarm::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:

◆ initializeMonitoring()

template<class _TBackend>
void Monitoring::initializeMonitoring ( )
private

Initialize the Monitoring.

Default values for the extra parameters of the Monitoring

Definition at line 93 of file Monitoring_impl.h.

93 {
95 p_statBufferDuration = 0lu;
96 p_binDuration = 0lu;
97}

References p_binDuration, and p_statBufferDuration.

Referenced by Monitoring().

+ 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 168 of file BaseDaemon.cpp.

168 {
169 MapDaemonConfig::const_iterator it(p_mapDaemon.find(name));
170 if(it == p_mapDaemon.end()){
171 //Then if the stat daemon does not exist in the map, it may be the current daemon
172 if(p_config.getName() == name){
173 return true;
174 }
175 }
176 if(it != p_mapDaemon.end()){
177 return true;
178 }
179
180 return false;
181}

References p_config, and p_mapDaemon.

Referenced by loadConfigFromNode(), testBaseDaemonLoadConfigJson(), testBaseDaemonLoadConfigJsonString(), testBaseDaemonLoadConfigToml(), testBaseDaemonLoadConfigTomlString(), testBaseDaemonLoadConfigYml(), testBaseDaemonLoadConfigYmlString(), and testBaseDaemonParseArgument().

+ 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 97 of file BaseDaemon.cpp.

97 {
98 ConfigNode dico;
99 daemon_load_config(p_log, dico, fileName);
100 loadConfigFromNode(dico, daemonName);
101 return true;
102}
Swarm::BaseDaemon::loadConfigFromNode
void loadConfigFromNode(const ConfigNode &dico, const PString &daemonName)
Load configuration form a node of ConfigNode.
Definition BaseDaemon.cpp:47
daemon_load_config
void daemon_load_config(PLog &log, ConfigNode &dico, const PString &inputConfig, ConfigFormat::ConfigFormat format)
Load the daemon config into a ConfigNode from a json string.
Definition daemon_load_config.cpp:21

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 85 of file BaseDaemon.cpp.

85 {
86 ConfigNode dico;
87 daemon_load_config(p_log, dico, configFileContent, format);
88 loadConfigFromNode(dico, daemonName);
89 return true;
90}

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

Referenced by parseArgument(), testBaseDaemonLoadConfigJson(), testBaseDaemonLoadConfigJsonString(), testBaseDaemonLoadConfigToml(), testBaseDaemonLoadConfigTomlString(), testBaseDaemonLoadConfigYml(), testBaseDaemonLoadConfigYmlString(), testBaseDaemonMissingDaemonSectionJsonFile(), testBaseDaemonMissingDaemonSectionJsonString(), testBaseDaemonMissingDaemonSectionTomlFile(), testBaseDaemonMissingDaemonSectionTomlString(), testBaseDaemonMissingDaemonSectionYmlFile(), testBaseDaemonMissingDaemonSectionYmlString(), and testBaseDaemonProcessConfirmedMessage().

+ 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 47 of file BaseDaemon.cpp.

47 {
48 const ConfigNode * mapMainConfig = dico.getChild("swarm");
49 if(mapMainConfig != nullptr){
50 p_mainConfig.recvTimeoutMs = phoenix_get_value<int>(*mapMainConfig, "recv_timeout_ms", -1);
51 p_mainConfig.sendTimeoutMs = phoenix_get_value<int>(*mapMainConfig, "send_timeout_ms", -1);
52 p_mainConfig.recvFlag = fromString<PRecvFlag::PRecvFlag>(phoenix_get_string(*mapMainConfig, "recv_flag", "NON_BLOCK"));
53 p_mainConfig.sendFlag = fromString<PSendFlag::PSendFlag>(phoenix_get_string(*mapMainConfig, "send_flag", "NON_BLOCK"));
54 }
55 std::map<PString, time_t> mapTimeout;
56 const ConfigNode * extraConfigParam = nullptr;
57 daemon_read_configNode(p_config, p_mapDaemon, p_log, mapTimeout, extraConfigParam, dico, daemonName);
58
59 const ConfigNode * mapStatDaemon = dico.getChild("statistics");
60 if(mapStatDaemon != nullptr){
61 p_config.setStatDaemonName(daemon_loadString(*mapStatDaemon, "stat_daemon_name"));
62 extraLoad(mapStatDaemon);
63 }
64 p_config.setMapTimeout(mapTimeout);
65 if(p_config.getStatDaemonName() != ""){
66 if(!isDaemonExist(p_config.getStatDaemonName())){
67 p_log.getLogError() << "BaseDaemon::loadConfigFromNode : stat daemon '"<<p_config.getStatDaemonName()<<"' not found in configuration" << std::endl;
68 }
69 }
70
71 p_log.getLogInfo() << "BaseDaemon::loadConfigFromNode : loading configuration successful" << std::endl;
72 p_log.getLogInfo() << "BaseDaemon::loadConfigFromNode : ready to call addCallMethod to subscribe on received data" << std::endl;
73 addCallMethod();
74 if(extraConfigParam != nullptr){
75 extraLoad(extraConfigParam);
76 }
77}
Swarm::BaseDaemon::isDaemonExist
bool isDaemonExist(const PString &name) const
Say if a neighbour Daemon does exist.
Definition BaseDaemon.cpp:168
Swarm::BaseDaemon::addCallMethod
virtual void addCallMethod()
Do the addCallableMethod here.
Definition BaseDaemon.cpp:113
Swarm::BaseDaemon::extraLoad
virtual bool extraLoad(const ConfigNode *config)
Extra call on load for the current Daemon.
Definition BaseDaemon.cpp:108
daemon_loadString
PString daemon_loadString(const ConfigNode &dico, const PString &attributeName)
Load a string value.
Definition daemon_load_config.cpp:69
daemon_read_configNode
void daemon_read_configNode(Swarm::DaemonConfig &daemonConfig, MapDaemonConfig &mapDaemon, PLog &log, MapTimeout &mapTimeout, const ConfigNode *&extraConfigParam, const ConfigNode &dico, const PString &daemonName)
Read the ConfigNode to initialise current Daemon.
Definition daemon_load_config.cpp:114

References addCallMethod(), daemon_loadString(), daemon_read_configNode(), extraLoad(), 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 30 of file BaseDaemon.cpp.

30 {
31 p_optionParser.parseArgument(argc, argv);
32 const OptionMode & defaultMode = p_optionParser.getDefaultMode();
33 PPath configurationFile;
34 defaultMode.getValue(configurationFile, "daemonconfig");
35 PString daemonName;
36 defaultMode.getValue(daemonName, "daemonname");
37 p_isFullMock = defaultMode.isOptionExist("mock");
38 p_isFullMockRecord = defaultMode.isOptionExist("mockrecord");
39 return load(configurationFile, daemonName);
40}
Swarm::BaseDaemon::load
bool load(const PString &configFileContent, const PString &daemonName, ConfigFormat::ConfigFormat format)
Load the Json configuration which define all BaseDaemons of the Swarm.
Definition BaseDaemon.cpp:85

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

Referenced by testBaseDaemonParseArgument().

+ Here is the call graph for this function:
+ Here is the caller 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 208 of file BaseDaemon.cpp.

208 {
209 std::map<size_t, Message>::const_iterator it(p_mapMessageToBeConfirmed.find(id));
210 if(it != p_mapMessageToBeConfirmed.end()){
211 getLog().getLogInfo() << "BaseDaemon::processConfirmedMessage : adding statistics for processed transaction " << id << std::endl;
212 const Message & message = it->second;
213 time_t ellapsedTime = currentTime - message.getSendTime();
214 for(const PString & receiver : message.getVecRecver()){
215 getLog().getLogDebug() << "BaseDaemon::processConfirmedMessage : add statistic for receiver : " << receiver << std::endl;
216 getCommunicationStat(receiver, message.getData().getType(), ellapsedTime, p_config.getStatNbBin(), p_config.getStatHistLowerBound(), p_config.getStatHistUpperBound());
217 }
218 // Remove the confirmed message
219 getLog().getLogInfo() << "BaseDaemon::removeConfirmedMessage : remove confirmed transaction " << id << std::endl;
220 p_mapMessageToBeConfirmed.erase(it);
221 }else{
222 getLog().getLogError() << "BaseDaemon::processConfirmedMessage : transaction " << id << " not found in p_mapMessageToBeConfirmed" << std::endl;
223 }
224}
Swarm::BaseDaemon::getCommunicationStat
void getCommunicationStat(const PString &destName, const PString &dataType, float latency, size_t nbBin, float histLowerBound, float histUpperBound)
Add a communication statistic.
Definition BaseDaemon.cpp:431
Swarm::Message::getData
const Swarm::Data & getData() const
Gets the data of the Message.
Definition Representation.cpp:505

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

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

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ processData()

bool BaseDaemon::processData ( const Swarm::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 282 of file BaseDaemon.cpp.

282 {
283 AbstractDataFunction* function = getDataFunction(data);
284 if(function == nullptr){
285 return false;
286 }
287 getLog().getLogDebug() << "BaseDaemon::processData : process data '"<<data.getType()<<"'" << std::endl;
288 bool b = function->call(p_log, data);
289 return b;
290}
Swarm::AbstractDataFunction::call
virtual bool call(PLog &log, const Swarm::Data &data)=0
Swarm::BaseDaemon::getDataFunction
Swarm::AbstractDataFunction * getDataFunction(const Swarm::Data &data)
Get the data function associated with the given data.
Definition BaseDaemon.cpp:268

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

+ Here is the call graph for this function:

◆ processEvent()

template<class _TBackend>
bool Monitoring::processEvent ( )

Process event.

Returns
true

Definition at line 103 of file Monitoring_impl.h.

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

◆ processInputMessage()

template<class _TBackend>
void Daemon::processInputMessage ( Swarm::Message & message)
protectedinherited

Process an input message.

Parameters
[out]message: received Message to be processed

Definition at line 255 of file Daemon_impl.h.

255 {
256 //Check is the message needs a confirmation
257 if(message.getIsConfirmationNeeded()){
258 Message confirmation;
259 //We do not need to change the time of the message because it has to be in the clock reference of the sender
260 confirmation.setSendTime(message.getSendTime());
261 confirmation.setId(message.getId());
262 confirmation.setSender(p_config.getName());
263 confirmation.setType(MessageType::MESSAGE_CONFIRMATION);
264 confirmation.getVecRecver().push_back(message.getSender());
265 sendMessage(confirmation);
266 }
267
268 //Let's check is we receive a stop message
269 if(message.getType() == MessageType::STOP){stop();}
270 else if(message.getType() == MessageType::MESSAGE_CONFIRMATION){
271 processConfirmedMessage(message.getId(), p_backend.clock.now());
272 }else if(message.getType() == MessageType::RESULT_DATA){
273 AbstractDataFunction* function = getDataFunction(message.getData());
274 if(function == NULL){
275 return;
276 }
277 time_t functionStartTime = p_backend.clock.now();
278 if(!function->call(p_log, message.getData())){
279 getLog().getLogError() << "Daemon<_TBackend>::processInputMessage : cannot process data of type '"<<message.getData().getType()<<"' from Daemon '"<<message.getSender()<<"'" << std::endl;
280 return;
281 }
282 time_t functionEllapsedTime = p_backend.clock.now() - functionStartTime;
283 getLog().getLogDebug() << "Daemon<_TBackend>::processInputMessage : function '"<<message.getData().getType()<<"' processed data from daemon '"<<message.getSender()<<"' in "<<functionEllapsedTime<<" nanoseconds" << std::endl;
284 if(p_config.getStatDaemonName() != "" && p_config.getStatDaemonName() != p_config.getName()){
285 updateStatAccumulator(p_config.getDaemonStatAccumulator().getMapStatComputing().find(message.getData().getType())->second, functionEllapsedTime);
286 }
287 }
288}
Swarm::BaseDaemon::stop
void stop()
Stops the BaseDaemon.
Definition BaseDaemon.cpp:145
Swarm::BaseDaemon::processConfirmedMessage
void processConfirmedMessage(size_t id, time_t currentTime)
Process confirmed message.
Definition BaseDaemon.cpp:208
Swarm::Daemon::sendMessage
bool sendMessage(const Swarm::Message &message)
Send message to other Daemon.
Definition Daemon_impl.h:160

References Swarm::AbstractDataFunction::call(), Swarm::Message::getData(), Swarm::BaseDaemon::getDataFunction(), Swarm::Message::getId(), Swarm::Message::getIsConfirmationNeeded(), Swarm::BaseDaemon::getLog(), Swarm::Message::getSender(), Swarm::Message::getSendTime(), Swarm::Data::getType(), Swarm::Message::getType(), Swarm::Message::getVecRecver(), MessageType::MESSAGE_CONFIRMATION, p_backend, Swarm::BaseDaemon::p_config, Swarm::BaseDaemon::p_log, Swarm::BaseDaemon::processConfirmedMessage(), MessageType::RESULT_DATA, sendMessage(), Swarm::Message::setId(), Swarm::Message::setSender(), Swarm::Message::setSendTime(), Swarm::Message::setType(), MessageType::STOP, Swarm::BaseDaemon::stop(), and Swarm::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::run ( )
inherited

Run the Daemon.

Returns
true if the run was a success, false otherwise

Definition at line 127 of file Daemon_impl.h.

127 {
128 p_isRun = true;
129 //Let's initialise all connexions
130 initialisationDaemonSocket();
131 p_startTimestamp = p_backend.clock.now();
132 p_statTimer.setEllapsedTime(p_config.getStatTimerPeriodMs());
133 p_statTimer.setStartTime(p_startTimestamp);
134 while(p_isRun){
135 //Let's get the last received message
136 //If there is not message, we treat the rest of the loop
137 Message message;
138 PRecvStatus::PRecvStatus recvStatus = checkRecvStatus(p_backend.socketManager.recvData("pull", message, p_mainConfig.recvFlag));
139 if(recvStatus == PRecvStatus::OK){
140 processInputMessage(message);
141 }
142 extraLoopProcessing();
143
144 time_t currentTime = p_backend.clock.now();
145 checkMessageTimeout(currentTime);
146 if(p_statTimer.isTime(currentTime) || !p_isRun){
147 sendStatToStatDaemon(currentTime);
148 }
149 }
150 //Let's execute a last command before stop
151 executeOnStop();
152 return true;
153}
Swarm::BaseDaemon::checkMessageTimeout
void checkMessageTimeout(time_t currentTime)
Check if a message has reached the timeout.
Definition BaseDaemon.cpp:229
Swarm::Daemon::extraLoopProcessing
virtual void extraLoopProcessing()
Computing Method for each event loop (when receiving message from other Daemon)
Definition Daemon_impl.h:204
Swarm::Daemon::initialisationDaemonSocket
void initialisationDaemonSocket()
Initialise the Daemon Sockets.
Definition Daemon_impl.h:218
Swarm::Daemon::executeOnStop
virtual void executeOnStop()
Method which is called on stop of the Daemon.
Definition Daemon_impl.h:208
Swarm::Daemon::p_statTimer
PTimer p_statTimer
Timer to send statistics to the Stat Daemon.
Definition Daemon.h:51
Swarm::Daemon::processInputMessage
void processInputMessage(Swarm::Message &message)
Process an input message.
Definition Daemon_impl.h:255
Swarm::Daemon::checkRecvStatus
PRecvStatus::PRecvStatus checkRecvStatus(PRecvStatus::PRecvStatus recvStatus)
Check the status of recv sockets.
Definition Daemon_impl.h:77
Swarm::Daemon::p_startTimestamp
time_t p_startTimestamp
Start timestamp of the current accumulation of statistics.
Definition Daemon.h:53
Swarm::Daemon::sendStatToStatDaemon
void sendStatToStatDaemon(time_t currentTime)
Send the statistics of the Daemon to the Stat Daemon.
Definition Daemon_impl.h:294

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

+ Here is the call graph for this function:

◆ sendData()

template<class _TBackend>
bool Daemon::sendData ( const PString & destinationName,
const Swarm::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 190 of file Daemon_impl.h.

190 {
191 Message message;
192 message.setSendTime(p_backend.clock.now());
193 message.setData(data);
194 message.setId(getMessageId());
195 message.setIsConfirmationNeeded(isConfirmationNeeded);
196 message.setType(MessageType::RESULT_DATA);
197 message.setSender(p_config.getName());
198 message.getVecRecver().push_back(destinationName);
199 return sendMessage(destinationName, message);
200}
Swarm::BaseDaemon::getMessageId
size_t getMessageId()
Get current message id.
Definition BaseDaemon.cpp:259

References Swarm::BaseDaemon::getMessageId(), Swarm::Message::getVecRecver(), p_backend, Swarm::BaseDaemon::p_config, MessageType::RESULT_DATA, sendMessage(), Swarm::Message::setData(), Swarm::Message::setId(), Swarm::Message::setIsConfirmationNeeded(), Swarm::Message::setSender(), Swarm::Message::setSendTime(), and Swarm::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::sendMessage ( const PString & destinationName,
const Swarm::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 175 of file Daemon_impl.h.

175 {
176 if(message.getIsConfirmationNeeded()){
177 addMessageToConfirm(message);
178 }
179 checkSendStatus(p_backend.socketManager.sendData(destinationName, message, p_mainConfig.sendFlag));
180 return true;
181}
Swarm::BaseDaemon::addMessageToConfirm
void addMessageToConfirm(const Swarm::Message &message)
Add a message to confirm.
Definition BaseDaemon.cpp:186
Swarm::Daemon::checkSendStatus
void checkSendStatus(PSendStatus::PSendStatus sendStatus)
Check the status of recv sockets.
Definition Daemon_impl.h:102

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

+ Here is the call graph for this function:

◆ sendMessage() [2/2]

template<class _TBackend>
bool Daemon::sendMessage ( const Swarm::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 160 of file Daemon_impl.h.

160 {
161 bool b(true);
162 const PVecString & vecDestination = message.getVecRecver();
163 for(PVecString::const_iterator it(vecDestination.begin()); it != vecDestination.end(); ++it){
164 b &= sendMessage(*it, message);
165 }
166 return b;
167}

References Swarm::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:

◆ sendStatToStatDaemon()

template<class _TBackend>
void Daemon::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 294 of file Daemon_impl.h.

294 {
295 //Let's fill the Stat
296 Stat stat;
297 fillDaemonStat(stat, p_startTimestamp, currentTime);
298 stat.setName(p_config.getName());
299
300 //Let's send it to the Stat Daemon
301 if(p_config.getStatDaemonName() != "" && p_config.getStatDaemonName() != p_config.getName()){
302 getLog().getLogDebug() << "Daemon::sendStatToStatDaemon() : sending statistics to Stat Daemon '"<<p_config.getStatDaemonName()<<"'" << std::endl;
303 sendValue(p_config.getStatDaemonName(), stat, true);
304 }
305
306 clearStat();
307 p_startTimestamp = currentTime;
308}
Swarm::BaseDaemon::fillDaemonStat
void fillDaemonStat(Swarm::Stat &stat, time_t startTimestamp, time_t endTimestamp)
Fill the Stat with the current statistics of the daemon.
Definition BaseDaemon.cpp:482
Swarm::BaseDaemon::clearStat
void clearStat()
Clear all the statistics of the daemon.
Definition BaseDaemon.cpp:355
Swarm::Daemon::sendValue
bool sendValue(const PString &destinationName, const T &data, bool isConfirmationNeeded=true)
Send data to other Daemon.
Definition Daemon.h:38

References Swarm::BaseDaemon::clearStat(), Swarm::BaseDaemon::fillDaemonStat(), Swarm::BaseDaemon::getLog(), Swarm::BaseDaemon::p_config, p_startTimestamp, sendValue(), and Swarm::Stat::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 Swarm::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.

38 {
39 return sendData(destinationName, phoenix_createData(data), isConfirmationNeeded);
40 }
Swarm::Daemon::sendData
bool sendData(const PString &destinationName, const Swarm::Data &data, bool isConfirmationNeeded)
Send data to other Daemon (specialization for Data)
Definition Daemon_impl.h:190
phoenix_createData
Swarm::Data phoenix_createData(const T &value)
Create a Data from a value.
Definition phoenix_createData_impl.h:20

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::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 55 of file Daemon_impl.h.

55 {
56 p_backend.clock.setMode(mode);
57 switch(mode){
58 case PClockMode::MOCK:
59 p_isFullMock = true;
60 p_isFullMockRecord = false;
61 break;
62 case PClockMode::MOCK_RECORD:
63 p_isFullMock = false;
64 p_isFullMockRecord = true;
65 break;
66 default:
67 p_isFullMock = false;
68 p_isFullMockRecord = false;
69 break;
70 }
71}

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

Referenced by initialisationDaemonSocket().

+ Here is the caller graph for this function:

◆ setSocketMode()

template<class _TBackend>
void Daemon::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 33 of file Daemon_impl.h.

33 {
34 p_backend.socketManager.setMode(mode);
35 switch(mode){
36 case PSocketMode::MOCK:
37 p_isFullMock = true;
38 p_isFullMockRecord = false;
39 break;
40 case PSocketMode::MOCK_RECORD:
41 p_isFullMock = false;
42 p_isFullMockRecord = true;
43 break;
44 default:
45 p_isFullMock = false;
46 p_isFullMockRecord = false;
47 break;
48 }
49}

References p_backend, Swarm::BaseDaemon::p_isFullMock, and Swarm::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 145 of file BaseDaemon.cpp.

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

References p_config, p_isRun, and p_log.

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

+ 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 296 of file BaseDaemon.cpp.

296 {
297 stat.setNbEvent(stat.getNbEvent() + 1lu);
298 getLog().getLogDebug() << "BaseDaemon::updateStatAccumulator : event nb is " << stat.getNbEvent() << std::endl;
299 if(stat.getNbEvent() == 1lu){
300 stat.setMin(value);
301 stat.setMax(value);
302 stat.setSum(value);
303 }else{
304 if(value < stat.getMin()){
305 stat.setMin(value);
306 }
307 if(value > stat.getMax()){
308 stat.setMax(value);
309 }
310 stat.setSum(stat.getSum() + value);
311 }
312 if(value > stat.getHistUpperBound()){
313 stat.setNbEventAboveUpperBound(stat.getNbEventAboveUpperBound() + 1lu);
314 }
315 if(value < stat.getHistLowerBound()){
316 stat.setNbEventBelowLowerBound(stat.getNbEventBelowLowerBound() + 1lu);
317 }
318 float binSize = (stat.getHistUpperBound() - stat.getHistLowerBound()) / stat.getVecHistogram().size();
319 size_t bin = (value - stat.getHistLowerBound()) / binSize;
320 if(bin < stat.getVecHistogram().size()){
321 std::vector<size_t> & vecHistogram = stat.getVecHistogram();
322 vecHistogram[bin] = vecHistogram[bin] + 1lu;
323 }
324}
Swarm::StatAccumulator::getHistUpperBound
float getHistUpperBound() const
Gets the histUpperBound of the StatAccumulator.
Definition Representation.cpp:1156
Swarm::StatAccumulator::getHistLowerBound
float getHistLowerBound() const
Gets the histLowerBound of the StatAccumulator.
Definition Representation.cpp:1142

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

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

+ 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 Swarm::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_binDuration

template<class _TBackend>
size_t Swarm::Monitoring< _TBackend >::p_binDuration
private

Duration of a bin in seconds for stat accumulation.

Definition at line 39 of file Monitoring.h.

Referenced by extraLoad(), getStatBinDurationSecond(), and initializeMonitoring().

◆ p_config

DaemonConfig Swarm::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(), Swarm::Daemon< _TBackend >::initialisationDaemonSocket(), isDaemonExist(), loadConfigFromNode(), processConfirmedMessage(), Swarm::Daemon< _TBackend >::processInputMessage(), Swarm::Daemon< _TBackend >::run(), Swarm::Daemon< _TBackend >::sendData(), Swarm::Daemon< _TBackend >::sendStatToStatDaemon(), and stop().

◆ p_isFullMock

bool Swarm::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(), Swarm::Daemon< _TBackend >::initialisationDaemonSocket(), parseArgument(), Swarm::Daemon< _TBackend >::setClockMode(), and Swarm::Daemon< _TBackend >::setSocketMode().

◆ p_isFullMockRecord

bool Swarm::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(), Swarm::Daemon< _TBackend >::initialisationDaemonSocket(), parseArgument(), Swarm::Daemon< _TBackend >::setClockMode(), and Swarm::Daemon< _TBackend >::setSocketMode().

◆ p_isRun

bool Swarm::BaseDaemon::p_isRun
protectedinherited

True if the current BaseDaemon is running.

Definition at line 168 of file BaseDaemon.h.

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

◆ p_log

PLog Swarm::BaseDaemon::p_log
protectedinherited

Logger of the current Daemon.

Definition at line 166 of file BaseDaemon.h.

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

◆ p_mainConfig

DaemonMainConfig Swarm::BaseDaemon::p_mainConfig
protectedinherited

Main configuration of the Daemon.

Definition at line 160 of file BaseDaemon.h.

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

◆ p_mapCallableMethod

std::map<PString, Swarm::AbstractFunction*> Swarm::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 Swarm::BaseDaemon::p_mapDaemon
protectedinherited

Map of the other Daemon of the Swarm.

Definition at line 164 of file BaseDaemon.h.

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

◆ p_mapDaemonStat

template<class _TBackend>
MapDaemonStat Swarm::Monitoring< _TBackend >::p_mapDaemonStat
private

Statistics about all Daemon in the swarm.

Definition at line 41 of file Monitoring.h.

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

◆ p_mapDataFunction

std::map<PString, Swarm::AbstractDataFunction*> Swarm::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, Swarm::Message> Swarm::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 Swarm::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 Swarm::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 Swarm::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_statBufferDuration

template<class _TBackend>
size_t Swarm::Monitoring< _TBackend >::p_statBufferDuration
private

Buffer duration in seconds for the statistics accumulation period.

Definition at line 37 of file Monitoring.h.

Referenced by extraLoad(), getStatBufferDurationSecond(), and initializeMonitoring().

◆ p_statTimer

template<class _TBackend>
PTimer Swarm::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: