padmm_simulation.cc File Reference

#include "purify/config.h"
#include "purify/types.h"
#include <array>
#include <ctime>
#include <memory>
#include <random>
#include <boost/math/special_functions/erf.hpp>
#include "purify/directories.h"
#include "purify/logging.h"
#include "purify/operators.h"
#include "purify/pfitsio.h"
#include "purify/utilities.h"
#include <sopt/imaging_padmm.h>
#include <sopt/power_method.h>
#include <sopt/relative_variation.h>
#include <sopt/utilities.h>
#include <sopt/wavelets.h>
#include <sopt/wavelets/sara.h>

Include dependency graph for padmm_simulation.cc:

Go to the source code of this file.

Functions
int	main (int nargs, char const **args)

Function Documentation

main()

int main	(	int	nargs,
		char const **	args
	)

Definition at line 20 of file padmm_simulation.cc.

                                       {
  if (nargs != 9) {
    std::cerr << " Wrong number of arguments! " << '\n';
    return 1;
  }
 
  using namespace purify;
  sopt::logging::set_level("debug");
  purify::logging::set_level("debug");
 
  std::string const test_type = args[1];
  const std::string kernel = args[2];
  t_real const over_sample = std::stod(static_cast<std::string>(args[3]));
  t_int const J = static_cast<t_int>(std::stod(static_cast<std::string>(args[4])));
  t_real const m_over_n = std::stod(static_cast<std::string>(args[5]));
  std::string const test_number = static_cast<std::string>(args[6]);
  t_real const ISNR = std::stod(static_cast<std::string>(args[7]));
  std::string const name = static_cast<std::string>(args[8]);
 
  std::string const fitsfile = image_filename(name + ".fits");
 
  std::string const dirty_image_fits =
      output_filename(name + "_dirty_" + kernel + "_" + test_number + ".fits");
  std::string const results =
      output_filename(name + "_results_" + kernel + "_" + test_number + ".txt");
 
  auto sky_model = pfitsio::read2d(fitsfile);
  auto sky_model_max = sky_model.array().abs().maxCoeff();
  sky_model = sky_model / sky_model_max;
  t_int const number_of_vis = std::floor(m_over_n * sky_model.size());
  t_real const sigma_m = constant::pi / 3;
 
  auto uv_data = utilities::random_sample_density(number_of_vis, 0, sigma_m);
  uv_data.units = utilities::vis_units::radians;
  PURIFY_MEDIUM_LOG("Number of measurements: {}", uv_data.u.size());
 
  auto measurements_sky = std::get<2>(sopt::algorithm::normalise_operator<Vector<t_complex>>(
      *measurementoperator::init_degrid_operator_2d<Vector<t_complex>>(
          uv_data.u, uv_data.v, uv_data.w, uv_data.weights, sky_model.cols(), sky_model.rows(),
          over_sample, kernels::kernel_from_string.at(kernel), 8, 8),
      100, 1e-4, Vector<t_complex>::Random(sky_model.size())));
  uv_data.vis = measurements_sky * Vector<t_complex>::Map(sky_model.data(), sky_model.size());
  auto measurements_transform = std::get<2>(sopt::algorithm::normalise_operator<Vector<t_complex>>(
      *measurementoperator::init_degrid_operator_2d<Vector<t_complex>>(
          uv_data.u, uv_data.v, uv_data.w, uv_data.weights, sky_model.cols(), sky_model.rows(),
          over_sample, kernels::kernel_from_string.at(kernel), J, J),
      100, 1e-4, Vector<t_complex>::Random(sky_model.size())));
 
  std::vector<std::tuple<std::string, t_uint>> wavelets;
 
  if (test_type == "clean") wavelets.push_back(std::make_tuple("Dirac", 3u));
  if (test_type == "ms_clean") wavelets.push_back(std::make_tuple("DB4", 3u));
  if (test_type == "padmm") {
    wavelets.push_back(std::make_tuple("Dirac", 3u));
    wavelets.push_back(std::make_tuple("DB1", 3u));
    wavelets.push_back(std::make_tuple("DB2", 3u));
    wavelets.push_back(std::make_tuple("DB3", 3u));
    wavelets.push_back(std::make_tuple("DB4", 3u));
    wavelets.push_back(std::make_tuple("DB5", 3u));
    wavelets.push_back(std::make_tuple("DB6", 3u));
    wavelets.push_back(std::make_tuple("DB7", 3u));
    wavelets.push_back(std::make_tuple("DB8", 3u));
  }
  sopt::wavelets::SARA const sara(wavelets.begin(), wavelets.end());
  auto const Psi = sopt::linear_transform<t_complex>(sara, sky_model.rows(), sky_model.cols());
 
  // working out value of sigma given SNR of 30
  t_real sigma = utilities::SNR_to_standard_deviation(uv_data.vis, ISNR);
  // adding noise to visibilities
  uv_data.vis = utilities::add_noise(uv_data.vis, 0., sigma);
 
  Vector<> dimage = (measurements_transform.adjoint() * uv_data.vis).real();
  t_real const max_val = dimage.array().abs().maxCoeff();
  dimage = dimage / max_val;
  Vector<t_complex> initial_estimate = Vector<t_complex>::Zero(dimage.size());
 
  auto const epsilon = utilities::calculate_l2_radius(uv_data.vis.size(), sigma);
  auto const purify_regulariser_strength =
      (Psi.adjoint() * (measurements_transform.adjoint() * uv_data.vis).eval()).real().maxCoeff() *
      1e-3;
  t_int iters = 0;
  auto convergence_function = [&iters](const Vector<t_complex> &x) {
    iters = iters + 1;
    return true;
  };
  PURIFY_HIGH_LOG("Starting sopt!");
  PURIFY_MEDIUM_LOG("Epsilon {}", epsilon);
  PURIFY_MEDIUM_LOG("Regulariser_Strength {}", purify_regulariser_strength);
  auto const padmm = sopt::algorithm::ImagingProximalADMM<t_complex>(uv_data.vis)
                         .regulariser_strength(purify_regulariser_strength)
                         .relative_variation(1e-3)
                         .l2ball_proximal_epsilon(epsilon * 1.001)
                         .tight_frame(false)
                         .l1_proximal_tolerance(1e-2)
                         .l1_proximal_nu(1)
                         .l1_proximal_itermax(50)
                         .l1_proximal_positivity_constraint(true)
                         .l1_proximal_real_constraint(true)
                         .residual_convergence(epsilon * 1.001)
                         .lagrange_update_scale(0.9)
                         .Psi(Psi)
                         .itermax(100)
                         .is_converged(convergence_function)
                         .Phi(measurements_transform);
  // Timing reconstruction
 
  std::clock_t c_start = std::clock();
  auto const diagnostic = padmm();
  std::clock_t c_end = std::clock();
 
  // Reading if algo has converged
  t_int converged = 0;
  if (diagnostic.good) {
    converged = 1;
  }
  const t_uint maxiters = iters;
 
  Image<t_complex> image =
      Image<t_complex>::Map(diagnostic.x.data(), sky_model.rows(), sky_model.cols());
 
  Vector<t_complex> original = Vector<t_complex>::Map(sky_model.data(), sky_model.size(), 1);
  Image<t_complex> res = sky_model - image;
  Vector<t_complex> residual = Vector<t_complex>::Map(res.data(), image.size(), 1);
 
  auto snr = 20. * std::log10(original.norm() / residual.norm());  // SNR of reconstruction
  auto total_time = (c_end - c_start) / CLOCKS_PER_SEC;  // total time for solver to run in seconds
  // writing snr and time to a file
  std::ofstream out(results);
  out.precision(13);
  out << snr << " " << total_time << " " << converged << " " << maxiters;
  out.close();
 
  return 0;
}

References purify::utilities::add_noise(), purify::utilities::calculate_l2_radius(), purify::image_filename(), purify::measurementoperator::init_degrid_operator_2d(), purify::kernels::kernel_from_string, purify::output_filename(), padmm(), purify::constant::pi, PURIFY_HIGH_LOG, PURIFY_MEDIUM_LOG, purify::utilities::radians, purify::utilities::random_sample_density(), purify::pfitsio::read2d(), purify::logging::set_level(), and purify::utilities::SNR_to_standard_deviation().