RtclSignalAction.cpp

Go to the documentation of this file.

// $Id: RtclSignalAction.cpp 1186 2019-07-12 17:49:59Z mueller $
// SPDX-License-Identifier: GPL-3.0-or-later
// Copyright 2013-2018 by Walter F.J. Mueller <W.F.J.Mueller@gsi.de>
// 
// Revision History: 
// Date         Rev Version  Comment
// 2018-12-18  1089   1.0.5  use c++ style casts
// 2018-11-30  1075   1.0.4  use list-init
// 2014-11-08   602   1.0.3  cast int first to ptrdiff_t, than to ClientData
// 2014-08-22   584   1.0.2  use nullptr
// 2014-08-02   577   1.0.1  add include unistd.h  (write+pipe dcl)
// 2013-05-17   521   1.0    Initial version
// ---------------------------------------------------------------------------
 
#include <errno.h>
#include <signal.h>
#include <unistd.h>
 
#include <iostream>
 
#include "librtools/Rexception.hpp"
 
#include "RtclSignalAction.hpp"
 
using namespace std;
 
// all method definitions in namespace Retro
namespace Retro {
 
RtclSignalAction* RtclSignalAction::fpObj = nullptr;
 
//------------------------------------------+-----------------------------------
bool RtclSignalAction::Init(Tcl_Interp* interp, RerrMsg& emsg)
{
  if (fpObj) {
    emsg.Init("RtclSignalAction::Init", "already initialized");
    return false;
  }
  
  try {
    fpObj = new RtclSignalAction(interp);
  } catch (exception& e) {
    emsg.Init("RtclSignalAction::Init", string("exception: ")+e.what());
    return false;
  }
 
  Tcl_CreateExitHandler(reinterpret_cast<Tcl_ExitProc*>(ThunkTclExitProc),
                        reinterpret_cast<ClientData>(fpObj));
 
  return true;
}
 
//------------------------------------------+-----------------------------------
 
RtclSignalAction* RtclSignalAction::Obj()
{
  return fpObj;
}
  
 
//------------------------------------------+-----------------------------------
 
bool RtclSignalAction::SetAction(int signum, Tcl_Obj* pobj, RerrMsg& emsg)
{
  if (!ValidSignal(signum, emsg)) return false;
  if (fActionSet[signum] && !ClearAction(signum, emsg)) return false;
 
  struct sigaction sigact = {};
  sigact.sa_handler = SignalHandler;
 
  if (::sigaction(signum, &sigact, &fOldAction[signum]) != 0) {
    emsg.InitErrno("RtclSignalAction::SetAction",
                   "sigaction() failed: ", errno);
    return false;
  }
 
  fpScript[signum] = pobj;
  fActionSet[signum] = true;
  return true;
}
 
//------------------------------------------+-----------------------------------
 
bool RtclSignalAction::GetAction(int signum, Tcl_Obj*& pobj, RerrMsg& emsg)
{
  if (!ValidSignal(signum, emsg)) return false;
  if (!fActionSet[signum]) {
    emsg.Init("RtclSignalAction::GetAction", "no action for signal");
    return false;
  }
 
  pobj = fpScript[signum];
  return true;
}
 
//------------------------------------------+-----------------------------------
 
bool RtclSignalAction::ClearAction(int signum, RerrMsg& emsg)
{
  if (!ValidSignal(signum, emsg)) return false;
  if (!fActionSet[signum]) {
    emsg.Init("RtclSignalAction::ClearAction", "no action for signal");
    return false;
  }
 
  if (::sigaction(signum, &fOldAction[signum], nullptr) != 0) {
    emsg.InitErrno("RtclSignalAction::ClearAction",
                   "sigaction() failed: ", errno);
    return false;
  }  
  fpScript[signum] = nullptr;
  fActionSet[signum] = false;
  return true;
}
 
//------------------------------------------+-----------------------------------
 
bool RtclSignalAction::ValidSignal(int signum, RerrMsg& emsg)
{
  if (signum > 0 && signum < 32) {
    switch (signum) {
    case SIGHUP:
    case SIGINT:
    case SIGTERM:
    case SIGUSR1:
    case SIGUSR2:
      return true;
    default:
      break;
    }
  }
  emsg.Init("RtclSignalAction::ValidSignal", "unsupported signal");
  return false;
}
 
//------------------------------------------+-----------------------------------
 
void RtclSignalAction::TclChannelHandler(int /*mask*/)
{
  char signum;
  Tcl_Read(fShuttleChn, reinterpret_cast<char*>(&signum), sizeof(signum));
  // FIXME_code: handle return code
 
  Tcl_SetVar2Ex(fpInterp, "Rutil_signum", nullptr, 
                Tcl_NewIntObj(int(signum)), 0);
  // FIXME_code: handle return code
 
  if (!!fpScript[int(signum)]) {
    Tcl_EvalObjEx(fpInterp, fpScript[int(signum)], TCL_EVAL_GLOBAL);
    // FIXME_code: handle return code 
  }
 
  return;
}
 
//------------------------------------------+-----------------------------------
 
void RtclSignalAction::SignalHandler(int signum)
{
  if (fpObj && fpObj->fFdPipeWrite>0) {
    char signum_c = signum;
    int irc = ::write(fpObj->fFdPipeWrite, &signum_c, sizeof(signum_c));
    if (irc < 0) 
      cerr << "RtclSignalAction::SignalHandler-E: write() failed, errno="
           << errno << endl;
  } else {
    cerr << "RtclSignalAction::SignalHandler-E: spurious call" << endl;
  }
  return;
}
 
//------------------------------------------+-----------------------------------
 
void RtclSignalAction::ThunkTclChannelHandler(ClientData /*cdata*/, int mask)
{
  if (fpObj) fpObj->TclChannelHandler(mask);
  return;
}
 
//------------------------------------------+-----------------------------------
 
void RtclSignalAction::ThunkTclExitProc(ClientData /*cdata*/)
{
  delete fpObj;
  fpObj = nullptr;
  return;
}
 
//------------------------------------------+-----------------------------------
 
RtclSignalAction::RtclSignalAction(Tcl_Interp* interp)
  : fpInterp(interp),
    fFdPipeRead(-1),
    fFdPipeWrite(-1),
    fShuttleChn(),
    fActionSet{},
    fpScript{},
    fOldAction{}
{
  int pipefd[2];
  if (::pipe(pipefd) < 0) 
    throw Rexception("RtclSignalAction::<ctor>", "pipe() failed: ", errno);
 
  fFdPipeRead  = pipefd[0];
  fFdPipeWrite = pipefd[1];
 
  // cast first to ptrdiff_t to promote to proper int size
  fShuttleChn = Tcl_MakeFileChannel(reinterpret_cast<ClientData>(fFdPipeRead), 
                                    TCL_READABLE);
 
  Tcl_SetChannelOption(nullptr, fShuttleChn, "-buffersize", "64");
  Tcl_SetChannelOption(nullptr, fShuttleChn, "-encoding", "binary");
  Tcl_SetChannelOption(nullptr, fShuttleChn, "-translation", "binary");
 
  Tcl_CreateChannelHandler(fShuttleChn, TCL_READABLE, 
                    reinterpret_cast<Tcl_FileProc*>(ThunkTclChannelHandler),
                    reinterpret_cast<ClientData>(this));
}
 
//------------------------------------------+-----------------------------------
 
RtclSignalAction::~RtclSignalAction()
{
  for (size_t i=0; i<32; i++) {
    RerrMsg emsg;
    if (fActionSet[i]) ClearAction(i, emsg);
  }
}
  
 
} // end namespace Retro