File: parallel_mpi_utilities.cc

package info (click to toggle)
purify 5.0.1-2
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 186,836 kB
  • sloc: cpp: 17,731; python: 510; xml: 182; makefile: 7; sh: 6
file content (34 lines) | stat: -rw-r--r-- 1,022 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
#include "catch2/catch_all.hpp"
#include "purify/mpi_utilities.h"

using namespace purify;
using Catch::Approx;

TEST_CASE("Distribution of visibility data") {
  auto const world = sopt::mpi::Communicator::World();
  auto const N = 5;
  utilities::vis_params params;

  params.u = Vector<t_real>::Random(N);
  params.v = Vector<t_real>::Random(N);
  params.w = Vector<t_real>::Random(N);
  params.vis = Vector<t_complex>::Random(N);
  params.weights = Vector<t_complex>::Random(N);

  std::vector<t_int> order(N);

  if (world.size() == 1) return;
  order[0] = 1;
  std::fill(order.begin() + 1, order.end(), 0);

  auto actual = utilities::regroup_and_scatter(params, order, world);
  if (world.rank() == 0) {
    CHECK(actual.u.size() == 4);
    CHECK(actual.u(0) == Approx(params.u(N - 1)));
    CHECK(actual.u.tail(N - 2).isApprox(params.u.segment(1, N - 2)));
  } else if (world.rank() == 1) {
    CHECK(actual.u.size() == 1);
    CHECK(actual.u(0) == Approx(params.u(0)));
  } else
    CHECK(actual.u.size() == 0);
}