ShipTdcSource Class Reference

#include <ShipTdcSource.h>

Inheritance diagram for ShipTdcSource:

Collaboration diagram for ShipTdcSource:

Public Member Functions
	ShipTdcSource ()
	ShipTdcSource (TString filename)
	ShipTdcSource (const ShipTdcSource &source)
virtual	~ShipTdcSource ()
virtual Bool_t	Init ()
virtual Int_t	ReadEvent (UInt_t=0)
virtual void	Close ()
void	FillEventHeader (FairEventHeader *feh)
void	AddUnpacker (uint16_t partitionId, FairUnpack *unpacker)

Protected Member Functions
Bool_t	Unpack (Int_t *data, Int_t size, uint16_t partitionId)
Int_t	UnpackEventFrame (Int_t *data, Int_t total_size)

Protected Attributes
TFile *	fIn
unsigned char	buffer [UINT16_MAX]
Double_t	fEventTime = 0
std::map< uint16_t, FairUnpack * >	fUnpackerMap {}
TString	fFilename

Detailed Description

Definition at line 13 of file ShipTdcSource.h.

Constructor & Destructor Documentation

ShipTdcSource() [1/3]

ShipTdcSource::ShipTdcSource

(

)

Definition at line 8 of file ShipTdcSource.cxx.

: fFilename("tdcdata.bin") {}

ShipTdcSource() [2/3]

ShipTdcSource::ShipTdcSource ( TString  filename )

explicit

Definition at line 10 of file ShipTdcSource.cxx.

: fFilename(std::move(filename)) {}

ShipTdcSource() [3/3]

ShipTdcSource::ShipTdcSource

(

const ShipTdcSource &

source

)

Definition at line 12 of file ShipTdcSource.cxx.

: FairOnlineSource(source) {}

~ShipTdcSource()

ShipTdcSource::~ShipTdcSource ( )

virtualdefault

Member Function Documentation

AddUnpacker()

void ShipTdcSource::AddUnpacker ( uint16_t  partitionId, FairUnpack *  unpacker  )

inline

Definition at line 24 of file ShipTdcSource.h.

   {
      fUnpackerMap[partitionId] = unpacker;
      fUnpackers->Add(unpacker);
   }

Close()

void ShipTdcSource::Close ( )

virtual

Definition at line 22 of file ShipTdcSource.cxx.

{
   LOG(DEBUG) << "Closing file " << fFilename;
   fIn->Close();
}

FillEventHeader()

void ShipTdcSource::FillEventHeader

(

FairEventHeader *

feh

)

Definition at line 106 of file ShipTdcSource.cxx.

{
   // TODO add frame times per partition?, -1 if not present?
   feh->SetEventTime(fEventTime);
   feh->SetRunId(fRunId);
   return;
}

Init()

Bool_t ShipTdcSource::Init ( )

virtual

Definition at line 16 of file ShipTdcSource.cxx.

{
   fIn = TFile::Open(fFilename + "?filetype=raw", "read");
   return kTRUE;
}

ReadEvent()

Int_t ShipTdcSource::ReadEvent ( UInt_t  = 0 )

virtual

Definition at line 51 of file ShipTdcSource.cxx.

{
   auto df = new (buffer) DataFrame();
   if (!fIn->ReadBuffer(reinterpret_cast<char *>(df), sizeof(DataFrame))) {
      size_t size = df->header.size;
      auto frameTime = df->header.frameTime;
      uint16_t partitionId = df->header.partitionId;
      if (!fIn->ReadBuffer(reinterpret_cast<char *>(df->hits), size - sizeof(DataFrame))) {
         switch (frameTime) {
            case SoS: LOG(INFO) << "ShipTdcSource: SoS frame."; return 2;
            case EoS: LOG(INFO) << "ShipTdcSource: EoS frame."; break;
            default: break;
         }
         fEventTime = double(frameTime) * 25;
         if (partitionId == 0x8000) {
            LOG(DEBUG) << "ShipTdcSource: Event builder meta frame.";
            if (fEventTime > 5000000000 && frameTime != EoS && frameTime != SoS) {
               LOG(WARNING) << "Late event:";
               for (int i = 0; i < size; i++) {
                  if (i % 4 == 0) {
                     std::cout << ' ';
                  } else if (i % 16 == 0) {
                     std::cout << '\n';
                  }
                  std::cout << std::hex << +buffer[i] << std::dec;
               }
               std::cout << std::endl;
            }
            return UnpackEventFrame(reinterpret_cast<Int_t *>(&buffer), size);
         }
         LOG(DEBUG) << "ShipTdcSource: PartitionId " << std::hex << partitionId << std::dec;
 
         if (Unpack(reinterpret_cast<Int_t *>(&buffer), size, partitionId)) {
            return (frameTime == EoS) ? 1 : 0;
         }
         LOG(WARNING) << "ShipTdcSource: Failed to Unpack.";
         LOG(WARNING) << "ShipTdcSource: Maybe missing unpacker for PartitionId " << std::hex << partitionId << std::dec;
         return 3;
      }
      LOG(WARNING) << "ShipTdcSource: Failed to read hits.";
      return 2;
   }
   return 1;
}

Unpack()

Bool_t ShipTdcSource::Unpack ( Int_t *  data, Int_t  size, uint16_t  partitionId  )

protected

Definition at line 96 of file ShipTdcSource.cxx.

{
   try {
      return fUnpackerMap.at(partitionId)->DoUnpack(data, size);
   } catch (const std::out_of_range &oor) {
      LOG(WARNING) << "ShipTdcSource: Failed to find suitable unpacker.";
      return kFALSE;
   }
}

UnpackEventFrame()

Int_t ShipTdcSource::UnpackEventFrame ( Int_t *  data, Int_t  total_size  )

protected

Definition at line 28 of file ShipTdcSource.cxx.

{
   auto mf = reinterpret_cast<DataFrame *>(data);
   total_size -= sizeof(DataFrame);
   data = reinterpret_cast<Int_t *>(&(mf->hits));
   auto frameTime = mf->header.frameTime;
   while (total_size > 0) {
      auto df = reinterpret_cast<DataFrame *>(data);
      Int_t size = df->header.size;
      uint16_t partitionId = df->header.partitionId;
      LOG(DEBUG) << "ShipTdcSource: PartitionId " << std::hex << partitionId << std::dec;
      if (!Unpack(data, size, partitionId)) {
         LOG(WARNING) << "ShipTdcSource: Failed to Unpack.";
         LOG(WARNING) << "ShipTdcSource: Maybe missing unpacker for PartitionId " << std::hex << partitionId << std::dec;
         return 3;
      }
      data += size / sizeof(Int_t);
      total_size -= size;
   }
   assert(total_size == 0);
   return (frameTime == EoS) ? 1 : 0;
}

Member Data Documentation

buffer

unsigned char ShipTdcSource::buffer[UINT16_MAX]

protected

Definition at line 34 of file ShipTdcSource.h.

fEventTime

Double_t ShipTdcSource::fEventTime = 0

protected

Definition at line 35 of file ShipTdcSource.h.

fFilename

TString ShipTdcSource::fFilename

protected

Definition at line 38 of file ShipTdcSource.h.

fIn

TFile* ShipTdcSource::fIn

protected

Definition at line 33 of file ShipTdcSource.h.

fUnpackerMap

std::map<uint16_t, FairUnpack *> ShipTdcSource::fUnpackerMap {}

protected

Definition at line 36 of file ShipTdcSource.h.

{};

---

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

• online/ShipTdcSource.h
• online/ShipTdcSource.cxx