@@ -830,17 +830,16 @@ finalize_internal (int status_code)
830
830
MPI_Cancel (& alive_request );
831
831
832
832
if (status_code == 0 ) {
833
- /* In finalization don't stopped or failed images any more. */
833
+ /* In finalization do not report stopped or failed images any more. */
834
834
MPI_Errhandler_set (CAF_COMM_WORLD , MPI_ERRORS_RETURN );
835
- // MPI_Errhandler_set (lock_comm, MPI_ERRORS_RETURN);
836
835
MPI_Errhandler_set (alive_comm , MPI_ERRORS_RETURN );
837
836
/* Only add a conventional barrier to prevent images from quitting to early,
838
837
* when this images is not failing. */
839
838
dprint ("%d/%d: %s: Before MPI_Barrier (CAF_COMM_WORLD)\n" ,
840
- caf_this_image , caf_num_images , __FUNCTION__ );
839
+ caf_this_image , caf_num_images , __FUNCTION__ );
841
840
int ierr = MPI_Barrier (CAF_COMM_WORLD );
842
841
dprint ("%d/%d: %s: After MPI_Barrier (CAF_COMM_WORLD) = %d\n" ,
843
- caf_this_image , caf_num_images , __FUNCTION__ , ierr );
842
+ caf_this_image , caf_num_images , __FUNCTION__ , ierr );
844
843
}
845
844
else
846
845
return ;
@@ -871,18 +870,18 @@ finalize_internal (int status_code)
871
870
prev = tmp_tot -> prev ;
872
871
p = TOKEN (tmp_tot -> token );
873
872
dprint ("%d/%d: %s: Before CAF_Win_unlock_all (*p)\n" ,
874
- caf_this_image , caf_num_images , __FUNCTION__ );
873
+ caf_this_image , caf_num_images , __FUNCTION__ );
875
874
CAF_Win_unlock_all (* p );
876
875
dprint ("%d/%d: %s: After CAF_Win_unlock_all (*p)\n" ,
877
- caf_this_image , caf_num_images , __FUNCTION__ );
876
+ caf_this_image , caf_num_images , __FUNCTION__ );
878
877
#ifdef GCC_GE_7
879
878
/* Unregister the window to the descriptors when freeing the token. */
880
879
mpi_caf_token_t * mpi_token = (mpi_caf_token_t * )tmp_tot -> token ;
881
880
if (mpi_token -> desc )
882
881
{
883
882
CAF_Win_unlock_all (* (mpi_token -> desc ));
884
- MPI_Win_free (mpi_token -> desc );
885
- free (mpi_token -> desc );
883
+ MPI_Win_free (mpi_token -> desc );
884
+ free (mpi_token -> desc );
886
885
}
887
886
MPI_Win_free (p );
888
887
/* Free the memory only, when it was allocated by the caf-library. */
@@ -1046,7 +1045,7 @@ PREFIX (register) (size_t size, caf_register_t type, caf_token_t *token,
1046
1045
if (type == CAF_REGTYPE_COARRAY_ALLOC_REGISTER_ONLY )
1047
1046
{
1048
1047
int ierr = MPI_Win_create_dynamic (MPI_INFO_NULL , CAF_COMM_WORLD , p );
1049
- fprintf ( stderr , "%d/%d: Register win = %p, ierr= %d\n" , caf_this_image , caf_num_images ,
1048
+ dprint ( "%d/%d: Register win = %p, ierr= %d\n" , caf_this_image , caf_num_images ,
1050
1049
* p , ierr );
1051
1050
CAF_Win_lock_all (* p );
1052
1051
}
@@ -1058,7 +1057,7 @@ PREFIX (register) (size_t size, caf_register_t type, caf_token_t *token,
1058
1057
ierr = MPI_Win_attach (* p , mem , actual_size );
1059
1058
CAF_Win_lock_all (* p );
1060
1059
* (mpi_token -> flags ) |= (FLAG_ASSOCIATED | FLAG_MEM_NOT_OWNED );
1061
- fprintf ( stderr , "%d/%d: Attach mem %p to win = %p, ierr: %d, flags: %u\n" ,
1060
+ dprint ( "%d/%d: Attach mem %p to win = %p, ierr: %d, flags: %u\n" ,
1062
1061
caf_this_image , caf_num_images , mem , * p , ierr , * mpi_token -> flags );
1063
1062
}
1064
1063
else
@@ -1184,7 +1183,7 @@ PREFIX (register) (size_t size, caf_register_t type, caf_token_t *token,
1184
1183
free (init_array );
1185
1184
}
1186
1185
1187
- PREFIX (sync_all ) (NULL ,NULL ,0 );
1186
+ PREFIX (sync_all ) (NULL , NULL , 0 );
1188
1187
1189
1188
caf_static_t * tmp = malloc (sizeof (caf_static_t ));
1190
1189
tmp -> prev = caf_tot ;
@@ -1364,7 +1363,7 @@ PREFIX (sync_all) (int *stat, char *errmsg, int errmsg_len)
1364
1363
{
1365
1364
int ierr = 0 ;
1366
1365
1367
- fprintf ( stderr , "%d/%d: Entering sync all.\n" , caf_this_image , caf_num_images );
1366
+ dprint ( "%d/%d: Entering sync all.\n" , caf_this_image , caf_num_images );
1368
1367
if (unlikely (caf_is_finalized ))
1369
1368
ierr = STAT_STOPPED_IMAGE ;
1370
1369
else
@@ -1414,7 +1413,7 @@ PREFIX (sync_all) (int *stat, char *errmsg, int errmsg_len)
1414
1413
else if (stat == NULL )
1415
1414
caf_runtime_error (msg );
1416
1415
}
1417
- fprintf ( stderr , "%d/%d: Leaving sync all.\n" , caf_this_image , caf_num_images );
1416
+ dprint ( "%d/%d: Leaving sync all.\n" , caf_this_image , caf_num_images );
1418
1417
}
1419
1418
1420
1419
/* token: The token of the array to be written to. */
@@ -2527,7 +2526,7 @@ convert_type (void *dst, int dst_type, int dst_kind, void *src, int src_type,
2527
2526
}
2528
2527
2529
2528
error :
2530
- fprintf (stderr , "libcaf_single RUNTIME ERROR: Cannot convert type %d kind "
2529
+ fprintf (stderr , "libcaf_mpi RUNTIME ERROR: Cannot convert type %d kind "
2531
2530
"%d to type %d kind %d\n" , src_type , src_kind , dst_type , dst_kind );
2532
2531
if (stat )
2533
2532
* stat = 1 ;
@@ -3549,7 +3548,7 @@ PREFIX(is_present) (caf_token_t token, int image_index, caf_reference_t *refs)
3549
3548
int ierr = MPI_Get (& remote_flags , sizeof (unsigned ), MPI_BYTE ,
3550
3549
image_index - 1 , 0 , sizeof (unsigned ), MPI_BYTE ,
3551
3550
mpi_token -> flags_win );
3552
- fprintf ( stderr , "%d/%d: Got remote_flags[%d] for win %p to be: %u, ierr = %d\n" ,
3551
+ dprint ( "%d/%d: Got remote_flags[%d] for win %p to be: %u, ierr = %d\n" ,
3553
3552
caf_this_image , caf_num_images , image_index , mpi_token -> flags_win ,
3554
3553
remote_flags , ierr );
3555
3554
return (remote_flags & FLAG_ASSOCIATED ) > 0 ;
0 commit comments