Fork.h

#ifndef _Belle2_Fork_hh
#define _Belle2_Fork_hh
 
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>
#include <stdlib.h>
 
namespace Belle2 {
  class Fork {
 
  public:
    template <class WORKER>
    static void g_handler_exit(int, void* worker)
    {
      delete(WORKER*)worker;
      exit(0);
    }
    static void g_handler_int(int) { exit(0); }
 
  public:
    Fork() : m_pid(-1) {}
 
    template<class WORKER>
    Fork(WORKER* worker, bool detached = true)
    {
      m_pid = fork();
      if (m_pid == 0) {
        signal(SIGINT, g_handler_int);
        if (detached) {
          on_exit(g_handler_exit<WORKER>, (void*)worker);
        }
        worker->run();
        exit(0);
      } else if (detached) {
        delete worker;
      }
    }
    ~Fork() {}
 
  public:
    pid_t get_id() const { return m_pid; }
    void set_id(pid_t id) { m_pid = id; }
    bool isAlive() const { return kill(0); }
    bool kill(int signo) const
    {
      if (m_pid < 0) return false;
      return ::kill(m_pid, signo) == 0;
    }
    bool wait(int opt = 0)
    {
      if (m_pid < 0) return false;
      if (::waitpid(m_pid, NULL, opt)) {
        m_pid = -1;
      }
      return true;
    }
    bool cancel() { return kill(SIGINT); }
 
  private:
    pid_t m_pid;
 
  };
 
}
 
#endif