QDbWatchdogThread.cc

Go to the documentation of this file.

#include "QDbWatchdogThread.hh"
 
#include "QError.hh"
#include "QDb.hh"
#include "QWatchdogTimer.hh"
#include <unistd.h>
 
//_____________________________________________________________________________
QDbWatchdogThread::QDbWatchdogThread():
   QBaseThread()
{
}
 
 
void QDbWatchdogThread::operator()()
{
   if(NULL == fErr)
      throw QError(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                   "fErr is not set for this thread");
 
   if(NULL == fControlFlag)
   {
      fErr->Set(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                 "fControlFlag is not set for this thread");
      return;
   }
 
   if(NULL == fTimer)
   {
      fErr->Set(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                 "fTimer is not set for this thread");
      return;
   }
 
   if(NULL == fDb)
   {
      fErr->Set(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                 "fDb is not set for this thread");
      return;
   }
 
   
   while(0 == *fControlFlag) {
      if(*fErr != QERR_SUCCESS)
         return;
 
      bool elapsed = false;
      *fErr = fTimer->TimeoutElapsed(elapsed);
      if(*fErr != QERR_SUCCESS)
         return;
 
      if(elapsed && fDb->IsConnected())
      {
         bool success = fDb->Disconnect();
         if(!success) {
            fErr->Set(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                      "Disconnect failed()");
            return;
         }
      }
      usleep(500000);
   }
   return;
}