cgiavgtraces.c

/*----------------------------------------------------------------------
 * Copyright (c) 2018 XIA LLC
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, 
 * with or without modification, are permitted provided 
 * that the following conditions are met:
 *
 *   * Redistributions of source code must retain the above 
 *     copyright notice, this list of conditions and the 
 *     following disclaimer.
 *   * Redistributions in binary form must reproduce the 
 *     above copyright notice, this list of conditions and the 
 *     following disclaimer in the documentation and/or other 
 *     materials provided with the distribution.
 *   * Neither the name of XIA LLC
 *     nor the names of its contributors may be used to endorse 
 *     or promote products derived from this software without 
 *     specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND 
 * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, 
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 
 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. 
 * IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE 
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON 
 * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR 
 * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 
 * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 
 * SUCH DAMAGE.
 *----------------------------------------------------------------------*/
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <time.h>
#include <signal.h>
#include <errno.h>
#include <string.h>
#include <sys/mman.h>
#include <math.h>

#include "PixieNetDefs.h"
#include "PixieNetCommon.h"
#include "PixieNetConfig.h"


int main(void) {		 

  int fd;
  void *map_addr;
  int size = 4096;
  volatile unsigned int *mapped;
  int k;
  FILE * fil;
  unsigned int adc0[NAVG_TRACE_SAMPLES], adc1[NAVG_TRACE_SAMPLES], adc2[NAVG_TRACE_SAMPLES], adc3[NAVG_TRACE_SAMPLES];
  unsigned int mval;
  unsigned int maxwait;
  double scale[NCHANNELS];
  char line[LINESZ];

    PixieNetFippiConfig fippiconfig;		// struct holding the input parameters
  const char *defaults_file = "defaults.ini";
  int rval = init_PixieNetFippiConfig_from_file( defaults_file, 0, &fippiconfig );   // first load defaults, do not allow missing parameters
  if( rval != 0 )
  {
    printf( "Failed to parse FPGA settings from %s, rval=%d\n", defaults_file, rval );
    return rval;
  }
  const char *settings_file = "settings.ini";
  rval = init_PixieNetFippiConfig_from_file( settings_file, 1, &fippiconfig );   // second override with user settings, do allow missing
  if( rval != 0 )
  {
    printf( "Failed to parse FPGA settings from %s, rval=%d\n", settings_file, rval );
    return rval;
  }

  // compute max. wait time  and scaling factor
  maxwait = 0;
  for( k = 0; k < NCHANNELS; k ++ )          // get maximum sampling interval
  {
   if(maxwait< fippiconfig.ADC_AVG[k]) maxwait = fippiconfig.ADC_AVG[k];

      scale[k] = (double)fippiconfig.ADC_AVG[k];
      if(fippiconfig.ADC_AVG[k] > 2048)
         scale[k] = scale[k]/16384.0; 
      else  if(fippiconfig.ADC_AVG[k] > 64)
         scale[k] = scale[k]/128.0; 
   // scale[k] =1; // debug

  }
  maxwait = maxwait * NAVG_TRACE_SAMPLES * 10;            // ten times  max total sampling time   (in clock cycles)
  maxwait = (int)floor(maxwait * 8 / 100000);             // scale in 100 us wait cycles
//  printf( "maxwait for timeout: %d \n", maxwait );
//  printf( "scale factors %f %f %f %f \n", scale[0], scale[1], scale[2], scale[3] );

  


  // *************** PS/PL IO initialization *********************
  // open the device for PD register I/O
  fd = open("/dev/uio0", O_RDWR);
  if (fd < 0) {
    perror("Failed to open devfile");
    return 1;
  }

  map_addr = mmap( NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);

  if (map_addr == MAP_FAILED) {
    perror("Failed to mmap");
    return 1;
  }

  mapped = (unsigned int *) map_addr;


   // **************** XIA code begins **********************

  // 1a. arm trigger
    mapped[AOUTBLOCK] = OB_IOREG;	
    mapped[ACOUNTER_CLR] = 1;	      // any write to COUNTER_CLR arms the trigger for capturing averaged samples

    // 2a. poll for capture to be finished 
    mapped[AOUTBLOCK] = OB_EVREG;		// switch reads to event data block of addresses
    k=0; 
    do {          
       usleep(1000);                    
       k=k+1;
       mval = mapped[AADCTRIG];
       //printf("ADCTRIG = 0x%x \n", mval);
    }  
    while ( ((mval & 0x0010) == 0) & (k< maxwait) );      // wait the estimated time, for this channel
    if( (k>=maxwait)  )                 // not even one trigger found
    {
       printf("Error: Waiting for trigger timed out, ch. 0 \n");
      // return -1;
    }

    // 3a. read 4K samples from ADC register 

   // dummy reads for sampling update
   k = mapped[AAVGADC0] & 0xFFFF;

   if( (mval & 0x0010) >0)    // read only traces that triggered  
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc0[k] = (int)floor((double)mapped[AAVGADC0] / scale[0] );
   else
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc0[k] = (k & 0x0003) +0 ;   




    // 1b. arm trigger
    mapped[AOUTBLOCK] = OB_IOREG;	
    mapped[ACOUNTER_CLR] = 1;	      // any write to COUNTER_CLR arms the trigger for capturing averaged samples       
         
    // 2b. poll for capture to be finished 
    mapped[AOUTBLOCK] = OB_EVREG;		// switch reads to event data block of addresses
    k=0; 
    do {          
       usleep(1000);                    
       k=k+1;
       mval = mapped[AADCTRIG];
       //printf("ADCTRIG = 0x%x \n", mval);
    }  
    while ( ((mval & 0x0020) == 0) & (k< maxwait) );      // wait the estimated time, for this channel
    if( (k>=maxwait)  )                 // not even one trigger found
    {
       //printf("Error: Waiting for trigger timed out, ch. 1 \n");
      // return -1;
    }

    // 3b. read 4K samples from ADC register 

   // dummy reads for sampling update
   k = mapped[AAVGADC1] & 0xFFFF;

   if( (mval & 0x0020) >0)    // read only traces that triggered  
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc1[k] = (int)floor((double)mapped[AAVGADC1] / scale[1] );
   else
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc1[k] = (k & 0x0003) +1 ;



   // 1c. arm trigger
    mapped[AOUTBLOCK] = OB_IOREG;	
    mapped[ACOUNTER_CLR] = 1;	      // any write to COUNTER_CLR arms the trigger for capturing averaged samples

    // 2c. poll for capture to be finished 
    mapped[AOUTBLOCK] = OB_EVREG;		// switch reads to event data block of addresses
    k=0; 
    do {          
       usleep(1000);                    
       k=k+1;
       mval = mapped[AADCTRIG];
       //printf("ADCTRIG = 0x%x \n", mval);
    }  
    while ( ((mval & 0x0040) == 0) & (k< maxwait) );      // wait the estimated time, for this channel
    if( (k>=maxwait)  )                 // not even one trigger found
    {
      // printf("Error: Waiting for trigger timed out, ch. 2 \n");
      // return -1;
    }

    // 3c. read 4K samples from ADC register 

   // dummy reads for sampling update
   k = mapped[AAVGADC2] & 0xFFFF;

   if( (mval & 0x0040) >0)    // read only traces that triggered  
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc2[k] = (int)floor((double)mapped[AAVGADC2] / scale[2] );
   else
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc2[k] = (k & 0x0003) +2 ;



   // 1d. arm trigger
    mapped[AOUTBLOCK] = OB_IOREG;	
    mapped[ACOUNTER_CLR] = 1;	      // any write to COUNTER_CLR arms the trigger for capturing averaged samples


    // 2d. poll for capture to be finished 
    mapped[AOUTBLOCK] = OB_EVREG;		// switch reads to event data block of addresses
    k=0; 
    do {          
       usleep(1000);                    
       k=k+1;
       mval = mapped[AADCTRIG];
       //printf("ADCTRIG = 0x%x \n", mval);
    }  
    while ( ((mval & 0x0080) == 0) & (k< maxwait) );      // wait the estimated time, for this channel
    if( (k>=maxwait)  )                 // not even one trigger found
    {
      // printf("Error: Waiting for trigger timed out, ch. 3 \n");
      // return -1;
    }

    // 3d. read 4K samples from ADC register 

   // dummy reads for sampling update
   k = mapped[AAVGADC3] & 0xFFFF;

   if( (mval & 0x0080) >0)    // read only traces that triggered  
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc3[k] = (int)floor((double)mapped[AAVGADC3] / scale[3] );
   else
      for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
         adc3[k] = (k & 0x0003) +3 ;


      // 4. read the webpage template and print 
   fil = fopen("adcavgpage.html","r");
   for( k = 0; k < 96; k ++ )
   {
      fgets(line, LINESZ, fil);     // read from template, first part
     if(k==6)
         printf("<title>Pixie-Net Triggered ADC Traces </title>\n");            // "print" to webserver on stdout  
      else if(k==57)
         printf("<h1>Pixie-Net Triggered ADC Traces </h1>\n");            // "print" to webserver on stdout  
      else if(k==58)
         printf("[ current read from FPGA ] \n"); 
      else if(k==72)
         printf("<i><p>This page displays the triggered, averaged ADC waveforms just read from the Pixie-Net</p>\n");            // "print" to webserver on stdout  
      else if(k==76)  
         printf("<p><b>Do not execute or refresh while a DAQ is in progress</b></p>\n");                     // "print" to webserver on stdout  
      else
         printf("%s",line);            // "print" to webserver on stdout  
   }   
   
   fgets(line, LINESZ, fil);        // read from template, the line listing the ADC.csv file. This is not printed
   printf("       \"sample,adc0,adc1,adc2,adc3\\n\"  +  \n");

   // print the data
   for( k = 0; k < NAVG_TRACE_SAMPLES; k ++ )
   {
        printf("      \"%d,%d,%d,%d,%d\\n \"  + \n",k,adc0[k],adc1[k],adc2[k],adc3[k]);
   }
   // comma, not + requred in last line
   printf("      \"%d,%d,%d,%d,%d\\n \"  ,  \n",k,adc0[k-1],adc1[k-1],adc2[k-1],adc3[k-1]);
 
   // finish printing the webpage
   for( k = 97; k < 125; k ++ )
   {
      if(k==74) {
         fgets(line, LINESZ, fil);        // read from template
         printf("<p>Time scale (ns): %d %d %d %d </p>",fippiconfig.ADC_AVG[0]*4,fippiconfig.ADC_AVG[1]*4,fippiconfig.ADC_AVG[2]*4,fippiconfig.ADC_AVG[3]*4);              
      }
      else {
         fgets(line, LINESZ, fil);        // read from template
         printf("%s",line);               // "print" to webserver on stdout
      }
   }   

// clean up  
munmap(map_addr, size);
close(fd);
fclose(fil);
return 0;
}