WebSVN - f9daq - Rev 110 - /praktikum/lc2277/daqusb.C

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/mman.h>
#include <sys/ioctl.h>
#include <errno.h>
#include <signal.h>
#include <ctype.h>
#include <time.h>
#include <sys/time.h>

#include "wusbxx_dll.h" /* the header of the shared library */
#include "daq.h"

#define DEVICE_NAME "/dev/cc32_1"
#define PRRES(X) printf(">>> %s -> %d\n",#X,(X))



/* definiram lokacije enot*/
//#define NTDC 23         /* TDC LeCroy 2277*/
#define NTDC 16         /* TDC LeCroy 2277*/
#define END_MARKER 0xFAF5
int ctrlc=0;
int timer_out=0;

void SigInt (int sig)
{
    ctrlc = 1;
    timer_out=1;
   
}

struct sigaction oact;
void timerast (int signumber)
{
    timer_out = 1;
    printf("->>> TIMEOUT !!!\n");
}

void tmlnk (int tout)
{
    timer_out = 0;
    struct sigaction act;
    struct itimerval tdelay;

    act.sa_handler = timerast;
    sigemptyset (&act.sa_mask);
    act.sa_flags = 0;

    tdelay.it_value.tv_sec = tout / 100;
    tdelay.it_value.tv_usec = 10000 * (tout % 100);
    tdelay.it_interval.tv_sec = 0;
    tdelay.it_interval.tv_usec = 0;

    if (sigaction (SIGALRM, &act, &oact) < 0)
{
        perror ("sigaction(tmlnk)");
        exit (EXIT_FAILURE);
    }
    if (setitimer (ITIMER_REAL, &tdelay, NULL) < 0)
    {
        perror ("setitimer(tmlnk)");
        exit (EXIT_FAILURE);
    }
}

void tmulk ()
{
    struct itimerval tdelay;

    tdelay.it_value.tv_sec = 0;
    tdelay.it_value.tv_usec = 0;
    tdelay.it_interval.tv_sec = 0;
    tdelay.it_interval.tv_usec = 0;

    if (setitimer (ITIMER_REAL, &tdelay, NULL) < 0)
    {
        perror ("setitimer(tmulk)");
        exit (EXIT_FAILURE);
    }
    if (sigaction (SIGALRM, &oact, NULL) < 0)
    {
        perror ("sigaction(tmulk)");
        exit (EXIT_FAILURE);
    }
}




void CAMAC_status(void)
{
  unsigned short id,fpga,modid,inhibit,lam;
  unsigned short dum;
  

  long cres;
  int q,x;  
 
  CSSA_RQX(0,0,0,&cres,&q,&x);
  dum = cres;
  id   = (dum & 0xF000) >> 12;
  fpga = (dum & 0x0F00) >> 8;   
  modid =  (dum & 0x00F0) >> 4; 
  q      =  (dum & 0x0008) >> 3;
  x      =  (dum & 0x0004) >> 2;
  inhibit=  (dum & 0x0002) >> 1;
  lam    =  (dum & 0x0001);     
  printf ("CC32 CSR ID=%x FPGA=%x modID=%x Q=%d X=%d INHIBIT=%d LAM=%d \n",id,fpga,modid, q,x,inhibit,lam);
}

int daq::init(){

  printf("DAQ init at 0x%x\n",(unsigned int *) udev);
  if (udev == NULL) connect();
  if (udev == NULL) printf("udev == NULL\n");
  xxusb_register_write(udev,1,0x0); // Stop DAQ mode
  while (xxusb_usbfifo_read(udev, (int*) stackdump,BUFF_L,100)>0); 
  
  printf("DAQ init finished\n");
  CCCZ;
  CCCC;

  CREM_I;
  long cres;
  int q,x;  
 
  // set status registerdevices_find
  //int tdcreg2277=0x8C00; // status register common start (green LED),Front panel timeout ,leading+trailing
  //  tdcreg2277= 0xC00;   //  status register common stop (red LED)                        ,leading + trailing edge recording
  int  tdcreg2277= 0xCC00; //  status register common start (green LED),8192 ns timeout     ,leading+trailing
  
 CSSA_WQX(NTDC,0,17,tdcreg2277,&q,&x);
 CSSA_RQX(NTDC,0,17,&cres,&q,&x);
  
  printf("LC2277 SetRegister 0x%04x GetRegister 0x%04x\n",tdcreg2277,(unsigned int)cres);
  
  CAMAC_status();

  // listmode data -----------------------------------------------

    long k=1;
    

  /*
    stackwrite[k++]=(NAF(NTDC,0,8))| 0x8000 ; // test lam
    stackwrite[k++]=0x80 ; // wait for lam 


    stackwrite[k++]=(NAF(NTDC,1,27))| 0x8000;  // test buffering
    stackwrite[k++]=0x10 | 0x8000 ; //until Q=0
    stackwrite[k++]=0xF ; //max repetitions

    stackwrite[k++]=NAFS(0,0,16);
    stackwrite[k++]=0xbeef;

    stackwrite[k++]=(NAF(NTDC,9,27))| 0x8000;  // test buffering
    stackwrite[k++]=0x10 | 0x8000 ; //until Q=0
    stackwrite[k++]=0xFF ; //max repetitions

    stackwrite[k++]=NAFS(0,0,16);
    stackwrite[k++]=0xbeef;
*/


    stackwrite[k++]=(NAF(NTDC,0,0))| 0x8000;  // read TDC
    stackwrite[k++]=0x10 | 0x8000 ; //until Q=0
    stackwrite[k++]=0xF ; //max repetitions
   
    stackwrite[k++]=NAF(NTDC,0,9) ; // clear tdc

    stackwrite[k++]=NAF(NTDC,0,10) ; // clear lam

    
//    stackwrite[k++]=NAF(NTDC,0,1);  // read status register
    stackwrite[k++]=NAFS(0,0,16);
    stackwrite[k++]=END_MARKER;
    stackwrite[0]=k-1;

    for(unsigned int i=0;i<stackwrite[0];i++) printf("0x%04lx\n",stackwrite[i+1]);
    
    CAMAC_LED_settings(udev, 1,1,0,0);
    xxusb_stack_write(udev,0x2,(long int *)stackwrite);
    PRRES(xxusb_stack_read(udev,0x2,(long int *) stackdata));
    for(int i=0;i<13;i++) printf("0x%04lx\n",stackdata[i]);

    PRRES(CAMAC_register_read(udev,0,&k));
    char tbline[300];
    sprintf(tbline,"Firmware ID -> 0x%08lX",k);
    printf("%s\n",tbline);
   
    CAMAC_register_read(udev,1,&k);
    sprintf(tbline,"Global Mode -> 0x%08lX",k);
    printf("%s\n",tbline);
    k=(k&0xF000)|0x0006;
    //                    k=0x0002;
    k=7;// Start DAQ mode Buffopt=7 single event
    CAMAC_register_write(udev,1,k);
    CAMAC_register_write(udev,2,0x80); // wait 0x80 us
    CAMAC_register_write(udev,3,0x0);
    CAMAC_register_write(udev,9,0x0);
    CAMAC_register_write(udev,14,0x0);

    return 0;
}

int daq::connect(){
/*xxusb_device_type devices[100];
struct usb_device *dev;
dev = devices[0].usbdev;
udev = xxusb_device_open(dev);*/
    WUSBXX_load (NULL);
//    WUSBXX_open ((char *)"CC0126");
    WUSBXX_open ((char *)"CC0130");
    printf("daq::connect()\n");
    return 0;
}
  
int daq::disconnect(){ 
  /* zakljuci */
  
   printf("daq::disconnect()\n");
  return 0;
}


int daq::event(unsigned int *data, int maxn){
  
  //int events=0;  
 
  short ret;

  
 
  //while ((events==0)&&(!fStop)){ 
  int tout=100; /* 1/100 of a second */
  tmlnk (tout);
   
  ret=xxusb_usbfifo_read(udev,(int *) data,BUFF_L,500);
  tmulk(); 
   

  // printf("ret=%d,events=0x%08x\n",ret,data[0]);
  //}
  
  
  return ret*2;
}



daq::daq(){
// intercept routine
  if (signal (SIGINT, SigInt) == SIG_ERR) perror ("sigignore");
   
fStop=0;
connect();
init();
 xxusb_register_write(udev,1,0x1); // Start DAQ mode
}

daq::~daq(){
 xxusb_register_write(udev,1,0x0); // Stop DAQ mode
  while (xxusb_usbfifo_read(udev,(int *)stackdump,BUFF_L,30)>0);

disconnect();
}

#ifdef MAIN



int main (int argc, char **argv){
  
  int debug=0;
  int neve=1000000;
  char fname[0xFF];
  sprintf(fname, "test.dat");
  if (argc==1) {
    printf("Uporaba: %s stevilo_dogodkov ime_datoteke\n",argv[0]);
    printf("Meritev prekini s Ctrl-C, ce je nabranih dogodkov ze dovolj\n");
    exit(0);
  } 
  if (argc>1) neve  = atoi(argv[1]);
  if (argc>2) sprintf(fname,"%s", argv[2]);
  if (argc>3) debug = atoi(argv[3]);
  
  

  // odpremo datoteko za pisanje
  FILE *fp=fopen(fname,"w");
  
  int hdr[4]={1};
  
  #define BSIZE 10000
  unsigned int data[BSIZE];
  daq *d= new daq();
  
  for (int ieve=0;ieve!=neve && !ctrlc ;ieve++){
    //int tout=100; /* 1/100 of a second */
    //tmlnk (tout);
    int nb=d->event(data,BSIZE);
    //tmulk();
    // zapis v datoteko   
    if (nb<0){
      ieve--; 
      continue;
    }
    hdr[1]=nb+4*sizeof(int);
    hdr[2]=time(NULL);
    hdr[3]=ieve;
   
    fwrite(hdr,   sizeof(int),4 , fp); 
    fwrite(data,   sizeof(int),nb, fp);
//*****************
    int evsize=0;
    int events=0;  
    int ib=1,count=0;
    events = data[0];
    evsize = data[ib++]&0xffff;
    if (ieve %100 == 0) printf("nb=%d Event:%d events=%d EvSize:%d\n",nb, ieve,  events, evsize);
    if (evsize<2) {
      ieve--;
      continue;
    }
    for (int i=0;i<evsize;i++)  {
       //if (debug) printf("%d\t%08x\n", ib, data[ib]);
       if (data[ib]== END_MARKER) break; 
       if (ib%2==0) {
          unsigned short word1 =data[ib  ]&0xFFFF;
          unsigned short word2 =data[ib+1]&0xFFFF;
          unsigned short tdc =  word1;                 
          unsigned short ch  =  (word2 >> 1 ) &0x1F;
          unsigned short edge =  word2   & 0x1;
          unsigned short q    = (word2 >> 8)  &0x1;
          unsigned short x    = (word2 >> 9)  &0x1;
          if (debug) printf("%d. [ch=%2d] edge=%d data=%d q=%d x=%d\n",count,ch,edge,tdc, q, x);
          count++;
       }
       ib++;
    }
    if (data[evsize+1]!=END_MARKER) printf("Error! END_MARKER not found\n");
//*****************   

 
  }
  fclose(fp);
  printf("Podatki so v datoteki %s\n", fname);

  
  delete d;

  return 0;
}
#endif
Subversion Repositories f9daq

(root)/praktikum/lc2277/daqusb.C - Rev 110
