File: python_deconvolution.h

package info (click to toggle)
wsclean 3.6-3
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 16,296 kB
  • sloc: cpp: 129,246; python: 22,066; sh: 360; ansic: 230; makefile: 185
file content (61 lines) | stat: -rw-r--r-- 2,077 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
// SPDX-License-Identifier: LGPL-3.0-only

#ifndef RADLER_ALGORITHMS_PYTHON_DECONVOLUTION_H_
#define RADLER_ALGORITHMS_PYTHON_DECONVOLUTION_H_

#include <aocommon/uvector.h>

#include <schaapcommon/fitters/spectralfitter.h>

#include "image_set.h"
#include "algorithms/deconvolution_algorithm.h"

namespace pybind11 {
// Forward declarations to keep pybind11 symbols internal.
class scoped_interpreter;
class gil_scoped_release;
class function;
}  // namespace pybind11

namespace radler::algorithms {

class PythonDeconvolution final : public DeconvolutionAlgorithm {
 public:
  PythonDeconvolution(const std::string& filename);

  // TODO(AST-912) Make copy/move operations Google Style compliant.
  PythonDeconvolution(const PythonDeconvolution& other);
  PythonDeconvolution(PythonDeconvolution&&) = delete;
  PythonDeconvolution& operator=(const PythonDeconvolution&) = delete;
  PythonDeconvolution& operator=(PythonDeconvolution&&) = delete;

  ~PythonDeconvolution() override;

  DeconvolutionResult ExecuteMajorIteration(
      ImageSet& dirty_set, ImageSet& model_set,
      const std::vector<aocommon::Image>& psfs) final;

  std::unique_ptr<DeconvolutionAlgorithm> Clone() const final {
    return std::make_unique<PythonDeconvolution>(*this);
  }

 private:
  std::string _filename;
  // A Python interpreter can not be restarted, so the interpreter
  // needs to live for the entire run
  std::shared_ptr<pybind11::scoped_interpreter> _guard;
  std::unique_ptr<pybind11::function> _deconvolveFunction;

  // gil_scoped_release needs to be the last of the python members.
  // This ensures that the GIL is obtained by the destructor before
  // the python objects are destructed.
  std::unique_ptr<pybind11::gil_scoped_release> release_;

  void setBuffer(const ImageSet& imageSet, double* pyPtr);
  void setPsf(const std::vector<aocommon::Image>& psfs, double* pyPtr,
              size_t width, size_t height);
  void getBuffer(ImageSet& imageSet, const double* pyPtr);
};
}  // namespace radler::algorithms

#endif  // RADLER_ALGORITHMS_PYTHON_DECONVOLUTION_H_