QWatchdogTimer.cc

Go to the documentation of this file.

#include "QWatchdogTimer.hh"
 
#include "QError.hh"
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/thread/locks.hpp>
 
//_____________________________________________________________________________
QWatchdogTimer::QWatchdogTimer():
//   kMutexTimeoutMillisec(500),
   fMutex(NULL),
   fTimeout(NULL),
   fLastStartTime(NULL)
{
   fMutex = new boost::mutex();
}
 
 
//_____________________________________________________________________________
QWatchdogTimer::~QWatchdogTimer()
{
   delete fMutex;
   if(fTimeout != NULL)
      delete fTimeout;
   if(fLastStartTime != NULL)
      delete fLastStartTime;
}
 
 
//_____________________________________________________________________________
QError QWatchdogTimer::SetTimeoutSec(double timeout)
{
   boost::lock_guard<boost::mutex> lock(*fMutex);   
   if(NULL == fTimeout)
      fTimeout = new boost::posix_time::time_duration();
   *fTimeout = boost::posix_time::millisec((int)(1000*timeout));
 
   return QERR_SUCCESS;
}
 
 
//_____________________________________________________________________________
QError QWatchdogTimer::TimeoutElapsed(bool& elapsed) const
{
   boost::lock_guard<boost::mutex> lock(*fMutex);
 
   elapsed = false;
   if(NULL == fTimeout) // timeout was never set
      return QERR_SUCCESS; 
   if(NULL == fLastStartTime) // timer is stopped (was never started)
      return QERR_SUCCESS;
   if(fLastStartTime->is_not_a_date_time()) // timer is stopped
      return QERR_SUCCESS; 
 
   boost::posix_time::ptime tNow
      = boost::posix_time::microsec_clock::local_time();
   if(tNow - (*fLastStartTime) > (*fTimeout) )
      elapsed = true;
 
   return QERR_SUCCESS;
}
 
 
//_____________________________________________________________________________
QError QWatchdogTimer::Start()
{
   boost::lock_guard<boost::mutex> lock(*fMutex);
   if(NULL == fLastStartTime)
      fLastStartTime = new boost::posix_time::ptime();
   
   *fLastStartTime = boost::posix_time::microsec_clock::local_time();
   
   return QERR_SUCCESS;
}
 
 
//_____________________________________________________________________________
QError QWatchdogTimer::Stop()
{
   boost::lock_guard<boost::mutex> lock(*fMutex);
   if(fLastStartTime != NULL)
      *fLastStartTime = boost::posix_time::not_a_date_time;
   
   return QERR_SUCCESS;
}