correlator.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_TELSUB_CORRELATOR_HPP
#define RTCTK_TELSUB_CORRELATOR_HPP
 
#include <memory>
#include <deque>
#include <rtctk/telSub/correlatorIf.hpp>
#include <rtctk/telSub/ddsSubscriberIf.hpp>
 
namespace rtctk::telSub {
 
class Correlator final : public CorrelatorIf {
public:
    explicit Correlator(std::unique_ptr<DdsSubscriberIf> dds_subscriber);
    virtual ~Correlator();
 
    virtual std::error_code
    Poll(CorrelatedDataSamplesRef& samples, std::chrono::milliseconds timeout) noexcept override;
private:
    bool FrontRowHasSameSampleIds(unsigned long& sample_id);
    std::error_code DropMissalignedSamples();
 
    std::unique_ptr<DdsSubscriberIf> m_dds_subscriber;
    std::vector<std::deque<const rtctk::AgnosticTopic*>> m_input_streams;
    std::vector<const rtctk::AgnosticTopic*> m_forwarded_samples;
};
 
}  // namespace rtctk::telSub
 
#endif  // #define RTCTK_TELSUB_CORRELATOR_HPP