QBaseThreadHandler.cc

Go to the documentation of this file.

#include "QBaseThreadHandler.hh"
 
#include "QError.hh"
#include "QBaseThread.hh"
 
#include <boost/thread.hpp>
 
//_____________________________________________________________________________
QBaseThreadHandler::QBaseThreadHandler():
   fControlFlag(0),
   fErr(NULL),
   fThread(NULL)
{
   fErr = new QError(QERR_SUCCESS);
}
 
//_____________________________________________________________________________
QBaseThreadHandler::~QBaseThreadHandler()
{
   Stop();
   delete fErr;
}
 
 
//_____________________________________________________________________________
QError QBaseThreadHandler::Check(bool& isRunning)
{
   return Check(isRunning, 10);
}
 
//_____________________________________________________________________________
QError QBaseThreadHandler::Check(bool& isRunning, int timeoutMillisec)
{
   isRunning = false;
   if(NULL == fThread)
      return QERR_SUCCESS;
 
   isRunning
      = !(fThread->timed_join(boost::posix_time::millisec(timeoutMillisec)));
   if(!isRunning)
   {
      delete fThread;
      fThread = NULL;
   }
 
   return *fErr;
}
 
 
//_____________________________________________________________________________
QError QBaseThreadHandler::Stop()
{
   fControlFlag = 1;
   bool isRunning = true;
   int ctr = 100;
   while(isRunning && ctr--)
   {
      QError err = Check(isRunning);
      if(err != QERR_SUCCESS)
         return err;
   }
   if(isRunning)
      return QError(QERR_UNDEFINED_STATUS, __FILE__, __LINE__,
                    "thread failed to stop");
 
   delete fThread;
   fThread = NULL;
   return QERR_SUCCESS;
}