ATLAS Offline Software
Public Member Functions | Protected Member Functions | Protected Attributes | Private Types | Private Member Functions | Private Attributes | List of all members
EFTrackingFPGAIntegration::F100StreamIntegrationAlg Class Reference

This is the class for the benchmark algorithm specific to the FPGA integration and output conversion. More...

#include <F100StreamIntegrationAlg.h>

Inheritance diagram for EFTrackingFPGAIntegration::F100StreamIntegrationAlg:
Collaboration diagram for EFTrackingFPGAIntegration::F100StreamIntegrationAlg:

Public Member Functions

virtual StatusCode initialize () override final
 Detect the OpenCL devices and prepare OpenCL context. More...
 
virtual StatusCode execute (const EventContext &ctx) const override final
 Should be overriden by derived classes to perform meaningful work. More...
 
virtual StatusCode finalize () override final
 
StatusCode loadProgram (const std::string &xclbin)
 Find the xclbin file and load it into the OpenCL program object. More...
 
StatusCode precheck (const std::vector< Gaudi::Property< std::string >> &inputs) const
 Check if the the desired Gaudi properties are set. More...
 
virtual StatusCode sysInitialize () override
 Override sysInitialize. More...
 
virtual bool isClonable () const override
 Specify if the algorithm is clonable. More...
 
virtual unsigned int cardinality () const override
 Cardinality (Maximum number of clones that can exist) special value 0 means that algorithm is reentrant. More...
 
virtual StatusCode sysExecute (const EventContext &ctx) override
 Execute an algorithm. More...
 
virtual const DataObjIDColl & extraOutputDeps () const override
 Return the list of extra output dependencies. More...
 
virtual bool filterPassed (const EventContext &ctx) const
 
virtual void setFilterPassed (bool state, const EventContext &ctx) const
 
ServiceHandle< StoreGateSvc > & evtStore ()
 The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc. More...
 
const ServiceHandle< StoreGateSvc > & evtStore () const
 The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc. More...
 
const ServiceHandle< StoreGateSvc > & detStore () const
 The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc. More...
 
virtual StatusCode sysStart () override
 Handle START transition. More...
 
virtual std::vector< Gaudi::DataHandle * > inputHandles () const override
 Return this algorithm's input handles. More...
 
virtual std::vector< Gaudi::DataHandle * > outputHandles () const override
 Return this algorithm's output handles. More...
 
Gaudi::Details::PropertyBase & declareProperty (Gaudi::Property< T, V, H > &t)
 
Gaudi::Details::PropertyBase * declareProperty (const std::string &name, SG::VarHandleKey &hndl, const std::string &doc, const SG::VarHandleKeyType &)
 Declare a new Gaudi property. More...
 
Gaudi::Details::PropertyBase * declareProperty (const std::string &name, SG::VarHandleBase &hndl, const std::string &doc, const SG::VarHandleType &)
 Declare a new Gaudi property. More...
 
Gaudi::Details::PropertyBase * declareProperty (const std::string &name, SG::VarHandleKeyArray &hndArr, const std::string &doc, const SG::VarHandleKeyArrayType &)
 
Gaudi::Details::PropertyBase * declareProperty (const std::string &name, T &property, const std::string &doc, const SG::NotHandleType &)
 Declare a new Gaudi property. More...
 
Gaudi::Details::PropertyBase * declareProperty (const std::string &name, T &property, const std::string &doc="none")
 Declare a new Gaudi property. More...
 
void updateVHKA (Gaudi::Details::PropertyBase &)
 
MsgStream & msg () const
 
MsgStream & msg (const MSG::Level lvl) const
 
bool msgLvl (const MSG::Level lvl) const
 

Protected Member Functions

void renounceArray (SG::VarHandleKeyArray &handlesArray)
 remove all handles from I/O resolution More...
 
std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void > renounce (T &h)
 
void extraDeps_update_handler (Gaudi::Details::PropertyBase &ExtraDeps)
 Add StoreName to extra input/output deps as needed. More...
 

Protected Attributes

cl::Device m_accelerator
 Device object for the accelerator card. More...
 
cl::Context m_context
 Context object for the application. More...
 
cl::Program m_program
 Program object containing the kernel. More...
 
Gaudi::Property< std::string > m_deviceBDF {this, "bdfID", "", "BDF ID of the accelerator card"}
 BDF ID of the accelerator card. More...
 
Gaudi::Property< bool > m_doEmulation {this, "doEmulation", false, "If software or hardware emulation is being used for debugging"}
 

Private Types

typedef ServiceHandle< StoreGateSvcStoreGateSvc_t
 

Private Member Functions

void getListofCUs (std::vector< std::string > &cuNames)
 
Gaudi::Details::PropertyBase & declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
 specialization for handling Gaudi::Property<SG::VarHandleKey> More...
 
Gaudi::Details::PropertyBase & declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyArrayType &)
 specialization for handling Gaudi::Property<SG::VarHandleKeyArray> More...
 
Gaudi::Details::PropertyBase & declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleType &)
 specialization for handling Gaudi::Property<SG::VarHandleBase> More...
 
Gaudi::Details::PropertyBase & declareGaudiProperty (Gaudi::Property< T, V, H > &t, const SG::NotHandleType &)
 specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray> More...
 

Private Attributes

ServiceHandle< IChronoSvc > m_chronoSvc {"ChronoStatSvc", name()}
 Service for timing the algorithm. More...
 
SG::ReadHandleKey< std::vector< uint64_t > > m_FPGAPixelRDO {this, "FPGAEncodedPixelKey", "FPGAEncodedPixelRDOs", "Pixel RDO converted to FPGA format"}
 
SG::ReadHandleKey< std::vector< uint64_t > > m_FPGAStripRDO {this, "FPGAEncodedStripKey", "FPGAEncodedStripRDOs", "Strip RDO converted to FPGA format"}
 
SG::WriteHandleKey< std::vector< uint64_t > > m_FPGAPixelOutput {this, "FPGAOutputPixelKey", "FPGAPixelOutput", "Pixel output from FPGA format"}
 
SG::WriteHandleKey< std::vector< uint64_t > > m_FPGAStripOutput {this, "FPGAOutputStripKey", "FPGAStripOutput", "Strip output from FPGA format"}
 
Gaudi::Property< int > m_FPGAThreads {this, "FPGAThreads", 1, "number of FPGA threads to initialize"}
 
Gaudi::Property< std::string > m_xclbin {this, "xclbin", "", "xclbin path and name"}
 Path and name of the xclbin file. More...
 
Gaudi::Property< std::string > m_pixelEdmKernelName {this, "PixelEDMPrepKernelName", "", "Name of the FPGA kernel"}
 Name of the FPGA kernel. More...
 
Gaudi::Property< std::string > m_stripEdmKernelName {this, "StripEDMPrepKernelName", "", "Name of the FPGA kernel"}
 Name of the FPGA kernel. More...
 
Gaudi::Property< std::string > m_pixelStartClusterKernelName {this, "PixelStartClusterKernelName", "", "Name of the pixel clustering start kernel"}
 Name of the pixel clustering kernel start. More...
 
Gaudi::Property< std::string > m_pixelEndClusterKernelName {this, "PixelEndClusterKernelName", "", "Name of the pixel clustering end kernel"}
 Name of the pixel clustering kernel start. More...
 
Gaudi::Property< std::string > m_pixelEndClusterEdmKernelName {this, "PixelEndClusterEdmKernelName", "", "Name of the pixel clustering end kernel"}
 Name of the pixel clustering kernel start. More...
 
Gaudi::Property< std::string > m_stripStartClusterKernelName {this, "StripStartClusterKernelName", "", "Name of the strip clustering start kernel"}
 Name of the strip clustering kernel start. More...
 
Gaudi::Property< std::string > m_stripEndClusterKernelName {this, "StripEndClusterKernelName", "", "Name of the strip clustering end kernel"}
 Name of the strip clustering kernel start. More...
 
Gaudi::Property< std::string > m_pixelL2GKernelName {this, "PixelL2GKernelName", "", "Name of the pixel L2G kernel"}
 Name of the pixel L2G kernel. More...
 
Gaudi::Property< std::string > m_stripL2GKernelName {this, "StripL2GKernelName", "", "Name of the strip L2G kernel"}
 Name of the strip L2G kernelS. More...
 
std::atomic< ulonglong > m_numEvents {0}
 Number of events processed. More...
 
std::atomic< cl_ulong > m_pixelInputTime {0}
 Time for pixel input buffer write. More...
 
std::atomic< cl_ulong > m_stripInputTime {0}
 Time for strip input buffer write. More...
 
std::atomic< cl_ulong > m_pixelClusteringTime {0}
 Time for pixel clustering. More...
 
std::atomic< cl_ulong > m_stripClusteringTime {0}
 Time for strip clustering. More...
 
std::atomic< cl_ulong > m_pixelL2GTime {0}
 Time for pixel L2G. More...
 
std::atomic< cl_ulong > m_stripL2GTime {0}
 Time for strip L2G. More...
 
std::atomic< cl_ulong > m_pixelEdmPrepTime {0}
 Time for pixel EDM preparation. More...
 
std::atomic< cl_ulong > m_stripEdmPrepTime {0}
 Time for strip EDM preparation. More...
 
std::atomic< cl_ulong > m_pixelOutputTime {0}
 Time for pixel output buffer read. More...
 
std::atomic< cl_ulong > m_stripOutputTime {0}
 Time for strip output buffer read. More...
 
std::atomic< cl_ulong > m_kernelTime {0}
 Time for kernel execution. More...
 
std::vector< cl::Kernel > m_pixelStartClusteringKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_pixelEndClusteringClusterKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_pixelEndClusteringEDMKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_stripStartClusteringKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_stripEndClusteringKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_pixelL2GKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_stripL2GKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_pixelEdmPrepKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Kernel > m_stripEdmPrepKernels ATLAS_THREAD_SAFE
 
std::vector< cl::Buffer > m_pixelClusterInputBufferList
 
std::vector< cl::Buffer > m_stripClusterInputBufferList
 
std::vector< cl::Buffer > m_pixelClusterOutputBufferList
 
std::vector< cl::Buffer > m_stripClusterOutputBufferList
 
std::vector< cl::Buffer > m_pixelClusterEDMOutputBufferList
 
std::vector< cl::Buffer > m_stripClusterEDMOutputBufferList
 
std::vector< cl::Buffer > m_pixelL2GOutputBufferList
 
std::vector< cl::Buffer > m_stripL2GOutputBufferList
 
std::vector< cl::Buffer > m_pixelL2GEDMOutputBufferList
 
std::vector< cl::Buffer > m_stripL2GEDMOutputBufferList
 
std::vector< cl::Buffer > m_edmPixelOutputBufferList
 
std::vector< cl::Buffer > m_edmStripOutputBufferList
 
std::vector< cl::CommandQueue > m_acc_queues
 
DataObjIDColl m_extendedExtraObjects
 Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks. More...
 
StoreGateSvc_t m_evtStore
 Pointer to StoreGate (event store by default) More...
 
StoreGateSvc_t m_detStore
 Pointer to StoreGate (detector store by default) More...
 
std::vector< SG::VarHandleKeyArray * > m_vhka
 
bool m_varHandleArraysDeclared
 

Detailed Description

This is the class for the benchmark algorithm specific to the FPGA integration and output conversion.

This algorithm is used to benchmark and optimize the FPGA output memory migration and output conversion. It expects the use of FPGA pass-through kernel.

Definition at line 33 of file F100StreamIntegrationAlg.h.

Member Typedef Documentation

◆ StoreGateSvc_t

typedef ServiceHandle<StoreGateSvc> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::StoreGateSvc_t
privateinherited

Definition at line 388 of file AthCommonDataStore.h.

Member Function Documentation

◆ cardinality()

unsigned int AthCommonReentrantAlgorithm< Gaudi::Algorithm >::cardinality
overridevirtualinherited

Cardinality (Maximum number of clones that can exist) special value 0 means that algorithm is reentrant.

Override this to return 0 for reentrant algorithms.

Override this to return 0 for reentrant algorithms.

Definition at line 75 of file AthCommonReentrantAlgorithm.cxx.

64 {
65  return 0;
66 }

◆ declareGaudiProperty() [1/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty ( Gaudi::Property< T, V, H > &  hndl,
const SG::VarHandleKeyArrayType  
)
inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKeyArray>

Definition at line 170 of file AthCommonDataStore.h.

172  {
173  return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
174  hndl.value(),
175  hndl.documentation());
176 
177  }

◆ declareGaudiProperty() [2/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty ( Gaudi::Property< T, V, H > &  hndl,
const SG::VarHandleKeyType  
)
inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKey>

Definition at line 156 of file AthCommonDataStore.h.

158  {
159  return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
160  hndl.value(),
161  hndl.documentation());
162 
163  }

◆ declareGaudiProperty() [3/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty ( Gaudi::Property< T, V, H > &  hndl,
const SG::VarHandleType  
)
inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleBase>

Definition at line 184 of file AthCommonDataStore.h.

186  {
187  return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
188  hndl.value(),
189  hndl.documentation());
190  }

◆ declareGaudiProperty() [4/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty ( Gaudi::Property< T, V, H > &  t,
const SG::NotHandleType  
)
inlineprivateinherited

specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray>

Definition at line 199 of file AthCommonDataStore.h.

200  {
201  return PBASE::declareProperty(t);
202  }

◆ declareProperty() [1/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( const std::string &  name,
SG::VarHandleBase hndl,
const std::string &  doc,
const SG::VarHandleType  
)
inlineinherited

Declare a new Gaudi property.

Parameters
nameName of the property.
hndlObject holding the property value.
docDocumentation string for the property.

This is the version for types that derive from SG::VarHandleBase. The property value object is put on the input and output lists as appropriate; then we forward to the base class.

Definition at line 245 of file AthCommonDataStore.h.

249  {
250  this->declare(hndl.vhKey());
251  hndl.vhKey().setOwner(this);
252 
253  return PBASE::declareProperty(name,hndl,doc);
254  }

◆ declareProperty() [2/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( const std::string &  name,
SG::VarHandleKey hndl,
const std::string &  doc,
const SG::VarHandleKeyType  
)
inlineinherited

Declare a new Gaudi property.

Parameters
nameName of the property.
hndlObject holding the property value.
docDocumentation string for the property.

This is the version for types that derive from SG::VarHandleKey. The property value object is put on the input and output lists as appropriate; then we forward to the base class.

Definition at line 221 of file AthCommonDataStore.h.

225  {
226  this->declare(hndl);
227  hndl.setOwner(this);
228 
229  return PBASE::declareProperty(name,hndl,doc);
230  }

◆ declareProperty() [3/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( const std::string &  name,
SG::VarHandleKeyArray hndArr,
const std::string &  doc,
const SG::VarHandleKeyArrayType  
)
inlineinherited

Definition at line 259 of file AthCommonDataStore.h.

263  {
264 
265  // std::ostringstream ost;
266  // ost << Algorithm::name() << " VHKA declareProp: " << name
267  // << " size: " << hndArr.keys().size()
268  // << " mode: " << hndArr.mode()
269  // << " vhka size: " << m_vhka.size()
270  // << "\n";
271  // debug() << ost.str() << endmsg;
272 
273  hndArr.setOwner(this);
274  m_vhka.push_back(&hndArr);
275 
276  Gaudi::Details::PropertyBase* p = PBASE::declareProperty(name, hndArr, doc);
277  if (p != 0) {
278  p->declareUpdateHandler(&AthCommonDataStore<PBASE>::updateVHKA, this);
279  } else {
280  ATH_MSG_ERROR("unable to call declareProperty on VarHandleKeyArray "
281  << name);
282  }
283 
284  return p;
285 
286  }

◆ declareProperty() [4/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( const std::string &  name,
T &  property,
const std::string &  doc,
const SG::NotHandleType  
)
inlineinherited

Declare a new Gaudi property.

Parameters
nameName of the property.
propertyObject holding the property value.
docDocumentation string for the property.

This is the generic version, for types that do not derive from SG::VarHandleKey. It just forwards to the base class version of declareProperty.

Definition at line 333 of file AthCommonDataStore.h.

337  {
338  return PBASE::declareProperty(name, property, doc);
339  }

◆ declareProperty() [5/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( const std::string &  name,
T &  property,
const std::string &  doc = "none" 
)
inlineinherited

Declare a new Gaudi property.

Parameters
nameName of the property.
propertyObject holding the property value.
docDocumentation string for the property.

This dispatches to either the generic declareProperty or the one for VarHandle/Key/KeyArray.

Definition at line 352 of file AthCommonDataStore.h.

355  {
356  typedef typename SG::HandleClassifier<T>::type htype;
357  return declareProperty (name, property, doc, htype());
358  }

◆ declareProperty() [6/6]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( Gaudi::Property< T, V, H > &  t)
inlineinherited

Definition at line 145 of file AthCommonDataStore.h.

145  {
146  typedef typename SG::HandleClassifier<T>::type htype;
148  }

◆ detStore()

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::detStore ( ) const
inlineinherited

The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 95 of file AthCommonDataStore.h.

95 { return m_detStore; }

◆ evtStore() [1/2]

ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::evtStore ( )
inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 85 of file AthCommonDataStore.h.

85 { return m_evtStore; }

◆ evtStore() [2/2]

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::evtStore ( ) const
inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 90 of file AthCommonDataStore.h.

90 { return m_evtStore; }

◆ execute()

StatusCode EFTrackingFPGAIntegration::F100StreamIntegrationAlg::execute ( const EventContext &  ctx) const
finaloverridevirtual

Should be overriden by derived classes to perform meaningful work.

Input handles

Reimplemented from IntegrationBase.

Definition at line 120 of file F100StreamIntegrationAlg.cxx.

121  {
122  ATH_MSG_DEBUG("Executing F100StreamIntegrationAlg");
123  m_numEvents++;
124 
126  const std::vector<uint64_t>* pixelInput{nullptr}, *stripInput{nullptr};
127  ATH_CHECK(SG::get(pixelInput, m_FPGAPixelRDO, ctx));
128  ATH_CHECK(SG::get(stripInput, m_FPGAStripRDO, ctx));
129 
130 
131  // logic
132  unsigned int nthreads = m_FPGAThreads.value();
133 
134  if(m_FPGAThreads.value() < 1){
135  nthreads = SG::getNSlots();
136  }
137 
138  size_t bufferIndex = ctx.slot() % nthreads;
139 
140  // Get index for each of the kernels
141  size_t pixelStartClusterIndex = ctx.slot() % m_pixelStartClusteringKernels.size();
142  size_t pixelEndClusterIndex = ctx.slot() % m_pixelEndClusteringClusterKernels.size();
143  size_t pixelEndClusterEDMIndex = ctx.slot() % m_pixelEndClusteringEDMKernels.size();
144  size_t stripStartClusterIndex = ctx.slot() % m_stripStartClusteringKernels.size();
145  size_t stripEndClusterIndex = ctx.slot() % m_stripEndClusteringKernels.size();
146  size_t pixelL2GIndex = m_pixelL2GKernels.size() ? ctx.slot() % m_pixelL2GKernels.size() : 0;
147  size_t stripL2GIndex = ctx.slot() % m_stripL2GKernels.size();
148  size_t pixelEDMIndex = m_pixelEdmPrepKernels.size() ? ctx.slot() % m_pixelEdmPrepKernels.size() : 0;
149  size_t stripEDMIndex = m_stripEdmPrepKernels.size() ? ctx.slot() % m_stripEdmPrepKernels.size() : 0;
150 
151  const cl::CommandQueue &acc_queue = m_acc_queues[bufferIndex];
152 
153  ATH_MSG_INFO("Thread number "<<ctx.slot()<<" running on buffer "<<bufferIndex<<" pixelStartClusterIndex: "<< pixelStartClusterIndex<<" stripStartClusterIndex: "<< stripStartClusterIndex<<" stripEndClusterIndex: "<< stripEndClusterIndex<<" stripL2GIndex: "<< stripL2GIndex<<" pixelEDMIndex: "<< pixelEDMIndex<<" stripEDMIndex: "<< stripEDMIndex);
154 
155  cl::Kernel &pixelStartClusteringKernel = m_pixelStartClusteringKernels[pixelStartClusterIndex];
156  cl::Kernel &pixelEndClusteringClusterKernel = m_pixelEndClusteringClusterKernels[pixelEndClusterIndex];
157  cl::Kernel &pixelEndClusteringEDMKernel = m_pixelEndClusteringEDMKernels[pixelEndClusterEDMIndex];
158  cl::Kernel &stripStartClusteringKernel = m_stripStartClusteringKernels[stripStartClusterIndex];
159  cl::Kernel &stripEndClusteringKernel = m_stripEndClusteringKernels[stripEndClusterIndex];
160  cl::Kernel &stripL2GKernel = m_stripL2GKernels[stripL2GIndex];
161  cl::Kernel &pixelL2GKernel = m_pixelL2GKernels[pixelL2GIndex];
162 
163  cl::Kernel &pixelEdmPrepKernel = m_pixelEdmPrepKernels[pixelEDMIndex];
164  cl::Kernel &stripEdmPrepKernel = m_stripEdmPrepKernels[stripEDMIndex];
165 
166 
167  // Set kernel arguments
168  pixelStartClusteringKernel.setArg(0, m_pixelClusterInputBufferList[bufferIndex]);
169  pixelStartClusteringKernel.setArg(2, static_cast<unsigned long long>((*pixelInput).size()));
170 
171  pixelEndClusteringClusterKernel.setArg(1, m_pixelClusterOutputBufferList[bufferIndex]);
172  pixelEndClusteringEDMKernel.setArg(1, m_pixelClusterEDMOutputBufferList[bufferIndex]);
173 
174  stripStartClusteringKernel.setArg(0, m_stripClusterInputBufferList[bufferIndex]);
175  stripStartClusteringKernel.setArg(2, static_cast<unsigned long long>((*stripInput).size()));
176 
177  stripEndClusteringKernel.setArg(1, m_stripClusterOutputBufferList[bufferIndex]);
178 
179  pixelL2GKernel.setArg(0, m_pixelClusterOutputBufferList[bufferIndex]);
180  pixelL2GKernel.setArg(1, m_pixelClusterEDMOutputBufferList[bufferIndex]);
181  pixelL2GKernel.setArg(2, m_pixelL2GOutputBufferList[bufferIndex]);
182  pixelL2GKernel.setArg(3, m_pixelL2GEDMOutputBufferList[bufferIndex]);
183 
184 
185  stripL2GKernel.setArg(0, m_stripClusterOutputBufferList[bufferIndex]);
186  stripL2GKernel.setArg(1, m_stripClusterEDMOutputBufferList[bufferIndex]);
187  stripL2GKernel.setArg(2, m_stripL2GOutputBufferList[bufferIndex]);
188  stripL2GKernel.setArg(3, m_stripL2GEDMOutputBufferList[bufferIndex]);
189 
190  pixelEdmPrepKernel.setArg(0, m_pixelL2GEDMOutputBufferList[bufferIndex]);
191  pixelEdmPrepKernel.setArg(1, m_edmPixelOutputBufferList[bufferIndex]);
192  stripEdmPrepKernel.setArg(0, m_stripL2GEDMOutputBufferList[bufferIndex]);
193  stripEdmPrepKernel.setArg(1, m_edmStripOutputBufferList[bufferIndex]);
194 
195 
196 
197  // Start the transfers
198  cl::Event evt_write_pixel_input;
199  cl::Event evt_write_strip_input;
200 
201  acc_queue.enqueueWriteBuffer(m_pixelClusterInputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint64_t) * (*pixelInput).size(), (*pixelInput).data(), NULL, &evt_write_pixel_input);
202  acc_queue.enqueueWriteBuffer(m_stripClusterInputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint64_t) * (*stripInput).size(), (*stripInput).data(), NULL, &evt_write_strip_input);
203  std::vector<cl::Event> evt_vec_pixel_input{evt_write_pixel_input};
204  std::vector<cl::Event> evt_vec_strip_input{evt_write_strip_input};
205 
206 
207  cl::Event evt_pixel_start_clustering;
208  cl::Event evt_pixel_end_clustering_cluster;
209  cl::Event evt_pixel_end_clustering_edm;
210  cl::Event evt_strip_start_clustering;
211  cl::Event evt_strip_end_clustering;
212  cl::Event evt_strip_l2g;
213  cl::Event evt_pixel_l2g;
214  cl::Event evt_edm_prep;
215  cl::Event evt_pixel_edm_prep;
216  cl::Event evt_strip_edm_prep;
217  {
218  Athena::Chrono chrono("Kernel execution", m_chronoSvc.get());
219  acc_queue.enqueueTask(pixelStartClusteringKernel, &evt_vec_pixel_input, &evt_pixel_start_clustering);
220  acc_queue.enqueueTask(pixelEndClusteringClusterKernel, NULL , &evt_pixel_end_clustering_cluster);
221  acc_queue.enqueueTask(pixelEndClusteringEDMKernel, NULL , &evt_pixel_end_clustering_edm);
222  acc_queue.enqueueTask(stripStartClusteringKernel, &evt_vec_strip_input, &evt_strip_start_clustering);
223  acc_queue.enqueueTask(stripEndClusteringKernel, NULL, &evt_strip_end_clustering);
224 
225  std::vector<cl::Event> evt_vec_pixel_clustering{
226  evt_pixel_end_clustering_cluster,
227  evt_pixel_end_clustering_edm,
228  };
229 
230  acc_queue.enqueueTask(pixelL2GKernel, &evt_vec_pixel_clustering, &evt_pixel_l2g);
231 
232  std::vector<cl::Event> evt_vec_strip_clustering{evt_strip_end_clustering};
233  acc_queue.enqueueTask(stripL2GKernel, &evt_vec_strip_clustering, &evt_strip_l2g);
234 
235  std::vector<cl::Event> evt_vec_pixel_l2g{evt_pixel_l2g};
236  acc_queue.enqueueTask(pixelEdmPrepKernel, &evt_vec_pixel_l2g, &evt_pixel_edm_prep);
237 
238  std::vector<cl::Event> evt_vec_strip_l2g{evt_strip_l2g};
239  acc_queue.enqueueTask(stripEdmPrepKernel, &evt_vec_strip_l2g, &evt_strip_edm_prep);
240 
241  }
242 
243  cl::Event evt_pixel_cluster_output;
244  cl::Event evt_strip_cluster_output;
245 
246  std::vector<cl::Event> evt_vec_pixel_edm_prep;
247  std::vector<cl::Event> evt_vec_strip_edm_prep;
248 
249  evt_vec_pixel_edm_prep.push_back(evt_pixel_edm_prep);
250  evt_vec_strip_edm_prep.push_back(evt_strip_edm_prep);
251 
252 
253  // output handles
254 
256  ATH_CHECK(FPGAPixelOutput.record(std::make_unique<std::vector<uint64_t> >(EFTrackingTransient::PIXEL_CONTAINER_BUF_SIZE, 0)));
257 
259  ATH_CHECK(FPGAStripOutput.record(std::make_unique<std::vector<uint64_t> >(EFTrackingTransient::STRIP_CONTAINER_BUF_SIZE, 0)));
260 
261  acc_queue.enqueueReadBuffer(m_edmPixelOutputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint64_t) * (*FPGAPixelOutput).size(), (*FPGAPixelOutput).data(), &evt_vec_pixel_edm_prep, &evt_pixel_cluster_output);
262  acc_queue.enqueueReadBuffer(m_edmStripOutputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint64_t) * (*FPGAStripOutput).size(), (*FPGAStripOutput).data(), &evt_vec_strip_edm_prep, &evt_strip_cluster_output);
263 
264  std::vector<cl::Event> wait_for_reads = { evt_pixel_cluster_output, evt_strip_cluster_output };
265  cl::Event::waitForEvents(wait_for_reads);
266 
267 
268  if(pixelInput->size() == 6) (*FPGAPixelOutput)[0] = 0; // if no pixel input, set the first element to 0
269  if(stripInput->size() == 6) (*FPGAStripOutput)[0] = 0; // if no strip input, set the first element to 0
270 
271 
272  // calculate the time for the kernel execution
273  // get the time of writing pixel input buffer
274  cl_ulong pixel_input_time = evt_write_pixel_input.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_write_pixel_input.getProfilingInfo<CL_PROFILING_COMMAND_START>();
275  m_pixelInputTime += pixel_input_time;
276  ATH_MSG_DEBUG("Pixel input buffer write time: " << pixel_input_time / 1e6 << " ms");
277 
278  // get the time of writing strip input buffer
279  cl_ulong strip_input_time = evt_write_strip_input.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_write_strip_input.getProfilingInfo<CL_PROFILING_COMMAND_START>();
280  m_stripInputTime += strip_input_time;
281  ATH_MSG_DEBUG("Strip input buffer write time: " << strip_input_time / 1e6 << " ms");
282 
283  // get the time of pixel clustering_cluster
284  cl_ulong pixel_clustering_cluster_time = evt_pixel_end_clustering_cluster.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_start_clustering.getProfilingInfo<CL_PROFILING_COMMAND_START>();
285  m_pixelClusteringTime += pixel_clustering_cluster_time;
286  ATH_MSG_DEBUG("Pixel clustering_cluster time: " << pixel_clustering_cluster_time / 1e6 << " ms");
287 
288  cl_ulong pixel_clustering_edm_time = evt_pixel_end_clustering_edm.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_start_clustering.getProfilingInfo<CL_PROFILING_COMMAND_START>();
289  m_pixelClusteringTime += pixel_clustering_edm_time;
290  ATH_MSG_DEBUG("Pixel clustering_edm time: " << pixel_clustering_edm_time / 1e6 << " ms");
291 
292  // get the time of strip clustering
293  cl_ulong strip_clustering_time = evt_strip_end_clustering.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_strip_start_clustering.getProfilingInfo<CL_PROFILING_COMMAND_START>();
294  m_stripClusteringTime += strip_clustering_time;
295  ATH_MSG_DEBUG("Strip clustering time: " << strip_clustering_time / 1e6 << " ms");
296 
297  // get the time of pixel L2G
298  cl_ulong pixel_l2g_time = evt_pixel_l2g.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_l2g.getProfilingInfo<CL_PROFILING_COMMAND_START>();
299  m_pixelL2GTime += pixel_l2g_time;
300  ATH_MSG_DEBUG("Pixel L2G time: " << pixel_l2g_time / 1e6 << " ms");
301 
302  // get the time of strip L2G
303  cl_ulong strip_l2g_time = evt_strip_l2g.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_strip_l2g.getProfilingInfo<CL_PROFILING_COMMAND_START>();
304  m_stripL2GTime += strip_l2g_time;
305  ATH_MSG_DEBUG("Strip L2G time: " << strip_l2g_time / 1e6 << " ms");
306 
307  // get the time of EDMPrep
308  cl_ulong pixel_edm_prep_time = evt_pixel_edm_prep.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_edm_prep.getProfilingInfo<CL_PROFILING_COMMAND_START>();
309  cl_ulong strip_edm_prep_time = evt_strip_edm_prep.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_strip_edm_prep.getProfilingInfo<CL_PROFILING_COMMAND_START>();
310 
311  m_pixelEdmPrepTime += pixel_edm_prep_time;
312  ATH_MSG_DEBUG("PixelEDMPrep time: " << pixel_edm_prep_time / 1e6 << " ms");
313 
314  m_stripEdmPrepTime += strip_edm_prep_time;
315  ATH_MSG_DEBUG("StripEDMPrep time: " << strip_edm_prep_time / 1e6 << " ms");
316 
317 
318  // get the time of the whole kernel execution
319  cl_ulong kernel_start = evt_pixel_start_clustering.getProfilingInfo<CL_PROFILING_COMMAND_QUEUED>();
320  cl_ulong kernel_end = std::max(evt_pixel_edm_prep.getProfilingInfo<CL_PROFILING_COMMAND_END>(), evt_strip_edm_prep.getProfilingInfo<CL_PROFILING_COMMAND_END>());
321  m_kernelTime += (kernel_end - kernel_start);
322  ATH_MSG_DEBUG("Kernel execution time: " << (kernel_end - kernel_start) / 1e6 << " ms");
323 
324  // get the time of reading pixel output buffer
325  cl_ulong pixel_output_time = evt_pixel_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_START>();
326  m_pixelOutputTime += pixel_output_time;
327  ATH_MSG_DEBUG("Pixel output buffer read time: " << pixel_output_time / 1e6 << " ms");
328 
329  // get the time of reading strip output buffer
330  cl_ulong strip_output_time = evt_strip_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_strip_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_START>();
331  m_stripOutputTime += strip_output_time;
332  ATH_MSG_DEBUG("Strip output buffer read time: " << strip_output_time / 1e6 << " ms");
333 
334  return StatusCode::SUCCESS;
335  }

◆ extraDeps_update_handler()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::extraDeps_update_handler ( Gaudi::Details::PropertyBase &  ExtraDeps)
protectedinherited

Add StoreName to extra input/output deps as needed.

use the logic of the VarHandleKey to parse the DataObjID keys supplied via the ExtraInputs and ExtraOuputs Properties to add the StoreName if it's not explicitly given

◆ extraOutputDeps()

const DataObjIDColl & AthCommonReentrantAlgorithm< Gaudi::Algorithm >::extraOutputDeps
overridevirtualinherited

Return the list of extra output dependencies.

This list is extended to include symlinks implied by inheritance relations.

Definition at line 94 of file AthCommonReentrantAlgorithm.cxx.

90 {
91  // If we didn't find any symlinks to add, just return the collection
92  // from the base class. Otherwise, return the extended collection.
93  if (!m_extendedExtraObjects.empty()) {
95  }
96  return BaseAlg::extraOutputDeps();
97 }

◆ filterPassed()

virtual bool AthCommonReentrantAlgorithm< Gaudi::Algorithm >::filterPassed ( const EventContext &  ctx) const
inlinevirtualinherited

Definition at line 96 of file AthCommonReentrantAlgorithm.h.

96  {
97  return execState( ctx ).filterPassed();
98  }

◆ finalize()

StatusCode EFTrackingFPGAIntegration::F100StreamIntegrationAlg::finalize ( )
finaloverridevirtual

Definition at line 337 of file F100StreamIntegrationAlg.cxx.

338  {
339 
340  ATH_MSG_INFO("Finalizing F100StreamIntegrationAlg");
341  ATH_MSG_INFO("Number of events: " << m_numEvents);
342 
343  if(m_numEvents > 0){
344  ATH_MSG_INFO("Pixel input ave time: " << m_pixelInputTime / m_numEvents / 1e6 << " ms");
345  ATH_MSG_INFO("Strip input ave time: " << m_stripInputTime / m_numEvents / 1e6 << " ms");
346  ATH_MSG_INFO("Pixel clustering ave time: " << m_pixelClusteringTime / m_numEvents / 1e6 << " ms");
347  ATH_MSG_INFO("Strip clustering ave time: " << m_stripClusteringTime / m_numEvents / 1e6 << " ms");
348  ATH_MSG_INFO("Pixel L2G ave time: " << m_pixelL2GTime / m_numEvents / 1e6 << " ms");
349  ATH_MSG_INFO("Strip L2G ave time: " << m_stripL2GTime / m_numEvents / 1e6 << " ms");
350  ATH_MSG_INFO("PixelEDMPrep ave time: " << m_pixelEdmPrepTime / m_numEvents / 1e6 << " ms");
351  ATH_MSG_INFO("StripEDMPrep ave time: " << m_stripEdmPrepTime / m_numEvents / 1e6 << " ms");
352  ATH_MSG_INFO("Kernel execution ave time: " << m_kernelTime / m_numEvents / 1e6 << " ms");
353  ATH_MSG_INFO("Pixel output ave time: " << m_pixelOutputTime / m_numEvents / 1e6 << " ms");
354  ATH_MSG_INFO("Strip output ave time: " << m_stripOutputTime / m_numEvents / 1e6 << " ms");
355  }
356 
357  return StatusCode::SUCCESS;
358  }

◆ getListofCUs()

void EFTrackingFPGAIntegration::F100StreamIntegrationAlg::getListofCUs ( std::vector< std::string > &  cuNames)
private

Definition at line 360 of file F100StreamIntegrationAlg.cxx.

361  {
362  xrt::xclbin xrt_xclbin(m_xclbin);
363 
364  ATH_MSG_INFO("xsa name: "<<xrt_xclbin.get_xsa_name());
365  ATH_MSG_INFO("fpga name: "<<xrt_xclbin.get_fpga_device_name());
366  ATH_MSG_INFO("uuid: "<<xrt_xclbin.get_uuid().to_string());
367 
368  for (const xrt::xclbin::kernel &kernel : xrt_xclbin.get_kernels()) {
369  const std::string& kernelName = kernel.get_name();
370 
371  ATH_MSG_INFO("kernelName: "<<kernelName);
372 
373 
374  for (const xrt::xclbin::ip &computeUnit : kernel.get_cus()) {
375  const std::string& computeUnitName = computeUnit.get_name();
376  const std::string computeUnitIsolatedName = computeUnitName.substr(kernelName.size() + 1);
377 
378  const std::string computeUnitUsableName = kernelName + ":{" + computeUnitIsolatedName + "}";
379 
380  ATH_MSG_INFO("CU name: "<<computeUnitUsableName);
381  cuNames.push_back(computeUnitUsableName);
382  }
383  }
384  }

◆ initialize()

StatusCode EFTrackingFPGAIntegration::F100StreamIntegrationAlg::initialize ( )
finaloverridevirtual

Detect the OpenCL devices and prepare OpenCL context.

This should always be called by derived classes when running on the FPGA accelerator.

Reimplemented from IntegrationBase.

Definition at line 15 of file F100StreamIntegrationAlg.cxx.

16  {
17  ATH_MSG_INFO("Running on the FPGA accelerator");
18 
20 
21  ATH_CHECK(m_chronoSvc.retrieve());
22 
23  {
24  Athena::Chrono chrono("Platform and device initlize", m_chronoSvc.get());
26  }
27 
28  {
29  Athena::Chrono chrono("CL::loadProgram", m_chronoSvc.get());
31  }
32  ATH_MSG_INFO("loading "<<m_xclbin);
33 
34 
37 
40 
41  std::vector<std::string> listofCUs;
42 
43  getListofCUs(listofCUs);
44 
45  cl_int err = 0;
46 
47  unsigned int nthreads = m_FPGAThreads.value();
48 
49  if(m_FPGAThreads.value() < 1){
50  nthreads = SG::getNSlots();
51  }
52 
53  // create the buffers
54  for(unsigned int i = 0; i < nthreads; i++)
55  {
56  m_acc_queues.emplace_back(m_context, m_accelerator, CL_QUEUE_PROFILING_ENABLE | CL_QUEUE_OUT_OF_ORDER_EXEC_MODE_ENABLE, &err);
57 
58  // Input
59  m_pixelClusterInputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_ONLY, EFTrackingTransient::PIXEL_CONTAINER_INPUT_BUF_SIZE * sizeof(uint64_t), NULL, &err));
60  m_stripClusterInputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_ONLY, EFTrackingTransient::STRIP_CONTAINER_INPUT_BUF_SIZE * sizeof(uint64_t), NULL, &err));
61 
62  // Clustering
63  m_pixelClusterOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE,EFTrackingTransient::PIXEL_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
64  m_stripClusterOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::STRIP_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
65  m_pixelClusterEDMOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE,EFTrackingTransient::PIXEL_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
66  m_stripClusterEDMOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::STRIP_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
67 
68  // L2G
69  m_pixelL2GOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::PIXEL_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
70  m_pixelL2GEDMOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::PIXEL_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
71  m_stripL2GOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::STRIP_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
72  m_stripL2GEDMOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::STRIP_BLOCK_BUF_SIZE * sizeof(uint64_t), NULL, &err));
73 
74  // EDMPrep
75  m_edmPixelOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::PIXEL_CONTAINER_BUF_SIZE * sizeof(uint64_t), NULL, &err));
76  m_edmStripOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::STRIP_CONTAINER_BUF_SIZE * sizeof(uint64_t), NULL, &err));
77  }
78 
79  // Create kernels for each one of CUs that is inside device
80  for (const auto& cuName: listofCUs)
81  {
82  // Pixel clustering
83  if(cuName.find(m_pixelEndClusterKernelName.value()) != std::string::npos) m_pixelEndClusteringClusterKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
84  else if(cuName.find(m_pixelEndClusterEdmKernelName.value()) != std::string::npos) m_pixelEndClusteringEDMKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
85  else if(cuName.find(m_pixelStartClusterKernelName.value()) != std::string::npos) m_pixelStartClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
86 
87  // Strip clustering
88  else if(cuName.find(m_stripEndClusterKernelName.value()) != std::string::npos) m_stripEndClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
89  else if(cuName.find(m_stripStartClusterKernelName.value()) != std::string::npos) m_stripStartClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
90 
91  // Pixel L2G
92  else if(cuName.find(m_pixelL2GKernelName.value()) != std::string::npos) m_pixelL2GKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
93 
94  // Strip L2G
95  else if(cuName.find(m_stripL2GKernelName.value()) != std::string::npos) m_stripL2GKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
96 
97  // EDM prep
98  else if(cuName.find(m_pixelEdmKernelName.value()) != std::string::npos) m_pixelEdmPrepKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
99 
100  else if(cuName.find(m_stripEdmKernelName.value()) != std::string::npos) m_stripEdmPrepKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
101  else
102  {
103  ATH_MSG_WARNING("Do not recognize kernel name: "<<cuName);
104  }
105  }
106 
107  ATH_MSG_INFO(m_pixelStartClusterKernelName.value()<<" size: "<<m_pixelStartClusteringKernels.size());
108  ATH_MSG_INFO(m_pixelEndClusterKernelName.value()<<" size: "<<m_pixelEndClusteringClusterKernels.size());
109  ATH_MSG_INFO(m_pixelEndClusterEdmKernelName.value()<<" size: "<<m_pixelEndClusteringEDMKernels.size());
110  ATH_MSG_INFO(m_stripStartClusterKernelName.value()<<" size: "<<m_stripStartClusteringKernels.size());
111  ATH_MSG_INFO(m_stripEndClusterKernelName.value()<<" size: "<<m_stripEndClusteringKernels.size());
112  ATH_MSG_INFO(m_stripL2GKernelName.value()<<" size: "<<m_stripL2GKernels.size());
113  ATH_MSG_INFO(m_pixelEdmKernelName.value()<<" size: "<<m_pixelEdmPrepKernels.size());
114  ATH_MSG_INFO(m_stripEdmKernelName.value()<<" size: "<<m_stripEdmPrepKernels.size());
115 
116 
117  return StatusCode::SUCCESS;
118  }

◆ inputHandles()

virtual std::vector<Gaudi::DataHandle*> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::inputHandles ( ) const
overridevirtualinherited

Return this algorithm's input handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

◆ isClonable()

bool AthCommonReentrantAlgorithm< Gaudi::Algorithm >::isClonable
overridevirtualinherited

Specify if the algorithm is clonable.

Reentrant algorithms are clonable.

Definition at line 68 of file AthCommonReentrantAlgorithm.cxx.

52 {
53  // Reentrant algorithms are clonable.
54  return true;
55 }

◆ loadProgram()

StatusCode IntegrationBase::loadProgram ( const std::string &  xclbin)
inherited

Find the xclbin file and load it into the OpenCL program object.

Definition at line 115 of file IntegrationBase.cxx.

116 {
117  // Open binary object in binary mode
118  std::ifstream bin_file(xclbin, std::ios_base::binary);
119  if (!bin_file)
120  {
121  ATH_MSG_ERROR("Couldn't find the xclbin file: " << xclbin);
122  return StatusCode::FAILURE;
123  }
124  // Get the size of the binary file
125  bin_file.seekg(0, bin_file.end);
126  unsigned bin_size = bin_file.tellg();
127  // Reset the reference point back to the beginning
128  bin_file.seekg(0, bin_file.beg);
129  // Create a new pointer for the binary buffer and get the set a pointer to the binary buffer
130  std::vector<char> buf(bin_size);
131  bin_file.read(buf.data(), bin_size);
132 
133  // Create binary object and program object
134  cl_int err = 0;
135  std::vector<cl_int> binaryStatus;
136  cl::Program::Binaries bins{{buf.data(), bin_size}};
137  m_program = cl::Program(m_context, {m_accelerator}, bins, &binaryStatus, &err);
138 
139  bin_file.close();
140 
141  if (err == CL_SUCCESS && binaryStatus.at(0) == CL_SUCCESS)
142  {
143  ATH_MSG_INFO("Successfully loaded xclbin file into " << m_accelerator.getInfo<CL_DEVICE_NAME>());
144  }
145  else
146  {
147  ATH_MSG_ERROR("Error loading xclbin file (" << xclbin << ") into " << m_accelerator.getInfo<CL_DEVICE_NAME>() <<". Error code: " << err);
148  return StatusCode::FAILURE;
149  }
150 
151  return StatusCode::SUCCESS;
152 }

◆ msg() [1/2]

MsgStream& AthCommonMsg< Gaudi::Algorithm >::msg ( ) const
inlineinherited

Definition at line 24 of file AthCommonMsg.h.

24  {
25  return this->msgStream();
26  }

◆ msg() [2/2]

MsgStream& AthCommonMsg< Gaudi::Algorithm >::msg ( const MSG::Level  lvl) const
inlineinherited

Definition at line 27 of file AthCommonMsg.h.

27  {
28  return this->msgStream(lvl);
29  }

◆ msgLvl()

bool AthCommonMsg< Gaudi::Algorithm >::msgLvl ( const MSG::Level  lvl) const
inlineinherited

Definition at line 30 of file AthCommonMsg.h.

30  {
31  return this->msgLevel(lvl);
32  }

◆ outputHandles()

virtual std::vector<Gaudi::DataHandle*> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::outputHandles ( ) const
overridevirtualinherited

Return this algorithm's output handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

◆ precheck()

StatusCode IntegrationBase::precheck ( const std::vector< Gaudi::Property< std::string >> &  inputs) const
inherited

Check if the the desired Gaudi properties are set.

Definition at line 154 of file IntegrationBase.cxx.

155 {
156  for(const auto &item : inputs)
157  {
158  if(item.empty())
159  {
160  ATH_MSG_FATAL(item.documentation()<<" is empty. Please set it to a valid value");
161  return StatusCode::FAILURE;
162  }
163  }
164 
165  // Always check if bdf is set
166  if (m_deviceBDF.empty())
167  {
168  ATH_MSG_WARNING("Device BDF is not set. Using the first found accelerator card. Set property 'bdfID' to specify the BDF of the device.");
169  }
170 
171  return StatusCode::SUCCESS;
172 }

◆ renounce()

std::enable_if_t<std::is_void_v<std::result_of_t<decltype(&T::renounce)(T)> > && !std::is_base_of_v<SG::VarHandleKeyArray, T> && std::is_base_of_v<Gaudi::DataHandle, T>, void> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::renounce ( T &  h)
inlineprotectedinherited

Definition at line 380 of file AthCommonDataStore.h.

381  {
382  h.renounce();
383  PBASE::renounce (h);
384  }

◆ renounceArray()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::renounceArray ( SG::VarHandleKeyArray handlesArray)
inlineprotectedinherited

remove all handles from I/O resolution

Definition at line 364 of file AthCommonDataStore.h.

364  {
365  handlesArray.renounce();
366  }

◆ setFilterPassed()

virtual void AthCommonReentrantAlgorithm< Gaudi::Algorithm >::setFilterPassed ( bool  state,
const EventContext &  ctx 
) const
inlinevirtualinherited

Definition at line 100 of file AthCommonReentrantAlgorithm.h.

100  {
101  execState( ctx ).setFilterPassed( state );
102  }

◆ sysExecute()

StatusCode AthCommonReentrantAlgorithm< Gaudi::Algorithm >::sysExecute ( const EventContext &  ctx)
overridevirtualinherited

Execute an algorithm.

We override this in order to work around an issue with the Algorithm base class storing the event context in a member variable that can cause crashes in MT jobs.

Definition at line 85 of file AthCommonReentrantAlgorithm.cxx.

77 {
78  return BaseAlg::sysExecute (ctx);
79 }

◆ sysInitialize()

StatusCode AthCommonReentrantAlgorithm< Gaudi::Algorithm >::sysInitialize
overridevirtualinherited

Override sysInitialize.

Override sysInitialize from the base class.

Loop through all output handles, and if they're WriteCondHandles, automatically register them and this Algorithm with the CondSvc

Scan through all outputHandles, and if they're WriteCondHandles, register them with the CondSvc

Reimplemented from AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >.

Reimplemented in InputMakerBase, and HypoBase.

Definition at line 61 of file AthCommonReentrantAlgorithm.cxx.

107  {
109 
110  if (sc.isFailure()) {
111  return sc;
112  }
113 
114  ServiceHandle<ICondSvc> cs("CondSvc",name());
115  for (auto h : outputHandles()) {
116  if (h->isCondition() && h->mode() == Gaudi::DataHandle::Writer) {
117  // do this inside the loop so we don't create the CondSvc until needed
118  if ( cs.retrieve().isFailure() ) {
119  ATH_MSG_WARNING("no CondSvc found: won't autoreg WriteCondHandles");
120  return StatusCode::SUCCESS;
121  }
122  if (cs->regHandle(this,*h).isFailure()) {
123  sc = StatusCode::FAILURE;
124  ATH_MSG_ERROR("unable to register WriteCondHandle " << h->fullKey()
125  << " with CondSvc");
126  }
127  }
128  }
129  return sc;
130 }

◆ sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::sysStart ( )
overridevirtualinherited

Handle START transition.

We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.

◆ updateVHKA()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::updateVHKA ( Gaudi::Details::PropertyBase &  )
inlineinherited

Definition at line 308 of file AthCommonDataStore.h.

308  {
309  // debug() << "updateVHKA for property " << p.name() << " " << p.toString()
310  // << " size: " << m_vhka.size() << endmsg;
311  for (auto &a : m_vhka) {
312  std::vector<SG::VarHandleKey*> keys = a->keys();
313  for (auto k : keys) {
314  k->setOwner(this);
315  }
316  }
317  }

Member Data Documentation

◆ ATLAS_THREAD_SAFE [1/9]

std::vector<cl::Kernel> m_pixelStartClusteringKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 87 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [2/9]

std::vector<cl::Kernel> m_pixelEndClusteringClusterKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 88 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [3/9]

std::vector<cl::Kernel> m_pixelEndClusteringEDMKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 89 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [4/9]

std::vector<cl::Kernel> m_stripStartClusteringKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 90 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [5/9]

std::vector<cl::Kernel> m_stripEndClusteringKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 91 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [6/9]

std::vector<cl::Kernel> m_pixelL2GKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 94 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [7/9]

std::vector<cl::Kernel> m_stripL2GKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 95 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [8/9]

std::vector<cl::Kernel> m_pixelEdmPrepKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 98 of file F100StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [9/9]

std::vector<cl::Kernel> m_stripEdmPrepKernels EFTrackingFPGAIntegration::F100StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 99 of file F100StreamIntegrationAlg.h.

◆ m_acc_queues

std::vector<cl::CommandQueue> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_acc_queues
private

Definition at line 119 of file F100StreamIntegrationAlg.h.

◆ m_accelerator

cl::Device IntegrationBase::m_accelerator
protectedinherited

Device object for the accelerator card.

Definition at line 66 of file IntegrationBase.h.

◆ m_chronoSvc

ServiceHandle<IChronoSvc> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_chronoSvc {"ChronoStatSvc", name()}
private

Service for timing the algorithm.

Definition at line 42 of file F100StreamIntegrationAlg.h.

◆ m_context

cl::Context IntegrationBase::m_context
protectedinherited

Context object for the application.

Definition at line 67 of file IntegrationBase.h.

◆ m_detStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_detStore
privateinherited

Pointer to StoreGate (detector store by default)

Definition at line 393 of file AthCommonDataStore.h.

◆ m_deviceBDF

Gaudi::Property<std::string> IntegrationBase::m_deviceBDF {this, "bdfID", "", "BDF ID of the accelerator card"}
protectedinherited

BDF ID of the accelerator card.

Definition at line 69 of file IntegrationBase.h.

◆ m_doEmulation

Gaudi::Property<bool> IntegrationBase::m_doEmulation {this, "doEmulation", false, "If software or hardware emulation is being used for debugging"}
protectedinherited

Definition at line 70 of file IntegrationBase.h.

◆ m_edmPixelOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_edmPixelOutputBufferList
private

Definition at line 115 of file F100StreamIntegrationAlg.h.

◆ m_edmStripOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_edmStripOutputBufferList
private

Definition at line 116 of file F100StreamIntegrationAlg.h.

◆ m_evtStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_evtStore
privateinherited

Pointer to StoreGate (event store by default)

Definition at line 390 of file AthCommonDataStore.h.

◆ m_extendedExtraObjects

DataObjIDColl AthCommonReentrantAlgorithm< Gaudi::Algorithm >::m_extendedExtraObjects
privateinherited

Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.

Empty if no symlinks were found.

Definition at line 114 of file AthCommonReentrantAlgorithm.h.

◆ m_FPGAPixelOutput

SG::WriteHandleKey<std::vector<uint64_t> > EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAPixelOutput {this, "FPGAOutputPixelKey", "FPGAPixelOutput", "Pixel output from FPGA format"}
private

Definition at line 47 of file F100StreamIntegrationAlg.h.

◆ m_FPGAPixelRDO

SG::ReadHandleKey<std::vector<uint64_t> > EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAPixelRDO {this, "FPGAEncodedPixelKey", "FPGAEncodedPixelRDOs", "Pixel RDO converted to FPGA format"}
private

Definition at line 44 of file F100StreamIntegrationAlg.h.

◆ m_FPGAStripOutput

SG::WriteHandleKey<std::vector<uint64_t> > EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAStripOutput {this, "FPGAOutputStripKey", "FPGAStripOutput", "Strip output from FPGA format"}
private

Definition at line 48 of file F100StreamIntegrationAlg.h.

◆ m_FPGAStripRDO

SG::ReadHandleKey<std::vector<uint64_t> > EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAStripRDO {this, "FPGAEncodedStripKey", "FPGAEncodedStripRDOs", "Strip RDO converted to FPGA format"}
private

Definition at line 45 of file F100StreamIntegrationAlg.h.

◆ m_FPGAThreads

Gaudi::Property<int> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAThreads {this, "FPGAThreads", 1, "number of FPGA threads to initialize"}
private

Definition at line 50 of file F100StreamIntegrationAlg.h.

◆ m_kernelTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_kernelTime {0}
mutableprivate

Time for kernel execution.

Definition at line 83 of file F100StreamIntegrationAlg.h.

◆ m_numEvents

std::atomic<ulonglong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_numEvents {0}
mutableprivate

Number of events processed.

Definition at line 72 of file F100StreamIntegrationAlg.h.

◆ m_pixelClusterEDMOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusterEDMOutputBufferList
private

Definition at line 107 of file F100StreamIntegrationAlg.h.

◆ m_pixelClusteringTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusteringTime {0}
mutableprivate

Time for pixel clustering.

Definition at line 75 of file F100StreamIntegrationAlg.h.

◆ m_pixelClusterInputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusterInputBufferList
private

Definition at line 102 of file F100StreamIntegrationAlg.h.

◆ m_pixelClusterOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusterOutputBufferList
private

Definition at line 105 of file F100StreamIntegrationAlg.h.

◆ m_pixelEdmKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEdmKernelName {this, "PixelEDMPrepKernelName", "", "Name of the FPGA kernel"}
private

Name of the FPGA kernel.

Definition at line 55 of file F100StreamIntegrationAlg.h.

◆ m_pixelEdmPrepTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEdmPrepTime {0}
mutableprivate

Time for pixel EDM preparation.

Definition at line 79 of file F100StreamIntegrationAlg.h.

◆ m_pixelEndClusterEdmKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEndClusterEdmKernelName {this, "PixelEndClusterEdmKernelName", "", "Name of the pixel clustering end kernel"}
private

Name of the pixel clustering kernel start.

Definition at line 61 of file F100StreamIntegrationAlg.h.

◆ m_pixelEndClusterKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEndClusterKernelName {this, "PixelEndClusterKernelName", "", "Name of the pixel clustering end kernel"}
private

Name of the pixel clustering kernel start.

Definition at line 60 of file F100StreamIntegrationAlg.h.

◆ m_pixelInputTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelInputTime {0}
mutableprivate

Time for pixel input buffer write.

Definition at line 73 of file F100StreamIntegrationAlg.h.

◆ m_pixelL2GEDMOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GEDMOutputBufferList
private

Definition at line 112 of file F100StreamIntegrationAlg.h.

◆ m_pixelL2GKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GKernelName {this, "PixelL2GKernelName", "", "Name of the pixel L2G kernel"}
private

Name of the pixel L2G kernel.

Definition at line 67 of file F100StreamIntegrationAlg.h.

◆ m_pixelL2GOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GOutputBufferList
private

Definition at line 110 of file F100StreamIntegrationAlg.h.

◆ m_pixelL2GTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GTime {0}
mutableprivate

Time for pixel L2G.

Definition at line 77 of file F100StreamIntegrationAlg.h.

◆ m_pixelOutputTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelOutputTime {0}
mutableprivate

Time for pixel output buffer read.

Definition at line 81 of file F100StreamIntegrationAlg.h.

◆ m_pixelStartClusterKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelStartClusterKernelName {this, "PixelStartClusterKernelName", "", "Name of the pixel clustering start kernel"}
private

Name of the pixel clustering kernel start.

Definition at line 59 of file F100StreamIntegrationAlg.h.

◆ m_program

cl::Program IntegrationBase::m_program
protectedinherited

Program object containing the kernel.

Definition at line 68 of file IntegrationBase.h.

◆ m_stripClusterEDMOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusterEDMOutputBufferList
private

Definition at line 108 of file F100StreamIntegrationAlg.h.

◆ m_stripClusteringTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusteringTime {0}
mutableprivate

Time for strip clustering.

Definition at line 76 of file F100StreamIntegrationAlg.h.

◆ m_stripClusterInputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusterInputBufferList
private

Definition at line 103 of file F100StreamIntegrationAlg.h.

◆ m_stripClusterOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusterOutputBufferList
private

Definition at line 106 of file F100StreamIntegrationAlg.h.

◆ m_stripEdmKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripEdmKernelName {this, "StripEDMPrepKernelName", "", "Name of the FPGA kernel"}
private

Name of the FPGA kernel.

Definition at line 57 of file F100StreamIntegrationAlg.h.

◆ m_stripEdmPrepTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripEdmPrepTime {0}
mutableprivate

Time for strip EDM preparation.

Definition at line 80 of file F100StreamIntegrationAlg.h.

◆ m_stripEndClusterKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripEndClusterKernelName {this, "StripEndClusterKernelName", "", "Name of the strip clustering end kernel"}
private

Name of the strip clustering kernel start.

Definition at line 64 of file F100StreamIntegrationAlg.h.

◆ m_stripInputTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripInputTime {0}
mutableprivate

Time for strip input buffer write.

Definition at line 74 of file F100StreamIntegrationAlg.h.

◆ m_stripL2GEDMOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GEDMOutputBufferList
private

Definition at line 113 of file F100StreamIntegrationAlg.h.

◆ m_stripL2GKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GKernelName {this, "StripL2GKernelName", "", "Name of the strip L2G kernel"}
private

Name of the strip L2G kernelS.

Definition at line 68 of file F100StreamIntegrationAlg.h.

◆ m_stripL2GOutputBufferList

std::vector<cl::Buffer> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GOutputBufferList
private

Definition at line 111 of file F100StreamIntegrationAlg.h.

◆ m_stripL2GTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GTime {0}
mutableprivate

Time for strip L2G.

Definition at line 78 of file F100StreamIntegrationAlg.h.

◆ m_stripOutputTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripOutputTime {0}
mutableprivate

Time for strip output buffer read.

Definition at line 82 of file F100StreamIntegrationAlg.h.

◆ m_stripStartClusterKernelName

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripStartClusterKernelName {this, "StripStartClusterKernelName", "", "Name of the strip clustering start kernel"}
private

Name of the strip clustering kernel start.

Definition at line 63 of file F100StreamIntegrationAlg.h.

◆ m_varHandleArraysDeclared

bool AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_varHandleArraysDeclared
privateinherited

Definition at line 399 of file AthCommonDataStore.h.

◆ m_vhka

std::vector<SG::VarHandleKeyArray*> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_vhka
privateinherited

Definition at line 398 of file AthCommonDataStore.h.

◆ m_xclbin

Gaudi::Property<std::string> EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_xclbin {this, "xclbin", "", "xclbin path and name"}
private

Path and name of the xclbin file.

Definition at line 52 of file F100StreamIntegrationAlg.h.


The documentation for this class was generated from the following files:
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAStripRDO
SG::ReadHandleKey< std::vector< uint64_t > > m_FPGAStripRDO
Definition: F100StreamIntegrationAlg.h:45
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAStripOutput
SG::WriteHandleKey< std::vector< uint64_t > > m_FPGAStripOutput
Definition: F100StreamIntegrationAlg.h:48
IntegrationBase::m_accelerator
cl::Device m_accelerator
Device object for the accelerator card.
Definition: IntegrationBase.h:66
IntegrationBase::initialize
virtual StatusCode initialize() override
Detect the OpenCL devices and prepare OpenCL context.
Definition: IntegrationBase.cxx:16
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GEDMOutputBufferList
std::vector< cl::Buffer > m_stripL2GEDMOutputBufferList
Definition: F100StreamIntegrationAlg.h:113
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusteringTime
std::atomic< cl_ulong > m_stripClusteringTime
Time for strip clustering.
Definition: F100StreamIntegrationAlg.h:76
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusterInputBufferList
std::vector< cl::Buffer > m_stripClusterInputBufferList
Definition: F100StreamIntegrationAlg.h:103
ATH_MSG_FATAL
#define ATH_MSG_FATAL(x)
Definition: AthMsgStreamMacros.h:34
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusterOutputBufferList
std::vector< cl::Buffer > m_stripClusterOutputBufferList
Definition: F100StreamIntegrationAlg.h:106
EFTrackingTransient::PIXEL_CONTAINER_BUF_SIZE
constexpr unsigned long PIXEL_CONTAINER_BUF_SIZE
Definition: EFTrackingTransient.h:36
ATH_MSG_INFO
#define ATH_MSG_INFO(x)
Definition: AthMsgStreamMacros.h:31
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEdmKernelName
Gaudi::Property< std::string > m_pixelEdmKernelName
Name of the FPGA kernel.
Definition: F100StreamIntegrationAlg.h:55
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GTime
std::atomic< cl_ulong > m_pixelL2GTime
Time for pixel L2G.
Definition: F100StreamIntegrationAlg.h:77
make_unique
std::unique_ptr< T > make_unique(Args &&... args)
Definition: SkimmingToolEXOT5.cxx:23
max
constexpr double max()
Definition: ap_fixedTest.cxx:33
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripOutputTime
std::atomic< cl_ulong > m_stripOutputTime
Time for strip output buffer read.
Definition: F100StreamIntegrationAlg.h:82
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusterOutputBufferList
std::vector< cl::Buffer > m_pixelClusterOutputBufferList
Definition: F100StreamIntegrationAlg.h:105
JiveXML::Event
struct Event_t Event
Definition: ONCRPCServer.h:65
IntegrationBase::m_context
cl::Context m_context
Context object for the application.
Definition: IntegrationBase.h:67
AthCommonDataStore::renounce
std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void > renounce(T &h)
Definition: AthCommonDataStore.h:380
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GKernelName
Gaudi::Property< std::string > m_pixelL2GKernelName
Name of the pixel L2G kernel.
Definition: F100StreamIntegrationAlg.h:67
AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_evtStore
StoreGateSvc_t m_evtStore
Pointer to StoreGate (event store by default)
Definition: AthCommonDataStore.h:390
AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_vhka
std::vector< SG::VarHandleKeyArray * > m_vhka
Definition: AthCommonDataStore.h:398
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_edmStripOutputBufferList
std::vector< cl::Buffer > m_edmStripOutputBufferList
Definition: F100StreamIntegrationAlg.h:116
read_hist_ntuple.t
t
Definition: read_hist_ntuple.py:5
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::getListofCUs
void getListofCUs(std::vector< std::string > &cuNames)
Definition: F100StreamIntegrationAlg.cxx:360
postInclude.inputs
inputs
Definition: postInclude.SortInput.py:15
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_xclbin
Gaudi::Property< std::string > m_xclbin
Path and name of the xclbin file.
Definition: F100StreamIntegrationAlg.h:52
AthenaPoolTestRead.sc
sc
Definition: AthenaPoolTestRead.py:27
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_numEvents
std::atomic< ulonglong > m_numEvents
Number of events processed.
Definition: F100StreamIntegrationAlg.h:72
SG::VarHandleKeyArray::setOwner
virtual void setOwner(IDataHandleHolder *o)=0
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAPixelOutput
SG::WriteHandleKey< std::vector< uint64_t > > m_FPGAPixelOutput
Definition: F100StreamIntegrationAlg.h:47
IDTPMcnv.htype
htype
Definition: IDTPMcnv.py:29
EFTrackingTransient::PIXEL_BLOCK_BUF_SIZE
constexpr unsigned long PIXEL_BLOCK_BUF_SIZE
Definition: EFTrackingTransient.h:34
PyPoolBrowser.item
item
Definition: PyPoolBrowser.py:129
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GOutputBufferList
std::vector< cl::Buffer > m_stripL2GOutputBufferList
Definition: F100StreamIntegrationAlg.h:111
AthCommonDataStore::declareGaudiProperty
Gaudi::Details::PropertyBase & declareGaudiProperty(Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
specialization for handling Gaudi::Property<SG::VarHandleKey>
Definition: AthCommonDataStore.h:156
AthCommonReentrantAlgorithm::extraOutputDeps
virtual const DataObjIDColl & extraOutputDeps() const override
Return the list of extra output dependencies.
Definition: AthCommonReentrantAlgorithm.cxx:89
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_kernelTime
std::atomic< cl_ulong > m_kernelTime
Time for kernel execution.
Definition: F100StreamIntegrationAlg.h:83
EFTrackingTransient::STRIP_CONTAINER_BUF_SIZE
constexpr unsigned long STRIP_CONTAINER_BUF_SIZE
Definition: EFTrackingTransient.h:37
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelInputTime
std::atomic< cl_ulong > m_pixelInputTime
Time for pixel input buffer write.
Definition: F100StreamIntegrationAlg.h:73
python.utils.AtlRunQueryDQUtils.p
p
Definition: AtlRunQueryDQUtils.py:209
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEndClusterEdmKernelName
Gaudi::Property< std::string > m_pixelEndClusterEdmKernelName
Name of the pixel clustering kernel start.
Definition: F100StreamIntegrationAlg.h:61
AthCommonDataStore
Definition: AthCommonDataStore.h:52
ATH_MSG_ERROR
#define ATH_MSG_ERROR(x)
Definition: AthMsgStreamMacros.h:33
Athena::Chrono
Exception-safe IChronoSvc caller.
Definition: Chrono.h:50
dqt_zlumi_pandas.err
err
Definition: dqt_zlumi_pandas.py:183
AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::outputHandles
virtual std::vector< Gaudi::DataHandle * > outputHandles() const override
Return this algorithm's output handles.
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelStartClusterKernelName
Gaudi::Property< std::string > m_pixelStartClusterKernelName
Name of the pixel clustering kernel start.
Definition: F100StreamIntegrationAlg.h:59
lumiFormat.i
int i
Definition: lumiFormat.py:85
python.DecayParser.buf
buf
print ("=> [%s]"cmd)
Definition: DecayParser.py:26
SG::get
const T * get(const ReadCondHandleKey< T > &key, const EventContext &ctx)
Convenience function to retrieve an object given a ReadCondHandleKey.
Definition: ReadCondHandle.h:287
EL::StatusCode
::StatusCode StatusCode
StatusCode definition for legacy code.
Definition: PhysicsAnalysis/D3PDTools/EventLoop/EventLoop/StatusCode.h:22
ATH_MSG_DEBUG
#define ATH_MSG_DEBUG(x)
Definition: AthMsgStreamMacros.h:29
AthCommonDataStore::declareProperty
Gaudi::Details::PropertyBase & declareProperty(Gaudi::Property< T, V, H > &t)
Definition: AthCommonDataStore.h:145
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAPixelRDO
SG::ReadHandleKey< std::vector< uint64_t > > m_FPGAPixelRDO
Definition: F100StreamIntegrationAlg.h:44
EFTrackingTransient::PIXEL_CONTAINER_INPUT_BUF_SIZE
constexpr unsigned long PIXEL_CONTAINER_INPUT_BUF_SIZE
Definition: EFTrackingTransient.h:42
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_chronoSvc
ServiceHandle< IChronoSvc > m_chronoSvc
Service for timing the algorithm.
Definition: F100StreamIntegrationAlg.h:42
AthCommonReentrantAlgorithm::sysExecute
virtual StatusCode sysExecute(const EventContext &ctx) override
Execute an algorithm.
Definition: AthCommonReentrantAlgorithm.cxx:76
IntegrationBase::m_deviceBDF
Gaudi::Property< std::string > m_deviceBDF
BDF ID of the accelerator card.
Definition: IntegrationBase.h:69
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusterEDMOutputBufferList
std::vector< cl::Buffer > m_pixelClusterEDMOutputBufferList
Definition: F100StreamIntegrationAlg.h:107
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_acc_queues
std::vector< cl::CommandQueue > m_acc_queues
Definition: F100StreamIntegrationAlg.h:119
find_tgc_unfilled_channelids.ip
ip
Definition: find_tgc_unfilled_channelids.py:3
xAOD::uint64_t
uint64_t
Definition: EventInfo_v1.cxx:123
ATH_CHECK
#define ATH_CHECK
Definition: AthCheckMacros.h:40
plotting.yearwise_luminosity_vs_mu.bins
bins
Definition: yearwise_luminosity_vs_mu.py:30
AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_detStore
StoreGateSvc_t m_detStore
Pointer to StoreGate (detector store by default)
Definition: AthCommonDataStore.h:393
IntegrationBase::precheck
StatusCode precheck(const std::vector< Gaudi::Property< std::string >> &inputs) const
Check if the the desired Gaudi properties are set.
Definition: IntegrationBase.cxx:154
SG::VarHandleKey::initialize
StatusCode initialize(bool used=true)
If this object is used as a property, then this should be called during the initialize phase.
Definition: AthToolSupport/AsgDataHandles/Root/VarHandleKey.cxx:103
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripStartClusterKernelName
Gaudi::Property< std::string > m_stripStartClusterKernelName
Name of the strip clustering kernel start.
Definition: F100StreamIntegrationAlg.h:63
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_edmPixelOutputBufferList
std::vector< cl::Buffer > m_edmPixelOutputBufferList
Definition: F100StreamIntegrationAlg.h:115
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripEdmKernelName
Gaudi::Property< std::string > m_stripEdmKernelName
Name of the FPGA kernel.
Definition: F100StreamIntegrationAlg.h:57
IntegrationBase::loadProgram
StatusCode loadProgram(const std::string &xclbin)
Find the xclbin file and load it into the OpenCL program object.
Definition: IntegrationBase.cxx:115
EFTrackingTransient::STRIP_CONTAINER_INPUT_BUF_SIZE
constexpr unsigned long STRIP_CONTAINER_INPUT_BUF_SIZE
Definition: EFTrackingTransient.h:43
SG::VarHandleKeyArray::renounce
virtual void renounce()=0
SG::HandleClassifier::type
std::conditional< std::is_base_of< SG::VarHandleKeyArray, T >::value, VarHandleKeyArrayType, type2 >::type type
Definition: HandleClassifier.h:54
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripClusterEDMOutputBufferList
std::vector< cl::Buffer > m_stripClusterEDMOutputBufferList
Definition: F100StreamIntegrationAlg.h:108
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusterInputBufferList
std::vector< cl::Buffer > m_pixelClusterInputBufferList
Definition: F100StreamIntegrationAlg.h:102
merge_scale_histograms.doc
string doc
Definition: merge_scale_histograms.py:9
name
std::string name
Definition: Control/AthContainers/Root/debug.cxx:240
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_FPGAThreads
Gaudi::Property< int > m_FPGAThreads
Definition: F100StreamIntegrationAlg.h:50
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelOutputTime
std::atomic< cl_ulong > m_pixelOutputTime
Time for pixel output buffer read.
Definition: F100StreamIntegrationAlg.h:81
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEdmPrepTime
std::atomic< cl_ulong > m_pixelEdmPrepTime
Time for pixel EDM preparation.
Definition: F100StreamIntegrationAlg.h:79
EFTrackingTransient::STRIP_BLOCK_BUF_SIZE
constexpr unsigned long STRIP_BLOCK_BUF_SIZE
Definition: EFTrackingTransient.h:35
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripInputTime
std::atomic< cl_ulong > m_stripInputTime
Time for strip input buffer write.
Definition: F100StreamIntegrationAlg.h:74
SG::WriteHandle
Definition: StoreGate/StoreGate/WriteHandle.h:73
a
TList * a
Definition: liststreamerinfos.cxx:10
h
ATH_MSG_WARNING
#define ATH_MSG_WARNING(x)
Definition: AthMsgStreamMacros.h:32
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelClusteringTime
std::atomic< cl_ulong > m_pixelClusteringTime
Time for pixel clustering.
Definition: F100StreamIntegrationAlg.h:75
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GEDMOutputBufferList
std::vector< cl::Buffer > m_pixelL2GEDMOutputBufferList
Definition: F100StreamIntegrationAlg.h:112
SG::getNSlots
size_t getNSlots()
Return the number of event slots.
Definition: SlotSpecificObj.cxx:64
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelEndClusterKernelName
Gaudi::Property< std::string > m_pixelEndClusterKernelName
Name of the pixel clustering kernel start.
Definition: F100StreamIntegrationAlg.h:60
SG::VarHandleBase::vhKey
SG::VarHandleKey & vhKey()
Return a non-const reference to the HandleKey.
Definition: StoreGate/src/VarHandleBase.cxx:629
AthCommonReentrantAlgorithm< Gaudi::Algorithm >::sysInitialize
virtual StatusCode sysInitialize() override
Override sysInitialize.
Definition: AthCommonReentrantAlgorithm.cxx:107
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_pixelL2GOutputBufferList
std::vector< cl::Buffer > m_pixelL2GOutputBufferList
Definition: F100StreamIntegrationAlg.h:110
python.Bindings.keys
keys
Definition: Control/AthenaPython/python/Bindings.py:801
LHEF::Writer
Pythia8::Writer Writer
Definition: Prophecy4fMerger.cxx:12
AthCommonReentrantAlgorithm< Gaudi::Algorithm >::m_extendedExtraObjects
DataObjIDColl m_extendedExtraObjects
Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.
Definition: AthCommonReentrantAlgorithm.h:114
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GKernelName
Gaudi::Property< std::string > m_stripL2GKernelName
Name of the strip L2G kernelS.
Definition: F100StreamIntegrationAlg.h:68
IntegrationBase::m_program
cl::Program m_program
Program object containing the kernel.
Definition: IntegrationBase.h:68
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripEdmPrepTime
std::atomic< cl_ulong > m_stripEdmPrepTime
Time for strip EDM preparation.
Definition: F100StreamIntegrationAlg.h:80
fitman.k
k
Definition: fitman.py:528
ServiceHandle< ICondSvc >
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripL2GTime
std::atomic< cl_ulong > m_stripL2GTime
Time for strip L2G.
Definition: F100StreamIntegrationAlg.h:78
EFTrackingFPGAIntegration::F100StreamIntegrationAlg::m_stripEndClusterKernelName
Gaudi::Property< std::string > m_stripEndClusterKernelName
Name of the strip clustering kernel start.
Definition: F100StreamIntegrationAlg.h:64