ViewHelper::ViewMerger Class Reference

#include <ViewHelper.h>

Collaboration diagram for ViewHelper::ViewMerger:

Public Member Functions
	ViewMerger (StoreGateSvc *sg, MsgStream &msg)
template<typename T >
StatusCode	mergeViewCollection (ViewContainer const &viewVector, SG::ReadHandleKey< T > const &queryKey, EventContext const &sourceContext, T &outputData)
template<typename T >
StatusCode	mergeViewCollection (ViewContainer const &viewVector, SG::ReadHandleKey< DataVector< T > > const &queryKey, EventContext const &sourceContext, DataVector< T > &outputData)

Private Attributes
StoreGateSvc *	m_sg
MsgStream &	m_msg

Detailed Description

Definition at line 135 of file ViewHelper.h.

Constructor & Destructor Documentation

ViewMerger()

ViewHelper::ViewMerger::ViewMerger ( StoreGateSvc *  sg, MsgStream &  msg  )

inline

Definition at line 140 of file ViewHelper.h.

: m_sg( sg ), m_msg( msg ) {}

Member Function Documentation

mergeViewCollection() [1/2]

template<typename T >

StatusCode ViewHelper::ViewMerger::mergeViewCollection ( ViewContainer const &  viewVector, SG::ReadHandleKey< DataVector< T > > const &  queryKey, EventContext const &  sourceContext, DataVector< T > &  outputData  )

inline

Definition at line 175 of file ViewHelper.h.

    {
      //Check that there's a non-const aux store for output bookkeeping
      if ( !outputData.getStore() )
      {
        m_msg << MSG::ERROR << "output data does not have the store"  << endmsg;
        return StatusCode::FAILURE;
      }
 
      //Make ReadHandle to access views
      SG::ReadHandle< DataVector< T > > queryHandle( queryKey, sourceContext );
 
      //Make accessor for bookkeeping
      SG::AuxElement::Accessor< ElementLink< TrigRoiDescriptorCollection > > viewBookkeeper( "viewIndex" );
 
      //Loop over all views
      unsigned int offset = outputData.size(); //allow for existing objects in the container
      for ( const SG::View* inputView : viewVector )
      {
        // setProxyDict only supports non-const stores
        SG::View* nc_inputView ATLAS_THREAD_SAFE = const_cast< SG::View* >( inputView );
        //Attach the handle to the view
        StatusCode sc = queryHandle.setProxyDict( nc_inputView );
        if ( !sc.isSuccess() )
        {
          m_msg << MSG::ERROR << "Failed to use view " << inputView->name() << " to read " << queryHandle.key() << endmsg;
          return sc;
        }
 
        //Nothing to do for empty collections
        if ( queryHandle->empty() )
        {
          if (m_msg.level() <= MSG::DEBUG) {
            m_msg << MSG::DEBUG << "Empty collection " << queryHandle.key() <<" in a view " << inputView->name() <<endmsg;
            continue;
          }
        }
 
        // Warn about unlocked decorations that won't get copied.
        for ( SG::auxid_t decor : queryHandle->getDecorIDs() ) {
          SG::AuxTypeRegistry& r = SG::AuxTypeRegistry::instance();
          m_msg << MSG::WARNING << "mergeViewCollection: skipped unlocked decoration " << queryHandle.key() << "." << r.getName( decor ) << endmsg;
        }
 
        //Merge the data
        for ( const auto inputObject : *queryHandle.cptr() )
        {
          //Element-wise copy data (looks a bit weird, but necessary for xAOD objects)
          T * outputObject = new T();
          outputData.push_back( outputObject );
          *outputObject = *inputObject;
 
          //Add aux data for bookkeeping
          viewBookkeeper( *outputObject ) = inputView->getROI();
        }
 
        if (m_msg.level() <= MSG::DEBUG) {
          m_msg << MSG::DEBUG << "Copied " << queryHandle->size() << " objects from collection in view  " << inputView->name() << endmsg;
        }
 
        //Declare remapping
        auto proxy = inputView->proxy( queryHandle.clid(), queryHandle.key() ); //shouldn't need to test validity since queryHandle already used
        m_sg->remap( ClassID_traits< DataVector< T > >::ID(),
                     proxy->name(),
                     queryHandle.name(),
                     offset );
        offset += queryHandle->size();
      }
 
      return StatusCode::SUCCESS;
    }

mergeViewCollection() [2/2]

template<typename T >

StatusCode ViewHelper::ViewMerger::mergeViewCollection ( ViewContainer const &  viewVector, SG::ReadHandleKey< T > const &  queryKey, EventContext const &  sourceContext, T &  outputData  )

inline

Definition at line 144 of file ViewHelper.h.

    {
      //Make a ReadHandle to use
      SG::ReadHandle<T> queryHandle( queryKey, sourceContext );
 
      //Loop over all views
      for ( const SG::View* inputView : viewVector )
      {
        // setProxyDict only supports non-const stores
        SG::View* nc_inputView ATLAS_THREAD_SAFE = const_cast< SG::View* >( inputView );
        //Attach the handle to the view
        StatusCode sc = queryHandle.setProxyDict( nc_inputView );
        if ( !sc.isSuccess() )
        {
          m_msg << MSG::ERROR <<"Failed to use view " << inputView->name() << " to read " << queryHandle.key() << " resetting output" << endmsg;
          outputData.clear();
          return sc;
        }
 
        //Merge the data
        T inputData = *queryHandle;
        outputData.insert( outputData.end(), inputData.begin(), inputData.end() );
      }
 
      return StatusCode::SUCCESS;
    }

Member Data Documentation

m_msg

MsgStream& ViewHelper::ViewMerger::m_msg

private

Definition at line 138 of file ViewHelper.h.

m_sg

StoreGateSvc* ViewHelper::ViewMerger::m_sg

private

Definition at line 137 of file ViewHelper.h.

---

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

• ViewHelper.h