24 #ifndef SKA_CHEETAH_PIPELINE_TEST_ACCELERATIONSEARCHPIPELINE_H 25 #define SKA_CHEETAH_PIPELINE_TEST_ACCELERATIONSEARCHPIPELINE_H 27 #include <gtest/gtest.h> 28 #include "cheetah/data/DmTime.h" 29 #include "cheetah/data/DmTrials.h" 30 #include "cheetah/pipeline/Dedispersion.h" 31 #include "cheetah/pipeline/AccelerationSearch.h" 38 template<
typename NumericalT>
46 template<
typename SiftHandlerT>
51 void operator()(std::shared_ptr<DmTimeType>
const&);
53 bool wait_sift_handler_called()
const;
56 SiftHandlerT& _handler;
57 mutable std::condition_variable _acceleration_wait;
58 mutable std::mutex _acceleration_data_mutex;
59 std::vector<std::shared_ptr<DmTimeType>> _received_data;
60 bool _sift_handler_called =
false;
65 template<
typename SiftHandlerT>
70 template<
typename NumericalT>
81 typedef typename Dedispersion<NumericalT>::DmHandler DedispersionHandler;
87 bool wait_dedispersion_handler_called()
const;
90 mutable std::condition_variable _dedispersion_wait;
91 mutable std::mutex _dedispersion_data_mutex;
92 std::vector<std::shared_ptr<typename BaseT::TimeFrequencyType>> _received_tf_data;
93 bool _dm_handler_called =
false;
99 void operator()(std::shared_ptr<data::Ocld>
const&);
101 bool wait_fldo_handler_called()
const;
104 mutable std::condition_variable _fldo_wait;
105 mutable std::mutex _fldo_data_mutex;
106 std::vector<std::shared_ptr<data::Ocld>> _candidate_data;
107 bool _fldo_handler_called =
false;
114 template<
typename DmHandlerT>
123 void SetUp()
override;
124 void TearDown()
override;
138 #endif //SKA_CHEETAH_PIPELINE_TEST_ACCELERATIONSEARCHPIPELINE_H
Configuration parameters for the available acceleration searches.
Some limits and constants for FLDO.
Parse configuration parameters for a single beam in the pipeline instance of cheetah.
Base class for dedispersion pipeline handlers.
A continuous memory container for dispersion measure trials of varying downsamplings.
A wrapper class for a list of DmTime instances.