Romain LION пре 5 година
родитељ
комит
86bcd60738

+ 7 - 7
mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint_template.c

@@ -521,13 +521,13 @@ int _starpu_mpi_checkpoint_template_print(starpu_mpi_checkpoint_template_t cp_te
 		}
 		else if (item->type == STARPU_DATA_ARRAY)
 		{
-			fprintf(stderr, "STARPU_DATA_ARRAY - Multiple values: %d", *(int*)starpu_data_handle_to_pointer(((starpu_data_handle_t)item->ptr), 0));
-
-			for (int j=1 ; j<MIN(item->count, 5) ; j++)
-			{
-				fprintf(stderr, ", %d", *(int*)starpu_data_handle_to_pointer(((starpu_data_handle_t*)item->ptr)[j], 0)); //j*sizeof(starpu_data_handle_t)
-			}
-			fprintf(stderr, "...\n");
+//			fprintf(stderr, "STARPU_DATA_ARRAY - Multiple values: %d", *(int*)starpu_data_handle_to_pointer(((starpu_data_handle_t)item->ptr), 0));
+//
+//			for (int j=1 ; j<MIN(item->count, 5) ; j++)
+//			{
+//				fprintf(stderr, ", %d", *(int*)starpu_data_handle_to_pointer(((starpu_data_handle_t*)item->ptr)[j], 0)); //j*sizeof(starpu_data_handle_t)
+//			}
+//			fprintf(stderr, "...\n");
 		}
 		else
 		{

+ 0 - 3
mpi/src/starpu_mpi_cache.c

@@ -23,9 +23,6 @@
 #include <starpu_mpi_private.h>
 #include <mpi_failure_tolerance/starpu_mpi_ft_stats.h>
 
-#define STARPU_CACHE_IN_CACHE                (1U<<0U)
-#define STARPU_CACHE_FT_INDUCED_IN_CACHE     (1<<1)
-
 /* Whether we are allowed to keep copies of remote data. */
 struct _starpu_data_entry
 {

+ 2 - 2
mpi/src/starpu_mpi_private.h

@@ -197,8 +197,8 @@ struct _starpu_mpi_coop_sends
 
 struct _starpu_cache_info
 {
-	int in_cache:1;
-	int ft_induced_cache:1;
+	unsigned int in_cache:1;
+	unsigned int ft_induced_cache:1;
 };
 
 /** Initialized in starpu_mpi_data_register_comm */

+ 1 - 1
src/util/starpu_data_cpy.c

@@ -198,7 +198,7 @@ int starpu_data_dup_ro(starpu_data_handle_t *dst_handle, starpu_data_handle_t sr
 	_starpu_spin_unlock(&src_handle->header_lock);
 
 	starpu_data_register_same(dst_handle, src_handle);
-//	(*dst_handle)->mpi_data = src_handle->mpi_data;
+	(*dst_handle)->mpi_data = src_handle->mpi_data;
 	_starpu_data_cpy(*dst_handle, src_handle, asynchronous, NULL, NULL, 0, NULL);
 	(*dst_handle)->readonly = 1;