42 #include "cheetah/pipeline/CheetahConfig.h" 43 #include "cheetah/pipeline/BeamLauncher.h" 44 #include "cheetah/utils/TerminateException.h" 45 #include "cheetah/rcpt/UdpStream.h" 46 #include "cheetah/rcpt_low/UdpStream.h" 47 #include "cheetah/sigproc/SigProcFileStream.h" 48 #include "cheetah/psrdada/SigProcDadaStream.h" 49 #include "cheetah/pipeline/PipelineHandlerFactory.h" 50 #include "panda/MixInTimer.h" 54 int main(
int argc,
char** argv) {
58 typedef uint8_t NumericalT;
67 if( (rv=config.
parse(argc, argv)) )
return rv;
70 std::function<pipeline::PipelineHandlerFactory::HandlerType*(pipeline::BeamConfig<NumericalT>
const&)> runtime_handler_factory;
73 return pipeline_factory.create_timed(config.
pipeline_name(), beam_config);
78 return pipeline_factory.create(config.
pipeline_name(), beam_config);
84 std::string
const& stream_name = config.
stream_name();
85 if(stream_name ==
"sigproc") {
91 else if(stream_name ==
"psrdada") {
97 else if(stream_name ==
"udp") {
103 else if(stream_name ==
"udp_low") {
109 std::cerr <<
"unknown source '" << stream_name <<
"'" << std::endl;
115 catch(std::exception& e) {
116 std::cerr << e.what() << std::endl;
SigProcDadaStream configuration parameters.
MultiBeamConfig< NumericalRep > const & beams_config() const
return the configuration node with beam configurations
int exec()
launch the beam pipelines
configurable parameters for the rcpt
SigProc configuration parameters.
bool time_handler_invocation() const
wether to activte timing between each invocation of the runtime computational pipeline ...
int parse(int argc, char **argv)
parse the command line options/config file
PoolManagerType const & pool_manager() const
return the pool manager object
Parse configuration parameters for a single beam in the pipeline instance of cheetah.
Generates pipeline handler objects by name.
std::string const & pipeline_name() const
return the selected pipeline name
configurable parameters for the rcpt
void set_pipeline_handlers(std::vector< std::string > const &handler_names)
set the computational unit names available
std::string const & stream_name() const
return the selected stream name
Exception to indicate program should terminate, without an error.