DbuSignalHandler.cxx

Go to the documentation of this file.

// $Id: DbuSignalHandler.cxx,v 1.4 2004/02/12 18:04:55 rhatcher Exp $
#include "DatabaseUpdater/DbuSignalHandler.h"

// MINOS include files
#include "MessageService/MsgService.h"

#include <syslog.h>
#include <signal.h>
#include "OnlineUtil/msgLogLib/msgLog.h"

CVSID("$Id: DbuSignalHandler.cxx,v 1.4 2004/02/12 18:04:55 rhatcher Exp $");

//......................................................................

DbuSignalHandler* DbuSignalHandler::fgInstance = 0;

//----------------------------------------------------------------------

class DbuSIGINTHandler : public TSignalHandler {
public:
   DbuSIGINTHandler() : TSignalHandler(kSigInterrupt, kFALSE) { }
   Bool_t  Notify();
};

Bool_t DbuSIGINTHandler::Notify()
{
  //syslog(LOG_INFO,"<I> DbuSIGINTHandler::Notify()");
  logDebug(5,"DbuSIGINTHandler::Notify()");
  if (fDelay) { 
    //syslog(LOG_INFO,"<I> DbuSIGINTHandler::Notify() delayed");
    logDebug(4,"DbuSIGINTHandler::Notify() delayed");
    fDelay++; 
    return kFALSE; 
  }

  DbuSignalHandler::Instance().SignalAction(fSignal);
  return kTRUE;
}

class DbuSIGTERMHandler : public TSignalHandler {
public:
   DbuSIGTERMHandler() : TSignalHandler(kSigTermination, kFALSE) { }
   Bool_t  Notify();
};

Bool_t DbuSIGTERMHandler::Notify()
{
  //syslog(LOG_INFO,"<I> DbuSIGTERMHandler::Notify()");
  logDebug(5,"DbuSIGTERMHandler::Notify()");
  if (fDelay) { 
    //syslog(LOG_INFO,"<I> DbuSIGTERMHandler::Notify() delayed");
    logDebug(4,"DbuSIGINTHandler::Notify() delayed");
    fDelay++; 
    return kFALSE; 
  }

  DbuSignalHandler::Instance().SignalAction(fSignal);
  return kTRUE;
}

//----------------------------------------------------------------------
//......................................................................

DbuSignalHandler::DbuSignalHandler() :
   fSIGINT(0), fSIGTERM(0)
{
  // ctor
  // create handlers for SIGTERM and SIGINT

  fSIGINT  = new DbuSIGINTHandler;
  fSIGINT->Add();

  fSIGTERM = new DbuSIGTERMHandler;
  fSIGTERM->Add();
}

//......................................................................

DbuSignalHandler::~DbuSignalHandler() 
{
  delete fSIGINT;
  delete fSIGTERM;
}

//......................................................................
  
DbuSignalHandler& DbuSignalHandler::Instance()
{
  // protect singleton
  if (fgInstance == 0) {
    static DbuSignalHandler::Cleaner c; // end-of-run clean up
    c.ClassIsUsed();

    fgInstance = new DbuSignalHandler;
  }
  return *fgInstance;
}

//......................................................................

void DbuSignalHandler::Delay()
{
   // delay processing of signals until HandleDelayedSignal is called

  fSIGTERM->Delay();
  fSIGINT->Delay();

  //syslog(LOG_INFO,"<I> DbuSignalHandler::Delay()");
  logDebug(5,"DbuSignalHandler::Delay()");
}

//......................................................................

void DbuSignalHandler::HandleDelayedSignal()
{
   // processing any delayed signals

  fSIGTERM->HandleDelayedSignal();
  fSIGINT->HandleDelayedSignal();

  //syslog(LOG_INFO,"<I> DbuSignalHandler::HandleDelayedSignal()");
  logDebug(5,"DbuSignalHandler::HandleDelayedSignal()");
}

//......................................................................

bool DbuSignalHandler::SignalAction(int signal)
{
  // This is where the real work is done
  // decisions about what to do when a signal is caught go here

  MSG("Dbu",Msg::kInfo) 
    << "Dbu SignalAction (signal " << signal 
    << ") called" << endl;

  logNotice("SignalAction: signal %d, attempt shutdown.",signal);

  // make sure the clean up code is called

  // closelog(); // shutdown code might want to write to syslog
  //NO!//msgLogCleanup();

  exit(1);

  return true;

}

---