PollingService.cc

Go to the documentation of this file.

/*----------------------------------------------------------------------------*
*  Copyright (c) 2006        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, 31-Oct-2006, 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 <PollingService.hxx>


using namespace std;
using namespace codaObject;



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


PollingService::PollingService(int timeout)
    : pollingThreadId((pthread_t)NULL), pollingTimeout(timeout),
      pollingPthreadDispatcher(NULL) {}


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


void *PollingService::dispatchInterrupt(void*) {
  while(true) {
#ifdef VXWORKS
    timespec ts = {0, pollingTimeout};
    if (pollingTimeout > 1000000000) {
        ts.tv_sec  = pollingTimeout/1000000000;
        ts.tv_nsec = pollingTimeout - ts.tv_sec*1000000000;
    }
    nanosleep(&ts, NULL);
#else
    usleep(pollingTimeout*1000);
#endif
    if(myIntObj!=NULL)myIntObj->interrupt(0);
    pthread_testcancel();
  }
  return(NULL);
}


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


bool PollingService::setupInterrupt(void) {
    return(true);
}


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


bool PollingService::enableInterrupt(void) {

  if(pollingPthreadDispatcher==NULL) {

      //creates and launches thread
    pollingPthreadDispatcher = new pthreadDispatcher<PollingService,void*,void*>(this,&PollingService::dispatchInterrupt,NULL);
    if(pthread_create(&pollingThreadId,NULL,pthreadDispatcher<PollingService,void*,void*>::dispatchIt,
                      (void*)pollingPthreadDispatcher)==0) {

    } else {

      pollingThreadId=0;
      delete(pollingPthreadDispatcher);
      pollingPthreadDispatcher=NULL;
      string err = "?PollingService...unable to start polling thread";
      cerr << err << endl;
      myIntObj->daLogMsg(err,DALOG_ERROR);
    }
    
  } else {
    string err = "?PollingService::enableInterrupt:  attempt to start a second interrupt thread ignored";
    cerr << err << endl;
    myIntObj->daLogMsg(err,DALOG_ERROR);
  }

  return(true);
}


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


bool PollingService::pauseInterrupt(void) {
  return(deleteInterrupt());
}


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


bool PollingService::resumeInterrupt(void) {
  return(enableInterrupt());
}


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


bool PollingService::deleteInterrupt(void) {

  if(pollingThreadId!=0)pthread_cancel(pollingThreadId);
  pollingThreadId=0;

  if(pollingPthreadDispatcher!=NULL)delete(pollingPthreadDispatcher);
  pollingPthreadDispatcher=NULL;

  return(true);
}
  

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

---