Combine.h

Go to the documentation of this file.

// Copyright (C) 2025 ASTRON (Netherlands Institute for Radio Astronomy)
// SPDX-License-Identifier: GPL-3.0-or-later
 
#ifndef DP3_STEPS_COMBINE_H_
#define DP3_STEPS_COMBINE_H_
 
#include "Step.h"
 
#include <xtensor/containers/xtensor.hpp>
 
#include "common/ParameterSet.h"
#include "common/Timer.h"
 
namespace dp3::steps {
 
class Combine final : public Step {
 public:
  Combine(const common::ParameterSet&, const std::string& prefix);
 
  common::Fields getRequiredFields() const final { return kDataField; }
 
  common::Fields getProvidedFields() const final { return kDataField; }
 
  bool process(std::unique_ptr<base::DPBuffer>) final;
 
  bool process(std::unique_ptr<base::BdaBuffer>) final;
 
  void finish() final;
 
  void updateInfo(const base::DPInfo&) final;
 
  void SetOperation(const std::string& operation);
 
  void show(std::ostream&) const final;
 
  void showTimings(std::ostream&, double duration) const final;
 
 private:
  enum class Operation { kAdd, kSubtract };
 
  std::string name_;
  common::NSTimer timer_;
  std::string buffer_name_;  //< Buffer that will be added or subtracted
  Operation operation_;      //< Add or subtract
};
 
}  // namespace dp3::steps
 
#endif