Continue changing printf

mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint_template.c

@@ -68,7 +68,7 @@ int set_pending_checkpoint_template(starpu_mpi_checkpoint_template_t _pending_ch
 	int ret=starpu_pthread_mutex_trylock(&checkpoint_pending_mutex);
 	if (EBUSY==ret)
 	{
-		fprintf(stderr, "The process is blocked, a checkpoint has been submitted while the previous one's "
+		_STARPU_DISP("[warning] The process is blocked, a checkpoint has been submitted while the previous one's "
 		                "submission has not ended. The submission has to wait, try to submit checkpoint "
 		                "less frequently.\n");
 		starpu_pthread_mutex_lock(&checkpoint_pending_mutex);

mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint_template.h

@@ -151,7 +151,7 @@ static inline int _checkpoint_template_add_to_backup_arrays(starpu_mpi_checkpoin
 	}
 	else
 	{
-		fprintf(stderr, "Checkpoint template item does not refer any backup information. This should not happen.\n");
+		_STARPU_DISP("[warning] Checkpoint template item does not refer any backup information. This should not happen.\n");
 	}
 }
 

mpi/src/starpu_mpi.c

@@ -188,7 +188,7 @@ struct _starpu_mpi_req* _starpu_mpi_isend_cache_aware(starpu_data_handle_t data_
 	}
 	else
 	{
-		fprintf(stderr, "STARPU CACHE: Data already sent\n");
+		_STARPU_MPI_DEBUG(1, "STARPU CACHE: Data already sent\n");
 		starpu_data_acquire_cb(data_handle, STARPU_R, alt_callback, _alt_arg);
 	}
 	return req;
@@ -270,7 +270,7 @@ struct _starpu_mpi_req* _starpu_mpi_irecv_cache_aware(starpu_data_handle_t data_
 	}
 	else
 	{
-		fprintf(stderr, "STARPU CACHE: Data already received\n");
+		_STARPU_MPI_DEBUG(1, "STARPU CACHE: Data already received\n");
 		starpu_data_acquire_cb(data_handle, STARPU_R, alt_callback, _alt_arg);
 	}
 	return req;