Subversion Repositories f9daq

#include <utility.h>
#include <ansi_c.h>
#include <cvirte.h>            
#include <userint.h>
#include "drs4.h"
#include "drsread.h"

static int daq_on;
static int ph, plothandle[4];
static int tfID;
static int controlID;

#define MAX_THREADS 10  

static CmtThreadPoolHandle poolHandle = 0;  

int main (int argc, char *argv[]) {
  if (InitCVIRTE (0, argv, 0) == 0)
    return -1;  /* out of memory */
  if ((ph = LoadPanel (0, "drs4.uir", PANEL)) < 0)
    return -1;
  SetStdioPort (CVI_STDIO_WINDOW);
  SetSleepPolicy(VAL_SLEEP_MORE);
  CmtNewThreadPool (MAX_THREADS,  &poolHandle);
 
  DisplayPanel (ph);
  RunUserInterface ();
  DiscardPanel (ph);
   CmtDiscardThreadPool (poolHandle);
  return 0;
}





static void start_timer (double tout) {
  SetCtrlAttribute (ph, PANEL_TIMER, ATTR_INTERVAL, tout);
  SetCtrlAttribute (ph, PANEL_TIMER, ATTR_ENABLED, 1);
}

static void stop_timer ( void ) {
  SetCtrlAttribute (ph, PANEL_TIMER, ATTR_ENABLED, 0);
   DRSSetTimeout();      
}




void CVICALLBACK EndOfThread ( CmtThreadPoolHandle poolhandle,
                               CmtThreadFunctionID functionID, unsigned int event,
                               int value, void *callbackData  ) {

  daq_on=0;
  //SetDimming(0);
  printf("End of Thread \n");
  return ;

}

   
int CVICALLBACK daq(void *functionData) {

 
  int neve;
  char filename[0xff];      
  char smask[0xff];      
  unsigned long mask;
  int frequency;
  double trgdelay;  
  double trglevel;  
  int trgtype;
  int trgchannel;
  int trgpolarity;  
  int verbose;  
  double range;
 
 
  GetCtrlVal(ph, PANEL_FILENAME, filename );
  GetCtrlVal(ph, PANEL_MASK, smask );      
  mask = strtoul (smask,NULL,0);
  GetCtrlVal(ph,PANEL_NEVE, &neve);
 
  GetCtrlVal(ph,PANEL_FREQUENCY, &frequency);
  GetCtrlVal(ph,PANEL_TRGDELAY, &trgdelay);
  GetCtrlVal(ph,PANEL_TRGCHANNEL, &trgchannel);
  GetCtrlVal(ph,PANEL_TRGTYPE, &trgtype);
  GetCtrlVal(ph,PANEL_TRGLEVEL, &trglevel);
  GetCtrlVal(ph,PANEL_TRGPOLARITY, &trgpolarity);
  GetCtrlVal(ph,PANEL_RANGE, &range);
  GetCtrlVal(ph,PANEL_DEBUG, &verbose);
 
  printf("mask=0x%x\n",mask);
   
  DRSSetMask( (unsigned char)( mask & 0xF ) );
 
  DRSSetFrequency( frequency  );
  DRSSetTriggerPolarity(trgpolarity);
  DRSSetTriggerLevel(trglevel);
  DRSSetRange (  range );
  DRSSetTriggerType( trgtype );
  DRSSetTriggerChannel(trgchannel );
         
  FILE *fp=fopen(filename,"wb");
 
 
  static unsigned char *buffer;

  int buffer_size = 0;
const int nBoards=1;
const int waveDepth=1024;
if (buffer_size == 0) {
         buffer_size =  4 +  nBoards * (4 + 4*(4+waveDepth*4));
         buffer_size += 24 + nBoards * (8 + 4*(4+waveDepth*2));
         buffer = (unsigned char *)malloc(buffer_size);
}
   
time_t t=0,told=0, tstart=0;

if (!DRSInit()){
  time(&tstart);
  told=tstart;
  int i=0;
  for (i=0; i<neve; i++) {
    start_timer(1);// 1 s timeout  
    int retval = DRSRead(0);
    stop_timer();
    int nb =  ( retval == 0 && fp ) ? DRSToBuffer( buffer , i ) : 0;
    SetCtrlVal(ph,PANEL_CEVE,i);       
          if (retval) i--;
    if (!daq_on) break;
    time(&t);
    if (t!=told ) {
                  printf("%d events in %2.2f min (%d s) %s",i+1, (double)(t-tstart)/60.,(t-tstart), ctime(&t));
          }    
    told=t;
// Save data   
        if (nb>0 && fp) fwrite(buffer, 1,nb ,fp);
// Plot Data
        for (int k=0;k<4;k++){
        if (! (mask & ( 0x1<<k ))  ) continue;
        float *t=DRSGetTime(k);
        float *x=DRSGetWave(k);        
       
        const int col[4]={VAL_WHITE,VAL_RED,VAL_GREEN,VAL_BLUE};
        if (plothandle[k])      DeleteGraphPlot (ph, PANEL_GRAPH, plothandle[k], VAL_IMMEDIATE_DRAW);
        plothandle[k] = PlotXY (ph, PANEL_GRAPH, t, x, 1024, VAL_FLOAT, VAL_FLOAT, VAL_THIN_LINE, VAL_NO_POINT, VAL_SOLID, 1, col[k]);
         
              for (int i=0 ; i<1024 ; i++) {
           if (verbose) printf("[%d] %d. x= %3.2f  y=%3.2f\n", k, i, t[i], x[i] );
           //h[k]->Fill( t[i], x[i]*1e-3);
        }
  }
       
 
        }
        time(&t);
  printf("%d events in %2.2f min (%d s) %s",i+1, (double)(t-tstart)/60.,t-tstart, ctime(&t));
  DRSEnd();
}

if (fp) fclose(fp);

free(buffer);

  return 0;

}

int CVICALLBACK StartCB (int panel, int control, int event,
                         void *callbackData, int eventData1, int eventData2) {
  ThreadFunctionPtr mythread = NULL;  
  switch (event) {
     
    case EVENT_COMMIT:
     
      mythread = daq;
      if (mythread!=NULL) {
      printf("New Thread panel=%d button=%d\n", panel, control);
     
     // SetDimming(1);
      controlID= control;
      daq_on=1;
        CmtScheduleThreadPoolFunctionAdv (poolHandle, mythread, &controlID,
                                        DEFAULT_THREAD_PRIORITY,
                                        EndOfThread,
                                        EVENT_TP_THREAD_FUNCTION_END,
                                        NULL, RUN_IN_SCHEDULED_THREAD,
                                        &tfID);
    }
      break;
  }
  return 0;
}

int CVICALLBACK StopCB (int panel, int control, int event,
                        void *callbackData, int eventData1, int eventData2) {
  switch (event) {
    case EVENT_COMMIT:
      daq_on=0;        
      break;
  }
  return 0;
}

int CVICALLBACK ExitCB (int panel, int control, int event,
                        void *callbackData, int eventData1, int eventData2) {
  switch (event) {
    case EVENT_COMMIT:
      QuitUserInterface (0);
      break;
  }
  return 0;
}