RawTrcMonitorBlock.cxx

Go to the documentation of this file.

// $Id: RawTrcMonitorBlock.cxx,v 1.4 2005/07/22 19:12:14 rhatcher Exp $
// 
// RawTrcMonitorBlock 
// 
// RawTrcMonitorBlock holds info about the charge injection
//
// Author:  R. Hatcher 2001.08.20
//

#include "RawData/RawTrcMonitorBlock.h"

UInt_t RawTrcMonitorBlock::fgDebugFlags = 0;
enum DDebugTrcMonitorBlock {
  kdbg_ForceHexDump = 0x00000001
};

#include "MessageService/MsgFormat.h"
#include "MessageService/MsgService.h"
CVSID("$Id: RawTrcMonitorBlock.cxx,v 1.4 2005/07/22 19:12:14 rhatcher Exp $");

#include "RawData/RawBlockRegistry.h"
REGISTERRAWBLOCK(RawTrcMonitorBlock,kMdBlockTrcMonitor,0);

ClassImp(RawTrcMonitorBlock)

enum ETrcMonitorBlkPos {
   indx_size      = 0,
   indx_checksum  = 1,
   indx_blockid   = 2,
   indx_run       = 3,
   indx_subrun    = 4,
   indx_runtype   = indx_subrun,
   indx_crateid   = 5,
   indx_timeframe = 6,
   indx_nreports  = 7,
   zzzz_last      = 8
};

static RawTrcMonitorBlock::RawTrcStatusReport dummyTrcStatusReport;

//_____________________________________________________________________________
RawTrcMonitorBlock::RawTrcMonitorBlock()
{
   // Default constructor
}

//_____________________________________________________________________________
RawTrcMonitorBlock::RawTrcMonitorBlock(const Int_t *block)
   : RawDataBlock(block)
{
   //  stored block format is:
   //---------------------
   //  0   # words in block
   //  1   checksum
   //  2   Block Id
   //-----
   //  3   run #
   //  4   {subrun#| run type}
   //  5   crate identifier
   //  6   timeframe #
   //  7   # of Trc status report blocks
   //  ..  { Trc status report sub-blocks }
}

//_____________________________________________________________________________
RawTrcMonitorBlock::~RawTrcMonitorBlock()
{
   // dtor
}

//_____________________________________________________________________________
Int_t RawTrcMonitorBlock::GetRun() const
{
   // get the run number
   if (fSize > indx_run) return fRawBlock[indx_run];
   return -1;
}

//_____________________________________________________________________________
Short_t RawTrcMonitorBlock::GetSubRun() const
{
   // get the subrun number
   if (fSize > indx_subrun) return (fRawBlock[indx_subrun]>>16)&0xffff;
   return -1;
}

//_____________________________________________________________________________
Short_t RawTrcMonitorBlock::GetRunType() const
{
   // get the run type
   if (fSize > indx_runtype) return fRawBlock[indx_runtype]&0xffff;
   return -1;
}

//_____________________________________________________________________________
Int_t RawTrcMonitorBlock::GetCrateId() const
{
   // get the crate id
   if (fSize > indx_crateid) return fRawBlock[indx_crateid];
   return -1;
}

//_____________________________________________________________________________
Int_t RawTrcMonitorBlock::GetTimeFrameNum() const
{
   // get the time frame #
   if (fSize > indx_timeframe) return fRawBlock[indx_timeframe];
   return -1;
}

//_____________________________________________________________________________
Int_t RawTrcMonitorBlock::GetNumTrcStatusReports() const
{
   // get the number of status report sub-blocks

   //if (fSize > indx_nreports) return fRawBlock[indx_nreports];
   //return -1;
  UnpackTrcStatusReports();
  return fTrcStatusReports.size();
}

//_____________________________________________________________________________
const RawTrcMonitorBlock::RawTrcStatusReport& 
RawTrcMonitorBlock::GetTrcStatusReport(UInt_t indx) const
{
   // get the i-th status report sub-block
  size_t nreports = GetNumTrcStatusReports();
  if (indx >= nreports) {
    MSG("Raw",Msg::kWarning)
      << "GetStatusReport() can't get index " << indx
      << " as there are only " << nreports << endl;
    return dummyTrcStatusReport;
  }
  return fTrcStatusReports[indx];
}

//_____________________________________________________________________________
std::ostream& RawTrcMonitorBlock::FormatToOStream(std::ostream& os, 
                                                        Option_t *option) const
{

   if (fgDebugFlags & kdbg_ForceHexDump) option = "x";

   RawDataBlock::FormatToOStream(os,option);
   if (option[0] == 'X') return os;

   // additional block specific formatted output is done here

   os << " Run " << GetRun() 
      << " SubRun " << GetSubRun() 
      << " RunType " << GetRunType() << endl; 
   int crateid = GetCrateId();
   os << " Crate " << (crateid&0x3f)
      << " (0x" << hex << crateid << dec << ") had "
      << GetNumTrcStatusReports() << " reports: " << endl;
   for (int i = 0; i<GetNumTrcStatusReports(); i++) {
     const RawTrcStatusReport status = GetTrcStatusReport(i);
     os << "   report [" << setw(2) << i << "] " 
        << status.timestamp.AsString("c")
        << " swaps=" << int(status.numBufferSwaps)
        << " flags=0x" << hex << setfill('0') << int(status.flags&0xFF)
        << setfill(' ') << dec
        << endl;
   }
   return os;
}

//_____________________________________________________________________________
void RawTrcMonitorBlock::UnpackTrcStatusReports() const
{
   // unpack the Trc status sub-blocks
   if (!fTrcStatusReports.empty()) return;  // early exit if already unpacked

   UInt_t nexpected = 0, nseen = 0;
   if (fSize > indx_nreports) nexpected = fRawBlock[indx_nreports];

   Int_t *report_start = fRawBlock + indx_nreports + 1;
   Int_t *toofar       = fRawBlock + fSize;

   const size_t sizeTrcReportSubBlk = 3;

   while (report_start < toofar) {
     time_t sec    = report_start[0];
     Int_t  ns     = report_start[1];
     Int_t  packed = report_start[2]; 
     // packed is the two char flags and numBufferSwaps + 2 padding chars
     // structure mappings of chars to memory is tricky!
     // for gcc Linux on x86 architecture first char maps to *lowest* byte.
     // but despite documentation (and structure in mdBlockDefinitions.h
     // it appears to be filled via the following) the flags data 
     // appears to be in the top most byte, not the lowest.
     // but that assumes that the structure is filled on the same
     // a platform with the endian-ness and a byte swapping doesn't
     // occur somewhere in the game.
     char flags = (packed>>24) & 0xff;
     char nswap = (packed>>16) & 0xff;

     RawTrcStatusReport report;
     report.timestamp      = VldTimeStamp(sec,ns);
     report.flags          = flags;
     report.numBufferSwaps = nswap;
     fTrcStatusReports.push_back(report);

     ++nseen;
     report_start += sizeTrcReportSubBlk;
   }

   if (nseen != nexpected || report_start != toofar)
     MSG("Raw",Msg::kWarning)
       << "Unpacking reached end in an inconsistent manner"
       << " ptr @ " << report_start << " should be " << toofar
       << " saw " << nseen << " of " << nexpected << " expected"
       << " TrcStatusReports." << endl;

}
//_____________________________________________________________________________

---