Daemon.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __DAEMON_H__
#define __DAEMON_H__
 
#include "daemon_config_exception.h"
#include "DaemonEmptyBackend.h"
#include "BaseDaemon.h"
#include "PTimer.h"

template<class _TBackend>
class Swarm::Daemon : public Swarm::BaseDaemon{
        public:
                Daemon();
                virtual ~Daemon();
                
                void setSocketMode(PSocketMode::PSocketMode mode);
                void setClockMode(PClockMode::PClockMode mode);
                PRecvStatus::PRecvStatus checkRecvStatus(PRecvStatus::PRecvStatus recvStatus);
                void checkSendStatus(PSendStatus::PSendStatus sendStatus);
                bool run();
                
                bool sendMessage(const Swarm::Message & message);
                bool sendMessage(const PString & destinationName, const Swarm::Message & message);


                template<typename T>
                bool sendValue(const PString & destinationName, const T & data, bool isConfirmationNeeded = true){
                        return sendData(destinationName, phoenix_createData(data), isConfirmationNeeded);
                }
 
                bool sendData(const PString & destinationName, const Swarm::Data & data, bool isConfirmationNeeded);
                
                virtual void extraLoopProcessing();
                virtual void executeOnStop();
 
        protected:
                _TBackend p_backend;
                PTimer p_statTimer;
                time_t p_startTimestamp;
 
                void processInputMessage(Swarm::Message & message);
                
        private:
                void initialisationDaemon();
                void initialisationDaemonSocket();
                void sendStatToStatDaemon(time_t currentTime);
 
};
 
#include "Daemon_impl.h"
 
 
#endif