 |
ATLAS Offline Software
|
Go to the documentation of this file.
12 #include "EventInfo/EventInfo.h"
24 #include "GaudiKernel/ISvcLocator.h"
25 #include "GaudiKernel/IAlgTool.h"
26 #include "GaudiKernel/GaudiException.h"
27 #include "GaudiKernel/TypeNameString.h"
28 #include "GaudiKernel/MsgStream.h"
40 p_overStore(
"StoreGateSvc",
"StoreGateSvc")
47 ToolHandleArray<IPileUpXingFolder>::const_iterator
49 while (iXing != iEnd) {
52 msg() <<
MSG::DEBUG <<
"decodeIntervals: adding IPileUpXingFolder "
57 while(
item != endItem) {
62 <<
"decodeInterval: accepting objects of CLID " <<
item->id()
63 <<
" key " <<
item->key() <<
" in the Xing range ["
65 <<
" with cache refresh frequency "
82 m_autoRetrieveTools =
false;
83 m_checkToolDeps =
false;
89 <<
"Could not locate default store"
91 return StatusCode::FAILURE;
96 <<
"Could not locate ITriggerTime tool"
98 return StatusCode::FAILURE;
106 return StatusCode::SUCCESS;
117 if( xAODEventInfo ) {
118 ATH_MSG_DEBUG(
"Found xAOD::EventInfo="<<xAODEventInfo<<
" SG="<<sg<<
" : "<<*xAODEventInfo);
126 std::lock_guard<std::mutex>
lock (*m_slotMutex);
129 const EventInfo* pEvent = einame.empty()?
133 ATH_MSG_DEBUG(
"Converting (PileUp)EventInfo "<<pEvent<<
" SG="<<sg<<
" to xAOD::EventInfo");
135 std::unique_ptr< xAOD::EventInfo > pxAODEventInfo(
new xAOD::EventInfo() );
137 pxAODEventInfo->
setStore( pxAODEventAuxInfo.get() );
138 pxAODEventInfo->setEvtStore( sg );
139 if( !
m_xAODCnvTool->convert( pEvent, pxAODEventInfo.get(),
true,
false ).isSuccess() ) {
149 puei->setStore( puaux.get() );
152 std::vector< xAOD::EventInfo::SubEvent > subEvents;
157 #define DECLARE_SE_TYPE( TYPE ) \
158 { PileUpTimeEventIndex::TYPE, xAOD::EventInfo::TYPE },
167 #undef DECLARE_SE_TYPE
176 const unsigned int countEvents =
std::distance(pu_itr,pu_end);
177 ATH_MSG_VERBOSE(
"CHECKING: There are " << countEvents <<
" subevents in this Event." );
178 for( ; pu_itr != pu_end; ++pu_itr ) {
182 if( !
m_xAODCnvTool->convert( pu_itr->pSubEvt, ei.get(),
true,
false ).isSuccess() ) {
183 ATH_MSG_ERROR(
"Failed to convert EventInfo to xAOD::EventInfo");
189 ei->setEvtStore(tmpSG);
198 auto typeItr = pileupTypeMap.find( pu_itr->type() );
200 if( typeItr == pileupTypeMap.end() ) {
203 type = typeItr->second;
205 ATH_MSG_VERBOSE(
"PileUpEventInfo: time = " << pu_itr->time() <<
", index = " << pu_itr->index());
209 EiLink(
"PileUpEventInfo", puei->
size()-1, sg )));
210 ATH_MSG_VERBOSE(
"PileUpEventInfo: time = " << subEvents.back().time() <<
", index = " << subEvents.back().index());
213 if( subEvents.size() ) {
218 if( !sg->
record( std::move( puaux ),
"PileUpEventInfoAux." ).isSuccess()
219 || !sg->
record( std::move( puei ),
"PileUpEventInfo" ).isSuccess() ) {
220 ATH_MSG_ERROR(
"Failed to record xAOD::EventInfoContainer in SG");
227 xAODEventInfo = std::launder(pxAODEventInfo.get());
229 const auto ptrVal = pxAODEventInfo.get();
230 if( ! sg->
record( std::move( pxAODEventAuxInfo ),
"EventInfoAux." ).isSuccess()
231 || ! sg->
record( std::move( pxAODEventInfo ),
"EventInfo" ).isSuccess() ) {
232 ATH_MSG_ERROR(
"Failed to record the new xAOD::EventInfo in SG");
233 xAODEventInfo =
nullptr;
235 ATH_MSG_DEBUG(
"Record the new xAOD::EventInfo "<<ptrVal<<
" in SG="<<sg);
239 if( !xAODEventInfo ) {
240 ATH_MSG_DEBUG(
"Could not find EventInfo '" << einame <<
"' in store " << sg->name());
242 return xAODEventInfo;
248 return m_ranges[make_pair(
id, dataKey)].contains(iXing);
256 return (
r.contains(iXing) &&
r.doRefresh(
double(random())*(1./RAND_MAX)));
276 proxy->setObject ((DataObject*)0);
279 <<
"clearDataCachesByFolder: object with clid "
280 <<
item.first.first <<
" and key " <<
item.first.second
281 <<
" removed from cache "
282 << pSubEvtSG->name() <<
endmsg;
291 <<
"clearDataCachesByFolder: done with store " << pSubEvtSG->name()
296 sc=StatusCode::SUCCESS;
StatusCode record(T *p2BRegistered, const TKEY &key)
Record an object with a key.
void setSubEvents(const std::vector< SubEvent > &value)
Set the pileup events that were used in the simulation.
This class provides information about an overlaid event. It extends EventInfo with a list of sub-evts...
virtual const_iterator end() const =0
const xAOD::EventInfo * getPileUpEvent(StoreGateSvc *sg, const std::string &einame) const
get EventInfo from SG, by default using p_overStore
Auxiliary information about the event.
PileUpType
Enumerator describing the types of pileup events.
bool isLive(const KEY &key, int iXing)
is iXing live for DATA/key?
bool doRefresh(const Range &r, int iXing)
This class provides general information about an event. It extends EventInfo with a list of sub-evts ...
#define ATH_MSG_VERBOSE(x)
SubEvent::iterator beginSubEvt()
void emptyTrash()
throw away bad objects
The Athena Transient Store API.
This class provides a unique identification for each event, in terms of run/event number and/or a tim...
void setStore(const SG::IConstAuxStore *store)
Set the store associated with this object.
ServiceHandle< StoreGateSvc > p_overStore
overlaid SG (default)
StringProperty m_EventInfoKeyName
@ Unknown
Type not known/specified.
::StatusCode StatusCode
StatusCode definition for legacy code.
an interface to SG::Folder with an attached bunch crossing interval
#define CHECK(...)
Evaluate an expression and check for errors.
virtual const_iterator begin() const =0
AthROOTErrorHandlerSvc * svc
virtual SG::DataProxy * proxy_exact(SG::sgkey_t sgkey) const override final
Get proxy given a hashed key+clid.
uint32_t CLID
The Class ID type.
void decodeIntervals()
setup PileUpIntervals
StatusCode clearDataCaches()
clear bkg event caches from unneeded data objects (as configured using PileUpXingFolder CacheRefreshF...
virtual sgkey_t stringToKey(const std::string &str, CLID clid) override final
Find the key for a string/CLID pair.
ElementLink implementation for ROOT usage.
Auxiliary information about the pileup events.
virtual int firstXing() const =0
ToolHandleArray< IPileUpXingFolder > m_intervals
SG::IFolder::const_iterator const_iterator
This class provides general information about an event. Event information is provided by the accessor...
value_type push_back(value_type pElem)
Add an element to the end of the collection.
virtual StatusCode initialize() override
Service initialisation.
uint32_t sgkey_t
Type used for hashed StoreGate key+CLID pairs.
const T * tryConstRetrieve() const
Class describing the basic event information.
This class provides information about an overlaid event. It extends EventInfo with a list of sub-evts...
virtual float cacheRefreshFrequency() const =0
controls the rate at which we clear data objs in this folder at the end of event
#define ATH_MSG_WARNING(x)
the preferred mechanism to access information from the different event stores in a pileup job.
PileUpMergeSvc(const std::string &name, ISvcLocator *svc)
Standard Gaudi Constructor.
virtual int lastXing() const =0
an interface to SG::Folder with an attached bunch crossing interval
const std::vector< SubEvent > & subEvents() const
Get the pileup events that were used in the simulation.
float distance(const Amg::Vector3D &p1, const Amg::Vector3D &p2)
calculates the distance between two point in 3D space
PileUpTimeEventIndex::PileUpType pileup_type
size_type size() const noexcept
Returns the number of elements in the collection.
#define DECLARE_SE_TYPE(TYPE)
ToolHandle< xAODMaker::IEventInfoCnvTool > m_xAODCnvTool
property: Handle to the EventInfo -> xAOD::EventInfo converter tool
ToolHandle< ITriggerTime > m_pITriggerTime
controls PileUpTimedEventIndex for TimedData returned by retrieveSubEvts
Class describing the properties of one pileup sub-event.
SubEvent::iterator endSubEvt()
interface to a tool that returns the time offset of the current trigger. Used by PileUpMergeSvc
the active crossing range for a data object (CLID/key combination)