In This Package:

RawDataInputSvc.h

Go to the documentation of this file.

#ifndef RAWDATAINPUTSVC_H
#define RAWDATAINPUTSVC_H

// STL includes
#include <vector>

// Gaudi includes
#include "GaudiKernel/Service.h"

// local includes
#include "RawDataEvent.h"
#include "RawDataIO/IRawDataInputSvc.h"

// InputStream to work with .data and .rraw
#include "RawData/IInputStream.h"
#include "RawData/RawDataReader.h"
#include "RawData/RawData.h"

class RawDataInputSvc: public Service,
         virtual public IRawDataInputSvc
{
public:
   RawDataInputSvc(const std::string& name, ISvcLocator* svcloc);
   ~RawDataInputSvc();

   //Service interface
   virtual StatusCode queryInterface(const InterfaceID& riid, void** ppRaw);
   virtual StatusCode initialize();
   virtual StatusCode finalize();

   virtual RawDataEvent*  currentEvent();
   virtual StatusCode     nextEvent();

private:
   StatusCode nextInputFile();

   uint32_t nextRecord();

   void setBuffer(uint32_t size) {
      if (m_buffer != 0) delete[] m_buffer;
      m_buffer = new char[size];
      m_bufferSize = size;
   }

   void readRawEventBuffer();
   int readRomData(RawDataEvent::RomFee* rom, int& offset, const int& romDataSize);
   int readRomData(RawDataEvent::RomFadc* rom, int& offset, const int& romDataSize);
   int readRomData(RawDataEvent::RomLtb* rom, int& offset, const int& romDataSize);
   int readRomDataUTC(RawDataEvent::RomLtb* rom, int& offset, const int& romDataSize);
   int readRomDataUnix(RawDataEvent::RomLtb* rom, int& offset, const int& romDataSize);

   void printEvent();

   int  queryRawFileFromDB();

   std::vector<std::string> m_inputFiles;
   IInputStream*            m_inputStream;
   RawDataEvent*            m_rawDataEvent;

   int m_bufferSize;
   char* m_buffer;
   int m_printFreq;
   bool m_isFileHeaderPrinted;
   bool m_includeRawEvent;
   bool m_ifRawEventHeader;

   int m_samplingInterval;  //average sampling interval
   int m_randomEvtNum;
  
   int   m_SeqNo;
   bool  m_IsDBI;


public:
   DayaBay::RawEvent*  currentRawEvent();
   DayaBay::RawEvent*  currentRawEventClone();

private:
   DayaBay::RawDataReader* m_reader;
   DayaBay::RawEvent*      m_rawEvent;
   DayaBay::RawEvent*      m_rawEventClone;

};

#endif

---