#include <AFP_ByteStream2RawCnv.h>

Inheritance diagram for AFP_ByteStream2RawCnv:

Collaboration diagram for AFP_ByteStream2RawCnv:

Public Member Functions
	AFP_ByteStream2RawCnv (const std::string &type, const std::string &name, const IInterface *parent)

virtual	~AFP_ByteStream2RawCnv ()
	Does nothing. More...

virtual StatusCode	initialize ()

virtual StatusCode	finalize ()

StatusCode	fillCollection (const OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment robFrag, AFP_RawContainer rawContainer) const
	Fills rawContainer with collections from ROBFragment. More...

bool	isLinkToF (const unsigned int link) const
	returns true if provided link corresponds to time-of-flight information More...

bool	isLinkSi (const unsigned int link) const
	returns true if provided link corresponds to silicon detector information More...

AFP_SiRawCollection *	getCollectionSi (AFP_RawContainer *container) const
	Adds new silicon collection to AFP_RawContainer. More...

AFP_ToFRawCollection *	getCollectionToF (AFP_RawContainer *container) const
	Adds new time-of-flight collection to AFP_RawContainer. More...

void	setDataHeader (uint32_t the_word, AFP_RawDataCommonHead *dataHead) const
	Sets data header information for given argument based on m_wordReadout. More...

ServiceHandle< StoreGateSvc > &	evtStore ()
	The standard `StoreGateSvc` (event store) Returns (kind of) a pointer to the `StoreGateSvc`. More...

const ServiceHandle< StoreGateSvc > &	evtStore () const
	The standard `StoreGateSvc` (event store) Returns (kind of) a pointer to the `StoreGateSvc`. More...

const ServiceHandle< StoreGateSvc > &	detStore () const
	The standard `StoreGateSvc/DetectorStore` Returns (kind of) a pointer to the `StoreGateSvc`. More...

virtual StatusCode	sysInitialize () override
	Perform system initialization for an algorithm. More...

virtual StatusCode	sysStart () override
	Handle START transition. More...

virtual std::vector< Gaudi::DataHandle * >	inputHandles () const override
	Return this algorithm's input handles. More...

virtual std::vector< Gaudi::DataHandle * >	outputHandles () const override
	Return this algorithm's output handles. More...

Gaudi::Details::PropertyBase &	declareProperty (Gaudi::Property< T > &t)

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, SG::VarHandleKey &hndl, const std::string &doc, const SG::VarHandleKeyType &)
	Declare a new Gaudi property. More...

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, SG::VarHandleBase &hndl, const std::string &doc, const SG::VarHandleType &)
	Declare a new Gaudi property. More...

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, SG::VarHandleKeyArray &hndArr, const std::string &doc, const SG::VarHandleKeyArrayType &)

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, T &property, const std::string &doc, const SG::NotHandleType &)
	Declare a new Gaudi property. More...

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, T &property, const std::string &doc="none")
	Declare a new Gaudi property. More...

void	updateVHKA (Gaudi::Details::PropertyBase &)

MsgStream &	msg () const

MsgStream &	msg (const MSG::Level lvl) const

bool	msgLvl (const MSG::Level lvl) const

Static Public Member Functions
static const InterfaceID &	interfaceID ()

Protected Member Functions
void	renounceArray (SG::VarHandleKeyArray &handlesArray)
	remove all handles from I/O resolution More...

std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void >	renounce (T &h)

void	extraDeps_update_handler (Gaudi::Details::PropertyBase &ExtraDeps)
	Add StoreName to extra input/output deps as needed. More...

Private Types
typedef ServiceHandle< StoreGateSvc >	StoreGateSvc_t

Private Member Functions
Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleKeyType &)
	specialization for handling Gaudi::Property<SG::VarHandleKey> More...

Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleKeyArrayType &)
	specialization for handling Gaudi::Property<SG::VarHandleKeyArray> More...

Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleType &)
	specialization for handling Gaudi::Property<SG::VarHandleBase> More...

Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &t, const SG::NotHandleType &)
	specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray> More...

Private Attributes
ServiceHandle< IROBDataProviderSvc >	m_robDataProvider

ToolHandle< AFP_WordReadOut >	m_wordReadout {this, "AFP_WordReadOut", "AFP_WordReadOut", "Tool that reads word"}

StoreGateSvc_t	m_evtStore
	Pointer to StoreGate (event store by default) More...

StoreGateSvc_t	m_detStore
	Pointer to StoreGate (detector store by default) More...

std::vector< SG::VarHandleKeyArray * >	m_vhka

bool	m_varHandleArraysDeclared

Static Private Attributes
static const uint32_t	s_siNoHitMarker = 15

Detailed Description

Definition at line 27 of file AFP_ByteStream2RawCnv.h.

Member Typedef Documentation

◆ StoreGateSvc_t

typedef ServiceHandle<StoreGateSvc> AthCommonDataStore< AthCommonMsg< AlgTool > >::StoreGateSvc_t

privateinherited

Definition at line 388 of file AthCommonDataStore.h.

Constructor & Destructor Documentation

◆ AFP_ByteStream2RawCnv()

AFP_ByteStream2RawCnv::AFP_ByteStream2RawCnv	(	const std::string &	type,
		const std::string &	name,
		const IInterface *	parent
	)

Definition at line 23 of file AFP_ByteStream2RawCnv.cxx.

   : AthAlgTool(type, name, parent),
     m_robDataProvider("ROBDataProviderSvc", name)
 {
   declareInterface<AFP_ByteStream2RawCnv>(this);
 }

◆ ~AFP_ByteStream2RawCnv()

AFP_ByteStream2RawCnv::~AFP_ByteStream2RawCnv ( )

virtual

Does nothing.

Definition at line 32 of file AFP_ByteStream2RawCnv.cxx.

32 {}

Member Function Documentation

◆ declareGaudiProperty() [1/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< AlgTool > >::declareGaudiProperty	(	Gaudi::Property< T > &	hndl,
		const SG::VarHandleKeyArrayType &
	)

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKeyArray>

Definition at line 170 of file AthCommonDataStore.h.

   {
     return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                        hndl.value(), 
                                                        hndl.documentation());
  
   }

◆ declareGaudiProperty() [2/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< AlgTool > >::declareGaudiProperty	(	Gaudi::Property< T > &	hndl,
		const SG::VarHandleKeyType &
	)

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKey>

Definition at line 156 of file AthCommonDataStore.h.

   {
     return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                        hndl.value(), 
                                                        hndl.documentation());
  
   }

◆ declareGaudiProperty() [3/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< AlgTool > >::declareGaudiProperty	(	Gaudi::Property< T > &	hndl,
		const SG::VarHandleType &
	)

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleBase>

Definition at line 184 of file AthCommonDataStore.h.

   {
     return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                        hndl.value(), 
                                                        hndl.documentation());
   }

◆ declareGaudiProperty() [4/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< AlgTool > >::declareGaudiProperty	(	Gaudi::Property< T > &	t,
		const SG::NotHandleType &
	)

inlineprivateinherited

specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray>

Definition at line 199 of file AthCommonDataStore.h.

   {
     return PBASE::declareProperty(t);
   }

◆ declareProperty() [1/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty	(	const std::string &	name,
		SG::VarHandleBase &	hndl,
		const std::string &	doc,
		const SG::VarHandleType &
	)

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
hndl	Object holding the property value.
doc	Documentation string for the property.

This is the version for types that derive from SG::VarHandleBase. The property value object is put on the input and output lists as appropriate; then we forward to the base class.

Definition at line 245 of file AthCommonDataStore.h.

   {
     this->declare(hndl.vhKey());
     hndl.vhKey().setOwner(this);
  
     return PBASE::declareProperty(name,hndl,doc);
   }

◆ declareProperty() [2/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty	(	const std::string &	name,
		SG::VarHandleKey &	hndl,
		const std::string &	doc,
		const SG::VarHandleKeyType &
	)

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
hndl	Object holding the property value.
doc	Documentation string for the property.

This is the version for types that derive from SG::VarHandleKey. The property value object is put on the input and output lists as appropriate; then we forward to the base class.

Definition at line 221 of file AthCommonDataStore.h.

   {
     this->declare(hndl);
     hndl.setOwner(this);
  
     return PBASE::declareProperty(name,hndl,doc);
   }

◆ declareProperty() [3/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty	(	const std::string &	name,
		SG::VarHandleKeyArray &	hndArr,
		const std::string &	doc,
		const SG::VarHandleKeyArrayType &
	)

inlineinherited

Definition at line 259 of file AthCommonDataStore.h.

   {
  
     // std::ostringstream ost;
     // ost << Algorithm::name() << " VHKA declareProp: " << name 
     //     << " size: " << hndArr.keys().size() 
     //     << " mode: " << hndArr.mode() 
     //     << "  vhka size: " << m_vhka.size()
     //     << "\n";
     // debug() << ost.str() << endmsg;
  
     hndArr.setOwner(this);
     m_vhka.push_back(&hndArr);
  
     Gaudi::Details::PropertyBase* p =  PBASE::declareProperty(name, hndArr, doc);
     if (p != 0) {
       p->declareUpdateHandler(&AthCommonDataStore<PBASE>::updateVHKA, this);
     } else {
       ATH_MSG_ERROR("unable to call declareProperty on VarHandleKeyArray " 
                     << name);
     }
  
     return p;
  
   }

◆ declareProperty() [4/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty	(	const std::string &	name,
		T &	property,
		const std::string &	doc,
		const SG::NotHandleType &
	)

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
property	Object holding the property value.
doc	Documentation string for the property.

This is the generic version, for types that do not derive from SG::VarHandleKey. It just forwards to the base class version of declareProperty.

Definition at line 333 of file AthCommonDataStore.h.

   {
     return PBASE::declareProperty(name, property, doc);
   }

◆ declareProperty() [5/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty	(	const std::string &	name,
		T &	property,
		const std::string &	doc = `"none"`
	)

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
property	Object holding the property value.
doc	Documentation string for the property.

This dispatches to either the generic declareProperty or the one for VarHandle/Key/KeyArray.

Definition at line 352 of file AthCommonDataStore.h.

   {
     typedef typename SG::HandleClassifier<T>::type htype;
     return declareProperty (name, property, doc, htype());
   }

◆ declareProperty() [6/6]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty ( Gaudi::Property< T > & t )

inlineinherited

Definition at line 145 of file AthCommonDataStore.h.

                                                                  {
     typedef typename SG::HandleClassifier<T>::type htype;
     return AthCommonDataStore<PBASE>::declareGaudiProperty(t, htype());
   }

◆ detStore()

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< AlgTool > >::detStore ( ) const

inlineinherited

The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 95 of file AthCommonDataStore.h.

95 { return m_detStore; }

◆ evtStore() [1/2]

ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< AlgTool > >::evtStore ( )

inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 85 of file AthCommonDataStore.h.

85 { return m_evtStore; }

◆ evtStore() [2/2]

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< AlgTool > >::evtStore ( ) const

inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 90 of file AthCommonDataStore.h.

90 { return m_evtStore; }

◆ extraDeps_update_handler()

void AthCommonDataStore< AthCommonMsg< AlgTool > >::extraDeps_update_handler ( Gaudi::Details::PropertyBase & ExtraDeps )

protectedinherited

Add StoreName to extra input/output deps as needed.

use the logic of the VarHandleKey to parse the DataObjID keys supplied via the ExtraInputs and ExtraOuputs Properties to add the StoreName if it's not explicitly given

◆ fillCollection()

StatusCode AFP_ByteStream2RawCnv::fillCollection	(	const OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment *	robFrag,
		AFP_RawContainer *	rawContainer
	)		const

Fills rawContainer with collections from ROBFragment.

Definition at line 69 of file AFP_ByteStream2RawCnv.cxx.

                                                                                                                                             {
   ATH_MSG_DEBUG("AFP_ByteStream2RawCnv::fillColelction rob_source_id: in decimal="<<std::dec<<robFrag->rob_source_id()<<",  in hex=0x"<<std::hex<<robFrag->rob_source_id()<<std::dec);
  
   try {
     robFrag->check();
   } catch (...) {
     ATH_MSG_WARNING("An exception occurred");
     return StatusCode::SUCCESS;
   }
  
   const uint32_t nStat = robFrag->nstatus();
   if (nStat) {
     const uint32_t *it;
     robFrag->status(it);
     if (*it) {
       ATH_MSG_WARNING(" Error in ROB status word: 0x");
       return StatusCode::SUCCESS;
     }
   }
  
   if (!rawContainer) {
     ATH_MSG_WARNING("NULL pointer passed in rawContainer argument.");
     return StatusCode::SUCCESS;
   }
  
   // --- end of check input parameters ---
  
   OFFLINE_FRAGMENTS_NAMESPACE::PointerType vint;
   robFrag->rod_data(vint);
  
   if (robFrag->rod_nstatus() <= 0) {
     ATH_MSG_WARNING("Buffer size <= 0!");
     return StatusCode::SUCCESS;
   }
  
   const eformat::FullEventFragment<const uint32_t*> *event = m_robDataProvider->getEvent(Gaudi::Hive::currentContext());
  
   // this information will be present only in offline reconstruction
   // not be at HLT; however the remaining AFP information will be
   // present both online and offline
   if (event) {
     // set information about event in the RawContainer
     rawContainer->setTimeStamp(event->bc_time_seconds());
     rawContainer->setTimeStampNS(event->bc_time_nanoseconds());
     rawContainer->setBCId(event->bc_id());
     rawContainer->setLumiBlock(event->lumi_block());
     rawContainer->setLvl1Id(event->lvl1_id());
   }
  
  
   // fill container with collections
   AFP_SiRawCollection *collectionSi = nullptr;
   AFP_ToFRawCollection *collectionToF = nullptr;
  
   std::vector<std::vector<uint16_t>> picoTDC1_channels, picoTDC2_channels;
   std::vector<bool> picoTDC_hasTrigger;
   std::vector<int> ToF_links;
  
   const uint32_t size = robFrag->rod_ndata();
   for (unsigned i = 0; i < size; i++) {
     uint32_t the_word=vint[i];
     uint32_t the_link=m_wordReadout->link(the_word);
  
     if (m_wordReadout->isHeader(the_word)) {
       AFP_RawCollectionHead* collectionHead = nullptr;
       if ( isLinkToF (the_link) ) {
         // prepare collection for time-of-flight
         collectionToF = getCollectionToF(//m_wordReadout->link(), robFrag->rob_source_id(), 
                                            rawContainer);
         collectionHead = collectionToF;
         
         std::vector<uint16_t> helper;
         picoTDC1_channels.push_back(helper);
         picoTDC2_channels.push_back(helper);
         picoTDC_hasTrigger.push_back(false);
         ToF_links.push_back(the_link);
       }
       else if ( isLinkSi (the_link) ) {
         // prepare collection for silicon detector
         collectionSi = getCollectionSi(//m_wordReadout->link(), robFrag->rob_source_id(), 
                                          rawContainer);
         collectionHead = collectionSi;
       }
       else {
         ATH_MSG_ERROR("Unidentified value of link="<<the_link<<" for header record.");
         return StatusCode::FAILURE;
       }
  
       if (!collectionHead) {
         ATH_MSG_WARNING("nullptr returned by getCollection(link = "
                         << the_link << ", robID = " << robFrag->rob_source_id() <<")");
         return StatusCode::SUCCESS;
       }
  
       // set head collection informaiton
       collectionHead->setLvl1Id(m_wordReadout->getBits(the_word, 14, 10));
       collectionHead->setLink(the_link);
       collectionHead->setFrontendFlag(m_wordReadout->getBits(the_word, 15, 15));
       collectionHead->setBcId(m_wordReadout->getBits(the_word, 9, 0));
       collectionHead->setRobId(robFrag->rob_source_id());
     }
     else if (m_wordReadout->isData(the_word)) {
       // fill time-of-flight collection
       if ( isLinkToF (the_link) ) {
  
         // check if collection is available
         if ( !collectionToF ) {
           ATH_MSG_WARNING("No ToF collection available to fill data.");
           return StatusCode::SUCCESS;
         }
  
         uint32_t bit23=m_wordReadout->getBits(the_word, 23, 23);
         if(!bit23)
         {
           // HPTDC 2017
           uint32_t bits22_21=m_wordReadout->getBits(the_word, 22, 21);
           if(bits22_21==2)
           {
             // ToF measurement
             AFP_ToFRawData& ToFData = collectionToF->newDataRecord();
             ToFData.setHeader( m_wordReadout->getBits(the_word, 23, 21) );
             ToFData.setEdge( m_wordReadout->getBits(the_word, 20, 20) );
             ToFData.setChannel( m_wordReadout->getBits(the_word, 19, 16) );
             ToFData.setPulseLength( m_wordReadout->getBits(the_word, 15, 10) );
             ToFData.setTime( m_wordReadout->getBits(the_word, 9, 0) );
  
             setDataHeader (the_word, &ToFData);
           }
           else
           {
             ATH_MSG_DEBUG("This is not a ToF measurement, bit23 = "<<bit23<<", bits22_21 "<<bits22_21<<", ignoring word = "<<the_word);
           }
         }
         else
         {
           // picoTDC
           
           uint32_t bits19_22=m_wordReadout->getBits(the_word, 22, 19);
             
           if(bits19_22==0 || bits19_22==1)
           {
             // picoTDC #1 (==0) or picoTDC #2 (==1)
             uint16_t channel=m_wordReadout->getBits(the_word, 18, 13);
               
             // find entry with the same channel number
             auto ToFData_itr=std::find_if( collectionToF->begin(), collectionToF->end(),
                                            [&](const AFP_ToFRawData& entry){return entry.channel()==channel;});
  
             if(ToFData_itr==collectionToF->end())
             {
               // create a new entry if such channel number doesn't exist
               auto& ToFData = collectionToF->newDataRecord();
                   
               ToFData.setHeader( bit23 );
               ToFData.setEdge( 0 );
               ToFData.setChannel( m_wordReadout->getBits(the_word, 18, 13) );
               ToFData.setPulseLength( 0 );
               ToFData.setTime( 0 );
               setDataHeader (the_word, &ToFData);
               
               ToFData_itr = std::prev(collectionToF->end());
             }
               
             if(!bits19_22)
             {
               // picoTDC #1
               if(ToFData_itr->time() !=0 )
               {
                 ATH_MSG_WARNING("trying to set time to "<<m_wordReadout->getBits(the_word, 12, 0)<<", but it is already set to = "<<ToFData_itr->time()<<", will not overwrite");
               }
               else
               {
                 ToFData_itr->setTime( m_wordReadout->getBits(the_word, 12, 0) );
                 picoTDC1_channels.back().push_back(channel);
               }
             }
             else
             {
               // picoTDC #2
               if(ToFData_itr->pulseLength() !=0 )
               {
                 ATH_MSG_WARNING("trying to set pulseLength to "<<m_wordReadout->getBits(the_word, 12, 0)<<", but it is already set to = "<<ToFData_itr->pulseLength()<<", will not overwrite");
               }
               else
               {
                 ToFData_itr->setPulseLength( m_wordReadout->getBits(the_word, 12, 0) );
                 picoTDC2_channels.back().push_back(channel);
               }
             }
           }
           else if(bits19_22==4)
           {              
             // check if there's already some other trigger word
             auto ToFData_itr=std::find_if( collectionToF->begin(), collectionToF->end(),
                                            [&](const AFP_ToFRawData& e){return e.isTrigger();});
             if(ToFData_itr!=collectionToF->end())
             {
               // there shouldn't be any other trigger word
               ATH_MSG_WARNING("already found a trigger word with delayedTrigger = "<<ToFData_itr->delayedTrigger()<<" and triggerPattern = "<<ToFData_itr->triggerPattern()<<", will ignore new word with delayedTrigger = "<<m_wordReadout->getBits(the_word, 18,16)<<" and triggerPattern = "<<m_wordReadout->getBits(the_word, 15, 0));
             }
             else
             {
               // if there isn't any other trigger word, create a new entry
               auto& ToFData = collectionToF->newDataRecord();
             
               ToFData.setHeader( bit23 );
               ToFData.setEdge( 0 );
               ToFData.setTrigger(); // mark this entry as a trigger entry; must be done before setting delayedTrigger or triggerPattern
               ToFData.setDelayedTrigger( m_wordReadout->getBits(the_word, 18,16) );
               ToFData.setTriggerPattern( m_wordReadout->getBits(the_word, 15, 0) );
               picoTDC_hasTrigger.back()=true;
             }
           }
           else
           {
             ATH_MSG_WARNING("unknown pattern in bits 19-22 = "<<bits19_22<<", ignoring word = "<<the_word);
           }
         }
       }
       else if ( isLinkSi (the_link) ) {
         // fill silicon detector collection
  
         // check if collection is available
         if ( !collectionSi ) {
           ATH_MSG_WARNING("No silicon detector collection available to fill data.");
           return StatusCode::SUCCESS;
         }
  
         // check first silicon hit information
         if (m_wordReadout->getBits(the_word, 7, 4) != s_siNoHitMarker) {
           AFP_SiRawData& siData = collectionSi->newDataRecord();
           siData.setColumn (m_wordReadout->getBits(the_word, 23, 17));
           siData.setRow (m_wordReadout->getBits(the_word, 16, 8));
           siData.setTimeOverThreshold (m_wordReadout->getBits(the_word, 7, 4));
           
           setDataHeader (the_word, &siData);
         }
  
         // check second silicon hit information
         if (m_wordReadout->getBits(the_word, 3, 0) != s_siNoHitMarker) {
           AFP_SiRawData& siData = collectionSi->newDataRecord();
           siData.setColumn (m_wordReadout->getBits(the_word, 23, 17));
           siData.setRow (m_wordReadout->getBits(the_word, 16, 8) + 1);
           siData.setTimeOverThreshold (m_wordReadout->getBits(the_word, 3, 0));
  
           setDataHeader (the_word, &siData);
         }
       }
       else {
         ATH_MSG_ERROR("Not recognised value of link="<<the_link<<" for data record.");
         return StatusCode::FAILURE;
       }
  
     } // end is data
   } // end of loop
   
   // in case of picoTDC, check we always have both words
   for(unsigned int i=0;i<picoTDC1_channels.size();++i)
   {
     if(!picoTDC1_channels.at(i).empty() || !picoTDC2_channels.at(i).empty())
     {
       for(auto ch1 : picoTDC1_channels.at(i))
       {
         if(std::find(picoTDC2_channels.at(i).begin(),picoTDC2_channels.at(i).end(),ch1) == picoTDC2_channels.at(i).end())
         {
           ATH_MSG_WARNING("Cannot find channel "<<ch1<<" from picoTDC #1 in picoTDC #2 in ToF collections with link nr. "<<ToF_links.at(i)<<", pulseLength is very probably not set");
         }
       }
       for(auto ch2 : picoTDC2_channels.at(i))
       {
         if(std::find(picoTDC1_channels.at(i).begin(),picoTDC1_channels.at(i).end(),ch2) == picoTDC1_channels.at(i).end())
         {
           ATH_MSG_WARNING("Cannot find channel "<<ch2<<" from picoTDC #2 in picoTDC #1 in ToF collections with link nr. "<<ToF_links.at(i)<<", time is very probably not set");
         }
       }
       
       if(!picoTDC_hasTrigger.at(i))
       {
         ATH_MSG_WARNING("Cannot find trigger word in ToF collections with link nr. "<<ToF_links.at(i));
       }
     }
   }
   
   return StatusCode::SUCCESS;
 }

◆ finalize()

StatusCode AFP_ByteStream2RawCnv::finalize ( )

virtual

Definition at line 63 of file AFP_ByteStream2RawCnv.cxx.

                                            {
   ATH_MSG_DEBUG("AFP_ByteStream2RawCnv: finalizing ");
  
   return StatusCode::SUCCESS;
 }

◆ getCollectionSi()

AFP_SiRawCollection * AFP_ByteStream2RawCnv::getCollectionSi ( AFP_RawContainer * container ) const

Adds new silicon collection to AFP_RawContainer.

It is checked if a silicon collection with given link and robId is already in the container. If it is a warning message is issued and nullptr is returned. If it is not, then it is created and pointer to the new collection is returned.

Definition at line 356 of file AFP_ByteStream2RawCnv.cxx.

                                                                           {
  
   if (!container) {
     ATH_MSG_WARNING("NULL pointer passed in argument: container. NULL pointer returned.");
     return nullptr;
   }
  
   // Code below is commented, because it was impossible to
   // reconstruct several bunch crossings in one event with it. In
   // standard data taking only one bunch crossing is saved and this
   // protection should not be necessary. However in case of big
   // readout problems the code may be needed, that is why it stays
   // commented here.
  
   // for (const AFP_SiRawCollection& collection : container->collectionsSi())
   //   if (collection.link() == link && collection.robId() == robId)
   //     ATH_MSG_WARNING("Silicon collection link="<<link<<" robId="<<robId<<" already in container, although it should not be there. Anyway creating new collection. (Reading several BCX?)");
  
   AFP_SiRawCollection& newCollection = container->newCollectionSi();
   return &newCollection;
 }

◆ getCollectionToF()

AFP_ToFRawCollection * AFP_ByteStream2RawCnv::getCollectionToF ( AFP_RawContainer * container ) const

Adds new time-of-flight collection to AFP_RawContainer.

It is checked if a time-of-flight collection with given link and robId is already in the container. If it is a warning message is issued and nullptr is returned. If it is not, then it is created and pointer to the new collection is returned.

Definition at line 380 of file AFP_ByteStream2RawCnv.cxx.

                                                                            {
  
   if (!container) {
     ATH_MSG_WARNING("NULL pointer passed in argument: container. NULL pointer returned.");
     return nullptr;
   }
   
   // Code below is commented, because it was impossible to
   // reconstruct several bunch crossings in one event with it. In
   // standard data taking only one bunch crossing is saved and this
   // protection should not be necessary. However in case of big
   // readout problems the code may be needed, that is why it stays
   // commented here.
  
   // for (const AFP_ToFRawCollection& collection : container->collectionsToF())
   //   if (collection.link() == link && collection.robId() == robId)
   //     ATH_MSG_WARNING("ToF collection link="<<link<<" robId="<<robId<<" already in container, although it should not be there. Anyway creating new collection (Reading several BCX?)");
  
   AFP_ToFRawCollection& newCollection = container->newCollectionToF();
   return &newCollection;
 }

◆ initialize()

StatusCode AFP_ByteStream2RawCnv::initialize ( )

virtual

Definition at line 34 of file AFP_ByteStream2RawCnv.cxx.

                                              {
   ATH_MSG_INFO("Initializing " << name() << "...");
  
   StatusCode sc = AthAlgTool::initialize();
   ATH_MSG_DEBUG("AFP_ByteStream2RawCnv::initialize");
   if (sc.isFailure()) {
     ATH_MSG_WARNING("Failed to initialize");
     return StatusCode::SUCCESS;
   }
  
   if (m_robDataProvider.retrieve().isFailure()) {
     ATH_MSG_WARNING("Failed to retrieve service " << m_robDataProvider
                     << "...");
     return StatusCode::SUCCESS;
   } else {
     ATH_MSG_DEBUG("Retrieved service " << m_robDataProvider << "...");
   }
  
    if (m_wordReadout.retrieve().isFailure()) {
     ATH_MSG_WARNING("Failed to retrieve service " << m_wordReadout
                     << "...");
     return StatusCode::SUCCESS;
   } else {
     ATH_MSG_DEBUG("Retrieved service " << m_wordReadout << "...");
   }
  
   return StatusCode::SUCCESS;
 }

◆ inputHandles()

virtual std::vector<Gaudi::DataHandle*> AthCommonDataStore< AthCommonMsg< AlgTool > >::inputHandles ( ) const

overridevirtualinherited

Return this algorithm's input handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

◆ interfaceID()

const InterfaceID & AFP_ByteStream2RawCnv::interfaceID ( )

static

Definition at line 18 of file AFP_ByteStream2RawCnv.cxx.

                                                       {
   static const InterfaceID IID_IAFP_ByteStream2RawCnv("AFP_ByteStream2RawCnv", 1, 0);
   return IID_IAFP_ByteStream2RawCnv;
 }

◆ isLinkSi()

bool AFP_ByteStream2RawCnv::isLinkSi ( const unsigned int link ) const

inline

returns true if provided link corresponds to silicon detector information

Definition at line 47 of file AFP_ByteStream2RawCnv.h.

47 {return ( (link <= 3) || ( (link >= 8) && (link <= 11) ) );}

◆ isLinkToF()

bool AFP_ByteStream2RawCnv::isLinkToF ( const unsigned int link ) const

inline

returns true if provided link corresponds to time-of-flight information

Definition at line 44 of file AFP_ByteStream2RawCnv.h.

44 {return ( (link == 12) || (link == 13));}

◆ msg() [1/2]

MsgStream& AthCommonMsg< AlgTool >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                 {
     return this->msgStream();
   }

◆ msg() [2/2]

MsgStream& AthCommonMsg< AlgTool >::msg ( const MSG::Level lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                   {
     return this->msgStream(lvl);
   }

◆ msgLvl()

bool AthCommonMsg< AlgTool >::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                                {
     return this->msgLevel(lvl);
   }

◆ outputHandles()

virtual std::vector<Gaudi::DataHandle*> AthCommonDataStore< AthCommonMsg< AlgTool > >::outputHandles ( ) const

overridevirtualinherited

Return this algorithm's output handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

◆ renounce()

std::enable_if_t<std::is_void_v<std::result_of_t<decltype(&T::renounce)(T)> > && !std::is_base_of_v<SG::VarHandleKeyArray, T> && std::is_base_of_v<Gaudi::DataHandle, T>, void> AthCommonDataStore< AthCommonMsg< AlgTool > >::renounce ( T & h )

inlineprotectedinherited

Definition at line 380 of file AthCommonDataStore.h.

   {
     h.renounce();
     PBASE::renounce (h);
   }

◆ renounceArray()

void AthCommonDataStore< AthCommonMsg< AlgTool > >::renounceArray ( SG::VarHandleKeyArray & handlesArray )

inlineprotectedinherited

remove all handles from I/O resolution

Definition at line 364 of file AthCommonDataStore.h.

                                                           {
     handlesArray.renounce();
   }

◆ setDataHeader()

void AFP_ByteStream2RawCnv::setDataHeader	(	uint32_t	the_word,
		AFP_RawDataCommonHead *	dataHead
	)		const

Sets data header information for given argument based on m_wordReadout.

Definition at line 403 of file AFP_ByteStream2RawCnv.cxx.

 {
   dataHead->setLink (m_wordReadout->link(the_word));
   dataHead->setHitDiscConfig (m_wordReadout->getBits(the_word, 29, 28));
 }

◆ sysInitialize()

virtual StatusCode AthCommonDataStore< AthCommonMsg< AlgTool > >::sysInitialize ( )

overridevirtualinherited

Perform system initialization for an algorithm.

We override this to declare all the elements of handle key arrays at the end of initialization. See comments on updateVHKA.

Reimplemented in DerivationFramework::CfAthAlgTool, AthCheckedComponent< AthAlgTool >, AthCheckedComponent<::AthAlgTool >, and asg::AsgMetadataTool.

◆ sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< AlgTool > >::sysStart ( )

overridevirtualinherited

Handle START transition.

We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.

◆ updateVHKA()

void AthCommonDataStore< AthCommonMsg< AlgTool > >::updateVHKA ( Gaudi::Details::PropertyBase & )

inlineinherited

Definition at line 308 of file AthCommonDataStore.h.

                                                {
     // debug() << "updateVHKA for property " << p.name() << " " << p.toString() 
     //         << "  size: " << m_vhka.size() << endmsg;
     for (auto &a : m_vhka) {
       std::vector<SG::VarHandleKey*> keys = a->keys();
       for (auto k : keys) {
         k->setOwner(this);
       }
     }
   }

Member Data Documentation

◆ m_detStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< AlgTool > >::m_detStore

privateinherited

Pointer to StoreGate (detector store by default)

Definition at line 393 of file AthCommonDataStore.h.

◆ m_evtStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< AlgTool > >::m_evtStore

privateinherited

Pointer to StoreGate (event store by default)

Definition at line 390 of file AthCommonDataStore.h.

◆ m_robDataProvider

ServiceHandle<IROBDataProviderSvc> AFP_ByteStream2RawCnv::m_robDataProvider

private

Definition at line 71 of file AFP_ByteStream2RawCnv.h.

◆ m_varHandleArraysDeclared

bool AthCommonDataStore< AthCommonMsg< AlgTool > >::m_varHandleArraysDeclared

privateinherited

Definition at line 399 of file AthCommonDataStore.h.

◆ m_vhka

std::vector<SG::VarHandleKeyArray*> AthCommonDataStore< AthCommonMsg< AlgTool > >::m_vhka

privateinherited

Definition at line 398 of file AthCommonDataStore.h.

◆ m_wordReadout

ToolHandle<AFP_WordReadOut> AFP_ByteStream2RawCnv::m_wordReadout {this, "AFP_WordReadOut", "AFP_WordReadOut", "Tool that reads word"}

private

Definition at line 73 of file AFP_ByteStream2RawCnv.h.

◆ s_siNoHitMarker

const uint32_t AFP_ByteStream2RawCnv::s_siNoHitMarker = 15

staticprivate

Definition at line 75 of file AFP_ByteStream2RawCnv.h.

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

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Member Typedef Documentation

◆ StoreGateSvc_t

Constructor & Destructor Documentation

◆ AFP_ByteStream2RawCnv()

◆ ~AFP_ByteStream2RawCnv()

Member Function Documentation

◆ declareGaudiProperty() [1/4]

◆ declareGaudiProperty() [2/4]

◆ declareGaudiProperty() [3/4]

◆ declareGaudiProperty() [4/4]

◆ declareProperty() [1/6]

◆ declareProperty() [2/6]

◆ declareProperty() [3/6]

◆ declareProperty() [4/6]

◆ declareProperty() [5/6]

◆ declareProperty() [6/6]

◆ detStore()

◆ evtStore() [1/2]

◆ evtStore() [2/2]

◆ extraDeps_update_handler()

◆ fillCollection()

◆ finalize()

◆ getCollectionSi()

◆ getCollectionToF()

◆ initialize()

◆ inputHandles()

◆ interfaceID()

◆ isLinkSi()

◆ isLinkToF()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ outputHandles()

◆ renounce()

◆ renounceArray()

◆ setDataHeader()

◆ sysInitialize()

◆ sysStart()

◆ updateVHKA()

Member Data Documentation

◆ m_detStore

◆ m_evtStore

◆ m_robDataProvider

◆ m_varHandleArraysDeclared

◆ m_vhka

◆ m_wordReadout

◆ s_siNoHitMarker