FlagTransfer.h

Go to the documentation of this file.

// FlagTransfer.h: DP3 step class to transfer flags
// Copyright (C) 2024 ASTRON (Netherlands Institute for Radio Astronomy)
// SPDX-License-Identifier: GPL-3.0-or-later
 
 
#ifndef DP3_STEPS_FLAG_TRANSFER_H_
#define DP3_STEPS_FLAG_TRANSFER_H_
 
#include <casacore/ms/MeasurementSets/MeasurementSet.h>
#include <casacore/tables/Tables/TableIter.h>
#include "base/DPBuffer.h"
#include "steps/Step.h"
#include "Filter.h"
#include "ResultStep.h"
#include "common/Timer.h"
 
namespace dp3 {
 
namespace common {
class ParameterSet;
}
 
namespace steps {
 
 
 
 
class FlagTransfer final : public Step {
 public:
  explicit FlagTransfer(const common::ParameterSet& parameter_set,
                        const std::string& prefix);
 
  common::Fields getRequiredFields() const final {
    return filter_step_->getRequiredFields();
  }
 
  common::Fields getProvidedFields() const final { return kFlagsField; }
 
  bool process(std::unique_ptr<base::DPBuffer> buffer) final;
 
  void finish() final;
 
  void updateInfo(const base::DPInfo&) final;
 
  void show(std::ostream&) const final;
 
  void showTimings(std::ostream&, double duration) const final;
 
 private:
  void ReadSourceMsFlags();
 
  std::string name_;
  common::NSTimer timer_;
  std::string source_ms_path_;
  casacore::MeasurementSet ms_;
  casacore::TableIterator ms_iterator_;
 
  base::DPBuffer::FlagsType flags_;
 
  std::size_t timestep_counter_;
 
  std::size_t time_averaging_factor_;
 
  double time_interval_;
 
  std::vector<double> source_channel_upper_edges_;
 
  std::shared_ptr<Step> filter_step_;
  std::shared_ptr<ResultStep> result_step_;
};
 
}  // namespace steps
}  // namespace dp3
 
#endif