The Gaudi Framework  master (37c0b60a)
GPUCruncher Class Reference

#include </builds/gaudi/Gaudi/GaudiCUDA/src/GPUCruncher.h>

Inheritance diagram for GPUCruncher:
Collaboration diagram for GPUCruncher:

Public Types

using CHM = tbb::concurrent_hash_map< std::string, unsigned int >
 
- Public Types inherited from Gaudi::Algorithm
typedef Gaudi::PluginService::Factory< IAlgorithm *(const std::string &, ISvcLocator *)> Factory
 
- Public Types inherited from extends< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >, IDataHandleHolder >
using base_class = extends
 Typedef to this class. More...
 
using extend_interfaces_base = extend_interfaces< Interfaces... >
 Typedef to the base of this class. More...
 
- Public Types inherited from PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >
using PropertyHolderImpl = PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >
 Typedef used to refer to this class from derived classes, as in. More...
 
- Public Types inherited from CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > >
using base_class = CommonMessaging
 
- Public Types inherited from extend_interfaces< Interfaces... >
using ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids... >::type
 take union of the ext_iids of all Interfaces... More...
 

Public Member Functions

bool isClonable () const override
 
StatusCode execute (const EventContext &ctx) const override
 the execution of the algorithm More...
 
StatusCode initialize () override
 Its initialization. More...
 
StatusCode finalize () override
 the finalization of the algorithm More...
 
double get_runtime () const
 
 GPUCruncher (const std::string &name, ISvcLocator *pSvc)
 
virtual ~GPUCruncher ()
 virtual & protected desctrustor More...
 
- Public Member Functions inherited from Gaudi::AsynchronousAlgorithm
StatusCode sysInitialize () override
 
StatusCode sysExecute (const EventContext &ctx) override
 
virtual StatusCode restoreAfterSuspend () const
 Restore after suspend. More...
 
StatusCode yield () const
 Forwards to boost::this_fiber::yield. More...
 
template<typename Clock , typename Duration >
StatusCode sleep_until (std::chrono::time_point< Clock, Duration > const &sleep_time) const
 Forwards to boost::this_fiber::sleep_until. More...
 
template<typename Rep , typename Period >
StatusCode sleep_for (std::chrono::duration< Rep, Period > const &dur) const
 Forwards to boost::this_fiber::sleep_for. More...
 
- Public Member Functions inherited from Gaudi::Algorithm
 Algorithm (std::string name, ISvcLocator *svcloc, std::string version=PACKAGE_VERSION)
 Constructor. More...
 
StatusCode sysStart () override
 Reinitialization method invoked by the framework. More...
 
StatusCode sysInitialize () override
 Initialization method invoked by the framework. More...
 
StatusCode sysReinitialize () override
 Reinitialization method invoked by the framework. More...
 
StatusCode sysRestart () override
 Restart method invoked by the framework. More...
 
StatusCode sysExecute (const EventContext &ctx) override
 The actions to be performed by the algorithm on an event. More...
 
StatusCode sysStop () override
 System stop. More...
 
StatusCode sysFinalize () override
 System finalization. More...
 
const std::stringname () const override
 The identifying name of the algorithm object. More...
 
const Gaudi::StringKeynameKey () const override
 
const std::stringtype () const override
 The type of the algorithm object. More...
 
void setType (std::string type) override
 
const std::stringversion () const override
 
unsigned int index () const override
 
StatusCode configure () override
 Dummy implementation of IStateful::configure() method. More...
 
StatusCode terminate () override
 Dummy implementation of IStateful::terminate() method. More...
 
StatusCode initialize () override
 the default (empty) implementation of IStateful::initialize() method More...
 
StatusCode start () override
 the default (empty) implementation of IStateful::start() method More...
 
StatusCode stop () override
 the default (empty) implementation of IStateful::stop() method More...
 
StatusCode finalize () override
 the default (empty) implementation of IStateful::finalize() method More...
 
StatusCode reinitialize () override
 the default (empty) implementation of IStateful::reinitialize() method More...
 
StatusCode restart () override
 the default (empty) implementation of IStateful::restart() method More...
 
Gaudi::StateMachine::State FSMState () const override
 returns the current state of the algorithm More...
 
Gaudi::StateMachine::State targetFSMState () const override
 returns the state the algorithm will be in after the ongoing transition More...
 
bool isEnabled () const override
 Is this algorithm enabled or disabled? More...
 
bool isSequence () const override
 Are we a Sequence? More...
 
unsigned int errorCount () const
 Get the number of failures of the algorithm. More...
 
template<class T >
StatusCode service (std::string_view name, T *&psvc, bool createIf=true) const
 Access a service by name, creating it if it doesn't already exist. More...
 
template<class T >
StatusCode service (std::string_view svcType, std::string_view svcName, T *&psvc) const
 Access a service by name and type, creating it if it doesn't already exist. More...
 
SmartIF< IServiceservice (std::string_view name, const bool createIf=true, const bool quiet=false) const
 Return a pointer to the service identified by name (or "type/name") More...
 
template<class T >
SmartIF< T > service (std::string_view name, bool createIf=true, bool quiet=false) const
 
SmartIF< IAuditorSvc > & auditorSvc () const
 The standard auditor service.May not be invoked before sysInitialize() has been invoked. More...
 
SmartIF< IChronoStatSvc > & chronoSvc () const
 The standard Chrono & Stat service, Return a pointer to the service if present. More...
 
SmartIF< IDataProviderSvc > & detSvc () const
 The standard detector data service. More...
 
SmartIF< IConversionSvc > & detCnvSvc () const
 The standard detector data persistency conversion service. More...
 
SmartIF< IDataProviderSvc > & eventSvc () const
 The standard event data service. More...
 
SmartIF< IDataProviderSvc > & evtSvc () const
 shortcut for method eventSvc More...
 
SmartIF< IConversionSvc > & eventCnvSvc () const
 The standard event data persistency conversion service. More...
 
SmartIF< IHistogramSvc > & histoSvc () const
 The standard histogram service. More...
 
SmartIF< INTupleSvc > & ntupleSvc () const
 The standard N tuple service. More...
 
SmartIF< IRndmGenSvc > & randSvc () const
 The standard RandomGen service, Return a pointer to the service if present. More...
 
SmartIF< IToolSvc > & toolSvc () const
 The standard ToolSvc service, Return a pointer to the service if present. More...
 
SmartIF< IExceptionSvc > & exceptionSvc () const
 Get the exception Service. More...
 
SmartIF< IAlgContextSvc > & contextSvc () const
 get Algorithm Context Service More...
 
SmartIF< ITimelineSvc > & timelineSvc () const
 
SmartIF< ISvcLocator > & serviceLocator () const override
 The standard service locator. More...
 
SmartIF< ISvcLocator > & svcLoc () const
 shortcut for method serviceLocator More...
 
SmartIF< IHiveWhiteBoard > & whiteboard () const
 
SmartIF< IAlgExecStateSvc > & algExecStateSvc () const
 
bool registerContext () const
 register for Algorithm Context Service? More...
 
template<class T >
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, ToolHandle< T > &hndl, const std::string &doc="none")
 
template<class T >
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, ToolHandleArray< T > &hndlArr, const std::string &doc="none")
 
SmartIF< IMonitorSvc > & monitorSvc () const
 Access the monitor service. More...
 
template<class T >
void declareInfo (const std::string &name, const T &var, const std::string &desc) const
 Declare monitoring information. More...
 
void declareInfo (const std::string &name, const std::string &format, const void *var, int size, const std::string &desc) const
 Declare monitoring information (special case) More...
 
void acceptDHVisitor (IDataHandleVisitor *) const override
 
void registerTool (IAlgTool *tool) const
 
void deregisterTool (IAlgTool *tool) const
 
template<class T >
StatusCode declareTool (ToolHandle< T > &handle, bool createIf=true)
 
template<class T >
StatusCode declareTool (ToolHandle< T > &handle, const std::string &toolTypeAndName, bool createIf=true)
 
template<class T >
void addToolsArray (ToolHandleArray< T > &hndlArr)
 
const std::vector< IAlgTool * > & tools () const
 
bool isAsynchronous () const
 
void setAsynchronous (bool value)
 
unsigned int cardinality () const override
 Return the cardinality. More...
 
const std::vector< std::string > & neededResources () const override
 
AlgExecStateexecState (const EventContext &ctx) const override
 reference to AlgExecState of Alg More...
 
std::ostreamtoControlFlowExpression (std::ostream &os) const override
 Produce string represention of the control flow expression. More...
 
- Public Member Functions inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > > >
std::vector< Gaudi::DataHandle * > inputHandles () const override
 
std::vector< Gaudi::DataHandle * > outputHandles () const override
 
virtual const DataObjIDCollextraInputDeps () const override
 
virtual const DataObjIDCollextraOutputDeps () const override
 
void declare (Gaudi::DataHandle &handle) override
 
void renounce (Gaudi::DataHandle &handle) override
 
bool renounceInput (const DataObjID &id) override
 
const DataObjIDCollinputDataObjs () const override
 
const DataObjIDColloutputDataObjs () const override
 
void addDependency (const DataObjID &id, const Gaudi::DataHandle::Mode &mode) override
 
- Public Member Functions inherited from extends< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >, IDataHandleHolder >
void * i_cast (const InterfaceID &tid) const override
 Implementation of IInterface::i_cast. More...
 
StatusCode queryInterface (const InterfaceID &ti, void **pp) override
 Implementation of IInterface::queryInterface. More...
 
std::vector< std::stringgetInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
- Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >
 PropertyHolder ()=default
 
Gaudi::Details::PropertyBasedeclareProperty (Gaudi::Details::PropertyBase &prop)
 Declare a property. More...
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, TYPE &value, const std::string &doc="none")
 Helper to wrap a regular data member and use it as a regular property. More...
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, Gaudi::Property< TYPE, VERIFIER, HANDLERS > &prop, const std::string &doc="none")
 Declare a PropertyBase instance setting name and documentation. More...
 
Gaudi::Details::PropertyBasedeclareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="")
 Declare a remote property. More...
 
StatusCode setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p) override
 set the property from another property with a different name More...
 
StatusCode setProperty (const std::string &s) override
 set the property from the formatted string More...
 
StatusCode setProperty (const Gaudi::Details::PropertyBase &p)
 Set the property from a property. More...
 
virtual StatusCode setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p)=0
 Set the property from a property with a different name. More...
 
virtual StatusCode setProperty (const std::string &s)=0
 Set the property by string. More...
 
StatusCode setProperty (const std::string &name, const char *v)
 Special case for string literals. More...
 
StatusCode setProperty (const std::string &name, const std::string &v)
 Special case for std::string. More...
 
StatusCode setProperty (const std::string &name, const TYPE &value)
 set the property form the value More...
 
StatusCode setPropertyRepr (const std::string &n, const std::string &r) override
 set the property from name and value string representation More...
 
StatusCode getProperty (Gaudi::Details::PropertyBase *p) const override
 get the property More...
 
const Gaudi::Details::PropertyBasegetProperty (std::string_view name) const override
 get the property by name More...
 
StatusCode getProperty (std::string_view n, std::string &v) const override
 convert the property to the string More...
 
const std::vector< Gaudi::Details::PropertyBase * > & getProperties () const override
 get all properties More...
 
bool hasProperty (std::string_view name) const override
 Return true if we have a property with the given name. More...
 
Gaudi::Details::PropertyBaseproperty (std::string_view name) const
 \fixme property and bindPropertiesTo should be protected More...
 
void bindPropertiesTo (Gaudi::Interfaces::IOptionsSvc &optsSvc)
 
 PropertyHolder (const PropertyHolder &)=delete
 
PropertyHolderoperator= (const PropertyHolder &)=delete
 
- Public Member Functions inherited from CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > >
MSG::Level msgLevel () const
 get the cached level (originally extracted from the embedded MsgStream) More...
 
bool msgLevel (MSG::Level lvl) const
 get the output level from the embedded MsgStream More...
 

Private Member Functions

 GPUCruncher ()
 the default constructor is disabled More...
 
 GPUCruncher (const GPUCruncher &)
 the copy constructor is disabled More...
 
GPUCruncheroperator= (const GPUCruncher &)
 the assignement operator is disabled More...
 
StatusCode gpuExecute (const std::vector< double > &in, std::vector< double > &out) const
 The GPU intensive function. More...
 

Private Attributes

Gaudi::Property< std::vector< std::string > > m_inpKeys { this, "inpKeys", {}, "" }
 
Gaudi::Property< std::vector< std::string > > m_outKeys { this, "outKeys", {}, "" }
 
Gaudi::Property< double > m_avg_runtime { this, "avgRuntime", 1., "Average runtime of the module." }
 
Gaudi::Property< double > m_var_runtime { this, "varRuntime", 0.01, "Variance of the runtime of the module." }
 
const uint MAX_INPUTS = 40
 
const uint MAX_OUTPUTS = 10
 
std::vector< DataObjectHandle< DataObject > * > m_inputHandles
 
std::vector< DataObjectHandle< DataObject > * > m_outputHandles
 

Static Private Attributes

static CHM m_name_ncopies_map
 

Additional Inherited Members

- Public Attributes inherited from Gaudi::Algorithm
friend AlgorithmManager
 
- Protected Member Functions inherited from Gaudi::Algorithm
std::vector< IAlgTool * > & tools ()
 
bool isInitialized () const override
 Has the Algorithm already been initialized? More...
 
bool isFinalized () const override
 Has the Algorithm already been finalized? More...
 
void setIndex (const unsigned int &idx) override
 set instantiation index of Alg More...
 
bool isReEntrant () const override
 
- Protected Member Functions inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > > >
void initDataHandleHolder ()
 initializes all handles - called by the sysInitialize method of any descendant of this More...
 
- Protected Member Functions inherited from CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > >
MSG::Level setUpMessaging () const
 Set up local caches. More...
 
MSG::Level resetMessaging ()
 Reinitialize internal states. More...
 
void updateMsgStreamOutputLevel (int level)
 Update the output level of the cached MsgStream. More...
 
- Protected Attributes inherited from Gaudi::Algorithm
std::unique_ptr< IDataHandleVisitorm_updateDataHandles
 Hook for for derived classes to provide a custom visitor for data handles. More...
 
- Protected Attributes inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > > >
DataObjIDColl m_inputDataObjs
 
DataObjIDColl m_outputDataObjs
 

Detailed Description

A test asynchronous algorithm on the GPU

Definition at line 25 of file GPUCruncher.h.

Member Typedef Documentation

◆ CHM

using GPUCruncher::CHM = tbb::concurrent_hash_map<std::string, unsigned int>

Definition at line 28 of file GPUCruncher.h.

Constructor & Destructor Documentation

◆ GPUCruncher() [1/3]

GPUCruncher::GPUCruncher ( const std::string name,
ISvcLocator pSvc 
)

Definition at line 32 of file GPUCruncher.cpp.

34  : AsynchronousAlgorithm( name, pSvc ) {
35 
36  // Register the algo in the static concurrent hash map in order to
37  // monitor the # of copies
38  CHM::accessor name_ninstances;
39  m_name_ncopies_map.insert( name_ninstances, name );
40  name_ninstances->second += 1;
41 }

◆ ~GPUCruncher()

GPUCruncher::~GPUCruncher ( )
virtual

virtual & protected desctrustor

Definition at line 43 of file GPUCruncher.cpp.

43  {
44  for ( uint i = 0; i < m_inputHandles.size(); ++i ) delete m_inputHandles[i];
45 
46  for ( uint i = 0; i < m_outputHandles.size(); ++i ) delete m_outputHandles[i];
47 }

◆ GPUCruncher() [2/3]

GPUCruncher::GPUCruncher ( )
private

the default constructor is disabled

◆ GPUCruncher() [3/3]

GPUCruncher::GPUCruncher ( const GPUCruncher )
private

the copy constructor is disabled

Member Function Documentation

◆ execute()

StatusCode GPUCruncher::execute ( const EventContext ctx) const
override

the execution of the algorithm

Definition at line 80 of file GPUCruncher.cpp.

81 {
82 
83  double crunchtime;
84  std::vector<double> input{};
85  /* This will disappear with a thread safe random number generator service.
86  * Use basic Box-Muller to generate Gaussian random numbers.
87  * The quality is not good for in depth study given that the generator is a
88  * linear congruent.
89  * Throw away basically a free number: we are in a ~~cpu~~ /gpu/ cruncher after all.
90  * The seed is taken from the clock, but we could assign a seed per module to
91  * ensure reproducibility.
92  *
93  * This is not an overkill but rather an exercise towards a thread safe
94  * random number generation.
95  */
96 
97  auto getGausRandom = []( double mean, double sigma ) -> double {
98  unsigned int seed = std::clock();
99 
100  auto getUnifRandom = []( unsigned int& seed ) -> double {
101  // from "Numerical Recipes"
102  constexpr unsigned int m = 232;
103  constexpr unsigned int a = 1664525;
104  constexpr unsigned int c = 1013904223;
105  seed = ( a * seed + c ) % m;
106  const double unif = double( seed ) / m;
107  return unif;
108  };
109 
110  double unif1, unif2;
111  do {
112  unif1 = getUnifRandom( seed );
113  unif2 = getUnifRandom( seed );
114  } while ( unif1 < std::numeric_limits<double>::epsilon() );
115 
116  const double normal = sqrt( -2. * log( unif1 ) ) * cos( 2 * M_PI * unif2 );
117 
118  return normal * sigma + mean;
119  };
120 
121  crunchtime = fabs( getGausRandom( m_avg_runtime, m_var_runtime ) );
122  // Generate input vector
123  input.reserve( 50000 * crunchtime );
124  for ( int i = 0; i < 50000 * crunchtime; ++i ) { input.push_back( getGausRandom( 20.0, 1.0 ) ); }
125  unsigned int crunchtime_ms = 1000 * crunchtime;
126 
127  // First figure out what output should be
128  double lower_bound = std::ranges::min( input );
129  double upper_bound = std::ranges::max( input ) * 256;
130  DEBUG_MSG << "Crunching time will be: " << crunchtime_ms << " ms" << endmsg;
131  DEBUG_MSG << "Start event " << ctx.evt() << " in slot " << ctx.slot() << " on pthreadID " << std::hex
132  << pthread_self() << std::dec << endmsg;
133 
134  // start timer
135  tbb::tick_count starttbb = tbb::tick_count::now();
136 
137  VERBOSE_MSG << "inputs number: " << m_inputHandles.size() << endmsg;
138  for ( auto& inputHandle : m_inputHandles ) {
139  if ( !inputHandle->isValid() ) continue;
140 
141  VERBOSE_MSG << "get from TS: " << inputHandle->objKey() << endmsg;
142  DataObject* obj = nullptr;
143  try {
144  obj = inputHandle->get();
145  } catch ( const GaudiException& e ) {
146  error() << "Caught exception with message " << e.what() << " in evt " << ctx.evt() << endmsg;
147  throw;
148  }
149  if ( obj == nullptr ) error() << "A read object was a null pointer." << endmsg;
150  }
151 
152  info() << "Crunching..." << endmsg;
153  auto startcrunch = std::chrono::steady_clock::now();
155  gpuExecute( input, out ).orThrow( "GPU_EXECUTE" );
156  auto endcrunch = std::chrono::steady_clock::now();
157  int total_entries = std::accumulate( out.begin() + 2, out.end(), 0, std::plus{} );
158  bool match =
159  ( out.at( 0 ) == lower_bound ) && ( out.at( 1 ) == upper_bound ) && ( total_entries == 256 * input.size() );
160  info() << "Crunched." << endmsg;
161  ( match ? info() : warning() )
162  << std::format(
163  "GPU Crunch time: {} s. Input length {}, total entries {}. Pass: Lower {}, Upper {}, Entries {} ({} "
164  "missing)",
165  std::chrono::duration_cast<std::chrono::milliseconds>( endcrunch - startcrunch ).count() / 1e3,
166  input.size(), total_entries, out.at( 0 ) == lower_bound, out.at( 1 ) == upper_bound,
167  total_entries == 256 * input.size(), 256 * input.size() - total_entries )
168  << endmsg;
169 
170  VERBOSE_MSG << "outputs number: " << m_outputHandles.size() << endmsg;
171  for ( auto& outputHandle : m_outputHandles ) {
172  if ( !outputHandle->isValid() ) continue;
173 
174  VERBOSE_MSG << "put to TS: " << outputHandle->objKey() << endmsg;
175  try {
176  outputHandle->put( std::make_unique<DataObject>() );
177  } catch ( const GaudiException& e ) {
178  error() << "Caught exception with message " << e.what() << " in evt " << ctx.evt() << endmsg;
179  throw;
180  }
181  }
182 
183  tbb::tick_count endtbb = tbb::tick_count::now();
184  const double actualRuntime = ( endtbb - starttbb ).seconds();
185 
186  DEBUG_MSG << "Finish event " << ctx.evt() << " in " << int( 1000 * actualRuntime ) << " ms" << endmsg;
187 
188  DEBUG_MSG << "Timing: ExpectedCrunchtime= " << crunchtime_ms
189  << " ms. ActualTotalRuntime= " << int( 1000 * actualRuntime )
190  << " ms. Ratio= " << crunchtime / actualRuntime << endmsg;
191 
192  return StatusCode::SUCCESS;
193 }

◆ finalize()

StatusCode GPUCruncher::finalize ( )
override

the finalization of the algorithm

Definition at line 197 of file GPUCruncher.cpp.

198 {
199  MsgStream log( msgSvc(), name() );
200 
201  unsigned int ninstances;
202 
203  {
204  CHM::const_accessor const_name_ninstances;
205  m_name_ncopies_map.find( const_name_ninstances, name() );
206  ninstances = const_name_ninstances->second;
207  }
208 
209  constexpr double s2ms = 1000.;
210  // do not show repetitions
211  if ( ninstances != 0 ) {
212  info() << "Summary: name= " << name() << "\t avg_runtime= " << m_avg_runtime * s2ms << "\t n_clones= " << ninstances
213  << endmsg;
214 
215  CHM::accessor name_ninstances;
216  m_name_ncopies_map.find( name_ninstances, name() );
217  name_ninstances->second = 0;
218  }
219 
220  return Algorithm::finalize();
221 }

◆ get_runtime()

double GPUCruncher::get_runtime ( ) const
inline

Definition at line 39 of file GPUCruncher.h.

39 { return m_avg_runtime; }

◆ gpuExecute()

StatusCode GPUCruncher::gpuExecute ( const std::vector< double > &  in,
std::vector< double > &  out 
) const
private

The GPU intensive function.

◆ initialize()

StatusCode GPUCruncher::initialize ( )
override

Its initialization.

Definition at line 49 of file GPUCruncher.cpp.

49  {
50  auto sc = Algorithm::initialize();
51  if ( !sc ) return sc;
52 
53  // This is a bit ugly. There is no way to declare a vector of DataObjectHandles, so
54  // we need to wait until initialize when we've read in the input and output key
55  // properties, and know their size, and then turn them
56  // into Handles and register them with the framework by calling declareProperty. We
57  // could call declareInput/declareOutput on them too.
58 
59  int i = 0;
60  for ( auto k : m_inpKeys ) {
61  DEBUG_MSG << "adding input key " << k << endmsg;
63  declareProperty( "dummy_in_" + std::to_string( i ), *( m_inputHandles.back() ) );
64  i++;
65  }
66 
67  i = 0;
68  for ( auto k : m_outKeys ) {
69  DEBUG_MSG << "adding output key " << k << endmsg;
71  declareProperty( "dummy_out_" + std::to_string( i ), *( m_outputHandles.back() ) );
72  i++;
73  }
74 
75  return sc;
76 }

◆ isClonable()

bool GPUCruncher::isClonable ( ) const
inlineoverride

Definition at line 30 of file GPUCruncher.h.

30 { return true; }

◆ operator=()

GPUCruncher& GPUCruncher::operator= ( const GPUCruncher )
private

the assignement operator is disabled

Member Data Documentation

◆ m_avg_runtime

Gaudi::Property<double> GPUCruncher::m_avg_runtime { this, "avgRuntime", 1., "Average runtime of the module." }
private

Definition at line 60 of file GPUCruncher.h.

◆ m_inpKeys

Gaudi::Property<std::vector<std::string> > GPUCruncher::m_inpKeys { this, "inpKeys", {}, "" }
private

Definition at line 57 of file GPUCruncher.h.

◆ m_inputHandles

std::vector<DataObjectHandle<DataObject>*> GPUCruncher::m_inputHandles
private

Definition at line 67 of file GPUCruncher.h.

◆ m_name_ncopies_map

GPUCruncher::CHM GPUCruncher::m_name_ncopies_map
staticprivate

Definition at line 70 of file GPUCruncher.h.

◆ m_outKeys

Gaudi::Property<std::vector<std::string> > GPUCruncher::m_outKeys { this, "outKeys", {}, "" }
private

Definition at line 58 of file GPUCruncher.h.

◆ m_outputHandles

std::vector<DataObjectHandle<DataObject>*> GPUCruncher::m_outputHandles
private

Definition at line 68 of file GPUCruncher.h.

◆ m_var_runtime

Gaudi::Property<double> GPUCruncher::m_var_runtime { this, "varRuntime", 0.01, "Variance of the runtime of the module." }
private

Definition at line 61 of file GPUCruncher.h.

◆ MAX_INPUTS

const uint GPUCruncher::MAX_INPUTS = 40
private

Definition at line 64 of file GPUCruncher.h.

◆ MAX_OUTPUTS

const uint GPUCruncher::MAX_OUTPUTS = 10
private

Definition at line 65 of file GPUCruncher.h.


The documentation for this class was generated from the following files:
Gaudi::Accumulators::sqrt
auto sqrt(std::chrono::duration< Rep, Period > d)
sqrt for std::chrono::duration
Definition: Counters.h:34
GPUCruncher::m_inpKeys
Gaudi::Property< std::vector< std::string > > m_inpKeys
Definition: GPUCruncher.h:57
DEBUG_MSG
#define DEBUG_MSG
Definition: GPUCruncher.cpp:25
details::size
constexpr auto size(const T &, Args &&...) noexcept
Definition: AnyDataWrapper.h:23
GPUCruncher::m_outputHandles
std::vector< DataObjectHandle< DataObject > * > m_outputHandles
Definition: GPUCruncher.h:68
Gaudi.Configuration.log
log
Definition: Configuration.py:28
std::fabs
T fabs(T... args)
StatusCode::orThrow
const StatusCode & orThrow(std::string_view message, std::string_view tag) const
Throw a GaudiException in case of failures.
Definition: StatusCode.h:206
Gaudi::Algorithm::name
const std::string & name() const override
The identifying name of the algorithm object.
Definition: Algorithm.cpp:526
std::cos
T cos(T... args)
std::vector< double >
std::vector::size
T size(T... args)
GPUCruncher::m_var_runtime
Gaudi::Property< double > m_var_runtime
Definition: GPUCruncher.h:61
Gaudi::Algorithm::initialize
StatusCode initialize() override
the default (empty) implementation of IStateful::initialize() method
Definition: Algorithm.h:178
GaudiException
Definition: GaudiException.h:31
Gaudi::Algorithm::declareProperty
Gaudi::Details::PropertyBase * declareProperty(const std::string &name, ToolHandle< T > &hndl, const std::string &doc="none")
Definition: Algorithm.h:304
gaudirun.c
c
Definition: gaudirun.py:525
std::vector::back
T back(T... args)
DataObjectHandle< DataObject >
Gaudi::DataHandle::Writer
@ Writer
Definition: DataHandle.h:40
AvalancheSchedulerErrorTest.msgSvc
msgSvc
Definition: AvalancheSchedulerErrorTest.py:80
std::hex
T hex(T... args)
std::vector::push_back
T push_back(T... args)
std::clock
T clock(T... args)
GPUCruncher::m_inputHandles
std::vector< DataObjectHandle< DataObject > * > m_inputHandles
Definition: GPUCruncher.h:67
GaudiPython.Pythonizations.ctx
ctx
Definition: Pythonizations.py:578
Gaudi::Units::m
constexpr double m
Definition: SystemOfUnits.h:108
std::plus
VERBOSE_MSG
#define VERBOSE_MSG
Definition: GPUCruncher.cpp:28
std::to_string
T to_string(T... args)
std::accumulate
T accumulate(T... args)
format
GAUDI_API std::string format(const char *,...)
MsgStream format utility "a la sprintf(...)".
Definition: MsgStream.cpp:119
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202
std::upper_bound
T upper_bound(T... args)
MsgStream
Definition: MsgStream.h:33
GPUCruncher::gpuExecute
StatusCode gpuExecute(const std::vector< double > &in, std::vector< double > &out) const
The GPU intensive function.
Gaudi::Algorithm::finalize
StatusCode finalize() override
the default (empty) implementation of IStateful::finalize() method
Definition: Algorithm.h:184
std::lower_bound
T lower_bound(T... args)
StatusCode::SUCCESS
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
std::chrono::duration_cast
T duration_cast(T... args)
std
STL namespace.
OffloadAtlasMCRecoScenario.seed
seed
Definition: OffloadAtlasMCRecoScenario.py:52
DataObject
Definition: DataObject.h:36
std::count
T count(T... args)
GPUCruncher::m_outKeys
Gaudi::Property< std::vector< std::string > > m_outKeys
Definition: GPUCruncher.h:58
GPUCruncher::m_name_ncopies_map
static CHM m_name_ncopies_map
Definition: GPUCruncher.h:70
Gaudi::DataHandle::Reader
@ Reader
Definition: DataHandle.h:40
HepRndm::Engine
Definition: HepRndmEngine.h:35
GPUCruncher::m_avg_runtime
Gaudi::Property< double > m_avg_runtime
Definition: GPUCruncher.h:60
std::numeric_limits
GaudiException::what
const char * what() const override
method from std::exception
Definition: GaudiException.h:110
PrepareBase.out
out
Definition: PrepareBase.py:20
std::chrono::steady_clock::now
T now(T... args)