#include <RawDataEvtHeaderCnv.h>

Inheritance diagram for RawDataEvtHeaderCnv:

Public Member Functions
StatusCode	initialize ()

virtual long	repSvcType () const

StatusCode	createObj (IOpaqueAddress pAddr, DataObject &pObj)

virtual StatusCode	updateObj (IOpaqueAddress , DataObject )
	override the RawDataBaseCnv version

Public Member Functions inherited from RawDataBaseCnv
	RawDataBaseCnv (ISvcLocator *svc)

	RawDataBaseCnv (unsigned char storageType, const CLID &clid, ISvcLocator *svc)

virtual	~RawDataBaseCnv ()

virtual long	repSvcType () const

StatusCode	initialize ()

virtual StatusCode	finalize ()

void	declareObject (const std::string &fullPath, const CLID &clid, const std::string &bank, long par=0)
	Store TDS path to link a particular converter to an object on the TDS.

virtual StatusCode	createRep (DataObject pObject, IOpaqueAddress &refpAddress)
	Convert the transient object to the requested representation.

virtual StatusCode	fillRepRefs (IOpaqueAddress pAddress, DataObject pObject)
	Resolve the references of the converted object.

virtual StatusCode	updateRep (IOpaqueAddress pAddress, DataObject pObject)
	Update the converted representation of a transient object.

virtual StatusCode	updateRepRefs (IOpaqueAddress pAddress, DataObject pObject)
	Update the references of an already converted object.

Public Member Functions inherited from Converter< Ty1, Ty2 >
destination *	operator (const source &) const

Static Public Member Functions
static const CLID &	classID ()

static const unsigned char	storageType ()

Static Public Member Functions inherited from RawDataBaseCnv
static const long	storageType ()

static const CLID &	classID ()

Protected Member Functions
	RawDataEvtHeaderCnv (ISvcLocator *svc)

Protected Member Functions inherited from Converter< Ty1, Ty2 >
virtual destination *	convert (const source &) const =0

Friends
class	CnvFactory< RawDataEvtHeaderCnv >

Additional Inherited Members
Public Types inherited from Converter< Ty1, Ty2 >
typedef Ty1	source

typedef Ty2	destination

Protected Attributes inherited from RawDataBaseCnv
IRawDataCnvSvc *	m_CnvSvc
	Pointer to event conversion service interface.

std::vector< IRawDataCnvSvc::Leaf >	m_leaves
	Leaf objects giving the locations of the objects in the data store.

Detailed Description

Definition at line 17 of file RawDataEvtHeaderCnv.h.

Constructor & Destructor Documentation

◆ RawDataEvtHeaderCnv()

RawDataEvtHeaderCnv::RawDataEvtHeaderCnv ( ISvcLocator * svc )

protected

Definition at line 19 of file RawDataEvtHeaderCnv.cxx.

                                                         :
  RawDataBaseCnv(PACKEDRAWEVENT_StorageType, classID(), svc)
{
  // for Mutil-thread by tianhl
  //init();
  // for Mutil-thread by tianhl
}

Member Function Documentation

◆ classID()

const CLID & RawDataEvtHeaderCnv::classID ( )

static

Definition at line 79 of file RawDataEvtHeaderCnv.cxx.

{
  return CLID_EventHeader;
}

Referenced by PackedRawDataCnvSvc::addConverters().

◆ createObj()

StatusCode RawDataEvtHeaderCnv::createObj	(	IOpaqueAddress *	pAddr,
		DataObject *&	pObj
	)

Definition at line 91 of file RawDataEvtHeaderCnv.cxx.

{
   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);
         //{  // debug
         //    std::cout << "[ETS]:  " << std::hex;
         //    for ( uint32_t i = 0; i < dataLen; ++i ) {
         //        std::cout << " 0x" << std::setw(8) << std::setfill('0') << dataPtr[i];
         //    }
         //    std::cout << std::dec << std::endl;
         //}
         // check
         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);
 
                 //do not revise ets here, move to ResetEtsAlg
                 //_localRevisor->fixHeader(header);
 
                 //if ( header->etsT1() != t1 || header->etsT2() != t2 )
                 //{
                 //    std::cout << "event " << header->eventNumber()
                 //              << "  time " << header->time()
                 //              << "  new t1 " << header->etsT1()
                 //              << "  old t1 " << t1
                 //              << "  new t2 " << header->etsT2()
                 //              << "  old t2 " << t2
                 //              << std::endl;
                 //}
             }
         }
     }
     
   return StatusCode::SUCCESS;
   //}
   //else {
   //  return StatusCode::FAILURE;
   //}
 
}

◆ initialize()

StatusCode RawDataEvtHeaderCnv::initialize ( )

Definition at line 27 of file RawDataEvtHeaderCnv.cxx.

{
  StatusCode sc = RawDataBaseCnv::initialize();
  if ( sc.isFailure() ) return sc;
 
  std::string PackedRawDataCnvSvc_Name("PackedRawDataCnvSvc");
  std::string RawDataInputSvc_Name("RawDataInputSvc");
  std::string RawDataEvtHeaderCnv_Name("RawDataEvtHeaderCnv");
  
  // for Mutil-thread by tianhl
  //ConversionSvc*  pCnvSvc = 0;
  //if (pCnvSvc = dynamic_cast<ConversionSvc*>(conversionSvc())){
  SmartIF<IService> pCnvSvc(conversionSvc());  
  if  (isGaudiThreaded(pCnvSvc->name())){
      PackedRawDataCnvSvc_Name += getGaudiThreadIDfromName(pCnvSvc->name());
      RawDataInputSvc_Name += getGaudiThreadIDfromName(pCnvSvc->name());
      RawDataEvtHeaderCnv_Name += getGaudiThreadIDfromName(pCnvSvc->name());
    }
  //}
  // for Mutil-thread by tianhl
  MsgStream log(messageService(), RawDataEvtHeaderCnv_Name.c_str());
 
  IService* svc = 0;
  sc = serviceLocator()->service(PackedRawDataCnvSvc_Name.c_str(), svc);
  if ( sc.isFailure() ) {
    log << MSG::ERROR << "Can't get RawDataAccess interface" << endreq;
    return StatusCode::FAILURE;
  }
 
  m_RawDataAccess = dynamic_cast<PackedRawDataCnvSvc*> (svc);
  if (m_RawDataAccess  == 0 ) {
    log << MSG::ERROR << "RawDataEvtHeaderCnv: Cant cast to RawDataCnvSvc" << endreq;
    return StatusCode::FAILURE;
  }
 
  sc = serviceLocator()->getService(RawDataInputSvc_Name.c_str(), svc);
  if ( sc.isFailure() ) {
    log << MSG::WARNING << "Cant get RawDataInputSvc " << endreq;
    return sc ;
  }
 
  m_inputSvc = dynamic_cast<RawDataInputSvc*> (svc);
  if ( m_inputSvc == 0 ) {
    log << MSG::ERROR << "Cant cast to RawDataInputSvc" << endreq;
    return StatusCode::FAILURE ;
  }
 
  _localRevisor = dynamic_cast<RawDataInputSvc*>(m_inputSvc)->offlineRevisor();
 
  return StatusCode::SUCCESS;
}

◆ repSvcType()

virtual long RawDataEvtHeaderCnv::repSvcType ( ) const

inlinevirtual

Reimplemented from RawDataBaseCnv.

Definition at line 32 of file RawDataEvtHeaderCnv.h.

                                   {
     return PACKEDRAWEVENT_StorageType;
   }

◆ storageType()

static const unsigned char RawDataEvtHeaderCnv::storageType ( )

inlinestatic

Definition at line 36 of file RawDataEvtHeaderCnv.h.

                                            {
     return PACKEDRAWEVENT_StorageType;
   }

◆ updateObj()

StatusCode RawDataEvtHeaderCnv::updateObj	(	IOpaqueAddress *	pAddr,
		DataObject *	pObj
	)

virtual

override the RawDataBaseCnv version

Definition at line 84 of file RawDataEvtHeaderCnv.cxx.

                                                                                 {
  //MsgStream log(msgSvc(), "RawDataEvtHeaderCnv");
  //log << MSG::DEBUG << "RawDataEvtHeaderCnv::updateObj" << endreq;
  return Converter::updateObj(pAddr, pObj);
}

Friends And Related Function Documentation

◆ CnvFactory< RawDataEvtHeaderCnv >

friend class CnvFactory< RawDataEvtHeaderCnv >

friend

Definition at line 1 of file RawDataEvtHeaderCnv.h.

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

Public Member Functions

Static Public Member Functions

Protected Member Functions

Friends

Additional Inherited Members