edm::shared_memory::WorkerMonitorThread Class Reference

#include <WorkerMonitorThread.h>

Public Member Functions
const WorkerMonitorThread &	operator= (const WorkerMonitorThread &)=delete
const WorkerMonitorThread &	operator= (WorkerMonitorThread &&)=delete
void	setAction (std::function< void()> iFunc)
void	setupSignalHandling ()
	Sets the unix signal handler which communicates with the thread. More...
void	startThread ()
void	stop ()
	WorkerMonitorThread ()
	WorkerMonitorThread (const WorkerMonitorThread &)=delete
	WorkerMonitorThread (WorkerMonitorThread &&)=delete
	~WorkerMonitorThread ()

Private Member Functions
void	run ()

Static Private Member Functions
static void	sig_handler (int sig, siginfo_t *, void *)

Private Attributes
std::function< void()>	action_
std::atomic< bool >	actionSet_ = false
std::atomic< bool >	helperReady_ = false
std::thread	helperThread_
std::atomic< bool >	stopRequested_ = false

Static Private Attributes
static std::atomic< bool >	s_helperThreadDone = false
static std::atomic< int >	s_pipeReadEnd = 0
static std::atomic< int >	s_pipeWriteEnd = 0

Detailed Description

Definition at line 32 of file WorkerMonitorThread.h.

Constructor & Destructor Documentation

edm::shared_memory::WorkerMonitorThread::WorkerMonitorThread ( )

inline

Definition at line 34 of file WorkerMonitorThread.h.

Referenced by ~WorkerMonitorThread().

{}

edm::shared_memory::WorkerMonitorThread::~WorkerMonitorThread ( )

inline

Definition at line 35 of file WorkerMonitorThread.h.

References operator=(), stop(), stopRequested_, and WorkerMonitorThread().

                           {
      if (not stopRequested_.load()) {
        stop();
      }
    }

edm::shared_memory::WorkerMonitorThread::WorkerMonitorThread ( const WorkerMonitorThread &  )

delete

edm::shared_memory::WorkerMonitorThread::WorkerMonitorThread ( WorkerMonitorThread &&  )

delete

Member Function Documentation

const WorkerMonitorThread& edm::shared_memory::WorkerMonitorThread::operator= ( const WorkerMonitorThread &  )

delete

Referenced by ~WorkerMonitorThread().

const WorkerMonitorThread& edm::shared_memory::WorkerMonitorThread::operator= ( WorkerMonitorThread &&  )

delete

void WorkerMonitorThread::run ( )

private

Definition at line 41 of file WorkerMonitorThread.cc.

References action_, actionSet_, MessageLogger_cfi::cerr, helperReady_, s_helperThreadDone, and s_pipeReadEnd.

Referenced by setAction(), and startThread().

                              {
  //std::cerr << "Started cleanup thread\n";
  sigset_t ensemble;

  sigemptyset(&ensemble);
  sigaddset(&ensemble, SIGABRT);
  sigaddset(&ensemble, SIGILL);
  sigaddset(&ensemble, SIGBUS);
  sigaddset(&ensemble, SIGSEGV);
  sigaddset(&ensemble, SIGTERM);
  pthread_sigmask(SIG_BLOCK, &ensemble, nullptr);

  //std::cerr << "Start loop\n";
  helperReady_ = true;
  while (true) {
    int signal = -1;
    auto res = read(s_pipeReadEnd.load(), &signal, sizeof(signal) / sizeof(char));
    if (res == -1) {
      if (errno == EINTR) {
        continue;
      }
      abort();
    }
    if (signal != 0) {
      if (actionSet_) {
        action_();
      }
      std::cerr << "Worker: SIGNAL CAUGHT " << signal << "\n";
      s_helperThreadDone = true;
      break;
    } /* else {
      std::cerr << "SIGNAL woke\n";
    } */
  }
  //std::cerr << "Ending cleanup thread\n";
}

void edm::shared_memory::WorkerMonitorThread::setAction ( std::function< void()>  iFunc )

inline

Definition at line 48 of file WorkerMonitorThread.h.

References action_, actionSet_, eostools::move(), run(), setupSignalHandling(), sig_handler(), startThread(), and stop().

Referenced by main().

                                              {
      action_ = std::move(iFunc);
      actionSet_.store(true);
    }

void WorkerMonitorThread::setupSignalHandling

(

)

Sets the unix signal handler which communicates with the thread.

Definition at line 102 of file WorkerMonitorThread.cc.

References sig_handler().

Referenced by main(), setAction(), and startThread().

                                              {
  struct sigaction act;
  act.sa_sigaction = sig_handler;
  act.sa_flags = SA_SIGINFO;
  sigemptyset(&act.sa_mask);
  sigaction(SIGABRT, &act, nullptr);
  sigaction(SIGILL, &act, nullptr);
  sigaction(SIGBUS, &act, nullptr);
  sigaction(SIGSEGV, &act, nullptr);
  sigaction(SIGTERM, &act, nullptr);
}

void WorkerMonitorThread::sig_handler ( int  sig, siginfo_t *  , void *    )

staticprivate

Definition at line 127 of file WorkerMonitorThread.cc.

References createfilelist::int, s_helperThreadDone, s_pipeWriteEnd, and TriggerAnalyzer::write().

Referenced by setAction(), and setupSignalHandling().

                                                                {
  write(s_pipeWriteEnd.load(), &sig, sizeof(int) / sizeof(char));
  while (not s_helperThreadDone) {
  };
  signal(sig, SIG_DFL);
  raise(sig);
}

void WorkerMonitorThread::startThread

(

)

Definition at line 78 of file WorkerMonitorThread.cc.

References helperReady_, helperThread_, eostools::move(), pipe::pipe(), run(), s_pipeReadEnd, s_pipeWriteEnd, setupSignalHandling(), and protons_cff::t.

Referenced by main(), and setAction().

                                      {
  {
    //Setup watchdog thread for crashing signals

    int pipeEnds[2] = {0, 0};
    auto ret = pipe(pipeEnds);
    if (ret != 0) {
      abort();
    }
    s_pipeReadEnd.store(pipeEnds[0]);
    s_pipeWriteEnd.store(pipeEnds[1]);
    //Need to use signal handler since signals generated
    // from within a program are thread specific which can
    // only be handed by a signal handler
    setupSignalHandling();

    std::thread t(&WorkerMonitorThread::run, this);
    t.detach();
    helperThread_ = std::move(t);
  }
  while (helperReady_.load() == false) {
  }
}

void WorkerMonitorThread::stop

(

)

Definition at line 114 of file WorkerMonitorThread.cc.

References createfilelist::int, s_pipeWriteEnd, stopRequested_, and TriggerAnalyzer::write().

Referenced by setAction(), and ~WorkerMonitorThread().

                               {
  stopRequested_ = true;
  int sig = 0;
  write(s_pipeWriteEnd.load(), &sig, sizeof(int) / sizeof(char));
}

Member Data Documentation

std::function<void()> edm::shared_memory::WorkerMonitorThread::action_

private

Definition at line 67 of file WorkerMonitorThread.h.

Referenced by run(), and setAction().

std::atomic<bool> edm::shared_memory::WorkerMonitorThread::actionSet_ = false

private

Definition at line 66 of file WorkerMonitorThread.h.

Referenced by run(), and setAction().

std::atomic<bool> edm::shared_memory::WorkerMonitorThread::helperReady_ = false

private

Definition at line 65 of file WorkerMonitorThread.h.

Referenced by run(), and startThread().

std::thread edm::shared_memory::WorkerMonitorThread::helperThread_

private

Definition at line 73 of file WorkerMonitorThread.h.

Referenced by startThread().

std::atomic< bool > WorkerMonitorThread::s_helperThreadDone = false

staticprivate

Definition at line 71 of file WorkerMonitorThread.h.

Referenced by run(), and sig_handler().

std::atomic< int > WorkerMonitorThread::s_pipeReadEnd = 0

staticprivate

Definition at line 69 of file WorkerMonitorThread.h.

Referenced by run(), and startThread().

std::atomic< int > WorkerMonitorThread::s_pipeWriteEnd = 0

staticprivate

Definition at line 70 of file WorkerMonitorThread.h.

Referenced by sig_handler(), startThread(), and stop().

std::atomic<bool> edm::shared_memory::WorkerMonitorThread::stopRequested_ = false

private

Definition at line 64 of file WorkerMonitorThread.h.

Referenced by stop(), and ~WorkerMonitorThread().