| The Gaudi Framework v30r0 (c919700c)

- Main Page
- Related Pages
- Modules
- Namespaces
- Classes
- Files

- File List
- File Members

InputCopyStream.cpp
Go to the documentation of this file.
1 // Framework include files
2 #include "InputCopyStream.h"
3 #include "GaudiKernel/DataObject.h"
4 #include "GaudiKernel/DataStoreItem.h"
5 #include "GaudiKernel/IDataManagerSvc.h"
6 #include "GaudiKernel/IDataProviderSvc.h"
7 #include "GaudiKernel/IDataStoreLeaves.h"
8 #include "GaudiKernel/IOpaqueAddress.h"
9 #include "GaudiKernel/IRegistry.h"
10 #include "GaudiKernel/MsgStream.h"
11
12 // Define the algorithm factory for the standard output data writer
13 DECLARE_COMPONENT( InputCopyStream )
14
15 // Standard Constructor
16 InputCopyStream::InputCopyStream( const std::string& name, ISvcLocator* pSvcLocator )
17 : OutputStream( name, pSvcLocator )
18 {
19 m_doPreLoad = false;
20 m_doPreLoadOpt = false;
21 }
22
23 // Initialize the instance.
24 StatusCode InputCopyStream::initialize()
25 {
26 StatusCode sc = OutputStream::initialize();
27 if ( sc.isFailure() ) return sc;
28
29 sc = toolSvc()->retrieveTool( "DataSvcFileEntriesTool", "InputCopyStreamTool", m_leavesTool );
30 return sc;
31 }
32
33 // Finalize the instance.
34 StatusCode InputCopyStream::finalize()
35 {
36 toolSvc()->releaseTool( m_leavesTool ).ignore();
37 m_leavesTool = nullptr;
38 return OutputStream::finalize();
39 }
40
42 StatusCode InputCopyStream::collectObjects()
43 {
44 // Get the objects in the same file as the root node
45 try {
46 // Get all the leaves on the input stream
47 const IDataStoreLeaves::LeavesList& leaves = m_leavesTool->leaves();
48
49 // Do we need to veto anything ?
50 if ( UNLIKELY( !m_tesVetoList.empty() ) ) {
51 // Veto out locations
52 IDataStoreLeaves::LeavesList filteredLeaves;
53 filteredLeaves.reserve( leaves.size() );
54 std::copy_if( leaves.begin(), leaves.end(), std::back_inserter( filteredLeaves ),
55 [&]( IDataStoreLeaves::LeavesList::const_reference i ) {
56 return i && i->registry() &&
57 std::find( m_tesVetoList.begin(), m_tesVetoList.end(), i->registry()->identifier() ) ==
58 m_tesVetoList.end();
59
60 } );
61 // save the veto'ed list
62 m_objects.assign( filteredLeaves.begin(), filteredLeaves.end() );
63
64 } else {
65 // no veto'ing, so save everything
66 m_objects.assign( leaves.begin(), leaves.end() );
67 }
68 } catch ( const GaudiException& e ) {
69 error() << e.message() << endmsg;
70 return StatusCode::FAILURE;
71 }
72
73 // Collect the other objects from the transient store (mandatory and optional)
74 return OutputStream::collectObjects();
75 }
IDataStoreLeaves::leaves
virtual const LeavesList & leaves() const =0
Return the list of leaves.
IDataStoreLeaves.h
GaudiException::message
virtual const std::string & message() const
error message to be printed
Definition: GaudiException.h:99
UNLIKELY
#define UNLIKELY(x)
Definition: Kernel.h:128
InputCopyStream
Extension of OutputStream to copy the content of the main input file.
Definition: InputCopyStream.h:19
std::copy_if
T copy_if(T...args)
InputCopyStream::initialize
StatusCode initialize() override
Initialize the instance.
Definition: InputCopyStream.cpp:24
GaudiException
Define general base for Gaudi exception.
Definition: GaudiException.h:22
ISvcLocator
The ISvcLocator is the interface implemented by the Service Factory in the Application Manager to loc...
Definition: ISvcLocator.h:25
OutputStream::m_objects
IDataSelector m_objects
Collection of objects being selected.
Definition: OutputStream.h:93
OutputStream::finalize
StatusCode finalize() override
Terminate OutputStream.
Definition: OutputStream.cpp:128
gaudiComponentHelp.name
name
Definition: gaudiComponentHelp.py:32
MsgStream.h
Algorithm::toolSvc
SmartIF< IToolSvc > & toolSvc() const
The standard ToolSvc service, Return a pointer to the service if present.
Definition: Algorithm.cpp:809
std
STL namespace.
std::vector::end
T end(T...args)
InputCopyStream.h
StatusCode::isFailure
bool isFailure() const
Test for a status code of FAILURE.
Definition: StatusCode.h:61
IToolSvc::retrieveTool
StatusCode retrieveTool(const std::string &type, T *&tool, const IInterface *parent=nullptr, bool createIf=true)
Retrieve specified tool sub-type with tool dependent part of the name automatically assigned...
Definition: IToolSvc.h:139
DECLARE_COMPONENT
#define DECLARE_COMPONENT(type)
Definition: PluginService.h:33
OutputStream
A small to stream Data I/O.
Definition: OutputStream.h:29
CommonMessagingBase::error
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
Definition: CommonMessaging.h:106
OutputStream::initialize
StatusCode initialize() override
Initialize OutputStream.
Definition: OutputStream.cpp:40
DataStoreItem.h
IDataManagerSvc.h
IDataProviderSvc.h
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:26
InputCopyStream::m_leavesTool
IDataStoreLeaves * m_leavesTool
Pointer to the (public) tool used to retrieve the objects in a file.
Definition: InputCopyStream.h:40
IRegistry.h
InputCopyStream::m_tesVetoList
Gaudi::Property< std::vector< std::string > > m_tesVetoList
Definition: InputCopyStream.h:42
IOpaqueAddress.h
std::find
T find(T...args)
std::vector::size
T size(T...args)
std::vector::assign
T assign(T...args)
std::vector< DataObject * >
std::vector::begin
T begin(T...args)
std::back_inserter
T back_inserter(T...args)
InputCopyStream::finalize
StatusCode finalize() override
Finalize the instance.
Definition: InputCopyStream.cpp:34
IToolSvc::releaseTool
virtual StatusCode releaseTool(IAlgTool *tool)=0
Release the tool.
StatusCode::FAILURE
Definition: StatusCode.h:29
StatusCode::ignore
void ignore() const
Definition: StatusCode.h:84
InputCopyStream::collectObjects
StatusCode collectObjects() override
Collect all objects to be written to the output stream.
Definition: InputCopyStream.cpp:42
OutputStream::collectObjects
virtual StatusCode collectObjects()
Collect all objects to be written to the output stream.
Definition: OutputStream.cpp:235
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
std::vector::reserve
T reserve(T...args)
DataObject.h