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)
DataHeader_p6 *	createPersistent (const DataHeader *transObj, DataHeaderForm_p6 &form)
void	elemToPers (const DataHeaderElement *trans, DataHeader_p6 *pers, DataHeaderForm_p6 &form)
	convert single DH element to persistent represenation More...
bool	persToElem (const DataHeader_p6 *pers, unsigned p_idx, DataHeaderElement *trans, const DataHeaderForm_p6 &form)
	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)
	insert DH self reference as one of the DHElements. Contains the stream Key More...
void	setSGAliasFiltering (bool doFiltering)

Public Attributes
bool	m_SGAliasFiltering { true }

Detailed Description

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

Definition at line 22 of file DataHeaderCnv_p6.h.

Constructor & Destructor Documentation

DataHeaderCnv_p6()

DataHeaderCnv_p6::DataHeaderCnv_p6 ( )

inline

Definition at line 24 of file DataHeaderCnv_p6.h.

{}

Member Function Documentation

createPersistent()

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

Definition at line 136 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
	)

Definition at line 61 of file DataHeaderCnv_p6.cxx.

{
   DataHeader* trans = new DataHeader();
   const unsigned int provSize = pers->m_provenanceSize;
   trans->m_inputDataHeader.resize(provSize);
   // DataHeaders with a self Reference at the end have the list longer by 1 element
   int hasSelfRefSizeCorrection = (form.version() ==  DataHeaderForm_p6::DHverFormRef? 1 : 0);
   trans->m_dataHeader.resize( pers->m_shortElements.size() - hasSelfRefSizeCorrection - provSize );
 
   // 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 );
   }
   for( auto& elem : trans->m_inputDataHeader ) {
      persToElem( pers, i++, &elem, form );
   }
   // Add the self reference
   trans->m_dataHeader.resize( trans->m_dataHeader.size() + 1 );
   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 );
 
   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
	)

convert single DH element to persistent represenation

Definition at line 97 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
	)

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

Definition at line 154 of file DataHeaderCnv_p6.cxx.

{
   Token* token = new Token();
   token->fromString( tokstr );
   DataHeaderElement tEle(ClassID_traits<DataHeader>::ID(), key, token);
   elemToPers( &tEle, pers, form );
}

persToElem()

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

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.

{
   delete trans->m_token;  trans->m_token = nullptr;
   int obj_idx = pers->m_shortElements[p_idx];
   if( obj_idx == INT32_MIN ) return true;
 
   Token* token = new Token;
   trans->m_token = token;
   trans->m_ownToken = true;
   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->setCont(       form.getObjContainer( obj_idx ) );
      // Append ClassId
      token->setClassID(    form.getObjClassId(obj_idx) );
      token->setOid( Token::OID_t( form.getObjOid1(obj_idx), oid2) );
      // 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 41 of file DataHeaderCnv_p6.h.

{ m_SGAliasFiltering = doFiltering; }

Member Data Documentation

m_SGAliasFiltering

bool DataHeaderCnv_p6::m_SGAliasFiltering { true }

Definition at line 43 of file DataHeaderCnv_p6.h.

---

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

• DataHeaderCnv_p6.h
• DataHeaderCnv_p6.cxx