Interpolate.h

Go to the documentation of this file.

// Copyright (C) 2020 ASTRON (Netherlands Institute for Radio Astronomy)
// SPDX-License-Identifier: GPL-3.0-or-later
 
#ifndef INTERPOLATE_H
#define INTERPOLATE_H
 
#include <deque>
#include <string>
 
#include "InputStep.h"
 
#include "base/DPBuffer.h"
 
#include "common/ParameterSet.h"
 
#include <aocommon/lane.h>
 
namespace dp3 {
namespace steps {
 
class Interpolate : public Step {
 public:
  Interpolate(const common::ParameterSet&, const std::string& prefix);
 
  ~Interpolate() override = default;
 
  common::Fields getRequiredFields() const override {
    return kDataField | kFlagsField;
  }
 
  common::Fields getProvidedFields() const override {
    return kDataField | kFlagsField;
  }
 
  bool process(std::unique_ptr<base::DPBuffer> input_buffer) override;
 
  void finish() override;
 
  void show(std::ostream&) const override;
 
  void showTimings(std::ostream&, double duration) const override;
 
 private:
  void interpolateTimestep(size_t index);
  void interpolateSample(size_t timestep, size_t baseline, size_t channel,
                         size_t pol);
  void sendFrontBufferToNextStep();
  void interpolationThread();
 
  struct Sample {
    Sample() = default;
    Sample(size_t timestep_, size_t baseline_, size_t channel_, size_t pol_)
        : timestep(timestep_),
          baseline(baseline_),
          channel(channel_),
          pol(pol_) {}
    size_t timestep;
    size_t baseline;
    size_t channel;
    size_t pol;
  };
 
  std::string name_;
  size_t interpolated_pos_;
  std::deque<std::unique_ptr<base::DPBuffer>> buffers_;
  size_t window_size_;
  common::NSTimer timer_;
  aocommon::Lane<Sample> lane_;
  std::vector<float> kernel_lookup_;
};
 
}  // namespace steps
}  // namespace dp3
 
#endif