Cheetah - SKA - PSS - Prototype Time Domain Search Pipeline
|
Public Member Functions | |
template<typename StreamConfigFactory , typename PipelineFactory > | |
BeamLauncher (MultiBeamConfig< NumericalT > const &mb_config, StreamConfigFactory const &config_factory, PipelineFactory const &pipeline_factory) | |
int | exec () |
launch the beam pipelines More... | |
void | join () |
Wait for threads to finish. | |
bool | is_running () const |
return true if all activated beams are running | |
std::vector< std::unique_ptr< StreamType > > & | streams () |
return the vector of unique pointers to all the streams | |
template<typename ConfigFactory , typename PipelineFactory > | |
BeamLauncher (MultiBeamConfig< NumericalT > const &multi_beams_config, ConfigFactory const &config_factory, PipelineFactory const &runtime_handler_factory) | |
Definition at line 51 of file BeamLauncher.h.
int ska::cheetah::pipeline::BeamLauncher< InputDataStream, NumericalT >::exec | ( | ) |
launch the beam pipelines
PipelineFactory | a functor that will return a suitable runtime handler of the incoming data this function will block until join() is called, or the pipelines terminate in some other way |
Definition at line 184 of file BeamLauncher.cpp.