| The Gaudi Framework v28r2-patches (bc4ad17a)

- 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 "GaudiKernel/IRegistry.h"
3 #include "GaudiKernel/IDataManagerSvc.h"
4 #include "GaudiKernel/IDataProviderSvc.h"
5 #include "GaudiKernel/IOpaqueAddress.h"
6 #include "GaudiKernel/DataStoreItem.h"
7 #include "GaudiKernel/DataObject.h"
8 #include "GaudiKernel/IDataStoreLeaves.h"
9 #include "GaudiKernel/MsgStream.h"
10 #include "InputCopyStream.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",
30 m_leavesTool);
31 return sc;
32 }
33
34 // Finalize the instance.
35 StatusCode InputCopyStream::finalize()
36 {
37 toolSvc()->releaseTool(m_leavesTool).ignore();
38 m_leavesTool = nullptr;
39 return OutputStream::finalize();
40 }
41
43 StatusCode InputCopyStream::collectObjects()
44 {
45 // Get the objects in the same file as the root node
46 try
47 {
48 // Get all the leaves on the input stream
49 const IDataStoreLeaves::LeavesList & leaves = m_leavesTool->leaves();
50
51 // Do we need to veto anything ?
52 if ( UNLIKELY( !m_tesVetoList.empty() ) )
53 {
54 // Veto out locations
55 IDataStoreLeaves::LeavesList filteredLeaves;
56 filteredLeaves.reserve( leaves.size() );
57 std::copy_if( leaves.begin(), leaves.end(),
58 std::back_inserter(filteredLeaves),
59 [&](IDataStoreLeaves::LeavesList::const_reference i) {
60 return i && i->registry() &&
61 std::find( m_tesVetoList.begin(),
62 m_tesVetoList.end(),
63 i->registry()->identifier() ) == m_tesVetoList.end();
64
65 });
66 // save the veto'ed list
67 m_objects.assign( filteredLeaves.begin(), filteredLeaves.end() );
68
69 }
70 else
71 {
72 // no veto'ing, so save everything
73 m_objects.assign( leaves.begin(), leaves.end() );
74 }
75 }
76 catch ( const GaudiException & e )
77 {
78 error() << e.message() << endmsg;
79 return StatusCode::FAILURE;
80 }
81
82 // Collect the other objects from the transient store (mandatory and optional)
83 return OutputStream::collectObjects();
84 }
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:111
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:23
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:28
StatusCode::FAILURE
Definition: StatusCode.h:29
MsgStream.h
Algorithm::toolSvc
SmartIF< IToolSvc > & toolSvc() const
The standard ToolSvc service, Return a pointer to the service if present.
Definition: Algorithm.cpp:781
UNLIKELY
#define UNLIKELY(x)
Definition: Kernel.h:126
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:84
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:146
DECLARE_COMPONENT
#define DECLARE_COMPONENT(type)
Definition: PluginService.h:36
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:117
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:35
IToolSvc::releaseTool
virtual StatusCode releaseTool(IAlgTool *tool)=0
Release the tool.
StatusCode::ignore
void ignore() const
Definition: StatusCode.h:106
InputCopyStream::collectObjects
StatusCode collectObjects() override
Collect all objects to be written to the output stream.
Definition: InputCopyStream.cpp:43
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:244
std::vector::reserve
T reserve(T...args)
DataObject.h