QDbWatchdogThreadHandler.cc

Go to the documentation of this file.

#include "QDbWatchdogThreadHandler.hh"
 
#include "QError.hh"
#include "QDbWatchdogThread.hh"
#include <boost/thread.hpp>
 
//_____________________________________________________________________________
QDbWatchdogThreadHandler::QDbWatchdogThreadHandler():
   QBaseThreadHandler(),
   fTimer(NULL),
   fDb(NULL)
{
}
 
 
//_____________________________________________________________________________
QError QDbWatchdogThreadHandler::Start()
{
   if(NULL == fTimer)
      return QError(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                    "timer is not set");
   if(NULL == fDb)
      return QError(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                    "database is not set");
 
   
   
   QDbWatchdogThread thread;
   thread.SetError(fErr);
   thread.SetControlFlag(&fControlFlag);
   thread.SetWatchdogTimer(fTimer);
   thread.SetDatabase(fDb);
 
   fThread = new boost::thread(thread);
 
   bool isRunning;
   QError err = Check(isRunning);
   if(err != QERR_SUCCESS)
      return err;
   if(!isRunning)
      return QError(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                    "Thread failed to start but did not report an error");
   return QERR_SUCCESS;
}