Subversion Repositories f9daq

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

#include <sys/mman.h>

#include <errno.h>

#include <signal.h>

#include <ctype.h>

#include <time.h>

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

#include "daq.h"

//#define DEBUG /* vkljuci dodatni izpis */

#ifdef DEBUG

  #define DBG(X) X

  #define DBGFUNI(X) printf(">>> %s -> %d\n",#X,(X))

#else

  #define DBG(X)

  #define DBGFUNI(X) X

#endif

/* definiram lokacije enot*/

//#define NTDC 1         /* TDC */

//#define NTDCCH 8

//#define NADC 2         /* ADC */

//#define NADCCH 8

int ctrlc=0;

char *ccserial=(char*)"CC0126";

//int devDetect;	// variable to tell if we detect any devices

int daq::connect(){

// odpri daq

  xxusb_device_type devices[100];

  //struct usb_device *dev;

  devDetect = xxusb_devices_find(devices);

//  printf("Detected devices: %d\n", devDetect);

  //dev = devices[0].usbdev;

  //udev = xxusb_device_open(dev);

  if(devDetect > 0)

  {

    WUSBXX_load(NULL);

    WUSBXX_open(ccserial);

    printf("daq::connect()\n");

  }

  else

    printf("daq::connect() - No devices were detected!\n");

  return 0;

}

int daq::init(int chan = 0){

    int i;  

    long k;

    DBGFUNI(xxusb_register_write(udev,1,0x0)); // Stop DAQ mode

    while (xxusb_usbfifo_read(udev, (int*) stackdump,BUFF_L,100)>0); 

    CCCZ;

    CCCC;

    CREM_I;

    NTDC = 1;

    NADC = 2;

    if(chan != 0)

    {

      NTDCCH = chan/2;

      NADCCH = chan/2;

    }

    else

    {

      NTDCCH = 1;

      NADCCH = 1;

    }

    printf("after: NTDCCH = %d, NADCCH = %d\n", NTDCCH, NADCCH);

// create command stack for the TDC and ADC

    k=1;

    for(i=0;(i<NTDCCH)&&(i<NADCCH);i++) { stackwrite[k++]=NAF(NTDC,i,0); stackwrite[k++]=NAF(NADC,i,0); }

//    for(i=0;i<NADCCH;i++) stackwrite[k++]=NAF(NADC,i,0);

    stackwrite[k++]=NAF(NTDC,0,9);

    stackwrite[k++]=NAF(NADC,0,9);

    stackwrite[k++]=NAFS(0,0,16); // insert next word to data

    stackwrite[k++]=0xfafb; // event termination word

    stackwrite[0]=k-1;

// upload stack #2

    xxusb_stack_write(udev,0x2,(long int *)stackwrite);

    xxusb_stack_read(udev,0x2,(long int *) stackdata);

    DBG(for(i=0;i<k;i++) printf("0x%04x\n",stackdata[i]);)

    int ret[10];

    CAMAC_LED_settings(udev, 1,1,0,0);

    ret[0] = CAMAC_register_read(udev,0,&k);

    printf("Firmware ID (return %d) -> 0x%08lX\n",ret[0],k);		// GKM: Firmware ID (i.e. 0x72000001 = 0111 0010 0000 0000 0000 0000 0000 0001)

    ret[1] = CAMAC_register_read(udev,1,&k);

    printf("Global Mode (return %d) -> 0x%08lX\n",ret[1],k);

    k=(k&0xF000)|0x0005; // set buffer length: n=0..6 -> 0x10000 >> n, n=7 -> single event

    ret[0] = CAMAC_register_write(udev,1,k);				// GKM: sets the buffer length (i.e. k=5 -> buf length=128 words)

    ret[1] = CAMAC_register_write(udev,2,0x80); // wait 0x80 us after trigger		// GKM: delay settings in microseconds

    ret[2] = CAMAC_register_write(udev,3,0x0); // Scaler Readout Control Register		// GKM: scaler readout settings - sets the frequency of readout (if 0, it is disabled)

    ret[3] = CAMAC_register_write(udev,9,0x0); // Lam Mask Register		// GKM: When 0, readout is triggered by the signal on NIM input

    ret[4] = CAMAC_register_write(udev,14,0x0); // USB Bulk Transfer Setup Register

    //    CAMAC_DGG(udev,1,2,3,0,200,0,0);

    //    CAMAC_DGG(udev,0,0,0,0,100,0,0);

    ret[5] = CAMAC_register_write(udev,5,(0x06<<16)+(0x04<<8)+0x00); // output		// GKM: NIM outputs (i.e. 0x060400 = 00 0110 0000 0100 0000 0000 -> NIM O2=DGG_B, NIM O3=DGG_A)

    ret[6] = CAMAC_register_write(udev,6,(0x01<<24)+(0x01<<16)+(0x0<<8)+0x0); // SCLR & DGG	// GKM: device source selector (i.e. 0x01010000 = 00 0000 0001 0000 0001 0000 0000 0000 0000 -> DGG_A=NIM I1, DGG_B=NIM I1, SCLR=disabled)

    ret[7] = CAMAC_register_write(udev,7,(100<<16)+0); // output		// GKM: Delay and Gate Generator A registers (i.e. 0x00640000 = 0000 0000 0110 0100 0000 0000 0000 0000 -> DDG_A [gate=100, delay=0])

    ret[8] = CAMAC_register_write(udev,8,(10000<<16)+0); // output	// GKM: Delay and Gate Generator B registers (i.e. 0x27100000 = 0010 0111 0001 0000 0000 0000 0000 0000 -> DDG_B [gate=10000, delay=0])

    ret[9] = CAMAC_register_write(udev,13,0); // output		// GKM: Extended (course) delay (i.e. 0x00000000 = 0 -> DDG_A ext=0, DDG_B ext=0)

//    for(i = 0; i < 10; i++) printf("Setting %d? -> return = %d\n",i,ret[i]);

//    ret[0] = CAMAC_register_read(udev,1,&k);

//    printf("k (return %d) -> 0x%08lX\n",ret[0],k);

    printf("daq::init()\n");

    return 0;

}

int daq::start(){

    xxusb_register_write(udev,1,0x1); // Start DAQ mode

    printf("daq::start()\n");

    return 0;

}

int daq::stop(){

    xxusb_register_write(udev,1,0x0); // Stop DAQ mode

    while (xxusb_usbfifo_read(udev,(int *)stackdump,BUFF_L,30)>0);

    printf("daq::stop()\n");

    return 0;

}

int daq::event(unsigned int *data, int maxn){

    int ib,count;

    int events,evsize;

    short ret;

    ib=0;

    ret=xxusb_usbfifo_read(udev,(int *) stackdata,BUFF_L,500);

    events=stackdata[ib++];

    DBG(printf("ret=%d,events=0x%08x\n",ret,events);)

      if ((ret<0)||(ret!=(((NTDCCH+NADCCH)*4+4)*events+4))) return 0;

    count=0;

    while (ib<(ret/2-1)){

      evsize = stackdata[ib++]&0xffff;

      DBG(printf("Event:%d EvSize:%d\n", events, evsize);)

      for (int i=0;i<(NTDCCH+NADCCH);i++,ib++)  data[count++] =stackdata[ib++]&0xffff;

      if (stackdata[ib++]!=0xfafb){

        printf("Error!\n");

        return 0;

      }

      events--;

      if (fStop) return 0;

    } 

    if (stackdata[ib++]!=0xffff){

      printf("Error!\n");

      return 0;

    }

//    count = 1;

    return count;

}

int daq::disconnect(){ 

// zapri daq

    WUSBXX_close();

    printf("daq::disconnect()\n");

    return 0;

}

daq::daq(){

  fStop=0;

  connect();

//  if(devDetect > 0)

//    init();

}

daq::~daq(){

disconnect();

}

#ifdef MAIN

void CatchSig (int signumber)

{

   ctrlc = 1;

}

int main (int argc, char **argv){

  int neve=1000000;

  char *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) fname = argv[2];

// intercept routine

  if (signal (SIGINT, CatchSig) == SIG_ERR) perror ("sigignore");

#define BSIZE 10000

  int i,ieve,nc,nb;

//  int hdr[4]={1,(NTDCCH+4)*sizeof(int)};	// hdr[0]=1, hdr[1]=(NTDCCH+4)*4

  int hdr[4]={1,(NTDCCH+NADCCH+4)*sizeof(int)};

  unsigned short adc;

  unsigned int data[BSIZE];

  daq *d= new daq();

  time_t time_check;

// odpremo datoteko za pisanje

  FILE *fp=fopen(fname,"w");

  d->start();

  ieve=0;

  while((ieve<neve)&&(!ctrlc)){

    nc=d->event(data,BSIZE);

    nb=0;

    while((nc>0)&&(ieve++<neve)&&(!ctrlc)){

      // zapis v datoteko   

      hdr[2]=time(NULL);

      hdr[3]=ieve;

      fwrite(hdr,sizeof(int),4 ,fp); 

      fwrite(&data[nb],sizeof(int),(NTDCCH+NADCCH),fp);

//      DBG(

        for(i=0;i<(NTDCCH+NADCCH);i++){

          adc=data[nb+i]&0xFFFF;	

          if(i % 2 == 0)

printf(/*"nev=%4d %d. TDC data=%d\n"*/"%d\t"/*,ieve,i*//*/2*/,adc);

//            printf("nev=%4d %d. TDC data=%d\n",ieve,i/2,adc);

          else if(i % 2 == 1)

printf(/*"nev=%4d %d. TDC data=%d\n"*/"%d\t"/*,ieve,i*//*/2*/,adc);

//            printf("nev=%4d %d. ADC data=%d\n",ieve,i/2,adc);

        }

printf("\n");

//      )

      nb+=(NTDCCH+NADCCH);

      nc-=(NTDCCH+NADCCH);

      if (!(ieve%1000)) printf("event no. -> %d\n",ieve);

    };

  };

  d->stop();

  fclose(fp);

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

  delete d;

  return 0;

}

#endif