InterruptibleObject.cc

Go to the documentation of this file.

// still to do:
//   call super?



/*----------------------------------------------------------------------------*
*  Copyright (c) 2005        Southeastern Universities Research Association, *
*                            Thomas Jefferson National Accelerator Facility  *
*                                                                            *
*    This software was developed under a United States Government license    *
*    described in the NOTICE file included as part of this distribution.     *
*                                                                            *
*    E.Wolin, 15-Apr-2005, Jefferson Lab                                     *
*                                                                            *
*    Authors: Elliott Wolin                                                  *
*             wolin@jlab.org                    Jefferson Lab, MS-6B         *
*             Phone: (757) 269-7365             12000 Jefferson Ave.         *
*             Fax:   (757) 269-5519             Newport News, VA 23606       *
*                                                                            *
*----------------------------------------------------------------------------*/



#include <InterruptibleObject.hxx>


using namespace std;
using namespace cmsg;
using namespace codaObject;


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


InterruptibleObject::InterruptibleObject(const string& udl, const string& Name, const string& Descr, 
                                         InterruptService *IntSvc, const string &cClass,
                                         const cMsgSubscriptionConfig *scfg) throw(CodaException)
  : RunObject(udl,Name,Descr,cClass,scfg), dllInterrupt(NULL), intSvc(IntSvc) { 


  // set object type
  objectType="InterruptibleObject";


  // register with interrupt service
  if(intSvc!=NULL)intSvc->setInterruptibleObject(this);
}


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


InterruptibleObject::~InterruptibleObject(void) throw() {}


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


bool InterruptibleObject::download(const string& s) throw(CodaException) {

  bool stat = RunObject::download(s);

  // get additional dll sumbol after executing superclass method
#ifndef VXWORKS  
  if(hasDLL) dllInterrupt = (dllIntFuncPtr)dlsym(dllHandle,"interrupt");
#endif

  return(stat);
}


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


bool InterruptibleObject::prestart(const string& s) throw(CodaException) {

  bool stat = true;
  changeState("prestarting");

  if(intSvc!=NULL) {
    stat = intSvc->setupInterrupt();
    if(!stat) {
      string err = "?InterruptibleObject::prestart...setupInterrupt failure";
      cerr << err << endl;
      daLogMsg(err,DALOG_ERROR);
      return(false);
    }
  }

  stat = RunObject::prestart(s);
  return(stat);
}


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


bool InterruptibleObject::go(const string& s) throw(CodaException) {

  bool stat = true;
  changeState("going");


  // reset statistics counters
  eventNumber=0;
  dataCount=0;


  // must call userGo before enabling interrupt
  if(hasDLL&&(dllGo!=NULL)) {
#ifndef VXWORKS
    stat=dllGo(s.c_str(),(void *)&dllSysArg,NULL);
#endif
  } else {
    stat=userGo(s);
  }
  if(!stat)return(false);


  if(intSvc!=NULL) {
    stat = intSvc->enableInterrupt();
    if(!stat) {
      string err = "?InterruptibleObject::go...enableInterrupt failure";
      cerr << err << endl;
      daLogMsg(err,DALOG_ERROR);
      return(false);
    }
  }


  changeState("active");
  return(true);
}


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


bool InterruptibleObject::interrupt(unsigned int flag) throw(CodaException) {
  
  bool stat = false;

  if(hasDLL&&(dllInterrupt!=NULL)) {
#ifndef VXWORKS
    stat=dllInterrupt(flag,(void *)&dllSysArg,NULL);
#endif
  } else {
    stat=userInterrupt(flag);
  }

  return(stat);
}


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


bool InterruptibleObject::pause(const string& s) throw(CodaException) {

  bool stat = true;
  changeState("pausing");

  if(intSvc!=NULL) {
    stat = intSvc->pauseInterrupt();
    if(!stat) {
      string err = "?InterruptibleObject::pause failure";
      cerr << err << endl;
      daLogMsg(err,DALOG_ERROR);
      return(false);
    }
  }

  stat = RunObject::pause(s);
  return(stat);
}


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


bool InterruptibleObject::resume(const string& s) throw(CodaException) {

  bool stat = true;
  changeState("resuming");


  if(hasDLL&&(dllResume!=NULL)) {
#ifndef VXWORKS
    stat=dllResume(s.c_str(),(void *)&dllSysArg,NULL);
#endif
  } else {
    stat=userResume(s);
  }
  if(!stat)return(false);


  if(intSvc!=NULL) {
    stat = intSvc->resumeInterrupt();
    if(!stat) {
      string err = "?InterruptibleObject::resume failure";
      cerr << err << endl;
      daLogMsg(err,DALOG_ERROR);
    }
  }

  changeState("active");
  return(stat);
}


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


bool InterruptibleObject::end(const string& s) throw(CodaException) {

  bool stat1 = true;
  bool stat2 = true;
  changeState("ending");

  if(intSvc!=NULL) {
    stat1 = intSvc->deleteInterrupt();
    if(!stat1) {
      string err = "?InterruptibleObject::end...deleteInterrupt failure";
      cerr << err << endl;
      daLogMsg(err,DALOG_ERROR);
    }
  }

  //calls user routine
  stat2 = RunObject::end(s);
  return(stat1&stat2);
}


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


bool InterruptibleObject::reset(const string& s) throw(CodaException) {

  bool stat1 = true;
  bool stat2 = true;
  changeState("resetting");

  if(intSvc!=NULL) {
    stat1 = intSvc->deleteInterrupt();
    if(!stat1) {
      string err = "?InterruptibleObject::reset...deleteInterrupt failure";
      cerr << err << endl;
      daLogMsg(err,DALOG_ERROR);
    }
  }

  //calls user routine
  stat2 = RunObject::reset(s);
  return(stat1&stat2);
}


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


bool InterruptibleObject::userInterrupt(unsigned int flag) throw(CodaException) {
  return(true);
}


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

---