AANTupleStream Class Reference

#include <AANTupleStream.h>

Inheritance diagram for AANTupleStream:

Collaboration diagram for AANTupleStream:

Public Member Functions
	AANTupleStream (const std::string &name, ISvcLocator *pSvcLocator)
	Standard AANTupleStream Constructor.
virtual	~AANTupleStream ()
	Standard Destructor.
virtual StatusCode	initialize () override
	Initialize AANTupleStream.
virtual StatusCode	finalize () override
	Terminate AANTupleStream.
virtual StatusCode	execute () override
	Working entry point.

Private Member Functions
StatusCode	initCollection ()
	Initialize the output collection.
StatusCode	getRef (CLID id, const std::string &key, std::string &ref)
	Get ref from a proxy.
StatusCode	splitAddress (const std::string &address, const std::string &match, std::string &address_header, std::string &address_data) const
	Split the address to get pool token.
void	writeAttributeListSpecification ()
	write schema of AttributeList
void	setupTree ()
	setup Tree
bool	writeTokenAttrList (const std::string &token, const coral::AttributeList &attributeList)
	write Token and AttributeList
StatusCode	getFilters ()
	get filter alogs
bool	isEventAccepted () const
	check filters passed
StatusCode	initSchema ()
virtual StatusCode	io_reinit () override
	callback method to reinitialize the internal state of the component for I/O purposes (e.g.

Private Attributes
ServiceHandle< IAddressCreator >	m_persSvc
	Persistency service.
coral::AttributeListSpecification *	m_attribSpec
	Collection attribute specification.
std::string	m_fileName
	Name of the output collection.
StringArrayProperty	m_extraRefNames
	Vector of extra parent ref names to register in collection.
BooleanProperty	m_writeInputDH
	Flag to signal whether or not to write input data header.
BooleanProperty	m_existDH
	Flag to signal whether data header exists.
std::string	m_streamName
	Name of Stream.
BooleanProperty	m_lateSchema
	write schema in execute()
std::string	m_macro
	macro
bool	m_schemaDone
	first event
std::string	m_treeName
	Name of the output tree.
std::vector< std::string >	m_acceptNames
	Vector of names of Algorithms that this stream accepts.
std::vector< IAlgorithm * >	m_acceptAlgs
	Vector of Algorithms that this stream accepts.
TTree *	m_tree
	TTree.
TBranch *	m_tokenBranch
	TBranch which contains Token info.
ServiceHandle< ITHistSvc >	m_tHistSvc
	THistSvc.
char	m_tokenCString [s_maxLengthOfStrings]

Static Private Attributes
static const unsigned int	s_maxLengthOfStrings = 5000
	for string branches

Detailed Description

Definition at line 33 of file AANTupleStream.h.

Constructor & Destructor Documentation

AANTupleStream()

AANTupleStream::AANTupleStream	(	const std::string &	name,
		ISvcLocator *	pSvcLocator )

Standard AANTupleStream Constructor.

Definition at line 45 of file AANTupleStream.cxx.

  : base_class::base_class(name, pSvcLocator),
    m_persSvc      ("EventPersistencySvc", name),
    m_attribSpec(0),
    m_schemaDone(false),
    m_tree(0),
    m_tokenBranch(0),
    m_tHistSvc     ("THistSvc", name)
{
  declareProperty("OutputName",           m_fileName="AANTuple.root");
  declareProperty("ExtraRefNames",        m_extraRefNames);
  declareProperty("WriteInputDataHeader", m_writeInputDH=false);
  declareProperty("ExistDataHeader",      m_existDH=true);
  declareProperty("StreamName",           m_streamName=c_streamName);
  declareProperty("LateSchemaWriting",    m_lateSchema=false);
  declareProperty("TreeName",             m_treeName=c_treeName);
  declareProperty("Macro",                m_macro="");
  declareProperty("FilterAlgs",           m_acceptNames);
 
  m_tokenCString[0] = '\0';
}

~AANTupleStream()

AANTupleStream::~AANTupleStream ( )

virtual

Standard Destructor.

Definition at line 69 of file AANTupleStream.cxx.

{
}

Member Function Documentation

execute()

StatusCode AANTupleStream::execute ( )

overridevirtual

Working entry point.

Definition at line 167 of file AANTupleStream.cxx.

{
  StatusCode sc;
 
  if (!m_schemaDone) {
    sc = initSchema();
    if (sc.isFailure())
      return sc;
  }
 
  std::map<std::string,std::string> inputRefs;
  std::string ref;
 
  // Get tokens specified by item list
  if (m_existDH)
    {
      // get token
      SG::ConstIterator<DataHeader> beg;
      SG::ConstIterator<DataHeader> ending;
      StatusCode status = evtStore()->retrieve(beg,ending);
      if (status.isFailure() || beg==ending)
    {
      ATH_MSG_WARNING ("No DataHeaders present in StoreGate");
      return  StatusCode::FAILURE;
    }
 
      // look for header
      for (; beg != ending; ++beg)
    if (m_writeInputDH == beg->isInput()) break;
 
      if (beg==ending)
    {
      ATH_MSG_WARNING ("No appropriate DataHeader present in StoreGate");
      return  StatusCode::FAILURE;
    }
 
      // get the ref
      while (getRef(ClassID_traits<DataHeader>::ID(), beg.key(), ref) == StatusCode::FAILURE)
    {
      ++beg;
      if (beg==ending)
        {
          ATH_MSG_ERROR ("No refs found");
          return StatusCode::FAILURE;
        }
    }
 
      ATH_MSG_DEBUG ("Found token: Key=" << beg.key() << ", Ref=" << ref);
 
      // Get a single input header ref if requested
      const DataHeader* hdr = &(*beg);
      if (hdr->sizeProvenance())
    {
      std::vector<DataHeaderElement>::const_iterator it =
        (const_cast<DataHeader*>(hdr)->beginProvenance());
      std::vector<DataHeaderElement>::const_iterator itE = 
        (const_cast<DataHeader*>(hdr)->endProvenance());
      // grab refs for those
      for (; it!=itE; ++it)
        {
          std::string tmpRef = (*it).getToken() != NULL
        ? (*it).getToken()->toString()
        : "";
          inputRefs.insert(std::make_pair(it->getKey(),tmpRef));
          ATH_MSG_DEBUG ("Found ref for input header: Key=" << it->getKey()
                 << ", Ref=" << tmpRef);
        }
    }
    }
  
  // create Attrlist, add attributes and if extra ref is requested, append to the end
 
  ATH_MSG_DEBUG ("create AttributeList");
  // AthenaAttributeList  newAttr(*m_attribSpec);
  coral::AttributeList newAttr(*m_attribSpec);
 
  unsigned int runNumber   = 0;
  unsigned int eventNumber = 0;
 
  // retrieve event info
  const EventInfo* eventInfo;
  eventInfo = evtStore()->tryConstRetrieve<EventInfo>();
  if ( !eventInfo )
    {
      // Try to get the xAOD::EventInfo
      const xAOD::EventInfo* eventInfoX{nullptr};
      ATH_CHECK( evtStore()->retrieve(eventInfoX) );
      runNumber   = eventInfoX->runNumber();
      eventNumber = eventInfoX->eventNumber();
    }
  else
    {
      runNumber   = eventInfo->event_ID()->run_number();
      eventNumber = eventInfo->event_ID()->event_number();
    }
 
  // add global event tag data
  newAttr[ name_RunNumber   ].setValue( runNumber );
  newAttr[ name_EventNumber ].setValue( eventNumber );
 
  // add back nav ref's
  ATH_MSG_DEBUG ("Append extra ref");
  std::vector<std::string> extraRefs = m_extraRefNames.value();
  std::map<std::string,std::string>::iterator itRef  = inputRefs.begin();
  std::map<std::string,std::string>::iterator itRefE = inputRefs.end();
  for (; itRef != itRefE; ++itRef)
    {
      std::string name = itRef->first + "_ref";
      if (extraRefs.end() != std::find(extraRefs.begin(),extraRefs.end(),itRef->first))
    {
      newAttr[name].setValue(std::string(itRef->second));
      ATH_MSG_DEBUG (" Added extra ref to new attribute list - name: " 
             << name << " " << itRef->second);
    }
    }
 
  // write if filters passed
  if (isEventAccepted())
    {
      ATH_MSG_DEBUG ("write attributes to collection");
  
      // write token plus attributes
      try
    {
      writeTokenAttrList(ref, newAttr);
    } 
      catch (std::exception &e)
    {
      ATH_MSG_ERROR 
        ("Caught exception from collection add of Pool attributes. "
         "Message: " << e.what());
      return StatusCode::FAILURE;
    }
    }
  
  ATH_MSG_DEBUG ("done successfully");
 
  return StatusCode::SUCCESS;
}

finalize()

StatusCode AANTupleStream::finalize ( )

overridevirtual

Terminate AANTupleStream.

Definition at line 143 of file AANTupleStream.cxx.

{
  ATH_MSG_INFO ("finalize");
 
  // exec macro
  if (m_macro != "")
    {
      // save current dir
      std::string curDir = gDirectory->GetPath();
      // go to the root dir of output file
      gDirectory->cd((m_fileName+":/").c_str());
      // exec
      // G__exec_tempfile(m_macro.c_str());
      // MN: that should be the equivalent new call:
      gInterpreter->ExecuteMacro(m_macro.c_str());
      // back to the current dir
      gDirectory->cd(curDir.c_str());
    }
 
  return StatusCode::SUCCESS;
}

getFilters()

StatusCode AANTupleStream::getFilters ( )

private

get filter alogs

Definition at line 506 of file AANTupleStream.cxx.

{
  ATH_MSG_DEBUG ("in getFilters()");
  
  // no filter
  if (m_acceptNames.empty())
    return StatusCode::SUCCESS;
 
  ServiceHandle<IAlgManager> theAlgMgr("ApplicationMgr", this->name());
  ATH_CHECK( theAlgMgr.retrieve() );
 
  // loop over all alg names
  for (const std::string& name : m_acceptNames)
    {
      SmartIF<IAlgorithm> ialg{theAlgMgr->algorithm(name)};
      if (!ialg )
    {
      ATH_MSG_ERROR ("Can't get Filter Alg : " << name);
      return StatusCode::FAILURE;
    }
      ATH_MSG_DEBUG (" -> getting Filter Alg success " << name);
      // push back
      m_acceptAlgs.push_back(ialg);
    }
  return StatusCode::SUCCESS;
}

getRef()

StatusCode AANTupleStream::getRef ( CLID id, const std::string & key, std::string & ref )

private

Get ref from a proxy.

Definition at line 362 of file AANTupleStream.cxx.

{
  // Must access the SG proxy to get the IOpaqueAddress
  SG::DataProxy* itemProxy = 0;
  ATH_MSG_DEBUG ("Retrieving proxy for " << id << " " << key);
  itemProxy = evtStore()->proxy(id, key);
  if (!itemProxy)
    {
      ATH_MSG_ERROR ("Could not get proxy ");
      return(StatusCode::FAILURE);
    }
  else
    {
      ATH_MSG_DEBUG (" found proxy for ("<< id << ",\"" << key << "\") ");
    }
  
  if (!itemProxy)
    {
      ATH_MSG_ERROR ("Empty proxy ");
      return(StatusCode::FAILURE);
    }
  
  // Get IOpaqueAddress from the proxy
  IOpaqueAddress* addr = itemProxy->address();
  if (!addr)
    {
      ATH_MSG_DEBUG ("Could not get address for clid "
             << itemProxy->clID() << " " << itemProxy->name());
      return( StatusCode::FAILURE);
    }
 
  // Convert IOpaqueAddress to string via the persistency
  // service. And then remove header to extract the token.
  std::string saddr;
 
  StatusCode sc = m_persSvc->convertAddress(addr, saddr);   
  if (sc.isFailure()) 
    {
      ATH_MSG_ERROR 
    ("Could not get string from IOpaqueAddress for clid " << id
     << " " << key
     << " is BAD_STORAGE_TYPE: "<< (sc == IConversionSvc::Status::BAD_STORAGE_TYPE));
      return( StatusCode::FAILURE);
    }
            
 
  // We assume here some knowledge of the form of the AthenaPool
  // string address
  std::string hdr;
  sc = splitAddress(saddr, " /> ", hdr, ref);
  if (sc.isFailure()) 
    {
      ATH_MSG_ERROR ("Could not get split off token. string address " << saddr);
      return( StatusCode::FAILURE);
    }
  
  ATH_MSG_DEBUG ("String address " << ref);
 
  return StatusCode::SUCCESS;
}

initCollection()

StatusCode AANTupleStream::initCollection ( )

private

Initialize the output collection.

Definition at line 126 of file AANTupleStream.cxx.

{
  // write schema
  writeAttributeListSpecification();
 
  // setup TTree
  setupTree();
 
  // setup Token
  m_tokenBranch = m_tree->GetBranch(c_tokenBranchName);
  m_tokenBranch->SetAddress(m_tokenCString);
 
  return StatusCode::SUCCESS;
}

initialize()

StatusCode AANTupleStream::initialize ( )

overridevirtual

Initialize AANTupleStream.

Definition at line 75 of file AANTupleStream.cxx.

{
  ATH_MSG_DEBUG ("In initialize ");
  // register with the I/O component manager
  {
    ServiceHandle<IIoComponentMgr> iomgr ("IoComponentMgr", this->name());
    ATH_CHECK( iomgr.retrieve() );
    ATH_CHECK( iomgr->io_register (this) );
 
    if ( !iomgr->io_register (this,
                  IIoComponentMgr::IoMode::WRITE,
                  m_fileName).isSuccess() ) {
      ATH_MSG_ERROR ("Could not register [" << this->name() << "]["
             << m_fileName << "] with the I/O component manager !");
      return StatusCode::FAILURE;
    }
  }
 
  // StoreGateSvc
  ATH_CHECK( evtStore().retrieve() );
 
  // set up the persistency service:
  ATH_CHECK( m_persSvc.retrieve() );
 
  // instantiate AttrListSpec and add attributes for Run# and Event# 
  m_attribSpec = new coral::AttributeListSpecification;
  m_attribSpec->extend( name_RunNumber,   "unsigned int" );
  m_attribSpec->extend( name_EventNumber, "unsigned int" );
  const std::string refStr{"_ref"};
  const std::string stringTypeStr{"string"};
  // Add on specification for extra refs
  for (const std::string& ref : m_extraRefNames.value())
    {
      // Append _ref to name of attribute
      m_attribSpec->extend(ref + refStr, stringTypeStr);
    }
 
  if (!m_lateSchema) {
    ATH_CHECK( initSchema() );
  }
 
  // get filters
  ATH_CHECK( getFilters() );
 
  ATH_MSG_DEBUG ("End initialize ");
 
  return StatusCode::SUCCESS;
}

initSchema()

StatusCode AANTupleStream::initSchema ( )

private

dump

Definition at line 558 of file AANTupleStream.cxx.

{
  m_schemaDone = true;
 
  ATH_CHECK( m_tHistSvc.retrieve() );
 
  // initialize output collection
  ATH_CHECK( initCollection() );
 
  // register TTree to THistSvc
  ATH_CHECK( m_tHistSvc->regTree("/"+m_streamName+"/"+m_treeName, m_tree) );

  m_tree->Print();
 
  return StatusCode::SUCCESS;
}

io_reinit()

StatusCode AANTupleStream::io_reinit ( )

overrideprivatevirtual

callback method to reinitialize the internal state of the component for I/O purposes (e.g.

upon fork(2))

Definition at line 577 of file AANTupleStream.cxx.

{
  ServiceHandle<IIoComponentMgr> iomgr ("IoComponentMgr", this->name());
  ATH_CHECK( iomgr.retrieve() );
 
  ServiceHandle<Gaudi::Interfaces::IOptionsSvc> josvc ("JobOptionsSvc", this->name());
  ATH_CHECK( josvc.retrieve() );
 
  // check the I/O manager knows about me
  if ( !iomgr->io_hasitem (this) ) {
    ATH_MSG_ERROR ("I/O component mgr does not know about ourselves !");
    return StatusCode::FAILURE;
  }
 
  // check there is actually something to do...
  if ( !iomgr->io_contains (this, m_fileName) ) {
    ATH_MSG_DEBUG 
      ("I/O component mgr does not have any entry about ["<< m_fileName<<"]");
    return StatusCode::SUCCESS;
  }
 
  if ( !iomgr->io_retrieve (this, m_fileName).isSuccess() ) {
    ATH_MSG_ERROR ("Could not retrieve new name for [" << m_fileName << "] !");
    return StatusCode::FAILURE;
  }
  
  // recreate the proper property value...
  std::vector<std::string> outvec = {"AANT DATAFILE='" + m_fileName + "' OPT='RECREATE'"};
  josvc->set("THistSvc.Output", Gaudi::Utils::toString(outvec));
 
  // handle schema...
  if (!m_schemaDone) {
    if ( !initSchema().isSuccess() ) {
      ATH_MSG_ERROR ("Could not initialize schema !");
    }
  }
 
  return StatusCode::SUCCESS;
}

isEventAccepted()

bool AANTupleStream::isEventAccepted ( ) const

private

check filters passed

Definition at line 538 of file AANTupleStream.cxx.

{
  // no filter
  if (m_acceptAlgs.empty())
    return true;
 
  const EventContext& ctx = Gaudi::Hive::currentContext();
  
  // loop over all algs
  for (const IAlgorithm* alg : m_acceptAlgs)
    {
      if ( alg->execState(ctx).state() == AlgExecState::State::Done &&
             ( ! alg->execState(ctx).filterPassed() ) )
    return false;
    }
 
  return true;
}

setupTree()

void AANTupleStream::setupTree ( )

private

setup Tree

Definition at line 316 of file AANTupleStream.cxx.

{
  static const std::map<std::string,char> typeDict = {
    {"double", 'D'},
    {"long double", 'D'},    // only 64 bit doubles are supported
    {"float", 'F'},
    {"int", 'i'},
    {"unsigned int", 'I'},
    {"long", 'i'},           // support for 64 bit integers introduced with ROOT 4.00/08
    {"unsigned long", 'I'},  // support for 64 bit integers introduced with ROOT 4.00/08
    {"short", 's'},
    {"unsigned short", 'S'},
    {"char", 'b'},           // AttributeLists's "get_root_type_char(...)" returned 'C' ???
    {"unsigned char", 'B'},  // AttributeLists's "get_root_type_char(...)" returned 's' ???
    {"bool", 'B'},           // AttributeLists's "get_root_type_char(...)" returned 'i' ???
    {"string", 'C'},
    {"Token", 'C'}
  };
 
  // go to the root dir of output file
  TDirectory::TContext save;
  gDirectory->cd((m_fileName+":/").c_str());
  
  // instantiate TTree
  m_tree = new TTree(m_treeName.c_str(), m_treeName.c_str());
 
  // add branches for attributes
  for(coral::AttributeListSpecification::const_iterator iter=m_attribSpec->begin(); iter!=m_attribSpec->end(); ++iter)
    {
      std::string type = "/?";
      type[1] = typeDict.at(iter->typeName());
      std::string leaflist = iter->name() + type;
      m_tree->Branch(iter->name().c_str(),0,leaflist.c_str());
    }
 
  // add Token branch
  std::string leaflist = c_tokenBranchName;
  leaflist += "/C";
  m_tree->Branch(c_tokenBranchName,0,leaflist.c_str());
 
  // set TTree
  AANTTreeMap::setTree(m_streamName,m_tree);
}

splitAddress()

StatusCode AANTupleStream::splitAddress ( const std::string & address, const std::string & match, std::string & address_header, std::string & address_data ) const

private

Split the address to get pool token.

Definition at line 426 of file AANTupleStream.cxx.

{
  ATH_MSG_DEBUG ("splitAddress " << endmsg
         << "   address :  " << address
         << "   match :  " << match);
  
  std::string::size_type p1;
 
  p1 = address.find( match );
  if (p1 != std::string::npos) 
    {
      address_header = address.substr( 0, p1+match.size());
      
      address_data = address.substr( p1+match.size() );
    } 
  else 
    {
      return StatusCode::FAILURE;
    }
 
  ATH_MSG_DEBUG ("   address_header :  " << address_header
         << endmsg
         << "   address_data   :  " << address_data);
 
  return StatusCode::SUCCESS;
}

writeAttributeListSpecification()

void AANTupleStream::writeAttributeListSpecification ( )

private

write schema of AttributeList

Definition at line 308 of file AANTupleStream.cxx.

{
  // go to the root dir of output file
  TDirectory::TContext save;
  gDirectory->cd((m_fileName+":/").c_str());
}

writeTokenAttrList()

bool AANTupleStream::writeTokenAttrList ( const std::string & token, const coral::AttributeList & attributeList )

private

write Token and AttributeList

Definition at line 458 of file AANTupleStream.cxx.

{
  // set addresses for attributes
  coral::AttributeList::const_iterator attIter = attributeList.begin();
  const TObjArray* branches = m_tree->GetListOfBranches();
  std::vector<std::string> tokenStringDump;
  // loop over all attributes
  for (unsigned int i=0; i<attributeList.size(); ++i)
    {
      TBranch* branch = (TBranch*)branches->UncheckedAt(i);
      // string attributes
      if (attIter->specification().type() == typeid(std::string))
    {
      const std::string& str = attIter->data<std::string>();
      if( str.length()+1 >= s_maxLengthOfStrings )
        {
          throw std::runtime_error("String is too long : RootCollection::pool2Root<std::string>"); 
        }
      branch->SetAddress( (void*)str.c_str() );
    }
      // Token
      else if(attIter->specification().typeName() == "Token")
    {
      tokenStringDump.push_back( attIter->data<std::string>() );
      branch->SetAddress( (void*) tokenStringDump.back().c_str() );
    }
      // else
      else
    {
      branch->SetAddress( (void*)attIter->addressOfData() );
    }
      ++attIter;  
    }
 
  // set address for Token
  m_tokenBranch->SetAddress((void*)token.c_str());
 
  // fill TTree
  m_tree->Fill();
 
  // releases Token
  m_tokenBranch->SetAddress(m_tokenCString); 
 
  return true;
}

Member Data Documentation

m_acceptAlgs

std::vector<IAlgorithm*> AANTupleStream::m_acceptAlgs

private

Vector of Algorithms that this stream accepts.

Definition at line 126 of file AANTupleStream.h.

m_acceptNames

std::vector<std::string> AANTupleStream::m_acceptNames

private

Vector of names of Algorithms that this stream accepts.

Definition at line 123 of file AANTupleStream.h.

m_attribSpec

coral::AttributeListSpecification* AANTupleStream::m_attribSpec

private

Collection attribute specification.

Definition at line 93 of file AANTupleStream.h.

m_existDH

BooleanProperty AANTupleStream::m_existDH

private

Flag to signal whether data header exists.

Definition at line 105 of file AANTupleStream.h.

m_extraRefNames

StringArrayProperty AANTupleStream::m_extraRefNames

private

Vector of extra parent ref names to register in collection.

Definition at line 99 of file AANTupleStream.h.

m_fileName

std::string AANTupleStream::m_fileName

private

Name of the output collection.

Definition at line 96 of file AANTupleStream.h.

m_lateSchema

BooleanProperty AANTupleStream::m_lateSchema

private

write schema in execute()

Definition at line 111 of file AANTupleStream.h.

m_macro

std::string AANTupleStream::m_macro

private

macro

Definition at line 114 of file AANTupleStream.h.

m_persSvc

ServiceHandle<IAddressCreator> AANTupleStream::m_persSvc

private

Persistency service.

Definition at line 90 of file AANTupleStream.h.

m_schemaDone

bool AANTupleStream::m_schemaDone

private

first event

Definition at line 117 of file AANTupleStream.h.

m_streamName

std::string AANTupleStream::m_streamName

private

Name of Stream.

Definition at line 108 of file AANTupleStream.h.

m_tHistSvc

ServiceHandle<ITHistSvc> AANTupleStream::m_tHistSvc

private

THistSvc.

Definition at line 135 of file AANTupleStream.h.

m_tokenBranch

TBranch* AANTupleStream::m_tokenBranch

private

TBranch which contains Token info.

Definition at line 132 of file AANTupleStream.h.

m_tokenCString

char AANTupleStream::m_tokenCString[s_maxLengthOfStrings]

private

Definition at line 139 of file AANTupleStream.h.

m_tree

TTree* AANTupleStream::m_tree

private

TTree.

Definition at line 129 of file AANTupleStream.h.

m_treeName

std::string AANTupleStream::m_treeName

private

Name of the output tree.

Definition at line 120 of file AANTupleStream.h.

m_writeInputDH

BooleanProperty AANTupleStream::m_writeInputDH

private

Flag to signal whether or not to write input data header.

Definition at line 102 of file AANTupleStream.h.

s_maxLengthOfStrings

const unsigned int AANTupleStream::s_maxLengthOfStrings = 5000

staticprivate

for string branches

Definition at line 138 of file AANTupleStream.h.

---

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

• AANTupleStream.h
• AANTupleStream.cxx