WebSVN – f9daq – Diff – /lab/sipmscan/trunk/src/daqusb.C


#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 "../include/wusbxx_dll.h" /* the header of the shared library */
#include "../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
 

Rev 146	Rev 173
1	#include <stdio.h>	1	#include <stdio.h>
2	#include <stdlib.h>	2	#include <stdlib.h>
3	#include <string.h>	3	#include <string.h>
4	#include <unistd.h>	4	#include <unistd.h>
5	#include <sys/mman.h>	5	#include <sys/mman.h>
6	#include <errno.h>	6	#include <errno.h>
7	#include <signal.h>	7	#include <signal.h>
8	#include <ctype.h>	8	#include <ctype.h>
9	#include <time.h>	9	#include <time.h>
10	//#include "../include/wusbxx_dll.h" /* the header of the shared library */	10	#include "../include/wusbxx_dll.h" /* the header of the shared library */
11	#include "../include/daq.h"	11	#include "../include/daq.h"
12		12
13	//#define DEBUG /* vkljuci dodatni izpis */	13	//#define DEBUG /* vkljuci dodatni izpis */
14	#ifdef DEBUG	14	#ifdef DEBUG
15	#define DBG(X) X	15	#define DBG(X) X
16	#define DBGFUNI(X) printf(">>> %s -> %d\n",#X,(X))	16	#define DBGFUNI(X) printf(">>> %s -> %d\n",#X,(X))
17	#else	17	#else
18	#define DBG(X)	18	#define DBG(X)
19	#define DBGFUNI(X) X	19	#define DBGFUNI(X) X
20	#endif	20	#endif
21		21
22	/* definiram lokacije enot*/	22	/* definiram lokacije enot*/
23	//#define NTDC 1 /* TDC */	23	//#define NTDC 1 /* TDC */
24	//#define NTDCCH 8	24	//#define NTDCCH 8
25	//#define NADC 2 /* ADC */	25	//#define NADC 2 /* ADC */
26	//#define NADCCH 8	26	//#define NADCCH 8
27	int ctrlc=0;	27	int ctrlc=0;
28	char ccserial=(char)"CC0126";	28	char ccserial=(char)"CC0126";
29	int devDetect; // variable to tell if we detect any devices	29	//int devDetect; // variable to tell if we detect any devices
30		30
31	int daq::connect(){	31	int daq::connect(){
32	// odpri daq	32	// odpri daq
33	/* xxusb_device_type devices[100];	33	xxusb_device_type devices[100];
34	//struct usb_device *dev;	34	//struct usb_device *dev;
35	devDetect = xxusb_devices_find(devices);	35	devDetect = xxusb_devices_find(devices);
36	// printf("Detected devices: %d\n", devDetect);	36	// printf("Detected devices: %d\n", devDetect);
37	//dev = devices[0].usbdev;	37	//dev = devices[0].usbdev;
38	//udev = xxusb_device_open(dev);	38	//udev = xxusb_device_open(dev);
39		39
40	if(devDetect > 0)	40	if(devDetect > 0)
41	{	41	{
42	WUSBXX_load(NULL);	42	WUSBXX_load(NULL);
43	WUSBXX_open(ccserial);	43	WUSBXX_open(ccserial);
44	printf("daq::connect()\n");	44	printf("daq::connect()\n");
45	}	45	}
46	else	46	else
47	*/ printf("daq::connect() - No devices were detected!\n");	47	printf("daq::connect() - No devices were detected!\n");
48	return 0;	48	return 0;
49	}	49	}
50		50
51	int daq::init(int chan = 0){	51	int daq::init(int chan = 0){
52		52
53	// int i;	53	int i;
54	// long k;	54	long k;
55		55
56	/* DBGFUNI(xxusb_register_write~~(udev,1,0x0))~~; // Stop DAQ mode	56	DBGFUNI(xxusb_register_write(udev,1,0x0)); // Stop DAQ mode
57	while (xxusb_usbfifo_read(udev, (int*) stackdump,BUFF_L,100)>0);	57	while (xxusb_usbfifo_read(udev, (int*) stackdump,BUFF_L,100)>0);
58		58
59	CCCZ;	59	CCCZ;
60	CCCC;	60	CCCC;
61	CREM_I;	61	CREM_I;
62		62
63	NTDC = 1;	63	NTDC = 1;
64	NADC = 2;	64	NADC = 2;
65	if(chan != 0)	65	if(chan != 0)
66	{	66	{
67	NTDCCH = chan/2;	67	NTDCCH = chan/2;
68	NADCCH = chan/2;	68	NADCCH = chan/2;
69	}	69	}
70	else	70	else
71	{	71	{
72	NTDCCH = 1;	72	NTDCCH = 1;
73	NADCCH = 1;	73	NADCCH = 1;
74	}	74	}
75	printf("after: NTDCCH = %d, NADCCH = %d\n", NTDCCH, NADCCH);	75	printf("after: NTDCCH = %d, NADCCH = %d\n", NTDCCH, NADCCH);
76		76
77	// create command stack for the TDC and ADC	77	// create command stack for the TDC and ADC
78	k=1;	78	k=1;
79	for(i=0;(i<NTDCCH)&&(i<NADCCH);i++) { stackwrite[k++]=NAF(NTDC,i,0); stackwrite[k++]=NAF(NADC,i,0); }	79	for(i=0;(i<NTDCCH)&&(i<NADCCH);i++) { stackwrite[k++]=NAF(NTDC,i,0); stackwrite[k++]=NAF(NADC,i,0); }
80	// for(i=0;i<NADCCH;i++) stackwrite[k++]=NAF(NADC,i,0);	80	// for(i=0;i<NADCCH;i++) stackwrite[k++]=NAF(NADC,i,0);
81	stackwrite[k++]=NAF(NTDC,0,9);	81	stackwrite[k++]=NAF(NTDC,0,9);
82	stackwrite[k++]=NAF(NADC,0,9);	82	stackwrite[k++]=NAF(NADC,0,9);
83	stackwrite[k++]=NAFS(0,0,16); // insert next word to data	83	stackwrite[k++]=NAFS(0,0,16); // insert next word to data
84	stackwrite[k++]=0xfafb; // event termination word	84	stackwrite[k++]=0xfafb; // event termination word
85	stackwrite[0]=k-1;	85	stackwrite[0]=k-1;
86	// upload stack #2	86	// upload stack #2
87	xxusb_stack_write(udev,0x2,(long int *)stackwrite);	87	xxusb_stack_write(udev,0x2,(long int *)stackwrite);
88	xxusb_stack_read(udev,0x2,(long int *) stackdata);	88	xxusb_stack_read(udev,0x2,(long int *) stackdata);
89	DBG(for(i=0;i<k;i++) printf("0x%04x\n",stackdata[i]);)	89	DBG(for(i=0;i<k;i++) printf("0x%04x\n",stackdata[i]);)
90		90
91	int ret[10];	91	int ret[10];
92		92
93	CAMAC_LED_settings(udev, 1,1,0,0);	93	CAMAC_LED_settings(udev, 1,1,0,0);
94	ret[0] = CAMAC_register_read(udev,0,&k);	94	ret[0] = CAMAC_register_read(udev,0,&k);
95	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)	95	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)
96	ret[1] = CAMAC_register_read(udev,1,&k);	96	ret[1] = CAMAC_register_read(udev,1,&k);
97	printf("Global Mode (return %d) -> 0x%08lX\n",ret[1],k);	97	printf("Global Mode (return %d) -> 0x%08lX\n",ret[1],k);
98	k=(k&0xF000)\|0x0005; // set buffer length: n=0..6 -> 0x10000 >> n, n=7 -> single event	98	k=(k&0xF000)\|0x0005; // set buffer length: n=0..6 -> 0x10000 >> n, n=7 -> single event
99	ret[0] = CAMAC_register_write(udev,1,k); // GKM: sets the buffer length (i.e. k=5 -> buf length=128 words)	99	ret[0] = CAMAC_register_write(udev,1,k); // GKM: sets the buffer length (i.e. k=5 -> buf length=128 words)
100	ret[1] = CAMAC_register_write(udev,2,0x80); // wait 0x80 us after trigger // GKM: delay settings in microseconds	100	ret[1] = CAMAC_register_write(udev,2,0x80); // wait 0x80 us after trigger // GKM: delay settings in microseconds
101	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)	101	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)
102	ret[3] = CAMAC_register_write(udev,9,0x0); // Lam Mask Register // GKM: When 0, readout is triggered by the signal on NIM input	102	ret[3] = CAMAC_register_write(udev,9,0x0); // Lam Mask Register // GKM: When 0, readout is triggered by the signal on NIM input
103	ret[4] = CAMAC_register_write(udev,14,0x0); // USB Bulk Transfer Setup Register	103	ret[4] = CAMAC_register_write(udev,14,0x0); // USB Bulk Transfer Setup Register
104		104
105	// CAMAC_DGG(udev,1,2,3,0,200,0,0);	105	// CAMAC_DGG(udev,1,2,3,0,200,0,0);
106	// CAMAC_DGG(udev,0,0,0,0,100,0,0);	106	// CAMAC_DGG(udev,0,0,0,0,100,0,0);
107	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)	107	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)
108	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)	108	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)
109	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])	109	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])
110	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])	110	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])
111	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)	111	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)
112		112
113	// for(i = 0; i < 10; i++) printf("Setting %d? -> return = %d\n",i,ret[i]);	113	// for(i = 0; i < 10; i++) printf("Setting %d? -> return = %d\n",i,ret[i]);
114		114
115	// ret[0] = CAMAC_register_read(udev,1,&k);	115	// ret[0] = CAMAC_register_read(udev,1,&k);
116	// printf("k (return %d) -> 0x%08lX\n",ret[0],k);	116	// printf("k (return %d) -> 0x%08lX\n",ret[0],k);
117		117
118	*/ printf("daq::init()\n");	118	printf("daq::init()\n");
119	return 0;	119	return 0;
120	}	120	}
121		121
122	int daq::start(){	122	int daq::start(){
123	// xxusb_register_write~~(udev,1,0x1)~~; // Start DAQ mode	123	xxusb_register_write(udev,1,0x1); // Start DAQ mode
124	printf("daq::start()\n");	124	printf("daq::start()\n");
125	return 0;	125	return 0;
126	}	126	}
127		127
128	int daq::stop(){	128	int daq::stop(){
129	// xxusb_register_write~~(udev,1,0x0)~~; // Stop DAQ mode	129	xxusb_register_write(udev,1,0x0); // Stop DAQ mode
130	// while (xxusb_usbfifo_read~~(udev,(~~int *~~)stackdump,BUFF_L,30)~~>0);	130	while (xxusb_usbfifo_read(udev,(int *)stackdump,BUFF_L,30)>0);
131	printf("daq::stop()\n");	131	printf("daq::stop()\n");
132	return 0;	132	return 0;
133	}	133	}
134		134
135	int daq::event(unsigned int *data, int maxn){	135	int daq::event(unsigned int *data, int maxn){
136	// int ~~ib,count~~;	136	int ib,count;
137	int count;	-
138	/* int ~~events,evsize~~;	137	int events,evsize;
139	short ret;	138	short ret;
140		139
141	ib=0;	140	ib=0;
142	ret=xxusb_usbfifo_read(udev,(int *) stackdata,BUFF_L,500);	141	ret=xxusb_usbfifo_read(udev,(int *) stackdata,BUFF_L,500);
143	events=stackdata[ib++];	142	events=stackdata[ib++];
144	DBG(printf("ret=%d,events=0x%08x\n",ret,events);)	143	DBG(printf("ret=%d,events=0x%08x\n",ret,events);)
145	if ((ret<0)\|\|(ret!=(((NTDCCH+NADCCH)4+4)events+4))) return 0;	144	if ((ret<0)\|\|(ret!=(((NTDCCH+NADCCH)4+4)events+4))) return 0;
146		145
147	count=0;	146	count=0;
148	while (ib<(ret/2-1)){	147	while (ib<(ret/2-1)){
149	evsize = stackdata[ib++]&0xffff;	148	evsize = stackdata[ib++]&0xffff;
150	DBG(printf("Event:%d EvSize:%d\n", events, evsize);)	149	DBG(printf("Event:%d EvSize:%d\n", events, evsize);)
151	for (int i=0;i<(NTDCCH+NADCCH);i++,ib++) data[count++] =stackdata[ib++]&0xffff;	150	for (int i=0;i<(NTDCCH+NADCCH);i++,ib++) data[count++] =stackdata[ib++]&0xffff;
152	if (stackdata[ib++]!=0xfafb){	151	if (stackdata[ib++]!=0xfafb){
153	printf("~~Error!\n~~");,	152	printf("Error!\n");
154	return 0;	153	return 0;
155	}	154	}
156	events--;	155	events--;
157	if (fStop) return 0;	156	if (fStop) return 0;
158	}	157	}
159	if (stackdata[ib++]!=0xffff){	158	if (stackdata[ib++]!=0xffff){
160	printf("Error!\n");	159	printf("Error!\n");
161	return 0;	160	return 0;
162	}	161	}
163	*/	162
164	count = 1;	163	// count = 1;
165	return count;	164	return count;
166	}	165	}
167		166
168	int daq::disconnect(){	167	int daq::disconnect(){
169	// zapri daq	168	// zapri daq
170	// WUSBXX_close();	169	WUSBXX_close();
171	printf("daq::disconnect()\n");	170	printf("daq::disconnect()\n");
172	return 0;	171	return 0;
173	}	172	}
174		173
175	daq::daq(){	174	daq::daq(){
176	fStop=0;	175	fStop=0;
177	connect();	176	connect();
178	// if(devDetect > 0)	177	// if(devDetect > 0)
179	// init();	178	// init();
180	}	179	}
181		180
182	daq::~daq(){	181	daq::~daq(){
183	disconnect();	182	disconnect();
184	}	183	}
185		184
186	#ifdef MAIN	185	#ifdef MAIN
187	void CatchSig (int signumber)	186	void CatchSig (int signumber)
188	{	187	{
189	ctrlc = 1;	188	ctrlc = 1;
190	}	189	}
191		190
192		191
193	int main (int argc, char **argv){	192	int main (int argc, char **argv){
194		193
195	int neve=1000000;	194	int neve=1000000;
196	char *fname="test.dat";	195	char *fname="test.dat";
197	if (argc==1) {	196	if (argc==1) {
198	printf("Uporaba: %s stevilo_dogodkov ime_datoteke\n",argv[0]);	197	printf("Uporaba: %s stevilo_dogodkov ime_datoteke\n",argv[0]);
199	printf("Meritev prekini s Ctrl-C, ce je nabranih dogodkov ze dovolj\n");	198	printf("Meritev prekini s Ctrl-C, ce je nabranih dogodkov ze dovolj\n");
200	exit(0);	199	exit(0);
201	}	200	}
202	if (argc>1) neve = atoi(argv[1]);	201	if (argc>1) neve = atoi(argv[1]);
203	if (argc>2) fname = argv[2];	202	if (argc>2) fname = argv[2];
204		203
205		204
206	// intercept routine	205	// intercept routine
207	if (signal (SIGINT, CatchSig) == ~~SIG_E,RR~~) perror ("sigignore");	206	if (signal (SIGINT, CatchSig) == SIG_ERR) perror ("sigignore");
208		207
209	#define BSIZE 10000	208	#define BSIZE 10000
210	int i,ieve,nc,nb;	209	int i,ieve,nc,nb;
211	// int hdr[4]={1,(NTDCCH+4)sizeof(int)}; // hdr[0]=1, hdr[1]=(NTDCCH+4)4	210	// int hdr[4]={1,(NTDCCH+4)sizeof(int)}; // hdr[0]=1, hdr[1]=(NTDCCH+4)4
212	int hdr[4]={1,(NTDCCH+NADCCH+4)*sizeof(int)};	211	int hdr[4]={1,(NTDCCH+NADCCH+4)*sizeof(int)};
213	unsigned short adc;	212	unsigned short adc;
214	unsigned int data[BSIZE];	213	unsigned int data[BSIZE];
215	daq *d= new daq();,	214	daq *d= new daq();
216	time_t time_check;,	215	time_t time_check;
217		216
218	// odpremo datoteko za pisanje	217	// odpremo datoteko za pisanje
219	FILE *fp=fopen(fname,"w");	218	FILE *fp=fopen(fname,"w");
220		219
221	d->start();	220	d->start();
222	ieve=0;	221	ieve=0;
223		222
224	while((ieve<neve)&&(!ctrlc)){	223	while((ieve<neve)&&(!ctrlc)){
225	nc=d->event(data,BSIZE);	224	nc=d->event(data,BSIZE);
226	nb=0;	225	nb=0;
227	while((nc>0)&&(ieve++<neve)&&(!ctrlc)){	226	while((nc>0)&&(ieve++<neve)&&(!ctrlc)){
228	// zapis v datoteko	227	// zapis v datoteko
229	hdr[2]=time(NULL);	228	hdr[2]=time(NULL);
230	hdr[3]=ieve;	229	hdr[3]=ieve;
231	fwrite(hdr,sizeof(int),4 ,fp);	230	fwrite(hdr,sizeof(int),4 ,fp);
232	fwrite(&data[nb],sizeof(int),(NTDCCH+NADCCH),fp);	231	fwrite(&data[nb],sizeof(int),(NTDCCH+NADCCH),fp);
233	// DBG(	232	// DBG(
234	for(i=0;i<(NTDCCH+NADCCH);i++){	233	for(i=0;i<(NTDCCH+NADCCH);i++){
235	adc=data[nb+i]&0xFFFF;	234	adc=data[nb+i]&0xFFFF;
236	if(i % 2 == 0)	235	if(i % 2 == 0)
237	printf(/"nev=%4d %d. TDC data=%d\n"/"%d\t"/,ieve,i///2/,adc);	236	printf(/"nev=%4d %d. TDC data=%d\n"/"%d\t"/,ieve,i///2/,adc);
238	// printf("nev=%4d %d. TDC data=%d\n",ieve,i/2,adc);	237	// printf("nev=%4d %d. TDC data=%d\n",ieve,i/2,adc);
239	else if(i % 2 == 1)	238	else if(i % 2 == 1)
240	printf(/"nev=%4d %d. TDC data=%d\n"/"%d\t"/,ieve,i///2/,adc);	239	printf(/"nev=%4d %d. TDC data=%d\n"/"%d\t"/,ieve,i///2/,adc);
241	// printf("nev=%4d %d. ADC data=%d\n",ieve,i/2,adc);	240	// printf("nev=%4d %d. ADC data=%d\n",ieve,i/2,adc);
242	}	241	}
243	printf("\n");	242	printf("\n");
244	// )	243	// )
245	nb+=(NTDCCH+NADCCH);	244	nb+=(NTDCCH+NADCCH);
246	nc-=(NTDCCH+NADCCH);	245	nc-=(NTDCCH+NADCCH);
247	if (!(ieve%1000)) printf("event no. -> %d\n",ieve);	246	if (!(ieve%1000)) printf("event no. -> %d\n",ieve);
248	};	247	};
249	};	248	};
250		249
251	d->stop();	250	d->stop();
252	fclose(fp);	251	fclose(fp);
253	printf("Podatki so v datoteki %s\n", fname);	252	printf("Podatki so v datoteki %s\n", fname);
254	delete d;	253	delete d;
255		254
256	return 0;	255	return 0;
257	}	256	}
258	#endif	257	#endif
259		258

Subversion Repositories f9daq

(root)/lab/sipmscan/trunk/src/daqusb.C – Rev 146 → 173