Clipper.h

Go to the documentation of this file.

// Copyright (C) 2024 ASTRON (Netherlands Institute for Radio Astronomy)
// SPDX-License-Identifier: GPL-3.0-or-later
 
#ifndef DP3_STEPS_CLIPPER_H_
#define DP3_STEPS_CLIPPER_H_
 
#include "Step.h"
 
#include "common/ParameterSet.h"
#include "OnePredict.h"
#include "FastPredict.h"
#include "PreFlagger.h"
#include "Filter.h"
#include "ResultStep.h"
#include "common/Timer.h"
 
namespace dp3 {
namespace steps {
 
 
class Clipper : public Step {
 public:
  Clipper(const common::ParameterSet&, const std::string& prefix);
 
  common::Fields getRequiredFields() const override {
    return kFlagsField | filter_step_->getRequiredFields() |
           predict_step_->getRequiredFields();
  }
 
  common::Fields getProvidedFields() const override { return kFlagsField; }
 
  bool process(std::unique_ptr<base::DPBuffer>) override;
 
  void finish() override;
 
  void updateInfo(const base::DPInfo&) override;
 
  void show(std::ostream&) const override;
 
  void showTimings(std::ostream&, double duration) const override;
 
  void SetPredict(std::shared_ptr<Step> substep);
 
 private:
  std::string name_;
  common::NSTimer timer_;
  size_t counter_;
  size_t time_step_;
  size_t frequency_step_;
  bool flag_all_correlations_;
  float max_amplitude_;
  std::shared_ptr<Step> filter_step_;
  std::shared_ptr<Step> predict_step_;
  std::shared_ptr<ResultStep> result_step_;
  std::unique_ptr<dp3::base::DPBuffer> predict_buffer_;
  base::DPBuffer::FlagsType last_flags_;
};
 
}  // namespace steps
}  // namespace dp3
 
#endif