linuxTITrigPollingService.cc

Go to the documentation of this file.

// linuxTITrigPollingService

// assumes Linux VME access already enabled

// ejw, 12-Jul-2012



#include <iostream>
#include <linuxTITrigPollingService.hxx>

extern "C" {
#include <jvme.h>
#include <tirLib.h>
}


using namespace std;
using namespace codaObject;


static char *tiLocalAddress;



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


linuxTITrigPollingService::linuxTITrigPollingService(timespec *timeout)
    : linuxTITrigPollingThreadId((pthread_t)NULL), linuxTITrigPollingTimeout(timeout),
      linuxTITrigPollingPthreadDispatcher(NULL) {

  // get local address
  vmeBusToLocalAdrs(VME_ACCESS_MODE, (char*)TI_BASE_ADDR, &tiLocalAddress);
}


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


void *linuxTITrigPollingService::dispatchInterrupt(void*) {

  unsigned int trigType;

  while(true) {
    nanosleep(linuxTITrigPollingTimeout,NULL);

    // check for pending trigger
    trigType=tirIntPoll();
    if(trigType>=1) {
      
      // process trigger
      if(myIntObj!=NULL)myIntObj->interrupt(trigType);

      // reenable triggers
      tirIntAck();
      //      vmeWrite16((volatile unsigned short *)(tiLocallAddress+0), TI_ENABLE_TRIG);

    }
    pthread_testcancel();
  }

  return(NULL);
}


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


bool linuxTITrigPollingService::setupInterrupt(void) {


  // initialize board
  int stat = tirIntInit(TI_BASE_ADDR,TIR_EXT_POLL,0);
  
  //  vmeWrite16((volatile unsigned short *)(tiLocalAddress+0), TI_RESET);

  return(true);
}


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


bool linuxTITrigPollingService::enableInterrupt(void) {

  if(linuxTITrigPollingPthreadDispatcher==NULL) {

    linuxTITrigPollingPthreadDispatcher = new pthreadDispatcher<linuxTITrigPollingService,void*,void*>(this,&linuxTITrigPollingService::dispatchInterrupt,NULL);
    if(pthread_create(&linuxTITrigPollingThreadId,NULL,pthreadDispatcher<linuxTITrigPollingService,void*,void*>::dispatchIt,
                      (void*)linuxTITrigPollingPthreadDispatcher)==0) {

      // enable triggers
      tirWriteCsr(TIR_ENABLED|TIR_EXTERNAL);
      //      vmeWrite16((volatile unsigned short *)(tiLocallAddress+0), TI_ENABLE_TRIG);


    } else {

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

  return(true);
}


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


bool linuxTITrigPollingService::pauseInterrupt(void) {


  tirWriteCsr(0);
  //  vmeWrite16((volatile unsigned short *)(tiLocallAddress+0), TI_PAUSE);

  return(true);
}


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


bool linuxTITrigPollingService::resumeInterrupt(void) {

  // reenable triggers
  tirWriteCsr(TIR_ENABLED&TIR_EXTERNAL);
  //  vmeWrite16((volatile unsigned short *)(tiLocallAddress+0), TI_ENABLE_TRIG);

  return(true);
}


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


bool linuxTITrigPollingService::deleteInterrupt(void) {

  // disable triggers
  tirWriteCsr(0);
  //  vmeWrite16((volatile unsigned short *)(tiLocallAddress+0), TI_DISABLE);


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

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

  return(true);
}
  

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

---