Newer
Older
#include <assert.h>
#include <stdlib.h>
#include "field.h"
#include "mesh.h"
#include "mpicomm.h"
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
62
63
64
65
66
67
void int_field_init(int_field_t *field, const conf_t *configuration, const mesh_t *mesh)
{
field->configuration = configuration;
field->mesh = mesh;
field->data = malloc(mesh->extended_local_domain.volume * sizeof(int));
}
void int_field_free(int_field_t *field)
{
free(field->data);
field->data = NULL;
}
void int_field_set_constant(int_field_t *field, int value)
{
int i, n;
int *data;
n = field->mesh->extended_local_domain.volume;
data = field->data;
for(i = 0; i < n; i++) data[i] = value;
}
int int_field_check_value(const int_field_t *field, const box_t *domain, int expected_value)
{
const mesh_t* mesh = field->mesh;
const int *c = domain->coords;
const int *e = domain->extents;
const int *data = field->data;
int x, y, z, idx;;
for(z = c[Z]; z < c[Z] + e[Z]; z++) {
for(y = c[Y]; y < c[Y] + e[Y]; y++) {
for(x = c[X]; x < c[X] + e[X]; x++) {
idx = mesh_idx(mesh, x, y, z);
if(data[idx] != expected_value) return 0;
}
}
}
return 1;
}
void int_field_halo_exchange(int_field_t *field)
{
int mode = field->configuration->transfer_mode;
switch(mode) {
case SPARSE_COLLECTIVE:
mpi_halo_exchange_int_sparse_collective(field); break;
case COLLECTIVE:
mpi_halo_exchange_int_collective(field); break;
case P2P_DEFAULT:
mpi_halo_exchange_int_p2p_default(field); break;
case P2P_SYNCHRONOUS:
mpi_halo_exchange_int_p2p_synchronous(field); break;
case P2P_READY:
mpi_halo_exchange_int_p2p_ready(field); break;
}
}