MtcpCheckpointManager.h

Go to the documentation of this file.

#pragma once

#include "../external/Signals/Signal.h"
#include "timer.h"
// #include "dmtcpaware.h"

class MtcpCheckpointManager
{
        public:
                
                inline void checkpointingTimeFrame();

                inline void connectTimer(Timer & tim);
                
                inline void disconnectTimer(Timer & tim);


        protected:
                Gallant::Signal0<void> pauseTimerSig;
                Gallant::Signal0<void> continueTimerSig;
                inline void pauseTimers()       ;

                inline void continueTimers()    ;

                inline void mtcp_managed_ok();
        
                inline void mtcp_managed_no();
        
};


inline void     MtcpCheckpointManager::checkpointingTimeFrame()
{
                mtcp_managed_ok();
                mtcp_managed_no();
}

inline void     MtcpCheckpointManager::connectTimer(Timer & tim)
{
        pauseTimerSig.Connect(&tim, & Timer::pauseTimer );
        continueTimerSig.Connect(&tim, & Timer::continueTimer );
        
}

inline void     MtcpCheckpointManager::disconnectTimer(Timer & tim)
{
        pauseTimerSig.Disconnect(&tim, & Timer::pauseTimer );
        continueTimerSig.Disconnect(&tim, & Timer::continueTimer );
}


inline void     MtcpCheckpointManager::pauseTimers()    
{
        pauseTimerSig();
};

inline void     MtcpCheckpointManager::continueTimers() 
{
        continueTimerSig();
};

inline void     MtcpCheckpointManager::mtcp_managed_ok()
{
        pauseTimers();
        //dmtcpDelayCheckpointsUnlock( )
        #ifdef MTCP
                mtcp_ok();
        #endif
}


inline void     MtcpCheckpointManager::mtcp_managed_no()
{
        #ifdef MTCP
                mtcp_no(); 
        #endif
        //dmtcpDelayCheckpointsLock ( )
        continueTimers();
}