YetAnotherCoupler 3.2.0_a
Loading...
Searching...
No Matches
interpolation_utils.h
Go to the documentation of this file.
1// Copyright (c) 2024 The YAC Authors
2//
3// SPDX-License-Identifier: BSD-3-Clause
4
5#ifndef INTERPOLATION_UTILS_H
6#define INTERPOLATION_UTILS_H
7
8#include <math.h>
9
10#include "utils_common.h"
11#include "ppm/ppm_xfuncs.h"
12
13static inline void compute_tgt_field_wgt(
14 double const * restrict ** src_fields,
15 double const * restrict ** src_frac_masks,
16 double const * restrict * remote_src_fields,
17 double const * restrict * remote_src_frac_masks,
18 double * restrict * tgt_field,
19 size_t const * restrict tgt_pos,
20 size_t tgt_count, size_t const * restrict prefix_num_src_per_tgt,
21 double const * restrict weights,
22 size_t const * restrict src_field_idx,
23 size_t const * restrict src_idx,
24 size_t num_src_fields, size_t collection_size,
25 double frac_mask_fallback_value,
26 double scale_factor, double scale_summand) {
27
28 // return if there is nothing to do
29 if (tgt_count == 0) return;
30
31#define FRAC_MASK_TOL (1e-12)
32
33#define COMPUTE_TGT_FIELD_WGT_FRAC_(TGT_POS, WEIGHT, SCALE) \
34 { \
35 for (size_t l = 0; l < collection_size; ++l) { \
36 double const * restrict * curr_local_field_data = \
37 src_fields?src_fields[l]:NULL; \
38 double const * restrict * curr_local_frac_mask_data = \
39 src_frac_masks?src_frac_masks[l]:NULL; \
40 double const * restrict curr_remote_field_data = \
41 remote_src_fields[l * num_src_fields]; \
42 double const * restrict curr_remote_frac_mask_data = \
43 remote_src_frac_masks[l * num_src_fields]; \
44 double * restrict curr_tgt_field = tgt_field[l]; \
45 YAC_OMP_PARALLEL \
46 { \
47 YAC_OMP_FOR \
48 for (size_t i = 0; i < tgt_count; ++i) { \
49 double result = 0.0; \
50 double frac_weight_sum = 0.0; \
51 size_t const k_bound = prefix_num_src_per_tgt[i+1]; \
52 for (size_t k = prefix_num_src_per_tgt[i]; k < k_bound; ++k) { \
53 double const * restrict frac_mask_data; \
54 double const * restrict src_field_data; \
55 if (src_field_idx[k] == SIZE_MAX) { \
56 frac_mask_data = curr_remote_frac_mask_data; \
57 src_field_data = curr_remote_field_data; \
58 } else { \
59 frac_mask_data = \
60 curr_local_frac_mask_data[src_field_idx[k]]; \
61 src_field_data = curr_local_field_data[src_field_idx[k]]; \
62 } \
63 result += src_field_data[src_idx[k]] * (WEIGHT); \
64 frac_weight_sum += frac_mask_data[src_idx[k]] * (WEIGHT); \
65 } \
66 curr_tgt_field[(TGT_POS)] = \
67 (fabs(frac_weight_sum) > FRAC_MASK_TOL)? \
68 (SCALE(result / frac_weight_sum)): \
69 frac_mask_fallback_value; \
70 } \
71 } \
72 } \
73 }
74
75#define COMPUTE_TGT_FIELD_WGT_NOFRAC_(TGT_POS, WEIGHT, SCALE) \
76 { \
77 for (size_t l = 0; l < collection_size; ++l) { \
78 double const * restrict * curr_local_field_data = \
79 src_fields?src_fields[l]:NULL; \
80 double const * restrict curr_remote_field_data = \
81 remote_src_fields[l * num_src_fields]; \
82 double * restrict curr_tgt_field = tgt_field[l]; \
83 YAC_OMP_PARALLEL \
84 { \
85 YAC_OMP_FOR \
86 for (size_t i = 0; i < tgt_count; ++i) { \
87 double result = 0.0; \
88 size_t const k_bound = prefix_num_src_per_tgt[i+1]; \
89 for (size_t k = prefix_num_src_per_tgt[i]; k < k_bound; ++k) { \
90 double const * restrict src_field_data; \
91 if (src_field_idx[k] == SIZE_MAX) { \
92 src_field_data = curr_remote_field_data; \
93 } else { \
94 src_field_data = curr_local_field_data[src_field_idx[k]]; \
95 } \
96 result += src_field_data[src_idx[k]] * (WEIGHT); \
97 } \
98 curr_tgt_field[(TGT_POS)] = SCALE(result); \
99 } \
100 } \
101 } \
102 }
103
104#define COMPUTE_TGT_FIELD_WGT(COMPUTE, SCALE) \
105 { \
106 if (weights != NULL) { \
107 if (tgt_pos != NULL) COMPUTE(tgt_pos[i], weights[k], SCALE) \
108 else COMPUTE(i, weights[k], SCALE) \
109 } else { \
110 if (tgt_pos != NULL) COMPUTE(tgt_pos[i], 1.0, SCALE) \
111 else COMPUTE(i, 1.0, SCALE) \
112 } \
113 }
114
115#define COMPUTE_TGT_FIELD_WGT_FRAC(SCALE) \
116 COMPUTE_TGT_FIELD_WGT(COMPUTE_TGT_FIELD_WGT_FRAC_, SCALE)
117
118#define COMPUTE_TGT_FIELD_WGT_NOFRAC(SCALE) \
119 COMPUTE_TGT_FIELD_WGT(COMPUTE_TGT_FIELD_WGT_NOFRAC_, SCALE)
120
121#define NO_SCALING(RESULT) (RESULT)
122#define MULT(RESULT) ((RESULT) * scale_factor)
123#define ADD(RESULT) ((RESULT) + scale_summand)
124#define MULT_ADD(RESULT) ((RESULT) * scale_factor + scale_summand)
125
126#define COMPUTE_FIELD(COMPUTE_FIELD_FRAC, COMPUTE_FIELD_NOFRAC) \
127 { \
128 if (frac_mask_fallback_value != YAC_FRAC_MASK_NO_VALUE) { \
129 if (scale_factor == 1.0) { \
130 if (scale_summand == 0.0) COMPUTE_FIELD_FRAC(NO_SCALING) \
131 else COMPUTE_FIELD_FRAC(ADD) \
132 } else { \
133 if (scale_summand == 0.0) COMPUTE_FIELD_FRAC(MULT) \
134 else COMPUTE_FIELD_FRAC(MULT_ADD) \
135 } \
136 } else { \
137 if (scale_factor == 1.0) { \
138 if (scale_summand == 0.0) COMPUTE_FIELD_NOFRAC(NO_SCALING) \
139 else COMPUTE_FIELD_NOFRAC(ADD) \
140 } else { \
141 if (scale_summand == 0.0) COMPUTE_FIELD_NOFRAC(MULT) \
142 else COMPUTE_FIELD_NOFRAC(MULT_ADD) \
143 } \
144 } \
145 }
146
147 COMPUTE_FIELD(COMPUTE_TGT_FIELD_WGT_FRAC, COMPUTE_TGT_FIELD_WGT_NOFRAC)
148
149#undef COMPUTE_TGT_FIELD_WGT
150#undef COMPUTE_TGT_FIELD_WGT_FRAC
151#undef COMPUTE_TGT_FIELD_WGT_NOFRAC
152#undef COMPUTE_TGT_FIELD_WGT_FRAC_
153#undef COMPUTE_TGT_FIELD_WGT_NOFRAC_
154}
155
156static inline void compute_tgt_field(
157 double const * restrict ** src_fields,
158 double const * restrict ** src_frac_masks,
159 double * restrict * tgt_field,
160 size_t * restrict tgt_buffer_sizes,
161 size_t num_src_fields, size_t collection_size,
162 double frac_mask_fallback_value,
163 double scale_factor, double scale_summand) {
164
165#define COMPUTE_TGT_FIELD_FRAC(SCALE) \
166 { \
167 for (size_t i = 0; i < collection_size; ++i) { \
168 for (size_t j = 0; j < num_src_fields; ++j) { \
169 memcpy(tgt_field[i * num_src_fields + j], \
170 src_fields[i][j], tgt_buffer_sizes[j]); \
171 size_t const tgt_count = \
172 tgt_buffer_sizes[j] / sizeof(***src_fields); \
173 YAC_OMP_PARALLEL \
174 { \
175 YAC_OMP_FOR \
176 for (size_t k = 0; k < tgt_count; ++k) { \
177 if (src_frac_masks[i][j][k] != 0.0) \
178 tgt_field[i * num_src_fields + j][k] = \
179 SCALE( \
180 tgt_field[i * num_src_fields + j][k] / \
181 src_frac_masks[i][j][k]); \
182 else \
183 tgt_field[i * num_src_fields + j][k] = \
184 frac_mask_fallback_value; \
185 } \
186 } \
187 } \
188 } \
189 }
190
191#define COMPUTE_TGT_FIELD_NOFRAC(SCALE) \
192 { \
193 for (size_t i = 0; i < collection_size; ++i) { \
194 for (size_t j = 0; j < num_src_fields; ++j) { \
195 memcpy(tgt_field[i * num_src_fields + j], \
196 src_fields[i][j], tgt_buffer_sizes[j]); \
197 size_t const tgt_count = \
198 tgt_buffer_sizes[j] / sizeof(***src_fields); \
199 YAC_OMP_PARALLEL \
200 { \
201 YAC_OMP_FOR \
202 for (size_t k = 0; k < tgt_count; ++k) \
203 tgt_field[i * num_src_fields + j][k] = \
204 SCALE(tgt_field[i * num_src_fields + j][k]); \
205 } \
206 } \
207 } \
208 }
209
210 COMPUTE_FIELD(COMPUTE_TGT_FIELD_FRAC, COMPUTE_TGT_FIELD_NOFRAC)
211
212#undef COMPUTE_TGT_FIELD_NOFRAC
213#undef COMPUTE_TGT_FIELD_FRAC
214}
215
216#undef MULT_ADD
217#undef ADD
218#undef MULT
219#undef NO_SCALING
220#undef COMPUTE_FIELD
221#undef FRAC_MASK_TOL
222
223#define CHECK_WITH_FRAC_MASK(ROUTINE) \
224 YAC_ASSERT_F( \
225 with_frac_mask == (frac_mask_fallback_value != YAC_FRAC_MASK_NO_VALUE), \
226 "ERROR(%s) " \
227 "with_frac_mask does not match value provided to constructor\n" \
228 "(frac_mask_fallback_value = %lf with_frac_mask = %d " \
229 "with_frac_mask(constructor) %d)", (ROUTINE), \
230 frac_mask_fallback_value, \
231 frac_mask_fallback_value != YAC_FRAC_MASK_NO_VALUE, with_frac_mask)
232
237
238struct yac_interpolation_buffer {
239
240 double ** buffer;
241 size_t * buffer_sizes;
242};
243
244struct yac_interpolation_buffer yac_interpolation_buffer_init(
245 Xt_redist * redists, size_t num_fields, size_t collection_size,
246 enum yac_interpolation_buffer_type type);
247
248struct yac_interpolation_buffer yac_interpolation_buffer_init_2(
249 Xt_redist * redists, size_t * min_buffer_sizes, size_t num_fields,
250 size_t collection_size, enum yac_interpolation_buffer_type type);
251
252struct yac_interpolation_buffer yac_interpolation_buffer_copy(
253 struct yac_interpolation_buffer buffer, size_t num_fields,
254 size_t collection_size);
255
256void yac_interpolation_buffer_free(struct yac_interpolation_buffer * buffer);
257
258#endif // INTERPOLATION_UTILS_H
type
enum callback_type type
Definition interp_method_check.c:95
COMPUTE_TGT_FIELD_WGT_FRAC
#define COMPUTE_TGT_FIELD_WGT_FRAC(SCALE)
yac_interpolation_buffer_copy
struct yac_interpolation_buffer yac_interpolation_buffer_copy(struct yac_interpolation_buffer buffer, size_t num_fields, size_t collection_size)
Definition interpolation_utils.c:115
COMPUTE_FIELD
#define COMPUTE_FIELD(COMPUTE_FIELD_FRAC, COMPUTE_FIELD_NOFRAC)
compute_tgt_field
static void compute_tgt_field(double const *restrict **src_fields, double const *restrict **src_frac_masks, double *restrict *tgt_field, size_t *restrict tgt_buffer_sizes, size_t num_src_fields, size_t collection_size, double frac_mask_fallback_value, double scale_factor, double scale_summand)
Definition interpolation_utils.h:156
COMPUTE_TGT_FIELD_FRAC
#define COMPUTE_TGT_FIELD_FRAC(SCALE)
yac_interpolation_buffer_init_2
struct yac_interpolation_buffer yac_interpolation_buffer_init_2(Xt_redist *redists, size_t *min_buffer_sizes, size_t num_fields, size_t collection_size, enum yac_interpolation_buffer_type type)
Definition interpolation_utils.c:99
compute_tgt_field_wgt
static void compute_tgt_field_wgt(double const *restrict **src_fields, double const *restrict **src_frac_masks, double const *restrict *remote_src_fields, double const *restrict *remote_src_frac_masks, double *restrict *tgt_field, size_t const *restrict tgt_pos, size_t tgt_count, size_t const *restrict prefix_num_src_per_tgt, double const *restrict weights, size_t const *restrict src_field_idx, size_t const *restrict src_idx, size_t num_src_fields, size_t collection_size, double frac_mask_fallback_value, double scale_factor, double scale_summand)
Definition interpolation_utils.h:13
yac_interpolation_buffer_free
void yac_interpolation_buffer_free(struct yac_interpolation_buffer *buffer)
Definition interpolation_utils.c:126
COMPUTE_TGT_FIELD_NOFRAC
#define COMPUTE_TGT_FIELD_NOFRAC(SCALE)
COMPUTE_TGT_FIELD_WGT_NOFRAC
#define COMPUTE_TGT_FIELD_WGT_NOFRAC(SCALE)
yac_interpolation_buffer_type
yac_interpolation_buffer_type
Definition interpolation_utils.h:233
SEND_BUFFER
@ SEND_BUFFER
Definition interpolation_utils.h:234
RECV_BUFFER
@ RECV_BUFFER
Definition interpolation_utils.h:235
yac_interpolation_buffer_init
struct yac_interpolation_buffer yac_interpolation_buffer_init(Xt_redist *redists, size_t num_fields, size_t collection_size, enum yac_interpolation_buffer_type type)
Definition interpolation_utils.c:87
ppm_xfuncs.h
add versions of standard API functions not returning on error
yac_interpolation_buffer
Definition interpolation_utils.h:238
yac_interpolation_buffer::buffer
double ** buffer
Definition interpolation_utils.h:240
yac_interpolation_buffer::buffer_sizes
size_t * buffer_sizes
Definition interpolation_utils.h:241
utils_common.h
Generated on Mon Apr 8 2024 08:41:03 for YetAnotherCoupler by doxygen 1.9.8