DataHeaderCnv_p6 Class Reference

This class provides the converter to customize the saving of DataHeader_p6. More...

#include <DataHeaderCnv_p6.h>

Collaboration diagram for DataHeaderCnv_p6:

Public Member Functions
	DataHeaderCnv_p6 ()
DataHeader *	createTransient (const DataHeader_p6 *persObj, const DataHeaderForm_p6 &form, const Token *dhToken) const
DataHeader_p6 *	createPersistent (const DataHeader *transObj, DataHeaderForm_p6 &form) const
void	elemToPers (const DataHeaderElement *trans, DataHeader_p6 *pers, DataHeaderForm_p6 &form) const
	convert single DH element to persistent represenation More...
bool	persToElem (const DataHeader_p6 *pers, unsigned p_idx, DataHeaderElement *trans, const DataHeaderForm_p6 &form, bool sameForm) const
	restore single DH element from persistent represenation return false if p_idx is out of bounds for the Form More...
void	insertDHRef (DataHeader_p6 *pers_dh, const std::string &key, const std::string &dh_tokstr, DataHeaderForm_p6 &dh_form) const
	insert DH self reference as one of the DHElements. Contains the stream Key More...
void	setSGAliasFiltering (bool doFiltering)

Public Attributes
bool	m_SGAliasFiltering { true }

Private Attributes
Athena::RecyclableDataQueue< DataHeader > m_dhQueue	ATLAS_THREAD_SAFE

Detailed Description

This class provides the converter to customize the saving of DataHeader_p6.

Definition at line 25 of file DataHeaderCnv_p6.h.

Constructor & Destructor Documentation

DataHeaderCnv_p6()

DataHeaderCnv_p6::DataHeaderCnv_p6 ( )

inline

Definition at line 27 of file DataHeaderCnv_p6.h.

{}

Member Function Documentation

createPersistent()

DataHeader_p6 * DataHeaderCnv_p6::createPersistent	(	const DataHeader *	transObj,
		DataHeaderForm_p6 &	form
	)		const

Definition at line 154 of file DataHeaderCnv_p6.cxx.

{
   DataHeader_p6* pers = new DataHeader_p6();
   const unsigned int provSize = trans->m_inputDataHeader.size();
   pers->m_provenanceSize = provSize;
 
   pers->m_shortElements.reserve( provSize + trans->m_dataHeader.size() );
   form.resize(provSize + trans->m_dataHeader.size() + 1);
   for( const auto& transElem: trans->m_dataHeader ) {
      elemToPers( &transElem, pers, form );
   }
   for( const auto& transElem: trans->m_inputDataHeader ) {
      elemToPers( &transElem, pers, form );
   }
   return pers;
}

createTransient()

DataHeader * DataHeaderCnv_p6::createTransient	(	const DataHeader_p6 *	persObj,
		const DataHeaderForm_p6 &	form,
		const Token *	dhToken
	)		const

Definition at line 64 of file DataHeaderCnv_p6.cxx.

{
   DataHeader* trans = m_dhQueue.get();
   const unsigned int provSize = pers->m_provenanceSize;
   // DataHeaders with a self Reference at the end have the list longer by 1 element
   int selfRefSizeCorrection = (form.version() ==  DataHeaderForm_p6::DHverFormRef? 1 : 0);
   size_t nelts = pers->m_shortElements.size() - provSize;
   bool sameForm = false;
   if (!pers->dhFormToken().empty() &&
       pers->dhFormToken() == trans->dhFormToken() &&
       trans->m_inputDataHeader.size() == provSize &&
       trans->m_dataHeader.size() == nelts)
   {
     sameForm = true;
   }
   else {
     trans->setDhFormToken (pers->dhFormToken());
     trans->m_inputDataHeader.resize(provSize);
     trans->m_dataHeader.resize( nelts );
   }
 
   // convert all elements - transient vectors need to have the right sizes
   unsigned i = 0;
   for( auto& elem : trans->m_dataHeader ) {
      persToElem( pers, i++, &elem, form, sameForm );
      // Last entry is the self-reference, which is handled below.
      if (i == nelts - selfRefSizeCorrection) break;
   }
   for( auto& elem : trans->m_inputDataHeader ) {
      persToElem( pers, i++, &elem, form, sameForm );
   }
   // Add the self reference
   if (selfRefSizeCorrection > 0) {
     auto& elem = trans->m_dataHeader.back();
     // convert the self ref that was stored at the end of the element list
     persToElem( pers, i++, &elem, form, sameForm );
 
     if( elem.getToken()->contID().find("DataHeader") == std::string::npos ) {
       // discard wrong element
       trans->m_dataHeader.pop_back();
     }
   }
   trans->setStatus(DataHeader::Input);
   trans->setEvtRefTokenStr( dhToken->toString() );
   return trans;
}

elemToPers()

void DataHeaderCnv_p6::elemToPers	(	const DataHeaderElement *	trans,
		DataHeader_p6 *	pers,
		DataHeaderForm_p6 &	form
	)		const

convert single DH element to persistent represenation

Definition at line 115 of file DataHeaderCnv_p6.cxx.

{
   // Translate PoolToken
   const Token *token =  trans->getToken();
   if( !token ) {
      // store marker for NO Token
      pers->m_shortElements.push_back( INT32_MIN );
   } else {
      // Database GUID & Technology
      DataHeaderForm_p6::DbRecord  db_rec( token->dbID(), token->technology() );
      unsigned db_idx = form.insertDb( db_rec );
      // StoreGate Type/Key & persistent Class GUID
      DataHeaderForm_p6::ObjRecord transObj( token->classID(), token->contID(), trans->m_key,
                                             trans->m_pClid, token->oid().first );
      unsigned obj_idx = form.insertObj(transObj, trans->m_alias, m_SGAliasFiltering,
                                        trans->m_clids, trans->m_hashes);
      unsigned long long oid2 = token->oid().second;
 
      // first element sets the common DB
      if( pers->m_shortElements.empty() ) {
         // first element - set the common DB and OID2 values
         pers->m_commonDbIndex = db_idx;
         pers->m_commonOID2 = oid2;
      }
      if( db_idx == pers->m_commonDbIndex && oid2 == pers->m_commonOID2 ) {
         // Can use short DH element
         pers->m_shortElements.push_back( obj_idx );
      } else {
         // need to use full DH element
         // store the index (as negative) to the full element in the short vector
         pers->m_shortElements.push_back( -1 - pers->m_fullElements.size() );
         pers->m_fullElements.push_back( FullElement(oid2, db_idx, obj_idx) );
      }
   }
}

insertDHRef()

void DataHeaderCnv_p6::insertDHRef	(	DataHeader_p6 *	pers_dh,
		const std::string &	key,
		const std::string &	dh_tokstr,
		DataHeaderForm_p6 &	dh_form
	)		const

insert DH self reference as one of the DHElements. Contains the stream Key

Definition at line 172 of file DataHeaderCnv_p6.cxx.

{
   Token token;
   token.fromString( tokstr );
   DataHeaderElement tEle(ClassID_traits<DataHeader>::ID(), key, std::move(token));
   elemToPers( &tEle, pers, form );
}

persToElem()

bool DataHeaderCnv_p6::persToElem	(	const DataHeader_p6 *	pers,
		unsigned	p_idx,
		DataHeaderElement *	trans,
		const DataHeaderForm_p6 &	form,
		bool	sameForm
	)		const

restore single DH element from persistent represenation return false if p_idx is out of bounds for the Form

Definition at line 18 of file DataHeaderCnv_p6.cxx.

{
   int obj_idx = pers->m_shortElements[p_idx];
   if( obj_idx == INT32_MIN ) return true;
 
   Token& token = trans->m_token;
   unsigned db_idx = 0;
   unsigned long long oid2 = 0;
   if( obj_idx >= 0 ) {
      db_idx = pers->m_commonDbIndex;
      oid2   = pers->m_commonOID2;
   } else {
      const FullElement &full_el = pers->m_fullElements[ -1 - obj_idx ];
      db_idx = full_el.dbIdx;
      obj_idx = full_el.objIdx;
      oid2 = full_el.oid2;
   }
 
   if( form.sizeDb() > db_idx ) {
      // Append DbGuid
      token.setDb(         form.getDbGuid( db_idx ) );
      token.setTechnology( form.getDbTech( db_idx ) );
   }
   if( form.sizeObj() > (size_t)obj_idx ) {
      token.setOid( Token::OID_t( form.getObjOid1(obj_idx), oid2) );
 
      if (!sameForm) {
         // If the form hasn't changed, these should all be the same ---
         // so don't need to copy them again.
         token.setCont(       form.getObjContainer( obj_idx ) );
         // Append ClassId
         token.setClassID(    form.getObjClassId(obj_idx) );
         // StoreGate
         trans->m_key = form.getObjKey( obj_idx );
         trans->m_alias = form.getObjAlias( obj_idx );
         trans->m_pClid = form.getObjType( obj_idx );
         trans->m_clids = form.getObjSymLinks( obj_idx );
         trans->m_hashes = form.getObjHashes( obj_idx );
      }
   }
   return form.sizeDb() > db_idx and form.sizeObj() > (size_t)obj_idx;
}

setSGAliasFiltering()

void DataHeaderCnv_p6::setSGAliasFiltering ( bool  doFiltering )

inline

Definition at line 45 of file DataHeaderCnv_p6.h.

{ m_SGAliasFiltering = doFiltering; }

Member Data Documentation

ATLAS_THREAD_SAFE

Athena::RecyclableDataQueue<DataHeader> m_dhQueue DataHeaderCnv_p6::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 50 of file DataHeaderCnv_p6.h.

m_SGAliasFiltering

bool DataHeaderCnv_p6::m_SGAliasFiltering { true }

Definition at line 47 of file DataHeaderCnv_p6.h.

---

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

• DataHeaderCnv_p6.h
• DataHeaderCnv_p6.cxx