| The Gaudi Framework v29r1 (5cd95fa2)

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

- File List
- File Members

EventSelectorDataStream.cpp
Go to the documentation of this file.
1 //====================================================================
2 // EventSelectorDataStream.cpp
3 //--------------------------------------------------------------------
4 //
5 // Package : EventSelectorDataStream (The LHCb Event Selector Package)
6 //
7 //
8 // Author : M.Frank
9 // Created : 4/10/00
10 // Changes : R. Lambert 2009-09-04
11 //
12 //====================================================================
13 #define GAUDISVC_EVENTSELECTOR_EVENTSELECTORDATASTREAM_CPP 1
14 // Include files
15 #include "GaudiKernel/EventSelectorDataStream.h"
16 #include "GaudiKernel/AttribStringParser.h"
17 #include "GaudiKernel/IConversionSvc.h"
18 #include "GaudiKernel/IDataManagerSvc.h"
19 #include "GaudiKernel/IPersistencySvc.h"
20 #include "GaudiKernel/IService.h"
21 #include "GaudiKernel/ISvcLocator.h"
22 #include "GaudiKernel/MsgStream.h"
23
24 // Output friend
25 MsgStream& operator<<( MsgStream& s, const EventSelectorDataStream& obj )
26 {
27 return s << "Stream:" << obj.name() << " Def:" << obj.definition();
28 }
29
30 // Output friend
31 std::ostream& operator<<( std::ostream& s, const EventSelectorDataStream& obj )
32 {
33 return s << "Stream:" << obj.name() << " Def:" << obj.definition();
34 }
35
36 // Standard Constructor
37 EventSelectorDataStream::EventSelectorDataStream( std::string nam, std::string def, ISvcLocator* svcloc )
38 : m_name{std::move( nam )}, m_definition{std::move( def )}, m_pSvcLocator( svcloc )
39 {
40 }
41
42 // Set selector
43 void EventSelectorDataStream::setSelector( IEvtSelector* pSelector ) { m_pSelector = pSelector; }
44
45 // Allow access to individual properties by name
46 Gaudi::Property<std::string>* EventSelectorDataStream::property( const std::string& nam )
47 {
48 auto i = std::find_if( std::begin( m_properties ), std::end( m_properties ),
49 [&]( const Gaudi::Property<std::string>& j ) { return j.name() == nam; } );
50 return i != std::end( m_properties ) ? &( *i ) : nullptr;
51 }
52
53 // Allow access to individual properties by name
54 const Gaudi::Property<std::string>* EventSelectorDataStream::property( const std::string& nam ) const
55 {
56 auto i = std::find_if( std::begin( m_properties ), std::end( m_properties ),
57 [&]( const Gaudi::Property<std::string>& j ) { return j.name() == nam; } );
58 return i != std::end( m_properties ) ? &( *i ) : nullptr;
59 }
60
61 // Parse input criteria
62 StatusCode EventSelectorDataStream::initialize()
63 {
64 bool isData = true;
65 std::string auth, dbtyp, collsvc, item, crit, sel, svc, stmt;
66 std::string cnt = "/Event";
67 std::string db = "<Unknown>";
68
69 auto eds = m_pSvcLocator->service<IDataManagerSvc>( "EventDataSvc" );
70 if ( !eds ) {
71 std::cout << "ERROR: Unable to localize interface IDataManagerSvc from service EventDataSvc" << std::endl;
72 return StatusCode::FAILURE;
73 } else {
74 cnt = eds->rootName();
75 }
76 m_selectorType = m_criteria = m_dbName = "";
77 m_properties.clear();
78
79 using Parser = Gaudi::Utils::AttribStringParser;
80 for ( auto attrib : Parser( m_definition ) ) {
81 long hash = -1;
82 switch (::toupper( attrib.tag[0] ) ) {
83 case 'A':
84 auth = std::move( attrib.value );
85 break;
86 case 'C':
87 svc = "EvtTupleSvc";
88 isData = false;
89 /* FALLTHROUGH */
90 case 'E':
91 hash = attrib.value.find( '#' );
92 if ( hash > 0 ) {
93 cnt = attrib.value.substr( 0, hash );
94 item = attrib.value.substr( hash + 1 );
95 } else {
96 cnt = std::move( attrib.value );
97 item = "Address";
98 }
99 break;
100 case 'D':
101 m_criteria = "FILE " + attrib.value;
102 m_dbName = std::move( attrib.value );
103 break;
104 case 'F':
105 switch (::toupper( attrib.tag[1] ) ) {
106 case 'I':
107 m_criteria = "FILE " + attrib.value;
108 m_dbName = std::move( attrib.value );
109 break;
110 case 'U':
111 stmt = std::move( attrib.value );
112 break;
113 default:
114 break;
115 }
116 break;
117 case 'J':
118 m_criteria = "JOBID " + attrib.value;
119 m_dbName = std::move( attrib.value );
120 dbtyp = "SICB";
121 break;
122 case 'T':
123 switch (::toupper( attrib.tag[1] ) ) {
124 case 'Y':
125 dbtyp = std::move( attrib.value );
126 break;
127 default:
128 break;
129 }
130 break;
131 case 'S':
132 switch (::toupper( attrib.tag[1] ) ) {
133 case 'E':
134 sel = std::move( attrib.value );
135 break;
136 case 'V':
137 svc = std::move( attrib.value );
138 collsvc = svc;
139 break;
140 default:
141 break;
142 }
143 break;
144 default:
145 m_properties.emplace_back( attrib.tag, attrib.value );
146 break;
147 }
148 }
149 if ( !isData ) { // Unfortunately options do not come in order...
150 m_selectorType = "EventCollectionSelector";
151 svc = "EvtTupleSvc";
152 } else if ( dbtyp.compare( 0, 4, "POOL" ) == 0 ) {
153 m_selectorType = "PoolDbEvtSelector";
154 } else if ( svc.empty() ) {
155 m_selectorType = "DbEvtSelector";
156 } else {
157 m_selectorType = svc;
158 }
159 StatusCode status = StatusCode::SUCCESS;
160 if ( svc.empty() && !dbtyp.empty() ) {
161 auto ipers = m_pSvcLocator->service<IPersistencySvc>( "EventPersistencySvc" );
162 if ( ipers ) {
163 IConversionSvc* icnvSvc = nullptr;
164 status = ipers->getService( dbtyp, icnvSvc );
165 if ( status.isSuccess() ) {
166 auto isvc = SmartIF<INamedInterface>{icnvSvc};
167 if ( isvc ) svc = isvc->name();
168 }
169 }
170 }
171 m_properties.emplace_back( "Function", stmt );
172 m_properties.emplace_back( "CnvService", svc );
173 m_properties.emplace_back( "Authentication", auth );
174 m_properties.emplace_back( "Container", cnt );
175 m_properties.emplace_back( "Item", item );
176 m_properties.emplace_back( "Criteria", sel );
177 m_properties.emplace_back( "DbType", dbtyp );
178 m_properties.emplace_back( "DB", m_criteria );
179 if ( !isData && !collsvc.empty() ) {
180 m_properties.emplace_back( "DbService", collsvc );
181 }
182
183 m_initialized = status.isSuccess();
184 return status;
185 }
186
187 // Parse input criteria
188 StatusCode EventSelectorDataStream::finalize()
189 {
190 setSelector( nullptr );
191 m_properties.clear();
192 m_initialized = false;
193 return StatusCode::SUCCESS;
194 }
Gaudi::Utils::AttribStringParser
Parse attribute strings allowing iteration over the various attributes.
Definition: AttribStringParser.h:32
MsgStream
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
EventSelectorDataStream::m_initialized
bool m_initialized
Initialization state.
Definition: EventSelectorDataStream.h:73
StatusCode::SUCCESS
Definition: StatusCode.h:31
SmartIF< INamedInterface >
EventSelectorDataStream::name
const std::string & name() const
Retrieve stream name.
Definition: EventSelectorDataStream.h:93
std::string::empty
T empty(T...args)
ISvcLocator
The ISvcLocator is the interface implemented by the Service Factory in the Application Manager to loc...
Definition: ISvcLocator.h:25
operator<<
MsgStream & operator<<(MsgStream &s, const EventSelectorDataStream &obj)
Output friend for MsgStream.
Definition: EventSelectorDataStream.cpp:25
StatusCode::FAILURE
Definition: StatusCode.h:31
IConversionSvc
Definition: IConversionSvc.h:37
Gaudi::Property
Implementation of property with value of concrete type.
Definition: Property.h:319
MsgStream.h
Gaudi::Details::PropertyBase::name
const std::string name() const
property name
Definition: Property.h:40
IEvtSelector
The Event Selector Interface.
Definition: IEvtSelector.h:18
StatusCode::isSuccess
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:75
std::endl
T endl(T...args)
IOTest.sel
sel
Definition: IOTest.py:95
std::end
T end(T...args)
EventSelectorDataStream::m_criteria
std::string m_criteria
Criteria.
Definition: EventSelectorDataStream.h:61
EventSelectorDataStream::m_selectorType
std::string m_selectorType
Event selector type.
Definition: EventSelectorDataStream.h:65
std::string
STL class.
IPersistencySvc.h
EventSelectorDataStream::m_pSelector
SmartIF< IEvtSelector > m_pSelector
Pointer to valid selector.
Definition: EventSelectorDataStream.h:67
ISvcLocator::service
StatusCode service(const Gaudi::Utils::TypeNameString &name, T *&svc, bool createIf=true)
Templated method to access a service by name.
Definition: ISvcLocator.h:79
EventSelectorDataStream::m_pSvcLocator
ISvcLocator * m_pSvcLocator
Reference to service locator.
Definition: EventSelectorDataStream.h:69
EventSelectorDataStream::initialize
virtual StatusCode initialize()
Parse input criteria.
Definition: EventSelectorDataStream.cpp:62
IDataManagerSvc.h
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
EventSelectorDataStream::finalize
virtual StatusCode finalize()
Finalize stream and release resources.
Definition: EventSelectorDataStream.cpp:188
EventSelectorDataStream.h
std::vector::clear
T clear(T...args)
std::move
T move(T...args)
IService.h
EventSelectorDataStream::m_definition
std::string m_definition
Definition string.
Definition: EventSelectorDataStream.h:59
EventSelectorDataStream::definition
const std::string & definition() const
Retrieve definition string.
Definition: EventSelectorDataStream.h:101
std::find_if
T find_if(T...args)
EventSelectorDataStream::m_properties
Properties m_properties
Properties vector.
Definition: EventSelectorDataStream.h:71
IConversionSvc.h
IDataManagerSvc
Definition: IDataManagerSvc.h:45
std::begin
T begin(T...args)
EventSelectorDataStream
Definition of class EventSelectorDataStream.
Definition: EventSelectorDataStream.h:45
gaudirun.s
string s
Definition: gaudirun.py:253
AttribStringParser.h
std::string::substr
T substr(T...args)
IPersistencySvc
Data persistency service interface.
Definition: IPersistencySvc.h:19
EventSelectorDataStream::EventSelectorDataStream
EventSelectorDataStream(std::string nam, std::string def, ISvcLocator *svcloc)
Standard Constructor.
Definition: EventSelectorDataStream.cpp:37
EventSelectorDataStream::m_dbName
std::string m_dbName
String with name of the db as parsed.
Definition: EventSelectorDataStream.h:63
EventSelectorDataStream::property
Gaudi::Property< std::string > * property(const std::string &nam)
Allow access to individual properties by name.
Definition: EventSelectorDataStream.cpp:46
std::ostream
STL class.
ISvcLocator.h
toupper
void toupper(std::string &s)
Definition: StatusCodeSvc.cpp:10
EventSelectorDataStream::setSelector
virtual void setSelector(IEvtSelector *pSelector)
Attach event selector object.
Definition: EventSelectorDataStream.cpp:43
std::string::compare
T compare(T...args)
std::vector::emplace_back
T emplace_back(T...args)