RawDataEvtHeaderCnv.hpp

Go to the documentation of this file.

#pragma once
 
#include "RawDataCnv/EventManagement/RAWEVENT.h"
#include "RawDataCnv/OfflineRevise.h"
#include "RawDataCnv/RawDataAddress.h"
 
#include "RawDataBaseCnv.h"
 
extern const CLID&    CLID_EventHeader;
static OfflineRevise* _localRevisor   = nullptr;
static int            _localTimeRound = 0;
 
class RawDataEvtHeaderCnv : public RawDataBaseCnv {
public:
  RawDataEvtHeaderCnv( ISvcLocator* svc ) : RawDataBaseCnv( svc, classID() ) {}
 
  StatusCode initialize() {
    MsgStream log( msgSvc(), "RawDataEvtHeaderCnv" );
    log << MSG::INFO << "RawDataEvtHeaderCnv::initialize" << endmsg;
 
    StatusCode sc = RawDataBaseCnv::initialize();
    if ( sc.isFailure() )
    {
      log << MSG::ERROR << "Failed to initialize Converter" << endmsg;
      return sc;
    }
 
    _localRevisor = m_inputSvc->offlineRevisor();
 
    return StatusCode::SUCCESS;
  }
 
  static const CLID& classID() { return CLID_EventHeader; }
 
  StatusCode createObj( IOpaqueAddress* pAddr, DataObject*& pObj ) {
    StatusCode      sc;
    RawDataAddress* pEFAddr;
    const RAWEVENT* evt;
 
    Event::EventHeader* header = new Event::EventHeader();
    pObj                       = header;
 
    // if ( (pEFAddr = dynamic_cast<RawDataAddress*>(pAddr)) ) {
    evt = m_inputSvc->currentEvent();
 
    if ( evt == NULL ) return StatusCode::FAILURE;
 
    header->setEventNumber( evt->eventHeader().event_number() );
    header->setRunNumber( evt->eventHeader().run_number() );
    header->setTime( evt->eventHeader().time() );
    header->setFlag1( evt->eventHeader().flag1() );
    // header->setFlag2( evt->eventHeader().flag2() );
 
    const BufferHolder& rBuf = evt->getEtsBuf();
    if ( rBuf.nBuf() == 1 )
    { // this event has ETS data
      uint32_t  dataLen = rBuf.bufSize( 0 );
      uint32_t* dataPtr = rBuf( 0 );
 
      if ( dataLen > 11 && dataPtr[1] == 0xffffffff )
      {
        uint32_t start = 10;
        if ( ( dataPtr[start] >> 24 ) == 0xcf )
        {
          _localTimeRound = _localRevisor->timeRound( header->runNumber() );
 
          unsigned long t1 = calEts( dataPtr + start );
          header->setEtsT1( t1 );
 
          static unsigned long t2 = 0;
          if ( ( start + 3 ) < dataLen && dataPtr[start + 2] != 0xf0f0f0f0 )
          {
            if ( ( dataPtr[start + 2] >> 24 ) == 0xd1 ) { t2 = calEts( dataPtr + start + 2 ); }
            else
            {
              uint32_t      _dataT2[2] = { dataPtr[10], dataPtr[12] };
              unsigned long _t2        = calEts( _dataT2 );
              if ( labs( _t2 - t2 ) < 150 /*ms*/ * 2000 ) { t2 = _t2; }
              else if ( labs( _t2 - 2000000 - t2 ) < 150 * 2000 ) { t2 = _t2 - 2000000; }
              else if ( labs( _t2 + 2000000 - t2 ) < 150 * 2000 ) { t2 = _t2 + 2000000; }
            }
          }
          header->setEtsT2( t2 );
        }
      }
    }
 
    return StatusCode::SUCCESS;
    //}
  }
 
  unsigned long calEts( uint32_t* dptr ) {
    unsigned int  tmp = dptr[0] & 0xffffff;
    unsigned long val = ( tmp >> 16 ) * _localTimeRound * _localTimeRound;
    val += ( ( tmp >> 8 ) & 0xff ) * _localTimeRound;
    val += tmp & 0xff;
    val *= 2000000; // s -> 500ns
    val += ( dptr[1] & 0x3fffff );
    return val;
  }
};