ATLAS Offline Software
Loading...
Searching...
No Matches
EFTrackingFPGAIntegration::F110StreamIntegrationAlg Class Reference

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

#include <F110StreamIntegrationAlg.h>

Inheritance diagram for EFTrackingFPGAIntegration::F110StreamIntegrationAlg:

Public Member Functions

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

Protected Member Functions

void renounceArray (SG::VarHandleKeyArray &handlesArray)
 remove all handles from I/O resolution
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.

Protected Attributes

cl::Device m_accelerator
 Device object for the accelerator card.
cl::Context m_context
 Context object for the application.
cl::Program m_program
 Program object containing the kernel.
Gaudi::Property< std::string > m_deviceBDF {this, "bdfID", "", "BDF ID of the accelerator card"}
 BDF ID of the accelerator card.
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>

Private Attributes

ServiceHandle< IChronoSvc > m_chronoSvc {"ChronoStatSvc", name()}
 Service for timing the algorithm.
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::ReadHandleKey< int > m_FPGAPixelRDOSize {this, "FPGAEncodedPixelSizeKey", "FPGAEncodedPixelSizeRDOs", "Pixel RDO converted to FPGA format"}
SG::ReadHandleKey< int > m_FPGAStripRDOSize {this, "FPGAEncodedStripSizeKey", "FPGAEncodedStripSizeRDOs", "Strip RDO converted to FPGA format"}
SG::WriteHandleKey< std::vector< uint32_t > > m_FPGAPixelOutput {this, "FPGAOutputPixelKey", "FPGAPixelOutput", "Pixel output from FPGA format"}
SG::WriteHandleKey< std::vector< uint32_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.
Gaudi::Property< std::string > m_pixelStartClusterKernelName {this, "PixelStartClusterKernelName", "", "Name of the pixel clustering start kernel"}
 Name of the pixel clustering kernel start.
Gaudi::Property< std::string > m_pixelEndClusterKernelName {this, "PixelEndClusterKernelName", "", "Name of the pixel clustering end kernel"}
 Name of the pixel clustering kernel start.
Gaudi::Property< std::string > m_stripStartClusterKernelName {this, "StripStartClusterKernelName", "", "Name of the strip clustering start kernel"}
 Name of the strip clustering kernel start.
Gaudi::Property< std::string > m_stripEndClusterKernelName {this, "StripEndClusterKernelName", "", "Name of the strip clustering end kernel"}
 Name of the strip clustering kernel start.
std::atomic< ulonglong > m_numEvents {0}
 Number of events processed.
std::atomic< cl_ulong > m_pixelInputTime {0}
 Time for pixel input buffer write.
std::atomic< cl_ulong > m_stripInputTime {0}
 Time for strip input buffer write.
std::atomic< cl_ulong > m_pixelPipelineTime {0}
 Time for pixel pipeline.
std::atomic< cl_ulong > m_stripPipelineTime {0}
 Time for strip pipeline.
std::atomic< cl_ulong > m_pixelOutputTime {0}
 Time for pixel output buffer read.
std::atomic< cl_ulong > m_stripOutputTime {0}
 Time for strip output buffer read.
std::vector< cl::Kernel > m_pixelStartClusteringKernels ATLAS_THREAD_SAFE
std::vector< cl::Kernel > m_pixelEndClusteringKernels ATLAS_THREAD_SAFE
std::vector< cl::Kernel > m_stripStartClusteringKernels ATLAS_THREAD_SAFE
std::vector< cl::Kernel > m_stripEndClusteringKernels ATLAS_THREAD_SAFE
std::vector< cl::Buffer > m_pixelClusterInputBufferList
std::vector< cl::Buffer > m_stripClusterInputBufferList
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.
StoreGateSvc_t m_evtStore
 Pointer to StoreGate (event store by default)
StoreGateSvc_t m_detStore
 Pointer to StoreGate (detector store by default)
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 F110StreamIntegrationAlg.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 ( ) const
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.

Definition at line 75 of file AthCommonReentrantAlgorithm.cxx.

64{
65 return 0;
66}

◆ declareGaudiProperty()

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 {
160 hndl.value(),
161 hndl.documentation());
162
163 }
Gaudi::Details::PropertyBase & declareProperty(Gaudi::Property< T, V, H > &t)

◆ declareProperty()

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 }
Gaudi::Details::PropertyBase & declareGaudiProperty(Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
specialization for handling Gaudi::Property<SG::VarHandleKey>

◆ 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.

◆ evtStore()

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.

◆ execute()

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

Should be overriden by derived classes to perform meaningful work.

Input handles

Reimplemented from IntegrationBase.

Definition at line 97 of file F110StreamIntegrationAlg.cxx.

98 {
99 ATH_MSG_DEBUG("Executing F110StreamIntegrationAlg");
100 m_numEvents++;
101
103 const std::vector<uint64_t>* pixelInput{nullptr}, *stripInput{nullptr};
104 ATH_CHECK(SG::get(pixelInput, m_FPGAPixelRDO, ctx));
105 ATH_CHECK(SG::get(stripInput, m_FPGAStripRDO, ctx));
106
107 const int* pixelInputSize{nullptr}, *stripInputSize{nullptr};
108 ATH_CHECK(SG::get(pixelInputSize, m_FPGAPixelRDOSize, ctx));
109 ATH_CHECK(SG::get(stripInputSize, m_FPGAStripRDOSize, ctx));
110
111 // logic
112 unsigned int nthreads = m_FPGAThreads.value();
113
114 if(m_FPGAThreads.value() < 1){
115 nthreads = SG::getNSlots();
116 }
117
118 size_t bufferIndex = ctx.slot() % nthreads;
119
120 // Get index for each of the kernels
121 size_t pixelStartClusterIndex = ctx.slot() % m_pixelStartClusteringKernels.size();
122 size_t pixelEndClusterIndex = ctx.slot() % m_pixelEndClusteringKernels.size();
123 size_t stripStartClusterIndex = ctx.slot() % m_stripStartClusteringKernels.size();
124 size_t stripEndClusterIndex = ctx.slot() % m_stripEndClusteringKernels.size();
125
126
127 const cl::CommandQueue &acc_queue = m_acc_queues[bufferIndex];
128
129 ATH_MSG_INFO("Thread number "<<ctx.slot()<<" running on buffer "<<bufferIndex<<" pixelStartClusterIndex: "<< pixelStartClusterIndex<<" stripStartClusterIndex: "<< stripStartClusterIndex<<" stripEndClusterIndex: "<< stripEndClusterIndex);
130
131 cl::Kernel &pixelStartClusteringKernel = m_pixelStartClusteringKernels[pixelStartClusterIndex];
132 cl::Kernel &pixelEndClusteringKernel = m_pixelEndClusteringKernels[pixelEndClusterIndex];
133 cl::Kernel &stripStartClusteringKernel = m_stripStartClusteringKernels[stripStartClusterIndex];
134 cl::Kernel &stripEndClusteringKernel = m_stripEndClusteringKernels[stripEndClusterIndex];
135
136 // Set kernel arguments
137 pixelStartClusteringKernel.setArg(0, m_pixelClusterInputBufferList[bufferIndex]);
138 pixelStartClusteringKernel.setArg(2, static_cast<unsigned long long>(*pixelInputSize));
139
140 pixelEndClusteringKernel.setArg(2, m_edmPixelOutputBufferList[bufferIndex]);
141
142
143 stripStartClusteringKernel.setArg(0, m_stripClusterInputBufferList[bufferIndex]);
144 stripStartClusteringKernel.setArg(2, static_cast<unsigned long long>(*stripInputSize));
145
146 stripEndClusteringKernel.setArg(2, m_edmStripOutputBufferList[bufferIndex]);
147
148 // Start the transfers
149 cl::Event evt_write_pixel_input;
150 cl::Event evt_write_strip_input;
151
152 acc_queue.enqueueWriteBuffer(m_pixelClusterInputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint64_t) * (*pixelInput).size(), (*pixelInput).data(), NULL, &evt_write_pixel_input);
153 acc_queue.enqueueWriteBuffer(m_stripClusterInputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint64_t) * (*stripInput).size(), (*stripInput).data(), NULL, &evt_write_strip_input);
154 std::vector<cl::Event> evt_vec_pixel_input{evt_write_pixel_input};
155 std::vector<cl::Event> evt_vec_strip_input{evt_write_strip_input};
156
157
158 cl::Event evt_pixel_start_clustering;
159 cl::Event evt_pixel_end_clustering;
160 cl::Event evt_strip_start_clustering;
161 cl::Event evt_strip_end_clustering;
162
163 {
164 Athena::Chrono chrono("Kernel execution", m_chronoSvc.get());
165
166 acc_queue.enqueueTask(pixelStartClusteringKernel, &evt_vec_pixel_input, &evt_pixel_start_clustering);
167 acc_queue.enqueueTask(pixelEndClusteringKernel, NULL , &evt_pixel_end_clustering);
168
169 acc_queue.enqueueTask(stripStartClusteringKernel, &evt_vec_strip_input, &evt_strip_start_clustering);
170 acc_queue.enqueueTask(stripEndClusteringKernel, NULL, &evt_strip_end_clustering);
171
172 }
173
174 cl::Event evt_pixel_cluster_output;
175 cl::Event evt_strip_cluster_output;
176
177 std::vector<cl::Event> evt_vec_pixel_done{evt_pixel_end_clustering};
178 std::vector<cl::Event> evt_vec_strip_done{evt_strip_end_clustering};
179
180
181 // output handles
182
183 SG::WriteHandle<std::vector<uint32_t>> FPGAPixelOutput(m_FPGAPixelOutput, ctx);
184 ATH_CHECK(FPGAPixelOutput.record(std::make_unique<std::vector<uint32_t> >(EFTrackingTransient::PIXEL_CONTAINER_BUF_SIZE, 0)));
185
186 SG::WriteHandle<std::vector<uint32_t>> FPGAStripOutput(m_FPGAStripOutput, ctx);
187 ATH_CHECK(FPGAStripOutput.record(std::make_unique<std::vector<uint32_t> >(EFTrackingTransient::STRIP_CONTAINER_BUF_SIZE, 0)));
188
189 acc_queue.enqueueReadBuffer(m_edmPixelOutputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint32_t) * (*FPGAPixelOutput).size(), (*FPGAPixelOutput).data(), &evt_vec_pixel_done, &evt_pixel_cluster_output);
190 acc_queue.enqueueReadBuffer(m_edmStripOutputBufferList[bufferIndex], CL_FALSE, 0, sizeof(uint32_t) * (*FPGAStripOutput).size(), (*FPGAStripOutput).data(), &evt_vec_strip_done, &evt_strip_cluster_output);
191
192 std::vector<cl::Event> wait_for_reads = { evt_pixel_cluster_output, evt_strip_cluster_output};
193 cl::Event::waitForEvents(wait_for_reads);
194
195
196 if(*pixelInputSize == 6) (*FPGAPixelOutput)[0] = 0; // if no pixel input, set the first element to 0
197 if(*stripInputSize == 6) (*FPGAStripOutput)[0] = 0; // if no strip input, set the first element to 0
198
199
200 // calculate the time for the kernel execution
201 // get the time of writing pixel input buffer
202 cl_ulong pixel_input_time = evt_write_pixel_input.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_write_pixel_input.getProfilingInfo<CL_PROFILING_COMMAND_START>();
203 m_pixelInputTime += pixel_input_time;
204
205 // get the time of writing strip input buffer
206 cl_ulong strip_input_time = evt_write_strip_input.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_write_strip_input.getProfilingInfo<CL_PROFILING_COMMAND_START>();
207 m_stripInputTime += strip_input_time;
208
209 // get the time of pixel clustering
210 cl_ulong pixel_clustering_time = evt_pixel_end_clustering.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_start_clustering.getProfilingInfo<CL_PROFILING_COMMAND_START>();
211 m_pixelPipelineTime += pixel_clustering_time;
212
213 // get the time of strip clustering
214 cl_ulong strip_clustering_time = evt_strip_end_clustering.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_strip_start_clustering.getProfilingInfo<CL_PROFILING_COMMAND_START>();
215 m_stripPipelineTime += strip_clustering_time;
216
217 // get the time of reading pixel output buffer
218 cl_ulong pixel_output_time = evt_pixel_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_pixel_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_START>();
219 m_pixelOutputTime += pixel_output_time;
220
221 // get the time of reading strip output buffer
222 cl_ulong strip_output_time = evt_strip_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_END>() - evt_strip_cluster_output.getProfilingInfo<CL_PROFILING_COMMAND_START>();
223 m_stripOutputTime += strip_output_time;
224
225 return StatusCode::SUCCESS;
226 }
#define ATH_CHECK
Evaluate an expression and check for errors.
#define ATH_MSG_INFO(x)
#define ATH_MSG_DEBUG(x)
std::atomic< cl_ulong > m_stripPipelineTime
Time for strip pipeline.
SG::WriteHandleKey< std::vector< uint32_t > > m_FPGAPixelOutput
SG::WriteHandleKey< std::vector< uint32_t > > m_FPGAStripOutput
SG::ReadHandleKey< std::vector< uint64_t > > m_FPGAStripRDO
std::atomic< cl_ulong > m_stripInputTime
Time for strip input buffer write.
std::atomic< cl_ulong > m_stripOutputTime
Time for strip output buffer read.
ServiceHandle< IChronoSvc > m_chronoSvc
Service for timing the algorithm.
std::atomic< cl_ulong > m_pixelPipelineTime
Time for pixel pipeline.
SG::ReadHandleKey< std::vector< uint64_t > > m_FPGAPixelRDO
std::atomic< cl_ulong > m_pixelInputTime
Time for pixel input buffer write.
std::atomic< ulonglong > m_numEvents
Number of events processed.
std::atomic< cl_ulong > m_pixelOutputTime
Time for pixel output buffer read.
constexpr uint32_t STRIP_CONTAINER_BUF_SIZE
constexpr uint32_t PIXEL_CONTAINER_BUF_SIZE
size_t getNSlots()
Return the number of event slots.
const T * get(const ReadCondHandleKey< T > &key, const EventContext &ctx)
Convenience function to retrieve an object given a ReadCondHandleKey.

◆ 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 ( ) const
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 }
97}
An algorithm that can be simultaneously executed in multiple threads.

◆ 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 }
virtual bool filterPassed(const EventContext &ctx) const

◆ finalize()

StatusCode EFTrackingFPGAIntegration::F110StreamIntegrationAlg::finalize ( )
finaloverridevirtual

Definition at line 228 of file F110StreamIntegrationAlg.cxx.

229 {
230
231 ATH_MSG_INFO("Finalizing F110StreamIntegrationAlg");
232 ATH_MSG_INFO("Number of events: " << m_numEvents);
233
234 if(m_numEvents > 0){
235 ATH_MSG_INFO("Pixel input ave time: " << m_pixelInputTime / m_numEvents / 1e6 << " ms");
236 ATH_MSG_INFO("Strip input ave time: " << m_stripInputTime / m_numEvents / 1e6 << " ms");
237 ATH_MSG_INFO("Pixel pipeline ave time: " << m_pixelPipelineTime / m_numEvents / 1e6 << " ms");
238 ATH_MSG_INFO("Strip pipeline ave time: " << m_stripPipelineTime / m_numEvents / 1e6 << " ms");
239 ATH_MSG_INFO("Pixel output ave time: " << m_pixelOutputTime / m_numEvents / 1e6 << " ms");
240 ATH_MSG_INFO("Strip output ave time: " << m_stripOutputTime / m_numEvents / 1e6 << " ms");
241 }
242
243 return StatusCode::SUCCESS;
244 }

◆ getListofCUs()

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

Definition at line 246 of file F110StreamIntegrationAlg.cxx.

247 {
248 xrt::xclbin xrt_xclbin(m_xclbin.value());
249
250 ATH_MSG_INFO("xsa name: "<<xrt_xclbin.get_xsa_name());
251 ATH_MSG_INFO("fpga name: "<<xrt_xclbin.get_fpga_device_name());
252 ATH_MSG_INFO("uuid: "<<xrt_xclbin.get_uuid().to_string());
253
254 for (const xrt::xclbin::kernel &kernel : xrt_xclbin.get_kernels()) {
255 const std::string& kernelName = kernel.get_name();
256
257 ATH_MSG_INFO("kernelName: "<<kernelName);
258
259
260 for (const xrt::xclbin::ip &computeUnit : kernel.get_cus()) {
261 const std::string& computeUnitName = computeUnit.get_name();
262 const std::string computeUnitIsolatedName = computeUnitName.substr(kernelName.size() + 1);
263
264 const std::string computeUnitUsableName = kernelName + ":{" + computeUnitIsolatedName + "}";
265
266 ATH_MSG_INFO("CU name: "<<computeUnitUsableName);
267 cuNames.push_back(computeUnitUsableName);
268 }
269 }
270 }
Gaudi::Property< std::string > m_xclbin
Path and name of the xclbin file.

◆ initialize()

StatusCode EFTrackingFPGAIntegration::F110StreamIntegrationAlg::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 16 of file F110StreamIntegrationAlg.cxx.

17 {
18 ATH_MSG_INFO("Running on the FPGA accelerator");
19
21
22 ATH_CHECK(m_chronoSvc.retrieve());
23
24 {
25 Athena::Chrono chrono("Platform and device initlize", m_chronoSvc.get());
27 }
28
29 {
30 Athena::Chrono chrono("CL::loadProgram", m_chronoSvc.get());
32 }
33 ATH_MSG_INFO("loading "<<m_xclbin);
34
35
36 ATH_CHECK(m_FPGAPixelRDO.initialize());
37 ATH_CHECK(m_FPGAStripRDO.initialize());
38
39 ATH_CHECK(m_FPGAPixelRDOSize.initialize());
40 ATH_CHECK(m_FPGAStripRDOSize.initialize());
41
42 ATH_CHECK(m_FPGAPixelOutput.initialize());
43 ATH_CHECK(m_FPGAStripOutput.initialize());
44
45 std::vector<std::string> listofCUs;
46
47 getListofCUs(listofCUs);
48
49 cl_int err = 0;
50
51 unsigned int nthreads = m_FPGAThreads.value();
52
53 if(m_FPGAThreads.value() < 1){
54 nthreads = SG::getNSlots();
55 }
56
57 // create the buffers
58 for(unsigned int i = 0; i < nthreads; i++)
59 {
60 m_acc_queues.emplace_back(m_context, m_accelerator, CL_QUEUE_PROFILING_ENABLE | CL_QUEUE_OUT_OF_ORDER_EXEC_MODE_ENABLE, &err);
61
62 // Input
63 m_pixelClusterInputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_ONLY, EFTrackingTransient::PIXEL_CONTAINER_INPUT_BUF_SIZE * sizeof(uint64_t), NULL, &err));
64 m_stripClusterInputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_ONLY, EFTrackingTransient::STRIP_CONTAINER_INPUT_BUF_SIZE * sizeof(uint64_t), NULL, &err));
65
66 // EDMPrep
67 m_edmPixelOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::PIXEL_CONTAINER_BUF_SIZE * sizeof(uint32_t), NULL, &err));
68 m_edmStripOutputBufferList.push_back(cl::Buffer(m_context, CL_MEM_READ_WRITE, EFTrackingTransient::STRIP_CONTAINER_BUF_SIZE * sizeof(uint32_t), NULL, &err));
69 }
70
71 // Create kernels for each one of CUs that is inside device
72 for (const auto& cuName: listofCUs)
73 {
74 // Pixel clustering
75 if(cuName.find(m_pixelEndClusterKernelName.value()) != std::string::npos) m_pixelEndClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
76 else if(cuName.find(m_pixelStartClusterKernelName.value()) != std::string::npos) m_pixelStartClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
77
78 // Strip clustering
79 else if(cuName.find(m_stripEndClusterKernelName.value()) != std::string::npos) m_stripEndClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
80 else if(cuName.find(m_stripStartClusterKernelName.value()) != std::string::npos) m_stripStartClusteringKernels.emplace_back(cl::Kernel(m_program, cuName.c_str()));
81
82 else
83 {
84 ATH_MSG_WARNING("Do not recognize kernel name: "<<cuName);
85 }
86 }
87
88 ATH_MSG_INFO(m_pixelStartClusterKernelName.value()<<" size: "<<m_pixelStartClusteringKernels.size());
89 ATH_MSG_INFO(m_pixelEndClusterKernelName.value()<<" size: "<<m_pixelEndClusteringKernels.size());
90 ATH_MSG_INFO(m_stripStartClusterKernelName.value()<<" size: "<<m_stripStartClusteringKernels.size());
91 ATH_MSG_INFO(m_stripEndClusterKernelName.value()<<" size: "<<m_stripEndClusteringKernels.size());
92
93
94 return StatusCode::SUCCESS;
95 }
#define ATH_MSG_WARNING(x)
Gaudi::Property< std::string > m_stripStartClusterKernelName
Name of the strip clustering kernel start.
Gaudi::Property< std::string > m_pixelStartClusterKernelName
Name of the pixel clustering kernel start.
Gaudi::Property< std::string > m_stripEndClusterKernelName
Name of the strip clustering kernel start.
void getListofCUs(std::vector< std::string > &cuNames)
Gaudi::Property< std::string > m_pixelEndClusterKernelName
Name of the pixel clustering kernel start.
StatusCode loadProgram(const std::string &xclbin)
Find the xclbin file and load it into the OpenCL program object.
cl::Program m_program
Program object containing the kernel.
virtual StatusCode initialize() override
Detect the OpenCL devices and prepare OpenCL context.
cl::Context m_context
Context object for the application.
StatusCode precheck(const std::vector< Gaudi::Property< std::string > > &inputs) const
Check if the the desired Gaudi properties are set.
cl::Device m_accelerator
Device object for the accelerator card.
constexpr unsigned long PIXEL_CONTAINER_INPUT_BUF_SIZE
constexpr unsigned long STRIP_CONTAINER_INPUT_BUF_SIZE

◆ 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()

◆ 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}
#define ATH_MSG_ERROR(x)
static const std::vector< std::string > bins

◆ msg()

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

Definition at line 24 of file AthCommonMsg.h.

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

◆ 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}
#define ATH_MSG_FATAL(x)
Gaudi::Property< std::string > m_deviceBDF
BDF ID of the accelerator card.

◆ 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();
384 }
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)

◆ 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 {
366 }

◆ setFilterPassed()

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

Definition at line 100 of file AthCommonReentrantAlgorithm.h.

100 {
102 }
virtual void setFilterPassed(bool state, const EventContext &ctx) const

◆ 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 HypoBase, and InputMakerBase.

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()) {
124 ATH_MSG_ERROR("unable to register WriteCondHandle " << h->fullKey()
125 << " with CondSvc");
126 }
127 }
128 }
129 return sc;
130}
virtual std::vector< Gaudi::DataHandle * > outputHandles() const override

◆ 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) {
313 for (auto k : keys) {
314 k->setOwner(this);
315 }
316 }
317 }

Member Data Documentation

◆ ATLAS_THREAD_SAFE [1/4]

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

Definition at line 75 of file F110StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [2/4]

std::vector<cl::Kernel> m_pixelEndClusteringKernels EFTrackingFPGAIntegration::F110StreamIntegrationAlg::ATLAS_THREAD_SAFE
mutableprivate

Definition at line 76 of file F110StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [3/4]

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

Definition at line 77 of file F110StreamIntegrationAlg.h.

◆ ATLAS_THREAD_SAFE [4/4]

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

Definition at line 78 of file F110StreamIntegrationAlg.h.

◆ m_acc_queues

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

Definition at line 89 of file F110StreamIntegrationAlg.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::F110StreamIntegrationAlg::m_chronoSvc {"ChronoStatSvc", name()}
private

Service for timing the algorithm.

Definition at line 42 of file F110StreamIntegrationAlg.h.

42{"ChronoStatSvc", name()};

◆ 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.

69{this, "bdfID", "", "BDF ID of the accelerator card"};

◆ 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.

70{this, "doEmulation", false, "If software or hardware emulation is being used for debugging"};

◆ m_edmPixelOutputBufferList

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

Definition at line 85 of file F110StreamIntegrationAlg.h.

◆ m_edmStripOutputBufferList

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

Definition at line 86 of file F110StreamIntegrationAlg.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<uint32_t> > EFTrackingFPGAIntegration::F110StreamIntegrationAlg::m_FPGAPixelOutput {this, "FPGAOutputPixelKey", "FPGAPixelOutput", "Pixel output from FPGA format"}
private

Definition at line 50 of file F110StreamIntegrationAlg.h.

50{this, "FPGAOutputPixelKey", "FPGAPixelOutput", "Pixel output from FPGA format"};

◆ m_FPGAPixelRDO

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

Definition at line 44 of file F110StreamIntegrationAlg.h.

44{this, "FPGAEncodedPixelKey", "FPGAEncodedPixelRDOs", "Pixel RDO converted to FPGA format"};

◆ m_FPGAPixelRDOSize

SG::ReadHandleKey<int> EFTrackingFPGAIntegration::F110StreamIntegrationAlg::m_FPGAPixelRDOSize {this, "FPGAEncodedPixelSizeKey", "FPGAEncodedPixelSizeRDOs", "Pixel RDO converted to FPGA format"}
private

Definition at line 47 of file F110StreamIntegrationAlg.h.

47{this, "FPGAEncodedPixelSizeKey", "FPGAEncodedPixelSizeRDOs", "Pixel RDO converted to FPGA format"};

◆ m_FPGAStripOutput

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

Definition at line 51 of file F110StreamIntegrationAlg.h.

51{this, "FPGAOutputStripKey", "FPGAStripOutput", "Strip output from FPGA format"};

◆ m_FPGAStripRDO

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

Definition at line 45 of file F110StreamIntegrationAlg.h.

45{this, "FPGAEncodedStripKey", "FPGAEncodedStripRDOs", "Strip RDO converted to FPGA format"};

◆ m_FPGAStripRDOSize

SG::ReadHandleKey<int> EFTrackingFPGAIntegration::F110StreamIntegrationAlg::m_FPGAStripRDOSize {this, "FPGAEncodedStripSizeKey", "FPGAEncodedStripSizeRDOs", "Strip RDO converted to FPGA format"}
private

Definition at line 48 of file F110StreamIntegrationAlg.h.

48{this, "FPGAEncodedStripSizeKey", "FPGAEncodedStripSizeRDOs", "Strip RDO converted to FPGA format"};

◆ m_FPGAThreads

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

Definition at line 53 of file F110StreamIntegrationAlg.h.

53{this, "FPGAThreads", 1, "number of FPGA threads to initialize"};

◆ m_numEvents

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

Number of events processed.

Definition at line 64 of file F110StreamIntegrationAlg.h.

64{0};

◆ m_pixelClusterInputBufferList

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

Definition at line 81 of file F110StreamIntegrationAlg.h.

◆ m_pixelEndClusterKernelName

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

Name of the pixel clustering kernel start.

Definition at line 58 of file F110StreamIntegrationAlg.h.

58{this, "PixelEndClusterKernelName", "", "Name of the pixel clustering end kernel"};

◆ m_pixelInputTime

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

Time for pixel input buffer write.

Definition at line 65 of file F110StreamIntegrationAlg.h.

65{0};

◆ m_pixelOutputTime

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

Time for pixel output buffer read.

Definition at line 70 of file F110StreamIntegrationAlg.h.

70{0};

◆ m_pixelPipelineTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F110StreamIntegrationAlg::m_pixelPipelineTime {0}
mutableprivate

Time for pixel pipeline.

Definition at line 68 of file F110StreamIntegrationAlg.h.

68{0};

◆ m_pixelStartClusterKernelName

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

Name of the pixel clustering kernel start.

Definition at line 57 of file F110StreamIntegrationAlg.h.

57{this, "PixelStartClusterKernelName", "", "Name of the pixel clustering start kernel"};

◆ m_program

cl::Program IntegrationBase::m_program
protectedinherited

Program object containing the kernel.

Definition at line 68 of file IntegrationBase.h.

◆ m_stripClusterInputBufferList

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

Definition at line 82 of file F110StreamIntegrationAlg.h.

◆ m_stripEndClusterKernelName

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

Name of the strip clustering kernel start.

Definition at line 61 of file F110StreamIntegrationAlg.h.

61{this, "StripEndClusterKernelName", "", "Name of the strip clustering end kernel"};

◆ m_stripInputTime

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

Time for strip input buffer write.

Definition at line 66 of file F110StreamIntegrationAlg.h.

66{0};

◆ m_stripOutputTime

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

Time for strip output buffer read.

Definition at line 71 of file F110StreamIntegrationAlg.h.

71{0};

◆ m_stripPipelineTime

std::atomic<cl_ulong> EFTrackingFPGAIntegration::F110StreamIntegrationAlg::m_stripPipelineTime {0}
mutableprivate

Time for strip pipeline.

Definition at line 69 of file F110StreamIntegrationAlg.h.

69{0};

◆ m_stripStartClusterKernelName

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

Name of the strip clustering kernel start.

Definition at line 60 of file F110StreamIntegrationAlg.h.

60{this, "StripStartClusterKernelName", "", "Name of the strip clustering start kernel"};

◆ 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::F110StreamIntegrationAlg::m_xclbin {this, "xclbin", "", "xclbin path and name"}
private

Path and name of the xclbin file.

Definition at line 55 of file F110StreamIntegrationAlg.h.

55{this, "xclbin", "", "xclbin path and name"};

The documentation for this class was generated from the following files: