@@ -247,7 +247,7 @@ typedef struct mca_coll_han_single_collective_fallback_s {
247
247
mca_coll_base_module_gather_fn_t gather ;
248
248
mca_coll_base_module_reduce_fn_t reduce ;
249
249
mca_coll_base_module_scatter_fn_t scatter ;
250
- };
250
+ } module_fn ;
251
251
mca_coll_base_module_t * module ;
252
252
} mca_coll_han_single_collective_fallback_t ;
253
253
@@ -316,36 +316,36 @@ OBJ_CLASS_DECLARATION(mca_coll_han_module_t);
316
316
* Some defines to stick to the naming used in the other components in terms of
317
317
* fallback routines
318
318
*/
319
- #define previous_allgather fallback.allgather.allgather
319
+ #define previous_allgather fallback.allgather.module_fn. allgather
320
320
#define previous_allgather_module fallback.allgather.module
321
321
322
- #define previous_allgatherv fallback.allgatherv.allgatherv
322
+ #define previous_allgatherv fallback.allgatherv.module_fn. allgatherv
323
323
#define previous_allgatherv_module fallback.allgatherv.module
324
324
325
- #define previous_allreduce fallback.allreduce.allreduce
325
+ #define previous_allreduce fallback.allreduce.module_fn. allreduce
326
326
#define previous_allreduce_module fallback.allreduce.module
327
327
328
- #define previous_barrier fallback.barrier.barrier
328
+ #define previous_barrier fallback.barrier.module_fn. barrier
329
329
#define previous_barrier_module fallback.barrier.module
330
330
331
- #define previous_bcast fallback.bcast.bcast
331
+ #define previous_bcast fallback.bcast.module_fn. bcast
332
332
#define previous_bcast_module fallback.bcast.module
333
333
334
- #define previous_reduce fallback.reduce.reduce
334
+ #define previous_reduce fallback.reduce.module_fn. reduce
335
335
#define previous_reduce_module fallback.reduce.module
336
336
337
- #define previous_gather fallback.gather.gather
337
+ #define previous_gather fallback.gather.module_fn. gather
338
338
#define previous_gather_module fallback.gather.module
339
339
340
- #define previous_scatter fallback.scatter.scatter
340
+ #define previous_scatter fallback.scatter.module_fn. scatter
341
341
#define previous_scatter_module fallback.scatter.module
342
342
343
343
344
344
/* macro to correctly load a fallback collective module */
345
345
#define HAN_LOAD_FALLBACK_COLLECTIVE (HANM , COMM , COLL ) \
346
346
do { \
347
347
if ( ((COMM)->c_coll->coll_ ## COLL ## _module) == (mca_coll_base_module_t*)(HANM) ) { \
348
- (COMM)->c_coll->coll_ ## COLL = (HANM)->fallback.COLL.COLL; \
348
+ (COMM)->c_coll->coll_ ## COLL = (HANM)->fallback.COLL.module_fn. COLL; \
349
349
mca_coll_base_module_t *coll_module = (COMM)->c_coll->coll_ ## COLL ## _module; \
350
350
(COMM)->c_coll->coll_ ## COLL ## _module = (HANM)->fallback.COLL.module; \
351
351
OBJ_RETAIN((COMM)->c_coll->coll_ ## COLL ## _module); \
0 commit comments