Hardroc2XdaqReader Class Reference

#include <Hardroc2XdaqReader.hh>

Inheritance diagram for Hardroc2XdaqReader:

[legend]Collaboration diagram for Hardroc2XdaqReader:

[legend]List of all members.

Public Member Functions
	Hardroc2XdaqReader (Run &aRun, FILE *aFile, ui32 lastEventId)
	~Hardroc2XdaqReader ()
int	getScData ()
int	getNextEvent (Event &eventToFill)
int	getAcqData (Event &event)
Static Public Member Functions
static const char *	type (const int subtype=0)

---

Detailed Description

CLASS DATAREADER //

Definition at line 27 of file Hardroc2XdaqReader.hh.

---

Constructor & Destructor Documentation

Hardroc2XdaqReader::Hardroc2XdaqReader	(	Run &	aRun,
		FILE *	aFile,
		ui32	lastEventId
	)

Definition at line 47 of file Hardroc2XdaqReader.cpp.

                                                                               : Hardroc2Reader(aRun, aFile, lastEventId)
{
  FILE_LOG(logDEBUG1) << "--Hardroc2XdaqReader constructor()"<< endl;
  reset();
}

Hardroc2XdaqReader::~Hardroc2XdaqReader

(

)

Definition at line 54 of file Hardroc2XdaqReader.cpp.

{
  FILE_LOG(logDEBUG1)<< "----Hardroc2XdaqReader destructor"<< endl;
}

---

Member Function Documentation

static const char* Hardroc2XdaqReader::type

(

const int

subtype = 0

)

[inline, static]

Reimplemented from Hardroc2Reader.

Definition at line 31 of file Hardroc2XdaqReader.hh.

Referenced by main().

{ return CROSSDAQHR2; };

int Hardroc2XdaqReader::getScData

(

)

[virtual]

Implements Hardroc2Reader.

Definition at line 61 of file Hardroc2XdaqReader.cpp.

Referenced by getNextEvent().

                                  {
  unsigned int data;
  display(+1);
  FILE_LOG(logDEBUG) << " Slow Control data header B1 found" << endl;

  int trop = 0;
  while ( getData(1) != 0xA1)
  {
      display();
      trop++;
  }
  display();
  FILE_LOG(logDEBUG) <<  "Il y a un  [" << dec << trop << "] bytes depuis B1 0xA1 " << endl;
  data = 0xA1;


  display(-1);
  if (data != 0xA1)
    FILE_LOG(logERROR) << "  parsing file error : Slow control trailer 0xA1 not found [" << hex << data << dec << "]" << endl;

  return(1);
} // Hardroc2XdaqReader.getScData

int Hardroc2XdaqReader::getNextEvent

(

Event &

eventToFill

)

[virtual]

Implements Hardroc2Reader.

Definition at line 286 of file Hardroc2XdaqReader.cpp.

                                                 {
  // Start data reconstruction
  Level(0);

FILE_LOG(logDEBUG) << "DEBUG A1"<< endl;
        ui16 dataFormat = run.getDataFormat();
  if (dataFormat == 0) {
FILE_LOG(logDEBUG) << "DEBUG A2"<< endl;
    // first read of the file
    bcIdDifAbsOrgMap.clear();
    // read file header
    dataFormat = getData(1);
    if (fileError == EOF) {
      FILE_LOG(logERROR) << "parsing file[" << inputFile << "]  - error " << errno << ":" << strerror(errno) << endl;
      reset();
      return(LAST_FILE_EVENT);
    }
    display(+1);
    FILE_LOG(logINFO) << "  HARDROC2 DIF VHDL  data format : " << dataFormat << endl;

    if (dataFormat != 7 ) {
      // unknown format
      FILE_LOG(logERROR) << " HARDROC2 DIF VHDL  data format " << dataFormat << " is not implemented" << endl;
      reset();
      return(LAST_FILE_EVENT);
    }
    run.setDataFormat(dataFormat);


    FILE_LOG(logDEBUG) << run.getDetector() << endl;
    display(-1);
    return NEW_CONFIG;
  }


  // loops until a non-empty event has been found
  for (unsigned int nbHits = 0; !nbHits; ) {

    // look for a global data header and process corresponding data
    unsigned int globalHeader = getData(1);
    if (fileError == EOF) {
      FILE_LOG(logINFO) << "  END OF DATA FILE" << endl;
      reset();
      return(LAST_FILE_EVENT);
    }
FILE_LOG(logDEBUG) << "globalHeader:["<< hex  << globalHeader << "]" << endl;
    if (globalHeader == 0xB1) {
      // slow control data
      getScData();
    }
    else if (globalHeader == 0xB0) {
      // acquisition data
      nbHits = getAcqData(event);
    }
    else {
      display();
      FILE_LOG(logERROR) << "  parsing file error. global header error : " << hex << globalHeader << dec << endl;
    }
  } // for (nbHits)

  return EVENT_CORRECT;
}

int Hardroc2XdaqReader::getAcqData

(

Event &

event

)

[virtual]

Implements Hardroc2Reader.

Definition at line 86 of file Hardroc2XdaqReader.cpp.

Referenced by getNextEvent().

                                               {
  unsigned int nbHits = 0;

  display(+1);

  this->setComputeCrcFlag(true);
  crc->compute(0xB0);


  FILE_LOG(logDEBUG) << " global header B0 found" << endl;

  // reset the data for the block
//  bcId_AbsOrg = -1;
  bcId_Abs = 0; // max. 48 bits
  bcId_Dif = 0;
  // the following data is repeated one time for each Dif which has sent data
  difId = getData(1);
  difTriggerCounter = getData(4);
  acqTriggerCounter = getData(4);  // trigger counter version >= 4
  globalTriggerCounter = getData(4);
  ui64 bcIdHigh = getData(2);
  ui64 bcIdLow = getData(4);
  bcId_Abs = (bcIdHigh << 32) + bcIdLow;
  bcId_Dif = getData(3);

  bcId_AbsOrg = getbcIdAbsOrg(difId, bcId_Abs);
  FILE_LOG(logDEBUG1)   << " bcId_AbsOrg  [" << bcId_AbsOrg << "[" << endl;
  display();

  // the bcTime in milliseconds
  i64 bcTime = ((bcId_Abs - bcId_AbsOrg) * bcPeriod) / 1000;
  // the reading time in milliseconds
  i64 readTime = globalTime + bcTime;

  FILE_LOG(logDEBUG)   << "  START EVENT ------------- time " << readTime << " ms" << endl;
  FILE_LOG(logDEBUG)   << "    bc time               " << bcTime << " ms" << endl;
  FILE_LOG(logDEBUG)   << "    DIF Id                0x" << hex << (int)difId << dec << endl;
  FILE_LOG(logDEBUG)   << "    DIF trigger counter   " << difTriggerCounter << endl;
  FILE_LOG(logDEBUG) << "    ACQ trigger counter   " << acqTriggerCounter << endl;
  FILE_LOG(logDEBUG)   << "    total trigger counter " << globalTriggerCounter << endl;
  FILE_LOG(logDEBUG) << "    absolute bcId         " << bcId_Abs - bcId_AbsOrg << endl;
  // end of global header

  bool difFound = false;
  Detector &detector = run.getDetector();
  { const ChamberMap_t &chambers = detector.getChambers();
    for (ChamberMap_t::const_iterator it = chambers.begin(); it != chambers.end(); ++it) {
      try {
        Chamber& chamber = *(it->second);
        const BoardMap_t& boards = chamber.getBoardsByDifId(difId);
      }
      catch (...) {
        // any error case - try next chamber
        continue;
      }

      // the DIF has been found in a chamber. Process all data and continue
      difFound = true;
      break;
    } // for
    if (!difFound) {
      FILE_LOG(logERROR) << "    No dif found with Id 0x" << hex << difId << dec << endl;
    }
  }

  for (bool finish = false; !finish; ) {
    int delimiter = 0;

    display();
    for (; delimiter != 0xA0 && delimiter != 0xB4; ) {
      // seek for first data frame header (0xB4)
      delimiter = getData(1);
      if (fileError == EOF) {
        delimiter = 0;
        break;
      }
      if (delimiter == 0xA3)
        FILE_LOG(logERROR) << "    frame trailer A3 found -- should not" << endl;
    }
    if (delimiter == 0x00) {
      FILE_LOG(logERROR) << "  end of file -- should not" << endl;
      break;
    }
    if (delimiter == 0xA0) {
      this->setComputeCrcFlag(false);
      unsigned short CRC_check = getData(2);
      FILE_LOG(logDEBUG) << hex << " Compute CRC[" << crc->getCrc() << "]" <<  endl;
      FILE_LOG(logDEBUG) << hex << " Received CRC[" << CRC_check << "]" <<  endl;
      if ( CRC_check != crc->getCrc() )
      {
        FILE_LOG(logERROR)  << " CRC Error for event id " <<  lastEventId
                            <<  " Compute CRC[" << crc->getCrc()
                            << "] Received CRC[" << CRC_check << "]" <<  endl ;
        event.setCrcIsCorrect(false);
        event.setValidFlag(CRC_ERROR);
      }
      display(-1);
      FILE_LOG(logDEBUG) << " global trailer A0 found" << endl;
      break;
    }
    display(+1);
    FILE_LOG(logDEBUG) << "   frame header B4 found" << endl;

    int chipId = -1;
    for (; ; ) {
      chipId = getData(1);
      if (fileError == EOF) {
        finish = true;
        FILE_LOG(logINFO) << "    end of file found -- should not" << endl;
        break;
      }
      if (chipId == 0x00) {
        // dummy null bytes
        continue;
      }
      else if (chipId == 0xA3) {
        display(-1);
        FILE_LOG(logDEBUG) << "   frame trailer A3 found" << endl;
        break;
      }
      else if (chipId == 0xA0) {
        finish = true;
        display(-1);
        FILE_LOG(logERROR) << "    global trailer A0 found -- should not" << endl;
        int CRC_check = getData(1);
        break;
      }
      else if (chipId == 0xC3) {
        display(-1);
        FILE_LOG(logERROR) << "    frame trailer C3 found - error occured during data transfer" << endl;
        break;
      }

      // bcId from hardroc chip is counted as Gray code
      bcId_Hit = grayToBinary(getData(3));
      // event time in milliseconds
      eventTime = readTime + (((bcId_Dif - bcId_Hit) * bcPeriod) / 1000);

      //  skip lines where bcId is < 2 (most of the time, data is corrupted)
      if (bcId_Hit <= 1) {
        FILE_LOG(logDEBUG) << "      skip data (bcIdHit = " << (int)bcId_Hit << ")" << endl;
        SkippedBcId++;

        for (int chNum = 48; chNum >= 0; chNum -= 16) {
          unsigned int data4 = getData(4); // lit 4 bytes => 8 char => 16 canaux
        }
      }
      else {
        // not on first line and bcId OK : get and check data
        if (difFound) {
          FILE_LOG(logDEBUG) << "      chip Id               0x" << hex << (int)chipId << dec << endl;
          FILE_LOG(logDEBUG) << "      bcId Hardroc          " << (int)bcId_Hit << endl;
          FILE_LOG(logDEBUG) << "      event time            " << eventTime << endl;
        }

        // trigger data for 64 channels : 1 bit trigger1, 1 bit trigger0 for each channel from 63 downto 0.
        // this makes 2-bit values which should not give bit 1 without bit 0
        for (int chNum = 48; chNum >= 0; chNum -= 16) {
          unsigned int data4 = getData(4); // lit 4 bytes => 8 char => 16 canaux

          if (difFound) {
            for (int index = 0; index < 16; index++) {
              // sur les 16 canaux, recupere les donnees canal par canal
              int trigger = (data4 >> ((15 - index) * 2)) & 0x03; // 2 bits
              // store new event data if any
              if (trigger) {
                nbHits += newHit(event, detector, trigger, index + chNum, chipId, difId);
              }
            } // for (index)
          }
        } // for (chNum)
      }
      display();
    } // for(;;)

  } // for (;;)
  display(-1);

  if (nbHits) {
    // CREATE EVENT for current Run
    event.setTimeStamp(globalTime + (bcId_AbsOrg * bcPeriod) / 1000);

    event.setId(++lastEventId);
    FILE_LOG(logDEBUG1) << "  STORE EVENT " << lastEventId << ", " << nbHits << " hits" << endl;
  }
  else
    FILE_LOG(logDEBUG) << "  EMPTY EVENT" << endl;


  if (SkippedBcId) {
    FILE_LOG(logWARNING) << "    skipped " << SkippedBcId << " data because of bad bcId" << endl;
    SkippedBcId = 0;
  }

  return(nbHits);
} // Hardroc2XdaqReader.getAcqData

---

The documentation for this class was generated from the following files:

• /data3/calcul/jacquem/working_dir/Micromegas/micromegasFrameWork/include/parser/Hardroc2XdaqReader.hh
• /data3/calcul/jacquem/working_dir/Micromegas/micromegasFrameWork/src/parser/Hardroc2XdaqReader.cpp

---