MSBDAReader.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 DPPP_MSBDAREADER_H
#define DPPP_MSBDAREADER_H
 
#include "InputStep.h"
 
#include "base/BdaBuffer.h"
#include "base/UVWCalculator.h"
#include "base/FlagCounter.h"
 
#include <casacore/ms/MeasurementSets/MeasurementSet.h>
 
#include <map>
 
namespace dp3 {
namespace common {
class ParameterSet;
}
 
namespace steps {
 
 
class MSBDAReader : public InputStep {
 public:
  MSBDAReader(const casacore::MeasurementSet& ms, const common::ParameterSet&,
              const std::string& prefix);
 
  ~MSBDAReader() override;
 
  bool process(std::unique_ptr<base::DPBuffer> buffer) override;
 
  bool process(std::unique_ptr<base::BdaBuffer> buffer) override;
 
  void finish() override;
 
  MsType outputs() const override { return MsType::kBda; };
 
  void updateInfo(const base::DPInfo&) override;
 
  void show(std::ostream&) const override;
 
  void showTimings(std::ostream&, double duration) const override;
 
  std::string msName() const override;
 
  const casacore::Table& table() const override { return ms_; }
 
 private:
  const casacore::MeasurementSet ms_;
  std::string data_column_name_;
  std::string weight_column_name_;
  double last_ms_time_;
  double last_ms_interval_;
  bool is_interval_integer_;
  unsigned int nread_;  
  common::NSTimer timer_;
  std::size_t pool_size_;  
 
  std::map<int, std::size_t>
      desc_id_to_nchan_;  
  std::map<std::pair<int, int>, unsigned int>
      bl_to_id_;  
};
 
}  // namespace steps
}  // namespace dp3
 
#endif