@@ -180,14 +180,9 @@ component_select(struct ompi_win_t *win, void **base, size_t size, int disp_unit
180
180
calloc (1 , sizeof (ompi_osc_sm_module_t ));
181
181
if (NULL == module ) return OMPI_ERR_TEMP_OUT_OF_RESOURCE ;
182
182
183
- OBJ_CONSTRUCT (& module -> lock , opal_mutex_t );
184
-
185
- ret = opal_infosubscribe_subscribe (& (win -> super ), "blocking_fence" , "false" ,
186
- component_set_blocking_fence_info );
187
-
188
- module -> global_state -> use_barrier_for_fence = 1 ;
183
+ win -> w_osc_module = & module -> super ;
189
184
190
- if ( OPAL_SUCCESS != ret ) goto error ;
185
+ OBJ_CONSTRUCT ( & module -> lock , opal_mutex_t ) ;
191
186
192
187
ret = opal_infosubscribe_subscribe (& (win -> super ), "alloc_shared_contig" , "false" , component_set_alloc_shared_noncontig_info );
193
188
@@ -390,18 +385,20 @@ component_select(struct ompi_win_t *win, void **base, size_t size, int disp_unit
390
385
#endif
391
386
}
392
387
388
+ ret = opal_infosubscribe_subscribe (& (win -> super ), "blocking_fence" , "false" ,
389
+ component_set_blocking_fence_info );
390
+
391
+ if (OPAL_SUCCESS != ret ) goto error ;
392
+
393
393
ret = module -> comm -> c_coll -> coll_barrier (module -> comm ,
394
394
module -> comm -> c_coll -> coll_barrier_module );
395
395
if (OMPI_SUCCESS != ret ) goto error ;
396
396
397
397
* model = MPI_WIN_UNIFIED ;
398
398
399
- win -> w_osc_module = & module -> super ;
400
-
401
399
return OMPI_SUCCESS ;
402
400
403
401
error :
404
- win -> w_osc_module = & module -> super ;
405
402
ompi_osc_sm_free (win );
406
403
407
404
return ret ;
0 commit comments