/data3/calcul/jacquem/working_dir/Micromegas/micromegasFrameWork/src/parser/MicrorocLabviewReader.cpp

Go to the documentation of this file.

/* @version $Revision: 1938 $ * @modifiedby $Author: jacquem $ * @lastmodified $Date: 2012-11-13 17:10:17 +0100 (Tue, 13 Nov 2012) $ */

////////////////////////////////////////////////////////////////////////
// MICROMEGAS
//
//       EVENT RECONSTRUCTION SOFTWARE FOR MICROROC BOARDS
//
////////////////////////////////////////////////////////////////////////

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>

#include "parser/MicrorocLabviewReader.hh"
#include "parser/AcquisitionParser.hh"

#include "event/Event.hh"

#include "geometry/Chamber.hh"
#include "geometry/Board.hh"
#include "geometry/Dif.hh"
#include "geometry/MicrorocChip.hh"
#include "geometry/Detector.hh"

#include "tools/Toolbox.hh"
#include "tools/SteerDesc.hh"
#include "tools/Log.hh"
#include "tools/MicroException.hh"

#include <iostream>
#include <iomanip>

using namespace std;

////////////////////////////////////////////////////////////////////////
MicrorocLabviewReader::MicrorocLabviewReader(Run& aRun, FILE *aFile, ui32 lastEventId,bool _forceAnalog, set<unsigned int>*_difList) : MicrorocMergeReader(aRun, aFile, lastEventId,_forceAnalog,_difList), nbBufferedData(0),bufferedData(0)

{
  FILE_LOG(logDEBUG1) << "--MicrorocLabviewReader constructor()"<< endl;
  FILE_LOG(logDEBUG) << "cwMixrorocLabview ReaderDifReader Constructeur  crc adr[" <<  crc << "]" << endl;
  
        run.setDataFormat(0);
  MicrorocMergeReader::localReset();

}

//--------------- Destructeur -------------//
MicrorocLabviewReader::~MicrorocLabviewReader()
{
  FILE_LOG(logDEBUG1)<< "----MicrorocLabviewReader destructor"<< endl;
}

//-------------------------------------------------------------------


//-------------------------------------------------------------------
// LOOP over the data Files, returns after each event
//      called for every dif found in the data file.
int MicrorocLabviewReader::getNextEvent(Event& event) {
  // Start data reconstruction
  Level(0);

        ui16 dataFormat = run.getDataFormat();

  if (dataFormat == 0) {
    // first read of the file
    bcIdDifAbsOrgMap.clear();
    // read file header
    dataFormat = getData(1);
    if ( dataFormat == 0x10  ) { dataFormat = 0xa; }
                run.setDataFormat(dataFormat);
    if ( run.getDataFormat() != 15 && run.getDataFormat() != 14 )
    {
      FILE_LOG(logERROR) << "labview data format[" << dec << dataFormat << "] not implemented" << endl;
      return(LAST_FILE_EVENT);
    }


    if (fileError == EOF) {
      FILE_LOG(logERROR) << "parsing file[" << inputFile << "]  - error " << errno << ":" << strerror(errno) << endl;
      reset();
      return(LAST_FILE_EVENT);
    }
    display(+1);
    FILE_LOG(logINFO) << "  Microroc LABVIEW DATA FORMAT  : " << dataFormat << endl;

    if ( dataFormat != 15 && run.getDataFormat() != 14  ){
      // unknown format
      FILE_LOG(logERROR) << " Microroc LABVIEW data format  " << dataFormat << " is not implemented" << endl;
      reset();
      return(LAST_FILE_EVENT);
    }

        if ( dataFormat == 15 || dataFormat == 14 )
  {

                run.setDaqSoftware(getData(2) );
                display(+1);
                FILE_LOG(logINFO) << hex << "  DAQ software version  : " << run.getDaqSoftware() <<endl;

   run.setSDccFirmware(getData(2));
   display(+1);
   FILE_LOG(logINFO) << hex << "  SDcc firware  : 0x" << run.getSDccFirmware() << endl;

   run.setDifFirmware(getData(2));
   display(+1);
   FILE_LOG(logINFO) << hex << "  Dif firware  : 0x" << run.getDifFirmware() << endl;
  
    globalTime = getData(4)    ; // labview time is second since 1 janv 1970 and globalTime milli second
    FILE_LOG(logDEBUG) << "globalTime in second:[0x"  << hex << globalTime << "] decimal[" << dec << globalTime << "]" <<   endl;
    globalTime *= 1000;
    FILE_LOG(logDEBUG) << "globalTime in millisecond:[" << globalTime << "]" <<  endl;

    globalTimeMilli = getData(4)    ; // labview time in millisecond
    FILE_LOG(logDEBUG) << "Plus globalTimeMilli in millisecond:[0x"  << hex << globalTimeMilli << "] decimal [" << dec <<  globalTimeMilli << "]" <<  endl;
  }


    if (fileError == EOF) {
      FILE_LOG(logDEBUG) << "  END OF DATA FILE" << endl;
      reset();
      return(LAST_FILE_EVENT);
    }
    //FILE_LOG(logDEBUG) << run.getDetector() << endl;
    display(-1);
    return NEW_CONFIG;
  }

  if (  skipNbEvent != 0 && debugEventId < skipNbEvent)
  {
    while ( debugEventId < skipNbEvent )
    {
      unsigned int globalHeader = getSpecificData(1);
      if (fileError == EOF) {
        FILE_LOG(logDEBUG) << "  END OF DATA FILE" << endl;
        return(LAST_FILE_EVENT);
      }
      FILE_LOG(logDEBUG1) << "DEBUG 1 wait for 0xa0[0x " << hex << globalHeader << "]"  << endl;
      while ( globalHeader != 0xa0  )
      {
        globalHeader = getSpecificData(1);
        FILE_LOG(logDEBUG1) << "wait for 0xa0[0x " << hex << globalHeader << "]"  << endl;
        if (fileError == EOF) {
          FILE_LOG(logDEBUG) << "  END OF DATA FILE" << endl;
          return(LAST_FILE_EVENT);
        }
      }

      unsigned int crc = getSpecificData(2);
      globalHeader = getSpecificData(1);
      FILE_LOG(logDEBUG1) << "wait for 0xb0[0x " << hex << globalHeader << "]"  << endl;
      if ( globalHeader == 0xb0 )
      { 
        FILE_LOG(logINFO) << "skip event " << debugEventId <<   "\t\t\t\t   \r" << flush;

        debugEventId++;
      }
    }
  
   FILE_LOG(logINFO) <<  debugEventId++ << " event(s)  skipped "  << endl;
   nbBufferedData = 1;
   bufferedData = 0xb0;
  }


  // loops until a non-empty event has been found
        bool eventFound = false;
        while (! eventFound)
                {
      eventFound = MicrorocMergeReader::decodeData(event);
      if (fileError == EOF) 
      {
        FILE_LOG(logDEBUG) << "  END OF DATA FILE" << endl;
        reset();
        return(LAST_FILE_EVENT);
      }
          }

  if ( event.getChannelHitSize() > 0 )
  {
    event.setId(++lastEventId);
    return EVENT_CORRECT;
  }
  else
  {
    return EVENT_ERROR;
  }
}

//-------------------------------------------------------------------
unsigned int MicrorocLabviewReader::getSpecificData(const unsigned int nBytes)
{
  if (nbBufferedData != 0 )
  {
    if ( nbBufferedData > 1 ) { FILE_LOG(logERROR) << "  could only buffed 1 byte" << endl; exit(1); }
    nbBufferedData = 0;
    return  bufferedData;
  }

  else
  {
    return DifReader::getData(nBytes);
  }
}

---