@@ -333,31 +333,31 @@ ompi_osc_sm_put_with_notify(const void *origin_addr,
333333 int notify ,
334334 struct ompi_win_t * win )
335335{
336- int ret ;
337- ompi_osc_sm_module_t * module =
338- (ompi_osc_sm_module_t * ) win -> w_osc_module ;
339- void * remote_address ;
340-
341- OPAL_OUTPUT_VERBOSE ((50 , ompi_osc_base_framework .framework_output ,
342- "put_notify: 0x%lx, %zu, %s, %d, %d, %zu, %s, %d, 0x%lx" ,
343- (unsigned long ) origin_addr , origin_count ,
344- origin_dt -> name , target , (int ) target_disp ,
345- target_count , target_dt -> name ,
346- notify ,
347- (unsigned long ) win ));
348-
349- remote_address = ((char * ) (module -> bases [target ])) + module -> disp_units [target ] * target_disp ;
350-
351- ret = ompi_datatype_sndrcv ((void * )origin_addr , origin_count , origin_dt ,
352- remote_address , target_count , target_dt );
353- if (OMPI_SUCCESS != ret ) {
354- return ret ;
355- }
336+ int ret ;
337+ ompi_osc_sm_module_t * module =
338+ (ompi_osc_sm_module_t * ) win -> w_osc_module ;
339+ void * remote_address ;
340+
341+ OPAL_OUTPUT_VERBOSE ((50 , ompi_osc_base_framework .framework_output ,
342+ "put_notify: 0x%lx, %zu, %s, %d, %d, %zu, %s, %d, 0x%lx" ,
343+ (unsigned long ) origin_addr , origin_count ,
344+ origin_dt -> name , target , (int ) target_disp ,
345+ target_count , target_dt -> name ,
346+ notify ,
347+ (unsigned long ) win ));
348+
349+ remote_address = ((char * ) (module -> bases [target ])) + module -> disp_units [target ] * target_disp ;
350+
351+ ret = ompi_datatype_sndrcv ((void * )origin_addr , origin_count , origin_dt ,
352+ remote_address , target_count , target_dt );
353+ if (OMPI_SUCCESS != ret ) {
354+ return ret ;
355+ }
356356
357- opal_atomic_wmb ();
358- opal_atomic_add (& module -> notify_counters [target ][notify ], 1 );
357+ opal_atomic_wmb ();
358+ opal_atomic_add (& module -> notify_counters [target ][notify ], 1 );
359359
360- return ret ;
360+ return ret ;
361361}
362362
363363int
@@ -419,7 +419,7 @@ ompi_osc_sm_get_with_notify(void *origin_addr,
419419 ret = ompi_datatype_sndrcv (remote_address , target_count , target_dt ,
420420 origin_addr , origin_count , origin_dt );
421421 if (OMPI_SUCCESS != ret ) {
422- return ret ;
422+ return ret ;
423423 }
424424 opal_atomic_rmb ();
425425 opal_atomic_add (& module -> notify_counters [target ][notify ], 1 );
@@ -598,5 +598,5 @@ ompi_osc_sm_fetch_and_op(const void *origin_addr,
598598 done :
599599 opal_atomic_unlock (& module -> node_states [target ].accumulate_lock );
600600
601- return OMPI_SUCCESS ;;
602- }
601+ return OMPI_SUCCESS ;
602+ }
0 commit comments